Home
last modified time | relevance | path

Searched refs:bytesRead (Results 1 – 25 of 154) sorted by relevance

1234567

/external/okhttp/samples/guide/src/main/java/com/squareup/okhttp/recipes/
DProgress.java41 @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/compressors/
DCompressorInputStream.java24 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/apache-commons-compress/src/main/java/org/apache/commons/compress/compressors/lzw/
DLZWInputStream.java75 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/apache-commons-compress/src/main/java/org/apache/commons/compress/archivers/
DArchiveInputStream.java46 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/
DBoundedSeekableByteChannelInputStream.java64 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/smali/util/src/main/java/org/jf/util/
DRandomAccessFileInputStream.java56 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/
DSocketTransportWrapper.java243 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/
DBitReader.cs71 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/webrtc/webrtc/modules/media_file/
Dmedia_file_utility.cc442 int32_t bytesRead = ReadWavData( in ReadWavDataAsMono() local
446 if(bytesRead == 0) in ReadWavDataAsMono()
450 if(bytesRead < 0) in ReadWavDataAsMono()
533 int32_t bytesRead = ReadWavData(wav, _tempData, totalBytesNeeded); in ReadWavDataAsStereo() local
534 if(bytesRead <= 0) in ReadWavDataAsStereo()
609 int32_t bytesRead = wav.Read(buffer, dataLengthInBytes); in ReadWavData() local
610 if(bytesRead < 0) in ReadWavData()
619 if(bytesRead < (int32_t)dataLengthInBytes) in ReadWavData()
629 bytesRead = wav.Read(buffer, dataLengthInBytes); in ReadWavData()
630 if(bytesRead < (int32_t)dataLengthInBytes) in ReadWavData()
[all …]
Dmedia_file_impl.cc122 int32_t bytesRead = 0; in PlayoutAudioData() local
146 bytesRead = _ptrFileUtilityObj->ReadPCMData( in PlayoutAudioData()
152 bytesRead = _ptrFileUtilityObj->ReadCompressedData( in PlayoutAudioData()
158 bytesRead = _ptrFileUtilityObj->ReadWavDataAsMono( in PlayoutAudioData()
164 bytesRead = _ptrFileUtilityObj->ReadPreEncodedData( in PlayoutAudioData()
168 if(bytesRead > 0) in PlayoutAudioData()
170 dataLengthInBytes = static_cast<size_t>(bytesRead); in PlayoutAudioData()
183 if( bytesRead > 0) in PlayoutAudioData()
185 dataLengthInBytes = static_cast<size_t>(bytesRead); in PlayoutAudioData()
188 HandlePlayCallbacks(bytesRead); in PlayoutAudioData()
[all …]
/external/sl4a/Common/src/com/googlecode/android_scripting/facade/bluetooth/
DBluetoothConnection.java173 int bytesRead = mInputStream.read(buffer); in readBinary() local
174 if (bytesRead == -1) { in readBinary()
178 byte[] truncatedBuffer = new byte[bytesRead]; in readBinary()
179 System.arraycopy(buffer, 0, truncatedBuffer, 0, bytesRead); in readBinary()
206 int bytesRead = mReader.read(buffer); in read() local
207 if (bytesRead == -1) { in read()
211 return new String(buffer, 0, bytesRead); in read()
/external/apache-commons-compress/src/main/java/org/apache/commons/compress/utils/
DBoundedInputStream.java61 final int bytesRead = in.read(b, off, bytesToRead); in read() local
62 if (bytesRead >= 0) { in read()
63 bytesRemaining -= bytesRead; in read()
65 return bytesRead; in read()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DApplicationThreadDeframerTest.java93 applicationThreadDeframer.bytesRead(1); in bytesReadInvokesTransportExecutor()
94 assertEquals(0, listener.bytesRead); in bytesReadInvokesTransportExecutor()
96 assertEquals(1, listener.bytesRead); in bytesReadInvokesTransportExecutor()
137 private int bytesRead; field in ApplicationThreadDeframerTest.DeframerListener
147 public void bytesRead(int numBytes) { in bytesRead() method in ApplicationThreadDeframerTest.DeframerListener
148 assertEquals(0, bytesRead); in bytesRead()
149 bytesRead = numBytes; in bytesRead()
DMessageDeframerTest.java129 verify(listener, atLeastOnce()).bytesRead(anyInt()); in simplePayload()
142 verify(listener, atLeastOnce()).bytesRead(anyInt()); in smallCombinedPayloads()
156 verify(listener, atLeastOnce()).bytesRead(anyInt()); in endOfStreamWithPayloadShouldNotifyEndOfStream()
168 verify(listener, atLeast(1)).bytesRead(anyInt()); in endOfStreamShouldNotifyEndOfStream()
180 verify(listener, atLeastOnce()).bytesRead(anyInt()); in endOfStreamWithPartialMessageShouldNotifyDeframerClosedWithPartialMessage()
206 verify(listener, atLeastOnce()).bytesRead(anyInt()); in payloadSplitBetweenBuffers()
212 verify(listener, atLeastOnce()).bytesRead(anyInt()); in payloadSplitBetweenBuffers()
231 verify(listener, atLeastOnce()).bytesRead(anyInt()); in frameHeaderSplitBetweenBuffers()
236 verify(listener, atLeastOnce()).bytesRead(anyInt()); in frameHeaderSplitBetweenBuffers()
247 verify(listener, atLeastOnce()).bytesRead(anyInt()); in emptyPayload()
[all …]
/external/icu/icu4j/demos/src/com/ibm/icu/dev/demo/charsetdet/
DDetectingViewer.java224 int bytesRead = in.read(buffer, bufLen, bytesRemaining); in filter() local
226 if (bytesRead <= 0) { in filter()
230 bufLen += bytesRead; in filter()
231 bytesRemaining -= bytesRead; in filter()
295 int bytesRead = 0; in show() local
314 while ((bytesRead = inputStream.read(bytes, offset, 1024)) >= 0) { in show()
315 offset = bytesRead % 4; in show()
316 chBytes = bytesRead - offset; in show()
329 while ((bytesRead = isr.read(buffer, 0, 1024)) >= 0) { in show()
330 sb.append(buffer, 0, bytesRead); in show()
/external/apache-commons-compress/src/main/java/org/apache/commons/compress/archivers/dump/
DTapeInputStream.java44 private long bytesRead = 0; field in TapeInputStream
275 bytesRead += blockSize;
278 bytesRead += 4;
286 bytesRead += blockSize;
293 bytesRead += length;
353 return bytesRead; in getBytesRead()
/external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/
DOkHttpReadableBuffer.java58 int bytesRead = buffer.read(dest, destOffset, length); in readBytes() local
59 if (bytesRead == -1) { in readBytes()
62 length -= bytesRead; in readBytes()
63 destOffset += bytesRead; in readBytes()
/external/skqp/src/codec/
DSkIcoCodec.cpp21 bool SkIcoCodec::IsIco(const void* buffer, size_t bytesRead) { in IsIco() argument
24 return bytesRead >= sizeof(icoSig) && in IsIco()
111 uint32_t bytesRead = kIcoDirectoryBytes + numImages * kIcoDirEntryBytes; in MakeFromStream() local
119 if (offset < bytesRead) { in MakeFromStream()
126 if (stream->skip(offset - bytesRead) != offset - bytesRead) { in MakeFromStream()
130 bytesRead = offset; in MakeFromStream()
147 bytesRead += size; in MakeFromStream()
/external/skia/src/codec/
DSkIcoCodec.cpp21 bool SkIcoCodec::IsIco(const void* buffer, size_t bytesRead) { in IsIco() argument
24 return bytesRead >= sizeof(icoSig) && in IsIco()
111 uint32_t bytesRead = kIcoDirectoryBytes + numImages * kIcoDirEntryBytes; in MakeFromStream() local
119 if (offset < bytesRead) { in MakeFromStream()
126 if (stream->skip(offset - bytesRead) != offset - bytesRead) { in MakeFromStream()
130 bytesRead = offset; in MakeFromStream()
147 bytesRead += size; in MakeFromStream()
/external/conscrypt/common/src/main/java/org/conscrypt/
DConscryptEngine.java861 int bytesRead = readPlaintextData(dst);
862 if (bytesRead > 0) {
863 bytesProduced += bytesRead;
870 switch (bytesRead) {
1103 int bytesRead = readPlaintextDataDirect(dst, pos, len);
1104 if (bytesRead > 0) {
1105 dst.position(pos + bytesRead);
1107 return bytesRead;
1139 int bytesRead = readPlaintextDataDirect(buffer, 0, bytesToRead);
1140 if (bytesRead > 0) {
[all …]
/external/webrtc/webrtc/modules/audio_device/android/java/src/org/webrtc/voiceengine/
DWebRtcAudioRecord.java79 int bytesRead = audioRecord.read(byteBuffer, byteBuffer.capacity()); in run() local
80 if (bytesRead == byteBuffer.capacity()) { in run()
81 nativeDataIsRecorded(bytesRead, nativeAudioRecord); in run()
83 Logging.e(TAG,"AudioRecord.read failed: " + bytesRead); in run()
84 if (bytesRead == AudioRecord.ERROR_INVALID_OPERATION) { in run()
93 Logging.d(TAG, "bytesRead[" + durationInMs + "] " + bytesRead); in run()
/external/conscrypt/repackaged/benchmark-base/src/main/java/com/android/org/conscrypt/
DServerEndpoint.java164 int bytesRead = readMessage(); in run() local
166 messageProcessor.processMessage(buffer, bytesRead, outputStream); in run()
179 int bytesRead = inputStream.read(buffer, totalBytesRead, remaining); in readMessage() local
180 if (bytesRead == -1) { in readMessage()
183 totalBytesRead += bytesRead; in readMessage()
/external/icu/icu4j/main/tests/core/src/com/ibm/icu/dev/test/compression/
DDecompressionTest.java41 int [] bytesRead = new int[1]; in decompressTest() local
46 bytesRead, in decompressTest()
51 logln("Bytes consumed: " + bytesRead[0]); in decompressTest()
58 bytesRead, in decompressTest()
64 logln("Bytes consumed: " + bytesRead[0]); in decompressTest()
/external/conscrypt/benchmark-base/src/main/java/org/conscrypt/
DServerEndpoint.java161 int bytesRead = readMessage(); in run() local
163 messageProcessor.processMessage(buffer, bytesRead, outputStream); in run()
176 int bytesRead = inputStream.read(buffer, totalBytesRead, remaining); in readMessage() local
177 if (bytesRead == -1) { in readMessage()
180 totalBytesRead += bytesRead; in readMessage()
/external/icu/android_icu4j/src/main/tests/android/icu/dev/test/compression/
DDecompressionTest.java44 int [] bytesRead = new int[1]; in decompressTest() local
49 bytesRead, in decompressTest()
54 logln("Bytes consumed: " + bytesRead[0]); in decompressTest()
61 bytesRead, in decompressTest()
67 logln("Bytes consumed: " + bytesRead[0]); in decompressTest()

1234567