use the pending instead of the ending

oneflow/core/comm_network/ibverbs/ibverbs_qp.cpp

@@ -190,7 +190,7 @@ void IBVerbsQP::PostSendRequest(const ActorMsg& msg) {
 }
 
 void IBVerbsQP::EnqueuePostSendReadWR(ibv_send_wr wr, ibv_sge sge) {
-  std::unique_lock<std::mutex> ending_send_wr_lock_(pending_send_wr_mutex_);
+  std::unique_lock<std::mutex> pending_send_wr_lock_(pending_send_wr_mutex_);
   if (num_outstanding_send_wr_ < max_outstanding_send_wr_) {
     num_outstanding_send_wr_++;
     ibv_send_wr* bad_wr = nullptr;
@@ -208,7 +208,7 @@ void IBVerbsQP::ReadDone(WorkRequestId* wr_id) {
     Global<CommNet>::Get()->ReadDone(wr_id->read_id);
     DeleteWorkRequestId(wr_id);
   }
-  PostPenddingSendWR();
+  PostPendingSendWR();
 }
 
 void IBVerbsQP::SendDone(WorkRequestId* wr_id) {
@@ -228,8 +228,8 @@ void IBVerbsQP::RecvDone(WorkRequestId* wr_id) {
   DeleteWorkRequestId(wr_id);
 }
 
-void IBVerbsQP::PostPenddingSendWR() {
-  std::unique_lock<std::mutex> ending_send_wr_lock_(pending_send_wr_mutex_);
+void IBVerbsQP::PostPendingSendWR() {
+  std::unique_lock<std::mutex> pending_send_wr_lock_(pending_send_wr_mutex_);
   if (pending_send_wr_queue_.empty() == false) {
     std::pair<ibv_send_wr, ibv_sge> ibv_send_wr_sge = std::move(pending_send_wr_queue_.front());
     ibv_send_wr wr = ibv_send_wr_sge.first;

oneflow/core/comm_network/ibverbs/ibverbs_qp.h

@@ -71,7 +71,7 @@ class IBVerbsQP final {
 
  private:
   void EnqueuePostSendReadWR(ibv_send_wr wr, ibv_sge sge);
-  void PostPenddingSendWR();
+  void PostPendingSendWR();
   WorkRequestId* NewWorkRequestId();
   void DeleteWorkRequestId(WorkRequestId* wr_id);
   ActorMsgMR* GetOneSendMsgMRFromBuf();