| /external/okio/okio/src/jvmMain/kotlin/okio/ |
| D | Throttler.kt | 50 private var maxByteCount: Long = 256 * 1024 // 256 KiB. variable in okio.Throttler
62 maxByteCount: Long = this.maxByteCount, in bytesPerSecond()
67 require(maxByteCount >= waitByteCount) in bytesPerSecond()
71 this.maxByteCount = maxByteCount in bytesPerSecond()
102 val immediateBytes = maxByteCount - idleInNanos.nanosToBytes() in byteCountOrWaitNanos()
112 allocatedUntil = now + maxByteCount.bytesToNanos() in byteCountOrWaitNanos()
118 val minWaitNanos = idleInNanos + (minByteCount - maxByteCount).bytesToNanos() in byteCountOrWaitNanos()
122 allocatedUntil = now + maxByteCount.bytesToNanos() in byteCountOrWaitNanos()
|
| /external/leakcanary2/shark-hprof/src/main/java/shark/ |
| D | ByteArraySourceProvider.kt | 23 val maxByteCount = byteCount.coerceAtMost(byteArray.size - position) in openRandomAccessSource() constant
24 sink.write(byteArray, position.toInt(), maxByteCount.toInt()) in openRandomAccessSource()
25 return maxByteCount in openRandomAccessSource()
|
| /external/okio/okio/src/nativeMain/kotlin/okio/ |
| D | DataProcessor.kt | 158 maxByteCount: Long = Long.MAX_VALUE, in prepareSource()
161 if (maxByteCount == 0L || head == null) { in prepareSource()
167 val toProcess = minOf(maxByteCount, head.limit - head.pos).toInt() in prepareSource()
206 maxByteCount: Long = Long.MAX_VALUE, in prepareTarget()
209 val toProcess = minOf(maxByteCount, tail.data.size - tail.limit).toInt() in prepareTarget()
|
| /external/okio/okio/src/jvmTest/kotlin/okio/ |
| D | ThrottlerTakeTest.kt | 28 throttler.bytesPerSecond(bytesPerSecond = 20, waitByteCount = 5, maxByteCount = 10) in takeByByteCount()
56 throttler.bytesPerSecond(bytesPerSecond = 20, waitByteCount = 5, maxByteCount = 10) in takeFullyTimeElapsed()
104 throttler.bytesPerSecond(3, maxByteCount = 4, waitByteCount = 4) in infiniteWait()
|
| D | ThrottlerTest.kt | 133 throttlerLocal.bytesPerSecond(4 * size, maxByteCount = 8192) in parallelIndividualThrottle()
149 throttlerLocal.bytesPerSecond(4 * size, maxByteCount = 8192) in parallelGroupAndIndividualThrottle()
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/framed/ |
| D | FramedStream.java | 322 private final long maxByteCount; field in FramedStream.FramedDataSource
333 private FramedDataSource(long maxByteCount) { in FramedDataSource() argument
334 this.maxByteCount = maxByteCount; in FramedDataSource()
392 flowControlError = byteCount + readBuffer.size() > maxByteCount; in receive()
|
| /external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/internal/framed/ |
| D | FramedStream.java | 324 private final long maxByteCount; field in FramedStream.FramedDataSource
335 private FramedDataSource(long maxByteCount) { in FramedDataSource() argument
336 this.maxByteCount = maxByteCount; in FramedDataSource()
394 flowControlError = byteCount + readBuffer.size() > maxByteCount; in receive()
|
| /external/cronet/tot/third_party/rust/chromium_crates_io/vendor/windows-sys-0.52.0/src/Windows/Win32/Networking/WindowsWebServices/ |
| D | mod.rs | 1843 pub maxByteCount: u32, field
1854 pub maxByteCount: u32, field
2363 pub maxByteCount: u32, field
4383 pub maxByteCount: u32, field
4875 pub maxByteCount: u32, field
|
| /external/cronet/stable/third_party/rust/chromium_crates_io/vendor/windows-sys-0.52.0/src/Windows/Win32/Networking/WindowsWebServices/ |
| D | mod.rs | 1843 pub maxByteCount: u32, field
1854 pub maxByteCount: u32, field
2363 pub maxByteCount: u32, field
4383 pub maxByteCount: u32, field
4875 pub maxByteCount: u32, field
|