| /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, in Write()
38 count - bytes_written); in Write()
41 bytes_written += rc; in Write()
43 CHECK_EQ(bytes_written, count); in Write()
44 return bytes_written == count; in Write()
|
| D | extent_writer.cc | 36 size_t bytes_written = 0; in Write() local
37 while (count - bytes_written > 0) { in Write()
44 static_cast<size_t>(min(static_cast<uint64_t>(count - bytes_written), in Write()
55 utils::WriteAll(fd_, c_bytes + bytes_written, bytes_to_write)); in Write()
57 bytes_written += bytes_to_write; in Write()
|
| D | extent_writer_unittest.cc | 138 size_t bytes_written = 0; in WriteAlignedExtents() local
139 while (bytes_written < data.size()) { in WriteAlignedExtents()
140 size_t bytes_to_write = min(data.size() - bytes_written, chunk_size); in WriteAlignedExtents()
141 if (bytes_written == 0) { in WriteAlignedExtents()
142 bytes_to_write = min(data.size() - bytes_written, first_chunk_size); in WriteAlignedExtents()
144 EXPECT_TRUE(direct_writer.Write(&data[bytes_written], bytes_to_write)); in WriteAlignedExtents()
145 bytes_written += bytes_to_write; in WriteAlignedExtents()
239 size_t bytes_written = 0; in TEST_F() local
240 while (bytes_written < (block_count * kBlockSize)) { in TEST_F()
241 size_t bytes_to_write = min(block_count * kBlockSize - bytes_written, in TEST_F()
[all …]
|
| D | download_action.cc | 157 ssize_t bytes_written = write(p2p_sharing_fd_, data, length); in WriteToP2PFile() local
158 if (bytes_written != static_cast<ssize_t>(length)) { in WriteToP2PFile()
|
| D | delta_performer.cc | 1020 ssize_t bytes_written = 0; in PerformMoveOperation() local
1026 &buf[bytes_written], in PerformMoveOperation()
1029 bytes_written += bytes; in PerformMoveOperation()
1031 DCHECK_EQ(bytes_written, bytes_read); in PerformMoveOperation()
1032 DCHECK_EQ(bytes_written, static_cast<ssize_t>(buf.size())); in PerformMoveOperation()
|
| /system/update_engine/common/ |
| D | utils.cc | 229 ssize_t bytes_written = 0; in WriteAll() local
230 while (bytes_written < static_cast<ssize_t>(count)) { in WriteAll()
231 ssize_t rc = write(fd, c_buf + bytes_written, count - bytes_written); in WriteAll()
233 bytes_written += rc; in WriteAll()
240 size_t bytes_written = 0; in PWriteAll() local
242 while (bytes_written < count) { in PWriteAll()
244 ssize_t rc = pwrite(fd, c_buf + bytes_written, count - bytes_written, in PWriteAll()
245 offset + bytes_written); in PWriteAll()
249 << " bytes_written=" << bytes_written in PWriteAll()
253 bytes_written += rc; in PWriteAll()
[all …]
|
| /system/core/adb/ |
| D | socket_test.cpp | 108 size_t bytes_written; member
115 arg->bytes_written = 0; in CloseWithPacketThreadFunc()
119 arg->bytes_written += p->len; in CloseWithPacketThreadFunc()
181 std::vector<char> buf(arg.bytes_written); in TEST_F()
182 ASSERT_NE(0u, arg.bytes_written); in TEST_F()
|
| D | adb.cpp | 625 const size_t bytes_written = fwrite(buf, 1, bytes_read, stream.get()); in _redirect_pipe_thread() local
626 if (bytes_written != bytes_read) { in _redirect_pipe_thread()
627 fprintf(stderr, "adb: error: only wrote %zu of %lu bytes to %s\n", bytes_written, in _redirect_pipe_thread()
|
| /system/gatekeeper/ |
| D | gatekeeper_messages.cpp | 80 uint32_t bytes_written = 0; in Serialize() local
90 bytes_written += sizeof(*header); in Serialize()
93 bytes_written += sizeof(retry_timeout); in Serialize()
101 bytes_written += sizeof(*header) + nonErrorSerializedSize(); in Serialize()
104 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 | 134 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()
328 (int)(rw_bytes->bytes_written / (1024 * 1024))); in print_bytes()
332 (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()
|