Searched refs:blk_state (Results 1 – 2 of 2) sorted by relevance
534 std::lock_guard<std::mutex> lock(blk_state->m_lock); in SetMergeCompleted()537 CHECK(blk_state->num_ios_in_progress == 0); in SetMergeCompleted()551 std::unique_lock<std::mutex> lock(blk_state->m_lock); in SetMergeInProgress()567 while (!(blk_state->num_ios_in_progress == 0)) { in SetMergeInProgress()568 blk_state->m_cv.wait(lock); in SetMergeInProgress()579 std::unique_lock<std::mutex> lock(blk_state->m_lock); in SetMergeFailed()597 std::unique_lock<std::mutex> lock(blk_state->m_lock); in NotifyIOCompletion()599 blk_state->num_ios_in_progress -= 1; in NotifyIOCompletion()600 if (blk_state->num_ios_in_progress == 0) { in NotifyIOCompletion()608 blk_state->m_cv.notify_all(); in NotifyIOCompletion()[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()