Lines Matching refs:queue
53 MppTaskQueueImpl *queue; member
92 static MPP_RET mpp_port_init(MppTaskQueueImpl *queue, MppPortType type, MppPort *port) in mpp_port_init() argument
100 mpp_task_dbg_func("enter queue %p type %d\n", queue, type); in mpp_port_init()
103 impl->queue = queue; in mpp_port_init()
117 mpp_task_dbg_func("leave queue %p port %p\n", queue, impl); in mpp_port_init()
133 MppTaskQueueImpl *queue = port_impl->queue; in _mpp_port_poll() local
137 mpp_mutex_lock(&queue->lock); in _mpp_port_poll()
140 if (!queue->ready) { in _mpp_port_poll()
146 curr = &queue->info[port_impl->status_curr]; in _mpp_port_poll()
151 queue->mpp, queue->name, caller, in _mpp_port_poll()
167 queue->mpp, queue->name, caller, in _mpp_port_poll()
170 ret = (MPP_RET)mpp_cond_wait(cond, &queue->lock); in _mpp_port_poll()
173 queue->mpp, queue->name, caller, in _mpp_port_poll()
175 ret = (MPP_RET)mpp_cond_timedwait(cond, &queue->lock, timeout); in _mpp_port_poll()
186 queue->mpp, queue->name, caller, in _mpp_port_poll()
190 mpp_mutex_unlock(&queue->lock); in _mpp_port_poll()
200 MppTaskQueueImpl *queue = port_impl->queue; in _mpp_port_move() local
205 mpp_mutex_lock(&queue->lock); in _mpp_port_move()
209 if (!queue->ready) { in _mpp_port_move()
217 mpp_assert(task_impl->queue == (MppTaskQueue)queue); in _mpp_port_move()
219 curr = &queue->info[task_impl->status]; in _mpp_port_move()
220 next = &queue->info[status]; in _mpp_port_move()
228 queue->mpp, queue->name, caller, in _mpp_port_move()
239 mpp_mutex_unlock(&queue->lock); in _mpp_port_move()
247 MppTaskQueueImpl *queue = port_impl->queue; in _mpp_port_dequeue() local
254 mpp_mutex_lock(&queue->lock); in _mpp_port_dequeue()
258 if (!queue->ready) { in _mpp_port_dequeue()
264 curr = &queue->info[port_impl->status_curr]; in _mpp_port_dequeue()
265 next = &queue->info[port_impl->next_on_dequeue]; in _mpp_port_dequeue()
271 queue->mpp, queue->name, caller, in _mpp_port_dequeue()
291 queue->mpp, queue->name, caller, in _mpp_port_dequeue()
300 mpp_mutex_unlock(&queue->lock); in _mpp_port_dequeue()
309 MppTaskQueueImpl *queue = port_impl->queue; in _mpp_port_enqueue() local
314 mpp_mutex_lock(&queue->lock); in _mpp_port_enqueue()
318 if (!queue->ready) { in _mpp_port_enqueue()
321 mpp_mutex_unlock(&queue->lock); in _mpp_port_enqueue()
327 mpp_assert(task_impl->queue == (MppTaskQueue)queue); in _mpp_port_enqueue()
330 curr = &queue->info[task_impl->status]; in _mpp_port_enqueue()
331 next = &queue->info[port_impl->next_on_enqueue]; in _mpp_port_enqueue()
340 queue->mpp, queue->name, caller, in _mpp_port_enqueue()
350 mpp_mutex_unlock(&queue->lock); in _mpp_port_enqueue()
362 MppTaskQueueImpl *queue = port_impl->queue; in _mpp_port_awake() local
364 if (queue) { in _mpp_port_awake()
365 mpp_mutex_lock(&queue->lock); in _mpp_port_awake()
366 curr = &queue->info[port_impl->status_curr]; in _mpp_port_awake()
370 mpp_mutex_unlock(&queue->lock); in _mpp_port_awake()
377 MPP_RET mpp_task_queue_init(MppTaskQueue *queue, void *mpp, const char *name) in mpp_task_queue_init() argument
379 if (!queue) { in mpp_task_queue_init()
391 *queue = NULL; in mpp_task_queue_init()
432 *queue = p; in mpp_task_queue_init()
438 MPP_RET mpp_task_queue_setup(MppTaskQueue queue, RK_S32 task_count) in mpp_task_queue_setup() argument
440 MppTaskQueueImpl *impl = (MppTaskQueueImpl *)queue; in mpp_task_queue_setup()
466 tasks[i].queue = queue; in mpp_task_queue_setup()
480 MPP_RET mpp_task_queue_deinit(MppTaskQueue queue) in mpp_task_queue_deinit() argument
482 MppTaskQueueImpl *p = (MppTaskQueueImpl *)queue; in mpp_task_queue_deinit()
530 MppPort mpp_task_queue_get_port(MppTaskQueue queue, MppPortType type) in mpp_task_queue_get_port() argument
532 if (!queue || type >= MPP_PORT_BUTT) { in mpp_task_queue_get_port()
533 mpp_err_f("invalid input queue %p type %d\n", queue, type); in mpp_task_queue_get_port()
537 MppTaskQueueImpl *impl = (MppTaskQueueImpl *)queue; in mpp_task_queue_get_port()