From 0d04545e9cba70ed4393f455b5bf97ee1412480f Mon Sep 17 00:00:00 2001
From: minqiyang <minqiyang@baidu.com>
Date: Thu, 5 Jul 2018 20:19:08 +0800
Subject: [PATCH] Remove debug info

---
 cmake/external/grpc.cmake                     |  2 +-
 .../operators/distributed/grpc_client.cc      | 29 -------------------
 2 files changed, 1 insertion(+), 30 deletions(-)

diff --git a/cmake/external/grpc.cmake b/cmake/external/grpc.cmake
index 7828ba24a..42f94bb62 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 "c93a1ba08a449e5b800524131cc900a8"
+    URL_MD5 "f5ae795081d7e5befa648876aee62cc8"
     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 7f16692d6..7feccf3c6 100644
--- a/paddle/fluid/operators/distributed/grpc_client.cc
+++ b/paddle/fluid/operators/distributed/grpc_client.cc
@@ -15,7 +15,6 @@ limitations under the License. */
 #include "paddle/fluid/operators/distributed/grpc_client.h"
 
 #include <sys/time.h>
-#include <unistd.h>
 
 #include <limits>
 
@@ -43,37 +42,11 @@ 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<std::mutex> guard(chan_mutex_);
     for (auto& it : channels_) {
-      LOG(ERROR) << "channel ptr use count:" << it.second.use_count();
-      LOG(ERROR) << "channel ptr use count:" << it.second.get();
       it.second.reset();
     }
     channels_.clear();
@@ -330,9 +303,7 @@ std::shared_ptr<grpc::Channel> GRPCClient::GetChannel(const std::string& ep) {
 
   auto ch =
       grpc::CreateCustomChannel(ep, grpc::InsecureChannelCredentials(), args);
-  LOG(ERROR) << "get channel ep: " << ep << "count: " << ch.use_count();
   channels_[ep] = ch;
-  LOG(ERROR) << "get channel ep: " << ep << "count: " << ch.use_count();
   return ch;
 }
 
-- 
GitLab