| /external/lz4/tests/ |
| D | fuzzer.c | 704 U32 messageSize = (FUZ_rand(&randState) & maxMessageSizeMask) + 1; in FUZ_unitTests() local
715 while (iNext + messageSize < testCompressedSize) { in FUZ_unitTests()
716 XXH64_update(&xxhOrig, testInput + iNext, messageSize); in FUZ_unitTests()
719 memcpy (ringBuffer + rNext, testInput + iNext, messageSize); in FUZ_unitTests()
720 …ess_fast_continue(&streamingState, ringBuffer + rNext, testCompressed, messageSize, testCompressed… in FUZ_unitTests()
723 …Z4_decompress_safe_continue(&decodeState, testCompressed, testVerify + dNext, result, messageSize); in FUZ_unitTests()
724 … FUZ_CHECKTEST(result!=(int)messageSize, "ringBuffer : LZ4_decompress_safe() test failed"); in FUZ_unitTests()
726 XXH64_update(&xxhNew, testVerify + dNext, messageSize); in FUZ_unitTests()
731 iNext += messageSize; in FUZ_unitTests()
732 rNext += messageSize; in FUZ_unitTests()
[all …]
|
| /external/conscrypt/benchmark-base/src/main/java/org/conscrypt/ |
| D | ServerEndpoint.java | 60 private final int messageSize; field in ServerEndpoint
72 ChannelType channelType, int messageSize, String[] protocols, in ServerEndpoint() argument
77 this.messageSize = messageSize; in ServerEndpoint()
80 buffer = new byte[messageSize]; in ServerEndpoint()
161 while (totalBytesRead < messageSize) { in readMessage()
162 int remaining = messageSize - totalBytesRead; in readMessage()
|
| D | EngineWrapBenchmark.java | 54 int messageSize(); in messageSize() method
85 int messageSize = config.messageSize(); in EngineWrapBenchmark() local
86 messageBuffer = bufferType.newBuffer(messageSize); in EngineWrapBenchmark()
87 messageBuffer.put(newTextMessage(messageSize)); in EngineWrapBenchmark()
174 public int messageSize() { in main()
|
| D | ServerSocketBenchmark.java | 42 int messageSize(); in messageSize() method
58 byte[] message = newTextMessage(config.messageSize()); in ServerSocketBenchmark()
63 channelType, config.messageSize(), getProtocols(), ciphers(config)); in ServerSocketBenchmark()
96 byte[] buffer = new byte[config.messageSize()]; in ServerSocketBenchmark()
99 assertEquals(config.messageSize(), numBytes); in ServerSocketBenchmark()
149 public int messageSize() { in main()
|
| D | ClientSocketBenchmark.java | 39 int messageSize(); in messageSize() method
57 message = newTextMessage(config.messageSize()); in ClientSocketBenchmark()
61 ChannelType.CHANNEL, config.messageSize(), getProtocols(), ciphers(config)); in ClientSocketBenchmark()
135 public int messageSize() { in main()
|
| D | SocketType.java | 30 ServerEndpoint newServer(ChannelType channelType, int messageSize, in newServer() argument
33 channelType, messageSize, protocols, ciphers); in newServer()
|
| /external/conscrypt/benchmark-jmh/src/jmh/java/org/conscrypt/ |
| D | JmhClientSocketBenchmark.java | 63 public int messageSize; field in JmhClientSocketBenchmark
96 public int messageSize() { in messageSize() method in JmhClientSocketBenchmark.JmhConfig
97 return messageSize; in messageSize()
|
| D | JmhServerSocketBenchmark.java | 66 public int messageSize; field in JmhServerSocketBenchmark
96 public int messageSize() { in messageSize() method in JmhServerSocketBenchmark.JmhConfig
97 return messageSize; in messageSize()
|
| D | JmhEngineWrapBenchmark.java | 103 public int messageSize() { in messageSize() method in JmhEngineWrapBenchmark.JmhConfig
|
| /external/deqp/executor/ |
| D | xeTcpIpLink.cpp | 40 …atic 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 …MESSAGE_HEADER_SIZE ? &m_curMsgBuf[xs::MESSAGE_HEADER_SIZE] : DE_NULL, messageSize-xs::MESSAGE_HEA… in run()
312 size_t curSize = hasHeader ? messageSize : (size_t)xs::MESSAGE_HEADER_SIZE; in run()
|
| /external/tpm2/ |
| D | CpriRSA.c | 342 UINT32 messageSize, // IN: the message size in OaepEncode() argument
371 if(messageSize > paddedSize - 2 * hLen - 2) in OaepEncode()
378 padLen = paddedSize - messageSize - (2 * hLen) - 2; in OaepEncode()
382 memcpy(&pp[hLen+padLen], message, messageSize); in OaepEncode()
384 dbSize = hLen+padLen+messageSize; in OaepEncode()
530 UINT32 messageSize, // IN: the message size in RSAES_PKSC1v1_5Encode() argument
534 UINT32 ps = paddedSize - messageSize - 3; in RSAES_PKSC1v1_5Encode()
535 if(messageSize > paddedSize - 11) in RSAES_PKSC1v1_5Encode()
538 memcpy(&padded[paddedSize - messageSize], message, messageSize); in RSAES_PKSC1v1_5Encode()
570 UINT32 *messageSize, // IN/OUT: recovered message size in RSAES_Decode() argument
[all …]
|
| /external/libmojo/mojo/public/java/system/src/org/chromium/mojo/system/ |
| D | MessagePipeHandle.java | 159 public void setMessageSize(int messageSize) { in setMessageSize() argument
160 mMessageSize = messageSize; in setMessageSize()
|
| /external/deqp/execserver/tools/ |
| 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()
|
| 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()
|
| /external/deqp/execserver/ |
| D | xsProtocol.hpp | 77 … 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);
|
| 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()
|
| /external/libmojo/mojo/android/system/src/org/chromium/mojo/system/impl/ |
| D | CoreImpl.java | 570 int mojoResult, int messageSize, int handlesCount) { in newReadMessageResult() argument
572 result.setMessageSize(messageSize); in newReadMessageResult()
|
| /external/protobuf/objectivec/Tests/ |
| D | GPBMessageTests.m | 373 size_t messageSize = class_getInstanceSize([GPBMessage class]);
374 XCTAssertEqual((messageSize % sizeof(void *)), (size_t)0,
381 XCTAssertEqual(testMessageSize, messageSize);
|