Searched refs:blk_state (Results 1 – 2 of 2) sorted by relevance
595 MergeGroupState* blk_state = merge_blk_state_[ra_index].get(); in SetMergeCompleted() local597 std::lock_guard<std::mutex> lock(blk_state->m_lock); in SetMergeCompleted()599 CHECK(blk_state->merge_state_ == MERGE_GROUP_STATE::GROUP_MERGE_IN_PROGRESS); in SetMergeCompleted()600 CHECK(blk_state->num_ios_in_progress == 0); in SetMergeCompleted()604 blk_state->merge_state_ = MERGE_GROUP_STATE::GROUP_MERGE_COMPLETED; in SetMergeCompleted()612 MergeGroupState* blk_state = merge_blk_state_[ra_index].get(); in SetMergeInProgress() local614 std::unique_lock<std::mutex> lock(blk_state->m_lock); in SetMergeInProgress()619 if (blk_state->merge_state_ == MERGE_GROUP_STATE::GROUP_MERGE_IN_PROGRESS) { in SetMergeInProgress()623 CHECK(blk_state->merge_state_ == MERGE_GROUP_STATE::GROUP_MERGE_PENDING); in SetMergeInProgress()627 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()