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 2019/01/11 23:54:25 UTC
[geode] branch develop updated (1909935 -> 9d737c9)
This is an automated email from the ASF dual-hosted git repository.
klund pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/geode.git.
from 1909935 GEODE-6261: Do not break repeatable read by incorrectly cleaning up TXEntries (#3062)
add 9d737c9 GEODE-4391: Add `@Override` where missing. (#3069)
No new revisions were added by this update.
Summary of changes:
.../dockerizedtest/DockerizedExecHandle.java | 14 +
.../dockerizedtest/DockerizedExecHandleRunner.java | 1 +
.../plugins/dockerizedtest/TestExecuter.java | 3 +
.../geode/gradle/OverriddenTestExecutor.java | 2 +
.../internal/filter/DummySessionManager.java | 2 +
.../internal/filter/GemfireSessionManager.java | 2 +
.../session/internal/filter/MyServletTester.java | 2 +
.../ServletRequestAttributeListenerImpl.java | 3 +
.../filter/ServletRequestListenerImpl.java | 2 +
.../filter/SessionReplicationJUnitTest.java | 1 +
.../SessionReplicationLocalCacheJUnitTest.java | 1 +
.../modules/session/filter/SessionListener.java | 2 +
.../session/installer/args/URLArgumentHandler.java | 1 +
.../catalina/Tomcat7DeltaSessionManager.java | 1 +
.../gatewaydelta/AbstractGatewayDeltaEvent.java | 2 +
.../gatewaydelta/GatewayDeltaCreateEvent.java | 3 +
.../gatewaydelta/GatewayDeltaDestroyEvent.java | 3 +
.../GatewayDeltaEventApplicationCacheListener.java | 2 +
.../GatewayDeltaForwarderCacheListener.java | 4 +
.../session/catalina/AbstractSessionCache.java | 2 +
.../session/catalina/ClientServerSessionCache.java | 1 +
.../modules/session/catalina/DeltaSession.java | 23 ++
.../session/catalina/DeltaSessionInterface.java | 1 +
.../session/catalina/DeltaSessionManager.java | 1 +
.../catalina/callback/LocalSessionCacheLoader.java | 3 +
.../catalina/callback/LocalSessionCacheWriter.java | 5 +
.../callback/SessionExpirationCacheListener.java | 2 +
.../internal/DeltaSessionAttributeEventBatch.java | 3 +
.../DeltaSessionDestroyAttributeEvent.java | 3 +
.../internal/DeltaSessionUpdateAttributeEvent.java | 4 +
.../geode/modules/util/CreateRegionFunction.java | 6 +
.../geode/modules/util/DebugCacheListener.java | 5 +
.../geode/modules/util/RegionConfiguration.java | 3 +
.../util/RegionConfigurationCacheListener.java | 3 +
.../geode/modules/util/RegionSizeFunction.java | 5 +
.../geode/modules/util/SessionCustomExpiry.java | 3 +
.../TouchPartitionedRegionEntriesFunction.java | 6 +
.../util/TouchReplicatedRegionEntriesFunction.java | 6 +
.../web/controllers/AddFreeItemToOrders.java | 2 +
.../web/controllers/GetDeliveredOrders.java | 2 +
.../rest/internal/web/controllers/GetRegions.java | 2 +
.../internal/web/controllers/PutKeyFunction.java | 5 +
.../tools/pulse/ui/PulseAcceptanceAuthTest.java | 1 +
.../tools/pulse/ui/PulseAcceptanceNoAuthTest.java | 1 +
.../junit/rules/SqlDatabaseConnectionRule.java | 1 +
.../geode/cache/ClientServerTimeSyncDUnitTest.java | 4 +
.../cache/ConnectionPoolAndLoaderDUnitTest.java | 17 +
.../geode/cache/ConnectionPoolAutoDUnitTest.java | 2 +
.../geode/cache/ConnectionPoolDUnitTest.java | 365 +++++++++++++++++++++
.../internal/LocatorLoadBalancingDUnitTest.java | 1 +
.../management/MemoryThresholdsDUnitTest.java | 102 ++++++
.../MemoryThresholdsOffHeapDUnitTest.java | 69 ++++
.../cache/management/ResourceManagerDUnitTest.java | 48 +++
.../partition/PartitionRegionHelperDUnitTest.java | 19 ++
.../query/dunit/CompactRangeIndexDUnitTest.java | 9 +
.../cache/query/dunit/CompiledInDUnitTest.java | 27 ++
.../query/dunit/CorruptedIndexIntegrationTest.java | 2 +
.../cache/query/dunit/CqTimeTestListener.java | 13 +
.../geode/cache/query/dunit/GroupByDUnitImpl.java | 3 +
.../dunit/GroupByPartitionedQueryDUnitTest.java | 2 +
.../cache/query/dunit/GroupByQueryDUnitTest.java | 7 +
.../cache/query/dunit/HashIndexDUnitTest.java | 5 +
.../query/dunit/NonDistinctOrderByDUnitImpl.java | 3 +
.../NonDistinctOrderByPartitionedDUnitTest.java | 2 +
.../query/dunit/OrderByPartitionedDUnitTest.java | 5 +
.../geode/cache/query/dunit/PDXQueryTestBase.java | 8 +
...artitionedRegionCompactRangeIndexDUnitTest.java | 1 +
.../dunit/PdxGroupByPartitionedQueryDUnitTest.java | 2 +
.../cache/query/dunit/PdxLocalQueryDUnitTest.java | 3 +
.../geode/cache/query/dunit/PdxQueryDUnitTest.java | 109 ++++++
.../cache/query/dunit/PdxStringQueryDUnitTest.java | 60 ++++
.../cache/query/dunit/PositionPdxVersion.java | 3 +
.../dunit/QueryDataInconsistencyDUnitTest.java | 1 +
.../cache/query/dunit/QueryIndexDUnitTest.java | 7 +
.../dunit/QueryUsingFunctionContextDUnitTest.java | 1 +
.../cache/query/dunit/QueryUsingPoolDUnitTest.java | 8 +
.../cache/query/dunit/RemoteQueryDUnitTest.java | 54 +++
.../ResourceManagerWithQueryMonitorDUnitTest.java | 25 ++
.../query/dunit/SelectStarQueryDUnitTest.java | 1 +
...ncurrentIndexInitOnOverflowRegionDUnitTest.java | 1 +
...ntIndexOperationsOnOverflowRegionDUnitTest.java | 2 +
.../internal/index/CopyOnReadIndexDUnitTest.java | 24 ++
.../index/IndexTrackingQueryObserverDUnitTest.java | 11 +
.../index/MultiIndexCreationDUnitTest.java | 4 +
.../index/PutAllWithIndexPerfDUnitTest.java | 2 +
.../query/partitioned/PRQueryDUnitHelper.java | 8 +
.../apache/geode/cache30/CacheCloseDUnitTest.java | 2 +
.../geode/cache30/CacheListenerTestCase.java | 17 +
.../apache/geode/cache30/CacheLoaderTestCase.java | 8 +
.../CacheRegionsReliablityStatsCheckDUnitTest.java | 1 +
.../geode/cache30/CacheStatisticsDUnitTest.java | 10 +
.../apache/geode/cache30/CacheWriterTestCase.java | 14 +
.../geode/cache30/CacheXMLPartitionResolver.java | 5 +
.../apache/geode/cache30/CacheXml66DUnitTest.java | 11 +
.../geode/cache30/CacheXmlGeode10DUnitTest.java | 1 +
.../geode/cache30/CachedAllEventsDUnitTest.java | 1 +
.../apache/geode/cache30/CallbackArgDUnitTest.java | 6 +
.../geode/cache30/ClearMultiVmCallBkDUnitTest.java | 1 +
.../geode/cache30/ClearMultiVmDUnitTest.java | 12 +
.../geode/cache30/ClientMembershipDUnitTest.java | 34 ++
.../cache30/ClientRegisterInterestDUnitTest.java | 21 ++
.../geode/cache30/ClientServerCCEDUnitTest.java | 25 ++
.../cache30/ConcurrentLeaveDuringGIIDUnitTest.java | 14 +
...stributedNoAckAsyncOverflowRegionDUnitTest.java | 1 +
.../DiskDistributedNoAckAsyncRegionDUnitTest.java | 1 +
...istributedNoAckSyncOverflowRegionDUnitTest.java | 1 +
.../apache/geode/cache30/DiskRegionTestImpl.java | 5 +
.../geode/cache30/DistAckMapMethodsDUnitTest.java | 4 +
.../cache30/DistributedAckRegionCCEDUnitTest.java | 9 +
.../cache30/DistributedAckRegionDUnitTest.java | 5 +
.../DistributedMulticastRegionDUnitTest.java | 6 +
.../DistributedNoAckRegionCCEDUnitTest.java | 5 +
.../cache30/DistributedNoAckRegionDUnitTest.java | 11 +
.../geode/cache30/DynamicRegionDUnitTest.java | 5 +
.../geode/cache30/GlobalLockingDUnitTest.java | 16 +
.../geode/cache30/GlobalRegionCCEDUnitTest.java | 4 +
.../geode/cache30/GlobalRegionDUnitTest.java | 18 +
.../cache30/LRUEvictionControllerDUnitTest.java | 8 +
.../apache/geode/cache30/LocalRegionDUnitTest.java | 7 +
.../cache30/MemLRUEvictionControllerDUnitTest.java | 1 +
.../geode/cache30/PartitionedRegionDUnitTest.java | 13 +
...rtitionedRegionMembershipListenerDUnitTest.java | 3 +
.../org/apache/geode/cache30/ProxyDUnitTest.java | 41 +++
.../cache30/PutAllCallBkRemoteVMDUnitTest.java | 10 +
.../cache30/PutAllCallBkSingleVMDUnitTest.java | 6 +
.../geode/cache30/PutAllMultiVmDUnitTest.java | 11 +
.../apache/geode/cache30/QueueMsgDUnitTest.java | 13 +
.../apache/geode/cache30/ReconnectDUnitTest.java | 46 +++
.../geode/cache30/RegionAttributesTestCase.java | 6 +
.../cache30/RegionMembershipListenerDUnitTest.java | 12 +
.../cache30/RegionReliabilityDistAckDUnitTest.java | 1 +
.../RegionReliabilityDistNoAckDUnitTest.java | 1 +
.../cache30/RegionReliabilityGlobalDUnitTest.java | 1 +
.../RegionReliabilityListenerDUnitTest.java | 5 +
.../geode/cache30/RegionReliabilityTestCase.java | 38 +++
.../geode/cache30/RemoveAllMultiVmDUnitTest.java | 9 +
.../geode/cache30/RequiredRolesDUnitTest.java | 12 +
.../geode/cache30/SearchAndLoadDUnitTest.java | 65 ++++
.../org/apache/geode/cache30/SlowRecDUnitTest.java | 48 +++
.../geode/cache30/TXDistributedDUnitTest.java | 58 ++++
.../org/apache/geode/cache30/TXOrderDUnitTest.java | 19 ++
.../geode/cache30/TXRestrictionsDUnitTest.java | 1 +
.../apache/geode/cache30/TestPdxSerializer.java | 4 +
.../geode/cache30/TestTransactionListener.java | 3 +
.../geode/cache30/TestTransactionWriter.java | 3 +
.../apache/geode/distributed/AuthInitializer.java | 3 +
.../DistributedLockServiceDUnitTest.java | 53 +++
.../distributed/DistributedMemberDUnitTest.java | 8 +
.../apache/geode/distributed/LocatorDUnitTest.java | 9 +
.../apache/geode/distributed/MyAuthenticator.java | 3 +
.../org/apache/geode/distributed/MyPrincipal.java | 1 +
.../apache/geode/distributed/RoleDUnitTest.java | 2 +
...lusterDistributionManagerForAdminDUnitTest.java | 1 +
.../geode/distributed/internal/DateMessage.java | 5 +
.../internal/DistributionAdvisorDUnitTest.java | 1 +
.../org/apache/geode/distributed/internal/LDM.java | 1 +
.../internal/ProductUseLogDUnitTest.java | 3 +
.../deadlock/GemFireDeadlockDetectorDUnitTest.java | 9 +
.../streaming/StreamingOperationManyDUnitTest.java | 4 +
.../streaming/StreamingOperationOneDUnitTest.java | 4 +
.../apache/geode/disttx/DistTXDebugDUnitTest.java | 5 +
.../disttx/DistributedTransactionDUnitTest.java | 5 +
.../org/apache/geode/disttx/PRDistTXDUnitTest.java | 10 +
.../disttx/PRDistTXWithVersionsDUnitTest.java | 4 +
.../internal/ClassNotFoundExceptionDUnitTest.java | 11 +
.../geode/internal/PdxDeleteFieldDUnitTest.java | 7 +
.../apache/geode/internal/PdxRenameDUnitTest.java | 7 +
.../internal/cache/ARMLockTestHookAdapter.java | 9 +
.../internal/cache/CacheAdvisorDUnitTest.java | 12 +
.../geode/internal/cache/ClearDAckDUnitTest.java | 2 +
.../geode/internal/cache/ClearGlobalDUnitTest.java | 2 +
.../internal/cache/ClearRvvLockingDUnitTest.java | 4 +
.../internal/cache/ClearTXLockingDUnitTest.java | 1 +
.../cache/ClientServerGetAllDUnitTest.java | 4 +
...entServerInvalidAndDestroyedEntryDUnitTest.java | 5 +
.../cache/ClientServerTransactionCCEDUnitTest.java | 2 +
.../cache/ClientServerTransactionDUnitTest.java | 140 ++++++++
.../cache/ConcurrentDestroySubRegionDUnitTest.java | 6 +
.../internal/cache/ConcurrentMapOpsDUnitTest.java | 65 ++++
.../internal/cache/DeltaFaultInDUnitTest.java | 4 +
.../internal/cache/DeltaPropagationDUnitTest.java | 20 ++
.../cache/DeltaPropagationStatsDUnitTest.java | 4 +
.../geode/internal/cache/DeltaSizingDUnitTest.java | 7 +
.../internal/cache/DiskRegByteArrayDUnitTest.java | 1 +
.../internal/cache/DistributedCacheTestCase.java | 2 +
.../internal/cache/FixedPRSinglehopDUnitTest.java | 4 +
.../geode/internal/cache/GIIDeltaDUnitTest.java | 65 ++++
.../internal/cache/GIIFlowControlDUnitTest.java | 30 ++
.../geode/internal/cache/IteratorDUnitTest.java | 3 +
.../geode/internal/cache/MapClearGIIDUnitTest.java | 9 +
.../cache/NetSearchMessagingDUnitTest.java | 12 +
.../cache/P2PDeltaPropagationDUnitTest.java | 1 +
.../geode/internal/cache/PRBadToDataDUnitTest.java | 5 +
.../internal/cache/PartitionListenerDUnitTest.java | 14 +
.../PartitionedRegionDelayedRecoveryDUnitTest.java | 13 +
.../PartitionedRegionEntryCountDUnitTest.java | 5 +
.../cache/PartitionedRegionEvictionDUnitTest.java | 55 ++++
.../PartitionedRegionInvalidateDUnitTest.java | 6 +
.../PartitionedRegionRedundancyZoneDUnitTest.java | 5 +
.../cache/PartitionedRegionSingleHopDUnitTest.java | 10 +
...nedRegionSingleHopWithServerGroupDUnitTest.java | 7 +
.../geode/internal/cache/PutAllDAckDUnitTest.java | 2 +
.../internal/cache/PutAllGlobalDUnitTest.java | 3 +
.../internal/cache/RemoveAllDAckDUnitTest.java | 2 +
.../geode/internal/cache/RemoveDAckDUnitTest.java | 1 +
.../internal/cache/RemoveGlobalDUnitTest.java | 10 +
.../geode/internal/cache/SizingFlagDUnitTest.java | 20 ++
.../internal/cache/SystemFailureDUnitTest.java | 16 +
.../org/apache/geode/internal/cache/TestDelta.java | 5 +
.../geode/internal/cache/TestObjectSizerImpl.java | 1 +
.../cache/TransactionsWithDeltaDUnitTest.java | 14 +
.../cache/control/RebalanceOperationDUnitTest.java | 119 +++++++
.../cache/event/EventTrackerDUnitTest.java | 15 +
.../ClientServerFunctionExecutionDUnitTest.java | 18 +
.../cache/execute/ColocationFailoverDUnitTest.java | 10 +
.../cache/execute/CustomResultCollector.java | 5 +
.../execute/FunctionServiceStatsDUnitTest.java | 34 ++
.../cache/execute/LocalDataSetDUnitTest.java | 14 +
.../execute/LocalDataSetIndexingDUnitTest.java | 7 +
.../execute/LocalFunctionExecutionDUnitTest.java | 1 +
.../MultiRegionFunctionExecutionDUnitTest.java | 1 +
...UserAuthenticationFunctionServiceDUnitTest.java | 1 +
.../cache/execute/MyTransactionFunction.java | 5 +
...ientServerRegionFunctionExecutionDUnitTest.java | 12 +
...egionFunctionExecutionNoSingleHopDUnitTest.java | 23 ++
...ctionExecutionSelectorNoSingleHopDUnitTest.java | 23 ++
...rRegionFunctionExecutionSingleHopDUnitTest.java | 2 +
.../cache/execute/PRColocationDUnitTest.java | 25 ++
.../cache/execute/PRSetOperationJTADUnitTest.java | 10 +
.../geode/internal/cache/execute/PerfFunction.java | 5 +
.../internal/cache/execute/PerfTxFunction.java | 5 +
...dRegionFunctionFunctionInvocationException.java | 3 +
.../cache/functions/LocalDataSetFunction.java | 5 +
.../cache/ha/EventIdOptimizationDUnitTest.java | 4 +
.../geode/internal/cache/ha/FailoverDUnitTest.java | 8 +
.../internal/cache/ha/HABugInPutDUnitTest.java | 1 +
.../geode/internal/cache/ha/HAClearDUnitTest.java | 15 +
.../internal/cache/ha/HAConflationDUnitTest.java | 17 +
.../internal/cache/ha/HADuplicateDUnitTest.java | 7 +
.../cache/ha/HAEventIdPropagationDUnitTest.java | 3 +
.../geode/internal/cache/ha/HAExpiryDUnitTest.java | 8 +
.../geode/internal/cache/ha/HAGIIBugDUnitTest.java | 7 +
.../geode/internal/cache/ha/HAGIIDUnitTest.java | 18 +
.../cache/ha/HARQueueNewImplDUnitTest.java | 3 +
.../cache/ha/OperationsPropagationDUnitTest.java | 20 ++
.../geode/internal/cache/ha/PutAllDUnitTest.java | 3 +
.../cache/locks/TXLockServiceDUnitTest.java | 20 ++
.../internal/cache/partitioned/MockAppender.java | 1 +
.../partitioned/PartitionResolverDUnitTest.java | 15 +
.../PartitionedRegionLoaderWriterDUnitTest.java | 2 +
.../PartitionedRegionMetaDataCleanupDUnitTest.java | 5 +
...sistentColocatedPartitionedRegionDUnitTest.java | 42 +++
...tPartitionedRegionWithTransactionDUnitTest.java | 5 +
.../cache/partitioned/ShutdownAllDUnitTest.java | 15 +
.../StreamingPartitionOperationManyDUnitTest.java | 6 +
.../StreamingPartitionOperationOneDUnitTest.java | 5 +
.../fixed/CustomerFixedPartitionResolver.java | 6 +
.../fixed/FixedPartitioningTestBase.java | 1 +
.../internal/cache/partitioned/fixed/MyDate1.java | 4 +
.../internal/cache/partitioned/fixed/MyDate2.java | 3 +
.../internal/cache/partitioned/fixed/MyDate3.java | 4 +
.../fixed/QuarterPartitionResolver.java | 8 +
.../fixed/SingleHopQuarterPartitionResolver.java | 8 +
.../PersistentRVVRecoveryDUnitTest.java | 10 +
.../persistence/PersistentReplicatedTestBase.java | 9 +
.../sockets/CacheServerTransactionsDUnitTest.java | 19 ++
.../CacheServerTransactionsSelectorDUnitTest.java | 1 +
.../tier/sockets/ClearPropagationDUnitTest.java | 6 +
.../tier/sockets/ClientConflationDUnitTest.java | 13 +
.../sockets/ClientInterestNotifyDUnitTest.java | 6 +
.../sockets/ClientServerMiscSelectorDUnitTest.java | 1 +
.../cache/tier/sockets/ConflationDUnitTest.java | 22 ++
.../cache/tier/sockets/DeltaEOFException.java | 2 +
.../sockets/DestroyEntryPropagationDUnitTest.java | 8 +
.../sockets/DurableClientBug39997DUnitTest.java | 6 +
.../tier/sockets/DurableRegistrationDUnitTest.java | 11 +
.../sockets/DurableResponseMatrixDUnitTest.java | 3 +
.../tier/sockets/EventIDVerificationDUnitTest.java | 10 +
.../sockets/EventIDVerificationInP2PDUnitTest.java | 5 +
.../internal/cache/tier/sockets/FaultyDelta.java | 5 +
.../sockets/ForceInvalidateEvictionDUnitTest.java | 15 +
.../cache/tier/sockets/HAInterestTestCase.java | 6 +
.../sockets/HAStartupAndFailoverDUnitTest.java | 11 +
.../sockets/InstantiatorPropagationDUnitTest.java | 97 ++++++
.../cache/tier/sockets/InterestListDUnitTest.java | 1 +
.../sockets/InterestListEndpointDUnitTest.java | 6 +
.../sockets/InterestListEndpointPRDUnitTest.java | 1 +
.../InterestListEndpointSelectorDUnitTest.java | 1 +
.../sockets/InterestListFailoverDUnitTest.java | 2 +
.../sockets/InterestListRecoveryDUnitTest.java | 8 +
.../sockets/RedundancyLevelPart3DUnitTest.java | 3 +
.../tier/sockets/RedundancyLevelTestBase.java | 1 +
.../cache/tier/sockets/RegionCloseDUnitTest.java | 8 +
...isterInterestBeforeRegionCreationDUnitTest.java | 5 +
.../sockets/RegisterInterestKeysPRDUnitTest.java | 1 +
.../tier/sockets/ReliableMessagingDUnitTest.java | 3 +
.../tier/sockets/UpdatePropagationDUnitTest.java | 2 +
.../VerifyEventIDGenerationInP2PDUnitTest.java | 1 +
.../cache/tx/SetOperationJTADistributedTest.java | 10 +
.../CompressionCacheListenerDUnitTest.java | 2 +
.../compression/CompressionStatsDUnitTest.java | 2 +
.../geode/internal/jta/dunit/CommitThread.java | 1 +
.../internal/jta/dunit/LoginTimeOutDUnitTest.java | 4 +
.../geode/internal/jta/dunit/RollbackThread.java | 1 +
.../offheap/OutOfOffHeapMemoryDUnitTest.java | 6 +
.../commands/ExecuteFunctionCommandDUnitTest.java | 1 +
.../internal/pulse/TestFunctionsDUnitTest.java | 2 +
.../pdx/ClientsWithVersioningRetryDUnitTest.java | 11 +
.../geode/pdx/DistributedSystemIdDUnitTest.java | 3 +
.../geode/pdx/JSONPdxClientServerDUnitTest.java | 14 +
.../geode/pdx/PDXAsyncEventQueueDUnitTest.java | 5 +
.../apache/geode/pdx/PdxClientServerDUnitTest.java | 17 +
.../geode/pdx/PdxDeserializationDUnitTest.java | 15 +
.../apache/geode/pdx/PdxSerializableDUnitTest.java | 8 +
.../security/ClientAuthenticationTestCase.java | 1 +
.../security/query/IndexSecurityDUnitTest.java | 1 +
.../query/PartitionedIndexSecurityDUnitTest.java | 1 +
...tionedQuerySecurityAllowedQueriesDUnitTest.java | 1 +
...rictedButMethodsDoNotExistQueriesDUnitTest.java | 1 +
...nedQuerySecurityRestrictedQueriesDUnitTest.java | 1 +
...tionedQuerySecurityAllowedQueriesDUnitTest.java | 1 +
.../QuerySecurityDistinctQueryDistributedTest.java | 1 +
.../java/org/apache/geode/CopyJUnitTest.java | 25 ++
.../apache/geode/DiskInstantiatorsJUnitTest.java | 6 +
.../java/org/apache/geode/TXJUnitTest.java | 2 +
.../java/org/apache/geode/TXWriterJUnitTest.java | 8 +
.../org/apache/geode/TXWriterOOMEJUnitTest.java | 2 +
.../internal/CacheHealthEvaluatorJUnitTest.java | 6 +
.../apache/geode/cache/CacheListenerJUnitTest.java | 10 +
.../org/apache/geode/cache/ProxyJUnitTest.java | 36 ++
.../apache/geode/cache/RegionFactoryJUnitTest.java | 4 +
.../cache/client/ClientRegionFactoryJUnitTest.java | 2 +
.../AutoConnectionSourceImplJUnitTest.java | 61 ++++
.../internal/ConnectionPoolImplJUnitTest.java | 3 +
.../client/internal/QueueManagerJUnitTest.java | 58 ++++
.../pooling/ConnectionManagerJUnitTest.java | 32 ++
.../mapInterface/PutAllGlobalLockJUnitTest.java | 2 +
.../apache/geode/cache/query/QueryJUnitTest.java | 1 +
.../QueryWithBucketParameterIntegrationTest.java | 3 +
.../functional/CustomerOptimizationsJUnitTest.java | 80 +++++
.../query/functional/IUM6Bug32345ReJUnitTest.java | 2 +
.../geode/cache/query/functional/IUMJUnitTest.java | 2 +
.../functional/IUMRCompositeIteratorJUnitTest.java | 2 +
.../functional/IUMRSingleRegionJUnitTest.java | 2 +
...IndependentOperandsInWhereClause2JUnitTest.java | 2 +
.../query/functional/IndexCreationJUnitTest.java | 2 +
.../IndexMaintenanceAsynchJUnitTest.java | 4 +
.../query/functional/IndexOnEntrySetJUnitTest.java | 4 +
.../functional/IndexPrimaryKeyUsageJUnitTest.java | 2 +
.../IndexUsageInNestedQueryJUnitTest.java | 2 +
.../IndexUseMultFrmSnglCondJUnitTest.java | 2 +
.../IndexWithSngleFrmAndMultCondQryJUnitTest.java | 3 +
.../functional/IumMultConditionJUnitTest.java | 2 +
.../query/functional/LimitClauseJUnitTest.java | 14 +
.../functional/MultiIndexCreationJUnitTest.java | 10 +
.../functional/MultiRegionIndexUsageJUnitTest.java | 2 +
.../query/functional/NumericQueryJUnitTest.java | 1 +
.../functional/OrderByReplicatedJUnitTest.java | 4 +
.../TestNewFunctionSSorRSIntegrationTest.java | 2 +
.../query/internal/ExecutionContextJUnitTest.java | 1 +
.../QueryFromClauseCanonicalizationJUnitTest.java | 1 +
.../index/AsynchIndexMaintenanceJUnitTest.java | 9 +
.../internal/index/CompactRangeIndexJUnitTest.java | 4 +
.../internal/index/EquiJoinIntegrationTest.java | 8 +
.../index/IndexCreationInternalsJUnitTest.java | 2 +
.../query/internal/index/IndexHintJUnitTest.java | 2 +
.../internal/index/IndexMaintainceJUnitTest.java | 4 +
.../internal/index/IndexStatisticsJUnitTest.java | 1 +
.../IndexedMergeEquiJoinScenariosJUnitTest.java | 2 +
.../internal/index/MapIndexStoreJUnitTest.java | 1 +
.../PartitionedRegionEquiJoinIntegrationTest.java | 1 +
.../QueryOnCompressedRegionWithIndexTest.java | 1 +
.../partitioned/PRQueryCacheClosedJUnitTest.java | 2 +
.../partitioned/PRQueryRegionClosedJUnitTest.java | 2 +
.../PRQueryRegionDestroyedJUnitTest.java | 2 +
.../query/transaction/QueryAndJtaJUnitTest.java | 4 +
.../cache/snapshot/RegionSnapshotJUnitTest.java | 1 +
.../geode/cache/snapshot/WanSnapshotJUnitTest.java | 1 +
.../geode/cache30/DiskRegionIntegrationTest.java | 5 +
.../AnalyzeSerializablesJUnitTest.java | 1 +
.../LocatorLauncherRemoteIntegrationTestCase.java | 1 +
.../ServerLauncherRemoteIntegrationTestCase.java | 1 +
.../LocatorLoadSnapshotIntegrationTest.java | 1 +
.../deadlock/DeadlockDetectorIntegrationTest.java | 6 +
.../internal/tcpserver/TcpServerJUnitTest.java | 17 +
...edThreadPoolExecutorWithKeepAliveJUnitTest.java | 12 +
...urrentFlushingAndRegionOperationsJUnitTest.java | 9 +
.../cache/ConcurrentRegionOperationsJUnitTest.java | 9 +
...currentRollingAndRegionOperationsJUnitTest.java | 19 ++
.../DiskRandomOperationsAndRecoveryJUnitTest.java | 2 +
.../internal/cache/DiskRegCbkChkJUnitTest.java | 6 +
.../DiskRegOplogSwtchingAndRollerJUnitTest.java | 11 +
.../internal/cache/DiskRegRecoveryJUnitTest.java | 2 +
.../geode/internal/cache/FaultingInJUnitTest.java | 2 +
.../internal/cache/MapInterface2JUnitTest.java | 5 +
.../MultipleOplogsRollingFeatureJUnitTest.java | 2 +
.../cache/PartitionedRegionCreationJUnitTest.java | 1 +
...itionedRegionSingleNodeOperationsJUnitTest.java | 6 +
.../internal/cache/SimpleDiskRegionJUnitTest.java | 1 +
.../internal/cache/TXManagerImplJUnitTest.java | 9 +
.../internal/cache/TXReservationMgrJUnitTest.java | 1 +
.../cache/control/MemoryMonitorJUnitTest.java | 1 +
...skRegionOverflowAsyncRollingOpLogJUnitTest.java | 3 +
...iskRegionOverflowSyncRollingOpLogJUnitTest.java | 3 +
.../DiskRegionRollOpLogJUnitPerformanceTest.java | 1 +
.../MultiThreadedOplogPerJUnitPerformanceTest.java | 1 +
.../ha/BlockingHARQAddOperationJUnitTest.java | 4 +
.../cache/ha/BlockingHARQStatsJUnitTest.java | 2 +
.../cache/ha/BlockingHARegionJUnitTest.java | 11 +
.../cache/ha/HARQAddOperationJUnitTest.java | 13 +
.../geode/internal/cache/ha/HARegionJUnitTest.java | 1 +
.../CacheServerMaxConnectionsJUnitTest.java | 4 +
...CacheServerSelectorMaxConnectionsJUnitTest.java | 1 +
...ClientHealthMonitorSelectorIntegrationTest.java | 1 +
.../tier/sockets/ConnectionProxyJUnitTest.java | 11 +
.../sockets/FilterProfileIntegrationJUnitTest.java | 3 +
...elGatewaySenderFlushedCoordinatorJUnitTest.java | 2 +
.../datasource/ConnectionPoolingJUnitTest.java | 3 +
.../internal/jta/SetOperationJTAJUnitTest.java | 10 +
.../jta/TransactionManagerImplJUnitTest.java | 24 ++
.../internal/jta/functional/CacheJUnitTest.java | 2 +
.../net/ClientSocketFactoryIntegrationTest.java | 1 +
.../internal/net/SSLSocketIntegrationTest.java | 1 +
.../geode/internal/offheap/OffHeapRegionBase.java | 2 +
.../statistics/FileSizeLimitIntegrationTest.java | 2 +
.../GemFireStatSamplerIntegrationTest.java | 2 +
.../SimpleStatSamplerIntegrationTest.java | 2 +
.../statistics/StatSamplerIntegrationTest.java | 2 +
.../internal/stats50/AtomicStatsJUnitTest.java | 2 +
.../concurrent/cm/CountedMapLoopsJUnitTest.java | 1 +
.../util/concurrent/cm/MapLoopsJUnitTest.java | 1 +
.../util/concurrent/cm/RLJBarJUnitTest.java | 1 +
.../concurrent/cm/StringMapLoopsJUnitTest.java | 1 +
.../bean/stats/AsyncEventQueueStatsJUnitTest.java | 1 +
.../bean/stats/CacheServerStatsJUnitTest.java | 1 +
.../management/bean/stats/DiskStatsJUnitTest.java | 1 +
.../bean/stats/GatewayMBeanBridgeJUnitTest.java | 1 +
.../bean/stats/GatewayReceiverStatsJUnitTest.java | 1 +
.../bean/stats/MemberLevelStatsJUnitTest.java | 1 +
.../bean/stats/RegionStatsJUnitTest.java | 1 +
...urityServiceWithCustomRealmIntegrationTest.java | 1 +
.../geode/pdx/AutoSerializableJUnitTest.java | 3 +
.../geode/pdx/PdxInstanceFactoryJUnitTest.java | 4 +
.../org/apache/geode/pdx/PdxInstanceJUnitTest.java | 9 +
.../apache/geode/pdx/PdxSerializableJUnitTest.java | 16 +
.../geode/internal/ra/GFConnectionFactoryImpl.java | 3 +
.../apache/geode/internal/ra/GFConnectionImpl.java | 3 +
.../ra/spi/JCAManagedConnectionFactory.java | 6 +
.../ra/spi/JCAManagedConnectionMetaData.java | 4 +
.../org/apache/geode/admin/CacheServerConfig.java | 4 +
.../geode/admin/RegionSubRegionSnapshot.java | 2 +
.../admin/internal/AdminDistributedSystemImpl.java | 60 ++++
.../admin/internal/CacheHealthConfigImpl.java | 8 +
.../admin/internal/CacheServerConfigImpl.java | 4 +
.../geode/admin/internal/CacheServerImpl.java | 12 +
.../admin/internal/ConfigurationParameterImpl.java | 12 +
.../internal/DistributedSystemConfigImpl.java | 68 ++++
.../DistributedSystemHealthConfigImpl.java | 2 +
.../internal/DistributedSystemHealthEvaluator.java | 3 +
.../internal/DistributedSystemHealthMonitor.java | 43 +++
.../internal/DistributionLocatorConfigImpl.java | 6 +
.../admin/internal/DistributionLocatorImpl.java | 16 +
.../internal/EnabledManagedEntityController.java | 6 +
.../admin/internal/GemFireHealthConfigImpl.java | 3 +
.../geode/admin/internal/GemFireHealthImpl.java | 15 +
.../admin/internal/ManagedEntityConfigImpl.java | 9 +
.../admin/internal/ManagedEntityConfigXml.java | 4 +
.../internal/ManagedEntityConfigXmlGenerator.java | 14 +
.../internal/ManagedEntityConfigXmlParser.java | 11 +
.../admin/internal/ManagedSystemMemberImpl.java | 3 +
.../admin/internal/MemberHealthConfigImpl.java | 8 +
.../apache/geode/admin/internal/StatisticImpl.java | 5 +
.../admin/internal/StatisticResourceImpl.java | 7 +
.../internal/SystemMemberBridgeServerImpl.java | 30 ++
.../admin/internal/SystemMemberCacheEventImpl.java | 1 +
.../internal/SystemMemberCacheEventProcessor.java | 1 +
.../admin/internal/SystemMemberCacheImpl.java | 19 ++
.../geode/admin/internal/SystemMemberImpl.java | 19 ++
.../internal/SystemMemberRegionEventImpl.java | 1 +
.../admin/internal/SystemMemberRegionImpl.java | 46 +++
.../admin/internal/SystemMembershipEventImpl.java | 2 +
.../org/apache/geode/admin/jmx/AgentConfig.java | 1 +
.../internal/AdminDistributedSystemJmxImpl.java | 78 +++++
.../geode/admin/jmx/internal/AgentConfigImpl.java | 50 +++
.../geode/admin/jmx/internal/AgentLauncher.java | 1 +
.../admin/jmx/internal/CacheServerJmxImpl.java | 28 ++
.../DistributedSystemHealthConfigJmxImpl.java | 6 +
.../jmx/internal/DistributionLocatorJmxImpl.java | 21 ++
.../jmx/internal/GemFireHealthConfigJmxImpl.java | 25 ++
.../admin/jmx/internal/GemFireHealthJmxImpl.java | 6 +
.../apache/geode/admin/jmx/internal/MBeanUtil.java | 1 +
.../geode/admin/jmx/internal/MX4JModelMBean.java | 24 ++
.../jmx/internal/MX4JServerSocketFactory.java | 2 +
.../jmx/internal/MemberInfoWithStatsMBean.java | 5 +
.../admin/jmx/internal/RMIRegistryService.java | 8 +
.../admin/jmx/internal/StatAlertNotification.java | 3 +
.../jmx/internal/StatisticResourceJmxImpl.java | 8 +
.../internal/SystemMemberBridgeServerJmxImpl.java | 6 +
.../jmx/internal/SystemMemberCacheJmxImpl.java | 6 +
.../geode/admin/jmx/internal/SystemMemberJmx.java | 1 +
.../admin/jmx/internal/SystemMemberJmxImpl.java | 20 ++
.../jmx/internal/SystemMemberRegionJmxImpl.java | 6 +
.../org/apache/geode/cache/AttributesFactory.java | 44 +++
.../apache/geode/cache/ExpirationAttributes.java | 2 +
.../apache/geode/cache/MembershipAttributes.java | 4 +
.../main/java/org/apache/geode/cache/Region.java | 19 ++
.../java/org/apache/geode/cache/RegionService.java | 1 +
.../apache/geode/cache/SubscriptionAttributes.java | 4 +
.../internal/ParallelAsyncEventQueueImpl.java | 1 +
.../geode/cache/client/internal/AbstractOp.java | 1 +
.../client/internal/AutoConnectionSourceImpl.java | 10 +
.../client/internal/CacheServerLoadMessage.java | 1 +
.../client/internal/ClientMetadataService.java | 2 +
.../client/internal/ClientRegionFactoryImpl.java | 20 ++
.../client/internal/ConnectionFactoryImpl.java | 5 +
.../cache/client/internal/ConnectionImpl.java | 18 +
.../cache/client/internal/ConnectionStats.java | 4 +
.../cache/client/internal/EndpointManager.java | 3 +
.../cache/client/internal/EndpointManagerImpl.java | 15 +
.../internal/ExplicitConnectionSourceImpl.java | 1 +
.../geode/cache/client/internal/GetAllOp.java | 1 +
.../cache/client/internal/GetEventValueOp.java | 4 +
.../cache/client/internal/InternalClientCache.java | 1 +
.../internal/LocatorDiscoveryCallbackAdapter.java | 2 +
.../cache/client/internal/OpExecutorImpl.java | 16 +
.../geode/cache/client/internal/PoolImpl.java | 52 +++
.../geode/cache/client/internal/ProxyRegion.java | 86 +++++
.../geode/cache/client/internal/PutAllOp.java | 1 +
.../geode/cache/client/internal/QueryOp.java | 1 +
.../cache/client/internal/QueueConnectionImpl.java | 18 +
.../cache/client/internal/QueueManagerImpl.java | 14 +
.../cache/client/internal/QueueStateImpl.java | 7 +
.../geode/cache/client/internal/RemoveAllOp.java | 1 +
.../cache/client/internal/ServerDenyList.java | 4 +
.../cache/client/internal/ServerRegionProxy.java | 13 +
.../internal/SingleHopOperationCallable.java | 1 +
.../internal/locator/ClientConnectionRequest.java | 1 +
.../internal/locator/ClientConnectionResponse.java | 3 +
.../internal/locator/GetAllServersRequest.java | 1 +
.../internal/locator/GetAllServersResponse.java | 3 +
.../internal/locator/LocatorListRequest.java | 1 +
.../internal/locator/LocatorListResponse.java | 3 +
.../internal/locator/QueueConnectionRequest.java | 1 +
.../internal/locator/QueueConnectionResponse.java | 3 +
.../internal/locator/ServerLocationRequest.java | 2 +
.../internal/pooling/ConnectionManagerImpl.java | 14 +
.../client/internal/pooling/PooledConnection.java | 18 +
.../geode/cache/configuration/CacheConfig.java | 1 +
.../org/apache/geode/cache/execute/Function.java | 1 +
.../cache/operations/internal/UpdateOnlyMap.java | 16 +
.../cache/partition/PartitionListenerAdapter.java | 4 +
.../query/internal/AbstractCompiledValue.java | 21 ++
.../internal/AbstractGroupOrRangeJunction.java | 3 +
.../cache/query/internal/AllGroupJunction.java | 3 +
.../org/apache/geode/cache/query/internal/Bag.java | 20 ++
.../cache/query/internal/CompiledAddition.java | 1 +
.../cache/query/internal/CompiledArithmetic.java | 2 +
.../cache/query/internal/CompiledBindArgument.java | 2 +
.../cache/query/internal/CompiledComparison.java | 9 +
.../cache/query/internal/CompiledConstruction.java | 2 +
.../cache/query/internal/CompiledDivision.java | 1 +
.../cache/query/internal/CompiledFunction.java | 2 +
.../geode/cache/query/internal/CompiledID.java | 2 +
.../geode/cache/query/internal/CompiledIn.java | 14 +
.../query/internal/CompiledIndexOperation.java | 6 +
.../cache/query/internal/CompiledIteratorDef.java | 2 +
.../cache/query/internal/CompiledJunction.java | 5 +
.../cache/query/internal/CompiledLiteral.java | 3 +
.../geode/cache/query/internal/CompiledMod.java | 1 +
.../query/internal/CompiledMultiplication.java | 1 +
.../cache/query/internal/CompiledNegation.java | 2 +
.../cache/query/internal/CompiledOperation.java | 2 +
.../geode/cache/query/internal/CompiledPath.java | 3 +
.../geode/cache/query/internal/CompiledRegion.java | 2 +
.../geode/cache/query/internal/CompiledSelect.java | 2 +
.../query/internal/CompiledSortCriterion.java | 2 +
.../cache/query/internal/CompiledSubtraction.java | 1 +
.../cache/query/internal/CompiledUnaryMinus.java | 2 +
.../cache/query/internal/CompiledUndefined.java | 10 +
.../query/internal/CompositeGroupJunction.java | 4 +
.../apache/geode/cache/query/internal/CqEntry.java | 3 +
.../geode/cache/query/internal/CqStateImpl.java | 4 +
.../internal/CumulativeNonDistinctResults.java | 1 +
.../cache/query/internal/DefaultQueryService.java | 31 ++
.../geode/cache/query/internal/GroupJunction.java | 2 +
.../query/internal/IndexTrackingQueryObserver.java | 3 +
.../cache/query/internal/LinkedResultSet.java | 9 +
.../geode/cache/query/internal/MethodDispatch.java | 1 +
.../cache/query/internal/NWayMergeResults.java | 1 +
.../cache/query/internal/ObjectIntHashMap.java | 15 +
.../cache/query/internal/OrderByComparator.java | 1 +
.../cache/query/internal/ProxyQueryService.java | 29 ++
.../geode/cache/query/internal/QCompiler.java | 5 +
.../apache/geode/cache/query/internal/QRegion.java | 19 ++
.../cache/query/internal/QueryObserverAdapter.java | 26 ++
.../geode/cache/query/internal/RangeJunction.java | 14 +
.../geode/cache/query/internal/ResultsBag.java | 3 +
.../query/internal/ResultsCollectionWrapper.java | 25 ++
.../geode/cache/query/internal/ResultsSet.java | 9 +
.../cache/query/internal/RuntimeIterator.java | 2 +
.../query/internal/SelectResultsComparator.java | 1 +
.../cache/query/internal/SortedResultSet.java | 9 +
.../cache/query/internal/SortedStructBag.java | 5 +
.../cache/query/internal/SortedStructSet.java | 16 +
.../geode/cache/query/internal/StructBag.java | 11 +
.../geode/cache/query/internal/StructImpl.java | 6 +
.../geode/cache/query/internal/StructSet.java | 21 ++
.../geode/cache/query/internal/Undefined.java | 3 +
.../geode/cache/query/internal/cq/ClientCQ.java | 1 +
.../cache/query/internal/cq/CqAttributesImpl.java | 5 +
.../cache/query/internal/cq/InternalCqQuery.java | 6 +
.../geode/cache/query/internal/cq/ServerCQ.java | 2 +
.../cache/query/internal/index/AbstractIndex.java | 1 +
.../query/internal/index/AbstractMapIndex.java | 28 ++
.../query/internal/index/CompactMapRangeIndex.java | 3 +
.../query/internal/index/CompactRangeIndex.java | 40 +++
.../cache/query/internal/index/HashIndex.java | 41 +++
.../cache/query/internal/index/HashIndexSet.java | 12 +
.../cache/query/internal/index/IndexElemArray.java | 6 +
.../cache/query/internal/index/IndexManager.java | 1 +
.../cache/query/internal/index/MapIndexStore.java | 21 ++
.../cache/query/internal/index/MapRangeIndex.java | 2 +
.../query/internal/index/MemoryIndexStore.java | 5 +
.../query/internal/index/PartitionedIndex.java | 30 ++
.../query/internal/index/PrimaryKeyIndex.java | 13 +
.../index/PrimaryKeyIndexCreationHelper.java | 3 +
.../cache/query/internal/index/RangeIndex.java | 30 ++
.../geode/cache/query/internal/parse/ASTLimit.java | 1 +
.../query/internal/types/CollectionTypeImpl.java | 3 +
.../internal/types/ExtendedNumericComparator.java | 1 +
.../cache/query/internal/types/MapTypeImpl.java | 2 +
.../query/internal/types/NumericComparator.java | 1 +
.../cache/query/internal/types/ObjectTypeImpl.java | 8 +
.../cache/query/internal/types/StructTypeImpl.java | 3 +
.../query/internal/types/TemporalComparator.java | 1 +
.../cache/query/internal/types/TypeUtils.java | 5 +
.../org/apache/geode/cache/server/ServerLoad.java | 2 +
.../apache/geode/cache/server/ServerLoadProbe.java | 1 +
.../geode/cache/server/ServerLoadProbeAdapter.java | 2 +
.../server/internal/ConnectionCountProbe.java | 5 +
.../geode/cache/server/internal/LoadMonitor.java | 4 +
.../cache/server/internal/ServerMetricsImpl.java | 4 +
.../geode/cache/snapshot/SnapshotIterator.java | 1 +
.../geode/cache/util/CacheListenerAdapter.java | 10 +
.../geode/cache/util/CacheWriterAdapter.java | 6 +
.../apache/geode/cache/util/CqListenerAdapter.java | 3 +
.../util/RegionMembershipListenerAdapter.java | 4 +
.../cache/util/RegionRoleListenerAdapter.java | 2 +
.../cache/util/TransactionListenerAdapter.java | 4 +
.../distributed/internal/DistributionAdvisor.java | 7 +
.../distributed/internal/DistributionConfig.java | 5 +
.../distributed/internal/DistributionManager.java | 1 +
.../distributed/internal/DistributionMessage.java | 4 +
.../distributed/internal/DistributionStats.java | 220 +++++++++++++
.../internal/FunctionExecutionPooledExecutor.java | 4 +
.../distributed/internal/HealthMonitorImpl.java | 5 +
.../internal/HighPriorityAckedMessage.java | 1 +
.../internal/InternalDistributedSystem.java | 34 ++
.../distributed/internal/LocatorLoadSnapshot.java | 2 +
.../internal/LonerDistributionManager.java | 54 +++
.../internal/PooledExecutorWithDMStats.java | 3 +
.../geode/distributed/internal/ReplyMessage.java | 2 +
.../distributed/internal/ReplyProcessor21.java | 4 +
.../distributed/internal/SerialAckedMessage.java | 1 +
.../geode/distributed/internal/ServerLocation.java | 3 +
.../geode/distributed/internal/ServerLocator.java | 16 +
.../distributed/internal/ShutdownMessage.java | 1 +
.../distributed/internal/SizeableRunnable.java | 1 +
.../geode/distributed/internal/StartupMessage.java | 1 +
.../internal/StartupResponseMessage.java | 1 +
.../StartupResponseWithVersionMessage.java | 1 +
.../internal/WaitForViewInstallation.java | 1 +
.../internal/deadlock/DLockDependencyMonitor.java | 2 +
.../internal/deadlock/GemFireDeadlockDetector.java | 10 +
.../deadlock/MessageDependencyMonitor.java | 2 +
.../distributed/internal/locks/DLockGrantor.java | 5 +
.../internal/locks/DLockQueryProcessor.java | 2 +
.../locks/DLockRecoverGrantorProcessor.java | 2 +
.../internal/locks/DLockReleaseProcessor.java | 2 +
.../internal/locks/DLockRemoteToken.java | 3 +
.../internal/locks/DLockRequestProcessor.java | 2 +
.../distributed/internal/locks/DLockService.java | 4 +
.../distributed/internal/locks/DLockStats.java | 110 +++++++
.../internal/locks/DeposeGrantorProcessor.java | 1 +
.../internal/locks/DistributedMemberLock.java | 12 +
.../internal/locks/DummyDLockStats.java | 107 ++++++
.../internal/locks/ElderInitProcessor.java | 1 +
.../internal/locks/GrantorRequestProcessor.java | 1 +
.../locks/NonGrantorDestroyedProcessor.java | 1 +
.../membership/DistributedMembershipListener.java | 1 +
.../membership/InternalDistributedMember.java | 14 +
.../internal/membership/InternalRole.java | 4 +
.../internal/membership/gms/GMSMember.java | 26 ++
.../membership/gms/fd/GMSHealthMonitor.java | 4 +
.../membership/gms/membership/GMSJoinLeave.java | 6 +
.../gms/messages/LeaveRequestMessage.java | 1 +
.../gms/messages/RemoveMemberMessage.java | 1 +
.../membership/gms/messenger/JGroupsMessenger.java | 1 +
.../membership/gms/mgr/GMSMembershipManager.java | 40 +++
.../membership/gms/mgr/LocalViewMessage.java | 1 +
.../internal/tcpserver/InfoRequest.java | 2 +
.../internal/tcpserver/InfoResponse.java | 2 +
.../internal/tcpserver/ShutdownRequest.java | 2 +
.../internal/tcpserver/ShutdownResponse.java | 2 +
.../unsafe/RegisterSignalHandlerSupport.java | 1 +
.../apache/geode/internal/CopyOnWriteHashSet.java | 13 +
.../org/apache/geode/internal/DSFIDFactory.java | 4 +
.../apache/geode/internal/ExternalizableDSFID.java | 5 +
.../geode/internal/HeapDataOutputStream.java | 12 +
.../geode/internal/InternalInstantiator.java | 1 +
.../org/apache/geode/internal/ManagerInfo.java | 2 +
.../geode/internal/NullDataOutputStream.java | 12 +
.../apache/geode/internal/OneTaskOnlyExecutor.java | 3 +
.../ScheduledThreadPoolExecutorWithKeepAlive.java | 8 +
.../org/apache/geode/internal/SystemAdmin.java | 5 +
.../internal/admin/ClientMembershipMessage.java | 1 +
.../internal/admin/CompoundEntrySnapshot.java | 8 +
.../internal/admin/CompoundRegionSnapshot.java | 8 +
.../apache/geode/internal/admin/StatResource.java | 2 +
.../admin/remote/AddHealthListenerRequest.java | 1 +
.../admin/remote/AddHealthListenerResponse.java | 1 +
.../admin/remote/AddStatListenerRequest.java | 1 +
.../admin/remote/AddStatListenerResponse.java | 1 +
.../geode/internal/admin/remote/AdminRegion.java | 85 +++++
.../admin/remote/AlertsNotificationMessage.java | 1 +
.../admin/remote/AppCacheSnapshotMessage.java | 1 +
.../internal/admin/remote/BridgeServerRequest.java | 1 +
.../internal/admin/remote/CacheConfigRequest.java | 1 +
.../internal/admin/remote/CacheInfoRequest.java | 1 +
.../admin/remote/CancelStatListenerRequest.java | 1 +
.../admin/remote/CancelStatListenerResponse.java | 1 +
.../internal/admin/remote/CancellationMessage.java | 1 +
.../admin/remote/ChangeRefreshIntervalMessage.java | 1 +
.../internal/admin/remote/ClientHealthStats.java | 3 +
.../internal/admin/remote/CompactResponse.java | 1 +
.../internal/admin/remote/DestroyEntryMessage.java | 1 +
.../admin/remote/DestroyRegionMessage.java | 1 +
.../geode/internal/admin/remote/DummyEntry.java | 9 +
.../admin/remote/DurableClientInfoRequest.java | 4 +
.../internal/admin/remote/EntryValueNodeImpl.java | 7 +
.../admin/remote/FetchDistLockInfoRequest.java | 1 +
.../admin/remote/FetchDistLockInfoResponse.java | 1 +
.../admin/remote/FetchHealthDiagnosisRequest.java | 1 +
.../admin/remote/FetchHealthDiagnosisResponse.java | 1 +
.../internal/admin/remote/FetchHostRequest.java | 1 +
.../internal/admin/remote/FetchHostResponse.java | 1 +
.../remote/FetchResourceAttributesRequest.java | 1 +
.../remote/FetchResourceAttributesResponse.java | 1 +
.../internal/admin/remote/FetchStatsRequest.java | 1 +
.../internal/admin/remote/FetchStatsResponse.java | 3 +
.../internal/admin/remote/FetchSysCfgRequest.java | 1 +
.../internal/admin/remote/FetchSysCfgResponse.java | 1 +
.../admin/remote/FlushAppCacheSnapshotMessage.java | 1 +
.../admin/remote/HealthListenerMessage.java | 1 +
.../internal/admin/remote/LicenseInfoRequest.java | 1 +
.../internal/admin/remote/LicenseInfoResponse.java | 1 +
.../admin/remote/MissingPersistentIDsResponse.java | 1 +
.../admin/remote/ObjectDetailsRequest.java | 2 +
.../admin/remote/ObjectDetailsResponse.java | 2 +
.../internal/admin/remote/ObjectNamesRequest.java | 2 +
.../internal/admin/remote/ObjectNamesResponse.java | 2 +
.../admin/remote/RefreshMemberSnapshotRequest.java | 1 +
.../admin/remote/RegionAttributesRequest.java | 1 +
.../admin/remote/RegionAttributesResponse.java | 1 +
.../geode/internal/admin/remote/RegionRequest.java | 1 +
.../internal/admin/remote/RegionResponse.java | 1 +
.../internal/admin/remote/RegionSizeRequest.java | 2 +
.../internal/admin/remote/RegionSizeResponse.java | 2 +
.../admin/remote/RegionStatisticsRequest.java | 1 +
.../admin/remote/RegionStatisticsResponse.java | 1 +
.../admin/remote/RegionSubRegionSizeRequest.java | 2 +
.../geode/internal/admin/remote/RemoteAlert.java | 14 +
.../internal/admin/remote/RemoteBridgeServer.java | 13 +
.../admin/remote/RemoteCacheStatistics.java | 8 +
.../internal/admin/remote/RemoteDLockInfo.java | 9 +
.../internal/admin/remote/RemoteEntrySnapshot.java | 10 +
.../internal/admin/remote/RemoteGemFireVM.java | 42 +++
.../admin/remote/RemoteGfManagerAgent.java | 19 ++
.../internal/admin/remote/RemoteObjectName.java | 2 +
.../admin/remote/RemoteRegionAttributes.java | 68 ++++
.../admin/remote/RemoteRegionSnapshot.java | 10 +
.../geode/internal/admin/remote/RemoteStat.java | 9 +
.../internal/admin/remote/RemoteStatResource.java | 12 +
.../admin/remote/RemoveHealthListenerRequest.java | 1 +
.../admin/remote/RemoveHealthListenerResponse.java | 1 +
.../admin/remote/ResetHealthStatusRequest.java | 1 +
.../admin/remote/ResetHealthStatusResponse.java | 1 +
.../admin/remote/RevokePersistentIDResponse.java | 1 +
.../internal/admin/remote/RootRegionRequest.java | 1 +
.../remote/ShutdownAllGatewayHubsRequest.java | 2 +
.../internal/admin/remote/ShutdownAllResponse.java | 1 +
.../admin/remote/SnapshotResultMessage.java | 1 +
.../remote/StatAlertsManagerAssignMessage.java | 1 +
.../internal/admin/remote/StatListenerMessage.java | 1 +
.../internal/admin/remote/StoreSysCfgRequest.java | 1 +
.../internal/admin/remote/StoreSysCfgResponse.java | 1 +
.../internal/admin/remote/SubRegionRequest.java | 1 +
.../internal/admin/remote/SubRegionResponse.java | 1 +
.../internal/admin/remote/TailLogRequest.java | 1 +
.../admin/remote/UpdateAlertDefinitionMessage.java | 1 +
.../internal/admin/remote/VersionInfoRequest.java | 1 +
.../internal/admin/remote/VersionInfoResponse.java | 1 +
.../admin/remote/VersionMismatchAlert.java | 7 +
.../admin/statalerts/BaseDecoratorImpl.java | 17 +
.../admin/statalerts/DummyStatisticInfoImpl.java | 11 +
.../statalerts/GaugeThresholdDecoratorImpl.java | 1 +
.../admin/statalerts/MultiAttrDefinitionImpl.java | 17 +
.../statalerts/NumberThresholdDecoratorImpl.java | 1 +
.../admin/statalerts/SingleAttrDefinitionImpl.java | 17 +
.../admin/statalerts/StatisticInfoImpl.java | 11 +
.../internal/alerting/NullAlertingService.java | 3 +
.../internal/cache/AbstractBucketRegionQueue.java | 2 +
.../geode/internal/cache/AbstractCacheServer.java | 29 ++
.../apache/geode/internal/cache/BucketAdvisor.java | 6 +
.../apache/geode/internal/cache/BucketRegion.java | 6 +
.../geode/internal/cache/BucketRegionQueue.java | 4 +
.../internal/cache/CacheDistributionAdvisor.java | 19 ++
.../geode/internal/cache/CacheObserverAdapter.java | 21 ++
.../geode/internal/cache/CachePerfStats.java | 5 +
.../geode/internal/cache/CacheServerLauncher.java | 1 +
.../geode/internal/cache/CacheStatisticsImpl.java | 6 +
.../cache/ClientServerObserverAdapter.java | 12 +
.../cache/ClientSubscriptionConfigImpl.java | 8 +
.../geode/internal/cache/CloseCacheMessage.java | 1 +
.../geode/internal/cache/ColocationLogger.java | 1 +
.../internal/cache/CountingDataInputStream.java | 15 +
.../internal/cache/CreateRegionProcessor.java | 4 +
.../geode/internal/cache/DestroyOperation.java | 1 +
.../cache/DestroyPartitionedRegionMessage.java | 1 +
.../internal/cache/DestroyRegionOperation.java | 3 +
.../apache/geode/internal/cache/DiskRegion.java | 13 +
.../geode/internal/cache/DiskStoreAttributes.java | 14 +
.../geode/internal/cache/DiskStoreFactoryImpl.java | 10 +
.../apache/geode/internal/cache/DiskStoreImpl.java | 22 ++
.../geode/internal/cache/DiskStoreMonitor.java | 2 +
.../internal/cache/DiskWriteAttributesImpl.java | 5 +
.../geode/internal/cache/DistPeerTXStateStub.java | 6 +
.../apache/geode/internal/cache/DistTXState.java | 3 +
.../internal/cache/DistTXStateOnCoordinator.java | 8 +
.../internal/cache/DistributedCacheOperation.java | 3 +
.../internal/cache/DistributedClearOperation.java | 1 +
.../internal/cache/DistributedPutAllOperation.java | 5 +
.../geode/internal/cache/DistributedRegion.java | 2 +
.../DistributedRegionFunctionStreamingMessage.java | 5 +
.../cache/DistributedRemoveAllOperation.java | 5 +
.../cache/DistributedTombstoneOperation.java | 2 +
.../geode/internal/cache/DummyCachePerfStats.java | 2 +
.../internal/cache/DynamicRegionAttributes.java | 2 +
.../apache/geode/internal/cache/EntriesSet.java | 3 +
.../geode/internal/cache/EntryEventImpl.java | 39 +++
.../geode/internal/cache/EntryOperationImpl.java | 6 +
.../apache/geode/internal/cache/EntrySnapshot.java | 11 +
.../org/apache/geode/internal/cache/EventID.java | 5 +
...xpireDisconnectedClientTransactionsMessage.java | 1 +
.../apache/geode/internal/cache/ExpiryTask.java | 1 +
.../apache/geode/internal/cache/FilterProfile.java | 4 +
.../geode/internal/cache/FilterRoutingInfo.java | 6 +
.../internal/cache/FindDurableQueueProcessor.java | 1 +
.../geode/internal/cache/FindRemoteTXMessage.java | 1 +
.../internal/cache/FindVersionTagOperation.java | 1 +
.../cache/FixedPartitionAttributesImpl.java | 5 +
.../cache/ForceableLinkedBlockingQueue.java | 19 ++
.../FunctionStreamingOrderedReplyMessage.java | 1 +
.../geode/internal/cache/GemFireCacheImpl.java | 20 ++
.../apache/geode/internal/cache/GridAdvisor.java | 2 +
.../geode/internal/cache/IdentityArrayList.java | 26 ++
.../cache/InMemoryPersistentMemberView.java | 19 ++
.../internal/cache/InitialImageFlowControl.java | 5 +
.../internal/cache/InitialImageOperation.java | 11 +
.../cache/InterestRegistrationEventImpl.java | 10 +
.../apache/geode/internal/cache/InternalCache.java | 2 +
.../geode/internal/cache/InternalRegion.java | 2 +
.../geode/internal/cache/InvalidateOperation.java | 1 +
.../cache/InvalidatePartitionedRegionMessage.java | 1 +
.../internal/cache/InvalidateRegionOperation.java | 1 +
.../internal/cache/JtaAfterCompletionMessage.java | 1 +
.../internal/cache/JtaBeforeCompletionMessage.java | 1 +
.../geode/internal/cache/LoaderHelperImpl.java | 4 +
.../apache/geode/internal/cache/LocalDataSet.java | 86 +++++
.../apache/geode/internal/cache/LocalRegion.java | 5 +
.../geode/internal/cache/LocalRegionDataView.java | 24 ++
.../cache/MemberFunctionStreamingMessage.java | 5 +
.../apache/geode/internal/cache/OverflowOplog.java | 5 +
.../geode/internal/cache/OverflowOplogSet.java | 1 +
.../internal/cache/PRHARedundancyProvider.java | 10 +
.../geode/internal/cache/PRQueryProcessor.java | 4 +
.../geode/internal/cache/PartitionedRegion.java | 18 +
.../internal/cache/PartitionedRegionDataStore.java | 11 +
.../internal/cache/PartitionedRegionHelper.java | 8 +
.../geode/internal/cache/PeerTXStateStub.java | 1 +
.../geode/internal/cache/PersistentOplogSet.java | 2 +
.../geode/internal/cache/PoolFactoryImpl.java | 32 ++
.../cache/PreferBytesCachedDeserializable.java | 13 +
.../geode/internal/cache/ProxyBucketRegion.java | 21 ++
.../geode/internal/cache/RegionEventImpl.java | 20 ++
.../internal/cache/ReleaseClearLockMessage.java | 1 +
.../apache/geode/internal/cache/RoleEventImpl.java | 1 +
.../cache/SearchLoadAndWriteProcessor.java | 13 +
.../geode/internal/cache/StateFlushOperation.java | 3 +
.../cache/StoreAllCachedDeserializable.java | 13 +
.../geode/internal/cache/TXCommitMessage.java | 5 +
.../org/apache/geode/internal/cache/TXEntry.java | 15 +
.../apache/geode/internal/cache/TXEntryState.java | 3 +
.../org/apache/geode/internal/cache/TXEvent.java | 3 +
.../geode/internal/cache/TXFarSideCMTracker.java | 5 +
.../apache/geode/internal/cache/TXManagerImpl.java | 26 ++
.../org/apache/geode/internal/cache/TXMessage.java | 4 +
.../internal/cache/TXRemoteCommitMessage.java | 1 +
.../internal/cache/TXRemoteRollbackMessage.java | 1 +
.../apache/geode/internal/cache/TXRmtEvent.java | 3 +
.../geode/internal/cache/TXStateInterface.java | 2 +
.../apache/geode/internal/cache/TXStateProxy.java | 3 +
.../geode/internal/cache/TombstoneService.java | 2 +
.../geode/internal/cache/UnsharedImageState.java | 29 ++
.../internal/cache/UpdateAttributesProcessor.java | 1 +
.../geode/internal/cache/UpdateOperation.java | 2 +
.../internal/cache/VMCachedDeserializable.java | 13 +
.../cache/WrappedRegionMembershipListener.java | 14 +
.../geode/internal/cache/control/FilterByPath.java | 1 +
.../control/PartitionRebalanceDetailsImpl.java | 16 +
.../cache/control/RebalanceOperationImpl.java | 6 +
.../cache/control/RebalanceResultsImpl.java | 10 +
.../cache/entries/AbstractLRURegionEntry.java | 1 +
.../entries/VMStatsDiskLRURegionEntryHeap.java | 3 +
.../entries/VMStatsDiskLRURegionEntryOffHeap.java | 3 +
.../cache/entries/VMStatsDiskRegionEntryHeap.java | 3 +
.../entries/VMStatsDiskRegionEntryOffHeap.java | 3 +
.../cache/entries/VMStatsLRURegionEntryHeap.java | 3 +
.../entries/VMStatsLRURegionEntryOffHeap.java | 3 +
.../cache/entries/VMStatsRegionEntryHeap.java | 3 +
.../cache/entries/VMStatsRegionEntryOffHeap.java | 3 +
.../entries/VMThinDiskLRURegionEntryHeap.java | 3 +
.../entries/VMThinDiskLRURegionEntryOffHeap.java | 3 +
.../cache/entries/VMThinDiskRegionEntryHeap.java | 3 +
.../entries/VMThinDiskRegionEntryOffHeap.java | 3 +
.../cache/entries/VMThinLRURegionEntryHeap.java | 3 +
.../cache/entries/VMThinLRURegionEntryOffHeap.java | 3 +
.../cache/entries/VMThinRegionEntryHeap.java | 3 +
.../cache/entries/VMThinRegionEntryOffHeap.java | 3 +
.../VersionedStatsDiskLRURegionEntryHeap.java | 3 +
.../VersionedStatsDiskLRURegionEntryOffHeap.java | 3 +
.../entries/VersionedStatsDiskRegionEntryHeap.java | 3 +
.../VersionedStatsDiskRegionEntryOffHeap.java | 3 +
.../entries/VersionedStatsLRURegionEntryHeap.java | 3 +
.../VersionedStatsLRURegionEntryOffHeap.java | 3 +
.../entries/VersionedStatsRegionEntryHeap.java | 3 +
.../entries/VersionedStatsRegionEntryOffHeap.java | 3 +
.../VersionedThinDiskLRURegionEntryHeap.java | 3 +
.../VersionedThinDiskLRURegionEntryOffHeap.java | 3 +
.../entries/VersionedThinDiskRegionEntryHeap.java | 3 +
.../VersionedThinDiskRegionEntryOffHeap.java | 3 +
.../entries/VersionedThinLRURegionEntryHeap.java | 3 +
.../VersionedThinLRURegionEntryOffHeap.java | 3 +
.../entries/VersionedThinRegionEntryHeap.java | 3 +
.../entries/VersionedThinRegionEntryOffHeap.java | 3 +
.../cache/event/DistributedEventTracker.java | 1 +
.../cache/event/EventSequenceNumberHolder.java | 2 +
.../internal/cache/execute/AbstractExecution.java | 6 +
.../cache/execute/DefaultResultCollector.java | 5 +
.../execute/DistributedRegionFunctionExecutor.java | 5 +
.../DistributedRegionFunctionResultSender.java | 7 +
.../cache/execute/FunctionContextImpl.java | 4 +
.../cache/execute/FunctionRemoteContext.java | 2 +
.../execute/FunctionStreamingResultCollector.java | 5 +
.../internal/cache/execute/InternalFunction.java | 1 +
.../cache/execute/LocalResultCollectorImpl.java | 8 +
.../cache/execute/MemberFunctionExecutor.java | 4 +
.../cache/execute/MemberFunctionResultSender.java | 7 +
.../cache/execute/MemberFunctionResultWaiter.java | 1 +
.../cache/execute/MultiRegionFunctionContext.java | 1 +
.../execute/MultiRegionFunctionContextImpl.java | 2 +
.../cache/execute/MultiRegionFunctionExecutor.java | 4 +
.../geode/internal/cache/execute/NoResult.java | 5 +
.../execute/PartitionedRegionFunctionExecutor.java | 7 +
.../PartitionedRegionFunctionResultSender.java | 7 +
.../PartitionedRegionFunctionResultWaiter.java | 1 +
.../cache/execute/RegionFunctionContextImpl.java | 6 +
.../ServerToClientFunctionResultSender.java | 3 +
.../util/FindRestEnabledServersFunction.java | 2 +
.../geode/internal/cache/ha/HAContainerMap.java | 24 ++
.../geode/internal/cache/ha/HAContainerRegion.java | 21 ++
.../internal/cache/ha/HAContainerWrapper.java | 1 +
.../internal/cache/ha/QueueRemovalMessage.java | 1 +
.../geode/internal/cache/ha/ThreadIdentifier.java | 2 +
.../cache/locks/TXLessorDepartureHandler.java | 1 +
.../geode/internal/cache/locks/TXLockBatch.java | 7 +
.../geode/internal/cache/locks/TXLockId.java | 1 +
.../geode/internal/cache/locks/TXLockIdImpl.java | 7 +
.../locks/TXLockUpdateParticipantsMessage.java | 1 +
.../cache/locks/TXOriginatorRecoveryProcessor.java | 2 +
.../locks/TXRecoverGrantorMessageProcessor.java | 2 +
.../AllBucketProfilesUpdateMessage.java | 1 +
.../partitioned/BecomePrimaryBucketMessage.java | 1 +
.../geode/internal/cache/partitioned/Bucket.java | 1 +
.../cache/partitioned/BucketBackupMessage.java | 1 +
.../cache/partitioned/BucketCountLoadProbe.java | 4 +
.../partitioned/BucketProfileUpdateMessage.java | 1 +
.../cache/partitioned/BucketSizeMessage.java | 2 +
.../cache/partitioned/ContainsKeyValueMessage.java | 1 +
.../cache/partitioned/CreateBucketMessage.java | 1 +
.../partitioned/DeposePrimaryBucketMessage.java | 1 +
.../internal/cache/partitioned/DestroyMessage.java | 1 +
.../DestroyRegionOnDataStoreMessage.java | 1 +
.../cache/partitioned/DumpAllPRConfigMessage.java | 1 +
.../internal/cache/partitioned/DumpB2NRegion.java | 1 +
.../cache/partitioned/DumpBucketsMessage.java | 1 +
.../partitioned/EndBucketCreationMessage.java | 1 +
.../cache/partitioned/FetchBulkEntriesMessage.java | 2 +
.../cache/partitioned/FetchEntriesMessage.java | 2 +
.../cache/partitioned/FetchEntryMessage.java | 1 +
.../cache/partitioned/FetchKeysMessage.java | 3 +
.../partitioned/FetchPartitionDetailsMessage.java | 1 +
.../internal/cache/partitioned/FlushMessage.java | 1 +
.../internal/cache/partitioned/GetMessage.java | 1 +
.../cache/partitioned/IdentityRequestMessage.java | 2 +
.../cache/partitioned/IdentityUpdateMessage.java | 1 +
.../cache/partitioned/IndexCreationMsg.java | 1 +
.../cache/partitioned/InterestEventMessage.java | 2 +
.../partitioned/ManageBackupBucketMessage.java | 1 +
.../cache/partitioned/ManageBucketMessage.java | 1 +
.../cache/partitioned/MoveBucketMessage.java | 1 +
.../cache/partitioned/OfflineMemberDetails.java | 3 +
.../partitioned/OfflineMemberDetailsImpl.java | 3 +
.../geode/internal/cache/partitioned/PRLoad.java | 2 +
.../cache/partitioned/PRSanityCheckMessage.java | 1 +
.../cache/partitioned/PRTombstoneMessage.java | 2 +
.../cache/partitioned/PartitionMemberInfoImpl.java | 8 +
.../cache/partitioned/PartitionMessage.java | 4 +
.../PartitionMessageWithDirectReply.java | 3 +
.../cache/partitioned/PartitionRegionInfoImpl.java | 11 +
.../PartitionedRegionFunctionStreamingMessage.java | 1 +
.../PartitionedRegionObserverAdapter.java | 1 +
.../partitioned/PartitionedRegionRebalanceOp.java | 6 +
.../cache/partitioned/PrimaryRequestMessage.java | 1 +
.../cache/partitioned/PutAllPRMessage.java | 1 +
.../internal/cache/partitioned/PutMessage.java | 2 +
.../cache/partitioned/RecoveryRunnable.java | 1 +
.../internal/cache/partitioned/RegionAdvisor.java | 26 ++
.../cache/partitioned/RemoveAllPRMessage.java | 1 +
.../cache/partitioned/RemoveBucketMessage.java | 1 +
.../cache/partitioned/RemoveIndexesMessage.java | 1 +
.../internal/cache/partitioned/SizeMessage.java | 1 +
.../cache/partitioned/SizedBasedLoadProbe.java | 4 +
.../partitioned/StreamingPartitionOperation.java | 2 +
.../rebalance/ParallelBucketOperator.java | 1 +
.../rebalance/SimulatedBucketOperator.java | 4 +
.../cache/persistence/DiskStoreFilter.java | 1 +
.../cache/persistence/MembershipFlushRequest.java | 1 +
.../cache/persistence/MembershipViewRequest.java | 1 +
.../persistence/PersistenceObserverHolder.java | 6 +
.../cache/persistence/PersistentMemberID.java | 2 +
.../persistence/PersistentMembershipView.java | 2 +
.../cache/persistence/PersistentStateListener.java | 3 +
.../persistence/PersistentStateQueryMessage.java | 1 +
.../PrepareNewPersistentMemberMessage.java | 1 +
.../persistence/RemovePersistentMemberMessage.java | 1 +
.../UninterruptibleRandomAccessFile.java | 11 +
.../query/mock/SortedResultMapImpl.java | 1 +
.../cache/tier/InternalClientMembership.java | 5 +
.../internal/cache/tier/sockets/AcceptorImpl.java | 2 +
.../cache/tier/sockets/CacheClientNotifier.java | 1 +
.../cache/tier/sockets/CacheClientProxy.java | 9 +
.../cache/tier/sockets/CacheClientProxyStats.java | 4 +
.../cache/tier/sockets/CacheServerStats.java | 6 +
.../tier/sockets/ClientDenylistProcessor.java | 1 +
.../tier/sockets/ClientInterestMessageImpl.java | 10 +
.../tier/sockets/ClientMarkerMessageImpl.java | 10 +
.../cache/tier/sockets/ClientPingMessageImpl.java | 10 +
.../tier/sockets/ClientProxyMembershipID.java | 5 +
.../tier/sockets/ClientUpdateMessageImpl.java | 32 ++
.../tier/sockets/ConnectionListenerAdapter.java | 4 +
.../internal/cache/tier/sockets/EncryptorImpl.java | 2 +
.../cache/tier/sockets/HAEventWrapper.java | 10 +
.../tier/sockets/InterestResultPolicyImpl.java | 3 +
.../cache/tier/sockets/ObjectPartList.java | 3 +
.../tier/sockets/OriginalServerConnection.java | 1 +
.../sockets/RemoveClientFromDenylistMessage.java | 1 +
.../cache/tier/sockets/ServerConnection.java | 1 +
.../tier/sockets/ServerSideHandshakeImpl.java | 2 +
.../cache/tier/sockets/VersionedObjectList.java | 8 +
.../command/ExecuteRegionFunctionGeode18.java | 1 +
.../internal/cache/tier/sockets/command/Query.java | 1 +
.../cache/tier/sockets/command/Query651.java | 1 +
.../cache/tier/sockets/command/QueryGeode10.java | 1 +
.../command/QueryWithParametersGeode10.java | 1 +
.../sockets/command/RegisterDataSerializers.java | 1 +
.../tier/sockets/command/RequestEventValue.java | 1 +
.../internal/cache/tx/ClientTXRegionStub.java | 11 +
.../geode/internal/cache/tx/DistTxKeyInfo.java | 1 +
.../internal/cache/tx/DistributedTXRegionStub.java | 9 +
.../internal/cache/tx/PartitionedTXRegionStub.java | 9 +
.../internal/cache/tx/RemoteClearMessage.java | 1 +
.../cache/tx/RemoteContainsKeyValueMessage.java | 1 +
.../internal/cache/tx/RemoteDestroyMessage.java | 1 +
.../internal/cache/tx/RemoteFetchEntryMessage.java | 1 +
.../internal/cache/tx/RemoteFetchKeysMessage.java | 2 +
.../geode/internal/cache/tx/RemoteGetMessage.java | 1 +
.../internal/cache/tx/RemoteOperationMessage.java | 4 +
.../tx/RemoteOperationMessageWithDirectReply.java | 3 +
.../internal/cache/tx/RemotePutAllMessage.java | 2 +
.../geode/internal/cache/tx/RemotePutMessage.java | 2 +
.../internal/cache/tx/RemoteRemoveAllMessage.java | 2 +
.../geode/internal/cache/tx/RemoteSizeMessage.java | 1 +
.../cache/versions/CompactVersionHolder.java | 7 +
.../internal/cache/versions/DiskVersionTag.java | 1 +
.../internal/cache/versions/RVVException.java | 3 +
.../internal/cache/versions/RVVExceptionB.java | 11 +
.../internal/cache/versions/RVVExceptionT.java | 8 +
.../cache/versions/RegionVersionHolder.java | 2 +
.../cache/versions/RegionVersionVector.java | 9 +
.../geode/internal/cache/versions/VersionTag.java | 9 +
.../cache/vmotion/VMotionObserverAdapter.java | 3 +
.../wan/AbstractGatewaySenderEventProcessor.java | 1 +
.../internal/cache/wan/GatewayEventFilterImpl.java | 4 +
.../wan/GatewaySenderEventCallbackArgument.java | 1 +
.../wan/GatewaySenderEventCallbackDispatcher.java | 1 +
.../internal/cache/wan/GatewaySenderEventImpl.java | 16 +
.../cache/wan/TransportFilterServerSocket.java | 1 +
.../internal/cache/wan/TransportFilterSocket.java | 3 +
.../cache/wan/TransportFilterSocketFactory.java | 1 +
.../ParallelGatewaySenderEventProcessor.java | 8 +
.../wan/parallel/ParallelGatewaySenderQueue.java | 7 +
.../cache/wan/parallel/RREventIDResolver.java | 3 +
...tilParallelGatewaySenderFlushedCoordinator.java | 1 +
.../cache/wan/serial/BatchDestroyOperation.java | 1 +
...oncurrentSerialGatewaySenderEventProcessor.java | 2 +
.../serial/SerialGatewaySenderEventProcessor.java | 4 +
.../cache/wan/serial/SerialGatewaySenderQueue.java | 12 +
.../cache/xmlcache/AsyncEventQueueCreation.java | 3 +
.../internal/cache/xmlcache/CacheCreation.java | 3 +
.../cache/xmlcache/CacheServerCreation.java | 9 +
.../xmlcache/CacheTransactionManagerCreation.java | 21 ++
.../geode/internal/cache/xmlcache/CacheXml.java | 4 +
.../internal/cache/xmlcache/CacheXmlGenerator.java | 15 +
.../internal/cache/xmlcache/CacheXmlParser.java | 10 +
.../cache/xmlcache/CacheXmlPropertyResolver.java | 5 +
.../xmlcache/DiskStoreAttributesCreation.java | 2 +
.../cache/xmlcache/GatewayReceiverCreation.java | 14 +
.../xmlcache/ParallelAsyncEventQueueCreation.java | 13 +
.../xmlcache/ParallelGatewaySenderCreation.java | 15 +
.../cache/xmlcache/RegionAttributesCreation.java | 46 +++
.../internal/cache/xmlcache/RegionCreation.java | 95 ++++++
.../cache/xmlcache/ResourceManagerCreation.java | 8 +
.../xmlcache/SerialAsyncEventQueueCreation.java | 13 +
.../xmlcache/SerialGatewaySenderCreation.java | 15 +
.../geode/internal/concurrent/AtomicLong5.java | 1 +
.../concurrent/CompactConcurrentHashSet2.java | 9 +
.../internal/concurrent/ConcurrentHashSet.java | 7 +
.../internal/datasource/AbstractDataSource.java | 6 +
.../internal/datasource/AbstractPoolCache.java | 5 +
.../datasource/ConnectionEventListenerAdaptor.java | 7 +
.../datasource/FacetsJCAConnectionManagerImpl.java | 8 +
.../datasource/GemFireBasicDataSource.java | 2 +
.../datasource/GemFireConnPooledDataSource.java | 4 +
.../datasource/GemFireConnectionPoolManager.java | 4 +
.../datasource/GemFireTransactionDataSource.java | 4 +
.../datasource/JCAConnectionManagerImpl.java | 6 +
.../geode/internal/io/CompositeOutputStream.java | 4 +
.../apache/geode/internal/jndi/ContextImpl.java | 34 ++
.../internal/jndi/InitialContextFactoryImpl.java | 1 +
.../apache/geode/internal/jndi/NameParserImpl.java | 1 +
.../apache/geode/internal/jta/TransactionImpl.java | 7 +
.../geode/internal/jta/TransactionManagerImpl.java | 11 +
.../geode/internal/jta/UserTransactionImpl.java | 6 +
.../org/apache/geode/internal/jta/XidImpl.java | 3 +
.../internal/memcached/ConnectionHandler.java | 1 +
.../geode/internal/memcached/ValueWrapper.java | 2 +
.../memcached/commands/FlushAllCommand.java | 1 +
.../internal/modules/util/RegionConfiguration.java | 3 +
.../apache/geode/internal/net/SocketCloser.java | 1 +
.../DisconnectingOutOfOffHeapMemoryListener.java | 1 +
.../apache/geode/internal/offheap/Fragment.java | 1 +
.../internal/offheap/MemoryAllocatorImpl.java | 1 +
.../geode/internal/offheap/MemoryBlockNode.java | 5 +
.../geode/internal/offheap/OffHeapStorage.java | 9 +
.../internal/offheap/OffHeapStoredObject.java | 1 +
.../internal/sequencelog/SequenceLoggerImpl.java | 3 +
.../sequencelog/io/GemfireLogConverter.java | 11 +
.../geode/internal/sequencelog/io/GraphReader.java | 2 +
.../geode/internal/sequencelog/model/GraphID.java | 1 +
.../geode/internal/sequencelog/model/GraphSet.java | 4 +
.../geode/internal/sequencelog/model/Vertex.java | 1 +
.../visualization/text/TextDisplay.java | 4 +
.../geode/internal/shared/NativeCallsJNAImpl.java | 5 +
.../geode/internal/shared/StringPrintWriter.java | 1 +
.../internal/size/CachingSingleObjectSizer.java | 1 +
.../size/InstrumentationSingleObjectSizer.java | 1 +
.../geode/internal/size/ObjectGraphSizer.java | 3 +
.../geode/internal/size/ReflectionObjectSizer.java | 2 +
.../internal/size/ReflectionSingleObjectSizer.java | 1 +
.../internal/size/SizeClassOnceObjectSizer.java | 2 +
.../statistics/DummyStatisticsFactory.java | 24 ++
.../internal/statistics/DummyStatisticsImpl.java | 40 +++
.../statistics/MapBasedStatisticsNotification.java | 7 +
.../internal/statistics/StatArchiveReader.java | 33 ++
.../internal/statistics/StatArchiveWriter.java | 18 +
.../statistics/StatisticDescriptorImpl.java | 8 +
.../geode/internal/statistics/StatisticsImpl.java | 40 +++
.../statistics/StatisticsNotification.java | 1 +
.../statistics/StatisticsTypeFactoryImpl.java | 15 +
.../internal/statistics/StatisticsTypeImpl.java | 5 +
.../internal/statistics/StatisticsTypeXml.java | 4 +
.../apache/geode/internal/statistics/VMStats.java | 2 +
.../geode/internal/statistics/ValueMonitor.java | 1 +
.../apache/geode/internal/stats50/VMStats50.java | 2 +
.../geode/internal/tcp/ByteBufferInputStream.java | 17 +
.../org/apache/geode/internal/tcp/Connection.java | 1 +
.../geode/internal/tcp/DirectReplySender.java | 1 +
.../apache/geode/internal/tcp/MsgOutputStream.java | 12 +
.../org/apache/geode/internal/tcp/MsgStreamer.java | 16 +
.../org/apache/geode/internal/tcp/TCPConduit.java | 2 +
.../apache/geode/internal/util/TransformUtils.java | 1 +
.../geode/internal/util/VersionedArrayList.java | 7 +
.../util/concurrent/CopyOnWriteWeakHashMap.java | 1 +
.../concurrent/CustomEntryConcurrentHashMap.java | 25 ++
.../internal/util/concurrent/FutureResult.java | 5 +
.../geode/management/internal/ArrayConverter.java | 3 +
.../management/internal/BaseManagementService.java | 2 +
.../management/internal/CollectionConverter.java | 3 +
.../management/internal/CompositeConverter.java | 3 +
.../geode/management/internal/EnumConverter.java | 2 +
.../management/internal/IdentityConverter.java | 3 +
.../management/internal/JmxManagerAdvisor.java | 4 +
.../internal/JmxManagerLocatorRequest.java | 3 +
.../internal/JmxManagerLocatorResponse.java | 3 +
.../geode/management/internal/LocalManager.java | 1 +
.../internal/MBeanProxyInvocationHandler.java | 2 +
.../internal/MXBeanProxyInvocationHandler.java | 2 +
.../management/internal/ManagementFunction.java | 2 +
.../internal/ManagementMembershipListener.java | 1 +
.../management/internal/OpenTypeConverter.java | 10 +
.../geode/management/internal/TableConverter.java | 3 +
.../internal/beans/CacheServerBridge.java | 1 +
.../internal/beans/DistributedRegionMBean.java | 1 +
.../internal/beans/DistributedSystemMBean.java | 1 +
.../internal/beans/GatewayReceiverMBean.java | 1 +
.../internal/beans/GatewayReceiverMBeanBridge.java | 1 +
.../internal/beans/GatewaySenderMBean.java | 1 +
.../management/internal/beans/MBeanAggregator.java | 13 +
.../internal/beans/ManagementAdapter.java | 3 +
.../management/internal/beans/MemberMBean.java | 3 +
.../internal/beans/PartitionedRegionBridge.java | 2 +
.../management/internal/cli/CommandResponse.java | 3 +
.../geode/management/internal/cli/LogWrapper.java | 1 +
.../internal/cli/commands/AlterRegionCommand.java | 1 +
.../internal/cli/commands/ConnectCommand.java | 3 +
.../internal/cli/commands/GfshHelpCommand.java | 1 +
.../internal/cli/commands/GfshHintCommand.java | 1 +
.../ImportClusterConfigurationCommand.java | 1 +
.../cli/commands/LauncherSignalListener.java | 1 +
.../cli/commands/lifecycle/StartVsdCommand.java | 1 +
.../converters/ClusterMemberIdNameConverter.java | 1 +
.../cli/converters/MemberGroupConverter.java | 1 +
.../internal/cli/domain/DiskStoreDetails.java | 9 +
.../internal/cli/domain/IndexDetails.java | 1 +
.../cli/functions/DescribeDiskStoreFunction.java | 2 +
.../internal/cli/functions/ExportDataFunction.java | 2 +
.../internal/cli/functions/ImportDataFunction.java | 2 +
.../cli/functions/ListDiskStoresFunction.java | 2 +
.../cli/functions/ListDurableCqNamesFunction.java | 2 +
.../internal/cli/functions/ListIndexFunction.java | 2 +
.../internal/cli/remote/CommandStatementImpl.java | 1 +
.../internal/cli/remote/MemberCommandService.java | 4 +
.../internal/cli/result/AbstractResultData.java | 2 +
.../internal/cli/result/CommandResult.java | 8 +
.../internal/cli/result/CompositeResultData.java | 2 +
.../internal/cli/result/ErrorResultData.java | 4 +
.../internal/cli/result/InfoResultData.java | 6 +
.../internal/cli/result/LegacyCommandResult.java | 3 +
.../internal/cli/result/ModelCommandResult.java | 1 +
.../internal/cli/result/TabularResultData.java | 3 +
.../internal/cli/shell/JmxOperationInvoker.java | 6 +
.../internal/cli/util/GfshConsoleReader.java | 3 +
.../messages/ConfigurationResponse.java | 1 +
.../internal/messages/CompactRequest.java | 1 +
.../internal/messages/CompactResponse.java | 1 +
.../internal/web/io/MultipartFileAdapter.java | 8 +
.../internal/web/shell/HttpOperationInvoker.java | 3 +
.../ClientMembershipListenerAdapter.java | 3 +
.../UniversalMembershipListenerAdapter.java | 11 +
.../geode/memcached/GemFireMemcachedServer.java | 1 +
.../geode/pdx/ReflectionBasedAutoSerializer.java | 2 +
.../geode/pdx/internal/CheckTypeRegistryState.java | 1 +
.../geode/pdx/internal/ClientTypeRegistration.java | 11 +
.../java/org/apache/geode/pdx/internal/EnumId.java | 3 +
.../org/apache/geode/pdx/internal/EnumInfo.java | 16 +
.../geode/pdx/internal/LonerTypeRegistration.java | 4 +
.../org/apache/geode/pdx/internal/PdxField.java | 3 +
.../apache/geode/pdx/internal/PdxInstanceEnum.java | 13 +
.../apache/geode/pdx/internal/PdxReaderImpl.java | 73 +++++
.../org/apache/geode/pdx/internal/PdxString.java | 1 +
.../org/apache/geode/pdx/internal/PdxType.java | 2 +
.../apache/geode/pdx/internal/PdxWriterImpl.java | 28 ++
.../geode/pdx/internal/PeerTypeRegistration.java | 11 +
.../geode/pdx/internal/TrackingPdxReaderImpl.java | 73 +++++
.../pdx/internal/WritablePdxInstanceImpl.java | 1 +
.../geode/pdx/internal/json/PdxInstanceHelper.java | 19 ++
.../geode/redis/internal/executor/ListQuery.java | 7 +
.../redis/internal/executor/SortedSetQuery.java | 46 +++
.../redis/internal/executor/hash/HashExecutor.java | 1 +
.../redis/internal/executor/list/PushExecutor.java | 1 +
.../org/apache/geode/security/Authenticator.java | 1 +
.../BaseLineAndCompareQueryPerfJUnitTest.java | 2 +
.../DiskRegionPerfJUnitPerformanceTest.java | 1 +
.../src/test/java/com/company/app/Customer.java | 1 +
.../src/test/java/com/company/app/DBLoader.java | 3 +
.../java/com/company/app/OrdersCacheListener.java | 11 +
.../test/java/com/company/data/DatabaseLoader.java | 3 +
.../test/java/com/company/data/MyDeclarable.java | 1 +
.../src/test/java/com/company/data/MySizer.java | 2 +
.../com/company/data/MyTransactionListener.java | 5 +
.../java/com/main/MyDistributedSystemListener.java | 2 +
.../test/java/org/apache/geode/UnitTestDoclet.java | 1 +
.../geode/cache/AttributesFactoryJUnitTest.java | 2 +
.../client/internal/OpExecutorImplJUnitTest.java | 1 +
.../cache/client/internal/TXFailoverOpTest.java | 2 +
.../management/MXMemoryPoolListenerExample.java | 1 +
.../org/apache/geode/cache/query/PerfQuery.java | 8 +
.../cache/query/facets/lang/DerivedEmployee.java | 1 +
.../QueryObjectSerializationJUnitTest.java | 7 +
...IndexStoreWithInplaceModificationJUnitTest.java | 2 +
.../org/apache/geode/cache30/TestDiskRegion.java | 1 +
.../deadlock/UnsafeThreadLocalJUnitTest.java | 1 +
.../geode/internal/DataSerializableJUnitTest.java | 39 +++
.../internal/DataSerializerHolderJUnitTest.java | 1 +
.../internal/OneTaskOnlyDecoratorJUnitTest.java | 5 +
.../internal/cache/AbstractRegionMapTest.java | 1 +
.../DistributedRegionSearchLoadJUnitTest.java | 1 +
.../cache/PartitionedRegionQueryEvaluatorTest.java | 8 +
.../cache/SearchLoadAndWriteProcessorTest.java | 3 +
.../geode/internal/cache/TXManagerImplTest.java | 5 +
.../cache/execute/LocalDataSetFunction.java | 5 +
.../cache/execute/PerformanceTestFunction.java | 4 +
.../rebalance/BucketOperatorWrapperTest.java | 4 +
.../cache/tier/sockets/MessageJUnitTest.java | 1 +
.../TestSerialGatewaySenderEventProcessor.java | 1 +
.../geode/internal/config/JAXBServiceTest.java | 2 +
.../internal/jta/functional/TestXACacheLoader.java | 2 +
.../geode/internal/offheap/DataTypeJUnitTest.java | 1 +
.../internal/size/ObjectTraverserJUnitTest.java | 2 +
.../geode/internal/size/ObjectTraverserPerf.java | 2 +
.../apache/geode/internal/size/SizeOfUtil0.java | 1 +
.../internal/statistics/FakeValueMonitor.java | 1 +
.../util/AbortableTaskServiceJUnitTest.java | 1 +
.../concurrent/ReentrantSemaphoreJUnitTest.java | 3 +
.../cli/shell/GfshConsoleModeUnitTest.java | 1 +
.../cli/shell/GfshHeadlessModeUnitTest.java | 1 +
.../apache/geode/sequence/DefaultLineMapper.java | 1 +
.../geode/sequence/GemfireSequenceDisplay.java | 5 +
.../org/apache/geode/sequence/HydraLineMapper.java | 1 +
.../apache/geode/sequence/SelectGraphDialog.java | 7 +
.../java/org/apache/geode/sequence/TimeAxis.java | 1 +
.../persistence/logging/SimpleFormatter.java | 1 +
.../apache/persistence/logging/StreamHandler.java | 4 +
.../RollingUpgrade2DUnitTestBase.java | 19 ++
.../RollingUpgradeConcurrentPutsReplicated.java | 2 +
.../rollingupgrade/RollingUpgradeDUnitTest.java | 11 +
.../RollingUpgradeNonHAFunction.java | 1 +
.../cache/query/cq/dunit/CqDataDUnitTest.java | 23 ++
.../cq/dunit/CqDataOptimizedExecuteDUnitTest.java | 2 +
.../CqDataUsingPoolOptimizedExecuteDUnitTest.java | 2 +
.../cache/query/cq/dunit/CqPerfDUnitTest.java | 2 +
.../query/cq/dunit/CqPerfUsingPoolDUnitTest.java | 11 +
.../cache/query/cq/dunit/CqQueryDUnitTest.java | 44 +++
.../cq/dunit/CqQueryOptimizedExecuteDUnitTest.java | 8 +
.../CqQueryUsingPoolOptimizedExecuteDUnitTest.java | 2 +
.../cq/dunit/CqResultSetUsingPoolDUnitTest.java | 25 ++
...esultSetUsingPoolOptimizedExecuteDUnitTest.java | 6 +
...SecurityPartitionedAuthorizedUserDUnitTest.java | 2 +
...curityPartitionedUnauthorizedUserDUnitTest.java | 1 +
.../cache/query/cq/dunit/CqStateDUnitTest.java | 1 +
.../cq/dunit/CqStatsOptimizedExecuteDUnitTest.java | 2 +
.../CqStatsUsingPoolOptimizedExecuteDUnitTest.java | 2 +
.../cache/query/cq/dunit/CqTimeTestListener.java | 13 +
.../dunit/PartitionedRegionCqQueryDUnitTest.java | 10 +
...onedRegionCqQueryOptimizedExecuteDUnitTest.java | 7 +
.../query/cq/dunit/PrCqUsingPoolDUnitTest.java | 19 ++
.../PrCqUsingPoolOptimizedExecuteDUnitTest.java | 2 +
.../cache/query/dunit/PdxQueryCQDUnitTest.java | 30 ++
.../cache/query/dunit/PdxQueryCQTestBase.java | 8 +
.../query/dunit/QueryIndexUpdateRIDUnitTest.java | 11 +
.../internal/cache/ha/HADispatcherDUnitTest.java | 4 +
...ltaToRegionRelationCQRegistrationDUnitTest.java | 4 +
.../sockets/DurableClientNetDownDUnitTest.java | 1 +
.../cache/tier/sockets/DurableClientTestBase.java | 12 +
.../cache/tier/sockets/DurableClientTestCase.java | 8 +
.../management/CacheServerManagementDUnitTest.java | 10 +
.../ClientCQPostAuthorizationDUnitTest.java | 1 +
.../geode/security/FilterPostAuthorization.java | 3 +
.../geode/security/FilterPreAuthorization.java | 3 +
.../security/MultiUserDurableCQAuthzDUnitTest.java | 1 +
.../org/apache/geode/security/ObjectWithAuthz.java | 2 +
.../query/cq/internal/CqAttributesMutatorImpl.java | 3 +
.../cache/query/cq/internal/CqConflatable.java | 6 +
.../geode/cache/query/cq/internal/CqEventImpl.java | 7 +
.../cache/query/cq/internal/CqListenerImpl.java | 3 +
.../cache/query/cq/internal/CqStatisticsImpl.java | 4 +
.../cache/query/cq/internal/ServerCQImpl.java | 1 +
.../geode/test/dunit/rules/CQUnitTestRule.java | 1 +
.../cache/client/internal/LocatorTestBase.java | 5 +
.../apache/geode/cache/query/QueryTestUtils.java | 10 +
.../cache/query/cq/dunit/CqQueryTestListener.java | 27 ++
.../geode/cache/query/dunit/HelperTestCase.java | 13 +
.../apache/geode/cache/query/dunit/TestObject.java | 2 +
.../OrderByPartitionedJUnitTestBase.java | 4 +
.../functional/OrderByTestImplementation.java | 3 +
.../internal/index/IndexTrackingTestHook.java | 1 +
.../geode/cache30/CacheSerializableRunnable.java | 1 +
.../cache30/CertifiableTestCacheListener.java | 15 +
.../apache/geode/cache30/ClientServerTestCase.java | 1 +
.../geode/cache30/MultiVMRegionTestCase.java | 4 +
.../org/apache/geode/cache30/RegionTestCase.java | 63 ++++
.../apache/geode/cache30/TestCacheCallback.java | 3 +
.../apache/geode/cache30/TestCacheListener.java | 3 +
.../org/apache/geode/cache30/TestCacheLoader.java | 1 +
.../membership/gms/MembershipManagerHelper.java | 2 +
.../gms/membership/GMSJoinLeaveTestHelper.java | 2 +
.../geode/internal/cache/CommitFunction.java | 5 +
.../cache/CustomerIDPartitionResolver.java | 3 +
.../internal/cache/NestedTransactionFunction.java | 5 +
.../geode/internal/cache/RollbackFunction.java | 5 +
.../cache/execute/CustomerIDPartitionResolver.java | 3 +
.../internal/cache/execute/data/Customer.java | 2 +
.../geode/internal/cache/execute/data/Order.java | 2 +
.../internal/cache/execute/data/Shipment.java | 2 +
.../internal/cache/functions/TestFunction.java | 2 +
.../sockets/ClientServerMiscDUnitTestBase.java | 1 +
.../cache/wan/AsyncEventQueueTestBase.java | 30 ++
.../org/apache/geode/management/MBeanUtil.java | 20 ++
.../geode/management/ManagementTestBase.java | 1 +
.../management/internal/cli/HeadlessGfsh.java | 2 +
.../security/ClientAuthorizationTestCase.java | 6 +
.../apache/geode/test/dunit/IgnoredException.java | 2 +
.../org/apache/geode/test/dunit/RMIException.java | 2 +
.../org/apache/geode/test/dunit/WaitCriterion.java | 1 +
.../geode/test/dunit/internal/DUnitLauncher.java | 1 +
.../dunit/internal/JUnit4DistributedTestCase.java | 1 +
.../apache/geode/test/dunit/internal/Master.java | 3 +
.../apache/geode/test/dunit/rules/MemberVM.java | 2 +
.../geode/experimental/driver/JSONWrapper.java | 1 +
.../java/com/examples/ds/CompanySerializer.java | 4 +
.../src/main/java/com/examples/ds/Employee.java | 2 +
.../src/main/java/com/examples/ds/User.java | 3 +
.../geode/cache/query/data/CollectionHolder.java | 2 +
.../geode/cache/query/data/ComparableWrapper.java | 1 +
.../apache/geode/cache/query/data/Portfolio.java | 2 +
.../geode/cache/query/data/PortfolioData.java | 1 +
.../geode/cache/query/data/PortfolioPdx.java | 2 +
.../apache/geode/cache/query/data/Position.java | 3 +
.../geode/cache/query/data/PositionNoDS.java | 1 +
.../apache/geode/cache/query/data/PositionPdx.java | 3 +
.../apache/geode/cache/query/data/TestData.java | 1 +
.../cache/query/functional/GroupByTestImpl.java | 19 ++
.../NonDistinctOrderByTestImplementation.java | 3 +
.../cache/query/functional/PdxGroupByTestImpl.java | 1 +
.../geode/cache30/MyGatewayEventFilter1.java | 6 +
.../geode/cache30/MyGatewayEventFilter2.java | 6 +
.../geode/cache30/MyGatewayTransportFilter1.java | 5 +
.../geode/cache30/MyGatewayTransportFilter2.java | 5 +
.../apache/geode/codeAnalysis/ClassAndMethods.java | 1 +
.../geode/codeAnalysis/ClassAndVariables.java | 1 +
.../geode/codeAnalysis/decode/CompiledClass.java | 1 +
.../geode/codeAnalysis/decode/CompiledField.java | 1 +
.../internal/cache/eviction/LRUTestEntry.java | 1 +
.../geode/internal/cache/execute/data/CustId.java | 2 +
.../geode/internal/cache/execute/data/OrderId.java | 2 +
.../internal/cache/execute/data/ShipmentId.java | 2 +
.../geode/internal/cache/ha/ConflatableObject.java | 6 +
.../cache/ha/TestBlockingHARegionQueue.java | 2 +
.../cache/wan/CustomAsyncEventListener.java | 2 +
.../apache/geode/internal/cache/wan/Filter70.java | 4 +
.../cache/wan/MyDistributedSystemListener.java | 2 +
.../cache/wan/MyGatewaySenderEventListener.java | 2 +
.../cache/wan/MyGatewaySenderEventListener2.java | 2 +
.../cache/wan/MyGatewayTransportFilter1.java | 3 +
.../cache/wan/MyGatewayTransportFilter2.java | 3 +
.../cache/wan/MyGatewayTransportFilter3.java | 3 +
.../cache/wan/MyGatewayTransportFilter4.java | 3 +
.../geode/internal/cache/wan/QueueListener.java | 10 +
.../cache/wan/WaitingAsyncEventListener.java | 2 +
.../org/apache/geode/internal/jta/SyncImpl.java | 2 +
.../internal/offheap/NullOffHeapMemoryStats.java | 8 +
.../internal/util/concurrent/cm/LoopHelpers.java | 1 +
.../internal/security/TestFunctions.java | 4 +
.../java/org/apache/geode/pdx/DSInsidePdx.java | 2 +
.../main/java/org/apache/geode/pdx/NestedPdx.java | 2 +
.../java/org/apache/geode/pdx/PdxInsideDS.java | 2 +
.../apache/geode/pdx/SeparateClassloaderPdx.java | 2 +
.../java/org/apache/geode/pdx/SimpleClass.java | 2 +
.../java/org/apache/geode/pdx/SimpleClass1.java | 2 +
.../junit/rules/gfsh/internal/StreamGobbler.java | 1 +
.../serializable/SerializableExternalResource.java | 1 +
.../apache/geode/test/process/ProcessWrapper.java | 1 +
.../java/org/apache/geode/util/JSR166TestCase.java | 17 +
...CategoryWithParameterizedRunnerFactoryTest.java | 1 +
.../cache/lucene/LuceneIndexCreationDUnitTest.java | 1 +
.../LuceneIndexCreationOnFixedPRDUnitTest.java | 1 +
.../cache/lucene/LuceneQueriesClientDUnitTest.java | 2 +
.../geode/cache/lucene/LuceneQueriesDUnitTest.java | 1 +
.../LuceneQueriesReindexClientDUnitTest.java | 2 +
.../geode/cache/lucene/RebalanceDUnitTest.java | 1 +
...ncyWithRegionCreatedBeforeReindexDUnitTest.java | 4 +
...hRegionCreatedBeforeReindexIntegrationTest.java | 2 +
.../NestedObjectSeralizerIntegrationTest.java | 5 +
.../repository/IndexRepositoryImplJUnitTest.java | 1 +
...onCreatedBeforeReindexIntegrationJUnitTest.java | 2 +
.../cache/lucene/PageableLuceneQueryResults.java | 2 +
.../lucene/internal/LuceneBucketListener.java | 2 +
.../internal/LuceneIndexForPartitionedRegion.java | 3 +
.../cache/lucene/internal/LuceneIndexImpl.java | 6 +
.../cache/lucene/internal/LuceneServiceImpl.java | 3 +
.../cli/functions/LuceneCreateIndexFunction.java | 2 +
.../cli/functions/LuceneDescribeIndexFunction.java | 2 +
.../cli/functions/LuceneDestroyIndexFunction.java | 1 +
.../cli/functions/LuceneListIndexFunction.java | 2 +
.../cli/functions/LuceneSearchIndexFunction.java | 2 +
.../lucene/internal/directory/RegionDirectory.java | 1 +
.../internal/filesystem/SeekableInputStream.java | 1 +
.../internal/repository/IndexRepositoryImpl.java | 1 +
.../RawLuceneRepositoryManagerJUnitTest.java | 3 +
.../LuceneSearchWithRollingUpgradeDUnit.java | 13 +
.../org/apache/geode/tools/pulse/tests/Member.java | 1 +
.../org/apache/geode/tools/pulse/tests/Region.java | 1 +
.../tools/pulse/internal/data/JMXDataUpdater.java | 1 +
.../pulse/internal/security/LogoutHandler.java | 1 +
.../internal/service/ClusterDetailsService.java | 1 +
.../service/ClusterDiskThroughputService.java | 1 +
.../internal/service/ClusterGCPausesService.java | 1 +
.../service/ClusterKeyStatisticsService.java | 1 +
.../internal/service/ClusterMemberService.java | 1 +
.../service/ClusterMembersRGraphService.java | 1 +
.../service/ClusterMemoryUsageService.java | 1 +
.../internal/service/ClusterRegionsService.java | 1 +
.../internal/service/ClusterWANInfoService.java | 1 +
.../service/MemberAsynchEventQueuesService.java | 1 +
.../internal/service/MemberClientsService.java | 1 +
.../internal/service/MemberDetailsService.java | 1 +
.../service/MemberDiskThroughputService.java | 1 +
.../internal/service/MemberGCPausesService.java | 1 +
.../internal/service/MemberGatewayHubService.java | 1 +
.../internal/service/MemberHeapUsageService.java | 1 +
.../service/MemberKeyStatisticsService.java | 1 +
.../internal/service/MemberRegionsService.java | 1 +
.../pulse/internal/service/MembersListService.java | 1 +
.../internal/service/PulseVersionService.java | 1 +
.../internal/service/SystemAlertsService.java | 1 +
.../org/apache/geode/cache/util/AutoBalancer.java | 1 +
...tewayReceiverAutoConnectionSourceDUnitTest.java | 2 +
.../cache/wan/Simple2CacheServerDUnitTest.java | 1 +
.../geode/internal/cache/wan/WANTestBase.java | 29 ++
...ParallelGatewaySenderOperation_2_DUnitTest.java | 2 +
...rentSerialGatewaySenderOperationsDUnitTest.java | 2 +
.../ConcurrentWANPropagation_1_DUnitTest.java | 2 +
.../misc/CommonParallelGatewaySenderDUnitTest.java | 2 +
...hutdownAllPersistentGatewaySenderDUnitTest.java | 6 +
...ParallelGatewaySenderOperation_2_DUnitTest.java | 2 +
.../SerialGatewaySenderEventListenerDUnitTest.java | 2 +
.../SerialGatewaySenderOperationsDUnitTest.java | 4 +
.../wan/serial/SerialWANPropagationDUnitTest.java | 2 +
.../client/internal/GatewaySenderBatchOp.java | 1 +
.../internal/locator/wan/LocatorDiscovery.java | 2 +
.../internal/locator/wan/LocatorJoinMessage.java | 3 +
.../locator/wan/LocatorMembershipListenerImpl.java | 9 +
.../locator/wan/RemoteLocatorJoinRequest.java | 3 +
.../locator/wan/RemoteLocatorJoinResponse.java | 3 +
.../locator/wan/RemoteLocatorPingRequest.java | 3 +
.../locator/wan/RemoteLocatorPingResponse.java | 3 +
.../internal/locator/wan/RemoteLocatorRequest.java | 3 +
.../locator/wan/RemoteLocatorResponse.java | 3 +
.../cache/wan/AbstractRemoteGatewaySender.java | 1 +
.../internal/cache/wan/GatewayReceiverImpl.java | 15 +
.../wan/GatewaySenderEventRemoteDispatcher.java | 2 +
.../cache/wan/GatewaySenderFactoryImpl.java | 24 ++
.../wan/parallel/ParallelGatewaySenderImpl.java | 1 +
.../RemoteParallelGatewaySenderEventProcessor.java | 1 +
.../RemoteSerialGatewaySenderEventProcessor.java | 1 +
.../cache/wan/WANRollingUpgradeDUnitTest.java | 2 +
.../web/controllers/AddFreeItemToOrders.java | 2 +
.../web/controllers/support/RegionData.java | 3 +
.../support/RestServersResultCollector.java | 5 +
.../CustomMappingJackson2HttpMessageConverter.java | 4 +
.../web/security/RestSecurityConfiguration.java | 1 +
1582 files changed, 11827 insertions(+)