diff options
| author | BMatajsz <90217645+BMatajsz@users.noreply.github.com> | 2024-12-02 17:25:26 -0500 |
|---|---|---|
| committer | BMatajsz <90217645+BMatajsz@users.noreply.github.com> | 2024-12-02 17:25:26 -0500 |
| commit | 06b85e583dd9242855b2ca9173a580c766733a25 (patch) | |
| tree | 3328857a43dae98d2d58157e5a01868f2abb8e7a /src/main/java/derms/Replica3.java | |
| parent | 6767d5b22d105cdbae568b4734c6835f2828118d (diff) | |
| download | soen423-06b85e583dd9242855b2ca9173a580c766733a25.zip | |
Added Replica4
Diffstat (limited to 'src/main/java/derms/Replica3.java')
| -rw-r--r-- | src/main/java/derms/Replica3.java | 100 |
1 files changed, 0 insertions, 100 deletions
diff --git a/src/main/java/derms/Replica3.java b/src/main/java/derms/Replica3.java deleted file mode 100644 index b1ee8ce..0000000 --- a/src/main/java/derms/Replica3.java +++ /dev/null @@ -1,100 +0,0 @@ -package derms; - -import derms.Replica3pkg.CoordinatorClient; -import derms.Replica3pkg.RemoteServer; -import derms.Replica3pkg.ResponderClient; -import derms.Replica3pkg.Server; -import derms.net.runicast.ReliableUnicastSender; -import derms.Replica; -import derms.ReplicaManager; -import derms.Request; -import derms.Response; -import javax.xml.ws.Endpoint; -import java.io.IOException; -import java.net.InetSocketAddress; -import java.util.HashMap; -import java.util.Map; -import java.util.logging.Logger; - -public class Replica3 implements Replica { - - private ReplicaManager replicaManager; - private RemoteServer remoteServer; - private boolean alive = true; - - public Replica3(ReplicaManager replicaManager){ - this.replicaManager = replicaManager; - this.remoteServer = new RemoteServer(); - } - - @Override - public boolean isAlive() { - return alive; - } - - @Override - public void startProcess() { - - } - - @Override - public void processRequest(Request request) { - ResponderClient responderClient; - CoordinatorClient coordinatorClient; - 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.getResourceID(), request.getDuration()); - break; - case "findResource": - coordinatorClient = new CoordinatorClient(request.getClientID()); - responseMessage = coordinatorClient.findResource(request.getResourceType()); - break; - case "returnResource": - coordinatorClient = new CoordinatorClient(request.getClientID()); - responseMessage = coordinatorClient.returnResource(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 " + 3 + " processed request: " + request + ", response: " + response); - replicaManager.sendResponseToFE(response); - } - - @Override - public void restart() { - - } - - @Override - public int getId() { - return 3; - } -}
\ No newline at end of file |