Home
last modified time | relevance | path

Searched refs:cow_op (Results 1 – 7 of 7) sorted by relevance

/system/update_engine/common/
Dcow_operation_convert_unittest.cc64 for (auto&& cow_op : cow_ops) { in VerifyCowMergeOp()
65 if (cow_op.op == CowOperation::CowCopy) { in VerifyCowMergeOp()
66 EXPECT_TRUE(src_extent_set.ContainsBlock(cow_op.src_block)); in VerifyCowMergeOp()
68 EXPECT_FALSE(modified_extents.ContainsBlock(cow_op.src_block)) in VerifyCowMergeOp()
69 << "SOURCE_COPY operation " << cow_op in VerifyCowMergeOp()
72 EXPECT_TRUE(dst_extent_set.ContainsBlock(cow_op.dst_block)); in VerifyCowMergeOp()
73 dst_extent_set.SubtractExtent(ExtentForRange(cow_op.dst_block, 1)); in VerifyCowMergeOp()
74 modified_extents.AddBlock(cow_op.dst_block); in VerifyCowMergeOp()
127 ASSERT_TRUE(std::all_of(cow_ops.begin(), cow_ops.end(), [](auto&& cow_op) { in TEST_F() argument
128 return cow_op.op == CowOperation::CowCopy; in TEST_F()
[all …]
/system/update_engine/payload_consumer/
Dvabc_partition_writer.cc104 for (const auto& cow_op : converted) { in WriteAllCowOps() local
105 switch (cow_op.op) { in WriteAllCowOps()
107 if (cow_op.src_block == cow_op.dst_block) { in WriteAllCowOps()
111 cow_writer->AddCopy(cow_op.dst_block, cow_op.src_block)); in WriteAllCowOps()
118 cow_op.src_block * block_size, in WriteAllCowOps()
125 cow_op.dst_block, buffer.data(), block_size)); in WriteAllCowOps()
/system/update_engine/payload_generator/
Dcow_size_estimator.cc73 for (const auto& cow_op : converted) { in WriteAllCowOps() local
74 switch (cow_op.op) { in WriteAllCowOps()
76 if (cow_op.src_block == cow_op.dst_block) { in WriteAllCowOps()
80 cow_writer->AddCopy(cow_op.dst_block, cow_op.src_block)); in WriteAllCowOps()
88 cow_op.dst_block * block_size, in WriteAllCowOps()
95 cow_op.dst_block, buffer.data(), block_size)); in WriteAllCowOps()
/system/core/fs_mgr/libsnapshot/
Dsnapuserd_worker.cpp136 bool WorkerThread::ProcessReplaceOp(const CowOperation* cow_op) { in ProcessReplaceOp() argument
137 if (!reader_->ReadData(*cow_op, &bufsink_)) { in ProcessReplaceOp()
138 SNAP_LOG(ERROR) << "ProcessReplaceOp failed for block " << cow_op->new_block; in ProcessReplaceOp()
145 bool WorkerThread::ReadFromBaseDevice(const CowOperation* cow_op) { in ReadFromBaseDevice() argument
151 SNAP_LOG(DEBUG) << " ReadFromBaseDevice...: new-block: " << cow_op->new_block in ReadFromBaseDevice()
152 << " Source: " << cow_op->source; in ReadFromBaseDevice()
154 cow_op->source * BLOCK_SZ)) { in ReadFromBaseDevice()
156 << "at block :" << cow_op->source; in ReadFromBaseDevice()
163 bool WorkerThread::GetReadAheadPopulatedBuffer(const CowOperation* cow_op) { in GetReadAheadPopulatedBuffer() argument
170 if (!snapuserd_->GetReadAheadPopulatedBuffer(cow_op->new_block, buffer)) { in GetReadAheadPopulatedBuffer()
[all …]
Dsnapuserd.cpp383 const CowOperation* cow_op = &cowop_riter_->Get(); in ReadMetadata() local
387 if (IsMetadataOp(*cow_op)) { in ReadMetadata()
398 if (cow_op->type == kCowCopyOp) { in ReadMetadata()
403 if (cow_op->type == kCowReplaceOp) { in ReadMetadata()
405 } else if (cow_op->type == kCowZeroOp) { in ReadMetadata()
410 de->old_chunk = cow_op->new_block; in ReadMetadata()
415 chunk_vec_.push_back(std::make_pair(ChunkToSector(data_chunk_id), cow_op)); in ReadMetadata()
456 const CowOperation* cow_op = &cowop_riter_->Get(); in ReadMetadata() local
457 if (IsMetadataOp(*cow_op)) { in ReadMetadata()
510 if (dest_blocks.count(cow_op->new_block) || source_blocks.count(cow_op->source)) { in ReadMetadata()
[all …]
Dsnapuserd_readahead.cpp174 void ReadAheadThread::CheckOverlap(const CowOperation* cow_op) { in CheckOverlap() argument
175 if (dest_blocks_.count(cow_op->new_block) || source_blocks_.count(cow_op->source)) { in CheckOverlap()
179 dest_blocks_.insert(cow_op->source); in CheckOverlap()
180 source_blocks_.insert(cow_op->new_block); in CheckOverlap()
190 const CowOperation* cow_op = GetIterOp(); in PrepareReadAhead() local
191 *source_block = cow_op->source; in PrepareReadAhead()
195 blocks.push_back(cow_op->new_block); in PrepareReadAhead()
198 CheckOverlap(cow_op); in PrepareReadAhead()
Dsnapuserd.h134 void CheckOverlap(const CowOperation* cow_op);
188 bool ProcessCowOp(const CowOperation* cow_op);
189 bool ProcessReplaceOp(const CowOperation* cow_op);
190 bool ProcessCopyOp(const CowOperation* cow_op);
193 bool ReadFromBaseDevice(const CowOperation* cow_op);
194 bool GetReadAheadPopulatedBuffer(const CowOperation* cow_op);