Searched refs:task (Results 1 – 6 of 6) sorted by relevance
76 if (task != nullptr) { in OnFlushCompleted()78 task->retry_on_fail = true; in OnFlushCompleted()81 ScheduleCompaction(task); in OnFlushCompleted()111 std::unique_ptr<CompactionTask> task( in CompactFiles() local113 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()[all …]
224 if (task) { in initialize()226 new (&function_) CombineFunction(task); in initialize()625 task.attach(&storage);1061 auto&& task = Request<Func>{func};1085 return std::move(task).get();1166 auto&& task = coalesce(request, state);1169 attach(task, storage);1313 CombineFunction task) {1336 task();1356 CombineFunction task) {[all …]
285 auto lock_combine(Task task) -> decltype(std::declval<const Task&>()());
31 Having addressed our latency goal, the next task was to design a very compact hash index to minimiz…
86 [Uber](http://eng.uber.com/cherami/) uses RocksDB as a durable and scalable task queue.
9521 const task_t task = mach_task_self(); in GetThreadCount() local9524 const kern_return_t status = task_threads(task, &thread_list, &thread_count); in GetThreadCount()9528 vm_deallocate(task, in GetThreadCount()