This is an automated email from the ASF dual-hosted git repository.
donalevans pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/geode.git.
from 798037e GEODE-9306: support ZINCRBY command (#6534)
add 2879573 GEODE-7864: Always use curly braces for control flow
statements (#6523)
No new revisions were added by this update.
Summary of changes:
.../geode/modules/session/installer/Installer.java | 6 +-
.../LocalSessionCacheWriterIntegrationTest.java | 9 +-
.../web/controllers/AddFreeItemToOrders.java | 15 +-
.../web/controllers/GetDeliveredOrders.java | 15 +-
.../geode/rest/internal/web/controllers/Order.java | 9 +-
.../web/controllers/RedactingPostProcessor.java | 9 +-
.../geode/session/tests/ContainerInstall.java | 3 +-
.../geode/session/tests/ContainerManager.java | 18 +-
.../geode/session/tests/ServerContainer.java | 6 +-
.../geode/tools/pulse/PulseConnectivityTest.java | 3 +-
.../tools/pulse/ui/PulseAcceptanceTestBase.java | 15 +-
.../apache/geode/util/internal/GeodeConverter.java | 9 +-
.../geode/test/concurrency/loop/LoopRunner.java | 4 +-
.../internal/cli/ListMappingCommandDUnitTest.java | 3 +-
.../connectors/jdbc/internal/xml/ElementType.java | 3 +-
.../management/MemoryThresholdsDUnitTest.java | 9 +-
.../MemoryThresholdsOffHeapDUnitTest.java | 12 +-
.../cache/management/ResourceManagerDUnitTest.java | 3 +-
.../partition/PartitionRegionHelperDUnitTest.java | 18 +-
.../dunit/QueryUsingFunctionContextDUnitTest.java | 30 +-
...igurationServiceConstraintsDistributedTest.java | 9 +-
...ncurrentIndexInitOnOverflowRegionDUnitTest.java | 6 +-
...exUpdateWithInplaceObjectModFalseDUnitTest.java | 3 +-
.../ConcurrentIndexUpdateWithoutWLDUnitTest.java | 3 +-
.../index/PutAllWithIndexPerfDUnitTest.java | 6 +-
.../query/partitioned/PRBasicQueryDUnitTest.java | 3 +-
.../query/partitioned/PRQueryDUnitHelper.java | 12 +-
.../cache30/ClientRegisterInterestDUnitTest.java | 9 +-
.../geode/cache30/DistAckMapMethodsDUnitTest.java | 3 +-
.../cache30/PutAllCallBkRemoteVMDUnitTest.java | 12 +-
.../geode/cache30/RegionReliabilityTestCase.java | 9 +-
.../org/apache/geode/cache30/SlowRecDUnitTest.java | 3 +-
.../geode/cache30/TXDistributedDUnitTest.java | 3 +-
.../distributed/DistributedLockBlackboardImpl.java | 9 +-
.../DistributedLockServiceDUnitTest.java | 12 +-
.../apache/geode/disttx/DistTXDebugDUnitTest.java | 6 +-
.../cache/ClientServerGetAllDUnitTest.java | 20 +-
.../cache/ClientServerTransactionDUnitTest.java | 15 +-
.../internal/cache/ConcurrentMapOpsDUnitTest.java | 3 +-
.../PartitionedRegionCacheLoaderForRootRegion.java | 3 +-
.../PartitionedRegionCacheLoaderForSubRegion.java | 3 +-
.../internal/cache/RemoteTransactionDUnitTest.java | 3 +-
.../internal/cache/RemoveGlobalDUnitTest.java | 6 +-
.../geode/internal/cache/SizingFlagDUnitTest.java | 30 +-
.../cache/TransactionsWithDeltaDUnitTest.java | 3 +-
.../cache/execute/ColocationFailoverDUnitTest.java | 6 +-
.../cache/execute/LocalDataSetDUnitTest.java | 6 +-
...lientServerFunctionExecutionNoAckDUnitTest.java | 6 +-
.../cache/execute/PRColocationDUnitTest.java | 20 +-
.../geode/internal/cache/execute/TimeKeeper.java | 3 +-
.../geode/internal/cache/ha/HAClearDUnitTest.java | 24 +-
.../internal/cache/ha/HADuplicateDUnitTest.java | 9 +-
.../geode/internal/cache/ha/HAGIIBugDUnitTest.java | 12 +-
.../internal/cache/ha/HARegionQueueDUnitTest.java | 3 +-
.../partitioned/PartitionResolverDUnitTest.java | 42 +-
.../sockets/EventIDVerificationInP2PDUnitTest.java | 8 +-
.../cache/tier/sockets/HAInterestTestCase.java | 6 +-
.../sockets/InterestListEndpointDUnitTest.java | 18 +-
.../sockets/InterestRegrListenerDUnitTest.java | 11 +-
.../tier/sockets/NewRegionAttributesDUnitTest.java | 33 +-
.../jta/dunit/TransactionTimeOutDUnitTest.java | 18 +-
.../internal/jta/dunit/TxnTimeOutDUnitTest.java | 12 +-
.../geode/pdx/JSONPdxClientServerDUnitTest.java | 18 +-
.../java/org/apache/geode/CopyJUnitTest.java | 54 ++-
.../java/org/apache/geode/TXJUnitTest.java | 24 +-
.../org/apache/geode/cache/ProxyJUnitTest.java | 4 +-
.../operations/PutOperationContextJUnitTest.java | 15 +-
.../apache/geode/cache/query/QueryJUnitTest.java | 3 +-
.../cache/query/QueryServiceRegressionTest.java | 9 +-
.../functional/ComparisonOperatorsJUnitTest.java | 12 +-
.../cache/query/functional/ConstantsJUnitTest.java | 18 +-
...tinctResultsWithDupValuesInRegionJUnitTest.java | 6 +-
.../cache/query/functional/FunctionJUnitTest.java | 24 +-
.../query/functional/IUM6Bug32345ReJUnitTest.java | 15 +-
.../geode/cache/query/functional/IUMJUnitTest.java | 6 +-
.../query/functional/IndexOperatorJUnitTest.java | 33 +-
.../functional/IndexPrimaryKeyUsageJUnitTest.java | 3 +-
.../IndexUsageInNestedQueryJUnitTest.java | 3 +-
.../IndexUseMultFrmSnglCondJUnitTest.java | 6 +-
.../IndexWithSngleFrmAndMultCondQryJUnitTest.java | 66 ++--
.../query/functional/IteratorTypeDefJUnitTest.java | 6 +-
.../IteratorTypeDefaultTypesJUnitTest.java | 36 +-
.../functional/IumMultConditionJUnitTest.java | 15 +-
.../query/functional/LimitClauseJUnitTest.java | 21 +-
.../functional/LogicalOperatorsJUnitTest.java | 39 +-
.../query/functional/MultipleRegionsJUnitTest.java | 3 +-
.../query/functional/NestedQueryJUnitTest.java | 12 +-
.../functional/QRegionInterfaceJUnitTest.java | 21 +-
.../functional/StructMemberAccessJUnitTest.java | 6 +-
.../CompiledJunctionInternalsJUnitTest.java | 3 +-
.../internal/ProjectionAttributeJUnitTest.java | 25 +-
.../QueryFromClauseCanonicalizationJUnitTest.java | 3 +-
.../query/internal/QueryObserverCallbacksTest.java | 3 +-
.../cache/query/internal/QueryUtilsJUnitTest.java | 6 +-
.../index/DeclarativeIndexCreationJUnitTest.java | 12 +-
.../index/IndexManagerIntegrationTest.java | 6 +-
...ProgRegionCreationIndexUpdateTypeJUnitTest.java | 12 +-
...qualityShouldUseArrayEqualsIntegrationTest.java | 54 ++-
...urrentFlushingAndRegionOperationsJUnitTest.java | 3 +-
.../cache/ConcurrentRegionOperationsJUnitTest.java | 3 +-
.../internal/cache/DiskRegRecoveryJUnitTest.java | 24 +-
.../internal/cache/DiskRegionClearJUnitTest.java | 3 +-
.../cache/PartitionedRegionCreationJUnitTest.java | 24 +-
...itionedRegionQueryEvaluatorIntegrationTest.java | 3 +-
...itionedRegionSingleNodeOperationsJUnitTest.java | 15 +-
...skRegionOverflowAsyncRollingOpLogJUnitTest.java | 18 +-
.../ha/BlockingHARQAddOperationJUnitTest.java | 6 +-
.../cache/ha/HARQAddOperationJUnitTest.java | 27 +-
.../tier/sockets/ConnectionProxyJUnitTest.java | 3 +-
.../datasource/AbstractPoolCacheJUnitTest.java | 3 +-
.../internal/datasource/CleanUpJUnitTest.java | 3 +-
.../ConnectionPoolCacheImplJUnitTest.java | 3 +-
.../datasource/ConnectionPoolingJUnitTest.java | 9 +-
.../datasource/DataSourceFactoryJUnitTest.java | 9 +-
.../internal/jta/GlobalTransactionJUnitTest.java | 21 +-
.../internal/jta/functional/CacheJUnitTest.java | 94 +++--
.../StatTypesAreRolledOverRegressionTest.java | 3 +-
.../concurrent/cm/ConcurrentHashMapJUnitTest.java | 3 +-
.../concurrent/cm/CountedMapLoopsJUnitTest.java | 45 ++-
.../util/concurrent/cm/IntMapCheckJUnitTest.java | 132 ++++---
.../util/concurrent/cm/MapCheckJUnitTest.java | 132 ++++---
.../util/concurrent/cm/MapLoopsJUnitTest.java | 43 +-
.../util/concurrent/cm/RLJBarJUnitTest.java | 12 +-
.../concurrent/cm/StringMapLoopsJUnitTest.java | 37 +-
.../internal/security/CliCommandsSecurityTest.java | 3 +-
.../geode/pdx/AutoSerializableJUnitTest.java | 105 +++--
.../geode/pdx/PdxInstanceFactoryJUnitTest.java | 12 +-
.../apache/geode/pdx/PdxSerializableJUnitTest.java | 18 +-
.../src/main/java/org/apache/geode/CopyHelper.java | 33 +-
.../org/apache/geode/GemFireCheckedException.java | 3 +-
.../org/apache/geode/InternalGemFireError.java | 3 +-
.../main/java/org/apache/geode/SystemFailure.java | 3 +-
.../java/org/apache/geode/admin/AlertLevel.java | 15 +-
.../org/apache/geode/admin/SystemMemberType.java | 12 +-
.../admin/internal/AdminDistributedSystemImpl.java | 24 +-
.../internal/DistributedSystemConfigImpl.java | 6 +-
.../internal/DistributedSystemHealthEvaluator.java | 3 +-
.../admin/internal/DistributionLocatorImpl.java | 6 +-
.../internal/EnabledManagedEntityController.java | 15 +-
.../admin/internal/ManagedSystemMemberImpl.java | 6 +-
.../geode/admin/internal/SystemMemberImpl.java | 18 +-
.../internal/AdminDistributedSystemJmxImpl.java | 15 +-
.../apache/geode/admin/jmx/internal/AgentImpl.java | 18 +-
.../admin/jmx/internal/CacheServerJmxImpl.java | 6 +-
.../geode/admin/jmx/internal/MBeanUtils.java | 3 +-
.../geode/admin/jmx/internal/MX4JModelMBean.java | 426 +++++++++++++-------
.../admin/jmx/internal/ManagedResourceType.java | 15 +-
.../jmx/internal/RefreshNotificationType.java | 15 +-
.../jmx/internal/StatisticResourceJmxImpl.java | 6 +-
.../geode/admin/jmx/internal/SystemMemberJmx.java | 4 +-
.../admin/jmx/internal/SystemMemberJmxImpl.java | 6 +-
.../org/apache/geode/cache/AttributesFactory.java | 15 +-
.../java/org/apache/geode/cache/DataPolicy.java | 3 +-
.../apache/geode/cache/DynamicRegionFactory.java | 44 ++-
.../org/apache/geode/cache/EvictionAction.java | 6 +-
.../org/apache/geode/cache/EvictionAlgorithm.java | 6 +-
.../apache/geode/cache/MembershipAttributes.java | 22 +-
.../apache/geode/cache/SubscriptionAttributes.java | 12 +-
.../client/internal/AutoConnectionSourceImpl.java | 3 +-
.../client/internal/ClientPartitionAdvisor.java | 3 +-
.../geode/cache/client/internal/Endpoint.java | 9 +-
.../client/internal/ExecuteFunctionNoAckOp.java | 10 +-
.../internal/ExecuteRegionFunctionNoAckOp.java | 10 +-
.../internal/ExecuteRegionFunctionSingleHopOp.java | 3 +-
.../apache/geode/cache/client/internal/GetOp.java | 3 +-
.../geode/cache/client/internal/PoolImpl.java | 12 +-
.../apache/geode/cache/client/internal/PutOp.java | 6 +-
.../cache/client/internal/QueueManagerImpl.java | 6 +-
.../cache/client/internal/QueueStateImpl.java | 3 +-
.../client/internal/SingleHopClientExecutor.java | 7 +-
.../client/internal/pooling/PooledConnection.java | 9 +-
.../query/internal/AbstractCompiledValue.java | 9 +-
.../internal/AbstractGroupOrRangeJunction.java | 18 +-
.../cache/query/internal/AttributeDescriptor.java | 9 +-
.../org/apache/geode/cache/query/internal/Bag.java | 3 +-
.../cache/query/internal/CompiledArithmetic.java | 44 ++-
.../cache/query/internal/CompiledComparison.java | 18 +-
.../geode/cache/query/internal/CompiledID.java | 3 +-
.../geode/cache/query/internal/CompiledIn.java | 9 +-
.../cache/query/internal/CompiledJunction.java | 63 +--
.../cache/query/internal/CompiledNegation.java | 6 +-
.../cache/query/internal/CompiledOperation.java | 12 +-
.../geode/cache/query/internal/CompiledPath.java | 6 +-
.../cache/query/internal/CompiledUnaryMinus.java | 21 +-
.../cache/query/internal/CompiledUndefined.java | 11 +-
.../cache/query/internal/CqQueryVsdStats.java | 3 +-
.../cache/query/internal/DefaultQueryService.java | 15 +-
.../cache/query/internal/ExecutionContext.java | 19 +-
.../geode/cache/query/internal/Functions.java | 9 +-
.../query/internal/IndexConditioningHelper.java | 3 +-
.../cache/query/internal/LinkedResultSet.java | 3 +-
.../cache/query/internal/LinkedStructSet.java | 3 +-
.../geode/cache/query/internal/MethodDispatch.java | 30 +-
.../cache/query/internal/ObjectIntHashMap.java | 121 ++++--
.../geode/cache/query/internal/PathUtils.java | 8 +-
.../geode/cache/query/internal/QCompiler.java | 17 +-
.../apache/geode/cache/query/internal/QRegion.java | 12 +-
.../geode/cache/query/internal/QueryUtils.java | 24 +-
.../geode/cache/query/internal/RangeJunction.java | 15 +-
.../query/internal/ResultsCollectionWrapper.java | 12 +-
.../geode/cache/query/internal/ResultsSet.java | 3 +-
.../cache/query/internal/RuntimeIterator.java | 3 +-
.../cache/query/internal/SortedResultSet.java | 3 +-
.../cache/query/internal/SortedStructSet.java | 3 +-
.../geode/cache/query/internal/StructBag.java | 9 +-
.../geode/cache/query/internal/StructImpl.java | 15 +-
.../geode/cache/query/internal/StructSet.java | 9 +-
.../apache/geode/cache/query/internal/Support.java | 15 +-
.../cache/query/internal/index/AbstractIndex.java | 6 +-
.../query/internal/index/CompactRangeIndex.java | 9 +-
.../cache/query/internal/index/DummyQRegion.java | 6 +-
.../index/FunctionalIndexCreationHelper.java | 3 +-
.../cache/query/internal/index/HashIndex.java | 6 +-
.../cache/query/internal/index/HashIndexSet.java | 9 +-
.../cache/query/internal/index/IndexElemArray.java | 18 +-
.../cache/query/internal/index/IndexManager.java | 6 +-
.../query/internal/index/PrimaryKeyIndex.java | 6 +-
.../index/PrimaryKeyIndexCreationHelper.java | 3 +-
.../cache/query/internal/index/RangeIndex.java | 15 +-
.../cache/query/internal/parse/ASTLiteral.java | 56 ++-
.../cache/query/internal/parse/UtilParser.java | 3 +-
.../query/internal/types/NumericComparator.java | 31 +-
.../cache/query/internal/types/ObjectTypeImpl.java | 3 +-
.../cache/query/internal/types/StructTypeImpl.java | 6 +-
.../query/internal/types/TemporalComparator.java | 3 +-
.../cache/query/internal/xml/ElementType.java | 3 +-
.../org/apache/geode/cache/server/ServerLoad.java | 21 +-
.../apache/geode/cache/wan/EventSequenceID.java | 3 +-
.../geode/distributed/DurableClientAttributes.java | 15 +-
.../internal/ClusterDistributionManager.java | 37 +-
.../internal/ClusterOperationExecutors.java | 9 +-
.../distributed/internal/DistributionAdvisor.java | 6 +-
.../distributed/internal/DistributionImpl.java | 22 +-
.../internal/HighPriorityAckedMessage.java | 3 +-
.../distributed/internal/LocatorLoadSnapshot.java | 3 +-
.../internal/OverflowQueueWithDMStats.java | 12 +-
.../geode/distributed/internal/ReplyMessage.java | 3 +-
.../distributed/internal/ReplyProcessor21.java | 9 +-
.../distributed/internal/SerialAckedMessage.java | 3 +-
.../geode/distributed/internal/ServerLocation.java | 15 +-
.../internal/ServerLocationAndMemberId.java | 9 +-
.../geode/distributed/internal/StartupMessage.java | 6 +-
.../distributed/internal/StartupOperation.java | 3 +-
.../ThrottlingMemLinkedQueueWithDMStats.java | 3 +-
.../internal/deadlock/DLockDependencyMonitor.java | 21 +-
.../distributed/internal/deadlock/Dependency.java | 21 +-
.../internal/deadlock/LocalLockInfo.java | 18 +-
.../distributed/internal/deadlock/LocalThread.java | 18 +-
.../deadlock/MessageDependencyMonitor.java | 18 +-
.../internal/deadlock/UnsafeThreadLocal.java | 3 +-
.../distributed/internal/direct/DirectChannel.java | 9 +-
.../distributed/internal/locks/DLockGrantor.java | 81 ++--
.../internal/locks/DLockQueryProcessor.java | 3 +-
.../locks/DLockRecoverGrantorProcessor.java | 3 +-
.../internal/locks/DLockReleaseProcessor.java | 6 +-
.../internal/locks/DLockRequestProcessor.java | 24 +-
.../distributed/internal/locks/DLockService.java | 42 +-
.../distributed/internal/locks/DLockToken.java | 6 +-
.../distributed/internal/locks/ElderState.java | 6 +-
.../internal/locks/GrantorRequestProcessor.java | 3 +-
.../distributed/internal/locks/LockGrantorId.java | 18 +-
.../distributed/internal/locks/RemoteThread.java | 15 +-
.../membership/InternalDistributedMember.java | 3 +-
.../internal/membership/InternalRole.java | 12 +-
.../membership/adapter/auth/GMSAuthenticator.java | 3 +-
.../geode/examples/SimpleSecurityManager.java | 3 +-
.../examples/security/ExampleSecurityManager.java | 9 +-
.../org/apache/geode/internal/ConfigSource.java | 9 +-
.../geode/internal/HeapDataOutputStream.java | 6 +-
.../apache/geode/internal/ObjIdConcurrentMap.java | 118 ++++--
.../java/org/apache/geode/internal/ObjIdMap.java | 5 +-
.../org/apache/geode/internal/SystemAdmin.java | 12 +-
.../apache/geode/internal/admin/ListenerIdMap.java | 5 +-
.../geode/internal/admin/StatAlertsManager.java | 6 +-
.../internal/admin/remote/AdminReplyProcessor.java | 3 +-
.../geode/internal/admin/remote/CacheDisplay.java | 3 +-
.../admin/remote/CancellationRegistry.java | 3 +-
.../admin/remote/DistributionLocatorId.java | 42 +-
.../internal/admin/remote/EntryValueNodeImpl.java | 12 +-
.../admin/remote/ObjectDetailsResponse.java | 15 +-
.../internal/admin/remote/RemoteEntrySnapshot.java | 3 +-
.../admin/remote/RemoteGfManagerAgent.java | 3 +-
.../admin/remote/RemoteRegionSnapshot.java | 3 +-
.../internal/admin/remote/TailLogResponse.java | 3 +-
.../internal/admin/statalerts/FunctionHelper.java | 15 +-
.../admin/statalerts/MultiAttrDefinitionImpl.java | 6 +-
.../statalerts/NumberThresholdDecoratorImpl.java | 5 +-
.../admin/statalerts/SingleAttrDefinitionImpl.java | 9 +-
.../admin/statalerts/StatisticInfoImpl.java | 12 +-
.../internal/cache/AbstractBucketRegionQueue.java | 3 +-
.../geode/internal/cache/AbstractDiskRegion.java | 15 +-
.../geode/internal/cache/AbstractRegion.java | 6 +-
.../geode/internal/cache/AbstractRegionMap.java | 42 +-
.../apache/geode/internal/cache/BucketAdvisor.java | 12 +-
.../apache/geode/internal/cache/BucketDump.java | 21 +-
.../geode/internal/cache/BucketRegionQueue.java | 3 +-
.../geode/internal/cache/CacheClientStatus.java | 3 +-
.../internal/cache/CacheDistributionAdvisor.java | 63 ++-
.../geode/internal/cache/CacheObserverHolder.java | 3 +-
.../geode/internal/cache/CachePerfStats.java | 6 +-
.../geode/internal/cache/ColocationHelper.java | 8 +-
.../internal/cache/CreateRegionProcessor.java | 3 +-
.../internal/cache/DestroyRegionOperation.java | 12 +-
.../apache/geode/internal/cache/DiskInitFile.java | 21 +-
.../apache/geode/internal/cache/DiskRegion.java | 6 +-
.../apache/geode/internal/cache/DiskStoreImpl.java | 30 +-
.../internal/cache/DistributedCacheOperation.java | 3 +-
.../internal/cache/DistributedClearOperation.java | 21 +-
.../internal/cache/DistributedPutAllOperation.java | 9 +-
.../geode/internal/cache/DistributedRegion.java | 46 ++-
.../DistributedRegionFunctionStreamingMessage.java | 24 +-
.../cache/DistributedRemoveAllOperation.java | 9 +-
.../geode/internal/cache/EntryEventImpl.java | 21 +-
.../org/apache/geode/internal/cache/EventID.java | 15 +-
.../geode/internal/cache/EventStateHelper.java | 12 +-
.../apache/geode/internal/cache/ExpiryTask.java | 23 +-
.../apache/geode/internal/cache/FilterProfile.java | 18 +-
.../cache/ForceableLinkedBlockingQueue.java | 129 ++++--
.../apache/geode/internal/cache/GridAdvisor.java | 3 +-
.../geode/internal/cache/IdentityArrayList.java | 127 +++---
.../internal/cache/InitialImageOperation.java | 6 +-
.../cache/MemberFunctionStreamingMessage.java | 27 +-
.../org/apache/geode/internal/cache/Oplog.java | 54 ++-
.../apache/geode/internal/cache/OverflowOplog.java | 21 +-
.../geode/internal/cache/PRQueryProcessor.java | 6 +-
.../geode/internal/cache/PartitionedRegion.java | 25 +-
.../internal/cache/PartitionedRegionDataStore.java | 6 +-
.../internal/cache/PartitionedRegionHelper.java | 12 +-
.../cache/PreferBytesCachedDeserializable.java | 3 +-
.../geode/internal/cache/RegionIdleExpiryTask.java | 3 +-
.../geode/internal/cache/RegionTTLExpiryTask.java | 3 +-
.../cache/SearchLoadAndWriteProcessor.java | 60 ++-
.../geode/internal/cache/ServerPingMessage.java | 9 +-
.../apache/geode/internal/cache/TXEntryState.java | 12 +-
.../geode/internal/cache/TXFarSideCMTracker.java | 3 +-
.../java/org/apache/geode/internal/cache/TXId.java | 3 +-
.../apache/geode/internal/cache/TXManagerImpl.java | 9 +-
.../apache/geode/internal/cache/TXRegionState.java | 3 +-
.../org/apache/geode/internal/cache/TXState.java | 9 +-
.../geode/internal/cache/UpdateOperation.java | 3 +-
.../internal/cache/VMCachedDeserializable.java | 12 +-
.../geode/internal/cache/VMLRURegionMap.java | 9 +-
.../CompressedCachedDeserializable.java | 3 +-
.../cache/control/RebalanceOperationImpl.java | 3 +-
.../cache/control/RebalanceResultsImpl.java | 6 +-
.../cache/entries/AbstractRegionEntry.java | 23 +-
.../geode/internal/cache/entries/DiskEntry.java | 12 +-
.../execute/FunctionStreamingResultCollector.java | 3 +-
.../cache/execute/StreamingFunctionOperation.java | 3 +-
.../geode/internal/cache/ha/HARegionQueue.java | 15 +-
.../cache/locks/TXLessorDepartureHandler.java | 3 +-
.../geode/internal/cache/locks/TXLockIdImpl.java | 12 +-
.../geode/internal/cache/locks/TXLockService.java | 3 +-
.../cache/locks/TXOriginatorRecoveryProcessor.java | 3 +-
.../AllBucketProfilesUpdateMessage.java | 9 +-
.../partitioned/BucketProfileUpdateMessage.java | 9 +-
.../cache/partitioned/ColocatedRegionDetails.java | 9 +-
.../internal/cache/partitioned/DestroyMessage.java | 3 +-
.../internal/cache/partitioned/DumpB2NRegion.java | 3 +-
.../cache/partitioned/FetchEntryMessage.java | 3 +-
.../cache/partitioned/IndexCreationMsg.java | 6 +-
.../cache/partitioned/PartitionMessage.java | 21 +-
.../PartitionedRegionFunctionStreamingMessage.java | 3 +-
.../cache/partitioned/PutAllPRMessage.java | 12 +-
.../internal/cache/partitioned/PutMessage.java | 21 +-
.../internal/cache/partitioned/RegionAdvisor.java | 14 +-
.../cache/partitioned/RemoveAllPRMessage.java | 12 +-
.../cache/partitioned/RemoveIndexesMessage.java | 6 +-
.../internal/cache/partitioned/SizeMessage.java | 3 +-
.../partitioned/StreamingPartitionOperation.java | 9 +-
.../internal/cache/persistence/DiskStoreID.java | 15 +-
.../cache/persistence/PRPersistentConfig.java | 18 +-
.../cache/persistence/PersistentMemberID.java | 39 +-
.../cache/persistence/PersistentMemberPattern.java | 30 +-
.../cache/persistence/query/mock/Pair.java | 21 +-
.../internal/cache/snapshot/FlowController.java | 15 +-
.../cache/snapshot/RegionSnapshotServiceImpl.java | 6 +-
.../internal/cache/snapshot/WindowedExporter.java | 9 +-
.../cache/tier/InternalClientMembership.java | 6 +-
.../internal/cache/tier/sockets/BaseCommand.java | 3 +-
.../cache/tier/sockets/CacheClientProxy.java | 12 +-
.../cache/tier/sockets/CacheClientUpdater.java | 3 +-
.../cache/tier/sockets/CacheServerHelper.java | 6 +-
.../cache/tier/sockets/ChunkedMessage.java | 11 +-
.../cache/tier/sockets/ClientHealthMonitor.java | 6 +-
.../cache/tier/sockets/ClientUserAuths.java | 10 +-
.../internal/cache/tier/sockets/Handshake.java | 6 +-
.../geode/internal/cache/tier/sockets/Message.java | 3 +-
.../cache/tier/sockets/MessageDispatcher.java | 3 +-
.../cache/tier/sockets/ServerConnection.java | 6 +-
.../cache/tier/sockets/command/PeriodicAck.java | 3 +-
.../cache/tx/RemoteContainsKeyValueMessage.java | 3 +-
.../internal/cache/tx/RemoteDestroyMessage.java | 18 +-
.../internal/cache/tx/RemoteOperationMessage.java | 12 +-
.../internal/cache/tx/RemotePutAllMessage.java | 9 +-
.../geode/internal/cache/tx/RemotePutMessage.java | 42 +-
.../internal/cache/tx/RemoteRemoveAllMessage.java | 6 +-
.../internal/cache/versions/RVVExceptionB.java | 3 +-
.../cache/versions/RegionVersionVector.java | 9 +-
.../geode/internal/cache/versions/VersionTag.java | 24 +-
.../wan/AbstractGatewaySenderEventProcessor.java | 4 +-
.../internal/cache/wan/GatewaySenderAdvisor.java | 12 +-
.../ConcurrentParallelGatewaySenderQueue.java | 6 +-
.../wan/parallel/ParallelGatewaySenderQueue.java | 42 +-
.../cache/wan/serial/BatchDestroyOperation.java | 3 +-
.../serial/SerialGatewaySenderEventProcessor.java | 9 +-
.../cache/wan/serial/SerialGatewaySenderQueue.java | 6 +-
.../internal/cache/xmlcache/CacheXmlGenerator.java | 366 +++++++++++------
.../internal/cache/xmlcache/CacheXmlParser.java | 13 +-
.../geode/internal/concurrent/AtomicLong5.java | 6 +-
.../apache/geode/internal/concurrent/Atomics.java | 6 +-
.../concurrent/CompactConcurrentHashSet2.java | 434 +++++++++++++--------
.../org/apache/geode/internal/concurrent/LI.java | 18 +-
.../internal/datasource/AbstractPoolCache.java | 11 +-
.../datasource/ConfiguredDataSourceProperties.java | 15 +-
.../internal/datasource/DataSourceFactory.java | 27 +-
.../datasource/GemFireConnPooledDataSource.java | 7 +-
.../datasource/GemFireTransactionDataSource.java | 3 +-
.../datasource/JCAConnectionManagerImpl.java | 6 +-
.../internal/datasource/TranxPoolCacheImpl.java | 3 +-
.../i18n/AbstractStringIdResourceBundle.java | 3 +-
.../apache/geode/internal/jndi/ContextImpl.java | 9 +-
.../internal/jndi/InitialContextFactoryImpl.java | 5 +-
.../apache/geode/internal/jndi/JNDIInvoker.java | 57 ++-
.../geode/internal/jta/GlobalTransaction.java | 86 ++--
.../apache/geode/internal/jta/TransactionImpl.java | 21 +-
.../geode/internal/jta/TransactionManagerImpl.java | 111 ++++--
.../geode/internal/jta/UserTransactionImpl.java | 3 +-
.../geode/internal/logging/LogFileParser.java | 8 +
.../internal/monitoring/ThreadsMonitoringImpl.java | 3 +-
.../monitoring/executor/AbstractExecutor.java | 6 +-
.../geode/internal/offheap/FreeListManager.java | 12 +-
.../offheap/OffHeapStoredObjectAddressStack.java | 3 +-
.../geode/internal/offheap/RefCountChangeInfo.java | 6 +-
.../geode/internal/sequencelog/model/Edge.java | 30 +-
.../geode/internal/sequencelog/model/GraphID.java | 21 +-
.../geode/internal/sequencelog/model/Vertex.java | 24 +-
.../internal/size/ReflectionSingleObjectSizer.java | 21 +-
.../geode/internal/statistics/HostStatSampler.java | 15 +-
.../internal/statistics/StatArchiveReader.java | 39 +-
.../statistics/platform/LinuxProcFsStatistics.java | 4 +-
.../geode/internal/tcp/ByteBufferInputStream.java | 3 +-
.../org/apache/geode/internal/tcp/Connection.java | 6 +-
.../apache/geode/internal/tcp/ConnectionTable.java | 6 +-
.../apache/geode/internal/tcp/MsgDestreamer.java | 24 +-
.../org/apache/geode/internal/tcp/MsgStreamer.java | 6 +-
.../apache/geode/internal/util/PasswordUtil.java | 6 +-
.../apache/geode/internal/util/PluckStacks.java | 39 +-
.../concurrent/CustomEntryConcurrentHashMap.java | 3 +-
.../internal/util/concurrent/FutureResult.java | 18 +-
.../util/concurrent/SemaphoreReadWriteLock.java | 12 +-
.../util/concurrent/StoppableReentrantLock.java | 6 +-
.../StoppableReentrantReadWriteLock.java | 12 +-
.../management/internal/CollectionConverter.java | 11 +-
.../management/internal/CompositeConverter.java | 21 +-
.../management/internal/FederationComponent.java | 3 +-
.../internal/JmxManagerLocatorRequest.java | 4 +-
.../geode/management/internal/NotificationKey.java | 3 +-
.../geode/management/internal/OpenMethod.java | 24 +-
.../management/internal/OpenTypeConverter.java | 103 +++--
.../geode/management/internal/RestAgent.java | 9 +-
.../configuration/domain/Configuration.java | 3 +-
.../domain/ConfigurationChangeResult.java | 24 +-
.../internal/configuration/domain/XmlEntity.java | 24 +-
.../internal/functions/CliFunctionResult.java | 15 +-
.../internal/security/MBeanServerWrapper.java | 13 +-
.../internal/util/ClasspathScanLoadHelper.java | 3 +-
.../UniversalMembershipListenerAdapter.java | 12 +-
.../pdx/internal/AutoSerializableManager.java | 27 +-
.../java/org/apache/geode/pdx/internal/EnumId.java | 12 +-
.../org/apache/geode/pdx/internal/EnumInfo.java | 42 +-
.../apache/geode/pdx/internal/PdxInstanceEnum.java | 21 +-
.../apache/geode/pdx/internal/PdxInstanceImpl.java | 3 +-
.../apache/geode/pdx/internal/PdxReaderImpl.java | 3 +-
.../org/apache/geode/pdx/internal/PdxString.java | 3 +-
.../org/apache/geode/pdx/internal/PdxType.java | 3 +-
.../apache/geode/pdx/internal/PdxUnreadData.java | 6 +-
.../internal/WeakConcurrentIdentityHashMap.java | 12 +-
.../geode/pdx/internal/json/PdxInstanceHelper.java | 3 +-
.../geode/pdx/internal/json/PdxListHelper.java | 3 +-
.../apache/geode/pdx/internal/json/PdxToJSON.java | 3 +-
.../geode/cache/query/facets/lang/Address.java | 12 +-
.../geode/cache/query/facets/lang/Employee.java | 10 +-
.../geode/cache/query/facets/lang/Faculty.java | 18 +-
.../geode/cache/query/facets/lang/Person.java | 3 +-
.../geode/cache/query/facets/lang/Student.java | 12 +-
.../geode/cache/query/facets/lang/Utils.java | 3 +-
.../internal/SelectResultsComparatorJUnitTest.java | 9 +-
.../geode/internal/DataSerializableJUnitTest.java | 12 +-
.../apache/geode/internal/ObjIdMapJUnitTest.java | 15 +-
.../rebalance/BucketOperatorWrapperTest.java | 32 +-
.../PartitionedRegionLoadModelJUnitTest.java | 57 ++-
.../offheap/OffHeapStoredObjectJUnitTest.java | 3 +-
.../offheap/RefCountChangeInfoJUnitTest.java | 3 +-
.../security/GemFireSecurityExceptionTest.java | 6 +-
.../geode/security/NotAuthorizedExceptionTest.java | 12 +-
.../java/org/apache/geode/sequence/TimeAxis.java | 6 +-
.../query/cq/dunit/CqQueryUsingPoolDUnitTest.java | 6 +-
...igurationServiceConstraintsDistributedTest.java | 9 +-
.../cache/PRDeltaPropagationDUnitTest.java | 6 +-
.../internal/cache/ha/HADispatcherDUnitTest.java | 3 +-
.../tier/sockets/ClientToServerDeltaDUnitTest.java | 7 +-
...ltaToRegionRelationCQRegistrationDUnitTest.java | 10 +-
.../tier/sockets/TestAutoSerializerObject1.java | 6 +-
.../tier/sockets/TestAutoSerializerObject2.java | 6 +-
.../management/CacheServerManagementDUnitTest.java | 6 +-
.../geode/security/FilterPreAuthorization.java | 6 +-
.../cache/query/cq/internal/ClientCQImpl.java | 3 +-
.../cache/query/cq/internal/CqServiceImpl.java | 6 +-
.../cache/query/cq/internal/ServerCQImpl.java | 3 +-
.../cache/query/cq/internal/command/CloseCQ.java | 3 +-
.../cache/query/cq/internal/command/StopCQ.java | 3 +-
.../internal/LegacyClasspathServiceImpl.java | 3 +-
.../dunit/rules/tests/MemberStarterRuleTest.java | 3 +-
.../apache/geode/cache/query/QueryTestUtils.java | 6 +-
.../apache/geode/cache30/ClientServerTestCase.java | 3 +-
.../org/apache/geode/cache30/RegionTestCase.java | 57 ++-
.../apache/geode/cache30/TestCacheListener.java | 3 +-
.../org/apache/geode/cache30/TestCacheWriter.java | 3 +-
.../cache/CustomerIDPartitionResolver.java | 6 +-
.../cache/execute/CustomerIDPartitionResolver.java | 6 +-
.../internal/cache/execute/data/Customer.java | 6 +-
.../geode/internal/cache/execute/data/Order.java | 3 +-
.../internal/cache/execute/data/Shipment.java | 3 +-
.../internal/cache/functions/TestFunction.java | 23 +-
.../sockets/ClientServerMiscDUnitTestBase.java | 12 +-
.../cache/wan/AsyncEventQueueTestBase.java | 6 +-
.../management/internal/cli/HeadlessGfsh.java | 3 +-
.../commands/GemfireDataCommandsDUnitTestBase.java | 12 +-
.../internal/configuration/ClusterConfig.java | 5 +-
.../security/templates/SimpleAccessController.java | 3 +-
.../java/org/apache/geode/test/dunit/Invoke.java | 10 +-
.../junit/rules/MBeanServerConnectionRule.java | 6 +-
.../geode/test/junit/rules/MemberStarterRule.java | 3 +-
.../OfflineDiskStoreCommandsDUnitTest.java | 6 +-
.../cli/commands/VersionCommandJUnitTest.java | 3 +-
.../geode/management/internal/cli/CliUtils.java | 3 +-
.../geode/management/internal/cli/Launcher.java | 3 +-
.../cli/commands/AlterGatewaySenderCommand.java | 6 +-
.../cli/commands/AlterQueryServiceCommand.java | 3 +-
.../cli/commands/CreateJndiBindingCommand.java | 3 +-
.../GetMemberConfigInformationFunction.java | 9 +-
.../geode/management/internal/cli/help/Helper.java | 9 +-
.../geode/management/internal/cli/shell/Gfsh.java | 9 +-
.../management/internal/cli/shell/GfshConfig.java | 6 +-
.../internal/cli/shell/MultiCommandHelper.java | 7 +-
.../internal/cli/util/ExportLogsCacheWriter.java | 3 +-
.../org/apache/geode/cache/query/CacheUtils.java | 6 +-
.../java/org/apache/geode/cache/query/Utils.java | 3 +-
.../geode/cache/query/data/ComparableWrapper.java | 3 +-
.../geode/cache/query/data/PortfolioPdx.java | 6 +-
.../apache/geode/cache/query/data/Position.java | 8 +-
.../geode/cache/query/data/PositionNoDS.java | 8 +-
.../apache/geode/cache/query/data/PositionPdx.java | 3 +-
.../org/apache/geode/cache/query/data/Student.java | 3 +-
.../geode/codeAnalysis/decode/CompiledClass.java | 39 +-
.../geode/codeAnalysis/decode/CompiledField.java | 27 +-
.../geode/codeAnalysis/decode/CompiledMethod.java | 38 +-
.../geode/codeAnalysis/decode/cp/CpClass.java | 3 +-
.../geode/codeAnalysis/decode/cp/CpUtf8.java | 20 +-
.../geode/internal/cache/execute/data/CustId.java | 6 +-
.../geode/internal/cache/execute/data/OrderId.java | 6 +-
.../internal/cache/execute/data/ShipmentId.java | 3 +-
.../apache/geode/internal/cache/wan/Filter70.java | 3 +-
.../cache/wan/MyGatewaySenderEventListener.java | 3 +-
.../cache/wan/MyGatewaySenderEventListener2.java | 3 +-
.../cache/wan/MyGatewayTransportFilter1.java | 3 +-
.../cache/wan/MyGatewayTransportFilter2.java | 3 +-
.../cache/wan/MyGatewayTransportFilter3.java | 3 +-
.../cache/wan/MyGatewayTransportFilter4.java | 3 +-
.../org/apache/geode/internal/jta/CacheUtils.java | 3 +-
.../internal/util/concurrent/cm/LoopHelpers.java | 6 +-
.../geode/management/internal/cli/dto/Key1.java | 3 +-
.../geode/management/internal/cli/dto/Key2.java | 3 +-
.../internal/cli/dto/ObjectWithCharAttr.java | 3 +-
.../geode/management/internal/cli/dto/Value1.java | 3 +-
.../geode/management/internal/cli/dto/Value2.java | 3 +-
.../java/org/apache/geode/pdx/DSInsidePdx.java | 33 +-
.../java/org/apache/geode/pdx/DomainObject.java | 27 +-
.../org/apache/geode/pdx/DomainObjectPdxAuto.java | 111 ++++--
.../main/java/org/apache/geode/pdx/Employee.java | 27 +-
.../main/java/org/apache/geode/pdx/NestedPdx.java | 33 +-
.../java/org/apache/geode/pdx/PdxInsideDS.java | 30 +-
.../java/org/apache/geode/pdx/SimpleClass.java | 18 +-
.../java/org/apache/geode/pdx/SimpleClass1.java | 42 +-
.../geode/pdx/TestObjectForJSONFormatter.java | 138 ++++---
.../apache/geode/security/TestSecurityManager.java | 6 +-
.../geode/security/query/UserPermissions.java | 3 +-
.../geode/test/junit/rules/RestoreLocaleRule.java | 6 +-
.../java/parReg/query/unittest/NewPortfolio.java | 6 +-
geode-junit/src/main/java/perffmwk/Formatter.java | 5 +-
.../test/junit/rules/RestoreLocaleRuleTest.java | 3 +-
.../serializable/SerializableRuleListTest.java | 6 +-
.../apache/geode/logging/internal/OSProcess.java | 9 +-
.../cache/lucene/LuceneQueriesAccessorBase.java | 15 +-
.../cache/lucene/MixedObjectIndexDUnitTest.java | 75 ++--
.../IndexRepositoryFactoryDistributedTest.java | 9 +-
.../NestedObjectSeralizerIntegrationTest.java | 3 +-
.../repository/IndexRepositoryImplJUnitTest.java | 12 +-
.../lucene/internal/LuceneResultStructImpl.java | 24 +-
.../cache/lucene/internal/LuceneServiceImpl.java | 3 +-
.../internal/PageableLuceneQueryResultsImpl.java | 3 +-
.../lucene/internal/cli/LuceneIndexDetails.java | 3 +-
.../cache/lucene/internal/cli/LuceneQueryInfo.java | 5 +-
.../cli/functions/LuceneCreateIndexFunction.java | 12 +-
.../repository/LuceneIndexMemoryOverheadTest.java | 3 +-
.../management/runtime/MemberInformation.java | 3 +-
.../gms/messenger/JGroupsMessengerJUnitTest.java | 3 +-
.../internal/membership/gms/GMSMemberData.java | 12 +-
.../internal/membership/gms/GMSMembership.java | 12 +-
.../internal/membership/gms/GMSMembershipView.java | 9 +-
.../membership/gms/MemberIdentifierImpl.java | 65 +--
.../internal/membership/gms/Services.java | 3 +-
.../gms/locator/FindCoordinatorRequest.java | 24 +-
.../gms/locator/FindCoordinatorResponse.java | 48 ++-
.../membership/gms/membership/GMSJoinLeave.java | 3 +-
.../gms/messages/InstallViewMessage.java | 27 +-
.../gms/messages/JoinRequestMessage.java | 27 +-
.../gms/messages/JoinResponseMessage.java | 33 +-
.../membership/gms/messenger/JGAddress.java | 10 +-
.../membership/gms/messenger/Transport.java | 3 +-
.../internal/membership/utils/AvailablePort.java | 8 +-
.../org/apache/geode/tools/pulse/tests/Server.java | 3 +-
.../geode/tools/pulse/internal/data/Cluster.java | 8 +-
.../service/ClusterMembersRGraphService.java | 3 +-
.../tools/pulse/tests/junit/BaseServiceTest.java | 6 +-
.../geode/cache/util/AutoBalancerJUnitTest.java | 3 +-
.../internal/serialization/AbstractVersion.java | 3 +-
.../serialization/BufferDataOutputStream.java | 54 ++-
.../geode/internal/cache/wan/WANTestBase.java | 18 +-
.../wan/misc/NewWanAuthenticationDUnitTest.java | 5 +-
...hutdownAllPersistentGatewaySenderDUnitTest.java | 3 +-
...erialGatewaySenderAlterOperationsDUnitTest.java | 9 +-
.../internal/locator/wan/LocatorJoinMessage.java | 6 +-
.../GatewaySenderEventRemoteDispatcher.java | 3 +-
.../wan/internal/client/locator/LocatorHelper.java | 12 +-
.../geode/rest/internal/web/controllers/Order.java | 6 +-
.../web/security/GeodeAuthenticationProvider.java | 6 +-
.../rest/security/GeodeAuthenticationProvider.java | 6 +-
.../ExportLogsStatsOverHttpDistributedTest.java | 3 +-
640 files changed, 6604 insertions(+), 3437 deletions(-)
