Searched refs:sq (Results 1 - 25 of 36) sorted by relevance

12

/illumos-gate/usr/src/uts/common/os/
H A Dputnext.c147 syncq_t *sq; local
174 sq = qp->q_syncq;
175 ASSERT(sq != NULL);
176 ASSERT(MUTEX_NOT_HELD(SQLOCK(sq)));
179 if (sq->sq_ciputctrl != NULL) {
181 ASSERT(sq->sq_flags & SQ_CIPUT);
182 ix = CPU->cpu_seqid & sq->sq_nciputctrl;
183 sqciplock = &sq->sq_ciputctrl[ix].ciputctrl_lock;
184 sqcipcount = &sq->sq_ciputctrl[ix].ciputctrl_count;
187 (sq
429 syncq_t *sq; local
[all...]
H A Dddi.c692 syncq_t *sq, *outer; local
698 * Perform the same operations as a leavesq(sq, SQ_OPENCLOSE)
705 sq = q->q_syncq;
706 ASSERT(sq);
707 is_sq_cioc = (sq->sq_type & SQ_CIOC) ? 1 : 0;
708 ASSERT(sq->sq_outer == NULL || sq->sq_outer->sq_flags & SQ_WRITER);
709 outer = sq->sq_outer;
717 mutex_enter(SQLOCK(sq));
719 SQ_PUTLOCKS_ENTER(sq);
805 syncq_t *sq, *outer; local
907 syncq_t *sq; local
996 syncq_t *sq; local
1025 syncq_t *sq; local
1067 syncq_t *sq = q->q_syncq; local
1105 syncq_t *sq = q->q_syncq; local
[all...]
H A Dstrsubr.c471 #define SQPUT_Q(sq, qp) \
473 ASSERT(MUTEX_HELD(SQLOCK(sq))); \
478 EQUIV(sq->sq_head, sq->sq_tail); \
480 ASSERT(sq == qp->q_syncq); \
482 EQUIV(sq->sq_head, (sq->sq_flags & SQ_MESSAGES)); \
484 IMPLY(sq->sq_head != NULL, sq->sq_head->q_sqprev == NULL);\
485 IMPLY(sq
694 syncq_t *sq = &qip->qu_syncq; local
755 syncq_t *sq = &qip->qu_syncq; local
782 syncq_t *sq = buf; local
797 syncq_t *sq = buf; local
1690 wait_syncq(syncq_t *sq) argument
1717 syncq_t *sq = q->q_syncq; local
2105 syncq_t *sq = wrq->q_syncq; local
2117 syncq_t *sq, *outer; local
2183 syncq_t *sq = rq->q_syncq; local
2505 syncq_t *sq, *outer; local
2660 syncq_t *sq; local
3368 syncq_t *sq; local
3430 syncq_t *sq, *outer; local
3776 syncq_t *sq; local
3813 wait_sq_svc(syncq_t *sq) argument
3854 sqenable(syncq_t *sq) argument
4637 syncq_t *sq = sql->sql_sq; local
4874 syncq_t *sq = qp->q_syncq; local
5024 blocksq(syncq_t *sq, ushort_t flag, int maxcnt) argument
5086 unblocksq(syncq_t *sq, uint16_t resetflag, int isouter) argument
5121 dropsq(syncq_t *sq, uint16_t resetflag) argument
5146 emptysq(syncq_t *sq) argument
5395 entersq(syncq_t *sq, int entrypoint) argument
5514 leavesq(syncq_t *sq, int entrypoint) argument
5581 syncq_t *sq = qp->q_syncq; local
5598 syncq_t *sq = qp->q_syncq; local
5664 free_syncq(syncq_t *sq) argument
5742 syncq_t *sq; local
5832 syncq_t *sq; local
5894 outer_insert(syncq_t *outer, syncq_t *sq) argument
5925 outer_remove(syncq_t *outer, syncq_t *sq) argument
5994 syncq_t *osq, *sq, *outer; local
6187 sq_run_events(syncq_t *sq) argument
6271 sqfill_events(syncq_t *sq, queue_t *q, mblk_t *mp, void (*func)()) argument
6385 drain_syncq(syncq_t *sq) argument
6660 qdrain_syncq(syncq_t *sq, queue_t *q) argument
6873 qfill_syncq(syncq_t *sq, queue_t *q, mblk_t *mp) argument
6966 flush_syncq(syncq_t *sq, queue_t *qp) argument
7110 syncq_t *sq; local
7269 syncq_t *sq = q->q_syncq; local
7313 callbparams_alloc(syncq_t *sq, void (*func)(void *), void *arg, int kmflags) argument
7344 callbparams_free(syncq_t *sq, callbparams_t *cbp) argument
7362 callbparams_free_id(syncq_t *sq, callbparams_id_t id, int32_t flag) argument
7389 syncq_t *sq; local
7484 putnext_tail(syncq_t *sq, queue_t *qp, uint32_t passflags) argument
7834 syncq_t *sq; local
8304 syncq_service(syncq_t *sq) argument
[all...]
H A Dsemaphore.c289 kthread_t *sq, *tp; local
293 sq = s->s_slpq;
299 if ((sq != NULL) && (s->s_count > 0)) {
300 tp = sq;
302 sq = sq->t_link;
309 s->s_slpq = sq;
335 kthread_t *sq, *tp; local
346 sq = s->s_slpq;
347 if (sq !
[all...]
H A Dsig.c2399 sigqueue_t *sq, *next; local
2416 sqh->sqb_free = sq = (sigqueue_t *)(sqh + 1);
2418 next = (sigqueue_t *)((uintptr_t)sq + size);
2419 sq->sq_next = next;
2420 sq = next;
2422 sq->sq_next = NULL;
2438 sigqueue_t *sq = NULL; local
2450 sq = kmem_alloc(sizeof (sigqueue_t), KM_SLEEP);
2451 sq->sq_func = NULL;
2453 sq
2473 sigqrel(sigqueue_t *sq) argument
[all...]
/illumos-gate/usr/src/uts/common/inet/ip/
H A Dip_squeue.c188 squeue_t **lastsqp, *sq; local
236 sq = *defaultq_lastp;
237 *defaultq_lastp = sq->sq_next;
238 sq->sq_next = NULL;
239 if (!(sq->sq_state & SQS_DEFAULT)) {
240 mutex_enter(&sq->sq_lock);
241 sq->sq_state |= SQS_DEFAULT;
242 mutex_exit(&sq->sq_lock);
245 sq = ip_squeue_create(SQUEUE_DEFAULT_PRIORITY);
246 sq
267 squeue_t *sq; local
359 squeue_t *sq; local
394 ip_squeue_set_move(squeue_t *sq, squeue_set_t *newset) argument
427 ip_squeue_cpu_move(squeue_t *sq, processorid_t cpuid) argument
478 squeue_t *sq = NULL; local
[all...]
H A Dsadb.c2139 sadb_match_spi(ipsa_query_t *sq, ipsa_t *sa) argument
2141 return (sq->spi == sa->ipsa_spi);
2145 sadb_match_dst_v6(ipsa_query_t *sq, ipsa_t *sa) argument
2147 return (IPSA_ARE_ADDR_EQUAL(sa->ipsa_dstaddr, sq->dstaddr, AF_INET6));
2151 sadb_match_src_v6(ipsa_query_t *sq, ipsa_t *sa) argument
2153 return (IPSA_ARE_ADDR_EQUAL(sa->ipsa_srcaddr, sq->srcaddr, AF_INET6));
2157 sadb_match_dst_v4(ipsa_query_t *sq, ipsa_t *sa) argument
2159 return (sq->dstaddr[0] == sa->ipsa_dstaddr[0]);
2163 sadb_match_src_v4(ipsa_query_t *sq, ipsa_t *sa) argument
2165 return (sq
2169 sadb_match_dstid(ipsa_query_t *sq, ipsa_t *sa) argument
2177 sadb_match_srcid(ipsa_query_t *sq, ipsa_t *sa) argument
2185 sadb_match_kmc(ipsa_query_t *sq, ipsa_t *sa) argument
2202 sadb_form_query(keysock_in_t *ksi, uint32_t req, uint32_t match, ipsa_query_t *sq, int *diagnostic) argument
2376 sadb_match_query(ipsa_query_t *sq, ipsa_t *sa) argument
2396 ipsa_query_t sq; member in struct:sadb_purge_state
2464 ipsa_query_t *sq = &ps->sq; local
2543 ipsa_query_t sq; local
2666 get_ipsa_pair(ipsa_query_t *sq, ipsap_t *ipsapp, int *diagnostic) argument
3644 ipsa_query_t sq; local
4446 sadb_check_kmc(ipsa_query_t *sq, ipsa_t *sa, int *diagnostic) argument
4476 sadb_update_kmc(ipsa_query_t *sq, ipsa_t *sa) argument
4511 ipsa_query_t sq; local
4715 update_pairing(ipsap_t *ipsapp, ipsa_query_t *sq, keysock_in_t *ksi, int *diagnostic) argument
[all...]
H A Dipsecesp.c3069 ipsa_query_t sq; local
3075 sq.spp = &espstack->esp_sadb; /* XXX */
3078 &sq, diagnostic);
3088 if (sq.assoc->sadb_sa_flags & IPSA_F_INBOUND) {
3089 primary = sq.inbound;
3090 secondary = sq.outbound;
3092 if (sq.assoc->sadb_sa_flags & IPSA_F_OUTBOUND)
3094 } else if (sq.assoc->sadb_sa_flags & IPSA_F_OUTBOUND) {
3095 primary = sq.outbound;
3096 secondary = sq
[all...]
H A Dipsecah.c770 ipsa_query_t sq; local
779 sq.spp = &ahstack->ah_sadb;
782 &sq, diagnostic);
793 primary = sq.inbound;
794 secondary = sq.outbound;
800 primary = sq.outbound;
801 secondary = sq.inbound;
824 primary = sq.inbound;
825 secondary = sq.outbound;
840 primary = sq
[all...]
/illumos-gate/usr/src/lib/libm/common/m9x/
H A Dremquof.c58 int hx, ix, iy, iz, k, ny, nd, m, sq; local
63 sq = (iy ^ hx) & is; /* sign of x/y */
75 *quo = 1 + (sq >> 30);
165 *quo = sq >= 0 ? m : -m;
187 *quo = sq >= 0 ? m : -m;
215 int hx, hy, sx, sq; local
221 sq = (hx ^ hy) & is; /* sign of x/y */
264 if (sq != 0)
H A Dremquo.c61 int n, hx, hy, hz, ix, iy, sx, sq, i, m; local
69 sq = (hx ^ hy) & 0x80000000; /* sign of x/y */
82 *quo = 1 + (sq >> 30);
157 *quo = sq >= 0 ? m : -m;
175 *quo = sq >= 0 ? m : -m;
213 int hx, hy, sx, sq; local
221 sq = (hx ^ hy) & 0x80000000; /* sign of x/y */
263 if (sq != 0)
H A Dremquol.c60 int n, ix, iy, k, sx, sq, m; local
75 sq = (hx ^ y0) & is;
85 *quo = 1 + (sq >> 30);
189 *quo = sq >= 0 ? m : -m;
233 *quo = sq >= 0 ? m : -m;
295 int hx, hy, sx, sq; local
301 sq = (hx ^ hy) & is; /* sign of x/y */
343 if (sq != 0)
/illumos-gate/usr/src/uts/common/sys/
H A Dstrsubr.h420 * mutex_enter(SQLOCK(sq));
421 * while (sq->sq_count > 0) {
422 * sq->sq_flags |= SQ_WANTWAKEUP;
423 * cv_wait(&sq->sq_wait, SQLOCK(sq));
425 * mutex_exit(SQLOCK(sq));
429 * mutex_enter(SQLOCK(sq));
430 * count = sq->sq_count;
431 * SQ_PUTLOCKS_ENTER(sq);
432 * SUM_SQ_PUTCOUNTS(sq, coun
[all...]
/illumos-gate/usr/src/cmd/factor/
H A Dfactor.c43 double sq[] = { variable
97 ii += sq[j];
/illumos-gate/usr/src/cmd/lp/filter/postscript/font/devpost/charlib/
H A DMakefile31 ob rc rf rh sq
/illumos-gate/usr/src/cmd/bhyve/
H A Dpci_nvme.c635 DPRINTF(("%s sq %u size %u gaddr %p cqid %u\r\n", __func__,
1041 struct nvme_submission_queue *sq; local
1048 sq = &sc->submit_queues[0];
1050 sqhead = atomic_load_acq_short(&sq->head);
1052 if (atomic_testandset_int(&sq->busy, 1)) {
1054 __func__, sqhead, sq->tail));
1058 DPRINTF(("sqhead %u, tail %u\r\n", sqhead, sq->tail));
1060 while (sqhead != atomic_load_acq_short(&sq->tail)) {
1061 cmd = &(sq->qbase)[sqhead];
1134 sqhead = (sqhead + 1) % sq
1231 pci_nvme_set_completion(struct pci_nvme_softc *sc, struct nvme_submission_queue *sq, int sqid, uint16_t cid, uint32_t cdw0, uint16_t status, int ignore_busy) argument
1328 struct nvme_submission_queue *sq = req->nvme_sq; local
1355 struct nvme_submission_queue *sq; local
[all...]
/illumos-gate/usr/src/uts/common/io/
H A Dstream.c3764 syncq_t *sq; local
3811 sq = qp->q_syncq;
3812 mutex_enter(SQLOCK(sq));
3814 count = sq->sq_count;
3815 flags = sq->sq_flags;
3816 ASSERT(sq->sq_ciputctrl == NULL || (flags & SQ_CIPUT));
3823 mutex_exit(SQLOCK(sq));
3831 sq->sq_flags = flags | SQ_WANTWAKEUP;
3832 cv_wait(&sq->sq_wait, SQLOCK(sq));
3952 syncq_t *sq; local
4074 syncq_t *sq = q->q_syncq; local
[all...]
/illumos-gate/usr/src/uts/common/io/mlxcx/
H A Dmlxcx_gld.c434 mlxcx_work_queue_t *sq = (mlxcx_work_queue_t *)arg; local
435 mlxcx_t *mlxp = sq->mlwq_mlx;
481 bcount = mlxcx_buf_bind_or_copy(mlxp, sq, kmp, take, &b);
483 atomic_or_uint(&sq->mlwq_state, MLXCX_WQ_BLOCKED_MAC);
487 mutex_enter(&sq->mlwq_mtx);
488 VERIFY3U(sq->mlwq_inline_mode, <=, MLXCX_ETH_INLINE_L2);
489 cq = sq->mlwq_cq;
496 mutex_exit(&sq->mlwq_mtx);
501 if ((sq->mlwq_state & (MLXCX_WQ_TEARDOWN | MLXCX_WQ_STARTED)) !=
503 mutex_exit(&sq
[all...]
H A Dmlxcx_ring.c663 mlxcx_warn(mlxp, "failed to stop sq %x",
1314 mlxcx_work_queue_t *sq; local
1361 sq = &g->mlg_wqs[i];
1362 if (!mlxcx_sq_setup(mlxp, g->mlg_port, cq, &g->mlg_tis, sq)) {
1366 sq->mlwq_group = g;
1376 mlxcx_work_queue_t *sq)
1384 cq = sq->mlwq_cq;
1388 mutex_enter(&sq->mlwq_mtx);
1389 if (sq->mlwq_state & MLXCX_WQ_STARTED) {
1390 mutex_exit(&sq
1375 mlxcx_tx_ring_start(mlxcx_t *mlxp, mlxcx_ring_group_t *g, mlxcx_work_queue_t *sq) argument
[all...]
H A Dmlxcx.c1536 mlxcx_check_sq(mlxcx_t *mlxp, mlxcx_work_queue_t *sq) argument
1541 ASSERT(mutex_owned(&sq->mlwq_mtx));
1543 if (!mlxcx_cmd_query_sq(mlxp, sq, &ctx))
1546 ASSERT3U(from_be24(ctx.mlsqc_cqn), ==, sq->mlwq_cq->mlcq_num);
1550 if (sq->mlwq_state & MLXCX_WQ_STARTED) {
1552 sq->mlwq_num, "RST", state);
1553 sq->mlwq_fm_repd_qstate = B_TRUE;
1557 if (!(sq->mlwq_state & MLXCX_WQ_STARTED)) {
1559 sq->mlwq_num, "RDY", state);
1560 sq
[all...]
/illumos-gate/usr/src/cmd/mdb/common/modules/genunix/
H A Dstreams.c487 syncq_t sq; local
557 if (mdb_vread(&sq, sizeof (sq), addr) == -1) {
562 if (mask != 0 && !(sq.sq_flags & mask))
565 if (not_mask != 0 && (sq.sq_flags & not_mask))
568 sqtype = (sq.sq_type >> 8) & 0xff;
586 addr, sq.sq_flags & 0xff, sqtype, sq.sq_count,
587 sq.sq_nqueues, sq
868 syncq_t sq; local
[all...]
H A Dsobj.c172 sleepq_head_t *sq; local
187 sq = &ww->ww_sleepq[ww->ww_sleepq_ndx++];
188 t = (uintptr_t)sq->sq_queue.sq_first;
/illumos-gate/usr/src/cmd/troff/nroff.d/terms.d/
H A Dab.X33 sq 1 \033X\115
/illumos-gate/usr/src/uts/common/io/scsi/adapters/pmcs/
H A Dpmcs_sata.c93 sp = STAILQ_FIRST(&xp->sq);
499 STAILQ_REMOVE_HEAD(&xp->sq, cmd_next);
540 while (!STAILQ_EMPTY(&xp->sq)) {
570 if (STAILQ_EMPTY(&xp->sq)) {
/illumos-gate/usr/src/uts/i86pc/io/
H A Dimmu_intrmap.c67 SVT_ALL_VERIFY, /* using sid and sq to verify */
443 uchar_t svt, sq; local
453 sq = SQ_VERIFY_ALL;
465 sq = SQ_VERIFY_ALL;
471 sq = SQ_VERIFY_ALL;
475 return (sid | (svt << 18) | (sq << 16));

Completed in 115 milliseconds

12