Lines Matching refs:task
32 virtual void ScheduleCompaction(CompactionTask *task) = 0;
75 CompactionTask* task = PickCompaction(db, info.cf_name); in OnFlushCompleted() local
76 if (task != nullptr) { in OnFlushCompleted()
78 task->retry_on_fail = true; in OnFlushCompleted()
81 ScheduleCompaction(task); in OnFlushCompleted()
106 void ScheduleCompaction(CompactionTask* task) override { in ScheduleCompaction() argument
107 options_.env->Schedule(&FullCompactor::CompactFiles, task); in ScheduleCompaction()
111 std::unique_ptr<CompactionTask> task( in CompactFiles() local
113 assert(task); in CompactFiles()
114 assert(task->db); in CompactFiles()
115 Status s = task->db->CompactFiles( in CompactFiles()
116 task->compact_options, in CompactFiles()
117 task->input_file_names, in CompactFiles()
118 task->output_level); in CompactFiles()
120 if (!s.ok() && !s.IsIOError() && task->retry_on_fail) { in CompactFiles()
124 CompactionTask* new_task = task->compactor->PickCompaction( in CompactFiles()
125 task->db, task->column_family_name); in CompactFiles()
126 task->compactor->ScheduleCompaction(new_task); in CompactFiles()