| /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/angle/src/tests/gl_tests/ |
| D | DebugTest.cpp | 259 GLint messageLength = 0; in TEST_P() local
260 glGetIntegerv(GL_DEBUG_NEXT_LOGGED_MESSAGE_LENGTH, &messageLength); in TEST_P()
261 EXPECT_EQ(static_cast<GLint>(message.length()) + 1, messageLength); in TEST_P()
268 std::vector<char> messageBuf(messageLength); in TEST_P()
277 EXPECT_EQ(lengthBuf, messageLength); in TEST_P()
316 GLint messageLength = 0; in TEST_P() local
317 glGetIntegerv(GL_DEBUG_NEXT_LOGGED_MESSAGE_LENGTH, &messageLength); in TEST_P()
318 EXPECT_EQ(static_cast<GLint>(expectedMessage.length()) + 1, messageLength); in TEST_P()
325 std::vector<char> messageBuf(messageLength); in TEST_P()
334 EXPECT_EQ(lengthBuf, messageLength); in TEST_P()
|
| /external/okio/okio/src/hashFunctions/kotlin/okio/internal/ |
| D | Sha1.kt | 21 private var messageLength = 0L variable in okio.internal.Sha1
37 messageLength += byteCount in update()
139 val messageLengthBits = messageLength * 8 in digest()
193 messageLength = 0L in reset()
|
| D | Sha256.kt | 21 private var messageLength = 0L variable
40 messageLength += byteCount in update()
156 val messageLengthBits = messageLength * 8 in digest()
225 messageLength = 0L in reset()
|
| D | Sha512.kt | 21 private var messageLength = 0L variable in okio.internal.Sha512
40 messageLength += byteCount in update()
151 val messageLengthBits = messageLength * 8 in digest()
252 messageLength = 0L in reset()
|
| D | Md5.kt | 21 private var messageLength = 0L variable in okio.internal.Md5
36 messageLength += byteCount in update()
141 val messageLengthBits = messageLength * 8 in digest()
|
| /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/rust/crates/quiche/deps/boringssl/src/util/fipstools/acvp/modulewrapper/ |
| D | modulewrapper.cc | 129 "messageLength": [{ in GetConfig()
136 "messageLength": [{ in GetConfig()
143 "messageLength": [{ in GetConfig()
150 "messageLength": [{ in GetConfig()
157 "messageLength": [{ in GetConfig()
|
| /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/modules/audio_device/win/ |
| D | audio_device_core_win.cc | 280 DWORD messageLength = ::FormatMessageW(dwFlags, 0, hr, dwLangID, errorText, in CoreAudioIsSupported() local
283 assert(messageLength <= MAXERRORLENGTH); in CoreAudioIsSupported()
286 for (; messageLength && ::isspace(errorText[messageLength - 1]); in CoreAudioIsSupported()
287 --messageLength) { in CoreAudioIsSupported()
288 errorText[messageLength - 1] = '\0'; in CoreAudioIsSupported()
4130 DWORD messageLength = ::FormatMessageW(dwFlags, 0, hr, dwLangID, errorText, in _TraceCOMError() local
4133 assert(messageLength <= MAXERRORLENGTH); in _TraceCOMError()
4136 for (; messageLength && ::isspace(errorText[messageLength - 1]); in _TraceCOMError()
4137 --messageLength) { in _TraceCOMError()
4138 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()
|
| /external/angle/src/tests/test_utils/ |
| D | ANGLETest.cpp | 1226 SIZE_T messageLength = 0; in checkD3D11SDKLayersMessages() local
1227 hr = infoQueue->GetMessage(i, nullptr, &messageLength); in checkD3D11SDKLayersMessages()
1232 reinterpret_cast<D3D11_MESSAGE *>(malloc(messageLength)); in checkD3D11SDKLayersMessages()
1233 infoQueue->GetMessage(i, pMessage, &messageLength); in checkD3D11SDKLayersMessages()
|
| /external/boringssl/src/util/fipstools/acvp/modulewrapper/ |
| D | modulewrapper.cc | 230 "messageLength": [{ in GetConfig()
237 "messageLength": [{ in GetConfig()
244 "messageLength": [{ in GetConfig()
251 "messageLength": [{ in GetConfig()
258 "messageLength": [{ in GetConfig()
265 "messageLength": [{ in GetConfig()
|
| /external/angle/src/libANGLE/ |
| D | validationES2.cpp | 2234 size_t messageLength = (length < 0) ? strlen(buf) : length; in ValidateDebugMessageInsertKHR() local
2235 if (messageLength > context->getExtensions().maxDebugMessageLength) in ValidateDebugMessageInsertKHR()
2300 size_t messageLength = (length < 0) ? strlen(message) : length; in ValidatePushDebugGroupKHR() local
2301 if (messageLength > context->getExtensions().maxDebugMessageLength) in ValidatePushDebugGroupKHR()
|
| /external/guice/extensions/struts2/lib/ |
| D | core-3.1.1.jar | META-INF/
org/
org/eclipse/
org/eclipse/jdt/
org/eclipse ... |
| /external/icu/tools/srcgen/currysrc/libs/ |
| D | org.eclipse.jdt.core_3.14.0.v20180528-0519.jar | META-INF/MANIFEST.MF
META-INF/ECLIPSE_.SF
META-INF/ECLIPSE_ ... |