You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by sb...@apache.org on 2018/04/06 20:54:58 UTC
[geode] 01/01: Merge branch 'release/1.5.0'
This is an automated email from the ASF dual-hosted git repository.
sbawaskar pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/geode.git
commit e35aac5a4b5f497df014c61a195d80bc6d73de91
Merge: d234394 1be57f3
Author: Swapnil Bawaskar <sb...@apache.org>
AuthorDate: Fri Apr 6 13:09:30 2018 -0700
Merge branch 'release/1.5.0'
NOTICE | 4 +-
README.md | 2 +-
build.gradle | 64 +-
buildSrc/build.gradle | 4 +-
.../geode/gradle/TestPropertiesWriter.groovy | 3 -
.../javac/EnsureCorrectRunsWithProcessor.java | 135 +
.../services/javax.annotation.processing.Processor | 1 +
.../org/apache/geode/javac/SimpleClassFile.java | 42 +
.../org/apache/geode/javac/SimpleFileManager.java | 46 +
.../org/apache/geode/javac/SimpleSourceFile.java | 35 +
.../geode/javac/TestAnnotationProcessor.java | 51 +
.../java/org/apache/geode/javac/TestCompiler.java | 51 +
ci/bin/concourse_job_performance.py | 120 +
ci/docker/Dockerfile | 12 +-
ci/docker/initdocker | 2 +-
ci/pipelines/develop.yml | 53 +-
ci/pipelines/docker-images.yml | 9 +-
ci/pipelines/meta.yml | 19 +
ci/pipelines/metrics.yml | 159 +
ci/scripts/build-examples.sh | 26 +
ci/scripts/capture-call-stacks.sh | 75 +
ci/scripts/concourse_job_performance.sh | 37 +
ci/scripts/test-archive.sh | 9 +-
ci/scripts/test-run.sh | 9 +
ci/scripts/update-passing-ref.sh | 2 +-
docker/Dockerfile | 82 +-
docker/README.md | 2 +-
etc/eclipse-java-google-style.xml | 598 +--
.../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 +-
.../gatewaydelta/GatewayDeltaCreateEvent.java | 4 +-
.../modules/gatewaydelta/GatewayDeltaEvent.java | 2 +-
.../modules/session/catalina/SessionCache.java | 36 +-
.../modules/session/catalina/SessionManager.java | 26 +-
.../internal/DeltaSessionAttributeEvent.java | 3 +-
.../geode/modules/util/BootstrappingFunction.java | 26 +-
.../geode/modules/util/CreateRegionFunction.java | 25 +-
.../geode/modules/util/RegionSizeFunction.java | 9 +
.../TouchPartitionedRegionEntriesFunction.java | 25 +-
.../util/TouchReplicatedRegionEntriesFunction.java | 29 +-
.../modules/util/ModuleFunctionsSecurityTest.java | 75 +
geode-assembly/build.gradle | 7 +-
geode-assembly/src/main/dist/LICENSE | 22 +-
geode-assembly/src/main/dist/NOTICE | 10 +-
.../cli/commands/DeployWithLargeJarTest.java | 8 +-
.../cli/commands/GfshStartLocatorLogTest.java | 3 +-
.../LogsAreFullyRedactedAcceptanceTest.java | 126 +
.../cli/commands/StartLocatorAcceptanceTest.java | 60 +
.../cli/commands/StartLocatorCommandTest.java | 97 +
.../cli/commands/StartServerCommandTest.java | 84 +
.../internal/web/RestFunctionExecuteDUnitTest.java | 124 +
.../internal/web/RestSecurityIntegrationTest.java | 150 +-
.../src/test/resources/expected_jars.txt | 11 +
geode-assembly/src/test/resources/security.json | 45 +
geode-benchmarks/build.gradle | 28 -
.../benchmark/RangeQueryWithIndexBenchmark.java | 105 -
.../cache/benchmark/RegionOperationBenchmark.java | 63 -
geode-book/Gemfile | 2 +-
geode-book/Gemfile.lock | 70 +-
geode-book/config.yml | 7 +-
.../source/subnavs/geode-subnav.erb | 11 +-
geode-book/redirects.rb | 4 +-
geode-client-protocol/build.gradle | 30 -
.../protocol/ClientProtocolMessageHandler.java | 40 -
.../apache/geode/internal/protocol/Failure.java | 48 -
.../protocol/LocatorMessageExecutionContext.java | 61 -
.../internal/protocol/MessageExecutionContext.java | 54 -
.../geode/internal/protocol/OperationContext.java | 65 -
.../geode/internal/protocol/ProtocolErrorCode.java | 32 -
.../internal/protocol/ProtocolSerializer.java | 34 -
.../org/apache/geode/internal/protocol/Result.java | 28 -
.../protocol/ServerMessageExecutionContext.java | 60 -
.../apache/geode/internal/protocol/Success.java | 48 -
.../exception/InvalidProtocolMessageException.java | 31 -
.../protocol/operations/OperationHandler.java | 42 -
.../protocol/serialization/JsonPdxConverter.java | 49 -
.../serialization/SerializationService.java | 31 -
.../protocol/serialization/SerializationType.java | 32 -
.../protocol/serialization/TypeConverter.java | 37 -
.../serialization/exception/EncodingException.java | 31 -
.../ConnectionAuthenticatingStateProcessor.java | 31 -
.../ConnectionShiroAuthorizingStateProcessor.java | 59 -
.../protocol/state/ConnectionStateProcessor.java | 73 -
.../state/ConnectionTerminatingStateProcessor.java | 34 -
.../LegacySecurityConnectionStateProcessor.java | 36 -
.../state/NoSecurityConnectionStateProcessor.java | 32 -
.../state/exception/ConnectionStateException.java | 30 -
.../exception/OperationNotAuthorizedException.java | 23 -
.../protocol/statistics/NoOpStatistics.java | 47 -
.../statistics/ProtocolClientStatistics.java | 33 -
geode-concurrency-test/build.gradle | 8 -
.../src/main/java/java/net/InetAddress.java | 155 -
.../test/concurrency/ConcurrentTestRunner.java | 11 +-
.../annotation/ConcurrentTestConfig.java | 4 +-
.../geode/test/concurrency/jpf/JpfRunner.java | 98 -
.../test/concurrency/jpf/JpfRunnerConfig.java | 34 -
.../test/concurrency/jpf/ParallelExecutorImpl.java | 87 -
.../test/concurrency/jpf/logging/EmptyLogger.java | 1975 ---------
...il_concurrent_locks_ReentrantReadWriteLock.java | 42 -
...ributed_internal_InternalDistributedSystem.java | 28 -
...g_apache_geode_internal_logging_LogService.java | 42 -
...che_geode_internal_logging_log4j_LogMarker.java | 27 -
.../JPF_org_apache_logging_log4j_LogManager.java | 29 -
.../geode/connectors/jdbc/JdbcAsyncWriter.java | 3 +-
.../connectors/jdbc/JdbcConnectorException.java | 35 +
.../apache/geode/connectors/jdbc/JdbcLoader.java | 8 +-
.../apache/geode/connectors/jdbc/JdbcWriter.java | 24 +-
.../jdbc/internal/HikariJdbcDataSource.java | 4 +-
.../jdbc/internal/HikariJdbcDataSourceFactory.java | 2 +-
.../connectors/jdbc/internal/RegionMapping.java | 36 +
.../geode/connectors/jdbc/internal/SqlHandler.java | 113 +-
.../jdbc/internal/TableKeyColumnManager.java | 6 +-
.../jdbc/internal/cli/CreateMappingCommand.java | 2 +-
.../jdbc/internal/cli/ExceptionHandler.java | 3 +-
.../jdbc/internal/cli/JdbcCliFunction.java | 5 +-
.../xml/JdbcConnectorServiceXmlGenerator.java | 13 +-
.../geode/connectors/jdbc/JdbcAsyncWriterTest.java | 6 +-
.../geode/connectors/jdbc/JdbcDUnitTest.java | 38 +-
.../geode/connectors/jdbc/JdbcLoaderTest.java | 2 +-
.../connectors/jdbc/JdbcWriterIntegrationTest.java | 1 -
.../geode/connectors/jdbc/JdbcWriterTest.java | 6 +-
.../jdbc/internal/RegionMappingTest.java | 118 +-
.../connectors/jdbc/internal/SqlHandlerTest.java | 51 +-
.../jdbc/internal/TableKeyColumnManagerTest.java | 3 +-
.../cli/CreateMappingCommandDUnitTest.java | 58 +-
.../cli/JDBCConnectorFunctionsSecurityTest.java | 93 +
...onnectorServiceXmlGeneratorIntegrationTest.java | 30 +
geode-core/build.gradle | 27 +-
.../geode/cache/CreateOnRegionBenchmark.java | 74 +
.../CreateWithEvictionUnderLimitBenchmark.java | 86 +
.../cache/EvictionBasePerformanceBenchmark.java | 98 +
.../EvictionMultiThreadedPerformanceBenchmark.java | 129 +
.../EvictionWithPartiallyMarkedListsBenchmark.java | 101 +
.../apache/geode/cache/FirstEvictionBenchmark.java | 80 +
.../apache/geode/cache/GetOnRegionBenchmark.java | 80 +
.../GetsWithEvictionPerformanceBenchmark.java | 92 +
.../geode/cache/RangeQueryWithIndexBenchmark.java | 97 +
.../geode/cache/RegionOperationBenchmark.java | 52 +
.../geode/cache/UpdateOnRegionBenchmark.java | 79 +
.../cache/FilterProfileConcurrencyTest.java | 86 -
.../apache/geode/cache/query/internal/parse/oql.g | 12 +-
.../java/org/apache/geode/DataSerializable.java | 13 +-
.../org/apache/geode/GemFireCheckedException.java | 4 -
.../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 +-
.../java/org/apache/geode/admin/BackupStatus.java | 20 +-
.../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 +-
.../apache/geode/admin/GemFireMemberStatus.java | 27 +-
.../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 | 16 +-
.../admin/internal/AbstractHealthEvaluator.java | 4 +-
.../admin/internal/AdminDistributedSystemImpl.java | 141 +-
.../geode/admin/internal/CacheHealthEvaluator.java | 8 +-
.../geode/admin/internal/CacheServerImpl.java | 19 +-
.../internal/ConfigurationParameterListener.java | 2 +-
.../internal/DistributedSystemConfigImpl.java | 7 -
.../internal/DistributedSystemHealthEvaluator.java | 28 +-
.../internal/DistributedSystemHealthMonitor.java | 1 -
.../admin/internal/DistributionLocatorImpl.java | 5 +-
.../internal/EnabledManagedEntityController.java | 21 +-
.../admin/internal/GemFireHealthEvaluator.java | 4 +-
.../geode/admin/internal/GemFireHealthImpl.java | 21 +-
.../geode/admin/internal/InetAddressUtil.java | 1 -
.../admin/internal/InternalManagedEntity.java | 26 +-
.../admin/internal/ManagedEntityConfigXml.java | 13 +-
.../internal/ManagedEntityConfigXmlParser.java | 21 +-
.../admin/internal/ManagedEntityController.java | 12 +-
.../admin/internal/MemberHealthEvaluator.java | 5 +-
.../admin/internal/StatisticResourceImpl.java | 2 +-
.../internal/SystemMemberCacheEventProcessor.java | 4 +-
.../admin/internal/SystemMemberCacheImpl.java | 31 +-
.../geode/admin/internal/SystemMemberImpl.java | 27 +-
.../admin/internal/SystemMembershipEventImpl.java | 15 +-
.../java/org/apache/geode/admin/jmx/Agent.java | 26 +-
.../org/apache/geode/admin/jmx/AgentConfig.java | 216 +-
.../internal/AdminDistributedSystemJmxImpl.java | 129 +-
.../geode/admin/jmx/internal/AgentConfigImpl.java | 53 +-
.../apache/geode/admin/jmx/internal/AgentImpl.java | 36 +-
.../geode/admin/jmx/internal/AgentLauncher.java | 4 +-
.../admin/jmx/internal/CacheServerJmxImpl.java | 35 -
.../admin/jmx/internal/GemFireHealthJmxImpl.java | 3 +-
.../admin/jmx/internal/GenerateMBeanHTML.java | 18 -
.../apache/geode/admin/jmx/internal/MBeanUtil.java | 8 -
.../geode/admin/jmx/internal/ManagedResource.java | 14 +-
.../jmx/internal/MemberInfoWithStatsMBean.java | 59 +-
.../jmx/internal/RMIRegistryServiceMBean.java | 14 +-
.../admin/jmx/internal/StatAlertsAggregator.java | 20 +-
.../admin/jmx/internal/StatisticAttributeInfo.java | 1 -
.../geode/admin/jmx/internal/SystemMemberJmx.java | 60 +-
.../admin/jmx/internal/SystemMemberJmxImpl.java | 36 -
.../org/apache/geode/cache/AttributesFactory.java | 35 +-
.../org/apache/geode/cache/AttributesMutator.java | 38 +-
.../java/org/apache/geode/cache/CacheCallback.java | 2 +-
.../apache/geode/cache/CacheClosedException.java | 5 -
.../java/org/apache/geode/cache/CacheEvent.java | 13 +-
.../apache/geode/cache/CacheExistsException.java | 4 +
.../java/org/apache/geode/cache/CacheFactory.java | 14 +-
.../java/org/apache/geode/cache/CacheListener.java | 25 +-
.../java/org/apache/geode/cache/CacheLoader.java | 7 +-
.../org/apache/geode/cache/CacheStatistics.java | 12 +-
.../geode/cache/CacheTransactionManager.java | 42 +-
.../java/org/apache/geode/cache/CacheWriter.java | 14 +-
.../java/org/apache/geode/cache/ClientSession.java | 18 +-
.../java/org/apache/geode/cache/CustomExpiry.java | 2 +-
.../java/org/apache/geode/cache/Declarable.java | 21 +-
.../java/org/apache/geode/cache/DiskStore.java | 38 +-
.../org/apache/geode/cache/DiskStoreFactory.java | 63 +-
.../apache/geode/cache/DiskWriteAttributes.java | 12 +-
.../apache/geode/cache/DynamicRegionFactory.java | 13 +-
.../apache/geode/cache/DynamicRegionListener.java | 8 +-
.../java/org/apache/geode/cache/EntryEvent.java | 16 +-
.../org/apache/geode/cache/EntryOperation.java | 12 +-
.../org/apache/geode/cache/EvictionAttributes.java | 42 +-
.../geode/cache/EvictionAttributesMutator.java | 2 +-
.../org/apache/geode/cache/ExpirationAction.java | 3 +-
.../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 | 41 +-
.../geode/cache/PartitionAttributesFactory.java | 68 +-
.../org/apache/geode/cache/PartitionResolver.java | 4 +-
.../main/java/org/apache/geode/cache/Region.java | 653 ++-
.../org/apache/geode/cache/RegionAttributes.java | 92 +-
.../java/org/apache/geode/cache/RegionEvent.java | 2 +-
.../java/org/apache/geode/cache/RegionFactory.java | 8 +-
.../geode/cache/RegionMembershipListener.java | 8 +-
.../geode/cache/RegionReinitializedException.java | 1 -
.../org/apache/geode/cache/RegionRoleListener.java | 4 +-
.../java/org/apache/geode/cache/RegionService.java | 35 +-
.../org/apache/geode/cache/RegionShortcut.java | 26 +-
.../java/org/apache/geode/cache/RequiredRoles.java | 9 +-
.../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 | 10 +-
.../org/apache/geode/cache/TransactionWriter.java | 7 +-
.../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/ClientCacheFactory.java | 7 +-
.../geode/cache/client/ClientRegionFactory.java | 47 +-
.../java/org/apache/geode/cache/client/Pool.java | 70 +-
.../org/apache/geode/cache/client/PoolFactory.java | 110 +-
.../geode/cache/client/internal/AbstractOp.java | 12 +-
.../cache/client/internal/AuthenticateUserOp.java | 20 +-
.../client/internal/AutoConnectionSourceImpl.java | 28 +-
.../client/internal/CacheServerLoadMessage.java | 4 +-
.../client/internal/ClientMetadataService.java | 30 +-
.../client/internal/ClientRegionFactoryImpl.java | 11 +-
.../client/internal/ClientSideHandshakeImpl.java | 463 ++
.../geode/cache/client/internal/ClientUpdater.java | 6 +-
.../cache/client/internal/CloseConnectionOp.java | 2 +-
.../geode/cache/client/internal/Connection.java | 38 +-
.../client/internal/ConnectionFactoryImpl.java | 54 +-
.../cache/client/internal/ConnectionImpl.java | 28 +-
.../cache/client/internal/ConnectionStats.java | 57 -
.../geode/cache/client/internal/DestroyOp.java | 3 -
.../cache/client/internal/EndpointManager.java | 10 +-
.../cache/client/internal/EndpointManagerImpl.java | 9 -
.../cache/client/internal/ExecutablePool.java | 29 +-
.../cache/client/internal/ExecuteFunctionOp.java | 2 -
.../internal/ExecuteRegionFunctionNoAckOp.java | 6 -
.../client/internal/ExecuteRegionFunctionOp.java | 6 -
.../internal/ExecuteRegionFunctionSingleHopOp.java | 10 -
.../geode/cache/client/internal/GetEntryOp.java | 2 +-
.../cache/client/internal/GetEventValueOp.java | 1 -
.../cache/client/internal/GetPDXIdForEnumOp.java | 1 -
.../cache/client/internal/GetPDXIdForTypeOp.java | 1 -
.../cache/client/internal/InternalClientCache.java | 2 +-
.../geode/cache/client/internal/KeySetOp.java | 2 -
.../cache/client/internal/LiveServerPinger.java | 4 -
.../cache/client/internal/OpExecutorImpl.java | 35 +-
.../geode/cache/client/internal/PoolImpl.java | 99 +-
.../geode/cache/client/internal/ProxyCache.java | 13 +-
.../cache/client/internal/ProxyCacheCloseOp.java | 3 +-
.../geode/cache/client/internal/ProxyRegion.java | 2 +-
.../geode/cache/client/internal/PutAllOp.java | 1 -
.../apache/geode/cache/client/internal/PutOp.java | 6 +-
.../cache/client/internal/QueueConnectionImpl.java | 4 +-
.../geode/cache/client/internal/QueueManager.java | 18 +-
.../cache/client/internal/QueueManagerImpl.java | 17 +-
.../geode/cache/client/internal/QueueState.java | 14 +-
.../cache/client/internal/QueueStateImpl.java | 35 +-
.../cache/client/internal/RegisterInterestOp.java | 7 -
.../client/internal/RegisterInterestTracker.java | 9 -
.../geode/cache/client/internal/RemoveAllOp.java | 1 -
.../cache/client/internal/ServerBlackList.java | 12 +-
.../client/internal/ServerRegionDataAccess.java | 42 +-
.../cache/client/internal/ServerRegionProxy.java | 3 +-
.../client/internal/SingleHopClientExecutor.java | 10 -
.../internal/locator/LocatorStatusResponse.java | 33 +-
.../locator/wan/LocatorMembershipListener.java | 16 +-
.../client/internal/pooling/ConnectionManager.java | 8 +-
.../internal/pooling/ConnectionManagerImpl.java | 330 +-
.../client/internal/pooling/PooledConnection.java | 9 +-
.../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 +-
.../execute/internal/FunctionServiceManager.java | 5 +-
.../geode/cache/operations/InterestType.java | 30 -
.../cache/operations/KeyValueOperationContext.java | 4 -
.../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 | 94 +-
.../apache/geode/cache/query/QueryStatistics.java | 4 +-
.../apache/geode/cache/query/SelectResults.java | 19 +-
.../java/org/apache/geode/cache/query/Struct.java | 6 +-
.../cache/query/internal/CompiledAddition.java | 54 +
.../cache/query/internal/CompiledArithmetic.java | 176 +
.../cache/query/internal/CompiledDivision.java | 54 +
.../geode/cache/query/internal/CompiledMod.java | 57 +
.../query/internal/CompiledMultiplication.java | 54 +
.../cache/query/internal/CompiledSubtraction.java | 54 +
.../geode/cache/query/internal/CompiledValue.java | 5 +
.../geode/cache/query/internal/DefaultQuery.java | 2 +-
.../cache/query/internal/DefaultQueryService.java | 16 +-
.../cache/query/internal/ExecutionContext.java | 5 +-
.../apache/geode/cache/query/internal/Filter.java | 37 +-
.../cache/query/internal/HashingStrategy.java | 4 +-
.../geode/cache/query/internal/Negatable.java | 2 +-
.../cache/query/internal/ProxyQueryService.java | 2 +-
.../geode/cache/query/internal/QCompiler.java | 56 +-
.../geode/cache/query/internal/QueryExecutor.java | 4 +-
.../geode/cache/query/internal/QueryMonitor.java | 37 +-
.../RestrictedMethodInvocationAuthorizer.java | 11 +-
.../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 +-
.../cache/query/internal/index/AbstractIndex.java | 15 +-
.../query/internal/index/AbstractMapIndex.java | 13 +-
.../query/internal/index/CompactMapRangeIndex.java | 27 +-
.../query/internal/index/CompactRangeIndex.java | 9 +-
.../cache/query/internal/index/HashIndex.java | 17 +-
.../cache/query/internal/index/IndexManager.java | 53 +-
.../cache/query/internal/index/IndexProtocol.java | 19 +-
.../cache/query/internal/index/IndexStore.java | 42 +-
.../cache/query/internal/index/IndexUtils.java | 5 +-
.../internal/index/IndexedExpressionEvaluator.java | 17 +-
.../cache/query/internal/index/MapRangeIndex.java | 18 +-
.../query/internal/index/MemoryIndexStore.java | 7 +-
.../query/internal/index/PartitionedIndex.java | 14 +-
.../query/internal/index/PrimaryKeyIndex.java | 7 +-
.../cache/query/internal/index/RangeIndex.java | 11 +-
.../query/internal/parse/ASTArithmeticOp.java | 38 +
.../cache/query/internal/parse/ASTParameter.java | 3 +-
.../cache/query/internal/types/TypeUtils.java | 662 +--
.../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 +-
.../geode/cache/snapshot/CacheSnapshotService.java | 25 +-
.../cache/snapshot/RegionSnapshotService.java | 2 +-
.../geode/cache/snapshot/SnapshotReader.java | 16 +-
.../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 | 93 +-
.../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 +-
.../apache/geode/distributed/AbstractLauncher.java | 9 +-
.../geode/distributed/ClientSocketFactory.java | 2 +-
.../geode/distributed/ConfigurationProperties.java | 4 +-
.../geode/distributed/DistributedMember.java | 14 +-
.../geode/distributed/DistributedSystem.java | 12 +-
.../apache/geode/distributed/LocatorLauncher.java | 10 +-
.../java/org/apache/geode/distributed/Role.java | 6 +-
.../apache/geode/distributed/ServerLauncher.java | 42 +-
.../geode/distributed/internal/CacheTime.java | 2 +-
.../internal/ClusterConfigurationService.java | 14 +-
.../internal/ClusterDistributionManager.java | 4592 ++++++++++++++++++++
.../internal/CollectingReplyProcessor.java | 2 +-
.../org/apache/geode/distributed/internal/DM.java | 489 ---
.../apache/geode/distributed/internal/DMStats.java | 352 +-
.../apache/geode/distributed/internal/DSClock.java | 8 +-
.../distributed/internal/DirectReplyProcessor.java | 23 +-
.../distributed/internal/DistributionAdvisee.java | 22 +-
.../distributed/internal/DistributionAdvisor.java | 47 +-
.../distributed/internal/DistributionConfig.java | 11 +-
.../internal/DistributionConfigImpl.java | 24 +-
.../distributed/internal/DistributionManager.java | 4538 ++-----------------
.../distributed/internal/DistributionMessage.java | 18 +-
.../internal/DistributionMessageObserver.java | 6 +-
.../distributed/internal/FlowControlParams.java | 4 -
.../geode/distributed/internal/HealthMonitor.java | 8 +-
.../distributed/internal/HealthMonitorImpl.java | 4 +-
.../internal/HighPriorityAckedMessage.java | 6 +-
.../internal/HighPriorityDistributionMessage.java | 2 +-
.../internal/InternalDistributedSystem.java | 59 +-
.../distributed/internal/InternalLocator.java | 11 +-
.../distributed/internal/LocatorLoadSnapshot.java | 128 +-
.../internal/LonerDistributionManager.java | 41 +-
.../apache/geode/distributed/internal/MQueue.java | 2 +-
.../distributed/internal/MembershipListener.java | 19 +-
.../distributed/internal/MessageWithReply.java | 6 +-
.../geode/distributed/internal/PoolStatHelper.java | 4 +-
.../internal/PooledDistributionMessage.java | 2 +-
.../geode/distributed/internal/ProductUseLog.java | 18 +-
.../distributed/internal/QueueStatHelper.java | 6 +-
.../internal/ReliableReplyProcessor21.java | 7 +-
.../geode/distributed/internal/ReplyException.java | 10 +-
.../geode/distributed/internal/ReplyMessage.java | 6 +-
.../distributed/internal/ReplyProcessor21.java | 56 +-
.../geode/distributed/internal/ReplySender.java | 6 +-
.../geode/distributed/internal/ResourceEvent.java | 1 +
.../distributed/internal/SerialAckedMessage.java | 6 +-
.../internal/SerialDistributionMessage.java | 2 +-
.../geode/distributed/internal/ServerLocator.java | 2 +-
.../distributed/internal/ShutdownMessage.java | 2 +-
.../geode/distributed/internal/Sizeable.java | 2 +-
.../geode/distributed/internal/StartupMessage.java | 9 +-
.../internal/StartupMessageReplyProcessor.java | 6 +-
.../distributed/internal/StartupOperation.java | 6 +-
.../internal/StartupResponseMessage.java | 4 +-
.../StartupResponseWithVersionMessage.java | 5 +-
.../internal/ThrottledMemQueueStatHelper.java | 8 +-
.../internal/ThrottledQueueStatHelper.java | 4 +-
.../internal/WaitForViewInstallation.java | 6 +-
.../distributed/internal/WanLocatorDiscoverer.java | 2 +-
.../internal/deadlock/DLockDependencyMonitor.java | 1 -
.../internal/deadlock/DependencyMonitor.java | 4 +-
.../internal/deadlock/GemFireDeadlockDetector.java | 6 +-
.../distributed/internal/direct/DirectChannel.java | 42 +-
.../internal/direct/DirectChannelListener.java | 6 +-
.../distributed/internal/locks/DLockBatch.java | 12 +-
.../distributed/internal/locks/DLockBatchId.java | 3 +-
.../distributed/internal/locks/DLockGrantor.java | 21 +-
.../locks/DLockLessorDepartureHandler.java | 4 +-
.../internal/locks/DLockQueryProcessor.java | 18 +-
.../locks/DLockRecoverGrantorProcessor.java | 27 +-
.../internal/locks/DLockReleaseProcessor.java | 18 +-
.../internal/locks/DLockRequestProcessor.java | 33 +-
.../distributed/internal/locks/DLockService.java | 51 +-
.../distributed/internal/locks/DLockToken.java | 8 +-
.../internal/locks/DeposeGrantorProcessor.java | 16 +-
.../internal/locks/DistributedLockStats.java | 207 +-
.../internal/locks/DistributedMemberLock.java | 6 +-
.../internal/locks/ElderInitProcessor.java | 17 +-
.../distributed/internal/locks/ElderState.java | 8 +-
.../internal/locks/GrantorRequestProcessor.java | 22 +-
.../distributed/internal/locks/LockGrantorId.java | 8 +-
.../locks/NonGrantorDestroyedProcessor.java | 22 +-
.../membership/DistributedMembershipListener.java | 21 +-
.../membership/InternalDistributedMember.java | 81 +-
.../internal/membership/InternalRole.java | 6 +-
.../internal/membership/MemberAttributes.java | 4 +-
.../internal/membership/MemberServices.java | 10 +-
.../internal/membership/MembershipManager.java | 82 +-
.../internal/membership/MembershipTestHook.java | 4 +-
.../distributed/internal/membership/NetMember.java | 63 +-
.../distributed/internal/membership/NetView.java | 24 +-
.../internal/membership/QuorumChecker.java | 12 +-
.../internal/membership/gms/GMSMember.java | 2 +-
.../internal/membership/gms/NetLocator.java | 2 +-
.../membership/gms/auth/GMSAuthenticator.java | 4 +-
.../membership/gms/interfaces/HealthMonitor.java | 15 +-
.../membership/gms/interfaces/JoinLeave.java | 2 +-
.../membership/gms/interfaces/Manager.java | 8 -
.../membership/gms/interfaces/MessageHandler.java | 2 +-
.../gms/locator/FindCoordinatorRequest.java | 5 +-
.../gms/locator/FindCoordinatorResponse.java | 4 +-
.../membership/gms/locator/GMSLocator.java | 17 +-
.../membership/gms/membership/GMSJoinLeave.java | 39 +-
.../gms/messages/FinalCheckPassedMessage.java | 4 +-
.../membership/gms/messages/HasMemberID.java | 2 +-
.../membership/gms/messages/HeartbeatMessage.java | 4 +-
.../gms/messages/HeartbeatRequestMessage.java | 4 +-
.../gms/messages/InstallViewMessage.java | 8 +-
.../gms/messages/JoinRequestMessage.java | 4 +-
.../gms/messages/JoinResponseMessage.java | 8 +-
.../gms/messages/LeaveRequestMessage.java | 4 +-
.../gms/messages/NetworkPartitionMessage.java | 4 +-
.../gms/messages/RemoveMemberMessage.java | 5 +-
.../gms/messages/SuspectMembersMessage.java | 4 +-
.../membership/gms/messages/ViewAckMessage.java | 4 +-
.../membership/gms/messenger/GMSEncrypt.java | 103 +-
.../membership/gms/messenger/GMSQuorumChecker.java | 4 -
.../membership/gms/messenger/JGroupsMessenger.java | 34 +-
.../membership/gms/messenger/StatRecorder.java | 8 -
.../membership/gms/messenger/Transport.java | 8 -
.../membership/gms/mgr/GMSMembershipManager.java | 12 +-
.../membership/gms/mgr/LocalViewMessage.java | 6 +-
.../internal/streaming/StreamingOperation.java | 19 +-
.../distributed/internal/tcpserver/TcpServer.java | 5 +-
.../java/org/apache/geode/i18n/LogWriterI18n.java | 114 +-
.../org/apache/geode/internal/AbstractConfig.java | 380 +-
.../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 +-
.../org/apache/geode/internal/DSFIDFactory.java | 38 +-
.../geode/internal/DataSerializableFixedID.java | 1095 ++---
.../org/apache/geode/internal/DeployedJar.java | 12 +-
.../geode/internal/GfeConsoleReaderFactory.java | 7 +-
.../apache/geode/internal/InputStreamFilter.java | 3 +
.../geode/internal/InternalDataSerializer.java | 77 +-
.../geode/internal/InternalInstantiator.java | 6 +-
.../org/apache/geode/internal/ManagerInfo.java | 20 +-
.../java/org/apache/geode/internal/NanoTimer.java | 2 +-
.../java/org/apache/geode/internal/OSProcess.java | 45 +-
.../geode/internal/ObjToByteArraySerializer.java | 5 +-
.../internal/ObjectInputStreamFilterWrapper.java | 195 +-
.../apache/geode/internal/OneTaskOnlyExecutor.java | 2 +-
.../geode/internal/SerializationVersions.java | 2 +-
.../org/apache/geode/internal/SystemAdmin.java | 5 +-
.../java/org/apache/geode/internal/Version.java | 8 +-
.../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 +-
.../internal/admin/ClientMembershipMessage.java | 6 +-
.../geode/internal/admin/ClientStatsManager.java | 5 +-
.../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 | 26 +-
.../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 +-
.../geode/internal/admin/StatAlertsManager.java | 10 +-
.../apache/geode/internal/admin/StatListener.java | 4 +-
.../apache/geode/internal/admin/StatResource.java | 16 +-
.../admin/remote/AddHealthListenerRequest.java | 2 +-
.../admin/remote/AddHealthListenerResponse.java | 4 +-
.../admin/remote/AddStatListenerRequest.java | 2 +-
.../admin/remote/AddStatListenerResponse.java | 4 +-
.../remote/AdminConsoleDisconnectMessage.java | 4 +-
.../internal/admin/remote/AdminConsoleMessage.java | 9 +-
.../admin/remote/AdminMultipleReplyProcessor.java | 4 +-
.../geode/internal/admin/remote/AdminRequest.java | 8 +-
.../geode/internal/admin/remote/AdminResponse.java | 2 +-
.../geode/internal/admin/remote/AdminWaiters.java | 6 +-
.../admin/remote/AlertLevelChangeMessage.java | 4 +-
.../admin/remote/AlertListenerMessage.java | 2 +-
.../admin/remote/AlertsNotificationMessage.java | 4 +-
.../admin/remote/AppCacheSnapshotMessage.java | 2 +-
.../internal/admin/remote/BridgeServerRequest.java | 4 +-
.../admin/remote/BridgeServerResponse.java | 4 +-
.../internal/admin/remote/CacheConfigRequest.java | 2 +-
.../internal/admin/remote/CacheConfigResponse.java | 6 +-
.../internal/admin/remote/CacheInfoRequest.java | 2 +-
.../internal/admin/remote/CacheInfoResponse.java | 5 +-
.../admin/remote/CancelStatListenerRequest.java | 2 +-
.../admin/remote/CancelStatListenerResponse.java | 4 +-
.../geode/internal/admin/remote/Cancellable.java | 2 +-
.../internal/admin/remote/CancellationMessage.java | 2 +-
.../admin/remote/ChangeRefreshIntervalMessage.java | 4 +-
.../internal/admin/remote/CliLegacyMessage.java | 4 +-
.../internal/admin/remote/CompactRequest.java | 12 +-
.../internal/admin/remote/DestroyEntryMessage.java | 4 +-
.../admin/remote/DestroyRegionMessage.java | 4 +-
.../admin/remote/DurableClientInfoRequest.java | 2 +-
.../admin/remote/DurableClientInfoResponse.java | 6 +-
.../admin/remote/FetchDistLockInfoRequest.java | 2 +-
.../admin/remote/FetchDistLockInfoResponse.java | 3 +-
.../admin/remote/FetchHealthDiagnosisRequest.java | 2 +-
.../admin/remote/FetchHealthDiagnosisResponse.java | 4 +-
.../internal/admin/remote/FetchHostRequest.java | 2 +-
.../internal/admin/remote/FetchHostResponse.java | 5 +-
.../remote/FetchResourceAttributesRequest.java | 2 +-
.../remote/FetchResourceAttributesResponse.java | 6 +-
.../internal/admin/remote/FetchStatsRequest.java | 2 +-
.../internal/admin/remote/FetchStatsResponse.java | 6 +-
.../internal/admin/remote/FetchSysCfgRequest.java | 2 +-
.../internal/admin/remote/FetchSysCfgResponse.java | 3 +-
.../admin/remote/FlushAppCacheSnapshotMessage.java | 2 +-
.../admin/remote/HealthListenerMessage.java | 2 +-
.../internal/admin/remote/LicenseInfoRequest.java | 2 +-
.../internal/admin/remote/LicenseInfoResponse.java | 4 +-
.../admin/remote/MissingPersistentIDsRequest.java | 10 +-
.../admin/remote/MissingPersistentIDsResponse.java | 5 +-
.../admin/remote/ObjectDetailsRequest.java | 2 +-
.../admin/remote/ObjectDetailsResponse.java | 3 +-
.../internal/admin/remote/ObjectNamesRequest.java | 2 +-
.../internal/admin/remote/ObjectNamesResponse.java | 3 +-
.../remote/PrepareRevokePersistentIDRequest.java | 13 +-
.../admin/remote/RefreshMemberSnapshotRequest.java | 2 +-
.../remote/RefreshMemberSnapshotResponse.java | 5 +-
.../admin/remote/RegionAttributesRequest.java | 2 +-
.../admin/remote/RegionAttributesResponse.java | 4 +-
.../geode/internal/admin/remote/RegionRequest.java | 2 +-
.../internal/admin/remote/RegionResponse.java | 2 +-
.../internal/admin/remote/RegionSizeRequest.java | 2 +-
.../internal/admin/remote/RegionSizeResponse.java | 3 +-
.../admin/remote/RegionStatisticsRequest.java | 2 +-
.../admin/remote/RegionStatisticsResponse.java | 4 +-
.../admin/remote/RegionSubRegionSizeRequest.java | 4 +-
.../admin/remote/RegionSubRegionsSizeResponse.java | 7 +-
.../admin/remote/RemoteGfManagerAgent.java | 54 +-
.../admin/remote/RemoveHealthListenerRequest.java | 2 +-
.../admin/remote/RemoveHealthListenerResponse.java | 4 +-
.../admin/remote/ResetHealthStatusRequest.java | 2 +-
.../admin/remote/ResetHealthStatusResponse.java | 4 +-
.../admin/remote/RevokePersistentIDRequest.java | 8 +-
.../internal/admin/remote/RootRegionRequest.java | 2 +-
.../internal/admin/remote/RootRegionResponse.java | 5 +-
.../remote/ShutdownAllGatewayHubsRequest.java | 6 +-
.../internal/admin/remote/ShutdownAllRequest.java | 26 +-
.../admin/remote/SnapshotResultMessage.java | 2 +-
.../remote/StatAlertsManagerAssignMessage.java | 6 +-
.../internal/admin/remote/StatListenerMessage.java | 2 +-
.../internal/admin/remote/StoreSysCfgRequest.java | 2 +-
.../internal/admin/remote/StoreSysCfgResponse.java | 3 +-
.../internal/admin/remote/SubRegionRequest.java | 2 +-
.../internal/admin/remote/SubRegionResponse.java | 3 +-
.../internal/admin/remote/TailLogRequest.java | 2 +-
.../internal/admin/remote/TailLogResponse.java | 5 +-
.../admin/remote/UpdateAlertDefinitionMessage.java | 4 +-
.../internal/admin/remote/VersionInfoRequest.java | 2 +-
.../internal/admin/remote/VersionInfoResponse.java | 3 +-
.../internal/admin/statalerts/StatisticInfo.java | 18 +-
.../internal/cache/AbstractBucketRegionQueue.java | 20 +-
.../geode/internal/cache/AbstractCacheServer.java | 4 +-
.../geode/internal/cache/AbstractDiskRegion.java | 121 +-
.../geode/internal/cache/AbstractLRURegionMap.java | 829 ----
.../geode/internal/cache/AbstractRegion.java | 110 +-
.../geode/internal/cache/AbstractRegionMap.java | 851 +---
.../internal/cache/AbstractUpdateOperation.java | 29 +-
.../cache/AddCacheServerProfileMessage.java | 10 +-
.../apache/geode/internal/cache/BucketAdvisor.java | 6 +-
.../internal/cache/BucketPersistenceAdvisor.java | 2 +-
.../apache/geode/internal/cache/BucketRegion.java | 106 +-
.../geode/internal/cache/BucketRegionQueue.java | 2 +-
.../internal/cache/CacheDistributionAdvisee.java | 10 +-
.../internal/cache/CacheDistributionAdvisor.java | 11 +-
.../apache/geode/internal/cache/CacheObserver.java | 36 +-
.../geode/internal/cache/CacheServerAdvisor.java | 8 +-
.../geode/internal/cache/CacheServerImpl.java | 12 +-
.../geode/internal/cache/CacheServerLauncher.java | 2 +-
.../apache/geode/internal/cache/CacheService.java | 6 +-
.../geode/internal/cache/CacheStatisticsImpl.java | 4 +-
.../geode/internal/cache/CachedDeserializable.java | 22 +-
.../cache/CachedDeserializableFactory.java | 13 +-
.../geode/internal/cache/ClientServerObserver.java | 24 +-
.../geode/internal/cache/CloseCacheMessage.java | 6 +-
.../geode/internal/cache/CompactableOplog.java | 9 +-
.../apache/geode/internal/cache/Conflatable.java | 12 +-
.../geode/internal/cache/ControllerAdvisor.java | 9 +-
.../internal/cache/CreateRegionProcessor.java | 10 +-
.../geode/internal/cache/DestroyOperation.java | 8 +-
.../cache/DestroyPartitionedRegionMessage.java | 5 +-
.../internal/cache/DestroyRegionOperation.java | 12 +-
.../geode/internal/cache/DirectReplyMessage.java | 7 +-
.../apache/geode/internal/cache/DiskInitFile.java | 3 -
.../apache/geode/internal/cache/DiskRegion.java | 20 +-
.../geode/internal/cache/DiskStoreBackup.java | 92 -
.../geode/internal/cache/DiskStoreFactoryImpl.java | 4 +-
.../apache/geode/internal/cache/DiskStoreImpl.java | 283 +-
.../geode/internal/cache/DiskStoreMonitor.java | 45 +-
.../apache/geode/internal/cache/DiskStoreTask.java | 2 +-
.../geode/internal/cache/DistPeerTXStateStub.java | 10 +-
.../internal/cache/DistTXAdjunctCommitMessage.java | 4 +-
.../geode/internal/cache/DistTXCommitMessage.java | 22 +-
.../internal/cache/DistTXCoordinatorInterface.java | 26 +-
.../internal/cache/DistTXPrecommitMessage.java | 12 +-
.../internal/cache/DistTXRollbackMessage.java | 25 +-
.../apache/geode/internal/cache/DistTXState.java | 21 +-
.../internal/cache/DistTXStateOnCoordinator.java | 19 +-
.../geode/internal/cache/DistTXStateProxyImpl.java | 15 +-
.../cache/DistTXStateProxyImplOnCoordinator.java | 49 +-
.../cache/DistTXStateProxyImplOnDatanode.java | 11 +-
.../internal/cache/DistributedCacheOperation.java | 26 +-
.../internal/cache/DistributedClearOperation.java | 8 +-
.../internal/cache/DistributedPutAllOperation.java | 31 +-
.../geode/internal/cache/DistributedRegion.java | 144 +-
.../DistributedRegionFunctionStreamingMessage.java | 37 +-
.../cache/DistributedRemoveAllOperation.java | 6 +-
.../cache/DistributedTombstoneOperation.java | 8 +-
.../apache/geode/internal/cache/EntriesMap.java | 13 +-
.../geode/internal/cache/EntryEventImpl.java | 216 +-
.../apache/geode/internal/cache/EntrySnapshot.java | 9 +-
.../org/apache/geode/internal/cache/EventID.java | 4 +-
.../geode/internal/cache/EventStateHelper.java | 9 +-
.../geode/internal/cache/EvictableRegion.java | 37 +
.../internal/cache/EvictionAttributesImpl.java | 115 +-
.../cache/EvictionAttributesMutatorImpl.java | 35 +
.../apache/geode/internal/cache/ExpiryTask.java | 10 +-
.../geode/internal/cache/ExportDiskRegion.java | 4 +-
.../apache/geode/internal/cache/FilterProfile.java | 12 +-
.../internal/cache/FindDurableQueueProcessor.java | 12 +-
.../geode/internal/cache/FindRemoteTXMessage.java | 9 +-
.../internal/cache/FindVersionTagOperation.java | 12 +-
.../FunctionStreamingOrderedReplyMessage.java | 7 +-
.../cache/FunctionStreamingReplyMessage.java | 5 +-
.../internal/cache/FutureCachedDeserializable.java | 35 +
.../geode/internal/cache/GemFireCacheImpl.java | 512 ++-
.../apache/geode/internal/cache/GridAdvisor.java | 11 +-
.../org/apache/geode/internal/cache/HARegion.java | 14 +-
.../apache/geode/internal/cache/ImageState.java | 64 +-
.../internal/cache/InitialImageFlowControl.java | 30 +-
.../internal/cache/InitialImageOperation.java | 172 +-
.../geode/internal/cache/InterestFilter.java | 10 +-
.../apache/geode/internal/cache/InternalCache.java | 53 +-
.../geode/internal/cache/InternalCacheEvent.java | 20 +-
.../geode/internal/cache/InternalDataView.java | 10 +-
.../internal/cache/InternalDistributedRegion.java | 3 +-
.../geode/internal/cache/InternalEntryEvent.java | 25 +
.../geode/internal/cache/InternalRegion.java | 115 +-
.../geode/internal/cache/InvalidateOperation.java | 10 +-
.../cache/InvalidatePartitionedRegionMessage.java | 5 +-
.../internal/cache/InvalidateRegionOperation.java | 4 +-
.../internal/cache/JtaAfterCompletionMessage.java | 21 +-
.../internal/cache/JtaBeforeCompletionMessage.java | 10 +-
.../cache/LatestLastAccessTimeMessage.java | 10 +-
.../cache/LatestLastAccessTimeOperation.java | 8 +-
.../cache/LatestLastAccessTimeReplyProcessor.java | 5 +-
.../geode/internal/cache/LoaderHelperFactory.java | 4 +-
.../apache/geode/internal/cache/LocalRegion.java | 374 +-
.../geode/internal/cache/LocalRegionDataView.java | 12 +-
.../cache/MemberFunctionStreamingMessage.java | 35 +-
.../geode/internal/cache/NonLocalRegionEntry.java | 4 +-
.../cache/OfflineCompactionDiskRegion.java | 16 +-
.../org/apache/geode/internal/cache/Oplog.java | 103 +-
.../org/apache/geode/internal/cache/OplogSet.java | 8 +-
.../internal/cache/PRContainsValueFunction.java | 5 +-
.../internal/cache/PRHARedundancyProvider.java | 76 +-
.../geode/internal/cache/PRQueryProcessor.java | 21 +-
.../internal/cache/PartitionAttributesImpl.java | 3 +-
.../cache/PartitionRegionConfigValidator.java | 2 +-
.../geode/internal/cache/PartitionedRegion.java | 175 +-
.../internal/cache/PartitionedRegionDataStore.java | 48 +-
.../internal/cache/PartitionedRegionDataView.java | 12 +-
.../internal/cache/PartitionedRegionHelper.java | 41 +-
.../cache/PartitionedRegionQueryEvaluator.java | 55 +-
.../internal/cache/PausedTXStateProxyImpl.java | 3 +-
.../geode/internal/cache/PeerTXStateStub.java | 3 +
.../internal/cache/PlaceHolderDiskRegion.java | 45 +-
.../geode/internal/cache/PoolFactoryImpl.java | 89 +-
.../geode/internal/cache/ProxyBucketRegion.java | 4 +-
.../geode/internal/cache/ProxyRegionMap.java | 54 +-
.../geode/internal/cache/QueuedOperation.java | 2 +-
.../apache/geode/internal/cache/RegionEntry.java | 4 +-
.../geode/internal/cache/RegionEntryContext.java | 2 +
.../geode/internal/cache/RegionEntryFactory.java | 8 +-
.../cache/RegionEntrySynchronizationListener.java | 2 +-
.../org/apache/geode/internal/cache/RegionMap.java | 30 +-
.../geode/internal/cache/RegionMapFactory.java | 2 +-
.../geode/internal/cache/RegionMapOwner.java | 19 +
.../apache/geode/internal/cache/RegionQueue.java | 32 +-
.../apache/geode/internal/cache/RegionStatus.java | 6 +-
.../internal/cache/ReleaseClearLockMessage.java | 8 +-
.../cache/RemoteContainsKeyValueMessage.java | 310 --
.../geode/internal/cache/RemoteDestroyMessage.java | 705 ---
.../internal/cache/RemoteFetchEntryMessage.java | 335 --
.../internal/cache/RemoteFetchVersionMessage.java | 251 --
.../geode/internal/cache/RemoteGetMessage.java | 430 --
.../internal/cache/RemoteInvalidateMessage.java | 415 --
.../internal/cache/RemoteOperationException.java | 91 +-
.../internal/cache/RemoteOperationMessage.java | 667 ---
.../RemoteOperationMessageWithDirectReply.java | 81 -
.../geode/internal/cache/RemotePutAllMessage.java | 546 ---
.../geode/internal/cache/RemotePutMessage.java | 1133 -----
.../internal/cache/RemoteRegionOperation.java | 204 -
.../internal/cache/RemoteRemoveAllMessage.java | 535 ---
.../cache/RemoveCacheServerProfileMessage.java | 162 +
.../cache/SearchLoadAndWriteProcessor.java | 72 +-
.../geode/internal/cache/SerializationHelper.java | 4 +-
.../geode/internal/cache/ServerPingMessage.java | 6 +-
.../geode/internal/cache/StateFlushOperation.java | 35 +-
.../geode/internal/cache/TXCommitMessage.java | 99 +-
.../apache/geode/internal/cache/TXEntryState.java | 9 +-
.../geode/internal/cache/TXEntryStateFactory.java | 6 +-
.../geode/internal/cache/TXFarSideCMTracker.java | 25 +-
.../apache/geode/internal/cache/TXLockRequest.java | 13 +-
.../apache/geode/internal/cache/TXManagerImpl.java | 65 +-
.../org/apache/geode/internal/cache/TXMessage.java | 18 +-
.../internal/cache/TXRegionLockRequestImpl.java | 33 +-
.../apache/geode/internal/cache/TXRegionState.java | 4 +-
.../internal/cache/TXRemoteCommitMessage.java | 45 +-
.../internal/cache/TXRemoteRollbackMessage.java | 4 +-
.../org/apache/geode/internal/cache/TXState.java | 36 +-
.../geode/internal/cache/TXStateInterface.java | 81 +-
.../apache/geode/internal/cache/TXStateProxy.java | 40 +-
.../geode/internal/cache/TXStateProxyImpl.java | 151 +-
.../apache/geode/internal/cache/TXStateStub.java | 79 +-
.../internal/cache/TXSynchronizationRunnable.java | 36 +-
.../geode/internal/cache/TombstoneService.java | 2 +-
.../geode/internal/cache/TransactionMessage.java | 14 +-
.../geode/internal/cache/TxEntryFactory.java | 4 +-
.../internal/cache/UpdateAttributesProcessor.java | 15 +-
.../cache/UpdateEntryVersionOperation.java | 8 +-
.../geode/internal/cache/UpdateOperation.java | 12 +-
.../internal/cache/VMCachedDeserializable.java | 12 +-
.../geode/internal/cache/VMLRURegionMap.java | 788 +++-
.../apache/geode/internal/cache/VMRegionMap.java | 5 +-
.../geode/internal/cache/ValidatingDiskRegion.java | 9 +-
.../geode/internal/cache/backup/AbortBackup.java | 32 +
.../internal/cache/backup/AbortBackupFactory.java | 45 +
.../cache/backup/AbortBackupOperation.java | 66 +
.../internal/cache/backup/AbortBackupRequest.java | 54 +
.../cache/backup/AbstractBackupWriterConfig.java | 51 +
.../cache/backup/BackupDataStoreHelper.java | 28 +-
.../internal/cache/backup/BackupDefinition.java | 20 +-
.../internal/cache/backup/BackupDestination.java | 28 -
.../internal/cache/backup/BackupFileCopier.java | 185 +
.../geode/internal/cache/backup/BackupFilter.java | 24 +
.../geode/internal/cache/backup/BackupLock.java | 114 -
.../geode/internal/cache/backup/BackupManager.java | 661 ---
.../internal/cache/backup/BackupOperation.java | 8 +-
.../cache/backup/BackupReplyProcessor.java | 4 +-
.../internal/cache/backup/BackupResponse.java | 3 +-
.../geode/internal/cache/backup/BackupService.java | 179 +
.../geode/internal/cache/backup/BackupTask.java | 287 ++
.../geode/internal/cache/backup/BackupUtil.java | 38 +-
.../geode/internal/cache/backup/BackupWriter.java | 33 +
.../internal/cache/backup/BackupWriterFactory.java | 60 +
.../internal/cache/backup/DiskStoreBackup.java | 87 +
.../cache/backup/FileSystemBackupDestination.java | 145 -
.../cache/backup/FileSystemBackupWriter.java | 242 ++
.../cache/backup/FileSystemBackupWriterConfig.java | 40 +
.../FileSystemIncrementalBackupLocation.java | 132 +
.../geode/internal/cache/backup/FinishBackup.java | 13 +-
.../internal/cache/backup/FinishBackupFactory.java | 18 +-
.../cache/backup/FinishBackupOperation.java | 19 +-
.../internal/cache/backup/FinishBackupRequest.java | 38 +-
.../internal/cache/backup/FlushToDiskFactory.java | 5 +-
.../cache/backup/FlushToDiskOperation.java | 9 +-
.../cache/backup/FlushToDiskProcessor.java | 4 +-
.../internal/cache/backup/FlushToDiskRequest.java | 4 +-
.../cache/backup/IncrementalBackupFilter.java | 37 +
.../cache/backup/IncrementalBackupLocation.java | 25 +
.../geode/internal/cache/backup/PrepareBackup.java | 8 +-
.../cache/backup/PrepareBackupFactory.java | 25 +-
.../cache/backup/PrepareBackupOperation.java | 18 +-
.../cache/backup/PrepareBackupRequest.java | 27 +-
.../geode/internal/cache/backup/RestoreScript.java | 4 +
.../cache/backup/TemporaryBackupFiles.java | 139 +
.../client/protocol/ClientProtocolService.java | 5 +-
.../internal/cache/control/HeapMemoryMonitor.java | 5 +-
.../cache/control/InternalResourceManager.java | 16 +-
.../internal/cache/control/MemoryMonitor.java | 12 +-
.../cache/control/OffHeapMemoryMonitor.java | 16 +-
.../internal/cache/control/ResourceAdvisor.java | 12 +-
.../internal/cache/control/ResourceEvent.java | 6 +-
.../internal/cache/control/ResourceListener.java | 2 +-
.../internal/cache/control/ResourceMonitor.java | 6 +-
.../entries/AbstractOplogDiskRegionEntry.java | 6 +-
.../cache/entries/AbstractRegionEntry.java | 109 +-
.../geode/internal/cache/entries/DiskEntry.java | 83 +-
.../internal/cache/entries/HashRegionEntry.java | 21 +
.../internal/cache/entries/OffHeapRegionEntry.java | 4 +-
.../cache/eviction/AbstractEvictionController.java | 237 +-
.../cache/eviction/AbstractEvictionList.java | 33 +-
.../internal/cache/eviction/CountLRUEviction.java | 243 +-
.../cache/eviction/CountLRUStatistics.java | 112 +
.../cache/eviction/DisabledEvictionCounters.java | 90 +
.../cache/eviction/DisabledEvictionStatistics.java | 105 -
.../internal/cache/eviction/EvictableMap.java | 2 +
.../cache/eviction/EvictionController.java | 74 +-
.../internal/cache/eviction/EvictionCounters.java | 48 +
.../cache/eviction/EvictionCountersImpl.java | 124 +
.../internal/cache/eviction/EvictionList.java | 11 +-
.../cache/eviction/EvictionListBuilder.java | 82 +-
.../cache/eviction/EvictionStatistics.java | 34 -
.../cache/eviction/EvictionStatisticsImpl.java | 180 -
.../internal/cache/eviction/EvictionStats.java | 39 +
.../internal/cache/eviction/HeapLRUController.java | 128 +-
.../internal/cache/eviction/HeapLRUStatistics.java | 108 +
.../cache/eviction/InternalEvictionStatistics.java | 39 -
.../geode/internal/cache/eviction/LIFOList.java | 6 +-
.../cache/eviction/LRUListWithAsyncSorting.java | 26 +-
.../cache/eviction/LRUListWithSyncSorting.java | 10 +-
.../cache/eviction/MemoryLRUController.java | 330 +-
.../cache/eviction/MemoryLRUStatistics.java | 111 +
.../internal/cache/eviction/RegionEvictorTask.java | 4 +-
.../internal/cache/eviction/SizeLRUController.java | 61 +-
.../internal/cache/execute/AbstractExecution.java | 24 +-
.../DistributedRegionFunctionResultSender.java | 12 +-
.../execute/FunctionStreamingResultCollector.java | 6 +-
.../internal/cache/execute/InternalExecution.java | 10 +-
.../internal/cache/execute/InternalFunction.java | 40 +
.../execute/InternalRegionFunctionContext.java | 7 +-
.../cache/execute/InternalResultSender.java | 8 +-
.../cache/execute/MemberFunctionExecutor.java | 4 +-
.../cache/execute/MemberFunctionResultSender.java | 11 +-
.../cache/execute/MultiRegionFunctionContext.java | 4 +-
.../cache/execute/MultiRegionFunctionExecutor.java | 4 +-
.../PartitionedRegionFunctionResultSender.java | 16 +-
.../PartitionedRegionFunctionResultWaiter.java | 6 +-
.../cache/execute/ServerFunctionExecutor.java | 4 +-
.../execute/ServerRegionFunctionExecutor.java | 4 +-
.../util/FindRestEnabledServersFunction.java | 10 +-
.../geode/internal/cache/extension/Extensible.java | 2 +-
.../internal/cache/ha/HAContainerWrapper.java | 18 +-
.../geode/internal/cache/ha/HARegionQueue.java | 113 +-
.../internal/cache/ha/QueueRemovalMessage.java | 5 +-
.../cache/locks/TXLessorDepartureHandler.java | 4 +-
.../geode/internal/cache/locks/TXLockId.java | 10 +-
.../geode/internal/cache/locks/TXLockService.java | 5 +-
.../internal/cache/locks/TXLockServiceImpl.java | 6 +-
.../locks/TXLockUpdateParticipantsMessage.java | 4 +-
.../cache/locks/TXOriginatorRecoveryProcessor.java | 14 +-
.../locks/TXRecoverGrantorMessageProcessor.java | 8 +-
.../internal/cache/locks/TXRegionLockRequest.java | 8 +-
.../internal/cache/map/CacheModificationLock.java | 28 +
.../geode/internal/cache/map/FocusedRegionMap.java | 45 +
.../geode/internal/cache/map/RegionMapDestroy.java | 741 ++++
.../AllBucketProfilesUpdateMessage.java | 8 +-
.../partitioned/BecomePrimaryBucketMessage.java | 15 +-
.../geode/internal/cache/partitioned/Bucket.java | 16 +-
.../cache/partitioned/BucketBackupMessage.java | 7 +-
.../partitioned/BucketProfileUpdateMessage.java | 10 +-
.../cache/partitioned/BucketSizeMessage.java | 15 +-
.../cache/partitioned/ContainsKeyValueMessage.java | 10 +-
.../cache/partitioned/CreateBucketMessage.java | 15 +-
.../partitioned/DeposePrimaryBucketMessage.java | 13 +-
.../internal/cache/partitioned/DestroyMessage.java | 13 +-
.../DestroyRegionOnDataStoreMessage.java | 15 +-
.../cache/partitioned/DumpAllPRConfigMessage.java | 5 +-
.../internal/cache/partitioned/DumpB2NRegion.java | 13 +-
.../cache/partitioned/DumpBucketsMessage.java | 5 +-
.../partitioned/EndBucketCreationMessage.java | 9 +-
.../cache/partitioned/FetchBulkEntriesMessage.java | 15 +-
.../cache/partitioned/FetchEntriesMessage.java | 16 +-
.../cache/partitioned/FetchEntryMessage.java | 9 +-
.../cache/partitioned/FetchKeysMessage.java | 18 +-
.../partitioned/FetchPartitionDetailsMessage.java | 13 +-
.../internal/cache/partitioned/FlushMessage.java | 4 +-
.../internal/cache/partitioned/GetMessage.java | 46 +-
.../cache/partitioned/IdentityRequestMessage.java | 11 +-
.../cache/partitioned/IdentityUpdateMessage.java | 6 +-
.../cache/partitioned/IndexCreationMsg.java | 21 +-
.../cache/partitioned/InterestEventMessage.java | 15 +-
.../internal/cache/partitioned/InternalPRInfo.java | 5 +-
.../partitioned/InternalPartitionDetails.java | 4 +-
.../cache/partitioned/InvalidateMessage.java | 12 +-
.../partitioned/ManageBackupBucketMessage.java | 19 +-
.../cache/partitioned/ManageBucketMessage.java | 19 +-
.../cache/partitioned/MoveBucketMessage.java | 15 +-
.../cache/partitioned/OfflineMemberDetails.java | 4 +-
.../cache/partitioned/PREntriesIterator.java | 4 +-
.../PRFunctionStreamingResultCollector.java | 4 +-
.../cache/partitioned/PRSanityCheckMessage.java | 12 +-
.../cache/partitioned/PRTombstoneMessage.java | 7 +-
.../partitioned/PRUpdateEntryVersionMessage.java | 5 +-
.../cache/partitioned/PartitionMessage.java | 64 +-
.../PartitionMessageWithDirectReply.java | 3 +-
.../PartitionedRegionFunctionStreamingMessage.java | 16 +-
.../partitioned/PartitionedRegionObserver.java | 6 +-
.../partitioned/PartitionedRegionRebalanceOp.java | 18 +-
.../cache/partitioned/PrimaryRequestMessage.java | 11 +-
.../cache/partitioned/PutAllPRMessage.java | 34 +-
.../internal/cache/partitioned/PutMessage.java | 17 +-
.../internal/cache/partitioned/QueryMessage.java | 8 +-
.../internal/cache/partitioned/RegionAdvisor.java | 29 +-
.../cache/partitioned/RemoteFetchKeysMessage.java | 490 ---
.../cache/partitioned/RemoteSizeMessage.java | 325 --
.../cache/partitioned/RemoveAllPRMessage.java | 18 +-
.../cache/partitioned/RemoveBucketMessage.java | 15 +-
.../cache/partitioned/RemoveIndexesMessage.java | 19 +-
.../internal/cache/partitioned/SizeMessage.java | 11 +-
.../partitioned/StreamingPartitionOperation.java | 17 +-
.../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 | 128 +-
.../cache/persistence/MembershipFlushRequest.java | 9 +-
.../cache/persistence/MembershipViewRequest.java | 27 +-
.../cache/persistence/PersistenceAdvisor.java | 32 +-
.../cache/persistence/PersistenceAdvisorImpl.java | 36 +-
.../persistence/PersistenceObserverHolder.java | 16 +-
.../cache/persistence/PersistentMemberManager.java | 34 +-
.../cache/persistence/PersistentMemberView.java | 42 +-
.../cache/persistence/PersistentStateListener.java | 8 +-
.../persistence/PersistentStateQueryMessage.java | 14 +-
.../PrepareNewPersistentMemberMessage.java | 10 +-
.../persistence/RemovePersistentMemberMessage.java | 11 +-
.../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 +-
.../apache/geode/internal/cache/properties.html | 690 +--
.../region/entry/RegionEntryFactoryBuilder.java | 6 +-
.../cache/snapshot/CacheSnapshotServiceImpl.java | 2 +-
.../internal/cache/snapshot/ClientExporter.java | 13 +-
.../internal/cache/snapshot/FlowController.java | 27 +-
.../geode/internal/cache/snapshot/GFSnapshot.java | 39 +-
.../cache/snapshot/RegionSnapshotServiceImpl.java | 29 +-
.../internal/cache/snapshot/WindowedExporter.java | 10 +-
.../geode/internal/cache/tier/ClientHandShake.java | 44 -
.../internal/cache/tier/ClientSideHandshake.java | 40 +
.../geode/internal/cache/tier/ConnectionProxy.java | 2 +-
.../geode/internal/cache/tier/Encryptor.java | 26 +
.../cache/tier/InternalClientMembership.java | 16 +-
.../internal/cache/tier/ServerSideHandshake.java | 49 +
.../internal/cache/tier/sockets/AcceptorImpl.java | 74 +-
.../internal/cache/tier/sockets/BaseCommand.java | 2 +-
.../cache/tier/sockets/CacheClientNotifier.java | 116 +-
.../cache/tier/sockets/CacheClientProxy.java | 15 +-
.../cache/tier/sockets/CacheClientUpdater.java | 47 +-
.../tier/sockets/ClientBlacklistProcessor.java | 14 +-
.../cache/tier/sockets/ClientHealthMonitor.java | 288 +-
.../internal/cache/tier/sockets/ClientMessage.java | 2 +-
.../tier/sockets/ClientProxyMembershipID.java | 6 +-
.../cache/tier/sockets/ClientUpdateMessage.java | 44 +-
.../tier/sockets/ClientUpdateMessageImpl.java | 20 +-
.../cache/tier/sockets/CommBufferPool.java | 4 +-
.../cache/tier/sockets/CommandInitializer.java | 5 +
.../internal/cache/tier/sockets/EncryptorImpl.java | 749 ++++
.../sockets/GenericProtocolServerConnection.java | 126 -
.../internal/cache/tier/sockets/HandShake.java | 1802 --------
.../internal/cache/tier/sockets/Handshake.java | 525 +++
.../cache/tier/sockets/LegacyServerConnection.java | 88 -
.../geode/internal/cache/tier/sockets/Message.java | 130 +-
.../cache/tier/sockets/MessageIdExtractor.java | 6 +-
.../internal/cache/tier/sockets/MessageStats.java | 8 +-
.../cache/tier/sockets/ObjectPartList.java | 2 +-
.../tier/sockets/OldClientSupportService.java | 8 +-
.../tier/sockets/OriginalServerConnection.java | 88 +
.../tier/sockets/ProtobufServerConnection.java | 128 +
.../sockets/RemoveClientFromBlacklistMessage.java | 5 +-
.../cache/tier/sockets/ServerConnection.java | 373 +-
.../tier/sockets/ServerConnectionCollection.java | 44 +
.../tier/sockets/ServerConnectionFactory.java | 11 +-
.../tier/sockets/ServerHandShakeProcessor.java | 404 --
.../sockets/ServerInterestRegistrationMessage.java | 6 +-
.../cache/tier/sockets/ServerQueueStatus.java | 58 +-
.../tier/sockets/ServerSideHandshakeFactory.java | 102 +
.../tier/sockets/ServerSideHandshakeImpl.java | 224 +
.../cache/tier/sockets/VersionedObjectList.java | 5 +-
.../cache/tier/sockets/command/CommitCommand.java | 5 +-
.../tier/sockets/command/ExecuteFunction.java | 11 +-
.../tier/sockets/command/ExecuteFunction65.java | 11 +-
.../tier/sockets/command/ExecuteFunction66.java | 21 +-
.../sockets/command/ExecuteRegionFunction.java | 11 +-
.../sockets/command/ExecuteRegionFunction61.java | 11 +-
.../sockets/command/ExecuteRegionFunction65.java | 11 +-
.../sockets/command/ExecuteRegionFunction66.java | 11 +-
.../command/ExecuteRegionFunctionSingleHop.java | 11 +-
.../sockets/command/GatewayReceiverCommand.java | 2 +-
.../cache/tier/sockets/command/PutAll.java | 3 +-
.../cache/tier/sockets/command/PutAll70.java | 3 +-
.../cache/tier/sockets/command/PutAll80.java | 3 +-
.../tier/sockets/command/TXFailoverCommand.java | 19 +-
.../sockets/command/TXSynchronizationCommand.java | 30 +-
.../cache/tx/AbstractPeerTXRegionStub.java | 25 +-
.../internal/cache/tx/BucketTXRegionStub.java | 31 +
.../internal/cache/tx/ClientTXRegionStub.java | 2 +-
.../geode/internal/cache/tx/ClientTXStateStub.java | 66 +-
.../internal/cache/tx/DistClientTXStateStub.java | 25 +-
.../geode/internal/cache/tx/DistTxEntryEvent.java | 38 +-
.../internal/cache/tx/DistributedTXRegionStub.java | 85 +-
.../internal/cache/tx/PartitionedTXRegionStub.java | 29 +-
.../internal/cache/tx/RemoteClearMessage.java | 182 +
.../cache/tx/RemoteContainsKeyValueMessage.java | 294 ++
.../internal/cache/tx/RemoteDestroyMessage.java | 685 +++
.../internal/cache/tx/RemoteFetchEntryMessage.java | 304 ++
.../internal/cache/tx/RemoteFetchKeysMessage.java | 441 ++
.../cache/tx/RemoteFetchVersionMessage.java | 241 +
.../geode/internal/cache/tx/RemoteGetMessage.java | 402 ++
.../internal/cache/tx/RemoteInvalidateMessage.java | 392 ++
.../internal/cache/tx/RemoteOperationMessage.java | 586 +++
.../tx/RemoteOperationMessageWithDirectReply.java | 59 +
.../internal/cache/tx/RemotePutAllMessage.java | 517 +++
.../geode/internal/cache/tx/RemotePutMessage.java | 1066 +++++
.../internal/cache/tx/RemoteRemoveAllMessage.java | 510 +++
.../geode/internal/cache/tx/RemoteSizeMessage.java | 254 ++
.../geode/internal/cache/tx/TXRegionStub.java | 2 +-
.../cache/versions/RegionVersionVector.java | 30 +-
.../cache/versions/VMRegionVersionVector.java | 13 +-
.../internal/cache/versions/VMVersionTag.java | 4 +-
.../internal/cache/versions/VersionHolder.java | 4 +-
.../geode/internal/cache/versions/VersionTag.java | 4 +-
.../internal/cache/vmotion/VMotionObserver.java | 6 +-
.../internal/cache/wan/AbstractGatewaySender.java | 11 +-
.../wan/AbstractGatewaySenderEventProcessor.java | 30 +-
.../cache/wan/DistributedSystemListener.java | 4 +-
.../internal/cache/wan/GatewaySenderAdvisor.java | 7 +-
.../cache/wan/GatewaySenderEventDispatcher.java | 10 +-
.../internal/cache/wan/GatewaySenderEventImpl.java | 36 +-
...waySenderQueueEntrySynchronizationListener.java | 4 +-
...aySenderQueueEntrySynchronizationOperation.java | 17 +-
.../cache/wan/InternalGatewaySenderFactory.java | 13 +-
...currentParallelGatewaySenderEventProcessor.java | 8 +-
.../ParallelGatewaySenderEventProcessor.java | 3 +-
.../wan/parallel/ParallelGatewaySenderQueue.java | 5 +-
.../parallel/ParallelQueueBatchRemovalMessage.java | 259 --
.../wan/parallel/ParallelQueueRemovalMessage.java | 5 +-
...tilParallelGatewaySenderFlushedCoordinator.java | 3 +-
.../cache/wan/serial/BatchDestroyOperation.java | 6 +-
...oncurrentSerialGatewaySenderEventProcessor.java | 3 -
.../serial/SerialGatewaySenderEventProcessor.java | 44 +-
.../cache/wan/serial/SerialGatewaySenderQueue.java | 2 +-
.../internal/cache/xmlcache/CacheCreation.java | 137 +-
.../geode/internal/cache/xmlcache/CacheXml.java | 1 +
.../internal/cache/xmlcache/CacheXmlGenerator.java | 22 +-
.../internal/cache/xmlcache/CacheXmlParser.java | 22 +-
.../cache/xmlcache/ClientCacheCreation.java | 14 +-
.../geode/internal/cache/xmlcache/Declarable2.java | 2 +-
.../cache/xmlcache/FunctionServiceCreation.java | 23 +-
.../cache/xmlcache/GatewayReceiverCreation.java | 4 +
.../xmlcache/ParallelAsyncEventQueueCreation.java | 4 +-
.../xmlcache/ParallelGatewaySenderCreation.java | 4 +-
.../internal/cache/xmlcache/PropertyResolver.java | 16 +-
.../xmlcache/SerialAsyncEventQueueCreation.java | 4 +-
.../xmlcache/SerialGatewaySenderCreation.java | 4 +-
.../org/apache/geode/internal/concurrent/AL.java | 24 +-
.../geode/internal/concurrent/MapCallback.java | 31 +-
.../geode/internal/concurrent/MapResult.java | 4 +-
.../internal/datasource/AbstractPoolCache.java | 11 +-
.../datasource/ConfiguredDataSourceProperties.java | 11 +-
.../internal/datasource/ConnectionPoolCache.java | 8 +-
.../internal/datasource/ConnectionProvider.java | 8 +-
.../internal/datasource/DataSourceResources.java | 14 +-
.../internal/datasource/ManagedPoolCacheImpl.java | 2 +-
.../internal/datasource/TranxPoolCacheImpl.java | 2 +-
.../geode/internal/i18n/LocalizedStrings.java | 8 +-
.../org/apache/geode/internal/i18n/StringId.java | 10 +-
.../apache/geode/internal/jndi/JNDIInvoker.java | 9 +-
.../geode/internal/jta/GlobalTransaction.java | 4 +-
.../org/apache/geode/internal/lang/Filter.java | 2 +-
.../org/apache/geode/internal/lang/Initable.java | 2 +-
.../geode/internal/lang/MutableIdentifiable.java | 2 +-
.../apache/geode/internal/lang/ObjectUtils.java | 124 -
.../org/apache/geode/internal/lang/Orderable.java | 2 +-
.../org/apache/geode/internal/lang/Ordered.java | 4 +-
.../apache/geode/internal/lang/StringUtils.java | 13 +
.../geode/internal/lang/SystemPropertyHelper.java | 41 +-
.../geode/internal/logging/InternalLogWriter.java | 40 +-
.../geode/internal/logging/MergeLogFiles.java | 12 +-
.../internal/logging/log4j/AlertAppender.java | 4 +-
.../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 | 50 +-
.../apache/geode/internal/offheap/DataType.java | 31 +-
.../geode/internal/offheap/FreeListManager.java | 10 +-
.../geode/internal/offheap/LifecycleListener.java | 13 +-
.../geode/internal/offheap/MemoryAllocator.java | 23 +-
.../internal/offheap/MemoryAllocatorImpl.java | 26 +-
.../apache/geode/internal/offheap/MemoryBlock.java | 24 +-
.../geode/internal/offheap/MemoryInspector.java | 14 +-
.../internal/offheap/MemoryUsageListener.java | 2 +-
.../geode/internal/offheap/OffHeapHelper.java | 12 +-
.../geode/internal/offheap/OffHeapMemoryStats.java | 48 +-
.../internal/offheap/OffHeapRegionEntryHelper.java | 4 +-
.../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 +-
.../internal/security/FilterPostAuthorization.java | 218 -
.../internal/security/FilterPreAuthorization.java | 149 -
.../security/IntegratedSecurityService.java | 2 +-
.../geode/internal/security/ObjectWithAuthz.java | 67 -
.../internal/security/SecurityServiceFactory.java | 10 -
.../security/shiro/GeodeAuthenticationToken.java | 11 +-
.../geode/internal/sequencelog/SequenceLogger.java | 8 +-
.../geode/internal/sequencelog/io/Filter.java | 5 +-
.../sequencelog/model/GraphReaderCallback.java | 6 +-
.../apache/geode/internal/shared/NativeCalls.java | 57 +-
.../geode/internal/shared/NativeCallsJNAImpl.java | 125 +-
.../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 +-
.../org/apache/geode/internal/tcp/Connection.java | 26 +-
.../apache/geode/internal/tcp/ConnectionTable.java | 14 +-
.../geode/internal/tcp/DirectReplySender.java | 4 -
.../apache/geode/internal/tcp/ServerDelegate.java | 8 +-
.../org/apache/geode/internal/tcp/TCPConduit.java | 10 +-
.../org/apache/geode/internal/tcp/package.html | 2 +-
.../geode/internal/util/ArgumentRedactor.java | 177 +-
.../geode/internal/util/DebuggerSupport.java | 62 -
.../org/apache/geode/internal/util/IOUtils.java | 4 +-
.../geode/internal/util/ObjectIntProcedure.java | 2 +-
.../apache/geode/internal/util/PluckStacks.java | 99 +-
.../geode/internal/util/SingletonCallable.java | 82 -
.../apache/geode/internal/util/SingletonValue.java | 318 --
.../geode/internal/util/StackTraceCollector.java | 170 -
.../apache/geode/internal/util/Transformer.java | 2 +-
.../apache/geode/internal/util/Versionable.java | 8 +-
.../ConcurrentMapWithReusableEntries.java | 50 +
.../concurrent/CustomEntryConcurrentHashMap.java | 59 +-
.../java/org/apache/geode/lang/Identifiable.java | 2 +-
.../geode/management/AsyncEventQueueMXBean.java | 28 +-
.../org/apache/geode/management/BackupStatus.java | 21 +-
.../management/DistributedLockServiceMXBean.java | 12 +-
.../geode/management/DistributedRegionMXBean.java | 99 +-
.../geode/management/JMXNotificationType.java | 71 +-
.../geode/management/JMXNotificationUserData.java | 6 +-
.../org/apache/geode/management/LocatorMXBean.java | 16 +-
.../org/apache/geode/management/ManagerMXBean.java | 14 +-
.../org/apache/geode/management/MemberMXBean.java | 10 +-
.../org/apache/geode/management/RegionMXBean.java | 104 +-
.../apache/geode/management/cli/CliMetaData.java | 6 +-
.../geode/management/cli/CommandService.java | 8 +-
.../geode/management/cli/CommandStatement.java | 8 +-
.../org/apache/geode/management/cli/Result.java | 18 +-
.../geode/management/internal/JettyHelper.java | 30 +-
.../management/internal/JmxManagerAdvisee.java | 4 +-
.../management/internal/JmxManagerAdvisor.java | 11 +-
.../management/internal/JmxManagerLocator.java | 5 +-
.../geode/management/internal/MBeanJMXAdapter.java | 1 -
.../geode/management/internal/ManagementAgent.java | 29 +-
.../management/internal/ManagementConstants.java | 136 +-
.../management/internal/ManagementFunction.java | 5 +-
.../internal/ManagementMembershipListener.java | 14 +-
.../management/internal/ManagerStartupMessage.java | 7 +-
.../geode/management/internal/MemberMessenger.java | 8 +-
.../internal/NotificationBroadCasterProxy.java | 2 +-
.../geode/management/internal/ProxyInterface.java | 4 +-
.../geode/management/internal/ProxyListener.java | 6 +-
.../geode/management/internal/RestAgent.java | 11 +-
.../internal/SystemManagementService.java | 8 +-
.../internal/beans/AggregateHandler.java | 10 +-
.../internal/beans/CacheServerBridge.java | 16 +-
.../internal/beans/CacheServiceMBeanBase.java | 4 +-
.../internal/beans/DistributedRegionBridge.java | 2 +-
.../internal/beans/DistributedSystemBridge.java | 93 +-
.../internal/beans/DistributedSystemMBean.java | 3 +-
.../internal/beans/GatewayReceiverMBeanBridge.java | 4 +
.../management/internal/beans/MBeanAggregator.java | 14 +-
.../internal/beans/ManagementAdapter.java | 53 +-
.../internal/beans/ManagementListener.java | 8 +
.../management/internal/beans/MemberMBean.java | 5 +
.../internal/beans/MemberMBeanBridge.java | 111 +-
.../internal/beans/QueryDataFunction.java | 6 +-
.../internal/beans/RegionMBeanBridge.java | 39 +-
.../beans/stats/RegionClusterStatsMonitor.java | 2 +
.../internal/cli/AbstractCliAroundInterceptor.java | 35 +-
.../geode/management/internal/cli/CliUtil.java | 677 ++-
.../management/internal/cli/CommandManager.java | 12 +-
.../internal/cli/CommandResponseBuilder.java | 4 +-
.../geode/management/internal/cli/GfshParser.java | 59 +-
.../geode/management/internal/cli/Launcher.java | 10 +-
.../geode/management/internal/cli/LogWrapper.java | 7 +-
.../internal/cli/commands/AlterRegionCommand.java | 52 +-
.../cli/commands/AlterRuntimeConfigCommand.java | 2 +-
.../cli/commands/BackupDiskStoreCommand.java | 9 +-
.../cli/commands/ChangeLogLevelCommand.java | 3 +-
.../cli/commands/CloseDurableCQsCommand.java | 2 +-
.../cli/commands/CloseDurableClientCommand.java | 2 +-
.../cli/commands/CommandAvailabilityIndicator.java | 3 +-
.../cli/commands/CompactDiskStoreCommand.java | 7 +-
.../commands/CompactOfflineDiskStoreCommand.java | 5 +-
.../internal/cli/commands/ConfigurePDXCommand.java | 2 +-
.../internal/cli/commands/ConnectCommand.java | 49 +-
.../cli/commands/CountDurableCQEventsCommand.java | 2 +-
.../cli/commands/CreateJndiBindingCommand.java | 267 ++
.../internal/cli/commands/CreateRegionCommand.java | 246 +-
.../internal/cli/commands/DeployCommand.java | 2 +-
.../cli/commands/DescribeClientCommand.java | 14 +-
.../cli/commands/DescribeMemberCommand.java | 5 +-
.../cli/commands/DescribeRegionCommand.java | 212 +-
.../internal/cli/commands/DestroyIndexCommand.java | 2 +-
.../internal/cli/commands/DisconnectCommand.java | 5 +-
.../cli/commands/ExecuteFunctionCommand.java | 94 +-
.../internal/cli/commands/ExportConfigCommand.java | 2 +-
.../commands/ExportOfflineDiskStoreCommand.java | 3 +-
.../cli/commands/ExportStackTraceCommand.java | 6 +-
.../internal/cli/commands/GCCommand.java | 11 +-
.../internal/cli/commands/GfshCommand.java | 10 +-
.../cli/commands/ListAsyncEventQueuesCommand.java | 2 +-
.../internal/cli/commands/ListClientCommand.java | 6 +-
.../internal/cli/commands/ListDeployedCommand.java | 2 +-
.../cli/commands/ListDurableClientCQsCommand.java | 2 +-
.../internal/cli/commands/ListFunctionCommand.java | 2 +-
.../internal/cli/commands/ListMembersCommand.java | 69 +-
.../internal/cli/commands/ListRegionCommand.java | 4 +-
.../internal/cli/commands/NetstatCommand.java | 4 +-
.../internal/cli/commands/PutCommand.java | 10 +-
.../internal/cli/commands/RebalanceCommand.java | 33 +-
.../internal/cli/commands/RegionCommandsUtils.java | 9 -
.../cli/commands/ResumeGatewaySenderCommand.java | 2 +-
.../internal/cli/commands/ShCommand.java | 3 +-
.../internal/cli/commands/ShutdownCommand.java | 2 +-
.../internal/cli/commands/SleepCommand.java | 4 +-
.../cli/commands/StartGatewayReceiverCommand.java | 2 +-
.../internal/cli/commands/StartLocatorCommand.java | 39 +-
.../internal/cli/commands/StartMemberUtils.java | 12 +-
.../internal/cli/commands/StartServerCommand.java | 21 +-
.../cli/commands/StatusGatewayReceiverCommand.java | 2 +-
.../cli/commands/StatusGatewaySenderCommand.java | 2 +-
.../cli/commands/StopGatewayReceiverCommand.java | 2 +-
.../cli/commands/StopGatewaySenderCommand.java | 2 +-
.../internal/cli/commands/UndeployCommand.java | 2 +-
.../commands/UpgradeOfflineDiskStoreCommand.java | 8 +-
.../cli/converters/ClassNameConverter.java | 62 +
.../cli/converters/ConfigPropertyConverter.java | 58 +
.../converters/ConnectionEndpointConverter.java | 43 -
.../internal/cli/converters/EnumConverter.java | 15 +-
.../cli/converters/ExpirationActionConverter.java | 50 +
.../management/internal/cli/domain/ClassName.java | 127 +
.../cli/domain/EvictionAttributesInfo.java | 4 +-
.../internal/cli/domain/RegionAttributesInfo.java | 34 +-
.../cli/domain/RegionDescriptionPerMember.java | 19 -
.../cli/exceptions/EntityExistsException.java | 25 +
.../cli/functions/AlterRuntimeConfigFunction.java | 9 +-
.../cli/functions/ChangeLogLevelFunction.java | 7 +-
.../cli/functions/CloseDurableClientFunction.java | 8 +-
.../cli/functions/CloseDurableCqFunction.java | 8 +-
.../cli/functions/ContinuousQueryFunction.java | 5 +-
.../functions/CreateAsyncEventQueueFunction.java | 10 +-
.../functions/CreateDefinedIndexesFunction.java | 5 +-
.../cli/functions/CreateDiskStoreFunction.java | 5 +-
.../cli/functions/CreateIndexFunction.java | 5 +-
.../cli/functions/CreateJndiBindingFunction.java | 38 +
.../cli/functions/DataCommandFunction.java | 6 +-
.../internal/cli/functions/DeployFunction.java | 5 +-
.../cli/functions/DescribeDiskStoreFunction.java | 5 +-
.../functions/DestroyAsyncEventQueueFunction.java | 5 +-
.../cli/functions/DestroyDiskStoreFunction.java | 6 +-
.../cli/functions/DestroyIndexFunction.java | 5 +-
.../cli/functions/ExportConfigFunction.java | 5 +-
.../internal/cli/functions/ExportDataFunction.java | 9 +-
.../internal/cli/functions/ExportLogsFunction.java | 6 +-
.../functions/FetchRegionAttributesFunction.java | 66 +-
.../FetchSharedConfigurationStatusFunction.java | 9 +-
.../cli/functions/GarbageCollectionFunction.java | 10 +-
.../functions/GatewayReceiverCreateFunction.java | 5 +-
.../cli/functions/GatewaySenderCreateFunction.java | 5 +-
.../functions/GatewaySenderDestroyFunction.java | 5 +-
.../GetMemberConfigInformationFunction.java | 24 +-
.../functions/GetMemberInformationFunction.java | 15 +-
.../functions/GetRegionDescriptionFunction.java | 12 +-
.../internal/cli/functions/GetRegionsFunction.java | 12 +-
.../cli/functions/GetStackTracesFunction.java | 5 +-
.../GetSubscriptionQueueSizeFunction.java | 7 +-
.../internal/cli/functions/ImportDataFunction.java | 5 +-
.../cli/functions/JndiBindingConfiguration.java | 217 +
.../functions/ListAsyncEventQueuesFunction.java | 5 +-
.../cli/functions/ListDeployedFunction.java | 5 +-
.../cli/functions/ListDiskStoresFunction.java | 6 +-
.../cli/functions/ListDurableCqNamesFunction.java | 5 +-
.../cli/functions/ListFunctionFunction.java | 4 +-
.../internal/cli/functions/ListIndexFunction.java | 6 +-
.../cli/functions/MemberRegionFunction.java | 82 -
.../cli/functions/MembersForRegionFunction.java | 91 -
.../internal/cli/functions/NetstatFunction.java | 12 +-
.../internal/cli/functions/RebalanceFunction.java | 6 +-
.../cli/functions/RegionAlterFunction.java | 125 +-
.../cli/functions/RegionAttributesWrapper.java | 108 +
.../cli/functions/RegionCreateFunction.java | 65 +-
.../cli/functions/RegionDestroyFunction.java | 5 +-
.../internal/cli/functions/RegionFunctionArgs.java | 208 +-
.../functions/ShowMissingDiskStoresFunction.java | 5 +-
.../internal/cli/functions/ShutDownFunction.java | 11 +-
.../cli/functions/SizeExportLogsFunction.java | 6 +-
.../internal/cli/functions/UndeployFunction.java | 5 +-
.../internal/cli/functions/UnregisterFunction.java | 15 +-
.../cli/functions/UserFunctionExecution.java | 230 +-
.../management/internal/cli/i18n/CliStrings.java | 59 +-
.../management/internal/cli/json/GfJsonArray.java | 25 +-
.../internal/cli/remote/MemberCommandService.java | 2 +-
.../cli/remote/OnlineCommandProcessor.java | 18 +-
.../internal/cli/result/CommandResult.java | 37 +-
.../geode/management/internal/cli/shell/Gfsh.java | 37 +-
.../internal/cli/shell/GfshExecutionStrategy.java | 4 +-
.../internal/cli/shell/JmxOperationInvoker.java | 32 +-
.../internal/cli/shell/OperationInvoker.java | 23 +-
.../internal/cli/util/DiskStoreCompacter.java | 13 +-
.../internal/cli/util/DiskStoreUpgrader.java | 13 +-
.../management/internal/cli/util/MergeLogs.java | 46 +-
.../internal/cli/util/RegionAttributesNames.java | 5 +-
.../callbacks/ConfigurationChangeListener.java | 4 -
.../configuration/domain/Configuration.java | 5 +-
.../functions/DownloadJarFunction.java | 5 +-
.../functions/GetClusterConfigurationFunction.java | 21 +-
.../functions/GetRegionNamesFunction.java | 9 +-
.../functions/RecreateCacheFunction.java | 7 +-
.../internal/deployment/FunctionScanner.java | 2 +-
.../internal/messages/CompactRequest.java | 12 +-
.../internal/security/AccessControlMXBean.java | 2 +-
.../internal/security/ResourcePermissions.java | 20 +
.../web/controllers/ShellCommandsController.java | 56 +-
.../support/LoginHandlerInterceptor.java | 28 +-
.../SerializableObjectHttpMessageConverter.java | 4 +-
.../internal/web/shell/HttpOperationInvoker.java | 7 +-
.../membership/ClientMembershipEvent.java | 6 +-
.../membership/ClientMembershipListener.java | 6 +-
.../management/membership/MembershipEvent.java | 4 +-
.../management/membership/MembershipListener.java | 6 +-
.../java/org/apache/geode/pdx/JSONFormatter.java | 136 +-
.../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 +-
.../geode/pdx/ReflectionBasedAutoSerializer.java | 25 +-
.../org/apache/geode/pdx/WritablePdxInstance.java | 2 +-
.../pdx/internal/AutoSerializableManager.java | 26 +-
.../geode/pdx/internal/CheckTypeRegistryState.java | 7 +-
.../geode/pdx/internal/ClientTypeRegistration.java | 4 +-
.../apache/geode/pdx/internal/ComparableEnum.java | 6 +-
.../geode/pdx/internal/ConvertableToBytes.java | 2 +-
.../geode/pdx/internal/InternalPdxReader.java | 96 +-
.../geode/pdx/internal/PdxInstanceFactoryImpl.java | 10 +-
.../geode/pdx/internal/PeerTypeRegistration.java | 26 +-
.../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 | 4 +-
.../org/apache/geode/security/AuthInitialize.java | 33 +-
.../apache/geode/security/ResourcePermission.java | 143 +-
.../org/apache/geode/security/SecurityManager.java | 11 +-
.../geode.apache.org/schema/cache/cache-1.0.xsd | 1 +
.../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 | 17 +-
.../test/java/org/apache/geode/DeltaTestImpl.java | 16 +-
.../org/apache/geode/admin/AdminTestHelper.java | 12 +-
.../geode/cache/ConnectionPoolDUnitTest.java | 22 +-
.../CreateAndLocalDestroyInTXRegressionTest.java | 154 +
.../cache/PRCacheListenerDistributedTest.java | 84 +
...stenerWithInterestPolicyAllDistributedTest.java | 66 +
.../PRCreationTotalNumBucketsDistributedTest.java | 137 +
.../geode/cache/RegionExpirationDUnitTest.java | 193 +
.../cache/RegionExpirationIntegrationTest.java | 126 +
.../org/apache/geode/cache/RegionShortcutTest.java | 41 +
.../ReplicateCacheListenerDistributedTest.java | 308 ++
.../cache/client/ClientCacheFactoryJUnitTest.java | 1 +
.../AutoConnectionSourceImplJUnitTest.java | 5 +
.../internal/ConnectionPoolImplJUnitTest.java | 5 +-
.../internal/QueueConnectionImplJUnitTest.java | 47 +
.../client/internal/QueueManagerJUnitTest.java | 50 +-
.../pooling/ConnectionManagerJUnitTest.java | 97 +-
.../cache/execute/CoreFunctionSecurityTest.java | 180 +
.../management/MemoryThresholdsDUnitTest.java | 34 +-
.../org/apache/geode/cache/query/BugJUnitTest.java | 7 -
.../geode/cache/query/PdxStringQueryJUnitTest.java | 33 +-
.../geode/cache/query/QueryServiceJUnitTest.java | 28 -
.../geode/cache/query/TypedIteratorJUnitTest.java | 3 -
.../cache/query/cq/dunit/CqQueryTestListener.java | 2 +-
.../cache/query/dunit/PdxLocalQueryDUnitTest.java | 4 +-
.../PdxLocalQueryVersionedClassDUnitTest.java | 5 +-
.../geode/cache/query/dunit/PdxQueryDUnitTest.java | 38 +-
.../ResourceManagerWithQueryMonitorDUnitTest.java | 22 +-
.../functional/IndexPrimaryKeyUsageJUnitTest.java | 1 -
.../IndexUsageInNestedQueryJUnitTest.java | 1 -
.../cache/query/functional/MiscJUnitTest.java | 14 -
.../query/functional/NestedQueryJUnitTest.java | 2 -
.../ArithmeticOperationsIntegrationTest.java | 287 ++
.../RestrictedMethodInvocationAuthorizerTest.java | 10 +-
.../CompactRangeIndexQueryIntegrationTest.java | 3 +
.../index/DeclarativeIndexCreationJUnitTest.java | 9 +-
.../index/IndexCreationInternalsJUnitTest.java | 5 +-
.../query/internal/index/IndexHintJUnitTest.java | 53 +
.../internal/index/IndexMaintainceJUnitTest.java | 32 +-
.../internal/index/MemoryIndexStoreJUnitTest.java | 9 +-
.../NewDeclarativeIndexCreationJUnitTest.java | 15 +-
.../internal/index/PartitionedIndexJUnitTest.java | 70 +
...ProgRegionCreationIndexUpdateTypeJUnitTest.java | 16 +-
.../query/internal/types/ObjectTypeAssert.java | 67 +
.../cache/query/internal/types/TypeUtilTest.java | 44 -
.../query/internal/types/TypeUtilsJUnitTest.java | 1163 +++++
.../partitioned/PRBasicIndexCreationDUnitTest.java | 947 ++--
.../PRBasicIndexCreationDeadlockDUnitTest.java | 245 --
.../PRBasicMultiIndexCreationDUnitTest.java | 370 +-
.../query/partitioned/PRBasicQueryDUnitTest.java | 466 +-
.../partitioned/PRBasicRemoveIndexDUnitTest.java | 132 +-
.../partitioned/PRColocatedEquiJoinDUnitTest.java | 1651 +++----
.../query/partitioned/PRInvalidQueryDUnitTest.java | 137 +-
.../partitioned/PRQueryCacheCloseDUnitTest.java | 319 --
.../query/partitioned/PRQueryDUnitHelper.java | 9 +-
.../cache/query/partitioned/PRQueryDUnitTest.java | 1266 ++----
.../partitioned/PRQueryPortfolioDUnitTest.java | 467 ++
.../partitioned/PRQueryRegionCloseDUnitTest.java | 211 +-
.../PRQueryRegionDestroyedDUnitTest.java | 208 +-
.../PRQueryRemoteNodeExceptionDUnitTest.java | 792 +---
.../geode/cache30/CacheListenerTestCase.java | 3 -
.../geode/cache30/CacheSerializableRunnable.java | 3 -
.../apache/geode/cache30/CacheXml66DUnitTest.java | 6 +-
.../apache/geode/cache30/CacheXml70DUnitTest.java | 4 +-
.../org/apache/geode/cache30/CacheXmlTestCase.java | 20 +
.../geode/cache30/CachedAllEventsDUnitTest.java | 17 -
.../apache/geode/cache30/CallbackArgDUnitTest.java | 20 -
.../geode/cache30/ClientMembershipDUnitTest.java | 57 +-
.../geode/cache30/ClientServerCCEDUnitTest.java | 8 +-
.../apache/geode/cache30/ClientServerTestCase.java | 22 -
.../CreateAndLocalDestroyInTXRegressionTest.java | 167 -
.../apache/geode/cache30/DiskRegionDUnitTest.java | 1632 -------
.../geode/cache30/DiskRegionDistributedTest.java | 415 ++
.../geode/cache30/DiskRegionIntegrationTest.java | 580 +++
.../apache/geode/cache30/DiskRegionTestImpl.java | 14 -
...ibutedAckOverflowRegionCCEOffHeapDUnitTest.java | 2 +-
...utedAckPersistentRegionCCEOffHeapDUnitTest.java | 2 +-
.../cache30/DistributedAckRegionCCEDUnitTest.java | 13 +-
.../DistributedAckRegionCCEOffHeapDUnitTest.java | 2 +-
.../DistributedAckRegionOffHeapDUnitTest.java | 2 +-
.../DistributedNoAckRegionCCEDUnitTest.java | 14 -
.../DistributedNoAckRegionCCEOffHeapDUnitTest.java | 2 +-
.../DistributedNoAckRegionOffHeapDUnitTest.java | 2 +-
.../EntriesDoNotExpireDuringGIIRegressionTest.java | 210 -
.../cache30/GlobalRegionCCEOffHeapDUnitTest.java | 2 +-
.../cache30/GlobalRegionOffHeapDUnitTest.java | 2 +-
.../cache30/LRUEvictionControllerDUnitTest.java | 61 +-
.../cache30/MemLRUEvictionControllerDUnitTest.java | 12 +-
.../geode/cache30/MultiVMRegionTestCase.java | 418 +-
.../OffHeapLRUEvictionControllerDUnitTest.java | 2 +-
.../cache30/PartitionedRegionOffHeapDUnitTest.java | 2 +-
.../org/apache/geode/cache30/ProxyDUnitTest.java | 11 +-
.../apache/geode/cache30/ReconnectDUnitTest.java | 31 +-
.../geode/cache30/RegionExpirationDUnitTest.java | 259 --
.../cache30/RegionMembershipListenerDUnitTest.java | 14 +-
.../geode/cache30/RegionReliabilityTestCase.java | 7 -
.../org/apache/geode/cache30/RegionTestCase.java | 206 -
.../org/apache/geode/cache30/SlowRecDUnitTest.java | 14 +-
.../org/apache/geode/cache30/TXOrderDUnitTest.java | 18 -
.../org/apache/geode/cache30/TestDiskRegion.java | 12 +-
.../AnalyzeSerializablesJUnitTest.java | 22 +-
.../DistributedLockServiceDUnitTest.java | 7 +-
.../distributed/DistributedMemberDUnitTest.java | 15 +-
.../distributed/DistributedSystemDUnitTest.java | 17 +-
.../geode/distributed/HostedLocatorsDUnitTest.java | 28 +-
.../apache/geode/distributed/LocatorDUnitTest.java | 28 +-
.../distributed/LocatorLauncherBuilderTest.java | 15 +-
.../apache/geode/distributed/RoleDUnitTest.java | 8 +-
.../distributed/ServerLauncherBuilderTest.java | 15 +-
.../geode/distributed/ServerLauncherDUnitTest.java | 112 +
.../distributed/ServerLauncherDUnitTestHelper.java | 37 +
.../geode/distributed/SystemAdminDUnitTest.java | 4 +-
.../ClusterDistributionManagerDUnitTest.java | 399 ++
...lusterDistributionManagerForAdminDUnitTest.java | 317 ++
.../internal/ClusterDistributionManagerTest.java | 46 +
.../ConsoleDistributionManagerDUnitTest.java | 446 --
.../geode/distributed/internal/DateMessage.java | 2 +-
.../internal/DistributionAdvisorDUnitTest.java | 2 +-
.../internal/DistributionManagerDUnitTest.java | 545 ---
.../internal/DistributionManagerTest.java | 44 -
.../InternalDistributedSystemJUnitTest.java | 37 +-
.../org/apache/geode/distributed/internal/LDM.java | 4 +-
.../internal/LocatorLoadSnapshotJUnitTest.java | 66 +
.../distributed/internal/ProduceDateMessages.java | 2 +-
.../internal/locks/DLockServiceLeakTest.java | 23 +-
.../internal/membership/MembershipJUnitTest.java | 18 +-
.../internal/membership/NetViewJUnitTest.java | 24 +-
.../membership/gms/MembershipManagerHelper.java | 5 +-
.../gms/fd/GMSHealthMonitorJUnitTest.java | 5 +-
.../gms/locator/GMSLocatorRecoveryJUnitTest.java | 27 +-
.../gms/membership/GMSJoinLeaveJUnitTest.java | 74 +-
.../gms/membership/GMSJoinLeaveTestHelper.java | 19 +-
.../gms/membership/StatRecorderJUnitTest.java | 6 +-
.../gms/messenger/GMSEncryptJUnitTest.java | 495 +--
.../gms/messenger/GMSQuorumCheckerJUnitTest.java | 27 +-
.../gms/messenger/JGroupsMessengerJUnitTest.java | 12 +-
.../gms/mgr/GMSMembershipManagerJUnitTest.java | 6 +-
.../geode/internal/AbstractConfigJUnitTest.java | 91 -
.../internal/InternalDataSerializerJUnitTest.java | 63 +
...alDataSerializerSerializationWhitelistTest.java | 9 +-
.../internal/PutAllOperationContextJUnitTest.java | 2 +-
.../internal/cache/ARMLockTestHookAdapter.java | 18 +-
.../internal/cache/AbstractLRURegionMapTest.java | 43 -
.../internal/cache/AbstractRegionJUnitTest.java | 640 +--
.../internal/cache/AbstractRegionMapTest.java | 768 +++-
.../internal/cache/BucketRegionJUnitTest.java | 1 +
.../geode/internal/cache/Bug41091DUnitTest.java | 5 +-
.../geode/internal/cache/Bug41733DUnitTest.java | 8 +-
.../internal/cache/CacheOperationMessageTest.java | 4 +-
.../geode/internal/cache/CacheProfileTest.java | 57 +
.../CacheWriterGetOldValueIntegrationTest.java | 4 +-
.../internal/cache/ClearRvvLockingDUnitTest.java | 8 +-
.../internal/cache/ClearTXLockingDUnitTest.java | 181 +-
.../cache/ClientServerGetAllDUnitTest.java | 2 +-
...entServerInvalidAndDestroyedEntryDUnitTest.java | 14 +-
.../cache/ClientServerTransactionDUnitTest.java | 4 +-
.../geode/internal/cache/ColocationHelperTest.java | 9 -
.../internal/cache/DeltaFaultInDUnitTest.java | 3 +-
.../internal/cache/DeltaPropagationDUnitTest.java | 22 +-
...stroyEntryWithConcurrentOperationJUnitTest.java | 229 -
.../DiskRegOplogSwtchingAndRollerJUnitTest.java | 6 +-
.../geode/internal/cache/DiskRegionJUnitTest.java | 7 +-
.../cache/DiskStoreImplIntegrationTest.java | 53 +-
.../geode/internal/cache/DiskStoreMonitorTest.java | 57 +
.../DistrbutedRegionProfileOffHeapDUnitTest.java | 2 +-
.../internal/cache/DistributedCacheTestCase.java | 17 +-
...tributedRegionFunctionStreamingMessageTest.java | 4 +-
.../EnforceUniqueHostForLonerIntegrationTest.java | 62 +
.../EntriesDoNotExpireDuringGiiRegressionTest.java | 182 +
.../geode/internal/cache/EntryEventImplTest.java | 67 +-
.../cache/FilterProfileConcurrencyTest.java | 89 +
.../geode/internal/cache/FlusherThreadTest.java | 77 +
.../geode/internal/cache/GIIDeltaDUnitTest.java | 10 +-
.../internal/cache/GIIFlowControlDUnitTest.java | 6 +-
.../geode/internal/cache/GemFireCacheImplTest.java | 114 +
.../geode/internal/cache/GridProfileTest.java | 6 +-
.../cache/HAOverflowMemObjectSizerDUnitTest.java | 9 +-
.../internal/cache/InitialImageOperationTest.java | 56 +
.../cache/InterruptClientServerDUnitTest.java | 8 +-
.../internal/cache/InterruptDiskJUnitTest.java | 21 +-
.../geode/internal/cache/InterruptsDUnitTest.java | 8 +-
.../cache/JtaAfterCompletionMessageTest.java | 52 +
.../cache/JtaBeforeCompletionMessageTest.java | 52 +
.../LIFOEvictionAlgoEnabledRegionJUnitTest.java | 4 +-
...FOEvictionAlgoMemoryEnabledRegionJUnitTest.java | 9 +-
.../LRUClearWithDiskRegionOpRegressionTest.java | 12 +-
.../cache/NetSearchMessagingDUnitTest.java | 12 +-
.../geode/internal/cache/OffHeapTestUtil.java | 17 +-
.../geode/internal/cache/OplogFlushTest.java | 10 +-
.../geode/internal/cache/OplogJUnitTest.java | 181 +-
.../cache/PRCacheListenerInvocationTest.java | 88 -
...istenerWithInterestPolicyAllInvocationTest.java | 72 -
.../PREntryIdleExpirationDistributedTest.java | 51 +
.../internal/cache/PREntryIdleExpirationTest.java | 50 -
.../cache/PartitionAttributesImplJUnitTest.java | 47 +
...onedRegionAPIConserveSocketsFalseDUnitTest.java | 9 +-
.../cache/PartitionedRegionAPIDUnitTest.java | 1811 +++-----
.../PartitionedRegionAsSubRegionDUnitTest.java | 314 --
.../PartitionedRegionAsSubregionDUnitTest.java | 234 +
...dRegionBucketCreationDistributionDUnitTest.java | 1851 +++-----
.../PartitionedRegionCacheCloseDUnitTest.java | 276 +-
.../PartitionedRegionCacheXMLExampleDUnitTest.java | 176 +-
.../cache/PartitionedRegionCloseDUnitTest.java | 196 -
.../PartitionedRegionCloseDistributedTest.java | 197 +
.../cache/PartitionedRegionCreationDUnitTest.java | 1025 ++---
.../cache/PartitionedRegionDUnitTestCase.java | 507 ---
.../cache/PartitionedRegionDestroyDUnitTest.java | 361 +-
.../cache/PartitionedRegionEvictionDUnitTest.java | 18 +-
.../cache/PartitionedRegionGetSomeKeys.java | 95 +
.../cache/PartitionedRegionHADUnitTest.java | 654 ++-
...itionedRegionHAFailureAndRecoveryDUnitTest.java | 689 ++-
.../PartitionedRegionLocalMaxMemoryDUnitTest.java | 274 +-
...tionedRegionLocalMaxMemoryOffHeapDUnitTest.java | 45 +-
.../cache/PartitionedRegionMultipleDUnitTest.java | 576 +--
.../PartitionedRegionOffHeapEvictionDUnitTest.java | 2 +-
.../cache/PartitionedRegionPRIDDUnitTest.java | 287 +-
.../cache/PartitionedRegionQueryDUnitTest.java | 5 +-
...itionedRegionSingleNodeOperationsJUnitTest.java | 2 +-
.../cache/PartitionedRegionSizeDUnitTest.java | 625 +--
.../cache/PartitionedRegionStatsDUnitTest.java | 823 ++--
.../cache/PartitionedRegionTestUtilsDUnitTest.java | 817 ++--
.../PartitionedRegionWithSameNameDUnitTest.java | 920 +---
.../geode/internal/cache/RegionCommitTest.java | 58 +
.../cache/RemoteFetchEntryMessageTest.java | 44 -
.../internal/cache/RemoteOperationMessageTest.java | 109 -
.../internal/cache/RemotePutAllMessageTest.java | 40 -
.../cache/RemotePutReplyMessageJUnitTest.java | 52 -
.../internal/cache/RemoteRemoveAllMessageTest.java | 40 -
.../internal/cache/RemoteTransactionDUnitTest.java | 23 +-
.../ReplicateCacheListenerInvocationTest.java | 327 --
...eplicateEntryIdleExpirationDistributedTest.java | 128 +
.../cache/ReplicateEntryIdleExpirationTest.java | 128 -
.../cache/RequestFilterInfoMessageTest.java | 30 +
.../cache/SearchLoadAndWriteProcessorTest.java | 6 +-
.../internal/cache/SimpleDiskRegionJUnitTest.java | 2 +-
.../geode/internal/cache/SizingFlagDUnitTest.java | 4 +-
.../cache/StartServerWithXmlDUnitTest.java | 73 +
.../internal/cache/StateMarkerMessageTest.java | 5 +-
.../internal/cache/SystemFailureDUnitTest.java | 4 +-
.../geode/internal/cache/TXManagerImplTest.java | 7 +-
.../cache/TXRegionLockRequestImplTest.java | 55 +
.../internal/cache/TXReservationMgrJUnitTest.java | 2 +-
.../internal/cache/TXStateProxyImplJUnitTest.java | 61 -
.../geode/internal/cache/TXStateProxyImplTest.java | 82 +
.../cache/TXSynchronizationRunnableTest.java | 64 +
.../internal/cache/TestObjectWithIdentifier.java | 85 +
...ommitMessageBackwardCompatibilityDUnitTest.java | 640 +++
.../geode/internal/cache/VMLRURegionMapTest.java | 43 +
.../cache/backup/AbortBackupFactoryTest.java | 85 +
.../cache/backup/AbortBackupOperationTest.java | 183 +
.../cache/backup/AbortBackupRequestTest.java | 79 +
.../backup/AbstractBackupWriterConfigTest.java | 86 +
.../cache/backup/BackupDefinitionTest.java | 21 +-
.../cache/backup/BackupDistributedTest.java | 24 +-
.../backup/BackupFileCopierIntegrationTest.java | 283 ++
.../cache/backup/BackupIntegrationTest.java | 53 +-
.../internal/cache/backup/BackupLockTest.java | 105 -
.../backup/BackupPrepareAndFinishMsgDUnitTest.java | 59 +-
.../cache/backup/BackupReplyProcessorTest.java | 6 +-
.../internal/cache/backup/BackupServiceTest.java | 90 +
.../cache/backup/BackupWriterFactoryTest.java | 78 +
.../backup/FileSystemBackupDestinationTest.java | 229 -
.../backup/FileSystemBackupWriterConfigTest.java | 74 +
.../cache/backup/FileSystemBackupWriterTest.java | 250 ++
.../FileSystemIncrementalBackupLocationTest.java | 189 +
.../cache/backup/FinishBackupFactoryTest.java | 14 +-
.../cache/backup/FinishBackupOperationTest.java | 20 +-
.../cache/backup/FinishBackupRequestTest.java | 27 +-
.../cache/backup/FlushToDiskFactoryTest.java | 6 +-
.../cache/backup/FlushToDiskOperationTest.java | 6 +-
.../cache/backup/FlushToDiskRequestTest.java | 6 +-
.../backup/IncrementalBackupDistributedTest.java | 34 +-
...titionedBackupPrepareAndFinishMsgDUnitTest.java | 4 +-
.../cache/backup/PrepareBackupFactoryTest.java | 13 +-
.../cache/backup/PrepareBackupOperationTest.java | 25 +-
.../cache/backup/PrepareBackupRequestTest.java | 24 +-
...eplicateBackupPrepareAndFinishMsgDUnitTest.java | 4 +-
.../cache/backup/TemporaryBackupFilesTest.java | 110 +
.../cache/control/RebalanceOperationDUnitTest.java | 6 +-
.../cache/control/TestMemoryThresholdListener.java | 7 +-
.../DiskRegOverflowAsyncJUnitPerformanceTest.java | 8 +-
.../DiskRegOverflowSyncJUnitPerformanceTest.java | 8 +-
...skRegionOverflowAsyncRollingOpLogJUnitTest.java | 6 +-
...iskRegionOverflowSyncRollingOpLogJUnitTest.java | 6 +-
.../cache/eviction/AbstractEvictionListTest.java | 81 +-
.../internal/cache/eviction/EvictionDUnitTest.java | 22 +-
.../cache/eviction/EvictionListBuilderTest.java | 80 +
.../eviction/EvictionObjectSizerDUnitTest.java | 14 +-
.../cache/eviction/EvictionStatsDUnitTest.java | 157 +-
.../internal/cache/eviction/EvictionTestBase.java | 13 +-
.../internal/cache/eviction/LIFOListTest.java | 15 +-
.../LRUListWithAsyncSortingIntegrationTest.java | 11 +-
.../eviction/LRUListWithAsyncSortingTest.java | 50 +-
.../LRUListWithSyncSortingIntegrationTest.java | 6 +-
.../cache/eviction/LRUListWithSyncSortingTest.java | 19 +-
.../internal/cache/eviction/LRUTestEntry.java | 5 +-
.../cache/eviction/OffHeapEvictionDUnitTest.java | 9 +-
.../eviction/OffHeapEvictionStatsDUnitTest.java | 7 +-
.../cache/eviction/TestEvictionController.java | 114 +-
.../eviction/TestLRUListWithAsyncSorting.java | 17 +-
.../eviction/TransactionsWithOverflowTest.java | 48 +
.../internal/cache/execute/BooleanFunction.java | 46 +
.../ClientFunctionTimeoutRegressionTest.java | 205 +-
...istributedRegionFunctionExecutionDUnitTest.java | 4 +-
.../ExecuteFunctionInstanceRegressionTest.java | 188 +
...ExceptionsIncludeLocalMemberRegressionTest.java | 136 +
.../FunctionExecutionOnLonerRegressionTest.java | 142 +
.../FunctionExecution_ExceptionDUnitTest.java | 799 ++--
.../cache/execute/FunctionServiceBase.java | 9 +-
.../execute/MemberFunctionExecutionDUnitTest.java | 4 +-
.../cache/execute/MonthBasedPartitionResolver.java | 73 +
.../execute/PRCustomPartitioningDUnitTest.java | 598 +--
.../execute/PRFunctionExecutionDUnitTest.java | 4181 +++++++-----------
...FunctionExecutionWithResultSenderDUnitTest.java | 904 ++--
.../cache/execute/PRPerformanceTestDUnitTest.java | 417 --
.../cache/execute/PRSetOperationJTADUnitTest.java | 180 +
.../cache/execute/PRTransaction2DUnitTest.java | 146 -
.../PRTransactionWithSizeOperationDUnitTest.java | 196 +
.../internal/cache/execute/SerializableMonth.java | 55 +
.../geode/internal/cache/execute/TestFunction.java | 163 -
.../geode/internal/cache/execute/TimeKeeper.java | 41 +
.../internal/cache/functions/TestFunction.java | 24 +-
.../internal/cache/ha/HARegionQueueDUnitTest.java | 88 +-
.../geode/internal/cache/ha/HARegionQueueTest.java | 128 +
.../cache/locks/TXLockServiceDUnitTest.java | 34 +-
.../DestroyEntryDuringCloseIntegrationTest.java | 97 +
.../internal/cache/map/RegionMapDestroyTest.java | 658 +++
.../BucketRebalanceStatRegressionTest.java | 178 +-
.../cache/partitioned/Bug39356DUnitTest.java | 6 +-
.../DeposePrimaryBucketMessageTest.java | 4 +-
.../cache/partitioned/FetchEntryMessageTest.java | 4 +-
.../FetchPartitionDetailsMessageTest.java | 4 +-
.../cache/partitioned/MoveBucketMessageTest.java | 4 +-
.../cache/partitioned/PartitionMessageTest.java | 9 +-
.../cache/partitioned/PersistPRKRFDUnitTest.java | 255 --
.../partitioned/PersistPRKRFIntegrationTest.java | 176 +
...sistentColocatedPartitionedRegionDUnitTest.java | 8 +-
.../PersistentPartitionedRegionDUnitTest.java | 35 +-
.../PersistentPartitionedRegionTestBase.java | 4 +-
.../cache/partitioned/RemoveBucketMessageTest.java | 4 +-
.../PersistentRVVRecoveryDUnitTest.java | 6 +-
.../PersistentRecoveryOrderDUnitTest.java | 41 +-
.../entry/RegionEntryFactoryBuilderJUnitTest.java | 6 +-
.../rollingupgrade/RollingUpgrade2DUnitTest.java | 392 +-
.../rollingupgrade/RollingUpgradeDUnitTest.java | 177 +-
.../cache/snapshot/ClientExporterTest.java | 52 +
.../snapshot/GFSnapshotJUnitPerformanceTest.java | 15 +-
...dCompatibilityHigherVersionClientDUnitTest.java | 5 +-
.../ClientHealthMonitorIntegrationTest.java | 221 +
.../tier/sockets/ClientHealthMonitorJUnitTest.java | 243 +-
...ClientHealthMonitorSelectorIntegrationTest.java | 33 +
.../ClientHealthMonitorSelectorJUnitTest.java | 35 -
.../ClientProxyWithDeltaDistributedTest.java | 323 ++
.../tier/sockets/ClientProxyWithDeltaTest.java | 321 --
.../tier/sockets/ClientServerMiscDUnitTest.java | 58 +-
.../ClientWithInterestFailoverDistributedTest.java | 281 ++
.../sockets/ClientWithInterestFailoverTest.java | 280 --
.../cache/tier/sockets/ConflationDUnitTest.java | 60 -
.../ForceInvalidateOffHeapEvictionDUnitTest.java | 2 +-
.../internal/cache/tier/sockets/HandShakeTest.java | 53 -
.../internal/cache/tier/sockets/HandshakeTest.java | 53 +
.../cache/tier/sockets/MessageIdExtractorTest.java | 9 +-
.../cache/tier/sockets/MessageJUnitTest.java | 58 +
.../sockets/RegisterInterestIntegrationTest.java | 342 ++
.../sockets/RegisterInterestKeysDUnitTest.java | 4 +-
...isterInterestServerMetaDataDistributedTest.java | 272 ++
.../RegisterInterestServerMetaDataTest.java | 272 --
.../tier/sockets/ServerConnectionFactoryTest.java | 4 +-
.../sockets/ServerConnectionIntegrationTest.java | 194 +
.../cache/tier/sockets/ServerConnectionTest.java | 42 +-
.../sockets/command/ExecuteFunction65Test.java | 5 +-
.../sockets/command/ExecuteFunction66Test.java | 4 +-
.../tier/sockets/command/ExecuteFunctionTest.java | 7 +-
.../sockets/command/TXFailoverCommandTest.java | 72 +-
.../cache/tx/AbstractPeerTXRegionStubTest.java | 13 +-
.../internal/cache/tx/ClientTXStateStubTest.java | 82 +
.../cache/tx/RemoteFetchEntryMessageTest.java | 46 +
.../cache/tx/RemoteOperationMessageTest.java | 300 ++
.../cache/tx/RemoteOperationResponseTest.java | 162 +
.../internal/cache/tx/RemotePutAllMessageTest.java | 41 +
.../cache/tx/RemotePutReplyMessageJUnitTest.java | 53 +
.../cache/tx/RemoteRemoveAllMessageTest.java | 41 +
.../cache/tx/SetOperationJTADistributedTest.java | 290 ++
.../RegionVersionVectorIntegrationTest.java | 172 +
.../cache/versions/RegionVersionVectorTest.java | 28 +-
.../cache/wan/AsyncEventQueueTestBase.java | 18 +-
...rallelGatewaySenderEventProcessorJUnitTest.java | 141 +
.../wan/parallel/ParallelGatewaySenderHelper.java | 79 +
.../ParallelQueueRemovalMessageJUnitTest.java | 41 +-
.../cache/xmlcache/CacheCreationJUnitTest.java | 98 +
.../CompressionCacheListenerOffHeapDUnitTest.java | 2 +-
.../CompressionRegionOperationsDUnitTest.java | 15 +-
...ompressionRegionOperationsOffHeapDUnitTest.java | 2 +-
.../internal/jta/ClientServerJTADUnitTest.java | 357 +-
.../internal/jta/SetOperationJTAJUnitTest.java | 154 +
.../geode/internal/lang/ObjectUtilsJUnitTest.java | 88 -
.../geode/internal/lang/StringUtilsJUnitTest.java | 13 +-
.../lang/SystemPropertyHelperJUnitTest.java | 85 -
.../internal/lang/SystemPropertyHelperTest.java | 110 +
.../geode/internal/offheap/DataTypeJUnitTest.java | 106 +-
...nectingOutOfOffHeapMemoryListenerJUnitTest.java | 4 +-
.../internal/offheap/MemoryAllocatorJUnitTest.java | 2 +-
.../internal/offheap/OffHeapHelperJUnitTest.java | 26 +-
.../geode/internal/offheap/OffHeapRegionBase.java | 2 +-
.../offheap/OutOfOffHeapMemoryDUnitTest.java | 14 +-
.../BlockingProcessStreamReaderWindowsTest.java | 20 +-
.../ControlFileWatchdogIntegrationTest.java | 15 +-
.../FileProcessControllerIntegrationTest.java | 23 +-
.../internal/process/PidFileIntegrationTest.java | 10 -
.../security/IntegratedSecurityServiceTest.java | 4 +-
.../statistics/DiskSpaceLimitIntegrationTest.java | 16 +-
...chiveWithMissingResourceTypeRegressionTest.java | 22 +-
.../geode/internal/tcp/ConnectionJUnitTest.java | 4 +-
.../geode/internal/tcp/ConnectionTableTest.java | 4 +-
.../util/AbortableTaskServiceJUnitTest.java | 18 +-
.../internal/util/ArgumentRedactorJUnitTest.java | 185 +-
.../geode/internal/util/PluckStacksDUnitTest.java | 131 +
.../geode/internal/util/PluckStacksUnitTest.java | 65 +
.../geode/management/ManagementTestRule.java | 4 +-
.../geode/management/QueryDataDUnitTest.java | 13 +-
.../QueryDataFunctionIntegrationTest.java | 5 +-
.../management/RegionManagementDUnitTest.java | 10 +-
...ServerBridgeClientMembershipRegressionTest.java | 24 +-
.../beans/DistributedSystemBridgeJUnitTest.java | 39 +-
.../cli/AbstractCliAroundInterceptorJUnitTest.java | 59 -
.../management/internal/cli/CliUtilDUnitTest.java | 35 +-
.../geode/management/internal/cli/CliUtilTest.java | 11 -
.../internal/cli/GfshParserAutoCompletionTest.java | 18 +-
.../internal/cli/GfshParserConverterTest.java | 23 +
.../internal/cli/GfshParserJUnitTest.java | 17 +
.../internal/cli/GfshParserParsingTest.java | 10 -
.../management/internal/cli/NetstatDUnitTest.java | 56 +-
.../cli/commands/AlterCompressorDUnitTest.java | 250 ++
.../cli/commands/AlterRegionCommandDUnitTest.java | 738 +---
.../AlterRegionCommandIntegrationTest.java | 9 +-
.../cli/commands/AlterRegionCommandTest.java | 74 +
.../cli/commands/ConcurrentDeployDUnitTest.java | 2 +-
.../cli/commands/ConnectCommandDUnitTest.java | 49 +
.../internal/cli/commands/ConnectCommandTest.java | 39 +-
.../CreateAsyncEventQueueCommandDUnitTest.java | 4 +-
.../CreateDefinedIndexesCommandDUnitTest.java | 10 +-
.../CreateJndiBindingCommandDUnitTest.java | 106 +
.../cli/commands/CreateJndiBindingCommandTest.java | 417 ++
.../cli/commands/CreateRegionCommandDUnitTest.java | 369 +-
.../CreateRegionCommandIntegrationTest.java | 32 +-
.../cli/commands/CreateRegionCommandTest.java | 196 +-
.../commands/CreateRegionSecurityDUnitTest.java | 86 +
...DeployCommandFunctionRegistrationDUnitTest.java | 11 +-
.../cli/commands/DeployWithGroupsDUnitTest.java | 63 +-
.../cli/commands/DescribeRegionDUnitTest.java | 135 +-
.../commands/DestroyIndexCommandsDUnitTest.java | 10 +-
.../commands/DestroyRegionCommandDUnitTest.java | 19 +-
.../cli/commands/DiskStoreCommandsDUnitTest.java | 10 +-
.../ExecuteFunctionCommandSecurityTest.java | 10 +-
.../internal/cli/commands/ExportLogsDUnitTest.java | 5 +-
.../commands/ExportLogsOnServerManagerDUnit.java | 11 +-
.../cli/commands/ExportLogsStatsDUnitTest.java | 36 +-
.../ExportLogsWithMemberGroupDUnitTest.java | 6 +-
.../cli/commands/FunctionCommandsDUnitTest.java | 124 +-
.../IndexCommandsShareConfigurationDUnitTest.java | 10 +-
.../ListAsyncEventQueuesCommandDUnitTest.java | 4 +-
.../cli/commands/ListMembersCommandDUnitTest.java | 15 +-
.../cli/commands/ListMembersCommandTest.java | 101 +
.../cli/commands/LocateEntryDUnitTest.java | 12 +-
.../cli/commands/PutCommandIntegrationTest.java | 44 +-
.../internal/cli/commands/QueryCommandTest.java | 23 +-
.../cli/commands/RemoveCommandDUnitTest.java | 65 +-
.../cli/commands/RemoveCommandJsonDUnitTest.java | 10 +-
.../cli/commands/ShowDeadlockDUnitTest.java | 10 +-
.../cli/commands/ShowLogCommandDUnitTest.java | 6 +-
.../cli/commands/ShutdownCommandDUnitTest.java | 70 +-
.../cli/commands/StartMemberUtilsTest.java | 30 +
.../internal/cli/commands/TestCompressor1.java | 39 +
.../cli/commands/TestCustomIdleExpiry.java | 30 +
.../internal/cli/commands/TestCustomTTLExpiry.java | 30 +
.../cli/converters/ClassNameConverterTest.java | 87 +
.../converters/ConfigPropertyConverterTest.java | 75 +
.../internal/cli/domain/ClassNameTest.java | 115 +
.../internal/cli/domain/MyCacheWriter.java | 33 +
.../cli/functions/ExpirationAttrsTest.java | 67 +-
.../cli/functions/RegionFunctionArgsTest.java | 3 +-
.../ShowMissingDiskStoresFunctionJUnitTest.java | 1 -
.../cli/json/TypedJsonPdxIntegrationTest.java | 7 +-
.../cli/remote/OnlineCommandProcessorTest.java | 3 +-
.../cli/shell/GfshExecutionStrategyTest.java | 14 +-
.../internal/cli/shell/GfshInitFileJUnitTest.java | 7 +-
.../internal/cli/shell/GfshJunitTest.java | 55 +-
.../internal/cli/util/MergeLogsDUnitTest.java | 31 +-
.../ClusterConfigStartMemberDUnitTest.java | 5 +-
.../ClusterConfigWithSecurityDUnitTest.java | 6 +-
.../GetClusterConfigurationFunctionTest.java | 48 -
.../internal/security/MultiGfshDUnitTest.java | 10 +-
.../internal/security/ResourcePermissionTest.java | 242 +-
.../ConnectionWithOneMinuteTimeoutFactory.java | 25 +
.../memcached/DomainObjectsAsValuesJUnitTest.java | 5 +-
.../memcached/GemcachedDevelopmentJUnitTest.java | 6 +-
.../geode/memcached/IntegrationJUnitTest.java | 8 +-
.../geode/pdx/AutoSerializableJUnitTest.java | 58 +-
.../pdx/ClientsWithVersioningRetryDUnitTest.java | 7 +-
.../geode/pdx/DistributedSystemIdDUnitTest.java | 6 +-
.../geode/pdx/JSONFormatterBasicJUnitTest.java | 105 +
.../apache/geode/pdx/JSONFormatterJUnitTest.java | 297 +-
.../geode/pdx/JSONPdxClientServerDUnitTest.java | 126 +-
.../geode/pdx/PdxInstanceFactoryJUnitTest.java | 173 +-
.../org/apache/geode/pdx/PdxInstanceJUnitTest.java | 40 +-
.../pdx/PdxInstanceLoaderIntegrationTest.java | 77 +
.../apache/geode/pdx/PdxSerializableDUnitTest.java | 4 +-
.../org/apache/geode/pdx/PdxStringJUnitTest.java | 14 +-
.../geode/pdx/internal/MultipleCacheJUnitTest.java | 123 +
.../apache/geode/security/ClientAuthDUnitTest.java | 28 +-
.../security/ClientAuthorizationDUnitTest.java | 756 ----
...tAuthorizationLegacyConfigurationDUnitTest.java | 216 +
...aAuthorizationUsingLegacySecurityDUnitTest.java | 274 ++
...onUsingLegacySecurityWithFailoverDUnitTest.java | 450 ++
.../ClientExecuteFunctionAuthDUnitTest.java | 104 +-
.../ClientRegisterInterestAuthDUnitTest.java | 39 +-
.../security/ClusterConfigNotEnabledDUnitTest.java | 4 +-
.../DeltaClientAuthorizationDUnitTest.java | 11 +-
.../DeltaClientPostAuthorizationDUnitTest.java | 10 +-
.../IntegratedSecurityPeerAuthDUnitTest.java | 123 +
.../apache/geode/security/SecurityTestUtil.java | 8 +
.../generator/LdapUserCredentialGenerator.java | 20 +-
.../QuerySecurityAllowedQueriesDUnitTest.java | 32 +
.../geode/security/query/data/QueryTestObject.java | 3 +
.../security/templates/SimpleAccessController.java | 89 +
.../security/templates/SimpleAuthenticator.java | 58 +
.../org/apache/geode/test/dunit/DebuggerUtils.java | 52 -
.../apache/geode/test/dunit/IgnoredException.java | 11 +-
.../java/org/apache/geode/test/dunit/LocalVM.java | 90 +
.../test/java/org/apache/geode/test/dunit/VM.java | 114 +-
.../dunit/cache/internal/JUnit4CacheTestCase.java | 2 +-
.../apache/geode/test/dunit/rules/CacheRule.java | 50 +-
.../geode/test/dunit/rules/ClusterStartupRule.java | 273 +-
.../apache/geode/test/dunit/rules/MemberVM.java | 25 +-
...tartupRuleCanSpecifyOlderVersionsDUnitTest.java | 102 +
.../geode/test/dunit/standalone/DUnitLauncher.java | 23 +-
.../test/dunit/standalone/ProcessManager.java | 3 -
.../test/dunit/standalone/VersionManager.java | 3 +
.../java/org/apache/geode/test/fake/Fakes.java | 8 +-
.../test/junit/assertions/CommandResultAssert.java | 23 +-
.../geode/test/junit/rules/GfshCommandRule.java | 11 +-
.../geode/test/junit/rules/MemberStarterRule.java | 13 +-
.../geode/test/junit/rules/ServerStarterRule.java | 10 +
.../geode/test/process/MainLauncherJUnitTest.java | 32 +-
.../java/parReg/query/unittest/NewPortfolio.java | 2 +-
.../test/java/parReg/query/unittest/Position.java | 4 +-
.../apache/geode/codeAnalysis/excludedClasses.txt | 18 +-
.../codeAnalysis/sanctionedDataSerializables.txt | 164 +-
.../internal/cache/CacheServerWithZeroPort.xml | 24 +
.../util/PluckStacksJstackGeneratedDump.txt | 2520 +++++++++++
.../internal/deployment/ImplementsFunction.java | 17 +
geode-core/src/test/resources/ssl/trusted.keystore | Bin 2241 -> 536 bytes
.../cache/query/internal/cq/ClientCQImpl.java | 6 +-
.../geode/cache/query/cq/CQDistributedTest.java | 191 +
.../query/cq/dunit/CqDataUsingPoolDUnitTest.java | 25 +-
.../cache/query/cq/dunit/CqPerfDUnitTest.java | 86 +-
.../query/cq/dunit/CqPerfUsingPoolDUnitTest.java | 100 +-
.../cache/query/cq/dunit/CqStatsDUnitTest.java | 8 +-
.../query/cq/dunit/CqStatsUsingPoolDUnitTest.java | 8 +-
.../cache/query/dunit/QueryMonitorDUnitTest.java | 18 +-
.../geode/internal/cache/PutAllCSDUnitTest.java | 8 +-
.../tier/sockets/ClientServerMiscBCDUnitTest.java | 10 +
.../tier/sockets/ClientToServerDeltaDUnitTest.java | 32 +-
.../cli/commands/ClientCommandsTestUtils.java | 5 +-
.../commands/DescribeClientCommandDUnitTest.java | 23 +-
.../cli/commands/ListClientCommandDUnitTest.java | 12 +-
.../security/ClientAuthzObjectModDUnitTest.java | 3 -
.../geode/security/FilterPostAuthorization.java | 218 +
.../geode/security/FilterPreAuthorization.java | 144 +
.../org/apache/geode/security/ObjectWithAuthz.java | 67 +
.../persisting_configurations.html.md.erb | 14 +-
.../running/running_the_locator.html.md.erb | 2 +-
geode-docs/developing/book_intro.html.md.erb | 2 +-
...ing_durable_client_server_messaging.html.md.erb | 2 +-
.../eviction/chapter_overview.html.md.erb | 6 +-
.../eviction/configuring_data_eviction.html.md.erb | 14 +-
.../eviction/how_eviction_works.html.md.erb | 34 +-
.../expiration/chapter_overview.html.md.erb | 2 +-
.../configuring_data_expiration.html.md.erb | 38 +-
.../expiration/how_expiration_works.html.md.erb | 28 +-
.../general_region_data_management.html.md.erb | 40 +
.../chapter_overview.html.md.erb | 40 -
.../query_additional/operators.html.md.erb | 36 +-
.../query_select/the_where_clause.html.md.erb | 13 +-
.../query_grammar_and_reserved_words.html.md.erb | 58 +-
.../querying_basics/reserved_words.html.md.erb | 2 +-
.../15_minute_quickstart_gfsh.html.md.erb | 4 +-
.../system_requirements/host_machine.html.md.erb | 4 +-
geode-docs/images/ClientServerAdvancedTopics-6.gif | Bin 12056 -> 0 bytes
geode-docs/images/ClientServerAdvancedTopics-6.png | Bin 0 -> 22878 bytes
geode-docs/images/expiration.png | Bin 0 -> 79419 bytes
geode-docs/images_svg/expiration.svg | 3 -
.../managing/heap_use/heap_management.html.md.erb | 2 +-
.../management/jmx_manager_operations.html.md.erb | 2 +-
.../management/list_of_mbeans_full.html.md.erb | 16 +
.../security/authentication_overview.html.md.erb | 4 -
.../encrypting_with_diffie_hellman.html.md.erb | 66 -
geode-docs/reference/topics/cache_xml.html.md.erb | 355 +-
.../topics/chapter_overview_cache_xml.html.md.erb | 2 +-
.../reference/topics/client-cache.html.md.erb | 15 +-
.../topics/gemfire_properties.html.md.erb | 5 +-
.../gfsh/chapter_overview.html.md.erb | 4 +
.../gfsh/command-pages/alter.html.md.erb | 32 +-
.../gfsh/command-pages/create.html.md.erb | 33 +-
.../gfsh/command-pages/describe.html.md.erb | 32 +-
.../gfsh/command-pages/put.html.md.erb | 4 +-
.../gfsh/command-pages/start.html.md.erb | 57 +-
.../gfsh/configuring_gfsh.html.md.erb | 13 +
.../tools_modules/gfsh/json_in_gfsh.html.md.erb | 80 +
.../tools_modules/gfsh/tour_of_gfsh.html.md.erb | 6 +-
.../tc_additional_info.html.md.erb | 2 +-
.../tc_setting_up_the_module.html.md.erb | 2 +-
.../weblogic_setting_up_the_module.html.md.erb | 2 +-
.../how_the_pool_manages_connections.html.md.erb | 21 +-
geode-experimental-driver/build.gradle | 1 -
.../apache/geode/experimental/driver/Driver.java | 12 +
.../geode/experimental/driver/JSONWrapper.java | 61 +-
.../geode/experimental/driver/ProtobufChannel.java | 153 +
.../geode/experimental/driver/ProtobufDriver.java | 127 +-
.../experimental/driver/ProtobufQueryService.java | 104 +
.../geode/experimental/driver/ProtobufRegion.java | 140 +-
.../apache/geode/experimental/driver/Query.java | 23 +
.../geode/experimental/driver/QueryService.java | 20 +
.../apache/geode/experimental/driver/Region.java | 9 +
.../geode/experimental/driver/ValueEncoder.java | 2 +-
.../experimental/driver/DriverConnectionTest.java | 25 +-
.../experimental/driver/IntegrationTestBase.java | 74 +
.../driver/QueryServiceIntegrationTest.java | 44 +
.../experimental/driver/RegionIntegrationTest.java | 104 +-
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 +-
.../test/junit/rules/ExecutorServiceRule.java | 355 ++
.../geode/test/junit/rules/gfsh/GfshScript.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 +-
.../rules/ExecutorServiceRuleIntegrationTest.java | 131 +
.../test/junit/rules/ExecutorServiceRuleTest.java | 380 ++
.../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 +-
.../lucene/internal/DestroyLuceneIndexMessage.java | 5 +-
.../geode/cache/lucene/internal/IndexListener.java | 8 +-
.../lucene/internal/IndexRepositoryFactory.java | 77 +-
.../cache/lucene/internal/InternalLuceneIndex.java | 6 +-
.../lucene/internal/LuceneBucketListener.java | 6 +-
.../cache/lucene/internal/LuceneEventListener.java | 3 +-
.../internal/LuceneIndexForPartitionedRegion.java | 6 +-
.../cache/lucene/internal/LuceneServiceImpl.java | 60 +-
.../lucene/internal/cli/LuceneIndexCommands.java | 14 +-
.../cli/functions/LuceneCreateIndexFunction.java | 27 +-
.../cli/functions/LuceneDescribeIndexFunction.java | 3 +-
.../cli/functions/LuceneDestroyIndexFunction.java | 8 +-
.../cli/functions/LuceneListIndexFunction.java | 3 +-
.../cli/functions/LuceneSearchIndexFunction.java | 12 +-
.../internal/directory/DumpDirectoryFiles.java | 5 +-
.../internal/distributed/LuceneQueryFunction.java | 15 +-
.../distributed/WaitUntilFlushedFunction.java | 16 +-
.../lucene/internal/filesystem/FileSystem.java | 5 +-
.../internal/repository/IndexRepository.java | 4 +-
.../internal/repository/IndexResultCollector.java | 4 +-
.../internal/results/LuceneGetPageFunction.java | 16 +-
.../lucene/management/LuceneServiceMXBean.java | 6 +-
.../lucene/FlatFormatPdxSerializerJunitTest.java | 16 +-
.../lucene/LuceneClientSecurityDUnitTest.java | 5 +-
.../apache/geode/cache/lucene/LuceneDUnitTest.java | 10 +-
.../lucene/LuceneIndexCreationIntegrationTest.java | 24 +-
.../LuceneIndexMaintenanceIntegrationTest.java | 19 +-
.../cache/lucene/LuceneQueriesAccessorBase.java | 11 +-
.../geode/cache/lucene/LuceneQueriesDUnitTest.java | 109 +-
.../cache/lucene/LuceneQueriesIntegrationTest.java | 67 +-
.../LuceneQueriesReindexClientDUnitTest.java | 72 +
.../lucene/LuceneQueriesReindexDUnitTest.java | 128 +
...hRegionCreatedBeforeReindexClientDUnitTest.java | 66 +
...iesWithRegionCreatedBeforeReindexDUnitTest.java | 76 +
...hRegionCreatedBeforeReindexIntegrationTest.java | 61 +
...eriesWithReindexFlagEnabledClientDUnitTest.java | 44 +
...ceneQueriesWithReindexFlagEnabledDUnitTest.java | 51 +
...eriesWithReindexFlagEnabledIntegrationTest.java | 41 +
.../LuceneSearchWithRollingUpgradeDUnit.java | 52 +-
.../lucene/RebalanceWithRedundancyDUnitTest.java | 55 +-
.../internal/LuceneEventListenerJUnitTest.java | 15 +
.../PartitionedRepositoryManagerJUnitTest.java | 31 +-
.../internal/cli/LuceneIndexCommandsDUnitTest.java | 21 +-
.../LuceneClusterConfigurationDUnitTest.java | 83 +-
...onWhereRegionCreatedBeforeReindexDUnitTest.java | 91 +
...ClusterConfigurationWithReindexFlagEnabled.java | 58 +
.../management/LuceneManagementDUnitTest.java | 8 +-
...uceneIndexXmlGeneratorIntegrationJUnitTest.java | 27 +-
...onCreatedBeforeReindexIntegrationJUnitTest.java | 56 +
...WithReindexFlagEnabledIntegrationJUnitTest.java | 39 +
.../LuceneIndexXmlParserIntegrationJUnitTest.java | 11 +-
.../lucene/test/LuceneFunctionSecurityTest.java | 106 +
.../cache/lucene/test/LuceneTestSerializer.java | 5 +
geode-old-versions/build.gradle | 4 +-
.../src/main/proto/v1/basicTypes.proto | 16 +
.../src/main/proto/v1/clientProtocol.proto | 67 +-
.../src/main/proto/v1/connection_API.proto | 8 +
.../src/main/proto/v1/function_API.proto | 50 +
.../src/main/proto/v1/region_API.proto | 24 +
geode-protobuf/build.gradle | 1 -
.../operations/ProtobufOperationHandler.java | 34 +-
.../protobuf/statistics/ClientStatistics.java | 45 +
.../protobuf/statistics/NoOpStatistics.java | 57 +
.../statistics/ProtobufClientStatistics.java | 127 +
.../statistics/ProtobufClientStatisticsImpl.java | 115 -
.../internal/protocol/protobuf/v1/Failure.java | 78 +
.../v1/LocatorMessageExecutionContext.java | 59 +
.../protobuf/v1/MessageExecutionContext.java | 55 +
.../protobuf/v1/ProtobufCachePipeline.java | 5 +-
.../protobuf/v1/ProtobufOperationContext.java | 78 +-
.../protocol/protobuf/v1/ProtobufOpsProcessor.java | 69 +-
.../protobuf/v1/ProtobufProtocolService.java | 18 +-
.../protobuf/v1/ProtobufSerializationService.java | 24 +-
.../protobuf/v1/ProtobufStreamProcessor.java | 20 +-
.../internal/protocol/protobuf/v1/Result.java | 29 +
.../protobuf/v1/ServerMessageExecutionContext.java | 57 +
.../internal/protocol/protobuf/v1/Success.java | 48 +
.../AbstractFunctionRequestOperationHandler.java | 145 +
.../DisconnectClientRequestOperationHandler.java | 43 +
...cuteFunctionOnGroupRequestOperationHandler.java | 117 +
...uteFunctionOnMemberRequestOperationHandler.java | 120 +
...uteFunctionOnRegionRequestOperationHandler.java | 108 +
.../operations/GetAllRequestOperationHandler.java | 134 +-
.../GetRegionNamesRequestOperationHandler.java | 21 +-
.../GetRegionRequestOperationHandler.java | 18 +-
.../v1/operations/GetRequestOperationHandler.java | 48 +-
.../v1/operations/GetServerOperationHandler.java | 32 +-
.../v1/operations/KeySetOperationHandler.java | 68 +
.../OqlQueryRequestOperationHandler.java | 126 +
.../v1/operations/ProtocolVersionHandler.java | 8 +-
.../operations/PutAllRequestOperationHandler.java | 121 +-
.../v1/operations/PutRequestOperationHandler.java | 59 +-
.../operations/RemoveRequestOperationHandler.java | 53 +-
.../AuthenticationRequestOperationHandler.java | 30 +-
.../registry/ProtobufOperationContextRegistry.java | 152 +-
.../v1/serialization/JsonPdxConverter.java | 48 +
.../v1/serialization/SerializationService.java | 32 +
.../v1/serialization/SerializationType.java | 32 +
.../protobuf/v1/serialization/TypeConverter.java | 38 +
.../serialization/exception/DecodingException.java | 31 +
.../serialization/exception/EncodingException.java | 31 +
.../v1/serializer/ProtobufProtocolSerializer.java | 7 +-
.../exception/InvalidProtocolMessageException.java | 31 +
...onnectionShiroAuthenticatingStateProcessor.java | 56 -
...cySecurityProtobufConnectionStateProcessor.java | 39 +
...NoSecurityProtobufConnectionStateProcessor.java | 35 +
...obufConnectionAuthenticatingStateProcessor.java | 60 +
...rotobufConnectionAuthorizingStateProcessor.java | 72 +
.../ProtobufConnectionHandshakeStateProcessor.java | 29 +-
.../v1/state/ProtobufConnectionStateProcessor.java | 76 +
...rotobufConnectionTerminatingStateProcessor.java | 37 +
.../state/exception/ConnectionStateException.java | 32 +
.../v1/state/exception/ExceptionWithErrorCode.java | 21 +
.../exception/OperationNotAuthorizedException.java | 31 +
.../v1/utilities/ProtobufRequestUtilities.java | 38 +-
.../v1/utilities/ProtobufResponseUtilities.java | 64 -
.../protobuf/v1/utilities/ProtobufUtilities.java | 47 +-
.../GenericProtocolServerConnectionTest.java | 141 -
.../OutputCapturingServerConnectionTest.java | 94 +
.../tier/sockets/ProtobufServerConnectionTest.java | 141 +
.../internal/protocol/TestExecutionContext.java | 15 +-
.../protobuf/v1/AuthenticationIntegrationTest.java | 90 +-
.../protobuf/v1/AuthorizationIntegrationTest.java | 269 +-
.../v1/DisconnectClientIntegrationTest.java | 137 +
.../protocol/protobuf/v1/ErrorCodesJUnitTest.java | 45 -
.../v1/ExecuteFunctionOnGroupIntegrationTest.java | 332 ++
.../v1/ExecuteFunctionOnMemberIntegrationTest.java | 332 ++
.../v1/ExecuteFunctionOnRegionIntegrationTest.java | 357 ++
.../internal/protocol/protobuf/v1/MessageUtil.java | 21 +-
.../v1/ProtobufProtocolServiceJUnitTest.java | 6 +-
.../v1/acceptance/CacheConnectionJUnitTest.java | 22 +-
.../CacheConnectionTimeoutJUnitTest.java | 8 -
.../v1/acceptance/CacheMaxConnectionJUnitTest.java | 12 +-
.../v1/acceptance/CacheOperationsJUnitTest.java | 109 +-
.../LocatorConnectionAuthenticationDUnitTest.java | 36 +-
.../v1/acceptance/LocatorConnectionDUnitTest.java | 45 +-
...ionOnGroupRequestOperationHandlerJUnitTest.java | 201 +
...onOnMemberRequestOperationHandlerJUnitTest.java | 189 +
...onOnRegionRequestOperationHandlerJUnitTest.java | 161 +
.../GetAllRequestOperationHandlerJUnitTest.java | 52 +-
.../GetAndPutJsonDocumentsDUnitTest.java | 10 +-
...egionNamesRequestOperationHandlerJUnitTest.java | 10 +-
.../GetRegionRequestOperationHandlerJUnitTest.java | 15 +-
.../GetRequestOperationHandlerJUnitTest.java | 28 +-
.../GetServerOperationHandlerJUnitTest.java | 78 +-
.../KeySetOperationHandlerJUnitTest.java | 81 +
.../v1/operations/OperationHandlerJUnitTest.java | 9 +-
...ueryRequestOperationHandlerIntegrationTest.java | 164 +
.../OqlQueryRequestOperationHandlerJUnitTest.java | 138 +
.../ProtocolVersionHandlerJUnitTest.java | 6 +-
.../PutAllRequestOperationHandlerJUnitTest.java | 55 +-
.../PutRequestOperationHandlerJUnitTest.java | 39 +-
.../RemoveRequestOperationHandlerJUnitTest.java | 27 +-
.../codec/JsonPdxConverterJUnitTest.java | 2 +-
.../ProtobufProtocolSerializerJUnitTest.java | 5 +-
.../v1/utilities/ProtobufUtilitiesJUnitTest.java | 21 +-
geode-pulse/build.gradle | 2 +
geode-pulse/src/main/webapp/META-INF/NOTICE | 8 +-
.../geode/tools/pulse/tests/rules/ServerRule.java | 2 +-
.../org/apache/geode/cache/util/AutoBalancer.java | 50 +-
.../util/AutoBalancerIntegrationJUnitTest.java | 21 +-
.../geode/cache/util/AutoBalancerJUnitTest.java | 14 +-
.../client/internal/GatewaySenderBatchOp.java | 5 +-
.../internal/cache/wan/GatewayReceiverImpl.java | 11 +
.../cache/wan/WANRollingUpgradeDUnitTest.java | 112 +-
.../cache/wan/AckReaderThreadJUnitTest.java | 6 -
.../cache/wan/CacheClientNotifierDUnitTest.java | 5 +-
.../GatewayLegacyAuthenticationRegressionTest.java | 420 ++
.../cache/wan/GatewayReceiverImplJUnitTest.java | 56 +
.../cache/wan/GatewayReceiverMBeanDUnitTest.java | 118 +
.../geode/internal/cache/wan/WANTestBase.java | 25 +-
.../ConcurrentParallelGatewaySenderDUnitTest.java | 76 +-
.../GatewayLegacyAuthenticationRegressionTest.java | 423 --
.../cache/wan/misc/PDXNewWanDUnitTest.java | 200 +-
.../cache/wan/misc/WANConfigurationJUnitTest.java | 10 +-
.../cache/wan/serial/GatewayReceiverDUnitTest.java | 144 +
.../DestroyGatewaySenderCommandDUnitTest.java | 106 +
.../cache/wan/wancommand/WANCommandUtils.java | 3 +-
geode-web-api/build.gradle | 1 +
.../web/controllers/AbstractBaseController.java | 6 +-
.../web/controllers/BaseControllerAdvice.java | 15 +
.../web/controllers/FunctionAccessController.java | 37 +-
.../CustomMappingJackson2HttpMessageConverter.java | 4 +-
.../internal/web/security/RestSecurityService.java | 13 +
geode-web-api/src/main/webapp/META-INF/NOTICE | 8 +-
geode-web/src/main/webapp/META-INF/NOTICE | 4 +-
.../cli/commands/AlterRuntimeCommandDUnitTest.java | 8 +-
.../cli/commands/ConnectCommandWithSSLTest.java | 53 +-
.../commands/DescribeConfigCommandDUnitTest.java | 6 +-
...xecuteFunctionCommandWithSecurityDUnitTest.java | 5 +-
.../cli/commands/ExportConfigCommandDUnitTest.java | 15 +-
.../commands/ExportLogsStatsOverHttpDUnitTest.java | 4 +-
.../FunctionCommandsOverHttpDUnitTest.java | 5 +-
.../cli/commands/QueryCommandOverHttpTest.java | 30 +
.../commands/ShutdownCommandOverHttpDUnitTest.java | 31 +
.../support/LoginHandlerInterceptorJUnitTest.java | 16 +-
gradle.properties | 4 +-
gradle/dependency-versions.properties | 56 +-
gradle/publish.gradle | 6 +-
gradle/spotless.gradle | 75 +
gradle/test.gradle | 28 +-
settings.gradle | 2 -
2347 files changed, 86293 insertions(+), 74106 deletions(-)
--
To stop receiving notification emails like this one, please contact
sbawaskar@apache.org.