This is an automated email from the ASF dual-hosted git repository.
sai_boorlagadda pushed a change to branch startlocator_command_tests
in repository https://gitbox.apache.org/repos/asf/geode.git.
from f55b621 reworked on tests
new e084d4e added startServer command unit tests
add 89f7a62 GEODE-5824: DestroyRegionCommandDUnitTest tests failed in
java 10 (#2566)
add 9bed808 GEODE-4338 - User Guide: Correction to continuous query
explanation
add 9199a9e GEODE-5829: Bind locator to 0.0.0.0 instead of localhost
(#2570)
add d185c4a GEODE-5212: fix timing issues in BeforeCompletionTest (#2565)
add fe0f50b GEODE-5212: Make rsync installation more robust
add db8ba67 GEODE-5828: fixes replicates miss transaction commit. (#2571)
add 90d2d30 GEODE-5212: Corrected powershell conditional syntax
add 0894bee GEODE-5711: Gfsh prompt for JNDI username and password
add b16b3e4 Merge pull request #2556 from gemzdude/jndi-intercept
add 5289607 GEODE-5780: remove LoggingThreadGroup
add 5bccf66 GEODE-5686: Remove LocalizedStrings
add db716cc GEODE-5820: upgrade jetty to fix jetty tests in java 9+
(#2567)
add c9792ae GEODE-2644: Add LogWriterLevel enum and test
add 9eee15e GEODE-2644: Cleanup LogLevel and expand LogLevelTest
add 2a9dd67 GEODE-2644: Cleanup custom log4j2 config logging tests
add ff40e7d GEODE-2644: Cleanup Marker Filter logging tests
add fb21c24 GEODE-2644: Cleanup logging tests
add 1c9cc15 GEODE-2644: Cleanup AlertAppenderTest
add f8bb38a GEODE-2644: Extract AlertLevel from AlertAppender
add 6bd7d6c GEODE-5686: Fix deprecated javadoc in StringId
new 4e6460f Merge branch 'develop' into startlocator_command_tests
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../windows-packer.json | 27 +-
.../geode/modules/util/CreateRegionFunction.java | 9 +-
.../geode/session/tests/ServerContainer.java | 13 +-
.../cli/commands/StartServerCommandDUnitTest.java | 32 +-
.../session/tests/GenericAppServerInstall.java | 2 +-
.../web/SwaggerVerificationIntegrationTest.java | 5 +-
.../integrationTest/resources/assembly_content.txt | 16 +-
.../resources/dependency_classpath.txt | 16 +-
.../StartLocatorCommandWorkingDirectoryTest.java | 3 -
.../StartServerCommandWorkingDirectoryTest.java | 146 +
.../CreateAndLocalDestroyInTXRegressionTest.java | 15 +-
.../management/MemoryThresholdsDUnitTest.java | 99 +-
.../MemoryThresholdsOffHeapDUnitTest.java | 39 +-
.../geode/cache/query/dunit/PDXQueryTestBase.java | 9 +-
.../ResourceManagerWithQueryMonitorDUnitTest.java | 11 +-
.../partitioned/PRColocatedEquiJoinDUnitTest.java | 6 +-
.../apache/geode/cache30/CacheXml66DUnitTest.java | 35 +-
.../geode/cache30/CacheXmlGeode10DUnitTest.java | 24 +-
.../geode/cache30/ClientServerCCEDUnitTest.java | 3 +-
.../apache/geode/cache30/LocalRegionDUnitTest.java | 2 +-
.../disttx/DistributedTransactionDUnitTest.java | 78 +-
.../cache/ClientServerTransactionDUnitTest.java | 4 +-
.../internal/cache/ConcurrentMapOpsDUnitTest.java | 2 +-
.../cache/DeltaPropagationStatsDUnitTest.java | 2 +-
.../cache/P2PDeltaPropagationDUnitTest.java | 8 +-
.../internal/cache/RemoteTransactionDUnitTest.java | 16 +-
.../geode/internal/cache/SizingFlagDUnitTest.java | 17 +-
.../internal/cache/eviction/EvictionTestBase.java | 3 +-
.../execute/MemberFunctionExecutionDUnitTest.java | 11 +-
...ientServerRegionFunctionExecutionDUnitTest.java | 5 +-
...egionFunctionExecutionNoSingleHopDUnitTest.java | 5 +-
...ctionExecutionSelectorNoSingleHopDUnitTest.java | 5 +-
...rRegionFunctionExecutionSingleHopDUnitTest.java | 5 +-
.../cache/execute/PRColocationDUnitTest.java | 4 +-
.../execute/PRFunctionExecutionDUnitTest.java | 11 +-
.../partitioned/PartitionResolverDUnitTest.java | 4 +-
...PersistentPartitionedRegionDistributedTest.java | 11 +-
.../geode/management/QueryDataDUnitTest.java | 18 +-
.../CreateJndiBindingCommandDUnitTest.java | 10 +-
.../commands/DestroyRegionCommandDUnitTest.java | 13 +-
.../ClusterConfigWithoutSecurityDUnitTest.java | 10 +-
.../security/SecurityClusterConfigDUnitTest.java | 14 +-
.../SecurityWithoutClusterConfigDUnitTest.java | 8 +-
.../java/org/apache/geode/TXJUnitTest.java | 21 +-
.../DeprecatedAgentLauncherIntegrationTest.java | 6 +-
.../AutoConnectionSourceImplJUnitTest.java | 4 +-
.../internal/ConnectionPoolImplJUnitTest.java | 4 +-
.../client/internal/QueueManagerJUnitTest.java | 4 +-
.../internal/CompiledGroupBySelectJUnitTest.java | 7 +-
.../AsyncIndexUpdaterThreadShutdownJUnitTest.java | 46 +-
.../LocatorLauncherIntegrationTest.java | 15 +-
.../ServerLauncherBuilderIntegrationTest.java | 15 +-
.../distributed/ServerLauncherIntegrationTest.java | 15 +-
.../InternalDistributedSystemJUnitTest.java | 13 +-
.../tcpserver/TCPClientSSLIntegrationTest.java | 7 +-
.../internal/tcpserver/TCPServerSSLJUnitTest.java | 7 +-
.../internal/tcpserver/TcpServerJUnitTest.java | 2 +-
.../cache/PartitionedRegionCreationJUnitTest.java | 5 +-
.../cache/control/MemoryMonitorJUnitTest.java | 7 +-
.../control/MemoryMonitorOffHeapJUnitTest.java | 8 +-
.../tier/sockets/ConnectionProxyJUnitTest.java | 4 +-
.../tier/sockets/RedundancyLevelJUnitTest.java | 4 +-
.../sockets/ServerConnectionIntegrationTest.java | 12 -
.../geode/internal/i18n/BasicI18nJUnitTest.java | 379 -
.../logging/CacheLogRollingIntegrationTest.java | 10 +-
.../DistributedSystemLogFileIntegrationTest.java | 2514 +++----
.../logging/LocatorLogFileIntegrationTest.java | 137 +-
.../logging/LogServiceIntegrationTest.java | 20 +-
.../CustomConfigWithCacheIntegrationTest.java | 143 +
.../CustomConfigWithLogServiceIntegrationTest.java | 108 +
...reVerboseMarkerFilterAcceptIntegrationTest.java | 95 +
...fireVerboseMarkerFilterDenyIntegrationTest.java | 87 +
.../GeodeVerboseLogMarkerIntegrationTest.java | 221 -
...deVerboseMarkerFilterAcceptIntegrationTest.java | 96 +
...eodeVerboseMarkerFilterDenyIntegrationTest.java | 96 +
.../CustomConfigWithCacheIntegrationTest.java | 162 -
.../CustomConfigWithLogServiceIntegrationTest.java | 128 -
.../apache/geode/codeAnalysis/excludedClasses.txt | 3 +-
.../codeAnalysis/sanctionedDataSerializables.txt | 4 +-
...CustomConfigWithCacheIntegrationTest_log4j2.xml | 26 +-
...mConfigWithLogServiceIntegrationTest_log4j2.xml | 26 +-
...oseMarkerFilterAcceptIntegrationTest_log4j2.xml | 35 +
...rboseMarkerFilterDenyIntegrationTest_log4j2.xml | 35 +
...oseMarkerFilterAcceptIntegrationTest_log4j2.xml | 35 +
...rboseMarkerFilterDenyIntegrationTest_log4j2.xml | 35 +
.../geode/internal/ra/spi/JCALocalTransaction.java | 4 +-
.../src/main/java/org/apache/geode/CopyHelper.java | 7 +-
.../main/java/org/apache/geode/DataSerializer.java | 16 +-
.../main/java/org/apache/geode/Instantiator.java | 9 +-
.../main/java/org/apache/geode/SystemFailure.java | 65 +-
.../java/org/apache/geode/admin/AdminConfig.java | 6 +-
.../geode/admin/AdminDistributedSystemFactory.java | 8 +-
.../main/java/org/apache/geode/admin/Alert.java | 2 +-
.../java/org/apache/geode/admin/AlertLevel.java | 7 +-
.../geode/admin/DistributedSystemConfig.java | 4 +-
.../java/org/apache/geode/admin/GemFireHealth.java | 7 +-
.../geode/admin/RegionSubRegionSnapshot.java | 4 +-
.../admin/internal/AbstractHealthEvaluator.java | 10 +-
.../admin/internal/AdminDistributedSystemImpl.java | 96 +-
.../geode/admin/internal/CacheHealthEvaluator.java | 15 +-
.../admin/internal/ConfigurationParameterImpl.java | 28 +-
.../internal/DistributedSystemConfigImpl.java | 46 +-
.../internal/DistributedSystemHealthEvaluator.java | 8 +-
.../internal/DistributedSystemHealthMonitor.java | 95 +-
.../internal/DistributionLocatorConfigImpl.java | 9 +-
.../admin/internal/DistributionLocatorImpl.java | 8 +-
.../internal/EnabledManagedEntityController.java | 54 +-
.../admin/internal/GemFireHealthConfigImpl.java | 8 +-
.../admin/internal/GemFireHealthEvaluator.java | 3 +-
.../geode/admin/internal/GemFireHealthImpl.java | 20 +-
.../geode/admin/internal/InetAddressUtil.java | 4 +-
.../admin/internal/ManagedEntityConfigImpl.java | 11 +-
.../admin/internal/ManagedEntityConfigXml.java | 11 +-
.../internal/ManagedEntityConfigXmlGenerator.java | 7 +-
.../internal/ManagedEntityConfigXmlParser.java | 13 +-
.../admin/internal/MemberHealthEvaluator.java | 28 +-
.../admin/internal/StatisticResourceImpl.java | 5 +-
.../internal/SystemMemberBridgeServerImpl.java | 7 +-
.../admin/internal/SystemMemberCacheImpl.java | 5 +-
.../geode/admin/internal/SystemMemberImpl.java | 14 +-
.../internal/AdminDistributedSystemJmxImpl.java | 115 +-
.../geode/admin/jmx/internal/AgentConfigImpl.java | 202 +-
.../apache/geode/admin/jmx/internal/AgentImpl.java | 122 +-
.../geode/admin/jmx/internal/AgentLauncher.java | 116 +-
.../admin/jmx/internal/CacheServerJmxImpl.java | 8 +-
.../internal/ConfigurationParameterJmxImpl.java | 4 +-
.../jmx/internal/DistributionLocatorJmxImpl.java | 5 +-
.../admin/jmx/internal/GemFireHealthJmxImpl.java | 7 +-
.../admin/jmx/internal/GenerateMBeanHTML.java | 7 +-
.../apache/geode/admin/jmx/internal/MBeanUtil.java | 74 +-
.../geode/admin/jmx/internal/MX4JModelMBean.java | 99 +-
.../geode/admin/jmx/internal/MailManager.java | 32 +-
.../jmx/internal/MemberInfoWithStatsMBean.java | 116 +-
.../jmx/internal/StatisticResourceJmxImpl.java | 6 +-
.../jmx/internal/SystemMemberCacheJmxImpl.java | 7 +-
.../geode/admin/jmx/internal/SystemMemberJmx.java | 19 +-
.../admin/jmx/internal/SystemMemberJmxImpl.java | 4 +-
.../org/apache/geode/cache/AttributesFactory.java | 143 +-
.../java/org/apache/geode/cache/CacheFactory.java | 10 +-
.../java/org/apache/geode/cache/DataPolicy.java | 9 +-
.../geode/cache/DiskWriteAttributesFactory.java | 30 +-
.../apache/geode/cache/DynamicRegionFactory.java | 100 +-
.../java/org/apache/geode/cache/LossAction.java | 5 +-
.../apache/geode/cache/MembershipAttributes.java | 4 +-
.../geode/cache/PartitionAttributesFactory.java | 4 +-
.../java/org/apache/geode/cache/RegionFactory.java | 5 +-
.../java/org/apache/geode/cache/RequiredRoles.java | 6 +-
.../org/apache/geode/cache/ResumptionAction.java | 7 +-
.../main/java/org/apache/geode/cache/Scope.java | 5 +-
.../internal/AsyncEventQueueFactoryImpl.java | 12 +-
.../internal/ParallelAsyncEventQueueImpl.java | 13 +-
.../internal/SerialAsyncEventQueueImpl.java | 15 +-
.../geode/cache/client/ClientCacheFactory.java | 3 +-
.../client/internal/AutoConnectionSourceImpl.java | 35 +-
.../client/internal/ClientMetadataService.java | 22 +-
.../client/internal/ClientPartitionAdvisor.java | 5 +-
.../client/internal/ClientSideHandshakeImpl.java | 7 +-
.../client/internal/ConnectionFactoryImpl.java | 13 +-
.../cache/client/internal/ConnectionImpl.java | 10 +-
.../internal/DataSerializerRecoveryListener.java | 11 +-
.../geode/cache/client/internal/DestroyOp.java | 4 +-
.../client/internal/ExecuteFunctionNoAckOp.java | 8 +-
.../cache/client/internal/ExecuteFunctionOp.java | 5 +-
.../internal/ExecuteRegionFunctionNoAckOp.java | 8 +-
.../client/internal/GetClientPRMetaDataOp.java | 5 +-
.../internal/GetClientPartitionAttributesOp.java | 5 +-
.../internal/InstantiatorRecoveryListener.java | 11 +-
.../geode/cache/client/internal/PoolImpl.java | 139 +-
.../cache/client/internal/QueueManagerImpl.java | 113 +-
.../client/internal/RegisterInterestTracker.java | 17 +-
.../cache/client/internal/ServerRegionProxy.java | 9 +-
.../client/internal/SingleHopClientExecutor.java | 30 +-
.../internal/pooling/ConnectionManagerImpl.java | 81 +-
.../geode/cache/execute/FunctionService.java | 4 +-
.../execute/internal/FunctionServiceManager.java | 67 +-
.../cache/partition/PartitionRegionHelper.java | 19 +-
.../geode/cache/query/CqAttributesFactory.java | 7 +-
.../query/internal/AbstractCompiledValue.java | 13 +-
.../internal/AbstractGroupOrRangeJunction.java | 4 +-
.../cache/query/internal/AttributeDescriptor.java | 23 +-
.../org/apache/geode/cache/query/internal/Bag.java | 6 +-
.../cache/query/internal/CompiledBindArgument.java | 3 +-
.../cache/query/internal/CompiledFunction.java | 4 +-
.../query/internal/CompiledGroupBySelect.java | 7 +-
.../geode/cache/query/internal/CompiledIn.java | 8 +-
.../query/internal/CompiledIndexOperation.java | 8 +-
.../cache/query/internal/CompiledIteratorDef.java | 10 +-
.../cache/query/internal/CompiledJunction.java | 18 +-
.../geode/cache/query/internal/CompiledLike.java | 4 +-
.../cache/query/internal/CompiledNegation.java | 3 +-
.../cache/query/internal/CompiledOperation.java | 7 +-
.../geode/cache/query/internal/CompiledRegion.java | 3 +-
.../geode/cache/query/internal/CompiledSelect.java | 24 +-
.../cache/query/internal/CompiledUnaryMinus.java | 5 +-
.../geode/cache/query/internal/DefaultQuery.java | 41 +-
.../cache/query/internal/DefaultQueryService.java | 61 +-
.../cache/query/internal/ExecutionContext.java | 17 +-
.../geode/cache/query/internal/Functions.java | 20 +-
.../cache/query/internal/LinkedResultSet.java | 4 +-
.../cache/query/internal/LinkedStructSet.java | 10 +-
.../geode/cache/query/internal/MethodDispatch.java | 18 +-
.../cache/query/internal/PRQueryTraceInfo.java | 7 +-
.../cache/query/internal/ProxyQueryService.java | 5 +-
.../geode/cache/query/internal/QCompiler.java | 20 +-
.../apache/geode/cache/query/internal/QRegion.java | 35 +-
.../geode/cache/query/internal/QueryMonitor.java | 11 +-
.../geode/cache/query/internal/QueryUtils.java | 5 +-
.../geode/cache/query/internal/RangeJunction.java | 28 +-
.../query/internal/ResultsCollectionWrapper.java | 10 +-
.../geode/cache/query/internal/ResultsSet.java | 4 +-
.../cache/query/internal/RuntimeIterator.java | 4 +-
.../cache/query/internal/SortedResultSet.java | 4 +-
.../cache/query/internal/SortedStructBag.java | 12 +-
.../cache/query/internal/SortedStructSet.java | 14 +-
.../geode/cache/query/internal/StructBag.java | 24 +-
.../geode/cache/query/internal/StructImpl.java | 3 +-
.../geode/cache/query/internal/StructSet.java | 19 +-
.../apache/geode/cache/query/internal/Support.java | 3 +-
.../cache/query/internal/cq/CqAttributesImpl.java | 36 +-
.../cache/query/internal/index/AbstractIndex.java | 5 +-
.../query/internal/index/CompactRangeIndex.java | 3 +-
.../cache/query/internal/index/DummyQRegion.java | 3 +-
.../index/FunctionalIndexCreationHelper.java | 61 +-
.../cache/query/internal/index/HashIndex.java | 3 +-
.../cache/query/internal/index/IndexManager.java | 52 +-
.../query/internal/index/PartitionedIndex.java | 22 +-
.../query/internal/index/PrimaryKeyIndex.java | 6 +-
.../index/PrimaryKeyIndexCreationHelper.java | 23 +-
.../cache/query/internal/index/RangeIndex.java | 45 +-
.../cache/query/internal/parse/ASTLiteral.java | 48 +-
.../cache/query/internal/parse/ASTUnsupported.java | 3 +-
.../cache/query/internal/types/StructTypeImpl.java | 5 +-
.../cache/query/internal/types/TypeUtils.java | 30 +-
.../geode/cache/server/internal/LoadMonitor.java | 9 +-
.../apache/geode/distributed/AbstractLauncher.java | 28 +-
.../geode/distributed/DistributedSystem.java | 5 +-
.../java/org/apache/geode/distributed/Locator.java | 5 +-
.../apache/geode/distributed/LocatorLauncher.java | 91 +-
.../apache/geode/distributed/ServerLauncher.java | 115 +-
.../internal/AbstractDistributionConfig.java | 590 +-
.../internal/ClusterDistributionManager.java | 743 +-
.../distributed/internal/ClusterElderManager.java | 10 +-
.../internal/CollectingReplyProcessor.java | 5 +-
.../apache/geode/distributed/internal/DSClock.java | 24 +-
.../distributed/internal/DistributionAdvisor.java | 3 +-
.../distributed/internal/DistributionConfig.java | 3 +-
.../internal/DistributionConfigImpl.java | 7 +-
.../internal/DistributionConfigSnapshot.java | 6 +-
.../distributed/internal/DistributionMessage.java | 18 +-
.../internal/FunctionExecutionPooledExecutor.java | 14 +-
.../distributed/internal/HealthMonitorImpl.java | 16 +-
.../internal/HighPriorityAckedMessage.java | 8 +-
.../internal/InternalDistributedSystem.java | 199 +-
.../distributed/internal/InternalLocator.java | 87 +-
.../distributed/internal/LocatorLoadSnapshot.java | 16 +-
.../internal/LonerDistributionManager.java | 18 +-
.../internal/PooledExecutorWithDMStats.java | 11 +-
.../geode/distributed/internal/ProductUseLog.java | 5 +-
.../internal/ReliableReplyProcessor21.java | 5 +-
.../geode/distributed/internal/ReplyException.java | 9 +-
.../distributed/internal/ReplyProcessor21.java | 55 +-
.../geode/distributed/internal/ServerLocator.java | 15 +-
.../distributed/internal/ShutdownMessage.java | 7 +-
.../geode/distributed/internal/StartupMessage.java | 51 +-
.../internal/StartupMessageReplyProcessor.java | 4 +-
.../distributed/internal/StartupOperation.java | 19 +-
.../distributed/internal/direct/DirectChannel.java | 53 +-
.../distributed/internal/locks/DLockGrantor.java | 60 +-
.../locks/DLockRecoverGrantorProcessor.java | 6 +-
.../internal/locks/DLockRequestProcessor.java | 50 +-
.../distributed/internal/locks/DLockService.java | 104 +-
.../distributed/internal/locks/DLockToken.java | 5 +-
.../internal/locks/DistributedMemberLock.java | 3 +-
.../internal/locks/ElderInitProcessor.java | 10 +-
.../distributed/internal/locks/ElderState.java | 18 +-
.../internal/locks/GrantorRequestProcessor.java | 6 +-
.../distributed/internal/locks/LockGrantorId.java | 5 +-
.../membership/InternalDistributedMember.java | 8 +-
.../internal/membership/InternalRole.java | 10 +-
.../internal/membership/gms/GMSMember.java | 4 +-
.../internal/membership/gms/GMSMemberFactory.java | 3 +-
.../internal/membership/gms/Services.java | 11 -
.../membership/gms/auth/GMSAuthenticator.java | 21 +-
.../membership/gms/fd/GMSHealthMonitor.java | 39 +-
.../membership/gms/locator/GMSLocator.java | 5 +-
.../membership/gms/membership/GMSJoinLeave.java | 38 +-
.../membership/gms/messenger/JGroupsMessenger.java | 14 +-
.../membership/gms/mgr/GMSMembershipManager.java | 167 +-
.../internal/streaming/StreamingOperation.java | 3 +-
.../distributed/internal/tcpserver/TcpServer.java | 46 +-
.../main/java/org/apache/geode/i18n/StringId.java | 6 +-
.../org/apache/geode/internal/AbstractConfig.java | 31 +-
.../java/org/apache/geode/internal/Assert.java | 3 +-
.../org/apache/geode/internal/AvailablePort.java | 14 +-
.../apache/geode/internal/DistributionLocator.java | 53 +-
.../geode/internal/HeapDataOutputStream.java | 5 +-
.../geode/internal/InternalDataSerializer.java | 131 +-
.../geode/internal/InternalInstantiator.java | 123 +-
.../org/apache/geode/internal/ManagerInfo.java | 40 +-
.../java/org/apache/geode/internal/OSProcess.java | 122 +-
.../java/org/apache/geode/internal/ObjIdMap.java | 7 +-
.../apache/geode/internal/ProcessOutputReader.java | 4 +-
.../java/org/apache/geode/internal/SmHelper.java | 9 +-
.../org/apache/geode/internal/SystemAdmin.java | 341 +-
.../org/apache/geode/internal/SystemTimer.java | 5 +-
.../apache/geode/internal/UniqueIdGenerator.java | 9 +-
.../java/org/apache/geode/internal/Version.java | 6 +-
.../apache/geode/internal/VersionDescription.java | 48 +-
.../geode/internal/admin/CacheCollector.java | 7 +-
.../admin/ClientHealthMonitoringRegion.java | 5 +-
.../geode/internal/admin/ClientStatsManager.java | 15 +-
.../internal/admin/CompoundEntrySnapshot.java | 4 +-
.../internal/admin/CompoundRegionSnapshot.java | 4 +-
.../apache/geode/internal/admin/ListenerIdMap.java | 9 +-
.../geode/internal/admin/StatAlertsManager.java | 15 +-
.../admin/remote/AddHealthListenerRequest.java | 5 +-
.../admin/remote/AddStatListenerRequest.java | 3 +-
.../remote/AdminConsoleDisconnectMessage.java | 11 +-
.../geode/internal/admin/remote/AdminRegion.java | 47 +-
.../geode/internal/admin/remote/AdminRequest.java | 12 +-
.../geode/internal/admin/remote/AdminResponse.java | 5 +-
.../geode/internal/admin/remote/AdminWaiters.java | 19 +-
.../admin/remote/AlertLevelChangeMessage.java | 5 +-
.../internal/admin/remote/BridgeServerRequest.java | 20 +-
.../internal/admin/remote/CacheConfigRequest.java | 4 +-
.../geode/internal/admin/remote/CacheDisplay.java | 4 +-
.../internal/admin/remote/CacheInfoRequest.java | 3 +-
.../admin/remote/CancelStatListenerRequest.java | 8 +-
.../admin/remote/CancelStatListenerResponse.java | 5 +-
.../internal/admin/remote/CancellationMessage.java | 5 +-
.../admin/remote/CancellationRegistry.java | 3 +-
.../internal/admin/remote/CliLegacyMessage.java | 9 +-
.../internal/admin/remote/DestroyEntryMessage.java | 11 +-
.../admin/remote/DestroyRegionMessage.java | 11 +-
.../admin/remote/DistributionLocatorId.java | 11 +-
.../internal/admin/remote/EntryValueNodeImpl.java | 7 +-
.../admin/remote/FetchDistLockInfoRequest.java | 7 +-
.../admin/remote/FetchDistLockInfoResponse.java | 5 +-
.../admin/remote/FetchHealthDiagnosisRequest.java | 11 +-
.../internal/admin/remote/FetchHostRequest.java | 7 +-
.../internal/admin/remote/FetchHostResponse.java | 7 +-
.../remote/FetchResourceAttributesRequest.java | 8 +-
.../internal/admin/remote/FetchSysCfgRequest.java | 3 +-
.../admin/remote/HealthListenerMessage.java | 5 +-
.../internal/admin/remote/LicenseInfoRequest.java | 3 +-
.../admin/remote/ObjectDetailsRequest.java | 3 +-
.../internal/admin/remote/ObjectNamesRequest.java | 3 +-
.../remote/PrepareRevokePersistentIDRequest.java | 6 +-
.../internal/admin/remote/RegionAdminRequest.java | 5 +-
.../admin/remote/RegionAttributesRequest.java | 3 +-
.../geode/internal/admin/remote/RegionRequest.java | 11 +-
.../internal/admin/remote/RegionResponse.java | 5 +-
.../internal/admin/remote/RegionSizeRequest.java | 3 +-
.../admin/remote/RegionStatisticsRequest.java | 3 +-
.../geode/internal/admin/remote/RemoteAlert.java | 3 +-
.../internal/admin/remote/RemoteBridgeServer.java | 25 +-
.../internal/admin/remote/RemoteCacheInfo.java | 5 +-
.../internal/admin/remote/RemoteGemFireVM.java | 25 +-
.../admin/remote/RemoteGfManagerAgent.java | 71 +-
.../admin/remote/RemoteRegionAttributes.java | 8 +-
.../admin/remote/RemoteTransportConfig.java | 4 +-
.../admin/remote/RemoveHealthListenerRequest.java | 3 +-
.../admin/remote/ResetHealthStatusRequest.java | 3 +-
.../internal/admin/remote/RootRegionRequest.java | 3 +-
.../internal/admin/remote/ShutdownAllRequest.java | 20 +-
.../internal/admin/remote/StoreSysCfgRequest.java | 3 +-
.../internal/admin/remote/SubRegionRequest.java | 3 +-
.../internal/admin/remote/TailLogRequest.java | 3 +-
.../internal/admin/remote/TailLogResponse.java | 11 +-
.../internal/admin/remote/VersionInfoRequest.java | 3 +-
.../internal/cache/AbstractBucketRegionQueue.java | 4 +-
.../geode/internal/cache/AbstractDiskRegion.java | 19 +-
.../geode/internal/cache/AbstractRegion.java | 86 +-
.../geode/internal/cache/AbstractRegionMap.java | 6 +-
.../internal/cache/AbstractUpdateOperation.java | 9 +-
.../apache/geode/internal/cache/BucketAdvisor.java | 50 +-
.../internal/cache/BucketPersistenceAdvisor.java | 35 +-
.../apache/geode/internal/cache/BucketRegion.java | 26 +-
.../geode/internal/cache/BucketRegionQueue.java | 4 +-
.../apache/geode/internal/cache/CacheConfig.java | 23 +-
.../internal/cache/CacheDistributionAdvisor.java | 5 +-
.../geode/internal/cache/CacheServerImpl.java | 27 +-
.../geode/internal/cache/CacheServerLauncher.java | 104 +-
.../cache/CachedDeserializableFactory.java | 11 +-
.../cache/ClientSubscriptionConfigImpl.java | 13 +-
.../geode/internal/cache/ColocationHelper.java | 11 +-
.../geode/internal/cache/ColocationLogger.java | 11 +-
.../internal/cache/CreateRegionProcessor.java | 45 +-
.../geode/internal/cache/DestroyOperation.java | 6 +-
.../cache/DestroyPartitionedRegionMessage.java | 7 +-
.../internal/cache/DestroyRegionOperation.java | 26 +-
.../org/apache/geode/internal/cache/DiskId.java | 13 +-
.../apache/geode/internal/cache/DiskInitFile.java | 74 +-
.../geode/internal/cache/DiskStoreFactoryImpl.java | 57 +-
.../apache/geode/internal/cache/DiskStoreImpl.java | 195 +-
.../geode/internal/cache/DiskStoreMonitor.java | 56 +-
.../internal/cache/DiskWriteAttributesImpl.java | 34 +-
.../geode/internal/cache/DistPeerTXStateStub.java | 9 +-
.../geode/internal/cache/DistTXCommitMessage.java | 3 +-
.../internal/cache/DistTXPrecommitMessage.java | 4 +-
.../apache/geode/internal/cache/DistTXState.java | 6 +-
.../internal/cache/DistTXStateOnCoordinator.java | 13 +-
.../cache/DistTXStateProxyImplOnCoordinator.java | 40 +-
.../cache/DistTXStateProxyImplOnDatanode.java | 4 +-
.../internal/cache/DistributedCacheOperation.java | 17 +-
.../geode/internal/cache/DistributedRegion.java | 212 +-
.../DistributedRegionFunctionStreamingMessage.java | 17 +-
.../cache/DistributedRemoveAllOperation.java | 4 +-
.../apache/geode/internal/cache/EntriesSet.java | 14 +-
.../geode/internal/cache/EntryEventImpl.java | 38 +-
.../apache/geode/internal/cache/EntrySnapshot.java | 7 +-
.../org/apache/geode/internal/cache/EventID.java | 9 +-
.../geode/internal/cache/ExpirationScheduler.java | 7 +-
.../apache/geode/internal/cache/ExpiryTask.java | 55 +-
.../apache/geode/internal/cache/FilterProfile.java | 17 +-
.../geode/internal/cache/FilterRoutingInfo.java | 2 +-
.../geode/internal/cache/GemFireCacheImpl.java | 229 +-
.../org/apache/geode/internal/cache/HARegion.java | 9 +-
.../internal/cache/InitialImageFlowControl.java | 16 +-
.../internal/cache/InitialImageOperation.java | 33 +-
.../apache/geode/internal/cache/InterestEvent.java | 6 +-
.../org/apache/geode/internal/cache/KeyInfo.java | 9 +-
.../geode/internal/cache/LoaderHelperImpl.java | 8 +-
.../apache/geode/internal/cache/LocalDataSet.java | 15 +-
.../apache/geode/internal/cache/LocalRegion.java | 340 +-
.../cache/MemberFunctionStreamingMessage.java | 18 +-
.../geode/internal/cache/NonLocalRegionEntry.java | 91 +-
.../org/apache/geode/internal/cache/Oplog.java | 253 +-
.../apache/geode/internal/cache/OverflowOplog.java | 88 +-
.../geode/internal/cache/OverflowOplogSet.java | 13 +-
.../internal/cache/PRHARedundancyProvider.java | 78 +-
.../geode/internal/cache/PRQueryProcessor.java | 12 +-
.../internal/cache/PartitionAttributesImpl.java | 54 +-
.../cache/PartitionRegionConfigValidator.java | 148 +-
.../geode/internal/cache/PartitionedRegion.java | 448 +-
.../internal/cache/PartitionedRegionDataStore.java | 81 +-
.../internal/cache/PartitionedRegionHelper.java | 66 +-
.../cache/PartitionedRegionQueryEvaluator.java | 14 +-
.../cache/PartitionedRegionRedundancyTracker.java | 7 +-
.../geode/internal/cache/PeerTXStateStub.java | 5 +-
.../geode/internal/cache/PersistentOplogSet.java | 23 +-
.../internal/cache/PlaceHolderDiskRegion.java | 10 +-
.../geode/internal/cache/PoolFactoryImpl.java | 6 +-
.../geode/internal/cache/PoolManagerImpl.java | 19 +-
.../cache/PreferBytesCachedDeserializable.java | 4 +-
.../geode/internal/cache/ProxyBucketRegion.java | 6 +-
.../geode/internal/cache/ProxyRegionMap.java | 165 +-
.../geode/internal/cache/QueuedOperation.java | 15 +-
.../geode/internal/cache/RegionEventImpl.java | 3 +-
.../geode/internal/cache/RegionNameValidation.java | 9 +-
.../cache/SearchLoadAndWriteProcessor.java | 49 +-
.../geode/internal/cache/ServerPingMessage.java | 14 +-
.../geode/internal/cache/StateFlushOperation.java | 21 +-
.../cache/StoreAllCachedDeserializable.java | 3 +-
.../geode/internal/cache/TXCommitMessage.java | 196 +-
.../org/apache/geode/internal/cache/TXEntry.java | 10 +-
.../apache/geode/internal/cache/TXEntryState.java | 50 +-
.../geode/internal/cache/TXEntryUserAttrState.java | 6 +-
.../geode/internal/cache/TXFarSideCMTracker.java | 63 +-
.../apache/geode/internal/cache/TXManagerImpl.java | 74 +-
.../org/apache/geode/internal/cache/TXMessage.java | 13 +-
.../apache/geode/internal/cache/TXRegionState.java | 12 +-
.../internal/cache/TXRemoteRollbackMessage.java | 3 +-
.../geode/internal/cache/TXReservationMgr.java | 6 +-
.../org/apache/geode/internal/cache/TXState.java | 31 +-
.../geode/internal/cache/TXStateProxyImpl.java | 26 +-
.../apache/geode/internal/cache/TXStateStub.java | 18 +-
.../geode/internal/cache/TombstoneService.java | 16 +-
.../cache/UpdateEntryVersionOperation.java | 7 +-
.../geode/internal/cache/UpdateOperation.java | 8 +-
.../internal/cache/VMCachedDeserializable.java | 3 +-
.../geode/internal/cache/VMLRURegionMap.java | 9 +-
.../geode/internal/cache/ValidatingDiskRegion.java | 3 +-
.../internal/cache/backup/BackupOperation.java | 3 +-
.../geode/internal/cache/backup/BackupService.java | 20 +-
.../cache/backup/FileSystemBackupWriter.java | 4 +-
.../internal/cache/backup/FinishBackupRequest.java | 4 +-
.../cache/backup/PrepareBackupRequest.java | 4 +-
.../CompressedCachedDeserializable.java | 7 +-
.../internal/cache/control/HeapMemoryMonitor.java | 86 +-
.../cache/control/InternalResourceManager.java | 66 +-
.../internal/cache/control/MemoryThresholds.java | 10 +-
.../cache/control/OffHeapMemoryMonitor.java | 50 +-
.../internal/cache/control/ResourceAdvisor.java | 8 +-
.../cache/entries/AbstractRegionEntry.java | 26 +-
.../geode/internal/cache/entries/DiskEntry.java | 11 +-
.../cache/eviction/AbstractEvictionList.java | 14 +-
.../internal/cache/eviction/CountLRUEviction.java | 9 +-
.../geode/internal/cache/eviction/HeapEvictor.java | 45 +-
.../internal/cache/eviction/HeapLRUController.java | 6 +-
.../cache/eviction/LRUListWithAsyncSorting.java | 23 +-
.../cache/eviction/LRUListWithSyncSorting.java | 11 +-
.../cache/eviction/MemoryLRUController.java | 5 +-
.../internal/cache/eviction/OffHeapEvictor.java | 7 +-
.../internal/cache/eviction/RegionEvictorTask.java | 4 +-
.../internal/cache/execute/AbstractExecution.java | 42 +-
.../execute/DistributedRegionFunctionExecutor.java | 59 +-
.../DistributedRegionFunctionResultSender.java | 22 +-
.../cache/execute/FunctionExecutionNodePruner.java | 5 +-
.../execute/FunctionStreamingResultCollector.java | 24 +-
.../cache/execute/InternalFunctionService.java | 14 +-
.../cache/execute/LocalResultCollectorImpl.java | 8 +-
.../cache/execute/MemberFunctionExecutor.java | 31 +-
.../cache/execute/MemberFunctionResultSender.java | 14 +-
.../cache/execute/MultiRegionFunctionExecutor.java | 35 +-
.../geode/internal/cache/execute/NoResult.java | 15 +-
.../execute/PartitionedRegionFunctionExecutor.java | 33 +-
.../PartitionedRegionFunctionResultSender.java | 16 +-
.../cache/execute/ServerFunctionExecutor.java | 24 +-
.../execute/ServerRegionFunctionExecutor.java | 28 +-
.../ServerToClientFunctionResultSender.java | 36 +-
.../ServerToClientFunctionResultSender65.java | 29 +-
.../geode/internal/cache/ha/HARegionQueue.java | 104 +-
.../internal/cache/ha/QueueRemovalMessage.java | 15 +-
.../internal/cache/locks/TXLockServiceImpl.java | 27 +-
.../cache/locks/TXOriginatorRecoveryProcessor.java | 15 +-
.../locks/TXRecoverGrantorMessageProcessor.java | 16 +-
.../cache/partitioned/BucketBackupMessage.java | 5 +-
.../cache/partitioned/BucketSizeMessage.java | 13 +-
.../cache/partitioned/ContainsKeyValueMessage.java | 21 +-
.../internal/cache/partitioned/DestroyMessage.java | 3 +-
.../internal/cache/partitioned/DumpB2NRegion.java | 4 +-
.../cache/partitioned/FetchBulkEntriesMessage.java | 23 +-
.../cache/partitioned/FetchEntriesMessage.java | 21 +-
.../cache/partitioned/FetchEntryMessage.java | 14 +-
.../cache/partitioned/FetchKeysMessage.java | 26 +-
.../internal/cache/partitioned/GetMessage.java | 15 +-
.../cache/partitioned/IndexCreationMsg.java | 20 +-
.../cache/partitioned/InvalidateMessage.java | 5 +-
.../cache/partitioned/ManageBucketMessage.java | 9 +-
.../PRFunctionStreamingResultCollector.java | 18 +-
.../partitioned/PRUpdateEntryVersionMessage.java | 3 +-
.../cache/partitioned/PartitionMessage.java | 52 +-
.../PartitionedRegionFunctionStreamingMessage.java | 9 +-
.../partitioned/PartitionedRegionRebalanceOp.java | 15 +-
.../cache/partitioned/PrimaryRequestMessage.java | 6 +-
.../internal/cache/partitioned/PutMessage.java | 5 +-
.../internal/cache/partitioned/QueryMessage.java | 16 +-
.../cache/partitioned/RedundancyLogger.java | 29 +-
.../internal/cache/partitioned/RegionAdvisor.java | 12 +-
.../cache/partitioned/RemoveIndexesMessage.java | 25 +-
.../internal/cache/partitioned/SizeMessage.java | 15 +-
.../partitioned/StreamingPartitionOperation.java | 14 +-
.../rebalance/ExplicitMoveDirector.java | 21 +-
.../rebalance/PercentageMoveDirector.java | 21 +-
.../model/PartitionedRegionLoadModel.java | 8 +-
.../cache/persistence/DiskInitFileParser.java | 5 +-
.../cache/persistence/PersistenceAdvisorImpl.java | 61 +-
.../PersistenceInitialImageAdvisor.java | 4 +-
.../cache/persistence/PersistentMemberManager.java | 16 +-
.../cache/snapshot/CacheSnapshotServiceImpl.java | 12 +-
.../internal/cache/snapshot/FlowController.java | 22 +-
.../geode/internal/cache/snapshot/GFSnapshot.java | 9 +-
.../cache/snapshot/RegionSnapshotServiceImpl.java | 32 +-
.../internal/cache/snapshot/WindowedExporter.java | 14 +-
.../cache/tier/InternalClientMembership.java | 30 +-
.../internal/cache/tier/sockets/AcceptorImpl.java | 276 +-
.../internal/cache/tier/sockets/BaseCommand.java | 63 +-
.../cache/tier/sockets/BaseCommandQuery.java | 21 +-
.../cache/tier/sockets/CacheClientNotifier.java | 98 +-
.../cache/tier/sockets/CacheClientProxy.java | 182 +-
.../cache/tier/sockets/CacheClientUpdater.java | 129 +-
.../cache/tier/sockets/CacheServerHelper.java | 9 +-
.../cache/tier/sockets/ChunkedMessage.java | 13 +-
.../cache/tier/sockets/ClientHealthMonitor.java | 57 +-
.../tier/sockets/ClientProxyMembershipID.java | 38 +-
.../cache/tier/sockets/ClientUserAuths.java | 11 +-
.../internal/cache/tier/sockets/EncryptorImpl.java | 21 +-
.../internal/cache/tier/sockets/Handshake.java | 11 +-
.../geode/internal/cache/tier/sockets/Message.java | 52 +-
.../cache/tier/sockets/MessageIdExtractor.java | 5 +-
.../tier/sockets/OriginalServerConnection.java | 7 +-
.../cache/tier/sockets/ServerConnection.java | 79 +-
.../tier/sockets/ServerSideHandshakeFactory.java | 4 +-
.../tier/sockets/ServerSideHandshakeImpl.java | 15 +-
.../cache/tier/sockets/TcpServerFactory.java | 4 +-
.../cache/tier/sockets/command/ClearRegion.java | 13 +-
.../cache/tier/sockets/command/ContainsKey.java | 20 +-
.../cache/tier/sockets/command/ContainsKey66.java | 22 +-
.../cache/tier/sockets/command/CreateRegion.java | 22 +-
.../cache/tier/sockets/command/Default.java | 13 +-
.../cache/tier/sockets/command/Destroy.java | 29 +-
.../cache/tier/sockets/command/Destroy65.java | 29 +-
.../cache/tier/sockets/command/DestroyRegion.java | 13 +-
.../tier/sockets/command/ExecuteFunction.java | 36 +-
.../tier/sockets/command/ExecuteFunction65.java | 43 +-
.../tier/sockets/command/ExecuteFunction66.java | 87 +-
.../tier/sockets/command/ExecuteFunction70.java | 3 +-
.../sockets/command/ExecuteRegionFunction.java | 51 +-
.../sockets/command/ExecuteRegionFunction61.java | 63 +-
.../sockets/command/ExecuteRegionFunction65.java | 71 +-
.../sockets/command/ExecuteRegionFunction66.java | 66 +-
.../command/ExecuteRegionFunctionSingleHop.java | 49 +-
.../sockets/command/GatewayReceiverCommand.java | 161 +-
.../internal/cache/tier/sockets/command/Get70.java | 19 +-
.../cache/tier/sockets/command/GetAll.java | 29 +-
.../cache/tier/sockets/command/GetAll651.java | 26 +-
.../cache/tier/sockets/command/GetAll70.java | 26 +-
.../tier/sockets/command/GetAllWithCallback.java | 30 +-
.../command/GetClientPRMetadataCommand.java | 14 +-
.../command/GetClientPRMetadataCommand66.java | 14 +-
.../GetClientPartitionAttributesCommand.java | 18 +-
.../GetClientPartitionAttributesCommand66.java | 16 +-
.../tier/sockets/command/GetFunctionAttribute.java | 9 +-
.../cache/tier/sockets/command/Invalid.java | 11 +-
.../cache/tier/sockets/command/Invalidate.java | 26 +-
.../cache/tier/sockets/command/KeySet.java | 15 +-
.../internal/cache/tier/sockets/command/Put.java | 35 +-
.../internal/cache/tier/sockets/command/Put61.java | 7 +-
.../internal/cache/tier/sockets/command/Put65.java | 7 +-
.../cache/tier/sockets/command/PutAll.java | 13 +-
.../cache/tier/sockets/command/PutAll70.java | 13 +-
.../cache/tier/sockets/command/PutAll80.java | 13 +-
.../tier/sockets/command/PutUserCredentials.java | 9 +-
.../sockets/command/RegisterInstantiators.java | 6 +-
.../tier/sockets/command/RegisterInterest.java | 21 +-
.../tier/sockets/command/RegisterInterest61.java | 21 +-
.../tier/sockets/command/RegisterInterestList.java | 23 +-
.../sockets/command/RegisterInterestList61.java | 23 +-
.../sockets/command/RegisterInterestList66.java | 21 +-
.../cache/tier/sockets/command/RemoveAll.java | 18 +-
.../cache/tier/sockets/command/RemoveUserAuth.java | 9 +-
.../cache/tier/sockets/command/Request.java | 19 +-
.../tier/sockets/command/RequestEventValue.java | 12 +-
.../internal/cache/tier/sockets/command/Size.java | 15 +-
.../tier/sockets/command/UnregisterInterest.java | 12 +-
.../sockets/command/UnregisterInterestList.java | 12 +-
.../cache/tx/AbstractPeerTXRegionStub.java | 9 +-
.../geode/internal/cache/tx/ClientTXStateStub.java | 3 +-
.../internal/cache/tx/DistClientTXStateStub.java | 37 +-
.../internal/cache/tx/DistributedTXRegionStub.java | 37 +-
.../internal/cache/tx/PartitionedTXRegionStub.java | 68 +-
.../internal/cache/tx/RemoteClearMessage.java | 3 +-
.../cache/tx/RemoteContainsKeyValueMessage.java | 9 +-
.../internal/cache/tx/RemoteDestroyMessage.java | 3 +-
.../internal/cache/tx/RemoteFetchEntryMessage.java | 5 +-
.../internal/cache/tx/RemoteFetchKeysMessage.java | 6 +-
.../cache/tx/RemoteFetchVersionMessage.java | 3 +-
.../geode/internal/cache/tx/RemoteGetMessage.java | 13 +-
.../internal/cache/tx/RemoteInvalidateMessage.java | 5 +-
.../internal/cache/tx/RemoteOperationMessage.java | 5 +-
.../internal/cache/tx/RemotePutAllMessage.java | 3 +-
.../geode/internal/cache/tx/RemotePutMessage.java | 8 +-
.../internal/cache/tx/RemoteRemoveAllMessage.java | 3 +-
.../cache/versions/RegionVersionVector.java | 7 +-
.../internal/cache/wan/AbstractGatewaySender.java | 103 +-
.../wan/AbstractGatewaySenderEventProcessor.java | 80 +-
.../internal/cache/wan/GatewaySenderAdvisor.java | 172 +-
.../wan/GatewaySenderEventCallbackDispatcher.java | 14 +-
.../internal/cache/wan/GatewaySenderEventImpl.java | 4 +-
...aySenderQueueEntrySynchronizationOperation.java | 11 +-
...currentParallelGatewaySenderEventProcessor.java | 35 +-
.../ParallelGatewaySenderEventProcessor.java | 12 +-
.../wan/parallel/ParallelGatewaySenderQueue.java | 68 +-
.../wan/parallel/ParallelQueueRemovalMessage.java | 23 +-
.../cache/wan/serial/BatchDestroyOperation.java | 14 +-
...oncurrentSerialGatewaySenderEventProcessor.java | 36 +-
.../serial/SerialGatewaySenderEventProcessor.java | 82 +-
.../cache/wan/serial/SerialGatewaySenderQueue.java | 31 +-
.../internal/cache/xmlcache/AbstractXmlParser.java | 5 +-
.../internal/cache/xmlcache/CacheCreation.java | 379 +-
.../cache/xmlcache/CacheServerCreation.java | 5 +-
.../xmlcache/CacheTransactionManagerCreation.java | 43 +-
.../geode/internal/cache/xmlcache/CacheXml.java | 7 +-
.../internal/cache/xmlcache/CacheXmlGenerator.java | 14 +-
.../internal/cache/xmlcache/CacheXmlParser.java | 262 +-
.../cache/xmlcache/CacheXmlPropertyResolver.java | 7 +-
.../xmlcache/CacheXmlPropertyResolverHelper.java | 8 +-
.../cache/xmlcache/ClientCacheCreation.java | 33 +-
.../cache/xmlcache/ClientHaQueueCreation.java | 13 +-
.../xmlcache/DiskStoreAttributesCreation.java | 67 +-
.../cache/xmlcache/RegionAttributesCreation.java | 127 +-
.../internal/cache/xmlcache/RegionCreation.java | 204 +-
.../cache/xmlcache/SerializerCreation.java | 7 +-
.../internal/datasource/AbstractDataSource.java | 6 +-
.../internal/datasource/AbstractPoolCache.java | 13 +-
.../datasource/ConnectionPoolCacheImpl.java | 7 +-
.../internal/datasource/DataSourceFactory.java | 108 +-
.../datasource/FacetsJCAConnectionManagerImpl.java | 27 +-
.../datasource/GemFireBasicDataSource.java | 19 +-
.../datasource/GemFireConnPooledDataSource.java | 20 +-
.../datasource/GemFireTransactionDataSource.java | 15 +-
.../datasource/JCAConnectionManagerImpl.java | 26 +-
.../internal/datasource/ManagedPoolCacheImpl.java | 4 +-
.../internal/datasource/TranxPoolCacheImpl.java | 7 +-
.../geode/internal/i18n/LocalizedStrings.java | 7759 --------------------
.../io/MainWithChildrenRollingFileHandler.java | 30 +-
.../geode/internal/io/RollingFileHandler.java | 5 +-
.../apache/geode/internal/jndi/ContextImpl.java | 93 +-
.../apache/geode/internal/jndi/JNDIInvoker.java | 37 +-
.../geode/internal/jta/GlobalTransaction.java | 121 +-
.../apache/geode/internal/jta/TransactionImpl.java | 39 +-
.../geode/internal/jta/TransactionManagerImpl.java | 168 +-
.../geode/internal/jta/TransactionUtils.java | 10 +-
.../geode/internal/jta/UserTransactionImpl.java | 10 +-
.../geode/internal/logging/GemFireFormatter.java | 3 +-
.../geode/internal/logging/LocalLogWriter.java | 4 +-
.../geode/internal/logging/LogFileParser.java | 7 +-
.../geode/internal/logging/LogWriterFactory.java | 8 +-
.../geode/internal/logging/LogWriterImpl.java | 66 +-
.../LogWriterLevel.java} | 37 +-
.../geode/internal/logging/LoggingExecutors.java | 306 +
.../geode/internal/logging/LoggingThread.java | 58 +
.../internal/logging/LoggingThreadFactory.java | 131 +
.../geode/internal/logging/LoggingThreadGroup.java | 22 +-
.../logging/LoggingUncaughtExceptionHandler.java | 107 +
.../geode/internal/logging/ManagerLogWriter.java | 8 +-
.../geode/internal/logging/MergeLogFiles.java | 52 +-
.../geode/internal/logging/PureLogWriter.java | 9 +-
.../apache/geode/internal/logging/SortLogFile.java | 16 +-
.../internal/logging/log4j/AlertAppender.java | 48 +-
.../geode/internal/logging/log4j/AlertLevel.java | 61 +
.../internal/logging/log4j/LocalizedMessage.java | 80 -
.../geode/internal/logging/log4j/LogLevel.java | 12 +-
.../internal/logging/log4j/LogWriterAppenders.java | 17 +-
.../memcached/commands/StorageCommand.java | 12 +-
.../internal/monitoring/ThreadsMonitoringImpl.java | 3 +-
.../apache/geode/internal/net/SocketCloser.java | 28 +-
.../apache/geode/internal/net/SocketCreator.java | 41 +-
.../DisconnectingOutOfOffHeapMemoryListener.java | 7 +-
.../geode/internal/offheap/OffHeapStorage.java | 9 +-
.../internal/process/ControlFileWatchdog.java | 4 +-
.../internal/process/FileProcessController.java | 3 +-
.../internal/process/ProcessStreamReader.java | 8 +-
.../geode/internal/process/StartupStatus.java | 7 +-
.../geode/internal/security/AuthorizeRequest.java | 136 +-
.../internal/security/AuthorizeRequestPP.java | 45 +-
.../statistics/AbstractStatisticsFactory.java | 3 +-
.../geode/internal/statistics/ArchiveSplitter.java | 27 +-
.../geode/internal/statistics/CallbackSampler.java | 12 +-
.../internal/statistics/GemFireStatSampler.java | 14 +-
.../geode/internal/statistics/HostStatHelper.java | 25 +-
.../geode/internal/statistics/HostStatSampler.java | 25 +-
.../statistics/LocalStatisticsFactory.java | 6 +-
.../geode/internal/statistics/ResourceType.java | 3 +-
.../geode/internal/statistics/SampleCollector.java | 8 +-
.../internal/statistics/SimpleStatSampler.java | 5 +-
.../internal/statistics/StatArchiveHandler.java | 42 +-
.../internal/statistics/StatArchiveReader.java | 44 +-
.../internal/statistics/StatArchiveWriter.java | 70 +-
.../internal/statistics/StatMonitorHandler.java | 4 +-
.../statistics/StatisticDescriptorImpl.java | 27 +-
.../geode/internal/statistics/StatisticsImpl.java | 9 +-
.../statistics/StatisticsTypeFactoryImpl.java | 5 +-
.../internal/statistics/StatisticsTypeImpl.java | 19 +-
.../internal/statistics/StatisticsTypeXml.java | 30 +-
.../statistics/platform/LinuxProcFsStatistics.java | 2 +-
.../internal/stats50/Atomic50StatisticsImpl.java | 16 +-
.../geode/internal/tcp/ConnectExceptions.java | 7 +-
.../org/apache/geode/internal/tcp/Connection.java | 501 +-
.../apache/geode/internal/tcp/ConnectionTable.java | 86 +-
.../geode/internal/tcp/DirectReplySender.java | 9 +-
.../apache/geode/internal/tcp/MsgDestreamer.java | 12 +-
.../apache/geode/internal/tcp/MsgOutputStream.java | 7 +-
.../org/apache/geode/internal/tcp/MsgStreamer.java | 8 +-
.../apache/geode/internal/tcp/ServerDelegate.java | 4 +-
.../org/apache/geode/internal/tcp/TCPConduit.java | 194 +-
.../apache/geode/internal/util/Breadcrumbs.java | 5 +-
.../org/apache/geode/internal/util/StopWatch.java | 3 +-
.../concurrent/CustomEntryConcurrentHashMap.java | 4 +-
.../internal/util/concurrent/FutureResult.java | 7 +-
.../concurrent/StoppableCountDownOrUpLatch.java | 3 +-
.../util/concurrent/StoppableNonReentrantLock.java | 4 +-
.../geode/management/cli/CommandService.java | 6 +-
.../management/internal/FederatingManager.java | 5 +-
.../geode/management/internal/JettyHelper.java | 2 +-
.../management/internal/JmxManagerAdvisor.java | 5 +-
.../geode/management/internal/LocalManager.java | 37 +-
.../internal/MXBeanProxyInvocationHandler.java | 6 +-
.../management/internal/ManagementFunction.java | 5 +-
.../management/internal/ManagementStrings.java | 195 -
.../geode/management/internal/NotificationHub.java | 6 +-
.../internal/SystemManagementService.java | 22 +-
.../internal/beans/AsyncEventQueueMBeanBridge.java | 8 +-
.../internal/beans/DiskStoreMBeanBridge.java | 5 +-
.../internal/beans/DistributedSystemBridge.java | 31 +-
.../internal/beans/GatewaySenderMBeanBridge.java | 6 +-
.../internal/beans/LocatorMBeanBridge.java | 12 +-
.../management/internal/beans/MBeanAggregator.java | 6 +-
.../internal/beans/ManagementListener.java | 6 +-
.../internal/beans/MemberMBeanBridge.java | 54 +-
.../internal/beans/QueryDataFunction.java | 35 +-
.../internal/beans/RegionMBeanBridge.java | 5 +-
.../management/internal/beans/ServerBridge.java | 5 +-
.../internal/beans/stats/StatsAggregator.java | 6 +-
.../management/internal/cli/GfshParseResult.java | 4 +
.../geode/management/internal/cli/LogWrapper.java | 4 +-
.../cli/commands/CreateJndiBindingCommand.java | 5 +-
.../internal/cli/commands/CreateRegionCommand.java | 14 +-
.../internal/cli/commands/RebalanceCommand.java | 5 +-
.../internal/cli/commands/ShutdownCommand.java | 4 +-
.../cli/commands/StartGatewaySenderCommand.java | 15 +-
.../internal/cli/commands/StartMemberUtils.java | 2 +-
.../internal/cli/commands/StartServerCommand.java | 38 +-
.../cli/commands/UsernamePasswordInterceptor.java | 50 +
.../cli/functions/RegionCreateFunction.java | 3 +-
.../internal/cli/functions/ShutDownFunction.java | 4 +-
.../management/internal/cli/i18n/CliStrings.java | 3 +
.../geode/management/internal/cli/shell/Gfsh.java | 3 +-
.../internal/cli/util/DiskStoreCompacter.java | 7 +-
.../internal/cli/util/DiskStoreUpgrader.java | 7 +-
.../UniversalMembershipListenerAdapter.java | 5 +-
.../pdx/internal/AutoSerializableManager.java | 5 +-
.../org/apache/geode/pdx/internal/EnumInfo.java | 5 +-
.../apache/geode/pdx/internal/PdxInstanceEnum.java | 5 +-
.../apache/geode/pdx/internal/PdxReaderImpl.java | 9 +-
.../apache/geode/pdx/internal/TypeRegistry.java | 9 +-
.../org/apache/geode/redis/GeodeRedisServer.java | 3 +-
.../sanctioned-geode-core-serializables.txt | 1 +
.../java/org/apache/geode/cache30/TestHeapLRU.java | 36 +-
.../internal/ServerLocatorJUnitTest.java | 4 +-
.../GMSAuthenticatorWithAuthenticatorTest.java | 12 -
.../GMSAuthenticatorWithSecurityManagerTest.java | 12 -
.../geode/internal/GemFireVersionJUnitTest.java | 9 +-
.../geode/internal/cache/BeforeCompletionTest.java | 12 +-
.../geode/internal/cache/ColocationHelperTest.java | 16 +-
.../internal/cache/RegionNameValidationTest.java | 13 +-
.../geode/internal/cache/TXCommitMessageTest.java | 60 +
.../internal/cache/TXFarSideCMTrackerTest.java | 119 +
.../internal/cache/tier/sockets/HandshakeTest.java | 3 +-
.../cache/tier/sockets/ServerConnectionTest.java | 15 +-
.../cache/tier/sockets/TcpServerFactoryTest.java | 2 +-
.../Configuration.java => LogWriterLevelTest.java} | 33 +-
.../internal/logging/LoggingThreadFactoryTest.java | 116 +
.../geode/internal/logging/LoggingThreadTest.java | 73 +
.../LoggingUncaughtExceptionHandlerTest.java | 117 +
...penderJUnitTest.java => AlertAppenderTest.java} | 78 +-
.../internal/logging/log4j/AlertLevelTest.java | 137 +
.../internal/logging/log4j/FastLoggerTest.java | 128 +-
.../log4j/HexThreadIdPatternConverterTest.java | 3 +
.../logging/log4j/LocalizedMessageJUnitTest.java | 56 -
.../geode/internal/logging/log4j/LogLevelTest.java | 454 +-
.../logging/log4j/custom/BasicAppender.java | 74 -
.../geode/internal/process/StartupStatusTest.java | 13 +-
.../commands/UsernamePasswordInterceptorTest.java | 136 +
.../cli/shell/GfshExecutionStrategyTest.java | 43 +
geode-core/src/test/resources/expected-pom.xml | 2 +-
.../log4j/marker/log4j2-gemfire_verbose-accept.xml | 40 -
.../log4j/marker/log4j2-gemfire_verbose-deny.xml | 40 -
.../log4j/marker/log4j2-geode_verbose-accept.xml | 40 -
.../log4j/marker/log4j2-geode_verbose-deny.xml | 40 -
.../RollingUpgrade2DUnitTestBase.java | 4 +-
.../cache/query/cq/dunit/CqQueryDUnitTest.java | 5 +-
.../cache/query/dunit/PdxQueryCQTestBase.java | 15 +-
.../geode/internal/cache/PutAllCSDUnitTest.java | 46 +-
.../cache/RemoteCQTransactionDUnitTest.java | 2 +-
.../tier/sockets/ClientToServerDeltaDUnitTest.java | 6 +-
.../tier/sockets/DurableClientCQDUnitTest.java | 25 +-
.../geode/security/FilterPostAuthorization.java | 20 +-
.../geode/security/FilterPreAuthorization.java | 6 +-
.../cache/query/internal/cq/ClientCQImpl.java | 103 +-
.../query/internal/cq/CqAttributesMutatorImpl.java | 7 +-
.../cache/query/internal/cq/CqConflatable.java | 3 +-
.../geode/cache/query/internal/cq/CqEventImpl.java | 4 +-
.../cache/query/internal/cq/CqListenerImpl.java | 5 +-
.../geode/cache/query/internal/cq/CqQueryImpl.java | 32 +-
.../cache/query/internal/cq/CqServiceImpl.java | 110 +-
.../cache/query/internal/cq/ServerCQImpl.java | 30 +-
.../cache/tier/sockets/command/CloseCQ.java | 7 +-
.../cache/tier/sockets/command/ExecuteCQ.java | 3 +-
.../cache/tier/sockets/command/ExecuteCQ61.java | 6 +-
.../cache/tier/sockets/command/MonitorCQ.java | 16 +-
.../cache/tier/sockets/command/StopCQ.java | 7 +-
.../query/internal/cq/CqServiceImplJUnitTest.java | 3 +-
.../implementing_continuous_querying.html.md.erb | 2 -
.../java/batterytest/greplogs/ExpectedStrings.java | 2 +
.../org/apache/geode/management/MBeanUtil.java | 16 +-
.../cli/commands/QueryCommandDUnitTestBase.java | 6 +-
.../geode/cache/query/data/PortfolioPdx.java | 4 +-
.../apache/geode/cache/query/data/PositionPdx.java | 6 +-
.../internal/logging/TestLogWriterFactory.java | 19 +-
.../cache/lucene/LuceneIndexCreationDUnitTest.java | 6 +-
.../cache/lucene/LuceneIndexDestroyDUnitTest.java | 6 +-
.../cli/DestroyLuceneIndexCommandsDUnitTest.java | 9 +-
.../cli/LuceneIndexCommandsIntegrationTest.java | 13 +-
.../cache/lucene/LuceneIndexExistsException.java | 5 +-
.../CreateLuceneCommandParametersValidator.java | 5 +-
.../lucene/internal/DestroyLuceneIndexMessage.java | 5 +-
.../internal/LuceneIndexCreationProfile.java | 45 +-
.../internal/LuceneIndexForPartitionedRegion.java | 5 +-
.../cache/lucene/internal/LuceneIndexImpl.java | 3 +-
.../lucene/internal/LuceneRegionListener.java | 5 +-
.../cache/lucene/internal/LuceneServiceImpl.java | 44 +-
.../cache/lucene/internal/StringQueryProvider.java | 5 +-
.../internal/distributed/LuceneQueryFunction.java | 7 +-
.../lucene/internal/xml/LuceneIndexCreation.java | 5 +-
.../cache/lucene/internal/xml/LuceneXmlParser.java | 7 +-
.../security/SecureFunctionServiceImpl.java | 5 +-
.../geode/internal/cache/wan/WANTestBase.java | 2 +-
.../wan/misc/NewWanAuthenticationDUnitTest.java | 4 +-
.../cache/wan/misc/WANConfigurationJUnitTest.java | 4 +-
.../client/internal/GatewaySenderBatchOp.java | 5 +-
.../internal/locator/wan/LocatorDiscovery.java | 46 +-
.../locator/wan/LocatorMembershipListenerImpl.java | 14 +-
.../locator/wan/WanLocatorDiscovererImpl.java | 17 +-
.../cache/wan/AbstractRemoteGatewaySender.java | 44 +-
.../cache/wan/GatewayReceiverFactoryImpl.java | 4 +-
.../internal/cache/wan/GatewayReceiverImpl.java | 14 +-
.../wan/GatewaySenderEventRemoteDispatcher.java | 101 +-
.../cache/wan/GatewaySenderFactoryImpl.java | 44 +-
.../wan/parallel/ParallelGatewaySenderImpl.java | 13 +-
.../cache/wan/serial/SerialGatewaySenderImpl.java | 15 +-
.../internal/web/swagger/config/SwaggerConfig.java | 15 +-
.../cli/commands/AlterRuntimeCommandDUnitTest.java | 14 +-
gradle/dependency-versions.properties | 2 +-
905 files changed, 14322 insertions(+), 24334 deletions(-)
create mode 100644
geode-assembly/src/test/java/org/apache/geode/management/internal/cli/commands/StartServerCommandWorkingDirectoryTest.java
delete mode 100755
geode-core/src/integrationTest/java/org/apache/geode/internal/i18n/BasicI18nJUnitTest.java
create mode 100644
geode-core/src/integrationTest/java/org/apache/geode/internal/logging/log4j/CustomConfigWithCacheIntegrationTest.java
create mode 100644
geode-core/src/integrationTest/java/org/apache/geode/internal/logging/log4j/CustomConfigWithLogServiceIntegrationTest.java
create mode 100644
geode-core/src/integrationTest/java/org/apache/geode/internal/logging/log4j/GemfireVerboseMarkerFilterAcceptIntegrationTest.java
create mode 100644
geode-core/src/integrationTest/java/org/apache/geode/internal/logging/log4j/GemfireVerboseMarkerFilterDenyIntegrationTest.java
delete mode 100644
geode-core/src/integrationTest/java/org/apache/geode/internal/logging/log4j/GeodeVerboseLogMarkerIntegrationTest.java
create mode 100644
geode-core/src/integrationTest/java/org/apache/geode/internal/logging/log4j/GeodeVerboseMarkerFilterAcceptIntegrationTest.java
create mode 100644
geode-core/src/integrationTest/java/org/apache/geode/internal/logging/log4j/GeodeVerboseMarkerFilterDenyIntegrationTest.java
delete mode 100644
geode-core/src/integrationTest/java/org/apache/geode/internal/logging/log4j/custom/CustomConfigWithCacheIntegrationTest.java
delete mode 100644
geode-core/src/integrationTest/java/org/apache/geode/internal/logging/log4j/custom/CustomConfigWithLogServiceIntegrationTest.java
rename
geode-core/src/integrationTest/resources/org/apache/geode/internal/logging/log4j/{custom
=> }/CustomConfigWithCacheIntegrationTest_log4j2.xml (62%)
rename
geode-core/src/integrationTest/resources/org/apache/geode/internal/logging/log4j/{custom
=> }/CustomConfigWithLogServiceIntegrationTest_log4j2.xml (62%)
create mode 100644
geode-core/src/integrationTest/resources/org/apache/geode/internal/logging/log4j/GemfireVerboseMarkerFilterAcceptIntegrationTest_log4j2.xml
create mode 100644
geode-core/src/integrationTest/resources/org/apache/geode/internal/logging/log4j/GemfireVerboseMarkerFilterDenyIntegrationTest_log4j2.xml
create mode 100644
geode-core/src/integrationTest/resources/org/apache/geode/internal/logging/log4j/GeodeVerboseMarkerFilterAcceptIntegrationTest_log4j2.xml
create mode 100644
geode-core/src/integrationTest/resources/org/apache/geode/internal/logging/log4j/GeodeVerboseMarkerFilterDenyIntegrationTest_log4j2.xml
delete mode 100755
geode-core/src/main/java/org/apache/geode/internal/i18n/LocalizedStrings.java
rename
geode-core/src/main/java/org/apache/geode/internal/{cache/GemfireCacheHelper.java
=> logging/LogWriterLevel.java} (51%)
mode change 100755 => 100644
create mode 100644
geode-core/src/main/java/org/apache/geode/internal/logging/LoggingExecutors.java
create mode 100644
geode-core/src/main/java/org/apache/geode/internal/logging/LoggingThread.java
create mode 100644
geode-core/src/main/java/org/apache/geode/internal/logging/LoggingThreadFactory.java
create mode 100644
geode-core/src/main/java/org/apache/geode/internal/logging/LoggingUncaughtExceptionHandler.java
create mode 100644
geode-core/src/main/java/org/apache/geode/internal/logging/log4j/AlertLevel.java
delete mode 100644
geode-core/src/main/java/org/apache/geode/internal/logging/log4j/LocalizedMessage.java
delete mode 100644
geode-core/src/main/java/org/apache/geode/management/internal/ManagementStrings.java
create mode 100644
geode-core/src/main/java/org/apache/geode/management/internal/cli/commands/UsernamePasswordInterceptor.java
create mode 100644
geode-core/src/test/java/org/apache/geode/internal/cache/TXCommitMessageTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/internal/cache/TXFarSideCMTrackerTest.java
rename
geode-core/src/test/java/org/apache/geode/internal/logging/{log4j/Configuration.java
=> LogWriterLevelTest.java} (51%)
create mode 100644
geode-core/src/test/java/org/apache/geode/internal/logging/LoggingThreadFactoryTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/internal/logging/LoggingThreadTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/internal/logging/LoggingUncaughtExceptionHandlerTest.java
rename
geode-core/src/test/java/org/apache/geode/internal/logging/log4j/{AlertAppenderJUnitTest.java
=> AlertAppenderTest.java} (78%)
create mode 100644
geode-core/src/test/java/org/apache/geode/internal/logging/log4j/AlertLevelTest.java
delete mode 100644
geode-core/src/test/java/org/apache/geode/internal/logging/log4j/LocalizedMessageJUnitTest.java
delete mode 100644
geode-core/src/test/java/org/apache/geode/internal/logging/log4j/custom/BasicAppender.java
create mode 100644
geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/UsernamePasswordInterceptorTest.java
delete mode 100644
geode-core/src/test/resources/org/apache/geode/internal/logging/log4j/marker/log4j2-gemfire_verbose-accept.xml
delete mode 100644
geode-core/src/test/resources/org/apache/geode/internal/logging/log4j/marker/log4j2-gemfire_verbose-deny.xml
delete mode 100644
geode-core/src/test/resources/org/apache/geode/internal/logging/log4j/marker/log4j2-geode_verbose-accept.xml
delete mode 100644
geode-core/src/test/resources/org/apache/geode/internal/logging/log4j/marker/log4j2-geode_verbose-deny.xml
