Home
last modified time | relevance | path

Searched refs:num_ops (Results 1 – 18 of 18) sorted by relevance

/system/core/fs_mgr/libsnapshot/snapuserd/user-space-merge/
Dsnapuserd_merge.cpp28 int num_ops = *pending_ops; in PrepareMerge() local
33 if (!cowop_iter_->Done() && num_ops) { in PrepareMerge()
45 num_ops -= 1; in PrepareMerge()
48 while (!cowop_iter_->Done() && num_ops) { in PrepareMerge()
64 num_ops -= 1; in PrepareMerge()
89 int num_ops = PAYLOAD_BUFFER_SZ / BLOCK_SZ; in MergeReplaceZeroOps() local
93 int linear_blocks = PrepareMerge(&source_offset, &num_ops, &replace_zero_vec); in MergeReplaceZeroOps()
199 int num_ops = snapuserd_->GetTotalBlocksToMerge(); in MergeOrderedOpsAsync() local
206 SNAP_LOG(DEBUG) << "Merging copy-ops of size: " << num_ops; in MergeOrderedOpsAsync()
207 while (num_ops) { in MergeOrderedOpsAsync()
[all …]
Dsnapuserd_readahead.cpp56 int num_ops = *pending_ops; in PrepareNextReadAhead() local
59 bool is_ops_present = (!RAIterDone() && num_ops); in PrepareNextReadAhead()
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()
164 << " Pending ops: " << num_ops; in ReconstructDataFromCow()
[all …]
/system/core/fs_mgr/libsnapshot/snapuserd/dm-snapshot-merge/
Dsnapuserd_readahead.cpp191 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()
284 << " Pending ops: " << num_ops; in ReconstructDataFromCow()
[all …]
Dsnapuserd.cpp387 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()
462 << " Number of replace/zero ops completed in this 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()
[all …]
Dsnapuserd_worker.cpp313 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()
/system/core/fs_mgr/libsnapshot/libsnapshot_cow/
Dcow_writer.cpp122 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 …]
Dinspect_cow.cpp135 std::cout << "Number of Ops: " << footer.op.num_ops << "\n"; in Inspect()
Dcow_reader.cpp286 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()
Dcow_api_test.cpp86 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()
/system/core/fs_mgr/libsnapshot/include/libsnapshot/
Dsnapshot_writer.h83 bool EmitSequenceData(size_t num_ops, const uint32_t* data) override;
118 bool EmitSequenceData(size_t num_ops, const uint32_t* data) override;
Dcow_writer.h87 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;
Dcow_format.h99 uint64_t num_ops; member
/system/nfc/src/nfc/tags/
Drw_main.cc80 rw_cb.stats.num_ops++; in rw_main_update_tx_stats()
149 rw_cb.stats.num_ops, rw_cb.stats.num_retries, rw_cb.stats.num_fail, in rw_main_log_stats()
/system/core/fs_mgr/libsnapshot/
Dsnapshot_writer.cpp140 bool CompressedSnapshotWriter::EmitSequenceData(size_t num_ops, const uint32_t* data) { in EmitSequenceData() argument
141 return cow_->AddSequenceData(num_ops, data); in EmitSequenceData()
Dsnapshot.cpp1388 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()
/system/update_engine/payload_consumer/
Dsnapshot_extent_writer_unittest.cc85 bool EmitSequenceData(size_t num_ops, const uint32_t* data) override { in EmitSequenceData() argument
/system/update_engine/payload_generator/
Ddelta_diff_utils.cc778 size_t num_ops = aops->size(); in DeltaMovedAndZeroBlocks() local
808 LOG(INFO) << "Produced " << (aops->size() - num_ops) << " operations for " in DeltaMovedAndZeroBlocks()
812 num_ops = aops->size(); in DeltaMovedAndZeroBlocks()
848 LOG(INFO) << "Produced " << (aops->size() - num_ops) << " operations for " in DeltaMovedAndZeroBlocks()
/system/nfc/src/nfc/include/
Drw_int.h622 uint32_t num_ops; /* Number of operations since activation */ member