Home
last modified time | relevance | path

Searched refs:wqp (Results 1 – 6 of 6) sorted by relevance

/titanic_44/usr/src/uts/common/os/
H A Dstrsubr.c689 queue_t *wqp = &qip->qu_wqueue; in queue_constructor() local
707 wqp->q_first = NULL; in queue_constructor()
708 wqp->q_link = NULL; in queue_constructor()
709 wqp->q_count = 0; in queue_constructor()
710 wqp->q_mblkcnt = 0; in queue_constructor()
711 wqp->q_sqhead = NULL; in queue_constructor()
712 wqp->q_sqtail = NULL; in queue_constructor()
713 wqp->q_sqnext = NULL; in queue_constructor()
714 wqp->q_sqprev = NULL; in queue_constructor()
715 wqp->q_sqflags = 0; in queue_constructor()
[all …]
H A Dstreamio.c2547 queue_t *wqp = stp->sd_wrq; in strput() local
2561 if (!canputnext(wqp) && !(flags & MSG_IGNFLOW)) { in strput()
2566 if (!(flags & MSG_IGNFLOW) && !bcanputnext(wqp, pri)) { in strput()
2606 putnext(wqp, mp); in strput()
2609 putnext(wqp, mp); in strput()
2641 error = rwnext(wqp, &uiod); in strput()
2665 if (!canputnext(wqp) && !(flags & MSG_IGNFLOW)) { in strput()
2670 if (!bcanputnext(wqp, pri) && !(flags & MSG_IGNFLOW)) { in strput()
2677 if ((error = struioget(wqp, mp, &uiod, 0)) != 0) { in strput()
2689 putnext(wqp, mp); in strput()
[all …]
/titanic_44/usr/src/uts/common/io/
H A Dpts.c432 queue_t *wqp; in ptsclose() local
464 wqp = WR(rqp); in ptsclose()
466 while ((bp = getq(wqp)) != NULL) { in ptsclose()
473 qreply(wqp, bp); in ptsclose()
H A Dzcons.c628 queue_t *wqp; in zc_close() local
659 wqp = WR(rqp); in zc_close()
660 while ((bp = getq(wqp)) != NULL) { in zc_close()
664 miocnak(wqp, bp, 0, 0); in zc_close()
/titanic_44/usr/src/uts/common/fs/sockfs/
H A Dsocktpi.c4479 struct queue *wqp; in kstrwritemp() local
4500 wqp = stp->sd_wrq; in kstrwritemp()
4501 if (canputnext(wqp) && direct && in kstrwritemp()
4526 if (canputnext(wqp)) { in kstrwritemp()
4537 putnext(wqp, mp); in kstrwritemp()
/titanic_44/usr/src/uts/common/inet/nca/
H A Dnca.h1044 queue_t *wqp; /* our write-side STREAMS queue */ member