This is an automated email from the ASF dual-hosted git repository.
udo pushed a change to branch newFunctionService
in repository https://gitbox.apache.org/repos/asf/geode.git.
from 11e472d Initial FS commit
new b31f421 Splitting of FunctionService into Client and server
completed. Removing of original FunctionService, before removing the import
statement to final real failures.
new ace2643 List of all files that require changes due to the static
referencing of FunctionService
The 2 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:
.../internal/common/ClientServerSessionCache.java | 2 +-
.../internal/common/PeerToPeerSessionCache.java | 2 +-
.../session/catalina/ClientServerSessionCache.java | 2 +-
.../session/catalina/PeerToPeerSessionCache.java | 2 +-
.../geode/modules/util/BootstrappingFunction.java | 2 +-
.../modules/util/ModuleFunctionsSecurityTest.java | 2 +-
.../RestAPIOnRegionFunctionExecutionDUnitTest.java | 2 +-
.../internal/web/controllers/RestAPITestBase.java | 2 +-
...RestAPIsOnGroupsFunctionExecutionDUnitTest.java | 2 +-
...estAPIsOnMembersFunctionExecutionDUnitTest.java | 2 +-
.../RestQueryAndFunctionIntegrationTest.java | 2 +-
.../cli/JDBCConnectorFunctionsSecurityTest.java | 2 +-
geode-core/build.gradle | 15 +
.../apache/geode/cache/DynamicRegionFactory.java | 2 +-
.../java/org/apache/geode/cache/Operation.java | 2 +-
.../org/apache/geode/cache/client/ClientCache.java | 4 +
.../cache/client/function/FunctionService.java | 82 ------
.../geode/cache/client/function/FunctionService.kt | 82 ++++++
.../internal/function/FunctionServiceImpl.java | 136 ---------
.../internal/function/FunctionServiceImpl.kt | 124 +++++++++
.../cache/common/function/FunctionServiceBase.java | 2 +-
.../geode/cache/execute/FunctionService.java | 272 ------------------
.../execute/internal/FunctionServiceManager.java | 308 +--------------------
.../geode/cache/function/FunctionService.java | 77 ------
.../apache/geode/cache/function/FunctionService.kt | 76 +++++
.../cache/function/internal/FunctionServiceImpl.kt | 91 ++++++
.../cache/partition/PartitionRegionHelper.java | 2 +-
.../java/org/apache/geode/cache/query/Query.java | 2 +-
.../internal/deadlock/GemFireDeadlockDetector.java | 2 +-
.../org/apache/geode/internal/DeployedJar.java | 2 +-
.../internal/cache/ClusterConfigurationLoader.java | 2 +-
.../geode/internal/cache/ColocationHelper.java | 2 +-
.../DistributedRegionFunctionStreamingMessage.java | 2 +-
.../geode/internal/cache/GemFireCacheImpl.java | 301 +++++++++++---------
.../apache/geode/internal/cache/InternalCache.java | 4 +
.../cache/MemberFunctionStreamingMessage.java | 2 +-
.../geode/internal/cache/PartitionedRegion.java | 74 +++--
.../internal/cache/execute/AbstractExecution.java | 3 +-
.../execute/DistributedRegionFunctionExecutor.java | 2 +-
.../cache/execute/FunctionRemoteContext.java | 2 +-
.../internal/cache/execute/InternalExecution.java | 2 +-
.../cache/execute/InternalFunctionException.java | 2 +-
.../cache/execute/RegionFunctionContextImpl.java | 2 +-
.../cache/execute/ServerFunctionExecutor.java | 12 +-
.../execute/ServerRegionFunctionExecutor.java | 2 +-
.../internal/cache/snapshot/ClientExporter.java | 2 +-
.../cache/snapshot/RegionSnapshotServiceImpl.java | 2 +-
.../internal/cache/snapshot/WindowedExporter.java | 2 +-
.../tier/sockets/command/ExecuteFunction.java | 2 +-
.../tier/sockets/command/ExecuteFunction65.java | 2 +-
.../tier/sockets/command/ExecuteFunction66.java | 2 +-
.../sockets/command/ExecuteRegionFunction.java | 2 +-
.../sockets/command/ExecuteRegionFunction61.java | 2 +-
.../sockets/command/ExecuteRegionFunction65.java | 2 +-
.../sockets/command/ExecuteRegionFunction66.java | 2 +-
.../command/ExecuteRegionFunctionSingleHop.java | 2 +-
.../tier/sockets/command/GetFunctionAttribute.java | 2 +-
.../internal/cache/xmlcache/CacheXmlGenerator.java | 2 +-
.../cache/xmlcache/FunctionServiceCreation.java | 2 +-
.../management/internal/JmxManagerLocator.java | 2 +-
.../internal/MBeanProxyInvocationHandler.java | 2 +-
.../internal/SystemManagementService.java | 2 +-
.../internal/beans/MemberMBeanBridge.java | 2 +-
.../internal/beans/QueryDataFunction.java | 2 +-
.../geode/management/internal/cli/CliUtil.java | 2 +-
.../cli/commands/ChangeLogLevelCommand.java | 2 +-
.../internal/cli/commands/DataCommandsUtils.java | 2 +-
.../cli/commands/DescribeClientCommand.java | 2 +-
.../cli/commands/DestroyFunctionCommand.java | 2 +-
.../cli/commands/ExecuteFunctionCommand.java | 2 +-
.../internal/cli/commands/GfshCommand.java | 4 +-
.../internal/cli/commands/QueryCommand.java | 2 +-
.../internal/cli/commands/ShutdownCommand.java | 2 +-
.../cli/functions/ListFunctionFunction.java | 2 +-
.../internal/cli/functions/UnregisterFunction.java | 2 +-
.../cli/functions/UserFunctionExecution.java | 2 +-
.../management/MemoryThresholdsDUnitTest.java | 2 +-
.../dunit/QueryUsingFunctionContextDUnitTest.java | 2 +-
.../PartitionedRegionEquiJoinIntegrationTest.java | 2 +-
.../partitioned/PRColocatedEquiJoinDUnitTest.java | 2 +-
.../query/partitioned/PRQueryDUnitHelper.java | 2 +-
.../apache/geode/cache30/CacheXml66DUnitTest.java | 2 +-
.../deadlock/GemFireDeadlockDetectorDUnitTest.java | 2 +-
.../internal/ClassPathLoaderIntegrationTest.java | 2 +-
.../geode/internal/JarDeployerDeadlockTest.java | 2 +-
.../geode/internal/cache/CommitFunction.java | 2 +-
...FireAndForgetFunctionOnAllServersDUnitTest.java | 2 +-
.../internal/cache/NestedTransactionFunction.java | 2 +-
.../cache/PartitionedRegionSingleHopDUnitTest.java | 2 +-
.../internal/cache/RemoteTransactionDUnitTest.java | 2 +-
.../geode/internal/cache/RollbackFunction.java | 2 +-
.../ClientFunctionTimeoutRegressionTest.java | 2 +-
.../ClientServerFunctionExecutionDUnitTest.java | 2 +-
...istributedRegionFunctionExecutionDUnitTest.java | 2 +-
.../FunctionExecution_ExceptionDUnitTest.java | 2 +-
.../FunctionServiceClientAccessorPRBase.java | 2 +-
.../execute/FunctionServiceClientOnServerBase.java | 2 +-
.../execute/FunctionServiceLocalPRDUnitTest.java | 2 +-
.../execute/FunctionServiceLocalRRDUnitTest.java | 2 +-
.../FunctionServiceMultipleOnMemberDUnitTest.java | 2 +-
.../execute/FunctionServicePeerAccessorPRBase.java | 2 +-
.../FunctionServicePeerAccessorPRDUnitTest.java | 2 +-
...vicePeerAccessorPRMultipleMembersDUnitTest.java | 2 +-
.../FunctionServicePeerAccessorRRDUnitTest.java | 2 +-
.../FunctionServiceSingleOnMemberDUnitTest.java | 2 +-
.../execute/FunctionServiceStatsDUnitTest.java | 2 +-
.../cache/execute/LocalDataSetDUnitTest.java | 2 +-
.../execute/LocalDataSetIndexingDUnitTest.java | 2 +-
.../execute/LocalFunctionExecutionDUnitTest.java | 2 +-
.../execute/MemberFunctionExecutionDUnitTest.java | 2 +-
.../MultiRegionFunctionExecutionDUnitTest.java | 2 +-
.../cache/execute/MyTransactionFunction.java | 2 +-
.../OnGroupsFunctionExecutionDUnitTest.java | 2 +-
...lientServerFunctionExecutionNoAckDUnitTest.java | 2 +-
...ientServerRegionFunctionExecutionDUnitTest.java | 2 +-
...erRegionFunctionExecutionFailoverDUnitTest.java | 2 +-
...egionFunctionExecutionNoSingleHopDUnitTest.java | 2 +-
...ctionExecutionSelectorNoSingleHopDUnitTest.java | 2 +-
...rRegionFunctionExecutionSingleHopDUnitTest.java | 2 +-
.../cache/execute/PRClientServerTestBase.java | 2 +-
.../cache/execute/PRColocationDUnitTest.java | 2 +-
.../execute/PRFunctionExecutionDUnitTest.java | 2 +-
...FunctionExecutionWithResultSenderDUnitTest.java | 2 +-
.../cache/execute/PRPerformanceTestDUnitTest.java | 2 +-
.../cache/execute/PRTransactionDUnitTest.java | 2 +-
.../partitioned/PartitionResolverDUnitTest.java | 2 +-
.../PersistentPartitionedRegionDUnitTest.java | 2 +-
.../rollingupgrade/RollingUpgrade2DUnitTest.java | 2 +-
.../sockets/command/ExecuteFunction65Test.java | 2 +-
.../sockets/command/ExecuteFunction66Test.java | 2 +-
.../tier/sockets/command/ExecuteFunctionTest.java | 2 +-
...DeployCommandFunctionRegistrationDUnitTest.java | 2 +-
.../commands/DeployCommandRedeployDUnitTest.java | 2 +-
.../ExecuteFunctionCommandSecurityTest.java | 2 +-
.../cli/commands/FunctionCommandsDUnitTest.java | 2 +-
.../cli/commands/ShowDeadlockDUnitTest.java | 2 +-
.../internal/pulse/TestFunctionsDUnitTest.java | 2 +-
.../apache/geode/security/SecurityTestUtils.java | 2 +-
.../geode/security/MultiUserAPIDUnitTest.java | 2 +-
.../internal/LuceneIndexForPartitionedRegion.java | 2 +-
.../cache/lucene/internal/LuceneQueryImpl.java | 2 +-
.../cache/lucene/internal/LuceneServiceImpl.java | 2 +-
.../internal/PageableLuceneQueryResultsImpl.java | 2 +-
.../LuceneIndexForPartitionedRegionTest.java | 2 +-
.../internal/LuceneServiceImplIntegrationTest.java | 2 +-
.../lucene/test/LuceneFunctionSecurityTest.java | 2 +-
.../gemfire/cache/execute/FunctionException.java | 2 +-
.../AbstractFunctionRequestOperationHandler.java | 2 +-
...cuteFunctionOnGroupRequestOperationHandler.java | 2 +-
...uteFunctionOnMemberRequestOperationHandler.java | 2 +-
...uteFunctionOnRegionRequestOperationHandler.java | 2 +-
.../v1/ExecuteFunctionOnGroupIntegrationTest.java | 2 +-
.../v1/ExecuteFunctionOnMemberIntegrationTest.java | 2 +-
.../v1/ExecuteFunctionOnRegionIntegrationTest.java | 2 +-
...ionOnGroupRequestOperationHandlerJUnitTest.java | 2 +-
...onOnMemberRequestOperationHandlerJUnitTest.java | 2 +-
...onOnRegionRequestOperationHandlerJUnitTest.java | 2 +-
.../web/controllers/CommonCrudController.java | 2 +-
.../web/controllers/FunctionAccessController.java | 2 +-
...xecuteFunctionCommandWithSecurityDUnitTest.java | 2 +-
gradle/wrapper/gradle-wrapper.properties | 4 +-
161 files changed, 760 insertions(+), 1195 deletions(-)
delete mode 100644
geode-core/src/main/java/org/apache/geode/cache/client/function/FunctionService.java
create mode 100644
geode-core/src/main/java/org/apache/geode/cache/client/function/FunctionService.kt
delete mode 100644
geode-core/src/main/java/org/apache/geode/cache/client/internal/function/FunctionServiceImpl.java
create mode 100644
geode-core/src/main/java/org/apache/geode/cache/client/internal/function/FunctionServiceImpl.kt
delete mode 100755
geode-core/src/main/java/org/apache/geode/cache/execute/FunctionService.java
delete mode 100644
geode-core/src/main/java/org/apache/geode/cache/function/FunctionService.java
create mode 100644
geode-core/src/main/java/org/apache/geode/cache/function/FunctionService.kt
create mode 100644
geode-core/src/main/java/org/apache/geode/cache/function/internal/FunctionServiceImpl.kt
--
To stop receiving notification emails like this one, please contact
u...@apache.org.
