Home
last modified time | relevance | path

Searched refs:q_first (Results 1 – 25 of 52) sorted by relevance

123

/onnv-gate/usr/src/uts/common/io/fibre-channel/fca/emlxs/
H A Demlxs_fcp.c2048 while (cp->nodeq.q_first) { in emlxs_tx_channel_flush()
2049 ndlp = (NODELIST *) cp->nodeq.q_first; in emlxs_tx_channel_flush()
2052 if (ndlp->nlp_ptx[channelno].q_first) { in emlxs_tx_channel_flush()
2054 if (abort.q_first == 0) { in emlxs_tx_channel_flush()
2055 abort.q_first = in emlxs_tx_channel_flush()
2056 ndlp->nlp_ptx[channelno].q_first; in emlxs_tx_channel_flush()
2059 (IOCBQ *)ndlp->nlp_ptx[channelno].q_first; in emlxs_tx_channel_flush()
2068 if (ndlp->nlp_tx[channelno].q_first) { in emlxs_tx_channel_flush()
2070 if (abort.q_first == 0) { in emlxs_tx_channel_flush()
2071 abort.q_first = ndlp->nlp_tx[channelno].q_first; in emlxs_tx_channel_flush()
[all …]
H A Demlxs_clock.c301 nlp = (NODELIST *)cp->nodeq.q_first; in emlxs_timer_check_pkts()
306 iocbq = (IOCBQ *)nlp->nlp_ptx[channelno].q_first; in emlxs_timer_check_pkts()
323 q_first = (uint8_t *)next; in emlxs_timer_check_pkts()
339 if (tmo.q_first) { in emlxs_timer_check_pkts()
346 tmo.q_first = in emlxs_timer_check_pkts()
365 iocbq = (IOCBQ *)nlp->nlp_tx[channelno].q_first; in emlxs_timer_check_pkts()
381 nlp->nlp_tx[channelno].q_first = in emlxs_timer_check_pkts()
398 if (tmo.q_first) { in emlxs_timer_check_pkts()
405 tmo.q_first = in emlxs_timer_check_pkts()
432 iocbq = (IOCBQ *)tmo.q_first; in emlxs_timer_check_pkts()
[all …]
H A Demlxs_node.c135 if (cp->nodeq.q_first == (void *)ndlp && in emlxs_node_close()
138 cp->nodeq.q_first = NULL; in emlxs_node_close()
140 } else if (cp->nodeq.q_first == (void *)ndlp) { in emlxs_node_close()
141 cp->nodeq.q_first = ndlp->nlp_next[channelno]; in emlxs_node_close()
143 cp->nodeq.q_first; in emlxs_node_close()
260 if ((ndlp->nlp_ptx[channelno].q_first || in emlxs_node_open()
261 ndlp->nlp_tx[channelno].q_first) && !ndlp->nlp_next[channelno]) { in emlxs_node_open()
265 if (cp->nodeq.q_first) { in emlxs_node_open()
268 ndlp->nlp_next[channelno] = cp->nodeq.q_first; in emlxs_node_open()
277 cp->nodeq.q_first = (uint8_t *)ndlp; in emlxs_node_open()
[all …]
H A Demlxs_fct.c4244 next = (IOCBQ *)nlp->nlp_ptx[channelno].q_first;
4259 if (nlp->nlp_ptx[channelno].q_first ==
4262 q_first =
4278 next = (IOCBQ *)nlp->nlp_tx[channelno].q_first;
4293 if (nlp->nlp_tx[channelno].q_first ==
4295 nlp->nlp_tx[channelno].q_first =
4315 if ((nlp->nlp_ptx[channelno].q_first) ||
4316 (nlp->nlp_tx[channelno].q_first &&
4326 cp->nodeq.q_first = nlp->nlp_next[channelno];
4334 cp->nodeq.q_first = NULL;
[all …]
H A Demlxs_solaris.c3490 next = (IOCBQ *) nlp->nlp_ptx[channelno].q_first; in emlxs_pkt_abort()
3505 if (nlp->nlp_ptx[channelno].q_first == in emlxs_pkt_abort()
3508 q_first = in emlxs_pkt_abort()
3524 next = (IOCBQ *) nlp->nlp_tx[channelno].q_first; in emlxs_pkt_abort()
3539 if (nlp->nlp_tx[channelno].q_first == in emlxs_pkt_abort()
3541 nlp->nlp_tx[channelno].q_first = in emlxs_pkt_abort()
3565 if ((nlp->nlp_ptx[channelno].q_first) || in emlxs_pkt_abort()
3566 (nlp->nlp_tx[channelno].q_first && in emlxs_pkt_abort()
3578 cp->nodeq.q_first = nlp->nlp_next[channelno]; in emlxs_pkt_abort()
3584 if (cp->nodeq.q_first == (void *)nlp && in emlxs_pkt_abort()
[all …]
H A Demlxs_mbox.c3805 if (hba->mbox_queue.q_first) { in emlxs_mb_put()
3818 hba->mbox_queue.q_first = (uint8_t *)mbq; in emlxs_mb_put()
3851 if (hba->mbox_queue.q_first) { in emlxs_mb_get()
3852 p_first = (MAILBOXQ *)hba->mbox_queue.q_first; in emlxs_mb_get()
3853 hba->mbox_queue.q_first = (uint8_t *)p_first->next; in emlxs_mb_get()
3855 if (hba->mbox_queue.q_first == NULL) { in emlxs_mb_get()
/onnv-gate/usr/src/uts/common/inet/
H A Dmi.c1101 ASSERT(mtb->mtb_q->q_first == mp || in mi_timer()
1111 ASSERT(mtb->mtb_q->q_first == mp || in mi_timer()
1119 ASSERT(mtb->mtb_q->q_first == mp || in mi_timer()
1202 ASSERT(mtb->mtb_q->q_first == mp || in mi_timer_free()
1210 ASSERT(mtb->mtb_q->q_first == mp || in mi_timer_free()
1217 ASSERT(mtb->mtb_q == NULL || mtb->mtb_q->q_first != mp); in mi_timer_free()
1245 ASSERT(mtb->mtb_q->q_first == mp || in mi_timer_move()
1248 ASSERT(mtb->mtb_q->q_first != mp && in mi_timer_move()
1262 ASSERT(mtb->mtb_q->q_first == mp || in mi_timer_move()
1265 ASSERT(mtb->mtb_q->q_first != mp && in mi_timer_move()
[all …]
/onnv-gate/usr/src/uts/common/io/
H A Dstream.c1941 if ((bp = q->q_first) == 0) { in getq_noenab()
2032 q->q_first = mp2; in getq_noenab()
2034 if ((q->q_first = bp->b_next) == NULL) in getq_noenab()
2037 q->q_first->b_prev = NULL; in getq_noenab()
2048 if ((q->q_first = bp->b_next) == NULL) in getq_noenab()
2051 q->q_first->b_prev = NULL; in getq_noenab()
2259 q->q_first = mp->b_next; in rmvq_noenab()
2314 if (q->q_first == NULL) in flushq_common()
2318 mp = q->q_first; in flushq_common()
2319 q->q_first = NULL; in flushq_common()
[all …]
H A Dlogindmux.c541 if (q->q_first != NULL || !canputnext(qp)) { in logdmuxuwput()
650 if ((q->q_first != NULL) && (queclass(mp) < QPCTL) && in logdmuxlrput()
738 if (q->q_first != NULL || !canputnext(qp)) { in logdmuxlrput()
822 if (q->q_first != NULL || !canputnext(qp)) { in logdmuxlrput()
1219 mp = q->q_first; in flushq_dataonly()
H A Dtirdwr.c384 for (mp = q->q_next->q_first; mp != NULL; mp = mp->b_next) { in check_strhead()
428 for (mp = q->q_first; mp != NULL; ) { in strip_strhead()
H A Dtty_pty.c389 q->q_first != NULL && in ptcread()
829 q->q_first != NULL && !(pty->pt_flags & PF_STOPPED)) { in ptcioctl()
833 for (mp = q->q_first; mp != NULL; mp = mp->b_next) in ptcioctl()
1011 q->q_first != NULL && !(pty->pt_flags & PF_STOPPED)) { in ptcpoll()
H A Dtelmod.c363 ((q->q_first) || ((tmip->flags & TEL_STOPPED) && in telmodrput()
666 (q->q_first)) { in telmodwput()
838 if (!canputnext(q) || q->q_first != NULL) in telmodwput()
H A Drlmod.c378 ((q->q_first) || in rlmodrput()
438 if (canputnext(q) && q->q_first == NULL) { in rlmodrput()
628 if ((q->q_first || rmip->rl_expdat) && mp->b_datap->db_type < QPCTL) { in rlmodwput()
H A Dpts.c590 ASSERT(RD(qp)->q_first == NULL); in ptswput()
H A Dtl.c1646 if (tep->te_wq->q_first && (IS_CLTS(tep) || IS_COTSORD(tep))) { in tl_close_ser()
1817 if ((tep->te_state == TS_IDLE) && !wq->q_first) { in tl_wput()
1828 if (wq->q_first != NULL) { in tl_wput()
1946 (tep->te_wq->q_first == NULL) && in tl_wput_data_ser()
1987 while ((wq->q_first != NULL) && !tep->te_nowsrv) { in tl_wsrv()
2058 ASSERT(rq->q_first == NULL); in tl_rsrv()
4953 if (!tep->te_closing && (wq->q_first != NULL)) { in tl_unitdata_ser()
5836 ASSERT(tep->te_rq->q_first == NULL); in tl_icon_sendmsgs()
6177 (void) insq(wq, wq->q_first, mp); in tl_memrecover()
H A Dtimod.c591 if (q->q_first != 0 && mp->b_datap->db_type < QPCTL) { in timodrput()
1251 if (q->q_first != 0) in timodrproc()
1494 if (q->q_first != 0 && mp->b_datap->db_type < QPCTL) { in timodwput()
2669 bp = rq->q_first; in ti_expind_on_rdqueues()
H A Dzcons.c930 if (qp->q_first == NULL && bcanputnext(RD(zc_switch(qp)), mp->b_band)) { in zc_wput()
/onnv-gate/usr/src/cmd/mdb/common/modules/genunix/
H A Dlog.c57 (uintptr_t)q.q_first) == -1) { in msgbuf()
H A Dmemory.c377 struct vn_htable_list *q_first = hp->vn_q_first; in vn_get() local
380 if (q_first->vn_ptr == ptr) { in vn_get()
381 vp->v_flag = q_first->vn_flag; in vn_get()
432 hent->vn_q_next = q_first; in vn_get()
433 q_first->vn_q_prev = hent; in vn_get()
H A Dstreams.c417 for (maddr = (uintptr_t)q.q_first; maddr != NULL; nblks++) { in queue()
455 addr, name, q.q_flag, nblks, q.q_first); in queue()
/onnv-gate/usr/src/uts/common/os/
H A Dstreamio.c679 ASSERT(qp->q_first == NULL); /* No more delayed write */ in strclose()
978 q->q_first == NULL && in strget()
1368 while ((((bp = q->q_first)) != NULL) && in strread()
1807 (q->q_first == bp))) in strrput()
2121 if (q->q_first || (*bp->b_rptr == SIGTSTP && in strrput_nondata()
2176 if ((q->q_first == NULL) || in strrput_nondata()
2177 (q->q_first->b_datap->db_type < QPCTL)) in strrput_nondata()
3611 size = msgdsize(rdq->q_first); in strioctl()
3612 for (mp = rdq->q_first; mp != NULL; mp = mp->b_next) in strioctl()
3654 for (mp = rdq->q_first; mp != NULL; mp = mp->b_next) in strioctl()
[all …]
/onnv-gate/usr/src/uts/common/io/ppp/sppp/
H A Dsppp.c514 (WR(nextsib->sps_rq)->q_first != NULL)) { in sppp_ioctl()
1340 if (WR(sps->sps_rq)->q_first != NULL) in sppp_outer_ioctl()
1345 if (WR(nextsib->sps_rq)->q_first != NULL) { in sppp_outer_ioctl()
1409 if (WR(sps->sps_rq)->q_first != NULL) in sppp_outer_ioctl()
1413 if (WR(nextsib->sps_rq)->q_first != NULL) { in sppp_outer_ioctl()
1617 if (q->q_first != NULL || in sppp_send()
1772 WR(nextsib->sps_rq)->q_first != NULL) in sppp_lwsrv()
1776 if (WR(nextsib->sps_rq)->q_first != NULL) { in sppp_lwsrv()
/onnv-gate/usr/src/uts/common/rpc/
H A Drpcmod.c1184 if ((mp1 = q->q_first) != NULL) { in mir_clnt_dup_request()
1967 if (q->q_first == NULL) { in mir_rsrv()
2017 if (q->q_first == NULL) in mir_rsrv()
2038 if (q->q_first == NULL) { in mir_rsrv()
2840 if (q->q_first == NULL) in mir_wsrv()
/onnv-gate/usr/src/uts/sun4u/starcat/io/
H A Dcvc.c495 if (q->q_first != NULL || cvcoutput_q == NULL || in cvc_wput()
624 if (q->q_first != NULL) { in cvc_wsrv()
/onnv-gate/usr/src/uts/common/sys/
H A Dstream.h113 struct msgb *q_first; /* Q9S: first message in Q */ member

123