From 53bd785304f4ecb62f46e19f02183a858aebe027 Mon Sep 17 00:00:00 2001 From: ShazaAli Date: Sun, 1 Dec 2024 08:23:40 -0500 Subject: running all. error comm between FE Replica --- src/main/java/derms/Replica1.java | 160 ++++++++++++++++++++++---------------- 1 file changed, 92 insertions(+), 68 deletions(-) (limited to 'src/main/java/derms/Replica1.java') diff --git a/src/main/java/derms/Replica1.java b/src/main/java/derms/Replica1.java index 1df25a2..ad8b7a0 100644 --- a/src/main/java/derms/Replica1.java +++ b/src/main/java/derms/Replica1.java @@ -8,90 +8,114 @@ import java.net.InetSocketAddress; import java.util.logging.Logger; public class Replica1 implements Replica { - private final ReliableUnicastSender unicastSender; - ReplicaManager replicaManager; - private final Logger log; - private boolean alive = true; - - public Replica1( InetSocketAddress frontEndAddress) throws IOException { - this.unicastSender = new ReliableUnicastSender(frontEndAddress); - this.log = Logger.getLogger(getClass().getName()); - } - - @Override public boolean isAlive() { - return alive; + return false; } @Override public void startProcess() { - // Simulate the replica process starting. - log.info("Replica " + 1 + " started."); + } @Override public void processRequest(Request request) { - // Process the request and create a response. - endpoint1 = Endpoint.publish("http://localhost:8080/ws/derms", new DERMSServer("MTL")); - endpoint2 = Endpoint.publish("http://localhost:8081/ws/derms", new DERMSServer("QUE")); - endpoint3 = Endpoint.publish("http://localhost:8082/ws/derms", new DERMSServer("SHE")); - - String responseMessage; - switch (request.getFunction()) { - case "addResource": - responderClient = new ResponderClient(request.getClientID()); - responseMessage = responderClient.addResource(request.getResourceID(), request.getResourceType(), request.getDuration()); - break; - case "removeResource": - responderClient = new ResponderClient(request.getClientID()); - responseMessage = responderClient.removeResource(request.getResourceID(), request.getDuration()); - break; - case "listResourceAvailability": - responderClient = new ResponderClient(request.getClientID()); - responseMessage = responderClient.listResourceAvailability(request.getResourceType()); - break; - case "requestResource": - coordinatorClient = new CoordinatorClient(request.getClientID()); - responseMessage = coordinatorClient.requestResource(request.getClientID(), request.getResourceID(), request.getDuration()); - break; - case "findResource": - coordinatorClient = new CoordinatorClient(request.getClientID()); - responseMessage = coordinatorClient.findResource(request.getClientID(), request.getResourceType()); - break; - case "returnResource": - coordinatorClient = new CoordinatorClient(request.getClientID()); - responseMessage = coordinatorClient.returnResource(request.getClientID(), request.getResourceID()); - break; - case "swapResource": - coordinatorClient = new CoordinatorClient(request.getClientID()); - responseMessage = coordinatorClient.swapResource( - request.getClientID(), - request.getOldResourceID(), - request.getOldResourceType(), - request.getResourceID(), - request.getResourceType() - ); - break; - default: - responseMessage = "Unrecognized function: " + request.getFunction(); - log.severe("Unrecognized function in request: " + request.getFunction()); - break; - } - - Response response = new Response(request.getSequenceNumber(), responseMessage); - log.info("Replica " + 1 + " processed request: " + request + ", response: " + response); - replicaManager.sendResponseToFE(response); } @Override public void restart() { - // Restart the replica process. - log.warning("Replica " + 1 + " is restarting..."); - startProcess(); + } @Override - public int getId() { return 1; } + public int getId() { + return 0; + } +// private final ReliableUnicastSender unicastSender; +// ReplicaManager replicaManager; +// private final Logger log; +// private boolean alive = true; +// +// public Replica1( InetSocketAddress frontEndAddress) throws IOException { +// this.unicastSender = new ReliableUnicastSender(frontEndAddress); +// this.log = Logger.getLogger(getClass().getName()); +// } +// +// +// @Override +// public boolean isAlive() { +// return alive; +// } +// +// @Override +// public void startProcess() { +// // Simulate the replica process starting. +// log.info("Replica " + 1 + " started."); +// } +// +// @Override +// public void processRequest(Request request) { +// // Process the request and create a response. +// endpoint1 = Endpoint.publish("http://localhost:8080/ws/derms", new DERMSServer("MTL")); +// endpoint2 = Endpoint.publish("http://localhost:8081/ws/derms", new DERMSServer("QUE")); +// endpoint3 = Endpoint.publish("http://localhost:8082/ws/derms", new DERMSServer("SHE")); +// +// +// String responseMessage; +// switch (request.getFunction()) { +// case "addResource": +// responderClient = new ResponderClient(request.getClientID()); +// responseMessage = responderClient.addResource(request.getResourceID(), request.getResourceType(), request.getDuration()); +// break; +// case "removeResource": +// responderClient = new ResponderClient(request.getClientID()); +// responseMessage = responderClient.removeResource(request.getResourceID(), request.getDuration()); +// break; +// case "listResourceAvailability": +// responderClient = new ResponderClient(request.getClientID()); +// responseMessage = responderClient.listResourceAvailability(request.getResourceType()); +// break; +// case "requestResource": +// coordinatorClient = new CoordinatorClient(request.getClientID()); +// responseMessage = coordinatorClient.requestResource(request.getClientID(), request.getResourceID(), request.getDuration()); +// break; +// case "findResource": +// coordinatorClient = new CoordinatorClient(request.getClientID()); +// responseMessage = coordinatorClient.findResource(request.getClientID(), request.getResourceType()); +// break; +// case "returnResource": +// coordinatorClient = new CoordinatorClient(request.getClientID()); +// responseMessage = coordinatorClient.returnResource(request.getClientID(), request.getResourceID()); +// break; +// case "swapResource": +// coordinatorClient = new CoordinatorClient(request.getClientID()); +// responseMessage = coordinatorClient.swapResource( +// request.getClientID(), +// request.getOldResourceID(), +// request.getOldResourceType(), +// request.getResourceID(), +// request.getResourceType() +// ); +// break; +// default: +// responseMessage = "Unrecognized function: " + request.getFunction(); +// log.severe("Unrecognized function in request: " + request.getFunction()); +// break; +// } +// +// Response response = new Response(request.getSequenceNumber(), responseMessage); +// log.info("Replica " + 1 + " processed request: " + request + ", response: " + response); +// replicaManager.sendResponseToFE(response); +// } +// +// @Override +// public void restart() { +// // Restart the replica process. +// log.warning("Replica " + 1 + " is restarting..."); +// startProcess(); +// } +// +// @Override +// public int getId() { return 1; } } \ No newline at end of file -- cgit v1.2.3