You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by bs...@apache.org on 2020/04/28 14:23:00 UTC
[geode] 01/01: revert change to Connection.java
This is an automated email from the ASF dual-hosted git repository.
bschuchardt pushed a commit to branch feature/GEODE-8020b
in repository https://gitbox.apache.org/repos/asf/geode.git
commit ae8ea5ca334c83426d7e3f55f8630f8ad03d689a
Author: Bruce Schuchardt <bs...@pivotal.io>
AuthorDate: Tue Apr 28 07:21:59 2020 -0700
revert change to Connection.java
---
geode-core/src/main/java/org/apache/geode/internal/tcp/Connection.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/geode-core/src/main/java/org/apache/geode/internal/tcp/Connection.java b/geode-core/src/main/java/org/apache/geode/internal/tcp/Connection.java
index f8f6932..719f48e 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/tcp/Connection.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/tcp/Connection.java
@@ -1720,7 +1720,7 @@ public class Connection implements Runnable {
if (inputBuffer != null) {
getBufferPool().releaseReceiveBuffer(inputBuffer);
}
- inputBuffer = getBufferPool().acquireNonDirectReceiveBuffer(packetBufferSize);
+ inputBuffer = getBufferPool().acquireDirectReceiveBuffer(packetBufferSize);
}
if (channel.socket().getReceiveBufferSize() < packetBufferSize) {
channel.socket().setReceiveBufferSize(packetBufferSize);