INTERFACE_CLASS=LightBulb
+INTERFACE_STUB_CLASS=LightBulbTest
private IoTRMIObject rmiObj;
private final static int object0Id = 0; //LightBulbTest
- private static Integer[] object0Permission = { 2, 1, 3, 4, 0, 5 };
+ private static Integer[] object0Permission = { 2, 6, 1, 3, 4, 8, 0, 5, 7, 9 };
private static List<Integer> set0Allowed;
$(JAVAC) -cp .:../$(BIN_DIR) -d $(BIN_DIR) iotrmi/Java/*.java
$(JAVAC) -cp .:../$(BIN_DIR) -d $(BIN_DIR) iotrmi/Java/sample/*.java
mkdir -p $(BIN_DIR)/iotrmi/C++/sample
- $(G++) iotrmi/C++/sample/TestClass_Stub.cpp -o $(BIN_DIR)/iotrmi/C++/sample/TestClass_Stub.out --std=c++11 -pthread -pg
- $(G++) iotrmi/C++/sample/TestClass_Skeleton.cpp -o $(BIN_DIR)/iotrmi/C++/sample/TestClass_Skeleton.out --std=c++11 -pthread -pg
+ #$(G++) iotrmi/C++/sample/TestClass_Stub.cpp -o $(BIN_DIR)/iotrmi/C++/sample/TestClass_Stub.out --std=c++11 -pthread -pg
+ #$(G++) iotrmi/C++/sample/TestClass_Skeleton.cpp -o $(BIN_DIR)/iotrmi/C++/sample/TestClass_Skeleton.out --std=c++11 -pthread -pg
PHONY += run-rmiserver
run-rmiserver:
* ClassRuntimeInstrumenterMaster class constants
*/
private static final int INT_NUM_CLASS_TYPE = 3;
- private static final String STR_IOT_ANNOTATION_SIGNATURE = "Liotchecker/qual/config;";
+ //private static final String STR_IOT_ANNOTATION_SIGNATURE = "Liotchecker/qual/config;";
+ private static final String STR_IOT_ANNOTATION_SIGNATURE = "Liotcode/annotation/config;";
private static final String STR_IOT_SET_SIGNATURE = "Liotruntime/slave/IoTSet;";
private static final String STR_IOT_RELATION_SIGNATURE = "Liotruntime/slave/IoTRelation;";
private static final String STR_IOT_CONSTRAINT_SIGNATURE = "Liotcode/annotation/constraint;";
super.visit(version, access, name, signature, superName, interfaces);
}
- /**
- * Visit class annotation
- */
- @Override
- public AnnotationVisitor visitAnnotation(String desc,
- boolean visible) {
-
- return super.visitAnnotation(desc, visible);
- }
-
/**
* Make a visit to a field.
*/
public AnnotationVisitor visitAnnotation(String desc,
boolean visible) {
- //RuntimeOutput.print("ClassRuntimeInstrumenterMaster@AnnotationVisitor: " + desc, bVerbose);
+ RuntimeOutput.print("ClassRuntimeInstrumenterMaster@AnnotationVisitor: " + desc, bVerbose);
// Check annotation description @config
if(desc.equals(STR_IOT_ANNOTATION_SIGNATURE)) {
* @return void
*/
public void addActiveControllerObject(String strFieldObjectID, String strObjName, String strObjClassName,
- String strObjClassInterfaceName, String strIoTSlaveObjectHostAdd, Object[] arrFieldValues,
+ String strObjClassInterfaceName, String strObjStubClsIntfaceName, String strIoTSlaveObjectHostAdd, Object[] arrFieldValues,
Class[] arrFieldClasses) {
listActiveControllerObj.add(strObjName);
listArrFieldValues.add(arrFieldValues);
listArrFieldClasses.add(arrFieldClasses);
ObjectCreationInfo objCrtInfo = new ObjectCreationInfo(strIoTSlaveObjectHostAdd, strObjName,
- strObjClassName, strObjClassInterfaceName);
+ strObjClassName, strObjClassInterfaceName, strObjStubClsIntfaceName);
listObjCrtInfo.add(objCrtInfo);
}
private String strObjName;
private String strObjClassName;
private String strObjClassInterfaceName;
+ private String strObjStubClsIntfaceName;
private String strIoTMasterHostAdd;
private String strIoTSlaveControllerHostAdd;
private String strIoTSlaveObjectHostAdd;
private static final String STR_NO_PROTOCOL = "nopro";
private static final String STR_SELF_MAC_ADD = "00:00:00:00:00:00";
private static final String STR_INTERFACE_CLS_CFG = "INTERFACE_CLASS";
+ private static final String STR_INT_STUB_CLS_CFG = "INTERFACE_STUB_CLASS";
private static final String STR_FILE_TRF_CFG = "ADDITIONAL_ZIP_FILE";
private static final String STR_YES = "Yes";
private static final String STR_NO = "No";
strObjName = null;
strObjClassName = null;
strObjClassInterfaceName = null;
+ strObjStubClsIntfaceName = null;
strIoTMasterHostAdd = null;
strIoTSlaveControllerHostAdd = null;
strIoTSlaveObjectHostAdd = null;
// Extract the interface name for RMI
// e.g. ProximitySensorInterface, TempSensorInterface, etc.
- String strObjCfgFile = STR_IOT_CODE_PATH + strObjClassName + "/" + strObjClassName + STR_CFG_FILE_EXT;
+
+String strObjCfgFile = STR_IOT_CODE_PATH + strObjClassName + "/" + strObjClassName + STR_CFG_FILE_EXT;
strObjClassInterfaceName = parseConfigFile(strObjCfgFile, STR_INTERFACE_CLS_CFG);
+ strObjStubClsIntfaceName = parseConfigFile(strObjCfgFile, STR_INT_STUB_CLS_CFG);
// Create an object name, e.g. ProximitySensorImplPS1
strObjName = strObjClassName + strFieldObjectID;
// Check first if host exists
// Naming for objects ProximitySensor becomes ProximitySensor0, ProximitySensor1, etc.
commHan.addPortConnection(strIoTSlaveObjectHostAdd, strObjName);
commHan.addActiveControllerObject(strFieldObjectID, strObjName, strObjClassName, strObjClassInterfaceName,
- strIoTSlaveObjectHostAdd, arrFieldValues, arrFieldClasses);
+ strObjStubClsIntfaceName, strIoTSlaveObjectHostAdd, arrFieldValues, arrFieldClasses);
// ROUTING POLICY: IoTMaster and device/controller object
// Master-slave communication
routerConfig.configureRouterMainPolicies(STR_ROUTER_ADD, strIoTMasterHostAdd,
* @params arrFieldClasses Array of field classes
* @return void
*/
- private void createObject(String strObjName, String strObjClassName, String strObjClassInterfaceName,
+ private void createObject(String strObjName, String strObjClassName, String strObjClassInterfaceName, String strObjStubClsIntfaceName,
String strIoTSlaveObjectHostAdd, String strFieldObjectID, Object[] arrFieldValues, Class[] arrFieldClasses)
throws IOException, FileNotFoundException, ClassNotFoundException, InterruptedException {
// Pack object information to create object on a IoTSlave
Message msgObjIoTSlave = new MessageCreateObject(IoTCommCode.CREATE_OBJECT, strIoTSlaveObjectHostAdd,
- strObjClassName, strObjName, strObjClassInterfaceName, commHan.getRMIRegPort(strObjName),
+ strObjClassName, strObjName, strObjClassInterfaceName, strObjStubClsIntfaceName, commHan.getRMIRegPort(strObjName),
commHan.getRMIStubPort(strObjName), arrFieldValues, arrFieldClasses);
// Send message
commMasterToSlave(msgObjIoTSlave, "Sending object information", inStream, outStream);
}
}
// End the session
+ // TODO: Change this later
outStream.writeObject(new MessageSimple(IoTCommCode.END_SESSION));
// PROFILING
synchronized(this) {
try {
createObject(strObjName, objCrtInfo.getObjectClassName(), objCrtInfo.getObjectClassInterfaceName(),
- objCrtInfo.getIoTSlaveObjectHostAdd(), commHan.getFieldObjectID(strObjName),
- commHan.getArrayFieldValues(strObjName), commHan.getArrayFieldClasses(strObjName));
+ objCrtInfo.getObjectStubClassInterfaceName(), objCrtInfo.getIoTSlaveObjectHostAdd(),
+ commHan.getFieldObjectID(strObjName), commHan.getArrayFieldValues(strObjName),
+ commHan.getArrayFieldClasses(strObjName));
} catch (IOException |
ClassNotFoundException |
InterruptedException ex) {
// Call the method to create an object
instrumentObject(strObjID);
objInitHand.addObjectIntoField(strFieldName, strIoTSlaveObjectHostAdd, strObjName,
- strObjClassName, strObjClassInterfaceName, commHan.getRMIRegPort(strObjName),
+ strObjClassName, strObjClassInterfaceName, strObjStubClsIntfaceName, commHan.getRMIRegPort(strObjName),
commHan.getRMIStubPort(strObjName));
}
}
// Get the first object controller host address
String strFirstIoTSlaveObjectHostAdd = strIoTSlaveObjectHostAdd;
objInitHand.addObjectIntoField(strFieldName, strIoTSlaveObjectHostAdd, strObjName,
- strObjClassName, strObjClassInterfaceName, commHan.getRMIRegPort(strObjName),
- commHan.getRMIStubPort(strObjName));
+ strObjClassName, strObjClassInterfaceName, strObjStubClsIntfaceName,
+ commHan.getRMIRegPort(strObjName), commHan.getRMIStubPort(strObjName));
// Operate on the second set
arrFieldClasses = relationInstrumenter.secondFieldClasses(iRow);
arrFieldValues = relationInstrumenter.secondFieldValues(iRow);
// Get the second object controller host address
String strSecondIoTSlaveObjectHostAdd = strIoTSlaveObjectHostAdd;
objInitHand.addSecondObjectIntoField(strFieldName, strIoTSlaveObjectHostAdd, strObjName,
- strObjClassName, strObjClassInterfaceName, commHan.getRMIRegPort(strObjName),
- commHan.getRMIStubPort(strObjName));
+ strObjClassName, strObjClassInterfaceName, strObjStubClsIntfaceName,
+ commHan.getRMIRegPort(strObjName), commHan.getRMIStubPort(strObjName));
// ROUTING POLICY: first and second controller objects in IoTRelation
routerConfig.configureRouterMainPolicies(STR_ROUTER_ADD, strFirstIoTSlaveObjectHostAdd,
// == COMMUNICATION WITH IOTSLAVE CONTROLLER TO FILL IN IOTSET
commMasterToSlave(new MessageGetObject(IoTCommCode.GET_IOTSET_OBJECT, objInitInfo.getIoTSlaveObjectHostAdd(),
objInitInfo.getObjectName(), objInitInfo.getObjectClassName(), objInitInfo.getObjectClassInterfaceName(),
- objInitInfo.getRMIRegistryPort(), objInitInfo.getRMIStubPort()),
+ objInitInfo.getObjectStubClassInterfaceName(), objInitInfo.getRMIRegistryPort(), objInitInfo.getRMIStubPort()),
"Get IoTSet object!", inStream, outStream);
}
// == COMMUNICATION WITH IOTSLAVE CONTROLLER TO REINITIALIZE IOTSET FIELD
// == COMMUNICATION WITH IOTSLAVE CONTROLLER TO FILL IN IOTRELATION (FIRST OBJECT)
commMasterToSlave(new MessageGetObject(IoTCommCode.GET_IOTRELATION_FIRST_OBJECT,
objInitInfo.getIoTSlaveObjectHostAdd(), objInitInfo.getObjectName(), objInitInfo.getObjectClassName(),
- objInitInfo.getObjectClassInterfaceName(), objInitInfo.getRMIRegistryPort(), objInitInfo.getRMIStubPort()),
+ objInitInfo.getObjectClassInterfaceName(), objInitInfo.getObjectStubClassInterfaceName(),
+ 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.getRMIRegistryPort(), objSecObj.getRMIStubPort()),
+ objSecObj.getObjectClassInterfaceName(), objInitInfo.getObjectStubClassInterfaceName(),
+ objSecObj.getRMIRegistryPort(), objSecObj.getRMIStubPort()),
"Get IoTRelation second object!", inStream, outStream);
}
// == COMMUNICATION WITH IOTSLAVE CONTROLLER TO REINITIALIZE IOTRELATION FIELD
protected String strObjName;
protected String strObjClassName;
protected String strObjClassInterfaceName;
+ protected String strObjStubClsIntfaceName;
/**
* Constructor
*/
public ObjectCreationInfo(String _strIoTSlaveObjectHostAdd, String _strObjName,
- String _strObjClassName, String _strObjClassInterfaceName) {
+ String _strObjClassName, String _strObjClassInterfaceName, String _strObjStubClsIntfaceName) {
strIoTSlaveObjectHostAdd = _strIoTSlaveObjectHostAdd;
+ strObjStubClsIntfaceName = _strObjStubClsIntfaceName;
strObjName = _strObjName;
strObjClassName = _strObjClassName;
strObjClassInterfaceName = _strObjClassInterfaceName;
public String getObjectClassInterfaceName() {
return strObjClassInterfaceName;
}
+
+ /**
+ * Method getObjectStubClassInterfaceName()
+ */
+ public String getObjectStubClassInterfaceName() {
+ return strObjStubClsIntfaceName;
+ }
}
*/
public void addObjectIntoField(String strField, String strIoTSlaveObjectHostAdd,
String strObjName, String strObjClassName, String strObjClassInterfaceName,
- int iRMIRegPort, int iRMIStubPort) {
+ 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, iRMIRegPort, iRMIStubPort);
+ 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,
- int iRMIRegPort, int iRMIStubPort) {
+ 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, iRMIRegPort, iRMIStubPort);
+ strObjClassName, strObjClassInterfaceName, strObjStubClsIntfaceName, iRMIRegPort, iRMIStubPort);
// Add the new ObjectInitInfo
list.add(objInitInfo);
}
RuntimeOutput.print("==> Object name: " + objInitInfo.getObjectName(), bVerbose);
RuntimeOutput.print("==> Object class name: " + objInitInfo.getObjectClassName(), bVerbose);
RuntimeOutput.print("==> Object class interface: " + objInitInfo.getObjectClassInterfaceName(), bVerbose);
+ RuntimeOutput.print("==> Object stub class interface: " + objInitInfo.getObjectStubClassInterfaceName(), bVerbose);
RuntimeOutput.print("==> RMI registry port: " + objInitInfo.getRMIRegistryPort(), bVerbose);
RuntimeOutput.print("==> RMI stub port: " + objInitInfo.getRMIStubPort(), bVerbose);
RuntimeOutput.print("==> Object name: " + objSecObj.getObjectName(), bVerbose);
RuntimeOutput.print("==> Object class name: " + objSecObj.getObjectClassName(), bVerbose);
RuntimeOutput.print("==> Object class interface: " + objSecObj.getObjectClassInterfaceName(), bVerbose);
+ RuntimeOutput.print("==> Object stub class interface: " + objInitInfo.getObjectStubClassInterfaceName(), bVerbose);
RuntimeOutput.print("==> RMI registry port: " + objSecObj.getRMIRegistryPort(), bVerbose);
RuntimeOutput.print("==> RMI stub port: " + objSecObj.getRMIStubPort(), bVerbose);
}
}
}
}
-
- public static void main(String[] args) throws Exception {
-
- ObjectInitHandler objInitHand = new ObjectInitHandler(true);
- // Field #1 IoTSet
- objInitHand.addField("someField1", IoTCommCode.CREATE_NEW_IOTSET);
- objInitHand.addObjectIntoField("someField1", "192.168.2.191", "LifxLightBulbLB1",
- "LifxLightBulb", "LightBulb", 1234, 2345);
- objInitHand.addObjectIntoField("someField1", "192.168.2.192", "LifxLightBulbLB2",
- "LifxLightBulb", "LightBulb", 4321, 5432);
-
- // Field #2 IoTRelation
- objInitHand.addField("someField2", IoTCommCode.CREATE_NEW_IOTRELATION);
- objInitHand.addObjectIntoField("someField2", "192.168.2.191", "LifxLightBulbLB1",
- "LifxLightBulb", "LightBulb", 1111, 2222);
- objInitHand.addSecondObjectIntoField("someField2", "192.168.2.192", "LifxLightBulbLB1",
- "LifxLightBulb", "LightBulb", 3333, 4444);
-
- objInitHand.addObjectIntoField("someField2", "192.168.2.191", "LifxLightBulbLB2",
- "LifxLightBulb", "LightBulb", 5555, 6666);
- objInitHand.addSecondObjectIntoField("someField2", "192.168.2.192", "LifxLightBulbLB2",
- "LifxLightBulb", "LightBulb", 7777, 8888);
-
- // Field #3 IoTSet
- objInitHand.addField("someField3", IoTCommCode.CREATE_NEW_IOTSET);
- objInitHand.addObjectIntoField("someField3", "192.168.2.191", "LifxLightBulbLB1",
- "LifxLightBulb", "LightBulb", 5678, 8989);
- objInitHand.addObjectIntoField("someField3", "192.168.2.192", "LifxLightBulbLB2",
- "LifxLightBulb", "LightBulb", 5432, 4576);
- objInitHand.printLists();
- //objInitHand.addField("someField1", IoTCommCode.CREATE_NEW_IOTSET, null, null);
- }
}
* Constructor
*/
public ObjectInitInfo(String _strIoTSlaveObjectHostAdd, String _strObjName,
- String _strObjClassName, String _strObjClassInterfaceName,
+ String _strObjClassName, String _strObjClassInterfaceName, String _strObjStubClsIntfaceName,
int _iRMIRegPort, int _iRMIStubPort) {
- super(_strIoTSlaveObjectHostAdd, _strObjName, _strObjClassName, _strObjClassInterfaceName);
+ super(_strIoTSlaveObjectHostAdd, _strObjName, _strObjClassName, _strObjClassInterfaceName, _strObjStubClsIntfaceName);
iRMIRegPort = _iRMIRegPort;
iRMIStubPort = _iRMIStubPort;
}
private String sObjClass;
private String sObjName;
private String sObjIntName;
+ private String sObjStubIntName;
private int iRMIRegPort;
private int iRMIStubPort;
private Object[] arrObjFields;
* Class constructor (to tell IoTSlave to create a new object)
*/
public MessageCreateObject(IoTCommCode sMsg, String sHAddress, String sOClass,
- String sOName, String sOIName, int iRRPort, int iRSPort,
+ String sOName, String sOIName, String sOSIName, int iRRPort, int iRSPort,
Object[] arrOFlds, Class[] arrOFldCls) {
super(sMsg);
sObjClass = sOClass;
sObjName = sOName;
sObjIntName = sOIName;
+ sObjStubIntName = sOSIName;
iRMIRegPort = iRRPort;
iRMIStubPort = iRSPort;
arrObjFields = arrOFlds;
return sObjIntName;
}
+ /**
+ * getObjectStubInterfaceName() method
+ *
+ * @return String
+ */
+ public String getObjectStubInterfaceName() {
+ return sObjStubIntName;
+ }
+
/**
* getRMIRegPort() method
*
sObjIntName = sOIName;
}
+ /**
+ * setObjectStubInterfaceName() method
+ *
+ * @param sOIName String object name
+ * @return void
+ */
+ public void setObjectStubInterfaceName(String sOSIName) {
+ sObjStubIntName = sOSIName;
+ }
+
/**
* setRMIRegPort() method
*
private String sObjClass;
private String sObjName;
private String sObjIntName;
+ private String sObjStubIntName;
private int iRMIRegPort;
private int iRMIStubPort;
private Object[] arrObjFields;
* Class constructor (to tell IoTSlave controller to get objects for IoTSet/IoTRelation)
*/
public MessageGetObject(IoTCommCode sMsg, String sHAddress, String sOName,
- String sOClass, String sOIName, int iRRPort, int iRSPort) {
+ String sOClass, String sOIName, String sOSIName, int iRRPort, int iRSPort) {
super(sMsg);
sObjClass = sOClass;
sObjName = sOName;
sObjIntName = sOIName;
+ sObjStubIntName = sOSIName;
iRMIRegPort = iRRPort;
iRMIStubPort = iRSPort;
}
return sObjIntName;
}
+ /**
+ * getObjectStubInterfaceName() method
+ *
+ * @return String
+ */
+ public String getObjectStubInterfaceName() {
+ return sObjStubIntName;
+ }
+
/**
* getRMIRegPort() method
*
sObjIntName = sOIName;
}
+ /**
+ * setObjectStubInterfaceName() method
+ *
+ * @param sOIName String object name
+ * @return void
+ */
+ public void setObjectStubInterfaceName(String sOSIName) {
+ sObjStubIntName = sOSIName;
+ }
+
/**
* setRMIRegPort() method
*
import java.lang.Class;
import java.lang.reflect.*;
import java.lang.ClassLoader;
+import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;
import java.net.URL;
import java.rmi.NotBoundException;
import java.rmi.server.UnicastRemoteObject;
import java.util.Properties;
+import java.util.HashMap;
+import java.util.Map;
// Zip/Unzip utility
import net.lingala.zip4j.exception.ZipException;
*/
private Message sIoTMasterMsg;
private String sIoTMasterHostAdd;
+ private String sMainObjectName;
private int iComPort;
private int iRMIRegPort;
private int iRMIStubPort;
private Socket socket;
private ObjectOutputStream outStream;
private ObjectInputStream inStream;
+
/**
* IoTSet object, e.g. IoTSet<ProximitySensor> proximity_sensors;
* IoTRelation object, e.g. IoTRelation<ProximitySensor, LightBulb> ps_lb_relation;
private static String STR_JAR_FILE_PATH;
private static String STR_OBJ_CLS_PFX;
private static String STR_INTERFACE_PFX;
+ private static String SKEL_CLASS_SUFFIX;
+ private static String STUB_CLASS_SUFFIX;
private static boolean BOOL_VERBOSE;
+ private static boolean CAPAB_BASED_RMI;
/**
* IoTSlave class constants - not to be changed by users
iComPort = Integer.parseInt(argInp[1]);
iRMIRegPort = Integer.parseInt(argInp[2]);
iRMIStubPort = Integer.parseInt(argInp[3]);
+ sMainObjectName = null;
strFieldName = null;
clsMain = null;
objMainCls = null;
STR_JAR_FILE_PATH = null;
STR_OBJ_CLS_PFX = null;
STR_INTERFACE_PFX = null;
+ SKEL_CLASS_SUFFIX = null;
+ STUB_CLASS_SUFFIX = null;
BOOL_VERBOSE = false;
+ CAPAB_BASED_RMI = false;
}
/**
STR_JAR_FILE_PATH = prop.getProperty("JAR_FILE_PATH");
STR_OBJ_CLS_PFX = prop.getProperty("OBJECT_CLASS_PREFIX");
STR_INTERFACE_PFX = prop.getProperty("INTERFACE_PREFIX");
- STR_INTERFACE_PFX = prop.getProperty("INTERFACE_PREFIX");
+ SKEL_CLASS_SUFFIX = prop.getProperty("SKEL_CLASS_SUFFIX");
+ STUB_CLASS_SUFFIX = prop.getProperty("STUB_CLASS_SUFFIX");
if (prop.getProperty("VERBOSE").equals(STR_YES)) {
BOOL_VERBOSE = true;
}
+ if (prop.getProperty("CAPAB_BASED_RMI").equals(STR_YES)) {
+ CAPAB_BASED_RMI = true;
+ }
System.out.println("JAR_FILE_PATH=" + STR_JAR_FILE_PATH);
System.out.println("OBJECT_CLASS_PREFIX=" + STR_OBJ_CLS_PFX);
System.out.println("INTERFACE_PREFIX=" + STR_INTERFACE_PFX);
+ System.out.println("SKEL_CLASS_SUFFIX=" + SKEL_CLASS_SUFFIX);
+ System.out.println("STUB_CLASS_SUFFIX=" + STUB_CLASS_SUFFIX);
+ System.out.println("CAPAB_BASED_RMI=" + CAPAB_BASED_RMI);
System.out.println("IoTMaster: Information extracted successfully!");
}
}
}
+ /**
+ * A private method to create object
+ *
+ * @return void
+ */
+ private void createCapabBasedRMIJava(MessageCreateObject sMessage) throws
+ ClassNotFoundException, NoSuchMethodException {
+
+ // Instantiate the skeleton and put in the object
+ String strObjSkelName = STR_OBJ_CLS_PFX + "." + sMessage.getObjectClass() +
+ "." + sMessage.getObjectInterfaceName() + SKEL_CLASS_SUFFIX;
+ RuntimeOutput.print("IoTSlave: Skeleton object: " + strObjSkelName, BOOL_VERBOSE);
+ Class<?> clsSkel = Class.forName(strObjSkelName);
+ Class<?> clsInt = Class.forName(STR_OBJ_CLS_PFX + "." + STR_INTERFACE_PFX +
+ "." + sMessage.getObjectInterfaceName());
+ Class[] clsSkelParams = { clsInt, int.class }; // Port number is integer
+ Constructor<?> objSkelCons = clsSkel.getDeclaredConstructor(clsSkelParams);
+ Object objSkelParams[] = { objMainCls, iRMIStubPort };
+ // Create a new thread for each skeleton
+ Thread objectThread = new Thread(new Runnable() {
+ public void run() {
+ try {
+ Object objSkel = objSkelCons.newInstance(objSkelParams);
+ } catch (InstantiationException |
+ IllegalAccessException |
+ InvocationTargetException ex) {
+ ex.printStackTrace();
+ }
+ }
+ });
+ objectThread.start();
+ RuntimeOutput.print("IoTSlave: Done generating object!", BOOL_VERBOSE);
+ }
+
/**
* A private method to create object
*
// Translating into the actual Message class
MessageCreateObject sMessage = (MessageCreateObject) sIoTMasterMsg;
-
// Instantiate object using reflection
String strObjClassName = STR_OBJ_CLS_PFX + "." + sMessage.getObjectClass() +
"." + sMessage.getObjectClass();
sMessage.getObjectClass() + STR_JAR_FILE_EXT, BOOL_VERBOSE);
addURL(file.toURI().toURL());
clsMain = Class.forName(strObjClassName);
-
Class[] clsParams = sMessage.getObjectFldCls();
Constructor<?> ct = clsMain.getDeclaredConstructor(clsParams);
Object objParams[] = sMessage.getObjectFields();
objMainCls = ct.newInstance(objParams);
- RuntimeOutput.print("IoTSlave: Create object!", BOOL_VERBOSE);
-
- // Register object to RMI - there are 2 ports: RMI registry port and RMI stub port
- Object objStub = (Object)
- UnicastRemoteObject.exportObject((Remote) objMainCls, iRMIStubPort);
- Registry registry = LocateRegistry.createRegistry(iRMIRegPort);
- registry.bind(sMessage.getObjectName(), (Remote) objStub);
+ RuntimeOutput.print("IoTSlave: Creating RMI skeleton: " +
+ sMessage.getHostAddress() + ":" + sMessage.getRMIRegPort() +
+ " with RMI stub port: " + iRMIStubPort, BOOL_VERBOSE);
+ if (CAPAB_BASED_RMI) {
+ // Use the new capability-based RMI in Java
+ createCapabBasedRMIJava(sMessage);
+ } else {
+ // Register object to RMI - there are 2 ports: RMI registry port and RMI stub port
+ Object objStub = (Object)
+ UnicastRemoteObject.exportObject((Remote) objMainCls, iRMIStubPort);
+ Registry registry = LocateRegistry.createRegistry(iRMIRegPort);
+ registry.bind(sMessage.getObjectName(), (Remote) objStub);
+ }
outStream.writeObject(new MessageSimple(IoTCommCode.ACKNOWLEDGED));
RuntimeOutput.print("IoTSlave: Registering object via RMI!", BOOL_VERBOSE);
addURL(file.toURI().toURL());
// We will always have a package name <object name>.<object name>
// e.g. SmartLightsController.SmartLightsController
- clsMain = Class.forName(sMessage.getObjectName() + "." + sMessage.getObjectName());
+ sMainObjectName = sMessage.getObjectName();
+ clsMain = Class.forName(sMainObjectName + "." + sMainObjectName);
objMainCls = clsMain.newInstance();
// Send back the received message as acknowledgement
return stubObjConv;
}
+ /**
+ * A private method to get an object and create a stub
+ * <p>
+ * This is using the capability-based RMI skeleton and stub scheme
+ *
+ * @return Object
+ */
+ private Object getObjectFromStub() throws RemoteException,
+ ClassNotFoundException, NoSuchMethodException, InstantiationException,
+ IllegalAccessException, NotBoundException, InvocationTargetException, UnknownHostException {
+
+ // Translating into the actual Message class
+ MessageGetObject sMessage = (MessageGetObject) sIoTMasterMsg;
+ // Instantiate the stub and put in the object
+ String strObjStubName = sMainObjectName + "." + sMessage.getObjectStubInterfaceName() + STUB_CLASS_SUFFIX;
+ RuntimeOutput.print("IoTSlave: Stub object: " + strObjStubName, BOOL_VERBOSE);
+ Class<?> clsStub = Class.forName(strObjStubName); // Port number is integer
+ Class[] clsStubParams = { int.class, String.class, String.class, int.class, int[].class };
+ Constructor<?> objStubCons = clsStub.getDeclaredConstructor(clsStubParams);
+ int[] ports = { sMessage.getRMIRegPort() }; // TODO: Change this temporary use of reg port for callbacks
+ int rev = 0;
+ String callbackAddress = InetAddress.getLocalHost().getHostAddress(); // Callback address is this machine's address
+ Object objStubParams[] = { sMessage.getRMIStubPort(), sMessage.getHostAddress(), callbackAddress,
+ rev, ports };
+ RuntimeOutput.print("IoTSlave: Creating RMI stub: " +
+ sMessage.getHostAddress() + ":" + sMessage.getRMIRegPort() +
+ " with callback address: " + callbackAddress + " and RMI stub port: " + sMessage.getRMIStubPort(), BOOL_VERBOSE);
+ Object stubObj = objStubCons.newInstance(objStubParams);
+ RuntimeOutput.print("IoTSlave: Object name: " + sMessage.getObjectName(), BOOL_VERBOSE);
+ RuntimeOutput.print("IoTSlave: Stub address: " + callbackAddress, BOOL_VERBOSE);
+ // Class conversion to interface class of this class,
+ // e.g. ProximitySensorImpl has ProximitySensor interface
+ String strObjClassInterfaceName = STR_OBJ_CLS_PFX + "." + STR_INTERFACE_PFX + "." +
+ sMessage.getObjectStubInterfaceName();
+ Class<?> clsInf = Class.forName(strObjClassInterfaceName);
+ Object stubObjConv = clsInf.cast(stubObj);
+
+ return stubObjConv;
+ }
+
/**
* A private method to get an IoTSet object
*
* @return void
*/
private void getIoTSetObject() throws IOException,
- ClassNotFoundException, RemoteException, NotBoundException {
-
- Object objRegistry = getObjectFromRegistry();
+ ClassNotFoundException, RemoteException, NotBoundException, NoSuchMethodException,
+ InstantiationException, IllegalAccessException, InvocationTargetException {
+
+ Object objRegistry = null;
+ if (CAPAB_BASED_RMI)
+ objRegistry = getObjectFromStub();
+ else
+ objRegistry = getObjectFromRegistry();
isetObject.add(objRegistry);
RuntimeOutput.print("IoTSlave: This IoTSet now has: " + isetObject.size() + " entry(s)", BOOL_VERBOSE);
// Send back the received message as acknowledgement
outStream.writeObject(new MessageSimple(IoTCommCode.ACKNOWLEDGED));
RuntimeOutput.print("IoTSlave: Getting an object for IoTSet!", BOOL_VERBOSE);
-
}
/**
* @return void
*/
private void getIoTRelationFirstObject() throws IOException,
- ClassNotFoundException, RemoteException, NotBoundException {
-
- Object objRegistry = getObjectFromRegistry();
+ ClassNotFoundException, RemoteException, NotBoundException, NoSuchMethodException,
+ InstantiationException, IllegalAccessException, InvocationTargetException {
+
+ Object objRegistry = null;
+ if (CAPAB_BASED_RMI)
+ objRegistry = getObjectFromStub();
+ else
+ objRegistry = getObjectFromRegistry();
iRelFirstObject = objRegistry;
// Send back the received message as acknowledgement
* @return void
*/
private void getIoTRelationSecondObject() throws IOException,
- ClassNotFoundException, RemoteException, NotBoundException {
-
- Object objRegistry = getObjectFromRegistry();
+ ClassNotFoundException, RemoteException, NotBoundException, NoSuchMethodException,
+ InstantiationException, IllegalAccessException, InvocationTargetException {
+
+ Object objRegistry = null;
+ if (CAPAB_BASED_RMI)
+ objRegistry = getObjectFromStub();
+ else
+ objRegistry = getObjectFromRegistry();
iRelSecondObject = objRegistry;
// Now add the first and the second object into IoTRelation
inStream.close();
socket.close();
RuntimeOutput.print("IoTSlave: Closing!", BOOL_VERBOSE);
+ // We have to continuously loop because we are preserving our stubs and skeletons
+ //while(true) { }
} catch (IOException |
ClassNotFoundException |
MAC_ADDRESS=74:da:38:68:72:8a
IOT_CODE_PATH=./../iotcode/
CONTROLLERS_CODE_PATH=../
-RUNTIME_DIR=~/iotjava/iotruntime;
-#CLASS_PATH=-cp .:/usr/share/java/*:./../../iotjava/:./../../iotjava/iotruntime/:./../../iotjava/iotinstaller/
-CLASS_PATH=-cp .:/usr/share/java/*:./../:./../iotruntime/:./../iotinstaller/
+RUNTIME_DIR=~/iot2/iotjava/iotruntime;
+#CLASS_PATH=-cp .:/usr/share/java/*:./../../iotjava/:./../../iotjava/iotruntime/:./../../iotjava/iotinstaller/:./../../iotjava/iotrmi/
+CLASS_PATH=-cp .:/usr/share/java/*:./../:./../iotruntime/:./../iotinstaller/:./../../iotjava/iotrmi/
#benchmarks/libs/boofcv_libs/* - we usually put these benchmark codes in /usr/share/java on compute nodes
#benchmarks/libs/georegression_libs/* - we usually put these benchmark codes in /usr/share/java on compute nodes
# e.g. interfaces.Camera - basically the path of the interface class file
INTERFACE_PREFIX=interfaces
-#Verboseness of runtime messages
+# Skeleton suffix, e.g. _Skeleton for Camera_Skeleton.class
+SKEL_CLASS_SUFFIX=_Skeleton
+
+# Skeleton suffix, e.g. _Stub for CameraSpecial_Stub.class
+STUB_CLASS_SUFFIX=_Stub
+
+# Verboseness of runtime messages
VERBOSE=Yes
+
+# Capability-based RMI - default is Java RMI
+CAPAB_BASED_RMI=Yes
# MySQLInterface configuration
-HOST=128.195.204.105
+#HOST=128.195.204.105
+HOST=localhost
DATABASE=IoTMain
USERNAME=root
PASSWORD=root
projects / iot2.git / commitdiff