| /net/9p/ |
| D | trans_rdma.c | 82 struct ib_cq *cq; member
291 recv_done(struct ib_cq *cq, struct ib_wc *wc) in recv_done() argument
293 struct p9_client *client = cq->cq_context; in recv_done()
342 send_done(struct ib_cq *cq, struct ib_wc *wc) in send_done() argument
344 struct p9_client *client = cq->cq_context; in send_done()
374 if (rdma->cq && !IS_ERR(rdma->cq)) in rdma_destroy_trans()
375 ib_free_cq(rdma->cq); in rdma_destroy_trans()
698 rdma->cq = ib_alloc_cq_any(rdma->cm_id->device, client, in rdma_create_trans()
701 if (IS_ERR(rdma->cq)) in rdma_create_trans()
719 qp_attr.send_cq = rdma->cq; in rdma_create_trans()
[all …]
|
| /net/sunrpc/ |
| D | cache.c | 974 struct cache_queue *cq; in cache_poll() local
986 for (cq= &rp->q; &cq->list != &cd->queue; in cache_poll()
987 cq = list_entry(cq->list.next, struct cache_queue, list)) in cache_poll()
988 if (!cq->reader) { in cache_poll()
1002 struct cache_queue *cq; in cache_ioctl() local
1012 for (cq= &rp->q; &cq->list != &cd->queue; in cache_ioctl()
1013 cq = list_entry(cq->list.next, struct cache_queue, list)) in cache_ioctl()
1014 if (!cq->reader) { in cache_ioctl()
1016 container_of(cq, struct cache_request, q); in cache_ioctl()
1060 struct cache_queue *cq; in cache_release() local
[all …]
|
| /net/sunrpc/xprtrdma/ |
| D | frwr_ops.c | 360 static void frwr_wc_fastreg(struct ib_cq *cq, struct ib_wc *wc) in frwr_wc_fastreg() argument
370 rpcrdma_flush_disconnect(cq->cq_context, wc); in frwr_wc_fastreg()
444 static void frwr_wc_localinv(struct ib_cq *cq, struct ib_wc *wc) in frwr_wc_localinv() argument
455 rpcrdma_flush_disconnect(cq->cq_context, wc); in frwr_wc_localinv()
465 static void frwr_wc_localinv_wake(struct ib_cq *cq, struct ib_wc *wc) in frwr_wc_localinv_wake() argument
477 rpcrdma_flush_disconnect(cq->cq_context, wc); in frwr_wc_localinv_wake()
568 static void frwr_wc_localinv_done(struct ib_cq *cq, struct ib_wc *wc) in frwr_wc_localinv_done() argument
584 rpcrdma_flush_disconnect(cq->cq_context, wc); in frwr_wc_localinv_done()
|
| D | svc_rdma_rw.c | 17 static void svc_rdma_write_done(struct ib_cq *cq, struct ib_wc *wc);
18 static void svc_rdma_wc_read_done(struct ib_cq *cq, struct ib_wc *wc);
238 static void svc_rdma_write_done(struct ib_cq *cq, struct ib_wc *wc) in svc_rdma_write_done() argument
296 static void svc_rdma_wc_read_done(struct ib_cq *cq, struct ib_wc *wc) in svc_rdma_wc_read_done() argument
|
| D | svc_rdma_recvfrom.c | 111 static void svc_rdma_wc_receive(struct ib_cq *cq, struct ib_wc *wc);
316 static void svc_rdma_wc_receive(struct ib_cq *cq, struct ib_wc *wc) in svc_rdma_wc_receive() argument
318 struct svcxprt_rdma *rdma = cq->cq_context; in svc_rdma_wc_receive()
|
| D | svc_rdma_sendto.c | 116 static void svc_rdma_wc_send(struct ib_cq *cq, struct ib_wc *wc);
276 static void svc_rdma_wc_send(struct ib_cq *cq, struct ib_wc *wc) in svc_rdma_wc_send() argument
278 struct svcxprt_rdma *rdma = cq->cq_context; in svc_rdma_wc_send()
|
| D | verbs.c | 162 static void rpcrdma_wc_send(struct ib_cq *cq, struct ib_wc *wc) in rpcrdma_wc_send() argument
167 struct rpcrdma_xprt *r_xprt = cq->cq_context; in rpcrdma_wc_send()
181 static void rpcrdma_wc_receive(struct ib_cq *cq, struct ib_wc *wc) in rpcrdma_wc_receive() argument
186 struct rpcrdma_xprt *r_xprt = cq->cq_context; in rpcrdma_wc_receive()
|
| /net/xdp/ |
| D | xsk_buff_pool.c | 78 pool->cq = xs->cq_tmp; in xp_create_and_assign_umem()
208 if (!pool->fq || !pool->cq) in xp_assign_dev_shared()
243 if (pool->cq) { in xp_release_deferred()
244 xskq_destroy(pool->cq); in xp_release_deferred()
245 pool->cq = NULL; in xp_release_deferred()
|
| D | xsk_diag.c | 73 if (!err && pool && pool->cq) in xsk_diag_put_umem()
74 err = xsk_diag_put_ring(pool->cq, in xsk_diag_put_umem()
|
| D | xsk.c | 296 xskq_prod_submit_n(pool->cq, nb_entries); in xsk_tx_completed()
330 if (xskq_prod_reserve_addr(pool->cq, desc->addr)) in xsk_tx_peek_desc()
368 xskq_prod_submit_addr(xs->pool->cq, addr); in xsk_destruct_skb()
420 if (unlikely(err) || xskq_prod_reserve(xs->pool->cq)) { in xsk_generic_xmit()
438 xskq_prod_cancel(xs->pool->cq); in xsk_generic_xmit()
|
| /net/rds/ |
| D | ib_cm.c | 281 static void rds_ib_cq_comp_handler_recv(struct ib_cq *cq, void *context) in rds_ib_cq_comp_handler_recv() argument
286 rdsdebug("conn %p cq %p\n", conn, cq); in rds_ib_cq_comp_handler_recv()
293 static void poll_scq(struct rds_ib_connection *ic, struct ib_cq *cq, in poll_scq() argument
299 while ((nr = ib_poll_cq(cq, RDS_IB_WC_MAX, wcs)) > 0) { in poll_scq()
337 static void poll_rcq(struct rds_ib_connection *ic, struct ib_cq *cq, in poll_rcq() argument
344 while ((nr = ib_poll_cq(cq, RDS_IB_WC_MAX, wcs)) > 0) { in poll_rcq()
409 static void rds_ib_cq_comp_handler_send(struct ib_cq *cq, void *context) in rds_ib_cq_comp_handler_send() argument
414 rdsdebug("conn %p cq %p\n", conn, cq); in rds_ib_cq_comp_handler_send()
|
| /net/ipv4/ |
| D | ipconfig.c | 1383 char *cp, *cq; in root_nfs_parse_addr() local
1385 cp = cq = name; in root_nfs_parse_addr()
1389 if (cp == cq || cp - cq > 3) in root_nfs_parse_addr()
1395 cq = cp; in root_nfs_parse_addr()
|