Searched refs:blk_state (Results 1 – 2 of 2) sorted by relevance
556 MergeGroupState* blk_state = merge_blk_state_[ra_index].get(); in SetMergeCompleted() local558 std::lock_guard<std::mutex> lock(blk_state->m_lock); in SetMergeCompleted()560 CHECK(blk_state->merge_state_ == MERGE_GROUP_STATE::GROUP_MERGE_IN_PROGRESS); in SetMergeCompleted()561 CHECK(blk_state->num_ios_in_progress == 0); in SetMergeCompleted()565 blk_state->merge_state_ = MERGE_GROUP_STATE::GROUP_MERGE_COMPLETED; in SetMergeCompleted()573 MergeGroupState* blk_state = merge_blk_state_[ra_index].get(); in SetMergeInProgress() local575 std::unique_lock<std::mutex> lock(blk_state->m_lock); in SetMergeInProgress()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()[all …]
221 std::unique_ptr<MergeGroupState> blk_state = std::make_unique<MergeGroupState>( in ReadMetadata() local224 merge_blk_state_.push_back(std::move(blk_state)); in ReadMetadata()