From 17b67c30cc6c076d1ee66657a9708ab1be4c9cfa Mon Sep 17 00:00:00 2001 From: Rob Austin Date: Fri, 12 Dec 2014 15:48:59 +0000 Subject: [PATCH] if issue when onRead has no attached --- src/main/java/net/openhft/chronicle/map/TcpReplicator.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/src/main/java/net/openhft/chronicle/map/TcpReplicator.java b/src/main/java/net/openhft/chronicle/map/TcpReplicator.java index 88fcd6183..230bbce37 100644 --- a/src/main/java/net/openhft/chronicle/map/TcpReplicator.java +++ b/src/main/java/net/openhft/chronicle/map/TcpReplicator.java @@ -639,6 +639,12 @@ final class TcpReplicator extends AbstractChannelReplicator implements Closeable final SocketChannel socketChannel = (SocketChannel) key.channel(); final Attached attached = (Attached) key.attachment(); + if (attached == null) { + LOG.info("Closing connection " + socketChannel + ", nothing attached"); + socketChannel.close(); + return; + } + try { int len = attached.entryReader.readSocketToBuffer(socketChannel);