java类javax.management.QueryExp的实例源码-第2页-面圈网

ROConnection.java 文件源码项目：scheduling 阅读 65 收藏 0 点赞 0 评论 0

/**
 * @see javax.management.MBeanServerConnection#queryMBeans(javax.management.ObjectName, javax.management.QueryExp)
 */
@SuppressWarnings("unchecked")
public Set<ObjectInstance> queryMBeans(final ObjectName name, final QueryExp query) throws IOException {
    if (this.context == null) {
        return this.mbs.queryMBeans(name, query);
    }
    try {
        return (Set<ObjectInstance>) Subject.doAsPrivileged(this.subject,
                                                            new PrivilegedExceptionAction<Set<ObjectInstance>>() {
                                                                public final Set<ObjectInstance> run()
                                                                        throws Exception {
                                                                    return mbs.queryMBeans(name, query);
                                                                }
                                                            },
                                                            this.context);
    } catch (final PrivilegedActionException pe) {
        final Exception e = JMXProviderUtils.extractException(pe);
        if (e instanceof IOException)
            throw (IOException) e;
        throw JMXProviderUtils.newIOException("Got unexpected server exception: " + e, e);
    }
}

ROConnection.java 文件源码项目：scheduling 阅读 22 收藏 0 点赞 0 评论 0

/**
 * @see javax.management.MBeanServerConnection#queryNames(javax.management.ObjectName, javax.management.QueryExp)
 */
@SuppressWarnings("unchecked")
public Set<ObjectName> queryNames(final ObjectName name, final QueryExp query) throws IOException {
    if (this.subject == null) {
        return this.mbs.queryNames(name, query);
    }
    try {
        return (Set<ObjectName>) Subject.doAsPrivileged(this.subject,
                                                        new PrivilegedExceptionAction<Set<ObjectName>>() {
                                                            public final Set<ObjectName> run() throws Exception {
                                                                return mbs.queryNames(name, query);
                                                            }
                                                        },
                                                        this.context);
    } catch (final PrivilegedActionException pe) {
        final Exception e = JMXProviderUtils.extractException(pe);
        if (e instanceof IOException)
            throw (IOException) e;
        throw JMXProviderUtils.newIOException("Got unexpected server exception: " + e, e);
    }
}

ArrayNotificationBuffer.java 文件源码项目：infobip-open-jdk-8 阅读 27 收藏 0 点赞 0 评论 0

private Set<ObjectName> queryNames(final ObjectName name,
                                   final QueryExp query) {
    PrivilegedAction<Set<ObjectName>> act =
        new PrivilegedAction<Set<ObjectName>>() {
            public Set<ObjectName> run() {
                return mBeanServer.queryNames(name, query);
            }
        };
    try {
        return AccessController.doPrivileged(act);
    } catch (RuntimeException e) {
        logger.fine("queryNames", "Failed to query names: " + e);
        logger.debug("queryNames", e);
        throw e;
    }
}

RMIConnector.java 文件源码项目：infobip-open-jdk-8 阅读 31 收藏 0 点赞 0 评论 0

public Set<ObjectInstance> queryMBeans(ObjectName name,
        QueryExp query)
        throws IOException {
    if (logger.debugOn()) logger.debug("queryMBeans",
            "name=" + name + ", query=" + query);

    final MarshalledObject<QueryExp> sQuery =
            new MarshalledObject<QueryExp>(query);
    final ClassLoader old = pushDefaultClassLoader();
    try {
        return connection.queryMBeans(name, sQuery, delegationSubject);
    } catch (IOException ioe) {
        communicatorAdmin.gotIOException(ioe);

        return connection.queryMBeans(name, sQuery, delegationSubject);
    } finally {
        popDefaultClassLoader(old);
    }
}

RMIConnector.java 文件源码项目：infobip-open-jdk-8 阅读 25 收藏 0 点赞 0 评论 0

public Set<ObjectName> queryNames(ObjectName name,
        QueryExp query)
        throws IOException {
    if (logger.debugOn()) logger.debug("queryNames",
            "name=" + name + ", query=" + query);

    final MarshalledObject<QueryExp> sQuery =
            new MarshalledObject<QueryExp>(query);
    final ClassLoader old = pushDefaultClassLoader();
    try {
        return connection.queryNames(name, sQuery, delegationSubject);
    } catch (IOException ioe) {
        communicatorAdmin.gotIOException(ioe);

        return connection.queryNames(name, sQuery, delegationSubject);
    } finally {
        popDefaultClassLoader(old);
    }
}

OldMBeanServerTest.java 文件源码项目：infobip-open-jdk-8 阅读 29 收藏 0 点赞 0 评论 0

public Set<ObjectInstance> queryMBeans(ObjectName name, QueryExp query) {
    Set<ObjectInstance> instances = newSet();
    if (name == null)
        name = ObjectName.WILDCARD;
    if (query == null)
        query = trueQuery;
    MBeanServer oldMBS = QueryEval.getMBeanServer();
    try {
        query.setMBeanServer(this);
        for (ObjectName n : mbeans.keySet()) {
            if (name.apply(n)) {
                try {
                    if (query.apply(n))
                        instances.add(getObjectInstance(n));
                } catch (Exception e) {
                    // OK: Ignore this MBean in the result
                }
            }
        }
    } finally {
        query.setMBeanServer(oldMBS);
    }
    return instances;
}

ArrayNotificationBuffer.java 文件源码项目：jdk8u-dev-jdk 阅读 29 收藏 0 点赞 0 评论 0

private Set<ObjectName> queryNames(final ObjectName name,
                                   final QueryExp query) {
    PrivilegedAction<Set<ObjectName>> act =
        new PrivilegedAction<Set<ObjectName>>() {
            public Set<ObjectName> run() {
                return mBeanServer.queryNames(name, query);
            }
        };
    try {
        return AccessController.doPrivileged(act);
    } catch (RuntimeException e) {
        logger.fine("queryNames", "Failed to query names: " + e);
        logger.debug("queryNames", e);
        throw e;
    }
}

RMIConnector.java 文件源码项目：jdk8u-dev-jdk 阅读 25 收藏 0 点赞 0 评论 0

public Set<ObjectInstance> queryMBeans(ObjectName name,
        QueryExp query)
        throws IOException {
    if (logger.debugOn()) logger.debug("queryMBeans",
            "name=" + name + ", query=" + query);

    final MarshalledObject<QueryExp> sQuery =
            new MarshalledObject<QueryExp>(query);
    final ClassLoader old = pushDefaultClassLoader();
    try {
        return connection.queryMBeans(name, sQuery, delegationSubject);
    } catch (IOException ioe) {
        communicatorAdmin.gotIOException(ioe);

        return connection.queryMBeans(name, sQuery, delegationSubject);
    } finally {
        popDefaultClassLoader(old);
    }
}

RMIConnector.java 文件源码项目：jdk8u-dev-jdk 阅读 33 收藏 0 点赞 0 评论 0

public Set<ObjectName> queryNames(ObjectName name,
        QueryExp query)
        throws IOException {
    if (logger.debugOn()) logger.debug("queryNames",
            "name=" + name + ", query=" + query);

    final MarshalledObject<QueryExp> sQuery =
            new MarshalledObject<QueryExp>(query);
    final ClassLoader old = pushDefaultClassLoader();
    try {
        return connection.queryNames(name, sQuery, delegationSubject);
    } catch (IOException ioe) {
        communicatorAdmin.gotIOException(ioe);

        return connection.queryNames(name, sQuery, delegationSubject);
    } finally {
        popDefaultClassLoader(old);
    }
}

OldMBeanServerTest.java 文件源码项目：jdk8u-dev-jdk 阅读 28 收藏 0 点赞 0 评论 0

public Set<ObjectInstance> queryMBeans(ObjectName name, QueryExp query) {
    Set<ObjectInstance> instances = newSet();
    if (name == null)
        name = ObjectName.WILDCARD;
    if (query == null)
        query = trueQuery;
    MBeanServer oldMBS = QueryEval.getMBeanServer();
    try {
        query.setMBeanServer(this);
        for (ObjectName n : mbeans.keySet()) {
            if (name.apply(n)) {
                try {
                    if (query.apply(n))
                        instances.add(getObjectInstance(n));
                } catch (Exception e) {
                    // OK: Ignore this MBean in the result
                }
            }
        }
    } finally {
        query.setMBeanServer(oldMBS);
    }
    return instances;
}