/illumos-gate/usr/src/uts/common/io/ib/adapters/tavor/ |
H A D | tavor_wr.c | 53 static int tavor_wqe_send_build(tavor_state_t *state, tavor_qphdl_t qp, 57 uint64_t *prev_desc, tavor_sw_wqe_dbinfo_t *dbinfo, tavor_qphdl_t qp); 58 static int tavor_wqe_mlx_build(tavor_state_t *state, tavor_qphdl_t qp, 62 tavor_qphdl_t qp); 63 static int tavor_wqe_recv_build(tavor_state_t *state, tavor_qphdl_t qp, 66 uint64_t *prev, tavor_qphdl_t qp); 86 static void tavor_wrid_wqhdr_lock_both(tavor_qphdl_t qp); 87 static void tavor_wrid_wqhdr_unlock_both(tavor_qphdl_t qp); 96 tavor_post_send(tavor_state_t *state, tavor_qphdl_t qp, argument 119 if (qp 396 tavor_post_recv(tavor_state_t *state, tavor_qphdl_t qp, ibt_recv_wr_t *wr, uint_t num_wr, uint_t *num_posted) argument 943 tavor_wqe_send_build(tavor_state_t *state, tavor_qphdl_t qp, ibt_send_wr_t *wr, uint64_t *desc, uint_t *size) argument 1304 tavor_wqe_send_linknext(ibt_send_wr_t *curr_wr, ibt_send_wr_t *prev_wr, uint64_t *curr_desc, uint_t curr_descsz, uint64_t *prev_desc, tavor_sw_wqe_dbinfo_t *dbinfo, tavor_qphdl_t qp) argument 1433 tavor_wqe_mlx_build(tavor_state_t *state, tavor_qphdl_t qp, ibt_send_wr_t *wr, uint64_t *desc, uint_t *size) argument 1673 tavor_wqe_mlx_linknext(ibt_send_wr_t *prev_wr, uint64_t *curr_desc, uint_t curr_descsz, uint64_t *prev_desc, tavor_sw_wqe_dbinfo_t *dbinfo, tavor_qphdl_t qp) argument 1805 tavor_wqe_recv_build(tavor_state_t *state, tavor_qphdl_t qp, ibt_recv_wr_t *wr, uint64_t *desc, uint_t *size) argument 1874 tavor_wqe_recv_linknext(uint64_t *curr_desc, uint_t curr_descsz, uint64_t *prev_desc, tavor_qphdl_t qp) argument 2080 tavor_qphdl_t qp; local 2328 tavor_wrid_from_reset_handling(tavor_state_t *state, tavor_qphdl_t qp) argument 2613 tavor_wrid_to_reset_handling(tavor_state_t *state, tavor_qphdl_t qp) argument 3583 tavor_wrid_wqhdr_lock_both(tavor_qphdl_t qp) argument 3619 tavor_wrid_wqhdr_unlock_both(tavor_qphdl_t qp) argument [all...] |
/illumos-gate/usr/src/uts/common/io/ |
H A D | stream.c | 175 static boolean_t rwnext_enter(queue_t *qp); 176 static void rwnext_exit(queue_t *qp); 3237 qsize(queue_t *qp) argument 3242 mutex_enter(QLOCK(qp)); 3243 for (mp = qp->q_first; mp; mp = mp->b_next) 3245 mutex_exit(QLOCK(qp)); 3702 * fails. The qp->q_rwcnt keeps track of the number of successful entries so 3707 rwnext_enter(queue_t *qp) argument 3709 mutex_enter(QLOCK(qp)); 3710 if (qp 3725 rwnext_exit(queue_t *qp) argument 3751 rwnext(queue_t *qp, struiod_t *dp) argument 3939 infonext(queue_t *qp, infod_t *idp) argument 4284 queue_t *qp = p; local [all...] |
H A D | gld.c | 2858 void (*send)(queue_t *qp, mblk_t *mp); 2859 int (*cansend)(queue_t *qp); 3084 void (*send)(queue_t *qp, mblk_t *mp)) 3083 gld_passon(gld_t *gld, mblk_t *mp, pktinfo_t *pktinfo, void (*send)(queue_t *qp, mblk_t *mp)) argument
|
/illumos-gate/usr/src/lib/libc/port/threads/ |
H A D | synch.c | 471 queue_head_t *qp; local 484 udp->queue_head = qp = (queue_head_t *)data; 485 for (i = 0; i < 2 * QHASHSIZE; qp++, i++) { 486 qp->qh_type = (i < QHASHSIZE)? MX : CV; 487 qp->qh_lock.mutex_flag = LOCK_INITED; 488 qp->qh_lock.mutex_magic = MUTEX_MAGIC; 489 qp->qh_hlist = &qp->qh_def_root; 491 qp->qh_hlen = 1; 492 qp 503 QVERIFY(queue_head_t *qp) argument 560 queue_head_t *qp; local 597 queue_unlock(queue_head_t *qp) argument 611 enqueue(queue_head_t *qp, ulwp_t *ulwp, int force_fifo) argument 780 queue_slot(queue_head_t *qp, ulwp_t **prevp, int *more) argument 825 queue_unlink(queue_head_t *qp, ulwp_t **ulwpp, ulwp_t *prev) argument 882 dequeue(queue_head_t *qp, int *more) argument 901 queue_waiter(queue_head_t *qp) argument 913 dequeue_self(queue_head_t *qp) argument 954 queue_head_t *qp; local 1618 queue_head_t *qp; local 1641 queue_head_t *qp; local 1786 queue_head_t *qp; local 3181 queue_head_t *qp; local 3703 queue_head_t *qp; local 3832 queue_head_t *qp; local 3968 queue_head_t *qp; local [all...] |
H A D | thr.c | 1622 queue_head_t *qp; local 1649 if ((qp = udp->queue_head) != NULL) { 1650 (void) memset(qp, 0, 2 * QHASHSIZE * sizeof (queue_head_t)); 1651 for (i = 0; i < 2 * QHASHSIZE; qp++, i++) { 1652 qp->qh_type = (i < QHASHSIZE)? MX : CV; 1653 qp->qh_lock.mutex_flag = LOCK_INITED; 1654 qp->qh_lock.mutex_magic = MUTEX_MAGIC; 1655 qp->qh_hlist = &qp->qh_def_root; 1657 qp [all...] |
/illumos-gate/usr/src/lib/libpicltree/ |
H A D | picltree.c | 205 unqueue_event(eventq_t **qp) argument 209 evtp = *qp; 211 *qp = evtp->next;
|
/illumos-gate/usr/src/common/mpi/ |
H A D | mpi.c | 570 mp_int qp; local 597 if((res = mp_init_copy(&qp, a)) != MP_OKAY) 600 res = s_mp_div_d(&qp, d, &rem); 602 if(s_mp_cmp_d(&qp, 0) == 0) 609 s_mp_exch(&qp, q); 611 mp_clear(&qp); 4148 mp_digit *qp, mp_digit *rp) 4176 if (qp) 4177 *qp = (q1 << MP_HALF_DIGIT_BIT) | q0; 4147 s_mpv_div_2dx1d(mp_digit Nhi, mp_digit Nlo, mp_digit divisor, mp_digit *qp, mp_digit *rp) argument
|
/illumos-gate/usr/src/uts/common/os/ |
H A D | streamio.c | 194 push_mod(queue_t *qp, dev_t *devp, struct stdata *stp, const char *name, argument 216 if ((error = qattach(qp, devp, 0, crp, fp, B_FALSE)) != 0) 240 queue_t *qp; local 347 qp = stp->sd_wrq; 348 while (_SAMESTR(qp)) { 349 qp = qp->q_next; 350 if ((error = qreopen(_RD(qp), devp, flag, crp)) != 0) 369 qp = allocq(); 370 stp = shalloc(qp); 615 queue_t *qp; local 1883 queue_t *wq, *qp; local 5703 queue_t *qp, *nextqp; local 8214 queue_t *qp = stp->sd_wrq; local 8283 queue_t *qp = _RD(stp->sd_wrq); local 8505 strq2vp(queue_t *qp) argument [all...] |
H A D | strsubr.c | 467 #define SQPUT_Q(sq, qp) \ 470 if (!(qp->q_sqflags & Q_SQQUEUED)) { \ 472 ASSERT((qp->q_sqprev == NULL) && (qp->q_sqnext == NULL)); \ 476 ASSERT(sq == qp->q_syncq); \ 491 sq->sq_head = sq->sq_tail = qp; \ 493 } else if (qp->q_spri == 0) { \ 494 qp->q_sqprev = sq->sq_tail; \ 495 sq->sq_tail->q_sqnext = qp; \ 496 sq->sq_tail = qp; \ 688 queue_t *qp = &qip->qu_rqueue; local 749 queue_t *qp = &qip->qu_rqueue; local 1117 qattach(queue_t *qp, dev_t *devp, int oflag, cred_t *crp, fmodsw_impl_t *fp, boolean_t is_insert) argument 1221 qreopen(queue_t *qp, dev_t *devp, int flag, cred_t *crp) argument 1256 qdetach(queue_t *qp, int clmode, int flag, cred_t *crp, boolean_t is_remove) argument 1319 disable_svc(queue_t *qp) argument 1334 enable_svc(queue_t *qp) argument 1359 remove_runlist(queue_t *qp) argument 1387 wait_svc(queue_t *qp) argument 3275 shalloc(queue_t *qp) argument 3352 queue_t *qp, *wqp; local 3412 freeq(queue_t *qp) argument 4852 removeq(queue_t *qp) argument 5564 claimq(queue_t *qp) argument 5581 releaseq(queue_t *qp) argument 5617 claimstr(queue_t *qp) argument 5631 releasestr(queue_t *qp) argument 6175 queue_t *qp; local 6372 queue_t *qp; local 6951 flush_syncq(syncq_t *sq, queue_t *qp) argument 7092 propagate_syncq(queue_t *qp) argument 7469 putnext_tail(syncq_t *sq, queue_t *qp, uint32_t passflags) argument 7629 queue_t *qp; local [all...] |
/illumos-gate/usr/src/uts/common/avs/ns/rdc/ |
H A D | rdc_io.c | 2512 net_queue *qp = &krdc->group->ra_queue; local 2537 qp->nitems, qp->blocks, 2538 (void *)qp->net_qhead, 2539 (void *)qp->net_qtail); 3995 net_queue *qp = &krdc->group->ra_queue; local 4020 qp->nitems, qp->blocks, 4021 (void *)qp->net_qhead, 4022 (void *)qp [all...] |
/illumos-gate/usr/src/uts/common/fs/sockfs/ |
H A D | socktpi.c | 6432 boolean_t *direct, queue_t **qp, struct cred *cr) 6446 *qp = NULL; 6503 *qp = _RD(q); 6431 sotpi_convert_sonode(struct sonode *so, struct sockparams *newsp, boolean_t *direct, queue_t **qp, struct cred *cr) argument
|
/illumos-gate/usr/src/cmd/cron/ |
H A D | cron.c | 2189 struct queue *qp; local 2207 qp = &qt[e->etype]; /* set pointer to queue defs */ 2208 if (qp->nrun >= qp->njob) { 2210 resched(qp->nwait); 2319 ++qp->nrun; 2539 (void) nice(qp->nice);
|
/illumos-gate/usr/src/cmd/sendmail/src/ |
H A D | queue.c | 5779 QPATHS *qp = &qg->qg_qpaths[i]; local 5784 needed += fsize / FILE_SYS_BLKSIZE(qp->qp_fsysidx) 5785 + ((fsize % FILE_SYS_BLKSIZE(qp->qp_fsysidx) 5789 fsavail = FILE_SYS_AVAIL(qp->qp_fsysidx); 5800 fsavail = freediskspace(FILE_SYS_NAME(qp->qp_fsysidx), 6438 QPATHS *qp = &Queue[i]->qg_qpaths[j]; local 6441 (void) sm_strlcpyn(qddf, sizeof(qddf), 2, qp->qp_name, 6442 (bitset(QP_SUBDF, qp->qp_subdirs) 6444 fs = filesys_find(qp->qp_name, qddf, add); 6446 qp [all...] |
/illumos-gate/usr/src/uts/common/sys/ib/clients/of/rdma/ |
H A D | ib_verbs.h | 283 struct ib_qp *qp; member in union:ib_event::__anon7919 383 struct ib_qp *qp; member in struct:ib_wc 692 * @qp: The QP to modify. 698 int ib_modify_qp(struct ib_qp *qp, struct ib_qp_attr *qp_attr, 703 * @qp: The QP to destroy. 705 int ib_destroy_qp(struct ib_qp *qp);
|
/illumos-gate/usr/src/uts/common/io/fibre-channel/fca/emlxs/ |
H A D | emlxs_solaris.c | 5282 FCIO_Q_STAT_t *qp; local 5424 qp = (FCIO_Q_STAT_t *)pm->pm_stat_buf; 5427 qp->eq[i].host_index = 5429 qp->eq[i].max_index = 5431 qp->eq[i].qid = 5433 qp->eq[i].msix_vector = 5435 qp->eq[i].phys = 5437 qp->eq[i].virt = PADDR_LO( 5439 qp->eq[i].virt_hi = PADDR_HI( 5441 qp [all...] |
/illumos-gate/usr/src/uts/common/rpc/ |
H A D | rpcib.c | 384 static struct rdma_done_list *rdma_done_add(rib_qp_t *qp, uint32_t xid); 385 static void rdma_done_rm(rib_qp_t *qp, struct rdma_done_list *rd); 387 static void rdma_done_notify(rib_qp_t *qp, uint32_t xid); 837 * A qp is allowed to access a memory region 862 * If number of qp's gets too large, then several 1010 rib_qp_t *qp; local 1031 qp = wd->qp; 1032 conn = qptoc(qp); 1080 rib_rbuf_free(qptoc(wd->qp), 1102 rib_qp_t *qp; local 1180 rib_qp_t *qp; local 1318 rib_qp_t *qp; local 1565 rib_clnt_create_chan(rib_hca_t *hca, struct netbuf *raddr, rib_qp_t **qp) argument 1614 rib_svc_create_chan(rib_hca_t *hca, caddr_t q, uint8_t port, rib_qp_t **qp) argument 1719 rib_qp_t *qp; local 1794 rib_conn_to_srv(rib_hca_t *hca, rib_qp_t *qp, rpcib_ping_t *rptp) argument 2023 rib_qp_t *qp = ctoqp(conn); local 2145 rib_send_hold(rib_qp_t *qp) argument 2153 rib_send_rele(rib_qp_t *qp) argument 2163 rib_recv_rele(rib_qp_t *qp) argument 2178 rib_sendwait(rib_qp_t *qp, struct send_wid *wd) argument 2261 rib_init_sendwait(uint32_t xid, int cv_sig, rib_qp_t *qp) argument 2287 rib_rem_rep(rib_qp_t *qp, struct reply *rep) argument 2316 rib_qp_t *qp; local 2426 rib_qp_t *qp = ctoqp(conn); local 2456 rib_create_wid(rib_qp_t *qp, ibt_wr_ds_t *sgl, uint32_t msgid) argument 2477 rib_qp_t *qp = ctoqp(conn); local 2563 rib_qp_t *qp = ctoqp(conn); local 2627 rib_qp_t *qp = ctoqp(conn); local 2650 rib_qp_t *qp = ctoqp(conn); local 2671 rib_qp_t *qp = ctoqp(conn); local 2757 rib_qp_t *qp = ctoqp(conn); local 2849 rib_qp_t *qp = ctoqp(conn); local 2936 rib_qp_t *qp; local 3136 rib_qp_t *qp; local 3564 rib_init_svc_recv(rib_qp_t *qp, ibt_wr_ds_t *sgl) argument 3584 rib_addreplylist(rib_qp_t *qp, uint32_t msgid) argument 3618 rib_rem_replylist(rib_qp_t *qp) argument 3633 rib_remreply(rib_qp_t *qp, struct reply *rep) argument 4061 rib_qp_t *qp = ctoqp(conn); local 4133 rib_qp_t *qp = ctoqp(conn); local 4340 rib_qp_t *qp; local 4475 rib_qp_t *qp = ctoqp(conn); local 4605 rdma_done_add(rib_qp_t *qp, uint32_t xid) argument 4625 rdma_done_rm(rib_qp_t *qp, struct rdma_done_list *rd) argument 4648 rdma_done_rem_list(rib_qp_t *qp) argument 4661 rdma_done_notify(rib_qp_t *qp, uint32_t xid) argument 4686 rib_qp_t *qp; local [all...] |
/illumos-gate/usr/src/uts/common/avs/ns/sdbc/ |
H A D | sd_bcache.c | 1244 _sd_cctl_t *cp, *cn, *qp; local 1247 qp = (q->sq_qhead).cc_prev; 1251 !_sd_cctl_valid(qp)) 1253 "_sd_requeue %x prev %x next %x qp %x", 1254 centry, cp, cn, qp); 4580 _sd_cctl_t *cp, *cn, *qp; local 4583 qp = (q->sq_qhead).cc_prev; 4587 !_sd_cctl_valid(qp)) 4589 "_sd_centry_alloc %x prev %x next %x qp %x", 4590 cc_ent, cp, cn, qp); [all...] |
/illumos-gate/usr/src/uts/common/io/cxgbe/common/ |
H A D | t4_hw.c | 2391 __be32 *qp = &cmd.iq0_to_iq2; local 2429 *qp++ = htonl(v);
|
/illumos-gate/usr/src/uts/sun4u/starfire/io/ |
H A D | idn_proto.c | 9496 idn_retry_queue_t *qp; 9498 qp = &idn.retryqueue; 9500 mutex_enter(&qp->rq_mutex); 9502 for (i = 0, rp = qp->rq_jobs; i < qp->rq_count; i++, rp = rp->rj_next) 9507 mutex_exit(&qp->rq_mutex); 9517 idn_retry_queue_t *qp; local 9519 qp = &idn.retryqueue; 9521 mutex_enter(&qp->rq_mutex); 9528 mutex_exit(&qp 9552 idn_retry_queue_t *qp; local 9609 idn_retry_queue_t *qp; local [all...] |
/illumos-gate/usr/src/cmd/cmd-inet/usr.lib/mdnsd/ |
H A D | mDNS.c | 11806 DNSQuestion **qp = &m->Questions; local 11810 if (question->InterfaceID == mDNSInterface_LocalOnly || question->InterfaceID == mDNSInterface_P2P) qp = &m->LocalOnlyQuestions; 11811 while (*qp && *qp != question) qp=&(*qp)->next; 11812 if (*qp) *qp = (*qp)->next;
|