diff options
Diffstat (limited to 'src/main/java/derms/Replica1.java')
| -rw-r--r-- | src/main/java/derms/Replica1.java | 121 |
1 files changed, 0 insertions, 121 deletions
diff --git a/src/main/java/derms/Replica1.java b/src/main/java/derms/Replica1.java deleted file mode 100644 index ad8b7a0..0000000 --- a/src/main/java/derms/Replica1.java +++ /dev/null @@ -1,121 +0,0 @@ -package derms; - -import derms.net.runicast.ReliableUnicastSender; - -import javax.xml.ws.Endpoint; -import java.io.IOException; -import java.net.InetSocketAddress; -import java.util.logging.Logger; - -public class Replica1 implements Replica { - @Override - public boolean isAlive() { - return false; - } - - @Override - public void startProcess() { - - } - - @Override - public void processRequest(Request request) { - - } - - @Override - public void restart() { - - } - - @Override - public int getId() { - return 0; - } -// private final ReliableUnicastSender<Response> unicastSender; -// ReplicaManager replicaManager; -// private final Logger log; -// private boolean alive = true; -// -// public Replica1( InetSocketAddress frontEndAddress) throws IOException { -// this.unicastSender = new ReliableUnicastSender<Response>(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 |