Lines Matching defs:queue
358 ipc_kmsg_queue_t queue,
361 ipc_kmsg_enqueue_macro(queue, kmsg);
372 ipc_kmsg_queue_t queue)
376 first = ipc_kmsg_queue_first(queue);
379 ipc_kmsg_rmqueue_first_macro(queue, first);
387 * Pull a kmsg out of a queue.
392 ipc_kmsg_queue_t queue,
397 assert(queue->ikmq_base != IKM_NULL);
404 assert(queue->ikmq_base == kmsg);
406 queue->ikmq_base = IKM_NULL;
408 if (queue->ikmq_base == kmsg)
409 queue->ikmq_base = next;
423 * (Or IKM_NULL if it is the last one in the queue.)
428 ipc_kmsg_queue_t queue,
433 assert(queue->ikmq_base != IKM_NULL);
436 if (queue->ikmq_base == next)
456 ipc_kmsg_queue_t queue;
465 queue = &(current_thread()->ith_messages);
466 empty = ipc_kmsg_queue_empty(queue);
467 ipc_kmsg_enqueue(queue, kmsg);
470 /* must leave kmsg in queue while cleaning it */
472 while ((kmsg = ipc_kmsg_queue_first(queue)) != IKM_NULL) {
474 ipc_kmsg_rmqueue(queue, kmsg);
979 * queue.