X-Git-Url: http://demsky.eecs.uci.edu/git/?a=blobdiff_plain;f=iotjava%2Fiotrmi%2FC%2B%2B%2FIoTRMICommClient.hpp;h=a08bb043a2f2c4e6f42cf826596723ff904c3844;hb=ffea2cb68e5a2e1bac041fe2279620eba8d227f8;hp=77804cdda37afa1b2e2dc198e607262cc9214ac4;hpb=e9a65a3fa878d7451ceb4f5a2cb1bc9ee846e035;p=iot2.git diff --git a/iotjava/iotrmi/C++/IoTRMICommClient.hpp b/iotjava/iotrmi/C++/IoTRMICommClient.hpp index 77804cd..a08bb04 100644 --- a/iotjava/iotrmi/C++/IoTRMICommClient.hpp +++ b/iotjava/iotrmi/C++/IoTRMICommClient.hpp @@ -30,8 +30,6 @@ class IoTRMICommClient final : public IoTRMIComm { void sendReturnObj(void* retObj, string type, char* methodBytes); void sendReturnObj(void* retObj[], string type[], int numRet, char* methodBytes); void remoteCall(int objectId, int methodId, string paramCls[], void* paramObj[], int numParam); - //void waitForPackets(); - //void waitForPackets(IoTRMICommClient* rmiComm); private: IoTSocketClient *rmiClientSend; @@ -49,7 +47,6 @@ IoTRMICommClient::IoTRMICommClient(int _portSend, int _portRecv, const char* _ad rmiClientSend = new IoTSocketClient(_portRecv, _address, _rev, _bResult); thread th1 (&IoTRMICommClient::waitForPackets, this, this); th1.detach(); - } @@ -77,8 +74,6 @@ void IoTRMICommClient::waitForPackets(IoTRMICommClient* rmiComm) { packetBytes = rmiClientRecv->receiveBytes(packetBytes, &packetLen); fflush(NULL); if (packetBytes != NULL) { // If there is method bytes - //IoTRMIUtil::printBytes(packetBytes, packetLen, false); - //packetBytesPtr = &packetBytes; int packetType = getPacketType(packetBytes); if (packetType == IoTRMIUtil::METHOD_TYPE) { rmiComm->methodQueue.enqueue(packetBytes, packetLen);