Skip to content

Commit 0f5a9cc

Browse files
committed
change RunSyncUpdate to RunSyncLoop
1 parent d144dba commit 0f5a9cc

File tree

2 files changed

+9
-8
lines changed

2 files changed

+9
-8
lines changed

paddle/fluid/operators/listen_and_serv_op.cc

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -70,9 +70,10 @@ void ListenAndServOp::Stop() {
7070
server_thread_->join();
7171
}
7272

73-
void ListenAndServOp::RunSyncUpdate(
74-
framework::Executor *executor, framework::ProgramDesc *program,
75-
framework::Scope *recv_scope, framework::BlockDesc *prefetch_block) const {
73+
void ListenAndServOp::RunSyncLoop(framework::Executor *executor,
74+
framework::ProgramDesc *program,
75+
framework::Scope *recv_scope,
76+
framework::BlockDesc *prefetch_block) const {
7677
auto fan_in = Attr<int>("Fanin");
7778

7879
size_t num_blocks = program->Size();
@@ -201,7 +202,7 @@ void ListenAndServOp::RunImpl(const framework::Scope &scope,
201202
sleep(5);
202203
// Write to a file of server selected port for python use.
203204
SavePort(rpc_service_);
204-
RunSyncUpdate(&executor, program, &recv_scope, prefetch_block);
205+
RunSyncLoop(&executor, program, &recv_scope, prefetch_block);
205206
}
206207

207208
class ListenAndServOpMaker : public framework::OpProtoAndCheckerMaker {

paddle/fluid/operators/listen_and_serv_op.h

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -41,10 +41,10 @@ class ListenAndServOp : public framework::OperatorBase {
4141

4242
int GetSelectedPort() const;
4343

44-
void RunSyncUpdate(framework::Executor* executor,
45-
framework::ProgramDesc* program,
46-
framework::Scope* recv_scope,
47-
framework::BlockDesc* prefetch_block) const;
44+
void RunSyncLoop(framework::Executor* executor,
45+
framework::ProgramDesc* program,
46+
framework::Scope* recv_scope,
47+
framework::BlockDesc* prefetch_block) const;
4848

4949
void Stop() override;
5050

0 commit comments

Comments
 (0)