Lines Matching refs:ASSERT

411 	ASSERT(el->link == NULL);				\
447 ASSERT(curr == el); \
472 ASSERT(MUTEX_HELD(SQLOCK(sq))); \
475 ASSERT((qp->q_sqprev == NULL) && (qp->q_sqnext == NULL)); \
479 ASSERT(sq == qp->q_syncq); \
534 ASSERT(MUTEX_HELD(SQLOCK(sq))); \
535 ASSERT(qp->q_sqflags & Q_SQQUEUED); \
536 ASSERT(sq->sq_head != NULL && sq->sq_tail != NULL); \
537 ASSERT((sq->sq_flags & SQ_MESSAGES) != 0); \
539 ASSERT(qp->q_sqnext != NULL || sq->sq_tail == qp); \
540 ASSERT(qp->q_sqprev != NULL || sq->sq_head == qp); \
541 ASSERT(sq->sq_nqueues != 0); \
567 ASSERT(sq->sq_head != NULL || sq->sq_evhead != NULL || \
582 ASSERT(MUTEX_HELD(QLOCK(qp))); \
583 ASSERT(qp->q_sqhead == NULL || \
587 ASSERT(qp->q_syncqmsgs != 0); /* Wraparound */ \
594 ASSERT(qp->q_syncqmsgs > 0); \
599 ASSERT(MUTEX_HELD(SQLOCK(sq))); \
604 ASSERT((sq)->sq_type & SQ_CIPUT); \
606 ASSERT(MUTEX_HELD(&cip[i].ciputctrl_lock)); \
614 ASSERT(MUTEX_HELD(SQLOCK(sq))); \
619 ASSERT((sq)->sq_type & SQ_CIPUT); \
621 ASSERT(MUTEX_HELD(&cip[i].ciputctrl_lock)); \
631 ASSERT(MUTEX_HELD(&stp->sd_qlock)); \
634 ASSERT(stp->sd_nqueues > 0); \
636 ASSERT(!(q->q_flag & QINSERVICE)); \
641 ASSERT(stp->sd_nqueues == 0); \
642 ASSERT((stp->sd_qhead == NULL) && (stp->sd_qtail == NULL)); \
756 ASSERT(qp->q_sqhead == NULL); in queue_destructor()
757 ASSERT(wqp->q_sqhead == NULL); in queue_destructor()
758 ASSERT(qp->q_sqnext == NULL); in queue_destructor()
759 ASSERT(wqp->q_sqnext == NULL); in queue_destructor()
760 ASSERT(qp->q_rwcnt == 0); in queue_destructor()
761 ASSERT(wqp->q_rwcnt == 0); in queue_destructor()
798 ASSERT(sq->sq_head == NULL); in syncq_destructor()
799 ASSERT(sq->sq_tail == NULL); in syncq_destructor()
800 ASSERT(sq->sq_evhead == NULL); in syncq_destructor()
801 ASSERT(sq->sq_evtail == NULL); in syncq_destructor()
802 ASSERT(sq->sq_callbpend == NULL); in syncq_destructor()
803 ASSERT(sq->sq_callbflags == 0); in syncq_destructor()
804 ASSERT(sq->sq_outer == NULL); in syncq_destructor()
805 ASSERT(sq->sq_onext == NULL); in syncq_destructor()
806 ASSERT(sq->sq_oprev == NULL); in syncq_destructor()
807 ASSERT(sq->sq_next == NULL); in syncq_destructor()
808 ASSERT(sq->sq_needexcl == 0); in syncq_destructor()
809 ASSERT(sq->sq_svcflags == 0); in syncq_destructor()
810 ASSERT(sq->sq_servcount == 0); in syncq_destructor()
811 ASSERT(sq->sq_nqueues == 0); in syncq_destructor()
812 ASSERT(sq->sq_pri == 0); in syncq_destructor()
813 ASSERT(sq->sq_count == 0); in syncq_destructor()
814 ASSERT(sq->sq_rmqcount == 0); in syncq_destructor()
815 ASSERT(sq->sq_cancelid == 0); in syncq_destructor()
816 ASSERT(sq->sq_ciputctrl == NULL); in syncq_destructor()
817 ASSERT(sq->sq_nciputctrl == 0); in syncq_destructor()
818 ASSERT(sq->sq_type == 0); in syncq_destructor()
819 ASSERT(sq->sq_flags == 0); in syncq_destructor()
849 ASSERT(cip[i].ciputctrl_count & SQ_FASTPUT); in ciputctrl_destructor()
881 ASSERT(n_ciputctrl >= 1); in strinit()
938 ASSERT(vp->v_stream); in str_sendsig()
957 ASSERT(MUTEX_HELD(&proc->p_lock)); in dosendsig()
1078 ASSERT(ssp->ss_pid == pidp->pid_id); in strsendsig()
1152 ASSERT(!is_insert); in qattach()
1158 ASSERT(str == STREAMSTAB(major)); in qattach()
1161 ASSERT(qflag & QISDRV); in qattach()
1205 ASSERT(qprocsareon(rq)); in qattach()
1230 ASSERT(qp->q_flag & QREADR); in qreopen()
1247 ASSERT(qprocsareon(_RD(qp))); in qreopen()
1262 ASSERT(STREAM(qp)->sd_flag & (STRCLOSE|STWOPEN|STRPLUMB)); in qdetach()
1285 ASSERT((qp->q_flag & QWCLOSE) && (wqp->q_flag & QWCLOSE)); in qdetach()
1305 ASSERT(flush_syncq(qp->q_syncq, qp) == 0); in qdetach()
1306 ASSERT(flush_syncq(wqp->q_syncq, wqp) == 0); in qdetach()
1307 ASSERT((qp->q_flag & QPERMOD) || in qdetach()
1312 ASSERT(qp->q_fp != NULL || qp->q_flag & QISDRV); in qdetach()
1326 ASSERT(qp->q_flag & QREADR); in disable_svc()
1341 ASSERT(qp->q_flag & QREADR); in enable_svc()
1394 ASSERT(qp->q_flag & QREADR); in wait_svc()
1451 ASSERT((flag & (U_TO_K | K_TO_K)) == U_TO_K || in putiocd()
1457 ASSERT(bp->b_datap->db_type == M_COPYIN); in putiocd()
1464 ASSERT(count >= 0); in putiocd()
1496 ASSERT(bp->b_datap->db_type == M_COPYOUT); in getiocd()
1499 ASSERT(count >= 0); in getiocd()
1508 ASSERT(count == 0); in getiocd()
1535 ASSERT(lnk_id != 0); /* this should never wrap in practice */ in alloclink()
1646 ASSERT((type & LINKTYPEMASK) == LINKPERSIST); in findlinks()
1677 ASSERT(q != NULL); in getendq()
1770 ASSERT(ns != NULL); in mlink_file()
1772 ASSERT(ss != NULL); in mlink_file()
1874 ASSERT((rq->q_flag & QMT_TYPEMASK) == QMTSAFE); in mlink_file()
1875 ASSERT(rq->q_syncq == SQ(rq) && _WR(rq)->q_syncq == SQ(rq)); in mlink_file()
1883 ASSERT(dp->d_str == str); in mlink_file()
1915 ASSERT((cmd == I_LINK) || (cmd == I_PLINK)); in mlink_file()
2033 ASSERT(MUTEX_HELD(&muxifier)); in munlink()
2181 ASSERT((rq->q_flag & QPERMOD) || in munlink()
2206 ASSERT(flush_syncq(rq->q_syncq, rq) == 0); in munlink()
2207 ASSERT(flush_syncq(wrq->q_syncq, wrq) == 0); in munlink()
2225 ASSERT((rq->q_flag & QMT_TYPEMASK) == QMTSAFE); in munlink()
2226 ASSERT(rq->q_syncq == SQ(rq) && _WR(rq)->q_syncq == SQ(rq)); in munlink()
2239 ASSERT(((flag & LINKTYPEMASK) == LINKNORMAL) || in munlink()
2342 ASSERT(np->mn_outp != NULL); in mux_rmvedge()
2356 ASSERT(0); /* should not reach here */ in mux_rmvedge()
2516 ASSERT(rq->q_flag & QREADR); in setq()
2517 ASSERT((qflag & QMT_TYPEMASK) != 0); in setq()
2536 ASSERT(wq->q_syncq->sq_outer == outer); in setq()
2541 ASSERT(sq->sq_outer == NULL); in setq()
2542 ASSERT(sq->sq_onext == NULL && sq->sq_oprev == NULL); in setq()
2556 ASSERT(rq->q_syncq == NULL || (rq->q_syncq->sq_head == NULL && in setq()
2558 ASSERT(wq->q_syncq == NULL || (wq->q_syncq->sq_head == NULL && in setq()
2563 ASSERT(rq->q_syncq->sq_nciputctrl == n_ciputctrl - 1); in setq()
2566 ASSERT(ciputctrl_cache != NULL); in setq()
2574 ASSERT(wq->q_syncq->sq_nciputctrl == n_ciputctrl - 1); in setq()
2577 ASSERT(ciputctrl_cache != NULL); in setq()
2584 ASSERT(sq->sq_head == NULL && sq->sq_tail == NULL); in setq()
2585 ASSERT(sq->sq_outer == NULL); in setq()
2586 ASSERT(sq->sq_onext == NULL && sq->sq_oprev == NULL); in setq()
2592 ASSERT((sq->sq_flags & ~SQ_TYPES_IN_FLAGS) == 0); in setq()
2604 ASSERT((sq->sq_svcflags & SQ_SERVICE) == 0); in setq()
2628 ASSERT(sq->sq_outer == NULL && sq->sq_onext == NULL && in setq()
2639 ASSERT(sq->sq_outer == NULL && sq->sq_onext == NULL && in setq()
2646 ASSERT(outer->sq_outer == NULL); in setq()
2651 ASSERT((rq->q_syncq->sq_flags & SQ_TYPES_IN_FLAGS) == in setq()
2653 ASSERT((wq->q_syncq->sq_flags & SQ_TYPES_IN_FLAGS) == in setq()
2655 ASSERT((rq->q_flag & QMT_TYPEMASK) == (qflag & QMT_TYPEMASK)); in setq()
2674 ASSERT(str != NULL); in hold_dm()
2675 ASSERT(qflag & (QPERMOD | QMTOUTPERIM)); in hold_dm()
2692 ASSERT(qflag & QMTOUTPERIM); in hold_dm()
2725 ASSERT(dmp->dm_ref > 0); in rele_dm()
2735 ASSERT(p == dmp); in rele_dm()
2770 ASSERT(uiop != NULL); in strmakemsg()
2814 ASSERT(cr != NULL); in strmakectl()
2895 ASSERT(cr != NULL); in strmakedata()
2908 ASSERT(uiop); in strmakedata()
2929 ASSERT(wroff <= dp->db_lim - bp->b_wptr); in strmakedata()
3033 ASSERT(MUTEX_HELD(&stp->sd_lock)); in strwaitq()
3180 ASSERT(mutex_owned(&stp->sd_lock)); in straccess()
3289 ASSERT(bp->b_wptr >= bp->b_rptr); in xmsgsize()
3343 ASSERT(MUTEX_NOT_HELD(&stp->sd_lock)); in shfree()
3355 ASSERT(stp->sd_nciputctrl == n_ciputctrl - 1); in shfree()
3358 ASSERT(ciputctrl_cache != NULL); in shfree()
3363 ASSERT(stp->sd_qhead == NULL); in shfree()
3364 ASSERT(stp->sd_qtail == NULL); in shfree()
3365 ASSERT(stp->sd_nqueues == 0); in shfree()
3442 ASSERT(qp->q_flag & QREADR); in freeq()
3454 ASSERT(qp->q_syncqmsgs == 0 && wqp->q_syncqmsgs == 0); in freeq()
3468 ASSERT(!(qp->q_flag & QENAB)); in freeq()
3469 ASSERT(!(wqp->q_flag & QENAB)); in freeq()
3485 ASSERT((qp->q_sqflags & (Q_SQQUEUED | Q_SQDRAINING)) == 0); in freeq()
3486 ASSERT((wqp->q_sqflags & (Q_SQQUEUED | Q_SQDRAINING)) == 0); in freeq()
3487 ASSERT(MUTEX_NOT_HELD(QLOCK(qp))); in freeq()
3488 ASSERT(MUTEX_NOT_HELD(QLOCK(wqp))); in freeq()
3490 ASSERT(MUTEX_NOT_HELD(SQLOCK(sq))); in freeq()
3491 ASSERT(sq->sq_head == NULL && sq->sq_tail == NULL); in freeq()
3492 ASSERT(sq->sq_outer == NULL); in freeq()
3493 ASSERT(sq->sq_onext == NULL && sq->sq_oprev == NULL); in freeq()
3494 ASSERT(sq->sq_callbpend == NULL); in freeq()
3495 ASSERT(sq->sq_needexcl == 0); in freeq()
3498 ASSERT(sq->sq_nciputctrl == n_ciputctrl - 1); in freeq()
3501 ASSERT(ciputctrl_cache != NULL); in freeq()
3507 ASSERT(qp->q_first == NULL && wqp->q_first == NULL); in freeq()
3508 ASSERT(qp->q_count == 0 && wqp->q_count == 0); in freeq()
3509 ASSERT(qp->q_mblkcnt == 0 && wqp->q_mblkcnt == 0); in freeq()
3659 ASSERT(q->q_qinfo->qi_srvp); in runservice()
3768 ASSERT(q != NULL); in streams_qbkgrnd_service()
3773 ASSERT(qhead == NULL && qtail == NULL); in streams_qbkgrnd_service()
3807 ASSERT(sq != NULL); in streams_sqbkgrnd_service()
3808 ASSERT(sq->sq_svcflags & SQ_BGTHREAD); in streams_sqbkgrnd_service()
3831 ASSERT(sq->sq_servcount == 1); in wait_sq_svc()
3871 ASSERT(MUTEX_HELD(SQLOCK(sq))); in sqenable()
3950 ASSERT(dbp->db_mblk == mp); in freebs_enqueue()
3951 ASSERT(qindex < esbq_nelem); in freebs_enqueue()
4003 ASSERT(MUTEX_HELD(&eqp->eq_lock)); in esballoc_process_queue()
4085 ASSERT(MUTEX_HELD(&eqp->eq_lock)); in esballoc_set_timer()
4120 ASSERT(MUTEX_HELD(QLOCK(q))); in setqback()
4152 ASSERT((copyflag & K_TO_K) == 0); in strcopyin()
4156 ASSERT(copyflag & K_TO_K); in strcopyin()
4169 ASSERT(copyflag & K_TO_K); in strcopyout()
4185 ASSERT(MUTEX_HELD(&stp->sd_lock)); in strsignal_nolock()
4223 ASSERT(mutex_owned(&stp->sd_lock)); in strhup()
4248 ASSERT(STRMATED(q->q_stream) || STREAM(q) == STREAM(nq)); in backenable()
4267 ASSERT(frozenstr(q)); in backenable()
4268 ASSERT(MUTEX_HELD(QLOCK(q))); in backenable()
4269 ASSERT(MUTEX_HELD(QLOCK(nq))); in backenable()
4303 ASSERT(MUTEX_HELD(&stp->sd_lock)); in strgeterr()
4304 ASSERT((flags_to_check & ~(STRDERR|STWRERR|STRHUP|STPLEX)) == 0); in strgeterr()
4447 ASSERT(MUTEX_HELD(&stp->sd_lock)); in strendplumb()
4448 ASSERT(stp->sd_flag & STRPLUMB); in strendplumb()
4651 ASSERT(sq->sq_rmqcount <= count); in strlock()
4696 ASSERT(count == sq->sq_rmqcount); in strlock()
4778 ASSERT(stp->sd_vnode->v_type != VFIFO); in insertq()
4788 ASSERT(after->q_flag & QREADR); in insertq()
4789 ASSERT(new->q_flag & QREADR); in insertq()
4821 ASSERT(_SAMESTR(new) == O_SAMESTR(new)); in insertq()
4822 ASSERT(_SAMESTR(wnew) == O_SAMESTR(wnew)); in insertq()
4823 ASSERT(_SAMESTR(after) == O_SAMESTR(after)); in insertq()
4824 ASSERT(_SAMESTR(wafter) == O_SAMESTR(wafter)); in insertq()
4886 ASSERT(stp); in removeq()
4890 ASSERT(qp->q_flag&QREADR); in removeq()
4944 ASSERT(wqp->q_next == NULL || backq(qp)->q_next == qp); in removeq()
4945 ASSERT(qp->q_next == NULL || backq(wqp)->q_next == wqp); in removeq()
4960 ASSERT(_SAMESTR(stp->sd_wrq) == O_SAMESTR(stp->sd_wrq)); in removeq()
4961 ASSERT(_SAMESTR(_RD(stp->sd_wrq)) == O_SAMESTR(_RD(stp->sd_wrq))); in removeq()
5052 ASSERT(sq->sq_needexcl != 0); /* wraparound */ in blocksq()
5069 ASSERT(maxcnt == -1 || count == maxcnt); in blocksq()
5100 ASSERT(resetflag != SQ_WRITER); in unblocksq()
5101 ASSERT(sq->sq_flags & resetflag); in unblocksq()
5135 ASSERT(sq->sq_flags & resetflag); in dropsq()
5194 ASSERT((char *)new_sqlp < (char *)sqlist + sqlist->sqlist_size); in sqlist_insert()
5235 ASSERT(q->q_flag & QREADR); in sqlist_build()
5294 ASSERT(stp != NULL); in strblock()
5328 ASSERT(stp != NULL); in strunblock()
5416 ASSERT(sq); in entersq()
5417 ASSERT(c_inner && c_outer); in entersq()
5428 ASSERT(sq->sq_needexcl != 0); /* wraparound */ in entersq()
5452 ASSERT(sq->sq_needexcl > 0); in entersq()
5501 ASSERT(sq->sq_count != 0); /* Wraparound */ in entersq()
5504 ASSERT(sq->sq_count == 1); in entersq()
5536 ASSERT(sq); in leavesq()
5537 ASSERT(c_inner && c_outer); in leavesq()
5557 ASSERT(sq->sq_count != 0); in leavesq()
5559 ASSERT((flags & SQ_EXCL) || (type & c_inner)); in leavesq()
5562 ASSERT(MUTEX_NOT_HELD(SQLOCK(sq))); in leavesq()
5570 ASSERT(sq->sq_count != 0); in leavesq()
5572 ASSERT((flags & SQ_EXCL) || (type & c_inner)); in leavesq()
5594 ASSERT(sq->sq_count != 0); /* Wraparound */ in claimq()
5611 ASSERT(sq->sq_count > 0); in releaseq()
5647 ASSERT(stp->sd_refcnt != 0); /* Wraparound */ in claimstr()
5660 ASSERT(stp->sd_refcnt != 0); in releasestr()
5675 ASSERT(sq->sq_head == NULL); in free_syncq()
5676 ASSERT(sq->sq_outer == NULL); in free_syncq()
5677 ASSERT(sq->sq_callbpend == NULL); in free_syncq()
5678 ASSERT((sq->sq_onext == NULL && sq->sq_oprev == NULL) || in free_syncq()
5682 ASSERT(sq->sq_nciputctrl == n_ciputctrl - 1); in free_syncq()
5685 ASSERT(ciputctrl_cache != NULL); in free_syncq()
5755 ASSERT(outer->sq_outer == NULL && outer->sq_onext != NULL && in outer_enter()
5757 ASSERT(flags & SQ_WRITER); in outer_enter()
5766 ASSERT(!(outer->sq_flags & SQ_WRITER)); in outer_enter()
5769 ASSERT(outer->sq_count != 0); /* wraparound */ in outer_enter()
5845 ASSERT(outer->sq_outer == NULL && outer->sq_onext != NULL && in outer_exit()
5847 ASSERT(MUTEX_NOT_HELD(SQLOCK(outer))); in outer_exit()
5859 ASSERT(outer->sq_flags & SQ_WRITER); in outer_exit()
5874 ASSERT(!(outer->sq_flags & SQ_QUEUED)); in outer_exit()
5889 ASSERT(outer->sq_count > 0); in outer_exit()
5905 ASSERT(outer->sq_outer == NULL && outer->sq_onext != NULL && in outer_insert()
5907 ASSERT(sq->sq_outer == NULL && sq->sq_onext == NULL && in outer_insert()
5912 ASSERT(outer->sq_flags & SQ_BLOCKED); in outer_insert()
5913 ASSERT(!(outer->sq_flags & SQ_WRITER)); in outer_insert()
5936 ASSERT(outer->sq_outer == NULL && outer->sq_onext != NULL && in outer_remove()
5938 ASSERT(sq->sq_outer == outer); in outer_remove()
5942 ASSERT(outer->sq_flags & SQ_BLOCKED); in outer_remove()
5943 ASSERT(!(outer->sq_flags & SQ_WRITER)); in outer_remove()
5967 ASSERT(MUTEX_HELD(SQLOCK(outer))); in queue_writer()
5973 ASSERT(outer->sq_count != 0); /* Wraparound */ in queue_writer()
5983 ASSERT(outer->sq_flags & SQ_EVENTS); in queue_writer()
6011 ASSERT(outer->sq_outer == NULL && outer->sq_onext != NULL && in qwriter_outer()
6047 ASSERT(osq->sq_flags & SQ_WRITER); in qwriter_outer()
6058 ASSERT(outer->sq_count != 0); /* wraparound */ in qwriter_outer()
6101 ASSERT(outer->sq_count > 0); in qwriter_outer()
6103 ASSERT(outer->sq_flags & SQ_WRITER); in qwriter_outer()
6134 ASSERT(MUTEX_HELD(SQLOCK(outer))); in write_now()
6135 ASSERT(outer->sq_outer == NULL && outer->sq_onext != NULL && in write_now()
6142 ASSERT(!(outer->sq_flags & SQ_MESSAGES)); in write_now()
6143 ASSERT((outer->sq_flags & SQ_EVENTS)); in write_now()
6150 ASSERT(outer->sq_count != 0); in write_now()
6160 ASSERT(func != NULL); in write_now()
6171 ASSERT(MUTEX_HELD(SQLOCK(outer))); in write_now()
6203 ASSERT(MUTEX_HELD(SQLOCK(sq))); in sq_run_events()
6204 ASSERT((sq->sq_outer == NULL && sq->sq_onext == NULL && in sq_run_events()
6209 ASSERT(flags & SQ_EXCL); in sq_run_events()
6210 ASSERT(sq->sq_count == 1); in sq_run_events()
6224 ASSERT(bp->b_queue->q_syncq == sq); in sq_run_events()
6225 ASSERT(sq->sq_flags & SQ_EVENTS); in sq_run_events()
6229 ASSERT(func != NULL); in sq_run_events()
6235 ASSERT(sq->sq_evhead == bp); in sq_run_events()
6240 ASSERT(sq->sq_evtail == bp); in sq_run_events()
6245 ASSERT(bp->b_datap->db_ref != 0); in sq_run_events()
6256 ASSERT(flags & SQ_EXCL); in sq_run_events()
6258 ASSERT(sq->sq_evhead == NULL && sq->sq_evtail == NULL); in sq_run_events()
6259 ASSERT(!(sq->sq_flags & SQ_EVENTS)); in sq_run_events()
6284 ASSERT(MUTEX_HELD(SQLOCK(sq))); in sqfill_events()
6285 ASSERT(func != NULL); in sqfill_events()
6298 ASSERT(sq->sq_evtail != NULL); in sqfill_events()
6299 ASSERT(sq->sq_evtail->b_next == NULL); in sqfill_events()
6300 ASSERT(sq->sq_flags & SQ_EVENTS); in sqfill_events()
6338 ASSERT((sq->sq_flags & SQ_EXCL) == 0); in sqfill_events()
6340 ASSERT(sq->sq_count == 0); in sqfill_events()
6362 ASSERT(!(sq->sq_flags & SQ_EXCL)); in sqfill_events()
6404 ASSERT(MUTEX_HELD(SQLOCK(sq))); in drain_syncq()
6405 ASSERT((sq->sq_outer == NULL && sq->sq_onext == NULL && in drain_syncq()
6422 ASSERT(sq->sq_servcount != 0); in drain_syncq()
6446 ASSERT(sq->sq_servcount != 0); in drain_syncq()
6464 ASSERT(sq->sq_servcount != 0); in drain_syncq()
6485 ASSERT(sq->sq_count != 0); /* wraparound */ in drain_syncq()
6502 ASSERT(sq->sq_flags & SQ_EVENTS); in drain_syncq()
6512 ASSERT((flags & SQ_EXCL) == 0); in drain_syncq()
6527 ASSERT(sq->sq_flags & SQ_EXCL); in drain_syncq()
6535 ASSERT((sq->sq_flags & SQ_EXCL) || (type & SQ_CIPUT)); in drain_syncq()
6539 ASSERT(sq->sq_evhead == NULL); in drain_syncq()
6540 ASSERT(!(sq->sq_flags & SQ_EVENTS)); in drain_syncq()
6579 ASSERT(qp->q_sqflags & Q_SQDRAINING); in drain_syncq()
6587 ASSERT(MUTEX_HELD(SQLOCK(sq))); in drain_syncq()
6603 ASSERT((sq->sq_head == NULL) || (flags & SQ_GOAWAY) || in drain_syncq()
6609 ASSERT((flags & SQ_EXCL) == 0); in drain_syncq()
6622 ASSERT(sq->sq_count != 0); in drain_syncq()
6627 ASSERT(sq->sq_servcount != 0); in drain_syncq()
6678 ASSERT(q->q_syncq == sq); in qdrain_syncq()
6679 ASSERT(MUTEX_HELD(QLOCK(q))); in qdrain_syncq()
6680 ASSERT(MUTEX_NOT_HELD(SQLOCK(sq))); in qdrain_syncq()
6686 ASSERT((sq->sq_flags & (SQ_EXCL|SQ_CIPUT))); in qdrain_syncq()
6687 ASSERT(!((sq->sq_type & SQ_CIPUT) && (sq->sq_flags & SQ_EXCL))); in qdrain_syncq()
6688 ASSERT((sq->sq_type & SQ_CIPUT) || (sq->sq_flags & SQ_EXCL)); in qdrain_syncq()
6692 ASSERT((sq->sq_outer == NULL && sq->sq_onext == NULL && in qdrain_syncq()
6706 ASSERT(count >= 1); in qdrain_syncq()
6732 ASSERT(q->q_syncqmsgs == 0); in qdrain_syncq()
6762 ASSERT(bp->b_queue == q); in qdrain_syncq()
6763 ASSERT(bp->b_queue->q_syncq == sq); in qdrain_syncq()
6780 ASSERT(q->q_sqhead == bp); in qdrain_syncq()
6783 ASSERT(q->q_syncqmsgs > 0); in qdrain_syncq()
6786 ASSERT(bp->b_datap->db_ref != 0); in qdrain_syncq()
6830 ASSERT((q->q_sqhead == NULL) || in qdrain_syncq()
6833 ASSERT(MUTEX_HELD(QLOCK(q))); in qdrain_syncq()
6834 ASSERT(MUTEX_NOT_HELD(SQLOCK(sq))); in qdrain_syncq()
6838 ASSERT(q->q_syncqmsgs == 0); in qdrain_syncq()
6856 ASSERT(q->q_draining); in qdrain_syncq()
6884 ASSERT(MUTEX_NOT_HELD(SQLOCK(sq))); in qfill_syncq()
6885 ASSERT(MUTEX_NOT_HELD(QLOCK(q))); in qfill_syncq()
6886 ASSERT(sq->sq_count > 0); in qfill_syncq()
6887 ASSERT(q->q_syncq == sq); in qfill_syncq()
6888 ASSERT((sq->sq_outer == NULL && sq->sq_onext == NULL && in qfill_syncq()
6909 ASSERT(q->q_syncq == sq); in qfill_syncq()
6933 ASSERT(sq->sq_tail != NULL); in qfill_syncq()
6935 ASSERT((q->q_sqprev == NULL) && in qfill_syncq()
6938 ASSERT((q->q_sqprev != NULL) || in qfill_syncq()
6941 ASSERT(sq->sq_flags & SQ_QUEUED); in qfill_syncq()
6942 ASSERT(q->q_syncqmsgs != 0); in qfill_syncq()
6943 ASSERT(q->q_sqflags & Q_SQQUEUED); in qfill_syncq()
6989 ASSERT(sq->sq_flags & SQ_EVENTS); in flush_syncq()
7003 ASSERT(mp_next == NULL); in flush_syncq()
7026 ASSERT(q->q_syncq == sq); in flush_syncq()
7039 ASSERT(mp_head->b_queue && in flush_syncq()
7054 ASSERT(q->q_sqflags & Q_SQQUEUED); in flush_syncq()
7091 ASSERT(MUTEX_HELD(SQLOCK(sq))); in flush_syncq()
7131 ASSERT(MUTEX_HELD(SQLOCK(sq))); in propagate_syncq()
7139 ASSERT((qp->q_flag & QPERQ) || (sq->sq_count >= 1)); in propagate_syncq()
7152 ASSERT(MUTEX_HELD(SQLOCK(nsq))); in propagate_syncq()
7195 ASSERT(tail != NULL); in propagate_syncq()
7199 ASSERT(nqp->q_sqtail != NULL); in propagate_syncq()
7215 ASSERT(nqp->q_syncqmsgs != 0); in propagate_syncq()
7225 ASSERT(sq->sq_flags & SQ_EVENTS); in propagate_syncq()
7238 ASSERT(next == NULL); in propagate_syncq()
7285 ASSERT(count >= 1); in qwriter_inner()
7286 ASSERT(sq->sq_type & (SQ_CIPUT|SQ_CISVC)); in qwriter_inner()
7341 ASSERT(size >= sizeof (callbparams_t)); in callbparams_alloc()
7357 ASSERT(MUTEX_HELD(SQLOCK(sq))); in callbparams_free()
7375 ASSERT(MUTEX_HELD(SQLOCK(sq))); in callbparams_free_id()
7412 ASSERT(sq->sq_needexcl != 0); /* wraparound */ in qcallbwrapper()
7416 ASSERT(type & SQ_COCB); in qcallbwrapper()
7425 ASSERT(sq->sq_needexcl > 0); in qcallbwrapper()
7448 ASSERT(sq->sq_count != 0); /* Wraparound */ in qcallbwrapper()
7450 ASSERT(count == 0); in qcallbwrapper()
7452 ASSERT(sq->sq_needexcl > 0); in qcallbwrapper()
7497 ASSERT(MUTEX_HELD(SQLOCK(sq))); in putnext_tail()
7498 ASSERT(MUTEX_NOT_HELD(QLOCK(qp))); in putnext_tail()
7573 ASSERT(MUTEX_HELD(QLOCK(q))); in set_qfull()
7662 ASSERT(!(rnew->q_flag & _QINSERTING)); in set_nfsrv_ptr()
7758 ASSERT(rqp->q_next != NULL); in reset_nfsrv_ptr()
8194 ASSERT(MUTEX_HELD(QLOCK(q))); in qenable_locked()
8266 ASSERT((stp->sd_qhead == q) && (stp->sd_qtail == q)); in qenable_locked()
8267 ASSERT(q->q_link == NULL); in qenable_locked()
8303 ASSERT(!(q->q_flag & QINSERVICE)); in queue_service()
8304 ASSERT((q->q_flag & QENAB)); in queue_service()
8317 ASSERT(!(sq->sq_svcflags & SQ_SERVICE)); in syncq_service()
8318 ASSERT(sq->sq_servcount != 0); in syncq_service()
8319 ASSERT(sq->sq_next == NULL); in syncq_service()
8360 ASSERT(dbp->db_fthdr == NULL); in mblk_free()
8362 ASSERT(dbp->db_mblk == mp); in mblk_free()
8433 ASSERT(cr != NULL); in mblk_setcred()
8475 ASSERT(DB_TYPE(mp) == M_DATA); in lso_info_set()
8476 ASSERT((flags & ~HW_LSO_FLAGS) == 0); in lso_info_set()
8486 ASSERT(DB_TYPE(mp) == M_DATA); in lso_info_cleanup()
8654 ASSERT(cr != NULL); in str_stack_shutdown()