summaryrefslogtreecommitdiffstats
path: root/src/main/java/derms/replica2/Replica2.java
diff options
context:
space:
mode:
authorShazaAli <shazamamdouh@aucegypt.edu>2024-12-01 08:23:40 -0500
committerShazaAli <shazamamdouh@aucegypt.edu>2024-12-01 08:23:40 -0500
commit53bd785304f4ecb62f46e19f02183a858aebe027 (patch)
treeadbdb888329fab8f406e6eed6c9cb88508d9d1bd /src/main/java/derms/replica2/Replica2.java
parent66f256b05c7daa7c4cd20f20758b8413a9329500 (diff)
downloadsoen423-53bd785304f4ecb62f46e19f02183a858aebe027.zip
running all. error comm between FE Replica
Diffstat (limited to 'src/main/java/derms/replica2/Replica2.java')
-rw-r--r--src/main/java/derms/replica2/Replica2.java6
1 files changed, 4 insertions, 2 deletions
diff --git a/src/main/java/derms/replica2/Replica2.java b/src/main/java/derms/replica2/Replica2.java
index 25609cc..666ee1b 100644
--- a/src/main/java/derms/replica2/Replica2.java
+++ b/src/main/java/derms/replica2/Replica2.java
@@ -1,6 +1,7 @@
package derms.replica2;
import derms.Replica;
+import derms.ReplicaManager;
import derms.Request;
import derms.Response;
import sun.reflect.generics.reflectiveObjects.NotImplementedException;
@@ -23,14 +24,15 @@ public class Replica2 implements Replica {
private final ResponderServer responderServer;
private final CoordinatorServer coordinatorServer;
private boolean alive;
+ private final ReplicaManager replicaManager;
- public Replica2(City city) throws IOException {
+ public Replica2(City city, ReplicaManager replicaManager) throws IOException {
this.city = city;
this.localAddr = InetAddress.getLocalHost();
this.resources = new Resources();
this.servers = new Servers();
this.log = DermsLogger.getLogger(getClass());
-
+ this.replicaManager = replicaManager;
try {
this.responderServer = new ResponderServer(city, resources, servers);
} catch (IOException e) {