| /external/okhttp/okhttp-ws/src/main/java/com/squareup/okhttp/internal/ws/ |
| D | WebSocketReader.java | 169 int toRead = (int) Math.min(frameLength - frameBytesRead, maskBuffer.length); in readControlFrame() local
170 int read = source.read(maskBuffer, 0, toRead); in readControlFrame()
281 long toRead = Math.min(byteCount, frameLength - frameBytesRead); in read() local
285 toRead = Math.min(toRead, maskBuffer.length); in read()
286 read = source.read(maskBuffer, 0, (int) toRead); in read()
291 read = source.read(sink, toRead); in read()
|
| D | WebSocketWriter.java | 218 int toRead = (int) Math.min(byteCount, maskBuffer.length); in writeMaskedSynchronized() local
219 int read = source.read(maskBuffer, 0, toRead); in writeMaskedSynchronized()
|
| /external/okhttp/benchmarks/src/main/java/com/squareup/okhttp/benchmarks/ |
| D | NettyHttpClient.java | 179 for (int toRead; (toRead = byteBuf.readableBytes()) > 0; ) { in receive()
180 byteBuf.readBytes(buffer, 0, Math.min(buffer.length, toRead)); in receive()
181 total += toRead; in receive()
|
| /external/bouncycastle/bcprov/src/main/java/org/bouncycastle/asn1/ |
| D | DefiniteLengthInputStream.java | 76 int toRead = Math.min(len, _remaining); in read() local
77 int numRead = _in.read(buf, off, toRead); in read()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | GzipInflatingBuffer.java | 102 int toRead = Math.min(bytesToSkip - total, buf.length); in skipBytes() local
103 gzippedData.readBytes(buf, 0, toRead); in skipBytes()
104 crc.update(buf, 0, toRead); in skipBytes()
105 total += toRead; in skipBytes()
|
| D | MessageDeframer.java | 345 int toRead = Math.min(missingBytes, unprocessed.readableBytes()); in readRequiredBytes() local
346 totalBytesRead += toRead; in readRequiredBytes()
347 nextFrame.addBuffer(unprocessed.readBytes(toRead)); in readRequiredBytes()
|
| /external/bouncycastle/repackaged/bcprov/src/main/java/com/android/org/bouncycastle/asn1/ |
| D | DefiniteLengthInputStream.java | 77 int toRead = Math.min(len, _remaining); in read() local
78 int numRead = _in.read(buf, off, toRead); in read()
|
| /external/conscrypt/common/src/main/java/org/conscrypt/ |
| D | OpenSSLBIOSource.java | 88 int toRead = Math.min(source.remaining(), byteCount); in read() local
90 source.get(buffer, byteOffset, toRead); in read()
|
| /external/conscrypt/repackaged/common/src/main/java/com/android/org/conscrypt/ |
| D | OpenSSLBIOSource.java | 89 int toRead = Math.min(source.remaining(), byteCount); in read() local
91 source.get(buffer, byteOffset, toRead); in read()
|
| /external/okhttp/mockwebserver/src/main/java/com/squareup/okhttp/mockwebserver/ |
| D | MockWebServer.java | 769 long toRead = Math.min(byteCount, bytesPerPeriod - b);
772 toRead = Math.min(toRead, byteCount - halfByteCount);
775 long read = source.read(buffer, toRead);
832 long toRead = Math.min(remainingByteCount, byteCount);
833 if (toRead > 0) {
834 source.read(buffer, toRead);
836 long toSkip = byteCount - toRead;
840 remainingByteCount -= toRead;
|
| /external/okhttp/okio/okio/src/main/java/okio/ |
| D | RealBufferedSource.java | 54 long toRead = Math.min(byteCount, buffer.size); in read() local
55 return buffer.read(sink, toRead); in read()
129 int toRead = (int) Math.min(byteCount, buffer.size); in read() local
130 return buffer.read(sink, offset, toRead); in read()
|
| /external/okhttp/repackaged/okio/okio/src/main/java/com/android/okhttp/okio/ |
| D | RealBufferedSource.java | 55 long toRead = Math.min(byteCount, buffer.size); in read() local
56 return buffer.read(sink, toRead); in read()
130 int toRead = (int) Math.min(byteCount, buffer.size); in read() local
131 return buffer.read(sink, offset, toRead); in read()
|
| /external/apache-commons-compress/src/main/java/org/apache/commons/compress/archivers/sevenz/ |
| D | CLI.java | 89 final int toRead = (int) Math.min(total - off, buf.length); in takeAction() local
90 final int bytesRead = archive.read(buf, 0, toRead); in takeAction()
|
| /external/apache-commons-compress/src/main/java/org/apache/commons/compress/archivers/zip/ |
| D | ZipArchiveInputStream.java | 537 int toRead = Math.min(buf.remaining(), length); in readStored() local
538 if ((csize - current.bytesRead) < toRead) { in readStored()
540 toRead = (int) (csize - current.bytesRead); in readStored()
542 buf.get(buffer, offset, toRead); in readStored()
543 current.bytesRead += toRead; in readStored()
544 return toRead; in readStored()
|
| /external/apache-commons-compress/src/main/java/org/apache/commons/compress/archivers/ar/ |
| D | ArArchiveInputStream.java | 271 final int toRead = (int) Math.min(len, entryEnd - offset); in read() local
272 final int ret = this.input.read(b, off, toRead); in read()
|
| /external/mockwebserver/src/main/java/com/google/mockwebserver/ |
| D | MockWebServer.java | 536 int toRead = (int) Math.min(Math.min(buffer.length, limit), bytesPerPeriod - b); in throttledTransfer() local
537 int read = in.read(buffer, 0, toRead); in throttledTransfer()
|
| /external/conscrypt/repackaged/openjdk-integ-tests/src/test/java/com/android/org/conscrypt/javax/net/ssl/ |
| D | SSLSocketVersionCompatibilityTest.java | 1604 final Socket toRead = readUnderlying ? underlying : clientWrapping; in test_SSLSocket_interrupt_case() local
1619 toRead.setSoTimeout(readingTimeoutMillis); in test_SSLSocket_interrupt_case()
1620 int read = toRead.getInputStream().read(); in test_SSLSocket_interrupt_case()
|
| /external/conscrypt/openjdk-integ-tests/src/test/java/org/conscrypt/javax/net/ssl/ |
| D | SSLSocketVersionCompatibilityTest.java | 1587 final Socket toRead = readUnderlying ? underlying : clientWrapping; in test_SSLSocket_interrupt_case() local
1602 toRead.setSoTimeout(readingTimeoutMillis); in test_SSLSocket_interrupt_case()
1603 int read = toRead.getInputStream().read(); in test_SSLSocket_interrupt_case()
|