running all. error comm between FE Replica

5 files changed, 9 insertions, 7 deletions

diff --git a/src/main/java/derms/replica2/City.java b/src/main/java/derms/replica2/City.java
index 74535ae..a5a2f4c 100644
--- a/src/main/java/derms/replica2/City.java
+++ b/src/main/java/derms/replica2/City.java
@@ -2,7 +2,7 @@ package derms.replica2;
 
 import java.io.Serializable;
 
-class City implements Serializable {
+public class City implements Serializable {
 	static final int codeLen = 3;
 
 	private String code;
@@ -13,7 +13,7 @@ class City implements Serializable {
 		this.code = code;
 	}
 
-	City() {
+	public City() {
 		this("XXX");
 	}
 
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) {
diff --git a/src/main/java/derms/replica2/Resource.java b/src/main/java/derms/replica2/Resource.java
index 31d40bc..404cfb0 100644
--- a/src/main/java/derms/replica2/Resource.java
+++ b/src/main/java/derms/replica2/Resource.java
@@ -20,7 +20,7 @@ class Resource implements Serializable {
   }
 
   Resource(ResourceID id, ResourceType type, int duration) {
-    this(id, type, duration, false, new CoordinatorID(), -1);
+    this(id, type, duration, false, new CoordinatorID("XXX", (short) 1), -1);
   }
 
   Resource() {
diff --git a/src/main/java/derms/replica2/ReturnResource.java b/src/main/java/derms/replica2/ReturnResource.java
index 6c42b8a..6adac50 100644
--- a/src/main/java/derms/replica2/ReturnResource.java
+++ b/src/main/java/derms/replica2/ReturnResource.java
@@ -169,7 +169,7 @@ class ReturnResource {
 								request.resourceID+" is not borrowed by "+request.coordinatorID);
 					}
 					resource.isBorrowed = false;
-					resource.borrower = new CoordinatorID();
+					resource.borrower = request.coordinatorID;
 					resource.borrowDuration = -1;
 					return new Response(Response.Status.SUCCESS, request.coordinatorID+" successfully returned "+resource.id);
 				}
diff --git a/src/main/java/derms/replica2/SwapResource.java b/src/main/java/derms/replica2/SwapResource.java
index cc65f29..fbd2cf9 100644
--- a/src/main/java/derms/replica2/SwapResource.java
+++ b/src/main/java/derms/replica2/SwapResource.java
@@ -219,7 +219,7 @@ class SwapResource {
 
 		private void returnOldResource(Resource r) {
 			r.isBorrowed = false;
-			r.borrower = new CoordinatorID();
+			r.borrower = request.cid;
 			r.borrowDuration = -1;
 		}
 	}