Home
last modified time | relevance | path

Searched refs:chunk_size (Results 1 – 20 of 20) sorted by relevance

/system/logging/logd/
DSerializedLogChunkTest.cpp31 size_t chunk_size = 10 * 4096; in TEST() local
32 auto chunk = SerializedLogChunk{chunk_size}; in TEST()
33 EXPECT_EQ(chunk_size + sizeof(SerializedLogChunk), chunk.PruneSize()); in TEST()
38 EXPECT_TRUE(chunk.CanLog(chunk_size)); in TEST()
39 EXPECT_FALSE(chunk.CanLog(chunk_size + 1)); in TEST()
54 EXPECT_FALSE(chunk.CanLog(chunk_size)); in TEST()
62 size_t chunk_size = individual_message_size * 3; in TEST() local
63 auto chunk = SerializedLogChunk{chunk_size}; in TEST()
64 EXPECT_EQ(chunk_size + sizeof(SerializedLogChunk), chunk.PruneSize()); in TEST()
79 size_t chunk_size = 10 * 4096; in TEST() local
[all …]
/system/update_engine/common/
Dmock_http_fetcher.cc73 const size_t chunk_size = in SendData() local
75 sent_offset_ += chunk_size; in SendData()
76 bytes_sent_ += chunk_size; in SendData()
79 this, &data_[sent_offset_ - chunk_size], chunk_size); in SendData()
/system/core/fs_mgr/libsnapshot/
Dpartition_cow_creator_test.cpp143 const uint64_t chunk_size = kSnapshotChunkSize * dm::kSectorSize; in TEST_F() local
144 ASSERT_EQ(chunk_size, block_size); in TEST_F()
171 ASSERT_EQ(2 * chunk_size, cow_device_size(iopv, builder_a.get(), builder_b.get(), system_b)); in TEST_F()
178 ASSERT_EQ(2 * chunk_size, cow_device_size(iopv, builder_a.get(), builder_b.get(), system_b)); in TEST_F()
184 ASSERT_EQ(2 * chunk_size, cow_device_size(iopv, builder_a.get(), builder_b.get(), system_b)); in TEST_F()
191 ASSERT_EQ(3 * chunk_size, cow_device_size(iopv, builder_a.get(), builder_b.get(), system_b)); in TEST_F()
198 ASSERT_EQ(4 * chunk_size, cow_device_size(iopv, builder_a.get(), builder_b.get(), system_b)); in TEST_F()
205 ASSERT_EQ(6 * chunk_size, cow_device_size(iopv, builder_a.get(), builder_b.get(), system_b)); in TEST_F()
/system/update_engine/payload_consumer/
Ddelta_performer_fuzzer.cc83 auto chunk_size = data_provider.ConsumeIntegralInRange<size_t>(0, 100); in FuzzDeltaPerformer() local
84 auto data = data_provider.ConsumeBytes<uint8_t>(chunk_size); in FuzzDeltaPerformer()
Dextent_writer_unittest.cc59 void WriteAlignedExtents(size_t chunk_size, size_t first_chunk_size);
103 void ExtentWriterTest::WriteAlignedExtents(size_t chunk_size, in WriteAlignedExtents() argument
115 size_t bytes_to_write = min(data.size() - bytes_written, chunk_size); in WriteAlignedExtents()
Ddelta_performer_integration_test.cc389 ssize_t chunk_size, in GenerateDeltaFile() argument
548 payload_config.hard_chunk_size = chunk_size; in GenerateDeltaFile()
963 ssize_t chunk_size, in DoSmallImageTest() argument
971 chunk_size, in DoSmallImageTest()
/system/core/libsparse/
Dsparse_read.cpp212 static int process_raw_chunk(struct sparse_file* s, unsigned int chunk_size, in process_raw_chunk() argument
218 if (chunk_size % s->block_size != 0) { in process_raw_chunk()
222 if (chunk_size / s->block_size != blocks) { in process_raw_chunk()
246 static int process_fill_chunk(struct sparse_file* s, unsigned int chunk_size, in process_fill_chunk() argument
256 if (chunk_size != sizeof(fill_val)) { in process_fill_chunk()
287 static int process_skip_chunk(struct sparse_file* s, unsigned int chunk_size, in process_skip_chunk() argument
290 if (chunk_size != 0) { in process_skip_chunk()
308 static int process_crc32_chunk(SparseFileSource* source, unsigned int chunk_size, uint32_t* crc32) { in process_crc32_chunk() argument
311 if (chunk_size != sizeof(file_crc32)) { in process_crc32_chunk()
/system/extras/pagecache/
Dpagecache.py120 def __init__(self, file_object, output_queue, text_file, chunk_size=-1): argument
137 self._chunk_size = chunk_size
138 assert text_file or chunk_size > 0
157 def set_chunk_size(self, chunk_size): argument
170 assert chunk_size > 0
171 self._chunk_size = chunk_size
291 text_file=True, chunk_size=64)
/system/core/fs_mgr/tools/
Ddmctl.cpp155 uint32_t chunk_size; in Next() local
156 if (!android::base::ParseUint(chunk_size_str, &chunk_size)) { in Next()
161 cow_device, mode, chunk_size); in Next()
174 uint32_t chunk_size; in Next() local
175 if (!android::base::ParseUint(chunk_size_str, &chunk_size)) { in Next()
180 cow_device, mode, chunk_size); in Next()
/system/core/fs_mgr/libsnapshot/snapuserd/include/snapuserd/
Dsnapuserd_kernel.h68 uint32_t chunk_size; member
/system/update_engine/scripts/
Dupdate_device.py79 chunk_size = buffer_size
81 chunk_size = min(chunk_size, copy_length - copied)
82 if not chunk_size:
84 buf = fsrc.read(chunk_size)
/system/core/fastboot/device/
Dcommands.cpp873 uint64_t chunk_size = std::min<uint64_t>(buf.size(), remaining); in Fetch() local
874 if (!android::base::ReadFully(handle_.fd(), buf.data(), chunk_size)) { in Fetch()
875 PLOG(ERROR) << std::hex << "Unable to read 0x" << chunk_size << " bytes from " in Fetch()
880 if (!device_->HandleData(false /* is read */, buf.data(), chunk_size)) { in Fetch()
881 PLOG(ERROR) << std::hex << "Unable to send 0x" << chunk_size << " bytes of " in Fetch()
886 current_offset += chunk_size; in Fetch()
/system/core/fs_mgr/libfiemap/
Dsplit_fiemap_writer.cpp104 uint64_t chunk_size = std::min(max_piece_size, remaining_bytes); in Create() local
106 auto status = FiemapWriter::Open(chunk_path, chunk_size, &writer, true, on_progress); in Create()
/system/core/fastboot/
Dfastboot_driver.cpp332 uint64_t chunk_size = std::min(buf_size, remaining); in RunAndReadBuffer() local
333 if ((ret = ReadBuffer(data.data(), chunk_size)) != SUCCESS) { in RunAndReadBuffer()
336 if ((ret = write_fn(data.data(), chunk_size)) != SUCCESS) { in RunAndReadBuffer()
339 current_offset += chunk_size; in RunAndReadBuffer()
Dfastboot.cpp1436 uint64_t chunk_size = std::min(fetch_size, partition_size - offset); in fetch_partition() local
1437 if (fb->FetchToFd(partition, fd, offset, chunk_size) != fastboot::RetCode::SUCCESS) { in fetch_partition()
1439 offset, chunk_size); in fetch_partition()
1441 offset += chunk_size; in fetch_partition()
/system/core/fs_mgr/libdm/include/libdm/
Ddm_target.h205 const std::string& cow_device, SnapshotStorageMode mode, uint64_t chunk_size) in DmTargetSnapshot() argument
210 chunk_size_(chunk_size) {} in DmTargetSnapshot()
/system/update_engine/payload_generator/
Ddelta_diff_utils.cc1000 const size_t chunk_size = in PopulateXorOps() local
1002 const auto xor_blocks = (chunk_size + kBlockSize / 2) / kBlockSize; in PopulateXorOps()
Dgenerate_delta_main.cc374 DEFINE_int32(chunk_size,
/system/core/fastboot/fuzzy_fastboot/
Dmain.cpp691 uint64_t chunk_size = std::min(fetch_size, partition_size - offset); in TEST_F() local
692 auto ret = fb->FetchToFd(partition, fetched.fd, offset, chunk_size); in TEST_F()
695 << ", size=" << chunk_size << ")"; in TEST_F()
696 offset += chunk_size; in TEST_F()
/system/core/fs_mgr/libsnapshot/snapuserd/dm-snapshot-merge/
Dsnapuserd_worker.cpp91 dh->chunk_size = CHUNK_SIZE; in ConstructKernelCowHeader()