| /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 | snapshot_extent_writer.cc | 111 auto bytes_written = ConsumeWithBuffer(data, count); in Write() local
112 TEST_AND_RETURN_FALSE(bytes_written > 0); in Write()
113 data += bytes_written; in Write()
114 count -= bytes_written; in Write()
|
| D | partition_writer.cc | 127 bool Write(const void* buf, size_t count, size_t* bytes_written) override { in Write() argument
129 *bytes_written = count; in Write()
|
| /system/update_engine/common/ |
| D | utils.cc | 153 ssize_t bytes_written = 0; in WriteAll() local
154 while (bytes_written < static_cast<ssize_t>(count)) { in WriteAll()
155 ssize_t rc = write(fd, c_buf + bytes_written, count - bytes_written); in WriteAll()
157 bytes_written += rc; in WriteAll()
164 size_t bytes_written = 0; in PWriteAll() local
166 while (bytes_written < count) { in PWriteAll()
169 c_buf + bytes_written, in PWriteAll()
170 count - bytes_written, in PWriteAll()
171 offset + bytes_written); in PWriteAll()
175 << " bytes_written=" << bytes_written << " count=" << count in PWriteAll()
[all …]
|
| /system/core/fs_mgr/libfiemap/ |
| D | fiemap_writer_test.cpp | 346 size_t bytes_written = 0; in TEST_F() local
347 while (bytes_written < kSize) { in TEST_F()
348 size_t to_write = std::min(kSize - bytes_written, (size_t)1000); in TEST_F()
349 char* data = reinterpret_cast<char*>(buffer.get()) + bytes_written; in TEST_F()
351 bytes_written += to_write; in TEST_F()
373 size_t bytes_written = 0; in TEST_F() local
374 while (bytes_written < kSize) { in TEST_F()
375 size_t to_write = std::min(kSize - bytes_written, kChunkSize); in TEST_F()
376 char* data = reinterpret_cast<char*>(buffer.get()) + bytes_written; in TEST_F()
378 bytes_written += to_write; in TEST_F()
|
| /system/unwinding/libunwindstack/tools/ |
| D | unwind_for_offline.cpp | 156 size_t bytes_written = fwrite(buffer.data(), 1, bytes, output.get()); in CreateElfFromMemory() local
157 if (bytes_written != bytes) { in CreateElfFromMemory()
158 printf("Failed to write all data to file: bytes read %zu, written %zu\n", bytes, bytes_written); in CreateElfFromMemory()
189 size_t bytes_written = fwrite(buffer.data(), 1, bytes, output.get()); in CopyElfFromFile() local
190 if (bytes_written != bytes) { in CopyElfFromFile()
192 bytes_written); in CopyElfFromFile()
|
| /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/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/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/nvram/messages/ |
| D | message_codec.cpp | 40 return EncodeData(&writer) ? counting_stream.bytes_written() : 0; in GetSize()
|
| D | nvram_messages.cpp | 188 *size = stream.bytes_written(); in Encode()
|
| /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/update_engine/cros/ |
| D | download_action_chromeos.cc | 158 ssize_t bytes_written = write(p2p_sharing_fd_, data, length); in WriteToP2PFile() local
159 if (bytes_written != static_cast<ssize_t>(length)) { in WriteToP2PFile()
|
| /system/bt/audio_hal_interface/ |
| D | le_audio_software.cc | 273 void LogBytesWritten(size_t bytes_written) override { in LogBytesWritten() argument
274 transport_->LogBytesProcessed(bytes_written); in LogBytesWritten()
|
| D | client_interface.h | 177 virtual void LogBytesWritten(size_t bytes_written) = 0;
|
| D | client_interface_unittest.cc | 204 void LogBytesWritten(size_t bytes_written __unused) override{}; in LogBytesWritten()
|
| /system/chre/platform/slpi/see/ |
| D | sns_qmi_client.c | 237 req_msg->payload_len = stream.bytes_written; in sns_client_send()
|
| D | see_helper.cc | 353 *msgLen = stream.bytes_written; in encodeSnsRemoteProcSensorConfig()
|
| /system/bt/gd/hal/ |
| D | hci_hal_host.cc | 375 auto bytes_written = write(this->sock_fd_, (void*)packet_to_send.data(), packet_to_send.size()); in send_packet_ready() local
377 if (bytes_written == -1) { in send_packet_ready()
|