X-Git-Url: http://demsky.eecs.uci.edu/git/?a=blobdiff_plain;f=iotjava%2Fiotruntime%2Fmaster%2FCommunicationHandler.java;h=5d257722772b03d9480bb67df92e36967755b6b0;hb=f7ff6050110f71874879912c9b1f6a01745d2d76;hp=fd4340828242297ea6e8a5768a92347139488a1e;hpb=325bdddf294e581e97dcf23bbbcaed7df7efaea8;p=iot2.git

diff --git a/iotjava/iotruntime/master/CommunicationHandler.java b/iotjava/iotruntime/master/CommunicationHandler.java
index fd43408..5d25772 100644
--- a/iotjava/iotruntime/master/CommunicationHandler.java
+++ b/iotjava/iotruntime/master/CommunicationHandler.java
@@ -73,6 +73,13 @@ public final class CommunicationHandler {
 	private int iNumOfHosts;
 	private boolean bVerbose;
 
+	// TODO: THIS IS HACKING FOR IOTSEC
+	// Replace random
+	private int comPortCount = 10000;
+	private int rmiRegCount = 20000;
+	private int rmiStubCount = 30000;
+	private int additionalCount = 40000;
+
 	/**
 	 * CommunicationHandler class constants
 	 */
@@ -165,6 +172,8 @@ public final class CommunicationHandler {
 		int iComPort = 0;
 		do {
 			iComPort = random.nextInt(INT_MAX_PORT - INT_MIN_PORT + 1) + INT_MIN_PORT;
+			//System.out.println("DEBUG: Assigning comPort: " + comPortCount);
+			//iComPort = comPortCount++;
 			// Check port existence in HashMap
 		} while (portIsAvailable(iComPort) == false);
 		hmComPort.put(iNumOfObjects, iComPort);
@@ -174,6 +183,8 @@ public final class CommunicationHandler {
 		int iRMIRegPort = 0;
 		do {
 			iRMIRegPort = random.nextInt(INT_MAX_PORT - INT_MIN_PORT + 1) + INT_MIN_PORT;
+			//System.out.println("DEBUG: Assigning regPort: " + rmiRegCount);
+			//iRMIRegPort = rmiRegCount++;
 			// Check port existence in HashMap
 		} while (portIsAvailable(iRMIRegPort) == false);
 		hmRMIRegPort.put(iNumOfObjects, iRMIRegPort);
@@ -182,6 +193,8 @@ public final class CommunicationHandler {
 		int iRMIStubPort = 0;
 		do {
 			iRMIStubPort = random.nextInt(INT_MAX_PORT - INT_MIN_PORT + 1) + INT_MIN_PORT;
+			//System.out.println("DEBUG: Assigning stubPort: " + rmiStubCount);
+			//iRMIStubPort = rmiStubCount++;
 			// Check port existence in HashMap
 		} while (portIsAvailable(iRMIStubPort) == false);
 		hmRMIStubPort.put(iNumOfObjects, iRMIStubPort);
@@ -246,6 +259,8 @@ public final class CommunicationHandler {
 		int iAdditionalPort = 0;
 		do {
 			iAdditionalPort = random.nextInt(INT_MAX_PORT - INT_MIN_PORT + 1) + INT_MIN_PORT;
+			//System.out.println("DEBUG: Assigning additionalPort: " + additionalCount);
+			//iAdditionalPort = additionalCount++;
 			// Check port existence in HashMap
 		} while (portIsAvailable(iAdditionalPort) == false);
 		hmAdditionalPort.put(iNumOfObjects, iAdditionalPort);
@@ -269,7 +284,7 @@ public final class CommunicationHandler {
 	 */
 	public boolean portIsAvailable(int iPortNumber) {
 
-		/*if (hmComPort.containsValue(iPortNumber) == true) {
+		if (hmComPort.containsValue(iPortNumber) == true) {
 			return false;
 		} else if (hmRMIRegPort.containsValue(iPortNumber) == true) {
 			return false;
@@ -281,12 +296,12 @@ public final class CommunicationHandler {
 			return false;
 		} else {
 			return true;
-		}*/
-		if (hsAllPorts.contains(iPortNumber)) {
-		    return false;
-		} else {
-		    return true;
 		}
+		//if (hsAllPorts.contains(iPortNumber)) {
+		//    return false;
+		//} else {
+		//    return true;
+		//}
 	}
 
 	/**