corrected if (!attached.isServer || !attached.isHandShakingComplete())

return;
This commit is contained in:
Rob Austin
2015-09-15 19:44:24 +01:00
parent ef39df5a59
commit 522f0503b3
@@ -388,7 +388,7 @@ final class TcpReplicator<K, V> extends AbstractChannelReplicator implements Clo
final Attached attached = (Attached) key.attachment();
if (attached.isServer && !attached.isHandShakingComplete())
if (!attached.isServer || !attached.isHandShakingComplete())
return;
final SocketChannel channel = (SocketChannel) key.channel();
@@ -412,6 +412,7 @@ final class TcpReplicator<K, V> extends AbstractChannelReplicator implements Clo
if (replicationConfig.autoReconnectedUponDroppedConnection())
attached.connector.connectLater();
}
}
/**