Lines Matching refs:cq
1872 static void srpt_process_rcv_completion(struct ib_cq *cq, in srpt_process_rcv_completion() argument
1910 static void srpt_process_send_completion(struct ib_cq *cq, in srpt_process_send_completion() argument
1955 static void srpt_process_completion(struct ib_cq *cq, struct srpt_rdma_ch *ch) in srpt_process_completion() argument
1960 WARN_ON(cq != ch->cq); in srpt_process_completion()
1962 ib_req_notify_cq(cq, IB_CQ_NEXT_COMP); in srpt_process_completion()
1963 while ((n = ib_poll_cq(cq, ARRAY_SIZE(ch->wc), wc)) > 0) { in srpt_process_completion()
1966 srpt_process_rcv_completion(cq, ch, &wc[i]); in srpt_process_completion()
1968 srpt_process_send_completion(cq, ch, &wc[i]); in srpt_process_completion()
1984 static void srpt_completion(struct ib_cq *cq, void *ctx) in srpt_completion() argument
2004 (srpt_process_completion(ch->cq, ch), in srpt_compl_thread()
2033 ch->cq = ib_create_cq(sdev->device, srpt_completion, NULL, ch, in srpt_create_ch_ib()
2035 if (IS_ERR(ch->cq)) { in srpt_create_ch_ib()
2036 ret = PTR_ERR(ch->cq); in srpt_create_ch_ib()
2045 qp_init->send_cq = ch->cq; in srpt_create_ch_ib()
2046 qp_init->recv_cq = ch->cq; in srpt_create_ch_ib()
2059 ib_destroy_cq(ch->cq); in srpt_create_ch_ib()
2070 __func__, ch->cq->cqe, qp_init->cap.max_send_sge, in srpt_create_ch_ib()
2096 ib_destroy_cq(ch->cq); in srpt_create_ch_ib()
2106 ib_destroy_cq(ch->cq); in srpt_destroy_ch_ib()