This is an automated email from the ASF dual-hosted git repository.
jinmeiliao pushed a change to branch feature/GEODE-7665
in repository https://gitbox.apache.org/repos/asf/geode.git.
omit 605f5b2 GEODE-7680: PR.clear must be successful when interacting with
rebalance (#5095)
omit 7d45393 GEODE-7670: PR Clear with Concurrent Ops DUnitTests (#4848)
omit 9909cae GEODE-8361: Use Set instead of List to track cleared buckets
(#5379)
omit 2d82c28 GEODE-8334: PR.clear should sync with putAll or removeAll on
rvvLock (#5365)
omit e5efc6d GEODE-8173: Add unit test (coverage) for
PartitionedRegionClear class. (#5208)
omit df1b2d3 GEODE-7669 Test coverage for Partitioned Region clear with
Overflow enabled (#5189)
omit ab008ff GEODE-7678 (2nd PR) - Support for cache-listener and
client-notification for Partitioned Region Clear operation (#5124)
omit 2d75484 GEODE-7667: Fixing test to include PR clear help text.
omit a5ca20c GEODE-7894: Moving expiry tasks to AbstractRegion.
omit 2a2ebc9 GEODE-7676: Conversion of duration to seconds.
omit 856133b GEODE-7667: Add a 'clear' gfsh command for PR and RR clear
(#4818)
omit 7ae4a7d GEODE-7676: Add PR clear with expiration tests (#4970)
omit 9bf6afc GEODE-7983: Clear region writer callbacks should not be
invoked for bucket regions (#4954)
omit 1a4a888 GEODE-7912: cacheWriter should be triggered when PR.clear
(#4882)
omit cafffb3 PR.clear's event id should be created and used in BR (#4805)
omit ea07461 GEODE-7682: add PR.clear API (#4755)
omit d0613b3 GEODE-7683: introduce BR.cmnClearRegion
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)
new 5324bbf GEODE-7683: introduce BR.cmnClearRegion
new d83ba5e GEODE-7682: add PR.clear API (#4755)
new f0874d5 PR.clear's event id should be created and used in BR (#4805)
new 033c653 GEODE-7912: cacheWriter should be triggered when PR.clear
(#4882)
new e74a2ca GEODE-7983: Clear region writer callbacks should not be
invoked for bucket regions (#4954)
new 7f13e3b GEODE-7676: Add PR clear with expiration tests (#4970)
new 59c4149 GEODE-7667: Add a 'clear' gfsh command for PR and RR clear
(#4818)
new dc2374a GEODE-7676: Conversion of duration to seconds.
new 0dc7df4 GEODE-7894: Moving expiry tasks to AbstractRegion.
new 8266f8f GEODE-7667: Fixing test to include PR clear help text.
new 8a0ce88 GEODE-7678 (2nd PR) - Support for cache-listener and
client-notification for Partitioned Region Clear operation (#5124)
new ed22ccd GEODE-7669 Test coverage for Partitioned Region clear with
Overflow enabled (#5189)
new 62fb46f GEODE-8173: Add unit test (coverage) for
PartitionedRegionClear class. (#5208)
new e3b0a7b GEODE-8334: PR.clear should sync with putAll or removeAll on
rvvLock (#5365)
new d95d77b GEODE-8361: Use Set instead of List to track cleared buckets
(#5379)
new e12a394 GEODE-7670: PR Clear with Concurrent Ops DUnitTests (#4848)
new 7ce8d10 GEODE-7680: PR.clear must be successful when interacting with
rebalance (#5095)
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 (605f5b2)
\
N -- N -- N refs/heads/feature/GEODE-7665 (7ce8d10)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 17 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
ci/scripts/archive_results.sh | 5 +-
ci/scripts/create_instance.sh | 5 +-
ci/scripts/delete_instance.sh | 4 +-
ci/scripts/execute_build.sh | 4 +-
ci/scripts/execute_redis_tests.sh | 4 +-
ci/scripts/execute_tests.sh | 4 +-
ci/scripts/repeat-new-tests.sh | 4 +-
ci/scripts/rsync_code_down.sh | 4 +-
ci/scripts/rsync_code_up.sh | 4 +-
ci/scripts/shared_utilities.sh | 57 +--
dev-tools/release/create_support_branches.sh | 3 +-
.../geode/distributed/internal/DateMessage.java | 6 +-
...ackwardCompatibilitySerializationDUnitTest.java | 17 +-
.../internal/cache/DeltaPropagationDUnitTest.java | 6 +-
.../geode/internal/cache/GIIDeltaDUnitTest.java | 126 ++++++-
.../geode/pdx/PDXAsyncEventQueueDUnitTest.java | 4 +-
.../geode/pdx/PdxAttributesDistributedTest.java | 6 +-
.../apache/geode/pdx/PdxClientServerDUnitTest.java | 8 +-
.../cache/client/ClientCacheFactoryJUnitTest.java | 24 +-
.../cache/CompactOfflineDiskStoreJUnitTest.java | 4 +-
.../cache/FilterProfileConcurrencyTest.java | 4 +-
...FOEvictionAlgoMemoryEnabledRegionJUnitTest.java | 4 +-
.../cache/ha/HARegionQueueIntegrationTest.java | 4 +-
.../cache/tier/sockets/CacheClientProxyTest.java | 4 +-
.../sockets/ServerConnectionIntegrationTest.java | 6 +-
.../offheap/OffHeapValidationJUnitTest.java | 4 +-
.../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 +--
.../internal/InternalDataSerializerBenchmark.java | 6 +-
.../src/main/java/org/apache/geode/CopyHelper.java | 4 +-
.../main/java/org/apache/geode/DataSerializer.java | 6 +-
.../admin/jmx/internal/StatAlertNotification.java | 4 +-
.../geode/cache/client/internal/AbstractOp.java | 8 +-
.../cache/client/internal/AuthenticateUserOp.java | 8 +-
.../client/internal/ClientSideHandshakeImpl.java | 37 +-
.../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 | 4 +-
.../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 +-
.../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 | 4 +-
.../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 | 4 +-
.../query/internal/index/IndexCreationData.java | 4 +-
.../cache/query/internal/types/ObjectTypeImpl.java | 4 +-
.../internal/ClusterDistributionManager.java | 10 +-
.../distributed/internal/DistributionAdvisor.java | 4 +-
.../distributed/internal/DistributionImpl.java | 4 +-
.../distributed/internal/DistributionManager.java | 6 +-
.../distributed/internal/DistributionMessage.java | 4 +-
.../internal/LonerDistributionManager.java | 10 +-
.../distributed/internal/ReplyProcessor21.java | 4 +-
.../geode/distributed/internal/StartupMessage.java | 4 +-
.../internal/StartupResponseMessage.java | 4 +-
.../StartupResponseWithVersionMessage.java | 4 +-
.../internal/locks/DLockRemoteToken.java | 4 +-
.../distributed/internal/locks/DLockService.java | 4 +-
.../membership/InternalDistributedMember.java | 12 +-
.../internal/streaming/StreamingOperation.java | 9 +-
.../org/apache/geode/internal/DSFIDFactory.java | 4 +-
.../geode/internal/HeapDataOutputStream.java | 10 +-
.../geode/internal/InternalDataSerializer.java | 36 +-
.../geode/internal/VersionedObjectInput.java | 8 +-
.../geode/internal/VersionedObjectOutput.java | 12 +-
.../internal/admin/remote/ClientHealthStats.java | 8 +-
.../statalerts/GaugeThresholdDecoratorImpl.java | 4 +-
.../statalerts/NumberThresholdDecoratorImpl.java | 4 +-
.../internal/cache/AbstractUpdateOperation.java | 4 +-
.../apache/geode/internal/cache/BucketRegion.java | 4 +-
.../cache/DestroyPartitionedRegionMessage.java | 6 +-
.../apache/geode/internal/cache/DiskInitFile.java | 37 +-
.../apache/geode/internal/cache/DiskStoreImpl.java | 15 +-
.../internal/cache/DistTXPrecommitMessage.java | 4 +-
.../internal/cache/DistributedPingMessage.java | 4 +-
.../internal/cache/DistributedPutAllOperation.java | 6 +-
.../cache/DistributedTombstoneOperation.java | 6 +-
.../geode/internal/cache/EntryEventImpl.java | 10 +-
.../org/apache/geode/internal/cache/EventID.java | 26 +-
...xpireDisconnectedClientTransactionsMessage.java | 6 +-
.../apache/geode/internal/cache/FilterProfile.java | 4 +-
.../geode/internal/cache/FilterRoutingInfo.java | 14 +-
.../geode/internal/cache/GemFireCacheImpl.java | 5 +-
.../internal/cache/InitialImageOperation.java | 34 +-
.../cache/InvalidatePartitionedRegionMessage.java | 6 +-
.../cache/LatestLastAccessTimeOperation.java | 4 +-
.../apache/geode/internal/cache/LocalRegion.java | 6 +-
.../java/org/apache/geode/internal/cache/Node.java | 4 +-
.../geode/internal/cache/NonLocalRegionEntry.java | 4 +-
.../org/apache/geode/internal/cache/Oplog.java | 83 ++---
.../geode/internal/cache/PRQueryProcessor.java | 4 +-
.../internal/cache/PartitionRegionConfig.java | 4 +-
.../geode/internal/cache/PartitionedRegion.java | 8 +-
.../cache/PartitionedRegionQueryEvaluator.java | 4 +-
.../cache/PreferBytesCachedDeserializable.java | 4 +-
.../geode/internal/cache/ProxyRegionMap.java | 4 +-
.../apache/geode/internal/cache/RegionEntry.java | 4 +-
.../geode/internal/cache/RegionEventImpl.java | 4 +-
.../geode/internal/cache/ServerPingMessage.java | 4 +-
.../cache/StoreAllCachedDeserializable.java | 4 +-
.../geode/internal/cache/TXCommitMessage.java | 17 +-
.../apache/geode/internal/cache/TXEntryState.java | 4 +-
.../java/org/apache/geode/internal/cache/TXId.java | 4 +-
.../internal/cache/TXRegionLockRequestImpl.java | 8 +-
.../org/apache/geode/internal/cache/Token.java | 14 +-
.../geode/internal/cache/TombstoneService.java | 28 +-
.../internal/cache/VMCachedDeserializable.java | 4 +-
.../geode/internal/cache/ValidatingDiskRegion.java | 4 +-
.../internal/cache/ValueComparisonHelper.java | 4 +-
.../SnappyCompressedCachedDeserializable.java | 4 +-
.../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 | 6 +-
.../geode/internal/cache/locks/TXLockBatch.java | 4 +-
.../geode/internal/cache/locks/TXLockIdImpl.java | 4 +-
.../cache/partitioned/BucketCountLoadProbe.java | 4 +-
.../cache/partitioned/FetchBulkEntriesMessage.java | 8 +-
.../cache/partitioned/FetchEntriesMessage.java | 8 +-
.../cache/partitioned/FetchKeysMessage.java | 8 +-
.../internal/cache/partitioned/GetMessage.java | 4 +-
.../cache/partitioned/IndexCreationMsg.java | 6 +-
.../cache/partitioned/PRTombstoneMessage.java | 6 +-
.../cache/partitioned/PartitionMessage.java | 6 +-
.../internal/cache/partitioned/QueryMessage.java | 8 +-
.../cache/partitioned/SizedBasedLoadProbe.java | 4 +-
.../partitioned/StreamingPartitionOperation.java | 4 +-
.../internal/cache/persistence/BytesAndBits.java | 8 +-
.../cache/persistence/DiskInitFileInterpreter.java | 4 +-
.../cache/persistence/DiskInitFileParser.java | 12 +-
.../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 | 16 +-
.../tier/sockets/ClientRegistrationMetadata.java | 20 +-
.../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 | 6 +-
.../cache/tier/sockets/ServerConnection.java | 33 +-
.../tier/sockets/ServerSideHandshakeFactory.java | 16 +-
.../tier/sockets/ServerSideHandshakeImpl.java | 35 +-
.../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/RegisterInterest61.java | 4 +-
.../sockets/command/RegisterInterestList66.java | 4 +-
.../geode/internal/cache/tx/DistTxEntryEvent.java | 8 +-
.../internal/cache/tx/RemoteFetchKeysMessage.java | 4 +-
.../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/GatewaySenderAdvisor.java | 11 +-
.../wan/GatewaySenderEventCallbackArgument.java | 4 +-
.../internal/cache/wan/GatewaySenderEventImpl.java | 16 +-
...aySenderQueueEntrySynchronizationOperation.java | 4 +-
.../org/apache/geode/internal/logging/Banner.java | 4 +-
.../geode/internal/sequencelog/io/GraphReader.java | 4 +-
.../org/apache/geode/internal/tcp/Connection.java | 22 +-
.../apache/geode/internal/tcp/MsgDestreamer.java | 8 +-
.../org/apache/geode/internal/tcp/MsgReader.java | 4 +-
.../org/apache/geode/internal/tcp/MsgStreamer.java | 14 +-
.../tcp/VersionedByteBufferInputStream.java | 14 +-
.../geode/internal/tcp/VersionedMsgStreamer.java | 8 +-
.../org/apache/geode/internal/util/BlobHelper.java | 6 +-
.../management/internal/FederationComponent.java | 4 +-
.../internal/JmxManagerLocatorRequest.java | 4 +-
.../internal/JmxManagerLocatorResponse.java | 4 +-
.../internal/beans/CacheServerBridge.java | 6 +-
.../internal/beans/MemberMBeanBridge.java | 4 +-
.../configuration/domain/Configuration.java | 8 +-
.../internal/configuration/domain/XmlEntity.java | 6 +-
.../messages/ConfigurationResponse.java | 4 +-
.../internal/functions/CliFunctionResult.java | 6 +-
.../operation/RestoreRedundancyPerformer.java | 6 +-
.../management/internal/util/ManagementUtils.java | 6 +-
.../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 +-
.../cache/execute/FunctionAdapterJUnitTest.java | 4 +-
.../cache/query/internal/ResultsBagJUnitTest.java | 4 +-
.../geode/internal/DataSerializableJUnitTest.java | 12 +-
.../internal/HeapDataOutputStreamJUnitTest.java | 10 +-
...lDataSerializerSerializationAcceptlistTest.java | 4 +-
.../internal/cache/AbstractRegionMapTest.java | 6 +-
.../apache/geode/internal/cache/EventIDTest.java | 8 +-
...eDisconnectedClientTransactionsMessageTest.java | 10 +-
.../geode/internal/cache/FilterInfoTest.java | 6 +-
.../geode/internal/cache/TombstoneServiceTest.java | 89 +++++
.../cache/ha/EventIdOptimizationJUnitTest.java | 12 +-
.../cache/ha/ThreadIdentifierJUnitTest.java | 4 +-
.../partitioned/FetchEntriesMessageJUnitTest.java | 5 +-
.../tier/sockets/CacheClientProxyFactoryTest.java | 10 +-
.../tier/sockets/CommandInitializerJUnitTest.java | 4 +-
.../cache/tier/sockets/MessageJUnitTest.java | 4 +-
.../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 +-
.../geode/internal/offheap/DataTypeJUnitTest.java | 4 +-
.../offheap/OffHeapStoredObjectJUnitTest.java | 6 +-
.../geode/internal/size/ObjectTraverserPerf.java | 4 +-
.../apache/geode/internal/tcp/MsgStreamerTest.java | 8 +-
.../apache/geode/internal/util/BlobHelperTest.java | 6 +-
.../operation/RestoreRedundancyPerformerTest.java | 14 +-
.../RollingUpgrade2DUnitTestBase.java | 2 +-
.../rollingupgrade/RollingUpgradeDUnitTest.java | 6 +-
.../geode/security/FilterPostAuthorization.java | 4 +-
.../geode/security/FilterPreAuthorization.java | 4 +-
.../query/cq/internal/CqServiceFactoryImpl.java | 18 +-
.../cache/query/cq/internal/ops/CreateCQOp.java | 4 +-
.../query/cq/internal/ops/GetDurableCQsOp.java | 4 +-
.../running/starting_up_shutting_down.html.md.erb | 4 +-
...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 +-
.../logging/logging_categories.html.md.erb | 2 +-
.../JTA_transactions.html.md.erb | 2 +-
geode-docs/reference/statistics_list.html.md.erb | 4 +-
geode-docs/reference/topics/cache_xml.html.md.erb | 4 +-
.../reference/topics/client-cache.html.md.erb | 4 +-
geode-docs/reference/topics/glossary.html.md.erb | 2 +-
.../tools_modules/redis_api_for_geode.html.md.erb | 6 +-
.../geode/cache30/MultiVMRegionTestCase.java | 4 +-
.../apache/geode/management/cli/GfshCommand.java | 4 +-
.../cli/commands/CreateGatewaySenderCommand.java | 6 +-
.../internal/cli/commands/RedundancyCommand.java | 6 +-
.../geode/management/internal/cli/shell/Gfsh.java | 4 +-
.../commands/CreateGatewaySenderCommandTest.java | 6 +-
.../AnalyzeDataSerializablesJUnitTestBase.java | 4 +-
.../AnalyzeSerializablesJUnitTestBase.java | 4 +-
.../geode/codeAnalysis/CompiledClassUtils.java | 4 +-
.../internal/cache/eviction/LRUTestEntry.java | 4 +-
.../org/apache/geode/pdx/NonDelegatingLoader.java | 4 +-
.../apache/geode/test/version/VersionManager.java | 28 +-
.../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 | 25 +-
...ccessfulWhenAllServersRollToCurrentVersion.java | 4 +-
.../api/MemberIdentifierFactoryImplTest.java | 6 +-
.../membership/gms/GMSMemberDataJUnitTest.java | 6 +-
.../gms/GMSMemberDataVersionJUnitTest.java | 11 +-
.../membership/gms/GMSMembershipJUnitTest.java | 120 ++++++-
.../membership/gms/MemberDataBuilderImplTest.java | 6 +-
.../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 | 33 +-
.../internal/membership/gms/GMSMembership.java | 44 +--
.../internal/membership/gms/GMSMembershipView.java | 8 +-
.../membership/gms/MemberDataBuilderImpl.java | 4 +-
.../membership/gms/MemberIdentifierImpl.java | 40 +--
.../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 +-
.../membership/gms/membership/GMSJoinLeave.java | 4 +-
.../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 | 38 +-
.../apache/geode/OldClientSupportDUnitTest.java | 12 +-
.../gemstone/gemfire/OldClientSupportProvider.java | 10 +-
geode-redis/README.md | 361 +++++++++++++++----
geode-redis/gfsh.png | Bin 0 -> 16270 bytes
.../session/NativeRedisSessionAcceptanceTest.java | 17 +-
...NativeRedisSessionExpirationAcceptanceTest.java | 18 +-
.../executor/CrashAndNoRepeatDUnitTest.java | 138 +++----
.../executor/hash/HashesAndCrashesDUnitTest.java | 50 ++-
.../internal/executor/pubsub/PubSubDUnitTest.java | 11 +-
.../geode/redis/session/RedisSessionDUnitTest.java | 5 +-
.../geode/redis/session/SessionDUnitTest.java | 103 +++---
.../redis/session/SessionExpirationDUnitTest.java | 8 +-
.../executor/server/TimeIntegrationTest.java | 2 +-
.../executor/set/SDiffIntegrationTest.java | 9 +
.../executor/set/SInterIntegrationTest.java | 9 +
.../executor/set/SUnionIntegrationTest.java | 9 +
.../redis/internal/data/ByteArrayWrapper.java | 4 +-
.../geode/redis/internal/data/NullRedisSet.java | 8 +-
.../internal/netty/ExecutionHandlerContext.java | 20 +-
.../internal/serialization/AbstractVersion.java | 16 +-
.../serialization/BufferDataOutputStream.java | 12 +-
.../internal/serialization/ByteArrayDataInput.java | 8 +-
.../serialization/DSFIDNotFoundException.java | 2 +-
.../serialization/DataSerializableFixedID.java | 4 +-
.../serialization/DeserializationContext.java | 2 +-
.../{Version.java => KnownVersion.java} | 183 +++++-----
.../serialization/SerializationContext.java | 2 +-
.../serialization/SerializationVersions.java | 2 +-
.../serialization/StaticSerialization.java | 28 +-
.../internal/serialization/UnknownVersion.java | 1 -
.../geode/internal/serialization/Version.java | 399 +++------------------
.../internal/serialization/VersionOrdinal.java | 83 -----
.../serialization/VersionedDataInputStream.java | 6 +-
.../serialization/VersionedDataOutputStream.java | 6 +-
.../serialization/VersionedDataStream.java | 8 +-
.../geode/internal/serialization/Versioning.java | 42 +--
.../geode/internal/serialization/VersioningIO.java | 18 +-
.../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 ++++++
.../serialization/UnknownVersionJUnitTest.java | 12 +-
.../internal/serialization/VersionJUnitTest.java | 116 ------
.../serialization/VersioningJUnitTest.java | 38 +-
.../internal/tcpserver/HostAndPort.java | 4 +-
.../distributed/internal/tcpserver/TcpClient.java | 22 +-
.../distributed/internal/tcpserver/TcpServer.java | 22 +-
.../internal/tcpserver/VersionRequest.java | 4 +-
.../internal/tcpserver/VersionResponse.java | 4 +-
.../internal/tcpserver/HostAndPortTest.java | 8 +-
...ANPersistenceEnabledGatewaySenderDUnitTest.java | 5 +
.../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 +-
.../RemoteParallelGatewaySenderEventProcessor.java | 4 +-
...ateGatewaySenderMixedSiteOneCurrentSiteTwo.java | 4 +-
.../geode/rest/internal/web/util/JSONUtils.java | 14 +-
.../web/controllers/ShellCommandsController.java | 4 +-
441 files changed, 2753 insertions(+), 2611 deletions(-)
create mode 100644
geode-core/src/test/java/org/apache/geode/internal/cache/TombstoneServiceTest.java
create mode 100644 geode-redis/gfsh.png
copy
geode-serialization/src/main/java/org/apache/geode/internal/serialization/{Version.java
=> KnownVersion.java} (54%)
delete mode 100644
geode-serialization/src/main/java/org/apache/geode/internal/serialization/VersionOrdinal.java
create mode 100644
geode-serialization/src/test/java/org/apache/geode/internal/serialization/KnownVersionJUnitTest.java
delete mode 100644
geode-serialization/src/test/java/org/apache/geode/internal/serialization/VersionJUnitTest.java
