This is an automated email from the ASF dual-hosted git repository. upthewaterspout pushed a commit to branch feature/redis-performance-testing in repository https://gitbox.apache.org/repos/asf/geode.git
commit 5fb8bb82e53601d35344197376f2a42b20a11f9e Author: Jens Deppe <[email protected]> AuthorDate: Thu Feb 25 15:38:16 2021 -0800 HACK - run functions on same thread --- .../geode/redis/internal/executor/RedisCommandsFunctionInvoker.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/geode-redis/src/main/java/org/apache/geode/redis/internal/executor/RedisCommandsFunctionInvoker.java b/geode-redis/src/main/java/org/apache/geode/redis/internal/executor/RedisCommandsFunctionInvoker.java index 33f1355..cef95fd 100644 --- a/geode-redis/src/main/java/org/apache/geode/redis/internal/executor/RedisCommandsFunctionInvoker.java +++ b/geode-redis/src/main/java/org/apache/geode/redis/internal/executor/RedisCommandsFunctionInvoker.java @@ -22,6 +22,7 @@ import org.apache.geode.cache.Region; import org.apache.geode.cache.execute.FunctionException; import org.apache.geode.cache.execute.FunctionService; import org.apache.geode.internal.cache.PrimaryBucketLockException; +import org.apache.geode.internal.cache.tier.sockets.ServerConnection; import org.apache.geode.redis.internal.data.RedisData; import org.apache.geode.redis.internal.data.RedisKey; @@ -39,6 +40,7 @@ public abstract class RedisCommandsFunctionInvoker { do { SingleResultCollector<T> resultsCollector = new SingleResultCollector<>(); try { + ServerConnection.executeFunctionOnLocalNodeOnly((byte) 1); FunctionService .onRegion(region) .withFilter(Collections.singleton(filter))
