Lines Matching refs:dataSize
316 const int dataSize) in PushAsyncMessage() argument
325 if (dataSize > 0) { in PushAsyncMessage()
326 param->dataSize = dataSize; in PushAsyncMessage()
327 param->data = new uint8_t[param->dataSize](); in PushAsyncMessage()
332 if (memcpy_s((uint8_t *)param->data, param->dataSize, data, dataSize)) { in PushAsyncMessage()
799 const uint8_t *data, const int dataSize) in Send() argument
810 …protectBuf.checkSum = (ENABLE_IO_CHECKSUM && dataSize > 0) ? Base::CalcCheckSum(data, dataSize) : … in Send()
821 payloadHead.dataSize = htonl(dataSize); in Send()
822 int finalBufSize = sizeof(PayloadHead) + s.size() + dataSize; in Send()
831 WRITE_LOG(LOG_WARN, "send copyhead err for dataSize:%d", dataSize); in Send()
836 WRITE_LOG(LOG_WARN, "send copyProtbuf err for dataSize:%d", dataSize); in Send()
839 …if (dataSize > 0 && memcpy_s(finayBuf + sizeof(PayloadHead) + s.size(), dataSize, data, dataSize))… in Send()
840 WRITE_LOG(LOG_WARN, "send copyDatabuf err for dataSize:%d", dataSize); in Send()
847 WRITE_LOG(LOG_WARN, "send copywholedata err for dataSize:%d", dataSize); in Send()
862 int dataSize = ntohl(payloadHeadBe->dataSize); in DecryptPayload() local
870 …CKSUM && protectBuf.checkSum != 0 && (protectBuf.checkSum != Base::CalcCheckSum(data, dataSize))) { in DecryptPayload()
874 if (!FetchCommand(hSession, protectBuf.channelId, protectBuf.commandFlag, data, dataSize)) { in DecryptPayload()
892 uint64_t payloadHeadSize = static_cast<uint64_t>(ntohl(payloadHead->dataSize)) + in OnRead()
1081 int dataSize) in BuildCtrlString() argument
1085 if (dataSize > BUF_SIZE_MICRO) { in BuildCtrlString()
1091 ctrl.dataSize = dataSize; in BuildCtrlString()
1092 …if (dataSize > 0 && data != nullptr && memcpy_s(ctrl.data, sizeof(ctrl.data), data, dataSize) != E… in BuildCtrlString()