ensure that we close() on interupt

Conflicts: src/test/java/net/openhft/chronicle/map/CHMUseCasesTest.java
2021-09-13 01:26:12 +00:00 · 2015-07-25 17:08:55 +03:00
parent 9557993b8f
commit 3ce0a03ca2
2 changed files with 19 additions and 14 deletions
@@ -263,7 +263,9 @@ public final class TcpReplicator<K, V> extends AbstractChannelReplicator impleme
                    LOG.debug("onWrite - " + name);
                onWrite(key, approxTime);
            }
-        } catch (BufferUnderflowException | InterruptedException | IOException |
+        } catch (InterruptedException e) {
+            quietClose(key, e);
+        } catch (BufferUnderflowException | IOException |
                ClosedSelectorException | CancelledKeyException e) {
            if (!isClosed)
                quietClose(key, e);