Lines Matching refs:job_context
82 IOStatus DBImpl::SyncClosedLogs(JobContext* job_context) { in SyncClosedLogs() argument
105 "[JOB %d] Syncing log #%" PRIu64, job_context->job_id, in SyncClosedLogs()
139 bool* made_progress, JobContext* job_context, in FlushMemTableToOutputFile() argument
153 snapshot_checker, job_context, log_buffer, directories_.GetDbDir(), in FlushMemTableToOutputFile()
166 NotifyOnFlushBegin(cfd, &file_meta, mutable_cf_options, job_context->job_id); in FlushMemTableToOutputFile()
179 io_s = SyncClosedLogs(job_context); in FlushMemTableToOutputFile()
248 JobContext* job_context, LogBuffer* log_buffer, Env::Priority thread_pri) { in FlushMemTablesToOutputFiles() argument
251 bg_flush_args, made_progress, job_context, log_buffer, thread_pri); in FlushMemTablesToOutputFiles()
256 GetSnapshotContext(job_context, &snapshot_seqs, in FlushMemTablesToOutputFiles()
264 cfd, mutable_cf_options, made_progress, job_context, in FlushMemTablesToOutputFiles()
290 JobContext* job_context, LogBuffer* log_buffer, Env::Priority thread_pri) { in AtomicFlushMemTablesToOutputFiles() argument
308 GetSnapshotContext(job_context, &snapshot_seqs, in AtomicFlushMemTablesToOutputFiles()
344 snapshot_checker, job_context, log_buffer, directories_.GetDbDir(), in AtomicFlushMemTablesToOutputFiles()
362 job_context->job_id); in AtomicFlushMemTablesToOutputFiles()
369 io_s = SyncClosedLogs(job_context); in AtomicFlushMemTablesToOutputFiles()
526 &job_context->memtables_to_free, directories_.GetDbDir(), log_buffer); in AtomicFlushMemTablesToOutputFiles()
531 static_cast<int>(job_context->superversion_contexts.size())); in AtomicFlushMemTablesToOutputFiles()
537 &job_context->superversion_contexts[i], in AtomicFlushMemTablesToOutputFiles()
875 JobContext job_context(0, true); in CompactFiles()
895 &job_context, &log_buffer, compaction_job_info); in CompactFiles()
907 FindObsoleteFiles(&job_context, !s.ok()); in CompactFiles()
911 if (job_context.HaveSomethingToClean() || in CompactFiles()
912 job_context.HaveSomethingToDelete() || !log_buffer.IsEmpty()) { in CompactFiles()
919 if (job_context.HaveSomethingToDelete()) { in CompactFiles()
921 PurgeObsoleteFiles(job_context); in CompactFiles()
923 job_context.Clean(); in CompactFiles()
935 int output_path_id, JobContext* job_context, LogBuffer* log_buffer, in CompactFilesImpl() argument
1016 GetSnapshotContext(job_context, &snapshot_seqs, in CompactFilesImpl()
1026 job_context->job_id, c.get(), immutable_db_options_, in CompactFilesImpl()
1056 &job_context->superversion_contexts[0], in CompactFilesImpl()
1073 job_context->job_id, version, compaction_job_info); in CompactFilesImpl()
1085 job_context->job_id); in CompactFilesImpl()
1090 job_context->job_id, status.ToString().c_str()); in CompactFilesImpl()
2199 Status DBImpl::BackgroundFlush(bool* made_progress, JobContext* job_context, in BackgroundFlush() argument
2222 job_context->superversion_contexts; in BackgroundFlush()
2261 job_context, log_buffer, thread_pri); in BackgroundFlush()
2281 JobContext job_context(next_job_id_.fetch_add(1), true); in BackgroundCallFlush() local
2297 Status s = BackgroundFlush(&made_progress, &job_context, &log_buffer, in BackgroundCallFlush()
2324 FindObsoleteFiles(&job_context, !s.ok() && !s.IsShutdownInProgress() && in BackgroundCallFlush()
2327 if (job_context.HaveSomethingToClean() || in BackgroundCallFlush()
2328 job_context.HaveSomethingToDelete() || !log_buffer.IsEmpty()) { in BackgroundCallFlush()
2337 if (job_context.HaveSomethingToDelete()) { in BackgroundCallFlush()
2338 PurgeObsoleteFiles(job_context); in BackgroundCallFlush()
2340 job_context.Clean(); in BackgroundCallFlush()
2362 JobContext job_context(next_job_id_.fetch_add(1), true); in BackgroundCallCompaction() local
2382 Status s = BackgroundCompaction(&made_progress, &job_context, &log_buffer, in BackgroundCallCompaction()
2412 m->cfd->GetName().c_str(), job_context.job_id); in BackgroundCallCompaction()
2420 FindObsoleteFiles(&job_context, !s.ok() && !s.IsShutdownInProgress() && in BackgroundCallCompaction()
2426 if (job_context.HaveSomethingToClean() || in BackgroundCallCompaction()
2427 job_context.HaveSomethingToDelete() || !log_buffer.IsEmpty()) { in BackgroundCallCompaction()
2435 if (job_context.HaveSomethingToDelete()) { in BackgroundCallCompaction()
2436 PurgeObsoleteFiles(job_context); in BackgroundCallCompaction()
2439 job_context.Clean(); in BackgroundCallCompaction()
2476 JobContext* job_context, in BackgroundCompaction() argument
2686 compaction_job_stats, job_context->job_id); in BackgroundCompaction()
2697 &job_context->superversion_contexts[0], in BackgroundCompaction()
2719 compaction_job_stats, job_context->job_id); in BackgroundCompaction()
2756 &job_context->superversion_contexts[0], in BackgroundCompaction()
2764 << "job" << job_context->job_id << "event" in BackgroundCompaction()
2813 GetSnapshotContext(job_context, &snapshot_seqs, in BackgroundCompaction()
2817 job_context->job_id, c.get(), immutable_db_options_, in BackgroundCompaction()
2830 compaction_job_stats, job_context->job_id); in BackgroundCompaction()
2843 &job_context->superversion_contexts[0], in BackgroundCompaction()
2869 compaction_job_stats, job_context->job_id); in BackgroundCompaction()
3166 JobContext* job_context, std::vector<SequenceNumber>* snapshot_seqs, in GetSnapshotContext() argument
3170 assert(job_context != nullptr); in GetSnapshotContext()
3187 job_context->job_snapshot.reset(new ManagedSnapshot(this, job_snapshot)); in GetSnapshotContext()