| /cts/suite/audio_quality/lib/src/audio/ |
| AudioRecordingLocal.cpp | 73 int toRead = mSizes;
75 toRead = buffer->amountToHandle();
77 LOGD("recording will read %d", toRead);
79 while (toRead > 0) {
80 int readSize = (toRead > mBufferSize) ? mBufferSize : toRead;
86 toRead -= readSize;
|
| /external/libvncserver/libvncclient/ |
| ultra.c | 38 int toRead=0;
45 toRead = rfbClientSwap32IfLE(hdr.nBytes);
46 if (toRead==0) return TRUE;
72 if ( client->ultra_buffer_size < toRead ) {
76 client->ultra_buffer_size = toRead;
84 if (!ReadFromRFBServer(client, client->ultra_buffer, toRead))
90 (lzo_byte *)client->ultra_buffer, toRead,
119 int toRead=0;
128 toRead = rfbClientSwap32IfLE(hdr.nBytes);
130 if (toRead==0) return TRUE
[all...] |
| zlib.c | 41 int toRead;
100 toRead = RFB_BUFFER_SIZE;
103 toRead = remaining;
107 if (!ReadFromRFBServer(client, client->buffer,toRead))
111 client->decompStream.avail_in = toRead;
138 remaining -= toRead;
|
| zrle.c | 89 int toRead;
149 toRead = RFB_BUFFER_SIZE;
152 toRead = remaining;
156 if (!ReadFromRFBServer(client, client->buffer,toRead))
160 client->decompStream.avail_in = toRead;
187 remaining -= toRead;
|
| /frameworks/base/libs/androidfw/ |
| StreamingZipInflater.cpp | 139 size_t toRead = min_of(count, size_t(mOutTotalSize - mOutCurPosition));
140 while (toRead > 0) {
142 size_t deliverable = min_of(toRead, mOutLastDecoded - mOutDeliverable);
149 toRead -= deliverable;
153 if (toRead > 0) {
211 size_t toRead = min_of(mInBufSize, mInTotalSize - mInNextChunkOffset);
212 if (toRead > 0) {
213 ssize_t didRead = TEMP_FAILURE_RETRY(::read(mFd, mInBuf, toRead));
215 ALOGV("Reading input chunk, size %08zx didread %08zx", toRead, didRead);
|
| /frameworks/base/cmds/statsd/src/ |
| stats_log_util.h | 80 size_t toRead = iter.currentToRead();
81 pbBytes.append(reinterpret_cast<const char*>(iter.readBuffer()), toRead);
82 iter.rp()->move(toRead);
|
| /packages/apps/Car/libs/car-apps-common/src/com/android/car/apps/common/ |
| CachedInputStream.java | 157 int toRead = count > leftInBuffer ? leftInBuffer : count;
158 int reads = in.read(buf, indexInBuf, toRead);
194 int toRead = read > leftInBuffer ? leftInBuffer : read;
195 System.arraycopy(buf, indexInBuf, buffer, offset, toRead);
196 offset += toRead;
197 read -= toRead;
198 totalRead += toRead;
199 mPos += toRead;
236 int toRead = (int) (byteCount > leftInBuffer ? leftInBuffer : byteCount);
237 int reads = in.read(buf, indexInBuf, toRead);
[all...] |
| /cts/suite/audio_quality/lib/src/ |
| ClientSocket.cpp | 97 int toRead = len;
98 while (toRead > 0) {
117 read = recv(mSocket, (void*)data, toRead, 0);
119 toRead -= read;
|
| /tools/external/fat32lib/src/main/java/de/waldheinz/fs/util/ |
| FileDisk.java | 113 int toRead = dest.remaining();
114 if ((devOffset + toRead) > getSize()) throw new IOException(
117 while (toRead > 0) {
120 toRead -= read;
|
| /external/bouncycastle/bcprov/src/main/java/org/bouncycastle/asn1/ |
| DefiniteLengthInputStream.java | 73 int toRead = Math.min(len, _remaining);
74 int numRead = _in.read(buf, off, toRead);
|
| /external/conscrypt/common/src/main/java/org/conscrypt/ |
| OpenSSLBIOSource.java | 88 int toRead = Math.min(source.remaining(), byteCount);
90 source.get(buffer, byteOffset, toRead);
|
| /frameworks/base/cmds/statsd/src/metrics/ |
| EventMetricProducer.cpp | 94 size_t toRead = it.currentToRead();
95 std::memcpy(&((*buffer)[pos]), it.readBuffer(), toRead);
96 pos += toRead;
97 it.rp()->move(toRead);
|
| /frameworks/base/cmds/statsd/tests/ |
| FieldValue_test.cpp | 257 size_t toRead = iter.currentToRead();
258 std::memcpy(&(outData[pos]), iter.readBuffer(), toRead);
259 pos += toRead;
260 iter.rp()->move(toRead);
347 size_t toRead = iter.currentToRead();
348 std::memcpy(&(outData[pos]), iter.readBuffer(), toRead);
349 pos += toRead;
350 iter.rp()->move(toRead);
409 size_t toRead = iter.currentToRead();
410 std::memcpy(&(outData[pos]), iter.readBuffer(), toRead);
[all...] |
| /external/okhttp/okhttp-ws/src/main/java/com/squareup/okhttp/internal/ws/ |
| WebSocketReader.java | 169 int toRead = (int) Math.min(frameLength - frameBytesRead, maskBuffer.length);
170 int read = source.read(maskBuffer, 0, toRead);
281 long toRead = Math.min(byteCount, frameLength - frameBytesRead);
285 toRead = Math.min(toRead, maskBuffer.length);
286 read = source.read(maskBuffer, 0, (int) toRead);
291 read = source.read(sink, toRead);
|
| /frameworks/data-binding/compiler/src/test/java/android/databinding/tool/expr/ |
| ExprModelTest.java | 206 List<Expr> toRead = getShouldRead();
207 List<Expr> readNow = getReadFirst(toRead);
212 readNow = filterOut(getReadFirst(toRead, justRead), justRead);
216 readNow = filterOut(getReadFirst(toRead, justRead), justRead);
219 readNow = filterOut(getReadFirst(toRead, justRead), justRead);
223 toRead = getShouldRead();
224 assertEquals(2, toRead.size());
226 readNow = filterOut(getReadFirst(toRead, justRead), justRead);
231 readNow = filterOut(getReadFirst(toRead, justRead), justRead);
236 readNow = filterOut(getReadFirst(toRead, justRead), justRead)
[all...] |
| /libcore/luni/src/main/java/libcore/io/ |
| Streams.java | 158 int toRead = (int) Math.min(byteCount - skipped, buffer.length);
159 int read = in.read(buffer, 0, toRead);
164 if (read < toRead) {
|
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/io/ |
| BufferedInputStreamTest.java | 410 int toRead = len;
411 if (toRead > available()) {
412 toRead = available();
414 System.arraycopy(contents, pos, buf, off, toRead);
415 pos += toRead;
416 return toRead;
|
| BufferedReaderTest.java | 312 int toRead = len;
313 if (toRead > (size - pos))
314 toRead = size - pos;
315 System.arraycopy(contents, pos, buf, off, toRead);
316 pos += toRead;
317 return toRead;
|
| /frameworks/base/services/backup/java/com/android/server/backup/utils/ |
| FullBackupUtils.java | 60 int toRead = (chunkTotal > buffer.length) ? buffer.length : chunkTotal;
61 int nRead = in.read(buffer, 0, toRead);
|
| /external/okhttp/benchmarks/src/main/java/com/squareup/okhttp/benchmarks/ |
| NettyHttpClient.java | 179 for (int toRead; (toRead = byteBuf.readableBytes()) > 0; ) {
180 byteBuf.readBytes(buffer, 0, Math.min(buffer.length, toRead));
181 total += toRead;
|
| /prebuilts/go/darwin-x86/src/compress/lzw/ |
| reader.go | 87 toRead []byte // bytes to return from Read
124 if len(d.toRead) > 0 {
125 n := copy(b, d.toRead)
126 d.toRead = d.toRead[n:]
136 // decode decompresses bytes from r and leaves them in d.toRead.
219 d.toRead = d.output[:d.o]
|
| /prebuilts/go/linux-x86/src/compress/lzw/ |
| reader.go | 87 toRead []byte // bytes to return from Read
124 if len(d.toRead) > 0 {
125 n := copy(b, d.toRead)
126 d.toRead = d.toRead[n:]
136 // decode decompresses bytes from r and leaves them in d.toRead.
219 d.toRead = d.output[:d.o]
|
| /prebuilts/go/darwin-x86/src/compress/flate/ |
| inflate.go | 295 toRead []byte
336 if len(f.toRead) > 0 {
337 n := copy(b, f.toRead)
338 f.toRead = f.toRead[n:]
339 if len(f.toRead) == 0 {
348 if f.err != nil && len(f.toRead) == 0 {
349 f.toRead = f.dict.readFlush() // Flush what's left in case of error
505 f.toRead = f.dict.readFlush()
612 f.toRead = f.dict.readFlush(
[all...] |
| /prebuilts/go/linux-x86/src/compress/flate/ |
| inflate.go | 295 toRead []byte
336 if len(f.toRead) > 0 {
337 n := copy(b, f.toRead)
338 f.toRead = f.toRead[n:]
339 if len(f.toRead) == 0 {
348 if f.err != nil && len(f.toRead) == 0 {
349 f.toRead = f.dict.readFlush() // Flush what's left in case of error
505 f.toRead = f.dict.readFlush()
612 f.toRead = f.dict.readFlush(
[all...] |
| /external/okhttp/okio/okio/src/main/java/okio/ |
| RealBufferedSource.java | 54 long toRead = Math.min(byteCount, buffer.size);
55 return buffer.read(sink, toRead);
129 int toRead = (int) Math.min(byteCount, buffer.size);
130 return buffer.read(sink, offset, toRead);
|
