void* params[SKELPARAMSIZE];
params[0] = objMainCls;
- //string callbackAddress = LOCALHOST;
- //params[1] = &callbackAddress;
- //params[2] = &objectStubPort;
params[1] = &objectStubPort;
params[2] = &objectRegPort;
writeToFile("Skeleton Object " + objectSkelClass + " created for " + objectClassName);
params[0] = &objectStubPort;
params[1] = &objectRegPort;
params[2] = &hostAddress;
- //params[0] = &objectStubPort;
- //params[1] = &hostAddress;
- //string callbackAddress = LOCALHOST;
- //params[2] = &callbackAddress;
int rev = 0;
params[3] = &rev;
bool result = false;
params[4] = &result;
- //params[5] = ports;
writeToFile("Stub Object " + objectStubClass + " created for " + objectClassName);
writeToFile("Success 1!");
objStubCls = create_object(params);
instantiateStubObject();
mapObjNameStub.insert(make_pair(objectName,objStubCls));
writeToFile("=> Map has: " + to_string(mapObjNameStub.size()) + " members");
- // vector<int> for ports has been copied - now delete it
- delete ports;
}
}
writeToFile("=> Driver object registry port: " + to_string(objectRegPort));
objectStubPort = recvInteger(); sendAck();
writeToFile("=> Driver object stub port: " + to_string(objectStubPort));
- int numOfPorts = recvInteger(); sendAck();
- ports = new vector<int>();
- for (int i = 0; i < numOfPorts; i++) {
- int port = recvInteger(); sendAck();
- ports->push_back(port);
- writeToFile("==> Got a new port: " + to_string(port));
- }
}
// Constants
const static int RCVBUFSIZE = 1024; // Size of receive buffer
const static int SKELPARAMSIZE = 3; // Number of params for skeleton
- //const static int STUBPARAMSIZE = 6; // Number of params for stub
const static int STUBPARAMSIZE = 5; // Number of params for stub
const static string FILEPATH; // File path
const static string FILEEXT; // File extension
string objectStubClass; // Need to send from Java IoTSlave: sMessage.getObjectStubInterfaceName() + STUB_CLASS_SUFFIX
int objectRegPort;
int objectStubPort;
- vector<int>* ports; // Now used to contain callback ports
string objectFieldName; // Field name that is going to be initialized with IoTSet or IoTRelation
unordered_set<void*>* isetObject; // Set of object
IoTSet<void*>* iotsetObject; // IoTSet of object
private Map<Integer, Integer> hmRMIRegPort;
private Map<Integer, Integer> hmRMIStubPort;
private Set<Integer> hsDevicePort;
- private Set<Integer> hsCallbackPort;
- private Map<Integer, Integer[]> hmCallbackPort;
private Map<Integer, Integer> hmAdditionalPort;
private int iNumOfObjects;
private int iNumOfHosts;
hmRMIRegPort = new HashMap<Integer, Integer>();
hmRMIStubPort = new HashMap<Integer, Integer>();
hsDevicePort = new HashSet<Integer>();
- hsCallbackPort = new HashSet<Integer>();
- hmCallbackPort = new HashMap<Integer, Integer[]>();
hmAdditionalPort = new HashMap<Integer, Integer>();
iNumOfObjects = 0;
iNumOfHosts = 0;
listObjCrtInfo.add(objCrtInfo);
}
-
- /**
- * Method getCallbackPort()
- * <p>
- * Get a new port for new connections for callback objects in the program.
- * This newly generated port number will be recorded.
- *
- * @return int[] A set of callback ports
- */
- public int[] getCallbackPorts(int numOfPorts) {
-
- int[] ports = new int[numOfPorts];
-
- for(int i = 0; i < numOfPorts; i++) {
- do {
- ports[i] = random.nextInt(INT_MAX_PORT - INT_MIN_PORT + 1) + INT_MIN_PORT;
- // Check port existence in HashMap
- } while (portIsAvailable(ports[i]) == false);
- hsCallbackPort.add(ports[i]);
- }
-
- return ports;
- }
-
-
- /**
- * Method getCallbackPorts()
- * <p>
- * Get a set of new ports for new connections for callback objects in the program.
- * This newly generated port number will be recorded.
- *
- * @return int[] A set of callback ports
- */
- public Integer[] getCallbackPorts(String sAObject, int numOfPorts) {
-
- Integer[] ports = new Integer[numOfPorts];
- int iNumOfObject = hmActiveObj.get(sAObject);
-
- if (!hmCallbackPort.containsKey(iNumOfObject)) {
- for(int i = 0; i < numOfPorts; i++) {
- do {
- ports[i] = random.nextInt(INT_MAX_PORT - INT_MIN_PORT + 1) + INT_MIN_PORT;
- // Check port existence in HashMap
- } while (portIsAvailable(ports[i]) == false);
- hsCallbackPort.add(ports[i]);
- }
- hmCallbackPort.put(iNumOfObject, ports);
- } else {
- ports = hmCallbackPort.get(iNumOfObject);
- }
-
- return ports;
- }
-
-
/**
* Method addDevicePort()
* <p>
return false;
} else if (hsDevicePort.contains(iPortNumber) == true) {
return false;
- } else if (hsCallbackPort.contains(iPortNumber) == true) {
- return false;
} else {
return true;
}
RuntimeOutput.print("\n", bVerbose);
}
}
- for(Integer i : hsCallbackPort)
- RuntimeOutput.print("RMI callback Port: " + i, bVerbose);
- RuntimeOutput.print("\n", bVerbose);
for(int iPort : hsDevicePort) {
RuntimeOutput.print("Device Port: " + iPort, bVerbose);
private static String STR_ZB_GATEWAY_ADDRESS;
private static String STR_ZB_GATEWAY_PORT;
private static String STR_ZB_IOTMASTER_PORT;
- private static String STR_NUM_CALLBACK_PORTS;
private static String STR_JVM_INIT_HEAP_SIZE;
private static String STR_JVM_MAX_HEAP_SIZE;
private static String STR_LANGUAGE_CONTROLLER;
STR_ZB_GATEWAY_ADDRESS = null;
STR_ZB_GATEWAY_PORT = null;
STR_ZB_IOTMASTER_PORT = null;
- STR_NUM_CALLBACK_PORTS = null;
STR_JVM_INIT_HEAP_SIZE = null;
STR_JVM_MAX_HEAP_SIZE = null;
STR_LANGUAGE_CONTROLLER = null;
STR_ZB_GATEWAY_ADDRESS = prop.getProperty("ZIGBEE_GATEWAY_ADDRESS");
STR_ZB_GATEWAY_PORT = prop.getProperty("ZIGBEE_GATEWAY_PORT");
STR_ZB_IOTMASTER_PORT = prop.getProperty("ZIGBEE_IOTMASTER_PORT");
- STR_NUM_CALLBACK_PORTS = prop.getProperty("NUMBER_CALLBACK_PORTS");
STR_JVM_INIT_HEAP_SIZE = prop.getProperty("JVM_INIT_HEAP_SIZE");
STR_JVM_MAX_HEAP_SIZE = prop.getProperty("JVM_MAX_HEAP_SIZE");
- //STR_LANGUAGE = prop.getProperty("LANGUAGE");
STR_SKEL_CLASS_SUFFIX = prop.getProperty("SKEL_CLASS_SUFFIX");
STR_STUB_CLASS_SUFFIX = prop.getProperty("STUB_CLASS_SUFFIX");
if(prop.getProperty("VERBOSE").equals(STR_YES)) {
RuntimeOutput.print("STR_ZB_GATEWAY_ADDRESS=" + STR_ZB_GATEWAY_ADDRESS, BOOL_VERBOSE);
RuntimeOutput.print("STR_ZB_GATEWAY_PORT=" + STR_ZB_GATEWAY_PORT, BOOL_VERBOSE);
RuntimeOutput.print("STR_ZB_IOTMASTER_PORT=" + STR_ZB_IOTMASTER_PORT, BOOL_VERBOSE);
- RuntimeOutput.print("STR_NUM_CALLBACK_PORTS=" + STR_NUM_CALLBACK_PORTS, BOOL_VERBOSE);
RuntimeOutput.print("STR_JVM_INIT_HEAP_SIZE=" + STR_JVM_INIT_HEAP_SIZE, BOOL_VERBOSE);
RuntimeOutput.print("STR_JVM_MAX_HEAP_SIZE=" + STR_JVM_MAX_HEAP_SIZE, BOOL_VERBOSE);
- //RuntimeOutput.print("STR_LANGUAGE=" + STR_LANGUAGE, BOOL_VERBOSE);
RuntimeOutput.print("STR_SKEL_CLASS_SUFFIX=" + STR_SKEL_CLASS_SUFFIX, BOOL_VERBOSE);
RuntimeOutput.print("STR_STUB_CLASS_SUFFIX=" + STR_STUB_CLASS_SUFFIX, BOOL_VERBOSE);
RuntimeOutput.print("BOOL_VERBOSE=" + BOOL_VERBOSE, BOOL_VERBOSE);
STR_TCP_PROTOCOL, commHan.getRMIStubPort(strObjName));
routerConfig.configureHostMainPolicies(strIoTSlaveObjectHostAdd, strIoTSlaveControllerHostAdd, strIoTSlaveObjectHostAdd,
STR_TCP_PROTOCOL, commHan.getRMIStubPort(strObjName));
- // Send the same set of routing policies for callback ports
- setCallbackPortsPolicy(strObjName, STR_ROUTER_ADD, strIoTSlaveControllerHostAdd, strIoTSlaveObjectHostAdd, STR_TCP_PROTOCOL);
}
- /**
- * A private method to set router policies for callback ports
- *
- * @params strRouterAdd String router address
- * @params strIoTSlaveControllerHostAdd String slave controller host address
- * @params strIoTSlaveObjectHostAdd String slave object host address
- * @params strProtocol String protocol
- * @return iPort Integer port number
- */
- private void setCallbackPortsPolicy(String strObjName, String strRouterAdd, String strIoTSlaveControllerHostAdd,
- String strIoTSlaveObjectHostAdd, String strProtocol) {
-
- int iNumCallbackPorts = Integer.parseInt(STR_NUM_CALLBACK_PORTS);
- Integer[] rmiCallbackPorts = commHan.getCallbackPorts(strObjName, iNumCallbackPorts);
-
- // Iterate over port numbers and set up policies
- for (int i=0; i<iNumCallbackPorts; i++) {
- routerConfig.configureRouterMainPolicies(strRouterAdd, strIoTSlaveControllerHostAdd, strIoTSlaveObjectHostAdd,
- strProtocol, rmiCallbackPorts[i]);
- routerConfig.configureHostMainPolicies(strIoTSlaveControllerHostAdd, strIoTSlaveControllerHostAdd, strIoTSlaveObjectHostAdd,
- strProtocol, rmiCallbackPorts[i]);
- routerConfig.configureHostMainPolicies(strIoTSlaveObjectHostAdd, strIoTSlaveControllerHostAdd, strIoTSlaveObjectHostAdd,
- strProtocol, rmiCallbackPorts[i]);
- }
- }
/**
* A private method to set router policies for IoTDeviceAddress objects
strObjClassName = setInstrumenter.fieldEntryType(strObjID);
// Call the method to create an object
instrumentObject(strObjID, strLanguage);
- int iNumOfPorts = Integer.parseInt(STR_NUM_CALLBACK_PORTS);
objInitHand.addObjectIntoField(strFieldName, strIoTSlaveObjectHostAdd, strObjName,
strObjClassName, strObjClassInterfaceName, strObjStubClsIntfaceName, commHan.getRMIRegPort(strObjName),
- commHan.getRMIStubPort(strObjName), commHan.getCallbackPorts(strObjName, iNumOfPorts));
+ commHan.getRMIStubPort(strObjName));
}
}
instrumentObject(strObjID, strLanguage);
// Get the first object controller host address
String strFirstIoTSlaveObjectHostAdd = strIoTSlaveObjectHostAdd;
- int iNumOfPorts = Integer.parseInt(STR_NUM_CALLBACK_PORTS);
objInitHand.addObjectIntoField(strFieldName, strIoTSlaveObjectHostAdd, strObjName,
strObjClassName, strObjClassInterfaceName, strObjStubClsIntfaceName,
- commHan.getRMIRegPort(strObjName), commHan.getRMIStubPort(strObjName),
- commHan.getCallbackPorts(strObjName, iNumOfPorts));
+ commHan.getRMIRegPort(strObjName), commHan.getRMIStubPort(strObjName));
// Operate on the second set
arrFieldClasses = relationInstrumenter.secondFieldClasses(iRow);
arrFieldValues = relationInstrumenter.secondFieldValues(iRow);
String strSecondIoTSlaveObjectHostAdd = strIoTSlaveObjectHostAdd;
objInitHand.addSecondObjectIntoField(strFieldName, strIoTSlaveObjectHostAdd, strObjName,
strObjClassName, strObjClassInterfaceName, strObjStubClsIntfaceName,
- commHan.getRMIRegPort(strObjName), commHan.getRMIStubPort(strObjName),
- commHan.getCallbackPorts(strObjName, iNumOfPorts));
+ commHan.getRMIRegPort(strObjName), commHan.getRMIStubPort(strObjName));
// ROUTING POLICY: first and second controller objects in IoTRelation
routerConfig.configureRouterMainPolicies(STR_ROUTER_ADD, strFirstIoTSlaveObjectHostAdd,
strSecondIoTSlaveObjectHostAdd, STR_TCP_PROTOCOL);
// == COMMUNICATION WITH IOTSLAVE CONTROLLER TO FILL IN IOTSET
commMasterToSlave(new MessageGetObject(IoTCommCode.GET_IOTSET_OBJECT, objInitInfo.getIoTSlaveObjectHostAdd(),
objInitInfo.getObjectName(), objInitInfo.getObjectClassName(), objInitInfo.getObjectClassInterfaceName(),
- objInitInfo.getObjectStubClassInterfaceName(), objInitInfo.getRMIRegistryPort(), objInitInfo.getRMIStubPort(),
- objInitInfo.getRMICallbackPorts()), "Get IoTSet object!", inStream, outStream);
+ objInitInfo.getObjectStubClassInterfaceName(), objInitInfo.getRMIRegistryPort(), objInitInfo.getRMIStubPort()),
+ "Get IoTSet object!", inStream, outStream);
}
// == COMMUNICATION WITH IOTSLAVE CONTROLLER TO REINITIALIZE IOTSET FIELD
commMasterToSlave(new MessageGetObject(IoTCommCode.GET_IOTRELATION_FIRST_OBJECT,
objInitInfo.getIoTSlaveObjectHostAdd(), objInitInfo.getObjectName(), objInitInfo.getObjectClassName(),
objInitInfo.getObjectClassInterfaceName(), objInitInfo.getObjectStubClassInterfaceName(),
- objInitInfo.getRMIRegistryPort(), objInitInfo.getRMIStubPort(), objInitInfo.getRMICallbackPorts()),
+ objInitInfo.getRMIRegistryPort(), objInitInfo.getRMIStubPort()),
"Get IoTRelation first object!", inStream, outStream);
ObjectInitInfo objSecObj = (ObjectInitInfo) it.next();
// == COMMUNICATION WITH IOTSLAVE CONTROLLER TO FILL IN IOTRELATION (SECOND OBJECT)
commMasterToSlave(new MessageGetObject(IoTCommCode.GET_IOTRELATION_SECOND_OBJECT,
objSecObj.getIoTSlaveObjectHostAdd(), objSecObj.getObjectName(), objSecObj.getObjectClassName(),
objSecObj.getObjectClassInterfaceName(), objSecObj.getObjectStubClassInterfaceName(),
- objSecObj.getRMIRegistryPort(), objSecObj.getRMIStubPort(), objSecObj.getRMICallbackPorts()),
+ objSecObj.getRMIRegistryPort(), objSecObj.getRMIStubPort()),
"Get IoTRelation second object!", inStream, outStream);
}
// == COMMUNICATION WITH IOTSLAVE CONTROLLER TO REINITIALIZE IOTRELATION FIELD
// == COMMUNICATION WITH IOTSLAVE CONTROLLER TO FILL IN IOTSET
getIoTSetRelationObjectCpp(IoTCommCode.GET_IOTSET_OBJECT, objInitInfo.getIoTSlaveObjectHostAdd(), objInitInfo.getObjectName(),
objInitInfo.getObjectClassName(), objInitInfo.getObjectClassInterfaceName(), objInitInfo.getObjectStubClassInterfaceName(),
- objInitInfo.getRMIRegistryPort(), objInitInfo.getRMIStubPort(), objInitInfo.getRMICallbackPorts(), outStream, inStream);
+ objInitInfo.getRMIRegistryPort(), objInitInfo.getRMIStubPort(), outStream, inStream);
}
// == COMMUNICATION WITH IOTSLAVE CONTROLLER TO REINITIALIZE IOTSET FIELD
reinitializeIoTSetFieldCpp(outStream, inStream);
// == COMMUNICATION WITH IOTSLAVE CONTROLLER TO FILL IN IOTRELATION (FIRST OBJECT)
getIoTSetRelationObjectCpp(IoTCommCode.GET_IOTRELATION_FIRST_OBJECT, objInitInfo.getIoTSlaveObjectHostAdd(), objInitInfo.getObjectName(),
objInitInfo.getObjectClassName(), objInitInfo.getObjectClassInterfaceName(), objInitInfo.getObjectStubClassInterfaceName(),
- objInitInfo.getRMIRegistryPort(), objInitInfo.getRMIStubPort(), objInitInfo.getRMICallbackPorts(), outStream, inStream);
+ objInitInfo.getRMIRegistryPort(), objInitInfo.getRMIStubPort(), outStream, inStream);
ObjectInitInfo objSecObj = (ObjectInitInfo) it.next();
// == COMMUNICATION WITH IOTSLAVE CONTROLLER TO FILL IN IOTRELATION (SECOND OBJECT)
getIoTSetRelationObjectCpp(IoTCommCode.GET_IOTRELATION_SECOND_OBJECT, objSecObj.getIoTSlaveObjectHostAdd(), objSecObj.getObjectName(),
objSecObj.getObjectClassName(), objSecObj.getObjectClassInterfaceName(), objSecObj.getObjectStubClassInterfaceName(),
- objSecObj.getRMIRegistryPort(), objSecObj.getRMIStubPort(), objSecObj.getRMICallbackPorts(), outStream, inStream);
+ objSecObj.getRMIRegistryPort(), objSecObj.getRMIStubPort(), outStream, inStream);
}
// == COMMUNICATION WITH IOTSLAVE CONTROLLER TO REINITIALIZE IOTRELATION FIELD
reinitializeIoTRelationFieldCpp(outStream, inStream);
*/
public void getIoTSetRelationObjectCpp(IoTCommCode iotCommCode, String strIoTSlaveHostAddress, String strObjectName, String strObjectClassName,
String strObjectClassInterfaceName, String strObjectStubClassInterfaceName, int iRMIRegistryPort, int iRMIStubPort,
- Integer[] iCallbackPorts, OutputStream outStream, InputStream inStream) throws IOException {
+ OutputStream outStream, InputStream inStream) throws IOException {
sendCommCode(iotCommCode, outStream, inStream);
RuntimeOutput.print("IoTMaster: Getting IoTSet object content...", BOOL_VERBOSE);
sendInteger(iRMIRegistryPort, outStream); recvAck(inStream);
RuntimeOutput.print("IoTMaster: Driver object stub port: " + iRMIStubPort, BOOL_VERBOSE);
sendInteger(iRMIStubPort, outStream); recvAck(inStream);
- sendInteger(iCallbackPorts.length, outStream); recvAck(inStream);
- for(Integer i : iCallbackPorts) {
- sendInteger(i, outStream); recvAck(inStream);
- }
}
* @param strObjClassInterfaceName String object class interface
* @param iRMIRegPort Integer RMI registry port
* @param iRMIStubPort Integer RMI stub port
- * @param iRMICallbackPorts Integer RMI callback ports
* @return void
*/
public void addObjectIntoField(String strField, String strIoTSlaveObjectHostAdd,
String strObjName, String strObjClassName, String strObjClassInterfaceName,
- String strObjStubClsIntfaceName, int iRMIRegPort, int iRMIStubPort, Integer[] iRMICallbackPorts) {
+ String strObjStubClsIntfaceName, int iRMIRegPort, int iRMIStubPort) {
// Get index of strField
int iFieldIndex = listField.indexOf(strField);
List<ObjectInitInfo> list = listFieldToObject.get(iFieldIndex);
// Create a new ObjectInitInfo for a new object in the field
ObjectInitInfo objInitInfo = new ObjectInitInfo(strIoTSlaveObjectHostAdd, strObjName,
- strObjClassName, strObjClassInterfaceName, strObjStubClsIntfaceName, iRMIRegPort, iRMIStubPort, iRMICallbackPorts);
+ strObjClassName, strObjClassInterfaceName, strObjStubClsIntfaceName, iRMIRegPort, iRMIStubPort);
// Add the new ObjectInitInfo
list.add(objInitInfo);
}
*/
public void addSecondObjectIntoField(String strField, String strIoTSlaveObjectHostAdd,
String strObjName, String strObjClassName, String strObjClassInterfaceName,
- String strObjStubClsIntfaceName, int iRMIRegPort, int iRMIStubPort, Integer[] iRMICallbackPorts) {
+ String strObjStubClsIntfaceName, int iRMIRegPort, int iRMIStubPort) {
// Get index of strField
int iFieldIndex = listField.indexOf(strField);
List<ObjectInitInfo> list = mapFieldToSecondObject.get(iFieldIndex);
// Create a new ObjectInitInfo for a new object in the field
ObjectInitInfo objInitInfo = new ObjectInitInfo(strIoTSlaveObjectHostAdd, strObjName,
- strObjClassName, strObjClassInterfaceName, strObjStubClsIntfaceName, iRMIRegPort, iRMIStubPort, iRMICallbackPorts);
+ strObjClassName, strObjClassInterfaceName, strObjStubClsIntfaceName, iRMIRegPort, iRMIStubPort);
// Add the new ObjectInitInfo
list.add(objInitInfo);
}
*/
protected int iRMIRegPort;
protected int iRMIStubPort;
- protected Integer[] iRMICallbackPorts;
/**
*/
public ObjectInitInfo(String _strIoTSlaveObjectHostAdd, String _strObjName,
String _strObjClassName, String _strObjClassInterfaceName, String _strObjStubClsIntfaceName,
- int _iRMIRegPort, int _iRMIStubPort, Integer[] _iRMICallbackPorts) {
+ int _iRMIRegPort, int _iRMIStubPort) {
super(_strIoTSlaveObjectHostAdd, _strObjName, _strObjClassName, _strObjClassInterfaceName, _strObjStubClsIntfaceName);
iRMIRegPort = _iRMIRegPort;
iRMIStubPort = _iRMIStubPort;
- iRMICallbackPorts = _iRMICallbackPorts;
}
/**
public int getRMIStubPort() {
return iRMIStubPort;
}
-
- /**
- * Method getRMICallbackPorts()
- */
- public Integer[] getRMICallbackPorts() {
- return iRMICallbackPorts;
- }
}
private String sObjStubIntName;
private int iRMIRegPort;
private int iRMIStubPort;
- private Integer[] iRMICallbackPorts;
private Object[] arrObjFields;
private Class[] arrObjFldCls;
* Class constructor (to tell IoTSlave controller to get objects for IoTSet/IoTRelation)
*/
public MessageGetObject(IoTCommCode sMsg, String sHAddress, String sOName,
- String sOClass, String sOIName, String sOSIName, int iRRPort, int iRSPort, Integer[] iCBPort) {
+ String sOClass, String sOIName, String sOSIName, int iRRPort, int iRSPort) {
super(sMsg);
sObjStubIntName = sOSIName;
iRMIRegPort = iRRPort;
iRMIStubPort = iRSPort;
- iRMICallbackPorts = iCBPort;
}
/**
return iRMIStubPort;
}
- /**
-
- * getRMICallbackPorts() method
- *
- * @return Integer[]
- */
- public Integer[] getRMICallbackPorts() {
- return iRMICallbackPorts;
- }
-
/**
* setHostAddress() method
*
iRMIStubPort = iRSPort;
}
- /**
- * setRMICallbackPorts() method
- *
- * @param iCBPort RMI callback port numbers
- * @return void
- */
- public void setRMICallbackPorts(Integer[] iCBPort) {
- iRMICallbackPorts = iCBPort;
- }
}
private void createCapabBasedRMIJava(MessageCreateObject sMessage) throws
ClassNotFoundException, NoSuchMethodException, UnknownHostException {
- // TODO: DEBUG
- System.out.println("\n\nDEBUG: Create capab based RMI here!");
- System.out.println("DEBUG: sMessage host address: " + sMessage.getHostAddress());
- System.out.println("DEBUG: sMessage object class: " + sMessage.getObjectClass());
- System.out.println("DEBUG: sMessage object name: " + sMessage.getObjectName());
- System.out.println("DEBUG: sMessage interface name: " + sMessage.getObjectInterfaceName());
- System.out.println("DEBUG: sMessage reg port: " + sMessage.getRMIRegPort());
- System.out.println("DEBUG: sMessage stub port: " + sMessage.getRMIStubPort());
- System.out.println("DEBUG: sMessage object fields: " + Arrays.toString(sMessage.getObjectFields()));
- System.out.println("DEBUG: sMessage object fields: " + Arrays.toString(sMessage.getObjectFldCls()));
- System.out.println("\n\n");
-
// Instantiate the skeleton and put in the object
String strObjSkelName = STR_OBJ_CLS_PFX + "." + sMessage.getObjectClass() +
"." + sMessage.getObjectInterfaceName() + SKEL_CLASS_SUFFIX;
RemoteException, AlreadyBoundException, IllegalAccessException,
InvocationTargetException {
- // TODO: DEBUG
- System.out.println("\n\nDEBUG: CREATE DRIVER OBJECT!!!\n\n");
-
// Translating into the actual Message class
MessageCreateObject sMessage = (MessageCreateObject) sIoTMasterMsg;
// Instantiate object using reflection
// Translating into the actual Message class
MessageCreateMainObject sMessage = (MessageCreateMainObject) sIoTMasterMsg;
- // TODO: DEBUG
- System.out.println("\n\nDEBUG: CREATE MAIN OBJECT!!!");
- System.out.println("DEBUG: sMessage object name: " + sMessage.getObjectName());
-
// Getting controller class
File file = new File(STR_JAR_FILE_PATH + sMessage.getObjectName() + STR_JAR_FILE_EXT);
RuntimeOutput.print("IoTSlave: DEBUG print path: " + STR_JAR_FILE_PATH +
// Translating into the actual Message class
MessageCreateSetRelation sMessage = (MessageCreateSetRelation) sIoTMasterMsg;
- // TODO: DEBUG
- System.out.println("\n\nDEBUG: CREATE NEW IOT SET!!!");
- System.out.println("DEBUG: sMessage object field name: " + sMessage.getObjectFieldName());
-
// Initialize field name
strFieldName = sMessage.getObjectFieldName();
RuntimeOutput.print("IoTSlave: Setting up field " + strFieldName, BOOL_VERBOSE);
// Translating into the actual Message class
MessageCreateSetRelation sMessage = (MessageCreateSetRelation) sIoTMasterMsg;
- // TODO: DEBUG
- System.out.println("\n\nDEBUG: CREATE NEW IOT RELATION!!!");
- System.out.println("DEBUG: sMessage object field name: " + sMessage.getObjectFieldName());
-
// Initialize field name
strFieldName = sMessage.getObjectFieldName();
RuntimeOutput.print("IoTSlave: Setting up field " + strFieldName, BOOL_VERBOSE);
// Translating into the actual Message class
MessageGetObject sMessage = (MessageGetObject) sIoTMasterMsg;
-
- System.out.println("DEBUG: sMessage host address: " + sMessage.getHostAddress());
- System.out.println("DEBUG: sMessage object class: " + sMessage.getObjectClass());
- System.out.println("DEBUG: sMessage object name: " + sMessage.getObjectName());
- System.out.println("DEBUG: sMessage interface name: " + sMessage.getObjectInterfaceName());
- System.out.println("DEBUG: sMessage reg port: " + sMessage.getRMIRegPort());
- System.out.println("DEBUG: sMessage stub port: " + sMessage.getRMIStubPort());
- System.out.println("DEBUG: sMessage callback ports: " + Arrays.toString(sMessage.getRMICallbackPorts()));
- System.out.println("\n\n");
-
Object stubObjConv = null;
String strObjectName = sMessage.getObjectName();
String strObjClassInterfaceName = STR_OBJ_CLS_PFX + "." + STR_INTERFACE_PFX + "." +
private void getIoTSetObject() throws IOException,
ClassNotFoundException, RemoteException, NotBoundException, NoSuchMethodException,
InstantiationException, IllegalAccessException, InvocationTargetException {
-
- // TODO: DEBUG
- System.out.println("\n\nDEBUG: GET IOT SET OBJECT!!!");
-
Object objRegistry = null;
if (CAPAB_BASED_RMI)
objRegistry = getObjectFromStub();
private void getIoTRelationFirstObject() throws IOException,
ClassNotFoundException, RemoteException, NotBoundException, NoSuchMethodException,
InstantiationException, IllegalAccessException, InvocationTargetException {
-
- // TODO: DEBUG
- System.out.println("\n\nDEBUG: GET IOT RELATION FIRST OBJECT!!!");
-
Object objRegistry = null;
if (CAPAB_BASED_RMI)
objRegistry = getObjectFromStub();
private void getIoTRelationSecondObject() throws IOException,
ClassNotFoundException, RemoteException, NotBoundException, NoSuchMethodException,
InstantiationException, IllegalAccessException, InvocationTargetException {
-
- // TODO: DEBUG
- System.out.println("\n\nDEBUG: GET IOT RELATION SECOND OBJECT!!!");
-
Object objRegistry = null;
if (CAPAB_BASED_RMI)
objRegistry = getObjectFromStub();
// Reinitialize IoTSet field after getting all the objects
iotsetObject = new IoTSet<Object>(isetObject.values());
-
- // TODO: DEBUG
- System.out.println("\n\nDEBUG: REINITIALIZE IOT SET FIELD!!!");
- System.out.println("DEBUG: Field name: " + strFieldName + "\n\n");
-
// Private fields need getDeclaredField(), while public fields use getField()
Field fld = clsMain.getDeclaredField(strFieldName);
boolean bAccess = fld.isAccessible();
// Reinitialize IoTSet field after getting all the objects
iotrelObject = new IoTRelation<Object,Object>(irelObject.relationMap(), irelObject.size());
-
- // TODO: DEBUG
- System.out.println("\n\nDEBUG: REINITIALIZE IOT RELATION FIELD!!!");
- System.out.println("DEBUG: Field name: " + strFieldName + "\n\n");
-
// Private fields need getDeclaredField(), while public fields use getField()
Field fld = clsMain.getDeclaredField(strFieldName);
boolean bAccess = fld.isAccessible();
// Translating into the actual Message class
MessageGetDeviceObject sMessage = (MessageGetDeviceObject) sIoTMasterMsg;
-
- // TODO: DEBUG
- System.out.println("\n\nDEBUG: GET DEVICE IOT SET OBJECT!!!");
- System.out.println("DEBUG: sMessage host address: " + sMessage.getHostAddress());
- System.out.println("DEBUG: sMessage source port: " + sMessage.getSourceDeviceDriverPort());
- System.out.println("DEBUG: sMessage destination port: " + sMessage.getDestinationDeviceDriverPort());
- System.out.println("DEBUG: sMessage source wild card: " + sMessage.isSourcePortWildCard());
- System.out.println("DEBUG: sMessage desination wild card: " + sMessage.isDestinationPortWildCard() + "\n\n");
-
// Get IoTSet objects for IP address set on device driver/controller
IoTDeviceAddress objDeviceAddress = new IoTDeviceAddress(sMessage.getHostAddress(),
sMessage.getSourceDeviceDriverPort(),
// Translating into the actual Message class
MessageGetSimpleDeviceObject sMessage = (MessageGetSimpleDeviceObject) sIoTMasterMsg;
-
- // TODO: DEBUG
- System.out.println("\n\nDEBUG: GET ZIGBEE DEVICE IOT SET OBJECT!!!");
- System.out.println("DEBUG: sMessage host address: " + sMessage.getHostAddress() + "\n\n");
-
// Get IoTSet objects for IP address set on device driver/controller
IoTZigbeeAddress objZBDevAddress = new IoTZigbeeAddress(sMessage.getHostAddress());
RuntimeOutput.print("IoTSlave: Device address transferred: " + sMessage.getHostAddress(), BOOL_VERBOSE);
// Translating into the actual Message class
MessageGetSimpleDeviceObject sMessage = (MessageGetSimpleDeviceObject) sIoTMasterMsg;
-
- // TODO: DEBUG
- System.out.println("\n\nDEBUG: GET ADD IOT SET OBJECT!!!");
- System.out.println("DEBUG: sMessage host address: " + sMessage.getHostAddress() + "\n\n");
-
// Get IoTSet objects for IP address set on device driver/controller
IoTAddress objAddress = new IoTAddress(sMessage.getHostAddress());
RuntimeOutput.print("IoTSlave: Address transferred: " + sMessage.getHostAddress(), BOOL_VERBOSE);
*/
private void invokeInitMethod() throws IOException {
- // TODO: DEBUG
- System.out.println("\n\nDEBUG: INVOKE INIT METHOD!!!\n\n");
-
new Thread() {
public void run() {
try {
#Verboseness of runtime messages
VERBOSE=Yes
-#Number of callback ports
-NUMBER_CALLBACK_PORTS=1
-
#Language: C++ or Java
LANGUAGE=Java
projects / iot2.git / commitdiff