This is an automated email from the ASF dual-hosted git repository. sbawaskar pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/geode.git
commit e86a731195c588021c79d50001bd6cbba367022f Merge: 2e60ce3 59f2a73 Author: Swapnil Bawaskar <[email protected]> AuthorDate: Mon Oct 30 14:52:00 2017 +0530 Merge branch 'release/1.3.0' .gitattributes | 1 + .gitignore | 3 +- build.gradle | 8 + dev-tools/docker/base/Dockerfile | 37 +- dev-tools/docker/base/build-base-docker.sh | 4 +- dev-tools/docker/base/entrypoint.sh | 29 + dev-tools/docker/compile/Dockerfile | 21 - dev-tools/docker/compile/start-compile-docker.sh | 62 - docker/Dockerfile | 4 +- docker/README.md | 2 +- etc/intellij-java-google-style.xml | 365 ---- etc/intellij-java-modified-google-style.xml | 255 +++ extensions/geode-modules-assembly/build.gradle | 30 +- .../release/session/bin/modify_war | 5 +- .../geode-modules-session-internal/build.gradle | 4 +- .../internal/common/AbstractSessionCache.java | 4 + .../session/internal/common/CacheProperty.java | 3 +- .../internal/common/ClientServerSessionCache.java | 9 +- .../internal/filter/DummySessionManager.java | 18 +- .../internal/filter/GemfireHttpSession.java | 88 +- .../internal/filter/GemfireSessionManager.java | 90 +- .../session/internal/filter/SessionManager.java | 21 +- .../attributes/AbstractDeltaSessionAttributes.java | 6 - .../attributes/AbstractSessionAttributes.java | 24 + .../internal/filter/attributes/DeltaEvent.java | 6 +- .../attributes/DeltaQueuedSessionAttributes.java | 4 + .../filter/attributes/DeltaSessionAttributes.java | 4 + .../attributes/ImmediateSessionAttributes.java | 64 - .../filter/attributes/QueuedSessionAttributes.java | 61 - .../filter/attributes/SessionAttributes.java | 10 + .../internal/filter/util/ThreadLocalSession.java | 36 - extensions/geode-modules-session/build.gradle | 2 + .../session/filter/SessionCachingFilter.java | 117 +- .../modules/session/filter/SessionListener.java | 14 +- .../geode/modules/session/installer/Installer.java | 37 +- .../session/internal/filter/CommonTests.java | 67 +- .../internal/filter/HttpSessionListenerImpl.java | 37 - .../internal/filter/HttpSessionListenerImpl2.java | 39 - .../SessionReplicationIntegrationJUnitTest.java | 192 +- .../installer/InstallerJUnitTest.web.xml.expected | 3 - extensions/geode-modules-tomcat7/build.gradle | 2 + .../modules/session/catalina/DeltaSession7.java | 572 +----- extensions/geode-modules-tomcat8/build.gradle | 2 + .../modules/session/catalina/DeltaSession8.java | 570 +---- .../catalina/Tomcat8DeltaSessionManager.java | 4 +- .../Tomcat8SessionsClientServerDUnitTest.java | 14 +- extensions/geode-modules/build.gradle | 2 + .../gatewaydelta/GatewayDeltaCreateEvent.java | 8 - .../gatewaydelta/GatewayDeltaDestroyEvent.java | 8 - .../session/catalina/ClientServerSessionCache.java | 8 +- .../modules/session/catalina/DeltaSession.java | 96 +- .../session/catalina/PeerToPeerSessionCache.java | 4 +- .../DeltaSessionDestroyAttributeEvent.java | 8 - .../geode/modules/session/CommandServlet.java | 1 + extensions/session-testing-war/build.gradle | 27 + .../geode/modules/session/CommandServlet.java | 110 + .../session/ListenerStoredInSessionContext.java | 31 + .../apache/geode/modules/session/QueryCommand.java | 36 + .../modules/session/SessionCountingListener.java | 43 + .../session/functions/GetMaxInactiveInterval.java | 29 + .../modules/session/functions/GetSessionCount.java | 30 + .../session/functions/GetSessionCreatedCount.java | 30 + .../functions/GetSessionDestroyedCount.java | 30 + .../src/main/webapp/WEB-INF/web.xml | 51 + geode-assembly/build.gradle | 75 +- geode-assembly/src/main/dist/LICENSE | 22 +- .../org/apache/geode/BundledJarsJUnitTest.java | 54 +- .../LocatorLauncherAssemblyIntegrationTest.java | 150 -- .../cli/commands/GemfireCoreClasspathTest.java | 101 + .../cli/commands/GfshStartLocatorLogTest.java | 58 + .../LauncherLifecycleCommandsDUnitTest.java | 81 +- .../LauncherLifecycleCommandsIntegrationTest.java | 214 -- .../commands/LauncherLifecycleCommandsTest.java | 575 ------ .../StartLocatorCommandIntegrationTest.java | 88 + .../cli/commands/StartLocatorCommandTest.java | 147 ++ .../StartServerCommandIntegrationTest.java | 88 + .../cli/commands/StartServerCommandTest.java | 144 ++ .../cli/commands/StatusLocatorRealGfshTest.java | 44 + .../cli/commands/StopServerAcceptanceTest.java | 52 + .../StopServerWithSecurityAcceptanceTest.java | 139 ++ .../cli/shell/GfshDisconnectWithinScript.java | 41 + .../cli/shell/GfshExitCodeStatusCommandsTest.java | 404 ++++ ...usterConfigurationServiceEndToEndDUnitTest.java | 468 ----- .../geode/rest/internal/web/GeodeRestClient.java | 2 +- .../internal/web/RestInterfaceIntegrationTest.java | 475 +++++ .../rest/internal/web/RestInterfaceJUnitTest.java | 463 ----- .../internal/web/RestSecurityIntegrationTest.java | 18 +- .../web/RestSecurityPostProcessorTest.java | 28 +- .../rest/internal/web/RestSecurityWithSSLTest.java | 23 +- .../internal/web/RestServersIntegrationTest.java | 72 + .../rest/internal/web/RestServersJUnitTest.java | 60 - .../web/SwaggerVerificationIntegrationTest.java | 70 + .../rest/internal/web/SwaggerVerificationTest.java | 63 - .../rest/internal/web/controllers/Customer.java | 2 +- .../controllers/RestAPIsAndInterOpsDUnitTest.java | 846 ++++---- .../controllers/RestAPIsQueryAndFEJUnitTest.java | 948 --------- .../RestQueryAndFunctionIntegrationTest.java | 958 +++++++++ .../apache/geode/session/tests/CargoTestBase.java | 322 +++ .../org/apache/geode/session/tests/Client.java | 306 +++ .../geode/session/tests/ContainerInstall.java | 597 ++++++ .../geode/session/tests/ContainerManager.java | 246 +++ .../tests/GenericAppServerClientServerTest.java | 116 ++ .../session/tests/GenericAppServerContainer.java | 165 ++ .../session/tests/GenericAppServerInstall.java | 141 ++ .../tests/Jetty9CachingClientServerTest.java | 83 + .../session/tests/Jetty9ClientServerTest.java | 42 + .../org/apache/geode/session/tests/Jetty9Test.java | 42 + .../geode/session/tests/ServerContainer.java | 404 ++++ .../session/tests/Tomcat6ClientServerTest.java | 42 + .../apache/geode/session/tests/Tomcat6Test.java | 41 + .../session/tests/Tomcat7ClientServerTest.java | 44 + .../apache/geode/session/tests/Tomcat7Test.java | 41 + .../session/tests/Tomcat8ClientServerTest.java | 42 + .../apache/geode/session/tests/Tomcat8Test.java | 41 + .../session/tests/TomcatClientServerTest.java | 83 + .../geode/session/tests/TomcatContainer.java | 155 ++ .../apache/geode/session/tests/TomcatInstall.java | 331 +++ .../TomcatSessionBackwardsCompatibilityTest.java | 244 +++ .../geode/test/dunit/rules/EmbeddedPulseRule.java | 76 - .../geode/test/dunit/rules/HttpClientRule.java | 107 - .../geode/test/junit/rules/EmbeddedPulseRule.java | 79 + .../geode/test/junit/rules/HttpClientRule.java | 102 + .../geode/tools/pulse/PulseConnectivityTest.java | 97 + .../geode/tools/pulse/PulseDataExportTest.java | 4 +- .../geode/tools/pulse/PulseSecurityTest.java | 6 +- .../tools/pulse/PulseSecurityWithSSLTest.java | 15 +- .../geode/tools/pulse/PulseVerificationTest.java | 70 - .../src/test/resources/expected_jars.txt | 6 +- geode-book/Gemfile | 2 +- geode-book/Gemfile.lock | 109 +- geode-book/README.md | 16 +- geode-book/config.yml | 6 +- .../source/subnavs/geode-subnav.erb | 1792 ++++++++-------- geode-book/redirects.rb | 6 +- .../org/apache/geode/annotations/TestingOnly.java | 28 + geode-concurrency-test/build.gradle | 28 + .../src/main/java/java/net/InetAddress.java | 156 ++ .../test/concurrency/ConcurrentTestRunner.java | 135 ++ .../geode/test/concurrency/ParallelExecutor.java | 48 + .../test/concurrency/RunnableWithException.java | 25 + .../org/apache/geode/test/concurrency/Runner.java | 28 + .../annotation/ConcurrentTestConfig.java | 32 + .../geode/test/concurrency/jpf/JpfRunner.java | 98 + .../test/concurrency/jpf/JpfRunnerConfig.java | 34 + .../test/concurrency/jpf/ParallelExecutorImpl.java | 87 + .../test/concurrency/jpf/logging/EmptyLogger.java | 1975 ++++++++++++++++++ ...il_concurrent_locks_ReentrantReadWriteLock.java | 42 + ...ributed_internal_InternalDistributedSystem.java | 28 + ...g_apache_geode_internal_logging_LogService.java | 42 + ...che_geode_internal_logging_log4j_LogMarker.java | 27 + .../JPF_org_apache_logging_log4j_LogManager.java | 29 + .../geode/test/concurrency/loop/LoopRunner.java | 90 + .../test/concurrency/loop/LoopRunnerConfig.java | 22 + geode-core/build.gradle | 28 +- .../cache/FilterProfileConcurrencyTest.java | 86 + .../main/java/org/apache/geode/SystemFailure.java | 225 +- .../admin/internal/DistributionLocatorImpl.java | 6 +- .../geode/admin/internal/FinishBackupRequest.java | 4 +- .../geode/admin/internal/FlushToDiskRequest.java | 2 +- .../geode/admin/internal/PrepareBackupRequest.java | 6 +- .../apache/geode/admin/jmx/internal/AgentImpl.java | 6 +- .../geode/admin/jmx/internal/AgentLauncher.java | 26 +- .../admin/jmx/internal/GenerateMBeanHTML.java | 23 +- .../org/apache/geode/cache/AttributesMutator.java | 13 - .../java/org/apache/geode/cache/CacheFactory.java | 46 +- .../apache/geode/cache/PartitionAttributes.java | 3 + .../geode/cache/PartitionAttributesFactory.java | 3 + .../org/apache/geode/cache/RegionRoleListener.java | 2 +- .../org/apache/geode/cache/TransactionEvent.java | 39 - .../asyncqueue/internal/AsyncEventQueueStats.java | 8 +- .../internal/ParallelAsyncEventQueueImpl.java | 10 +- .../internal/SerialAsyncEventQueueImpl.java | 7 +- .../geode/cache/client/ClientCacheFactory.java | 19 +- .../java/org/apache/geode/cache/client/Pool.java | 7 + .../org/apache/geode/cache/client/PoolFactory.java | 20 + .../geode/cache/client/internal/AbstractOp.java | 2 - .../client/internal/AutoConnectionSourceImpl.java | 171 +- .../client/internal/ConnectionFactoryImpl.java | 12 +- .../cache/client/internal/ConnectionImpl.java | 43 +- .../cache/client/internal/ExecuteFunctionOp.java | 12 +- .../client/internal/ExecuteRegionFunctionOp.java | 2 +- .../geode/cache/client/internal/PoolImpl.java | 35 +- .../cache/client/internal/ServerRegionProxy.java | 3 - .../org/apache/geode/cache/execute/Execution.java | 84 +- .../org/apache/geode/cache/execute/Function.java | 54 +- .../geode/cache/execute/FunctionContext.java | 6 +- .../java/org/apache/geode/cache/query/Index.java | 8 + .../org/apache/geode/cache/query/IndexType.java | 24 +- .../cache/query/internal/AttributeDescriptor.java | 58 +- .../geode/cache/query/internal/CompiledIn.java | 65 +- .../cache/query/internal/CompiledIteratorDef.java | 3 + .../cache/query/internal/CompiledOperation.java | 4 +- .../geode/cache/query/internal/CompiledPath.java | 2 +- .../geode/cache/query/internal/CompiledSelect.java | 266 +-- .../query/internal/CompiledSortCriterion.java | 6 +- .../geode/cache/query/internal/DefaultQuery.java | 1 - .../cache/query/internal/DefaultQueryService.java | 21 +- .../geode/cache/query/internal/DerivedInfo.java | 15 +- .../cache/query/internal/ExecutionContext.java | 2 +- .../cache/query/internal/InternalQueryService.java | 22 + .../geode/cache/query/internal/MethodDispatch.java | 27 +- .../query/internal/MethodInvocationAuthorizer.java | 21 + .../cache/query/internal/OrderByComparator.java | 208 +- .../query/internal/OrderByComparatorMapped.java | 126 ++ .../query/internal/OrderByComparatorUnmapped.java | 147 -- .../geode/cache/query/internal/PathUtils.java | 33 +- .../RestrictedMethodInvocationAuthorizer.java | 164 ++ .../cache/query/internal/RuntimeIterator.java | 22 +- .../geode/cache/query/internal/StructImpl.java | 17 +- .../cache/query/internal/index/AbstractIndex.java | 3 +- .../query/internal/index/CompactRangeIndex.java | 5 + .../cache/query/internal/index/IndexManager.java | 27 +- .../cache/query/internal/index/IndexProtocol.java | 2 - .../geode/cache/server/internal/LoadMonitor.java | 13 +- .../cache/snapshot/RegionSnapshotService.java | 42 +- .../geode/cache/snapshot/SnapshotIterator.java | 2 +- .../geode/cache/snapshot/SnapshotOptions.java | 32 +- .../apache/geode/cache/wan/GatewayReceiver.java | 7 +- .../org/apache/geode/cache/wan/GatewaySender.java | 7 +- .../geode/cache/wan/GatewaySenderFactory.java | 2 + .../apache/geode/distributed/AbstractLauncher.java | 139 +- .../geode/distributed/ConfigurationProperties.java | 17 + .../apache/geode/distributed/LocatorLauncher.java | 628 +++--- .../apache/geode/distributed/ServerLauncher.java | 687 +++---- .../internal/AbstractDistributionConfig.java | 36 +- .../org/apache/geode/distributed/internal/DM.java | 5 + .../distributed/internal/DistributionChannel.java | 8 +- .../distributed/internal/DistributionConfig.java | 39 +- .../internal/DistributionConfigImpl.java | 65 +- .../distributed/internal/DistributionManager.java | 26 +- .../internal/InternalDistributedSystem.java | 128 +- .../distributed/internal/InternalLocator.java | 64 +- .../internal/LonerDistributionManager.java | 12 + .../geode/distributed/internal/MessageFactory.java | 62 - .../geode/distributed/internal/SecurityConfig.java | 51 + .../geode/distributed/internal/ServerLocator.java | 4 + .../internal/deadlock/DeadlockDetector.java | 4 +- .../internal/locks/DLockRequestProcessor.java | 7 - .../membership/InternalDistributedMember.java | 35 +- .../internal/membership/MemberFactory.java | 16 +- .../internal/membership/MemberServices.java | 4 +- .../distributed/internal/membership/NetView.java | 4 + .../internal/membership/gms/GMSMember.java | 24 + .../internal/membership/gms/GMSMemberFactory.java | 11 +- .../internal/membership/gms/GMSUtil.java | 26 +- .../internal/membership/gms/Services.java | 127 +- .../membership/gms/auth/GMSAuthenticator.java | 36 +- .../membership/gms/interfaces/Locator.java | 5 + .../gms/locator/FindCoordinatorResponse.java | 2 +- .../membership/gms/locator/GMSLocator.java | 71 +- .../membership/gms/membership/GMSJoinLeave.java | 107 +- .../membership/gms/membership/HostAddress.java | 110 + .../membership/gms/messenger/GMSEncrypt.java | 14 +- .../membership/gms/messenger/JGroupsMessenger.java | 7 +- .../membership/gms/mgr/GMSMembershipManager.java | 32 +- .../distributed/internal/tcpserver/TcpClient.java | 38 +- .../distributed/internal/tcpserver/TcpServer.java | 238 ++- .../geode/examples/SimpleSecurityManager.java | 59 + .../examples/security/ExampleSecurityManager.java | 31 +- .../org/apache/geode/internal/AbstractConfig.java | 18 +- .../org/apache/geode/internal/AvailablePort.java | 24 +- .../java/org/apache/geode/internal/Banner.java | 8 +- .../org/apache/geode/internal/ClassLoadUtil.java | 75 +- .../org/apache/geode/internal/DSFIDFactory.java | 5 + .../geode/internal/DataSerializableFixedID.java | 2 + .../apache/geode/internal/DistributionLocator.java | 27 +- .../java/org/apache/geode/internal/ExitCode.java | 49 + .../geode/internal/GfeConsoleReaderFactory.java | 11 +- .../org/apache/geode/internal/JarDeployer.java | 34 +- .../org/apache/geode/internal/MigrationClient.java | 7 +- .../org/apache/geode/internal/MigrationServer.java | 7 +- .../org/apache/geode/internal/SystemAdmin.java | 179 +- .../java/org/apache/geode/internal/Version.java | 22 +- .../org/apache/geode/internal/admin/SSLConfig.java | 2 - .../internal/admin/remote/CompactRequest.java | 2 +- .../admin/remote/DistributionLocatorId.java | 45 +- .../admin/remote/MissingPersistentIDsRequest.java | 2 +- .../remote/PrepareRevokePersistentIDRequest.java | 2 +- .../admin/remote/RemoteTransportConfig.java | 5 +- .../admin/remote/RevokePersistentIDRequest.java | 2 +- .../internal/admin/remote/ShutdownAllRequest.java | 2 +- .../internal/cache/AbstractBucketRegionQueue.java | 10 +- .../geode/internal/cache/AbstractLRURegionMap.java | 1 - .../geode/internal/cache/AbstractRegion.java | 36 - .../geode/internal/cache/AbstractRegionEntry.java | 23 +- .../geode/internal/cache/AbstractRegionMap.java | 38 +- .../cache/AddCacheServerProfileMessage.java | 2 +- .../apache/geode/internal/cache/BackupLock.java | 66 +- .../apache/geode/internal/cache/BackupManager.java | 603 ++++++ .../apache/geode/internal/cache/BucketAdvisor.java | 118 +- .../internal/cache/BucketPersistenceAdvisor.java | 7 + .../internal/cache/BucketRedundancyTracker.java | 122 ++ .../apache/geode/internal/cache/BucketRegion.java | 53 +- .../geode/internal/cache/BucketRegionQueue.java | 3 +- .../internal/cache/CacheDistributionAdvisor.java | 3 +- .../geode/internal/cache/CachePerfStats.java | 4 + .../geode/internal/cache/CacheServerImpl.java | 14 +- .../geode/internal/cache/CacheServerLauncher.java | 28 +- .../internal/cache/ClusterConfigurationLoader.java | 44 +- .../internal/cache/CreateRegionProcessor.java | 22 +- .../apache/geode/internal/cache/DiskInitFile.java | 287 +-- .../geode/internal/cache/DiskStoreBackup.java | 9 +- .../geode/internal/cache/DiskStoreFactoryImpl.java | 19 +- .../apache/geode/internal/cache/DiskStoreImpl.java | 266 +-- .../geode/internal/cache/DistTXCommitMessage.java | 2 +- .../internal/cache/DistTXPrecommitMessage.java | 2 +- .../internal/cache/DistTXRollbackMessage.java | 2 +- .../internal/cache/DistributedPutAllOperation.java | 2 +- .../geode/internal/cache/DistributedRegion.java | 135 +- .../DistributedRegionFunctionStreamingMessage.java | 10 +- .../cache/DistributedRemoveAllOperation.java | 2 +- .../geode/internal/cache/EventStateHelper.java | 10 +- .../apache/geode/internal/cache/EventTracker.java | 790 ------- .../apache/geode/internal/cache/ExpiryTask.java | 54 +- .../apache/geode/internal/cache/FilterProfile.java | 73 +- .../geode/internal/cache/FindRemoteTXMessage.java | 2 +- .../internal/cache/FindVersionTagOperation.java | 9 +- .../geode/internal/cache/GemFireCacheImpl.java | 192 +- .../org/apache/geode/internal/cache/HARegion.java | 5 +- .../internal/cache/InitialImageOperation.java | 20 + .../apache/geode/internal/cache/InternalCache.java | 18 +- .../internal/cache/JtaAfterCompletionMessage.java | 2 +- .../internal/cache/JtaBeforeCompletionMessage.java | 2 +- .../apache/geode/internal/cache/LocalRegion.java | 270 +-- .../cache/MemberFunctionStreamingMessage.java | 15 +- .../org/apache/geode/internal/cache/Oplog.java | 765 +++---- .../geode/internal/cache/PartitionedRegion.java | 87 +- .../internal/cache/PartitionedRegionDataStore.java | 173 +- .../cache/PartitionedRegionQueryEvaluator.java | 9 +- .../cache/PartitionedRegionRedundancyTracker.java | 139 ++ .../internal/cache/PartitionedRegionStats.java | 13 + .../geode/internal/cache/PeerTXStateStub.java | 13 +- .../geode/internal/cache/PoolFactoryImpl.java | 44 +- .../cache/RegionEntrySynchronizationListener.java | 25 + .../geode/internal/cache/RegionExpiryTask.java | 2 +- .../org/apache/geode/internal/cache/TXEvent.java | 79 - .../apache/geode/internal/cache/TXManagerImpl.java | 63 +- .../org/apache/geode/internal/cache/TXMessage.java | 2 +- .../internal/cache/TXRemoteCommitMessage.java | 2 +- .../internal/cache/TXRemoteRollbackMessage.java | 2 +- .../apache/geode/internal/cache/TXRmtEvent.java | 78 - .../org/apache/geode/internal/cache/TXState.java | 11 +- .../internal/cache/TXSynchronizationRunnable.java | 15 +- .../internal/cache/control/ResourceAdvisor.java | 7 +- .../internal/cache/event/BulkOperationHolder.java | 79 + .../cache/event/DistributedEventTracker.java | 523 +++++ .../cache/event/EventSequenceNumberHolder.java | 124 ++ .../geode/internal/cache/event/EventTracker.java | 136 ++ .../cache/event/EventTrackerExpiryTask.java | 97 + .../cache/event/NonDistributedEventTracker.java | 135 ++ .../internal/cache/execute/AbstractExecution.java | 96 +- .../execute/DistributedRegionFunctionExecutor.java | 106 - .../cache/execute/FunctionContextImpl.java | 20 +- .../cache/execute/MemberFunctionExecutor.java | 7 +- .../execute/MultiRegionFunctionContextImpl.java | 8 +- .../cache/execute/MultiRegionFunctionExecutor.java | 5 +- .../cache/execute/RegionFunctionContextImpl.java | 10 +- .../cache/execute/ServerFunctionExecutor.java | 81 - .../execute/ServerRegionFunctionExecutor.java | 85 - .../internal/cache/ha/QueueRemovalMessage.java | 4 +- .../geode/internal/cache/locks/TXLockToken.java | 92 - .../partitioned/EndBucketCreationMessage.java | 5 + .../cache/partitioned/FetchEntriesMessage.java | 45 +- .../cache/partitioned/PartitionMessage.java | 7 +- .../internal/cache/partitioned/RegionAdvisor.java | 18 - .../cache/partitioned/RemoveAllPRMessage.java | 8 + .../cache/persistence/BackupInspector.java | 219 +- .../internal/cache/persistence/BackupManager.java | 389 ---- .../cache/persistence/DiskInitFileParser.java | 3 +- .../cache/persistence/MembershipViewRequest.java | 4 +- .../persistence/PersistentStateQueryMessage.java | 4 +- .../PrepareNewPersistentMemberMessage.java | 4 +- .../persistence/RemovePersistentMemberMessage.java | 4 +- .../internal/cache/persistence/RestoreScript.java | 235 +-- .../cache/persistence/ScriptGenerator.java | 37 + .../cache/persistence/UnixBackupInspector.java | 74 + .../cache/persistence/UnixScriptGenerator.java | 58 + .../cache/persistence/WindowsBackupInspector.java | 82 + .../cache/persistence/WindowsScriptGenerator.java | 81 + .../cache/snapshot/CacheSnapshotServiceImpl.java | 68 +- .../geode/internal/cache/snapshot/GFSnapshot.java | 3 +- .../cache/snapshot/ParallelSnapshotFileMapper.java | 68 + .../cache/snapshot/RegionSnapshotServiceImpl.java | 113 +- .../cache/snapshot/SnapshotOptionsImpl.java | 57 +- .../apache/geode/internal/cache/tier/Acceptor.java | 51 +- .../geode/internal/cache/tier/ClientHandShake.java | 2 +- .../apache/geode/internal/cache/tier/Command.java | 4 +- .../internal/cache/tier/CommunicationMode.java | 163 ++ .../cache/tier/InternalClientMembership.java | 30 +- .../internal/cache/tier/sockets/AcceptorImpl.java | 512 ++--- .../internal/cache/tier/sockets/BaseCommand.java | 56 +- .../cache/tier/sockets/BaseCommandQuery.java | 54 +- .../cache/tier/sockets/CacheClientNotifier.java | 63 +- .../cache/tier/sockets/CacheClientProxy.java | 54 +- .../cache/tier/sockets/CacheClientUpdater.java | 7 + .../cache/tier/sockets/CacheServerStats.java | 282 +-- .../tier/sockets/ClientBlacklistProcessor.java | 2 +- .../cache/tier/sockets/ClientHealthMonitor.java | 41 +- .../tier/sockets/ClientProtocolProcessor.java | 43 + .../cache/tier/sockets/ClientProtocolService.java | 44 + .../tier/sockets/ClientProtocolServiceLoader.java | 40 + .../tier/sockets/ClientProtocolStatistics.java | 24 + .../cache/tier/sockets/CommBufferPool.java | 36 + .../cache/tier/sockets/CommandInitializer.java | 5 + .../cache/tier/sockets/ConnectionListener.java | 6 +- .../tier/sockets/ConnectionListenerAdapter.java | 6 +- .../sockets/GenericProtocolServerConnection.java | 121 ++ .../internal/cache/tier/sockets/HandShake.java | 104 +- .../cache/tier/sockets/LegacyServerConnection.java | 88 + .../sockets/RemoveClientFromBlacklistMessage.java | 17 +- .../cache/tier/sockets/ServerConnection.java | 153 +- .../tier/sockets/ServerConnectionFactory.java | 136 ++ .../tier/sockets/ServerHandShakeProcessor.java | 17 +- .../sockets/ServiceLoadingFailureException.java | 35 + .../cache/tier/sockets/TcpServerFactory.java | 52 + .../cache/tier/sockets/command/AddPdxEnum.java | 4 +- .../cache/tier/sockets/command/AddPdxType.java | 5 +- .../cache/tier/sockets/command/ClearRegion.java | 9 +- .../cache/tier/sockets/command/ClientReady.java | 5 +- .../tier/sockets/command/CloseConnection.java | 5 +- .../cache/tier/sockets/command/CommitCommand.java | 8 +- .../cache/tier/sockets/command/ContainsKey.java | 11 +- .../cache/tier/sockets/command/ContainsKey66.java | 12 +- .../cache/tier/sockets/command/CreateRegion.java | 12 +- .../cache/tier/sockets/command/Default.java | 5 +- .../cache/tier/sockets/command/Destroy.java | 8 +- .../cache/tier/sockets/command/Destroy65.java | 12 +- .../cache/tier/sockets/command/DestroyRegion.java | 11 +- .../tier/sockets/command/ExecuteFunction.java | 77 +- .../tier/sockets/command/ExecuteFunction65.java | 82 +- .../tier/sockets/command/ExecuteFunction66.java | 98 +- .../tier/sockets/command/ExecuteFunction70.java | 7 +- .../sockets/command/ExecuteRegionFunction.java | 70 +- .../sockets/command/ExecuteRegionFunction61.java | 69 +- .../sockets/command/ExecuteRegionFunction65.java | 105 +- .../sockets/command/ExecuteRegionFunction66.java | 118 +- .../command/ExecuteRegionFunctionSingleHop.java | 106 +- .../sockets/command/GatewayReceiverCommand.java | 980 +++++---- .../internal/cache/tier/sockets/command/Get70.java | 11 +- .../cache/tier/sockets/command/GetAll.java | 17 +- .../cache/tier/sockets/command/GetAll651.java | 19 +- .../cache/tier/sockets/command/GetAll70.java | 18 +- .../tier/sockets/command/GetAllWithCallback.java | 21 +- .../command/GetClientPRMetadataCommand.java | 4 +- .../command/GetClientPRMetadataCommand66.java | 4 +- .../GetClientPartitionAttributesCommand.java | 4 +- .../GetClientPartitionAttributesCommand66.java | 4 +- .../tier/sockets/command/GetFunctionAttribute.java | 5 +- .../cache/tier/sockets/command/GetPDXEnumById.java | 4 +- .../tier/sockets/command/GetPDXIdForEnum.java | 4 +- .../tier/sockets/command/GetPDXIdForType.java | 5 +- .../cache/tier/sockets/command/GetPDXTypeById.java | 4 +- .../cache/tier/sockets/command/GetPdxEnums70.java | 4 +- .../cache/tier/sockets/command/GetPdxTypes70.java | 4 +- .../cache/tier/sockets/command/Invalid.java | 5 +- .../cache/tier/sockets/command/Invalidate.java | 11 +- .../cache/tier/sockets/command/KeySet.java | 9 +- .../cache/tier/sockets/command/MakePrimary.java | 5 +- .../tier/sockets/command/ManagementCommand.java | 4 +- .../cache/tier/sockets/command/PeriodicAck.java | 5 +- .../internal/cache/tier/sockets/command/Ping.java | 8 +- .../internal/cache/tier/sockets/command/Put.java | 13 +- .../internal/cache/tier/sockets/command/Put61.java | 13 +- .../internal/cache/tier/sockets/command/Put65.java | 11 +- .../cache/tier/sockets/command/PutAll.java | 14 +- .../cache/tier/sockets/command/PutAll70.java | 15 +- .../cache/tier/sockets/command/PutAll80.java | 14 +- .../tier/sockets/command/PutUserCredentials.java | 4 +- .../internal/cache/tier/sockets/command/Query.java | 7 +- .../cache/tier/sockets/command/Query651.java | 7 +- .../sockets/command/RegisterDataSerializers.java | 5 +- .../sockets/command/RegisterInstantiators.java | 5 +- .../tier/sockets/command/RegisterInterest.java | 11 +- .../tier/sockets/command/RegisterInterest61.java | 14 +- .../tier/sockets/command/RegisterInterestList.java | 37 +- .../sockets/command/RegisterInterestList61.java | 35 +- .../sockets/command/RegisterInterestList66.java | 71 +- .../cache/tier/sockets/command/RemoveAll.java | 16 +- .../cache/tier/sockets/command/RemoveUserAuth.java | 4 +- .../cache/tier/sockets/command/Request.java | 14 +- .../tier/sockets/command/RequestEventValue.java | 5 +- .../tier/sockets/command/RollbackCommand.java | 4 +- .../internal/cache/tier/sockets/command/Size.java | 13 +- .../tier/sockets/command/TXFailoverCommand.java | 14 +- .../sockets/command/TXSynchronizationCommand.java | 7 +- .../tier/sockets/command/UnregisterInterest.java | 14 +- .../sockets/command/UnregisterInterestList.java | 8 +- .../sockets/command/UpdateClientNotification.java | 61 +- .../cache/tx/AbstractPeerTXRegionStub.java | 4 +- .../geode/internal/cache/tx/ClientTXStateStub.java | 10 +- .../internal/cache/tx/DistributedTXRegionStub.java | 21 +- .../internal/cache/tx/PartitionedTXRegionStub.java | 31 +- .../cache/versions/RegionVersionVector.java | 10 +- .../internal/cache/wan/AbstractGatewaySender.java | 52 +- .../wan/AbstractGatewaySenderEventProcessor.java | 2 + .../internal/cache/wan/GatewayReceiverStats.java | 22 +- .../internal/cache/wan/GatewaySenderAdvisor.java | 2 +- .../wan/GatewaySenderEventCallbackDispatcher.java | 5 + .../cache/wan/GatewaySenderEventDispatcher.java | 2 + .../internal/cache/wan/GatewaySenderEventImpl.java | 2 +- ...waySenderQueueEntrySynchronizationListener.java | 35 + ...aySenderQueueEntrySynchronizationOperation.java | 314 +++ .../internal/cache/wan/GatewaySenderStats.java | 29 +- ...currentParallelGatewaySenderEventProcessor.java | 8 + .../ParallelGatewaySenderEventProcessor.java | 22 +- .../wan/parallel/ParallelQueueRemovalMessage.java | 3 +- ...oncurrentSerialGatewaySenderEventProcessor.java | 7 + .../serial/SerialGatewaySenderEventProcessor.java | 10 +- .../cache/wan/serial/SerialGatewaySenderQueue.java | 6 +- .../internal/cache/xmlcache/CacheCreation.java | 92 +- .../geode/internal/cache/xmlcache/CacheXml.java | 3 +- .../internal/cache/xmlcache/CacheXmlGenerator.java | 6 + .../internal/cache/xmlcache/CacheXmlParser.java | 31 +- .../cache/xmlcache/ClientCacheCreation.java | 10 + .../cache/xmlcache/GatewayReceiverCreation.java | 32 +- .../xmlcache/ParallelGatewaySenderCreation.java | 9 + .../xmlcache/SerialGatewaySenderCreation.java | 9 + .../internal/cache/xmlcache/XmlGenerator.java | 4 +- .../geode/internal/cache/xmlcache/XmlParser.java | 7 +- .../ClusterConfigurationNotAvailableException.java | 28 + .../InvalidExecutionContextException.java | 33 + .../geode/internal/i18n/LocalizedStrings.java | 25 +- .../io/MainWithChildrenRollingFileHandler.java | 3 + .../apache/geode/internal/io/TeePrintStream.java | 2 +- .../apache/geode/internal/lang/Initializer.java | 45 - .../geode/internal/logging/LogFileParser.java | 16 +- .../geode/internal/logging/LogWriterFactory.java | 32 +- .../geode/internal/logging/MergeLogFiles.java | 13 +- .../apache/geode/internal/logging/SortLogFile.java | 23 +- .../internal/logging/log4j/LogWriterAppenders.java | 8 +- .../internal/net/SSLConfigurationFactory.java | 206 +- .../apache/geode/internal/net/SocketCloser.java | 165 +- .../apache/geode/internal/net/SocketCreator.java | 74 +- .../geode/internal/process/AttachProcessUtils.java | 9 +- .../process/BlockingProcessStreamReader.java | 33 +- .../ClusterConfigurationNotAvailableException.java | 29 - .../process/ConnectionFailedException.java | 14 +- .../internal/process/ControlFileWatchdog.java | 124 +- .../process/ControlNotificationHandler.java | 5 +- .../internal/process/ControllableProcess.java | 225 +- .../process/FileAlreadyExistsException.java | 14 +- .../internal/process/FileControllerParameters.java | 5 +- .../internal/process/FileProcessController.java | 113 +- .../internal/process/LocalProcessController.java | 478 ----- .../internal/process/LocalProcessLauncher.java | 101 +- .../process/MBeanControllerParameters.java | 13 +- .../process/MBeanInvocationFailedException.java | 14 +- .../internal/process/MBeanProcessController.java | 128 +- .../geode/internal/process/NativeProcessUtils.java | 14 +- .../process/NonBlockingProcessStreamReader.java | 88 +- .../org/apache/geode/internal/process/PidFile.java | 113 +- .../internal/process/PidUnavailableException.java | 14 +- .../geode/internal/process/ProcessController.java | 17 +- .../internal/process/ProcessControllerFactory.java | 72 +- .../process/ProcessControllerParameters.java | 6 +- .../internal/process/ProcessLauncherContext.java | 68 +- .../internal/process/ProcessStreamReader.java | 161 +- .../ProcessTerminatedAbnormallyException.java | 97 - .../apache/geode/internal/process/ProcessType.java | 24 +- .../geode/internal/process/ProcessUtils.java | 66 +- .../geode/internal/process/StartupStatus.java | 20 +- .../internal/process/StartupStatusListener.java | 2 +- .../process/UnableToControlProcessException.java | 14 +- .../signal/AbstractSignalNotificationHandler.java | 81 +- .../geode/internal/process/signal/Signal.java | 20 +- .../geode/internal/process/signal/SignalEvent.java | 11 +- .../internal/process/signal/SignalListener.java | 9 +- .../geode/internal/process/signal/SignalType.java | 7 +- .../internal/security/CallbackInstantiator.java | 117 ++ .../geode/internal/security/Credentials.java | 36 + .../security/IntegratedSecurityService.java | 393 ++-- .../internal/security/LegacySecurityService.java | 52 + .../geode/internal/security/SecurityService.java | 186 +- .../internal/security/SecurityServiceFactory.java | 108 + .../internal/security/shiro/CustomAuthRealm.java | 18 +- .../security/shiro/JMXShiroAuthenticator.java | 22 +- .../security/shiro/SecurityManagerProvider.java | 83 + .../sequencelog/io/GemfireLogConverter.java | 4 +- .../geode/internal/statistics/ArchiveSplitter.java | 24 +- .../internal/statistics/StatArchiveReader.java | 203 +- .../org/apache/geode/internal/tcp/Connection.java | 122 +- .../apache/geode/internal/tcp/ConnectionTable.java | 54 +- .../org/apache/geode/internal/tcp/MsgReader.java | 2 +- .../geode/internal/tcp/PeerConnectionFactory.java | 32 + .../org/apache/geode/internal/tcp/TCPConduit.java | 30 +- .../geode/internal/util/ArgumentRedactor.java | 6 +- .../apache/geode/internal/util/PasswordUtil.java | 100 +- .../util/concurrent/CopyOnWriteHashMap.java | 4 + .../concurrent/CustomEntryConcurrentHashMap.java | 6 +- .../apache/geode/management/CacheServerMXBean.java | 122 +- .../apache/geode/management/DiskStoreMXBean.java | 68 +- .../geode/management/DistributedSystemMXBean.java | 174 +- .../geode/management/GatewayReceiverMXBean.java | 75 +- .../geode/management/GatewaySenderMXBean.java | 88 +- .../apache/geode/management/GemFireProperties.java | 52 +- .../apache/geode/management/LockServiceMXBean.java | 20 +- .../org/apache/geode/management/MemberMXBean.java | 266 +-- .../apache/geode/management/cli/CliMetaData.java | 14 +- .../management/cli/CommandProcessingException.java | 1 - .../geode/management/cli/CommandService.java | 54 +- .../geode/management/cli/CommandStatement.java | 4 +- .../management/internal/FederatingManager.java | 76 +- .../geode/management/internal/FilterChain.java | 54 - .../management/internal/JmxManagerAdvisor.java | 4 +- .../internal/JmxManagerLocatorRequest.java | 50 +- .../management/internal/LocalFilterChain.java | 61 - .../geode/management/internal/MBeanJMXAdapter.java | 199 +- .../management/internal/MBeanProxyFactory.java | 108 +- .../geode/management/internal/ManagementAgent.java | 115 +- .../management/internal/RemoteFilterChain.java | 101 - .../internal/SystemManagementService.java | 68 +- .../management/internal/beans/BeanUtilFuncs.java | 2 + .../internal/beans/CacheServerBridge.java | 18 +- .../internal/beans/DistributedSystemMBean.java | 21 +- .../management/internal/beans/MBeanAggregator.java | 7 +- .../internal/beans/ManagementAdapter.java | 48 +- .../management/internal/beans/MemberMBean.java | 15 +- .../internal/beans/MemberMBeanBridge.java | 71 +- .../internal/beans/QueryDataFunction.java | 12 +- .../management/internal/beans/ServerBridge.java | 16 +- .../internal/beans/stats/VMStatsMonitor.java | 14 +- .../internal/cli/AbstractCliAroundInterceptor.java | 18 +- .../geode/management/internal/cli/CliUtil.java | 196 +- .../management/internal/cli/CommandManager.java | 33 +- .../management/internal/cli/CommandRequest.java | 79 +- .../management/internal/cli/CommandResponse.java | 20 +- .../internal/cli/CommandResponseBuilder.java | 27 +- .../management/internal/cli/GfshParseResult.java | 31 +- .../geode/management/internal/cli/GfshParser.java | 46 +- .../geode/management/internal/cli/Launcher.java | 34 +- .../geode/management/internal/cli/LogWrapper.java | 44 +- .../cli/commands/AlterOfflineDiskStoreCommand.java | 141 ++ .../internal/cli/commands/AlterRegionCommand.java | 231 +++ .../cli/commands/AlterRuntimeConfigCommand.java | 246 +++ .../cli/commands/BackupDiskStoreCommand.java | 142 ++ .../cli/commands/ChangeLogLevelCommand.java | 165 ++ .../cli/commands/ClearDefinedIndexesCommand.java | 40 + .../internal/cli/commands/ClientCommands.java | 352 ---- .../cli/commands/CloseDurableCQsCommand.java | 83 + .../cli/commands/CloseDurableClientCommand.java | 77 + .../cli/commands/CommandAvailabilityIndicator.java | 63 + .../cli/commands/CompactDiskStoreCommand.java | 185 ++ .../commands/CompactOfflineDiskStoreCommand.java | 176 ++ .../internal/cli/commands/ConfigCommands.java | 501 ----- .../internal/cli/commands/ConfigurePDXCommand.java | 138 ++ .../internal/cli/commands/ConnectCommand.java | 517 +++++ .../cli/commands/CountDurableCQEventsCommand.java | 88 + .../commands/CreateAlterDestroyRegionCommands.java | 1141 ---------- .../cli/commands/CreateAsyncEventQueueCommand.java | 171 ++ .../cli/commands/CreateDefinedIndexesCommand.java | 152 ++ .../cli/commands/CreateDiskStoreCommand.java | 166 ++ .../cli/commands/CreateGatewayReceiverCommand.java | 128 ++ .../cli/commands/CreateGatewaySenderCommand.java | 159 ++ .../internal/cli/commands/CreateIndexCommand.java | 195 ++ .../internal/cli/commands/CreateRegionCommand.java | 725 +++++++ .../internal/cli/commands/DataCommandUtil.java | 44 + .../internal/cli/commands/DataCommands.java | 1279 ------------ .../internal/cli/commands/DataCommandsUtils.java | 311 +++ .../internal/cli/commands/DebugCommand.java | 54 + .../internal/cli/commands/DefineIndexCommand.java | 96 + .../internal/cli/commands/DeployCommand.java | 171 ++ .../internal/cli/commands/DeployCommands.java | 340 --- .../cli/commands/DescribeClientCommand.java | 245 +++ .../cli/commands/DescribeConfigCommand.java | 153 ++ .../cli/commands/DescribeConnectionCommand.java | 52 + .../cli/commands/DescribeDiskStoreCommand.java | 177 ++ .../cli/commands/DescribeMemberCommand.java | 132 ++ .../commands/DescribeOfflineDiskStoreCommand.java | 75 + .../cli/commands/DescribeRegionCommand.java | 372 ++++ .../cli/commands/DestroyDiskStoreCommand.java | 106 + .../cli/commands/DestroyFunctionCommand.java | 163 ++ .../cli/commands/DestroyGatewaySenderCommand.java | 90 + .../internal/cli/commands/DestroyIndexCommand.java | 174 ++ .../cli/commands/DestroyRegionCommand.java | 222 ++ .../internal/cli/commands/DisconnectCommand.java | 65 + .../internal/cli/commands/DiskStoreCommands.java | 1475 ------------- .../cli/commands/DiskStoreCommandsUtils.java | 60 + .../cli/commands/DurableClientCommands.java | 430 ---- .../DurableClientCommandsResultBuilder.java | 164 ++ .../internal/cli/commands/EchoCommand.java | 60 + .../cli/commands/ExecuteFunctionCommand.java | 177 ++ .../cli/commands/ExecuteScriptCommand.java | 52 + .../internal/cli/commands/ExitCommand.java | 40 + .../internal/cli/commands/ExportConfigCommand.java | 151 ++ .../internal/cli/commands/ExportDataCommand.java | 110 + .../ExportImportClusterConfigurationCommands.java | 54 +- .../internal/cli/commands/ExportLogsCommand.java | 44 +- .../commands/ExportOfflineDiskStoreCommand.java | 68 + .../cli/commands/ExportStackTraceCommand.java | 157 ++ .../internal/cli/commands/FunctionCommands.java | 597 ------ .../internal/cli/commands/GCCommand.java | 131 ++ .../cli/commands/GatewayCommandsUtils.java | 46 + .../internal/cli/commands/GetCommand.java | 108 + .../internal/cli/commands/GfshCommand.java | 95 +- .../internal/cli/commands/GfshHelpCommand.java | 45 + .../internal/cli/commands/GfshHelpCommands.java | 55 - .../internal/cli/commands/GfshHintCommand.java | 42 + .../internal/cli/commands/HistoryCommand.java | 141 ++ .../internal/cli/commands/ImportDataCommand.java | 106 + .../internal/cli/commands/IndexCommands.java | 692 ------- .../internal/cli/commands/IndexDefinition.java | 27 + .../cli/commands/LauncherLifecycleCommands.java | 1413 ------------- .../cli/commands/LauncherSignalListener.java | 31 + .../cli/commands/ListAsyncEventQueuesCommand.java | 118 ++ .../internal/cli/commands/ListClientCommand.java | 128 ++ .../internal/cli/commands/ListDeployedCommand.java | 102 + .../cli/commands/ListDiskStoresCommand.java | 112 + .../cli/commands/ListDurableClientCQsCommand.java | 121 ++ .../internal/cli/commands/ListFunctionCommand.java | 101 + .../internal/cli/commands/ListGatewayCommand.java | 165 ++ .../internal/cli/commands/ListIndexCommand.java | 163 ++ .../internal/cli/commands/ListMembersCommand.java | 77 + .../internal/cli/commands/ListRegionCommand.java | 113 + .../commands/LoadBalanceGatewaySenderCommand.java | 104 + .../internal/cli/commands/LocateEntryCommand.java | 93 + .../internal/cli/commands/MemberCommands.java | 208 -- .../cli/commands/MiscellaneousCommands.java | 1961 ------------------ .../internal/cli/commands/NetstatCommand.java | 212 ++ .../internal/cli/commands/PDXCommands.java | 216 -- .../internal/cli/commands/PDXRenameCommand.java | 81 + .../cli/commands/PauseGatewaySenderCommand.java | 119 ++ .../internal/cli/commands/PutCommand.java | 107 + .../internal/cli/commands/QueryCommand.java | 60 +- .../internal/cli/commands/QueueCommands.java | 269 --- .../internal/cli/commands/RebalanceCommand.java | 592 ++++++ .../internal/cli/commands/RegionCommands.java | 502 ----- .../internal/cli/commands/RegionCommandsUtils.java | 78 + .../internal/cli/commands/RemoveCommand.java | 98 + .../cli/commands/ResumeGatewaySenderCommand.java | 119 ++ .../commands/RevokeMissingDiskStoreCommand.java | 61 + .../internal/cli/commands/SetVariableCommand.java | 47 + .../internal/cli/commands/ShCommand.java | 95 + .../internal/cli/commands/ShellCommands.java | 1046 ---------- .../internal/cli/commands/ShowDeadlockCommand.java | 92 + .../internal/cli/commands/ShowLogCommand.java | 105 + .../internal/cli/commands/ShowMetricsCommand.java | 1083 ++++++++++ .../cli/commands/ShowMissingDiskStoreCommand.java | 149 ++ .../internal/cli/commands/ShutdownCommand.java | 205 ++ .../internal/cli/commands/SleepCommand.java | 39 + .../cli/commands/StartGatewayReceiverCommand.java | 115 ++ .../cli/commands/StartGatewaySenderCommand.java | 167 ++ .../internal/cli/commands/StartLocatorCommand.java | 497 +++++ .../internal/cli/commands/StartMemberUtils.java | 247 +++ .../internal/cli/commands/StartServerCommand.java | 583 ++++++ .../StatusClusterConfigServiceCommand.java | 82 + .../internal/cli/commands/StatusCommands.java | 92 - .../cli/commands/StatusGatewayReceiverCommand.java | 112 + .../cli/commands/StatusGatewaySenderCommand.java | 131 ++ .../cli/commands/StopGatewayReceiverCommand.java | 114 + .../cli/commands/StopGatewaySenderCommand.java | 113 + .../internal/cli/commands/UndeployCommand.java | 114 + .../commands/UpgradeOfflineDiskStoreCommand.java | 177 ++ .../internal/cli/commands/UserInputProperty.java | 120 ++ .../cli/commands/ValidateDiskStoreCommand.java | 104 + .../internal/cli/commands/VersionCommand.java | 36 + .../internal/cli/commands/WanCommands.java | 1156 ----------- .../cli/commands/lifecycle/StartPulseCommand.java | 18 +- .../commands/lifecycle/StatusLocatorCommand.java | 18 +- .../commands/lifecycle/StatusServerCommand.java | 11 +- .../internal/cli/converters/HelpConverter.java | 25 +- .../cli/converters/MemberGroupConverter.java | 11 +- .../internal/cli/domain/DataCommandResult.java | 14 +- .../internal/cli/domain/IndexDetails.java | 74 +- .../management/internal/cli/domain/IndexInfo.java | 16 +- .../cli/functions/AlterRuntimeConfigFunction.java | 7 +- .../cli/functions/ChangeLogLevelFunction.java | 3 +- .../cli/functions/ContinuousQueryFunction.java | 143 ++ .../cli/functions/ContunuousQueryFunction.java | 150 -- .../functions/CreateAsyncEventQueueFunction.java | 21 +- .../functions/CreateDefinedIndexesFunction.java | 16 +- .../cli/functions/CreateDiskStoreFunction.java | 7 +- .../cli/functions/CreateIndexFunction.java | 9 +- .../cli/functions/DataCommandFunction.java | 23 +- .../internal/cli/functions/DeployFunction.java | 11 +- .../cli/functions/DescribeDiskStoreFunction.java | 7 +- .../cli/functions/DestroyDiskStoreFunction.java | 7 +- .../cli/functions/DestroyIndexFunction.java | 3 +- .../cli/functions/ExportConfigFunction.java | 3 +- .../internal/cli/functions/ExportDataFunction.java | 17 +- .../internal/cli/functions/ExportLogsFunction.java | 2 +- .../cli/functions/GarbageCollectionFunction.java | 3 +- .../functions/GatewayReceiverCreateFunction.java | 23 +- .../cli/functions/GatewayReceiverFunctionArgs.java | 10 +- .../cli/functions/GatewaySenderCreateFunction.java | 19 +- .../functions/GatewaySenderDestroyFunction.java | 3 +- .../GetMemberConfigInformationFunction.java | 3 +- .../functions/GetMemberInformationFunction.java | 3 +- .../functions/GetRegionDescriptionFunction.java | 3 +- .../internal/cli/functions/GetRegionsFunction.java | 3 +- .../cli/functions/GetStackTracesFunction.java | 3 +- .../internal/cli/functions/ImportDataFunction.java | 14 +- .../functions/ListAsyncEventQueuesFunction.java | 8 +- .../cli/functions/ListDeployedFunction.java | 7 +- .../cli/functions/ListDurableCqNamesFunction.java | 8 +- .../cli/functions/ListFunctionFunction.java | 3 +- .../cli/functions/MemberRegionFunction.java | 3 +- .../cli/functions/MembersForRegionFunction.java | 4 +- .../internal/cli/functions/RebalanceFunction.java | 3 +- .../cli/functions/RegionAlterFunction.java | 21 +- .../cli/functions/RegionCreateFunction.java | 63 +- .../cli/functions/RegionDestroyFunction.java | 3 +- .../internal/cli/functions/RegionFunctionArgs.java | 26 +- .../functions/ShowMissingDiskStoresFunction.java | 6 +- .../cli/functions/SizeExportLogsFunction.java | 2 +- .../internal/cli/functions/UndeployFunction.java | 17 +- .../internal/cli/functions/UnregisterFunction.java | 4 - .../cli/functions/UserFunctionExecution.java | 218 +- .../management/internal/cli/i18n/CliStrings.java | 318 +-- .../internal/cli/multistep/CLIMultiStepHelper.java | 402 ---- .../internal/cli/multistep/CLIRemoteStep.java | 30 - .../management/internal/cli/multistep/CLIStep.java | 31 - .../internal/cli/multistep/CLIStepExecption.java | 36 - .../internal/cli/multistep/MultiStepCommand.java | 31 - .../cli/remote/CommandExecutionContext.java | 15 +- .../internal/cli/remote/CommandExecutor.java | 58 + .../internal/cli/remote/CommandProcessor.java | 182 -- .../internal/cli/remote/CommandStatementImpl.java | 55 +- .../internal/cli/remote/MemberCommandService.java | 34 +- .../cli/remote/OnlineCommandProcessor.java | 133 ++ .../cli/remote/RemoteExecutionStrategy.java | 134 -- .../internal/cli/result/AbstractResultData.java | 81 +- .../internal/cli/result/CommandResult.java | 115 +- .../internal/cli/result/CompositeResultData.java | 19 +- .../internal/cli/result/DownloadFileResult.java | 73 + .../internal/cli/result/ErrorResultData.java | 6 +- .../internal/cli/result/InfoResultData.java | 18 +- .../internal/cli/result/ResultBuilder.java | 68 +- .../management/internal/cli/result/ResultData.java | 6 +- .../internal/cli/result/TableBuilder.java | 9 +- .../geode/management/internal/cli/shell/Gfsh.java | 188 +- .../internal/cli/shell/GfshExecutionStrategy.java | 141 +- .../internal/cli/shell/JmxOperationInvoker.java | 217 +- .../internal/cli/shell/ScriptExecutionDetails.java | 79 + .../cli/shell/unsafe/GfshSignalHandler.java | 13 +- .../internal/cli/util/CommandStringBuilder.java | 31 +- .../internal/cli/util/GfshConsoleReader.java | 35 +- .../management/internal/cli/util/JsonUtil.java | 6 +- .../internal/cli/util/ReadWriteFile.java | 78 +- .../configuration/domain/CacheElement.java | 46 +- .../internal/configuration/domain/XmlEntity.java | 50 +- .../functions/RecreateCacheFunction.java | 4 +- .../messages/ConfigurationRequest.java | 18 +- .../utils/ClusterConfigurationStatusRetriever.java | 17 +- .../internal/configuration/utils/DtdResolver.java | 91 - .../internal/configuration/utils/XmlUtils.java | 205 +- .../internal/security/AccessControlMBean.java | 13 +- .../internal/security/MBeanServerWrapper.java | 39 +- .../internal/security/ResourceOperation.java | 14 +- .../internal/security/ResourcePermissions.java | 35 + .../controllers/AbstractCommandsController.java | 540 +---- .../AbstractMultiPartCommandsController.java | 77 - .../web/controllers/ClientCommandsController.java | 58 - .../web/controllers/ClusterCommandsController.java | 46 - .../web/controllers/ConfigCommandsController.java | 225 -- .../web/controllers/DataCommandsController.java | 230 --- .../web/controllers/DeployCommandsController.java | 114 - .../controllers/DiskStoreCommandsController.java | 190 -- .../DurableClientCommandsController.java | 174 -- .../web/controllers/ExportLogController.java | 140 -- .../controllers/FunctionCommandsController.java | 146 -- .../web/controllers/IndexCommandsController.java | 177 -- .../LauncherLifecycleCommandsController.java | 54 - .../web/controllers/MemberCommandsController.java | 79 - .../MiscellaneousCommandsController.java | 247 --- .../web/controllers/PdxCommandsController.java | 126 -- .../web/controllers/QueueCommandsController.java | 157 -- .../web/controllers/RegionCommandsController.java | 404 ---- .../web/controllers/ShellCommandsController.java | 334 +-- .../web/controllers/WanCommandsController.java | 498 ----- .../support/LoginHandlerInterceptor.java | 42 +- .../geode/management/internal/web/domain/Link.java | 164 -- .../management/internal/web/domain/LinkIndex.java | 138 -- .../internal/web/http/ClientHttpRequest.java | 507 ----- .../management/internal/web/http/HttpHeader.java | 99 - .../management/internal/web/http/HttpMethod.java | 27 - .../internal/web/http/support/HttpRequester.java | 202 ++ .../web/http/support/SimpleHttpRequester.java | 250 --- .../web/shell/AbstractHttpOperationInvoker.java | 895 -------- .../internal/web/shell/HttpOperationInvoker.java | 410 +++- .../RestApiCallForCommandNotFoundException.java | 42 - .../web/shell/RestHttpOperationInvoker.java | 464 ----- .../web/shell/SimpleHttpOperationInvoker.java | 163 -- .../management/internal/web/util/ConvertUtils.java | 88 +- .../geode/pdx/internal/CheckTypeRegistryState.java | 2 +- .../geode/pdx/internal/PeerTypeRegistration.java | 18 +- .../geode/redis/internal/RegionProvider.java | 29 +- .../org/apache/geode/security/AuthInitialize.java | 14 +- .../org/apache/geode/security/PostProcessor.java | 2 +- .../apache/geode/security/ResourcePermission.java | 100 +- .../security/internal/server/Authenticator.java | 59 + .../geode/security/internal/server/Authorizer.java | 21 + .../internal/server/NoOpAuthenticator.java | 48 + .../security/internal/server/NoOpAuthorizer.java | 27 + .../geode/security/internal/server/package.html | 45 + .../geode.apache.org/schema/cache/cache-1.0.xsd | 10 +- ...he.geode.security.internal.server.Authenticator | 1 + .../java/com/main/WANBootStrapping_Site1_Add.java | 15 +- .../com/main/WANBootStrapping_Site1_Remove.java | 14 +- .../java/com/main/WANBootStrapping_Site2_Add.java | 14 +- .../com/main/WANBootStrapping_Site2_Remove.java | 12 +- .../java/org/apache/geode/LonerDMJUnitTest.java | 15 - .../test/java/org/apache/geode/TXJUnitTest.java | 369 ++-- .../java/org/apache/geode/TXWriterTestCase.java | 2 +- .../apache/geode/cache/CacheListenerJUnitTest.java | 6 +- .../geode/cache/ConnectionPoolDUnitTest.java | 6 +- .../cache/client/ClientCacheFactoryJUnitTest.java | 26 +- .../internal/AutoConnectionSourceDUnitTest.java | 12 +- .../AutoConnectionSourceImplJUnitTest.java | 136 +- .../internal/ConnectionPoolImplJUnitTest.java | 6 +- .../client/internal/QueueManagerJUnitTest.java | 4 + .../apache/geode/cache/query/IndexTypeTest.java | 41 + .../cache/query/JoinQueriesIntegrationTest.java | 122 ++ .../cache/query/TypedJsonQueryIntegrationTest.java | 102 + .../apache/geode/cache/query/data/Portfolio.java | 4 + .../query/dunit/CorruptedIndexIntegrationTest.java | 265 +++ .../query/dunit/QueryIndexUsingXMLDUnitTest.java | 30 +- .../dunit/QueryParamsAuthorizationDUnitTest.java | 87 +- .../ResourceManagerWithQueryMonitorDUnitTest.java | 2 +- .../query/functional/IndexCreationJUnitTest.java | 32 + .../query/functional/StructSetOrResultsSet.java | 13 +- .../cache/query/internal/CompiledInJUnitTest.java | 68 +- .../query/internal/OrderByComparatorJUnitTest.java | 71 +- .../RestrictedMethodInvocationAuthorizerTest.java | 514 +++++ .../CompactRangeIndexQueryIntegrationTest.java | 54 +- .../internal/index/HashIndexSetJUnitTest.java | 2 +- .../query/transaction/QueryAndJtaJUnitTest.java | 26 - .../cache/server/internal/LoadMonitorTest.java | 50 + .../cache/snapshot/CacheSnapshotJUnitTest.java | 44 +- .../cache/snapshot/ParallelSnapshotDUnitTest.java | 152 +- .../cache/snapshot/RegionSnapshotJUnitTest.java | 165 +- .../cache/snapshot/SnapshotByteArrayDUnitTest.java | 44 +- .../geode/cache/snapshot/SnapshotDUnitTest.java | 3 +- .../snapshot/SnapshotPerformanceDUnitTest.java | 4 +- .../geode/cache/snapshot/SnapshotTestCase.java | 56 +- .../cache/snapshot/TestSnapshotFileMapper.java | 52 + .../geode/cache/snapshot/WanSnapshotJUnitTest.java | 17 +- .../geode/cache/util/PasswordUtilJUnitTest.java | 42 - .../apache/geode/cache/util/TxEventTestUtil.java | 88 + .../apache/geode/cache30/Bug34387DUnitTest.java | 188 -- .../apache/geode/cache30/Bug34948DUnitTest.java | 157 -- .../apache/geode/cache30/Bug35214DUnitTest.java | 220 -- .../apache/geode/cache30/Bug38013DUnitTest.java | 150 -- .../apache/geode/cache30/CacheLoaderTestCase.java | 2 +- .../geode/cache30/CacheStatisticsDUnitTest.java | 3 +- .../org/apache/geode/cache30/CacheTestCase.java | 10 +- .../geode/cache30/ClientServerCCEDUnitTest.java | 131 +- .../CreateAndLocalDestroyInTXRegressionTest.java | 167 ++ .../apache/geode/cache30/DiskRegionDUnitTest.java | 4 +- .../EntriesDoNotExpireDuringGIIRegressionTest.java | 210 ++ .../geode/cache30/MultiVMRegionTestCase.java | 75 +- .../geode/cache30/RegionAttributesTestCase.java | 5 +- .../geode/cache30/RegionExpirationDUnitTest.java | 3 +- .../org/apache/geode/cache30/RegionTestCase.java | 2 +- ...tePRValuesAreNotDeserializedRegressionTest.java | 168 ++ .../ValuesAreLazilyDeserializedRegressionTest.java | 169 ++ .../AnalyzeSerializablesJUnitTest.java | 67 +- .../geode/codeAnalysis/decode/CompiledClass.java | 25 +- .../AbstractLauncherIntegrationTest.java | 49 +- .../AbstractLauncherIntegrationTestCase.java | 268 --- .../AbstractLauncherServiceStateTest.java | 224 ++ .../AbstractLauncherServiceStatusTest.java | 224 -- .../geode/distributed/AbstractLauncherTest.java | 462 +++-- ...AbstractLocatorLauncherIntegrationTestCase.java | 135 -- ...ctLocatorLauncherRemoteIntegrationTestCase.java | 65 - .../AbstractServerLauncherIntegrationTestCase.java | 98 - ...actServerLauncherRemoteIntegrationTestCase.java | 95 - .../distributed/DistributedMemberDUnitTest.java | 107 +- .../distributed/DistributedSystemConnectPerf.java | 10 +- .../distributed/LauncherIntegrationTestCase.java | 324 +++ .../LauncherMemberMXBeanIntegrationTest.java | 174 +- .../apache/geode/distributed/LocatorCommand.java | 107 + .../apache/geode/distributed/LocatorDUnitTest.java | 305 ++- .../distributed/LocatorLauncherBuilderTest.java | 507 +++++ .../LocatorLauncherIntegrationTest.java | 278 ++- .../LocatorLauncherIntegrationTestCase.java | 163 ++ ...catorLauncherJmxManagerLocalRegressionTest.java | 111 + ...atorLauncherJmxManagerRemoteRegressionTest.java | 72 + .../LocatorLauncherLocalFileIntegrationTest.java | 35 +- .../LocatorLauncherLocalIntegrationTest.java | 887 ++------ .../LocatorLauncherRemoteFileIntegrationTest.java | 211 +- .../LocatorLauncherRemoteIntegrationTest.java | 1091 ++-------- .../LocatorLauncherRemoteIntegrationTestCase.java | 234 +++ ...cherRemoteWithCustomLoggingIntegrationTest.java | 104 +- .../geode/distributed/LocatorLauncherTest.java | 344 +--- .../apache/geode/distributed/LocatorStateTest.java | 185 +- .../distributed/LocatorUDPSecurityDUnitTest.java | 6 +- .../MockServerLauncherCacheProvider.java | 38 - .../apache/geode/distributed/ServerCommand.java | 120 ++ .../distributed/ServerLauncherBuilderTest.java | 855 ++++++++ .../distributed/ServerLauncherIntegrationTest.java | 349 ++-- .../ServerLauncherIntegrationTestCase.java | 204 ++ .../ServerLauncherLocalFileIntegrationTest.java | 24 +- .../ServerLauncherLocalIntegrationTest.java | 1123 +++------- .../ServerLauncherLocalIntegrationTestCase.java | 26 + .../ServerLauncherRemoteFileIntegrationTest.java | 207 +- .../ServerLauncherRemoteIntegrationTest.java | 1578 ++------------ .../ServerLauncherRemoteIntegrationTestCase.java | 236 +++ ...cherRemoteWithCustomLoggingIntegrationTest.java | 107 +- .../geode/distributed/ServerLauncherTest.java | 967 ++------- ...erverLauncherWaitOnServerMultiThreadedTest.java | 111 + .../ServerLauncherWithProviderIntegrationTest.java | 81 - .../ServerLauncherWithProviderRegressionTest.java | 68 + .../TestServerLauncherCacheProvider.java | 42 + .../geode/distributed/UsesLocatorCommand.java | 28 + .../geode/distributed/UsesServerCommand.java | 30 + .../internal/DistributionConfigJUnitTest.java | 30 +- .../internal/ProductUseLogDUnitTest.java | 2 + .../internal/StartupMessageDataJUnitTest.java | 4 +- .../deadlock/GemFireDeadlockDetectorDUnitTest.java | 4 + .../internal/membership/MembershipJUnitTest.java | 77 +- .../gms/auth/AbstractGMSAuthenticatorTestCase.java | 33 +- .../GMSAuthenticatorWithAuthenticatorTest.java | 88 +- .../GMSAuthenticatorWithSecurityManagerTest.java | 74 +- .../gms/locator/GMSLocatorRecoveryJUnitTest.java | 70 +- .../gms/membership/GMSJoinLeaveJUnitTest.java | 66 +- .../gms/membership/GMSJoinLeaveTestHelper.java | 16 +- .../gms/messenger/GMSEncryptJUnitTest.java | 1 - .../gms/messenger/JGroupsMessengerJUnitTest.java | 6 +- .../gms/mgr/GMSMembershipManagerJUnitTest.java | 8 +- .../internal/tcpserver/TCPServerSSLJUnitTest.java | 3 +- .../internal/tcpserver/TcpServerJUnitTest.java | 5 +- .../support/DistributedSystemAdapter.java | 272 --- .../disttx/DistributedTransactionDUnitTest.java | 8 +- .../org/apache/geode/disttx/PRDistTXDUnitTest.java | 9 + .../disttx/PRDistTXWithVersionsDUnitTest.java | 9 + .../org/apache/geode/internal/ClassBuilder.java | 285 --- .../internal/ClassPathLoaderIntegrationTest.java | 195 +- .../apache/geode/internal/ClassPathLoaderTest.java | 2 +- .../geode/internal/DeployedJarJUnitTest.java | 398 +--- .../geode/internal/JarDeployerDeadlockTest.java | 131 ++ .../geode/internal/JarDeployerIntegrationTest.java | 40 +- .../internal/cache/AbstractRegionEntryTest.java | 64 +- .../internal/cache/AbstractRegionMapTest.java | 48 + .../geode/internal/cache/BackupDUnitTest.java | 176 +- .../geode/internal/cache/BackupJUnitTest.java | 145 +- .../cache/BucketPersistenceAdvisorTest.java | 56 + .../cache/BucketRedundancyTrackerTest.java | 124 ++ .../internal/cache/BucketRegionJUnitTest.java | 4 + .../geode/internal/cache/Bug48182JUnitTest.java | 13 +- .../cache/ClientServerTransactionDUnitTest.java | 180 +- .../geode/internal/cache/ColocationHelperTest.java | 14 + .../internal/cache/ConnectDisconnectDUnitTest.java | 148 +- .../internal/cache/DeltaPropagationDUnitTest.java | 661 +++--- .../internal/cache/DiskRegCbkChkJUnitTest.java | 6 +- .../geode/internal/cache/DiskRegionJUnitTest.java | 5 +- .../internal/cache/DiskStoreFactoryJUnitTest.java | 20 + .../internal/cache/DistributedRegionJUnitTest.java | 11 +- .../internal/cache/EventTrackerDUnitTest.java | 486 ----- .../geode/internal/cache/EventTrackerTest.java | 94 - .../internal/cache/FixedPRSinglehopDUnitTest.java | 1 - .../geode/internal/cache/GIIDeltaDUnitTest.java | 9 +- .../internal/cache/IncrementalBackupDUnitTest.java | 5 +- .../geode/internal/cache/IteratorDUnitTest.java | 2 +- .../internal/cache/MapInterface2JUnitTest.java | 2 +- .../geode/internal/cache/OplogFlushTest.java | 13 +- .../internal/cache/OverflowOplogFlushTest.java | 11 +- .../cache/PRCacheListenerInvocationTest.java | 86 + ...istenerWithInterestPolicyAllInvocationTest.java | 70 + .../PartitionedRegionAttributesMutatorTest.java | 211 ++ .../cache/PartitionedRegionDUnitTestCase.java | 4 +- .../cache/PartitionedRegionDataStoreJUnitTest.java | 89 +- .../PartitionedRegionLocalMaxMemoryDUnitTest.java | 229 +-- .../cache/PartitionedRegionQueryDUnitTest.java | 4 +- .../cache/PartitionedRegionQueryEvaluatorTest.java | 17 +- .../PartitionedRegionRedundancyTrackerTest.java | 126 ++ ...itionedRegionSingleNodeOperationsJUnitTest.java | 11 +- .../ReplicateCacheListenerInvocationTest.java | 327 +++ .../internal/cache/TXManagerImplJUnitTest.java | 59 + .../cache/event/DistributedEventTrackerTest.java | 328 +++ .../cache/event/EventTrackerDUnitTest.java | 489 +++++ .../cache/event/EventTrackerExpiryTaskTest.java | 94 + .../event/NonDistributedEventTrackerTest.java | 89 + .../ClientFunctionTimeoutRegressionTest.java | 29 +- ...istributedRegionFunctionExecutionDUnitTest.java | 4 +- .../cache/execute/FunctionServiceBase.java | 37 +- .../FunctionServiceMultipleOnMemberDUnitTest.java | 4 +- .../FunctionServiceSingleOnMemberDUnitTest.java | 12 +- .../cache/execute/LocalDataSetDUnitTest.java | 21 +- .../execute/MemberFunctionExecutionDUnitTest.java | 2 +- .../cache/execute/MyTransactionFunction.java | 16 + ...lientServerFunctionExecutionNoAckDUnitTest.java | 3 +- .../cache/execute/PRColocationDUnitTest.java | 22 +- .../cache/execute/PRTransaction2DUnitTest.java | 145 ++ .../cache/execute/PRTransactionDUnitTest.java | 224 +- .../mock/AbstractMockExtensionXmlGenerator.java | 2 +- .../extension/mock/MockExtensionXmlParser.java | 2 +- .../cache/ha/BlockingHARegionJUnitTest.java | 9 +- .../geode/internal/cache/ha/Bug48571DUnitTest.java | 72 +- .../cache/ha/HARQAddOperationJUnitTest.java | 8 +- .../cache/ha/HARQueueNewImplDUnitTest.java | 40 +- .../ha/PreferSerializedHARegionQueueTest.java | 184 ++ .../BucketRebalanceStatRegressionTest.java | 267 +++ .../DeposePrimaryBucketMessageTest.java | 1 - .../cache/partitioned/FetchEntryMessageTest.java | 1 - .../FetchPartitionDetailsMessageTest.java | 1 - .../cache/partitioned/MoveBucketMessageTest.java | 1 - ...sistentColocatedPartitionedRegionDUnitTest.java | 9 +- .../PersistentPartitionedRegionDUnitTest.java | 5 +- .../PersistentPartitionedRegionTestBase.java | 10 +- .../cache/partitioned/RemoveBucketMessageTest.java | 1 - .../BackupInspectorIntegrationTest.java | 169 ++ .../persistence/BackupInspectorJUnitTest.java | 225 -- .../BackupPrepareAndFinishMsgDUnitTest.java | 239 +++ ...titionedBackupPrepareAndFinishMsgDUnitTest.java | 28 + .../persistence/PersistentReplicatedTestBase.java | 2 +- ...eplicateBackupPrepareAndFinishMsgDUnitTest.java | 28 + .../rollingupgrade/RollingUpgrade2DUnitTest.java | 14 +- .../rollingupgrade/RollingUpgradeDUnitTest.java | 12 +- .../cache/snapshot/GFSnapshotDUnitTest.java | 2 +- .../snapshot/ParallelSnapshotFileMapperTest.java | 83 + .../cache/tier/sockets/AcceptorImplJUnitTest.java | 27 +- .../tier/sockets/ClientHealthMonitorJUnitTest.java | 197 +- .../tier/sockets/HAInterestPart2DUnitTest.java | 17 +- .../sockets/HAStartupAndFailoverDUnitTest.java | 57 +- .../cache/tier/sockets/InterestListDUnitTest.java | 2 +- .../tier/sockets/ServerConnectionFactoryTest.java | 117 ++ .../cache/tier/sockets/ServerConnectionTest.java | 29 +- .../cache/tier/sockets/TcpServerFactoryTest.java | 34 + .../tier/sockets/command/ContainsKey66Test.java | 26 +- .../tier/sockets/command/ContainsKeyTest.java | 27 +- .../tier/sockets/command/CreateRegionTest.java | 26 +- .../cache/tier/sockets/command/Destroy65Test.java | 27 +- .../tier/sockets/command/DestroyRegionTest.java | 26 +- .../cache/tier/sockets/command/DestroyTest.java | 25 +- .../sockets/command/ExecuteFunction65Test.java | 40 +- .../sockets/command/ExecuteFunction66Test.java | 39 +- .../tier/sockets/command/ExecuteFunctionTest.java | 39 +- .../cache/tier/sockets/command/Get70Test.java | 27 +- .../cache/tier/sockets/command/GetAll651Test.java | 31 +- .../cache/tier/sockets/command/GetAll70Test.java | 31 +- .../cache/tier/sockets/command/GetAllTest.java | 33 +- .../sockets/command/GetAllWithCallbackTest.java | 31 +- .../GetClientPartitionAttributesCommand66Test.java | 3 +- .../GetClientPartitionAttributesCommandTest.java | 5 +- .../cache/tier/sockets/command/InvalidateTest.java | 29 +- .../cache/tier/sockets/command/KeySetTest.java | 29 +- .../cache/tier/sockets/command/Put61Test.java | 35 +- .../cache/tier/sockets/command/Put65Test.java | 33 +- .../cache/tier/sockets/command/PutTest.java | 39 +- .../sockets/command/RegisterInterest61Test.java | 35 +- .../command/RegisterInterestList61Test.java | 34 +- .../command/RegisterInterestList66Test.java | 34 +- .../sockets/command/RegisterInterestListTest.java | 34 +- .../tier/sockets/command/RegisterInterestTest.java | 29 +- .../cache/tier/sockets/command/RemoveAllTest.java | 27 +- .../cache/tier/sockets/command/RequestTest.java | 29 +- .../sockets/command/TXFailoverCommandTest.java | 84 + .../sockets/command/UnregisterInterestTest.java | 32 +- .../cache/tx/AbstractPeerTXRegionStubTest.java | 2 +- .../versions/RegionVersionVectorJUnitTest.java | 68 +- ...yncEventQueueEntrySynchronizationDUnitTest.java | 183 ++ .../cache/wan/AsyncEventQueueTestBase.java | 48 +- .../wan/PossibleDuplicateAsyncEventListener.java | 78 + .../cache/wan/WaitingAsyncEventListener.java | 63 + .../AbstractMovingAsyncEventListener.java | 57 + .../asyncqueue/AsyncEventListenerDUnitTest.java | 263 ++- .../ParallelQueueRemovalMessageJUnitTest.java | 14 +- .../cache/wan/serial/DestroyMessageTest.java | 1 - ...SerialGatewaySenderEventProcessorJUnitTest.java | 114 + .../TestSerialGatewaySenderEventProcessor.java | 32 + .../cache/xmlcache/AbstractXmlParserJUnitTest.java | 2 +- .../cache/xmlcache/CacheXmlParserJUnitTest.java | 47 +- .../cache/xmlcache/DefaultEntityResolver2Test.java | 1 - ...ainWithChildrenRollingFileHandlerDUnitTest.java | 2 +- .../internal/jta/ClientServerJTADUnitTest.java | 195 ++ .../internal/jta/functional/TestXACacheLoader.java | 20 +- .../geode/internal/lang/InitializerJUnitTest.java | 78 - .../internal/logging/TestLogWriterFactory.java | 4 +- .../logging/log4j/FastLoggerJUnitTest.java | 3 +- .../net/SSLConfigurationFactoryJUnitTest.java | 37 +- .../geode/internal/net/SocketCloserJUnitTest.java | 155 +- .../offheap/OffHeapLRURecoveryRegressionTest.java | 10 +- ...AbstractProcessStreamReaderIntegrationTest.java | 312 +++ .../internal/process/AttachProcessUtilsTest.java | 85 + .../BaseProcessStreamReaderIntegrationTest.java | 57 + ...BlockingProcessStreamReaderIntegrationTest.java | 133 ++ .../BlockingProcessStreamReaderJUnitTest.java | 443 ---- .../BlockingProcessStreamReaderWindowsTest.java | 93 + .../ControlFileWatchdogIntegrationTest.java | 241 +++ .../ControllableProcessIntegrationTest.java | 196 ++ .../FileProcessControllerIntegrationJUnitTest.java | 151 -- .../FileProcessControllerIntegrationTest.java | 249 +++ .../process/FileProcessControllerTest.java | 90 + .../process/LocalProcessControllerJUnitTest.java | 121 -- .../process/LocalProcessLauncherDUnitTest.java | 154 -- .../LocalProcessLauncherDistributedTest.java | 92 + .../LocalProcessLauncherIntegrationTest.java | 160 ++ .../process/LocalProcessLauncherJUnitTest.java | 177 -- .../process/NativeProcessUtilsIntegrationTest.java | 119 ++ .../internal/process/NativeProcessUtilsTest.java | 76 + ...BlockingProcessStreamReaderIntegrationTest.java | 130 ++ .../NonBlockingProcessStreamReaderJUnitTest.java | 365 ---- .../internal/process/PidFileIntegrationTest.java | 187 ++ .../geode/internal/process/PidFileJUnitTest.java | 275 --- .../ProcessControllerFactoryIntegrationTest.java | 135 ++ .../process/ProcessControllerFactoryJUnitTest.java | 176 -- .../process/ProcessControllerFactoryTest.java | 116 ++ .../process/ProcessLauncherContextTest.java | 208 ++ .../process/ProcessStreamReaderTestCase.java | 254 --- .../geode/internal/process/StartupStatusTest.java | 176 ++ .../geode/internal/process/io/EmptyFileWriter.java | 40 + .../internal/process/io/IntegerFileReader.java | 38 + .../internal/process/io/IntegerFileWriter.java | 33 + .../internal/process/io/StringFileWriter.java | 43 + .../geode/internal/process/lang/AvailablePid.java | 189 ++ .../internal/process/lang/AvailablePidTest.java | 164 ++ .../geode/internal/process/mbean/Process.java | 57 - .../geode/internal/process/mbean/ProcessMBean.java | 27 - ...AbstractSignalNotificationHandlerJUnitTest.java | 467 ----- .../AbstractSignalNotificationHandlerTest.java | 406 ++++ .../security/CallbackInstantiatorTest.java | 98 + .../IntegratedSecurityServiceConstructorTest.java | 93 + .../security/IntegratedSecurityServiceTest.java | 250 +-- .../security/LegacySecurityServiceTest.java | 58 + ...SecurityServiceFactoryShiroIntegrationTest.java | 70 + .../security/SecurityServiceFactoryTest.java | 192 ++ .../internal/security/SecurityServiceTest.java | 129 ++ .../statistics/DiskSpaceLimitIntegrationTest.java | 38 +- .../internal/statistics/StatisticsImplTest.java | 61 +- .../geode/internal/tcp/ConnectionJUnitTest.java | 2 +- .../geode/internal/tcp/ConnectionTableTest.java | 94 + .../internal/util/ArgumentRedactorJUnitTest.java | 20 +- .../geode/internal/util/PasswordUtilJUnitTest.java | 46 + .../geode/management/CacheManagementDUnitTest.java | 48 +- .../management/ClientHealthStatsDUnitTest.java | 32 +- .../apache/geode/management/CompositeStats.java | 37 +- .../geode/management/CompositeTestMBean.java | 12 +- .../geode/management/CompositeTestMXBean.java | 13 +- .../management/CompositeTypeTestDUnitTest.java | 10 +- .../management/ConnectToLocatorSSLDUnitTest.java | 153 -- .../org/apache/geode/management/CustomMBean.java | 72 - .../org/apache/geode/management/CustomMXBean.java | 35 - .../geode/management/DLockManagementDUnitTest.java | 11 +- .../DataBrowserJSONValidationJUnitTest.java | 342 --- .../geode/management/DeployJarTestSuite.java | 36 - .../geode/management/DiskManagementDUnitTest.java | 4 +- .../management/DistributedSystemDUnitTest.java | 69 +- .../apache/geode/management/JMXMBeanDUnitTest.java | 35 +- .../management/LocatorManagementDUnitTest.java | 384 ++-- .../org/apache/geode/management/MBeanUtil.java | 2 +- .../apache/geode/management/MXBeanAwaitility.java | 80 + .../geode/management/ManagementTestBase.java | 206 +- .../geode/management/ManagementTestRule.java | 15 +- .../management/MemberMBeanAttributesDUnitTest.java | 314 ++- .../management/OffHeapManagementDUnitTest.java | 609 +++--- .../geode/management/QueryDataDUnitTest.java | 169 +- .../QueryDataFunctionIntegrationTest.java | 322 +++ .../management/RegionCreateDestroyDUnitTest.java | 6 +- .../management/RegionManagementDUnitTest.java | 181 +- .../geode/management/TypedJsonJUnitTest.java | 281 --- ...niversalMembershipListenerAdapterDUnitTest.java | 2173 ++++++++------------ .../bean/stats/MemberLevelStatsJUnitTest.java | 8 +- .../internal/CompositeBuilderViaFromTest.java | 1 - .../internal/CompositeBuilderViaProxyTest.java | 1 - ...ServerBridgeClientMembershipRegressionTest.java | 130 ++ .../beans/DistributedSystemBridgeJUnitTest.java | 10 +- .../management/internal/cli/CliUtilDUnitTest.java | 18 +- .../internal/cli/CommandManagerJUnitTest.java | 23 +- .../internal/cli/CommandRequestTest.java | 13 +- .../internal/cli/GfshParserAutoCompletionTest.java | 222 +- .../internal/cli/GfshParserConverterTest.java | 118 +- .../internal/cli/GfshParserParsingTest.java | 74 +- .../management/internal/cli/HeadlessGfsh.java | 33 +- .../management/internal/cli/NetstatDUnitTest.java | 12 +- .../internal/cli/OptionAliasesParsingTest.java | 344 ++++ .../cli/commands/AlterRegionCommandDUnitTest.java | 639 ++++++ .../commands/ChangeLogLevelCommandDUnitTest.java | 144 ++ .../internal/cli/commands/CliCommandTestBase.java | 137 +- .../cli/commands/ConcurrentDeployDUnitTest.java | 13 +- .../cli/commands/ConfigCommandsDUnitTest.java | 567 ----- .../internal/cli/commands/ConnectCommandTest.java | 300 +++ .../CreateAlterDestroyRegionCommandsDUnitTest.java | 1229 +---------- .../cli/commands/CreateRegionCommandDUnitTest.java | 304 +++ .../cli/commands/CreateRegionCommandTest.java | 61 + ...DeployCommandFunctionRegistrationDUnitTest.java | 2 +- .../commands/DeployCommandRedeployDUnitTest.java | 44 +- .../cli/commands/DeployCommandsDUnitTest.java | 270 --- .../cli/commands/DeployWithGroupsDUnitTest.java | 303 +++ .../commands/DescribeConfigCommandJUnitTest.java | 90 + .../commands/DescribeMembersCommandDUnitTest.java | 81 + .../commands/DestroyRegionCommandDUnitTest.java | 388 ++++ .../cli/commands/DiskStoreCommandsDUnitTest.java | 110 +- .../cli/commands/DiskStoreCommandsJUnitTest.java | 112 +- .../ExecuteFunctionCommandSecurityTest.java | 157 ++ .../cli/commands/ExportDataIntegrationTest.java | 177 ++ .../internal/cli/commands/ExportLogsDUnitTest.java | 46 +- .../cli/commands/ExportLogsIntegrationTest.java | 15 +- .../commands/ExportLogsOnServerManagerDUnit.java | 25 +- .../cli/commands/ExportLogsStatsDUnitTest.java | 35 +- .../ExportLogsWithMemberGroupDUnitTest.java | 37 +- .../cli/commands/FunctionCommandsDUnitTest.java | 734 ++----- .../internal/cli/commands/GcCommandDUnitTest.java | 118 ++ .../cli/commands/GemfireDataCommandsDUnitTest.java | 318 +-- ...ionWithCacheLoaderDuringCacheMissDUnitTest.java | 50 +- .../cli/commands/GfshCommandIntegrationTest.java | 49 + .../cli/commands/GfshCommandJUnitTest.java | 312 ++- .../cli/commands/ImportDataIntegrationTest.java | 218 ++ .../cli/commands/IndexCommandsDUnitTest.java | 957 ++------- .../cli/commands/IndexCommandsJUnitTest.java | 223 -- .../IndexCommandsShareConfigurationDUnitTest.java | 174 ++ .../ListAndDescribeDiskStoreCommandsDUnitTest.java | 40 +- .../commands/ListAndDescribeRegionDUnitTest.java | 460 ++--- .../cli/commands/ListIndexCommandDUnitTest.java | 699 +------ .../cli/commands/ListIndexCommandJUnitTest.java | 223 ++ .../cli/commands/ListMembersCommandDUnitTest.java | 123 ++ .../cli/commands/LogLevelInterceptorTest.java | 21 +- .../cli/commands/MemberCommandsDUnitTest.java | 311 --- .../commands/MiscellaneousCommandsDUnitTest.java | 518 ----- .../internal/cli/commands/QueryCommandTest.java | 6 +- .../cli/commands/QueueCommandsDUnitTest.java | 52 +- .../commands/RebalanceCommandDistributedTest.java | 156 ++ .../cli/commands/RemoveCommandDUnitTest.java | 210 ++ .../cli/commands/RemoveCommandJsonDUnitTest.java | 171 ++ .../cli/commands/ShellCommandsDUnitTest.java | 65 +- .../cli/commands/ShowDeadlockDUnitTest.java | 243 +-- .../cli/commands/ShowLogCommandDUnitTest.java | 163 ++ .../cli/commands/ShowMetricsCommandJUnitTest.java | 61 + .../cli/commands/ShowMetricsDUnitTest.java | 416 +--- .../commands/ShowMissingDiskStoresDUnitTest.java | 46 +- .../cli/commands/ShowStackTraceDUnitTest.java | 37 +- .../cli/commands/ShutdownCommandDUnitTest.java | 134 ++ .../cli/commands/StartMemberUtilsTest.java | 91 + .../cli/commands/UserInputPropertyTest.java | 102 + .../GfshStatusCommandsIntegrationTest.java | 84 + .../cli/domain/IndexDetailsIntegrationTest.java | 81 + .../DataCommandFunctionWithPDXJUnitTest.java | 2 +- .../DescribeDiskStoreFunctionJUnitTest.java | 149 +- .../ExportLogsFunctionIntegrationTest.java | 61 +- .../cli/functions/ExportLogsFunctionTest.java | 40 +- .../internal/cli/functions/Geode3544JUnitTest.java | 165 ++ .../cli/functions/GetRegionsFunctionJUnitTest.java | 20 +- .../cli/functions/GetRegionsFunctionTest.java | 88 + .../cli/functions/ListIndexFunctionJUnitTest.java | 18 +- .../ShowMissingDiskStoresFunctionJUnitTest.java | 49 +- .../cli/functions/SizeExportLogsFunctionTest.java | 46 +- .../internal/cli/help/HelperIntegrationTest.java | 73 +- .../cli/json/TypedJsonPdxIntegrationTest.java | 116 ++ .../internal/cli/json/TypedJsonTest.java | 140 +- .../internal/cli/remote/CommandExecutorTest.java | 97 + .../cli/remote/OnlineCommandProcessorTest.java | 93 + .../internal/cli/result/CommandResultTest.java | 75 + .../cli/result/DownloadFileResultTest.java | 48 + .../cli/shell/GfshExecutionStrategyJUnitTest.java | 107 - .../cli/shell/GfshExecutionStrategyTest.java | 108 + .../internal/cli/shell/GfshInitFileJUnitTest.java | 2 + .../cli/shell/GfshMultilineCommandTest.java | 13 +- .../cli/util/LogExporterIntegrationTest.java | 28 +- .../internal/cli/util/MergeLogsDUnitTest.java | 34 +- .../internal/configuration/ClusterConfig.java | 4 +- .../ClusterConfigDeployJarDUnitTest.java | 24 +- .../ClusterConfigDistributionDUnitTest.java | 36 +- .../ClusterConfigImportDUnitTest.java | 42 +- .../ClusterConfigStartMemberDUnitTest.java | 17 +- .../configuration/ClusterConfigTestBase.java | 23 +- .../ClusterConfigWithSecurityDUnitTest.java | 59 +- .../ImportClusterConfigDistributedTest.java | 28 +- .../ImportOldClusterConfigDUnitTest.java | 104 + .../configuration/utils/XmlUtilsJUnitTest.java | 306 ++- .../internal/deployment/FunctionScannerTest.java | 17 + .../security/AccessControlMBeanJUnitTest.java | 7 +- .../CacheServerMBeanAuthenticationJUnitTest.java | 20 +- .../CacheServerMBeanAuthorizationJUnitTest.java | 68 +- .../security/CacheServerMBeanShiroJUnitTest.java | 109 - ...acheServerMBeanWithShiroIniIntegrationTest.java | 110 + .../internal/security/CliCommandsSecurityTest.java | 40 +- .../security/DataCommandsSecurityTest.java | 21 +- .../security/DeployCommandsSecurityTest.java | 42 +- .../security/DiskStoreMXBeanSecurityJUnitTest.java | 125 +- .../DistributedSystemMXBeanSecurityTest.java | 77 + .../security/GatewayReceiverMBeanSecurityTest.java | 44 +- .../security/GatewaySenderMBeanSecurityTest.java | 82 +- .../security/GfshCommandsPostProcessorTest.java | 34 +- .../security/GfshCommandsSecurityTest.java | 157 +- ...egratedSecurityServiceCustomRealmJUnitTest.java | 44 - ...egratedSecurityServiceWithIniFileJUnitTest.java | 152 -- .../internal/security/JavaRmiServerNameTest.java | 2 +- .../LockServiceMBeanAuthorizationJUnitTest.java | 85 +- .../internal/security/MBeanSecurityJUnitTest.java | 33 +- .../ManagerMBeanAuthorizationJUnitTest.java | 36 +- .../security/MemberMBeanSecurityJUnitTest.java | 88 +- .../internal/security/MultiUserDUnitTest.java | 110 +- .../internal/security/ResourcePermissionTest.java | 60 +- ...urityServiceWithCustomRealmIntegrationTest.java | 44 + ...SecurityServiceWithShiroIniIntegrationTest.java | 148 ++ .../management/internal/security/TestCommand.java | 294 +-- .../internal/security/TestFunctions.java | 59 + .../web/controllers/ExportLogControllerTest.java | 56 - .../ShellCommandsControllerProcessCommandTest.java | 118 ++ .../WanCommandsControllerJUnitTest.java | 146 -- .../management/internal/web/domain/LinkTest.java | 45 - .../internal/web/http/ClientHttpRequestTest.java | 37 - .../web/http/support/HttpRequesterTest.java | 149 ++ .../apache/geode/pdx/PdxAttributesJUnitTest.java | 239 ++- .../executor/AbstractScanExecutorTest.java | 1 - .../CacheFactoryWithSecurityObjectTest.java | 125 +- .../apache/geode/security/ClientAuthDUnitTest.java | 4 +- .../security/ClientContainsKeyAuthDUnitTest.java | 2 +- .../ClientDestroyInvalidateAuthDUnitTest.java | 2 +- .../security/ClientDestroyRegionAuthDUnitTest.java | 2 +- .../ClientExecuteFunctionAuthDUnitTest.java | 84 +- .../ClientExecuteRegionFunctionAuthDUnitTest.java | 61 +- .../geode/security/ClientGetAllAuthDUnitTest.java | 2 +- .../security/ClientGetEntryAuthDUnitTest.java | 2 +- .../geode/security/ClientGetPutAuthDUnitTest.java | 2 +- .../security/ClientRegionClearAuthDUnitTest.java | 2 +- .../ClientRegisterInterestAuthDUnitTest.java | 2 +- .../security/ClientRemoveAllAuthDUnitTest.java | 2 +- .../ClientUnregisterInterestAuthDUnitTest.java | 2 +- .../ClusterConfigWithoutSecurityDUnitTest.java | 65 +- .../geode/security/ExampleSecurityManagerTest.java | 40 +- ...ratedSecurityCacheLifecycleIntegrationTest.java | 74 - .../NoShowValue1PostProcessorDUnitTest.java | 2 +- .../geode/security/OtherPDXPostProcessor.java | 18 + .../geode/security/OtherSimplySecurityManager.java | 18 + .../PDXGfshPostProcessorOnRemoteServerTest.java | 32 +- .../apache/geode/security/PDXPostProcessor.java | 28 +- .../geode/security/PDXPostProcessorDUnitTest.java | 138 +- .../geode/security/PeerAuthenticatorDUnitTest.java | 15 +- .../PeerSecurityWithEmbeddedLocatorDUnitTest.java | 2 +- .../geode/security/PostProcessorDUnitTest.java | 2 +- .../security/SecurityClusterConfigDUnitTest.java | 93 +- .../SecurityManagerCallbacksDistributedTest.java | 132 -- .../SecurityManagerLifecycleDistributedTest.java | 143 ++ .../SecurityManagerLifecycleIntegrationTest.java | 73 + .../apache/geode/security/SecurityTestUtil.java | 7 +- .../SecurityWithoutClusterConfigDUnitTest.java | 4 +- .../geode/security/SimpleSecurityManagerTest.java | 12 +- .../geode/security/SimpleTestSecurityManager.java | 13 +- .../apache/geode/security/SpySecurityManager.java | 19 +- .../security/StartServerAuthorizationTest.java | 4 +- .../apache/geode/security/TestSecurityManager.java | 31 +- .../security/query/IndexSecurityDUnitTest.java | 105 + .../query/PartitionedIndexSecurityDUnitTest.java | 33 + ...tionedQuerySecurityAllowedQueriesDUnitTest.java | 37 + ...rictedButMethodsDoNotExistQueriesDUnitTest.java | 36 + ...nedQuerySecurityRestrictedQueriesDUnitTest.java | 37 + ...tionedQuerySecurityAllowedQueriesDUnitTest.java | 33 + .../PdxQuerySecurityAllowedQueriesDUnitTest.java | 74 + ...PdxQuerySecurityRestrictedQueriesDUnitTest.java | 80 + .../QuerySecurityAllowedQueriesDUnitTest.java | 255 +++ ...curityAuthorizedUserBindParameterDUnitTest.java | 53 + .../geode/security/query/QuerySecurityBase.java | 225 ++ .../QuerySecurityRestrictedQueriesDUnitTest.java | 276 +++ ...rityRetrictedButMethodsDoNotExistDUnitTest.java | 127 ++ ...rityUnauthorizedUserBindParameterDUnitTest.java | 76 + .../geode/security/query/UserPermissions.java | 46 + .../security/query/data/PdxQueryTestObject.java | 73 + .../geode/security/query/data/QueryTestObject.java | 65 + .../geode/sequence/GemfireSequenceDisplay.java | 40 +- .../java/org/apache/geode/test/dunit/Assert.java | 14 +- .../apache/geode/test/dunit/AsyncInvocation.java | 2 + .../apache/geode/test/dunit/DUnitBlackboard.java | 8 +- .../java/org/apache/geode/test/dunit/DUnitEnv.java | 9 +- .../org/apache/geode/test/dunit/DebuggerUtils.java | 13 +- .../org/apache/geode/test/dunit/Disconnect.java | 53 + .../geode/test/dunit/DistributedTestUtils.java | 50 +- .../java/org/apache/geode/test/dunit/Host.java | 53 +- .../geode/test/dunit/SerializableCallable.java | 2 +- .../test/java/org/apache/geode/test/dunit/VM.java | 42 +- .../geode/test/dunit/cache/CacheTestCase.java | 26 + .../cache/examples/CacheTestCaseExampleTest.java | 35 + .../dunit/cache/internal/CacheTestFixture.java | 4 +- .../dunit/cache/internal/JUnit3CacheTestCase.java | 19 +- .../dunit/cache/internal/JUnit4CacheTestCase.java | 181 +- .../examples/AsyncInvokeCallableExampleTest.java | 92 + .../examples/AsyncInvokeRunnableExampleTest.java | 56 + .../dunit/examples/BeforeClassExampleTest.java | 39 + .../CatchingUnexpectedExceptionExampleTest.java | 98 + .../examples/DistributedTestCaseExampleTest.java | 36 + .../examples/DistributedTestRuleExampleTest.java | 37 + .../DoNotHandleUnexpectedExceptionExampleTest.java | 59 + .../dunit/examples/FixtureOrderingExampleTest.java | 63 + .../dunit/examples/InvokeRunnableExampleTest.java | 46 + .../examples/LocatorPortClusterExampleTest.java | 81 + .../examples/ReplaceTryFinallyExampleTest.java | 61 + .../dunit/internal/DistributedTestFixture.java | 16 +- .../dunit/internal/JUnit3DistributedTestCase.java | 77 +- .../dunit/internal/JUnit4DistributedTestCase.java | 179 +- .../apache/geode/test/dunit/rules/CacheRule.java | 202 ++ .../test/dunit/rules/ConnectionConfiguration.java | 33 - .../dunit/rules/DistributedDisconnectRule.java | 61 +- .../dunit/rules/DistributedExternalResource.java | 2 +- .../rules/DistributedRestoreSystemProperties.java | 4 +- .../test/dunit/rules/DistributedTestRule.java | 85 + .../DistributedUseJacksonForJsonPathRule.java | 4 +- .../test/dunit/rules/GfshShellConnectionRule.java | 247 --- .../apache/geode/test/dunit/rules/JarFileRule.java | 80 - .../org/apache/geode/test/dunit/rules/Locator.java | 23 - .../test/dunit/rules/LocatorServerStartupRule.java | 200 +- .../geode/test/dunit/rules/LocatorStarterRule.java | 96 - .../dunit/rules/MBeanServerConnectionRule.java | 195 -- .../org/apache/geode/test/dunit/rules/Member.java | 31 - .../geode/test/dunit/rules/MemberStarterRule.java | 209 -- .../apache/geode/test/dunit/rules/MemberVM.java | 55 +- .../geode/test/dunit/rules/RemoteInvoker.java | 32 +- .../org/apache/geode/test/dunit/rules/Server.java | 29 - .../geode/test/dunit/rules/ServerStarterRule.java | 183 -- .../geode/test/dunit/rules/SharedCountersRule.java | 183 ++ .../test/dunit/rules/SharedErrorCollector.java | 160 ++ .../dunit/rules/test/MemberStarterRuleTest.java | 72 - .../test/dunit/rules/tests/CacheRuleTest.java | 287 +++ .../DistributedDisconnectRuleAsClassRuleTest.java | 171 ++ .../rules/tests/DistributedDisconnectRuleTest.java | 187 ++ .../dunit/rules/tests/DistributedTestRuleTest.java | 37 + .../dunit/rules/tests/MemberStarterRuleTest.java | 107 + .../dunit/rules/tests/SharedCountersRuleTest.java | 182 ++ .../rules/tests/SharedErrorCollectorTest.java | 352 ++++ .../geode/test/dunit/standalone/BounceResult.java | 10 +- .../geode/test/dunit/standalone/ChildVM.java | 16 +- .../geode/test/dunit/standalone/DUnitLauncher.java | 12 +- .../test/dunit/standalone/ProcessManager.java | 60 +- .../test/dunit/standalone/VersionManager.java | 72 +- .../dunit/standalone/VersionManagerJUnitTest.java | 6 +- .../geode/test/dunit/tests/BasicDUnitTest.java | 6 +- .../tests/GetDefaultDiskStoreNameDUnitTest.java | 4 +- .../GetPidAndIdAfterBounceDistributedTest.java | 62 + .../dunit/tests/GetPidAndIdDistributedTest.java | 51 + .../dunit/tests/GetTestMethodNameDUnitTest.java | 4 +- .../dunit/tests/GetUniqueNameDistributedTest.java | 39 + .../test/dunit/tests/JUnit4BasicDUnitTest.java | 4 +- .../JUnit4GetDefaultDiskStoreNameDUnitTest.java | 1 + .../tests/JUnit4GetTestMethodNameDUnitTest.java | 1 + ...ridingGetPropertiesDisconnectsAllDUnitTest.java | 1 + .../geode/test/dunit/tests/JUnit4VMDUnitTest.java | 1 + ...ridingGetPropertiesDisconnectsAllDUnitTest.java | 5 +- .../apache/geode/test/dunit/tests/VMDUnitTest.java | 1 + .../java/org/apache/geode/test/fake/Fakes.java | 4 + .../test/junit/rules/ConnectionConfiguration.java | 33 + .../geode/test/junit/rules/GfshParserRule.java | 145 ++ .../test/junit/rules/GfshShellConnectionRule.java | 286 +++ .../org/apache/geode/test/junit/rules/Locator.java | 22 + .../geode/test/junit/rules/LocatorStarterRule.java | 93 + .../junit/rules/MBeanServerConnectionRule.java | 194 ++ .../org/apache/geode/test/junit/rules/Member.java | 31 + .../geode/test/junit/rules/MemberStarterRule.java | 249 +++ .../org/apache/geode/test/junit/rules/Server.java | 27 + .../geode/test/junit/rules/ServerStarterRule.java | 166 ++ ...e.geode.distributed.ServerLauncherCacheProvider | 2 +- .../ClientCacheFactoryJUnitTest_single_pool.xml | 11 +- .../apache/geode/codeAnalysis/excludedClasses.txt | 8 +- .../codeAnalysis/sanctionedDataSerializables.txt | 28 +- .../geode/codeAnalysis/sanctionedSerializables.txt | 31 +- .../SecurityServiceFactoryShiroIntegrationTest.ini | 30 + .../shiro/ConfigInitializerIntegrationTest.ini | 30 + .../management/internal/configuration/cluster8.xml | 25 + .../configuration/domain/CacheElementJUnitTest.xml | 16 + ...LocationMapMapOfStringListOfStringAttribute.xml | 10 - .../internal/deployment/AbstractFunction.java | 33 - .../internal/deployment/AnnotatedFunction.java | 23 + .../deployment/ExtendsAbstractFunction.java | 25 - .../management/internal/security/clientServer.json | 104 +- .../apache/geode/security/templates/security.json | 5 + .../cache/tier/sockets/command/CloseCQ.java | 52 +- .../cache/tier/sockets/command/ExecuteCQ.java | 35 +- .../cache/tier/sockets/command/ExecuteCQ61.java | 43 +- .../cache/tier/sockets/command/GetCQStats.java | 23 +- .../cache/tier/sockets/command/GetDurableCQs.java | 32 +- .../cache/tier/sockets/command/MonitorCQ.java | 21 +- .../cache/tier/sockets/command/StopCQ.java | 30 +- .../cache/query/cq/dunit/CqDataDUnitTest.java | 2 +- .../query/cq/dunit/CqDataUsingPoolDUnitTest.java | 2 +- .../cache/query/cq/dunit/CqQueryDUnitTest.java | 2 +- .../query/cq/dunit/CqQueryUsingPoolDUnitTest.java | 2 +- .../dunit/CqSecurityAuthorizedUserDUnitTest.java | 267 +++ ...SecurityPartitionedAuthorizedUserDUnitTest.java | 65 + ...curityPartitionedUnauthorizedUserDUnitTest.java | 45 + .../dunit/CqSecurityUnauthorizedUserDUnitTest.java | 215 ++ .../query/dunit/QueryIndexUpdateRIDUnitTest.java | 6 +- .../cache/snapshot/ClientSnapshotDUnitTest.java | 10 +- .../geode/internal/cache/PutAllCSDUnitTest.java | 91 +- .../internal/cache/ha/CQListGIIDUnitTest.java | 2 +- .../cache/tier/sockets/DurableClientTestCase.java | 19 +- .../cache/tier/sockets/command/CloseCQTest.java | 47 + .../tier/sockets/command/ExecuteCQ61Test.java | 46 + .../cache/tier/sockets/command/StopCQTest.java | 48 + .../management/CacheServerManagementDUnitTest.java | 58 +- .../cli/commands/ClientCommandsDUnitTest.java | 1173 ----------- .../cli/commands/ClientCommandsTestUtils.java | 139 ++ .../commands/DescribeClientCommandDUnitTest.java | 782 +++++++ .../commands/DurableClientCommandsDUnitTest.java | 280 +-- .../cli/commands/ListClientCommandDUnitTest.java | 401 ++++ .../geode/security/CQClientAuthDUnitTest.java | 114 - .../security/CQPDXPostProcessorDUnitTest.java | 5 +- .../geode/security/CQPostProcessorDunitTest.java | 64 +- .../security/ClientAuthzObjectModDUnitTest.java | 22 +- .../geode/security/ClientCQAuthDUnitTest.java | 108 + .../geode/security/ClientQueryAuthDUnitTest.java | 87 +- .../geode/test/dunit/rules/CQUnitTestRule.java | 85 + geode-docs/CONTRIBUTE.md | 44 + geode-docs/about_geode.html.md.erb | 8 +- geode-docs/basic_config/book_intro.html.md.erb | 18 +- .../config_concepts/chapter_overview.html.md.erb | 18 +- ...ributed_system_member_configuration.html.md.erb | 8 +- .../config_concepts/local_vs_remote.html.md.erb | 4 +- .../chapter_overview.html.md.erb | 6 +- .../managing_data_entries.html.md.erb | 6 +- .../using_custom_classes.html.md.erb | 4 +- .../data_regions/chapter_overview.html.md.erb | 22 +- .../create_a_region_with_gfsh.html.md.erb | 2 +- .../data_regions/managing_data_regions.html.md.erb | 8 +- .../data_regions/region_shortcuts.html.md.erb | 12 +- .../store_retrieve_region_shortcuts.html.md.erb | 6 +- .../setting_distributed_properties.html.md.erb | 8 +- .../the_cache/chapter_overview.html.md.erb | 16 +- .../the_cache/intro_cache_management.html.md.erb | 12 +- .../the_cache/managing_a_client_cache.html.md.erb | 6 +- .../managing_a_multiuser_cache.html.md.erb | 2 +- .../managing_a_peer_server_cache.html.md.erb | 4 +- .../the_cache/setting_cache_properties.html.md.erb | 4 +- .../configuring/chapter_overview.html.md.erb | 56 +- .../deploying_application_jars.html.md.erb | 22 +- .../cluster_config/export-import.html.md.erb | 29 +- .../gfsh_config_troubleshooting.html.md.erb | 14 +- .../cluster_config/gfsh_persist.html.md.erb | 12 +- .../cluster_config/gfsh_remote.html.md.erb | 4 +- .../persisting_configurations.html.md.erb | 90 +- .../cluster_config/using_member_groups.html.md.erb | 6 +- .../running/change_file_spec.html.md.erb | 2 +- .../running/default_file_specs.html.md.erb | 4 +- .../running/deploy_config_files_intro.html.md.erb | 6 +- .../running/deploying_config_files.html.md.erb | 12 +- .../running/deploying_config_jar_files.html.md.erb | 4 +- .../running/firewall_ports_config.html.md.erb | 4 +- .../running/firewalls_connections.html.md.erb | 6 +- .../running/firewalls_multisite.html.md.erb | 87 - .../running/firewalls_ports.html.md.erb | 80 +- .../running/managing_output_files.html.md.erb | 4 +- .../running/running_the_cacheserver.html.md.erb | 26 +- .../running/running_the_locator.html.md.erb | 29 +- .../running/starting_up_shutting_down.html.md.erb | 16 +- geode-docs/developing/book_intro.html.md.erb | 46 +- .../chapter_overview.html.md.erb | 6 +- .../PDX_Serialization_Features.html.md.erb | 10 +- .../auto_serialization.html.md.erb | 2 +- ...lization_with_class_pattern_strings.html.md.erb | 2 +- .../chapter_overview.html.md.erb | 16 +- .../data_serialization_options.html.md.erb | 24 +- .../extending_the_autoserializer.html.md.erb | 2 +- .../gemfire_data_serialization.html.md.erb | 8 +- .../gemfire_pdx_serialization.html.md.erb | 32 +- .../jsonformatter_pdxinstances.html.md.erb | 18 +- .../persist_pdx_metadata_to_disk.html.md.erb | 10 +- .../program_application_for_pdx.html.md.erb | 2 +- .../use_pdx_high_level_steps.html.md.erb | 4 +- .../use_pdx_serializable.html.md.erb | 8 +- .../use_pdx_serializer.html.md.erb | 4 +- .../delta_propagation_example.html.md.erb | 6 +- .../delta_propagation_properties.html.md.erb | 4 +- .../how_delta_propagation_works.html.md.erb | 12 +- .../implementing_delta_propagation.html.md.erb | 4 +- .../chapter_overview.html.md.erb | 14 +- .../choosing_level_of_dist.html.md.erb | 2 +- .../how_region_versioning_works.html.md.erb | 42 +- .../how_region_versioning_works_wan.html.md.erb | 14 +- .../locking_in_global_regions.html.md.erb | 2 +- .../managing_distributed_regions.html.md.erb | 2 +- .../region_entry_versions.html.md.erb | 22 +- .../developing/events/chapter_overview.html.md.erb | 16 +- ...igure_client_server_event_messaging.html.md.erb | 6 +- ...configure_multisite_event_messaging.html.md.erb | 10 +- ...figuring_gateway_concurrency_levels.html.md.erb | 12 +- ...ing_highly_available_gateway_queues.html.md.erb | 4 +- ...onfiguring_highly_available_servers.html.md.erb | 2 +- .../events/event_handler_overview.html.md.erb | 4 +- .../events/filtering_multisite_events.html.md.erb | 12 +- .../events/how_cache_events_work.html.md.erb | 4 +- ...ow_client_server_distribution_works.html.md.erb | 2 +- .../developing/events/how_events_work.html.md.erb | 20 +- .../how_multisite_distribution_works.html.md.erb | 2 +- .../implementing_cache_event_handlers.html.md.erb | 2 +- ...ing_durable_client_server_messaging.html.md.erb | 4 +- ...ementing_write_behind_event_handler.html.md.erb | 20 +- .../list_of_event_handlers_and_events.html.md.erb | 6 +- .../tune_client_server_event_messaging.html.md.erb | 6 +- ...ing_callbacks_that_modify_the_cache.html.md.erb | 10 +- .../eviction/chapter_overview.html.md.erb | 6 +- .../eviction/configuring_data_eviction.html.md.erb | 6 +- .../eviction/how_eviction_works.html.md.erb | 6 +- .../expiration/chapter_overview.html.md.erb | 4 +- .../expiration/how_expiration_works.html.md.erb | 4 +- .../function_exec/chapter_overview.html.md.erb | 2 +- .../function_exec/function_execution.html.md.erb | 51 +- .../how_function_execution_works.html.md.erb | 19 +- .../chapter_overview.html.md.erb | 2 +- .../how_data_loaders_work.html.md.erb | 2 +- .../sync_outside_data.html.md.erb | 8 +- .../automated_rebalance.html.md.erb | 2 + .../chapter_overview.html.md.erb | 27 +- .../colocating_partitioned_region_data.html.md.erb | 4 +- .../configuring_bucket_for_pr.html.md.erb | 2 +- .../configuring_ha_for_pr.html.md.erb | 20 +- ...om_partitioning_and_data_colocation.html.md.erb | 10 +- .../how_partitioning_works.html.md.erb | 8 +- .../how_pr_ha_works.html.md.erb | 14 +- .../join_query_partitioned_regions.html.md.erb | 2 +- ...om_partitioning_and_data_colocation.html.md.erb | 12 +- .../overview_how_pr_ha_works.html.md.erb | 6 +- .../overview_how_pr_single_hop_works.html.md.erb | 4 +- .../rebalancing_pr_data.html.md.erb | 13 +- .../set_enforce_unique_host.html.md.erb | 4 +- .../set_join_redundancy_recovery.html.md.erb | 35 +- .../set_redundancy_zones.html.md.erb | 2 +- .../using_custom_partition_resolvers.html.md.erb | 10 +- .../query_additional/advanced_querying.html.md.erb | 18 +- .../query_additional/literals.html.md.erb | 4 +- .../query_additional/operators.html.md.erb | 4 +- .../query_additional/query_debugging.html.md.erb | 2 +- .../query_language_features.html.md.erb | 16 +- .../using_query_bind_parameters.html.md.erb | 2 +- .../create_multiple_indexes.html.md.erb | 2 +- .../query_index/creating_an_index.html.md.erb | 2 +- .../query_index/creating_hash_indexes.html.md.erb | 15 +- .../query_index/indexing_guidelines.html.md.erb | 2 +- .../query_index/maintaining_indexes.html.md.erb | 2 +- .../developing/query_index/query_index.html.md.erb | 34 +- .../query_index/query_index_hints.html.md.erb | 2 +- .../query_select/the_select_statement.html.md.erb | 4 +- .../query_select/the_where_clause.html.md.erb | 28 +- .../querying_basics/chapter_overview.html.md.erb | 4 +- .../monitor_queries_for_low_memory.html.md.erb | 2 +- .../querying_basics/query_basics.html.md.erb | 22 +- .../querying_partitioned_regions.html.md.erb | 16 +- .../querying_basics/reserved_words.html.md.erb | 2 +- ...strictions_and_unsupported_features.html.md.erb | 2 +- .../querying_basics/running_a_query.html.md.erb | 6 +- .../supported_character_sets.html.md.erb | 2 +- .../what_is_a_query_string.html.md.erb | 10 +- .../region_options/chapter_overview.html.md.erb | 12 +- .../dynamic_region_creation.html.md.erb | 2 +- .../region_options/region_types.html.md.erb | 6 +- .../storage_distribution_options.html.md.erb | 4 +- .../chapter_overview.html.md.erb | 10 +- .../how_persist_overflow_work.html.md.erb | 6 +- .../transactions/JTA_transactions.html.md.erb | 119 +- .../transactions/about_transactions.html.md.erb | 18 +- .../cache_plugins_with_jta.html.md.erb | 8 +- .../cache_transaction_performance.html.md.erb | 2 +- .../transactions/cache_transactions.html.md.erb | 26 +- .../cache_transactions_by_region_type.html.md.erb | 16 +- .../transactions/chapter_overview.html.md.erb | 24 +- .../client_server_transactions.html.md.erb | 16 +- ...nfiguring_db_connections_using_JNDI.html.md.erb | 16 +- .../how_cache_transactions_work.html.md.erb | 20 +- .../transactions/jca_adapter_example.html.md.erb | 2 +- .../monitor_troubleshoot_transactions.html.md.erb | 8 +- .../run_a_cache_transaction.html.md.erb | 16 +- ..._cache_transaction_with_external_db.html.md.erb | 16 +- .../transaction_coding_examples.html.md.erb | 14 +- .../transaction_event_management.html.md.erb | 4 +- .../transaction_jta_gemfire_example.html.md.erb | 6 +- .../transactions/transaction_semantics.html.md.erb | 14 +- ...nsactional_and_nontransactional_ops.html.md.erb | 2 +- .../working_with_transactions.html.md.erb | 28 +- .../15_minute_quickstart_gfsh.html.md.erb | 51 +- geode-docs/getting_started/book_intro.html.md.erb | 18 +- .../getting_started/geode_overview.html.md.erb | 16 +- .../installation/install_standalone.html.md.erb | 10 +- .../getting_started/product_intro.html.md.erb | 2 +- .../querying_quick_reference.html.md.erb | 28 +- .../getting_started/setup_classpath.html.md.erb | 26 +- .../system_requirements/host_machine.html.md.erb | 4 +- .../getting_started/uninstall_geode.html.md.erb | 4 +- .../autoreconnect/member-reconnect.html.md.erb | 83 - geode-docs/managing/book_intro.html.md.erb | 40 +- .../cache_snapshots/chapter_overview.html.md.erb | 14 +- .../exporting_a_snapshot.html.md.erb | 41 +- .../filtering_snapshot_entries.html.md.erb | 2 +- .../importing_a_snapshot.html.md.erb | 13 +- .../disk_storage/chapter_overview.html.md.erb | 22 +- .../compacting_disk_stores.html.md.erb | 12 +- .../disk_free_space_monitoring.html.md.erb | 2 +- .../disk_store_configuration_params.html.md.erb | 2 +- .../disk_storage/how_disk_stores_work.html.md.erb | 10 +- .../keeping_offline_disk_store_in_sync.html.md.erb | 2 +- .../managing_disk_buffer_flushes.html.md.erb | 10 +- .../disk_storage/managing_disk_stores.html.md.erb | 16 +- .../disk_storage/operation_logs.html.md.erb | 16 +- ...timize_availability_and_performance.html.md.erb | 2 +- .../overview_using_disk_stores.html.md.erb | 8 +- .../starting_system_with_disk_stores.html.md.erb | 2 +- .../disk_storage/using_disk_stores.html.md.erb | 8 +- .../using_the_default_disk_store.html.md.erb | 4 +- .../managing/heap_use/heap_management.html.md.erb | 28 +- .../managing/heap_use/lock_memory.html.md.erb | 6 +- .../heap_use/off_heap_management.html.md.erb | 12 +- .../logging/configuring_log4j2.html.md.erb | 26 +- .../managing/logging/how_logging_works.html.md.erb | 20 +- geode-docs/managing/logging/logging.html.md.erb | 14 +- .../logging/logging_categories.html.md.erb | 12 +- .../logging/setting_up_logging.html.md.erb | 2 +- .../configuring_rmi_connector.html.md.erb | 10 +- .../management/gfsh_and_management_api.html.md.erb | 2 +- .../management/jmx_manager_node.html.md.erb | 4 +- .../management/jmx_manager_operations.html.md.erb | 70 +- .../list_of_mbean_notifications.html.md.erb | 2 +- .../managing/management/list_of_mbeans.html.md.erb | 8 +- .../management/list_of_mbeans_full.html.md.erb | 10 +- .../management_and_monitoring.html.md.erb | 30 +- .../management_and_monitoring_features.html.md.erb | 12 +- .../management_system_overview.html.md.erb | 34 +- .../management/mbean_architecture.html.md.erb | 24 +- .../management/mbean_notifications.html.md.erb | 8 +- .../management/mbeans_jconsole.html.md.erb | 10 +- .../managing/management/mm_overview.html.md.erb | 48 +- .../notification_federation_and_alerts.html.md.erb | 2 +- geode-docs/managing/member-reconnect.html.md.erb | 83 + .../monitor_tune/cache_consistency.html.md.erb | 8 +- .../monitor_tune/chapter_overview.html.md.erb | 28 +- .../multicast_communication.html.md.erb | 14 +- ...munication_configuring_speed_limits.html.md.erb | 2 +- ...ommunication_runtime_considerations.html.md.erb | 6 +- ...tion_testing_multicast_speed_limits.html.md.erb | 2 +- .../monitor_tune/performance_controls.html.md.erb | 14 +- ...ormance_controls_data_serialization.html.md.erb | 4 +- .../performance_on_vsphere.html.md.erb | 38 +- .../monitor_tune/slow_messages.html.md.erb | 2 +- .../monitor_tune/slow_receivers.html.md.erb | 6 +- .../slow_receivers_managing.html.md.erb | 6 +- .../slow_receivers_preventing_problems.html.md.erb | 8 +- .../monitor_tune/socket_communication.html.md.erb | 18 +- ...t_communication_have_enough_sockets.html.md.erb | 4 +- ...ication_setting_socket_buffer_sizes.html.md.erb | 2 +- .../monitor_tune/socket_tcp_keepalive.html.md.erb | 4 +- .../monitor_tune/sockets_and_gateways.html.md.erb | 2 +- .../system_member_performance.html.md.erb | 8 +- ...member_performance_jvm_mem_settings.html.md.erb | 2 +- .../monitor_tune/udp_communication.html.md.erb | 12 +- .../chapter_overview.html.md.erb | 18 +- .../failure_detection.html.md.erb | 2 +- .../handling_network_partitioning.html.md.erb | 6 +- ...twork_partitioning_management_works.html.md.erb | 4 +- ...dinators_lead_members_and_weighting.html.md.erb | 2 +- .../preventing_network_partitions.html.md.erb | 2 +- geode-docs/managing/region_compression.html.md.erb | 226 ++ .../region_compression.html.md.erb | 226 -- .../security/authentication_examples.html.md.erb | 4 +- .../security/authentication_overview.html.md.erb | 10 +- .../security/authorization_example.html.md.erb | 2 +- .../security/authorization_overview.html.md.erb | 4 +- .../managing/security/chapter_overview.html.md.erb | 14 +- .../security/encrypting_passwords.html.md.erb | 49 - ... => encrypting_with_diffie_hellman.html.md.erb} | 0 .../implementing_authentication.html.md.erb | 7 +- .../implementing_authorization.html.md.erb | 169 +- .../managing/security/implementing_ssl.html.md.erb | 11 +- .../managing/security/properties_file.html.md.erb | 2 +- .../managing/security/security-audit.html.md.erb | 8 +- .../security/security_audit_overview.html.md.erb | 4 +- .../managing/security/ssl_example.html.md.erb | 2 +- .../managing/security/ssl_overview.html.md.erb | 10 +- .../application_defined_statistics.html.md.erb | 4 +- .../statistics/chapter_overview.html.md.erb | 16 +- .../statistics/how_statistics_work.html.md.erb | 2 +- .../statistics/setting_up_statistics.html.md.erb | 2 +- ...ansient_region_and_entry_statistics.html.md.erb | 6 +- .../troubleshooting/chapter_overview.html.md.erb | 24 +- .../diagnosing_system_probs.html.md.erb | 24 +- ...revent_and_recover_disk_full_errors.html.md.erb | 4 +- ...overing_conflicting_data_exceptions.html.md.erb | 14 +- .../recovering_from_app_crashes.html.md.erb | 4 +- .../recovering_from_cs_crashes.html.md.erb | 2 +- .../recovering_from_machine_crashes.html.md.erb | 6 +- .../recovering_from_network_outages.html.md.erb | 2 +- .../recovering_from_p2p_crashes.html.md.erb | 4 +- geode-docs/reference/book_intro.html.md.erb | 20 +- .../statistics/statistics_list.html.md.erb | 1310 ------------ geode-docs/reference/statistics_list.html.md.erb | 1311 ++++++++++++ .../topics/cache-elements-list.html.md.erb | 4 +- geode-docs/reference/topics/cache_xml.html.md.erb | 50 +- .../topics/chapter_overview_cache_xml.html.md.erb | 8 +- .../chapter_overview_regionshortcuts.html.md.erb | 54 +- .../topics/client-cache-elements-list.html.md.erb | 2 +- .../reference/topics/client-cache.html.md.erb | 48 +- .../topics/gemfire_properties.html.md.erb | 55 +- .../reference/topics/gfe_cache_xml.html.md.erb | 82 +- geode-docs/reference/topics/glossary.html.md.erb | 84 +- .../handling_exceptions_and_failures.html.md.erb | 10 +- .../memory_requirements_for_cache_data.html.md.erb | 30 +- .../non-ascii_strings_in_config_files.html.md.erb | 6 +- .../topics/region_shortcuts_reference.html.md.erb | 2 +- geode-docs/rest_apps/book_intro.html.md.erb | 40 +- geode-docs/rest_apps/chapter_overview.html.md.erb | 18 +- geode-docs/rest_apps/delete_all_data.html.md.erb | 2 +- .../rest_apps/delete_data_for_key.html.md.erb | 2 +- .../delete_data_for_multiple_keys.html.md.erb | 2 +- geode-docs/rest_apps/develop_rest_apps.html.md.erb | 40 +- .../rest_apps/get_execute_adhoc_query.html.md.erb | 4 +- geode-docs/rest_apps/get_functions.html.md.erb | 4 +- geode-docs/rest_apps/get_queries.html.md.erb | 2 +- geode-docs/rest_apps/get_region_data.html.md.erb | 2 +- .../rest_apps/get_region_key_data.html.md.erb | 2 +- geode-docs/rest_apps/get_region_keys.html.md.erb | 2 +- geode-docs/rest_apps/get_regions.html.md.erb | 2 +- geode-docs/rest_apps/get_servers.html.md.erb | 2 +- geode-docs/rest_apps/head_region_size.html.md.erb | 4 +- geode-docs/rest_apps/ping_service.html.md.erb | 2 +- geode-docs/rest_apps/post_create_query.html.md.erb | 2 +- .../rest_apps/post_execute_functions.html.md.erb | 2 +- .../rest_apps/post_if_absent_data.html.md.erb | 2 +- .../put_multiple_values_for_keys.html.md.erb | 3 +- geode-docs/rest_apps/put_replace_data.html.md.erb | 2 +- .../rest_apps/put_update_cas_data.html.md.erb | 2 +- geode-docs/rest_apps/put_update_data.html.md.erb | 2 +- geode-docs/rest_apps/put_update_query.html.md.erb | 2 +- geode-docs/rest_apps/rest_admin.html.md.erb | 4 +- .../rest_apps/rest_api_reference.html.md.erb | 14 +- geode-docs/rest_apps/rest_examples.html.md.erb | 6 +- geode-docs/rest_apps/rest_functions.html.md.erb | 10 +- geode-docs/rest_apps/rest_prereqs.html.md.erb | 14 +- geode-docs/rest_apps/rest_queries.html.md.erb | 14 +- geode-docs/rest_apps/rest_regions.html.md.erb | 32 +- geode-docs/rest_apps/setup_config.html.md.erb | 272 ++- geode-docs/rest_apps/troubleshooting.html.md.erb | 8 +- geode-docs/rest_apps/using_swagger.html.md.erb | 17 +- geode-docs/tools_modules/book_intro.html.md.erb | 18 +- .../gemcached/about_gemcached.html.md.erb | 6 +- .../tools_modules/gemcached/advantages.html.md.erb | 14 +- .../gemcached/chapter_overview.html.md.erb | 4 +- .../gemcached/deploying_gemcached.html.md.erb | 4 +- .../tools_modules/gfsh/about_gfsh.html.md.erb | 12 +- .../gfsh/cache_xml_2_gfsh.html.md.erb | 2 +- .../gfsh/chapter_overview.html.md.erb | 8 +- .../gfsh/command-pages/alter.html.md.erb | 23 +- .../gfsh/command-pages/change.html.md.erb | 4 +- .../gfsh/command-pages/close.html.md.erb | 13 +- .../gfsh/command-pages/compact.html.md.erb | 4 +- .../gfsh/command-pages/configure.html.md.erb | 2 +- .../gfsh/command-pages/connect.html.md.erb | 15 +- .../gfsh/command-pages/create.html.md.erb | 92 +- .../gfsh/command-pages/deploy.html.md.erb | 16 +- .../gfsh/command-pages/destroy.html.md.erb | 64 +- .../gfsh/command-pages/encrypt.html.md.erb | 57 - .../gfsh/command-pages/execute.html.md.erb | 9 +- .../gfsh/command-pages/export.html.md.erb | 90 +- .../gfsh/command-pages/gc.html.md.erb | 6 +- .../gfsh/command-pages/import.html.md.erb | 91 +- .../gfsh/command-pages/list.html.md.erb | 59 +- .../gfsh/command-pages/netstat.html.md.erb | 8 +- .../gfsh/command-pages/pause.html.md.erb | 8 +- .../gfsh/command-pages/query.html.md.erb | 2 +- .../gfsh/command-pages/resume.html.md.erb | 10 +- .../gfsh/command-pages/search.html.md.erb | 12 +- .../gfsh/command-pages/show.html.md.erb | 10 +- .../gfsh/command-pages/start.html.md.erb | 146 +- .../gfsh/command-pages/status.html.md.erb | 80 +- .../gfsh/command-pages/stop.html.md.erb | 93 +- .../gfsh/command-pages/undeploy.html.md.erb | 16 +- .../gfsh/configuring_gfsh.html.md.erb | 19 +- .../gfsh/getting_started_gfsh.html.md.erb | 2 +- .../gfsh/gfsh_command_index.html.md.erb | 12 +- .../gfsh/gfsh_quick_reference.html.md.erb | 4 +- .../gfsh/quick_ref_commands_by_area.html.md.erb | 65 +- .../tools_modules/gfsh/starting_gfsh.html.md.erb | 12 +- .../tools_modules/gfsh/tour_of_gfsh.html.md.erb | 90 +- .../gfsh/useful_gfsh_shell_variables.html.md.erb | 2 +- .../http_session_mgmt/chapter_overview.html.md.erb | 10 +- .../common_gemfire_topologies.html.md.erb | 2 +- .../http_why_use_gemfire.html.md.erb | 16 +- .../interactive_mode_ref.html.md.erb | 38 +- .../http_session_mgmt/quick_start.html.md.erb | 8 +- .../session_mgmt_tcserver.html.md.erb | 4 +- .../session_mgmt_tomcat.html.md.erb | 6 +- .../session_mgmt_weblogic.html.md.erb | 6 +- .../session_state_log_files.html.md.erb | 20 +- .../tc_additional_info.html.md.erb | 14 +- .../tc_changing_gf_default_cfg.html.md.erb | 16 +- .../tc_installing_the_module.html.md.erb | 2 +- .../tc_setting_up_the_module.html.md.erb | 8 +- .../tomcat_changing_gf_default_cfg.html.md.erb | 38 +- .../tomcat_installing_the_module.html.md.erb | 2 +- .../tomcat_setting_up_the_module.html.md.erb | 18 +- .../weblogic_changing_gf_default_cfg.html.md.erb | 48 +- ...blogic_common_configuration_changes.html.md.erb | 4 +- .../weblogic_setting_up_the_module.html.md.erb | 23 +- .../tools_modules/lucene_integration.html.md.erb | 23 +- .../tools_modules/pulse/pulse-auth.html.md.erb | 4 +- .../tools_modules/pulse/pulse-embedded.html.md.erb | 12 +- .../tools_modules/pulse/pulse-hosted.html.md.erb | 14 +- .../tools_modules/pulse/pulse-overview.html.md.erb | 16 +- .../tools_modules/pulse/pulse-views.html.md.erb | 40 +- geode-docs/tools_modules/redis_adapter.html.md.erb | 36 +- .../topologies_and_comm/book_intro.html.md.erb | 12 +- .../cs_configuration/chapter_overview.html.md.erb | 18 +- ...lient_server_example_configurations.html.md.erb | 2 +- .../client_server_whats_next.html.md.erb | 2 +- .../chapter_overview.html.md.erb | 10 +- .../multisite_topologies.html.md.erb | 4 +- .../setting_up_a_multisite_system.html.md.erb | 76 +- .../p2p_configuration/chapter_overview.html.md.erb | 8 +- .../setting_up_peer_communication.html.md.erb | 4 +- .../topology_concepts/IPv4_and_IPv6.html.md.erb | 8 +- .../topology_concepts/chapter_overview.html.md.erb | 26 +- .../how_communication_works.html.md.erb | 16 +- .../how_member_discovery_works.html.md.erb | 10 +- .../how_multisite_systems_work.html.md.erb | 20 +- .../how_server_discovery_works.html.md.erb | 4 +- .../how_the_pool_manages_connections.html.md.erb | 2 +- .../member_communication.html.md.erb | 2 +- .../multisite_overview.html.md.erb | 3 +- .../topology_concepts/topology_types.html.md.erb | 10 +- .../using_bind_addresses.html.md.erb | 12 +- geode-junit/build.gradle | 5 +- .../apache/geode/test/compiler/ClassBuilder.java | 286 +++ .../org/apache/geode/test/compiler/JarBuilder.java | 67 +- .../apache/geode/test/compiler/JavaCompiler.java | 11 +- .../test/concurrent/FileBasedCountDownLatch.java | 87 + .../org/apache/geode/test/junit/ResultCaptor.java | 34 + .../test/junit/categories/AcceptanceTest.java | 26 + .../geode/test/junit/categories/RestAPITest.java | 2 +- .../junit/rules/DescribedExternalResource.java | 2 +- .../apache/geode/test/junit/rules/DiskDirRule.java | 60 - .../apache/geode/test/junit/rules/JarFileRule.java | 80 + .../geode/test/junit/rules/RequiresGeodeHome.java | 51 + .../geode/test/junit/rules/RestoreLocaleRule.java | 106 + .../geode/test/junit/rules/gfsh/GfshExecution.java | 47 + .../geode/test/junit/rules/gfsh/GfshRule.java | 170 ++ .../geode/test/junit/rules/gfsh/GfshScript.java | 161 ++ .../test/junit/rules/gfsh/internal/OutputLine.java | 45 + .../junit/rules/gfsh/internal/ProcessLogger.java | 105 + .../junit/rules/gfsh/internal/StreamGobbler.java | 44 + .../serializable/SerializableExternalResource.java | 4 +- .../geode/test/junit/runner/SuiteBlockRunner.java | 46 - .../geode/test/junit/runner/SuiteRunner.java | 52 - .../runners/CategoryWithParameterizedRunner.java | 9 +- .../CategoryWithParameterizedRunnerFactory.java | 7 +- .../geode/test/junit/runners/SuiteBlockRunner.java | 44 + .../geode/test/junit/runners/SuiteRunner.java | 54 + .../geode/test/junit/runners/TestRunner.java | 52 + .../apache/geode/test/compiler/JarBuilderTest.java | 1 + .../geode/test/compiler/JavaCompilerTest.java | 1 + .../test/compiler/UncompiledSourceCodeTest.java | 2 +- .../concurrent/FileBasedCountDownLatchTest.java | 37 + .../geode/test/junit/categories/CategoryTest.java | 2 +- .../geode/test/junit/rules/DiskDirRuleTest.java | 47 - .../test/junit/rules/ExpectedTimeoutRuleTest.java | 1 + .../test/junit/rules/IgnoreUntilRuleTest.java | 1 + .../geode/test/junit/rules/RepeatRuleTest.java | 1 + .../test/junit/rules/RestoreLocaleRuleTest.java | 182 ++ .../junit/rules/RetryRuleGlobalWithErrorTest.java | 1 + .../rules/RetryRuleGlobalWithExceptionTest.java | 1 + .../junit/rules/RetryRuleLocalWithErrorTest.java | 1 + .../rules/RetryRuleLocalWithExceptionTest.java | 1 + .../geode/test/junit/rules/RuleListTest.java | 1 + .../test/junit/rules/TemporaryFileRuleTest.java | 1 + .../apache/geode/test/junit/rules/TestRunner.java | 32 - .../junit/rules/examples/RuleAndClassRuleTest.java | 2 +- geode-lucene/build.gradle | 4 +- .../org/apache/geode/cache/lucene/LuceneQuery.java | 1 - .../geode/cache/lucene/LuceneQueryFactory.java | 2 +- .../cache/lucene/PageableLuceneQueryResults.java | 3 +- .../AbstractPartitionedRepositoryManager.java | 2 +- .../lucene/internal/DestroyLuceneIndexMessage.java | 2 +- .../lucene/internal/LuceneBucketListener.java | 1 - .../cache/lucene/internal/LuceneEventListener.java | 2 - .../internal/LuceneEventSubstitutionFilter.java | 1 - .../internal/LuceneIndexCreationProfile.java | 1 - .../lucene/internal/LuceneIndexFactoryImpl.java | 1 - .../internal/LuceneIndexForPartitionedRegion.java | 1 - .../cache/lucene/internal/LuceneIndexImpl.java | 8 +- .../cache/lucene/internal/LuceneServiceImpl.java | 29 +- .../internal/PageableLuceneQueryResultsImpl.java | 2 +- .../lucene/internal/RawIndexRepositoryFactory.java | 1 - .../cache/lucene/internal/StringQueryProvider.java | 3 - .../lucene/internal/cli/LuceneCliStrings.java | 3 +- .../lucene/internal/cli/LuceneIndexCommands.java | 87 +- .../lucene/internal/cli/LuceneIndexDetails.java | 3 - .../cache/lucene/internal/cli/LuceneIndexInfo.java | 10 - .../cache/lucene/internal/cli/LuceneQueryInfo.java | 2 - .../lucene/internal/cli/LuceneSearchResults.java | 8 +- .../cli/functions/LuceneCreateIndexFunction.java | 12 +- .../cli/functions/LuceneDescribeIndexFunction.java | 6 +- .../cli/functions/LuceneDestroyIndexFunction.java | 8 +- .../cli/functions/LuceneListIndexFunction.java | 6 +- .../cli/functions/LuceneSearchIndexFunction.java | 8 +- .../internal/directory/DumpDirectoryFiles.java | 15 - .../lucene/internal/directory/RegionDirectory.java | 1 - .../internal/distributed/LuceneQueryFunction.java | 14 +- .../distributed/WaitUntilFlushedFunction.java | 41 +- .../WaitUntilFlushedFunctionContext.java | 4 - .../cache/lucene/internal/filesystem/File.java | 2 +- .../lucene/internal/filesystem/FileSystem.java | 1 + .../internal/filesystem/FileSystemStats.java | 1 - .../management/LuceneIndexStatsMonitor.java | 1 - .../partition/BucketTargetingFixedResolver.java | 6 - .../internal/partition/BucketTargetingMap.java | 3 - .../serializer/HeterogeneousLuceneSerializer.java | 1 - .../repository/serializer/SerializerUtil.java | 10 +- .../repository/serializer/package-info.java | 2 +- .../internal/results/LuceneGetPageFunction.java | 14 +- .../cache/lucene/internal/results/PageEntry.java | 1 - .../lucene/internal/security/LucenePermission.java | 21 + .../lucene/internal/xml/LuceneIndexCreation.java | 2 - .../internal/xml/LuceneIndexXmlGenerator.java | 2 +- .../internal/xml/LuceneServiceXmlGenerator.java | 2 +- .../cache/lucene/internal/xml/LuceneXmlParser.java | 4 +- .../lucene/LuceneClientSecurityDUnitTest.java | 78 +- .../lucene/LuceneCommandsSecurityDUnitTest.java | 128 +- .../lucene/LuceneIndexCreationIntegrationTest.java | 1 - .../LuceneIndexCreationOnFixedPRDUnitTest.java | 2 - ...eneIndexCreationPersistenceIntegrationTest.java | 41 +- .../LuceneIndexMaintenanceIntegrationTest.java | 34 +- .../geode/cache/lucene/LuceneQueriesDUnitTest.java | 3 - .../cache/lucene/LuceneQueriesIntegrationTest.java | 79 +- .../LuceneQueriesPersistenceIntegrationTest.java | 29 +- .../LuceneSearchWithRollingUpgradeDUnit.java | 1042 ++++++++++ .../cache/lucene/MixedObjectIndexDUnitTest.java | 20 +- .../geode/cache/lucene/RebalanceDUnitTest.java | 1 - .../internal/LuceneEventListenerJUnitTest.java | 7 +- .../lucene/internal/LuceneIndexFactorySpy.java | 5 +- .../LuceneIndexForPartitionedRegionTest.java | 12 +- .../internal/LuceneQueryFactoryImplJUnitTest.java | 1 - .../lucene/internal/LuceneQueryImplJUnitTest.java | 3 - .../PageableLuceneQueryResultsImplJUnitTest.java | 2 - .../PartitionedRepositoryManagerJUnitTest.java | 2 +- .../RawLuceneRepositoryManagerJUnitTest.java | 26 +- .../internal/cli/LuceneIndexCommandsDUnitTest.java | 270 +-- .../internal/cli/LuceneIndexCommandsJUnitTest.java | 90 +- .../LuceneCreateIndexFunctionJUnitTest.java | 5 +- .../LuceneDescribeIndexFunctionJUnitTest.java | 4 +- .../LuceneDestroyIndexFunctionJUnitTest.java | 15 +- .../LuceneListIndexFunctionJUnitTest.java | 3 +- .../LuceneSearchIndexFunctionJUnitTest.java | 4 +- .../LuceneClusterConfigurationDUnitTest.java | 29 +- .../DumpDirectoryFilesIntegrationTest.java | 27 +- .../directory/DumpDirectoryFilesJUnitTest.java | 3 - .../directory/RegionDirectoryJUnitTest.java | 10 +- .../distributed/DistributedScoringJUnitTest.java | 2 - .../distributed/LuceneQueryFunctionJUnitTest.java | 12 +- .../TopEntriesFunctionCollectorJUnitTest.java | 5 +- .../WaitUntilFlushedFunctionJUnitTest.java | 6 - .../internal/filesystem/FileSystemJUnitTest.java | 23 +- .../filesystem/FileSystemStatsJUnitTest.java | 1 - .../BucketTargetingFixedResolverTest.java | 5 +- .../internal/partition/BucketTargetingMapTest.java | 4 - .../repository/IndexRepositoryImplJUnitTest.java | 6 +- .../IndexRepositoryImplPerformanceTest.java | 58 +- .../repository/LuceneIndexMemoryOverheadTest.java | 129 ++ .../results/LuceneGetPageFunctionJUnitTest.java | 5 - .../internal/results/PageEntryJUnitTest.java | 1 - .../xml/LuceneIndexXmlGeneratorJUnitTest.java | 1 - .../xml/LuceneIndexXmlParserJUnitTest.java | 1 - .../cache/lucene/test/IndexRepositorySpy.java | 3 +- geode-old-versions/build.gradle | 44 +- geode-protobuf/build.gradle | 62 + .../tier/sockets/ClientProtocolMessageHandler.java | 37 + .../tier/sockets/MessageExecutionContext.java | 93 + .../internal/protocol/ProtobufCachePipeline.java | 66 + .../internal/protocol/ProtobufLocatorPipeline.java | 55 + .../internal/protocol/ProtobufProtocolService.java | 61 + .../exception/InvalidProtocolMessageException.java | 31 + .../protocol/operations/OperationHandler.java | 39 + .../protocol/protobuf/EncodingTypeTranslator.java | 66 + .../geode/internal/protocol/protobuf/Failure.java | 48 + .../protocol/protobuf/OperationContext.java | 67 + .../protocol/protobuf/ProtobufOpsProcessor.java | 79 + .../protobuf/ProtobufSerializationService.java | 55 + .../protobuf/ProtobufSimpleAuthenticator.java | 78 + .../protobuf/ProtobufSimpleAuthorizer.java | 34 + .../protocol/protobuf/ProtobufStreamProcessor.java | 85 + .../protocol/protobuf/ProtocolErrorCode.java | 41 + .../geode/internal/protocol/protobuf/Result.java | 29 + .../geode/internal/protocol/protobuf/Success.java | 48 + .../operations/GetAllRequestOperationHandler.java | 106 + .../GetAvailableServersOperationHandler.java | 62 + .../GetRegionNamesRequestOperationHandler.java | 41 + .../GetRegionRequestOperationHandler.java | 58 + .../operations/GetRequestOperationHandler.java | 77 + .../operations/PutAllRequestOperationHandler.java | 95 + .../operations/PutRequestOperationHandler.java | 74 + .../operations/RemoveRequestOperationHandler.java | 71 + .../registry/OperationContextRegistry.java | 104 + .../serializer/ProtobufProtocolSerializer.java | 43 + .../protobuf/statistics/NoOpStatistics.java | 47 + .../statistics/ProtobufClientStatistics.java | 33 + .../statistics/ProtobufClientStatisticsImpl.java | 103 + .../protobuf/utilities/ProtobufPrimitiveTypes.java | 49 + .../utilities/ProtobufRequestUtilities.java | 118 ++ .../utilities/ProtobufResponseUtilities.java | 61 + .../protobuf/utilities/ProtobufUtilities.java | 315 +++ .../exception/UnknownProtobufPrimitiveType.java | 24 + .../protocol/serializer/ProtocolSerializer.java | 34 + .../serialization/SerializationService.java | 34 + .../internal/serialization/SerializationType.java | 32 + .../geode/internal/serialization/TypeCodec.java | 36 + .../internal/serialization/codec/JSONCodec.java | 39 + .../UnsupportedEncodingTypeException.java | 31 + .../registry/SerializationCodecRegistry.java | 67 + .../CodecAlreadyRegisteredForTypeException.java | 28 + .../CodecNotRegisteredForTypeException.java | 27 + .../src/main/proto/authentication_API.proto | 26 + geode-protobuf/src/main/proto/basicTypes.proto | 88 + geode-protobuf/src/main/proto/clientProtocol.proto | 82 + geode-protobuf/src/main/proto/region_API.proto | 95 + geode-protobuf/src/main/proto/server_API.proto | 32 + ...ternal.cache.tier.sockets.ClientProtocolService | 1 + ...g.apache.geode.internal.serialization.TypeCodec | 1 + ...he.geode.security.internal.server.Authenticator | 1 + .../GenericProtocolServerConnectionTest.java | 140 ++ .../protocol/AuthenticationIntegrationTest.java | 146 ++ .../protocol/AuthorizationIntegrationTest.java | 205 ++ .../geode/internal/protocol/MessageUtil.java | 80 + .../apache/geode/internal/protocol/OpsHandler.java | 21 + .../acceptance/CacheConnectionJUnitTest.java | 278 +++ .../CacheConnectionTimeoutJUnitTest.java | 168 ++ .../acceptance/CacheMaxConnectionJUnitTest.java | 241 +++ .../acceptance/CacheOperationsJUnitTest.java | 430 ++++ .../acceptance/LocatorConnectionDUnitTest.java | 268 +++ ...TypeToSerializationTypeTranslatorJUnitTest.java | 54 + .../ProtobufSimpleAuthenticatorJUnitTest.java | 128 ++ .../protobuf/ProtobufStreamProcessorTest.java | 46 + .../GetAllRequestOperationHandlerJUnitTest.java | 185 ++ ...tAvailableServersOperationHandlerJUnitTest.java | 112 + ...egionNamesRequestOperationHandlerJUnitTest.java | 101 + .../GetRegionRequestOperationHandlerJUnitTest.java | 105 + .../GetRequestOperationHandlerJUnitTest.java | 145 ++ .../operations/OperationHandlerJUnitTest.java | 38 + .../PutAllRequestOperationHandlerJUnitTest.java | 140 ++ .../PutRequestOperationHandlerJUnitTest.java | 142 ++ .../RemoveRequestOperationHandlerJUnitTest.java | 133 ++ .../statistics/NoOpProtobufStatistics.java | 47 + .../utilities/ProtobufUtilitiesJUnitTest.java | 159 ++ .../ProtobufProtocolSerializerJUnitTest.java | 75 + .../serialization/codec/JSONCodecJUnitTest.java | 229 +++ .../registry/CodecRegistryJUnitTest.java | 49 + .../internal/protocol/acceptance/default.keystore | Bin 0 -> 1115 bytes geode-pulse/build.gradle | 3 - .../tools/pulse/internal/PulseAppListener.java | 7 +- .../tools/pulse/internal/PulseAppListenerTest.java | 91 + .../org/apache/geode/tools/pulse/tests/Server.java | 42 +- .../geode/tools/pulse/tests/rules/ServerRule.java | 8 +- .../org/apache/geode/cache/util/AutoBalancer.java | 6 +- .../internal/locator/wan/LocatorDiscovery.java | 10 +- .../locator/wan/LocatorMembershipListenerImpl.java | 8 +- .../cache/wan/AbstractRemoteGatewaySender.java | 4 +- .../internal/cache/wan/GatewayReceiverImpl.java | 72 +- .../wan/GatewaySenderEventRemoteDispatcher.java | 37 +- .../wan/parallel/ParallelGatewaySenderImpl.java | 6 +- .../cache/wan/serial/SerialGatewaySenderImpl.java | 7 +- .../geode/cache/CacheXml70GatewayDUnitTest.java | 2 +- .../cache/wan/WANRollingUpgradeDUnitTest.java | 635 +++++- .../internal/cache/UpdateVersionDUnitTest.java | 940 ++++----- .../cache/wan/GatewayReceiverImplJUnitTest.java | 59 + .../geode/internal/cache/wan/WANTestBase.java | 7 +- .../ConcurrentParallelGatewaySenderDUnitTest.java | 28 +- .../GatewayLegacyAuthenticationRegressionTest.java | 423 ++++ .../KeepEventsOnGatewaySenderQueueDUnitTest.java | 168 ++ .../cache/wan/misc/WANConfigurationJUnitTest.java | 2 +- .../cache/wan/misc/WanAutoDiscoveryDUnitTest.java | 7 +- .../wan/parallel/BatchRemovalThreadHelper.java | 22 + .../ParallelGatewaySenderOperationsDUnitTest.java | 38 + .../wan/serial/SerialWANPropagationDUnitTest.java | 25 +- ...teAndDestroyGatewaySenderCommandsDUnitTest.java | 532 +++++ .../CreateGatewayReceiverCommandDUnitTest.java | 795 +++++++ .../CreateGatewaySenderCommandDUnitTest.java | 148 ++ .../DestroyGatewaySenderCommandDUnitTest.java | 75 + .../PauseGatewaySenderCommandDUnitTest.java | 233 +++ .../ResumeGatewaySenderCommandDUnitTest.java | 263 +++ .../StartGatewayReceiverCommandDUnitTest.java | 224 ++ .../StartGatewaySenderCommandDUnitTest.java | 275 +++ .../StatusGatewayReceiverCommandDUnitTest.java | 206 ++ .../StatusGatewaySenderCommandDUnitTest.java | 251 +++ .../StopGatewayReceiverCommandDUnitTest.java | 221 ++ .../StopGatewaySenderCommandDUnitTest.java | 236 +++ .../cache/wan/wancommand/WANCommandTestBase.java | 186 +- ...CommandCreateDestroyGatewaySenderDUnitTest.java | 794 ------- .../WanCommandCreateGatewayReceiverDUnitTest.java | 585 ------ .../WanCommandGatewayReceiverStartDUnitTest.java | 269 --- .../WanCommandGatewayReceiverStopDUnitTest.java | 269 --- .../WanCommandGatewaySenderStartDUnitTest.java | 327 --- .../WanCommandGatewaySenderStopDUnitTest.java | 287 --- .../wan/wancommand/WanCommandListDUnitTest.java | 73 +- .../wancommand/WanCommandPauseResumeDUnitTest.java | 553 ----- .../wan/wancommand/WanCommandStatusDUnitTest.java | 537 ----- .../geode/management/WANManagementDUnitTest.java | 58 +- .../ClusterConfigurationDUnitTest.java | 40 +- ...rConfigurationIndexWithFromClauseDUnitTest.java | 45 +- .../internal/pulse/TestRemoteClusterDUnitTest.java | 39 +- .../web/controllers/CommonCrudController.java | 14 +- .../web/controllers/FunctionAccessController.java | 8 +- .../web/controllers/PdxBasedCrudController.java | 15 +- .../web/controllers/QueryAccessController.java | 17 +- .../web/security/GeodeAuthenticationProvider.java | 24 +- .../web/security/RestSecurityConfiguration.java | 7 +- .../internal/web/security/RestSecurityService.java | 22 +- .../cli/commands/AlterRuntimeCommandDUnitTest.java | 1205 +++++++++++ .../commands/ClusterConfigurationDUnitTest.java | 144 ++ .../cli/commands/CommandOverHttpDUnitTest.java | 16 +- .../internal/cli/commands/CommandOverHttpTest.java | 91 + .../commands/ConnectCommandIntegrationTest.java | 50 + .../ConnectCommandWithHttpAndSSLDUnitTest.java | 328 --- .../cli/commands/ConnectCommandWithSSLTest.java | 329 +++ .../commands/ConnectCommandWithSecurityTest.java | 58 + .../DataCommandsOverHttpDistributedTest.java | 155 -- .../commands/DescribeConfigCommandDUnitTest.java | 91 + ...xecuteFunctionCommandWithSecurityDUnitTest.java | 113 + .../cli/commands/ExportConfigCommandDUnitTest.java | 111 + .../ExportLogsOverHttpIntegrationTest.java | 2 +- .../commands/ExportLogsStatsOverHttpDUnitTest.java | 2 +- .../FunctionCommandsOverHttpDUnitTest.java | 29 + .../cli/commands/IndexCommandOverHttpTest.java | 30 + .../ListIndexCommandOverHttpDUnitTest.java | 29 + .../cli/commands/QueryNamesOverHttpDUnitTest.java | 60 - .../RebalanceCommandOverHttpDistributedTest.java | 31 + .../security/GfshCommandsOverHttpSecurityTest.java | 6 +- .../internal/security/LogNoPasswordTest.java | 40 +- .../internal/web/AbstractWebTestCase.java | 96 - .../ShellCommandsControllerJUnitTest.java | 253 --- ...inHandlerInterceptorRequestHeaderJUnitTest.java | 3 +- .../internal/web/domain/LinkIndexJUnitTest.java | 275 --- .../internal/web/domain/LinkJUnitTest.java | 129 -- .../web/http/ClientHttpRequestJUnitTest.java | 556 ----- .../HttpOperationInvokerMBeanOperationTest.java | 93 + .../shell/HttpOperationInvokerSecurityTest.java | 99 + .../shell/RestHttpOperationInvokerJUnitTest.java | 470 ----- .../shell/SimpleHttpOperationInvokerJUnitTest.java | 205 -- .../internal/web/util/UriUtilsJUnitTest.java | 116 -- gradle.properties | 13 +- gradle/dependency-resolution.gradle | 89 +- gradle/dependency-versions.properties | 15 +- gradle/docker.gradle | 113 + gradle/ide.gradle | 16 +- gradle/publish.gradle | 4 +- gradle/rat.gradle | 14 +- gradle/test.gradle | 46 +- gradle/wrapper/gradle-wrapper.properties | 2 +- settings.gradle | 6 +- 2326 files changed, 112465 insertions(+), 88002 deletions(-) -- To stop receiving notification emails like this one, please contact "[email protected]" <[email protected]>.
