Lines Matching refs:syncq_t
180 static syncq_t *sqhead;
181 static syncq_t *sqtail;
281 static syncq_t *new_syncq(void);
282 static void free_syncq(syncq_t *);
283 static void outer_insert(syncq_t *, syncq_t *);
284 static void outer_remove(syncq_t *, syncq_t *);
285 static void write_now(syncq_t *);
288 static void sqenable(syncq_t *);
289 static void sqfill_events(syncq_t *, queue_t *, mblk_t *, void (*)());
295 static void syncq_service(syncq_t *);
296 static void qwriter_outer_service(syncq_t *);
306 static void sq_run_events(syncq_t *);
309 static void blocksq(syncq_t *, ushort_t, int);
310 static void unblocksq(syncq_t *, ushort_t, int);
311 static int dropsq(syncq_t *, uint16_t);
312 static void emptysq(syncq_t *);
316 static void sqlist_insert(sqlist_t *, syncq_t *);
690 syncq_t *sq = &qip->qu_syncq; in queue_constructor()
751 syncq_t *sq = &qip->qu_syncq; in queue_destructor()
778 syncq_t *sq = buf; in syncq_constructor()
780 bzero(buf, sizeof (syncq_t)); in syncq_constructor()
793 syncq_t *sq = buf; in syncq_destructor()
867 syncq_cache = kmem_cache_create("syncq_cache", sizeof (syncq_t), 0, in strinit()
1412 syncq_t *rsq = qp->q_syncq; in wait_svc()
1413 syncq_t *wsq = wqp->q_syncq; in wait_svc()
1686 wait_syncq(syncq_t *sq) in wait_syncq()
1713 syncq_t *sq = q->q_syncq; in wait_q_syncq()
1735 syncq_t *passyncq; in mlink_file()
2016 syncq_t *passyncq; in munlink()
2101 syncq_t *sq = wrq->q_syncq; in munlink()
2113 syncq_t *sq, *outer; in munlink()
2179 syncq_t *sq = rq->q_syncq; in munlink()
2490 syncq_t *sq, *outer; in setq()
2645 syncq_t *sq; in hold_dm()
3353 syncq_t *sq; in allocq()
3415 syncq_t *sq, *outer; in freeq()
3761 syncq_t *sq; in streams_sqbkgrnd_service()
3798 wait_sq_svc(syncq_t *sq) in wait_sq_svc()
3803 syncq_t *sq_chase; in wait_sq_svc()
3804 syncq_t *sq_curr; in wait_sq_svc()
3839 sqenable(syncq_t *sq) in sqenable()
4622 syncq_t *sq = sql->sql_sq; in strlock()
4859 syncq_t *sq = qp->q_syncq; in removeq()
4860 syncq_t *wsq = wqp->q_syncq; in removeq()
5009 blocksq(syncq_t *sq, ushort_t flag, int maxcnt) in blocksq()
5071 unblocksq(syncq_t *sq, uint16_t resetflag, int isouter) in unblocksq()
5106 dropsq(syncq_t *sq, uint16_t resetflag) in dropsq()
5131 emptysq(syncq_t *sq) in emptysq()
5156 sqlist_insert(sqlist_t *sqlist, syncq_t *sqp) in sqlist_insert()
5380 entersq(syncq_t *sq, int entrypoint) in entersq()
5499 leavesq(syncq_t *sq, int entrypoint) in leavesq()
5566 syncq_t *sq = qp->q_syncq; in claimq()
5583 syncq_t *sq = qp->q_syncq; in releaseq()
5642 static syncq_t *
5649 free_syncq(syncq_t *sq) in free_syncq()
5725 outer_enter(syncq_t *outer, uint16_t flags) in outer_enter()
5727 syncq_t *sq; in outer_enter()
5815 outer_exit(syncq_t *outer) in outer_exit()
5817 syncq_t *sq; in outer_exit()
5879 outer_insert(syncq_t *outer, syncq_t *sq) in outer_insert()
5910 outer_remove(syncq_t *outer, syncq_t *sq) in outer_remove()
5941 queue_writer(syncq_t *outer, void (*func)(), queue_t *q, mblk_t *mp) in queue_writer()
5979 syncq_t *osq, *sq, *outer; in qwriter_outer()
6104 write_now(syncq_t *outer) in write_now()
6172 sq_run_events(syncq_t *sq) in sq_run_events()
6256 sqfill_events(syncq_t *sq, queue_t *q, mblk_t *mp, void (*func)()) in sqfill_events()
6370 drain_syncq(syncq_t *sq) in drain_syncq()
6645 qdrain_syncq(syncq_t *sq, queue_t *q) in qdrain_syncq()
6858 qfill_syncq(syncq_t *sq, queue_t *q, mblk_t *mp) in qfill_syncq()
6951 flush_syncq(syncq_t *sq, queue_t *qp) in flush_syncq()
7095 syncq_t *sq; in propagate_syncq()
7097 syncq_t *nsq; in propagate_syncq()
7254 syncq_t *sq = q->q_syncq; in qwriter_inner()
7298 callbparams_alloc(syncq_t *sq, void (*func)(void *), void *arg, int kmflags) in callbparams_alloc()
7329 callbparams_free(syncq_t *sq, callbparams_t *cbp) in callbparams_free()
7347 callbparams_free_id(syncq_t *sq, callbparams_id_t id, int32_t flag) in callbparams_free_id()
7374 syncq_t *sq; in qcallbwrapper()
7469 putnext_tail(syncq_t *sq, queue_t *qp, uint32_t passflags) in putnext_tail()
7812 syncq_t *sq; in pass_wput()
8281 syncq_service(syncq_t *sq) in syncq_service()
8299 qwriter_outer_service(syncq_t *outer) in qwriter_outer_service()