Searched defs:cq (Results 1 - 25 of 52) sorted by relevance

123

/illumos-gate/usr/src/cmd/spell/
H A Dhuff.h45 #define cq huffcode.xcq macro
/illumos-gate/usr/src/uts/common/io/fibre-channel/fca/oce/
H A Doce_mq.c35 * cq - pointer to the cq to drain
47 struct oce_cq *cq; local
52 cq = mq->cq;
55 cqe = RING_GET_CONSUMER_ITEM_VA(cq->ring, struct oce_mq_cqe);
77 RING_GET(cq->ring, 1);
78 cqe = RING_GET_CONSUMER_ITEM_VA(cq->ring, struct oce_mq_cqe);
82 oce_arm_cq(dev, cq->cq_id, num_cqe, B_TRUE);
89 oce_arm_cq(mq->parent, mq->cq
97 struct oce_cq *cq; local
[all...]
H A Doce_intr.c310 struct oce_cq *cq; local
332 /* get the cq from the eqe */
334 cq = dev->cq[cq_id];
337 (void) cq->cq_handler(cq->cb_arg);
H A Doce_rx.c502 struct oce_cq *cq; local
509 cq = rq->cq;
513 cqe = RING_GET_CONSUMER_ITEM_VA(cq->ring, struct oce_nic_rx_cqe);
515 (void) DBUF_SYNC(cq->ring->dbuf, DDI_DMA_SYNC_FORKERNEL);
554 RING_GET(cq->ring, 1);
555 cqe = RING_GET_CONSUMER_ITEM_VA(cq->ring,
567 oce_arm_cq(dev, cq->cq_id, num_cqe, B_TRUE);
615 struct oce_cq *cq; local
621 cq
[all...]
H A Doce_queue.c189 * eq - optional eq to be associated with to the cq
192 * return pointer to the cq created. NULL on failure
199 struct oce_cq *cq = NULL; local
204 /* create cq */
205 cq = kmem_zalloc(sizeof (struct oce_cq), KM_NOSLEEP);
206 if (cq == NULL) {
213 cq->ring = create_ring_buffer(dev, q_len,
215 if (cq->ring == NULL) {
218 (void *)cq->ring);
219 kmem_free(cq, sizeo
291 oce_cq_del(struct oce_dev *dev, struct oce_cq *cq) argument
334 struct oce_cq *cq; local
585 struct oce_cq *cq; local
828 struct oce_cq *cq; local
[all...]
H A Doce_tx.c560 struct oce_cq *cq; local
565 cq = wq->cq;
567 (void) ddi_dma_sync(cq->ring->dbuf->dma_handle, 0, 0,
571 cqe = RING_GET_CONSUMER_ITEM_VA(cq->ring, struct oce_nic_tx_cqe);
590 RING_GET(cq->ring, 1);
591 cqe = RING_GET_CONSUMER_ITEM_VA(cq->ring,
597 oce_arm_cq(wq->parent, cq->cq_id, num_cqe, rearm);
605 * cq - pointer to the cq t
[all...]
/illumos-gate/usr/src/lib/libtecla/common/
H A Dchrqueue.c94 GlCharQueue *cq; /* The object to be returned */ local
98 cq = malloc(sizeof(GlCharQueue));
99 if(!cq) {
108 cq->err = NULL;
109 cq->bufmem = NULL;
110 cq->buffers.head = NULL;
111 cq->buffers.tail = NULL;
112 cq->nflush = cq->ntotal = 0;
116 cq
136 _del_GlCharQueue(GlCharQueue *cq) argument
163 _glq_append_chars(GlCharQueue *cq, const char *chars, int n, GlWriteFn *write_fn, void *data) argument
272 _glq_empty_queue(GlCharQueue *cq) argument
295 _glq_char_count(GlCharQueue *cq) argument
323 _glq_flush_queue(GlCharQueue *cq, GlWriteFn *write_fn, void *data) argument
432 _glq_last_error(GlCharQueue *cq) argument
[all...]
/illumos-gate/usr/src/uts/common/io/
H A Ddedump.c163 struct copyreq *cq = (struct copyreq *)mp->b_rptr; local
166 "%lu\n", hdr, cq->cq_cmd, (void *)cq->cq_cr, cq->cq_id, cq->cq_flag,
167 (void *)cq->cq_private, (void *)cq->cq_addr, cq->cq_size);
/illumos-gate/usr/src/uts/common/io/ib/clients/rdsv3/
H A Dib_cm.c296 rdsv3_ib_snd_cq_comp_handler(struct ib_cq *cq, void *context) argument
302 "Enter(conn: %p ic: %p cq: %p)", conn, ic, cq);
347 rdsv3_ib_cq_comp_handler(struct ib_cq *cq, void *context) argument
353 "Enter(conn: %p cq: %p)", conn, cq);
544 "ib_create_cq send cq failed: %d", ret);
636 RDSV3_DPRINTF2("rdsv3_ib_setup_qp", "conn %p pd %p mr %p cq %p",
960 "cm %p pd %p cq %p qp %p", ic->i_cm_id,
/illumos-gate/usr/src/lib/libnisdb/
H A Ddb_mindex.cc746 db_query * cq = extract_index_values_from_record(recloc); local
747 if (cq == NULL) {
752 if (cq->size() != indices.indices_len) { /* something is wrong */
753 delete cq; // clean up
784 queryRes = removeLDAP(cq, o);
795 db_qcomp * comps = cq->queryloc();
813 delete cq;
959 db_query *cq = extract_index_values_from_object(obj); local
960 if (cq == NULL) {
969 if (cq
[all...]
/illumos-gate/usr/src/lib/udapl/udapl_tavor/tavor/
H A Ddapl_tavor_wr.c59 dapls_tavor_wrid_get_entry(ib_cq_handle_t cq, tavor_hw_cqe_t *cqe, argument
68 dapl_os_lock(&cq->cq_wrid_wqhdr_lock);
72 wq = dapli_tavor_wrid_wqhdr_find(cq, qpnum, send_or_recv);
114 dapl_os_unlock(&cq->cq_wrid_wqhdr_lock);
303 dapls_tavor_wrid_cq_reap(ib_cq_handle_t cq) argument
309 /* dapl_os_assert(MUTEX_HELD(&cq->cq_lock)); */
312 dapl_os_lock(&cq->cq_wrid_wqhdr_lock);
315 container = cq->cq_wrid_reap_head;
326 dapli_tavor_cq_wqhdr_remove(cq, consume_wqhdr);
331 cq
341 dapls_tavor_wrid_cq_force_reap(ib_cq_handle_t cq) argument
509 dapli_tavor_wrid_reaplist_add(ib_cq_handle_t cq, dapls_tavor_workq_hdr_t *wq) argument
536 dapli_tavor_wrid_wqhdr_find(ib_cq_handle_t cq, uint_t qpn, uint_t send_or_recv) argument
926 dapli_tavor_wrid_wqhdr_create(ib_cq_handle_t cq, uint_t qpn, uint_t send_or_recv, uint_t alloc_wrl) argument
1091 dapli_tavor_cq_wqhdr_add(ib_cq_handle_t cq, dapls_tavor_workq_hdr_t *wqhdr) argument
1112 dapli_tavor_cq_wqhdr_remove(ib_cq_handle_t cq, dapls_tavor_workq_hdr_t *wqhdr) argument
[all...]
H A Ddapl_arbel_hw.c104 * Takes the specified cq cmd and cq number and rings the cq doorbell
119 ((tavor_hw_uar_t *)ia_uar)->cq = HTOBE_64(doorbell);
127 ((tavor_hw_uar32_t *)ia_uar)->cq[0] =
129 ((tavor_hw_uar32_t *)ia_uar)->cq[1] =
134 &((tavor_hw_uar_t *)ia_uar)->cq);
552 dapli_arbel_cq_peek(ib_cq_handle_t cq, int *num_cqe) argument
563 cons_indx = cq->cq_consindx;
569 wrap_around_mask = (cq
611 dapli_arbel_cq_poll(ib_cq_handle_t cq, ibt_wc_t *wc_p, uint_t num_wc, uint_t *num_polled) argument
704 dapli_arbel_cq_poll_one(ib_cq_handle_t cq, ibt_wc_t *wc_p) argument
982 dapli_arbel_cq_notify(ib_cq_handle_t cq, int flags, uint32_t param) argument
1386 ib_cq_handle_t cq; local
1591 dapli_arbel_cq_init(ib_cq_handle_t cq) argument
[all...]
H A Ddapl_hermon_hw.c44 #define HERMON_CQE_OWNER_IS_SW(cq, cqe) ((((uint8_t *)cqe)[31] >> 7) == \
45 ((cq->cq_consindx & cq->cq_size) >> cq->cq_log_cqsz))
69 #define cq_wrap_around_mask (cq->cq_size - 1)
104 * Takes the specified cq cmd and cq number and rings the cq doorbell
118 ((tavor_hw_uar_t *)ia_uar)->cq = HTOBE_64(doorbell);
126 ((tavor_hw_uar32_t *)ia_uar)->cq[
529 dapli_hermon_cq_peek(ib_cq_handle_t cq, int *num_cqe) argument
579 dapli_hermon_cq_resize_helper(ib_cq_handle_t cq) argument
615 dapli_hermon_cq_poll(ib_cq_handle_t cq, ibt_wc_t *wc_p, uint_t num_wc, uint_t *num_polled) argument
707 dapli_hermon_cq_poll_one(ib_cq_handle_t cq, ibt_wc_t *wc_p) argument
988 dapli_hermon_cq_notify(ib_cq_handle_t cq, int flags, uint32_t param) argument
1441 ib_cq_handle_t cq; local
1624 dapli_hermon_cq_init(ib_cq_handle_t cq) argument
[all...]
H A Ddapl_tavor_hw.c77 ((tavor_hw_uar_t *)ia_uar)->cq = HTOBE_64( \
84 * Takes the specified cq cmd and cq number and rings the cq doorbell
98 ((tavor_hw_uar_t *)ia_uar)->cq = HTOBE_64(doorbell);
106 ((tavor_hw_uar32_t *)ia_uar)->cq[0] =
108 ((tavor_hw_uar32_t *)ia_uar)->cq[1] =
113 &((tavor_hw_uar_t *)ia_uar)->cq);
784 dapli_tavor_cq_peek(ib_cq_handle_t cq, int *num_cqe) argument
795 cons_indx = cq
840 dapli_tavor_cq_poll(ib_cq_handle_t cq, ibt_wc_t *wc_p, uint_t num_wc, uint_t *num_polled) argument
941 dapli_tavor_cq_poll_one(ib_cq_handle_t cq, ibt_wc_t *wc_p) argument
1263 dapli_tavor_cq_notify(ib_cq_handle_t cq, int flags, uint32_t param) argument
1719 ib_cq_handle_t cq; local
1879 dapli_tavor_cq_init(ib_cq_handle_t cq) argument
[all...]
/illumos-gate/usr/src/uts/common/io/ib/adapters/hermon/
H A Dhermon_umap.c86 static ibt_status_t hermon_umap_cq_data_out(hermon_cqhdl_t cq,
292 hermon_cqhdl_t cq; local
298 cq = (hermon_cqhdl_t)rsrcp->hr_addr;
301 size = ptob(btopr(cq->cq_resize_hdl ?
302 cq->cq_resize_hdl->cq_cqinfo.qa_size : cq->cq_cqinfo.qa_size));
307 &hermon_devmap_umem_cbops, cq->cq_resize_hdl ?
308 cq->cq_resize_hdl->cq_cqinfo.qa_umemcookie :
309 cq->cq_cqinfo.qa_umemcookie, 0, size,
460 hermon_cqhdl_t cq; local
664 hermon_cqhdl_t cq; local
865 hermon_cqhdl_t cq; local
1063 hermon_cqhdl_t cq; local
1548 hermon_umap_cq_data_out(hermon_cqhdl_t cq, mlnx_umap_cq_data_out_t *data, size_t data_sz) argument
[all...]
/illumos-gate/usr/src/uts/common/io/ib/adapters/tavor/
H A Dtavor_cq.c49 static int tavor_cq_cqe_consume(tavor_state_t *state, tavor_cqhdl_t cq,
51 static int tavor_cq_errcqe_consume(tavor_state_t *state, tavor_cqhdl_t cq,
53 static void tavor_cqe_sync(tavor_cqhdl_t cq, tavor_hw_cqe_t *cqe,
55 static void tavor_cq_resize_helper(tavor_cqhdl_t cq, tavor_hw_cqe_t *new_cqbuf,
70 tavor_cqhdl_t cq; local
138 cq = (tavor_cqhdl_t)rsrc->tr_addr;
139 _NOTE(NOW_INVISIBLE_TO_OTHER_THREADS(*cq))
140 cq->cq_is_umap = cq_is_umap;
143 cq->cq_cqnum = cqc->tr_indx;
152 if (cq
403 tavor_cqhdl_t cq; local
547 tavor_cq_resize(tavor_state_t *state, tavor_cqhdl_t cq, uint_t req_size, uint_t *actual_size, uint_t sleepflag) argument
866 tavor_cq_notify(tavor_state_t *state, tavor_cqhdl_t cq, ibt_cq_notify_flags_t flags) argument
907 tavor_cq_poll(tavor_state_t *state, tavor_cqhdl_t cq, ibt_wc_t *wc_p, uint_t num_wc, uint_t *num_polled) argument
1055 tavor_cqhdl_t cq; local
1129 tavor_cqhdl_t cq; local
1199 tavor_cq_refcnt_inc(tavor_cqhdl_t cq, uint_t is_special) argument
1230 tavor_cq_refcnt_dec(tavor_cqhdl_t cq) argument
1300 tavor_cq_cqe_consume(tavor_state_t *state, tavor_cqhdl_t cq, tavor_hw_cqe_t *cqe, ibt_wc_t *wc) argument
1472 tavor_cq_errcqe_consume(tavor_state_t *state, tavor_cqhdl_t cq, tavor_hw_cqe_t *cqe, ibt_wc_t *wc) argument
1636 tavor_cqe_sync(tavor_cqhdl_t cq, tavor_hw_cqe_t *cqe, uint_t flag) argument
1672 tavor_cq_resize_helper(tavor_cqhdl_t cq, tavor_hw_cqe_t *new_cqbuf, uint32_t old_cons_indx, uint32_t num_newcqe) argument
1734 tavor_cqhdl_t cq; local
[all...]
H A Dtavor_rsrc.c148 static int tavor_rsrc_cqhdl_constructor(void *cq, void *priv, int flags);
149 static void tavor_rsrc_cqhdl_destructor(void *cq, void *state);
150 static int tavor_rsrc_qphdl_constructor(void *cq, void *priv, int flags);
151 static void tavor_rsrc_qphdl_destructor(void *cq, void *state);
2612 tavor_rsrc_cqhdl_constructor(void *cq, void *priv, int flags) argument
2619 cqhdl = (tavor_cqhdl_t)cq;
2638 tavor_rsrc_cqhdl_destructor(void *cq, void *priv) argument
2644 cqhdl = (tavor_cqhdl_t)cq;
H A Dtavor_umap.c78 static ibt_status_t tavor_umap_cq_data_out(tavor_cqhdl_t cq,
281 tavor_cqhdl_t cq; local
289 cq = (tavor_cqhdl_t)rsrcp->tr_addr;
292 size = ptob(btopr(cq->cq_cqinfo.qa_size));
297 &tavor_devmap_umem_cbops, cq->cq_cqinfo.qa_umemcookie, 0, size,
419 tavor_cqhdl_t cq; local
475 cq = tavor_cqhdl_from_cqnum(state, key);
482 mutex_enter(&cq->cq_lock);
483 if (cq->cq_umap_dhp == NULL) {
484 cq
628 tavor_cqhdl_t cq; local
1182 tavor_umap_cq_data_out(tavor_cqhdl_t cq, mlnx_umap_cq_data_out_t *data, size_t data_sz) argument
[all...]
/illumos-gate/usr/src/uts/common/io/ib/clients/of/sol_ofs/
H A Dsol_kverbs.c137 * which dispatches each event to corresponding qp/cq handlers registered
158 "event->qp: 0x%p, event->cq: 0x%p, event->srq: 0x%p "
903 * which dispatches them to corresponding cq handlers registered
909 struct ib_cq *cq = (struct ib_cq *)ibt_get_cq_private(ibt_cq); local
913 "arg: 0x%p", ibt_cq, cq, cq->comp_handler, arg);
915 if (cq->comp_handler) {
916 cq->comp_handler(cq, cq
945 struct ib_cq *cq; local
1014 ib_destroy_cq(struct ib_cq *cq) argument
1303 ib_req_notify_cq(struct ib_cq *cq, enum ib_cq_notify_flags flags) argument
2259 ib_poll_cq(struct ib_cq *cq, int num_entries, struct ib_wc *wc) argument
[all...]
/illumos-gate/usr/src/uts/common/io/ib/clients/rds/
H A Drdsib_ib.c625 rds_poll_ctrl_completions(ibt_cq_hdl_t cq, rds_ep_t *ep) argument
637 ret = ibt_poll_cq(cq, &wc, 1, &npolled);
641 "returned: %d", ep, cq, ret);
644 "returned: IBT_CQ_EMPTY", ep, cq);
664 ep, cq, wc.wc_id, wc.wc_status);
869 rds_poll_data_completions(ibt_cq_hdl_t cq, rds_ep_t *ep) argument
882 ret = ibt_poll_cq(cq, &wc, 1, &npolled);
886 "returned: %d", ep, cq, ret);
889 "returned: IBT_CQ_EMPTY", ep, cq);
912 ep, cq, w
987 rds_recvcq_handler(ibt_cq_hdl_t cq, void *arg) argument
1023 rds_poll_send_completions(ibt_cq_hdl_t cq, rds_ep_t *ep, boolean_t lock) argument
1150 rds_sendcq_handler(ibt_cq_hdl_t cq, void *arg) argument
[all...]
/illumos-gate/usr/src/cmd/make/bin/
H A Dread2.cc205 register wchar_t *cq; local
228 for (cq = memberp, has_dollar = false, paren_count = 0;
233 *cq++ = *member_start++) {
246 member = GETNAME(memberp, cq - memberp);
247 *cq = 0;
251 if ((cq - q > (int) ar_member_name_len) &&
253 *cq++ = (int) parenright_char;
255 *cq++ = (int) parenright_char;
257 long_member_name = GETNAME(buffer, cq - buffer);
258 cq
[all...]
/illumos-gate/usr/src/lib/cfgadm_plugins/scsi/common/
H A Dcfga_ctl.c700 char *cq; local
703 cq = cfga_str(append_newline, WARN_DISCONNECT, 0);
705 ans = confp->confirm(confp->appdata_ptr, cq);
707 S_FREE(cq);
/illumos-gate/usr/src/cmd/dc/
H A Ddc.c1346 int cq, cp, mt, mcr; local
1371 cq = sgetc(mq);
1379 mt = cp*cq + carry + mcr;
/illumos-gate/usr/src/cmd/grep_xpg4/
H A Dgrep.c624 char *cp, *cq; local
636 cq = cp;
637 *cq++ = '^';
638 cq = strcpy(cq, pp->pattern) + plen;
639 *cq++ = '$';
640 *cq = '\0';
/illumos-gate/usr/src/uts/common/inet/
H A Dmi.c206 struct copyreq *cq = (struct copyreq *)mp->b_rptr; local
217 cq->cq_private = mp->b_cont;
218 cq->cq_size = len;
219 cq->cq_flag = 0;
220 bcopy(mp->b_cont->b_rptr, &cq->cq_addr, sizeof (cq->cq_addr));
296 struct copyreq *cq = (struct copyreq *)mp->b_rptr; local
302 cq->cq_private = mp->b_cont;
303 cq->cq_size = len;
304 cq
316 struct copyreq *cq = (struct copyreq *)iocp; local
[all...]

Completed in 130 milliseconds

123