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

1234

/freebsd-9.3-release/sys/ofed/drivers/net/mlx4/
H A Den_cq.c36 #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 Dcq.c41 #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 Dcq.c34 #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 DMakefile3 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 Dmthca_cq.c168 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 Dmthca_provider.c680 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 Dcq.c110 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 Dverbs.c169 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 Dcq.c125 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 Dverbs.c193 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 Dmthca.h270 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 Ddisklabel.c69 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 Dcq.h110 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 Doce_queue.c77 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 DTBI12 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 DTI13 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 DTB11 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 Diw_cxgb_hal.c109 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 Diw_cxgb_wr.h677 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 Diw_cxgb_hal.h138 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 Dverbs.c276 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 Dcompat-1_0.c180 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 Ddevice.c199 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 DMakefile17 SRCS= buf.c cq.c dbrec.c mlx4.c qp.c srq.c verbs.c
/freebsd-9.3-release/sys/contrib/rdma/
H A Drdma_verbs.c600 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...]

Completed in 349 milliseconds

1234