From 41564184b42cf33d2f1d3495f322652cf78fd240 Mon Sep 17 00:00:00 2001 From: xiaoxiao-luomu <73728031+xiaoxiao-luomu@users.noreply.github.com> Date: Mon, 29 Nov 2021 11:14:01 +0800 Subject: [PATCH] delete gloo connect retry (#37616) --- paddle/fluid/framework/fleet/gloo_wrapper.cc | 17 ----------------- 1 file changed, 17 deletions(-) diff --git a/paddle/fluid/framework/fleet/gloo_wrapper.cc b/paddle/fluid/framework/fleet/gloo_wrapper.cc index 14e5f2f519..d850d05d87 100644 --- a/paddle/fluid/framework/fleet/gloo_wrapper.cc +++ b/paddle/fluid/framework/fleet/gloo_wrapper.cc @@ -278,23 +278,6 @@ void ParallelConnectContext::connectFullMesh( std::string ip = getCharIpAddr(sa->sin_addr.s_addr); VLOG(0) << "peer " << i << " ip addr: " << ip << ", port: " << sa->sin_port; - - auto start = std::chrono::steady_clock::now(); - std::chrono::seconds connect_wait_timeout_ = - std::chrono::seconds(600); - while (true) { - auto elapsed = std::chrono::duration_cast( - std::chrono::steady_clock::now() - start); - if (elapsed > connect_wait_timeout_) { - break; - } - try { - transportContext->getPair(i)->connect(addr); - break; - } catch (...) { - VLOG(0) << "gloo connect failed, retrying..."; - } - } transportContext->getPair(i)->connect(addr); } VLOG(0) << "peer connected success"; -- GitLab