From 39d35914ab9cc0b0ece9de54b4abe07ad6e5f5d3 Mon Sep 17 00:00:00 2001 From: Rob Austin Date: Fri, 12 Dec 2014 15:37:06 +0000 Subject: [PATCH] HCOLL-240 changed to tcpBufferSize() --- .../openhft/chronicle/map/StatelessChronicleMap.java | 4 ++-- .../net/openhft/chronicle/map/StatelessMapConfig.java | 10 +++++----- 2 files changed, 7 insertions(+), 7 deletions(-) diff --git a/src/main/java/net/openhft/chronicle/map/StatelessChronicleMap.java b/src/main/java/net/openhft/chronicle/map/StatelessChronicleMap.java index 253df7f79..1051cc25c 100644 --- a/src/main/java/net/openhft/chronicle/map/StatelessChronicleMap.java +++ b/src/main/java/net/openhft/chronicle/map/StatelessChronicleMap.java @@ -1191,7 +1191,7 @@ class StatelessChronicleMap implements ChronicleMap, Closeable, Clon // if we have other threads waiting to send and the buffer is not full, let the other threads // write to the buffer if (outBytesLock.hasQueuedThreads() && - outBytes.position() + lagestEntrySoFar <= config.packetSize()) { + outBytes.position() + lagestEntrySoFar <= config.tcpBufferSize()) { return; } @@ -1215,7 +1215,7 @@ class StatelessChronicleMap implements ChronicleMap, Closeable, Clon // if we have queued threads then we don't have to write all the bytes as the other // threads will write the remains bytes. if (outBuffer.remaining() > 0 && outBytesLock.hasQueuedThreads() && - outBuffer.remaining() + lagestEntrySoFar <= config.packetSize()) { + outBuffer.remaining() + lagestEntrySoFar <= config.tcpBufferSize()) { LOG.debug("continuing - without all the data being written to the buffer as " + diff --git a/src/main/java/net/openhft/chronicle/map/StatelessMapConfig.java b/src/main/java/net/openhft/chronicle/map/StatelessMapConfig.java index 538f9de30..b145f0f82 100644 --- a/src/main/java/net/openhft/chronicle/map/StatelessMapConfig.java +++ b/src/main/java/net/openhft/chronicle/map/StatelessMapConfig.java @@ -35,7 +35,7 @@ class StatelessMapConfig implements StatelessClientConfig implements StatelessClientConfig