Home | History | Annotate | Download | only in rs

Lines Matching refs:dataLen

57 void * ThreadIO::coreHeader(uint32_t cmdID, size_t dataLen) {
58 //LOGE("coreHeader %i %i", cmdID, dataLen);
61 hdr.bytes = dataLen;
65 mCoreCommandSize = dataLen;
67 mCoreDataPtr = (uint8_t *)mToCore.reserve(dataLen);
74 void ThreadIO::coreData(const void *data, size_t dataLen) {
75 //LOGE("coreData %p %i", data, dataLen);
76 mToCoreSocket.writeAsync(data, dataLen);
106 void ThreadIO::coreSetReturn(const void *data, size_t dataLen) {
107 rsAssert(dataLen <= sizeof(mToCoreRet));
108 memcpy(&mToCoreRet, data, dataLen);
111 void ThreadIO::coreGetReturn(void *data, size_t dataLen) {
112 memcpy(data, &mToCoreRet, dataLen);
208 size_t dataLen, bool waitForSpace) {
210 hdr.bytes = dataLen;
215 if (dataLen) {
216 mToClientSocket.writeAsync(data, dataLen);
221 if (!mToClient.makeSpaceNonBlocking(dataLen + sizeof(hdr))) {
228 uint32_t *p = (uint32_t *)mToClient.reserve(dataLen + sizeof(usrID));
230 if (dataLen > 0) {
231 memcpy(p+1, data, dataLen);
233 mToClient.commit(cmdID, dataLen + sizeof(usrID));