/freebsd-9.3-release/sys/ofed/drivers/net/mlx4/ |
H A D | en_cq.c | 36 #include <linux/mlx4/cq.h> 40 static void mlx4_en_cq_event(struct mlx4_cq *cq, enum mlx4_event event) argument 47 struct mlx4_en_cq *cq, 53 cq->size = entries; 54 cq->tq = taskqueue_create_fast("mlx4_en_que", M_NOWAIT, 55 taskqueue_thread_enqueue, &cq->tq); 57 cq->buf_size = cq->size * sizeof(struct mlx4_cqe); 58 cq->vector = (ring + priv->port) % 60 TASK_INIT(&cq 46 mlx4_en_create_cq(struct mlx4_en_priv *priv, struct mlx4_en_cq *cq, int entries, int ring, enum cq_type mode) argument 89 mlx4_en_activate_cq(struct mlx4_en_priv *priv, struct mlx4_en_cq *cq) argument 121 mlx4_en_destroy_cq(struct mlx4_en_priv *priv, struct mlx4_en_cq *cq) argument 134 mlx4_en_deactivate_cq(struct mlx4_en_priv *priv, struct mlx4_en_cq *cq) argument 146 mlx4_en_set_cq_moder(struct mlx4_en_priv *priv, struct mlx4_en_cq *cq) argument 152 mlx4_en_arm_cq(struct mlx4_en_priv *priv, struct mlx4_en_cq *cq) argument [all...] |
H A D | cq.c | 41 #include <linux/mlx4/cq.h> 78 struct mlx4_cq *cq; local 80 cq = radix_tree_lookup(&mlx4_priv(dev)->cq_table.tree, 82 if (!cq) { 87 ++cq->arm_sn; 89 cq->comp(cq); 95 struct mlx4_cq *cq; local 99 cq = radix_tree_lookup(&cq_table->tree, cqn & (dev->caps.num_cqs - 1)); 100 if (cq) 138 mlx4_cq_modify(struct mlx4_dev *dev, struct mlx4_cq *cq, u16 count, u16 period) argument 162 mlx4_cq_resize(struct mlx4_dev *dev, struct mlx4_cq *cq, int entries, struct mlx4_mtt *mtt) argument 206 mlx4_cq_alloc(struct mlx4_dev *dev, int nent, struct mlx4_mtt *mtt, struct mlx4_uar *uar, u64 db_rec, struct mlx4_cq *cq, unsigned vector, int collapsed) argument 292 mlx4_cq_free(struct mlx4_dev *dev, struct mlx4_cq *cq) argument [all...] |
/freebsd-9.3-release/sys/ofed/drivers/infiniband/hw/mlx4/ |
H A D | cq.c | 34 #include <linux/mlx4/cq.h> 44 static void mlx4_ib_cq_comp(struct mlx4_cq *cq) argument 46 struct ib_cq *ibcq = &to_mibcq(cq)->ibcq; 50 static void mlx4_ib_cq_event(struct mlx4_cq *cq, enum mlx4_event type) argument 57 "on CQ %06x\n", type, cq->cqn); 61 ibcq = &to_mibcq(cq)->ibcq; 65 event.element.cq = ibcq; 75 static void *get_cqe(struct mlx4_ib_cq *cq, int n) argument 77 return get_cqe_from_buf(&cq->buf, n); 80 static void *get_sw_cqe(struct mlx4_ib_cq *cq, in argument 88 next_cqe_sw(struct mlx4_ib_cq *cq) argument 93 mlx4_ib_modify_cq(struct ib_cq *cq, u16 cq_count, u16 cq_period) argument 174 struct mlx4_ib_cq *cq; local 270 mlx4_alloc_resize_buf(struct mlx4_ib_dev *dev, struct mlx4_ib_cq *cq, int entries) argument 294 mlx4_alloc_resize_umem(struct mlx4_ib_dev *dev, struct mlx4_ib_cq *cq, int entries, struct ib_udata *udata) argument 323 mlx4_ib_get_outstanding_cqes(struct mlx4_ib_cq *cq) argument 334 mlx4_ib_cq_resize_copy_cqes(struct mlx4_ib_cq *cq) argument 355 struct mlx4_ib_cq *cq = to_mcq(ibcq); local 451 mlx4_ib_destroy_cq(struct ib_cq *cq) argument 557 mlx4_ib_poll_one(struct mlx4_ib_cq *cq, struct mlx4_ib_qp **cur_qp, struct ib_wc *wc) argument 765 struct mlx4_ib_cq *cq = to_mcq(ibcq); local 801 __mlx4_ib_cq_clean(struct mlx4_ib_cq *cq, u32 qpn, struct mlx4_ib_srq *srq) argument 856 mlx4_ib_cq_clean(struct mlx4_ib_cq *cq, u32 qpn, struct mlx4_ib_srq *srq) argument [all...] |
H A D | Makefile | 3 mlx4_ib-y := ah.o cq.o doorbell.o mad.o main.o mr.o qp.o srq.o
|
/freebsd-9.3-release/sys/ofed/drivers/infiniband/hw/mthca/ |
H A D | mthca_cq.c | 168 static inline struct mthca_cqe *get_cqe(struct mthca_cq *cq, int entry) argument 170 return get_cqe_from_buf(&cq->buf, entry); 178 static inline struct mthca_cqe *next_cqe_sw(struct mthca_cq *cq) argument 180 return cqe_sw(get_cqe(cq, cq->cons_index & cq->ibcq.cqe)); 200 * incr is ignored in native Arbel (mem-free) mode, so cq->cons_index 203 static inline void update_cons_index(struct mthca_dev *dev, struct mthca_cq *cq, argument 207 *cq->set_ci_db = cpu_to_be32(cq 223 struct mthca_cq *cq; local 240 struct mthca_cq *cq; local 277 mthca_cq_clean(struct mthca_dev *dev, struct mthca_cq *cq, u32 qpn, struct mthca_srq *srq) argument 329 mthca_cq_resize_copy_cqes(struct mthca_cq *cq) argument 376 handle_error_cqe(struct mthca_dev *dev, struct mthca_cq *cq, struct mthca_qp *qp, int wqe_index, int is_send, struct mthca_err_cqe *cqe, struct ib_wc *entry, int *free_cqe) argument 482 mthca_poll_one(struct mthca_dev *dev, struct mthca_cq *cq, struct mthca_qp **cur_qp, int *freed, struct ib_wc *entry) argument 663 struct mthca_cq *cq = to_mcq(ibcq); local 728 mthca_tavor_arm_cq(struct ib_cq *cq, enum ib_cq_notify_flags flags) argument 743 struct mthca_cq *cq = to_mcq(ibcq); local 773 mthca_init_cq(struct mthca_dev *dev, int nent, struct mthca_ucontext *ctx, u32 pdn, struct mthca_cq *cq) argument 900 get_cq_refcount(struct mthca_dev *dev, struct mthca_cq *cq) argument 911 mthca_free_cq(struct mthca_dev *dev, struct mthca_cq *cq) argument [all...] |
H A D | mthca_provider.c | 680 struct mthca_cq *cq; local 704 cq = kmalloc(sizeof *cq, GFP_KERNEL); 705 if (!cq) { 711 cq->buf.mr.ibmr.lkey = ucmd.lkey; 712 cq->set_ci_db_index = ucmd.set_db_index; 713 cq->arm_db_index = ucmd.arm_db_index; 722 cq); 726 if (context && ib_copy_to_udata(udata, &cq->cqn, sizeof (__u32))) { 727 mthca_free_cq(to_mdev(ibdev), cq); local 751 mthca_alloc_resize_buf(struct mthca_dev *dev, struct mthca_cq *cq, int entries) argument 799 struct mthca_cq *cq = to_mcq(ibcq); local 875 mthca_destroy_cq(struct ib_cq *cq) argument [all...] |
/freebsd-9.3-release/contrib/ofed/libmlx4/src/ |
H A D | cq.c | 110 static struct mlx4_cqe *get_cqe(struct mlx4_cq *cq, int entry) argument 112 return cq->buf.buf + entry * MLX4_CQ_ENTRY_SIZE; 115 static void *get_sw_cqe(struct mlx4_cq *cq, int n) argument 117 struct mlx4_cqe *cqe = get_cqe(cq, n & cq->ibv_cq.cqe); 120 !!(n & (cq->ibv_cq.cqe + 1))) ? NULL : cqe; 123 static struct mlx4_cqe *next_cqe_sw(struct mlx4_cq *cq) argument 125 return get_sw_cqe(cq, cq->cons_index); 128 static void update_cons_index(struct mlx4_cq *cq) argument 191 mlx4_poll_one(struct mlx4_cq *cq, struct mlx4_qp **cur_qp, struct ibv_wc *wc) argument 344 struct mlx4_cq *cq = to_mcq(ibcq); local 367 struct mlx4_cq *cq = to_mcq(ibvcq); local 393 mlx4_cq_event(struct ibv_cq *cq) argument 398 __mlx4_cq_clean(struct mlx4_cq *cq, uint32_t qpn, struct mlx4_srq *srq) argument 455 mlx4_cq_clean(struct mlx4_cq *cq, uint32_t qpn, struct mlx4_srq *srq) argument 462 mlx4_get_outstanding_cqes(struct mlx4_cq *cq) argument 472 mlx4_cq_resize_copy_cqes(struct mlx4_cq *cq, void *buf, int old_cqe) argument [all...] |
H A D | verbs.c | 169 struct mlx4_cq *cq; local 176 cq = malloc(sizeof *cq); 177 if (!cq) 180 cq->cons_index = 0; 182 if (pthread_spin_init(&cq->lock, PTHREAD_PROCESS_PRIVATE)) 187 if (mlx4_alloc_cq_buf(to_mdev(context->device), &cq->buf, cqe)) 190 cq->set_ci_db = mlx4_alloc_db(to_mctx(context), MLX4_DB_TYPE_CQ); 191 if (!cq->set_ci_db) 194 cq 226 struct mlx4_cq *cq = to_mcq(ibcq); local 281 mlx4_destroy_cq(struct ibv_cq *cq) argument [all...] |
/freebsd-9.3-release/contrib/ofed/libmthca/src/ |
H A D | cq.c | 125 static inline struct mthca_cqe *get_cqe(struct mthca_cq *cq, int entry) argument 127 return cq->buf.buf + entry * MTHCA_CQ_ENTRY_SIZE; 130 static inline struct mthca_cqe *cqe_sw(struct mthca_cq *cq, int i) argument 132 struct mthca_cqe *cqe = get_cqe(cq, i); 136 static inline struct mthca_cqe *next_cqe_sw(struct mthca_cq *cq) argument 138 return cqe_sw(cq, cq->cons_index & cq->ibv_cq.cqe); 148 * incr is ignored in native Arbel (mem-free) mode, so cq->cons_index 151 static inline void update_cons_index(struct mthca_cq *cq, in argument 175 handle_error_cqe(struct mthca_cq *cq, struct mthca_qp *qp, int wqe_index, int is_send, struct mthca_err_cqe *cqe, struct ibv_wc *wc, int *free_cqe) argument 290 mthca_poll_one(struct mthca_cq *cq, struct mthca_qp **cur_qp, int *freed, struct ibv_wc *wc) argument 462 struct mthca_cq *cq = to_mcq(ibcq); local 486 mthca_tavor_arm_cq(struct ibv_cq *cq, int solicited) argument 503 struct mthca_cq *cq = to_mcq(ibvcq); local 535 mthca_arbel_cq_event(struct ibv_cq *cq) argument 549 __mthca_cq_clean(struct mthca_cq *cq, uint32_t qpn, struct mthca_srq *srq) argument 593 mthca_cq_clean(struct mthca_cq *cq, uint32_t qpn, struct mthca_srq *srq) argument 600 mthca_cq_resize_copy_cqes(struct mthca_cq *cq, void *buf, int old_cqe) argument [all...] |
H A D | verbs.c | 193 struct mthca_cq *cq; local 200 cq = malloc(sizeof *cq); 201 if (!cq) 204 cq->cons_index = 0; 206 if (pthread_spin_init(&cq->lock, PTHREAD_PROCESS_PRIVATE)) 210 if (mthca_alloc_cq_buf(to_mdev(context->device), &cq->buf, cqe)) 213 cq->mr = __mthca_reg_mr(to_mctx(context)->pd, cq->buf.buf, 216 if (!cq 285 struct mthca_cq *cq = to_mcq(ibcq); local 350 mthca_destroy_cq(struct ibv_cq *cq) argument [all...] |
H A D | mthca.h | 270 return to_mxxx(cq, cq); 318 int mthca_resize_cq(struct ibv_cq *cq, int cqe); 319 int mthca_destroy_cq(struct ibv_cq *cq); 320 int mthca_poll_cq(struct ibv_cq *cq, int ne, struct ibv_wc *wc); 321 int mthca_tavor_arm_cq(struct ibv_cq *cq, int solicited); 322 int mthca_arbel_arm_cq(struct ibv_cq *cq, int solicited); 323 void mthca_arbel_cq_event(struct ibv_cq *cq); 324 void __mthca_cq_clean(struct mthca_cq *cq, uint32_t qpn, struct mthca_srq *srq); 325 void mthca_cq_clean(struct mthca_cq *cq, uint32_ [all...] |
/freebsd-9.3-release/lib/libc/gen/ |
H A D | disklabel.c | 69 char *cp, *cq; /* can't be register */ local 81 cq = dp->d_typename; 83 while (cq < dp->d_typename + sizeof(dp->d_typename) - 1 && 84 (*cq = *cp) && *cq != '|' && *cq != ':') 85 cq++, cp++; 86 *cq = '\0'; 88 if (cgetstr(buf, "ty", &cq) > 0 && strcmp(cq, "removabl [all...] |
/freebsd-9.3-release/sys/ofed/include/linux/mlx4/ |
H A D | cq.h | 110 static inline void mlx4_cq_arm(struct mlx4_cq *cq, u32 cmd, argument 118 sn = cq->arm_sn & 3; 119 ci = cq->cons_index & 0xffffff; 121 *cq->arm_db = cpu_to_be32(sn << 28 | cmd | ci); 129 doorbell[0] = cpu_to_be32(sn << 28 | cmd | cq->cqn); 135 static inline void mlx4_cq_set_ci(struct mlx4_cq *cq) argument 137 *cq->set_ci_db = cpu_to_be32(cq->cons_index & 0xffffff); 145 int mlx4_cq_modify(struct mlx4_dev *dev, struct mlx4_cq *cq, 147 int mlx4_cq_resize(struct mlx4_dev *dev, struct mlx4_cq *cq, [all...] |
/freebsd-9.3-release/sys/dev/oce/ |
H A D | oce_queue.c | 77 static void oce_cq_del(POCE_SOFTC sc, struct oce_cq *cq); 321 struct oce_cq *cq; local 325 cq = oce_cq_create(sc, 329 if (!cq) 333 wq->cq = cq; 344 eq->cq[eq->cq_valid] = cq; 346 cq->cb_arg = wq; 347 cq 513 struct oce_cq *cq; local 664 struct oce_cq *cq; local 884 struct oce_cq *cq = NULL; local 923 oce_cq_del(POCE_SOFTC sc, struct oce_cq *cq) argument 1075 struct oce_cq *cq = wq->cq; local 1124 struct oce_cq *cq; local [all...] |
/freebsd-9.3-release/contrib/groff/font/devdvi/ |
H A D | TBI | 12 ff cq 111848 20 cq ' -92624 21 ' cq -92624 22 cq cq -92624 25 cq ? 123498 27 cq ! 123498 175 Fn cq 111848 177 f cq 111848 190 n cq [all...] |
H A D | TI | 13 ff cq 109373 21 cq ' -80390 22 ' cq -80390 23 cq cq -80390 26 cq ? 107187 28 cq ! 107187 176 Fn cq 109373 178 f cq 109373 191 n cq [all...] |
H A D | TB | 11 ff cq 114323 19 ' cq -100488 20 cq ' -100488 21 cq cq -100488 24 cq ? 133984 26 cq ! 133984 140 f cq 114323 250 cq 334960,728178 2 0047
|
/freebsd-9.3-release/sys/dev/cxgb/ulp/iw_cxgb/ |
H A D | iw_cxgb_hal.c | 109 cxio_hal_cq_op(struct cxio_rdev *rdev_p, struct t3_cq *cq, argument 121 ret = t3_sge_cqcntxt_op(sc, cq->cqid, op, credit); 132 if (Q_PTR2IDX((cq->rptr), cq->size_log2) != ret) { 135 rptr = cq->rptr; 141 while (Q_PTR2IDX((rptr+1), cq->size_log2) != ret) 149 cqe = cq->queue + Q_PTR2IDX(rptr, cq->size_log2); 150 while (!CQ_VLD_ENTRY(rptr, cq->size_log2, cqe)) { 197 cxio_create_cq(struct cxio_rdev *rdev_p, struct t3_cq *cq, in argument 343 cxio_destroy_cq(struct cxio_rdev *rdev_p, struct t3_cq *cq) argument 383 insert_recv_cqe(struct t3_wq *wq, struct t3_cq *cq) argument 402 cxio_flush_rq(struct t3_wq *wq, struct t3_cq *cq, int count) argument 421 insert_sq_cqe(struct t3_wq *wq, struct t3_cq *cq, struct t3_swsq *sqp) argument 443 cxio_flush_sq(struct t3_wq *wq, struct t3_cq *cq, int count) argument 464 cxio_flush_hw_cq(struct t3_cq *cq) argument 501 cxio_count_scqes(struct t3_cq *cq, struct t3_wq *wq, int *count) argument 519 cxio_count_rcqes(struct t3_cq *cq, struct t3_wq *wq, int *count) argument 1077 flush_completed_wrs(struct t3_wq *wq, struct t3_cq *cq) argument 1154 cxio_poll_cq(struct t3_wq *wq, struct t3_cq *cq, struct t3_cqe *cqe, u8 *cqe_flushed, u64 *cookie, u32 *credit) argument [all...] |
H A D | iw_cxgb_wr.h | 677 static inline int cxio_cq_in_error(struct t3_cq *cq) argument 680 &cq->queue[1 << cq->size_log2])->cq_err; 683 static inline void cxio_set_cq_in_error(struct t3_cq *cq) argument 686 &cq->queue[1 << cq->size_log2])->cq_err = 1; 694 static inline struct t3_cqe *cxio_next_hw_cqe(struct t3_cq *cq) argument 698 cqe = cq->queue + (Q_PTR2IDX(cq->rptr, cq 704 cxio_next_sw_cqe(struct t3_cq *cq) argument 715 cxio_next_cqe(struct t3_cq *cq) argument [all...] |
H A D | iw_cxgb_hal.h | 138 int cxio_hal_cq_op(struct cxio_rdev *rdev, struct t3_cq *cq, 140 int cxio_create_cq(struct cxio_rdev *rdev, struct t3_cq *cq, int kernel); 141 int cxio_destroy_cq(struct cxio_rdev *rdev, struct t3_cq *cq); 148 int cxio_peek_cq(struct t3_wq *wr, struct t3_cq *cq, int opcode); 168 int cxio_flush_rq(struct t3_wq *wq, struct t3_cq *cq, int count); 169 int cxio_flush_sq(struct t3_wq *wq, struct t3_cq *cq, int count); 170 void cxio_count_rcqes(struct t3_cq *cq, struct t3_wq *wq, int *count); 171 void cxio_count_scqes(struct t3_cq *cq, struct t3_wq *wq, int *count); 172 void cxio_flush_hw_cq(struct t3_cq *cq); 173 int cxio_poll_cq(struct t3_wq *wq, struct t3_cq *cq, struc [all...] |
/freebsd-9.3-release/contrib/ofed/libibverbs/src/ |
H A D | verbs.c | 276 struct ibv_cq *cq; local 280 cq = context->ops.create_cq(context, cqe, channel, comp_vector); 282 if (cq) { 283 cq->context = context; 284 cq->channel = channel; 287 cq->cq_context = cq_context; 288 cq->comp_events_completed = 0; 289 cq->async_events_completed = 0; 290 pthread_mutex_init(&cq->mutex, NULL); 291 pthread_cond_init(&cq 300 __ibv_resize_cq(struct ibv_cq *cq, int cqe) argument 309 __ibv_destroy_cq(struct ibv_cq *cq) argument 329 __ibv_get_cq_event(struct ibv_comp_channel *channel, struct ibv_cq **cq, void **cq_context) argument 347 __ibv_ack_cq_events(struct ibv_cq *cq, unsigned int nevents) argument [all...] |
H A D | compat-1_0.c | 180 int (*poll_cq)(struct ibv_cq_1_0 *cq, int num_entries, 182 int (*req_notify_cq)(struct ibv_cq_1_0 *cq, 184 void (*cq_event)(struct ibv_cq *cq); 185 int (*resize_cq)(struct ibv_cq *cq, int cqe); 186 int (*destroy_cq)(struct ibv_cq *cq); 292 static int poll_cq_wrapper_1_0(struct ibv_cq_1_0 *cq, int num_entries, argument 295 return cq->context->real_context->ops.poll_cq(cq->real_cq, num_entries, wc); 298 static int req_notify_cq_wrapper_1_0(struct ibv_cq_1_0 *cq, int sol_only) argument 300 return cq 643 struct ibv_cq_1_0 *cq; local 667 __ibv_resize_cq_1_0(struct ibv_cq_1_0 *cq, int cqe) argument 673 __ibv_destroy_cq_1_0(struct ibv_cq_1_0 *cq) argument 686 __ibv_get_cq_event_1_0(struct ibv_comp_channel *channel, struct ibv_cq_1_0 **cq, void **cq_context) argument 704 __ibv_ack_cq_events_1_0(struct ibv_cq_1_0 *cq, unsigned int nevents) argument [all...] |
H A D | device.c | 199 event->element.cq = (void *) (uintptr_t) ev.element; 234 struct ibv_cq *cq = event->element.cq; local 236 pthread_mutex_lock(&cq->mutex); 237 ++cq->async_events_completed; 238 pthread_cond_signal(&cq->cond); 239 pthread_mutex_unlock(&cq->mutex);
|
/freebsd-9.3-release/contrib/ofed/usr.lib/libmlx4/ |
H A D | Makefile | 17 SRCS= buf.c cq.c dbrec.c mlx4.c qp.c srq.c verbs.c
|
/freebsd-9.3-release/sys/contrib/rdma/ |
H A D | rdma_verbs.c | 600 struct ib_cq *cq; local 602 cq = device->create_cq(device, cqe, comp_vector, NULL, NULL); 604 if (!IS_ERR(cq)) { 605 cq->device = device; 606 cq->uobject = NULL; 607 cq->comp_handler = comp_handler; 608 cq->event_handler = event_handler; 609 cq->cq_context = cq_context; 610 atomic_store_rel_int(&cq->usecnt, 0); 613 return cq; 616 ib_destroy_cq(struct ib_cq *cq) argument 624 ib_resize_cq(struct ib_cq *cq, int cqe) argument [all...] |