Home
last modified time | relevance | path

Searched refs:snapuserd_ (Results 1 – 12 of 12) sorted by relevance

/aosp14/system/core/fs_mgr/libsnapshot/snapuserd/user-space-merge/
H A Dsnapuserd_merge.cpp150 if (snapuserd_->IsIOTerminated()) { in MergeReplaceZeroOps()
336 if (!snapuserd_->CommitMerge(snapuserd_->GetTotalBlocksToMerge())) { in MergeOrderedOpsAsync()
348 snapuserd_->NotifyRAForMergeReady(); in MergeOrderedOpsAsync()
421 if (!snapuserd_->CommitMerge(snapuserd_->GetTotalBlocksToMerge())) { in MergeOrderedOps()
433 snapuserd_->NotifyRAForMergeReady(); in MergeOrderedOps()
497 snapuserd_->MergeFailed(); in Merge()
505 snapuserd_->MergeFailed(); in Merge()
509 snapuserd_->MergeCompleted(); in Merge()
515 if (!snapuserd_->IsIouringSupported()) { in InitializeIouring()
541 if (!snapuserd_->WaitForMergeBegin()) { in RunMergeThread()
[all …]
H A Dsnapuserd_readahead.cpp31 snapuserd_ = snapuserd; in ReadAhead()
165 snapuserd_->ReadAheadIOFailed(); in ReconstructDataFromCow()
174 snapuserd_->FinishReconstructDataFromCow(); in ReconstructDataFromCow()
176 if (!snapuserd_->ReadAheadIOCompleted(true)) { in ReconstructDataFromCow()
178 snapuserd_->ReadAheadIOFailed(); in ReconstructDataFromCow()
522 snapuserd_->ReadAheadIOFailed(); in ReadAheadSyncIO()
566 snapuserd_->ReadAheadIOFailed(); in ReadAheadSyncIO()
654 if (!snapuserd_->WaitForMergeReady()) { in ReadAheadIOStart()
681 snapuserd_->ReadAheadIOFailed(); in ReadAheadIOStart()
689 if (!snapuserd_->IsIouringSupported()) { in InitializeIouring()
[all …]
H A Dsnapuserd_server.h65 if (snapuserd_) { in FreeResources()
66 snapuserd_->FreeResources(); in FreeResources()
67 snapuserd_ = nullptr; in FreeResources()
70 const std::shared_ptr<SnapshotHandler>& snapuserd() const { return snapuserd_; } in snapuserd()
79 std::shared_ptr<SnapshotHandler> snapuserd_; variable
H A Dsnapuserd_dm_user.cpp34 snapuserd_ = snapuserd; in Worker()
67 reader_ = snapuserd_->CloneReaderForWorker(); in InitReader()
156 MERGE_GROUP_STATE state = snapuserd_->ProcessMergingBlock(cow_op->new_block, buffer); in ProcessOrderedOp()
182 snapuserd_->NotifyIOCompletion(cow_op->new_block); in ProcessOrderedOp()
328 std::vector<std::pair<sector_t, const CowOperation*>>& chunk_vec = snapuserd_->GetChunkVec(); in ReadAlignedSector()
442 std::vector<std::pair<sector_t, const CowOperation*>>& chunk_vec = snapuserd_->GetChunkVec(); in ReadUnalignedSector()
H A Dsnapuserd_core.h150 std::shared_ptr<SnapshotHandler> snapuserd_; variable
298 std::shared_ptr<SnapshotHandler> snapuserd_; variable
H A Dsnapuserd_server.cpp106 : snapuserd_(snapuserd), misc_name_(snapuserd_->GetMiscName()) {} in HandlerThread()
/aosp14/system/core/fs_mgr/libsnapshot/snapuserd/dm-snapshot-merge/
H A Dsnapuserd_readahead.cpp171 snapuserd_ = snapuserd; in ReadAheadThread()
285 snapuserd_->ReadAheadIOFailed(); in ReconstructDataFromCow()
294 snapuserd_->ReconstructDataFromCowFinish(); in ReconstructDataFromCow()
296 if (!snapuserd_->ReadAheadIOCompleted(true)) { in ReconstructDataFromCow()
298 snapuserd_->ReadAheadIOFailed(); in ReconstructDataFromCow()
310 if (snapuserd_->ReconstructDataFromCow()) { in ReadAheadIOStart()
390 snapuserd_->ReadAheadIOFailed(); in ReadAheadIOStart()
407 if (!snapuserd_->ReadAheadIOCompleted(overlap_)) { in ReadAheadIOStart()
409 snapuserd_->ReadAheadIOFailed(); in ReadAheadIOStart()
431 if (status && !snapuserd_->CommitMerge(snapuserd_->GetTotalRaBlocksMerged())) { in RunThread()
[all …]
H A Dsnapuserd_server.h57 if (snapuserd_) { in FreeResources()
58 snapuserd_->FreeResources(); in FreeResources()
59 snapuserd_ = nullptr; in FreeResources()
62 const std::shared_ptr<Snapuserd>& snapuserd() const { return snapuserd_; } in snapuserd()
69 std::shared_ptr<Snapuserd> snapuserd_; variable
H A Dsnapuserd_worker.cpp42 snapuserd_ = snapuserd; in WorkerThread()
69 reader_ = snapuserd_->CloneReaderForWorker(); in InitReader()
134 if (!snapuserd_->GetReadAheadPopulatedBuffer(cow_op->new_block, buffer)) { in GetReadAheadPopulatedBuffer()
239 std::vector<std::pair<sector_t, const CowOperation*>>& chunk_vec = snapuserd_->GetChunkVec(); in ReadData()
389 const std::vector<std::unique_ptr<uint8_t[]>>& vec = snapuserd_->GetMetadataVec(); in ReadDiskExceptions()
459 std::unordered_map<uint64_t, void*>& read_ahead_buffer_map = snapuserd_->GetReadAheadMap(); in GetNumberOfMergedOps()
498 if (snapuserd_->IsReadAheadFeaturePresent() && IsOrderedOp(*cow_op)) { in GetNumberOfMergedOps()
511 if (cow_op->new_block == snapuserd_->GetFinalBlockMerged()) { in GetNumberOfMergedOps()
543 const std::vector<std::unique_ptr<uint8_t[]>>& vec = snapuserd_->GetMetadataVec(); in ProcessMergeComplete()
581 snapuserd_->StartReadAhead(); in ProcessMergeComplete()
[all …]
H A Dsnapuserd.h129 std::shared_ptr<Snapuserd> snapuserd_; variable
203 std::shared_ptr<Snapuserd> snapuserd_; variable
H A Dcow_snapuserd_test.cpp170 std::unique_ptr<Snapuserd> snapuserd_; member in android::snapshot::CowSnapuserdMetadataTest
931 int area_sz = snapuserd_->GetMetadataAreaSize(); in ValidatePartialFilledArea()
936 void* buffer = snapuserd_->GetExceptionBuffer(1); in ValidatePartialFilledArea()
1022 snapuserd_ = std::make_unique<Snapuserd>("", cow_system_->path, ""); in InitMetadata()
1023 ASSERT_TRUE(snapuserd_->InitCowDevice()); in InitMetadata()
1032 int area_sz = snapuserd_->GetMetadataAreaSize(); in ValidateMetadata()
1039 void* buffer = snapuserd_->GetExceptionBuffer(i); in ValidateMetadata()
H A Dsnapuserd_server.cpp94 : snapuserd_(snapuserd), misc_name_(snapuserd_->GetMiscName()) {} in DmUserHandler()