From e6dcef2e81f259bc256d88daaafddc6329f59ace Mon Sep 17 00:00:00 2001 From: Rob Austin Date: Thu, 27 Nov 2014 07:21:06 +0000 Subject: [PATCH] HCOLL-216 reintroduced the spin look into the selector --- src/main/java/net/openhft/chronicle/map/TcpReplicator.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/main/java/net/openhft/chronicle/map/TcpReplicator.java b/src/main/java/net/openhft/chronicle/map/TcpReplicator.java index 3fbc6525e..718bfde30 100644 --- a/src/main/java/net/openhft/chronicle/map/TcpReplicator.java +++ b/src/main/java/net/openhft/chronicle/map/TcpReplicator.java @@ -142,7 +142,7 @@ final class TcpReplicator extends AbstractChannelReplicator implements Closeable registerPendingRegistrations(); - final int nSelectedKeys = selector.selectNow(); + final int nSelectedKeys = select(); // its less resource intensive to set this less frequently and use an approximation final long approxTime = System.currentTimeMillis(); @@ -284,6 +284,7 @@ final class TcpReplicator extends AbstractChannelReplicator implements Closeable final int keys = selector.selectNow(); if (keys != 0) return keys; + } return selector.select(selectorTimeout); @@ -295,6 +296,7 @@ final class TcpReplicator extends AbstractChannelReplicator implements Closeable * * @param approxTime the approximate time in milliseconds */ + void heartBeatMonitor(long approxTime) { for (int i = activeKeys.nextSetBit(0); i >= 0; i = activeKeys.nextSetBit(i + 1)) {