Lines Matching refs:status
103 Status status; in WriteImpl() local
106 status = ThrottleLowPriWritesIfNeeded(write_options, my_batch); in WriteImpl()
107 if (!status.ok()) { in WriteImpl()
108 return status; in WriteImpl()
131 status = WriteImplWALOnly(&write_thread_, write_options, my_batch, callback, in WriteImpl()
136 if (!status.ok()) { in WriteImpl()
137 return status; in WriteImpl()
144 status = UnorderedWriteMemtable(write_options, my_batch, callback, in WriteImpl()
147 return status; in WriteImpl()
175 w.status = WriteBatchInternal::InsertInto( in WriteImpl()
190 MemTableInsertStatusCheck(w.status); in WriteImpl()
196 status = w.FinalStatus(); in WriteImpl()
232 status = PreprocessWrite(write_options, &need_log_sync, &write_context); in WriteImpl()
254 if (status.ok()) { in WriteImpl()
324 if (status.ok() && !write_options.disableWAL) { in WriteImpl()
330 if (status.ok() && !write_options.disableWAL) { in WriteImpl()
341 status = io_s; in WriteImpl()
347 if (status.ok()) { in WriteImpl()
364 status = ws; in WriteImpl()
377 if (status.ok()) { in WriteImpl()
382 w.status = WriteBatchInternal::InsertInto( in WriteImpl()
399 w.status = WriteBatchInternal::InsertInto( in WriteImpl()
419 WriteStatusCheck(status); in WriteImpl()
425 MarkLogsSynced(logfile_number_, need_log_dir_sync, status); in WriteImpl()
431 status = FlushWAL(true); in WriteImpl()
433 status = SyncWAL(); in WriteImpl()
445 if (status.ok()) { in WriteImpl()
450 MemTableInsertStatusCheck(w.status); in WriteImpl()
451 write_thread_.ExitAsBatchGroupLeader(write_group, status); in WriteImpl()
454 if (status.ok()) { in WriteImpl()
455 status = w.FinalStatus(); in WriteImpl()
457 return status; in WriteImpl()
482 w.status = PreprocessWrite(write_options, &need_log_sync, &write_context); in PipelinedWriteImpl()
495 if (w.status.ok()) { in PipelinedWriteImpl()
525 if (w.status.ok() && !write_options.disableWAL) { in PipelinedWriteImpl()
536 w.status = io_s; in PipelinedWriteImpl()
543 WriteStatusCheck(w.status); in PipelinedWriteImpl()
549 MarkLogsSynced(logfile_number_, need_log_dir_sync, w.status); in PipelinedWriteImpl()
553 write_thread_.ExitAsBatchGroupLeader(wal_write_group, w.status); in PipelinedWriteImpl()
565 memtable_write_group.status = WriteBatchInternal::InsertInto( in PipelinedWriteImpl()
579 w.status = WriteBatchInternal::InsertInto( in PipelinedWriteImpl()
586 MemTableInsertStatusCheck(w.status); in PipelinedWriteImpl()
619 w.status = WriteBatchInternal::InsertInto( in UnorderedWriteMemtable()
626 WriteStatusCheck(w.status); in UnorderedWriteMemtable()
657 Status status; in WriteImplWALOnly() local
683 status = error_handler_.GetBGError(); in WriteImplWALOnly()
687 if (status.ok()) { in WriteImplWALOnly()
690 status = PreprocessWrite(write_options, &need_log_sync, &write_context); in WriteImplWALOnly()
691 WriteStatusCheck(status); in WriteImplWALOnly()
693 if (!status.ok()) { in WriteImplWALOnly()
696 write_thread->ExitAsBatchGroupLeader(write_group, status); in WriteImplWALOnly()
697 return status; in WriteImplWALOnly()
758 status = io_s; in WriteImplWALOnly()
780 if (status.ok() && write_options.sync) { in WriteImplWALOnly()
785 status = FlushWAL(true); in WriteImplWALOnly()
787 status = SyncWAL(); in WriteImplWALOnly()
796 WriteStatusCheck(status); in WriteImplWALOnly()
799 if (status.ok()) { in WriteImplWALOnly()
808 status = ws; in WriteImplWALOnly()
819 if (immutable_db_options_.unordered_write && status.ok()) { in WriteImplWALOnly()
822 write_thread->ExitAsBatchGroupLeader(write_group, status); in WriteImplWALOnly()
823 if (status.ok()) { in WriteImplWALOnly()
824 status = w.FinalStatus(); in WriteImplWALOnly()
829 return status; in WriteImplWALOnly()
832 void DBImpl::WriteStatusCheck(const Status& status) { in WriteStatusCheck() argument
835 if (immutable_db_options_.paranoid_checks && !status.ok() && in WriteStatusCheck()
836 !status.IsBusy() && !status.IsIncomplete()) { in WriteStatusCheck()
838 error_handler_.SetBGError(status, BackgroundErrorReason::kWriteCallback); in WriteStatusCheck()
854 void DBImpl::MemTableInsertStatusCheck(const Status& status) { in MemTableInsertStatusCheck() argument
860 if (!status.ok()) { in MemTableInsertStatusCheck()
863 error_handler_.SetBGError(status, BackgroundErrorReason::kMemTable); in MemTableInsertStatusCheck()
873 Status status; in PreprocessWrite() local
876 status = error_handler_.GetBGError(); in PreprocessWrite()
883 if (UNLIKELY(status.ok() && !single_column_family_mode_ && in PreprocessWrite()
886 status = SwitchWAL(write_context); in PreprocessWrite()
889 if (UNLIKELY(status.ok() && write_buffer_manager_->ShouldFlush())) { in PreprocessWrite()
896 status = HandleWriteBufferFull(write_context); in PreprocessWrite()
899 if (UNLIKELY(status.ok() && !trim_history_scheduler_.Empty())) { in PreprocessWrite()
900 status = TrimMemtableHistory(write_context); in PreprocessWrite()
903 if (UNLIKELY(status.ok() && !flush_scheduler_.Empty())) { in PreprocessWrite()
905 status = ScheduleFlushes(write_context); in PreprocessWrite()
911 if (UNLIKELY(status.ok() && (write_controller_.IsStopped() || in PreprocessWrite()
919 status = DelayWrite(last_batch_group_size_, write_options); in PreprocessWrite()
923 if (status.ok() && *need_log_sync) { in PreprocessWrite()
947 return status; in PreprocessWrite()
1158 auto status = WriteBatchInternal::InsertInto( in WriteRecoverableState() local
1172 if (status.ok() && recoverable_state_pre_release_callback_) { in WriteRecoverableState()
1175 sub_batch_seq < next_seq && status.ok(); sub_batch_seq++) { in WriteRecoverableState()
1180 status = recoverable_state_pre_release_callback_->Callback( in WriteRecoverableState()
1185 if (status.ok()) { in WriteRecoverableState()
1189 return status; in WriteRecoverableState()
1219 Status status; in SwitchWAL() local
1222 return status; in SwitchWAL()
1239 return status; in SwitchWAL()
1286 status = SwitchMemtable(cfd, write_context); in SwitchWAL()
1288 if (!status.ok()) { in SwitchWAL()
1296 if (status.ok()) { in SwitchWAL()
1308 return status; in SwitchWAL()
1314 Status status; in HandleWriteBufferFull() local
1365 status = SwitchMemtable(cfd, write_context); in HandleWriteBufferFull()
1367 if (!status.ok()) { in HandleWriteBufferFull()
1375 if (status.ok()) { in HandleWriteBufferFull()
1387 return status; in HandleWriteBufferFull()
1580 Status status; in ScheduleFlushes() local
1588 status = SwitchMemtable(cfd, context); in ScheduleFlushes()
1593 if (!status.ok()) { in ScheduleFlushes()
1602 if (status.ok()) { in ScheduleFlushes()
1611 return status; in ScheduleFlushes()