| /third_party/lz4/tests/ |
| H A D | fuzzer.c | 1240 U32 messageSize = (FUZ_rand(&randState) & maxMessageSizeMask) + 1; in FUZ_unitTests() local
1253 while (iNext + messageSize < testCompressedSize) { in FUZ_unitTests()
1255 XXH64_update(&xxhOrig, testInput + iNext, messageSize); in FUZ_unitTests()
1258 memcpy (ringBuffer + rNext, testInput + iNext, messageSize); in FUZ_unitTests()
1259 compressedSize = LZ4_compress_fast_continue(&streamingState, ringBuffer + rNext, testCompressed, (int)messageSize, testCompressedSize-ringBufferSize, 1); in FUZ_unitTests()
1262 { int const r = LZ4_decompress_safe_continue(&decodeStateSafe, testCompressed, testVerify + dNext, compressedSize, (int)messageSize); in FUZ_unitTests()
1263 FUZ_CHECKTEST(r!=(int)messageSize, "ringBuffer : LZ4_decompress_safe_continue() test failed"); } in FUZ_unitTests()
1265 XXH64_update(&xxhNewSafe, testVerify + dNext, messageSize); in FUZ_unitTests()
1269 { int const r = LZ4_decompress_fast_continue(&decodeStateFast, testCompressed, testVerify + dNext, (int)messageSize); in FUZ_unitTests()
1272 XXH64_update(&xxhNewFast, testVerify + dNext, messageSize); in FUZ_unitTests()
1487 U32 messageSize = (FUZ_rand(&randState) & maxMessageSizeMask) + 1; FUZ_unitTests() local
1551 int messageSize; FUZ_unitTests() local
[all...] |
| /third_party/protobuf/csharp/src/Google.Protobuf.Benchmarks/ |
| H A D | WriteMessagesBenchmark.cs | 155 int messageSize = message.CalculateSize(); in SubTest()
156 this.outputBuffer = new byte[messageSize]; in SubTest()
157 this.multipleMessagesOutputBuffer = new byte[maxMessageCount * (messageSize + CodedOutputStream.ComputeLengthSize(messageSize))]; in SubTest()
|
| /third_party/protobuf/java/core/src/test/java/com/google/protobuf/ |
| H A D | DiscardUnknownFieldsTest.java | 77 final int messageSize = payload.size(); in assertReuseCodedInputStreamPreserve()
78 byte[] copied = new byte[messageSize * 2]; in assertReuseCodedInputStreamPreserve()
80 payload.copyTo(copied, messageSize); in assertReuseCodedInputStreamPreserve()
84 int oldLimit = input.pushLimit(messageSize); in assertReuseCodedInputStreamPreserve()
|
| /third_party/vk-gl-cts/executor/ |
| H A D | xeTcpIpLink.cpp | 40 static void writeMessageHeader (de::BlockBuffer<deUint8>& dst, xs::MessageType type, int messageSize) in writeMessageHeader() argument
43 xs::Message::writeHeader(type, messageSize, &hdr[0], xs::MESSAGE_HEADER_SIZE); in writeMessageHeader()
294 size_t messageSize = 0; in run() local
299 xs::Message::parseHeader(&m_curMsgBuf[0], xs::MESSAGE_HEADER_SIZE, messageType, messageSize); in run()
300 hasPayload = m_curMsgPos >= messageSize; in run()
306 handleMessage(messageType, m_curMsgPos > xs::MESSAGE_HEADER_SIZE ? &m_curMsgBuf[xs::MESSAGE_HEADER_SIZE] : DE_NULL, messageSize-xs::MESSAGE_HEADER_SIZE); in run()
312 size_t curSize = hasHeader ? messageSize : (size_t)xs::MESSAGE_HEADER_SIZE; in run()
|
| /third_party/vk-gl-cts/execserver/tools/ |
| H A D | xsClient.cpp | 109 size_t messageSize; in readMessage() local
110 Message::parseHeader(&header[0], (int)header.size(), type, messageSize); in readMessage()
122 readBytes(socket, messageBuf, messageSize-MESSAGE_HEADER_SIZE); in readMessage()
|
| H A D | xsTest.cpp | 115 size_t messageSize; in readMessage() local
116 Message::parseHeader(&header[0], (int)header.size(), type, messageSize); in readMessage()
128 readBytes(socket, messageBuf, messageSize-MESSAGE_HEADER_SIZE); in readMessage()
|
| /third_party/protobuf/csharp/src/Google.Protobuf.Test/ |
| H A D | MessageParsingHelpers.cs | 111 int messageSize = message.CalculateSize(); in AssertWritingMessage()
120 var singleSpan = new Span<byte>(new byte[messageSize]); in AssertWritingMessage()
|
| /third_party/vk-gl-cts/execserver/ |
| H A D | xsProtocol.hpp | 77 static void parseHeader (const deUint8* data, size_t dataSize, MessageType& type, size_t& messageSize);
78 static void writeHeader (MessageType type, size_t messageSize, deUint8* dst, size_t bufSize);
|
| H A D | xsProtocol.cpp | 149 void Message::writeHeader (MessageType type, size_t messageSize, deUint8* dst, size_t bufSize) in writeHeader() argument
152 int netSize = hostToNetwork((int)messageSize); in writeHeader()
|
| /third_party/backends/backend/ |
| H A D | dell1600n_net.c | 1194 unsigned short messageSize, nameSize, valueSize; in ProcessFindResponse() local
1212 messageSize = (((unsigned short) (pData[6])) << 8) | pData[7]; in ProcessFindResponse()
1216 pEnd = pItem + messageSize; in ProcessFindResponse()
1348 unsigned short messageSize, nameSize, valueSize; in ProcessUdpResponse() local
1371 messageSize = (((unsigned short) (pData[6])) << 8) | pData[7]; in ProcessUdpResponse()
1375 pEnd = pItem + messageSize; in ProcessUdpResponse()
1480 unsigned short messageSize = 0, nameSize, valueSize, dataChunkSize; in ProcessTcpResponse() local
1507 messageSize = (((unsigned short) (pData[6])) << 8) | pData[7]; in ProcessTcpResponse()
1511 pEnd = pItem + messageSize; in ProcessTcpResponse()
1745 PopFromComBuf (pTcpBuf, messageSize in ProcessTcpResponse()
[all...] |