Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id C0A09200BAC for ; Wed, 26 Oct 2016 23:54:50 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id BF074160AFD; Wed, 26 Oct 2016 21:54:50 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id B2AFE160AE1 for ; Wed, 26 Oct 2016 23:54:48 +0200 (CEST) Received: (qmail 12247 invoked by uid 500); 26 Oct 2016 21:54:47 -0000 Mailing-List: contact commits-help@geode.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@geode.incubator.apache.org Delivered-To: mailing list commits@geode.incubator.apache.org Received: (qmail 12238 invoked by uid 99); 26 Oct 2016 21:54:47 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd2-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 26 Oct 2016 21:54:47 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd2-us-west.apache.org (ASF Mail Server at spamd2-us-west.apache.org) with ESMTP id CEF361A9398 for ; Wed, 26 Oct 2016 21:54:46 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -6.219 X-Spam-Level: X-Spam-Status: No, score=-6.219 tagged_above=-999 required=6.31 tests=[KAM_ASCII_DIVIDERS=0.8, KAM_LAZY_DOMAIN_SECURITY=1, RCVD_IN_DNSWL_HI=-5, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RP_MATCHES_RCVD=-2.999] autolearn=disabled Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd2-us-west.apache.org [10.40.0.9]) (amavisd-new, port 10024) with ESMTP id Frrt-PKQy2b5 for ; Wed, 26 Oct 2016 21:54:27 +0000 (UTC) Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with SMTP id 5A71F5FC9A for ; Wed, 26 Oct 2016 21:54:08 +0000 (UTC) Received: (qmail 7378 invoked by uid 99); 26 Oct 2016 21:54:06 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 26 Oct 2016 21:54:06 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id D4593E0230; Wed, 26 Oct 2016 21:54:06 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: klund@apache.org To: commits@geode.incubator.apache.org Date: Wed, 26 Oct 2016 21:54:54 -0000 Message-Id: In-Reply-To: References: X-Mailer: ASF-Git Admin Mailer Subject: [50/50] [abbrv] incubator-geode git commit: Move Admin API to internal archived-at: Wed, 26 Oct 2016 21:54:50 -0000 Move Admin API to internal Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/3bd8ef7f Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/3bd8ef7f Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/3bd8ef7f Branch: refs/heads/feature/GEODE-288 Commit: 3bd8ef7fb5b19bd520db0e5f1e90d8ab2e282059 Parents: 56917a2 Author: Kirk Lund Authored: Tue Oct 18 11:56:28 2016 -0700 Committer: Kirk Lund Committed: Wed Oct 26 14:53:15 2016 -0700 ---------------------------------------------------------------------- geode-core/build.gradle | 1 - .../java/org/apache/geode/DataSerializer.java | 2 +- .../org/apache/geode/admin/AdminConfig.java | 156 -- .../geode/admin/AdminDistributedSystem.java | 477 ---- .../admin/AdminDistributedSystemFactory.java | 161 -- .../org/apache/geode/admin/AdminException.java | 89 - .../apache/geode/admin/AdminXmlException.java | 47 - .../main/java/org/apache/geode/admin/Alert.java | 55 - .../java/org/apache/geode/admin/AlertLevel.java | 172 -- .../org/apache/geode/admin/AlertListener.java | 30 - .../org/apache/geode/admin/BackupStatus.java | 48 - .../geode/admin/CacheDoesNotExistException.java | 86 - .../apache/geode/admin/CacheHealthConfig.java | 156 -- .../org/apache/geode/admin/CacheServer.java | 45 - .../apache/geode/admin/CacheServerConfig.java | 54 - .../java/org/apache/geode/admin/CacheVm.java | 37 - .../org/apache/geode/admin/CacheVmConfig.java | 53 - .../geode/admin/ConfigurationParameter.java | 73 - .../geode/admin/DistributedSystemConfig.java | 642 ----- .../admin/DistributedSystemHealthConfig.java | 76 - .../apache/geode/admin/DistributionLocator.java | 46 - .../geode/admin/DistributionLocatorConfig.java | 89 - .../org/apache/geode/admin/GemFireHealth.java | 233 -- .../apache/geode/admin/GemFireHealthConfig.java | 57 - .../apache/geode/admin/GemFireMemberStatus.java | 698 ----- .../org/apache/geode/admin/ManagedEntity.java | 124 - .../apache/geode/admin/ManagedEntityConfig.java | 99 - .../apache/geode/admin/MemberHealthConfig.java | 141 - .../admin/OperationCancelledException.java | 48 - .../geode/admin/RegionNotFoundException.java | 39 - .../geode/admin/RegionSubRegionSnapshot.java | 192 -- .../geode/admin/RuntimeAdminException.java | 49 - .../java/org/apache/geode/admin/Statistic.java | 65 - .../apache/geode/admin/StatisticResource.java | 85 - .../org/apache/geode/admin/SystemMember.java | 147 -- .../geode/admin/SystemMemberBridgeServer.java | 308 --- .../apache/geode/admin/SystemMemberCache.java | 204 -- .../geode/admin/SystemMemberCacheEvent.java | 33 - .../geode/admin/SystemMemberCacheListener.java | 72 - .../geode/admin/SystemMemberCacheServer.java | 308 --- .../apache/geode/admin/SystemMemberRegion.java | 321 --- .../geode/admin/SystemMemberRegionEvent.java | 32 - .../apache/geode/admin/SystemMemberType.java | 145 - .../geode/admin/SystemMembershipEvent.java | 40 - .../geode/admin/SystemMembershipListener.java | 61 - .../UnmodifiableConfigurationException.java | 88 - .../admin/internal/AbstractHealthEvaluator.java | 184 -- .../internal/AdminDistributedSystemImpl.java | 2476 ----------------- .../admin/internal/BackupDataStoreHelper.java | 76 - .../admin/internal/BackupDataStoreResult.java | 57 - .../geode/admin/internal/BackupStatusImpl.java | 61 - .../admin/internal/CacheHealthConfigImpl.java | 91 - .../admin/internal/CacheHealthEvaluator.java | 323 --- .../admin/internal/CacheServerConfigImpl.java | 136 - .../geode/admin/internal/CacheServerImpl.java | 199 -- .../internal/ConfigurationParameterImpl.java | 280 -- .../ConfigurationParameterListener.java | 34 - .../DisabledManagedEntityController.java | 91 - .../internal/DistributedSystemConfigImpl.java | 1130 -------- .../DistributedSystemHealthConfigImpl.java | 58 - .../DistributedSystemHealthEvaluator.java | 172 -- .../DistributedSystemHealthMonitor.java | 436 --- .../internal/DistributionLocatorConfigImpl.java | 192 -- .../admin/internal/DistributionLocatorImpl.java | 336 --- .../EnabledManagedEntityController.java | 411 --- .../admin/internal/FinishBackupRequest.java | 171 -- .../admin/internal/FinishBackupResponse.java | 78 - .../admin/internal/FlushToDiskRequest.java | 97 - .../admin/internal/FlushToDiskResponse.java | 45 - .../admin/internal/GemFireHealthConfigImpl.java | 83 - .../admin/internal/GemFireHealthEvaluator.java | 187 -- .../geode/admin/internal/GemFireHealthImpl.java | 535 ---- .../geode/admin/internal/InetAddressUtil.java | 209 -- .../admin/internal/InternalManagedEntity.java | 105 - .../geode/admin/internal/LogCollator.java | 137 - .../admin/internal/ManagedEntityConfigImpl.java | 262 -- .../admin/internal/ManagedEntityConfigXml.java | 170 -- .../ManagedEntityConfigXmlGenerator.java | 385 --- .../internal/ManagedEntityConfigXmlParser.java | 622 ----- .../admin/internal/ManagedEntityController.java | 73 - .../ManagedEntityControllerFactory.java | 60 - .../admin/internal/ManagedSystemMemberImpl.java | 271 -- .../admin/internal/MemberHealthConfigImpl.java | 95 - .../admin/internal/MemberHealthEvaluator.java | 242 -- .../admin/internal/PrepareBackupRequest.java | 132 - .../admin/internal/PrepareBackupResponse.java | 81 - .../geode/admin/internal/StatisticImpl.java | 96 - .../admin/internal/StatisticResourceImpl.java | 181 -- .../internal/SystemMemberBridgeServerImpl.java | 233 -- .../internal/SystemMemberCacheEventImpl.java | 60 - .../SystemMemberCacheEventProcessor.java | 147 -- .../admin/internal/SystemMemberCacheImpl.java | 312 --- .../geode/admin/internal/SystemMemberImpl.java | 505 ---- .../internal/SystemMemberRegionEventImpl.java | 62 - .../admin/internal/SystemMemberRegionImpl.java | 380 --- .../internal/SystemMembershipEventImpl.java | 70 - .../apache/geode/admin/internal/package.html | 53 - .../java/org/apache/geode/admin/jmx/Agent.java | 164 -- .../org/apache/geode/admin/jmx/AgentConfig.java | 883 ------- .../apache/geode/admin/jmx/AgentFactory.java | 51 - .../internal/AdminDistributedSystemJmxImpl.java | 2291 ---------------- .../admin/jmx/internal/AgentConfigImpl.java | 1794 ------------- .../geode/admin/jmx/internal/AgentImpl.java | 1618 ------------ .../geode/admin/jmx/internal/AgentLauncher.java | 888 ------- .../admin/jmx/internal/CacheServerJmxImpl.java | 641 ----- .../admin/jmx/internal/ConfigAttributeInfo.java | 76 - .../internal/ConfigurationParameterJmxImpl.java | 169 -- .../DistributedSystemHealthConfigJmxImpl.java | 107 - .../internal/DistributionLocatorJmxImpl.java | 185 -- .../admin/jmx/internal/DynamicManagedBean.java | 141 - .../internal/GemFireHealthConfigJmxImpl.java | 222 -- .../jmx/internal/GemFireHealthJmxImpl.java | 178 -- .../admin/jmx/internal/GenerateMBeanHTML.java | 513 ---- .../geode/admin/jmx/internal/MBeanUtil.java | 768 ------ .../admin/jmx/internal/MX4JModelMBean.java | 1239 --------- .../jmx/internal/MX4JServerSocketFactory.java | 160 -- .../geode/admin/jmx/internal/MailManager.java | 331 --- .../admin/jmx/internal/ManagedResource.java | 77 - .../admin/jmx/internal/ManagedResourceType.java | 209 -- .../jmx/internal/MemberInfoWithStatsMBean.java | 1352 ---------- .../admin/jmx/internal/RMIRegistryService.java | 237 -- .../jmx/internal/RMIRegistryServiceMBean.java | 84 - .../jmx/internal/RefreshNotificationType.java | 130 - .../jmx/internal/StatAlertNotification.java | 161 -- .../jmx/internal/StatAlertsAggregator.java | 124 - .../jmx/internal/StatisticAttributeInfo.java | 78 - .../jmx/internal/StatisticResourceJmxImpl.java | 360 --- .../SystemMemberBridgeServerJmxImpl.java | 134 - .../jmx/internal/SystemMemberCacheJmxImpl.java | 473 ---- .../admin/jmx/internal/SystemMemberJmx.java | 494 ---- .../admin/jmx/internal/SystemMemberJmxImpl.java | 592 ----- .../jmx/internal/SystemMemberRegionJmxImpl.java | 138 - .../geode/admin/jmx/internal/package.html | 166 -- .../org/apache/geode/admin/jmx/package.html | 28 - .../java/org/apache/geode/admin/package.html | 78 - .../main/java/org/apache/geode/cache/Cache.java | 3 +- .../ConflictingPersistentDataException.java | 1 - .../geode/cache/persistence/PersistentID.java | 2 +- .../RevokedPersistentDataException.java | 2 +- .../geode/distributed/DistributedSystem.java | 34 +- .../internal/DistributionManager.java | 2 +- .../distributed/internal/HealthMonitor.java | 2 +- .../distributed/internal/HealthMonitorImpl.java | 6 +- .../internal/InternalDistributedSystem.java | 5 +- .../org/apache/geode/internal/DSFIDFactory.java | 19 +- .../apache/geode/internal/MigrationServer.java | 2 +- .../org/apache/geode/internal/SystemAdmin.java | 6 +- .../internal/admin/ClientMembershipMessage.java | 2 +- .../apache/geode/internal/admin/GemFireVM.java | 19 +- .../geode/internal/admin/HealthListener.java | 5 +- .../geode/internal/admin/StatAlertsManager.java | 2 +- .../geode/internal/admin/api/AdminConfig.java | 156 ++ .../admin/api/AdminDistributedSystem.java | 476 ++++ .../api/AdminDistributedSystemFactory.java | 161 ++ .../internal/admin/api/AdminException.java | 89 + .../internal/admin/api/AdminXmlException.java | 47 + .../apache/geode/internal/admin/api/Alert.java | 55 + .../geode/internal/admin/api/AlertLevel.java | 172 ++ .../geode/internal/admin/api/AlertListener.java | 30 + .../geode/internal/admin/api/BackupStatus.java | 48 + .../admin/api/CacheDoesNotExistException.java | 86 + .../internal/admin/api/CacheHealthConfig.java | 156 ++ .../geode/internal/admin/api/CacheServer.java | 45 + .../internal/admin/api/CacheServerConfig.java | 54 + .../geode/internal/admin/api/CacheVm.java | 37 + .../geode/internal/admin/api/CacheVmConfig.java | 53 + .../admin/api/ConfigurationParameter.java | 73 + .../admin/api/DistributedSystemConfig.java | 642 +++++ .../api/DistributedSystemHealthConfig.java | 76 + .../internal/admin/api/DistributionLocator.java | 46 + .../admin/api/DistributionLocatorConfig.java | 89 + .../geode/internal/admin/api/GemFireHealth.java | 233 ++ .../internal/admin/api/GemFireHealthConfig.java | 57 + .../internal/admin/api/GemFireMemberStatus.java | 698 +++++ .../geode/internal/admin/api/ManagedEntity.java | 124 + .../internal/admin/api/ManagedEntityConfig.java | 99 + .../internal/admin/api/MemberHealthConfig.java | 141 + .../admin/api/OperationCancelledException.java | 48 + .../admin/api/RegionNotFoundException.java | 39 + .../admin/api/RegionSubRegionSnapshot.java | 192 ++ .../admin/api/RuntimeAdminException.java | 49 + .../geode/internal/admin/api/Statistic.java | 65 + .../internal/admin/api/StatisticResource.java | 85 + .../geode/internal/admin/api/SystemMember.java | 147 ++ .../admin/api/SystemMemberBridgeServer.java | 308 +++ .../internal/admin/api/SystemMemberCache.java | 204 ++ .../admin/api/SystemMemberCacheEvent.java | 33 + .../admin/api/SystemMemberCacheListener.java | 72 + .../admin/api/SystemMemberCacheServer.java | 308 +++ .../internal/admin/api/SystemMemberRegion.java | 321 +++ .../admin/api/SystemMemberRegionEvent.java | 32 + .../internal/admin/api/SystemMemberType.java | 145 + .../admin/api/SystemMembershipEvent.java | 40 + .../admin/api/SystemMembershipListener.java | 61 + .../api/UnmodifiableConfigurationException.java | 88 + .../admin/api/impl/AbstractHealthEvaluator.java | 184 ++ .../api/impl/AdminDistributedSystemImpl.java | 2495 ++++++++++++++++++ .../admin/api/impl/BackupDataStoreHelper.java | 76 + .../admin/api/impl/BackupDataStoreResult.java | 57 + .../admin/api/impl/BackupStatusImpl.java | 61 + .../admin/api/impl/CacheHealthConfigImpl.java | 91 + .../admin/api/impl/CacheHealthEvaluator.java | 323 +++ .../admin/api/impl/CacheServerConfigImpl.java | 136 + .../admin/api/impl/CacheServerImpl.java | 205 ++ .../api/impl/ConfigurationParameterImpl.java | 280 ++ .../impl/ConfigurationParameterListener.java | 34 + .../impl/DisabledManagedEntityController.java | 91 + .../api/impl/DistributedSystemConfigImpl.java | 1135 ++++++++ .../impl/DistributedSystemHealthConfigImpl.java | 58 + .../impl/DistributedSystemHealthEvaluator.java | 172 ++ .../impl/DistributedSystemHealthMonitor.java | 436 +++ .../api/impl/DistributionLocatorConfigImpl.java | 192 ++ .../admin/api/impl/DistributionLocatorImpl.java | 336 +++ .../impl/EnabledManagedEntityController.java | 411 +++ .../admin/api/impl/FinishBackupRequest.java | 171 ++ .../admin/api/impl/FinishBackupResponse.java | 78 + .../admin/api/impl/FlushToDiskRequest.java | 97 + .../admin/api/impl/FlushToDiskResponse.java | 45 + .../admin/api/impl/GemFireHealthConfigImpl.java | 83 + .../admin/api/impl/GemFireHealthEvaluator.java | 187 ++ .../admin/api/impl/GemFireHealthImpl.java | 538 ++++ .../admin/api/impl/InetAddressUtil.java | 209 ++ .../admin/api/impl/InternalManagedEntity.java | 105 + .../internal/admin/api/impl/LogCollator.java | 137 + .../admin/api/impl/ManagedEntityConfigImpl.java | 260 ++ .../admin/api/impl/ManagedEntityConfigXml.java | 171 ++ .../impl/ManagedEntityConfigXmlGenerator.java | 392 +++ .../api/impl/ManagedEntityConfigXmlParser.java | 626 +++++ .../admin/api/impl/ManagedEntityController.java | 73 + .../impl/ManagedEntityControllerFactory.java | 60 + .../admin/api/impl/ManagedSystemMemberImpl.java | 271 ++ .../admin/api/impl/MemberHealthConfigImpl.java | 95 + .../admin/api/impl/MemberHealthEvaluator.java | 243 ++ .../admin/api/impl/PrepareBackupRequest.java | 132 + .../admin/api/impl/PrepareBackupResponse.java | 81 + .../internal/admin/api/impl/StatisticImpl.java | 97 + .../admin/api/impl/StatisticResourceImpl.java | 182 ++ .../api/impl/SystemMemberBridgeServerImpl.java | 233 ++ .../api/impl/SystemMemberCacheEventImpl.java | 61 + .../impl/SystemMemberCacheEventProcessor.java | 147 ++ .../admin/api/impl/SystemMemberCacheImpl.java | 320 +++ .../admin/api/impl/SystemMemberImpl.java | 512 ++++ .../api/impl/SystemMemberRegionEventImpl.java | 63 + .../admin/api/impl/SystemMemberRegionImpl.java | 381 +++ .../api/impl/SystemMembershipEventImpl.java | 71 + .../geode/internal/admin/api/impl/package.html | 53 + .../geode/internal/admin/api/jmx/Agent.java | 164 ++ .../internal/admin/api/jmx/AgentConfig.java | 883 +++++++ .../internal/admin/api/jmx/AgentFactory.java | 50 + .../jmx/impl/AdminDistributedSystemJmxImpl.java | 2304 ++++++++++++++++ .../admin/api/jmx/impl/AgentConfigImpl.java | 1794 +++++++++++++ .../internal/admin/api/jmx/impl/AgentImpl.java | 1618 ++++++++++++ .../admin/api/jmx/impl/AgentLauncher.java | 888 +++++++ .../admin/api/jmx/impl/CacheServerJmxImpl.java | 642 +++++ .../admin/api/jmx/impl/ConfigAttributeInfo.java | 76 + .../jmx/impl/ConfigurationParameterJmxImpl.java | 170 ++ .../DistributedSystemHealthConfigJmxImpl.java | 106 + .../jmx/impl/DistributionLocatorJmxImpl.java | 166 ++ .../admin/api/jmx/impl/DynamicManagedBean.java | 141 + .../jmx/impl/GemFireHealthConfigJmxImpl.java | 222 ++ .../api/jmx/impl/GemFireHealthJmxImpl.java | 178 ++ .../admin/api/jmx/impl/GenerateMBeanHTML.java | 511 ++++ .../internal/admin/api/jmx/impl/MBeanUtil.java | 765 ++++++ .../admin/api/jmx/impl/MX4JModelMBean.java | 1239 +++++++++ .../api/jmx/impl/MX4JServerSocketFactory.java | 160 ++ .../admin/api/jmx/impl/MailManager.java | 331 +++ .../admin/api/jmx/impl/ManagedResource.java | 77 + .../admin/api/jmx/impl/ManagedResourceType.java | 222 ++ .../api/jmx/impl/MemberInfoWithStatsMBean.java | 1360 ++++++++++ .../admin/api/jmx/impl/RMIRegistryService.java | 237 ++ .../api/jmx/impl/RMIRegistryServiceMBean.java | 84 + .../api/jmx/impl/RefreshNotificationType.java | 130 + .../api/jmx/impl/StatAlertNotification.java | 161 ++ .../api/jmx/impl/StatAlertsAggregator.java | 124 + .../api/jmx/impl/StatisticAttributeInfo.java | 78 + .../api/jmx/impl/StatisticResourceJmxImpl.java | 360 +++ .../impl/SystemMemberBridgeServerJmxImpl.java | 135 + .../api/jmx/impl/SystemMemberCacheJmxImpl.java | 474 ++++ .../admin/api/jmx/impl/SystemMemberJmx.java | 501 ++++ .../admin/api/jmx/impl/SystemMemberJmxImpl.java | 591 +++++ .../api/jmx/impl/SystemMemberRegionJmxImpl.java | 141 + .../internal/admin/api/jmx/impl/package.html | 166 ++ .../geode/internal/admin/api/jmx/package.html | 28 + .../geode/internal/admin/api/package.html | 78 + .../admin/remote/AddHealthListenerRequest.java | 2 +- .../admin/remote/AddHealthListenerResponse.java | 2 +- .../internal/admin/remote/AdminRegion.java | 3 +- .../internal/admin/remote/AdminRequest.java | 2 +- .../internal/admin/remote/AdminWaiters.java | 4 +- .../admin/remote/AlertLevelChangeMessage.java | 2 +- .../admin/remote/AlertListenerMessage.java | 2 +- .../admin/remote/AlertsNotificationMessage.java | 4 +- .../remote/FetchHealthDiagnosisRequest.java | 2 +- .../remote/FetchHealthDiagnosisResponse.java | 2 +- .../admin/remote/HealthListenerMessage.java | 2 +- .../remote/RefreshMemberSnapshotRequest.java | 4 +- .../remote/RefreshMemberSnapshotResponse.java | 4 +- .../admin/remote/RegionAdminRequest.java | 4 +- .../remote/RegionSubRegionsSizeResponse.java | 2 +- .../internal/admin/remote/RemoteGemFireVM.java | 17 +- .../admin/remote/RemoteGfManagerAgent.java | 4 +- .../admin/statalerts/StatisticInfoImpl.java | 2 +- .../geode/internal/cache/GemFireCacheImpl.java | 2 +- .../geode/internal/cache/LocalRegion.java | 3 +- .../internal/cache/RemoteFetchEntryMessage.java | 2 +- .../cache/partitioned/FetchEntryMessage.java | 2 +- .../apache/geode/internal/cache/properties.html | 18 +- .../snapshot/CacheSnapshotServiceImpl.java | 2 +- .../geode/internal/net/SocketCreator.java | 2 +- .../internal/beans/DistributedSystemBridge.java | 4 +- .../cli/commands/DiskStoreCommands.java | 6 +- .../src/main/java/org/apache/geode/package.html | 2 +- .../internal/doc-files/mbeans-descriptors.dtd | 247 ++ .../geode/admin/api/jmx/mbeans-descriptors.xml | 1452 ++++++++++ .../internal/doc-files/mbeans-descriptors.dtd | 247 -- .../geode/admin/jmx/mbeans-descriptors.xml | 1452 ---------- .../org/apache/geode/admin/AdminTestHelper.java | 45 - .../apache/geode/admin/AlertLevelJUnitTest.java | 64 - .../BindDistributedSystemJUnitTest.java | 87 - .../internal/CacheHealthEvaluatorJUnitTest.java | 207 -- .../internal/DistributedSystemTestCase.java | 67 - .../admin/internal/HealthEvaluatorTestCase.java | 76 - .../MemberHealthEvaluatorJUnitTest.java | 101 - .../query/dunit/QueryUsingPoolDUnitTest.java | 26 +- .../cache/query/dunit/RemoteQueryDUnitTest.java | 24 +- .../ConsoleDistributionManagerDUnitTest.java | 3 +- .../internal/DistributionManagerDUnitTest.java | 12 +- .../geode/internal/AvailablePortJUnitTest.java | 2 +- .../internal/admin/api/AdminTestHelper.java | 46 + .../internal/admin/api/AlertLevelJUnitTest.java | 65 + .../impl/BindDistributedSystemJUnitTest.java | 89 + .../api/impl/CacheHealthEvaluatorJUnitTest.java | 208 ++ .../api/impl/DistributedSystemTestCase.java | 67 + .../admin/api/impl/HealthEvaluatorTestCase.java | 78 + .../impl/MemberHealthEvaluatorJUnitTest.java | 101 + .../geode/internal/cache/BackupDUnitTest.java | 8 +- .../cache/IncrementalBackupDUnitTest.java | 12 +- ...tentColocatedPartitionedRegionDUnitTest.java | 5 +- .../PersistentPartitionedRegionTestBase.java | 10 +- .../cache/partitioned/ShutdownAllDUnitTest.java | 8 +- .../PersistentRecoveryOrderDUnitTest.java | 8 +- .../beans/DistributedSystemBridgeJUnitTest.java | 6 +- .../internal/JUnit4DistributedTestCase.java | 3 +- .../sanctionedDataSerializables.txt | 64 +- .../codeAnalysis/sanctionedSerializables.txt | 63 +- ...downAllPersistentGatewaySenderDUnitTest.java | 8 +- gradle/rat.gradle | 2 +- 347 files changed, 39056 insertions(+), 39008 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/3bd8ef7f/geode-core/build.gradle ---------------------------------------------------------------------- diff --git a/geode-core/build.gradle b/geode-core/build.gradle index 067bafc..6669b27 100755 --- a/geode-core/build.gradle +++ b/geode-core/build.gradle @@ -170,7 +170,6 @@ jar { exclude 'org/apache/geode/management/internal/web/**' exclude 'org/apache/geode/internal/i18n/StringIdResourceBundle_ja.txt' - exclude 'org/apache/geode/admin/doc-files/ds4_0.dtd' } task webJar (type: Jar, dependsOn: classes) { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/3bd8ef7f/geode-core/src/main/java/org/apache/geode/DataSerializer.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/DataSerializer.java b/geode-core/src/main/java/org/apache/geode/DataSerializer.java index 09b6ced..60c4411 100644 --- a/geode-core/src/main/java/org/apache/geode/DataSerializer.java +++ b/geode-core/src/main/java/org/apache/geode/DataSerializer.java @@ -48,7 +48,7 @@ import java.util.concurrent.ConcurrentMap; import org.apache.logging.log4j.Logger; -import org.apache.geode.admin.RegionNotFoundException; +import org.apache.geode.internal.admin.api.RegionNotFoundException; import org.apache.geode.cache.Cache; import org.apache.geode.cache.CacheFactory; import org.apache.geode.cache.Region; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/3bd8ef7f/geode-core/src/main/java/org/apache/geode/admin/AdminConfig.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/AdminConfig.java b/geode-core/src/main/java/org/apache/geode/admin/AdminConfig.java deleted file mode 100755 index ec5ed73..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/AdminConfig.java +++ /dev/null @@ -1,156 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.geode.admin; - -import org.apache.geode.internal.i18n.LocalizedStrings; - -import java.io.BufferedReader; -import java.io.File; -import java.io.FileOutputStream; -import java.io.FileReader; -import java.io.IOException; -import java.io.PrintStream; -import java.util.ArrayList; -import java.util.Date; - - -/** - * AdminConfig loads/stores the member information list. The list contains - * all of the members being monitored. - * - * Config must be of the format: - *

- *

  • Name=What you want displayed as a name for the instance - *
  • Type=SERVER|CLIENT - *
  • Host=A valid hostname or IP Address where the instance is - * running - *
  • Port=The port you are using to open the monitor port for - * the instance - * @deprecated as of 7.0 use the management package instead - */ -public class AdminConfig -{ - // Name, Type, Host, Port - public static Entry[] loadConfig(File file) throws IOException - { - - // Place all lines into stack - ArrayList entryList = new ArrayList(); - FileReader reader = null; - BufferedReader fileReader = null; - try { - reader = new FileReader(file); - fileReader = new BufferedReader(reader); - // Read the first line. - String line = fileReader.readLine(); - - while (line != null) { - line = line.trim(); - - // Replace tabs with spaces - line = line.replace('\t', ' '); - - // Skip all empty and comment lines - if (line.length() != 0 && line.startsWith("#") == false) { - try { - entryList.add(new Entry(line)); - } catch (Exception ex) { - // ignore - drop any lines that are not valid - } - } - line = fileReader.readLine(); - } - } - finally { - if (fileReader != null) { - fileReader.close(); - } - if (reader != null) { - reader.close(); - } - } - - return (Entry[])entryList.toArray(new Entry[0]); - } - - public static void storeConfig(File file, AdminConfig.Entry entries[]) throws IOException - { - FileOutputStream fos = null; - PrintStream ps = null; - try { - fos = new FileOutputStream(file); - ps = new PrintStream(fos); - - // Header - ps.print("#"); - ps.println(LocalizedStrings.AdminConfig_THIS_FILE_IS_GENERATED_BY_ADMINCONSOLE_EDIT_AS_YOU_WISH_BUT_IT_WILL_BE_OVERWRITTEN_IF_IT_IS_MODIFIED_IN_ADMINCONSOLE.toLocalizedString()); - ps.println("#"); - ps.println(LocalizedStrings.AdminConfig_MODIFIED_0.toLocalizedString(new Date())); - ps.println("#"); - ps.println("# Name, Type, Host, Port"); - ps.println("#"); - int len = entries.length; - for (int i = 0; i < len; i++) { - ps.println(entries[i].toString()); - } - ps.flush(); - } - finally { - if (ps != null) { - ps.close(); - } - if (fos != null) { - fos.close(); - } - } - } - - - public static class Entry - { - public String name; - public String type; - public String host; - public int port; - - public Entry(String line) - { - // Split - String split[] = line.split(","); - - // Convert line to parameters - name = split[0].trim(); - type = split[1].trim(); - host = split[2].trim(); - port = Integer.parseInt(split[3]); - } - - public Entry(String name, String type, String host, int port) - { - this.name = name; - this.type = type; - this.host = host; - this.port = port; - } - - @Override // GemStoneAddition - public String toString() - { - return name + "," + type + "," + host + "," + port; - } - } -} http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/3bd8ef7f/geode-core/src/main/java/org/apache/geode/admin/AdminDistributedSystem.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/AdminDistributedSystem.java b/geode-core/src/main/java/org/apache/geode/admin/AdminDistributedSystem.java deleted file mode 100755 index 982c4f1..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/AdminDistributedSystem.java +++ /dev/null @@ -1,477 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.geode.admin; - -import org.apache.geode.LogWriter; -import org.apache.geode.cache.DataPolicy; -import org.apache.geode.cache.persistence.PersistentID; -import org.apache.geode.distributed.DistributedMember; - -import java.io.File; -import java.net.InetAddress; -import java.util.Map; -import java.util.Set; -import java.util.UUID; - -/** - * Administrative interface for managing an entire GemFire distributed - * system. This interface should not be confused with {@link - * org.apache.geode.distributed.DistributedSystem - * DistributedSystem} that represents a connection to a GemFire - * distributed system. - * - * @see AdminDistributedSystemFactory - * - * @since GemFire 3.5 - * @deprecated as of 7.0 use the management package instead - */ -public interface AdminDistributedSystem { - - /** - * Retrieves the unique id for this system. - */ - public String getId(); - - /** - * Retrieves display friendly name for this system. If this administrative - * VM defined an optional name for its connection to the distributed system, - * that name will be returned. Otherwise the returned value will be {@link - * org.apache.geode.admin.AdminDistributedSystem#getId}. - */ - public String getName(); - - /** - * Retrieves the remote command and formatting this system should use to - * access and/or manipulate resources on remote machines. - */ - public String getRemoteCommand(); - - /** - * Sets the remote command and formatting this system should use to access - * and/or manipulate resources on remote machines. - */ - public void setRemoteCommand(String remoteCommand); - - /** - * Sets the lowest level of alert that should be delivered to the - * {@link AlertListener}s registered on this - * AdminDistributedSystem. The default level is {@link - * AlertLevel#WARNING}. - */ - public void setAlertLevel(AlertLevel level); - - /** - * Returns the lowest level of alerts that should be delivered to - * the {@link AlertListener}s registered on this - * AdminDistributedSystem. - * - * @see #setAlertLevel - */ - public AlertLevel getAlertLevel(); - - /** - * Sets the lowest level of alert that should be delivered to the - * {@link AlertListener}s registered on this - * AdminDistributedSystem. The default level is {@link - * AlertLevel#WARNING}. - */ - public void setAlertLevelAsString(String level); - - /** - * Returns the lowest level of alerts that should be delivered to - * the {@link AlertListener}s registered on this - * AdminDistributedSystem. - * - * @see #setAlertLevelAsString - */ - public String getAlertLevelAsString(); - - /** - * Registers an AlertListener that will receive all - * alerts that are at or above the {@linkplain #setAlertLevel alert - * level}. - */ - public void addAlertListener(AlertListener listener); - - /** - * Unregisters an AlertListener - */ - public void removeAlertListener(AlertListener listener); - - /** - * Retrieves the multicast address in use by this system. - */ - public String getMcastAddress(); - - /** - * Retrieves the multicast port in use by this system. - */ - public int getMcastPort(); - - /** - * Retrieves comma-delimited list locators to be used if multi-cast port is - * zero. Format of each locators must be host[port]. - */ - public String getLocators(); - - /** - * Returns true if this system has enabled the use of multicast for communications - */ - public boolean isMcastEnabled(); - - /** - * Returns true if any members of this system are currently running. - */ - public boolean isRunning(); - - /** - * Returns true if this is currently connected to the - * system. - */ - public boolean isConnected(); - - /** - * Starts all managed entities that are not currently running. - * - * @throws AdminException - * If a problem is encountered while starting the managed - * entities. - */ - public void start() throws AdminException; - - /** - * Stops all managed entities that are currently running. - * - * @throws AdminException - * If a problem is encountered while starting the managed - * entities. - */ - public void stop() throws AdminException; - - /** - * Merges and returns all system logs as a single formatted log. - */ - public String displayMergedLogs(); - - /** - * Retrieves the license information for this installation of GemFire. - * - * @deprecated Removed licensing in 8.0. - */ - public java.util.Properties getLicense(); - - /** - * Creates a new DistributionLocator that is ready to - * {@linkplain DistributionLocator#getConfig configure} and - * {@linkplain #start start}. - * - *

    - * - * It is presumed that the newly-added locator is used to discover - * members of the distributed system. That is, the host/port of the - * new locator is appended to the {@link #getLocators locators} - * attribute of this AdminDistributedSystem. - */ - public DistributionLocator addDistributionLocator(); - - /** - * Returns array of DistributionLocators administered - * by this AdminDistributedSystem. - */ - public DistributionLocator[] getDistributionLocators(); - - /** - * Retrieves SystemMember instances for every - * application that is running and currently connection to this - * system. Note that this list does not include dedicated - * {@linkplain #getCacheVms cache server vms}. - */ - public SystemMember[] getSystemMemberApplications() - throws org.apache.geode.admin.AdminException; - - /** - * Display in readable format the latest Alert in this distributed system. - */ - public String getLatestAlert(); - - /** - * Returns an object for monitoring the health of GemFire. - */ - public GemFireHealth getGemFireHealth(); - - /** - * Connects to the distributed system. This method will return - * immediately after spawning a background thread that connects to - * the distributed system. As a result, a - * AdminDistributedSystem can be "connected" to before - * any members of the system have been started or have been seen. - * The {@link #waitToBeConnected} method will wait for the - * connection to be made. - * - * @see #isConnected - * @see #isRunning - * @see #waitToBeConnected - */ - public void connect(); - - /** - * Wait for up to a given number of milliseconds for the connection - * to the distributed system to be made. - * - * @param timeout - * The number of milliseconds to wait for the connection to - * to be made. - * - * @return Whether or not the connection was made. - * false, if the method times out - * - * @throws InterruptedException - * If the thread invoking this method is interrupted while - * waiting. - * @throws IllegalStateException - * If {@link #connect} has not yet been called. - */ - public boolean waitToBeConnected(long timeout) - throws InterruptedException; - - /** - * Disconnects from the distributed system. - */ - public void disconnect(); - - /** Returns this system's configuration .*/ - public DistributedSystemConfig getConfig(); - - /** - * Registers a listener that receives callbacks when a member joins - * or leaves the distributed system. - */ - public void addMembershipListener(SystemMembershipListener listener); - - /** - * Unregisters a membership listener - * - * @see #addMembershipListener - */ - public void removeMembershipListener(SystemMembershipListener listener); - - /** - * Registers a cache event listener. - * Does nothing if the listener is already registered. The listeners are called - * in the order they are registered. - * @param listener the listener to register. - * @since GemFire 5.0 - */ - public void addCacheListener(SystemMemberCacheListener listener); - - /** - * Unregisters a cache listener. Does nothing if the listener is - * not registered. - * @param listener the listener to unregister. - * @since GemFire 5.0 - */ - public void removeCacheListener(SystemMemberCacheListener listener); - - /** - * Creates a new cache server that is ready to {@linkplain - * CacheServerConfig configure} and {@linkplain #start - * start}. - * - * @since GemFire 4.0 - * @deprecated as of 5.7 use {@link #addCacheVm} instead. - */ - @Deprecated - public CacheServer addCacheServer() throws AdminException; - - /** - * Returns all of the dedicated cache server members of the - * distributed system. Because they are not managed entities, - * application VMs that host a server cache are not included in the - * array. - * - * @since GemFire 4.0 - * @deprecated as of 5.7 use {@link #getCacheVms} instead. - */ - @Deprecated - public CacheServer[] getCacheServers() throws AdminException; - - /** - * Returns all the cache server members of the distributed system which are - * hosting a client queue for the particular durable-client having the given - * durableClientId - * - * @param durableClientId - - * durable-id of the client - * @return array of CacheServer(s) having the queue for the durable client - * @throws AdminException - * - * @since GemFire 5.6 - */ - public CacheServer[] getCacheServers(String durableClientId) - throws AdminException; - - /** - * Creates a new cache vm that is ready to {@linkplain - * CacheVmConfig configure} and {@linkplain #start - * start}. - * - * @since GemFire 5.7 - */ - public CacheVm addCacheVm() throws AdminException; - - /** - * Returns all of the dedicated cache server vm members of the - * distributed system. Because they are not managed entities, - * application VMs that host a server cache are not included in the - * array. - * - * @since GemFire 5.7 - */ - public CacheVm[] getCacheVms() throws AdminException; - - /** - * Returns the administrative SystemMember specified by the {@link - * org.apache.geode.distributed.DistributedMember}. - * - * @param distributedMember the distributed member to lookup - * @return administrative SystemMember for that distributed member - * @since GemFire 5.0 - */ - public SystemMember lookupSystemMember(DistributedMember distributedMember) - throws AdminException; - - /** - * Indicate to the distributed system that persistent files have been lost. - * When a member recovers from a set of persistent files, it will wait for - * other members that were also persisting the same region to start up. If the - * persistent files for those other members were lost, this method can be used - * to tell the remaining members to stop waiting for the lost data. - * - * @param host - * The host of the member whose files were lost. - * @param directory - * The directory where those files resided. - * @since GemFire 6.5 - * @deprecated use {@link #revokePersistentMember(UUID)} instead - */ - public void revokePersistentMember(InetAddress host, String directory) throws AdminException; - - /** - * Indicate to the distributed system that persistent files have been lost. - * When a member recovers from a set of persistent files, it will wait for - * other members that were also persisting the same region to start up. If the - * persistent files for those other members were lost, this method can be used - * to tell the remaining members to stop waiting for the lost data. - * - * @param diskStoreID - * The unique id of the disk store which you are revoking. The unique - * id can be discovered from {@link #getMissingPersistentMembers()} - * - * @since GemFire 7.0 - */ - public void revokePersistentMember(UUID diskStoreID) throws AdminException; - - /** - * Retrieve the set of persistent files that the existing members are waiting - * for. See {@link AdminDistributedSystem#revokePersistentMember(InetAddress, String)} - * @return The persistent members that were known to the existing persistent members, - * when the existing members were last online. - * @throws AdminException - * @since GemFire 6.5 - * - */ - public Set getMissingPersistentMembers() throws AdminException; - - /** - * Shuts down all the members of the distributed system with a cache that the admin - * member is connected to, excluding the stand-alone locators. Calling this method - * will ensure that regions with the {@link DataPolicy#PERSISTENT_PARTITION} to - * be shutdown in a way which allows for a faster recovery when the members are - * restarted. - * - * Killing individual members can lead to inconsistencies in the members persistent - * data, which gemfire repairs on startup. Calling shutDownAllMembers makes sure - * that the persistent files are consistent on shutdown, which makes recovery faster. - * - * This is equivalent to calling shutDownAllMembers(0); - * @return The set of members that were shutdown - * @since GemFire 6.5 - */ - public Set shutDownAllMembers() throws AdminException; - - /** - * Shuts down all the members of the distributed system with a cache that the - * admin member is connected to, excluding the stand-alone locators. Calling - * this method will ensure that regions with the - * {@link DataPolicy#PERSISTENT_PARTITION} to be shutdown in a way which - * allows for a faster recovery when the members are restarted. - * - * Killing individual members can lead to inconsistencies in the members - * persistent data, which gemfire repairs on startup. Calling - * shutDownAllMembers makes sure that the persistent files are consistent on - * shutdown, which makes recovery faster. - * - * @param timeout The amount of time to wait (in milliseconds) for the shutdown all to - * complete. - * @return The set of members that were shutdown, or null if the timeout is exceeded. - * - * @since GemFire 6.5 - */ - public Set shutDownAllMembers(long timeout) throws AdminException; - - /** - * Backup the persistent files for all of the members of the distributed - * system that the admin member is connected to. - * - * @param targetDir The directory where each member's backup should be placed. - * - * @return The status of the backup, which includes the set of members - * that were backed up and the set of members that were known to be - * offline at the time of backup. - * @since GemFire 6.5 - */ - public BackupStatus backupAllMembers(File targetDir) throws AdminException; - - /** - * Incrementally backup the persistent files for all of the members of the distributed - * system that the admin member is connected to. Only new operation log files since the previous backup will be copied during this backup. - * The generated restore script will reference and copy operation log files from the previous backup. - * - * @param targetDir The directory where each member's backup should be placed. - * @param baselineDir The directory of a previous backup. - * If this parameter is null or the directory does not exist (on a member by member basis) - * a full backup will be performed for the member. - * - * @return The status of the backup, which includes the set of members - * that were backed up and the set of members that were known to be - * offline at the time of backup. - * @since GemFire 6.5 - */ - public BackupStatus backupAllMembers(File targetDir,File baselineDir) throws AdminException; - - /** - * Compact the persistent files for all of the members of the distributed - * system that the admin member connected to. - * - * This is equivalent to calling {DiskStore#forceCompaction} on all members. - * - * @return The set of members that compacted their disk stores. - * @since GemFire 6.5 - */ - public Map> compactAllDiskStores() throws AdminException; -} - http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/3bd8ef7f/geode-core/src/main/java/org/apache/geode/admin/AdminDistributedSystemFactory.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/AdminDistributedSystemFactory.java b/geode-core/src/main/java/org/apache/geode/admin/AdminDistributedSystemFactory.java deleted file mode 100755 index 6f2af1f..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/AdminDistributedSystemFactory.java +++ /dev/null @@ -1,161 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.geode.admin; - -import org.apache.geode.admin.internal.AdminDistributedSystemImpl; -import org.apache.geode.admin.internal.DistributedSystemConfigImpl; -import org.apache.geode.distributed.DistributedSystem; -import org.apache.geode.distributed.internal.DistributionConfig; -import org.apache.geode.distributed.internal.DistributionConfigImpl; -import org.apache.geode.distributed.internal.InternalDistributedSystem; -import org.apache.geode.i18n.LogWriterI18n; -import org.apache.geode.internal.i18n.LocalizedStrings; -import org.apache.geode.internal.logging.LocalLogWriter; - -import java.util.Properties; - -/** - * Factory for creating GemFire administration entities. - * - * @since GemFire 3.5 - * @deprecated as of 7.0 use the management package instead - */ -public class AdminDistributedSystemFactory { - - /** - * Sets the address this VM should bind to when connecting to the distributed - * system. This involves a system property, so using this option will limit - * all connections to distributed systems to this one network interface. - *

    - * Using a null or empty bindAddress will clear the usage of this option and - * connections to distributed systems will return to using all available - * network interfaces. - *

    - * This method always throws UnsupportedOperationException because it is - * now deprecated and is unsafe to use. Please use {@link - * DistributedSystemConfig#setBindAddress} instead. - * - * @param bindAddress machine name or IP address to bind to - * @throws UnsupportedOperationException because of deprecation - * @deprecated Use {@link DistributedSystemConfig#setBindAddress} instead. - */ - @Deprecated - public static void bindToAddress(String bindAddress) { - throw new UnsupportedOperationException(LocalizedStrings.AdminDistributedSystemFactory_PLEASE_USE_DISTRIBUTEDSYSTEMCONFIGSETBINDADDRESS_INSTEAD.toLocalizedString()); - } - - /** - * Defines a "default" distributed system configuration based on VM - * system properties and the content of - * gemfire.properties. The {@linkplain - * DistributedSystemConfig#DEFAULT_REMOTE_COMMAND} default remote - * command is used. - * - * @see DistributedSystem#connect - */ - public static DistributedSystemConfig defineDistributedSystem() { - DistributionConfig dc = new DistributionConfigImpl(new Properties()); - - String remoteCommand = - DistributedSystemConfig.DEFAULT_REMOTE_COMMAND; - return new DistributedSystemConfigImpl(dc, remoteCommand); - } - - /** - * Call this method with a value of true - * to dedicate the VM to GemFire administration only. - * Default is false. - *

    This method must be called before calling - * {@link AdminDistributedSystem#connect}. It must also be called - * before {@link DistributedSystem#connect} is when creating a colocated distributed system. - *

    - * Once it has been enabled be careful to only use GemFire APIs from the - * org.apache.geode.admin package. In particular do not create - * a {@link org.apache.geode.cache.Cache} or a normal {@link DistributedSystem}. - * @param adminOnly true if this VM should be limited to administration APIs; - * false if this VM should allow all GemFire APIs. - * @throws IllegalStateException if a {@link DistributedSystem} - * or {@link AdminDistributedSystem} connection already exists. - * - * @since GemFire 5.7 - */ - public static void setEnableAdministrationOnly(boolean adminOnly) { - InternalDistributedSystem.setEnableAdministrationOnly(adminOnly); - } - - /** - * Defines a distributed system configuration for administering the - * distributed system to which this VM is currently connected. The - * DistributedSystem is used to configure the discovery - * mechanism (multicast or locators), bind address, SSL attributes, - * as well as the logger of the - * DistributedSystemConfig. Note that the distributed - * system will not be able to be administered until the {@link - * AdminDistributedSystem#connect connect} method is invoked. - * - * @param system - * A connection to the distributed system - * @param remoteCommand - * The shell command that is used to launch processes that - * run on remote machines. If null, then the - * {@linkplain DistributedSystemConfig#DEFAULT_REMOTE_COMMAND - * default} will be used. - * - * @since GemFire 4.0 - */ - public static DistributedSystemConfig - defineDistributedSystem(DistributedSystem system, - String remoteCommand) - throws AdminException { - - InternalDistributedSystem internal = - (InternalDistributedSystem) system; - if (remoteCommand == null) { - remoteCommand = DistributedSystemConfig.DEFAULT_REMOTE_COMMAND; - } - - DistributedSystemConfigImpl impl = - new DistributedSystemConfigImpl(internal.getConfig(), - remoteCommand); - return impl; - } - - /** - * Returns the distributed system for administrative monitoring and - * managing. You must then call {@link - * AdminDistributedSystem#connect} before interacting with the - * actual system. - * - * @param config configuration definition of the system to administer - * @return administrative interface for a distributed system - */ - public static AdminDistributedSystem getDistributedSystem(DistributedSystemConfig config) { - return new AdminDistributedSystemImpl((DistributedSystemConfigImpl)config); - } - - /** - * Returns a default GemFire LogWriterI18n for logging. This LogWriterI18n will - * log to standard out. - * - * @return a GemFire LogWriterI18n for logging - */ - public static LogWriterI18n getLogWriter() { - return new LocalLogWriter(DistributionConfig.DEFAULT_LOG_LEVEL); - } - -} - http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/3bd8ef7f/geode-core/src/main/java/org/apache/geode/admin/AdminException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/AdminException.java b/geode-core/src/main/java/org/apache/geode/admin/AdminException.java deleted file mode 100755 index e7d574d..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/AdminException.java +++ /dev/null @@ -1,89 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.geode.admin; - -import org.apache.geode.GemFireCheckedException; - -/** - * An AdminException is thrown when administration or monitoring - * of GemFire fails. - * - * @since GemFire 3.5 - * - * @deprecated as of 7.0 use the management package instead - */ -public class AdminException extends GemFireCheckedException { -private static final long serialVersionUID = 879398950879472021L; - - /** - * Constructs a new exception with null as its detail message. - * The cause is not initialized, and may subsequently be initialized by a - * call to {@link Throwable#initCause}. - */ - public AdminException() { - super(); - } - - /** - * Constructs a new exception with the specified detail message. The - * cause is not initialized, and may subsequently be initialized by - * a call to {@link Throwable#initCause}. - * - * @param message the detail message. The detail message is saved for - * later retrieval by the {@link #getMessage()} method. - */ - public AdminException(String message) { - super(message); - } - - /** - * Constructs a new exception with the specified detail message and - * cause.

    Note that the detail message associated with - * cause is not automatically incorporated in - * this exception's detail message. - * - * @param message the detail message (which is saved for later retrieval - * by the {@link #getMessage()} method). - * @param cause the cause (which is saved for later retrieval by the - * {@link #getCause()} method). (A null value is - * permitted, and indicates that the cause is nonexistent or - * unknown.) - */ - public AdminException(String message, Throwable cause) { - super(message, cause); - } - - /** - * Constructs a new exception with the specified cause. - * The detail - * message will be (cause==null ? null : cause.toString()) (which - * typically contains the class and detail message of cause). - * This constructor is useful for exceptions that are little more than - * wrappers for other throwables (for example, {@link - * java.security.PrivilegedActionException}). - * - * @param cause the cause (which is saved for later retrieval by the - * {@link #getCause()} method). (A null value is - * permitted, and indicates that the cause is nonexistent or - * unknown.) - */ - public AdminException(Throwable cause) { - super(cause); - } - -} http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/3bd8ef7f/geode-core/src/main/java/org/apache/geode/admin/AdminXmlException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/AdminXmlException.java b/geode-core/src/main/java/org/apache/geode/admin/AdminXmlException.java deleted file mode 100644 index e465ddc..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/AdminXmlException.java +++ /dev/null @@ -1,47 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.geode.admin; - -/** - * Thrown when a problem is encountered while working with - * admin-related XML data. - * - * @see DistributedSystemConfig#getEntityConfigXMLFile - * - * @since GemFire 4.0 - * @deprecated as of 7.0 use the management package instead - */ -public class AdminXmlException extends RuntimeAdminException { - private static final long serialVersionUID = -6848726449157550169L; - - /** - * Creates a new AdminXmlException with the given - * descriptive message. - */ - public AdminXmlException(String s) { - super(s); - } - - /** - * Creates a new AdminXmlException with the given - * descriptive message and cause. - */ - public AdminXmlException(String s, Throwable cause) { - super(s, cause); - } - -} http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/3bd8ef7f/geode-core/src/main/java/org/apache/geode/admin/Alert.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/Alert.java b/geode-core/src/main/java/org/apache/geode/admin/Alert.java deleted file mode 100755 index 9519cba..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/Alert.java +++ /dev/null @@ -1,55 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.geode.admin; - -/** - * An administration alert that is issued by a member of a GemFire - * distributed system. It is similar to a {@linkplain - * org.apache.geode.i18n.LogWriterI18n log message}. - * - * @see AlertListener - * @since GemFire 3.5 - * @deprecated as of 7.0 use the management package instead - */ -public interface Alert { - - /** The level at which this alert is issued */ - public AlertLevel getLevel(); - - /** - * The member of the distributed system that issued the alert, or - * null if the issuer is no longer a member of the distributed system. - */ - public SystemMember getSystemMember(); - - /** - * The name of the {@linkplain - * org.apache.geode.distributed.DistributedSystem#getName - * distributed system}) through which the alert was issued. - */ - public String getConnectionName(); - - /** The id of the source of the alert (such as a thread in a VM) */ - public String getSourceId(); - - /** The alert's message */ - public String getMessage(); - - /** The time at which the alert was issued */ - public java.util.Date getDate(); - -} http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/3bd8ef7f/geode-core/src/main/java/org/apache/geode/admin/AlertLevel.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/AlertLevel.java b/geode-core/src/main/java/org/apache/geode/admin/AlertLevel.java deleted file mode 100755 index 0791a5f..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/AlertLevel.java +++ /dev/null @@ -1,172 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.geode.admin; - -import org.apache.geode.internal.admin.Alert; -import org.apache.geode.internal.i18n.LocalizedStrings; - -/** - * Type-safe enumeration for {@link org.apache.geode.admin.Alert - * Alert} level. - * - * @since GemFire 3.5 - * @deprecated as of 7.0 use the management package instead - */ -public class AlertLevel implements java.io.Serializable { - private static final long serialVersionUID = -4752438966587392126L; - - public static final AlertLevel WARNING = - new AlertLevel(Alert.WARNING, "WARNING"); - public static final AlertLevel ERROR = - new AlertLevel(Alert.ERROR, "ERROR"); - public static final AlertLevel SEVERE = - new AlertLevel(Alert.SEVERE, "SEVERE"); - - public static final AlertLevel OFF = - new AlertLevel(Alert.OFF, "OFF"); - - /** The severity level of this AlertLevel. Greater is more severe. */ - private final transient int severity; - - /** The name of this AlertLevel. */ - private final transient String name; - - // The 4 declarations below are necessary for serialization - /** int used as ordinal to represent this AlertLevel */ - public final int ordinal = nextOrdinal++; - - private static int nextOrdinal = 0; - - private static final AlertLevel[] VALUES = - { WARNING, ERROR, SEVERE, OFF }; - - private Object readResolve() throws java.io.ObjectStreamException { - return VALUES[ordinal]; // Canonicalize - } - - /** Creates a new instance of AlertLevel. */ - private AlertLevel(int severity, String name) { - this.severity = severity; - this.name = name; - } - - /** Return the AlertLevel represented by specified ordinal */ - public static AlertLevel fromOrdinal(int ordinal) { - return VALUES[ordinal]; - } - - /** - * Returns the AlertLevel for the given severity - * - * @throws IllegalArgumentException - * If there is no alert level with the given - * severity - */ - public static AlertLevel forSeverity(int severity) { - switch (severity) { - case Alert.WARNING: - return AlertLevel.WARNING; - case Alert.ERROR: - return AlertLevel.ERROR; - case Alert.SEVERE: - return AlertLevel.SEVERE; - case Alert.OFF: - return AlertLevel.OFF; - default: - throw new IllegalArgumentException(LocalizedStrings.AlertLevel_UNKNOWN_ALERT_SEVERITY_0.toLocalizedString(Integer.valueOf(severity))); - } - } - - /** - * Returns the AlertLevel with the given name - * - * @throws IllegalArgumentException - * If there is no alert level named name - */ - public static AlertLevel forName(String name) { - for (int i = 0; i < VALUES.length; i++) { - AlertLevel level = VALUES[i]; - if (level.getName().equalsIgnoreCase(name)) { - return level; - } - } - - throw new IllegalArgumentException(LocalizedStrings.AlertLevel_THERE_IS_NO_ALERT_LEVEL_0.toLocalizedString(name)); - } - - public int getSeverity() { - return this.severity; - } - - public String getName() { - return this.name; - } - - public static AlertLevel[] values() { - return VALUES; - } - - /** - * Returns a string representation for this alert level. - * - * @return the name of this alert level - */ - @Override - public String toString() { - return this.name /* + "=" + this.severity */; - } - - /** - * Indicates whether some other object is "equal to" this one. - * - * @param other the reference object with which to compare. - * @return true if this object is the same as the obj argument; - * false otherwise. - */ - @Override - public boolean equals(Object other) { - if (other == this) return true; - if (other == null) return false; - if (!(other instanceof AlertLevel)) return false; - final AlertLevel that = (AlertLevel) other; - - if (this.severity != that.severity) return false; - if (this.name != null && - !this.name.equals(that.name)) return false; - - return true; - } - - /** - * Returns a hash code for the object. This method is supported for the - * benefit of hashtables such as those provided by java.util.Hashtable. - * - * @return the integer 0 if description is null; otherwise a unique integer. - */ - @Override - public int hashCode() { - int result = 17; - final int mult = 37; - - result = mult * result + this.severity; - result = mult * result + - (this.name == null ? 0 : this.name.hashCode()); - - return result; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/3bd8ef7f/geode-core/src/main/java/org/apache/geode/admin/AlertListener.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/AlertListener.java b/geode-core/src/main/java/org/apache/geode/admin/AlertListener.java deleted file mode 100755 index f217817..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/AlertListener.java +++ /dev/null @@ -1,30 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.geode.admin; - -/** - * A listener whose callback methods are invoked when an {@link Alert} - * is received. - * @deprecated as of 7.0 use the management package instead - */ -public interface AlertListener extends java.util.EventListener { - - /** - * Invoked when an Alert is received. - */ - public void alert(Alert alert); -} http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/3bd8ef7f/geode-core/src/main/java/org/apache/geode/admin/BackupStatus.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/BackupStatus.java b/geode-core/src/main/java/org/apache/geode/admin/BackupStatus.java deleted file mode 100644 index 802d37e..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/BackupStatus.java +++ /dev/null @@ -1,48 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.geode.admin; - -import java.util.Map; -import java.util.Set; - -import org.apache.geode.cache.persistence.PersistentID; -import org.apache.geode.distributed.DistributedMember; - -/** - * The status of a backup operation, returned by - * {@link AdminDistributedSystem#backupAllMembers(java.io.File,java.io.File)}. - * - * @since GemFire 6.5 - * @deprecated as of 7.0 use the management package instead - */ -public interface BackupStatus { - - /** - * Returns a map of disk stores that were successfully backed up. - * The key is an online distributed member. The value is the set of disk - * stores on that distributed member. - */ - Map> getBackedUpDiskStores(); - - /** - * Returns the set of disk stores that were known to be offline at the - * time of the backup. These members were not backed up. If this set - * is not empty the backup may not contain a complete snapshot of - * any partitioned regions in the distributed system. - */ - Set getOfflineDiskStores(); -} http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/3bd8ef7f/geode-core/src/main/java/org/apache/geode/admin/CacheDoesNotExistException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/CacheDoesNotExistException.java b/geode-core/src/main/java/org/apache/geode/admin/CacheDoesNotExistException.java deleted file mode 100644 index ac43c1f..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/CacheDoesNotExistException.java +++ /dev/null @@ -1,86 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.geode.admin; - -/** - * An CacheDoesNotExistException is thrown when an attempt - * is made to get a cache and one does not exist. - * - * @since GemFire 3.5 - * @deprecated as of 7.0 use the management package instead - */ -public class CacheDoesNotExistException extends AdminException { -private static final long serialVersionUID = -1639933911265729978L; - - /** - * Constructs a new exception with null as its detail message. - * The cause is not initialized, and may subsequently be initialized by a - * call to {@link Throwable#initCause}. - */ - public CacheDoesNotExistException() { - super(); - } - - /** - * Constructs a new exception with the specified detail message. The - * cause is not initialized, and may subsequently be initialized by - * a call to {@link Throwable#initCause}. - * - * @param message the detail message. The detail message is saved for - * later retrieval by the {@link #getMessage()} method. - */ - public CacheDoesNotExistException(String message) { - super(message); - } - - /** - * Constructs a new exception with the specified detail message and - * cause.

    Note that the detail message associated with - * cause is not automatically incorporated in - * this exception's detail message. - * - * @param message the detail message (which is saved for later retrieval - * by the {@link #getMessage()} method). - * @param cause the cause (which is saved for later retrieval by the - * {@link #getCause()} method). (A null value is - * permitted, and indicates that the cause is nonexistent or - * unknown.) - */ - public CacheDoesNotExistException(String message, Throwable cause) { - super(message, cause); - } - - /** - * Constructs a new exception with the specified cause and a detail - * message of (cause==null ? null : cause.toString()) (which - * typically contains the class and detail message of cause). - * This constructor is useful for exceptions that are little more than - * wrappers for other throwables (for example, {@link - * java.security.PrivilegedActionException}). - * - * @param cause the cause (which is saved for later retrieval by the - * {@link #getCause()} method). (A null value is - * permitted, and indicates that the cause is nonexistent or - * unknown.) - */ - public CacheDoesNotExistException(Throwable cause) { - super(cause); - } - -} - http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/3bd8ef7f/geode-core/src/main/java/org/apache/geode/admin/CacheHealthConfig.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/CacheHealthConfig.java b/geode-core/src/main/java/org/apache/geode/admin/CacheHealthConfig.java deleted file mode 100644 index f2aeb6d..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/CacheHealthConfig.java +++ /dev/null @@ -1,156 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.geode.admin; - -/** - * Provides configuration information relating to the health of a - * member of a GemFire distributed system that hosts a GemFire {@link - * org.apache.geode.cache.Cache Cache}. - * - *

    - * - * If any of the following criteria is true, then a cache member is - * considered to be in {@link GemFireHealth#OKAY_HEALTH OKAY_HEALTH}. - * - *

      - * - *
    • netSearch operations take {@linkplain - * #getMaxNetSearchTime too long} to complete.
      • - * - *
    • Cache load operations take {@linkplain - * #getMaxLoadTime too long} to complete.
      • - * - *
    • The overall cache {@link #getMinHitRatio hitRatio} is too - * small
      • - * - *
    • The number of entries in the Cache {@link #getMaxEventQueueSize - * event delivery queue} is too large.
      • - * - *
    • If one of the regions is configured with {@link org.apache.geode.cache.LossAction#FULL_ACCESS FULL_ACCESS} - * on role loss.
      • - * - *
    - * - * If any of the following criteria is true, then a cache member is - * considered to be in {@link GemFireHealth#POOR_HEALTH POOR_HEALTH}. - * - *
      - * - *
    • If one of the regions is configured with {@link org.apache.geode.cache.LossAction#NO_ACCESS NO_ACCESS} - * on role loss.
      • - * - *
    • If one of the regions is configured with {@link org.apache.geode.cache.LossAction#LIMITED_ACCESS LIMITED_ACCESS} - * on role loss.
      • - * - *
    - * - *
      - * - *
    - * - * - * @since GemFire 3.5 - * @deprecated as of 7.0 use the management package instead - * */ -public interface CacheHealthConfig { - - /** The default maximum number of milliseconds a - * netSearch operation can take before the cache member - * is considered to be unhealthy. */ - public static final long DEFAULT_MAX_NET_SEARCH_TIME = 60 * 1000; - - /** The default maximum mumber of milliseconds a cache - * load operation can take before the cache member is - * considered to be unhealthy. */ - public static final long DEFAULT_MAX_LOAD_TIME = 60 * 1000; - - /** The default minimum hit ratio of a healthy cache member. */ - public static final double DEFAULT_MIN_HIT_RATIO = 0.0; - - /** The default maximum number of entries in the event delivery queue - * of a healthy cache member. */ - public static final long DEFAULT_MAX_EVENT_QUEUE_SIZE = 1000; - - /////////////////////// Instance Methods /////////////////////// - - /** - * Returns the maximum number of milliseconds a - * netSearch operation can take before the cache member - * is considered to be unhealthy. - * - * @see #DEFAULT_MAX_NET_SEARCH_TIME - */ - public long getMaxNetSearchTime(); - - /** - * Sets the maximum number of milliseconds a - * netSearch operation can take before the cache member - * is considered to be unhealthy. - * - * @see #getMaxNetSearchTime - */ - public void setMaxNetSearchTime(long maxNetSearchTime); - - /** - * Returns the maximum mumber of milliseconds a cache - * load operation can take before the cache member is - * considered to be unhealthy. - * - * @see #DEFAULT_MAX_LOAD_TIME - */ - public long getMaxLoadTime(); - - /** - * Sets the maximum mumber of milliseconds a cache - * load operation can take before the cache member is - * considered to be unhealthy. - * - * @see #getMaxLoadTime - */ - public void setMaxLoadTime(long maxLoadTime); - - /** - * Returns the minimum hit ratio of a healthy cache member. - * - * @see #DEFAULT_MIN_HIT_RATIO - */ - public double getMinHitRatio(); - - /** - * Sets the minimum hit ratio of a healthy cache member. - * - * @see #getMinHitRatio - */ - public void setMinHitRatio(double minHitRatio); - - /** - * Returns the maximum number of entries in the event delivery queue - * of a healthy cache member. - * - * @see #DEFAULT_MAX_EVENT_QUEUE_SIZE - */ - public long getMaxEventQueueSize(); - - /** - * Sets the maximum number of entries in the event delivery queue - * of a healthy cache member. - * - * @see #getMaxEventQueueSize - */ - public void setMaxEventQueueSize(long maxEventQueueSize); - -} http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/3bd8ef7f/geode-core/src/main/java/org/apache/geode/admin/CacheServer.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/CacheServer.java b/geode-core/src/main/java/org/apache/geode/admin/CacheServer.java deleted file mode 100644 index 0149a05..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/CacheServer.java +++ /dev/null @@ -1,45 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.geode.admin; - -/** - * A dedicated cache server VM that is managed by the administration - * API. - * - * @since GemFire 4.0 - * @deprecated as of 5.7 use {@link CacheVm} instead. - */ -@Deprecated -public interface CacheServer extends SystemMember, ManagedEntity { - /** - * Returns the configuration of this cache vm - * @deprecated as of 5.7 use {@link CacheVm#getVmConfig} instead. - */ - @Deprecated - public CacheServerConfig getConfig(); - /** - * Find whether this server is primary for given client (durableClientId) - * - * @param durableClientId - - * durable-id of the client - * @return true if the server is primary for given client - * - * @since GemFire 5.6 - */ - public boolean isPrimaryForDurableClient(String durableClientId); - -} http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/3bd8ef7f/geode-core/src/main/java/org/apache/geode/admin/CacheServerConfig.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/CacheServerConfig.java b/geode-core/src/main/java/org/apache/geode/admin/CacheServerConfig.java deleted file mode 100644 index fc4ce0f..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/CacheServerConfig.java +++ /dev/null @@ -1,54 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.geode.admin; - -/** - * Configuration for a GemFire cache server that is managed by the - * administration API. The cache server may or may not be running. - * - * @see AdminDistributedSystem#addCacheServer() - * - * @since GemFire 4.0 - * @deprecated as of 5.7 use {@link CacheVmConfig} instead. - */ -@Deprecated -public interface CacheServerConfig extends CacheVmConfig { - /** - * Returns the cache.xml declarative caching - * initialization file used to configure this cache server VM. By - * default, a cache server VM is started without an XML file. - */ - public String getCacheXMLFile(); - - /** - * Sets the cache.xml declarative caching - * initialization file used to configure this cache server VM. - */ - public void setCacheXMLFile(String cacheXml); - - /** - * Returns the location(s) of user classes (such as cache loaders) - * required by the cache server VM. - */ - public String getClassPath(); - - /** - * Sets the location(s) of user classes (such as cache loaders) - * required by the cache server VM. - */ - public void setClassPath(String classpath); -} http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/3bd8ef7f/geode-core/src/main/java/org/apache/geode/admin/CacheVm.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/CacheVm.java b/geode-core/src/main/java/org/apache/geode/admin/CacheVm.java deleted file mode 100755 index 5bfeddc..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/CacheVm.java +++ /dev/null @@ -1,37 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.geode.admin; - -/** - * A dedicated cache server VM that is managed by the administration - * API. - *

    Note that this may not represent an instance of - * {@link org.apache.geode.cache.server.CacheServer}. It is possible for - * a cache VM to be started but for it not to listen for client connections - * in which case it is not a - * {@link org.apache.geode.cache.server.CacheServer} - * but is an instance of this interface. - * - * @since GemFire 5.7 - * @deprecated as of 7.0 use the management package instead - */ -public interface CacheVm extends SystemMember, ManagedEntity { - /** - * Returns the configuration of this cache vm - */ - public CacheVmConfig getVmConfig(); -}