libcapulet: increase maximum Send/Recv count

libcapulet/rdma_ib.c

@@ -44,8 +44,8 @@ bool capulet_rdma_ib_initialize_qp(struct CapuletRdmaIbContext *ctx, int access)
 
 	int result;
 
-	ctx->send_cq = ibv_create_cq(ctx->ib_ctx, 16, NULL, NULL, 0);
-	ctx->recv_cq = ibv_create_cq(ctx->ib_ctx, 16, NULL, NULL, 0);
+	ctx->send_cq = ibv_create_cq(ctx->ib_ctx, 32, NULL, NULL, 0);
+	ctx->recv_cq = ibv_create_cq(ctx->ib_ctx, 32, NULL, NULL, 0);
 	if(!ctx->send_cq || !ctx->recv_cq) {
 		return false;
 	}
@@ -60,10 +60,10 @@ bool capulet_rdma_ib_initialize_qp(struct CapuletRdmaIbContext *ctx, int access)
 	ibv_dev_qp_request.send_cq = ctx->send_cq;
 	ibv_dev_qp_request.recv_cq = ctx->recv_cq;
 
-	ibv_dev_qp_request.cap.max_send_wr = 16;
-	ibv_dev_qp_request.cap.max_recv_wr = 16;
-	ibv_dev_qp_request.cap.max_send_sge = 16;
-	ibv_dev_qp_request.cap.max_recv_sge = 16;
+	ibv_dev_qp_request.cap.max_send_wr = 32;
+	ibv_dev_qp_request.cap.max_recv_wr = 32;
+	ibv_dev_qp_request.cap.max_send_sge = 32;
+	ibv_dev_qp_request.cap.max_recv_sge = 32;
 
 	ibv_dev_qp = ibv_create_qp(ctx->pd, &ibv_dev_qp_request);
 

libtrx/trx_rdma.c

@@ -122,7 +122,7 @@ int trx_rdma_start(TRXState *s, const TRXDriverParams2 *p) {
 	if(!result) return -1;
 
 	// Fill the Recv queue
-	for(int i = 0; i < 16; i++) {
+	for(int i = 0; i < 32; i++) {
 		capulet_rdma_ib_post_recv(&sdr_context->ib_ctx, sdr_context->in_mr, sizeof(struct SDRMemoryRegion));
 	}