| Methods Summary |
|---|
| private final void | addAllMatching(java.util.Hashtable moiTb, java.util.Set result, com.sun.jmx.mbeanserver.RepositorySupport$ObjectNamePattern pattern)Add all the matching objects from the given hashtable in the
result set for the given ObjectNamePattern
Do not check whether the domains match (only check for matching
key property lists - see matchKeys())
synchronized (moiTb) {
for (Enumeration e = moiTb.elements(); e.hasMoreElements();) {
final NamedObject no = (NamedObject) e.nextElement();
final ObjectName on = no.getName();
// if all couples (property, value) are contained
if (pattern.matchKeys(on)) result.add(no);
}
}
|
| public void | addMBean(java.lang.Object object, javax.management.ObjectName name)Stores an MBean associated with its object name in the repository.
if (isTraceOn()) {
trace("addMBean", "name=" + name);
}
// Extract the domain name.
String dom = name.getDomain().intern();
boolean to_default_domain = false;
// Set domain to default if domain is empty and not already set
if (dom.length() == 0) {
try {
name = new ObjectName(domain + name.toString());
} catch (MalformedObjectNameException e) {
if (isDebugOn()) {
debug("addMBean",
"Unexpected MalformedObjectNameException");
}
}
}
// Do we have default domain ?
if (dom == domain) {
to_default_domain = true;
dom = domain;
} else {
to_default_domain = false;
}
// ------------------------------
// ------------------------------
// Validate name for an object
if (name.isPattern() == true) {
throw new RuntimeOperationsException(
new IllegalArgumentException("Repository: cannot add mbean for pattern name " + name.toString()));
}
// Domain cannot be JMImplementation if entry does not exists
if ( !to_default_domain &&
dom.equals("JMImplementation") &&
domainTb.containsKey("JMImplementation")) {
throw new RuntimeOperationsException(
new IllegalArgumentException(
"Repository: domain name cannot be JMImplementation"));
}
// If domain not already exists, add it to the hash table
final Hashtable moiTb= (Hashtable) domainTb.get(dom);
if (moiTb == null) {
addNewDomMoi(object, dom, name);
return;
}
else {
// Add instance if not already present
String cstr = name.getCanonicalKeyPropertyListString();
Object elmt= moiTb.get(cstr);
if (elmt != null) {
throw new InstanceAlreadyExistsException(name.toString());
} else {
nbElements++;
moiTb.put(cstr, new NamedObject(name, object));
}
}
|
| private final void | addNewDomMoi(java.lang.Object object, java.lang.String dom, javax.management.ObjectName name)
final Hashtable moiTb= new Hashtable();
domainTb.put(dom, moiTb);
moiTb.put(name.getCanonicalKeyPropertyListString(),
new NamedObject(name, object));
nbElements++;
|
| public boolean | contains(javax.management.ObjectName name)Checks whether an MBean of the name specified is already stored in
the repository.
if (isTraceOn()) {
trace("contains", "name=" + name);
}
return (retrieveNamedObject(name) != null);
|
| private static final void | debug(java.lang.String clz, java.lang.String func, java.lang.String info)
Trace.send(Trace.LEVEL_DEBUG, Trace.INFO_MBEANSERVER, clz, func,
info);
|
| private static final void | debug(java.lang.String func, java.lang.String info)
debug(dbgTag, func, info);
|
| public java.lang.Integer | getCount()Gets the number of MBeans stored in the repository.
return new Integer(nbElements);
|
| public java.lang.String | getDefaultDomain()Gets the name of the domain currently used by default in the
repository.
return domain;
|
| public java.lang.String[] | getDomains()Returns the list of domains in which any MBean is currently
registered.
final ArrayList result;
synchronized(domainTb) {
// Temporary list
result = new ArrayList(domainTb.size());
// Loop over all domains
for (Enumeration e = domainTb.keys();e.hasMoreElements();) {
// key = domain name
final String key = (String)e.nextElement();
if (key == null) continue;
// If no MBean in domain continue
final Hashtable t = (Hashtable)domainTb.get(key);
if (t == null || t.size()==0) continue;
// Some MBean are registered => add to result.
result.add(key);
}
}
// Make an array from result.
return (String[]) result.toArray(new String[result.size()]);
|
| private static final boolean | isDebugOn()
return Trace.isSelected(Trace.LEVEL_DEBUG, Trace.INFO_MBEANSERVER);
|
| public boolean | isFiltering()Indicates whether or not the Repository Service supports filtering. If
the Repository Service does not support filtering, the MBean Server
will perform filtering.
// Let the MBeanServer perform the filtering !
return false;
|
| private static final boolean | isTraceOn()
// Private fields <=============================================
// Private methods --------------------------------------------->
// TRACES & DEBUG
//---------------
return Trace.isSelected(Trace.LEVEL_TRACE, Trace.INFO_MBEANSERVER);
|
| public java.util.Set | query(javax.management.ObjectName pattern, javax.management.QueryExp query)Selects and retrieves the list of MBeans whose names match the specified
object name pattern and which match the specified query expression
(optionally).
// ------------------------------
// ------------------------------
ObjectNamePattern on_pattern = null; // intermediate Object name pattern for performance
final HashSet result = new HashSet();
// The following filter cases are considered :
// null, "", "*:*"" : names in all domains
// ":*" : names in defaultDomain
// "domain:*" : names in the specified domain
// "domain:[key=value], *"
// Surely one of the most frequent case ... query on the whole world
ObjectName name = null;
if (pattern == null ||
pattern.getCanonicalName().length() == 0 ||
pattern.equals(_WholeWordQueryObjectName))
name = _WholeWordQueryObjectName;
else name = pattern;
// If pattern is not a pattern, retrieve this mbean !
if (!name.isPattern()) {
final NamedObject no = retrieveNamedObject(name);
if (no != null) result.add(no);
return result;
}
// all names in all domains
if (name == _WholeWordQueryObjectName) {
synchronized(domainTb) {
for(final Enumeration e = domainTb.elements();
e.hasMoreElements();) {
final Hashtable moiTb = (Hashtable) e.nextElement();
result.addAll(moiTb.values());
}
}
return result;
}
String canonical_key_property_list_string = name.getCanonicalKeyPropertyListString();
// all names in default domain
//
// DF: fix 4618986 - take into account the case where the
// property list is not empty.
//
if (name.getDomain().length() == 0) {
final Hashtable moiTb = (Hashtable) domainTb.get(domain);
if (canonical_key_property_list_string.length() == 0) {
result.addAll(moiTb.values());
} else {
if (on_pattern == null)
on_pattern = new ObjectNamePattern(name);
addAllMatching(moiTb,result,on_pattern);
}
return result;
}
// Pattern matching in the domain name (*, ?)
synchronized (domainTb) {
char[] dom2Match = name.getDomain().toCharArray();
String nextDomain;
char [] theDom;
for (final Enumeration enumi = domainTb.keys(); enumi.hasMoreElements();) {
nextDomain = (String) enumi.nextElement();
theDom = nextDomain.toCharArray();
if (wildmatch(theDom, dom2Match, 0, 0)) {
final Hashtable moiTb =
(Hashtable) domainTb.get(nextDomain);
if (canonical_key_property_list_string.length() == 0)
result.addAll(moiTb.values());
else {
if (on_pattern == null)
on_pattern = new ObjectNamePattern(name);
addAllMatching(moiTb,result,on_pattern);
}
}
}
}
return result;
|
| public void | remove(javax.management.ObjectName name)Removes an MBean from the repository.
// Debugging stuff
if (isTraceOn()) {
trace("remove", "name=" + name);
}
// Extract domain name.
String dom= name.getDomain().intern();
// Default domain case
if (dom.length() == 0) dom = domain;
// Find the domain subtable
Object tmp_object = domainTb.get(dom);
if (tmp_object == null) {
throw new InstanceNotFoundException(name.toString());
}
// Remove the corresponding element
Hashtable moiTb= (Hashtable) tmp_object;
if (moiTb.remove(name.getCanonicalKeyPropertyListString()) == null) {
throw new InstanceNotFoundException(name.toString());
}
// We removed it !
nbElements--;
// No more object for this domain, we remove this domain hashtable
if (moiTb.isEmpty()) {
domainTb.remove(dom);
// set a new default domain table (always present)
// need to reinstantiate a hashtable because of possible
// big buckets array size inside table, never cleared,
// thus the new !
if (dom == domain)
domainTb.put(domain, new Hashtable());
}
|
| public java.lang.Object | retrieve(javax.management.ObjectName name)Retrieves the MBean of the name specified from the repository. The
object name must match exactly.
// ------------------------------
// ------------------------------
if (isTraceOn()) {
trace("retrieve", "name=" + name);
}
// Calls internal retrieve method to get the named object
NamedObject no = retrieveNamedObject(name);
if (no == null) return null;
else return no.getObject();
|
| private com.sun.jmx.mbeanserver.NamedObject | retrieveNamedObject(javax.management.ObjectName name)Retrieves the named object contained in repository
from the given objectname.
// No patterns inside reposit
if (name.isPattern() == true) return null;
// Extract the domain name.
String dom= name.getDomain().intern();
// Default domain case
if (dom.length() == 0) {
dom = domain;
}
Object tmp_object = domainTb.get(dom);
if (tmp_object == null) {
return null; // No domain containing registered object names
}
// If name exists in repository, we will get it now
Hashtable moiTb= (Hashtable) tmp_object;
Object o = moiTb.get(name.getCanonicalKeyPropertyListString());
if (o != null ) {
return (NamedObject) o;
}
else return null;
|
| public void | setConfigParameters(java.util.ArrayList configParameters)The purpose of this method is to provide a unified way to provide
whatever configuration information is needed by the specific
underlying implementation of the repository.
return;
|
| private static final void | trace(java.lang.String clz, java.lang.String func, java.lang.String info)
Trace.send(Trace.LEVEL_TRACE, Trace.INFO_MBEANSERVER, clz, func,
info);
|
| private static final void | trace(java.lang.String func, java.lang.String info)
trace(dbgTag, func, info);
|
| private static boolean | wildmatch(char[] s, char[] p, int si, int pi)
char c;
// Be careful: this is dangerous: it works because wildmatch
// is protected by a synchronized block on domainTb
_slen = s.length;
_plen = p.length;
// end of comment.
while (pi < _plen) { // While still string
c = p[pi++];
if (c == '?") {
if (++si > _slen) return false;
} else if (c == '*") { // Wildcard
if (pi >= _plen) return true;
do {
if (wildmatch(s,p,si,pi)) return true;
} while (++si < _slen);
return false;
} else {
if (si >= _slen || c != s[si++]) return false;
}
}
return (si == _slen);
|
