diff --git a/paddle/fluid/operators/listen_and_serv_op.cc b/paddle/fluid/operators/listen_and_serv_op.cc index 10064357eace09e9efe5678fdf23267fe1653824..7e2f8e74d673396927eb20e53b0e96ff72a595f2 100644 --- a/paddle/fluid/operators/listen_and_serv_op.cc +++ b/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("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); } diff --git a/paddle/fluid/operators/listen_and_serv_op.h b/paddle/fluid/operators/listen_and_serv_op.h index 9b915a594105483a5e72c3396287928337562d5c..2372e3cf3ee20abdfeb32655c9f58e9d579937cd 100644 --- a/paddle/fluid/operators/listen_and_serv_op.h +++ b/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,