Home
last modified time | relevance | path

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

/system/update_engine/payload_consumer/
Dfile_writer.cc35 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()
Dextent_writer.cc36 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()
Dextent_writer_unittest.cc116 size_t bytes_written = 0; in WriteAlignedExtents() local
117 while (bytes_written < data.size()) { in WriteAlignedExtents()
118 size_t bytes_to_write = min(data.size() - bytes_written, chunk_size); in WriteAlignedExtents()
119 if (bytes_written == 0) { in WriteAlignedExtents()
120 bytes_to_write = min(data.size() - bytes_written, first_chunk_size); in WriteAlignedExtents()
122 EXPECT_TRUE(direct_writer.Write(&data[bytes_written], bytes_to_write)); in WriteAlignedExtents()
123 bytes_written += bytes_to_write; in WriteAlignedExtents()
157 size_t bytes_written = 0; in TEST_F() local
158 while (bytes_written < (block_count * kBlockSize)) { in TEST_F()
160 min(block_count * kBlockSize - bytes_written, data.size()); in TEST_F()
[all …]
Ddownload_action.cc157 ssize_t bytes_written = write(p2p_sharing_fd_, data, length); in WriteToP2PFile() local
158 if (bytes_written != static_cast<ssize_t>(length)) { in WriteToP2PFile()
Ddelta_performer.cc1314 bool Write(const void* buf, size_t count, size_t* bytes_written) override { in Write() argument
1316 *bytes_written = count; in Write()
/system/bt/vendor_libs/test_vendor_lib/model/devices/
Dhci_socket_device.cc114 int bytes_written; in SendHci() local
115 bytes_written = write(socket_file_descriptor_, &type, sizeof(type)); in SendHci()
116 if (bytes_written != sizeof(type)) { in SendHci()
117 LOG_WARN("bytes_written %d != sizeof(type)", bytes_written); in SendHci()
119 bytes_written = write(socket_file_descriptor_, packet->data(), packet->size()); in SendHci()
120 if (static_cast<size_t>(bytes_written) != packet->size()) { in SendHci()
121 LOG_WARN("bytes_written %d != packet->size", bytes_written); in SendHci()
/system/update_engine/common/
Dutils.cc174 ssize_t bytes_written = 0; in WriteAll() local
175 while (bytes_written < static_cast<ssize_t>(count)) { in WriteAll()
176 ssize_t rc = write(fd, c_buf + bytes_written, count - bytes_written); in WriteAll()
178 bytes_written += rc; in WriteAll()
185 size_t bytes_written = 0; in PWriteAll() local
187 while (bytes_written < count) { in PWriteAll()
190 c_buf + bytes_written, in PWriteAll()
191 count - bytes_written, in PWriteAll()
192 offset + bytes_written); in PWriteAll()
196 << " bytes_written=" << bytes_written << " count=" << count in PWriteAll()
[all …]
/system/core/fs_mgr/libfiemap/
Dfiemap_writer_test.cpp346 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/gatekeeper/
Dgatekeeper_messages.cpp95 uint32_t bytes_written = 0; in Serialize() local
104 bytes_written += sizeof(*header); in Serialize()
109 bytes_written += sizeof(retry_timeout); in Serialize()
114 bytes_written += serialized_size; in Serialize()
116 return bytes_written; in Serialize()
/system/core/libunwindstack/tools/
Dunwind_for_offline.cpp156 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/core/adb/
Dsocket_test.cpp108 size_t bytes_written; member
116 arg->bytes_written = 0; in CreateCloser()
126 arg->bytes_written += data.size(); in CreateCloser()
194 std::vector<char> buf(arg.bytes_written); in TEST_F()
195 ASSERT_NE(0u, arg.bytes_written); in TEST_F()
Dsysdeps_win32.cpp505 DWORD bytes_written = 0; in adb_pwrite() local
506 if (!::WriteFile(adb_get_os_handle(fd), buf, len, &bytes_written, &params)) { in adb_pwrite()
517 return static_cast<int>(bytes_written); in adb_pwrite()
733 DWORD bytes_written = 0; in _fh_socket_writev() local
734 int result = WSASend(f->fh_socket, wsabuf, iovcnt, &bytes_written, 0, nullptr, nullptr); in _fh_socket_writev()
746 CHECK_GE(static_cast<DWORD>(std::numeric_limits<int>::max()), bytes_written); in _fh_socket_writev()
747 return static_cast<int>(bytes_written); in _fh_socket_writev()
Dadb.cpp632 const size_t bytes_written = fwrite(buf, 1, bytes_read, stream.get()); in _redirect_pipe_thread() local
633 if (bytes_written != bytes_read) { in _redirect_pipe_thread()
634 fprintf(stderr, "adb: error: only wrote %zu of %lu bytes to %s\n", bytes_written, in _redirect_pipe_thread()
/system/nvram/messages/tests/
Dio_test.cpp303 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/
Dio.h158 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/
Dstorage.c242 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/
Dmessage_codec.cpp40 return EncodeData(&writer) ? counting_stream.bytes_written() : 0; in GetSize()
Dnvram_messages.cpp188 *size = stream.bytes_written(); in Encode()
/system/extras/ioshark/
Dioshark_bench.c135 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()
Dioshark_bench.h64 u_int64_t bytes_written; member
Dioshark_bench_subr.c291 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()
Dioshark_bench_mmap.c134 rw_bytes->bytes_written += len; in mmap_do_io()
/system/bt/gd/hal/
Dhci_hal_host_rootcanal.cc210 auto bytes_written = write(this->sock_fd_, (void*)packet_to_send.data(), packet_to_send.size()); in send_packet_ready() local
212 if (bytes_written == -1) { in send_packet_ready()
/system/chre/platform/slpi/see/
Dsns_qmi_client.c237 req_msg->payload_len = stream.bytes_written; in sns_client_send()
Dsee_helper.cc351 *msgLen = stream.bytes_written; in encodeSnsRemoteProcSensorConfig()