From 411ca5e6242e3db3b1177ddfe5316ba8b85ef7e5 Mon Sep 17 00:00:00 2001
From: Theodora-Mara Pislar <tmp1u19@soton.ac.uk>
Date: Mon, 26 Apr 2021 14:37:23 +0100
Subject: [PATCH] Small piece of code added
---
src/Controller.java | 22 ++++++++++++++++++++++
src/Dstore.java | 2 +-
2 files changed, 23 insertions(+), 1 deletion(-)
diff --git a/src/Controller.java b/src/Controller.java
index 7ab2ca8..3d53363 100644
--- a/src/Controller.java
+++ b/src/Controller.java
@@ -19,6 +19,28 @@ public class Controller {
// how long to wait to start the next rebalance operation
int rebalance_period = Integer.parseInt(args[3]);
+ System.out.println("Started");
+
+ try {
+ ServerSocket socket = new ServerSocket(cport);
+ socket.setSoTimeout(10 * timeout);
+ for(;;) {
+ try {
+ if(R > 0) {
+ Socket client = socket.accept();
+ R = R - 1;
+ } else {
+
+ }
+
+ } catch (Exception e1) {
+ System.out.println(e1);
+ }
+ }
+
+ } catch (IOException e) {
+ System.out.println("error" + e);
+ }
}
}
\ No newline at end of file
diff --git a/src/Dstore.java b/src/Dstore.java
index 7c65791..bb258a8 100644
--- a/src/Dstore.java
+++ b/src/Dstore.java
@@ -11,6 +11,6 @@ public class Dstore {
// where to store the data locally
String file_folder = args[3];
-
+ System.out.println("Adding");
}
}
\ No newline at end of file
--
GitLab