Lines Matching refs:error_handler_

40         sfm->EnoughRoomForCompaction(cfd, inputs, error_handler_.GetBGError());  in EnoughRoomForCompaction()
129 error_handler_.SetBGError(io_s, BackgroundErrorReason::kFlush); in SyncClosedLogs()
213 error_handler_.SetBGError(io_s, BackgroundErrorReason::kFlush); in FlushMemTableToOutputFile()
216 error_handler_.SetBGError(new_bg_error, BackgroundErrorReason::kFlush); in FlushMemTableToOutputFile()
237 error_handler_.SetBGError(new_bg_error, BackgroundErrorReason::kFlush); in FlushMemTableToOutputFile()
497 bool resuming_from_bg_err = error_handler_.IsDBStopped(); in AtomicFlushMemTablesToOutputFiles()
498 while ((!error_handler_.IsDBStopped() || in AtomicFlushMemTablesToOutputFiles()
499 error_handler_.GetRecoveryError().ok()) && in AtomicFlushMemTablesToOutputFiles()
504 s = resuming_from_bg_err ? error_handler_.GetRecoveryError() in AtomicFlushMemTablesToOutputFiles()
505 : error_handler_.GetBGError(); in AtomicFlushMemTablesToOutputFiles()
562 error_handler_.GetBGError().ok()) { in AtomicFlushMemTablesToOutputFiles()
565 error_handler_.SetBGError(new_bg_error, in AtomicFlushMemTablesToOutputFiles()
577 error_handler_.SetBGError(io_s, BackgroundErrorReason::kFlush); in AtomicFlushMemTablesToOutputFiles()
580 error_handler_.SetBGError(new_bg_error, BackgroundErrorReason::kFlush); in AtomicFlushMemTablesToOutputFiles()
1030 &error_handler_, snapshot_seqs, earliest_write_conflict_snapshot, in CompactFilesImpl()
1091 error_handler_.SetBGError(status, BackgroundErrorReason::kCompaction); in CompactFilesImpl()
1812 if (error_handler_.IsBGWorkStopped()) { in WaitUntilFlushWouldNotStallWrites()
1813 return error_handler_.GetBGError(); in WaitUntilFlushWouldNotStallWrites()
1886 while (resuming_from_bg_err || !error_handler_.IsDBStopped()) { in WaitForFlushMemTables()
1891 if (!error_handler_.GetRecoveryError().ok()) { in WaitForFlushMemTables()
1921 if (!resuming_from_bg_err && error_handler_.IsDBStopped()) { in WaitForFlushMemTables()
1922 s = error_handler_.GetBGError(); in WaitForFlushMemTables()
1958 } else if (error_handler_.IsBGWorkStopped() && in MaybeScheduleFlushOrCompaction()
1959 !error_handler_.IsRecoveryInProgress()) { in MaybeScheduleFlushOrCompaction()
2004 } else if (error_handler_.IsBGWorkStopped()) { in MaybeScheduleFlushOrCompaction()
2208 if (!error_handler_.IsBGWorkStopped()) { in BackgroundFlush()
2212 } else if (!error_handler_.IsRecoveryInProgress()) { in BackgroundFlush()
2213 status = error_handler_.GetBGError(); in BackgroundFlush()
2502 if (!error_handler_.IsBGWorkStopped()) { in BackgroundCompaction()
2510 status = error_handler_.GetBGError(); in BackgroundCompaction()
2821 &mutex_, &error_handler_, snapshot_seqs, in BackgroundCompaction()
2881 error_handler_.SetBGError(io_s, BackgroundErrorReason::kCompaction); in BackgroundCompaction()
2883 error_handler_.SetBGError(status, BackgroundErrorReason::kCompaction); in BackgroundCompaction()
2885 if (c != nullptr && !is_manual && !error_handler_.IsBGWorkStopped()) { in BackgroundCompaction()