Skip to content
Snippets Groups Projects
Commit 411ca5e6 authored by tmp1u19's avatar tmp1u19 :octopus:
Browse files

Small piece of code added

parent ce0fb4e1
No related branches found
No related tags found
No related merge requests found
......@@ -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
......@@ -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
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment