| 740 | } |
| 741 | |
| 742 | void Connection::forceConnected(const ConnectionTimeouts & timeouts) |
| 743 | { |
| 744 | if (!isConnected()) |
| 745 | { |
| 746 | connect(timeouts); |
| 747 | } |
| 748 | else if (!ping(timeouts)) |
| 749 | { |
| 750 | ProfileEvents::increment(ProfileEvents::DistributedConnectionReconnectCount); |
| 751 | LOG_TRACE(log_wrapper.get(), "Connection was closed, will reconnect."); |
| 752 | connect(timeouts); |
| 753 | } |
| 754 | } |
| 755 | |
| 756 | #if USE_SSL |
| 757 | void Connection::sendClusterNameAndSalt() |