Lines Matching refs:queue
61 * In addition, it provides for queue single-threading
106 * Stream-level locks should be acquired before any queue-level locks
109 * The stream head write queue lock(sd_wrq) is used to protect the
111 * necessary for strqset() only gets the queue lock.
176 struct queue *sd_wrq; /* write queue */
192 struct msgb *sd_mark; /* "marked" message on read queue */
208 struct queue *sd_struiordq; /* sync barrier struio() read queue */
209 struct queue *sd_struiowrq; /* sync barrier struio() write queue */
234 struct queue *sd_qhead; /* Head of queues to be serviced. */
235 struct queue *sd_qtail; /* Tail of queues to be serviced. */
335 * Each queue points to a sync queue (the inner perimeter) which keeps
336 * track of the number of threads that are inside a given queue (sq_count)
338 * (by queuing messages if the queue can not be entered.)
342 * b_queue recording the queue and b_prev recording the function to
362 * dependent code. sq_head/sq_tail are used to queue deferred messages on
363 * the inner perimeter syncqs and to queue become_writer requests on the
445 * The list of queue's is handled by sq_head and
451 queue_t *sq_head; /* queue of deferred messages */
452 queue_t *sq_tail; /* queue of deferred messages */
461 kcondvar_t sq_wait; /* block on this sync queue */
505 * sync queue scheduling flags (for sq_svcflags).
518 * sync queue state flags
533 * Test a queue to see if inner perimeter is exclusive.
702 struct queue qu_rqueue; /* read queue - must be first */
703 struct queue qu_wqueue; /* write queue - must be second */
805 * Get the module/driver name for a queue. Since some queues don't have
968 * Put a message on the queue syncq.
1016 * data queued on the stream head read queue.
1042 * Obsolete queue scheduling macros. They are not used anymore, but still kept
1286 * esballoc queue for throttling
1291 mblk_t *eq_head; /* head of queue */
1292 mblk_t *eq_tail; /* tail of queue */
1293 uint_t eq_flags; /* esballoc queue flags */
1297 * esballoc flags for queue processing.
1299 #define ESBQ_PROCESSING 0x01 /* queue is being processed */
1322 extern struct queue *OTHERQ(queue_t *); /* stream.h */
1323 extern struct queue *RD(queue_t *);
1324 extern struct queue *WR(queue_t *);