Searched refs:port_mq (Results 1 – 3 of 3) sorted by relevance
152 ipc_mqueue_t port_mq = &lport->ip_messages; in flipc_port_destroy() local153 flipc_port_t fport = port_mq->imq_fport; in flipc_port_destroy()158 int m = port_mq->imq_msgcount; in flipc_port_destroy()167 kmsg = ipc_kmsg_queue_first(&port_mq->imq_messages); in flipc_port_destroy()169 ipc_kmsg_rmqueue(&port_mq->imq_messages, kmsg); in flipc_port_destroy()171 flipc_msg_ack(kmsg->ikm_node, port_mq, FALSE); in flipc_port_destroy()173 ipc_mqueue_release_msgcount(port_mq); in flipc_port_destroy()174 port_mq->imq_seqno++; in flipc_port_destroy()423 ipc_mqueue_t port_mq = IMQ_NULL; in flipc_msg_to_remote_node() local431 port_mq = thread->ith_peekq; in flipc_msg_to_remote_node()[all …]
113 ipc_mqueue_t port_mq,538 ipc_mqueue_release_msgcount(ipc_mqueue_t port_mq) in ipc_mqueue_release_msgcount() argument540 ipc_port_t port = ip_from_mq(port_mq); in ipc_mqueue_release_msgcount()544 assert(port_mq->imq_msgcount > 1 || ipc_kmsg_queue_empty(&port_mq->imq_messages)); in ipc_mqueue_release_msgcount()546 port_mq->imq_msgcount--; in ipc_mqueue_release_msgcount()548 if (!imq_full(port_mq) && port->ip_fullwaiters && in ipc_mqueue_release_msgcount()570 port_mq->imq_msgcount++; in ipc_mqueue_release_msgcount()574 if (ipc_kmsg_queue_empty(&port_mq->imq_messages)) { in ipc_mqueue_release_msgcount()1074 ipc_mqueue_t port_mq, in ipc_mqueue_peek_on_thread_locked() argument1080 assert(ipc_kmsg_queue_first(&port_mq->imq_messages) != IKM_NULL); in ipc_mqueue_peek_on_thread_locked()[all …]
201 ipc_mqueue_t port_mq,232 ipc_mqueue_t port_mq);