Lines Matching refs:impl
94 MppPortImpl *impl = mpp_malloc(MppPortImpl, 1); in mpp_port_init() local
95 if (!impl) { in mpp_port_init()
102 impl->type = type; in mpp_port_init()
103 impl->queue = queue; in mpp_port_init()
106 impl->status_curr = MPP_INPUT_PORT; in mpp_port_init()
107 impl->next_on_dequeue = MPP_INPUT_HOLD; in mpp_port_init()
108 impl->next_on_enqueue = MPP_OUTPUT_PORT; in mpp_port_init()
110 impl->status_curr = MPP_OUTPUT_PORT; in mpp_port_init()
111 impl->next_on_dequeue = MPP_OUTPUT_HOLD; in mpp_port_init()
112 impl->next_on_enqueue = MPP_INPUT_PORT; in mpp_port_init()
115 *port = (MppPort *)impl; in mpp_port_init()
117 mpp_task_dbg_func("leave queue %p port %p\n", queue, impl); in mpp_port_init()
440 MppTaskQueueImpl *impl = (MppTaskQueueImpl *)queue; in mpp_task_queue_setup() local
445 mpp_mutex_lock(&impl->lock); in mpp_task_queue_setup()
448 mpp_assert(impl->tasks == NULL); in mpp_task_queue_setup()
449 mpp_assert(impl->task_count == 0); in mpp_task_queue_setup()
453 mpp_mutex_unlock(&impl->lock); in mpp_task_queue_setup()
457 impl->tasks = tasks; in mpp_task_queue_setup()
458 impl->task_count = task_count; in mpp_task_queue_setup()
460 info = &impl->info[MPP_INPUT_PORT]; in mpp_task_queue_setup()
473 impl->ready = 1; in mpp_task_queue_setup()
475 mpp_mutex_unlock(&impl->lock); in mpp_task_queue_setup()
537 MppTaskQueueImpl *impl = (MppTaskQueueImpl *)queue; in mpp_task_queue_get_port() local
538 return (type == MPP_PORT_INPUT) ? (impl->input) : (impl->output); in mpp_task_queue_get_port()