Searched defs:qp (Results 76 - 95 of 95) sorted by relevance

1234

/illumos-gate/usr/src/uts/common/io/ib/adapters/tavor/
H A Dtavor_wr.c53 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 Dstream.c175 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 Dgld.c2858 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 Dsynch.c471 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 Dthr.c1622 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 Dpicltree.c205 unqueue_event(eventq_t **qp) argument
209 evtp = *qp;
211 *qp = evtp->next;
/illumos-gate/usr/src/common/mpi/
H A Dmpi.c570 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 Dstreamio.c194 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 Dstrsubr.c467 #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 Drdc_io.c2512 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 Dsocktpi.c6432 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 Dcron.c2189 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 Dqueue.c5779 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 Dib_verbs.h283 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 Demlxs_solaris.c5282 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 Drpcib.c384 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 Dsd_bcache.c1244 _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 Dt4_hw.c2391 __be32 *qp = &cmd.iq0_to_iq2; local
2429 *qp++ = htonl(v);
/illumos-gate/usr/src/uts/sun4u/starfire/io/
H A Didn_proto.c9496 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 DmDNS.c11806 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;

Completed in 422 milliseconds

1234