diff --git a/src/Controller.java b/src/Controller.java index 7ab2ca8fcf9be1f37c03c8539fb26b25e7a359a1..3d5336387acde9c46420223235ad1843e69540bd 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 7c65791448ba4df434c45a872d7814525aabe67b..bb258a8c159c2cd95fb34aeb1ec399c64684af56 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