Home
last modified time | relevance | path

Searched refs:messageSize (Results 1 – 25 of 33) sorted by relevance

12

/external/lz4/tests/
Dfuzzer.c1005 U32 messageSize = (FUZ_rand(&randState) & maxMessageSizeMask) + 1; in FUZ_unitTests() local
1019 while (iNext + messageSize < testCompressedSize) { in FUZ_unitTests()
1020 XXH64_update(&xxhOrig, testInput + iNext, messageSize); in FUZ_unitTests()
1023 memcpy (ringBuffer + rNext, testInput + iNext, messageSize); in FUZ_unitTests()
1024 …ess_fast_continue(&streamingState, ringBuffer + rNext, testCompressed, messageSize, testCompressed… in FUZ_unitTests()
1027 …s_safe_continue(&decodeStateSafe, testCompressed, testVerify + dNext, compressedSize, messageSize); in FUZ_unitTests()
1028 …FUZ_CHECKTEST(result!=(int)messageSize, "ringBuffer : LZ4_decompress_safe_continue() test failed"); in FUZ_unitTests()
1030 XXH64_update(&xxhNewSafe, testVerify + dNext, messageSize); in FUZ_unitTests()
1034 … = LZ4_decompress_fast_continue(&decodeStateFast, testCompressed, testVerify + dNext, messageSize); in FUZ_unitTests()
1037 XXH64_update(&xxhNewFast, testVerify + dNext, messageSize); in FUZ_unitTests()
[all …]
/external/conscrypt/repackaged/benchmark-base/src/main/java/com/android/org/conscrypt/
DServerEndpoint.java69 private final int messageSize; field in ServerEndpoint
82 ChannelType channelType, int messageSize, String[] protocols, in ServerEndpoint() argument
87 this.messageSize = messageSize; in ServerEndpoint()
90 buffer = new byte[messageSize]; in ServerEndpoint()
176 while (!stopping && totalBytesRead < messageSize) { in readMessage()
178 int remaining = messageSize - totalBytesRead; in readMessage()
DServerSocketBenchmark.java46 int messageSize(); in messageSize() method
62 byte[] message = newTextMessage(config.messageSize()); in ServerSocketBenchmark()
67 channelType, config.messageSize(), getProtocols(), ciphers(config)); in ServerSocketBenchmark()
106 byte[] buffer = new byte[config.messageSize()]; in ServerSocketBenchmark()
112 assertEquals(config.messageSize(), numBytes); in ServerSocketBenchmark()
DEngineWrapBenchmark.java57 int messageSize(); in messageSize() method
88 int messageSize = config.messageSize(); in EngineWrapBenchmark() local
89 messageBuffer = bufferType.newBuffer(messageSize); in EngineWrapBenchmark()
90 messageBuffer.put(newTextMessage(messageSize)); in EngineWrapBenchmark()
DCipherEncryptBenchmark.java77 int messageSize = messageSize(tx.toFormattedString()); in EncryptStrategy() local
78 outputSize = cipher.getOutputSize(messageSize); in EncryptStrategy()
85 final int messageSize(String transformation) throws Exception { in messageSize() method in CipherEncryptBenchmark.EncryptStrategy
DClientSocketBenchmark.java41 int messageSize(); in messageSize() method
60 message = newTextMessage(config.messageSize()); in ClientSocketBenchmark()
64 ChannelType.CHANNEL, config.messageSize(), config.protocol().getProtocols(), in ClientSocketBenchmark()
/external/conscrypt/benchmark-base/src/main/java/org/conscrypt/
DServerEndpoint.java66 private final int messageSize; field in ServerEndpoint
79 ChannelType channelType, int messageSize, String[] protocols, in ServerEndpoint() argument
84 this.messageSize = messageSize; in ServerEndpoint()
87 buffer = new byte[messageSize]; in ServerEndpoint()
173 while (!stopping && totalBytesRead < messageSize) { in readMessage()
175 int remaining = messageSize - totalBytesRead; in readMessage()
DEngineWrapBenchmark.java55 int messageSize(); in messageSize() method
86 int messageSize = config.messageSize(); in EngineWrapBenchmark() local
87 messageBuffer = bufferType.newBuffer(messageSize); in EngineWrapBenchmark()
88 messageBuffer.put(newTextMessage(messageSize)); in EngineWrapBenchmark()
DServerSocketBenchmark.java44 int messageSize(); in messageSize() method
60 byte[] message = newTextMessage(config.messageSize()); in ServerSocketBenchmark()
65 channelType, config.messageSize(), getProtocols(), ciphers(config)); in ServerSocketBenchmark()
104 byte[] buffer = new byte[config.messageSize()]; in ServerSocketBenchmark()
110 assertEquals(config.messageSize(), numBytes); in ServerSocketBenchmark()
DCipherEncryptBenchmark.java72 int messageSize = messageSize(tx.toFormattedString()); in EncryptStrategy() local
73 outputSize = cipher.getOutputSize(messageSize); in EncryptStrategy()
80 final int messageSize(String transformation) throws Exception { in messageSize() method in CipherEncryptBenchmark.EncryptStrategy
DClientSocketBenchmark.java39 int messageSize(); in messageSize() method
58 message = newTextMessage(config.messageSize()); in ClientSocketBenchmark()
62 ChannelType.CHANNEL, config.messageSize(), config.protocol().getProtocols(), in ClientSocketBenchmark()
DEndpointFactory.java12 ServerEndpoint newServer(ChannelType channelType, int messageSize, in newServer() argument
/external/conscrypt/repackaged/benchmark-android/src/main/java/com/android/org/conscrypt/
DCaliperClientSocketBenchmark.java39 public int messageSize; field in CaliperClientSocketBenchmark
80 public int messageSize() { in messageSize() method in CaliperClientSocketBenchmark.CaliperConfig
81 return messageSize; in messageSize()
DAndroidEndpointFactory.java34 public ServerEndpoint newServer(ChannelType channelType, int messageSize, in newServer() argument
37 channelType, messageSize, protocols, ciphers); in newServer()
/external/conscrypt/benchmark-android/src/main/java/org/conscrypt/
DCaliperClientSocketBenchmark.java37 public int messageSize; field in CaliperClientSocketBenchmark
78 public int messageSize() { in messageSize() method in CaliperClientSocketBenchmark.CaliperConfig
79 return messageSize; in messageSize()
DAndroidEndpointFactory.java32 public ServerEndpoint newServer(ChannelType channelType, int messageSize, in newServer() argument
35 channelType, messageSize, protocols, ciphers); in newServer()
/external/conscrypt/benchmark-jmh/src/jmh/java/org/conscrypt/
DJmhServerSocketBenchmark.java65 public int messageSize; field in JmhServerSocketBenchmark
101 public int messageSize() { in messageSize() method in JmhServerSocketBenchmark.JmhConfig
102 return messageSize; in messageSize()
DJmhClientSocketBenchmark.java68 public int messageSize; field in JmhClientSocketBenchmark
110 public int messageSize() { in messageSize() method in JmhClientSocketBenchmark.JmhConfig
111 return messageSize; in messageSize()
DOpenJdkEndpointFactory.java34 public ServerEndpoint newServer(ChannelType channelType, int messageSize, in newServer() argument
37 channelType, messageSize, protocols, ciphers); in newServer()
/external/deqp/executor/
DxeTcpIpLink.cpp40 …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/opencensus-java/api/src/main/java/io/opencensus/trace/
DNetworkEvent.java166 public Builder setMessageSize(long messageSize) { in setMessageSize() argument
167 return setUncompressedMessageSize(messageSize); in setMessageSize()
/external/deqp/execserver/tools/
DxsClient.cpp109 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()
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DApplicationThreadDeframer.java57 public void setMaxInboundMessageSize(int messageSize) { in setMaxInboundMessageSize() argument
58 deframer.setMaxInboundMessageSize(messageSize); in setMaxInboundMessageSize()
DDeframer.java24 void setMaxInboundMessageSize(int messageSize); in setMaxInboundMessageSize() argument
/external/deqp/execserver/
DxsProtocol.hpp77 … 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);

12