This is an automated email from the ASF dual-hosted git repository.
bschuchardt pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/geode.git.
from a951681 add www.apache.org to brew mirrors because it updates much
faster
add 24faeea GEODE-7196 Simplify ClusterDistributionManage
No new revisions were added by this update.
Summary of changes:
.../geode/ClusterCommunicationsDUnitTest.java | 3 +-
.../distributed/DistributedSystemDUnitTest.java | 23 +-
.../cache/BucketCreationCrashRegressionTest.java | 2 +
.../NestedFunctionExecutionDistributedTest.java | 2 +-
...PersistentPartitionedRegionDistributedTest.java | 2 +-
...niversalMembershipListenerAdapterDUnitTest.java | 2 +-
.../adapter/GMSMembershipManagerJUnitTest.java | 2 +-
.../geode/admin/internal/CacheServerImpl.java | 3 +-
.../internal/ClusterDistributionManager.java | 1243 ++------------------
.../internal/ClusterOperationExecutors.java | 920 +++++++++++++++
.../distributed/internal/DistributionManager.java | 35 +-
.../distributed/internal/DistributionMessage.java | 8 +-
.../internal/FunctionExecutionPooledExecutor.java | 31 +-
.../internal/HighPriorityAckedMessage.java | 3 +-
.../internal/HighPriorityDistributionMessage.java | 2 +-
.../distributed/internal/InternalLocator.java | 2 +-
.../internal/LonerDistributionManager.java | 42 +-
.../internal/LonerOperationExecutors.java | 64 +
.../distributed/internal/OperationExecutors.java | 72 ++
.../internal/PooledDistributionMessage.java | 2 +-
.../distributed/internal/ReplyProcessor21.java | 1 -
.../distributed/internal/SerialAckedMessage.java | 4 +-
.../internal/SerialDistributionMessage.java | 2 +-
.../geode/distributed/internal/StartupMessage.java | 2 +-
.../internal/StartupResponseMessage.java | 2 +-
.../internal/WaitForViewInstallation.java | 2 +-
.../distributed/internal/locks/DLockGrantor.java | 2 +-
.../internal/locks/DLockQueryProcessor.java | 2 +-
.../internal/locks/DLockReleaseProcessor.java | 2 +-
.../internal/locks/DLockRequestProcessor.java | 2 +-
.../distributed/internal/locks/DLockService.java | 4 +-
.../internal/membership/MembershipManager.java | 13 +-
.../internal/membership/MembershipView.java | 19 +-
.../membership/adapter/GMSMembershipManager.java | 80 +-
.../membership/adapter/GMSMessageAdapter.java | 4 +-
.../membership/adapter/LocalViewMessage.java | 3 +-
.../internal/membership/gms/GMSMember.java | 16 +-
.../internal/membership/gms/api/Membership.java | 1 +
.../admin/remote/RemoteGfManagerAgent.java | 2 +-
.../remote/ShutdownAllGatewayHubsRequest.java | 3 +-
.../geode/internal/cache/AbstractRegionMap.java | 2 +-
.../apache/geode/internal/cache/BucketAdvisor.java | 4 +-
.../internal/cache/DestroyRegionOperation.java | 61 +-
.../internal/cache/DistributedClearOperation.java | 3 +-
.../geode/internal/cache/DistributedRegion.java | 2 +-
.../DistributedRegionFunctionStreamingMessage.java | 3 +-
.../cache/DistributedTombstoneOperation.java | 3 +-
.../FunctionStreamingOrderedReplyMessage.java | 4 +-
.../internal/cache/InitialImageFlowControl.java | 3 +-
.../internal/cache/InitialImageOperation.java | 19 +-
.../internal/cache/JtaAfterCompletionMessage.java | 5 +-
.../cache/MemberFunctionStreamingMessage.java | 3 +-
.../geode/internal/cache/PartitionedRegion.java | 6 +-
.../cache/PartitionedRegionBucketMgmtHelper.java | 3 +-
.../internal/cache/PartitionedRegionDataStore.java | 4 +-
.../internal/cache/PartitionedRegionHelper.java | 19 +-
.../cache/SearchLoadAndWriteProcessor.java | 2 +-
.../geode/internal/cache/StateFlushOperation.java | 2 +-
.../internal/cache/TXRemoteCommitMessage.java | 3 +-
.../org/apache/geode/internal/cache/TXState.java | 2 +-
.../geode/internal/cache/TombstoneService.java | 2 +-
.../geode/internal/cache/UpdateOperation.java | 2 +-
.../internal/cache/execute/AbstractExecution.java | 4 +-
.../cache/execute/MemberFunctionExecutor.java | 5 +-
.../cache/locks/TXLessorDepartureHandler.java | 2 +-
.../cache/locks/TXOriginatorRecoveryProcessor.java | 2 +-
.../locks/TXRecoverGrantorMessageProcessor.java | 2 +-
.../AllBucketProfilesUpdateMessage.java | 3 +-
.../partitioned/BecomePrimaryBucketMessage.java | 3 +-
.../cache/partitioned/BucketBackupMessage.java | 3 +-
.../partitioned/BucketProfileUpdateMessage.java | 3 +-
.../cache/partitioned/BucketSizeMessage.java | 3 +-
.../cache/partitioned/CreateBucketMessage.java | 3 +-
.../DestroyRegionOnDataStoreMessage.java | 3 +-
.../partitioned/EndBucketCreationMessage.java | 3 +-
.../internal/cache/partitioned/GetMessage.java | 9 +-
.../cache/partitioned/IdentityRequestMessage.java | 3 +-
.../cache/partitioned/IdentityUpdateMessage.java | 3 +-
.../cache/partitioned/InterestEventMessage.java | 3 +-
.../partitioned/ManageBackupBucketMessage.java | 3 +-
.../cache/partitioned/ManageBucketMessage.java | 3 +-
.../cache/partitioned/PRSanityCheckMessage.java | 3 +-
.../cache/partitioned/PartitionMessage.java | 5 +-
.../PartitionedRegionFunctionStreamingMessage.java | 3 +-
.../partitioned/PartitionedRegionRebalanceOp.java | 2 +-
.../cache/partitioned/PrimaryRequestMessage.java | 3 +-
.../internal/cache/partitioned/PutMessage.java | 2 +-
.../cache/persistence/MembershipViewRequest.java | 5 +-
.../internal/cache/snapshot/FlowController.java | 5 +-
.../cache/snapshot/RegionSnapshotServiceImpl.java | 6 +-
.../cache/tier/sockets/CacheClientNotifier.java | 2 +-
.../cache/tier/sockets/CacheClientProxy.java | 4 +-
.../tier/sockets/command/ExecuteFunction66.java | 2 +-
.../internal/cache/tx/RemoteOperationMessage.java | 3 +-
.../cache/versions/RegionVersionVector.java | 4 +-
...tilParallelGatewaySenderFlushedCoordinator.java | 3 +-
.../org/apache/geode/internal/tcp/Connection.java | 5 +-
.../geode/pdx/internal/PeerTypeRegistration.java | 3 +
.../internal/StartupMessageJUnitTest.java | 4 +-
.../sockets/command/ExecuteFunction66Test.java | 5 +-
.../java/org/apache/geode/test/fake/Fakes.java | 2 +
.../lucene/internal/LuceneBucketListener.java | 4 +-
.../internal/LuceneIndexForPartitionedRegion.java | 3 +-
.../cache/lucene/internal/LuceneRawIndex.java | 2 +-
.../internal/LuceneServiceImplJUnitTest.java | 9 +-
105 files changed, 1479 insertions(+), 1459 deletions(-)
create mode 100644
geode-core/src/main/java/org/apache/geode/distributed/internal/ClusterOperationExecutors.java
create mode 100644
geode-core/src/main/java/org/apache/geode/distributed/internal/LonerOperationExecutors.java
create mode 100644
geode-core/src/main/java/org/apache/geode/distributed/internal/OperationExecutors.java
