return 1;\r
}\r
}\r
- /* post recieve max msg size*/\r
+ /* post receive max msg size*/\r
{\r
int i;\r
struct ibv_recv_wr *bad_wr_recv;\r
- //recieve\r
+ //receive\r
ctx->rwr.wr_id = PINGPONG_RECV_WRID;\r
ctx->rwr.sg_list = &ctx->recv_list;\r
ctx->rwr.num_sge = 1;\r
* Important note :\r
* In case of UD/UC this is NOT the way to measure\r
* BW sicen we are running with loop on the send side\r
- * while we should run on the recieve side or enable retry in SW\r
+ * while we should run on the receive side or enable retry in SW\r
* Since the sender may be faster than the reciver than although\r
- * we had posted recieve it is not enough and might end this will\r
+ * we had posted receive it is not enough and might end this will\r
* result in deadlock of test since both sides are stuck on poll cq\r
* In this test i do not solve this for the general test ,need to send\r
* seperate test for UC/UD but in case the tx_depth is ~1/3 from the\r
while (rcnt < user_param->iters) {\r
int ne;\r
struct ibv_wc wc;\r
- /*Server is polling on recieve first */\r
+ /*Server is polling on receive first */\r
if (user_param->use_event) {\r
struct ibv_cq *ev_cq;\r
void *ev_ctx;\r
} while (ne > 0 );\r
\r
if (ne < 0) {\r
- fprintf(stderr, "Poll Recieve CQ failed %d\n", ne);\r
+ fprintf(stderr, "Poll Receive CQ failed %d\n", ne);\r
return 12;\r
}\r
}\r
ctx->wr.opcode = IBV_WR_SEND;\r
ctx->wr.next = NULL;\r
\r
- /* recieve */\r
+ /* receive */\r
ctx->rwr.wr_id = PINGPONG_RECV_WRID;\r
ctx->rwr.sg_list = &ctx->recv_list;\r
ctx->rwr.num_sge = 1;\r
}\r
ctx->rcq = ibv_create_cq(ctx->context, tx_depth, NULL, ctx->channel, 0);\r
if (!ctx->rcq) {\r
- fprintf(stderr, "Couldn't create Recieve CQ\n");\r
+ fprintf(stderr, "Couldn't create Receive CQ\n");\r
return NULL;\r
}\r
{\r
ctx->wr.num_sge = 1;\r
ctx->wr.opcode = IBV_WR_SEND;\r
ctx->wr.next = NULL;\r
- //recieve\r
+ //receive\r
ctx->rwr.wr_id = PINGPONG_RECV_WRID;\r
ctx->rwr.sg_list = &ctx->recv_list;\r
ctx->rwr.num_sge = 1;\r
return 1;\r
}\r
}\r
- /* post recieve max msg size*/\r
+ /* post receive max msg size*/\r
{\r
int i;\r
struct ibv_recv_wr *bad_wr_recv;\r
if (rcnt < iters && !(scnt < 1 && user_param->servername)) {\r
int ne;\r
struct ibv_wc wc;\r
- /*Server is polling on recieve first */\r
+ /*Server is polling on receive first */\r
++rcnt;\r
if (ibv_post_recv(qp, &rwr, &bad_wr_recv)) {\r
fprintf(stderr, "Couldn't post recv: rcnt=%d\n",\r
} while (!user_param->use_event && ne < 1);\r
\r
if (ne < 0) {\r
- fprintf(stderr, "Poll Recieve CQ failed %d\n", ne);\r
+ fprintf(stderr, "Poll Receive CQ failed %d\n", ne);\r
return 12;\r
}\r
if (wc.status != IBV_WC_SUCCESS) {\r
- fprintf(stderr, "Recieve Completion wth error at %s:\n",\r
+ fprintf(stderr, "Receive Completion wth error at %s:\n",\r
user_param->servername ? "client" : "server");\r
fprintf(stderr, "Failed status %d: wr_id %d\n",\r
wc.status, (int) wc.wr_id);\r
} while (ib_status == IB_SUCCESS);
if (ib_status != IB_NOT_FOUND) {
- fprintf(stderr, "Poll Recieve CQ failed %d\n", ib_status);
+ fprintf(stderr, "Poll Receive CQ failed %d\n", ib_status);
return 12;
}
- /* post recieve max msg size*/
+ /* post receive max msg size*/
{
int i;
ib_recv_wr_t *bad_wr_recv;
- //recieve
+ //receive
ctx->rwr.wr_id = PINGPONG_RECV_WRID;
ctx->rwr.ds_array = &ctx->recv_list;
ctx->rwr.num_ds = 1;
* BW since we are running with loop on the send side
* while we should run on the receive side or enable retry in SW
* Since the sender may be faster than the reciver than although
- * we had posted recieve it is not enough and might end this will
+ * we had posted receive it is not enough and might end this will
* result in deadlock of test since both sides are stuck on poll cq
* In this test i do not solve this for the general test ,need to write
* separate test for UC/UD but in case the tx_depth is ~1/3 from the
p_wc_done = NULL;
p_wc_free->p_next = NULL;
- /*Server is polling on recieve first */
+ /*Server is polling on receive first */
if (user_param->use_event) {
cl_status_t cl_status;
}
} while (ib_status == IB_SUCCESS);
if (ib_status != IB_NOT_FOUND) {
- fprintf(stderr, "Poll Recieve CQ failed %d\n", ib_status);
+ fprintf(stderr, "Poll Receive CQ failed %d\n", ib_status);
return 12;
}
ctx->wr.wr_type = WR_SEND;
ctx->wr.p_next = NULL;
- //recieve
+ //receive
ctx->rwr.wr_id = PINGPONG_RECV_WRID;
ctx->rwr.ds_array = &ctx->recv_list;
ctx->rwr.num_ds = 1;
- /* post recieve max msg size*/
+ /* post receive max msg size*/
{
int i;
ib_recv_wr_t *bad_wr_recv;
- //recieve
+ //receive
ctx->rwr.wr_id = PINGPONG_RECV_WRID;
ctx->rwr.ds_array = &ctx->recv_list;
ctx->rwr.num_ds = 1;
p_wc_free->p_next = NULL;
PERF_DEBUG("rcnt %d\n",rcnt);
PERF_DEBUG("scnt %d\n",scnt);
- /*Server is polling on recieve first */
+ /*Server is polling on receive first */
++rcnt;
if (ib_post_recv(qp, &rwr, &bad_wr_recv)) {
fprintf(stderr, "Couldn't post recv: rcnt=%d\n",
} while (ib_status == IB_NOT_FOUND);
if (ib_status != IB_SUCCESS) {
- fprintf(stderr, "Poll Recieve CQ failed %d\n", ib_status);
+ fprintf(stderr, "Poll Receive CQ failed %d\n", ib_status);
return 12;
}
if (p_wc_done->status != IB_WCS_SUCCESS) {
- fprintf(stderr, "Recieve Completion wth error at %s:\n",
+ fprintf(stderr, "Receive Completion wth error at %s:\n",
user_param->servername ? "client" : "server");
fprintf(stderr, "Failed status %d: wr_id %d\n",
wc.status, (int) wc.wr_id);
} while (ib_status == IB_NOT_FOUND);
if (ib_status != IB_SUCCESS) {
- fprintf(stderr, "Poll Recieve CQ failed %d\n", ib_status);
+ fprintf(stderr, "Poll Receive CQ failed %d\n", ib_status);
return 12;
}
if (wc.status != IB_WCS_SUCCESS) {
- fprintf(stderr, "Recieve Completion wth error at %s:\n",
+ fprintf(stderr, "Receive Completion wth error at %s:\n",
user_param->servername ? "client" : "server");
fprintf(stderr, "Failed status %d: wr_id %d\n",
wc.status, (int) wc.wr_id);
} while (ib_status == IB_SUCCESS);
if (ib_status != IB_NOT_FOUND) {
- fprintf(stderr, "Poll Recieve CQ failed %d\n", ib_status);
+ fprintf(stderr, "Poll Receive CQ failed %d\n", ib_status);
return 12;
}
{\r
IPOIB_ENTER( IPOIB_DBG_ENDPT );\r
\r
- /* This function must be called from the recieve path */\r
+ /* This function must be called from the receive path */\r
CL_ASSERT(p_port->endpt_rdr > 0);\r
\r
cl_obj_lock( &p_port->obj );\r