Cross Reference: /illumos-gate/usr/src/uts/common/os/msg.c

Lines Matching refs:queue
39  * Description:  Maximum number of message queue ids allowed a zone.
41  *   When msgget() is used to allocate a message queue, one id is
47  * Description:  Maximum number of message queue ids allowed a project.
49  *   When msgget() is used to allocate a message queue, one id is
55  * Description:  Maximum number of bytes of messages on a message queue.
57  *   When msgget() successfully allocates a message queue, the minimum
61  * Description:  Maximum number of messages on a message queue.
63  *   When msgget() successfully allocates a message queue, the minimum
64  *   enforced value of this limit is used to initialize a per-queue
160  *      Big Theory statement for message queue correctness
166  * message are now linked in a queue-like fashion and awaken one at a time in
205  *    2. Blocking on the copyout queue is only temporary while messages
207  *	 when it gets to front of the queue (copyout is a FIFO).
211  *      before blocking on a sendwait queue.
229  *		   We issue a wakeup on copy queue and then go back to
241  *		   queue where it will be awakened again sometime in the future.
245  * 	but is being copied out we have to block on the copyout queue.
253  *		   an error), the first entry on the copyout queue is woken
260  *			   success the next entry on the copyout queue is
263  *			   on the copyout queue.
265  *		   process on the copyout queue.
388  * msgunlink - Unlink msg from queue, decrement byte count and wake up anyone
389  * waiting for free bytes on queue.
391  * Called with queue locked.
419 	 * for this message queue.
438 	STRUCT_DECL(msqid_ds, ds);		/* SVR4 queue work area */
719 			 * can result in a message on the queue that can be
857 	 * Reclaim the mutex and make sure the message queue still exists.
912 			 * type on the send queue.  This allows us to terminate
998 	 * the number of messages on the queue.
1240 	 * msg queue.  Given that, we need to do the wakeup
1404 msg_rcvq_sleep(list_t *queue, msgq_wakeup_t *entry, kmutex_t **lock,
1411 	list_insert_tail(queue, entry);
1422 		list_remove(queue, entry);
1514 	 * msgs_out:	is the number of messages on the message queue if