HCOLL-383 Fix TcpReplicator

This commit is contained in:
leventov
2015-09-04 16:53:49 +03:00
parent e873899ff4
commit 600325d1e3
@@ -430,7 +430,7 @@ final class TcpReplicator<K, V> extends AbstractChannelReplicator implements Clo
// is no-longer required as the remote node will establish the connection its self
// on startup.
attached.connector.connect();
attached.connector.connectLater();
throw e;
}
@@ -977,11 +977,7 @@ final class TcpReplicator<K, V> extends AbstractChannelReplicator implements Clo
socketChannel.socket().setSoLinger(false, 0);
socketChannel.socket().setSoTimeout(0);
try {
socketChannel.connect(details.address());
} catch (UnresolvedAddressException e) {
this.connectLater();
}
socketChannel.connect(details.address());
// Under experiment, the concoction was found to be more successful if we
// paused before registering the OP_CONNECT
@@ -1018,6 +1014,7 @@ final class TcpReplicator<K, V> extends AbstractChannelReplicator implements Clo
} catch (IOException e) {
LOG.error("", e);
}
this.connectLater();
}
}
}