diff --git a/cmake/external/grpc.cmake b/cmake/external/grpc.cmake index e06c337254d39ebc87fb6bbd9e6bcbd9bae18218..7828ba24aaca5e7eba8b85037ddcd2bf1a2f2799 100644 --- a/cmake/external/grpc.cmake +++ b/cmake/external/grpc.cmake @@ -47,7 +47,7 @@ ExternalProject_Add( #URL "http://paddlepaddledeps.bj.bcebos.com/grpc-v1.10.x.tar.gz" URL "http://localhost:8000/grpc-v1.13.x.tar.gz" #URL_MD5 "1f268a2aff6759839dccd256adcc91cf" - URL_MD5 "27019f520a32161396b319e57c24a5ac" + URL_MD5 "c93a1ba08a449e5b800524131cc900a8" PREFIX ${GRPC_SOURCES_DIR} UPDATE_COMMAND "" CONFIGURE_COMMAND "" diff --git a/paddle/fluid/operators/distributed/grpc_client.cc b/paddle/fluid/operators/distributed/grpc_client.cc index c42f7e4326efd6c8ef153a3eab724516f4ee49fb..7f16692d684144ea76a3e831f2f05a107a5f7f78 100644 --- a/paddle/fluid/operators/distributed/grpc_client.cc +++ b/paddle/fluid/operators/distributed/grpc_client.cc @@ -15,6 +15,7 @@ limitations under the License. */ #include "paddle/fluid/operators/distributed/grpc_client.h" #include +#include #include @@ -42,8 +43,32 @@ void GRPCClient::SendComplete() { } GRPCClient::~GRPCClient() { + LOG(ERROR) << "start sleep:"; + usleep(10000); + for (auto& it : channels_) { + LOG(ERROR) << "channel service config:" + << it.second->GetServiceConfigJSON(); + LOG(ERROR) << "channel lb config:" + << it.second->GetLoadBalancingPolicyName(); + } + Wait(); + + for (auto& it : channels_) { + LOG(ERROR) << "channel service config:" + << it.second->GetServiceConfigJSON(); + LOG(ERROR) << "channel lb config:" + << it.second->GetLoadBalancingPolicyName(); + } + cq_.Shutdown(); + for (auto& it : channels_) { + LOG(ERROR) << "channel service config:" + << it.second->GetServiceConfigJSON(); + LOG(ERROR) << "channel lb config:" + << it.second->GetLoadBalancingPolicyName(); + } + { std::lock_guard guard(chan_mutex_); for (auto& it : channels_) { @@ -53,6 +78,7 @@ GRPCClient::~GRPCClient() { } channels_.clear(); } + client_thread_->join(); }