rename ProcessMsgAndWardKernel to ProcessMsgWithKernelCtx

oneflow/core/actor/copy_actor.cpp

@@ -8,7 +8,7 @@ void CopyActor::Init(const TaskProto& task_proto) {
   Actor::Init(task_proto);
 }
 
-void CopyActor::ProcessMsgAndWardKernel(const ActorMsg& msg,
+void CopyActor::ProcessMsgWithKernelCtx(const ActorMsg& msg,
                                         const KernelContext& kernel_ctx) {
   if (TryOneReadDone(msg.regst_warpper()->regst_raw_ptr()) != 0) {
     waiting_in_regst_.push(std::move(msg.regst_warpper()));

oneflow/core/actor/copy_actor.h

@@ -15,7 +15,7 @@ public:
 
 protected:
   CopyActor() = default;
-  void ProcessMsgAndWardKernel(const ActorMsg& msg, const KernelContext& kernel_ctx);
+  void ProcessMsgWithKernelCtx(const ActorMsg& msg, const KernelContext& kernel_ctx);
 
 private:
   std::queue<std::shared_ptr<RegstWarpper>> waiting_in_regst_;

oneflow/core/actor/copy_comm_net_actor.cpp

@@ -7,7 +7,7 @@ namespace oneflow {
 void CopyCommNetActor::ProcessMsg(const ActorMsg& msg,
                                   const ThreadContext&) {
   KernelContext kernel_ctx;
-  ProcessMsgAndWardKernel(msg, kernel_ctx);
+  ProcessMsgWithKernelCtx(msg, kernel_ctx);
 }
 
 REGISTER_ACTOR(kCopyCommNetTask, true, CopyCommNetActor);

oneflow/core/actor/copy_hd_actor.cpp

@@ -8,7 +8,7 @@ void CopyHdActor::ProcessMsg(const ActorMsg& msg,
                              const ThreadContext& thread_ctx) {
   KernelContext kernel_ctx;
   kernel_ctx.cuda_stream = thread_ctx.copy_hd_cuda_stream;
-  ProcessMsgAndWardKernel(msg, kernel_ctx);
+  ProcessMsgWithKernelCtx(msg, kernel_ctx);
 }
 
 REGISTER_ACTOR(kCopyHdTask, true, CopyHdActor);