diff --git a/paddle/fluid/operators/listen_and_serv_op.cc b/paddle/fluid/operators/listen_and_serv_op.cc index 49e191b7bb9e97c91ae2e536550aebd6e91c6fce..af235fb6a029a71ee275bebfbbd75aaa0b7d546d 100644 --- a/paddle/fluid/operators/listen_and_serv_op.cc +++ b/paddle/fluid/operators/listen_and_serv_op.cc @@ -70,9 +70,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(); @@ -201,7 +202,7 @@ void ListenAndServOp::RunImpl(const framework::Scope &scope, sleep(5); // Write to a file of server selected port for python use. SavePort(rpc_service_); - RunSyncUpdate(&executor, program, &recv_scope, prefetch_block); + RunSyncLoop(&executor, program, &recv_scope, prefetch_block); } class ListenAndServOpMaker : public framework::OpProtoAndCheckerMaker { diff --git a/paddle/fluid/operators/listen_and_serv_op.h b/paddle/fluid/operators/listen_and_serv_op.h index 68c8da4d382221f662932789e67ce2aacf18e1a3..dfb7c77c8e36d9af79d8b1713d0c0c59c81b1ca6 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 Stop() override;