Searched refs:blk_state (Results 1 – 2 of 2) sorted by relevance
532 MergeGroupState* blk_state = merge_blk_state_[ra_index].get(); in SetMergeCompleted() local534 std::lock_guard<std::mutex> lock(blk_state->m_lock); in SetMergeCompleted()536 CHECK(blk_state->merge_state_ == MERGE_GROUP_STATE::GROUP_MERGE_IN_PROGRESS); in SetMergeCompleted()537 CHECK(blk_state->num_ios_in_progress == 0); in SetMergeCompleted()541 blk_state->merge_state_ = MERGE_GROUP_STATE::GROUP_MERGE_COMPLETED; in SetMergeCompleted()549 MergeGroupState* blk_state = merge_blk_state_[ra_index].get(); in SetMergeInProgress() local551 std::unique_lock<std::mutex> lock(blk_state->m_lock); in SetMergeInProgress()556 if (blk_state->merge_state_ == MERGE_GROUP_STATE::GROUP_MERGE_IN_PROGRESS) { in SetMergeInProgress()560 CHECK(blk_state->merge_state_ == MERGE_GROUP_STATE::GROUP_MERGE_PENDING); in SetMergeInProgress()564 blk_state->merge_state_ = MERGE_GROUP_STATE::GROUP_MERGE_RA_READY; in SetMergeInProgress()[all …]
215 std::unique_ptr<MergeGroupState> blk_state = std::make_unique<MergeGroupState>( in ReadMetadata() local218 merge_blk_state_.push_back(std::move(blk_state)); in ReadMetadata()