From commits-return-27474-archive-asf-public=cust-asf.ponee.io@geode.apache.org Fri Jul 13 00:55:28 2018 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx-eu-01.ponee.io (Postfix) with SMTP id E8FBE180654 for ; Fri, 13 Jul 2018 00:55:25 +0200 (CEST) Received: (qmail 38940 invoked by uid 500); 12 Jul 2018 22:55:25 -0000 Mailing-List: contact commits-help@geode.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@geode.apache.org Delivered-To: mailing list commits@geode.apache.org Received: (qmail 38931 invoked by uid 99); 12 Jul 2018 22:55:24 -0000 Received: from ec2-52-202-80-70.compute-1.amazonaws.com (HELO gitbox.apache.org) (52.202.80.70) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 12 Jul 2018 22:55:24 +0000 Received: by gitbox.apache.org (ASF Mail Server at gitbox.apache.org, from userid 33) id 3661A81E1C; Thu, 12 Jul 2018 22:55:24 +0000 (UTC) Date: Thu, 12 Jul 2018 22:55:22 +0000 To: , "' commits@geode.apache.org" , '@gitbox.apache.org, Subject: [geode] branch feature/GEODE-5145 updated (8047a18 -> ce67725) MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 8bit Message-ID: <153143612184.21888.8279143274760684463@gitbox.apache.org> From: boglesby@apache.org X-Git-Host: gitbox.apache.org X-Git-Repo: geode X-Git-Refname: refs/heads/feature/GEODE-5145 X-Git-Reftype: branch X-Git-Oldrev: 8047a18ba27065a10022221f12102442a813f37e X-Git-Newrev: ce67725770664bebefd34c23b998344d4a0a334f X-Git-NotificationType: ref_changed X-Git-Multimail-Version: 1.5.dev Auto-Submitted: auto-generated This is an automated email from the ASF dual-hosted git repository. boglesby pushed a change to branch feature/GEODE-5145 in repository https://gitbox.apache.org/repos/asf/geode.git. omit 8047a18 GEODE-5145: Incorporated review comments omit d95c4cf GEODE-5145: Added support for destroying an index during region creation add a0cb1fe GEODE-5109: Handle only IllegalStateException add edd8836 Adding pgp signature for Nabarun Nag in KEYS add 8895864 GEODE-4386 Document the gfsh describe jndi-binding command (#1973) add ec7a162 GEODE-4858: CreateAsyncEventQueue and tests refactor. (#1969) add 75e8b9e GEODE-5230: Pulse does not work when SSL is enabled for JMX (#1976) add 5403732 GEODE-5010: have post interceptor uses ResultModel as an input if com… (#1974) add 45af84a Updating the version numbers to 1.8.0 add d998510 GEODE-3563 SSL socket handling problems in TCPConduit run add 3af0a82 GEODE-5011: ResultModel can add a table that takes a list of CliFunct… (#1972) add 2bf85a6 GEODE-4953: Extend spotless to prohibit the use of wildcard imports. (#1926) add cd418f0 GEODE-5032: Pluralize configuration class getters and fields that refer to lists. (#1977) add 16dbf7e [GEODE-5243] Fix deploy scripts and pipeline definitions for releases. (#1979) add 52f0787 GEODE-5242 Correct docs SSL component name from http to web (#1980) add 019345e GEODE-5071 Update docs of gfsh limitations and recommendations (#1978) add 530c66d GEODE-5245: Unit tests fail on windows due to assertions on paths (#1981) add 2faf3fb GEODE-4858: Refactor 'list async-event-queue' command and function (#1975) add ff66270 GEODE-5208 remove test hooks from TypeRegistration (#1958) add d77744a GEODE-5186: set operation in a client transaction could cause the transaction to hang (#1967) add 88340a7 GEODE-5220: Validate Region Attributes Earlier add 9e8dfb2 Merge branch 'feature/GEODE-5220' of https://github.com/jujoramos/geode into develop add 527e346 GEODE-5247: Gfsh query results contain json instead of object references (#1985) add 71145b6 GEODE-4858: Convert *DefinedIndex commands to use ResultModel and Sin… (#1983) add 5321796 GEODE-5237 DiskAccessException can sometimes state that actual usage is less than critical (#1990) add 3c52a00 GEODE-5249: add test code to display serial gateway sender queue's content (#1991) add 19bcc96 GEODE-3733: Removed flaky flag - ran 210 passes which revealed nothing - talked to other developers and learned that there have been a number of changes since original bug - Removing flaky flag in order to get it back into test. add 4e7c6f1 GEODE-5254: Configure spotless to refrain from joining wrapped lines (#1994) add 8aff924 GEODE-5261 - Add a test for connection-pool prefill during shutdown add b9a37ce GEODE-4614: Handle case where unable to find region while handling put request. (#2002) add c87afbe GEODE-5261 - Add a test for connection-pool prefill during shutdown add 084d4b5 GEODE-4614: updating sanctionedDataSerializables.txt to reflect changed code add bb0a614 GEODE-5262: fix race condition in RemoteGfManagerAgent between remove… (#2001) add 2cf7cbc GEODE-5255: check all colocated partitioned regions are ready before … (#1998) add 6bdcc57 GEODE-5245: Unit tests fail on windows due to assertions on paths (#2003) add 2008b46 GEODE-5266: Add additional tests for gfsh create region (#2004) add 6f9a172 GEODE-5250: Repaired a threadpool leak (#1989) add d3a9f75 GEODE-5268: fixing race condition in GMSHealthMonitor (#2005) add af07c3c GEODE-5223 Add unit tests for AbstractRegionMap.txApplyDestroy (#1988) add 44e5d36 GEODE-5265: fix dataStoreEntryCount statistic (#2006) add 0c49431 GEODE-5270: Closing the connection. (#2008) add e628df4 GEODE-5272: CacheClosedException not wrapped in TypeMismatchException (#2009) add 7f63c4b GEODE-5273: Prevent unnecessary chaining of exception. (#2012) add 7d69f29 Revert "GEODE-5265: fix dataStoreEntryCount statistic (#2006)" add 9a40c9d GEODE-5265: fix dataStoreEntryCount statistic (#2006) add 400a843 GEODE-5274: Null check for closing CacheClientProxy (#2014) add f50b945 GEODE-5269 CommitConflictException after TransactionInDoubtException add 066ded0 User Guide: update redirects.rb to reflect latest development version add 62665a4 Revert "GEODE-5270: Closing the connection. (#2008)" add 6491a34 GEODE-5249: should sync on this.unprocessedEventsLock when iterating (#2018) add b731658 GEODE-5252: Race in management adapter could fail to create MXBeans. (#1993) add 0d89728 Revert "GEODE-5269 CommitConflictException after TransactionInDoubtException" add e9a61bb Split monolithic DistributedTest job into two parallel tasks add ddcd514 Merge pull request #2019 from smgoller/GEODE-5282 add 024ed43 GEODE-5278 Unexpected CommitConflictException caused by faulty region synchronization add cad7a1b GEODE-5269 CommitConflictException after TransactionInDoubtException add b488f12 GEODE-5280: Fixes NPE when logging event (#2022) add dbdd788 GEODE-5283: Client transaction fails with TransactionException: GemFireInternalException add c4e7fb8 GEODE-3692 Intermittent test failure: ClientAuthDUnitTest add d4e9725 GEODE-5267: User Guide - un-document deprecated JTA transaction manager add bec37bd GEODE-5267: User Guide - remove redundant JTA subheads from subnav add 3b35239 Bump Bookbinder, nokogiri dependency add ca7ea46 GEODE-5283: Client transaction fails with TransactionException: GemFireInternalException add 2d0dce3 GEODE-577: Reducing the timeout (#2023) add d0ec4e4 GEODE-5270: Shutting down the AckThread (#2017) add f7fb7e3 GEODE-3013: Prevent multiple node found error to be displayed in the log (#2029) add 44643a8 GEODE-5290: Fixes NPE with ResultsCollectionPdxDeserializerWrapper iterator (#2027) add 373f7ad GEODE-5291: More destroys recorded in CachePerfStats than actual in a transaction with expiration (#2028) add c9e7d88 GEODE-5287 Incorporate ACID semantics into transaction intro docs (#2032) add 4e2f2bc Release server affinity immediately after commit add bdfab05 Merge pull request #2015 from apache/feature/GEODE-5277 add ca0f662 Adding 1.8 as a version in Version.java add 69c8710 GEODE-5292: Fix memory leak for off heap regions with overflow add 81b0019 GEODE-5300: Remove mention of a developer by name add a58d8d2 GEODE-5212: Fix gfsh rule to use gfsh.bat on windows (#2036) add 5d9eb94 GEODE-5288: fix execute function on region call and create more tests to improve coverage. (#2024) add 3cef629 GEODE-5276: fix entries stats from going negative (#2033) add 8956291 GEODE-5279: RegionExistsException coming from JMX Manager (#2026) add 94dd9bb GEODE-5294: Fix ConcurrentModificationException ShutdownAllRequest wh… (#2030) add dca0240 GEODE-5298: User Guide - Document Transactions + Functions Limitation add 2d97c22 GEODE-5292: Ignoring flaky ConcurrentRegion... test until we can fix it add fe9f0d9 Check readiness and closed before assertion add 929f804 Merge pull request #2040 from apache/feature/GEODE-5301 add e4f789b GEODE-5302: set totalLiveCount to 0 after successfuly compacted the oplog. (#2041) add 1da8eb9 GEODE-5288: improve ResultModel assertions (#2038) add ba320cb GEODE-5311: User Guide - simplify navigation for "Client Transactions" section add 48539ed GEODE-5288: improve ResultModel assertions. Fix test add 3ed33a1 GEODE-5307 Hang with servers all in waitForPrimaryMember and one server in NO_PRIMARY_HOSTING state add ca1f3bf GEODE-5312: Cleanup transaction if it is removed by the client tx failover (#2047) add 1e69c19 GEODE-5310: Modified to check for initialized RegionAdvisor add 0f75926 GEODE-5313: User Guide - consolidate transaction coding examples add 09f0ba9 GEODE-5308: User Guide - simplify terminology: "cache transactions" can be "transactions". add 40327e7 GEODE-5308: User Guide - simplify terminology: "cache transactions" can be "transactions". add b12abfa GEODE-4822 fix AnalyzeSerializablesJUnitTest's "actualDataSerializables.dat" add 834b5ee GEODE-5319: Mark test as integration test. (#2055) add 80aabee GEODE-5305: Add flag to TXCommitMessage to indicate the use of shadow key (#2043) add 065e996 GEODE-5313: User Guide - consolidate transaction coding examples - fix a broken link add 3f4c33b GEODE-5320 add a test for thread-owned connection cleanup add 3668888 GEODE-5318: Extract the valid region name (#2054) add 56c5d11 GEODE-5323 ConfigurationProperties says the default socket-lease-time is 15000ms but it is 60000ms add 7df2f75 GEODE-5325: add FlakyTest to recoversFromCloseDuringRegionOperation add 337869d GEode-5317: Add null check around reconnectDS add 2a82742 Merge pull request #2053 from apache/feature/GEODE-5317 add a76e951 GEODE-5322: Catch exceptions during plugin loading (#2058) add 816c180 GEODE-5306: add crashVM and forceDisconnect in ClusterStartupRule (#2048) add c58acb1 GEODE-5327: Update expected number of gateway senders (#2060) add 8bab21a Create temp folder in two places (#2062) add b2216b6 GEODE-5065: fix race in DataSerializerPropagationDUnitTest. (#2063) add 7685375 GEODE-4791: Enable gradle 4.8 for features and futureproofing (#2050) add c9be10e GEODE-5313: User Guide - consolidate transaction coding examples - broken link repairs add 82bc8f9 GEODE-5284: Add testing surrounding MBean persistence during member failure and reconnection. (#2066) add 1380562 Introduces Serializable Consumer for Cluster junit (#2067) add 982d332 GEODE-5285: Make PdxInstanceImplTest a unit test instead of an integration test (#2064) add f5eab20 GEODE-5330: only create one temp folder (#2068) add 7d7a651 Fix test failure related to #2067 add ec0501d GEODE-5109: Ignoring the test add 13087e2 GEODE-5333: Destroy failed connection in ConnectionConnector (#2072) add f2aeed4 User Guide: correct a CQ typo add 908a5ef GEODE-5335: Do not resolve addresses when calling netstat and lsof (#2070) add 226e406 GEODE-4791: Fix intellij with gradle 4.8 by removing provided configuration add 880a9d6 Write a test that hangs without the fix for GEODE-3563. (#2057) add 87c0ec3 GEODE-4511: rework ClientAuthDUnitRule to illustrate when authenticat… (#2077) add af0ac3d GEODE-1655: CI Failure in AutoConnectionSourceDUnitTest.testClientMembershipListener add 6ae3cad GEODE-5346: Fix race in LauncherLifecycleCommandsDUnitTest (#2080) add d8538ee GEODE-1198 CI Failure: DistributedSystemDUnitTest.testConflictingUDPPort add 3246b4e GEODE-5285: Improve unit test coverage for PdxInstanceImpl. (#2085) add 40ecb6e GEODE-5328: Update exception message when MemberMBean.showLog is call… (#2061) add 213ae23 GEODE-5339: removing the unnecessary property files in pulse main resource module (#2073) add 01b51ba GEODE-5296 Rewrite introductory prose on transactions (#2056) add dfafad7 GEODE-5349 State-flush operation may exit early allowing for cache inconsistency add 5e3d497 [GEODE-5368] Fix dockerfile to reference docker's website to fetch the gpg key. add 6b782d9 Merge pull request #2092 from smgoller/GEODE-5368 add 6cfc84a GEODE-5352: testLocalDataContextWithColocation will now wait for result before shutting down (#2084) add 4ec2878 GEODE-5350: User Guide: Specifying that 'statistics-enabled' parameter for region (#2081) add 2e5bff9 GEODE-5380: create PR pipeline that integrates with GitHub pull requests add 40bead1 GEODE-5380 pr-pipeline needs to be named pr- to not collide with develop add b6d4519 Merge pull request #2103 from smgoller/GEODE-5380-take-2 add 73965a8 GEODE-5212: Ensure that paths on Windows don't end up with spaces (#2100) add 3937ebe GEODE-5373: Adjust timing for GMSHealthMonitorJUnitTest.testRemoveMemberCalled (#2097) add 2709f1c Fix test which is using a hijacked domain add ba1923f Don't send email on failure as it's unnecessary. (#2104) add 035e7bb GEM-2031: Removing the use of shutdownNow from AcceptorImpl pools add 599f960 GEODE-5359: Clear interrupt bit on retry in DirectChannel.sendToMany add 4bfa4ce Missed some email references. add 4885473 GEODE-5361: Add wait for MBean federation after member restarts (#2090) add 10d8dab GEODE-5336: create integration tests to test region rest apis and con… (#2071) add 6a9a98b GEODE-5430: Allow disk store commands to use custom log4j2 config add 377529c GEODE-5341: Improve debug logging in BackupTask add bb85e7c GEODE-5355: Remove BackupUtil and BackupDataStoreHelper add 9357435 GEODE-5355: Fix apache license header of new backup classes add 29c71c9 GEODE-5281: replicate failure and fix bug (#2096) add b66d110 Add exclusion for gradle notification file add 2c3a7b1 [GEODE-5378] Adjust initdocker script to implement workaround. add 5dfc65c Merge pull request #2110 from smgoller/GEODE-5378 add 2ba81f6 GEODE-4803: remove flaky category (#2108) add dbdbd7a GEODE-5385: hang trying to create a bucket add bb79fdb GEODE-5375: fix the test hang when a CommitFailedException happens (#2101) add 1eb0275 GEODE-5398: Add BackupOperationTest and BackupStatusImplTest add b79b64a GEODE-5383: Check that data propagated earlier add 023b495 GEODE-5390: Use @Override in DiskInitFile and DiskInitFileParser add 1de96e4 GEODE-5390: Move inner classes to end of DiskInitFile add 3482a10 GEODE-5390: Move inner classes to end of Oplog add 6ef4e4a GEODE-5390: Fix log statements in DiskInitFileParser add 172c6a9 GEODE-5390: Improve trace level log statement in Oplog add 0e8ecd9 GEODE-5391: Fix toString of RegionVersionHolder add 1564e56 GEODE-5392: Cleanup javadocs and code style in AsyncInvocation add 9d87117 GEODE-5393: StateFlushOperation hangs waiting for non-existant operation to complete add 9037d42 [GEODE-5292] Actually destroy the region instead of pretending to. add c891b0b GEODE-5405: Refactor backup to remove duplication and clean up add 442e7aa GEODE-5407: increase timeout and provide more logging (#2120) add 445c8b7 GEODE-5369: fix for Lucene Stats (#2115) add 4fcee50 GEODE-5351 Prefer terminology of cluster over dist system (#2116) add e4bd46d Revert "[GEODE-5292] Actually destroy the region instead of pretending to." add b4796e6 GEODE-5379: Reset affinityRetryCount to zero only when initial retry count is zero to avoid stack overflow (#2098) add a96edf2 GEODE-5404: Created static default whitelist and modified to call length add 2e1673b GEODE-5408 Update docs for gfsh remove --all (#2119) add 84e911c GEODE-5295: Improve member WaitUntilX methods (#2039) add 1590182 GEODE-5377: wait till threads to finish before exiting the test (#2106) add 71fdb76 spotless add 5da7ad4 GEODE-5394: Change to add additional logging in the event of a failure. new d67979d GEODE-5145: Added support for destroying an index during region creation new ce67725 GEODE-5145: Incorporated review comments This update added new revisions after undoing existing revisions. That is to say, some revisions that were in the old version of the branch are not in the new version. This situation occurs when a user --force pushes a change and generates a repository containing something like this: * -- * -- B -- O -- O -- O (8047a18) \ N -- N -- N refs/heads/feature/GEODE-5145 (ce67725) You should already have received notification emails for all of the O revisions, and so the following emails describe only the N revisions from the common base, B. Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. The 2 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: KEYS | 72 + build.gradle | 7 +- ci/docker/Dockerfile | 13 +- ci/docker/docker.list | 17 - ci/docker/initdocker | 3 + ci/pipelines/deploy_meta.sh | 19 +- ci/pipelines/geode-build/base.yml | 125 +- ci/pipelines/geode-build/deploy_pipeline.sh | 10 +- .../geode-build/test-stubs/distributed.yml | 27 - ci/pipelines/meta.yml | 55 +- ci/pipelines/pull-request/base.yml | 246 + .../deploy_pr_pipeline.sh} | 26 +- ci/pipelines/pull-request/pr-template.yml | 104 + ci/scripts/build.sh | 31 +- ci/scripts/test-archive.sh | 29 +- ci/scripts/test-run.sh | 33 +- etc/eclipse-java-google-style.xml | 2 +- .../geode/modules/session/TestSessionsBase.java | 4 +- .../modules/util/ModuleFunctionsSecurityTest.java | 2 +- extensions/session-testing-war/build.gradle | 3 +- geode-assembly/build.gradle | 5 +- .../LauncherLifecycleCommandsDUnitTest.java | 50 +- .../cli/commands/StatusLocatorRealGfshTest.java | 4 +- .../internal/web/RestFunctionExecuteDUnitTest.java | 32 +- .../rest/internal/web/RestRegionAPIDUnitTest.java | 422 + .../internal/web/RestSecurityIntegrationTest.java | 317 +- .../web/RestSecurityPostProcessorTest.java | 85 +- .../rest/internal/web/RestSecurityWithSSLTest.java | 13 +- .../internal/web/RestServersIntegrationTest.java | 20 +- .../web/SwaggerVerificationIntegrationTest.java | 15 +- .../PdxBasedCrudControllerIntegrationTest.java | 8 +- .../junit/rules/GeodeDevRestClient.java} | 133 +- ...ttpClientRule.java => GeodeHttpClientRule.java} | 30 +- .../geode/test/junit/rules/GfshRuleTest.java | 6 +- .../geode/test/junit/rules/HttpResponseAssert.java | 118 + .../geode/tools/pulse/PulseConnectivityTest.java | 5 +- .../geode/tools/pulse/PulseDataExportTest.java | 22 +- .../tools/pulse/PulseJmxPasswordFileTest.java | 10 +- .../geode/tools/pulse/PulseSecurityTest.java | 4 +- .../tools/pulse/PulseSecurityWithSSLTest.java | 6 +- geode-assembly/src/test/resources/sampleJson.json | 37881 +++++++++++++++++++ geode-book/Gemfile.lock | 16 +- geode-book/config.yml | 6 +- .../source/subnavs/geode-subnav.erb | 104 +- geode-book/redirects.rb | 4 +- .../jdbc/internal/cli/AlterConnectionCommand.java | 3 +- .../jdbc/internal/cli/AlterMappingCommand.java | 3 +- .../jdbc/internal/cli/CreateConnectionCommand.java | 3 +- .../jdbc/internal/cli/CreateMappingCommand.java | 3 +- .../internal/cli/DestroyConnectionCommand.java | 3 +- .../jdbc/internal/cli/DestroyMappingCommand.java | 3 +- .../jdbc/JdbcConnectorExceptionTest.java | 2 +- .../geode/connectors/jdbc/JdbcDistributedTest.java | 4 +- .../cli/JDBCConnectorFunctionsSecurityTest.java | 4 +- .../cli/JdbcClusterConfigDistributedTest.java | 2 +- geode-core/build.gradle | 10 +- .../admin/internal/AdminDistributedSystemImpl.java | 5 +- .../cache/client/internal/ConnectionConnector.java | 127 + .../client/internal/ConnectionFactoryImpl.java | 101 +- .../cache/client/internal/OpExecutorImpl.java | 97 +- .../geode/cache/client/internal/TXFailoverOp.java | 2 +- .../geode/cache/configuration/CacheConfig.java | 251 +- .../configuration/CacheTransactionManagerType.java | 18 +- .../geode/cache/configuration/ClassNameType.java | 3 +- .../geode/cache/configuration/DeclarableType.java | 26 +- .../geode/cache/configuration/DiskDirsType.java | 14 +- .../cache/configuration/FunctionServiceType.java | 16 +- .../cache/configuration/JndiBindingsType.java | 36 +- .../geode/cache/configuration/ObjectType.java | 3 +- .../apache/geode/cache/configuration/PoolType.java | 30 +- .../cache/configuration/RegionAttributesType.java | 42 +- .../geode/cache/configuration/RegionConfig.java | 54 +- .../SerializationRegistrationType.java | 27 +- .../geode/cache/configuration/ServerType.java | 16 +- .../org/apache/geode/cache/query/IndexType.java | 12 + .../cache/query/internal/CompiledIteratorDef.java | 47 +- .../RestrictedMethodInvocationAuthorizer.java | 10 +- .../ResultsCollectionPdxDeserializerWrapper.java | 4 + .../org/apache/geode/cache/wan/GatewaySender.java | 2 - .../geode/distributed/ConfigurationProperties.java | 2 +- .../internal/ClusterDistributionManager.java | 2 +- .../distributed/internal/DistributionAdvisor.java | 434 +- .../distributed/internal/DistributionManager.java | 7 +- .../internal/InternalDistributedSystem.java | 4 +- .../distributed/internal/InternalLocator.java | 7 + .../internal/LonerDistributionManager.java | 2 +- .../distributed/internal/ReplyProcessor21.java | 3 +- .../distributed/internal/direct/DirectChannel.java | 13 +- .../internal/membership/MembershipManager.java | 13 + .../membership/gms/fd/GMSHealthMonitor.java | 6 - .../membership/gms/mgr/GMSMembershipManager.java | 18 +- .../geode/internal/InternalDataSerializer.java | 125 +- .../org/apache/geode/internal/SystemAdmin.java | 8 +- .../java/org/apache/geode/internal/Version.java | 9 +- .../admin/remote/RemoteGfManagerAgent.java | 40 +- .../internal/admin/remote/ShutdownAllRequest.java | 19 +- .../geode/internal/cache/AbstractRegionMap.java | 105 +- .../apache/geode/internal/cache/BucketAdvisor.java | 50 +- .../apache/geode/internal/cache/BucketRegion.java | 1 + .../geode/internal/cache/BucketRegionQueue.java | 6 +- .../cache/DestroyPartitionedRegionMessage.java | 30 +- .../apache/geode/internal/cache/DiskInitFile.java | 56 +- .../apache/geode/internal/cache/DiskRegion.java | 2 - .../apache/geode/internal/cache/DiskStoreImpl.java | 2 +- .../geode/internal/cache/DiskStoreMonitor.java | 9 +- .../internal/cache/DistributedCacheOperation.java | 37 +- .../geode/internal/cache/DistributedRegion.java | 49 +- .../org/apache/geode/internal/cache/EventID.java | 5 +- .../geode/internal/cache/GemFireCacheImpl.java | 1 + .../internal/cache/InitialImageOperation.java | 29 +- .../geode/internal/cache/InternalRegion.java | 11 + .../apache/geode/internal/cache/LocalRegion.java | 5 +- .../geode/internal/cache/LocalRegionDataView.java | 4 +- .../org/apache/geode/internal/cache/Oplog.java | 380 +- .../internal/cache/PRHARedundancyProvider.java | 2 +- .../geode/internal/cache/PartitionedRegion.java | 27 +- .../internal/cache/PartitionedRegionDataStore.java | 34 +- .../geode/internal/cache/PeerTXStateStub.java | 17 +- .../geode/internal/cache/ProxyBucketRegion.java | 6 +- .../geode/internal/cache/ProxyRegionMap.java | 8 +- .../apache/geode/internal/cache/RegionEntry.java | 2 +- .../geode/internal/cache/TXCommitMessage.java | 232 +- .../apache/geode/internal/cache/TXManagerImpl.java | 25 + .../apache/geode/internal/cache/TXRegionState.java | 4 - .../org/apache/geode/internal/cache/TXState.java | 4 + .../internal/cache/backup/AbortBackupFactory.java | 6 + .../internal/cache/backup/AbortBackupRequest.java | 4 +- ...rtBackupOperation.java => AbortBackupStep.java} | 24 +- .../internal/cache/backup/BackupConfigFactory.java | 56 + .../cache/backup/BackupDataStoreHelper.java | 85 - .../cache/backup/BackupDataStoreResult.java | 22 +- .../internal/cache/backup/BackupDefinition.java | 2 + .../internal/cache/backup/BackupFileCopier.java | 11 +- .../geode/internal/cache/backup/BackupFilter.java | 1 + .../internal/cache/backup/BackupInspector.java | 41 +- .../internal/cache/backup/BackupLockService.java | 54 + .../internal/cache/backup/BackupOperation.java | 144 +- .../internal/cache/backup/BackupResponse.java | 4 +- .../cache/backup/BackupResultCollector.java | 1 + .../geode/internal/cache/backup/BackupService.java | 85 +- .../{FlushToDiskOperation.java => BackupStep.java} | 58 +- .../geode/internal/cache/backup/BackupTask.java | 32 +- .../geode/internal/cache/backup/BackupUtil.java | 95 - .../geode/internal/cache/backup/BackupWriter.java | 2 +- .../internal/cache/backup/BackupWriterFactory.java | 6 +- .../internal/cache/backup/DiskStoreBackup.java | 14 +- .../cache/backup/FileSystemBackupWriter.java | 8 +- .../cache/backup/FileSystemBackupWriterConfig.java | 5 +- .../FileSystemIncrementalBackupLocation.java | 14 +- .../internal/cache/backup/FinishBackupFactory.java | 6 + .../internal/cache/backup/FinishBackupRequest.java | 4 +- ...hBackupOperation.java => FinishBackupStep.java} | 9 +- .../internal/cache/backup/FlushToDiskFactory.java | 5 + .../internal/cache/backup/FlushToDiskRequest.java | 7 +- .../internal/cache/backup/FlushToDiskResponse.java | 7 +- ...shBackupOperation.java => FlushToDiskStep.java} | 29 +- .../cache/backup/IncrementalBackupLocation.java | 1 + .../geode/internal/cache/backup/PrepareBackup.java | 1 - .../cache/backup/PrepareBackupFactory.java | 7 + .../cache/backup/PrepareBackupRequest.java | 2 +- ...BackupOperation.java => PrepareBackupStep.java} | 4 +- .../geode/internal/cache/backup/RestoreScript.java | 20 +- .../internal/cache/backup/ScriptGenerator.java | 1 - .../cache/backup/TemporaryBackupFiles.java | 2 +- .../internal/cache/backup/UnixBackupInspector.java | 2 +- .../internal/cache/backup/UnixScriptGenerator.java | 10 +- .../cache/backup/WindowsBackupInspector.java | 10 +- .../execute/FunctionStreamingResultCollector.java | 3 +- .../geode/internal/cache/map/RegionMapDestroy.java | 5 +- .../cache/partitioned/FetchKeysMessage.java | 93 +- .../partitioned/ManageBackupBucketMessage.java | 64 +- .../cache/partitioned/PRSanityCheckMessage.java | 2 +- .../cache/partitioned/PartitionMessage.java | 28 +- .../internal/cache/partitioned/PutMessage.java | 27 +- .../internal/cache/partitioned/RegionAdvisor.java | 10 + .../cache/persistence/DiskInitFileParser.java | 8 +- .../internal/cache/tier/sockets/AcceptorImpl.java | 6 +- .../cache/tier/sockets/BaseCommandQuery.java | 6 +- .../cache/tier/sockets/CommandInitializer.java | 1 + .../cache/tier/sockets/command/CommitCommand.java | 60 +- .../command/ExecuteRegionFunctionSingleHop.java | 8 +- .../cache/tier/sockets/command/KeySet.java | 25 +- .../geode/internal/cache/tx/ClientTXStateStub.java | 8 +- .../internal/cache/tx/RemoteFetchKeysMessage.java | 6 + .../internal/cache/tx/RemoteOperationMessage.java | 2 +- .../cache/versions/RegionVersionHolder.java | 1 + .../cache/versions/RegionVersionVector.java | 4 + .../wan/AbstractGatewaySenderEventProcessor.java | 9 + ...oncurrentSerialGatewaySenderEventProcessor.java | 11 + .../serial/SerialGatewaySenderEventProcessor.java | 21 + .../cache/wan/serial/SerialGatewaySenderQueue.java | 4 + .../geode/internal/i18n/LocalizedStrings.java | 16 +- .../apache/geode/internal/tcp/ConnectionTable.java | 2 +- .../java/org/apache/geode/internal/util/Hex.java | 16 + .../management/internal/BackupStatusImpl.java | 14 +- .../management/internal/FederatingManager.java | 262 +- .../geode/management/internal/JettyHelper.java | 15 +- .../geode/management/internal/MBeanJMXAdapter.java | 8 + .../management/internal/MBeanProxyFactory.java | 15 +- .../internal/MBeanProxyInvocationHandler.java | 6 +- .../geode/management/internal/ManagementAgent.java | 47 +- .../geode/management/internal/RestAgent.java | 6 +- .../internal/beans/DistributedSystemBridge.java | 16 +- .../internal/beans/ManagementAdapter.java | 54 +- .../internal/beans/ManagementListener.java | 243 +- .../internal/beans/MemberMBeanBridge.java | 5 +- .../internal/cli/CliAroundInterceptor.java | 8 +- .../management/internal/cli/CommandManager.java | 14 +- .../cli/commands/BackupDiskStoreCommand.java | 7 +- .../cli/commands/ClearDefinedIndexesCommand.java | 11 +- .../cli/commands/CreateAsyncEventQueueCommand.java | 61 +- .../cli/commands/CreateDefinedIndexesCommand.java | 148 +- .../cli/commands/CreateGatewayReceiverCommand.java | 2 +- .../internal/cli/commands/CreateIndexCommand.java | 2 +- .../cli/commands/CreateJndiBindingCommand.java | 2 +- .../internal/cli/commands/DefineIndexCommand.java | 22 +- .../cli/commands/DescribeJndiBindingCommand.java | 3 +- .../internal/cli/commands/DestroyIndexCommand.java | 8 +- .../cli/commands/DiskStoreCommandsUtils.java | 16 +- .../cli/commands/ExecuteFunctionCommand.java | 13 +- .../internal/cli/commands/ExportConfigCommand.java | 19 +- .../ExportImportClusterConfigurationCommands.java | 6 +- .../internal/cli/commands/IndexDefinition.java | 17 +- .../cli/commands/ListAsyncEventQueuesCommand.java | 143 +- .../internal/cli/commands/QueryInterceptor.java | 19 +- .../cli/domain/AsyncEventQueueDetails.java | 6 +- .../internal/cli/domain/DataCommandResult.java | 26 +- .../management/internal/cli/domain/IndexInfo.java | 115 - .../internal/cli/functions/CliFunctionResult.java | 29 +- .../functions/CreateAsyncEventQueueFunction.java | 75 +- .../functions/CreateDefinedIndexesFunction.java | 106 +- .../cli/functions/CreateJndiBindingFunction.java | 2 +- .../functions/DestroyGatewayReceiverFunction.java | 2 +- .../cli/functions/DestroyIndexFunction.java | 4 +- .../cli/functions/GatewayReceiverFunctionArgs.java | 4 +- .../functions/ListAsyncEventQueuesFunction.java | 71 +- .../internal/cli/functions/NetstatFunction.java | 14 +- .../cli/functions/UserFunctionExecution.java | 24 +- .../internal/cli/remote/CommandExecutor.java | 13 +- .../internal/cli/result/ModelCommandResult.java | 20 +- .../internal/cli/result/ResultBuilder.java | 17 +- .../internal/cli/result/model/ResultModel.java | 103 +- .../cli/result/model/TabularResultModel.java | 52 +- .../internal/cli/shell/GfshExecutionStrategy.java | 45 +- .../callbacks/ConfigurationChangeListener.java | 12 +- .../internal/security/MBeanServerWrapper.java | 1 - .../geode/pdx/internal/ClientTypeRegistration.java | 3 - .../geode/pdx/internal/LonerTypeRegistration.java | 27 +- .../geode/pdx/internal/NullTypeRegistration.java | 20 +- .../geode/pdx/internal/PeerTypeRegistration.java | 48 +- .../geode/pdx/internal/TypeRegistration.java | 10 - .../apache/geode/pdx/internal/TypeRegistry.java | 25 +- .../sanctioned-geode-core-serializables.txt | 15 +- .../ConcurrentRegionOperationIntegrationTest.java | 105 + .../internal/AutoConnectionSourceDUnitTest.java | 19 +- .../client/internal/ConnectionConnectorTest.java | 114 + .../internal/ConnectionFactoryJUnitTest.java | 78 + .../cache/client/internal/LocatorSSLJUnitTest.java | 4 +- .../client/internal/OpExecutorImplJUnitTest.java | 82 + .../geode/cache/configuration/CacheConfigTest.java | 24 +- .../cache/configuration/DeclarableTypeTest.java | 14 +- .../cache/execute/CoreFunctionSecurityTest.java | 2 +- .../geode/cache/query/PdxStringQueryJUnitTest.java | 14 + .../geode/cache/query/dunit/PdxQueryDUnitTest.java | 102 +- .../internal/CompiledIteratorDefJUnitTest.java | 42 +- .../RestrictedMethodInvocationAuthorizerTest.java | 14 + .../AnalyzeSerializablesJUnitTest.java | 8 +- .../geode/codeAnalysis/ClassAndMethodDetails.java | 6 +- .../distributed/DistributedSystemDUnitTest.java | 11 +- .../distributed/ServerLauncherBuilderTest.java | 2 +- .../internal/CacheConfigDAODUnitTest.java | 2 +- .../internal/DistributionAdvisorDUnitTest.java | 100 +- .../internal/DlockAndTxlockRegressionTest.java | 21 +- ...nternalConfigurationPersistenceServiceTest.java | 4 +- .../membership/gms/MembershipManagerHelper.java | 50 +- .../gms/fd/GMSHealthMonitorJUnitTest.java | 99 +- .../admin/remote/RemoteGfManagerAgentTest.java | 86 + .../internal/cache/AbstractRegionMapTest.java | 212 + .../cache/AbstractRegionMapTxApplyDestroyTest.java | 1630 + .../geode/internal/cache/BucketAdvisorTest.java | 54 + .../cache/DiskStoreImplIntegrationTest.java | 2 +- .../apache/geode/internal/cache/DiskUsageTest.java | 34 +- .../cache/DistributedCacheOperationTest.java | 61 + .../org/apache/geode/internal/cache/OplogTest.java | 86 + .../cache/PartitionedRegionDataStoreTest.java | 171 + .../cache/PartitionedRegionDestroyJUnitTest.java | 65 + .../geode/internal/cache/TXManagerImplTest.java | 27 + .../geode/internal/cache/TxCommitMessageTest.java | 1167 + ...OperationTest.java => AbortBackupStepTest.java} | 53 +- .../cache/backup/BackupDistributedTest.java | 5 +- .../cache/backup/BackupIntegrationTest.java | 3 +- .../internal/cache/backup/BackupOperationTest.java | 130 + .../backup/BackupPrepareAndFinishMsgDUnitTest.java | 14 +- .../internal/cache/backup/BackupServiceTest.java | 4 +- ...perationTest.java => FinishBackupStepTest.java} | 48 +- ...OperationTest.java => FlushToDiskStepTest.java} | 20 +- .../backup/IncrementalBackupDistributedTest.java | 20 +- .../cache/backup/PrepareBackupFactoryTest.java | 3 +- .../cache/backup/PrepareBackupRequestTest.java | 4 +- ...erationTest.java => PrepareBackupStepTest.java} | 54 +- .../execute/PRFunctionExecutionDUnitTest.java | 13 +- .../internal/cache/map/RegionMapDestroyTest.java | 131 + .../cache/partitioned/FetchKeysMessageTest.java | 125 + .../ManageBackupBucketReplyMessageTest.java | 125 + .../cache/partitioned/PartitionMessageTest.java | 5 + ...PersistentPartitionedRegionDistributedTest.java | 2 + .../PersistentPartitionedRegionTestBase.java | 7 +- .../partitioned/RemotePutMessageJUnitTest.java | 68 + .../tier/sockets/ClientServerMiscDUnitTest.java | 76 +- .../DataSerializerPropagationDUnitTest.java | 54 +- .../tier/sockets/command/CommitCommandTest.java | 62 + .../cache/tier/sockets/command/KeySetTest.java | 78 + .../cache/tx/AbstractPeerTXRegionStubTest.java | 33 + .../internal/cache/tx/ClientTXStateStubTest.java | 46 +- .../cache/versions/RegionVersionVectorTest.java | 43 + ...SerialGatewaySenderEventProcessorJUnitTest.java | 33 + .../geode/internal/config/JAXBServiceTest.java | 2 +- .../geode/internal/net/SocketCreatorJUnitTest.java | 14 + .../geode/internal/tcp/ConnectionTableTest.java | 19 + .../geode/internal/tcp/TCPConduitDUnitTest.java | 128 + .../FederatingManagerIntegrationTest.java | 70 + .../management/JMXMBeanReconnectDUnitTest.java | 325 + .../management/internal/BackupStatusImplTest.java | 69 + .../internal/JMXMBeanFederationDUnitTest.java | 189 + .../MBeanFederationErrorPathDUnitTest.java | 128 + .../beans/DistributedSystemBridgeJUnitTest.java | 6 +- .../internal/beans/ManagementAdapterTest.java | 160 + .../management/internal/cli/CliUtilDUnitTest.java | 12 +- .../management/internal/cli/NetstatDUnitTest.java | 149 +- .../AlterAsyncEventQueueCommandDUnitTest.java | 6 +- .../cli/commands/AlterCompressorDUnitTest.java | 14 +- .../cli/commands/AlterDiskStoreDUnitTest.java | 4 +- .../cli/commands/ConcurrentDeployDUnitTest.java | 3 +- .../ConfigurePDXCommandIntegrationTest.java | 10 +- .../cli/commands/ConfigurePDXCommandTest.java | 29 +- .../CreateAsyncEventQueueCommandDUnitTest.java | 35 +- .../commands/CreateAsyncEventQueueCommandTest.java | 74 +- .../CreateDefinedIndexesCommandDUnitTest.java | 155 +- .../commands/CreateDefinedIndexesCommandTest.java | 60 +- .../cli/commands/CreateIndexCommandDUnitTest.java | 2 +- .../cli/commands/CreateIndexCommandTest.java | 8 +- .../CreateJndiBindingCommandDUnitTest.java | 2 +- .../cli/commands/CreateJndiBindingCommandTest.java | 6 +- .../cli/commands/CreateRegionCommandDUnitTest.java | 35 +- .../CreateRegionCommandIntegrationTest.java | 9 + .../commands/DeployCommandRedeployDUnitTest.java | 2 +- .../cli/commands/DescribeRegionDUnitTest.java | 2 +- .../DestroyAsyncEventQueueCommandDUnitTest.java | 16 +- .../commands/DestroyIndexCommandsDUnitTest.java | 4 +- .../DestroyJndiBindingCommandDUnitTest.java | 2 +- .../commands/DestroyJndiBindingCommandTest.java | 2 +- .../commands/DestroyRegionCommandDUnitTest.java | 10 +- .../cli/commands/DiskStoreCommandsDUnitTest.java | 14 +- .../commands/ExecuteFunctionCommandDUnitTest.java | 333 + .../ExecuteFunctionCommandSecurityTest.java | 6 +- .../cli/commands/ExecuteFunctionCommandTest.java | 15 +- .../cli/commands/ExportConfigCommandTest.java | 2 +- .../cli/commands/FunctionCommandsDUnitTest.java | 14 +- .../IndexCommandsShareConfigurationDUnitTest.java | 2 +- .../ListAsyncEventQueuesCommandDUnitTest.java | 11 +- .../cli/commands/ListAsyncEventQueuesTest.java | 264 + .../cli/commands/LocateEntryDUnitTest.java | 6 +- .../cli/commands/QueryCommandIntegrationTest.java | 23 +- .../cli/commands/RemoveCommandDUnitTest.java | 4 +- .../commands/ShowMissingDiskStoresDUnitTest.java | 4 +- .../CreateDefinedIndexesFunctionTest.java | 85 +- .../functions/DestroyJndiBindingFunctionTest.java | 2 +- .../cli/functions/ListJndiBindingFunctionTest.java | 4 +- .../internal/cli/help/HelperIntegrationTest.java | 10 +- .../internal/cli/result/model/ResultModelTest.java | 168 + .../cli/result/model/TabularResultModelTest.java | 57 + .../internal/cli/shell/GfshHistoryJUnitTest.java | 2 - .../ClusterConfigImportDUnitTest.java | 2 +- .../ClusterConfigLocatorRestartDUnitTest.java | 42 +- .../ImportClusterConfigDistributedTest.java | 4 +- .../ImportOldClusterConfigDUnitTest.java | 2 +- .../apache/geode/pdx/PdxSerializableJUnitTest.java | 4 - .../geode/pdx/internal/PdxInstanceImplTest.java | 402 +- .../apache/geode/security/ClientAuthDUnitTest.java | 61 +- ...tAuthorizationLegacyConfigurationDUnitTest.java | 14 +- ...aAuthorizationUsingLegacySecurityDUnitTest.java | 23 +- ...onUsingLegacySecurityWithFailoverDUnitTest.java | 21 +- .../QuerySecurityDistinctQueryDistributedTest.java | 99 + .../apache/geode/security/query/data/PdxTrade.java | 61 + .../apache/geode/test/dunit/AsyncInvocation.java | 61 +- .../geode/test/dunit/DistributedTestUtils.java | 32 +- .../java/org/apache/geode/test/dunit/Host.java | 3 +- .../geode/test/dunit/SerializableConsumerIF.java} | 15 +- .../dunit/cache/internal/JUnit4CacheTestCase.java | 5 +- .../geode/test/dunit/rules/ClusterStartupRule.java | 137 +- .../apache/geode/test/dunit/rules/MemberVM.java | 96 +- ...tartupRuleCanSpecifyOlderVersionsDUnitTest.java | 8 +- .../tests/MemberStarterRuleAwaitDUnitTest.java | 141 + .../MemberStarterRuleAwaitIntegrationTest.java | 112 + .../tests/MemberStarterRuleIntegrationTest.java | 77 + .../dunit/rules/tests/MemberStarterRuleTest.java | 9 + .../assertions/AbstractResultModelAssert.java} | 35 +- .../test/junit/assertions/CommandResultAssert.java | 75 +- .../junit/assertions/DataResultModelAssert.java} | 27 +- .../junit/assertions/InfoResultModelAssert.java} | 35 +- .../junit/assertions/TabularResultModelAssert.java | 55 + .../geode/test/junit/rules/GfshCommandRule.java | 37 +- .../geode/test/junit/rules/GfshParserRule.java | 2 +- .../geode/test/junit/rules/LocatorStarterRule.java | 7 +- .../geode/test/junit/rules/MemberStarterRule.java | 167 +- .../geode/test/junit/rules/ServerStarterRule.java | 4 +- .../apache/geode/test/junit/rules/VMProvider.java | 30 +- .../org.springframework.shell.core.CommandMarker | 2 +- .../apache/geode/codeAnalysis/excludedClasses.txt | 1 + .../codeAnalysis/sanctionedDataSerializables.txt | 10 +- geode-cq/build.gradle | 3 +- .../cache/query/internal/cq/CqServiceImpl.java | 13 +- .../cache/query/dunit/QueryMonitorDUnitTest.java | 8 +- .../query/internal/cq/CqServiceImplJUnitTest.java | 63 + .../commands/DescribeClientCommandDUnitTest.java | 5 +- geode-docs/basic_config/book_intro.html.md.erb | 6 +- .../config_concepts/chapter_overview.html.md.erb | 8 +- ...ributed_system_member_configuration.html.md.erb | 30 +- .../config_concepts/local_vs_remote.html.md.erb | 2 +- .../data_regions/chapter_overview.html.md.erb | 4 +- .../create_a_region_with_gfsh.html.md.erb | 55 - .../data_regions/managing_data_regions.html.md.erb | 2 +- .../new_region_existing_data.html.md.erb | 6 +- .../setting_distributed_properties.html.md.erb | 6 +- .../the_cache/intro_cache_management.html.md.erb | 8 +- .../the_cache/managing_a_client_cache.html.md.erb | 2 +- .../managing_a_peer_server_cache.html.md.erb | 4 +- .../the_cache/setting_cache_properties.html.md.erb | 2 +- .../configuring/chapter_overview.html.md.erb | 6 +- .../deploying_application_jars.html.md.erb | 14 +- .../gfsh_config_troubleshooting.html.md.erb | 11 +- .../cluster_config/gfsh_persist.html.md.erb | 31 +- .../cluster_config/using_member_groups.html.md.erb | 4 +- .../running/change_file_spec.html.md.erb | 2 +- .../running/deploy_config_files_intro.html.md.erb | 2 +- .../running/firewalls_ports.html.md.erb | 10 +- .../running/running_the_cacheserver.html.md.erb | 8 +- .../running/running_the_locator.html.md.erb | 20 +- .../running/starting_up_shutting_down.html.md.erb | 18 +- geode-docs/developing/book_intro.html.md.erb | 2 +- .../how_continuous_querying_works.html.md.erb | 3 +- .../PDX_Serialization_Features.html.md.erb | 4 +- .../use_pdx_high_level_steps.html.md.erb | 2 +- .../delta_propagation/chapter_overview.html.md.erb | 2 +- .../implementing_delta_propagation.html.md.erb | 4 +- .../when_to_use_delta_prop.html.md.erb | 2 +- .../choosing_level_of_dist.html.md.erb | 6 +- .../how_distribution_works.html.md.erb | 4 +- .../how_region_versioning_works.html.md.erb | 2 +- .../how_replication_works.html.md.erb | 4 +- .../developing/events/chapter_overview.html.md.erb | 4 +- .../configure_p2p_event_messaging.html.md.erb | 2 +- .../conflate_multisite_gateway_queue.html.md.erb | 2 +- .../conflate_server_subscription_queue.html.md.erb | 2 +- .../events/how_cache_events_work.html.md.erb | 2 +- ...ow_client_server_distribution_works.html.md.erb | 2 +- .../developing/events/how_events_work.html.md.erb | 19 +- .../how_multisite_distribution_works.html.md.erb | 4 +- ...ing_durable_client_server_messaging.html.md.erb | 2 +- .../list_of_event_handlers_and_events.html.md.erb | 6 +- .../tune_client_server_event_messaging.html.md.erb | 2 +- .../configuring_data_expiration.html.md.erb | 7 +- .../expiration/how_expiration_works.html.md.erb | 2 +- .../function_exec/function_execution.html.md.erb | 4 +- .../how_function_execution_works.html.md.erb | 23 +- .../chapter_overview.html.md.erb | 4 +- ...nfiguring_db_connections_using_JNDI.html.md.erb | 11 +- .../how_data_loaders_work.html.md.erb | 4 +- .../implementing_data_loaders.html.md.erb | 2 +- .../sync_outside_data.html.md.erb | 4 + .../chapter_overview.html.md.erb | 4 +- .../how_partitioning_works.html.md.erb | 4 +- .../rebalancing_pr_data.html.md.erb | 6 +- .../region_options/chapter_overview.html.md.erb | 4 +- .../dynamic_region_creation.html.md.erb | 2 +- .../region_options/region_types.html.md.erb | 8 +- .../storage_distribution_options.html.md.erb | 4 +- .../how_persist_overflow_work.html.md.erb | 2 +- .../transactions/JTA_transactions.html.md.erb | 145 +- .../transactions/about_transactions.html.md.erb | 157 +- .../cache_plugins_with_jta.html.md.erb | 8 +- .../cache_transaction_performance.html.md.erb | 4 +- .../transactions/cache_transactions.html.md.erb | 24 +- .../cache_transactions_by_region_type.html.md.erb | 2 +- .../transactions/chapter_overview.html.md.erb | 12 +- .../client_server_transactions.html.md.erb | 2 +- .../data_location_cache_transactions.html.md.erb | 2 +- .../how_cache_transactions_work.html.md.erb | 4 +- .../transactions/jca_adapter_example.html.md.erb | 51 - .../monitor_troubleshoot_transactions.html.md.erb | 4 +- .../run_a_cache_transaction.html.md.erb | 10 +- ..._cache_transaction_with_external_db.html.md.erb | 10 +- .../transaction_coding_examples.html.md.erb | 174 +- .../transaction_jta_gemfire_example.html.md.erb | 46 - .../transactions/transaction_semantics.html.md.erb | 52 - .../transaction_suspend_resume_example.html.md.erb | 38 - .../transactional_function_example.html.md.erb | 72 - .../transactions/transactions_overview.html.md.erb | 67 - .../working_with_transactions.html.md.erb | 52 +- .../15_minute_quickstart_gfsh.html.md.erb | 2 +- .../getting_started/geode_overview.html.md.erb | 4 +- .../getting_started/product_intro.html.md.erb | 4 +- geode-docs/images/JMX_Architecture.png | Bin 0 -> 136485 bytes geode-docs/images/transactions_jta.png | Bin 104780 -> 0 bytes geode-docs/images_svg/JMX_Architecture.svg | 3 - geode-docs/managing/book_intro.html.md.erb | 4 +- .../cache_snapshots/chapter_overview.html.md.erb | 6 +- .../exporting_a_snapshot.html.md.erb | 4 +- .../importing_a_snapshot.html.md.erb | 4 +- .../backup_restore_disk_store.html.md.erb | 6 +- .../disk_storage/chapter_overview.html.md.erb | 2 +- .../compacting_disk_stores.html.md.erb | 2 +- .../handling_missing_disk_stores.html.md.erb | 2 +- .../disk_storage/how_disk_stores_work.html.md.erb | 2 +- .../managing_disk_stores_cmds.html.md.erb | 2 +- .../disk_storage/using_disk_stores.html.md.erb | 2 +- .../managing/heap_use/heap_management.html.md.erb | 4 +- .../logging/logging_categories.html.md.erb | 10 +- .../management/jmx_manager_node.html.md.erb | 4 +- .../management/jmx_manager_operations.html.md.erb | 8 +- .../management/list_of_mbeans_full.html.md.erb | 10 +- .../management_and_monitoring.html.md.erb | 12 +- .../management_and_monitoring_features.html.md.erb | 8 +- .../management_system_overview.html.md.erb | 20 +- .../management/mbean_architecture.html.md.erb | 16 +- .../management/mbeans_jconsole.html.md.erb | 6 +- .../managing/management/mm_overview.html.md.erb | 18 +- .../notification_federation_and_alerts.html.md.erb | 6 +- .../management/programming_example.html.md.erb | 237 - geode-docs/managing/member-reconnect.html.md.erb | 16 +- ...ommunication_runtime_considerations.html.md.erb | 4 +- ...tion_testing_multicast_speed_limits.html.md.erb | 2 +- ...nce_controls_controlling_socket_use.html.md.erb | 2 +- ...ce_controls_managing_slow_receivers.html.md.erb | 4 +- .../monitor_tune/slow_receivers.html.md.erb | 2 +- .../slow_receivers_managing.html.md.erb | 18 +- ...t_communication_have_enough_sockets.html.md.erb | 14 +- ...ication_setting_socket_buffer_sizes.html.md.erb | 2 +- .../monitor_tune/sockets_and_gateways.html.md.erb | 2 +- .../system_member_performance.html.md.erb | 6 +- ...formance_connection_thread_settings.html.md.erb | 2 +- ...rformance_distributed_system_member.html.md.erb | 4 +- .../chapter_overview.html.md.erb | 4 +- .../failure_detection.html.md.erb | 2 +- .../handling_network_partitioning.html.md.erb | 6 +- ...twork_partitioning_management_works.html.md.erb | 16 +- ...dinators_lead_members_and_weighting.html.md.erb | 14 +- .../network_partitioning_scenarios.html.md.erb | 6 +- .../security/authentication_overview.html.md.erb | 6 +- .../security/authorization_overview.html.md.erb | 4 +- .../managing/security/chapter_overview.html.md.erb | 6 +- .../implementing_authentication.html.md.erb | 4 +- .../implementing_authorization.html.md.erb | 4 +- .../security/implementing_security.html.md.erb | 4 +- .../managing/security/implementing_ssl.html.md.erb | 8 +- .../managing/security/security_intro.html.md.erb | 38 - .../managing/security/ssl_overview.html.md.erb | 6 +- .../statistics/chapter_overview.html.md.erb | 6 +- .../statistics/how_statistics_work.html.md.erb | 9 +- .../statistics/setting_up_statistics.html.md.erb | 195 +- .../troubleshooting/chapter_overview.html.md.erb | 2 +- .../diagnosing_system_probs.html.md.erb | 26 +- ...revent_and_recover_disk_full_errors.html.md.erb | 4 +- ...producing_troubleshooting_artifacts.html.md.erb | 4 +- ...overing_conflicting_data_exceptions.html.md.erb | 6 +- .../recovering_from_app_crashes.html.md.erb | 2 +- .../recovering_from_cs_crashes.html.md.erb | 6 +- .../recovering_from_machine_crashes.html.md.erb | 6 +- .../recovering_from_network_outages.html.md.erb | 18 +- .../system_failure_and_recovery.html.md.erb | 8 +- geode-docs/reference/book_intro.html.md.erb | 2 +- geode-docs/reference/statistics_list.html.md.erb | 6 +- geode-docs/reference/topics/cache_xml.html.md.erb | 44 +- .../reference/topics/client-cache.html.md.erb | 50 +- .../topics/gemfire_properties.html.md.erb | 52 +- geode-docs/reference/topics/glossary.html.md.erb | 48 +- .../handling_exceptions_and_failures.html.md.erb | 2 +- .../memory_requirements_for_cache_data.html.md.erb | 6 +- geode-docs/rest_apps/get_servers.html.md.erb | 2 +- geode-docs/rest_apps/rest_admin.html.md.erb | 2 +- geode-docs/rest_apps/setup_config.html.md.erb | 2 +- .../tools_modules/gfsh/about_gfsh.html.md.erb | 2 +- .../gfsh/command-pages/alter.html.md.erb | 22 +- .../gfsh/command-pages/change.html.md.erb | 4 +- .../gfsh/command-pages/create.html.md.erb | 12 +- .../gfsh/command-pages/describe.html.md.erb | 42 + .../gfsh/command-pages/export.html.md.erb | 4 +- .../gfsh/command-pages/import.html.md.erb | 2 +- .../gfsh/command-pages/list.html.md.erb | 4 +- .../gfsh/command-pages/remove.html.md.erb | 30 +- .../gfsh/command-pages/revoke.html.md.erb | 2 +- .../gfsh/command-pages/show.html.md.erb | 12 +- .../gfsh/command-pages/start.html.md.erb | 14 +- .../gfsh/getting_started_gfsh.html.md.erb | 6 +- .../gfsh/gfsh_command_index.html.md.erb | 2 +- .../gfsh/quick_ref_commands_by_area.html.md.erb | 10 +- .../tools_modules/gfsh/tour_of_gfsh.html.md.erb | 10 +- .../weblogic_changing_gf_default_cfg.html.md.erb | 2 +- .../tools_modules/pulse/pulse-embedded.html.md.erb | 6 +- .../tools_modules/pulse/pulse-hosted.html.md.erb | 4 +- .../tools_modules/pulse/pulse-views.html.md.erb | 10 +- .../topologies_and_comm/book_intro.html.md.erb | 4 +- ...lient_server_example_configurations.html.md.erb | 6 +- .../chapter_overview.html.md.erb | 4 +- .../setting_up_a_multisite_system.html.md.erb | 4 +- .../p2p_configuration/chapter_overview.html.md.erb | 4 +- .../setting_up_a_p2p_system.html.md.erb | 2 +- .../topology_concepts/chapter_overview.html.md.erb | 2 +- .../how_communication_works.html.md.erb | 10 +- .../how_member_discovery_works.html.md.erb | 12 +- .../how_multisite_systems_work.html.md.erb | 4 +- .../member_communication.html.md.erb | 2 +- .../multisite_overview.html.md.erb | 6 +- .../topology_concepts/topology_types.html.md.erb | 4 +- .../test/dunit/standalone/VersionManager.java | 0 .../geode/test/junit/rules/gfsh/GfshRule.java | 10 +- .../geode/test/junit/rules/gfsh/GfshScript.java | 1 + .../dunit/standalone/VersionManagerJUnitTest.java | 0 .../cache/lucene/internal/LuceneServiceImpl.java | 2 +- .../lucene/LuceneQueriesReindexDUnitTest.java | 145 +- ...ava => LuceneIndexCommandsIntegrationTest.java} | 266 +- ...CommandsWithReindexAllowedIntegrationTest.java} | 151 +- .../lucene/test/LuceneFunctionSecurityTest.java | 2 +- geode-old-versions/build.gradle | 9 +- geode-protobuf/build.gradle | 3 +- .../protobuf/v1/utilities/ProtobufUtilities.java | 4 +- .../v1/acceptance/CacheMaxConnectionJUnitTest.java | 91 +- geode-pulse/build.gradle | 17 +- .../tools/pulse/internal/PulseAppListener.java | 8 +- .../tools/pulse/internal/data/JMXDataUpdater.java | 26 +- .../tools/pulse/internal/data/Repository.java | 9 + geode-pulse/src/main/resources/gemfire.properties | 46 - geode-pulse/src/main/resources/sqlfire.properties | 47 - .../tools/pulse/internal/PulseAppListenerTest.java | 14 +- .../geode/tools/pulse/tests/rules/ServerRule.java | 2 +- geode-rebalancer/build.gradle | 6 +- geode-wan/build.gradle | 3 +- .../wan/GatewaySenderEventRemoteDispatcher.java | 3 +- ...atewaySenderEventRemoteDispatcherJUnitTest.java | 14 + .../geode/internal/cache/wan/WANTestBase.java | 41 +- .../cache/wan/disttx/DistTXWANDUnitTest.java | 4 +- .../cache/wan/misc/WANConfigurationJUnitTest.java | 15 +- .../SerialGatewaySenderOperationsDUnitTest.java | 34 + .../DestroyGatewaySenderCommandDUnitTest.java | 8 +- .../cli/commands/CreateRegionCommandDUnitTest.java | 104 + .../cli/commands/DescribeRegionDUnitTest.java | 4 +- ...rConfigurationIndexWithFromClauseDUnitTest.java | 50 +- geode-web-api/build.gradle | 6 +- geode-web/build.gradle | 11 +- ...xecuteFunctionCommandWithSecurityDUnitTest.java | 2 +- gradle.properties | 8 +- gradle/ide.gradle | 2 - gradle/java.gradle | 22 +- gradle/rat.gradle | 1 + gradle/spotless.gradle | 11 +- gradle/test.gradle | 10 +- gradle/wrapper/gradle-wrapper.jar | Bin 53639 -> 54413 bytes gradle/wrapper/gradle-wrapper.properties | 4 +- gradlew | 72 +- gradlew.bat | 12 +- settings.gradle | 5 + 661 files changed, 54354 insertions(+), 6709 deletions(-) delete mode 100644 ci/docker/docker.list delete mode 100644 ci/pipelines/geode-build/test-stubs/distributed.yml create mode 100644 ci/pipelines/pull-request/base.yml copy ci/pipelines/{geode-build/deploy_pipeline.sh => pull-request/deploy_pr_pipeline.sh} (80%) create mode 100644 ci/pipelines/pull-request/pr-template.yml create mode 100644 geode-assembly/src/test/java/org/apache/geode/rest/internal/web/RestRegionAPIDUnitTest.java rename geode-assembly/src/test/java/org/apache/geode/{rest/internal/web/GeodeRestClient.java => test/junit/rules/GeodeDevRestClient.java} (60%) rename geode-assembly/src/test/java/org/apache/geode/test/junit/rules/{HttpClientRule.java => GeodeHttpClientRule.java} (86%) create mode 100644 geode-assembly/src/test/java/org/apache/geode/test/junit/rules/HttpResponseAssert.java create mode 100644 geode-assembly/src/test/resources/sampleJson.json create mode 100644 geode-core/src/main/java/org/apache/geode/cache/client/internal/ConnectionConnector.java rename geode-core/src/main/java/org/apache/geode/internal/cache/backup/{AbortBackupOperation.java => AbortBackupStep.java} (90%) create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/backup/BackupConfigFactory.java delete mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/backup/BackupDataStoreHelper.java create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/backup/BackupLockService.java rename geode-core/src/main/java/org/apache/geode/internal/cache/backup/{FlushToDiskOperation.java => BackupStep.java} (59%) delete mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/backup/BackupUtil.java copy geode-core/src/main/java/org/apache/geode/internal/cache/backup/{FinishBackupOperation.java => FinishBackupStep.java} (90%) rename geode-core/src/main/java/org/apache/geode/internal/cache/backup/{FinishBackupOperation.java => FlushToDiskStep.java} (66%) rename geode-core/src/main/java/org/apache/geode/internal/cache/backup/{PrepareBackupOperation.java => PrepareBackupStep.java} (95%) delete mode 100644 geode-core/src/main/java/org/apache/geode/management/internal/cli/domain/IndexInfo.java create mode 100644 geode-core/src/test/java/org/apache/geode/cache/ConcurrentRegionOperationIntegrationTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/cache/client/internal/ConnectionConnectorTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/cache/client/internal/ConnectionFactoryJUnitTest.java copy geode-wan/src/test/java/org/apache/geode/internal/cache/wan/GatewaySenderEventRemoteDispatcherJUnitTest.java => geode-core/src/test/java/org/apache/geode/cache/query/internal/CompiledIteratorDefJUnitTest.java (52%) create mode 100644 geode-core/src/test/java/org/apache/geode/internal/admin/remote/RemoteGfManagerAgentTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/AbstractRegionMapTxApplyDestroyTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/OplogTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/PartitionedRegionDataStoreTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/PartitionedRegionDestroyJUnitTest.java create mode 100755 geode-core/src/test/java/org/apache/geode/internal/cache/TxCommitMessageTest.java rename geode-core/src/test/java/org/apache/geode/internal/cache/backup/{AbortBackupOperationTest.java => AbortBackupStepTest.java} (79%) create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/backup/BackupOperationTest.java rename geode-core/src/test/java/org/apache/geode/internal/cache/backup/{FinishBackupOperationTest.java => FinishBackupStepTest.java} (86%) rename geode-core/src/test/java/org/apache/geode/internal/cache/backup/{FlushToDiskOperationTest.java => FlushToDiskStepTest.java} (91%) rename geode-core/src/test/java/org/apache/geode/internal/cache/backup/{PrepareBackupOperationTest.java => PrepareBackupStepTest.java} (84%) create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/partitioned/FetchKeysMessageTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/partitioned/ManageBackupBucketReplyMessageTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/partitioned/RemotePutMessageJUnitTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/internal/tcp/TCPConduitDUnitTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/management/FederatingManagerIntegrationTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/management/JMXMBeanReconnectDUnitTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/BackupStatusImplTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/JMXMBeanFederationDUnitTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/MBeanFederationErrorPathDUnitTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/beans/ManagementAdapterTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/ExecuteFunctionCommandDUnitTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/ListAsyncEventQueuesTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/cli/result/model/ResultModelTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/security/query/QuerySecurityDistinctQueryDistributedTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/security/query/data/PdxTrade.java copy geode-core/src/{main/java/org/apache/geode/internal/cache/backup/BackupFilter.java => test/java/org/apache/geode/test/dunit/SerializableConsumerIF.java} (73%) create mode 100644 geode-core/src/test/java/org/apache/geode/test/dunit/rules/tests/MemberStarterRuleAwaitDUnitTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/test/dunit/rules/tests/MemberStarterRuleAwaitIntegrationTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/test/dunit/rules/tests/MemberStarterRuleIntegrationTest.java copy geode-core/src/{main/java/org/apache/geode/internal/cache/backup/FlushToDiskResponse.java => test/java/org/apache/geode/test/junit/assertions/AbstractResultModelAssert.java} (52%) copy geode-core/src/{main/java/org/apache/geode/internal/cache/backup/BackupWriter.java => test/java/org/apache/geode/test/junit/assertions/DataResultModelAssert.java} (58%) copy geode-core/src/{main/java/org/apache/geode/internal/cache/backup/FlushToDiskResponse.java => test/java/org/apache/geode/test/junit/assertions/InfoResultModelAssert.java} (51%) create mode 100644 geode-core/src/test/java/org/apache/geode/test/junit/assertions/TabularResultModelAssert.java create mode 100644 geode-cq/src/test/java/org/apache/geode/cache/query/internal/cq/CqServiceImplJUnitTest.java delete mode 100644 geode-docs/basic_config/data_regions/create_a_region_with_gfsh.html.md.erb rename geode-docs/developing/{transactions => outside_data_sources}/configuring_db_connections_using_JNDI.html.md.erb (96%) delete mode 100644 geode-docs/developing/transactions/jca_adapter_example.html.md.erb delete mode 100644 geode-docs/developing/transactions/transaction_jta_gemfire_example.html.md.erb delete mode 100644 geode-docs/developing/transactions/transaction_semantics.html.md.erb delete mode 100644 geode-docs/developing/transactions/transaction_suspend_resume_example.html.md.erb delete mode 100644 geode-docs/developing/transactions/transactional_function_example.html.md.erb delete mode 100644 geode-docs/developing/transactions/transactions_overview.html.md.erb create mode 100644 geode-docs/images/JMX_Architecture.png delete mode 100644 geode-docs/images/transactions_jta.png delete mode 100644 geode-docs/images_svg/JMX_Architecture.svg delete mode 100644 geode-docs/managing/management/programming_example.html.md.erb delete mode 100644 geode-docs/managing/security/security_intro.html.md.erb rename {geode-old-versions => geode-junit}/src/main/java/org/apache/geode/test/dunit/standalone/VersionManager.java (100%) rename {geode-old-versions => geode-junit}/src/test/java/org/apache/geode/test/dunit/standalone/VersionManagerJUnitTest.java (100%) rename geode-lucene/src/test/java/org/apache/geode/cache/lucene/internal/cli/{LuceneIndexCommandsDUnitTest.java => LuceneIndexCommandsIntegrationTest.java} (78%) rename geode-lucene/src/test/java/org/apache/geode/cache/lucene/internal/cli/{LuceneIndexCommandsWithReindexAllowedDUnitTest.java => LuceneIndexCommandsWithReindexAllowedIntegrationTest.java} (65%) delete mode 100644 geode-pulse/src/main/resources/gemfire.properties delete mode 100644 geode-pulse/src/main/resources/sqlfire.properties create mode 100644 geode-wan/src/test/java/org/apache/geode/management/internal/cli/commands/CreateRegionCommandDUnitTest.java