This is an automated email from the ASF dual-hosted git repository.
upthewaterspout pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/geode.git.
from dffcb94 GEODE-7152: Send alert messages using executor
new 1b72091 GEODE-7049: Add timeout to Java native client
Execute::execute() methods
new 1d21356 GEODE-7049: Change signature of execute with timeout methods
to use a TimeUnit param
new 66e327c GEODE-7049: add TimeUnit param to executeFunction methods and
handle smaller than 1ms values and greater than Integer.MAX_VALUE ms
new b8b6769 Merge branch 'develop' into feature/GEODE-7049
new 940fe4f GEODE-7049: Add timeout to Java native client
Execute::execute() methods
new 8f1cfd6 GEODE-7049: Change signature of execute with timeout methods
to use a TimeUnit param
new cd869a0 GEODE-7049: add TimeUnit param to executeFunction methods and
handle smaller than 1ms values and greater than Integer.MAX_VALUE ms
new 86477eb Add timeout to function execution from server and improve
comments in function execution API
new 1b7edf0 Merge branch 'GEODE-7049-new' into feature/GEODE-7049
new 776c5ed Add test cases to function execution with timeout from servers
new 4516172 Update Geode version where new API methods have been added.
new 2c512a7 Merge pull request #3888 from Nordix/feature/GEODE-7049
The 8420 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../ClientFunctionTimeoutRegressionTest.java | 33 +++-
...istributedRegionFunctionExecutionDUnitTest.java | 104 +++++++++++++
.../execute/MemberFunctionExecutionDUnitTest.java | 173 ++++++++++++++++-----
.../MultiRegionFunctionExecutionDUnitTest.java | 87 +++++++++++
.../execute/PRFunctionExecutionDUnitTest.java | 157 +++++++++++++++++++
.../org/apache/geode/cache/execute/Execution.java | 49 +++++-
.../internal/cache/execute/AbstractExecution.java | 20 ++-
.../cache/execute/CachedResultCollector.java} | 38 ++---
.../cache/execute/DefaultResultCollector.java | 7 +-
.../execute/DistributedRegionFunctionExecutor.java | 42 +++--
.../execute/FunctionStreamingResultCollector.java | 18 ++-
.../cache/execute/LocalResultCollectorImpl.java | 19 ++-
.../cache/execute/MemberFunctionExecutor.java | 21 ++-
.../cache/execute/MultiRegionFunctionExecutor.java | 21 ++-
.../execute/PartitionedRegionFunctionExecutor.java | 23 +--
.../cache/execute/ResultCollectorHolder.java | 79 ++++++++++
.../cache/execute/ServerFunctionExecutor.java | 47 +++---
.../execute/ServerRegionFunctionExecutor.java | 35 +++--
.../internal/cache/execute/TimeoutHelper.java | 23 +--
.../PRFunctionStreamingResultCollector.java | 18 ++-
.../internal/cache/execute/TimeoutHelperTest.java | 57 +++++++
.../internal/cache/functions/TestFunction.java | 2 +-
22 files changed, 907 insertions(+), 166 deletions(-)
copy
geode-core/src/{distributedTest/java/org/apache/geode/internal/cache/execute/CustomResultCollector.java
=>
main/java/org/apache/geode/internal/cache/execute/CachedResultCollector.java}
(60%)
mode change 100755 => 100644
create mode 100644
geode-core/src/main/java/org/apache/geode/internal/cache/execute/ResultCollectorHolder.java
copy
geode-dunit/src/main/java/org/apache/geode/internal/cache/execute/PRColocationDUnitTestHelper.java
=>
geode-core/src/main/java/org/apache/geode/internal/cache/execute/TimeoutHelper.java
(71%)
create mode 100644
geode-core/src/test/java/org/apache/geode/internal/cache/execute/TimeoutHelperTest.java
