From b9302248a2575f6f6c2994a9ff176ef1ff5a0545 Mon Sep 17 00:00:00 2001 From: Rob Austin Date: Mon, 2 Feb 2015 09:28:52 +0000 Subject: [PATCH] now not closing on a - AsynchronousCloseException e --- .../java/net/openhft/chronicle/map/StatelessChronicleMap.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/main/java/net/openhft/chronicle/map/StatelessChronicleMap.java b/src/main/java/net/openhft/chronicle/map/StatelessChronicleMap.java index 69cd99d19..29610c33c 100644 --- a/src/main/java/net/openhft/chronicle/map/StatelessChronicleMap.java +++ b/src/main/java/net/openhft/chronicle/map/StatelessChronicleMap.java @@ -42,6 +42,7 @@ import java.lang.reflect.Field; import java.net.InetSocketAddress; import java.nio.ByteBuffer; import java.nio.ByteOrder; +import java.nio.channels.AsynchronousCloseException; import java.nio.channels.SocketChannel; import java.util.*; import java.util.concurrent.atomic.AtomicLong; @@ -1151,6 +1152,9 @@ class StatelessChronicleMap implements ChronicleMap, Closeable, Clon try { return blockingFetchThrowable(timeoutTime, transactionId); + } catch (AsynchronousCloseException e) { + LOG.error("name=" + name, e); + throw new RuntimeException(e); } catch (IOException e) { close(); throw new IORuntimeException(e);