Home
last modified time | relevance | path

Searched refs:new_block (Results 1 – 19 of 19) sorted by relevance

/aosp14/system/core/fs_mgr/libsnapshot/snapuserd/user-space-merge/
H A Dsnapuserd_readahead.cpp78 blocks.push_back(cow_op->new_block); in PrepareNextReadAhead()
106 blocks.push_back(op->new_block); in PrepareNextReadAhead()
364 bm->new_block = 0; in UpdateScratchMetadata()
375 bm->new_block = new_block; in UpdateScratchMetadata()
387 bm->new_block = 0; in UpdateScratchMetadata()
436 if (xor_op->new_block == new_block) { in ProcessXorData()
469 if (xor_op->new_block == new_block) { in ReadXorData()
541 bm->new_block = 0; in ReadAheadSyncIO()
561 if (xor_op->new_block == new_block) { in ReadAheadSyncIO()
589 bm->new_block = new_block; in ReadAheadSyncIO()
[all …]
H A Dsnapuserd_dm_user.cpp80 SNAP_LOG(ERROR) << "ProcessReplaceOp failed for block " << cow_op->new_block; in ProcessReplaceOp()
93 SNAP_LOG(DEBUG) << " ReadFromBaseDevice...: new-block: " << cow_op->new_block in ReadFromSourceDevice()
130 SNAP_LOG(ERROR) << "ProcessXorOp failed for block " << cow_op->new_block; in ProcessXorOp()
156 MERGE_GROUP_STATE state = snapuserd_->ProcessMergingBlock(cow_op->new_block, buffer); in ProcessOrderedOp()
163 << (cow_op->new_block >> SECTOR_SHIFT) in ProcessOrderedOp()
164 << " Block-number: " << cow_op->new_block; in ProcessOrderedOp()
165 if (!ReadDataFromBaseDevice(ChunkToSector(cow_op->new_block), BLOCK_SZ)) { in ProcessOrderedOp()
167 << (cow_op->new_block >> SECTOR_SHIFT) << " after merge-complete."; in ProcessOrderedOp()
182 snapuserd_->NotifyIOCompletion(cow_op->new_block); in ProcessOrderedOp()
H A Dsnapuserd_transitions.cpp588 void SnapshotHandler::NotifyIOCompletion(uint64_t new_block) { in NotifyIOCompletion() argument
589 auto it = block_to_ra_index_.find(new_block); in NotifyIOCompletion()
590 CHECK(it != block_to_ra_index_.end()) << " invalid block: " << new_block; in NotifyIOCompletion()
631 MERGE_GROUP_STATE SnapshotHandler::ProcessMergingBlock(uint64_t new_block, void* buffer) { in ProcessMergingBlock() argument
632 auto it = block_to_ra_index_.find(new_block); in ProcessMergingBlock()
659 if (!GetRABuffer(&lock, new_block, buffer)) { in ProcessMergingBlock()
H A Dsnapuserd_merge.cpp39 *source_offset = cow_op->new_block * BLOCK_SZ; in PrepareMerge()
54 uint64_t next_offset = op->new_block * BLOCK_SZ; in PrepareMerge()
104 SNAP_LOG(ERROR) << "Merge - ReplaceOp failed for block: " << cow_op->new_block; in MergeReplaceZeroOps()
H A Dsnapuserd_core.cpp207 chunk_vec_.push_back(std::make_pair(ChunkToSector(cow_op->new_block), cow_op)); in ReadMetadata()
211 block_to_ra_index_[cow_op->new_block] = ra_index; in ReadMetadata()
H A Dsnapuserd_core.h381 void NotifyIOCompletion(uint64_t new_block);
383 MERGE_GROUP_STATE ProcessMergingBlock(uint64_t new_block, void* buffer);
/aosp14/system/core/fs_mgr/libsnapshot/snapuserd/dm-snapshot-merge/
H A Dsnapuserd_readahead.cpp186 source_blocks_.insert(cow_op->new_block); in CheckOverlap()
206 blocks.push_back(cow_op->new_block); in PrepareReadAhead()
227 blocks.push_back(op->new_block); in PrepareReadAhead()
256 if (bm->new_block == 0 && bm->file_offset == 0) { in ReconstructDataFromCow()
262 read_ahead_buffer_map[bm->new_block] = bufptr; in ReconstructDataFromCow()
276 snapuserd_->SetFinalBlockMerged(op->new_block); in ReconstructDataFromCow()
323 bm->new_block = 0; in ReadAheadIOStart()
362 uint64_t new_block = blocks.back(); in ReadAheadIOStart() local
366 read_ahead_buffer_map[new_block] = bufptr; in ReadAheadIOStart()
371 bm->new_block = new_block; in ReadAheadIOStart()
[all …]
H A Dsnapuserd_worker.cpp99 SNAP_LOG(ERROR) << "ProcessReplaceOp failed for block " << cow_op->new_block; in ProcessReplaceOp()
112 SNAP_LOG(DEBUG) << " ReadFromBaseDevice...: new-block: " << cow_op->new_block in ReadFromBaseDevice()
134 if (!snapuserd_->GetReadAheadPopulatedBuffer(cow_op->new_block, buffer)) { in GetReadAheadPopulatedBuffer()
146 << " new_block: " << cow_op->new_block; in ProcessCopyOp()
502 if (read_ahead_buffer_map.find(cow_op->new_block) == read_ahead_buffer_map.end()) { in GetNumberOfMergedOps()
504 << " Block: " << cow_op->new_block << " not found in read-ahead cache" in GetNumberOfMergedOps()
511 if (cow_op->new_block == snapuserd_->GetFinalBlockMerged()) { in GetNumberOfMergedOps()
H A Dsnapuserd.cpp421 de->old_chunk = cow_op->new_block; in ReadMetadata()
519 if (dest_blocks.count(cow_op->new_block) || source_blocks.count(block_source) || in ReadMetadata()
531 source_blocks.insert(cow_op->new_block); in ReadMetadata()
532 prev_id = cow_op->new_block; in ReadMetadata()
546 de->old_chunk = cow_op->new_block; in ReadMetadata()
/aosp14/system/core/fs_mgr/libsnapshot/
H A Dsnapshot_reader_test.cpp65 std::string new_block = MakeNewBlockString(); in WriteCow() local
70 ASSERT_TRUE(writer->AddRawBlocks(5, new_block.data(), new_block.size())); in WriteCow()
151 std::string new_block = "This is a new block"; in MakeNewBlockString() local
152 new_block.resize(kBlockSize / 2, '*'); in MakeNewBlockString()
153 new_block.resize(kBlockSize, '!'); in MakeNewBlockString()
154 return new_block; in MakeNewBlockString()
H A Dsnapshot_writer.cpp117 bool CompressedSnapshotWriter::EmitCopy(uint64_t new_block, uint64_t old_block, in EmitCopy() argument
119 return cow_->AddCopy(new_block, old_block, num_blocks); in EmitCopy()
198 bool OnlineKernelSnapshotWriter::EmitCopy(uint64_t new_block, uint64_t old_block, in EmitCopy() argument
214 if (!EmitRawBlocks(new_block + i, buffer.data(), buffer.size())) { in EmitCopy()
H A Dsnapshot_reader.cpp97 if (op->new_block >= ops_.size()) { in SetCow()
98 ops_.resize(op->new_block + 1, nullptr); in SetCow()
100 ops_[op->new_block] = op; in SetCow()
/aosp14/system/core/fs_mgr/libsnapshot/libsnapshot_cow/
H A Dcow_api_test.cpp144 ASSERT_EQ(op->new_block, 10); in TEST_F()
156 ASSERT_EQ(op->new_block, 50); in TEST_F()
168 ASSERT_EQ(op->new_block, 51); in TEST_F()
178 ASSERT_EQ(op->new_block, 52); in TEST_F()
222 ASSERT_EQ(op->new_block, 10); in TEST_F()
234 ASSERT_EQ(op->new_block, 50); in TEST_F()
247 ASSERT_EQ(op->new_block, 51); in TEST_F()
257 ASSERT_EQ(op->new_block, 52); in TEST_F()
293 ASSERT_EQ(op->new_block, 50); in TEST_F()
478 ASSERT_EQ(op->new_block, 50); in TEST_F()
[all …]
H A Dcow_writer.cpp63 bool ICowWriter::AddCopy(uint64_t new_block, uint64_t old_block, uint64_t num_blocks) { in AddCopy() argument
67 if (!ValidateNewBlock(new_block + i)) { in AddCopy()
72 return EmitCopy(new_block, old_block, num_blocks); in AddCopy()
126 bool ICowWriter::ValidateNewBlock(uint64_t new_block) { in ValidateNewBlock() argument
127 if (options_.max_blocks && new_block >= options_.max_blocks.value()) { in ValidateNewBlock()
128 LOG(ERROR) << "New block " << new_block << " exceeds maximum block count " in ValidateNewBlock()
423 bool CowWriter::EmitCopy(uint64_t new_block, uint64_t old_block, uint64_t num_blocks) { in EmitCopy() argument
429 op.new_block = new_block + i; in EmitCopy()
512 op.new_block = new_block_start + i; in EmitBlocks()
562 op.new_block = new_block_start + i; in EmitZeroBlocks()
H A Dcow_reader.cpp215 data_loc->insert({current_op.new_block, data_pos}); in ParseOps()
449 merge_op_blocks->emplace_back(current_op.new_block); in PrepMergeOps()
450 } else if (seq_ops_set.count(current_op.new_block) == 0) { in PrepMergeOps()
451 other_ops.push_back(current_op.new_block); in PrepMergeOps()
453 block_map->insert({current_op.new_block, i}); in PrepMergeOps()
541 overwritten_blocks[op.new_block] = op; in VerifyMergeOps()
795 offset = data_loc_->at(op.new_block); in ReadData()
H A Dcow_format.cpp58 os << "new_block:" << op.new_block << ",\t"; in operator <<()
/aosp14/system/core/fs_mgr/libsnapshot/include/libsnapshot/
H A Dcow_writer.h71 bool AddCopy(uint64_t new_block, uint64_t old_block, uint64_t num_blocks = 1);
102 virtual bool EmitCopy(uint64_t new_block, uint64_t old_block, uint64_t num_blocks = 1) = 0;
110 bool ValidateNewBlock(uint64_t new_block);
177 virtual bool EmitCopy(uint64_t new_block, uint64_t old_block, uint64_t num_blocks = 1) override;
H A Dcow_format.h125 uint64_t new_block; member
177 uint64_t new_block; member
H A Dsnapshot_writer.h77 bool EmitCopy(uint64_t new_block, uint64_t old_block, uint64_t num_blocks = 1) override;
116 bool EmitCopy(uint64_t new_block, uint64_t old_block, uint64_t num_blocks = 1) override;