You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by kl...@apache.org on 2017/06/15 21:54:59 UTC
[26/40] geode git commit: GEODE-2980: remove unnecessary explicit
keywords from interfaces
http://git-wip-us.apache.org/repos/asf/geode/blob/ebb691dd/geode-core/src/main/java/org/apache/geode/internal/sequencelog/SequenceLogger.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/sequencelog/SequenceLogger.java b/geode-core/src/main/java/org/apache/geode/internal/sequencelog/SequenceLogger.java
index 530737f..c4a8b3b 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/sequencelog/SequenceLogger.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/sequencelog/SequenceLogger.java
@@ -46,10 +46,10 @@ public interface SequenceLogger {
* @param source the source, for example ("member 1, region 1");
* @param dest the destination, for example ("member 2, region 1");
*/
- public void logTransition(GraphType type, Object graphName, Object edgeName, Object state,
- Object source, Object dest);
+ void logTransition(GraphType type, Object graphName, Object edgeName, Object state, Object source,
+ Object dest);
- public boolean isEnabled(GraphType type);
+ boolean isEnabled(GraphType type);
- public void flush() throws InterruptedException;
+ void flush() throws InterruptedException;
}
http://git-wip-us.apache.org/repos/asf/geode/blob/ebb691dd/geode-core/src/main/java/org/apache/geode/internal/sequencelog/io/Filter.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/sequencelog/io/Filter.java b/geode-core/src/main/java/org/apache/geode/internal/sequencelog/io/Filter.java
index e4d630c..0bbda18 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/sequencelog/io/Filter.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/sequencelog/io/Filter.java
@@ -23,10 +23,9 @@ import org.apache.geode.internal.sequencelog.GraphType;
*/
public interface Filter {
- public boolean accept(GraphType graphType, String name, String edgeName, String source,
- String dest);
+ boolean accept(GraphType graphType, String name, String edgeName, String source, String dest);
- public boolean acceptPattern(GraphType graphType, Pattern pattern, String edgeName, String source,
+ boolean acceptPattern(GraphType graphType, Pattern pattern, String edgeName, String source,
String dest);
}
http://git-wip-us.apache.org/repos/asf/geode/blob/ebb691dd/geode-core/src/main/java/org/apache/geode/internal/sequencelog/model/GraphReaderCallback.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/sequencelog/model/GraphReaderCallback.java b/geode-core/src/main/java/org/apache/geode/internal/sequencelog/model/GraphReaderCallback.java
index a1abd96..b644677 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/sequencelog/model/GraphReaderCallback.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/sequencelog/model/GraphReaderCallback.java
@@ -23,10 +23,10 @@ import org.apache.geode.internal.sequencelog.GraphType;
*/
public interface GraphReaderCallback {
- public abstract void addEdge(long timestamp, GraphType graphType, String graphName,
- String edgeName, String state, String source, String dest);
+ void addEdge(long timestamp, GraphType graphType, String graphName, String edgeName, String state,
+ String source, String dest);
- public abstract void addEdgePattern(long timestamp, GraphType graphType, Pattern graphNamePattern,
+ void addEdgePattern(long timestamp, GraphType graphType, Pattern graphNamePattern,
String edgeName, String state, String source, String dest);
}
http://git-wip-us.apache.org/repos/asf/geode/blob/ebb691dd/geode-core/src/main/java/org/apache/geode/internal/shared/NativeCalls.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/shared/NativeCalls.java b/geode-core/src/main/java/org/apache/geode/internal/shared/NativeCalls.java
index 238abcf..c20a5ef 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/shared/NativeCalls.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/shared/NativeCalls.java
@@ -431,12 +431,12 @@ public abstract class NativeCalls {
*
* @since GemFire 8.0
*/
- public static interface RehashServerOnSIGHUP {
+ public interface RehashServerOnSIGHUP {
/**
* Perform the actions required to "rehash" the server.
*/
- public void rehash();
+ void rehash();
}
/**
http://git-wip-us.apache.org/repos/asf/geode/blob/ebb691dd/geode-core/src/main/java/org/apache/geode/internal/shared/NativeCallsJNAImpl.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/shared/NativeCallsJNAImpl.java b/geode-core/src/main/java/org/apache/geode/internal/shared/NativeCallsJNAImpl.java
index 760144a..e9daec2 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/shared/NativeCallsJNAImpl.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/shared/NativeCallsJNAImpl.java
@@ -134,7 +134,7 @@ public class NativeCallsJNAImpl {
static final Map<String, String> javaEnv = getModifiableJavaEnv();
/** Signal callback handler for <code>signal</code> native call. */
- static interface SignalHandler extends Callback {
+ interface SignalHandler extends Callback {
void callback(int signum);
}
http://git-wip-us.apache.org/repos/asf/geode/blob/ebb691dd/geode-core/src/main/java/org/apache/geode/internal/size/ObjectGraphSizer.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/size/ObjectGraphSizer.java b/geode-core/src/main/java/org/apache/geode/internal/size/ObjectGraphSizer.java
index 9b64148..ac308ed 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/size/ObjectGraphSizer.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/size/ObjectGraphSizer.java
@@ -233,7 +233,7 @@ public class ObjectGraphSizer {
- public static interface ObjectFilter {
+ public interface ObjectFilter {
boolean accept(Object parent, Object object);
}
http://git-wip-us.apache.org/repos/asf/geode/blob/ebb691dd/geode-core/src/main/java/org/apache/geode/internal/statistics/LocalStatListener.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/statistics/LocalStatListener.java b/geode-core/src/main/java/org/apache/geode/internal/statistics/LocalStatListener.java
index fe249af..0bba3cc 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/statistics/LocalStatListener.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/statistics/LocalStatListener.java
@@ -31,5 +31,5 @@ public interface LocalStatListener {
*
* @param value The new value of the statistic
*/
- public void statValueChanged(double value);
+ void statValueChanged(double value);
}
http://git-wip-us.apache.org/repos/asf/geode/blob/ebb691dd/geode-core/src/main/java/org/apache/geode/internal/statistics/SampleHandler.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/statistics/SampleHandler.java b/geode-core/src/main/java/org/apache/geode/internal/statistics/SampleHandler.java
index b2572dd..08108aa 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/statistics/SampleHandler.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/statistics/SampleHandler.java
@@ -37,26 +37,26 @@ public interface SampleHandler {
* @param nanosTimeStamp an arbitrary nanoseconds time stamp for this sample
* @param resourceInstances the statistics resource instances captured in this sample
*/
- public void sampled(long nanosTimeStamp, List<ResourceInstance> resourceInstances);
+ void sampled(long nanosTimeStamp, List<ResourceInstance> resourceInstances);
/**
* Notification that a new statistics {@link ResourceType} has been created.
*
* @param resourceType the new statistics ResourceType that was created
*/
- public void allocatedResourceType(ResourceType resourceType);
+ void allocatedResourceType(ResourceType resourceType);
/**
* Notification that a new statistics {@link ResourceInstance} has been created.
*
* @param resourceInstance the new statistics ResourceInstance that was created
*/
- public void allocatedResourceInstance(ResourceInstance resourceInstance);
+ void allocatedResourceInstance(ResourceInstance resourceInstance);
/**
* Notification that an existing statistics {@link ResourceInstance} has been destroyed.
*
* @param resourceInstance the existing statistics ResourceInstance that was destroyed
*/
- public void destroyedResourceInstance(ResourceInstance resourceInstance);
+ void destroyedResourceInstance(ResourceInstance resourceInstance);
}
http://git-wip-us.apache.org/repos/asf/geode/blob/ebb691dd/geode-core/src/main/java/org/apache/geode/internal/statistics/StatArchiveFormat.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/statistics/StatArchiveFormat.java b/geode-core/src/main/java/org/apache/geode/internal/statistics/StatArchiveFormat.java
index 169ebd1..b39bc02 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/statistics/StatArchiveFormat.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/statistics/StatArchiveFormat.java
@@ -27,160 +27,160 @@ public interface StatArchiveFormat {
* <li>Changed from 3 to 4 with addition of largerBetter boolean in statistic descriptor
* </ol>
*/
- public static final byte ARCHIVE_VERSION = 4;
+ byte ARCHIVE_VERSION = 4;
/**
* Token consists of a timestamp and any statistic value changes.
*/
- public static final byte SAMPLE_TOKEN = 0;
+ byte SAMPLE_TOKEN = 0;
/**
* Token defines a new resource type.
*/
- public static final byte RESOURCE_TYPE_TOKEN = 1;
+ byte RESOURCE_TYPE_TOKEN = 1;
/**
* Token defines a new resource instance.
*/
- public static final byte RESOURCE_INSTANCE_CREATE_TOKEN = 2;
+ byte RESOURCE_INSTANCE_CREATE_TOKEN = 2;
/**
* Token notes that a previous resource instance no longer exists and thus will have any more
* samples of its statistic values taken.
*/
- public static final byte RESOURCE_INSTANCE_DELETE_TOKEN = 3;
+ byte RESOURCE_INSTANCE_DELETE_TOKEN = 3;
/**
* Token defines a new resource instance with initial data.
*/
- public static final byte RESOURCE_INSTANCE_INITIALIZE_TOKEN = 4;
+ byte RESOURCE_INSTANCE_INITIALIZE_TOKEN = 4;
/**
* Token defines a new archive and provides some global information about the environment the
* archive was created in.
*/
- public static final byte HEADER_TOKEN = 77;
+ byte HEADER_TOKEN = 77;
/**
* The value used to signal the end of a list of resource instances.
*/
- public static final int ILLEGAL_RESOURCE_INST_ID = -1;
+ int ILLEGAL_RESOURCE_INST_ID = -1;
/**
* The maximum value a resource inst id can have and still be stored in the archive as an unsigned
* byte.
*/
- public static final int MAX_BYTE_RESOURCE_INST_ID = 252;
+ int MAX_BYTE_RESOURCE_INST_ID = 252;
/**
* Used to say that the next two bytes contain the resource inst id as an unsigned short.
*/
- public static final int SHORT_RESOURCE_INST_ID_TOKEN = 253;
+ int SHORT_RESOURCE_INST_ID_TOKEN = 253;
/**
* Used to say that the next four bytes contain the resource inst id as an int.
*/
- public static final int INT_RESOURCE_INST_ID_TOKEN = 254;
+ int INT_RESOURCE_INST_ID_TOKEN = 254;
/**
* Used to say that the current byte represents the ILLEGAL_RESOURCE_INST_ID.
*/
- public static final int ILLEGAL_RESOURCE_INST_ID_TOKEN = 255;
+ int ILLEGAL_RESOURCE_INST_ID_TOKEN = 255;
/**
* The maximum value a resource inst id can have and still be stored in the archive as an unsigned
* short.
*/
- public static final int MAX_SHORT_RESOURCE_INST_ID = 65535;
+ int MAX_SHORT_RESOURCE_INST_ID = 65535;
/**
* The value used to signal the end of a list of statistic samples.
*/
- public static final int ILLEGAL_STAT_OFFSET = 255;
+ int ILLEGAL_STAT_OFFSET = 255;
/**
* The maximum value a timestamp can have and still be stored in the archive as an unsigned short.
*/
- public static final int MAX_SHORT_TIMESTAMP = 65534;
+ int MAX_SHORT_TIMESTAMP = 65534;
/**
* Means the next 4 bytes contain the timestamp as an int.
*/
- public static final int INT_TIMESTAMP_TOKEN = 65535;
+ int INT_TIMESTAMP_TOKEN = 65535;
/**
* The maximum value a compact value can have and still be stored in the archive as one byte.
*/
- public static final int MAX_1BYTE_COMPACT_VALUE = Byte.MAX_VALUE;
+ int MAX_1BYTE_COMPACT_VALUE = Byte.MAX_VALUE;
/**
* The minimum value a compact value can have and still be stored in the archive as one byte.
*/
- public static final int MIN_1BYTE_COMPACT_VALUE = Byte.MIN_VALUE + 7;
+ int MIN_1BYTE_COMPACT_VALUE = Byte.MIN_VALUE + 7;
/**
* The maximum value a compact value can have and still be stored in the archive as two bytes.
*/
- public static final int MAX_2BYTE_COMPACT_VALUE = Short.MAX_VALUE;
+ int MAX_2BYTE_COMPACT_VALUE = Short.MAX_VALUE;
/**
* The minimum value a compact value can have and still be stored in the archive as two bytes.
*/
- public static final int MIN_2BYTE_COMPACT_VALUE = Short.MIN_VALUE;
+ int MIN_2BYTE_COMPACT_VALUE = Short.MIN_VALUE;
/**
* Means the next 2 bytes hold the compact value's data.
*/
- public static final int COMPACT_VALUE_2_TOKEN = Byte.MIN_VALUE;
+ int COMPACT_VALUE_2_TOKEN = Byte.MIN_VALUE;
/**
* Means the next 3 bytes hold the compact value's data.
*/
- public static final int COMPACT_VALUE_3_TOKEN = Byte.MIN_VALUE + 1;
+ int COMPACT_VALUE_3_TOKEN = Byte.MIN_VALUE + 1;
/**
* Means the next 4 bytes hold the compact value's data.
*/
- public static final int COMPACT_VALUE_4_TOKEN = Byte.MIN_VALUE + 2;
+ int COMPACT_VALUE_4_TOKEN = Byte.MIN_VALUE + 2;
/**
* Means the next 5 bytes hold the compact value's data.
*/
- public static final int COMPACT_VALUE_5_TOKEN = Byte.MIN_VALUE + 3;
+ int COMPACT_VALUE_5_TOKEN = Byte.MIN_VALUE + 3;
/**
* Means the next 6 bytes hold the compact value's data.
*/
- public static final int COMPACT_VALUE_6_TOKEN = Byte.MIN_VALUE + 4;
+ int COMPACT_VALUE_6_TOKEN = Byte.MIN_VALUE + 4;
/**
* Means the next 7 bytes hold the compact value's data.
*/
- public static final int COMPACT_VALUE_7_TOKEN = Byte.MIN_VALUE + 5;
+ int COMPACT_VALUE_7_TOKEN = Byte.MIN_VALUE + 5;
/**
* Means the next 8 bytes hold the compact value's data.
*/
- public static final int COMPACT_VALUE_8_TOKEN = Byte.MIN_VALUE + 6;
+ int COMPACT_VALUE_8_TOKEN = Byte.MIN_VALUE + 6;
/**
* Statistic represents a <code>boolean</code> java primitive.
*/
- public static final int BOOLEAN_CODE = 1;
+ int BOOLEAN_CODE = 1;
/**
* Statistic represents a <code>char</code> java primitive.
*/
- public static final int CHAR_CODE = 2;
+ int CHAR_CODE = 2;
/**
* Statistic represents a <code>char</code> java primitive.
*/
- public static final int WCHAR_CODE = 12;
+ int WCHAR_CODE = 12;
/**
* Statistic represents a <code>byte</code> java primitive.
*/
- public static final int BYTE_CODE = 3;
+ int BYTE_CODE = 3;
/**
* Statistic represents a <code>short</code> java primitive.
*/
- public static final int SHORT_CODE = 4;
+ int SHORT_CODE = 4;
/**
* Statistic represents a <code>int</code> java primitive.
*/
- public static final int INT_CODE = 5;
+ int INT_CODE = 5;
/**
* Statistic represents a <code>long</code> java primitive.
*/
- public static final int LONG_CODE = 6;
+ int LONG_CODE = 6;
/**
* Statistic represents a <code>float</code> java primitive.
*/
- public static final int FLOAT_CODE = 7;
+ int FLOAT_CODE = 7;
/**
* Statistic represents a <code>double</code> java primitive.
*/
- public static final int DOUBLE_CODE = 8;
+ int DOUBLE_CODE = 8;
/**
* Number of nanoseconds in one millisecond
*/
- public static final long NANOS_PER_MILLI = 1000000;
+ long NANOS_PER_MILLI = 1000000;
}
http://git-wip-us.apache.org/repos/asf/geode/blob/ebb691dd/geode-core/src/main/java/org/apache/geode/internal/statistics/StatArchiveHandlerConfig.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/statistics/StatArchiveHandlerConfig.java b/geode-core/src/main/java/org/apache/geode/internal/statistics/StatArchiveHandlerConfig.java
index ef58b54..c36bcdc 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/statistics/StatArchiveHandlerConfig.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/statistics/StatArchiveHandlerConfig.java
@@ -30,35 +30,35 @@ public interface StatArchiveHandlerConfig {
/**
* Gets the name of the archive file.
*/
- public File getArchiveFileName();
+ File getArchiveFileName();
/**
* Gets the archive size limit in bytes.
*/
- public long getArchiveFileSizeLimit();
+ long getArchiveFileSizeLimit();
/**
* Gets the archive disk space limit in bytes.
*/
- public long getArchiveDiskSpaceLimit();
+ long getArchiveDiskSpaceLimit();
/**
* Returns a unique id for the sampler's system.
*/
- public long getSystemId();
+ long getSystemId();
/**
* Returns the time this sampler's system was started.
*/
- public long getSystemStartTime();
+ long getSystemStartTime();
/**
* Returns the path to this sampler's system directory; if it has one.
*/
- public String getSystemDirectoryPath();
+ String getSystemDirectoryPath();
/**
* Returns a description of the product that the stats are on
*/
- public String getProductDescription();
+ String getProductDescription();
}
http://git-wip-us.apache.org/repos/asf/geode/blob/ebb691dd/geode-core/src/main/java/org/apache/geode/internal/statistics/StatArchiveReader.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/statistics/StatArchiveReader.java b/geode-core/src/main/java/org/apache/geode/internal/statistics/StatArchiveReader.java
index 36888e8..53333fe 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/statistics/StatArchiveReader.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/statistics/StatArchiveReader.java
@@ -397,7 +397,7 @@ public class StatArchiveReader implements StatArchiveFormat {
}
}
- public static interface StatValue {
+ public interface StatValue {
/**
* {@link StatArchiveReader.StatValue} filter that causes the statistic values to be unfiltered.
* This causes the raw values written to the archive to be used.
@@ -405,7 +405,7 @@ public class StatArchiveReader implements StatArchiveFormat {
* This is the default filter for non-counter statistics. To determine if a statistic is not a
* counter use {@link StatArchiveReader.StatDescriptor#isCounter}.
*/
- public static final int FILTER_NONE = 0;
+ int FILTER_NONE = 0;
/**
* {@link StatArchiveReader.StatValue} filter that causes the statistic values to be filtered to
* reflect how often they change per second. Since the difference between two samples is used to
@@ -417,7 +417,7 @@ public class StatArchiveReader implements StatArchiveFormat {
* This is the default filter for counter statistics. To determine if a statistic is a counter
* use {@link StatArchiveReader.StatDescriptor#isCounter}.
*/
- public static final int FILTER_PERSEC = 1;
+ int FILTER_PERSEC = 1;
/**
* {@link StatArchiveReader.StatValue} filter that causes the statistic values to be filtered to
* reflect how much they changed between sample periods. Since the difference between two
@@ -426,90 +426,90 @@ public class StatArchiveReader implements StatArchiveFormat {
* per second value is the instance's first time stamp
* {@link StatArchiveReader.ResourceInst#getFirstTimeMillis}.
*/
- public static final int FILTER_PERSAMPLE = 2;
+ int FILTER_PERSAMPLE = 2;
/**
* Creates and returns a trimmed version of this stat value. Any samples taken before
* <code>startTime</code> and after <code>endTime</code> are discarded from the resulting value.
* Set a time parameter to <code>-1</code> to not trim that side.
*/
- public StatValue createTrimmed(long startTime, long endTime);
+ StatValue createTrimmed(long startTime, long endTime);
/**
* Returns true if value has data that has been trimmed off it by a start timestamp.
*/
- public boolean isTrimmedLeft();
+ boolean isTrimmedLeft();
/**
* Gets the {@link StatArchiveReader.ResourceType type} of the resources that this value belongs
* to.
*/
- public ResourceType getType();
+ ResourceType getType();
/**
* Gets the {@link StatArchiveReader.ResourceInst resources} that this value belongs to.
*/
- public ResourceInst[] getResources();
+ ResourceInst[] getResources();
/**
* Returns an array of timestamps for each unfiltered snapshot in this value. Each returned time
* stamp is the number of millis since midnight, Jan 1, 1970 UTC.
*/
- public long[] getRawAbsoluteTimeStamps();
+ long[] getRawAbsoluteTimeStamps();
/**
* Returns an array of timestamps for each unfiltered snapshot in this value. Each returned time
* stamp is the number of millis since midnight, Jan 1, 1970 UTC. The resolution is seconds.
*/
- public long[] getRawAbsoluteTimeStampsWithSecondRes();
+ long[] getRawAbsoluteTimeStampsWithSecondRes();
/**
* Returns an array of doubles containing the unfiltered value of this statistic for each point
* in time that it was sampled.
*/
- public double[] getRawSnapshots();
+ double[] getRawSnapshots();
/**
* Returns an array of doubles containing the filtered value of this statistic for each point in
* time that it was sampled.
*/
- public double[] getSnapshots();
+ double[] getSnapshots();
/**
* Returns the number of samples taken of this statistic's value.
*/
- public int getSnapshotsSize();
+ int getSnapshotsSize();
/**
* Returns the smallest of all the samples taken of this statistic's value.
*/
- public double getSnapshotsMinimum();
+ double getSnapshotsMinimum();
/**
* Returns the largest of all the samples taken of this statistic's value.
*/
- public double getSnapshotsMaximum();
+ double getSnapshotsMaximum();
/**
* Returns the average of all the samples taken of this statistic's value.
*/
- public double getSnapshotsAverage();
+ double getSnapshotsAverage();
/**
* Returns the standard deviation of all the samples taken of this statistic's value.
*/
- public double getSnapshotsStandardDeviation();
+ double getSnapshotsStandardDeviation();
/**
* Returns the most recent value of all the samples taken of this statistic's value.
*/
- public double getSnapshotsMostRecent();
+ double getSnapshotsMostRecent();
/**
* Returns true if sample whose value was different from previous values has been added to this
* StatValue since the last time this method was called.
*/
- public boolean hasValueChanged();
+ boolean hasValueChanged();
/**
* Returns the current filter used to calculate this statistic's values. It will be one of these
@@ -520,7 +520,7 @@ public class StatArchiveReader implements StatArchiveFormat {
* <li>{@link #FILTER_PERSEC}
* </ul>
*/
- public int getFilter();
+ int getFilter();
/**
* Sets the current filter used to calculate this statistic's values. The default filter is
@@ -535,12 +535,12 @@ public class StatArchiveReader implements StatArchiveFormat {
* </ul>
* @throws IllegalArgumentException if <code>filter</code> is not a valid filter constant.
*/
- public void setFilter(int filter);
+ void setFilter(int filter);
/**
* Returns a description of this statistic.
*/
- public StatDescriptor getDescriptor();
+ StatDescriptor getDescriptor();
}
protected static abstract class AbstractValue implements StatValue {
@@ -2751,26 +2751,26 @@ public class StatArchiveReader implements StatArchiveFormat {
}
}
- public static interface StatSpec extends ValueFilter {
+ public interface StatSpec extends ValueFilter {
/**
* Causes all stats that matches this spec, in all archive files, to be combined into a single
* global stat value.
*/
- public static final int GLOBAL = 2;
+ int GLOBAL = 2;
/**
* Causes all stats that matches this spec, in each archive file, to be combined into a single
* stat value for each file.
*/
- public static final int FILE = 1;
+ int FILE = 1;
/**
* No combination is done.
*/
- public final int NONE = 0;
+ int NONE = 0;
/**
* Returns one of the following values: {@link #GLOBAL}, {@link #FILE}, {@link #NONE}.
*/
- public int getCombineType();
+ int getCombineType();
}
/**
@@ -2778,30 +2778,30 @@ public class StatArchiveReader implements StatArchiveFormat {
* when loading a statistic archive file to reduce the memory footprint. Only statistic data that
* matches all four will be selected for loading.
*/
- public static interface ValueFilter {
+ public interface ValueFilter {
/**
* Returns true if the specified archive file matches this spec. Any archives whose name does
* not match this spec will not be selected for loading by this spec.
*/
- public boolean archiveMatches(File archive);
+ boolean archiveMatches(File archive);
/**
* Returns true if the specified type name matches this spec. Any types whose name does not
* match this spec will not be selected for loading by this spec.
*/
- public boolean typeMatches(String typeName);
+ boolean typeMatches(String typeName);
/**
* Returns true if the specified statistic name matches this spec. Any stats whose name does not
* match this spec will not be selected for loading by this spec.
*/
- public boolean statMatches(String statName);
+ boolean statMatches(String statName);
/**
* Returns true if the specified instance matches this spec. Any instance whose text id and
* numeric id do not match this spec will not be selected for loading by this spec.
*/
- public boolean instanceMatches(String textId, long numericId);
+ boolean instanceMatches(String textId, long numericId);
}
public static class StatArchiveFile {
http://git-wip-us.apache.org/repos/asf/geode/blob/ebb691dd/geode-core/src/main/java/org/apache/geode/internal/statistics/StatisticId.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/statistics/StatisticId.java b/geode-core/src/main/java/org/apache/geode/internal/statistics/StatisticId.java
index 596ba8c..ea32e45 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/statistics/StatisticId.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/statistics/StatisticId.java
@@ -29,8 +29,8 @@ import org.apache.geode.Statistics;
public interface StatisticId {
/** Returns the descriptor that this stat is an instance of */
- public StatisticDescriptor getStatisticDescriptor();
+ StatisticDescriptor getStatisticDescriptor();
/** Returns the statistics instance which owns this stat instance */
- public Statistics getStatistics();
+ Statistics getStatistics();
}
http://git-wip-us.apache.org/repos/asf/geode/blob/ebb691dd/geode-core/src/main/java/org/apache/geode/internal/statistics/StatisticsListener.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/statistics/StatisticsListener.java b/geode-core/src/main/java/org/apache/geode/internal/statistics/StatisticsListener.java
index 4964297..9af0d2e 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/statistics/StatisticsListener.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/statistics/StatisticsListener.java
@@ -19,6 +19,6 @@ package org.apache.geode.internal.statistics;
*/
public interface StatisticsListener {
- public void handleNotification(StatisticsNotification notification);
+ void handleNotification(StatisticsNotification notification);
}
http://git-wip-us.apache.org/repos/asf/geode/blob/ebb691dd/geode-core/src/main/java/org/apache/geode/internal/statistics/StatisticsManager.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/statistics/StatisticsManager.java b/geode-core/src/main/java/org/apache/geode/internal/statistics/StatisticsManager.java
index 1cbc474..b1a4247 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/statistics/StatisticsManager.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/statistics/StatisticsManager.java
@@ -30,51 +30,51 @@ public interface StatisticsManager extends StatisticsFactory {
/**
* Called when the Statistics instance <code>s</code> is closed.
*/
- public void destroyStatistics(Statistics s);
+ void destroyStatistics(Statistics s);
/**
* Returns a name that can be used to identify the manager
*/
- public String getName();
+ String getName();
/**
* Returns a numeric id that can be used to identify the manager
*/
- public long getId();
+ long getId();
/**
* Returns the start time of this manager.
*/
- public long getStartTime();
+ long getStartTime();
/**
* Returns a value that changes any time a Statistics instance is added or removed from this
* manager.
*/
- public int getStatListModCount();
+ int getStatListModCount();
/**
* Returns a list of all the Statistics this manager is currently managing.
*/
- public List<Statistics> getStatsList();
+ List<Statistics> getStatsList();
/**
* Returns the current number of statistics instances.
*/
- public int getStatisticsCount();
+ int getStatisticsCount();
/**
* Returns the statistics resource instance given its id.
*/
- public Statistics findStatistics(long id);
+ Statistics findStatistics(long id);
/**
* Returns true if the specified statistic resource still exists.
*/
- public boolean statisticsExists(long id);
+ boolean statisticsExists(long id);
/**
* Returns an array of all the current statistic resource instances.
*/
- public Statistics[] getStatistics();
+ Statistics[] getStatistics();
}
http://git-wip-us.apache.org/repos/asf/geode/blob/ebb691dd/geode-core/src/main/java/org/apache/geode/internal/statistics/StatisticsNotification.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/statistics/StatisticsNotification.java b/geode-core/src/main/java/org/apache/geode/internal/statistics/StatisticsNotification.java
index 2e0feb2..9a5fa26 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/statistics/StatisticsNotification.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/statistics/StatisticsNotification.java
@@ -25,7 +25,7 @@ import org.apache.geode.StatisticsType;
*/
public interface StatisticsNotification extends Iterable<StatisticId> {
- public static enum Type {
+ enum Type {
/** CounterMonitor threshold was exceeded */
THRESHOLD_VALUE_EXCEEDED,
/** GaugeMonitor low-threshold was exceeded */
@@ -41,32 +41,32 @@ public interface StatisticsNotification extends Iterable<StatisticId> {
}
/** Returns the timestamp of the stat sample */
- public long getTimeStamp();
+ long getTimeStamp();
/** Returns the notification type */
- public Type getType();
+ Type getType();
/** Returns an iterator of all the stat instances that met the monitor's criteria */
- public Iterator<StatisticId> iterator();
+ Iterator<StatisticId> iterator();
/**
* Returns an iterator of all the stat instances for the specified descriptor that met the
* monitor's criteria
*/
- public Iterator<StatisticId> iterator(StatisticDescriptor statDesc);
+ Iterator<StatisticId> iterator(StatisticDescriptor statDesc);
/**
* Returns an iterator of all the stat instances for the specified statistics instance that met
* the monitor's criteria
*/
- public Iterator<StatisticId> iterator(Statistics statistics);
+ Iterator<StatisticId> iterator(Statistics statistics);
/**
* Returns an iterator of all the stat instances for the specified statistics type that met the
* monitor's criteria
*/
- public Iterator<StatisticId> iterator(StatisticsType statisticsType);
+ Iterator<StatisticId> iterator(StatisticsType statisticsType);
/** Returns the value for the specified stat instance */
- public Number getValue(StatisticId statId) throws StatisticNotFoundException;
+ Number getValue(StatisticId statId) throws StatisticNotFoundException;
}
http://git-wip-us.apache.org/repos/asf/geode/blob/ebb691dd/geode-core/src/main/java/org/apache/geode/internal/statistics/StatisticsSampler.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/statistics/StatisticsSampler.java b/geode-core/src/main/java/org/apache/geode/internal/statistics/StatisticsSampler.java
index 6aefbec..01fd9a0 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/statistics/StatisticsSampler.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/statistics/StatisticsSampler.java
@@ -27,12 +27,12 @@ public interface StatisticsSampler {
/**
* Returns the number of times a statistics resource has been add or deleted.
*/
- public int getStatisticsModCount();
+ int getStatisticsModCount();
/**
* Returns an array of all the current statistics resource instances.
*/
- public Statistics[] getStatistics();
+ Statistics[] getStatistics();
/**
* Waits for the SampleCollector to be created and initialized.
@@ -41,7 +41,7 @@ public interface StatisticsSampler {
* @return the initialized SampleCollector or null if timed out
* @throws InterruptedException if the current thread is interrupted while waiting
*/
- public SampleCollector waitForSampleCollector(long timeout) throws InterruptedException;
+ SampleCollector waitForSampleCollector(long timeout) throws InterruptedException;
/**
* Waits for at least one statistics sample to occur before returning.
@@ -50,5 +50,5 @@ public interface StatisticsSampler {
* @return true if a statistics sample occurred; false if wait timed out
* @throws InterruptedException if the current thread is interrupted while waiting
*/
- public boolean waitForSample(long timeout) throws InterruptedException;
+ boolean waitForSample(long timeout) throws InterruptedException;
}
http://git-wip-us.apache.org/repos/asf/geode/blob/ebb691dd/geode-core/src/main/java/org/apache/geode/internal/statistics/VMStatsContract.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/statistics/VMStatsContract.java b/geode-core/src/main/java/org/apache/geode/internal/statistics/VMStatsContract.java
index 38c019e..0e95aca 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/statistics/VMStatsContract.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/statistics/VMStatsContract.java
@@ -26,10 +26,10 @@ public interface VMStatsContract {
/**
* Called by sampler when it wants the VMStats statistics values to be refetched from the system.
*/
- public void refresh();
+ void refresh();
/**
* Called by sampler when it wants the VMStats to go away.
*/
- public void close();
+ void close();
}
http://git-wip-us.apache.org/repos/asf/geode/blob/ebb691dd/geode-core/src/main/java/org/apache/geode/internal/statistics/platform/OsStatisticsFactory.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/statistics/platform/OsStatisticsFactory.java b/geode-core/src/main/java/org/apache/geode/internal/statistics/platform/OsStatisticsFactory.java
index 00a6188..1a84f5e 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/statistics/platform/OsStatisticsFactory.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/statistics/platform/OsStatisticsFactory.java
@@ -35,6 +35,6 @@ public interface OsStatisticsFactory {
* <p>
* The created instance may not be {@link Statistics#isAtomic atomic}.
*/
- public Statistics createOsStatistics(StatisticsType type, String textId, long numericId,
+ Statistics createOsStatistics(StatisticsType type, String textId, long numericId,
int osStatFlags);
}
http://git-wip-us.apache.org/repos/asf/geode/blob/ebb691dd/geode-core/src/main/java/org/apache/geode/internal/tcp/BaseMsgStreamer.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/tcp/BaseMsgStreamer.java b/geode-core/src/main/java/org/apache/geode/internal/tcp/BaseMsgStreamer.java
index 1345825..38c2580 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/tcp/BaseMsgStreamer.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/tcp/BaseMsgStreamer.java
@@ -28,31 +28,31 @@ import org.apache.geode.i18n.LogWriterI18n;
*/
public interface BaseMsgStreamer {
- public void reserveConnections(long startTime, long ackTimeout, long ackSDTimeout);
+ void reserveConnections(long startTime, long ackTimeout, long ackSDTimeout);
/**
* Returns a list of the Connections that the message was sent to. Call this after
* {@link #writeMessage}.
*/
- public List<?> getSentConnections();
+ List<?> getSentConnections();
/**
* Returns an exception the describes which cons the message was not sent to. Call this after
* {@link #writeMessage}.
*/
- public ConnectExceptions getConnectExceptions();
+ ConnectExceptions getConnectExceptions();
/**
* Writes the message to the connected streams and returns the number of bytes written.
*
* @throws IOException if serialization failure
*/
- public int writeMessage() throws IOException;
+ int writeMessage() throws IOException;
/**
* Close this streamer.
*
* @throws IOException on exception
*/
- public void close() throws IOException;
+ void close() throws IOException;
}
http://git-wip-us.apache.org/repos/asf/geode/blob/ebb691dd/geode-core/src/main/java/org/apache/geode/internal/tcp/ByteBufferInputStream.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/tcp/ByteBufferInputStream.java b/geode-core/src/main/java/org/apache/geode/internal/tcp/ByteBufferInputStream.java
index 216a9d9..c003850 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/tcp/ByteBufferInputStream.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/tcp/ByteBufferInputStream.java
@@ -53,7 +53,7 @@ public class ByteBufferInputStream extends InputStream
*
*
*/
- public static interface ByteSource {
+ public interface ByteSource {
int position();
int limit();
http://git-wip-us.apache.org/repos/asf/geode/blob/ebb691dd/geode-core/src/main/java/org/apache/geode/internal/tcp/ServerDelegate.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/tcp/ServerDelegate.java b/geode-core/src/main/java/org/apache/geode/internal/tcp/ServerDelegate.java
index 37e9336..75c018f 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/tcp/ServerDelegate.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/tcp/ServerDelegate.java
@@ -34,12 +34,12 @@ import org.apache.geode.i18n.LogWriterI18n;
*/
public interface ServerDelegate {
- public void receive(DistributionMessage message, int bytesRead, DistributedMember connId);
+ void receive(DistributionMessage message, int bytesRead, DistributedMember connId);
- public LogWriterI18n getLogger();
+ LogWriterI18n getLogger();
/**
* Called when a possibly new member is detected by receiving a direct channel message from him.
*/
- public void newMemberConnected(InternalDistributedMember member);
+ void newMemberConnected(InternalDistributedMember member);
}
http://git-wip-us.apache.org/repos/asf/geode/blob/ebb691dd/geode-core/src/main/java/org/apache/geode/internal/util/ObjectIntProcedure.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/util/ObjectIntProcedure.java b/geode-core/src/main/java/org/apache/geode/internal/util/ObjectIntProcedure.java
index e40e363..32907bf 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/util/ObjectIntProcedure.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/util/ObjectIntProcedure.java
@@ -21,6 +21,6 @@ package org.apache.geode.internal.util;
*/
public interface ObjectIntProcedure {
- public boolean executeWith(Object a, int b);
+ boolean executeWith(Object a, int b);
}
http://git-wip-us.apache.org/repos/asf/geode/blob/ebb691dd/geode-core/src/main/java/org/apache/geode/internal/util/Transformer.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/util/Transformer.java b/geode-core/src/main/java/org/apache/geode/internal/util/Transformer.java
index 73455da..05d0270 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/util/Transformer.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/util/Transformer.java
@@ -27,5 +27,5 @@ public interface Transformer<T1, T2> {
* @param t the data to be transferred from.
* @return the transformed data.
*/
- public T2 transform(T1 t);
+ T2 transform(T1 t);
}
http://git-wip-us.apache.org/repos/asf/geode/blob/ebb691dd/geode-core/src/main/java/org/apache/geode/internal/util/Versionable.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/util/Versionable.java b/geode-core/src/main/java/org/apache/geode/internal/util/Versionable.java
index 62ec5ec..0e3962f 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/util/Versionable.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/util/Versionable.java
@@ -22,11 +22,11 @@ package org.apache.geode.internal.util;
*/
public interface Versionable {
- public abstract Comparable getVersion();
+ Comparable getVersion();
- public abstract boolean isNewerThan(Versionable other);
+ boolean isNewerThan(Versionable other);
- public abstract boolean isSame(Versionable other);
+ boolean isSame(Versionable other);
- public abstract boolean isOlderThan(Versionable other);
+ boolean isOlderThan(Versionable other);
}
http://git-wip-us.apache.org/repos/asf/geode/blob/ebb691dd/geode-core/src/main/java/org/apache/geode/internal/util/concurrent/CustomEntryConcurrentHashMap.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/util/concurrent/CustomEntryConcurrentHashMap.java b/geode-core/src/main/java/org/apache/geode/internal/util/concurrent/CustomEntryConcurrentHashMap.java
index a5f6a8d..6a58f31 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/util/concurrent/CustomEntryConcurrentHashMap.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/util/concurrent/CustomEntryConcurrentHashMap.java
@@ -258,7 +258,7 @@ public class CustomEntryConcurrentHashMap<K, V> extends AbstractMap<K, V>
* {@link org.apache.geode.internal.util.concurrent.CustomEntryConcurrentHashMap.HashEntry}
* objects for each entry in the map.
*/
- public static interface HashEntry<K, V> {
+ public interface HashEntry<K, V> {
/**
* Get the key object for this entry.
@@ -379,19 +379,19 @@ public class CustomEntryConcurrentHashMap<K, V> extends AbstractMap<K, V>
* {@link org.apache.geode.internal.util.concurrent.CustomEntryConcurrentHashMap.HashEntry}
* objects by caller. This can be used, for example, to return GemFire RegionEntries directly.
*/
- public static interface HashEntryCreator<K, V> {
+ public interface HashEntryCreator<K, V> {
/**
* Create a new
* {@link org.apache.geode.internal.util.concurrent.CustomEntryConcurrentHashMap.HashEntry}
* given the key, hash, value and next element.
*/
- public HashEntry<K, V> newEntry(K key, int hash, HashEntry<K, V> next, V value);
+ HashEntry<K, V> newEntry(K key, int hash, HashEntry<K, V> next, V value);
/**
* Get the hashCode for given key object.
*/
- public int keyHashCode(Object key, boolean compareValues);
+ int keyHashCode(Object key, boolean compareValues);
}
// End GemStone addition
@@ -1561,7 +1561,7 @@ public class CustomEntryConcurrentHashMap<K, V> extends AbstractMap<K, V>
* @param <C> the type of context parameter passed to the creation/removal methods
* @param <P> the type of extra parameter passed to the creation/removal methods
*/
- public static interface MapCallback<K, V, C, P> {
+ public interface MapCallback<K, V, C, P> {
/**
* Create a new instance of the value object given the key and provided parameters for
@@ -1571,7 +1571,7 @@ public class CustomEntryConcurrentHashMap<K, V> extends AbstractMap<K, V>
* @param context any context in which this method has been invoked
* @param createParams parameters, if any, required for construction of a new value object
*/
- public V newValue(K key, C context, P createParams);
+ V newValue(K key, C context, P createParams);
/**
* Invoked when an existing value in map is read by the
@@ -1580,7 +1580,7 @@ public class CustomEntryConcurrentHashMap<K, V> extends AbstractMap<K, V>
*
* @param value the value read by create that will be returned
*/
- public void oldValueRead(V value);
+ void oldValueRead(V value);
/**
* Check if the existing value should be removed by the
@@ -1590,7 +1590,7 @@ public class CustomEntryConcurrentHashMap<K, V> extends AbstractMap<K, V>
* @param context any context in which this method has been invoked
* @param removeParams parameters, if any, to be passed for cleanup of the object
*/
- public boolean doRemoveValue(V value, C context, P removeParams);
+ boolean doRemoveValue(V value, C context, P removeParams);
}
/**
http://git-wip-us.apache.org/repos/asf/geode/blob/ebb691dd/geode-core/src/main/java/org/apache/geode/lang/Identifiable.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/lang/Identifiable.java b/geode-core/src/main/java/org/apache/geode/lang/Identifiable.java
index cedf8b8..dfa6552 100644
--- a/geode-core/src/main/java/org/apache/geode/lang/Identifiable.java
+++ b/geode-core/src/main/java/org/apache/geode/lang/Identifiable.java
@@ -34,6 +34,6 @@ public interface Identifiable<T extends Comparable<T>> extends Serializable {
*
* @return an identifier uniquely identifying this Object.
*/
- public T getId();
+ T getId();
}
http://git-wip-us.apache.org/repos/asf/geode/blob/ebb691dd/geode-core/src/main/java/org/apache/geode/management/AsyncEventQueueMXBean.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/management/AsyncEventQueueMXBean.java b/geode-core/src/main/java/org/apache/geode/management/AsyncEventQueueMXBean.java
index 0147da1..11338ee 100644
--- a/geode-core/src/main/java/org/apache/geode/management/AsyncEventQueueMXBean.java
+++ b/geode-core/src/main/java/org/apache/geode/management/AsyncEventQueueMXBean.java
@@ -31,41 +31,41 @@ public interface AsyncEventQueueMXBean {
/**
* Returns the ID of the AsyncEventQueue.
*/
- public String getId();
+ String getId();
/**
* Returns the name of the disk store that is used for persistence.
*/
- public String getOverflowDiskStoreName();
+ String getOverflowDiskStoreName();
/**
* Returns the maximum memory after which the data needs to be overflowed to disk.
*/
- public int getMaximumQueueMemory();
+ int getMaximumQueueMemory();
/**
* Returns the size of a batch that gets delivered over the AsyncEventQueue.
*/
- public int getBatchSize();
+ int getBatchSize();
/**
* Returns the interval between transmissions by the AsyncEventQueue.
*/
- public long getBatchTimeInterval();
+ long getBatchTimeInterval();
/**
* Returns whether batch conflation for the AsyncEventQueue is enabled
*
* @return True if batch conflation is enabled, false otherwise.
*/
- public boolean isBatchConflationEnabled();
+ boolean isBatchConflationEnabled();
/**
* Returns whether the AsyncEventQueue is configured to be persistent or non-persistent.
*
* @return True if the queue is persistent, false otherwise.
*/
- public boolean isPersistent();
+ boolean isPersistent();
/**
* Returns whether the queue is primary or secondary. Events get delivered only by the primary
@@ -74,44 +74,44 @@ public interface AsyncEventQueueMXBean {
*
* @return True if this is the primary queue, false otherwise.
*/
- public boolean isPrimary();
+ boolean isPrimary();
/**
* Returns the number of dispatcher threads working for this <code>AsyncEventQueue</code>.
*/
- public int getDispatcherThreads();
+ int getDispatcherThreads();
/**
* Returns the order policy followed while dispatching the events to remote distributed system.
* Order policy is only relevant when the number of dispatcher threads is greater than one.
*/
- public String getOrderPolicy();
+ String getOrderPolicy();
/**
* Returns whether the isDiskSynchronous property is set for this AsyncEventQueue.
*
* @return True if the property is set, false otherwise.
*/
- public boolean isDiskSynchronous();
+ boolean isDiskSynchronous();
/**
* Returns whether the isParallel property is set for this AsyncEventQueue.
*
* @return True if the property is set, false otherwise.
*/
- public boolean isParallel();
+ boolean isParallel();
/**
* Returns the class name of the AsyncEventListener that is attached to the queue.
*/
- public String getAsyncEventListener();
+ String getAsyncEventListener();
/**
* Returns the Size of the event queue
*
* @return integer
*/
- public int getEventQueueSize();
+ int getEventQueueSize();
}
http://git-wip-us.apache.org/repos/asf/geode/blob/ebb691dd/geode-core/src/main/java/org/apache/geode/management/CacheServerMXBean.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/management/CacheServerMXBean.java b/geode-core/src/main/java/org/apache/geode/management/CacheServerMXBean.java
index 3adbf01..44dd291 100644
--- a/geode-core/src/main/java/org/apache/geode/management/CacheServerMXBean.java
+++ b/geode-core/src/main/java/org/apache/geode/management/CacheServerMXBean.java
@@ -60,48 +60,48 @@ public interface CacheServerMXBean {
/**
* Returns the port on which this CacheServer listens for clients.
*/
- public int getPort();
+ int getPort();
/**
* Returns a string representing the IP address or host name that this CacheServer will listen on.
*/
- public String getBindAddress();
+ String getBindAddress();
/**
* Returns the configured buffer size of the socket connection for this CacheServer.
*/
- public int getSocketBufferSize();
+ int getSocketBufferSize();
/**
* Returns the maximum amount of time between client pings. This value is used to determine the
* health of client's attached to the server.
*/
- public int getMaximumTimeBetweenPings();
+ int getMaximumTimeBetweenPings();
/**
* Returns the maximum allowed client connections.
*/
- public int getMaxConnections();
+ int getMaxConnections();
/**
* Returns the maxium number of threads allowed in this CacheServer to service client requests.
*/
- public int getMaxThreads();
+ int getMaxThreads();
/**
* Returns the maximum number of messages that can be enqueued in a client-queue.
*/
- public int getMaximumMessageCount();
+ int getMaximumMessageCount();
/**
* Returns the time (in seconds) after which a message in the client queue will expire.
*/
- public int getMessageTimeToLive();
+ int getMessageTimeToLive();
/**
* Returns the frequency (in milliseconds) to poll the load probe on this CacheServer.
*/
- public long getLoadPollInterval();
+ long getLoadPollInterval();
/**
* Returns the name or IP address to pass to the client as the location where the server is
@@ -111,164 +111,164 @@ public interface CacheServerMXBean {
* and won’t be able to find the server. For this situation, you must supply the server’s
* alternate hostname for the locator to pass to the client.
*/
- public String getHostNameForClients();
+ String getHostNameForClients();
/**
* Returns the load probe for this CacheServer.
*/
- public ServerLoadData fetchLoadProbe();
+ ServerLoadData fetchLoadProbe();
/**
* Returns whether or not this CacheServer is running.
*
* @return True of the server is running, false otherwise.
*/
- public boolean isRunning();
+ boolean isRunning();
/**
* Returns the capacity (in megabytes) of the client queue.
*/
- public int getCapacity();
+ int getCapacity();
/**
* Returns the eviction policy that is executed when the capacity of the client queue is reached.
*/
- public String getEvictionPolicy();
+ String getEvictionPolicy();
/**
* Returns the name of the disk store that is used for persistence.
*/
- public String getDiskStoreName();
+ String getDiskStoreName();
/**
* Returns the number of sockets accepted and used for client to server messaging.
*/
- public int getClientConnectionCount();
+ int getClientConnectionCount();
/**
* Returns the number of client virtual machines connected.
*/
- public int getCurrentClients();
+ int getCurrentClients();
/**
* Returns the average get request latency.
*/
- public long getGetRequestAvgLatency();
+ long getGetRequestAvgLatency();
/**
* Returns the average put request latency.
*/
- public long getPutRequestAvgLatency();
+ long getPutRequestAvgLatency();
/**
* Returns the total number of client connections that timed out and were closed.
*/
- public int getTotalConnectionsTimedOut();
+ int getTotalConnectionsTimedOut();
/**
* Returns the total number of client connection requests that failed.
*/
- public int getTotalFailedConnectionAttempts();
+ int getTotalFailedConnectionAttempts();
/**
* Returns the current number of connections waiting for a thread to start processing their
* message.
*/
- public int getThreadQueueSize();
+ int getThreadQueueSize();
/**
* Returns the current number of threads handling a client connection.
*/
- public int getConnectionThreads();
+ int getConnectionThreads();
/**
* Returns the load from client to server connections as reported by the load probe installed in
* this server.
*/
- public double getConnectionLoad();
+ double getConnectionLoad();
/**
* Returns the estimate of how much load is added for each new connection as reported by the load
* probe installed in this server.
*/
- public double getLoadPerConnection();
+ double getLoadPerConnection();
/**
* Returns the load from queues as reported by the load probe installed in this server.
*/
- public double getQueueLoad();
+ double getQueueLoad();
/**
* Returns the estimate of how much load is added for each new queue as reported by the load probe
* installed in this server.
*/
- public double getLoadPerQueue();
+ double getLoadPerQueue();
/**
* Returns the rate of get requests.
*/
- public float getGetRequestRate();
+ float getGetRequestRate();
/**
* Returns the rate of put requests.
*/
- public float getPutRequestRate();
+ float getPutRequestRate();
/**
* Returns the total number of bytes sent to clients.
*/
- public long getTotalSentBytes();
+ long getTotalSentBytes();
/**
* Returns the total number of bytes received from clients.
*/
- public long getTotalReceivedBytes();
+ long getTotalReceivedBytes();
/**
* Returns the number of cache client notification requests.
*/
- public int getNumClientNotificationRequests();
+ int getNumClientNotificationRequests();
/**
* Returns the average latency for processing client notifications.
*/
- public long getClientNotificationAvgLatency();
+ long getClientNotificationAvgLatency();
/**
* Returns the rate of client notifications.
*/
- public float getClientNotificationRate();
+ float getClientNotificationRate();
/**
* Returns the number of registered CQs.
*/
- public long getRegisteredCQCount();
+ long getRegisteredCQCount();
/**
* Returns the number of active (currently executing) CQs.
*/
- public long getActiveCQCount();
+ long getActiveCQCount();
/**
* Returns the rate of queries.
*/
- public float getQueryRequestRate();
+ float getQueryRequestRate();
/**
* Returns the total number of indexes in use by the member.
*/
- public int getIndexCount();
+ int getIndexCount();
/**
* Returns a list of names for all indexes.
*/
- public String[] getIndexList();
+ String[] getIndexList();
/**
* Returns the total time spent updating indexes due to changes in the data.
*/
- public long getTotalIndexMaintenanceTime();
+ long getTotalIndexMaintenanceTime();
/**
* Remove an index.
@@ -276,12 +276,12 @@ public interface CacheServerMXBean {
* @param indexName Name of the index to be removed.
*/
@ResourceOperation(resource = Resource.DATA, operation = Operation.MANAGE)
- public void removeIndex(String indexName) throws Exception;
+ void removeIndex(String indexName) throws Exception;
/**
* Returns a list of names for all registered CQs.
*/
- public String[] getContinuousQueryList();
+ String[] getContinuousQueryList();
/**
* Execute an ad-hoc CQ on the server
@@ -293,7 +293,7 @@ public interface CacheServerMXBean {
*/
@Deprecated
@ResourceOperation(resource = Resource.DATA, operation = Operation.READ)
- public void executeContinuousQuery(String queryName) throws Exception;
+ void executeContinuousQuery(String queryName) throws Exception;
/**
* Stop (pause) a CQ from executing
@@ -306,7 +306,7 @@ public interface CacheServerMXBean {
*/
@Deprecated
@ResourceOperation(resource = Resource.DATA, operation = Operation.MANAGE)
- public void stopContinuousQuery(String queryName) throws Exception;
+ void stopContinuousQuery(String queryName) throws Exception;
/**
* Unregister all CQs from a region
@@ -318,7 +318,7 @@ public interface CacheServerMXBean {
*/
@Deprecated
@ResourceOperation(resource = Resource.DATA, operation = Operation.MANAGE)
- public void closeAllContinuousQuery(String regionName) throws Exception;
+ void closeAllContinuousQuery(String regionName) throws Exception;
/**
@@ -331,7 +331,7 @@ public interface CacheServerMXBean {
*/
@Deprecated
@ResourceOperation(resource = Resource.DATA, operation = Operation.MANAGE)
- public void closeContinuousQuery(String queryName) throws Exception;
+ void closeContinuousQuery(String queryName) throws Exception;
/**
@@ -339,7 +339,7 @@ public interface CacheServerMXBean {
*
* @return A list of IDs or a length 0 array if no clients are registered.
*/
- public String[] getClientIds() throws Exception;
+ String[] getClientIds() throws Exception;
/**
* Returns health and statistic information for the give client id. Some of the information (CPUs,
@@ -348,19 +348,19 @@ public interface CacheServerMXBean {
*
* @param clientId ID of the client for which to retrieve information.
*/
- public ClientHealthStatus showClientStats(String clientId) throws Exception;
+ ClientHealthStatus showClientStats(String clientId) throws Exception;
/**
* Returns the number of clients who have existing subscriptions.
*/
- public int getNumSubscriptions();
+ int getNumSubscriptions();
/**
* Returns health and statistic information for all clients. Some of the information (CPUs,
* NumOfCacheListenerCalls, NumOfGets,NumOfMisses, NumOfPuts,NumOfThreads, ProcessCpuTime) only
* available for clients which have set a "StatisticsInterval".
*/
- public ClientHealthStatus[] showAllClientStats() throws Exception;
+ ClientHealthStatus[] showAllClientStats() throws Exception;
/**
* Shows a list of client with their queue statistics. Client queue statistics shown in this
@@ -372,7 +372,7 @@ public interface CacheServerMXBean {
* @return an array of ClientQueueDetail
* @throws Exception
*/
- public ClientQueueDetail[] showClientQueueDetails() throws Exception;
+ ClientQueueDetail[] showClientQueueDetails() throws Exception;
/**
*
@@ -386,6 +386,6 @@ public interface CacheServerMXBean {
* @return ClientQueueDetail
* @throws Exception
*/
- public ClientQueueDetail showClientQueueDetails(String clientId) throws Exception;
+ ClientQueueDetail showClientQueueDetails(String clientId) throws Exception;
}
http://git-wip-us.apache.org/repos/asf/geode/blob/ebb691dd/geode-core/src/main/java/org/apache/geode/management/DiskStoreMXBean.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/management/DiskStoreMXBean.java b/geode-core/src/main/java/org/apache/geode/management/DiskStoreMXBean.java
index cca6272..d51b71c 100644
--- a/geode-core/src/main/java/org/apache/geode/management/DiskStoreMXBean.java
+++ b/geode-core/src/main/java/org/apache/geode/management/DiskStoreMXBean.java
@@ -31,58 +31,58 @@ public interface DiskStoreMXBean {
/**
* Returns the name of the DiskStore.
*/
- public String getName();
+ String getName();
/**
* Returns whether disk files are to be automatically compacted.
*
* @return True if disk files are automatically compacted, false otherwise
*/
- public boolean isAutoCompact();
+ boolean isAutoCompact();
/**
* Returns the threshold at which an op-log may be compacted. Until it reaches this threshold the
* op-log will not be compacted. The threshold is a percentage in the range 0..100.
*/
- public int getCompactionThreshold();
+ int getCompactionThreshold();
/**
* Returns whether manual compaction of disk files is allowed.
*
* @return True if manual compaction is allowed, false otherwise.
*/
- public boolean isForceCompactionAllowed();
+ boolean isForceCompactionAllowed();
/**
* Returns the maximum size (in megabytes) that a single op-log can grow to.
*/
- public long getMaxOpLogSize();
+ long getMaxOpLogSize();
/**
* Returns the time (in milliseconds) that can elapse before unwritten data is saved to disk.
*/
- public long getTimeInterval();
+ long getTimeInterval();
/**
* Returns the size of the write buffer that this DiskStore will use when writing data to disk.
*/
- public int getWriteBufferSize();
+ int getWriteBufferSize();
/**
* Returns the path of the directories to which the region's data will be written.
*/
- public String[] getDiskDirectories();
+ String[] getDiskDirectories();
/**
* Returns the maximum number of operations that can be asynchronously queued for saving to disk.
* When this limit is reached operations will block until they can be put in the queue.
*/
- public int getQueueSize();
+ int getQueueSize();
/**
* Returns the total number of bytes of space this DiskStore has used.
*/
- public long getTotalBytesOnDisk();
+ long getTotalBytesOnDisk();
/**
* Returns the average latency of disk reads in nanoseconds Its the average latency required to
@@ -92,7 +92,7 @@ public interface DiskStoreMXBean {
* So this rate won't match the number of bytes put in all regions.This is rate of actual bytes
* system is persisting.
*/
- public float getDiskReadsRate();
+ float getDiskReadsRate();
/**
* Returns the average latency of disk writes in nanoseconds. Its the average latency required to
@@ -102,44 +102,44 @@ public interface DiskStoreMXBean {
* So this rate won't match the number of bytes put in all regions. This is rate of actual bytes
* system is persisting.
*/
- public float getDiskWritesRate();
+ float getDiskWritesRate();
/**
* Returns the disk reads average latency in nanoseconds. It depicts average time needed to read
* one byte of data from disk.
*/
- public long getDiskReadsAvgLatency();
+ long getDiskReadsAvgLatency();
/**
* Returns the disk writes average latency in nanoseconds. It depicts average time needed to write
* one byte of data to disk.
*/
- public long getDiskWritesAvgLatency();
+ long getDiskWritesAvgLatency();
/**
* Returns the flush time average latency.
*/
- public long getFlushTimeAvgLatency();
+ long getFlushTimeAvgLatency();
/**
* Returns the number of entries in the asynchronous queue waiting to be written to disk.
*/
- public int getTotalQueueSize();
+ int getTotalQueueSize();
/**
* Returns the number of backups currently in progress on this DiskStore.
*/
- public int getTotalBackupInProgress();
+ int getTotalBackupInProgress();
/**
* Returns the number of backups of this DiskStore that have been completed.
*/
- public int getTotalBackupCompleted();
+ int getTotalBackupCompleted();
/**
* Returns the number of persistent regions currently being recovered from disk.
*/
- public int getTotalRecoveriesInProgress();
+ int getTotalRecoveriesInProgress();
/**
* Requests the DiskStore to start writing to a new op-log. The old oplog will be asynchronously
@@ -150,7 +150,7 @@ public interface DiskStoreMXBean {
* additional space is available.
*/
@ResourceOperation(resource = Resource.DATA, operation = Operation.MANAGE)
- public void forceRoll();
+ void forceRoll();
/**
* Requests the DiskStore to start compacting. The compaction is done even if automatic compaction
@@ -162,14 +162,14 @@ public interface DiskStoreMXBean {
* ready to be compacted or that a compaction was already in progress.
*/
@ResourceOperation(resource = Resource.DATA, operation = Operation.MANAGE)
- public boolean forceCompaction();
+ boolean forceCompaction();
/**
* Causes any data that is currently in the asynchronous queue to be written to disk. Does not
* return until the flush is complete.
*/
@ResourceOperation(resource = Resource.DATA, operation = Operation.MANAGE)
- public void flush();
+ void flush();
/**
* Returns the warning threshold for disk usage as a percentage of the total disk volume.
@@ -177,7 +177,7 @@ public interface DiskStoreMXBean {
* @return the warning percent
* @since GemFire 8.0
*/
- public float getDiskUsageWarningPercentage();
+ float getDiskUsageWarningPercentage();
/**
* Returns the critical threshold for disk usage as a percentage of the total disk volume.
@@ -185,7 +185,7 @@ public interface DiskStoreMXBean {
* @return the critical percent
* @since GemFire 8.0
*/
- public float getDiskUsageCriticalPercentage();
+ float getDiskUsageCriticalPercentage();
/**
* Sets the value of the disk usage warning percentage.
@@ -193,7 +193,7 @@ public interface DiskStoreMXBean {
* @param warningPercent the warning percent
*/
@ResourceOperation(resource = Resource.DATA, operation = Operation.MANAGE)
- public void setDiskUsageWarningPercentage(float warningPercent);
+ void setDiskUsageWarningPercentage(float warningPercent);
/**
* Sets the value of the disk usage critical percentage.
@@ -201,5 +201,5 @@ public interface DiskStoreMXBean {
* @param criticalPercent the critical percent
*/
@ResourceOperation(resource = Resource.DATA, operation = Operation.MANAGE)
- public void setDiskUsageCriticalPercentage(float criticalPercent);
+ void setDiskUsageCriticalPercentage(float criticalPercent);
}
http://git-wip-us.apache.org/repos/asf/geode/blob/ebb691dd/geode-core/src/main/java/org/apache/geode/management/DistributedLockServiceMXBean.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/management/DistributedLockServiceMXBean.java b/geode-core/src/main/java/org/apache/geode/management/DistributedLockServiceMXBean.java
index e5306ba..6cc7816 100644
--- a/geode-core/src/main/java/org/apache/geode/management/DistributedLockServiceMXBean.java
+++ b/geode-core/src/main/java/org/apache/geode/management/DistributedLockServiceMXBean.java
@@ -35,32 +35,32 @@ public interface DistributedLockServiceMXBean {
/**
* Returns the name of the LockService.
*/
- public String getName();
+ String getName();
/**
* Returns the number of members using this LockService.
*/
- public int getMemberCount();
+ int getMemberCount();
/**
* Returns of the name of the member which grants the lock.
*/
- public String fetchGrantorMember();
+ String fetchGrantorMember();
/**
* Returns a list of names of the members using this LockService.
*/
- public String[] getMemberNames();
+ String[] getMemberNames();
/**
* Returns a map of the names of the objects being locked on and the names of the threads holding
* the locks.
*/
- public Map<String, String> listThreadsHoldingLock();
+ Map<String, String> listThreadsHoldingLock();
/**
* Returns a list of names of the locks held by this member's threads.
*/
- public String[] listHeldLocks();
+ String[] listHeldLocks();
}
http://git-wip-us.apache.org/repos/asf/geode/blob/ebb691dd/geode-core/src/main/java/org/apache/geode/management/DistributedRegionMXBean.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/management/DistributedRegionMXBean.java b/geode-core/src/main/java/org/apache/geode/management/DistributedRegionMXBean.java
index c45c5f3..1906e04 100644
--- a/geode-core/src/main/java/org/apache/geode/management/DistributedRegionMXBean.java
+++ b/geode-core/src/main/java/org/apache/geode/management/DistributedRegionMXBean.java
@@ -35,170 +35,170 @@ public interface DistributedRegionMXBean {
/**
* Returns the name of the Region.
*/
- public String getName();
+ String getName();
/**
* Returns the number of members hosting/using the Region.
*/
- public int getMemberCount();
+ int getMemberCount();
/**
* Returns a list of names/IDs of the members hosting the Region.
*/
- public String[] getMembers();
+ String[] getMembers();
/**
* Returns the type (data policy) of the Region.
*/
- public String getRegionType();
+ String getRegionType();
/**
* Returns the full path of the Region.
*/
- public String getFullPath();
+ String getFullPath();
/**
* Returns the name of the parent Region.
*/
- public String getParentRegion();
+ String getParentRegion();
/**
* Returns a list of the names of the subregions.
*
* @param recursive <code>true</code> to recursively traverse and find sub-regions.
*/
- public String[] listSubRegionPaths(boolean recursive);
+ String[] listSubRegionPaths(boolean recursive);
/**
* Returns the attributes of the Region.
*/
- public RegionAttributesData listRegionAttributes();
+ RegionAttributesData listRegionAttributes();
/**
* Returns the partition attributes of the Region.
*/
- public PartitionAttributesData listPartitionAttributes();
+ PartitionAttributesData listPartitionAttributes();
/**
* Returns the fixed partition attributes of the Region.
*/
- public FixedPartitionAttributesData[] listFixedPartitionAttributesData();
+ FixedPartitionAttributesData[] listFixedPartitionAttributesData();
/**
* Returns the eviction attributes of the Region.
*/
- public EvictionAttributesData listEvictionAttributes();
+ EvictionAttributesData listEvictionAttributes();
/**
* Returns the membership attributes of the Region.
*
* @deprecated this API is scheduled to be removed
*/
- public MembershipAttributesData listMembershipAttributes();
+ MembershipAttributesData listMembershipAttributes();
/**
* Returns the time of the most recent modification. For partitioned region it will be -1. This
* feature is not supported for partitioned regions.
*/
- public long getLastModifiedTime();
+ long getLastModifiedTime();
/**
* Returns the time of the most recent access. For partitioned region it will be -1. This feature
* is not supported for partitioned regions.
*/
- public long getLastAccessedTime();
+ long getLastAccessedTime();
/**
* Returns the number of times that a cache miss occurred. For partitioned region it will be -1.
* This feature is not supported for partitioned regions.
*/
- public long getMissCount();
+ long getMissCount();
/**
* Returns the number of times that a hit occurred. For partitioned region it will be -1. This
* feature is not supported for partitioned regions.
*/
- public long getHitCount();
+ long getHitCount();
/**
* Returns the hit to miss ratio. For partitioned region it will be -1. This feature is not
* supported for partitioned regions.
*/
- public float getHitRatio();
+ float getHitRatio();
/**
* Returns the number of entries in the Region.
*
*/
- public long getSystemRegionEntryCount();
+ long getSystemRegionEntryCount();
/**
* Returns the number of gets per second.
*/
- public float getGetsRate();
+ float getGetsRate();
/**
* Returns the number of puts per second.
*/
- public float getPutsRate();
+ float getPutsRate();
/**
* Returns the number of creates per second.
*/
- public float getCreatesRate();
+ float getCreatesRate();
/**
* Returns the number of destroys per second.
*/
- public float getDestroyRate();
+ float getDestroyRate();
/**
* Returns the number of putAlls per second.
*/
- public float getPutAllRate();
+ float getPutAllRate();
/**
* Returns the number of local puts per second.
*/
- public float getPutLocalRate();
+ float getPutLocalRate();
/**
* Returns the number of remote puts per second.
*/
- public float getPutRemoteRate();
+ float getPutRemoteRate();
/**
* Returns the latency for the most recent remote put.
*/
- public long getPutRemoteLatency();
+ long getPutRemoteLatency();
/**
* Returns the average latency for remote puts.
*/
- public long getPutRemoteAvgLatency();
+ long getPutRemoteAvgLatency();
/**
* Returns the current number of entries whose values are only on disk (not in memory). Entries
* may not exist in memory if they have been overflowed to disk or not yet been faulted in after a
* recovery.
*/
- public long getTotalEntriesOnlyOnDisk();
+ long getTotalEntriesOnlyOnDisk();
/**
* Returns the current number of entries held in memory.
*/
- public long getTotalDiskEntriesInVM();
+ long getTotalDiskEntriesInVM();
/**
* Returns the number of entries per second for all disks.
*/
- public float getDiskReadsRate();
+ float getDiskReadsRate();
/**
* Returns the number of entries per second for all disks.
*/
- public float getDiskWritesRate();
+ float getDiskWritesRate();
/**
* Returns the current number of disk tasks (op-log compaction, asynchronous recoveries, etc) that
@@ -206,96 +206,96 @@ public interface DistributedRegionMXBean {
*
* @deprecated
*/
- public long getDiskTaskWaiting();
+ long getDiskTaskWaiting();
/**
* Returns the current number of disk writes in progress.
*/
- public long getTotalDiskWritesProgress();
+ long getTotalDiskWritesProgress();
/**
* Returns the average latency of a call to a {@link CacheWriter}.
*/
- public long getCacheWriterCallsAvgLatency();
+ long getCacheWriterCallsAvgLatency();
/**
* Returns the average latency of a call to a {@link CacheListener}.
*/
- public long getCacheListenerCallsAvgLatency();
+ long getCacheListenerCallsAvgLatency();
/**
* Returns the entry eviction rate as triggered by the LRU policy.
*/
- public float getLruEvictionRate();
+ float getLruEvictionRate();
/**
* Returns the rate of entries destroyed either by destroy cache operations or eviction.
*/
- public float getLruDestroyRate();
+ float getLruDestroyRate();
/**
* Returns the number of buckets on this member. Only applicable for partitioned regions.
*/
- public int getBucketCount();
+ int getBucketCount();
/**
* Returns the number of primary buckets on this member. Only applicable for partitioned regions.
*/
- public int getPrimaryBucketCount();
+ int getPrimaryBucketCount();
/**
* Returns the number of buckets without full redundancy. Only applicable for partitioned regions.
*/
- public int getNumBucketsWithoutRedundancy();
+ int getNumBucketsWithoutRedundancy();
/**
* Returns the total number of entries in all buckets. Only applicable for partitioned regions.
*/
- public int getTotalBucketSize();
+ int getTotalBucketSize();
/**
* Returns the average number of entries in bucket. Only applicable for partitioned regions.
*/
- public int getAvgBucketSize();
+ int getAvgBucketSize();
/**
* Returns the total number of bytes used by all disks.
*/
- public long getDiskUsage();
+ long getDiskUsage();
/**
* Returns the average number of read requests per second.
*/
- public float getAverageReads();
+ float getAverageReads();
/**
* Returns the average number of write requests per second.
*/
- public float getAverageWrites();
+ float getAverageWrites();
/**
* Returns whether the Region sends data to a {@link GatewaySender}.
*
* @return True if the Region sends data, false otherwise.
*/
- public boolean isGatewayEnabled();
+ boolean isGatewayEnabled();
/**
* Returns whether persistence is enabled.
*
* @return True if persistence is enabled, false otherwise.
*/
- public boolean isPersistentEnabled();
+ boolean isPersistentEnabled();
/**
* Returns the aggregate entry size (in megabytes) of all entries. This will provide a correct
* value only if the eviction algorithm has been set to {@link EvictionAlgorithm#LRU_MEMORY}.
*/
- public long getEntrySize();
+ long getEntrySize();
/**
* Returns the number of members whose entry count is 0.
*/
- public int getEmptyNodes();
+ int getEmptyNodes();
}