diff --git a/src/client/messenger.cpp b/src/client/messenger.cpp index bfc1aed8..0325d297 100644 --- a/src/client/messenger.cpp +++ b/src/client/messenger.cpp @@ -749,7 +749,7 @@ void osd_messenger_t::check_peer_config(osd_client_t *cl) } }); // Add the initial receive request - try_recv_rdma(cl); + init_recv_rdma(cl); } } #endif diff --git a/src/client/messenger.h b/src/client/messenger.h index a52634a8..0318f04e 100644 --- a/src/client/messenger.h +++ b/src/client/messenger.h @@ -289,7 +289,7 @@ protected: void try_send_rdma(osd_client_t *cl); void try_send_rdma_odp(osd_client_t *cl); void try_send_rdma_nodp(osd_client_t *cl); - bool try_recv_rdma(osd_client_t *cl); + bool init_recv_rdma(osd_client_t *cl); void handle_rdma_events(msgr_rdma_context_t *rdma_context); msgr_rdma_context_t* choose_rdma_context(osd_client_t *cl); #endif diff --git a/src/client/msgr_rdma.cpp b/src/client/msgr_rdma.cpp index 47b79902..5e25ed20 100644 --- a/src/client/msgr_rdma.cpp +++ b/src/client/msgr_rdma.cpp @@ -734,7 +734,7 @@ static void try_recv_rdma_wr(osd_client_t *cl, msgr_rdma_buf_t b) cl->rdma_conn->cur_recv++; } -bool osd_messenger_t::try_recv_rdma(osd_client_t *cl) +bool osd_messenger_t::init_recv_rdma(osd_client_t *cl) { auto rc = cl->rdma_conn; while (rc->cur_recv < rc->max_recv) diff --git a/src/client/msgr_rdmacm.cpp b/src/client/msgr_rdmacm.cpp index 8be31326..9a402386 100644 --- a/src/client/msgr_rdmacm.cpp +++ b/src/client/msgr_rdmacm.cpp @@ -531,7 +531,7 @@ void osd_messenger_t::rdmacm_established(rdma_cm_event *ev) fprintf(stderr, "Successfully connected with OSD %ju using RDMA-CM\n", peer_osd); } // Add initial receive request(s) - try_recv_rdma(cl); + init_recv_rdma(cl); if (peer_osd) { check_peer_config(cl); diff --git a/src/client/msgr_send.cpp b/src/client/msgr_send.cpp index 0e49d10e..92da6980 100644 --- a/src/client/msgr_send.cpp +++ b/src/client/msgr_send.cpp @@ -363,7 +363,7 @@ void osd_messenger_t::handle_send(int result, bool prev, bool more, osd_client_t } }); // Add the initial receive request - try_recv_rdma(cl); + init_recv_rdma(cl); } #endif }