Searched refs:mqueue (Results 1 - 5 of 5) sorted by relevance
/darwin-on-arm/xnu/osfmk/ipc/ |
H A D | ipc_mqueue.c | 114 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 D | ipc_mqueue.h | 139 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 D | mach_msg.c | 353 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 D | ipc_port.c | 793 ipc_mqueue_t mqueue; local 853 mqueue = &port->ip_messages; 854 ipc_mqueue_destroy(mqueue);
|
/darwin-on-arm/xnu/osfmk/kern/ |
H A D | ipc_mig.c | 301 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 25 milliseconds