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;
rmiClientSend = new IoTSocketClient(_portRecv, _address, _rev, _bResult);
thread th1 (&IoTRMICommClient::waitForPackets, this, this);
th1.detach();
-
}
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);