summaryrefslogtreecommitdiffstats
path: root/src/main/java/derms/client/CoordinatorClient.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/derms/client/CoordinatorClient.java')
-rw-r--r--src/main/java/derms/client/CoordinatorClient.java112
1 files changed, 12 insertions, 100 deletions
diff --git a/src/main/java/derms/client/CoordinatorClient.java b/src/main/java/derms/client/CoordinatorClient.java
index 570d76b..40d8a94 100644
--- a/src/main/java/derms/client/CoordinatorClient.java
+++ b/src/main/java/derms/client/CoordinatorClient.java
@@ -4,116 +4,28 @@ import derms.frontend.DERMSInterface;
import java.net.MalformedURLException;
-public class CoordinatorClient extends CLI {
- public static final String usage = "Usage: java derms.client.CoordinatorClient <coordinator ID> <FE host>";
-
- private final String coordinatorID;
+public class CoordinatorClient {
private final DERMSInterface server;
+ private final String coordinatorID;
- private CoordinatorClient(String coordinatorID, String FEhost) throws MalformedURLException {
- this.coordinatorID = coordinatorID;
+ public CoordinatorClient(String coordinatorID, String FEhost) throws MalformedURLException {
this.server = Client.connectToServer(FEhost);
-
- commands.put("request", new Request());
- cmdDescriptions.add(new Description(
- "request <resource ID> <duration>",
- "Borrow a resource."));
-
- commands.put("find", new Find());
- cmdDescriptions.add(new Description(
- "find <resource name>",
- "List borrowed resources."));
-
- commands.put("return", new Return());
- cmdDescriptions.add(new Description(
- "return <resource ID>",
- "Return a borrowed resource."));
-
- commands.put("swap", new Swap());
- cmdDescriptions.add(new Description(
- "swap <old resource ID> <old resource type> <new resource ID> <new resource type>",
- "Return the old resource and borrow the new one."));
- }
-
- public static void main(String[] args) {
- if (args.length < 2) {
- System.err.println(usage);
- System.exit(1);
- }
-
- String coordinatorID = args[0];
- String FEhost = args[1];
-
- try {
- (new CoordinatorClient(coordinatorID, FEhost)).run();
- } catch (MalformedURLException e) {
- e.printStackTrace();
- }
+ this.coordinatorID = coordinatorID;
}
- private class Request implements Command {
- @Override
- public void exec(String[] args) {
- if (args.length < 2)
- System.out.println("invalid arguments for 'request'");
- else
- request(args[0], args[1]);
- }
-
- private void request(String resourceID, String durationStr) {
- try {
- int duration = Integer.parseInt(durationStr);
- if (duration < 0)
- throw new NumberFormatException("duration less than 0");
- String response = server.requestResource(coordinatorID, resourceID, duration);
- System.out.println(response);
- } catch (NumberFormatException e) {
- System.out.println("invalid duration: " + e.getMessage());
- }
- }
+ public String requestResource(String resourceID, int duration) {
+ return server.requestResource(coordinatorID, resourceID, duration);
}
- private class Find implements Command {
- @Override
- public void exec(String[] args) {
- if (args.length < 1)
- System.out.println("invalid arguments for 'find'");
- else find(args[0]);
- }
-
- private void find(String resourceID) {
- String response = server.findResource(coordinatorID, resourceID);
- System.out.println(response);
- }
+ public String findResource(String resourceName) {
+ return server.findResource(coordinatorID, resourceName);
}
- private class Return implements Command {
- @Override
- public void exec(String[] args) {
- if (args.length < 1)
- System.out.println("invalid arguments for 'return'");
- else
- returnResource(args[0]);
- }
-
- private void returnResource(String resourceID) {
- String response = server.returnResource(coordinatorID, resourceID);
- System.out.println(response);
- }
+ public String returnResource(String resourceID) {
+ return server.returnResource(coordinatorID, resourceID);
}
- private class Swap implements Command {
- @Override
- public void exec(String[] args) {
- if (args.length < 4)
- System.out.println("invalid arguments for 'swap'");
- else
- swap(args[0], args[1], args[2], args[3]);
- }
-
- private void swap(String oldResourceID, String oldResourceType, String newResourceID, String newResourceType) {
- String response = server.swapResource(coordinatorID, oldResourceID, oldResourceType, newResourceID, newResourceType);
- System.out.println(response);
- }
+ public String swapResource(String oldResourceID, String oldResourceType, String newResourceID, String newResourceType) {
+ return server.swapResource(coordinatorID, oldResourceID, oldResourceType, newResourceID, newResourceType);
}
}