From 0f5a9cc9fc31bb1c6682c06feb713fa793adb3b8 Mon Sep 17 00:00:00 2001 From: qiaolongfei Date: Fri, 20 Apr 2018 16:52:29 +0800 Subject: [PATCH] change RunSyncUpdate to RunSyncLoop --- paddle/fluid/operators/listen_and_serv_op.cc | 9 +++++---- paddle/fluid/operators/listen_and_serv_op.h | 8 ++++---- 2 files changed, 9 insertions(+), 8 deletions(-) diff --git a/paddle/fluid/operators/listen_and_serv_op.cc b/paddle/fluid/operators/listen_and_serv_op.cc index 49e191b7bb..af235fb6a0 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 68c8da4d38..dfb7c77c8e 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;