Searched refs:xf_msg_dequeue (Results 1 – 5 of 5) sorted by relevance
137 xf_message_t *m = xf_msg_dequeue(&port->queue); in xf_input_port_complete()315 while ((m = xf_msg_dequeue(&port->queue)) != NULL) in xf_input_port_purge()351 xf_response_ok(xf_msg_dequeue(&port->queue)); in xf_input_port_purge_done()553 xf_message_t *m = xf_msg_dequeue(&port->queue); in xf_output_port_produce()604 while ((m = xf_msg_dequeue(&port->queue)) != NULL) in xf_output_port_flush()
397 if ((m = xf_msg_dequeue(&rw->local)) != NULL) in xf_msg_local_ipc_get()406 m = xf_msg_dequeue(&rw->local); in xf_msg_local_ipc_get()450 m = xf_msg_dequeue(&cd->queue); in xf_msg_local_get()465 m = xf_msg_dequeue(&cd->response); in xf_msg_local_response_get()
126 m = xf_msg_dequeue(&rw->remote); in xf_msg_proxy_get()137 m = xf_msg_dequeue(&rw->remote); in xf_msg_proxy_get()
138 static inline xf_message_t * xf_msg_dequeue(xf_msg_queue_t *queue) in xf_msg_dequeue() function
178 xf_message_t *m = xf_msg_dequeue(&mixer->output.queue); in xa_mixer_prepare_runtime()