Alawn/Chronicle-Map
1
0
Fork 0
mirror of https://github.com/OpenHFT/Chronicle-Map.git synced 2021-09-13 01:26:12 +00:00
Code Releases Activity

added connection listener check

Browse Source
This commit is contained in:
leventov
2015-10-02 02:45:38 +03:00
parent dad9de7ca2
commit fe4b200142
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/net/openhft/chronicle/map/TcpReplicator.java
+2 -3
View File
@@ -394,8 +394,7 @@ public final class TcpReplicator<K, V> extends AbstractChannelReplicator impleme
if (LOG.isDebugEnabled())
LOG.debug("", e);
// null check (Attached)key.attachment();
if (key.channel() != null && key.attachment() != null)
if (key.channel() != null && key.attachment() != null && connectionListener != null)
connectionListener.onDisconnect(((SocketChannel) key.channel()).socket().getInetAddress(),
((Attached) key.attachment()).remoteIdentifier);
@@ -589,7 +588,7 @@ public final class TcpReplicator<K, V> extends AbstractChannelReplicator impleme
attached.remoteIdentifier = remoteIdentifier;
final SocketChannel channel = (SocketChannel) key.channel();
if (channel != null && channel.socket() != null) {
if (channel != null && channel.socket() != null && connectionListener != null) {
connectionListener.onConnect(channel.socket().getInetAddress(),
attached.remoteIdentifier, attached.isServer);
}