Searched refs:MERGE_GROUP_STATE (Results 1 – 4 of 4) sorted by relevance
560 CHECK(blk_state->merge_state_ == MERGE_GROUP_STATE::GROUP_MERGE_IN_PROGRESS); in SetMergeCompleted()565 blk_state->merge_state_ = MERGE_GROUP_STATE::GROUP_MERGE_COMPLETED; in SetMergeCompleted()580 if (blk_state->merge_state_ == MERGE_GROUP_STATE::GROUP_MERGE_IN_PROGRESS) { in SetMergeInProgress()584 CHECK(blk_state->merge_state_ == MERGE_GROUP_STATE::GROUP_MERGE_PENDING); in SetMergeInProgress()588 blk_state->merge_state_ = MERGE_GROUP_STATE::GROUP_MERGE_RA_READY; in SetMergeInProgress()595 blk_state->merge_state_ = MERGE_GROUP_STATE::GROUP_MERGE_IN_PROGRESS; in SetMergeInProgress()605 blk_state->merge_state_ = MERGE_GROUP_STATE::GROUP_MERGE_FAILED; in SetMergeFailed()654 MERGE_GROUP_STATE SnapshotHandler::ProcessMergingBlock(uint64_t new_block, void* buffer) { in ProcessMergingBlock()657 return MERGE_GROUP_STATE::GROUP_INVALID; in ProcessMergingBlock()665 MERGE_GROUP_STATE state = blk_state->merge_state_; in ProcessMergingBlock()[all …]
82 enum class MERGE_GROUP_STATE { enum92 MERGE_GROUP_STATE merge_state_;99 MergeGroupState(MERGE_GROUP_STATE state, size_t n_ios) in MergeGroupState()184 MERGE_GROUP_STATE ProcessMergingBlock(uint64_t new_block, void* buffer);
133 MERGE_GROUP_STATE state = snapuserd_->ProcessMergingBlock(cow_op->new_block, buffer); in ProcessOrderedOp()136 case MERGE_GROUP_STATE::GROUP_MERGE_COMPLETED: { in ProcessOrderedOp()149 case MERGE_GROUP_STATE::GROUP_MERGE_PENDING: { in ProcessOrderedOp()164 case MERGE_GROUP_STATE::GROUP_MERGE_RA_READY: { in ProcessOrderedOp()167 case MERGE_GROUP_STATE::GROUP_MERGE_IN_PROGRESS: { in ProcessOrderedOp()
222 MERGE_GROUP_STATE::GROUP_MERGE_PENDING, 0); in ReadMetadata()