Searched refs:payloadHead (Results 1 – 5 of 5) sorted by relevance
20 let payloadHead = new PayloadHead(); variable22 expect(payloadHead).not.toBeUndefined();26 expect(payloadHead.flag).toBeUndefined();30 payloadHead.flag = true;31 expect(payloadHead.flag).toBeTruthy();35 expect(payloadHead.reserve).toBeUndefined();39 payloadHead.reserve = true;40 expect(payloadHead.reserve).toBeTruthy();44 expect(payloadHead.protocolVer).toBeUndefined();48 payloadHead.protocolVer = true;[all …]
95 let payloadHead: PayloadHead = new PayloadHead(102 let dataView = payloadHead.getDataView();
155 TransferPayload payloadHead; in SendIOPayload() local163 payloadHead.compressType = context->transferConfig.compressType; in SendIOPayload()164 payloadHead.uncompressSize = dataSize; in SendIOPayload()165 payloadHead.index = index; in SendIOPayload()167 switch (payloadHead.compressType) { in SendIOPayload()186 payloadHead.compressSize = compressSize; in SendIOPayload()187 head = SerialStruct::SerializeToString(payloadHead); in SendIOPayload()197 if (dataSize > 0 && payloadHead.compressType == COMPRESS_LZ4) { in SendIOPayload()
816 PayloadHead payloadHead = {}; // need convert to big-endian in Send() local817 payloadHead.flag[0] = PACKET_FLAG.at(0); in Send()818 payloadHead.flag[1] = PACKET_FLAG.at(1); in Send()819 payloadHead.protocolVer = VER_PROTOCOL; in Send()820 payloadHead.headSize = htons(s.size()); in Send()821 payloadHead.dataSize = htonl(dataSize); in Send()830 …if (memcpy_s(finayBuf, sizeof(PayloadHead), reinterpret_cast<uint8_t *>(&payloadHead), sizeof(Payl… in Send()890 struct PayloadHead *payloadHead = reinterpret_cast<struct PayloadHead *>(bufPtr); in OnRead() local892 uint64_t payloadHeadSize = static_cast<uint64_t>(ntohl(payloadHead->dataSize)) + in OnRead()893 static_cast<uint64_t>(ntohs(payloadHead->headSize)); in OnRead()[all …]