diff --git a/paddle/fluid/operators/distributed/grpc_client.h b/paddle/fluid/operators/distributed/grpc_client.h index 102b4e5bcf72c6ba54ff2e171ff8deb348de7481..eab9fc7e866ef6430a15b2c5fa93da0df85d7a38 100644 --- a/paddle/fluid/operators/distributed/grpc_client.h +++ b/paddle/fluid/operators/distributed/grpc_client.h @@ -211,9 +211,8 @@ class GRPCClient : public RPCClient { void AsyncSendFetchBarrier(const std::string& ep, int64_t time_out = FLAGS_grpc_deadline) override; - void AsyncCheckpointNotify( - const std::string& ep, const std::string& dir, - int64_t time_out = RPCClient::rpc_time_out) override; + void AsyncCheckpointNotify(const std::string& ep, const std::string& dir, + int64_t time_out = FLAGS_grpc_deadline) override; void Wait() override; diff --git a/paddle/fluid/operators/distributed/rpc_client.h b/paddle/fluid/operators/distributed/rpc_client.h index 84bef0ab2341a5fa11e0d803471912491f3152fe..4ce01287aa84725c8f507d5c8c5c3c9077596131 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_grpc_deadline) = 0; - virtual void AsyncCheckpointNotify(const std::string& ep, - const std::string& dir, - int64_t time_out = rpc_time_out) = 0; + virtual void AsyncCheckpointNotify( + const std::string& ep, const std::string& dir, + int64_t time_out = FLAGS_grpc_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