http://git-wip-us.apache.org/repos/asf/geode/blob/f7396e4c/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/f7396e4c/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/f7396e4c/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/f7396e4c/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/f7396e4c/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/f7396e4c/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/f7396e4c/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/f7396e4c/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/f7396e4c/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/f7396e4c/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/f7396e4c/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/f7396e4c/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/f7396e4c/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/f7396e4c/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/f7396e4c/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/f7396e4c/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/f7396e4c/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/f7396e4c/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/f7396e4c/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/f7396e4c/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/f7396e4c/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/f7396e4c/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/f7396e4c/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/f7396e4c/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/f7396e4c/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/f7396e4c/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/f7396e4c/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/f7396e4c/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/f7396e4c/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/f7396e4c/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/f7396e4c/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(); }
