You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by sa...@apache.org on 2018/10/08 20:09:36 UTC
[geode] branch startlocator_command_tests updated (f55b621 ->
4e6460f)
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
[geode] 01/02: added startServer command unit tests
Posted by sa...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
sai_boorlagadda pushed a commit to branch startlocator_command_tests
in repository https://gitbox.apache.org/repos/asf/geode.git
commit e084d4ee9e97fd035baa3ed82c11560592291fc8
Author: Sai Boorlagadda <sb...@pivotal.io>
AuthorDate: Mon Oct 8 13:08:48 2018 -0700
added startServer command unit tests
---
.../cli/commands/StartServerCommandDUnitTest.java | 32 +----
.../StartLocatorCommandWorkingDirectoryTest.java | 3 -
.../StartServerCommandWorkingDirectoryTest.java | 146 +++++++++++++++++++++
.../internal/cli/commands/StartMemberUtils.java | 2 +-
.../internal/cli/commands/StartServerCommand.java | 38 +++++-
5 files changed, 185 insertions(+), 36 deletions(-)
diff --git a/geode-assembly/src/distributedTest/java/org/apache/geode/management/internal/cli/commands/StartServerCommandDUnitTest.java b/geode-assembly/src/distributedTest/java/org/apache/geode/management/internal/cli/commands/StartServerCommandDUnitTest.java
index 2d884c1..eb75315 100644
--- a/geode-assembly/src/distributedTest/java/org/apache/geode/management/internal/cli/commands/StartServerCommandDUnitTest.java
+++ b/geode-assembly/src/distributedTest/java/org/apache/geode/management/internal/cli/commands/StartServerCommandDUnitTest.java
@@ -41,7 +41,6 @@ import java.net.InetSocketAddress;
import java.net.Socket;
import java.nio.file.Paths;
-import org.apache.commons.io.FileUtils;
import org.junit.AfterClass;
import org.junit.Before;
import org.junit.BeforeClass;
@@ -67,6 +66,7 @@ import org.apache.geode.test.dunit.rules.ClusterStartupRule;
import org.apache.geode.test.dunit.rules.MemberVM;
import org.apache.geode.test.dunit.rules.SharedErrorCollector;
import org.apache.geode.test.junit.rules.GfshCommandRule;
+import org.apache.geode.test.junit.rules.RequiresGeodeHome;
public class StartServerCommandDUnitTest {
@@ -78,6 +78,9 @@ public class StartServerCommandDUnitTest {
private int serverPort;
@ClassRule
+ public static RequiresGeodeHome requiresGeodeHome = new RequiresGeodeHome();
+
+ @ClassRule
public static ClusterStartupRule cluster = new ClusterStartupRule();
@ClassRule
@@ -240,33 +243,6 @@ public class StartServerCommandDUnitTest {
}
@Test
- public void testWithMissingStartDirectoryThatCanBeCreated() {
- // path to a missing dir that can be created
- String readWritePathname = "readWriteDir";
- File readWriteDir = new File(readWritePathname);
- String missingDirPath =
- Paths.get(readWritePathname, "missing", "dir", "to", "start", "in").toString();
-
- String expectedMessage = "Server in .*" + missingDirPath.replace("\\", "\\\\");
-
- String command = new CommandStringBuilder(START_SERVER)
- .addOption(START_SERVER__NAME, memberName)
- .addOption(START_SERVER__LOCATORS, locatorConnectionString)
- .addOption(START_SERVER__SERVER_PORT, String.valueOf(serverPort))
- .addOption(START_SERVER__DIR, missingDirPath)
- .getCommandString();
-
- try {
- CommandResult result = gfsh.executeCommand(command);
-
- assertThat(result.getStatus()).isEqualTo(Result.Status.OK);
- assertThat(result.getMessageFromContent()).containsPattern(expectedMessage);
- } finally {
- FileUtils.deleteQuietly(readWriteDir);
- }
- }
-
- @Test
public void testWithConflictingPIDFile() throws Exception {
String fileName = ProcessType.SERVER.getPidFileName();
diff --git a/geode-assembly/src/test/java/org/apache/geode/management/internal/cli/commands/StartLocatorCommandWorkingDirectoryTest.java b/geode-assembly/src/test/java/org/apache/geode/management/internal/cli/commands/StartLocatorCommandWorkingDirectoryTest.java
index bb4c751..5e0b75f 100644
--- a/geode-assembly/src/test/java/org/apache/geode/management/internal/cli/commands/StartLocatorCommandWorkingDirectoryTest.java
+++ b/geode-assembly/src/test/java/org/apache/geode/management/internal/cli/commands/StartLocatorCommandWorkingDirectoryTest.java
@@ -24,9 +24,6 @@ import static org.mockito.Mockito.spy;
import static org.mockito.Mockito.verify;
import java.io.File;
-import java.io.IOException;
-
-import javax.management.MalformedObjectNameException;
import org.junit.Before;
import org.junit.Test;
diff --git a/geode-assembly/src/test/java/org/apache/geode/management/internal/cli/commands/StartServerCommandWorkingDirectoryTest.java b/geode-assembly/src/test/java/org/apache/geode/management/internal/cli/commands/StartServerCommandWorkingDirectoryTest.java
new file mode 100644
index 0000000..e756865
--- /dev/null
+++ b/geode-assembly/src/test/java/org/apache/geode/management/internal/cli/commands/StartServerCommandWorkingDirectoryTest.java
@@ -0,0 +1,146 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more contributor license
+ * agreements. See the NOTICE file distributed with this work for additional information regarding
+ * copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance with the License. You may obtain a
+ * copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+ * or implied. See the License for the specific language governing permissions and limitations under
+ * the License.
+ */
+package org.apache.geode.management.internal.cli.commands;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.mockito.ArgumentMatchers.anyBoolean;
+import static org.mockito.ArgumentMatchers.anyFloat;
+import static org.mockito.ArgumentMatchers.anyInt;
+import static org.mockito.ArgumentMatchers.anyString;
+import static org.mockito.ArgumentMatchers.isNull;
+import static org.mockito.Mockito.doReturn;
+import static org.mockito.Mockito.spy;
+import static org.mockito.Mockito.verify;
+
+import java.io.File;
+
+import org.junit.Before;
+import org.junit.Test;
+import org.mockito.ArgumentCaptor;
+
+public class StartServerCommandWorkingDirectoryTest {
+
+ private String memberName;
+ private String workingDirectory;
+ private StartServerCommand startServerCommand;
+ private ArgumentCaptor<String> workingDirectoryCaptor;
+
+ @Before
+ public void setUp() throws Exception {
+ memberName = "server1";
+ startServerCommand = spy(new StartServerCommand());
+
+ doReturn(null).when(startServerCommand)
+ .doStartServer(anyString(), anyBoolean(), isNull(), isNull(), isNull(), anyFloat(),
+ anyFloat(), anyString(), anyBoolean(), anyBoolean(), anyBoolean(), anyFloat(),
+ anyFloat(), anyBoolean(), isNull(), isNull(), isNull(), anyBoolean(), isNull(),
+ isNull(), isNull(), anyInt(), anyBoolean(), isNull(), anyInt(), isNull(), anyInt(),
+ anyInt(), isNull(), anyInt(), anyInt(), isNull(), isNull(), anyInt(), isNull(),
+ isNull(), anyInt(), isNull(), isNull(), anyBoolean(), isNull(), isNull(), anyInt(),
+ anyInt(), isNull(), isNull(), anyBoolean(), anyBoolean(), isNull(), isNull(), isNull(),
+ isNull(), anyBoolean());
+
+ workingDirectoryCaptor = ArgumentCaptor.forClass(String.class);
+ }
+
+ @Test
+ public void startLocatorWithRelativeWorkingDirectory() throws Exception {
+ workingDirectory = "server1Directory";
+
+ startServerCommand
+ .startServer(memberName, false, null, null, null, 0.0f, 0.0f, workingDirectory, false,
+ false, false, 0.0f, 0.0f, false, null, null, null, false, null, null, null, 0, false,
+ null, 0, null, 0, 0, null, 0, 0, null, null, 0, null, null, 0, null, null, false, null,
+ null, 0, 0, null, null, false, false, null, null, null, null, false);
+
+ verifyDoStartServerInvoked();
+
+ assertThat(workingDirectoryCaptor.getValue())
+ .isEqualTo(new File(workingDirectory).getAbsolutePath());
+ }
+
+ @Test
+ public void startServerWithNullWorkingDirectory() throws Exception {
+ workingDirectory = null;
+
+ startServerCommand
+ .startServer(memberName, false, null, null, null, 0.0f, 0.0f, workingDirectory, false,
+ false, false, 0.0f, 0.0f, false, null, null, null, false, null, null, null, 0, false,
+ null, 0, null, 0, 0, null, 0, 0, null, null, 0, null, null, 0, null, null, false, null,
+ null, 0, 0, null, null, false, false, null, null, null, null, false);
+
+ verifyDoStartServerInvoked();
+
+ assertThat(workingDirectoryCaptor.getValue()).isEqualTo(new File(memberName).getAbsolutePath());
+ }
+
+ @Test
+ public void startServerWithEmptyWorkingDirectory() throws Exception {
+ workingDirectory = "";
+
+ startServerCommand
+ .startServer(memberName, false, null, null, null, 0.0f, 0.0f, workingDirectory, false,
+ false, false, 0.0f, 0.0f, false, null, null, null, false, null, null, null, 0, false,
+ null, 0, null, 0, 0, null, 0, 0, null, null, 0, null, null, 0, null, null, false, null,
+ null, 0, 0, null, null, false, false, null, null, null, null, false);
+
+ verifyDoStartServerInvoked();
+
+ assertThat(workingDirectoryCaptor.getValue()).isEqualTo(new File(memberName).getAbsolutePath());
+ }
+
+ @Test
+ public void startServerWithDotWorkingDirectory() throws Exception {
+ workingDirectory = ".";
+
+ startServerCommand
+ .startServer(memberName, false, null, null, null, 0.0f, 0.0f, workingDirectory, false,
+ false, false, 0.0f, 0.0f, false, null, null, null, false, null, null, null, 0, false,
+ null, 0, null, 0, 0, null, 0, 0, null, null, 0, null, null, 0, null, null, false, null,
+ null, 0, 0, null, null, false, false, null, null, null, null, false);
+
+ verifyDoStartServerInvoked();
+
+ assertThat(workingDirectoryCaptor.getValue())
+ .isEqualTo(StartMemberUtils.resolveWorkingDir(new File("."), new File(memberName)));
+ }
+
+ @Test
+ public void startServerWithAbsoluteWorkingDirectory() throws Exception {
+ workingDirectory = new File(System.getProperty("user.dir")).getAbsolutePath();
+
+ startServerCommand
+ .startServer(memberName, false, null, null, null, 0.0f, 0.0f, workingDirectory, false,
+ false, false, 0.0f, 0.0f, false, null, null, null, false, null, null, null, 0, false,
+ null, 0, null, 0, 0, null, 0, 0, null, null, 0, null, null, 0, null, null, false, null,
+ null, 0, 0, null, null, false, false, null, null, null, null, false);
+
+ verifyDoStartServerInvoked();
+
+ assertThat(workingDirectoryCaptor.getValue()).isEqualTo(workingDirectory);
+ }
+
+ private void verifyDoStartServerInvoked() throws Exception {
+ verify(startServerCommand)
+ .doStartServer(anyString(), anyBoolean(), isNull(), isNull(), isNull(), anyFloat(),
+ anyFloat(), workingDirectoryCaptor.capture(), anyBoolean(), anyBoolean(), anyBoolean(),
+ anyFloat(), anyFloat(), anyBoolean(), isNull(), isNull(), isNull(), anyBoolean(),
+ isNull(), isNull(), isNull(), anyInt(), anyBoolean(), isNull(), anyInt(), isNull(),
+ anyInt(), anyInt(), isNull(), anyInt(), anyInt(), isNull(), isNull(), anyInt(),
+ isNull(), isNull(), anyInt(), isNull(), isNull(), anyBoolean(), isNull(), isNull(),
+ anyInt(), anyInt(), isNull(), isNull(), anyBoolean(), anyBoolean(), isNull(), isNull(),
+ isNull(), isNull(), anyBoolean());
+ }
+}
diff --git a/geode-core/src/main/java/org/apache/geode/management/internal/cli/commands/StartMemberUtils.java b/geode-core/src/main/java/org/apache/geode/management/internal/cli/commands/StartMemberUtils.java
index 7116ed8..d425187 100644
--- a/geode-core/src/main/java/org/apache/geode/management/internal/cli/commands/StartMemberUtils.java
+++ b/geode-core/src/main/java/org/apache/geode/management/internal/cli/commands/StartMemberUtils.java
@@ -71,7 +71,7 @@ public class StartMemberUtils {
}
static String resolveWorkingDir(File userSpecifiedDir, File memberNameDir) {
- //TODO: see if file has some APIs to do equals
+ // TODO: see if file has some APIs to do equals
File workingDir =
(userSpecifiedDir == null || userSpecifiedDir.equals(new File(""))) ? memberNameDir
: userSpecifiedDir;
diff --git a/geode-core/src/main/java/org/apache/geode/management/internal/cli/commands/StartServerCommand.java b/geode-core/src/main/java/org/apache/geode/management/internal/cli/commands/StartServerCommand.java
index 5ac18fc..e5c5e4f 100644
--- a/geode-core/src/main/java/org/apache/geode/management/internal/cli/commands/StartServerCommand.java
+++ b/geode-core/src/main/java/org/apache/geode/management/internal/cli/commands/StartServerCommand.java
@@ -16,6 +16,7 @@
package org.apache.geode.management.internal.cli.commands;
import java.io.File;
+import java.io.IOException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
@@ -201,6 +202,37 @@ public class StartServerCommand extends InternalGfshCommand {
workingDirectory = StartMemberUtils.resolveWorkingDir(
workingDirectory == null ? null : new File(workingDirectory), new File(memberName));
+ return doStartServer(memberName, assignBuckets, bindAddress, cacheXmlPathname, classpath,
+ criticalHeapPercentage, criticalOffHeapPercentage, workingDirectory, disableDefaultServer,
+ disableExitWhenOutOfMemory, enableTimeStatistics, evictionHeapPercentage,
+ evictionOffHeapPercentage, force, group, hostNameForClients, jmxManagerHostnameForClients,
+ includeSystemClasspath, initialHeap, jvmArgsOpts, locators, locatorWaitTime, lockMemory,
+ logLevel, maxConnections, maxHeap, maxMessageCount, maxThreads, mcastBindAddress, mcastPort,
+ memcachedPort, memcachedProtocol, memcachedBindAddress, redisPort, redisBindAddress,
+ redisPassword, messageTimeToLive, offHeapMemorySize, gemfirePropertiesFile, rebalance,
+ gemfireSecurityPropertiesFile, serverBindAddress, serverPort, socketBufferSize,
+ springXmlLocation, statisticsArchivePathname, requestSharedConfiguration, startRestApi,
+ httpServicePort, httpServiceBindAddress, userName, passwordToUse, redirectOutput);
+ }
+
+ Result doStartServer(String memberName, Boolean assignBuckets, String bindAddress,
+ String cacheXmlPathname, String classpath, Float criticalHeapPercentage,
+ Float criticalOffHeapPercentage, String workingDirectory, Boolean disableDefaultServer,
+ Boolean disableExitWhenOutOfMemory, Boolean enableTimeStatistics,
+ Float evictionHeapPercentage, Float evictionOffHeapPercentage, Boolean force, String group,
+ String hostNameForClients, String jmxManagerHostnameForClients,
+ Boolean includeSystemClasspath, String initialHeap, String[] jvmArgsOpts, String locators,
+ Integer locatorWaitTime, Boolean lockMemory, String logLevel, Integer maxConnections,
+ String maxHeap, Integer maxMessageCount, Integer maxThreads, String mcastBindAddress,
+ Integer mcastPort, Integer memcachedPort, String memcachedProtocol,
+ String memcachedBindAddress, Integer redisPort, String redisBindAddress, String redisPassword,
+ Integer messageTimeToLive, String offHeapMemorySize, File gemfirePropertiesFile,
+ Boolean rebalance, File gemfireSecurityPropertiesFile, String serverBindAddress,
+ Integer serverPort, Integer socketBufferSize, String springXmlLocation,
+ String statisticsArchivePathname, Boolean requestSharedConfiguration, Boolean startRestApi,
+ String httpServicePort, String httpServiceBindAddress, String userName, String passwordToUse,
+ Boolean redirectOutput)
+ throws MalformedObjectNameException, IOException, InterruptedException {
cacheXmlPathname = CliUtil.resolvePathname(cacheXmlPathname);
if (StringUtils.isNotBlank(cacheXmlPathname)) {
@@ -378,10 +410,8 @@ public class StartServerCommand extends InternalGfshCommand {
} while (!(registeredServerSignalListener && serverSignalListener.isSignaled())
&& serverState.isStartingOrNotResponding());
} finally {
- stderrReader.stopAsync(StartMemberUtils.PROCESS_STREAM_READER_ASYNC_STOP_TIMEOUT_MILLIS); // stop
- // will
- // close
- // ErrorStream
+ stderrReader.stopAsync(StartMemberUtils.PROCESS_STREAM_READER_ASYNC_STOP_TIMEOUT_MILLIS);
+ // stop will close ErrorStream
getGfsh().getSignalHandler().unregisterListener(serverSignalListener);
}
[geode] 02/02: Merge branch 'develop' into
startlocator_command_tests
Posted by sa...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
sai_boorlagadda pushed a commit to branch startlocator_command_tests
in repository https://gitbox.apache.org/repos/asf/geode.git
commit 4e6460fdccae4685e27afce3d66706ecf43b4aaf
Merge: e084d4e 6bd7d6c
Author: Sai Boorlagadda <sb...@pivotal.io>
AuthorDate: Mon Oct 8 13:09:10 2018 -0700
Merge branch 'develop' into startlocator_command_tests
.../windows-packer.json | 27 +-
.../geode/modules/util/CreateRegionFunction.java | 9 +-
.../geode/session/tests/ServerContainer.java | 13 +-
.../session/tests/GenericAppServerInstall.java | 2 +-
.../web/SwaggerVerificationIntegrationTest.java | 5 +-
.../integrationTest/resources/assembly_content.txt | 16 +-
.../resources/dependency_classpath.txt | 16 +-
.../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 +-
.../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 +-
900 files changed, 14137 insertions(+), 24298 deletions(-)