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 2019/12/02 17:52:11 UTC
[geode] branch feature/GEODE-7507 updated (59e4e952 -> ade1eea)
This is an automated email from the ASF dual-hosted git repository.
bschuchardt pushed a change to branch feature/GEODE-7507
in repository https://gitbox.apache.org/repos/asf/geode.git.
from 59e4e952 making pmdMain happy
add ade1eea revert renaming message class/interface
No new revisions were added by this update.
Summary of changes:
.../geode/ClusterCommunicationsDUnitTest.java | 4 +-
.../geode/cache30/ClientServerCCEDUnitTest.java | 26 +++++------
.../DistributedLockServiceDUnitTest.java | 12 ++---
.../distributed/internal/ProduceDateMessages.java | 4 +-
.../streaming/StreamingOperationManyDUnitTest.java | 4 +-
.../streaming/StreamingOperationOneDUnitTest.java | 4 +-
.../cache/BucketCreationCrashRegressionTest.java | 20 ++++----
.../cache/BucketCreationGIIHARegressionTest.java | 14 +++---
...ntServerTransactionFailoverDistributedTest.java | 28 +++++------
...iskRecoveryWithVersioningGiiRegressionTest.java | 4 +-
.../geode/internal/cache/GIIDeltaDUnitTest.java | 24 +++++-----
.../internal/cache/GIIFlowControlDUnitTest.java | 14 +++---
.../cache/InterruptClientServerDUnitTest.java | 10 ++--
.../geode/internal/cache/InterruptsDUnitTest.java | 10 ++--
.../cache/NetSearchMessagingDUnitTest.java | 14 +++---
.../cache/OnRequestImageMessageObserver.java | 8 ++--
...RQueryWithPdxDuringRebalanceRegressionTest.java | 8 ++--
.../cache/PersistentRegionRecoveryDUnitTest.java | 16 +++----
.../cache/backup/BackupDistributedTest.java | 54 +++++++++++-----------
.../control/RebalanceOperationDistributedTest.java | 10 ++--
.../cache/locks/TXLockServiceDUnitTest.java | 14 +++---
...BucketCreationCrashCompletesRegressionTest.java | 10 ++--
...tColocatedPartitionedRegionDistributedTest.java | 12 ++---
...tPartitionHangsDuringRestartRegressionTest.java | 14 +++---
...PersistentPartitionedRegionDistributedTest.java | 16 +++----
.../PersistentPartitionedRegionRegressionTest.java | 20 ++++----
.../StreamingPartitionOperationManyDUnitTest.java | 4 +-
.../StreamingPartitionOperationOneDUnitTest.java | 4 +-
...ntPartitionedRegionWithRedundancyDUnitTest.java | 4 +-
.../PersistentRVVRecoveryDUnitTest.java | 10 ++--
.../PersistentRecoveryOrderDUnitTest.java | 44 +++++++++---------
.../cache/versions/TombstoneDUnitTest.java | 12 ++---
.../pdx/ClientsWithVersioningRetryDUnitTest.java | 36 +++++++--------
.../apache/geode/pdx/PdxSerializableDUnitTest.java | 8 ++--
.../membership/gms/GMSMembershipJUnitTest.java | 4 +-
.../gms/messenger/JGroupsMessengerJUnitTest.java | 16 +++----
...ccessExceptionDisablesServerRegressionTest.java | 4 +-
.../admin/internal/AbstractHealthEvaluator.java | 2 +-
.../internal/ClusterDistributionManager.java | 32 ++++++-------
.../internal/ClusterOperationExecutors.java | 2 +-
.../internal/CollectingReplyProcessor.java | 2 +-
.../geode/distributed/internal/Distribution.java | 6 +--
.../distributed/internal/DistributionImpl.java | 10 ++--
.../distributed/internal/DistributionManager.java | 2 +-
...lusterMessage.java => DistributionMessage.java} | 26 +++++------
...erver.java => DistributionMessageObserver.java} | 22 ++++-----
.../internal/HighPriorityDistributionMessage.java | 2 +-
.../distributed/internal/IgnoredByManager.java | 2 +-
.../internal/LonerDistributionManager.java | 2 +-
.../distributed/internal/MessageWithReply.java | 2 +-
.../distributed/internal/OperationExecutors.java | 2 +-
.../internal/PooledDistributionMessage.java | 2 +-
.../geode/distributed/internal/ReplyException.java | 2 +-
.../distributed/internal/ReplyProcessor21.java | 12 ++---
.../geode/distributed/internal/ReplySender.java | 4 +-
.../internal/SerialDistributionMessage.java | 2 +-
.../distributed/internal/ShutdownMessage.java | 2 +-
.../geode/distributed/internal/StartupMessage.java | 2 +-
.../internal/StartupMessageReplyProcessor.java | 2 +-
.../internal/StartupResponseMessage.java | 2 +-
.../ThrottlingMemLinkedQueueWithDMStats.java | 2 +-
.../internal/WaitForViewInstallation.java | 2 +-
.../deadlock/MessageDependencyMonitor.java | 6 +--
.../distributed/internal/direct/DirectChannel.java | 12 ++---
.../internal/distribution-overview.html | 2 +-
.../internal/locks/DLockQueryProcessor.java | 4 +-
.../locks/DLockRecoverGrantorProcessor.java | 4 +-
.../internal/locks/DLockReleaseProcessor.java | 4 +-
.../internal/locks/DLockRequestProcessor.java | 4 +-
.../internal/locks/ElderInitProcessor.java | 4 +-
.../internal/locks/GrantorRequestProcessor.java | 4 +-
.../locks/NonGrantorDestroyedProcessor.java | 4 +-
.../internal/membership/gms/GMSMembership.java | 18 ++++----
.../{DistributionMessage.java => GMSMessage.java} | 6 +--
.../internal/membership/gms/api/Membership.java | 6 +--
.../membership/gms/api/MessageListener.java | 2 +-
.../membership/gms/interfaces/Manager.java | 4 +-
.../membership/gms/interfaces/Messenger.java | 8 ++--
.../gms/messages/AbstractGMSMessage.java | 4 +-
.../membership/gms/messenger/JGroupsMessenger.java | 46 +++++++++---------
.../apache/geode/distributed/internal/package.html | 2 +-
.../internal/streaming/StreamingOperation.java | 8 ++--
.../internal/admin/ClientMembershipMessage.java | 4 +-
.../admin/remote/AdminMultipleReplyProcessor.java | 4 +-
.../internal/admin/remote/AdminReplyProcessor.java | 4 +-
.../internal/admin/remote/CompactRequest.java | 4 +-
.../admin/remote/MissingPersistentIDsRequest.java | 4 +-
.../internal/admin/remote/RemoteGemFireVM.java | 4 +-
.../admin/remote/RemoteGfManagerAgent.java | 4 +-
.../remote/ShutdownAllGatewayHubsRequest.java | 4 +-
.../internal/admin/remote/ShutdownAllRequest.java | 4 +-
.../internal/cache/CreateRegionProcessor.java | 4 +-
.../geode/internal/cache/DirectReplyMessage.java | 4 +-
.../geode/internal/cache/DistTXCommitMessage.java | 6 +--
.../internal/cache/DistTXPrecommitMessage.java | 6 +--
.../internal/cache/DistTXRollbackMessage.java | 8 ++--
.../internal/cache/DistributedCacheOperation.java | 12 ++---
.../DistributedRegionFunctionStreamingMessage.java | 4 +-
.../geode/internal/cache/EntryEventImpl.java | 8 ++--
.../apache/geode/internal/cache/FilterProfile.java | 2 +-
.../internal/cache/FindDurableQueueProcessor.java | 4 +-
.../geode/internal/cache/FindRemoteTXMessage.java | 4 +-
.../internal/cache/FindVersionTagOperation.java | 4 +-
.../internal/cache/InitialImageFlowControl.java | 4 +-
.../internal/cache/InitialImageOperation.java | 16 +++----
.../cache/LatestLastAccessTimeReplyProcessor.java | 4 +-
.../cache/MemberFunctionStreamingMessage.java | 4 +-
.../cache/PartitionedRegionQueryEvaluator.java | 8 ++--
.../cache/SearchLoadAndWriteProcessor.java | 4 +-
.../geode/internal/cache/StateFlushOperation.java | 4 +-
.../geode/internal/cache/TXCommitMessage.java | 6 +--
.../internal/cache/TXRemoteCommitMessage.java | 4 +-
.../geode/internal/cache/TransactionMessage.java | 4 +-
.../internal/cache/UpdateAttributesProcessor.java | 4 +-
.../internal/cache/backup/AbortBackupStep.java | 4 +-
.../cache/backup/BackupReplyProcessor.java | 4 +-
.../geode/internal/cache/backup/BackupStep.java | 4 +-
.../internal/cache/backup/FinishBackupStep.java | 4 +-
.../cache/backup/FlushToDiskProcessor.java | 4 +-
.../internal/cache/backup/FlushToDiskStep.java | 4 +-
.../internal/cache/backup/PrepareBackupStep.java | 4 +-
.../DistributedRegionFunctionResultWaiter.java | 4 +-
.../execute/FunctionStreamingResultCollector.java | 4 +-
.../cache/execute/MemberFunctionResultWaiter.java | 4 +-
.../execute/MultiRegionFunctionResultWaiter.java | 4 +-
.../PartitionedRegionFunctionResultWaiter.java | 4 +-
.../cache/execute/StreamingFunctionOperation.java | 6 +--
.../AllBucketProfilesUpdateMessage.java | 4 +-
.../partitioned/BecomePrimaryBucketMessage.java | 4 +-
.../partitioned/BucketProfileUpdateMessage.java | 4 +-
.../cache/partitioned/BucketSizeMessage.java | 4 +-
.../cache/partitioned/ContainsKeyValueMessage.java | 4 +-
.../cache/partitioned/CreateBucketMessage.java | 4 +-
.../partitioned/DeposePrimaryBucketMessage.java | 4 +-
.../internal/cache/partitioned/DumpB2NRegion.java | 4 +-
.../cache/partitioned/FetchEntriesMessage.java | 4 +-
.../cache/partitioned/FetchEntryMessage.java | 4 +-
.../partitioned/FetchPartitionDetailsMessage.java | 4 +-
.../internal/cache/partitioned/GetMessage.java | 4 +-
.../cache/partitioned/IdentityRequestMessage.java | 6 +--
.../cache/partitioned/IdentityUpdateMessage.java | 4 +-
.../partitioned/ManageBackupBucketMessage.java | 4 +-
.../cache/partitioned/ManageBucketMessage.java | 4 +-
.../cache/partitioned/MoveBucketMessage.java | 4 +-
.../PRFunctionStreamingResultCollector.java | 4 +-
.../cache/partitioned/PRTombstoneMessage.java | 4 +-
.../cache/partitioned/PartitionMessage.java | 8 ++--
.../PartitionMessageWithDirectReply.java | 4 +-
.../cache/partitioned/PrimaryRequestMessage.java | 4 +-
.../internal/cache/partitioned/PutMessage.java | 4 +-
.../cache/partitioned/RemoveBucketMessage.java | 4 +-
.../internal/cache/partitioned/SizeMessage.java | 4 +-
.../partitioned/StreamingPartitionOperation.java | 10 ++--
.../cache/persistence/MembershipViewRequest.java | 6 +--
.../persistence/PersistentStateQueryMessage.java | 4 +-
.../internal/cache/snapshot/FlowController.java | 6 +--
.../tier/sockets/ClientDenylistProcessor.java | 4 +-
.../cache/tx/RemoteContainsKeyValueMessage.java | 4 +-
.../internal/cache/tx/RemoteFetchEntryMessage.java | 4 +-
.../internal/cache/tx/RemoteFetchKeysMessage.java | 4 +-
.../cache/tx/RemoteFetchVersionMessage.java | 4 +-
.../geode/internal/cache/tx/RemoteGetMessage.java | 4 +-
.../internal/cache/tx/RemoteOperationMessage.java | 6 +--
.../tx/RemoteOperationMessageWithDirectReply.java | 4 +-
.../geode/internal/cache/tx/RemoteSizeMessage.java | 4 +-
...aySenderQueueEntrySynchronizationOperation.java | 4 +-
...tilParallelGatewaySenderFlushedCoordinator.java | 4 +-
.../geode/internal/sequencelog/MessageLogger.java | 4 +-
.../org/apache/geode/internal/tcp/Connection.java | 22 ++++-----
.../geode/internal/tcp/DirectReplySender.java | 4 +-
.../apache/geode/internal/tcp/MsgDestreamer.java | 10 ++--
.../org/apache/geode/internal/tcp/MsgReader.java | 6 +--
.../org/apache/geode/internal/tcp/MsgStreamer.java | 10 ++--
.../apache/geode/internal/tcp/ServerDelegate.java | 6 +--
.../org/apache/geode/internal/tcp/TCPConduit.java | 10 ++--
.../geode/internal/tcp/VersionedMsgStreamer.java | 4 +-
.../org/apache/geode/internal/tcp/package.html | 2 +-
.../geode/management/internal/MemberMessenger.java | 4 +-
.../internal/messages/CompactRequest.java | 4 +-
.../internal/DistributionMessageTest.java | 2 +-
.../distributed/internal/DistributionTest.java | 14 +++---
.../internal/StartupMessageJUnitTest.java | 12 ++---
.../gms/api/MembershipAPIArchUnitTest.java | 4 +-
.../cache/PartitionedRegionQueryEvaluatorTest.java | 4 +-
.../cache/backup/BackupReplyProcessorTest.java | 6 +--
.../apache/geode/internal/tcp/ConnectionTest.java | 4 +-
.../dunit/cache/internal/JUnit4CacheTestCase.java | 4 +-
.../dunit/internal/JUnit4DistributedTestCase.java | 4 +-
.../geode/test/dunit/rules/DistributedRule.java | 6 +--
.../cache/wan/misc/PDXNewWanDUnitTest.java | 14 +++---
190 files changed, 688 insertions(+), 688 deletions(-)
rename geode-core/src/main/java/org/apache/geode/distributed/internal/{ClusterMessage.java => DistributionMessage.java} (96%)
rename geode-core/src/main/java/org/apache/geode/distributed/internal/{ClusterMessageObserver.java => DistributionMessageObserver.java} (72%)
rename geode-core/src/main/java/org/apache/geode/distributed/internal/membership/gms/api/{DistributionMessage.java => GMSMessage.java} (94%)