X-Git-Url: http://plrg.eecs.uci.edu/git/?p=iot2.git;a=blobdiff_plain;f=benchmarks%2Fdrivers%2FCpp%2FLifxLightBulb%2FLightBulb_Skeleton.cpp;h=b2ec39899ab3bf42d2db2e69bc8628b3de4c67b6;hp=aab1ac859ddd24bccf89e3d889c239c02183268b;hb=12cd536cebfeea6c5df468170b6388a9f6ff2f12;hpb=db205c86272ade784240295eb0e4c8d160f02717

diff --git a/benchmarks/drivers/Cpp/LifxLightBulb/LightBulb_Skeleton.cpp b/benchmarks/drivers/Cpp/LifxLightBulb/LightBulb_Skeleton.cpp
index aab1ac8..b2ec398 100644
--- a/benchmarks/drivers/Cpp/LifxLightBulb/LightBulb_Skeleton.cpp
+++ b/benchmarks/drivers/Cpp/LifxLightBulb/LightBulb_Skeleton.cpp
@@ -1,11 +1,470 @@
 #include <iostream>
 #include "LightBulb_Skeleton.hpp"
 
-// External creator/destroyer
-/*extern "C" LightBulb_Skeleton* create(LightBulb *_mainObj, string _callbackAddress, int _port) {
-	return new LightBulb_Skeleton(_mainObj, _callbackAddress, _port);
+using namespace std;
+
+LightBulb_Skeleton::LightBulb_Skeleton(LightBulb *_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 (&LightBulb_Skeleton::___waitRequestInvokeMethod, this, this);
+	th1.join();
+}
+
+LightBulb_Skeleton::LightBulb_Skeleton(LightBulb *_mainObj, IoTRMIComm *_rmiComm, int _objectId) {
+	bool _bResult = false;
+	mainObj = _mainObj;
+	rmiComm = _rmiComm;
+	objectId = _objectId;
+	rmiComm->registerSkeleton(objectId, &methodReceived);
+}
+
+LightBulb_Skeleton::~LightBulb_Skeleton() {
+	if (rmiComm != NULL) {
+		delete rmiComm;
+		rmiComm = NULL;
+	}
+}
+
+bool LightBulb_Skeleton::didInitWaitInvoke() {
+	return didAlreadyInitWaitInvoke;
+}
+
+void LightBulb_Skeleton::init() {
+	mainObj->init();
+}
+
+void LightBulb_Skeleton::turnOff() {
+	mainObj->turnOff();
+}
+
+void LightBulb_Skeleton::turnOn() {
+	mainObj->turnOn();
+}
+
+bool LightBulb_Skeleton::getState() {
+	return mainObj->getState();
+}
+
+void LightBulb_Skeleton::setColor(double _hue, double _saturation, double _brightness) {
+	mainObj->setColor(_hue, _saturation, _brightness);
+}
+
+void LightBulb_Skeleton::setTemperature(int _temperature) {
+	mainObj->setTemperature(_temperature);
+}
+
+double LightBulb_Skeleton::getBrightness() {
+	return mainObj->getBrightness();
+}
+
+double LightBulb_Skeleton::getHue() {
+	return mainObj->getHue();
+}
+
+double LightBulb_Skeleton::getSaturation() {
+	return mainObj->getSaturation();
+}
+
+int LightBulb_Skeleton::getTemperature() {
+	return mainObj->getTemperature();
+}
+
+double LightBulb_Skeleton::getBrightnessRangeLowerBound() {
+	return mainObj->getBrightnessRangeLowerBound();
+}
+
+double LightBulb_Skeleton::getBrightnessRangeUpperBound() {
+	return mainObj->getBrightnessRangeUpperBound();
+}
+
+double LightBulb_Skeleton::getHueRangeLowerBound() {
+	return mainObj->getHueRangeLowerBound();
+}
+
+double LightBulb_Skeleton::getHueRangeUpperBound() {
+	return mainObj->getHueRangeUpperBound();
+}
+
+double LightBulb_Skeleton::getSaturationRangeLowerBound() {
+	return mainObj->getSaturationRangeLowerBound();
+}
+
+double LightBulb_Skeleton::getSaturationRangeUpperBound() {
+	return mainObj->getSaturationRangeUpperBound();
+}
+
+int LightBulb_Skeleton::getTemperatureRangeLowerBound() {
+	return mainObj->getTemperatureRangeLowerBound();
+}
+
+int LightBulb_Skeleton::getTemperatureRangeUpperBound() {
+	return mainObj->getTemperatureRangeUpperBound();
+}
+
+void LightBulb_Skeleton::___init(LightBulb_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);
+	init();
+	delete[] localMethodBytes;
+}
+
+void LightBulb_Skeleton::___turnOff(LightBulb_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);
+	turnOff();
+	delete[] localMethodBytes;
+}
+
+void LightBulb_Skeleton::___turnOn(LightBulb_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);
+	turnOn();
+	delete[] localMethodBytes;
+}
+
+void LightBulb_Skeleton::___getState(LightBulb_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);
+	bool retVal = getState();
+	void* retObj = &retVal;
+	rmiComm->sendReturnObj(retObj, "boolean", localMethodBytes);
+	delete[] localMethodBytes;
+}
+
+void LightBulb_Skeleton::___setColor(LightBulb_Skeleton* skel) {
+	char* localMethodBytes = new char[methodLen];
+	memcpy(localMethodBytes, skel->methodBytes, methodLen);
+	didGetMethodBytes.exchange(true);
+	string paramCls[] = { "double", "double", "double" };
+	int numParam = 3;
+	double _hue;
+	double _saturation;
+	double _brightness;
+	void* paramObj[] = { &_hue, &_saturation, &_brightness };
+	rmiComm->getMethodParams(paramCls, numParam, paramObj, localMethodBytes);
+	setColor(_hue, _saturation, _brightness);
+	delete[] localMethodBytes;
+}
+
+void LightBulb_Skeleton::___setTemperature(LightBulb_Skeleton* skel) {
+	char* localMethodBytes = new char[methodLen];
+	memcpy(localMethodBytes, skel->methodBytes, methodLen);
+	didGetMethodBytes.exchange(true);
+	string paramCls[] = { "int" };
+	int numParam = 1;
+	int _temperature;
+	void* paramObj[] = { &_temperature };
+	rmiComm->getMethodParams(paramCls, numParam, paramObj, localMethodBytes);
+	setTemperature(_temperature);
+	delete[] localMethodBytes;
+}
+
+void LightBulb_Skeleton::___getBrightness(LightBulb_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);
+	double retVal = getBrightness();
+	void* retObj = &retVal;
+	rmiComm->sendReturnObj(retObj, "double", localMethodBytes);
+	delete[] localMethodBytes;
+}
+
+void LightBulb_Skeleton::___getHue(LightBulb_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);
+	double retVal = getHue();
+	void* retObj = &retVal;
+	rmiComm->sendReturnObj(retObj, "double", localMethodBytes);
+	delete[] localMethodBytes;
+}
+
+void LightBulb_Skeleton::___getSaturation(LightBulb_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);
+	double retVal = getSaturation();
+	void* retObj = &retVal;
+	rmiComm->sendReturnObj(retObj, "double", localMethodBytes);
+	delete[] localMethodBytes;
+}
+
+void LightBulb_Skeleton::___getTemperature(LightBulb_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 = getTemperature();
+	void* retObj = &retVal;
+	rmiComm->sendReturnObj(retObj, "int", localMethodBytes);
+	delete[] localMethodBytes;
+}
+
+void LightBulb_Skeleton::___getBrightnessRangeLowerBound(LightBulb_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);
+	double retVal = getBrightnessRangeLowerBound();
+	void* retObj = &retVal;
+	rmiComm->sendReturnObj(retObj, "double", localMethodBytes);
+	delete[] localMethodBytes;
+}
+
+void LightBulb_Skeleton::___getBrightnessRangeUpperBound(LightBulb_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);
+	double retVal = getBrightnessRangeUpperBound();
+	void* retObj = &retVal;
+	rmiComm->sendReturnObj(retObj, "double", localMethodBytes);
+	delete[] localMethodBytes;
+}
+
+void LightBulb_Skeleton::___getHueRangeLowerBound(LightBulb_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);
+	double retVal = getHueRangeLowerBound();
+	void* retObj = &retVal;
+	rmiComm->sendReturnObj(retObj, "double", localMethodBytes);
+	delete[] localMethodBytes;
+}
+
+void LightBulb_Skeleton::___getHueRangeUpperBound(LightBulb_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);
+	double retVal = getHueRangeUpperBound();
+	void* retObj = &retVal;
+	rmiComm->sendReturnObj(retObj, "double", localMethodBytes);
+	delete[] localMethodBytes;
+}
+
+void LightBulb_Skeleton::___getSaturationRangeLowerBound(LightBulb_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);
+	double retVal = getSaturationRangeLowerBound();
+	void* retObj = &retVal;
+	rmiComm->sendReturnObj(retObj, "double", localMethodBytes);
+	delete[] localMethodBytes;
+}
+
+void LightBulb_Skeleton::___getSaturationRangeUpperBound(LightBulb_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);
+	double retVal = getSaturationRangeUpperBound();
+	void* retObj = &retVal;
+	rmiComm->sendReturnObj(retObj, "double", localMethodBytes);
+	delete[] localMethodBytes;
+}
+
+void LightBulb_Skeleton::___getTemperatureRangeLowerBound(LightBulb_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 = getTemperatureRangeLowerBound();
+	void* retObj = &retVal;
+	rmiComm->sendReturnObj(retObj, "int", localMethodBytes);
+	delete[] localMethodBytes;
+}
+
+void LightBulb_Skeleton::___getTemperatureRangeUpperBound(LightBulb_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 = getTemperatureRangeUpperBound();
+	void* retObj = &retVal;
+	rmiComm->sendReturnObj(retObj, "int", localMethodBytes);
+	delete[] localMethodBytes;
+}
+
+void LightBulb_Skeleton::___waitRequestInvokeMethod(LightBulb_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 (&LightBulb_Skeleton::___init, skel, skel);
+				th0.detach(); break;
+			}
+			case 1: {
+				thread th1 (&LightBulb_Skeleton::___turnOff, skel, skel);
+				th1.detach(); break;
+			}
+			case 2: {
+				thread th2 (&LightBulb_Skeleton::___turnOn, skel, skel);
+				th2.detach(); break;
+			}
+			case 3: {
+				thread th3 (&LightBulb_Skeleton::___getState, skel, skel);
+				th3.detach(); break;
+			}
+			case 4: {
+				thread th4 (&LightBulb_Skeleton::___setColor, skel, skel);
+				th4.detach(); break;
+			}
+			case 5: {
+				thread th5 (&LightBulb_Skeleton::___setTemperature, skel, skel);
+				th5.detach(); break;
+			}
+			case 6: {
+				thread th6 (&LightBulb_Skeleton::___getBrightness, skel, skel);
+				th6.detach(); break;
+			}
+			case 7: {
+				thread th7 (&LightBulb_Skeleton::___getHue, skel, skel);
+				th7.detach(); break;
+			}
+			case 8: {
+				thread th8 (&LightBulb_Skeleton::___getSaturation, skel, skel);
+				th8.detach(); break;
+			}
+			case 9: {
+				thread th9 (&LightBulb_Skeleton::___getTemperature, skel, skel);
+				th9.detach(); break;
+			}
+			case 10: {
+				thread th10 (&LightBulb_Skeleton::___getBrightnessRangeLowerBound, skel, skel);
+				th10.detach(); break;
+			}
+			case 11: {
+				thread th11 (&LightBulb_Skeleton::___getBrightnessRangeUpperBound, skel, skel);
+				th11.detach(); break;
+			}
+			case 12: {
+				thread th12 (&LightBulb_Skeleton::___getHueRangeLowerBound, skel, skel);
+				th12.detach(); break;
+			}
+			case 13: {
+				thread th13 (&LightBulb_Skeleton::___getHueRangeUpperBound, skel, skel);
+				th13.detach(); break;
+			}
+			case 14: {
+				thread th14 (&LightBulb_Skeleton::___getSaturationRangeLowerBound, skel, skel);
+				th14.detach(); break;
+			}
+			case 15: {
+				thread th15 (&LightBulb_Skeleton::___getSaturationRangeUpperBound, skel, skel);
+				th15.detach(); break;
+			}
+			case 16: {
+				thread th16 (&LightBulb_Skeleton::___getTemperatureRangeLowerBound, skel, skel);
+				th16.detach(); break;
+			}
+			case 17: {
+				thread th17 (&LightBulb_Skeleton::___getTemperatureRangeUpperBound, skel, skel);
+				th17.detach(); break;
+			}
+			default: 
+			cerr << "Method Id " << methodId << " not recognized!" << endl;
+			return;
+		}
+	}
+}
+
+extern "C" void* createLightBulb_Skeleton(void** params) {
+	// Args: *_mainObj, int _portSend, int _portRecv
+	return new LightBulb_Skeleton((LightBulb*) params[0], *((int*) params[0]), *((int*) params[1]));
+}
+
+extern "C" void destroyLightBulb_Skeleton(void* t) {
+	LightBulb_Skeleton* obj = (LightBulb_Skeleton*) t;
+	delete obj;
+}
+
+extern "C" void initLightBulb_Skeleton(void* t) {
+}
+
+int main() {
+	return 0;
 }
 
-extern "C" void destroy(LightBulb_Skeleton* t) {
-	delete t;
-}*/