提交 c66dc0fd 编写于 作者: M mchung

6610094: Add generic support for platform MXBeans of any type (also fixed 6681031)

Summary: Add new methods in ManagementFactory class to obtain platform MXBeans
Reviewed-by: alanb, dfuchs, emcmanus
上级 c1e29c84
...@@ -25,6 +25,8 @@ ...@@ -25,6 +25,8 @@
package com.sun.management; package com.sun.management;
import java.lang.management.PlatformManagedObject;
/** /**
* Diagnostic management interface for the HotSpot Virtual Machine. * Diagnostic management interface for the HotSpot Virtual Machine.
* The diagnostic MBean is registered to the platform MBeanServer * The diagnostic MBean is registered to the platform MBeanServer
...@@ -35,8 +37,13 @@ package com.sun.management; ...@@ -35,8 +37,13 @@ package com.sun.management;
* <blockquote> * <blockquote>
* <tt>com.sun.management:type=HotSpotDiagnostic</tt> * <tt>com.sun.management:type=HotSpotDiagnostic</tt>
* </blockquote> * </blockquote>
.*
* It can be obtained by calling the
* {@link PlatformManagedObject#getObjectName} method.
*
* @see ManagementFactory#getPlatformMXBeans(Class)
*/ */
public interface HotSpotDiagnosticMXBean { public interface HotSpotDiagnosticMXBean extends PlatformManagedObject {
/** /**
* Dumps the heap to the <tt>outputFile</tt> file in the same * Dumps the heap to the <tt>outputFile</tt> file in the same
* format as the hprof heap dump. * format as the hprof heap dump.
......
...@@ -35,7 +35,7 @@ package java.lang.management; ...@@ -35,7 +35,7 @@ package java.lang.management;
* that can be obtained by calling * that can be obtained by calling
* the {@link ManagementFactory#getClassLoadingMXBean} method or * the {@link ManagementFactory#getClassLoadingMXBean} method or
* from the {@link ManagementFactory#getPlatformMBeanServer * from the {@link ManagementFactory#getPlatformMBeanServer
* platform <tt>MBeanServer</tt>} method. * platform <tt>MBeanServer</tt>}.
* *
* <p>The <tt>ObjectName</tt> for uniquely identifying the MXBean for * <p>The <tt>ObjectName</tt> for uniquely identifying the MXBean for
* the class loading system within an <tt>MBeanServer</tt> is: * the class loading system within an <tt>MBeanServer</tt> is:
...@@ -44,6 +44,10 @@ package java.lang.management; ...@@ -44,6 +44,10 @@ package java.lang.management;
* <tt>java.lang:type=ClassLoading</tt>} * <tt>java.lang:type=ClassLoading</tt>}
* </blockquote> * </blockquote>
* *
* It can be obtained by calling the
* {@link PlatformManagedObject#getObjectName} method.
*
* @see ManagementFactory#getPlatformMXBeans(Class)
* @see <a href="../../../javax/management/package-summary.html"> * @see <a href="../../../javax/management/package-summary.html">
* JMX Specification.</a> * JMX Specification.</a>
* @see <a href="package-summary.html#examples"> * @see <a href="package-summary.html#examples">
...@@ -52,7 +56,7 @@ package java.lang.management; ...@@ -52,7 +56,7 @@ package java.lang.management;
* @author Mandy Chung * @author Mandy Chung
* @since 1.5 * @since 1.5
*/ */
public interface ClassLoadingMXBean { public interface ClassLoadingMXBean extends PlatformManagedObject {
/** /**
* Returns the total number of classes that have been loaded since * Returns the total number of classes that have been loaded since
......
...@@ -44,6 +44,10 @@ package java.lang.management; ...@@ -44,6 +44,10 @@ package java.lang.management;
* <tt>java.lang:type=Compilation</tt>} * <tt>java.lang:type=Compilation</tt>}
* </blockquote> * </blockquote>
* *
* It can be obtained by calling the
* {@link PlatformManagedObject#getObjectName} method.
*
* @see ManagementFactory#getPlatformMXBeans(Class)
* @see <a href="../../../javax/management/package-summary.html"> * @see <a href="../../../javax/management/package-summary.html">
* JMX Specification.</a> * JMX Specification.</a>
* @see <a href="package-summary.html#examples"> * @see <a href="package-summary.html#examples">
...@@ -52,7 +56,7 @@ package java.lang.management; ...@@ -52,7 +56,7 @@ package java.lang.management;
* @author Mandy Chung * @author Mandy Chung
* @since 1.5 * @since 1.5
*/ */
public interface CompilationMXBean { public interface CompilationMXBean extends PlatformManagedObject {
/** /**
* Returns the name of the Just-in-time (JIT) compiler. * Returns the name of the Just-in-time (JIT) compiler.
* *
......
...@@ -48,9 +48,13 @@ package java.lang.management; ...@@ -48,9 +48,13 @@ package java.lang.management;
* <tt>java.lang:type=GarbageCollector</tt>}<tt>,name=</tt><i>collector's name</i> * <tt>java.lang:type=GarbageCollector</tt>}<tt>,name=</tt><i>collector's name</i>
* </blockquote> * </blockquote>
* *
* It can be obtained by calling the
* {@link PlatformManagedObject#getObjectName} method.
*
* A platform usually includes additional platform-dependent information * A platform usually includes additional platform-dependent information
* specific to a garbage collection algorithm for monitoring. * specific to a garbage collection algorithm for monitoring.
* *
* @see ManagementFactory#getPlatformMXBeans(Class)
* @see MemoryMXBean * @see MemoryMXBean
* *
* @see <a href="../../../javax/management/package-summary.html"> * @see <a href="../../../javax/management/package-summary.html">
......
...@@ -24,17 +24,31 @@ ...@@ -24,17 +24,31 @@
*/ */
package java.lang.management; package java.lang.management;
import javax.management.DynamicMBean;
import javax.management.MBeanServer; import javax.management.MBeanServer;
import javax.management.MBeanServerConnection; import javax.management.MBeanServerConnection;
import javax.management.MBeanServerFactory;
import javax.management.MBeanServerPermission; import javax.management.MBeanServerPermission;
import javax.management.NotificationEmitter;
import javax.management.ObjectInstance;
import javax.management.ObjectName; import javax.management.ObjectName;
import javax.management.InstanceAlreadyExistsException;
import javax.management.InstanceNotFoundException; import javax.management.InstanceNotFoundException;
import javax.management.MalformedObjectNameException; import javax.management.MalformedObjectNameException;
import javax.management.MBeanRegistrationException;
import javax.management.NotCompliantMBeanException;
import javax.management.StandardEmitterMBean;
import javax.management.StandardMBean;
import java.util.Collections;
import java.util.ArrayList;
import java.util.List; import java.util.List;
import java.security.AccessController; import java.security.AccessController;
import java.security.Permission; import java.security.Permission;
import java.security.PrivilegedAction; import java.security.PrivilegedAction;
import java.security.PrivilegedActionException;
import java.security.PrivilegedExceptionAction;
import javax.management.JMX; import javax.management.JMX;
import sun.management.ManagementFactoryHelper;
/** /**
* The <tt>ManagementFactory</tt> class is a factory class for getting * The <tt>ManagementFactory</tt> class is a factory class for getting
...@@ -49,13 +63,16 @@ import javax.management.JMX; ...@@ -49,13 +63,16 @@ import javax.management.JMX;
* <ul> * <ul>
* <li><i>Direct access to an MXBean interface</i> * <li><i>Direct access to an MXBean interface</i>
* <ol type="a"> * <ol type="a">
* <li>Get the MXBean instance through the static factory method * <li>Get the MXBean instance through the static factory method,
* or the {@link #getPlatformMXBeans(Class)} method
* and access the MXBean locally of the running * and access the MXBean locally of the running
* virtual machine. * virtual machine.
* </li> * </li>
* <li>Construct an MXBean proxy instance that forwards the * <li>Construct an MXBean proxy instance that forwards the
* method calls to a given {@link MBeanServer MBeanServer} by calling * method calls to a given {@link MBeanServer MBeanServer} by calling
* {@link #newPlatformMXBeanProxy newPlatfromMXBeanProxy}. * the {@link #newPlatformMXBeanProxy newPlatformMXBeanProxy} method
* or the {@link #getPlatformMXBeans(MBeanServerConnection, Class)}
* method.
* A proxy is typically constructed to remotely access * A proxy is typically constructed to remotely access
* an MXBean of another running virtual machine. * an MXBean of another running virtual machine.
* </li> * </li>
...@@ -83,6 +100,10 @@ import javax.management.JMX; ...@@ -83,6 +100,10 @@ import javax.management.JMX;
* a set of basic data types described below. * a set of basic data types described below.
* See <a href="../../../javax/management/MXBean.html#MXBean-spec"> * See <a href="../../../javax/management/MXBean.html#MXBean-spec">
* the specification of MXBeans</a> for details. * the specification of MXBeans</a> for details.
* All platform MXBean interfaces extend {@link PlatformManagedObject}s
* and new methods may be added in these interfaces
* in future Java SE releases.
* <p>
* A JMX management application and the platform <tt>MBeanServer</tt> * A JMX management application and the platform <tt>MBeanServer</tt>
* can interoperate without requiring classes for MXBean specific * can interoperate without requiring classes for MXBean specific
* data types. * data types.
...@@ -191,7 +212,10 @@ import javax.management.JMX; ...@@ -191,7 +212,10 @@ import javax.management.JMX;
* <h4><a name="MXBeanNames">MXBean Names</a></h4> * <h4><a name="MXBeanNames">MXBean Names</a></h4>
* Each platform MXBean for a Java virtual machine has a unique * Each platform MXBean for a Java virtual machine has a unique
* {@link javax.management.ObjectName ObjectName} for * {@link javax.management.ObjectName ObjectName} for
* registration in the platform <tt>MBeanServer</tt>. * registration in the platform <tt>MBeanServer</tt> that can
* be obtained by calling the {@link PlatformManagedObject#getObjectName}
* method.
*
* A Java virtual machine has a single instance of the following management * A Java virtual machine has a single instance of the following management
* interfaces: * interfaces:
* *
...@@ -275,7 +299,7 @@ import javax.management.JMX; ...@@ -275,7 +299,7 @@ import javax.management.JMX;
* </blockquote> * </blockquote>
* *
* @see <a href="../../../javax/management/package-summary.html"> * @see <a href="../../../javax/management/package-summary.html">
* JMX Specification.</a> * JMX Specification</a>
* @see <a href="package-summary.html#examples"> * @see <a href="package-summary.html#examples">
* Ways to Access Management Metrics</a> * Ways to Access Management Metrics</a>
* @see java.util.logging.LoggingMXBean * @see java.util.logging.LoggingMXBean
...@@ -368,7 +392,7 @@ public class ManagementFactory { ...@@ -368,7 +392,7 @@ public class ManagementFactory {
* the Java virtual machine. * the Java virtual machine.
*/ */
public static ClassLoadingMXBean getClassLoadingMXBean() { public static ClassLoadingMXBean getClassLoadingMXBean() {
return sun.management.ManagementFactory.getClassLoadingMXBean(); return ManagementFactoryHelper.getClassLoadingMXBean();
} }
/** /**
...@@ -378,7 +402,7 @@ public class ManagementFactory { ...@@ -378,7 +402,7 @@ public class ManagementFactory {
* @return a {@link MemoryMXBean} object for the Java virtual machine. * @return a {@link MemoryMXBean} object for the Java virtual machine.
*/ */
public static MemoryMXBean getMemoryMXBean() { public static MemoryMXBean getMemoryMXBean() {
return sun.management.ManagementFactory.getMemoryMXBean(); return ManagementFactoryHelper.getMemoryMXBean();
} }
/** /**
...@@ -388,7 +412,7 @@ public class ManagementFactory { ...@@ -388,7 +412,7 @@ public class ManagementFactory {
* @return a {@link ThreadMXBean} object for the Java virtual machine. * @return a {@link ThreadMXBean} object for the Java virtual machine.
*/ */
public static ThreadMXBean getThreadMXBean() { public static ThreadMXBean getThreadMXBean() {
return sun.management.ManagementFactory.getThreadMXBean(); return ManagementFactoryHelper.getThreadMXBean();
} }
/** /**
...@@ -399,7 +423,7 @@ public class ManagementFactory { ...@@ -399,7 +423,7 @@ public class ManagementFactory {
*/ */
public static RuntimeMXBean getRuntimeMXBean() { public static RuntimeMXBean getRuntimeMXBean() {
return sun.management.ManagementFactory.getRuntimeMXBean(); return ManagementFactoryHelper.getRuntimeMXBean();
} }
/** /**
...@@ -412,7 +436,7 @@ public class ManagementFactory { ...@@ -412,7 +436,7 @@ public class ManagementFactory {
* no compilation system. * no compilation system.
*/ */
public static CompilationMXBean getCompilationMXBean() { public static CompilationMXBean getCompilationMXBean() {
return sun.management.ManagementFactory.getCompilationMXBean(); return ManagementFactoryHelper.getCompilationMXBean();
} }
/** /**
...@@ -423,7 +447,7 @@ public class ManagementFactory { ...@@ -423,7 +447,7 @@ public class ManagementFactory {
* the Java virtual machine. * the Java virtual machine.
*/ */
public static OperatingSystemMXBean getOperatingSystemMXBean() { public static OperatingSystemMXBean getOperatingSystemMXBean() {
return sun.management.ManagementFactory.getOperatingSystemMXBean(); return ManagementFactoryHelper.getOperatingSystemMXBean();
} }
/** /**
...@@ -436,7 +460,7 @@ public class ManagementFactory { ...@@ -436,7 +460,7 @@ public class ManagementFactory {
* *
*/ */
public static List<MemoryPoolMXBean> getMemoryPoolMXBeans() { public static List<MemoryPoolMXBean> getMemoryPoolMXBeans() {
return sun.management.ManagementFactory.getMemoryPoolMXBeans(); return ManagementFactoryHelper.getMemoryPoolMXBeans();
} }
/** /**
...@@ -449,7 +473,7 @@ public class ManagementFactory { ...@@ -449,7 +473,7 @@ public class ManagementFactory {
* *
*/ */
public static List<MemoryManagerMXBean> getMemoryManagerMXBeans() { public static List<MemoryManagerMXBean> getMemoryManagerMXBeans() {
return sun.management.ManagementFactory.getMemoryManagerMXBeans(); return ManagementFactoryHelper.getMemoryManagerMXBeans();
} }
...@@ -465,7 +489,7 @@ public class ManagementFactory { ...@@ -465,7 +489,7 @@ public class ManagementFactory {
* *
*/ */
public static List<GarbageCollectorMXBean> getGarbageCollectorMXBeans() { public static List<GarbageCollectorMXBean> getGarbageCollectorMXBeans() {
return sun.management.ManagementFactory.getGarbageCollectorMXBeans(); return ManagementFactoryHelper.getGarbageCollectorMXBeans();
} }
private static MBeanServer platformMBeanServer; private static MBeanServer platformMBeanServer;
...@@ -518,8 +542,25 @@ public class ManagementFactory { ...@@ -518,8 +542,25 @@ public class ManagementFactory {
} }
if (platformMBeanServer == null) { if (platformMBeanServer == null) {
platformMBeanServer = platformMBeanServer = MBeanServerFactory.createMBeanServer();
sun.management.ManagementFactory.createPlatformMBeanServer(); for (PlatformComponent pc : PlatformComponent.values()) {
List<? extends PlatformManagedObject> list =
pc.getMXBeans(pc.getMXBeanInterface());
for (PlatformManagedObject o : list) {
// Each PlatformComponent represents one management
// interface. Some MXBean may extend another one.
// The MXBean instances for one platform component
// (returned by pc.getMXBeans()) might be also
// the MXBean instances for another platform component.
// e.g. com.sun.management.GarbageCollectorMXBean
//
// So need to check if an MXBean instance is registered
// before registering into the platform MBeanServer
if (!platformMBeanServer.isRegistered(o.getObjectName())) {
addMXBean(platformMBeanServer, o);
}
}
}
} }
return platformMBeanServer; return platformMBeanServer;
} }
...@@ -657,6 +698,136 @@ public class ManagementFactory { ...@@ -657,6 +698,136 @@ public class ManagementFactory {
} }
} }
/**
* Returns the list of platform MXBeans that implement
* the given {@code mxbeanInterface} in the running Java
* virtual machine.
* The returned list may contain zero, one, or more instances.
* The number of instances in the returned list is defined
* in the specification of the given management interface.
*
* @param mxbeanInterface a management interface for a platform
* MXBean
*
* @return the list of platform MXBeans that implements
* {@code mxbeanInterface}.
*
* @throws IllegalArgumentException if {@code mxbeanInterface}
* is not a management interface for the platform.
*
* @since 1.7
*/
public static <T extends PlatformManagedObject> List<T>
getPlatformMXBeans(Class<T> mxbeanInterface) {
String className = mxbeanInterface.getName();
for (PlatformComponent component: PlatformComponent.values()) {
// comparing the class name first instead of the Class instance
// to avoid causing unnecessary class loading of
// the other MXBean interfaces
if (className.equals(component.getMXBeanInterfaceName())) {
if (component.getMXBeanInterface() == mxbeanInterface) {
return component.getMXBeans(mxbeanInterface);
}
}
}
throw new IllegalArgumentException(mxbeanInterface.getName() +
" is not implemented by any of the platform MXBeans.");
}
/**
* Returns the list of the platform MXBean proxies for
* forwarding the method calls of the {@code mxbeanInterface}
* through the given {@code MBeanServerConnection}.
* The returned list may contain zero, one, or more instances.
* The number of instances in the returned list is defined
* in the specification of the given management interface.
*
* @param connection the {@code MBeanServerConnection} to forward to.
* @param mxbeanInterface a management interface for a platform
* MXBean
*
* @return the list of platform MXBean proxies for
* forwarding the method calls of the {@code mxbeanInterface}
* through the given {@code MBeanServerConnection}.
*
* @throws IllegalArgumentException if {@code mxbeanInterface}
* is not a management interface for the platform.
*
* @throws java.io.IOException if a communication problem
* occurred when accessing the {@code MBeanServerConnection}.
*
* @since 1.7
*/
public static <T extends PlatformManagedObject>
List<T> getPlatformMXBeans(MBeanServerConnection connection,
Class<T> mxbeanInterface)
throws java.io.IOException
{
String className = mxbeanInterface.getName();
for (PlatformComponent component: PlatformComponent.values()) {
// comparing the class name first instead of the Class instance
// to avoid causing unnecessary class loading of
// the other MXBean interfaces
if (className.equals(component.getMXBeanInterfaceName())) {
if (component.getMXBeanInterface() == mxbeanInterface) {
return component.getMXBeans(connection,
mxbeanInterface);
}
}
}
throw new IllegalArgumentException(mxbeanInterface.getName() +
" is not implemented by any of the platform MXBeans.");
}
/**
* Returns a list of {@code Class} objects, subinterface of
* {@link PlatformManagedObject}, representing
* all management interfaces for
* monitoring and managing the Java platform.
*
* @return a list of {@code Class} objects, subinterface of
* {@link PlatformManagedObject} representing
* the management interfaces for
* monitoring and managing the Java platform.
*
* @since 1.7
*/
public static List<Class<? extends PlatformManagedObject>> getAllPlatformMXBeanInterfaces() {
List<Class<? extends PlatformManagedObject>> result =
new ArrayList<Class<? extends PlatformManagedObject>>();
for (PlatformComponent component: PlatformComponent.values()) {
result.add(component.getMXBeanInterface());
}
return result;
}
private static final String NOTIF_EMITTER = private static final String NOTIF_EMITTER =
"javax.management.NotificationEmitter"; "javax.management.NotificationEmitter";
/**
* Registers an MXBean.
*/
private static void addMXBean(final MBeanServer mbs, final PlatformManagedObject pmo) {
// Make DynamicMBean out of MXBean by wrapping it with a StandardMBean
final DynamicMBean dmbean;
if (pmo instanceof NotificationEmitter) {
dmbean = new StandardEmitterMBean(pmo, null, true, (NotificationEmitter) pmo);
} else {
dmbean = new StandardMBean(pmo, null, true);
}
try {
AccessController.doPrivileged(new PrivilegedExceptionAction<Void>() {
public Void run() throws InstanceAlreadyExistsException,
MBeanRegistrationException,
NotCompliantMBeanException {
mbs.registerMBean(dmbean, pmo.getObjectName());
return null;
}
});
} catch (PrivilegedActionException e) {
throw new RuntimeException(e.getException());
}
}
} }
...@@ -46,6 +46,9 @@ import javax.management.openmbean.CompositeData; ...@@ -46,6 +46,9 @@ import javax.management.openmbean.CompositeData;
* <tt>java.lang:type=Memory</tt>} * <tt>java.lang:type=Memory</tt>}
* </blockquote> * </blockquote>
* *
* It can be obtained by calling the
* {@link PlatformManagedObject#getObjectName} method.
*
* <h4> Memory </h4> * <h4> Memory </h4>
* The memory system of the Java virtual machine manages * The memory system of the Java virtual machine manages
* the following kinds of memory: * the following kinds of memory:
...@@ -190,6 +193,7 @@ import javax.management.openmbean.CompositeData; ...@@ -190,6 +193,7 @@ import javax.management.openmbean.CompositeData;
* emitter.addNotificationListener(listener, null, null); * emitter.addNotificationListener(listener, null, null);
* </pre></blockquote> * </pre></blockquote>
* *
* @see ManagementFactory#getPlatformMXBeans(Class)
* @see <a href="../../../javax/management/package-summary.html"> * @see <a href="../../../javax/management/package-summary.html">
* JMX Specification.</a> * JMX Specification.</a>
* @see <a href="package-summary.html#examples"> * @see <a href="package-summary.html#examples">
...@@ -198,7 +202,7 @@ import javax.management.openmbean.CompositeData; ...@@ -198,7 +202,7 @@ import javax.management.openmbean.CompositeData;
* @author Mandy Chung * @author Mandy Chung
* @since 1.5 * @since 1.5
*/ */
public interface MemoryMXBean { public interface MemoryMXBean extends PlatformManagedObject {
/** /**
* Returns the approximate number of objects for which * Returns the approximate number of objects for which
* finalization is pending. * finalization is pending.
......
...@@ -45,6 +45,10 @@ package java.lang.management; ...@@ -45,6 +45,10 @@ package java.lang.management;
* <tt>java.lang:type=MemoryManager</tt>}<tt>,name=</tt><i>manager's name</i> * <tt>java.lang:type=MemoryManager</tt>}<tt>,name=</tt><i>manager's name</i>
* </blockquote> * </blockquote>
* *
* It can be obtained by calling the
* {@link PlatformManagedObject#getObjectName} method.
*
* @see ManagementFactory#getPlatformMXBeans(Class)
* @see MemoryMXBean * @see MemoryMXBean
* *
* @see <a href="../../../javax/management/package-summary.html"> * @see <a href="../../../javax/management/package-summary.html">
...@@ -55,7 +59,7 @@ package java.lang.management; ...@@ -55,7 +59,7 @@ package java.lang.management;
* @author Mandy Chung * @author Mandy Chung
* @since 1.5 * @since 1.5
*/ */
public interface MemoryManagerMXBean { public interface MemoryManagerMXBean extends PlatformManagedObject {
/** /**
* Returns the name representing this memory manager. * Returns the name representing this memory manager.
* *
......
...@@ -46,6 +46,9 @@ package java.lang.management; ...@@ -46,6 +46,9 @@ package java.lang.management;
* <tt>java.lang:type=MemoryPool</tt>}<tt>,name=</tt><i>pool's name</i> * <tt>java.lang:type=MemoryPool</tt>}<tt>,name=</tt><i>pool's name</i>
* </blockquote> * </blockquote>
* *
* It can be obtained by calling the
* {@link PlatformManagedObject#getObjectName} method.
*
* <h4>Memory Type</h4> * <h4>Memory Type</h4>
* <p>The Java virtual machine has a heap for object allocation and also * <p>The Java virtual machine has a heap for object allocation and also
* maintains non-heap memory for the method area and the Java virtual * maintains non-heap memory for the method area and the Java virtual
...@@ -349,6 +352,7 @@ package java.lang.management; ...@@ -349,6 +352,7 @@ package java.lang.management;
* described above for the <a href="#UsageThreshold">usage threshold</a> * described above for the <a href="#UsageThreshold">usage threshold</a>
* in a similar fashion. * in a similar fashion.
* *
* @see ManagementFactory#getPlatformMXBeans(Class)
* @see <a href="../../../javax/management/package-summary.html"> * @see <a href="../../../javax/management/package-summary.html">
* JMX Specification.</a> * JMX Specification.</a>
* @see <a href="package-summary.html#examples"> * @see <a href="package-summary.html#examples">
...@@ -357,7 +361,7 @@ package java.lang.management; ...@@ -357,7 +361,7 @@ package java.lang.management;
* @author Mandy Chung * @author Mandy Chung
* @since 1.5 * @since 1.5
*/ */
public interface MemoryPoolMXBean { public interface MemoryPoolMXBean extends PlatformManagedObject {
/** /**
* Returns the name representing this memory pool. * Returns the name representing this memory pool.
* *
......
...@@ -44,10 +44,14 @@ package java.lang.management; ...@@ -44,10 +44,14 @@ package java.lang.management;
* <tt>java.lang:type=OperatingSystem</tt>} * <tt>java.lang:type=OperatingSystem</tt>}
* </blockquote> * </blockquote>
* *
* It can be obtained by calling the
* {@link PlatformManagedObject#getObjectName} method.
*
* <p> This interface defines several convenient methods for accessing * <p> This interface defines several convenient methods for accessing
* system properties about the operating system on which the Java * system properties about the operating system on which the Java
* virtual machine is running. * virtual machine is running.
* *
* @see ManagementFactory#getPlatformMXBeans(Class)
* @see <a href="../../../javax/management/package-summary.html"> * @see <a href="../../../javax/management/package-summary.html">
* JMX Specification.</a> * JMX Specification.</a>
* @see <a href="package-summary.html#examples"> * @see <a href="package-summary.html#examples">
...@@ -56,7 +60,7 @@ package java.lang.management; ...@@ -56,7 +60,7 @@ package java.lang.management;
* @author Mandy Chung * @author Mandy Chung
* @since 1.5 * @since 1.5
*/ */
public interface OperatingSystemMXBean { public interface OperatingSystemMXBean extends PlatformManagedObject {
/** /**
* Returns the operating system name. * Returns the operating system name.
* This method is equivalent to <tt>System.getProperty("os.name")</tt>. * This method is equivalent to <tt>System.getProperty("os.name")</tt>.
......
/*
* Copyright 2008 Sun Microsystems, Inc. All Rights Reserved.
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
*
* This code is free software; you can redistribute it and/or modify it
* under the terms of the GNU General Public License version 2 only, as
* published by the Free Software Foundation. Sun designates this
* particular file as subject to the "Classpath" exception as provided
* by Sun in the LICENSE file that accompanied this code.
*
* This code is distributed in the hope that it will be useful, but WITHOUT
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
* version 2 for more details (a copy is included in the LICENSE file that
* accompanied this code).
*
* You should have received a copy of the GNU General Public License version
* 2 along with this work; if not, write to the Free Software Foundation,
* Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
*
* Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa Clara,
* CA 95054 USA or visit www.sun.com if you need additional information or
* have any questions.
*/
package java.lang.management;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.HashSet;
import java.util.Set;
import java.util.logging.LoggingMXBean;
import java.util.logging.LogManager;
import javax.management.MBeanServerConnection;
import javax.management.MalformedObjectNameException;
import javax.management.ObjectName;
import com.sun.management.HotSpotDiagnosticMXBean;
import com.sun.management.UnixOperatingSystemMXBean;
import sun.management.ManagementFactoryHelper;
/**
* This enum class defines the list of platform components
* that provides monitoring and management support.
* Each enum represents one MXBean interface. A MXBean
* instance could implement one or more MXBean interfaces.
*
* For example, com.sun.management.GarbageCollectorMXBean
* extends java.lang.management.GarbageCollectorMXBean
* and there is one set of garbage collection MXBean instances,
* each of which implements both c.s.m. and j.l.m. interfaces.
* There are two separate enums GARBAGE_COLLECTOR
* and SUN_GARBAGE_COLLECTOR so that ManagementFactory.getPlatformMXBeans(Class)
* will return the list of MXBeans of the specified type.
*
* To add a new MXBean interface for the Java platform,
* add a new enum constant and implement the MXBeanFetcher.
*/
enum PlatformComponent {
/**
* Class loading system of the Java virtual machine.
*/
CLASS_LOADING(
"java.lang.management.ClassLoadingMXBean",
"java.lang", "ClassLoading", defaultKeyProperties(),
new MXBeanFetcher<ClassLoadingMXBean>() {
public List<ClassLoadingMXBean> getMXBeans() {
return Collections.singletonList(ManagementFactoryHelper.getClassLoadingMXBean());
}
}),
/**
* Compilation system of the Java virtual machine.
*/
COMPILATION(
"java.lang.management.CompilationMXBean",
"java.lang", "Compilation", defaultKeyProperties(),
new MXBeanFetcher<CompilationMXBean>() {
public List<CompilationMXBean> getMXBeans() {
CompilationMXBean m = ManagementFactoryHelper.getCompilationMXBean();
if (m == null) {
return Collections.emptyList();
} else {
return Collections.singletonList(m);
}
}
}),
/**
* Memory system of the Java virtual machine.
*/
MEMORY(
"java.lang.management.MemoryMXBean",
"java.lang", "Memory", defaultKeyProperties(),
new MXBeanFetcher<MemoryMXBean>() {
public List<MemoryMXBean> getMXBeans() {
return Collections.singletonList(ManagementFactoryHelper.getMemoryMXBean());
}
}),
/**
* Garbage Collector in the Java virtual machine.
*/
GARBAGE_COLLECTOR(
"java.lang.management.GarbageCollectorMXBean",
"java.lang", "GarbageCollector", keyProperties("name"),
new MXBeanFetcher<GarbageCollectorMXBean>() {
public List<GarbageCollectorMXBean> getMXBeans() {
return ManagementFactoryHelper.
getGarbageCollectorMXBeans();
}
}),
/**
* Memory manager in the Java virtual machine.
*/
MEMORY_MANAGER(
"java.lang.management.MemoryManagerMXBean",
"java.lang", "MemoryManager", keyProperties("name"),
new MXBeanFetcher<MemoryManagerMXBean>() {
public List<MemoryManagerMXBean> getMXBeans() {
return ManagementFactoryHelper.getMemoryManagerMXBeans();
}
},
GARBAGE_COLLECTOR),
/**
* Memory pool in the Java virtual machine.
*/
MEMORY_POOL(
"java.lang.management.MemoryPoolMXBean",
"java.lang", "MemoryPool", keyProperties("name"),
new MXBeanFetcher<MemoryPoolMXBean>() {
public List<MemoryPoolMXBean> getMXBeans() {
return ManagementFactoryHelper.getMemoryPoolMXBeans();
}
}),
/**
* Operating system on which the Java virtual machine is running
*/
OPERATING_SYSTEM(
"java.lang.management.OperatingSystemMXBean",
"java.lang", "OperatingSystem", defaultKeyProperties(),
new MXBeanFetcher<OperatingSystemMXBean>() {
public List<OperatingSystemMXBean> getMXBeans() {
return Collections.singletonList(ManagementFactoryHelper.getOperatingSystemMXBean());
}
}),
/**
* Runtime system of the Java virtual machine.
*/
RUNTIME(
"java.lang.management.RuntimeMXBean",
"java.lang", "Runtime", defaultKeyProperties(),
new MXBeanFetcher<RuntimeMXBean>() {
public List<RuntimeMXBean> getMXBeans() {
return Collections.singletonList(ManagementFactoryHelper.getRuntimeMXBean());
}
}),
/**
* Threading system of the Java virtual machine.
*/
THREADING(
"java.lang.management.ThreadMXBean",
"java.lang", "Threading", defaultKeyProperties(),
new MXBeanFetcher<ThreadMXBean>() {
public List<ThreadMXBean> getMXBeans() {
return Collections.singletonList(ManagementFactoryHelper.getThreadMXBean());
}
}),
/**
* Logging facility.
*/
LOGGING(
"java.util.logging.LoggingMXBean",
"java.util.logging", "Logging", defaultKeyProperties(),
new MXBeanFetcher<LoggingMXBean>() {
public List<LoggingMXBean> getMXBeans() {
return Collections.singletonList(LogManager.getLoggingMXBean());
}
}),
// Sun Platform Extension
/**
* Sun extension garbage collector that performs collections in cycles.
*/
SUN_GARBAGE_COLLECTOR(
"com.sun.management.GarbageCollectorMXBean",
"java.lang", "GarbageCollector", keyProperties("name"),
new MXBeanFetcher<com.sun.management.GarbageCollectorMXBean>() {
public List<com.sun.management.GarbageCollectorMXBean> getMXBeans() {
return getGcMXBeanList(com.sun.management.GarbageCollectorMXBean.class);
}
}),
/**
* Sun extension operating system on which the Java virtual machine
* is running.
*/
SUN_OPERATING_SYSTEM(
"com.sun.management.OperatingSystemMXBean",
"java.lang", "OperatingSystem", defaultKeyProperties(),
new MXBeanFetcher<com.sun.management.OperatingSystemMXBean>() {
public List<com.sun.management.OperatingSystemMXBean> getMXBeans() {
return getOSMXBeanList(com.sun.management.OperatingSystemMXBean.class);
}
}),
/**
* Unix operating system.
*/
SUN_UNIX_OPERATING_SYSTEM(
"com.sun.management.UnixOperatingSystemMXBean",
"java.lang", "OperatingSystem", defaultKeyProperties(),
new MXBeanFetcher<UnixOperatingSystemMXBean>() {
public List<UnixOperatingSystemMXBean> getMXBeans() {
return getOSMXBeanList(com.sun.management.UnixOperatingSystemMXBean.class);
}
}),
/**
* Diagnostic support for the HotSpot Virtual Machine.
*/
HOTSPOT_DIAGNOSTIC(
"com.sun.management.HotSpotDiagnosticMXBean",
"com.sun.management", "HotSpotDiagnostic", defaultKeyProperties(),
new MXBeanFetcher<HotSpotDiagnosticMXBean>() {
public List<HotSpotDiagnosticMXBean> getMXBeans() {
return Collections.singletonList(ManagementFactoryHelper.getDiagnosticMXBean());
}
});
/**
* A task that returns the MXBeans for a component.
*/
interface MXBeanFetcher<T extends PlatformManagedObject> {
public List<T> getMXBeans();
}
/*
* Returns a list of the GC MXBeans of the given type.
*/
private static <T extends GarbageCollectorMXBean>
List<T> getGcMXBeanList(Class<T> gcMXBeanIntf) {
List<GarbageCollectorMXBean> list =
ManagementFactoryHelper.getGarbageCollectorMXBeans();
List<T> result = new ArrayList<T>(list.size());
for (GarbageCollectorMXBean m : list) {
if (gcMXBeanIntf.isInstance(m)) {
result.add(gcMXBeanIntf.cast(m));
}
}
return result;
}
/*
* Returns the OS mxbean instance of the given type.
*/
private static <T extends OperatingSystemMXBean>
List<T> getOSMXBeanList(Class<T> osMXBeanIntf) {
OperatingSystemMXBean m =
ManagementFactoryHelper.getOperatingSystemMXBean();
if (osMXBeanIntf.isInstance(m)) {
return Collections.singletonList(osMXBeanIntf.cast(m));
} else {
return Collections.emptyList();
}
}
private final String mxbeanInterfaceName;
private final String domain;
private final String type;
private final Set<String> keyProperties;
private final MXBeanFetcher fetcher;
private final PlatformComponent[] subComponents;
private PlatformComponent(String intfName,
String domain, String type,
Set<String> keyProperties,
MXBeanFetcher fetcher) {
this.mxbeanInterfaceName = intfName;
this.domain = domain;
this.type = type;
this.keyProperties = keyProperties;
this.fetcher = fetcher;
this.subComponents = new PlatformComponent[0];
}
private PlatformComponent(String intfName,
String domain, String type,
Set<String> keyProperties,
MXBeanFetcher fetcher,
PlatformComponent... subComponents) {
this.mxbeanInterfaceName = intfName;
this.domain = domain;
this.type = type;
this.keyProperties = keyProperties;
this.fetcher = fetcher;
this.subComponents = subComponents;
}
private static Set<String> defaultKeyProps;
private static Set<String> defaultKeyProperties() {
if (defaultKeyProps == null) {
defaultKeyProps = Collections.singleton("type");
}
return defaultKeyProps;
}
private static Set<String> keyProperties(String... keyNames) {
Set<String> set = new HashSet<String>();
set.add("type");
for (String s : keyNames) {
set.add(s);
}
return set;
}
String getMXBeanInterfaceName() {
return mxbeanInterfaceName;
}
@SuppressWarnings("unchecked")
Class<? extends PlatformManagedObject> getMXBeanInterface() {
try {
// Lazy loading the MXBean interface only when it is needed
return (Class<? extends PlatformManagedObject>)
Class.forName(mxbeanInterfaceName, false, null);
} catch (ClassNotFoundException x) {
throw new AssertionError(x);
}
}
@SuppressWarnings("unchecked")
<T extends PlatformManagedObject>
List<T> getMXBeans(Class<T> mxbeanInterface)
{
return fetcher.getMXBeans();
}
<T extends PlatformManagedObject>
List<T> getMXBeans(MBeanServerConnection mbs, Class<T> mxbeanInterface)
throws java.io.IOException
{
List<T> result = new ArrayList<T>();
for (ObjectName on : getObjectNames(mbs)) {
result.add(ManagementFactory.
newPlatformMXBeanProxy(mbs,
on.getCanonicalName(),
mxbeanInterface)
);
}
return result;
}
private Set<ObjectName> getObjectNames(MBeanServerConnection mbs)
throws java.io.IOException
{
String domainAndType = domain + ":type=" + type;
if (keyProperties.size() > 1) {
// if there are more than 1 key properties (i.e. other than "type")
domainAndType += ",*";
}
ObjectName on = com.sun.jmx.mbeanserver.Util.newObjectName(domainAndType);
Set<ObjectName> set = mbs.queryNames(on, null);
for (PlatformComponent pc : subComponents) {
set.addAll(pc.getObjectNames(mbs));
}
return set;
}
private static final long serialVersionUID = 6992337162326171013L;
}
/*
* Copyright 2008 Sun Microsystems, Inc. All Rights Reserved.
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
*
* This code is free software; you can redistribute it and/or modify it
* under the terms of the GNU General Public License version 2 only, as
* published by the Free Software Foundation. Sun designates this
* particular file as subject to the "Classpath" exception as provided
* by Sun in the LICENSE file that accompanied this code.
*
* This code is distributed in the hope that it will be useful, but WITHOUT
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
* version 2 for more details (a copy is included in the LICENSE file that
* accompanied this code).
*
* You should have received a copy of the GNU General Public License version
* 2 along with this work; if not, write to the Free Software Foundation,
* Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
*
* Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa Clara,
* CA 95054 USA or visit www.sun.com if you need additional information or
* have any questions.
*/
package java.lang.management;
import javax.management.ObjectName;
/**
* A platform managed object is a {@linkplain javax.management.MXBean JMX MXBean}
* for monitoring and managing a component in the Java platform.
* Each platform managed object has a unique
* <a href="ManagementFactory.html#MXBean">object name</a>
* for the {@linkplain ManagementFactory.getPlatformMBeanServer
* platform MBeanServer} access.
* All platform MXBeans will implement this interface.
*
* <p>
* Note:
* The platform MXBean interfaces (i.e. all subinterfaces
* of {@code PlatformManagedObject}) are implemented
* by the Java platform only. New methods may be added in these interfaces
* in future Java SE releases.
* In addition, this {@code PlatformManagedObject} interface is only
* intended for the management interfaces for the platform to extend but
* not for applications.
*
* @see <a href="ManagementFactory.html#MXBean">Platform MXBeans</a>
* @since 1.7
*/
public interface PlatformManagedObject {
/**
* Returns an {@link ObjectName ObjectName} instance representing
* the object name of this platform managed object.
*
* @return an {@link ObjectName ObjectName} instance representing
* the object name of this platform managed object.
*/
public ObjectName getObjectName();
}
...@@ -44,9 +44,13 @@ package java.lang.management; ...@@ -44,9 +44,13 @@ package java.lang.management;
* <tt>java.lang:type=Runtime</tt>} * <tt>java.lang:type=Runtime</tt>}
* </blockquote> * </blockquote>
* *
* It can be obtained by calling the
* {@link PlatformManagedObject#getObjectName} method.
*
* <p> This interface defines several convenient methods for accessing * <p> This interface defines several convenient methods for accessing
* system properties about the Java virtual machine. * system properties about the Java virtual machine.
* *
* @see ManagementFactory#getPlatformMXBeans(Class)
* @see <a href="../../../javax/management/package-summary.html"> * @see <a href="../../../javax/management/package-summary.html">
* JMX Specification.</a> * JMX Specification.</a>
* @see <a href="package-summary.html#examples"> * @see <a href="package-summary.html#examples">
...@@ -55,7 +59,7 @@ package java.lang.management; ...@@ -55,7 +59,7 @@ package java.lang.management;
* @author Mandy Chung * @author Mandy Chung
* @since 1.5 * @since 1.5
*/ */
public interface RuntimeMXBean { public interface RuntimeMXBean extends PlatformManagedObject {
/** /**
* Returns the name representing the running Java virtual machine. * Returns the name representing the running Java virtual machine.
* The returned name string can be any arbitrary string and * The returned name string can be any arbitrary string and
......
...@@ -26,6 +26,7 @@ ...@@ -26,6 +26,7 @@
package java.lang.management; package java.lang.management;
import javax.management.openmbean.CompositeData; import javax.management.openmbean.CompositeData;
import sun.management.ManagementFactoryHelper;
import sun.management.ThreadInfoCompositeData; import sun.management.ThreadInfoCompositeData;
import static java.lang.Thread.State.*; import static java.lang.Thread.State.*;
...@@ -220,12 +221,9 @@ public class ThreadInfo { ...@@ -220,12 +221,9 @@ public class ThreadInfo {
LockInfo[] lockedSynchronizers) { LockInfo[] lockedSynchronizers) {
this.threadId = t.getId(); this.threadId = t.getId();
this.threadName = t.getName(); this.threadName = t.getName();
this.threadState = this.threadState = ManagementFactoryHelper.toThreadState(state);
sun.management.ManagementFactory.toThreadState(state); this.suspended = ManagementFactoryHelper.isThreadSuspended(state);
this.suspended = this.inNative = ManagementFactoryHelper.isThreadRunningNative(state);
sun.management.ManagementFactory.isThreadSuspended(state);
this.inNative =
sun.management.ManagementFactory.isThreadRunningNative(state);
this.blockedCount = blockedCount; this.blockedCount = blockedCount;
this.blockedTime = blockedTime; this.blockedTime = blockedTime;
this.waitedCount = waitedCount; this.waitedCount = waitedCount;
......
...@@ -46,6 +46,9 @@ import java.util.Map; ...@@ -46,6 +46,9 @@ import java.util.Map;
* <tt>java.lang:type=Threading</tt>} * <tt>java.lang:type=Threading</tt>}
* </blockquote> * </blockquote>
* *
* It can be obtained by calling the
* {@link PlatformManagedObject#getObjectName} method.
*
* <h4>Thread ID</h4> * <h4>Thread ID</h4>
* Thread ID is a positive long value returned by calling the * Thread ID is a positive long value returned by calling the
* {@link java.lang.Thread#getId} method for a thread. * {@link java.lang.Thread#getId} method for a thread.
...@@ -108,6 +111,7 @@ import java.util.Map; ...@@ -108,6 +111,7 @@ import java.util.Map;
* {@link #findDeadlockedThreads} methods to find deadlocks in * {@link #findDeadlockedThreads} methods to find deadlocks in
* the running application. * the running application.
* *
* @see ManagementFactory#getPlatformMXBeans(Class)
* @see <a href="../../../javax/management/package-summary.html"> * @see <a href="../../../javax/management/package-summary.html">
* JMX Specification.</a> * JMX Specification.</a>
* @see <a href="package-summary.html#examples"> * @see <a href="package-summary.html#examples">
...@@ -117,7 +121,7 @@ import java.util.Map; ...@@ -117,7 +121,7 @@ import java.util.Map;
* @since 1.5 * @since 1.5
*/ */
public interface ThreadMXBean { public interface ThreadMXBean extends PlatformManagedObject {
/** /**
* Returns the current number of live threads including both * Returns the current number of live threads including both
* daemon and non-daemon threads. * daemon and non-daemon threads.
......
...@@ -29,6 +29,8 @@ import java.util.Enumeration; ...@@ -29,6 +29,8 @@ import java.util.Enumeration;
import java.util.List; import java.util.List;
import java.util.ArrayList; import java.util.ArrayList;
import javax.management.ObjectName;
/** /**
* Logging is the implementation class of LoggingMXBean. * Logging is the implementation class of LoggingMXBean.
* *
...@@ -115,4 +117,7 @@ class Logging implements LoggingMXBean { ...@@ -115,4 +117,7 @@ class Logging implements LoggingMXBean {
} }
} }
public ObjectName getObjectName() {
return com.sun.jmx.mbeanserver.Util.newObjectName(LogManager.LOGGING_MXBEAN_NAME);
}
} }
...@@ -25,6 +25,8 @@ ...@@ -25,6 +25,8 @@
package java.util.logging; package java.util.logging;
import java.lang.management.PlatformManagedObject;
/** /**
* The management interface for the logging facility. * The management interface for the logging facility.
* *
...@@ -43,14 +45,17 @@ package java.util.logging; ...@@ -43,14 +45,17 @@ package java.util.logging;
* <tt>java.util.logging:type=Logging</tt>} * <tt>java.util.logging:type=Logging</tt>}
* </blockquote> * </blockquote>
* *
* @see java.lang.management.ManagementFactory * It can be obtained by calling the
* {@link PlatformManagedObject#getObjectName} method.
*
* @see java.lang.management.ManagementFactory#getPlatformMXBeans(Class)
* *
* @author Ron Mann * @author Ron Mann
* @author Mandy Chung * @author Mandy Chung
* @since 1.5 * @since 1.5
* *
*/ */
public interface LoggingMXBean { public interface LoggingMXBean extends PlatformManagedObject {
/** /**
* Returns the list of currently registered loggers. This method * Returns the list of currently registered loggers. This method
......
...@@ -26,6 +26,8 @@ ...@@ -26,6 +26,8 @@
package sun.management; package sun.management;
import java.lang.management.ClassLoadingMXBean; import java.lang.management.ClassLoadingMXBean;
import java.lang.management.ManagementFactory;
import javax.management.ObjectName;
/** /**
* Implementation class for the class loading subsystem. * Implementation class for the class loading subsystem.
...@@ -62,9 +64,13 @@ class ClassLoadingImpl implements ClassLoadingMXBean { ...@@ -62,9 +64,13 @@ class ClassLoadingImpl implements ClassLoadingMXBean {
} }
public void setVerbose(boolean value) { public void setVerbose(boolean value) {
ManagementFactory.checkControlAccess(); Util.checkControlAccess();
setVerboseClass(value); setVerboseClass(value);
} }
native static void setVerboseClass(boolean value); native static void setVerboseClass(boolean value);
public ObjectName getObjectName() {
return Util.newObjectName(ManagementFactory.CLASS_LOADING_MXBEAN_NAME);
}
} }
...@@ -26,6 +26,8 @@ ...@@ -26,6 +26,8 @@
package sun.management; package sun.management;
import java.lang.management.CompilationMXBean; import java.lang.management.CompilationMXBean;
import java.lang.management.ManagementFactory;
import javax.management.ObjectName;
/** /**
* Implementation class for the compilation subsystem. * Implementation class for the compilation subsystem.
...@@ -46,7 +48,7 @@ class CompilationImpl implements CompilationMXBean { ...@@ -46,7 +48,7 @@ class CompilationImpl implements CompilationMXBean {
this.jvm = vm; this.jvm = vm;
this.name = jvm.getCompilerName(); this.name = jvm.getCompilerName();
if (name == null) { if (name == null) {
throw new InternalError("Null compiler name"); throw new AssertionError("Null compiler name");
} }
} }
...@@ -67,4 +69,9 @@ class CompilationImpl implements CompilationMXBean { ...@@ -67,4 +69,9 @@ class CompilationImpl implements CompilationMXBean {
return jvm.getTotalCompileTime(); return jvm.getTotalCompileTime();
} }
public ObjectName getObjectName() {
return Util.newObjectName(ManagementFactory.COMPILATION_MXBEAN_NAME);
}
} }
...@@ -34,6 +34,7 @@ import com.sun.management.GcInfo; ...@@ -34,6 +34,7 @@ import com.sun.management.GcInfo;
import javax.management.openmbean.CompositeData; import javax.management.openmbean.CompositeData;
import javax.management.MBeanInfo; import javax.management.MBeanInfo;
import javax.management.MBeanAttributeInfo; import javax.management.MBeanAttributeInfo;
import javax.management.ObjectName;
import java.util.List; import java.util.List;
import java.util.ListIterator; import java.util.ListIterator;
...@@ -88,4 +89,8 @@ class GarbageCollectorImpl extends MemoryManagerImpl ...@@ -88,4 +89,8 @@ class GarbageCollectorImpl extends MemoryManagerImpl
return info; return info;
} }
public ObjectName getObjectName() {
return Util.newObjectName(ManagementFactory.GARBAGE_COLLECTOR_MXBEAN_DOMAIN_TYPE, getName());
}
} }
...@@ -145,7 +145,7 @@ public class GcInfoBuilder { ...@@ -145,7 +145,7 @@ public class GcInfoBuilder {
allItemTypes[i] = SimpleType.DOUBLE; allItemTypes[i] = SimpleType.DOUBLE;
break; break;
default: default:
throw new InternalError( throw new AssertionError(
"Unsupported type [" + gcExtItemTypes[i] + "]"); "Unsupported type [" + gcExtItemTypes[i] + "]");
} }
} }
......
...@@ -80,19 +80,19 @@ public class GcInfoCompositeData extends LazyCompositeData { ...@@ -80,19 +80,19 @@ public class GcInfoCompositeData extends LazyCompositeData {
}; };
} catch (OpenDataException e) { } catch (OpenDataException e) {
// Should never reach here // Should never reach here
throw Util.newAssertionError(e); throw new AssertionError(e);
} }
// Get the item values for the extension attributes // Get the item values for the extension attributes
final int gcExtItemCount = builder.getGcExtItemCount(); final int gcExtItemCount = builder.getGcExtItemCount();
if (gcExtItemCount == 0 && if (gcExtItemCount == 0 &&
gcExtItemValues != null && gcExtItemValues.length != 0) { gcExtItemValues != null && gcExtItemValues.length != 0) {
throw new InternalError("Unexpected Gc Extension Item Values"); throw new AssertionError("Unexpected Gc Extension Item Values");
} }
if (gcExtItemCount > 0 && (gcExtItemValues == null || if (gcExtItemCount > 0 && (gcExtItemValues == null ||
gcExtItemCount != gcExtItemValues.length)) { gcExtItemCount != gcExtItemValues.length)) {
throw new InternalError("Unmatched Gc Extension Item Values"); throw new AssertionError("Unmatched Gc Extension Item Values");
} }
Object[] values = new Object[baseGcInfoItemValues.length + Object[] values = new Object[baseGcInfoItemValues.length +
...@@ -111,7 +111,7 @@ public class GcInfoCompositeData extends LazyCompositeData { ...@@ -111,7 +111,7 @@ public class GcInfoCompositeData extends LazyCompositeData {
values); values);
} catch (OpenDataException e) { } catch (OpenDataException e) {
// Should never reach here // Should never reach here
throw Util.newInternalError(e); throw new AssertionError(e);
} }
} }
...@@ -141,10 +141,10 @@ public class GcInfoCompositeData extends LazyCompositeData { ...@@ -141,10 +141,10 @@ public class GcInfoCompositeData extends LazyCompositeData {
MappedMXBeanType.getMappedType(m.getGenericReturnType()); MappedMXBeanType.getMappedType(m.getGenericReturnType());
} catch (NoSuchMethodException e) { } catch (NoSuchMethodException e) {
// Should never reach here // Should never reach here
throw Util.newAssertionError(e); throw new AssertionError(e);
} catch (OpenDataException e) { } catch (OpenDataException e) {
// Should never reach here // Should never reach here
throw Util.newAssertionError(e); throw new AssertionError(e);
} }
} }
...@@ -186,10 +186,10 @@ public class GcInfoCompositeData extends LazyCompositeData { ...@@ -186,10 +186,10 @@ public class GcInfoCompositeData extends LazyCompositeData {
return cast(memoryUsageMapType.toJavaTypeData(td)); return cast(memoryUsageMapType.toJavaTypeData(td));
} catch (InvalidObjectException e) { } catch (InvalidObjectException e) {
// Should never reach here // Should never reach here
throw Util.newAssertionError(e); throw new AssertionError(e);
} catch (OpenDataException e) { } catch (OpenDataException e) {
// Should never reach here // Should never reach here
throw Util.newAssertionError(e); throw new AssertionError(e);
} }
} }
...@@ -205,10 +205,10 @@ public class GcInfoCompositeData extends LazyCompositeData { ...@@ -205,10 +205,10 @@ public class GcInfoCompositeData extends LazyCompositeData {
return cast(memoryUsageMapType.toJavaTypeData(td)); return cast(memoryUsageMapType.toJavaTypeData(td));
} catch (InvalidObjectException e) { } catch (InvalidObjectException e) {
// Should never reach here // Should never reach here
throw Util.newAssertionError(e); throw new AssertionError(e);
} catch (OpenDataException e) { } catch (OpenDataException e) {
// Should never reach here // Should never reach here
throw Util.newAssertionError(e); throw new AssertionError(e);
} }
} }
......
...@@ -28,6 +28,8 @@ package sun.management; ...@@ -28,6 +28,8 @@ package sun.management;
import java.util.*; import java.util.*;
import java.io.IOException; import java.io.IOException;
import java.lang.reflect.Method; import java.lang.reflect.Method;
import javax.management.ObjectName;
import com.sun.management.HotSpotDiagnosticMXBean; import com.sun.management.HotSpotDiagnosticMXBean;
import com.sun.management.VMOption; import com.sun.management.VMOption;
...@@ -72,7 +74,7 @@ public class HotSpotDiagnostic implements HotSpotDiagnosticMXBean { ...@@ -72,7 +74,7 @@ public class HotSpotDiagnostic implements HotSpotDiagnosticMXBean {
throw new NullPointerException("value cannot be null"); throw new NullPointerException("value cannot be null");
} }
ManagementFactory.checkControlAccess(); Util.checkControlAccess();
Flag flag = Flag.getFlag(name); Flag flag = Flag.getFlag(name);
if (flag == null) { if (flag == null) {
throw new IllegalArgumentException("VM option \"" + throw new IllegalArgumentException("VM option \"" +
...@@ -113,4 +115,8 @@ public class HotSpotDiagnostic implements HotSpotDiagnosticMXBean { ...@@ -113,4 +115,8 @@ public class HotSpotDiagnostic implements HotSpotDiagnosticMXBean {
v.getClass().getName()); v.getClass().getName());
} }
} }
public ObjectName getObjectName() {
return Util.newObjectName("com.sun.management:type=HotSpotDiagnostic");
}
} }
...@@ -131,7 +131,7 @@ class HotspotCompilation ...@@ -131,7 +131,7 @@ class HotspotCompilation
} }
// FIXME: should tolerate if counter doesn't exist // FIXME: should tolerate if counter doesn't exist
throw new InternalError("Counter " + name + " does not exist"); throw new AssertionError("Counter " + name + " does not exist");
} }
private void initCompilerCounters() { private void initCompilerCounters() {
......
...@@ -39,6 +39,9 @@ import javax.management.ObjectName; ...@@ -39,6 +39,9 @@ import javax.management.ObjectName;
public class HotspotInternal public class HotspotInternal
implements HotspotInternalMBean, MBeanRegistration { implements HotspotInternalMBean, MBeanRegistration {
private final static String HOTSPOT_INTERNAL_MBEAN_NAME =
"sun.management:type=HotspotInternal";
private static ObjectName objName = Util.newObjectName(HOTSPOT_INTERNAL_MBEAN_NAME);
private MBeanServer server = null; private MBeanServer server = null;
/** /**
...@@ -52,16 +55,16 @@ public class HotspotInternal ...@@ -52,16 +55,16 @@ public class HotspotInternal
ObjectName name) throws java.lang.Exception { ObjectName name) throws java.lang.Exception {
// register all internal MBeans when this MBean is instantiated // register all internal MBeans when this MBean is instantiated
// and to be registered in a MBeanServer. // and to be registered in a MBeanServer.
ManagementFactory.registerInternalMBeans(server); ManagementFactoryHelper.registerInternalMBeans(server);
this.server = server; this.server = server;
return ManagementFactory.getHotspotInternalObjectName(); return objName;
} }
public void postRegister(Boolean registrationDone) {}; public void postRegister(Boolean registrationDone) {};
public void preDeregister() throws java.lang.Exception { public void preDeregister() throws java.lang.Exception {
// unregister all internal MBeans when this MBean is unregistered. // unregister all internal MBeans when this MBean is unregistered.
ManagementFactory.unregisterInternalMBeans(server); ManagementFactoryHelper.unregisterInternalMBeans(server);
} }
public void postDeregister() {}; public void postDeregister() {};
......
...@@ -73,7 +73,7 @@ class LockDataConverter extends StandardMBean ...@@ -73,7 +73,7 @@ class LockDataConverter extends StandardMBean
try { try {
return (CompositeData) getAttribute("LockInfo"); return (CompositeData) getAttribute("LockInfo");
} catch (Exception e) { } catch (Exception e) {
throw Util.newInternalError(e); throw new AssertionError(e);
} }
} }
...@@ -81,7 +81,7 @@ class LockDataConverter extends StandardMBean ...@@ -81,7 +81,7 @@ class LockDataConverter extends StandardMBean
try { try {
return (CompositeData[]) getAttribute("LockedSynchronizers"); return (CompositeData[]) getAttribute("LockedSynchronizers");
} catch (Exception e) { } catch (Exception e) {
throw Util.newInternalError(e); throw new AssertionError(e);
} }
} }
...@@ -89,7 +89,7 @@ class LockDataConverter extends StandardMBean ...@@ -89,7 +89,7 @@ class LockDataConverter extends StandardMBean
try { try {
setAttribute(new Attribute("LockInfo", cd)); setAttribute(new Attribute("LockInfo", cd));
} catch (Exception e) { } catch (Exception e) {
throw Util.newInternalError(e); throw new AssertionError(e);
} }
return getLockInfo(); return getLockInfo();
} }
...@@ -98,7 +98,7 @@ class LockDataConverter extends StandardMBean ...@@ -98,7 +98,7 @@ class LockDataConverter extends StandardMBean
try { try {
setAttribute(new Attribute("LockedSynchronizers", cd)); setAttribute(new Attribute("LockedSynchronizers", cd));
} catch (Exception e) { } catch (Exception e) {
throw Util.newInternalError(e); throw new AssertionError(e);
} }
return getLockedSynchronizers(); return getLockedSynchronizers();
} }
......
/* /*
* Copyright 2003-2006 Sun Microsystems, Inc. All Rights Reserved. * Copyright 2008 Sun Microsystems, Inc. All Rights Reserved.
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
* *
* This code is free software; you can redistribute it and/or modify it * This code is free software; you can redistribute it and/or modify it
...@@ -25,445 +25,17 @@ ...@@ -25,445 +25,17 @@
package sun.management; package sun.management;
import java.lang.management.*; import java.lang.management.MemoryManagerMXBean;
import java.util.logging.LogManager; import java.lang.management.MemoryPoolMXBean;
import java.lang.management.GarbageCollectorMXBean;
import javax.management.DynamicMBean;
import javax.management.MBeanServer;
import javax.management.MBeanServerFactory;
import javax.management.MBeanInfo;
import javax.management.NotificationEmitter;
import javax.management.ObjectName;
import javax.management.ObjectInstance;
import javax.management.InstanceAlreadyExistsException;
import javax.management.InstanceNotFoundException;
import javax.management.MBeanRegistrationException;
import javax.management.NotCompliantMBeanException;
import javax.management.MalformedObjectNameException;
import javax.management.RuntimeOperationsException;
import javax.management.StandardEmitterMBean;
import javax.management.StandardMBean;
import java.security.AccessController;
import java.security.Permission;
import java.security.PrivilegedActionException;
import java.security.PrivilegedExceptionAction;
import sun.security.action.LoadLibraryAction;
import java.util.ArrayList;
import java.util.List;
import java.util.HashMap;
import java.util.Map;
import java.util.Set;
import java.util.Iterator;
import java.util.ListIterator;
import com.sun.management.OSMBeanFactory;
import com.sun.management.HotSpotDiagnosticMXBean;
import static java.lang.management.ManagementFactory.*;
/** /**
* ManagementFactory provides static factory methods to create * ManagementFactory class provides the methods that the HotSpot VM
* instances of the management interface. * will invoke. So the class and method names cannot be renamed.
*/ */
public class ManagementFactory { class ManagementFactory {
private ManagementFactory() {}; private ManagementFactory() {};
private static VMManagement jvm;
private static boolean mbeansCreated = false;
private static ClassLoadingImpl classMBean = null;
private static MemoryImpl memoryMBean = null;
private static ThreadImpl threadMBean = null;
private static RuntimeImpl runtimeMBean = null;
private static CompilationImpl compileMBean = null;
private static OperatingSystemImpl osMBean = null;
public static synchronized ClassLoadingMXBean getClassLoadingMXBean() {
if (classMBean == null) {
classMBean = new ClassLoadingImpl(jvm);
}
return classMBean;
}
public static synchronized MemoryMXBean getMemoryMXBean() {
if (memoryMBean == null) {
memoryMBean = new MemoryImpl(jvm);
}
return memoryMBean;
}
public static synchronized ThreadMXBean getThreadMXBean() {
if (threadMBean == null) {
threadMBean = new ThreadImpl(jvm);
}
return threadMBean;
}
public static synchronized RuntimeMXBean getRuntimeMXBean() {
if (runtimeMBean == null) {
runtimeMBean = new RuntimeImpl(jvm);
}
return runtimeMBean;
}
public static synchronized CompilationMXBean getCompilationMXBean() {
if (compileMBean == null && jvm.getCompilerName() != null) {
compileMBean = new CompilationImpl(jvm);
}
return compileMBean;
}
public static synchronized OperatingSystemMXBean getOperatingSystemMXBean() {
if (osMBean == null) {
osMBean = (OperatingSystemImpl)
OSMBeanFactory.getOperatingSystemMXBean(jvm);
}
return osMBean;
}
public static List<MemoryPoolMXBean> getMemoryPoolMXBeans() {
MemoryPoolMXBean[] pools = MemoryImpl.getMemoryPools();
List<MemoryPoolMXBean> list = new ArrayList<MemoryPoolMXBean>(pools.length);
for (int i = 0; i < pools.length; i++) {
MemoryPoolMXBean p = pools[i];
list.add(p);
}
return list;
}
public static List<MemoryManagerMXBean> getMemoryManagerMXBeans() {
MemoryManagerMXBean[] mgrs = MemoryImpl.getMemoryManagers();
List<MemoryManagerMXBean> result = new ArrayList<MemoryManagerMXBean>(mgrs.length);
for (int i = 0; i < mgrs.length; i++) {
MemoryManagerMXBean m = mgrs[i];
result.add(m);
}
return result;
}
public static List<GarbageCollectorMXBean> getGarbageCollectorMXBeans() {
MemoryManagerMXBean[] mgrs = MemoryImpl.getMemoryManagers();
List<GarbageCollectorMXBean> result = new ArrayList<GarbageCollectorMXBean>(mgrs.length);
for (int i = 0; i < mgrs.length; i++) {
if (mgrs[i] instanceof GarbageCollectorMXBean) {
GarbageCollectorMXBean gc = (GarbageCollectorMXBean) mgrs[i];
result.add(gc);
}
}
return result;
}
private static HotSpotDiagnostic hsDiagMBean = null;
private static HotspotRuntime hsRuntimeMBean = null;
private static HotspotClassLoading hsClassMBean = null;
private static HotspotThread hsThreadMBean = null;
private static HotspotCompilation hsCompileMBean = null;
private static HotspotMemory hsMemoryMBean = null;
public static synchronized HotSpotDiagnosticMXBean getDiagnosticMXBean() {
if (hsDiagMBean == null) {
hsDiagMBean = new HotSpotDiagnostic();
}
return hsDiagMBean;
}
/**
/**
* This method is for testing only.
*/
public static synchronized HotspotRuntimeMBean getHotspotRuntimeMBean() {
if (hsRuntimeMBean == null) {
hsRuntimeMBean = new HotspotRuntime(jvm);
}
return hsRuntimeMBean;
}
/**
* This method is for testing only.
*/
public static synchronized HotspotClassLoadingMBean getHotspotClassLoadingMBean() {
if (hsClassMBean == null) {
hsClassMBean = new HotspotClassLoading(jvm);
}
return hsClassMBean;
}
/**
* This method is for testing only.
*/
public static synchronized HotspotThreadMBean getHotspotThreadMBean() {
if (hsThreadMBean == null) {
hsThreadMBean = new HotspotThread(jvm);
}
return hsThreadMBean;
}
/**
* This method is for testing only.
*/
public static synchronized HotspotMemoryMBean getHotspotMemoryMBean() {
if (hsMemoryMBean == null) {
hsMemoryMBean = new HotspotMemory(jvm);
}
return hsMemoryMBean;
}
/**
* This method is for testing only.
*/
public static synchronized HotspotCompilationMBean getHotspotCompilationMBean() {
if (hsCompileMBean == null) {
hsCompileMBean = new HotspotCompilation(jvm);
}
return hsCompileMBean;
}
private static Permission monitorPermission =
new ManagementPermission("monitor");
private static Permission controlPermission =
new ManagementPermission("control");
/**
* Check that the current context is trusted to perform monitoring
* or management.
* <p>
* If the check fails we throw a SecurityException, otherwise
* we return normally.
*
* @exception SecurityException if a security manager exists and if
* the caller does not have ManagementPermission("control").
*/
static void checkAccess(Permission p)
throws SecurityException {
SecurityManager sm = System.getSecurityManager();
if (sm != null) {
sm.checkPermission(p);
}
}
static void checkMonitorAccess() throws SecurityException {
checkAccess(monitorPermission);
}
static void checkControlAccess() throws SecurityException {
checkAccess(controlPermission);
}
/**
* Registers an MXBean and throws exception if an instance with the same
* name exists.
*
* This method makes a DynamicMBean out of an MXBean by wrapping it with a
* StandardMBean (StandardEmitterMBean if the supplied emitter is not null),
* so it can be registered in an MBeanServer which does not have support for
* MXBeans.
*/
private static void addMXBean(MBeanServer mbs, Object mbean,
String mbeanName, NotificationEmitter emitter) {
// Make DynamicMBean out of MXBean by wrapping it with a StandardMBean
//
final DynamicMBean dmbean;
if (emitter == null) {
dmbean = new StandardMBean(mbean, null, true);
} else {
dmbean = new StandardEmitterMBean(mbean, null, true, emitter);
}
addMBean(mbs, dmbean, mbeanName, false);
}
/**
* Registers a Standard MBean or a Dynamic MBean and throws
* exception if an instance with the same name exists.
*/
private static void addMBean(MBeanServer mbs, Object mbean, String mbeanName) {
addMBean(mbs, mbean, mbeanName, false);
}
private static void addMBean(MBeanServer mbs, Object mbean,
String mbeanName, boolean ignoreConflicts) {
try {
final ObjectName objName = new ObjectName(mbeanName);
// inner class requires these fields to be final
final MBeanServer mbs0 = mbs;
final Object mbean0 = mbean;
final boolean ignore = ignoreConflicts;
AccessController.doPrivileged(new PrivilegedExceptionAction<Object>() {
public Object run() throws InstanceAlreadyExistsException,
MBeanRegistrationException,
NotCompliantMBeanException {
try {
ObjectInstance o = mbs0.registerMBean(mbean0,
objName);
return null;
} catch (InstanceAlreadyExistsException e) {
// if an instance with the object name exists in
// the MBeanServer ignore the exception
// if ignoreConflicts is true;
// otherwise, throws exception.
if (!ignore) {
throw e;
}
}
return null;
}
});
} catch (PrivilegedActionException e) {
throw Util.newException(e.getException());
} catch (MalformedObjectNameException e) {
// should not reach here
throw Util.newException(e);
}
}
public static MBeanServer createPlatformMBeanServer() {
MBeanServer mbs = MBeanServerFactory.createMBeanServer();
// Register all the platform MBeans to this MBeanServer
addMXBean(mbs, getClassLoadingMXBean(),
CLASS_LOADING_MXBEAN_NAME, null);
addMXBean(mbs, getMemoryMXBean(),
MEMORY_MXBEAN_NAME, (NotificationEmitter) getMemoryMXBean());
addMXBean(mbs, getOperatingSystemMXBean(),
OPERATING_SYSTEM_MXBEAN_NAME, null);
addMXBean(mbs, getRuntimeMXBean(),
RUNTIME_MXBEAN_NAME, null);
addMXBean(mbs, getThreadMXBean(),
THREAD_MXBEAN_NAME, null);
addMXBean(mbs, getDiagnosticMXBean(),
HOTSPOT_DIAGNOSTIC_MXBEAN_NAME, null);
// CompilationMBean may not exist
if (getCompilationMXBean() != null) {
addMXBean(mbs, getCompilationMXBean(),
COMPILATION_MXBEAN_NAME, null);
}
// Register MBeans for memory pools and memory managers
addMemoryManagers(mbs);
addMemoryPools(mbs);
// Register platform extension
addMXBean(mbs, LogManager.getLoggingMXBean(),
LogManager.LOGGING_MXBEAN_NAME, null);
return mbs;
}
private final static String HOTSPOT_DIAGNOSTIC_MXBEAN_NAME =
"com.sun.management:type=HotSpotDiagnostic";
private final static String HOTSPOT_CLASS_LOADING_MBEAN_NAME =
"sun.management:type=HotspotClassLoading";
private final static String HOTSPOT_COMPILATION_MBEAN_NAME =
"sun.management:type=HotspotCompilation";
private final static String HOTSPOT_MEMORY_MBEAN_NAME =
"sun.management:type=HotspotMemory";
private static final String HOTSPOT_RUNTIME_MBEAN_NAME =
"sun.management:type=HotspotRuntime";
private final static String HOTSPOT_THREAD_MBEAN_NAME =
"sun.management:type=HotspotThreading";
private final static String HOTSPOT_INTERNAL_MBEAN_NAME =
"sun.management:type=HotspotInternal";
private static ObjectName hsInternalObjName = null;
static synchronized ObjectName getHotspotInternalObjectName() {
if (hsInternalObjName == null) {
try {
hsInternalObjName = new ObjectName(HOTSPOT_INTERNAL_MBEAN_NAME);
} catch (MalformedObjectNameException e) {
// should not reach here
throw Util.newException(e);
}
}
return hsInternalObjName;
}
static void registerInternalMBeans(MBeanServer mbs) {
// register all internal MBeans if not registered
// No exception is thrown if a MBean with that object name
// already registered (i.e. ignore if name conflicts).
addMBean(mbs, getHotspotClassLoadingMBean(),
HOTSPOT_CLASS_LOADING_MBEAN_NAME, true);
addMBean(mbs, getHotspotMemoryMBean(),
HOTSPOT_MEMORY_MBEAN_NAME, true);
addMBean(mbs, getHotspotRuntimeMBean(),
HOTSPOT_RUNTIME_MBEAN_NAME, true);
addMBean(mbs, getHotspotThreadMBean(),
HOTSPOT_THREAD_MBEAN_NAME, true);
// CompilationMBean may not exist
if (getCompilationMXBean() != null) {
addMBean(mbs, getHotspotCompilationMBean(),
HOTSPOT_COMPILATION_MBEAN_NAME, true);
}
}
private static void unregisterMBean(MBeanServer mbs, String mbeanName) {
try {
final ObjectName objName = new ObjectName(mbeanName);
// inner class requires these fields to be final
final MBeanServer mbs0 = mbs;
AccessController.doPrivileged(new PrivilegedExceptionAction<Object>() {
public Object run() throws MBeanRegistrationException,
RuntimeOperationsException {
try {
mbs0.unregisterMBean(objName);
} catch (InstanceNotFoundException e) {
// ignore exception if not found
}
return null;
}
});
} catch (PrivilegedActionException e) {
throw Util.newException(e.getException());
} catch (MalformedObjectNameException e) {
// should not reach here
throw Util.newException(e);
}
}
static void unregisterInternalMBeans(MBeanServer mbs) {
// unregister all internal MBeans
unregisterMBean(mbs, HOTSPOT_CLASS_LOADING_MBEAN_NAME);
unregisterMBean(mbs, HOTSPOT_MEMORY_MBEAN_NAME);
unregisterMBean(mbs, HOTSPOT_RUNTIME_MBEAN_NAME);
unregisterMBean(mbs, HOTSPOT_THREAD_MBEAN_NAME);
// CompilationMBean may not exist
if (getCompilationMXBean() != null) {
unregisterMBean(mbs, HOTSPOT_COMPILATION_MBEAN_NAME);
}
}
private static synchronized void addMemoryPools(MBeanServer mbs) {
// Get a list of memory pools
MemoryPoolMXBean[] newPools = MemoryImpl.getMemoryPools();
for (int i = 0; i < newPools.length; i++) {
String poolObjNameString = Util.getMBeanObjectName(newPools[i]);
addMXBean(mbs, newPools[i], poolObjNameString, null);
}
}
// Register all memory managers with the MBeanServer;
private static synchronized void addMemoryManagers(MBeanServer mbs) {
// Get a list of memory managers
MemoryManagerMXBean[] newMgrs = MemoryImpl.getMemoryManagers();
for (int i = 0; i < newMgrs.length; i++) {
String mgrObjNameString = Util.getMBeanObjectName(newMgrs[i]);
addMXBean(mbs, newMgrs[i], mgrObjNameString, null);
}
}
// Invoked by the VM // Invoked by the VM
private static MemoryPoolMXBean createMemoryPool private static MemoryPoolMXBean createMemoryPool
(String name, boolean isHeap, long uThreshold, long gcThreshold) { (String name, boolean isHeap, long uThreshold, long gcThreshold) {
...@@ -480,29 +52,4 @@ public class ManagementFactory { ...@@ -480,29 +52,4 @@ public class ManagementFactory {
// ignore type parameter which is for future extension // ignore type parameter which is for future extension
return new GarbageCollectorImpl(name); return new GarbageCollectorImpl(name);
} }
static {
AccessController.doPrivileged(new LoadLibraryAction("management"));
jvm = new VMManagementImpl();
}
public static boolean isThreadSuspended(int state) {
return ((state & JMM_THREAD_STATE_FLAG_SUSPENDED) != 0);
}
public static boolean isThreadRunningNative(int state) {
return ((state & JMM_THREAD_STATE_FLAG_NATIVE) != 0);
}
public static Thread.State toThreadState(int state) {
// suspended and native bits may be set in state
int threadStatus = state & ~JMM_THREAD_STATE_FLAG_MASK;
return sun.misc.VM.toThreadState(threadStatus);
}
// These values are defined in jmm.h
private static final int JMM_THREAD_STATE_FLAG_MASK = 0xFFF00000;
private static final int JMM_THREAD_STATE_FLAG_SUSPENDED = 0x00100000;
private static final int JMM_THREAD_STATE_FLAG_NATIVE = 0x00400000;
} }
/*
* Copyright 2003-2006 Sun Microsystems, Inc. All Rights Reserved.
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
*
* This code is free software; you can redistribute it and/or modify it
* under the terms of the GNU General Public License version 2 only, as
* published by the Free Software Foundation. Sun designates this
* particular file as subject to the "Classpath" exception as provided
* by Sun in the LICENSE file that accompanied this code.
*
* This code is distributed in the hope that it will be useful, but WITHOUT
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
* version 2 for more details (a copy is included in the LICENSE file that
* accompanied this code).
*
* You should have received a copy of the GNU General Public License version
* 2 along with this work; if not, write to the Free Software Foundation,
* Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
*
* Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa Clara,
* CA 95054 USA or visit www.sun.com if you need additional information or
* have any questions.
*/
package sun.management;
import java.lang.management.*;
import java.util.logging.LogManager;
import javax.management.DynamicMBean;
import javax.management.MBeanServer;
import javax.management.MBeanServerFactory;
import javax.management.MBeanInfo;
import javax.management.NotificationEmitter;
import javax.management.ObjectName;
import javax.management.ObjectInstance;
import javax.management.InstanceAlreadyExistsException;
import javax.management.InstanceNotFoundException;
import javax.management.MBeanRegistrationException;
import javax.management.NotCompliantMBeanException;
import javax.management.RuntimeOperationsException;
import javax.management.StandardEmitterMBean;
import javax.management.StandardMBean;
import java.security.AccessController;
import java.security.PrivilegedActionException;
import java.security.PrivilegedExceptionAction;
import sun.security.action.LoadLibraryAction;
import java.util.ArrayList;
import java.util.List;
import java.util.HashMap;
import java.util.Map;
import java.util.Set;
import java.util.Iterator;
import java.util.ListIterator;
import com.sun.management.OSMBeanFactory;
import com.sun.management.HotSpotDiagnosticMXBean;
import static java.lang.management.ManagementFactory.*;
/**
* ManagementFactoryHelper provides static factory methods to create
* instances of the management interface.
*/
public class ManagementFactoryHelper {
private ManagementFactoryHelper() {};
private static VMManagement jvm;
private static boolean mbeansCreated = false;
private static ClassLoadingImpl classMBean = null;
private static MemoryImpl memoryMBean = null;
private static ThreadImpl threadMBean = null;
private static RuntimeImpl runtimeMBean = null;
private static CompilationImpl compileMBean = null;
private static OperatingSystemImpl osMBean = null;
public static synchronized ClassLoadingMXBean getClassLoadingMXBean() {
if (classMBean == null) {
classMBean = new ClassLoadingImpl(jvm);
}
return classMBean;
}
public static synchronized MemoryMXBean getMemoryMXBean() {
if (memoryMBean == null) {
memoryMBean = new MemoryImpl(jvm);
}
return memoryMBean;
}
public static synchronized ThreadMXBean getThreadMXBean() {
if (threadMBean == null) {
threadMBean = new ThreadImpl(jvm);
}
return threadMBean;
}
public static synchronized RuntimeMXBean getRuntimeMXBean() {
if (runtimeMBean == null) {
runtimeMBean = new RuntimeImpl(jvm);
}
return runtimeMBean;
}
public static synchronized CompilationMXBean getCompilationMXBean() {
if (compileMBean == null && jvm.getCompilerName() != null) {
compileMBean = new CompilationImpl(jvm);
}
return compileMBean;
}
public static synchronized OperatingSystemMXBean getOperatingSystemMXBean() {
if (osMBean == null) {
osMBean = (OperatingSystemImpl)
OSMBeanFactory.getOperatingSystemMXBean(jvm);
}
return osMBean;
}
public static List<MemoryPoolMXBean> getMemoryPoolMXBeans() {
MemoryPoolMXBean[] pools = MemoryImpl.getMemoryPools();
List<MemoryPoolMXBean> list = new ArrayList<MemoryPoolMXBean>(pools.length);
for (MemoryPoolMXBean p : pools) {
list.add(p);
}
return list;
}
public static List<MemoryManagerMXBean> getMemoryManagerMXBeans() {
MemoryManagerMXBean[] mgrs = MemoryImpl.getMemoryManagers();
List<MemoryManagerMXBean> result = new ArrayList<MemoryManagerMXBean>(mgrs.length);
for (MemoryManagerMXBean m : mgrs) {
result.add(m);
}
return result;
}
public static List<GarbageCollectorMXBean> getGarbageCollectorMXBeans() {
MemoryManagerMXBean[] mgrs = MemoryImpl.getMemoryManagers();
List<GarbageCollectorMXBean> result = new ArrayList<GarbageCollectorMXBean>(mgrs.length);
for (MemoryManagerMXBean m : mgrs) {
if (GarbageCollectorMXBean.class.isInstance(m)) {
result.add(GarbageCollectorMXBean.class.cast(m));
}
}
return result;
}
private static HotSpotDiagnostic hsDiagMBean = null;
private static HotspotRuntime hsRuntimeMBean = null;
private static HotspotClassLoading hsClassMBean = null;
private static HotspotThread hsThreadMBean = null;
private static HotspotCompilation hsCompileMBean = null;
private static HotspotMemory hsMemoryMBean = null;
public static synchronized HotSpotDiagnosticMXBean getDiagnosticMXBean() {
if (hsDiagMBean == null) {
hsDiagMBean = new HotSpotDiagnostic();
}
return hsDiagMBean;
}
/**
/**
* This method is for testing only.
*/
public static synchronized HotspotRuntimeMBean getHotspotRuntimeMBean() {
if (hsRuntimeMBean == null) {
hsRuntimeMBean = new HotspotRuntime(jvm);
}
return hsRuntimeMBean;
}
/**
* This method is for testing only.
*/
public static synchronized HotspotClassLoadingMBean getHotspotClassLoadingMBean() {
if (hsClassMBean == null) {
hsClassMBean = new HotspotClassLoading(jvm);
}
return hsClassMBean;
}
/**
* This method is for testing only.
*/
public static synchronized HotspotThreadMBean getHotspotThreadMBean() {
if (hsThreadMBean == null) {
hsThreadMBean = new HotspotThread(jvm);
}
return hsThreadMBean;
}
/**
* This method is for testing only.
*/
public static synchronized HotspotMemoryMBean getHotspotMemoryMBean() {
if (hsMemoryMBean == null) {
hsMemoryMBean = new HotspotMemory(jvm);
}
return hsMemoryMBean;
}
/**
* This method is for testing only.
*/
public static synchronized HotspotCompilationMBean getHotspotCompilationMBean() {
if (hsCompileMBean == null) {
hsCompileMBean = new HotspotCompilation(jvm);
}
return hsCompileMBean;
}
/**
* Registers a given MBean if not registered in the MBeanServer;
* otherwise, just return.
*/
private static void addMBean(MBeanServer mbs, Object mbean, String mbeanName) {
try {
final ObjectName objName = Util.newObjectName(mbeanName);
// inner class requires these fields to be final
final MBeanServer mbs0 = mbs;
final Object mbean0 = mbean;
AccessController.doPrivileged(new PrivilegedExceptionAction<Void>() {
public Void run() throws MBeanRegistrationException,
NotCompliantMBeanException {
try {
mbs0.registerMBean(mbean0, objName);
return null;
} catch (InstanceAlreadyExistsException e) {
// if an instance with the object name exists in
// the MBeanServer ignore the exception
}
return null;
}
});
} catch (PrivilegedActionException e) {
throw Util.newException(e.getException());
}
}
private final static String HOTSPOT_CLASS_LOADING_MBEAN_NAME =
"sun.management:type=HotspotClassLoading";
private final static String HOTSPOT_COMPILATION_MBEAN_NAME =
"sun.management:type=HotspotCompilation";
private final static String HOTSPOT_MEMORY_MBEAN_NAME =
"sun.management:type=HotspotMemory";
private static final String HOTSPOT_RUNTIME_MBEAN_NAME =
"sun.management:type=HotspotRuntime";
private final static String HOTSPOT_THREAD_MBEAN_NAME =
"sun.management:type=HotspotThreading";
static void registerInternalMBeans(MBeanServer mbs) {
// register all internal MBeans if not registered
// No exception is thrown if a MBean with that object name
// already registered
addMBean(mbs, getHotspotClassLoadingMBean(),
HOTSPOT_CLASS_LOADING_MBEAN_NAME);
addMBean(mbs, getHotspotMemoryMBean(),
HOTSPOT_MEMORY_MBEAN_NAME);
addMBean(mbs, getHotspotRuntimeMBean(),
HOTSPOT_RUNTIME_MBEAN_NAME);
addMBean(mbs, getHotspotThreadMBean(),
HOTSPOT_THREAD_MBEAN_NAME);
// CompilationMBean may not exist
if (getCompilationMXBean() != null) {
addMBean(mbs, getHotspotCompilationMBean(),
HOTSPOT_COMPILATION_MBEAN_NAME);
}
}
private static void unregisterMBean(MBeanServer mbs, String mbeanName) {
try {
final ObjectName objName = Util.newObjectName(mbeanName);
// inner class requires these fields to be final
final MBeanServer mbs0 = mbs;
AccessController.doPrivileged(new PrivilegedExceptionAction<Void>() {
public Void run() throws MBeanRegistrationException,
RuntimeOperationsException {
try {
mbs0.unregisterMBean(objName);
} catch (InstanceNotFoundException e) {
// ignore exception if not found
}
return null;
}
});
} catch (PrivilegedActionException e) {
throw Util.newException(e.getException());
}
}
static void unregisterInternalMBeans(MBeanServer mbs) {
// unregister all internal MBeans
unregisterMBean(mbs, HOTSPOT_CLASS_LOADING_MBEAN_NAME);
unregisterMBean(mbs, HOTSPOT_MEMORY_MBEAN_NAME);
unregisterMBean(mbs, HOTSPOT_RUNTIME_MBEAN_NAME);
unregisterMBean(mbs, HOTSPOT_THREAD_MBEAN_NAME);
// CompilationMBean may not exist
if (getCompilationMXBean() != null) {
unregisterMBean(mbs, HOTSPOT_COMPILATION_MBEAN_NAME);
}
}
static {
AccessController.doPrivileged(new LoadLibraryAction("management"));
jvm = new VMManagementImpl();
}
public static boolean isThreadSuspended(int state) {
return ((state & JMM_THREAD_STATE_FLAG_SUSPENDED) != 0);
}
public static boolean isThreadRunningNative(int state) {
return ((state & JMM_THREAD_STATE_FLAG_NATIVE) != 0);
}
public static Thread.State toThreadState(int state) {
// suspended and native bits may be set in state
int threadStatus = state & ~JMM_THREAD_STATE_FLAG_MASK;
return sun.misc.VM.toThreadState(threadStatus);
}
// These values are defined in jmm.h
private static final int JMM_THREAD_STATE_FLAG_MASK = 0xFFF00000;
private static final int JMM_THREAD_STATE_FLAG_SUSPENDED = 0x00100000;
private static final int JMM_THREAD_STATE_FLAG_NATIVE = 0x00400000;
}
...@@ -735,14 +735,14 @@ public abstract class MappedMXBeanType { ...@@ -735,14 +735,14 @@ public abstract class MappedMXBeanType {
throws OpenDataException, InvalidObjectException { throws OpenDataException, InvalidObjectException {
if (fromMethod == null) { if (fromMethod == null) {
throw new InternalError("Does not support data conversion"); throw new AssertionError("Does not support data conversion");
} }
try { try {
return fromMethod.invoke(null, data); return fromMethod.invoke(null, data);
} catch (IllegalAccessException e) { } catch (IllegalAccessException e) {
// should never reach here // should never reach here
throw Util.newAssertionError(e); throw new AssertionError(e);
} catch (InvocationTargetException e) { } catch (InvocationTargetException e) {
final OpenDataException ode = final OpenDataException ode =
new OpenDataException("Failed to invoke " + new OpenDataException("Failed to invoke " +
...@@ -785,7 +785,7 @@ public abstract class MappedMXBeanType { ...@@ -785,7 +785,7 @@ public abstract class MappedMXBeanType {
t = new InProgress(); t = new InProgress();
} catch (OpenDataException e) { } catch (OpenDataException e) {
// Should not reach here // Should not reach here
throw Util.newAssertionError(e); throw new AssertionError(e);
} }
inProgress = t; inProgress = t;
} }
...@@ -807,9 +807,9 @@ public abstract class MappedMXBeanType { ...@@ -807,9 +807,9 @@ public abstract class MappedMXBeanType {
} catch (ClassNotFoundException e) { } catch (ClassNotFoundException e) {
// the classes that these predefined types declare // the classes that these predefined types declare
// must exist! // must exist!
throw Util.newAssertionError(e); throw new AssertionError(e);
} catch (OpenDataException e) { } catch (OpenDataException e) {
throw Util.newAssertionError(e); throw new AssertionError(e);
} }
if (c.getName().startsWith("java.lang.")) { if (c.getName().startsWith("java.lang.")) {
...@@ -821,12 +821,12 @@ public abstract class MappedMXBeanType { ...@@ -821,12 +821,12 @@ public abstract class MappedMXBeanType {
// OK: must not be a primitive wrapper // OK: must not be a primitive wrapper
} catch (IllegalAccessException e) { } catch (IllegalAccessException e) {
// Should not reach here // Should not reach here
throw Util.newAssertionError(e); throw new AssertionError(e);
} }
} }
} }
} catch (OpenDataException e) { } catch (OpenDataException e) {
throw Util.newAssertionError(e); throw new AssertionError(e);
} }
} }
......
...@@ -25,13 +25,13 @@ ...@@ -25,13 +25,13 @@
package sun.management; package sun.management;
import java.lang.management.ManagementFactory;
import java.lang.management.MemoryMXBean; import java.lang.management.MemoryMXBean;
import java.lang.management.MemoryUsage; import java.lang.management.MemoryUsage;
import java.lang.management.MemoryNotificationInfo; import java.lang.management.MemoryNotificationInfo;
import java.lang.management.MemoryManagerMXBean; import java.lang.management.MemoryManagerMXBean;
import java.lang.management.MemoryPoolMXBean; import java.lang.management.MemoryPoolMXBean;
import javax.management.ObjectName; import javax.management.ObjectName;
import javax.management.MalformedObjectNameException;
import javax.management.MBeanNotificationInfo; import javax.management.MBeanNotificationInfo;
import javax.management.Notification; import javax.management.Notification;
import javax.management.NotificationEmitter; import javax.management.NotificationEmitter;
...@@ -88,7 +88,7 @@ class MemoryImpl extends NotificationEmitterSupport ...@@ -88,7 +88,7 @@ class MemoryImpl extends NotificationEmitterSupport
} }
public void setVerbose(boolean value) { public void setVerbose(boolean value) {
ManagementFactory.checkControlAccess(); Util.checkControlAccess();
setVerboseGC(value); setVerboseGC(value);
} }
...@@ -150,19 +150,6 @@ class MemoryImpl extends NotificationEmitterSupport ...@@ -150,19 +150,6 @@ class MemoryImpl extends NotificationEmitterSupport
return ++seqNumber; return ++seqNumber;
} }
private static ObjectName objname = null;
private static synchronized ObjectName getObjectName() {
if (objname != null) return objname;
try {
objname = new ObjectName(java.lang.management.ManagementFactory.MEMORY_MXBEAN_NAME);
} catch (MalformedObjectNameException e) {
// should never reach here
throw Util.newInternalError(e);
}
return objname;
}
static void createNotification(String notifType, static void createNotification(String notifType,
String poolName, String poolName,
MemoryUsage usage, MemoryUsage usage,
...@@ -175,7 +162,7 @@ class MemoryImpl extends NotificationEmitterSupport ...@@ -175,7 +162,7 @@ class MemoryImpl extends NotificationEmitterSupport
long timestamp = System.currentTimeMillis(); long timestamp = System.currentTimeMillis();
String msg = getNotifMsg(notifType); String msg = getNotifMsg(notifType);
Notification notif = new Notification(notifType, Notification notif = new Notification(notifType,
getObjectName(), mbean.getObjectName(),
getNextSeqNumber(), getNextSeqNumber(),
timestamp, timestamp,
msg); msg);
...@@ -189,4 +176,8 @@ class MemoryImpl extends NotificationEmitterSupport ...@@ -189,4 +176,8 @@ class MemoryImpl extends NotificationEmitterSupport
mbean.sendNotification(notif); mbean.sendNotification(notif);
} }
public ObjectName getObjectName() {
return Util.newObjectName(ManagementFactory.MEMORY_MXBEAN_NAME);
}
} }
...@@ -25,9 +25,12 @@ ...@@ -25,9 +25,12 @@
package sun.management; package sun.management;
import java.lang.management.ManagementFactory;
import java.lang.management.MemoryManagerMXBean; import java.lang.management.MemoryManagerMXBean;
import java.lang.management.MemoryPoolMXBean; import java.lang.management.MemoryPoolMXBean;
import javax.management.ObjectName;
/** /**
* Implementation class for a memory manager. * Implementation class for a memory manager.
* Standard and committed hotspot-specific metrics if any. * Standard and committed hotspot-specific metrics if any.
...@@ -73,4 +76,8 @@ class MemoryManagerImpl implements MemoryManagerMXBean { ...@@ -73,4 +76,8 @@ class MemoryManagerImpl implements MemoryManagerMXBean {
} }
private native MemoryPoolMXBean[] getMemoryPools0(); private native MemoryPoolMXBean[] getMemoryPools0();
public ObjectName getObjectName() {
return Util.newObjectName(ManagementFactory.MEMORY_MANAGER_MXBEAN_DOMAIN_TYPE, getName());
}
} }
...@@ -69,7 +69,7 @@ public class MemoryNotifInfoCompositeData extends LazyCompositeData { ...@@ -69,7 +69,7 @@ public class MemoryNotifInfoCompositeData extends LazyCompositeData {
memoryNotifInfoItemValues); memoryNotifInfoItemValues);
} catch (OpenDataException e) { } catch (OpenDataException e) {
// Should never reach here // Should never reach here
throw Util.newInternalError(e); throw new AssertionError(e);
} }
} }
...@@ -80,7 +80,7 @@ public class MemoryNotifInfoCompositeData extends LazyCompositeData { ...@@ -80,7 +80,7 @@ public class MemoryNotifInfoCompositeData extends LazyCompositeData {
MappedMXBeanType.toOpenType(MemoryNotificationInfo.class); MappedMXBeanType.toOpenType(MemoryNotificationInfo.class);
} catch (OpenDataException e) { } catch (OpenDataException e) {
// Should never reach here // Should never reach here
throw Util.newInternalError(e); throw new AssertionError(e);
} }
} }
......
...@@ -25,12 +25,13 @@ ...@@ -25,12 +25,13 @@
package sun.management; package sun.management;
import java.lang.management.ManagementFactory;
import java.lang.management.MemoryPoolMXBean; import java.lang.management.MemoryPoolMXBean;
import java.lang.management.MemoryUsage; import java.lang.management.MemoryUsage;
import java.lang.management.MemoryType; import java.lang.management.MemoryType;
import java.lang.management.MemoryManagerMXBean; import java.lang.management.MemoryManagerMXBean;
import javax.management.openmbean.CompositeData; import javax.management.openmbean.CompositeData;
import javax.management.ObjectName;
import static java.lang.management.MemoryNotificationInfo.*; import static java.lang.management.MemoryNotificationInfo.*;
...@@ -114,7 +115,7 @@ class MemoryPoolImpl implements MemoryPoolMXBean { ...@@ -114,7 +115,7 @@ class MemoryPoolImpl implements MemoryPoolMXBean {
"Usage threshold is not supported"); "Usage threshold is not supported");
} }
ManagementFactory.checkControlAccess(); Util.checkControlAccess();
MemoryUsage usage = getUsage0(); MemoryUsage usage = getUsage0();
if (newThreshold < 0) { if (newThreshold < 0) {
...@@ -159,7 +160,7 @@ class MemoryPoolImpl implements MemoryPoolMXBean { ...@@ -159,7 +160,7 @@ class MemoryPoolImpl implements MemoryPoolMXBean {
} }
public void resetPeakUsage() { public void resetPeakUsage() {
ManagementFactory.checkControlAccess(); Util.checkControlAccess();
synchronized (this) { synchronized (this) {
// synchronized since getPeakUsage may be called concurrently // synchronized since getPeakUsage may be called concurrently
...@@ -211,7 +212,7 @@ class MemoryPoolImpl implements MemoryPoolMXBean { ...@@ -211,7 +212,7 @@ class MemoryPoolImpl implements MemoryPoolMXBean {
"CollectionUsage threshold is not supported"); "CollectionUsage threshold is not supported");
} }
ManagementFactory.checkControlAccess(); Util.checkControlAccess();
MemoryUsage usage = getUsage0(); MemoryUsage usage = getUsage0();
if (newThreshold < 0) { if (newThreshold < 0) {
...@@ -304,7 +305,7 @@ class MemoryPoolImpl implements MemoryPoolMXBean { ...@@ -304,7 +305,7 @@ class MemoryPoolImpl implements MemoryPoolMXBean {
} }
void triggerAction() { void triggerAction() {
// Should not reach here // Should not reach here
throw new InternalError(); throw new AssertionError("Should not reach here");
} }
void clearAction() { void clearAction() {
// do nothing // do nothing
...@@ -332,10 +333,15 @@ class MemoryPoolImpl implements MemoryPoolMXBean { ...@@ -332,10 +333,15 @@ class MemoryPoolImpl implements MemoryPoolMXBean {
} }
void triggerAction() { void triggerAction() {
// Should not reach here // Should not reach here
throw new InternalError(); throw new AssertionError("Should not reach here");
} }
void clearAction() { void clearAction() {
// do nothing // do nothing
} }
} }
public ObjectName getObjectName() {
return Util.newObjectName(ManagementFactory.MEMORY_POOL_MXBEAN_DOMAIN_TYPE, getName());
}
} }
...@@ -68,7 +68,7 @@ public class MemoryUsageCompositeData extends LazyCompositeData { ...@@ -68,7 +68,7 @@ public class MemoryUsageCompositeData extends LazyCompositeData {
memoryUsageItemValues); memoryUsageItemValues);
} catch (OpenDataException e) { } catch (OpenDataException e) {
// Should never reach here // Should never reach here
throw Util.newInternalError(e); throw new AssertionError(e);
} }
} }
...@@ -79,7 +79,7 @@ public class MemoryUsageCompositeData extends LazyCompositeData { ...@@ -79,7 +79,7 @@ public class MemoryUsageCompositeData extends LazyCompositeData {
MappedMXBeanType.toOpenType(MemoryUsage.class); MappedMXBeanType.toOpenType(MemoryUsage.class);
} catch (OpenDataException e) { } catch (OpenDataException e) {
// Should never reach here // Should never reach here
throw Util.newInternalError(e); throw new AssertionError(e);
} }
} }
......
...@@ -81,7 +81,7 @@ public class MonitorInfoCompositeData extends LazyCompositeData { ...@@ -81,7 +81,7 @@ public class MonitorInfoCompositeData extends LazyCompositeData {
values); values);
} catch (OpenDataException e) { } catch (OpenDataException e) {
// Should never reach here // Should never reach here
throw Util.newInternalError(e); throw new AssertionError(e);
} }
} }
...@@ -95,7 +95,7 @@ public class MonitorInfoCompositeData extends LazyCompositeData { ...@@ -95,7 +95,7 @@ public class MonitorInfoCompositeData extends LazyCompositeData {
monitorInfoItemNames = (String[]) s.toArray(new String[0]); monitorInfoItemNames = (String[]) s.toArray(new String[0]);
} catch (OpenDataException e) { } catch (OpenDataException e) {
// Should never reach here // Should never reach here
throw Util.newInternalError(e); throw new AssertionError(e);
} }
} }
......
...@@ -156,7 +156,7 @@ abstract class NotificationEmitterSupport implements NotificationEmitter { ...@@ -156,7 +156,7 @@ abstract class NotificationEmitterSupport implements NotificationEmitter {
li.listener.handleNotification(notification, li.handback); li.listener.handleNotification(notification, li.handback);
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
throw new InternalError("Error in invoking listener"); throw new AssertionError("Error in invoking listener");
} }
} }
} }
......
...@@ -26,6 +26,8 @@ ...@@ -26,6 +26,8 @@
package sun.management; package sun.management;
import java.lang.management.OperatingSystemMXBean; import java.lang.management.OperatingSystemMXBean;
import java.lang.management.ManagementFactory;
import javax.management.ObjectName;
import sun.misc.Unsafe; import sun.misc.Unsafe;
/** /**
...@@ -71,4 +73,9 @@ public class OperatingSystemImpl implements OperatingSystemMXBean { ...@@ -71,4 +73,9 @@ public class OperatingSystemImpl implements OperatingSystemMXBean {
return -1.0; return -1.0;
} }
} }
public ObjectName getObjectName() {
return Util.newObjectName(ManagementFactory.OPERATING_SYSTEM_MXBEAN_NAME);
}
} }
...@@ -26,6 +26,7 @@ ...@@ -26,6 +26,7 @@
package sun.management; package sun.management;
import java.lang.management.RuntimeMXBean; import java.lang.management.RuntimeMXBean;
import java.lang.management.ManagementFactory;
import java.util.List; import java.util.List;
import java.util.HashMap; import java.util.HashMap;
...@@ -38,6 +39,7 @@ import javax.management.openmbean.CompositeType; ...@@ -38,6 +39,7 @@ import javax.management.openmbean.CompositeType;
import javax.management.openmbean.OpenType; import javax.management.openmbean.OpenType;
import javax.management.openmbean.SimpleType; import javax.management.openmbean.SimpleType;
import javax.management.openmbean.OpenDataException; import javax.management.openmbean.OpenDataException;
import javax.management.ObjectName;
/** /**
* Implementation class for the runtime subsystem. * Implementation class for the runtime subsystem.
...@@ -104,12 +106,12 @@ class RuntimeImpl implements RuntimeMXBean { ...@@ -104,12 +106,12 @@ class RuntimeImpl implements RuntimeMXBean {
throw new UnsupportedOperationException( throw new UnsupportedOperationException(
"Boot class path mechanism is not supported"); "Boot class path mechanism is not supported");
} }
ManagementFactory.checkMonitorAccess(); Util.checkMonitorAccess();
return jvm.getBootClassPath(); return jvm.getBootClassPath();
} }
public List<String> getInputArguments() { public List<String> getInputArguments() {
ManagementFactory.checkMonitorAccess(); Util.checkMonitorAccess();
return jvm.getVmArguments(); return jvm.getVmArguments();
} }
...@@ -145,4 +147,9 @@ class RuntimeImpl implements RuntimeMXBean { ...@@ -145,4 +147,9 @@ class RuntimeImpl implements RuntimeMXBean {
return map; return map;
} }
public ObjectName getObjectName() {
return Util.newObjectName(ManagementFactory.RUNTIME_MXBEAN_NAME);
}
} }
...@@ -76,7 +76,7 @@ public class StackTraceElementCompositeData extends LazyCompositeData { ...@@ -76,7 +76,7 @@ public class StackTraceElementCompositeData extends LazyCompositeData {
stackTraceElementItemValues); stackTraceElementItemValues);
} catch (OpenDataException e) { } catch (OpenDataException e) {
// Should never reach here // Should never reach here
throw Util.newInternalError(e); throw new AssertionError(e);
} }
} }
...@@ -87,7 +87,7 @@ public class StackTraceElementCompositeData extends LazyCompositeData { ...@@ -87,7 +87,7 @@ public class StackTraceElementCompositeData extends LazyCompositeData {
MappedMXBeanType.toOpenType(StackTraceElement.class); MappedMXBeanType.toOpenType(StackTraceElement.class);
} catch (OpenDataException e) { } catch (OpenDataException e) {
// Should never reach here // Should never reach here
throw Util.newInternalError(e); throw new AssertionError(e);
} }
} }
......
...@@ -26,6 +26,7 @@ ...@@ -26,6 +26,7 @@
package sun.management; package sun.management;
import java.lang.management.ThreadMXBean; import java.lang.management.ThreadMXBean;
import java.lang.management.ManagementFactory;
import java.lang.management.ThreadInfo; import java.lang.management.ThreadInfo;
import java.lang.management.LockInfo; import java.lang.management.LockInfo;
...@@ -33,6 +34,8 @@ import java.lang.management.MonitorInfo; ...@@ -33,6 +34,8 @@ import java.lang.management.MonitorInfo;
import java.util.Map; import java.util.Map;
import java.util.HashMap; import java.util.HashMap;
import javax.management.ObjectName;
/** /**
* Implementation class for the thread subsystem. * Implementation class for the thread subsystem.
* Standard and committed hotspot-specific metrics if any. * Standard and committed hotspot-specific metrics if any.
...@@ -102,7 +105,7 @@ class ThreadImpl implements ThreadMXBean { ...@@ -102,7 +105,7 @@ class ThreadImpl implements ThreadMXBean {
} }
public long[] getAllThreadIds() { public long[] getAllThreadIds() {
ManagementFactory.checkMonitorAccess(); Util.checkMonitorAccess();
Thread[] threads = getThreads(); Thread[] threads = getThreads();
int length = threads.length; int length = threads.length;
...@@ -156,7 +159,7 @@ class ThreadImpl implements ThreadMXBean { ...@@ -156,7 +159,7 @@ class ThreadImpl implements ThreadMXBean {
"Invalid maxDepth parameter: " + maxDepth); "Invalid maxDepth parameter: " + maxDepth);
} }
ManagementFactory.checkMonitorAccess(); Util.checkMonitorAccess();
ThreadInfo[] infos = new ThreadInfo[ids.length]; ThreadInfo[] infos = new ThreadInfo[ids.length];
if (maxDepth == Integer.MAX_VALUE) { if (maxDepth == Integer.MAX_VALUE) {
...@@ -175,7 +178,7 @@ class ThreadImpl implements ThreadMXBean { ...@@ -175,7 +178,7 @@ class ThreadImpl implements ThreadMXBean {
"Thread contention monitoring is not supported"); "Thread contention monitoring is not supported");
} }
ManagementFactory.checkControlAccess(); Util.checkControlAccess();
synchronized (this) { synchronized (this) {
if (contentionMonitoringEnabled != enable) { if (contentionMonitoringEnabled != enable) {
...@@ -297,7 +300,7 @@ class ThreadImpl implements ThreadMXBean { ...@@ -297,7 +300,7 @@ class ThreadImpl implements ThreadMXBean {
"Thread CPU time measurement is not supported"); "Thread CPU time measurement is not supported");
} }
ManagementFactory.checkControlAccess(); Util.checkControlAccess();
synchronized (this) { synchronized (this) {
if (cpuTimeEnabled != enable) { if (cpuTimeEnabled != enable) {
// update VM of the state change // update VM of the state change
...@@ -308,7 +311,7 @@ class ThreadImpl implements ThreadMXBean { ...@@ -308,7 +311,7 @@ class ThreadImpl implements ThreadMXBean {
} }
public long[] findMonitorDeadlockedThreads() { public long[] findMonitorDeadlockedThreads() {
ManagementFactory.checkMonitorAccess(); Util.checkMonitorAccess();
Thread[] threads = findMonitorDeadlockedThreads0(); Thread[] threads = findMonitorDeadlockedThreads0();
if (threads == null) { if (threads == null) {
...@@ -329,7 +332,7 @@ class ThreadImpl implements ThreadMXBean { ...@@ -329,7 +332,7 @@ class ThreadImpl implements ThreadMXBean {
"Monitoring of Synchronizer Usage is not supported."); "Monitoring of Synchronizer Usage is not supported.");
} }
ManagementFactory.checkMonitorAccess(); Util.checkMonitorAccess();
Thread[] threads = findDeadlockedThreads0(); Thread[] threads = findDeadlockedThreads0();
if (threads == null) { if (threads == null) {
...@@ -345,7 +348,7 @@ class ThreadImpl implements ThreadMXBean { ...@@ -345,7 +348,7 @@ class ThreadImpl implements ThreadMXBean {
} }
public void resetPeakThreadCount() { public void resetPeakThreadCount() {
ManagementFactory.checkControlAccess(); Util.checkControlAccess();
resetPeakThreadCount0(); resetPeakThreadCount0();
} }
...@@ -373,7 +376,7 @@ class ThreadImpl implements ThreadMXBean { ...@@ -373,7 +376,7 @@ class ThreadImpl implements ThreadMXBean {
"Monitoring of Synchronizer Usage is not supported."); "Monitoring of Synchronizer Usage is not supported.");
} }
ManagementFactory.checkMonitorAccess(); Util.checkMonitorAccess();
return dumpThreads0(ids, lockedMonitors, lockedSynchronizers); return dumpThreads0(ids, lockedMonitors, lockedSynchronizers);
} }
...@@ -388,7 +391,7 @@ class ThreadImpl implements ThreadMXBean { ...@@ -388,7 +391,7 @@ class ThreadImpl implements ThreadMXBean {
"Monitoring of Synchronizer Usage is not supported."); "Monitoring of Synchronizer Usage is not supported.");
} }
ManagementFactory.checkMonitorAccess(); Util.checkMonitorAccess();
return dumpThreads0(null, lockedMonitors, lockedSynchronizers); return dumpThreads0(null, lockedMonitors, lockedSynchronizers);
} }
...@@ -410,4 +413,10 @@ class ThreadImpl implements ThreadMXBean { ...@@ -410,4 +413,10 @@ class ThreadImpl implements ThreadMXBean {
// tid == 0 to reset contention times for all threads // tid == 0 to reset contention times for all threads
private static native void resetContentionTimes0(long tid); private static native void resetContentionTimes0(long tid);
public ObjectName getObjectName() {
return Util.newObjectName(ManagementFactory.THREAD_MXBEAN_NAME);
}
} }
...@@ -126,7 +126,7 @@ public class ThreadInfoCompositeData extends LazyCompositeData { ...@@ -126,7 +126,7 @@ public class ThreadInfoCompositeData extends LazyCompositeData {
threadInfoItemValues); threadInfoItemValues);
} catch (OpenDataException e) { } catch (OpenDataException e) {
// Should never reach here // Should never reach here
throw Util.newInternalError(e); throw new AssertionError(e);
} }
} }
...@@ -209,7 +209,7 @@ public class ThreadInfoCompositeData extends LazyCompositeData { ...@@ -209,7 +209,7 @@ public class ThreadInfoCompositeData extends LazyCompositeData {
v5ItemTypes); v5ItemTypes);
} catch (OpenDataException e) { } catch (OpenDataException e) {
// Should never reach here // Should never reach here
throw Util.newInternalError(e); throw new AssertionError(e);
} }
// Each CompositeData object has its CompositeType associated // Each CompositeData object has its CompositeType associated
......
...@@ -26,48 +26,58 @@ ...@@ -26,48 +26,58 @@
package sun.management; package sun.management;
import java.lang.management.*; import java.lang.management.*;
import static java.lang.management.ManagementFactory.*;
import java.util.List; import java.util.List;
import java.security.Permission;
import javax.management.ObjectName;
import javax.management.MalformedObjectNameException;
import static java.lang.management.ManagementFactory.*;
class Util { class Util {
static String getMBeanObjectName(MemoryPoolMXBean pool) { static RuntimeException newException(Exception e) {
return MEMORY_POOL_MXBEAN_DOMAIN_TYPE + throw new RuntimeException(e);
",name=" + pool.getName();
} }
static String getMBeanObjectName(MemoryManagerMXBean mgr) { private static final String[] EMPTY_STRING_ARRAY = new String[0];
if (mgr instanceof GarbageCollectorMXBean) { static String[] toStringArray(List<String> list) {
return getMBeanObjectName((GarbageCollectorMXBean) mgr); return (String[]) list.toArray(EMPTY_STRING_ARRAY);
} else {
return MEMORY_MANAGER_MXBEAN_DOMAIN_TYPE +
",name=" + mgr.getName();
}
} }
static String getMBeanObjectName(GarbageCollectorMXBean gc) { static ObjectName newObjectName(String name) {
return GARBAGE_COLLECTOR_MXBEAN_DOMAIN_TYPE + return com.sun.jmx.mbeanserver.Util.newObjectName(name);
",name=" + gc.getName();
} }
static RuntimeException newException(Exception e) { public static ObjectName newObjectName(String domainAndType, String name) {
RuntimeException e1 = new RuntimeException(e.getMessage()); return newObjectName(domainAndType + ",name=" + name);
e1.initCause(e);
return e1;
} }
static InternalError newInternalError(Exception e) { private static ManagementPermission monitorPermission =
InternalError e1 = new InternalError(e.getMessage()); new ManagementPermission("monitor");
e1.initCause(e); private static ManagementPermission controlPermission =
return e1; new ManagementPermission("control");
}
static AssertionError newAssertionError(Exception e) { /**
AssertionError e1 = new AssertionError(e.getMessage()); * Check that the current context is trusted to perform monitoring
e1.initCause(e); * or management.
return e1; * <p>
* If the check fails we throw a SecurityException, otherwise
* we return normally.
*
* @exception SecurityException if a security manager exists and if
* the caller does not have ManagementPermission("control").
*/
static void checkAccess(ManagementPermission p)
throws SecurityException {
SecurityManager sm = System.getSecurityManager();
if (sm != null) {
sm.checkPermission(p);
}
} }
private static String[] EMPTY_STRING_ARRAY = new String[0]; static void checkMonitorAccess() throws SecurityException {
static String[] toStringArray(List<String> list) { checkAccess(monitorPermission);
return (String[]) list.toArray(EMPTY_STRING_ARRAY); }
static void checkControlAccess() throws SecurityException {
checkAccess(controlPermission);
} }
} }
...@@ -59,7 +59,7 @@ class VMManagementImpl implements VMManagement { ...@@ -59,7 +59,7 @@ class VMManagementImpl implements VMManagement {
static { static {
version = getVersion0(); version = getVersion0();
if (version == null) { if (version == null) {
throw new InternalError("Invalid Management Version"); throw new AssertionError("Invalid Management Version");
} }
initOptionalSupportFields(); initOptionalSupportFields();
} }
...@@ -244,7 +244,7 @@ class VMManagementImpl implements VMManagement { ...@@ -244,7 +244,7 @@ class VMManagementImpl implements VMManagement {
// was set // was set
noPerfData = true; noPerfData = true;
} catch (IOException e) { } catch (IOException e) {
throw new InternalError(e.getMessage()); throw new AssertionError(e);
} }
return perfInstr; return perfInstr;
} }
......
...@@ -69,7 +69,7 @@ public class VMOptionCompositeData extends LazyCompositeData { ...@@ -69,7 +69,7 @@ public class VMOptionCompositeData extends LazyCompositeData {
vmOptionItemValues); vmOptionItemValues);
} catch (OpenDataException e) { } catch (OpenDataException e) {
// Should never reach here // Should never reach here
throw Util.newInternalError(e); throw new AssertionError(e);
} }
} }
...@@ -80,7 +80,7 @@ public class VMOptionCompositeData extends LazyCompositeData { ...@@ -80,7 +80,7 @@ public class VMOptionCompositeData extends LazyCompositeData {
MappedMXBeanType.toOpenType(VMOption.class); MappedMXBeanType.toOpenType(VMOption.class);
} catch (OpenDataException e) { } catch (OpenDataException e) {
// Should never reach here // Should never reach here
throw Util.newInternalError(e); throw new AssertionError(e);
} }
} }
......
...@@ -29,14 +29,14 @@ ...@@ -29,14 +29,14 @@
*/ */
import java.lang.management.*; import java.lang.management.*;
import java.util.List;
import javax.management.MBeanServer; import javax.management.MBeanServer;
import com.sun.management.HotSpotDiagnosticMXBean; import com.sun.management.HotSpotDiagnosticMXBean;
public class DumpHeap { public class DumpHeap {
public static void main(String[] argv) throws Exception { public static void main(String[] argv) throws Exception {
MBeanServer mbs = ManagementFactory.getPlatformMBeanServer(); List<HotSpotDiagnosticMXBean> list = ManagementFactory.getPlatformMXBeans(HotSpotDiagnosticMXBean.class);
HotSpotDiagnosticMXBean dm = sun.management.ManagementFactory.getDiagnosticMXBean();
System.out.println("Dumping to file: " + argv[0] + " ...."); System.out.println("Dumping to file: " + argv[0] + " ....");
dm.dumpHeap(argv[0], true); list.get(0).dumpHeap(argv[0], true);
} }
} }
...@@ -41,8 +41,9 @@ public class GetDiagnosticOptions { ...@@ -41,8 +41,9 @@ public class GetDiagnosticOptions {
"com.sun.management:type=HotSpotDiagnostic"; "com.sun.management:type=HotSpotDiagnostic";
public static void main(String[] args) throws Exception { public static void main(String[] args) throws Exception {
HotSpotDiagnosticMXBean mbean = List<HotSpotDiagnosticMXBean> list =
sun.management.ManagementFactory.getDiagnosticMXBean(); ManagementFactory.getPlatformMXBeans(HotSpotDiagnosticMXBean.class);
HotSpotDiagnosticMXBean mbean = list.get(0);
checkDiagnosticOptions(mbean); checkDiagnosticOptions(mbean);
MBeanServer mbs = ManagementFactory.getPlatformMBeanServer(); MBeanServer mbs = ManagementFactory.getPlatformMBeanServer();
......
...@@ -34,6 +34,7 @@ import com.sun.management.HotSpotDiagnosticMXBean; ...@@ -34,6 +34,7 @@ import com.sun.management.HotSpotDiagnosticMXBean;
import com.sun.management.VMOption; import com.sun.management.VMOption;
import com.sun.management.VMOption.Origin; import com.sun.management.VMOption.Origin;
import java.lang.management.ManagementFactory; import java.lang.management.ManagementFactory;
import java.util.List;
import javax.management.MBeanServer; import javax.management.MBeanServer;
public class GetVMOption { public class GetVMOption {
...@@ -44,8 +45,9 @@ public class GetVMOption { ...@@ -44,8 +45,9 @@ public class GetVMOption {
"com.sun.management:type=HotSpotDiagnostic"; "com.sun.management:type=HotSpotDiagnostic";
public static void main(String[] args) throws Exception { public static void main(String[] args) throws Exception {
HotSpotDiagnosticMXBean mbean = List<HotSpotDiagnosticMXBean> list =
sun.management.ManagementFactory.getDiagnosticMXBean(); ManagementFactory.getPlatformMXBeans(HotSpotDiagnosticMXBean.class);
HotSpotDiagnosticMXBean mbean = list.get(0);
checkVMOption(mbean); checkVMOption(mbean);
MBeanServer mbs = ManagementFactory.getPlatformMBeanServer(); MBeanServer mbs = ManagementFactory.getPlatformMBeanServer();
......
...@@ -31,11 +31,11 @@ ...@@ -31,11 +31,11 @@
* @run main/othervm -XX:+PrintGCDetails SetVMOption * @run main/othervm -XX:+PrintGCDetails SetVMOption
*/ */
import java.lang.management.ManagementFactory;
import java.util.*; import java.util.*;
import com.sun.management.HotSpotDiagnosticMXBean; import com.sun.management.HotSpotDiagnosticMXBean;
import com.sun.management.VMOption; import com.sun.management.VMOption;
import com.sun.management.VMOption.Origin; import com.sun.management.VMOption.Origin;
import sun.management.ManagementFactory;
import sun.misc.Version; import sun.misc.Version;
public class SetVMOption { public class SetVMOption {
...@@ -44,10 +44,11 @@ public class SetVMOption { ...@@ -44,10 +44,11 @@ public class SetVMOption {
private static String BAD_VALUE = "yes"; private static String BAD_VALUE = "yes";
private static String NEW_VALUE = "false"; private static String NEW_VALUE = "false";
private static String MANAGEMENT_SERVER = "ManagementServer"; private static String MANAGEMENT_SERVER = "ManagementServer";
private static HotSpotDiagnosticMXBean mbean = private static HotSpotDiagnosticMXBean mbean;
ManagementFactory.getDiagnosticMXBean();
public static void main(String[] args) throws Exception { public static void main(String[] args) throws Exception {
List<HotSpotDiagnosticMXBean> list =
ManagementFactory.getPlatformMXBeans(HotSpotDiagnosticMXBean.class);
// The following test is transitional only and should be removed // The following test is transitional only and should be removed
// once build 52 is promoted. // once build 52 is promoted.
......
/*
* Copyright 2008 Sun Microsystems, Inc. All Rights Reserved.
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
*
* This code is free software; you can redistribute it and/or modify it
* under the terms of the GNU General Public License version 2 only, as
* published by the Free Software Foundation.
*
* This code is distributed in the hope that it will be useful, but WITHOUT
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
* version 2 for more details (a copy is included in the LICENSE file that
* accompanied this code).
*
* You should have received a copy of the GNU General Public License version
* 2 along with this work; if not, write to the Free Software Foundation,
* Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
*
* Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa Clara,
* CA 95054 USA or visit www.sun.com if you need additional information or
* have any questions.
*/
/*
* @test
* @bug 6610094
* @summary Basic unit test of ManagementFactory.getPlatformMXBeans()
* and also PlatformManagedObject.getObjectName()
* @author Mandy Chung
*
* @run main GetPlatformMXBeans
*/
import java.lang.management.*;
import static java.lang.management.ManagementFactory.*;
import java.util.*;
import javax.management.*;
public class GetPlatformMXBeans {
private static MBeanServer platformMBeanServer =
getPlatformMBeanServer();
public static void main(String[] argv) throws Exception {
checkPlatformMXBean(getClassLoadingMXBean(),
ClassLoadingMXBean.class,
CLASS_LOADING_MXBEAN_NAME);
checkPlatformMXBean(getCompilationMXBean(),
CompilationMXBean.class,
COMPILATION_MXBEAN_NAME);
checkPlatformMXBean(getMemoryMXBean(),
MemoryMXBean.class,
MEMORY_MXBEAN_NAME);
checkPlatformMXBean(getOperatingSystemMXBean(),
OperatingSystemMXBean.class,
OPERATING_SYSTEM_MXBEAN_NAME);
checkPlatformMXBean(getRuntimeMXBean(),
RuntimeMXBean.class,
RUNTIME_MXBEAN_NAME);
checkPlatformMXBean(getThreadMXBean(),
ThreadMXBean.class,
THREAD_MXBEAN_NAME);
checkGarbageCollectorMXBeans(getGarbageCollectorMXBeans());
checkMemoryManagerMXBeans(getMemoryManagerMXBeans());
checkMemoryPoolMXBeans(getMemoryPoolMXBeans());
}
private static <T extends PlatformManagedObject>
void checkPlatformMXBean(T obj, Class<T> mxbeanInterface,
String mxbeanName) throws Exception
{
int numElements = (obj != null ? 1 : 0);
// verify local list of platform MXBeans
List<? extends PlatformManagedObject> mxbeans =
getPlatformMXBeans(mxbeanInterface);
if (mxbeans.size() != numElements) {
throw new RuntimeException("Unmatched number of platform MXBeans "
+ mxbeans.size() + ". Expected = " + numElements);
}
if (obj != null) {
PlatformManagedObject pmo = mxbeans.get(0);
if (obj != pmo) {
throw new RuntimeException("The list returned by getPlatformMXBeans"
+ " not matched");
}
ObjectName on = new ObjectName(mxbeanName);
if (!on.equals(pmo.getObjectName())) {
throw new RuntimeException("Unmatched ObjectName " +
pmo.getObjectName() + " Expected = " + on);
}
}
// verify platform MXBeans in the platform MBeanServer
mxbeans = getPlatformMXBeans(platformMBeanServer, mxbeanInterface);
if (mxbeans.size() != numElements) {
throw new RuntimeException("Unmatched number of platform MXBeans "
+ mxbeans.size() + ". Expected = " + numElements);
}
}
private static void checkMemoryManagerMXBeans(List<MemoryManagerMXBean> objs)
throws Exception
{
checkPlatformMXBeans(objs, MemoryManagerMXBean.class);
for (MemoryManagerMXBean mxbean : objs) {
String domainAndType;
if (mxbean instanceof GarbageCollectorMXBean) {
domainAndType = GARBAGE_COLLECTOR_MXBEAN_DOMAIN_TYPE;
} else {
domainAndType = MEMORY_MANAGER_MXBEAN_DOMAIN_TYPE;
}
ObjectName on = new ObjectName(domainAndType +
",name=" + mxbean.getName());
if (!on.equals(mxbean.getObjectName())) {
throw new RuntimeException("Unmatched ObjectName " +
mxbean.getObjectName() + " Expected = " + on);
}
}
}
private static void checkMemoryPoolMXBeans(List<MemoryPoolMXBean> objs)
throws Exception
{
checkPlatformMXBeans(objs, MemoryPoolMXBean.class);
for (MemoryPoolMXBean mxbean : objs) {
ObjectName on = new ObjectName(MEMORY_POOL_MXBEAN_DOMAIN_TYPE +
",name=" + mxbean.getName());
if (!on.equals(mxbean.getObjectName())) {
throw new RuntimeException("Unmatched ObjectName " +
mxbean.getObjectName() + " Expected = " + on);
}
}
}
private static void checkGarbageCollectorMXBeans(List<GarbageCollectorMXBean> objs)
throws Exception
{
checkPlatformMXBeans(objs, GarbageCollectorMXBean.class);
for (GarbageCollectorMXBean mxbean : objs) {
ObjectName on = new ObjectName(GARBAGE_COLLECTOR_MXBEAN_DOMAIN_TYPE +
",name=" + mxbean.getName());
if (!on.equals(mxbean.getObjectName())) {
throw new RuntimeException("Unmatched ObjectName " +
mxbean.getObjectName() + " Expected = " + on);
}
}
}
private static <T extends PlatformManagedObject>
void checkPlatformMXBeans(List<T> objs, Class<T> mxbeanInterface)
throws Exception
{
// verify local list of platform MXBeans
List<? extends PlatformManagedObject> mxbeans =
getPlatformMXBeans(mxbeanInterface);
if (objs.size() != mxbeans.size()) {
throw new RuntimeException("Unmatched number of platform MXBeans "
+ mxbeans.size() + ". Expected = " + objs.size());
}
List<T> list = new ArrayList<T>(objs);
for (PlatformManagedObject pmo : mxbeans) {
if (list.contains(pmo)) {
list.remove(pmo);
} else {
throw new RuntimeException(pmo +
" not in the platform MXBean list");
}
}
if (!list.isEmpty()) {
throw new RuntimeException("The list returned by getPlatformMXBeans"
+ " not matched");
}
// verify platform MXBeans in the platform MBeanServer
mxbeans = getPlatformMXBeans(platformMBeanServer, mxbeanInterface);
if (objs.size() != mxbeans.size()) {
throw new RuntimeException("Unmatched number of platform MXBeans "
+ mxbeans.size() + ". Expected = " + objs.size());
}
}
}
/*
* Copyright 2008 Sun Microsystems, Inc. All Rights Reserved.
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
*
* This code is free software; you can redistribute it and/or modify it
* under the terms of the GNU General Public License version 2 only, as
* published by the Free Software Foundation.
*
* This code is distributed in the hope that it will be useful, but WITHOUT
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
* version 2 for more details (a copy is included in the LICENSE file that
* accompanied this code).
*
* You should have received a copy of the GNU General Public License version
* 2 along with this work; if not, write to the Free Software Foundation,
* Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
*
* Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa Clara,
* CA 95054 USA or visit www.sun.com if you need additional information or
* have any questions.
*/
/*
* @test
* @bug 6610094
* @summary Test the OperatingSystemMXBean instance returned by
* ManagementFactory.getPlatformMXBeans()
* @author Mandy Chung
*
* @run main PlatformMXBeanTest
*/
import java.lang.management.*;
import java.util.List;
public class PlatformMXBeanTest {
public static void main(String[] argv) throws Exception {
OperatingSystemMXBean osMBean = getOSPlatformMXBean(OperatingSystemMXBean.class);
// There should have only one single MXBean for the OS MXBean interfaces:
// java.lang.management.OperatingSystemMXBean
// com.sun.management.OperatingSystemMXBean
// com.sun.management.UnixOperatingSystemMXBean
if (osMBean != getOSPlatformMXBean(com.sun.management.OperatingSystemMXBean.class)) {
throw new RuntimeException(
"Invalid com.sun.management.OperatingSystemMXBean instance");
}
if (!System.getProperty("os.name").startsWith("Windows") &&
osMBean != getOSPlatformMXBean(com.sun.management.UnixOperatingSystemMXBean.class)) {
throw new RuntimeException(
"Invalid com.sun.management.UnixOperatingSystemMXBean instance");
}
}
private static <T extends OperatingSystemMXBean>
T getOSPlatformMXBean(Class<T> c) {
List<T> result = ManagementFactory.getPlatformMXBeans(c);
if (result.isEmpty()) {
return null;
} else if (result.size() == 1) {
return result.get(0);
} else {
throw new RuntimeException(c.getName() + " has " +
result.size() + " number of instances");
}
}
}
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册