http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/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 29dfa98..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); - } - -}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/main/java/org/apache/geode/admin/RegionSubRegionSnapshot.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/RegionSubRegionSnapshot.java b/geode-core/src/main/java/org/apache/geode/admin/RegionSubRegionSnapshot.java deleted file mode 100644 index 1945566..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/RegionSubRegionSnapshot.java +++ /dev/null @@ -1,192 +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.io.DataInput; -import java.io.DataOutput; -import java.io.IOException; -import java.util.HashSet; -import java.util.Iterator; -import java.util.Set; - -import org.apache.geode.DataSerializable; -import org.apache.geode.DataSerializer; -import org.apache.geode.cache.Region; -import org.apache.geode.i18n.LogWriterI18n; -import org.apache.geode.internal.cache.PartitionedRegion; - -/** - * Class <code>RegionSubRegionSnapshot</code> provides information about - * <code>Region</code>s. This also provides the information about sub regions - * This class is used by the monitoring tool. - * - * - * @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 class RegionSubRegionSnapshot implements DataSerializable { - private static final long serialVersionUID = -8052137675270041871L; - public RegionSubRegionSnapshot() { - this.parent = null; - this.subRegionSnapshots = new HashSet(); - } - - public RegionSubRegionSnapshot(Region reg) { - this(); - this.name = reg.getName(); - if (reg instanceof PartitionedRegion) { - PartitionedRegion p_reg = (PartitionedRegion)reg; - this.entryCount = p_reg.entryCount(true); - } - else { - this.entryCount = reg.entrySet().size(); - } - final LogWriterI18n logger = reg.getCache().getLoggerI18n(); - if((logger != null) && logger.fineEnabled()) { - logger.fine( - "RegionSubRegionSnapshot Region entry count =" + this.entryCount - + " for region =" + this.name); - } - } - - /** - * add the snapshot of sub region - * - * @param snap - * snapshot of sub region - * @return true if operation is successful - */ - public boolean addSubRegion(RegionSubRegionSnapshot snap) { - if (subRegionSnapshots.contains(snap)) { - return true; - } - - if (subRegionSnapshots.add(snap)) { - snap.setParent(this); - return true; - } - - return false; - } - - /** - * @return get entry count of region - */ - public final int getEntryCount() { - return entryCount; - } - - /** - * @param entryCount - * entry count of region - */ - public final void setEntryCount(int entryCount) { - this.entryCount = entryCount; - } - - /** - * @return name of region - */ - public final String getName() { - return name; - } - - /** - * @param name - * name of region - */ - public final void setName(String name) { - this.name = name; - } - - /** - * @return subRegionSnapshots of all the sub regions - */ - public final Set getSubRegionSnapshots() { - return subRegionSnapshots; - } - - /** - * @param subRegionSnapshots - * subRegionSnapshots of all the sub regions - */ - public final void setSubRegionSnapshots(Set subRegionSnapshots) { - this.subRegionSnapshots = subRegionSnapshots; - } - - /** - * @return snapshot of parent region - */ - public final RegionSubRegionSnapshot getParent() { - return parent; - } - - /** - * @param parent - * snapshot of parent region - */ - public final void setParent(RegionSubRegionSnapshot parent) { - this.parent = parent; - } - - /** - * - * @return full path of region - */ - public String getFullPath() { - return (getParent() == null ? "/" : getParent().getFullPath()) + getName() - + "/"; - } - - public void toData(DataOutput out) throws IOException { - DataSerializer.writeString(this.name, out); - out.writeInt(this.entryCount); - DataSerializer.writeHashSet((HashSet)this.subRegionSnapshots, out); - } - - public void fromData(DataInput in) throws IOException, ClassNotFoundException { - this.name = DataSerializer.readString(in); - this.entryCount = in.readInt(); - this.subRegionSnapshots = DataSerializer.readHashSet(in); - for (Iterator iter = this.subRegionSnapshots.iterator(); iter.hasNext();) { - ((RegionSubRegionSnapshot)iter.next()).setParent(this); - } - } - - @Override - public String toString() { - String toStr = "RegionSnapshot [" + "path=" + this.getFullPath() - + ",parent=" + (this.parent == null ? "null" : this.parent.name) - + ", entryCount=" + this.entryCount + ", subRegionCount=" - + this.subRegionSnapshots.size() + "<<"; - - for (Iterator iter = subRegionSnapshots.iterator(); iter.hasNext();) { - toStr = toStr + ((RegionSubRegionSnapshot)iter.next()).getName() + ", "; - } - - toStr = toStr + ">>" + "]"; - return toStr; - } - - protected String name; - - protected int entryCount; - - protected RegionSubRegionSnapshot parent; - - protected Set subRegionSnapshots; -} http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/main/java/org/apache/geode/admin/RuntimeAdminException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/RuntimeAdminException.java b/geode-core/src/main/java/org/apache/geode/admin/RuntimeAdminException.java deleted file mode 100755 index 7a28867..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/RuntimeAdminException.java +++ /dev/null @@ -1,49 +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 <code>RuntimeAdminException</code> is thrown when a runtime errors occurs - * during administration or monitoring of GemFire. - * - * @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 RuntimeAdminException -extends org.apache.geode.GemFireException { - - private static final long serialVersionUID = -7512771113818634005L; - - public RuntimeAdminException() { - super(); - } - - public RuntimeAdminException(String message) { - super(message); - } - - public RuntimeAdminException(String message, Throwable cause) { - super(message, cause); - } - - public RuntimeAdminException(Throwable cause) { - super(cause); - } - -} http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/main/java/org/apache/geode/admin/Statistic.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/Statistic.java b/geode-core/src/main/java/org/apache/geode/admin/Statistic.java deleted file mode 100755 index b1f1cc8..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/Statistic.java +++ /dev/null @@ -1,65 +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; - -/** - * Interface to represent a single statistic of a <code>StatisticResource</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 Statistic extends java.io.Serializable { - - /** - * Gets the identifying name of this statistic. - * - * @return the identifying name of this statistic - */ - public String getName(); - - /** - * Gets the value of this statistic as a <code>java.lang.Number</code>. - * - * @return the value of this statistic - */ - public Number getValue(); - - /** - * Gets the unit of measurement (if any) this statistic represents. - * - * @return the unit of measurement (if any) this statistic represents - */ - public String getUnits(); - - /** - * Returns true if this statistic represents a numeric value which always - * increases. - * - * @return true if this statistic represents a value which always increases - */ - public boolean isCounter(); - - /** - * Gets the full description of this statistic. - * - * @return the full description of this statistic - */ - public String getDescription(); -} - http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/main/java/org/apache/geode/admin/StatisticResource.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/StatisticResource.java b/geode-core/src/main/java/org/apache/geode/admin/StatisticResource.java deleted file mode 100755 index 43c51cd..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/StatisticResource.java +++ /dev/null @@ -1,85 +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; - -/** - * Adminitrative interface for monitoring a statistic resource in a GemFire - * system member. A resource is comprised of one or many - * <code>Statistics</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 StatisticResource { - - /** - * Gets the identifying name of this resource. - * - * @return the identifying name of this resource - */ - public String getName(); - - /** - * Gets the full description of this resource. - * - * @return the full description of this resource - */ - public String getDescription(); - - /** - * Gets the classification type of this resource. - * - * @return the classification type of this resource - * @since GemFire 5.0 - */ - public String getType(); - - /** - * Returns a display string of the {@link SystemMember} owning this - * resource. - * - * @return a display string of the owning {@link SystemMember} - */ - public String getOwner(); - - /** - * Returns an ID that uniquely identifies the resource within the - * {@link SystemMember} it belongs to. - * - * @return unique id within the owning {@link SystemMember} - */ - public long getUniqueId(); - - /** - * Returns a read-only array of every {@link Statistic} in this resource. - * - * @return read-only array of every {@link Statistic} in this resource - */ - public Statistic[] getStatistics(); - - /** - * Refreshes the values of every {@link Statistic} in this resource by - * retrieving them from the member's VM. - * - * @throws org.apache.geode.admin.AdminException - * if unable to refresh statistic values - */ - public void refresh() throws org.apache.geode.admin.AdminException; - -} - http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/main/java/org/apache/geode/admin/SystemMember.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/SystemMember.java b/geode-core/src/main/java/org/apache/geode/admin/SystemMember.java deleted file mode 100755 index 78cc9aa..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/SystemMember.java +++ /dev/null @@ -1,147 +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.distributed.DistributedMember; - -import java.net.InetAddress; - -/** - * Administrative interface for monitoring a GemFire system member. - * - * @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 SystemMember { - - /** Gets the {@link AdminDistributedSystem} this member belongs to. */ - public AdminDistributedSystem getDistributedSystem(); - - /** - * Gets identifying name of this member. - * For applications this is the string form of {@link #getDistributedMember}. - * For cache servers it is a unique cache server string. - */ - public String getId(); - - /** - * Retrieves display friendly name for this member. If this member 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.SystemMember#getId}. - * - * @see org.apache.geode.distributed.DistributedSystem#connect - * @see org.apache.geode.distributed.DistributedSystem#getName - */ - public String getName(); - - /** Gets the type of {@link SystemMemberType} this member is. */ - public SystemMemberType getType(); - - /** Gets host name of the machine this member resides on. */ - public String getHost(); - - /** Gets the host of this member as an <code>java.net.InetAddress<code>. */ - public InetAddress getHostAddress(); - - /** Retrieves the log for this member. */ - public String getLog(); - - /** - * Returns the GemFire license this member is using. - * - * @deprecated Removed licensing in 8.0. - */ - @Deprecated - public java.util.Properties getLicense(); - - /** Returns this member's GemFire version information. */ - public String getVersion(); - - /** - * Gets the configuration parameters for this member. - */ - public ConfigurationParameter[] getConfiguration(); - - /** - * Sets the configuration of this member. The argument is an array of any - * and all configuration parameters that are to be updated in the member. - * <p> - * The entire array of configuration parameters is then returned. - * - * @param parms subset of the configuration parameters to be changed - * @return all configuration parameters including those that were changed - * @throws org.apache.geode.admin.AdminException - * if this fails to make the configuration changes - */ - public ConfigurationParameter[] setConfiguration(ConfigurationParameter[] parms) throws org.apache.geode.admin.AdminException; - - /** Refreshes this member's configuration from the member or it's properties */ - public void refreshConfig() throws org.apache.geode.admin.AdminException; - - /** - * Retrieves this members statistic resources. If the member is not running - * then an empty array is returned. - * - *@param statisticsTypeName String ame of the Statistics Type - * @return array of runtime statistic resources owned by this member - * @since GemFire 5.7 - */ - public StatisticResource[] getStat(String statisticsTypeName) throws org.apache.geode.admin.AdminException; - - /** - * Retrieves this members statistic resources. If the member is not running - * then an empty array is returned. All Stats are returned - * - * @return array of runtime statistic resources owned by this member - */ - public StatisticResource[] getStats() throws org.apache.geode.admin.AdminException; - - /** - * Returns whether or not this system member hosts a GemFire {@link - * org.apache.geode.cache.Cache Cache}. - * - * @see #getCache - */ - public boolean hasCache() - throws org.apache.geode.admin.AdminException; - - /** - * Returns an object that provides admin access to this member's cache. - * If the member currently has no cache then <code>null</code> is returned. - */ - public SystemMemberCache getCache() throws org.apache.geode.admin.AdminException; - - /** - * Returns the names of the membership roles filled by this member. - * - * @return array of string membership role names - * @since GemFire 5.0 - */ - public String[] getRoles(); - - /** - * Returns the {@link org.apache.geode.distributed.DistributedMember} - * that represents this system member. - * - * @return DistributedMember instance representing this system member - * @since GemFire 5.0 - */ - public DistributedMember getDistributedMember(); -} - http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/main/java/org/apache/geode/admin/SystemMemberBridgeServer.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/SystemMemberBridgeServer.java b/geode-core/src/main/java/org/apache/geode/admin/SystemMemberBridgeServer.java deleted file mode 100644 index 71fb7e1..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/SystemMemberBridgeServer.java +++ /dev/null @@ -1,308 +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.server.ServerLoadProbe; - -/** - * Administrative interface that represents a CacheServer that - * serves the contents of a system member's cache. - * - * @see SystemMemberCache#addCacheServer - * - * @since GemFire 4.0 - * @deprecated as of 5.7 use {@link SystemMemberCacheServer} instead. - */ -@Deprecated -public interface SystemMemberBridgeServer { - - /** - * Returns the port on which this bridge server listens for bridge - * clients to connect. - */ - public int getPort(); - - /** - * Sets the port on which this bridge server listens for bridge - * clients to connect. - * - * @throws AdminException - * If this bridge server is running - */ - public void setPort(int port) throws AdminException; - - /** - * Starts this bridge server. Once the server is running, its - * configuration cannot be changed. - * - * @throws AdminException - * If an error occurs while starting the bridge server - */ - public void start() throws AdminException; - - /** - * Returns whether or not this bridge server is running - */ - public boolean isRunning(); - - /** - * Stops this bridge server. Note that the - * <code>BridgeServer</code> can be reconfigured and restarted if - * desired. - */ - public void stop() throws AdminException; - - /** - * Updates the information about this bridge server. - */ - public void refresh(); - - /** - * Returns a string representing the ip address or host name that this server - * will listen on. - * @return the ip address or host name that this server is to listen on - * @since GemFire 5.7 - */ - public String getBindAddress(); - /** - * Sets the ip address or host name that this server is to listen on for - * client connections. - * <p>Setting a specific bind address will cause the bridge server to always - * use this address and ignore any address specified by "server-bind-address" - * or "bind-address" in the <code>gemfire.properties</code> file - * (see {@link org.apache.geode.distributed.DistributedSystem} - * for a description of these properties). - * <p> A <code>null</code> value will be treated the same as the default "". - * <p> The default value does not override the gemfire.properties. If you wish to - * override the properties and want to have your server bind to all local - * addresses then use this string <code>"0.0.0.0"</code>. - * @param address the ip address or host name that this server is to listen on - * @throws AdminException if this bridge server is running - * @since GemFire 5.7 - */ - public void setBindAddress(String address) throws AdminException; - /** - * Returns a string representing the ip address or host name that server locators - * will tell clients that this server is listening on. - * @return the ip address or host name to give to clients so they can connect - * to this server - * @since GemFire 5.7 - */ - public String getHostnameForClients(); - /** - * Sets the ip address or host name that this server is to listen on for - * client connections. - * <p>Setting a specific hostname-for-clients will cause server locators - * to use this value when telling clients how to connect to this server. - * <p> The default value causes the bind-address to be given to clients - * <p> A <code>null</code> value will be treated the same as the default "". - * @param name the ip address or host name that will be given to clients - * so they can connect to this server - * @throws AdminException if this bridge server is running - * @since GemFire 5.7 - */ - public void setHostnameForClients(String name) throws AdminException; - /** - * Sets whether or not this bridge server should notify clients based on - * key subscription. - * - * If false, then an update to any key on the server causes an update to - * be sent to all clients. This update does not push the actual data to the - * clients. Instead, it causes the client to locally invalidate or destroy - * the corresponding entry. The next time the client requests the key, it - * goes to the bridge server for the value. - * - * If true, then an update to any key on the server causes an update to be - * sent to only those clients who have registered interest in that key. Other - * clients are not notified of the change. In addition, the actual value is - * pushed to the client. The client does not need to request the new value - * from the bridge server. - * @throws AdminException if this bridge server is running - * @since GemFire 5.7 - */ - public void setNotifyBySubscription(boolean b) throws AdminException; - - /** - * Answers whether or not this bridge server should notify clients based on - * key subscription. - * @since GemFire 5.7 - */ - public boolean getNotifyBySubscription(); - - /** - * Sets the buffer size in bytes of the socket connection for this - * <code>BridgeServer</code>. The default is 32768 bytes. - * - * @param socketBufferSize The size in bytes of the socket buffer - * @throws AdminException if this bridge server is running - * @since GemFire 5.7 - */ - public void setSocketBufferSize(int socketBufferSize) throws AdminException; - - /** - * Returns the configured buffer size of the socket connection for this - * <code>BridgeServer</code>. The default is 32768 bytes. - * @return the configured buffer size of the socket connection for this - * <code>BridgeServer</code> - * @since GemFire 5.7 - */ - public int getSocketBufferSize(); - - /** - * Sets the maximum amount of time between client pings. This value is - * used by the <code>ClientHealthMonitor</code> to determine the health - * of this <code>BridgeServer</code>'s clients. The default is 60000 ms. - * - * @param maximumTimeBetweenPings The maximum amount of time between client - * pings - * @throws AdminException if this bridge server is running - * @since GemFire 5.7 - */ - public void setMaximumTimeBetweenPings(int maximumTimeBetweenPings) throws AdminException; - - /** - * Returns the maximum amount of time between client pings. This value is - * used by the <code>ClientHealthMonitor</code> to determine the health - * of this <code>BridgeServer</code>'s clients. The default is 60000 ms. - * @return the maximum amount of time between client pings. - * @since GemFire 5.7 - */ - public int getMaximumTimeBetweenPings(); - - /** - * Returns the maximum allowed client connections - * @since GemFire 5.7 - */ - public int getMaxConnections(); - - /** - * Sets the maxium number of client connections allowed. - * When the maximum is reached the server will stop accepting - * connections. - * @throws AdminException if this bridge server is running - * @since GemFire 5.7 - */ - public void setMaxConnections(int maxCons) throws AdminException; - - /** - * Returns the maxium number of threads allowed in this server to service - * client requests. - * The default of <code>0</code> causes the server to dedicate a thread for - * every client connection. - * @since GemFire 5.7 - */ - public int getMaxThreads(); - - /** - * Sets the maxium number of threads allowed in this server to service - * client requests. - * The default of <code>0</code> causes the server to dedicate a thread for - * every client connection. - * @throws AdminException if this bridge server is running - * @since GemFire 5.7 - */ - public void setMaxThreads(int maxThreads) throws AdminException; - - /** - * Returns the maximum number of messages that can be enqueued in a - * client-queue. - * @since GemFire 5.7 - */ - public int getMaximumMessageCount(); - - /** - * Sets maximum number of messages that can be enqueued in a client-queue. - * @throws AdminException if this bridge server is running - * @since GemFire 5.7 - */ - public void setMaximumMessageCount(int maxMessageCount) throws AdminException; - - /** - * Returns the time (in seconds ) after which a message in the client queue - * will expire. - * @since GemFire 5.7 - */ - public int getMessageTimeToLive(); - - /** - * Sets the time (in seconds ) after which a message in the client queue - * will expire. - * @throws AdminException if this bridge server is running - * @since GemFire 5.7 - */ - public void setMessageTimeToLive(int messageTimeToLive) throws AdminException; - /** - * Sets the list of server groups this bridge server will belong to. - * By default bridge servers belong to the default global server group - * which all bridge servers always belong to. - * @param groups possibly empty array of <code>String</code> where each string - * is a server groups that this bridge server will be a member of. - * @throws AdminException if this bridge server is running - * @since GemFire 5.7 - */ - public void setGroups(String[] groups) throws AdminException; - /** - * Returns the list of server groups that this bridge server belongs to. - * @return a possibly empty array of <code>String</code>s where - * each string is a server group. Modifying this array will not change the - * server groups that this bridge server belongs to. - * @since GemFire 5.7 - */ - public String[] getGroups(); - - /** - * Get a description of the load probe for this bridge server. - * {@link ServerLoadProbe} for details on the load probe. - * @return the load probe used by this bridge - * server. - * @since GemFire 5.7 - */ - public String getLoadProbe(); - - /** - * Set the load probe for this bridge server. See - * {@link ServerLoadProbe} for details on how to implement - * a load probe. - * - * The load probe should implement DataSerializable if - * it is used with this interface, because it will be sent to the remote - * VM. - * @param loadProbe the load probe to use for - * this bridge server. - * @throws AdminException if the bridge server is running - * @since GemFire 5.7 - */ - public void setLoadProbe(ServerLoadProbe loadProbe) throws AdminException; - - /** - * Get the frequency in milliseconds to poll the load probe on this bridge - * server. - * - * @return the frequency in milliseconds that we will poll the load probe. - */ - public long getLoadPollInterval(); - - /** - * Set the frequency in milliseconds to poll the load probe on this bridge - * server - * @param loadPollInterval the frequency in milliseconds to poll - * the load probe. Must be greater than 0. - * @throws AdminException if the bridge server is running - */ - public void setLoadPollInterval(long loadPollInterval) throws AdminException; - -} http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/main/java/org/apache/geode/admin/SystemMemberCache.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/SystemMemberCache.java b/geode-core/src/main/java/org/apache/geode/admin/SystemMemberCache.java deleted file mode 100644 index 2c194ca..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/SystemMemberCache.java +++ /dev/null @@ -1,204 +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.RegionAttributes; - -/** - * Administrative interface that represent's the {@link SystemMember}'s view - * of its {@link org.apache.geode.cache.Cache}. - * - * @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 SystemMemberCache { - // attributes - /** - * The name of the cache. - */ - public String getName(); - /** - * Value that uniquely identifies an instance of a cache for a given member. - */ - public int getId(); - /** - * Indicates if this cache has been closed. - * @return true, if this cache is closed; false, otherwise - */ - public boolean isClosed(); - /** - * Gets the number of seconds a cache operation will wait to obtain - * a distributed lock lease. - */ - public int getLockTimeout(); - /** - * Sets the number of seconds a cache operation may wait to obtain a - * distributed lock lease before timing out. - * - * @throws AdminException - * If a problem is encountered while setting the lock - * timeout - * - * @see org.apache.geode.cache.Cache#setLockTimeout - */ - public void setLockTimeout(int seconds) throws AdminException; - - /** - * Gets the length, in seconds, of distributed lock leases obtained - * by this cache. - */ - public int getLockLease(); - /** - * Sets the length, in seconds, of distributed lock leases obtained - * by this cache. - * - * @throws AdminException - * If a problem is encountered while setting the lock - * lease - * - * @see org.apache.geode.cache.Cache#setLockLease - */ - public void setLockLease(int seconds) throws AdminException; - - /** - * Gets the number of seconds a cache - * {@link org.apache.geode.cache.Region#get(Object) get} operation - * can spend searching for a value before it times out. - * The search includes any time spent loading the object. - * When the search times out it causes the get to fail by throwing - * an exception. - */ - public int getSearchTimeout(); - /** - * Sets the number of seconds a cache get operation can spend searching - * for a value. - * - * @throws AdminException - * If a problem is encountered while setting the search - * timeout - * - * @see org.apache.geode.cache.Cache#setSearchTimeout - */ - public void setSearchTimeout(int seconds) throws AdminException; - /** - * Returns number of seconds since this member's cache has been created. - * Returns <code>-1</code> if this member does not have a cache or its cache - * has been closed. - */ - public int getUpTime(); - - /** - * Returns the names of all the root regions currently in this cache. - */ - public java.util.Set getRootRegionNames(); - - // operations - - /** - * Returns statistics related to this cache's performance. - */ - public Statistic[] getStatistics(); - - /** - * Return the existing region (or subregion) with the specified - * path that already exists in the cache. - * Whether or not the path starts with a forward slash it is interpreted as a - * full path starting at a root. - * - * @param path the path to the region - * @return the Region or null if not found - * @throws IllegalArgumentException if path is null, the empty string, or "/" - */ - public SystemMemberRegion getRegion(String path) throws AdminException; - - /** - * Creates a VM root <code>Region</code> in this cache. - * - * @param name - * The name of the region to create - * @param attrs - * The attributes of the root region - * - * @throws AdminException - * If the region cannot be created - * - * @since GemFire 4.0 - * @deprecated as of GemFire 5.0, use {@link #createRegion} instead - */ - @Deprecated - public SystemMemberRegion createVMRegion(String name, - RegionAttributes attrs) - throws AdminException; - - /** - * Creates a root <code>Region</code> in this cache. - * - * @param name - * The name of the region to create - * @param attrs - * The attributes of the root region - * - * @throws AdminException - * If the region cannot be created - * - * @since GemFire 5.0 - */ - public SystemMemberRegion createRegion(String name, - RegionAttributes attrs) - throws AdminException; - - /** - * Updates the state of this cache instance. Note that once a cache - * instance is closed refresh will never change the state of that instance. - */ - public void refresh(); - - /** - * Adds a new, unstarted cache server that will serve the contents - * of this cache to clients. - * - * @see org.apache.geode.cache.Cache#addCacheServer - * - * @since GemFire 5.7 - */ - public SystemMemberCacheServer addCacheServer() - throws AdminException; - - /** - * Returns the cache servers that run in this member's VM. Note - * that this list will not be updated until {@link #refresh} is - * called. - * - * @see org.apache.geode.cache.Cache#getCacheServers - * - * @since GemFire 5.7 - */ - public SystemMemberCacheServer[] getCacheServers() - throws AdminException; - - /** - * Returns whether or not this cache acts as a server. This method - * will always return <code>true</code> for the - * <code>SystemMemberCache</code> obtained from a {@link - * CacheServer}. Note that this value will not be updated until - * {@link #refresh} is invoked. - * - * @since GemFire 4.0 - */ - public boolean isServer() throws AdminException; -} - http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/main/java/org/apache/geode/admin/SystemMemberCacheEvent.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/SystemMemberCacheEvent.java b/geode-core/src/main/java/org/apache/geode/admin/SystemMemberCacheEvent.java deleted file mode 100644 index dee9bc1..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/SystemMemberCacheEvent.java +++ /dev/null @@ -1,33 +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.Operation; -/** - * An event that describes an operation on a cache. - * Instances of this are delivered to a {@link SystemMemberCacheListener} when a - * a cache is created or closed. - * - * @since GemFire 5.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 SystemMemberCacheEvent extends SystemMembershipEvent { - /** - * Returns the actual operation that caused this event. - */ - public Operation getOperation(); -} http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/main/java/org/apache/geode/admin/SystemMemberCacheListener.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/SystemMemberCacheListener.java b/geode-core/src/main/java/org/apache/geode/admin/SystemMemberCacheListener.java deleted file mode 100644 index 0d258b6..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/SystemMemberCacheListener.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; - -import org.apache.geode.cache.*; - -/** - * A listener whose callback methods can be used to track the lifecycle of - * {@link Cache caches} and {@link Region regions} in the GemFire distributed system. - * - * @see AdminDistributedSystem#addCacheListener - * @see AdminDistributedSystem#removeCacheListener - * - * @since GemFire 5.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 SystemMemberCacheListener { - - /** - * Invoked after a region is created in any node of distributed system. - * @param event describes the region that was created. - * @see CacheFactory#create - * @see Cache#createRegion - * @see Region#createSubregion - */ - public void afterRegionCreate(SystemMemberRegionEvent event); - - /** - * Invoked when a region is destroyed or closed in any node of distributed system. - * @param event describes the region that was lost. The operation on this event - * can be used to determine the actual operation that caused the loss. Note that - * {@link Cache#close()} invokes this callback with <code>Operation.CACHE_CLOSE</code> - * for each region in the closed cache and it invokes {@link #afterCacheClose}. - - * @see Cache#close() - * @see Region#close - * @see Region#localDestroyRegion() - * @see Region#destroyRegion() - */ - public void afterRegionLoss(SystemMemberRegionEvent event); - - /** - * Invoked after a cache is created in any node of a distributed system. - * Note that this callback will be done before any regions are created in the - * cache. - * @param event describes the member that created the cache. - * @see CacheFactory#create - */ - public void afterCacheCreate(SystemMemberCacheEvent event); - /** - * Invoked after a cache is closed in any node of a distributed system. - * This callback is done after those done for each region in the cache. - * This callback is not done if the distributed member that has a cache crashes. - * @param event describes the member that closed its cache. - * @see Cache#close() - */ - public void afterCacheClose(SystemMemberCacheEvent event); -} http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/main/java/org/apache/geode/admin/SystemMemberCacheServer.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/SystemMemberCacheServer.java b/geode-core/src/main/java/org/apache/geode/admin/SystemMemberCacheServer.java deleted file mode 100755 index daf2199..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/SystemMemberCacheServer.java +++ /dev/null @@ -1,308 +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.server.ServerLoadProbe; - -/** - * Administrative interface that represents a {@link - * org.apache.geode.cache.server.CacheServer CacheServer} that - * serves the contents of a system member's cache to clients. - * - * @see SystemMemberCache#addCacheServer - * - * @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 SystemMemberCacheServer { - - /** - * Returns the port on which this cache server listens for - * clients to connect. - */ - public int getPort(); - - /** - * Sets the port on which this cache server listens for - * clients to connect. - * - * @throws AdminException - * If this cache server is running - */ - public void setPort(int port) throws AdminException; - - /** - * Starts this cache server. Once the server is running, its - * configuration cannot be changed. - * - * @throws AdminException - * If an error occurs while starting the cache server - */ - public void start() throws AdminException; - - /** - * Returns whether or not this cache server is running - */ - public boolean isRunning(); - - /** - * Stops this cache server. Note that the - * <code>CacheServer</code> can be reconfigured and restarted if - * desired. - */ - public void stop() throws AdminException; - - /** - * Updates the information about this cache server. - */ - public void refresh(); - - /** - * Returns a string representing the ip address or host name that this server - * will listen on. - * @return the ip address or host name that this server is to listen on - * @since GemFire 5.7 - */ - public String getBindAddress(); - /** - * Sets the ip address or host name that this server is to listen on for - * client connections. - * <p>Setting a specific bind address will cause the cache server to always - * use this address and ignore any address specified by "server-bind-address" - * or "bind-address" in the <code>gemfire.properties</code> file - * (see {@link org.apache.geode.distributed.DistributedSystem} - * for a description of these properties). - * <p> A <code>null</code> value will be treated the same as the default "". - * <p> The default value does not override the gemfire.properties. If you wish to - * override the properties and want to have your server bind to all local - * addresses then use this string <code>"0.0.0.0"</code>. - * @param address the ip address or host name that this server is to listen on - * @throws AdminException if this cache server is running - * @since GemFire 5.7 - */ - public void setBindAddress(String address) throws AdminException; - /** - * Returns a string representing the ip address or host name that server locators - * will tell clients that this server is listening on. - * @return the ip address or host name to give to clients so they can connect - * to this server - * @since GemFire 5.7 - */ - public String getHostnameForClients(); - /** - * Sets the ip address or host name that this server is to listen on for - * client connections. - * <p>Setting a specific hostname-for-clients will cause server locators - * to use this value when telling clients how to connect to this server. - * <p> The default value causes the bind-address to be given to clients - * <p> A <code>null</code> value will be treated the same as the default "". - * @param name the ip address or host name that will be given to clients - * so they can connect to this server - * @throws AdminException if this cache server is running - * @since GemFire 5.7 - */ - public void setHostnameForClients(String name) throws AdminException; - /** - * Sets whether or not this cache server should notify clients based on - * key subscription. - * - * If false, then an update to any key on the server causes an update to - * be sent to all clients. This update does not push the actual data to the - * clients. Instead, it causes the client to locally invalidate or destroy - * the corresponding entry. The next time the client requests the key, it - * goes to the cache server for the value. - * - * If true, then an update to any key on the server causes an update to be - * sent to only those clients who have registered interest in that key. Other - * clients are not notified of the change. In addition, the actual value is - * pushed to the client. The client does not need to request the new value - * from the cache server. - * @throws AdminException if this cache server is running - * @since GemFire 5.7 - */ - public void setNotifyBySubscription(boolean b) throws AdminException; - - /** - * Answers whether or not this cache server should notify clients based on - * key subscription. - * @since GemFire 5.7 - */ - public boolean getNotifyBySubscription(); - - /** - * Sets the buffer size in bytes of the socket connection for this - * <code>CacheServer</code>. The default is 32768 bytes. - * - * @param socketBufferSize The size in bytes of the socket buffer - * @throws AdminException if this cache server is running - * @since GemFire 5.7 - */ - public void setSocketBufferSize(int socketBufferSize) throws AdminException; - - /** - * Returns the configured buffer size of the socket connection for this - * <code>CacheServer</code>. The default is 32768 bytes. - * @return the configured buffer size of the socket connection for this - * <code>CacheServer</code> - * @since GemFire 5.7 - */ - public int getSocketBufferSize(); - - /** - * Sets the maximum amount of time between client pings. This value is - * used by the <code>ClientHealthMonitor</code> to determine the health - * of this <code>CacheServer</code>'s clients. The default is 60000 ms. - * - * @param maximumTimeBetweenPings The maximum amount of time between client - * pings - * @throws AdminException if this cache server is running - * @since GemFire 5.7 - */ - public void setMaximumTimeBetweenPings(int maximumTimeBetweenPings) throws AdminException; - - /** - * Returns the maximum amount of time between client pings. This value is - * used by the <code>ClientHealthMonitor</code> to determine the health - * of this <code>CacheServer</code>'s clients. The default is 60000 ms. - * @return the maximum amount of time between client pings. - * @since GemFire 5.7 - */ - public int getMaximumTimeBetweenPings(); - - /** - * Returns the maximum allowed client connections - * @since GemFire 5.7 - */ - public int getMaxConnections(); - - /** - * Sets the maxium number of client connections allowed. - * When the maximum is reached the server will stop accepting - * connections. - * @throws AdminException if this cache server is running - * @since GemFire 5.7 - */ - public void setMaxConnections(int maxCons) throws AdminException; - - /** - * Returns the maxium number of threads allowed in this server to service - * client requests. - * The default of <code>0</code> causes the server to dedicate a thread for - * every client connection. - * @since GemFire 5.7 - */ - public int getMaxThreads(); - - /** - * Sets the maxium number of threads allowed in this server to service - * client requests. - * The default of <code>0</code> causes the server to dedicate a thread for - * every client connection. - * @throws AdminException if this cache server is running - * @since GemFire 5.7 - */ - public void setMaxThreads(int maxThreads) throws AdminException; - - /** - * Returns the maximum number of messages that can be enqueued in a - * client-queue. - * @since GemFire 5.7 - */ - public int getMaximumMessageCount(); - - /** - * Sets maximum number of messages that can be enqueued in a client-queue. - * @throws AdminException if this cache server is running - * @since GemFire 5.7 - */ - public void setMaximumMessageCount(int maxMessageCount) throws AdminException; - - /** - * Returns the time (in seconds ) after which a message in the client queue - * will expire. - * @since GemFire 5.7 - */ - public int getMessageTimeToLive(); - - /** - * Sets the time (in seconds ) after which a message in the client queue - * will expire. - * @throws AdminException if this cache server is running - * @since GemFire 5.7 - */ - public void setMessageTimeToLive(int messageTimeToLive) throws AdminException; - /** - * Sets the list of server groups this cache server will belong to. - * By default cache servers belong to the default global server group - * which all cache servers always belong to. - * @param groups possibly empty array of <code>String</code> where each string - * is a server groups that this cache server will be a member of. - * @throws AdminException if this cache server is running - * @since GemFire 5.7 - */ - public void setGroups(String[] groups) throws AdminException; - /** - * Returns the list of server groups that this cache server belongs to. - * @return a possibly empty array of <code>String</code>s where - * each string is a server group. Modifying this array will not change the - * server groups that this cache server belongs to. - * @since GemFire 5.7 - */ - public String[] getGroups(); - - /** - * Get a description of the load probe for this cache server. - * {@link ServerLoadProbe} for details on the load probe. - * @return the load probe used by this cache - * server. - * @since GemFire 5.7 - */ - public String getLoadProbe(); - - /** - * Set the load probe for this cache server. See - * {@link ServerLoadProbe} for details on how to implement - * a load probe. - * - * The load probe should implement DataSerializable if - * it is used with this interface, because it will be sent to the remote - * VM. - * @param loadProbe the load probe to use for - * this cache server. - * @throws AdminException if the cache server is running - * @since GemFire 5.7 - */ - public void setLoadProbe(ServerLoadProbe loadProbe) throws AdminException; - - /** - * Get the frequency in milliseconds to poll the load probe on this cache - * server. - * - * @return the frequency in milliseconds that we will poll the load probe. - */ - public long getLoadPollInterval(); - - /** - * Set the frequency in milliseconds to poll the load probe on this cache - * server - * @param loadPollInterval the frequency in milliseconds to poll - * the load probe. Must be greater than 0. - * @throws AdminException if the cache server is running - */ - public void setLoadPollInterval(long loadPollInterval) throws AdminException; - -} http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/main/java/org/apache/geode/admin/SystemMemberRegion.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/SystemMemberRegion.java b/geode-core/src/main/java/org/apache/geode/admin/SystemMemberRegion.java deleted file mode 100644 index 22acdcc..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/SystemMemberRegion.java +++ /dev/null @@ -1,321 +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.*; -import java.io.File; - -/** - * Administrative interface that represent's the {@link - * SystemMember}'s view of one of its cache's {@link - * org.apache.geode.cache.Region}s. If the region in the remote - * system member is closed or destroyed, the methods of - * <code>SystemMemberRegion</code> will throw {@link - * RegionNotFoundException}. - * - * @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 SystemMemberRegion { - // attributes - /** - * Returns the name that identifies this region in its cache. - * - * @see org.apache.geode.cache.Region#getName - */ - public String getName(); - - /** - * Returns the full path name that identifies this region in its - * cache. - * - * @see org.apache.geode.cache.Region#getFullPath - */ - public String getFullPath(); - - /** - * Returns the names of all the subregions of this region. - */ - public java.util.Set getSubregionNames(); - - /** - * Returns the full path of each of the subregions of this region. - * These paths are suitable for use with {@link - * SystemMemberCache#getRegion}. - */ - public java.util.Set getSubregionFullPaths(); - - /** - * Returns a description of any user attribute associated with this - * region. The description includes the classname of the user - * attribute object as well as its <code>toString</code> - * representation. - */ - public String getUserAttribute(); - - /** - * Returns a description of any CacheLoader associated with this region. - */ - public String getCacheLoader(); - /** - * Returns a description of any CacheWriter associated with this region. - */ - public String getCacheWriter(); - - /** - * Returns the <code>EvictionAttributes</code> that configure how - * entries in the the region are evicted - */ - public EvictionAttributes getEvictionAttributes(); - - /** - * Returns a description of the CacheListener in this region's attributes. If - * there is more than 1 CacheListener defined for a region this method will - * return the description of the 1st CacheListener returned from - * {@link #getCacheListeners} - * - * @deprecated as of 6.0 use getCacheListeners() instead - */ - @Deprecated - public String getCacheListener(); - - /** - * This method will return an empty array if there are no CacheListeners - * defined on the region. If there are one or more than 1 CacheListeners - * defined, this method will return an array which has the names of all the - * CacheListeners - * - * @return String[] the region's <code>CacheListeners</code> as a String array - * @since GemFire 6.0 - */ - public String[] getCacheListeners(); - - /** - * Returns the KeyConstraint in this region's attributes. - */ - public String getKeyConstraint(); - - /** - * Returns the ValueConstraint in this region's attributes. - */ - public String getValueConstraint(); - - /** - * Returns the RegionTimeToLive time limit in this region's attributes. - */ - public int getRegionTimeToLiveTimeLimit(); - - /** - * Returns the RegionTimeToLive action in this region's attributes. - */ - public ExpirationAction getRegionTimeToLiveAction(); - - /** - * Returns the EntryTimeToLive time limit in this region's attributes. - */ - public int getEntryTimeToLiveTimeLimit(); - - /** - * Returns the EntryTimeToLive action in this region's attributes. - */ - public ExpirationAction getEntryTimeToLiveAction(); - - /** - * string describing the CustomExpiry for entry-time-to-live - * @return the CustomExpiry for entry-time-to-live - */ - public String getCustomEntryTimeToLive(); - - /** - * Returns the RegionIdleTimeout time limit in this region's attributes. - */ - public int getRegionIdleTimeoutTimeLimit(); - - /** - * Returns the RegionIdleTimeout action in this region's attributes. - */ - public ExpirationAction getRegionIdleTimeoutAction(); - - /** - * Returns the EntryIdleTimeout time limit in this region's attributes. - */ - public int getEntryIdleTimeoutTimeLimit(); - - /** - * Returns the EntryIdleTimeout action in this region's attributes. - */ - public ExpirationAction getEntryIdleTimeoutAction(); - - /** - * string describing the CustomExpiry for entry-idle-timeout - * @return the CustomExpiry for entry-idle-timeout - */ - public String getCustomEntryIdleTimeout(); - - /** - * Returns the MirrorType in this region's attributes. - * @deprecated as of 5.0, you should use getDataPolicy instead - */ - @Deprecated - public MirrorType getMirrorType(); - - /** - * Returns the DataPolicy in this region's attributes. - */ - public DataPolicy getDataPolicy(); - - /** - - /** - * Returns the Scope in this region's attributes. - */ - public Scope getScope(); - - /** - * Returns the InitialCapacity in this region's attributes. - */ - public int getInitialCapacity(); - - /** - * Returns the LoadFactor in this region's attributes. - */ - public float getLoadFactor(); - - /** - * Returns the ConcurrencyLevel in this region's attributes. - */ - public int getConcurrencyLevel(); - - /** - * Returns whether or not conflicting concurrent operations on this region - * are prevented - */ - public boolean getConcurrencyChecksEnabled(); - - /** - * Returns the StatisticsEnabled in this region's attributes. - */ - public boolean getStatisticsEnabled(); - - /** - * Returns whether or not a persistent backup should be made of the - * region (as opposed to just writing the overflow data to disk). - */ - public boolean getPersistBackup(); - - /** - * Returns the <code>DiskWriteAttributes</code> that configure how - * the region is written to disk. - */ - public DiskWriteAttributes getDiskWriteAttributes(); - - /** - * Returns the directories to which the region's data are written. If - * multiple directories are used, GemFire will attempt to distribute the - * data evenly amongst them. - */ - public File[] getDiskDirs(); - - /** - * Returns the number of entries currently in this region. - */ - public int getEntryCount(); - - /** - * Returns the number of subregions currently in this region. - */ - public int getSubregionCount(); - - /** - * Returns the LastModifiedTime obtained from this region's statistics. - */ - public long getLastModifiedTime(); - - /** - * Returns the LastAccessedTime obtained from this region's statistics. - */ - public long getLastAccessedTime(); - - /** - * Returns the HitCount obtained from this region's statistics. - */ - public long getHitCount(); - - /** - * Returns the MissCount obtained from this region's statistics. - */ - public long getMissCount(); - - /** - * Returns the HitRatio obtained from this region's statistics. - */ - public float getHitRatio(); - - /** - * Returns whether or not acks are sent after an update is processed. - * @return False if acks are sent after updates are processed; - * true if acks are sent before updates are processed. - * - * @since GemFire 4.1 - */ - public boolean getEarlyAck(); - - // operations - /** - * Updates the state of this region instance. Note that once a cache - * instance is closed refresh will never change the state of its regions. - */ - public void refresh(); - - /** - * Creates a subregion of this region. - * - * @param name - * The name of the region to create - * @param attrs - * The attributes of the root region - * - * @throws AdminException - * If the region cannot be created - * - * @since GemFire 4.0 - */ - public SystemMemberRegion createSubregion(String name, - RegionAttributes attrs) - throws AdminException; - - /** - * Returns the <code>MembershipAttributes</code> that configure required - * roles for reliable access to the region. - * @deprecated this API is scheduled to be removed - */ - public MembershipAttributes getMembershipAttributes(); - - /** - * Returns the <code>SubscriptionAttributes</code> for the region. - * @since GemFire 5.0 - */ - public SubscriptionAttributes getSubscriptionAttributes(); - - /** - * Returns the <code>PartitionAttributes</code> for the region. - * @since GemFire 5.7 - */ - public PartitionAttributes getPartitionAttributes(); - -} - http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/main/java/org/apache/geode/admin/SystemMemberRegionEvent.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/SystemMemberRegionEvent.java b/geode-core/src/main/java/org/apache/geode/admin/SystemMemberRegionEvent.java deleted file mode 100644 index 2dd1ffd..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/SystemMemberRegionEvent.java +++ /dev/null @@ -1,32 +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 event that describes an operation on a region. - * Instances of this are delivered to a {@link SystemMemberCacheListener} when a - * a region comes or goes. - * - * @since GemFire 5.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 SystemMemberRegionEvent extends SystemMemberCacheEvent { - /** - * Returns the full path of the region the event was done on. - */ - public String getRegionPath(); -} http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/main/java/org/apache/geode/admin/SystemMemberType.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/SystemMemberType.java b/geode-core/src/main/java/org/apache/geode/admin/SystemMemberType.java deleted file mode 100755 index 7ba99fb..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/SystemMemberType.java +++ /dev/null @@ -1,145 +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.io.*; - -/** - * Type-safe definition for system members. - * - * @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 SystemMemberType implements java.io.Serializable { - private static final long serialVersionUID = 3284366994485749302L; - - /** GemFire shared-memory manager connected to the distributed system */ - public static final SystemMemberType MANAGER = - new SystemMemberType("GemFireManager"); - - /** Application connected to the distributed system */ - public static final SystemMemberType APPLICATION = - new SystemMemberType("Application"); - - /** GemFire Cache VM connected to the distributed system */ - public static final SystemMemberType CACHE_VM = - new SystemMemberType("CacheVm"); - - /** GemFire Cache Server connected to the distributed system - * @deprecated as of 5.7 use {@link #CACHE_VM} instead. - */ - @Deprecated - public static final SystemMemberType CACHE_SERVER = CACHE_VM; - - - /** The display-friendly name of this system member type. */ - private final transient String name; - - // The 4 declarations below are necessary for serialization - /** int used as ordinal to represent this Scope */ - public final int ordinal = nextOrdinal++; - - private static int nextOrdinal = 0; - - private static final SystemMemberType[] VALUES = - { MANAGER, APPLICATION, CACHE_VM }; - - private Object readResolve() throws java.io.ObjectStreamException { - return VALUES[ordinal]; // Canonicalize - } - - /** Creates a new instance of SystemMemberType. */ - private SystemMemberType(String name) { - this.name = name; - } - - /** Return the SystemMemberType represented by specified ordinal */ - public static SystemMemberType fromOrdinal(int ordinal) { - return VALUES[ordinal]; - } - - public String getName() { - return this.name; - } - - /** Return whether this is <code>MANAGER</code>. */ - public boolean isManager() { - return this.equals(MANAGER); - } - - /** Return whether this is <code>APPLICATION</code>. */ - public boolean isApplication() { - return this.equals(APPLICATION); - } - - /** Return whether this is <code>CACHE_SERVER</code>. - * @deprecated as of 5.7 use {@link #isCacheVm} instead. - */ - @Deprecated - public boolean isCacheServer() { - return isCacheVm(); - } - /** Return whether this is <code>CACHE_VM</code>. - */ - public boolean isCacheVm() { - return this.equals(CACHE_VM); - } - - /** - * Returns a string representation for this system member type. - * - * @return the name of this system member type - */ - @Override - public String toString() { - return this.name; - } - - /** - * 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 SystemMemberType)) return false; - final SystemMemberType that = (SystemMemberType) other; - if (this.ordinal != that.ordinal) 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.ordinal; - return result; - } - -} - http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/main/java/org/apache/geode/admin/SystemMembershipEvent.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/SystemMembershipEvent.java b/geode-core/src/main/java/org/apache/geode/admin/SystemMembershipEvent.java deleted file mode 100644 index 9319de5..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/SystemMembershipEvent.java +++ /dev/null @@ -1,40 +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.distributed.DistributedMember; -/** - * An event that describes the distributed member originated this event. - * Instances of this are delivered to a {@link SystemMembershipListener} when a - * member has joined or 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 interface SystemMembershipEvent { - /** - * Returns the distributed member as a String. - */ - public String getMemberId(); - - /** - * Returns the {@link DistributedMember} that this event originated in. - * @return the member that performed the operation that originated this event. - * @since GemFire 5.0 - */ - public DistributedMember getDistributedMember(); -} http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/main/java/org/apache/geode/admin/SystemMembershipListener.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/SystemMembershipListener.java b/geode-core/src/main/java/org/apache/geode/admin/SystemMembershipListener.java deleted file mode 100644 index b1d6afe..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/SystemMembershipListener.java +++ /dev/null @@ -1,61 +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 members join or - * leave the GemFire distributed system. - * - * @see AdminDistributedSystem#addMembershipListener - * - * @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 SystemMembershipListener { - - /** - * Invoked when a member has joined the distributed system - */ - public void memberJoined(SystemMembershipEvent event); - - /** - * Invoked when a member has gracefully left the distributed system. This - * occurs when the member took action to remove itself from the distributed - * system. - */ - public void memberLeft(SystemMembershipEvent event); - - /** - * Invoked when a member has unexpectedly left the distributed - * system. This occurs when a member is forcibly removed from the - * distributed system by another process, such as from - * <a href=../distributed/DistributedSystem.html#member-timeout> failure detection</a>, or - * <a href=../distributed/DistributedSystem.html#enable-network-partition-detection> - * network partition detection</a> processing. - */ - public void memberCrashed(SystemMembershipEvent event); - -// /** -// * Invoked when a member broadcasts an informational message. -// * -// * @see org.apache.geode.distributed.DistributedSystem#fireInfoEvent -// * -// * @since GemFire 4.0 -// */ -// public void memberInfo(SystemMembershipEvent event); - -} http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/main/java/org/apache/geode/admin/UnmodifiableConfigurationException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/UnmodifiableConfigurationException.java b/geode-core/src/main/java/org/apache/geode/admin/UnmodifiableConfigurationException.java deleted file mode 100755 index e89fc96..0000000 --- a/geode-core/src/main/java/org/apache/geode/admin/UnmodifiableConfigurationException.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; - -/** - * An <code>UnmodifiableConfigurationException</code> is thrown when an attempt - * is made to modify the value of an unmodifiable - * {@link ConfigurationParameter}. - * - * @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 UnmodifiableConfigurationException extends AdminException { -private static final long serialVersionUID = -7653547392992060646L; - - /** - * Constructs a new exception with <code>null</code> as its detail message. - * The cause is not initialized, and may subsequently be initialized by a - * call to {@link Throwable#initCause}. - */ - public UnmodifiableConfigurationException() { - 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 UnmodifiableConfigurationException(String message) { - super(message); - } - - /** - * Constructs a new exception with the specified detail message and - * cause. <p>Note that the detail message associated with - * <code>cause</code> is <i>not</i> 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 <tt>null</tt> value is - * permitted, and indicates that the cause is nonexistent or - * unknown.) - */ - public UnmodifiableConfigurationException(String message, Throwable cause) { - super(message, cause); - } - - /** - * Constructs a new exception with the specified cause and a detail - * message of <tt>(cause==null ? null : cause.toString())</tt> (which - * typically contains the class and detail message of <tt>cause</tt>). - * 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 <tt>null</tt> value is - * permitted, and indicates that the cause is nonexistent or - * unknown.) - */ - public UnmodifiableConfigurationException(Throwable cause) { - super(cause); - } - -} -
