| /system/core/logd/ |
| D | SerializedLogChunkTest.cpp | 28 size_t chunk_size = 10 * 4096; in TEST() local
29 auto chunk = SerializedLogChunk{chunk_size}; in TEST()
30 EXPECT_EQ(chunk_size + sizeof(SerializedLogChunk), chunk.PruneSize()); in TEST()
35 EXPECT_TRUE(chunk.CanLog(chunk_size)); in TEST()
36 EXPECT_FALSE(chunk.CanLog(chunk_size + 1)); in TEST()
51 EXPECT_FALSE(chunk.CanLog(chunk_size)); in TEST()
59 size_t chunk_size = individual_message_size * 3; in TEST() local
60 auto chunk = SerializedLogChunk{chunk_size}; in TEST()
61 EXPECT_EQ(chunk_size + sizeof(SerializedLogChunk), chunk.PruneSize()); in TEST()
76 size_t chunk_size = 10 * 4096; in TEST() local
[all …]
|
| /system/core/init/ |
| D | security.cpp | 72 ssize_t chunk_size = in MixHwrngIntoLinuxRngAction() local
74 if (chunk_size == -1) { in MixHwrngIntoLinuxRngAction()
76 } else if (chunk_size == 0) { in MixHwrngIntoLinuxRngAction()
80 chunk_size = TEMP_FAILURE_RETRY(write(urandom_fd, buf, chunk_size)); in MixHwrngIntoLinuxRngAction()
81 if (chunk_size == -1) { in MixHwrngIntoLinuxRngAction()
84 total_bytes_written += chunk_size; in MixHwrngIntoLinuxRngAction()
|
| /system/update_engine/common/ |
| D | mock_http_fetcher.cc | 71 const size_t chunk_size = in SendData() local
73 sent_size_ += chunk_size; in SendData()
75 delegate_->ReceivedBytes(this, &data_[sent_size_ - chunk_size], chunk_size); in SendData()
|
| /system/core/fs_mgr/libsnapshot/ |
| D | partition_cow_creator_test.cpp | 137 const uint64_t chunk_size = kSnapshotChunkSize * dm::kSectorSize; in TEST_F() local
138 ASSERT_EQ(chunk_size, block_size); in TEST_F()
163 ASSERT_EQ(2 * chunk_size, cow_device_size(iopv, builder_a.get(), builder_b.get(), system_b)); in TEST_F()
170 ASSERT_EQ(2 * chunk_size, cow_device_size(iopv, builder_a.get(), builder_b.get(), system_b)); in TEST_F()
176 ASSERT_EQ(2 * chunk_size, cow_device_size(iopv, builder_a.get(), builder_b.get(), system_b)); in TEST_F()
183 ASSERT_EQ(3 * chunk_size, cow_device_size(iopv, builder_a.get(), builder_b.get(), system_b)); in TEST_F()
190 ASSERT_EQ(4 * chunk_size, cow_device_size(iopv, builder_a.get(), builder_b.get(), system_b)); in TEST_F()
197 ASSERT_EQ(6 * chunk_size, cow_device_size(iopv, builder_a.get(), builder_b.get(), system_b)); in TEST_F()
|
| /system/core/libsparse/ |
| D | sparse_read.cpp | 174 static int process_raw_chunk(struct sparse_file* s, unsigned int chunk_size, in process_raw_chunk() argument
180 if (chunk_size % s->block_size != 0) { in process_raw_chunk()
184 if (chunk_size / s->block_size != blocks) { in process_raw_chunk()
205 static int process_fill_chunk(struct sparse_file* s, unsigned int chunk_size, in process_fill_chunk() argument
215 if (chunk_size != sizeof(fill_val)) { in process_fill_chunk()
246 static int process_skip_chunk(struct sparse_file* s, unsigned int chunk_size, in process_skip_chunk() argument
249 if (chunk_size != 0) { in process_skip_chunk()
267 static int process_crc32_chunk(SparseFileSource* source, unsigned int chunk_size, uint32_t* crc32) { in process_crc32_chunk() argument
270 if (chunk_size != sizeof(file_crc32)) { in process_crc32_chunk()
|
| /system/update_engine/payload_consumer/ |
| D | delta_performer_fuzzer.cc | 83 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()
|
| D | extent_writer_unittest.cc | 59 void WriteAlignedExtents(size_t chunk_size, size_t first_chunk_size);
105 void ExtentWriterTest::WriteAlignedExtents(size_t chunk_size, in WriteAlignedExtents() argument
118 size_t bytes_to_write = min(data.size() - bytes_written, chunk_size); in WriteAlignedExtents()
|
| D | delta_performer_integration_test.cc | 359 ssize_t chunk_size, in GenerateDeltaFile() argument
540 payload_config.hard_chunk_size = chunk_size; in GenerateDeltaFile()
944 ssize_t chunk_size, in DoSmallImageTest() argument
952 chunk_size, in DoSmallImageTest()
|
| /system/extras/pagecache/ |
| D | pagecache.py | 120 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/update_engine/scripts/ |
| D | update_device.py | 65 chunk_size = buffer_size
67 chunk_size = min(chunk_size, copy_length - copied)
68 if not chunk_size:
70 buf = fsrc.read(chunk_size)
|
| /system/core/fs_mgr/tools/ |
| D | dmctl.cpp | 151 uint32_t chunk_size; in Next() local
152 if (!android::base::ParseUint(chunk_size_str, &chunk_size)) { in Next()
157 cow_device, mode, chunk_size); in Next()
170 uint32_t chunk_size; in Next() local
171 if (!android::base::ParseUint(chunk_size_str, &chunk_size)) { in Next()
176 cow_device, mode, chunk_size); in Next()
|
| /system/core/fs_mgr/libfiemap/ |
| D | split_fiemap_writer.cpp | 104 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/adb/client/ |
| D | usb_linux.cpp | 412 int chunk_size = (i + 16384 > len) ? len - i : 16384; in usb_write_split() local
413 int n = usb_bulk_write(h, data + i, chunk_size); in usb_write_split()
414 if (n != chunk_size) { in usb_write_split()
|
| /system/core/fs_mgr/libdm/include/libdm/ |
| D | dm_target.h | 204 const std::string& cow_device, SnapshotStorageMode mode, uint64_t chunk_size) in DmTargetSnapshot() argument
209 chunk_size_(chunk_size) {} in DmTargetSnapshot()
|
| /system/update_engine/payload_generator/ |
| D | generate_delta_main.cc | 365 chunk_size, 200 * 1024 * 1024, "Payload chunk size (-1 for whole files)"); in Main()
|