GEODE-2919: Provide finer grained security - For full details, see https://cwiki.apache.org/confluence/display/GEODE/Finer+grained+security
Project: http://git-wip-us.apache.org/repos/asf/geode/repo Commit: http://git-wip-us.apache.org/repos/asf/geode/commit/451d12e8 Tree: http://git-wip-us.apache.org/repos/asf/geode/tree/451d12e8 Diff: http://git-wip-us.apache.org/repos/asf/geode/diff/451d12e8 Branch: refs/heads/feature/GEM-1483 Commit: 451d12e83c2457c22535ae684995e973ba8d3dd2 Parents: 3ee585c Author: Patrick Rhomberg <[email protected]> Authored: Wed Jun 21 10:51:32 2017 -0700 Committer: Jared Stewart <[email protected]> Committed: Fri Jun 23 15:46:01 2017 -0700 ---------------------------------------------------------------------- .../geode/management/CacheServerMXBean.java | 122 ++--- .../geode/management/DiskStoreMXBean.java | 68 +-- .../management/DistributedSystemMXBean.java | 174 +++---- .../geode/management/GatewayReceiverMXBean.java | 75 +-- .../geode/management/GatewaySenderMXBean.java | 88 ++-- .../geode/management/LockServiceMXBean.java | 20 +- .../apache/geode/management/MemberMXBean.java | 263 +++++----- .../internal/beans/DistributedSystemMBean.java | 21 +- .../management/internal/beans/MemberMBean.java | 7 +- .../internal/beans/MemberMBeanBridge.java | 4 +- .../internal/cli/commands/ClientCommands.java | 90 ++-- .../CreateAlterDestroyRegionCommands.java | 43 +- .../internal/cli/commands/DataCommands.java | 64 ++- .../internal/cli/commands/DeployCommands.java | 34 +- .../cli/commands/DiskStoreCommands.java | 222 ++++----- .../cli/commands/DurableClientCommands.java | 90 ++-- .../internal/cli/commands/FunctionCommands.java | 136 ++---- .../internal/cli/commands/GfshCommand.java | 20 +- .../internal/cli/commands/IndexCommands.java | 138 +++--- .../cli/commands/MiscellaneousCommands.java | 258 +++++----- .../internal/cli/commands/PDXCommands.java | 39 +- .../internal/cli/commands/QueueCommands.java | 55 +-- .../internal/cli/commands/RegionCommands.java | 76 ++- .../internal/cli/commands/WanCommands.java | 219 +++++---- .../commands/lifecycle/StartPulseCommand.java | 18 +- .../cli/functions/ContinuousQueryFunction.java | 148 ++++++ .../cli/functions/ContunuousQueryFunction.java | 150 ------ .../cli/functions/RegionFunctionArgs.java | 26 +- .../cli/functions/UserFunctionExecution.java | 42 +- .../internal/cli/i18n/CliStrings.java | 44 +- .../internal/cli/remote/CommandProcessor.java | 17 +- .../internal/security/MBeanServerWrapper.java | 38 +- .../MemberMBeanAttributesDUnitTest.java | 35 +- .../bean/stats/MemberLevelStatsJUnitTest.java | 8 +- .../CreateAlterDestroyRegionCommandsTest.java | 17 +- ...CacheServerMBeanAuthenticationJUnitTest.java | 20 +- .../CacheServerMBeanAuthorizationJUnitTest.java | 42 +- ...eServerMBeanWithShiroIniIntegrationTest.java | 15 +- .../security/CliCommandsSecurityTest.java | 34 +- .../security/DataCommandsSecurityTest.java | 13 +- .../security/DeployCommandsSecurityTest.java | 28 +- .../DiskStoreMXBeanSecurityJUnitTest.java | 98 ++-- .../DistributedSystemMXBeanSecurityTest.java | 77 +++ .../GatewayReceiverMBeanSecurityTest.java | 42 +- .../GatewaySenderMBeanSecurityTest.java | 68 +-- .../security/GfshCommandsPostProcessorTest.java | 28 +- .../security/GfshCommandsSecurityTest.java | 76 +-- .../LockServiceMBeanAuthorizationJUnitTest.java | 73 ++- .../security/MBeanSecurityJUnitTest.java | 30 +- .../ManagerMBeanAuthorizationJUnitTest.java | 30 +- .../security/MemberMBeanSecurityJUnitTest.java | 51 +- .../internal/security/MultiUserDUnitTest.java | 102 ++-- .../security/ResourcePermissionTest.java | 13 +- .../internal/security/TestCommand.java | 157 +++--- .../dunit/rules/LocatorServerStartupRule.java | 19 +- .../test/dunit/rules/MemberStarterRule.java | 6 + .../codeAnalysis/sanctionedSerializables.txt | 4 +- .../cli/commands/ClientCommandsDUnitTest.java | 478 ++++++++++--------- .../internal/cli/LuceneIndexCommands.java | 58 ++- .../lucene/internal/cli/LuceneIndexInfo.java | 10 - .../functions/LuceneCreateIndexFunction.java | 14 +- .../lucene/LuceneCommandsSecurityDUnitTest.java | 126 +++-- .../GfshCommandsOverHttpSecurityTest.java | 4 +- 63 files changed, 2342 insertions(+), 2243 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/geode/blob/451d12e8/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..d0159f0 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 @@ -18,12 +18,13 @@ import org.apache.geode.cache.server.CacheServer; import org.apache.geode.management.internal.security.ResourceOperation; import org.apache.geode.security.ResourcePermission.Operation; import org.apache.geode.security.ResourcePermission.Resource; +import org.apache.geode.security.ResourcePermission.Target; /** * MBean that provides access to information and management functionality for a {@link CacheServer}. * * <p> - * The will be one CacheServermBean per {@link CacheServer} started in GemFire node. + * The will be one CacheServerMBean per {@link CacheServer} started in GemFire node. * * <p> * ObjectName for this MBean is GemFire:service=CacheServer,port={0},type=Member,member={1} @@ -60,48 +61,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. + * Returns the maximum 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 +112,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 +277,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 +294,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 @@ -305,8 +306,9 @@ public interface CacheServerMXBean { * methods to modify a CQ. */ @Deprecated - @ResourceOperation(resource = Resource.DATA, operation = Operation.MANAGE) - public void stopContinuousQuery(String queryName) throws Exception; + @ResourceOperation(resource = Resource.CLUSTER, operation = Operation.MANAGE, + target = Target.QUERY) + void stopContinuousQuery(String queryName) throws Exception; /** * Unregister all CQs from a region @@ -317,8 +319,9 @@ public interface CacheServerMXBean { * methods to modify a CQ. */ @Deprecated - @ResourceOperation(resource = Resource.DATA, operation = Operation.MANAGE) - public void closeAllContinuousQuery(String regionName) throws Exception; + @ResourceOperation(resource = Resource.CLUSTER, operation = Operation.MANAGE, + target = Target.QUERY) + void closeAllContinuousQuery(String regionName) throws Exception; /** @@ -330,8 +333,9 @@ public interface CacheServerMXBean { * methods to modify a CQ. */ @Deprecated - @ResourceOperation(resource = Resource.DATA, operation = Operation.MANAGE) - public void closeContinuousQuery(String queryName) throws Exception; + @ResourceOperation(resource = Resource.CLUSTER, operation = Operation.MANAGE, + target = Target.QUERY) + void closeContinuousQuery(String queryName) throws Exception; /** @@ -339,7 +343,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,44 +352,44 @@ 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 * method are the following * - * eventsEnqued,eventsRemoved , eventsConflated ,markerEventsConflated , eventsExpired, + * eventsEnqueued,eventsRemoved , eventsConflated ,markerEventsConflated , eventsExpired, * eventsRemovedByQrm , eventsTaken , numVoidRemovals * * @return an array of ClientQueueDetail * @throws Exception */ - public ClientQueueDetail[] showClientQueueDetails() throws Exception; + ClientQueueDetail[] showClientQueueDetails() throws Exception; /** * * Shows queue statistics of the given client. Client queue statistics shown in this method are * the following * - * eventsEnqued,eventsRemoved , eventsConflated ,markerEventsConflated , eventsExpired, + * eventsEnqueued,eventsRemoved , eventsConflated ,markerEventsConflated , eventsExpired, * eventsRemovedByQrm , eventsTaken , numVoidRemovals * * @param clientId the ID of client which is returned by the attribute ClientIds * @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/451d12e8/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..6275df5 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 @@ -18,6 +18,7 @@ import org.apache.geode.cache.DiskStore; import org.apache.geode.management.internal.security.ResourceOperation; import org.apache.geode.security.ResourcePermission.Operation; import org.apache.geode.security.ResourcePermission.Resource; +import org.apache.geode.security.ResourcePermission.Target; /** * MBean that provides access to information and management functionality for a {@link DiskStore}. @@ -31,58 +32,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 +93,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 +103,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 @@ -149,8 +150,9 @@ public interface DiskStoreMXBean { * compaction is true then the application will wait for the other op-logs to be compacted and * additional space is available. */ - @ResourceOperation(resource = Resource.DATA, operation = Operation.MANAGE) - public void forceRoll(); + @ResourceOperation(resource = Resource.CLUSTER, operation = Operation.MANAGE, + target = Target.DISK) + void forceRoll(); /** * Requests the DiskStore to start compacting. The compaction is done even if automatic compaction @@ -161,15 +163,17 @@ public interface DiskStoreMXBean { * @return True if one or more op-logs were compacted or false to indicate that no op-logs were * ready to be compacted or that a compaction was already in progress. */ - @ResourceOperation(resource = Resource.DATA, operation = Operation.MANAGE) - public boolean forceCompaction(); + @ResourceOperation(resource = Resource.CLUSTER, operation = Operation.MANAGE, + target = Target.DISK) + 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(); + @ResourceOperation(resource = Resource.CLUSTER, operation = Operation.MANAGE, + target = Target.DISK) + void flush(); /** * Returns the warning threshold for disk usage as a percentage of the total disk volume. @@ -177,7 +181,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,21 +189,23 @@ 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. * * @param warningPercent the warning percent */ - @ResourceOperation(resource = Resource.DATA, operation = Operation.MANAGE) - public void setDiskUsageWarningPercentage(float warningPercent); + @ResourceOperation(resource = Resource.CLUSTER, operation = Operation.MANAGE, + target = Target.DISK) + void setDiskUsageWarningPercentage(float warningPercent); /** * Sets the value of the disk usage critical percentage. * * @param criticalPercent the critical percent */ - @ResourceOperation(resource = Resource.DATA, operation = Operation.MANAGE) - public void setDiskUsageCriticalPercentage(float criticalPercent); + @ResourceOperation(resource = Resource.CLUSTER, operation = Operation.MANAGE, + target = Target.DISK) + void setDiskUsageCriticalPercentage(float criticalPercent); } http://git-wip-us.apache.org/repos/asf/geode/blob/451d12e8/geode-core/src/main/java/org/apache/geode/management/DistributedSystemMXBean.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/management/DistributedSystemMXBean.java b/geode-core/src/main/java/org/apache/geode/management/DistributedSystemMXBean.java index f6f701e..3d52115 100644 --- a/geode-core/src/main/java/org/apache/geode/management/DistributedSystemMXBean.java +++ b/geode-core/src/main/java/org/apache/geode/management/DistributedSystemMXBean.java @@ -15,6 +15,7 @@ package org.apache.geode.management; import java.util.Map; + import javax.management.ObjectName; import org.apache.geode.cache.DiskStore; @@ -24,6 +25,7 @@ import org.apache.geode.distributed.DistributedSystem; import org.apache.geode.management.internal.security.ResourceOperation; import org.apache.geode.security.ResourcePermission.Operation; import org.apache.geode.security.ResourcePermission.Resource; +import org.apache.geode.security.ResourcePermission.Target; /** * MBean that provides access to information and management operations for a @@ -76,22 +78,22 @@ import org.apache.geode.security.ResourcePermission.Resource; public interface DistributedSystemMXBean { /** - * Returns the ID of thie DistributedSystem. allow anyone to access this method + * Returns the ID of the DistributedSystem. allow anyone to access this method * * @return The DistributedSystem ID or -1 if not set. */ @ResourceOperation() - public int getDistributedSystemId(); + int getDistributedSystemId(); /** * Returns the number of members in the distributed system. */ - public int getMemberCount(); + int getMemberCount(); /** * Returns a list of names for all members. */ - public String[] listMembers(); + String[] listMembers(); /** * Returns a list of names for locator members. @@ -101,49 +103,49 @@ public interface DistributedSystemMXBean { * @return a list of names for locator members. */ - public String[] listLocatorMembers(boolean onlyStandAloneLocators); + String[] listLocatorMembers(boolean onlyStandAloneLocators); /** * Returns a list of names for all groups. */ - public String[] listGroups(); + String[] listGroups(); /** * Returns the number of locators in the distributed system. */ - public int getLocatorCount(); + int getLocatorCount(); /** * Returns a list of IDs for all locators. */ - public String[] listLocators(); // TODO - Abhishek Should be renamed to - // listLocatorDiscoveryConfigurations? Do we need something for - // mcast too? + String[] listLocators(); // TODO - Abhishek Should be renamed to + // listLocatorDiscoveryConfigurations? Do we need something for + // mcast too? /** * Returns the number of disks stores in the distributed system. */ - public int getSystemDiskStoreCount(); + int getSystemDiskStoreCount(); /** * Returns a map of all {@link DistributedMember}s and their {@link DiskStore}s. */ - public Map<String, String[]> listMemberDiskstore(); + Map<String, String[]> listMemberDiskstore(); /** * Returns a list of IDs for all gateway senders. */ - public String[] listGatewaySenders(); + String[] listGatewaySenders(); /** * Returns a list of IDs for all gateway receivers. */ - public String[] listGatewayReceivers(); + String[] listGatewayReceivers(); /** * Returns the minimum level set for alerts to be delivered to listeners. */ - public String getAlertLevel(); + String getAlertLevel(); /** * Sets the minimum level for alerts to be delivered to listeners. @@ -152,74 +154,74 @@ public interface DistributedSystemMXBean { * SEVERE or NONE. */ @ResourceOperation(resource = Resource.CLUSTER, operation = Operation.WRITE) - public void changeAlertLevel(String alertLevel) throws Exception; + void changeAlertLevel(String alertLevel) throws Exception; /** * Returns the total available heap (in megabytes) across all distributed members. */ - public long getTotalHeapSize(); + long getTotalHeapSize(); /** * Returns the total number of entries in all regions. */ - public long getTotalRegionEntryCount(); + long getTotalRegionEntryCount(); /** * Returns the number of {@link Region}s. */ - public int getTotalRegionCount(); + int getTotalRegionCount(); /** * Returns the number of times that a cache miss occurred for all regions. */ - public int getTotalMissCount(); + int getTotalMissCount(); /** * Returns the number of times that a hit occurred for all regions. */ - public int getTotalHitCount(); + int getTotalHitCount(); /** * Returns the number of connected clients. */ - public int getNumClients(); + int getNumClients(); /** * Returns the average number of disk reads per second across all distributed members. */ - public float getDiskReadsRate(); + float getDiskReadsRate(); /** * Returns the average number of disk writes per second across all distributed members. */ - public float getDiskWritesRate(); + float getDiskWritesRate(); /** * Returns the average disk flush latency time. */ - public long getDiskFlushAvgLatency(); + long getDiskFlushAvgLatency(); /** * Returns the number of backups currently in progress for all disk stores. */ - public int getTotalBackupInProgress(); + int getTotalBackupInProgress(); /** * Returns the number of initial images in progress. */ - public int getNumInitialImagesInProgress(); + int getNumInitialImagesInProgress(); /** * Returns the number of active (currently executing) CQs for all cache servers. */ - public long getActiveCQCount(); + long getActiveCQCount(); /** * Returns the average number of queries per second across all distributed members. */ - public float getQueryRequestRate(); + float getQueryRequestRate(); /** * Performs a backup on all members. @@ -229,8 +231,7 @@ public interface DistributedSystemMXBean { * @return The results of the backup request. */ @ResourceOperation(resource = Resource.DATA, operation = Operation.READ) - public DiskBackupStatus backupAllMembers(String targetDirPath, String baselineDirPath) - throws Exception; + DiskBackupStatus backupAllMembers(String targetDirPath, String baselineDirPath) throws Exception; /** * Returns the configuration information for a distributed member. @@ -239,7 +240,7 @@ public interface DistributedSystemMXBean { * @return The configuration information for a member. * @throws Exception for an invalid member ID. */ - public GemFireProperties fetchMemberConfiguration(String member) throws Exception; + GemFireProperties fetchMemberConfiguration(String member) throws Exception; /** * Returns the total time (in seconds) since a distributed member was started. @@ -248,21 +249,21 @@ public interface DistributedSystemMXBean { * @return The total time (in seconds) since a member was started. * @throws Exception for an invalid member ID. */ - public long fetchMemberUpTime(String member) throws Exception; + long fetchMemberUpTime(String member) throws Exception; /** * Returns a list of names for all cache servers which are able to serve requests from GemFire * clients. * */ - public String[] listCacheServers(); + String[] listCacheServers(); /** * Returns a list of names for all servers where server means any long-running GemFire process * that was started with "start server" command from GFSH. */ - public String[] listServers(); + String[] listServers(); /** * Returns JVM metrics for a distributed member. @@ -270,7 +271,7 @@ public interface DistributedSystemMXBean { * @param member Name or ID of the member. * @throws Exception for an invalid member ID. */ - public JVMMetrics showJVMMetrics(String member) throws Exception; + JVMMetrics showJVMMetrics(String member) throws Exception; /** * Returns operating system metrics for a distributed member. @@ -278,7 +279,7 @@ public interface DistributedSystemMXBean { * @param member Name or ID of the member. * @throws Exception for an invalid member ID. */ - public OSMetrics showOSMetrics(String member) throws Exception; + OSMetrics showOSMetrics(String member) throws Exception; /** * Returns network metrics for a distributed member. @@ -286,7 +287,7 @@ public interface DistributedSystemMXBean { * @param member Name or ID of the member. * @throws Exception for an invalid member ID. */ - public NetworkMetrics showNetworkMetric(String member) throws Exception; + NetworkMetrics showNetworkMetric(String member) throws Exception; /** * Returns disk metrics for a distributed member. @@ -294,7 +295,7 @@ public interface DistributedSystemMXBean { * @param member Name or ID of the member. * @throws Exception for an invalid member ID. */ - public DiskMetrics showDiskMetrics(String member) throws Exception; + DiskMetrics showDiskMetrics(String member) throws Exception; /** * Shuts down all members of a distributed system except for the managing member. @@ -302,17 +303,17 @@ public interface DistributedSystemMXBean { * @return List of names of all distributed members that were shutdown. */ @ResourceOperation(resource = Resource.CLUSTER, operation = Operation.MANAGE) - public String[] shutDownAllMembers() throws Exception; + String[] shutDownAllMembers() throws Exception; /** * Returns a list of names for all regions. */ - public String[] listRegions(); + String[] listRegions(); /** * Returns a list of full paths for all regions. */ - public String[] listAllRegionPaths(); + String[] listAllRegionPaths(); /** * Removes a disk store from the distributed system. @@ -320,40 +321,41 @@ public interface DistributedSystemMXBean { * @param diskStoreId UUID of the disk store to remove * @return True if the request is successful, false otherwise. */ - @ResourceOperation(resource = Resource.DATA, operation = Operation.MANAGE) - public boolean revokeMissingDiskStores(String diskStoreId) throws Exception; + @ResourceOperation(resource = Resource.CLUSTER, operation = Operation.MANAGE, + target = Target.DISK) + boolean revokeMissingDiskStores(String diskStoreId); /** * Returns a list of details for disk stores which have been determined to be unavailable during * the recovery of region. */ - public PersistentMemberDetails[] listMissingDiskStores(); + PersistentMemberDetails[] listMissingDiskStores(); /** * Returns the object name for a {@link MemberMXBean} used to access this distributed member. * allow anyone to access this method */ @ResourceOperation() - public ObjectName getMemberObjectName(); + ObjectName getMemberObjectName(); /** * Returns the object name for a {@link ManagerMXBean} used to access the management service * running on this distributed member. */ - public ObjectName getManagerObjectName(); + ObjectName getManagerObjectName(); /** * Returns a list of object names for the {@link MemberMXBean}s used to access all distributed * members. */ - public ObjectName[] listMemberObjectNames(); + ObjectName[] listMemberObjectNames(); /** * Returns the object name for a {@link MemberMXBean} used to access a distributed member.. * * @param member Name or ID of the member. */ - public ObjectName fetchMemberObjectName(String member) throws Exception; + ObjectName fetchMemberObjectName(String member) throws Exception; /** * Returns a list of object names for the {@link RegionMXBean}s used to access all regions on a @@ -361,7 +363,7 @@ public interface DistributedSystemMXBean { * * @param memberMBeanName ObjectName of the member. */ - public ObjectName[] fetchRegionObjectNames(ObjectName memberMBeanName) throws Exception; + ObjectName[] fetchRegionObjectNames(ObjectName memberMBeanName) throws Exception; /** * Returns a list of object names for the {@link DistributedRegionMXBean}s used to access all @@ -369,7 +371,7 @@ public interface DistributedSystemMXBean { * * @return An array of object names or an empty array if no distributed regions are found. */ - public ObjectName[] listDistributedRegionObjectNames(); + ObjectName[] listDistributedRegionObjectNames(); /** * Returns the object name for a {@link DistributedRegionMXBean} used to access a distributed @@ -377,7 +379,7 @@ public interface DistributedSystemMXBean { * * @param regionPath Full path of the region. */ - public ObjectName fetchDistributedRegionObjectName(String regionPath) throws Exception; + ObjectName fetchDistributedRegionObjectName(String regionPath) throws Exception; /** * Returns the object name for a {@link RegionMXBean} used to access a region. @@ -385,7 +387,7 @@ public interface DistributedSystemMXBean { * @param member Name or ID of the member. * @param regionPath Full path of the region. */ - public ObjectName fetchRegionObjectName(String member, String regionPath) throws Exception; + ObjectName fetchRegionObjectName(String member, String regionPath) throws Exception; /** * Returns the object name for a {@link GatewaySenderMXBean} used to access a gateway sender. @@ -393,14 +395,14 @@ public interface DistributedSystemMXBean { * @param member Name or ID of the member. * @param senderId ID of a gateway sender. */ - public ObjectName fetchGatewaySenderObjectName(String member, String senderId) throws Exception; + ObjectName fetchGatewaySenderObjectName(String member, String senderId) throws Exception; /** * Returns the object name for a {@link GatewayReceiverMXBean} used to access a gateway receiver. * * @param member Name or ID of the member. */ - public ObjectName fetchGatewayReceiverObjectName(String member) throws Exception; + ObjectName fetchGatewayReceiverObjectName(String member) throws Exception; /** * Returns a list of object names for the {@link GatewaySenderMXBean}s used to access all gateway @@ -408,7 +410,7 @@ public interface DistributedSystemMXBean { * * @return An array of object names or an empty array if no gateway senders are found. */ - public ObjectName[] listGatewaySenderObjectNames(); + ObjectName[] listGatewaySenderObjectNames(); /** * Returns a list of object names for the {@link GatewaySenderMXBean}s used to access all gateway @@ -416,7 +418,7 @@ public interface DistributedSystemMXBean { * * @param member Name or ID of the member. */ - public ObjectName[] listGatewaySenderObjectNames(String member) throws Exception; + ObjectName[] listGatewaySenderObjectNames(String member) throws Exception; /** * Returns a list of object names for the {@link GatewayReceiverMXBean}s used to access all @@ -424,7 +426,7 @@ public interface DistributedSystemMXBean { * * @return An array of object names or an empty array if no gateway receivers are found. */ - public ObjectName[] listGatewayReceiverObjectNames(); + ObjectName[] listGatewayReceiverObjectNames(); /** * Returns the object name for a {@link DistributedLockServiceMXBean} used to access a distributed @@ -432,7 +434,7 @@ public interface DistributedSystemMXBean { * * @param lockServiceName Name of the lock service. */ - public ObjectName fetchDistributedLockServiceObjectName(String lockServiceName) throws Exception; + ObjectName fetchDistributedLockServiceObjectName(String lockServiceName) throws Exception; /** * Returns the object name for a {@link LockServiceMXBean} used to access a lock service. @@ -440,7 +442,7 @@ public interface DistributedSystemMXBean { * @param member Name or Id of the member. * @param lockService Name of the lock service. */ - public ObjectName fetchLockServiceObjectName(String member, String lockService) throws Exception; + ObjectName fetchLockServiceObjectName(String member, String lockService) throws Exception; /** * Returns object name of a {@link DiskStoreMXBean} for a given name and member @@ -450,7 +452,7 @@ public interface DistributedSystemMXBean { * @return a ObjectName * @throws Exception */ - public ObjectName fetchDiskStoreObjectName(String member, String diskStoreName) throws Exception; + ObjectName fetchDiskStoreObjectName(String member, String diskStoreName) throws Exception; /** * Returns the object name for a {@link CacheServerMXBean} used to access a cache server. @@ -458,70 +460,70 @@ public interface DistributedSystemMXBean { * @param member Name or ID of the member. * @param port Port of the server. */ - public ObjectName fetchCacheServerObjectName(String member, int port) throws Exception; + ObjectName fetchCacheServerObjectName(String member, int port) throws Exception; /** * Returns a list of object names for the {@link CacheServerMXBean}s used to access all cache * servers. */ - public ObjectName[] listCacheServerObjectNames(); + ObjectName[] listCacheServerObjectNames(); /** * Returns the number of map-reduce jobs currently running on all members in the distributed * system. */ - public int getNumRunningFunctions(); + int getNumRunningFunctions(); /** * Returns the number of CQs registers on all members. */ - public long getRegisteredCQCount(); + long getRegisteredCQCount(); /** * Returns the number of bytes used on all disks. */ - public long getTotalDiskUsage(); + long getTotalDiskUsage(); /** * Returns the total heap used on all members. */ - public long getUsedHeapSize(); + long getUsedHeapSize(); /** * Returns the average number of reads per second for all members. */ - public float getAverageReads(); + float getAverageReads(); /** * Returns the average writes per second, including both put and putAll operations, for all * members. */ - public float getAverageWrites(); + float getAverageWrites(); /** * Returns the number of subscriptions for all members. */ - public int getNumSubscriptions(); + int getNumSubscriptions(); /** * Returns the number of garbage collection operations for all members. */ - public long getGarbageCollectionCount(); + long getGarbageCollectionCount(); /** * Returns a map of remote distributed system IDs and the current connection status for each. */ - public Map<String, Boolean> viewRemoteClusterStatus(); + Map<String, Boolean> viewRemoteClusterStatus(); /** * Returns the number JVM pauses (which may or may not include full garbage collection pauses) * detected by GemFire. */ - public long getJVMPauses(); + long getJVMPauses(); /** - * This API is used to query data from GemFire system. This returns a JSON formated String having + * This API is used to query data from GemFire system. This returns a JSON formatted String having * data and it's type. Type and value of data makes an array , type preceding the value. * * e.g. {"result":[["java.lang.String","v"],["java.lang.String","b"]]} @@ -548,10 +550,10 @@ public interface DistributedSystemMXBean { * mandatory to give this input barring join queries on PR. If member list is not provided * query will be for the whole cluster. * @param limit result set limit. If not set or 0 is passed default limit of 1000 will be set. - * @return a JSON formated string containing data and its type + * @return a JSON formatted string containing data and its type */ @ResourceOperation(resource = Resource.DATA, operation = Operation.READ) - public String queryData(String queryString, String members, int limit) throws Exception; + String queryData(String queryString, String members, int limit) throws Exception; /** * @@ -575,7 +577,7 @@ public interface DistributedSystemMXBean { * @return a byte[] which is a compressed JSON string. */ @ResourceOperation(resource = Resource.DATA, operation = Operation.READ) - public byte[] queryDataForCompressedResult(String queryString, String members, int limit) + byte[] queryDataForCompressedResult(String queryString, String members, int limit) throws Exception; @@ -583,31 +585,33 @@ public interface DistributedSystemMXBean { * Returns the number of committed transactions across all members. It gives point in time value * i.e. Number of tx committed at the time of reading this value */ - public int getTransactionCommitted(); + int getTransactionCommitted(); /** * Returns the number of transactions that were rolled back across all members. It gives point in * time value i.e. Number of tx rolled back at the time of reading this value */ - public int getTransactionRolledBack(); + int getTransactionRolledBack(); /** * Number of rows DistributedSystemMXBean.queryData() operation will return. By default it will be * 1000. User can modify this to control number of rows to be shown on Pulse, as Pulse DataBrowser * internally uses DistributedSystemMXBean.queryData() */ - public int getQueryResultSetLimit(); + int getQueryResultSetLimit(); - @ResourceOperation(resource = Resource.DATA, operation = Operation.MANAGE) - public void setQueryResultSetLimit(int queryResultSetLimit); + @ResourceOperation(resource = Resource.CLUSTER, operation = Operation.MANAGE, + target = Target.QUERY) + void setQueryResultSetLimit(int queryResultSetLimit); /** * Number of elements in a collection to be shown in queryData operation if query results contain * collections like Map, List etc. * */ - public int getQueryCollectionsDepth(); + int getQueryCollectionsDepth(); - @ResourceOperation(resource = Resource.DATA, operation = Operation.MANAGE) - public void setQueryCollectionsDepth(int queryCollectionsDepth); + @ResourceOperation(resource = Resource.CLUSTER, operation = Operation.MANAGE, + target = Target.QUERY) + void setQueryCollectionsDepth(int queryCollectionsDepth); } http://git-wip-us.apache.org/repos/asf/geode/blob/451d12e8/geode-core/src/main/java/org/apache/geode/management/GatewayReceiverMXBean.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/management/GatewayReceiverMXBean.java b/geode-core/src/main/java/org/apache/geode/management/GatewayReceiverMXBean.java index 749a743..556bd6f 100644 --- a/geode-core/src/main/java/org/apache/geode/management/GatewayReceiverMXBean.java +++ b/geode-core/src/main/java/org/apache/geode/management/GatewayReceiverMXBean.java @@ -18,6 +18,7 @@ import org.apache.geode.cache.wan.GatewayReceiver; import org.apache.geode.management.internal.security.ResourceOperation; import org.apache.geode.security.ResourcePermission.Operation; import org.apache.geode.security.ResourcePermission.Resource; +import org.apache.geode.security.ResourcePermission.Target; /** * MBean that provides access to information and management functionality for a @@ -32,180 +33,182 @@ public interface GatewayReceiverMXBean { /** * Returns the port the receiver is listening on. */ - public int getPort(); + int getPort(); /** * Returns the configured buffer size of the socket connection. */ - public int getSocketBufferSize(); + int getSocketBufferSize(); /** * Returns the bind address on the host. */ - public String getBindAddress(); + String getBindAddress(); /** * Returns the maximum amount of time between client pings. */ - public int getMaximumTimeBetweenPings(); + int getMaximumTimeBetweenPings(); /** * Returns whether the receiver is in running state. * * @return True if the receiver is in a running state, false otherwise. */ - public boolean isRunning(); + boolean isRunning(); /** * Returns the instantaneous rate of events received. */ - public float getEventsReceivedRate(); + float getEventsReceivedRate(); /** * Returns the rate of create requests received. */ - public float getCreateRequestsRate(); + float getCreateRequestsRate(); /** * Returns the rate of update requests received. */ - public float getUpdateRequestsRate(); + float getUpdateRequestsRate(); /** * Returns the rate of destroy requests received. */ - public float getDestroyRequestsRate(); + float getDestroyRequestsRate(); /** * Returns the number of duplicate batches which have been received. */ - public int getDuplicateBatchesReceived(); + int getDuplicateBatchesReceived(); /** * Returns the number of batches which have been received out of order. */ - public int getOutoforderBatchesReceived(); + int getOutoforderBatchesReceived(); /** * Starts the gateway receiver. */ - @ResourceOperation(resource = Resource.DATA, operation = Operation.MANAGE) - public void start() throws Exception; + @ResourceOperation(resource = Resource.CLUSTER, operation = Operation.MANAGE, + target = Target.GATEWAY) + void start() throws Exception; /** * Stops the gateway receiver. */ - @ResourceOperation(resource = Resource.DATA, operation = Operation.MANAGE) - public void stop() throws Exception; + @ResourceOperation(resource = Resource.CLUSTER, operation = Operation.MANAGE, + target = Target.GATEWAY) + void stop() throws Exception; /** * Returns the configured start port. */ - public int getStartPort(); + int getStartPort(); /** * Returns the configured end port. */ - public int getEndPort(); + int getEndPort(); /** * Returns a list of names for the transport filters in use. */ - public String[] getGatewayTransportFilters(); + String[] getGatewayTransportFilters(); /** * 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 and acting as a gateway. */ - public int getNumGateways(); + int getNumGateways(); /** * 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 a list of the host and port information for gateway senders connected to this gateway * receiver. */ - public String[] getConnectedGatewaySenders(); + String[] getConnectedGatewaySenders(); /** * Returns the average batch processing time (in milliseconds). */ - public long getAverageBatchProcessingTime(); + long getAverageBatchProcessingTime(); } http://git-wip-us.apache.org/repos/asf/geode/blob/451d12e8/geode-core/src/main/java/org/apache/geode/management/GatewaySenderMXBean.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/management/GatewaySenderMXBean.java b/geode-core/src/main/java/org/apache/geode/management/GatewaySenderMXBean.java index 718a9be..f8cad87 100644 --- a/geode-core/src/main/java/org/apache/geode/management/GatewaySenderMXBean.java +++ b/geode-core/src/main/java/org/apache/geode/management/GatewaySenderMXBean.java @@ -18,6 +18,7 @@ import org.apache.geode.cache.wan.GatewaySender; import org.apache.geode.management.internal.security.ResourceOperation; import org.apache.geode.security.ResourcePermission.Operation; import org.apache.geode.security.ResourcePermission.Resource; +import org.apache.geode.security.ResourcePermission.Target; /** * MBean that provides access to information and management functionality for a @@ -32,51 +33,51 @@ public interface GatewaySenderMXBean { /** * Returns the ID of the GatewaySender. */ - public String getSenderId(); + String getSenderId(); /** * Returns the id of the remote <code>GatewayReceiver</code>'s DistributedSystem. */ - public int getRemoteDSId(); + int getRemoteDSId(); /** * Returns the configured buffer size of the socket connection between this GatewaySender and its * receiving <code>GatewayReceiver</code>. */ - public int getSocketBufferSize(); + int getSocketBufferSize(); /** * Returns the amount of time (in milliseconds) that a socket read between a sending GatewaySender * and its receiving <code>GatewayReceiver</code> is allowed to block. */ - public long getSocketReadTimeout(); + long getSocketReadTimeout(); /** * 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 by the GatewaySender. */ - public int getBatchSize(); + int getBatchSize(); /** * Returns the interval between transmissions by the GatewaySender. */ - public long getBatchTimeInterval(); + long getBatchTimeInterval(); /** * Returns whether batch conflation for the GatewaySender's queue is enabled * * @return True if batch conflation is enabled, false otherwise. */ - public boolean isBatchConflationEnabled(); + boolean isBatchConflationEnabled(); /** * Returns whether the GatewaySender is configured to be persistent or non-persistent. @@ -84,162 +85,167 @@ public interface GatewaySenderMXBean { * @return True if the sender is persistent, false otherwise. */ - public boolean isPersistenceEnabled(); + boolean isPersistenceEnabled(); /** * Returns the alert threshold for entries in a GatewaySender's queue.The default value is 0 * milliseconds in which case no alert will be logged if events are delayed in Queue. */ - public int getAlertThreshold(); + int getAlertThreshold(); /** * Returns a list of <code>GatewayEventFilter</code>s added to this GatewaySender. */ - public String[] getGatewayEventFilters(); + String[] getGatewayEventFilters(); /** * Returns a list of <code>GatewayTransportFilter</code>s added to this GatewaySender. */ - public String[] getGatewayTransportFilters(); + String[] getGatewayTransportFilters(); /** * Returns whether the GatewaySender is configured for manual start. * * @return True if the GatewaySender is configured for manual start, false otherwise. */ - public boolean isManualStart(); + boolean isManualStart(); /** * Returns whether or not this GatewaySender is running. * * @return True if the GatewaySender is running, false otherwise. */ - public boolean isRunning(); + boolean isRunning(); /** * Returns whether or not this GatewaySender is paused. * * @return True of the GatewaySender is paused, false otherwise. */ - public boolean isPaused(); + boolean isPaused(); /** * Returns the rate of events received per second by this Sender if it's a serial-wan. */ - public float getEventsReceivedRate(); + float getEventsReceivedRate(); /** * Returns the rate of events being queued. */ - public float getEventsQueuedRate(); + float getEventsQueuedRate(); /** * Returns the current size of the event queue. */ - public int getEventQueueSize(); + int getEventQueueSize(); /** * Returns the number of events received, but not added to the event queue, because the queue * already contains an event with the same key. */ - public int getTotalEventsConflated(); + int getTotalEventsConflated(); /** * Returns the average number of batches sent per second. */ - public float getBatchesDispatchedRate(); + float getBatchesDispatchedRate(); /** * Returns the average time taken to send a batch of events. */ - public long getAverageDistributionTimePerBatch(); + long getAverageDistributionTimePerBatch(); /** * Returns the total number of batches of events that were resent. */ - public int getTotalBatchesRedistributed(); + int getTotalBatchesRedistributed(); /** * Starts this GatewaySender. Once the GatewaySender is running its configuration cannot be * changed. * */ - @ResourceOperation(resource = Resource.DATA, operation = Operation.MANAGE) - public void start(); + @ResourceOperation(resource = Resource.CLUSTER, operation = Operation.MANAGE, + target = Target.GATEWAY) + void start(); /** * Stops this GatewaySender. */ - @ResourceOperation(resource = Resource.DATA, operation = Operation.MANAGE) - public void stop(); + @ResourceOperation(resource = Resource.CLUSTER, operation = Operation.MANAGE, + target = Target.GATEWAY) + void stop(); /** * Pauses this GatewaySender. */ - @ResourceOperation(resource = Resource.DATA, operation = Operation.MANAGE) - public void pause(); + @ResourceOperation(resource = Resource.CLUSTER, operation = Operation.MANAGE, + target = Target.GATEWAY) + void pause(); /** * Resumes this paused GatewaySender. */ - @ResourceOperation(resource = Resource.DATA, operation = Operation.MANAGE) - public void resume(); + @ResourceOperation(resource = Resource.CLUSTER, operation = Operation.MANAGE, + target = Target.GATEWAY) + void resume(); /** * Rebalances this GatewaySender. */ - @ResourceOperation(resource = Resource.DATA, operation = Operation.MANAGE) - public void rebalance(); + @ResourceOperation(resource = Resource.CLUSTER, operation = Operation.MANAGE, + target = Target.GATEWAY) + void rebalance(); /** * Returns whether this GatewaySender is primary or secondary. * * @return True if this is the primary, false otherwise. */ - public boolean isPrimary(); + boolean isPrimary(); /** * Returns the number of dispatcher threads working for this <code>GatewaySender</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 GatewaySender. * * @return True if the property is set, false otherwise. */ - public boolean isDiskSynchronous(); + boolean isDiskSynchronous(); /** * Returns whether the isParallel property is set for this GatewaySender. * * @return True if the property is set, false otherwise. */ - public boolean isParallel(); + boolean isParallel(); /** * Returns the host and port information of GatewayReceiver to which this gateway sender is * connected. */ - public String getGatewayReceiver(); + String getGatewayReceiver(); /** * Returns whether this GatewaySender is connected and sending data to a GatewayReceiver. */ - public boolean isConnected(); + boolean isConnected(); /** * Returns number of events which have exceeded the configured alert threshold. */ - public int getEventsExceedingAlertThreshold(); + int getEventsExceedingAlertThreshold(); http://git-wip-us.apache.org/repos/asf/geode/blob/451d12e8/geode-core/src/main/java/org/apache/geode/management/LockServiceMXBean.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/management/LockServiceMXBean.java b/geode-core/src/main/java/org/apache/geode/management/LockServiceMXBean.java index f109022..a62ca49 100644 --- a/geode-core/src/main/java/org/apache/geode/management/LockServiceMXBean.java +++ b/geode-core/src/main/java/org/apache/geode/management/LockServiceMXBean.java @@ -35,53 +35,53 @@ public interface LockServiceMXBean { /** * Returns the name of the lock service. */ - public String getName(); + String getName(); /** * Returns whether this is a distributed LockService. * * @return True is this is a distributed LockService, false otherwise. */ - public boolean isDistributed(); + boolean isDistributed(); /** * 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 whether this member is the granter. * * @return True if this member is the granter, false otherwise. */ - public boolean isLockGrantor(); + boolean isLockGrantor(); /** * Requests that this member become the granter. */ - @ResourceOperation(resource = Resource.DATA, operation = Operation.MANAGE) - public void becomeLockGrantor(); + @ResourceOperation(resource = Resource.CLUSTER, operation = Operation.MANAGE) + void becomeLockGrantor(); /** * 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/451d12e8/geode-core/src/main/java/org/apache/geode/management/MemberMXBean.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/management/MemberMXBean.java b/geode-core/src/main/java/org/apache/geode/management/MemberMXBean.java index e2de400..ca7c2a2 100644 --- a/geode-core/src/main/java/org/apache/geode/management/MemberMXBean.java +++ b/geode-core/src/main/java/org/apache/geode/management/MemberMXBean.java @@ -20,6 +20,7 @@ import org.apache.geode.distributed.DistributedMember; import org.apache.geode.management.internal.security.ResourceOperation; import org.apache.geode.security.ResourcePermission.Operation; import org.apache.geode.security.ResourcePermission.Resource; +import org.apache.geode.security.ResourcePermission.Target; /** * MBean that provides access to information and management functionality for a @@ -143,7 +144,7 @@ public interface MemberMXBean { * * @param numberOfLines Number of lines to return, up to a maximum of 100. */ - public String showLog(int numberOfLines); + String showLog(int numberOfLines); /** * Returns the license string for this member. @@ -151,15 +152,16 @@ public interface MemberMXBean { * @deprecated Removed licensing in 8.0. */ @Deprecated - public String viewLicense(); + String viewLicense(); /** * Performs compaction on all of the member's disk stores. * * @return A list of names of the disk stores that were compacted. */ - @ResourceOperation(resource = Resource.DATA, operation = Operation.MANAGE) - public String[] compactAllDiskStores(); + @ResourceOperation(resource = Resource.CLUSTER, operation = Operation.MANAGE, + target = Target.DISK) + String[] compactAllDiskStores(); /** * Creates a Manager MBean on this member. @@ -167,24 +169,24 @@ public interface MemberMXBean { * @return True if the Manager MBean was successfully created, false otherwise. */ @ResourceOperation(resource = Resource.CLUSTER, operation = Operation.MANAGE) - public boolean createManager(); + boolean createManager(); /** * Shuts down the member. This is an asynchronous call and it will return immediately without * waiting for a result. */ @ResourceOperation(resource = Resource.CLUSTER, operation = Operation.MANAGE) - public void shutDownMember(); + void shutDownMember(); /** * Returns JVM metrics. */ - public JVMMetrics showJVMMetrics(); + JVMMetrics showJVMMetrics(); /** * Returns operating system metrics. */ - public OSMetrics showOSMetrics(); + OSMetrics showOSMetrics(); /** * Executes a command on the member. @@ -222,89 +224,89 @@ public interface MemberMXBean { * * @param includeRegionOwned Whether to include disk stores owned by a region. */ - public String[] listDiskStores(boolean includeRegionOwned); + String[] listDiskStores(boolean includeRegionOwned); /** * Returns the GemFire specific properties for this member. */ - public GemFireProperties listGemFireProperties(); + GemFireProperties listGemFireProperties(); /** * Returns the name or IP address of the host on which this member is running. */ - public String getHost(); + String getHost(); /** * Returns the name of this member. */ - public String getName(); + String getName(); /** * Returns the ID of this member. */ - public String getId(); + String getId(); /** * Returns the name of the member if it's been set, otherwise the ID. */ - public String getMember(); + String getMember(); /** * Returns the names of the groups this member belongs to. */ - public String[] getGroups(); + String[] getGroups(); /** * Returns the operating system process ID. */ - public int getProcessId(); + int getProcessId(); /** * Returns the status. */ - public String status(); + String status(); /** * Returns the GemFire version. */ - public String getVersion(); + String getVersion(); /** * Returns whether this member is attached to at least one Locator. * * @return True if this member is attached to a Locator, false otherwise. */ - public boolean isLocator(); + boolean isLocator(); /** * Returns the number of seconds that this member will wait for a distributed lock. */ - public long getLockTimeout(); + long getLockTimeout(); /** * Returns the number of second that this member will lease a distributed lock. */ - public long getLockLease(); + long getLockLease(); /** * Any long-running GemFire process that was started with "start server" command from GFSH. It * returns true even if that process has --disable-default-server=true. */ - public boolean isServer(); + boolean isServer(); /** * Returns whether this member has at least one GatewaySender. * - * @return True if this member has at least one GatwaySender, false otherwise. + * @return True if this member has at least one GatewaySender, false otherwise. */ - public boolean hasGatewaySender(); + boolean hasGatewaySender(); /** * Returns whether this member is running the Manager service. * * @return True if this member is running the Manager service, false otherwise. */ - public boolean isManager(); + boolean isManager(); /** * Returns whether this member has created the Manager service (it may be created, but not @@ -312,29 +314,29 @@ public interface MemberMXBean { * * @return True if this member has created the Manager service, false otherwise. */ - public boolean isManagerCreated(); + boolean isManagerCreated(); /** * Returns whether this member has at least one GatewayReceiver. * - * @return True if this member has at least one GatwayReceiver, false otherwise. + * @return True if this member has at least one GatewayReceiver, false otherwise. */ - public boolean hasGatewayReceiver(); + boolean hasGatewayReceiver(); /** * Returns the ClassPath. */ - public String getClassPath(); + String getClassPath(); /** * Returns the current time on the member's host. */ - public long getCurrentTime(); + long getCurrentTime(); /** * Returns the number of seconds that this member has been running. */ - public long getMemberUpTime(); + long getMemberUpTime(); /** * Returns the time (as a percentage) that this member's process time with respect to Statistics @@ -345,393 +347,402 @@ public interface MemberMXBean { * the platform it will be shown as -1 * */ - public float getCpuUsage(); + float getCpuUsage(); /** * Returns the current size of the heap in megabytes. * * @deprecated Please use {@link #getUsedMemory()} instead. */ - public long getCurrentHeapSize(); + long getCurrentHeapSize(); /** * Returns the maximum size of the heap in megabytes. * * @deprecated Please use {@link #getMaxMemory()} instead. */ - public long getMaximumHeapSize(); + long getMaximumHeapSize(); /** * Returns the free heap size in megabytes. * * @deprecated Please use {@link #getFreeMemory()} instead. */ - public long getFreeHeapSize(); + long getFreeHeapSize(); /** * Returns the maximum size of the heap in megabytes. * */ - public long getMaxMemory(); + long getMaxMemory(); /** * Returns the free heap size in megabytes. */ - public long getFreeMemory(); + long getFreeMemory(); /** * Returns the current size of the heap in megabytes. */ - public long getUsedMemory(); + long getUsedMemory(); /** * Returns the current threads. */ - public String[] fetchJvmThreads(); + String[] fetchJvmThreads(); /** * Returns the maximum number of open file descriptors allowed for the member's host operating * system. */ - public long getFileDescriptorLimit(); + long getFileDescriptorLimit(); /** * Returns the current number of open file descriptors. */ - public long getTotalFileDescriptorOpen(); + long getTotalFileDescriptorOpen(); /** * Returns the number of Regions present in the Cache. */ - public int getTotalRegionCount(); + int getTotalRegionCount(); /** * Returns the number of Partition Regions present in the Cache. */ - public int getPartitionRegionCount(); + int getPartitionRegionCount(); /** * Returns a list of all Region names. */ - public String[] listRegions(); + String[] listRegions(); /** * Returns a list of all disk stores, including those owned by a Region. */ - public String[] getDiskStores(); + String[] getDiskStores(); /** * Returns a list of all root Region names. */ - public String[] getRootRegionNames(); + String[] getRootRegionNames(); /** * Returns the total number of entries in all regions. */ - public int getTotalRegionEntryCount(); + int getTotalRegionEntryCount(); /** * Returns the total number of buckets. */ - public int getTotalBucketCount(); + int getTotalBucketCount(); /** * Returns the number of buckets for which this member is the primary holder. */ - public int getTotalPrimaryBucketCount(); + int getTotalPrimaryBucketCount(); /** * Returns the cache get average latency. */ - public long getGetsAvgLatency(); + long getGetsAvgLatency(); /** * Returns the cache put average latency. */ - public long getPutsAvgLatency(); + long getPutsAvgLatency(); /** * Returns the cache putAll average latency. */ - public long getPutAllAvgLatency(); + long getPutAllAvgLatency(); /** * Returns the number of times that a cache miss occurred for all regions. */ - public int getTotalMissCount(); + int getTotalMissCount(); /** * Returns the number of times that a hit occurred for all regions. */ - public int getTotalHitCount(); + int getTotalHitCount(); /** * Returns the number of gets per second. */ - public float getGetsRate(); + float getGetsRate(); /** * Returns the number of puts per second. Only includes puts done explicitly on this member's * cache, not those pushed from another member. */ - public float getPutsRate(); + float getPutsRate(); /** * Returns the number of putAlls per second. */ - public float getPutAllRate(); + float getPutAllRate(); /** * Returns the number of creates per second. */ - public float getCreatesRate(); + float getCreatesRate(); /** * Returns the number of destroys per second. */ - public float getDestroysRate(); + float getDestroysRate(); /** * Returns the average latency of a call to a CacheWriter. */ - public long getCacheWriterCallsAvgLatency(); + long getCacheWriterCallsAvgLatency(); /** * Returns the average latency of a call to a CacheListener. */ - public long getCacheListenerCallsAvgLatency(); + long getCacheListenerCallsAvgLatency(); /** * Returns the total number of times that a load on this cache has completed, as a result of * either a local get or a remote net load. */ - public int getTotalLoadsCompleted(); + int getTotalLoadsCompleted(); /** * Returns the average latency of a load. */ - public long getLoadsAverageLatency(); + long getLoadsAverageLatency(); /** * Returns the total number of times the a network load initiated by this cache has completed. */ - public int getTotalNetLoadsCompleted(); + int getTotalNetLoadsCompleted(); /** * Returns the net load average latency. */ - public long getNetLoadsAverageLatency(); + long getNetLoadsAverageLatency(); /** * Returns the total number of times that a network search initiated by this cache has completed. */ - public int getTotalNetSearchCompleted(); + int getTotalNetSearchCompleted(); /** * Returns the net search average latency. */ - public long getNetSearchAverageLatency(); + long getNetSearchAverageLatency(); /** * Returns the current number of disk tasks (op-log compaction, asynchronous recovery, etc.) that * are waiting for a thread to run. */ - public int getTotalDiskTasksWaiting(); + int getTotalDiskTasksWaiting(); /** * Returns the average number of bytes per second sent. */ - public float getBytesSentRate(); + float getBytesSentRate(); /** * Returns the average number of bytes per second received. */ - public float getBytesReceivedRate(); + float getBytesReceivedRate(); /** * Returns a list of IDs for all connected gateway receivers. */ - public String[] listConnectedGatewayReceivers(); + String[] listConnectedGatewayReceivers(); /** * Returns a list of IDs for all gateway senders. */ - public String[] listConnectedGatewaySenders(); + String[] listConnectedGatewaySenders(); /** * Returns the number of currently executing functions. */ - public int getNumRunningFunctions(); + int getNumRunningFunctions(); /** * Returns the average function execution rate. */ - public float getFunctionExecutionRate(); + float getFunctionExecutionRate(); /** - * Returns the number of currently executing functions that will return resutls. + * Returns the number of currently executing functions that will return results. */ - public int getNumRunningFunctionsHavingResults(); + int getNumRunningFunctionsHavingResults(); /** * Returns the number of current transactions. */ - public int getTotalTransactionsCount(); + int getTotalTransactionsCount(); /** * Returns the average commit latency in nanoseconds . */ - public long getTransactionCommitsAvgLatency(); + long getTransactionCommitsAvgLatency(); /** * Returns the number of committed transactions. */ - public int getTransactionCommittedTotalCount(); + int getTransactionCommittedTotalCount(); /** * Returns the number of transactions that were rolled back. */ - public int getTransactionRolledBackTotalCount(); + int getTransactionRolledBackTotalCount(); /** * Returns the average number of transactions committed per second. */ - public float getTransactionCommitsRate(); + float getTransactionCommitsRate(); /** * Returns the number of bytes reads per second from all the disks of the member. */ - public float getDiskReadsRate(); + float getDiskReadsRate(); /** * Returns the number of bytes written per second to disk to all the disks of the member. */ - public float getDiskWritesRate(); + float getDiskWritesRate(); /** * Returns the average disk flush latency time in nanoseconds. */ - public long getDiskFlushAvgLatency(); + long getDiskFlushAvgLatency(); /** * Returns the number of backups currently in progress for all disk stores. */ - public int getTotalBackupInProgress(); + int getTotalBackupInProgress(); /** * Returns the number of backups that have been completed. */ - public int getTotalBackupCompleted(); + int getTotalBackupCompleted(); /** * Returns the number of threads waiting for a lock. */ - public int getLockWaitsInProgress(); + int getLockWaitsInProgress(); /** * Returns the amount of time (in milliseconds) spent waiting for a lock. */ - public long getTotalLockWaitTime(); + long getTotalLockWaitTime(); /** * Returns the number of lock services in use. */ - public int getTotalNumberOfLockService(); + int getTotalNumberOfLockService(); /** * Returns the number of locks for which this member is a granter. */ - public int getTotalNumberOfGrantors(); + int getTotalNumberOfGrantors(); /** * Returns the number of lock request queues in use by this member. */ - public int getLockRequestQueues(); + int getLockRequestQueues(); /** * 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 initial images in progress. + * + * @deprecated as typo in name has been corrected: use + * {@link MemberMXBean#getInitialImagesInProgress} instead. + */ + @Deprecated + int getInitialImagesInProgres(); /** * Returns the number of initial images in progress. */ - public int getInitialImagesInProgres(); + int getInitialImagesInProgress(); /** * Returns the total amount of time spent performing a "get initial image" operation when creating * a region. */ - public long getInitialImageTime(); + long getInitialImageTime(); /** * Return the number of keys received while performing a "get initial image" operation when * creating a region. */ - public int getInitialImageKeysReceived(); + int getInitialImageKeysReceived(); /** * Returns the average time (in nanoseconds) spent deserializing objects. Includes * deserializations that result in a PdxInstance. */ - public long getDeserializationAvgLatency(); + long getDeserializationAvgLatency(); /** * Returns the average latency (in nanoseconds) spent deserializing objects. Includes * deserializations that result in a PdxInstance. */ - public long getDeserializationLatency(); + long getDeserializationLatency(); /** * Returns the instantaneous rate of deserializing objects. Includes deserializations that result * in a PdxInstance. */ - public float getDeserializationRate(); + float getDeserializationRate(); /** * Returns the average time (in nanoseconds) spent serializing objects. Includes serializations * that result in a PdxInstance. */ - public long getSerializationAvgLatency(); + long getSerializationAvgLatency(); /** * Returns the average latency (in nanoseconds) spent serializing objects. Includes serializations * that result in a PdxInstance. */ - public long getSerializationLatency(); + long getSerializationLatency(); /** * Returns the instantaneous rate of serializing objects. Includes serializations that result in a * PdxInstance. */ - public float getSerializationRate(); + float getSerializationRate(); /** * Returns the instantaneous rate of PDX instance deserialization. */ - public float getPDXDeserializationRate(); + float getPDXDeserializationRate(); /** * Returns the average time, in seconds, spent deserializing PDX instanced. */ - public long getPDXDeserializationAvgLatency(); + long getPDXDeserializationAvgLatency(); /** * Returns the total number of bytes used on all disks. */ - public long getTotalDiskUsage(); + long getTotalDiskUsage(); /** * Returns the number of threads in use. */ - public int getNumThreads(); + int getNumThreads(); /** * Returns the system load average for the last minute. The system load average is the sum of the @@ -742,99 +753,99 @@ public interface MemberMXBean { * * @return The load average or a negative value if one is not available. */ - public double getLoadAverage(); + double getLoadAverage(); /** * Returns the number of times garbage collection has occurred. */ - public long getGarbageCollectionCount(); + long getGarbageCollectionCount(); /** * Returns the amount of time (in milliseconds) spent on garbage collection. */ - public long getGarbageCollectionTime(); + long getGarbageCollectionTime(); /** * Returns the average number of reads per second. */ - public float getAverageReads(); + float getAverageReads(); /** * Returns the average writes per second, including both put and putAll operations. */ - public float getAverageWrites(); + float getAverageWrites(); /** * Returns the number JVM pauses (which may or may not include full garbage collection pauses) * detected by GemFire. */ - public long getJVMPauses(); + long getJVMPauses(); /** * Returns the underlying host's current cpuActive percentage */ - public int getHostCpuUsage(); + int getHostCpuUsage(); /** * * Returns true if a cache server is running on this member and able server requests from GemFire * clients */ - public boolean isCacheServer(); + boolean isCacheServer(); /** * Returns the redundancy-zone of the member; */ - public String getRedundancyZone(); + String getRedundancyZone(); /** * Returns current number of cache rebalance operations being directed by this process. */ - public int getRebalancesInProgress(); + int getRebalancesInProgress(); /** * Returns current number of threads waiting for a reply. */ - public int getReplyWaitsInProgress(); + int getReplyWaitsInProgress(); /** * Returns total number of times waits for a reply have completed. */ - public int getReplyWaitsCompleted(); + int getReplyWaitsCompleted(); /** * The current number of nodes in this distributed system visible to this member. */ - public int getVisibleNodes(); + int getVisibleNodes(); /** * Returns the number of off heap objects. */ - public int getOffHeapObjects(); + int getOffHeapObjects(); /** * Returns the size of the maximum configured off-heap memory in bytes. */ - public long getOffHeapMaxMemory(); + long getOffHeapMaxMemory(); /** * Returns the size of available (or unallocated) off-heap memory in bytes. */ - public long getOffHeapFreeMemory(); + long getOffHeapFreeMemory(); /** * Returns the size of utilized off-heap memory in bytes. */ - public long getOffHeapUsedMemory(); + long getOffHeapUsedMemory(); /** * Returns the percentage of off-heap memory fragmentation. */ - public int getOffHeapFragmentation(); + int getOffHeapFragmentation(); /** - * Returns the total time spent compacting in millseconds. + * Returns the total time spent compacting in milliseconds. */ - public long getOffHeapCompactionTime(); + long getOffHeapCompactionTime(); }
