Lines Matching refs:q
112 * the read q due to allocb failures, these failures must get
176 queue_t *pi_qptr; /* back pointer to q */
204 queue_t *q, /* pointer to the read side queue */
217 if (q->q_ptr != NULL) {
234 pip->pi_qptr = q;
235 q->q_ptr = pip;
236 WR(q)->q_ptr = pip;
238 qprocson(q);
246 bufcall_id_t id = qbufcall(q, sizeof (struct stroptions),
248 if (!qwait_sig(q)) {
249 qunbufcall(q, id);
251 qprocsoff(q);
254 qunbufcall(q, id);
272 putnext(q, mop);
286 queue_t *q, /* Pointer to the read queue */
290 struct pckt_info *pip = (struct pckt_info *)q->q_ptr;
292 qprocsoff(q);
297 qunbufcall(q, pip->pi_bufcall_id);
301 * Do not worry about msgs queued on the q, the framework
304 kmem_free(q->q_ptr, sizeof (struct pckt_info));
305 q->q_ptr = WR(q)->q_ptr = NULL;
316 queue_t *q, /* Pointer to the read queue */
346 putnext(q, mp);
369 * Also, if there are messages on the q already, keep
372 if (!canputnext(q) || (qsize(q) > 0)) {
373 (void) putq(q, mp);
391 if ((mp = add_ctl_info(q, mp)) != NULL)
392 putnext(q, mp);
401 * q, simply putnext() and pass it on.
403 if ((datamsg(mp->b_datap->db_type)) && (qsize(q) > 0))
404 (void) putq(q, mp);
406 putnext(q, mp);
420 pcktrsrv(queue_t *q)
424 while ((mp = getq(q)) != NULL) {
425 if (!canputnext(q)) {
431 * will reenable the q.
436 noenable(q);
437 (void) putbq(q, mp);
459 if ((mp = add_ctl_info(q, mp)) == NULL) {
468 putnext(q, mp);
481 queue_t *q, /* Pointer to the read queue */
484 putnext(q, mp);
499 queue_t *q, /* Pointer to the read queue */
515 struct pckt_info *pip = (struct pckt_info *)q->q_ptr;
517 noenable(q);
518 if (pip->pi_bufcall_id = qbufcall(q, mp->b_wptr - mp->b_rptr,
519 BPRI_MED, add_ctl_wkup, q)) {
521 * Put the message back onto the q.
523 (void) putq(q, mp);
546 queue_t *q, /* pointer to the read queue */
549 struct pckt_info *pip = (struct pckt_info *)q->q_ptr;
557 * Chain this message on to q for later processing.
559 (void) putq(q, mp);
570 * There are two reasons to disable the q:
571 * (1) Flow control reasons should not wake up the q.
572 * (2) High priority messages will wakeup the q
575 noenable(q);
576 if (pip->pi_bufcall_id = qbufcall(q, sizeof (char), BPRI_MED,
577 add_ctl_wkup, q)) {
579 * Add the message to the q.
581 (void) putq(q, mp);
629 if ((mp = pckt_reallocb(q, mp)) == (mblk_t *)0)
651 if ((mp = pckt_reallocb(q, mp)) == (mblk_t *)0)
678 queue_t *q = arg; /* ptr to the read queue */
679 struct pckt_info *pip = (struct pckt_info *)q->q_ptr;
683 * Allow enabling of the q to allow the service
686 * Also, qenable() to schedule the q immediately.
688 * messages if they are on the q.
690 enableok(q);
691 qenable(q);