Home
last modified time | relevance | path

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

12

/packages/services/Car/car-lib/src/android/car/storagemonitoring/
DIoStatsEntry.java217 && record.foreground_rchar == foreground.bytesRead in representsSameMetrics()
222 && record.background_rchar == background.bytesRead in representsSameMetrics()
251 public final long bytesRead; field in IoStatsEntry.Metrics
280 public Metrics(long bytesRead, long bytesWritten, long bytesReadFromStorage, in Metrics() argument
282 this.bytesRead = bytesRead; in Metrics()
298 dest.writeLong(bytesRead); in writeToParcel()
311 jsonWriter.name("bytesRead").value(bytesRead); in writeToJson()
320 bytesRead = in.readLong(); in Metrics()
331 bytesRead = in.getLong("bytesRead"); in Metrics()
349 return new Metrics(bytesRead - other.bytesRead, in delta()
[all …]
DIoStats.java155 long bytesRead = 0; in getForegroundTotals() local
162 bytesRead += stats.foreground.bytesRead; in getForegroundTotals()
169 return new Metrics(bytesRead, in getForegroundTotals()
182 long bytesRead = 0; in getBackgroundTotals() local
189 bytesRead += stats.background.bytesRead; in getBackgroundTotals()
196 return new Metrics(bytesRead, in getBackgroundTotals()
212 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/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/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/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.java167 int bytesRead = in.read(inBytes); in receiveFromFd() local
169 if (bytesRead < 0) { in receiveFromFd()
171 } else if (bytesRead >= RCV_BUFFER_SIZE) { in receiveFromFd()
180 return Arrays.copyOf(inBytes, bytesRead); in receiveFromFd()
/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/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()
/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/modules/Bluetooth/android/app/src/com/android/bluetooth/opp/
DBluetoothOppSendFileInfo.java259 int bytesRead = is.read(unused, 0, 4096); in getStreamSize() local
260 while (bytesRead != -1) { in getStreamSize()
261 length += bytesRead; in getStreamSize()
262 bytesRead = is.read(unused, 0, 4096); in getStreamSize()
/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/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/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()
DBlockData.java142 int bytesRead = 0; in getValueInternal() local
143 while (bytesRead++ < valueSizeBytes) { in getValueInternal()
/packages/services/Mms/src/com/android/mms/service/
DMmsService.java584 int bytesRead = readPduBytesFromContentUri(contentUri, pduData);
587 if (bytesRead == 2
1056 int bytesRead = readPduBytesFromContentUri(contentUri, pduData); in readPduFromContentUri() local
1057 if (bytesRead <= 0) { in readPduFromContentUri()
1060 if (bytesRead > maxSize) { in readPduFromContentUri()
1064 return Arrays.copyOf(pduData, bytesRead); in readPduFromContentUri()
1086 int bytesRead = inStream.read(pduData, 0, pduData.length); in readPduBytesFromContentUri()
1087 if (bytesRead <= 0) { in readPduBytesFromContentUri()
1090 return bytesRead; in readPduBytesFromContentUri()
/packages/modules/IPsec/tests/iketests/src/java/com/android/internal/net/ipsec/ike/
DIkeSocketTestBase.java147 AtomicInteger bytesRead = new AtomicInteger(-1); in receive() local
151 while (bytesRead.get() < 0) { in receive()
153 bytesRead.set( in receive()
173 return Arrays.copyOfRange(receiveBuffer, 0, bytesRead.get()); in receive()
/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()
/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()

12