#include <iostream>
-#include <thread>
#include "LightBulbTest_Stub.hpp"
-// External create, destroy, and init functions
-extern "C" void* createLightBulbTest_Stub(void** params) {
- // Arguments: int _port, const char* _skeletonAddress, string _callbackAddress, int _rev, bool* _bResult, vector<int> _ports
- return new LightBulbTest_Stub(*((int*) params[0]), ((string*) params[1])->c_str(), *((string*) params[2]), *((int*) params[3]), (bool*) params[4], *((vector<int>*) params[5]));
+using namespace std;
+
+//LightBulbTest_Stub::LightBulbTest_Stub(int _portSend, int _portRecv, const char* _skeletonAddress, int _rev, bool* _bResult) {
+LightBulbTest_Stub::LightBulbTest_Stub(int _portSend, int _portRecv, const char* _skeletonAddress, int _rev, bool* _bResult) {
+
+ int i=0;
+ string file = "LightBulbTest_cpp" + to_string(i) + ".log";
+ while (ifstream(file.c_str())) {
+ i++;
+ file = "LightBulbTest_cpp" + to_string(i) + ".log";
+ }
+ log.open(file);
+ log << "Constructing LightBulbTest_Stub!" << endl;
+ log << "Port send: " << _portSend << endl;
+ log << "Port recv: " << _portRecv << endl;
+ log << "Skeleton addr: " << _skeletonAddress << endl;
+ log << "Rev: " << _rev << endl;
+ log << "Result: " << _bResult << endl;
+
+ rmiComm = new IoTRMICommClient(_portSend, _portRecv, _skeletonAddress, _rev, _bResult);
+ log << "Reached 1!" << endl;
+ rmiComm->registerStub(objectId, 6, &retValueReceived6);
+ rmiComm->registerStub(objectId, 3, &retValueReceived3);
+ rmiComm->registerStub(objectId, 8, &retValueReceived8);
+ rmiComm->registerStub(objectId, 7, &retValueReceived7);
+ rmiComm->registerStub(objectId, 9, &retValueReceived9);
+ IoTRMIUtil::mapStub->insert(make_pair(objectId, this));
+}
+
+LightBulbTest_Stub::LightBulbTest_Stub(IoTRMIComm* _rmiComm, int _objectId) {
+ rmiComm = _rmiComm;
+ objectId = _objectId;
+ rmiComm->registerStub(objectId, 6, &retValueReceived6);
+ rmiComm->registerStub(objectId, 3, &retValueReceived3);
+ rmiComm->registerStub(objectId, 8, &retValueReceived8);
+ rmiComm->registerStub(objectId, 7, &retValueReceived7);
+ rmiComm->registerStub(objectId, 9, &retValueReceived9);
}
+LightBulbTest_Stub::~LightBulbTest_Stub() {
+ if (rmiComm != NULL) {
+ delete rmiComm;
+ rmiComm = NULL;
+ }
+}
-extern "C" void destroyLightBulbTest_Stub(void* t) {
- LightBulbTest_Stub* lbs = (LightBulbTest_Stub*) t;
- delete lbs;
+mutex mtxLightBulbTest_StubMethodExec2;
+void LightBulbTest_Stub::turnOn() {
+ lock_guard<mutex> guard(mtxLightBulbTest_StubMethodExec2);
+ int methodId = 2;
+ string retType = "void";
+ int numParam = 0;
+ string paramCls[] = { };
+ void* paramObj[] = { };
+ rmiComm->remoteCall(objectId, methodId, paramCls, paramObj, numParam);
+}
+
+mutex mtxLightBulbTest_StubMethodExec6;
+double LightBulbTest_Stub::getBrightness() {
+ lock_guard<mutex> guard(mtxLightBulbTest_StubMethodExec6);
+ int methodId = 6;
+ string retType = "double";
+ int numParam = 0;
+ string paramCls[] = { };
+ void* paramObj[] = { };
+ double retVal = 0;
+ void* retObj = &retVal;
+ rmiComm->remoteCall(objectId, methodId, paramCls, paramObj, numParam);
+ // Waiting for return value
+ while (!retValueReceived6);
+ rmiComm->getReturnValue(retType, retObj);
+ retValueReceived6 = false;
+ didGetReturnBytes.exchange(true);
+
+ return retVal;
+}
+
+mutex mtxLightBulbTest_StubMethodExec1;
+void LightBulbTest_Stub::turnOff() {
+ lock_guard<mutex> guard(mtxLightBulbTest_StubMethodExec1);
+ int methodId = 1;
+ string retType = "void";
+ int numParam = 0;
+ string paramCls[] = { };
+ void* paramObj[] = { };
+ rmiComm->remoteCall(objectId, methodId, paramCls, paramObj, numParam);
+}
+
+mutex mtxLightBulbTest_StubMethodExec3;
+bool LightBulbTest_Stub::getState() {
+ lock_guard<mutex> guard(mtxLightBulbTest_StubMethodExec3);
+ int methodId = 3;
+ string retType = "boolean";
+ int numParam = 0;
+ string paramCls[] = { };
+ void* paramObj[] = { };
+ bool retVal = false;
+ void* retObj = &retVal;
+ rmiComm->remoteCall(objectId, methodId, paramCls, paramObj, numParam);
+ // Waiting for return value
+ while (!retValueReceived3);
+ rmiComm->getReturnValue(retType, retObj);
+ retValueReceived3 = false;
+ didGetReturnBytes.exchange(true);
+
+ return retVal;
}
+mutex mtxLightBulbTest_StubMethodExec4;
+void LightBulbTest_Stub::setColor(double _hue, double _saturation, double _brightness) {
+ lock_guard<mutex> guard(mtxLightBulbTest_StubMethodExec4);
+ int methodId = 4;
+ string retType = "void";
+ int numParam = 3;
+ string paramCls[] = { "double", "double", "double" };
+ void* paramObj[] = { &_hue, &_saturation, &_brightness };
+ rmiComm->remoteCall(objectId, methodId, paramCls, paramObj, numParam);
+}
+
+mutex mtxLightBulbTest_StubMethodExec8;
+double LightBulbTest_Stub::getSaturation() {
+ lock_guard<mutex> guard(mtxLightBulbTest_StubMethodExec8);
+ int methodId = 8;
+ string retType = "double";
+ int numParam = 0;
+ string paramCls[] = { };
+ void* paramObj[] = { };
+ double retVal = 0;
+ void* retObj = &retVal;
+ rmiComm->remoteCall(objectId, methodId, paramCls, paramObj, numParam);
+ // Waiting for return value
+ while (!retValueReceived8);
+ rmiComm->getReturnValue(retType, retObj);
+ retValueReceived8 = false;
+ didGetReturnBytes.exchange(true);
+
+ return retVal;
+}
+
+mutex mtxLightBulbTest_StubMethodExec0;
+void LightBulbTest_Stub::init() {
+ lock_guard<mutex> guard(mtxLightBulbTest_StubMethodExec0);
+ int methodId = 0;
+ string retType = "void";
+ int numParam = 0;
+ string paramCls[] = { };
+ void* paramObj[] = { };
+ rmiComm->remoteCall(objectId, methodId, paramCls, paramObj, numParam);
+}
+
+mutex mtxLightBulbTest_StubMethodExec5;
+void LightBulbTest_Stub::setTemperature(int _temperature) {
+ lock_guard<mutex> guard(mtxLightBulbTest_StubMethodExec5);
+ int methodId = 5;
+ string retType = "void";
+ int numParam = 1;
+ string paramCls[] = { "int" };
+ void* paramObj[] = { &_temperature };
+ rmiComm->remoteCall(objectId, methodId, paramCls, paramObj, numParam);
+}
+
+mutex mtxLightBulbTest_StubMethodExec7;
+double LightBulbTest_Stub::getHue() {
+ lock_guard<mutex> guard(mtxLightBulbTest_StubMethodExec7);
+ int methodId = 7;
+ string retType = "double";
+ int numParam = 0;
+ string paramCls[] = { };
+ void* paramObj[] = { };
+ double retVal = 0;
+ void* retObj = &retVal;
+ rmiComm->remoteCall(objectId, methodId, paramCls, paramObj, numParam);
+ // Waiting for return value
+ while (!retValueReceived7);
+ rmiComm->getReturnValue(retType, retObj);
+ retValueReceived7 = false;
+ didGetReturnBytes.exchange(true);
+
+ return retVal;
+}
+
+mutex mtxLightBulbTest_StubMethodExec9;
+int LightBulbTest_Stub::getTemperature() {
+ lock_guard<mutex> guard(mtxLightBulbTest_StubMethodExec9);
+ int methodId = 9;
+ string retType = "int";
+ int numParam = 0;
+ string paramCls[] = { };
+ void* paramObj[] = { };
+ int retVal = 0;
+ void* retObj = &retVal;
+ rmiComm->remoteCall(objectId, methodId, paramCls, paramObj, numParam);
+ // Waiting for return value
+ while (!retValueReceived9);
+ rmiComm->getReturnValue(retType, retObj);
+ retValueReceived9 = false;
+ didGetReturnBytes.exchange(true);
+
+ return retVal;
+}
+
+extern "C" void* createLightBulbTest_Stub(void** params) {
+ // Args: int _portSend, int _portRecv, const char* _skeletonAddress, int _rev, bool* _bResult
+ return new LightBulbTest_Stub(*((int*) params[0]), *((int*) params[1]), ((string*) params[2])->c_str(), *((int*) params[3]), (bool*) params[4]);
+}
+
+extern "C" void destroyLightBulbTest_Stub(void* t) {
+ LightBulbTest_Stub* obj = (LightBulbTest_Stub*) t;
+ delete obj;
+}
extern "C" void initLightBulbTest_Stub(void* t) {
- LightBulbTest_Stub* lbs = (LightBulbTest_Stub*) t;
- lbs->init();
-}
-
-
-int main(int argc, char *argv[])
-{
- int stubPort = 55179;
- vector<int> ports;
- ports.push_back(58551);
- const char* skeletonAddress = "localhost";
- string callbackAddress = "localhost";
- int rev = 0;
- bool result = false;
- LightBulbTest_Stub *lbs = new LightBulbTest_Stub(stubPort, skeletonAddress, callbackAddress, rev, &result, ports);
- cout << "Successfully instantiated stub!" << endl;
- lbs->init();
- for (int i = 0; i < 100; i++) {
- lbs->turnOff();
- cout << "Turning off!" << endl;
- this_thread::sleep_for (chrono::milliseconds(1000));
- lbs->turnOn();
- cout << "Turning on!" << endl;
- this_thread::sleep_for (chrono::milliseconds(1000));
- }
+}
+int main() {
return 0;
}
projects / iot2.git / blobdiff