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 <[email protected]> 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(-)
