Searched refs:mqueue (Results 1 - 5 of 5) sorted by relevance

/darwin-on-arm/xnu/osfmk/ipc/
H A Dipc_mqueue.c114 ipc_mqueue_t mqueue,
118 wait_queue_set_init(&mqueue->imq_set_queue, SYNC_POLICY_FIFO|SYNC_POLICY_PREPOST);
120 wait_queue_init(&mqueue->imq_wait_queue, SYNC_POLICY_FIFO);
121 ipc_kmsg_queue_init(&mqueue->imq_messages);
122 mqueue->imq_seqno = 0;
123 mqueue->imq_msgcount = 0;
124 mqueue->imq_qlimit = MACH_PORT_QLIMIT_DEFAULT;
125 mqueue->imq_fullwaiters = FALSE;
132 * Indicate whether the (port) mqueue is a member of
133 * this portset's mqueue
113 ipc_mqueue_init( ipc_mqueue_t mqueue, boolean_t is_set) argument
161 ipc_mqueue_remove( ipc_mqueue_t mqueue, ipc_mqueue_t set_mqueue, wait_queue_link_t *wqlp) argument
180 ipc_mqueue_remove_from_all( ipc_mqueue_t mqueue, queue_t links) argument
198 ipc_mqueue_remove_all( ipc_mqueue_t mqueue, queue_t links) argument
331 ipc_mqueue_changed( ipc_mqueue_t mqueue) argument
362 ipc_mqueue_send( ipc_mqueue_t mqueue, ipc_kmsg_t kmsg, mach_msg_option_t option, mach_msg_timeout_t send_timeout, spl_t s) argument
459 ipc_mqueue_release_msgcount( ipc_mqueue_t mqueue) argument
492 ipc_mqueue_post( register ipc_mqueue_t mqueue, register ipc_kmsg_t kmsg) argument
680 ipc_mqueue_receive( ipc_mqueue_t mqueue, mach_msg_option_t option, mach_msg_size_t max_size, mach_msg_timeout_t rcv_timeout, int interruptible) argument
711 ipc_mqueue_receive_on_thread( ipc_mqueue_t mqueue, mach_msg_option_t option, mach_msg_size_t max_size, mach_msg_timeout_t rcv_timeout, int interruptible, thread_t thread) argument
900 ipc_mqueue_select_on_thread( ipc_mqueue_t mqueue, mach_msg_option_t option, mach_msg_size_t max_size, thread_t thread) argument
1004 ipc_mqueue_destroy( ipc_mqueue_t mqueue) argument
1058 ipc_mqueue_set_qlimit( ipc_mqueue_t mqueue, mach_port_msgcount_t qlimit) argument
1100 ipc_mqueue_set_seqno( ipc_mqueue_t mqueue, mach_port_seqno_t seqno) argument
1140 ipc_mqueue_t mqueue; local
[all...]
H A Dipc_mqueue.h139 ipc_mqueue_t mqueue,
142 /* destroy an mqueue */
144 ipc_mqueue_t mqueue);
148 ipc_mqueue_t mqueue);
150 /* Add the specific mqueue as a member of the set */
152 ipc_mqueue_t mqueue,
156 /* Check to see if mqueue is member of set_mqueue */
158 ipc_mqueue_t mqueue,
161 /* Remove an mqueue from a specific set */
163 ipc_mqueue_t mqueue,
[all...]
H A Dmach_msg.c353 ipc_mqueue_t mqueue; local
356 mr = ipc_mqueue_copyin(space, rcv_name, &mqueue, &object);
369 ipc_mqueue_receive(mqueue, option, rcv_size, rcv_timeout, THREAD_ABORTSAFE);
440 ipc_mqueue_t mqueue; local
442 mr = ipc_mqueue_copyin(space, rcv_name, &mqueue, &object);
467 ipc_mqueue_receive(mqueue, option, rcv_size, msg_timeout, THREAD_ABORTSAFE);
H A Dipc_port.c793 ipc_mqueue_t mqueue; local
853 mqueue = &port->ip_messages;
854 ipc_mqueue_destroy(mqueue);
/darwin-on-arm/xnu/osfmk/kern/
H A Dipc_mig.c301 ipc_mqueue_t mqueue; local
316 mqueue = &reply->ip_messages;
321 ipc_mqueue_receive(mqueue,
474 ipc_mqueue_t mqueue; local
477 &mqueue, &object);
483 ipc_mqueue_receive(mqueue,

Completed in 84 milliseconds