Searched refs:cq (Results 1 - 25 of 84) sorted by relevance

1234

/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...]
H A Dchrqueue.h54 GlCharQueue *_del_GlCharQueue(GlCharQueue *cq);
59 int _glq_append_chars(GlCharQueue *cq, const char *chars, int n,
65 void _glq_empty_queue(GlCharQueue *cq);
70 int _glq_char_count(GlCharQueue *cq);
99 GlqFlushState _glq_flush_queue(GlCharQueue *cq, GlWriteFn *write_fn,
106 const char *_glq_last_error(GlCharQueue *cq);
/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_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_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_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);
/illumos-gate/usr/src/uts/common/io/ib/adapters/hermon/
H A Dhermon_cq.c47 #define hermon_cq_update_ci_doorbell(cq) \
49 HERMON_UAR_DB_RECORD_WRITE(cq->cq_arm_ci_vdbr, \
50 cq->cq_consindx & 0x00FFFFFF)
52 static int hermon_cq_arm_doorbell(hermon_state_t *state, hermon_cqhdl_t cq,
57 static void hermon_cq_cqe_consume(hermon_state_t *state, hermon_cqhdl_t cq,
59 static void hermon_cq_errcqe_consume(hermon_state_t *state, hermon_cqhdl_t cq,
75 hermon_cqhdl_t cq; local
140 cq = (hermon_cqhdl_t)rsrc->hr_addr;
141 _NOTE(NOW_INVISIBLE_TO_OTHER_THREADS(*cq))
142 cq
420 hermon_cqhdl_t cq, resize; local
576 hermon_cq_resize(hermon_state_t *state, hermon_cqhdl_t cq, uint_t req_size, uint_t *actual_size, uint_t sleepflag) argument
789 hermon_cq_modify(hermon_state_t *state, hermon_cqhdl_t cq, uint_t count, uint_t usec, ibt_cq_handler_id_t hid, uint_t sleepflag) argument
842 hermon_cq_notify(hermon_state_t *state, hermon_cqhdl_t cq, ibt_cq_notify_flags_t flags) argument
867 hermon_cq_poll(hermon_state_t *state, hermon_cqhdl_t cq, ibt_wc_t *wc_p, uint_t num_wc, uint_t *num_polled) argument
1060 hermon_cqhdl_t cq; local
1106 hermon_cqhdl_t cq; local
1152 hermon_cq_refcnt_inc(hermon_cqhdl_t cq, uint_t is_special) argument
1181 hermon_cq_refcnt_dec(hermon_cqhdl_t cq) argument
1195 hermon_cq_arm_doorbell(hermon_state_t *state, hermon_cqhdl_t cq, uint_t cq_cmd) argument
1291 hermon_cq_cqe_consume(hermon_state_t *state, hermon_cqhdl_t cq, hermon_hw_cqe_t *cqe, ibt_wc_t *wc) argument
1476 hermon_cq_errcqe_consume(hermon_state_t *state, hermon_cqhdl_t cq, hermon_hw_cqe_t *cqe, ibt_wc_t *wc) argument
1593 hermon_cq_resize_helper(hermon_state_t *state, hermon_cqhdl_t cq) argument
1649 hermon_cqhdl_t cq; local
[all...]
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_wr.c74 tavor_cqhdl_t cq, tavor_hw_cqe_t *cqe);
75 static void tavor_wrid_reaplist_add(tavor_cqhdl_t cq, tavor_workq_hdr_t *wq);
76 static tavor_workq_hdr_t *tavor_wrid_wqhdr_find(tavor_cqhdl_t cq, uint_t qpn,
79 tavor_cqhdl_t cq, uint_t qpn, uint_t wq_type, uint_t create_wql);
88 static void tavor_cq_wqhdr_add(tavor_cqhdl_t cq, tavor_workq_hdr_t *wqhdr);
89 static void tavor_cq_wqhdr_remove(tavor_cqhdl_t cq, tavor_workq_hdr_t *wqhdr);
2779 tavor_wrid_get_entry(tavor_cqhdl_t cq, tavor_hw_cqe_t *cqe, argument
2790 mutex_enter(&cq->cq_wrid_wqhdr_lock);
2796 opcode = TAVOR_CQE_OPCODE_GET(cq, cqe);
2804 send_or_recv = TAVOR_CQE_SENDRECV_GET(cq, cq
2860 tavor_wrid_find_match(tavor_workq_hdr_t *wq, tavor_cqhdl_t cq, tavor_hw_cqe_t *cqe) argument
2998 tavor_wrid_find_match_srq(tavor_wrid_list_hdr_t *wl, tavor_cqhdl_t cq, tavor_hw_cqe_t *cqe) argument
3054 tavor_wrid_cq_reap(tavor_cqhdl_t cq) argument
3095 tavor_wrid_cq_force_reap(tavor_cqhdl_t cq) argument
3261 tavor_wrid_reaplist_add(tavor_cqhdl_t cq, tavor_workq_hdr_t *wq) argument
3313 tavor_wrid_wqhdr_find(tavor_cqhdl_t cq, uint_t qpn, uint_t wq_type) argument
3345 tavor_wrid_wqhdr_create(tavor_state_t *state, tavor_cqhdl_t cq, uint_t qpn, uint_t wq_type, uint_t create_wql) argument
3649 tavor_cq_wqhdr_add(tavor_cqhdl_t cq, tavor_workq_hdr_t *wqhdr) argument
3675 tavor_cq_wqhdr_remove(tavor_cqhdl_t cq, tavor_workq_hdr_t *wqhdr) argument
[all...]
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/lib/udapl/udapl_tavor/tavor/
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_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_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...]
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...]
/illumos-gate/usr/src/cmd/spell/
H A Dhuff.h45 #define cq huffcode.xcq macro
H A Dhuff.c73 * z = cq, n = d(q-1)
147 *py = ((y-1)<<w) + cq + k;
199 cq = c*q;
200 cs = cq<<(L-w);
201 qcs = (((long)(q-1)<<w) + cq) << (L-QW-w);
202 v0 = c - cq;
/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/cmd/sendmail/libsmdb/
H A DMakefile38 ARFLAGS= cq
/illumos-gate/usr/src/cmd/sendmail/libsmutil/
H A DMakefile37 ARFLAGS= cq
/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/of/sol_uverbs/
H A Dsol_uverbs_comp.c286 rc = ibt_alloc_cq(uctxt->hca->hdl, &cq_attr, &ucq->cq, &real_size);
296 ibt_set_cq_private(ucq->cq, ucq);
307 (void *) ucq->cq, &resp.drv_out, sizeof (resp.drv_out));
357 ibt_set_cq_handler(ucq->cq, sol_uverbs_comp_event_handler, ucq);
374 (void) ibt_free_cq(ucq->cq);
394 rc = ibt_free_cq(ucq->cq);
534 resize_status = ibt_resize_cq(ucq->cq, cmd.cqe, &resp.cqe);
546 (void *) ucq->cq, &resp.drv_out, sizeof (resp.drv_out));
623 rc = ibt_enable_cq_notify(ucq->cq, flag);
697 rc = ibt_poll_cq(ucq->cq, completion
[all...]
/illumos-gate/usr/src/uts/common/os/
H A Ddumpsubr.c1606 dumpsys_close_cq(cqueue_t *cq, int live) argument
1609 mutex_enter(&cq->mutex);
1610 atomic_dec_uint(&cq->open);
1611 cv_signal(&cq->cv);
1612 mutex_exit(&cq->mutex);
1614 atomic_dec_uint(&cq->open);
1642 dumpsys_lock(cqueue_t *cq, int live) argument
1645 mutex_enter(&cq->mutex);
1647 dumpsys_spinlock(&cq->spinlock);
1651 dumpsys_unlock(cqueue_t *cq, in argument
1663 dumpsys_wait_cq(cqueue_t *cq, int live) argument
1677 dumpsys_put_cq(cqueue_t *cq, cbuf_t *cp, int newstate, int live) argument
1701 dumpsys_get_cq(cqueue_t *cq, int live) argument
[all...]
/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...]
/illumos-gate/usr/src/uts/common/sys/ib/clients/of/sol_ofs/
H A Dsol_kverb_impl.h57 ib_event.element.cq = cqp; \

Completed in 122 milliseconds

1234