Searched refs:port_mq (Results 1 – 3 of 3) sorted by relevance
151 ipc_mqueue_t port_mq = &lport->ip_messages; in flipc_port_destroy() local152 flipc_port_t fport = port_mq->imq_fport; in flipc_port_destroy()157 int m = port_mq->imq_msgcount; in flipc_port_destroy()166 kmsg = ipc_kmsg_queue_first(&port_mq->imq_messages); in flipc_port_destroy()168 ipc_kmsg_rmqueue(&port_mq->imq_messages, kmsg); in flipc_port_destroy()170 flipc_msg_ack(kmsg->ikm_node, port_mq, FALSE); in flipc_port_destroy()172 ipc_mqueue_release_msgcount(port_mq); in flipc_port_destroy()173 port_mq->imq_seqno++; in flipc_port_destroy()422 ipc_mqueue_t port_mq = IMQ_NULL; in flipc_msg_to_remote_node() local430 port_mq = thread->ith_peekq; in flipc_msg_to_remote_node()[all …]
115 ipc_mqueue_t port_mq,612 ipc_mqueue_release_msgcount(ipc_mqueue_t port_mq) in ipc_mqueue_release_msgcount() argument614 ipc_port_t port = ip_from_mq(port_mq); in ipc_mqueue_release_msgcount()618 assert(port_mq->imq_msgcount > 1 || ipc_kmsg_queue_empty(&port_mq->imq_messages)); in ipc_mqueue_release_msgcount()620 port_mq->imq_msgcount--; in ipc_mqueue_release_msgcount()622 if (!imq_full(port_mq) && port->ip_fullwaiters && in ipc_mqueue_release_msgcount()644 port_mq->imq_msgcount++; in ipc_mqueue_release_msgcount()648 if (ipc_kmsg_queue_empty(&port_mq->imq_messages)) { in ipc_mqueue_release_msgcount()1168 ipc_mqueue_t port_mq, in ipc_mqueue_peek_on_thread_locked() argument1173 assert(ipc_kmsg_queue_first(&port_mq->imq_messages) != IKM_NULL); in ipc_mqueue_peek_on_thread_locked()[all …]
192 ipc_mqueue_t port_mq,222 ipc_mqueue_t port_mq);