Searched refs:JobNode (Results 1 – 6 of 6) sorted by relevance
290 …assert { state is Empty || state is JobNode<*> } // only simple state without lists where children… in <lambda>()316 if (state is JobNode<*>) { // SINGLE/SINGLE+ state -- one completion handler (common case) in <lambda>()362 notifyHandlers<JobNode<*>>(this, cause) in <lambda>()364 private inline fun <reified T: JobNode<*>> notifyHandlers(list: NodeList, cause: Throwable?) { in <lambda>()456 var nodeCache: JobNode<*>? = null in <lambda>()470 promoteSingleToNodeList(state as JobNode<*>) in <lambda>()511 private fun makeNode(handler: CompletionHandler, onCancelling: Boolean): JobNode<*> { in <lambda>()516 … (handler as? JobNode<*>)?.also { assert { it.job === this && it !is JobCancellingNode } } in <lambda>()520 private fun addLastAtomic(expect: Any, list: NodeList, node: JobNode<*>) = in <lambda>()530 private fun promoteSingleToNodeList(state: JobNode<*>) { in <lambda>()[all …]
104 …AllNode(private val continuation: CancellableContinuation<List<T>>, job: Job) : JobNode<Job>(job) { in toString()
26 } JobNode; typedef34 JobNode job_info;
404 JobNode *proc_job = NULL; in first_pass_worker_hook()414 (JobNode *)vp9_enc_grp_get_next_job(multi_thread_ctxt, cur_tile_id); in first_pass_worker_hook()496 JobNode *proc_job = NULL; in temporal_filter_worker_hook()503 (JobNode *)vp9_enc_grp_get_next_job(multi_thread_ctxt, cur_tile_id); in temporal_filter_worker_hook()573 JobNode *proc_job = NULL; in enc_row_mt_worker_hook()580 (JobNode *)vp9_enc_grp_get_next_job(multi_thread_ctxt, cur_tile_id); in enc_row_mt_worker_hook()
23 JobNode *job_info = NULL; in vp9_enc_grp_get_next_job()
38 ) : JobNode<Job>(job) { in cancelFutureOnCompletion()