Home
last modified time | relevance | path

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

12

/packages/services/Car/car-lib/src/android/car/storagemonitoring/
DIoStatsEntry.java194 && record.foreground_rchar == foreground.bytesRead in representsSameMetrics()
199 && record.background_rchar == background.bytesRead in representsSameMetrics()
226 public final long bytesRead; field in IoStatsEntry.Metrics
251 public Metrics(long bytesRead, long bytesWritten, long bytesReadFromStorage, in Metrics() argument
253 this.bytesRead = bytesRead; in Metrics()
267 dest.writeLong(bytesRead); in writeToParcel()
279 jsonWriter.name("bytesRead").value(bytesRead); in writeToJson()
288 bytesRead = in.readLong(); in Metrics()
299 bytesRead = in.getLong("bytesRead"); in Metrics()
316 return new Metrics(bytesRead - other.bytesRead, in delta()
[all …]
DIoStats.java136 long bytesRead = 0; in getForegroundTotals() local
143 bytesRead += stats.foreground.bytesRead; in getForegroundTotals()
150 return new Metrics(bytesRead, in getForegroundTotals()
162 long bytesRead = 0; in getBackgroundTotals() local
169 bytesRead += stats.background.bytesRead; in getBackgroundTotals()
176 return new Metrics(bytesRead, in getBackgroundTotals()
191 return new IoStatsEntry.Metrics(foreground.bytesRead + background.bytesRead, in getTotals()
/packages/modules/Connectivity/tests/cts/net/src/android/net/ipv6/cts/
DPingTest.java114 int bytesRead; in checkResponse() local
119 bytesRead = Os.recvfrom(s, responseBuffer, 0, from); in checkResponse()
128 bytesRead = Os.read(s, responseBuffer); in checkResponse()
132 assertEquals(sent.length, bytesRead); in checkResponse()
135 byte[] response = new byte[bytesRead]; in checkResponse()
137 responseBuffer.get(response, 0, bytesRead); in checkResponse()
149 assertArrayBytesEqual(response, sent, bytesRead); in checkResponse()
/packages/apps/Gallery2/jni_jpegstream/src/
Djpeg_hook.cpp91 int32_t bytesRead = src->inStream->read(src->inStream->getBufferSize(), 0); in Mgr_fill_input_buffer_fcn() local
92 if (bytesRead == J_DONE) { in Mgr_fill_input_buffer_fcn()
97 bytesRead = src->inStream->forceReadEOI(); in Mgr_fill_input_buffer_fcn()
98 } else if (bytesRead < 0) { in Mgr_fill_input_buffer_fcn()
100 } else if (bytesRead == 0) { in Mgr_fill_input_buffer_fcn()
104 src->mgr.bytes_in_buffer = bytesRead; in Mgr_fill_input_buffer_fcn()
105 if (bytesRead != 0) { in Mgr_fill_input_buffer_fcn()
Dinputstream_wrapper.cpp27 int32_t bytesRead = 0; in read() local
33 bytesRead = static_cast<int32_t>(mEnv->CallIntMethod(mStream, sReadID, in read()
42 if (bytesRead == END_OF_STREAM) { in read()
45 return bytesRead; in read()
/packages/apps/Test/connectivity/PMC/src/com/android/pmc/
DWifiDownloadReceiver.java118 int bytesRead = downloadFile(connection); in doInBackground() local
119 if (fileLength != bytesRead) { in doInBackground()
121 + bytesRead; in doInBackground()
168 int bytesRead = -1; in downloadFile() local
170 while ((bytesRead = inputStream.read(buffer)) != -1) { in downloadFile()
171 totalBytesRead += bytesRead; in downloadFile()
/packages/apps/TV/tuner/tests/robotests/javatests/com/android/tv/tuner/exoplayer/tests/
DAssetDataSource.java92 int bytesRead = 0; in read() local
98 bytesRead = mInputStream.read(buffer, offset, bytesToRead); in read()
103 if (bytesRead > 0 && mBytesRemaining != C.LENGTH_UNBOUNDED) { in read()
104 mBytesRemaining -= bytesRead; in read()
107 return bytesRead; in read()
/packages/apps/Messaging/src/android/support/v7/mms/
DSendRequest.java112 final int bytesRead = inStream.read(readBuf, 0, maxSize+1); in readPduFromContentUri()
113 if (bytesRead <= 0) { in readPduFromContentUri()
117 if (bytesRead > maxSize) { in readPduFromContentUri()
122 final byte[] result = new byte[bytesRead]; in readPduFromContentUri()
123 System.arraycopy(readBuf, 0, result, 0, bytesRead); in readPduFromContentUri()
/packages/apps/Messaging/src/com/android/messaging/datamodel/action/
DDumpDatabaseAction.java71 int bytesRead; in executeAction() local
72 while ((bytesRead = bis.read(buffer)) > 0) { in executeAction()
73 bos.write(buffer, 0, bytesRead); in executeAction()
74 totalBytes += bytesRead; in executeAction()
/packages/modules/IPsec/src/java/com/android/internal/net/ipsec/ike/utils/
DFdEventsReader.java223 final int bytesRead; in handleInput() local
226 bytesRead = readPacket(mFd, mBuffer); in handleInput()
227 if (bytesRead < 1) { in handleInput()
248 handlePacket(mBuffer, bytesRead); in handleInput()
/packages/modules/GeoTZ/s2storage/src/write/java/com/android/timezone/location/storage/block/write/
DBlockFileWriter.java155 int bytesRead; in copyAll() local
156 while ((bytesRead = inputStream.read(buffer)) >= 0) { in copyAll()
157 outputStream.writeBytes(buffer, 0, bytesRead); in copyAll()
158 totalByteCount += bytesRead; in copyAll()
/packages/modules/IPsec/src/java/com/android/internal/net/ipsec/ike/
DIkeSocket.java172 int bytesRead = in.read(inBytes); in receiveFromFd() local
174 if (bytesRead < 0) { in receiveFromFd()
176 } else if (bytesRead >= RCV_BUFFER_SIZE) { in receiveFromFd()
185 return Arrays.copyOf(inBytes, bytesRead); in receiveFromFd()
/packages/modules/Connectivity/service/src/com/android/server/connectivity/
DNetworkDiagnostics.java730 int bytesRead = 0; in sendDoTProbe() local
731 while (bytesRead < replyLength) { in sendDoTProbe()
732 bytesRead += input.read(reply, bytesRead, replyLength - bytesRead); in sendDoTProbe()
735 if (bytesRead > DNS_HEADER_SIZE && bytesRead == replyLength) { in sendDoTProbe()
738 mMeasurement.recordFailure("1/1 Read " + bytesRead + " bytes while expected to be " in sendDoTProbe()
/packages/apps/Bluetooth/src/com/android/bluetooth/opp/
DBluetoothOppSendFileInfo.java253 int bytesRead = is.read(unused, 0, 4096); in getStreamSize() local
254 while (bytesRead != -1) { in getStreamSize()
255 length += bytesRead; in getStreamSize()
256 bytesRead = is.read(unused, 0, 4096); in getStreamSize()
/packages/modules/Connectivity/tests/cts/net/src/android/net/cts/
DTunUtils.java92 int bytesRead = in.read(inBytes); in receiveFromTun() local
94 if (bytesRead < 0) { in receiveFromTun()
96 } else if (bytesRead >= DATA_BUFFER_LEN) { in receiveFromTun()
99 return Arrays.copyOf(inBytes, bytesRead); in receiveFromTun()
DIpSecBaseTest.java195 AtomicInteger bytesRead = new AtomicInteger(-1); in receive() local
199 … while (bytesRead.get() < 0 && System.currentTimeMillis() < startTime + SOCK_TIMEOUT) { in receive()
201 bytesRead.set(Os.recvfrom(mFd, in, 0, DATA_BUFFER_LEN, 0, null)); in receive()
211 if (bytesRead.get() < 0) { in receive()
215 return Arrays.copyOfRange(in, 0, bytesRead.get()); in receive()
349 int bytesRead = mSocket.getInputStream().read(in); in receive() local
350 return Arrays.copyOfRange(in, 0, bytesRead); in receive()
DLocalSocketTest.java372 private int bytesRead; field in LocalSocketTest.StreamReader
385 bytesRead += readCount; in run()
386 if (bytesRead >= expectedByteCount) { in run()
407 assertEquals(expected, bytesRead); in assertBytesRead()
/packages/modules/IPsec/tests/cts/src/android/ipsec/ike/cts/
DTunUtils.java100 int bytesRead = in.read(inBytes); in receiveFromTun() local
102 if (bytesRead < 0) { in receiveFromTun()
104 } else if (bytesRead >= DATA_BUFFER_LEN) { in receiveFromTun()
107 return Arrays.copyOf(inBytes, bytesRead); in receiveFromTun()
/packages/modules/adb/client/
Dincremental_server.cpp392 const int64_t bytesRead = file.ReadTreeBlock(blockIdx, buffer.data); in SendTreeBlock() local
393 if (bytesRead <= 0) { in SendTreeBlock()
402 buffer.header.block_size = toBigEndian(int16_t(bytesRead)); in SendTreeBlock()
405 Send(&buffer, ResponseHeader::responseSizeFor(bytesRead), /*flush=*/false); in SendTreeBlock()
427 const int64_t bytesRead = file.ReadDataBlock(blockIdx, raw.data, &isZipCompressed); in SendDataBlock() local
428 if (bytesRead < 0) { in SendDataBlock()
437 compressedSize = LZ4_compress_default(raw.data, compressed.data, bytesRead, kCompressBound); in SendDataBlock()
448 blockSize = bytesRead; in SendDataBlock()
/packages/services/Mms/src/com/android/mms/service/
DMmsService.java507 int bytesRead = readPduBytesFromContentUri(contentUri, pduData);
510 if (bytesRead == 2
970 int bytesRead = readPduBytesFromContentUri(contentUri, pduData); in readPduFromContentUri() local
971 if (bytesRead <= 0) { in readPduFromContentUri()
974 if (bytesRead > maxSize) { in readPduFromContentUri()
978 return Arrays.copyOf(pduData, bytesRead); in readPduFromContentUri()
1000 int bytesRead = inStream.read(pduData, 0, pduData.length); in readPduBytesFromContentUri()
1001 if (bytesRead <= 0) { in readPduBytesFromContentUri()
1004 return bytesRead; in readPduBytesFromContentUri()
/packages/services/Car/tests/carservice_unit_test/src/com/android/car/storagemonitoring/
DCarStorageMonitoringTest.java372 assertThat(entry.foreground.bytesRead).isEqualTo(256797495); in testUidIoStatEntry()
377 assertThat(entry.background.bytesRead).isEqualTo(0); in testUidIoStatEntry()
387 assertThat(entry.foreground.bytesRead).isEqualTo(489007); in testUidIoStatEntry()
392 assertThat(entry.background.bytesRead).isEqualTo(51474); in testUidIoStatEntry()
505 assertThat(delta21.foreground.bytesRead).isEqualTo(100); in testUidIoStatEntryDelta()
511 assertThat(delta21.background.bytesRead).isEqualTo(200); in testUidIoStatEntryDelta()
621 assertThat(foregroundTotals.bytesRead).isEqualTo(120); in testUidIoStatsTotals()
628 assertThat(backgroundTotals.bytesRead).isEqualTo(10); in testUidIoStatsTotals()
634 assertThat(overallTotals.bytesRead).isEqualTo(130); in testUidIoStatsTotals()
/packages/modules/IPsec/tests/iketests/src/java/com/android/internal/net/ipsec/ike/
DIkeSocketTestBase.java148 AtomicInteger bytesRead = new AtomicInteger(-1); in receive() local
152 while (bytesRead.get() < 0) { in receive()
154 bytesRead.set( in receive()
174 return Arrays.copyOfRange(receiveBuffer, 0, bytesRead.get()); in receive()
/packages/modules/GeoTZ/s2storage/src/readonly/java/com/android/timezone/location/storage/block/read/
DBlockFileReader.java173 int bytesRead = mFileChannel.read(allBlockBuffer); in getBlock() local
174 if (bytesRead != blockSizeBytes) { in getBlock()
176 + ", only read" + bytesRead); in getBlock()
/packages/apps/Dialer/java/com/android/incallui/calllocation/impl/
DHttpFetcher.java85 int bytesRead; in sendRequestAsByteArray() local
87 while ((bytesRead = is.read(buffer)) != -1) { in sendRequestAsByteArray()
88 baos.write(buffer, 0, bytesRead); in sendRequestAsByteArray()
/packages/apps/CertInstaller/src/com/android/certinstaller/
DCertInstallerMain.java169 int bytesRead = 0; in readWithLimit() local
173 bytesRead += count; in readWithLimit()
174 if (bytesRead > READ_LIMIT) { in readWithLimit()

12