| /external/perfetto/ui/src/controller/ |
| D | trace_stream.ts | 24 bytesRead: number; property
39 private bytesRead = 0;
55 this.bytesRead += res.byteLength;
58 eof: this.bytesRead >= this.traceFile.size,
59 bytesRead: this.bytesRead,
65 const sliceEnd = Math.min(this.bytesRead + SLICE_SIZE, this.traceFile.size);
66 const slice = this.traceFile.slice(this.bytesRead, sliceEnd);
77 private bytesRead = 0; property in TraceBufferStream
84 assertTrue(this.bytesRead <= this.traceBuf.byteLength);
85 const len = Math.min(SLICE_SIZE, this.traceBuf.byteLength - this.bytesRead);
[all …]
|
| /external/oboe/src/common/ |
| D | FixedBlockReader.cpp | 49 int32_t bytesRead; in read() local
54 bytesRead = readFromStorage(buffer, bytesLeft); in read()
55 buffer += bytesRead; in read()
56 bytesLeft -= bytesRead; in read()
59 bytesRead = mFixedBlockProcessor.onProcessFixedBlock(buffer, mSize); in read()
60 if (bytesRead < 0) return bytesRead; in read()
61 buffer += bytesRead; in read()
62 bytesLeft -= bytesRead; in read()
65 bytesRead = mFixedBlockProcessor.onProcessFixedBlock(mStorage.get(), mSize); in read()
66 if (bytesRead < 0) return bytesRead; in read()
[all …]
|
| /external/exoplayer/tree/library/extractor/src/main/java/com/google/android/exoplayer2/extractor/ts/ |
| D | SectionReader.java | 38 private int bytesRead; field in SectionReader
74 bytesRead = 0; in consume()
78 if (bytesRead < SECTION_HEADER_LENGTH) { in consume()
81 if (bytesRead == 0) { in consume()
90 int headerBytesToRead = Math.min(data.bytesLeft(), SECTION_HEADER_LENGTH - bytesRead); in consume()
91 data.readBytes(sectionData.data, bytesRead, headerBytesToRead); in consume()
92 bytesRead += headerBytesToRead; in consume()
93 if (bytesRead == SECTION_HEADER_LENGTH) { in consume()
111 int bodyBytesToRead = Math.min(data.bytesLeft(), totalSectionLength - bytesRead); in consume()
112 data.readBytes(sectionData.data, bytesRead, bodyBytesToRead); in consume()
[all …]
|
| D | DtsReader.java | 48 private int bytesRead; field in DtsReader
75 bytesRead = 0; in seek()
110 int bytesToRead = Math.min(data.bytesLeft(), sampleSize - bytesRead); in consume()
112 bytesRead += bytesToRead; in consume()
113 if (bytesRead == sampleSize) { in consume()
140 int bytesToRead = Math.min(source.bytesLeft(), targetLength - bytesRead); in continueRead()
141 source.readBytes(target, bytesRead, bytesToRead); in continueRead()
142 bytesRead += bytesToRead; in continueRead()
143 return bytesRead == targetLength; in continueRead()
162 bytesRead = 4; in skipToNextSync()
|
| D | Ac4Reader.java | 57 private int bytesRead; field in Ac4Reader
85 bytesRead = 0; in Ac4Reader()
94 bytesRead = 0; in seek()
121 bytesRead = 2; in consume()
133 int bytesToRead = Math.min(data.bytesLeft(), sampleSize - bytesRead); in consume()
135 bytesRead += bytesToRead; in consume()
136 if (bytesRead == sampleSize) { in consume()
163 int bytesToRead = Math.min(source.bytesLeft(), targetLength - bytesRead); in continueRead()
164 source.readBytes(target, bytesRead, bytesToRead); in continueRead()
165 bytesRead += bytesToRead; in continueRead()
[all …]
|
| D | Ac3Reader.java | 61 private int bytesRead; field in Ac3Reader
96 bytesRead = 0; in seek()
122 bytesRead = 2; in consume()
134 int bytesToRead = Math.min(data.bytesLeft(), sampleSize - bytesRead); in consume()
136 bytesRead += bytesToRead; in consume()
137 if (bytesRead == sampleSize) { in consume()
164 int bytesToRead = Math.min(source.bytesLeft(), targetLength - bytesRead); in continueRead()
165 source.readBytes(target, bytesRead, bytesToRead); in continueRead()
166 bytesRead += bytesToRead; in continueRead()
167 return bytesRead == targetLength; in continueRead()
|
| D | AdtsReader.java | 77 private int bytesRead; field in AdtsReader
216 int bytesToRead = Math.min(source.bytesLeft(), targetLength - bytesRead); in continueRead()
217 source.readBytes(target, bytesRead, bytesToRead); in continueRead()
218 bytesRead += bytesToRead; in continueRead()
219 return bytesRead == targetLength; in continueRead()
227 bytesRead = 0; in setFindingSampleState()
237 bytesRead = ID3_IDENTIFIER.length; in setReadingId3HeaderState()
253 bytesRead = priorReadBytes; in setReadingSampleState()
264 bytesRead = 0; in setReadingAdtsHeaderState()
270 bytesRead = 0; in setCheckingAdtsHeaderState()
[all …]
|
| /external/exoplayer/tree/library/extractor/src/main/java/com/google/android/exoplayer2/extractor/ |
| D | DefaultExtractorInput.java | 58 int bytesRead = readFromPeekBuffer(target, offset, length); in read() local
59 if (bytesRead == 0) { in read()
60 bytesRead = in read()
64 commitBytesRead(bytesRead); in read()
65 return bytesRead; in read()
71 int bytesRead = readFromPeekBuffer(target, offset, length); in readFully() local
72 while (bytesRead < length && bytesRead != C.RESULT_END_OF_INPUT) { in readFully()
73 bytesRead = readFromUpstream(target, offset, length, bytesRead, allowEndOfInput); in readFully()
75 commitBytesRead(bytesRead); in readFully()
76 return bytesRead != C.RESULT_END_OF_INPUT; in readFully()
[all …]
|
| /external/exoplayer/tree/extensions/cronet/src/test/java/com/google/android/exoplayer2/ext/cronet/ |
| D | CronetDataSourceTest.java | 425 int bytesRead = dataSourceUnderTest.read(returnedBuffer, 0, 8); in requestReadTwice() local
427 assertThat(bytesRead).isEqualTo(8); in requestReadTwice()
430 bytesRead = dataSourceUnderTest.read(returnedBuffer, 0, 8); in requestReadTwice()
432 assertThat(bytesRead).isEqualTo(8); in requestReadTwice()
458 int bytesRead = dataSourceUnderTest.read(returnedBuffer, 0, 10); in secondRequestNoContentLength() local
459 assertThat(bytesRead).isEqualTo(10); in secondRequestNoContentLength()
460 bytesRead = dataSourceUnderTest.read(returnedBuffer, 0, 10); in secondRequestNoContentLength()
461 assertThat(bytesRead).isEqualTo(6); in secondRequestNoContentLength()
462 bytesRead = dataSourceUnderTest.read(returnedBuffer, 0, 10); in secondRequestNoContentLength()
463 assertThat(bytesRead).isEqualTo(C.RESULT_END_OF_INPUT); in secondRequestNoContentLength()
[all …]
|
| /external/exoplayer/tree/library/core/src/main/java/com/google/android/exoplayer2/source/ |
| D | IcyDataSource.java | 87 int bytesRead = upstream.read(buffer, offset, Math.min(bytesUntilMetadata, readLength)); in read() local
88 if (bytesRead != C.RESULT_END_OF_INPUT) { in read()
89 bytesUntilMetadata -= bytesRead; in read()
91 return bytesRead; in read()
118 int bytesRead = upstream.read(metadataLengthByteHolder, 0, 1); in readMetadata() local
119 if (bytesRead == C.RESULT_END_OF_INPUT) { in readMetadata()
131 bytesRead = upstream.read(metadata, offset, lengthRemaining); in readMetadata()
132 if (bytesRead == C.RESULT_END_OF_INPUT) { in readMetadata()
135 offset += bytesRead; in readMetadata()
136 lengthRemaining -= bytesRead; in readMetadata()
|
| /external/apache-commons-compress/src/main/java/org/apache/commons/compress/compressors/ |
| D | CompressorInputStream.java | 24 private long bytesRead = 0; field in CompressorInputStream
46 bytesRead = bytesRead + read; in count()
57 bytesRead -= pushedBack; in pushedBackBytes()
68 return (int) bytesRead; in getCount()
78 return bytesRead; in getBytesRead()
|
| /external/exoplayer/tree/library/core/src/test/java/com/google/android/exoplayer2/upstream/ |
| D | DataSourceInputStreamTest.java | 39 assertThat(inputStream.bytesRead()).isEqualTo(0); in readSingleBytes()
46 assertThat(inputStream.bytesRead()).isEqualTo(i + 1); in readSingleBytes()
50 assertThat(inputStream.bytesRead()).isEqualTo(TEST_DATA.length); in readSingleBytes()
62 int bytesRead = inputStream.read(readBytes, totalBytesRead,
64 assertThat(bytesRead).isGreaterThan(0);
65 totalBytesRead += bytesRead;
66 assertThat(inputStream.bytesRead()).isEqualTo(totalBytesRead);
71 assertThat(inputStream.bytesRead()).isEqualTo(TEST_DATA.length);
87 assertThat(inputStream.bytesRead()).isEqualTo(totalBytesSkipped);
90 assertThat(inputStream.bytesRead()).isEqualTo(TEST_DATA.length);
|
| D | ByteArrayDataSourceTest.java | 131 int bytesRead = dataSource.read(outputBuffer, writeOffset, requestedReadLength); in readTestData() local
132 if (bytesRead != C.RESULT_END_OF_INPUT) { in readTestData()
133 assertThat(bytesRead).isGreaterThan(0); in readTestData()
134 assertThat(bytesRead).isAtMost(requestedReadLength); in readTestData()
136 for (int i = 0; i < bytesRead; i++) { in readTestData()
141 accumulatedBytesRead += bytesRead; in readTestData()
145 || bytesRead == requestedReadLength).isTrue(); in readTestData()
|
| /external/exoplayer/tree/library/core/src/main/java/com/google/android/exoplayer2/upstream/ |
| D | StatsDataSource.java | 35 private long bytesRead; field in StatsDataSource
52 bytesRead = 0; in resetBytesRead()
57 return bytesRead; in getBytesRead()
91 int bytesRead = dataSource.read(buffer, offset, readLength); in read() local
92 if (bytesRead != C.RESULT_END_OF_INPUT) { in read()
93 this.bytesRead += bytesRead; in read()
95 return bytesRead; in read()
|
| D | DataSourceInputStream.java | 50 public long bytesRead() { in bytesRead() method in DataSourceInputStream
82 int bytesRead = dataSource.read(buffer, offset, length); in read() local
83 if (bytesRead == C.RESULT_END_OF_INPUT) { in read()
86 totalBytesRead += bytesRead; in read()
87 return bytesRead; in read()
|
| /external/okhttp/samples/guide/src/main/java/com/squareup/okhttp/recipes/ |
| D | Progress.java | 41 @Override public void update(long bytesRead, long contentLength, boolean done) { in run()
42 System.out.println(bytesRead); in run()
45 System.out.format("%d%% done\n", (100 * bytesRead) / contentLength); in run()
98 long bytesRead = super.read(sink, byteCount); in source() local
100 totalBytesRead += bytesRead != -1 ? bytesRead : 0; in source()
101 progressListener.update(totalBytesRead, responseBody.contentLength(), bytesRead == -1); in source()
102 return bytesRead; in source()
109 void update(long bytesRead, long contentLength, boolean done); in update() argument
|
| /external/apache-commons-compress/src/main/java/org/apache/commons/compress/archivers/ |
| D | ArchiveInputStream.java | 46 private long bytesRead = 0; field in ArchiveInputStream
104 bytesRead = bytesRead + read; in count()
115 bytesRead -= pushedBack; in pushedBackBytes()
126 return (int) bytesRead; in getCount()
135 return bytesRead; in getBytesRead()
|
| /external/apache-commons-compress/src/main/java/org/apache/commons/compress/archivers/sevenz/ |
| D | BoundedSeekableByteChannelInputStream.java | 64 int bytesRead; in read() local
68 bytesRead = read(bytesToRead); in read()
71 bytesRead = channel.read(buf); in read()
74 if (bytesRead >= 0) { in read()
75 buf.get(b, off, bytesRead); in read()
76 bytesRemaining -= bytesRead; in read()
78 return bytesRead; in read()
|
| /external/apache-commons-compress/src/main/java/org/apache/commons/compress/compressors/lzw/ |
| D | LZWInputStream.java | 75 int bytesRead = readFromStack(b, off, len); in read() local
76 while (len - bytesRead > 0) { in read()
79 if (bytesRead > 0) { in read()
80 count(bytesRead); in read()
81 return bytesRead; in read()
85 bytesRead += readFromStack(b, off + bytesRead, len - bytesRead); in read()
87 count(bytesRead); in read()
88 return bytesRead; in read()
|
| /external/smali/dexlib2/src/main/java/org/jf/util/ |
| D | RandomAccessFileInputStream.java | 56 int bytesRead = raf.read(bytes); in read() local
57 filePosition += bytesRead; in read()
58 return bytesRead; in read()
63 int bytesRead = raf.read(bytes, offset, length); in read() local
64 filePosition += bytesRead; in read()
65 return bytesRead; in read()
|
| /external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/framework/jdwp/ |
| D | SocketTransportWrapper.java | 243 int bytesRead = input.read(header, off, Packet.HEADER_SIZE - off); in readPacket() local
244 if (bytesRead < 0) { in readPacket()
247 off += bytesRead; in readPacket()
273 int bytesRead = input.read(bytes, off, len - off); in readPacket() local
274 if (bytesRead < 0) { in readPacket()
277 off += bytesRead; in readPacket()
313 int bytesRead = input.read(bytes, off, len - off); in handshake() local
314 if (bytesRead < 0) { in handshake()
317 off += bytesRead; in handshake()
|
| /external/brotli/csharp/org/brotli/dec/ |
| D | BitReader.cs | 71 int bytesRead = ByteReadSize - readOffset; in ReadMoreInput()
72 System.Array.Copy(br.byteBuffer, readOffset, br.byteBuffer, 0, bytesRead); in ReadMoreInput()
76 while (bytesRead < ByteReadSize) in ReadMoreInput()
78 int len = br.input.Read(br.byteBuffer, bytesRead, ByteReadSize - bytesRead); in ReadMoreInput()
83 br.tailBytes = bytesRead; in ReadMoreInput()
84 bytesRead += 3; in ReadMoreInput()
87 bytesRead += len; in ReadMoreInput()
94 Org.Brotli.Dec.IntReader.Convert(br.intReader, bytesRead >> 2); in ReadMoreInput()
|
| /external/zstd/contrib/pzstd/ |
| D | Pzstd.cpp | 60 std::uint64_t bytesRead; in handleOneInput() local
70 [&state, &outs, &executor, inputFd, inputSize, &options, &bytesRead] { in handleOneInput()
71 bytesRead = asyncCompressChunks( in handleOneInput()
84 readExecutor.add([&state, &outs, &executor, inputFd, &bytesRead] { in handleOneInput()
85 bytesRead = asyncDecompressFrames(state, outs, executor, inputFd); in handleOneInput()
96 static_cast<double>(bytesRead + !bytesRead); in handleOneInput()
99 inputFileName.c_str(), ratio * 100, bytesRead, bytesWritten, in handleOneInput()
365 auto bytesRead = in readData() local
367 *totalBytesRead += bytesRead; in readData()
368 queue.push(buffer.splitAt(bytesRead)); in readData()
[all …]
|
| /external/OpenCSD/decoder/source/mem_acc/ |
| D | trc_mem_acc_bufptr.cpp | 47 uint32_t bytesRead = bytesInRange(address,reqBytes); // check bytes available in readBytes() local
48 if(bytesRead) in readBytes()
49 memcpy(byteBuffer,m_p_buffer+address-m_startAddress,bytesRead); in readBytes()
50 return bytesRead; in readBytes()
|
| /external/skia/docs/examples/ |
| D | Path_readFromMemory.cpp | 14 size_t bytesRead = copy.readFromMemory(storage.begin(), wrongSize); in draw() local
15 SkDebugf("length = %u; returned by readFromMemory = %u\n", wrongSize, bytesRead); in draw()
17 bytesRead = copy.readFromMemory(storage.begin(), largerSize); in draw()
18 SkDebugf("length = %u; returned by readFromMemory = %u\n", largerSize, bytesRead); in draw()
|