| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | MessageFramer.java | 134 int messageLength = -2; in writePayload() local
136 messageLength = getKnownLength(message); in writePayload()
137 if (messageLength != 0 && compressed) { in writePayload()
138 written = writeCompressed(message, messageLength); in writePayload()
140 written = writeUncompressed(message, messageLength); in writePayload()
155 if (messageLength != -1 && written != messageLength) { in writePayload()
156 String err = String.format("Message length inaccurate %s != %s", written, messageLength); in writePayload()
164 private int writeUncompressed(InputStream message, int messageLength) throws IOException { in writeUncompressed() argument
165 if (messageLength != -1) { in writeUncompressed()
166 currentMessageWireSize = messageLength; in writeUncompressed()
[all …]
|
| /external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/ |
| D | TrafficControlProxy.java | 202 outStream.write(next.message, 0, next.messageLength); in writeOut()
203 incrementBytes(-next.messageLength); in writeOut()
240 int messageLength; field in TrafficControlProxy.Message
242 Message(long sendTime, byte[] message, int messageLength) { in Message() argument
245 this.messageLength = messageLength; in Message()
|
| /external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/ |
| D | OkHttpClientTransportTest.java | 601 int messageLength = Utils.DEFAULT_WINDOW_SIZE / 4; in windowUpdate() local
602 byte[] fakeMessage = new byte[messageLength]; in windowUpdate()
654 int messageLength = Utils.DEFAULT_WINDOW_SIZE / 2 + 1; in windowUpdateWithInboundFlowControl() local
655 byte[] fakeMessage = new byte[messageLength]; in windowUpdateWithInboundFlowControl()
688 int messageLength = Utils.DEFAULT_WINDOW_SIZE / 2 + 1; in outboundFlowControl() local
689 InputStream input = new ByteArrayInputStream(new byte[messageLength]); in outboundFlowControl()
693 eq(false), eq(3), any(Buffer.class), eq(messageLength + HEADER_LENGTH)); in outboundFlowControl()
697 input = new ByteArrayInputStream(new byte[messageLength]); in outboundFlowControl()
701 Utils.DEFAULT_WINDOW_SIZE - messageLength - HEADER_LENGTH; in outboundFlowControl()
710 eq(messageLength + HEADER_LENGTH - partiallySentSize)); in outboundFlowControl()
[all …]
|
| /external/wpa_supplicant_8/src/common/ |
| D | tnc.h | 43 TNC_UInt32 messageLength,
62 TNC_UInt32 messageLength,
|
| /external/wycheproof/java/com/google/security/wycheproof/testcases/ |
| D | EciesTest.java | 53 int expectedCiphertextLength(String algorithm, int coordinateSize, int messageLength) in expectedCiphertextLength() argument
59 return 1 + (2 * coordinateSize) + (messageLength - messageLength % 16 + 16) + 20; in expectedCiphertextLength()
|
| /external/protobuf/js/binary/ |
| D | writer.js | 151 var messageLength = this.totalLength_ + this.encoder_.length() - oldLength;
152 goog.asserts.assert(messageLength >= 0);
154 while (messageLength > 127) {
155 bookmark.push((messageLength & 0x7f) | 0x80);
156 messageLength = messageLength >>> 7;
160 bookmark.push(messageLength);
|
| /external/webrtc/webrtc/modules/audio_device/win/ |
| D | audio_device_core_win.cc | 289 DWORD messageLength = ::FormatMessageW(dwFlags, in CoreAudioIsSupported() local
297 assert(messageLength <= MAXERRORLENGTH); in CoreAudioIsSupported()
300 for (; messageLength && ::isspace(errorText[messageLength - 1]); in CoreAudioIsSupported()
301 --messageLength) in CoreAudioIsSupported()
303 errorText[messageLength - 1] = '\0'; in CoreAudioIsSupported()
5048 DWORD messageLength = ::FormatMessageW(dwFlags, in _TraceCOMError() local
5056 assert(messageLength <= MAXERRORLENGTH); in _TraceCOMError()
5059 for (; messageLength && ::isspace(errorText[messageLength - 1]); in _TraceCOMError()
5060 --messageLength) in _TraceCOMError()
5062 errorText[messageLength - 1] = '\0'; in _TraceCOMError()
|
| /external/wpa_supplicant_8/src/eap_server/ |
| D | tncs.c | 60 TNC_UInt32 messageLength,
178 TNC_UInt32 messageLength, in TNC_TNCS_SendMessage() argument
189 message, messageLength); in TNC_TNCS_SendMessage()
198 b64 = base64_encode(message, messageLength, &b64len); in TNC_TNCS_SendMessage()
|
| /external/wpa_supplicant_8/src/eap_peer/ |
| D | tncc.c | 85 TNC_UInt32 messageLength,
143 TNC_UInt32 messageLength, in TNC_TNCC_SendMessage() argument
154 message, messageLength); in TNC_TNCC_SendMessage()
159 b64 = base64_encode(message, messageLength, &b64len); in TNC_TNCC_SendMessage()
|