aboutsummaryrefslogtreecommitdiffstats
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/plugins/rdma/input.c12
-rw-r--r--src/plugins/rdma/output.c7
2 files changed, 10 insertions, 9 deletions
diff --git a/src/plugins/rdma/input.c b/src/plugins/rdma/input.c
index 7ced1ec66d4..f5091db4719 100644
--- a/src/plugins/rdma/input.c
+++ b/src/plugins/rdma/input.c
@@ -128,12 +128,12 @@ rdma_device_input_refill (vlib_main_t * vm, rdma_device_t * rd,
w[-1].next = 0; /* fix next pointer in WR linked-list last item */
- w = wr;
- ibv_post_wq_recv (rxq->wq, wr, &w);
- n = wr == w ? n_alloc : (uintptr_t) (w - wr);
-
- if (PREDICT_FALSE (n != n_alloc))
- vlib_buffer_free (vm, buffers + n, n_alloc - n);
+ n = n_alloc;
+ if (ibv_post_wq_recv (rxq->wq, wr, &w) != 0)
+ {
+ n = w - wr;
+ vlib_buffer_free (vm, buffers + n, n_alloc - n);
+ }
rxq->n_enq += n;
}
diff --git a/src/plugins/rdma/output.c b/src/plugins/rdma/output.c
index bb25abe1a98..ddda81a4b19 100644
--- a/src/plugins/rdma/output.c
+++ b/src/plugins/rdma/output.c
@@ -57,7 +57,7 @@ VNET_DEVICE_CLASS_TX_FN (rdma_device_class) (vlib_main_t * vm,
vlib_buffer_t *bufs[VLIB_FRAME_SIZE], **b = bufs;
struct ibv_send_wr wr[VLIB_FRAME_SIZE], *w = wr;
struct ibv_sge sge[VLIB_FRAME_SIZE], *s = sge;
- int i;
+ int i, ret;
f = from = vlib_frame_vector_args (frame);
n_left_from = frame->n_vectors;
@@ -155,12 +155,13 @@ VNET_DEVICE_CLASS_TX_FN (rdma_device_class) (vlib_main_t * vm,
for (i = 0; i < 5; i++)
{
rdma_device_output_free (vm, txq);
- if (0 == ibv_post_send (txq->qp, w, &w))
+ ret = ibv_post_send (txq->qp, w, &w);
+ if (0 == ret)
break;
}
clib_spinlock_unlock_if_init (&txq->lock);
- n_tx_packets = w == wr ? frame->n_vectors : w - wr;
+ n_tx_packets = 0 == ret ? frame->n_vectors : w - wr;
n_tx_failed = frame->n_vectors - n_tx_packets;
if (PREDICT_FALSE (n_tx_failed))