You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by sa...@apache.org on 2017/01/06 23:44:34 UTC
[5/9] geode git commit: Merge branch 'release/1.0.0-incubating.M3'
Merge branch 'release/1.0.0-incubating.M3'
Project: http://git-wip-us.apache.org/repos/asf/geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/geode/commit/2e107524
Tree: http://git-wip-us.apache.org/repos/asf/geode/tree/2e107524
Diff: http://git-wip-us.apache.org/repos/asf/geode/diff/2e107524
Branch: refs/heads/feature/GEODE-523
Commit: 2e1075246a5c95dcd087fe497bae0df323acfdbd
Parents: a745ce9 83f97ce
Author: Anthony Baker <ab...@apache.org>
Authored: Mon Aug 22 09:38:09 2016 -0700
Committer: Anthony Baker <ab...@apache.org>
Committed: Mon Aug 22 09:38:09 2016 -0700
----------------------------------------------------------------------
BUILDING.md | 2 +-
KEYS | 185 +
LICENSE | 62 +-
build.gradle | 4 +
.../apache/geode/gradle/PasswordDialog.groovy | 41 +
etc/eclipseFormatterProfile.xml | 560 +-
etc/eclipseOrganizeImports.importorder | 7 +
etc/intellijIdeaCodeStyle.xml | 426 +-
extensions/geode-modules-assembly/build.gradle | 52 +-
.../release/conf/cache-client.xml | 14 +-
.../release/conf/cache-server.xml | 6 +-
.../release/scripts/cacheserver.bat | 133 -
.../release/scripts/cacheserver.sh | 97 -
.../release/scripts/gemfire.bat | 41 -
.../release/scripts/gemfire.sh | 58 -
.../release/scripts/setenv.properties | 1 +
.../release/session/bin/cacheserver.bat | 56 -
.../release/session/bin/cacheserver.sh | 57 -
.../release/session/bin/gemfire.bat | 53 -
.../release/session/bin/gemfire.sh | 69 -
.../release/session/bin/modify_war | 91 +-
.../release/session/bin/setenv.properties | 6 -
.../gemfire-cs-tomcat-7/context-fragment.xml | 15 -
.../tcserver/gemfire-cs-tomcat-7/modules.env | 1 -
.../gemfire-cs-tomcat-8/context-fragment.xml | 15 -
.../tcserver/gemfire-cs-tomcat-8/modules.env | 1 -
.../gemfire-cs/configuration-prompts.properties | 17 -
.../tcserver/gemfire-cs/context-fragment.xml | 13 -
.../release/tcserver/gemfire-cs/modules.env | 1 -
.../tcserver/gemfire-cs/server-fragment.xml | 12 -
.../gemfire-p2p-tomcat-7/context-fragment.xml | 15 -
.../tcserver/gemfire-p2p-tomcat-7/modules.env | 1 -
.../gemfire-p2p-tomcat-8/context-fragment.xml | 15 -
.../tcserver/gemfire-p2p-tomcat-8/modules.env | 1 -
.../configuration-prompts.properties | 19 -
.../tcserver/gemfire-p2p/context-fragment.xml | 13 -
.../release/tcserver/gemfire-p2p/modules.env | 1 -
.../tcserver/gemfire-p2p/server-fragment.xml | 14 -
.../geode-cs-tomcat-7/context-fragment.xml | 15 +
.../geode-cs-tomcat-8/context-fragment.xml | 15 +
.../geode-cs/configuration-prompts.properties | 17 +
.../tcserver/geode-cs/context-fragment.xml | 13 +
.../tcserver/geode-cs/server-fragment.xml | 12 +
.../geode-p2p-tomcat-7/context-fragment.xml | 15 +
.../geode-p2p-tomcat-8/context-fragment.xml | 15 +
.../geode-p2p/configuration-prompts.properties | 19 +
.../tcserver/geode-p2p/context-fragment.xml | 13 +
.../tcserver/geode-p2p/server-fragment.xml | 14 +
.../modules/hibernate/GemFireCacheProvider.java | 8 +-
.../modules/hibernate/GemFireRegionFactory.java | 56 +-
.../ClientServerRegionFactoryDelegate.java | 23 +-
.../internal/RegionFactoryDelegate.java | 25 +-
.../gemfire/modules/HibernateJUnitTest.java | 116 +-
.../gemstone/gemfire/modules/SecondVMTest.java | 30 +-
.../geode-modules-session-internal/build.gradle | 25 +
.../internal/common/AbstractSessionCache.java | 102 +
.../session/internal/common/CacheProperty.java | 65 +
.../common/ClientServerSessionCache.java | 186 +
.../internal/common/PeerToPeerSessionCache.java | 184 +
.../session/internal/common/SessionCache.java | 68 +
.../common/SessionExpirationCacheListener.java | 53 +
.../session/internal/filter/Constants.java | 30 +
.../internal/filter/DummySessionManager.java | 132 +
.../internal/filter/GemfireHttpSession.java | 527 ++
.../filter/GemfireSessionException.java | 41 +
.../internal/filter/GemfireSessionManager.java | 512 ++
.../internal/filter/ListenerEventType.java | 75 +
.../session/internal/filter/SessionManager.java | 110 +
.../AbstractDeltaSessionAttributes.java | 107 +
.../attributes/AbstractSessionAttributes.java | 188 +
.../internal/filter/attributes/DeltaEvent.java | 119 +
.../DeltaQueuedSessionAttributes.java | 94 +
.../attributes/DeltaSessionAttributes.java | 75 +
.../attributes/ImmediateSessionAttributes.java | 68 +
.../attributes/QueuedSessionAttributes.java | 65 +
.../filter/attributes/SessionAttributes.java | 120 +
.../filter/util/NamedThreadFactory.java | 68 +
.../filter/util/ThreadLocalSession.java | 39 +
.../internal/filter/util/TypeAwareMap.java | 50 +
.../session/internal/jmx/SessionStatistics.java | 78 +
.../internal/jmx/SessionStatisticsMXBean.java | 30 +
extensions/geode-modules-session/build.gradle | 18 +-
.../session/filter/SessionCachingFilter.java | 19 +-
.../session/installer/JarClassLoader.java | 1 +
.../internal/common/AbstractSessionCache.java | 102 -
.../session/internal/common/CacheProperty.java | 65 -
.../common/ClientServerSessionCache.java | 186 -
.../internal/common/PeerToPeerSessionCache.java | 184 -
.../session/internal/common/SessionCache.java | 68 -
.../common/SessionExpirationCacheListener.java | 53 -
.../session/internal/filter/Constants.java | 30 -
.../internal/filter/DummySessionManager.java | 132 -
.../internal/filter/GemfireHttpSession.java | 526 --
.../filter/GemfireSessionException.java | 41 -
.../internal/filter/GemfireSessionManager.java | 511 --
.../internal/filter/ListenerEventType.java | 75 -
.../session/internal/filter/SessionManager.java | 110 -
.../AbstractDeltaSessionAttributes.java | 107 -
.../attributes/AbstractSessionAttributes.java | 188 -
.../internal/filter/attributes/DeltaEvent.java | 119 -
.../DeltaQueuedSessionAttributes.java | 94 -
.../attributes/DeltaSessionAttributes.java | 75 -
.../attributes/ImmediateSessionAttributes.java | 68 -
.../attributes/QueuedSessionAttributes.java | 65 -
.../filter/attributes/SessionAttributes.java | 120 -
.../filter/util/NamedThreadFactory.java | 68 -
.../filter/util/ThreadLocalSession.java | 39 -
.../internal/filter/util/TypeAwareMap.java | 50 -
.../session/internal/jmx/SessionStatistics.java | 78 -
.../internal/jmx/SessionStatisticsMXBean.java | 30 -
.../session/internal/filter/CommonTests.java | 16 +-
.../SessionReplicationIntegrationJUnitTest.java | 80 +-
.../filter/SessionReplicationJUnitTest.java | 3 +-
.../SessionReplicationLocalCacheJUnitTest.java | 5 +-
.../session/junit/PerTestClassLoaderRunner.java | 138 +-
.../junit/SeparateClassloaderTestRunner.java | 56 -
extensions/geode-modules-tomcat7/build.gradle | 6 +
.../session/Tomcat7SessionsJUnitTest.java | 2 -
.../session/bootstrap/AbstractCache.java | 24 +-
.../gemstone/gemfire/modules/util/Banner.java | 20 +-
.../modules/util/CreateRegionFunction.java | 36 +-
.../modules/util/RegionConfiguration.java | 2 +-
.../modules/session/TestSessionsBase.java | 66 +-
.../session/Tomcat6SessionsJUnitTest.java | 2 -
geode-assembly/build.gradle | 56 +-
geode-assembly/src/main/dist/LICENSE | 11 +-
geode-assembly/src/main/dist/NOTICE | 71 +-
geode-assembly/src/main/dist/bin/gfsh.bat | 33 +-
.../gemstone/gemfire/BundledJarsJUnitTest.java | 4 +-
.../LocatorLauncherAssemblyIntegrationTest.java | 161 +
.../LocatorLauncherAssemblyJUnitTest.java | 156 -
.../LauncherLifecycleCommandsDUnitTest.java | 106 +-
...auncherLifecycleCommandsIntegrationTest.java | 165 +
.../LauncherLifecycleCommandsJUnitTest.java | 189 +-
.../SharedConfigurationEndToEndDUnitTest.java | 314 +-
.../internal/web/RestInterfaceJUnitTest.java | 57 +-
.../rest/internal/web/controllers/Customer.java | 2 +-
.../rest/internal/web/controllers/Gender.java | 2 +-
.../internal/web/controllers/GetAllEntries.java | 2 +-
.../web/controllers/GetDeliveredOrders.java | 2 +-
.../internal/web/controllers/GetRegions.java | 2 +-
.../rest/internal/web/controllers/Item.java | 2 +-
.../rest/internal/web/controllers/Order.java | 2 +-
.../rest/internal/web/controllers/Person.java | 2 +-
...stAPIOnRegionFunctionExecutionDUnitTest.java | 97 +-
.../web/controllers/RestAPITestBase.java | 90 +-
.../RestAPIsAndInterOpsDUnitTest.java | 493 +-
...tAPIsOnGroupsFunctionExecutionDUnitTest.java | 29 +-
...APIsOnMembersFunctionExecutionDUnitTest.java | 55 +-
.../RestAPIsQueryAndFEJUnitTest.java | 289 +-
.../controllers/RestAPIsWithSSLDUnitTest.java | 605 +--
.../internal/web/controllers/RestTestUtils.java | 2 +-
.../src/test/resources/expected_jars.txt | 5 +-
.../annotations/ExperimentalJUnitTest.java | 1 -
geode-core/build.gradle | 105 +-
.../com/gemstone/gemfire/CancelCriterion.java | 15 +-
.../com/gemstone/gemfire/CancelException.java | 2 +-
.../gemstone/gemfire/CanonicalInstantiator.java | 4 +-
.../com/gemstone/gemfire/CopyException.java | 2 +-
.../java/com/gemstone/gemfire/CopyHelper.java | 6 +-
.../com/gemstone/gemfire/DataSerializable.java | 2 +-
.../com/gemstone/gemfire/DataSerializer.java | 86 +-
.../main/java/com/gemstone/gemfire/Delta.java | 2 +-
.../gemfire/DeltaSerializationException.java | 2 +-
.../gemfire/ForcedDisconnectException.java | 2 +-
.../gemfire/GemFireCheckedException.java | 2 +-
.../gemstone/gemfire/GemFireRethrowable.java | 2 +-
.../java/com/gemstone/gemfire/Instantiator.java | 2 +-
.../gemstone/gemfire/InternalGemFireError.java | 2 +-
.../gemstone/gemfire/InvalidDeltaException.java | 2 +-
.../gemfire/SerializationException.java | 2 +-
.../gemstone/gemfire/StatisticDescriptor.java | 2 +-
.../java/com/gemstone/gemfire/Statistics.java | 245 +-
.../com/gemstone/gemfire/StatisticsFactory.java | 2 +-
.../com/gemstone/gemfire/StatisticsType.java | 2 +-
.../gemstone/gemfire/StatisticsTypeFactory.java | 2 +-
.../com/gemstone/gemfire/SystemFailure.java | 15 +-
.../com/gemstone/gemfire/ToDataException.java | 2 +-
.../gemfire/admin/AdminDistributedSystem.java | 34 +-
.../admin/AdminDistributedSystemFactory.java | 9 +-
.../gemstone/gemfire/admin/AdminException.java | 2 +-
.../gemfire/admin/AdminXmlException.java | 2 +-
.../java/com/gemstone/gemfire/admin/Alert.java | 2 +-
.../com/gemstone/gemfire/admin/AlertLevel.java | 2 +-
.../gemstone/gemfire/admin/BackupStatus.java | 2 +-
.../admin/CacheDoesNotExistException.java | 2 +-
.../gemfire/admin/CacheHealthConfig.java | 2 +-
.../com/gemstone/gemfire/admin/CacheServer.java | 4 +-
.../gemfire/admin/CacheServerConfig.java | 2 +-
.../com/gemstone/gemfire/admin/CacheVm.java | 2 +-
.../gemstone/gemfire/admin/CacheVmConfig.java | 2 +-
.../gemfire/admin/ConfigurationParameter.java | 2 +-
.../gemfire/admin/DistributedSystemConfig.java | 163 +-
.../admin/DistributedSystemHealthConfig.java | 2 +-
.../gemfire/admin/DistributionLocator.java | 4 +-
.../admin/DistributionLocatorConfig.java | 6 +-
.../gemstone/gemfire/admin/GemFireHealth.java | 2 +-
.../gemfire/admin/GemFireHealthConfig.java | 2 +-
.../gemfire/admin/GemFireMemberStatus.java | 23 +-
.../gemstone/gemfire/admin/ManagedEntity.java | 2 +-
.../gemfire/admin/ManagedEntityConfig.java | 2 +-
.../gemfire/admin/MemberHealthConfig.java | 2 +-
.../admin/OperationCancelledException.java | 2 +-
.../gemfire/admin/RegionNotFoundException.java | 2 +-
.../gemfire/admin/RegionSubRegionSnapshot.java | 2 +-
.../gemfire/admin/RuntimeAdminException.java | 2 +-
.../com/gemstone/gemfire/admin/Statistic.java | 2 +-
.../gemfire/admin/StatisticResource.java | 4 +-
.../gemstone/gemfire/admin/SystemMember.java | 8 +-
.../gemfire/admin/SystemMemberBridgeServer.java | 46 +-
.../gemfire/admin/SystemMemberCache.java | 12 +-
.../gemfire/admin/SystemMemberCacheEvent.java | 2 +-
.../admin/SystemMemberCacheListener.java | 2 +-
.../gemfire/admin/SystemMemberCacheServer.java | 46 +-
.../gemfire/admin/SystemMemberRegion.java | 12 +-
.../gemfire/admin/SystemMemberRegionEvent.java | 2 +-
.../gemfire/admin/SystemMemberType.java | 2 +-
.../gemfire/admin/SystemMembershipEvent.java | 4 +-
.../gemfire/admin/SystemMembershipListener.java | 4 +-
.../UnmodifiableConfigurationException.java | 2 +-
.../admin/internal/AbstractHealthEvaluator.java | 2 +-
.../internal/AdminDistributedSystemImpl.java | 89 +-
.../admin/internal/CacheHealthConfigImpl.java | 2 +-
.../admin/internal/CacheHealthEvaluator.java | 2 +-
.../admin/internal/CacheServerConfigImpl.java | 7 +-
.../gemfire/admin/internal/CacheServerImpl.java | 9 +-
.../internal/ConfigurationParameterImpl.java | 2 +-
.../ConfigurationParameterListener.java | 2 +-
.../internal/DistributedSystemConfigImpl.java | 521 +-
.../DistributedSystemHealthConfigImpl.java | 2 +-
.../DistributedSystemHealthEvaluator.java | 13 +-
.../DistributedSystemHealthMonitor.java | 2 +-
.../internal/DistributionLocatorConfigImpl.java | 7 +-
.../admin/internal/DistributionLocatorImpl.java | 134 +-
.../EnabledManagedEntityController.java | 25 +-
.../admin/internal/GemFireHealthConfigImpl.java | 2 +-
.../admin/internal/GemFireHealthEvaluator.java | 2 +-
.../admin/internal/GemFireHealthImpl.java | 2 +-
.../gemfire/admin/internal/InetAddressUtil.java | 2 +-
.../admin/internal/InternalManagedEntity.java | 2 +-
.../admin/internal/ManagedEntityConfigImpl.java | 2 +-
.../admin/internal/ManagedEntityConfigXml.java | 9 +-
.../ManagedEntityConfigXmlGenerator.java | 2 +-
.../internal/ManagedEntityConfigXmlParser.java | 2 +-
.../admin/internal/ManagedSystemMemberImpl.java | 7 +-
.../admin/internal/MemberHealthConfigImpl.java | 2 +-
.../admin/internal/MemberHealthEvaluator.java | 2 +-
.../gemfire/admin/internal/StatisticImpl.java | 2 +-
.../admin/internal/StatisticResourceImpl.java | 2 +-
.../internal/SystemMemberBridgeServerImpl.java | 2 +-
.../internal/SystemMemberCacheEventImpl.java | 2 +-
.../SystemMemberCacheEventProcessor.java | 2 +-
.../admin/internal/SystemMemberCacheImpl.java | 2 +-
.../admin/internal/SystemMemberImpl.java | 30 +-
.../internal/SystemMemberRegionEventImpl.java | 2 +-
.../admin/internal/SystemMemberRegionImpl.java | 4 +-
.../internal/SystemMembershipEventImpl.java | 4 +-
.../com/gemstone/gemfire/admin/jmx/Agent.java | 2 +-
.../gemstone/gemfire/admin/jmx/AgentConfig.java | 14 +-
.../gemfire/admin/jmx/AgentFactory.java | 2 +-
.../internal/AdminDistributedSystemJmxImpl.java | 126 +-
.../admin/jmx/internal/AgentConfigImpl.java | 578 ++-
.../gemfire/admin/jmx/internal/AgentImpl.java | 8 +-
.../admin/jmx/internal/AgentLauncher.java | 2 +-
.../admin/jmx/internal/CacheServerJmxImpl.java | 2 +-
.../admin/jmx/internal/ConfigAttributeInfo.java | 2 +-
.../internal/ConfigurationParameterJmxImpl.java | 2 +-
.../DistributedSystemHealthConfigJmxImpl.java | 2 +-
.../admin/jmx/internal/DynamicManagedBean.java | 4 +-
.../internal/GemFireHealthConfigJmxImpl.java | 2 +-
.../jmx/internal/GemFireHealthJmxImpl.java | 2 +-
.../admin/jmx/internal/GenerateMBeanHTML.java | 2 +-
.../gemfire/admin/jmx/internal/MBeanUtil.java | 2 +-
.../jmx/internal/MX4JServerSocketFactory.java | 13 +-
.../gemfire/admin/jmx/internal/MailManager.java | 2 +-
.../admin/jmx/internal/ManagedResource.java | 2 +-
.../admin/jmx/internal/ManagedResourceType.java | 2 +-
.../jmx/internal/MemberInfoWithStatsMBean.java | 142 +-
.../jmx/internal/RefreshNotificationType.java | 2 +-
.../jmx/internal/StatAlertNotification.java | 2 +-
.../jmx/internal/StatisticAttributeInfo.java | 2 +-
.../jmx/internal/StatisticResourceJmxImpl.java | 2 +-
.../SystemMemberBridgeServerJmxImpl.java | 2 +-
.../jmx/internal/SystemMemberCacheJmxImpl.java | 8 +-
.../admin/jmx/internal/SystemMemberJmx.java | 55 +-
.../admin/jmx/internal/SystemMemberJmxImpl.java | 4 +-
.../jmx/internal/SystemMemberRegionJmxImpl.java | 2 +-
.../gemfire/cache/AttributesFactory.java | 119 +-
.../gemfire/cache/AttributesMutator.java | 27 +-
.../java/com/gemstone/gemfire/cache/Cache.java | 48 +-
.../gemstone/gemfire/cache/CacheCallback.java | 2 +-
.../gemfire/cache/CacheClosedException.java | 2 +-
.../com/gemstone/gemfire/cache/CacheEvent.java | 8 +-
.../gemstone/gemfire/cache/CacheException.java | 2 +-
.../gemfire/cache/CacheExistsException.java | 4 +-
.../gemstone/gemfire/cache/CacheFactory.java | 29 +-
.../gemstone/gemfire/cache/CacheListener.java | 8 +-
.../com/gemstone/gemfire/cache/CacheLoader.java | 2 +-
.../gemfire/cache/CacheLoaderException.java | 2 +-
.../gemfire/cache/CacheRuntimeException.java | 2 +-
.../gemstone/gemfire/cache/CacheStatistics.java | 2 +-
.../gemfire/cache/CacheTransactionManager.java | 38 +-
.../com/gemstone/gemfire/cache/CacheWriter.java | 2 +-
.../gemfire/cache/CacheWriterException.java | 2 +-
.../gemfire/cache/CacheXmlException.java | 2 +-
.../gemstone/gemfire/cache/ClientSession.java | 10 +-
.../gemfire/cache/CommitConflictException.java | 4 +-
.../cache/CommitDistributionException.java | 2 +-
.../cache/CommitIncompleteException.java | 2 +-
.../gemfire/cache/CustomEvictionAttributes.java | 78 -
.../com/gemstone/gemfire/cache/DataPolicy.java | 21 +-
.../com/gemstone/gemfire/cache/Declarable.java | 2 +-
.../gemfire/cache/DiskAccessException.java | 12 +-
.../com/gemstone/gemfire/cache/DiskStore.java | 8 +-
.../gemfire/cache/DiskStoreFactory.java | 10 +-
.../gemfire/cache/DiskWriteAttributes.java | 2 +-
.../cache/DiskWriteAttributesFactory.java | 4 +-
.../DuplicatePrimaryPartitionException.java | 2 +-
.../gemfire/cache/DynamicRegionFactory.java | 5 +-
.../gemfire/cache/DynamicRegionListener.java | 2 +-
.../gemfire/cache/EntryDestroyedException.java | 2 +-
.../com/gemstone/gemfire/cache/EntryEvent.java | 14 +-
.../gemfire/cache/EntryExistsException.java | 4 +-
.../gemfire/cache/EntryNotFoundException.java | 2 +-
.../gemstone/gemfire/cache/EntryOperation.java | 6 +-
.../gemstone/gemfire/cache/EvictionAction.java | 4 +-
.../gemfire/cache/EvictionAlgorithm.java | 4 +-
.../gemfire/cache/EvictionAttributes.java | 12 +-
.../cache/EvictionAttributesMutator.java | 2 +-
.../gemfire/cache/EvictionCriteria.java | 57 -
.../gemfire/cache/ExpirationAction.java | 2 +-
.../gemfire/cache/ExpirationAttributes.java | 2 +-
.../cache/FailedSynchronizationException.java | 2 +-
.../gemfire/cache/FixedPartitionAttributes.java | 2 +-
.../gemfire/cache/FixedPartitionResolver.java | 2 +-
.../cache/GatewayConfigurationException.java | 2 +-
.../gemfire/cache/GatewayException.java | 2 +-
.../gemstone/gemfire/cache/GemFireCache.java | 38 +-
.../cache/IncompatibleVersionException.java | 2 +-
.../gemstone/gemfire/cache/InterestPolicy.java | 2 +-
.../cache/InterestRegistrationEvent.java | 2 +-
.../cache/InterestRegistrationListener.java | 2 +-
.../gemfire/cache/InterestResultPolicy.java | 4 +-
.../gemstone/gemfire/cache/LoaderHelper.java | 2 +-
.../gemfire/cache/LowMemoryException.java | 2 +-
.../com/gemstone/gemfire/cache/MirrorType.java | 4 +-
.../cache/NoQueueServersAvailableException.java | 2 +-
...NoSubscriptionServersAvailableException.java | 2 +-
.../com/gemstone/gemfire/cache/Operation.java | 27 +-
.../cache/OperationAbortedException.java | 2 +-
.../gemfire/cache/PartitionAttributes.java | 14 +-
.../cache/PartitionAttributesFactory.java | 10 +-
.../gemfire/cache/PartitionResolver.java | 19 +-
.../PartitionedRegionDistributionException.java | 2 +-
.../PartitionedRegionStorageException.java | 2 +-
.../java/com/gemstone/gemfire/cache/Region.java | 88 +-
.../gemfire/cache/RegionAttributes.java | 71 +-
.../gemfire/cache/RegionDestroyedException.java | 2 +-
.../com/gemstone/gemfire/cache/RegionEvent.java | 2 +-
.../gemfire/cache/RegionExistsException.java | 2 +-
.../gemstone/gemfire/cache/RegionFactory.java | 64 +-
.../gemfire/cache/RegionMembershipListener.java | 2 +-
.../cache/RegionReinitializedException.java | 2 +-
.../gemstone/gemfire/cache/RegionService.java | 6 +-
.../gemstone/gemfire/cache/RegionShortcut.java | 2 +-
.../cache/RemoteTransactionException.java | 2 +-
.../gemfire/cache/ResourceException.java | 2 +-
.../java/com/gemstone/gemfire/cache/Scope.java | 2 +-
.../gemfire/cache/SerializedCacheValue.java | 2 +-
.../cache/StatisticsDisabledException.java | 2 +-
.../gemfire/cache/SubscriptionAttributes.java | 2 +-
.../SynchronizationCommitConflictException.java | 2 +-
.../gemfire/cache/TimeoutException.java | 2 +-
...TransactionDataNodeHasDepartedException.java | 2 +-
.../TransactionDataNotColocatedException.java | 2 +-
.../TransactionDataRebalancedException.java | 2 +-
.../gemfire/cache/TransactionEvent.java | 4 +-
.../gemfire/cache/TransactionException.java | 2 +-
.../gemstone/gemfire/cache/TransactionId.java | 2 +-
.../cache/TransactionInDoubtException.java | 2 +-
.../gemfire/cache/TransactionListener.java | 2 +-
.../gemfire/cache/TransactionWriter.java | 2 +-
.../cache/TransactionWriterException.java | 2 +-
...upportedOperationInTransactionException.java | 2 +-
.../cache/UnsupportedVersionException.java | 2 +-
.../gemfire/cache/VersionException.java | 2 +-
.../gemfire/cache/asyncqueue/AsyncEvent.java | 2 +-
.../cache/asyncqueue/AsyncEventListener.java | 2 +-
.../cache/asyncqueue/AsyncEventQueue.java | 11 +-
.../asyncqueue/AsyncEventQueueFactory.java | 11 +-
.../internal/AsyncEventQueueFactoryImpl.java | 13 +-
.../internal/AsyncEventQueueImpl.java | 7 +-
.../internal/ParallelAsyncEventQueueImpl.java | 4 +-
.../client/AllConnectionsInUseException.java | 2 +-
.../gemfire/cache/client/ClientCache.java | 6 +-
.../cache/client/ClientCacheFactory.java | 490 +-
.../cache/client/ClientNotReadyException.java | 2 +-
.../cache/client/ClientRegionFactory.java | 9 +-
.../cache/client/ClientRegionShortcut.java | 2 +-
.../client/NoAvailableLocatorsException.java | 2 +-
.../client/NoAvailableServersException.java | 2 +-
.../com/gemstone/gemfire/cache/client/Pool.java | 8 +-
.../gemfire/cache/client/PoolFactory.java | 10 +-
.../gemfire/cache/client/PoolManager.java | 2 +-
.../client/ServerConnectivityException.java | 2 +-
.../cache/client/ServerOperationException.java | 2 +-
.../ServerRefusedConnectionException.java | 2 +-
.../client/SubscriptionNotEnabledException.java | 2 +-
.../cache/client/internal/AbstractOp.java | 4 +-
.../cache/client/internal/AddPDXEnumOp.java | 2 +-
.../cache/client/internal/AddPDXTypeOp.java | 2 +-
.../client/internal/AuthenticateUserOp.java | 19 +-
.../internal/AutoConnectionSourceImpl.java | 4 +-
.../client/internal/CacheServerLoadMessage.java | 2 +-
.../gemfire/cache/client/internal/ClearOp.java | 2 +-
.../client/internal/ClientMetadataService.java | 63 +-
.../client/internal/ClientPartitionAdvisor.java | 2 +-
.../internal/ClientRegionFactoryImpl.java | 2 +-
.../client/internal/CloseConnectionOp.java | 28 +-
.../gemfire/cache/client/internal/CommitOp.java | 2 +-
.../cache/client/internal/Connection.java | 2 +-
.../client/internal/ConnectionFactory.java | 2 +-
.../client/internal/ConnectionFactoryImpl.java | 16 +-
.../cache/client/internal/ConnectionImpl.java | 17 +-
.../cache/client/internal/ConnectionSource.java | 2 +-
.../cache/client/internal/ConnectionStats.java | 2 +-
.../cache/client/internal/ContainsKeyOp.java | 2 +-
.../DataSerializerRecoveryListener.java | 33 +-
.../cache/client/internal/DestroyOp.java | 2 +-
.../cache/client/internal/DestroyRegionOp.java | 2 +-
.../gemfire/cache/client/internal/Endpoint.java | 2 +-
.../client/internal/EndpointManagerImpl.java | 6 +-
.../cache/client/internal/ExecutablePool.java | 16 +-
.../client/internal/ExecuteFunctionNoAckOp.java | 2 +-
.../client/internal/ExecuteFunctionOp.java | 2 +-
.../internal/ExecuteRegionFunctionNoAckOp.java | 2 +-
.../internal/ExecuteRegionFunctionOp.java | 2 +-
.../ExecuteRegionFunctionSingleHopOp.java | 2 +-
.../internal/ExplicitConnectionSourceImpl.java | 19 +-
.../gemfire/cache/client/internal/GetAllOp.java | 2 +-
.../client/internal/GetClientPRMetaDataOp.java | 2 +-
.../GetClientPartitionAttributesOp.java | 2 +-
.../cache/client/internal/GetEventValueOp.java | 2 +-
.../gemfire/cache/client/internal/GetOp.java | 2 +-
.../cache/client/internal/GetPDXEnumByIdOp.java | 2 +-
.../cache/client/internal/GetPDXEnumsOp.java | 2 +-
.../client/internal/GetPDXIdForEnumOp.java | 2 +-
.../client/internal/GetPDXIdForTypeOp.java | 2 +-
.../cache/client/internal/GetPDXTypeByIdOp.java | 2 +-
.../cache/client/internal/GetPDXTypesOp.java | 2 +-
.../internal/InstantiatorRecoveryListener.java | 2 +-
.../cache/client/internal/InternalPool.java | 2 +-
.../cache/client/internal/InvalidateOp.java | 2 +-
.../gemfire/cache/client/internal/KeySetOp.java | 2 +-
.../cache/client/internal/LiveServerPinger.java | 2 +-
.../internal/LocatorDiscoveryCallback.java | 2 +-
.../LocatorDiscoveryCallbackAdapter.java | 2 +-
.../cache/client/internal/MakePrimaryOp.java | 2 +-
.../gemfire/cache/client/internal/Op.java | 2 +-
.../cache/client/internal/OpExecutorImpl.java | 47 +-
.../gemfire/cache/client/internal/PingOp.java | 2 +-
.../gemfire/cache/client/internal/PoolImpl.java | 86 +-
.../cache/client/internal/PrimaryAckOp.java | 2 +-
.../cache/client/internal/ProxyCache.java | 2 +-
.../cache/client/internal/ProxyRegion.java | 2 +-
.../gemfire/cache/client/internal/PutAllOp.java | 2 +-
.../gemfire/cache/client/internal/PutOp.java | 6 +-
.../gemfire/cache/client/internal/QueryOp.java | 2 +-
.../cache/client/internal/QueueManager.java | 2 +-
.../cache/client/internal/QueueManagerImpl.java | 2 +-
.../cache/client/internal/QueueStateImpl.java | 6 +-
.../cache/client/internal/ReadyForEventsOp.java | 2 +-
.../internal/RegisterInstantiatorsOp.java | 2 +-
.../client/internal/RegisterInterestListOp.java | 2 +-
.../client/internal/RegisterInterestOp.java | 2 +-
.../internal/RegisterInterestTracker.java | 6 +-
.../cache/client/internal/RemoveAllOp.java | 2 +-
.../cache/client/internal/RollbackOp.java | 2 +-
.../cache/client/internal/ServerBlackList.java | 20 +-
.../cache/client/internal/ServerProxy.java | 2 +-
.../client/internal/ServerRegionProxy.java | 5 +-
.../gemfire/cache/client/internal/SizeOp.java | 2 +-
.../cache/client/internal/TXFailoverOp.java | 2 +-
.../internal/UnregisterInterestListOp.java | 2 +-
.../client/internal/UnregisterInterestOp.java | 2 +-
.../internal/locator/LocatorStatusRequest.java | 2 +-
.../internal/locator/LocatorStatusResponse.java | 2 +-
.../locator/wan/LocatorMembershipListener.java | 6 +-
.../internal/pooling/ConnectionManager.java | 2 +-
.../internal/pooling/ConnectionManagerImpl.java | 44 +-
.../internal/pooling/PooledConnection.java | 2 +-
.../gemfire/cache/control/RebalanceFactory.java | 6 +-
.../cache/control/RebalanceOperation.java | 2 +-
.../gemfire/cache/control/RebalanceResults.java | 2 +-
.../gemfire/cache/control/ResourceManager.java | 18 +-
.../execute/EmptyRegionFunctionException.java | 63 +
.../execute/EmtpyRegionFunctionException.java | 63 -
.../gemfire/cache/execute/Execution.java | 18 +-
.../gemfire/cache/execute/Function.java | 31 +-
.../gemfire/cache/execute/FunctionAdapter.java | 89 +-
.../gemfire/cache/execute/FunctionContext.java | 10 +-
.../cache/execute/FunctionException.java | 16 +-
.../FunctionInvocationTargetException.java | 6 +-
.../gemfire/cache/execute/FunctionService.java | 36 +-
.../cache/execute/RegionFunctionContext.java | 6 +-
.../gemfire/cache/execute/ResultCollector.java | 12 +-
.../gemfire/cache/execute/ResultSender.java | 4 +-
.../internal/FunctionServiceManager.java | 57 +-
.../gemfire/cache/hdfs/HDFSIOException.java | 52 -
.../gemstone/gemfire/cache/hdfs/HDFSStore.java | 341 --
.../gemfire/cache/hdfs/HDFSStoreFactory.java | 203 -
.../gemfire/cache/hdfs/HDFSStoreMutator.java | 196 -
.../cache/hdfs/StoreExistsException.java | 32 -
.../cache/hdfs/internal/FailureTracker.java | 96 -
.../cache/hdfs/internal/FlushObserver.java | 53 -
.../hdfs/internal/HDFSBucketRegionQueue.java | 1232 -----
.../cache/hdfs/internal/HDFSEntriesSet.java | 329 --
.../cache/hdfs/internal/HDFSEventListener.java | 179 -
.../hdfs/internal/HDFSEventQueueFilter.java | 73 -
.../hdfs/internal/HDFSGatewayEventImpl.java | 180 -
.../hdfs/internal/HDFSIntegrationUtil.java | 117 -
.../HDFSParallelGatewaySenderQueue.java | 471 --
.../hdfs/internal/HDFSStoreConfigHolder.java | 559 --
.../cache/hdfs/internal/HDFSStoreCreation.java | 198 -
.../hdfs/internal/HDFSStoreFactoryImpl.java | 77 -
.../cache/hdfs/internal/HDFSStoreImpl.java | 638 ---
.../hdfs/internal/HDFSStoreMutatorImpl.java | 200 -
.../HDFSWriteOnlyStoreEventListener.java | 184 -
.../hdfs/internal/HoplogListenerForRegion.java | 72 -
.../cache/hdfs/internal/PersistedEventImpl.java | 202 -
.../hdfs/internal/QueuedPersistentEvent.java | 27 -
.../hdfs/internal/SignalledFlushObserver.java | 122 -
.../internal/SortedHDFSQueuePersistedEvent.java | 86 -
.../internal/SortedHoplogPersistedEvent.java | 114 -
.../UnsortedHDFSQueuePersistedEvent.java | 76 -
.../internal/UnsortedHoplogPersistedEvent.java | 92 -
.../hdfs/internal/hoplog/AbstractHoplog.java | 357 --
.../hoplog/AbstractHoplogOrganizer.java | 430 --
.../cache/hdfs/internal/hoplog/BloomFilter.java | 36 -
.../hoplog/CloseTmpHoplogsTimerTask.java | 108 -
.../hdfs/internal/hoplog/CompactionStatus.java | 72 -
.../cache/hdfs/internal/hoplog/FlushStatus.java | 72 -
.../internal/hoplog/HDFSCompactionManager.java | 330 --
.../internal/hoplog/HDFSFlushQueueArgs.java | 93 -
.../internal/hoplog/HDFSFlushQueueFunction.java | 287 --
.../hoplog/HDFSForceCompactionArgs.java | 107 -
.../hoplog/HDFSForceCompactionFunction.java | 129 -
.../HDFSForceCompactionResultCollector.java | 131 -
.../hoplog/HDFSLastCompactionTimeFunction.java | 56 -
.../internal/hoplog/HDFSRegionDirector.java | 480 --
.../hdfs/internal/hoplog/HDFSStoreDirector.java | 78 -
.../hoplog/HDFSUnsortedHoplogOrganizer.java | 447 --
.../hdfs/internal/hoplog/HFileSortedOplog.java | 853 ----
.../hoplog/HdfsSortedOplogOrganizer.java | 2004 --------
.../cache/hdfs/internal/hoplog/Hoplog.java | 263 -
.../hdfs/internal/hoplog/HoplogConfig.java | 74 -
.../hdfs/internal/hoplog/HoplogListener.java | 47 -
.../hdfs/internal/hoplog/HoplogOrganizer.java | 123 -
.../hdfs/internal/hoplog/HoplogSetIterator.java | 166 -
.../hdfs/internal/hoplog/HoplogSetReader.java | 114 -
.../internal/hoplog/SequenceFileHoplog.java | 395 --
.../hoplog/mapred/AbstractGFRecordReader.java | 106 -
.../internal/hoplog/mapred/GFInputFormat.java | 95 -
.../internal/hoplog/mapred/GFOutputFormat.java | 75 -
.../mapreduce/AbstractGFRecordReader.java | 140 -
.../hoplog/mapreduce/GFInputFormat.java | 124 -
.../hdfs/internal/hoplog/mapreduce/GFKey.java | 72 -
.../hoplog/mapreduce/GFOutputFormat.java | 198 -
.../hoplog/mapreduce/HDFSSplitIterator.java | 197 -
.../internal/hoplog/mapreduce/HoplogUtil.java | 463 --
.../hoplog/mapreduce/RWSplitIterator.java | 48 -
.../hoplog/mapreduce/StreamSplitIterator.java | 46 -
.../org/apache/hadoop/io/SequenceFile.java | 3726 --------------
.../operations/CloseCQOperationContext.java | 2 +-
.../operations/DestroyOperationContext.java | 2 +-
.../operations/ExecuteCQOperationContext.java | 2 +-
.../ExecuteFunctionOperationContext.java | 2 +-
.../GetDurableCQsOperationContext.java | 2 +-
.../cache/operations/GetOperationContext.java | 2 +-
.../operations/InterestOperationContext.java | 6 +-
.../gemfire/cache/operations/InterestType.java | 2 +-
.../operations/InvalidateOperationContext.java | 2 +-
.../cache/operations/KeyOperationContext.java | 2 +-
.../operations/KeySetOperationContext.java | 2 +-
.../operations/KeyValueOperationContext.java | 12 +-
.../cache/operations/OperationContext.java | 542 +-
.../operations/PutAllOperationContext.java | 6 +-
.../cache/operations/PutOperationContext.java | 8 +-
.../cache/operations/QueryOperationContext.java | 2 +-
.../operations/RegionClearOperationContext.java | 2 +-
.../RegionCreateOperationContext.java | 2 +-
.../RegionDestroyOperationContext.java | 2 +-
.../operations/RegionOperationContext.java | 2 +-
.../RegisterInterestOperationContext.java | 2 +-
.../operations/RemoveAllOperationContext.java | 2 +-
.../operations/StopCQOperationContext.java | 2 +-
.../UnregisterInterestOperationContext.java | 2 +-
.../internal/GetOperationContextImpl.java | 2 +-
.../cache/partition/PartitionListener.java | 10 +-
.../partition/PartitionListenerAdapter.java | 2 +-
.../cache/partition/PartitionMemberInfo.java | 2 +-
.../PartitionNotAvailableException.java | 2 +-
.../cache/partition/PartitionRebalanceInfo.java | 2 +-
.../cache/partition/PartitionRegionHelper.java | 32 +-
.../cache/partition/PartitionRegionInfo.java | 2 +-
.../ConflictingPersistentDataException.java | 2 +-
.../persistence/PartitionOfflineException.java | 2 +-
.../gemfire/cache/persistence/PersistentID.java | 4 +-
.../PersistentReplicatesOfflineException.java | 2 +-
.../persistence/RevokeFailedException.java | 2 +-
.../RevokedPersistentDataException.java | 2 +-
.../cache/query/AmbiguousNameException.java | 2 +-
.../gemfire/cache/query/CqAttributes.java | 2 +-
.../cache/query/CqAttributesFactory.java | 2 +-
.../cache/query/CqAttributesMutator.java | 2 +-
.../gemfire/cache/query/CqClosedException.java | 2 +-
.../gemstone/gemfire/cache/query/CqEvent.java | 4 +-
.../gemfire/cache/query/CqException.java | 2 +-
.../gemfire/cache/query/CqExistsException.java | 2 +-
.../gemfire/cache/query/CqListener.java | 2 +-
.../gemstone/gemfire/cache/query/CqQuery.java | 4 +-
.../gemstone/gemfire/cache/query/CqResults.java | 2 +-
.../cache/query/CqServiceStatistics.java | 2 +-
.../gemstone/gemfire/cache/query/CqState.java | 2 +-
.../gemfire/cache/query/CqStatistics.java | 2 +-
.../gemfire/cache/query/CqStatusListener.java | 2 +-
.../cache/query/FunctionDomainException.java | 2 +-
.../com/gemstone/gemfire/cache/query/Index.java | 2 +-
.../cache/query/IndexExistsException.java | 2 +-
.../cache/query/IndexInvalidException.java | 2 +-
.../cache/query/IndexMaintenanceException.java | 2 +-
.../cache/query/IndexNameConflictException.java | 2 +-
.../gemfire/cache/query/IndexStatistics.java | 2 +-
.../gemstone/gemfire/cache/query/IndexType.java | 2 +-
.../query/MultiIndexCreationException.java | 2 +-
.../cache/query/NameNotFoundException.java | 2 +-
.../cache/query/NameResolutionException.java | 2 +-
.../query/ParameterCountInvalidException.java | 2 +-
.../com/gemstone/gemfire/cache/query/Query.java | 6 +-
.../gemfire/cache/query/QueryException.java | 2 +-
.../query/QueryExecutionLowMemoryException.java | 2 +-
.../query/QueryExecutionTimeoutException.java | 2 +-
.../cache/query/QueryInvalidException.java | 2 +-
.../query/QueryInvocationTargetException.java | 2 +-
.../gemfire/cache/query/QueryService.java | 30 +-
.../gemfire/cache/query/QueryStatistics.java | 2 +-
.../cache/query/RegionNotFoundException.java | 2 +-
.../gemfire/cache/query/SelectResults.java | 4 +-
.../gemstone/gemfire/cache/query/Struct.java | 2 +-
.../cache/query/TypeMismatchException.java | 2 +-
.../internal/AbstractGroupOrRangeJunction.java | 19 +-
.../gemfire/cache/query/internal/Bag.java | 2 +-
.../cache/query/internal/CompiledIn.java | 39 +-
.../cache/query/internal/CompiledLike.java | 2 +-
.../cache/query/internal/CompiledSelect.java | 2 +-
.../cache/query/internal/CompiledValue.java | 9 +-
.../gemfire/cache/query/internal/CqEntry.java | 2 +-
.../cache/query/internal/CqQueryVsdStats.java | 2 +-
.../cache/query/internal/CqStateImpl.java | 2 +-
.../cache/query/internal/DefaultQuery.java | 40 +-
.../query/internal/DefaultQueryService.java | 53 +-
.../cache/query/internal/HashingStrategy.java | 2 +-
.../cache/query/internal/IndexUpdater.java | 123 -
.../gemfire/cache/query/internal/NullToken.java | 2 +-
.../gemfire/cache/query/internal/PlanInfo.java | 2 +-
.../cache/query/internal/ProxyQueryService.java | 2 +-
.../gemfire/cache/query/internal/QRegion.java | 2 +-
.../QueryExecutionCanceledException.java | 2 +-
.../query/internal/QueryExecutionContext.java | 2 +-
.../cache/query/internal/QueryExecutor.java | 2 +-
.../cache/query/internal/QueryMonitor.java | 2 +-
.../ResultsCollectionCopyOnReadWrapper.java | 2 +-
.../internal/ResultsCollectionWrapper.java | 2 +-
.../cache/query/internal/ResultsSet.java | 2 +-
.../cache/query/internal/SortedResultSet.java | 2 +-
.../cache/query/internal/SortedStructSet.java | 2 +-
.../gemfire/cache/query/internal/StructBag.java | 2 +-
.../cache/query/internal/StructImpl.java | 2 +-
.../gemfire/cache/query/internal/StructSet.java | 4 +-
.../query/internal/cq/CqServiceProvider.java | 11 +-
.../query/internal/index/AbstractIndex.java | 41 +-
.../query/internal/index/CompactRangeIndex.java | 2 +-
.../query/internal/index/DummyQRegion.java | 3 -
.../cache/query/internal/index/HashIndex.java | 1 -
.../internal/index/IndexConcurrentHashSet.java | 2 +-
.../query/internal/index/IndexElemArray.java | 2 +-
.../query/internal/index/IndexManager.java | 79 +-
.../cache/query/internal/index/IndexStats.java | 6 +-
.../cache/query/internal/index/IndexStore.java | 6 +-
.../query/internal/index/MemoryIndexStore.java | 2 +-
.../query/internal/index/PartitionedIndex.java | 2 +-
.../cache/query/internal/parse/ASTHint.java | 2 +-
.../query/internal/parse/ASTHintIdentifier.java | 2 +-
.../cache/query/internal/parse/ASTTrace.java | 2 +-
.../internal/types/CollectionTypeImpl.java | 2 +-
.../cache/query/internal/types/MapTypeImpl.java | 2 +-
.../query/internal/types/ObjectTypeImpl.java | 2 +-
.../query/internal/types/StructTypeImpl.java | 2 +-
.../cache/query/types/CollectionType.java | 2 +-
.../gemfire/cache/query/types/MapType.java | 2 +-
.../gemfire/cache/query/types/ObjectType.java | 2 +-
.../gemfire/cache/query/types/StructType.java | 2 +-
.../gemfire/cache/server/CacheServer.java | 62 +-
.../cache/server/ClientSubscriptionConfig.java | 18 +-
.../gemfire/cache/server/ServerLoad.java | 2 +-
.../gemfire/cache/server/ServerLoadProbe.java | 2 +-
.../cache/server/ServerLoadProbeAdapter.java | 2 +-
.../gemfire/cache/server/ServerMetrics.java | 2 +-
.../server/internal/ConnectionCountProbe.java | 2 +-
.../cache/server/internal/LoadMonitor.java | 4 +-
.../server/internal/ServerMetricsImpl.java | 2 +-
.../cache/snapshot/CacheSnapshotService.java | 2 +-
.../cache/snapshot/RegionSnapshotService.java | 2 +-
.../gemfire/cache/snapshot/SnapshotFilter.java | 2 +-
.../cache/snapshot/SnapshotIterator.java | 2 +-
.../gemfire/cache/snapshot/SnapshotOptions.java | 4 +-
.../gemfire/cache/snapshot/SnapshotReader.java | 2 +-
.../cache/util/BoundedLinkedHashMap.java | 88 -
.../cache/util/CacheListenerAdapter.java | 2 +-
.../gemfire/cache/util/CacheWriterAdapter.java | 2 +-
.../gemfire/cache/util/CqListenerAdapter.java | 2 +-
.../gemstone/gemfire/cache/util/Gateway.java | 4 +-
.../cache/util/GatewayConflictHelper.java | 2 +-
.../cache/util/GatewayConflictResolver.java | 2 +-
.../gemfire/cache/util/GatewayEvent.java | 4 +-
.../gemfire/cache/util/ObjectSizer.java | 8 +-
.../util/RegionMembershipListenerAdapter.java | 2 +-
.../cache/util/TimestampedEntryEvent.java | 2 +-
.../cache/util/TransactionListenerAdapter.java | 2 +-
.../gemfire/cache/wan/GatewayEventFilter.java | 2 +-
.../gemfire/cache/wan/GatewayQueueEvent.java | 2 +-
.../gemfire/cache/wan/GatewayReceiver.java | 9 +-
.../cache/wan/GatewayReceiverFactory.java | 4 +-
.../gemfire/cache/wan/GatewaySender.java | 41 +-
.../gemfire/cache/wan/GatewaySenderFactory.java | 2 +-
.../gemfire/compression/SnappyCompressor.java | 48 +-
.../gemfire/distributed/AbstractLauncher.java | 48 +-
.../distributed/ClientSocketFactory.java | 2 +-
.../distributed/ConfigurationProperties.java | 1599 ++++++
.../gemfire/distributed/DistributedMember.java | 5 +-
.../gemfire/distributed/DistributedSystem.java | 1487 +-----
.../DistributedSystemDisconnectedException.java | 2 +-
.../distributed/FutureCancelledException.java | 2 +-
.../distributed/GatewayCancelledException.java | 4 +-
.../gemstone/gemfire/distributed/Locator.java | 49 +-
.../gemfire/distributed/LocatorLauncher.java | 70 +-
.../distributed/LockNotHeldException.java | 2 +-
.../LockServiceDestroyedException.java | 2 +-
.../distributed/OplogCancelledException.java | 4 +-
.../distributed/PoolCancelledException.java | 4 +-
.../gemfire/distributed/ServerLauncher.java | 83 +-
.../TXManagerCancelledException.java | 2 +-
.../internal/AbstractDistributionConfig.java | 467 +-
.../internal/AtomicLongWithTerminalState.java | 2 +-
.../gemfire/distributed/internal/CacheTime.java | 29 +
.../distributed/internal/ConfigAttribute.java | 1 -
.../internal/ConfigAttributeChecker.java | 1 -
.../internal/ConfigAttributeDesc.java | 3 -
.../internal/ConfigAttributeGetter.java | 3 -
.../internal/ConfigAttributeSetter.java | 3 -
.../distributed/internal/ConflationKey.java | 2 +-
.../gemfire/distributed/internal/DM.java | 34 +-
.../gemfire/distributed/internal/DMStats.java | 120 +-
.../gemfire/distributed/internal/DSClock.java | 22 +-
.../internal/DistributionAdvisee.java | 2 +-
.../internal/DistributionAdvisor.java | 69 +-
.../internal/DistributionChannel.java | 2 +-
.../internal/DistributionConfig.java | 4806 +++++++++---------
.../internal/DistributionConfigImpl.java | 684 +--
.../internal/DistributionManager.java | 116 +-
.../internal/DistributionMessage.java | 14 +-
.../distributed/internal/DistributionStats.java | 28 +-
.../distributed/internal/FlowControlParams.java | 2 +-
.../FunctionExecutionPooledExecutor.java | 18 +-
.../distributed/internal/HealthMonitor.java | 2 +-
.../distributed/internal/HealthMonitorImpl.java | 2 +-
.../internal/HighPriorityAckedMessage.java | 2 +-
.../internal/InternalDistributedSystem.java | 449 +-
.../distributed/internal/InternalLocator.java | 146 +-
.../internal/LocatorLoadSnapshot.java | 2 +-
.../distributed/internal/LocatorStats.java | 50 +-
.../internal/LonerDistributionManager.java | 32 +-
.../distributed/internal/MessageWithReply.java | 2 +-
.../distributed/internal/PoolStatHelper.java | 2 +-
.../internal/PooledExecutorWithDMStats.java | 23 +-
.../distributed/internal/ProductUseLog.java | 2 +-
.../distributed/internal/QueueStatHelper.java | 2 +-
.../internal/ReliableReplyProcessor21.java | 2 +-
.../distributed/internal/ReplyException.java | 6 +-
.../distributed/internal/ReplyProcessor21.java | 34 +-
.../distributed/internal/ResourceEvent.java | 4 +-
.../internal/RuntimeDistributionConfigImpl.java | 40 +-
.../distributed/internal/ServerLocator.java | 46 +-
.../internal/SharedConfiguration.java | 534 +-
.../gemfire/distributed/internal/Sizeable.java | 2 +-
.../distributed/internal/SizeableRunnable.java | 2 +-
.../distributed/internal/StartupMessage.java | 36 +-
.../internal/StartupMessageData.java | 2 +-
.../StartupResponseWithVersionMessage.java | 2 +-
.../internal/ThrottledMemQueueStatHelper.java | 2 +-
.../internal/ThrottledQueueStatHelper.java | 2 +-
.../ThrottlingMemLinkedQueueWithDMStats.java | 2 +-
.../internal/WanLocatorDiscoverer.java | 4 +
.../internal/direct/DirectChannel.java | 57 +-
.../internal/locks/Collaboration.java | 6 +-
.../internal/locks/DLockGrantor.java | 107 +-
.../internal/locks/DLockService.java | 75 +-
.../distributed/internal/locks/DLockStats.java | 6 +-
.../internal/locks/DeposeGrantorProcessor.java | 2 +-
.../internal/locks/DistributedMemberLock.java | 2 +-
.../internal/locks/ElderInitProcessor.java | 2 +-
.../distributed/internal/locks/ElderState.java | 2 +-
.../distributed/internal/locks/GrantorInfo.java | 2 +-
.../internal/locks/GrantorRequestProcessor.java | 8 +-
.../locks/LockGrantorDestroyedException.java | 2 +-
.../internal/locks/LockGrantorId.java | 5 +-
.../locks/NonGrantorDestroyedProcessor.java | 2 +-
.../membership/InternalDistributedMember.java | 104 +-
.../internal/membership/MemberAttributes.java | 2 +-
.../internal/membership/MemberFactory.java | 6 +-
.../internal/membership/MemberServices.java | 7 +-
.../internal/membership/MembershipManager.java | 6 +-
.../internal/membership/NetMember.java | 8 +-
.../internal/membership/NetView.java | 12 +-
.../internal/membership/gms/GMSMember.java | 54 +-
.../membership/gms/GMSMemberFactory.java | 14 +-
.../internal/membership/gms/ServiceConfig.java | 33 +-
.../internal/membership/gms/Services.java | 39 +-
.../membership/gms/auth/GMSAuthenticator.java | 109 +-
.../membership/gms/fd/GMSHealthMonitor.java | 122 +-
.../gms/interfaces/Authenticator.java | 6 +-
.../membership/gms/locator/GMSLocator.java | 2 +-
.../membership/gms/membership/GMSJoinLeave.java | 296 +-
.../gms/messages/HeartbeatRequestMessage.java | 8 +
.../membership/gms/messenger/JGAddress.java | 24 +-
.../gms/messenger/JGroupsMessenger.java | 112 +-
.../membership/gms/messenger/StatRecorder.java | 30 +-
.../membership/gms/messenger/Transport.java | 4 +-
.../gms/mgr/GMSMembershipManager.java | 207 +-
.../internal/tcpserver/InfoRequest.java | 2 +-
.../internal/tcpserver/InfoResponse.java | 2 +-
.../internal/tcpserver/ShutdownRequest.java | 2 +-
.../internal/tcpserver/ShutdownResponse.java | 2 +-
.../internal/tcpserver/TcpClient.java | 8 +-
.../internal/tcpserver/TcpHandler.java | 2 +-
.../internal/tcpserver/TcpServer.java | 104 +-
.../internal/tcpserver/VersionRequest.java | 2 +-
.../internal/tcpserver/VersionResponse.java | 2 +-
.../unsafe/RegisterSignalHandlerSupport.java | 2 +-
.../gemstone/gemfire/i18n/LogWriterI18n.java | 60 +-
.../com/gemstone/gemfire/i18n/StringId.java | 2 +-
.../gemfire/internal/AbstractConfig.java | 17 +-
.../internal/AbstractStatisticsFactory.java | 67 +-
.../com/gemstone/gemfire/internal/Assert.java | 5 +-
.../gemfire/internal/AvailablePort.java | 23 +-
.../com/gemstone/gemfire/internal/Banner.java | 255 +-
.../gemfire/internal/ByteArrayDataInput.java | 2 +-
.../internal/ByteBufferOutputStream.java | 2 +-
.../gemfire/internal/ClassPathLoader.java | 42 +-
.../com/gemstone/gemfire/internal/Config.java | 36 +-
.../gemstone/gemfire/internal/ConfigSource.java | 2 +-
.../com/gemstone/gemfire/internal/DSCODE.java | 78 +-
.../gemstone/gemfire/internal/DSFIDFactory.java | 192 +-
.../internal/DataSerializableFixedID.java | 61 +-
.../gemfire/internal/DistributionLocator.java | 22 +-
.../gemfire/internal/DummyStatisticsImpl.java | 46 +-
.../gemfire/internal/ExternalizableDSFID.java | 2 +-
.../com/gemstone/gemfire/internal/FileUtil.java | 14 +-
.../gemfire/internal/GemFireStatSampler.java | 16 +-
.../gemfire/internal/GemFireUtilLauncher.java | 165 -
.../gemfire/internal/GemFireVersion.java | 4 +-
.../internal/GfeConsoleReaderFactory.java | 2 +-
.../gemfire/internal/HeapDataOutputStream.java | 34 +-
.../gemfire/internal/HostStatHelper.java | 2 +-
.../gemfire/internal/HostStatSampler.java | 48 +-
.../InsufficientDiskSpaceException.java | 53 -
.../internal/InternalDataSerializer.java | 146 +-
.../gemfire/internal/InternalEntity.java | 2 +-
.../gemfire/internal/InternalInstantiator.java | 4 +-
.../InternalStatisticsDisabledException.java | 2 +-
.../gemfire/internal/JarClassLoader.java | 4 +-
.../gemfire/internal/LinuxProcFsStatistics.java | 17 +-
.../gemfire/internal/LinuxProcessStats.java | 2 +-
.../gemfire/internal/LocalStatisticsImpl.java | 2 +-
.../gemfire/internal/MigrationClient.java | 24 +-
.../gemfire/internal/MigrationServer.java | 32 +-
.../gemfire/internal/NullDataOutputStream.java | 2 +-
.../gemstone/gemfire/internal/OSProcess.java | 41 +-
.../gemfire/internal/OSXProcessStats.java | 2 +-
.../gemfire/internal/ObjIdConcurrentMap.java | 4 +-
.../internal/ObjToByteArraySerializer.java | 2 +-
.../gemfire/internal/OneTaskOnlyExecutor.java | 2 +-
.../gemfire/internal/OsStatisticsFactory.java | 2 +-
.../gemstone/gemfire/internal/ProcessStats.java | 2 +-
.../gemstone/gemfire/internal/PureJavaMode.java | 8 +-
.../com/gemstone/gemfire/internal/Sendable.java | 2 +-
.../com/gemstone/gemfire/internal/SetUtils.java | 2 +-
.../gemfire/internal/SharedLibrary.java | 5 +-
.../gemfire/internal/SocketCreator.java | 156 +-
.../gemfire/internal/SocketIOWithTimeout.java | 491 --
.../gemfire/internal/SocketInputStream.java | 181 -
.../gemfire/internal/SocketInputWrapper.java | 93 -
.../gemfire/internal/SocketOutputStream.java | 174 -
.../gemstone/gemfire/internal/SocketUtils.java | 220 -
.../gemfire/internal/SolarisProcessStats.java | 2 +-
.../gemfire/internal/StatArchiveWriter.java | 31 +-
.../gemfire/internal/StatSamplerStats.java | 34 +-
.../internal/StatisticDescriptorImpl.java | 2 +-
.../gemfire/internal/StatisticsImpl.java | 147 +-
.../internal/StatisticsTypeFactoryImpl.java | 2 +-
.../gemfire/internal/StatisticsTypeImpl.java | 8 +-
.../gemstone/gemfire/internal/SystemAdmin.java | 93 +-
.../gemfire/internal/SystemFailureTestHook.java | 2 +-
.../gemfire/internal/UniqueIdGenerator.java | 2 +-
.../com/gemstone/gemfire/internal/Version.java | 23 +-
.../internal/VersionedDataInputStream.java | 2 +-
.../internal/VersionedDataOutputStream.java | 2 +-
.../gemfire/internal/VersionedDataStream.java | 7 +-
.../gemfire/internal/VersionedObjectInput.java | 2 +-
.../gemfire/internal/VersionedObjectOutput.java | 2 +-
.../gemfire/internal/WindowsProcessStats.java | 2 +-
.../internal/admin/AdminBridgeServer.java | 2 +-
.../gemstone/gemfire/internal/admin/Alert.java | 2 +-
.../gemfire/internal/admin/CacheInfo.java | 6 +-
.../internal/admin/ClientStatsManager.java | 3 +-
.../gemfire/internal/admin/GemFireVM.java | 34 +-
.../gemfire/internal/admin/GfManagerAgent.java | 6 +-
.../gemfire/internal/admin/HealthListener.java | 2 +-
.../gemfire/internal/admin/SSLConfig.java | 12 +-
.../internal/admin/StatAlertsManager.java | 4 +-
.../admin/remote/AddHealthListenerRequest.java | 2 +-
.../admin/remote/AddHealthListenerResponse.java | 2 +-
.../remote/AdminConsoleDisconnectMessage.java | 2 +-
.../admin/remote/AdminReplyProcessor.java | 2 +-
.../admin/remote/AlertLevelChangeMessage.java | 2 +-
.../admin/remote/AlertsNotificationMessage.java | 2 +-
.../admin/remote/BridgeServerRequest.java | 2 +-
.../admin/remote/BridgeServerResponse.java | 2 +-
.../admin/remote/CacheConfigRequest.java | 2 +-
.../admin/remote/CacheConfigResponse.java | 4 +-
.../internal/admin/remote/CacheInfoRequest.java | 2 +-
.../admin/remote/CacheInfoResponse.java | 2 +-
.../remote/ChangeRefreshIntervalMessage.java | 2 +-
.../admin/remote/DistributionLocatorId.java | 18 +-
.../admin/remote/DurableClientInfoRequest.java | 2 +-
.../admin/remote/DurableClientInfoResponse.java | 2 +-
.../remote/FetchHealthDiagnosisRequest.java | 2 +-
.../remote/FetchHealthDiagnosisResponse.java | 2 +-
.../admin/remote/FetchHostResponse.java | 24 +-
.../admin/remote/HealthListenerMessage.java | 2 +-
.../internal/admin/remote/RegionRequest.java | 2 +-
.../internal/admin/remote/RegionResponse.java | 2 +-
.../internal/admin/remote/RemoteAlert.java | 2 +-
.../admin/remote/RemoteBridgeServer.java | 8 +-
.../internal/admin/remote/RemoteCacheInfo.java | 18 +-
.../internal/admin/remote/RemoteGemFireVM.java | 4 +-
.../admin/remote/RemoteGfManagerAgent.java | 47 +-
.../admin/remote/RemoteRegionAttributes.java | 25 -
.../admin/remote/RemoteTransportConfig.java | 33 +-
.../remote/RemoveHealthListenerRequest.java | 2 +-
.../remote/RemoveHealthListenerResponse.java | 2 +-
.../admin/remote/ResetHealthStatusRequest.java | 2 +-
.../admin/remote/ResetHealthStatusResponse.java | 2 +-
.../admin/remote/RootRegionResponse.java | 29 +-
.../remote/ShutdownAllGatewayHubsRequest.java | 2 +-
.../admin/remote/ShutdownAllRequest.java | 30 +-
.../remote/StatAlertsManagerAssignMessage.java | 2 +-
.../internal/admin/remote/TailLogResponse.java | 18 +-
.../admin/remote/VersionInfoRequest.java | 2 +-
.../admin/remote/VersionInfoResponse.java | 2 +-
.../admin/remote/VersionMismatchAlert.java | 2 +-
.../cache/AbstractBucketRegionQueue.java | 51 +-
.../internal/cache/AbstractCacheServer.java | 31 +-
.../cache/AbstractDiskLRURegionEntry.java | 2 +-
.../internal/cache/AbstractDiskRegion.java | 4 +-
.../internal/cache/AbstractDiskRegionEntry.java | 5 -
.../internal/cache/AbstractLRURegionEntry.java | 2 +-
.../internal/cache/AbstractLRURegionMap.java | 21 +-
.../cache/AbstractOplogDiskRegionEntry.java | 2 +-
.../gemfire/internal/cache/AbstractRegion.java | 249 +-
.../internal/cache/AbstractRegionEntry.java | 127 +-
.../internal/cache/AbstractRegionMap.java | 500 +-
.../internal/cache/AbstractUpdateOperation.java | 2 +-
.../gemfire/internal/cache/BucketAdvisor.java | 50 +-
.../gemfire/internal/cache/BucketRegion.java | 347 +-
.../internal/cache/BucketRegionEvictior.java | 2 +-
.../internal/cache/BucketRegionQueue.java | 23 +-
.../internal/cache/BucketServerLocation.java | 2 +-
.../internal/cache/BucketServerLocation66.java | 2 +-
.../cache/BytesAndBitsForCompactor.java | 2 +-
.../internal/cache/CacheClientStatus.java | 2 +-
.../gemfire/internal/cache/CacheConfig.java | 2 +-
.../cache/CacheDistributionAdvisee.java | 2 +-
.../cache/CacheDistributionAdvisor.java | 90 +-
.../gemfire/internal/cache/CachePerfStats.java | 91 +-
.../internal/cache/CacheServerAdvisor.java | 2 +-
.../gemfire/internal/cache/CacheServerImpl.java | 73 +-
.../internal/cache/CacheServerLauncher.java | 77 +-
.../gemfire/internal/cache/CacheService.java | 7 +
.../internal/cache/CacheServiceProfile.java | 40 +
.../internal/cache/CachedDeserializable.java | 4 +-
.../cache/CachedDeserializableFactory.java | 20 +-
.../internal/cache/ClientRegionEventImpl.java | 2 +-
.../internal/cache/ClientServerObserver.java | 2 +-
.../cache/ClientServerObserverAdapter.java | 2 +-
.../cache/ClientServerObserverHolder.java | 2 +-
.../cache/ClientSubscriptionConfigImpl.java | 16 +-
.../cache/ClusterConfigurationLoader.java | 23 +-
.../internal/cache/ColocationHelper.java | 104 +-
.../internal/cache/CommitReplyException.java | 2 +-
.../internal/cache/CompactableOplog.java | 2 +-
.../gemfire/internal/cache/Conflatable.java | 2 +-
.../internal/cache/ControllerAdvisor.java | 19 +-
.../internal/cache/CountingDataInputStream.java | 2 +-
.../internal/cache/CreateRegionProcessor.java | 23 +-
.../internal/cache/CustomEntryExpiryTask.java | 2 +-
.../cache/CustomEvictionAttributesImpl.java | 35 -
.../internal/cache/DestroyOperation.java | 9 +-
.../cache/DestroyPartitionedRegionMessage.java | 4 +-
.../gemfire/internal/cache/DirectoryHolder.java | 2 +-
.../internal/cache/DiskDirectoryStats.java | 2 +-
.../gemfire/internal/cache/DiskEntry.java | 253 +-
.../gemstone/gemfire/internal/cache/DiskId.java | 22 +-
.../gemfire/internal/cache/DiskInitFile.java | 40 +-
.../gemfire/internal/cache/DiskRegion.java | 16 +-
.../gemfire/internal/cache/DiskRegionStats.java | 2 +-
.../internal/cache/DiskStoreAttributes.java | 2 +-
.../internal/cache/DiskStoreFactoryImpl.java | 2 +-
.../gemfire/internal/cache/DiskStoreImpl.java | 160 +-
.../internal/cache/DiskStoreMonitor.java | 31 +-
.../gemfire/internal/cache/DiskStoreStats.java | 2 +-
.../internal/cache/DiskWriteAttributesImpl.java | 106 +-
.../internal/cache/DistPeerTXStateStub.java | 2 +
.../gemfire/internal/cache/DistTXState.java | 15 +-
.../cache/DistTXStateOnCoordinator.java | 4 +-
.../DistTXStateProxyImplOnCoordinator.java | 2 +
.../cache/DistributedCacheOperation.java | 108 +-
.../cache/DistributedPutAllOperation.java | 86 +-
.../internal/cache/DistributedRegion.java | 188 +-
...stributedRegionFunctionStreamingMessage.java | 4 +-
.../cache/DistributedRemoveAllOperation.java | 51 +-
.../internal/cache/DummyCachePerfStats.java | 2 +-
.../cache/DynamicRegionFactoryImpl.java | 2 +-
.../gemfire/internal/cache/EntriesMap.java | 2 +-
.../gemfire/internal/cache/EntriesSet.java | 10 -
.../gemfire/internal/cache/EntryBits.java | 22 -
.../gemfire/internal/cache/EntryEventImpl.java | 486 +-
.../gemfire/internal/cache/EntryExpiryTask.java | 28 +-
.../internal/cache/EntryOperationImpl.java | 19 +-
.../gemfire/internal/cache/EntrySnapshot.java | 6 +-
.../internal/cache/EnumListenerEvent.java | 2 +-
.../gemfire/internal/cache/EventID.java | 32 +-
.../gemfire/internal/cache/EventIDHolder.java | 35 +
.../gemfire/internal/cache/EventTracker.java | 34 +-
.../internal/cache/EvictionAttributesImpl.java | 4 +-
.../gemfire/internal/cache/EvictorService.java | 284 --
.../internal/cache/ExpirationScheduler.java | 10 +-
.../gemfire/internal/cache/ExpiryTask.java | 27 +-
.../gemfire/internal/cache/FilterProfile.java | 54 +-
.../internal/cache/FilterRoutingInfo.java | 2 +-
.../cache/FindDurableQueueProcessor.java | 2 +-
.../cache/FixedPartitionAttributesImpl.java | 13 +-
.../internal/cache/ForceReattemptException.java | 2 +-
.../cache/ForceableLinkedBlockingQueue.java | 2 +-
.../internal/cache/GemFireCacheImpl.java | 445 +-
.../gemfire/internal/cache/GridAdvisor.java | 15 +-
.../gemfire/internal/cache/HARegion.java | 33 +-
.../internal/cache/HDFSLRURegionMap.java | 111 -
.../gemfire/internal/cache/HDFSRegionMap.java | 32 -
.../internal/cache/HDFSRegionMapDelegate.java | 540 --
.../internal/cache/HDFSRegionMapImpl.java | 74 -
.../internal/cache/IncomingGatewayStatus.java | 2 +-
.../internal/cache/InitialImageOperation.java | 173 +-
.../gemfire/internal/cache/InlineKeyHelper.java | 4 +-
.../gemfire/internal/cache/InternalCache.java | 6 +-
.../internal/cache/InternalCacheEvent.java | 2 +-
.../internal/cache/InternalDataView.java | 30 +-
.../internal/cache/InternalRegionArguments.java | 65 +-
.../internal/cache/InvalidateOperation.java | 8 +-
.../gemfire/internal/cache/KeyInfo.java | 5 +-
.../internal/cache/KeyWithRegionContext.java | 70 -
.../gemfire/internal/cache/ListOfDeltas.java | 100 -
.../internal/cache/LoaderHelperFactory.java | 4 +-
.../internal/cache/LoaderHelperImpl.java | 2 +-
.../gemfire/internal/cache/LocalDataSet.java | 14 +-
.../gemfire/internal/cache/LocalRegion.java | 783 ++-
.../internal/cache/LocalRegionDataView.java | 37 +-
.../cache/MemberFunctionStreamingMessage.java | 2 +-
.../cache/MinimumSystemRequirements.java | 8 +-
.../internal/cache/NonLocalRegionEntry.java | 20 -
.../gemstone/gemfire/internal/cache/OpType.java | 2 +-
.../gemstone/gemfire/internal/cache/Oplog.java | 218 +-
.../gemfire/internal/cache/OverflowOplog.java | 5 +-
.../internal/cache/PRHARedundancyProvider.java | 88 +-
.../internal/cache/PRQueryProcessor.java | 42 +-
.../internal/cache/PartitionAttributesImpl.java | 16 +-
.../internal/cache/PartitionedRegion.java | 1028 +---
.../PartitionedRegionBucketMgmtHelper.java | 2 +-
.../cache/PartitionedRegionDataStore.java | 142 +-
.../cache/PartitionedRegionDataView.java | 29 +-
.../internal/cache/PartitionedRegionHelper.java | 12 +-
.../cache/PartitionedRegionQueryEvaluator.java | 65 +-
.../internal/cache/PartitionedRegionStats.java | 2 +-
.../internal/cache/PartitionedRegionStatus.java | 2 +-
.../internal/cache/PlaceHolderDiskRegion.java | 2 +-
.../gemfire/internal/cache/PoolFactoryImpl.java | 32 +-
.../gemfire/internal/cache/PoolManagerImpl.java | 2 +-
.../gemfire/internal/cache/PoolStats.java | 14 +-
.../cache/PreferBytesCachedDeserializable.java | 2 +-
.../internal/cache/PrimaryBucketException.java | 2 +-
.../internal/cache/ProxyBucketRegion.java | 2 +-
.../gemfire/internal/cache/ProxyRegionMap.java | 60 +-
.../cache/PutAllPartialResultException.java | 2 +-
.../gemfire/internal/cache/QueuedOperation.java | 21 +-
.../internal/cache/RegionClearedException.java | 2 +-
.../gemfire/internal/cache/RegionEntry.java | 42 +-
.../internal/cache/RegionEntryContext.java | 2 +-
.../internal/cache/RegionEntryFactory.java | 2 +-
.../gemfire/internal/cache/RegionEventImpl.java | 2 +-
.../internal/cache/RegionEvictorTask.java | 16 +-
.../internal/cache/RegionFactoryImpl.java | 2 +-
.../gemfire/internal/cache/RegionMap.java | 15 +-
.../internal/cache/RegionMapFactory.java | 8 +-
.../gemfire/internal/cache/RegionQueue.java | 2 +-
.../internal/cache/RegionQueueException.java | 2 +-
.../gemfire/internal/cache/RegionStatus.java | 2 +-
.../cache/ReliableDistributionData.java | 2 +-
.../internal/cache/ReliableMessageQueue.java | 2 +-
.../cache/ReliableMessageQueueFactory.java | 2 +-
.../cache/ReliableMessageQueueFactoryImpl.java | 4 +-
.../cache/RemoteContainsKeyValueMessage.java | 7 +-
.../internal/cache/RemoteDestroyMessage.java | 24 +-
.../internal/cache/RemoteFetchEntryMessage.java | 7 +-
.../cache/RemoteFetchVersionMessage.java | 5 +-
.../internal/cache/RemoteGetMessage.java | 11 +-
.../internal/cache/RemoteInvalidateMessage.java | 9 +-
.../cache/RemoteOperationException.java | 2 +-
.../internal/cache/RemoteOperationMessage.java | 51 +-
.../internal/cache/RemotePutAllMessage.java | 20 +-
.../internal/cache/RemotePutMessage.java | 42 +-
.../internal/cache/RemoteRegionOperation.java | 2 +-
.../internal/cache/RemoteRemoveAllMessage.java | 13 +-
.../gemfire/internal/cache/RoleEventImpl.java | 2 +-
.../cache/SearchLoadAndWriteProcessor.java | 92 +-
.../internal/cache/SendQueueOperation.java | 2 +-
.../internal/cache/StateFlushOperation.java | 8 +-
.../cache/StoreAllCachedDeserializable.java | 2 +-
.../gemfire/internal/cache/TXCommitMessage.java | 20 +-
.../gemfire/internal/cache/TXEntry.java | 16 +-
.../gemfire/internal/cache/TXEntryState.java | 128 +-
.../internal/cache/TXEntryUserAttrState.java | 2 +-
.../gemfire/internal/cache/TXEvent.java | 2 +-
.../internal/cache/TXFarSideCMTracker.java | 2 +-
.../gemstone/gemfire/internal/cache/TXId.java | 2 +-
.../gemfire/internal/cache/TXLockRequest.java | 8 +-
.../gemfire/internal/cache/TXManagerImpl.java | 301 +-
.../internal/cache/TXRegionLockRequestImpl.java | 16 +-
.../gemfire/internal/cache/TXRegionState.java | 8 +-
.../internal/cache/TXRemoteCommitMessage.java | 16 +-
.../internal/cache/TXReservationMgr.java | 2 +-
.../gemfire/internal/cache/TXRmtEvent.java | 11 +-
.../gemfire/internal/cache/TXState.java | 91 +-
.../internal/cache/TXStateInterface.java | 13 +-
.../gemfire/internal/cache/TXStateProxy.java | 3 +
.../internal/cache/TXStateProxyImpl.java | 39 +-
.../gemfire/internal/cache/TXStateStub.java | 32 +-
.../cache/TXSynchronizationRunnable.java | 4 +-
.../cache/TimestampedEntryEventImpl.java | 2 +
.../internal/cache/TombstoneService.java | 1305 +++--
.../cache/UpdateAttributesProcessor.java | 21 +-
.../cache/UpdateEntryVersionOperation.java | 9 +-
.../gemfire/internal/cache/UpdateOperation.java | 47 +-
.../cache/UserSpecifiedDiskStoreAttributes.java | 2 +-
.../cache/UserSpecifiedRegionAttributes.java | 46 +-
.../gemfire/internal/cache/VMLRURegionMap.java | 2 +-
.../gemfire/internal/cache/VMRegionMap.java | 2 +-
.../cache/VMStatsDiskLRURegionEntry.java | 2 +-
.../cache/VMStatsDiskLRURegionEntryHeap.java | 2 +-
.../VMStatsDiskLRURegionEntryHeapIntKey.java | 2 +-
.../VMStatsDiskLRURegionEntryHeapLongKey.java | 2 +-
.../VMStatsDiskLRURegionEntryHeapObjectKey.java | 2 +-
...VMStatsDiskLRURegionEntryHeapStringKey1.java | 2 +-
...VMStatsDiskLRURegionEntryHeapStringKey2.java | 2 +-
.../VMStatsDiskLRURegionEntryHeapUUIDKey.java | 2 +-
.../cache/VMStatsDiskLRURegionEntryOffHeap.java | 2 +-
.../VMStatsDiskLRURegionEntryOffHeapIntKey.java | 2 +-
...VMStatsDiskLRURegionEntryOffHeapLongKey.java | 2 +-
...StatsDiskLRURegionEntryOffHeapObjectKey.java | 2 +-
...tatsDiskLRURegionEntryOffHeapStringKey1.java | 2 +-
...tatsDiskLRURegionEntryOffHeapStringKey2.java | 2 +-
...VMStatsDiskLRURegionEntryOffHeapUUIDKey.java | 2 +-
.../internal/cache/VMStatsDiskRegionEntry.java | 2 +-
.../cache/VMStatsDiskRegionEntryHeap.java | 2 +-
.../cache/VMStatsDiskRegionEntryHeapIntKey.java | 2 +-
.../VMStatsDiskRegionEntryHeapLongKey.java | 2 +-
.../VMStatsDiskRegionEntryHeapObjectKey.java | 2 +-
.../VMStatsDiskRegionEntryHeapStringKey1.java | 2 +-
.../VMStatsDiskRegionEntryHeapStringKey2.java | 2 +-
.../VMStatsDiskRegionEntryHeapUUIDKey.java | 2 +-
.../cache/VMStatsDiskRegionEntryOffHeap.java | 2 +-
.../VMStatsDiskRegionEntryOffHeapIntKey.java | 2 +-
.../VMStatsDiskRegionEntryOffHeapLongKey.java | 2 +-
.../VMStatsDiskRegionEntryOffHeapObjectKey.java | 2 +-
...VMStatsDiskRegionEntryOffHeapStringKey1.java | 2 +-
...VMStatsDiskRegionEntryOffHeapStringKey2.java | 2 +-
.../VMStatsDiskRegionEntryOffHeapUUIDKey.java | 2 +-
.../internal/cache/VMStatsLRURegionEntry.java | 2 +-
.../cache/VMStatsLRURegionEntryHeap.java | 2 +-
.../cache/VMStatsLRURegionEntryOffHeap.java | 2 +-
.../internal/cache/VMStatsRegionEntry.java | 2 +-
.../internal/cache/VMStatsRegionEntryHeap.java | 2 +-
.../cache/VMStatsRegionEntryOffHeap.java | 2 +-
.../cache/VMThinDiskLRURegionEntry.java | 2 +-
.../cache/VMThinDiskLRURegionEntryHeap.java | 2 +-
.../VMThinDiskLRURegionEntryHeapIntKey.java | 2 +-
.../VMThinDiskLRURegionEntryHeapLongKey.java | 2 +-
.../VMThinDiskLRURegionEntryHeapObjectKey.java | 2 +-
.../VMThinDiskLRURegionEntryHeapStringKey1.java | 2 +-
.../VMThinDiskLRURegionEntryHeapStringKey2.java | 2 +-
.../VMThinDiskLRURegionEntryHeapUUIDKey.java | 2 +-
.../cache/VMThinDiskLRURegionEntryOffHeap.java | 2 +-
.../VMThinDiskLRURegionEntryOffHeapIntKey.java | 2 +-
.../VMThinDiskLRURegionEntryOffHeapLongKey.java | 2 +-
...MThinDiskLRURegionEntryOffHeapObjectKey.java | 2 +-
...ThinDiskLRURegionEntryOffHeapStringKey1.java | 2 +-
...ThinDiskLRURegionEntryOffHeapStringKey2.java | 2 +-
.../VMThinDiskLRURegionEntryOffHeapUUIDKey.java | 2 +-
.../internal/cache/VMThinDiskRegionEntry.java | 2 +-
.../cache/VMThinDiskRegionEntryHeap.java | 2 +-
.../cache/VMThinDiskRegionEntryHeapIntKey.java | 2 +-
.../cache/VMThinDiskRegionEntryHeapLongKey.java | 2 +-
.../VMThinDiskRegionEntryHeapObjectKey.java | 2 +-
.../VMThinDiskRegionEntryHeapStringKey1.java | 2 +-
.../VMThinDiskRegionEntryHeapStringKey2.java | 2 +-
.../cache/VMThinDiskRegionEntryHeapUUIDKey.java | 2 +-
.../cache/VMThinDiskRegionEntryOffHeap.java | 2 +-
.../VMThinDiskRegionEntryOffHeapIntKey.java | 2 +-
.../VMThinDiskRegionEntryOffHeapLongKey.java | 2 +-
.../VMThinDiskRegionEntryOffHeapObjectKey.java | 2 +-
.../VMThinDiskRegionEntryOffHeapStringKey1.java | 2 +-
.../VMThinDiskRegionEntryOffHeapStringKey2.java | 2 +-
.../VMThinDiskRegionEntryOffHeapUUIDKey.java | 2 +-
.../internal/cache/VMThinLRURegionEntry.java | 2 +-
.../cache/VMThinLRURegionEntryHeap.java | 2 +-
.../cache/VMThinLRURegionEntryOffHeap.java | 2 +-
.../internal/cache/VMThinRegionEntry.java | 2 +-
.../internal/cache/VMThinRegionEntryHeap.java | 2 +-
.../cache/VMThinRegionEntryOffHeap.java | 2 +-
.../internal/cache/ValidatingDiskRegion.java | 18 +-
.../internal/cache/VersionTagHolder.java | 34 +
.../VersionedStatsDiskLRURegionEntryHeap.java | 2 +-
...sionedStatsDiskLRURegionEntryHeapIntKey.java | 2 +-
...ionedStatsDiskLRURegionEntryHeapLongKey.java | 2 +-
...nedStatsDiskLRURegionEntryHeapObjectKey.java | 2 +-
...edStatsDiskLRURegionEntryHeapStringKey1.java | 2 +-
...edStatsDiskLRURegionEntryHeapStringKey2.java | 2 +-
...ionedStatsDiskLRURegionEntryHeapUUIDKey.java | 2 +-
...VersionedStatsDiskLRURegionEntryOffHeap.java | 2 +-
...nedStatsDiskLRURegionEntryOffHeapIntKey.java | 2 +-
...edStatsDiskLRURegionEntryOffHeapLongKey.java | 2 +-
...StatsDiskLRURegionEntryOffHeapObjectKey.java | 2 +-
...tatsDiskLRURegionEntryOffHeapStringKey1.java | 2 +-
...tatsDiskLRURegionEntryOffHeapStringKey2.java | 2 +-
...edStatsDiskLRURegionEntryOffHeapUUIDKey.java | 2 +-
.../VersionedStatsDiskRegionEntryHeap.java | 2 +-
...VersionedStatsDiskRegionEntryHeapIntKey.java | 2 +-
...ersionedStatsDiskRegionEntryHeapLongKey.java | 2 +-
...sionedStatsDiskRegionEntryHeapObjectKey.java | 2 +-
...ionedStatsDiskRegionEntryHeapStringKey1.java | 2 +-
...ionedStatsDiskRegionEntryHeapStringKey2.java | 2 +-
...ersionedStatsDiskRegionEntryHeapUUIDKey.java | 2 +-
.../VersionedStatsDiskRegionEntryOffHeap.java | 2 +-
...sionedStatsDiskRegionEntryOffHeapIntKey.java | 2 +-
...ionedStatsDiskRegionEntryOffHeapLongKey.java | 2 +-
...nedStatsDiskRegionEntryOffHeapObjectKey.java | 2 +-
...edStatsDiskRegionEntryOffHeapStringKey1.java | 2 +-
...edStatsDiskRegionEntryOffHeapStringKey2.java | 2 +-
...ionedStatsDiskRegionEntryOffHeapUUIDKey.java | 2 +-
.../cache/VersionedStatsLRURegionEntryHeap.java | 2 +-
.../VersionedStatsLRURegionEntryOffHeap.java | 2 +-
.../cache/VersionedStatsRegionEntryHeap.java | 2 +-
.../cache/VersionedStatsRegionEntryOffHeap.java | 2 +-
.../VersionedThinDiskLRURegionEntryHeap.java | 2 +-
...rsionedThinDiskLRURegionEntryHeapIntKey.java | 2 +-
...sionedThinDiskLRURegionEntryHeapLongKey.java | 2 +-
...onedThinDiskLRURegionEntryHeapObjectKey.java | 2 +-
...nedThinDiskLRURegionEntryHeapStringKey1.java | 2 +-
...nedThinDiskLRURegionEntryHeapStringKey2.java | 2 +-
...sionedThinDiskLRURegionEntryHeapUUIDKey.java | 2 +-
.../VersionedThinDiskLRURegionEntryOffHeap.java | 2 +-
...onedThinDiskLRURegionEntryOffHeapIntKey.java | 2 +-
...nedThinDiskLRURegionEntryOffHeapLongKey.java | 2 +-
...dThinDiskLRURegionEntryOffHeapObjectKey.java | 2 +-
...ThinDiskLRURegionEntryOffHeapStringKey1.java | 2 +-
...ThinDiskLRURegionEntryOffHeapStringKey2.java | 2 +-
...nedThinDiskLRURegionEntryOffHeapUUIDKey.java | 2 +-
.../cache/VersionedThinDiskRegionEntryHeap.java | 2 +-
.../VersionedThinDiskRegionEntryHeapIntKey.java | 2 +-
...VersionedThinDiskRegionEntryHeapLongKey.java | 2 +-
...rsionedThinDiskRegionEntryHeapObjectKey.java | 2 +-
...sionedThinDiskRegionEntryHeapStringKey1.java | 2 +-
...sionedThinDiskRegionEntryHeapStringKey2.java | 2 +-
...VersionedThinDiskRegionEntryHeapUUIDKey.java | 2 +-
.../VersionedThinDiskRegionEntryOffHeap.java | 2 +-
...rsionedThinDiskRegionEntryOffHeapIntKey.java | 2 +-
...sionedThinDiskRegionEntryOffHeapLongKey.java | 2 +-
...onedThinDiskRegionEntryOffHeapObjectKey.java | 2 +-
...nedThinDiskRegionEntryOffHeapStringKey1.java | 2 +-
...nedThinDiskRegionEntryOffHeapStringKey2.java | 2 +-
...sionedThinDiskRegionEntryOffHeapUUIDKey.java | 2 +-
.../cache/VersionedThinLRURegionEntryHeap.java | 2 +-
.../VersionedThinLRURegionEntryOffHeap.java | 2 +-
.../cache/VersionedThinRegionEntryHeap.java | 2 +-
.../cache/VersionedThinRegionEntryOffHeap.java | 2 +-
.../internal/cache/WrappedCallbackArgument.java | 28 +-
.../cache/control/HeapMemoryMonitor.java | 149 +-
.../cache/control/InternalResourceManager.java | 39 +-
.../cache/control/MemoryThresholds.java | 17 +-
.../cache/control/OffHeapMemoryMonitor.java | 2 +-
.../cache/control/RebalanceOperationImpl.java | 26 +-
.../internal/cache/control/ResourceAdvisor.java | 6 +-
.../cache/control/ResourceListener.java | 2 +-
.../internal/cache/control/ResourceMonitor.java | 2 +-
.../gemfire/internal/cache/delta/Delta.java | 56 -
.../cache/execute/AbstractExecution.java | 22 +-
.../cache/execute/BucketMovedException.java | 6 +-
.../cache/execute/DefaultResultCollector.java | 2 +-
.../DistributedRegionFunctionExecutor.java | 2 +-
.../cache/execute/FunctionContextImpl.java | 2 +-
.../internal/cache/execute/FunctionStats.java | 9 +-
.../FunctionStreamingResultCollector.java | 3 +-
.../cache/execute/InternalExecution.java | 31 +-
.../execute/InternalFunctionException.java | 2 +-
.../cache/execute/InternalFunctionService.java | 14 +-
.../execute/InternalRegionFunctionContext.java | 5 -
.../cache/execute/MemberFunctionExecutor.java | 7 -
.../cache/execute/MemberMappedArgument.java | 2 +-
.../execute/MultiRegionFunctionContext.java | 4 +-
.../execute/MultiRegionFunctionContextImpl.java | 2 +-
.../execute/MultiRegionFunctionExecutor.java | 7 -
.../internal/cache/execute/NoResult.java | 2 +-
.../execute/RegionFunctionContextImpl.java | 15 +-
.../cache/execute/ServerFunctionExecutor.java | 7 -
.../execute/ServerRegionFunctionExecutor.java | 2 +-
.../ServerToClientFunctionResultSender65.java | 2 +-
.../cache/execute/util/CommitFunction.java | 141 -
.../util/FindRestEnabledServersFunction.java | 3 +-
.../execute/util/NestedTransactionFunction.java | 116 -
.../cache/execute/util/RollbackFunction.java | 136 -
.../internal/cache/extension/Extensible.java | 4 +-
.../internal/cache/extension/Extension.java | 21 +-
.../cache/extension/ExtensionPoint.java | 10 +-
.../cache/extension/SimpleExtensionPoint.java | 11 +-
.../internal/cache/ha/HAContainerMap.java | 2 +-
.../internal/cache/ha/HAContainerRegion.java | 2 +-
.../internal/cache/ha/HAContainerWrapper.java | 2 +-
.../internal/cache/ha/HARegionQueue.java | 114 +-
.../cache/ha/HARegionQueueAttributes.java | 4 +-
.../internal/cache/locks/TXLockServiceImpl.java | 7 +-
.../locks/TXLockUpdateParticipantsMessage.java | 2 +-
.../gemfire/internal/cache/lru/HeapEvictor.java | 46 +-
.../cache/lru/HeapLRUCapacityController.java | 17 +-
.../internal/cache/lru/HeapLRUStatistics.java | 2 +-
.../internal/cache/lru/LRUAlgorithm.java | 6 +-
.../cache/lru/LRUCapacityController.java | 4 +-
.../internal/cache/lru/LRUClockNode.java | 2 +-
.../cache/lru/MemLRUCapacityController.java | 4 +-
.../internal/cache/lru/NewLIFOClockHand.java | 2 +-
.../internal/cache/lru/NewLRUClockHand.java | 19 +-
.../internal/cache/lru/OffHeapEvictor.java | 7 +-
.../gemfire/internal/cache/lru/Sizeable.java | 2 +-
.../operations/ContainsKeyOperationContext.java | 2 +-
.../AllBucketProfilesUpdateMessage.java | 2 +-
.../internal/cache/partitioned/Bucket.java | 2 +-
.../cache/partitioned/BucketBackupMessage.java | 2 +-
.../partitioned/BucketProfileUpdateMessage.java | 2 +-
.../cache/partitioned/BucketSizeMessage.java | 4 +-
.../partitioned/ContainsKeyValueMessage.java | 6 +-
.../cache/partitioned/CreateBucketMessage.java | 6 +-
.../cache/partitioned/DestroyMessage.java | 19 +-
.../DestroyRegionOnDataStoreMessage.java | 5 +-
.../partitioned/FetchBulkEntriesMessage.java | 16 +-
.../cache/partitioned/FetchEntriesMessage.java | 8 +-
.../cache/partitioned/FetchEntryMessage.java | 8 +-
.../cache/partitioned/FetchKeysMessage.java | 8 +-
.../cache/partitioned/FlushMessage.java | 2 +-
.../internal/cache/partitioned/GetMessage.java | 68 +-
.../partitioned/IdentityRequestMessage.java | 6 +-
.../partitioned/IdentityUpdateMessage.java | 2 +-
.../cache/partitioned/InterestEventMessage.java | 6 +-
.../cache/partitioned/InvalidateMessage.java | 11 +-
.../partitioned/ManageBackupBucketMessage.java | 6 +-
.../cache/partitioned/ManageBucketMessage.java | 6 +-
.../cache/partitioned/PREntriesIterator.java | 8 +-
.../internal/cache/partitioned/PRLoad.java | 2 +-
.../PRLocallyDestroyedException.java | 2 +-
.../cache/partitioned/PRSanityCheckMessage.java | 15 +-
.../cache/partitioned/PRTombstoneMessage.java | 2 +-
.../PRUpdateEntryVersionMessage.java | 6 +-
.../cache/partitioned/PartitionMessage.java | 79 +-
.../PartitionedRegionRebalanceOp.java | 349 +-
.../partitioned/PrimaryRequestMessage.java | 2 +-
.../cache/partitioned/PutAllPRMessage.java | 50 +-
.../internal/cache/partitioned/PutMessage.java | 63 +-
.../cache/partitioned/RecoveryRunnable.java | 2 +-
.../cache/partitioned/RegionAdvisor.java | 78 +-
.../partitioned/RemoteFetchKeysMessage.java | 6 -
.../cache/partitioned/RemoteSizeMessage.java | 4 +-
.../cache/partitioned/RemoveAllPRMessage.java | 28 +-
.../internal/cache/partitioned/SizeMessage.java | 4 +-
.../cache/partitioned/SizedBasedLoadProbe.java | 6 +-
.../rebalance/BucketOperatorImpl.java | 78 +
.../rebalance/BucketOperatorWrapper.java | 235 +
.../rebalance/PartitionedRegionLoadModel.java | 23 +-
.../cache/persistence/BackupManager.java | 21 +-
.../cache/persistence/BytesAndBits.java | 2 +-
.../cache/persistence/DiskRecoveryStore.java | 2 +-
.../persistence/PersistenceAdvisorImpl.java | 27 +-
.../persistence/PersistentMemberPattern.java | 2 +-
.../cache/persistence/query/IndexMap.java | 4 +-
.../cache/persistence/query/ResultBag.java | 2 +-
.../cache/persistence/query/ResultList.java | 2 +-
.../cache/persistence/query/ResultMap.java | 4 +-
.../cache/persistence/query/ResultSet.java | 2 +-
.../persistence/soplog/ByteComparator.java | 55 -
.../persistence/soplog/CursorIterator.java | 81 -
.../soplog/DelegatingSerializedComparator.java | 37 -
.../soplog/HFileStoreStatistics.java | 205 -
.../persistence/soplog/KeyValueIterator.java | 42 -
.../soplog/SortedOplogStatistics.java | 505 --
.../cache/persistence/soplog/SortedReader.java | 255 -
.../persistence/soplog/TrackedReference.java | 153 -
.../gemfire/internal/cache/properties.html | 2 +-
.../snapshot/RegionSnapshotServiceImpl.java | 47 +-
.../cache/snapshot/WindowedExporter.java | 39 +-
.../gemfire/internal/cache/tier/Acceptor.java | 4 +-
.../internal/cache/tier/BatchException.java | 2 +-
.../internal/cache/tier/CachedRegionHelper.java | 4 +-
.../internal/cache/tier/ClientHandShake.java | 2 +-
.../internal/cache/tier/ConnectionProxy.java | 4 +-
.../internal/cache/tier/InterestType.java | 2 +-
.../cache/tier/InternalClientMembership.java | 6 +-
.../internal/cache/tier/MessageType.java | 60 +-
.../cache/tier/sockets/AcceptorImpl.java | 55 +-
.../cache/tier/sockets/BaseCommand.java | 82 +-
.../cache/tier/sockets/BaseCommandQuery.java | 37 +-
.../cache/tier/sockets/CacheClientNotifier.java | 180 +-
.../tier/sockets/CacheClientNotifierStats.java | 2 +-
.../cache/tier/sockets/CacheClientProxy.java | 176 +-
.../tier/sockets/CacheClientProxyStats.java | 2 +-
.../cache/tier/sockets/CacheClientUpdater.java | 92 +-
.../cache/tier/sockets/CacheServerHelper.java | 2 +-
.../cache/tier/sockets/ChunkedMessage.java | 2 +-
.../tier/sockets/ClientBlacklistProcessor.java | 2 +-
.../cache/tier/sockets/ClientHealthMonitor.java | 54 +-
.../tier/sockets/ClientInstantiatorMessage.java | 2 +-
.../tier/sockets/ClientInterestMessageImpl.java | 44 +-
.../tier/sockets/ClientMarkerMessageImpl.java | 2 +-
.../cache/tier/sockets/ClientMessage.java | 2 +-
.../tier/sockets/ClientPingMessageImpl.java | 2 +-
.../tier/sockets/ClientProxyMembershipID.java | 48 +-
.../cache/tier/sockets/ClientUpdateMessage.java | 2 +-
.../tier/sockets/ClientUpdateMessageImpl.java | 4 +-
.../cache/tier/sockets/ClientUserAuths.java | 33 +-
.../cache/tier/sockets/CommandInitializer.java | 2 +-
.../cache/tier/sockets/ConnectionListener.java | 2 +-
.../tier/sockets/ConnectionListenerAdapter.java | 2 +-
.../cache/tier/sockets/HAEventWrapper.java | 2 +-
.../internal/cache/tier/sockets/HandShake.java | 138 +-
.../tier/sockets/InterestResultPolicyImpl.java | 2 +-
.../internal/cache/tier/sockets/Message.java | 82 +-
.../cache/tier/sockets/MessageStats.java | 2 +-
.../cache/tier/sockets/ObjectPartList.java | 2 +-
.../internal/cache/tier/sockets/Part.java | 13 +-
.../RemoveClientFromBlacklistMessage.java | 2 +-
.../cache/tier/sockets/ServerConnection.java | 542 +-
.../tier/sockets/ServerHandShakeProcessor.java | 80 +-
.../cache/tier/sockets/ServerQueueStatus.java | 2 +-
.../tier/sockets/ServerResponseMatrix.java | 2 +-
.../cache/tier/sockets/VersionedObjectList.java | 2 +-
.../cache/tier/sockets/command/ClearRegion.java | 139 +-
.../tier/sockets/command/CloseConnection.java | 30 +-
.../tier/sockets/command/CommitCommand.java | 2 +-
.../cache/tier/sockets/command/ContainsKey.java | 120 +-
.../tier/sockets/command/ContainsKey66.java | 150 +-
.../tier/sockets/command/CreateRegion.java | 122 +-
.../cache/tier/sockets/command/Destroy.java | 234 +-
.../cache/tier/sockets/command/Destroy65.java | 374 +-
.../tier/sockets/command/DestroyRegion.java | 167 +-
.../tier/sockets/command/ExecuteFunction.java | 9 +-
.../tier/sockets/command/ExecuteFunction65.java | 254 +-
.../tier/sockets/command/ExecuteFunction66.java | 347 +-
.../sockets/command/ExecuteRegionFunction.java | 237 +-
.../command/ExecuteRegionFunction61.java | 2 +-
.../command/ExecuteRegionFunction65.java | 357 +-
.../command/ExecuteRegionFunction66.java | 374 +-
.../command/ExecuteRegionFunctionSingleHop.java | 356 +-
.../sockets/command/GatewayReceiverCommand.java | 32 +-
.../cache/tier/sockets/command/Get70.java | 211 +-
.../cache/tier/sockets/command/GetAll.java | 167 +-
.../cache/tier/sockets/command/GetAll651.java | 172 +-
.../cache/tier/sockets/command/GetAll70.java | 303 +-
.../sockets/command/GetAllWithCallback.java | 68 +-
.../command/GetClientPRMetadataCommand.java | 2 +-
.../command/GetClientPRMetadataCommand66.java | 2 +-
.../GetClientPartitionAttributesCommand.java | 139 +-
.../GetClientPartitionAttributesCommand66.java | 182 +-
.../cache/tier/sockets/command/GetEntry70.java | 15 +-
.../tier/sockets/command/GetEntryCommand.java | 2 +-
.../sockets/command/GetFunctionAttribute.java | 35 +-
.../cache/tier/sockets/command/Invalidate.java | 237 +-
.../cache/tier/sockets/command/KeySet.java | 172 +-
.../tier/sockets/command/ManagementCommand.java | 2 +-
.../cache/tier/sockets/command/Put.java | 272 +-
.../cache/tier/sockets/command/Put61.java | 310 +-
.../cache/tier/sockets/command/Put65.java | 595 ++-
.../cache/tier/sockets/command/PutAll.java | 49 +-
.../cache/tier/sockets/command/PutAll70.java | 5 +-
.../cache/tier/sockets/command/PutAll80.java | 6 +-
.../cache/tier/sockets/command/Query.java | 42 +-
.../tier/sockets/command/RegisterInterest.java | 213 +-
.../sockets/command/RegisterInterest61.java | 219 +-
.../sockets/command/RegisterInterestList.java | 7 +-
.../sockets/command/RegisterInterestList61.java | 160 +-
.../sockets/command/RegisterInterestList66.java | 7 +-
.../cache/tier/sockets/command/RemoveAll.java | 7 +-
.../tier/sockets/command/RemoveUserAuth.java | 71 +-
.../cache/tier/sockets/command/Request.java | 4 +-
.../tier/sockets/command/RequestEventValue.java | 2 +-
.../tier/sockets/command/RollbackCommand.java | 5 +
.../cache/tier/sockets/command/Size.java | 141 +-
.../tier/sockets/command/TXFailoverCommand.java | 16 +-
.../sockets/command/UnregisterInterest.java | 116 +-
.../sockets/command/UnregisterInterestList.java | 119 +-
.../cache/tx/AbstractPeerTXRegionStub.java | 8 +-
.../internal/cache/tx/ClientTXRegionStub.java | 4 +-
.../internal/cache/tx/ClientTXStateStub.java | 17 +-
.../internal/cache/tx/DistTxEntryEvent.java | 27 +-
.../cache/tx/DistributedTXRegionStub.java | 14 +-
.../cache/tx/PartitionedTXRegionStub.java | 25 +-
.../gemfire/internal/cache/tx/TXRegionStub.java | 4 +-
.../ConcurrentCacheModificationException.java | 2 +-
.../cache/versions/RegionVersionVector.java | 39 +-
.../internal/cache/versions/VersionTag.java | 83 +-
.../cache/wan/AbstractGatewaySender.java | 140 +-
.../AbstractGatewaySenderEventProcessor.java | 57 +-
.../internal/cache/wan/BatchException70.java | 2 +-
.../cache/wan/GatewayReceiverException.java | 2 +-
.../cache/wan/GatewaySenderAdvisor.java | 3 +-
.../cache/wan/GatewaySenderAttributes.java | 14 +-
.../GatewaySenderConfigurationException.java | 2 +-
.../wan/GatewaySenderEventCallbackArgument.java | 10 +-
.../GatewaySenderEventCallbackDispatcher.java | 2 +-
.../cache/wan/GatewaySenderEventDispatcher.java | 2 +-
.../cache/wan/GatewaySenderEventImpl.java | 20 +-
...rentParallelGatewaySenderEventProcessor.java | 15 +-
.../ConcurrentParallelGatewaySenderQueue.java | 35 +-
.../ParallelGatewaySenderEventProcessor.java | 22 +-
.../parallel/ParallelGatewaySenderQueue.java | 60 +-
.../ParallelQueueBatchRemovalMessage.java | 2 +-
.../parallel/ParallelQueueRemovalMessage.java | 3 +-
.../cache/wan/serial/BatchDestroyOperation.java | 5 +-
...urrentSerialGatewaySenderEventProcessor.java | 8 +-
.../SerialGatewaySenderEventProcessor.java | 2 +-
.../wan/serial/SerialGatewaySenderQueue.java | 30 +-
.../serial/SerialSecondaryGatewayListener.java | 21 +-
.../cache/xmlcache/AbstractXmlParser.java | 2 +-
.../cache/xmlcache/AsyncEventQueueCreation.java | 25 +-
.../internal/cache/xmlcache/CacheCreation.java | 75 +-
.../cache/xmlcache/CacheServerCreation.java | 3 +-
.../CacheTransactionManagerCreation.java | 2 +-
.../internal/cache/xmlcache/CacheXml.java | 97 +-
.../cache/xmlcache/CacheXmlGenerator.java | 26 +-
.../internal/cache/xmlcache/CacheXmlParser.java | 232 +-
.../xmlcache/CacheXmlPropertyResolver.java | 2 +-
.../CacheXmlPropertyResolverHelper.java | 2 +-
.../cache/xmlcache/CacheXmlVersion.java | 12 +-
.../cache/xmlcache/ClientCacheCreation.java | 8 +-
.../cache/xmlcache/ClientHaQueueCreation.java | 2 +-
.../internal/cache/xmlcache/Declarable2.java | 2 +-
.../cache/xmlcache/DefaultEntityResolver2.java | 4 +-
.../xmlcache/DiskStoreAttributesCreation.java | 2 +-
.../cache/xmlcache/GeodeEntityResolver.java | 2 +-
.../cache/xmlcache/PivotalEntityResolver.java | 2 +-
.../cache/xmlcache/PropertyResolver.java | 2 +-
.../xmlcache/RegionAttributesCreation.java | 91 +-
.../internal/cache/xmlcache/RegionCreation.java | 18 +-
.../cache/xmlcache/ResourceManagerCreation.java | 2 +-
.../internal/cache/xmlcache/XmlGenerator.java | 8 +-
.../cache/xmlcache/XmlGeneratorUtils.java | 12 +-
.../internal/cache/xmlcache/XmlParser.java | 6 +-
.../internal/cache/xmlcache/package.html | 2 +-
.../gemfire/internal/concurrent/Atomics.java | 7 +-
.../concurrent/CompactConcurrentHashSet2.java | 6 +-
.../internal/concurrent/MapCallback.java | 2 +-
.../gemfire/internal/concurrent/MapResult.java | 2 +-
.../gemfire/internal/hll/HyperLogLog.java | 2 +-
.../gemfire/internal/hll/HyperLogLogPlus.java | 2 +-
.../i18n/AbstractStringIdResourceBundle.java | 2 +-
.../gemfire/internal/i18n/LocalizedStrings.java | 2513 +++++++--
.../internal/i18n/ParentLocalizedStrings.java | 2399 ---------
.../gemfire/internal/i18n/StringId.java | 2 +-
.../internal/io/CompositeOutputStream.java | 2 +-
.../internal/io/CompositePrintStream.java | 2 +-
.../gemfire/internal/io/TeeOutputStream.java | 2 +-
.../gemfire/internal/io/TeePrintStream.java | 2 +-
.../gemfire/internal/jndi/JNDIInvoker.java | 32 +-
.../gemfire/internal/jta/GlobalTransaction.java | 2 +-
.../internal/jta/TransactionManagerImpl.java | 2 +-
.../internal/jta/UserTransactionImpl.java | 2 +-
.../gemstone/gemfire/internal/jta/XidImpl.java | 2 +-
.../gemfire/internal/lang/ClassUtils.java | 2 +-
.../gemstone/gemfire/internal/lang/Filter.java | 2 +-
.../gemfire/internal/lang/InOutParameter.java | 2 +-
.../gemfire/internal/lang/Initable.java | 2 +-
.../gemfire/internal/lang/Initializer.java | 2 +-
.../internal/lang/MutableIdentifiable.java | 2 +-
.../gemfire/internal/lang/ObjectUtils.java | 2 +-
.../gemfire/internal/lang/Orderable.java | 2 +-
.../gemstone/gemfire/internal/lang/Ordered.java | 2 +-
.../gemfire/internal/lang/StringUtils.java | 2 +-
.../gemfire/internal/lang/SystemUtils.java | 13 +-
.../gemfire/internal/lang/ThreadUtils.java | 2 +-
.../gemfire/internal/lang/ThrowableUtils.java | 101 +
.../internal/logging/DebugLogWriter.java | 4 +-
.../internal/logging/LocalLogWriter.java | 2 +-
.../gemfire/internal/logging/LogConfig.java | 18 +-
.../gemfire/internal/logging/LogFileParser.java | 2 +-
.../gemfire/internal/logging/LogService.java | 2 +-
.../internal/logging/LogWriterFactory.java | 17 +-
.../gemfire/internal/logging/LogWriterImpl.java | 66 +-
.../internal/logging/LoggingThreadGroup.java | 12 +-
.../internal/logging/ManagerLogWriter.java | 61 +-
.../gemfire/internal/logging/MergeLogFiles.java | 2 +-
.../gemfire/internal/logging/PureLogWriter.java | 2 -
.../logging/SecurityLocalLogWriter.java | 2 +-
.../internal/logging/SecurityLogConfig.java | 4 +-
.../internal/logging/SecurityLogWriter.java | 5 +-
.../logging/SecurityManagerLogWriter.java | 7 +-
.../gemfire/internal/logging/SortLogFile.java | 2 +-
.../internal/logging/log4j/AppenderContext.java | 6 +-
.../logging/log4j/LogWriterAppender.java | 12 +-
.../logging/log4j/LogWriterAppenders.java | 28 +-
.../internal/logging/log4j/LogWriterLogger.java | 20 +-
.../message/GemFireParameterizedMessage.java | 556 ++
.../GemFireParameterizedMessageFactory.java | 56 +
.../modules/util/RegionConfiguration.java | 2 +-
.../gemfire/internal/net/SocketUtils.java | 2 +-
.../internal/offheap/AbstractStoredObject.java | 1 -
.../gemfire/internal/offheap/DataType.java | 2 +-
.../internal/offheap/FreeListManager.java | 329 +-
.../internal/offheap/MemoryAllocator.java | 2 +-
.../internal/offheap/MemoryAllocatorImpl.java | 32 +-
.../gemfire/internal/offheap/MemoryBlock.java | 2 +-
.../internal/offheap/MemoryInspector.java | 2 +-
.../internal/offheap/MemoryUsageListener.java | 2 +-
.../gemfire/internal/offheap/OffHeapHelper.java | 3 +-
.../internal/offheap/OffHeapMemoryStats.java | 3 +-
.../offheap/OffHeapRegionEntryHelper.java | 28 +-
.../internal/offheap/OffHeapStorage.java | 36 +-
.../internal/offheap/OffHeapStoredObject.java | 17 +-
.../OffHeapStoredObjectAddressStack.java | 5 +-
.../offheap/OutOfOffHeapMemoryListener.java | 2 +-
.../internal/offheap/ReferenceCountHelper.java | 220 +-
.../offheap/ReferenceCountHelperImpl.java | 303 ++
.../gemfire/internal/offheap/Releasable.java | 2 +-
.../gemfire/internal/offheap/SlabImpl.java | 13 +-
.../gemfire/internal/offheap/StoredObject.java | 2 +-
.../internal/offheap/TinyStoredObject.java | 13 +-
.../offheap/annotations/OffHeapIdentifier.java | 4 -
.../internal/process/AttachProcessUtils.java | 2 +-
.../process/BlockingProcessStreamReader.java | 2 +-
...usterConfigurationNotAvailableException.java | 2 +-
.../process/ConnectionFailedException.java | 2 +-
.../internal/process/ControlFileWatchdog.java | 2 +-
.../process/ControlNotificationHandler.java | 2 +-
.../internal/process/ControllableProcess.java | 12 +-
.../process/FileAlreadyExistsException.java | 2 +-
.../process/FileControllerParameters.java | 2 +-
.../internal/process/FileProcessController.java | 18 +-
.../process/LocalProcessController.java | 2 +-
.../internal/process/LocalProcessLauncher.java | 6 +-
.../process/MBeanControllerParameters.java | 2 +-
.../process/MBeanInvocationFailedException.java | 2 +-
.../process/MBeanProcessController.java | 2 +-
.../internal/process/NativeProcessUtils.java | 2 +-
.../process/NonBlockingProcessStreamReader.java | 2 +-
.../gemfire/internal/process/PidFile.java | 2 +-
.../process/PidUnavailableException.java | 2 +-
.../internal/process/ProcessController.java | 2 +-
.../process/ProcessControllerFactory.java | 13 +-
.../process/ProcessControllerParameters.java | 2 +-
.../process/ProcessLauncherContext.java | 15 +-
.../internal/process/ProcessStreamReader.java | 4 +-
.../ProcessTerminatedAbnormallyException.java | 2 +-
.../gemfire/internal/process/ProcessType.java | 6 +-
.../gemfire/internal/process/ProcessUtils.java | 2 +-
.../gemfire/internal/process/StartupStatus.java | 2 +-
.../UnableToControlProcessException.java | 2 +-
.../AbstractSignalNotificationHandler.java | 2 +-
.../gemfire/internal/process/signal/Signal.java | 2 +-
.../internal/process/signal/SignalEvent.java | 2 +-
.../internal/process/signal/SignalListener.java | 2 +-
.../internal/process/signal/SignalType.java | 2 +-
.../internal/redis/ByteArrayWrapper.java | 180 -
.../internal/redis/ByteToCommandDecoder.java | 188 -
.../gemstone/gemfire/internal/redis/Coder.java | 516 --
.../gemfire/internal/redis/Command.java | 149 -
.../gemfire/internal/redis/DoubleWrapper.java | 78 -
.../internal/redis/ExecutionHandlerContext.java | 379 --
.../gemfire/internal/redis/Executor.java | 37 -
.../gemfire/internal/redis/Extendable.java | 32 -
.../redis/RedisCommandParserException.java | 44 -
.../internal/redis/RedisCommandType.java | 2344 ---------
.../gemfire/internal/redis/RedisConstants.java | 202 -
.../gemfire/internal/redis/RedisDataType.java | 118 -
.../redis/RedisDataTypeMismatchException.java | 38 -
.../internal/redis/RegionCreationException.java | 38 -
.../gemfire/internal/redis/RegionProvider.java | 552 --
.../redis/executor/AbstractExecutor.java | 138 -
.../redis/executor/AbstractScanExecutor.java | 47 -
.../internal/redis/executor/AuthExecutor.java | 54 -
.../internal/redis/executor/DBSizeExecutor.java | 31 -
.../internal/redis/executor/DelExecutor.java | 55 -
.../internal/redis/executor/EchoExecutor.java | 40 -
.../internal/redis/executor/ExistsExecutor.java | 49 -
.../redis/executor/ExpirationExecutor.java | 41 -
.../redis/executor/ExpireAtExecutor.java | 93 -
.../internal/redis/executor/ExpireExecutor.java | 93 -
.../redis/executor/FlushAllExecutor.java | 49 -
.../internal/redis/executor/KeysExecutor.java | 70 -
.../internal/redis/executor/ListQuery.java | 53 -
.../redis/executor/PExpireAtExecutor.java | 32 -
.../redis/executor/PExpireExecutor.java | 32 -
.../internal/redis/executor/PTTLExecutor.java | 33 -
.../redis/executor/PersistExecutor.java | 52 -
.../internal/redis/executor/PingExecutor.java | 31 -
.../internal/redis/executor/QuitExecutor.java | 31 -
.../internal/redis/executor/ScanExecutor.java | 144 -
.../redis/executor/ShutDownExecutor.java | 28 -
.../internal/redis/executor/SortedSetQuery.java | 204 -
.../internal/redis/executor/TTLExecutor.java | 77 -
.../internal/redis/executor/TimeExecutor.java | 51 -
.../internal/redis/executor/TypeExecutor.java | 48 -
.../internal/redis/executor/UnkownExecutor.java | 31 -
.../redis/executor/hash/HDelExecutor.java | 67 -
.../redis/executor/hash/HExistsExecutor.java | 66 -
.../redis/executor/hash/HGetAllExecutor.java | 63 -
.../redis/executor/hash/HGetExecutor.java | 62 -
.../redis/executor/hash/HIncrByExecutor.java | 109 -
.../executor/hash/HIncrByFloatExecutor.java | 99 -
.../redis/executor/hash/HKeysExecutor.java | 63 -
.../redis/executor/hash/HLenExecutor.java | 57 -
.../redis/executor/hash/HMGetExecutor.java | 72 -
.../redis/executor/hash/HMSetExecutor.java | 62 -
.../redis/executor/hash/HScanExecutor.java | 163 -
.../redis/executor/hash/HSetExecutor.java | 78 -
.../redis/executor/hash/HSetNXExecutor.java | 33 -
.../redis/executor/hash/HValsExecutor.java | 62 -
.../redis/executor/hash/HashExecutor.java | 39 -
.../redis/executor/hll/HllExecutor.java | 38 -
.../redis/executor/hll/PFAddExecutor.java | 66 -
.../redis/executor/hll/PFCountExecutor.java | 70 -
.../redis/executor/hll/PFMergeExecutor.java | 74 -
.../internal/redis/executor/hll/Varint.java | 241 -
.../redis/executor/list/LIndexExecutor.java | 118 -
.../redis/executor/list/LInsertExecutor.java | 29 -
.../redis/executor/list/LLenExecutor.java | 58 -
.../redis/executor/list/LPopExecutor.java | 34 -
.../redis/executor/list/LPushExecutor.java | 34 -
.../redis/executor/list/LPushXExecutor.java | 34 -
.../redis/executor/list/LRangeExecutor.java | 113 -
.../redis/executor/list/LRemExecutor.java | 116 -
.../redis/executor/list/LSetExecutor.java | 108 -
.../redis/executor/list/LTrimExecutor.java | 124 -
.../redis/executor/list/ListExecutor.java | 150 -
.../redis/executor/list/PopExecutor.java | 150 -
.../redis/executor/list/PushExecutor.java | 54 -
.../redis/executor/list/PushXExecutor.java | 59 -
.../redis/executor/list/RPopExecutor.java | 34 -
.../redis/executor/list/RPushExecutor.java | 34 -
.../redis/executor/list/RPushXExecutor.java | 34 -
.../redis/executor/set/SAddExecutor.java | 60 -
.../redis/executor/set/SCardExecutor.java | 55 -
.../redis/executor/set/SDiffExecutor.java | 46 -
.../redis/executor/set/SDiffStoreExecutor.java | 33 -
.../redis/executor/set/SInterExecutor.java | 49 -
.../redis/executor/set/SInterStoreExecutor.java | 34 -
.../redis/executor/set/SIsMemberExecutor.java | 62 -
.../redis/executor/set/SMembersExecutor.java | 56 -
.../redis/executor/set/SMoveExecutor.java | 72 -
.../redis/executor/set/SPopExecutor.java | 61 -
.../redis/executor/set/SRandMemberExecutor.java | 96 -
.../redis/executor/set/SRemExecutor.java | 63 -
.../redis/executor/set/SScanExecutor.java | 154 -
.../redis/executor/set/SUnionExecutor.java | 51 -
.../redis/executor/set/SUnionStoreExecutor.java | 34 -
.../redis/executor/set/SetExecutor.java | 23 -
.../redis/executor/set/SetOpExecutor.java | 109 -
.../executor/sortedset/SortedSetExecutor.java | 41 -
.../redis/executor/sortedset/ZAddExecutor.java | 88 -
.../redis/executor/sortedset/ZCardExecutor.java | 54 -
.../executor/sortedset/ZCountExecutor.java | 145 -
.../executor/sortedset/ZIncrByExecutor.java | 77 -
.../executor/sortedset/ZLexCountExecutor.java | 143 -
.../executor/sortedset/ZRangeByLexExecutor.java | 209 -
.../sortedset/ZRangeByScoreExecutor.java | 209 -
.../executor/sortedset/ZRangeExecutor.java | 125 -
.../redis/executor/sortedset/ZRankExecutor.java | 98 -
.../redis/executor/sortedset/ZRemExecutor.java | 64 -
.../sortedset/ZRemRangeByLexExecutor.java | 153 -
.../sortedset/ZRemRangeByRankExecutor.java | 121 -
.../sortedset/ZRemRangeByScoreExecutor.java | 143 -
.../sortedset/ZRevRangeByScoreExecutor.java | 33 -
.../executor/sortedset/ZRevRangeExecutor.java | 34 -
.../executor/sortedset/ZRevRankExecutor.java | 32 -
.../redis/executor/sortedset/ZScanExecutor.java | 161 -
.../executor/sortedset/ZScoreExecutor.java | 59 -
.../redis/executor/string/AppendExecutor.java | 69 -
.../redis/executor/string/BitCountExecutor.java | 97 -
.../redis/executor/string/BitOpExecutor.java | 153 -
.../redis/executor/string/BitPosExecutor.java | 134 -
.../redis/executor/string/DecrByExecutor.java | 110 -
.../redis/executor/string/DecrExecutor.java | 95 -
.../redis/executor/string/GetBitExecutor.java | 82 -
.../redis/executor/string/GetExecutor.java | 51 -
.../redis/executor/string/GetRangeExecutor.java | 98 -
.../redis/executor/string/GetSetExecutor.java | 59 -
.../redis/executor/string/IncrByExecutor.java | 107 -
.../executor/string/IncrByFloatExecutor.java | 122 -
.../redis/executor/string/IncrExecutor.java | 91 -
.../redis/executor/string/MGetExecutor.java | 73 -
.../redis/executor/string/MSetExecutor.java | 64 -
.../redis/executor/string/MSetNXExecutor.java | 88 -
.../redis/executor/string/PSetEXExecutor.java | 34 -
.../redis/executor/string/SetBitExecutor.java | 106 -
.../redis/executor/string/SetEXExecutor.java | 88 -
.../redis/executor/string/SetExecutor.java | 154 -
.../redis/executor/string/SetNXExecutor.java | 60 -
.../redis/executor/string/SetRangeExecutor.java | 96 -
.../redis/executor/string/StringExecutor.java | 45 -
.../redis/executor/string/StrlenExecutor.java | 56 -
.../executor/transactions/DiscardExecutor.java | 42 -
.../executor/transactions/ExecExecutor.java | 88 -
.../executor/transactions/MultiExecutor.java | 47 -
.../transactions/TransactionExecutor.java | 23 -
.../executor/transactions/UnwatchExecutor.java | 31 -
.../executor/transactions/WatchExecutor.java | 31 -
.../redis/org/apache/hadoop/fs/GlobPattern.java | 164 -
.../internal/security/AuthorizeRequest.java | 7 +-
.../internal/security/AuthorizeRequestPP.java | 2 +-
.../security/FilterPostAuthorization.java | 2 +-
.../security/FilterPreAuthorization.java | 2 +-
.../internal/security/GeodeSecurityUtil.java | 456 ++
.../security/shiro/CustomAuthRealm.java | 92 +
.../security/shiro/GeodePermissionResolver.java | 29 +
.../security/shiro/JMXShiroAuthenticator.java | 79 +
.../internal/security/shiro/ShiroPrincipal.java | 39 +
.../internal/sequencelog/EntryLogger.java | 13 +-
.../sequencelog/SequenceLoggerImpl.java | 33 +-
.../gemfire/internal/shared/NativeCalls.java | 41 +-
.../internal/shared/NativeCallsJNAImpl.java | 2 +-
.../internal/shared/NativeErrorException.java | 2 +-
.../internal/shared/TCPSocketOptions.java | 2 +-
.../gemfire/internal/size/ObjectGraphSizer.java | 10 +-
.../internal/statistics/CallbackSampler.java | 96 +
.../internal/statistics/CounterMonitor.java | 2 +-
.../internal/statistics/GaugeMonitor.java | 2 +-
.../statistics/IgnoreResourceException.java | 2 +-
.../MapBasedStatisticsNotification.java | 2 +-
.../internal/statistics/ResourceInstance.java | 2 +-
.../internal/statistics/ResourceType.java | 2 +-
.../internal/statistics/SampleCollector.java | 10 +-
.../internal/statistics/SampleHandler.java | 2 +-
.../internal/statistics/SimpleStatisticId.java | 2 +-
.../statistics/StatArchiveDescriptor.java | 2 +-
.../internal/statistics/StatArchiveHandler.java | 2 +-
.../statistics/StatArchiveHandlerConfig.java | 2 +-
.../internal/statistics/StatMonitorHandler.java | 22 +-
.../internal/statistics/StatisticId.java | 2 +-
.../statistics/StatisticNotFoundException.java | 2 +-
.../internal/statistics/StatisticsListener.java | 2 +-
.../internal/statistics/StatisticsMonitor.java | 2 +-
.../statistics/StatisticsNotification.java | 2 +-
.../internal/statistics/StatisticsSampler.java | 2 +-
.../internal/statistics/ValueMonitor.java | 2 +-
.../stats50/Atomic50StatisticsImpl.java | 4 +-
.../gemfire/internal/stats50/VMStats50.java | 25 +-
.../gemfire/internal/tcp/BaseMsgStreamer.java | 2 +-
.../internal/tcp/ByteBufferInputStream.java | 2 +-
.../gemfire/internal/tcp/ConnectExceptions.java | 2 +-
.../gemfire/internal/tcp/Connection.java | 115 +-
.../internal/tcp/ConnectionException.java | 2 +-
.../gemfire/internal/tcp/ConnectionTable.java | 6 +-
.../tcp/ImmutableByteBufferInputStream.java | 2 +-
.../gemfire/internal/tcp/MsgDestreamer.java | 2 +-
.../gemfire/internal/tcp/MsgIdGenerator.java | 2 +-
.../gemfire/internal/tcp/MsgOutputStream.java | 2 +-
.../gemfire/internal/tcp/MsgStreamer.java | 37 +-
.../gemfire/internal/tcp/MsgStreamerList.java | 2 +-
.../gemfire/internal/tcp/ServerDelegate.java | 2 +-
.../gemfire/internal/tcp/TCPConduit.java | 58 +-
.../tcp/VersionedByteBufferInputStream.java | 2 +-
.../internal/tcp/VersionedMsgStreamer.java | 2 +-
.../gemfire/internal/util/ArrayUtils.java | 2 +-
.../gemfire/internal/util/BlobHelper.java | 75 +-
.../gemfire/internal/util/Breadcrumbs.java | 10 +-
.../gemfire/internal/util/CollectionUtils.java | 8 +-
.../gemfire/internal/util/HostName.java | 71 +
.../gemstone/gemfire/internal/util/IOUtils.java | 2 +-
.../internal/util/JavaCommandBuilder.java | 4 +-
.../gemfire/internal/util/LogFileUtils.java | 2 +-
.../internal/util/StackTraceCollector.java | 2 +-
.../internal/util/SunAPINotFoundException.java | 2 +-
.../gemfire/internal/util/Versionable.java | 2 +-
.../CustomEntryConcurrentHashMap.java | 10 +-
.../concurrent/StoppableCountDownLatch.java | 9 +-
.../lang/AttachAPINotFoundException.java | 2 +-
.../com/gemstone/gemfire/lang/Identifiable.java | 2 +-
.../management/AlreadyRunningException.java | 2 +-
.../management/AsyncEventQueueMXBean.java | 6 +-
.../gemfire/management/CacheServerMXBean.java | 13 +-
.../gemfire/management/ClientHealthStatus.java | 2 +-
.../gemfire/management/ClientQueueDetail.java | 2 +-
.../DependenciesNotFoundException.java | 2 +-
.../gemfire/management/DiskBackupResult.java | 2 +-
.../gemfire/management/DiskBackupStatus.java | 2 +-
.../gemfire/management/DiskMetrics.java | 2 +-
.../gemfire/management/DiskStoreMXBean.java | 16 +-
.../DistributedLockServiceMXBean.java | 7 +-
.../management/DistributedRegionMXBean.java | 17 +-
.../management/DistributedSystemMXBean.java | 40 +-
.../management/EvictionAttributesData.java | 2 +-
.../FixedPartitionAttributesData.java | 2 +-
.../management/GatewayReceiverMXBean.java | 9 +-
.../gemfire/management/GatewaySenderMXBean.java | 13 +-
.../gemfire/management/GemFireProperties.java | 2 +-
.../gemfire/management/JMXNotificationType.java | 59 +-
.../management/JMXNotificationUserData.java | 2 +-
.../gemstone/gemfire/management/JVMMetrics.java | 2 +-
.../gemfire/management/LocatorMXBean.java | 6 +-
.../gemfire/management/LockServiceMXBean.java | 9 +-
.../gemfire/management/ManagementException.java | 2 +-
.../gemfire/management/ManagementService.java | 2 +-
.../gemfire/management/ManagerMXBean.java | 11 +-
.../gemfire/management/MemberMXBean.java | 24 +-
.../gemfire/management/NetworkMetrics.java | 2 +-
.../gemstone/gemfire/management/OSMetrics.java | 2 +-
.../management/PartitionAttributesData.java | 2 +-
.../management/PersistentMemberDetails.java | 2 +-
.../management/RegionAttributesData.java | 2 +-
.../gemfire/management/RegionMXBean.java | 17 +-
.../gemfire/management/ServerLoadData.java | 2 +-
.../gemfire/management/cli/CliMetaData.java | 9 +-
.../cli/CommandProcessingException.java | 2 +-
.../gemfire/management/cli/CommandService.java | 2 +-
.../management/cli/CommandServiceException.java | 2 +-
.../management/cli/CommandStatement.java | 2 +-
.../gemfire/management/cli/ConverterHint.java | 2 +-
.../gemstone/gemfire/management/cli/Result.java | 4 +-
.../gemfire/management/internal/AgentUtil.java | 12 +-
.../internal/BaseManagementService.java | 2 +-
.../management/internal/FederatingManager.java | 2 +-
.../management/internal/JettyHelper.java | 2 +-
.../management/internal/JmxManagerAdvisee.java | 12 +-
.../management/internal/JmxManagerAdvisor.java | 2 +-
.../internal/JmxManagerLocatorRequest.java | 2 +-
.../internal/JmxManagerLocatorResponse.java | 2 +-
.../management/internal/MBeanJMXAdapter.java | 5 +
.../management/internal/ManagementAgent.java | 113 +-
.../internal/ManagementConstants.java | 15 +-
.../gemfire/management/internal/Manager.java | 2 +-
.../gemfire/management/internal/RestAgent.java | 53 +-
.../gemfire/management/internal/SSLUtil.java | 2 +-
.../internal/SystemManagementService.java | 12 +-
.../internal/beans/BeanUtilFuncs.java | 16 +-
.../internal/beans/CacheServiceMBeanBase.java | 24 +
.../internal/beans/DistributedRegionBridge.java | 5 -
.../internal/beans/DistributedRegionMBean.java | 5 -
.../internal/beans/DistributedSystemBridge.java | 19 -
.../internal/beans/DistributedSystemMBean.java | 7 -
.../internal/beans/GatewaySenderMBean.java | 8 +-
.../internal/beans/HDFSRegionBridge.java | 173 -
.../internal/beans/ManagementAdapter.java | 30 +-
.../internal/beans/ManagementListener.java | 7 +-
.../management/internal/beans/MemberMBean.java | 5 -
.../internal/beans/MemberMBeanBridge.java | 127 +-
.../internal/beans/PartitionedRegionBridge.java | 13 +-
.../management/internal/beans/RegionMBean.java | 5 -
.../internal/beans/RegionMBeanBridge.java | 5 -
.../beans/stats/RegionClusterStatsMonitor.java | 7 -
.../cli/AbstractCliAroundInterceptor.java | 2 +-
.../internal/cli/CliAroundInterceptor.java | 2 +-
.../management/internal/cli/CliUtil.java | 34 +-
.../management/internal/cli/CommandManager.java | 61 +-
.../management/internal/cli/CommandRequest.java | 24 +-
.../internal/cli/CommandResponse.java | 2 +-
.../internal/cli/CommandResponseBuilder.java | 2 +-
.../internal/cli/CommandResponseWriter.java | 2 +-
.../internal/cli/GfshParseResult.java | 2 +-
.../management/internal/cli/GfshParser.java | 554 +-
.../management/internal/cli/Launcher.java | 11 +-
.../management/internal/cli/LogWrapper.java | 6 +-
.../internal/cli/annotation/CliArgument.java | 2 +-
.../cli/commands/AbstractCommandsSupport.java | 2 +-
.../internal/cli/commands/ClientCommands.java | 32 +-
.../internal/cli/commands/ConfigCommands.java | 33 +-
.../CreateAlterDestroyRegionCommands.java | 96 +-
.../internal/cli/commands/DataCommands.java | 77 +-
.../internal/cli/commands/DeployCommands.java | 16 +-
.../cli/commands/DiskStoreCommands.java | 57 +-
.../cli/commands/DurableClientCommands.java | 31 +-
...ExportImportSharedConfigurationCommands.java | 9 +-
.../internal/cli/commands/FunctionCommands.java | 25 +-
.../internal/cli/commands/GfshHelpCommands.java | 19 +-
.../internal/cli/commands/IndexCommands.java | 198 +-
.../cli/commands/LauncherLifecycleCommands.java | 1798 +++----
.../internal/cli/commands/MemberCommands.java | 21 +-
.../cli/commands/MiscellaneousCommands.java | 45 +-
.../internal/cli/commands/PDXCommands.java | 79 +-
.../internal/cli/commands/QueueCommands.java | 38 +-
.../internal/cli/commands/RegionCommands.java | 13 +-
.../internal/cli/commands/ShellCommands.java | 856 ++--
.../internal/cli/commands/StatusCommands.java | 18 +-
.../internal/cli/commands/WanCommands.java | 330 +-
.../cli/converters/BooleanConverter.java | 2 +-
.../ClusterMemberIdNameConverter.java | 2 +-
.../internal/cli/converters/DirConverter.java | 2 +-
.../cli/converters/DirPathConverter.java | 2 +-
.../cli/converters/DiskStoreNameConverter.java | 2 +-
.../internal/cli/converters/EnumConverter.java | 2 +-
.../cli/converters/FilePathConverter.java | 2 +-
.../cli/converters/FilePathStringConverter.java | 2 +-
.../converters/GatewaySenderIdConverter.java | 2 +-
.../internal/cli/converters/HelpConverter.java | 2 +-
.../cli/converters/HintTopicConverter.java | 2 +-
.../LocatorDiscoveryConfigConverter.java | 2 +-
.../cli/converters/LocatorIdNameConverter.java | 2 +-
.../cli/converters/LogLevelConverter.java | 2 +-
.../cli/converters/MemberGroupConverter.java | 2 +-
.../cli/converters/MemberIdNameConverter.java | 2 +-
.../cli/converters/RegionPathConverter.java | 2 +-
.../cli/converters/StringArrayConverter.java | 2 +-
.../cli/converters/StringListConverter.java | 2 +-
.../cli/domain/AsyncEventQueueDetails.java | 2 +-
.../cli/domain/ConnectToLocatorResult.java | 2 +-
.../internal/cli/domain/DiskStoreDetails.java | 2 +-
.../internal/cli/domain/IndexDetails.java | 2 +-
.../cli/domain/RegionAttributesInfo.java | 21 +-
.../cli/exceptions/CliCommandException.java | 37 +-
.../exceptions/CliCommandInvalidException.java | 16 +-
.../CliCommandMultiModeOptionException.java | 16 +-
.../CliCommandNotAvailableException.java | 12 +-
.../exceptions/CliCommandOptionException.java | 40 +-
...CommandOptionHasMultipleValuesException.java | 21 +-
.../CliCommandOptionInvalidException.java | 14 +-
.../CliCommandOptionMissingException.java | 21 +-
.../CliCommandOptionNotApplicableException.java | 24 +-
...liCommandOptionValueConversionException.java | 16 +-
.../CliCommandOptionValueException.java | 25 +-
.../CliCommandOptionValueMissingException.java | 24 +-
.../internal/cli/exceptions/CliException.java | 17 +-
.../exceptions/CreateSubregionException.java | 2 +-
.../cli/exceptions/ExceptionGenerator.java | 38 +-
.../cli/exceptions/ExceptionHandler.java | 77 +-
.../functions/AlterRuntimeConfigFunction.java | 8 +-
.../functions/AsyncEventQueueFunctionArgs.java | 134 +
.../cli/functions/ChangeLogLevelFunction.java | 15 +-
.../cli/functions/ContunuousQueryFunction.java | 2 +-
.../CreateAsyncEventQueueFunction.java | 56 +-
.../cli/functions/CreateDiskStoreFunction.java | 2 +-
.../cli/functions/DataCommandFunction.java | 45 +-
.../functions/DescribeDiskStoreFunction.java | 2 +-
.../functions/DescribeHDFSStoreFunction.java | 86 -
.../cli/functions/DestroyDiskStoreFunction.java | 2 +-
.../ExportSharedConfigurationFunction.java | 9 +-
.../FetchRegionAttributesFunction.java | 2 +-
.../GetMemberConfigInformationFunction.java | 23 +-
.../functions/GetMemberInformationFunction.java | 17 +-
.../functions/ListAsyncEventQueuesFunction.java | 2 +-
.../cli/functions/ListDiskStoresFunction.java | 2 +-
.../functions/ListDurableCqNamesFunction.java | 2 +-
.../cli/functions/ListIndexFunction.java | 2 +-
.../internal/cli/functions/LogFileFunction.java | 2 +-
.../cli/functions/MembersForRegionFunction.java | 2 +-
.../internal/cli/functions/NetstatFunction.java | 2 +-
.../cli/functions/RegionAlterFunction.java | 2 +-
.../cli/functions/RegionCreateFunction.java | 54 +-
.../cli/functions/RegionDestroyFunction.java | 2 +-
.../cli/functions/RegionFunctionArgs.java | 2 +-
.../cli/functions/ShutDownFunction.java | 52 +-
.../cli/functions/UserFunctionExecution.java | 2 +-
.../management/internal/cli/help/CliTopic.java | 34 +-
.../internal/cli/help/format/NewHelp.java | 2 +-
.../internal/cli/help/utils/HelpUtils.java | 16 +-
.../internal/cli/i18n/CliStrings.java | 308 +-
.../internal/cli/json/GfJsonArray.java | 2 +-
.../internal/cli/json/GfJsonException.java | 2 +-
.../internal/cli/json/GfJsonObject.java | 2 +-
.../cli/multistep/CLIMultiStepHelper.java | 22 +-
.../internal/cli/parser/Argument.java | 2 +-
.../internal/cli/parser/AvailabilityTarget.java | 2 +-
.../internal/cli/parser/CommandTarget.java | 2 +-
.../internal/cli/parser/GfshMethodTarget.java | 2 +-
.../internal/cli/parser/GfshOptionParser.java | 2 +-
.../internal/cli/parser/MethodParameter.java | 2 +-
.../management/internal/cli/parser/Option.java | 4 +-
.../internal/cli/parser/OptionSet.java | 2 +-
.../internal/cli/parser/Parameter.java | 2 +-
.../internal/cli/parser/ParserUtils.java | 2 +-
.../internal/cli/parser/SyntaxConstants.java | 2 +-
.../cli/parser/jopt/JoptOptionParser.java | 47 +-
.../preprocessor/EnclosingCharacters.java | 2 +-
.../cli/parser/preprocessor/Preprocessor.java | 2 +-
.../parser/preprocessor/PreprocessorUtils.java | 2 +-
.../cli/parser/preprocessor/TrimmedInput.java | 2 +-
.../cli/remote/CommandExecutionContext.java | 2 +-
.../internal/cli/remote/CommandProcessor.java | 30 +-
.../cli/remote/CommandStatementImpl.java | 2 +-
.../cli/remote/RemoteExecutionStrategy.java | 2 +-
.../internal/cli/remote/WrapperThreadLocal.java | 2 +-
.../internal/cli/result/AbstractResultData.java | 2 +-
.../cli/result/CliJsonSerializable.java | 2 +-
.../cli/result/CliJsonSerializableIds.java | 2 +-
.../internal/cli/result/CommandResult.java | 2 +-
.../cli/result/CommandResultException.java | 2 +-
.../cli/result/CompositeResultData.java | 4 +-
.../internal/cli/result/ErrorResultData.java | 12 +-
.../internal/cli/result/FileResult.java | 2 +-
.../internal/cli/result/InfoResultData.java | 2 +-
.../internal/cli/result/ObjectResultData.java | 2 +-
.../internal/cli/result/ResultBuilder.java | 8 +-
.../internal/cli/result/ResultData.java | 2 +-
.../cli/result/ResultDataException.java | 2 +-
.../internal/cli/result/TableBuilder.java | 4 +-
.../internal/cli/result/TabularResultData.java | 2 +-
.../management/internal/cli/shell/Gfsh.java | 52 +-
.../internal/cli/shell/GfshConfig.java | 13 +-
.../cli/shell/GfshExecutionStrategy.java | 232 +-
.../cli/shell/JMXConnectionException.java | 2 +-
.../cli/shell/JMXInvocationException.java | 2 +-
.../internal/cli/shell/JmxOperationInvoker.java | 120 +-
.../internal/cli/shell/OperationInvoker.java | 2 +-
.../internal/cli/shell/jline/ANSIHandler.java | 2 +-
.../internal/cli/shell/jline/GfshHistory.java | 14 +-
.../shell/jline/GfshUnsupportedTerminal.java | 2 +-
.../internal/cli/util/CauseFinder.java | 2 +-
.../cli/util/ClasspathScanLoadHelper.java | 4 +-
.../internal/cli/util/CommandStringBuilder.java | 2 +-
.../internal/cli/util/CommentSkipHelper.java | 11 +-
.../internal/cli/util/DiskStoreCompacter.java | 2 +-
.../cli/util/DiskStoreNotFoundException.java | 2 +-
.../internal/cli/util/DiskStoreValidater.java | 2 +-
.../internal/cli/util/GfshConsoleReader.java | 2 +-
.../cli/util/HDFSStoreNotFoundException.java | 47 -
.../internal/cli/util/HyphenFormatter.java | 92 +
.../cli/util/JConsoleNotFoundException.java | 2 +-
.../management/internal/cli/util/JsonUtil.java | 2 +-
.../cli/util/MemberNotFoundException.java | 2 +-
.../management/internal/cli/util/MergeLogs.java | 2 +-
.../internal/cli/util/ReadWriteFile.java | 2 +-
.../cli/util/RegionAttributesNames.java | 4 +-
.../internal/cli/util/RegionPath.java | 2 +-
.../cli/util/VisualVmNotFoundException.java | 2 +-
.../configuration/domain/CacheElement.java | 10 +-
.../configuration/domain/XmlEntity.java | 30 +-
.../configuration/utils/DtdResolver.java | 14 +-
.../configuration/utils/XmlConstants.java | 8 +-
.../internal/configuration/utils/XmlUtils.java | 18 +-
.../internal/configuration/utils/ZipUtils.java | 1 -
.../internal/messages/CompactRequest.java | 2 +-
.../internal/messages/CompactResponse.java | 2 +-
.../internal/security/AccessControl.java | 51 -
.../internal/security/AccessControlContext.java | 37 -
.../internal/security/AccessControlMBean.java | 41 +
.../internal/security/AccessControlMXBean.java | 6 +-
.../internal/security/CLIOperationContext.java | 138 -
.../internal/security/JMXOperationContext.java | 177 -
.../internal/security/JSONAuthorization.java | 308 --
.../internal/security/MBeanServerWrapper.java | 162 +-
.../security/ManagementInterceptor.java | 271 -
.../management/internal/security/Resource.java | 26 -
.../internal/security/ResourceConstants.java | 91 +-
.../internal/security/ResourceOperation.java | 14 +-
.../security/ResourceOperationContext.java | 203 -
.../controllers/AbstractCommandsController.java | 150 +-
.../AbstractMultiPartCommandsController.java | 2 +-
.../controllers/ClientCommandsController.java | 2 +-
.../controllers/ClusterCommandsController.java | 2 +-
.../controllers/ConfigCommandsController.java | 22 +-
.../web/controllers/DataCommandsController.java | 28 +-
.../controllers/DeployCommandsController.java | 2 +-
.../DiskStoreCommandsController.java | 16 +-
.../DurableClientCommandsController.java | 20 +-
.../controllers/FunctionCommandsController.java | 11 +-
.../controllers/IndexCommandsController.java | 2 +-
.../LauncherLifecycleCommandsController.java | 2 +-
.../controllers/MemberCommandsController.java | 2 +-
.../MiscellaneousCommandsController.java | 14 +-
.../web/controllers/PdxCommandsController.java | 2 +-
.../controllers/QueueCommandsController.java | 4 +-
.../controllers/RegionCommandsController.java | 2 +-
.../controllers/ShellCommandsController.java | 2 +-
.../web/controllers/WanCommandsController.java | 4 +-
.../EnvironmentVariablesHandlerInterceptor.java | 92 -
.../support/LoginHandlerInterceptor.java | 129 +
.../support/MemberMXBeanAdapter.java | 659 ---
.../management/internal/web/domain/Link.java | 2 +-
.../internal/web/domain/LinkIndex.java | 2 +-
.../web/domain/QueryParameterSource.java | 2 +-
.../internal/web/http/ClientHttpRequest.java | 11 +-
.../internal/web/http/HttpHeader.java | 2 +-
.../internal/web/http/HttpMethod.java | 2 +-
.../SerializableObjectHttpMessageConverter.java | 2 +-
.../web/http/support/SimpleHttpRequester.java | 106 +-
.../internal/web/io/MultipartFileAdapter.java | 2 +-
.../web/io/MultipartFileResourceAdapter.java | 2 +-
.../web/shell/AbstractHttpOperationInvoker.java | 101 +-
.../web/shell/HttpOperationInvoker.java | 2 +-
.../web/shell/MBeanAccessException.java | 2 +-
.../RestApiCallForCommandNotFoundException.java | 2 +-
.../web/shell/RestHttpOperationInvoker.java | 28 +-
.../web/shell/SimpleHttpOperationInvoker.java | 13 +-
.../shell/support/HttpInvocationHandler.java | 2 +-
.../shell/support/HttpMBeanProxyFactory.java | 2 +-
.../internal/web/util/ConvertUtils.java | 2 +-
.../management/internal/web/util/UriUtils.java | 2 +-
.../management/membership/ClientMembership.java | 2 +-
.../membership/ClientMembershipEvent.java | 2 +-
.../membership/ClientMembershipListener.java | 2 +-
.../ClientMembershipListenerAdapter.java | 2 +-
.../management/membership/MembershipEvent.java | 4 +-
.../membership/MembershipListener.java | 2 +-
.../UniversalMembershipListenerAdapter.java | 2 +-
.../com/gemstone/gemfire/pdx/FieldType.java | 2 +-
.../com/gemstone/gemfire/pdx/JSONFormatter.java | 103 +-
.../gemfire/pdx/NonPortableClassException.java | 2 +-
.../gemfire/pdx/PdxConfigurationException.java | 2 +-
.../pdx/PdxFieldAlreadyExistsException.java | 2 +-
.../pdx/PdxFieldDoesNotExistException.java | 2 +-
.../pdx/PdxFieldTypeMismatchException.java | 2 +-
.../gemfire/pdx/PdxInitializationException.java | 2 +-
.../com/gemstone/gemfire/pdx/PdxInstance.java | 4 +-
.../gemfire/pdx/PdxInstanceFactory.java | 8 +-
.../com/gemstone/gemfire/pdx/PdxReader.java | 2 +-
.../gemstone/gemfire/pdx/PdxSerializable.java | 2 +-
.../gemfire/pdx/PdxSerializationException.java | 2 +-
.../com/gemstone/gemfire/pdx/PdxSerializer.java | 2 +-
.../gemstone/gemfire/pdx/PdxUnreadFields.java | 2 +-
.../com/gemstone/gemfire/pdx/PdxWriter.java | 8 +-
.../pdx/ReflectionBasedAutoSerializer.java | 30 +-
.../gemfire/pdx/WritablePdxInstance.java | 2 +-
.../pdx/internal/AutoSerializableManager.java | 52 +-
.../gemstone/gemfire/pdx/internal/DataSize.java | 2 +-
.../gemfire/pdx/internal/InternalPdxReader.java | 2 +-
.../gemstone/gemfire/pdx/internal/PdxField.java | 2 +-
.../gemfire/pdx/internal/PdxInputStream.java | 2 +-
.../gemfire/pdx/internal/PdxInstanceEnum.java | 2 +-
.../pdx/internal/PdxInstanceInputStream.java | 2 +-
.../gemfire/pdx/internal/PdxReaderImpl.java | 5 +-
.../gemfire/pdx/internal/PdxString.java | 2 +-
.../gemstone/gemfire/pdx/internal/PdxType.java | 2 +-
.../gemfire/pdx/internal/PdxUnreadData.java | 2 +-
.../gemfire/pdx/internal/PdxWriterImpl.java | 24 +-
.../pdx/internal/TrackingPdxReaderImpl.java | 2 +-
.../gemfire/pdx/internal/TypeRegistry.java | 16 +-
.../gemfire/pdx/internal/UnreadPdxType.java | 2 +-
.../internal/WeakConcurrentIdentityHashMap.java | 2 +-
.../pdx/internal/json/PdxListHelper.java | 2 +-
.../gemfire/redis/GemFireRedisServer.java | 716 ---
.../gemfire/security/AccessControl.java | 17 +-
.../gemfire/security/AuthInitialize.java | 14 +-
.../security/AuthenticationFailedException.java | 2 +-
.../AuthenticationRequiredException.java | 2 +-
.../gemfire/security/Authenticator.java | 18 +-
.../security/GemFireSecurityException.java | 2 +-
.../security/NotAuthorizedException.java | 2 +-
.../message/GemFireParameterizedMessage.java | 554 --
.../GemFireParameterizedMessageFactory.java | 54 -
.../apache/geode/redis/GeodeRedisServer.java | 737 +++
.../geode/redis/internal/ByteArrayWrapper.java | 180 +
.../redis/internal/ByteToCommandDecoder.java | 188 +
.../org/apache/geode/redis/internal/Coder.java | 516 ++
.../apache/geode/redis/internal/Command.java | 149 +
.../geode/redis/internal/DoubleWrapper.java | 78 +
.../redis/internal/ExecutionHandlerContext.java | 379 ++
.../apache/geode/redis/internal/Executor.java | 37 +
.../apache/geode/redis/internal/Extendable.java | 32 +
.../internal/RedisCommandParserException.java | 44 +
.../geode/redis/internal/RedisCommandType.java | 2344 +++++++++
.../geode/redis/internal/RedisConstants.java | 202 +
.../geode/redis/internal/RedisDataType.java | 118 +
.../RedisDataTypeMismatchException.java | 38 +
.../redis/internal/RegionCreationException.java | 38 +
.../geode/redis/internal/RegionProvider.java | 552 ++
.../internal/executor/AbstractExecutor.java | 138 +
.../internal/executor/AbstractScanExecutor.java | 47 +
.../redis/internal/executor/AuthExecutor.java | 54 +
.../redis/internal/executor/DBSizeExecutor.java | 31 +
.../redis/internal/executor/DelExecutor.java | 55 +
.../redis/internal/executor/EchoExecutor.java | 40 +
.../redis/internal/executor/ExistsExecutor.java | 49 +
.../internal/executor/ExpirationExecutor.java | 41 +
.../internal/executor/ExpireAtExecutor.java | 93 +
.../redis/internal/executor/ExpireExecutor.java | 93 +
.../internal/executor/FlushAllExecutor.java | 49 +
.../redis/internal/executor/KeysExecutor.java | 70 +
.../redis/internal/executor/ListQuery.java | 53 +
.../internal/executor/PExpireAtExecutor.java | 32 +
.../internal/executor/PExpireExecutor.java | 32 +
.../redis/internal/executor/PTTLExecutor.java | 33 +
.../internal/executor/PersistExecutor.java | 52 +
.../redis/internal/executor/PingExecutor.java | 31 +
.../redis/internal/executor/QuitExecutor.java | 31 +
.../redis/internal/executor/ScanExecutor.java | 145 +
.../internal/executor/ShutDownExecutor.java | 28 +
.../redis/internal/executor/SortedSetQuery.java | 204 +
.../redis/internal/executor/TTLExecutor.java | 77 +
.../redis/internal/executor/TimeExecutor.java | 51 +
.../redis/internal/executor/TypeExecutor.java | 48 +
.../redis/internal/executor/UnkownExecutor.java | 31 +
.../internal/executor/hash/HDelExecutor.java | 67 +
.../internal/executor/hash/HExistsExecutor.java | 66 +
.../internal/executor/hash/HGetAllExecutor.java | 63 +
.../internal/executor/hash/HGetExecutor.java | 62 +
.../internal/executor/hash/HIncrByExecutor.java | 109 +
.../executor/hash/HIncrByFloatExecutor.java | 99 +
.../internal/executor/hash/HKeysExecutor.java | 63 +
.../internal/executor/hash/HLenExecutor.java | 57 +
.../internal/executor/hash/HMGetExecutor.java | 72 +
.../internal/executor/hash/HMSetExecutor.java | 62 +
.../internal/executor/hash/HScanExecutor.java | 163 +
.../internal/executor/hash/HSetExecutor.java | 78 +
.../internal/executor/hash/HSetNXExecutor.java | 33 +
.../internal/executor/hash/HValsExecutor.java | 62 +
.../internal/executor/hash/HashExecutor.java | 39 +
.../internal/executor/hll/HllExecutor.java | 38 +
.../internal/executor/hll/PFAddExecutor.java | 66 +
.../internal/executor/hll/PFCountExecutor.java | 70 +
.../internal/executor/hll/PFMergeExecutor.java | 74 +
.../redis/internal/executor/hll/Varint.java | 241 +
.../internal/executor/list/LIndexExecutor.java | 118 +
.../internal/executor/list/LInsertExecutor.java | 29 +
.../internal/executor/list/LLenExecutor.java | 58 +
.../internal/executor/list/LPopExecutor.java | 34 +
.../internal/executor/list/LPushExecutor.java | 34 +
.../internal/executor/list/LPushXExecutor.java | 34 +
.../internal/executor/list/LRangeExecutor.java | 113 +
.../internal/executor/list/LRemExecutor.java | 116 +
.../internal/executor/list/LSetExecutor.java | 108 +
.../internal/executor/list/LTrimExecutor.java | 123 +
.../internal/executor/list/ListExecutor.java | 149 +
.../internal/executor/list/PopExecutor.java | 150 +
.../internal/executor/list/PushExecutor.java | 54 +
.../internal/executor/list/PushXExecutor.java | 59 +
.../internal/executor/list/RPopExecutor.java | 34 +
.../internal/executor/list/RPushExecutor.java | 34 +
.../internal/executor/list/RPushXExecutor.java | 34 +
.../internal/executor/set/SAddExecutor.java | 60 +
.../internal/executor/set/SCardExecutor.java | 55 +
.../internal/executor/set/SDiffExecutor.java | 46 +
.../executor/set/SDiffStoreExecutor.java | 33 +
.../internal/executor/set/SInterExecutor.java | 49 +
.../executor/set/SInterStoreExecutor.java | 34 +
.../executor/set/SIsMemberExecutor.java | 62 +
.../internal/executor/set/SMembersExecutor.java | 56 +
.../internal/executor/set/SMoveExecutor.java | 72 +
.../internal/executor/set/SPopExecutor.java | 61 +
.../executor/set/SRandMemberExecutor.java | 96 +
.../internal/executor/set/SRemExecutor.java | 63 +
.../internal/executor/set/SScanExecutor.java | 154 +
.../internal/executor/set/SUnionExecutor.java | 51 +
.../executor/set/SUnionStoreExecutor.java | 34 +
.../internal/executor/set/SetExecutor.java | 23 +
.../internal/executor/set/SetOpExecutor.java | 109 +
.../executor/sortedset/SortedSetExecutor.java | 41 +
.../executor/sortedset/ZAddExecutor.java | 88 +
.../executor/sortedset/ZCardExecutor.java | 54 +
.../executor/sortedset/ZCountExecutor.java | 145 +
.../executor/sortedset/ZIncrByExecutor.java | 77 +
.../executor/sortedset/ZLexCountExecutor.java | 143 +
.../executor/sortedset/ZRangeByLexExecutor.java | 209 +
.../sortedset/ZRangeByScoreExecutor.java | 209 +
.../executor/sortedset/ZRangeExecutor.java | 125 +
.../executor/sortedset/ZRankExecutor.java | 98 +
.../executor/sortedset/ZRemExecutor.java | 64 +
.../sortedset/ZRemRangeByLexExecutor.java | 153 +
.../sortedset/ZRemRangeByRankExecutor.java | 121 +
.../sortedset/ZRemRangeByScoreExecutor.java | 143 +
.../sortedset/ZRevRangeByScoreExecutor.java | 33 +
.../executor/sortedset/ZRevRangeExecutor.java | 34 +
.../executor/sortedset/ZRevRankExecutor.java | 32 +
.../executor/sortedset/ZScanExecutor.java | 161 +
.../executor/sortedset/ZScoreExecutor.java | 59 +
.../executor/string/AppendExecutor.java | 69 +
.../executor/string/BitCountExecutor.java | 97 +
.../internal/executor/string/BitOpExecutor.java | 153 +
.../executor/string/BitPosExecutor.java | 134 +
.../executor/string/DecrByExecutor.java | 110 +
.../internal/executor/string/DecrExecutor.java | 95 +
.../executor/string/GetBitExecutor.java | 82 +
.../internal/executor/string/GetExecutor.java | 51 +
.../executor/string/GetRangeExecutor.java | 98 +
.../executor/string/GetSetExecutor.java | 59 +
.../executor/string/IncrByExecutor.java | 107 +
.../executor/string/IncrByFloatExecutor.java | 122 +
.../internal/executor/string/IncrExecutor.java | 91 +
.../internal/executor/string/MGetExecutor.java | 73 +
.../internal/executor/string/MSetExecutor.java | 64 +
.../executor/string/MSetNXExecutor.java | 88 +
.../executor/string/PSetEXExecutor.java | 34 +
.../executor/string/SetBitExecutor.java | 106 +
.../internal/executor/string/SetEXExecutor.java | 89 +
.../internal/executor/string/SetExecutor.java | 155 +
.../internal/executor/string/SetNXExecutor.java | 60 +
.../executor/string/SetRangeExecutor.java | 96 +
.../executor/string/StringExecutor.java | 45 +
.../executor/string/StrlenExecutor.java | 56 +
.../executor/transactions/DiscardExecutor.java | 42 +
.../executor/transactions/ExecExecutor.java | 88 +
.../executor/transactions/MultiExecutor.java | 47 +
.../transactions/TransactionExecutor.java | 23 +
.../executor/transactions/UnwatchExecutor.java | 31 +
.../executor/transactions/WatchExecutor.java | 31 +
.../org/apache/hadoop/fs/GlobPattern.java | 164 +
.../apache/geode/security/GeodePermission.java | 126 +
.../apache/geode/security/PostProcessor.java | 58 +
.../apache/geode/security/SecurityManager.java | 71 +
.../security/templates/SamplePostProcessor.java | 53 +
.../templates/SampleSecurityManager.java | 297 ++
.../geode.apache.org/schema/cache/cache-1.0.xsd | 32 +-
.../membership/gms/messenger/jgroups-mcast.xml | 194 +-
.../internal/i18n/StringIdResourceBundle_ja.txt | 2 +-
.../src/test/java/cacheRunner/Portfolio.java | 2 +-
.../src/test/java/cacheRunner/Position.java | 2 +-
.../src/test/java/com/company/app/Customer.java | 2 +-
.../src/test/java/com/company/app/DBLoader.java | 2 +-
.../com/company/app/OrdersCacheListener.java | 2 +-
.../java/com/company/data/DatabaseLoader.java | 2 +-
.../java/com/company/data/MyDeclarable.java | 2 +-
.../src/test/java/com/company/data/MySizer.java | 2 +-
.../com/company/data/MyTransactionListener.java | 2 +-
.../src/test/java/com/examples/LinkNode.java | 2 +-
.../src/test/java/com/examples/SuperClass.java | 2 +-
.../src/test/java/com/examples/TestObject.java | 2 +-
.../com/examples/ds/PutDataSerializables.java | 2 +-
.../com/gemstone/gemfire/CopyJUnitTest.java | 16 +-
.../com/gemstone/gemfire/DeltaTestImpl.java | 12 +-
.../gemfire/DiskInstantiatorsJUnitTest.java | 25 +-
.../com/gemstone/gemfire/GemFireTestCase.java | 18 +-
.../com/gemstone/gemfire/JUnitTestSetup.java | 143 -
.../gemfire/JtaNoninvolvementJUnitTest.java | 30 +-
.../gemfire/LocalStatisticsJUnitTest.java | 16 +-
.../com/gemstone/gemfire/LonerDMJUnitTest.java | 43 +-
.../gemfire/SystemFailureJUnitTest.java | 1 +
.../com/gemstone/gemfire/TXExpiryJUnitTest.java | 55 +-
.../java/com/gemstone/gemfire/TXJUnitTest.java | 138 +-
.../com/gemstone/gemfire/TXWriterTestCase.java | 30 +-
.../gemstone/gemfire/TestDataSerializer.java | 2 -
.../com/gemstone/gemfire/TimingTestCase.java | 77 -
.../com/gemstone/gemfire/UnitTestDoclet.java | 2 +-
.../BindDistributedSystemJUnitTest.java | 31 +-
.../internal/CacheHealthEvaluatorJUnitTest.java | 2 +-
.../internal/DistributedSystemTestCase.java | 15 +-
.../admin/internal/HealthEvaluatorTestCase.java | 13 +-
.../MemberHealthEvaluatorJUnitTest.java | 2 +-
.../cache/AttributesFactoryJUnitTest.java | 33 +-
.../gemfire/cache/Bug36619JUnitTest.java | 77 -
.../gemfire/cache/Bug52289JUnitTest.java | 88 -
.../gemfire/cache/CacheListenerJUnitTest.java | 26 +-
.../cache/CacheRegionClearStatsDUnitTest.java | 43 +-
.../cache/ClientServerTimeSyncDUnitTest.java | 48 +-
.../cache/ConnectionPoolAndLoaderDUnitTest.java | 172 +-
.../cache/ConnectionPoolAutoDUnitTest.java | 7 +-
.../gemfire/cache/ConnectionPoolDUnitTest.java | 215 +-
.../cache/ConnectionPoolFactoryJUnitTest.java | 26 +-
...alStaticArrayShouldNotCauseSegFaultTest.java | 86 +
...MembershipAttributesAreSerializableTest.java | 74 +
.../gemfire/cache/OperationJUnitTest.java | 96 +-
.../gemfire/cache/PoolManagerJUnitTest.java | 26 +-
.../gemstone/gemfire/cache/ProxyJUnitTest.java | 27 +-
.../gemfire/cache/RegionFactoryJUnitTest.java | 58 +-
.../gemfire/cache/RoleExceptionJUnitTest.java | 26 +-
...ventQueueEvictionAndExpirationJUnitTest.java | 475 ++
.../SerialAsyncEventQueueImplJUnitTest.java | 14 +-
.../client/ClientCacheFactoryJUnitTest.java | 83 +-
.../client/ClientRegionFactoryJUnitTest.java | 48 +-
.../ClientServerRegisterInterestsDUnitTest.java | 28 +-
.../internal/AutoConnectionSourceDUnitTest.java | 413 +-
.../AutoConnectionSourceImplJUnitTest.java | 60 +-
.../CacheServerSSLConnectionDUnitTest.java | 101 +-
.../internal/ConnectionPoolImplJUnitTest.java | 27 +-
.../internal/LocatorLoadBalancingDUnitTest.java | 487 +-
.../cache/client/internal/LocatorTestBase.java | 430 +-
.../internal/OpExecutorImplJUnitTest.java | 175 +-
.../client/internal/QueueManagerJUnitTest.java | 46 +-
.../internal/SSLNoClientAuthDUnitTest.java | 63 +-
.../internal/ServerBlackListJUnitTest.java | 25 +-
.../locator/LocatorStatusResponseJUnitTest.java | 3 +-
.../pooling/ConnectionManagerJUnitTest.java | 73 +-
.../cache/execute/FunctionAdapterJUnitTest.java | 65 +
.../SignalledFlushObserverJUnitTest.java | 97 -
.../SortedListForAsyncQueueJUnitTest.java | 564 --
.../management/MXMemoryPoolListenerExample.java | 34 +-
.../management/MemoryThresholdsDUnitTest.java | 97 +-
.../MemoryThresholdsOffHeapDUnitTest.java | 145 +-
.../management/ResourceManagerDUnitTest.java | 59 +-
.../ExceptionHandlingJUnitTest.java | 34 +-
.../mapInterface/MapFunctionalJUnitTest.java | 28 +-
.../mapInterface/PutAllGlobalLockJUnitTest.java | 17 +-
.../PutOperationContextJUnitTest.java | 57 +-
.../GetOperationContextImplJUnitTest.java | 63 +-
.../PartitionRegionHelperDUnitTest.java | 23 +-
.../BaseLineAndCompareQueryPerfJUnitTest.java | 1 -
.../query/Bug32947ValueConstraintJUnitTest.java | 29 +-
.../gemfire/cache/query/CacheUtils.java | 27 +-
.../cache/query/PdxStringQueryJUnitTest.java | 26 +-
.../gemfire/cache/query/QueryJUnitTest.java | 113 +-
.../cache/query/QueryServiceJUnitTest.java | 7 +-
.../gemfire/cache/query/QueryTestUtils.java | 254 +-
.../cache/query/QueryTestUtilsJUnitTest.java | 1 +
.../gemfire/cache/query/RegionJUnitTest.java | 16 +-
.../com/gemstone/gemfire/cache/query/Utils.java | 38 +
.../query/dunit/CloseCacheAuthorization.java | 11 +-
.../query/dunit/CompactRangeIndexDUnitTest.java | 21 +-
.../cache/query/dunit/CompiledInDUnitTest.java | 701 +++
.../cache/query/dunit/GroupByDUnitImpl.java | 32 +-
.../dunit/GroupByPartitionedQueryDUnitTest.java | 13 +-
.../query/dunit/GroupByQueryDUnitTest.java | 16 +-
.../cache/query/dunit/HashIndexDUnitTest.java | 16 +-
.../cache/query/dunit/HelperTestCase.java | 25 +-
.../dunit/NonDistinctOrderByDUnitImpl.java | 25 +-
.../NonDistinctOrderByPartitionedDUnitTest.java | 13 +-
...itionedRegionCompactRangeIndexDUnitTest.java | 17 +-
.../query/dunit/PdxStringQueryDUnitTest.java | 380 +-
.../cache/query/dunit/QueryAuthorization.java | 18 +-
.../dunit/QueryDataInconsistencyDUnitTest.java | 40 +-
.../dunit/QueryIndexUsingXMLDUnitTest.java | 79 +-
.../QueryParamsAuthorizationDUnitTest.java | 36 +-
.../QueryUsingFunctionContextDUnitTest.java | 80 +-
.../query/dunit/QueryUsingPoolDUnitTest.java | 2667 ++++------
.../cache/query/dunit/RemoteQueryDUnitTest.java | 100 +-
...esourceManagerWithQueryMonitorDUnitTest.java | 87 +-
.../query/dunit/SelectStarQueryDUnitTest.java | 216 +-
.../query/functional/ConstantsJUnitTest.java | 21 +-
.../query/functional/CountStarJUnitTest.java | 518 +-
.../CustomerOptimizationsJUnitTest.java | 23 +-
...ctResultsWithDupValuesInRegionJUnitTest.java | 29 +-
.../query/functional/FunctionJUnitTest.java | 10 +-
.../query/functional/INOperatorJUnitTest.java | 5 +-
.../IUMRCompositeIteratorJUnitTest.java | 5 +-
.../IUMRMultiIndexesMultiRegionJUnitTest.java | 12 +-
.../IUMRShuffleIteratorsJUnitTest.java | 369 +-
.../functional/IUMRSingleRegionJUnitTest.java | 46 +-
.../IndexCreationDeadLockJUnitTest.java | 79 +-
.../functional/IndexCreationJUnitTest.java | 1426 +++---
.../IndexMaintenanceAsynchJUnitTest.java | 2 +-
.../functional/IndexOnEntrySetJUnitTest.java | 33 +-
.../IndexUsageWithAliasAsProjAtrbt.java | 176 -
...IndexUsageWithAliasAsProjAtrbtJUnitTest.java | 92 +-
.../functional/JavaSerializationJUnitTest.java | 17 +-
.../functional/LikePredicateJUnitTest.java | 42 +-
.../query/functional/LimitClauseJUnitTest.java | 13 +-
.../cache/query/functional/MiscJUnitTest.java | 305 +-
.../MultiRegionIndexUsageJUnitTest.java | 92 +-
.../NegativeNumberQueriesJUnitTest.java | 26 +-
.../query/functional/NestedQueryJUnitTest.java | 88 +-
.../NonDistinctOrderByReplicatedJUnitTest.java | 4 +-
.../NonDistinctOrderByTestImplementation.java | 16 +-
.../query/functional/NumericQueryJUnitTest.java | 15 +-
.../functional/OrderByReplicatedJUnitTest.java | 4 +-
.../functional/OrderByTestImplementation.java | 16 +-
.../query/functional/PdxOrderByJUnitTest.java | 2 +-
.../QueryREUpdateInProgressJUnitTest.java | 15 +-
.../functional/QueryUndefinedJUnitTest.java | 24 +-
.../ResultsDataSerializabilityJUnitTest.java | 5 +-
.../query/functional/SelectToDateJUnitTest.java | 35 +-
.../query/functional/StructSetOrResultsSet.java | 86 +-
.../query/functional/TestNewFunctionSSorRS.java | 128 -
.../TestNewFunctionSSorRSIntegrationTest.java | 128 +
.../CompiledAggregateFunctionJUnitTest.java | 28 +-
.../query/internal/CompiledInJUnitTest.java | 72 +-
.../CompiledJunctionInternalsJUnitTest.java | 9 +-
.../internal/NWayMergeResultsJUnitTest.java | 37 +-
.../query/internal/QCompilerJUnitTest.java | 5 +-
...ueryFromClauseCanonicalizationJUnitTest.java | 6 +-
.../QueryObjectSerializationJUnitTest.java | 48 +-
.../query/internal/ResultsBagJUnitTest.java | 52 +-
.../ResultsBagLimitBehaviourJUnitTest.java | 38 +-
.../ResultsCollectionWrapperLimitJUnitTest.java | 29 +-
.../SelectResultsComparatorJUnitTest.java | 24 +-
.../StructBagLimitBehaviourJUnitTest.java | 23 +-
.../query/internal/StructSetJUnitTest.java | 15 +-
.../internal/aggregate/AggregatorJUnitTest.java | 23 +-
...syncIndexUpdaterThreadShutdownJUnitTest.java | 22 +-
.../index/AsynchIndexMaintenanceJUnitTest.java | 81 +-
.../CompactRangeIndexIndexMapJUnitTest.java | 34 +-
.../index/CompactRangeIndexJUnitTest.java | 72 +-
...rrentIndexInitOnOverflowRegionDUnitTest.java | 46 +-
...ndexOperationsOnOverflowRegionDUnitTest.java | 126 +-
...pdateWithInplaceObjectModFalseDUnitTest.java | 74 +-
...ConcurrentIndexUpdateWithoutWLDUnitTest.java | 83 +-
.../index/CopyOnReadIndexDUnitTest.java | 25 +-
.../index/CopyOnReadIndexJUnitTest.java | 24 +-
.../DeclarativeIndexCreationJUnitTest.java | 40 +-
.../internal/index/EquiJoinIntegrationTest.java | 437 ++
.../query/internal/index/EquijoinDUnitTest.java | 437 --
.../internal/index/HashIndexSetJUnitTest.java | 192 +-
.../internal/index/IndexElemArrayJUnitTest.java | 24 +-
.../internal/index/IndexHintJUnitTest.java | 33 +-
.../index/IndexMaintainceJUnitTest.java | 5 +-
.../index/IndexMaintenanceJUnitTest.java | 16 +-
.../index/IndexStatisticsJUnitTest.java | 12 +-
.../IndexTrackingQueryObserverDUnitTest.java | 24 +-
.../IndexTrackingQueryObserverJUnitTest.java | 33 +-
...itializeIndexEntryDestroyQueryDUnitTest.java | 129 +-
.../index/MemoryIndexStoreJUnitTest.java | 698 ++-
...exStoreWithInplaceModificationJUnitTest.java | 45 +-
.../index/MultiIndexCreationDUnitTest.java | 17 +-
.../NewDeclarativeIndexCreationJUnitTest.java | 33 +-
...artitionedRegionEquiJoinIntegrationTest.java | 130 +
.../PartitionedRegionEquijoinDUnitTest.java | 130 -
.../index/PdxCopyOnReadQueryJUnitTest.java | 11 +-
...gRegionCreationIndexUpdateTypeJUnitTest.java | 22 +-
.../index/PutAllWithIndexPerfDUnitTest.java | 24 +-
.../PRBasicIndexCreationDUnitTest.java | 349 +-
.../PRBasicIndexCreationDeadlockDUnitTest.java | 63 +-
.../PRBasicMultiIndexCreationDUnitTest.java | 310 +-
.../partitioned/PRBasicQueryDUnitTest.java | 53 +-
.../PRBasicRemoveIndexDUnitTest.java | 82 +-
.../PRColocatedEquiJoinDUnitTest.java | 136 +-
.../partitioned/PRInvalidQueryDUnitTest.java | 41 +-
.../partitioned/PRQueryCacheCloseDUnitTest.java | 68 +-
.../query/partitioned/PRQueryDUnitHelper.java | 792 +--
.../query/partitioned/PRQueryDUnitTest.java | 120 +-
.../query/partitioned/PRQueryPerfDUnitTest.java | 504 --
.../PRQueryRegionCloseDUnitTest.java | 43 +-
.../PRQueryRegionDestroyedDUnitTest.java | 51 +-
.../PRQueryRemoteNodeExceptionDUnitTest.java | 75 +-
.../query/transaction/QueryAndJtaJUnitTest.java | 6 +-
.../internal/ConnectionCountProbeJUnitTest.java | 22 +-
.../snapshot/ParallelSnapshotDUnitTest.java | 18 +-
.../cache/snapshot/RegionSnapshotJUnitTest.java | 40 +-
.../snapshot/SnapshotByteArrayDUnitTest.java | 17 +-
.../cache/snapshot/SnapshotDUnitTest.java | 19 +-
.../snapshot/SnapshotPerformanceDUnitTest.java | 17 +-
.../cache/snapshot/SnapshotTestCase.java | 23 +-
.../cache/util/PasswordUtilJUnitTest.java | 11 +-
.../gemfire/cache30/Bug34387DUnitTest.java | 20 +-
.../gemfire/cache30/Bug34948DUnitTest.java | 19 +-
.../gemfire/cache30/Bug35214DUnitTest.java | 19 +-
.../gemfire/cache30/Bug38013DUnitTest.java | 19 +-
.../gemfire/cache30/Bug38741DUnitTest.java | 27 +-
.../gemfire/cache30/Bug40255JUnitTest.java | 36 +-
.../gemfire/cache30/Bug40662JUnitTest.java | 28 +-
.../gemfire/cache30/Bug44418JUnitTest.java | 171 +-
.../gemfire/cache30/CacheCloseDUnitTest.java | 19 +-
.../gemfire/cache30/CacheListenerTestCase.java | 22 +-
.../gemfire/cache30/CacheLoaderTestCase.java | 33 +-
.../gemfire/cache30/CacheLogRollDUnitTest.java | 179 +-
.../gemfire/cache30/CacheMapTxnDUnitTest.java | 60 +-
...cheRegionsReliablityStatsCheckDUnitTest.java | 197 +-
.../cache30/CacheSerializableRunnable.java | 30 +-
.../cache30/CacheStatisticsDUnitTest.java | 26 +-
.../gemstone/gemfire/cache30/CacheTestCase.java | 10 +-
.../gemfire/cache30/CacheWriterTestCase.java | 21 +-
.../gemfire/cache30/CacheXml30DUnitTest.java | 69 +-
.../gemfire/cache30/CacheXml40DUnitTest.java | 35 +-
.../gemfire/cache30/CacheXml41DUnitTest.java | 48 +-
.../gemfire/cache30/CacheXml45DUnitTest.java | 73 +-
.../gemfire/cache30/CacheXml51DUnitTest.java | 41 +-
.../gemfire/cache30/CacheXml55DUnitTest.java | 12 +-
.../gemfire/cache30/CacheXml57DUnitTest.java | 71 +-
.../gemfire/cache30/CacheXml58DUnitTest.java | 32 +-
.../gemfire/cache30/CacheXml60DUnitTest.java | 37 +-
.../gemfire/cache30/CacheXml61DUnitTest.java | 42 +-
.../gemfire/cache30/CacheXml65DUnitTest.java | 99 +-
.../gemfire/cache30/CacheXml66DUnitTest.java | 19 +-
.../gemfire/cache30/CacheXml70DUnitTest.java | 45 +-
.../gemfire/cache30/CacheXml80DUnitTest.java | 20 +-
.../gemfire/cache30/CacheXml81DUnitTest.java | 27 +-
.../cache30/CacheXmlGeode10DUnitTest.java | 122 +-
.../gemfire/cache30/CacheXmlTestCase.java | 17 +-
.../cache30/CachedAllEventsDUnitTest.java | 2 +-
.../gemfire/cache30/CallbackArgDUnitTest.java | 20 +-
.../cache30/ClearMultiVmCallBkDUnitTest.java | 88 +-
.../gemfire/cache30/ClearMultiVmDUnitTest.java | 33 +-
.../cache30/ClientMembershipDUnitTest.java | 1027 ++--
.../ClientMembershipSelectorDUnitTest.java | 11 +-
.../ClientRegisterInterestDUnitTest.java | 46 +-
...ClientRegisterInterestSelectorDUnitTest.java | 11 +-
.../cache30/ClientServerCCEDUnitTest.java | 39 +-
.../gemfire/cache30/ClientServerTestCase.java | 16 +-
.../ConcurrentLeaveDuringGIIDUnitTest.java | 104 +-
...ibutedNoAckAsyncOverflowRegionDUnitTest.java | 21 +-
...iskDistributedNoAckAsyncRegionDUnitTest.java | 22 +-
.../DiskDistributedNoAckRegionTestCase.java | 22 +-
...ributedNoAckSyncOverflowRegionDUnitTest.java | 23 +-
.../gemfire/cache30/DiskRegionDUnitTest.java | 41 +-
.../gemfire/cache30/DiskRegionTestImpl.java | 14 +-
.../cache30/DistAckMapMethodsDUnitTest.java | 53 +-
...istributedAckOverflowRegionCCEDUnitTest.java | 18 +-
...tedAckOverflowRegionCCEOffHeapDUnitTest.java | 17 +-
...tributedAckPersistentRegionCCEDUnitTest.java | 143 +-
...dAckPersistentRegionCCEOffHeapDUnitTest.java | 18 +-
.../DistributedAckRegionCCEDUnitTest.java | 175 +-
...DistributedAckRegionCCEOffHeapDUnitTest.java | 21 +-
...istributedAckRegionCompressionDUnitTest.java | 14 +-
.../cache30/DistributedAckRegionDUnitTest.java | 27 +-
.../DistributedAckRegionOffHeapDUnitTest.java | 21 +-
.../DistributedMulticastRegionDUnitTest.java | 89 +-
.../DistributedNoAckRegionCCEDUnitTest.java | 107 +-
...stributedNoAckRegionCCEOffHeapDUnitTest.java | 17 +-
.../DistributedNoAckRegionDUnitTest.java | 50 +-
.../DistributedNoAckRegionOffHeapDUnitTest.java | 17 +-
.../gemfire/cache30/DynamicRegionDUnitTest.java | 19 +-
.../gemfire/cache30/GlobalLockingDUnitTest.java | 27 +-
.../cache30/GlobalRegionCCEDUnitTest.java | 71 +-
.../GlobalRegionCCEOffHeapDUnitTest.java | 18 +-
.../gemfire/cache30/GlobalRegionDUnitTest.java | 17 +-
.../cache30/GlobalRegionOffHeapDUnitTest.java | 31 +-
.../cache30/LRUEvictionControllerDUnitTest.java | 27 +-
.../gemfire/cache30/LocalRegionDUnitTest.java | 19 +-
.../MemLRUEvictionControllerDUnitTest.java | 26 +-
.../gemfire/cache30/MultiVMRegionTestCase.java | 2068 ++++----
.../OffHeapLRUEvictionControllerDUnitTest.java | 19 +-
.../PRBucketSynchronizationDUnitTest.java | 19 +-
.../PartitionedRegionCompressionDUnitTest.java | 16 +-
.../cache30/PartitionedRegionDUnitTest.java | 179 +-
...tionedRegionMembershipListenerDUnitTest.java | 16 +-
.../PartitionedRegionOffHeapDUnitTest.java | 21 +-
.../cache30/PreloadedRegionTestCase.java | 17 +-
.../gemfire/cache30/ProxyDUnitTest.java | 21 +-
.../cache30/PutAllCallBkRemoteVMDUnitTest.java | 29 +-
.../cache30/PutAllCallBkSingleVMDUnitTest.java | 21 +-
.../gemfire/cache30/PutAllMultiVmDUnitTest.java | 34 +-
.../gemfire/cache30/QueueMsgDUnitTest.java | 54 +-
.../cache30/RRSynchronizationDUnitTest.java | 54 +-
.../gemfire/cache30/ReconnectDUnitTest.java | 405 +-
.../ReconnectedCacheServerDUnitTest.java | 26 +-
.../cache30/RegionAttributesTestCase.java | 18 +-
.../cache30/RegionExpirationDUnitTest.java | 25 +-
.../RegionMembershipListenerDUnitTest.java | 28 +-
.../RegionReliabilityDistAckDUnitTest.java | 16 +-
.../RegionReliabilityDistNoAckDUnitTest.java | 16 +-
.../RegionReliabilityGlobalDUnitTest.java | 16 +-
.../RegionReliabilityListenerDUnitTest.java | 20 +-
.../cache30/RegionReliabilityTestCase.java | 57 +-
.../gemfire/cache30/RegionTestCase.java | 83 +-
.../gemfire/cache30/ReliabilityTestCase.java | 25 +-
.../cache30/RemoveAllMultiVmDUnitTest.java | 30 +-
.../gemfire/cache30/RequiredRolesDUnitTest.java | 28 +-
.../cache30/RolePerformanceDUnitTest.java | 187 -
.../gemfire/cache30/SearchAndLoadDUnitTest.java | 31 +-
.../gemfire/cache30/SlowRecDUnitTest.java | 182 +-
.../gemfire/cache30/TXDistributedDUnitTest.java | 41 +-
.../gemfire/cache30/TXOrderDUnitTest.java | 60 +-
.../cache30/TXRestrictionsDUnitTest.java | 16 +-
.../gemfire/cache30/TestCacheCallback.java | 2 +-
.../gemfire/cache30/TestCacheListener.java | 8 +-
.../gemfire/cache30/TestCacheLoader.java | 2 +-
.../gemfire/cache30/TestCacheWriter.java | 2 +-
.../gemfire/cache30/TestDiskRegion.java | 2 +-
.../cache30/TestTransactionListener.java | 2 +-
.../AnalyzeSerializablesJUnitTest.java | 21 +-
.../codeAnalysis/ClassAndMethodDetails.java | 42 +-
.../AbstractLauncherIntegrationJUnitTest.java | 71 -
.../AbstractLauncherIntegrationTest.java | 71 +
.../AbstractLauncherIntegrationTestCase.java | 250 +
.../distributed/AbstractLauncherJUnitTest.java | 298 --
.../AbstractLauncherJUnitTestCase.java | 254 -
.../AbstractLauncherServiceStatusJUnitTest.java | 264 -
.../AbstractLauncherServiceStatusTest.java | 259 +
.../distributed/AbstractLauncherTest.java | 297 ++
...tractLocatorLauncherIntegrationTestCase.java | 132 +
.../AbstractLocatorLauncherJUnitTestCase.java | 105 -
...ocatorLauncherRemoteIntegrationTestCase.java | 67 +
...stractServerLauncherIntegrationTestCase.java | 95 +
.../AbstractServerLauncherJUnitTestCase.java | 93 -
...ServerLauncherRemoteIntegrationTestCase.java | 95 +
.../distributed/DistributedLockBlackboard.java | 37 +
.../DistributedLockBlackboardImpl.java | 97 +
.../DistributedLockServiceDUnitTest.java | 3278 ++++++++++++
.../distributed/DistributedMemberDUnitTest.java | 63 +-
.../DistributedSystemConnectPerf.java | 13 +-
.../distributed/DistributedSystemDUnitTest.java | 119 +-
.../distributed/DistributedTestSuite.java | 35 -
.../distributed/HostedLocatorsDUnitTest.java | 163 +-
.../LauncherMemberMXBeanIntegrationTest.java | 148 +
.../LauncherMemberMXBeanJUnitTest.java | 152 -
.../gemfire/distributed/LauncherTestSuite.java | 47 -
.../gemfire/distributed/LocatorDUnitTest.java | 812 ++-
.../gemfire/distributed/LocatorJUnitTest.java | 155 +-
.../LocatorLauncherIntegrationJUnitTest.java | 248 -
.../LocatorLauncherIntegrationTest.java | 249 +
.../distributed/LocatorLauncherJUnitTest.java | 341 --
...LocatorLauncherLocalFileIntegrationTest.java | 58 +
.../LocatorLauncherLocalFileJUnitTest.java | 51 -
.../LocatorLauncherLocalIntegrationTest.java | 836 +++
.../LocatorLauncherLocalJUnitTest.java | 842 ---
...ocatorLauncherRemoteFileIntegrationTest.java | 223 +
.../LocatorLauncherRemoteFileJUnitTest.java | 218 -
.../LocatorLauncherRemoteIntegrationTest.java | 1014 ++++
.../LocatorLauncherRemoteJUnitTest.java | 1004 ----
...rRemoteWithCustomLoggingIntegrationTest.java | 129 +
.../distributed/LocatorLauncherTest.java | 340 ++
.../distributed/LocatorStateJUnitTest.java | 208 -
.../gemfire/distributed/LocatorStateTest.java | 222 +
.../MockServerLauncherCacheProvider.java | 8 +-
.../gemfire/distributed/RoleDUnitTest.java | 42 +-
.../ServerLauncherIntegrationJUnitTest.java | 312 --
.../ServerLauncherIntegrationTest.java | 312 ++
.../distributed/ServerLauncherJUnitTest.java | 903 ----
.../ServerLauncherLocalFileIntegrationTest.java | 54 +
.../ServerLauncherLocalFileJUnitTest.java | 54 -
.../ServerLauncherLocalIntegrationTest.java | 1074 ++++
.../ServerLauncherLocalJUnitTest.java | 1073 ----
...ServerLauncherRemoteFileIntegrationTest.java | 222 +
.../ServerLauncherRemoteFileJUnitTest.java | 222 -
.../ServerLauncherRemoteIntegrationTest.java | 1368 +++++
.../ServerLauncherRemoteJUnitTest.java | 1425 ------
...rRemoteWithCustomLoggingIntegrationTest.java | 122 +
.../gemfire/distributed/ServerLauncherTest.java | 894 ++++
...rverLauncherWithProviderIntegrationTest.java | 88 +
.../ServerLauncherWithProviderJUnitTest.java | 90 -
.../distributed/SystemAdminDUnitTest.java | 18 +-
.../AtomicLongWithTerminalStateJUnitTest.java | 13 +-
.../distributed/internal/Bug40751DUnitTest.java | 35 +-
.../ConsoleDistributionManagerDUnitTest.java | 26 +-
.../internal/DistributionAdvisorDUnitTest.java | 21 +-
.../internal/DistributionConfigJUnitTest.java | 180 +-
.../internal/DistributionManagerDUnitTest.java | 97 +-
.../InternalDistributedSystemJUnitTest.java | 273 +-
.../gemfire/distributed/internal/LDM.java | 8 +-
.../LocatorLoadSnapshotIntegrationTest.java | 120 +
.../internal/LocatorLoadSnapshotJUnitTest.java | 102 +-
.../internal/ProductUseLogDUnitTest.java | 26 +-
.../internal/ProductUseLogJUnitTest.java | 105 +-
.../internal/ServerLocatorJUnitTest.java | 23 +-
.../internal/SharedConfigurationJUnitTest.java | 3 +-
.../internal/StartupMessageDataJUnitTest.java | 36 +-
.../DeadlockDetectorIntegrationTest.java | 299 ++
.../deadlock/DeadlockDetectorJUnitTest.java | 331 --
.../internal/deadlock/DeadlockDetectorTest.java | 140 +
.../deadlock/DependencyGraphJUnitTest.java | 24 +-
.../GemFireDeadlockDetectorDUnitTest.java | 32 +-
.../deadlock/UnsafeThreadLocalJUnitTest.java | 47 +-
.../internal/locks/CollaborationJUnitTest.java | 2 +-
.../internal/locks/DLockGrantorHelper.java | 2 +-
.../locks/DLockReentrantLockJUnitTest.java | 14 +-
.../membership/MembershipJUnitTest.java | 77 +-
.../internal/membership/NetViewJUnitTest.java | 53 +-
.../membership/gms/GMSMemberJUnitTest.java | 51 +-
.../membership/gms/MembershipManagerHelper.java | 2 +-
.../gms/auth/GMSAuthenticatorJUnitTest.java | 172 +-
.../gms/fd/GMSHealthMonitorJUnitTest.java | 76 +-
.../locator/GMSLocatorRecoveryJUnitTest.java | 27 +-
.../gms/membership/GMSJoinLeaveJUnitTest.java | 63 +-
.../gms/membership/GMSJoinLeaveTestHelper.java | 7 +-
.../gms/membership/StatRecorderJUnitTest.java | 95 +-
.../messenger/GMSQuorumCheckerJUnitTest.java | 172 +-
.../messenger/JGroupsMessengerJUnitTest.java | 23 +-
.../gms/mgr/GMSMembershipManagerJUnitTest.java | 134 +-
.../StreamingOperationManyDUnitTest.java | 20 +-
.../StreamingOperationOneDUnitTest.java | 16 +-
.../TcpServerBackwardCompatDUnitTest.java | 45 +-
.../internal/tcpserver/TcpServerJUnitTest.java | 53 +-
.../support/DistributedSystemAdapter.java | 2 +-
.../gemfire/disttx/CacheMapDistTXDUnitTest.java | 19 +-
.../gemfire/disttx/DistTXDebugDUnitTest.java | 3 +-
.../gemfire/disttx/DistTXExpiryJUnitTest.java | 15 +-
.../gemfire/disttx/DistTXJUnitTest.java | 22 +-
.../disttx/DistTXManagerImplJUnitTest.java | 18 +-
.../gemfire/disttx/DistTXOrderDUnitTest.java | 25 +-
.../DistTXReleasesOffHeapOnCloseJUnitTest.java | 19 +-
.../disttx/DistTXRestrictionsDUnitTest.java | 15 +-
.../disttx/DistTXWithDeltaDUnitTest.java | 14 +-
.../gemfire/disttx/DistTXWriterJUnitTest.java | 14 +-
.../disttx/DistTXWriterOOMEJUnitTest.java | 14 +-
.../disttx/DistributedTransactionDUnitTest.java | 87 +-
.../gemfire/disttx/PRDistTXDUnitTest.java | 37 +-
.../gemfire/disttx/PRDistTXJUnitTest.java | 19 +-
.../disttx/PRDistTXWithVersionsDUnitTest.java | 34 +-
...entPartitionedRegionWithDistTXDUnitTest.java | 18 +-
.../internal/AbstractConfigJUnitTest.java | 136 +-
.../gemfire/internal/ArrayEqualsJUnitTest.java | 193 -
.../internal/AvailablePortJUnitTest.java | 21 +-
...wardCompatibilitySerializationDUnitTest.java | 25 +-
.../gemfire/internal/Bug49856JUnitTest.java | 8 +-
.../gemfire/internal/Bug51616JUnitTest.java | 21 +-
.../gemfire/internal/ByteArrayData.java | 2 +-
.../gemstone/gemfire/internal/ClassBuilder.java | 17 +-
.../ClassNotFoundExceptionDUnitTest.java | 18 +-
.../ClassPathLoaderIntegrationTest.java | 503 ++
.../internal/ClassPathLoaderJUnitTest.java | 1261 -----
.../gemfire/internal/ClassPathLoaderTest.java | 890 ++++
.../gemfire/internal/ConfigSourceJUnitTest.java | 9 +-
.../internal/CopyOnWriteHashSetJUnitTest.java | 17 +-
.../internal/DataSerializableJUnitTest.java | 778 +--
.../gemfire/internal/FileUtilJUnitTest.java | 7 +-
.../internal/GemFireStatSamplerJUnitTest.java | 69 +-
.../GemFireVersionIntegrationJUnitTest.java | 19 +-
.../internal/GemFireVersionJUnitTest.java | 16 +-
.../internal/HeapDataOutputStreamJUnitTest.java | 17 +-
.../gemfire/internal/InlineKeyJUnitTest.java | 32 +-
.../gemfire/internal/JSSESocketJUnitTest.java | 249 +-
.../internal/JarClassLoaderJUnitTest.java | 58 +-
.../gemfire/internal/JarDeployerDUnitTest.java | 26 +-
.../gemfire/internal/LineWrapUnitJUnitTest.java | 13 +-
.../internal/LocalStatisticsImplJUnitTest.java | 139 +
.../gemfire/internal/NanoTimerJUnitTest.java | 33 +-
.../gemfire/internal/ObjIdMapJUnitTest.java | 29 +-
.../internal/OneTaskOnlyDecoratorJUnitTest.java | 22 +-
.../internal/PdxDeleteFieldDUnitTest.java | 35 +-
.../internal/PdxDeleteFieldJUnitTest.java | 48 +-
.../gemfire/internal/PdxRenameDUnitTest.java | 33 +-
.../gemfire/internal/PdxRenameJUnitTest.java | 36 +-
.../PutAllOperationContextJUnitTest.java | 14 +-
...lityShouldUseArrayEqualsIntegrationTest.java | 195 +
.../internal/SSLConfigIntegrationJUnitTest.java | 12 +-
.../gemfire/internal/SSLConfigJUnitTest.java | 683 ++-
...hreadPoolExecutorWithKeepAliveJUnitTest.java | 18 +-
.../internal/SimpleStatSamplerJUnitTest.java | 2 +-
.../gemfire/internal/SocketCloserJUnitTest.java | 6 +-
.../internal/SocketCloserWithWaitJUnitTest.java | 1 +
.../StatArchiveWriterReaderJUnitTest.java | 18 +-
.../gemfire/internal/StatSamplerJUnitTest.java | 105 +-
.../gemfire/internal/StatSamplerTestCase.java | 2 +-
.../internal/UniqueIdGeneratorJUnitTest.java | 20 +-
.../AbstractDistributedRegionJUnitTest.java | 8 +-
.../internal/cache/AbstractRegionJUnitTest.java | 4 +-
.../internal/cache/AbstractRegionMapTest.java | 23 +-
.../gemfire/internal/cache/BackupDUnitTest.java | 27 +-
.../gemfire/internal/cache/BackupJUnitTest.java | 59 +-
.../internal/cache/BucketRegionJUnitTest.java | 32 +-
.../internal/cache/Bug33359DUnitTest.java | 24 +-
.../internal/cache/Bug33726DUnitTest.java | 21 +-
.../internal/cache/Bug33726JUnitTest.java | 23 +-
.../Bug34179TooManyFilesOpenJUnitTest.java | 77 +-
.../internal/cache/Bug34583JUnitTest.java | 22 +-
.../internal/cache/Bug37241DUnitTest.java | 28 +-
.../internal/cache/Bug37244JUnitTest.java | 35 +-
.../internal/cache/Bug37377DUnitTest.java | 30 +-
.../internal/cache/Bug39079DUnitTest.java | 468 +-
.../internal/cache/Bug40299DUnitTest.java | 35 +-
.../internal/cache/Bug40632DUnitTest.java | 78 +-
.../internal/cache/Bug41091DUnitTest.java | 46 +-
.../internal/cache/Bug41733DUnitTest.java | 33 +-
.../internal/cache/Bug41957DUnitTest.java | 24 +-
.../internal/cache/Bug42055DUnitTest.java | 17 +-
.../internal/cache/Bug45164DUnitTest.java | 17 +-
.../internal/cache/Bug45934DUnitTest.java | 26 +-
.../internal/cache/Bug47667DUnitTest.java | 57 +-
.../internal/cache/Bug48182JUnitTest.java | 26 +-
.../internal/cache/CacheAdvisorDUnitTest.java | 29 +-
.../cache/CacheLifecycleListenerJUnitTest.java | 49 +-
.../internal/cache/CacheServiceJUnitTest.java | 17 +-
.../internal/cache/ClearDAckDUnitTest.java | 34 +-
.../internal/cache/ClearGlobalDUnitTest.java | 28 +-
...ssagesRegionCreationAndDestroyJUnitTest.java | 30 +-
.../cache/ClientServerGetAllDUnitTest.java | 40 +-
...ServerInvalidAndDestroyedEntryDUnitTest.java | 34 +-
.../ClientServerTransactionCCEDUnitTest.java | 14 +-
.../cache/ClientServerTransactionDUnitTest.java | 514 +-
.../gemfire/internal/cache/CommitFunction.java | 142 +
.../cache/ComplexDiskRegionJUnitTest.java | 34 +-
.../ConcurrentDestroySubRegionDUnitTest.java | 18 +-
...entFlushingAndRegionOperationsJUnitTest.java | 38 +-
.../cache/ConcurrentMapLocalJUnitTest.java | 14 +-
.../cache/ConcurrentMapOpsDUnitTest.java | 99 +-
.../ConcurrentRegionOperationsJUnitTest.java | 40 +-
...rentRollingAndRegionOperationsJUnitTest.java | 173 +-
.../internal/cache/ConflationJUnitTest.java | 159 +-
.../cache/ConnectDisconnectDUnitTest.java | 55 +-
.../internal/cache/DeltaFaultInDUnitTest.java | 19 +-
.../cache/DeltaPropagationDUnitTest.java | 69 +-
.../cache/DeltaPropagationStatsDUnitTest.java | 50 +-
.../internal/cache/DeltaSizingDUnitTest.java | 26 +-
.../gemfire/internal/cache/DiskIdJUnitTest.java | 51 +-
.../internal/cache/DiskInitFileJUnitTest.java | 35 +-
.../cache/DiskOfflineCompactionJUnitTest.java | 75 +-
.../internal/cache/DiskOldAPIsJUnitTest.java | 59 +-
...iskRandomOperationsAndRecoveryJUnitTest.java | 38 +-
.../cache/DiskRegByteArrayDUnitTest.java | 60 +-
.../cache/DiskRegCacheXmlJUnitTest.java | 87 +-
.../DiskRegCachexmlGeneratorJUnitTest.java | 389 +-
.../internal/cache/DiskRegCbkChkJUnitTest.java | 38 +-
.../DiskRegOplogSwtchingAndRollerJUnitTest.java | 130 +-
.../cache/DiskRegRecoveryJUnitTest.java | 217 +-
.../cache/DiskRegionAsyncRecoveryJUnitTest.java | 14 +-
...RegionChangingRegionAttributesJUnitTest.java | 51 +-
.../cache/DiskRegionClearJUnitTest.java | 155 +-
.../DiskRegionIllegalArguementsJUnitTest.java | 41 +-
...iskRegionIllegalCacheXMLvaluesJUnitTest.java | 57 +-
.../internal/cache/DiskRegionJUnitTest.java | 979 ++--
.../internal/cache/DiskRegionProperties.java | 2 +-
.../internal/cache/DiskRegionTestingBase.java | 144 +-
.../cache/DiskStoreFactoryJUnitTest.java | 57 +-
.../cache/DiskWriteAttributesJUnitTest.java | 99 +-
...DistrbutedRegionProfileOffHeapDUnitTest.java | 36 +-
.../cache/DistributedCacheTestCase.java | 37 +-
.../cache/DistributedRegionJUnitTest.java | 29 +-
.../internal/cache/EntryEventImplTest.java | 385 ++
.../cache/EnumListenerEventJUnitTest.java | 22 +-
.../internal/cache/EventTrackerDUnitTest.java | 44 +-
.../internal/cache/EvictionDUnitTest.java | 58 +-
.../cache/EvictionObjectSizerDUnitTest.java | 21 +-
.../internal/cache/EvictionStatsDUnitTest.java | 26 +-
.../internal/cache/EvictionTestBase.java | 21 +-
.../internal/cache/FaultingInJUnitTest.java | 77 +-
.../cache/FixedPRSinglehopDUnitTest.java | 86 +-
.../internal/cache/GIIDeltaDUnitTest.java | 96 +-
.../internal/cache/GIIFlowControlDUnitTest.java | 28 +-
.../internal/cache/GemFireCacheImplTest.java | 67 +
.../internal/cache/GridAdvisorDUnitTest.java | 1356 ++---
.../HAOverflowMemObjectSizerDUnitTest.java | 31 +-
.../cache/IncrementalBackupDUnitTest.java | 27 +-
.../cache/InterruptClientServerDUnitTest.java | 29 +-
.../internal/cache/InterruptDiskJUnitTest.java | 44 +-
...InterruptsConserveSocketsFalseDUnitTest.java | 19 +-
.../internal/cache/InterruptsDUnitTest.java | 28 +-
.../internal/cache/IteratorDUnitTest.java | 18 +-
.../LIFOEvictionAlgoEnabledRegionJUnitTest.java | 46 +-
...victionAlgoMemoryEnabledRegionJUnitTest.java | 46 +-
.../internal/cache/LocalDataSetTest.java | 66 +
.../internal/cache/MapClearGIIDUnitTest.java | 86 +-
.../internal/cache/MapInterfaceJUnitTest.java | 75 +-
.../internal/cache/MockCacheServiceImpl.java | 6 +
.../MultipleOplogsRollingFeatureJUnitTest.java | 110 +-
.../cache/NestedTransactionFunction.java | 116 +
.../cache/NetSearchMessagingDUnitTest.java | 32 +-
.../cache/OffHeapEvictionDUnitTest.java | 27 +-
.../cache/OffHeapEvictionStatsDUnitTest.java | 23 +-
.../gemfire/internal/cache/OffHeapTestUtil.java | 8 +-
.../cache/OffHeapValueWrapperJUnitTest.java | 9 +-
.../cache/OfflineSnapshotJUnitTest.java | 22 +-
.../gemfire/internal/cache/OldVLJUnitTest.java | 19 +-
.../cache/OldValueImporterTestBase.java | 17 +-
.../cache/OplogEntryIdMapJUnitTest.java | 12 +-
.../cache/OplogEntryIdSetJUnitTest.java | 12 +-
.../gemfire/internal/cache/OplogJUnitTest.java | 136 +-
.../internal/cache/OplogRVVJUnitTest.java | 32 +-
.../cache/OrderedTombstoneMapJUnitTest.java | 10 +-
.../cache/P2PDeltaPropagationDUnitTest.java | 39 +-
.../internal/cache/PRBadToDataDUnitTest.java | 17 +-
.../cache/PRConcurrentMapOpsJUnitTest.java | 27 +-
.../cache/PRDataStoreMemoryJUnitTest.java | 23 +-
.../PRDataStoreMemoryOffHeapJUnitTest.java | 15 +-
.../cache/PartitionAttributesImplJUnitTest.java | 11 +-
.../cache/PartitionListenerDUnitTest.java | 17 +-
...dRegionAPIConserveSocketsFalseDUnitTest.java | 26 +-
.../cache/PartitionedRegionAPIDUnitTest.java | 23 +-
.../PartitionedRegionAsSubRegionDUnitTest.java | 17 +-
...gionBucketCreationDistributionDUnitTest.java | 43 +-
.../PartitionedRegionCacheCloseDUnitTest.java | 17 +-
...rtitionedRegionCacheLoaderForRootRegion.java | 18 +-
...artitionedRegionCacheLoaderForSubRegion.java | 17 +-
...rtitionedRegionCacheXMLExampleDUnitTest.java | 31 +-
.../PartitionedRegionCreationDUnitTest.java | 69 +-
.../cache/PartitionedRegionDUnitTestCase.java | 27 +-
.../PartitionedRegionDataStoreJUnitTest.java | 40 +-
...rtitionedRegionDelayedRecoveryDUnitTest.java | 41 +-
.../PartitionedRegionDestroyDUnitTest.java | 17 +-
.../PartitionedRegionEntryCountDUnitTest.java | 17 +-
.../PartitionedRegionEvictionDUnitTest.java | 39 +-
.../cache/PartitionedRegionHADUnitTest.java | 17 +-
...onedRegionHAFailureAndRecoveryDUnitTest.java | 17 +-
.../cache/PartitionedRegionHelperJUnitTest.java | 15 +-
.../PartitionedRegionInvalidateDUnitTest.java | 19 +-
...artitionedRegionLocalMaxMemoryDUnitTest.java | 19 +-
...nedRegionLocalMaxMemoryOffHeapDUnitTest.java | 17 +-
.../PartitionedRegionMultipleDUnitTest.java | 17 +-
...rtitionedRegionOffHeapEvictionDUnitTest.java | 20 +-
.../cache/PartitionedRegionPRIDDUnitTest.java | 15 +-
.../cache/PartitionedRegionQueryDUnitTest.java | 28 +-
.../PartitionedRegionQueryEvaluatorTest.java | 69 +-
...artitionedRegionRedundancyZoneDUnitTest.java | 64 +-
...tionedRegionSerializableObjectJUnitTest.java | 51 +-
.../PartitionedRegionSingleHopDUnitTest.java | 639 +--
...RegionSingleHopWithServerGroupDUnitTest.java | 233 +-
...onedRegionSingleNodeOperationsJUnitTest.java | 12 +-
.../cache/PartitionedRegionSizeDUnitTest.java | 18 +-
.../cache/PartitionedRegionStatsDUnitTest.java | 19 +-
.../cache/PartitionedRegionStatsJUnitTest.java | 44 +-
.../cache/PartitionedRegionTestHelper.java | 32 +-
.../PartitionedRegionTestUtilsDUnitTest.java | 54 +-
.../PartitionedRegionWithSameNameDUnitTest.java | 24 +-
.../PersistentPartitionedRegionJUnitTest.java | 27 +-
.../internal/cache/PutAllDAckDUnitTest.java | 25 +-
.../internal/cache/PutAllGlobalDUnitTest.java | 27 +-
.../cache/RegionEntryFlagsJUnitTest.java | 9 +-
.../internal/cache/RegionListenerJUnitTest.java | 22 +-
.../cache/RemoteOperationMessageTest.java | 110 +
.../cache/RemoteTransactionCCEDUnitTest.java | 17 +-
.../cache/RemoteTransactionDUnitTest.java | 134 +-
.../internal/cache/RemoveAllDAckDUnitTest.java | 22 +-
.../internal/cache/RemoveDAckDUnitTest.java | 28 +-
.../internal/cache/RemoveGlobalDUnitTest.java | 28 +-
.../internal/cache/RollbackFunction.java | 137 +
.../internal/cache/RunCacheInOldGemfire.java | 187 -
.../cache/SearchLoadAndWriteProcessorTest.java | 67 +
.../cache/SimpleDiskRegionJUnitTest.java | 24 +-
.../internal/cache/SingleHopStatsDUnitTest.java | 449 +-
.../internal/cache/SizingFlagDUnitTest.java | 35 +-
.../internal/cache/SystemFailureDUnitTest.java | 158 +-
.../internal/cache/TXManagerImplJUnitTest.java | 37 +-
.../internal/cache/TXManagerImplTest.java | 335 ++
.../cache/TXReservationMgrJUnitTest.java | 24 +-
.../gemfire/internal/cache/TestDelta.java | 112 +-
.../cache/TombstoneCreationJUnitTest.java | 50 +-
.../cache/TransactionsWithDeltaDUnitTest.java | 35 +-
.../internal/cache/UpdateVersionJUnitTest.java | 40 +-
.../gemfire/internal/cache/VLJUnitTest.java | 35 +-
.../cache/control/FilterByPathJUnitTest.java | 24 +-
.../cache/control/MemoryMonitorJUnitTest.java | 19 +-
.../control/MemoryMonitorOffHeapJUnitTest.java | 34 +-
.../control/MemoryThresholdsJUnitTest.java | 7 +-
.../control/RebalanceOperationDUnitTest.java | 252 +-
...skRegOverflowAsyncGetInMemPerfJUnitTest.java | 40 +-
...iskRegOverflowAsyncJUnitPerformanceTest.java | 55 +-
...lowSyncGetInMemPerfJUnitPerformanceTest.java | 53 +-
...DiskRegOverflowSyncJUnitPerformanceTest.java | 65 +-
...egionOverflowAsyncRollingOpLogJUnitTest.java | 67 +-
...RegionOverflowSyncRollingOpLogJUnitTest.java | 14 +-
.../DiskRegionPerfJUnitPerformanceTest.java | 78 +-
.../DiskRegionPersistOnlySyncJUnitTest.java | 43 +-
...DiskRegionRollOpLogJUnitPerformanceTest.java | 90 +-
...ltiThreadedOplogPerJUnitPerformanceTest.java | 30 +-
.../cache/execute/Bug51193DUnitTest.java | 47 +-
.../ClientServerFunctionExecutionDUnitTest.java | 29 +-
.../execute/ColocationFailoverDUnitTest.java | 19 +-
...ributedRegionFunctionExecutionDUnitTest.java | 83 +-
.../FunctionExecution_ExceptionDUnitTest.java | 23 +-
.../cache/execute/FunctionServiceBase.java | 287 ++
.../FunctionServiceLocalPRDUnitTest.java | 54 +
.../FunctionServiceLocalRRDUnitTest.java | 52 +
...unctionServiceMultipleOnMemberDUnitTest.java | 57 +
.../FunctionServicePeerAccessorPRDUnitTest.java | 73 +
.../FunctionServicePeerAccessorRRDUnitTest.java | 63 +
.../FunctionServiceSingleOnMemberDUnitTest.java | 49 +
.../execute/FunctionServiceStatsDUnitTest.java | 60 +-
.../cache/execute/LocalDataSetDUnitTest.java | 25 +-
.../execute/LocalDataSetIndexingDUnitTest.java | 17 +-
.../LocalFunctionExecutionDUnitTest.java | 23 +-
.../MemberFunctionExecutionDUnitTest.java | 41 +-
.../MultiRegionFunctionExecutionDUnitTest.java | 27 +-
.../OnGroupsFunctionExecutionDUnitTest.java | 69 +-
...ntServerFunctionExecutionNoAckDUnitTest.java | 16 +-
...tServerRegionFunctionExecutionDUnitTest.java | 48 +-
...egionFunctionExecutionFailoverDUnitTest.java | 61 +-
...onFunctionExecutionNoSingleHopDUnitTest.java | 44 +-
...onExecutionSelectorNoSingleHopDUnitTest.java | 35 +-
...gionFunctionExecutionSingleHopDUnitTest.java | 83 +-
.../cache/execute/PRClientServerTestBase.java | 21 +-
.../cache/execute/PRColocationDUnitTest.java | 38 +-
.../execute/PRCustomPartitioningDUnitTest.java | 58 +-
.../execute/PRFunctionExecutionDUnitTest.java | 171 +-
.../PRFunctionExecutionTimeOutDUnitTest.java | 38 +-
...ctionExecutionWithResultSenderDUnitTest.java | 22 +-
.../execute/PRPerformanceTestDUnitTest.java | 19 +-
.../cache/execute/PRTransactionDUnitTest.java | 41 +-
.../PRTransactionWithVersionsDUnitTest.java | 14 +-
.../cache/execute/PerformanceTestFunction.java | 10 +-
.../execute/SingleHopGetAllPutAllDUnitTest.java | 16 +-
.../SimpleExtensionPointJUnitTest.java | 44 +-
.../extension/mock/AbstractMockExtension.java | 9 +-
.../mock/AbstractMockExtensionXmlGenerator.java | 2 +-
.../mock/AlterMockCacheExtensionFunction.java | 4 +-
.../mock/AlterMockRegionExtensionFunction.java | 4 +-
.../mock/CreateMockCacheExtensionFunction.java | 5 +-
.../mock/CreateMockRegionExtensionFunction.java | 9 +-
.../mock/DestroyMockCacheExtensionFunction.java | 4 +-
.../DestroyMockRegionExtensionFunction.java | 4 +-
.../extension/mock/MockCacheExtension.java | 2 +-
.../mock/MockCacheExtensionXmlGenerator.java | 2 +-
.../extension/mock/MockExtensionCommands.java | 33 +-
.../extension/mock/MockExtensionXmlParser.java | 2 +-
.../extension/mock/MockRegionExtension.java | 2 +-
.../mock/MockRegionExtensionXmlGenerator.java | 2 +-
.../internal/cache/functions/TestFunction.java | 4 +-
.../cache/ha/BlockingHARegionJUnitTest.java | 521 +-
.../ha/BlockingHARegionQueueJUnitTest.java | 5 +-
.../cache/ha/Bug36853EventsExpiryDUnitTest.java | 64 +-
.../internal/cache/ha/Bug48571DUnitTest.java | 89 +-
.../internal/cache/ha/Bug48879DUnitTest.java | 33 +-
.../cache/ha/EventIdOptimizationDUnitTest.java | 58 +-
.../cache/ha/EventIdOptimizationJUnitTest.java | 129 +-
.../internal/cache/ha/FailoverDUnitTest.java | 61 +-
.../internal/cache/ha/HABugInPutDUnitTest.java | 48 +-
.../internal/cache/ha/HAClearDUnitTest.java | 50 +-
.../cache/ha/HAConflationDUnitTest.java | 51 +-
.../internal/cache/ha/HADuplicateDUnitTest.java | 48 +-
.../cache/ha/HAEventIdPropagationDUnitTest.java | 92 +-
.../internal/cache/ha/HAExpiryDUnitTest.java | 22 +-
.../internal/cache/ha/HAGIIBugDUnitTest.java | 36 +-
.../internal/cache/ha/HAGIIDUnitTest.java | 143 +-
.../cache/ha/HARQAddOperationJUnitTest.java | 168 +-
.../cache/ha/HARQueueNewImplDUnitTest.java | 291 +-
.../internal/cache/ha/HARegionDUnitTest.java | 34 +-
.../internal/cache/ha/HARegionJUnitTest.java | 147 +-
.../cache/ha/HARegionQueueDUnitTest.java | 487 +-
.../cache/ha/HARegionQueueJUnitTest.java | 660 +--
.../ha/HARegionQueueStartStopJUnitTest.java | 22 +-
.../cache/ha/HARegionQueueStatsJUnitTest.java | 25 +-
.../cache/ha/HASlowReceiverDUnitTest.java | 41 +-
.../ha/OperationsPropagationDUnitTest.java | 131 +-
.../internal/cache/ha/PutAllDUnitTest.java | 39 +-
.../internal/cache/ha/StatsBugDUnitTest.java | 50 +-
.../cache/ha/ThreadIdentifierJUnitTest.java | 14 +-
.../cache/locks/TXLockServiceDUnitTest.java | 43 +-
.../internal/cache/lru/LRUClockJUnitTest.java | 267 +-
.../cache/lru/TransactionsWithOverflowTest.java | 7 +-
.../cache/partitioned/Bug39356DUnitTest.java | 25 +-
.../cache/partitioned/Bug43684DUnitTest.java | 54 +-
.../cache/partitioned/Bug47388DUnitTest.java | 54 +-
.../cache/partitioned/Bug51400DUnitTest.java | 55 +-
.../partitioned/ElidedPutAllDUnitTest.java | 17 +-
.../FetchEntriesMessageJUnitTest.java | 14 +-
.../OfflineMembersDetailsJUnitTest.java | 11 +-
.../cache/partitioned/PartitionMessageTest.java | 115 +
.../partitioned/PartitionResolverDUnitTest.java | 31 +-
.../PartitionedRegionLoadModelJUnitTest.java | 121 +-
.../PartitionedRegionLoaderWriterDUnitTest.java | 27 +-
...rtitionedRegionMetaDataCleanupDUnitTest.java | 19 +-
.../partitioned/PersistPRKRFDUnitTest.java | 15 +-
...tentColocatedPartitionedRegionDUnitTest.java | 47 +-
.../PersistentPartitionedRegionDUnitTest.java | 90 +-
...tentPartitionedRegionOldConfigDUnitTest.java | 20 +-
.../PersistentPartitionedRegionTestBase.java | 20 +-
...rtitionedRegionWithTransactionDUnitTest.java | 15 +-
.../cache/partitioned/ShutdownAllDUnitTest.java | 59 +-
...treamingPartitionOperationManyDUnitTest.java | 17 +-
...StreamingPartitionOperationOneDUnitTest.java | 17 +-
.../fixed/FixedPartitioningDUnitTest.java | 53 +-
.../fixed/FixedPartitioningTestBase.java | 40 +-
...ngWithColocationAndPersistenceDUnitTest.java | 26 +-
.../rebalance/BucketOperatorImplTest.java | 138 +
.../rebalance/BucketOperatorWrapperTest.java | 323 ++
.../persistence/BackupInspectorJUnitTest.java | 61 +-
.../PersistentRVVRecoveryDUnitTest.java | 41 +-
.../PersistentRecoveryOrderDUnitTest.java | 110 +-
...rsistentRecoveryOrderOldConfigDUnitTest.java | 14 +-
.../PersistentReplicatedTestBase.java | 23 +-
.../TemporaryResultSetFactoryJUnitTest.java | 44 +-
.../RegionEntryFactoryBuilderJUnitTest.java | 11 +-
.../GFSnapshotJUnitPerformanceTest.java | 32 +-
.../internal/cache/tier/Bug40396DUnitTest.java | 22 +-
.../tier/sockets/AcceptorImplJUnitTest.java | 157 +-
...mpatibilityHigherVersionClientDUnitTest.java | 38 +-
.../cache/tier/sockets/Bug36269DUnitTest.java | 70 +-
.../cache/tier/sockets/Bug36457DUnitTest.java | 28 +-
.../cache/tier/sockets/Bug36805DUnitTest.java | 33 +-
.../cache/tier/sockets/Bug36829DUnitTest.java | 97 +-
.../cache/tier/sockets/Bug36995DUnitTest.java | 75 +-
.../cache/tier/sockets/Bug37210DUnitTest.java | 39 +-
.../cache/tier/sockets/Bug37805DUnitTest.java | 39 +-
.../CacheServerMaxConnectionsJUnitTest.java | 117 +-
.../cache/tier/sockets/CacheServerTestUtil.java | 314 +-
.../CacheServerTransactionsDUnitTest.java | 66 +-
...acheServerTransactionsSelectorDUnitTest.java | 14 +-
.../tier/sockets/ClearPropagationDUnitTest.java | 43 +-
.../tier/sockets/ClientConflationDUnitTest.java | 43 +-
.../sockets/ClientHealthMonitorJUnitTest.java | 31 +-
.../sockets/ClientInterestNotifyDUnitTest.java | 108 +-
.../ClientServerForceInvalidateDUnitTest.java | 87 +-
.../tier/sockets/ClientServerMiscDUnitTest.java | 123 +-
.../ClientServerMiscSelectorDUnitTest.java | 14 +-
.../cache/tier/sockets/ConflationDUnitTest.java | 55 +-
.../tier/sockets/ConnectionProxyJUnitTest.java | 58 +-
.../DataSerializerPropogationDUnitTest.java | 48 +-
.../cache/tier/sockets/DeltaEOFException.java | 2 +-
.../DestroyEntryPropagationDUnitTest.java | 163 +-
.../sockets/DurableClientBug39997DUnitTest.java | 27 +-
.../DurableClientQueueSizeDUnitTest.java | 78 +-
.../DurableClientReconnectAutoDUnitTest.java | 28 +-
.../DurableClientReconnectDUnitTest.java | 287 +-
.../sockets/DurableClientStatsDUnitTest.java | 55 +-
.../sockets/DurableRegistrationDUnitTest.java | 40 +-
.../sockets/DurableResponseMatrixDUnitTest.java | 92 +-
.../sockets/EventIDVerificationDUnitTest.java | 33 +-
.../EventIDVerificationInP2PDUnitTest.java | 32 +-
.../cache/tier/sockets/FaultyDelta.java | 2 +-
.../tier/sockets/FilterProfileJUnitTest.java | 102 +-
.../ForceInvalidateEvictionDUnitTest.java | 20 +-
...ForceInvalidateOffHeapEvictionDUnitTest.java | 19 +-
.../cache/tier/sockets/HABug36738DUnitTest.java | 15 +-
.../tier/sockets/HAInterestPart1DUnitTest.java | 22 +-
.../tier/sockets/HAInterestPart2DUnitTest.java | 22 +-
.../cache/tier/sockets/HAInterestTestCase.java | 65 +-
.../sockets/HAStartupAndFailoverDUnitTest.java | 135 +-
.../InstantiatorPropagationDUnitTest.java | 135 +-
.../tier/sockets/InterestListDUnitTest.java | 549 +-
.../sockets/InterestListEndpointDUnitTest.java | 42 +-
.../InterestListEndpointPRDUnitTest.java | 16 +-
.../InterestListEndpointSelectorDUnitTest.java | 14 +-
.../sockets/InterestListFailoverDUnitTest.java | 35 +-
.../sockets/InterestListRecoveryDUnitTest.java | 184 +-
.../sockets/InterestRegrListenerDUnitTest.java | 49 +-
.../sockets/InterestResultPolicyDUnitTest.java | 51 +-
.../cache/tier/sockets/MessageJUnitTest.java | 38 +-
.../sockets/NewRegionAttributesDUnitTest.java | 27 +-
.../tier/sockets/ObjectPartListJUnitTest.java | 43 +-
.../tier/sockets/RedundancyLevelJUnitTest.java | 28 +-
.../sockets/RedundancyLevelPart1DUnitTest.java | 322 +-
.../sockets/RedundancyLevelPart2DUnitTest.java | 189 +-
.../sockets/RedundancyLevelPart3DUnitTest.java | 41 +-
.../tier/sockets/RedundancyLevelTestBase.java | 74 +-
.../tier/sockets/RegionCloseDUnitTest.java | 37 +-
...erInterestBeforeRegionCreationDUnitTest.java | 51 +-
.../sockets/RegisterInterestKeysDUnitTest.java | 50 +-
.../RegisterInterestKeysPRDUnitTest.java | 16 +-
.../sockets/ReliableMessagingDUnitTest.java | 40 +-
.../sockets/UnregisterInterestDUnitTest.java | 44 +-
.../sockets/UpdatePropagationDUnitTest.java | 550 +-
.../sockets/UpdatePropagationPRDUnitTest.java | 12 +-
.../VerifyEventIDGenerationInP2PDUnitTest.java | 32 +-
...UpdatesFromNonInterestEndPointDUnitTest.java | 50 +-
.../tier/sockets/command/CommitCommandTest.java | 12 +-
.../cache/tx/AbstractPeerTXRegionStubTest.java | 164 +
.../versions/AbstractVersionTagTestBase.java | 92 +
.../cache/versions/RVVExceptionJUnitTest.java | 14 +-
.../versions/RegionVersionHolder2JUnitTest.java | 5 +-
.../versions/RegionVersionHolderJUnitTest.java | 52 +-
.../RegionVersionHolderRandomJUnitTest.java | 47 +-
...RegionVersionHolderSmallBitSetJUnitTest.java | 15 +-
.../versions/RegionVersionVectorJUnitTest.java | 39 +-
.../cache/versions/VMVersionTagTest.java | 32 +
.../cache/wan/AsyncEventQueueTestBase.java | 114 +-
.../cache/wan/MyAsyncEventListener.java | 7 +-
.../cache/wan/MyGatewayEventFilter.java | 69 +
.../asyncqueue/AsyncEventListenerDUnitTest.java | 1307 ++---
.../AsyncEventListenerOffHeapDUnitTest.java | 16 +-
.../AsyncEventQueueStatsDUnitTest.java | 205 +-
.../AsyncEventQueueValidationsJUnitTest.java | 88 +-
.../ConcurrentAsyncEventQueueDUnitTest.java | 189 +-
...ncurrentAsyncEventQueueOffHeapDUnitTest.java | 14 +-
.../CommonParallelAsyncEventQueueDUnitTest.java | 23 +-
...ParallelAsyncEventQueueOffHeapDUnitTest.java | 14 +-
.../ParallelGatewaySenderQueueJUnitTest.java | 10 +-
...ialGatewaySenderEventProcessorJUnitTest.java | 16 +-
.../xmlcache/AbstractEntityResolverTest.java | 46 +-
.../xmlcache/AbstractXmlParserJUnitTest.java | 5 +-
.../cache/xmlcache/CacheCreationJUnitTest.java | 9 +-
.../cache/xmlcache/CacheXmlParserJUnitTest.java | 16 +-
.../xmlcache/CacheXmlVersionJUnitTest.java | 7 +-
.../xmlcache/GeodeEntityResolverJUnitTest.java | 10 +-
.../PivotalEntityResolverJUnitTest.java | 13 +-
.../cache/xmlcache/RegionCreationJUnitTest.java | 5 +-
.../xmlcache/XmlGeneratorUtilsJUnitTest.java | 31 +-
.../CompressionCacheConfigDUnitTest.java | 38 +-
.../CompressionCacheListenerDUnitTest.java | 39 +-
...ompressionCacheListenerOffHeapDUnitTest.java | 33 +-
.../CompressionRegionConfigDUnitTest.java | 70 +-
.../CompressionRegionFactoryDUnitTest.java | 26 +-
.../CompressionRegionOperationsDUnitTest.java | 65 +-
...ressionRegionOperationsOffHeapDUnitTest.java | 26 +-
.../compression/CompressionStatsDUnitTest.java | 19 +-
.../compression/SnappyCompressorJUnitTest.java | 46 +-
.../datasource/AbstractPoolCacheJUnitTest.java | 241 +-
.../internal/datasource/CleanUpJUnitTest.java | 28 +-
.../ConnectionPoolCacheImplJUnitTest.java | 31 +-
.../datasource/ConnectionPoolingJUnitTest.java | 44 +-
.../datasource/DataSourceFactoryJUnitTest.java | 77 +-
.../internal/datasource/RestartJUnitTest.java | 28 +-
.../internal/i18n/BasicI18nJUnitTest.java | 331 +-
.../io/CompositeOutputStreamJUnitTest.java | 4 +-
.../gemfire/internal/jndi/ContextJUnitTest.java | 305 +-
.../internal/jta/BlockingTimeOutJUnitTest.java | 48 +-
.../gemfire/internal/jta/CacheUtils.java | 20 +-
.../internal/jta/DataSourceJTAJUnitTest.java | 44 +-
.../internal/jta/ExceptionJUnitTest.java | 19 +-
.../jta/GlobalTransactionJUnitTest.java | 126 +-
.../internal/jta/JtaIntegrationJUnitTest.java | 27 +-
.../internal/jta/TransactionImplJUnitTest.java | 22 +-
.../jta/TransactionManagerImplJUnitTest.java | 30 +-
.../jta/TransactionTimeOutJUnitTest.java | 395 +-
.../jta/UserTransactionImplJUnitTest.java | 25 +-
.../internal/jta/dunit/ExceptionsDUnitTest.java | 23 +-
.../jta/dunit/IdleTimeOutDUnitTest.java | 24 +-
.../jta/dunit/LoginTimeOutDUnitTest.java | 38 +-
.../jta/dunit/MaxPoolSizeDUnitTest.java | 55 +-
.../jta/dunit/TransactionTimeOutDUnitTest.java | 107 +-
.../dunit/TxnManagerMultiThreadDUnitTest.java | 121 +-
.../internal/jta/dunit/TxnTimeOutDUnitTest.java | 98 +-
.../jta/functional/TestXACacheLoader.java | 2 +-
.../internal/lang/ClassUtilsJUnitTest.java | 2 +-
.../internal/lang/InOutParameterJUnitTest.java | 2 +-
.../internal/lang/InitializerJUnitTest.java | 2 +-
.../internal/lang/ObjectUtilsJUnitTest.java | 4 +-
.../internal/lang/StringUtilsJUnitTest.java | 2 +-
.../internal/lang/SystemUtilsJUnitTest.java | 2 +-
.../internal/lang/ThreadUtilsJUnitTest.java | 16 +-
.../internal/lang/ThrowableUtilsTest.java | 242 +
.../DistributedSystemLogFileJUnitTest.java | 159 +-
.../logging/LocatorLogFileJUnitTest.java | 29 +-
.../internal/logging/LogServiceJUnitTest.java | 16 +-
.../LogWriterDisabledPerformanceTest.java | 30 +-
.../logging/LogWriterPerformanceTest.java | 37 +-
.../logging/LoggingPerformanceTestCase.java | 40 +-
.../internal/logging/SortLogFileJUnitTest.java | 12 +-
.../internal/logging/TestLogWriterFactory.java | 3 +-
.../logging/log4j/AlertAppenderJUnitTest.java | 6 +-
.../logging/log4j/ConfigLocatorJUnitTest.java | 6 +-
.../logging/log4j/FastLoggerJUnitTest.java | 4 +-
.../log4j/LocalizedMessageJUnitTest.java | 6 +-
.../log4j/Log4J2DisabledPerformanceTest.java | 29 +-
.../logging/log4j/Log4J2PerformanceTest.java | 40 +-
.../log4j/LogWriterAppenderJUnitTest.java | 3 +-
.../LogWriterLoggerDisabledPerformanceTest.java | 25 +-
.../log4j/LogWriterLoggerPerformanceTest.java | 44 +-
.../logging/log4j/custom/BasicAppender.java | 76 +
.../CustomConfigWithCacheIntegrationTest.java | 147 +
...stomConfigWithLogServiceIntegrationTest.java | 119 +
.../log4j/custom/CustomConfiguration.java | 64 +
.../internal/net/SocketUtilsJUnitTest.java | 2 +-
.../offheap/AbstractStoredObjectTestBase.java | 256 +-
.../internal/offheap/DataTypeJUnitTest.java | 142 +-
...tingOutOfOffHeapMemoryListenerJUnitTest.java | 8 +-
.../internal/offheap/FragmentJUnitTest.java | 29 +-
.../internal/offheap/FreeListManagerTest.java | 155 +-
.../offheap/FreeListOffHeapRegionJUnitTest.java | 8 +-
.../internal/offheap/InlineKeyJUnitTest.java | 35 +-
.../offheap/LifecycleListenerJUnitTest.java | 96 +-
...moryAllocatorFillPatternIntegrationTest.java | 19 +-
.../MemoryAllocatorFillPatternJUnitTest.java | 16 +-
.../offheap/MemoryAllocatorJUnitTest.java | 16 +-
.../offheap/MemoryBlockNodeJUnitTest.java | 77 +-
.../offheap/MemoryInspectorImplJUnitTest.java | 18 +-
.../offheap/NullOffHeapMemoryStats.java | 4 +
.../offheap/OffHeapHelperJUnitTest.java | 17 +-
.../internal/offheap/OffHeapIndexJUnitTest.java | 32 +-
.../internal/offheap/OffHeapRegionBase.java | 36 +-
.../OffHeapRegionEntryHelperJUnitTest.java | 58 +-
.../offheap/OffHeapStorageJUnitTest.java | 119 +-
...ffHeapStoredObjectAddressStackJUnitTest.java | 24 -
.../offheap/OffHeapStoredObjectJUnitTest.java | 36 +-
.../OffHeapStoredObjectSliceJUnitTest.java | 4 +-
...ffHeapStoredObjectWithHeapFormJUnitTest.java | 7 +-
.../offheap/OffHeapValidationJUnitTest.java | 56 +-
.../OffHeapWriteObjectAsByteArrayJUnitTest.java | 6 -
.../OldFreeListOffHeapRegionJUnitTest.java | 10 +-
.../offheap/OutOfOffHeapMemoryDUnitTest.java | 42 +-
.../offheap/RefCountChangeInfoJUnitTest.java | 14 +-
.../offheap/ReferenceCountHelperImplTest.java | 974 ++++
.../offheap/ReferenceCountHelperJUnitTest.java | 208 +
.../offheap/TinyMemoryBlockJUnitTest.java | 33 +-
.../offheap/TinyStoredObjectJUnitTest.java | 502 +-
.../TxReleasesOffHeapOnCloseJUnitTest.java | 24 +-
.../BlockingProcessStreamReaderJUnitTest.java | 2 +-
...leProcessControllerIntegrationJUnitTest.java | 13 +-
.../LocalProcessControllerJUnitTest.java | 38 +-
.../process/LocalProcessLauncherDUnitTest.java | 20 +-
.../process/LocalProcessLauncherJUnitTest.java | 38 +-
...NonBlockingProcessStreamReaderJUnitTest.java | 2 +-
.../internal/process/PidFileJUnitTest.java | 6 +-
.../ProcessControllerFactoryJUnitTest.java | 2 +-
...tractSignalNotificationHandlerJUnitTest.java | 12 +-
.../security/GeodeSecurityUtilTest.java | 139 +
.../internal/size/ObjectSizerJUnitTest.java | 21 +-
.../internal/size/ObjectTraverserJUnitTest.java | 66 +-
.../size/ReflectionObjectSizerJUnitTest.java | 15 +-
.../size/SizeClassOnceObjectSizerJUnitTest.java | 15 +-
.../size/WellKnownClassSizerJUnitTest.java | 18 +-
.../statistics/CallbackSamplerJUnitTest.java | 98 +
.../internal/statistics/DummyStatistics.java | 208 -
.../statistics/SampleCollectorJUnitTest.java | 56 +-
.../statistics/StatMonitorHandlerJUnitTest.java | 46 +-
.../statistics/StatisticsDUnitTest.java | 52 +-
.../statistics/StatisticsMonitorJUnitTest.java | 55 +-
.../internal/statistics/TestSampleHandler.java | 10 +-
.../statistics/TestStatArchiveWriter.java | 2 +-
.../statistics/TestStatisticsManager.java | 2 +-
.../statistics/TestStatisticsSampler.java | 2 +-
.../statistics/ValueMonitorJUnitTest.java | 25 +-
.../internal/stats50/AtomicStatsJUnitTest.java | 24 +-
.../internal/tcp/ConnectionJUnitTest.java | 5 +-
.../util/AbortableTaskServiceJUnitTest.java | 1 -
.../internal/util/ArrayUtilsJUnitTest.java | 5 +-
.../gemfire/internal/util/BlobHelperTest.java | 179 +
...bHelperWithThreadContextClassLoaderTest.java | 306 ++
.../gemfire/internal/util/BytesJUnitTest.java | 35 +-
.../internal/util/CollectionUtilsJUnitTest.java | 3 +-
.../internal/util/DelayedActionJUnitTest.java | 9 +-
.../gemfire/internal/util/HostNameTest.java | 121 +
.../gemfire/internal/util/IOUtilsJUnitTest.java | 4 +-
.../gemfire/internal/util/SerializableImpl.java | 37 -
.../util/SerializableImplWithValue.java | 56 -
.../gemfire/internal/util/Valuable.java | 3 +-
.../CompactConcurrentHashSetJUnitTest.java | 26 +-
.../ConcurrentHashMapIteratorJUnitTest.java | 33 +-
.../concurrent/CopyOnWriteHashMapJUnitTest.java | 48 +-
.../concurrent/ReentrantSemaphoreJUnitTest.java | 98 +-
.../SemaphoreReadWriteLockJUnitTest.java | 110 +-
.../cm/ConcurrentHashMapJUnitTest.java | 73 +-
.../concurrent/cm/CountedMapLoopsJUnitTest.java | 10 +-
.../concurrent/cm/IntMapCheckJUnitTest.java | 26 +-
.../util/concurrent/cm/MapCheckJUnitTest.java | 26 +-
.../util/concurrent/cm/MapLoopsJUnitTest.java | 12 +-
.../util/concurrent/cm/RLJBarJUnitTest.java | 13 +-
.../concurrent/cm/StringMapLoopsJUnitTest.java | 10 +-
.../management/CacheManagementDUnitTest.java | 122 +-
.../management/ClientHealthStatsDUnitTest.java | 105 +-
.../management/CompositeTypeTestDUnitTest.java | 15 +-
.../management/DLockManagementDUnitTest.java | 38 +-
.../DataBrowserJSONValidationJUnitTest.java | 49 +-
.../management/DiskManagementDUnitTest.java | 19 +-
.../management/DistributedSystemDUnitTest.java | 20 +-
.../management/LocatorManagementDUnitTest.java | 132 +-
.../gemstone/gemfire/management/MBeanUtil.java | 16 +-
.../gemfire/management/ManagementTestBase.java | 137 +-
.../MemberMBeanAttributesDUnitTest.java | 18 +-
.../management/OffHeapManagementDUnitTest.java | 42 +-
.../gemfire/management/QueryDataDUnitTest.java | 29 +-
.../RegionCreateDestroyDUnitTest.java | 174 +
.../management/RegionManagementDUnitTest.java | 33 +-
.../gemfire/management/TypedJsonJUnitTest.java | 25 +-
...ersalMembershipListenerAdapterDUnitTest.java | 308 +-
.../stats/DistributedSystemStatsDUnitTest.java | 15 +-
.../stats/DistributedSystemStatsJUnitTest.java | 39 +-
.../stats/GatewayReceiverStatsJUnitTest.java | 8 +-
.../bean/stats/MBeanStatsTestCase.java | 25 +-
.../bean/stats/RegionStatsJUnitTest.java | 2 +-
.../bean/stats/StatsRateJUnitTest.java | 59 +-
.../internal/JettyHelperJUnitTest.java | 27 +-
.../beans/DistributedSystemBridgeJUnitTest.java | 3 +-
.../cli/ClasspathScanLoadHelperJUnitTest.java | 22 +-
.../internal/cli/CliUtilDUnitTest.java | 35 +-
.../internal/cli/CommandManagerJUnitTest.java | 80 +-
.../internal/cli/CommandRequestTest.java | 161 +
.../cli/CommandSeparatorEscapeJUnitTest.java | 47 +-
.../internal/cli/DataCommandJsonJUnitTest.java | 14 +-
.../internal/cli/GfshParserIntegrationTest.java | 157 +
.../internal/cli/GfshParserJUnitTest.java | 824 +--
.../management/internal/cli/HeadlessGfsh.java | 25 +-
.../cli/HeadlessGfshIntegrationTest.java | 91 +
.../internal/cli/HeadlessGfshJUnitTest.java | 85 -
.../internal/cli/JoptOptionParserTest.java | 513 ++
.../cli/annotations/CliArgumentJUnitTest.java | 181 +-
.../AbstractCommandsSupportJUnitTest.java | 24 +-
.../cli/commands/CliCommandTestBase.java | 235 +-
.../cli/commands/ConfigCommandsDUnitTest.java | 388 +-
...eateAlterDestroyRegionCommandsDUnitTest.java | 229 +-
.../cli/commands/DeployCommandsDUnitTest.java | 116 +-
.../commands/DiskStoreCommandsDUnitTest.java | 173 +-
.../commands/DiskStoreCommandsJUnitTest.java | 26 +-
.../cli/commands/FunctionCommandsDUnitTest.java | 237 +-
.../commands/GemfireDataCommandsDUnitTest.java | 331 +-
...WithCacheLoaderDuringCacheMissDUnitTest.java | 196 +-
.../HTTPServiceSSLSupportJUnitTest.java | 76 +-
.../commands/HelpCommandsIntegrationTest.java | 142 +
.../cli/commands/IndexCommandsDUnitTest.java | 88 +-
.../cli/commands/IndexCommandsJUnitTest.java | 26 +-
...stAndDescribeDiskStoreCommandsDUnitTest.java | 143 +-
.../ListAndDescribeRegionDUnitTest.java | 76 +-
.../cli/commands/ListIndexCommandDUnitTest.java | 163 +-
.../cli/commands/MemberCommandsDUnitTest.java | 86 +-
.../MiscellaneousCommandsDUnitTest.java | 135 +-
...laneousCommandsExportLogsPart1DUnitTest.java | 40 +-
...laneousCommandsExportLogsPart2DUnitTest.java | 41 +-
...laneousCommandsExportLogsPart3DUnitTest.java | 45 +-
...laneousCommandsExportLogsPart4DUnitTest.java | 39 +-
.../cli/commands/QueueCommandsDUnitTest.java | 73 +-
.../SharedConfigurationCommandsDUnitTest.java | 312 +-
.../cli/commands/ShellCommandsDUnitTest.java | 98 +-
.../cli/commands/ShowDeadlockDUnitTest.java | 53 +-
.../cli/commands/ShowMetricsDUnitTest.java | 84 +-
.../cli/commands/ShowStackTraceDUnitTest.java | 53 +-
.../cli/commands/ToUpperResultCollector.java | 65 +
.../cli/commands/UserCommandsDUnitTest.java | 23 +-
.../RegionPathConverterJUnitTest.java | 23 +-
.../functions/DataCommandFunctionJUnitTest.java | 10 +-
.../DescribeDiskStoreFunctionJUnitTest.java | 66 +-
.../ListDiskStoresFunctionJUnitTest.java | 32 +-
.../functions/ListIndexFunctionJUnitTest.java | 114 +-
.../cli/parser/ParserUtilsJUnitTest.java | 14 +-
.../preprocessor/PreprocessorJUnitTest.java | 7 +-
.../PreprocessorUtilsJUnitTest.java | 17 +-
.../cli/shell/GfshConfigInitFileJUnitTest.java | 20 +-
.../shell/GfshExecutionStrategyJUnitTest.java | 54 +-
.../cli/shell/GfshHistoryJUnitTest.java | 37 +-
.../cli/shell/GfshInitFileJUnitTest.java | 22 +-
.../cli/util/CommentSkipHelperTest.java | 101 +
.../internal/cli/util/HyphenFormatterTest.java | 201 +
.../SharedConfigurationDUnitTest.java | 239 +-
.../SharedConfigurationTestUtils.java | 40 +
.../SharedConfigurationUsingDirDUnitTest.java | 99 +-
.../configuration/ZipUtilsJUnitTest.java | 114 +-
.../domain/CacheElementJUnitTest.java | 23 +-
.../utils/XmlUtilsAddNewNodeJUnitTest.java | 57 +-
.../configuration/utils/XmlUtilsJUnitTest.java | 48 +-
.../internal/pulse/TestClientIdsDUnitTest.java | 28 +-
.../internal/pulse/TestFunctionsDUnitTest.java | 15 +-
.../internal/pulse/TestHeapDUnitTest.java | 15 +-
.../internal/pulse/TestLocatorsDUnitTest.java | 15 +-
.../pulse/TestSubscriptionsDUnitTest.java | 32 +-
.../security/AccessControlMBeanJUnitTest.java | 59 +
...rDistributedSystemMXBeanIntegrationTest.java | 50 -
...horizeOperationForMBeansIntegrationTest.java | 323 --
...erationForRegionCommandsIntegrationTest.java | 136 -
...CacheServerMBeanAuthenticationJUnitTest.java | 59 +
.../CacheServerMBeanAuthorizationJUnitTest.java | 93 +
.../CacheServerMBeanShiroJUnitTest.java | 95 +
.../security/CliCommandsSecurityTest.java | 88 +
.../security/DataCommandsSecurityTest.java | 86 +
.../DiskStoreMXBeanSecurityJUnitTest.java | 86 +
.../GatewayReceiverMBeanSecurityTest.java | 93 +
.../GatewaySenderMBeanSecurityTest.java | 109 +
.../security/GeodePermissionJUnitTest.java | 94 +
.../GeodeSecurityUtilCustomRealmJUnitTest.java | 44 +
.../GeodeSecurityUtilWithIniFileJUnitTest.java | 139 +
.../security/GfshCommandsPostProcessorTest.java | 69 +
.../security/GfshCommandsSecurityTest.java | 181 +
.../security/GfshShellConnectionRule.java | 113 +
.../security/JMXConnectionConfiguration.java | 33 +
...JSONAuthorizationDetailsIntegrationTest.java | 163 -
.../JsonAuthorizationCacheStartRule.java | 86 +
.../LockServiceMBeanAuthorizationJUnitTest.java | 93 +
.../security/MBeanSecurityJUnitTest.java | 116 +
.../security/MBeanServerConnectionRule.java | 130 +
.../ManagerMBeanAuthorizationJUnitTest.java | 82 +
.../security/MemberMBeanSecurityJUnitTest.java | 113 +
.../internal/security/MultiUserDUnitTest.java | 145 +
...tionCodesForDataCommandsIntegrationTest.java | 101 -
...tionCodesForDistributedSystemMXBeanTest.java | 76 -
.../internal/security/ShiroCacheStartRule.java | 64 +
.../internal/security/TestCommand.java | 228 +
.../ReadOpFileAccessControllerJUnitTest.java | 64 +-
.../WanCommandsControllerJUnitTest.java | 10 +-
.../DomainObjectsAsValuesJUnitTest.java | 25 +-
.../GemcachedDevelopmentJUnitTest.java | 36 +-
.../gemfire/memcached/IntegrationJUnitTest.java | 26 +-
.../gemfire/pdx/AutoSerializableJUnitTest.java | 66 +-
.../gemfire/pdx/ByteSourceJUnitTest.java | 8 +-
.../ClientsWithVersioningRetryDUnitTest.java | 34 +-
.../pdx/DistributedSystemIdDUnitTest.java | 56 +-
.../gemfire/pdx/JSONFormatterJUnitTest.java | 205 +
.../pdx/JSONPdxClientServerDUnitTest.java | 76 +-
.../gemfire/pdx/OffHeapByteSourceJUnitTest.java | 4 +-
.../pdx/PDXAsyncEventQueueDUnitTest.java | 18 +-
.../gemfire/pdx/PdxAttributesJUnitTest.java | 48 +-
.../gemfire/pdx/PdxClientServerDUnitTest.java | 56 +-
.../pdx/PdxDeserializationDUnitTest.java | 32 +-
.../pdx/PdxFormatterPutGetJUnitTest.java | 208 -
.../pdx/PdxInstanceFactoryJUnitTest.java | 46 +-
.../gemfire/pdx/PdxInstanceJUnitTest.java | 43 +-
.../gemfire/pdx/PdxSerializableDUnitTest.java | 20 +-
.../gemfire/pdx/PdxSerializableJUnitTest.java | 32 +-
.../gemfire/pdx/PdxStringJUnitTest.java | 13 +-
.../gemfire/pdx/PdxTypeExportDUnitTest.java | 18 +-
.../gemfire/pdx/TestObjectForJSONFormatter.java | 1000 ++++
.../gemfire/pdx/TestObjectForPdxFormatter.java | 1003 ----
.../gemfire/pdx/VersionClassLoader.java | 98 -
.../gemstone/gemfire/redis/AuthJUnitTest.java | 160 -
.../gemfire/redis/ConcurrentStartTest.java | 98 -
.../gemstone/gemfire/redis/HashesJUnitTest.java | 191 -
.../gemstone/gemfire/redis/ListsJUnitTest.java | 254 -
.../gemfire/redis/RedisDistDUnitTest.java | 257 -
.../gemstone/gemfire/redis/SetsJUnitTest.java | 258 -
.../gemfire/redis/SortedSetsJUnitTest.java | 430 --
.../gemfire/redis/StringsJunitTest.java | 312 --
...ractIntegratedClientAuthDistributedTest.java | 120 +
.../security/ClientAuthenticationDUnitTest.java | 8 +-
.../ClientAuthenticationPart2DUnitTest.java | 6 +-
.../security/ClientAuthenticationTestCase.java | 39 +-
.../security/ClientAuthenticationTestUtils.java | 25 +-
.../security/ClientAuthorizationDUnitTest.java | 25 +-
.../security/ClientAuthorizationTestCase.java | 66 +-
.../security/ClientMultiUserAuthzDUnitTest.java | 10 +-
.../DeltaClientAuthorizationDUnitTest.java | 12 +-
.../DeltaClientPostAuthorizationDUnitTest.java | 38 +-
.../security/GemFireSecurityExceptionTest.java | 6 +-
.../security/IntegratedClientAuthDUnitTest.java | 64 +
...tedClientContainsKeyAuthDistributedTest.java | 55 +
...entDestroyInvalidateAuthDistributedTest.java | 84 +
...dClientDestroyRegionAuthDistributedTest.java | 65 +
...lientExecuteFunctionAuthDistributedTest.java | 61 +
...xecuteRegionFunctionAuthDistributedTest.java | 62 +
...tegratedClientGetAllAuthDistributedTest.java | 57 +
...tGetClientPRMetaDataAuthDistributedTest.java | 66 +
...ientPartitionAttrCmdAuthDistributedTest.java | 52 +
...gratedClientGetEntryAuthDistributedTest.java | 76 +
...tegratedClientGetPutAuthDistributedTest.java | 115 +
...tedClientRegionClearAuthDistributedTest.java | 63 +
...ientRegisterInterestAuthDistributedTest.java | 164 +
...ratedClientRemoveAllAuthDistributedTest.java | 65 +
...IntegratedClientSizeAuthDistributedTest.java | 54 +
...ntUnregisterInterestAuthDistributedTest.java | 48 +
...edSecurityCacheLifecycleDistributedTest.java | 101 +
...edSecurityCacheLifecycleIntegrationTest.java | 69 +
...urityNoShowValue1PostProcessorDUnitTest.java | 86 +
...tegratedSecurityPeerAuthDistributedTest.java | 146 +
...ntegratedSecurityPostProcessorDUnitTest.java | 118 +
.../security/NoShowValue1PostProcessor.java | 36 +
.../security/NotAuthorizedExceptionTest.java | 10 +-
.../security/P2PAuthenticationDUnitTest.java | 139 +-
.../gemfire/security/SecurityTestUtils.java | 708 ++-
.../gemfire/security/SpySecurityManager.java | 43 +
.../generator/AuthzCredentialGenerator.java | 19 +-
.../security/generator/CredentialGenerator.java | 7 +-
.../generator/DummyCredentialGenerator.java | 6 +-
.../generator/LdapUserCredentialGenerator.java | 14 +-
.../generator/PKCSCredentialGenerator.java | 8 +-
.../generator/SSLCredentialGenerator.java | 10 +-
.../UserPasswordWithExtraPropsAuthInit.java | 5 +-
.../generator/XmlAuthzCredentialGenerator.java | 10 +-
.../security/templates/DummyAuthenticator.java | 2 +-
.../security/templates/DummyAuthorization.java | 10 +-
.../templates/FunctionSecurityPrmsHolder.java | 2 +-
.../templates/LdapUserAuthenticator.java | 5 +-
.../security/templates/PKCSAuthInit.java | 5 +-
.../security/templates/PKCSAuthenticator.java | 3 +-
.../security/templates/PKCSPrincipalTest.java | 12 +-
.../templates/UserPasswordAuthInit.java | 6 +-
.../security/templates/UsernamePrincipal.java | 2 +-
.../templates/UsernamePrincipalTest.java | 12 +-
.../security/templates/XmlAuthorization.java | 23 +-
.../security/templates/XmlErrorHandler.java | 7 +-
.../com/gemstone/gemfire/test/dunit/Assert.java | 2 +-
.../gemfire/test/dunit/AsyncInvocation.java | 511 +-
.../gemfire/test/dunit/DistributedTestCase.java | 17 +-
.../test/dunit/DistributedTestUtils.java | 19 +-
.../gemfire/test/dunit/IgnoredException.java | 6 +-
.../com/gemstone/gemfire/test/dunit/Invoke.java | 22 +-
.../gemfire/test/dunit/LogWriterUtils.java | 9 +-
.../gemfire/test/dunit/NetworkUtils.java | 7 +-
.../gemfire/test/dunit/RMIException.java | 2 +-
.../test/dunit/SerializableCallable.java | 2 +-
.../test/dunit/SerializableRunnable.java | 2 +-
.../gemfire/test/dunit/ThreadUtils.java | 21 +-
.../com/gemstone/gemfire/test/dunit/VM.java | 525 +-
.../com/gemstone/gemfire/test/dunit/Wait.java | 2 +-
.../cache/internal/JUnit3CacheTestCase.java | 4 +-
.../cache/internal/JUnit4CacheTestCase.java | 29 +-
.../internal/JUnit3DistributedTestCase.java | 17 +-
.../internal/JUnit4DistributedTestCase.java | 50 +-
.../internal/tests/JUnit3BasicDUnitTest.java | 189 -
.../JUnit3GetDefaultDiskStoreNameDUnitTest.java | 66 -
.../tests/JUnit3GetTestMethodNameDUnitTest.java | 53 -
.../dunit/internal/tests/JUnit3VMDUnitTest.java | 192 -
.../internal/tests/JUnit4BasicDUnitTest.java | 202 -
.../JUnit4GetDefaultDiskStoreNameDUnitTest.java | 65 -
.../tests/JUnit4GetTestMethodNameDUnitTest.java | 52 -
.../dunit/internal/tests/JUnit4VMDUnitTest.java | 200 -
.../DistributedRestoreSystemProperties.java | 3 +-
.../gemfire/test/dunit/rules/RemoteInvoker.java | 3 +-
.../gemfire/test/dunit/standalone/ChildVM.java | 29 +-
.../test/dunit/standalone/DUnitLauncher.java | 131 +-
.../test/dunit/standalone/ProcessManager.java | 132 +-
.../test/dunit/standalone/RemoteDUnitVM.java | 5 +-
.../test/dunit/standalone/RemoteDUnitVMIF.java | 4 +-
.../test/dunit/tests/BasicDUnitTest.java | 251 +-
.../tests/GetDefaultDiskStoreNameDUnitTest.java | 14 +-
.../dunit/tests/GetTestMethodNameDUnitTest.java | 14 +-
.../test/dunit/tests/JUnit4BasicDUnitTest.java | 234 +
.../JUnit4GetDefaultDiskStoreNameDUnitTest.java | 66 +
.../tests/JUnit4GetTestMethodNameDUnitTest.java | 53 +
...ingGetPropertiesDisconnectsAllDUnitTest.java | 59 +
.../test/dunit/tests/JUnit4VMDUnitTest.java | 201 +
...ingGetPropertiesDisconnectsAllDUnitTest.java | 19 +-
.../gemfire/test/dunit/tests/VMDUnitTest.java | 21 +-
.../com/gemstone/gemfire/test/fake/Fakes.java | 56 +-
...WithLineMissingFromEndOfOutputJUnitTest.java | 3 +-
...hLineMissingFromMiddleOfOutputJUnitTest.java | 3 +-
.../gemfire/test/golden/GoldenComparator.java | 2 +-
.../gemfire/test/golden/GoldenTestCase.java | 20 +-
.../gemfire/test/golden/log4j2-test.xml | 18 -
.../test/process/MainLauncherJUnitTest.java | 9 +-
.../gemfire/test/process/ProcessWrapper.java | 21 +-
.../gemstone/gemfire/util/JSR166TestCase.java | 23 +-
.../gemstone/gemfire/util/test/TestUtil.java | 8 +-
.../com/main/WANBootStrapping_Site1_Add.java | 19 +-
.../com/main/WANBootStrapping_Site1_Remove.java | 18 +-
.../com/main/WANBootStrapping_Site2_Add.java | 16 +-
.../com/main/WANBootStrapping_Site2_Remove.java | 16 +-
geode-core/src/test/java/hydra/GsRandom.java | 311 --
.../test/java/hydra/HydraRuntimeException.java | 33 -
geode-core/src/test/java/hydra/Log.java | 219 -
.../src/test/java/hydra/LogVersionHelper.java | 45 -
.../src/test/java/hydra/log/AnyLogWriter.java | 555 --
.../java/hydra/log/CircularOutputStream.java | 131 -
.../org/apache/geode/redis/AuthJUnitTest.java | 161 +
.../apache/geode/redis/ConcurrentStartTest.java | 101 +
.../org/apache/geode/redis/HashesJUnitTest.java | 185 +
.../org/apache/geode/redis/ListsJUnitTest.java | 253 +
.../apache/geode/redis/RedisDistDUnitTest.java | 263 +
.../org/apache/geode/redis/SetsJUnitTest.java | 259 +
.../apache/geode/redis/SortedSetsJUnitTest.java | 420 ++
.../apache/geode/redis/StringsJunitTest.java | 306 ++
.../templates/SampleSecurityManagerTest.java | 123 +
.../parReg/query/unittest/NewPortfolio.java | 37 +-
.../java/parReg/query/unittest/Position.java | 2 +-
.../src/test/java/perffmwk/Formatter.java | 14 +-
.../gemfire/codeAnalysis/excludedClasses.txt | 33 +-
.../sanctionedDataSerializables.txt | 594 +--
.../codeAnalysis/sanctionedSerializables.txt | 350 +-
...ntQueueConfiguredFromXmlUsesFilter.cache.xml | 40 +
...ntQueueConfiguredFromXmlUsesFilter.cache.xml | 40 +
.../logging/log4j/custom/log4j2-custom.xml | 27 +
.../cli/commands/golden-help-offline.properties | 3003 +++++++++++
.../cli/commands/golden-help-online.properties | 657 +++
.../management/internal/security/auth1.json | 28 +-
.../management/internal/security/auth3.json | 55 +-
.../internal/security/cacheServer.json | 230 +
.../internal/security/clientServer.json | 182 +
.../management/internal/security/shiro-ini.json | 87 +
.../internal/security/testInheritRole.json | 40 -
.../security/testSimpleUserAndRole.json | 14 -
.../testUserAndRoleRegionServerGroup.json | 16 -
.../internal/security/testUserMultipleRole.json | 20 -
.../pdx/jsonStrings/jsonListInsideList.txt | 48 +
.../com/gemstone/gemfire/security/peerAuth.json | 36 +
.../geode/security/templates/security.json | 30 +
geode-core/src/test/resources/shiro.ini | 40 +
.../src/test/resources/ssl/trusted.keystore | Bin 1078 -> 2241 bytes
.../cache/client/internal/CloseCQOp.java | 2 +-
.../cache/client/internal/CreateCQOp.java | 2 +-
.../cache/client/internal/CreateCQWithIROp.java | 2 +-
.../cache/client/internal/GetDurableCQsOp.java | 2 +-
.../client/internal/ServerCQProxyImpl.java | 2 +-
.../gemfire/cache/client/internal/StopCQOp.java | 2 +-
.../cache/query/internal/cq/ClientCQImpl.java | 3 +-
.../internal/cq/CqAttributesMutatorImpl.java | 2 +-
.../cache/query/internal/cq/CqEventImpl.java | 2 +-
.../cache/query/internal/cq/CqListenerImpl.java | 2 +-
.../cache/query/internal/cq/CqQueryImpl.java | 7 +-
.../cache/query/internal/cq/CqServiceImpl.java | 74 +-
.../internal/cq/CqServiceStatisticsImpl.java | 2 +-
.../query/internal/cq/CqServiceVsdStats.java | 2 +-
.../query/internal/cq/CqStatisticsImpl.java | 2 +-
.../cache/tier/sockets/command/CloseCQ.java | 25 +-
.../cache/tier/sockets/command/ExecuteCQ61.java | 2 +-
.../cache/tier/sockets/command/GetCQStats.java | 42 +-
.../tier/sockets/command/GetDurableCQs.java | 16 +-
.../cache/tier/sockets/command/MonitorCQ.java | 15 +-
.../cache/tier/sockets/command/StopCQ.java | 28 +-
.../gemfire/cache/query/cq/CQJUnitTest.java | 48 +-
.../cache/query/cq/dunit/CqDataDUnitTest.java | 31 +-
.../dunit/CqDataOptimizedExecuteDUnitTest.java | 14 +-
.../cq/dunit/CqDataUsingPoolDUnitTest.java | 540 +-
...qDataUsingPoolOptimizedExecuteDUnitTest.java | 14 +-
.../cache/query/cq/dunit/CqPerfDUnitTest.java | 37 +-
.../cq/dunit/CqPerfUsingPoolDUnitTest.java | 38 +-
.../cache/query/cq/dunit/CqQueryDUnitTest.java | 68 +-
.../dunit/CqQueryOptimizedExecuteDUnitTest.java | 28 +-
.../cq/dunit/CqQueryUsingPoolDUnitTest.java | 521 +-
...QueryUsingPoolOptimizedExecuteDUnitTest.java | 14 +-
.../cq/dunit/CqResultSetUsingPoolDUnitTest.java | 29 +-
...ltSetUsingPoolOptimizedExecuteDUnitTest.java | 15 +-
.../cache/query/cq/dunit/CqStateDUnitTest.java | 35 +-
.../cache/query/cq/dunit/CqStatsDUnitTest.java | 22 +-
.../dunit/CqStatsOptimizedExecuteDUnitTest.java | 14 +-
.../cq/dunit/CqStatsUsingPoolDUnitTest.java | 22 +-
...StatsUsingPoolOptimizedExecuteDUnitTest.java | 14 +-
.../PartitionedRegionCqQueryDUnitTest.java | 396 +-
...dRegionCqQueryOptimizedExecuteDUnitTest.java | 26 +-
.../query/cq/dunit/PrCqUsingPoolDUnitTest.java | 134 +-
.../PrCqUsingPoolOptimizedExecuteDUnitTest.java | 14 +-
.../cache/query/dunit/PdxQueryCQDUnitTest.java | 17 +-
.../cache/query/dunit/PdxQueryCQTestBase.java | 19 +-
.../dunit/QueryIndexUpdateRIDUnitTest.java | 42 +-
.../query/dunit/QueryMonitorDUnitTest.java | 1163 ++---
.../cache/snapshot/ClientSnapshotDUnitTest.java | 30 +-
.../cache/PRDeltaPropagationDUnitTest.java | 363 +-
.../internal/cache/PutAllCSDUnitTest.java | 447 +-
.../cache/RemoteCQTransactionDUnitTest.java | 208 +-
.../internal/cache/ha/CQListGIIDUnitTest.java | 199 +-
.../cache/ha/HADispatcherDUnitTest.java | 637 +--
.../sockets/ClientToServerDeltaDUnitTest.java | 69 +-
.../DeltaPropagationWithCQDUnitTest.java | 69 +-
...ToRegionRelationCQRegistrationDUnitTest.java | 106 +-
.../sockets/DurableClientCrashDUnitTest.java | 37 +-
.../sockets/DurableClientNetDownDUnitTest.java | 65 +-
.../sockets/DurableClientSimpleDUnitTest.java | 764 ++-
.../tier/sockets/DurableClientTestCase.java | 252 +-
.../CacheServerManagementDUnitTest.java | 285 +-
.../cli/commands/ClientCommandsDUnitTest.java | 1828 +++----
.../DurableClientCommandsDUnitTest.java | 89 +-
.../internal/pulse/TestCQDUnitTest.java | 18 +-
.../internal/pulse/TestClientsDUnitTest.java | 18 +-
.../internal/pulse/TestServerDUnitTest.java | 18 +-
.../security/CQPostProcessorDunitTest.java | 92 +
.../ClientAuthorizationTwoDUnitTest.java | 10 +-
.../security/ClientAuthzObjectModDUnitTest.java | 66 +-
.../ClientCQPostAuthorizationDUnitTest.java | 16 +-
.../ClientPostAuthorizationDUnitTest.java | 32 +-
...ntegratedClientQueryAuthDistributedTest.java | 122 +
.../gemfire/security/MultiUserAPIDUnitTest.java | 25 +-
.../MultiUserDurableCQAuthzDUnitTest.java | 16 +-
geode-examples/.gitignore | 1 +
geode-examples/README.md | 72 +
geode-examples/build.gradle | 53 +
geode-examples/gradle.properties | 21 +
.../gradle/wrapper/gradle-wrapper.jar | Bin 0 -> 53639 bytes
.../gradle/wrapper/gradle-wrapper.properties | 6 +
geode-examples/gradlew | 160 +
geode-examples/gradlew.bat | 90 +
geode-examples/replicated/.gitignore | 2 +
geode-examples/replicated/README.md | 45 +
geode-examples/replicated/build.gradle | 20 +
geode-examples/replicated/scripts/.gitignore | 2 +
geode-examples/replicated/scripts/pidkiller.sh | 36 +
geode-examples/replicated/scripts/setEnv.sh | 33 +
geode-examples/replicated/scripts/startAll.sh | 45 +
geode-examples/replicated/scripts/stopAll.sh | 28 +
.../geode/examples/replicated/BaseClient.java | 63 +
.../geode/examples/replicated/Consumer.java | 40 +
.../geode/examples/replicated/Producer.java | 40 +
.../geode/examples/replicated/ConsumerTest.java | 71 +
.../geode/examples/replicated/ProducerTest.java | 70 +
.../examples/replicated/ReplicatedTest.java | 164 +
geode-examples/settings.gradle | 21 +
.../apache/geode/example/utils/ShellUtil.java | 106 +
.../java/joptsimple/AbstractOptionSpec.java | 127 -
.../joptsimple/AlternativeLongOptionSpec.java | 54 -
.../joptsimple/ArgumentAcceptingOptionSpec.java | 349 --
.../src/main/java/joptsimple/ArgumentList.java | 59 -
.../java/joptsimple/BuiltinHelpFormatter.java | 149 -
.../src/main/java/joptsimple/HelpFormatter.java | 45 -
.../IllegalOptionSpecificationException.java | 52 -
.../MissingRequiredOptionException.java | 52 -
.../MultipleArgumentsForOptionException.java | 52 -
.../java/joptsimple/NoArgumentOptionSpec.java | 82 -
.../OptionArgumentConversionException.java | 63 -
.../main/java/joptsimple/OptionDescriptor.java | 94 -
.../main/java/joptsimple/OptionException.java | 111 -
.../OptionMissingRequiredArgumentException.java | 52 -
.../src/main/java/joptsimple/OptionParser.java | 568 ---
.../main/java/joptsimple/OptionParserState.java | 81 -
.../src/main/java/joptsimple/OptionSet.java | 309 --
.../src/main/java/joptsimple/OptionSpec.java | 98 -
.../main/java/joptsimple/OptionSpecBuilder.java | 96 -
.../java/joptsimple/OptionSpecTokenizer.java | 127 -
.../joptsimple/OptionalArgumentOptionSpec.java | 69 -
.../src/main/java/joptsimple/ParserRules.java | 84 -
.../joptsimple/RequiredArgumentOptionSpec.java | 54 -
.../joptsimple/UnrecognizedOptionException.java | 52 -
.../joptsimple/ValueConversionException.java | 54 -
.../main/java/joptsimple/ValueConverter.java | 58 -
.../joptsimple/internal/AbbreviationMap.java | 233 -
.../main/java/joptsimple/internal/Classes.java | 74 -
.../main/java/joptsimple/internal/Column.java | 133 -
.../internal/ColumnWidthCalculator.java | 41 -
.../java/joptsimple/internal/ColumnarData.java | 163 -
.../ConstructorInvokingValueConverter.java | 58 -
.../internal/MethodInvokingValueConverter.java | 60 -
.../main/java/joptsimple/internal/Objects.java | 46 -
.../java/joptsimple/internal/Reflection.java | 143 -
.../internal/ReflectionException.java | 39 -
.../main/java/joptsimple/internal/Strings.java | 117 -
.../java/joptsimple/util/DateConverter.java | 104 -
.../main/java/joptsimple/util/KeyValuePair.java | 83 -
.../main/java/joptsimple/util/RegexMatcher.java | 88 -
.../test/junit/categories/FlakyTest.java | 24 +
.../test/junit/categories/SecurityTest.java | 23 +
.../junit/rules/DescribedExternalResource.java | 63 +
.../gemfire/test/junit/rules/DiskDirRule.java | 62 +
.../gemfire/test/junit/rules/RetryRule.java | 2 +-
.../test/junit/runner/SuiteBlockRunner.java | 46 +
.../gemfire/test/junit/runner/SuiteRunner.java | 53 +
.../CategoryWithParameterizedRunner.java | 44 +
.../CategoryWithParameterizedRunnerFactory.java | 42 +
.../junit/runners/ExposedGetAnnotations.java | 23 +
.../test/junit/categories/CategoryOne.java | 20 +
.../test/junit/categories/CategoryTest.java | 169 +
.../test/junit/categories/CategoryTwo.java | 20 +
.../test/junit/rules/DiskDirRuleTest.java | 49 +
...egoryWithParameterizedRunnerFactoryTest.java | 162 +
geode-lucene/build.gradle | 4 -
.../gemfire/cache/lucene/LuceneIndex.java | 9 +-
.../gemfire/cache/lucene/LuceneQuery.java | 20 +-
.../cache/lucene/LuceneQueryException.java | 40 +
.../cache/lucene/LuceneQueryFactory.java | 5 +-
.../cache/lucene/LuceneQueryProvider.java | 6 +-
.../cache/lucene/LuceneQueryResults.java | 57 -
.../gemfire/cache/lucene/LuceneService.java | 22 +-
.../cache/lucene/LuceneServiceProvider.java | 9 +-
.../lucene/PageableLuceneQueryResults.java | 58 +
.../cache/lucene/internal/IndexListener.java | 35 +
.../lucene/internal/IndexRepositoryFactory.java | 71 +
.../lucene/internal/InternalLuceneIndex.java | 5 +
.../lucene/internal/LuceneEventListener.java | 18 +-
.../internal/LuceneIndexCreationProfile.java | 189 +
.../LuceneIndexForPartitionedRegion.java | 196 +-
.../LuceneIndexForReplicatedRegion.java | 48 -
.../cache/lucene/internal/LuceneIndexImpl.java | 102 +-
.../cache/lucene/internal/LuceneIndexStats.java | 198 +
.../lucene/internal/LuceneQueryFactoryImpl.java | 8 +-
.../cache/lucene/internal/LuceneQueryImpl.java | 77 +-
.../lucene/internal/LuceneQueryResultsImpl.java | 120 -
.../lucene/internal/LuceneServiceImpl.java | 90 +-
.../PageableLuceneQueryResultsImpl.java | 147 +
.../internal/PartitionedRepositoryManager.java | 82 +-
.../lucene/internal/StringQueryProvider.java | 38 +-
.../lucene/internal/cli/LuceneCliStrings.java | 72 +
.../internal/cli/LuceneIndexCommands.java | 328 ++
.../lucene/internal/cli/LuceneIndexDetails.java | 125 +
.../lucene/internal/cli/LuceneIndexInfo.java | 63 +
.../lucene/internal/cli/LuceneQueryInfo.java | 55 +
.../internal/cli/LuceneSearchResults.java | 50 +
.../functions/LuceneCreateIndexFunction.java | 106 +
.../functions/LuceneDescribeIndexFunction.java | 68 +
.../cli/functions/LuceneListIndexFunction.java | 66 +
.../functions/LuceneSearchIndexFunction.java | 90 +
.../internal/directory/DumpDirectoryFiles.java | 116 +
.../internal/directory/RegionDirectory.java | 25 +-
.../lucene/internal/directory/package-info.java | 23 +
.../internal/distributed/CollectorManager.java | 3 +-
.../lucene/internal/distributed/EntryScore.java | 10 +-
.../internal/distributed/LuceneFunction.java | 34 +-
.../lucene/internal/distributed/TopEntries.java | 16 +-
.../distributed/TopEntriesCollectorManager.java | 2 +-
.../TopEntriesFunctionCollector.java | 9 +-
.../internal/distributed/package-info.java | 25 +
.../cache/lucene/internal/filesystem/File.java | 19 +-
.../lucene/internal/filesystem/FileSystem.java | 48 +-
.../internal/filesystem/FileSystemStats.java | 128 +
.../internal/filesystem/package-info.java | 26 +
.../internal/management/LuceneIndexMetrics.java | 161 +
.../management/LuceneServiceBridge.java | 82 +
.../internal/management/LuceneServiceMBean.java | 57 +
.../management/LuceneServiceMXBean.java | 59 +
.../cache/lucene/internal/package-info.java | 23 +
.../internal/repository/IndexRepository.java | 17 +-
.../repository/IndexRepositoryImpl.java | 109 +-
.../internal/repository/package-info.java | 25 +
.../HeterogeneousLuceneSerializer.java | 107 +
.../HeterogenousLuceneSerializer.java | 83 -
.../serializer/PdxLuceneSerializer.java | 10 +
.../serializer/PrimitiveSerializer.java | 35 +
.../serializer/ReflectionLuceneSerializer.java | 11 +
.../repository/serializer/SerializerUtil.java | 46 +-
.../repository/serializer/package-info.java | 23 +
.../internal/xml/LuceneIndexCreation.java | 58 +-
.../internal/xml/LuceneIndexXmlGenerator.java | 5 +
.../lucene/internal/xml/LuceneXmlConstants.java | 1 +
.../lucene/internal/xml/LuceneXmlParser.java | 30 +-
.../cache/lucene/internal/xml/package-info.java | 24 +
.../gemfire/cache/lucene/package-info.java | 32 +
.../geode.apache.org/lucene/lucene-1.0.xsd | 1 +
...org.springframework.shell.core.CommandMarker | 2 +
.../gemfire/cache/lucene/LuceneDUnitTest.java | 38 +
.../lucene/LuceneIndexCreationDUnitTest.java | 391 ++
.../LuceneIndexCreationIntegrationTest.java | 200 +
...ceneIndexCreationOffHeapIntegrationTest.java | 71 +
...IndexCreationPersistenceIntegrationTest.java | 208 +
.../LuceneIndexMaintenanceIntegrationTest.java | 205 +
.../cache/lucene/LuceneIntegrationTest.java | 65 +
.../gemfire/cache/lucene/LuceneQueriesBase.java | 212 +
.../lucene/LuceneQueriesClientDUnitTest.java | 70 +
.../lucene/LuceneQueriesIntegrationTest.java | 538 ++
.../cache/lucene/LuceneQueriesPRBase.java | 195 +
.../lucene/LuceneQueriesPeerPRDUnitTest.java | 40 +
.../LuceneQueriesPeerPROverflowDUnitTest.java | 44 +
.../LuceneQueriesPeerPRRedundancyDUnitTest.java | 130 +
...LuceneQueriesPersistenceIntegrationTest.java | 104 +
.../internal/LuceneEventListenerJUnitTest.java | 40 +-
.../LuceneIndexCreationProfileJUnitTest.java | 144 +
.../LuceneIndexForPartitionedRegionTest.java | 370 ++
.../internal/LuceneIndexImplJUnitTest.java | 78 +
.../LuceneIndexRecoveryHAIntegrationTest.java | 120 +
.../LuceneIndexRecoveryHAJUnitTest.java | 201 -
.../internal/LuceneIndexStatsJUnitTest.java | 115 +
.../LuceneQueryFactoryImplJUnitTest.java | 25 +-
.../internal/LuceneQueryImplJUnitTest.java | 167 +-
.../LuceneQueryResultsImplJUnitTest.java | 126 -
.../LuceneResultStructImpJUnitTest.java | 2 -
.../LuceneServiceImplIntegrationTest.java | 110 +
.../internal/LuceneServiceImplJUnitTest.java | 213 +-
...PageableLuceneQueryResultsImplJUnitTest.java | 142 +
.../PartitionedRepositoryManagerJUnitTest.java | 78 +-
.../internal/StringQueryProviderJUnitTest.java | 48 +-
.../cli/LuceneIndexCommandsDUnitTest.java | 382 ++
.../cli/LuceneIndexCommandsJUnitTest.java | 312 ++
.../LuceneCreateIndexFunctionJUnitTest.java | 126 +
.../LuceneDescribeIndexFunctionJUnitTest.java | 103 +
.../LuceneListIndexFunctionJUnitTest.java | 102 +
.../LuceneSearchIndexFunctionJUnitTest.java | 109 +
.../DumpDirectoryFilesIntegrationTest.java | 76 +
.../directory/DumpDirectoryFilesJUnitTest.java | 127 +
.../directory/RegionDirectoryJUnitTest.java | 13 +-
.../DistributedScoringJUnitTest.java | 47 +-
.../distributed/EntryScoreJUnitTest.java | 13 +-
.../LuceneFunctionContextJUnitTest.java | 12 +-
.../distributed/LuceneFunctionJUnitTest.java | 431 +-
.../LuceneFunctionReadPathDUnitTest.java | 238 -
.../TopEntriesCollectorJUnitTest.java | 31 +-
.../TopEntriesFunctionCollectorJUnitTest.java | 23 +-
.../distributed/TopEntriesJUnitTest.java | 44 +-
.../internal/filesystem/ChunkKeyJUnitTest.java | 1 -
.../internal/filesystem/FileJUnitTest.java | 5 +-
.../filesystem/FileSystemJUnitTest.java | 151 +-
.../filesystem/FileSystemStatsJUnitTest.java | 100 +
.../IndexRepositoryImplJUnitTest.java | 76 +-
.../IndexRepositoryImplPerformanceTest.java | 92 +-
.../HeterogeneousLuceneSerializerJUnitTest.java | 107 +
.../HeterogenousLuceneSerializerJUnitTest.java | 90 -
.../serializer/PdxFieldMapperJUnitTest.java | 56 +-
.../ReflectionFieldMapperJUnitTest.java | 24 +-
...neIndexXmlGeneratorIntegrationJUnitTest.java | 32 +-
.../xml/LuceneIndexXmlGeneratorJUnitTest.java | 29 +-
...uceneIndexXmlParserIntegrationJUnitTest.java | 85 +-
.../xml/LuceneIndexXmlParserJUnitTest.java | 106 +-
.../cache/lucene/test/IndexRegionSpy.java | 82 +
.../cache/lucene/test/IndexRepositorySpy.java | 130 +
.../cache/lucene/test/LuceneTestUtilities.java | 125 +
.../gemfire/cache/lucene/test/TestObject.java | 59 +
.../gemfire/cache/lucene/test/package-info.java | 23 +
...ifferentFieldAnalyzerSizesFails1.1.cache.xml | 37 +
...ifferentFieldAnalyzerSizesFails1.2.cache.xml | 36 +
...ifferentFieldAnalyzerSizesFails2.1.cache.xml | 36 +
...ifferentFieldAnalyzerSizesFails2.2.cache.xml | 37 +
...ifyDifferentFieldAnalyzersFails1.1.cache.xml | 36 +
...ifyDifferentFieldAnalyzersFails1.2.cache.xml | 36 +
...ifyDifferentFieldAnalyzersFails2.1.cache.xml | 37 +
...ifyDifferentFieldAnalyzersFails2.2.cache.xml | 37 +
...ifyDifferentFieldAnalyzersFails3.1.cache.xml | 37 +
...ifyDifferentFieldAnalyzersFails3.2.cache.xml | 37 +
...tTest.verifyDifferentFieldsFails.1.cache.xml | 36 +
...tTest.verifyDifferentFieldsFails.2.cache.xml | 37 +
...t.verifyDifferentIndexNamesFails.1.cache.xml | 36 +
...t.verifyDifferentIndexNamesFails.2.cache.xml | 36 +
...est.verifyDifferentIndexesFails1.1.cache.xml | 36 +
...est.verifyDifferentIndexesFails1.2.cache.xml | 32 +
...est.verifyDifferentIndexesFails2.1.cache.xml | 36 +
...est.verifyDifferentIndexesFails2.2.cache.xml | 39 +
...nDUnitTest.verifyXMLEmptyIndexList.cache.xml | 33 +
...nitTest.verifyXMLMultipleIndexList.cache.xml | 39 +
...erIntegrationJUnitTest.createIndex.cache.xml | 7 +-
...nJUnitTest.parseIndexWithAnalyzers.cache.xml | 36 +
geode-pulse/build.gradle | 1 +
.../tools/pulse/internal/PulseAppListener.java | 70 +-
.../internal/controllers/PulseController.java | 30 +-
.../tools/pulse/internal/data/Cluster.java | 25 +-
.../tools/pulse/internal/data/DataBrowser.java | 2 +-
.../pulse/internal/data/IClusterUpdater.java | 2 +-
.../pulse/internal/data/JMXDataUpdater.java | 216 +-
.../pulse/internal/data/JmxManagerFinder.java | 2 +-
.../tools/pulse/internal/data/PulseConfig.java | 2 +-
.../pulse/internal/data/PulseConstants.java | 15 +-
.../tools/pulse/internal/data/PulseVersion.java | 2 +-
.../tools/pulse/internal/data/Repository.java | 56 +-
.../tools/pulse/internal/log/LogWriter.java | 2 +-
.../pulse/internal/log/MessageFormatter.java | 2 +-
.../pulse/internal/log/PulseLogWriter.java | 6 +-
.../tools/pulse/internal/log/PulseLogger.java | 4 +-
.../security/GemFireAuthentication.java | 91 +
.../security/GemFireAuthenticationProvider.java | 80 +
.../pulse/internal/security/LogoutHandler.java | 55 +
.../internal/service/ClusterDetailsService.java | 2 +-
.../service/ClusterDiskThroughputService.java | 2 +-
.../service/ClusterGCPausesService.java | 2 +-
.../service/ClusterKeyStatisticsService.java | 2 +-
.../internal/service/ClusterMemberService.java | 2 +-
.../service/ClusterMembersRGraphService.java | 2 +-
.../service/ClusterMemoryUsageService.java | 2 +-
.../internal/service/ClusterRegionService.java | 13 +-
.../internal/service/ClusterRegionsService.java | 13 +-
.../service/ClusterSelectedRegionService.java | 8 +-
.../ClusterSelectedRegionsMemberService.java | 2 +-
.../internal/service/ClusterWANInfoService.java | 2 +-
.../service/MemberAsynchEventQueuesService.java | 2 +-
.../internal/service/MemberClientsService.java | 2 +-
.../internal/service/MemberDetailsService.java | 2 +-
.../service/MemberDiskThroughputService.java | 2 +-
.../internal/service/MemberGCPausesService.java | 2 +-
.../service/MemberGatewayHubService.java | 2 +-
.../service/MemberHeapUsageService.java | 2 +-
.../service/MemberKeyStatisticsService.java | 2 +-
.../internal/service/MemberRegionsService.java | 2 +-
.../internal/service/MembersListService.java | 2 +-
.../pulse/internal/service/PulseService.java | 2 +-
.../internal/service/PulseServiceFactory.java | 2 +-
.../internal/service/PulseVersionService.java | 2 +-
.../service/QueryStatisticsService.java | 2 +-
.../internal/service/SystemAlertsService.java | 2 +-
.../pulse/internal/util/IPAddressUtil.java | 2 +-
.../tools/pulse/internal/util/StringUtils.java | 2 +-
.../tools/pulse/internal/util/TimeUtils.java | 2 +-
.../src/main/resources/gemfire.properties | 2 +-
geode-pulse/src/main/resources/pulse.properties | 12 +-
geode-pulse/src/main/webapp/DataBrowser.html | 2 +-
geode-pulse/src/main/webapp/META-INF/NOTICE | 33 +-
geode-pulse/src/main/webapp/MemberDetails.html | 2 +-
.../src/main/webapp/QueryStatistics.html | 2 +-
.../src/main/webapp/WEB-INF/spring-security.xml | 60 +-
geode-pulse/src/main/webapp/clusterDetail.html | 2 +-
.../main/webapp/properties/gemfire.properties | 2 +-
.../webapp/properties/gemfire_en.properties | 2 +-
geode-pulse/src/main/webapp/regionDetail.html | 2 +-
.../scripts/pulsescript/PulseCallbacks.js | 2 -
.../webapp/scripts/pulsescript/clusterDetail.js | 7 +-
.../webapp/scripts/pulsescript/regionView.js | 2 +-
.../controllers/PulseControllerJUnitTest.java | 91 +-
.../pulse/testbed/GemFireDistributedSystem.java | 4 +-
.../tools/pulse/testbed/driver/PulseUITest.java | 62 +-
.../pulse/tests/DataBrowserResultLoader.java | 14 +-
.../tools/pulse/tests/PulseAbstractTest.java | 1047 ++++
.../tools/pulse/tests/PulseAuthTest.java | 33 +
.../tools/pulse/tests/PulseAutomatedTest.java | 94 +-
.../tools/pulse/tests/PulseBaseTest.java | 79 +-
.../tools/pulse/tests/PulseNoAuthTest.java | 33 +
.../gemfire/tools/pulse/tests/PulseTest.java | 1039 ----
.../gemfire/tools/pulse/tests/Region.java | 11 +-
.../gemfire/tools/pulse/tests/Server.java | 154 +-
geode-pulse/src/test/resources/pulse-auth.json | 21 +
geode-pulse/src/test/resources/test.properties | 6 +-
geode-rebalancer/build.gradle | 7 -
.../util/AutoBalancerIntegrationJUnitTest.java | 36 +-
geode-site/website/README.md | 2 +-
geode-site/website/Rules | 6 +
geode-site/website/content/community/index.html | 3 +-
.../website/content/css/font-awesome.min.css | 409 +-
geode-site/website/content/css/geode-site.css | 41 +-
geode-site/website/content/docs/index.html | 2 +-
geode-site/website/content/font/FontAwesome.otf | Bin 61896 -> 124988 bytes
.../content/font/fontawesome-webfont-eot.eot | Bin 37405 -> 76518 bytes
.../content/font/fontawesome-webfont-svg.svg | 366 +-
.../content/font/fontawesome-webfont-ttf.ttf | Bin 79076 -> 152796 bytes
.../content/font/fontawesome-webfont-woff.woff | Bin 43572 -> 90412 bytes
.../content/font/fontawesome-webfont.woff2 | Bin 0 -> 71896 bytes
geode-site/website/content/index.html | 49 +-
geode-site/website/content/releases/index.html | 54 +-
geode-site/website/layouts/default.html | 2 +-
geode-site/website/layouts/header.html | 20 +-
geode-site/website/layouts/releases.html | 1 +
geode-site/website/lib/default.rb | 4 +-
geode-site/website/nanoc.yaml | 2 +
geode-spark-connector/doc/10_demos.md | 12 +-
geode-spark-connector/doc/1_building.md | 18 +-
geode-spark-connector/doc/2_quick.md | 26 +-
geode-spark-connector/doc/3_connecting.md | 38 +-
geode-spark-connector/doc/4_loading.md | 30 +-
geode-spark-connector/doc/5_rdd_join.md | 26 +-
geode-spark-connector/doc/6_save_rdd.md | 20 +-
geode-spark-connector/doc/7_save_dstream.md | 10 +-
geode-spark-connector/doc/8_oql.md | 8 +-
geode-spark-connector/doc/9_java_api.md | 36 +-
.../connector/internal/RegionMetadata.java | 93 -
.../gemfirefunctions/QueryFunction.java | 99 -
.../RetrieveRegionFunction.java | 208 -
.../RetrieveRegionMetadataFunction.java | 118 -
.../StructStreamingResultSender.java | 219 -
.../gemfire/spark/connector/Employee.java | 54 -
.../spark/connector/JavaApiIntegrationTest.java | 424 --
.../gemfire/spark/connector/Portfolio.java | 109 -
.../gemfire/spark/connector/Position.java | 73 -
.../src/it/resources/test-regions.xml | 49 -
.../src/it/resources/test-retrieve-regions.xml | 57 -
.../spark/connector/BasicIntegrationTest.scala | 598 ---
.../RDDJoinRegionIntegrationTest.scala | 300 --
.../RetrieveRegionIntegrationTest.scala | 253 -
.../gemfire/spark/connector/package.scala | 29 -
.../connector/testkit/GemFireCluster.scala | 47 -
.../spark/connector/testkit/GemFireRunner.scala | 148 -
.../spark/connector/testkit/IOUtils.scala | 94 -
.../spark/streaming/ManualClockHelper.scala | 28 -
.../spark/streaming/TestInputDStream.scala | 44 -
.../javaapi/GemFireJavaDStreamFunctions.java | 86 -
.../GemFireJavaPairDStreamFunctions.java | 77 -
.../javaapi/GemFireJavaPairRDDFunctions.java | 238 -
.../javaapi/GemFireJavaRDDFunctions.java | 178 -
.../javaapi/GemFireJavaSQLContextFunctions.java | 49 -
.../GemFireJavaSparkContextFunctions.java | 87 -
.../connector/javaapi/GemFireJavaUtil.java | 122 -
.../spark/connector/GemFireConnection.scala | 67 -
.../spark/connector/GemFireConnectionConf.scala | 73 -
.../connector/GemFireConnectionManager.scala | 31 -
.../connector/GemFireFunctionDeployer.scala | 81 -
.../connector/GemFireKryoRegistrator.scala | 29 -
.../connector/GemFirePairRDDFunctions.scala | 140 -
.../spark/connector/GemFireRDDFunctions.scala | 120 -
.../connector/GemFireSQLContextFunctions.scala | 42 -
.../GemFireSparkContextFunctions.scala | 39 -
.../internal/DefaultGemFireConnection.scala | 164 -
.../DefaultGemFireConnectionManager.scala | 77 -
.../connector/internal/LocatorHelper.scala | 135 -
.../StructStreamingResultCollector.scala | 152 -
.../connector/internal/oql/QueryParser.scala | 58 -
.../spark/connector/internal/oql/QueryRDD.scala | 83 -
.../internal/oql/QueryResultCollector.scala | 69 -
.../connector/internal/oql/RDDConverter.scala | 40 -
.../connector/internal/oql/RowBuilder.scala | 38 -
.../connector/internal/oql/SchemaBuilder.scala | 73 -
.../internal/oql/UndefinedSerializer.scala | 46 -
.../connector/internal/rdd/GemFireJoinRDD.scala | 67 -
.../internal/rdd/GemFireOuterJoinRDD.scala | 69 -
.../internal/rdd/GemFireRDDPartition.scala | 36 -
.../internal/rdd/GemFireRDDPartitioner.scala | 59 -
.../rdd/GemFireRDDPartitionerImpl.scala | 89 -
.../internal/rdd/GemFireRDDWriter.scala | 82 -
.../internal/rdd/GemFireRegionRDD.scala | 138 -
.../javaapi/GemFireJavaRegionRDD.scala | 26 -
.../spark/connector/javaapi/JavaAPIHelper.scala | 53 -
.../gemfire/spark/connector/package.scala | 69 -
.../streaming/GemFireDStreamFunctions.scala | 89 -
.../spark/connector/streaming/package.scala | 32 -
.../gemfire/spark/connector/JavaAPITest.java | 163 -
.../connector/GemFireFunctionDeployerTest.scala | 58 -
.../DefaultGemFireConnectionManagerTest.scala | 82 -
...tStreamingResultSenderAndCollectorTest.scala | 254 -
.../internal/oql/QueryParserTest.scala | 83 -
.../connector/ConnectorImplicitsTest.scala | 50 -
.../connector/GemFireConnectionConfTest.scala | 100 -
.../connector/GemFireDStreamFunctionsTest.scala | 79 -
.../connector/GemFireRDDFunctionsTest.scala | 139 -
.../spark/connector/LocatorHelperTest.scala | 168 -
.../rdd/GemFireRDDPartitionerTest.scala | 190 -
.../connector/rdd/GemFireRegionRDDTest.scala | 117 -
.../basic-demos/src/main/java/demo/Emp.java | 95 -
.../src/main/java/demo/OQLJavaDemo.java | 59 -
.../src/main/java/demo/PairRDDSaveJavaDemo.java | 86 -
.../src/main/java/demo/RDDSaveJavaDemo.java | 85 -
.../src/main/java/demo/RegionToRDDJavaDemo.java | 57 -
.../src/main/scala/demo/NetworkWordCount.scala | 75 -
.../connector/internal/RegionMetadata.java | 93 +
.../internal/geodefunctions/QueryFunction.java | 99 +
.../geodefunctions/RetrieveRegionFunction.java | 208 +
.../RetrieveRegionMetadataFunction.java | 118 +
.../StructStreamingResultSender.java | 219 +
.../pivotal/geode/spark/connector/Employee.java | 54 +
.../spark/connector/JavaApiIntegrationTest.java | 424 ++
.../geode/spark/connector/Portfolio.java | 109 +
.../pivotal/geode/spark/connector/Position.java | 73 +
.../src/it/resources/test-regions.xml | 49 +
.../src/it/resources/test-retrieve-regions.xml | 57 +
.../spark/connector/BasicIntegrationTest.scala | 598 +++
.../RDDJoinRegionIntegrationTest.scala | 300 ++
.../RetrieveRegionIntegrationTest.scala | 253 +
.../pivotal/geode/spark/connector/package.scala | 29 +
.../spark/connector/testkit/GeodeCluster.scala | 47 +
.../spark/connector/testkit/GeodeRunner.scala | 148 +
.../geode/spark/connector/testkit/IOUtils.scala | 94 +
.../spark/streaming/ManualClockHelper.scala | 28 +
.../spark/streaming/TestInputDStream.scala | 44 +
.../javaapi/GeodeJavaDStreamFunctions.java | 86 +
.../javaapi/GeodeJavaPairDStreamFunctions.java | 77 +
.../javaapi/GeodeJavaPairRDDFunctions.java | 238 +
.../javaapi/GeodeJavaRDDFunctions.java | 178 +
.../javaapi/GeodeJavaSQLContextFunctions.java | 49 +
.../javaapi/GeodeJavaSparkContextFunctions.java | 87 +
.../spark/connector/javaapi/GeodeJavaUtil.java | 122 +
.../geode/spark/connector/GeodeConnection.scala | 67 +
.../spark/connector/GeodeConnectionConf.scala | 73 +
.../connector/GeodeConnectionManager.scala | 31 +
.../spark/connector/GeodeFunctionDeployer.scala | 81 +
.../spark/connector/GeodeKryoRegistrator.scala | 29 +
.../spark/connector/GeodePairRDDFunctions.scala | 140 +
.../spark/connector/GeodeRDDFunctions.scala | 120 +
.../connector/GeodeSQLContextFunctions.scala | 42 +
.../connector/GeodeSparkContextFunctions.scala | 39 +
.../internal/DefaultGeodeConnection.scala | 164 +
.../DefaultGeodeConnectionManager.scala | 77 +
.../connector/internal/LocatorHelper.scala | 135 +
.../StructStreamingResultCollector.scala | 152 +
.../connector/internal/oql/QueryParser.scala | 58 +
.../spark/connector/internal/oql/QueryRDD.scala | 83 +
.../internal/oql/QueryResultCollector.scala | 69 +
.../connector/internal/oql/RDDConverter.scala | 40 +
.../connector/internal/oql/RowBuilder.scala | 38 +
.../connector/internal/oql/SchemaBuilder.scala | 73 +
.../internal/oql/UndefinedSerializer.scala | 46 +
.../connector/internal/rdd/GeodeJoinRDD.scala | 67 +
.../internal/rdd/GeodeOuterJoinRDD.scala | 69 +
.../internal/rdd/GeodeRDDPartition.scala | 36 +
.../internal/rdd/GeodeRDDPartitioner.scala | 59 +
.../internal/rdd/GeodeRDDPartitionerImpl.scala | 89 +
.../connector/internal/rdd/GeodeRDDWriter.scala | 82 +
.../connector/internal/rdd/GeodeRegionRDD.scala | 138 +
.../connector/javaapi/GeodeJavaRegionRDD.scala | 26 +
.../spark/connector/javaapi/JavaAPIHelper.scala | 53 +
.../pivotal/geode/spark/connector/package.scala | 69 +
.../streaming/GeodeDStreamFunctions.scala | 89 +
.../spark/connector/streaming/package.scala | 32 +
.../geode/spark/connector/JavaAPITest.java | 163 +
.../connector/GeodeFunctionDeployerTest.scala | 58 +
.../DefaultGeodeConnectionManagerTest.scala | 82 +
...tStreamingResultSenderAndCollectorTest.scala | 254 +
.../internal/oql/QueryParserTest.scala | 83 +
.../connector/ConnectorImplicitsTest.scala | 50 +
.../connector/GeodeConnectionConfTest.scala | 100 +
.../connector/GeodeDStreamFunctionsTest.scala | 79 +
.../spark/connector/GeodeRDDFunctionsTest.scala | 139 +
.../spark/connector/LocatorHelperTest.scala | 168 +
.../connector/rdd/GeodeRDDPartitionerTest.scala | 190 +
.../connector/rdd/GeodeRegionRDDTest.scala | 117 +
.../basic-demos/src/main/java/demo/Emp.java | 95 +
.../src/main/java/demo/OQLJavaDemo.java | 59 +
.../src/main/java/demo/PairRDDSaveJavaDemo.java | 86 +
.../src/main/java/demo/RDDSaveJavaDemo.java | 85 +
.../src/main/java/demo/RegionToRDDJavaDemo.java | 57 +
.../src/main/scala/demo/NetworkWordCount.scala | 75 +
.../project/Dependencies.scala | 8 +-
.../project/GemFireSparkBuild.scala | 76 -
.../project/GeodeSparkBuild.scala | 76 +
geode-spark-connector/project/Settings.scala | 4 +-
.../client/internal/GatewaySenderBatchOp.java | 10 +-
.../cache/client/internal/SenderProxy.java | 2 +-
.../internal/locator/wan/LocatorDiscovery.java | 34 +-
.../wan/LocatorMembershipListenerImpl.java | 37 +-
.../locator/wan/RemoteLocatorJoinRequest.java | 2 +-
.../locator/wan/WanLocatorDiscovererImpl.java | 38 +-
.../cache/wan/AbstractRemoteGatewaySender.java | 17 +-
.../cache/wan/GatewayReceiverFactoryImpl.java | 2 +-
.../internal/cache/wan/GatewayReceiverImpl.java | 4 +-
.../wan/GatewaySenderEventRemoteDispatcher.java | 38 +-
.../cache/wan/GatewaySenderFactoryImpl.java | 6 +-
.../wan/parallel/ParallelGatewaySenderImpl.java | 6 +-
.../wan/serial/SerialGatewaySenderImpl.java | 2 +-
.../cache/CacheXml70GatewayDUnitTest.java | 38 +-
.../cache/CacheXml80GatewayDUnitTest.java | 21 +-
.../internal/cache/UpdateVersionDUnitTest.java | 102 +-
.../cache/wan/CacheClientNotifierDUnitTest.java | 125 +-
.../cache/wan/Simple2CacheServerDUnitTest.java | 185 +
.../gemfire/internal/cache/wan/WANTestBase.java | 2191 ++------
...oncurrentParallelGatewaySenderDUnitTest.java | 85 +-
...ntParallelGatewaySenderOffHeapDUnitTest.java | 14 +-
...allelGatewaySenderOperation_1_DUnitTest.java | 55 +-
...allelGatewaySenderOperation_2_DUnitTest.java | 193 +-
...tSerialGatewaySenderOperationsDUnitTest.java | 14 +-
...GatewaySenderOperationsOffHeapDUnitTest.java | 14 +-
.../ConcurrentWANPropogation_1_DUnitTest.java | 44 +-
.../ConcurrentWANPropogation_2_DUnitTest.java | 74 +-
.../cache/wan/disttx/DistTXWANDUnitTest.java | 45 +-
.../CommonParallelGatewaySenderDUnitTest.java | 36 +-
...onParallelGatewaySenderOffHeapDUnitTest.java | 14 +-
...wWANConcurrencyCheckForDestroyDUnitTest.java | 38 +-
.../wan/misc/NewWanAuthenticationDUnitTest.java | 309 ++
.../cache/wan/misc/PDXNewWanDUnitTest.java | 67 +-
...dRegion_ParallelWANPersistenceDUnitTest.java | 54 +-
...dRegion_ParallelWANPropogationDUnitTest.java | 117 +-
.../SenderWithTransportFilterDUnitTest.java | 39 +-
...downAllPersistentGatewaySenderDUnitTest.java | 18 +-
.../wan/misc/WANConfigurationJUnitTest.java | 93 +-
.../wan/misc/WANLocatorServerDUnitTest.java | 42 +-
.../cache/wan/misc/WANSSLDUnitTest.java | 23 +-
.../wan/misc/WanAutoDiscoveryDUnitTest.java | 99 +-
.../cache/wan/misc/WanValidationsDUnitTest.java | 125 +-
...tewaySenderOperation_2_OffHeapDUnitTest.java | 14 +-
...tewaySenderOperation_2_OffHeapDUnitTest.java | 14 +-
...GatewaySenderOperationsOffHeapDUnitTest.java | 14 +-
...ewaySenderQueueOverflowOffHeapDUnitTest.java | 14 +-
.../ParallelWANConflationOffHeapDUnitTest.java | 14 +-
...nceEnabledGatewaySenderOffHeapDUnitTest.java | 14 +-
...ropogationConcurrentOpsOffHeapDUnitTest.java | 14 +-
.../ParallelWANPropogationOffHeapDUnitTest.java | 17 +-
...erialGatewaySenderQueueOffHeapDUnitTest.java | 14 +-
...nceEnabledGatewaySenderOffHeapDUnitTest.java | 14 +-
.../SerialWANPropogationOffHeapDUnitTest.java | 17 +-
...ation_PartitionedRegionOffHeapDUnitTest.java | 17 +-
...allelGatewaySenderOperation_2_DUnitTest.java | 14 +-
...arallelGatewaySenderOperationsDUnitTest.java | 69 +-
...llelGatewaySenderQueueOverflowDUnitTest.java | 123 +-
.../ParallelWANConflationDUnitTest.java | 41 +-
...ersistenceEnabledGatewaySenderDUnitTest.java | 72 +-
...llelWANPropagationClientServerDUnitTest.java | 15 +-
...lelWANPropagationConcurrentOpsDUnitTest.java | 23 +-
.../ParallelWANPropagationDUnitTest.java | 88 +-
...ParallelWANPropagationLoopBackDUnitTest.java | 36 +-
.../wan/parallel/ParallelWANStatsDUnitTest.java | 48 +-
...tewaySenderDistributedDeadlockDUnitTest.java | 38 +-
...rialGatewaySenderEventListenerDUnitTest.java | 42 +-
.../SerialGatewaySenderOperationsDUnitTest.java | 50 +-
.../SerialGatewaySenderQueueDUnitTest.java | 41 +-
...ersistenceEnabledGatewaySenderDUnitTest.java | 35 +-
.../SerialWANPropagationLoopBackDUnitTest.java | 46 +-
.../serial/SerialWANPropogationDUnitTest.java | 298 +-
...NPropogation_PartitionedRegionDUnitTest.java | 45 +-
.../SerialWANPropogationsFeatureDUnitTest.java | 48 +-
.../wan/serial/SerialWANStatsDUnitTest.java | 71 +-
.../wan/wancommand/WANCommandTestBase.java | 195 +-
...anCommandCreateGatewayReceiverDUnitTest.java | 271 +-
.../WanCommandCreateGatewaySenderDUnitTest.java | 306 +-
...WanCommandGatewayReceiverStartDUnitTest.java | 189 +-
.../WanCommandGatewayReceiverStopDUnitTest.java | 187 +-
.../WanCommandGatewaySenderStartDUnitTest.java | 247 +-
.../WanCommandGatewaySenderStopDUnitTest.java | 236 +-
.../wan/wancommand/WanCommandListDUnitTest.java | 207 +-
.../WanCommandPauseResumeDUnitTest.java | 559 +-
.../wancommand/WanCommandStatusDUnitTest.java | 293 +-
.../management/WANManagementDUnitTest.java | 23 +-
.../ClusterConfigurationDUnitTest.java | 1268 +++--
.../pulse/TestRemoteClusterDUnitTest.java | 17 +-
.../web/controllers/AbstractBaseController.java | 2 +-
.../web/controllers/BaseControllerAdvice.java | 2 +-
.../web/controllers/CommonCrudController.java | 2 +-
.../controllers/FunctionAccessController.java | 2 +-
.../web/controllers/PdxBasedCrudController.java | 2 +-
.../web/controllers/QueryAccessController.java | 2 +-
.../controllers/support/QueryResultTypes.java | 2 +-
.../web/controllers/support/RegionData.java | 2 +-
.../controllers/support/RegionEntryData.java | 2 +-
.../DataTypeNotSupportedException.java | 2 +-
.../web/exception/GemfireRestException.java | 2 +-
.../web/exception/MalformedJsonException.java | 2 +-
.../web/exception/RegionNotFoundException.java | 2 +-
.../exception/ResourceNotFoundException.java | 2 +-
...stomMappingJackson2HttpMessageConverter.java | 2 +-
.../web/swagger/config/RestApiPathProvider.java | 30 +-
.../rest/internal/web/util/ArrayUtils.java | 2 +-
.../rest/internal/web/util/DateTimeUtils.java | 2 +-
.../internal/web/util/IdentifiableUtils.java | 2 +-
.../rest/internal/web/util/JSONUtils.java | 2 +-
.../rest/internal/web/util/JsonWriter.java | 2 +-
.../rest/internal/web/util/NumberUtils.java | 2 +-
.../rest/internal/web/util/ValidationUtils.java | 2 +-
geode-web-api/src/main/webapp/META-INF/NOTICE | 18 +-
geode-web/build.gradle | 15 +-
geode-web/src/main/webapp/META-INF/NOTICE | 3 -
.../src/main/webapp/WEB-INF/gemfire-servlet.xml | 2 +-
.../cli/commands/CommandOverHttpDUnitTest.java | 58 +
.../ConnectCommandWithHttpAndSSLDUnitTest.java | 305 ++
.../DataCommandsOverHttpDistributedTest.java | 151 +
.../GfshCommandsOverHttpSecurityTest.java | 30 +
.../internal/web/AbstractWebTestCase.java | 2 +-
.../ShellCommandsControllerJUnitTest.java | 21 +-
...entVariablesHandlerInterceptorJUnitTest.java | 267 -
.../LoginHandlerInterceptorJUnitTest.java | 273 +
.../internal/web/domain/LinkIndexJUnitTest.java | 2 +-
.../internal/web/domain/LinkJUnitTest.java | 2 +-
.../domain/QueryParameterSourceJUnitTest.java | 2 +-
.../web/http/ClientHttpRequestJUnitTest.java | 14 +-
...ableObjectHttpMessageConverterJUnitTest.java | 8 +-
.../RestHttpOperationInvokerJUnitTest.java | 34 +-
.../SimpleHttpOperationInvokerJUnitTest.java | 10 +-
.../web/util/ConvertUtilsJUnitTest.java | 6 +-
.../internal/web/util/UriUtilsJUnitTest.java | 2 +-
gradle.properties | 3 +-
gradle/dependency-versions.properties | 27 +-
gradle/ide.gradle | 15 +-
gradle/publish.gradle | 35 +
gradle/rat.gradle | 8 +
gradle/test.gradle | 84 +-
gradle/wrapper/gradle-wrapper.jar | Bin 53637 -> 53639 bytes
gradle/wrapper/gradle-wrapper.properties | 4 +-
gradlew | 2 +-
gradlew.bat | 2 +-
settings.gradle | 3 +-
4537 files changed, 160199 insertions(+), 167669 deletions(-)
----------------------------------------------------------------------