| /aosp14/system/core/fs_mgr/libsnapshot/snapuserd/user-space-merge/ |
| H A D | snapuserd_merge.cpp | 28 int num_ops = *pending_ops; in PrepareMerge() local
33 if (!cowop_iter_->Done() && num_ops) { in PrepareMerge()
45 num_ops -= 1; in PrepareMerge()
64 num_ops -= 1; in PrepareMerge()
89 int num_ops = PAYLOAD_BUFFER_SZ / BLOCK_SZ; in MergeReplaceZeroOps() local
207 while (num_ops) { in MergeOrderedOpsAsync()
226 num_ops -= linear_blocks; in MergeOrderedOpsAsync()
326 CHECK(num_ops == 0); in MergeOrderedOpsAsync()
383 while (num_ops) { in MergeOrderedOps()
406 num_ops -= linear_blocks; in MergeOrderedOps()
[all …]
|
| H A D | snapuserd_readahead.cpp | 56 int num_ops = *pending_ops; in PrepareNextReadAhead() local
76 num_ops -= 1; in PrepareNextReadAhead()
87 while (!RAIterDone() && num_ops) { in PrepareNextReadAhead()
105 num_ops -= 1; in PrepareNextReadAhead()
121 int num_ops = 0; in ReconstructDataFromCow() local
142 num_ops += 1; in ReconstructDataFromCow()
154 num_ops -= 1; in ReconstructDataFromCow()
162 if (!(num_ops == 0)) { in ReconstructDataFromCow()
269 while (num_ops) { in ReadAheadAsyncIO()
500 while (num_ops) { in ReadAheadSyncIO()
[all …]
|
| /aosp14/system/core/fs_mgr/libsnapshot/snapuserd/dm-snapshot-merge/ |
| H A D | snapuserd_readahead.cpp | 191 int num_ops = *pending_ops; in PrepareReadAhead() local
195 if (!RAIterDone() && num_ops) { in PrepareReadAhead()
204 num_ops -= 1; in PrepareReadAhead()
215 while (!RAIterDone() && num_ops) { in PrepareReadAhead()
226 num_ops -= 1; in PrepareReadAhead()
242 int num_ops = 0; in ReconstructDataFromCow() local
263 num_ops += 1; in ReconstructDataFromCow()
275 num_ops -= 1; in ReconstructDataFromCow()
282 if (!(num_ops == 0)) { in ReconstructDataFromCow()
340 PrepareReadAhead(&source_offset, &num_ops, blocks); in ReadAheadIOStart()
[all …]
|
| H A D | snapuserd.cpp | 387 size_t num_ops = 0; in ReadMetadata() local
426 num_ops += 1; in ReadMetadata()
430 SNAP_LOG(DEBUG) << num_ops << ":" in ReadMetadata()
433 if (num_ops == exceptions_per_area_) { in ReadMetadata()
438 num_ops = 0; in ReadMetadata()
458 size_t pending_ordered_ops = exceptions_per_area_ - num_ops; in ReadMetadata()
552 num_ops += 1; in ReadMetadata()
561 SNAP_LOG(DEBUG) << num_ops << ":" in ReadMetadata()
565 if (num_ops == exceptions_per_area_) { in ReadMetadata()
569 num_ops = 0; in ReadMetadata()
[all …]
|
| H A D | snapuserd_worker.cpp | 313 int num_ops = DIV_ROUND_UP(size, BLOCK_SZ); in ReadData() local
315 while (num_ops) { in ReadData()
326 num_ops -= 1; in ReadData()
331 if (it == chunk_vec.end() && num_ops) { in ReadData()
333 << " COW ops completed; pending read-request: " << num_ops; in ReadData()
|
| /aosp14/system/core/fs_mgr/libsnapshot/libsnapshot_cow/ |
| H A D | cow_writer.cpp | 122 bool ICowWriter::AddSequenceData(size_t num_ops, const uint32_t* data) { in AddSequenceData() argument
123 return EmitSequenceData(num_ops, data); in AddSequenceData()
400 footer_.op.num_ops = 0; in OpenForAppend()
577 bool CowWriter::EmitSequenceData(size_t num_ops, const uint32_t* data) { in EmitSequenceData() argument
581 while (num_ops > 0) { in EmitSequenceData()
585 to_add = std::min(num_ops, max_ops); in EmitSequenceData()
591 num_ops -= to_add; in EmitSequenceData()
634 auto continue_num_ops = footer_.op.num_ops; in Finalize()
659 footer_.op.ops_size = footer_.op.num_ops * sizeof(CowOperation); in Finalize()
692 footer_.op.num_ops = continue_num_ops; in Finalize()
[all …]
|
| H A D | inspect_cow.cpp | 135 std::cout << "Number of Ops: " << footer.op.num_ops << "\n"; in Inspect()
|
| H A D | cow_reader.cpp | 286 if (ops_buffer->size() != footer_->op.num_ops) { in ParseOps()
287 LOG(ERROR) << "num ops does not match, expected " << footer_->op.num_ops << ", found " in ParseOps()
|
| H A D | cow_api_test.cpp | 86 ASSERT_EQ(footer.op.num_ops, 100); in TEST_F()
134 ASSERT_EQ(footer.op.num_ops, 4); in TEST_F()
212 ASSERT_EQ(footer.op.num_ops, 4); in TEST_F()
|
| /aosp14/system/core/fs_mgr/libsnapshot/include/libsnapshot/ |
| H A D | snapshot_writer.h | 83 bool EmitSequenceData(size_t num_ops, const uint32_t* data) override;
118 bool EmitSequenceData(size_t num_ops, const uint32_t* data) override;
|
| H A D | cow_writer.h | 87 bool AddSequenceData(size_t num_ops, const uint32_t* data);
108 virtual bool EmitSequenceData(size_t num_ops, const uint32_t* data) = 0;
183 virtual bool EmitSequenceData(size_t num_ops, const uint32_t* data) override;
|
| H A D | cow_format.h | 99 uint64_t num_ops; member
|
| /aosp14/system/core/fs_mgr/libsnapshot/ |
| H A D | snapshot_writer.cpp | 140 bool CompressedSnapshotWriter::EmitSequenceData(size_t num_ops, const uint32_t* data) { in EmitSequenceData() argument
141 return cow_->AddSequenceData(num_ops, data); in EmitSequenceData()
|
| H A D | snapshot.cpp | 1388 size_t num_ops = 0; in CheckMergeConsistency() local
1402 num_ops = reader.get_num_total_data_ops(); in CheckMergeConsistency()
1428 if (header->num_merge_ops != num_ops) { in CheckMergeConsistency()
1429 LOG(ERROR) << "COW consistency check failed, expected " << num_ops << " to be merged, " in CheckMergeConsistency()
|