Searched refs:io_state_ (Results 1 – 2 of 2) sorted by relevance
186 io_state_ = MERGE_IO_TRANSITION::MERGE_BEGIN; in InitiateMerge()202 cv.wait(lock, [this]() -> bool { return MergeInitiated() || IsMergeBeginError(io_state_); }); in WaitForMergeBegin()204 if (IsMergeBeginError(io_state_)) { in WaitForMergeBegin()205 SNAP_LOG(ERROR) << "WaitForMergeBegin failed with state: " << io_state_; in WaitForMergeBegin()210 return io_state_ == MERGE_IO_TRANSITION::MERGE_BEGIN || IsMergeBeginError(io_state_); in WaitForMergeBegin()213 if (IsMergeBeginError(io_state_)) { in WaitForMergeBegin()214 SNAP_LOG(ERROR) << "WaitForMergeBegin failed with state: " << io_state_; in WaitForMergeBegin()250 if (io_state_ != MERGE_IO_TRANSITION::IO_TERMINATED && in ReadAheadIOCompleted()251 io_state_ != MERGE_IO_TRANSITION::MERGE_FAILED) { in ReadAheadIOCompleted()252 io_state_ = MERGE_IO_TRANSITION::MERGE_BEGIN; in ReadAheadIOCompleted()[all …]
227 MERGE_IO_TRANSITION io_state_ = MERGE_IO_TRANSITION::INVALID; variable