/external/okio/okio/src/jvmMain/kotlin/okio/ |
D | InflaterSource.kt | 73 val toRead = minOf(byteCount, Segment.SIZE - tail.limit).toInt() in readOrInflate() constant
|
D | Throttler.kt | 139 val toRead = take(byteCount) in source() constant
|
/external/okio/okio/src/commonMain/kotlin/okio/internal/ |
D | RealBufferedSource.kt | 43 val toRead = minOf(byteCount, buffer.size) in commonRead() constant 138 val toRead = okio.minOf(byteCount, buffer.size).toInt() in commonRead() constant
|
/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 281 long toRead = Math.min(byteCount, frameLength - frameBytesRead); in read() local
|
D | WebSocketWriter.java | 218 int toRead = (int) Math.min(byteCount, maskBuffer.length); in writeMaskedSynchronized() local
|
/external/zstd/examples/ |
D | streaming_decompression.c | 35 size_t const toRead = buffInSize; in decompressFile_orDie() local
|
D | streaming_compression.c | 47 size_t const toRead = buffInSize; in compressFile_orDie() local
|
D | multiple_streaming_compression.c | 69 size_t const toRead = ress.buffInSize; in compressFile_orDie() local
|
D | streaming_compression_thread_pool.c | 64 size_t const toRead = buffInSize; in compressFile_orDie() local
|
/external/bouncycastle/repackaged/bcprov/src/main/java/com/android/org/bouncycastle/asn1/ |
D | DefiniteLengthInputStream.java | 79 int toRead = Math.min(len, _remaining); in read() local
|
/external/bouncycastle/bcprov/src/main/java/org/bouncycastle/asn1/ |
D | DefiniteLengthInputStream.java | 78 int toRead = Math.min(len, _remaining); in read() local
|
/external/bouncycastle/repackaged_platform/bcprov/src/main/java/com/android/internal/org/bouncycastle/asn1/ |
D | DefiniteLengthInputStream.java | 79 int toRead = Math.min(len, _remaining); in read() local
|
/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 130 int toRead = (int) Math.min(byteCount, buffer.size); in read() local
|
/external/okhttp/okio/okio/src/main/java/okio/ |
D | RealBufferedSource.java | 54 long toRead = Math.min(byteCount, buffer.size); in read() local 129 int toRead = (int) Math.min(byteCount, buffer.size); in read() local
|
/external/zstd/contrib/seekable_format/ |
D | zstdseek_decompress.c | 287 U32 const toRead = MIN(remaining, SEEKABLE_BUFF_SIZE); in ZSTD_seekable_loadSeekTable() local 322 U32 const toRead = MIN(remaining, SEEKABLE_BUFF_SIZE - offset); in ZSTD_seekable_loadSeekTable() local 401 size_t toRead; in ZSTD_seekable_decompress() local
|
/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
|
/external/zstd/contrib/seekable_format/examples/ |
D | seekable_compression.c | 77 size_t read, toRead = buffInSize; in compressFile_orDie() local
|
/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
|
D | MessageDeframer.java | 345 int toRead = Math.min(missingBytes, unprocessed.readableBytes()); in readRequiredBytes() local
|
/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
|
/external/mockwebserver/src/main/java/com/google/mockwebserver/ |
D | MockWebServer.java | 544 int toRead = (int) Math.min(Math.min(buffer.length, limit), bytesPerPeriod - b); in throttledTransfer() local
|
/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
|
/external/zstd/programs/ |
D | fileio.c | 2107 size_t const toRead = toDecode - ress->srcBufferLoaded; in FIO_decompressZstdFrame() local 2154 size_t const toRead = toDecode - ress->srcBufferLoaded; /* > 0 */ in FIO_decompressZstdFrame() local 2412 size_t const toRead = 4; in FIO_decompressFrames() local
|
/external/conscrypt/repackaged/common/src/test/java/com/android/org/conscrypt/javax/net/ssl/ |
D | SSLSocketVersionCompatibilityTest.java | 1371 final Socket toRead = readUnderlying ? underlying : clientWrapping; in test_SSLSocket_interrupt_case() local
|
/external/conscrypt/common/src/test/java/org/conscrypt/javax/net/ssl/ |
D | SSLSocketVersionCompatibilityTest.java | 1369 final Socket toRead = readUnderlying ? underlying : clientWrapping; in test_SSLSocket_interrupt_case() local
|