From a1f1a5ed8a75c54c2c61938c30df7fa38a24c57f Mon Sep 17 00:00:00 2001 From: tangwei12 Date: Tue, 26 Jun 2018 16:34:23 +0800 Subject: [PATCH] rename grpc to rpc (#11717) --- paddle/fluid/operators/distributed/grpc_client.h | 2 +- paddle/fluid/operators/distributed/rpc_client.h | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/paddle/fluid/operators/distributed/grpc_client.h b/paddle/fluid/operators/distributed/grpc_client.h index 69705d72106..7a08f2d3a4a 100644 --- a/paddle/fluid/operators/distributed/grpc_client.h +++ b/paddle/fluid/operators/distributed/grpc_client.h @@ -212,7 +212,7 @@ class GRPCClient : public RPCClient { int64_t time_out = FLAGS_rpc_deadline) override; void AsyncCheckpointNotify(const std::string& ep, const std::string& dir, - int64_t time_out = FLAGS_grpc_deadline) override; + int64_t time_out = FLAGS_rpc_deadline) override; void Wait() override; diff --git a/paddle/fluid/operators/distributed/rpc_client.h b/paddle/fluid/operators/distributed/rpc_client.h index cc3ae96787a..37783b78ecc 100644 --- a/paddle/fluid/operators/distributed/rpc_client.h +++ b/paddle/fluid/operators/distributed/rpc_client.h @@ -56,9 +56,9 @@ class RPCClient { virtual void AsyncSendFetchBarrier(const std::string& ep, int64_t time_out = FLAGS_rpc_deadline) = 0; - virtual void AsyncCheckpointNotify( - const std::string& ep, const std::string& dir, - int64_t time_out = FLAGS_grpc_deadline) = 0; + virtual void AsyncCheckpointNotify(const std::string& ep, + const std::string& dir, + int64_t time_out = FLAGS_rpc_deadline) = 0; // SendComplete tells all the server that current trainer have no more data // to train, so that the pserver can reduce it's barrier count, and continue -- GitLab