Searched refs:error_handler_ (Results 1 – 8 of 8) sorted by relevance
498 while ((!error_handler_.IsDBStopped() || in AtomicFlushMemTablesToOutputFiles()562 error_handler_.GetBGError().ok()) { in AtomicFlushMemTablesToOutputFiles()565 error_handler_.SetBGError(new_bg_error, in AtomicFlushMemTablesToOutputFiles()1812 if (error_handler_.IsBGWorkStopped()) { in WaitUntilFlushWouldNotStallWrites()1813 return error_handler_.GetBGError(); in WaitUntilFlushWouldNotStallWrites()1922 s = error_handler_.GetBGError(); in WaitForFlushMemTables()1958 } else if (error_handler_.IsBGWorkStopped() && in MaybeScheduleFlushOrCompaction()2208 if (!error_handler_.IsBGWorkStopped()) { in BackgroundFlush()2213 status = error_handler_.GetBGError(); in BackgroundFlush()2502 if (!error_handler_.IsBGWorkStopped()) { in BackgroundCompaction()[all …]
682 if (error_handler_.IsDBStopped()) { in WriteImplWALOnly()683 status = error_handler_.GetBGError(); in WriteImplWALOnly()862 assert(!error_handler_.IsBGWorkStopped()); in MemTableInsertStatusCheck()863 error_handler_.SetBGError(status, BackgroundErrorReason::kMemTable); in MemTableInsertStatusCheck()875 if (error_handler_.IsDBStopped()) { in PreprocessWrite()876 status = error_handler_.GetBGError(); in PreprocessWrite()1467 s = Status::Incomplete(error_handler_.GetBGError().ToString()); in DelayWrite()1469 if (error_handler_.IsDBStopped()) { in DelayWrite()1470 s = error_handler_.GetBGError(); in DelayWrite()1747 error_handler_.SetBGError(s, BackgroundErrorReason::kMemTable); in SwitchMemtable()[all …]
172 (error_handler_.GetBGError() == Status::OK())) { in TEST_WaitForCompact()175 return error_handler_.GetBGError(); in TEST_WaitForCompact()
268 if (!error_handler_.IsDBStopped() && !error_handler_.IsBGWorkStopped()) { in Resume()273 if (error_handler_.IsRecoveryInProgress()) { in Resume()300 Status bg_error = error_handler_.GetBGError(); in ResumeImpl()356 s = error_handler_.ClearBGError(); in ResumeImpl()448 error_handler_.CancelErrorRecovery(); in CloseHelper()449 while (error_handler_.IsRecoveryInProgress()) { in CloseHelper()472 error_handler_.IsRecoveryInProgress()) { in CloseHelper()4308 if (error_handler_.IsDBStopped()) { in CreateColumnFamilyWithImport()4310 status = error_handler_.GetBGError(); in CreateColumnFamilyWithImport()4548 if (error_handler_.IsDBStopped()) { in ReserveFileNumbersBeforeIngestion()[all …]
1412 impl->error_handler_.EnableAutoRecovery(); in Open()
2093 ErrorHandler error_handler_; variable
88 error_handler_(nullptr, db_options_, &mutex_) { in CompactionJobTest()332 nullptr, nullptr, &mutex_, &error_handler_, snapshots,385 ErrorHandler error_handler_; member in ROCKSDB_NAMESPACE::CompactionJobTest
4945 ASSERT_OK(dbfull()->error_handler_.GetBGError()); in TEST_F()