|
@@ -192,8 +192,11 @@ rpcrdma_sendcq_upcall(struct ib_cq *cq, void *cq_context)
|
|
|
return;
|
|
|
}
|
|
|
|
|
|
- rc = ib_req_notify_cq(cq, IB_CQ_NEXT_COMP);
|
|
|
- if (rc) {
|
|
|
+ rc = ib_req_notify_cq(cq,
|
|
|
+ IB_CQ_NEXT_COMP | IB_CQ_REPORT_MISSED_EVENTS);
|
|
|
+ if (rc == 0)
|
|
|
+ return;
|
|
|
+ if (rc < 0) {
|
|
|
dprintk("RPC: %s: ib_req_notify_cq failed: %i\n",
|
|
|
__func__, rc);
|
|
|
return;
|
|
@@ -272,8 +275,11 @@ rpcrdma_recvcq_upcall(struct ib_cq *cq, void *cq_context)
|
|
|
return;
|
|
|
}
|
|
|
|
|
|
- rc = ib_req_notify_cq(cq, IB_CQ_NEXT_COMP);
|
|
|
- if (rc) {
|
|
|
+ rc = ib_req_notify_cq(cq,
|
|
|
+ IB_CQ_NEXT_COMP | IB_CQ_REPORT_MISSED_EVENTS);
|
|
|
+ if (rc == 0)
|
|
|
+ return;
|
|
|
+ if (rc < 0) {
|
|
|
dprintk("RPC: %s: ib_req_notify_cq failed: %i\n",
|
|
|
__func__, rc);
|
|
|
return;
|