/illumos-gate/usr/src/lib/libtecla/common/ |
H A D | chrqueue.c | 94 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 D | chrqueue.h | 54 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 D | oce_mq.c | 35 * 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 D | oce_queue.c | 189 * 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 D | oce_rx.c | 502 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 D | oce_intr.c | 310 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 D | hermon_cq.c | 47 #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 D | hermon_umap.c | 86 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 D | tavor_cq.c | 49 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 D | tavor_wr.c | 74 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 D | tavor_umap.c | 78 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 D | dapl_hermon_hw.c | 44 #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 D | dapl_arbel_hw.c | 104 * 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 D | dapl_tavor_hw.c | 77 ((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 D | dapl_tavor_wr.c | 59 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 D | huff.h | 45 #define cq huffcode.xcq macro
|
H A D | huff.c | 73 * 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 D | dedump.c | 163 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 D | Makefile | 38 ARFLAGS= cq
|
/illumos-gate/usr/src/cmd/sendmail/libsmutil/ |
H A D | Makefile | 37 ARFLAGS= cq
|
/illumos-gate/usr/src/uts/common/io/ib/clients/of/sol_ofs/ |
H A D | sol_kverbs.c | 137 * 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 D | sol_uverbs_comp.c | 286 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 D | dumpsubr.c | 1606 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 D | mi.c | 206 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 D | sol_kverb_impl.h | 57 ib_event.element.cq = cqp; \
|