未验证 提交 41564184 编写于 作者: X xiaoxiao-luomu 提交者: GitHub

delete gloo connect retry (#37616)

上级 d50ae7ec
...@@ -278,23 +278,6 @@ void ParallelConnectContext::connectFullMesh( ...@@ -278,23 +278,6 @@ void ParallelConnectContext::connectFullMesh(
std::string ip = getCharIpAddr(sa->sin_addr.s_addr); std::string ip = getCharIpAddr(sa->sin_addr.s_addr);
VLOG(0) << "peer " << i << " ip addr: " << ip VLOG(0) << "peer " << i << " ip addr: " << ip
<< ", port: " << sa->sin_port; << ", 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::seconds>(
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); transportContext->getPair(i)->connect(addr);
} }
VLOG(0) << "peer connected success"; VLOG(0) << "peer connected success";
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册