Lines Matching refs:wc

131 rpcrdma_sendcq_process_wc(struct ib_wc *wc)  in rpcrdma_sendcq_process_wc()  argument
134 if (wc->wr_id == RPCRDMA_IGNORE_COMPLETION) { in rpcrdma_sendcq_process_wc()
135 if (wc->status != IB_WC_SUCCESS && in rpcrdma_sendcq_process_wc()
136 wc->status != IB_WC_WR_FLUSH_ERR) in rpcrdma_sendcq_process_wc()
138 __func__, ib_wc_status_msg(wc->status)); in rpcrdma_sendcq_process_wc()
142 r = (struct rpcrdma_mw *)(unsigned long)wc->wr_id; in rpcrdma_sendcq_process_wc()
143 r->mw_sendcompletion(wc); in rpcrdma_sendcq_process_wc()
194 rpcrdma_recvcq_process_wc(struct ib_wc *wc) in rpcrdma_recvcq_process_wc() argument
197 (struct rpcrdma_rep *)(unsigned long)wc->wr_id; in rpcrdma_recvcq_process_wc()
200 if (wc->status != IB_WC_SUCCESS) in rpcrdma_recvcq_process_wc()
204 if (wc->opcode != IB_WC_RECV) in rpcrdma_recvcq_process_wc()
208 __func__, rep, wc->byte_len); in rpcrdma_recvcq_process_wc()
210 rep->rr_len = wc->byte_len; in rpcrdma_recvcq_process_wc()
221 if (wc->status != IB_WC_WR_FLUSH_ERR) in rpcrdma_recvcq_process_wc()
223 __func__, rep, ib_wc_status_msg(wc->status)); in rpcrdma_recvcq_process_wc()
267 struct ib_wc wc; in rpcrdma_flush_cqs() local
269 while (ib_poll_cq(ep->rep_attr.recv_cq, 1, &wc) > 0) in rpcrdma_flush_cqs()
270 rpcrdma_recvcq_process_wc(&wc); in rpcrdma_flush_cqs()
271 while (ib_poll_cq(ep->rep_attr.send_cq, 1, &wc) > 0) in rpcrdma_flush_cqs()
272 rpcrdma_sendcq_process_wc(&wc); in rpcrdma_flush_cqs()
441 struct ib_wc wc; in rpcrdma_clean_cq() local
444 while (1 == ib_poll_cq(cq, 1, &wc)) in rpcrdma_clean_cq()
449 __func__, count, wc.opcode); in rpcrdma_clean_cq()