You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by zh...@apache.org on 2020/11/17 07:23:43 UTC
[geode] branch feature/GEODE-8444 updated (84a205b -> 86d34d8)
This is an automated email from the ASF dual-hosted git repository.
zhouxj pushed a change to branch feature/GEODE-8444
in repository https://gitbox.apache.org/repos/asf/geode.git.
discard 84a205b when P and R's rvvGC equals, still do deltaGII
discard b5c69f6 GEODE-8444: When requester's RVV equals provider's rvvGC, should do fullGII
add 8a47743 GEODE-8433: added inheritance of off-heap attribute (#5460)
add 9c31b21 GEODE-8435: restore ability to connect gfsh by serialization version (#5462)
add 084ec6a GEODE-8420: Throw SQLException when SQLException occurs in JdbcWriter (#5442)
add afb161f GEODE-8119: Threads hangs when offline disk store command is invoked (#5466)
add 666ea7d GEODE-8451 Redis PING response contains unneeded quotes (#5472)
add 0617430 GEODE-8456: bump Shiro to 1.6.0 (#5477)
add 43a783b Change all tests to use liberica instead of openjdk. (#5474)
add 6ca548f GEODE-8447: QueryResultFormatter should show dates in localized strings (#5469)
add cecf003 GEODE-8459: Redis API for Geode handles errors when member disconnects (#5481)
add 0c2a8a3 GEODE-8448: Update README based on user feedback (#5470)
add 93efb80 GEODE-7864: Fix some LGTM alerts and suppress some false positives (#5473)
add d9d1310 GEODE-8458: Use build metadata properties as task inputs (#5480)
add 20a35ec GEODE-8463: server's log filled with SSLException: Tag mismatch! (#5482)
add 27b8e47 GEODE-8333: Change Redis adapter threading model - fixes pubsub issues (#5488)
add 304e4d58 GEODE-8455: Fix difference between create region with gw sender and a… (#5476)
add e402ed3 GEODE-8467: server fails to notify of a ForcedDisconnect and fails to tear down the cache (#5490)
add 547542e GEODE-8404: Simplify AvailablePortHelper (#5493)
add b62e033 GEODE-8475: Resolve a potential dead lock in ParallelGatewaySenderQueue (#5492)
add 1076193 GEODE-8462: Make geode server startup fail if geode redis server has a port conflict (#5483)
add 2d995fb GEODE-8478: Modified logThresholdExceededAlerts to handle exceptions
add 2a04b9b GEODE-8485: When connection is closed, its server could be null (#5499)
add 8a7b1fc GEODE-8465: secondary HARegionQueue to sync with primary queue (#5496)
add 5d4d4a3 GEODE-8393: Add sequence number to RedisString to support delta and APPEND (#5504)
add 6b79dab GEODE-8339: fix Redis Rename hang (#5501)
add a8844ca GEODE-8486: record TransactionDataRebalancedException if tx put failed (#5500)
add 317a706 GEODE-8483: Remove JNDI lookup and check
add 5d9f60c GEODE-8481: fix release scripts (#5497)
add b2f643a GEODE-8488: Don't set success status if queue is destroyed. (#5506)
add 3f4d97e GEODE-8482: Concurrent access to ArrayList should be synchronized (#5503)
add bb046ec GEODE-8490: Docker containers are not properly cleaned up after native Redis acceptance tests (#5508)
add 7302f09 GEODE-8487: Document Redis_API HA model, requirements, guarantees (#5505)
add 9d139b5 add 1.13.0 to old versions and set as Benchmarks baseline on develop (#5502)
add 1d629e1 GEODE-8066: Pull up transitive dependency to clean up javax.activation and mail licenses. (#5291)
add c48c0c3 GEODE-8473: Hang in ReplyProcessor21 when forced-disconnect does not establish a cancellation cause (#5491)
add f2ccbc8 GEODE-8492: fix redis 'clients' statistic (#5510)
add f4498c3 GEODE-8499: Redis subscriptions leak if they are not explicitly unsubscribed (#5518)
add b26d04d GEODE-8493: Redis idle clients can cause server stuck thread warning (#5511)
add e18aa5a GEODE-8500: change Redis QUIT to stop command processing (#5521)
add 794526a GEODE-8503: Limit netty threads in PubSubDUnitTest (#5522)
add ded2dda GEODE-8505: Upgrade netty from 4.1.48 to 4.1.52 (#5523)
add a11b9c0 GEODE-8506: BufferPool returns byte buffers that may be much larger t… (#5525)
add 9816308 GEODE-8489: "Select *" query by DistributedSystemMBean should not hon… (#5507)
add ee99503 Redis StartUp tests use ephemeral port for Geode server (#5528)
add 40a2764 GEODE-8516: Add Redis tests for multiple subscriptions for the same client (#5529)
add 76edadc Revert "GEODE-8463: server's log filled with SSLException: Tag mismatch! (#5482)" (#5531)
add 5468d65 Revert "GEODE-8516: Add Redis tests for multiple subscriptions for the same client (#5529)" (#5534)
add 0c86d4f GEODE-8504: add redis info command (#5526)
add 86c32e4 GEODE-8496: bump dependency versions (#5527)
add e65a2b2 GEODE-8469: fix windows test failure (#5542)
add 16a3d1e GEODE-8516: Add Redis tests for multiple subscriptions for the same client (#5535)
add 1904a71 GEODE-8523: Session state document update (#5546)
add a355764 GEODE-8496: Bump mockito from 3.3.3 to 3.5.11 (#5540)
add c49389e GEODE-8496: fix rest management test after dependency bump (#5547)
add fe51439 GEODE-8520: GCStatsMonitor should sum up all the GC stats to get the … (#5536)
add 11488f5 Bump junit from 4.12 to 4.13 (#5538)
add 06d7bc8 GEODE-8515: change Redis PING to notify subscriber (#5544)
add 22f2c52 GEODE-8498: make AbstractSubscription write to channel synchronously (#5550)
add e4918fe GEODE-8541: move test to integrationTest folder (#5555)
add 74d446a GEODE-8496: skip windows test that broke after bumping junit from 4.12 to 4.13 (#5554)
add ff58476 Bump archunit from 0.12.0 to 0.14.1 (#5537)
add 3df057c GEODE-8522: Switching exception log back to debug
add 56f5508 GEODE-8469: Bump assertj from 3.15.0 to 3.17.2 (#5539)
add 502facc GEODE-8496: un-upgrade archunit to avoid OOM on JDK8 (#5565)
add 169ca6a GEODE-8491: Do not store dropped events in stopped primary gateway se… (#5509)
add d4b9ecd GEODE-8513: Remove (de)serialization of local sessions. (#5532)
add b439d33 GEODE-8542: java.lang.IllegalStateException: tcp message exceeded max… (#5562)
add 3733447 GEODE-8544: Making VM class start versioned VM (#5559)
add 14524c7 added code of conduct to project (#5430)
add bc28eb2 GEODE-8561: Add support to PR pipeline for running additional Windows PR checks if the 'windows' label is added to the PR (#5572)
add c78dddd GEODE-8549: Remove use of junit EnvironmentVariables rule from geode-redis (#5568)
add 26cb822 GEODE-8540: Create new DistributedBlackboard Rule (#5557)
add b0a2d32 GEODE-8561: Add support to PR pipeline for running Windows checks (#5574)
add 443cd2f GEODE-8561: Add support to PR pipeline for running Windows checks (#5575)
add 393c9a2 GEODE-8561: Add support to PR pipeline for running Windows checks (#5576)
add 90acb8f GEODE-8561: update timeouts, retries, and variables to match develop pipeline (#5578)
add 8ee4841 GEODE-8539: Update FixedPartitioningDUnitTest with Rules (#5558)
add 581b68d GEODE-8252: Rename DistributedErrorCollector (#5563)
add 07e8f64 GEODE-8252: Fix FixedPartitioningDUnitTest (#5580)
add 2a993a5 GEODE-8550: Create CloseableReference (#5570)
add 64e5682 GEODE-8252: Rename DistributedCounters (#5564)
add a4c6c24 GEODE-8555: SimpleDiskRegionJunitTest fails on Windows (#5569)
add 66bcce8 GEODE-8564: Updated CopyOnWriteHashSet's iterator implementation to (#5583)
add 2485e57 GEODE-8558: query input by users should trim newlines and comments. (#5571)
add a099fa3 GEODE-8533: Docs - compaction-threshold mechanism description are wrong (#5549)
add ce77067 GEODE-8533: Docs - compaction-threshold description refinements (#5585)
add 6d58009 GEODE-8495: Make tests honor default disk dir property (#5586)
add ae0d6bc GEODE-8550: Rename DistributedCloseableReference (#5579)
add eccd4f0 GEODE-8536: Allow limited retries when creating Lucene IndexWriter (#5553)
add c91e915 Revert "GEODE-8536: Allow limited retries when creating Lucene IndexWriter (#5553)" (#5588)
add fb3bcac GEODE-8566: Redis native tests should not also stand up a Geode server (#5584)
add b8147bb GEODE-8577: PubSubNativeRedisAcceptanceTest is flaky (#5593)
add 9bc288a GEODE-8421: replace clean with destroy region (#5445)
add f8dae61 GEODE-8577: Fix flaky PubSubNativeRedisAcceptanceTest (#5597)
add 0c41271 GEODE-8538: Create test to validate ordering of redis pipeline commands (#5552)
add e4c077a GEODE-8576: fix doc on "security-peer-auth-init" (#5592)
add 8f4566c GEODE-8525: Ensure that all pubsub related commands run on the correct EventLoopGroup (#5591)
add dbd1803 GEODE-8572: Make LogExporter not read dirs (#5595)
add 74a850b GEODE-8172_2: refactoring of failing testcase (#5599)
add 6c8bc5e GEODE-8216: modify test (#5335)
add 73f6783 GEODE-8574: ClusterManagementService should not throw ClassCastExcept… (#5596)
add bcdf3ca GEODE-8582: Redis SCAN returns internal server error (#5603)
add f4d44d6 GEODE-8584: Message transmission fails with IllegalStateException in socket i/o code (#5605)
add faef811 GEODE-8579: Stop waiting locator-wait-time if all locators are available
add c9ba7fa GEODE-8587: Redis glob pattern does not match carriage return, line feed, and tab (#5608)
add f3fb150 GEODE-8581: "Define index" and "create defined index" should work if … (#5602)
add 6476002 GEODE-8590: Cleanup dependencies in the session state modules (#5610)
add 30782f1 GEODE-8586: Redis SPOP with count on empty set returns NIL instead of empty array (#5609)
add 0cc4fa0 GEODE-8559: Compute interest routing info after transaction committed. (#5581)
add e85a1bd GEODE-8517: GatewaySenderEventImpl's 2 new attributes were introduced… (#5530)
add 1cab75d GEODE-8600: Fix for faulty statistics QueueSize (#5616)
add b167094 GEODE-8556: Remove outdated msg from docs (#5614)
add 2001240 GEODE-8606: Rename DistributedReference (#5626)
add 4d5ed9d GEODE-8608: StateFlush could hang when the target member is shutdown (#5624)
add 55a6cea GEODE-8602: Wait for view to change in locator test
add d2c1d67 GEODE-8536: Allow limited retries when creating Lucene IndexWriter (#5589)
add 4c48202 GEODE-8612: Remove unused Redis constants (#5628)
add f0ee8e2 GEODE-8621: Redis SPOP can return incorrect string type (#5634)
add f5dabd2 GEODE-8585: Redis SCAN, HSCAN, and SSCAN do not detect illegal parameters (#5627)
add f46d7ae GEODE-8610: Add parameter checking to unsupported Redis commands (#5635)
add c362f77 GEODE-8497: added getTotalQueueSizeBytesInUse (#5514)
add 02ffbce GEODE-7864: Fix potential resource leak LGTM warnings (#5582)
add 505eb3a GEODE-8620: Do not include non-created buckets in redundancy calculation (#5642)
add 7a0fd2e GEODE-8627: Redis not unsubscribing and punsubscribing correctly when no channel/pattern provided (#5639)
add b76eba7 GEODE-8629: Redis TTL should round up the returned value (#5640)
add d436e8d GEODE-8622: Redis INCRBYFLOAT error messages are consistent with native Redis (#5636)
add 047f9a0 GEODE-8632: Redis Unknown command error message has should have trailing space (#5646)
add eb91e95 GEODE-8607: Adding some test API to get oldest tombstone (#5623)
add d01195a GEODE-8595: Create new RandomRule for tests (#5612)
add 4624211 GEODE-8639: Increase PR resource-get attempts to match develop (#5651)
add 99f51c3 GEODE-8633: Add concurrency tests for Redis HDEL (#5647)
add 08e4e9a GEODE-8636: Remove hard-coded value from String in NettyRedisServer (#5621)
add 54527eb GEODE-8496: top off dependency updates for 1.14 (#5652)
add 74a0d75 GEODE-8594: Create new DistributedMap for dunit (#5611)
add e3d157d GEODE-8638: Match the way Redis 5.x handles HELLO (#5650)
add fef7a76 GEODE-8597: Improvements to JMH integration (#5606)
add a048a72 GEODE-8611: Fixes default KeyManagerFactory instantiation. (#5629)
add 293dd68 Revert "GEODE-8536: Allow limited retries when creating Lucene IndexWriter (#5589)" (#5656)
add 3bb3b19 GEODE-8648: Use SecureRandom in RandomRule (#5657)
add 872718e GEODE-8536: Allow limited retries when creating Lucene IndexWriter (#5659)
add 0fdfc1a GEODE-8067: Improve manifest module resolution (#5660)
add 8bfe58f GEODE-8603: Potentially expand classes identified for CI stressing to include subclasses (#5601)
add e3efe55 GEODE-8654: Remove debug logging from AbstractPubSubIntegrationTest (#5668)
add bece588 GEODE-8630: Add Redis UNLINK command as synonym to DEL (#5641)
add 3187a61 GEODE-7696: Add comment to GMSHealthMonitor explaining when IllegalStateException may be thrown (#5607)
add 77ff68c Revert "GEODE-8603: Potentially expand classes identified for CI stressing to include subclasses (#5601)" (#5671)
add 4ceabc8 GEODE-8657: Increase acceptance test timeout (#5673)
add d9c859b GEODE-8650: Support multiple instances of DistributedReference (#5664)
add 38ed638 GEODE-8071: Prevent Test Flakiness (#5676)
add 4039a36 GEODE-8603: Potentially expand classes identified for CI stressing to include subclasses (#5601) (#5674)
add 5312335 GEODE-8660: Remove mavenLocal from build.gradle. (#5675)
add e65f579 GEODE-8637: Give each test worker a unique working dir (#5649)
add c6a0b31 GEODE-8651: MsgReader's readHeader and readMessage should be synchron… (#5665)
add 84ac086 GEODE-8609: Create a dunit suspect file per VM (#5625)
add 828e84d [GEODE-8661] Use version provided by *-builder-image-family. (#5681)
add 92694c8 Fix problem with pr pipeline. Used wrong variable in template. (#5683)
add aff7a55 GEODE-8647: Support multiple instances of DistributedMap (#5667)
add 30bb6b1 GEODE-8275: exclude cancelled jobs when looking for last completed job (#5615)
add 4312fd1 GEODE-8662: add integration tests for strlen (#5654)
add 5953aad Update exmples CI to use the builder_image (#5685)
add a9d346f GEODE-8521: Cleanup CoreLoggingExecutors constructors (#5687)
add 08e9e96 GEODE-8652: NioSslEngine.close() Bypasses Locks (#5666)
add a00f18d GEODE-8659: Consolidating locator-wait-time-tests
add 4024509 GEODE-8570: deprecate cluster-configuration-dir property (#5684)
add 7e095b8 GEODE-8668: Implement Redis SELECT command (#5682)
add 25ff3d7 [GEODE-8661] Fix mass-test-run pipeline. (#5697)
add 7f19d9c GEODE-8675: Log at query start when <trace> is enabled (#5690)
add 63c6eb1 Geode-8677: Confirm binary data storage (#5696)
add e695938 GEODE-8672: No need in token mode if concurrencyChecksEnabled (#5691)
add 39db792 GEODE-8682: Bump jetty from 9.4.32.v20200930 to 9.4.33.v20201020 (#5700)
add 7da8f9b GEODE-8681: peer-to-peer message loss due to sending connection closing with TLS enabled (#5699)
add 7367d17 Revert "GEODE-8672: No need in token mode if concurrencyChecksEnabled (#5691)" (#5702)
add 7cc14ee GEODE-8547: Added impacts to show missing disk-stores (#5567)
add 9653a0b Revert "GEODE-8652: NioSslEngine.close() Bypasses Locks (#5666)"
add af267c0 * GEODE-8652: NioSslEngine.close() Bypasses Locks (#5712)
add d1e003c GEODE-8603: fix StressNew for support branches (#5717)
add c068979 GEODE-8683: Honor maximum-time-between-pings in gateway receiver (#5701)
add e1f5518 GEODE-8663: update Redis Info command To include additional statistics (#5678)
add 54ee0e4 GEODE-8691: Add test to cover native Redis hits and misses statistics (#5721)
add 70b1ee8 GEODE-8686: Prevent potential deadlock during GII and tombstone GC (#5707)
add ba8f901 GEODE-8684: Setting a session's maxInactiveInterval does not work when the commit valve is disabled (#5724)
add c99087a GEODE-8692: ArrayIndexOutOfBoundsException may be thrown in RegionAdvisor.processProfilesQueuedDuringInitialization (#5722)
add f6605e0 GEODE-8664: Nest errors in DistributionImpl.start (#5725)
add f23e01a Revert "GEODE-8664: Nest errors in DistributionImpl.start (#5725)" (#5742)
add 8f8cc7b GEODE-8704: many CI failures in Jetty9CachingClientServerTest (#5745)
add 7a55cba GEODE-8672: No need in token mode if concurrencyChecksEnabled (#5746)
add 99e7a13 GEODE-8670: ReconnectDUnitTest is hiding a NullPointerException (#5744)
add 403e19c GEODE-8697: Propagate ForcedDisconnectException to the user application (#5739)
add 1bf18b2 GEODE-8706: Redis INFO command 'Keyspace' section should not be present if no keys in database (#5753)
add 399b875 GEODE-8706: getConnection should get readLock to sync with destroyCon… (#5750)
add 86d34d8 GEODE-8444: When requester's RVV equals provider's rvvGC, should do fullGII
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 (84a205b)
\
N -- N -- N refs/heads/feature/GEODE-8444 (86d34d8)
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.
No new revisions were added by this update.
Summary of changes:
CODE_OF_CONDUCT.md | 7 +
README.md | 4 +-
.../src/test/resources/expected-pom.xml | 194 +-
build.gradle | 35 +-
buildSrc/build.gradle | 4 +-
.../gradle/plugins/DependencyConstraints.groovy | 101 +-
.../gradle/RunInSubdirectoryTestFramework.java | 102 +
ci/docker/Dockerfile | 4 +-
ci/images/alpine-tools/Dockerfile | 2 +-
.../scripts/cache_dependencies.sh | 2 +-
ci/images/google-windows-geode-builder/packer.json | 8 +-
ci/images/test-container/Dockerfile | 2 +-
ci/pipelines/examples/jinja.template.yml | 2 +
ci/pipelines/geode-build/jinja.template.yml | 17 +-
ci/pipelines/images/jinja.template.yml | 2 +-
ci/pipelines/mass-test-run/jinja.template.yml | 6 +-
ci/pipelines/pull-request/jinja.template.yml | 66 +-
ci/pipelines/shared/jinja.variables.yml | 10 +-
ci/scripts/create_instance.sh | 9 +-
ci/scripts/execute_build.sh | 4 +-
ci/scripts/execute_build_examples.sh | 4 +-
ci/scripts/execute_publish.sh | 4 +-
ci/scripts/execute_tests.sh | 8 +-
ci/scripts/repeat-new-tests.sh | 54 +-
ci/scripts/rsync_code_down.sh | 4 +-
dev-tools/dependencies/README.md | 46 +
dev-tools/dependencies/bump.sh | 59 +
dev-tools/docker/base/Dockerfile | 2 +-
dev-tools/release/commit_rc.sh | 2 +-
dev-tools/release/deploy_rc_pipeline.sh | 65 +-
dev-tools/release/end_of_support.sh | 31 +-
dev-tools/release/license_review.sh | 14 +-
dev-tools/release/prepare_rc.sh | 20 +-
dev-tools/release/promote_rc.sh | 33 +-
dev-tools/release/set_versions.sh | 12 +-
docker/Dockerfile | 4 +-
docker/README.md | 2 +-
.../geode-modules-session-internal/build.gradle | 22 +-
.../session/filter/SessionCachingFilter.java | 4 +-
.../modules/session/installer/JarClassLoader.java | 15 +-
extensions/geode-modules-test/build.gradle | 41 +-
.../modules/session/AbstractSessionsTest.java | 3 +-
.../catalina/AbstractDeltaSessionManagerTest.java | 223 +-
extensions/geode-modules-tomcat7/build.gradle | 59 +-
extensions/geode-modules-tomcat8/build.gradle | 86 +-
.../src/test/resources/expected-pom.xml | 60 +
extensions/geode-modules-tomcat9/build.gradle | 48 +-
extensions/geode-modules/build.gradle | 56 +-
.../modules/session/catalina/DeltaSession.java | 4 +
.../session/catalina/DeltaSessionManager.java | 354 +--
.../src/test/resources/expected-pom.xml | 75 +
geode-assembly/Dockerfile | 4 +-
geode-assembly/build.gradle | 5 +-
.../geode/session/tests/TomcatContainer.java | 15 +-
.../apache/geode/session/tests/TomcatInstall.java | 42 +-
.../shell/StatusLocatorExitCodeAcceptanceTest.java | 7 +-
.../shell/StatusServerExitCodeAcceptanceTest.java | 5 +-
.../management/JQFilterVerificationDUnitTest.java | 22 +-
.../cli/commands/StartServerCommandDUnitTest.java | 4 +-
.../rest/ListIndexManagementDUnitTest.java | 3 +-
.../rest/RestoreRedundancyManagementDUnitTest.java | 16 +-
.../apache/geode/session/tests/CargoTestBase.java | 9 +-
.../session/tests/GenericAppServerInstall.java | 2 +-
.../tests/Jetty9CachingClientServerTest.java | 2 +
.../tests/Tomcat6CachingClientServerTest.java | 2 +-
.../session/tests/Tomcat6ClientServerTest.java | 3 +-
.../apache/geode/session/tests/Tomcat6Test.java | 3 +-
.../tests/Tomcat7CachingClientServerTest.java | 2 +-
.../session/tests/Tomcat7ClientServerTest.java | 3 +-
.../apache/geode/session/tests/Tomcat7Test.java | 3 +-
.../tests/Tomcat8CachingClientServerTest.java | 2 +-
.../session/tests/Tomcat8ClientServerTest.java | 3 +-
.../apache/geode/session/tests/Tomcat8Test.java | 3 +-
.../tests/Tomcat9CachingClientServerTest.java | 2 +-
...mcat9CachingClientServerValveDisabledTest.java} | 4 +-
.../session/tests/Tomcat9ClientServerTest.java | 3 +-
.../apache/geode/session/tests/Tomcat9Test.java | 3 +-
...aggerManagementVerificationIntegrationTest.java | 2 +-
.../DevRestSwaggerVerificationIntegrationTest.java | 2 +-
.../integrationTest/resources/assembly_content.txt | 85 +-
.../resources/dependency_classpath.txt | 79 +-
.../integrationTest/resources/expected_jars.txt | 3 -
geode-assembly/src/main/dist/LICENSE | 2 -
.../Tomcat8ClientServerRollingUpgradeTest.java | 4 +-
...omcatSessionBackwardsCompatibilityTestBase.java | 8 +-
.../source/subnavs/geode-subnav.erb | 6 +
geode-common/build.gradle | 10 +
.../internal/lang/ComputeIfAbsentBenchmark.java | 105 +
.../lang/ComputeIfAbsentBenchmarkTest.java | 58 +
.../geode/util/internal/CompletionUtils.java | 63 +
geode-connectors/build.gradle | 2 +-
.../jdbc/JdbcAsyncWriterIntegrationTest.java | 119 +-
.../connectors/jdbc/JdbcWriterIntegrationTest.java | 98 +-
.../jdbc/MySqlJdbcWriterIntegrationTest.java | 5 +
.../jdbc/PostgresJdbcWriterIntegrationTest.java | 4 +
.../cli/CreateDataSourceCommandDUnitTest.java | 2 +-
.../cli/DeregisterDriverCommandDUnitTest.java | 2 +-
.../internal/cli/ListDriversCommandDUnitTest.java | 4 +-
.../cli/RegisterDriverCommandDUnitTest.java | 2 +-
.../geode/connectors/jdbc/internal/SqlHandler.java | 15 +
.../jdbc/internal/RegionMappingTest.java | 5 -
.../connectors/jdbc/internal/SqlHandlerTest.java | 106 +-
.../jdbc/internal/SqlToPdxInstanceCreatorTest.java | 5 -
.../jdbc/internal/SqlToPdxInstanceTest.java | 31 +-
geode-core/README.md | 24 +-
geode-core/build.gradle | 58 +-
.../geode/ClusterCommunicationsDUnitTest.java | 87 +-
.../ReplicateCacheListenerDistributedTest.java | 32 +-
.../partition/PartitionRegionHelperDUnitTest.java | 6 +-
.../cache/query/dunit/PdxLocalQueryDUnitTest.java | 6 +-
.../PdxLocalQueryVersionedClassDUnitTest.java | 2 +-
.../geode/cache/query/dunit/PdxQueryDUnitTest.java | 22 +-
.../cache/query/dunit/PdxStringQueryDUnitTest.java | 4 +-
.../dunit/QueryParamsAuthorizationDUnitTest.java | 2 +-
.../query/dunit/SelectStarQueryDUnitTest.java | 8 +-
.../apache/geode/cache30/CacheXml66DUnitTest.java | 5 +-
.../apache/geode/cache30/ReconnectDUnitTest.java | 15 +-
.../apache/geode/distributed/LocatorDUnitTest.java | 4 +-
.../ClusterDistributionManagerDUnitTest.java | 36 +-
.../internal/DistributionAdvisorDUnitTest.java | 4 +-
.../cache/BucketCreationCrashRegressionTest.java | 4 +-
.../internal/cache/DeltaPropagationDUnitTest.java | 16 +-
.../geode/internal/cache/GIIDeltaDUnitTest.java | 3 +-
...RQueryWithPdxDuringRebalanceRegressionTest.java | 4 +-
.../cache/TransactionsWithGIIDistributedTest.java | 318 +++
.../fixed/FixedPartitioningDUnitTest.java | 2890 ++++++++++++--------
.../fixed/FixedPartitioningTestBase.java | 1289 ---------
.../fixed/FixedPartitioningTestBaseJUnitTest.java | 57 -
.../internal/cache/partitioned/fixed/MyDate1.java | 70 -
.../internal/cache/partitioned/fixed/MyDate2.java | 53 -
.../internal/cache/partitioned/fixed/MyDate3.java | 70 -
.../PersistentRVVRecoveryDUnitTest.java | 4 +-
.../cache/tier/sockets/PingOpDistributedTest.java | 6 +-
.../tier/sockets/RedundancyLevelTestBase.java | 2 +-
.../cache/versions/TombstoneDUnitTest.java | 373 ++-
.../tcp/ConnectionCloseSSLTLSDUnitTest.java | 238 ++
.../DistributedSystemMXBeanDistributedTest.java | 4 +-
...butedSystemMXBeanWithAlertsDistributedTest.java | 4 +-
...stemMXBeanWithNotificationsDistributedTest.java | 4 +-
.../management/JMXMBeanReconnectDUnitTest.java | 4 +-
...BeanFederationErrorHandlingDistributedTest.java | 4 +-
.../ClusterConfigStartMemberDUnitTest.java | 2 -
.../internal/security/MultiGfshDUnitTest.java | 11 +-
.../internal/util/ManagementUtilsDUnitTest.java | 11 +
.../org/apache/geode/internal/tcp}/server.keystore | Bin
.../apache/geode/cache/RegionFactoryJUnitTest.java | 49 +
.../RestrictUseOfInetAddressJUnitTest.java | 1 -
.../LocatorLauncherIntegrationTestCase.java | 2 -
.../internal/InternalLocatorIntegrationTest.java | 59 +-
.../AvailablePortHelperIntegrationTest.java | 175 +-
...eplicateWithExpirationClearIntegrationTest.java | 0
.../internal/cache/SimpleDiskRegionJUnitTest.java | 6 +-
...GatewaySenderEventProcessorIntegrationTest.java | 76 +
...LSocketHostNameVerificationIntegrationTest.java | 4 +-
.../internal/net/SSLSocketIntegrationTest.java | 57 +-
.../geode/internal/net/SSLUtilIntegrationTest.java | 72 +
.../DistributedSystemMBeanIntegrationTest.java | 148 +
.../apache/geode/codeAnalysis/excludedClasses.txt | 1 +
.../codeAnalysis/sanctionedDataSerializables.txt | 12 +-
.../geode/internal/logging/dir1/systemlog.txt | 2 +-
.../geode/internal/logging/dir2/systemlog.txt | 2 +-
.../geode/internal/ra/spi/JCALocalTransaction.java | 63 +-
.../internal/ra/spi/JCAManagedConnection.java | 57 +-
.../internal/util/ComputeIfAbsentBenchmark.java | 76 -
.../admin/jmx/internal/GenerateMBeanHTML.java | 6 +-
.../alerting/internal/ClusterAlertMessaging.java | 2 +-
.../geode/cache/client/internal/AbstractOp.java | 5 +-
.../cache/client/internal/AuthenticateUserOp.java | 5 +-
.../geode/cache/client/internal/PoolImpl.java | 10 +-
.../apache/geode/cache/client/internal/PutOp.java | 5 +-
.../cache/client/internal/QueueManagerImpl.java | 2 +-
.../internal/pooling/ConnectionManagerImpl.java | 2 +-
.../geode/cache/query/internal/DefaultQuery.java | 9 +-
.../geode/cache/query/internal/NullToken.java | 3 +
.../geode/cache/query/internal/Undefined.java | 7 +-
.../apache/geode/cache/wan/EventSequenceID.java | 5 +-
.../apache/geode/distributed/AbstractLauncher.java | 4 +-
.../geode/distributed/ConfigurationProperties.java | 7 +
.../internal/ClusterDistributionManager.java | 55 +-
.../internal/ClusterOperationExecutors.java | 55 +-
.../distributed/internal/DistributionConfig.java | 2 +-
.../distributed/internal/DistributionManager.java | 2 +
.../internal/FunctionExecutionPooledExecutor.java | 336 +--
.../distributed/internal/InternalLocator.java | 25 +-
.../distributed/internal/LocatorLoadSnapshot.java | 2 +-
.../internal/LonerDistributionManager.java | 4 +
.../internal/PooledExecutorWithDMStats.java | 214 +-
.../internal/SerialQueuedExecutorWithDMStats.java | 34 +-
.../internal/deadlock/DeadlockDetector.java | 10 +-
.../apache/geode/internal/CopyOnWriteHashSet.java | 32 +-
.../org/apache/geode/internal/DSFIDFactory.java | 5 +
.../org/apache/geode/internal/DeployedJar.java | 18 +-
.../org/apache/geode/internal/GemFireVersion.java | 5 -
.../geode/internal/InternalDataSerializer.java | 43 +-
.../ScheduledThreadPoolExecutorWithKeepAlive.java | 127 +-
.../apache/geode/internal/VersionDescription.java | 11 -
.../internal/cache/AbstractBucketRegionQueue.java | 4 +-
.../geode/internal/cache/AbstractRegionMap.java | 24 +-
.../apache/geode/internal/cache/BucketRegion.java | 43 +-
.../geode/internal/cache/BucketRegionQueue.java | 4 +-
.../apache/geode/internal/cache/DiskInitFile.java | 83 +-
.../apache/geode/internal/cache/DiskStoreImpl.java | 10 +-
.../geode/internal/cache/DiskStoreMonitor.java | 2 +-
.../geode/internal/cache/EntryEventImpl.java | 16 +-
.../org/apache/geode/internal/cache/EventID.java | 12 +-
.../apache/geode/internal/cache/ExpiryTask.java | 5 +-
.../apache/geode/internal/cache/FilterProfile.java | 65 +-
.../geode/internal/cache/FilterRoutingInfo.java | 19 +-
.../geode/internal/cache/GemFireCacheImpl.java | 83 +-
.../internal/cache/InitialImageOperation.java | 43 +-
.../geode/internal/cache/InternalCacheEvent.java | 3 +
.../apache/geode/internal/cache/LocalRegion.java | 53 +-
.../org/apache/geode/internal/cache/Oplog.java | 244 +-
.../geode/internal/cache/PRQueryProcessor.java | 2 +-
.../geode/internal/cache/PartitionedRegion.java | 41 +-
.../geode/internal/cache/RegionMapFactory.java | 9 +-
.../geode/internal/cache/StateFlushOperation.java | 11 +-
.../geode/internal/cache/TXCommitMessage.java | 13 +-
.../apache/geode/internal/cache/TXEntryState.java | 5 +
.../org/apache/geode/internal/cache/TXState.java | 43 +-
.../geode/internal/cache/TombstoneService.java | 47 +-
.../internal/cache/TxCallbackEventFactoryImpl.java | 5 +-
.../internal/cache/ValueComparisonHelper.java | 3 +-
.../internal/cache/control/HeapMemoryMonitor.java | 2 +-
.../cache/control/InternalResourceManager.java | 26 +-
.../SerializableRegionRedundancyStatusImpl.java | 4 +-
.../geode/internal/cache/eviction/HeapEvictor.java | 5 +-
.../cache/eviction/LRUListWithAsyncSorting.java | 2 +-
.../geode/internal/cache/ha/HARegionQueue.java | 221 +-
.../internal/cache/ha/QueueRemovalMessage.java | 4 +
.../cache/ha/QueueSynchronizationProcessor.java | 254 ++
.../geode/internal/cache/ha/ThreadIdentifier.java | 5 +-
.../internal/cache/partitioned/DumpB2NRegion.java | 4 +-
.../cache/partitioned/FetchBulkEntriesMessage.java | 259 +-
.../cache/partitioned/FetchEntriesMessage.java | 100 +-
.../cache/partitioned/FetchKeysMessage.java | 60 +-
.../PartitionedRegionObserverHolder.java | 7 +-
.../internal/cache/partitioned/RegionAdvisor.java | 16 +-
.../apache/geode/internal/cache/tier/Acceptor.java | 2 +
.../cache/tier/InternalClientMembership.java | 5 +-
.../internal/cache/tier/sockets/AcceptorImpl.java | 88 +-
.../geode/internal/cache/tier/sockets/AuthIds.java | 21 +-
.../cache/tier/sockets/CacheClientUpdater.java | 3 +-
.../cache/tier/sockets/ClientHealthMonitor.java | 33 +-
.../tier/sockets/ClientProxyMembershipID.java | 21 +-
.../ClientRegistrationEventQueueManager.java | 2 +-
.../tier/sockets/ClientUpdateMessageImpl.java | 3 +-
.../cache/tier/sockets/MessageDispatcher.java | 5 +-
.../cache/tier/sockets/ServerConnection.java | 8 +-
.../internal/cache/tier/sockets/command/Put65.java | 18 +-
.../geode/internal/cache/tx/DistTxEntryEvent.java | 5 +
.../internal/cache/tx/RemoteFetchKeysMessage.java | 60 +-
.../cache/versions/RegionVersionVector.java | 2 +
.../internal/cache/wan/AbstractGatewaySender.java | 18 +-
.../wan/AbstractGatewaySenderEventProcessor.java | 39 +-
.../internal/cache/wan/GatewaySenderEventImpl.java | 20 +-
...currentParallelGatewaySenderEventProcessor.java | 4 +-
.../wan/parallel/ParallelGatewaySenderQueue.java | 54 +-
...oncurrentSerialGatewaySenderEventProcessor.java | 4 +-
.../serial/SerialGatewaySenderEventProcessor.java | 5 +-
.../cache/xmlcache/RegionAttributesCreation.java | 9 +
.../org/apache/geode/internal/logging/Banner.java | 1 -
.../internal/logging/CoreLoggingExecutors.java | 238 +-
.../geode/internal/logging/LogFileParser.java | 14 +-
.../geode/internal/logging/MergeLogFiles.java | 9 +-
.../apache/geode/internal/logging/SortLogFile.java | 24 +-
.../org/apache/geode/internal/net/BufferPool.java | 79 +-
.../geode/internal/net/ByteBufferSharing.java | 55 +
.../geode/internal/net/ByteBufferSharingImpl.java | 168 ++
.../geode/internal/net/ByteBufferSharingNoOp.java | 52 +
.../org/apache/geode/internal/net/NioFilter.java | 53 +-
.../apache/geode/internal/net/NioPlainEngine.java | 27 +-
.../apache/geode/internal/net/NioSslEngine.java | 347 +--
.../org/apache/geode/internal/net/SSLUtil.java | 15 +-
.../apache/geode/internal/net/SocketCreator.java | 44 +-
.../sequencelog/io/GemfireLogConverter.java | 5 +-
.../geode/internal/sequencelog/io/GraphReader.java | 16 +-
.../visualization/text/TextDisplay.java | 57 +-
.../statistics/platform/LinuxProcFsStatistics.java | 168 +-
.../org/apache/geode/internal/tcp/Connection.java | 428 +--
.../apache/geode/internal/tcp/ConnectionTable.java | 7 +-
.../org/apache/geode/internal/tcp/MsgReader.java | 85 +-
.../org/apache/geode/internal/tcp/MsgStreamer.java | 9 +-
.../org/apache/geode/internal/util/BlobHelper.java | 18 +-
.../apache/geode/internal/util/PluckStacks.java | 9 +-
.../geode/management/GatewaySenderMXBean.java | 5 +
.../internal/SystemManagementService.java | 4 +-
.../api/LocatorClusterManagementService.java | 40 +-
.../internal/beans/GatewaySenderMBean.java | 5 +
.../internal/beans/GatewaySenderMBeanBridge.java | 6 +
.../internal/beans/MemberMBeanBridge.java | 4 +-
.../internal/beans/QueryDataFunction.java | 24 +-
.../internal/beans/stats/GCStatsMonitor.java | 75 +-
.../beans/stats/GatewaySenderOverflowMonitor.java | 21 +
.../management/internal/beans/stats/StatsKey.java | 2 +
.../geode/management/internal/i18n/CliStrings.java | 3 +-
.../internal/json/AbstractJSONFormatter.java | 3 +
.../internal/json/QueryResultFormatter.java | 11 +-
.../internal/security/MBeanServerWrapper.java | 3 +-
.../management/internal/util/ManagementUtils.java | 5 +
.../org/apache/geode/pdx/internal/PdxString.java | 5 +-
.../sanctioned-geode-core-serializables.txt | 1 +
.../internal/ClusterDistributionManagerTest.java | 40 +
.../internal/CopyOnWriteHashSetJUnitTest.java | 20 +
.../geode/internal/GemFireVersionJUnitTest.java | 1 -
.../internal/cache/AbstractRegionJUnitTest.java | 4 +-
.../internal/cache/AbstractRegionMapTest.java | 27 +
.../cache/AbstractRegionMapTxApplyDestroyTest.java | 36 +-
.../geode/internal/cache/EntryEventImplTest.java | 198 +-
.../geode/internal/cache/FilterProfileTest.java | 258 ++
.../geode/internal/cache/GemFireCacheImplTest.java | 12 +
.../geode/internal/cache/LocalRegionTest.java | 55 +
.../geode/internal/cache/TXCommitMessageTest.java | 23 +
.../apache/geode/internal/cache/TXStateTest.java | 92 +
.../cache/control/InternalResourceManagerTest.java | 81 +
.../control/RegionRedundancyStatusImplTest.java | 19 +-
.../geode/internal/cache/ha/HARegionQueueTest.java | 391 ++-
.../internal/cache/ha/QueueRemovalMessageTest.java | 21 +
.../ha/QueueSynchronizationProcessorTest.java | 155 ++
.../cache/partitioned/RegionAdvisorJUnitTest.java | 81 +
.../tier/sockets/CacheClientNotifierTest.java | 2 +-
.../tier/sockets/ClientHealthMonitorTest.java | 4 +
.../ClientRegistrationEventQueueManagerTest.java | 2 +-
.../cache/wan/GatewaySenderEventImplTest.java | 79 +
.../ParallelGatewaySenderQueueJUnitTest.java | 90 +
.../apache/geode/internal/net/BufferPoolTest.java | 28 +-
.../internal/net/ByteBufferConcurrencyTest.java | 165 ++
.../internal/net/ByteBufferSharingImplTest.java | 179 ++
.../geode/internal/net/NioPlainEngineTest.java | 50 +-
.../geode/internal/net/NioSslEngineTest.java | 422 +--
.../org/apache/geode/internal/net/SSLUtilTest.java | 16 +
.../internal/ra/spi/JCALocalTransactionTest.java | 63 +
.../apache/geode/internal/tcp/ConnectionTest.java | 54 +
.../apache/geode/internal/tcp/MsgStreamerTest.java | 31 +-
.../bean/stats/MemberLevelStatsTest.java | 42 +-
.../api/LocatorClusterManagementServiceTest.java | 24 +-
.../QueryDataFunctionApplyLimitClauseTest.java | 52 +
.../internal/beans/stats/GCStatsMonitorTest.java | 119 +-
.../stats/GatewaySenderOverflowMonitorTest.java | 18 +-
.../internal}/json/QueryResultFormatterTest.java | 43 +-
.../pdx/internal/PeerTypeRegistrationTest.java | 8 +-
geode-core/src/test/resources/expected-pom.xml | 5 -
geode-cq/build.gradle | 6 +-
.../cache/RemoteCQTransactionDUnitTest.java | 310 ++-
.../running/starting_up_shutting_down.html.md.erb | 8 +-
.../query_additional/query_debugging.html.md.erb | 6 +-
.../compacting_disk_stores.html.md.erb | 22 +-
.../disk_store_configuration_params.html.md.erb | 7 +-
.../disk_storage/using_disk_stores.html.md.erb | 6 +-
.../topics/gemfire_properties.html.md.erb | 4 +-
.../gfsh/command-pages/compact.html.md.erb | 12 +-
.../gfsh/command-pages/create.html.md.erb | 2 +-
.../tomcat_installing_the_module.html.md.erb | 2 +
.../weblogic_setting_up_the_module.html.md.erb | 10 +-
.../tools_modules/redis_api_for_geode.html.md.erb | 23 +-
geode-dunit/build.gradle | 2 +-
.../DistributedReferenceCacheExampleTest.java | 12 +-
...ributedReferenceLocatorLauncherExampleTest.java | 12 +-
...tributedReferenceServerLauncherExampleTest.java | 14 +-
.../DistributedReferenceSystemExampleTest.java | 12 +-
.../dunit/internal/DUnitBlackboardDUnitTest.java | 75 +-
.../DistributedBlackboardDistributedTest.java | 297 ++
...ava => DistributedCountersDistributedTest.java} | 78 +-
... DistributedErrorCollectorDistributedTest.java} | 42 +-
.../test/dunit/rules/tests/DistributedMapTest.java | 656 +++++
.../rules/tests/DistributedReferenceTest.java | 399 ++-
.../sockets/ClientServerMiscDUnitTestBase.java | 6 +-
.../cache/wan/AsyncEventQueueTestBase.java | 6 +-
.../cli/commands/QueryCommandDUnitTestBase.java | 25 +-
.../commands/RebalanceCommandDistributedTest.java | 25 +-
.../InternalBlackboard.java => Blackboard.java} | 54 +-
.../apache/geode/test/dunit/DUnitBlackboard.java | 55 +-
.../geode/test/dunit/DistributedTestUtils.java | 71 +-
.../apache/geode/test/dunit/IgnoredException.java | 3 +
.../main/java/org/apache/geode/test/dunit/VM.java | 11 +-
.../geode/test/dunit/internal/DUnitLauncher.java | 166 +-
.../test/dunit/internal/InternalBlackboard.java | 33 +-
.../dunit/internal/InternalBlackboardImpl.java | 59 +-
.../test/dunit/internal/StandAloneDUnitEnv.java | 2 +-
.../test/dunit/rules/DistributedBlackboard.java | 138 +
...dCountersRule.java => DistributedCounters.java} | 44 +-
...llector.java => DistributedErrorCollector.java} | 9 +-
.../geode/test/dunit/rules/DistributedMap.java | 228 ++
.../test/dunit/rules/DistributedReference.java | 168 +-
.../geode/test/dunit/rules/DistributedRule.java | 13 +-
.../apache/geode/test/greplogs/LogConsumer.java | 32 +-
.../geode/test/greplogs/LogConsumerTest.java | 24 +-
geode-dunit/src/test/resources/expected-pom.xml | 2 +-
geode-experimental-driver/build.gradle | 5 +-
.../apache/geode/experimental/driver/SSLTest.java | 38 +-
.../geode/experimental/driver/SocketFactory.java | 10 +-
...xesCommandWithMultipleGfshSessionDUnitTest.java | 118 +
.../DestroySecondJndiBindingCommandDUnitTest.java | 13 +-
.../cli/commands/DiskStoreCommandsDUnitTest.java | 20 +
.../OfflineDiskStoreCommandsDUnitTest.java | 246 ++
.../RestoreRedundancyCommandDUnitTest.java | 24 +-
.../ShowMissingDiskStoreCommandDUnitTest.java | 57 +
.../AlterDiskStoreCommandIntegrationTest.java | 32 +
.../DescribeDiskStoreCommandIntegrationTest.java | 31 +-
.../cli/commands/VersionCommandJUnitTest.java | 3 +-
.../cli/util/LogExporterFileIntegrationTest.java | 10 +
.../cli/util/LogExporterIntegrationTest.java | 203 +-
.../apache/geode/management/cli/GfshCommand.java | 12 +
.../cli/commands/ClearDefinedIndexesCommand.java | 11 +
.../commands/CompactOfflineDiskStoreCommand.java | 11 +-
.../internal/cli/commands/ConnectCommand.java | 70 +-
.../internal/cli/commands/DefineIndexCommand.java | 11 +
.../internal/cli/commands/DeployCommand.java | 51 +-
.../internal/cli/commands/IndexDefinition.java | 5 +-
.../internal/cli/commands/RebalanceCommand.java | 6 +-
.../internal/cli/commands/ShCommand.java | 11 +-
.../cli/commands/ShowMissingDiskStoreCommand.java | 16 +-
.../internal/cli/commands/StartLocatorCommand.java | 2 -
.../commands/UpgradeOfflineDiskStoreCommand.java | 11 +-
.../cli/commands/ValidateDiskStoreCommand.java | 11 +-
.../functions/ManageIndexDefinitionFunction.java | 40 +
.../internal/cli/functions/NetstatFunction.java | 44 +-
.../internal/cli/shell/JmxOperationInvoker.java | 12 +-
.../management/internal/cli/util/LogExporter.java | 10 +-
.../management/internal/cli/util/MergeLogs.java | 15 +-
.../sanctioned-geode-gfsh-serializables.txt | 1 +
.../internal/cli/commands/ConnectCommandTest.java | 81 +-
.../cli/commands/GfshCommandJUnitTest.java | 28 +
.../cli/functions/GetRegionsFunctionTest.java | 4 +-
.../ManageIndexDefinitionFunctionTest.java | 68 +
.../cli/functions/UserFunctionExecutionTest.java | 5 -
{geode-common => geode-jmh}/build.gradle | 8 +-
.../jmh/profilers/BufferPoolProfiler.java | 94 +
.../services/org.openjdk.jmh.profile.Profiler | 1 +
.../jmh/profilers/BufferPoolProfilerTest.java | 100 +
geode-jmh/src/test/resources/expected-pom.xml | 55 +
geode-junit/build.gradle | 8 +-
.../geode/codeAnalysis/CompiledClassUtils.java | 7 +-
.../apache/geode/internal/AvailablePortHelper.java | 313 +--
.../internal/cache/DiskRegionTestingBase.java | 20 +
.../apache/geode/management/model/Employee.java | 94 +
.../org/apache/geode/pdx/NonDelegatingLoader.java | 35 +-
.../geode/test/junit/rules/CloseableReference.java | 209 ++
.../apache/geode/test/junit/rules/GsRandom.java | 33 +-
.../test/junit/rules/IgnoreOnWindowsRule.java | 2 +-
.../apache/geode/test/junit/rules/RandomRule.java | 279 ++
.../geode/test/junit/rules/gfsh/GfshExecution.java | 32 +-
.../serializable/SerializableTemporaryFolder.java | 20 +-
.../geode/test/util/StressNewTestHelper.java | 197 ++
.../test/junit/rules/CloseableReferenceTest.java | 204 ++
.../test/junit/rules/ExpectedTimeoutRuleTest.java | 4 +-
.../geode/test/junit/rules/RandomRuleTest.java | 108 +
.../SerializableTemporaryFolderTest.java | 26 +-
...CategoryWithParameterizedRunnerFactoryTest.java | 4 +-
.../geode/test/util/WhatExtendsJUnitTest.java | 99 +
geode-junit/src/test/resources/expected-pom.xml | 9 +-
geode-log4j/build.gradle | 31 +-
.../apache/geode/logging/internal/OSProcess.java | 25 +-
.../internal/executors/LoggingExecutors.java | 110 +-
.../internal/executors/LoggingThreadFactory.java | 15 +-
geode-lucene/build.gradle | 5 +-
.../IndexRepositoryFactoryDistributedTest.java | 2 -
.../IndexRepositoryFactoryIntegrationTest.java | 123 +
.../lucene/internal/IndexRepositoryFactory.java | 41 +-
.../internal/IndexRepositoryFactoryTest.java | 45 +-
.../LuceneSearchWithRollingUpgradeTestBase.java | 3 +
.../geode/management/configuration/Index.java | 4 +-
.../management/configuration/ClassNameTest.java | 4 +-
.../management/configuration/DeploymentTest.java | 2 +-
.../geode/management/configuration/IndexTest.java | 24 +-
.../management/runtime/DeploymentInfoTest.java | 2 +-
.../MembershipDependenciesJUnitTest.java | 1 +
.../membership/api/MembershipAPIArchUnitTest.java | 1 +
.../membership/gms/GMSMembershipJUnitTest.java | 15 +
.../membership/gms/MembershipIntegrationTest.java | 111 +-
.../internal/membership/gms/GMSMembership.java | 54 +-
.../membership/gms/fd/GMSHealthMonitor.java | 10 +-
.../membership/gms/membership/GMSJoinLeave.java | 14 +-
.../membership/gms/messenger/JGroupsMessenger.java | 60 +-
.../org/apache/geode/internal/AvailablePort.java | 22 +-
geode-memcached/build.gradle | 1 +
geode-old-versions/build.gradle | 5 +-
.../ClearRequestOperationHandlerJUnitTest.java | 5 -
...ionOnGroupRequestOperationHandlerJUnitTest.java | 5 -
.../GetAllRequestOperationHandlerJUnitTest.java | 14 +-
.../GetSizeRequestOperationHandlerJUnitTest.java | 11 +-
...utIfAbsentRequestOperationHandlerJUnitTest.java | 22 +-
.../PutRequestOperationHandlerJUnitTest.java | 15 +-
geode-pulse/build.gradle | 4 +-
geode-pulse/geode-pulse-test/build.gradle | 1 +
.../controllers/PulseControllerJUnitTest.java | 4 +-
.../context/PulseControllerTestContext.java | 1 -
.../security/OAuthSecurityTokenHandoffTest.java | 2 +-
.../tools/pulse/internal/PulseAppListener.java | 2 -
.../internal/controllers/PulseController.java | 1 -
.../tools/pulse/internal/data/PulseConstants.java | 1 -
.../tools/pulse/internal/data/PulseVersion.java | 12 +-
.../pulse/internal/security/OAuthClientConfig.java | 2 +-
.../internal/service/PulseVersionService.java | 1 -
geode-pulse/src/main/webapp/accessDenied.html | 4 -
geode-pulse/src/main/webapp/clusterDetail.html | 3 -
geode-pulse/src/main/webapp/dataBrowser.html | 3 -
geode-pulse/src/main/webapp/memberDetails.html | 4 -
geode-pulse/src/main/webapp/queryStatistics.html | 3 -
geode-pulse/src/main/webapp/regionDetail.html | 4 -
.../webapp/scripts/pulsescript/PulseCallbacks.js | 1 -
.../src/main/webapp/scripts/pulsescript/common.js | 1 -
geode-rebalancer/build.gradle | 4 +-
geode-redis/README.md | 103 +-
geode-redis/build.gradle | 9 +
...ommandPipeliningNativeRedisAcceptanceTest.java} | 19 +-
.../GeodeRedisServerStartUpAcceptanceTest.java | 99 +
.../GlobPatternNativeRedisAcceptanceTest.java | 21 +-
.../UnknownNativeRedisAcceptanceTest.java} | 24 +-
.../connection/AuthNativeRedisAcceptanceTest.java | 6 +-
.../connection/EchoNativeRedisAcceptanceTest.java} | 19 +-
.../connection/PingNativeRedisAcceptanceTest.java | 23 +-
.../SelectNativeRedisAcceptanceTest.java} | 19 +-
.../hash/HScanNativeRedisAcceptanceTest.java} | 17 +-
.../hash/HashesNativeRedisAcceptanceTest.java | 33 +-
.../executor/key/DelNativeRedisAcceptanceTest.java | 24 +-
.../key/ExistsNativeRedisAcceptanceTest.java | 35 +-
.../key/ExpireAtNativeRedisAcceptanceTest.java | 29 +-
.../key/ExpireNativeRedisAcceptanceTest.java | 31 +-
.../key/KeysNativeRedisAcceptanceTest.java | 23 +-
.../key/PExpireAtNativeRedisAcceptanceTest.java} | 18 +-
.../key/PTTLNativeRedisAcceptanceTest.java | 21 +-
.../key/PersistNativeRedisAcceptanceTest.java | 31 +-
.../key/PexpireNativeRedisAcceptanceTest.java | 29 +-
.../key/RenameNativeRedisAcceptanceTest.java | 31 +-
.../key/ScanNativeRedisAcceptanceTest.java} | 18 +-
.../executor/key/TTLNativeRedisAcceptanceTest.java | 23 +-
.../key/TypeNativeRedisAcceptanceTest.java | 22 +-
.../key/UnlinkNativeRedisAcceptanceTest.java} | 18 +-
.../LettucePubSubNativeRedisAcceptanceTest.java} | 18 +-
.../pubsub/PubSubNativeRedisAcceptanceTest.java | 41 +-
.../SubscriptionsNativeRedisAcceptanceTest.java} | 17 +-
.../server/DBSizeNativeRedisAcceptanceTest.java} | 18 +-
.../server/FlushAllNativeRedisAcceptanceTest.java} | 18 +-
.../server/FlushDBNativeRedisAcceptanceTest.java} | 18 +-
.../HitsMissesNativeRedisAcceptanceTest.java} | 19 +-
.../server/InfoNativeRedisAcceptanceTest.java} | 20 +-
.../server/ShutDownNativeRedisAcceptanceTest.java} | 18 +-
.../server/TimeNativeRedisAcceptanceTest.java} | 18 +-
.../set/SDiffNativeRedisAcceptanceTest.java | 30 +-
.../set/SInterNativeRedisAcceptanceTest.java | 30 +-
.../set/SIsMemberNativeRedisAcceptanceTest.java | 25 +-
.../set/SMoveNativeRedisAcceptanceTest.java | 30 +-
.../set/SPopNativeRedisAcceptanceTest.java | 30 +-
.../set/SRemNativeRedisAcceptanceTest.java | 30 +-
.../set/SScanNativeRedisAcceptanceTest.java} | 18 +-
.../set/SUnionNativeRedisAcceptanceTest.java | 30 +-
.../set/SetsNativeRedisAcceptanceTest.java | 30 +-
.../string/AppendNativeRedisAcceptanceTest.java | 21 +-
.../string/BitCountNativeRedisAcceptanceTest.java | 21 +-
.../string/BitOpNativeRedisAcceptanceTest.java | 21 +-
.../string/BitPosNativeRedisAcceptanceTest.java | 21 +-
.../string/DecrByNativeRedisAcceptanceTest.java | 24 +-
.../string/DecrNativeRedisAcceptanceTest.java | 22 +-
.../string/GetBitNativeRedisAcceptanceTest.java | 21 +-
.../string/GetNativeRedisAcceptanceTest.java | 21 +-
.../string/GetRangeNativeRedisAcceptanceTest.java | 21 +-
.../string/GetSetNativeRedisAcceptanceTest.java | 22 +-
.../IncrByFloatNativeRedisAcceptanceTest.java | 24 +-
.../string/IncrByNativeRedisAcceptanceTest.java | 24 +-
.../string/IncrNativeRedisAcceptanceTest.java | 22 +-
.../string/MGetNativeRedisAcceptanceTest.java | 22 +-
.../string/MSetNXNativeRedisAcceptanceTest.java | 21 +-
.../string/MSetNativeRedisAcceptanceTest.java | 22 +-
.../string/PSetEXNativeRedisAcceptanceTest.java | 21 +-
.../string/SetBitNativeRedisAcceptanceTest.java | 21 +-
.../string/SetExNativeRedisAcceptanceTest.java | 21 +-
.../string/SetNXNativeRedisAcceptanceTest.java | 21 +-
.../string/SetNativeRedisAcceptanceTest.java | 23 +-
.../string/SetRangeNativeRedisAcceptanceTest.java | 21 +-
.../string/StrLenNativeRedisAcceptanceTest.java | 21 +-
.../session/NativeRedisSessionAcceptanceTest.java | 10 +-
...NativeRedisSessionExpirationAcceptanceTest.java | 11 +-
.../java/org/apache/geode/NativeRedisTestRule.java | 70 +
.../geode/redis/ConcurrentLoopingThreads.java | 39 +-
.../apache/geode/redis/GeodeRedisServerRule.java | 4 +-
.../geode/redis/mocks/MockBinarySubscriber.java | 0
.../apache/geode/redis/mocks/MockSubscriber.java | 231 ++
.../test/dunit/rules/RedisClusterStartupRule.java | 4 +
.../geode/test/dunit/rules/RedisPortSupplier.java} | 15 +-
.../redis/GeodeRedisServerStartupDUnitTest.java | 17 +-
.../org/apache/geode/redis/MockSubscriber.java | 62 -
.../executor/CrashAndNoRepeatDUnitTest.java | 53 +-
.../internal/executor/hash/HdelDUnitTest.java | 184 ++
.../internal/executor/pubsub/PubSubDUnitTest.java | 215 +-
.../geode/redis/session/RedisSessionDUnitTest.java | 45 +
... AbstractCommandPipeliningIntegrationTest.java} | 67 +-
.../redis/CommandPipeliningIntegrationTest.java | 76 +-
.../redis/internal/RedisStatsIntegrationTest.java | 536 ++++
...ava => AbstractGlobPatternIntegrationTest.java} | 27 +-
.../executor/AbstractUnknownIntegrationTest.java | 69 +
.../executor/GlobPatternIntegrationTest.java | 240 +-
.../internal/executor/UnknownIntegrationTest.java | 31 +-
.../AbstractEchoIntegrationTest.java} | 42 +-
...nTest.java => AbstractPingIntegrationTest.java} | 28 +-
.../AbstractSelectIntegrationTest.java} | 58 +-
.../executor/connection/AuthIntegrationTest.java | 3 -
.../executor/connection/EchoIntegrationTest.java} | 19 +-
.../executor/connection/PingIntegrationTest.java | 56 +-
...tegrationTest.java => QuitIntegrationTest.java} | 62 +-
.../SelectIntegrationTest.java} | 40 +-
.../hash/AbstractHScanIntegrationTest.java | 383 +++
...est.java => AbstractHashesIntegrationTest.java} | 35 +-
.../HScanIntegrationTest.java} | 52 +-
.../executor/hash/HashesIntegrationTest.java | 719 +----
...onTest.java => AbstractDelIntegrationTest.java} | 53 +-
...est.java => AbstractExistsIntegrationTest.java} | 43 +-
...t.java => AbstractExpireAtIntegrationTest.java} | 67 +-
...est.java => AbstractExpireIntegrationTest.java} | 52 +-
...nTest.java => AbstractKeysIntegrationTest.java} | 68 +-
.../key/AbstractPExpireAtIntegrationTest.java | 85 +
...nTest.java => AbstractPTTLIntegrationTest.java} | 45 +-
...st.java => AbstractPersistIntegrationTest.java} | 45 +-
...st.java => AbstractPexpireIntegrationTest.java} | 53 +-
...est.java => AbstractRenameIntegrationTest.java} | 59 +-
.../executor/key/AbstractScanIntegrationTest.java | 297 ++
...onTest.java => AbstractTTLIntegrationTest.java} | 50 +-
...nTest.java => AbstractTypeIntegrationTest.java} | 27 +-
...est.java => AbstractUnlinkIntegrationTest.java} | 83 +-
.../internal/executor/key/DelIntegrationTest.java | 103 +-
.../executor/key/ExistsIntegrationTest.java | 174 +-
.../executor/key/ExpireAtIntegrationTest.java | 110 +-
.../executor/key/ExpireIntegrationTest.java | 324 +--
.../internal/executor/key/KeysIntegrationTest.java | 75 +-
.../executor/key/PExpireAtIntegrationTest.java} | 18 +-
.../internal/executor/key/PTTLIntegrationTest.java | 59 +-
.../executor/key/PersistIntegrationTest.java | 128 +-
.../executor/key/PexpireIntegrationTest.java | 75 +-
.../executor/key/RenameIntegrationTest.java | 398 +--
.../ScanIntegrationTest.java} | 54 +-
.../internal/executor/key/TTLIntegrationTest.java | 59 +-
.../internal/executor/key/TypeIntegrationTest.java | 68 +-
.../executor/key/UnlinkIntegrationTest.java} | 18 +-
.../AbstractLettucePubSubIntegrationTest.java | 375 +++
...est.java => AbstractPubSubIntegrationTest.java} | 282 +-
.../AbstractSubscriptionsIntegrationTest.java | 201 ++
.../pubsub/LettucePubSubIntegrationTest.java} | 18 +-
.../executor/pubsub/PubSubIntegrationTest.java | 655 +----
.../SubscriptionsIntegrationTest.java} | 45 +-
.../AbstractDBSizeIntegrationTest.java} | 39 +-
...t.java => AbstractFlushAllIntegrationTest.java} | 37 +-
.../AbstractFlushDBIntegrationTest.java} | 46 +-
.../server/AbstractHitsMissesIntegrationTest.java | 393 +++
.../server/AbstractInfoIntegrationTest.java | 191 ++
...t.java => AbstractShutDownIntegrationTest.java} | 38 +-
...nTest.java => AbstractTimeIntegrationTest.java} | 41 +-
.../executor/server/DBSizeIntegrationTest.java} | 18 +-
.../executor/server/FlushAllIntegrationTest.java | 39 +-
.../executor/server/FlushDBIntegrationTest.java} | 19 +-
.../executor/server/InfoIntegrationTest.java} | 23 +-
.../executor/server/ShutdownIntegrationTest.java | 34 +-
.../executor/server/TimeIntegrationTest.java | 42 +-
...Test.java => AbstractSDiffIntegrationTest.java} | 57 +-
...est.java => AbstractSInterIntegrationTest.java} | 57 +-
....java => AbstractSIsMemberIntegrationTest.java} | 56 +-
...Test.java => AbstractSMoveIntegrationTest.java} | 71 +-
...nTest.java => AbstractSPopIntegrationTest.java} | 127 +-
...nTest.java => AbstractSRemIntegrationTest.java} | 51 +-
.../executor/set/AbstractSScanIntegrationTest.java | 333 +++
...est.java => AbstractSUnionIntegrationTest.java} | 57 +-
...nTest.java => AbstractSetsIntegrationTest.java} | 82 +-
.../executor/set/SDiffIntegrationTest.java | 184 +-
.../executor/set/SInterIntegrationTest.java | 184 +-
.../executor/set/SIsMemberIntegrationTest.java | 68 +-
.../executor/set/SMoveIntegrationTest.java | 122 +-
.../internal/executor/set/SPopIntegrationTest.java | 168 +-
.../internal/executor/set/SRemIntegrationTest.java | 166 +-
.../SScanIntegrationTest.java} | 53 +-
.../executor/set/SUnionIntegrationTest.java | 177 +-
.../internal/executor/set/SetsIntegrationTest.java | 241 +-
...est.java => AbstractAppendIntegrationTest.java} | 46 +-
...t.java => AbstractBitCountIntegrationTest.java} | 82 +-
...Test.java => AbstractBitOpIntegrationTest.java} | 68 +-
...est.java => AbstractBitPosIntegrationTest.java} | 107 +-
...est.java => AbstractDecrByIntegrationTest.java} | 57 +-
...nTest.java => AbstractDecrIntegrationTest.java} | 51 +-
...est.java => AbstractGetBitIntegrationTest.java} | 45 +-
...onTest.java => AbstractGetIntegrationTest.java} | 47 +-
.../string/AbstractGetRangeIntegrationTest.java | 251 ++
...est.java => AbstractGetSetIntegrationTest.java} | 52 +-
.../string/AbstractIncrByFloatIntegrationTest.java | 175 ++
...est.java => AbstractIncrByIntegrationTest.java} | 48 +-
...nTest.java => AbstractIncrIntegrationTest.java} | 69 +-
.../AbstractLettuceAppendIntegrationTest.java | 61 +
...nTest.java => AbstractMGetIntegrationTest.java} | 34 +-
...nTest.java => AbstractMSetIntegrationTest.java} | 56 +-
...est.java => AbstractMSetNXIntegrationTest.java} | 48 +-
.../string/AbstractPSetEXIntegrationTest.java | 77 +
...est.java => AbstractSetBitIntegrationTest.java} | 52 +-
.../string/AbstractSetEXIntegrationTest.java | 83 +
...onTest.java => AbstractSetIntegrationTest.java} | 107 +-
...Test.java => AbstractSetNXIntegrationTest.java} | 46 +-
...t.java => AbstractSetRangeIntegrationTest.java} | 52 +-
...est.java => AbstractStrLenIntegrationTest.java} | 76 +-
.../executor/string/AppendIntegrationTest.java | 101 +-
.../executor/string/BitCountIntegrationTest.java | 135 +-
.../executor/string/BitOpIntegrationTest.java | 186 +-
.../executor/string/BitPosIntegrationTest.java | 52 +-
.../executor/string/DecrByIntegrationTest.java | 63 +-
.../executor/string/DecrIntegrationTest.java | 68 +-
.../executor/string/GetBitIntegrationTest.java | 63 +-
.../executor/string/GetIntegrationTest.java | 68 +-
.../executor/string/GetRangeIntegrationTest.java | 121 +-
.../executor/string/GetSetIntegrationTest.java | 140 +-
.../string/IncrByFloatIntegrationTest.java | 51 +-
.../executor/string/IncrByIntegrationTest.java | 62 +-
.../executor/string/IncrIntegrationTest.java | 98 +-
.../string/LettuceAppendIntegrationTest.java} | 15 +-
.../executor/string/MGetIntegrationTest.java | 43 +-
.../executor/string/MSetIntegrationTest.java | 137 +-
.../executor/string/MSetNXIntegrationTest.java | 50 +-
.../executor/string/PSetEXIntegrationTest.java | 33 +-
.../executor/string/SetBitIntegrationTest.java | 72 +-
.../executor/string/SetEXIntegrationTest.java | 40 +-
.../executor/string/SetIntegrationTest.java | 491 +---
.../executor/string/SetNXIntegrationTest.java | 47 +-
.../executor/string/SetRangeIntegrationTest.java | 84 +-
.../executor/string/StrLenIntegrationTest.java | 64 +-
.../pubsub/SubscriptionsIntegrationTest.java | 17 +-
.../geode/redis/mocks/DummySubscription.java | 13 +-
.../apache/geode/redis/mocks/MockSubscriber.java | 99 -
.../codeAnalysis/sanctionedDataSerializables.txt | 8 +-
.../geode/redis/internal/GeodeRedisServer.java | 26 +-
.../EvenParameterRequirements.java | 21 +-
.../ExactParameterRequirements.java | 2 +-
.../MaximumParameterRequirements.java | 19 +-
.../MinimumParameterRequirements.java | 4 +-
...irements.java => OddParameterRequirements.java} | 28 +-
.../ParameterRequirements.java | 4 +-
.../SpopParameterRequirements.java | 4 +-
.../geode/redis/internal/RedisCommandType.java | 107 +-
.../geode/redis/internal/RedisConstants.java | 105 +-
.../apache/geode/redis/internal/RedisStats.java | 185 +-
.../redis/internal/data/AbstractRedisData.java | 16 +-
.../geode/redis/internal/data/CommandHelper.java | 36 +-
.../geode/redis/internal/data/NullRedisSet.java | 7 -
.../geode/redis/internal/data/RedisHash.java | 61 +-
.../data/RedisHashCommandsFunctionExecutor.java | 6 +-
.../data/RedisKeyCommandsFunctionExecutor.java | 31 +-
.../apache/geode/redis/internal/data/RedisSet.java | 56 +-
.../data/RedisSetCommandsFunctionExecutor.java | 7 +-
.../geode/redis/internal/data/RedisString.java | 43 +-
.../data/RedisStringCommandsFunctionExecutor.java | 1 -
.../redis/internal/delta/AppendDeltaInfo.java | 9 +-
.../redis/internal/executor/CommandFunction.java | 5 +-
.../geode/redis/internal/executor/GlobPattern.java | 2 +-
.../redis/internal/executor/RedisResponse.java | 26 +-
.../redis/internal/executor/UnknownExecutor.java | 25 +-
.../internal/executor/connection/EchoExecutor.java | 4 -
.../internal/executor/connection/PingExecutor.java | 32 +-
.../internal/executor/connection/QuitExecutor.java | 3 +
.../{QuitExecutor.java => SelectExecutor.java} | 16 +-
.../internal/executor/hash/HScanExecutor.java | 109 +-
.../internal/executor/hash/RedisHashCommands.java | 6 +-
.../hash/RedisHashCommandsFunctionInvoker.java | 6 +-
.../executor/key/AbstractScanExecutor.java | 9 +-
.../internal/executor/key/ExpireAtExecutor.java | 10 +-
.../internal/executor/key/ExpireExecutor.java | 9 +-
.../internal/executor/key/PExpireAtExecutor.java | 5 -
.../internal/executor/key/PExpireExecutor.java | 5 -
.../redis/internal/executor/key/PTTLExecutor.java | 5 -
.../internal/executor/key/PersistExecutor.java | 11 +-
.../key/RedisKeyCommandsFunctionInvoker.java | 7 +-
.../internal/executor/key/RenameFunction.java | 2 +-
.../redis/internal/executor/key/ScanExecutor.java | 132 +-
.../redis/internal/executor/key/TTLExecutor.java | 11 +-
.../executor/pubsub/PsubscribeExecutor.java | 51 +-
.../internal/executor/pubsub/PublishExecutor.java | 9 +-
.../executor/pubsub/PunsubscribeExecutor.java | 28 +-
.../executor/pubsub/SubscribeExecutor.java | 44 +-
.../executor/pubsub/UnsubscribeExecutor.java | 6 +-
.../internal/executor/server/FlushAllExecutor.java | 1 +
.../internal/executor/server/InfoExecutor.java | 177 ++
...{FlushAllExecutor.java => SlowlogExecutor.java} | 18 +-
.../internal/executor/set/RedisSetCommands.java | 6 +-
.../set/RedisSetCommandsFunctionInvoker.java | 6 +-
.../redis/internal/executor/set/SPopExecutor.java | 15 +-
.../redis/internal/executor/set/SScanExecutor.java | 102 +-
.../internal/executor/string/BitCountExecutor.java | 5 -
.../internal/executor/string/BitOpExecutor.java | 14 +-
.../internal/executor/string/BitPosExecutor.java | 5 -
.../internal/executor/string/DecrByExecutor.java | 15 +-
.../internal/executor/string/DecrExecutor.java | 12 +-
.../internal/executor/string/GetBitExecutor.java | 10 +-
.../internal/executor/string/GetExecutor.java | 1 -
.../internal/executor/string/GetRangeExecutor.java | 13 +-
.../internal/executor/string/GetSetExecutor.java | 8 +-
.../internal/executor/string/IncrByExecutor.java | 9 +-
.../executor/string/IncrByFloatExecutor.java | 27 +-
.../internal/executor/string/IncrExecutor.java | 10 +-
.../internal/executor/string/MGetExecutor.java | 9 +-
.../internal/executor/string/MSetExecutor.java | 10 +-
.../internal/executor/string/MSetNXExecutor.java | 11 +-
.../internal/executor/string/PSetEXExecutor.java | 8 -
.../internal/executor/string/SetBitExecutor.java | 10 +-
.../internal/executor/string/SetEXExecutor.java | 19 +-
.../internal/executor/string/SetExecutor.java | 6 +-
.../internal/executor/string/SetNXExecutor.java | 13 +-
.../internal/executor/string/SetRangeExecutor.java | 9 +-
.../internal/executor/string/StrlenExecutor.java | 12 +-
.../redis/internal/netty/ByteToCommandDecoder.java | 17 +-
.../apache/geode/redis/internal/netty/Client.java | 8 +
.../apache/geode/redis/internal/netty/Coder.java | 39 +-
.../apache/geode/redis/internal/netty/Command.java | 36 +-
.../internal/netty/ExecutionHandlerContext.java | 292 +-
.../redis/internal/netty/NettyRedisServer.java | 68 +-
.../internal/pubsub/AbstractSubscription.java | 92 +-
.../redis/internal/pubsub/ChannelSubscription.java | 12 +-
.../redis/internal/pubsub/PatternSubscription.java | 12 +-
.../apache/geode/redis/internal/pubsub/PubSub.java | 22 +-
.../geode/redis/internal/pubsub/PubSubImpl.java | 22 +-
.../redis/internal/pubsub/SubscribeResult.java} | 42 +-
.../geode/redis/internal/pubsub/Subscription.java | 19 +-
.../geode/redis/internal/pubsub/Subscriptions.java | 23 +-
.../sanctioned-geode-redis-serializables.txt | 3 +-
.../redis/internal/SupportedCommandsJUnitTest.java | 7 +-
.../geode/redis/internal/data/RedisStringTest.java | 270 +-
.../executor/UnknownExecutorJUnitTest.java | 52 -
.../key/AbstractScanExecutorJUnitTest.java | 42 -
.../executor/key/DelExecutorJUnitTest.java | 53 -
.../executor/key/ExistsExecutorJUnitTest.java | 57 -
.../executor/key/ExpireAtExecutorJUnitTest.java | 82 -
.../executor/key/ExpireExecutorJUnitTest.java | 82 -
.../executor/key/KeysExecutorJUnitTest.java | 66 -
.../executor/key/PExpireAtExecutorJUnitTest.java | 81 -
.../executor/key/PTTLExecutorJUnitTest.java | 52 -
.../executor/key/PersistExecutorJUnitTest.java | 77 -
.../executor/key/PexpireExecutorJUnitTest.java | 81 -
.../executor/key/TTLExecutorJUnitTest.java | 52 -
.../executor/set/SetExecutorJUnitTest.java | 394 ---
.../executor/string/GetRangeExecutorJUnitTest.java | 108 -
.../executor/string/GetSetExecutorJUnitTest.java | 92 -
.../executor/string/IncrExecutorJUnitTest.java | 71 -
.../string/StringGetExecutorJUnitTest.java | 67 -
.../string/StringMGetExecutorJUnitTest.java | 71 -
.../string/StringMSetExecutorJUnitTest.java | 67 -
.../string/StringSetExecutorJUnitTest.java | 233 --
.../executor/string/StrlenExecutorJUnitTest.java | 72 -
.../redis/internal/pubsub/PubSubImplJUnitTest.java | 14 +-
.../internal/pubsub/SubscriptionsJUnitTest.java | 65 +-
.../serialization/DataSerializableFixedID.java | 5 +-
.../SerializationDependenciesJUnitTest.java | 3 +-
.../distributed/internal/tcpserver/TcpClient.java | 50 +-
.../distributed/internal/tcpserver/TcpServer.java | 7 +
.../tcpserver/TcpServerDependenciesTest.java | 3 +-
geode-wan/build.gradle | 7 +-
.../internal/cache/UpdateVersionDUnitTest.java | 6 +-
.../geode/internal/cache/wan/WANTestBase.java | 379 +--
.../misc/SenderWithTransportFilterDUnitTest.java | 2 +-
.../cache/wan/misc/WANLocatorServerDUnitTest.java | 10 +-
.../cache/wan/misc/WanAutoDiscoveryDUnitTest.java | 24 +-
.../cache/wan/misc/WanValidationsDUnitTest.java | 2 +-
.../ParallelGatewaySenderOperationsDUnitTest.java | 4 +-
...ANPersistenceEnabledGatewaySenderDUnitTest.java | 14 +-
.../parallel/ParallelWANPropagationDUnitTest.java | 313 ++-
.../ParallelWANPropagationLoopBackDUnitTest.java | 310 ++-
.../wan/parallel/ParallelWANStatsDUnitTest.java | 132 +-
.../cache/wan/serial/GatewayReceiverDUnitTest.java | 4 +-
.../SerialGatewaySenderEventListenerDUnitTest.java | 4 +-
...ANPersistenceEnabledGatewaySenderDUnitTest.java | 19 +-
.../SerialWANPropagationsFeatureDUnitTest.java | 359 ++-
.../cache/wan/serial/SerialWANStatsDUnitTest.java | 60 +-
.../WANHostNameVerificationDistributedTest.java | 2 +-
.../wan/GatewaySenderEventRemoteDispatcher.java | 36 +-
...atewaySenderEventRemoteDispatcherJUnitTest.java | 25 +-
.../cache/wan/WANRollingUpgradeDUnitTest.java | 5 +-
.../internal/rest/RebalanceIntegrationTest.java | 3 +-
...RedundancyRequestControllerIntegrationTest.java | 3 +-
.../AlterRuntimeCommandDistributedTest.java | 59 +-
.../support/LoginHandlerInterceptorTest.java | 4 +-
gradle.properties | 2 +-
gradle/docker.gradle | 2 +-
gradle/java.gradle | 57 +-
gradle/jmh.gradle | 54 +
gradle/publish-java.gradle | 46 -
gradle/test.gradle | 12 +
gradle/wrapper/gradle-wrapper.properties | 2 +-
settings.gradle | 4 +-
878 files changed, 27227 insertions(+), 22101 deletions(-)
create mode 100644 CODE_OF_CONDUCT.md
create mode 100644 buildSrc/src/main/java/org/apache/geode/gradle/RunInSubdirectoryTestFramework.java
create mode 100644 dev-tools/dependencies/README.md
create mode 100755 dev-tools/dependencies/bump.sh
create mode 100644 extensions/geode-modules-tomcat8/src/test/resources/expected-pom.xml
create mode 100644 extensions/geode-modules/src/test/resources/expected-pom.xml
copy geode-assembly/src/distributedTest/java/org/apache/geode/session/tests/{Tomcat9CachingClientServerTest.java => Tomcat9CachingClientServerValveDisabledTest.java} (89%)
create mode 100644 geode-common/src/jmh/java/org/apache/geode/internal/lang/ComputeIfAbsentBenchmark.java
create mode 100644 geode-common/src/jmhTest/java/org/apache/geode/internal/lang/ComputeIfAbsentBenchmarkTest.java
create mode 100644 geode-common/src/main/java/org/apache/geode/util/internal/CompletionUtils.java
create mode 100644 geode-core/src/distributedTest/java/org/apache/geode/internal/cache/TransactionsWithGIIDistributedTest.java
delete mode 100644 geode-core/src/distributedTest/java/org/apache/geode/internal/cache/partitioned/fixed/FixedPartitioningTestBase.java
delete mode 100644 geode-core/src/distributedTest/java/org/apache/geode/internal/cache/partitioned/fixed/FixedPartitioningTestBaseJUnitTest.java
delete mode 100644 geode-core/src/distributedTest/java/org/apache/geode/internal/cache/partitioned/fixed/MyDate1.java
delete mode 100644 geode-core/src/distributedTest/java/org/apache/geode/internal/cache/partitioned/fixed/MyDate2.java
delete mode 100644 geode-core/src/distributedTest/java/org/apache/geode/internal/cache/partitioned/fixed/MyDate3.java
create mode 100644 geode-core/src/distributedTest/java/org/apache/geode/internal/tcp/ConnectionCloseSSLTLSDUnitTest.java
copy {geode-dunit/src/main/resources/org/apache/geode => geode-core/src/distributedTest/resources/org/apache/geode/internal/tcp}/server.keystore (100%)
rename geode-core/src/{test => integrationTest}/java/org/apache/geode/internal/cache/ReplicateWithExpirationClearIntegrationTest.java (100%)
create mode 100644 geode-core/src/integrationTest/java/org/apache/geode/internal/cache/wan/AbstractGatewaySenderEventProcessorIntegrationTest.java
create mode 100644 geode-core/src/integrationTest/java/org/apache/geode/internal/net/SSLUtilIntegrationTest.java
create mode 100644 geode-core/src/integrationTest/java/org/apache/geode/management/internal/beans/DistributedSystemMBeanIntegrationTest.java
delete mode 100644 geode-core/src/jmh/java/org/apache/geode/internal/util/ComputeIfAbsentBenchmark.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/ha/QueueSynchronizationProcessor.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/net/ByteBufferSharing.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/net/ByteBufferSharingImpl.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/net/ByteBufferSharingNoOp.java
create mode 100644 geode-core/src/test/java/org/apache/geode/distributed/internal/ClusterDistributionManagerTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/FilterProfileTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/ha/QueueSynchronizationProcessorTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/partitioned/RegionAdvisorJUnitTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/net/ByteBufferConcurrencyTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/net/ByteBufferSharingImplTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/ra/spi/JCALocalTransactionTest.java
rename {geode-gfsh/src/test/java/org/apache/geode/management/internal/cli => geode-core/src/test/java/org/apache/geode/management/internal}/json/QueryResultFormatterTest.java (89%)
create mode 100644 geode-dunit/src/distributedTest/java/org/apache/geode/test/dunit/rules/tests/DistributedBlackboardDistributedTest.java
rename geode-dunit/src/distributedTest/java/org/apache/geode/test/dunit/rules/tests/{SharedCountersRuleDistributedTest.java => DistributedCountersDistributedTest.java} (72%)
rename geode-dunit/src/distributedTest/java/org/apache/geode/test/dunit/rules/tests/{SharedErrorCollectorDistributedTest.java => DistributedErrorCollectorDistributedTest.java} (88%)
create mode 100644 geode-dunit/src/distributedTest/java/org/apache/geode/test/dunit/rules/tests/DistributedMapTest.java
copy geode-dunit/src/main/java/org/apache/geode/test/dunit/{internal/InternalBlackboard.java => Blackboard.java} (51%)
mode change 100755 => 100644
create mode 100644 geode-dunit/src/main/java/org/apache/geode/test/dunit/rules/DistributedBlackboard.java
rename geode-dunit/src/main/java/org/apache/geode/test/dunit/rules/{SharedCountersRule.java => DistributedCounters.java} (79%)
rename geode-dunit/src/main/java/org/apache/geode/test/dunit/rules/{SharedErrorCollector.java => DistributedErrorCollector.java} (93%)
create mode 100644 geode-dunit/src/main/java/org/apache/geode/test/dunit/rules/DistributedMap.java
create mode 100644 geode-gfsh/src/distributedTest/java/org/apache/geode/management/internal/cli/commands/CreateDefinedIndexesCommandWithMultipleGfshSessionDUnitTest.java
create mode 100644 geode-gfsh/src/distributedTest/java/org/apache/geode/management/internal/cli/commands/OfflineDiskStoreCommandsDUnitTest.java
create mode 100644 geode-gfsh/src/main/java/org/apache/geode/management/internal/cli/functions/ManageIndexDefinitionFunction.java
create mode 100644 geode-gfsh/src/test/java/org/apache/geode/management/internal/cli/functions/ManageIndexDefinitionFunctionTest.java
copy {geode-common => geode-jmh}/build.gradle (87%)
mode change 100755 => 100644
create mode 100644 geode-jmh/src/main/java/org/apache/geode/benchmark/jmh/profilers/BufferPoolProfiler.java
create mode 100644 geode-jmh/src/main/resources/META-INF/services/org.openjdk.jmh.profile.Profiler
create mode 100644 geode-jmh/src/test/java/org/apache/geode/benchmark/jmh/profilers/BufferPoolProfilerTest.java
create mode 100644 geode-jmh/src/test/resources/expected-pom.xml
create mode 100644 geode-junit/src/main/java/org/apache/geode/management/model/Employee.java
create mode 100644 geode-junit/src/main/java/org/apache/geode/test/junit/rules/CloseableReference.java
copy geode-redis/src/main/java/org/apache/geode/redis/internal/executor/string/PSetEXExecutor.java => geode-junit/src/main/java/org/apache/geode/test/junit/rules/GsRandom.java (60%)
mode change 100755 => 100644
create mode 100644 geode-junit/src/main/java/org/apache/geode/test/junit/rules/RandomRule.java
create mode 100644 geode-junit/src/main/java/org/apache/geode/test/util/StressNewTestHelper.java
create mode 100644 geode-junit/src/test/java/org/apache/geode/test/junit/rules/CloseableReferenceTest.java
create mode 100644 geode-junit/src/test/java/org/apache/geode/test/junit/rules/RandomRuleTest.java
create mode 100644 geode-junit/src/test/java/org/apache/geode/test/util/WhatExtendsJUnitTest.java
create mode 100644 geode-lucene/src/integrationTest/java/org/apache/geode/cache/lucene/internal/IndexRepositoryFactoryIntegrationTest.java
rename {geode-core => geode-membership}/src/main/java/org/apache/geode/internal/AvailablePort.java (96%)
copy geode-redis/src/{main/java/org/apache/geode/redis/internal/executor/string/PSetEXExecutor.java => acceptanceTest/java/org/apache/geode/redis/CommandPipeliningNativeRedisAcceptanceTest.java} (69%)
mode change 100755 => 100644
create mode 100644 geode-redis/src/acceptanceTest/java/org/apache/geode/redis/internal/executor/GeodeRedisServerStartUpAcceptanceTest.java
copy geode-redis/src/{main/java/org/apache/geode/redis/internal/executor/Extendable.java => acceptanceTest/java/org/apache/geode/redis/internal/executor/UnknownNativeRedisAcceptanceTest.java} (72%)
copy geode-redis/src/{main/java/org/apache/geode/redis/internal/executor/key/PTTLExecutor.java => acceptanceTest/java/org/apache/geode/redis/internal/executor/connection/EchoNativeRedisAcceptanceTest.java} (69%)
mode change 100755 => 100644
copy geode-redis/src/{main/java/org/apache/geode/redis/internal/executor/key/PTTLExecutor.java => acceptanceTest/java/org/apache/geode/redis/internal/executor/connection/SelectNativeRedisAcceptanceTest.java} (69%)
mode change 100755 => 100644
copy geode-redis/src/{main/java/org/apache/geode/redis/internal/executor/string/PSetEXExecutor.java => acceptanceTest/java/org/apache/geode/redis/internal/executor/hash/HScanNativeRedisAcceptanceTest.java} (70%)
copy geode-redis/src/{main/java/org/apache/geode/redis/internal/executor/key/PTTLExecutor.java => acceptanceTest/java/org/apache/geode/redis/internal/executor/key/PExpireAtNativeRedisAcceptanceTest.java} (74%)
mode change 100755 => 100644
copy geode-redis/src/{main/java/org/apache/geode/redis/internal/executor/key/PTTLExecutor.java => acceptanceTest/java/org/apache/geode/redis/internal/executor/key/ScanNativeRedisAcceptanceTest.java} (74%)
mode change 100755 => 100644
copy geode-redis/src/{main/java/org/apache/geode/redis/internal/executor/key/PTTLExecutor.java => acceptanceTest/java/org/apache/geode/redis/internal/executor/key/UnlinkNativeRedisAcceptanceTest.java} (74%)
mode change 100755 => 100644
copy geode-redis/src/{main/java/org/apache/geode/redis/internal/executor/string/PSetEXExecutor.java => acceptanceTest/java/org/apache/geode/redis/internal/executor/pubsub/LettucePubSubNativeRedisAcceptanceTest.java} (68%)
copy geode-redis/src/{main/java/org/apache/geode/redis/internal/executor/string/PSetEXExecutor.java => acceptanceTest/java/org/apache/geode/redis/internal/executor/pubsub/SubscriptionsNativeRedisAcceptanceTest.java} (68%)
copy geode-redis/src/{main/java/org/apache/geode/redis/internal/executor/string/PSetEXExecutor.java => acceptanceTest/java/org/apache/geode/redis/internal/executor/server/DBSizeNativeRedisAcceptanceTest.java} (69%)
mode change 100755 => 100644
copy geode-redis/src/{main/java/org/apache/geode/redis/internal/executor/string/PSetEXExecutor.java => acceptanceTest/java/org/apache/geode/redis/internal/executor/server/FlushAllNativeRedisAcceptanceTest.java} (69%)
mode change 100755 => 100644
copy geode-redis/src/{main/java/org/apache/geode/redis/internal/executor/string/PSetEXExecutor.java => acceptanceTest/java/org/apache/geode/redis/internal/executor/server/FlushDBNativeRedisAcceptanceTest.java} (69%)
mode change 100755 => 100644
copy geode-redis/src/{main/java/org/apache/geode/redis/internal/executor/string/PSetEXExecutor.java => acceptanceTest/java/org/apache/geode/redis/internal/executor/server/HitsMissesNativeRedisAcceptanceTest.java} (66%)
mode change 100755 => 100644
copy geode-redis/src/{main/java/org/apache/geode/redis/internal/executor/string/PSetEXExecutor.java => acceptanceTest/java/org/apache/geode/redis/internal/executor/server/InfoNativeRedisAcceptanceTest.java} (66%)
mode change 100755 => 100644
copy geode-redis/src/{main/java/org/apache/geode/redis/internal/executor/string/PSetEXExecutor.java => acceptanceTest/java/org/apache/geode/redis/internal/executor/server/ShutDownNativeRedisAcceptanceTest.java} (69%)
mode change 100755 => 100644
copy geode-redis/src/{main/java/org/apache/geode/redis/internal/executor/string/PSetEXExecutor.java => acceptanceTest/java/org/apache/geode/redis/internal/executor/server/TimeNativeRedisAcceptanceTest.java} (69%)
mode change 100755 => 100644
copy geode-redis/src/{main/java/org/apache/geode/redis/internal/executor/string/PSetEXExecutor.java => acceptanceTest/java/org/apache/geode/redis/internal/executor/set/SScanNativeRedisAcceptanceTest.java} (70%)
create mode 100644 geode-redis/src/commonTest/java/org/apache/geode/NativeRedisTestRule.java
rename geode-redis/src/{integrationTest => commonTest}/java/org/apache/geode/redis/mocks/MockBinarySubscriber.java (100%)
create mode 100644 geode-redis/src/commonTest/java/org/apache/geode/redis/mocks/MockSubscriber.java
rename geode-redis/src/{main/java/org/apache/geode/redis/internal/executor/Extendable.java => commonTest/java/org/apache/geode/test/dunit/rules/RedisPortSupplier.java} (71%)
delete mode 100644 geode-redis/src/distributedTest/java/org/apache/geode/redis/MockSubscriber.java
create mode 100644 geode-redis/src/distributedTest/java/org/apache/geode/redis/internal/executor/hash/HdelDUnitTest.java
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/{CommandPipeliningIntegrationTest.java => AbstractCommandPipeliningIntegrationTest.java} (62%)
create mode 100644 geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/RedisStatsIntegrationTest.java
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/{GlobPatternIntegrationTest.java => AbstractGlobPatternIntegrationTest.java} (92%)
create mode 100644 geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/AbstractUnknownIntegrationTest.java
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/{UnknownIntegrationTest.java => connection/AbstractEchoIntegrationTest.java} (53%)
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/connection/{PingIntegrationTest.java => AbstractPingIntegrationTest.java} (77%)
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/{key/TTLIntegrationTest.java => connection/AbstractSelectIntegrationTest.java} (50%)
copy geode-redis/src/{main/java/org/apache/geode/redis/internal/executor/key/PTTLExecutor.java => integrationTest/java/org/apache/geode/redis/internal/executor/connection/EchoIntegrationTest.java} (69%)
mode change 100755 => 100644
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/connection/{PingIntegrationTest.java => QuitIntegrationTest.java} (55%)
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/{string/PSetEXIntegrationTest.java => connection/SelectIntegrationTest.java} (59%)
mode change 100755 => 100644
create mode 100755 geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/hash/AbstractHScanIntegrationTest.java
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/hash/{HashesIntegrationTest.java => AbstractHashesIntegrationTest.java} (96%)
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/{string/PSetEXIntegrationTest.java => hash/HScanIntegrationTest.java} (51%)
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/key/{DelIntegrationTest.java => AbstractDelIntegrationTest.java} (74%)
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/key/{ExistsIntegrationTest.java => AbstractExistsIntegrationTest.java} (84%)
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/key/{ExpireAtIntegrationTest.java => AbstractExpireAtIntegrationTest.java} (62%)
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/key/{ExpireIntegrationTest.java => AbstractExpireIntegrationTest.java} (82%)
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/key/{KeysIntegrationTest.java => AbstractKeysIntegrationTest.java} (62%)
create mode 100644 geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/key/AbstractPExpireAtIntegrationTest.java
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/key/{PTTLIntegrationTest.java => AbstractPTTLIntegrationTest.java} (70%)
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/key/{PersistIntegrationTest.java => AbstractPersistIntegrationTest.java} (78%)
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/key/{PexpireIntegrationTest.java => AbstractPexpireIntegrationTest.java} (58%)
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/key/{RenameIntegrationTest.java => AbstractRenameIntegrationTest.java} (91%)
create mode 100644 geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/key/AbstractScanIntegrationTest.java
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/key/{TTLIntegrationTest.java => AbstractTTLIntegrationTest.java} (61%)
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/key/{TypeIntegrationTest.java => AbstractTypeIntegrationTest.java} (81%)
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/key/{DelIntegrationTest.java => AbstractUnlinkIntegrationTest.java} (52%)
copy geode-redis/src/{main/java/org/apache/geode/redis/internal/executor/key/PTTLExecutor.java => integrationTest/java/org/apache/geode/redis/internal/executor/key/PExpireAtIntegrationTest.java} (74%)
mode change 100755 => 100644
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/{string/SetEXIntegrationTest.java => key/ScanIntegrationTest.java} (54%)
mode change 100755 => 100644
copy geode-redis/src/{main/java/org/apache/geode/redis/internal/executor/key/PTTLExecutor.java => integrationTest/java/org/apache/geode/redis/internal/executor/key/UnlinkIntegrationTest.java} (74%)
mode change 100755 => 100644
create mode 100644 geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/pubsub/AbstractLettucePubSubIntegrationTest.java
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/pubsub/{PubSubIntegrationTest.java => AbstractPubSubIntegrationTest.java} (75%)
create mode 100644 geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/pubsub/AbstractSubscriptionsIntegrationTest.java
copy geode-redis/src/{main/java/org/apache/geode/redis/internal/executor/string/PSetEXExecutor.java => integrationTest/java/org/apache/geode/redis/internal/executor/pubsub/LettucePubSubIntegrationTest.java} (68%)
mode change 100755 => 100644
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/{string/PSetEXIntegrationTest.java => pubsub/SubscriptionsIntegrationTest.java} (58%)
mode change 100755 => 100644
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/{UnknownIntegrationTest.java => server/AbstractDBSizeIntegrationTest.java} (57%)
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/server/{FlushAllIntegrationTest.java => AbstractFlushAllIntegrationTest.java} (60%)
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/{UnknownIntegrationTest.java => server/AbstractFlushDBIntegrationTest.java} (53%)
create mode 100644 geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/server/AbstractHitsMissesIntegrationTest.java
create mode 100644 geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/server/AbstractInfoIntegrationTest.java
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/server/{ShutdownIntegrationTest.java => AbstractShutDownIntegrationTest.java} (59%)
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/server/{TimeIntegrationTest.java => AbstractTimeIntegrationTest.java} (55%)
copy geode-redis/src/{main/java/org/apache/geode/redis/internal/executor/key/PTTLExecutor.java => integrationTest/java/org/apache/geode/redis/internal/executor/server/DBSizeIntegrationTest.java} (69%)
mode change 100755 => 100644
copy geode-redis/src/{main/java/org/apache/geode/redis/internal/executor/key/PTTLExecutor.java => integrationTest/java/org/apache/geode/redis/internal/executor/server/FlushDBIntegrationTest.java} (69%)
mode change 100755 => 100644
copy geode-redis/src/{main/java/org/apache/geode/redis/internal/executor/string/PSetEXExecutor.java => integrationTest/java/org/apache/geode/redis/internal/executor/server/InfoIntegrationTest.java} (61%)
mode change 100755 => 100644
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/set/{SDiffIntegrationTest.java => AbstractSDiffIntegrationTest.java} (81%)
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/set/{SInterIntegrationTest.java => AbstractSInterIntegrationTest.java} (81%)
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/set/{SIsMemberIntegrationTest.java => AbstractSIsMemberIntegrationTest.java} (59%)
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/set/{SMoveIntegrationTest.java => AbstractSMoveIntegrationTest.java} (68%)
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/set/{SPopIntegrationTest.java => AbstractSPopIntegrationTest.java} (58%)
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/set/{SRemIntegrationTest.java => AbstractSRemIntegrationTest.java} (80%)
create mode 100755 geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/set/AbstractSScanIntegrationTest.java
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/set/{SUnionIntegrationTest.java => AbstractSUnionIntegrationTest.java} (81%)
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/set/{SetsIntegrationTest.java => AbstractSetsIntegrationTest.java} (76%)
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/{string/SetEXIntegrationTest.java => set/SScanIntegrationTest.java} (53%)
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/{AppendIntegrationTest.java => AbstractAppendIntegrationTest.java} (75%)
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/{BitCountIntegrationTest.java => AbstractBitCountIntegrationTest.java} (60%)
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/{BitOpIntegrationTest.java => AbstractBitOpIntegrationTest.java} (74%)
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/{BitCountIntegrationTest.java => AbstractBitPosIntegrationTest.java} (50%)
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/{DecrByIntegrationTest.java => AbstractDecrByIntegrationTest.java} (52%)
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/{DecrIntegrationTest.java => AbstractDecrIntegrationTest.java} (64%)
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/{GetBitIntegrationTest.java => AbstractGetBitIntegrationTest.java} (61%)
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/{GetIntegrationTest.java => AbstractGetIntegrationTest.java} (60%)
create mode 100755 geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/AbstractGetRangeIntegrationTest.java
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/{GetSetIntegrationTest.java => AbstractGetSetIntegrationTest.java} (76%)
create mode 100755 geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/AbstractIncrByFloatIntegrationTest.java
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/{IncrByIntegrationTest.java => AbstractIncrByIntegrationTest.java} (58%)
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/{IncrIntegrationTest.java => AbstractIncrIntegrationTest.java} (63%)
create mode 100644 geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/AbstractLettuceAppendIntegrationTest.java
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/{MGetIntegrationTest.java => AbstractMGetIntegrationTest.java} (64%)
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/{MSetIntegrationTest.java => AbstractMSetIntegrationTest.java} (74%)
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/{MSetNXIntegrationTest.java => AbstractMSetNXIntegrationTest.java} (54%)
create mode 100755 geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/AbstractPSetEXIntegrationTest.java
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/{SetBitIntegrationTest.java => AbstractSetBitIntegrationTest.java} (60%)
create mode 100755 geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/AbstractSetEXIntegrationTest.java
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/{SetIntegrationTest.java => AbstractSetIntegrationTest.java} (79%)
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/{SetNXIntegrationTest.java => AbstractSetNXIntegrationTest.java} (53%)
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/{SetRangeIntegrationTest.java => AbstractSetRangeIntegrationTest.java} (63%)
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/{StrLenIntegrationTest.java => AbstractStrLenIntegrationTest.java} (51%)
copy geode-redis/src/{main/java/org/apache/geode/redis/internal/executor/string/PSetEXExecutor.java => integrationTest/java/org/apache/geode/redis/internal/executor/string/LettuceAppendIntegrationTest.java} (73%)
delete mode 100644 geode-redis/src/integrationTest/java/org/apache/geode/redis/mocks/MockSubscriber.java
copy geode-redis/src/main/java/org/apache/geode/redis/internal/ParameterRequirements/{MaximumParameterRequirements.java => OddParameterRequirements.java} (63%)
copy geode-redis/src/main/java/org/apache/geode/redis/internal/executor/connection/{QuitExecutor.java => SelectExecutor.java} (73%)
create mode 100644 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/server/InfoExecutor.java
copy geode-redis/src/main/java/org/apache/geode/redis/internal/executor/server/{FlushAllExecutor.java => SlowlogExecutor.java} (77%)
mode change 100755 => 100644
rename geode-redis/src/{integrationTest/java/org/apache/geode/redis/mocks/MockSubscriberWithLatch.java => main/java/org/apache/geode/redis/internal/pubsub/SubscribeResult.java} (52%)
delete mode 100644 geode-redis/src/test/java/org/apache/geode/redis/internal/executor/UnknownExecutorJUnitTest.java
delete mode 100644 geode-redis/src/test/java/org/apache/geode/redis/internal/executor/key/AbstractScanExecutorJUnitTest.java
delete mode 100644 geode-redis/src/test/java/org/apache/geode/redis/internal/executor/key/DelExecutorJUnitTest.java
delete mode 100644 geode-redis/src/test/java/org/apache/geode/redis/internal/executor/key/ExistsExecutorJUnitTest.java
delete mode 100644 geode-redis/src/test/java/org/apache/geode/redis/internal/executor/key/ExpireAtExecutorJUnitTest.java
delete mode 100644 geode-redis/src/test/java/org/apache/geode/redis/internal/executor/key/ExpireExecutorJUnitTest.java
delete mode 100644 geode-redis/src/test/java/org/apache/geode/redis/internal/executor/key/KeysExecutorJUnitTest.java
delete mode 100644 geode-redis/src/test/java/org/apache/geode/redis/internal/executor/key/PExpireAtExecutorJUnitTest.java
delete mode 100644 geode-redis/src/test/java/org/apache/geode/redis/internal/executor/key/PTTLExecutorJUnitTest.java
delete mode 100644 geode-redis/src/test/java/org/apache/geode/redis/internal/executor/key/PersistExecutorJUnitTest.java
delete mode 100644 geode-redis/src/test/java/org/apache/geode/redis/internal/executor/key/PexpireExecutorJUnitTest.java
delete mode 100644 geode-redis/src/test/java/org/apache/geode/redis/internal/executor/key/TTLExecutorJUnitTest.java
delete mode 100644 geode-redis/src/test/java/org/apache/geode/redis/internal/executor/set/SetExecutorJUnitTest.java
delete mode 100644 geode-redis/src/test/java/org/apache/geode/redis/internal/executor/string/GetRangeExecutorJUnitTest.java
delete mode 100644 geode-redis/src/test/java/org/apache/geode/redis/internal/executor/string/GetSetExecutorJUnitTest.java
delete mode 100644 geode-redis/src/test/java/org/apache/geode/redis/internal/executor/string/IncrExecutorJUnitTest.java
delete mode 100644 geode-redis/src/test/java/org/apache/geode/redis/internal/executor/string/StringGetExecutorJUnitTest.java
delete mode 100644 geode-redis/src/test/java/org/apache/geode/redis/internal/executor/string/StringMGetExecutorJUnitTest.java
delete mode 100644 geode-redis/src/test/java/org/apache/geode/redis/internal/executor/string/StringMSetExecutorJUnitTest.java
delete mode 100644 geode-redis/src/test/java/org/apache/geode/redis/internal/executor/string/StringSetExecutorJUnitTest.java
delete mode 100644 geode-redis/src/test/java/org/apache/geode/redis/internal/executor/string/StrlenExecutorJUnitTest.java
create mode 100644 gradle/jmh.gradle