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