Searched refs:blk_state (Results 1 – 2 of 2) sorted by relevance
558 MergeGroupState* blk_state = merge_blk_state_[ra_index].get(); in SetMergeCompleted() local560 std::lock_guard<std::mutex> lock(blk_state->m_lock); in SetMergeCompleted()562 CHECK(blk_state->merge_state_ == MERGE_GROUP_STATE::GROUP_MERGE_IN_PROGRESS); in SetMergeCompleted()563 CHECK(blk_state->num_ios_in_progress == 0); in SetMergeCompleted()567 blk_state->merge_state_ = MERGE_GROUP_STATE::GROUP_MERGE_COMPLETED; in SetMergeCompleted()575 MergeGroupState* blk_state = merge_blk_state_[ra_index].get(); in SetMergeInProgress() local577 std::unique_lock<std::mutex> lock(blk_state->m_lock); in SetMergeInProgress()582 if (blk_state->merge_state_ == MERGE_GROUP_STATE::GROUP_MERGE_IN_PROGRESS) { in SetMergeInProgress()586 CHECK(blk_state->merge_state_ == MERGE_GROUP_STATE::GROUP_MERGE_PENDING); in SetMergeInProgress()590 blk_state->merge_state_ = MERGE_GROUP_STATE::GROUP_MERGE_RA_READY; in SetMergeInProgress()[all …]
222 std::unique_ptr<MergeGroupState> blk_state = std::make_unique<MergeGroupState>( in ReadMetadata() local225 merge_blk_state_.push_back(std::move(blk_state)); in ReadMetadata()