Lines Matching refs:queue
125 int hal_workqueue_dowork(hal_workqueue *queue, hal_work *work) in hal_workqueue_dowork() argument
128 ret = rt_workqueue_dowork(queue, work); in hal_workqueue_dowork()
137 int hal_queue_delete(hal_queue_t queue) in hal_queue_delete() argument
139 if (queue == NULL) in hal_queue_delete()
145 rt_mq_delete(queue); in hal_queue_delete()
150 int hal_queue_send_wait(hal_queue_t queue, void *buffer, int timeout) in hal_queue_send_wait() argument
154 if (queue == NULL) in hal_queue_send_wait()
160 ret = rt_mq_send_wait(queue, buffer, queue->msg_size, timeout); in hal_queue_send_wait()
169 int hal_queue_send(hal_queue_t queue, void *buffer) in hal_queue_send() argument
171 return hal_queue_send_wait(queue, buffer, 0); in hal_queue_send()
174 int hal_queue_recv(hal_queue_t queue, void *buffer, int timeout) in hal_queue_recv() argument
178 if (queue == NULL) in hal_queue_recv()
184 ret = rt_mq_recv(queue, buffer, queue->msg_size, timeout); in hal_queue_recv()
194 int hal_is_queue_empty(hal_queue_t queue) in hal_is_queue_empty() argument
199 if (queue == NULL) in hal_is_queue_empty()
205 ret = rt_mq_control(queue, RT_IPC_CMD_GET_STATE, &arg); in hal_is_queue_empty()