Searched refs:mqueue (Results 1 - 5 of 5) sorted by relevance
/macosx-10.5.8/xnu-1228.15.4/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); 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) argument 179 ipc_mqueue_remove_from_all( ipc_mqueue_t mqueue) argument 196 ipc_mqueue_remove_all( ipc_mqueue_t mqueue) argument 314 ipc_mqueue_changed( ipc_mqueue_t mqueue) argument 345 ipc_mqueue_send( ipc_mqueue_t mqueue, ipc_kmsg_t kmsg, mach_msg_option_t option, mach_msg_timeout_t send_timeout) argument 443 ipc_mqueue_release_msgcount( ipc_mqueue_t mqueue) argument 476 ipc_mqueue_post( register ipc_mqueue_t mqueue, register ipc_kmsg_t kmsg) argument 652 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 837 ipc_mqueue_select( ipc_mqueue_t mqueue, mach_msg_option_t option, mach_msg_size_t max_size) argument 895 ipc_mqueue_destroy( ipc_mqueue_t mqueue) argument 940 ipc_mqueue_set_qlimit( ipc_mqueue_t mqueue, mach_port_msgcount_t qlimit) argument 982 ipc_mqueue_set_seqno( ipc_mqueue_t mqueue, mach_port_seqno_t seqno) argument 1022 ipc_mqueue_t mqueue; local [all...] |
H A D | ipc_mqueue.h | 129 ipc_mqueue_t mqueue, 132 /* destroy an mqueue */ 134 ipc_mqueue_t mqueue); 138 ipc_mqueue_t mqueue); 140 /* Add the specific mqueue as a member of the set */ 142 ipc_mqueue_t mqueue, 145 /* Check to see if mqueue is member of set_mqueue */ 147 ipc_mqueue_t mqueue, 150 /* Remove an mqueue from a specific set */ 152 ipc_mqueue_t mqueue, [all...] |
H A D | mach_msg.c | 425 ipc_mqueue_t mqueue; local 428 mr = ipc_mqueue_copyin(space, rcv_name, &mqueue, &object); 441 ipc_mqueue_receive(mqueue, option, rcv_size, rcv_timeout, THREAD_ABORTSAFE); 1070 * mqueue is insufficient to work with port sets, since 1147 * so the mqueue cannot go away. 1751 * and hold ref for rcv_object (to keep mqueue alive). 1871 ipc_mqueue_t mqueue; local 1873 mr = ipc_mqueue_copyin(space, rcv_name, &mqueue, &object); 1897 ipc_mqueue_receive(mqueue, option, rcv_size, msg_timeout, THREAD_ABORTSAFE);
|
H A D | ipc_port.c | 626 ipc_mqueue_t mqueue; local 684 mqueue = &port->ip_messages; 685 ipc_mqueue_destroy(mqueue);
|
/macosx-10.5.8/xnu-1228.15.4/osfmk/kern/ |
H A D | ipc_mig.c | 211 ipc_mqueue_t mqueue; local 226 mqueue = &reply->ip_messages; 231 ipc_mqueue_receive(mqueue, 377 ipc_mqueue_t mqueue; local 380 &mqueue, &object); 386 ipc_mqueue_receive(mqueue,
|
Completed in 23 milliseconds