You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by kl...@apache.org on 2017/05/15 22:09:12 UTC
[5/5] geode git commit: GEODE-2929: remove final from internal
classes and tests
GEODE-2929: remove final from internal classes and tests
Project: http://git-wip-us.apache.org/repos/asf/geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/geode/commit/3b867342
Tree: http://git-wip-us.apache.org/repos/asf/geode/tree/3b867342
Diff: http://git-wip-us.apache.org/repos/asf/geode/diff/3b867342
Branch: refs/heads/feature/GEODE-2929
Commit: 3b8673421809bc94597e0eb9168ddcf9c9b177b3
Parents: 6140317
Author: Kirk Lund <kl...@apache.org>
Authored: Mon May 15 14:56:59 2017 -0700
Committer: Kirk Lund <kl...@apache.org>
Committed: Mon May 15 15:08:56 2017 -0700
----------------------------------------------------------------------
.../SystemMemberCacheEventProcessor.java | 2 +-
.../client/internal/ClientMetadataService.java | 2 +-
.../operations/internal/UpdateOnlyMap.java | 5 ++-
.../cache/query/internal/ObjectIntHashMap.java | 10 ++---
.../query/internal/QueryObserverHolder.java | 2 +-
.../internal/ResultsCollectionWrapper.java | 2 +-
.../geode/cache/query/internal/ResultsSet.java | 2 +-
.../cache/query/internal/SortedResultSet.java | 2 +-
.../cache/query/internal/SortedStructSet.java | 2 +-
.../geode/cache/query/internal/StructBag.java | 2 +-
.../geode/cache/query/internal/StructSet.java | 2 +-
.../geode/cache/query/internal/Undefined.java | 2 +-
.../query/internal/index/HashIndexSet.java | 2 +-
.../cache/query/internal/types/MapTypeImpl.java | 2 +-
.../query/internal/types/StructTypeImpl.java | 2 +-
.../internal/DistributionConfigSnapshot.java | 2 +-
.../internal/DistributionManager.java | 18 ++++----
.../internal/HighPriorityAckedMessage.java | 2 +-
.../internal/LocatorLoadSnapshot.java | 4 +-
.../distributed/internal/ProductUseLog.java | 2 +-
.../internal/RuntimeDistributionConfigImpl.java | 2 +-
.../internal/SerialAckedMessage.java | 3 +-
.../distributed/internal/ShutdownMessage.java | 2 +-
.../distributed/internal/StartupMessage.java | 3 +-
.../internal/locks/DLockQueryProcessor.java | 4 +-
.../locks/DLockRecoverGrantorProcessor.java | 4 +-
.../internal/locks/DLockReleaseProcessor.java | 4 +-
.../internal/locks/DLockService.java | 2 +-
.../internal/locks/DeposeGrantorProcessor.java | 2 +-
.../internal/locks/DistributedMemberLock.java | 2 +-
.../internal/locks/ElderInitProcessor.java | 4 +-
.../internal/locks/GrantorRequestProcessor.java | 4 +-
.../locks/NonGrantorDestroyedProcessor.java | 4 +-
.../membership/gms/mgr/LocalViewMessage.java | 2 +-
.../internal/streaming/StreamingOperation.java | 2 +-
.../geode/internal/HeapDataOutputStream.java | 2 +-
.../geode/internal/InternalDataSerializer.java | 2 +-
.../geode/internal/InternalInstantiator.java | 2 +-
.../geode/internal/NullDataOutputStream.java | 2 +-
.../geode/internal/ObjIdConcurrentMap.java | 35 ++++++++--------
.../org/apache/geode/internal/PureJavaMode.java | 2 +-
.../org/apache/geode/internal/SetUtils.java | 2 +-
.../org/apache/geode/internal/SystemAdmin.java | 2 +-
.../java/org/apache/geode/internal/Version.java | 2 +-
.../internal/VersionedDataInputStream.java | 2 +-
.../internal/VersionedDataOutputStream.java | 3 +-
.../geode/internal/VersionedObjectInput.java | 2 +-
.../geode/internal/VersionedObjectOutput.java | 2 +-
.../admin/remote/AddHealthListenerRequest.java | 2 +-
.../admin/remote/AddHealthListenerResponse.java | 2 +-
.../admin/remote/AddStatListenerRequest.java | 2 +-
.../admin/remote/AddStatListenerResponse.java | 2 +-
.../remote/AdminConsoleDisconnectMessage.java | 2 +-
.../admin/remote/AdminConsoleMessage.java | 2 +-
.../admin/remote/AdminFailureResponse.java | 2 +-
.../admin/remote/AlertLevelChangeMessage.java | 2 +-
.../admin/remote/AlertListenerMessage.java | 3 +-
.../admin/remote/AppCacheSnapshotMessage.java | 2 +-
.../admin/remote/BridgeServerRequest.java | 2 +-
.../admin/remote/BridgeServerResponse.java | 2 +-
.../admin/remote/CacheConfigRequest.java | 2 +-
.../admin/remote/CacheConfigResponse.java | 2 +-
.../internal/admin/remote/CacheDisplay.java | 2 +-
.../internal/admin/remote/CacheInfoRequest.java | 2 +-
.../admin/remote/CacheInfoResponse.java | 2 +-
.../admin/remote/CancelStatListenerRequest.java | 2 +-
.../remote/CancelStatListenerResponse.java | 2 +-
.../admin/remote/CancellationMessage.java | 2 +-
.../admin/remote/DestroyEntryMessage.java | 2 +-
.../admin/remote/DestroyRegionMessage.java | 2 +-
.../admin/remote/FetchDistLockInfoRequest.java | 2 +-
.../admin/remote/FetchDistLockInfoResponse.java | 2 +-
.../remote/FetchHealthDiagnosisRequest.java | 2 +-
.../remote/FetchHealthDiagnosisResponse.java | 2 +-
.../internal/admin/remote/FetchHostRequest.java | 2 +-
.../admin/remote/FetchHostResponse.java | 2 +-
.../remote/FetchResourceAttributesRequest.java | 2 +-
.../remote/FetchResourceAttributesResponse.java | 2 +-
.../admin/remote/FetchStatsRequest.java | 2 +-
.../admin/remote/FetchStatsResponse.java | 2 +-
.../admin/remote/FetchSysCfgRequest.java | 2 +-
.../admin/remote/FetchSysCfgResponse.java | 2 +-
.../remote/FlushAppCacheSnapshotMessage.java | 2 +-
.../admin/remote/HealthListenerMessage.java | 3 +-
.../admin/remote/LicenseInfoRequest.java | 2 +-
.../admin/remote/LicenseInfoResponse.java | 2 +-
.../admin/remote/ObjectDetailsRequest.java | 2 +-
.../admin/remote/ObjectDetailsResponse.java | 2 +-
.../admin/remote/ObjectNamesRequest.java | 2 +-
.../admin/remote/ObjectNamesResponse.java | 2 +-
.../admin/remote/RegionAttributesRequest.java | 2 +-
.../admin/remote/RegionAttributesResponse.java | 2 +-
.../internal/admin/remote/RegionRequest.java | 2 +-
.../internal/admin/remote/RegionResponse.java | 2 +-
.../admin/remote/RegionSizeRequest.java | 2 +-
.../admin/remote/RegionSizeResponse.java | 2 +-
.../admin/remote/RegionStatisticsRequest.java | 2 +-
.../admin/remote/RegionStatisticsResponse.java | 2 +-
.../admin/remote/RemoteApplicationVM.java | 2 +-
.../admin/remote/RemoteGfManagerAgent.java | 2 +-
.../remote/RemoveHealthListenerRequest.java | 2 +-
.../remote/RemoveHealthListenerResponse.java | 2 +-
.../admin/remote/ResetHealthStatusRequest.java | 2 +-
.../admin/remote/ResetHealthStatusResponse.java | 2 +-
.../admin/remote/RootRegionRequest.java | 2 +-
.../admin/remote/RootRegionResponse.java | 2 +-
.../admin/remote/SnapshotResultMessage.java | 3 +-
.../admin/remote/StatListenerMessage.java | 3 +-
.../admin/remote/StoreSysCfgRequest.java | 2 +-
.../admin/remote/StoreSysCfgResponse.java | 2 +-
.../internal/admin/remote/SubRegionRequest.java | 2 +-
.../admin/remote/SubRegionResponse.java | 2 +-
.../internal/admin/remote/TailLogRequest.java | 2 +-
.../internal/admin/remote/TailLogResponse.java | 2 +-
.../admin/remote/VersionInfoRequest.java | 2 +-
.../admin/remote/VersionInfoResponse.java | 2 +-
.../admin/statalerts/FunctionDecoratorImpl.java | 2 +-
.../statalerts/GaugeThresholdDecoratorImpl.java | 2 +-
.../statalerts/MultiAttrDefinitionImpl.java | 2 +-
.../NumberThresholdDecoratorImpl.java | 2 +-
.../statalerts/SingleAttrDefinitionImpl.java | 2 +-
.../geode/internal/cache/BucketAdvisor.java | 2 +-
.../geode/internal/cache/BucketRegion.java | 2 +-
.../internal/cache/ClientRegionEventImpl.java | 2 +-
.../geode/internal/cache/CloseCacheMessage.java | 3 +-
.../internal/cache/CreateRegionProcessor.java | 4 +-
.../geode/internal/cache/DestroyOperation.java | 2 +-
.../cache/DestroyPartitionedRegionMessage.java | 2 +-
.../internal/cache/DestroyRegionOperation.java | 2 +-
.../internal/cache/DiskWriteAttributesImpl.java | 2 +-
.../internal/cache/DistPeerTXStateStub.java | 3 +-
.../internal/cache/DistTXCommitMessage.java | 4 +-
.../internal/cache/DistTXPrecommitMessage.java | 8 ++--
.../internal/cache/DistTXRollbackMessage.java | 6 +--
.../cache/DistTXStateOnCoordinator.java | 3 +-
.../cache/DistributedClearOperation.java | 2 +-
.../cache/DistributedPutAllOperation.java | 4 +-
.../geode/internal/cache/DistributedRegion.java | 2 +-
.../cache/DistributedRemoveAllOperation.java | 2 +-
.../geode/internal/cache/EntryEventImpl.java | 2 +-
.../internal/cache/EvictionAttributesImpl.java | 2 +-
.../geode/internal/cache/GridAdvisor.java | 2 +-
.../apache/geode/internal/cache/HARegion.java | 2 +-
.../internal/cache/InitialImageOperation.java | 14 +++----
.../internal/cache/InternalRegionArguments.java | 2 +-
.../internal/cache/InvalidateOperation.java | 2 +-
.../cache/InvalidateRegionOperation.java | 2 +-
.../org/apache/geode/internal/cache/Node.java | 2 +-
.../org/apache/geode/internal/cache/OpType.java | 2 +-
.../geode/internal/cache/PRQueryProcessor.java | 6 +--
.../cache/PreferBytesCachedDeserializable.java | 2 +-
.../geode/internal/cache/ProxyBucketRegion.java | 2 +-
.../cache/RemoteContainsKeyValueMessage.java | 4 +-
.../internal/cache/RemoteFetchEntryMessage.java | 4 +-
.../cache/RemoteFetchVersionMessage.java | 4 +-
.../geode/internal/cache/RemoteGetMessage.java | 4 +-
.../internal/cache/RemoteInvalidateMessage.java | 4 +-
.../internal/cache/RemotePutAllMessage.java | 4 +-
.../geode/internal/cache/RemotePutMessage.java | 4 +-
.../internal/cache/RemoteRegionOperation.java | 4 +-
.../internal/cache/RemoteRemoveAllMessage.java | 4 +-
.../geode/internal/cache/RoleEventImpl.java | 2 +-
.../cache/SearchLoadAndWriteProcessor.java | 16 +++----
.../internal/cache/StateFlushOperation.java | 7 ++--
.../geode/internal/cache/TXEntryState.java | 2 +-
.../org/apache/geode/internal/cache/TXId.java | 2 +-
.../internal/cache/TXRemoteCommitMessage.java | 2 +-
.../org/apache/geode/internal/cache/Token.java | 2 +-
.../internal/cache/UnsharedImageState.java | 2 +-
.../cache/UpdateAttributesProcessor.java | 2 +-
.../geode/internal/cache/UpdateOperation.java | 2 +-
.../internal/cache/VMCachedDeserializable.java | 2 +-
.../geode/internal/cache/VMLRURegionMap.java | 2 +-
.../geode/internal/cache/VMRegionMap.java | 2 +-
.../execute/MemberFunctionResultSender.java | 2 +-
.../geode/internal/cache/execute/NoResult.java | 2 +-
.../PartitionedRegionFunctionResultSender.java | 2 +-
.../internal/cache/ha/QueueRemovalMessage.java | 2 +-
.../geode/internal/cache/locks/TXLockBatch.java | 2 +-
.../internal/cache/locks/TXLockIdImpl.java | 2 +-
.../locks/TXLockUpdateParticipantsMessage.java | 4 +-
.../locks/TXOriginatorRecoveryProcessor.java | 4 +-
.../cache/lru/LRUCapacityController.java | 2 +-
.../cache/lru/MemLRUCapacityController.java | 2 +-
.../internal/cache/lru/NewLRUClockHand.java | 2 +-
.../AllBucketProfilesUpdateMessage.java | 2 +-
.../partitioned/BecomePrimaryBucketMessage.java | 2 +-
.../cache/partitioned/BucketBackupMessage.java | 2 +-
.../partitioned/BucketProfileUpdateMessage.java | 3 +-
.../cache/partitioned/BucketSizeMessage.java | 4 +-
.../partitioned/ContainsKeyValueMessage.java | 4 +-
.../cache/partitioned/CreateBucketMessage.java | 4 +-
.../partitioned/CreateMissingBucketsTask.java | 2 +-
.../partitioned/DeposePrimaryBucketMessage.java | 2 +-
.../DestroyRegionOnDataStoreMessage.java | 2 +-
.../partitioned/DumpAllPRConfigMessage.java | 2 +-
.../cache/partitioned/DumpB2NRegion.java | 4 +-
.../cache/partitioned/DumpBucketsMessage.java | 2 +-
.../partitioned/FetchBulkEntriesMessage.java | 4 +-
.../cache/partitioned/FetchEntriesMessage.java | 4 +-
.../cache/partitioned/FetchEntryMessage.java | 4 +-
.../cache/partitioned/FetchKeysMessage.java | 4 +-
.../FetchPartitionDetailsMessage.java | 2 +-
.../cache/partitioned/FlushMessage.java | 2 +-
.../internal/cache/partitioned/GetMessage.java | 4 +-
.../partitioned/IdentityRequestMessage.java | 4 +-
.../partitioned/IdentityUpdateMessage.java | 2 +-
.../cache/partitioned/IndexCreationMsg.java | 2 +-
.../cache/partitioned/InvalidateMessage.java | 4 +-
.../partitioned/ManageBackupBucketMessage.java | 4 +-
.../cache/partitioned/ManageBucketMessage.java | 4 +-
.../cache/partitioned/MoveBucketMessage.java | 2 +-
.../internal/cache/partitioned/PRLoad.java | 2 +-
.../cache/partitioned/PRSanityCheckMessage.java | 2 +-
.../cache/partitioned/PRTombstoneMessage.java | 2 +-
.../PRUpdateEntryVersionMessage.java | 2 +-
.../partitioned/PrimaryRequestMessage.java | 4 +-
.../internal/cache/partitioned/PutMessage.java | 4 +-
.../cache/partitioned/QueryMessage.java | 2 +-
.../cache/partitioned/RegionAdvisor.java | 2 +-
.../cache/partitioned/RemoteSizeMessage.java | 4 +-
.../cache/partitioned/RemoveAllPRMessage.java | 4 +-
.../cache/partitioned/RemoveBucketMessage.java | 2 +-
.../cache/partitioned/RemoveIndexesMessage.java | 4 +-
.../internal/cache/partitioned/SizeMessage.java | 4 +-
.../snapshot/RegionSnapshotServiceImpl.java | 4 +-
.../cache/tier/InternalClientMembership.java | 2 +-
.../tier/sockets/ClientInstantiatorMessage.java | 2 +-
.../tier/sockets/ClientMarkerMessageImpl.java | 2 +-
.../tier/sockets/ClientPingMessageImpl.java | 2 +-
.../tier/sockets/InterestResultPolicyImpl.java | 2 +-
.../cache/tier/sockets/ServerConnection.java | 2 +-
.../cache/wan/GatewaySenderAdvisor.java | 2 +-
.../wan/GatewaySenderEventCallbackArgument.java | 2 +-
.../ParallelQueueBatchRemovalMessage.java | 2 +-
.../cache/xmlcache/GeodeEntityResolver.java | 2 +-
.../cache/xmlcache/PivotalEntityResolver.java | 2 +-
.../cache/xmlcache/XmlGeneratorUtils.java | 2 +-
.../geode/internal/concurrent/AtomicLong5.java | 2 +-
.../concurrent/CompactConcurrentHashSet2.java | 16 +++----
.../geode/internal/logging/DateFormatter.java | 2 +-
.../geode/internal/logging/GemFireHandler.java | 2 +-
.../internal/logging/SecurityLogWriter.java | 2 +-
.../logging/SecurityManagerLogWriter.java | 2 +-
.../internal/logging/log4j/AlertAppender.java | 2 +-
.../logging/log4j/LocalizedMessage.java | 2 +-
.../internal/logging/log4j/LogWriterLogger.java | 2 +-
.../logging/log4j/ThreadIdPatternConverter.java | 2 +-
.../GemFireParameterizedMessageFactory.java | 2 +-
.../geode/internal/net/SocketCreator.java | 2 +-
.../geode/internal/offheap/FreeListManager.java | 2 +-
.../internal/process/AttachProcessUtils.java | 2 +-
.../process/BlockingProcessStreamReader.java | 2 +-
...usterConfigurationNotAvailableException.java | 2 +-
.../process/ConnectionFailedException.java | 2 +-
.../internal/process/ControlFileWatchdog.java | 2 +-
.../internal/process/ControllableProcess.java | 2 +-
.../process/FileAlreadyExistsException.java | 2 +-
.../process/LocalProcessController.java | 2 +-
.../internal/process/LocalProcessLauncher.java | 2 +-
.../process/MBeanInvocationFailedException.java | 2 +-
.../process/MBeanProcessController.java | 2 +-
.../internal/process/NativeProcessUtils.java | 2 +-
.../process/NonBlockingProcessStreamReader.java | 2 +-
.../process/PidUnavailableException.java | 2 +-
.../process/ProcessControllerFactory.java | 2 +-
.../process/ProcessLauncherContext.java | 2 +-
.../ProcessTerminatedAbnormallyException.java | 2 +-
.../geode/internal/process/ProcessUtils.java | 2 +-
.../UnableToControlProcessException.java | 2 +-
.../internal/shared/NativeCallsJNAImpl.java | 8 ++--
.../internal/statistics/CounterMonitor.java | 2 +-
.../geode/internal/statistics/GaugeMonitor.java | 2 +-
.../internal/statistics/GemFireStatSampler.java | 2 +-
.../internal/statistics/SimpleStatisticId.java | 2 +-
.../statistics/StatisticDescriptorImpl.java | 2 +-
.../geode/internal/tcp/MsgStreamerList.java | 2 +-
.../internal/tcp/VersionedMsgStreamer.java | 2 +-
.../geode/internal/util/TransformUtils.java | 2 +-
.../CustomEntryConcurrentHashMap.java | 20 ++++-----
.../management/internal/ArrayConverter.java | 2 +-
.../internal/CollectionConverter.java | 2 +-
.../management/internal/EnumConverter.java | 2 +-
.../management/internal/IdentityConverter.java | 2 +-
.../management/internal/OpenTypeConverter.java | 9 ++--
.../internal/SystemManagementService.java | 2 +-
.../management/internal/TableConverter.java | 2 +-
.../internal/beans/stats/VMStatsMonitor.java | 2 +-
.../geode/management/internal/cli/Launcher.java | 2 +-
.../internal/cli/commands/DeployCommands.java | 2 +-
.../cli/commands/LauncherLifecycleCommands.java | 2 +-
.../cli/functions/ExportedLogsSizeInfo.java | 2 +-
.../cli/util/RegionAttributesDefault.java | 2 +-
.../configuration/domain/XmlEntity.java | 2 +-
.../configuration/utils/XmlConstants.java | 2 +-
.../pdx/internal/AutoSerializableManager.java | 44 ++++++++++----------
.../redis/internal/executor/hll/Varint.java | 2 +-
.../ClientServerRegisterInterestsDUnitTest.java | 2 +-
.../management/MemoryThresholdsDUnitTest.java | 2 +-
...rrentIndexInitOnOverflowRegionDUnitTest.java | 2 +-
.../PRColocatedEquiJoinDUnitTest.java | 4 +-
.../query/partitioned/PRQueryDUnitHelper.java | 2 +-
.../geode/cache/snapshot/SnapshotDUnitTest.java | 2 +-
.../cache30/ClientMembershipDUnitTest.java | 2 +-
.../geode/codeAnalysis/decode/cp/CpUtf8.java | 2 +-
.../geode/distributed/AbstractLauncherTest.java | 2 +-
.../geode/distributed/ServerLauncherTest.java | 2 +-
.../distributed/internal/Bug40751DUnitTest.java | 2 +-
.../auth/AbstractGMSAuthenticatorTestCase.java | 16 +++----
.../StreamingOperationManyDUnitTest.java | 2 +-
.../StreamingOperationOneDUnitTest.java | 2 +-
.../disttx/DistributedTransactionDUnitTest.java | 10 ++---
...wardCompatibilitySerializationDUnitTest.java | 2 +-
.../apache/geode/internal/cache/TestDelta.java | 2 +-
.../extension/mock/MockCacheExtension.java | 2 +-
.../mock/MockCacheExtensionXmlGenerator.java | 2 +-
.../extension/mock/MockRegionExtension.java | 2 +-
.../mock/MockRegionExtensionXmlGenerator.java | 2 +-
.../cache/partitioned/Bug39356DUnitTest.java | 3 +-
.../PersistentPartitionedRegionDUnitTest.java | 3 +-
...treamingPartitionOperationManyDUnitTest.java | 2 +-
...StreamingPartitionOperationOneDUnitTest.java | 2 +-
.../asyncqueue/AsyncEventListenerDUnitTest.java | 2 +-
.../ParallelQueueRemovalMessageJUnitTest.java | 2 +-
.../xmlcache/AbstractXmlParserJUnitTest.java | 2 +-
.../compression/CompressionStatsDUnitTest.java | 4 +-
.../internal/lang/ObjectUtilsJUnitTest.java | 2 +-
.../internal/lang/ThreadUtilsJUnitTest.java | 2 +-
.../offheap/LifecycleListenerJUnitTest.java | 2 +-
...tractSignalNotificationHandlerJUnitTest.java | 3 +-
.../geode/internal/util/IOUtilsJUnitTest.java | 2 +-
.../util/concurrent/cm/LoopHelpers.java | 6 +--
...ersalMembershipListenerAdapterDUnitTest.java | 2 +-
...WithCacheLoaderDuringCacheMissDUnitTest.java | 2 +-
.../management/internal/cli/domain/Stock.java | 2 +-
.../DeltaClientAuthorizationDUnitTest.java | 2 +-
.../geode/security/SecurityTestUtils.java | 2 +-
.../generator/AuthzCredentialGenerator.java | 2 +-
.../security/generator/CredentialGenerator.java | 2 +-
.../cache/internal/JUnit4CacheTestCase.java | 2 +-
.../cache/query/internal/cq/CqServiceImpl.java | 2 +-
.../internal/directory/FileIndexInput.java | 2 +-
.../internal/filesystem/FileInputStream.java | 2 +-
.../internal/filesystem/FileOutputStream.java | 2 +-
.../internal/xml/LuceneServiceXmlGenerator.java | 2 +-
.../filesystem/FileSystemJUnitTest.java | 4 +-
.../tools/pulse/tests/ui/PulseTestUtils.java | 2 +-
...stomMappingJackson2HttpMessageConverter.java | 5 +--
.../LoginHandlerInterceptorJUnitTest.java | 3 +-
.../RestHttpOperationInvokerJUnitTest.java | 2 +-
.../SimpleHttpOperationInvokerJUnitTest.java | 2 +-
351 files changed, 503 insertions(+), 523 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMemberCacheEventProcessor.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMemberCacheEventProcessor.java b/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMemberCacheEventProcessor.java
index 8afafdb..012388b 100644
--- a/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMemberCacheEventProcessor.java
+++ b/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMemberCacheEventProcessor.java
@@ -74,7 +74,7 @@ public class SystemMemberCacheEventProcessor {
}
- public static final class SystemMemberCacheMessage extends HighPriorityDistributionMessage {
+ public static class SystemMemberCacheMessage extends HighPriorityDistributionMessage {
protected String regionPath;
protected Operation op;
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/cache/client/internal/ClientMetadataService.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ClientMetadataService.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ClientMetadataService.java
index 3cf0d7b..ec4895f 100755
--- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ClientMetadataService.java
+++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ClientMetadataService.java
@@ -52,7 +52,7 @@ import java.util.concurrent.CopyOnWriteArraySet;
*
* @since GemFire 6.5
*/
-public final class ClientMetadataService {
+public class ClientMetadataService {
private static final Logger logger = LogService.getLogger();
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/cache/operations/internal/UpdateOnlyMap.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/cache/operations/internal/UpdateOnlyMap.java b/geode-core/src/main/java/org/apache/geode/cache/operations/internal/UpdateOnlyMap.java
index ef54791..a3884c4 100644
--- a/geode-core/src/main/java/org/apache/geode/cache/operations/internal/UpdateOnlyMap.java
+++ b/geode-core/src/main/java/org/apache/geode/cache/operations/internal/UpdateOnlyMap.java
@@ -130,7 +130,7 @@ public class UpdateOnlyMap implements Map, Serializable {
return entrySet;
}
- private final class EntrySet extends AbstractSet {
+ private class EntrySet extends AbstractSet {
public Iterator iterator() {
return new EntryIterator();
}
@@ -140,6 +140,7 @@ public class UpdateOnlyMap implements Map, Serializable {
return m.size();
}
}
+
private class EntryIterator implements Iterator {
private Iterator mIterator = m.entrySet().iterator();
@@ -209,7 +210,7 @@ public class UpdateOnlyMap implements Map, Serializable {
return values;
}
- private final class Values extends AbstractCollection {
+ private class Values extends AbstractCollection {
@Override
public Iterator iterator() {
return new ValueIterator();
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/cache/query/internal/ObjectIntHashMap.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/ObjectIntHashMap.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/ObjectIntHashMap.java
index 26da1a3..ff794d6 100644
--- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/ObjectIntHashMap.java
+++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/ObjectIntHashMap.java
@@ -882,13 +882,13 @@ public class ObjectIntHashMap implements Cloneable, Serializable {
}
- private final class KeyIterator extends HashIterator<Object> {
+ private class KeyIterator extends HashIterator<Object> {
public Object next() {
return nextEntry().getKey();
}
}
- private final class EntryIterator extends HashIterator<Entry> {
+ private class EntryIterator extends HashIterator<Entry> {
public Entry next() {
return nextEntry();
}
@@ -923,7 +923,7 @@ public class ObjectIntHashMap implements Cloneable, Serializable {
return (ks != null ? ks : (keySet = new KeySet()));
}
- private final class KeySet extends AbstractSet<Object> {
+ private class KeySet extends AbstractSet<Object> {
public Iterator<Object> iterator() {
return newKeyIterator();
}
@@ -966,7 +966,7 @@ public class ObjectIntHashMap implements Cloneable, Serializable {
return es != null ? es : (entrySet = new EntrySet());
}
- private final class EntrySet extends AbstractSet<Entry> {
+ private class EntrySet extends AbstractSet<Entry> {
public Iterator<Entry> iterator() {
return newEntryIterator();
}
@@ -1055,7 +1055,7 @@ public class ObjectIntHashMap implements Cloneable, Serializable {
return loadFactor;
}
- private final class IntHashMapStrategy implements HashingStrategy {
+ private class IntHashMapStrategy implements HashingStrategy {
@Override
public int hashCode(Object o) {
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryObserverHolder.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryObserverHolder.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryObserverHolder.java
index 5730f67..93f848f 100644
--- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryObserverHolder.java
+++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/QueryObserverHolder.java
@@ -35,7 +35,7 @@ package org.apache.geode.cache.query.internal;
*
* @version $Revision: 1.1 $
*/
-public final class QueryObserverHolder {
+public class QueryObserverHolder {
/**
* The default 'do-nothing' query observer *
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/cache/query/internal/ResultsCollectionWrapper.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/ResultsCollectionWrapper.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/ResultsCollectionWrapper.java
index 6fb7d8d..e4ea56c 100644
--- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/ResultsCollectionWrapper.java
+++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/ResultsCollectionWrapper.java
@@ -35,7 +35,7 @@ import org.apache.geode.internal.Version;
*
* @since GemFire 4.0
*/
-public final class ResultsCollectionWrapper implements SelectResults, DataSerializableFixedID {
+public class ResultsCollectionWrapper implements SelectResults, DataSerializableFixedID {
private Collection base;
private CollectionType collectionType;
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/cache/query/internal/ResultsSet.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/ResultsSet.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/ResultsSet.java
index 209cd10..1e7a2f9 100644
--- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/ResultsSet.java
+++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/ResultsSet.java
@@ -37,7 +37,7 @@ import org.apache.geode.internal.i18n.LocalizedStrings;
*
* @since GemFire 4.0
*/
-public final class ResultsSet extends HashSet implements SelectResults, DataSerializableFixedID {
+public class ResultsSet extends HashSet implements SelectResults, DataSerializableFixedID {
private static final long serialVersionUID = -5423281031630216824L;
private ObjectType elementType;
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/cache/query/internal/SortedResultSet.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/SortedResultSet.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/SortedResultSet.java
index 05ebea7..db925b9 100644
--- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/SortedResultSet.java
+++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/SortedResultSet.java
@@ -31,7 +31,7 @@ import org.apache.geode.internal.Version;
*
* @since GemFire 4.0
*/
-public final class SortedResultSet extends TreeSet
+public class SortedResultSet extends TreeSet
implements SelectResults, Ordered, DataSerializableFixedID {
private static final long serialVersionUID = 5184711453750319224L;
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/cache/query/internal/SortedStructSet.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/SortedStructSet.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/SortedStructSet.java
index d1f9fb7..f3fd661 100644
--- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/SortedStructSet.java
+++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/SortedStructSet.java
@@ -32,7 +32,7 @@ import org.apache.geode.internal.Version;
*
* @since GemFire 4.0
*/
-public final class SortedStructSet extends TreeSet
+public class SortedStructSet extends TreeSet
implements SelectResults, DataSerializableFixedID, Ordered, StructFields {
private static final long serialVersionUID = -1687142950781718159L;
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/cache/query/internal/StructBag.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/StructBag.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/StructBag.java
index a2c4b7f..2e9697b 100644
--- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/StructBag.java
+++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/StructBag.java
@@ -41,7 +41,7 @@ import org.apache.geode.internal.i18n.LocalizedStrings;
*
* @since GemFire 5.1
*/
-public final class StructBag extends ResultsBag implements StructFields {
+public class StructBag extends ResultsBag implements StructFields {
/**
* Holds value of property modifiable.
*/
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/cache/query/internal/StructSet.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/StructSet.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/StructSet.java
index 984c419..7003d73 100644
--- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/StructSet.java
+++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/StructSet.java
@@ -39,7 +39,7 @@ import org.apache.geode.internal.i18n.LocalizedStrings;
*
* @since GemFire 4.0
*/
-public final class StructSet /* extends ObjectOpenCustomHashSet */ implements Set, SelectResults,
+public class StructSet /* extends ObjectOpenCustomHashSet */ implements Set, SelectResults,
DataSerializableFixedID, StructFields {
private static final long serialVersionUID = -1228835506930611510L;
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/cache/query/internal/Undefined.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/Undefined.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/Undefined.java
index 3ee0428..76a0325 100644
--- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/Undefined.java
+++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/Undefined.java
@@ -30,7 +30,7 @@ import org.apache.geode.internal.Version;
*
*/
-public final class Undefined implements DataSerializableFixedID, Comparable, Serializable {
+public class Undefined implements DataSerializableFixedID, Comparable, Serializable {
private static final long serialVersionUID = 6643107525908324141L;
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/HashIndexSet.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/HashIndexSet.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/HashIndexSet.java
index 6022b43..eb21f97 100755
--- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/HashIndexSet.java
+++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/index/HashIndexSet.java
@@ -46,7 +46,7 @@ public class HashIndexSet implements Set {
* optional statistics object to track number of hash collisions and time spent probing based on
* hash collisions
*/
- final class HashIndexSetProperties {
+ class HashIndexSetProperties {
/** the set of Objects */
final protected transient Object[] set;
/** used for hashing into the table **/
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/cache/query/internal/types/MapTypeImpl.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/types/MapTypeImpl.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/types/MapTypeImpl.java
index 889c4ec..1f66f0d 100644
--- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/types/MapTypeImpl.java
+++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/types/MapTypeImpl.java
@@ -25,7 +25,7 @@ import org.apache.geode.DataSerializer;
*
* @since GemFire 4.0
*/
-public final class MapTypeImpl extends CollectionTypeImpl implements MapType {
+public class MapTypeImpl extends CollectionTypeImpl implements MapType {
private static final long serialVersionUID = -705688605389537058L;
private ObjectType keyType;
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/cache/query/internal/types/StructTypeImpl.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/cache/query/internal/types/StructTypeImpl.java b/geode-core/src/main/java/org/apache/geode/cache/query/internal/types/StructTypeImpl.java
index 7047e12..cef2009 100644
--- a/geode-core/src/main/java/org/apache/geode/cache/query/internal/types/StructTypeImpl.java
+++ b/geode-core/src/main/java/org/apache/geode/cache/query/internal/types/StructTypeImpl.java
@@ -32,7 +32,7 @@ import org.apache.geode.internal.i18n.LocalizedStrings;
*
* @since GemFire 4.0
*/
-public final class StructTypeImpl extends ObjectTypeImpl implements StructType {
+public class StructTypeImpl extends ObjectTypeImpl implements StructType {
private static final long serialVersionUID = -6368710865627039204L;
private String[] fieldNames;
private ObjectType[] fieldTypes;
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionConfigSnapshot.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionConfigSnapshot.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionConfigSnapshot.java
index 07e8b02..e878cce 100644
--- a/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionConfigSnapshot.java
+++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionConfigSnapshot.java
@@ -31,7 +31,7 @@ import org.apache.geode.internal.i18n.LocalizedStrings;
* Removed implementations of hashCode() and equals() that were throwing
* UnsupportedOperationException. See bug #50939 if you need to override those.
*/
-public final class DistributionConfigSnapshot extends DistributionConfigImpl {
+public class DistributionConfigSnapshot extends DistributionConfigImpl {
private static final long serialVersionUID = 7445728132965092798L;
private HashSet modifiable;
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionManager.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionManager.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionManager.java
index df880a0..f4e547f 100644
--- a/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionManager.java
+++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionManager.java
@@ -4280,7 +4280,7 @@ public class DistributionManager implements DM {
* A simple class used for locking the list of members of the distributed system. We give this
* lock its own class so that it shows up nicely in stack traces.
*/
- private static final class MembersLock {
+ private static class MembersLock {
protected MembersLock() {
}
@@ -4290,7 +4290,7 @@ public class DistributionManager implements DM {
* A simple class used for locking the list of membership listeners. We give this lock its own
* class so that it shows up nicely in stack traces.
*/
- private static final class MembershipListenersLock {
+ private static class MembershipListenersLock {
protected MembershipListenersLock() {}
}
@@ -4298,7 +4298,7 @@ public class DistributionManager implements DM {
* This is the listener implementation for responding from events from the Membership Manager.
*
*/
- private final class MyListener implements DistributedMembershipListener {
+ private class MyListener implements DistributedMembershipListener {
DistributionManager dm;
public MyListener(DistributionManager dm) {
@@ -4438,7 +4438,7 @@ public class DistributionManager implements DM {
*
*
*/
- private static final class MemberJoinedEvent extends MemberEvent {
+ private static class MemberJoinedEvent extends MemberEvent {
MemberJoinedEvent(InternalDistributedMember id) {
super(id);
}
@@ -4458,7 +4458,7 @@ public class DistributionManager implements DM {
* This is an event reflecting that a InternalDistributedMember has left the system.
*
*/
- private static final class MemberDepartedEvent extends MemberEvent {
+ private static class MemberDepartedEvent extends MemberEvent {
String reason;
MemberDepartedEvent(InternalDistributedMember id, String r) {
@@ -4483,7 +4483,7 @@ public class DistributionManager implements DM {
*
*
*/
- private static final class MemberCrashedEvent extends MemberEvent {
+ private static class MemberCrashedEvent extends MemberEvent {
String reason;
MemberCrashedEvent(InternalDistributedMember id, String r) {
@@ -4506,7 +4506,7 @@ public class DistributionManager implements DM {
* This is an event reflecting that a InternalDistributedMember may be missing but has not yet
* left the system.
*/
- private static final class MemberSuspectEvent extends MemberEvent {
+ private static class MemberSuspectEvent extends MemberEvent {
InternalDistributedMember whoSuspected;
String reason;
@@ -4536,7 +4536,7 @@ public class DistributionManager implements DM {
}
}
- private static final class ViewInstalledEvent extends MemberEvent {
+ private static class ViewInstalledEvent extends MemberEvent {
NetView view;
ViewInstalledEvent(NetView view) {
@@ -4564,7 +4564,7 @@ public class DistributionManager implements DM {
}
}
- private static final class QuorumLostEvent extends MemberEvent {
+ private static class QuorumLostEvent extends MemberEvent {
Set<InternalDistributedMember> failures;
List<InternalDistributedMember> remaining;
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/distributed/internal/HighPriorityAckedMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/HighPriorityAckedMessage.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/HighPriorityAckedMessage.java
index 939b8ed..93ebe55 100755
--- a/geode-core/src/main/java/org/apache/geode/distributed/internal/HighPriorityAckedMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/HighPriorityAckedMessage.java
@@ -44,7 +44,7 @@ import org.apache.geode.internal.logging.log4j.LocalizedMessage;
*
* @since GemFire 5.1
*/
-public final class HighPriorityAckedMessage extends HighPriorityDistributionMessage
+public class HighPriorityAckedMessage extends HighPriorityDistributionMessage
implements MessageWithReply {
private static final Logger logger = LogService.getLogger();
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/distributed/internal/LocatorLoadSnapshot.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/LocatorLoadSnapshot.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/LocatorLoadSnapshot.java
index a190d05..6b19a12 100644
--- a/geode-core/src/main/java/org/apache/geode/distributed/internal/LocatorLoadSnapshot.java
+++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/LocatorLoadSnapshot.java
@@ -541,7 +541,7 @@ public class LocatorLoadSnapshot {
}
}
- private final class LoadEstimateTask implements Runnable {
+ private class LoadEstimateTask implements Runnable {
private final EstimateMapKey key;
private final LoadHolder lh;
@@ -578,7 +578,7 @@ public class LocatorLoadSnapshot {
}
}
- private static final class LoadHolder {
+ private static class LoadHolder {
private float load;
private float loadPerConnection;
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/distributed/internal/ProductUseLog.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/ProductUseLog.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/ProductUseLog.java
index 4022759..924d49b 100644
--- a/geode-core/src/main/java/org/apache/geode/distributed/internal/ProductUseLog.java
+++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/ProductUseLog.java
@@ -38,7 +38,7 @@ import org.apache.geode.internal.logging.PureLogWriter;
*
* @since GemFire 2013
*/
-public final class ProductUseLog implements MembershipListener {
+public class ProductUseLog implements MembershipListener {
protected static long MAX_PRODUCT_USE_FILE_SIZE = Long.getLong("max_view_log_size", 5000000);
private final int logLevel;
private final File productUseLogFile;
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/distributed/internal/RuntimeDistributionConfigImpl.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/RuntimeDistributionConfigImpl.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/RuntimeDistributionConfigImpl.java
index abe8133..567bbac 100644
--- a/geode-core/src/main/java/org/apache/geode/distributed/internal/RuntimeDistributionConfigImpl.java
+++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/RuntimeDistributionConfigImpl.java
@@ -37,7 +37,7 @@ import static org.apache.geode.distributed.ConfigurationProperties.*;
*
* @since GemFire 3.0
*/
-public final class RuntimeDistributionConfigImpl extends DistributionConfigImpl {
+public class RuntimeDistributionConfigImpl extends DistributionConfigImpl {
private static final long serialVersionUID = -805637520096606113L;
transient private final InternalDistributedSystem ds;
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/distributed/internal/SerialAckedMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/SerialAckedMessage.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/SerialAckedMessage.java
index 3217e19..c56a929 100644
--- a/geode-core/src/main/java/org/apache/geode/distributed/internal/SerialAckedMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/SerialAckedMessage.java
@@ -34,8 +34,7 @@ import org.apache.geode.internal.logging.LogService;
* some tests to flush the serial communication channels after no-ack tests.
*
*/
-public final class SerialAckedMessage extends SerialDistributionMessage
- implements MessageWithReply {
+public class SerialAckedMessage extends SerialDistributionMessage implements MessageWithReply {
private static final Logger logger = LogService.getLogger();
/** The is of the distribution manager that sent the message */
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/distributed/internal/ShutdownMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/ShutdownMessage.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/ShutdownMessage.java
index 46c51db..42de647 100644
--- a/geode-core/src/main/java/org/apache/geode/distributed/internal/ShutdownMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/ShutdownMessage.java
@@ -26,7 +26,7 @@ import org.apache.geode.distributed.internal.membership.*;
*
* N.B. -- this is a SerialDistributionMessage due to bug32980
*/
-public final class ShutdownMessage extends HighPriorityDistributionMessage
+public class ShutdownMessage extends HighPriorityDistributionMessage
implements AdminMessageType, MessageWithReply {
/** The is of the distribution manager that is shutting down */
protected InternalDistributedMember id;
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/distributed/internal/StartupMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/StartupMessage.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/StartupMessage.java
index 022cea7..d81aed0 100644
--- a/geode-core/src/main/java/org/apache/geode/distributed/internal/StartupMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/StartupMessage.java
@@ -38,8 +38,7 @@ import java.util.Set;
/**
* A message that is sent to all other distribution manager when a distribution manager starts up.
*/
-public final class StartupMessage extends HighPriorityDistributionMessage
- implements AdminMessageType {
+public class StartupMessage extends HighPriorityDistributionMessage implements AdminMessageType {
private static final Logger logger = LogService.getLogger();
private String version = GemFireVersion.getGemFireVersion(); // added for bug 29005
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/DLockQueryProcessor.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/DLockQueryProcessor.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/DLockQueryProcessor.java
index f8fcdd0..df21141 100755
--- a/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/DLockQueryProcessor.java
+++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/DLockQueryProcessor.java
@@ -123,7 +123,7 @@ public class DLockQueryProcessor extends ReplyProcessor21 {
// -------------------------------------------------------------------------
// DLockQueryMessage
// -------------------------------------------------------------------------
- public static final class DLockQueryMessage extends PooledDistributionMessage
+ public static class DLockQueryMessage extends PooledDistributionMessage
implements MessageWithReply {
/** The name of the DistributedLockService */
protected String serviceName;
@@ -348,7 +348,7 @@ public class DLockQueryProcessor extends ReplyProcessor21 {
// -------------------------------------------------------------------------
// DLockQueryReplyMessage
// -------------------------------------------------------------------------
- public static final class DLockQueryReplyMessage extends ReplyMessage {
+ public static class DLockQueryReplyMessage extends ReplyMessage {
static final int NOT_GRANTOR = 0;
static final int OK = 1;
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/DLockRecoverGrantorProcessor.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/DLockRecoverGrantorProcessor.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/DLockRecoverGrantorProcessor.java
index 2a48308..0ed4890 100755
--- a/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/DLockRecoverGrantorProcessor.java
+++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/DLockRecoverGrantorProcessor.java
@@ -187,7 +187,7 @@ public class DLockRecoverGrantorProcessor extends ReplyProcessor21 {
// -------------------------------------------------------------------------
// DLockRecoverGrantorMessage
// -------------------------------------------------------------------------
- public static final class DLockRecoverGrantorMessage extends PooledDistributionMessage
+ public static class DLockRecoverGrantorMessage extends PooledDistributionMessage
implements MessageWithReply {
/** The name of the DistributedLockService */
@@ -312,7 +312,7 @@ public class DLockRecoverGrantorProcessor extends ReplyProcessor21 {
// -------------------------------------------------------------------------
// DLockRecoverGrantorReplyMessage
// -------------------------------------------------------------------------
- public static final class DLockRecoverGrantorReplyMessage extends ReplyMessage {
+ public static class DLockRecoverGrantorReplyMessage extends ReplyMessage {
public static final int OK = 0;
public static final int GRANTOR_DISPUTE = 1;
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/DLockReleaseProcessor.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/DLockReleaseProcessor.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/DLockReleaseProcessor.java
index 6adfa9b..e133f79 100755
--- a/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/DLockReleaseProcessor.java
+++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/DLockReleaseProcessor.java
@@ -132,7 +132,7 @@ public class DLockReleaseProcessor extends ReplyProcessor21 {
// -------------------------------------------------------------------------
// DLockReleaseMessage
// -------------------------------------------------------------------------
- public static final class DLockReleaseMessage extends HighPriorityDistributionMessage
+ public static class DLockReleaseMessage extends HighPriorityDistributionMessage
implements MessageWithReply {
/** The name of the DistributedLockService */
protected String serviceName;
@@ -372,7 +372,7 @@ public class DLockReleaseProcessor extends ReplyProcessor21 {
// -------------------------------------------------------------------------
// DLockReleaseReplyMessage
// -------------------------------------------------------------------------
- public static final class DLockReleaseReplyMessage extends ReplyMessage {
+ public static class DLockReleaseReplyMessage extends ReplyMessage {
static final int NOT_GRANTOR = 0;
static final int OK = 1;
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/DLockService.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/DLockService.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/DLockService.java
index ca012d3..35d19bb 100644
--- a/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/DLockService.java
+++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/DLockService.java
@@ -3180,7 +3180,7 @@ public class DLockService extends DistributedLockService {
// -------------------------------------------------------------------------
/** Used as the name (key) for the suspend locking entry in the tokens map */
- public static final class SuspendLockingToken implements DataSerializableFixedID {
+ public static class SuspendLockingToken implements DataSerializableFixedID {
public SuspendLockingToken() {}
@Override
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/DeposeGrantorProcessor.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/DeposeGrantorProcessor.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/DeposeGrantorProcessor.java
index f05cc82..907e731 100644
--- a/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/DeposeGrantorProcessor.java
+++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/DeposeGrantorProcessor.java
@@ -99,7 +99,7 @@ public class DeposeGrantorProcessor extends ReplyProcessor21 {
/////////////// Inner message classes //////////////////
- public static final class DeposeGrantorMessage extends PooledDistributionMessage
+ public static class DeposeGrantorMessage extends PooledDistributionMessage
implements MessageWithReply {
private int processorId;
private String serviceName;
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/DistributedMemberLock.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/DistributedMemberLock.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/DistributedMemberLock.java
index c779e6f..9b379c7 100755
--- a/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/DistributedMemberLock.java
+++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/DistributedMemberLock.java
@@ -39,7 +39,7 @@ import java.util.concurrent.locks.Lock;
*
* @since GemFire 5.1
*/
-public final class DistributedMemberLock implements Lock {
+public class DistributedMemberLock implements Lock {
/** Lock lease timeout value that never expires. */
public static final long NON_EXPIRING_LEASE = -1;
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/ElderInitProcessor.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/ElderInitProcessor.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/ElderInitProcessor.java
index 886aafc..0dbaa0f 100644
--- a/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/ElderInitProcessor.java
+++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/ElderInitProcessor.java
@@ -143,7 +143,7 @@ public class ElderInitProcessor extends ReplyProcessor21 {
/////////////// Inner message classes //////////////////
- public static final class ElderInitMessage extends PooledDistributionMessage
+ public static class ElderInitMessage extends PooledDistributionMessage
implements MessageWithReply {
private int processorId;
@@ -222,7 +222,7 @@ public class ElderInitProcessor extends ReplyProcessor21 {
}
}
- public static final class ElderInitReplyMessage extends ReplyMessage {
+ public static class ElderInitReplyMessage extends ReplyMessage {
private ArrayList grantors; // svc names
private ArrayList grantorVersions; // grantor version longs
private ArrayList grantorSerialNumbers; // grantor dls serial number ints
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/GrantorRequestProcessor.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/GrantorRequestProcessor.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/GrantorRequestProcessor.java
index 0b301c3..14f4bc1 100644
--- a/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/GrantorRequestProcessor.java
+++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/GrantorRequestProcessor.java
@@ -458,7 +458,7 @@ public class GrantorRequestProcessor extends ReplyProcessor21 {
/////////////// Inner message classes //////////////////
- public static final class GrantorRequestMessage extends PooledDistributionMessage
+ public static class GrantorRequestMessage extends PooledDistributionMessage
implements MessageWithReply {
private long grantorVersion;
private int dlsSerialNumber;
@@ -637,7 +637,7 @@ public class GrantorRequestProcessor extends ReplyProcessor21 {
}
}
- public static final class GrantorInfoReplyMessage extends ReplyMessage {
+ public static class GrantorInfoReplyMessage extends ReplyMessage {
private InternalDistributedMember grantor;
private long elderVersionId;
private int grantorSerialNumber;
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/NonGrantorDestroyedProcessor.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/NonGrantorDestroyedProcessor.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/NonGrantorDestroyedProcessor.java
index 9a6c55b..d8f688b 100755
--- a/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/NonGrantorDestroyedProcessor.java
+++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/locks/NonGrantorDestroyedProcessor.java
@@ -103,7 +103,7 @@ public class NonGrantorDestroyedProcessor extends ReplyProcessor21 {
/////////////// Inner message classes //////////////////
- public static final class NonGrantorDestroyedMessage extends PooledDistributionMessage
+ public static class NonGrantorDestroyedMessage extends PooledDistributionMessage
implements MessageWithReply {
private int processorId;
@@ -218,7 +218,7 @@ public class NonGrantorDestroyedProcessor extends ReplyProcessor21 {
}
}
- public static final class NonGrantorDestroyedReplyMessage extends ReplyMessage {
+ public static class NonGrantorDestroyedReplyMessage extends ReplyMessage {
public static final byte OK = 0;
public static final byte NOT_GRANTOR = 1;
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/distributed/internal/membership/gms/mgr/LocalViewMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/membership/gms/mgr/LocalViewMessage.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/membership/gms/mgr/LocalViewMessage.java
index f92c318..cf00187 100755
--- a/geode-core/src/main/java/org/apache/geode/distributed/internal/membership/gms/mgr/LocalViewMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/membership/gms/mgr/LocalViewMessage.java
@@ -31,7 +31,7 @@ import org.apache.geode.distributed.internal.membership.NetView;
*
*/
-public final class LocalViewMessage extends SerialDistributionMessage {
+public class LocalViewMessage extends SerialDistributionMessage {
private GMSMembershipManager manager;
private long viewId;
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/distributed/internal/streaming/StreamingOperation.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/streaming/StreamingOperation.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/streaming/StreamingOperation.java
index b67191d..783f651 100644
--- a/geode-core/src/main/java/org/apache/geode/distributed/internal/streaming/StreamingOperation.java
+++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/streaming/StreamingOperation.java
@@ -416,7 +416,7 @@ public abstract class StreamingOperation {
}
}
- public static final class StreamingReplyMessage extends ReplyMessage {
+ public static class StreamingReplyMessage extends ReplyMessage {
/** the number of this message */
protected int msgNum;
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/HeapDataOutputStream.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/HeapDataOutputStream.java b/geode-core/src/main/java/org/apache/geode/internal/HeapDataOutputStream.java
index ef8cfb2..f2a6492 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/HeapDataOutputStream.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/HeapDataOutputStream.java
@@ -681,7 +681,7 @@ public class HeapDataOutputStream extends OutputStream
return new HDInputStream();
}
- private final class HDInputStream extends InputStream {
+ private class HDInputStream extends InputStream {
private Iterator<ByteBuffer> chunkIt;
private ByteBuffer bb;
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/InternalDataSerializer.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/InternalDataSerializer.java b/geode-core/src/main/java/org/apache/geode/internal/InternalDataSerializer.java
index 7dbd701..8c3ecb8 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/InternalDataSerializer.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/InternalDataSerializer.java
@@ -3230,7 +3230,7 @@ public abstract class InternalDataSerializer extends DataSerializer implements D
* A distribution message that alerts other members of the distributed cache of a new
* {@code DataSerializer} being registered.
*/
- public static final class RegistrationMessage extends SerialDistributionMessage {
+ public static class RegistrationMessage extends SerialDistributionMessage {
/**
* The id of the {@code DataSerializer} that was registered since 5.7 an int instead of a byte
*/
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/InternalInstantiator.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/InternalInstantiator.java b/geode-core/src/main/java/org/apache/geode/internal/InternalInstantiator.java
index 1c1a73e..64dd90b 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/InternalInstantiator.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/InternalInstantiator.java
@@ -955,7 +955,7 @@ public class InternalInstantiator {
*
* @since GemFire 5.0
*/
- public static final class RegistrationContextMessage extends RegistrationMessage {
+ public static class RegistrationContextMessage extends RegistrationMessage {
private transient ClientProxyMembershipID context;
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/NullDataOutputStream.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/NullDataOutputStream.java b/geode-core/src/main/java/org/apache/geode/internal/NullDataOutputStream.java
index d4ec874..a9f9e95 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/NullDataOutputStream.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/NullDataOutputStream.java
@@ -27,7 +27,7 @@ import org.apache.geode.DataSerializer;
* @since GemFire 5.0.2
*
*/
-public final class NullDataOutputStream extends OutputStream implements ObjToByteArraySerializer {
+public class NullDataOutputStream extends OutputStream implements ObjToByteArraySerializer {
private int size;
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/ObjIdConcurrentMap.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/ObjIdConcurrentMap.java b/geode-core/src/main/java/org/apache/geode/internal/ObjIdConcurrentMap.java
index b4f882e..da94abb 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/ObjIdConcurrentMap.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/ObjIdConcurrentMap.java
@@ -186,7 +186,7 @@ public class ObjIdConcurrentMap<V> /* extends AbstractMap<K, V> */
* Segment.readValueUnderLock method is used as a backup in case a null (pre-initialized) value is
* ever seen in an unsynchronized access method.
*/
- static final class HashEntry<V> {
+ static class HashEntry<V> {
final int key;
final int hash;
volatile V value;
@@ -209,7 +209,7 @@ public class ObjIdConcurrentMap<V> /* extends AbstractMap<K, V> */
* Segments are specialized versions of hash tables. This subclasses from ReentrantLock
* opportunistically, just to simplify some locking and avoid separate construction.
*/
- static final class Segment<V> extends ReentrantLock implements Serializable {
+ static class Segment<V> extends ReentrantLock implements Serializable {
/*
* Segments maintain a table of entry lists that are ALWAYS kept in a consistent state, so can
* be read without locking. Next fields of nodes are immutable (final). All list additions are
@@ -1049,12 +1049,11 @@ public class ObjIdConcurrentMap<V> /* extends AbstractMap<K, V> */
}
/*
- * final class KeyIterator extends HashIterator implements Iterator<K>, Enumeration<K> { public K
- * next() { return super.nextEntry().key; } public K nextElement() { return super.nextEntry().key;
- * } }
+ * class KeyIterator extends HashIterator implements Iterator<K>, Enumeration<K> { public K next()
+ * { return super.nextEntry().key; } public K nextElement() { return super.nextEntry().key; } }
*
- * final class ValueIterator extends HashIterator implements Iterator<V>, Enumeration<V> { public
- * V next() { return super.nextEntry().value; } public V nextElement() { return
+ * class ValueIterator extends HashIterator implements Iterator<V>, Enumeration<V> { public V
+ * next() { return super.nextEntry().value; } public V nextElement() { return
* super.nextEntry().value; } }
*/
@@ -1122,7 +1121,7 @@ public class ObjIdConcurrentMap<V> /* extends AbstractMap<K, V> */
// * Custom Entry class used by EntryIterator.next(), that relays
// * setValue changes to the underlying map.
// */
- // final class WriteThroughEntry
+ // class WriteThroughEntry
// extends SimpleEntry<V>
// {
// WriteThroughEntry(int k, V v) {
@@ -1148,25 +1147,25 @@ public class ObjIdConcurrentMap<V> /* extends AbstractMap<K, V> */
// }
/*
- * final class EntryIterator extends HashIterator implements Iterator<Entry<V>> { public Entry<V>
- * next() { HashEntry<V> e = super.nextEntry(); return new WriteThroughEntry(e.key, e.value); } }
+ * class EntryIterator extends HashIterator implements Iterator<Entry<V>> { public Entry<V> next()
+ * { HashEntry<V> e = super.nextEntry(); return new WriteThroughEntry(e.key, e.value); } }
*
- * final class KeySet extends AbstractSet<K> { public Iterator<K> iterator() { return new
- * KeyIterator(); } public int size() { return ObjIdConcurrentMap.this.size(); } public boolean
- * isEmpty() { return ObjIdConcurrentMap.this.isEmpty(); } public boolean contains(Object o) {
- * return ObjIdConcurrentMap.this.containsKey(o); } public boolean remove(Object o) { return
+ * class KeySet extends AbstractSet<K> { public Iterator<K> iterator() { return new KeyIterator();
+ * } public int size() { return ObjIdConcurrentMap.this.size(); } public boolean isEmpty() {
+ * return ObjIdConcurrentMap.this.isEmpty(); } public boolean contains(Object o) { return
+ * ObjIdConcurrentMap.this.containsKey(o); } public boolean remove(Object o) { return
* ObjIdConcurrentMap.this.remove(o) != null; } public void clear() {
* ObjIdConcurrentMap.this.clear(); } }
*
- * final class Values extends AbstractCollection<V> { public Iterator<V> iterator() { return new
+ * class Values extends AbstractCollection<V> { public Iterator<V> iterator() { return new
* ValueIterator(); } public int size() { return ObjIdConcurrentMap.this.size(); } public boolean
* isEmpty() { return ObjIdConcurrentMap.this.isEmpty(); } public boolean contains(Object o) {
* return ObjIdConcurrentMap.this.containsValue(o); } public void clear() {
* ObjIdConcurrentMap.this.clear(); } }
*
- * final class EntrySet extends AbstractSet<Map.Entry<K,V>> { public Iterator<Map.Entry<K,V>>
- * iterator() { return new EntryIterator(); } public boolean contains(Object o) { if (!(o
- * instanceof Map.Entry)) return false; Map.Entry<?,?> e = (Map.Entry<?,?>)o; V v =
+ * class EntrySet extends AbstractSet<Map.Entry<K,V>> { public Iterator<Map.Entry<K,V>> iterator()
+ * { return new EntryIterator(); } public boolean contains(Object o) { if (!(o instanceof
+ * Map.Entry)) return false; Map.Entry<?,?> e = (Map.Entry<?,?>)o; V v =
* ObjIdConcurrentMap.this.get(e.getKey()); return v != null && v.equals(e.getValue()); } public
* boolean remove(Object o) { if (!(o instanceof Map.Entry)) return false; Map.Entry<?,?> e =
* (Map.Entry<?,?>)o; return ObjIdConcurrentMap.this.remove(e.getKey(), e.getValue()); } public
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/PureJavaMode.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/PureJavaMode.java b/geode-core/src/main/java/org/apache/geode/internal/PureJavaMode.java
index bc6f23e..3b10365 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/PureJavaMode.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/PureJavaMode.java
@@ -20,7 +20,7 @@ import org.apache.geode.distributed.internal.DistributionConfig;
/**
* Used to determine if product should use pure java mode.
*/
-public final class PureJavaMode {
+public class PureJavaMode {
/**
* System property to set to true to force pure java mode
*/
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/SetUtils.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/SetUtils.java b/geode-core/src/main/java/org/apache/geode/internal/SetUtils.java
index 506cf03..66bd337 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/SetUtils.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/SetUtils.java
@@ -24,7 +24,7 @@ import java.util.Set;
* @since GemFire 59poc
*
*/
-public final class SetUtils {
+public class SetUtils {
public static <T> boolean intersectsWith(final Set<? extends T> a, final Set<? extends T> b) {
if (a == b) {
return true;
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/SystemAdmin.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/SystemAdmin.java b/geode-core/src/main/java/org/apache/geode/internal/SystemAdmin.java
index bdb635e..ceae486 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/SystemAdmin.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/SystemAdmin.java
@@ -1267,7 +1267,7 @@ public class SystemAdmin {
*
*/
@SuppressWarnings("serial")
- private static final class CombinedResources extends ArrayList<ResourceInst> {
+ private static class CombinedResources extends ArrayList<ResourceInst> {
public CombinedResources(StatValue v) {
super(Arrays.asList(v.getResources()));
}
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/Version.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/Version.java b/geode-core/src/main/java/org/apache/geode/internal/Version.java
index 288d104..030da85 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/Version.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/Version.java
@@ -34,7 +34,7 @@ import org.apache.geode.internal.i18n.LocalizedStrings;
*
* @since GemFire 5.7
*/
-public final class Version implements Comparable<Version> {
+public class Version implements Comparable<Version> {
/** The name of this version */
private final transient String name;
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/VersionedDataInputStream.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/VersionedDataInputStream.java b/geode-core/src/main/java/org/apache/geode/internal/VersionedDataInputStream.java
index a8d4b88..93511b4 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/VersionedDataInputStream.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/VersionedDataInputStream.java
@@ -25,7 +25,7 @@ import java.io.InputStream;
*
* @since GemFire 7.1
*/
-public final class VersionedDataInputStream extends DataInputStream implements VersionedDataStream {
+public class VersionedDataInputStream extends DataInputStream implements VersionedDataStream {
private final Version version;
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/VersionedDataOutputStream.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/VersionedDataOutputStream.java b/geode-core/src/main/java/org/apache/geode/internal/VersionedDataOutputStream.java
index 2fb40b9..cd14dc0 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/VersionedDataOutputStream.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/VersionedDataOutputStream.java
@@ -23,8 +23,7 @@ import java.io.OutputStream;
*
* @since GemFire 7.1
*/
-public final class VersionedDataOutputStream extends DataOutputStream
- implements VersionedDataStream {
+public class VersionedDataOutputStream extends DataOutputStream implements VersionedDataStream {
private final Version version;
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/VersionedObjectInput.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/VersionedObjectInput.java b/geode-core/src/main/java/org/apache/geode/internal/VersionedObjectInput.java
index 86e81c4..bd0b27f 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/VersionedObjectInput.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/VersionedObjectInput.java
@@ -24,7 +24,7 @@ import java.io.ObjectInput;
*
* @since GemFire 7.1
*/
-public final class VersionedObjectInput implements ObjectInput, VersionedDataStream {
+public class VersionedObjectInput implements ObjectInput, VersionedDataStream {
private final ObjectInput in;
private final Version version;
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/VersionedObjectOutput.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/VersionedObjectOutput.java b/geode-core/src/main/java/org/apache/geode/internal/VersionedObjectOutput.java
index 83e6f73..09f3995 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/VersionedObjectOutput.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/VersionedObjectOutput.java
@@ -24,7 +24,7 @@ import java.io.ObjectOutput;
*
* @since GemFire 7.1
*/
-public final class VersionedObjectOutput implements ObjectOutput, VersionedDataStream {
+public class VersionedObjectOutput implements ObjectOutput, VersionedDataStream {
private final ObjectOutput out;
private final Version version;
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AddHealthListenerRequest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AddHealthListenerRequest.java b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AddHealthListenerRequest.java
index 5993d6b..6dd97e8 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AddHealthListenerRequest.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AddHealthListenerRequest.java
@@ -30,7 +30,7 @@ import java.io.*;
*
* @since GemFire 3.5
*/
-public final class AddHealthListenerRequest extends AdminRequest {
+public class AddHealthListenerRequest extends AdminRequest {
// instance variables
private GemFireHealthConfig cfg;
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AddHealthListenerResponse.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AddHealthListenerResponse.java b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AddHealthListenerResponse.java
index 8b960ab..8777303 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AddHealthListenerResponse.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AddHealthListenerResponse.java
@@ -30,7 +30,7 @@ import org.apache.geode.distributed.internal.membership.*;
*
* @since GemFire 3.5
*/
-public final class AddHealthListenerResponse extends AdminResponse {
+public class AddHealthListenerResponse extends AdminResponse {
// instance variables
int listenerId;
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AddStatListenerRequest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AddStatListenerRequest.java b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AddStatListenerRequest.java
index 703ae6a..a911263 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AddStatListenerRequest.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AddStatListenerRequest.java
@@ -28,7 +28,7 @@ import java.io.*;
/**
* A message that is sent to a particular distribution manager to add a statistic listener.
*/
-public final class AddStatListenerRequest extends AdminRequest {
+public class AddStatListenerRequest extends AdminRequest {
// instance variables
private long resourceId;
private String statName;
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AddStatListenerResponse.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AddStatListenerResponse.java b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AddStatListenerResponse.java
index b88772f..f5d708e 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AddStatListenerResponse.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AddStatListenerResponse.java
@@ -28,7 +28,7 @@ import org.apache.geode.internal.statistics.GemFireStatSampler;
* A message that is sent to a particular distribution manager to get its current
* <code>RemoteAddStatListener</code>.
*/
-public final class AddStatListenerResponse extends AdminResponse {
+public class AddStatListenerResponse extends AdminResponse {
// instance variables
int listenerId;
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AdminConsoleDisconnectMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AdminConsoleDisconnectMessage.java b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AdminConsoleDisconnectMessage.java
index 8452929..dd9b793 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AdminConsoleDisconnectMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AdminConsoleDisconnectMessage.java
@@ -36,7 +36,7 @@ import org.apache.geode.internal.logging.log4j.LocalizedMessage;
* A message that is sent to a particular distribution manager to let it know that the sender is an
* administation console that just disconnected.
*/
-public final class AdminConsoleDisconnectMessage extends PooledDistributionMessage {
+public class AdminConsoleDisconnectMessage extends PooledDistributionMessage {
private static final Logger logger = LogService.getLogger();
// instance variables
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AdminConsoleMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AdminConsoleMessage.java b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AdminConsoleMessage.java
index fa07560..d8c9665 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AdminConsoleMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AdminConsoleMessage.java
@@ -34,7 +34,7 @@ import org.apache.geode.internal.logging.log4j.LogWriterLogger;
* A message that is sent to a particular distribution manager to let it know that the sender is an
* administation console that just connected.
*/
-public final class AdminConsoleMessage extends PooledDistributionMessage {
+public class AdminConsoleMessage extends PooledDistributionMessage {
// instance variables
int level;
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AdminFailureResponse.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AdminFailureResponse.java b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AdminFailureResponse.java
index 002d7d7..d201575 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AdminFailureResponse.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AdminFailureResponse.java
@@ -26,7 +26,7 @@ import org.apache.geode.distributed.internal.membership.*;
/**
* A response to a failed request.
*/
-public final class AdminFailureResponse extends AdminResponse {
+public class AdminFailureResponse extends AdminResponse {
// instance variables
Exception cause;
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AlertLevelChangeMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AlertLevelChangeMessage.java b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AlertLevelChangeMessage.java
index c3a293f..25f1eb1 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AlertLevelChangeMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AlertLevelChangeMessage.java
@@ -37,7 +37,7 @@ import org.apache.geode.internal.logging.log4j.LogMarker;
*
* @since GemFire 3.5
*/
-public final class AlertLevelChangeMessage extends SerialDistributionMessage {
+public class AlertLevelChangeMessage extends SerialDistributionMessage {
private static final Logger logger = LogService.getLogger();
http://git-wip-us.apache.org/repos/asf/geode/blob/3b867342/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AlertListenerMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AlertListenerMessage.java b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AlertListenerMessage.java
index 4f0e9ce..9f0e4bf 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AlertListenerMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/AlertListenerMessage.java
@@ -30,8 +30,7 @@ import org.apache.geode.distributed.internal.membership.*;
/**
* A message that is sent to a particular console distribution manager to notify it of an alert.
*/
-public final class AlertListenerMessage extends PooledDistributionMessage
- implements AdminMessageType {
+public class AlertListenerMessage extends PooledDistributionMessage implements AdminMessageType {
// instance variables
private int msgLevel;
private Date msgDate;