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

return;
This commit is contained in:
Rob Austin
2015-10-02 02:51:50 +03:00
committed by leventov
parent 488dc752c8
commit efe6db066f
@@ -388,7 +388,7 @@ public final class TcpReplicator<K, V> extends AbstractChannelReplicator impleme
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 @@ public final class TcpReplicator<K, V> extends AbstractChannelReplicator impleme
if (replicationConfig.autoReconnectedUponDroppedConnection())
attached.connector.connectLater();
}
}
/**