Home
last modified time | relevance | path

Searched defs:toRead (Results 1 – 25 of 27) sorted by relevance

12

/external/okio/okio/src/jvmMain/kotlin/okio/
DInflaterSource.kt73 val toRead = minOf(byteCount, Segment.SIZE - tail.limit).toInt() in readOrInflate() constant
DThrottler.kt139 val toRead = take(byteCount) in source() constant
/external/okio/okio/src/commonMain/kotlin/okio/internal/
DRealBufferedSource.kt43 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/
DWebSocketReader.java169 int toRead = (int) Math.min(frameLength - frameBytesRead, maskBuffer.length); in readControlFrame() local
281 long toRead = Math.min(byteCount, frameLength - frameBytesRead); in read() local
DWebSocketWriter.java218 int toRead = (int) Math.min(byteCount, maskBuffer.length); in writeMaskedSynchronized() local
/external/zstd/examples/
Dstreaming_decompression.c35 size_t const toRead = buffInSize; in decompressFile_orDie() local
Dstreaming_compression.c47 size_t const toRead = buffInSize; in compressFile_orDie() local
Dmultiple_streaming_compression.c69 size_t const toRead = ress.buffInSize; in compressFile_orDie() local
Dstreaming_compression_thread_pool.c64 size_t const toRead = buffInSize; in compressFile_orDie() local
/external/bouncycastle/repackaged/bcprov/src/main/java/com/android/org/bouncycastle/asn1/
DDefiniteLengthInputStream.java79 int toRead = Math.min(len, _remaining); in read() local
/external/bouncycastle/bcprov/src/main/java/org/bouncycastle/asn1/
DDefiniteLengthInputStream.java78 int toRead = Math.min(len, _remaining); in read() local
/external/bouncycastle/repackaged_platform/bcprov/src/main/java/com/android/internal/org/bouncycastle/asn1/
DDefiniteLengthInputStream.java79 int toRead = Math.min(len, _remaining); in read() local
/external/okhttp/repackaged/okio/okio/src/main/java/com/android/okhttp/okio/
DRealBufferedSource.java55 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/
DRealBufferedSource.java54 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/
Dzstdseek_decompress.c287 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/
DCLI.java89 final int toRead = (int) Math.min(total - off, buf.length); in takeAction() local
/external/zstd/contrib/seekable_format/examples/
Dseekable_compression.c77 size_t read, toRead = buffInSize; in compressFile_orDie() local
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DGzipInflatingBuffer.java102 int toRead = Math.min(bytesToSkip - total, buf.length); in skipBytes() local
DMessageDeframer.java345 int toRead = Math.min(missingBytes, unprocessed.readableBytes()); in readRequiredBytes() local
/external/apache-commons-compress/src/main/java/org/apache/commons/compress/archivers/ar/
DArArchiveInputStream.java271 final int toRead = (int) Math.min(len, entryEnd - offset); in read() local
/external/mockwebserver/src/main/java/com/google/mockwebserver/
DMockWebServer.java544 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/
DZipArchiveInputStream.java537 int toRead = Math.min(buf.remaining(), length); in readStored() local
/external/zstd/programs/
Dfileio.c2107 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/
DSSLSocketVersionCompatibilityTest.java1371 final Socket toRead = readUnderlying ? underlying : clientWrapping; in test_SSLSocket_interrupt_case() local
/external/conscrypt/common/src/test/java/org/conscrypt/javax/net/ssl/
DSSLSocketVersionCompatibilityTest.java1369 final Socket toRead = readUnderlying ? underlying : clientWrapping; in test_SSLSocket_interrupt_case() local

12