Cleaning up the Makefile for compiler related commands; cleaning up C++ stubs and...

[iot2.git] / benchmarks / drivers / Cpp / LabRoom / Room_Skeleton.cpp

diff --git a/benchmarks/drivers/Cpp/LabRoom/Room_Skeleton.cpp b/benchmarks/drivers/Cpp/LabRoom/Room_Skeleton.cpp
index 8782fde485d1c072443ff89487753d35b58b4701..f0575ded0168c54a3c651950803e637ebb276d38 100644 (file)
--- a/benchmarks/drivers/Cpp/LabRoom/Room_Skeleton.cpp
+++ b/benchmarks/drivers/Cpp/LabRoom/Room_Skeleton.cpp
@@ -1,25 +1,101 @@
 #include <iostream>
 #include "Room_Skeleton.hpp"
 
+using namespace std;
 
-// External create, destroy, and init functions
-extern "C" void* createRoom_Skeleton(void** params) {
-       // Arguments: Room *_mainObj, string _callbackAddress, int _port
-       return new Room_Skeleton((Room*) params[0], *((string*) params[1]), *((int*) params[2]));
+Room_Skeleton::Room_Skeleton(Room *_mainObj, int _portSend, int _portRecv) {
+       bool _bResult = false;
+       mainObj = _mainObj;
+       rmiComm = new IoTRMICommServer(_portSend, _portRecv, &_bResult);
+       IoTRMIUtil::mapSkel->insert(make_pair(_mainObj, this));
+       IoTRMIUtil::mapSkelId->insert(make_pair(_mainObj, objectId));
+       rmiComm->registerSkeleton(objectId, &methodReceived);
+       thread th1 (&Room_Skeleton::___waitRequestInvokeMethod, this, this);
+       th1.join();
 }
 
+Room_Skeleton::Room_Skeleton(Room *_mainObj, IoTRMIComm *_rmiComm, int _objectId) {
+       bool _bResult = false;
+       mainObj = _mainObj;
+       rmiComm = _rmiComm;
+       objectId = _objectId;
+       rmiComm->registerSkeleton(objectId, &methodReceived);
+}
 
-extern "C" void destroyRoom_Skeleton(void* t) {
-       Room_Skeleton* rs = (Room_Skeleton*) t;
-       delete rs;
+Room_Skeleton::~Room_Skeleton() {
+       if (rmiComm != NULL) {
+               delete rmiComm;
+               rmiComm = NULL;
+       }
 }
 
+bool Room_Skeleton::didInitWaitInvoke() {
+       return didAlreadyInitWaitInvoke;
+}
+
+int Room_Skeleton::getRoomID() {
+       return mainObj->getRoomID();
+}
+
+void Room_Skeleton::___getRoomID(Room_Skeleton* skel) {
+       char* localMethodBytes = new char[methodLen];
+       memcpy(localMethodBytes, skel->methodBytes, methodLen);
+       didGetMethodBytes.exchange(true);
+       string paramCls[] = {  };
+       int numParam = 0;
+       void* paramObj[] = {  };
+       rmiComm->getMethodParams(paramCls, numParam, paramObj, localMethodBytes);
+       int retVal = getRoomID();
+       void* retObj = &retVal;
+       rmiComm->sendReturnObj(retObj, "int", localMethodBytes);
+       delete[] localMethodBytes;
+}
+
+void Room_Skeleton::___waitRequestInvokeMethod(Room_Skeleton* skel) {
+       skel->didAlreadyInitWaitInvoke = true;
+       while (true) {
+               if (!methodReceived) {
+                       continue;
+               }
+               skel->methodBytes = skel->rmiComm->getMethodBytes();
+               skel->methodLen = skel->rmiComm->getMethodLength();
+               methodReceived = false;
+               int _objectId = skel->rmiComm->getObjectId(skel->methodBytes);
+               int methodId = skel->rmiComm->getMethodId(skel->methodBytes);
+               if (_objectId == objectId) {
+                       if (set0Allowed.find(methodId) == set0Allowed.end()) {
+                               cerr << "Object with object Id: " << _objectId << "  is not allowed to access method: " << methodId << endl;
+                               return;
+                       }
+               }
+               else {
+                       continue;
+               }
+               switch (methodId) {
+                       case 0: {
+                               thread th0 (&Room_Skeleton::___getRoomID, skel, skel);
+                               th0.detach(); break;
+                       }
+                       default: 
+                       cerr << "Method Id " << methodId << " not recognized!" << endl;
+                       return;
+               }
+       }
+}
+
+extern "C" void* createRoom_Skeleton(void** params) {
+       // Args: *_mainObj, int _portSend, int _portRecv
+       return new Room_Skeleton((Room*) params[0], *((int*) params[1]), *((int*) params[2]));
+}
+
+extern "C" void destroyRoom_Skeleton(void* t) {
+       Room_Skeleton* obj = (Room_Skeleton*) t;
+       delete obj;
+}
 
 extern "C" void initRoom_Skeleton(void* t) {
-       // TODO: We actually need init() in LabRoom class
-       // But, this is declared here just for the sake of consistency for Sentinel
-       // In this case, we need the symbol "init" when loading object handlers with .so files
-       //Room_Skeleton* rs = (Room_Skeleton*) t;
-       //rs->init();
 }
 
+int main() {
+       return 0;
+}