Adjusting C++ files to compile with gcc 4.9.3

[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 f46eae2..3124cf4 100644 (file)
--- a/benchmarks/drivers/Cpp/LabRoom/Room_Skeleton.cpp
+++ b/benchmarks/drivers/Cpp/LabRoom/Room_Skeleton.cpp
@@ -1,18 +1,112 @@
 #include <iostream>
 #include "Room_Skeleton.hpp"
 
 #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) {
+       // Logging
+       int i=0;
+       string file = "Room_Skeleton_cpp" + to_string(i) + ".log";
+       while (ifstream(file.c_str())) {
+               i++;
+               file = "Room_Skeleton_cpp" + to_string(i) + ".log";
+       }
+       log.open(file);
+       log << "Port send: " << _portSend << endl;
+       log << "Port receive: " << _portRecv << endl;
+       bool _bResult = false;
+       mainObj = _mainObj;
+       rmiComm = new IoTRMICommServer(_portSend, _portRecv, &_bResult);
+       log << "Established connection with slave! Wait request invoke now..." << endl;
+       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) {
+}
+
+int main() {
+       return 0;
+}