| /packages/services/Car/car-lib/src/android/car/storagemonitoring/ |
| D | IoStatsEntry.java | 203 && record.foreground_rchar == foreground.bytesRead in representsSameMetrics()
208 && record.background_rchar == background.bytesRead in representsSameMetrics()
235 public final long bytesRead; field in IoStatsEntry.Metrics
260 public Metrics(long bytesRead, long bytesWritten, long bytesReadFromStorage, in Metrics() argument
262 this.bytesRead = bytesRead; in Metrics()
276 dest.writeLong(bytesRead); in writeToParcel()
288 jsonWriter.name("bytesRead").value(bytesRead); in writeToJson()
297 bytesRead = in.readLong(); in Metrics()
308 bytesRead = in.getLong("bytesRead"); in Metrics()
325 return new Metrics(bytesRead - other.bytesRead, in delta()
[all …]
|
| D | IoStats.java | 145 long bytesRead = 0; in getForegroundTotals() local
152 bytesRead += stats.foreground.bytesRead; in getForegroundTotals()
159 return new Metrics(bytesRead, in getForegroundTotals()
171 long bytesRead = 0; in getBackgroundTotals() local
178 bytesRead += stats.background.bytesRead; in getBackgroundTotals()
185 return new Metrics(bytesRead, in getBackgroundTotals()
200 return new IoStatsEntry.Metrics(foreground.bytesRead + background.bytesRead, in getTotals()
|
| /packages/modules/Connectivity/tests/cts/net/src/android/net/ipv6/cts/ |
| D | PingTest.java | 114 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/TV/tuner/tests/robotests/javatests/com/android/tv/tuner/exoplayer/tests/ |
| D | AssetDataSource.java | 92 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/Gallery2/jni_jpegstream/src/ |
| D | inputstream_wrapper.cpp | 27 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()
|
| D | jpeg_hook.cpp | 91 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()
|
| /packages/apps/Test/connectivity/PMC/src/com/android/pmc/ |
| D | WifiDownloadReceiver.java | 118 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/ |
| D | SendRequest.java | 112 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/ |
| D | DumpDatabaseAction.java | 71 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/ |
| D | FdEventsReader.java | 223 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/OnDevicePersonalization/tests/federatedcomputetests/src/com/android/federatedcompute/services/http/ |
| D | HttpClientUtilTest.java | 42 int bytesRead; in compress_uncompress_success() local
43 while ((bytesRead = in.read(buf)) != -1) { in compress_uncompress_success()
44 outputStream.write(buf, 0, bytesRead); in compress_uncompress_success()
|
| /packages/modules/Connectivity/staticlibs/device/com/android/net/module/util/ |
| D | FdEventsReader.java | 245 final int bytesRead; in handleInput() local
248 bytesRead = readPacket(mFd, mBuffer); in handleInput()
249 if (bytesRead == 0 && !shouldProcessZeroLengthPacket()) { in handleInput()
272 handlePacket(mBuffer, bytesRead); in handleInput()
|
| /packages/modules/IPsec/src/java/com/android/internal/net/ipsec/ike/ |
| D | IkeSocket.java | 173 int bytesRead = in.read(inBytes); in receiveFromFd() local
175 if (bytesRead < 0) { in receiveFromFd()
177 } else if (bytesRead >= RCV_BUFFER_SIZE) { in receiveFromFd()
186 return Arrays.copyOf(inBytes, bytesRead); in receiveFromFd()
|
| /packages/modules/GeoTZ/s2storage/src/write/java/com/android/storage/block/write/ |
| D | BlockFileWriter.java | 155 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/AdServices/adservices/service-core/java/com/android/adservices/service/adselection/ |
| D | AuctionServerDataCompressorGzip.java | 71 int bytesRead; in decompress() local
72 while ((bytesRead = gzipInputStream.read(buffer)) > 0) { in decompress()
73 byteArrayOutputStream.write(buffer, 0, bytesRead); in decompress()
|
| /packages/modules/OnDevicePersonalization/federatedcompute/src/com/android/federatedcompute/services/common/ |
| D | FileUtils.java | 91 int bytesRead; in readFileDescriptorAsByteArray() local
93 while ((bytesRead = inputStream.read(buffer)) != -1) { in readFileDescriptorAsByteArray()
94 outputStream.write(buffer, 0, bytesRead); in readFileDescriptorAsByteArray()
|
| /packages/modules/Connectivity/tests/cts/net/src/android/net/cts/ |
| D | TunUtils.java | 93 int bytesRead = in.read(inBytes); in receiveFromTun() local
95 if (bytesRead < 0) { in receiveFromTun()
97 } else if (bytesRead >= DATA_BUFFER_LEN) { in receiveFromTun()
100 return Arrays.copyOf(inBytes, bytesRead); in receiveFromTun()
|
| /packages/modules/IPsec/tests/cts/src/android/ipsec/ike/cts/ |
| D | TunUtils.java | 99 int bytesRead = in.read(inBytes); in receiveFromTun() local
101 if (bytesRead < 0) { in receiveFromTun()
103 } else if (bytesRead >= DATA_BUFFER_LEN) { in receiveFromTun()
106 return Arrays.copyOf(inBytes, bytesRead); in receiveFromTun()
|
| /packages/modules/adb/client/ |
| D | incremental_server.cpp | 392 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/modules/Bluetooth/android/app/src/com/android/bluetooth/opp/ |
| D | BluetoothOppSendFileInfo.java | 359 int bytesRead = is.read(unused, 0, 4096); in getStreamSize() local
360 while (bytesRead != -1) { in getStreamSize()
361 length += bytesRead; in getStreamSize()
362 bytesRead = is.read(unused, 0, 4096); in getStreamSize()
|
| /packages/services/Car/tests/ConcurrentHotwordDetector/src/com/android/car/test/concurrent/hotword/ |
| D | ConcurrentHotwordDetectionService.java | 194 int bytesRead = in canReadAudio() local
196 if (bytesRead < 0) { in canReadAudio()
197 Log.e(TAG, "Error reading from mic: " + bytesRead); in canReadAudio()
200 numBytes += bytesRead; in canReadAudio()
|
| /packages/modules/OnDevicePersonalization/federatedcompute/src/com/android/federatedcompute/services/http/ |
| D | HttpClient.java | 189 int bytesRead; in getByteArray() local
190 while ((bytesRead = in.read(buffer)) != -1) { in getByteArray()
191 out.write(buffer, 0, bytesRead); in getByteArray()
|
| /packages/providers/MediaProvider/pdf/framework/libs/pdfClient/ |
| D | document.cc | 166 size_t bytesRead; in CloneRawFile() local
167 while ((bytesRead = read(source, buf, 4096)) > 0) { in CloneRawFile()
168 write(dest, buf, bytesRead); in CloneRawFile()
|
| /packages/modules/Connectivity/service/src/com/android/server/connectivity/ |
| D | NetworkDiagnostics.java | 825 int bytesRead = 0; in sendDoTProbe() local
826 while (bytesRead < replyLength) { in sendDoTProbe()
827 bytesRead += input.read(reply, bytesRead, replyLength - bytesRead); in sendDoTProbe()
830 if (bytesRead > DNS_HEADER_SIZE && bytesRead == replyLength) { in sendDoTProbe()
833 mMeasurement.recordFailure("1/1 Read " + bytesRead + " bytes while expected to be " in sendDoTProbe()
|
| /packages/modules/GeoTZ/s2storage/src/readonly/java/com/android/storage/block/read/ |
| D | BlockFileReader.java | 173 int bytesRead = mFileChannel.read(allBlockBuffer); in getBlock() local
174 if (bytesRead != blockSizeBytes) { in getBlock()
176 + ", only read" + bytesRead); in getBlock()
|