http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/895fd144/geode-core/src/main/java/org/apache/geode/admin/CacheVmConfig.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/CacheVmConfig.java b/geode-core/src/main/java/org/apache/geode/admin/CacheVmConfig.java deleted file mode 100755 index 81f4a38..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/CacheVmConfig.java +++ /dev/null @@ -1,51 +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 VM that is managed by the administration API. The VM may - * or may not be running. - * - * @see AdminDistributedSystem#addCacheVm() - * - * @since GemFire 5.7 - * @deprecated as of 7.0 use the <code><a href= - * "{@docRoot}/org/apache/geode/management/package-summary.html">management</a></code> - * package instead - */ -public interface CacheVmConfig extends ManagedEntityConfig { - /** - * Returns the <code>cache.xml</code> 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 <code>cache.xml</code> 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/895fd144/geode-core/src/main/java/org/apache/geode/admin/ConfigurationParameter.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/ConfigurationParameter.java b/geode-core/src/main/java/org/apache/geode/admin/ConfigurationParameter.java deleted file mode 100755 index 74e1510..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/ConfigurationParameter.java +++ /dev/null @@ -1,72 +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 single configuration parameter of a {@link SystemMember}. - * - * @since GemFire 3.5 - * - * @deprecated as of 7.0 use the <code><a href= - * "{@docRoot}/org/apache/geode/management/package-summary.html">management</a></code> - * package instead - */ -public interface ConfigurationParameter { - - /** Gets the identifying name of this configuration parameter. */ - public String getName(); - - /** Gets the full description of this configuration parameter */ - public String getDescription(); - - /** Gets the current value */ - public Object getValue(); - - /** Gets the current value as a string */ - public String getValueAsString(); - - /** Gets the class type of the value */ - public Class getValueType(); - - /** True if this is modifiable; false if read-only */ - public boolean isModifiable(); - - /** Returns true if this config parameter uses a string array for value. */ - public boolean isArray(); - - /** Returns true if this config parameter represents an InetAddress value. */ - public boolean isInetAddress(); - - /** Returns true if this config parameter represents a File value. */ - public boolean isFile(); - - /** Returns true if this config parameter represents an octal value. */ - public boolean isOctal(); - - /** Returns true if this config parameter represents a string value. */ - public boolean isString(); - - /** - * Sets a new value for this configuration parameter. - * - * @param value the new value which must be of type {@link #getValueType} - * @throws IllegalArgumentException if value type does not match {@link #getValueType} - * @throws UnmodifiableConfigurationException if attempting to set value when isModifiable is - * false - */ - public void setValue(Object value) throws UnmodifiableConfigurationException; -} - http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/895fd144/geode-core/src/main/java/org/apache/geode/admin/DistributedSystemConfig.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/DistributedSystemConfig.java b/geode-core/src/main/java/org/apache/geode/admin/DistributedSystemConfig.java deleted file mode 100755 index 940d306..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/DistributedSystemConfig.java +++ /dev/null @@ -1,626 +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.InetAddressUtil; -import org.apache.geode.distributed.internal.DistributionConfig; - -import java.util.Properties; - -import static org.apache.geode.distributed.ConfigurationProperties.*; - - -/** - * Configuration for defining a GemFire distributed system to administrate. This configuration - * includes information about the discovery mechanism used to find members of the distributed system - * and information about {@linkplain ManagedEntity managed entities} such as - * {@linkplain DistributionLocator distribution locators} and {@linkplain CacheVm GemFire cache vms} - * that can be {@linkplain AdminDistributedSystem#start started}. - * - * <P> - * - * Detailed descriptions of many of these configuration attributes can be found in the - * {@link org.apache.geode.distributed.DistributedSystem DistributedSystem} class. Note that the - * default values of these configuration attributes can be specified using Java system properties. - * - * <P> - * - * A <code>DistributedSystemConfig</code> can be modified using a number of mutator methods until - * the <code>AdminDistributedSystem</code> that it configures - * {@linkplain AdminDistributedSystem#connect connects} to the distributed system. After that, - * attempts to modify most attributes in the <code>DistributedSystemConfig</code> will result in an - * {@link IllegalStateException} being thrown. If you wish to use the same - * <code>DistributedSystemConfig</code> to configure multiple <code>AdminDistributedSystem</code>s, - * a copy of the <code>DistributedSystemConfig</code> object can be made by invoking the - * {@link #clone} method. - * - * @since GemFire 3.5 - * @deprecated as of 7.0 use the <code><a href= - * "{@docRoot}/org/apache/geode/management/package-summary.html">management</a></code> - * package instead - */ -public interface DistributedSystemConfig extends Cloneable { - - /** - * The name of an XML file that specifies the configuration for the {@linkplain ManagedEntity - * managed entities} administered by the <code>DistributedSystem</code>. The XML file must conform - * to a <a href="doc-files/ds5_0.dtd">dtd</a>. - */ - String ENTITY_CONFIG_XML_FILE_NAME = "entity-config-xml-file"; - - /** - * The default value of the "entity-config-xml-file" property ("distributed-system.xml"). - */ - String DEFAULT_ENTITY_CONFIG_XML_FILE = "distributed-system.xml"; - - /** The name of the "system-id" property */ - String SYSTEM_ID_NAME = "system-id"; - - /** The default value of the "system-id" property ("") */ - String DEFAULT_SYSTEM_ID = "Default System"; - - /** The name of the "name" property. See {@link #getSystemName()}. */ - String NAME_NAME = NAME; - - /** The default value of the "name" property (""). See {@link #getSystemName()}. */ - String DEFAULT_NAME = ""; - - /** The name of the "mcastPort" property */ - String MCAST_PORT_NAME = MCAST_PORT; - - /** The default value of the "mcastPort" property (10334) */ - int DEFAULT_MCAST_PORT = DistributionConfig.DEFAULT_MCAST_PORT; - - /** The minimum mcastPort (0) */ - int MIN_MCAST_PORT = DistributionConfig.MIN_MCAST_PORT; - - /** The maximum mcastPort (65535) */ - int MAX_MCAST_PORT = DistributionConfig.MAX_MCAST_PORT; - - /** The name of the "mcastAddress" property */ - String MCAST_ADDRESS_NAME = MCAST_ADDRESS; - - /** The default value of the "mcastAddress" property (239.192.81.1). */ - String DEFAULT_MCAST_ADDRESS = InetAddressUtil.toString(DistributionConfig.DEFAULT_MCAST_ADDRESS); - - /** - * The name of the "membership-port-range" property - * - * @since GemFire 6.5 - */ - String MEMBERSHIP_PORT_RANGE_NAME = MEMBERSHIP_PORT_RANGE; - - /** - * The default membership-port-range. - * <p> - * Actual value is <code>[1024,65535]</code>. - * - * @since GemFire 6.5 - */ - int[] DEFAULT_MEMBERSHIP_PORT_RANGE = DistributionConfig.DEFAULT_MEMBERSHIP_PORT_RANGE; - - /** - * settings for tcp-port - * - * @since GemFire 6.5 - */ - String TCP_PORT_NAME = TCP_PORT; - /** - * The default value of the "tcpPort" property. - * <p> - * Actual value is <code>0</code>. - * - * @since GemFire 6.5 - */ - int DEFAULT_TCP_PORT = DistributionConfig.DEFAULT_TCP_PORT; - - /** - * The default AckWaitThreshold. - * <p> - * Actual value of this constant is <code>15</code> seconds. - */ - int DEFAULT_ACK_WAIT_THRESHOLD = DistributionConfig.DEFAULT_ACK_WAIT_THRESHOLD; - /** - * The minimum AckWaitThreshold. - * <p> - * Actual value of this constant is <code>1</code> second. - */ - int MIN_ACK_WAIT_THRESHOLD = DistributionConfig.MIN_ACK_WAIT_THRESHOLD; - /** - * The maximum AckWaitThreshold. - * <p> - * Actual value of this constant is <code>MAX_INT</code> seconds. - */ - int MAX_ACK_WAIT_THRESHOLD = DistributionConfig.MIN_ACK_WAIT_THRESHOLD; - - /** - * The default ackSevereAlertThreshold. - * <p> - * Actual value of this constant is <code>0</code> seconds, which turns off forced disconnects - * based on ack wait periods. - */ - int DEFAULT_ACK_SEVERE_ALERT_THRESHOLD = DistributionConfig.DEFAULT_ACK_SEVERE_ALERT_THRESHOLD; - /** - * The minimum ackSevereAlertThreshold. - * <p> - * Actual value of this constant is <code>0</code> second, which turns off forced disconnects - * based on ack wait periods. - */ - int MIN_ACK_SEVERE_ALERT_THRESHOLD = DistributionConfig.MIN_ACK_SEVERE_ALERT_THRESHOLD; - /** - * The maximum ackSevereAlertThreshold. - * <p> - * Actual value of this constant is <code>MAX_INT</code> seconds. - */ - int MAX_ACK_SEVERE_ALERT_THRESHOLD = DistributionConfig.MAX_ACK_SEVERE_ALERT_THRESHOLD; - - /** The name of the "locators" property (comma-delimited host[port] list) */ - String LOCATORS_NAME = LOCATORS; - - /** The default value of the "locators" property ("") */ - String DEFAULT_LOCATORS = DistributionConfig.DEFAULT_LOCATORS; - - /** The name of the "bindAddress" property */ - String BIND_ADDRESS_NAME = BIND_ADDRESS; - - /** The default value of the "bindAddress" property */ - String DEFAULT_BIND_ADDRESS = DistributionConfig.DEFAULT_BIND_ADDRESS; - - /** The name of the remote-command property */ - String REMOTE_COMMAND_NAME = "remote-command"; - - /** The default value of the remote-command property */ - String DEFAULT_REMOTE_COMMAND = "rsh -n {HOST} {CMD}"; - - /** The default disable-tcp value (<code>false</code>) */ - boolean DEFAULT_DISABLE_TCP = DistributionConfig.DEFAULT_DISABLE_TCP; - - /** The default enable-network-partition-detection setting (<code>false</code>) */ - boolean DEFAULT_ENABLE_NETWORK_PARTITION_DETECTION = - DistributionConfig.DEFAULT_ENABLE_NETWORK_PARTITION_DETECTION; - - /** The default disable-auto-reconnect setting (<code>false</code>) */ - boolean DEFAULT_DISABLE_AUTO_RECONNECT = DistributionConfig.DEFAULT_DISABLE_AUTO_RECONNECT; - - /** The default failure-detection timeout period for member heart-beat responses */ - int DEFAULT_MEMBER_TIMEOUT = DistributionConfig.DEFAULT_MEMBER_TIMEOUT; - - /** The name of the "logFile" property */ - String LOG_FILE_NAME = LOG_FILE; - - /** - * The default log-file value ("" which directs logging to standard output) - */ - String DEFAULT_LOG_FILE = ""; - - /** The name of the "logLevel" property */ - String LOG_LEVEL_NAME = LOG_LEVEL; - - /** The default log level ("config") */ - String DEFAULT_LOG_LEVEL = "config"; - - /** The name of the "LogDiskSpaceLimit" property */ - String LOG_DISK_SPACE_LIMIT_NAME = LOG_DISK_SPACE_LIMIT; - - /** The default log disk space limit in megabytes (0) */ - int DEFAULT_LOG_DISK_SPACE_LIMIT = DistributionConfig.DEFAULT_LOG_DISK_SPACE_LIMIT; - - /** The minimum log disk space limit in megabytes (0) */ - int MIN_LOG_DISK_SPACE_LIMIT = DistributionConfig.MIN_LOG_DISK_SPACE_LIMIT; - - /** The minimum log disk space limit in megabytes (1000000) */ - int MAX_LOG_DISK_SPACE_LIMIT = DistributionConfig.MAX_LOG_DISK_SPACE_LIMIT; - - /** The name of the "LogFileSizeLimit" property */ - String LOG_FILE_SIZE_LIMIT_NAME = LOG_FILE_SIZE_LIMIT; - - /** The default log file size limit in megabytes (0) */ - int DEFAULT_LOG_FILE_SIZE_LIMIT = DistributionConfig.DEFAULT_LOG_FILE_SIZE_LIMIT; - - /** The minimum log file size limit in megabytes (0) */ - int MIN_LOG_FILE_SIZE_LIMIT = DistributionConfig.MIN_LOG_FILE_SIZE_LIMIT; - - /** The minimum log file size limit in megabytes (1000000) */ - int MAX_LOG_FILE_SIZE_LIMIT = DistributionConfig.MAX_LOG_FILE_SIZE_LIMIT; - - /** - * The name of the "refreshInterval" property which will apply to SystemMember, SystemMemberCache - * and StatisticResource refresh. This interval (in seconds) is used for auto-polling and updating - * AdminDistributedSystem constituents including SystemMember, CacheServer, SystemMemberCache and - * StatisticResource. This interval is read-only and retains the value set when the config is - * created. Note that the resource MBeans actually refresh and hit the DS only if there is an RMI - * client connected - */ - String REFRESH_INTERVAL_NAME = "refresh-interval"; - - /** - * The default "refreshInterval" in seconds which will apply to REFRESH_INTERVAL_NAME property. - * The default value is 15 secs - */ - int DEFAULT_REFRESH_INTERVAL = 15; - - ////////////////////// Instance Methods ////////////////////// - - /** - * Returns the name of the XML file that specifies the configuration of the - * {@linkplain org.apache.geode.admin.ManagedEntity managed entities} administered by the - * <code>DistributedSystem</code>. The XML file must conform to a - * <a href="doc-files/ds5_0.dtd">dtd</a>. - * - * @since GemFire 4.0 - */ - public String getEntityConfigXMLFile(); - - /** - * Sets the name of the XML file that specifies the configuration of managed entities administered - * by the <code>DistributedSystem</code>. - */ - public void setEntityConfigXMLFile(String xmlFile); - - /** Returns the string identity for the system */ - public String getSystemId(); - - /** Sets the string identity for the system */ - public void setSystemId(String systemId); - - /** Returns the optional non-unique name for the system */ - public String getSystemName(); - - /** Sets the optional non-unique name for the system */ - public void setSystemName(final String name); - - /** Returns the multicast address for the system */ - public String getMcastAddress(); - - /** Sets the multicast address for the system */ - public void setMcastAddress(String mcastAddress); - - /** Returns the multicast port for the system */ - public int getMcastPort(); - - /** Sets the multicast port for the system */ - public void setMcastPort(int mcastPort); - - /** Returns the ack-wait-threshold for the system */ - public int getAckWaitThreshold(); - - /** Sets the ack-wait-threshold for the system */ - public void setAckWaitThreshold(int seconds); - - /** Returns the ack-severe-alert-threshold for the system */ - public int getAckSevereAlertThreshold(); - - /** Sets the ack-severe-alert-threshold for the system */ - public void setAckSevereAlertThreshold(int seconds); - - /** Returns a comma-delimited list of locators for the system */ - public String getLocators(); - - /** Sets the comma-delimited list of locators for the system */ - public void setLocators(String locators); - - /** - * Returns the membership-port-range property of the Distributed System. This range is given as - * two numbers separated by a minus sign. - * - * @since GemFire 6.5 - */ - public String getMembershipPortRange(); - - /** - * Sets the membership-port-range property of the Distributed System. This range is given as two - * numbers separated by a minus sign. - * - * @since GemFire 6.5 - */ - public void setMembershipPortRange(String membershipPortRange); - - - /** - * Sets the primary communication port number for the Distributed System. - * - * @since GemFire 6.5 - */ - public void setTcpPort(int port); - - /** - * Returns the primary communication port number for the Distributed System. - * - * @since GemFire 6.5 - */ - public int getTcpPort(); - - - /** - * Sets the disable-tcp property for the system. When tcp is disabled, the cache uses udp for - * unicast messaging. This must be consistent across all members of the distributed system. The - * default is to enable tcp. - */ - public void setDisableTcp(boolean flag); - - /** - * Returns the disable-tcp property for the system. When tcp is disabled, the cache uses udp for - * unicast messaging. This must be consistent across all members of the distributed system. The - * default is to enable tcp. - */ - public boolean getDisableTcp(); - - - /** - * Turns on network partition detection - */ - public void setEnableNetworkPartitionDetection(boolean newValue); - - /** - * Returns true if network partition detection is enabled. - */ - public boolean getEnableNetworkPartitionDetection(); - - /** - * Disables auto reconnect after being forced out of the distributed system - */ - public void setDisableAutoReconnect(boolean newValue); - - /** - * Returns true if auto reconnect is disabled - */ - public boolean getDisableAutoReconnect(); - - - - /** - * Returns the member-timeout millisecond value used in failure-detection protocols - */ - public int getMemberTimeout(); - - /** - * Set the millisecond value of the member-timeout used in failure-detection protocols. This - * timeout determines how long a member has to respond to a heartbeat request. The member is given - * three chances before being kicked out of the distributed system with a SystemConnectException. - */ - public void setMemberTimeout(int value); - - /** - * Returns the IP address to which the distributed system's server sockets are bound. - * - * @since GemFire 4.0 - */ - public String getBindAddress(); - - /** - * Sets the IP address to which the distributed system's server sockets are bound. - * - * @since GemFire 4.0 - */ - public void setBindAddress(String bindAddress); - - - /** - * Returns the IP address to which client/server server sockets are bound - */ - public String getServerBindAddress(); - - /** - * Sets the IP address to which a server cache will bind when listening for client cache - * connections. - */ - public void setServerBindAddress(String bindAddress); - - - /** Returns the remote command setting to use for remote administration */ - public String getRemoteCommand(); - - /** - * Sets the remote command setting to use for remote administration. This attribute may be - * modified after this <code>DistributedSystemConfig</code> has been used to create an - * <codE>AdminDistributedSystem</code>. - */ - public void setRemoteCommand(String command); - - /** Returns the value of the "ssl-enabled" property. */ - public boolean isSSLEnabled(); - - /** Sets the value of the "ssl-enabled" property. */ - public void setSSLEnabled(boolean enabled); - - /** Returns the value of the "ssl-protocols" property. */ - public String getSSLProtocols(); - - /** Sets the value of the "ssl-protocols" property. */ - public void setSSLProtocols(String protocols); - - /** Returns the value of the "ssl-ciphers" property. */ - public String getSSLCiphers(); - - /** Sets the value of the "ssl-ciphers" property. */ - public void setSSLCiphers(String ciphers); - - /** Returns the value of the "ssl-require-authentication" property. */ - public boolean isSSLAuthenticationRequired(); - - /** Sets the value of the "ssl-require-authentication" property. */ - public void setSSLAuthenticationRequired(boolean authRequired); - - /** Returns the provider-specific properties for SSL. */ - public Properties getSSLProperties(); - - /** Sets the provider-specific properties for SSL. */ - public void setSSLProperties(Properties sslProperties); - - /** Adds an SSL property */ - public void addSSLProperty(String key, String value); - - /** Removes an SSL property */ - public void removeSSLProperty(String key); - - /** - * Returns the name of the log file to which informational messages are written. - * - * @see org.apache.geode.i18n.LogWriterI18n - */ - public String getLogFile(); - - /** - * Sets the name of the log file to which informational messages are written. - * - * @see org.apache.geode.i18n.LogWriterI18n - */ - public void setLogFile(String logFile); - - /** - * Returns the level at which informational messages are logged. - */ - public String getLogLevel(); - - /** - * Sets the level at which information messages are logged. - */ - public void setLogLevel(String logLevel); - - /** - * Returns the log disk space limit in megabytes - */ - public int getLogDiskSpaceLimit(); - - /** - * Sets the log disk space limit in megabytes - */ - public void setLogDiskSpaceLimit(int limit); - - /** - * Returns the log file size limit in megabytes - */ - public int getLogFileSizeLimit(); - - /** - * Sets the log file size limit in megabytes - */ - public void setLogFileSizeLimit(int limit); - - /** - * Returns the refreshInterval in seconds used for auto-polling and updating - * AdminDistributedSystem constituents including SystemMember, CacheServer, SystemMemberCache and - * StatisticResource - * - * @since GemFire 6.0 - */ - public int getRefreshInterval(); - - /** - * Sets the refreshInterval in seconds - * - * @since GemFire 6.0 - */ - public void setRefreshInterval(int timeInSecs); - - /** - * Returns an array of configurations for statically known <code>CacheServers</code>. - * - * @deprecated as of 5.7 use {@link #getCacheVmConfigs} instead. - */ - @Deprecated - public CacheServerConfig[] getCacheServerConfigs(); - - /** - * Creates the configuration for a CacheServer - * - * @deprecated as of 5.7 use {@link #createCacheVmConfig} instead. - */ - @Deprecated - public CacheServerConfig createCacheServerConfig(); - - /** - * Removes the configuration for a CacheServer - * - * @deprecated as of 5.7 use {@link #removeCacheVmConfig} instead. - */ - @Deprecated - public void removeCacheServerConfig(CacheServerConfig managerConfig); - - /** - * Returns an array of configurations for statically known {@link CacheVm}s. - * - * @since GemFire 5.7 - */ - public CacheVmConfig[] getCacheVmConfigs(); - - /** - * Creates the configuration for a {@link CacheVm}. - * - * @since GemFire 5.7 - */ - public CacheVmConfig createCacheVmConfig(); - - /** - * Removes the configuration for a {@link CacheVm} - * - * @since GemFire 5.7 - */ - public void removeCacheVmConfig(CacheVmConfig existing); - - /** - * Returns configuration information about {@link DistributionLocator}s that are managed by an - * <code>AdminDistributedSystem</code>. - */ - public DistributionLocatorConfig[] getDistributionLocatorConfigs(); - - /** - * Creates a new <code>DistributionLocatorConfig</code> for a distribution locator that is managed - * in this distributed system. The default locator config is set to not use multicast - */ - public DistributionLocatorConfig createDistributionLocatorConfig(); - - /** - * Removes a <code>DistributionLocatorConfig</code> from the distributed system. - */ - public void removeDistributionLocatorConfig(DistributionLocatorConfig config); - - /** Registers listener for notification of changes in this config. */ - public void addListener(ConfigListener listener); - - /** Removes previously registered listener of this config. */ - public void removeListener(ConfigListener listener); - - /** - * Validates that this distributed system configuration is correct and consistent. - * - * @throws IllegalStateException If this config is not valid - * @throws AdminXmlException If the {@linkplain #getEntityConfigXMLFile entity config XML file} is - * not valid - */ - public void validate(); - - /** - * Returns a copy of this <code>DistributedSystemConfig</code> object whose configuration can be - * modified. Note that this {@link DistributedSystemConfig.ConfigListener ConfigListener}s that - * are registered on this config object are not cloned. - * - * @since GemFire 4.0 - */ - public Object clone() throws CloneNotSupportedException; - - ////////////////////// Inner Classes ////////////////////// - - /** - * A listener whose callback methods are invoked when this config changes. - */ - public interface ConfigListener extends java.util.EventListener { - - /** Invoked when this configurated is changed. */ - public void configChanged(DistributedSystemConfig config); - } - -} - http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/895fd144/geode-core/src/main/java/org/apache/geode/admin/DistributedSystemHealthConfig.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/DistributedSystemHealthConfig.java b/geode-core/src/main/java/org/apache/geode/admin/DistributedSystemHealthConfig.java deleted file mode 100644 index d7f7751..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/DistributedSystemHealthConfig.java +++ /dev/null @@ -1,74 +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 an entire GemFire distributed - * system. - * - * <P> - * - * If any of the following criteria is true, then the distributed system is considered to be in - * {@link GemFireHealth#OKAY_HEALTH OKAY_HEALTH}. - * - * <UL> - * - * </UL> - * - * If any of the following criteria is true, then the distributed system is considered to be in - * {@link GemFireHealth#POOR_HEALTH POOR_HEALTH}. - * - * <UL> - * - * <LI>Too many application members {@linkplain #getMaxDepartedApplications unexpectedly leave} the - * distributed system.</LI> - * - * <LI>Too many application members {@linkplain #getMaxDepartedApplications unexpectedly leave} the - * distributed system.</LI> - * - * </UL> - * - * - * @since GemFire 3.5 - * @deprecated as of 7.0 use the <code><a href= - * "{@docRoot}/org/apache/geode/management/package-summary.html">management</a></code> - * package instead - */ -public interface DistributedSystemHealthConfig { - - /** - * The default maximum number of application members that can unexceptedly leave a healthy the - * distributed system. - */ - public static final long DEFAULT_MAX_DEPARTED_APPLICATIONS = 10; - - /////////////////////// Instance Methods /////////////////////// - - /** - * Returns the maximum number of application members that can unexceptedly leave a healthy the - * distributed system. - * - * @see #DEFAULT_MAX_DEPARTED_APPLICATIONS - */ - public long getMaxDepartedApplications(); - - /** - * Sets the maximum number of application members that can unexceptedly leave a healthy the - * distributed system. - * - * @see #getMaxDepartedApplications - */ - public void setMaxDepartedApplications(long maxDepartedApplications); -} http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/895fd144/geode-core/src/main/java/org/apache/geode/admin/DistributionLocator.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/DistributionLocator.java b/geode-core/src/main/java/org/apache/geode/admin/DistributionLocator.java deleted file mode 100755 index cb82679..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/DistributionLocator.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; - -/** - * Represents a single distribution locator server, of which a distributed system may use zero or - * many. The distributed system will be configured to use either multicast discovery or locator - * service. - * - * @see DistributionLocatorConfig - * - * @since GemFire 3.5 - * @deprecated as of 7.0 use the <code><a href= - * "{@docRoot}/org/apache/geode/management/package-summary.html">management</a></code> - * package instead - */ -public interface DistributionLocator extends ManagedEntity { - - /** - * Returns the identity name for this locator. - */ - public String getId(); - - /** - * Returns the configuration object for this distribution locator. - * - * @since GemFire 4.0 - */ - public DistributionLocatorConfig getConfig(); - -} - http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/895fd144/geode-core/src/main/java/org/apache/geode/admin/DistributionLocatorConfig.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/DistributionLocatorConfig.java b/geode-core/src/main/java/org/apache/geode/admin/DistributionLocatorConfig.java deleted file mode 100644 index 6e8794d..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/DistributionLocatorConfig.java +++ /dev/null @@ -1,81 +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.Properties; - -/** - * Describes the configuration of a {@link DistributionLocator} managed by the GemFire - * administration APIs. - * - * <P> - * - * A <code>DistributionLocatorConfig</code> can be modified using a number of mutator methods until - * the <code>DistributionLocator</code> configured by this object is {@linkplain ManagedEntity#start - * started}. After that, attempts to modify most attributes in the - * <code>DistributionLocatorConfig</code> will result in an {@link IllegalStateException} being - * thrown. If you wish to use the same <code>DistributionLocatorConfig</code> to configure another - * <code>DistributionLocator</code>s, a copy of the <code>DistributionLocatorConfig</code> object - * can be made by invoking the {@link Object#clone} method. - * - * @see AdminDistributedSystem#addDistributionLocator - * @see org.apache.geode.distributed.Locator - * - * @since GemFire 4.0 - * @deprecated as of 7.0 use the <code><a href= - * "{@docRoot}/org/apache/geode/management/package-summary.html">management</a></code> - * package instead - */ -public interface DistributionLocatorConfig extends ManagedEntityConfig { - - /** - * Returns the port on which ths distribution locator listens for members to connect. There is no - * default locator port, so a non-default port must be specified. - */ - public int getPort(); - - /** - * Sets the port on which the distribution locator listens for members to connect. - */ - public void setPort(int port); - - /** - * Returns the address to which the distribution locator's port is (or will be) bound. By default, - * the bind address is <code>null</code> meaning that the port will be bound to all network - * addresses on the host. - */ - public String getBindAddress(); - - /** - * Sets the address to which the distribution locator's port is (or will be) bound. - */ - public void setBindAddress(String bindAddress); - - /** - * Sets the properties used to configure the locator's DistributedSystem. - * - * @since GemFire 5.0 - */ - public void setDistributedSystemProperties(Properties props); - - /** - * Retrieves the properties used to configure the locator's DistributedSystem. - * - * @since GemFire 5.0 - */ - public Properties getDistributedSystemProperties(); - - -} http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/895fd144/geode-core/src/main/java/org/apache/geode/admin/GemFireHealth.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/GemFireHealth.java b/geode-core/src/main/java/org/apache/geode/admin/GemFireHealth.java deleted file mode 100644 index bb8590a..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/GemFireHealth.java +++ /dev/null @@ -1,209 +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.Assert; -import org.apache.geode.internal.i18n.LocalizedStrings; - -/** - * Provides information about the aggregate health of the members of a GemFire distributed system - * ("components"). The {@link #getHealth getHealth} method provides an indication of the overall - * health. Health is expressed as one of three levels: {@link #GOOD_HEALTH GOOD_HEALTH}, - * {@link #OKAY_HEALTH OKAY_HEALTH}, and {@link #POOR_HEALTH POOR_HEALTH}. The {@link #getDiagnosis - * getDiagnosis} method provides a more detailed explanation of the cause of ill health. - * - * <P> - * - * The aggregate health of the GemFire component is evaluated - * {@linkplain GemFireHealthConfig#setHealthEvaluationInterval every so often} and if certain - * criteria are met, then the overall health of the component changes accordingly. If any of the - * components is in <code>OKAY_HEALTH</code>, then the overall health is <code>OKAY_HEALTH</code>. - * If any of the components is in <code>POOR_HEALTH</code>, then the overall health is - * <code>POOR_HEALTH</code>. - * - * - * @since GemFire 3.5 - * @deprecated as of 7.0 use the <code><a href= - * "{@docRoot}/org/apache/geode/management/package-summary.html">management</a></code> - * package instead - */ -public interface GemFireHealth { - - /** - * An indicator that the GemFire components are healthy. - * - * @see #getHealth - */ - public static final Health GOOD_HEALTH = new Health(Health.GOOD_STRING); - - /** - * An indicator that one or more GemFire components is slightly unhealthy. The problem may or may - * not require configuration changes and may not necessarily lead to poorer component health. - * - * @see #getHealth - */ - public static final Health OKAY_HEALTH = new Health(Health.OKAY_STRING); - - /** - * An indicator that one or more GemFire components is unhealthy. While it may be possible for the - * components to recover on their own, it is likely that they will have to be restarted. - * - * @see #getHealth - */ - public static final Health POOR_HEALTH = new Health(Health.POOR_STRING); - - /////////////////////// Instance Methods /////////////////////// - - /** - * Returns an indicator of the overall health of the GemFire components. - * - * @see #GOOD_HEALTH - * @see #OKAY_HEALTH - * @see #POOR_HEALTH - */ - public Health getHealth(); - - /** - * Resets the overall health of the GemFire components to {@link #GOOD_HEALTH}. This operation - * should be invoked when the operator has determined that warnings about the components's health - * do not need to be regarded. - */ - public void resetHealth(); - - /** - * Returns a message that provides a description of the cause of a component's ill health. - */ - public String getDiagnosis(); - - /** - * Returns the configuration for determining the health of the distributed system itself. - */ - public DistributedSystemHealthConfig getDistributedSystemHealthConfig(); - - /** - * Sets the configuration for determining the health of the distributed system itself. - */ - public void setDistributedSystemHealthConfig(DistributedSystemHealthConfig config); - - /** - * Returns the <code>GemFireHealthConfig</code> for GemFire components whose configurations are - * not overridden on a per-host basis. Note that changes made to the returned - * <code>GemFireHealthConfig</code> will not take effect until - * {@link #setDefaultGemFireHealthConfig} is invoked. - */ - public GemFireHealthConfig getDefaultGemFireHealthConfig(); - - /** - * Sets the <code>GemFireHealthConfig</code> for GemFire components whose configurations are not - * overridden on a per-host basis. - * - * @throws IllegalArgumentException If <code>config</code> specifies the config for a host - */ - public void setDefaultGemFireHealthConfig(GemFireHealthConfig config); - - /** - * Returns the <code>GemFireHealthConfig</code> for GemFire components that reside on a given - * host. This configuration will override the {@linkplain #getDefaultGemFireHealthConfig default} - * configuration. - * - * @param hostName The {@linkplain java.net.InetAddress#getCanonicalHostName canonical} name of - * the host. - */ - public GemFireHealthConfig getGemFireHealthConfig(String hostName); - - /** - * Sets the <code>GemFireHealthConfig</code> for GemFire components that reside on a given host. - * This configuration will override the {@linkplain #getDefaultGemFireHealthConfig default} - * configuration. Note that changes made to the returned <code>GemFireHealthConfig</code> will not - * take effect until {@link #setDefaultGemFireHealthConfig} is invoked. - * - * @param hostName The {@linkplain java.net.InetAddress#getCanonicalHostName canonical} name of - * the host. - * - * @throws IllegalArgumentException If host <code>hostName</code> does not exist or if there are - * no GemFire components running on that host or if <code>config</code> does not configure - * host <code>hostName</code>. - */ - public void setGemFireHealthConfig(String hostName, GemFireHealthConfig config); - - /** - * Closes this health monitor and releases all resources associated with it. - */ - public void close(); - - /** - * Returns whether or not this <code>GemFireHealth</code> is {@linkplain #close closed}. - */ - public boolean isClosed(); - - ////////////////////// Inner Classes ////////////////////// - - /** - * An enumerated type for the health of GemFire. - */ - public static class Health implements java.io.Serializable { - private static final long serialVersionUID = 3039539430412151801L; - /** The string for good health */ - static final String GOOD_STRING = LocalizedStrings.GemFireHealth_GOOD.toLocalizedString(); - - /** The string for okay health */ - static final String OKAY_STRING = LocalizedStrings.GemFireHealth_OKAY.toLocalizedString(); - - /** The string for poor health */ - static final String POOR_STRING = LocalizedStrings.GemFireHealth_POOR.toLocalizedString(); - - //////////////////// Instance Fields //////////////////// - - /** The string for this health */ - private String healthString; - - ///////////////////// Constructors ////////////////////// - - /** - * Creates a new <code>Health</code> with the given string - */ - protected Health(String healthString) { - this.healthString = healthString; - } - - //////////////////// Instance Methods //////////////////// - - /** - * Returns the appropriate canonical instance of <code>Health</code>. - */ - public Object readResolve() { - if (this.healthString.equals(GOOD_STRING)) { - return GemFireHealth.GOOD_HEALTH; - - } else if (this.healthString.equals(OKAY_STRING)) { - return GemFireHealth.OKAY_HEALTH; - - } else if (this.healthString.equals(POOR_STRING)) { - return GemFireHealth.POOR_HEALTH; - - } else { - Assert.assertTrue(false, "Unknown healthString: " + this.healthString); - return null; - } - } - - @Override - public String toString() { - return this.healthString; - } - - } - -} http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/895fd144/geode-core/src/main/java/org/apache/geode/admin/GemFireHealthConfig.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/GemFireHealthConfig.java b/geode-core/src/main/java/org/apache/geode/admin/GemFireHealthConfig.java deleted file mode 100644 index b31861f..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/GemFireHealthConfig.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; - -/** - * Provides configuration information relating to all of the components of a GemFire distributed - * system. - * - * - * @since GemFire 3.5 - * @deprecated as of 7.0 use the <code><a href= - * "{@docRoot}/org/apache/geode/management/package-summary.html">management</a></code> - * package instead - */ -public interface GemFireHealthConfig extends MemberHealthConfig, CacheHealthConfig { - - /** - * The default number of seconds between assessments of the health of the GemFire components. - */ - public static final int DEFAULT_HEALTH_EVALUATION_INTERVAL = 30; - - ////////////////////// Instance Methods ////////////////////// - - /** - * Returns the name of the host to which this configuration applies. If this is the "default" - * configuration, then <code>null</code> is returned. - * - * @see GemFireHealth#getGemFireHealthConfig - */ - public String getHostName(); - - /** - * Sets the number of seconds between assessments of the health of the GemFire components. - */ - public void setHealthEvaluationInterval(int interval); - - /** - * Returns the number of seconds between assessments of the health of the GemFire components. - */ - public int getHealthEvaluationInterval(); - -} http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/895fd144/geode-core/src/main/java/org/apache/geode/admin/GemFireMemberStatus.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/GemFireMemberStatus.java b/geode-core/src/main/java/org/apache/geode/admin/GemFireMemberStatus.java deleted file mode 100755 index 5b4e59e..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/GemFireMemberStatus.java +++ /dev/null @@ -1,670 +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.cache.Cache; -import org.apache.geode.cache.Region; -import org.apache.geode.cache.client.PoolManager; -import org.apache.geode.cache.server.CacheServer; -import org.apache.geode.distributed.DistributedSystem; -import org.apache.geode.distributed.Locator; -import org.apache.geode.distributed.internal.DM; -import org.apache.geode.distributed.internal.DistributionConfig; -import org.apache.geode.distributed.internal.InternalDistributedSystem; -import org.apache.geode.distributed.internal.membership.InternalDistributedMember; -import org.apache.geode.internal.net.SocketCreator; -import org.apache.geode.internal.admin.ClientHealthMonitoringRegion; -import org.apache.geode.internal.admin.remote.ClientHealthStats; -import org.apache.geode.internal.cache.*; -import org.apache.geode.internal.cache.tier.InternalClientMembership; -import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; - -import java.io.IOException; -import java.io.Serializable; -import java.net.InetAddress; -import java.util.*; - -/** - * Class <code>GemFireMemberStatus</code> provides the status of a specific GemFire member VM. This - * VM can be a peer, a client, a server and/or a gateway. - * - * @deprecated as of 7.0 use the <code><a href= - * "{@docRoot}/org/apache/geode/management/package-summary.html">management</a></code> - * package instead - */ -public class GemFireMemberStatus implements Serializable { - private static final long serialVersionUID = 3389997790525991310L; - - /** - * Notifies whether this member is a client to a cache server. - */ - protected boolean _isClient; - - /** - * Notifies whether this member is a cache server. - */ - protected boolean _isServer; - - /** - * Notifies whether this member is a hub for WAN gateways. - */ - protected boolean _isGatewayHub; - - /** - * Notifies whether this member is a locator. - */ - protected boolean _isLocator; - - protected boolean _isPrimaryGatewayHub; - - protected Object/* GatewayHubStatus */ _gatewayHubStatus; - - protected boolean _isConnected; - protected Serializable _memberId; - protected Set _connectedPeers; - protected Set _connectedServers; - protected Set _unconnectedServers; - protected Set _connectedClients; - protected Map _connectedIncomingGateways; - protected Map _outgoingGateways; - - protected Map _clientHostNames; - protected Map _clientQueueSizes; - protected Map _gatewayQueueSizes; - protected Map _regionStatuses; - protected Map _clientHealthStats; - - protected String _memberName; - protected int _mcastPort; - protected int _serverPort; - protected InetAddress _mcastAddress; - protected String _bindAddress; - protected String _locators; - protected InetAddress _hostAddress; - - protected long _maximumHeapSize; - protected long _freeHeapSize; - - protected long upTime = -1; - - protected transient final Cache cache; - - public GemFireMemberStatus() { - this(null); - } - - public GemFireMemberStatus(Cache cache) { - this.cache = cache; - DistributedSystem ds = null; - if (cache != null) { - ds = cache.getDistributedSystem(); - } - initialize(ds); - } - - public boolean getIsConnected() { - return this._isConnected; - } - - protected void setIsConnected(boolean isConnected) { - this._isConnected = isConnected; - } - - /** - * Returns whether this member is a client to a cache server - * - * @return whether this member is a client to a cache server - */ - public boolean getIsClient() { - return this._isClient; - } - - /** - * Sets whether this member is a client to a cache server - * - * @param isClient Boolean defining whether this member is a client to a cache server - */ - protected void setIsClient(boolean isClient) { - this._isClient = isClient; - } - - /** - * Returns whether this member is a cache server - * - * @return whether this member is a cache server - */ - public boolean getIsServer() { - return this._isServer; - } - - /** - * Sets whether this member is a cache server - * - * @param isServer Boolean defining whether this member is a cache server - */ - protected void setIsServer(boolean isServer) { - this._isServer = isServer; - } - - public int getServerPort() { - return this._serverPort; - } - - protected void setServerPort(int port) { - this._serverPort = port; - } - - /** - * Returns whether this member is a hub for WAN gateways - * - * @return whether this member is a hub for WAN gateways - */ - public boolean getIsGatewayHub() { - return this._isGatewayHub; - } - - /** - * Sets whether this member is a cache server - * - * @param isGatewayHub Boolean defining whether this member is a hub for WAN gateways - */ - protected void setIsGatewayHub(boolean isGatewayHub) { - this._isGatewayHub = isGatewayHub; - } - - public boolean getIsLocator() { - return this._isLocator; - } - - protected void setIsLocator(boolean isLocator) { - this._isLocator = isLocator; - } - - public boolean getIsPrimaryGatewayHub() { - return this._isPrimaryGatewayHub; - } - - protected void setIsPrimaryGatewayHub(boolean isPrimaryGatewayHub) { - this._isPrimaryGatewayHub = isPrimaryGatewayHub; - } - - /** - * For internal use only - * - * @return status of the gateway hub - */ - public Object/* GatewayHubStatus */ getGatewayHubStatus() { - return this._gatewayHubStatus; - } - - // protected void setGatewayHubStatus(GatewayHubStatus gatewayHubStatus) { - // this._gatewayHubStatus = gatewayHubStatus; - // } - - public boolean getIsSecondaryGatewayHub() { - return !this._isPrimaryGatewayHub; - } - - public Set getConnectedPeers() { - return this._connectedPeers; - } - - protected void setConnectedPeers(Set connectedPeers) { - this._connectedPeers = connectedPeers; - } - - public Set getConnectedServers() { - return this._connectedServers; - } - - protected void setConnectedServers(Set connectedServers) { - this._connectedServers = connectedServers; - } - - protected void addConnectedServer(String connectedServer) { - this._connectedServers.add(connectedServer); - } - - public Set getUnconnectedServers() { - return this._unconnectedServers; - } - - protected void setUnconnectedServers(Set unconnectedServers) { - this._unconnectedServers = unconnectedServers; - } - - protected void addUnconnectedServer(String unconnectedServer) { - this._unconnectedServers.add(unconnectedServer); - } - - public Set getConnectedClients() { - return this._connectedClients; - } - - protected void addConnectedClient(String connectedClient) { - this._connectedClients.add(connectedClient); - } - - public Map getOutgoingGateways() { - return this._outgoingGateways; - } - - public Map getConnectedIncomingGateways() { - return this._connectedIncomingGateways; - } - - protected void setConnectedIncomingGateways(Map connectedIncomingGateways) { - this._connectedIncomingGateways = connectedIncomingGateways; - } - - public Map getClientQueueSizes() { - return this._clientQueueSizes; - } - - protected void setClientQueueSizes(Map clientQueueSizes) { - this._clientQueueSizes = clientQueueSizes; - } - - public int getClientQueueSize(String clientMemberId) { - Integer clientQueueSize = (Integer) getClientQueueSizes().get(clientMemberId); - return clientQueueSize == null ? 0 : clientQueueSize.intValue(); - } - - protected void putClientQueueSize(String clientMemberId, int size) { - getClientQueueSizes().put(clientMemberId, Integer.valueOf(size)); - } - - public Map getClientHealthStats() { - return this._clientHealthStats; - } - - protected void setClientHealthStats(Map stats) { - this._clientHealthStats = stats; - } - - /** - * For internal use only - * - * @param clientID client for health - * @return the client's health - */ - public Object/* ClientHealthStats */ getClientHealthStats(String clientID) { - return this._clientHealthStats.get(clientID); - } - - protected void setClientHealthStats(String clientID, ClientHealthStats stats) { - this._clientHealthStats.put(clientID, stats); - } - - protected void putClientHostName(String clientId, String hostName) { - this._clientHostNames.put(clientId, hostName); - } - - public String getClientHostName(String clientId) { - return (String) this._clientHostNames.get(clientId); - } - - public Map getRegionStatuses() { - return this._regionStatuses; - } - - /** - * For internal use only - * - * @param fullRegionPath region path - * @return status for the region - */ - public Object/* RegionStatus */ getRegionStatus(String fullRegionPath) { - return getRegionStatuses().get(fullRegionPath); - } - - protected void putRegionStatus(String fullRegionPath, RegionStatus status) { - getRegionStatuses().put(fullRegionPath, status); - } - - public Serializable getMemberId() { - return this._memberId; - } - - protected void setMemberId(Serializable memberId) { - this._memberId = memberId; - } - - public String getMemberName() { - return this._memberName; - } - - protected void setMemberName(String memberName) { - this._memberName = memberName; - } - - public int getMcastPort() { - return this._mcastPort; - } - - protected void setMcastPort(int mcastPort) { - this._mcastPort = mcastPort; - } - - public InetAddress getMcastAddress() { - return this._mcastAddress; - } - - protected void setMcastAddress(InetAddress mcastAddress) { - this._mcastAddress = mcastAddress; - } - - public InetAddress getHostAddress() { - return this._hostAddress; - } - - protected void setHostAddress(InetAddress hostAddress) { - this._hostAddress = hostAddress; - } - - public String getBindAddress() { - return this._bindAddress; - } - - protected void setBindAddress(String bindAddress) { - this._bindAddress = bindAddress; - } - - public String getLocators() { - return this._locators; - } - - protected void setLocators(String locators) { - this._locators = locators; - } - - public long getMaximumHeapSize() { - return this._maximumHeapSize; - } - - protected void setMaximumHeapSize(long size) { - this._maximumHeapSize = size; - } - - public long getFreeHeapSize() { - return this._freeHeapSize; - } - - protected void setFreeHeapSize(long size) { - this._freeHeapSize = size; - } - - public long getUsedHeapSize() { - return getMaximumHeapSize() - getFreeHeapSize(); - } - - public long getUpTime() { - return upTime; - } - - public void setUpTime(long upTime) { - this.upTime = upTime; - } - - @Override - public String toString() { - StringBuffer buffer = new StringBuffer(); - buffer.append("GemFireMemberStatus[").append("isConnected=").append(this._isConnected) - .append("; memberName=").append(this._memberName).append("; memberId=") - .append(this._memberId).append("; hostAddress=").append(this._hostAddress) - .append("; mcastPort=").append(this._mcastPort).append("; mcastAddress=") - .append(this._mcastAddress).append("; bindAddress=").append(this._bindAddress) - .append("; serverPort=").append(this._serverPort).append("; locators=") - .append(this._locators).append("; isClient=").append(this._isClient).append("; isServer=") - .append(this._isServer).append("; isGatewayHub=").append(this._isGatewayHub) - .append("; isLocator=").append(this._isLocator).append("; isPrimaryGatewayHub=") - .append(this._isPrimaryGatewayHub).append("; gatewayHubStatus=") - .append(this._gatewayHubStatus).append("; connectedPeers=").append(this._connectedPeers) - .append("; connectedServers=").append(this._connectedServers) - .append("; unconnectedServers=").append(this._unconnectedServers) - .append("; connectedClients=").append(this._connectedClients).append("; clientHostNames=") - .append(this._clientHostNames).append("; clientQueueSizes=").append(this._clientQueueSizes) - .append("; clientHealthStats=").append(this._clientHealthStats) - .append("; gatewayQueueSizes=").append(this._gatewayQueueSizes).append("; regionStatuses=") - .append(this._regionStatuses).append("; maximumHeapSize=").append(this._maximumHeapSize) - .append("; freeHeapSize=").append(this._freeHeapSize).append("; upTime=") - .append(this.upTime).append("]"); - return buffer.toString(); - } - - protected void initialize(DistributedSystem distributedSystem) { - // Initialize instance variables - initializeInstanceVariables(); - - // If the cache is set, initialize the status. - // If the cache is not set, then this is most - // likely an unconnected status. - if (cache != null) { - // Initialize server - initializeServer(); - - // Initialize client - initializeClient(); - - // Initialize region sizes - initializeRegionSizes(); - } - - if (distributedSystem != null) { - // Initialize all - initializeAll(distributedSystem); - } - - // If this is a locator, initialize the locator status - if (Locator.getLocators().size() > 0) { - setIsLocator(true); - } - } - - protected void initializeInstanceVariables() { - // Variables for servers - this._connectedClients = new HashSet(); - this._clientQueueSizes = new HashMap(); - this._clientHealthStats = new HashMap(); - this._clientHostNames = new HashMap(); - - // Variables for gateway hubs - this._outgoingGateways = new HashMap(); - // this._connectedOutgoingGateways = new HashSet(); - // this._unconnectedOutgoingGateways = new HashSet(); - this._connectedIncomingGateways = new HashMap(); - this._gatewayQueueSizes = new HashMap(); - - // Variables for clients - this._connectedServers = new HashSet(); - this._unconnectedServers = new HashSet(); - - // Variables for all - this._connectedPeers = new HashSet(); - this._regionStatuses = new HashMap(); - } - - protected void initializeServer() { - Collection servers = cache.getCacheServers(); - if (servers.size() == 0) { - setIsServer(false); - } else { - setIsServer(true); - - // Get connected clients. - // The following method returns a map of client member id to a cache - // client info. For now, keep track of the member ids in the set of - // _connectedClients. - Map allConnectedClients = - InternalClientMembership.getStatusForAllClientsIgnoreSubscriptionStatus(); - Iterator allConnectedClientsIterator = allConnectedClients.values().iterator(); - while (allConnectedClientsIterator.hasNext()) { - CacheClientStatus ccs = (CacheClientStatus) allConnectedClientsIterator.next(); - addConnectedClient(ccs.getMemberId()); - // host address is available directly by id, hence CacheClientStatus need not be populated - putClientHostName(ccs.getMemberId(), ccs.getHostAddress()); - } - - // Get client queue sizes - Map clientQueueSize = getClientIDMap(InternalClientMembership.getClientQueueSizes()); - setClientQueueSizes(clientQueueSize); - - // Set server acceptor port (set it based on the first CacheServer) - CacheServer server = (CacheServer) servers.toArray()[0]; - setServerPort(server.getPort()); - - // Get Client Health Stats - // Assert.assertTrue(cache != null); (cannot be null) - Region clientHealthMonitoringRegion = - ClientHealthMonitoringRegion.getInstance((GemFireCacheImpl) cache); - if (clientHealthMonitoringRegion != null) { - String[] clients = (String[]) clientHealthMonitoringRegion.keySet().toArray(new String[0]); - for (int i = 0; i < clients.length; i++) { - String clientId = clients[i]; - ClientHealthStats stats = (ClientHealthStats) clientHealthMonitoringRegion.get(clientId); - setClientHealthStats(clientId, stats); - } - } - } - } - - /** - * returning Map of client queue size against client Id - * - * param clientMap is a Map of client queue size against ClientProxyMembershipID - */ - private Map getClientIDMap(Map ClientProxyMembershipIDMap) { - Map clientIdMap = new HashMap(); - Set entrySet = ClientProxyMembershipIDMap.entrySet(); - Iterator entries = entrySet.iterator(); - while (entries.hasNext()) { - Map.Entry entry = (Map.Entry) entries.next(); - ClientProxyMembershipID key = (ClientProxyMembershipID) entry.getKey(); - Integer size = (Integer) entry.getValue(); - clientIdMap.put(key.getDSMembership(), size); - } - return clientIdMap; - } - - protected void initializeClient() { - Map poolMap = PoolManager.getAll(); - if (poolMap.size() == 0) { - setIsClient(false); - } else { - setIsClient(true); - - // Get connected servers. - // The following method returns a map of server name to a count of logical - // connections. A logical connection will be made for each region that - // references the live server. If the client is not connected to the server, - // the logical connections for that server will be 0. For now, keep track - // of the keys (server names) of this map in the sets of _connectedServers - // and _unconnectedServers. - Map connectedServers = InternalClientMembership.getConnectedServers(); - if (!connectedServers.isEmpty()) { - Iterator connected = connectedServers.entrySet().iterator(); - while (connected.hasNext()) { - Map.Entry entry = (Map.Entry) connected.next(); - String server = (String) entry.getKey(); - // Integer connections = (Integer) entry.getValue(); - // if (connections.intValue()==0) { - // addUnconnectedServer(server); - // } else { - addConnectedServer(server); - // } - // System.out.println(connections.size() + " logical connnections to server " + server); - } - } - } - } - - protected void initializeAll(DistributedSystem distributedSystem) { - // Initialize isConnected - setIsConnected(true); - - // Initialize distributed system status - initializeDistributedSystem(distributedSystem); - - // Initialize peers - initializePeers(distributedSystem); - - // Initialize memory - initializeMemory(); - } - - protected void initializeDistributedSystem(DistributedSystem distributedSystem) { - InternalDistributedSystem ids = (InternalDistributedSystem) distributedSystem; - setMemberId(ids.getMemberId()); - DistributionConfig config = ids.getConfig(); - setMemberName(config.getName()); - setMcastPort(config.getMcastPort()); - setMcastAddress(config.getMcastAddress()); - String bindAddress = config.getBindAddress(); - setBindAddress(bindAddress); - setLocators(config.getLocators()); - setUpTime(System.currentTimeMillis() - ids.getStartTime()); - try { - setHostAddress((bindAddress != null && bindAddress.length() > 0) - ? InetAddress.getByName(bindAddress) : SocketCreator.getLocalHost()); - } catch (IOException e) { - /* ignore - leave null host address */} - } - - protected void initializePeers(DistributedSystem distributedSystem) { - InternalDistributedSystem ids = (InternalDistributedSystem) distributedSystem; - DM dm = ids.getDistributionManager(); - Set connections = dm.getOtherNormalDistributionManagerIds(); - Set connectionsIDs = new HashSet(connections.size()); - for (Iterator iter = connections.iterator(); iter.hasNext();) { - InternalDistributedMember idm = (InternalDistributedMember) iter.next(); - connectionsIDs.add(idm.getId()); - } - setConnectedPeers(connectionsIDs); - } - - protected void initializeMemory() { - // InternalDistributedSystem system = (InternalDistributedSystem) - // region.getCache().getDistributedSystem(); - // GemFireStatSampler sampler = system.getStatSampler(); - // VMStatsContract statsContract = sampler.getVMStats(); - - Runtime rt = Runtime.getRuntime(); - setMaximumHeapSize(rt.maxMemory()); - setFreeHeapSize(rt.freeMemory()); - } - - protected void initializeRegionSizes() { - Iterator rootRegions = cache.rootRegions().iterator(); - - while (rootRegions.hasNext()) { - LocalRegion rootRegion = (LocalRegion) rootRegions.next(); - if (!(rootRegion instanceof HARegion)) { - RegionStatus rootRegionStatus = rootRegion instanceof PartitionedRegion - ? new PartitionedRegionStatus((PartitionedRegion) rootRegion) - : new RegionStatus(rootRegion); - putRegionStatus(rootRegion.getFullPath(), rootRegionStatus); - Iterator subRegions = rootRegion.subregions(true).iterator(); - while (subRegions.hasNext()) { - LocalRegion subRegion = (LocalRegion) subRegions.next(); - RegionStatus subRegionStatus = subRegion instanceof PartitionedRegion - ? new PartitionedRegionStatus((PartitionedRegion) subRegion) - : new RegionStatus(subRegion); - putRegionStatus(subRegion.getFullPath(), subRegionStatus); - } - } - } - } -} - http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/895fd144/geode-core/src/main/java/org/apache/geode/admin/ManagedEntity.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/ManagedEntity.java b/geode-core/src/main/java/org/apache/geode/admin/ManagedEntity.java deleted file mode 100644 index 1eaa892..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/ManagedEntity.java +++ /dev/null @@ -1,100 +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 entity that can be managed with the GemFire administration API. - * - * @see ManagedEntityConfig - * - * @since GemFire 4.0 - * @deprecated as of 7.0 use the <code><a href= - * "{@docRoot}/org/apache/geode/management/package-summary.html">management</a></code> - * package instead - */ -public interface ManagedEntity { - - /** - * Starts this managed entity. Note that this method may return before the managed entity is - * actually started. - * - * @throws AdminException If a problem is encountered while starting this managed entity. - * @throws IllegalStateException If this managed entity resides on a remote machine and a - * <code>null</code> or empty (<code>""</code>) - * {@linkplain ManagedEntityConfig#getRemoteCommand remote command} has been specified. - * - * @see #waitToStart - */ - public void start() throws AdminException; - - /** - * Stops this managed entity. Note that this method may return before the managed entity is - * actually stopped. - * - * @throws AdminException If a problem is encountered while stopping this managed entity. - * @throws IllegalStateException If this managed entity resides on a remote machine and a - * <code>null</code> or empty (<code>""</code>) - * {@linkplain ManagedEntityConfig#getRemoteCommand remote command} has been specified. - * - * @see #waitToStop - */ - public void stop() throws AdminException; - - /** - * Waits for up to a given number of milliseconds for this managed entity to {@linkplain #start - * start}. - * - * @param timeout The number of milliseconds to wait for this managed entity to start. - * - * @return Whether or not the entity has started. <code>false</code>, if the method times out. - * - * @throws InterruptedException If the thread invoking this method is interrupted while waiting. - */ - public boolean waitToStart(long timeout) throws InterruptedException; - - /** - * Waits for up to a given number of milliseconds for this managed entity to {@linkplain #stop - * stop}. - * - * @param timeout The number of milliseconds to wait for this managed entity to stop. - * - * @return Whether or not the entity has stopped. <code>false</code>, if the method times out. - * - * @throws InterruptedException If the thread invoking this method is interrupted while waiting. - */ - public boolean waitToStop(long timeout) throws InterruptedException; - - /** - * Returns whether or not this managed entity is running. Note that this operation may attempt to - * contact the managed entity. - * - * @throws IllegalStateException If this managed entity resides on a remote machine and a - * <code>null</code> or empty (<code>""</code>) - * {@linkplain ManagedEntityConfig#getRemoteCommand remote command} has been specified. - */ - public boolean isRunning(); - - /** - * Returns the tail of this manage entity's log file. Note that not all managed entities implement - * this functionality. - * - * @throws AdminException If a problem is encountered while getting the log of this managed - * entity. - * @throws UnsupportedOperationException If this managed entity does not support retrieving its - * log. - */ - public String getLog() throws AdminException; - -} http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/895fd144/geode-core/src/main/java/org/apache/geode/admin/ManagedEntityConfig.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/ManagedEntityConfig.java b/geode-core/src/main/java/org/apache/geode/admin/ManagedEntityConfig.java deleted file mode 100644 index 0b7acd7..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/ManagedEntityConfig.java +++ /dev/null @@ -1,88 +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; - -/** - * Common configuration for all entities that can be managed using the GemFire administration API. - * Note that once a managed entity has been {@linkplain ManagedEntity#start started}, attempts to - * modify its configuration will cause an {@link IllegalStateException} to be thrown. - * - * @see ManagedEntity - * - * @since GemFire 4.0 - * @deprecated as of 7.0 use the <code><a href= - * "{@docRoot}/org/apache/geode/management/package-summary.html">management</a></code> - * package instead - */ -public interface ManagedEntityConfig extends Cloneable { - - /** - * Returns the name of the host on which the managed entity runs or will run. - */ - public String getHost(); - - /** - * Sets the name of the host on which the managed entity will run. - */ - public void setHost(String host); - - /** - * Returns the name of the working directory in which the managed entity runs or will run. - */ - public String getWorkingDirectory(); - - /** - * Sets the name of the working directory in which the managed entity will run. - */ - public void setWorkingDirectory(String dir); - - /** - * Returns the name of the GemFire product directory to use when administering the managed entity. - */ - public String getProductDirectory(); - - /** - * Sets the name of the GemFire product directory to use when administering the managed entity. - */ - public void setProductDirectory(String dir); - - /** - * Returns the command prefix used to administer a managed entity that is hosted on a remote - * machine. If the remote command is <code>null</code> (the default value), then the remote - * command associated with the {@linkplain AdminDistributedSystem#getRemoteCommand() distributed - * system} will be used. - */ - public String getRemoteCommand(); - - /** - * Sets the command prefix used to administer a managed entity that is hosted on a remote machine. - */ - public void setRemoteCommand(String remoteCommand); - - /** - * Validates this configuration. - * - * @throws IllegalStateException If a managed entity cannot be administered using this - * configuration - */ - public void validate(); - - /** - * Returns a new <code>ManagedEntityConfig</code> with the same configuration as this - * <code>ManagedEntityConfig</code>. - */ - public Object clone() throws CloneNotSupportedException; - -} http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/895fd144/geode-core/src/main/java/org/apache/geode/admin/MemberHealthConfig.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/MemberHealthConfig.java b/geode-core/src/main/java/org/apache/geode/admin/MemberHealthConfig.java deleted file mode 100644 index 63dd605..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/MemberHealthConfig.java +++ /dev/null @@ -1,142 +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. - * - * <P> - * - * If any of the following criteria is true, then a member is considered to be in - * {@link GemFireHealth#OKAY_HEALTH OKAY_HEALTH}. - * - * <UL> - * - * <LI>The size of the {@linkplain #getMaxVMProcessSize VM process} is too large.</LI> - * - * <LI>There are too many {@linkplain #getMaxMessageQueueSize enqueued} incoming/outgoing - * messages.</LI> - * - * <LI>Too many message sends {@link #getMaxReplyTimeouts timeout} while waiting for a reply.</LI> - * - * </UL> - * - * If any of the following criteria is true, then a member is considered to be in - * {@link GemFireHealth#POOR_HEALTH POOR_HEALTH}. - * - * <UL> - * - * </UL> - * - * - * @since GemFire 3.5 - * @deprecated as of 7.0 use the <code><a href= - * "{@docRoot}/org/apache/geode/management/package-summary.html">management</a></code> - * package instead - */ -public interface MemberHealthConfig { - - /** - * The default maximum VM process size (in megabytes) of a health member of the distributed - * system. The default value is 1000. - */ - public static final long DEFAULT_MAX_VM_PROCESS_SIZE = 1000; - - /** - * The default maximum number of enqueued incoming or outgoing messages that a healthy member of a - * distributed system can have. The default value is 1000. - */ - public static final long DEFAULT_MAX_MESSAGE_QUEUE_SIZE = 1000; - - /** - * The default maximum number of message reply timeouts that can occur in a given health - * monitoring interval. The default value is zero. - */ - public static final long DEFAULT_MAX_REPLY_TIMEOUTS = 0; - - /** - * The default maximum multicast retransmission ratio. The default value is 0.20 (twenty percent - * of messages retransmitted) - */ - public static final double DEFAULT_MAX_RETRANSMISSION_RATIO = 0.20; - - /////////////////////// Instance Methods /////////////////////// - - /** - * Returns the maximum VM process size (in megabytes) of a healthy member of the distributed - * system. - * - * @see #DEFAULT_MAX_VM_PROCESS_SIZE - */ - public long getMaxVMProcessSize(); - - /** - * Sets the maximum VM process size (in megabytes) of a healthy member of the distributed system. - * - * @see #getMaxVMProcessSize - */ - public void setMaxVMProcessSize(long size); - - /** - * Returns the maximum number of enqueued incoming or outgoing messages that a healthy member of a - * distributed system can have. - * - * @see #DEFAULT_MAX_MESSAGE_QUEUE_SIZE - */ - public long getMaxMessageQueueSize(); - - /** - * Sets the maximum number of enqueued incoming or outgoing messages that a healthy member of a - * distributed system can have. - * - * @see #getMaxMessageQueueSize - */ - public void setMaxMessageQueueSize(long maxMessageQueueSize); - - /** - * Returns the maximum number message replies that can timeout in a healthy member. - * - * @see #DEFAULT_MAX_REPLY_TIMEOUTS - */ - public long getMaxReplyTimeouts(); - - /** - * Sets the maximum number message replies that can timeout in a healthy member. - * - * @see #getMaxReplyTimeouts - */ - public void setMaxReplyTimeouts(long maxReplyTimeouts); - - /** - * Returns the maximum ratio of multicast retransmissions / total multicast messages. - * Retransmissions are requestor-specific (i.e., unicast), so a single lost message may result in - * multiple retransmissions. - * <p> - * A high retransmission ratio may indicate poor network conditions requiring reduced flow-control - * settings, a udp-fragment-size setting that is too high. - * - * @see #DEFAULT_MAX_RETRANSMISSION_RATIO - */ - public double getMaxRetransmissionRatio(); - - /** - * Sets the maximum ratio of multicast retransmissions / total multicast messages. - * - * @see #getMaxRetransmissionRatio - */ - public void setMaxRetransmissionRatio(double ratio); - -} http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/895fd144/geode-core/src/main/java/org/apache/geode/admin/OperationCancelledException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/OperationCancelledException.java b/geode-core/src/main/java/org/apache/geode/admin/OperationCancelledException.java deleted file mode 100644 index 0328641..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/OperationCancelledException.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; - -// import org.apache.geode.GemFireException; - -/** - * Thrown when an administration operation that accesses information in a remote system member is - * cancelled. The cancelation may occur because the system member has left the distributed system. - * - * @since GemFire 3.5 - * @deprecated as of 7.0 use the <code><a href= - * "{@docRoot}/org/apache/geode/management/package-summary.html">management</a></code> - * package instead - */ -public class OperationCancelledException extends RuntimeAdminException { - private static final long serialVersionUID = 5474068770227602546L; - - public OperationCancelledException() { - super(); - } - - public OperationCancelledException(String message) { - super(message); - } - - public OperationCancelledException(Throwable cause) { - super(cause); - } - - public OperationCancelledException(String message, Throwable cause) { - super(message, cause); - } -} http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/895fd144/geode-core/src/main/java/org/apache/geode/admin/RegionNotFoundException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/RegionNotFoundException.java b/geode-core/src/main/java/org/apache/geode/admin/RegionNotFoundException.java deleted file mode 100644 index e849a70..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/RegionNotFoundException.java +++ /dev/null @@ -1,39 +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.cache.CacheException; -import org.apache.geode.cache.CacheRuntimeException; - -/** - * Thrown by the administration API when the region administered by a {@link SystemMemberRegion} has - * been closed or destroyed in system member. - * <P> - * Also thrown by {@link org.apache.geode.DataSerializer#readRegion(java.io.DataInput)} if the named - * region no longer exists. - * - * @since GemFire 3.5 - * @deprecated as of 7.0 use the <code><a href= - * "{@docRoot}/org/apache/geode/management/package-summary.html">management</a></code> - * package instead - */ -public class RegionNotFoundException extends CacheRuntimeException { - private static final long serialVersionUID = 1758668137691463909L; - - public RegionNotFoundException(String message) { - super(message); - } - -}
