This is an automated email from the ASF dual-hosted git repository.
boglesby pushed a change to branch feature/GEODE-8324
in repository https://gitbox.apache.org/repos/asf/geode.git.
discard 514b17a GEODE-8324: Don't add a remote ds id to recipients unless it
is running
add ee9a4b0 GEODE-8259: when client singlehop getAll encountered
SerializationException, it should retry (#5253)
add ffeabe0 GEODE-8239 - Add gradle config to add 'Class-Path' and
'Dependent-Modules' attirbutes to manifest file. (#5317)
add fdc4401 GEODE-8029: Allow OplogEntryIdSet to Overflow (#5329)
add 5e6c9e9 GEODE-8250: Create new custom log config acceptance tests
(#5309)
add 54a21c5 GEODE-8328: Fix GfshRuleIntegrationTest on Windows (#5345)
add ee13af8 GEODE-8327: buildSrc depends directly on guava. Declare it.
Misc other build fixups (#5339)
add 7badfc7 GEODE-8332: Refactor inregion classes (#5320)
add 625a204 GEODE-8323: Process QueueRemovalMessage after queue
initialized. (#5333)
add 868d4bc GEODE-8330: Structural Improvements to Versioning
add 13d17ec GEODE-8313: Improve RedisData synchronization for toData
(#5318)
add 9d7d467 GEODE-8341: Correct docs typo in gfsh export logs (#5352)
add fae1c94 GEODE-7956: Correct documentation of legal region names
(format fix) (#5362)
add 62ee81f GEODE-8346: Add try/catch around Entry.getValue in
CompiledComparison (#5359)
add daa70d7 GEODE-8347: use same benchmarks branch as geode branch, since
that's the way we release (#5361)
add 8c35d9c GEODE-8302: Fixed 'events not queued conflated' stats when
group-tran… (#5313)
add 426b9de GEODE-8200: Rebalance operations stuck in "IN_PROGRESS" state
forever (#5350)
add 25bb3b5 GEODE-8338: change redis commands not be repeated when a
server dies (#5351)
add 9cd8e7d GEODE-8326: remove 5 minutes wait to get stack dump (#5358)
add c41e3b4 GEODE-8355: add `public: true` to the test job in
long-running-test (#5366)
add 1ebd307 GEODE-8351: DUnit tests for Delta Propagation (#5364)
add 0a5a629 GEODE-8348: Add benchmarks EC2 image builder job. (#5367)
add 0f16c0f GEODE-8331: allow GFSH to connect to other versions of
cluster (#5375)
add 86e3266 GEODE-8358: Run Geode Redis session tests against native
Redis (#5373)
add 85ab541 GEODE-8359 (#5371)
add 28fb073 GEODE-8365: Redis Delta not propagating updated hash values
properly (#5377)
add 4b84af3 GEODE-2113: User Guide - p2p.HANDSHAKE_POOL_SIZE is obsolete,
remove from docs (#5383)
add 17d6679 GEODE-8337: git mv Version.java->KnownVersion.java
add 2a3b609 GEODE-8337: git mv VersionOrdinal.java->Version.java
add fd76cc0 GEODE-8298: Fix multicast version detection (#5370)
add 25c15e9 GEODE-8369: Do not build docker images on Windows for
geode-assembly:acceptanceTest (#5384)
add 1067f45 GEODE-8363: Label Micrometer docs as experimental (#5386)
add 6fa5dcb GEODE-7628: Block jmx mbean creation when no security manager
is configured (docs) (#5387)
add 4b91664 GEODE-8362: add redis tests that access binary data (#5374)
add 5365651 GEODE-8371: Move ClassGraph to MIT License (#5388)
add 2a2c2aa GEODE-8370: Add test for maxInactiveInterval (#5385)
add 78e182e Revert "GEODE-8298: Fix multicast version detection (#5370)"
add 12f393d Revert "GEODE-8337: git mv VersionOrdinal.java->Version.java"
add 76a034b Revert "GEODE-8337: git mv Version.java->KnownVersion.java"
add 6a0e2bc GEODE-8377: User Guide: GFSH GC command should be documented
... (#5396)
add f962632 GEODE-8366: Compared the input region's data policy to the
sender instead of the leader region's
add a4306dc GEODE-8316: move RollingUpgradeWithGfshDUnitTest to
geode-assembly since it needs to do installDist first. (#5394)
add a322434 GEODE-8375: No-op test to run Redis server for Geode for
local development (#5392)
add c3cefe1 GEODE-8381: User Guide - Reformat table in REST command
description (#5398)
add 067194e GEODE-8333: Fix PUBSUB hang (#5349)
add 1469eb7 For CI test runs, split the assemble and test invocation, to
set max-test-workers
add ce5e315 GEODE-8383: User Guide - add "Client" to
ssl-enabled-component property table (#5401)
add ee6b3a9 Revert "For CI test runs, split the assemble and test
invocation, to set max-test-workers" (#5407)
add e705128 GEODE-7864: Fix several LGTM warnings (#5400)
add 08316aa GEODE-8385: hang recovering from disk with cyclic
dependencies (#5403)
add de6ab7a GEODE-8331: allow GFSH to connect to other versions of
cluster (#5408)
add 4cea862 GEODE-8331: allow GFSH to connect to other versions of
cluster (doc correction) (#5410)
add 95bba9a Revert "GEODE-8333: Fix PUBSUB hang (#5349)" (#5415)
add 1f1bd1a GEODE-8372: Configure CMS to send UTF-8 regardless of JVM
default (#5411)
add 76573ce GEODE-8391: Skip assertion if unsupported by host (#5412)
add 0a31dd5 GEODE-8384: fix SETEX error message (#5402)
add 42c086b GEODE-8386: fix SRANDMEMBER with negative count (#5404)
add dec583b GEODE-8387: fix SET*STORE commands handling of empty results
(#5405)
add 54421c4 GEODE-8395: fix product name in gfsh help banner (#5417)
add 6e07aac GEODE-8389: reconnect attempt fails due to distribution
configuration… (#5413)
add 53abb22 GEODE-6564: fix entryExpiryTasks leak (#5419)
add a13d72c GEODE-8401: User Guide - incorrect method name on "forced
disconnect" page (#5423)
add eb8668a GEODE-8382: Run Redis tests against Redis API for Geode
(#5416)
add d6c3b1f GEODE-8407: MergeLogFiles fails to include files with the
same name b… (#5428)
add 1a6e192 GEODE-6950: hot loop in PrimaryHandler.processRequest()
(#5422)
add 2b86f66 GEODE-8292: Added check if key is destroyed in CQResults
(#5426)
add ae64bbb GEODE-8191_1: test updated, added bucket initialization after
creation of each child region (#5432)
add fbcf0c6 GEODE-8406: Enable early-return in CI scripts for CI-only
changes (#5427)
add 83d1e28 GEODE-8394: Rewind the message Part on command failure (#5424)
add 4759840 GEODE-8396: Fixing NullPointerException in create
jdbc-mapping command (#5418)
add 6a08bba GEODE-8413: CI failure:
MergeLogFilesIntegrationTest.testDircountZero failes on Windows (#5435)
add 018339f GEODE-8409: S*STORE need to handle target that is not a redis
set (#5429)
add 0a91484 GEODE-8393: change memberDeparted to disconnect the
connection (#5431)
add 52c215c GEODE-8416: Add more Redis tests files to pipeline (#5438)
add eb10815 GEODE-8410: remove offensive language from docs (#5437)
add 0e31dd1 GEODE-8406: Make early-return immune to the Geode dir not
existing (#5440)
add d19368f Revert "GEODE-8393: change memberDeparted to disconnect the
connection (#5431)" (#5441)
add 21e2609 GEODE-8172_1: additional check added (#5444)
add 140de5d GEODE-8423: Updates Redis API for Geode docs 1.13 (#5449)
add cf27a6a Changes to help reduce the occurence of GEODE-8422 (#5447)
add 068a467 GEODE-8337: git mv Version.java->KnownVersion.java
add 415e440 GEODE-8337: git mv VersionOrdinal.java->Version.java
add b5e2b56 GEODE-8298: Fix multicast version detection (#5370)
add 52018fc GEODE-8337: fix support branch creation script to mod
KnownVersion.java
add 71e114f GEODE-8428: Update geode-redis README (#5450)
add b236f1a GEODE-8424: Updates Redis API for Geode docs 1.14 (#5454)
add 5daded4 GEODE-8409: S*STORE need to handle target that is not a redis
set (#5453)
add 3126133 GEODE-8379: Allow microseconds value to be zero (#5456)
add 7ca77cc GEODE-8428: Update geode-redis README (#5455)
add 4637498 GEODE-8427: fix flaky test and do not throw memberDeparted
(#5446)
add 515fd92 GEODE-8430: add dunit test to verify tombstoneGC will not
happen in uninitialized region (#5457)
add 8021084 GEODE-8432: use regionPath directly instead of getRegion when
put eve… (#5459)
add 75a7aa5 Revert "GEODE-8432: use regionPath directly instead of
getRegion when put eve… (#5459)" (#5461)
add 28790ca GEODE-8425: Add new stats for handling netsearch
add be9a232 First pass at switching to liberica jdk. (#5312) (#5458)
add 6f12a36 GEODE-8432: use regionPath directly instead of getRegion when
put eve… (#5464)
add 537721f GEODE-8419: SSL/TLS protocol and cipher suite configuration
is ignored (#5465)
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 be100b3 GEODE-8324: Don't add a remote ds id to recipients unless it
is running
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 (514b17a)
\
N -- N -- N refs/heads/feature/GEODE-8324 (be100b3)
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:
.gitignore | 1 +
CODE_OF_CONDUCT.md | 7 +
README.md | 4 +-
.../src/test/resources/expected-pom.xml | 184 +-
build.gradle | 4 +-
buildSrc/build.gradle | 3 +-
.../gradle/plugins/DependencyConstraints.groovy | 97 +-
ci/docker/Dockerfile | 4 +-
ci/images/alpine-tools/Dockerfile | 2 +-
.../scripts/cache_dependencies.sh | 2 +-
ci/images/google-geode-builder/scripts/setup.sh | 9 +-
ci/images/google-windows-geode-builder/packer.json | 8 +-
ci/images/test-container/Dockerfile | 6 +
ci/pipelines/geode-build/jinja.template.yml | 21 +-
ci/pipelines/images/jinja.template.yml | 43 +-
ci/pipelines/mass-test-run/jinja.template.yml | 3 +-
ci/pipelines/meta/deploy_meta.sh | 43 +-
ci/pipelines/meta/jinja.template.yml | 2 +-
ci/pipelines/pull-request/jinja.template.yml | 66 +-
ci/pipelines/shared/jinja.variables.yml | 22 +-
ci/scripts/archive_results.sh | 2 +
ci/scripts/create_instance.sh | 6 +-
ci/scripts/delete_instance.sh | 3 +
ci/scripts/execute_build.sh | 5 +-
ci/scripts/execute_build_examples.sh | 3 +-
ci/scripts/execute_publish.sh | 3 +-
ci/scripts/execute_redis_tests.sh | 58 +
ci/scripts/execute_tests.sh | 13 +-
ci/scripts/repeat-new-tests.sh | 4 +
ci/scripts/rsync_code_down.sh | 6 +-
ci/scripts/rsync_code_up.sh | 3 +
ci/scripts/run_benchmarks.sh | 9 +-
ci/scripts/shared_utilities.sh | 44 +
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/create_support_branches.sh | 3 +-
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 | 3 +-
docker/README.md | 2 +-
extensions/geode-modules-assembly/build.gradle | 4 +
.../geode-modules-session-internal/build.gradle | 22 +-
extensions/geode-modules-session/build.gradle | 3 +
.../session/filter/SessionCachingFilter.java | 4 +-
extensions/geode-modules-test/build.gradle | 41 +-
.../catalina/AbstractDeltaSessionManagerTest.java | 223 +-
extensions/geode-modules-tomcat7/build.gradle | 62 +-
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 | 59 +-
.../session/catalina/DeltaSessionManager.java | 354 +--
.../catalina/Tomcat6DeltaSessionManager.java | 4 +-
.../src/test/resources/expected-pom.xml | 75 +
geode-assembly/Dockerfile | 3 +-
geode-assembly/build.gradle | 16 +-
.../apache/geode/session/tests/TomcatInstall.java | 6 +-
.../LocatorWithCustomLogConfigAcceptanceTest.java | 288 ++
.../ServerWithCustomLogConfigAcceptanceTest.java | 212 ++
.../internal/cli/shell/DirectoryTree.java | 68 +
.../shell/StatusLocatorExitCodeAcceptanceTest.java | 302 +-
.../shell/StatusServerExitCodeAcceptanceTest.java | 232 +-
...stomLogConfigAcceptanceTestWithGeodePlugins.xml | 49 +
...mLogConfigAcceptanceTestWithoutGeodePlugins.xml | 37 +
...stomLogConfigAcceptanceTestWithGeodePlugins.xml | 49 +
...mLogConfigAcceptanceTestWithoutGeodePlugins.xml | 37 +
.../management/JQFilterVerificationDUnitTest.java | 22 +-
.../cli/commands/StartServerCommandDUnitTest.java | 4 +-
.../rest/ListIndexManagementDUnitTest.java | 3 +-
.../rest/RestoreRedundancyManagementDUnitTest.java | 16 +-
.../session/tests/GenericAppServerInstall.java | 2 +-
...aggerManagementVerificationIntegrationTest.java | 2 +-
.../DevRestSwaggerVerificationIntegrationTest.java | 2 +-
.../test/junit/rules/GfshRuleIntegrationTest.java | 85 +
.../integrationTest/resources/assembly_content.txt | 83 +-
.../resources/dependency_classpath.txt | 77 +-
.../integrationTest/resources/expected_jars.txt | 3 -
geode-assembly/src/main/dist/LICENSE | 6 +-
.../geode/test/junit/rules/GfshRuleTest.java | 51 -
.../management/OperationManagementUpgradeTest.java | 123 +
.../RollingUpgradeWithGfshDUnitTest.java | 128 +
.../source/subnavs/geode-subnav.erb | 9 +-
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/cli/CreateMappingCommand.java | 4 +-
.../jdbc/internal/cli/MappingCommandUtils.java | 11 +
.../jdbc/internal/RegionMappingTest.java | 5 -
.../connectors/jdbc/internal/SqlHandlerTest.java | 106 +-
.../jdbc/internal/SqlToPdxInstanceCreatorTest.java | 5 -
.../jdbc/internal/SqlToPdxInstanceTest.java | 31 +-
.../internal/cli/CreateMappingCommandTest.java | 18 +
.../jdbc/internal/cli/MappingCommandUtilsTest.java | 61 +
geode-core/build.gradle | 32 +-
.../ReplicateCacheListenerDistributedTest.java | 32 +-
.../ReplicateRegionNetsearchDistributedTest.java | 547 ++++
.../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 +-
.../ClientServerCacheOperationDUnitTest.java | 204 ++
.../apache/geode/distributed/LocatorDUnitTest.java | 4 +-
.../ClusterDistributionManagerDUnitTest.java | 32 +-
.../geode/distributed/internal/DateMessage.java | 6 +-
.../internal/DistributionAdvisorDUnitTest.java | 4 +-
...ackwardCompatibilitySerializationDUnitTest.java | 17 +-
.../cache/BucketCreationCrashRegressionTest.java | 4 +-
.../internal/cache/DeltaPropagationDUnitTest.java | 22 +-
.../geode/internal/cache/GIIDeltaDUnitTest.java | 126 +-
...RQueryWithPdxDuringRebalanceRegressionTest.java | 4 +-
.../fixed/FixedPartitioningDUnitTest.java | 2890 ++++++++++++--------
.../fixed/FixedPartitioningTestBase.java | 1289 ---------
.../fixed/FixedPartitioningTestBaseJUnitTest.java | 57 -
...PartitioningWithTransactionDistributedTest.java | 4 +-
.../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 +-
.../DistributedSystemMXBeanDistributedTest.java | 4 +-
...butedSystemMXBeanWithAlertsDistributedTest.java | 4 +-
...stemMXBeanWithNotificationsDistributedTest.java | 4 +-
.../management/JMXMBeanReconnectDUnitTest.java | 4 +-
.../management/MemberMXBeanDistributedTest.java | 17 +-
...BeanFederationErrorHandlingDistributedTest.java | 4 +-
.../internal/util/ManagementUtilsDUnitTest.java | 11 +
.../geode/pdx/PDXAsyncEventQueueDUnitTest.java | 4 +-
.../geode/pdx/PdxAttributesDistributedTest.java | 6 +-
.../apache/geode/pdx/PdxClientServerDUnitTest.java | 8 +-
.../apache/geode/cache/RegionFactoryJUnitTest.java | 49 +
.../cache/client/ClientCacheFactoryJUnitTest.java | 24 +-
.../RestrictUseOfInetAddressJUnitTest.java | 1 -
.../AvailablePortHelperIntegrationTest.java | 175 +-
.../geode/internal/AvailablePortJUnitTest.java | 12 +-
.../apache/geode/internal/SSLConfigJUnitTest.java | 2 +-
.../cache/CompactOfflineDiskStoreJUnitTest.java | 4 +-
.../cache/FilterProfileConcurrencyTest.java | 4 +-
...FOEvictionAlgoMemoryEnabledRegionJUnitTest.java | 4 +-
...eplicateWithExpirationClearIntegrationTest.java | 71 +
.../internal/cache/SimpleDiskRegionJUnitTest.java | 6 +-
.../cache/ha/HARegionQueueIntegrationTest.java | 4 +-
.../cache/tier/sockets/CacheClientProxyTest.java | 4 +-
.../sockets/ServerConnectionIntegrationTest.java | 6 +-
...GatewaySenderEventProcessorIntegrationTest.java | 76 +
.../logging/MergeLogFilesIntegrationTest.java | 32 +
...LSocketHostNameVerificationIntegrationTest.java | 4 +-
.../internal/net/SSLSocketIntegrationTest.java | 4 +-
.../internal/net/SocketCreatorFailHandshake.java | 2 -
.../offheap/OffHeapValidationJUnitTest.java | 4 +-
.../DistributedSystemMBeanIntegrationTest.java | 148 +
.../geode/pdx/AutoSerializableJUnitTest.java | 52 +-
.../org/apache/geode/pdx/ByteSourceJUnitTest.java | 6 +-
.../geode/pdx/PdxInstanceFactoryJUnitTest.java | 4 +-
.../org/apache/geode/pdx/PdxInstanceJUnitTest.java | 4 +-
.../apache/geode/pdx/PdxSerializableJUnitTest.java | 54 +-
.../version/VersionManagerIntegrationTest.java | 54 +
.../codeAnalysis/sanctionedDataSerializables.txt | 14 +-
.../logging/MergeLogFilesIntegrationTest.txt | 1 +
.../geode/internal/logging/dir1/systemlog.txt | 992 +++++++
.../geode/internal/logging/dir2/systemlog.txt | 1571 +++++++++++
.../geode/internal/ra/spi/JCALocalTransaction.java | 63 +-
.../internal/ra/spi/JCAManagedConnection.java | 57 +-
.../internal/InternalDataSerializerBenchmark.java | 6 +-
.../src/main/java/org/apache/geode/CopyHelper.java | 4 +-
.../main/java/org/apache/geode/DataSerializer.java | 6 +-
.../admin/internal/AdminDistributedSystemImpl.java | 2 +-
.../admin/jmx/internal/StatAlertNotification.java | 4 +-
.../geode/cache/client/internal/AbstractOp.java | 8 +-
.../cache/client/internal/AuthenticateUserOp.java | 8 +-
.../client/internal/ClientSideHandshakeImpl.java | 48 +-
.../client/internal/ExecuteFunctionNoAckOp.java | 4 +-
.../cache/client/internal/ExecuteFunctionOp.java | 4 +-
.../internal/ExecuteRegionFunctionNoAckOp.java | 4 +-
.../client/internal/ExecuteRegionFunctionOp.java | 4 +-
.../internal/ExecuteRegionFunctionSingleHopOp.java | 4 +-
.../geode/cache/client/internal/GetAllOp.java | 42 +-
.../geode/cache/client/internal/KeySetOp.java | 4 +-
.../cache/client/internal/ProxyCacheCloseOp.java | 4 +-
.../geode/cache/client/internal/PutAllOp.java | 4 +-
.../geode/cache/client/internal/QueryOp.java | 4 +-
.../cache/client/internal/RegisterInterestOp.java | 4 +-
.../geode/cache/client/internal/RemoveAllOp.java | 4 +-
.../internal/locator/ServerLocationRequest.java | 4 +-
.../internal/locator/ServerLocationResponse.java | 4 +-
.../cache/query/internal/CompiledComparison.java | 13 +-
.../apache/geode/cache/query/internal/CqEntry.java | 4 +-
.../internal/CumulativeNonDistinctResults.java | 4 +-
.../cache/query/internal/LinkedResultSet.java | 4 +-
.../cache/query/internal/LinkedStructSet.java | 4 +-
.../cache/query/internal/NWayMergeResults.java | 4 +-
.../geode/cache/query/internal/NullToken.java | 7 +-
.../cache/query/internal/PRQueryTraceInfo.java | 4 +-
.../geode/cache/query/internal/ResultsBag.java | 4 +-
.../query/internal/ResultsCollectionWrapper.java | 4 +-
.../geode/cache/query/internal/ResultsSet.java | 4 +-
.../cache/query/internal/SortedResultSet.java | 4 +-
.../cache/query/internal/SortedStructSet.java | 4 +-
.../geode/cache/query/internal/StructImpl.java | 4 +-
.../geode/cache/query/internal/StructSet.java | 4 +-
.../geode/cache/query/internal/Undefined.java | 11 +-
.../geode/cache/query/internal/cq/ServerCQ.java | 5 +
.../query/internal/index/CompactRangeIndex.java | 2 +-
.../query/internal/index/IndexCreationData.java | 4 +-
.../cache/query/internal/types/ObjectTypeImpl.java | 4 +-
.../geode/cache/wan/GatewaySenderFactory.java | 7 +-
.../apache/geode/distributed/LocatorLauncher.java | 2 +-
.../internal/ClusterDistributionManager.java | 91 +-
.../distributed/internal/DistributionAdvisor.java | 4 +-
.../distributed/internal/DistributionConfig.java | 23 +-
.../internal/DistributionConfigImpl.java | 40 +-
.../distributed/internal/DistributionImpl.java | 4 +-
.../distributed/internal/DistributionManager.java | 8 +-
.../distributed/internal/DistributionMessage.java | 4 +-
.../internal/InternalConfigAttribute.java | 28 +
.../internal/LonerDistributionManager.java | 14 +-
.../distributed/internal/ReplyProcessor21.java | 14 +-
.../geode/distributed/internal/StartupMessage.java | 4 +-
.../distributed/internal/StartupOperation.java | 1 -
.../internal/StartupResponseMessage.java | 4 +-
.../StartupResponseWithVersionMessage.java | 4 +-
.../internal/locks/DLockRemoteToken.java | 4 +-
.../distributed/internal/locks/DLockService.java | 4 +-
.../membership/InternalDistributedMember.java | 25 +-
.../internal/streaming/StreamingOperation.java | 11 +-
.../org/apache/geode/internal/AvailablePort.java | 579 ----
.../apache/geode/internal/CopyOnWriteHashSet.java | 32 +-
.../org/apache/geode/internal/DSFIDFactory.java | 9 +-
.../org/apache/geode/internal/GemFireVersion.java | 5 -
.../geode/internal/HeapDataOutputStream.java | 10 +-
.../geode/internal/InternalDataSerializer.java | 36 +-
.../apache/geode/internal/VersionDescription.java | 11 -
.../geode/internal/VersionedObjectInput.java | 8 +-
.../geode/internal/VersionedObjectOutput.java | 12 +-
.../org/apache/geode/internal/admin/SSLConfig.java | 376 ---
.../internal/admin/remote/ClientHealthStats.java | 8 +-
.../admin/remote/DistributionLocatorId.java | 2 +-
.../admin/remote/RemoteTransportConfig.java | 2 +-
.../statalerts/GaugeThresholdDecoratorImpl.java | 4 +-
.../statalerts/NumberThresholdDecoratorImpl.java | 4 +-
.../internal/cache/AbstractBucketRegionQueue.java | 4 +-
.../geode/internal/cache/AbstractRegion.java | 5 +
.../internal/cache/AbstractUpdateOperation.java | 4 +-
.../apache/geode/internal/cache/BucketRegion.java | 44 +-
.../geode/internal/cache/BucketRegionQueue.java | 4 +-
.../geode/internal/cache/CachePerfStats.java | 75 +-
.../cache/DestroyPartitionedRegionMessage.java | 6 +-
.../apache/geode/internal/cache/DiskInitFile.java | 44 +-
.../apache/geode/internal/cache/DiskStoreImpl.java | 102 +-
.../internal/cache/DistTXPrecommitMessage.java | 4 +-
.../internal/cache/DistributedPingMessage.java | 4 +-
.../internal/cache/DistributedPutAllOperation.java | 6 +-
.../cache/DistributedTombstoneOperation.java | 6 +-
.../geode/internal/cache/EntryEventImpl.java | 15 +-
.../org/apache/geode/internal/cache/EventID.java | 26 +-
...xpireDisconnectedClientTransactionsMessage.java | 6 +-
.../apache/geode/internal/cache/FilterProfile.java | 69 +-
.../geode/internal/cache/FilterRoutingInfo.java | 29 +-
.../geode/internal/cache/GemFireCacheImpl.java | 75 +-
.../org/apache/geode/internal/cache/HARegion.java | 15 +-
.../internal/cache/InitialImageOperation.java | 82 +-
.../geode/internal/cache/InternalCacheEvent.java | 3 +
.../cache/InvalidatePartitionedRegionMessage.java | 6 +-
.../cache/LatestLastAccessTimeOperation.java | 4 +-
.../apache/geode/internal/cache/LocalRegion.java | 43 +-
.../java/org/apache/geode/internal/cache/Node.java | 4 +-
.../geode/internal/cache/NonLocalRegionEntry.java | 4 +-
.../org/apache/geode/internal/cache/Oplog.java | 360 +--
.../geode/internal/cache/PRQueryProcessor.java | 4 +-
.../internal/cache/PartitionRegionConfig.java | 4 +-
.../geode/internal/cache/PartitionedRegion.java | 53 +-
.../cache/PartitionedRegionQueryEvaluator.java | 4 +-
.../cache/PreferBytesCachedDeserializable.java | 4 +-
.../internal/cache/PrimaryBucketLockException.java | 31 +
.../geode/internal/cache/ProxyRegionMap.java | 4 +-
.../apache/geode/internal/cache/RegionEntry.java | 4 +-
.../geode/internal/cache/RegionEventImpl.java | 4 +-
.../cache/SearchLoadAndWriteProcessor.java | 12 +-
.../geode/internal/cache/ServerPingMessage.java | 4 +-
.../cache/StoreAllCachedDeserializable.java | 4 +-
.../geode/internal/cache/TXCommitMessage.java | 30 +-
.../apache/geode/internal/cache/TXEntryState.java | 9 +-
.../java/org/apache/geode/internal/cache/TXId.java | 4 +-
.../internal/cache/TXRegionLockRequestImpl.java | 8 +-
.../org/apache/geode/internal/cache/TXState.java | 43 +-
.../org/apache/geode/internal/cache/Token.java | 14 +-
.../geode/internal/cache/TombstoneService.java | 28 +-
.../internal/cache/TxCallbackEventFactoryImpl.java | 5 +-
.../internal/cache/VMCachedDeserializable.java | 4 +-
.../geode/internal/cache/ValidatingDiskRegion.java | 4 +-
.../internal/cache/ValueComparisonHelper.java | 4 +-
.../SnappyCompressedCachedDeserializable.java | 4 +-
.../cache/control/InternalResourceManager.java | 18 +-
.../SerializableRegionRedundancyStatusImpl.java | 4 +-
.../SerializableRestoreRedundancyResultsImpl.java | 4 +-
.../entries/AbstractOplogDiskRegionEntry.java | 4 +-
.../cache/entries/AbstractRegionEntry.java | 4 +-
.../geode/internal/cache/entries/DiskEntry.java | 9 +-
.../cache/execute/FunctionRemoteContext.java | 7 +-
.../PartitionedRegionFunctionResultSender.java | 4 +-
.../geode/internal/cache/ha/HARegionQueue.java | 276 +-
.../internal/cache/ha/QueueRemovalMessage.java | 173 +-
.../cache/ha/QueueSynchronizationProcessor.java | 254 ++
.../geode/internal/cache/locks/TXLockBatch.java | 4 +-
.../geode/internal/cache/locks/TXLockIdImpl.java | 4 +-
.../cache/partitioned/BucketCountLoadProbe.java | 4 +-
.../internal/cache/partitioned/DumpB2NRegion.java | 4 +-
.../cache/partitioned/FetchBulkEntriesMessage.java | 10 +-
.../cache/partitioned/FetchEntriesMessage.java | 10 +-
.../cache/partitioned/FetchKeysMessage.java | 10 +-
.../internal/cache/partitioned/GetMessage.java | 4 +-
.../cache/partitioned/IndexCreationMsg.java | 6 +-
.../cache/partitioned/PRTombstoneMessage.java | 6 +-
.../cache/partitioned/PartitionMessage.java | 6 +-
.../PartitionedRegionObserverHolder.java | 7 +-
.../internal/cache/partitioned/QueryMessage.java | 8 +-
.../cache/partitioned/SizedBasedLoadProbe.java | 4 +-
.../partitioned/StreamingPartitionOperation.java | 5 +-
.../internal/cache/persistence/BytesAndBits.java | 8 +-
.../cache/persistence/DiskInitFileInterpreter.java | 4 +-
.../cache/persistence/DiskInitFileParser.java | 23 +-
.../internal/cache/persistence/DiskStoreID.java | 4 +-
.../internal/cache/snapshot/SnapshotPacket.java | 6 +-
.../geode/internal/cache/tier/ConnectionProxy.java | 4 +-
.../internal/cache/tier/ServerSideHandshake.java | 4 +-
.../internal/cache/tier/sockets/AcceptorImpl.java | 6 +-
.../internal/cache/tier/sockets/BaseCommand.java | 8 +-
.../cache/tier/sockets/BaseCommandQuery.java | 8 +-
.../cache/tier/sockets/CacheClientNotifier.java | 12 +-
.../cache/tier/sockets/CacheClientProxy.java | 18 +-
.../tier/sockets/CacheClientProxyFactory.java | 6 +-
.../cache/tier/sockets/CacheClientUpdater.java | 4 +-
.../cache/tier/sockets/CacheServerHelper.java | 4 +-
.../cache/tier/sockets/ChunkedMessage.java | 6 +-
.../tier/sockets/ClientDataSerializerMessage.java | 10 +-
.../cache/tier/sockets/ClientHealthMonitor.java | 9 +-
.../tier/sockets/ClientInstantiatorMessage.java | 8 +-
.../tier/sockets/ClientInterestMessageImpl.java | 10 +-
.../tier/sockets/ClientMarkerMessageImpl.java | 10 +-
.../cache/tier/sockets/ClientPingMessageImpl.java | 10 +-
.../tier/sockets/ClientProxyMembershipID.java | 18 +-
.../ClientRegistrationEventQueueManager.java | 2 +-
.../tier/sockets/ClientRegistrationMetadata.java | 85 +-
.../cache/tier/sockets/ClientTombstoneMessage.java | 6 +-
.../tier/sockets/ClientUpdateMessageImpl.java | 26 +-
.../cache/tier/sockets/CommandInitializer.java | 116 +-
.../internal/cache/tier/sockets/EncryptorImpl.java | 6 +-
.../cache/tier/sockets/HAEventWrapper.java | 4 +-
.../internal/cache/tier/sockets/Handshake.java | 6 +-
.../tier/sockets/InterestResultPolicyImpl.java | 4 +-
.../geode/internal/cache/tier/sockets/Message.java | 16 +-
.../cache/tier/sockets/MessageDispatcher.java | 4 +-
.../cache/tier/sockets/ObjectPartList.java | 4 +-
.../tier/sockets/OldClientSupportService.java | 4 +-
.../geode/internal/cache/tier/sockets/Part.java | 27 +-
.../cache/tier/sockets/ServerConnection.java | 33 +-
.../tier/sockets/ServerSideHandshakeFactory.java | 58 +-
.../tier/sockets/ServerSideHandshakeImpl.java | 38 +-
.../cache/tier/sockets/SocketMessageWriter.java | 15 +-
.../cache/tier/sockets/VersionedObjectList.java | 9 +-
.../tier/sockets/command/CloseConnection.java | 5 +-
.../tier/sockets/command/ExecuteFunction66.java | 4 +-
.../sockets/command/ExecuteRegionFunction66.java | 6 +-
.../command/ExecuteRegionFunctionSingleHop.java | 4 +-
.../sockets/command/GatewayReceiverCommand.java | 4 +-
.../cache/tier/sockets/command/GetAll70.java | 4 +-
.../internal/cache/tier/sockets/command/Put65.java | 16 +-
.../cache/tier/sockets/command/PutAll70.java | 5 +-
.../tier/sockets/command/RegisterInterest.java | 55 +-
.../tier/sockets/command/RegisterInterest61.java | 64 +-
.../tier/sockets/command/RegisterInterestList.java | 82 +-
.../sockets/command/RegisterInterestList61.java | 79 +-
.../sockets/command/RegisterInterestList66.java | 54 +-
.../tier/sockets/command/UnregisterInterest.java | 69 +-
.../sockets/command/UnregisterInterestList.java | 75 +-
.../geode/internal/cache/tx/DistTxEntryEvent.java | 13 +-
.../internal/cache/tx/RemoteFetchKeysMessage.java | 5 +-
.../geode/internal/cache/tx/RemoteGetMessage.java | 4 +-
.../internal/cache/tx/RemotePutAllMessage.java | 4 +-
.../internal/cache/tx/RemoteRemoveAllMessage.java | 4 +-
.../internal/cache/versions/DiskVersionTag.java | 4 +-
.../internal/cache/versions/RVVException.java | 4 +-
.../cache/versions/RegionVersionVector.java | 4 +-
.../internal/cache/versions/VMVersionTag.java | 4 +-
.../geode/internal/cache/versions/VersionTag.java | 4 +-
.../internal/cache/wan/AbstractGatewaySender.java | 18 +-
.../wan/AbstractGatewaySenderEventProcessor.java | 39 +-
.../internal/cache/wan/GatewaySenderAdvisor.java | 11 +-
.../wan/GatewaySenderEventCallbackArgument.java | 4 +-
.../internal/cache/wan/GatewaySenderEventImpl.java | 32 +-
...aySenderQueueEntrySynchronizationOperation.java | 4 +-
.../wan/parallel/ParallelGatewaySenderQueue.java | 77 +-
.../cache/wan/serial/SerialGatewaySenderQueue.java | 52 +-
.../cache/xmlcache/RegionAttributesCreation.java | 9 +
.../org/apache/geode/internal/logging/Banner.java | 5 +-
.../geode/internal/logging/MergeLogFiles.java | 58 +-
.../org/apache/geode/internal/net/BufferPool.java | 79 +-
.../org/apache/geode/internal/net/NioFilter.java | 22 +-
.../apache/geode/internal/net/NioSslEngine.java | 17 +-
.../geode/internal/net/SCClusterSocketCreator.java | 1 -
.../org/apache/geode/internal/net/SSLConfig.java | 375 +++
.../internal/net/SSLConfigurationFactory.java | 1 -
.../org/apache/geode/internal/net/SSLUtil.java | 1 -
.../apache/geode/internal/net/SocketCreator.java | 96 +-
.../geode/internal/net/SocketCreatorFactory.java | 1 -
.../geode/internal/sequencelog/io/GraphReader.java | 4 +-
.../org/apache/geode/internal/tcp/Connection.java | 363 +--
.../apache/geode/internal/tcp/MsgDestreamer.java | 8 +-
.../org/apache/geode/internal/tcp/MsgReader.java | 86 +-
.../org/apache/geode/internal/tcp/MsgStreamer.java | 23 +-
.../tcp/VersionedByteBufferInputStream.java | 14 +-
.../geode/internal/tcp/VersionedMsgStreamer.java | 8 +-
.../org/apache/geode/internal/util/BlobHelper.java | 6 +-
.../ContextAwareSSLRMIClientSocketFactory.java | 2 +-
.../management/internal/FederationComponent.java | 4 +-
.../management/internal/JmxManagerAdvisee.java | 2 +-
.../internal/JmxManagerLocatorRequest.java | 6 +-
.../internal/JmxManagerLocatorResponse.java | 4 +-
.../geode/management/internal/ManagementAgent.java | 2 +-
.../internal/api/GeodeConnectionConfig.java | 2 +-
.../api/LocatorClusterManagementService.java | 43 +-
.../internal/beans/CacheServerBridge.java | 6 +-
.../internal/beans/MemberMBeanBridge.java | 8 +-
.../internal/beans/QueryDataFunction.java | 24 +-
.../internal/beans/stats/GCStatsMonitor.java | 75 +-
.../configuration/domain/Configuration.java | 9 +-
.../internal/configuration/domain/XmlEntity.java | 6 +-
...ClusterManagementServiceInfoRequestHandler.java | 2 +-
.../messages/ConfigurationResponse.java | 4 +-
.../internal/functions/CliFunctionResult.java | 6 +-
.../functions/GetMemberInformationFunction.java | 2 +-
.../internal/json/AbstractJSONFormatter.java | 3 +
.../internal/json/QueryResultFormatter.java | 11 +-
.../operation/OperationHistoryManager.java | 35 +-
.../internal/operation/OperationManager.java | 3 +-
.../internal/operation/OperationState.java | 17 +-
.../internal/operation/OperationStateStore.java | 2 +-
.../operation/RegionOperationStateStore.java | 4 +-
.../operation/RestoreRedundancyPerformer.java | 6 +-
.../internal/security/MBeanServerWrapper.java | 3 +-
.../management/internal/util/ManagementUtils.java | 11 +-
.../java/org/apache/geode/pdx/internal/EnumId.java | 4 +-
.../org/apache/geode/pdx/internal/EnumInfo.java | 6 +-
.../org/apache/geode/pdx/internal/PdxField.java | 6 +-
.../apache/geode/pdx/internal/PdxInstanceEnum.java | 4 +-
.../apache/geode/pdx/internal/PdxOutputStream.java | 6 +-
.../org/apache/geode/pdx/internal/PdxType.java | 6 +-
.../apache/geode/pdx/internal/json/PdxToJSON.java | 6 +-
.../sanctioned-geode-core-serializables.txt | 4 +-
.../cache/client/internal/GetAllOpJUnitTest.java | 101 +
.../cache/execute/FunctionAdapterJUnitTest.java | 4 +-
.../query/internal/CompiledComparisonTest.java | 24 +
.../cache/query/internal/ResultsBagJUnitTest.java | 4 +-
.../internal/DistributionConfigJUnitTest.java | 26 +
.../internal/CopyOnWriteHashSetJUnitTest.java | 20 +
.../geode/internal/DataSerializableJUnitTest.java | 12 +-
.../geode/internal/GemFireVersionJUnitTest.java | 1 -
.../internal/HeapDataOutputStreamJUnitTest.java | 10 +-
...lDataSerializerSerializationAcceptlistTest.java | 4 +-
.../internal/cache/AbstractRegionJUnitTest.java | 4 +-
.../internal/cache/AbstractRegionMapTest.java | 6 +-
.../geode/internal/cache/CachePerfStatsTest.java | 109 +-
.../geode/internal/cache/EntryEventImplTest.java | 198 +-
.../apache/geode/internal/cache/EventIDTest.java | 8 +-
...eDisconnectedClientTransactionsMessageTest.java | 10 +-
.../geode/internal/cache/FilterInfoTest.java | 6 +-
.../geode/internal/cache/FilterProfileTest.java | 258 ++
.../geode/internal/cache/GemFireCacheImplTest.java | 12 +
.../apache/geode/internal/cache/HARegionTest.java | 77 +
.../geode/internal/cache/LocalRegionTest.java | 55 +
.../internal/cache/OplogEntryIdSetJUnitTest.java | 74 -
.../geode/internal/cache/OplogEntryIdSetTest.java | 169 ++
.../geode/internal/cache/TXCommitMessageTest.java | 23 +
.../apache/geode/internal/cache/TXStateTest.java | 92 +
.../geode/internal/cache/TombstoneServiceTest.java | 89 +
.../cache/control/InternalResourceManagerTest.java | 81 +
.../cache/ha/EventIdOptimizationJUnitTest.java | 12 +-
.../geode/internal/cache/ha/HARegionQueueTest.java | 430 ++-
.../internal/cache/ha/QueueRemovalMessageTest.java | 236 ++
.../ha/QueueSynchronizationProcessorTest.java | 155 ++
.../cache/ha/ThreadIdentifierJUnitTest.java | 4 +-
.../partitioned/FetchEntriesMessageJUnitTest.java | 5 +-
.../tier/sockets/CacheClientNotifierTest.java | 2 +-
.../tier/sockets/CacheClientProxyFactoryTest.java | 10 +-
.../ClientRegistrationEventQueueManagerTest.java | 2 +-
.../tier/sockets/CommandInitializerJUnitTest.java | 4 +-
.../cache/tier/sockets/MessageJUnitTest.java | 4 +-
.../internal/cache/tier/sockets/PartTest.java | 105 +
.../cache/tier/sockets/ServerConnectionTest.java | 10 +-
.../tier/sockets/command/ContainsKey66Test.java | 4 +-
.../tier/sockets/command/CreateRegionTest.java | 4 +-
.../cache/tier/sockets/command/Destroy65Test.java | 4 +-
.../tier/sockets/command/DestroyRegionTest.java | 4 +-
.../cache/tier/sockets/command/DestroyTest.java | 4 +-
.../cache/tier/sockets/command/Get70Test.java | 4 +-
.../cache/tier/sockets/command/InvalidateTest.java | 4 +-
.../cache/tier/sockets/command/Put61Test.java | 4 +-
.../cache/tier/sockets/command/Put65Test.java | 4 +-
.../cache/tier/sockets/command/PutTest.java | 4 +-
.../sockets/command/RegisterInterest61Test.java | 4 +-
.../command/RegisterInterestList61Test.java | 4 +-
.../command/RegisterInterestList66Test.java | 4 +-
.../sockets/command/RegisterInterestListTest.java | 4 +-
.../cache/tier/sockets/command/RequestTest.java | 4 +-
.../sockets/command/UnregisterInterestTest.java | 4 +-
.../cache/versions/AbstractVersionTagTestBase.java | 4 +-
.../cache/versions/RegionVersionVectorTest.java | 4 +-
.../cache/wan/GatewaySenderEventImplTest.java | 79 +
.../ParallelGatewaySenderQueueJUnitTest.java | 139 +
.../apache/geode/internal/net/BufferPoolTest.java | 28 +-
.../geode/internal/net/NioPlainEngineTest.java | 3 +-
.../geode/internal/net/NioSslEngineTest.java | 26 +-
.../net/SSLConfigurationFactoryJUnitTest.java | 1 -
.../org/apache/geode/internal/net/SSLUtilTest.java | 2 -
.../geode/internal/net/SocketCreatorJUnitTest.java | 55 +-
.../geode/internal/offheap/DataTypeJUnitTest.java | 4 +-
.../offheap/OffHeapStoredObjectJUnitTest.java | 6 +-
.../internal/ra/spi/JCALocalTransactionTest.java | 63 +
.../geode/internal/size/ObjectTraverserPerf.java | 4 +-
.../apache/geode/internal/tcp/MsgStreamerTest.java | 35 +-
.../apache/geode/internal/tcp/TCPConduitTest.java | 2 +-
.../apache/geode/internal/util/BlobHelperTest.java | 6 +-
.../bean/stats/MemberLevelStatsTest.java | 42 +-
.../api/LocatorClusterManagementServiceTest.java | 56 +-
.../QueryDataFunctionApplyLimitClauseTest.java | 52 +
.../internal/beans/stats/GCStatsMonitorTest.java | 119 +-
.../internal/json/QueryResultFormatterTest.java | 315 +++
.../operation/OperationHistoryManagerTest.java | 35 +-
.../internal/operation/OperationManagerTest.java | 30 +-
.../internal/operation/OperationStateTest.java | 8 +
.../operation/RegionOperationStateStoreTest.java | 6 +-
.../operation/RestoreRedundancyPerformerTest.java | 14 +-
.../pdx/internal/PeerTypeRegistrationTest.java | 8 +-
.../test/version/VersionManagerJUnitTest.java | 49 -
geode-core/src/test/resources/expected-pom.xml | 5 -
.../RollingUpgrade2DUnitTestBase.java | 2 +-
.../rollingupgrade/RollingUpgradeDUnitTest.java | 6 +-
.../RollingUpgradeWithGfshDUnitTest.java | 128 -
geode-cq/build.gradle | 4 +-
.../geode/cache/query/cq/CQDistributedTest.java | 41 +-
.../cache/RemoteCQTransactionDUnitTest.java | 310 ++-
.../geode/security/FilterPostAuthorization.java | 4 +-
.../geode/security/FilterPreAuthorization.java | 4 +-
.../query/cq/internal/CqServiceFactoryImpl.java | 18 +-
.../cache/query/cq/internal/CqServiceImpl.java | 3 +-
.../cache/query/cq/internal/ServerCQImpl.java | 8 +
.../query/cq/internal/ServerCQResultsCache.java | 2 +
.../cq/internal/ServerCQResultsCacheNoOpImpl.java | 5 +
.../ServerCQResultsCachePartitionRegionImpl.java | 5 +
.../ServerCQResultsCacheReplicateRegionImpl.java | 5 +
.../cache/query/cq/internal/ops/CreateCQOp.java | 4 +-
.../query/cq/internal/ops/GetDurableCQsOp.java | 4 +-
.../data_regions/region_naming.html.md.erb | 2 +-
.../running/starting_up_shutting_down.html.md.erb | 14 +-
...ow_client_server_distribution_works.html.md.erb | 2 +-
.../list_of_event_handlers_and_events.html.md.erb | 4 +-
.../chapter_overview.html.md.erb | 2 +-
.../backup_restore_disk_store.html.md.erb | 2 +-
.../compacting_disk_stores.html.md.erb | 22 +-
.../disk_store_configuration_params.html.md.erb | 7 +-
.../disk_storage/using_disk_stores.html.md.erb | 6 +-
.../logging/logging_categories.html.md.erb | 2 +-
.../management/jmx_manager_node.html.md.erb | 2 +
geode-docs/managing/member-reconnect.html.md.erb | 2 +-
.../system_member_performance.html.md.erb | 4 -
...formance_connection_thread_settings.html.md.erb | 32 -
.../JTA_transactions.html.md.erb | 2 +-
geode-docs/reference/statistics_list.html.md.erb | 4 +-
geode-docs/reference/topics/cache_xml.html.md.erb | 6 +-
.../reference/topics/client-cache.html.md.erb | 4 +-
.../topics/gemfire_properties.html.md.erb | 4 +-
geode-docs/reference/topics/glossary.html.md.erb | 2 +-
.../rest_apps/put_update_cas_data.html.md.erb | 78 +-
.../gfsh/command-pages/compact.html.md.erb | 12 +-
.../gfsh/command-pages/connect.html.md.erb | 3 +
.../gfsh/command-pages/create.html.md.erb | 4 +-
.../gfsh/command-pages/export.html.md.erb | 2 +-
.../gfsh/command-pages/gc.html.md.erb | 4 +
.../gfsh/quick_ref_commands_by_area.html.md.erb | 2 +-
.../tomcat_installing_the_module.html.md.erb | 2 +
.../weblogic_setting_up_the_module.html.md.erb | 10 +-
.../micrometer-configuration.html.md.erb | 2 -
.../micrometer/micrometer-overview.html.md.erb | 3 +
.../tools_modules/redis_api_for_geode.html.md.erb | 25 +-
.../multisite_overview.html.md.erb | 11 +-
geode-dunit/build.gradle | 2 +-
...tributedCloseableReferenceCacheExampleTest.java | 64 +
...oseableReferenceLocatorLauncherExampleTest.java | 96 +
...loseableReferenceServerLauncherExampleTest.java | 83 +
...ributedCloseableReferenceSystemExampleTest.java | 64 +
.../DistributedReferenceCacheExampleTest.java | 64 -
...ributedReferenceLocatorLauncherExampleTest.java | 95 -
...tributedReferenceServerLauncherExampleTest.java | 82 -
.../DistributedReferenceSystemExampleTest.java | 63 -
.../dunit/internal/DUnitBlackboardDUnitTest.java | 75 +-
.../DistributedBlackboardDistributedTest.java | 297 ++
.../tests/DistributedCloseableReferenceTest.java | 673 +++++
.../tests/DistributedCountersDistributedTest.java | 265 ++
.../DistributedErrorCollectorDistributedTest.java | 473 ++++
.../rules/tests/DistributedReferenceTest.java | 653 -----
.../tests/SharedCountersRuleDistributedTest.java | 265 --
.../tests/SharedErrorCollectorDistributedTest.java | 473 ----
.../geode/cache30/MultiVMRegionTestCase.java | 4 +-
.../cache/wan/AsyncEventQueueTestBase.java | 6 +-
.../org/apache/geode/test/dunit/Blackboard.java | 79 +
.../apache/geode/test/dunit/DUnitBlackboard.java | 55 +-
.../geode/test/dunit/DistributedTestUtils.java | 71 +-
.../main/java/org/apache/geode/test/dunit/VM.java | 10 +
.../test/dunit/internal/InternalBlackboard.java | 33 +-
.../dunit/internal/InternalBlackboardImpl.java | 59 +-
.../test/dunit/rules/DistributedBlackboard.java | 138 +
.../dunit/rules/DistributedCloseableReference.java | 257 ++
.../test/dunit/rules/DistributedCounters.java | 245 ++
.../dunit/rules/DistributedErrorCollector.java | 139 +
.../test/dunit/rules/DistributedReference.java | 215 --
.../geode/test/dunit/rules/DistributedRule.java | 14 +-
.../geode/test/dunit/rules/SharedCountersRule.java | 245 --
.../test/dunit/rules/SharedErrorCollector.java | 140 -
geode-dunit/src/test/resources/expected-pom.xml | 2 +-
geode-experimental-driver/build.gradle | 5 +-
.../apache/geode/experimental/driver/SSLTest.java | 38 +-
geode-gfsh/build.gradle | 11 +-
...xesCommandWithMultipleGfshSessionDUnitTest.java | 118 +
.../cli/commands/DiskStoreCommandsDUnitTest.java | 20 +
.../OfflineDiskStoreCommandsDUnitTest.java | 246 ++
.../RestoreRedundancyCommandDUnitTest.java | 2 +-
.../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 | 16 +-
.../geode/management/internal/cli/Launcher.java | 2 +-
.../cli/commands/ClearDefinedIndexesCommand.java | 11 +
.../internal/cli/commands/ConnectCommand.java | 85 +-
.../cli/commands/CreateGatewaySenderCommand.java | 14 +-
.../internal/cli/commands/DefineIndexCommand.java | 11 +
.../internal/cli/commands/IndexDefinition.java | 5 +-
.../internal/cli/commands/RedundancyCommand.java | 6 +-
.../functions/ManageIndexDefinitionFunction.java | 40 +
.../geode/management/internal/cli/help/Helper.java | 23 +
.../cli/remote/OnlineCommandProcessor.java | 7 +-
.../geode/management/internal/cli/shell/Gfsh.java | 5 +-
.../internal/cli/shell/GfshExecutionStrategy.java | 20 +-
.../internal/cli/shell/JmxOperationInvoker.java | 2 +-
.../management/internal/cli/util/LogExporter.java | 10 +-
.../sanctioned-geode-gfsh-serializables.txt | 1 +
.../internal/cli/commands/ConnectCommandTest.java | 121 +-
.../commands/CreateGatewaySenderCommandTest.java | 39 +-
.../cli/commands/GfshCommandJUnitTest.java | 28 +
.../cli/functions/GetRegionsFunctionTest.java | 4 +-
.../ManageIndexDefinitionFunctionTest.java | 68 +
.../cli/functions/UserFunctionExecutionTest.java | 5 -
.../cli/json/QueryResultFormatterTest.java | 290 --
.../cli/remote/OnlineCommandProcessorTest.java | 5 +-
.../cli/shell/GfshExecutionStrategyTest.java | 14 +
.../geode/management/GfshCompatibilityTest.java | 89 +
.../geode/internal/cache/InternalHttpService.java | 2 +-
geode-junit/build.gradle | 6 +-
.../AnalyzeDataSerializablesJUnitTestBase.java | 4 +-
.../AnalyzeSerializablesJUnitTestBase.java | 4 +-
.../geode/codeAnalysis/CompiledClassUtils.java | 4 +-
.../apache/geode/internal/AvailablePortHelper.java | 313 +--
.../internal/cache/DiskRegionTestingBase.java | 20 +
.../cache/PartitionedRegionTestHelper.java | 7 +-
.../internal/cache/eviction/LRUTestEntry.java | 4 +-
.../apache/geode/management/model/Employee.java | 94 +
.../org/apache/geode/pdx/NonDelegatingLoader.java | 4 +-
.../assertj/internal/AbstractLogFileAssert.java | 5 +
.../geode/test/junit/rules/CloseableReference.java | 209 ++
.../test/junit/rules/IgnoreOnWindowsRule.java | 2 +-
.../geode/test/junit/rules/gfsh/GfshExecution.java | 146 +-
.../geode/test/junit/rules/gfsh/GfshRule.java | 40 +-
.../geode/test/junit/rules/gfsh/GfshScript.java | 42 +-
.../serializable/SerializableTemporaryFolder.java | 20 +-
.../apache/geode/test/version/VersionManager.java | 196 +-
.../test/junit/rules/CloseableReferenceTest.java | 204 ++
.../test/junit/rules/ExpectedTimeoutRuleTest.java | 4 +-
.../SerializableTemporaryFolderTest.java | 26 +-
...CategoryWithParameterizedRunnerFactoryTest.java | 4 +-
geode-junit/src/test/resources/expected-pom.xml | 4 +-
geode-log4j/build.gradle | 4 +-
geode-lucene/build.gradle | 3 +-
.../internal/LuceneIndexCreationProfile.java | 6 +-
.../lucene/internal/LuceneResultStructImpl.java | 4 +-
.../cache/lucene/internal/LuceneServiceImpl.java | 12 +-
.../cache/lucene/internal/StringQueryProvider.java | 4 +-
.../internal/cli/LuceneDestroyIndexCommand.java | 6 +-
.../lucene/internal/distributed/EntryScore.java | 4 +-
.../distributed/LuceneFunctionContext.java | 4 +-
.../internal/distributed/LuceneQueryFunction.java | 6 +-
.../lucene/internal/distributed/TopEntries.java | 4 +-
.../internal/distributed/TopEntriesCollector.java | 4 +-
.../distributed/TopEntriesCollectorManager.java | 4 +-
.../WaitUntilFlushedFunctionContext.java | 4 +-
.../cache/lucene/internal/filesystem/ChunkKey.java | 4 +-
.../cache/lucene/internal/filesystem/File.java | 4 +-
.../cache/lucene/internal/results/PageResults.java | 6 +-
.../LuceneIndexCreationProfileJUnitTest.java | 4 +-
.../internal/cli/LuceneIndexCommandsJUnitTest.java | 6 +-
.../internal/results/PageEntryJUnitTest.java | 4 +-
.../LuceneSearchWithRollingUpgradeTestBase.java | 33 +-
...ccessfulWhenAllServersRollToCurrentVersion.java | 4 +-
...tTemplateClusterManagementServiceTransport.java | 34 +-
.../geode/management/configuration/Index.java | 4 +-
...plateClusterManagementServiceTransportTest.java | 28 +
.../management/configuration/ClassNameTest.java | 4 +-
.../management/configuration/DeploymentTest.java | 2 +-
.../geode/management/configuration/IndexTest.java | 24 +-
.../management/runtime/DeploymentInfoTest.java | 2 +-
geode-membership/build.gradle | 23 +-
.../MembershipDependenciesJUnitTest.java | 1 +
.../api/MemberIdentifierFactoryImplTest.java | 6 +-
.../membership/api/MembershipAPIArchUnitTest.java | 1 +
.../membership/gms/GMSMemberDataJUnitTest.java | 6 +-
.../gms/GMSMemberDataVersionJUnitTest.java | 11 +-
.../membership/gms/GMSMembershipJUnitTest.java | 135 +-
.../membership/gms/MemberDataBuilderImplTest.java | 6 +-
.../membership/gms/MembershipIntegrationTest.java | 63 +
.../internal/membership/gms/TestMessage.java | 4 +-
.../gms/fd/GMSHealthMonitorJUnitTest.java | 35 +-
.../gms/locator/GMSLocatorIntegrationTest.java | 4 +-
.../locator/GMSLocatorRecoveryIntegrationTest.java | 14 +-
.../gms/membership/GMSJoinLeaveJUnitTest.java | 12 +-
.../gms/messenger/JGroupsMessengerJUnitTest.java | 38 +-
.../membership/gms/util/MemberIdentifierUtil.java | 6 +-
.../internal/membership/api/MemberData.java | 8 +-
.../internal/membership/api/MemberIdentifier.java | 5 +-
.../internal/membership/gms/GMSMemberData.java | 41 +-
.../internal/membership/gms/GMSMembership.java | 102 +-
.../internal/membership/gms/GMSMembershipView.java | 8 +-
.../membership/gms/MemberDataBuilderImpl.java | 4 +-
.../membership/gms/MemberIdentifierImpl.java | 47 +-
.../membership/gms/fd/GMSHealthMonitor.java | 6 +-
.../gms/locator/FindCoordinatorRequest.java | 4 +-
.../gms/locator/FindCoordinatorResponse.java | 4 +-
.../membership/gms/locator/GMSLocator.java | 14 +-
.../membership/gms/locator/GetViewRequest.java | 4 +-
.../membership/gms/locator/GetViewResponse.java | 4 +-
.../gms/locator/MembershipLocatorImpl.java | 4 +-
.../membership/gms/locator/PrimaryHandler.java | 36 +-
.../membership/gms/membership/GMSJoinLeave.java | 13 +-
.../gms/messages/FinalCheckPassedMessage.java | 4 +-
.../membership/gms/messages/HeartbeatMessage.java | 4 +-
.../gms/messages/HeartbeatRequestMessage.java | 4 +-
.../gms/messages/InstallViewMessage.java | 4 +-
.../gms/messages/JoinRequestMessage.java | 4 +-
.../gms/messages/JoinResponseMessage.java | 4 +-
.../gms/messages/LeaveRequestMessage.java | 4 +-
.../gms/messages/NetworkPartitionMessage.java | 4 +-
.../gms/messages/RemoveMemberMessage.java | 4 +-
.../gms/messages/SuspectMembersMessage.java | 4 +-
.../membership/gms/messages/ViewAckMessage.java | 4 +-
.../membership/gms/messenger/GMSPingPonger.java | 6 +-
.../membership/gms/messenger/JGroupsMessenger.java | 50 +-
.../org/apache/geode/internal/AvailablePort.java | 575 ++++
.../membership/gms/locator/PrimaryHandlerTest.java | 87 +
geode-memcached/build.gradle | 1 +
.../apache/geode/OldClientSupportDUnitTest.java | 12 +-
.../gemstone/gemfire/OldClientSupportProvider.java | 10 +-
geode-old-versions/build.gradle | 5 +-
.../acceptance/CacheConnectionIntegrationTest.java | 2 +-
.../v1/acceptance/CacheOperationsJUnitTest.java | 2 +-
.../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 +
.../geode/tools/pulse/tests/rules/ServerRule.java | 2 +-
.../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 -
geode-pulse/src/main/webapp/scripts/lib/jit.js | 2 +-
.../webapp/scripts/lib/jquery.i18n.properties.js | 4 +-
.../main/webapp/scripts/lib/jquery.jqGrid.src.js | 14 +-
geode-pulse/src/main/webapp/scripts/lib/tooltip.js | 4 +-
.../webapp/scripts/pulsescript/PulseCallbacks.js | 1 -
.../src/main/webapp/scripts/pulsescript/common.js | 9 +-
geode-rebalancer/build.gradle | 4 +-
geode-redis/README.md | 398 ++-
geode-redis/build.gradle | 25 +
geode-redis/gfsh.png | Bin 0 -> 16270 bytes
...CommandPipeliningNativeRedisAcceptanceTest.java | 33 +
.../GeodeRedisServerStartUpAcceptanceTest.java | 99 +
.../GlobPatternNativeRedisAcceptanceTest.java | 21 +-
.../connection/AuthNativeRedisAcceptanceTest.java | 6 +-
.../connection/PingNativeRedisAcceptanceTest.java | 23 +-
.../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/PTTLNativeRedisAcceptanceTest.java | 21 +-
.../key/PersistNativeRedisAcceptanceTest.java | 31 +-
.../key/PexpireNativeRedisAcceptanceTest.java | 29 +-
.../key/RenameNativeRedisAcceptanceTest.java | 31 +-
.../key/ScanNativeRedisAcceptanceTest.java | 32 +
.../executor/key/TTLNativeRedisAcceptanceTest.java | 23 +-
.../key/TypeNativeRedisAcceptanceTest.java | 22 +-
.../LettucePubSubNativeRedisAcceptanceTest.java | 32 +
.../pubsub/PubSubNativeRedisAcceptanceTest.java | 41 +-
.../SubscriptionsNativeRedisAcceptanceTest.java | 31 +
.../server/FlushAllNativeRedisAcceptanceTest.java | 32 +
.../server/InfoNativeRedisAcceptanceTest.java | 36 +
.../server/TimeNativeRedisAcceptanceTest.java | 32 +
.../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/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 | 56 +
...NativeRedisSessionExpirationAcceptanceTest.java | 51 +
.../java/org/apache/geode/NativeRedisTestRule.java | 70 +
.../apache/geode/redis/GeodeRedisServerRule.java | 3 +-
.../geode/redis/mocks/MockBinarySubscriber.java | 0
.../apache/geode/redis/mocks/MockSubscriber.java | 231 ++
.../test/dunit/rules/RedisClusterStartupRule.java | 7 +-
.../geode/test/dunit/rules/RedisPortSupplier.java | 21 +
.../geode/redis/CheckPrimaryBucketFunction.java | 12 +-
.../redis/GeodeRedisServerStartupDUnitTest.java | 17 +-
.../org/apache/geode/redis/MockSubscriber.java | 62 -
.../geode/redis/internal/data/DeltaDUnitTest.java | 231 ++
.../executor/CrashAndNoRepeatDUnitTest.java | 333 +++
.../executor/hash/HashesAndCrashesDUnitTest.java | 346 +++
.../internal/executor/pubsub/PubSubDUnitTest.java | 239 +-
.../geode/redis/session/RedisSessionDUnitTest.java | 166 ++
.../redis/session/RedisSessionDistDUnitTest.java | 118 -
.../geode/redis/session/SessionDUnitTest.java | 105 +-
.../redis/session/SessionExpirationDUnitTest.java | 91 +-
.../SessionController.java | 6 +
.../config/DUnitSocketAddressResolver.java | 6 +
.../AbstractCommandPipeliningIntegrationTest.java | 124 +
.../redis/CommandPipeliningIntegrationTest.java | 76 +-
.../java/org/apache/geode/redis/SSLTest.java | 2 +-
.../geode/redis/internal/GeodeServerRunTest.java | 38 +
.../redis/internal/RedisStatsIntegrationTest.java | 43 +
.../AbstractGlobPatternIntegrationTest.java | 255 ++
.../executor/GlobPatternIntegrationTest.java | 240 +-
.../internal/executor/UnknownIntegrationTest.java | 2 +-
.../connection/AbstractPingIntegrationTest.java | 75 +
.../executor/connection/AuthIntegrationTest.java | 3 -
.../executor/connection/PingIntegrationTest.java | 56 +-
.../executor/connection/QuitIntegrationTest.java | 83 +
.../hash/AbstractHashesIntegrationTest.java | 735 +++++
.../executor/hash/HashesIntegrationTest.java | 697 +----
.../executor/key/AbstractDelIntegrationTest.java | 118 +
.../key/AbstractExistsIntegrationTest.java | 189 ++
.../key/AbstractExpireAtIntegrationTest.java | 121 +
.../key/AbstractExpireIntegrationTest.java | 341 +++
.../executor/key/AbstractKeysIntegrationTest.java | 101 +
.../executor/key/AbstractPTTLIntegrationTest.java | 74 +
.../key/AbstractPersistIntegrationTest.java | 142 +
.../key/AbstractPexpireIntegrationTest.java | 91 +
.../key/AbstractRenameIntegrationTest.java | 405 +++
.../executor/key/AbstractScanIntegrationTest.java | 112 +
.../executor/key/AbstractTTLIntegrationTest.java | 74 +
.../executor/key/AbstractTypeIntegrationTest.java | 84 +
.../internal/executor/key/DelIntegrationTest.java | 93 +-
.../executor/key/ExistsIntegrationTest.java | 174 +-
.../executor/key/ExpireAtIntegrationTest.java | 110 +-
.../executor/key/ExpireIntegrationTest.java | 324 +--
.../internal/executor/key/KeysIntegrationTest.java | 75 +-
.../internal/executor/key/PTTLIntegrationTest.java | 59 +-
.../executor/key/PersistIntegrationTest.java | 128 +-
.../executor/key/PexpireIntegrationTest.java | 75 +-
.../executor/key/RenameIntegrationTest.java | 398 +--
.../internal/executor/key/ScanIntegrationTest.java | 32 +
.../internal/executor/key/TTLIntegrationTest.java | 59 +-
.../internal/executor/key/TypeIntegrationTest.java | 68 +-
.../AbstractLettucePubSubIntegrationTest.java | 375 +++
.../pubsub/AbstractPubSubIntegrationTest.java | 896 ++++++
.../AbstractSubscriptionsIntegrationTest.java | 105 +
.../pubsub/LettucePubSubIntegrationTest.java | 32 +
.../executor/pubsub/PubSubIntegrationTest.java | 655 +----
.../pubsub/SubscriptionsIntegrationTest.java | 53 +
.../server/AbstractFlushAllIntegrationTest.java | 58 +
.../server/AbstractInfoIntegrationTest.java | 170 ++
.../server/AbstractTimeIntegrationTest.java | 56 +
.../executor/server/FlushAllIntegrationTest.java | 35 +-
.../executor/server/InfoIntegrationTest.java | 39 +
.../executor/server/ShutdownIntegrationTest.java | 6 +-
.../executor/server/TimeIntegrationTest.java | 42 +-
.../executor/set/AbstractSDiffIntegrationTest.java | 190 ++
.../set/AbstractSInterIntegrationTest.java | 193 ++
.../set/AbstractSIsMemberIntegrationTest.java | 82 +
.../executor/set/AbstractSMoveIntegrationTest.java | 128 +
.../executor/set/AbstractSPopIntegrationTest.java | 217 ++
.../executor/set/AbstractSRemIntegrationTest.java | 172 ++
.../set/AbstractSUnionIntegrationTest.java | 183 ++
.../executor/set/AbstractSetsIntegrationTest.java | 248 ++
.../executor/set/SDiffIntegrationTest.java | 153 +-
.../executor/set/SInterIntegrationTest.java | 153 +-
.../executor/set/SIsMemberIntegrationTest.java | 68 +-
.../executor/set/SMoveIntegrationTest.java | 122 +-
.../internal/executor/set/SPopIntegrationTest.java | 168 +-
.../internal/executor/set/SRemIntegrationTest.java | 166 +-
.../executor/set/SUnionIntegrationTest.java | 146 +-
.../internal/executor/set/SetsIntegrationTest.java | 223 +-
.../string/AbstractAppendIntegrationTest.java | 115 +
.../string/AbstractBitCountIntegrationTest.java | 149 +
.../string/AbstractBitOpIntegrationTest.java | 200 ++
.../string/AbstractBitPosIntegrationTest.java | 67 +
.../string/AbstractDecrByIntegrationTest.java | 77 +
.../string/AbstractDecrIntegrationTest.java | 82 +
.../string/AbstractGetBitIntegrationTest.java | 77 +
.../string/AbstractGetIntegrationTest.java | 82 +
.../string/AbstractGetRangeIntegrationTest.java | 135 +
.../string/AbstractGetSetIntegrationTest.java | 154 ++
.../string/AbstractIncrByFloatIntegrationTest.java | 65 +
.../string/AbstractIncrByIntegrationTest.java | 76 +
.../string/AbstractIncrIntegrationTest.java | 112 +
.../string/AbstractMGetIntegrationTest.java | 57 +
.../string/AbstractMSetIntegrationTest.java | 151 +
.../string/AbstractMSetNXIntegrationTest.java | 64 +
.../string/AbstractPSetEXIntegrationTest.java | 47 +
.../string/AbstractSetBitIntegrationTest.java | 86 +
.../string/AbstractSetEXIntegrationTest.java | 54 +
.../string/AbstractSetIntegrationTest.java | 505 ++++
.../string/AbstractSetNXIntegrationTest.java | 61 +
.../string/AbstractSetRangeIntegrationTest.java | 98 +
.../string/AbstractStrLenIntegrationTest.java | 78 +
.../executor/string/AppendIntegrationTest.java | 84 +-
.../executor/string/BitCountIntegrationTest.java | 129 +-
.../executor/string/BitOpIntegrationTest.java | 186 +-
.../executor/string/BitPosIntegrationTest.java | 43 +-
.../executor/string/DecrByIntegrationTest.java | 63 +-
.../executor/string/DecrIntegrationTest.java | 68 +-
.../executor/string/GetBitIntegrationTest.java | 63 +-
.../executor/string/GetIntegrationTest.java | 59 +-
.../executor/string/GetRangeIntegrationTest.java | 121 +-
.../executor/string/GetSetIntegrationTest.java | 140 +-
.../string/IncrByFloatIntegrationTest.java | 51 +-
.../executor/string/IncrByIntegrationTest.java | 62 +-
.../executor/string/IncrIntegrationTest.java | 98 +-
.../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 | 33 +-
.../executor/string/SetIntegrationTest.java | 477 +---
.../executor/string/SetNXIntegrationTest.java | 47 +-
.../executor/string/SetRangeIntegrationTest.java | 84 +-
.../executor/string/StrLenIntegrationTest.java | 55 +-
.../pubsub/SubscriptionsIntegrationTest.java | 17 +-
.../geode/redis/mocks/DummySubscription.java | 6 +
.../apache/geode/redis/mocks/MockSubscriber.java | 99 -
.../geode/redis/mocks/MockSubscriberWithLatch.java | 47 -
.../codeAnalysis/sanctionedDataSerializables.txt | 12 +-
.../geode/redis/internal/GeodeRedisServer.java | 31 +-
.../EvenParameterRequirements.java | 2 +-
.../ExactParameterRequirements.java | 2 +-
.../MaximumParameterRequirements.java | 20 +-
.../MinimumParameterRequirements.java | 4 +-
.../ParameterRequirements.java | 1 -
.../redis/internal/PassiveExpirationManager.java | 4 +-
.../geode/redis/internal/RedisCommandType.java | 21 +-
.../apache/geode/redis/internal/RedisStats.java | 6 +
.../redis/internal/data/AbstractRedisData.java | 44 +-
.../redis/internal/data/ByteArrayWrapper.java | 10 +-
.../geode/redis/internal/data/CommandHelper.java | 147 +
.../geode/redis/internal/data/EmptyRedisHash.java | 48 -
.../geode/redis/internal/data/EmptyRedisSet.java | 79 -
.../geode/redis/internal/data/NullRedisData.java | 116 +
.../geode/redis/internal/data/NullRedisHash.java | 61 +
.../geode/redis/internal/data/NullRedisSet.java | 184 ++
.../geode/redis/internal/data/NullRedisString.java | 314 +++
.../geode/redis/internal/data/RedisData.java | 23 +
.../data/RedisDataCommandsFunctionExecutor.java | 49 +
.../geode/redis/internal/data/RedisHash.java | 57 +-
.../data/RedisHashCommandsFunctionExecutor.java | 108 +
.../redis/internal/data/RedisHashInRegion.java | 140 -
.../data/RedisKeyCommandsFunctionExecutor.java | 65 +
.../redis/internal/data/RedisKeyInRegion.java | 126 -
.../apache/geode/redis/internal/data/RedisSet.java | 42 +-
.../data/RedisSetCommandsFunctionExecutor.java | 111 +
.../redis/internal/data/RedisSetInRegion.java | 258 --
.../geode/redis/internal/data/RedisString.java | 84 +-
.../data/RedisStringCommandsFunctionExecutor.java | 154 ++
.../redis/internal/data/RedisStringInRegion.java | 483 ----
.../redis/internal/delta/AppendDeltaInfo.java | 9 +-
.../redis/internal/executor/AbstractExecutor.java | 4 +-
.../redis/internal/executor/CommandFunction.java | 337 +--
.../geode/redis/internal/executor/GlobPattern.java | 2 +-
.../executor/RedisCommandsFunctionInvoker.java | 74 +
.../redis/internal/executor/RedisResponse.java | 16 +
.../executor/SingleResultRedisFunction.java | 32 +-
.../internal/executor/connection/PingExecutor.java | 32 +-
.../internal/executor/connection/QuitExecutor.java | 3 +
.../internal/executor/hash/HScanExecutor.java | 2 +-
.../redis/internal/executor/hash/HashExecutor.java | 2 +-
.../hash/RedisHashCommandsFunctionExecutor.java | 115 -
.../hash/RedisHashCommandsFunctionInvoker.java | 118 +
.../internal/executor/key/ExpireExecutor.java | 2 +-
.../internal/executor/key/PersistExecutor.java | 2 +-
.../key/RedisKeyCommandsFunctionExecutor.java | 101 -
.../key/RedisKeyCommandsFunctionInvoker.java | 88 +
.../internal/executor/key/RenameFunction.java | 60 +-
.../redis/internal/executor/key/ScanExecutor.java | 37 +-
.../executor/pubsub/PsubscribeExecutor.java | 51 +-
.../internal/executor/pubsub/PublishExecutor.java | 9 +-
.../executor/pubsub/PunsubscribeExecutor.java | 2 +
.../executor/pubsub/SubscribeExecutor.java | 44 +-
.../executor/pubsub/UnsubscribeExecutor.java | 2 +
.../internal/executor/server/InfoExecutor.java | 97 +
.../set/RedisSetCommandsFunctionExecutor.java | 104 -
.../set/RedisSetCommandsFunctionInvoker.java | 107 +
.../redis/internal/executor/set/SPopExecutor.java | 15 +-
.../redis/internal/executor/set/SScanExecutor.java | 2 +-
.../redis/internal/executor/set/SetExecutor.java | 2 +-
.../RedisStringCommandsFunctionExecutor.java | 144 -
.../string/RedisStringCommandsFunctionInvoker.java | 149 +
.../internal/executor/string/SetEXExecutor.java | 2 +-
.../internal/executor/string/StringExecutor.java | 2 +-
.../apache/geode/redis/internal/netty/Client.java | 8 +
.../apache/geode/redis/internal/netty/Coder.java | 7 +-
.../apache/geode/redis/internal/netty/Command.java | 37 +-
.../internal/netty/ExecutionHandlerContext.java | 280 +-
.../redis/internal/netty/NettyRedisServer.java | 35 +-
.../internal/pubsub/AbstractSubscription.java | 92 +-
.../redis/internal/pubsub/ChannelSubscription.java | 5 +-
.../redis/internal/pubsub/PatternSubscription.java | 5 +-
.../apache/geode/redis/internal/pubsub/PubSub.java | 8 +-
.../geode/redis/internal/pubsub/PubSubImpl.java | 10 +-
.../redis/internal/pubsub/SubscribeResult.java | 47 +
.../geode/redis/internal/pubsub/Subscription.java | 7 +
.../geode/redis/internal/pubsub/Subscriptions.java | 23 +-
.../sanctioned-geode-redis-serializables.txt | 6 +-
.../redis/internal/SupportedCommandsJUnitTest.java | 2 +-
.../geode/redis/internal/data/RedisHashTest.java | 2 +-
.../geode/redis/internal/data/RedisSetTest.java | 2 +-
.../redis/internal/pubsub/PubSubImplJUnitTest.java | 14 +-
.../internal/pubsub/SubscriptionsJUnitTest.java | 65 +-
.../internal/serialization/AbstractVersion.java | 124 +
.../serialization/BufferDataOutputStream.java | 12 +-
.../internal/serialization/ByteArrayDataInput.java | 8 +-
.../serialization/DSFIDNotFoundException.java | 2 +-
.../serialization/DataSerializableFixedID.java | 9 +-
.../serialization/DeserializationContext.java | 2 +-
.../geode/internal/serialization/KnownVersion.java | 415 +++
.../serialization/SerializationContext.java | 2 +-
.../serialization/SerializationVersions.java | 2 +-
.../serialization/StaticSerialization.java | 28 +-
.../internal/serialization/UnknownVersion.java | 26 +
.../geode/internal/serialization/Version.java | 558 +---
.../internal/serialization/VersionOrdinal.java | 83 -
.../internal/serialization/VersionOrdinalImpl.java | 136 -
.../serialization/VersionedDataInputStream.java | 6 +-
.../serialization/VersionedDataOutputStream.java | 6 +-
.../serialization/VersionedDataStream.java | 8 +-
.../geode/internal/serialization/Versioning.java | 49 +-
.../geode/internal/serialization/VersioningIO.java | 114 +
.../internal/AbstractSerializationContext.java | 10 +-
.../internal/DSFIDSerializerImpl.java | 18 +-
.../internal/DeserializationContextImpl.java | 4 +-
.../internal/SerializationContextImpl.java | 4 +-
.../BufferDataOutputStreamJUnitTest.java | 6 +-
.../serialization/ByteArrayDataInputTest.java | 8 +-
.../serialization/KnownVersionJUnitTest.java | 102 +
.../SerializationDependenciesJUnitTest.java | 3 +-
.../serialization/UnknownVersionJUnitTest.java | 131 +
.../internal/serialization/VersionJUnitTest.java | 114 -
.../serialization/VersionOrdinalImplJUnitTest.java | 127 -
.../serialization/VersioningJUnitTest.java | 73 +
.../internal/tcpserver/HostAndPort.java | 4 +-
.../distributed/internal/tcpserver/TcpClient.java | 49 +-
.../distributed/internal/tcpserver/TcpServer.java | 30 +-
.../internal/tcpserver/VersionRequest.java | 4 +-
.../internal/tcpserver/VersionResponse.java | 4 +-
.../internal/tcpserver/HostAndPortTest.java | 8 +-
.../tcpserver/TcpServerDependenciesTest.java | 3 +-
geode-wan/build.gradle | 7 +-
.../internal/cache/UpdateVersionDUnitTest.java | 6 +-
...SenderWithIsolatedDiskStoreDistributedTest.java | 348 ---
.../geode/internal/cache/wan/WANTestBase.java | 353 +--
.../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 | 19 +-
.../parallel/ParallelWANPropagationDUnitTest.java | 328 ++-
.../ParallelWANPropagationLoopBackDUnitTest.java | 310 ++-
.../wan/parallel/ParallelWANStatsDUnitTest.java | 92 +-
.../cache/wan/serial/GatewayReceiverDUnitTest.java | 4 +-
.../SerialGatewaySenderEventListenerDUnitTest.java | 4 +-
...ANPersistenceEnabledGatewaySenderDUnitTest.java | 19 +-
...lWANPropagation_PartitionedRegionDUnitTest.java | 2 +
.../SerialWANPropagationsFeatureDUnitTest.java | 359 ++-
.../cache/wan/serial/SerialWANStatsDUnitTest.java | 64 +-
.../WANHostNameVerificationDistributedTest.java | 2 +-
.../cache/wan/misc/WANConfigurationJUnitTest.java | 12 +
.../locator/wan/RemoteLocatorJoinRequest.java | 4 +-
.../locator/wan/RemoteLocatorJoinResponse.java | 4 +-
.../locator/wan/RemoteLocatorPingRequest.java | 4 +-
.../locator/wan/RemoteLocatorPingResponse.java | 4 +-
.../internal/locator/wan/RemoteLocatorRequest.java | 4 +-
.../locator/wan/RemoteLocatorResponse.java | 4 +-
.../wan/GatewaySenderEventRemoteDispatcher.java | 3 +-
.../cache/wan/GatewaySenderFactoryImpl.java | 6 +
.../RemoteParallelGatewaySenderEventProcessor.java | 5 +-
...atewaySenderEventRemoteDispatcherJUnitTest.java | 24 +-
...ateGatewaySenderMixedSiteOneCurrentSiteTwo.java | 4 +-
.../cache/wan/WANRollingUpgradeDUnitTest.java | 5 +-
.../geode/rest/internal/web/util/JSONUtils.java | 14 +-
.../internal/rest/JsonSerializationTest.java | 2 +
.../internal/rest/RebalanceIntegrationTest.java | 3 +-
...RedundancyRequestControllerIntegrationTest.java | 3 +-
.../controllers/ManagementControllerAdvice.java | 3 +-
.../CustomMappingJackson2HttpMessageConverter.java | 85 +-
.../rest/security/RestSecurityConfiguration.java | 5 +-
.../web/controllers/ShellCommandsController.java | 4 +-
.../support/LoginHandlerInterceptorTest.java | 4 +-
gradle/docker.gradle | 2 +-
gradle/java.gradle | 2 +
gradle/publish-java.gradle | 12 +-
gradle/sonar.gradle | 24 -
gradle/standard-subproject-configuration.gradle | 15 +-
gradle/test.gradle | 15 +
settings.gradle | 3 +-
1178 files changed, 40252 insertions(+), 24870 deletions(-)
create mode 100644 CODE_OF_CONDUCT.md
create mode 100755 ci/scripts/execute_redis_tests.sh
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
create mode 100644
geode-assembly/src/acceptanceTest/java/org/apache/geode/logging/LocatorWithCustomLogConfigAcceptanceTest.java
create mode 100644
geode-assembly/src/acceptanceTest/java/org/apache/geode/logging/ServerWithCustomLogConfigAcceptanceTest.java
create mode 100644
geode-assembly/src/acceptanceTest/java/org/apache/geode/management/internal/cli/shell/DirectoryTree.java
create mode 100644
geode-assembly/src/acceptanceTest/resources/org/apache/geode/logging/LocatorWithCustomLogConfigAcceptanceTestWithGeodePlugins.xml
create mode 100644
geode-assembly/src/acceptanceTest/resources/org/apache/geode/logging/LocatorWithCustomLogConfigAcceptanceTestWithoutGeodePlugins.xml
create mode 100644
geode-assembly/src/acceptanceTest/resources/org/apache/geode/logging/ServerWithCustomLogConfigAcceptanceTestWithGeodePlugins.xml
create mode 100644
geode-assembly/src/acceptanceTest/resources/org/apache/geode/logging/ServerWithCustomLogConfigAcceptanceTestWithoutGeodePlugins.xml
create mode 100644
geode-assembly/src/integrationTest/java/org/apache/geode/test/junit/rules/GfshRuleIntegrationTest.java
delete mode 100644
geode-assembly/src/test/java/org/apache/geode/test/junit/rules/GfshRuleTest.java
create mode 100644
geode-assembly/src/upgradeTest/java/org/apache/geode/management/OperationManagementUpgradeTest.java
create mode 100644
geode-assembly/src/upgradeTest/java/org/apache/geode/management/RollingUpgradeWithGfshDUnitTest.java
create mode 100644
geode-core/src/distributedTest/java/org/apache/geode/cache/ReplicateRegionNetsearchDistributedTest.java
create mode 100644
geode-core/src/distributedTest/java/org/apache/geode/cache30/ClientServerCacheOperationDUnitTest.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/integrationTest/java/org/apache/geode/internal/cache/ReplicateWithExpirationClearIntegrationTest.java
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/management/internal/beans/DistributedSystemMBeanIntegrationTest.java
create mode 100755
geode-core/src/integrationTest/java/org/apache/geode/test/version/VersionManagerIntegrationTest.java
create mode 100644
geode-core/src/integrationTest/resources/org/apache/geode/internal/logging/MergeLogFilesIntegrationTest.txt
create mode 100644
geode-core/src/integrationTest/resources/org/apache/geode/internal/logging/dir1/systemlog.txt
create mode 100644
geode-core/src/integrationTest/resources/org/apache/geode/internal/logging/dir2/systemlog.txt
create mode 100644
geode-core/src/main/java/org/apache/geode/distributed/internal/InternalConfigAttribute.java
delete mode 100644
geode-core/src/main/java/org/apache/geode/internal/AvailablePort.java
delete mode 100755
geode-core/src/main/java/org/apache/geode/internal/admin/SSLConfig.java
create mode 100644
geode-core/src/main/java/org/apache/geode/internal/cache/PrimaryBucketLockException.java
create mode 100644
geode-core/src/main/java/org/apache/geode/internal/cache/ha/QueueSynchronizationProcessor.java
create mode 100755
geode-core/src/main/java/org/apache/geode/internal/net/SSLConfig.java
create mode 100644
geode-core/src/test/java/org/apache/geode/cache/client/internal/GetAllOpJUnitTest.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/HARegionTest.java
delete mode 100644
geode-core/src/test/java/org/apache/geode/internal/cache/OplogEntryIdSetJUnitTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/internal/cache/OplogEntryIdSetTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/internal/cache/TombstoneServiceTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/internal/cache/ha/QueueRemovalMessageTest.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/ra/spi/JCALocalTransactionTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/management/internal/json/QueryResultFormatterTest.java
delete mode 100755
geode-core/src/test/java/org/apache/geode/test/version/VersionManagerJUnitTest.java
delete mode 100644
geode-core/src/upgradeTest/java/org/apache/geode/internal/cache/rollingupgrade/RollingUpgradeWithGfshDUnitTest.java
delete mode 100644
geode-docs/managing/monitor_tune/system_member_performance_connection_thread_settings.html.md.erb
create mode 100644
geode-dunit/src/distributedTest/java/org/apache/geode/test/dunit/examples/DistributedCloseableReferenceCacheExampleTest.java
create mode 100644
geode-dunit/src/distributedTest/java/org/apache/geode/test/dunit/examples/DistributedCloseableReferenceLocatorLauncherExampleTest.java
create mode 100644
geode-dunit/src/distributedTest/java/org/apache/geode/test/dunit/examples/DistributedCloseableReferenceServerLauncherExampleTest.java
create mode 100644
geode-dunit/src/distributedTest/java/org/apache/geode/test/dunit/examples/DistributedCloseableReferenceSystemExampleTest.java
delete mode 100644
geode-dunit/src/distributedTest/java/org/apache/geode/test/dunit/examples/DistributedReferenceCacheExampleTest.java
delete mode 100644
geode-dunit/src/distributedTest/java/org/apache/geode/test/dunit/examples/DistributedReferenceLocatorLauncherExampleTest.java
delete mode 100644
geode-dunit/src/distributedTest/java/org/apache/geode/test/dunit/examples/DistributedReferenceServerLauncherExampleTest.java
delete mode 100644
geode-dunit/src/distributedTest/java/org/apache/geode/test/dunit/examples/DistributedReferenceSystemExampleTest.java
create mode 100644
geode-dunit/src/distributedTest/java/org/apache/geode/test/dunit/rules/tests/DistributedBlackboardDistributedTest.java
create mode 100644
geode-dunit/src/distributedTest/java/org/apache/geode/test/dunit/rules/tests/DistributedCloseableReferenceTest.java
create mode 100644
geode-dunit/src/distributedTest/java/org/apache/geode/test/dunit/rules/tests/DistributedCountersDistributedTest.java
create mode 100644
geode-dunit/src/distributedTest/java/org/apache/geode/test/dunit/rules/tests/DistributedErrorCollectorDistributedTest.java
delete mode 100644
geode-dunit/src/distributedTest/java/org/apache/geode/test/dunit/rules/tests/DistributedReferenceTest.java
delete mode 100644
geode-dunit/src/distributedTest/java/org/apache/geode/test/dunit/rules/tests/SharedCountersRuleDistributedTest.java
delete mode 100644
geode-dunit/src/distributedTest/java/org/apache/geode/test/dunit/rules/tests/SharedErrorCollectorDistributedTest.java
create mode 100644
geode-dunit/src/main/java/org/apache/geode/test/dunit/Blackboard.java
create mode 100644
geode-dunit/src/main/java/org/apache/geode/test/dunit/rules/DistributedBlackboard.java
create mode 100644
geode-dunit/src/main/java/org/apache/geode/test/dunit/rules/DistributedCloseableReference.java
create mode 100644
geode-dunit/src/main/java/org/apache/geode/test/dunit/rules/DistributedCounters.java
create mode 100644
geode-dunit/src/main/java/org/apache/geode/test/dunit/rules/DistributedErrorCollector.java
delete mode 100644
geode-dunit/src/main/java/org/apache/geode/test/dunit/rules/DistributedReference.java
delete mode 100644
geode-dunit/src/main/java/org/apache/geode/test/dunit/rules/SharedCountersRule.java
delete mode 100644
geode-dunit/src/main/java/org/apache/geode/test/dunit/rules/SharedErrorCollector.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
delete mode 100644
geode-gfsh/src/test/java/org/apache/geode/management/internal/cli/json/QueryResultFormatterTest.java
create mode 100644
geode-gfsh/src/upgradeTest/java/org/apache/geode/management/GfshCompatibilityTest.java
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
create mode 100644
geode-junit/src/test/java/org/apache/geode/test/junit/rules/CloseableReferenceTest.java
create mode 100644
geode-membership/src/main/java/org/apache/geode/internal/AvailablePort.java
create mode 100644
geode-membership/src/test/java/org/apache/geode/distributed/internal/membership/gms/locator/PrimaryHandlerTest.java
create mode 100644 geode-redis/gfsh.png
create mode 100644
geode-redis/src/acceptanceTest/java/org/apache/geode/redis/CommandPipeliningNativeRedisAcceptanceTest.java
create mode 100644
geode-redis/src/acceptanceTest/java/org/apache/geode/redis/internal/executor/GeodeRedisServerStartUpAcceptanceTest.java
create mode 100644
geode-redis/src/acceptanceTest/java/org/apache/geode/redis/internal/executor/key/ScanNativeRedisAcceptanceTest.java
create mode 100755
geode-redis/src/acceptanceTest/java/org/apache/geode/redis/internal/executor/pubsub/LettucePubSubNativeRedisAcceptanceTest.java
create mode 100755
geode-redis/src/acceptanceTest/java/org/apache/geode/redis/internal/executor/pubsub/SubscriptionsNativeRedisAcceptanceTest.java
create mode 100644
geode-redis/src/acceptanceTest/java/org/apache/geode/redis/internal/executor/server/FlushAllNativeRedisAcceptanceTest.java
create mode 100644
geode-redis/src/acceptanceTest/java/org/apache/geode/redis/internal/executor/server/InfoNativeRedisAcceptanceTest.java
create mode 100644
geode-redis/src/acceptanceTest/java/org/apache/geode/redis/internal/executor/server/TimeNativeRedisAcceptanceTest.java
create mode 100644
geode-redis/src/acceptanceTest/java/session/NativeRedisSessionAcceptanceTest.java
create mode 100644
geode-redis/src/acceptanceTest/java/session/NativeRedisSessionExpirationAcceptanceTest.java
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
create mode 100644
geode-redis/src/commonTest/java/org/apache/geode/test/dunit/rules/RedisPortSupplier.java
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/data/DeltaDUnitTest.java
create mode 100644
geode-redis/src/distributedTest/java/org/apache/geode/redis/internal/executor/CrashAndNoRepeatDUnitTest.java
create mode 100644
geode-redis/src/distributedTest/java/org/apache/geode/redis/internal/executor/hash/HashesAndCrashesDUnitTest.java
create mode 100644
geode-redis/src/distributedTest/java/org/apache/geode/redis/session/RedisSessionDUnitTest.java
delete mode 100644
geode-redis/src/distributedTest/java/org/apache/geode/redis/session/RedisSessionDistDUnitTest.java
create mode 100644
geode-redis/src/integrationTest/java/org/apache/geode/redis/AbstractCommandPipeliningIntegrationTest.java
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/GeodeServerRunTest.java
create mode 100644
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/RedisStatsIntegrationTest.java
create mode 100644
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/AbstractGlobPatternIntegrationTest.java
create mode 100644
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/connection/AbstractPingIntegrationTest.java
create mode 100644
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/connection/QuitIntegrationTest.java
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/hash/AbstractHashesIntegrationTest.java
create mode 100644
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/key/AbstractDelIntegrationTest.java
create mode 100644
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/key/AbstractExistsIntegrationTest.java
create mode 100644
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/key/AbstractExpireAtIntegrationTest.java
create mode 100644
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/key/AbstractExpireIntegrationTest.java
create mode 100644
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/key/AbstractKeysIntegrationTest.java
create mode 100644
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/key/AbstractPTTLIntegrationTest.java
create mode 100644
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/key/AbstractPersistIntegrationTest.java
create mode 100644
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/key/AbstractPexpireIntegrationTest.java
create mode 100644
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/key/AbstractRenameIntegrationTest.java
create mode 100644
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/key/AbstractScanIntegrationTest.java
create mode 100644
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/key/AbstractTTLIntegrationTest.java
create mode 100644
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/key/AbstractTypeIntegrationTest.java
create mode 100644
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/key/ScanIntegrationTest.java
create mode 100644
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/pubsub/AbstractLettucePubSubIntegrationTest.java
create mode 100644
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/pubsub/AbstractPubSubIntegrationTest.java
create mode 100644
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/pubsub/AbstractSubscriptionsIntegrationTest.java
create mode 100644
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/pubsub/LettucePubSubIntegrationTest.java
create mode 100644
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/pubsub/SubscriptionsIntegrationTest.java
create mode 100644
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/server/AbstractFlushAllIntegrationTest.java
create mode 100644
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/server/AbstractInfoIntegrationTest.java
create mode 100644
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/server/AbstractTimeIntegrationTest.java
create mode 100644
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/server/InfoIntegrationTest.java
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/set/AbstractSDiffIntegrationTest.java
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/set/AbstractSInterIntegrationTest.java
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/set/AbstractSIsMemberIntegrationTest.java
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/set/AbstractSMoveIntegrationTest.java
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/set/AbstractSPopIntegrationTest.java
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/set/AbstractSRemIntegrationTest.java
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/set/AbstractSUnionIntegrationTest.java
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/set/AbstractSetsIntegrationTest.java
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/AbstractAppendIntegrationTest.java
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/AbstractBitCountIntegrationTest.java
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/AbstractBitOpIntegrationTest.java
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/AbstractBitPosIntegrationTest.java
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/AbstractDecrByIntegrationTest.java
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/AbstractDecrIntegrationTest.java
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/AbstractGetBitIntegrationTest.java
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/AbstractGetIntegrationTest.java
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/AbstractGetRangeIntegrationTest.java
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/AbstractGetSetIntegrationTest.java
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/AbstractIncrByFloatIntegrationTest.java
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/AbstractIncrByIntegrationTest.java
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/AbstractIncrIntegrationTest.java
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/AbstractMGetIntegrationTest.java
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/AbstractMSetIntegrationTest.java
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/AbstractMSetNXIntegrationTest.java
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/AbstractPSetEXIntegrationTest.java
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/AbstractSetBitIntegrationTest.java
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/AbstractSetEXIntegrationTest.java
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/AbstractSetIntegrationTest.java
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/AbstractSetNXIntegrationTest.java
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/AbstractSetRangeIntegrationTest.java
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/AbstractStrLenIntegrationTest.java
delete mode 100644
geode-redis/src/integrationTest/java/org/apache/geode/redis/mocks/MockSubscriber.java
delete mode 100644
geode-redis/src/integrationTest/java/org/apache/geode/redis/mocks/MockSubscriberWithLatch.java
create mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/data/CommandHelper.java
delete mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/data/EmptyRedisHash.java
delete mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/data/EmptyRedisSet.java
create mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/data/NullRedisData.java
create mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/data/NullRedisHash.java
create mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/data/NullRedisSet.java
create mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/data/NullRedisString.java
create mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/data/RedisDataCommandsFunctionExecutor.java
create mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/data/RedisHashCommandsFunctionExecutor.java
delete mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/data/RedisHashInRegion.java
create mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/data/RedisKeyCommandsFunctionExecutor.java
delete mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/data/RedisKeyInRegion.java
create mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/data/RedisSetCommandsFunctionExecutor.java
delete mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/data/RedisSetInRegion.java
create mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/data/RedisStringCommandsFunctionExecutor.java
delete mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/data/RedisStringInRegion.java
create mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/executor/RedisCommandsFunctionInvoker.java
delete mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/executor/hash/RedisHashCommandsFunctionExecutor.java
create mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/executor/hash/RedisHashCommandsFunctionInvoker.java
delete mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/executor/key/RedisKeyCommandsFunctionExecutor.java
create mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/executor/key/RedisKeyCommandsFunctionInvoker.java
create mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/executor/server/InfoExecutor.java
delete mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/executor/set/RedisSetCommandsFunctionExecutor.java
create mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/executor/set/RedisSetCommandsFunctionInvoker.java
delete mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/executor/string/RedisStringCommandsFunctionExecutor.java
create mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/executor/string/RedisStringCommandsFunctionInvoker.java
create mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/pubsub/SubscribeResult.java
create mode 100644
geode-serialization/src/main/java/org/apache/geode/internal/serialization/AbstractVersion.java
create mode 100644
geode-serialization/src/main/java/org/apache/geode/internal/serialization/KnownVersion.java
create mode 100644
geode-serialization/src/main/java/org/apache/geode/internal/serialization/UnknownVersion.java
delete mode 100644
geode-serialization/src/main/java/org/apache/geode/internal/serialization/VersionOrdinal.java
delete mode 100644
geode-serialization/src/main/java/org/apache/geode/internal/serialization/VersionOrdinalImpl.java
create mode 100644
geode-serialization/src/main/java/org/apache/geode/internal/serialization/VersioningIO.java
create mode 100644
geode-serialization/src/test/java/org/apache/geode/internal/serialization/KnownVersionJUnitTest.java
create mode 100644
geode-serialization/src/test/java/org/apache/geode/internal/serialization/UnknownVersionJUnitTest.java
delete mode 100644
geode-serialization/src/test/java/org/apache/geode/internal/serialization/VersionJUnitTest.java
delete mode 100644
geode-serialization/src/test/java/org/apache/geode/internal/serialization/VersionOrdinalImplJUnitTest.java
create mode 100644
geode-serialization/src/test/java/org/apache/geode/internal/serialization/VersioningJUnitTest.java
delete mode 100644
geode-wan/src/distributedTest/java/org/apache/geode/internal/cache/wan/PersistentGatewaySenderWithIsolatedDiskStoreDistributedTest.java
