| /system/update_engine/payload_consumer/ |
| D | file_writer.cc | 35 size_t bytes_written = 0; in Write() local
36 while (bytes_written < count) { in Write()
37 ssize_t rc = write(fd_, char_bytes + bytes_written, count - bytes_written); in Write()
40 bytes_written += rc; in Write()
42 CHECK_EQ(bytes_written, count); in Write()
43 return bytes_written == count; in Write()
|
| D | extent_writer.cc | 36 size_t bytes_written = 0; in Write() local
37 while (bytes_written < count) { in Write()
43 static_cast<size_t>(min(static_cast<uint64_t>(count - bytes_written), in Write()
53 utils::WriteAll(fd_, c_bytes + bytes_written, bytes_to_write)); in Write()
55 bytes_written += bytes_to_write; in Write()
|
| D | extent_writer_unittest.cc | 113 size_t bytes_written = 0; in WriteAlignedExtents() local
114 while (bytes_written < data.size()) { in WriteAlignedExtents()
115 size_t bytes_to_write = min(data.size() - bytes_written, chunk_size); in WriteAlignedExtents()
116 if (bytes_written == 0) { in WriteAlignedExtents()
117 bytes_to_write = min(data.size() - bytes_written, first_chunk_size); in WriteAlignedExtents()
119 EXPECT_TRUE(direct_writer.Write(&data[bytes_written], bytes_to_write)); in WriteAlignedExtents()
120 bytes_written += bytes_to_write; in WriteAlignedExtents()
153 size_t bytes_written = 0; in TEST_F() local
154 while (bytes_written < (block_count * kBlockSize)) { in TEST_F()
156 min(block_count * kBlockSize - bytes_written, data.size()); in TEST_F()
[all …]
|
| D | block_extent_writer.cc | 115 const auto bytes_written = ConsumeWithBuffer(data, count); in Write() local
116 TEST_AND_RETURN_FALSE(bytes_written > 0); in Write()
117 data += bytes_written; in Write()
118 count -= bytes_written; in Write()
|
| D | install_operation_executor.cc | 65 bool Write(const void* buf, size_t count, size_t* bytes_written) override { in Write() argument
67 *bytes_written = count; in Write()
|
| /system/update_engine/lz4diff/ |
| D | lz4diff_compress.cc | 95 const uint64_t bytes_written = ret; in TryCompressBlob() local
97 TEST_LE(bytes_written, block.compressed_length); in TryCompressBlob()
98 if (bytes_written < block.compressed_length) { in TryCompressBlob()
100 const auto padding = block.compressed_length - bytes_written; in TryCompressBlob()
102 block_buffer.data() + padding, block_buffer.data(), bytes_written); in TryCompressBlob()
106 std::fill(block_buffer.data() + bytes_written, in TryCompressBlob()
|
| /system/update_engine/common/ |
| D | utils.cc | 154 ssize_t bytes_written = 0; in WriteAll() local
155 while (bytes_written < static_cast<ssize_t>(count)) { in WriteAll()
156 ssize_t rc = write(fd, c_buf + bytes_written, count - bytes_written); in WriteAll()
158 bytes_written += rc; in WriteAll()
165 size_t bytes_written = 0; in PWriteAll() local
167 while (bytes_written < count) { in PWriteAll()
170 c_buf + bytes_written, in PWriteAll()
171 count - bytes_written, in PWriteAll()
172 offset + bytes_written); in PWriteAll()
176 << " bytes_written=" << bytes_written << " count=" << count in PWriteAll()
[all …]
|
| /system/gatekeeper/ |
| D | gatekeeper_messages.cpp | 111 uint32_t bytes_written = 0; in Serialize() local
120 bytes_written += sizeof(*header); in Serialize()
125 bytes_written += sizeof(retry_timeout); in Serialize()
130 bytes_written += serialized_size; in Serialize()
132 return bytes_written; in Serialize()
|
| /system/core/fs_mgr/libfiemap/ |
| D | fiemap_writer_test.cpp | 381 size_t bytes_written = 0; in TEST_F() local
382 while (bytes_written < kSize) { in TEST_F()
383 size_t to_write = std::min(kSize - bytes_written, (size_t)1000); in TEST_F()
384 char* data = reinterpret_cast<char*>(buffer.get()) + bytes_written; in TEST_F()
386 bytes_written += to_write; in TEST_F()
408 size_t bytes_written = 0; in TEST_F() local
409 while (bytes_written < kSize) { in TEST_F()
410 size_t to_write = std::min(kSize - bytes_written, kChunkSize); in TEST_F()
411 char* data = reinterpret_cast<char*>(buffer.get()) + bytes_written; in TEST_F()
413 bytes_written += to_write; in TEST_F()
|
| /system/unwinding/libunwindstack/tools/ |
| D | unwind_for_offline.cpp | 167 size_t bytes_written = fwrite(buffer.data(), 1, bytes, output.get()); in CopyElf() local
168 if (bytes_written != bytes) { in CopyElf()
170 bytes_written); in CopyElf()
205 size_t bytes_written = fwrite(buffer.data(), 1, bytes, output.get()); in CreateElfFromMemory() local
206 if (bytes_written != bytes) { in CreateElfFromMemory()
208 bytes_written); in CreateElfFromMemory()
|
| /system/nvram/messages/tests/ |
| D | io_test.cpp | 303 EXPECT_EQ(0U, buf.bytes_written()); in TEST()
307 EXPECT_EQ(15U, buf.bytes_written()); in TEST()
311 EXPECT_EQ(16U, buf.bytes_written()); in TEST()
315 EXPECT_EQ(1040U, buf.bytes_written()); in TEST()
|
| /system/update_engine/liburing_cpp/tests/ |
| D | BasicTests.cpp | 148 size_t bytes_written = 0; in WriteTestData() local
150 while (bytes_written < size) { in WriteTestData()
153 bytes_written += ret; in WriteTestData()
|
| /system/nvram/messages/include/nvram/messages/ |
| D | io.h | 158 size_t bytes_written() const { return pos_ - data_; } in bytes_written() function
171 size_t bytes_written() const { in bytes_written() function
|
| /system/core/trusty/storage/lib/ |
| D | storage.c | 242 size_t bytes_written = 0; in storage_write() local
262 bytes_written += chunk; in storage_write()
265 return bytes_written; in storage_write()
|
| /system/chre/apps/nearby/third_party/nanopb/ |
| D | pb_encode.h | 41 size_t bytes_written; /* Number of bytes written so far. */ member
|
| /system/chre/apps/nearby/location/lbs/contexthub/nanoapps/nearby/ |
| D | app_manager.cc | 385 *encode_arg->msg_size = stream->bytes_written; in EncodeFilterResultCallback()
412 CHRE_ASSERT(stream->bytes_written == 0); in EncodeFilterResults()
435 CHRE_ASSERT(stream->bytes_written == 0); in EncodeFilterResult()
446 *msg_size = stream->bytes_written; in EncodeFilterResult()
|
| /system/logging/logd/ |
| D | logd_test.cpp | 53 ssize_t bytes_written = TEMP_FAILURE_RETRY(write(sock, command, command_length)); in write_command() local
54 if (bytes_written != static_cast<ssize_t>(command_length)) { in write_command()
55 if (bytes_written == -1) { in write_command()
59 command, bytes_written, command_length); in write_command()
|
| /system/nvram/messages/ |
| D | message_codec.cpp | 40 return EncodeData(&writer) ? counting_stream.bytes_written() : 0; in GetSize()
|
| /system/extras/ioshark/ |
| D | ioshark_bench.c | 135 dest->bytes_written += delta->bytes_written; in update_byte_counts()
259 rw_bytes->bytes_written += file_op->prw_len; in do_one_io()
289 rw_bytes->bytes_written += file_op->rw_len; in do_one_io()
|
| D | ioshark_bench.h | 64 u_int64_t bytes_written; member
|
| D | ioshark_bench_subr.c | 291 rw_bytes->bytes_written += n; in create_file()
327 (int)(rw_bytes->bytes_written / (1024 * 1024))); in print_bytes()
331 (int)(rw_bytes->bytes_written / (1024 * 1024))); in print_bytes()
|
| D | ioshark_bench_mmap.c | 134 rw_bytes->bytes_written += len; in mmap_do_io()
|
| /system/core/libsparse/ |
| D | output_file.cpp | 326 uint64_t bytes_written = 0; in write_fd_chunk_range() local
328 while (bytes_written < len) { in write_fd_chunk_range()
329 size_t mmap_size = std::min(static_cast<uint64_t>(kMaxMmapSize), len - bytes_written); in write_fd_chunk_range()
338 bytes_written += mmap_size; in write_fd_chunk_range()
|
| /system/libbase/ |
| D | file.cpp | 356 DWORD bytes_written; in pwrite() local
362 static_cast<DWORD>(byte_count), &bytes_written, &overlapped)) { in pwrite()
367 return static_cast<ssize_t>(bytes_written); in pwrite()
|
| /system/chre/platform/slpi/see/ |
| D | sns_qmi_client.c | 237 req_msg->payload_len = stream.bytes_written; in sns_client_send()
|