Merge branch 'refine-listen-and-serve-op' of ssh://github.com/jacquesqiao/Paddle into add-async-listen-and-serv-op

paddle/fluid/operators/listen_and_serv_op.cc

@@ -100,9 +100,10 @@ void ListenAndServOp::Stop() {
   server_thread_->join();
 }
 
-void ListenAndServOp::RunSyncUpdate(
-    framework::Executor *executor, framework::ProgramDesc *program,
-    framework::Scope *recv_scope, framework::BlockDesc *prefetch_block) const {
+void ListenAndServOp::RunSyncLoop(framework::Executor *executor,
+                                  framework::ProgramDesc *program,
+                                  framework::Scope *recv_scope,
+                                  framework::BlockDesc *prefetch_block) const {
   auto fan_in = Attr<int>("Fanin");
 
   size_t num_blocks = program->Size();
@@ -302,7 +303,7 @@ void ListenAndServOp::RunImpl(const framework::Scope &scope,
   // Write to a file of server selected port for python use.
   SavePort(rpc_service_);
   if (sync_mode) {
-    RunSyncUpdate(&executor, program, &recv_scope, prefetch_block);
+    RunSyncLoop(&executor, program, &recv_scope, prefetch_block);
   } else {
     RunAsyncUpdate(&executor, program, &recv_scope, prefetch_block);
   }

paddle/fluid/operators/listen_and_serv_op.h

@@ -41,10 +41,10 @@ class ListenAndServOp : public framework::OperatorBase {
 
   int GetSelectedPort() const;
 
-  void RunSyncUpdate(framework::Executor* executor,
-                     framework::ProgramDesc* program,
-                     framework::Scope* recv_scope,
-                     framework::BlockDesc* prefetch_block) const;
+  void RunSyncLoop(framework::Executor* executor,
+                   framework::ProgramDesc* program,
+                   framework::Scope* recv_scope,
+                   framework::BlockDesc* prefetch_block) const;
 
   void RunAsyncUpdate(framework::Executor* executor,
                       framework::ProgramDesc* program,