/** Class CommunicationHandler is a class that maintains
* a data structure that preserves a collection of host name,
* port numbers, and objects that are running
- * +-----------------+----+--------+------------------+--------------+----------------+
- * | HOST-ADDRESS | ...|IN-PORT | RMIREGISTRY-PORT | RMISTUB-PORT | ACTIVE OBJECTS |
- * +-----------------+----+--------+------------------+--------------+----------------+
- * | XXX.XXX.XXX.XXX | | XXXXX | XXXXX | XXXXX | XXXXXXXXXXXXXX |
- * | | | XXXXX | XXXXX | XXXXX | XXXXXXXXXXXXXX |
- * | | | XXXXX | XXXXX | XXXXX | XXXXXXXXXXXXXX |
- * | | ...| ... | ... | ... | ... |
- * +-----------------+----+--------+------------------+--------------+----------------+
+ * +-----------------+----+--------+------------------+--------------+----+----------------+
+ * | HOST-ADDRESS | ...|IN-PORT | RMIREGISTRY-PORT | RMISTUB-PORT | ...| ACTIVE OBJECTS |
+ * +-----------------+----+--------+------------------+--------------+----+----------------+
+ * | XXX.XXX.XXX.XXX | | XXXXX | XXXXX | XXXXX | | XXXXXXXXXXXXXX |
+ * | | | XXXXX | XXXXX | XXXXX | | XXXXXXXXXXXXXX |
+ * | | | XXXXX | XXXXX | XXXXX | | XXXXXXXXXXXXXX |
+ * | | ...| ... | ... | ... | ...| ... |
+ * +-----------------+----+--------+------------------+--------------+----+----------------+
* In this case we use ACTIVE OBJECTS names as the key
* So ACTIVE OBJECTS maps to numbers and these numbers map to each other
* entry in hashmaps (HostAddress can be repetitive)
* ProximitySensorPS1 - 1
* TempSensorTS1 - 2
* ...
- * IN-PORT / RMIREGISTRY-PORT / RMISTUB-PORT / HOST-ADDRESS: 0 - XXXXX
- * 1 - XXXXX
- * 2 - XXXXX
- * +-------------+
- * | DEVICE-PORT |
- * +-------------+
- * | XXXXX |
- * | XXXXX |
- * | XXXXX |
- * | ... |
- * +-------------+
- * We add a Set structure to handle all the other ports that are used by devices
- * when communicating with their respective drivers
*
* @author Rahmadi Trimananda <rahmadi.trimananda @ uci.edu>
* @version 1.0
private Map<Integer, Integer> hmRMIRegPort;
private Map<Integer, Integer> hmRMIStubPort;
private Set<Integer> hsDevicePort;
- private Set<Integer> hsAllPorts;
private Map<Integer, Integer> hmAdditionalPort;
private int iNumOfObjects;
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
*/
private final int INT_MIN_PORT = 10000;
/**
- * Empty constructor
+ * Constructor
*/
public CommunicationHandler(boolean _bVerbose) {
hmRMIRegPort = new HashMap<Integer, Integer>();
hmRMIStubPort = new HashMap<Integer, Integer>();
hsDevicePort = new HashSet<Integer>();
- hsAllPorts = new HashSet<Integer>();
hmAdditionalPort = new HashMap<Integer, Integer>();
iNumOfObjects = 0;
iNumOfHosts = 0;
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
+ // Check port existence in HashMap
} while (portIsAvailable(iComPort) == false);
hmComPort.put(iNumOfObjects, iComPort);
- // hsAllPorts tracks all the existing and used port numbers
- hsAllPorts.add(iComPort);
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
+ // Check port existence in HashMap
} while (portIsAvailable(iRMIRegPort) == false);
hmRMIRegPort.put(iNumOfObjects, iRMIRegPort);
- hsAllPorts.add(iRMIRegPort);
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
+ // Check port existence in HashMap
} while (portIsAvailable(iRMIStubPort) == false);
hmRMIStubPort.put(iNumOfObjects, iRMIStubPort);
- hsAllPorts.add(iRMIStubPort);
iNumOfObjects++;
}
public void addDevicePort(int iDevPort) {
hsDevicePort.add(iDevPort);
- // Track this port number
- hsAllPorts.add(iDevPort);
}
/**
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
+ // Check port existence in HashMap
} while (portIsAvailable(iAdditionalPort) == false);
hmAdditionalPort.put(iNumOfObjects, iAdditionalPort);
- // Track this port number
- hsAllPorts.add(iAdditionalPort);
iNumOfObjects++;
} else {
return true;
}
- //if (hsAllPorts.contains(iPortNumber)) {
- // return false;
- //} else {
- // return true;
- //}
}
/**