Searched refs:payloadHead (Results 1 – 4 of 4) sorted by relevance
19 let payloadHead = new PayloadHead(); variable21 expect(payloadHead).not.toBeUndefined();25 expect(payloadHead.flag).toBeUndefined();29 payloadHead.flag = true;30 expect(payloadHead.flag).toBeTruthy();34 expect(payloadHead.reserve).toBeUndefined();38 payloadHead.reserve = true;39 expect(payloadHead.reserve).toBeTruthy();43 expect(payloadHead.protocolVer).toBeUndefined();47 payloadHead.protocolVer = true;[all …]
95 let payloadHead: PayloadHead = new PayloadHead(102 let dataView = payloadHead.getDataView();
154 TransferPayload payloadHead; in SendIOPayload() local162 payloadHead.compressType = context->transferConfig.compressType; in SendIOPayload()163 payloadHead.uncompressSize = dataSize; in SendIOPayload()164 payloadHead.index = index; in SendIOPayload()166 switch (payloadHead.compressType) { in SendIOPayload()185 payloadHead.compressSize = compressSize; in SendIOPayload()186 head = SerialStruct::SerializeToString(payloadHead); in SendIOPayload()196 if (dataSize > 0 && payloadHead.compressType == COMPRESS_LZ4) { in SendIOPayload()
833 PayloadHead payloadHead = {}; // need convert to big-endian in Send() local834 payloadHead.flag[0] = PACKET_FLAG.at(0); in Send()835 payloadHead.flag[1] = PACKET_FLAG.at(1); in Send()836 payloadHead.protocolVer = VER_PROTOCOL; in Send()837 payloadHead.headSize = htons(s.size()); in Send()838 payloadHead.dataSize = htonl(dataSize); in Send()847 …if (memcpy_s(finayBuf, sizeof(PayloadHead), reinterpret_cast<uint8_t *>(&payloadHead), sizeof(Payl… in Send()907 struct PayloadHead *payloadHead = reinterpret_cast<struct PayloadHead *>(bufPtr); in OnRead() local909 uint64_t payloadHeadSize = static_cast<uint64_t>(ntohl(payloadHead->dataSize)) + in OnRead()910 static_cast<uint64_t>(ntohs(payloadHead->headSize)); in OnRead()[all …]