clients to support distributed communication (trial 1)

LENOVO-PC\Vasilis · LENOVO-PC\Vasilis · commit 0a9fa2873dd4 · 2018-12-18T18:49:52.000+01:00
diff --git a/Assignment3/src/assignment3/server/Client1.java b/Assignment3/src/assignment3/server/Client1.java
@@ -4,6 +4,7 @@
 import java.io.IOException;
 import java.rmi.AlreadyBoundException;
 import java.rmi.NotBoundException;
+import java.rmi.RemoteException;
 import java.rmi.registry.LocateRegistry;
 import java.rmi.registry.Registry;
 import java.util.ArrayList;
@@ -31,7 +32,7 @@ public static void main(String[] args) throws AlreadyBoundException, NotBoundExc
     	links = new HashMap<Integer, List<Link>>();
     	initializeEdges();
         // "clients" files contain the name of the remote processes used
-        BufferedReader br = new BufferedReader(new FileReader("tests/nodes1.txt"));
+        BufferedReader br = new BufferedReader(new FileReader("tests/nodes2.txt"));
         String line = br.readLine();
         numProc = Integer.parseInt(line);
         localProc = 0;
@@ -48,7 +49,16 @@ public static void main(String[] args) throws AlreadyBoundException, NotBoundExc
             	localIDS.add(i);
         	}
         	else{
-        		registry.bind("//145.94.233.58:"+Constant.RMI_PORT+"/"+split_line[0], new Node(i, new PriorityQueue<Link>(links.get(i))));
+        		boolean success = false;
+        		while (!success){
+	        		try{
+	        			registry.bind("//145.94.233.58:"+Constant.RMI_PORT+"/"+split_line[0], new Node(i, new PriorityQueue<Link>(links.get(i))));
+	        			success = true;
+	        		}
+	        		catch (RemoteException e) {
+	                    e.printStackTrace();
+	                }
+        		}
         		local[i] = 0;
 
         	}
@@ -63,7 +73,7 @@ public static void main(String[] args) throws AlreadyBoundException, NotBoundExc
     }
     
     public static void initializeEdges() throws IOException{
-    	BufferedReader br = new BufferedReader(new FileReader("tests/edges1.txt"));
+    	BufferedReader br = new BufferedReader(new FileReader("tests/edges2.txt"));
         String line;
         int node1;
         int node2;
@@ -118,7 +128,7 @@ public static void setRegistry() throws NotBoundException, NumberFormatException
         System.out.println("Press enter to continue");
         Scanner scan = new Scanner(System.in);
         scan.nextLine();
-         myThreads[0].start();
+        myThreads[0].start();
 		myThreads[1].start();
     }
 }
diff --git a/Assignment3/src/assignment3/server/Client2.java b/Assignment3/src/assignment3/server/Client2.java
@@ -4,11 +4,16 @@
 import java.io.IOException;
 import java.rmi.AlreadyBoundException;
 import java.rmi.NotBoundException;
+import java.rmi.RemoteException;
 import java.rmi.registry.LocateRegistry;
 import java.rmi.registry.Registry;
 import java.util.ArrayList;
+import java.util.PriorityQueue;
 import java.util.Scanner;
+
+import assignment3.link.Link;
 import assignment3.node.IComponent;
+import assignment3.node.Node;
 
 public class Client2 {
 	private static IComponent[] RMI_IDS; // Array with the remote processes
@@ -48,7 +53,18 @@ public static void main(String[] args) throws AlreadyBoundException, NotBoundExc
     }
     
     public static void setRegistry() throws NotBoundException, NumberFormatException, IOException{
-    	Registry registry = LocateRegistry.getRegistry("145.94.186.211", Constant.RMI_PORT);
+    	boolean success = false;
+    	Registry registry = null;
+		while (!success){
+    		try{
+    			registry = LocateRegistry.getRegistry("145.94.186.211", Constant.RMI_PORT);
+    			success = true;
+    		}
+    		catch (RemoteException e) {
+                e.printStackTrace();
+            }
+		}
+    	//Registry registry = LocateRegistry.getRegistry("145.94.186.211", Constant.RMI_PORT);
         RMI_IDS = new IComponent[numProc]; // the remote process array is instantiated
         Thread[] myThreads = new Thread[numProc]; // and numProc number of threads are created
         for(int i=0; i<numProc; i++){
