You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by rv...@apache.org on 2015/04/28 23:40:56 UTC
[51/51] [partial] incubator-geode git commit: Init
Init
Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/19459053
Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/19459053
Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/19459053
Branch: refs/heads/master
Commit: 194590531e50039c23459956a162c4c5257640a4
Parents:
Author: Roman Shaposhnik <rv...@apache.org>
Authored: Tue Apr 28 14:37:16 2015 -0700
Committer: Roman Shaposhnik <rv...@apache.org>
Committed: Tue Apr 28 14:37:16 2015 -0700
----------------------------------------------------------------------
.gitignore | 19 +
COMPILING.txt | 13 +
LICENSE.txt | 202 +
NOTICE | 339 +
README.md | 90 +
RUNNING.txt | 23 +
build.gradle | 267 +
etc/eclipseFormatterProfile.xml | 264 +
etc/intellijIdeaCodeStyle.xml | 109 +
gemfire-assembly/build.gradle | 171 +
gemfire-assembly/src/main/dist/bin/gfsh | 138 +
.../src/main/dist/bin/gfsh-completion.bash | 88 +
gemfire-assembly/src/main/dist/bin/gfsh.bat | 73 +
gemfire-core/build.gradle | 133 +
.../internal/ra/GFConnectionFactoryImpl.java | 57 +
.../gemfire/internal/ra/GFConnectionImpl.java | 62 +
.../internal/ra/spi/JCALocalTransaction.java | 227 +
.../internal/ra/spi/JCAManagedConnection.java | 290 +
.../ra/spi/JCAManagedConnectionFactory.java | 136 +
.../ra/spi/JCAManagedConnectionMetaData.java | 58 +
gemfire-core/src/jca/ra.xml | 37 +
.../com/gemstone/gemfire/CancelCriterion.java | 100 +
.../com/gemstone/gemfire/CancelException.java | 55 +
.../gemstone/gemfire/CanonicalInstantiator.java | 77 +
.../com/gemstone/gemfire/CopyException.java | 58 +
.../java/com/gemstone/gemfire/CopyHelper.java | 259 +
.../com/gemstone/gemfire/DataSerializable.java | 131 +
.../com/gemstone/gemfire/DataSerializer.java | 3542 +++++
.../main/java/com/gemstone/gemfire/Delta.java | 57 +
.../gemfire/DeltaSerializationException.java | 50 +
.../gemfire/ForcedDisconnectException.java | 32 +
.../gemstone/gemfire/GemFireCacheException.java | 41 +
.../gemfire/GemFireCheckedException.java | 81 +
.../gemfire/GemFireConfigException.java | 33 +
.../com/gemstone/gemfire/GemFireException.java | 140 +
.../gemstone/gemfire/GemFireIOException.java | 32 +
.../gemstone/gemfire/GemFireRethrowable.java | 38 +
.../gemfire/IncompatibleSystemException.java | 29 +
.../java/com/gemstone/gemfire/Instantiator.java | 303 +
.../gemstone/gemfire/InternalGemFireError.java | 145 +
.../gemfire/InternalGemFireException.java | 47 +
.../gemstone/gemfire/InvalidDeltaException.java | 54 +
.../gemstone/gemfire/InvalidValueException.java | 33 +
.../gemfire/InvalidVersionException.java | 9 +
.../com/gemstone/gemfire/LicenseException.java | 45 +
.../java/com/gemstone/gemfire/LogWriter.java | 292 +
.../com/gemstone/gemfire/NoSystemException.java | 39 +
.../gemfire/SerializationException.java | 36 +
.../gemstone/gemfire/StatisticDescriptor.java | 73 +
.../java/com/gemstone/gemfire/Statistics.java | 437 +
.../com/gemstone/gemfire/StatisticsFactory.java | 145 +
.../com/gemstone/gemfire/StatisticsType.java | 63 +
.../gemstone/gemfire/StatisticsTypeFactory.java | 188 +
.../gemfire/SystemConnectException.java | 33 +
.../com/gemstone/gemfire/SystemFailure.java | 1215 ++
.../gemfire/SystemIsRunningException.java | 37 +
.../gemfire/ThreadInterruptedException.java | 15 +
.../com/gemstone/gemfire/ToDataException.java | 33 +
.../gemfire/UncreatedSystemException.java | 39 +
.../gemstone/gemfire/UnmodifiableException.java | 27 +
.../gemfire/UnstartedSystemException.java | 40 +
.../com/gemstone/gemfire/admin/AdminConfig.java | 148 +
.../gemfire/admin/AdminDistributedSystem.java | 479 +
.../admin/AdminDistributedSystemFactory.java | 154 +
.../gemstone/gemfire/admin/AdminException.java | 81 +
.../gemfire/admin/AdminXmlException.java | 39 +
.../java/com/gemstone/gemfire/admin/Alert.java | 47 +
.../com/gemstone/gemfire/admin/AlertLevel.java | 165 +
.../gemstone/gemfire/admin/AlertListener.java | 21 +
.../gemstone/gemfire/admin/BackupStatus.java | 40 +
.../admin/CacheDoesNotExistException.java | 78 +
.../gemfire/admin/CacheHealthConfig.java | 148 +
.../com/gemstone/gemfire/admin/CacheServer.java | 37 +
.../gemfire/admin/CacheServerConfig.java | 46 +
.../com/gemstone/gemfire/admin/CacheVm.java | 29 +
.../gemstone/gemfire/admin/CacheVmConfig.java | 45 +
.../gemfire/admin/ConfigurationParameter.java | 65 +
.../gemfire/admin/DistributedSystemConfig.java | 673 +
.../admin/DistributedSystemHealthConfig.java | 68 +
.../gemfire/admin/DistributionLocator.java | 38 +
.../admin/DistributionLocatorConfig.java | 81 +
.../gemstone/gemfire/admin/GemFireHealth.java | 225 +
.../gemfire/admin/GemFireHealthConfig.java | 49 +
.../gemfire/admin/GemFireMemberStatus.java | 705 +
.../gemstone/gemfire/admin/ManagedEntity.java | 116 +
.../gemfire/admin/ManagedEntityConfig.java | 91 +
.../gemfire/admin/MemberHealthConfig.java | 133 +
.../admin/OperationCancelledException.java | 39 +
.../gemfire/admin/RegionNotFoundException.java | 30 +
.../gemfire/admin/RegionSubRegionSnapshot.java | 184 +
.../gemfire/admin/RuntimeAdminException.java | 41 +
.../com/gemstone/gemfire/admin/Statistic.java | 57 +
.../gemfire/admin/StatisticResource.java | 77 +
.../gemstone/gemfire/admin/SystemMember.java | 139 +
.../gemfire/admin/SystemMemberBridgeServer.java | 301 +
.../gemfire/admin/SystemMemberCache.java | 223 +
.../gemfire/admin/SystemMemberCacheEvent.java | 18 +
.../admin/SystemMemberCacheListener.java | 64 +
.../gemfire/admin/SystemMemberCacheServer.java | 300 +
.../gemfire/admin/SystemMemberRegion.java | 313 +
.../gemfire/admin/SystemMemberRegionEvent.java | 17 +
.../gemfire/admin/SystemMemberType.java | 137 +
.../gemfire/admin/SystemMembershipEvent.java | 32 +
.../gemfire/admin/SystemMembershipListener.java | 53 +
.../UnmodifiableConfigurationException.java | 80 +
.../admin/internal/AbstractHealthEvaluator.java | 176 +
.../internal/AdminDistributedSystemImpl.java | 2507 ++++
.../admin/internal/BackupStatusImpl.java | 53 +
.../admin/internal/CacheHealthConfigImpl.java | 83 +
.../admin/internal/CacheHealthEvaluator.java | 315 +
.../admin/internal/CacheServerConfigImpl.java | 127 +
.../gemfire/admin/internal/CacheServerImpl.java | 190 +
.../internal/ConfigurationParameterImpl.java | 272 +
.../ConfigurationParameterListener.java | 26 +
.../DisabledManagedEntityController.java | 83 +
.../internal/DistributedSystemConfigImpl.java | 1095 ++
.../DistributedSystemHealthConfigImpl.java | 50 +
.../DistributedSystemHealthEvaluator.java | 163 +
.../DistributedSystemHealthMonitor.java | 428 +
.../internal/DistributionLocatorConfigImpl.java | 183 +
.../admin/internal/DistributionLocatorImpl.java | 322 +
.../EnabledManagedEntityController.java | 403 +
.../admin/internal/FinishBackupRequest.java | 159 +
.../admin/internal/FinishBackupResponse.java | 70 +
.../admin/internal/FlushToDiskRequest.java | 89 +
.../admin/internal/FlushToDiskResponse.java | 37 +
.../admin/internal/GemFireHealthConfigImpl.java | 75 +
.../admin/internal/GemFireHealthEvaluator.java | 179 +
.../admin/internal/GemFireHealthImpl.java | 527 +
.../gemfire/admin/internal/InetAddressUtil.java | 200 +
.../admin/internal/InternalManagedEntity.java | 97 +
.../gemfire/admin/internal/LogCollator.java | 128 +
.../admin/internal/ManagedEntityConfigImpl.java | 254 +
.../admin/internal/ManagedEntityConfigXml.java | 161 +
.../ManagedEntityConfigXmlGenerator.java | 394 +
.../internal/ManagedEntityConfigXmlParser.java | 614 +
.../admin/internal/ManagedEntityController.java | 65 +
.../ManagedEntityControllerFactory.java | 52 +
.../admin/internal/ManagedSystemMemberImpl.java | 262 +
.../admin/internal/MemberHealthConfigImpl.java | 87 +
.../admin/internal/MemberHealthEvaluator.java | 233 +
.../admin/internal/PrepareBackupRequest.java | 124 +
.../admin/internal/PrepareBackupResponse.java | 73 +
.../gemfire/admin/internal/StatisticImpl.java | 88 +
.../admin/internal/StatisticResourceImpl.java | 174 +
.../internal/SystemMemberBridgeServerImpl.java | 225 +
.../internal/SystemMemberCacheEventImpl.java | 52 +
.../SystemMemberCacheEventProcessor.java | 139 +
.../admin/internal/SystemMemberCacheImpl.java | 317 +
.../admin/internal/SystemMemberImpl.java | 511 +
.../internal/SystemMemberRegionEventImpl.java | 54 +
.../admin/internal/SystemMemberRegionImpl.java | 372 +
.../internal/SystemMembershipEventImpl.java | 62 +
.../internal/doc-files/config-hierarchy.fig | 156 +
.../admin/internal/doc-files/health-classes.fig | 233 +
.../admin/internal/doc-files/health-classes.gif | Bin 0 -> 8973 bytes
.../gemfire/admin/internal/package.html | 37 +
.../com/gemstone/gemfire/admin/jmx/Agent.java | 156 +
.../gemstone/gemfire/admin/jmx/AgentConfig.java | 875 ++
.../gemfire/admin/jmx/AgentFactory.java | 43 +
.../internal/AdminDistributedSystemJmxImpl.java | 2332 ++++
.../admin/jmx/internal/AgentConfigImpl.java | 1847 +++
.../gemfire/admin/jmx/internal/AgentImpl.java | 1615 +++
.../admin/jmx/internal/AgentLauncher.java | 880 ++
.../admin/jmx/internal/CacheServerJmxImpl.java | 633 +
.../admin/jmx/internal/ConfigAttributeInfo.java | 69 +
.../internal/ConfigurationParameterJmxImpl.java | 161 +
.../DistributedSystemHealthConfigJmxImpl.java | 99 +
.../internal/DistributionLocatorJmxImpl.java | 178 +
.../admin/jmx/internal/DynamicManagedBean.java | 134 +
.../internal/GemFireHealthConfigJmxImpl.java | 214 +
.../jmx/internal/GemFireHealthJmxImpl.java | 170 +
.../admin/jmx/internal/GenerateMBeanHTML.java | 505 +
.../gemfire/admin/jmx/internal/MBeanUtil.java | 761 +
.../admin/jmx/internal/MX4JModelMBean.java | 1246 ++
.../jmx/internal/MX4JServerSocketFactory.java | 152 +
.../gemfire/admin/jmx/internal/MailManager.java | 324 +
.../admin/jmx/internal/ManagedResource.java | 69 +
.../admin/jmx/internal/ManagedResourceType.java | 201 +
.../jmx/internal/MemberInfoWithStatsMBean.java | 1379 ++
.../admin/jmx/internal/RMIRegistryService.java | 231 +
.../jmx/internal/RMIRegistryServiceMBean.java | 77 +
.../jmx/internal/RefreshNotificationType.java | 124 +
.../jmx/internal/StatAlertNotification.java | 153 +
.../jmx/internal/StatAlertsAggregator.java | 116 +
.../jmx/internal/StatisticAttributeInfo.java | 71 +
.../jmx/internal/StatisticResourceJmxImpl.java | 352 +
.../SystemMemberBridgeServerJmxImpl.java | 126 +
.../jmx/internal/SystemMemberCacheJmxImpl.java | 479 +
.../admin/jmx/internal/SystemMemberJmx.java | 499 +
.../admin/jmx/internal/SystemMemberJmxImpl.java | 584 +
.../jmx/internal/SystemMemberRegionJmxImpl.java | 131 +
.../gemfire/admin/jmx/internal/package.html | 150 +
.../com/gemstone/gemfire/admin/jmx/package.html | 12 +
.../com/gemstone/gemfire/admin/package.html | 62 +
.../gemfire/cache/AttributesFactory.java | 1999 +++
.../gemfire/cache/AttributesMutator.java | 194 +
.../java/com/gemstone/gemfire/cache/Cache.java | 474 +
.../gemstone/gemfire/cache/CacheCallback.java | 38 +
.../gemfire/cache/CacheClosedException.java | 68 +
.../com/gemstone/gemfire/cache/CacheEvent.java | 101 +
.../gemstone/gemfire/cache/CacheException.java | 61 +
.../gemfire/cache/CacheExistsException.java | 57 +
.../gemstone/gemfire/cache/CacheFactory.java | 397 +
.../gemstone/gemfire/cache/CacheListener.java | 165 +
.../com/gemstone/gemfire/cache/CacheLoader.java | 55 +
.../gemfire/cache/CacheLoaderException.java | 57 +
.../gemfire/cache/CacheRuntimeException.java | 72 +
.../gemstone/gemfire/cache/CacheStatistics.java | 121 +
.../gemfire/cache/CacheTransactionManager.java | 322 +
.../com/gemstone/gemfire/cache/CacheWriter.java | 142 +
.../gemfire/cache/CacheWriterException.java | 61 +
.../gemfire/cache/CacheXmlException.java | 41 +
.../gemstone/gemfire/cache/ClientSession.java | 189 +
.../gemfire/cache/CommitConflictException.java | 48 +
.../cache/CommitDistributionException.java | 72 +
.../cache/CommitIncompleteException.java | 15 +
.../gemstone/gemfire/cache/CustomExpiry.java | 33 +
.../com/gemstone/gemfire/cache/DataPolicy.java | 246 +
.../com/gemstone/gemfire/cache/Declarable.java | 68 +
.../gemfire/cache/DiskAccessException.java | 132 +
.../com/gemstone/gemfire/cache/DiskStore.java | 207 +
.../gemfire/cache/DiskStoreFactory.java | 234 +
.../gemfire/cache/DiskWriteAttributes.java | 99 +
.../cache/DiskWriteAttributesFactory.java | 254 +
.../DuplicatePrimaryPartitionException.java | 56 +
.../gemfire/cache/DynamicRegionFactory.java | 1118 ++
.../gemfire/cache/DynamicRegionListener.java | 61 +
.../gemfire/cache/EntryDestroyedException.java | 52 +
.../com/gemstone/gemfire/cache/EntryEvent.java | 146 +
.../gemfire/cache/EntryExistsException.java | 53 +
.../gemfire/cache/EntryNotFoundException.java | 42 +
.../gemfire/cache/EntryNotFoundInRegion.java | 41 +
.../gemstone/gemfire/cache/EntryOperation.java | 77 +
.../gemstone/gemfire/cache/EvictionAction.java | 105 +
.../gemfire/cache/EvictionAlgorithm.java | 141 +
.../gemfire/cache/EvictionAttributes.java | 486 +
.../cache/EvictionAttributesMutator.java | 31 +
.../gemfire/cache/ExpirationAction.java | 114 +
.../gemfire/cache/ExpirationAttributes.java | 135 +
.../cache/FailedSynchronizationException.java | 46 +
.../gemfire/cache/FixedPartitionAttributes.java | 106 +
.../gemfire/cache/FixedPartitionResolver.java | 71 +
.../cache/GatewayConfigurationException.java | 36 +
.../gemfire/cache/GatewayException.java | 59 +
.../gemstone/gemfire/cache/GemFireCache.java | 254 +
.../cache/IncompatibleVersionException.java | 39 +
.../gemstone/gemfire/cache/InterestPolicy.java | 140 +
.../cache/InterestRegistrationEvent.java | 83 +
.../cache/InterestRegistrationListener.java | 75 +
.../gemfire/cache/InterestResultPolicy.java | 113 +
.../gemstone/gemfire/cache/LoaderHelper.java | 72 +
.../com/gemstone/gemfire/cache/LossAction.java | 140 +
.../gemfire/cache/LowMemoryException.java | 58 +
.../gemfire/cache/MembershipAttributes.java | 260 +
.../com/gemstone/gemfire/cache/MirrorType.java | 127 +
.../cache/NoQueueServersAvailableException.java | 55 +
...NoSubscriptionServersAvailableException.java | 55 +
.../com/gemstone/gemfire/cache/Operation.java | 987 ++
.../cache/OperationAbortedException.java | 54 +
.../gemfire/cache/PartitionAttributes.java | 162 +
.../cache/PartitionAttributesFactory.java | 445 +
.../gemfire/cache/PartitionResolver.java | 76 +
.../PartitionedRegionDistributionException.java | 37 +
.../PartitionedRegionStorageException.java | 87 +
.../java/com/gemstone/gemfire/cache/Region.java | 2385 ++++
.../gemfire/cache/RegionAccessException.java | 109 +
.../gemfire/cache/RegionAttributes.java | 450 +
.../gemfire/cache/RegionDestroyedException.java | 43 +
.../cache/RegionDistributionException.java | 114 +
.../com/gemstone/gemfire/cache/RegionEvent.java | 32 +
.../gemfire/cache/RegionExistsException.java | 56 +
.../gemstone/gemfire/cache/RegionFactory.java | 893 ++
.../gemfire/cache/RegionMembershipListener.java | 74 +
.../cache/RegionReinitializedException.java | 39 +
.../gemfire/cache/RegionRoleException.java | 54 +
.../gemfire/cache/RegionRoleListener.java | 45 +
.../gemstone/gemfire/cache/RegionService.java | 133 +
.../gemstone/gemfire/cache/RegionShortcut.java | 229 +
.../cache/RemoteTransactionException.java | 33 +
.../gemstone/gemfire/cache/RequiredRoles.java | 108 +
.../gemfire/cache/ResourceException.java | 52 +
.../gemfire/cache/ResumptionAction.java | 105 +
.../com/gemstone/gemfire/cache/RoleEvent.java | 30 +
.../gemstone/gemfire/cache/RoleException.java | 59 +
.../java/com/gemstone/gemfire/cache/Scope.java | 159 +
.../gemfire/cache/SerializedCacheValue.java | 40 +
.../cache/StatisticsDisabledException.java | 59 +
.../gemfire/cache/SubscriptionAttributes.java | 108 +
.../SynchronizationCommitConflictException.java | 40 +
.../gemfire/cache/TimeoutException.java | 64 +
...TransactionDataNodeHasDepartedException.java | 33 +
.../TransactionDataNotColocatedException.java | 37 +
.../TransactionDataRebalancedException.java | 29 +
.../gemfire/cache/TransactionEvent.java | 105 +
.../gemfire/cache/TransactionException.java | 34 +
.../gemstone/gemfire/cache/TransactionId.java | 24 +
.../cache/TransactionInDoubtException.java | 33 +
.../gemfire/cache/TransactionListener.java | 57 +
.../gemfire/cache/TransactionWriter.java | 35 +
.../cache/TransactionWriterException.java | 36 +
...upportedOperationInTransactionException.java | 28 +
.../cache/UnsupportedVersionException.java | 35 +
.../gemfire/cache/VersionException.java | 41 +
.../gemfire/cache/asyncqueue/AsyncEvent.java | 33 +
.../cache/asyncqueue/AsyncEventListener.java | 67 +
.../cache/asyncqueue/AsyncEventQueue.java | 142 +
.../asyncqueue/AsyncEventQueueFactory.java | 182 +
.../internal/AsyncEventQueueFactoryImpl.java | 279 +
.../internal/AsyncEventQueueImpl.java | 188 +
.../internal/AsyncEventQueueStats.java | 177 +
.../internal/ParallelAsyncEventQueueImpl.java | 244 +
.../internal/SerialAsyncEventQueueImpl.java | 241 +
.../client/AllConnectionsInUseException.java | 52 +
.../gemfire/cache/client/ClientCache.java | 159 +
.../cache/client/ClientCacheFactory.java | 680 +
.../cache/client/ClientNotReadyException.java | 47 +
.../cache/client/ClientRegionFactory.java | 337 +
.../cache/client/ClientRegionShortcut.java | 99 +
.../client/NoAvailableLocatorsException.java | 50 +
.../client/NoAvailableServersException.java | 50 +
.../com/gemstone/gemfire/cache/client/Pool.java | 242 +
.../gemfire/cache/client/PoolFactory.java | 462 +
.../gemfire/cache/client/PoolManager.java | 89 +
.../client/ServerConnectivityException.java | 54 +
.../cache/client/ServerOperationException.java | 77 +
.../ServerRefusedConnectionException.java | 32 +
.../client/SubscriptionNotEnabledException.java | 54 +
.../client/doc-files/example-client-cache.xml | 30 +
.../cache/client/internal/AbstractOp.java | 427 +
.../cache/client/internal/AddPDXEnumOp.java | 89 +
.../cache/client/internal/AddPDXTypeOp.java | 89 +
.../client/internal/AuthenticateUserOp.java | 301 +
.../internal/AutoConnectionSourceImpl.java | 378 +
.../cache/client/internal/BridgePoolImpl.java | 479 +
.../internal/BridgeServerLoadMessage.java | 99 +
.../gemfire/cache/client/internal/ClearOp.java | 97 +
.../client/internal/ClientMetadataService.java | 835 ++
.../client/internal/ClientPartitionAdvisor.java | 279 +
.../internal/ClientRegionFactoryImpl.java | 262 +
.../cache/client/internal/ClientUpdater.java | 27 +
.../client/internal/CloseConnectionOp.java | 86 +
.../gemfire/cache/client/internal/CommitOp.java | 100 +
.../cache/client/internal/Connection.java | 75 +
.../client/internal/ConnectionFactory.java | 59 +
.../client/internal/ConnectionFactoryImpl.java | 305 +
.../cache/client/internal/ConnectionImpl.java | 326 +
.../cache/client/internal/ConnectionSource.java | 68 +
.../cache/client/internal/ConnectionStats.java | 3283 +++++
.../cache/client/internal/ContainsKeyOp.java | 93 +
.../DataSerializerRecoveryListener.java | 144 +
.../cache/client/internal/DestroyOp.java | 282 +
.../cache/client/internal/DestroyRegionOp.java | 95 +
.../gemfire/cache/client/internal/Endpoint.java | 102 +
.../cache/client/internal/EndpointManager.java | 91 +
.../client/internal/EndpointManagerImpl.java | 301 +
.../cache/client/internal/ExecutablePool.java | 141 +
.../client/internal/ExecuteFunctionHelper.java | 21 +
.../client/internal/ExecuteFunctionNoAckOp.java | 234 +
.../client/internal/ExecuteFunctionOp.java | 644 +
.../internal/ExecuteRegionFunctionNoAckOp.java | 218 +
.../internal/ExecuteRegionFunctionOp.java | 615 +
.../ExecuteRegionFunctionSingleHopOp.java | 491 +
.../internal/ExplicitConnectionSourceImpl.java | 341 +
.../gemfire/cache/client/internal/GetAllOp.java | 233 +
.../client/internal/GetClientPRMetaDataOp.java | 162 +
.../GetClientPartitionAttributesOp.java | 169 +
.../cache/client/internal/GetEntryOp.java | 73 +
.../cache/client/internal/GetEventValueOp.java | 113 +
.../client/internal/GetFunctionAttributeOp.java | 75 +
.../gemfire/cache/client/internal/GetOp.java | 241 +
.../cache/client/internal/GetPDXEnumByIdOp.java | 85 +
.../cache/client/internal/GetPDXEnumsOp.java | 103 +
.../client/internal/GetPDXIdForEnumOp.java | 106 +
.../client/internal/GetPDXIdForTypeOp.java | 106 +
.../cache/client/internal/GetPDXTypeByIdOp.java | 85 +
.../cache/client/internal/GetPDXTypesOp.java | 103 +
.../internal/InstantiatorRecoveryListener.java | 150 +
.../cache/client/internal/InternalPool.java | 34 +
.../cache/client/internal/InvalidateOp.java | 112 +
.../gemfire/cache/client/internal/KeySetOp.java | 121 +
.../cache/client/internal/LiveServerPinger.java | 108 +
.../internal/LocatorDiscoveryCallback.java | 38 +
.../LocatorDiscoveryCallbackAdapter.java | 27 +
.../cache/client/internal/MakePrimaryOp.java | 82 +
.../gemfire/cache/client/internal/Op.java | 34 +
.../cache/client/internal/OpExecutorImpl.java | 964 ++
.../internal/PdxRegistryRecoveryListener.java | 81 +
.../gemfire/cache/client/internal/PingOp.java | 104 +
.../gemfire/cache/client/internal/PoolImpl.java | 1513 ++
.../cache/client/internal/PrimaryAckOp.java | 92 +
.../cache/client/internal/ProxyCache.java | 239 +
.../client/internal/ProxyCacheCloseOp.java | 115 +
.../cache/client/internal/ProxyRegion.java | 689 +
.../gemfire/cache/client/internal/PutAllOp.java | 417 +
.../gemfire/cache/client/internal/PutOp.java | 540 +
.../gemfire/cache/client/internal/QueryOp.java | 194 +
.../client/internal/QueueConnectionImpl.java | 216 +
.../cache/client/internal/QueueManager.java | 48 +
.../cache/client/internal/QueueManagerImpl.java | 1478 ++
.../cache/client/internal/QueueState.java | 17 +
.../cache/client/internal/QueueStateImpl.java | 440 +
.../cache/client/internal/ReadyForEventsOp.java | 82 +
.../internal/RegisterDataSerializersOp.java | 129 +
.../internal/RegisterInstantiatorsOp.java | 171 +
.../client/internal/RegisterInterestListOp.java | 138 +
.../client/internal/RegisterInterestOp.java | 287 +
.../internal/RegisterInterestTracker.java | 410 +
.../cache/client/internal/RemoveAllOp.java | 382 +
.../cache/client/internal/RollbackOp.java | 90 +
.../cache/client/internal/ServerBlackList.java | 179 +
.../cache/client/internal/ServerProxy.java | 60 +
.../client/internal/ServerRegionDataAccess.java | 134 +
.../client/internal/ServerRegionProxy.java | 894 ++
.../internal/SingleHopClientExecutor.java | 387 +
.../internal/SingleHopOperationCallable.java | 74 +
.../gemfire/cache/client/internal/SizeOp.java | 83 +
.../cache/client/internal/TXFailoverOp.java | 84 +
.../client/internal/TXSynchronizationOp.java | 154 +
.../internal/UnregisterInterestListOp.java | 91 +
.../client/internal/UnregisterInterestOp.java | 89 +
.../cache/client/internal/UserAttributes.java | 50 +
.../doc-files/ConnectionManagerImpl.dia | Bin 0 -> 2034 bytes
.../doc-files/ConnectionManagerImpl.png | Bin 0 -> 11825 bytes
.../client/internal/doc-files/PoolImpl.dia | Bin 0 -> 3083 bytes
.../internal/doc-files/QueueManagerImpl.dia | Bin 0 -> 2180 bytes
.../internal/doc-files/QueueManagerImpl.png | Bin 0 -> 15075 bytes
.../doc-files/client_static_diagram.png | Bin 0 -> 29430 bytes
.../locator/ClientConnectionRequest.java | 59 +
.../locator/ClientConnectionResponse.java | 76 +
.../locator/ClientReplacementRequest.java | 66 +
.../internal/locator/GetAllServersRequest.java | 50 +
.../internal/locator/GetAllServersResponse.java | 72 +
.../internal/locator/LocatorListRequest.java | 27 +
.../internal/locator/LocatorListResponse.java | 83 +
.../internal/locator/LocatorStatusRequest.java | 29 +
.../internal/locator/LocatorStatusResponse.java | 313 +
.../locator/QueueConnectionRequest.java | 90 +
.../locator/QueueConnectionResponse.java | 78 +
.../internal/locator/SerializationHelper.java | 114 +
.../internal/locator/ServerLocationRequest.java | 52 +
.../locator/ServerLocationResponse.java | 24 +
.../locator/wan/LocatorJoinMessage.java | 96 +
.../locator/wan/LocatorMembershipListener.java | 48 +
.../locator/wan/RemoteLocatorJoinRequest.java | 78 +
.../locator/wan/RemoteLocatorJoinResponse.java | 80 +
.../locator/wan/RemoteLocatorPingRequest.java | 47 +
.../locator/wan/RemoteLocatorPingResponse.java | 46 +
.../locator/wan/RemoteLocatorRequest.java | 57 +
.../locator/wan/RemoteLocatorResponse.java | 65 +
.../gemfire/cache/client/internal/package.html | 47 +
.../pooling/ConnectionDestroyedException.java | 39 +
.../internal/pooling/ConnectionManager.java | 123 +
.../internal/pooling/ConnectionManagerImpl.java | 1573 +++
.../internal/pooling/PooledConnection.java | 344 +
.../gemstone/gemfire/cache/client/package.html | 52 +
.../gemfire/cache/control/RebalanceFactory.java | 57 +
.../cache/control/RebalanceOperation.java | 66 +
.../gemfire/cache/control/RebalanceResults.java | 97 +
.../gemfire/cache/control/ResourceManager.java | 176 +
.../gemstone/gemfire/cache/control/package.html | 7 +
.../gemfire/cache/doc-files/architecture.fig | 170 +
.../gemfire/cache/doc-files/architecture.gif | Bin 0 -> 9983 bytes
.../cache/doc-files/entry-life-cycle.fig | 64 +
.../cache/doc-files/entry-life-cycle.gif | Bin 0 -> 3357 bytes
.../gemfire/cache/doc-files/example-cache.xml | 82 +
.../gemfire/cache/doc-files/example2-cache.xml | 46 +
.../gemfire/cache/doc-files/example3-cache.xml | 44 +
.../cache/doc-files/partitioned-regions.fig | 267 +
.../cache/doc-files/partitioned-regions.gif | Bin 0 -> 9494 bytes
.../execute/EmtpyRegionFunctionException.java | 55 +
.../gemfire/cache/execute/Execution.java | 216 +
.../gemfire/cache/execute/Function.java | 104 +
.../gemfire/cache/execute/FunctionAdapter.java | 116 +
.../gemfire/cache/execute/FunctionContext.java | 72 +
.../cache/execute/FunctionException.java | 121 +
.../FunctionInvocationTargetException.java | 85 +
.../gemfire/cache/execute/FunctionService.java | 363 +
.../cache/execute/RegionFunctionContext.java | 63 +
.../gemfire/cache/execute/ResultCollector.java | 128 +
.../gemfire/cache/execute/ResultSender.java | 86 +
.../internal/FunctionServiceManager.java | 453 +
.../gemstone/gemfire/cache/execute/package.html | 147 +
.../operations/CloseCQOperationContext.java | 56 +
.../operations/DestroyOperationContext.java | 54 +
.../operations/ExecuteCQOperationContext.java | 59 +
.../ExecuteFunctionOperationContext.java | 88 +
.../GetDurableCQsOperationContext.java | 51 +
.../cache/operations/GetOperationContext.java | 77 +
.../operations/InterestOperationContext.java | 75 +
.../gemfire/cache/operations/InterestType.java | 143 +
.../operations/InvalidateOperationContext.java | 55 +
.../cache/operations/KeyOperationContext.java | 116 +
.../operations/KeySetOperationContext.java | 88 +
.../operations/KeyValueOperationContext.java | 152 +
.../cache/operations/OperationContext.java | 508 +
.../operations/PutAllOperationContext.java | 398 +
.../cache/operations/PutOperationContext.java | 135 +
.../cache/operations/QueryOperationContext.java | 163 +
.../operations/RegionClearOperationContext.java | 42 +
.../RegionCreateOperationContext.java | 52 +
.../RegionDestroyOperationContext.java | 42 +
.../operations/RegionOperationContext.java | 78 +
.../RegisterInterestOperationContext.java | 63 +
.../operations/RemoveAllOperationContext.java | 92 +
.../operations/StopCQOperationContext.java | 57 +
.../UnregisterInterestOperationContext.java | 45 +
.../gemfire/cache/operations/package.html | 91 +
.../com/gemstone/gemfire/cache/package.html | 593 +
.../cache/partition/PartitionListener.java | 124 +
.../partition/PartitionListenerAdapter.java | 41 +
.../cache/partition/PartitionManager.java | 369 +
.../cache/partition/PartitionMemberInfo.java | 65 +
.../PartitionNotAvailableException.java | 57 +
.../cache/partition/PartitionRebalanceInfo.java | 141 +
.../cache/partition/PartitionRegionHelper.java | 544 +
.../cache/partition/PartitionRegionInfo.java | 104 +
.../gemfire/cache/partition/package.html | 7 +
.../ConflictingPersistentDataException.java | 48 +
.../persistence/PartitionOfflineException.java | 68 +
.../gemfire/cache/persistence/PersistentID.java | 50 +
.../PersistentReplicatesOfflineException.java | 35 +
.../persistence/RevokeFailedException.java | 42 +
.../RevokedPersistentDataException.java | 49 +
.../cache/query/AmbiguousNameException.java | 38 +
.../gemfire/cache/query/CqAttributes.java | 41 +
.../cache/query/CqAttributesFactory.java | 310 +
.../cache/query/CqAttributesMutator.java | 48 +
.../gemfire/cache/query/CqClosedException.java | 48 +
.../gemstone/gemfire/cache/query/CqEvent.java | 84 +
.../gemfire/cache/query/CqException.java | 48 +
.../gemfire/cache/query/CqExistsException.java | 44 +
.../gemfire/cache/query/CqListener.java | 50 +
.../gemstone/gemfire/cache/query/CqQuery.java | 146 +
.../gemstone/gemfire/cache/query/CqResults.java | 42 +
.../cache/query/CqServiceStatistics.java | 61 +
.../gemstone/gemfire/cache/query/CqState.java | 46 +
.../gemfire/cache/query/CqStatistics.java | 44 +
.../gemfire/cache/query/CqStatusListener.java | 33 +
.../cache/query/FunctionDomainException.java | 27 +
.../com/gemstone/gemfire/cache/query/Index.java | 103 +
.../cache/query/IndexCreationException.java | 37 +
.../cache/query/IndexExistsException.java | 43 +
.../cache/query/IndexInvalidException.java | 55 +
.../cache/query/IndexMaintenanceException.java | 57 +
.../cache/query/IndexNameConflictException.java | 43 +
.../gemfire/cache/query/IndexStatistics.java | 67 +
.../gemstone/gemfire/cache/query/IndexType.java | 97 +
.../query/MultiIndexCreationException.java | 66 +
.../cache/query/NameNotFoundException.java | 39 +
.../cache/query/NameResolutionException.java | 38 +
.../query/ParameterCountInvalidException.java | 29 +
.../com/gemstone/gemfire/cache/query/Query.java | 319 +
.../gemfire/cache/query/QueryException.java | 57 +
.../query/QueryExecutionLowMemoryException.java | 58 +
.../query/QueryExecutionTimeoutException.java | 53 +
.../cache/query/QueryInvalidException.java | 39 +
.../query/QueryInvocationTargetException.java | 45 +
.../gemfire/cache/query/QueryService.java | 847 ++
.../gemfire/cache/query/QueryStatistics.java | 29 +
.../cache/query/RegionNotFoundException.java | 36 +
.../gemfire/cache/query/SelectResults.java | 113 +
.../gemstone/gemfire/cache/query/Struct.java | 50 +
.../cache/query/TypeMismatchException.java | 36 +
.../query/internal/AbstractCompiledValue.java | 314 +
.../internal/AbstractGroupOrRangeJunction.java | 589 +
.../cache/query/internal/AllGroupJunction.java | 269 +
.../query/internal/AttributeDescriptor.java | 412 +
.../query/internal/CompiledBindArgument.java | 89 +
.../query/internal/CompiledComparison.java | 860 ++
.../query/internal/CompiledConstruction.java | 70 +
.../cache/query/internal/CompiledFunction.java | 109 +
.../cache/query/internal/CompiledID.java | 91 +
.../cache/query/internal/CompiledIn.java | 1037 ++
.../query/internal/CompiledIndexOperation.java | 175 +
.../query/internal/CompiledIteratorDef.java | 370 +
.../cache/query/internal/CompiledJunction.java | 1189 ++
.../cache/query/internal/CompiledLike.java | 522 +
.../cache/query/internal/CompiledLiteral.java | 77 +
.../cache/query/internal/CompiledNegation.java | 71 +
.../cache/query/internal/CompiledOperation.java | 325 +
.../cache/query/internal/CompiledPath.java | 169 +
.../cache/query/internal/CompiledRegion.java | 103 +
.../cache/query/internal/CompiledSelect.java | 1519 ++
.../query/internal/CompiledSortCriterion.java | 70 +
.../query/internal/CompiledUnaryMinus.java | 93 +
.../cache/query/internal/CompiledUndefined.java | 313 +
.../cache/query/internal/CompiledValue.java | 133 +
.../query/internal/CompositeGroupJunction.java | 550 +
.../gemfire/cache/query/internal/CqEntry.java | 103 +
.../cache/query/internal/CqQueryVsdStats.java | 333 +
.../cache/query/internal/CqStateImpl.java | 96 +
.../cache/query/internal/DefaultQuery.java | 1094 ++
.../query/internal/DefaultQueryService.java | 995 ++
.../cache/query/internal/ExecutionContext.java | 714 +
.../gemfire/cache/query/internal/Filter.java | 170 +
.../gemfire/cache/query/internal/Functions.java | 198 +
.../cache/query/internal/GroupJunction.java | 181 +
.../cache/query/internal/HashingStrategy.java | 46 +
.../gemfire/cache/query/internal/IndexInfo.java | 71 +
.../internal/IndexTrackingQueryObserver.java | 215 +
.../cache/query/internal/IndexUpdater.java | 114 +
.../gemfire/cache/query/internal/Indexable.java | 46 +
.../cache/query/internal/LinkedResultSet.java | 126 +
.../cache/query/internal/LinkedStructSet.java | 348 +
.../cache/query/internal/MapIndexable.java | 10 +
.../cache/query/internal/MethodDispatch.java | 224 +
.../gemfire/cache/query/internal/Negatable.java | 18 +
.../gemfire/cache/query/internal/NullToken.java | 68 +
.../cache/query/internal/ObjectIntHashMap.java | 1132 ++
.../cache/query/internal/OrganizedOperands.java | 46 +
.../cache/query/internal/PRQueryTraceInfo.java | 101 +
.../gemfire/cache/query/internal/PathUtils.java | 198 +
.../gemfire/cache/query/internal/PlanInfo.java | 28 +
.../cache/query/internal/ProxyQueryService.java | 442 +
.../gemfire/cache/query/internal/QCompiler.java | 598 +
.../gemfire/cache/query/internal/QRegion.java | 530 +
.../gemfire/cache/query/internal/QScope.java | 82 +
.../QueryExecutionCanceledException.java | 54 +
.../query/internal/QueryExecutionContext.java | 238 +
.../cache/query/internal/QueryExecutor.java | 31 +
.../cache/query/internal/QueryMonitor.java | 364 +
.../cache/query/internal/QueryObserver.java | 323 +
.../query/internal/QueryObserverAdapter.java | 328 +
.../query/internal/QueryObserverHolder.java | 76 +
.../cache/query/internal/QueryUtils.java | 1971 +++
.../cache/query/internal/RangeJunction.java | 1236 ++
.../cache/query/internal/ResultsBag.java | 718 +
.../ResultsCollectionCopyOnReadWrapper.java | 219 +
...ResultsCollectionPdxDeserializerWrapper.java | 210 +
.../internal/ResultsCollectionWrapper.java | 654 +
.../cache/query/internal/ResultsSet.java | 140 +
.../cache/query/internal/RuntimeIterator.java | 333 +
.../query/internal/SelectResultsComparator.java | 52 +
.../cache/query/internal/SortedResultSet.java | 120 +
.../cache/query/internal/SortedStructSet.java | 337 +
.../gemfire/cache/query/internal/StructBag.java | 458 +
.../cache/query/internal/StructImpl.java | 172 +
.../gemfire/cache/query/internal/StructSet.java | 435 +
.../gemfire/cache/query/internal/Support.java | 87 +
.../gemfire/cache/query/internal/Undefined.java | 77 +
.../cache/query/internal/cq/ClientCQ.java | 26 +
.../cache/query/internal/cq/CqService.java | 247 +
.../query/internal/cq/CqServiceProvider.java | 56 +
.../query/internal/cq/InternalCqQuery.java | 66 +
.../query/internal/cq/MissingCqService.java | 201 +
.../internal/cq/MissingCqServiceStatistics.java | 36 +
.../cache/query/internal/cq/ServerCQ.java | 71 +
.../query/internal/cq/spi/CqServiceFactory.java | 20 +
.../query/internal/index/AbstractIndex.java | 2378 ++++
.../query/internal/index/AbstractMapIndex.java | 433 +
.../internal/index/CompactMapRangeIndex.java | 204 +
.../query/internal/index/CompactRangeIndex.java | 1775 +++
.../query/internal/index/DummyQRegion.java | 215 +
.../index/FunctionalIndexCreationHelper.java | 713 +
.../cache/query/internal/index/HashIndex.java | 1561 +++
.../query/internal/index/HashIndexSet.java | 1220 ++
.../query/internal/index/HashIndexStrategy.java | 81 +
.../query/internal/index/IMQException.java | 50 +
.../internal/index/IndexConcurrentHashSet.java | 69 +
.../query/internal/index/IndexCreationData.java | 157 +
.../internal/index/IndexCreationHelper.java | 104 +
.../cache/query/internal/index/IndexData.java | 63 +
.../query/internal/index/IndexElemArray.java | 324 +
.../query/internal/index/IndexManager.java | 1684 +++
.../query/internal/index/IndexProtocol.java | 214 +
.../cache/query/internal/index/IndexStats.java | 214 +
.../cache/query/internal/index/IndexStore.java | 144 +
.../cache/query/internal/index/IndexUtils.java | 126 +
.../index/IndexedExpressionEvaluator.java | 43 +
.../query/internal/index/MapIndexStore.java | 327 +
.../query/internal/index/MapRangeIndex.java | 186 +
.../query/internal/index/MemoryIndexStore.java | 765 +
.../query/internal/index/PartitionedIndex.java | 633 +
.../query/internal/index/PrimaryKeyIndex.java | 383 +
.../index/PrimaryKeyIndexCreationHelper.java | 115 +
.../cache/query/internal/index/RangeIndex.java | 1669 +++
.../cache/query/internal/index/package.html | 630 +
.../gemfire/cache/query/internal/package.html | 27 +
.../cache/query/internal/parse/ASTAnd.java | 30 +
.../query/internal/parse/ASTCombination.java | 37 +
.../query/internal/parse/ASTCompareOp.java | 29 +
.../query/internal/parse/ASTConstruction.java | 36 +
.../query/internal/parse/ASTConversionExpr.java | 33 +
.../cache/query/internal/parse/ASTCount.java | 45 +
.../cache/query/internal/parse/ASTHint.java | 43 +
.../query/internal/parse/ASTHintIdentifier.java | 43 +
.../query/internal/parse/ASTIdentifier.java | 33 +
.../cache/query/internal/parse/ASTImport.java | 48 +
.../cache/query/internal/parse/ASTIn.java | 34 +
.../query/internal/parse/ASTIteratorDef.java | 70 +
.../cache/query/internal/parse/ASTLike.java | 38 +
.../cache/query/internal/parse/ASTLimit.java | 32 +
.../cache/query/internal/parse/ASTLiteral.java | 223 +
.../internal/parse/ASTMethodInvocation.java | 59 +
.../cache/query/internal/parse/ASTOr.java | 29 +
.../cache/query/internal/parse/ASTOrderBy.java | 35 +
.../query/internal/parse/ASTParameter.java | 31 +
.../cache/query/internal/parse/ASTPostfix.java | 61 +
.../query/internal/parse/ASTProjection.java | 39 +
.../query/internal/parse/ASTRegionPath.java | 32 +
.../cache/query/internal/parse/ASTSelect.java | 125 +
.../query/internal/parse/ASTSortCriterion.java | 35 +
.../cache/query/internal/parse/ASTTrace.java | 32 +
.../cache/query/internal/parse/ASTType.java | 58 +
.../cache/query/internal/parse/ASTTypeCast.java | 35 +
.../cache/query/internal/parse/ASTUnary.java | 56 +
.../query/internal/parse/ASTUndefinedExpr.java | 33 +
.../query/internal/parse/ASTUnsupported.java | 36 +
.../cache/query/internal/parse/GemFireAST.java | 52 +
.../cache/query/internal/parse/OQLLexer.java | 2265 +++
.../internal/parse/OQLLexerTokenTypes.java | 149 +
.../query/internal/parse/OQLLexerTokenTypes.txt | 141 +
.../cache/query/internal/parse/OQLParser.java | 3684 +++++
.../cache/query/internal/parse/UtilParser.java | 83 +
.../cache/query/internal/parse/fixantlr.sh | 37 +
.../gemfire/cache/query/internal/parse/oql.g | 1146 ++
.../internal/types/CollectionTypeImpl.java | 105 +
.../types/ExtendedNumericComparator.java | 44 +
.../cache/query/internal/types/MapTypeImpl.java | 91 +
.../query/internal/types/NumericComparator.java | 88 +
.../query/internal/types/ObjectTypeImpl.java | 91 +
.../query/internal/types/StructTypeImpl.java | 151 +
.../internal/types/TemporalComparator.java | 69 +
.../cache/query/internal/types/TypeUtils.java | 444 +
.../gemstone/gemfire/cache/query/package.html | 692 +
.../cache/query/types/CollectionType.java | 38 +
.../gemfire/cache/query/types/MapType.java | 33 +
.../gemfire/cache/query/types/ObjectType.java | 51 +
.../gemfire/cache/query/types/StructType.java | 43 +
.../gemfire/cache/server/CacheServer.java | 503 +
.../cache/server/ClientSubscriptionConfig.java | 139 +
.../gemfire/cache/server/ServerLoad.java | 178 +
.../gemfire/cache/server/ServerLoadProbe.java | 66 +
.../cache/server/ServerLoadProbeAdapter.java | 34 +
.../gemfire/cache/server/ServerMetrics.java | 44 +
.../server/internal/ConnectionCountProbe.java | 85 +
.../cache/server/internal/LoadMonitor.java | 233 +
.../server/internal/ServerMetricsImpl.java | 70 +
.../gemstone/gemfire/cache/server/package.html | 27 +
.../cache/snapshot/CacheSnapshotService.java | 140 +
.../cache/snapshot/RegionSnapshotService.java | 131 +
.../gemfire/cache/snapshot/SnapshotFilter.java | 36 +
.../cache/snapshot/SnapshotIterator.java | 53 +
.../gemfire/cache/snapshot/SnapshotOptions.java | 53 +
.../gemfire/cache/snapshot/SnapshotReader.java | 49 +
.../gemfire/cache/snapshot/package.html | 39 +
.../cache/util/BoundedLinkedHashMap.java | 82 +
.../gemfire/cache/util/BridgeClient.java | 156 +
.../gemfire/cache/util/BridgeLoader.java | 607 +
.../gemfire/cache/util/BridgeMembership.java | 55 +
.../cache/util/BridgeMembershipEvent.java | 23 +
.../cache/util/BridgeMembershipListener.java | 41 +
.../util/BridgeMembershipListenerAdapter.java | 43 +
.../gemfire/cache/util/BridgeServer.java | 442 +
.../gemfire/cache/util/BridgeWriter.java | 795 ++
.../cache/util/BridgeWriterException.java | 48 +
.../cache/util/CacheListenerAdapter.java | 58 +
.../gemfire/cache/util/CacheWriterAdapter.java | 45 +
.../gemfire/cache/util/CqListenerAdapter.java | 57 +
.../util/EndpointDoesNotExistException.java | 34 +
.../gemfire/cache/util/EndpointException.java | 61 +
.../cache/util/EndpointExistsException.java | 28 +
.../cache/util/EndpointInUseException.java | 27 +
.../cache/util/GatewayConflictHelper.java | 25 +
.../cache/util/GatewayConflictResolver.java | 39 +
.../gemfire/cache/util/GatewayEvent.java | 82 +
.../util/IncompatibleVersionException.java | 47 +
.../gemfire/cache/util/ObjectSizer.java | 74 +
.../gemfire/cache/util/ObjectSizerImpl.java | 19 +
.../util/RegionMembershipListenerAdapter.java | 35 +
.../cache/util/RegionRoleListenerAdapter.java | 31 +
.../util/ServerRefusedConnectionException.java | 36 +
.../cache/util/TimestampedEntryEvent.java | 31 +
.../cache/util/TransactionListenerAdapter.java | 34 +
.../UniversalMembershipListenerAdapter.java | 352 +
.../cache/util/UnknownVersionException.java | 39 +
.../gemfire/cache/util/VersionException.java | 45 +
.../gemstone/gemfire/cache/util/package.html | 19 +
.../gemfire/cache/wan/EventSequenceID.java | 95 +
.../gemfire/cache/wan/GatewayEventFilter.java | 56 +
.../wan/GatewayEventSubstitutionFilter.java | 31 +
.../gemfire/cache/wan/GatewayQueueEvent.java | 65 +
.../gemfire/cache/wan/GatewayReceiver.java | 166 +
.../cache/wan/GatewayReceiverFactory.java | 114 +
.../gemfire/cache/wan/GatewaySender.java | 405 +
.../gemfire/cache/wan/GatewaySenderFactory.java | 231 +
.../cache/wan/GatewayTransportFilter.java | 19 +
.../compression/CompressionException.java | 34 +
.../gemfire/compression/Compressor.java | 39 +
.../gemfire/compression/SnappyCompressor.java | 102 +
.../gemfire/distributed/AbstractLauncher.java | 916 ++
.../distributed/ClientSocketFactory.java | 38 +
.../distributed/DistributedLockService.java | 384 +
.../gemfire/distributed/DistributedMember.java | 71 +
.../gemfire/distributed/DistributedSystem.java | 2026 +++
.../DistributedSystemDisconnectedException.java | 38 +
.../distributed/DurableClientAttributes.java | 138 +
.../distributed/FutureCancelledException.java | 38 +
.../distributed/GatewayCancelledException.java | 37 +
.../distributed/LeaseExpiredException.java | 29 +
.../gemstone/gemfire/distributed/Locator.java | 543 +
.../gemfire/distributed/LocatorLauncher.java | 1999 +++
.../distributed/LockNotHeldException.java | 42 +
.../LockServiceDestroyedException.java | 42 +
.../distributed/OplogCancelledException.java | 38 +
.../distributed/PoolCancelledException.java | 38 +
.../com/gemstone/gemfire/distributed/Role.java | 47 +
.../gemfire/distributed/ServerLauncher.java | 2497 ++++
.../TXManagerCancelledException.java | 38 +
.../internal/AbstractDistributionConfig.java | 3242 +++++
.../distributed/internal/AdminMessageType.java | 7 +
.../internal/AtomicLongWithTerminalState.java | 58 +
.../internal/CollectingReplyProcessor.java | 47 +
.../distributed/internal/ConflationKey.java | 69 +
.../gemfire/distributed/internal/DM.java | 463 +
.../gemfire/distributed/internal/DMStats.java | 634 +
.../gemfire/distributed/internal/DSClock.java | 297 +
.../internal/DirectReplyProcessor.java | 163 +
.../distributed/internal/DistributedState.java | 134 +
.../internal/DistributionAdvisee.java | 84 +
.../internal/DistributionAdvisor.java | 1669 +++
.../internal/DistributionChannel.java | 155 +
.../internal/DistributionConfig.java | 3548 +++++
.../internal/DistributionConfigImpl.java | 3526 +++++
.../internal/DistributionConfigSnapshot.java | 62 +
.../internal/DistributionException.java | 28 +
.../internal/DistributionManager.java | 5065 +++++++
.../internal/DistributionManagerConfig.java | 93 +
.../internal/DistributionMessage.java | 674 +
.../internal/DistributionMessageObserver.java | 66 +
.../distributed/internal/DistributionStats.java | 2127 +++
.../distributed/internal/FlowControlParams.java | 105 +
.../internal/ForceDisconnectOperation.java | 33 +
.../FunctionExecutionPooledExecutor.java | 303 +
.../distributed/internal/HealthMonitor.java | 37 +
.../distributed/internal/HealthMonitorImpl.java | 139 +
.../internal/HighPriorityAckedMessage.java | 222 +
.../HighPriorityDistributionMessage.java | 22 +
.../distributed/internal/IgnoredByManager.java | 10 +
.../internal/InternalDistributedSystem.java | 3020 ++++
.../distributed/internal/InternalLocator.java | 1504 ++
.../internal/LocatorLoadSnapshot.java | 687 +
.../distributed/internal/LocatorStats.java | 236 +
.../internal/LonerDistributionManager.java | 862 ++
.../gemfire/distributed/internal/MQueue.java | 16 +
.../internal/MembershipListener.java | 67 +
.../distributed/internal/MessageFactory.java | 47 +
.../distributed/internal/MessageWithReply.java | 34 +
.../internal/OverflowQueueWithDMStats.java | 165 +
.../distributed/internal/PoolStatHelper.java | 29 +
.../internal/PooledDistributionMessage.java | 25 +
.../internal/PooledExecutorWithDMStats.java | 226 +
.../distributed/internal/ProcessorKeeper21.java | 120 +
.../distributed/internal/ProductUseLog.java | 138 +
.../distributed/internal/ProfileListener.java | 46 +
.../distributed/internal/QueueStatHelper.java | 33 +
.../internal/ReliableReplyException.java | 28 +
.../internal/ReliableReplyProcessor21.java | 107 +
.../distributed/internal/ReplyException.java | 192 +
.../distributed/internal/ReplyMessage.java | 355 +
.../distributed/internal/ReplyProcessor21.java | 1289 ++
.../distributed/internal/ReplySender.java | 30 +
.../distributed/internal/ResourceEvent.java | 44 +
.../internal/ResourceEventsListener.java | 30 +
.../internal/RuntimeDistributionConfigImpl.java | 153 +
.../internal/SerialAckedMessage.java | 150 +
.../internal/SerialDistributionMessage.java | 25 +
.../SerialQueuedExecutorWithDMStats.java | 42 +
.../distributed/internal/ServerLocation.java | 169 +
.../distributed/internal/ServerLocator.java | 477 +
.../internal/SharedConfiguration.java | 945 ++
.../distributed/internal/ShutdownMessage.java | 112 +
.../gemfire/distributed/internal/Sizeable.java | 12 +
.../distributed/internal/SizeableRunnable.java | 30 +
.../distributed/internal/StartupMessage.java | 477 +
.../internal/StartupMessageData.java | 238 +
.../internal/StartupMessageReplyProcessor.java | 109 +
.../distributed/internal/StartupOperation.java | 133 +
.../internal/StartupResponseMessage.java | 326 +
.../StartupResponseWithVersionMessage.java | 122 +
.../internal/ThrottledMemQueueStatHelper.java | 40 +
.../internal/ThrottledQueueStatHelper.java | 30 +
.../ThrottlingMemLinkedQueueWithDMStats.java | 156 +
.../internal/WaitForViewInstallation.java | 117 +
.../internal/WanLocatorDiscoverer.java | 15 +
.../deadlock/DLockDependencyMonitor.java | 138 +
.../internal/deadlock/DeadlockDetector.java | 219 +
.../internal/deadlock/Dependency.java | 79 +
.../internal/deadlock/DependencyGraph.java | 187 +
.../internal/deadlock/DependencyMonitor.java | 36 +
.../deadlock/DependencyMonitorManager.java | 98 +
.../deadlock/GemFireDeadlockDetector.java | 133 +
.../internal/deadlock/LocalLockInfo.java | 92 +
.../internal/deadlock/LocalThread.java | 111 +
.../deadlock/MessageDependencyMonitor.java | 144 +
.../internal/deadlock/ThreadReference.java | 19 +
.../internal/deadlock/UnsafeThreadLocal.java | 84 +
.../internal/direct/DirectChannel.java | 988 ++
.../internal/direct/MissingStubException.java | 28 +
.../internal/distribution-overview.html | 26 +
.../internal/doc-files/config-classes.fig | 138 +
.../internal/doc-files/config-classes.gif | Bin 0 -> 4205 bytes
.../doc-files/distribution-managers.fig | 76 +
.../doc-files/distribution-managers.gif | Bin 0 -> 3267 bytes
.../internal/locks/Collaboration.java | 445 +
.../distributed/internal/locks/DLockBatch.java | 37 +
.../internal/locks/DLockBatchId.java | 22 +
.../internal/locks/DLockGrantor.java | 3781 +++++
.../locks/DLockLessorDepartureHandler.java | 26 +
.../internal/locks/DLockQueryProcessor.java | 510 +
.../locks/DLockRecoverGrantorProcessor.java | 451 +
.../internal/locks/DLockReleaseProcessor.java | 441 +
.../internal/locks/DLockRemoteToken.java | 226 +
.../internal/locks/DLockRequestProcessor.java | 1275 ++
.../internal/locks/DLockService.java | 3358 +++++
.../distributed/internal/locks/DLockStats.java | 878 ++
.../distributed/internal/locks/DLockToken.java | 563 +
.../internal/locks/DeposeGrantorProcessor.java | 201 +
.../internal/locks/DistributedLockStats.java | 192 +
.../internal/locks/DistributedMemberLock.java | 288 +
.../internal/locks/DummyDLockStats.java | 171 +
.../internal/locks/ElderInitProcessor.java | 305 +
.../distributed/internal/locks/ElderState.java | 390 +
.../distributed/internal/locks/GrantorInfo.java | 78 +
.../internal/locks/GrantorRequestProcessor.java | 742 +
.../locks/LockGrantorDestroyedException.java | 42 +
.../internal/locks/LockGrantorId.java | 234 +
.../locks/NonGrantorDestroyedProcessor.java | 299 +
.../internal/locks/RemoteThread.java | 79 +
.../internal/locks/doc-files/elder.fig | 84 +
.../internal/locks/doc-files/elder.jpg | Bin 0 -> 55182 bytes
.../internal/locks/doc-files/turks.fig | 128 +
.../internal/locks/doc-files/turks.jpg | Bin 0 -> 79859 bytes
.../distributed/internal/locks/package.html | 297 +
.../DistributedMembershipListener.java | 83 +
.../membership/InternalDistributedMember.java | 1180 ++
.../internal/membership/InternalRole.java | 160 +
.../internal/membership/MemberAttributes.java | 246 +
.../internal/membership/MemberFactory.java | 91 +
.../internal/membership/MemberServices.java | 74 +
.../internal/membership/MembershipManager.java | 344 +
.../internal/membership/MembershipTestHook.java | 31 +
.../internal/membership/NetMember.java | 70 +
.../internal/membership/NetView.java | 98 +
.../internal/membership/QuorumChecker.java | 42 +
.../membership/jgroup/GFJGBasicAdapter.java | 546 +
.../membership/jgroup/GFJGPeerAdapter.java | 484 +
.../membership/jgroup/JGroupMember.java | 251 +
.../membership/jgroup/JGroupMemberFactory.java | 119 +
.../jgroup/JGroupMembershipManager.java | 4212 ++++++
.../internal/membership/jgroup/LocatorImpl.java | 474 +
.../membership/jgroup/QuorumCheckerImpl.java | 291 +
.../internal/membership/jgroup/ViewMessage.java | 73 +
.../internal/membership/jgroup/package.html | 43 +
.../gemfire/distributed/internal/package.html | 39 +
.../internal/streaming/StreamingOperation.java | 579 +
.../internal/tcpserver/InfoRequest.java | 33 +
.../internal/tcpserver/InfoResponse.java | 48 +
.../internal/tcpserver/ShutdownRequest.java | 31 +
.../internal/tcpserver/ShutdownResponse.java | 32 +
.../internal/tcpserver/TcpClient.java | 210 +
.../internal/tcpserver/TcpHandler.java | 45 +
.../internal/tcpserver/TcpServer.java | 566 +
.../internal/tcpserver/VersionRequest.java | 25 +
.../internal/tcpserver/VersionResponse.java | 38 +
.../unsafe/RegisterSignalHandlerSupport.java | 27 +
.../gemstone/gemfire/distributed/package.html | 21 +
.../doc-files/data-serialization-exceptions.fig | 135 +
.../doc-files/data-serialization-exceptions.gif | Bin 0 -> 3666 bytes
.../gemstone/gemfire/i18n/LogWriterI18n.java | 413 +
.../com/gemstone/gemfire/i18n/StringIdImpl.java | 153 +
.../gemfire/internal/AbstractConfig.java | 418 +
.../internal/AbstractStatisticsFactory.java | 331 +
.../gemfire/internal/ArchiveSplitter.java | 513 +
.../com/gemstone/gemfire/internal/Assert.java | 168 +
.../gemfire/internal/AvailablePort.java | 572 +
.../com/gemstone/gemfire/internal/Banner.java | 152 +
.../gemfire/internal/ByteArrayDataInput.java | 449 +
.../internal/ByteBufferOutputStream.java | 93 +
.../gemfire/internal/ClassLoadUtil.java | 115 +
.../gemfire/internal/ClassPathLoader.java | 717 +
.../com/gemstone/gemfire/internal/Config.java | 101 +
.../gemstone/gemfire/internal/ConfigSource.java | 95 +
.../gemfire/internal/CopyOnWriteHashSet.java | 168 +
.../com/gemstone/gemfire/internal/DSCODE.java | 407 +
.../gemstone/gemfire/internal/DSFIDFactory.java | 1336 ++
.../internal/DSFIDNotFoundException.java | 43 +
.../internal/DataSerializableFixedID.java | 854 ++
.../gemfire/internal/DistributionLocator.java | 181 +
.../internal/DummyStatisticsFactory.java | 125 +
.../gemfire/internal/DummyStatisticsImpl.java | 190 +
.../gemfire/internal/ExternalizableDSFID.java | 34 +
.../com/gemstone/gemfire/internal/FileUtil.java | 322 +
.../gemfire/internal/GemFireStatSampler.java | 498 +
.../gemfire/internal/GemFireUtilLauncher.java | 157 +
.../gemfire/internal/GemFireVersion.java | 672 +
.../internal/GfeConsoleReaderFactory.java | 79 +
.../gemfire/internal/HeapDataOutputStream.java | 1134 ++
.../gemfire/internal/HistogramStats.java | 73 +
.../gemfire/internal/HostStatHelper.java | 280 +
.../gemfire/internal/HostStatSampler.java | 535 +
.../InsufficientDiskSpaceException.java | 45 +
.../internal/InternalDataSerializer.java | 4113 ++++++
.../gemfire/internal/InternalEntity.java | 14 +
.../gemfire/internal/InternalInstantiator.java | 1052 ++
.../InternalStatisticsDisabledException.java | 61 +
.../gemfire/internal/JarClassLoader.java | 693 +
.../gemstone/gemfire/internal/JarDeployer.java | 631 +
.../gemfire/internal/LinuxProcFsStatistics.java | 746 +
.../gemfire/internal/LinuxProcessStats.java | 70 +
.../gemfire/internal/LinuxSystemStats.java | 302 +
.../gemfire/internal/LocalStatListener.java | 32 +
.../internal/LocalStatisticsFactory.java | 90 +
.../gemfire/internal/LocalStatisticsImpl.java | 260 +
.../gemstone/gemfire/internal/ManagerInfo.java | 378 +
.../gemfire/internal/MigrationClient.java | 251 +
.../gemfire/internal/MigrationServer.java | 557 +
.../gemstone/gemfire/internal/NanoTimer.java | 148 +
.../gemfire/internal/NullDataOutputStream.java | 370 +
.../gemstone/gemfire/internal/OSProcess.java | 743 +
.../gemfire/internal/OSXProcessStats.java | 74 +
.../gemfire/internal/OSXSystemStats.java | 219 +
.../gemfire/internal/ObjIdConcurrentMap.java | 1357 ++
.../com/gemstone/gemfire/internal/ObjIdMap.java | 328 +
.../internal/ObjToByteArraySerializer.java | 26 +
.../gemfire/internal/OneTaskOnlyExecutor.java | 166 +
.../gemfire/internal/OsStatisticsFactory.java | 33 +
.../gemfire/internal/PdxSerializerObject.java | 24 +
.../gemfire/internal/ProcessOutputReader.java | 126 +
.../gemstone/gemfire/internal/ProcessStats.java | 52 +
.../gemstone/gemfire/internal/PureJavaMode.java | 71 +
...cheduledThreadPoolExecutorWithKeepAlive.java | 304 +
.../gemfire/internal/SerializationVersions.java | 33 +
.../com/gemstone/gemfire/internal/SetUtils.java | 60 +
.../gemfire/internal/SharedLibrary.java | 201 +
.../gemfire/internal/SimpleStatSampler.java | 105 +
.../com/gemstone/gemfire/internal/SmHelper.java | 174 +
.../gemfire/internal/SocketCreator.java | 1484 ++
.../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 | 208 +
.../gemfire/internal/SolarisSystemStats.java | 419 +
.../gemfire/internal/StatArchiveFormat.java | 188 +
.../gemfire/internal/StatArchiveReader.java | 3329 +++++
.../gemfire/internal/StatArchiveWriter.java | 741 +
.../gemfire/internal/StatSamplerStats.java | 114 +
.../internal/StatisticDescriptorImpl.java | 376 +
.../gemfire/internal/StatisticsImpl.java | 445 +
.../gemfire/internal/StatisticsManager.java | 70 +
.../internal/StatisticsTypeFactoryImpl.java | 132 +
.../gemfire/internal/StatisticsTypeImpl.java | 251 +
.../gemfire/internal/StatisticsTypeXml.java | 271 +
.../gemstone/gemfire/internal/SystemAdmin.java | 2289 +++
.../gemfire/internal/SystemFailureTestHook.java | 39 +
.../gemstone/gemfire/internal/SystemTimer.java | 458 +
.../gemfire/internal/UniqueIdGenerator.java | 248 +
.../com/gemstone/gemfire/internal/VMStats.java | 78 +
.../gemfire/internal/VMStatsContract.java | 27 +
.../internal/VMStatsContractFactory.java | 51 +
.../com/gemstone/gemfire/internal/Version.java | 609 +
.../internal/VersionedDataInputStream.java | 58 +
.../internal/VersionedDataOutputStream.java | 48 +
.../internal/VersionedDataSerializable.java | 18 +
.../gemfire/internal/VersionedDataStream.java | 44 +
.../gemfire/internal/VersionedObjectInput.java | 236 +
.../gemfire/internal/VersionedObjectOutput.java | 190 +
.../gemfire/internal/WindowsProcessStats.java | 151 +
.../gemfire/internal/WindowsSystemStats.java | 258 +
.../internal/admin/AdminBridgeServer.java | 17 +
.../gemstone/gemfire/internal/admin/Alert.java | 60 +
.../gemfire/internal/admin/AlertListener.java | 20 +
.../gemfire/internal/admin/ApplicationVM.java | 27 +
.../gemfire/internal/admin/CacheCollector.java | 268 +
.../gemfire/internal/admin/CacheInfo.java | 93 +
.../gemfire/internal/admin/CacheSnapshot.java | 25 +
.../admin/ClientHealthMonitoringRegion.java | 108 +
.../internal/admin/ClientMembershipMessage.java | 178 +
.../internal/admin/ClientStatsManager.java | 257 +
.../internal/admin/CompoundEntrySnapshot.java | 192 +
.../internal/admin/CompoundRegionSnapshot.java | 378 +
.../gemfire/internal/admin/DLockInfo.java | 26 +
.../gemfire/internal/admin/EntrySnapshot.java | 20 +
.../gemfire/internal/admin/EntryValueNode.java | 44 +
.../gemfire/internal/admin/GemFireVM.java | 387 +
.../gemfire/internal/admin/GfManagerAgent.java | 103 +
.../internal/admin/GfManagerAgentConfig.java | 78 +
.../internal/admin/GfManagerAgentFactory.java | 33 +
.../gemfire/internal/admin/GfObject.java | 19 +
.../gemfire/internal/admin/HealthListener.java | 35 +
.../internal/admin/JoinLeaveListener.java | 18 +
.../gemfire/internal/admin/ListenerIdMap.java | 309 +
.../gemfire/internal/admin/RegionSnapshot.java | 22 +
.../gemfire/internal/admin/SSLConfig.java | 122 +
.../gemfire/internal/admin/SnapshotClient.java | 29 +
.../gemstone/gemfire/internal/admin/Stat.java | 35 +
.../gemfire/internal/admin/StatAlert.java | 131 +
.../internal/admin/StatAlertDefinition.java | 94 +
.../internal/admin/StatAlertsManager.java | 399 +
.../gemfire/internal/admin/StatListener.java | 34 +
.../gemfire/internal/admin/StatResource.java | 33 +
.../gemfire/internal/admin/TransportConfig.java | 18 +
.../admin/doc-files/class-hierarchy.fig | 224 +
.../admin/doc-files/class-hierarchy.gif | Bin 0 -> 11971 bytes
.../gemfire/internal/admin/package.html | 13 +
.../admin/remote/AddHealthListenerRequest.java | 80 +
.../admin/remote/AddHealthListenerResponse.java | 67 +
.../admin/remote/AddStatListenerRequest.java | 76 +
.../admin/remote/AddStatListenerResponse.java | 70 +
.../remote/AdminConsoleDisconnectMessage.java | 116 +
.../admin/remote/AdminConsoleMessage.java | 74 +
.../admin/remote/AdminFailureResponse.java | 64 +
.../remote/AdminMultipleReplyProcessor.java | 82 +
.../internal/admin/remote/AdminRegion.java | 572 +
.../admin/remote/AdminReplyProcessor.java | 139 +
.../internal/admin/remote/AdminRequest.java | 184 +
.../internal/admin/remote/AdminResponse.java | 81 +
.../internal/admin/remote/AdminWaiters.java | 175 +
.../admin/remote/AlertLevelChangeMessage.java | 88 +
.../admin/remote/AlertListenerMessage.java | 138 +
.../admin/remote/AlertsNotificationMessage.java | 101 +
.../admin/remote/AppCacheSnapshotMessage.java | 154 +
.../admin/remote/BridgeServerRequest.java | 193 +
.../admin/remote/BridgeServerResponse.java | 172 +
.../admin/remote/CacheConfigRequest.java | 79 +
.../admin/remote/CacheConfigResponse.java | 110 +
.../internal/admin/remote/CacheDisplay.java | 77 +
.../internal/admin/remote/CacheInfoRequest.java | 64 +
.../admin/remote/CacheInfoResponse.java | 74 +
.../admin/remote/CancelStatListenerRequest.java | 70 +
.../remote/CancelStatListenerResponse.java | 65 +
.../internal/admin/remote/Cancellable.java | 18 +
.../admin/remote/CancellationMessage.java | 61 +
.../admin/remote/CancellationRegistry.java | 86 +
.../remote/ChangeRefreshIntervalMessage.java | 89 +
.../internal/admin/remote/CliLegacyMessage.java | 42 +
.../admin/remote/ClientHealthStats.java | 299 +
.../internal/admin/remote/CompactRequest.java | 136 +
.../internal/admin/remote/CompactResponse.java | 57 +
.../admin/remote/DestroyEntryMessage.java | 91 +
.../admin/remote/DestroyRegionMessage.java | 87 +
.../admin/remote/DistributionLocatorId.java | 386 +
.../internal/admin/remote/DummyEntry.java | 68 +
.../admin/remote/DurableClientInfoRequest.java | 101 +
.../admin/remote/DurableClientInfoResponse.java | 100 +
.../admin/remote/EntryValueNodeImpl.java | 384 +
.../admin/remote/FetchDistLockInfoRequest.java | 59 +
.../admin/remote/FetchDistLockInfoResponse.java | 84 +
.../remote/FetchHealthDiagnosisRequest.java | 82 +
.../remote/FetchHealthDiagnosisResponse.java | 83 +
.../internal/admin/remote/FetchHostRequest.java | 61 +
.../admin/remote/FetchHostResponse.java | 164 +
.../remote/FetchResourceAttributesRequest.java | 61 +
.../remote/FetchResourceAttributesResponse.java | 72 +
.../admin/remote/FetchStatsRequest.java | 63 +
.../admin/remote/FetchStatsResponse.java | 137 +
.../admin/remote/FetchSysCfgRequest.java | 67 +
.../admin/remote/FetchSysCfgResponse.java | 68 +
.../remote/FlushAppCacheSnapshotMessage.java | 60 +
.../admin/remote/HealthListenerMessage.java | 80 +
.../remote/InspectionClasspathManager.java | 81 +
.../admin/remote/LicenseInfoRequest.java | 63 +
.../admin/remote/LicenseInfoResponse.java | 70 +
.../remote/MissingPersistentIDsRequest.java | 132 +
.../remote/MissingPersistentIDsResponse.java | 106 +
.../admin/remote/ObjectDetailsRequest.java | 94 +
.../admin/remote/ObjectDetailsResponse.java | 146 +
.../admin/remote/ObjectNamesRequest.java | 80 +
.../admin/remote/ObjectNamesResponse.java | 89 +
.../PrepareRevokePersistentIDRequest.java | 118 +
.../remote/RefreshMemberSnapshotRequest.java | 65 +
.../remote/RefreshMemberSnapshotResponse.java | 86 +
.../admin/remote/RegionAdminMessage.java | 57 +
.../admin/remote/RegionAdminRequest.java | 65 +
.../admin/remote/RegionAttributesRequest.java | 65 +
.../admin/remote/RegionAttributesResponse.java | 66 +
.../internal/admin/remote/RegionRequest.java | 166 +
.../internal/admin/remote/RegionResponse.java | 140 +
.../admin/remote/RegionSizeRequest.java | 81 +
.../admin/remote/RegionSizeResponse.java | 87 +
.../admin/remote/RegionStatisticsRequest.java | 65 +
.../admin/remote/RegionStatisticsResponse.java | 66 +
.../remote/RegionSubRegionSizeRequest.java | 86 +
.../remote/RegionSubRegionsSizeResponse.java | 154 +
.../internal/admin/remote/RemoteAlert.java | 196 +
.../admin/remote/RemoteApplicationVM.java | 52 +
.../admin/remote/RemoteBridgeServer.java | 295 +
.../internal/admin/remote/RemoteCacheInfo.java | 183 +
.../admin/remote/RemoteCacheStatistics.java | 78 +
.../internal/admin/remote/RemoteDLockInfo.java | 106 +
.../admin/remote/RemoteEntrySnapshot.java | 122 +
.../internal/admin/remote/RemoteGemFireVM.java | 989 ++
.../admin/remote/RemoteGfManagerAgent.java | 1485 ++
.../internal/admin/remote/RemoteObjectName.java | 86 +
.../admin/remote/RemoteRegionAttributes.java | 768 +
.../admin/remote/RemoteRegionSnapshot.java | 149 +
.../internal/admin/remote/RemoteStat.java | 109 +
.../admin/remote/RemoteStatResource.java | 145 +
.../admin/remote/RemoteTransportConfig.java | 406 +
.../remote/RemoveHealthListenerRequest.java | 71 +
.../remote/RemoveHealthListenerResponse.java | 58 +
.../admin/remote/ResetHealthStatusRequest.java | 71 +
.../admin/remote/ResetHealthStatusResponse.java | 63 +
.../admin/remote/RevokePersistentIDRequest.java | 94 +
.../remote/RevokePersistentIDResponse.java | 27 +
.../admin/remote/RootRegionRequest.java | 67 +
.../admin/remote/RootRegionResponse.java | 106 +
.../admin/remote/ShutdownAllRequest.java | 288 +
.../admin/remote/ShutdownAllResponse.java | 71 +
.../admin/remote/SnapshotResultMessage.java | 76 +
.../remote/StatAlertsManagerAssignMessage.java | 143 +
.../admin/remote/StatListenerMessage.java | 109 +
.../admin/remote/StoreSysCfgRequest.java | 72 +
.../admin/remote/StoreSysCfgResponse.java | 68 +
.../internal/admin/remote/SubRegionRequest.java | 65 +
.../admin/remote/SubRegionResponse.java | 91 +
.../internal/admin/remote/TailLogRequest.java | 53 +
.../internal/admin/remote/TailLogResponse.java | 160 +
.../remote/UpdateAlertDefinitionMessage.java | 153 +
.../admin/remote/VersionInfoRequest.java | 64 +
.../admin/remote/VersionInfoResponse.java | 65 +
.../admin/remote/VersionMismatchAlert.java | 57 +
.../gemfire/internal/admin/remote/package.html | 25 +
.../admin/statalerts/BaseDecoratorImpl.java | 215 +
.../statalerts/DummyStatisticInfoImpl.java | 137 +
.../admin/statalerts/FunctionDecoratorImpl.java | 124 +
.../admin/statalerts/FunctionHelper.java | 249 +
.../statalerts/GaugeThresholdDecoratorImpl.java | 147 +
.../statalerts/MultiAttrDefinitionImpl.java | 198 +
.../NumberThresholdDecoratorImpl.java | 144 +
.../statalerts/SingleAttrDefinitionImpl.java | 204 +
.../admin/statalerts/StatisticInfo.java | 76 +
.../admin/statalerts/StatisticInfoImpl.java | 148 +
.../internal/cache/AbstractBridgeServer.java | 425 +
.../cache/AbstractBucketRegionQueue.java | 539 +
.../cache/AbstractDiskLRURegionEntry.java | 33 +
.../internal/cache/AbstractDiskRegion.java | 952 ++
.../internal/cache/AbstractDiskRegionEntry.java | 46 +
.../internal/cache/AbstractLRURegionEntry.java | 37 +
.../internal/cache/AbstractLRURegionMap.java | 830 ++
.../cache/AbstractOplogDiskRegionEntry.java | 156 +
.../gemfire/internal/cache/AbstractRegion.java | 1996 +++
.../internal/cache/AbstractRegionEntry.java | 1791 +++
.../internal/cache/AbstractRegionMap.java | 3989 ++++++
.../internal/cache/AbstractUpdateOperation.java | 326 +
.../gemfire/internal/cache/AcceptHelper.java | 92 +
.../cache/AddCacheServerProfileMessage.java | 152 +
.../gemfire/internal/cache/BackupLock.java | 82 +
.../internal/cache/BridgeEventConflator.java | 158 +
.../gemfire/internal/cache/BridgeObserver.java | 89 +
.../internal/cache/BridgeObserverAdapter.java | 107 +
.../internal/cache/BridgeObserverHolder.java | 53 +
.../internal/cache/BridgeRegionEventImpl.java | 108 +
.../internal/cache/BridgeServerAdvisor.java | 165 +
.../internal/cache/BridgeServerImpl.java | 816 ++
.../gemfire/internal/cache/BucketAdvisor.java | 2939 ++++
.../gemfire/internal/cache/BucketDump.java | 135 +
.../internal/cache/BucketNotFoundException.java | 29 +
.../cache/BucketPersistenceAdvisor.java | 454 +
.../gemfire/internal/cache/BucketRegion.java | 2319 ++++
.../internal/cache/BucketRegionEvictior.java | 54 +
.../internal/cache/BucketRegionQueue.java | 492 +
.../internal/cache/BucketServerLocation.java | 80 +
.../internal/cache/BucketServerLocation66.java | 105 +
.../cache/BytesAndBitsForCompactor.java | 68 +
.../internal/cache/CacheClientStatus.java | 92 +
.../gemfire/internal/cache/CacheConfig.java | 203 +
.../cache/CacheDistributionAdvisee.java | 49 +
.../cache/CacheDistributionAdvisor.java | 1229 ++
.../internal/cache/CacheLifecycleListener.java | 28 +
.../gemfire/internal/cache/CacheObserver.java | 177 +
.../internal/cache/CacheObserverAdapter.java | 141 +
.../internal/cache/CacheObserverHolder.java | 69 +
.../gemfire/internal/cache/CachePerfStats.java | 1325 ++
.../internal/cache/CacheServerLauncher.java | 1236 ++
.../internal/cache/CacheStatisticsImpl.java | 102 +
.../internal/cache/CachedDeserializable.java | 105 +
.../cache/CachedDeserializableFactory.java | 259 +
.../cache/ClientSubscriptionConfigImpl.java | 169 +
.../internal/cache/CloseCacheMessage.java | 107 +
.../cache/ClusterConfigurationLoader.java | 229 +
.../internal/cache/ColocationHelper.java | 489 +
.../internal/cache/CommitReplyException.java | 64 +
.../internal/cache/CompactableOplog.java | 28 +
.../gemfire/internal/cache/Conflatable.java | 67 +
.../internal/cache/ControllerAdvisor.java | 162 +
.../internal/cache/CountingDataInputStream.java | 116 +
.../internal/cache/CreateRegionProcessor.java | 893 ++
.../internal/cache/CustomEntryExpiryTask.java | 33 +
.../internal/cache/DataLocationException.java | 34 +
.../internal/cache/DestroyOperation.java | 282 +
.../cache/DestroyPartitionedRegionMessage.java | 243 +
.../internal/cache/DestroyRegionOperation.java | 538 +
.../gemfire/internal/cache/DestroyedEntry.java | 76 +
.../internal/cache/DirectReplyMessage.java | 49 +
.../gemfire/internal/cache/DirectoryHolder.java | 114 +
.../internal/cache/DiskDirectoryStats.java | 108 +
.../gemfire/internal/cache/DiskEntry.java | 1532 ++
.../gemstone/gemfire/internal/cache/DiskId.java | 721 +
.../gemfire/internal/cache/DiskInitFile.java | 2818 ++++
.../gemfire/internal/cache/DiskRegion.java | 855 ++
.../gemfire/internal/cache/DiskRegionStats.java | 295 +
.../internal/cache/DiskStoreAttributes.java | 187 +
.../gemfire/internal/cache/DiskStoreBackup.java | 89 +
.../internal/cache/DiskStoreFactoryImpl.java | 282 +
.../gemfire/internal/cache/DiskStoreImpl.java | 4857 +++++++
.../internal/cache/DiskStoreMonitor.java | 404 +
.../internal/cache/DiskStoreObserver.java | 54 +
.../gemfire/internal/cache/DiskStoreStats.java | 519 +
.../gemfire/internal/cache/DiskStoreTask.java | 18 +
.../internal/cache/DiskWriteAttributesImpl.java | 555 +
.../cache/DistributedCacheOperation.java | 1504 ++
.../cache/DistributedClearOperation.java | 351 +
.../cache/DistributedPutAllOperation.java | 1301 ++
.../internal/cache/DistributedRegion.java | 4254 ++++++
...stributedRegionFunctionStreamingMessage.java | 446 +
.../cache/DistributedRemoveAllOperation.java | 1043 ++
.../cache/DistributedTombstoneOperation.java | 227 +
.../internal/cache/DummyCachePerfStats.java | 476 +
.../internal/cache/DynamicRegionAttributes.java | 43 +
.../cache/DynamicRegionFactoryImpl.java | 35 +
.../gemfire/internal/cache/EntriesMap.java | 146 +
.../gemfire/internal/cache/EntriesSet.java | 285 +
.../gemfire/internal/cache/EntryBits.java | 119 +
.../gemfire/internal/cache/EntryEventImpl.java | 2285 +++
.../gemfire/internal/cache/EntryExpiryTask.java | 330 +
.../internal/cache/EntryOperationImpl.java | 110 +
.../gemfire/internal/cache/EntrySnapshot.java | 276 +
.../internal/cache/EnumListenerEvent.java | 467 +
.../gemfire/internal/cache/EventID.java | 795 ++
.../internal/cache/EventStateHelper.java | 187 +
.../gemfire/internal/cache/EventTracker.java | 772 ++
.../internal/cache/EvictionAttributesImpl.java | 234 +
.../internal/cache/ExpirationScheduler.java | 123 +
.../gemfire/internal/cache/ExpiryTask.java | 505 +
.../internal/cache/ExportDiskRegion.java | 68 +
.../gemfire/internal/cache/FilterProfile.java | 2521 ++++
.../internal/cache/FilterRoutingInfo.java | 510 +
.../cache/FindDurableQueueProcessor.java | 247 +
.../internal/cache/FindRemoteTXMessage.java | 272 +
.../internal/cache/FindVersionTagOperation.java | 245 +
.../cache/FixedPartitionAttributesImpl.java | 147 +
.../internal/cache/ForceReattemptException.java | 112 +
.../cache/ForceableLinkedBlockingQueue.java | 855 ++
.../FunctionStreamingOrderedReplyMessage.java | 55 +
.../cache/FunctionStreamingReplyMessage.java | 136 +
.../internal/cache/GatewayEventFilter.java | 11 +
.../internal/cache/GemFireCacheImpl.java | 5006 +++++++
.../internal/cache/GemfireCacheHelper.java | 29 +
.../gemfire/internal/cache/GridAdvisor.java | 433 +
.../gemfire/internal/cache/HARegion.java | 601 +
.../internal/cache/HasCachePerfStats.java | 6 +
.../internal/cache/IdentityArrayList.java | 473 +
.../gemfire/internal/cache/ImageState.java | 80 +
.../cache/InMemoryPersistentMemberView.java | 127 +
.../internal/cache/IncomingGatewayStatus.java | 74 +
.../internal/cache/InitialImageFlowControl.java | 244 +
.../internal/cache/InitialImageOperation.java | 4317 ++++++
.../gemfire/internal/cache/InlineKeyHelper.java | 62 +
.../gemfire/internal/cache/InterestEvent.java | 59 +
.../gemfire/internal/cache/InterestFilter.java | 25 +
.../cache/InterestRegistrationEventImpl.java | 143 +
.../gemfire/internal/cache/InternalCache.java | 36 +
.../internal/cache/InternalCacheEvent.java | 78 +
.../internal/cache/InternalDataView.java | 242 +
.../internal/cache/InternalRegionArguments.java | 312 +
.../internal/cache/InvalidateOperation.java | 227 +
.../InvalidatePartitionedRegionMessage.java | 93 +
.../cache/InvalidateRegionOperation.java | 99 +
.../cache/JtaAfterCompletionMessage.java | 119 +
.../cache/JtaBeforeCompletionMessage.java | 73 +
.../gemfire/internal/cache/KeyInfo.java | 86 +
.../internal/cache/KeyWithRegionContext.java | 62 +
.../gemfire/internal/cache/ListOfDeltas.java | 92 +
.../internal/cache/LoaderHelperFactory.java | 31 +
.../internal/cache/LoaderHelperImpl.java | 160 +
.../gemfire/internal/cache/LocalDataSet.java | 741 +
.../gemfire/internal/cache/LocalRegion.java | 12333 +++++++++++++++++
.../internal/cache/LocalRegionDataView.java | 264 +
.../cache/MemberFunctionStreamingMessage.java | 401 +
.../cache/MinimumSystemRequirements.java | 83 +
.../cache/NetSearchExpirationCalculator.java | 40 +
.../gemstone/gemfire/internal/cache/Node.java | 179 +
.../internal/cache/NonLocalRegionEntry.java | 534 +
.../cache/NonLocalRegionEntryWithStats.java | 77 +
.../cache/OfflineCompactionDiskRegion.java | 115 +
.../gemstone/gemfire/internal/cache/OpType.java | 50 +
.../gemstone/gemfire/internal/cache/Oplog.java | 7890 +++++++++++
.../gemfire/internal/cache/OplogSet.java | 18 +
.../internal/cache/OrderedTombstoneMap.java | 114 +
.../gemfire/internal/cache/OverflowOplog.java | 1607 +++
.../internal/cache/OverflowOplogSet.java | 318 +
.../internal/cache/PRContainsValueFunction.java | 51 +
.../internal/cache/PRHARedundancyProvider.java | 2376 ++++
.../internal/cache/PRQueryProcessor.java | 591 +
.../internal/cache/PRSystemPropertyGetter.java | 61 +
.../internal/cache/PartitionAttributesImpl.java | 689 +
.../internal/cache/PartitionRegionConfig.java | 468 +
.../cache/PartitionRegionConfigValidator.java | 502 +
.../internal/cache/PartitionedRegion.java | 10824 +++++++++++++++
.../PartitionedRegionBucketMgmtHelper.java | 46 +
.../cache/PartitionedRegionDataStore.java | 3207 +++++
.../cache/PartitionedRegionDataView.java | 133 +
.../cache/PartitionedRegionException.java | 39 +
.../internal/cache/PartitionedRegionHelper.java | 1124 ++
.../cache/PartitionedRegionQueryEvaluator.java | 1755 +++
.../internal/cache/PartitionedRegionStats.java | 1248 ++
.../internal/cache/PartitionedRegionStatus.java | 77 +
.../gemfire/internal/cache/PeerTXStateStub.java | 252 +
.../internal/cache/PersistentOplogSet.java | 1174 ++
.../internal/cache/PlaceHolderDiskRegion.java | 190 +
.../gemfire/internal/cache/PoolFactoryImpl.java | 680 +
.../gemfire/internal/cache/PoolManagerImpl.java | 340 +
.../gemfire/internal/cache/PoolStats.java | 310 +
.../cache/PreferBytesCachedDeserializable.java | 148 +
.../internal/cache/PrimaryBucketException.java | 40 +
.../cache/ProfileExchangeProcessor.java | 32 +
.../internal/cache/ProxyBucketRegion.java | 647 +
.../gemfire/internal/cache/ProxyRegionMap.java | 712 +
.../cache/PutAllPartialResultException.java | 220 +
.../gemfire/internal/cache/QueuedOperation.java | 190 +
.../internal/cache/RegionClearedException.java | 53 +
.../gemfire/internal/cache/RegionEntry.java | 454 +
.../internal/cache/RegionEntryContext.java | 28 +
.../internal/cache/RegionEntryFactory.java | 34 +
.../gemfire/internal/cache/RegionEventImpl.java | 343 +
.../internal/cache/RegionEvictorTask.java | 135 +
.../internal/cache/RegionExpiryTask.java | 150 +
.../internal/cache/RegionFactoryImpl.java | 41 +
.../internal/cache/RegionIdleExpiryTask.java | 63 +
.../gemfire/internal/cache/RegionMap.java | 378 +
.../internal/cache/RegionMapFactory.java | 62 +
.../gemfire/internal/cache/RegionQueue.java | 147 +
.../internal/cache/RegionQueueException.java | 40 +
.../gemfire/internal/cache/RegionStatus.java | 79 +
.../internal/cache/RegionTTLExpiryTask.java | 66 +
.../internal/cache/ReleaseClearLockMessage.java | 104 +
.../cache/ReliableDistributionData.java | 34 +
.../internal/cache/ReliableMessageQueue.java | 57 +
.../cache/ReliableMessageQueueFactory.java | 34 +
.../cache/ReliableMessageQueueFactoryImpl.java | 221 +
.../cache/RemoteContainsKeyValueMessage.java | 334 +
.../internal/cache/RemoteDestroyMessage.java | 704 +
.../internal/cache/RemoteFetchEntryMessage.java | 378 +
.../cache/RemoteFetchVersionMessage.java | 253 +
.../internal/cache/RemoteGetMessage.java | 448 +
.../internal/cache/RemoteInvalidateMessage.java | 425 +
.../cache/RemoteOperationException.java | 110 +
.../internal/cache/RemoteOperationMessage.java | 616 +
.../RemoteOperationMessageWithDirectReply.java | 76 +
.../internal/cache/RemotePutAllMessage.java | 526 +
.../internal/cache/RemotePutMessage.java | 1159 ++
.../internal/cache/RemoteRegionOperation.java | 216 +
.../internal/cache/RemoteRemoveAllMessage.java | 509 +
.../gemfire/internal/cache/RoleEventImpl.java | 87 +
.../cache/SearchLoadAndWriteProcessor.java | 2780 ++++
.../internal/cache/SendQueueOperation.java | 182 +
.../internal/cache/SerializationHelper.java | 8 +
.../internal/cache/StateFlushOperation.java | 775 ++
.../cache/StoreAllCachedDeserializable.java | 150 +
.../internal/cache/TXBucketRegionState.java | 28 +
.../gemfire/internal/cache/TXCommitMessage.java | 2384 ++++
.../gemfire/internal/cache/TXEntry.java | 263 +
.../gemfire/internal/cache/TXEntryState.java | 2067 +++
.../internal/cache/TXEntryStateFactory.java | 29 +
.../internal/cache/TXEntryUserAttrState.java | 58 +
.../gemfire/internal/cache/TXEvent.java | 125 +
.../internal/cache/TXFarSideCMTracker.java | 351 +
.../gemstone/gemfire/internal/cache/TXId.java | 122 +
.../gemfire/internal/cache/TXLockRequest.java | 135 +
.../gemfire/internal/cache/TXManagerImpl.java | 1369 ++
.../gemfire/internal/cache/TXMessage.java | 200 +
.../internal/cache/TXRegionLockRequestImpl.java | 200 +
.../gemfire/internal/cache/TXRegionState.java | 444 +
.../internal/cache/TXRemoteCommitMessage.java | 311 +
.../internal/cache/TXRemoteRollbackMessage.java | 79 +
.../internal/cache/TXReservationMgr.java | 145 +
.../gemfire/internal/cache/TXRmtEvent.java | 224 +
.../gemfire/internal/cache/TXState.java | 1752 +++
.../internal/cache/TXStateInterface.java | 181 +
.../gemfire/internal/cache/TXStateProxy.java | 87 +
.../internal/cache/TXStateProxyImpl.java | 989 ++
.../gemfire/internal/cache/TXStateStub.java | 529 +
.../cache/TXSynchronizationRunnable.java | 151 +
.../cache/TestHeapThresholdObserver.java | 53 +
.../cache/TimestampedEntryEventImpl.java | 64 +
.../gemstone/gemfire/internal/cache/Token.java | 286 +
.../internal/cache/TombstoneService.java | 991 ++
.../internal/cache/TransactionMessage.java | 60 +
.../gemfire/internal/cache/TxEntryFactory.java | 19 +
.../internal/cache/UnsharedImageState.java | 284 +
.../cache/UpdateAttributesProcessor.java | 544 +
.../cache/UpdateEntryVersionOperation.java | 187 +
.../gemfire/internal/cache/UpdateOperation.java | 647 +
.../cache/UserSpecifiedDiskStoreAttributes.java | 182 +
.../cache/UserSpecifiedRegionAttributes.java | 569 +
.../internal/cache/VMCachedDeserializable.java | 254 +
.../gemfire/internal/cache/VMLRURegionMap.java | 56 +
.../gemfire/internal/cache/VMRegionMap.java | 30 +
.../cache/VMStatsDiskLRURegionEntry.java | 31 +
.../cache/VMStatsDiskLRURegionEntryHeap.java | 56 +
.../VMStatsDiskLRURegionEntryHeapIntKey.java | 334 +
.../VMStatsDiskLRURegionEntryHeapLongKey.java | 334 +
.../VMStatsDiskLRURegionEntryHeapObjectKey.java | 327 +
...VMStatsDiskLRURegionEntryHeapStringKey1.java | 396 +
...VMStatsDiskLRURegionEntryHeapStringKey2.java | 437 +
.../VMStatsDiskLRURegionEntryHeapUUIDKey.java | 338 +
.../internal/cache/VMStatsDiskRegionEntry.java | 30 +
.../cache/VMStatsDiskRegionEntryHeap.java | 56 +
.../cache/VMStatsDiskRegionEntryHeapIntKey.java | 235 +
.../VMStatsDiskRegionEntryHeapLongKey.java | 235 +
.../VMStatsDiskRegionEntryHeapObjectKey.java | 228 +
.../VMStatsDiskRegionEntryHeapStringKey1.java | 297 +
.../VMStatsDiskRegionEntryHeapStringKey2.java | 338 +
.../VMStatsDiskRegionEntryHeapUUIDKey.java | 239 +
.../internal/cache/VMStatsLRURegionEntry.java | 34 +
.../cache/VMStatsLRURegionEntryHeap.java | 56 +
.../cache/VMStatsLRURegionEntryHeapIntKey.java | 245 +
.../cache/VMStatsLRURegionEntryHeapLongKey.java | 245 +
.../VMStatsLRURegionEntryHeapObjectKey.java | 238 +
.../VMStatsLRURegionEntryHeapStringKey1.java | 307 +
.../VMStatsLRURegionEntryHeapStringKey2.java | 348 +
.../cache/VMStatsLRURegionEntryHeapUUIDKey.java | 249 +
.../internal/cache/VMStatsRegionEntry.java | 30 +
.../internal/cache/VMStatsRegionEntryHeap.java | 56 +
.../cache/VMStatsRegionEntryHeapIntKey.java | 162 +
.../cache/VMStatsRegionEntryHeapLongKey.java | 162 +
.../cache/VMStatsRegionEntryHeapObjectKey.java | 155 +
.../cache/VMStatsRegionEntryHeapStringKey1.java | 224 +
.../cache/VMStatsRegionEntryHeapStringKey2.java | 265 +
.../cache/VMStatsRegionEntryHeapUUIDKey.java | 166 +
.../cache/VMThinDiskLRURegionEntry.java | 30 +
.../cache/VMThinDiskLRURegionEntryHeap.java | 56 +
.../VMThinDiskLRURegionEntryHeapIntKey.java | 269 +
.../VMThinDiskLRURegionEntryHeapLongKey.java | 269 +
.../VMThinDiskLRURegionEntryHeapObjectKey.java | 262 +
.../VMThinDiskLRURegionEntryHeapStringKey1.java | 331 +
.../VMThinDiskLRURegionEntryHeapStringKey2.java | 372 +
.../VMThinDiskLRURegionEntryHeapUUIDKey.java | 273 +
.../internal/cache/VMThinDiskRegionEntry.java | 32 +
.../cache/VMThinDiskRegionEntryHeap.java | 56 +
.../cache/VMThinDiskRegionEntryHeapIntKey.java | 169 +
.../cache/VMThinDiskRegionEntryHeapLongKey.java | 169 +
.../VMThinDiskRegionEntryHeapObjectKey.java | 162 +
.../VMThinDiskRegionEntryHeapStringKey1.java | 231 +
.../VMThinDiskRegionEntryHeapStringKey2.java | 272 +
.../cache/VMThinDiskRegionEntryHeapUUIDKey.java | 173 +
.../internal/cache/VMThinLRURegionEntry.java | 28 +
.../cache/VMThinLRURegionEntryHeap.java | 56 +
.../cache/VMThinLRURegionEntryHeapIntKey.java | 180 +
.../cache/VMThinLRURegionEntryHeapLongKey.java | 180 +
.../VMThinLRURegionEntryHeapObjectKey.java | 173 +
.../VMThinLRURegionEntryHeapStringKey1.java | 242 +
.../VMThinLRURegionEntryHeapStringKey2.java | 283 +
.../cache/VMThinLRURegionEntryHeapUUIDKey.java | 184 +
.../internal/cache/VMThinRegionEntry.java | 26 +
.../internal/cache/VMThinRegionEntryHeap.java | 58 +
.../cache/VMThinRegionEntryHeapIntKey.java | 96 +
.../cache/VMThinRegionEntryHeapLongKey.java | 96 +
.../cache/VMThinRegionEntryHeapObjectKey.java | 89 +
.../cache/VMThinRegionEntryHeapStringKey1.java | 158 +
.../cache/VMThinRegionEntryHeapStringKey2.java | 199 +
.../cache/VMThinRegionEntryHeapUUIDKey.java | 100 +
.../internal/cache/ValidatingDiskRegion.java | 477 +
.../internal/cache/ValueByteWrapper.java | 61 +
.../internal/cache/VersionTimestamp.java | 38 +
.../cache/VersionedStatsDiskLRURegionEntry.java | 24 +
.../VersionedStatsDiskLRURegionEntryHeap.java | 57 +
...sionedStatsDiskLRURegionEntryHeapIntKey.java | 419 +
...ionedStatsDiskLRURegionEntryHeapLongKey.java | 419 +
...nedStatsDiskLRURegionEntryHeapObjectKey.java | 412 +
...edStatsDiskLRURegionEntryHeapStringKey1.java | 481 +
...edStatsDiskLRURegionEntryHeapStringKey2.java | 522 +
...ionedStatsDiskLRURegionEntryHeapUUIDKey.java | 423 +
.../cache/VersionedStatsDiskRegionEntry.java | 24 +
.../VersionedStatsDiskRegionEntryHeap.java | 57 +
...VersionedStatsDiskRegionEntryHeapIntKey.java | 320 +
...ersionedStatsDiskRegionEntryHeapLongKey.java | 320 +
...sionedStatsDiskRegionEntryHeapObjectKey.java | 313 +
...ionedStatsDiskRegionEntryHeapStringKey1.java | 382 +
...ionedStatsDiskRegionEntryHeapStringKey2.java | 423 +
...ersionedStatsDiskRegionEntryHeapUUIDKey.java | 324 +
.../cache/VersionedStatsLRURegionEntry.java | 25 +
.../cache/VersionedStatsLRURegionEntryHeap.java | 57 +
.../VersionedStatsLRURegionEntryHeapIntKey.java | 330 +
...VersionedStatsLRURegionEntryHeapLongKey.java | 330 +
...rsionedStatsLRURegionEntryHeapObjectKey.java | 323 +
...sionedStatsLRURegionEntryHeapStringKey1.java | 392 +
...sionedStatsLRURegionEntryHeapStringKey2.java | 433 +
...VersionedStatsLRURegionEntryHeapUUIDKey.java | 334 +
.../cache/VersionedStatsRegionEntry.java | 25 +
.../cache/VersionedStatsRegionEntryHeap.java | 56 +
.../VersionedStatsRegionEntryHeapIntKey.java | 247 +
.../VersionedStatsRegionEntryHeapLongKey.java | 247 +
.../VersionedStatsRegionEntryHeapObjectKey.java | 240 +
...VersionedStatsRegionEntryHeapStringKey1.java | 309 +
...VersionedStatsRegionEntryHeapStringKey2.java | 350 +
.../VersionedStatsRegionEntryHeapUUIDKey.java | 251 +
.../cache/VersionedThinDiskLRURegionEntry.java | 24 +
.../VersionedThinDiskLRURegionEntryHeap.java | 57 +
...rsionedThinDiskLRURegionEntryHeapIntKey.java | 354 +
...sionedThinDiskLRURegionEntryHeapLongKey.java | 354 +
...onedThinDiskLRURegionEntryHeapObjectKey.java | 347 +
...nedThinDiskLRURegionEntryHeapStringKey1.java | 416 +
...nedThinDiskLRURegionEntryHeapStringKey2.java | 457 +
...sionedThinDiskLRURegionEntryHeapUUIDKey.java | 358 +
.../cache/VersionedThinDiskRegionEntry.java | 24 +
.../cache/VersionedThinDiskRegionEntryHeap.java | 57 +
.../VersionedThinDiskRegionEntryHeapIntKey.java | 254 +
...VersionedThinDiskRegionEntryHeapLongKey.java | 254 +
...rsionedThinDiskRegionEntryHeapObjectKey.java | 247 +
...sionedThinDiskRegionEntryHeapStringKey1.java | 316 +
...sionedThinDiskRegionEntryHeapStringKey2.java | 357 +
...VersionedThinDiskRegionEntryHeapUUIDKey.java | 258 +
.../cache/VersionedThinLRURegionEntry.java | 29 +
.../cache/VersionedThinLRURegionEntryHeap.java | 56 +
.../VersionedThinLRURegionEntryHeapIntKey.java | 265 +
.../VersionedThinLRURegionEntryHeapLongKey.java | 265 +
...ersionedThinLRURegionEntryHeapObjectKey.java | 258 +
...rsionedThinLRURegionEntryHeapStringKey1.java | 327 +
...rsionedThinLRURegionEntryHeapStringKey2.java | 368 +
.../VersionedThinLRURegionEntryHeapUUIDKey.java | 269 +
.../cache/VersionedThinRegionEntry.java | 24 +
.../cache/VersionedThinRegionEntryHeap.java | 56 +
.../VersionedThinRegionEntryHeapIntKey.java | 181 +
.../VersionedThinRegionEntryHeapLongKey.java | 181 +
.../VersionedThinRegionEntryHeapObjectKey.java | 174 +
.../VersionedThinRegionEntryHeapStringKey1.java | 243 +
.../VersionedThinRegionEntryHeapStringKey2.java | 284 +
.../VersionedThinRegionEntryHeapUUIDKey.java | 185 +
.../internal/cache/WrappedCallbackArgument.java | 96 +
.../cache/WrappedRegionMembershipListener.java | 191 +
.../CompressedCachedDeserializable.java | 188 +
.../SnappyCompressedCachedDeserializable.java | 74 +
.../internal/cache/control/FilterByPath.java | 57 +
.../cache/control/InternalResourceManager.java | 1806 +++
.../internal/cache/control/MemoryEvent.java | 57 +
.../internal/cache/control/MemoryEventImpl.java | 187 +
.../internal/cache/control/MemoryEventType.java | 352 +
.../control/PartitionRebalanceDetailsImpl.java | 150 +
.../cache/control/PartitionRebalanceEvent.java | 24 +
.../control/PartitionRebalanceEventImpl.java | 51 +
.../control/PartitionRebalanceEventType.java | 29 +
.../cache/control/RebalanceOperationImpl.java | 185 +
.../cache/control/RebalanceResultsImpl.java | 81 +
.../internal/cache/control/RegionFilter.java | 18 +
.../internal/cache/control/ResourceAdvisor.java | 429 +
.../internal/cache/control/ResourceEvent.java | 18 +
.../cache/control/ResourceListener.java | 24 +
.../cache/control/ResourceManagerStats.java | 511 +
.../gemfire/internal/cache/delta/Delta.java | 48 +
.../cache/doc-files/BucketAdvisor-state.png | Bin 0 -> 39148 bytes
.../internal/cache/doc-files/eventmatrix.xls | Bin 0 -> 24576 bytes
.../cache/doc-files/extensible-hashing.fig | 159 +
.../cache/doc-files/extensible-hashing.gif | Bin 0 -> 6605 bytes
.../cache/doc-files/jcache-get-flow.fig | 349 +
.../cache/doc-files/jcache-get-flow.pdf | Bin 0 -> 7519 bytes
.../cache/doc-files/jcache-put-flow.fig | 359 +
.../cache/doc-files/jcache-put-flow.pdf | Bin 0 -> 7667 bytes
.../doc-files/jcache-update-message-flow.fig | 334 +
.../doc-files/jcache-update-message-flow.pdf | Bin 0 -> 5937 bytes
.../cache/doc-files/partitioned-regions.fig | 255 +
.../cache/doc-files/partitioned-regions.gif | Bin 0 -> 9273 bytes
.../internal/cache/doc-files/properties.html | 3945 ++++++
.../cache/doc-files/region-implementation.fig | 262 +
.../cache/execute/AbstractExecution.java | 626 +
.../cache/execute/BucketMovedException.java | 48 +
.../cache/execute/DefaultResultCollector.java | 100 +
.../DistributedRegionFunctionExecutor.java | 437 +
.../DistributedRegionFunctionResultSender.java | 254 +
.../DistributedRegionFunctionResultWaiter.java | 51 +
.../cache/execute/FunctionContextImpl.java | 98 +
.../execute/FunctionExecutionNodePruner.java | 251 +
.../cache/execute/FunctionRemoteContext.java | 122 +
.../cache/execute/FunctionServiceStats.java | 433 +
.../internal/cache/execute/FunctionStats.java | 527 +
.../FunctionStreamingResultCollector.java | 627 +
.../cache/execute/InternalExecution.java | 105 +
.../execute/InternalFunctionException.java | 69 +
...ternalFunctionInvocationTargetException.java | 87 +
.../cache/execute/InternalFunctionService.java | 203 +
.../execute/InternalRegionFunctionContext.java | 75 +
.../cache/execute/InternalResultSender.java | 26 +
.../cache/execute/LocalResultCollector.java | 35 +
.../cache/execute/LocalResultCollectorImpl.java | 203 +
.../cache/execute/MemberFunctionExecutor.java | 274 +
.../execute/MemberFunctionResultSender.java | 270 +
.../execute/MemberFunctionResultWaiter.java | 42 +
.../cache/execute/MemberMappedArgument.java | 66 +
.../execute/MultiRegionFunctionContext.java | 41 +
.../execute/MultiRegionFunctionContextImpl.java | 47 +
.../execute/MultiRegionFunctionExecutor.java | 407 +
.../MultiRegionFunctionResultWaiter.java | 52 +
.../internal/cache/execute/NoResult.java | 71 +
.../PartitionedRegionFunctionExecutor.java | 369 +
.../PartitionedRegionFunctionResultSender.java | 332 +
.../PartitionedRegionFunctionResultWaiter.java | 116 +
.../execute/RegionFunctionContextImpl.java | 151 +
.../cache/execute/ServerFunctionExecutor.java | 437 +
.../execute/ServerRegionFunctionExecutor.java | 492 +
.../ServerToClientFunctionResultSender.java | 311 +
.../ServerToClientFunctionResultSender65.java | 281 +
.../execute/StreamingFunctionOperation.java | 118 +
.../execute/TransactionFunctionService.java | 184 +
.../cache/execute/util/CommitFunction.java | 135 +
.../util/FindRestEnabledServersFunction.java | 74 +
.../execute/util/NestedTransactionFunction.java | 108 +
.../cache/execute/util/RollbackFunction.java | 130 +
.../internal/cache/extension/Extensible.java | 34 +
.../internal/cache/extension/Extension.java | 44 +
.../cache/extension/ExtensionPoint.java | 56 +
.../cache/extension/SimpleExtensionPoint.java | 76 +
.../internal/cache/ha/HAContainerMap.java | 194 +
.../internal/cache/ha/HAContainerRegion.java | 161 +
.../internal/cache/ha/HAContainerWrapper.java | 38 +
.../internal/cache/ha/HARegionQueue.java | 4205 ++++++
.../cache/ha/HARegionQueueAttributes.java | 100 +
.../internal/cache/ha/HARegionQueueStats.java | 402 +
.../internal/cache/ha/QueueRemovalMessage.java | 231 +
.../internal/cache/ha/ThreadIdentifier.java | 321 +
.../locks/GFEAbstractQueuedSynchronizer.java | 1706 +++
.../locks/ReentrantReadWriteWriteShareLock.java | 468 +
.../cache/locks/TXLessorDepartureHandler.java | 93 +
.../internal/cache/locks/TXLockBatch.java | 139 +
.../gemfire/internal/cache/locks/TXLockId.java | 26 +
.../internal/cache/locks/TXLockIdImpl.java | 131 +
.../internal/cache/locks/TXLockService.java | 152 +
.../internal/cache/locks/TXLockServiceImpl.java | 269 +
.../internal/cache/locks/TXLockToken.java | 86 +
.../locks/TXLockUpdateParticipantsMessage.java | 177 +
.../locks/TXOriginatorRecoveryProcessor.java | 303 +
.../locks/TXRecoverGrantorMessageProcessor.java | 148 +
.../cache/locks/TXRegionLockRequest.java | 30 +
.../gemfire/internal/cache/lru/EnableLRU.java | 113 +
.../gemfire/internal/cache/lru/HeapEvictor.java | 344 +
.../cache/lru/HeapLRUCapacityController.java | 315 +
.../internal/cache/lru/HeapLRUStatistics.java | 59 +
.../internal/cache/lru/LRUAlgorithm.java | 343 +
.../cache/lru/LRUCapacityController.java | 347 +
.../internal/cache/lru/LRUClockNode.java | 36 +
.../gemfire/internal/cache/lru/LRUEntry.java | 23 +
.../internal/cache/lru/LRUMapCallbacks.java | 52 +
.../internal/cache/lru/LRUStatistics.java | 201 +
.../cache/lru/MemLRUCapacityController.java | 528 +
.../internal/cache/lru/NewLIFOClockHand.java | 59 +
.../internal/cache/lru/NewLRUClockHand.java | 449 +
.../gemfire/internal/cache/lru/Sizeable.java | 54 +
.../operations/ContainsKeyOperationContext.java | 43 +
.../gemfire/internal/cache/package.html | 225 +
.../AllBucketProfilesUpdateMessage.java | 161 +
.../partitioned/BecomePrimaryBucketMessage.java | 323 +
.../internal/cache/partitioned/Bucket.java | 71 +
.../cache/partitioned/BucketBackupMessage.java | 129 +
.../partitioned/BucketProfileUpdateMessage.java | 183 +
.../cache/partitioned/BucketSizeMessage.java | 277 +
.../partitioned/ContainsKeyValueMessage.java | 340 +
.../cache/partitioned/CreateBucketMessage.java | 362 +
.../partitioned/CreateMissingBucketsTask.java | 61 +
.../partitioned/DeposePrimaryBucketMessage.java | 276 +
.../cache/partitioned/DestroyMessage.java | 593 +
.../partitioned/DumpAllPRConfigMessage.java | 69 +
.../cache/partitioned/DumpB2NRegion.java | 335 +
.../cache/partitioned/DumpBucketsMessage.java | 102 +
.../partitioned/EndBucketCreationMessage.java | 140 +
.../partitioned/FetchBulkEntriesMessage.java | 661 +
.../cache/partitioned/FetchEntriesMessage.java | 651 +
.../cache/partitioned/FetchEntryMessage.java | 423 +
.../cache/partitioned/FetchKeysMessage.java | 573 +
.../FetchPartitionDetailsMessage.java | 388 +
.../cache/partitioned/FlushMessage.java | 145 +
.../internal/cache/partitioned/GetMessage.java | 610 +
.../partitioned/IdentityRequestMessage.java | 334 +
.../partitioned/IdentityUpdateMessage.java | 158 +
.../cache/partitioned/IndexCreationMsg.java | 707 +
.../cache/partitioned/InterestEventMessage.java | 275 +
.../cache/partitioned/InternalPRInfo.java | 35 +
.../partitioned/InternalPartitionDetails.java | 36 +
.../cache/partitioned/InvalidateMessage.java | 396 +
.../internal/cache/partitioned/LoadProbe.java | 24 +
.../internal/cache/partitioned/LockObject.java | 33 +
.../partitioned/ManageBackupBucketMessage.java | 428 +
.../cache/partitioned/ManageBucketMessage.java | 410 +
.../cache/partitioned/MoveBucketMessage.java | 315 +
.../cache/partitioned/OfflineMemberDetails.java | 39 +
.../partitioned/OfflineMemberDetailsImpl.java | 70 +
.../cache/partitioned/PREntriesIterator.java | 35 +
.../PRFunctionStreamingResultCollector.java | 427 +
.../internal/cache/partitioned/PRLoad.java | 145 +
.../PRLocallyDestroyedException.java | 31 +
.../cache/partitioned/PRSanityCheckMessage.java | 155 +
.../cache/partitioned/PRTombstoneMessage.java | 183 +
.../PRUpdateEntryVersionMessage.java | 286 +
.../partitioned/PartitionMemberInfoImpl.java | 158 +
.../cache/partitioned/PartitionMessage.java | 776 ++
.../PartitionMessageWithDirectReply.java | 132 +
.../partitioned/PartitionRegionInfoImpl.java | 130 +
...rtitionedRegionFunctionStreamingMessage.java | 196 +
.../partitioned/PartitionedRegionObserver.java | 30 +
.../PartitionedRegionObserverAdapter.java | 34 +
.../PartitionedRegionObserverHolder.java | 54 +
.../PartitionedRegionRebalanceOp.java | 844 ++
.../partitioned/PrimaryRequestMessage.java | 229 +
.../cache/partitioned/PutAllPRMessage.java | 826 ++
.../internal/cache/partitioned/PutMessage.java | 1310 ++
.../cache/partitioned/QueryMessage.java | 286 +
.../cache/partitioned/RecoveryRunnable.java | 77 +
.../RedundancyAlreadyMetException.java | 33 +
.../cache/partitioned/RedundancyLogger.java | 386 +
.../cache/partitioned/RegionAdvisor.java | 1948 +++
.../partitioned/RemoteFetchKeysMessage.java | 480 +
.../cache/partitioned/RemoteSizeMessage.java | 354 +
.../cache/partitioned/RemoveAllPRMessage.java | 787 ++
.../cache/partitioned/RemoveBucketMessage.java | 314 +
.../cache/partitioned/RemoveIndexesMessage.java | 536 +
.../internal/cache/partitioned/SizeMessage.java | 342 +
.../cache/partitioned/SizedBasedLoadProbe.java | 74 +
.../StreamingPartitionOperation.java | 465 +
.../partitioned/rebalance/BucketOperator.java | 60 +
.../rebalance/CompositeDirector.java | 118 +
.../rebalance/ExplicitMoveDirector.java | 90 +
.../partitioned/rebalance/FPRDirector.java | 70 +
.../partitioned/rebalance/MoveBuckets.java | 54 +
.../partitioned/rebalance/MovePrimaries.java | 54 +
.../partitioned/rebalance/MovePrimariesFPR.java | 96 +
.../rebalance/PartitionedRegionLoadModel.java | 1602 +++
.../rebalance/PercentageMoveDirector.java | 156 +
.../rebalance/RebalanceDirector.java | 70 +
.../rebalance/RebalanceDirectorAdapter.java | 30 +
.../rebalance/RemoveOverRedundancy.java | 73 +
.../rebalance/SatisfyRedundancy.java | 78 +
.../rebalance/SatisfyRedundancyFPR.java | 80 +
.../rebalance/SimulatedBucketOperator.java | 41 +
.../cache/persistence/BackupInspector.java | 336 +
.../cache/persistence/BackupManager.java | 360 +
.../cache/persistence/BytesAndBits.java | 42 +
.../cache/persistence/CanonicalIdHolder.java | 92 +
.../CreatePersistentRegionProcessor.java | 49 +
.../cache/persistence/DiskExceptionHandler.java | 29 +
.../persistence/DiskInitFileInterpreter.java | 139 +
.../cache/persistence/DiskInitFileParser.java | 610 +
.../cache/persistence/DiskRecoveryStore.java | 57 +
.../cache/persistence/DiskRegionView.java | 98 +
.../cache/persistence/DiskStoreFilter.java | 48 +
.../internal/cache/persistence/DiskStoreID.java | 147 +
.../persistence/MembershipFlushRequest.java | 132 +
.../persistence/MembershipViewRequest.java | 245 +
.../internal/cache/persistence/OplogType.java | 16 +
.../cache/persistence/PRPersistentConfig.java | 65 +
.../cache/persistence/PersistenceAdvisor.java | 181 +
.../persistence/PersistenceAdvisorImpl.java | 1295 ++
.../persistence/PersistenceObserverHolder.java | 93 +
.../cache/persistence/PersistentMemberID.java | 162 +
.../persistence/PersistentMemberManager.java | 261 +
.../persistence/PersistentMemberPattern.java | 220 +
.../persistence/PersistentMemberState.java | 32 +
.../cache/persistence/PersistentMemberView.java | 142 +
.../persistence/PersistentMembershipView.java | 103 +
.../persistence/PersistentStateListener.java | 29 +
.../PersistentStateQueryMessage.java | 299 +
.../PersistentStateQueryResults.java | 48 +
.../PrepareNewPersistentMemberMessage.java | 159 +
.../RemovePersistentMemberMessage.java | 173 +
.../cache/persistence/RestoreScript.java | 214 +
.../persistence/UninterruptibleFileChannel.java | 13 +
.../UninterruptibleRandomAccessFile.java | 235 +
.../persistence/query/CloseableIterator.java | 17 +
.../persistence/query/IdentityExtractor.java | 10 +
.../cache/persistence/query/IndexMap.java | 178 +
.../cache/persistence/query/ResultBag.java | 51 +
.../cache/persistence/query/ResultList.java | 49 +
.../cache/persistence/query/ResultMap.java | 115 +
.../cache/persistence/query/ResultSet.java | 51 +
.../persistence/query/SortKeyExtractor.java | 5 +
.../query/TemporaryResultSetFactory.java | 70 +
.../persistence/query/mock/ByteComparator.java | 77 +
.../mock/CachedDeserializableComparator.java | 45 +
.../persistence/query/mock/IndexMapImpl.java | 269 +
.../persistence/query/mock/ItrAdapter.java | 53 +
.../query/mock/NaturalComparator.java | 17 +
.../cache/persistence/query/mock/Pair.java | 63 +
.../persistence/query/mock/PairComparator.java | 37 +
.../persistence/query/mock/ResultListImpl.java | 46 +
.../query/mock/ReverseComparator.java | 31 +
.../query/mock/SortedResultBagImpl.java | 55 +
.../query/mock/SortedResultMapImpl.java | 175 +
.../query/mock/SortedResultSetImpl.java | 43 +
.../persistence/soplog/AbstractCompactor.java | 524 +
.../soplog/AbstractKeyValueIterator.java | 67 +
.../soplog/AbstractSortedReader.java | 126 +
.../soplog/ArraySerializedComparator.java | 135 +
.../persistence/soplog/ByteComparator.java | 53 +
.../cache/persistence/soplog/Compactor.java | 165 +
.../soplog/CompositeSerializedComparator.java | 48 +
.../soplog/DelegatingSerializedComparator.java | 29 +
.../soplog/IndexSerializedComparator.java | 118 +
.../persistence/soplog/KeyValueIterator.java | 34 +
.../cache/persistence/soplog/LevelTracker.java | 111 +
.../soplog/LexicographicalComparator.java | 451 +
.../cache/persistence/soplog/NonCompactor.java | 101 +
.../soplog/ReversingSerializedComparator.java | 58 +
.../persistence/soplog/SizeTieredCompactor.java | 189 +
.../cache/persistence/soplog/SoplogToken.java | 107 +
.../cache/persistence/soplog/SortedBuffer.java | 358 +
.../cache/persistence/soplog/SortedOplog.java | 149 +
.../persistence/soplog/SortedOplogFactory.java | 246 +
.../persistence/soplog/SortedOplogSet.java | 109 +
.../persistence/soplog/SortedOplogSetImpl.java | 771 ++
.../soplog/SortedOplogStatistics.java | 468 +
.../cache/persistence/soplog/SortedReader.java | 259 +
.../persistence/soplog/TrackedReference.java | 100 +
.../soplog/nofile/NoFileSortedOplog.java | 235 +
.../soplog/nofile/NoFileSortedOplogFactory.java | 32 +
.../snapshot/CacheSnapshotServiceImpl.java | 121 +
.../internal/cache/snapshot/ClientExporter.java | 220 +
.../cache/snapshot/ExportedRegistry.java | 95 +
.../internal/cache/snapshot/FlowController.java | 341 +
.../internal/cache/snapshot/GFSnapshot.java | 408 +
.../internal/cache/snapshot/LocalExporter.java | 49 +
.../snapshot/RegionSnapshotServiceImpl.java | 556 +
.../cache/snapshot/SnapshotFileMapper.java | 84 +
.../cache/snapshot/SnapshotOptionsImpl.java | 115 +
.../internal/cache/snapshot/SnapshotPacket.java | 252 +
.../cache/snapshot/WindowedExporter.java | 392 +
.../gemfire/internal/cache/tier/Acceptor.java | 106 +
.../internal/cache/tier/BatchException.java | 63 +
.../internal/cache/tier/CachedRegionHelper.java | 100 +
.../internal/cache/tier/ClientHandShake.java | 37 +
.../gemfire/internal/cache/tier/Command.java | 27 +
.../internal/cache/tier/ConnectionProxy.java | 184 +
.../internal/cache/tier/InterestType.java | 55 +
.../cache/tier/InternalBridgeMembership.java | 715 +
.../internal/cache/tier/MessageType.java | 560 +
.../gemfire/internal/cache/tier/package.html | 7 +
.../cache/tier/sockets/AcceptorImpl.java | 1887 +++
.../cache/tier/sockets/BaseCommand.java | 1616 +++
.../cache/tier/sockets/BaseCommandQuery.java | 562 +
.../cache/tier/sockets/CacheClientNotifier.java | 2751 ++++
.../tier/sockets/CacheClientNotifierStats.java | 286 +
.../cache/tier/sockets/CacheClientProxy.java | 3068 ++++
.../tier/sockets/CacheClientProxyStats.java | 396 +
.../cache/tier/sockets/CacheClientUpdater.java | 1985 +++
.../cache/tier/sockets/CacheServerHelper.java | 178 +
.../cache/tier/sockets/CacheServerStats.java | 1139 ++
.../cache/tier/sockets/ChunkedMessage.java | 370 +
.../tier/sockets/ClientBlacklistProcessor.java | 165 +
.../sockets/ClientDataSerializerMessage.java | 247 +
.../cache/tier/sockets/ClientHealthMonitor.java | 963 ++
.../tier/sockets/ClientInstantiatorMessage.java | 222 +
.../tier/sockets/ClientInterestMessageImpl.java | 265 +
.../tier/sockets/ClientMarkerMessageImpl.java | 118 +
.../cache/tier/sockets/ClientMessage.java | 37 +
.../tier/sockets/ClientPingMessageImpl.java | 102 +
.../tier/sockets/ClientProxyMembershipID.java | 622 +
.../tier/sockets/ClientTombstoneMessage.java | 179 +
.../cache/tier/sockets/ClientUpdateMessage.java | 179 +
.../tier/sockets/ClientUpdateMessageImpl.java | 1675 +++
.../cache/tier/sockets/ClientUserAuths.java | 192 +
.../cache/tier/sockets/CommandInitializer.java | 323 +
.../cache/tier/sockets/ConnectionListener.java | 46 +
.../tier/sockets/ConnectionListenerAdapter.java | 29 +
.../cache/tier/sockets/HAEventWrapper.java | 426 +
.../internal/cache/tier/sockets/HandShake.java | 1908 +++
.../tier/sockets/InterestResultPolicyImpl.java | 50 +
.../internal/cache/tier/sockets/Message.java | 1111 ++
.../cache/tier/sockets/MessageStats.java | 20 +
.../cache/tier/sockets/ObjectPartList.java | 254 +
.../cache/tier/sockets/ObjectPartList651.java | 157 +
.../internal/cache/tier/sockets/Part.java | 350 +
.../RemoveClientFromBlacklistMessage.java | 105 +
.../tier/sockets/SerializedObjectPartList.java | 123 +
.../cache/tier/sockets/ServerConnection.java | 2014 +++
.../tier/sockets/ServerHandShakeProcessor.java | 455 +
.../cache/tier/sockets/ServerQueueStatus.java | 123 +
.../tier/sockets/ServerResponseMatrix.java | 133 +
.../tier/sockets/UnregisterAllInterest.java | 41 +
.../cache/tier/sockets/UserAuthAttributes.java | 72 +
.../cache/tier/sockets/VersionedObjectList.java | 744 +
.../cache/tier/sockets/command/AddPdxEnum.java | 64 +
.../cache/tier/sockets/command/AddPdxType.java | 69 +
.../cache/tier/sockets/command/ClearRegion.java | 141 +
.../cache/tier/sockets/command/ClientReady.java | 67 +
.../tier/sockets/command/CloseConnection.java | 68 +
.../tier/sockets/command/CommitCommand.java | 131 +
.../cache/tier/sockets/command/ContainsKey.java | 136 +
.../tier/sockets/command/ContainsKey66.java | 153 +
.../tier/sockets/command/CreateRegion.java | 128 +
.../cache/tier/sockets/command/Default.java | 43 +
.../cache/tier/sockets/command/Destroy.java | 210 +
.../cache/tier/sockets/command/Destroy65.java | 331 +
.../cache/tier/sockets/command/Destroy70.java | 109 +
.../tier/sockets/command/DestroyRegion.java | 166 +
.../tier/sockets/command/ExecuteFunction.java | 231 +
.../tier/sockets/command/ExecuteFunction65.java | 263 +
.../tier/sockets/command/ExecuteFunction66.java | 420 +
.../tier/sockets/command/ExecuteFunction70.java | 135 +
.../sockets/command/ExecuteRegionFunction.java | 262 +
.../command/ExecuteRegionFunction61.java | 284 +
.../command/ExecuteRegionFunction65.java | 392 +
.../command/ExecuteRegionFunction66.java | 428 +
.../command/ExecuteRegionFunctionSingleHop.java | 413 +
.../sockets/command/GatewayReceiverCommand.java | 795 ++
.../cache/tier/sockets/command/Get70.java | 438 +
.../cache/tier/sockets/command/GetAll.java | 251 +
.../cache/tier/sockets/command/GetAll651.java | 275 +
.../cache/tier/sockets/command/GetAll70.java | 265 +
.../cache/tier/sockets/command/GetAllForRI.java | 43 +
.../sockets/command/GetAllWithCallback.java | 258 +
.../command/GetClientPRMetadataCommand.java | 106 +
.../command/GetClientPRMetadataCommand66.java | 97 +
.../GetClientPartitionAttributesCommand.java | 133 +
.../GetClientPartitionAttributesCommand66.java | 150 +
.../cache/tier/sockets/command/GetEntry70.java | 62 +
.../tier/sockets/command/GetEntryCommand.java | 55 +
.../sockets/command/GetFunctionAttribute.java | 72 +
.../tier/sockets/command/GetPDXEnumById.java | 64 +
.../tier/sockets/command/GetPDXIdForEnum.java | 65 +
.../tier/sockets/command/GetPDXIdForType.java | 66 +
.../tier/sockets/command/GetPDXTypeById.java | 64 +
.../tier/sockets/command/GetPdxEnums70.java | 59 +
.../tier/sockets/command/GetPdxTypes70.java | 58 +
.../cache/tier/sockets/command/Invalid.java | 40 +
.../cache/tier/sockets/command/Invalidate.java | 240 +
.../tier/sockets/command/Invalidate70.java | 98 +
.../cache/tier/sockets/command/KeySet.java | 184 +
.../cache/tier/sockets/command/MakePrimary.java | 57 +
.../tier/sockets/command/ManagementCommand.java | 30 +
.../cache/tier/sockets/command/PeriodicAck.java | 70 +
.../cache/tier/sockets/command/Ping.java | 93 +
.../cache/tier/sockets/command/Put.java | 252 +
.../cache/tier/sockets/command/Put61.java | 310 +
.../cache/tier/sockets/command/Put65.java | 530 +
.../cache/tier/sockets/command/Put70.java | 117 +
.../cache/tier/sockets/command/PutAll.java | 259 +
.../cache/tier/sockets/command/PutAll70.java | 371 +
.../cache/tier/sockets/command/PutAll80.java | 460 +
.../sockets/command/PutAllWithCallback.java | 44 +
.../sockets/command/PutUserCredentials.java | 72 +
.../cache/tier/sockets/command/Query.java | 98 +
.../cache/tier/sockets/command/Query651.java | 128 +
.../command/RegisterDataSerializers.java | 105 +
.../sockets/command/RegisterInstantiators.java | 139 +
.../tier/sockets/command/RegisterInterest.java | 236 +
.../sockets/command/RegisterInterest61.java | 273 +
.../sockets/command/RegisterInterestList.java | 244 +
.../sockets/command/RegisterInterestList61.java | 256 +
.../sockets/command/RegisterInterestList66.java | 258 +
.../cache/tier/sockets/command/RemoveAll.java | 395 +
.../tier/sockets/command/RemoveUserAuth.java | 75 +
.../cache/tier/sockets/command/Request.java | 264 +
.../tier/sockets/command/RequestEventValue.java | 168 +
.../tier/sockets/command/RollbackCommand.java | 81 +
.../cache/tier/sockets/command/Size.java | 158 +
.../tier/sockets/command/TXFailoverCommand.java | 123 +
.../command/TXSynchronizationCommand.java | 200 +
.../sockets/command/UnregisterInterest.java | 143 +
.../sockets/command/UnregisterInterestList.java | 162 +
.../command/UpdateClientNotification.java | 70 +
.../doc-files/communication-architecture.fig | 158 +
.../doc-files/communication-architecture.gif | Bin 0 -> 5485 bytes
.../internal/cache/tier/sockets/package.html | 7 +
.../cache/tx/AbstractPeerTXRegionStub.java | 47 +
.../internal/cache/tx/ClientTXRegionStub.java | 149 +
.../internal/cache/tx/ClientTXStateStub.java | 283 +
.../cache/tx/DistributedTXRegionStub.java | 246 +
.../cache/tx/PartitionedTXRegionStub.java | 518 +
.../gemfire/internal/cache/tx/TXRegionStub.java | 56 +
.../cache/tx/TransactionalOperation.java | 105 +
.../cache/versions/CompactVersionHolder.java | 96 +
.../ConcurrentCacheModificationException.java | 32 +
.../cache/versions/DiskRegionVersionVector.java | 94 +
.../internal/cache/versions/DiskVersionTag.java | 74 +
.../internal/cache/versions/RVVException.java | 198 +
.../internal/cache/versions/RVVExceptionB.java | 287 +
.../internal/cache/versions/RVVExceptionT.java | 274 +
.../cache/versions/RegionVersionHolder.java | 757 +
.../cache/versions/RegionVersionVector.java | 1524 ++
.../cache/versions/VMRegionVersionVector.java | 92 +
.../internal/cache/versions/VMVersionTag.java | 65 +
.../internal/cache/versions/VersionHolder.java | 48 +
.../internal/cache/versions/VersionSource.java | 32 +
.../internal/cache/versions/VersionStamp.java | 84 +
.../internal/cache/versions/VersionTag.java | 530 +
.../internal/cache/vmotion/VMotionObserver.java | 36 +
.../cache/vmotion/VMotionObserverAdapter.java | 41 +
.../cache/vmotion/VMotionObserverHolder.java | 49 +
.../cache/wan/AbstractGatewaySender.java | 1246 ++
.../AbstractGatewaySenderEventProcessor.java | 1311 ++
.../AsyncEventQueueConfigurationException.java | 64 +
.../internal/cache/wan/BatchException70.java | 99 +
.../cache/wan/DistributedSystemListener.java | 16 +
.../cache/wan/GatewayEventFilterImpl.java | 36 +
.../cache/wan/GatewayReceiverException.java | 60 +
.../cache/wan/GatewayReceiverStats.java | 269 +
.../cache/wan/GatewaySenderAdvisor.java | 701 +
.../cache/wan/GatewaySenderAttributes.java | 180 +
.../GatewaySenderConfigurationException.java | 40 +
.../wan/GatewaySenderEventCallbackArgument.java | 193 +
.../GatewaySenderEventCallbackDispatcher.java | 195 +
.../cache/wan/GatewaySenderEventDispatcher.java | 26 +
.../cache/wan/GatewaySenderEventImpl.java | 941 ++
.../cache/wan/GatewaySenderException.java | 54 +
.../internal/cache/wan/GatewaySenderStats.java | 735 +
.../cache/wan/InternalGatewaySenderFactory.java | 22 +
.../cache/wan/TransportFilterServerSocket.java | 31 +
.../cache/wan/TransportFilterSocket.java | 69 +
.../cache/wan/TransportFilterSocketFactory.java | 32 +
.../internal/cache/wan/WANServiceProvider.java | 60 +
.../BucketRegionQueueUnavailableException.java | 19 +
...rentParallelGatewaySenderEventProcessor.java | 352 +
.../ConcurrentParallelGatewaySenderQueue.java | 214 +
.../ParallelGatewaySenderEventProcessor.java | 163 +
.../parallel/ParallelGatewaySenderQueue.java | 1800 +++
.../ParallelQueueBatchRemovalMessage.java | 270 +
.../parallel/ParallelQueueRemovalMessage.java | 273 +
.../cache/wan/parallel/RREventIDResolver.java | 45 +
.../cache/wan/serial/BatchDestroyOperation.java | 228 +
...urrentSerialGatewaySenderEventProcessor.java | 354 +
.../SerialGatewaySenderEventProcessor.java | 819 ++
.../wan/serial/SerialGatewaySenderQueue.java | 1226 ++
.../serial/SerialSecondaryGatewayListener.java | 90 +
.../internal/cache/wan/spi/WANFactory.java | 21 +
.../cache/xmlcache/AbstractXmlParser.java | 86 +
.../cache/xmlcache/AsyncEventQueueCreation.java | 205 +
.../cache/xmlcache/BindingCreation.java | 52 +
.../cache/xmlcache/BridgeServerCreation.java | 213 +
.../internal/cache/xmlcache/CacheCreation.java | 1621 +++
.../CacheTransactionManagerCreation.java | 128 +
.../internal/cache/xmlcache/CacheXml.java | 995 ++
.../cache/xmlcache/CacheXmlGenerator.java | 2820 ++++
.../internal/cache/xmlcache/CacheXmlParser.java | 3574 +++++
.../xmlcache/CacheXmlPropertyResolver.java | 138 +
.../CacheXmlPropertyResolverHelper.java | 143 +
.../cache/xmlcache/CacheXmlVersion.java | 118 +
.../cache/xmlcache/ClientCacheCreation.java | 302 +
.../cache/xmlcache/ClientHaQueueCreation.java | 91 +
.../internal/cache/xmlcache/Declarable2.java | 30 +
.../cache/xmlcache/DefaultEntityResolver2.java | 66 +
.../xmlcache/DiskStoreAttributesCreation.java | 305 +
.../cache/xmlcache/FunctionServiceCreation.java | 44 +
.../cache/xmlcache/GatewayReceiverCreation.java | 181 +
.../cache/xmlcache/IndexCreationData.java | 135 +
.../ParallelAsyncEventQueueCreation.java | 110 +
.../xmlcache/ParallelGatewaySenderCreation.java | 110 +
.../cache/xmlcache/PivotalEntityResolver.java | 49 +
.../cache/xmlcache/PropertyResolver.java | 48 +
.../xmlcache/RegionAttributesCreation.java | 1601 +++
.../internal/cache/xmlcache/RegionCreation.java | 960 ++
.../cache/xmlcache/ResourceManagerCreation.java | 127 +
.../xmlcache/SerialAsyncEventQueueCreation.java | 106 +
.../xmlcache/SerialGatewaySenderCreation.java | 106 +
.../cache/xmlcache/SerializerCreation.java | 99 +
.../internal/cache/xmlcache/XmlGenerator.java | 53 +
.../cache/xmlcache/XmlGeneratorUtils.java | 142 +
.../internal/cache/xmlcache/XmlParser.java | 49 +
.../internal/cache/xmlcache/package.html | 16 +
.../gemfire/internal/concurrent/Atomics.java | 58 +
.../concurrent/CompactConcurrentHashSet2.java | 2498 ++++
.../internal/concurrent/ConcurrentHashSet.java | 80 +
.../gemfire/internal/concurrent/LI.java | 86 +
.../internal/datasource/AbstractDataSource.java | 232 +
.../internal/datasource/AbstractPoolCache.java | 546 +
.../ClientConnectionFactoryWrapper.java | 45 +
.../internal/datasource/ConfigProperty.java | 56 +
.../ConfiguredDataSourceProperties.java | 279 +
.../ConnectionEventListenerAdaptor.java | 67 +
.../datasource/ConnectionPoolCache.java | 43 +
.../datasource/ConnectionPoolCacheImpl.java | 95 +
.../internal/datasource/ConnectionProvider.java | 41 +
.../datasource/ConnectionProviderException.java | 58 +
.../datasource/DataSourceCreateException.java | 53 +
.../internal/datasource/DataSourceFactory.java | 365 +
.../datasource/DataSourceResources.java | 40 +
.../FacetsJCAConnectionManagerImpl.java | 260 +
.../datasource/GemFireBasicDataSource.java | 141 +
.../datasource/GemFireConnPooledDataSource.java | 216 +
.../GemFireConnectionPoolManager.java | 99 +
.../GemFireTransactionDataSource.java | 255 +
.../datasource/JCAConnectionManagerImpl.java | 211 +
.../datasource/ManagedPoolCacheImpl.java | 95 +
.../internal/datasource/PoolException.java | 46 +
.../internal/datasource/TranxPoolCacheImpl.java | 93 +
.../gemfire/internal/doc-files/cs-maps.fig | 150 +
.../gemfire/internal/doc-files/cs-maps.gif | Bin 0 -> 5951 bytes
.../gemfire/internal/doc-files/ds-map.fig | 105 +
.../gemfire/internal/doc-files/ds-map.gif | Bin 0 -> 4867 bytes
.../internal/doc-files/merge-log-files.fig | 153 +
.../internal/doc-files/merge-log-files.gif | Bin 0 -> 2646 bytes
.../i18n/AbstractStringIdResourceBundle.java | 148 +
.../gemfire/internal/i18n/LocalizedStrings.java | 2065 +++
.../internal/i18n/ParentLocalizedStrings.java | 2416 ++++
.../internal/io/CompositeOutputStream.java | 167 +
.../internal/io/CompositePrintStream.java | 70 +
.../gemfire/internal/io/TeeOutputStream.java | 84 +
.../gemfire/internal/io/TeePrintStream.java | 36 +
.../gemfire/internal/jndi/ContextImpl.java | 770 +
.../jndi/InitialContextFactoryImpl.java | 93 +
.../gemfire/internal/jndi/JNDIInvoker.java | 392 +
.../gemfire/internal/jndi/NameParserImpl.java | 46 +
.../gemfire/internal/jta/GlobalTransaction.java | 720 +
.../gemfire/internal/jta/TransactionImpl.java | 261 +
.../internal/jta/TransactionManagerImpl.java | 858 ++
.../gemfire/internal/jta/TransactionUtils.java | 50 +
.../internal/jta/UserTransactionImpl.java | 136 +
.../gemstone/gemfire/internal/jta/XidImpl.java | 85 +
.../gemfire/internal/lang/ClassUtils.java | 123 +
.../gemstone/gemfire/internal/lang/Filter.java | 20 +
.../gemfire/internal/lang/InOutParameter.java | 94 +
.../gemfire/internal/lang/Initable.java | 28 +
.../gemfire/internal/lang/Initializer.java | 37 +
.../internal/lang/MutableIdentifiable.java | 31 +
.../gemfire/internal/lang/ObjectUtils.java | 184 +
.../gemfire/internal/lang/Orderable.java | 33 +
.../gemstone/gemfire/internal/lang/Ordered.java | 36 +
.../gemfire/internal/lang/StringUtils.java | 346 +
.../gemfire/internal/lang/SystemUtils.java | 167 +
.../gemfire/internal/lang/ThreadUtils.java | 123 +
.../gemfire/internal/logging/DateFormatter.java | 78 +
.../internal/logging/DebugLogWriter.java | 117 +
.../internal/logging/GemFireFormatter.java | 95 +
.../internal/logging/GemFireHandler.java | 72 +
.../gemfire/internal/logging/GemFireLevel.java | 69 +
.../internal/logging/InternalLogWriter.java | 119 +
.../internal/logging/LocalLogWriter.java | 86 +
.../gemfire/internal/logging/LogConfig.java | 37 +
.../gemfire/internal/logging/LogFileParser.java | 496 +
.../gemfire/internal/logging/LogService.java | 326 +
.../internal/logging/LogWriterFactory.java | 93 +
.../gemfire/internal/logging/LogWriterImpl.java | 1042 ++
.../internal/logging/LoggingThreadGroup.java | 331 +
.../internal/logging/ManagerLogWriter.java | 683 +
.../gemfire/internal/logging/MergeLogFiles.java | 1005 ++
.../gemfire/internal/logging/PureLogWriter.java | 274 +
.../logging/SecurityLocalLogWriter.java | 78 +
.../internal/logging/SecurityLogConfig.java | 50 +
.../internal/logging/SecurityLogWriter.java | 71 +
.../logging/SecurityManagerLogWriter.java | 64 +
.../gemfire/internal/logging/SortLogFile.java | 140 +
.../internal/logging/StandardErrorPrinter.java | 27 +
.../internal/logging/StandardOutputPrinter.java | 27 +
.../internal/logging/log4j/AlertAppender.java | 324 +
.../internal/logging/log4j/AppenderContext.java | 64 +
.../internal/logging/log4j/Configurator.java | 113 +
.../internal/logging/log4j/FastLogger.java | 85 +
.../internal/logging/log4j/GemFireLogger.java | 907 ++
.../logging/log4j/LocalizedMessage.java | 64 +
.../internal/logging/log4j/LogMarker.java | 83 +
.../logging/log4j/LogWriterAppender.java | 196 +
.../logging/log4j/LogWriterAppenders.java | 283 +
.../internal/logging/log4j/LogWriterLogger.java | 2026 +++
.../logging/log4j/ThreadIdPatternConverter.java | 45 +
.../gemfire/internal/memcached/Command.java | 492 +
.../internal/memcached/CommandProcessor.java | 33 +
.../internal/memcached/ConnectionHandler.java | 84 +
.../gemfire/internal/memcached/KeyWrapper.java | 86 +
.../gemfire/internal/memcached/Reply.java | 112 +
.../internal/memcached/RequestReader.java | 282 +
.../internal/memcached/ResponseStatus.java | 55 +
.../internal/memcached/ValueWrapper.java | 137 +
.../memcached/commands/AbstractCommand.java | 214 +
.../internal/memcached/commands/AddCommand.java | 81 +
.../memcached/commands/AddQCommand.java | 14 +
.../memcached/commands/AppendCommand.java | 83 +
.../memcached/commands/AppendQCommand.java | 13 +
.../internal/memcached/commands/CASCommand.java | 67 +
.../memcached/commands/ClientError.java | 30 +
.../memcached/commands/DecrementCommand.java | 164 +
.../memcached/commands/DecrementQCommand.java | 13 +
.../memcached/commands/DeleteCommand.java | 92 +
.../memcached/commands/DeleteQCommand.java | 13 +
.../memcached/commands/FlushAllCommand.java | 110 +
.../memcached/commands/FlushAllQCommand.java | 13 +
.../internal/memcached/commands/GATCommand.java | 13 +
.../memcached/commands/GATQCommand.java | 13 +
.../internal/memcached/commands/GetCommand.java | 220 +
.../memcached/commands/GetKCommand.java | 14 +
.../memcached/commands/GetKQCommand.java | 14 +
.../memcached/commands/GetQCommand.java | 29 +
.../memcached/commands/IncrementCommand.java | 161 +
.../memcached/commands/IncrementQCommand.java | 13 +
.../memcached/commands/NoOpCommand.java | 31 +
.../memcached/commands/NotSupportedCommand.java | 32 +
.../memcached/commands/PrependCommand.java | 79 +
.../memcached/commands/PrependQCommand.java | 13 +
.../memcached/commands/QuitCommand.java | 47 +
.../memcached/commands/QuitQCommand.java | 13 +
.../memcached/commands/ReplaceCommand.java | 93 +
.../memcached/commands/ReplaceQCommand.java | 13 +
.../internal/memcached/commands/SetCommand.java | 81 +
.../memcached/commands/SetQCommand.java | 14 +
.../memcached/commands/StatsCommand.java | 41 +
.../memcached/commands/StorageCommand.java | 209 +
.../memcached/commands/TouchCommand.java | 95 +
.../memcached/commands/VerbosityCommand.java | 39 +
.../memcached/commands/VersionCommand.java | 40 +
.../modules/util/RegionConfiguration.java | 284 +
.../gemfire/internal/net/SocketUtils.java | 68 +
.../com/gemstone/gemfire/internal/package.html | 29 +
.../internal/process/AttachProcessUtils.java | 31 +
...usterConfigurationNotAvailableException.java | 15 +
.../process/ConnectionFailedException.java | 41 +
.../internal/process/ControlFileWatchdog.java | 142 +
.../process/ControlNotificationHandler.java | 16 +
.../internal/process/ControllableProcess.java | 116 +
.../process/FileAlreadyExistsException.java | 43 +
.../process/FileControllerParameters.java | 17 +
.../internal/process/FileProcessController.java | 125 +
.../process/LocalProcessController.java | 469 +
.../internal/process/LocalProcessLauncher.java | 119 +
.../process/MBeanControllerParameters.java | 21 +
.../process/MBeanInvocationFailedException.java | 41 +
.../process/MBeanProcessController.java | 375 +
.../internal/process/NativeProcessUtils.java | 27 +
.../process/PidUnavailableException.java | 42 +
.../internal/process/ProcessController.java | 45 +
.../process/ProcessControllerFactory.java | 134 +
.../process/ProcessControllerParameters.java | 14 +
.../process/ProcessLauncherContext.java | 167 +
.../internal/process/ProcessStreamReader.java | 175 +
.../ProcessTerminatedAbnormallyException.java | 82 +
.../gemfire/internal/process/ProcessType.java | 53 +
.../gemfire/internal/process/ProcessUtils.java | 145 +
.../gemfire/internal/process/StartupStatus.java | 47 +
.../internal/process/StartupStatusListener.java | 14 +
.../UnableToControlProcessException.java | 35 +
.../AbstractSignalNotificationHandler.java | 171 +
.../gemfire/internal/process/signal/Signal.java | 120 +
.../internal/process/signal/SignalEvent.java | 45 +
.../internal/process/signal/SignalListener.java | 26 +
.../internal/process/signal/SignalType.java | 36 +
.../internal/security/AuthorizeRequest.java | 747 +
.../internal/security/AuthorizeRequestPP.java | 240 +
.../security/FilterPostAuthorization.java | 226 +
.../security/FilterPreAuthorization.java | 151 +
.../internal/security/ObjectWithAuthz.java | 60 +
.../gemfire/internal/security/package.html | 9 +
.../internal/sequencelog/EntryLogger.java | 196 +
.../gemfire/internal/sequencelog/GraphType.java | 51 +
.../internal/sequencelog/MembershipLogger.java | 38 +
.../internal/sequencelog/MessageLogger.java | 31 +
.../internal/sequencelog/RegionLogger.java | 79 +
.../internal/sequencelog/SequenceLogger.java | 54 +
.../sequencelog/SequenceLoggerImpl.java | 140 +
.../internal/sequencelog/Transition.java | 79 +
.../gemfire/internal/sequencelog/io/Filter.java | 23 +
.../sequencelog/io/GemfireLogConverter.java | 242 +
.../internal/sequencelog/io/GraphReader.java | 81 +
.../sequencelog/io/InputStreamReader.java | 94 +
.../sequencelog/io/OutputStreamAppender.java | 108 +
.../internal/sequencelog/model/Edge.java | 102 +
.../internal/sequencelog/model/Graph.java | 96 +
.../internal/sequencelog/model/GraphID.java | 86 +
.../sequencelog/model/GraphReaderCallback.java | 28 +
.../internal/sequencelog/model/GraphSet.java | 156 +
.../internal/sequencelog/model/Vertex.java | 115 +
.../visualization/text/TextDisplay.java | 76 +
.../gemfire/internal/shared/NativeCalls.java | 626 +
.../internal/shared/NativeCallsJNAImpl.java | 1172 ++
.../internal/shared/NativeErrorException.java | 34 +
.../gemfire/internal/shared/OSType.java | 84 +
.../internal/shared/StringPrintWriter.java | 227 +
.../internal/shared/TCPSocketOptions.java | 39 +
.../internal/size/CachingSingleObjectSizer.java | 42 +
.../size/InstrumentationSingleObjectSizer.java | 33 +
.../gemfire/internal/size/ObjectGraphSizer.java | 250 +
.../gemfire/internal/size/ObjectTraverser.java | 203 +
.../internal/size/ReflectionObjectSizer.java | 85 +
.../size/ReflectionSingleObjectSizer.java | 174 +
.../internal/size/SingleObjectSizer.java | 12 +
.../internal/size/SizeClassOnceObjectSizer.java | 87 +
.../gemfire/internal/size/SizeOfUtil0.java | 24 +
.../internal/size/WellKnownClassSizer.java | 51 +
.../internal/statistics/CounterMonitor.java | 49 +
.../internal/statistics/GaugeMonitor.java | 44 +
.../statistics/IgnoreResourceException.java | 56 +
.../MapBasedStatisticsNotification.java | 79 +
.../internal/statistics/ResourceInstance.java | 111 +
.../internal/statistics/ResourceType.java | 61 +
.../internal/statistics/SampleCollector.java | 779 ++
.../internal/statistics/SampleHandler.java | 63 +
.../internal/statistics/SimpleStatisticId.java | 58 +
.../statistics/StatArchiveDescriptor.java | 125 +
.../internal/statistics/StatArchiveHandler.java | 667 +
.../statistics/StatArchiveHandlerConfig.java | 58 +
.../internal/statistics/StatMonitorHandler.java | 327 +
.../internal/statistics/StatisticId.java | 30 +
.../statistics/StatisticNotFoundException.java | 53 +
.../internal/statistics/StatisticsListener.java | 18 +
.../internal/statistics/StatisticsMonitor.java | 157 +
.../statistics/StatisticsNotification.java | 57 +
.../internal/statistics/StatisticsSampler.java | 48 +
.../internal/statistics/ValueMonitor.java | 124 +
.../gemfire/internal/statistics/package.html | 15 +
.../stats50/Atomic50StatisticsImpl.java | 488 +
.../gemfire/internal/stats50/VMStats50.java | 694 +
.../gemfire/internal/tcp/BaseMsgStreamer.java | 56 +
.../gemstone/gemfire/internal/tcp/Buffers.java | 161 +
.../internal/tcp/ByteBufferInputStream.java | 347 +
.../gemfire/internal/tcp/ConnectExceptions.java | 84 +
.../gemfire/internal/tcp/Connection.java | 4096 ++++++
.../internal/tcp/ConnectionException.java | 29 +
.../gemfire/internal/tcp/ConnectionTable.java | 1322 ++
.../gemfire/internal/tcp/DirectReplySender.java | 96 +
.../tcp/ImmutableByteBufferInputStream.java | 73 +
.../internal/tcp/MemberShunnedException.java | 40 +
.../gemfire/internal/tcp/MsgDestreamer.java | 527 +
.../gemfire/internal/tcp/MsgIdGenerator.java | 45 +
.../gemfire/internal/tcp/MsgOutputStream.java | 418 +
.../gemfire/internal/tcp/MsgReader.java | 120 +
.../gemfire/internal/tcp/MsgStreamer.java | 951 ++
.../gemfire/internal/tcp/MsgStreamerList.java | 150 +
.../gemfire/internal/tcp/NIOMsgReader.java | 104 +
.../gemfire/internal/tcp/OioMsgReader.java | 34 +
.../internal/tcp/ReenteredConnectException.java | 42 +
.../gemfire/internal/tcp/ServerDelegate.java | 37 +
.../com/gemstone/gemfire/internal/tcp/Stub.java | 155 +
.../gemfire/internal/tcp/TCPConduit.java | 1393 ++
.../tcp/VersionedByteBufferInputStream.java | 70 +
.../internal/tcp/VersionedMsgStreamer.java | 51 +
.../gemstone/gemfire/internal/tcp/package.html | 122 +
.../gfsh/aggregator/AggregateFunction.java | 67 +
.../tools/gfsh/aggregator/AggregateResults.java | 126 +
.../aggregator/AggregatorPartitionFunction.java | 54 +
.../tools/gfsh/app/CommandExecutable.java | 8 +
.../gemfire/internal/tools/gfsh/app/Gfsh.java | 2027 +++
.../internal/tools/gfsh/app/GfshVersion.java | 455 +
.../internal/tools/gfsh/app/Nextable.java | 8 +
.../tools/gfsh/app/ServerExecutable.java | 11 +
.../app/aggregator/AggregateFunctionTask.java | 62 +
.../tools/gfsh/app/aggregator/Aggregator.java | 549 +
.../app/aggregator/AggregatorException.java | 50 +
.../gfsh/app/aggregator/AggregatorPeer.java | 254 +
.../functions/util/LocalRegionInfoFunction.java | 235 +
.../functions/util/RegionCreateFunction.java | 81 +
.../functions/util/RegionDestroyFunction.java | 86 +
.../tools/gfsh/app/cache/CacheBase.java | 178 +
.../gfsh/app/cache/InstantiatorClassLoader.java | 101 +
.../tools/gfsh/app/cache/data/GenericMap.java | 196 +
.../gfsh/app/cache/data/GenericMessage.java | 807 ++
.../app/cache/data/InvalidTypeException.java | 28 +
.../tools/gfsh/app/cache/data/ListMap.java | 197 +
.../gfsh/app/cache/data/ListMapMessage.java | 615 +
.../tools/gfsh/app/cache/data/ListMessage.java | 594 +
.../tools/gfsh/app/cache/data/Listable.java | 45 +
.../tools/gfsh/app/cache/data/MapMessage.java | 629 +
.../tools/gfsh/app/cache/data/Mappable.java | 50 +
.../tools/gfsh/app/cache/index/EntryMap.java | 80 +
.../tools/gfsh/app/cache/index/IndexInfo.java | 52 +
.../tools/gfsh/app/cache/index/Indexer.java | 13 +
.../gfsh/app/cache/index/IndexerManager.java | 32 +
.../gfsh/app/cache/index/LookupService.java | 352 +
.../app/cache/index/LookupServiceException.java | 64 +
.../gfsh/app/cache/index/task/ForceGCTask.java | 32 +
.../app/cache/index/task/IndexInfoTask.java | 131 +
.../app/cache/index/task/QuerySizeTask.java | 134 +
.../gfsh/app/cache/index/task/QueryTask.java | 323 +
.../tools/gfsh/app/command/CommandClient.java | 417 +
.../gfsh/app/command/CommandException.java | 31 +
.../app/command/CommandResultsListener.java | 15 +
.../tools/gfsh/app/command/task/EchoTask.java | 63 +
.../task/PartitionedRegionAttributeTask.java | 205 +
.../gfsh/app/command/task/QueryResults.java | 123 +
.../tools/gfsh/app/command/task/QueryTask.java | 522 +
.../task/RefreshAggregatorRegionTask.java | 53 +
.../gfsh/app/command/task/RegionClearTask.java | 85 +
.../gfsh/app/command/task/RegionCreateTask.java | 162 +
.../app/command/task/RegionDestroyTask.java | 97 +
.../gfsh/app/command/task/RegionPathTask.java | 156 +
.../gfsh/app/command/task/RegionSizeTask.java | 70 +
.../gfsh/app/command/task/data/MemberInfo.java | 79 +
.../task/data/PartitionAttributeInfo.java | 124 +
.../command/task/data/RegionAttributeInfo.java | 286 +
.../internal/tools/gfsh/app/commands/bcp.java | 527 +
.../internal/tools/gfsh/app/commands/cd.java | 79 +
.../tools/gfsh/app/commands/classloader.java | 323 +
.../internal/tools/gfsh/app/commands/clear.java | 197 +
.../tools/gfsh/app/commands/connect.java | 124 +
.../internal/tools/gfsh/app/commands/db.java | 312 +
.../internal/tools/gfsh/app/commands/debug.java | 48 +
.../tools/gfsh/app/commands/deploy.java | 271 +
.../internal/tools/gfsh/app/commands/echo.java | 59 +
.../internal/tools/gfsh/app/commands/fetch.java | 48 +
.../internal/tools/gfsh/app/commands/gc.java | 93 +
.../internal/tools/gfsh/app/commands/get.java | 143 +
.../internal/tools/gfsh/app/commands/help.java | 40 +
.../internal/tools/gfsh/app/commands/index.java | 395 +
.../internal/tools/gfsh/app/commands/key.java | 67 +
.../internal/tools/gfsh/app/commands/local.java | 101 +
.../internal/tools/gfsh/app/commands/ls.java | 584 +
.../internal/tools/gfsh/app/commands/mkdir.java | 253 +
.../internal/tools/gfsh/app/commands/next.java | 63 +
.../tools/gfsh/app/commands/optional/look.java | 166 +
.../tools/gfsh/app/commands/optional/perf.java | 150 +
.../internal/tools/gfsh/app/commands/pr.java | 209 +
.../tools/gfsh/app/commands/property.java | 85 +
.../internal/tools/gfsh/app/commands/put.java | 490 +
.../internal/tools/gfsh/app/commands/pwd.java | 37 +
.../tools/gfsh/app/commands/rebalance.java | 186 +
.../tools/gfsh/app/commands/refresh.java | 67 +
.../internal/tools/gfsh/app/commands/rm.java | 175 +
.../internal/tools/gfsh/app/commands/rmdir.java | 249 +
.../tools/gfsh/app/commands/select.java | 139 +
.../internal/tools/gfsh/app/commands/show.java | 240 +
.../internal/tools/gfsh/app/commands/size.java | 281 +
.../internal/tools/gfsh/app/commands/value.java | 48 +
.../internal/tools/gfsh/app/commands/which.java | 189 +
.../internal/tools/gfsh/app/commands/zone.java | 49 +
.../tools/gfsh/app/function/GfshData.java | 86 +
.../tools/gfsh/app/function/GfshFunction.java | 149 +
.../tools/gfsh/app/function/command/clear.java | 95 +
.../tools/gfsh/app/function/command/deploy.java | 111 +
.../tools/gfsh/app/function/command/gc.java | 49 +
.../tools/gfsh/app/function/command/index.java | 199 +
.../tools/gfsh/app/function/command/ls.java | 80 +
.../tools/gfsh/app/function/command/pr.java | 118 +
.../gfsh/app/function/command/rebalance.java | 129 +
.../tools/gfsh/app/function/command/rm.java | 43 +
.../tools/gfsh/app/function/command/which.java | 159 +
.../tools/gfsh/app/misc/util/ClassFinder.java | 209 +
.../gfsh/app/misc/util/DataSerializerEx.java | 98 +
.../app/misc/util/QueueDispatcherListener.java | 11 +
.../app/misc/util/QueueDispatcherThread.java | 87 +
.../gfsh/app/misc/util/ReflectionUtil.java | 303 +
.../tools/gfsh/app/misc/util/StringUtil.java | 142 +
.../app/misc/util/SystemClassPathManager.java | 171 +
.../gfsh/app/pogo/InvalidKeyException.java | 34 +
.../internal/tools/gfsh/app/pogo/KeyType.java | 96 +
.../tools/gfsh/app/pogo/KeyTypeManager.java | 199 +
.../internal/tools/gfsh/app/pogo/MapLite.java | 1136 ++
.../tools/gfsh/app/pogo/MapLiteSerializer.java | 338 +
.../internal/tools/gfsh/app/util/DBUtil.java | 1094 ++
.../tools/gfsh/app/util/DBUtilException.java | 48 +
.../tools/gfsh/app/util/GfshResultsBag.java | 600 +
.../tools/gfsh/app/util/ObjectUtil.java | 164 +
.../tools/gfsh/app/util/OutputUtil.java | 255 +
.../internal/tools/gfsh/app/util/PrintUtil.java | 1683 +++
.../tools/gfsh/app/util/SimplePrintUtil.java | 1366 ++
.../tools/gfsh/command/AbstractCommandTask.java | 136 +
.../gfsh/command/CommandExecLoaderListener.java | 96 +
.../tools/gfsh/command/CommandResults.java | 119 +
.../tools/gfsh/command/CommandTask.java | 23 +
.../internal/tools/gfsh/util/RegionUtil.java | 829 ++
.../internal/util/AbortableTaskService.java | 165 +
.../gemfire/internal/util/ArrayUtils.java | 238 +
.../gemfire/internal/util/BlobHelper.java | 166 +
.../gemfire/internal/util/Breadcrumbs.java | 256 +
.../gemstone/gemfire/internal/util/Bytes.java | 250 +
.../gemfire/internal/util/Callable.java | 39 +
.../gemfire/internal/util/CollectionUtils.java | 273 +
.../gemfire/internal/util/DebuggerSupport.java | 55 +
.../gemfire/internal/util/DelayedAction.java | 56 +
.../com/gemstone/gemfire/internal/util/Hex.java | 48 +
.../gemstone/gemfire/internal/util/IOUtils.java | 338 +
.../internal/util/JavaCommandBuilder.java | 114 +
.../gemfire/internal/util/LogFileUtils.java | 169 +
.../internal/util/ObjectIntProcedure.java | 14 +
.../gemfire/internal/util/ObjectProcedure.java | 14 +
.../gemfire/internal/util/PasswordUtil.java | 124 +
.../gemfire/internal/util/PluckStacks.java | 492 +
.../gemfire/internal/util/PrimeFinder.java | 159 +
.../gemfire/internal/util/StopWatch.java | 71 +
.../internal/util/SunAPINotFoundException.java | 38 +
.../gemfire/internal/util/TransformUtils.java | 123 +
.../gemfire/internal/util/Transformer.java | 24 +
.../gemfire/internal/util/Versionable.java | 28 +
.../internal/util/VersionedArrayList.java | 338 +
.../util/concurrent/CopyOnWriteHashMap.java | 160 +
.../util/concurrent/CopyOnWriteWeakHashMap.java | 77 +
.../CustomEntryConcurrentHashMap.java | 2588 ++++
.../internal/util/concurrent/FutureResult.java | 84 +
.../util/concurrent/ReentrantSemaphore.java | 152 +
.../util/concurrent/SemaphoreReadWriteLock.java | 208 +
.../util/concurrent/StoppableCondition.java | 104 +
.../concurrent/StoppableCountDownLatch.java | 89 +
.../concurrent/StoppableCountDownOrUpLatch.java | 202 +
.../concurrent/StoppableNonReentrantLock.java | 83 +
.../util/concurrent/StoppableReadWriteLock.java | 19 +
.../util/concurrent/StoppableReentrantLock.java | 122 +
.../StoppableReentrantReadWriteLock.java | 235 +
.../internal/util/doc-files/call-stack.fig | 34 +
.../internal/util/doc-files/class-loaders.fig | 49 +
.../lang/AttachAPINotFoundException.java | 59 +
.../com/gemstone/gemfire/lang/Identifiable.java | 32 +
.../management/AlreadyRunningException.java | 37 +
.../management/AsyncEventQueueMXBean.java | 110 +
.../gemfire/management/CacheServerMXBean.java | 389 +
.../gemfire/management/ClientHealthStatus.java | 338 +
.../gemfire/management/ClientQueueDetail.java | 156 +
.../DependenciesNotFoundException.java | 50 +
.../gemfire/management/DiskBackupResult.java | 58 +
.../gemfire/management/DiskBackupStatus.java | 65 +
.../gemfire/management/DiskMetrics.java | 116 +
.../gemfire/management/DiskStoreMXBean.java | 204 +
.../DistributedLockServiceMXBean.java | 58 +
.../management/DistributedRegionMXBean.java | 298 +
.../management/DistributedSystemMXBean.java | 680 +
.../management/EvictionAttributesData.java | 96 +
.../FixedPartitionAttributesData.java | 78 +
.../management/GatewayReceiverMXBean.java | 203 +
.../gemfire/management/GatewaySenderMXBean.java | 241 +
.../gemfire/management/GemFireProperties.java | 1564 +++
.../gemfire/management/JMXNotificationType.java | 206 +
.../management/JMXNotificationUserData.java | 44 +
.../gemstone/gemfire/management/JVMMetrics.java | 136 +
.../gemfire/management/LocatorMXBean.java | 68 +
.../gemfire/management/LockServiceMXBean.java | 77 +
.../gemfire/management/ManagementException.java | 80 +
.../gemfire/management/ManagementService.java | 418 +
.../gemfire/management/ManagerMXBean.java | 75 +
.../gemfire/management/MemberMXBean.java | 810 ++
.../management/MembershipAttributesData.java | 88 +
.../gemfire/management/NetworkMetrics.java | 51 +
.../gemstone/gemfire/management/OSMetrics.java | 215 +
.../management/PartitionAttributesData.java | 131 +
.../management/PersistentMemberDetails.java | 55 +
.../management/RegionAttributesData.java | 408 +
.../gemfire/management/RegionMXBean.java | 340 +
.../gemfire/management/ServerLoadData.java | 78 +
.../gemfire/management/cli/CliMetaData.java | 96 +
.../cli/CommandProcessingException.java | 117 +
.../gemfire/management/cli/CommandService.java | 197 +
.../management/cli/CommandServiceException.java | 60 +
.../management/cli/CommandStatement.java | 50 +
.../gemfire/management/cli/ConverterHint.java | 44 +
.../gemstone/gemfire/management/cli/Result.java | 121 +
.../gemfire/management/cli/package.html | 7 +
.../management/internal/AlertDetails.java | 153 +
.../management/internal/ArrayConverter.java | 74 +
.../internal/BaseManagementService.java | 176 +
.../internal/CollectionConverter.java | 102 +
.../management/internal/CompositeConverter.java | 138 +
.../management/internal/EnumConverter.java | 42 +
.../management/internal/FederatingManager.java | 618 +
.../internal/FederationComponent.java | 298 +
.../management/internal/FilterChain.java | 51 +
.../management/internal/FilterParam.java | 63 +
.../management/internal/IdentityConverter.java | 39 +
.../management/internal/JettyHelper.java | 218 +
.../management/internal/JmxManagerAdvisee.java | 144 +
.../management/internal/JmxManagerAdvisor.java | 376 +
.../management/internal/JmxManagerLocator.java | 232 +
.../internal/JmxManagerLocatorRequest.java | 121 +
.../internal/JmxManagerLocatorResponse.java | 96 +
.../management/internal/LocalFilterChain.java | 55 +
.../management/internal/LocalManager.java | 458 +
.../management/internal/MBeanJMXAdapter.java | 613 +
.../management/internal/MBeanProxyFactory.java | 349 +
.../internal/MBeanProxyInfoRepository.java | 163 +
.../internal/MBeanProxyInvocationHandler.java | 537 +
.../internal/MXBeanProxyInvocationHandler.java | 252 +
.../management/internal/ManagementAgent.java | 573 +
.../internal/ManagementCacheListener.java | 114 +
.../internal/ManagementConstants.java | 179 +
.../management/internal/ManagementFunction.java | 165 +
.../internal/ManagementMembershipListener.java | 86 +
.../internal/ManagementResourceRepo.java | 254 +
.../management/internal/ManagementStrings.java | 146 +
.../gemfire/management/internal/Manager.java | 81 +
.../internal/ManagerStartupMessage.java | 67 +
.../management/internal/MemberMessenger.java | 97 +
.../internal/MonitoringRegionCacheListener.java | 108 +
.../internal/NotificationBroadCasterProxy.java | 30 +
.../internal/NotificationCacheListener.java | 112 +
.../management/internal/NotificationHub.java | 198 +
.../internal/NotificationHubClient.java | 69 +
.../management/internal/NotificationKey.java | 58 +
.../gemfire/management/internal/OpenMethod.java | 182 +
.../management/internal/OpenTypeConverter.java | 1010 ++
.../management/internal/OpenTypeUtil.java | 109 +
.../gemfire/management/internal/ProxyInfo.java | 75 +
.../management/internal/ProxyInterface.java | 32 +
.../management/internal/ProxyListener.java | 129 +
.../management/internal/RemoteFilterChain.java | 87 +
.../gemfire/management/internal/RestAgent.java | 239 +
.../gemfire/management/internal/SSLUtil.java | 66 +
.../management/internal/StringBasedFilter.java | 114 +
.../internal/SystemManagementService.java | 829 ++
.../management/internal/TableConverter.java | 94 +
.../internal/beans/AggregateHandler.java | 84 +
.../internal/beans/AsyncEventQueueMBean.java | 105 +
.../beans/AsyncEventQueueMBeanBridge.java | 113 +
.../internal/beans/BeanUtilFuncs.java | 385 +
.../internal/beans/CacheServerBridge.java | 762 +
.../internal/beans/CacheServerMBean.java | 309 +
.../internal/beans/DiskRegionBridge.java | 130 +
.../internal/beans/DiskStoreMBean.java | 174 +
.../internal/beans/DiskStoreMBeanBridge.java | 280 +
.../beans/DistributedLockServiceBridge.java | 219 +
.../beans/DistributedLockServiceMBean.java | 60 +
.../internal/beans/DistributedRegionBridge.java | 671 +
.../internal/beans/DistributedRegionMBean.java | 318 +
.../internal/beans/DistributedSystemBridge.java | 1853 +++
.../internal/beans/DistributedSystemMBean.java | 448 +
.../internal/beans/GatewayReceiverMBean.java | 212 +
.../beans/GatewayReceiverMBeanBridge.java | 216 +
.../internal/beans/GatewaySenderMBean.java | 218 +
.../beans/GatewaySenderMBeanBridge.java | 291 +
.../management/internal/beans/LocatorMBean.java | 71 +
.../internal/beans/LocatorMBeanBridge.java | 149 +
.../internal/beans/LockServiceMBean.java | 86 +
.../internal/beans/LockServiceMBeanBridge.java | 121 +
.../internal/beans/MBeanAggregator.java | 427 +
.../internal/beans/ManagementAdapter.java | 1122 ++
.../internal/beans/ManagementListener.java | 207 +
.../management/internal/beans/ManagerMBean.java | 63 +
.../internal/beans/ManagerMBeanBridge.java | 72 +
.../management/internal/beans/MemberMBean.java | 645 +
.../internal/beans/MemberMBeanBridge.java | 1878 +++
.../internal/beans/MetricsCalculator.java | 130 +
.../internal/beans/PartitionedRegionBridge.java | 293 +
.../internal/beans/QueryDataFunction.java | 605 +
.../management/internal/beans/RegionMBean.java | 310 +
.../internal/beans/RegionMBeanBridge.java | 588 +
.../beans/RegionMBeanCompositeDataFactory.java | 220 +
.../internal/beans/SequenceNumber.java | 42 +
.../management/internal/beans/ServerBridge.java | 175 +
.../stats/AggregateRegionStatsMonitor.java | 290 +
.../internal/beans/stats/GCStatsMonitor.java | 86 +
.../GatewayReceiverClusterStatsMonitor.java | 72 +
.../stats/GatewaySenderClusterStatsMonitor.java | 85 +
.../stats/IntegerStatsDeltaAggregator.java | 84 +
.../beans/stats/LongStatsDeltaAggregator.java | 83 +
.../internal/beans/stats/MBeanStatsMonitor.java | 112 +
.../beans/stats/MemberClusterStatsMonitor.java | 233 +
.../beans/stats/MemberLevelDiskMonitor.java | 303 +
.../beans/stats/RegionClusterStatsMonitor.java | 460 +
.../beans/stats/ServerClusterStatsMonitor.java | 78 +
.../internal/beans/stats/StatType.java | 21 +
.../internal/beans/stats/StatsAggregator.java | 297 +
.../beans/stats/StatsAverageLatency.java | 47 +
.../internal/beans/stats/StatsKey.java | 348 +
.../internal/beans/stats/StatsLatency.java | 62 +
.../internal/beans/stats/StatsRate.java | 84 +
.../internal/beans/stats/VMStatsMonitor.java | 121 +
.../cli/AbstractCliAroundInterceptor.java | 125 +
.../internal/cli/CliAroundInterceptor.java | 28 +
.../management/internal/cli/CliUtil.java | 750 +
.../management/internal/cli/CommandManager.java | 624 +
.../management/internal/cli/CommandRequest.java | 125 +
.../internal/cli/CommandResponse.java | 342 +
.../internal/cli/CommandResponseBuilder.java | 80 +
.../internal/cli/CommandResponseWriter.java | 58 +
.../internal/cli/GfshParseResult.java | 94 +
.../management/internal/cli/GfshParser.java | 1513 ++
.../management/internal/cli/Launcher.java | 303 +
.../management/internal/cli/LogWrapper.java | 432 +
.../internal/cli/MultipleValueAdapter.java | 30 +
.../internal/cli/MultipleValueConverter.java | 51 +
.../internal/cli/annotation/CliArgument.java | 80 +
.../cli/commands/AbstractCommandsSupport.java | 189 +
.../internal/cli/commands/ClientCommands.java | 320 +
.../internal/cli/commands/ConfigCommands.java | 476 +
.../CreateAlterDestroyRegionCommands.java | 1174 ++
.../internal/cli/commands/DataCommands.java | 1391 ++
.../internal/cli/commands/DeployCommands.java | 337 +
.../cli/commands/DiskStoreCommands.java | 1402 ++
.../cli/commands/DurableClientCommands.java | 422 +
...ExportImportSharedConfigurationCommands.java | 283 +
.../internal/cli/commands/FunctionCommands.java | 634 +
.../internal/cli/commands/GfshHelpCommands.java | 98 +
.../internal/cli/commands/IndexCommands.java | 666 +
.../cli/commands/LauncherLifecycleCommands.java | 2701 ++++
.../internal/cli/commands/MemberCommands.java | 190 +
.../cli/commands/MiscellaneousCommands.java | 2089 +++
.../internal/cli/commands/PDXCommands.java | 270 +
.../internal/cli/commands/QueueCommands.java | 273 +
.../internal/cli/commands/RegionCommands.java | 485 +
.../internal/cli/commands/ShellCommands.java | 1063 ++
.../internal/cli/commands/StatusCommands.java | 83 +
.../internal/cli/commands/WanCommands.java | 1272 ++
.../cli/commands/dto/RegionAttributesInfo.java | 155 +
.../cli/commands/dto/RegionDetails.java | 222 +
.../cli/commands/dto/RegionMemberDetails.java | 190 +
.../cli/converters/BooleanConverter.java | 46 +
.../ClusterMemberIdNameConverter.java | 72 +
.../converters/ConnectionEndpointConverter.java | 136 +
.../internal/cli/converters/DirConverter.java | 166 +
.../cli/converters/DirPathConverter.java | 135 +
.../cli/converters/DiskStoreNameConverter.java | 85 +
.../internal/cli/converters/EnumConverter.java | 59 +
.../cli/converters/FilePathConverter.java | 128 +
.../cli/converters/FilePathStringConverter.java | 124 +
.../converters/GatewayReceiverIdsConverter.java | 64 +
.../converters/GatewaySenderIdConverter.java | 73 +
.../internal/cli/converters/HelpConverter.java | 65 +
.../cli/converters/HintTopicConverter.java | 66 +
.../cli/converters/IndexTypeConverter.java | 48 +
.../LocatorDiscoveryConfigConverter.java | 72 +
.../cli/converters/LocatorIdNameConverter.java | 71 +
.../cli/converters/LogLevelConverter.java | 56 +
.../cli/converters/MemberGroupConverter.java | 75 +
.../cli/converters/MemberIdNameConverter.java | 74 +
.../cli/converters/RegionPathConverter.java | 92 +
.../cli/converters/StringArrayConverter.java | 51 +
.../cli/converters/StringListConverter.java | 52 +
.../cli/domain/AsyncEventQueueDetails.java | 68 +
.../internal/cli/domain/CacheServerInfo.java | 63 +
.../cli/domain/ConnectToLocatorResult.java | 48 +
.../internal/cli/domain/DataCommandRequest.java | 205 +
.../internal/cli/domain/DataCommandResult.java | 895 ++
.../internal/cli/domain/DiskStoreDetails.java | 682 +
.../cli/domain/DurableCqNamesResult.java | 55 +
.../cli/domain/EvictionAttributesInfo.java | 91 +
.../domain/FixedPartitionAttributesInfo.java | 61 +
.../internal/cli/domain/IndexDetails.java | 322 +
.../internal/cli/domain/IndexInfo.java | 94 +
.../cli/domain/MemberConfigurationInfo.java | 109 +
.../internal/cli/domain/MemberInformation.java | 187 +
.../internal/cli/domain/MemberResult.java | 105 +
.../cli/domain/PartitionAttributesInfo.java | 167 +
.../cli/domain/RegionAttributesInfo.java | 455 +
.../internal/cli/domain/RegionDescription.java | 238 +
.../cli/domain/RegionDescriptionPerMember.java | 128 +
.../internal/cli/domain/RegionInformation.java | 149 +
.../cli/domain/StackTracesPerMember.java | 30 +
.../cli/domain/SubscriptionQueueSizeResult.java | 42 +
.../cli/exceptions/CliCommandException.java | 57 +
.../exceptions/CliCommandInvalidException.java | 25 +
.../CliCommandMultiModeOptionException.java | 32 +
.../CliCommandNotAvailableException.java | 25 +
.../exceptions/CliCommandOptionException.java | 45 +
...CommandOptionHasMultipleValuesException.java | 25 +
.../CliCommandOptionInvalidException.java | 26 +
.../CliCommandOptionMissingException.java | 27 +
.../CliCommandOptionNotApplicableException.java | 28 +
...liCommandOptionValueConversionException.java | 28 +
.../CliCommandOptionValueException.java | 34 +
.../CliCommandOptionValueMissingException.java | 28 +
.../internal/cli/exceptions/CliException.java | 13 +
.../exceptions/CreateSubregionException.java | 33 +
.../cli/exceptions/ExceptionGenerator.java | 38 +
.../cli/exceptions/ExceptionHandler.java | 98 +
.../cli/exceptions/IndexNotFoundException.java | 19 +
.../functions/AlterRuntimeConfigFunction.java | 87 +
.../cli/functions/ChangeLogLevelFunction.java | 88 +
.../cli/functions/CliFunctionResult.java | 239 +
.../functions/CloseDurableClientFunction.java | 68 +
.../cli/functions/CloseDurableCqFunction.java | 70 +
.../cli/functions/ContunuousQueryFunction.java | 144 +
.../CreateAsyncEventQueueFunction.java | 174 +
.../functions/CreateDefinedIndexesFunction.java | 75 +
.../cli/functions/CreateDiskStoreFunction.java | 82 +
.../cli/functions/CreateIndexFunction.java | 91 +
.../cli/functions/DataCommandFunction.java | 1039 ++
.../internal/cli/functions/DeployFunction.java | 106 +
.../functions/DescribeDiskStoreFunction.java | 249 +
.../cli/functions/DestroyDiskStoreFunction.java | 94 +
.../cli/functions/DestroyIndexFunction.java | 113 +
.../cli/functions/ExportConfigFunction.java | 123 +
.../cli/functions/ExportDataFunction.java | 65 +
.../ExportSharedConfigurationFunction.java | 63 +
.../FetchRegionAttributesFunction.java | 136 +
.../FetchSharedConfigurationStatusFunction.java | 45 +
.../functions/GarbageCollectionFunction.java | 84 +
.../GatewayReceiverCreateFunction.java | 217 +
.../functions/GatewayReceiverFunctionArgs.java | 71 +
.../functions/GatewaySenderCreateFunction.java | 210 +
.../functions/GatewaySenderFunctionArgs.java | 135 +
.../GetMemberConfigInformationFunction.java | 204 +
.../functions/GetMemberInformationFunction.java | 140 +
.../functions/GetRegionDescriptionFunction.java | 54 +
.../cli/functions/GetRegionsFunction.java | 67 +
.../cli/functions/GetStackTracesFunction.java | 45 +
.../GetSubscriptionQueueSizeFunction.java | 92 +
.../cli/functions/ImportDataFunction.java | 61 +
...ortSharedConfigurationArtifactsFunction.java | 68 +
.../functions/ListAsyncEventQueuesFunction.java | 99 +
.../cli/functions/ListDeployedFunction.java | 97 +
.../cli/functions/ListDiskStoresFunction.java | 75 +
.../functions/ListDurableCqNamesFunction.java | 91 +
.../cli/functions/ListFunctionFunction.java | 106 +
.../cli/functions/ListIndexFunction.java | 66 +
.../LoadSharedConfigurationFunction.java | 56 +
.../internal/cli/functions/LogFileFunction.java | 289 +
.../cli/functions/MemberRegionFunction.java | 76 +
.../cli/functions/MembersForRegionFunction.java | 88 +
.../internal/cli/functions/NetstatFunction.java | 264 +
.../cli/functions/RebalanceFunction.java | 115 +
.../cli/functions/RegionAlterFunction.java | 336 +
.../cli/functions/RegionCreateFunction.java | 397 +
.../cli/functions/RegionDestroyFunction.java | 77 +
.../cli/functions/RegionFunctionArgs.java | 725 +
.../cli/functions/ShutDownFunction.java | 78 +
.../cli/functions/UndeployFunction.java | 124 +
.../cli/functions/UnregisterFunction.java | 67 +
.../cli/functions/UserFunctionExecution.java | 219 +
.../management/internal/cli/help/CliTopic.java | 123 +
.../internal/cli/help/format/Block.java | 37 +
.../internal/cli/help/format/DataNode.java | 43 +
.../internal/cli/help/format/Help.java | 39 +
.../internal/cli/help/format/NewHelp.java | 47 +
.../internal/cli/help/format/Row.java | 22 +
.../internal/cli/help/utils/FormatOutput.java | 19 +
.../internal/cli/help/utils/HelpUtils.java | 410 +
.../internal/cli/i18n/CliStrings.java | 2202 +++
.../internal/cli/json/GfJsonArray.java | 234 +
.../internal/cli/json/GfJsonException.java | 29 +
.../internal/cli/json/GfJsonObject.java | 385 +
.../management/internal/cli/json/TypedJson.java | 812 ++
.../internal/cli/modes/CommandModes.java | 139 +
.../cli/multistep/CLIMultiStepHelper.java | 391 +
.../internal/cli/multistep/CLIRemoteStep.java | 19 +
.../internal/cli/multistep/CLIStep.java | 18 +
.../cli/multistep/CLIStepExecption.java | 29 +
.../cli/multistep/MultiStepCommand.java | 18 +
.../internal/cli/parser/Argument.java | 68 +
.../internal/cli/parser/AvailabilityTarget.java | 99 +
.../internal/cli/parser/CommandTarget.java | 180 +
.../internal/cli/parser/GfshMethodTarget.java | 126 +
.../internal/cli/parser/GfshOptionParser.java | 32 +
.../internal/cli/parser/MethodParameter.java | 34 +
.../management/internal/cli/parser/Option.java | 215 +
.../internal/cli/parser/OptionSet.java | 124 +
.../internal/cli/parser/Parameter.java | 111 +
.../internal/cli/parser/ParserUtils.java | 182 +
.../internal/cli/parser/SyntaxConstants.java | 29 +
.../cli/parser/jopt/JoptOptionParser.java | 290 +
.../preprocessor/EnclosingCharacters.java | 27 +
.../cli/parser/preprocessor/Preprocessor.java | 132 +
.../parser/preprocessor/PreprocessorUtils.java | 329 +
.../internal/cli/parser/preprocessor/Stack.java | 47 +
.../cli/parser/preprocessor/TrimmedInput.java | 39 +
.../cli/remote/CommandExecutionContext.java | 119 +
.../internal/cli/remote/CommandProcessor.java | 158 +
.../cli/remote/CommandStatementImpl.java | 92 +
.../cli/remote/MemberCommandService.java | 76 +
.../cli/remote/RemoteExecutionStrategy.java | 161 +
.../internal/cli/remote/WrapperThreadLocal.java | 34 +
.../internal/cli/result/AbstractResultData.java | 332 +
.../cli/result/CliJsonSerializable.java | 37 +
.../cli/result/CliJsonSerializableFactory.java | 39 +
.../cli/result/CliJsonSerializableIds.java | 26 +
.../internal/cli/result/CommandResult.java | 653 +
.../cli/result/CommandResultException.java | 30 +
.../cli/result/CompositeResultData.java | 353 +
.../internal/cli/result/ErrorResultData.java | 96 +
.../internal/cli/result/FileResult.java | 109 +
.../internal/cli/result/InfoResultData.java | 83 +
.../internal/cli/result/ObjectResultData.java | 80 +
.../internal/cli/result/ResultBuilder.java | 467 +
.../internal/cli/result/ResultData.java | 45 +
.../cli/result/ResultDataException.java | 27 +
.../internal/cli/result/TableBuilder.java | 460 +
.../internal/cli/result/TableBuilderHelper.java | 167 +
.../internal/cli/result/TabularResultData.java | 166 +
.../management/internal/cli/shell/Gfsh.java | 1213 ++
.../internal/cli/shell/GfshConfig.java | 207 +
.../cli/shell/GfshExecutionStrategy.java | 286 +
.../cli/shell/JMXConnectionException.java | 48 +
.../cli/shell/JMXInvocationException.java | 34 +
.../internal/cli/shell/JmxOperationInvoker.java | 406 +
.../internal/cli/shell/MultiCommandHelper.java | 54 +
.../internal/cli/shell/OperationInvoker.java | 127 +
.../internal/cli/shell/jline/ANSIHandler.java | 106 +
.../cli/shell/jline/CygwinMinttyTerminal.java | 176 +
.../internal/cli/shell/jline/GfshHistory.java | 43 +
.../shell/jline/GfshUnsupportedTerminal.java | 25 +
.../cli/shell/unsafe/GfshSignalHandler.java | 76 +
.../internal/cli/util/CLIConsoleBufferUtil.java | 28 +
.../internal/cli/util/CauseFinder.java | 206 +
.../cli/util/ClasspathScanLoadHelper.java | 250 +
.../internal/cli/util/CommandStringBuilder.java | 97 +
.../internal/cli/util/CommentSkipHelper.java | 70 +
.../internal/cli/util/ConnectionEndpoint.java | 64 +
.../internal/cli/util/DiskStoreCompacter.java | 126 +
.../cli/util/DiskStoreNotFoundException.java | 39 +
.../internal/cli/util/DiskStoreUpgrader.java | 121 +
.../internal/cli/util/DiskStoreValidater.java | 53 +
.../cli/util/EvictionAttributesInfo.java | 54 +
.../cli/util/FixedPartitionAttributesInfo.java | 56 +
.../internal/cli/util/GfshConsoleReader.java | 82 +
.../cli/util/JConsoleNotFoundException.java | 39 +
.../management/internal/cli/util/JsonUtil.java | 598 +
.../internal/cli/util/MemberInformation.java | 149 +
.../cli/util/MemberNotFoundException.java | 39 +
.../management/internal/cli/util/MergeLogs.java | 78 +
.../internal/cli/util/ReadWriteFile.java | 223 +
.../cli/util/RegionAttributesDefault.java | 80 +
.../cli/util/RegionAttributesNames.java | 77 +
.../internal/cli/util/RegionPath.java | 120 +
.../cli/util/VisualVmNotFoundException.java | 40 +
.../internal/cli/util/spring/Assert.java | 27 +
.../internal/cli/util/spring/ObjectUtils.java | 291 +
.../cli/util/spring/ReflectionUtils.java | 123 +
.../internal/cli/util/spring/StringUtils.java | 220 +
.../SharedConfigurationWriter.java | 171 +
.../callbacks/ConfigurationChangeListener.java | 50 +
.../configuration/domain/CacheElement.java | 245 +
.../configuration/domain/Configuration.java | 198 +
.../domain/ConfigurationChangeResult.java | 117 +
.../domain/SharedConfigurationStatus.java | 10 +
.../configuration/domain/XmlEntity.java | 542 +
.../configuration/functions/AddJarFunction.java | 58 +
.../functions/AddXmlEntityFunction.java | 51 +
.../functions/DeleteJarFunction.java | 59 +
.../functions/DeleteXmlEntityFunction.java | 56 +
.../functions/GetAllJarsFunction.java | 58 +
.../functions/ModifyPropertiesFunction.java | 56 +
.../handlers/ConfigurationRequestHandler.java | 76 +
...SharedConfigurationStatusRequestHandler.java | 56 +
.../messages/ConfigurationRequest.java | 117 +
.../messages/ConfigurationResponse.java | 165 +
.../SharedConfigurationStatusRequest.java | 35 +
.../SharedConfigurationStatusResponse.java | 69 +
.../configuration/utils/DtdResolver.java | 76 +
.../configuration/utils/XmlConstants.java | 47 +
.../internal/configuration/utils/XmlUtils.java | 676 +
.../internal/configuration/utils/ZipUtils.java | 113 +
.../internal/messages/CompactRequest.java | 166 +
.../internal/messages/CompactResponse.java | 62 +
.../internal/security/AccessControl.java | 35 +
.../internal/security/AccessControlContext.java | 21 +
.../internal/security/AccessControlMXBean.java | 7 +
.../internal/security/CLIOperationContext.java | 122 +
.../internal/security/JMXOperationContext.java | 161 +
.../internal/security/JSONAuthorization.java | 292 +
.../internal/security/MBeanServerWrapper.java | 270 +
.../security/ManagementInterceptor.java | 255 +
.../management/internal/security/Resource.java | 10 +
.../internal/security/ResourceConstants.java | 99 +
.../internal/security/ResourceOperation.java | 18 +
.../security/ResourceOperationContext.java | 187 +
.../unsafe/ReadOpFileAccessController.java | 54 +
.../controllers/AbstractCommandsController.java | 606 +
.../AbstractMultiPartCommandsController.java | 69 +
.../controllers/ClientCommandsController.java | 51 +
.../controllers/ClusterCommandsController.java | 42 +
.../controllers/ConfigCommandsController.java | 211 +
.../web/controllers/DataCommandsController.java | 232 +
.../controllers/DeployCommandsController.java | 101 +
.../DiskStoreCommandsController.java | 168 +
.../DurableClientCommandsController.java | 149 +
.../controllers/FunctionCommandsController.java | 133 +
.../controllers/IndexCommandsController.java | 163 +
.../LauncherLifecycleCommandsController.java | 46 +
.../controllers/MemberCommandsController.java | 69 +
.../MiscellaneousCommandsController.java | 262 +
.../web/controllers/PdxCommandsController.java | 106 +
.../controllers/QueueCommandsController.java | 124 +
.../controllers/RegionCommandsController.java | 323 +
.../controllers/ShellCommandsController.java | 271 +
.../web/controllers/WanCommandsController.java | 394 +
.../EnvironmentVariablesHandlerInterceptor.java | 84 +
.../support/MemberMXBeanAdapter.java | 616 +
.../management/internal/web/domain/Link.java | 152 +
.../internal/web/domain/LinkIndex.java | 131 +
.../web/domain/QueryParameterSource.java | 54 +
.../internal/web/http/ClientHttpRequest.java | 442 +
.../internal/web/http/HttpHeader.java | 91 +
.../internal/web/http/HttpMethod.java | 27 +
.../SerializableObjectHttpMessageConverter.java | 94 +
.../web/http/support/SimpleHttpRequester.java | 131 +
.../internal/web/io/MultipartFileAdapter.java | 59 +
.../web/io/MultipartFileResourceAdapter.java | 59 +
.../web/shell/AbstractHttpOperationInvoker.java | 792 ++
.../web/shell/HttpOperationInvoker.java | 15 +
.../web/shell/MBeanAccessException.java | 36 +
.../RestApiCallForCommandNotFoundException.java | 35 +
.../web/shell/RestHttpOperationInvoker.java | 415 +
.../web/shell/SimpleHttpOperationInvoker.java | 152 +
.../shell/support/HttpInvocationHandler.java | 86 +
.../shell/support/HttpMBeanProxyFactory.java | 32 +
.../internal/web/util/ConvertUtils.java | 123 +
.../management/internal/web/util/UriUtils.java | 248 +
.../management/membership/ClientMembership.java | 58 +
.../membership/ClientMembershipEvent.java | 42 +
.../membership/ClientMembershipListener.java | 39 +
.../ClientMembershipListenerAdapter.java | 43 +
.../management/membership/MembershipEvent.java | 33 +
.../membership/MembershipListener.java | 44 +
.../UniversalMembershipListenerAdapter.java | 375 +
.../gemstone/gemfire/management/package.html | 8 +
.../memcached/GemFireMemcachedServer.java | 275 +
.../main/java/com/gemstone/gemfire/package.html | 70 +
.../com/gemstone/gemfire/pdx/FieldType.java | 149 +
.../com/gemstone/gemfire/pdx/JSONFormatter.java | 614 +
.../gemfire/pdx/JSONFormatterException.java | 38 +
.../gemfire/pdx/NonPortableClassException.java | 18 +
.../gemfire/pdx/PdxConfigurationException.java | 32 +
.../pdx/PdxFieldAlreadyExistsException.java | 37 +
.../pdx/PdxFieldDoesNotExistException.java | 33 +
.../pdx/PdxFieldTypeMismatchException.java | 37 +
.../gemfire/pdx/PdxInitializationException.java | 42 +
.../com/gemstone/gemfire/pdx/PdxInstance.java | 193 +
.../gemfire/pdx/PdxInstanceFactory.java | 463 +
.../com/gemstone/gemfire/pdx/PdxReader.java | 256 +
.../pdx/PdxRegistryMismatchException.java | 31 +
.../gemstone/gemfire/pdx/PdxSerializable.java | 62 +
.../gemfire/pdx/PdxSerializationException.java | 44 +
.../com/gemstone/gemfire/pdx/PdxSerializer.java | 85 +
.../gemstone/gemfire/pdx/PdxUnreadFields.java | 33 +
.../com/gemstone/gemfire/pdx/PdxWriter.java | 470 +
.../pdx/ReflectionBasedAutoSerializer.java | 543 +
.../gemfire/pdx/WritablePdxInstance.java | 35 +
.../pdx/internal/AutoSerializableManager.java | 2302 +++
.../pdx/internal/CheckTypeRegistryState.java | 101 +
.../pdx/internal/ClientTypeRegistration.java | 409 +
.../gemfire/pdx/internal/ComparableEnum.java | 8 +
.../pdx/internal/ConvertableToBytes.java | 7 +
.../gemstone/gemfire/pdx/internal/DataSize.java | 40 +
.../gemfire/pdx/internal/DefaultPdxField.java | 28 +
.../gemstone/gemfire/pdx/internal/EnumId.java | 87 +
.../gemstone/gemfire/pdx/internal/EnumInfo.java | 324 +
.../pdx/internal/FieldNotFoundInPdxVersion.java | 11 +
.../gemfire/pdx/internal/InternalPdxReader.java | 76 +
.../pdx/internal/LonerTypeRegistration.java | 177 +
.../pdx/internal/NullTypeRegistration.java | 111 +
.../gemstone/gemfire/pdx/internal/PdxField.java | 250 +
.../gemfire/pdx/internal/PdxInputStream.java | 424 +
.../gemfire/pdx/internal/PdxInstanceEnum.java | 174 +
.../pdx/internal/PdxInstanceFactoryImpl.java | 260 +
.../gemfire/pdx/internal/PdxInstanceImpl.java | 635 +
.../pdx/internal/PdxInstanceInputStream.java | 106 +
.../gemfire/pdx/internal/PdxOutputStream.java | 226 +
.../gemfire/pdx/internal/PdxReaderImpl.java | 891 ++
.../gemfire/pdx/internal/PdxString.java | 201 +
.../gemstone/gemfire/pdx/internal/PdxType.java | 486 +
.../gemfire/pdx/internal/PdxUnreadData.java | 108 +
.../gemfire/pdx/internal/PdxWriterImpl.java | 900 ++
.../pdx/internal/PeerTypeRegistration.java | 754 +
.../pdx/internal/TrackingPdxReaderImpl.java | 345 +
.../gemfire/pdx/internal/TypeRegistration.java | 93 +
.../gemfire/pdx/internal/TypeRegistry.java | 513 +
.../gemfire/pdx/internal/UnreadPdxType.java | 64 +
.../internal/WeakConcurrentIdentityHashMap.java | 128 +
.../pdx/internal/WritablePdxInstanceImpl.java | 279 +
.../gemfire/pdx/internal/json/JsonHelper.java | 173 +
.../pdx/internal/json/PdxInstanceHelper.java | 186 +
.../pdx/internal/json/PdxListHelper.java | 181 +
.../gemfire/pdx/internal/json/PdxToJSON.java | 313 +
.../pdx/internal/unsafe/UnsafeWrapper.java | 176 +
.../java/com/gemstone/gemfire/pdx/package.html | 97 +
.../com/gemstone/gemfire/ra/GFConnection.java | 11 +
.../gemfire/ra/GFConnectionFactory.java | 13 +
.../gemfire/security/AccessControl.java | 86 +
.../gemfire/security/AuthInitialize.java | 79 +
.../security/AuthenticationFailedException.java | 45 +
.../AuthenticationRequiredException.java | 45 +
.../gemfire/security/Authenticator.java | 78 +
.../security/GemFireSecurityException.java | 46 +
.../security/NotAuthorizedException.java | 54 +
.../com/gemstone/gemfire/security/package.html | 23 +
.../util/concurrent/SynchronousQueueNoSpin.java | 1144 ++
.../config/GemFireFileConfigurationMonitor.java | 145 +
.../config/xml/GemFireXmlConfiguration.java | 344 +
.../xml/GemFireXmlConfigurationFactory.java | 59 +
.../message/GemFireParameterizedMessage.java | 554 +
.../GemFireParameterizedMessageFactory.java | 54 +
.../src/main/java/external-overview.html | 27 +
.../src/main/java/internal-overview.html | 10 +
.../gemfire/cache/cache-8.1.xsd | 1496 ++
.../services/org.xml.sax.ext.EntityResolver2 | 1 +
.../gemstone/gemfire/admin/doc-files/ds4_0.dtd | 161 +
.../gemstone/gemfire/admin/doc-files/ds5_0.dtd | 153 +
.../internal/doc-files/mbeans-descriptors.dtd | 232 +
.../gemfire/admin/jmx/mbeans-descriptors.xml | 1435 ++
.../gemfire/cache/doc-files/cache3_0.dtd | 281 +
.../gemfire/cache/doc-files/cache4_0.dtd | 377 +
.../gemfire/cache/doc-files/cache4_1.dtd | 470 +
.../gemfire/cache/doc-files/cache5_0.dtd | 504 +
.../gemfire/cache/doc-files/cache5_1.dtd | 519 +
.../gemfire/cache/doc-files/cache5_5.dtd | 636 +
.../gemfire/cache/doc-files/cache5_7.dtd | 761 +
.../gemfire/cache/doc-files/cache5_8.dtd | 779 ++
.../gemfire/cache/doc-files/cache6_0.dtd | 847 ++
.../gemfire/cache/doc-files/cache6_1.dtd | 856 ++
.../gemfire/cache/doc-files/cache6_5.dtd | 934 ++
.../gemfire/cache/doc-files/cache6_6.dtd | 991 ++
.../gemfire/cache/doc-files/cache7_0.dtd | 1072 ++
.../gemfire/cache/doc-files/cache8_0.dtd | 1092 ++
.../distributed/internal/javagroups-config.txt | 101 +
.../distributed/internal/javagroups-mcast.txt | 97 +
.../internal/i18n/StringIdResourceBundle_ja.txt | 3811 +++++
.../internal/logging/log4j/log4j2-cli.xml | 17 +
.../internal/logging/log4j/log4j2-default.xml | 21 +
.../internal/logging/log4j/log4j2-legacy.xml | 17 +
.../gemstone/gemfire/internal/privatekey.ser | Bin 0 -> 756 bytes
.../com/gemstone/gemfire/internal/publickey.ser | Bin 0 -> 1029 bytes
.../tools/gfsh/app/windowsbindings.properties | 68 +
.../internal/cli/commands/support/gfmon.html | 20 +
.../management/internal/cli/modes/commands.json | 3 +
.../management/internal/cli/modes/connect.json | 29 +
.../internal/cli/modes/stopserver.json | 29 +
.../com/gemstone/gemfire/statisticsType.dtd | 72 +
.../gemstone/gemfire/admin/AdminTestHelper.java | 29 +
...ibutedSystemFactoryIntegrationJUnitTest.java | 76 +
.../DistributedSystemFactoryJUnitTest.java | 149 +
.../cache/AttributesFactoryJUnitTest.java | 429 +
.../gemfire/cache/Bug36619JUnitTest.java | 68 +
.../gemfire/cache/OperationJUnitTest.java | 924 ++
.../gemfire/cache/RoleExceptionJUnitTest.java | 130 +
.../internal/OpExecutorImplJUnitTest.java | 658 +
.../internal/ServerBlackListJUnitTest.java | 135 +
.../locator/LocatorStatusResponseJUnitTest.java | 69 +
.../gemfire/cache/query/data/Address.java | 42 +
.../gemstone/gemfire/cache/query/data/City.java | 47 +
.../cache/query/data/CollectionHolder.java | 80 +
.../cache/query/data/ComparableWrapper.java | 60 +
.../gemfire/cache/query/data/Country.java | 91 +
.../gemstone/gemfire/cache/query/data/Data.java | 37 +
.../gemfire/cache/query/data/District.java | 55 +
.../gemfire/cache/query/data/Employee.java | 63 +
.../gemfire/cache/query/data/Inventory.java | 118 +
.../gemfire/cache/query/data/Keywords.java | 81 +
.../gemfire/cache/query/data/Manager.java | 34 +
.../gemfire/cache/query/data/Numbers.java | 43 +
.../gemfire/cache/query/data/PhoneNo.java | 33 +
.../gemfire/cache/query/data/Portfolio.java | 292 +
.../gemfire/cache/query/data/PortfolioData.java | 145 +
.../gemfire/cache/query/data/PortfolioPdx.java | 292 +
.../gemfire/cache/query/data/Position.java | 157 +
.../gemfire/cache/query/data/PositionPdx.java | 173 +
.../query/data/ProhibitedSecurityQuote.java | 57 +
.../gemfire/cache/query/data/Quote.java | 105 +
.../gemfire/cache/query/data/Restricted.java | 71 +
.../cache/query/data/SecurityMaster.java | 253 +
.../gemfire/cache/query/data/State.java | 72 +
.../gemfire/cache/query/data/Street.java | 29 +
.../gemfire/cache/query/data/Student.java | 68 +
.../gemfire/cache/query/data/Vehicle.java | 30 +
.../gemfire/cache/query/data/Village.java | 46 +
.../internal/OrderByComparatorJUnitTest.java | 63 +
.../QueryObjectSerializationJUnitTest.java | 142 +
.../query/internal/ResultsBagJUnitTest.java | 305 +
.../ResultsBagLimitBehaviourJUnitTest.java | 576 +
.../ResultsCollectionWrapperLimitJUnitTest.java | 358 +
.../SelectResultsComparatorJUnitTest.java | 82 +
.../StructBagLimitBehaviourJUnitTest.java | 120 +
.../query/internal/StructSetJUnitTest.java | 68 +
.../internal/index/IndexElemArrayJUnitTest.java | 123 +
.../internal/ConnectionCountProbeJUnitTest.java | 42 +
.../cache/util/PasswordUtilJUnitTest.java | 32 +
.../distributed/AbstractLauncherJUnitTest.java | 354 +
.../AbstractLauncherServiceStatusJUnitTest.java | 264 +
.../distributed/CommonLauncherTestSuite.java | 45 +
.../distributed/LocatorLauncherJUnitTest.java | 498 +
.../distributed/ServerLauncherJUnitTest.java | 980 ++
.../AtomicLongWithTerminalStateJUnitTest.java | 32 +
.../internal/ProductUseLogJUnitTest.java | 77 +
.../internal/ServerLocatorJUnitTest.java | 66 +
.../internal/SharedConfigurationJUnitTest.java | 48 +
.../internal/StartupMessageDataJUnitTest.java | 310 +
.../deadlock/DeadlockDetectorJUnitTest.java | 311 +
.../deadlock/DependencyGraphJUnitTest.java | 78 +
.../deadlock/UnsafeThreadLocalJUnitTest.java | 52 +
...entrantReadWriteWriteShareLockJUnitTest.java | 448 +
.../membership/MembershipJUnitTest.java | 99 +
.../support/DistributedSystemAdapter.java | 249 +
.../internal/AvailablePortJUnitTest.java | 65 +
.../gemfire/internal/ByteArrayData.java | 64 +
.../gemstone/gemfire/internal/ClassBuilder.java | 283 +
.../internal/ClassPathLoaderJUnitTest.java | 1253 ++
.../internal/CopyOnWriteHashSetJUnitTest.java | 94 +
.../gemfire/internal/FileUtilJUnitTest.java | 63 +
.../internal/GemFireVersionJUnitTest.java | 93 +
.../internal/HeapDataOutputStreamJUnitTest.java | 41 +
.../internal/JarClassLoaderJUnitTest.java | 773 ++
.../gemfire/internal/LineWrapUnitJUnitTest.java | 43 +
.../gemfire/internal/NanoTimer2JUnitTest.java | 79 +
.../gemfire/internal/ObjIdMapJUnitTest.java | 247 +
.../internal/OneTaskOnlyDecoratorJUnitTest.java | 156 +
.../PutAllOperationContextJUnitTest.java | 188 +
.../internal/UniqueIdGeneratorJUnitTest.java | 59 +
.../internal/cache/AbstractRegionJUnitTest.java | 504 +
.../gemfire/internal/cache/DiskIdJUnitTest.java | 231 +
.../internal/cache/DiskInitFileJUnitTest.java | 104 +
.../cache/DiskWriteAttributesJUnitTest.java | 214 +
.../cache/EnumListenerEventJUnitTest.java | 64 +
.../gemfire/internal/cache/OldVLJUnitTest.java | 83 +
.../cache/OplogEntryIdMapJUnitTest.java | 90 +
.../cache/OplogEntryIdSetJUnitTest.java | 74 +
.../internal/cache/OplogRVVJUnitTest.java | 164 +
.../cache/OrderedTombstoneMapJUnitTest.java | 50 +
.../cache/PartitionedRegionHelperJUnitTest.java | 39 +
.../gemfire/internal/cache/VLJUnitTest.java | 121 +
.../cache/control/FilterByPathJUnitTest.java | 87 +
.../SimpleExtensionPointJUnitTest.java | 206 +
.../cache/ha/EventIdOptimizationJUnitTest.java | 245 +
.../cache/ha/ThreadIdentifierJUnitTest.java | 107 +
.../classpathloaderjunittest/DoesExist.java | 5 +
.../compression/SnappyCompressorJUnitTest.java | 57 +
.../util/AbortableTaskServiceJUnitTest.java | 193 +
.../internal/util/ArrayUtilsJUnitTest.java | 170 +
.../gemfire/internal/util/BytesJUnitTest.java | 107 +
.../internal/util/CollectionUtilsJUnitTest.java | 477 +
.../internal/util/DelayedActionJUnitTest.java | 47 +
.../gemfire/internal/util/IOUtilsJUnitTest.java | 306 +
.../gemfire/internal/util/SerializableImpl.java | 31 +
.../util/SerializableImplWithValue.java | 50 +
.../gemstone/gemfire/internal/util/Sizeof.java | 164 +
.../gemfire/internal/util/Valuable.java | 31 +
.../CompactConcurrentHashSetJUnitTest.java | 87 +
.../ConcurrentHashMapIteratorJUnitTest.java | 115 +
.../concurrent/ReentrantSemaphoreJUnitTest.java | 104 +
.../SemaphoreReadWriteLockJUnitTest.java | 176 +
.../internal/security/JSONAuthCodeTest.java | 184 +
.../security/JSONAuthorizationTest.java | 152 +
.../security/ResourceOperationJUnit.java | 378 +
.../gemstone/gemfire/util/test/TestUtil.java | 49 +
.../java/org/xerial/snappy/SnappyUtils.java | 9 +
.../internal/SharedConfigurationJUnitTest.xml | 6 +
.../management/internal/security/auth1.json | 14 +
.../management/internal/security/auth2.json | 21 +
.../management/internal/security/auth3.json | 25 +
.../internal/security/testInheritRole.json | 40 +
.../security/testSimpleUserAndRole.json | 14 +
.../testUserAndRoleRegionServerGroup.json | 16 +
.../internal/security/testUserMultipleRole.json | 20 +
gemfire-jgroups/build.gradle | 31 +
.../java/com/gemstone/org/jgroups/Address.java | 46 +
.../com/gemstone/org/jgroups/BlockEvent.java | 15 +
.../java/com/gemstone/org/jgroups/Channel.java | 508 +
.../org/jgroups/ChannelClosedException.java | 27 +
.../gemstone/org/jgroups/ChannelException.java | 28 +
.../gemstone/org/jgroups/ChannelFactory.java | 38 +
.../gemstone/org/jgroups/ChannelListener.java | 20 +
.../jgroups/ChannelNotConnectedException.java | 26 +
.../java/com/gemstone/org/jgroups/Event.java | 225 +
.../com/gemstone/org/jgroups/ExitEvent.java | 14 +
.../com/gemstone/org/jgroups/GetStateEvent.java | 22 +
.../java/com/gemstone/org/jgroups/Global.java | 44 +
.../java/com/gemstone/org/jgroups/Header.java | 51 +
.../java/com/gemstone/org/jgroups/JChannel.java | 1723 +++
.../gemstone/org/jgroups/JChannelFactory.java | 129 +
.../gemstone/org/jgroups/JGroupsVersion.java | 95 +
.../com/gemstone/org/jgroups/Membership.java | 358 +
.../org/jgroups/MembershipListener.java | 53 +
.../com/gemstone/org/jgroups/MergeView.java | 166 +
.../java/com/gemstone/org/jgroups/Message.java | 784 ++
.../com/gemstone/org/jgroups/Message.java.old | 711 +
.../gemstone/org/jgroups/MessageListener.java | 34 +
.../java/com/gemstone/org/jgroups/Receiver.java | 13 +
.../gemstone/org/jgroups/ReceiverAdapter.java | 35 +
.../com/gemstone/org/jgroups/SetStateEvent.java | 37 +
.../org/jgroups/ShunnedAddressException.java | 14 +
.../com/gemstone/org/jgroups/SuspectEvent.java | 26 +
.../com/gemstone/org/jgroups/SuspectMember.java | 42 +
.../org/jgroups/SuspectedException.java | 21 +
.../gemstone/org/jgroups/TimeoutException.java | 43 +
.../com/gemstone/org/jgroups/Transport.java | 22 +
.../com/gemstone/org/jgroups/UpHandler.java | 18 +
.../java/com/gemstone/org/jgroups/View.java | 528 +
.../java/com/gemstone/org/jgroups/ViewId.java | 174 +
.../org/jgroups/blocks/ConnectionTable.java | 1051 ++
.../org/jgroups/blocks/ConnectionTableNIO.java | 1519 ++
.../jgroups/blocks/DistributedHashtable.java | 656 +
.../jgroups/blocks/DistributedLockManager.java | 742 +
.../org/jgroups/blocks/DistributedQueue.java | 758 +
.../org/jgroups/blocks/DistributedTree.java | 756 +
.../org/jgroups/blocks/GroupRequest.java | 636 +
.../org/jgroups/blocks/GroupRequest.java.old | 641 +
.../com/gemstone/org/jgroups/blocks/Link.java | 680 +
.../com/gemstone/org/jgroups/blocks/Link.txt | 48 +
.../org/jgroups/blocks/LockManager.java | 87 +
.../blocks/LockMultiLockedException.java | 26 +
.../jgroups/blocks/LockNotGrantedException.java | 24 +
.../blocks/LockNotReleasedException.java | 24 +
.../org/jgroups/blocks/LockingException.java | 38 +
.../org/jgroups/blocks/LogicalLink.java | 340 +
.../blocks/MembershipListenerAdapter.java | 91 +
.../org/jgroups/blocks/MessageDispatcher.java | 845 ++
.../jgroups/blocks/MessageListenerAdapter.java | 123 +
.../gemstone/org/jgroups/blocks/MethodCall.java | 529 +
.../org/jgroups/blocks/MethodLookup.java | 15 +
.../org/jgroups/blocks/NBMessageForm_NIO.java | 94 +
.../org/jgroups/blocks/NotificationBus.java | 458 +
.../org/jgroups/blocks/PullPushAdapter.java | 434 +
.../org/jgroups/blocks/ReplicatedHashtable.java | 530 +
.../org/jgroups/blocks/ReplicatedTree.java | 1121 ++
.../org/jgroups/blocks/ReplicationData.java | 148 +
.../org/jgroups/blocks/ReplicationManager.java | 345 +
.../org/jgroups/blocks/ReplicationReceiver.java | 69 +
.../org/jgroups/blocks/RequestCorrelator.java | 911 ++
.../org/jgroups/blocks/RequestHandler.java | 15 +
.../org/jgroups/blocks/RpcDispatcher.java | 392 +
.../org/jgroups/blocks/RspCollector.java | 18 +
.../jgroups/blocks/TwoPhaseVotingAdapter.java | 173 +
.../jgroups/blocks/TwoPhaseVotingListener.java | 35 +
.../org/jgroups/blocks/UpdateException.java | 19 +
.../org/jgroups/blocks/VoteException.java | 19 +
.../jgroups/blocks/VoteResponseProcessor.java | 31 +
.../org/jgroups/blocks/VotingAdapter.java | 472 +
.../org/jgroups/blocks/VotingListener.java | 26 +
.../com/gemstone/org/jgroups/blocks/Xid.java | 164 +
.../gemstone/org/jgroups/blocks/package.html | 13 +
.../org/jgroups/conf/ClassConfigurator.java | 228 +
.../com/gemstone/org/jgroups/conf/ClassMap.java | 75 +
.../jgroups/conf/ClassPathEntityResolver.java | 63 +
.../org/jgroups/conf/ConfiguratorFactory.java | 449 +
.../org/jgroups/conf/MagicNumberReader.java | 402 +
.../org/jgroups/conf/PlainConfigurator.java | 48 +
.../gemstone/org/jgroups/conf/ProtocolData.java | 130 +
.../org/jgroups/conf/ProtocolParameter.java | 64 +
.../jgroups/conf/ProtocolStackConfigurator.java | 18 +
.../org/jgroups/conf/XmlConfigurator.java | 463 +
.../gemstone/org/jgroups/conf/XmlValidator.java | 146 +
.../com/gemstone/org/jgroups/conf/package.html | 5 +
.../gemstone/org/jgroups/debug/Debugger.java | 133 +
.../org/jgroups/debug/JChannelTestHook.java | 14 +
.../gemstone/org/jgroups/debug/Profiler.java | 160 +
.../org/jgroups/debug/ProtocolSpecificView.java | 24 +
.../org/jgroups/debug/ProtocolTester.java | 142 +
.../org/jgroups/debug/ProtocolView.java | 90 +
.../gemstone/org/jgroups/debug/QUEUEView.java | 28 +
.../gemstone/org/jgroups/debug/Simulator.java | 249 +
.../com/gemstone/org/jgroups/debug/package.html | 5 +
.../com/gemstone/org/jgroups/gemstonizing.txt | 28 +
.../org/jgroups/oswego/concurrent/Barrier.java | 65 +
.../oswego/concurrent/BoundedBuffer.java | 190 +
.../oswego/concurrent/BoundedChannel.java | 37 +
.../oswego/concurrent/BoundedLinkedQueue.java | 384 +
.../oswego/concurrent/BoundedPriorityQueue.java | 123 +
.../concurrent/BrokenBarrierException.java | 48 +
.../org/jgroups/oswego/concurrent/Callable.java | 39 +
.../org/jgroups/oswego/concurrent/Channel.java | 309 +
.../jgroups/oswego/concurrent/ClockDaemon.java | 403 +
.../org/jgroups/oswego/concurrent/CondVar.java | 277 +
.../jgroups/oswego/concurrent/CountDown.java | 126 +
.../oswego/concurrent/CyclicBarrier.java | 299 +
.../concurrent/DefaultChannelCapacity.java | 58 +
.../oswego/concurrent/DirectExecutor.java | 36 +
.../org/jgroups/oswego/concurrent/Executor.java | 70 +
.../oswego/concurrent/FIFOReadWriteLock.java | 198 +
.../oswego/concurrent/FIFOSemaphore.java | 84 +
.../org/jgroups/oswego/concurrent/FJTask.java | 535 +
.../jgroups/oswego/concurrent/FJTaskRunner.java | 979 ++
.../oswego/concurrent/FJTaskRunnerGroup.java | 625 +
.../jgroups/oswego/concurrent/FutureResult.java | 209 +
.../org/jgroups/oswego/concurrent/Heap.java | 151 +
.../org/jgroups/oswego/concurrent/Latch.java | 103 +
.../jgroups/oswego/concurrent/LayeredSync.java | 96 +
.../jgroups/oswego/concurrent/LinkedNode.java | 29 +
.../jgroups/oswego/concurrent/LinkedQueue.java | 192 +
.../oswego/concurrent/LockedExecutor.java | 62 +
.../org/jgroups/oswego/concurrent/Mutex.java | 173 +
.../org/jgroups/oswego/concurrent/NullSync.java | 51 +
.../oswego/concurrent/PooledExecutor.java | 924 ++
.../oswego/concurrent/PrioritySemaphore.java | 96 +
.../concurrent/PropertyChangeMulticaster.java | 466 +
.../org/jgroups/oswego/concurrent/Puttable.java | 68 +
.../oswego/concurrent/QueuedExecutor.java | 220 +
.../oswego/concurrent/QueuedSemaphore.java | 181 +
.../oswego/concurrent/ReadWriteLock.java | 86 +
.../ReaderPreferenceReadWriteLock.java | 35 +
.../oswego/concurrent/ReentrantLock.java | 151 +
.../ReentrantWriterPreferenceReadWriteLock.java | 169 +
.../jgroups/oswego/concurrent/Rendezvous.java | 422 +
.../jgroups/oswego/concurrent/Semaphore.java | 193 +
.../concurrent/SemaphoreControlledChannel.java | 164 +
.../org/jgroups/oswego/concurrent/Slot.java | 88 +
.../org/jgroups/oswego/concurrent/Sync.java | 344 +
.../oswego/concurrent/SyncCollection.java | 514 +
.../org/jgroups/oswego/concurrent/SyncList.java | 327 +
.../org/jgroups/oswego/concurrent/SyncMap.java | 314 +
.../org/jgroups/oswego/concurrent/SyncSet.java | 82 +
.../oswego/concurrent/SyncSortedMap.java | 129 +
.../oswego/concurrent/SyncSortedSet.java | 129 +
.../oswego/concurrent/SynchronizedBoolean.java | 182 +
.../oswego/concurrent/SynchronizedByte.java | 253 +
.../oswego/concurrent/SynchronizedChar.java | 176 +
.../oswego/concurrent/SynchronizedDouble.java | 181 +
.../oswego/concurrent/SynchronizedFloat.java | 181 +
.../oswego/concurrent/SynchronizedInt.java | 250 +
.../oswego/concurrent/SynchronizedLong.java | 252 +
.../oswego/concurrent/SynchronizedRef.java | 107 +
.../oswego/concurrent/SynchronizedShort.java | 254 +
.../oswego/concurrent/SynchronizedVariable.java | 209 +
.../oswego/concurrent/SynchronousChannel.java | 379 +
.../org/jgroups/oswego/concurrent/Takable.java | 67 +
.../oswego/concurrent/ThreadFactory.java | 35 +
.../oswego/concurrent/ThreadFactoryUser.java | 62 +
.../oswego/concurrent/ThreadedExecutor.java | 40 +
.../oswego/concurrent/TimedCallable.java | 68 +
.../oswego/concurrent/TimeoutException.java | 53 +
.../jgroups/oswego/concurrent/TimeoutSync.java | 75 +
.../concurrent/VetoableChangeMulticaster.java | 577 +
.../oswego/concurrent/WaitFreeQueue.java | 208 +
.../oswego/concurrent/WaitableBoolean.java | 141 +
.../jgroups/oswego/concurrent/WaitableByte.java | 238 +
.../jgroups/oswego/concurrent/WaitableChar.java | 170 +
.../oswego/concurrent/WaitableDouble.java | 173 +
.../oswego/concurrent/WaitableFloat.java | 173 +
.../jgroups/oswego/concurrent/WaitableInt.java | 239 +
.../jgroups/oswego/concurrent/WaitableLong.java | 239 +
.../jgroups/oswego/concurrent/WaitableRef.java | 112 +
.../oswego/concurrent/WaitableShort.java | 238 +
.../concurrent/WaiterPreferenceSemaphore.java | 155 +
.../WriterPreferenceReadWriteLock.java | 337 +
.../org/jgroups/oswego/concurrent/package.html | 998 ++
.../java/com/gemstone/org/jgroups/overview.html | 15 +
.../java/com/gemstone/org/jgroups/package.html | 5 +
.../persistence/CannotConnectException.java | 55 +
.../CannotCreateSchemaException.java | 45 +
.../persistence/CannotPersistException.java | 44 +
.../persistence/CannotRemoveException.java | 45 +
.../persistence/CannotRetrieveException.java | 44 +
.../persistence/DBPersistenceManager.java | 877 ++
.../persistence/FilePersistenceManager.java | 173 +
.../jgroups/persistence/PersistenceFactory.java | 207 +
.../jgroups/persistence/PersistenceManager.java | 69 +
.../org/jgroups/persistence/package.html | 5 +
.../com/gemstone/org/jgroups/primarychanges.txt | 80 +
.../gemstone/org/jgroups/protocols/AUTH.java | 438 +
.../org/jgroups/protocols/AUTOCONF.java | 249 +
.../org/jgroups/protocols/AuthHeader.java | 108 +
.../gemstone/org/jgroups/protocols/CAUSAL.java | 296 +
.../org/jgroups/protocols/COMPRESS.java | 188 +
.../org/jgroups/protocols/DEADLOCK.java | 250 +
.../gemstone/org/jgroups/protocols/DELAY.java | 116 +
.../com/gemstone/org/jgroups/protocols/DESIGN | 283 +
.../gemstone/org/jgroups/protocols/DISCARD.java | 150 +
.../gemstone/org/jgroups/protocols/DUMMY.java | 85 +
.../org/jgroups/protocols/DUMMY_TP.java | 84 +
.../gemstone/org/jgroups/protocols/Digest.java | 38 +
.../org/jgroups/protocols/Discovery.java | 484 +
.../gemstone/org/jgroups/protocols/ENCRYPT.java | 1390 ++
.../org/jgroups/protocols/ENCRYPT1_4.java | 566 +
.../gemstone/org/jgroups/protocols/EXAMPLE.java | 104 +
.../com/gemstone/org/jgroups/protocols/FC.java | 1025 ++
.../com/gemstone/org/jgroups/protocols/FD.java | 1100 ++
.../gemstone/org/jgroups/protocols/FD_PID.java | 640 +
.../gemstone/org/jgroups/protocols/FD_PROB.java | 628 +
.../org/jgroups/protocols/FD_SIMPLE.java | 357 +
.../gemstone/org/jgroups/protocols/FD_SOCK.java | 2607 ++++
.../org/jgroups/protocols/FD_SOCK.java.new | 1153 ++
.../org/jgroups/protocols/FLOWCONTROL.java | 89 +
.../org/jgroups/protocols/FLOW_CONTROL.java | 317 +
.../gemstone/org/jgroups/protocols/FLUSH.java | 466 +
.../gemstone/org/jgroups/protocols/FRAG.java | 572 +
.../gemstone/org/jgroups/protocols/FRAG2.java | 773 ++
.../gemstone/org/jgroups/protocols/FRAG3.java | 35 +
.../org/jgroups/protocols/FlushRsp.java | 31 +
.../org/jgroups/protocols/FragHeader.java | 80 +
.../gemstone/org/jgroups/protocols/GMS.java.rmi | 219 +
.../org/jgroups/protocols/GemFireTimeSync.java | 719 +
.../gemstone/org/jgroups/protocols/HDRS.java | 53 +
.../gemstone/org/jgroups/protocols/HTOTAL.java | 207 +
.../org/jgroups/protocols/LOOPBACK.java | 115 +
.../gemstone/org/jgroups/protocols/LOSS.java | 118 +
.../gemstone/org/jgroups/protocols/MERGE.java | 376 +
.../gemstone/org/jgroups/protocols/MERGE2.java | 362 +
.../gemstone/org/jgroups/protocols/MERGE3.java | 312 +
.../org/jgroups/protocols/MERGEFAST.java | 118 +
.../protocols/MessageProtocolEXAMPLE.java | 64 +
.../protocols/NAKACK.java.MessageProtocol | 422 +
.../org/jgroups/protocols/NAKACK.java.separate | 484 +
.../org/jgroups/protocols/NakAckHeader.java | 113 +
.../org/jgroups/protocols/PARTITIONER.java | 185 +
.../gemstone/org/jgroups/protocols/PERF.java | 284 +
.../gemstone/org/jgroups/protocols/PERF_TP.java | 172 +
.../org/jgroups/protocols/PIGGYBACK.java | 271 +
.../gemstone/org/jgroups/protocols/PING.java | 297 +
.../org/jgroups/protocols/PRINTMETHODS.java | 64 +
.../org/jgroups/protocols/PRINTOBJS.java | 120 +
.../org/jgroups/protocols/PerfHeader.java | 451 +
.../org/jgroups/protocols/PingHeader.java | 79 +
.../gemstone/org/jgroups/protocols/PingRsp.java | 107 +
.../org/jgroups/protocols/PingSender.java | 109 +
.../org/jgroups/protocols/PingWaiter.java | 301 +
.../gemstone/org/jgroups/protocols/QUEUE.java | 184 +
.../jgroups/protocols/RpcProtocolEXAMPLE.java | 64 +
.../gemstone/org/jgroups/protocols/SHUFFLE.java | 146 +
.../gemstone/org/jgroups/protocols/SIZE.java | 186 +
.../gemstone/org/jgroups/protocols/SMACK.java | 393 +
.../org/jgroups/protocols/STATE_TRANSFER.java | 448 +
.../gemstone/org/jgroups/protocols/STATS.java | 211 +
.../com/gemstone/org/jgroups/protocols/TCP.java | 308 +
.../org/jgroups/protocols/TCPGOSSIP.java | 429 +
.../gemstone/org/jgroups/protocols/TCPPING.java | 144 +
.../gemstone/org/jgroups/protocols/TCP_NIO.java | 118 +
.../gemstone/org/jgroups/protocols/TOTAL.java | 1055 ++
.../com/gemstone/org/jgroups/protocols/TP.java | 2009 +++
.../gemstone/org/jgroups/protocols/TP.java.mt | 1522 ++
.../gemstone/org/jgroups/protocols/TRACE.java | 47 +
.../gemstone/org/jgroups/protocols/TUNNEL.java | 459 +
.../org/jgroups/protocols/TcpHeader.java | 55 +
.../org/jgroups/protocols/TpHeader.java | 64 +
.../protocols/TransportedVectorTime.java | 185 +
.../org/jgroups/protocols/TunnelHeader.java | 47 +
.../com/gemstone/org/jgroups/protocols/UDP.java | 1462 ++
.../gemstone/org/jgroups/protocols/UDP.java.mt | 1005 ++
.../jgroups/protocols/UDP.java.packethandler | 592 +
.../gemstone/org/jgroups/protocols/UDP_NIO.java | 1567 +++
.../gemstone/org/jgroups/protocols/UNICAST.java | 981 ++
.../org/jgroups/protocols/UdpHeader.java | 62 +
.../org/jgroups/protocols/VERIFY_SUSPECT.java | 470 +
.../org/jgroups/protocols/VIEW_ENFORCER.java | 81 +
.../org/jgroups/protocols/VIEW_SYNC.java | 499 +
.../org/jgroups/protocols/VectorTime.java | 270 +
.../gemstone/org/jgroups/protocols/WANPING.java | 106 +
.../gemstone/org/jgroups/protocols/WANPIPE.java | 441 +
.../org/jgroups/protocols/WanPipeAddress.java | 140 +
.../gemstone/org/jgroups/protocols/dump2.log | 0
.../jgroups/protocols/obsolete/ENCRYPT.java.txt | 408 +
.../org/jgroups/protocols/obsolete/FC.java.txt | 643 +
.../jgroups/protocols/obsolete/FD_RAND.java.txt | 287 +
.../jgroups/protocols/obsolete/FD_SHUN.java.txt | 323 +
.../org/jgroups/protocols/obsolete/TCP.java.txt | 493 +
.../org/jgroups/protocols/obsolete/UDP.java.txt | 1921 +++
.../jgroups/protocols/obsolete/UNIFORM.java.txt | 349 +
.../gemstone/org/jgroups/protocols/package.html | 6 +
.../jgroups/protocols/pbcast/ClientGmsImpl.java | 898 ++
.../jgroups/protocols/pbcast/CoordGmsImpl.java | 1103 ++
.../org/jgroups/protocols/pbcast/DESIGN | 478 +
.../org/jgroups/protocols/pbcast/Digest.java | 534 +
.../jgroups/protocols/pbcast/Digest.java.old | 558 +
.../org/jgroups/protocols/pbcast/FD.java | 273 +
.../org/jgroups/protocols/pbcast/GMS.java | 2729 ++++
.../org/jgroups/protocols/pbcast/GmsImpl.java | 111 +
.../org/jgroups/protocols/pbcast/Gossip.java | 134 +
.../org/jgroups/protocols/pbcast/JoinRsp.java | 126 +
.../org/jgroups/protocols/pbcast/MergeData.java | 118 +
.../org/jgroups/protocols/pbcast/NAKACK.java | 1631 +++
.../jgroups/protocols/pbcast/NakAckHeader.java | 148 +
.../org/jgroups/protocols/pbcast/PBCAST.java | 1043 ++
.../protocols/pbcast/ParticipantGmsImpl.java | 371 +
.../jgroups/protocols/pbcast/PbcastHeader.java | 110 +
.../org/jgroups/protocols/pbcast/README | 140 +
.../org/jgroups/protocols/pbcast/STABLE.java | 907 ++
.../jgroups/protocols/pbcast/STABLE.java.latest | 897 ++
.../jgroups/protocols/pbcast/STABLE.java.new | 890 ++
.../jgroups/protocols/pbcast/STABLE.java.old | 855 ++
.../protocols/pbcast/STATE_TRANSFER.java | 461 +
.../org/jgroups/protocols/pbcast/package.html | 5 +
.../org/jgroups/protocols/ring/RingNode.java | 26 +
.../protocols/ring/RingNodeFlowControl.java | 135 +
.../org/jgroups/protocols/ring/RingToken.java | 245 +
.../org/jgroups/protocols/ring/TcpRingNode.java | 205 +
.../protocols/ring/TokenLostException.java | 63 +
.../org/jgroups/protocols/ring/package.html | 5 +
.../jgroups/stack/AckMcastReceiverWindow.java | 169 +
.../org/jgroups/stack/AckMcastSenderWindow.java | 601 +
.../org/jgroups/stack/AckReceiverWindow.java | 184 +
.../org/jgroups/stack/AckSenderWindow.java | 354 +
.../org/jgroups/stack/BoundedLinkedHashMap.java | 82 +
.../org/jgroups/stack/Configurator.java | 764 +
.../org/jgroups/stack/GFBasicAdapter.java | 95 +
.../org/jgroups/stack/GFBasicAdapterImpl.java | 466 +
.../org/jgroups/stack/GFPeerAdapter.java | 168 +
.../org/jgroups/stack/GFPeerAdapterImpl.java | 321 +
.../org/jgroups/stack/GossipClient.java | 819 ++
.../gemstone/org/jgroups/stack/GossipData.java | 232 +
.../org/jgroups/stack/GossipServer.java | 633 +
.../gemstone/org/jgroups/stack/Interval.java | 40 +
.../gemstone/org/jgroups/stack/IpAddress.java | 780 ++
.../org/jgroups/stack/LogicalAddress.java | 370 +
.../org/jgroups/stack/MessageProtocol.java | 243 +
.../org/jgroups/stack/NakReceiverWindow.java | 914 ++
.../gemstone/org/jgroups/stack/Protocol.java | 837 ++
.../org/jgroups/stack/ProtocolObserver.java | 81 +
.../org/jgroups/stack/ProtocolStack.java | 504 +
.../org/jgroups/stack/Retransmitter.java | 480 +
.../com/gemstone/org/jgroups/stack/Router.java | 577 +
.../gemstone/org/jgroups/stack/RouterStub.java | 419 +
.../gemstone/org/jgroups/stack/RpcProtocol.java | 166 +
.../org/jgroups/stack/SockCreatorImpl.java | 47 +
.../org/jgroups/stack/StateTransferInfo.java | 64 +
.../com/gemstone/org/jgroups/stack/package.html | 5 +
.../gemstone/org/jgroups/util/AckCollector.java | 149 +
.../gemstone/org/jgroups/util/BoundedList.java | 53 +
.../com/gemstone/org/jgroups/util/Buffer.java | 64 +
.../com/gemstone/org/jgroups/util/Command.java | 16 +
.../com/gemstone/org/jgroups/util/CondVar.java | 139 +
.../org/jgroups/util/ConnectionWatcher.java | 25 +
.../jgroups/util/ContextObjectInputStream.java | 91 +
.../util/ExposedBufferedInputStream.java | 61 +
.../util/ExposedBufferedOutputStream.java | 44 +
.../util/ExposedByteArrayInputStream.java | 58 +
.../util/ExposedByteArrayOutputStream.java | 31 +
.../jgroups/util/ExposedDataOutputStream.java | 31 +
.../org/jgroups/util/ExternalStrings.java | 841 ++
.../gemstone/org/jgroups/util/GFLogWriter.java | 55 +
.../org/jgroups/util/GFStringIdImpl.java | 68 +
.../org/jgroups/util/GemFireTracer.java | 468 +
.../org/jgroups/util/GetNetworkInterfaces.java | 34 +
.../org/jgroups/util/LinkedListQueue.java | 422 +
.../com/gemstone/org/jgroups/util/List.java | 462 +
.../jgroups/util/MagicObjectInputStream.java | 55 +
.../jgroups/util/MagicObjectOutputStream.java | 60 +
.../gemstone/org/jgroups/util/Marshaller.java | 152 +
.../org/jgroups/util/NullReadWriteLock.java | 25 +
.../com/gemstone/org/jgroups/util/NullSync.java | 26 +
.../gemstone/org/jgroups/util/PrintXMLTree.java | 168 +
.../com/gemstone/org/jgroups/util/Promise.java | 161 +
.../com/gemstone/org/jgroups/util/Proxy.java | 870 ++
.../com/gemstone/org/jgroups/util/Queue.java | 653 +
.../org/jgroups/util/Queue.java.concurrent | 113 +
.../com/gemstone/org/jgroups/util/Queue2.java | 715 +
.../org/jgroups/util/QueueClosedException.java | 29 +
.../com/gemstone/org/jgroups/util/Range.java | 58 +
.../org/jgroups/util/ReentrantLatch.java | 65 +
.../org/jgroups/util/ReusableThread.java | 295 +
.../java/com/gemstone/org/jgroups/util/Rsp.java | 82 +
.../com/gemstone/org/jgroups/util/RspList.java | 193 +
.../gemstone/org/jgroups/util/Scheduler.java | 270 +
.../org/jgroups/util/SchedulerListener.java | 29 +
.../gemstone/org/jgroups/util/SockCreator.java | 20 +
.../com/gemstone/org/jgroups/util/Stack.java | 108 +
.../gemstone/org/jgroups/util/Streamable.java | 26 +
.../org/jgroups/util/StreamableFixedID.java | 19 +
.../com/gemstone/org/jgroups/util/StringId.java | 49 +
.../gemstone/org/jgroups/util/ThreadPool.java | 105 +
.../org/jgroups/util/TimeScheduler.java | 720 +
.../gemstone/org/jgroups/util/TimedWriter.java | 295 +
.../com/gemstone/org/jgroups/util/Util.java | 1869 +++
.../org/jgroups/util/VersionedStreamable.java | 18 +
.../com/gemstone/org/jgroups/util/package.html | 5 +
.../java/com/gemstone/org/jgroups/util/todo.txt | 80 +
.../gemstone/org/jgroups/conf/jg-magic-map.dtd | 55 +
.../gemstone/org/jgroups/conf/jg-magic-map.xml | 269 +
.../com/gemstone/org/jgroups/log4j2-default.xml | 21 +
.../org/jgroups/stack/jboss-service.xml | 146 +
.../gemstone/org/jgroups/JChannelJUnitTest.java | 271 +
.../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 | 234 +
.../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 +
gemfire-json/src/main/java/org/json/CDL.java | 279 +
gemfire-json/src/main/java/org/json/Cookie.java | 169 +
.../src/main/java/org/json/CookieList.java | 90 +
gemfire-json/src/main/java/org/json/HTTP.java | 163 +
.../src/main/java/org/json/HTTPTokener.java | 77 +
.../src/main/java/org/json/JSONArray.java | 906 ++
.../src/main/java/org/json/JSONException.java | 28 +
gemfire-json/src/main/java/org/json/JSONML.java | 467 +
.../src/main/java/org/json/JSONObject.java | 1612 +++
.../src/main/java/org/json/JSONString.java | 18 +
.../src/main/java/org/json/JSONStringer.java | 78 +
.../src/main/java/org/json/JSONTokener.java | 446 +
.../src/main/java/org/json/JSONWriter.java | 327 +
gemfire-json/src/main/java/org/json/XML.java | 508 +
.../src/main/java/org/json/XMLTokener.java | 365 +
.../com/gemstone/junit/DistributedTest.java | 9 +
.../com/gemstone/junit/IntegrationTest.java | 9 +
.../com/gemstone/junit/PerformanceTest.java | 9 +
.../test/java/com/gemstone/junit/UnitTest.java | 9 +
.../test/java/com/gemstone/junit/WanTest.java | 8 +
gemfire-web-api/build.gradle | 42 +
.../web/controllers/AbstractBaseController.java | 832 ++
.../web/controllers/BaseControllerAdvice.java | 138 +
.../web/controllers/CommonCrudController.java | 240 +
.../controllers/FunctionAccessController.java | 237 +
.../web/controllers/PdxBasedCrudController.java | 345 +
.../web/controllers/QueryAccessController.java | 345 +
.../web/controllers/support/JSONTypes.java | 9 +
.../controllers/support/QueryResultTypes.java | 23 +
.../web/controllers/support/RegionData.java | 161 +
.../controllers/support/RegionEntryData.java | 96 +
.../support/RestServersResultCollector.java | 39 +
.../web/controllers/support/UpdateOp.java | 22 +
.../DataTypeNotSupportedException.java | 41 +
.../web/exception/GemfireRestException.java | 39 +
.../web/exception/MalformedJsonException.java | 42 +
.../web/exception/RegionNotFoundException.java | 35 +
.../exception/ResourceNotFoundException.java | 36 +
...stomMappingJackson2HttpMessageConverter.java | 145 +
.../web/swagger/config/RestApiPathProvider.java | 64 +
.../web/swagger/config/SwaggerConfig.java | 165 +
.../rest/internal/web/util/ArrayUtils.java | 51 +
.../rest/internal/web/util/DateTimeUtils.java | 45 +
.../internal/web/util/IdentifiableUtils.java | 100 +
.../rest/internal/web/util/JSONUtils.java | 244 +
.../rest/internal/web/util/JsonWriter.java | 588 +
.../rest/internal/web/util/NumberUtils.java | 137 +
.../rest/internal/web/util/ValidationUtils.java | 32 +
.../main/webapp/WEB-INF/gemfire-api-servlet.xml | 69 +
gemfire-web-api/src/main/webapp/WEB-INF/web.xml | 49 +
.../src/main/webapp/docs/css/reset.css | 125 +
.../src/main/webapp/docs/css/screen.css | 1221 ++
.../main/webapp/docs/images/explorer_icons.png | Bin 0 -> 5763 bytes
.../src/main/webapp/docs/images/logo_small.png | Bin 0 -> 770 bytes
.../main/webapp/docs/images/pet_store_api.png | Bin 0 -> 824 bytes
.../src/main/webapp/docs/images/throbber.gif | Bin 0 -> 9257 bytes
.../src/main/webapp/docs/images/wordnik_api.png | Bin 0 -> 980 bytes
gemfire-web-api/src/main/webapp/docs/index.html | 81 +
.../src/main/webapp/docs/lib/backbone-min.js | 38 +
.../main/webapp/docs/lib/handlebars-1.0.0.js | 2278 +++
.../main/webapp/docs/lib/highlight.7.3.pack.js | 1 +
.../main/webapp/docs/lib/jquery-1.8.0.min.js | 2 +
.../main/webapp/docs/lib/jquery.ba-bbq.min.js | 18 +
.../main/webapp/docs/lib/jquery.slideto.min.js | 1 +
.../main/webapp/docs/lib/jquery.wiggle.min.js | 8 +
.../src/main/webapp/docs/lib/shred.bundle.js | 2765 ++++
.../src/main/webapp/docs/lib/shred/content.js | 193 +
.../src/main/webapp/docs/lib/swagger-oauth.js | 211 +
.../src/main/webapp/docs/lib/swagger.js | 1527 ++
.../src/main/webapp/docs/lib/underscore-min.js | 32 +
gemfire-web-api/src/main/webapp/docs/o2c.html | 15 +
.../src/main/webapp/docs/swagger-ui.js | 2269 +++
.../src/main/webapp/docs/swagger-ui.min.js | 1 +
gemfire-web/build.gradle | 25 +
.../src/main/webapp/WEB-INF/gemfire-servlet.xml | 43 +
gemfire-web/src/main/webapp/WEB-INF/web.xml | 40 +
.../internal/web/AbstractWebTestCase.java | 88 +
.../ShellCommandsControllerJUnitTest.java | 206 +
...entVariablesHandlerInterceptorJUnitTest.java | 257 +
.../internal/web/domain/LinkIndexJUnitTest.java | 228 +
.../internal/web/domain/LinkJUnitTest.java | 115 +
.../domain/QueryParameterSourceJUnitTest.java | 84 +
.../web/http/ClientHttpRequestJUnitTest.java | 501 +
...ableObjectHttpMessageConverterJUnitTest.java | 157 +
.../RestHttpOperationInvokerJUnitTest.java | 445 +
.../SimpleHttpOperationInvokerJUnitTest.java | 190 +
.../web/util/ConvertUtilsJUnitTest.java | 162 +
.../internal/web/util/UriUtilsJUnitTest.java | 110 +
gradle.properties | 7 +
gradle/wrapper/gradle-wrapper.jar | Bin 0 -> 51018 bytes
gradle/wrapper/gradle-wrapper.properties | 6 +
gradlew | 164 +
gradlew.bat | 90 +
settings.gradle | 10 +
3849 files changed, 1039268 insertions(+)
----------------------------------------------------------------------