| /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/exoplayer/tree/library/core/src/test/java/com/google/android/exoplayer2/upstream/ |
| D | DataSourceInputStreamTest.java | 60 int totalBytesRead = 0;
61 while (totalBytesRead < TEST_DATA.length) {
62 int bytesRead = inputStream.read(readBytes, totalBytesRead,
63 TEST_DATA.length - totalBytesRead);
65 totalBytesRead += bytesRead;
66 assertThat(inputStream.bytesRead()).isEqualTo(totalBytesRead);
72 assertThat(totalBytesRead).isEqualTo(TEST_DATA.length);
|
| /external/guava/android/guava/src/com/google/common/io/ |
| D | ReaderInputStream.java | 133 int totalBytesRead = 0; in read() local
141 totalBytesRead += drain(b, off + totalBytesRead, len - totalBytesRead); in read()
142 if (totalBytesRead == len || doneFlushing) { in read()
143 return (totalBytesRead > 0) ? totalBytesRead : -1; in read()
|
| /external/guava/guava/src/com/google/common/io/ |
| D | ReaderInputStream.java | 133 int totalBytesRead = 0; in read() local
141 totalBytesRead += drain(b, off + totalBytesRead, len - totalBytesRead); in read()
142 if (totalBytesRead == len || doneFlushing) { in read()
143 return (totalBytesRead > 0) ? totalBytesRead : -1; in read()
|
| /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/exoplayer/tree/library/core/src/main/java/com/google/android/exoplayer2/upstream/ |
| D | DataSourceInputStream.java | 35 private long totalBytesRead; field in DataSourceInputStream
51 return totalBytesRead; in bytesRead()
86 totalBytesRead += bytesRead; in read()
|
| /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 | 197 int totalBytesRead = 0; in readReply() local
198 while (totalBytesRead < MESSAGE_LENGTH) { in readReply()
199 int remaining = MESSAGE_LENGTH - totalBytesRead; in readReply()
200 int bytesRead = socket.getInputStream().read(buffer, totalBytesRead, remaining); in readReply()
204 totalBytesRead += bytesRead; in readReply()
208 assertEquals(MESSAGE_LENGTH, totalBytesRead); in readReply()
|
| /external/conscrypt/openjdk/src/test/java/org/conscrypt/ |
| D | RenegotiationTest.java | 192 int totalBytesRead = 0; in readReply() local
193 while (totalBytesRead < MESSAGE_LENGTH) { in readReply()
194 int remaining = MESSAGE_LENGTH - totalBytesRead; in readReply()
195 int bytesRead = socket.getInputStream().read(buffer, totalBytesRead, remaining); in readReply()
199 totalBytesRead += bytesRead; in readReply()
203 assertEquals(MESSAGE_LENGTH, totalBytesRead); in readReply()
|
| /external/zstd/contrib/pzstd/ |
| D | Pzstd.cpp | 362 std::uint64_t *totalBytesRead) { in readData() argument
367 *totalBytesRead += bytesRead; in readData()
498 std::uint64_t totalBytesRead = 0; in asyncDecompressFrames() local
519 totalBytesRead += bytesRead; in asyncDecompressFrames()
546 status = readData(*in, chunkSize, chunkSize, fd, &totalBytesRead); in asyncDecompressFrames()
552 status = readData(*in, chunkSize, frameSize, fd, &totalBytesRead); in asyncDecompressFrames()
555 return totalBytesRead; in asyncDecompressFrames()
|
| /external/okio/okio/src/commonMain/kotlin/okio/internal/ |
| D | RealBufferedSink.kt | 91 var totalBytesRead = 0L in commonWriteAll() variable
95 totalBytesRead += readCount in commonWriteAll()
98 return totalBytesRead in commonWriteAll()
|
| D | Buffer.kt | 1076 var totalBytesRead = 0L in commonWriteAll() variable
1080 totalBytesRead += readCount in commonWriteAll()
1082 return totalBytesRead in commonWriteAll()
|
| /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/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/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/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 | 1082 int totalBytesRead = in RefillBuffer()
1084 if (totalBytesRead < 0 || totalBytesRead > sizeLimit) in RefillBuffer()
|
| /external/protobuf/java/core/src/main/java/com/google/protobuf/ |
| D | CodedInputStream.java | 3117 private int totalBytesRead; field in CodedInputStream.IterableDirectByteBufferDecoder
3145 startOffset = totalBytesRead = 0; in IterableDirectByteBufferDecoder()
3167 totalBytesRead += (int) (currentByteBufferPos - currentByteBufferStartPos); in tryGetNextByteBuffer()
3725 startOffset = (int) (totalBytesRead + currentByteBufferPos - currentByteBufferStartPos); in resetSizeCounter()
3774 return totalBytesRead + currentByteBufferPos - currentByteBufferStartPos == totalBufferSize; in isAtEnd()
3780 (totalBytesRead - startOffset + currentByteBufferPos - currentByteBufferStartPos); in getTotalBytesRead()
3856 - totalBytesRead in skipRawBytes()
3895 (totalBufferSize - totalBytesRead - currentByteBufferPos + currentByteBufferStartPos); in remaining()
|
| /external/javaparser/javaparser-symbol-solver-testing/src/test/test_sourcecode/javasymbolsolver_0_6_0/lib/ |
| D | guava-21.0.jar | META-INF/MANIFEST.MF
META-INF/
META-INF/maven/
META- ... |