This is an automated email from the ASF dual-hosted git repository.
zhouxj pushed a change to branch feature/GEODE-3967
in repository https://gitbox.apache.org/repos/asf/geode.git.
omit 291b1c1 GEODE-3967: when ConcurrentCacheModificationException
happened. GatewaySenderEventImpl should save the status and notify
gatewaysender anyway. SerialGatewaySender will handle it. In
AbstractUpdateOperation's doPutOrCreate's 3 tries of basicUpdate, the 3rd one
should allow both create and update. make event with CME to be
ignored by dispatcher
add 7752308 GEODE-4370: Ensure that rmi-io uses the JMX/RMI port (#1339)
add a8f99b5 GEODE-4223: Test now waits until internal lucene regions are
ready (#1301)
add e7b96eb GEODE-4369: remove generics from InternalRegion and
InternalDistributedRegion (#1336)
add c0bbe03 GEODE-4329: Move logic for copying files outside of
BackupManager (#1334)
add b484b66 GEODE-4334: Merge protobuf modules (#1332)
add 61d1d4d GEODE-4309: Refactor ArgumentRedactor for improved
robustness. (#1313)
add e664ce6 GEODE-3738: Use DUnit Rules to remove flakiness from legacy
Authorization tests
add f1d1144 GEODE-4389 Overriding a cache listener from a template region
works correctly (#1345)
add af25a80 GEODE-4379: Move RemoteOutputStreamServer from gfsh to the
manager (#1341)
add 16f2d53 GEODE-4387: Removing GemFireCacheImpl.setInstanceForTests
add 47df59a GEODE-4142: save commit message for failover after jta commit
(#1324)
add e63152a GEODE-4354: Add --if-not-exists option to create region
(#1328)
add 2f81f40 GEODE-4094: ClientHealthMonitor may cause an NPE in a
ServerConnection (#1326)
add d707e2c GEODE-4300 Server logs warning message when protobuf client
closes socket
add d49ca71 GEODE-4354: Update sanctioned-geode-core-serializables.txt
add dd24cb9 GEODE-4374: Allow client calls to complete before shutting
down (#1354)
add 819599b GEODE-4139: Add javac processor to ensure correct RunWith
options are enabled for parameterized tests (#1318)
add ebc1d5e GEODE-3205: GEODE-2790: fix flakiness in
DiskSpaceLimitIntegrationTest (#1350)
add d0fef0f GEODE-3915: use ClassName type for cache-loader, writer and
listeners (#1327)
add 4e7a98f GEODE-4418: add FlakyTest category to
testMemLRUEvictionNDestroyNNumOverflowOnDiskCount
add aab2332 GEODE-4390: add FlakyTest category to
testCloseDiskStoreWhenPut
add c3ead73 GEODE-4418: add FlakyTest category to testCleanupAfterConflict
add fe3e41f GEODE-4149: Replace CacheFactory.getInstance(getSystem())
with JUnit4CacheTestCase.getCache(). (#1348)
add 5302d88 GEODE-4368: Rename server connection classes. (#1343)
add 52ff5ef GEODE-4328: Make backup into a task run by a single thread
(#1351)
add 5149f3e GEODE-4438: Removing unused .ser files
add 215177f GEODE-4308: Allow two caches in the same JVM if a feature
flag is on
add 8dab486 GEODE-4417: Remove support for DES. (#1355)
add a0fc41b GEODE-4380: Trigger build of geode-examples off geode
success. (#1342)
add 0d4940d GEODE-4219: Test will properly shutdown listeners (#1325)
add c6ce067 GEODE-4375: Fix problem that an exception occurs when
transaction from CacheServer via Pool (#1363)
add 21e2e0a GEODE-4364: extract RegionMapDestroy and add
RegionMapDestroyTest (#1347)
add de9d814 GEODE-4429: Remove unnecessary modifiers from interfaces in
geode-core:cache
add a6ac186 GEODE-4431: Remove unnecessary modifiers from interfaces in
geode-core:internal
add adfd511 [GEODE-4371] Add lurker process that captures callstacks.
(#1337)
add 9cf05c1 GEODE-4433: Remove unnecessary modifiers from interfaces
outside geode-core
add 751735d GEODE-4432: Remove unnecessary modifiers from interfaces in
geode-core
add 9438685 GEODE-4430: Remove unnecessary modifiers from interfaces in
geode-core:internal.cache
add 2615332 GEODE-4373: gfsh 'describe region' not showing accessor
region description (#1365)
add 4a75148 GEODE-4390: Replace flaky test with new tests (#1371)
add a5068ff GEODE-3834: Use TemporaryFolder rule in backup tests that did
not yet use it (#1373)
add 503d622 GEODE-4013: Ensure that non-daemon thread is used during
shutdown of … (#1368)
add 329e0c5 GEODE-3653: Remove testHook from
AbstractGatewaySenderEventProcessor (#1217)
add 0f6e09c GEODE-3800: Replace BackupManager with BackupService (#1372)
new fd25a67 GEODE-3967: when ConcurrentCacheModificationException
happened. GatewaySenderEventImpl should save the status and notify
gatewaysender anyway. SerialGatewaySender will handle it. In
AbstractUpdateOperation's doPutOrCreate's 3 tries of basicUpdate, the 3rd one
should allow both create and update. make event with CME to be
ignored by dispatcher
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 (291b1c1)
\
N -- N -- N refs/heads/feature/GEODE-3967 (fd25a67)
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 1 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:
buildSrc/build.gradle | 4 +-
.../geode/gradle/TestPropertiesWriter.groovy | 2 -
.../javac/EnsureCorrectRunsWithProcessor.java | 135 +++
.../services/javax.annotation.processing.Processor | 1 +
.../org/apache/geode/javac/SimpleClassFile.java | 28 +-
.../org/apache/geode/javac/SimpleFileManager.java | 46 +
.../org/apache/geode/javac/SimpleSourceFile.java | 22 +-
.../geode/javac/TestAnnotationProcessor.java | 51 +
.../java/org/apache/geode/javac/TestCompiler.java | 51 +
ci/pipelines/develop.yml | 14 +-
ci/scripts/capture-call-stacks.sh | 61 ++
ci/scripts/test-run.sh | 3 +
.../session/internal/common/SessionCache.java | 12 +-
.../session/internal/filter/SessionManager.java | 16 +-
.../filter/attributes/SessionAttributes.java | 24 +-
.../internal/jmx/SessionStatisticsMXBean.java | 6 +-
.../geode/modules/gatewaydelta/GatewayDelta.java | 6 +-
.../modules/gatewaydelta/GatewayDeltaEvent.java | 2 +-
.../modules/session/catalina/SessionCache.java | 36 +-
.../modules/session/catalina/SessionManager.java | 26 +-
.../internal/DeltaSessionAttributeEvent.java | 3 +-
geode-assembly/build.gradle | 6 +-
geode-client-protocol/build.gradle | 30 -
.../protocol/ClientProtocolMessageHandler.java | 40 -
.../geode/internal/protocol/OperationContext.java | 65 --
.../internal/protocol/ProtocolSerializer.java | 34 -
.../protocol/operations/OperationHandler.java | 42 -
.../ConnectionAuthenticatingStateProcessor.java | 31 -
.../geode/connectors/jdbc/JdbcAsyncWriterTest.java | 2 +-
.../java/org/apache/geode/DataSerializable.java | 13 +-
.../src/main/java/org/apache/geode/LogWriter.java | 74 +-
.../java/org/apache/geode/StatisticDescriptor.java | 14 +-
.../src/main/java/org/apache/geode/Statistics.java | 98 +-
.../java/org/apache/geode/StatisticsFactory.java | 18 +-
.../main/java/org/apache/geode/StatisticsType.java | 10 +-
.../org/apache/geode/StatisticsTypeFactory.java | 32 +-
.../apache/geode/admin/AdminDistributedSystem.java | 94 +-
.../main/java/org/apache/geode/admin/Alert.java | 12 +-
.../java/org/apache/geode/admin/AlertListener.java | 2 +-
.../org/apache/geode/admin/CacheHealthConfig.java | 24 +-
.../java/org/apache/geode/admin/CacheServer.java | 4 +-
.../org/apache/geode/admin/CacheServerConfig.java | 8 +-
.../main/java/org/apache/geode/admin/CacheVm.java | 2 +-
.../java/org/apache/geode/admin/CacheVmConfig.java | 8 +-
.../apache/geode/admin/ConfigurationParameter.java | 24 +-
.../geode/admin/DistributedSystemConfig.java | 154 +--
.../geode/admin/DistributedSystemHealthConfig.java | 6 +-
.../apache/geode/admin/DistributionLocator.java | 4 +-
.../geode/admin/DistributionLocatorConfig.java | 12 +-
.../java/org/apache/geode/admin/GemFireHealth.java | 30 +-
.../apache/geode/admin/GemFireHealthConfig.java | 8 +-
.../java/org/apache/geode/admin/ManagedEntity.java | 12 +-
.../apache/geode/admin/ManagedEntityConfig.java | 20 +-
.../org/apache/geode/admin/MemberHealthConfig.java | 24 +-
.../java/org/apache/geode/admin/Statistic.java | 10 +-
.../org/apache/geode/admin/StatisticResource.java | 14 +-
.../java/org/apache/geode/admin/SystemMember.java | 36 +-
.../geode/admin/SystemMemberBridgeServer.java | 60 +-
.../org/apache/geode/admin/SystemMemberCache.java | 39 +-
.../apache/geode/admin/SystemMemberCacheEvent.java | 2 +-
.../geode/admin/SystemMemberCacheListener.java | 12 +-
.../geode/admin/SystemMemberCacheServer.java | 60 +-
.../org/apache/geode/admin/SystemMemberRegion.java | 104 +-
.../geode/admin/SystemMemberRegionEvent.java | 2 +-
.../apache/geode/admin/SystemMembershipEvent.java | 4 +-
.../geode/admin/SystemMembershipListener.java | 6 +-
.../geode/admin/internal/CacheServerImpl.java | 12 +-
.../internal/ConfigurationParameterListener.java | 2 +-
.../admin/internal/InternalManagedEntity.java | 26 +-
.../admin/internal/ManagedEntityController.java | 12 +-
.../java/org/apache/geode/admin/jmx/Agent.java | 26 +-
.../org/apache/geode/admin/jmx/AgentConfig.java | 216 ++--
.../geode/admin/jmx/internal/ManagedResource.java | 14 +-
.../jmx/internal/RMIRegistryServiceMBean.java | 14 +-
.../admin/jmx/internal/StatAlertsAggregator.java | 20 +-
.../geode/admin/jmx/internal/SystemMemberJmx.java | 59 +-
.../org/apache/geode/cache/AttributesMutator.java | 38 +-
.../java/org/apache/geode/cache/CacheCallback.java | 2 +-
.../java/org/apache/geode/cache/CacheEvent.java | 13 +-
.../java/org/apache/geode/cache/CacheFactory.java | 4 +-
.../java/org/apache/geode/cache/CacheListener.java | 18 +-
.../java/org/apache/geode/cache/CacheLoader.java | 2 +-
.../org/apache/geode/cache/CacheStatistics.java | 12 +-
.../geode/cache/CacheTransactionManager.java | 42 +-
.../java/org/apache/geode/cache/CacheWriter.java | 10 +-
.../java/org/apache/geode/cache/ClientSession.java | 18 +-
.../java/org/apache/geode/cache/CustomExpiry.java | 2 +-
.../java/org/apache/geode/cache/Declarable.java | 2 +-
.../java/org/apache/geode/cache/DiskStore.java | 38 +-
.../org/apache/geode/cache/DiskStoreFactory.java | 50 +-
.../apache/geode/cache/DiskWriteAttributes.java | 12 +-
.../apache/geode/cache/DynamicRegionListener.java | 8 +-
.../java/org/apache/geode/cache/EntryEvent.java | 16 +-
.../org/apache/geode/cache/EntryOperation.java | 12 +-
.../geode/cache/EvictionAttributesMutator.java | 2 +-
.../apache/geode/cache/FixedPartitionResolver.java | 3 +-
.../java/org/apache/geode/cache/GemFireCache.java | 46 +-
.../geode/cache/InterestRegistrationEvent.java | 16 +-
.../geode/cache/InterestRegistrationListener.java | 4 +-
.../java/org/apache/geode/cache/LoaderHelper.java | 8 +-
.../apache/geode/cache/PartitionAttributes.java | 27 +-
.../org/apache/geode/cache/PartitionResolver.java | 4 +-
.../main/java/org/apache/geode/cache/Region.java | 209 ++--
.../org/apache/geode/cache/RegionAttributes.java | 92 +-
.../java/org/apache/geode/cache/RegionEvent.java | 2 +-
.../geode/cache/RegionMembershipListener.java | 8 +-
.../org/apache/geode/cache/RegionRoleListener.java | 4 +-
.../java/org/apache/geode/cache/RegionService.java | 16 +-
.../java/org/apache/geode/cache/RoleEvent.java | 2 +-
.../apache/geode/cache/SerializedCacheValue.java | 4 +-
.../org/apache/geode/cache/TransactionEvent.java | 8 +-
.../apache/geode/cache/TransactionListener.java | 6 +-
.../org/apache/geode/cache/TransactionWriter.java | 2 +-
.../apache/geode/cache/asyncqueue/AsyncEvent.java | 4 +-
.../geode/cache/asyncqueue/AsyncEventListener.java | 2 +-
.../geode/cache/asyncqueue/AsyncEventQueue.java | 34 +-
.../cache/asyncqueue/AsyncEventQueueFactory.java | 34 +-
.../org/apache/geode/cache/client/ClientCache.java | 25 +-
.../geode/cache/client/ClientRegionFactory.java | 47 +-
.../java/org/apache/geode/cache/client/Pool.java | 60 +-
.../org/apache/geode/cache/client/PoolFactory.java | 90 +-
.../geode/cache/client/internal/AbstractOp.java | 2 +-
.../geode/cache/client/internal/ClientUpdater.java | 6 +-
.../geode/cache/client/internal/Connection.java | 38 +-
.../cache/client/internal/EndpointManager.java | 10 +-
.../cache/client/internal/ExecutablePool.java | 29 +-
.../geode/cache/client/internal/QueueManager.java | 18 +-
.../geode/cache/client/internal/QueueState.java | 14 +-
.../cache/client/internal/ServerBlackList.java | 12 +-
.../client/internal/ServerRegionDataAccess.java | 38 +-
.../locator/wan/LocatorMembershipListener.java | 16 +-
.../client/internal/pooling/ConnectionManager.java | 8 +-
.../geode/cache/control/RebalanceFactory.java | 4 +-
.../geode/cache/control/RebalanceOperation.java | 10 +-
.../geode/cache/control/RebalanceResults.java | 20 +-
.../geode/cache/control/ResourceManager.java | 24 +-
.../org/apache/geode/cache/execute/Execution.java | 12 +-
.../geode/cache/execute/FunctionContext.java | 12 +-
.../geode/cache/execute/RegionFunctionContext.java | 4 +-
.../geode/cache/execute/ResultCollector.java | 10 +-
.../apache/geode/cache/execute/ResultSender.java | 6 +-
.../geode/cache/partition/PartitionListener.java | 10 +-
.../geode/cache/partition/PartitionMemberInfo.java | 10 +-
.../cache/partition/PartitionRebalanceInfo.java | 30 +-
.../geode/cache/partition/PartitionRegionInfo.java | 18 +-
.../geode/cache/persistence/PersistentID.java | 6 +-
.../org/apache/geode/cache/query/Aggregator.java | 6 +-
.../org/apache/geode/cache/query/CqAttributes.java | 4 +-
.../geode/cache/query/CqAttributesMutator.java | 6 +-
.../java/org/apache/geode/cache/query/CqEvent.java | 14 +-
.../org/apache/geode/cache/query/CqListener.java | 4 +-
.../java/org/apache/geode/cache/query/CqQuery.java | 30 +-
.../geode/cache/query/CqServiceStatistics.java | 12 +-
.../java/org/apache/geode/cache/query/CqState.java | 10 +-
.../org/apache/geode/cache/query/CqStatistics.java | 8 +-
.../apache/geode/cache/query/CqStatusListener.java | 4 +-
.../java/org/apache/geode/cache/query/Index.java | 24 +-
.../apache/geode/cache/query/IndexStatistics.java | 18 +-
.../java/org/apache/geode/cache/query/Query.java | 21 +-
.../org/apache/geode/cache/query/QueryService.java | 81 +-
.../apache/geode/cache/query/QueryStatistics.java | 4 +-
.../apache/geode/cache/query/SelectResults.java | 19 +-
.../java/org/apache/geode/cache/query/Struct.java | 6 +-
.../apache/geode/cache/query/internal/Filter.java | 37 +-
.../cache/query/internal/HashingStrategy.java | 4 +-
.../geode/cache/query/internal/Negatable.java | 2 +-
.../geode/cache/query/internal/QueryExecutor.java | 4 +-
.../geode/cache/query/internal/StructFields.java | 10 +-
.../geode/cache/query/internal/cq/ClientCQ.java | 7 +-
.../geode/cache/query/internal/cq/CqService.java | 77 +-
.../cache/query/internal/cq/InternalCqQuery.java | 29 +-
.../geode/cache/query/internal/cq/ServerCQ.java | 24 +-
.../query/internal/index/CompactRangeIndex.java | 3 +-
.../cache/query/internal/index/IndexManager.java | 2 +-
.../cache/query/internal/index/IndexProtocol.java | 19 +-
.../cache/query/internal/index/IndexStore.java | 42 +-
.../internal/index/IndexedExpressionEvaluator.java | 17 +-
.../query/internal/index/MemoryIndexStore.java | 7 +-
.../geode/cache/query/types/CollectionType.java | 6 +-
.../apache/geode/cache/query/types/MapType.java | 4 +-
.../apache/geode/cache/query/types/ObjectType.java | 10 +-
.../apache/geode/cache/query/types/StructType.java | 2 +-
.../org/apache/geode/cache/server/CacheServer.java | 104 +-
.../cache/server/ClientSubscriptionConfig.java | 22 +-
.../cache/snapshot/RegionSnapshotService.java | 2 +-
.../geode/cache/util/GatewayConflictHelper.java | 4 +-
.../geode/cache/util/GatewayConflictResolver.java | 2 +-
.../org/apache/geode/cache/util/GatewayEvent.java | 18 +-
.../org/apache/geode/cache/util/ObjectSizer.java | 8 +-
.../geode/cache/util/TimestampedEntryEvent.java | 8 +-
.../apache/geode/cache/wan/GatewayEventFilter.java | 6 +-
.../cache/wan/GatewayEventSubstitutionFilter.java | 2 +-
.../apache/geode/cache/wan/GatewayQueueEvent.java | 12 +-
.../apache/geode/cache/wan/GatewayReceiver.java | 46 +-
.../geode/cache/wan/GatewayReceiverFactory.java | 20 +-
.../org/apache/geode/cache/wan/GatewaySender.java | 113 +-
.../geode/cache/wan/GatewaySenderFactory.java | 43 +-
.../geode/cache/wan/GatewayTransportFilter.java | 4 +-
.../org/apache/geode/compression/Compressor.java | 4 +-
.../geode/distributed/ClientSocketFactory.java | 2 +-
.../geode/distributed/DistributedMember.java | 14 +-
.../geode/distributed/DistributedSystem.java | 6 +
.../java/org/apache/geode/distributed/Role.java | 6 +-
.../apache/geode/distributed/ServerLauncher.java | 32 +-
.../geode/distributed/internal/CacheTime.java | 2 +-
.../apache/geode/distributed/internal/DMStats.java | 352 +++----
.../apache/geode/distributed/internal/DSClock.java | 8 +-
.../distributed/internal/DistributionAdvisee.java | 20 +-
.../distributed/internal/DistributionAdvisor.java | 8 +-
.../distributed/internal/DistributionConfig.java | 8 +-
.../geode/distributed/internal/HealthMonitor.java | 8 +-
.../internal/InternalDistributedSystem.java | 12 +-
.../apache/geode/distributed/internal/MQueue.java | 2 +-
.../distributed/internal/MembershipListener.java | 10 +-
.../distributed/internal/MessageWithReply.java | 6 +-
.../geode/distributed/internal/PoolStatHelper.java | 4 +-
.../distributed/internal/QueueStatHelper.java | 6 +-
.../geode/distributed/internal/ReplySender.java | 2 +-
.../geode/distributed/internal/Sizeable.java | 2 +-
.../internal/ThrottledMemQueueStatHelper.java | 8 +-
.../internal/ThrottledQueueStatHelper.java | 4 +-
.../distributed/internal/WanLocatorDiscoverer.java | 2 +-
.../internal/deadlock/DependencyMonitor.java | 4 +-
.../internal/direct/DirectChannelListener.java | 4 +-
.../distributed/internal/locks/DLockBatch.java | 12 +-
.../distributed/internal/locks/DLockBatchId.java | 3 +-
.../locks/DLockLessorDepartureHandler.java | 4 +-
.../locks/DLockRecoverGrantorProcessor.java | 4 +-
.../internal/locks/DistributedLockStats.java | 207 ++--
.../internal/locks/DistributedMemberLock.java | 2 +-
.../membership/DistributedMembershipListener.java | 20 +-
.../internal/membership/MemberServices.java | 10 +-
.../internal/membership/MembershipManager.java | 82 +-
.../internal/membership/MembershipTestHook.java | 4 +-
.../distributed/internal/membership/NetMember.java | 63 +-
.../internal/membership/QuorumChecker.java | 12 +-
.../internal/membership/gms/NetLocator.java | 2 +-
.../membership/gms/interfaces/HealthMonitor.java | 15 +-
.../membership/gms/interfaces/JoinLeave.java | 2 +-
.../membership/gms/interfaces/MessageHandler.java | 2 +-
.../membership/gms/messages/HasMemberID.java | 2 +-
.../membership/gms/messenger/GMSEncrypt.java | 7 +-
.../java/org/apache/geode/i18n/LogWriterI18n.java | 114 +--
.../java/org/apache/geode/internal/Banner.java | 140 +--
.../apache/geode/internal/ByteBufferWriter.java | 2 +-
.../apache/geode/internal/ConnectionWatcher.java | 4 +-
.../java/org/apache/geode/internal/DSCODE.java | 150 +--
.../geode/internal/DataSerializableFixedID.java | 1074 ++++++++++----------
.../java/org/apache/geode/internal/NanoTimer.java | 2 +-
.../geode/internal/ObjToByteArraySerializer.java | 5 +-
.../apache/geode/internal/OneTaskOnlyExecutor.java | 2 +-
.../geode/internal/SerializationVersions.java | 2 +-
.../apache/geode/internal/VersionedDataStream.java | 2 +-
.../geode/internal/admin/AdminBridgeServer.java | 2 +-
.../org/apache/geode/internal/admin/Alert.java | 34 +-
.../apache/geode/internal/admin/AlertListener.java | 2 +-
.../apache/geode/internal/admin/ApplicationVM.java | 2 +-
.../org/apache/geode/internal/admin/CacheInfo.java | 24 +-
.../apache/geode/internal/admin/CacheSnapshot.java | 14 +-
.../org/apache/geode/internal/admin/DLockInfo.java | 16 +-
.../apache/geode/internal/admin/EntrySnapshot.java | 2 +-
.../geode/internal/admin/EntryValueNode.java | 10 +-
.../org/apache/geode/internal/admin/GemFireVM.java | 98 +-
.../geode/internal/admin/GfManagerAgent.java | 24 +-
.../org/apache/geode/internal/admin/GfObject.java | 8 +-
.../geode/internal/admin/HealthListener.java | 2 +-
.../geode/internal/admin/JoinLeaveListener.java | 6 +-
.../geode/internal/admin/RegionSnapshot.java | 2 +-
.../geode/internal/admin/SnapshotClient.java | 2 +-
.../java/org/apache/geode/internal/admin/Stat.java | 6 +-
.../geode/internal/admin/StatAlertDefinition.java | 30 +-
.../apache/geode/internal/admin/StatListener.java | 4 +-
.../apache/geode/internal/admin/StatResource.java | 16 +-
.../geode/internal/admin/remote/Cancellable.java | 2 +-
.../internal/admin/statalerts/StatisticInfo.java | 18 +-
.../internal/cache/AbstractBucketRegionQueue.java | 2 +-
.../geode/internal/cache/AbstractDiskRegion.java | 96 +-
.../geode/internal/cache/AbstractRegion.java | 30 +-
.../geode/internal/cache/AbstractRegionMap.java | 750 ++------------
.../apache/geode/internal/cache/BucketRegion.java | 4 +-
.../internal/cache/CacheDistributionAdvisee.java | 10 +-
.../apache/geode/internal/cache/CacheObserver.java | 36 +-
.../geode/internal/cache/CacheServerImpl.java | 7 +-
.../apache/geode/internal/cache/CacheService.java | 6 +-
.../geode/internal/cache/CachedDeserializable.java | 22 +-
.../geode/internal/cache/ClientServerObserver.java | 24 +-
.../geode/internal/cache/CompactableOplog.java | 9 +-
.../apache/geode/internal/cache/Conflatable.java | 12 +-
.../geode/internal/cache/DiskStoreFactoryImpl.java | 4 +-
.../apache/geode/internal/cache/DiskStoreImpl.java | 24 +-
.../apache/geode/internal/cache/DiskStoreTask.java | 2 +-
.../geode/internal/cache/DistTXCommitMessage.java | 13 +-
.../internal/cache/DistTXCoordinatorInterface.java | 23 +-
.../geode/internal/cache/DistributedRegion.java | 2 +-
.../apache/geode/internal/cache/EntriesMap.java | 10 +-
.../geode/internal/cache/EntryEventImpl.java | 6 +-
.../geode/internal/cache/EvictableRegion.java | 3 +-
.../cache/EvictionAttributesMutatorImpl.java | 5 +-
.../apache/geode/internal/cache/ExpiryTask.java | 10 +-
.../geode/internal/cache/ExportDiskRegion.java | 4 +-
.../apache/geode/internal/cache/FilterProfile.java | 4 +-
.../geode/internal/cache/GemFireCacheImpl.java | 101 +-
.../apache/geode/internal/cache/ImageState.java | 64 +-
.../geode/internal/cache/InterestFilter.java | 10 +-
.../apache/geode/internal/cache/InternalCache.java | 10 +-
.../geode/internal/cache/InternalCacheEvent.java | 20 +-
.../geode/internal/cache/InternalDataView.java | 10 +-
.../internal/cache/InternalDistributedRegion.java | 3 +-
...{DiskStoreTask.java => InternalEntryEvent.java} | 9 +-
.../geode/internal/cache/InternalRegion.java | 38 +-
.../internal/cache/JtaAfterCompletionMessage.java | 12 +-
.../internal/cache/JtaBeforeCompletionMessage.java | 6 +
.../cache/LatestLastAccessTimeMessage.java | 6 +-
.../cache/LatestLastAccessTimeOperation.java | 4 +-
.../geode/internal/cache/LoaderHelperFactory.java | 4 +-
.../apache/geode/internal/cache/LocalRegion.java | 28 +-
.../cache/OfflineCompactionDiskRegion.java | 16 +-
.../org/apache/geode/internal/cache/Oplog.java | 30 +-
.../org/apache/geode/internal/cache/OplogSet.java | 8 +-
.../internal/cache/PRHARedundancyProvider.java | 38 +-
.../internal/cache/PartitionedRegionDataStore.java | 8 +-
.../cache/PartitionedRegionQueryEvaluator.java | 49 +-
.../internal/cache/PlaceHolderDiskRegion.java | 27 +-
.../geode/internal/cache/ProxyRegionMap.java | 18 +-
.../geode/internal/cache/RegionEntryFactory.java | 8 +-
.../org/apache/geode/internal/cache/RegionMap.java | 9 +-
.../{DiskStoreTask.java => RegionMapOwner.java} | 8 +-
.../apache/geode/internal/cache/RegionQueue.java | 32 +-
.../apache/geode/internal/cache/RegionStatus.java | 2 +-
.../geode/internal/cache/SerializationHelper.java | 4 +-
.../geode/internal/cache/TXCommitMessage.java | 20 +-
.../geode/internal/cache/TXEntryStateFactory.java | 6 +-
.../apache/geode/internal/cache/TXManagerImpl.java | 6 +-
.../internal/cache/TXRemoteCommitMessage.java | 17 +-
.../org/apache/geode/internal/cache/TXState.java | 7 +-
.../geode/internal/cache/TXStateInterface.java | 79 +-
.../apache/geode/internal/cache/TXStateProxy.java | 40 +-
.../geode/internal/cache/TransactionMessage.java | 14 +-
.../geode/internal/cache/TxEntryFactory.java | 4 +-
.../internal/cache/VMCachedDeserializable.java | 2 +-
.../geode/internal/cache/VMLRURegionMap.java | 32 +-
.../apache/geode/internal/cache/VMRegionMap.java | 2 +-
.../geode/internal/cache/ValidatingDiskRegion.java | 5 -
.../internal/cache/backup/BackupFileCopier.java | 185 ++++
.../geode/internal/cache/backup/BackupLock.java | 114 ---
.../geode/internal/cache/backup/BackupService.java | 157 +++
.../backup/{BackupManager.java => BackupTask.java} | 271 ++---
.../cache/backup/FileSystemBackupDestination.java | 2 +-
.../geode/internal/cache/backup/FinishBackup.java | 4 +-
.../geode/internal/cache/backup/PrepareBackup.java | 4 +-
.../cache/backup/PrepareBackupOperation.java | 2 +-
.../cache/backup/PrepareBackupRequest.java | 2 +-
.../cache/backup/TemporaryBackupFiles.java | 5 +-
.../cache/control/InternalResourceManager.java | 16 +-
.../internal/cache/control/MemoryMonitor.java | 12 +-
.../cache/control/OffHeapMemoryMonitor.java | 16 +-
.../internal/cache/control/ResourceEvent.java | 6 +-
.../internal/cache/control/ResourceListener.java | 2 +-
.../internal/cache/control/ResourceMonitor.java | 6 +-
.../cache/entries/AbstractRegionEntry.java | 2 +-
.../geode/internal/cache/entries/DiskEntry.java | 51 +-
.../internal/cache/entries/HashRegionEntry.java | 9 +-
.../internal/cache/entries/OffHeapRegionEntry.java | 4 +-
.../internal/cache/execute/AbstractExecution.java | 6 +-
.../internal/cache/execute/InternalExecution.java | 10 +-
.../execute/InternalRegionFunctionContext.java | 7 +-
.../cache/execute/InternalResultSender.java | 8 +-
.../cache/execute/MultiRegionFunctionContext.java | 4 +-
.../geode/internal/cache/extension/Extensible.java | 2 +-
.../internal/cache/ha/HAContainerWrapper.java | 18 +-
.../geode/internal/cache/locks/TXLockId.java | 10 +-
.../internal/cache/locks/TXRegionLockRequest.java | 8 +-
.../internal/cache/map/CacheModificationLock.java | 16 +-
.../geode/internal/cache/map/FocusedRegionMap.java | 45 +
.../geode/internal/cache/map/RegionMapDestroy.java | 650 ++++++++++++
.../geode/internal/cache/partitioned/Bucket.java | 16 +-
.../internal/cache/partitioned/InternalPRInfo.java | 5 +-
.../partitioned/InternalPartitionDetails.java | 4 +-
.../cache/partitioned/OfflineMemberDetails.java | 4 +-
.../cache/partitioned/PREntriesIterator.java | 4 +-
.../partitioned/PartitionedRegionObserver.java | 6 +-
.../internal/cache/partitioned/RegionAdvisor.java | 29 +-
.../partitioned/rebalance/BucketOperator.java | 8 +-
.../rebalance/PartitionedRegionLoadModel.java | 7 +-
.../partitioned/rebalance/RebalanceDirector.java | 8 +-
.../cache/persistence/DiskInitFileInterpreter.java | 10 +-
.../cache/persistence/DiskRecoveryStore.java | 44 +-
.../internal/cache/persistence/DiskRegionView.java | 123 ++-
.../cache/persistence/PersistenceAdvisor.java | 32 +-
.../cache/persistence/PersistenceAdvisorImpl.java | 18 +-
.../persistence/PersistenceObserverHolder.java | 16 +-
.../cache/persistence/PersistentMemberManager.java | 12 +-
.../cache/persistence/PersistentMemberView.java | 42 +-
.../cache/persistence/PersistentStateListener.java | 8 +-
.../UninterruptibleRandomAccessFile.java | 4 +-
.../internal/cache/persistence/query/IndexMap.java | 2 +-
.../cache/persistence/query/ResultBag.java | 2 +-
.../cache/persistence/query/ResultList.java | 2 +-
.../cache/persistence/query/ResultMap.java | 2 +-
.../cache/persistence/query/ResultSet.java | 2 +-
.../geode/internal/cache/tier/ClientHandShake.java | 12 +-
.../geode/internal/cache/tier/ConnectionProxy.java | 2 +-
.../internal/cache/tier/sockets/AcceptorImpl.java | 7 -
.../cache/tier/sockets/CacheClientProxy.java | 2 +-
.../cache/tier/sockets/ClientHealthMonitor.java | 253 ++---
.../internal/cache/tier/sockets/ClientMessage.java | 2 +-
.../cache/tier/sockets/ClientUpdateMessage.java | 44 +-
.../tier/sockets/ClientUpdateMessageImpl.java | 16 +-
.../cache/tier/sockets/CommBufferPool.java | 4 +-
.../internal/cache/tier/sockets/HandShake.java | 2 +-
.../internal/cache/tier/sockets/MessageStats.java | 8 +-
.../tier/sockets/OldClientSupportService.java | 8 +-
...nnection.java => OriginalServerConnection.java} | 4 +-
...nnection.java => ProtobufServerConnection.java} | 14 +-
.../cache/tier/sockets/ServerConnection.java | 61 +-
.../tier/sockets/ServerConnectionCollection.java | 44 +
.../tier/sockets/ServerConnectionFactory.java | 11 +-
.../tier/sockets/ServerHandShakeProcessor.java | 8 +-
.../cache/tier/sockets/command/CommitCommand.java | 5 +-
.../sockets/command/TXSynchronizationCommand.java | 27 +-
.../internal/cache/versions/VersionHolder.java | 4 +-
.../internal/cache/vmotion/VMotionObserver.java | 6 +-
.../wan/AbstractGatewaySenderEventProcessor.java | 15 +-
.../cache/wan/DistributedSystemListener.java | 4 +-
.../cache/wan/GatewaySenderEventDispatcher.java | 10 +-
.../cache/wan/InternalGatewaySenderFactory.java | 13 +-
.../internal/cache/xmlcache/CacheCreation.java | 19 +-
.../geode/internal/cache/xmlcache/Declarable2.java | 2 +-
.../internal/cache/xmlcache/PropertyResolver.java | 16 +-
.../org/apache/geode/internal/concurrent/AL.java | 24 +-
.../geode/internal/concurrent/MapCallback.java | 31 +-
.../geode/internal/concurrent/MapResult.java | 4 +-
.../internal/datasource/ConnectionPoolCache.java | 8 +-
.../internal/datasource/ConnectionProvider.java | 8 +-
.../internal/datasource/DataSourceResources.java | 14 +-
.../geode/internal/i18n/LocalizedStrings.java | 2 +-
.../org/apache/geode/internal/i18n/StringId.java | 10 +-
.../org/apache/geode/internal/lang/Filter.java | 2 +-
.../org/apache/geode/internal/lang/Initable.java | 2 +-
.../geode/internal/lang/MutableIdentifiable.java | 2 +-
.../org/apache/geode/internal/lang/Orderable.java | 2 +-
.../org/apache/geode/internal/lang/Ordered.java | 4 +-
.../geode/internal/logging/InternalLogWriter.java | 40 +-
.../geode/internal/logging/MergeLogFiles.java | 12 +-
.../internal/logging/log4j/GemFireLogger.java | 171 ++--
.../geode/internal/logging/log4j/LogMarker.java | 123 +--
.../geode/internal/memcached/CommandProcessor.java | 2 +-
.../apache/geode/internal/net/SocketCreator.java | 6 +-
.../geode/internal/offheap/FreeListManager.java | 10 +-
.../geode/internal/offheap/LifecycleListener.java | 13 +-
.../geode/internal/offheap/MemoryAllocator.java | 23 +-
.../apache/geode/internal/offheap/MemoryBlock.java | 24 +-
.../geode/internal/offheap/MemoryInspector.java | 14 +-
.../internal/offheap/MemoryUsageListener.java | 2 +-
.../geode/internal/offheap/OffHeapMemoryStats.java | 48 +-
.../offheap/OutOfOffHeapMemoryListener.java | 4 +-
.../apache/geode/internal/offheap/Releasable.java | 2 +-
.../org/apache/geode/internal/offheap/Slab.java | 6 +-
.../apache/geode/internal/offheap/SlabFactory.java | 2 +-
.../geode/internal/offheap/StoredObject.java | 46 +-
.../geode/internal/sequencelog/SequenceLogger.java | 8 +-
.../geode/internal/sequencelog/io/Filter.java | 5 +-
.../sequencelog/model/GraphReaderCallback.java | 6 +-
.../apache/geode/internal/shared/NativeCalls.java | 4 +-
.../geode/internal/shared/NativeCallsJNAImpl.java | 5 +-
.../geode/internal/size/ObjectGraphSizer.java | 2 +-
.../geode/internal/statistics/HostStatSampler.java | 2 +-
.../internal/statistics/LocalStatListener.java | 2 +-
.../geode/internal/statistics/SampleHandler.java | 8 +-
.../internal/statistics/StatArchiveFormat.java | 74 +-
.../statistics/StatArchiveHandlerConfig.java | 14 +-
.../geode/internal/statistics/StatisticId.java | 4 +-
.../internal/statistics/StatisticsListener.java | 2 +-
.../internal/statistics/StatisticsManager.java | 20 +-
.../statistics/StatisticsNotification.java | 16 +-
.../internal/statistics/StatisticsSampler.java | 8 +-
.../geode/internal/statistics/VMStatsContract.java | 4 +-
.../statistics/platform/OsStatisticsFactory.java | 5 +-
.../apache/geode/internal/tcp/BaseMsgStreamer.java | 12 +-
.../geode/internal/tcp/ByteBufferInputStream.java | 3 +-
.../apache/geode/internal/tcp/ServerDelegate.java | 8 +-
.../geode/internal/util/ArgumentRedactor.java | 168 ++-
.../geode/internal/util/ObjectIntProcedure.java | 2 +-
.../apache/geode/internal/util/Transformer.java | 2 +-
.../apache/geode/internal/util/Versionable.java | 8 +-
.../ConcurrentMapWithReusableEntries.java | 41 +
.../concurrent/CustomEntryConcurrentHashMap.java | 36 +-
.../java/org/apache/geode/lang/Identifiable.java | 2 +-
.../geode/management/AsyncEventQueueMXBean.java | 28 +-
.../management/DistributedLockServiceMXBean.java | 12 +-
.../geode/management/DistributedRegionMXBean.java | 98 +-
.../geode/management/JMXNotificationType.java | 55 +-
.../geode/management/JMXNotificationUserData.java | 6 +-
.../org/apache/geode/management/LocatorMXBean.java | 16 +-
.../org/apache/geode/management/ManagerMXBean.java | 14 +-
.../org/apache/geode/management/RegionMXBean.java | 104 +-
.../apache/geode/management/cli/CliMetaData.java | 6 +-
.../geode/management/cli/CommandStatement.java | 8 +-
.../org/apache/geode/management/cli/Result.java | 18 +-
.../internal/GeodeRemoteStreamExporter.java | 52 +
.../geode/management/internal/ManagementAgent.java | 23 +-
.../management/internal/ManagementConstants.java | 134 ++-
.../internal/NotificationBroadCasterProxy.java | 2 +-
.../geode/management/internal/ProxyInterface.java | 4 +-
.../geode/management/internal/ProxyListener.java | 6 +-
.../internal/beans/AggregateHandler.java | 10 +-
.../internal/beans/CacheServiceMBeanBase.java | 4 +-
.../internal/beans/DistributedSystemBridge.java | 4 +-
.../management/internal/beans/FileUploader.java | 86 +-
.../internal/beans/FileUploaderMBean.java | 5 +-
.../internal/beans/ManagementAdapter.java | 2 +-
.../internal/beans/MemberMBeanBridge.java | 13 +-
.../internal/beans/RegionMBeanBridge.java | 4 +-
.../geode/management/internal/cli/GfshParser.java | 59 +-
.../internal/cli/commands/AlterRegionCommand.java | 36 +-
.../internal/cli/commands/CreateRegionCommand.java | 50 +-
.../internal/cli/commands/DeployCommand.java | 9 +-
.../cli/commands/DescribeRegionCommand.java | 211 ++--
.../internal/cli/commands/GfshCommand.java | 2 +-
.../internal/cli/commands/RegionCommandsUtils.java | 9 -
.../cli/converters/ClassNameConverter.java | 62 ++
.../management/internal/cli/domain/ClassName.java | 124 +++
.../cli/domain/RegionDescriptionPerMember.java | 19 -
.../cli/functions/RegionAlterFunction.java | 52 +-
.../cli/functions/RegionCreateFunction.java | 30 +-
.../internal/cli/functions/RegionFunctionArgs.java | 70 +-
.../internal/cli/functions/ShutDownFunction.java | 6 +
.../management/internal/cli/i18n/CliStrings.java | 3 +
.../geode/management/internal/cli/shell/Gfsh.java | 2 +-
.../internal/cli/shell/JmxOperationInvoker.java | 23 +-
.../internal/cli/shell/OperationInvoker.java | 23 +-
.../functions/DownloadJarFunction.java | 7 +-
.../internal/security/AccessControlMXBean.java | 2 +-
.../membership/ClientMembershipEvent.java | 6 +-
.../membership/ClientMembershipListener.java | 6 +-
.../management/membership/MembershipEvent.java | 4 +-
.../management/membership/MembershipListener.java | 6 +-
.../java/org/apache/geode/pdx/PdxInstance.java | 22 +-
.../org/apache/geode/pdx/PdxInstanceFactory.java | 57 +-
.../main/java/org/apache/geode/pdx/PdxReader.java | 52 +-
.../java/org/apache/geode/pdx/PdxSerializable.java | 4 +-
.../java/org/apache/geode/pdx/PdxSerializer.java | 4 +-
.../main/java/org/apache/geode/pdx/PdxWriter.java | 61 +-
.../org/apache/geode/pdx/WritablePdxInstance.java | 2 +-
.../apache/geode/pdx/internal/ComparableEnum.java | 6 +-
.../geode/pdx/internal/ConvertableToBytes.java | 2 +-
.../geode/pdx/internal/InternalPdxReader.java | 96 +-
.../geode/pdx/internal/TypeRegistration.java | 36 +-
.../java/org/apache/geode/ra/GFConnection.java | 2 +-
.../org/apache/geode/ra/GFConnectionFactory.java | 2 +-
.../org/apache/geode/redis/internal/Executor.java | 2 +-
.../apache/geode/redis/internal/Extendable.java | 2 +-
.../geode/redis/internal/RegionProvider.java | 8 +-
.../org/apache/geode/security/AuthInitialize.java | 5 +-
.../org/apache/geode/internal/privatekey.ser | Bin 756 -> 0 bytes
.../org/apache/geode/internal/publickey.ser | Bin 1029 -> 0 bytes
.../sanctioned-geode-core-serializables.txt | 4 +-
.../internal/index/MemoryIndexStoreJUnitTest.java | 9 +-
.../geode/cache30/MultiVMRegionTestCase.java | 12 +-
.../AnalyzeSerializablesJUnitTest.java | 13 +-
.../geode/distributed/ServerLauncherDUnitTest.java | 112 ++
.../ServerLauncherDUnitTestHelper.java} | 34 +-
.../gms/messenger/GMSEncryptJUnitTest.java | 457 ++-------
.../internal/cache/ARMLockTestHookAdapter.java | 18 +-
.../internal/cache/AbstractRegionJUnitTest.java | 668 +-----------
.../internal/cache/AbstractRegionMapTest.java | 214 ++--
.../BugTxCommitMessageDesiralizeDUnitTest.java | 619 +++++++++++
.../CacheWriterGetOldValueIntegrationTest.java | 4 +-
.../internal/cache/ClearRvvLockingDUnitTest.java | 8 +-
.../internal/cache/ClearTXLockingDUnitTest.java | 2 +-
.../cache/ClientServerTransactionDUnitTest.java | 4 +-
.../geode/internal/cache/ColocationHelperTest.java | 9 -
.../internal/cache/DeltaFaultInDUnitTest.java | 2 +-
...stroyEntryWithConcurrentOperationJUnitTest.java | 229 -----
.../cache/DiskStoreImplIntegrationTest.java | 4 +-
.../cache/JtaAfterCompletionMessageTest.java | 52 +
.../cache/JtaBeforeCompletionMessageTest.java | 52 +
.../backup/BackupFileCopierIntegrationTest.java | 282 +++++
.../cache/backup/BackupIntegrationTest.java | 39 +-
.../internal/cache/backup/BackupLockTest.java | 105 --
.../backup/BackupPrepareAndFinishMsgDUnitTest.java | 38 +-
.../internal/cache/backup/BackupServiceTest.java | 95 ++
.../cache/backup/FinishBackupRequestTest.java | 6 +-
.../backup/IncrementalBackupDistributedTest.java | 2 +-
...titionedBackupPrepareAndFinishMsgDUnitTest.java | 4 +-
...eplicateBackupPrepareAndFinishMsgDUnitTest.java | 4 +-
.../cache/control/RebalanceOperationDUnitTest.java | 6 +-
.../cache/eviction/EvictionStatsDUnitTest.java | 17 +-
.../eviction/OffHeapEvictionStatsDUnitTest.java | 5 +-
.../internal/cache/ha/HARegionQueueDUnitTest.java | 88 +-
.../DestroyEntryDuringCloseIntegrationTest.java | 97 ++
.../internal/cache/map/RegionMapDestroyTest.java | 655 ++++++++++++
.../cache/partitioned/PersistPRKRFDUnitTest.java | 255 -----
.../partitioned/PersistPRKRFIntegrationTest.java | 176 ++++
.../PersistentPartitionedRegionDUnitTest.java | 16 +-
.../tier/sockets/ServerConnectionFactoryTest.java | 4 +-
.../cache/tier/sockets/ServerConnectionTest.java | 139 ++-
.../ParallelQueueRemovalMessageJUnitTest.java | 6 -
.../internal/jta/ClientServerJTADUnitTest.java | 77 +-
.../statistics/DiskSpaceLimitIntegrationTest.java | 16 +-
.../internal/util/ArgumentRedactorJUnitTest.java | 83 +-
.../beans/DistributedSystemBridgeJUnitTest.java | 30 +-
.../internal/beans/FileUploaderTest.java | 4 +-
.../internal/cli/GfshParserAutoCompletionTest.java | 2 +-
.../internal/cli/GfshParserJUnitTest.java | 17 +
.../internal/cli/GfshParserParsingTest.java | 10 -
.../cli/commands/AlterRegionCommandDUnitTest.java | 592 +----------
.../AlterRegionCommandIntegrationTest.java | 9 +-
.../cli/commands/AlterRegionCommandTest.java | 66 ++
.../cli/commands/CreateRegionCommandDUnitTest.java | 44 +-
.../CreateRegionCommandIntegrationTest.java | 32 +-
.../cli/commands/CreateRegionCommandTest.java | 129 ++-
.../cli/commands/DescribeRegionDUnitTest.java | 107 +-
.../cli/commands/ShutdownCommandDUnitTest.java | 52 +-
.../cli/converters/ClassNameConverterTest.java | 87 ++
.../internal/cli/domain/ClassNameTest.java | 115 +++
.../internal/cli/domain/MyCacheWriter.java} | 20 +-
.../ShowMissingDiskStoresFunctionJUnitTest.java | 1 -
.../geode/pdx/internal/MultipleCacheJUnitTest.java | 123 +++
.../security/ClientAuthorizationDUnitTest.java | 756 --------------
...tAuthorizationLegacyConfigurationDUnitTest.java | 216 ++++
...aAuthorizationUsingLegacySecurityDUnitTest.java | 246 +++++
...onUsingLegacySecurityWithFailoverDUnitTest.java | 423 ++++++++
.../security/templates/SimpleAccessController.java | 89 ++
.../security/templates/SimpleAuthenticator.java | 58 ++
.../apache/geode/codeAnalysis/excludedClasses.txt | 1 -
.../codeAnalysis/sanctionedDataSerializables.txt | 2 +-
geode-experimental-driver/build.gradle | 1 -
.../geode/experimental/driver/JSONWrapper.java | 6 +-
geode-json/src/main/java/org/json/JSONString.java | 2 +-
.../java/org/apache/geode/test/junit/Repeat.java | 2 +-
.../java/org/apache/geode/test/junit/Retry.java | 2 +-
.../serializable/FieldsOfTemporaryFolder.java | 6 +-
.../junit/rules/serializable/FieldsOfTestName.java | 2 +-
.../junit/rules/serializable/FieldsOfTimeout.java | 6 +-
.../geode/test/junit/runners/SuiteRunner.java | 2 +-
.../org/apache/geode/cache/lucene/LuceneIndex.java | 10 +-
.../geode/cache/lucene/LuceneIndexFactory.java | 2 +-
.../org/apache/geode/cache/lucene/LuceneQuery.java | 12 +-
.../geode/cache/lucene/LuceneQueryFactory.java | 8 +-
.../geode/cache/lucene/LuceneQueryProvider.java | 2 +-
.../geode/cache/lucene/LuceneResultStruct.java | 6 +-
.../apache/geode/cache/lucene/LuceneService.java | 18 +-
.../cache/lucene/PageableLuceneQueryResults.java | 8 +-
.../geode/cache/lucene/internal/IndexListener.java | 8 +-
.../cache/lucene/internal/InternalLuceneIndex.java | 6 +-
.../internal/repository/IndexRepository.java | 4 +-
.../internal/repository/IndexResultCollector.java | 4 +-
.../lucene/management/LuceneServiceMXBean.java | 6 +-
.../lucene/RebalanceWithRedundancyDUnitTest.java | 41 +-
geode-protobuf/build.gradle | 1 -
.../operations/ProtobufOperationHandler.java | 24 +-
.../protobuf/statistics/ClientStatistics.java | 4 +-
.../protobuf}/statistics/NoOpStatistics.java | 4 +-
...ticsImpl.java => ProtobufClientStatistics.java} | 6 +-
.../internal/protocol/protobuf/v1}/Failure.java | 2 +-
.../v1}/LocatorMessageExecutionContext.java | 16 +-
.../protobuf/v1}/MessageExecutionContext.java | 27 +-
.../protobuf/v1/ProtobufCachePipeline.java | 5 +-
.../protocol/protobuf/v1/ProtobufErrorCode.java | 6 +-
.../protobuf/v1/ProtobufOperationContext.java | 36 +-
.../protocol/protobuf/v1/ProtobufOpsProcessor.java | 24 +-
.../protobuf/v1/ProtobufProtocolService.java | 14 +-
.../protobuf/v1/ProtobufSerializationService.java | 6 +-
.../protobuf/v1/ProtobufStreamProcessor.java | 11 +-
.../internal/protocol/protobuf/v1}/Result.java | 2 +-
.../v1}/ServerMessageExecutionContext.java | 13 +-
.../internal/protocol/protobuf/v1}/Success.java | 2 +-
.../operations/GetAllRequestOperationHandler.java | 19 +-
.../GetRegionNamesRequestOperationHandler.java | 8 +-
.../GetRegionRequestOperationHandler.java | 10 +-
.../v1/operations/GetRequestOperationHandler.java | 14 +-
.../v1/operations/GetServerOperationHandler.java | 15 +-
.../v1/operations/ProtocolVersionHandler.java | 4 +-
.../operations/PutAllRequestOperationHandler.java | 20 +-
.../v1/operations/PutRequestOperationHandler.java | 14 +-
.../operations/RemoveRequestOperationHandler.java | 14 +-
.../AuthenticationRequestOperationHandler.java | 23 +-
.../v1}/serialization/JsonPdxConverter.java | 6 +-
.../v1}/serialization/SerializationService.java | 4 +-
.../v1}/serialization/SerializationType.java | 2 +-
.../protobuf/v1}/serialization/TypeConverter.java | 4 +-
.../serialization/exception/EncodingException.java | 2 +-
.../v1/serializer/ProtobufProtocolSerializer.java | 7 +-
.../exception/InvalidProtocolMessageException.java | 2 +-
...cySecurityProtobufConnectionStateProcessor.java | 21 +-
...NoSecurityProtobufConnectionStateProcessor.java | 19 +-
...bufConnectionAuthenticatingStateProcessor.java} | 30 +-
...rotobufConnectionAuthorizingStateProcessor.java | 25 +-
.../ProtobufConnectionHandshakeStateProcessor.java | 25 +-
.../v1/state/ProtobufConnectionStateProcessor.java | 26 +-
...rotobufConnectionTerminatingStateProcessor.java | 17 +-
.../state/exception/ConnectionStateException.java | 11 +-
.../exception/OperationNotAuthorizedException.java | 6 +-
.../v1/utilities/ProtobufResponseUtilities.java | 6 +-
.../protobuf/v1/utilities/ProtobufUtilities.java | 10 +-
.../OutputCapturingServerConnectionTest.java | 94 ++
...Test.java => ProtobufServerConnectionTest.java} | 14 +-
.../internal/protocol/TestExecutionContext.java | 11 +-
.../protobuf/v1/AuthorizationIntegrationTest.java | 4 +-
.../protocol/protobuf/v1/ErrorCodesJUnitTest.java | 3 +-
.../internal/protocol/protobuf/v1/MessageUtil.java | 2 +-
.../v1/ProtobufProtocolServiceJUnitTest.java | 6 +-
.../v1/acceptance/CacheConnectionJUnitTest.java | 7 +-
.../CacheConnectionTimeoutJUnitTest.java | 8 -
.../v1/acceptance/CacheMaxConnectionJUnitTest.java | 2 +-
.../v1/acceptance/CacheOperationsJUnitTest.java | 4 +-
.../v1/acceptance/LocatorConnectionDUnitTest.java | 10 +-
.../GetAllRequestOperationHandlerJUnitTest.java | 6 +-
.../GetAndPutJsonDocumentsDUnitTest.java | 10 +-
...egionNamesRequestOperationHandlerJUnitTest.java | 4 +-
.../GetRegionRequestOperationHandlerJUnitTest.java | 5 +-
.../GetRequestOperationHandlerJUnitTest.java | 9 +-
.../GetServerOperationHandlerJUnitTest.java | 6 +-
.../v1/operations/OperationHandlerJUnitTest.java | 4 +-
.../ProtocolVersionHandlerJUnitTest.java | 6 +-
.../PutAllRequestOperationHandlerJUnitTest.java | 6 +-
.../PutRequestOperationHandlerJUnitTest.java | 9 +-
.../RemoveRequestOperationHandlerJUnitTest.java | 9 +-
.../codec/JsonPdxConverterJUnitTest.java | 2 +-
.../ProtobufProtocolSerializerJUnitTest.java | 5 +-
.../v1/utilities/ProtobufUtilitiesJUnitTest.java | 2 +-
.../cache/wan/AckReaderThreadJUnitTest.java | 6 -
.../ConcurrentParallelGatewaySenderDUnitTest.java | 76 +-
.../CustomMappingJackson2HttpMessageConverter.java | 4 +-
.../commands/ShutdownCommandOverHttpDUnitTest.java | 2 +-
gradle/test.gradle | 22 +-
settings.gradle | 1 -
728 files changed, 13182 insertions(+), 11013 deletions(-)
create mode 100644
buildSrc/src/main/java/org/apache/geode/javac/EnsureCorrectRunsWithProcessor.java
create mode 100644
buildSrc/src/main/resources/META-INF/services/javax.annotation.processing.Processor
copy
geode-core/src/main/java/org/apache/geode/cache/wan/GatewayTransportFilter.java
=> buildSrc/src/test/java/org/apache/geode/javac/SimpleClassFile.java (60%)
create mode 100644
buildSrc/src/test/java/org/apache/geode/javac/SimpleFileManager.java
copy
geode-core/src/test/java/org/apache/geode/internal/cache/backup/PartitionedBackupPrepareAndFinishMsgDUnitTest.java
=> buildSrc/src/test/java/org/apache/geode/javac/SimpleSourceFile.java (61%)
create mode 100644
buildSrc/src/test/java/org/apache/geode/javac/TestAnnotationProcessor.java
create mode 100644
buildSrc/src/test/java/org/apache/geode/javac/TestCompiler.java
create mode 100755 ci/scripts/capture-call-stacks.sh
delete mode 100644 geode-client-protocol/build.gradle
delete mode 100644
geode-client-protocol/src/main/java/org/apache/geode/internal/protocol/ClientProtocolMessageHandler.java
delete mode 100644
geode-client-protocol/src/main/java/org/apache/geode/internal/protocol/OperationContext.java
delete mode 100644
geode-client-protocol/src/main/java/org/apache/geode/internal/protocol/ProtocolSerializer.java
delete mode 100644
geode-client-protocol/src/main/java/org/apache/geode/internal/protocol/operations/OperationHandler.java
delete mode 100644
geode-client-protocol/src/main/java/org/apache/geode/internal/protocol/state/ConnectionAuthenticatingStateProcessor.java
copy
geode-core/src/main/java/org/apache/geode/internal/cache/{DiskStoreTask.java =>
InternalEntryEvent.java} (80%)
copy
geode-core/src/main/java/org/apache/geode/internal/cache/{DiskStoreTask.java =>
RegionMapOwner.java} (89%)
create mode 100644
geode-core/src/main/java/org/apache/geode/internal/cache/backup/BackupFileCopier.java
delete mode 100644
geode-core/src/main/java/org/apache/geode/internal/cache/backup/BackupLock.java
create mode 100644
geode-core/src/main/java/org/apache/geode/internal/cache/backup/BackupService.java
rename
geode-core/src/main/java/org/apache/geode/internal/cache/backup/{BackupManager.java
=> BackupTask.java} (65%)
copy
extensions/geode-modules/src/main/java/org/apache/geode/modules/gatewaydelta/GatewayDeltaEvent.java
=>
geode-core/src/main/java/org/apache/geode/internal/cache/entries/HashRegionEntry.java
(74%)
copy
geode-client-protocol/src/main/java/org/apache/geode/internal/protocol/Result.java
=>
geode-core/src/main/java/org/apache/geode/internal/cache/map/CacheModificationLock.java
(60%)
create mode 100644
geode-core/src/main/java/org/apache/geode/internal/cache/map/FocusedRegionMap.java
create mode 100644
geode-core/src/main/java/org/apache/geode/internal/cache/map/RegionMapDestroy.java
rename
geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/{LegacyServerConnection.java
=> OriginalServerConnection.java} (95%)
rename
geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/{GenericProtocolServerConnection.java
=> ProtobufServerConnection.java} (90%)
create mode 100644
geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/ServerConnectionCollection.java
create mode 100644
geode-core/src/main/java/org/apache/geode/internal/util/concurrent/ConcurrentMapWithReusableEntries.java
create mode 100644
geode-core/src/main/java/org/apache/geode/management/internal/GeodeRemoteStreamExporter.java
create mode 100644
geode-core/src/main/java/org/apache/geode/management/internal/cli/converters/ClassNameConverter.java
create mode 100644
geode-core/src/main/java/org/apache/geode/management/internal/cli/domain/ClassName.java
delete mode 100644
geode-core/src/main/resources/org/apache/geode/internal/privatekey.ser
delete mode 100644
geode-core/src/main/resources/org/apache/geode/internal/publickey.ser
create mode 100644
geode-core/src/test/java/org/apache/geode/distributed/ServerLauncherDUnitTest.java
copy
geode-core/src/{main/java/org/apache/geode/internal/admin/HealthListener.java
=> test/java/org/apache/geode/distributed/ServerLauncherDUnitTestHelper.java}
(58%)
create mode 100644
geode-core/src/test/java/org/apache/geode/internal/cache/BugTxCommitMessageDesiralizeDUnitTest.java
delete mode 100644
geode-core/src/test/java/org/apache/geode/internal/cache/DestroyEntryWithConcurrentOperationJUnitTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/internal/cache/JtaAfterCompletionMessageTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/internal/cache/JtaBeforeCompletionMessageTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/internal/cache/backup/BackupFileCopierIntegrationTest.java
delete mode 100644
geode-core/src/test/java/org/apache/geode/internal/cache/backup/BackupLockTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/internal/cache/backup/BackupServiceTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/internal/cache/map/DestroyEntryDuringCloseIntegrationTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/internal/cache/map/RegionMapDestroyTest.java
delete mode 100644
geode-core/src/test/java/org/apache/geode/internal/cache/partitioned/PersistPRKRFDUnitTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/internal/cache/partitioned/PersistPRKRFIntegrationTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/AlterRegionCommandTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/management/internal/cli/converters/ClassNameConverterTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/management/internal/cli/domain/ClassNameTest.java
copy
geode-core/src/test/java/org/apache/geode/{internal/cache/backup/PartitionedBackupPrepareAndFinishMsgDUnitTest.java
=> management/internal/cli/domain/MyCacheWriter.java} (68%)
create mode 100644
geode-core/src/test/java/org/apache/geode/pdx/internal/MultipleCacheJUnitTest.java
delete mode 100644
geode-core/src/test/java/org/apache/geode/security/ClientAuthorizationDUnitTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/security/ClientAuthorizationLegacyConfigurationDUnitTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/security/ClientDataAuthorizationUsingLegacySecurityDUnitTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/security/ClientDataAuthorizationUsingLegacySecurityWithFailoverDUnitTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/security/templates/SimpleAccessController.java
create mode 100644
geode-core/src/test/java/org/apache/geode/security/templates/SimpleAuthenticator.java
rename
geode-client-protocol/src/main/java/org/apache/geode/internal/protocol/statistics/ProtocolClientStatistics.java
=>
geode-protobuf/src/main/java/org/apache/geode/internal/protocol/protobuf/statistics/ClientStatistics.java
(93%)
rename {geode-client-protocol/src/main/java/org/apache/geode/internal/protocol
=>
geode-protobuf/src/main/java/org/apache/geode/internal/protocol/protobuf}/statistics/NoOpStatistics.java
(91%)
rename
geode-protobuf/src/main/java/org/apache/geode/internal/protocol/protobuf/statistics/{ProtobufClientStatisticsImpl.java
=> ProtobufClientStatistics.java} (94%)
rename {geode-client-protocol/src/main/java/org/apache/geode/internal/protocol
=>
geode-protobuf/src/main/java/org/apache/geode/internal/protocol/protobuf/v1}/Failure.java
(96%)
rename {geode-client-protocol/src/main/java/org/apache/geode/internal/protocol
=>
geode-protobuf/src/main/java/org/apache/geode/internal/protocol/protobuf/v1}/LocatorMessageExecutionContext.java
(73%)
rename {geode-client-protocol/src/main/java/org/apache/geode/internal/protocol
=>
geode-protobuf/src/main/java/org/apache/geode/internal/protocol/protobuf/v1}/MessageExecutionContext.java
(61%)
rename
geode-client-protocol/src/main/java/org/apache/geode/internal/protocol/ProtocolErrorCode.java
=>
geode-protobuf/src/main/java/org/apache/geode/internal/protocol/protobuf/v1/ProtobufErrorCode.java
(89%)
rename {geode-client-protocol/src/main/java/org/apache/geode/internal/protocol
=>
geode-protobuf/src/main/java/org/apache/geode/internal/protocol/protobuf/v1}/Result.java
(95%)
rename {geode-client-protocol/src/main/java/org/apache/geode/internal/protocol
=>
geode-protobuf/src/main/java/org/apache/geode/internal/protocol/protobuf/v1}/ServerMessageExecutionContext.java
(79%)
rename {geode-client-protocol/src/main/java/org/apache/geode/internal/protocol
=>
geode-protobuf/src/main/java/org/apache/geode/internal/protocol/protobuf/v1}/Success.java
(96%)
rename {geode-client-protocol/src/main/java/org/apache/geode/internal/protocol
=>
geode-protobuf/src/main/java/org/apache/geode/internal/protocol/protobuf/v1}/serialization/JsonPdxConverter.java
(85%)
rename {geode-client-protocol/src/main/java/org/apache/geode/internal/protocol
=>
geode-protobuf/src/main/java/org/apache/geode/internal/protocol/protobuf/v1}/serialization/SerializationService.java
(88%)
rename {geode-client-protocol/src/main/java/org/apache/geode/internal/protocol
=>
geode-protobuf/src/main/java/org/apache/geode/internal/protocol/protobuf/v1}/serialization/SerializationType.java
(94%)
rename {geode-client-protocol/src/main/java/org/apache/geode/internal/protocol
=>
geode-protobuf/src/main/java/org/apache/geode/internal/protocol/protobuf/v1}/serialization/TypeConverter.java
(89%)
rename {geode-client-protocol/src/main/java/org/apache/geode/internal/protocol
=>
geode-protobuf/src/main/java/org/apache/geode/internal/protocol/protobuf/v1}/serialization/exception/EncodingException.java
(93%)
rename {geode-client-protocol/src/main/java/org/apache/geode/internal/protocol
=>
geode-protobuf/src/main/java/org/apache/geode/internal/protocol/protobuf/v1/serializer}/exception/InvalidProtocolMessageException.java
(93%)
rename
geode-client-protocol/src/main/java/org/apache/geode/internal/protocol/state/LegacySecurityConnectionStateProcessor.java
=>
geode-protobuf/src/main/java/org/apache/geode/internal/protocol/protobuf/v1/state/LegacySecurityProtobufConnectionStateProcessor.java
(61%)
rename
geode-client-protocol/src/main/java/org/apache/geode/internal/protocol/state/NoSecurityConnectionStateProcessor.java
=>
geode-protobuf/src/main/java/org/apache/geode/internal/protocol/protobuf/v1/state/NoSecurityProtobufConnectionStateProcessor.java
(58%)
rename
geode-protobuf/src/main/java/org/apache/geode/internal/protocol/protobuf/v1/state/{ConnectionShiroAuthenticatingStateProcessor.java
=> ProtobufConnectionAuthenticatingStateProcessor.java} (61%)
rename
geode-client-protocol/src/main/java/org/apache/geode/internal/protocol/state/ConnectionShiroAuthorizingStateProcessor.java
=>
geode-protobuf/src/main/java/org/apache/geode/internal/protocol/protobuf/v1/state/ProtobufConnectionAuthorizingStateProcessor.java
(65%)
rename
geode-client-protocol/src/main/java/org/apache/geode/internal/protocol/state/ConnectionStateProcessor.java
=>
geode-protobuf/src/main/java/org/apache/geode/internal/protocol/protobuf/v1/state/ProtobufConnectionStateProcessor.java
(73%)
rename
geode-client-protocol/src/main/java/org/apache/geode/internal/protocol/state/ConnectionTerminatingStateProcessor.java
=>
geode-protobuf/src/main/java/org/apache/geode/internal/protocol/protobuf/v1/state/ProtobufConnectionTerminatingStateProcessor.java
(61%)
rename {geode-client-protocol/src/main/java/org/apache/geode/internal/protocol
=>
geode-protobuf/src/main/java/org/apache/geode/internal/protocol/protobuf/v1}/state/exception/ConnectionStateException.java
(76%)
rename {geode-client-protocol/src/main/java/org/apache/geode/internal/protocol
=>
geode-protobuf/src/main/java/org/apache/geode/internal/protocol/protobuf/v1}/state/exception/OperationNotAuthorizedException.java
(81%)
create mode 100644
geode-protobuf/src/test/java/org/apache/geode/internal/cache/tier/sockets/OutputCapturingServerConnectionTest.java
rename
geode-protobuf/src/test/java/org/apache/geode/internal/cache/tier/sockets/{GenericProtocolServerConnectionTest.java
=> ProtobufServerConnectionTest.java} (92%)
--
To stop receiving notification emails like this one, please contact
zho...@apache.org.
