in interface/rdbc/net_channel.cpp [99:118]
int NetChannel::Send(const std::string& data) {
if (long_connect_tion_) {
return SendFromKeepAlive(data);
}
for (int i = 0; i < max_retry_time_; ++i) {
if (!connected_) {
if (Connect()) {
LOG(ERROR) << "connect fail:" << ip_ << " port:" << port_;
continue;
}
}
int ret = SendDataInternal(data);
if (ret >= 0) {
return ret;
} else if (ret == -1) {
LOG(ERROR) << "send data fail:" << ip_ << " port:" << port_;
}
}
return -1;
}