| /external/conscrypt/benchmark-base/src/main/java/org/conscrypt/ |
| D | ClientEndpoint.java | 67 int totalBytesRead = 0; in readMessage() local
68 while (totalBytesRead < buffer.length) { in readMessage()
69 int remaining = buffer.length - totalBytesRead; in readMessage()
70 int bytesRead = input.read(buffer, totalBytesRead, remaining); in readMessage()
74 totalBytesRead += bytesRead; in readMessage()
76 return totalBytesRead; in readMessage()
|
| D | ServerEndpoint.java | 172 int totalBytesRead = 0; in readMessage() local
173 while (!stopping && totalBytesRead < messageSize) { in readMessage()
175 int remaining = messageSize - totalBytesRead; in readMessage()
176 int bytesRead = inputStream.read(buffer, totalBytesRead, remaining); in readMessage()
180 totalBytesRead += bytesRead; in readMessage()
194 return totalBytesRead; in readMessage()
|
| /external/conscrypt/repackaged/benchmark-base/src/main/java/com/android/org/conscrypt/ |
| D | ClientEndpoint.java | 68 int totalBytesRead = 0; in readMessage() local
69 while (totalBytesRead < buffer.length) { in readMessage()
70 int remaining = buffer.length - totalBytesRead; in readMessage()
71 int bytesRead = input.read(buffer, totalBytesRead, remaining); in readMessage()
75 totalBytesRead += bytesRead; in readMessage()
77 return totalBytesRead; in readMessage()
|
| D | ServerEndpoint.java | 175 int totalBytesRead = 0; in readMessage() local
176 while (!stopping && totalBytesRead < messageSize) { in readMessage()
178 int remaining = messageSize - totalBytesRead; in readMessage()
179 int bytesRead = inputStream.read(buffer, totalBytesRead, remaining); in readMessage()
183 totalBytesRead += bytesRead; in readMessage()
197 return totalBytesRead; in readMessage()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | MessageDeframer.java | 309 int totalBytesRead = 0; in readRequiredBytes() local
327 totalBytesRead += fullStreamDecompressor.getAndResetBytesConsumed(); in readRequiredBytes()
346 totalBytesRead += toRead; in readRequiredBytes()
352 if (totalBytesRead > 0) { in readRequiredBytes()
353 listener.bytesRead(totalBytesRead); in readRequiredBytes()
360 statsTraceCtx.inboundWireSize(totalBytesRead); in readRequiredBytes()
361 inboundBodyWireSize += totalBytesRead; in readRequiredBytes()
|
| /external/okhttp/samples/guide/src/main/java/com/squareup/okhttp/recipes/ |
| D | Progress.java | 96 long totalBytesRead = 0L; in source()
100 totalBytesRead += bytesRead != -1 ? bytesRead : 0; in source()
101 progressListener.update(totalBytesRead, responseBody.contentLength(), bytesRead == -1); in source()
|
| /external/conscrypt/repackaged/openjdk/src/test/java/com/android/org/conscrypt/ |
| D | RenegotiationTest.java | 199 int totalBytesRead = 0; in readReply() local
200 while (totalBytesRead < MESSAGE_LENGTH) { in readReply()
201 int remaining = MESSAGE_LENGTH - totalBytesRead; in readReply()
202 int bytesRead = socket.getInputStream().read(buffer, totalBytesRead, remaining); in readReply()
206 totalBytesRead += bytesRead; in readReply()
210 assertEquals(MESSAGE_LENGTH, totalBytesRead); in readReply()
|
| /external/conscrypt/openjdk/src/test/java/org/conscrypt/ |
| D | RenegotiationTest.java | 194 int totalBytesRead = 0; in readReply() local
195 while (totalBytesRead < MESSAGE_LENGTH) { in readReply()
196 int remaining = MESSAGE_LENGTH - totalBytesRead; in readReply()
197 int bytesRead = socket.getInputStream().read(buffer, totalBytesRead, remaining); in readReply()
201 totalBytesRead += bytesRead; in readReply()
205 assertEquals(MESSAGE_LENGTH, totalBytesRead); in readReply()
|
| /external/rmi4utils/rmidevice/ |
| D | hiddevice.cpp | 227 size_t totalBytesRead; in Read() local
242 for (totalBytesRead = 0; totalBytesRead < len; totalBytesRead += bytesReadPerRequest) { in Read()
244 if ((len - totalBytesRead) < bytesPerRequest) in Read()
295 return totalBytesRead; in Read()
|
| /external/okhttp/repackaged/okio/okio/src/main/java/com/android/okhttp/okio/ |
| D | RealBufferedSink.java | 102 long totalBytesRead = 0; in writeAll() local
104 totalBytesRead += readCount; in writeAll()
107 return totalBytesRead; in writeAll()
|
| D | Buffer.java | 957 long totalBytesRead = 0;
959 totalBytesRead += readCount;
961 return totalBytesRead;
|
| /external/okhttp/okio/okio/src/main/java/okio/ |
| D | RealBufferedSink.java | 101 long totalBytesRead = 0; in writeAll() local
103 totalBytesRead += readCount; in writeAll()
106 return totalBytesRead; in writeAll()
|
| D | Buffer.java | 955 long totalBytesRead = 0;
957 totalBytesRead += readCount;
959 return totalBytesRead;
|
| /external/skia/experimental/Networking/ |
| D | SkSockets.cpp | 88 int totalBytesRead = 0; in readPacket() local
165 totalBytesRead += bytesReadInTransfer; in readPacket()
168 return totalBytesRead; in readPacket()
|
| /external/skqp/experimental/Networking/ |
| D | SkSockets.cpp | 88 int totalBytesRead = 0; in readPacket() local
165 totalBytesRead += bytesReadInTransfer; in readPacket()
168 return totalBytesRead; in readPacket()
|
| /external/protobuf/javamicro/src/main/java/com/google/protobuf/micro/ |
| D | CodedInputStreamMicro.java | 635 final int totalBytesRead = in refillBuffer() local
637 if (totalBytesRead > sizeLimit || totalBytesRead < 0) { in refillBuffer()
|
| /external/protobuf/csharp/src/Google.Protobuf/ |
| D | CodedInputStream.cs | 1052 int totalBytesRead = in RefillBuffer()
1054 if (totalBytesRead > sizeLimit || totalBytesRead < 0) in RefillBuffer()
|