import com.sun.jmx.snmp.SnmpOid; //导入依赖的package包/类
/**
 * Return a table handler containing the Thread indexes.
 * Indexes are computed from the ThreadId.
 **/
protected SnmpCachedData updateCachedDatas(Object userData) {


    // We are getting all the input args
    final String[] args = JvmRuntimeImpl.getInputArguments(userData);

    // Time stamp for the cache
    final long time = System.currentTimeMillis();
    SnmpOid indexes[] = new SnmpOid[args.length];

    for(int i = 0; i < args.length; i++) {
        indexes[i] = new SnmpOid(i + 1);
    }

    return new SnmpCachedData(time, indexes, args);
}
 

import com.sun.jmx.snmp.SnmpOid; //导入依赖的package包/类
/**
 * Update cahed datas.
 * Obtains a {@link List} of raw datas by calling
 * {@link #getRawDatas(Map,String) getRawDatas((Map)context,getRawDatasKey())}.<br>
 * Then allocate a new {@link TreeMap} to serve as temporary map between
 * names and indexes, and call {@link #updateCachedDatas(Object,List)}
 * with that temporary map as context.<br>
 * Finally replaces the {@link #names} TreeMap by the temporary
 * TreeMap.
 * @param context The request contextual cache allocated by the
 *        {@link JvmContextFactory}.
 **/
protected SnmpCachedData updateCachedDatas(Object context) {

    final Map<Object, Object> userData =
        (context instanceof Map)?Util.<Map<Object, Object>>cast(context):null;

    // Look for memory manager list in request contextual cache.
    final List<?> rawDatas = getRawDatas(userData,getRawDatasKey());

    log.debug("updateCachedDatas","rawDatas.size()=" +
          ((rawDatas==null)?"<no data>":""+rawDatas.size()));

    TreeMap<String,SnmpOid> ctxt = new TreeMap<>();
    final SnmpCachedData result =
        super.updateCachedDatas(ctxt,rawDatas);
    names = ctxt;
    return result;
}
 

import com.sun.jmx.snmp.SnmpOid; //导入依赖的package包/类
/**
 * Return a table handler containing the Thread indexes.
 * Indexes are computed from the ThreadId.
 **/
protected SnmpCachedData updateCachedDatas(Object userData) {


    // We are getting all the input args
    final String[] path =
        JvmRuntimeImpl.getLibraryPath(userData);

    // Time stamp for the cache
    final long time = System.currentTimeMillis();
    final int len = path.length;

    SnmpOid indexes[] = new SnmpOid[len];

    for(int i = 0; i < len; i++) {
        indexes[i] = new SnmpOid(i + 1);
    }

    return new SnmpCachedData(time, indexes, path);
}
 

import com.sun.jmx.snmp.SnmpOid; //导入依赖的package包/类
protected void updateTreeMap(TreeMap<SnmpOid, Object> table, Object userData,
                             SnmpTableHandler mmHandler,
                             SnmpTableHandler mpHandler,
                             Map<String, SnmpOid> poolIndexMap) {
    if (mmHandler instanceof SnmpCachedData) {
        updateTreeMap(table,userData,(SnmpCachedData)mmHandler,
                      mpHandler,poolIndexMap);
        return;
    }

    SnmpOid mmIndex=null;
    while ((mmIndex = mmHandler.getNext(mmIndex))!=null) {
        final MemoryManagerMXBean mmm =
            (MemoryManagerMXBean)mmHandler.getData(mmIndex);
        if (mmm == null) continue;
        updateTreeMap(table,userData,mmm,mmIndex,poolIndexMap);
    }
}
 

import com.sun.jmx.snmp.SnmpOid; //导入依赖的package包/类
/**
 * Compares two indexes for equality.
 *
 * @param index The index to compare <CODE>this</CODE> with.
 *
 * @return <CODE>true</CODE> if the two indexes are equal, <CODE>false</CODE> otherwise.
 */
public boolean equals(SnmpIndex index) {

    if (size != index.getNbComponents())
        return false;

    // The two vectors have the same length.
    // Compare each single element ...
    //
    SnmpOid oid1;
    SnmpOid oid2;
    Vector<SnmpOid> components= index.getComponents();
    for(int i=0; i <size; i++) {
        oid1= oids.elementAt(i);
        oid2= components.elementAt(i);
        if (oid1.equals(oid2) == false)
            return false;
    }
    return true;
}
 

import com.sun.jmx.snmp.SnmpOid; //导入依赖的package包/类
void checkCurrentOid() throws SnmpStatusException {
    if(model != null) {
        SnmpOid oid = new SnmpOid(l.toArray());
        if (SNMP_ADAPTOR_LOGGER.isLoggable(Level.FINEST)) {
            SNMP_ADAPTOR_LOGGER.logp(Level.FINEST, SnmpMib.class.getName(),
                    "checkCurrentOid", "Checking access for : " + oid);
        }
        model.checkAccess(version,
                          principal,
                          securityLevel,
                          pduType,
                          securityModel,
                          contextName,
                          oid);
    }
}
 

import com.sun.jmx.snmp.SnmpOid; //导入依赖的package包/类
/**
 * Sends a trap using SNMP V1 trap format.
 * <BR>The trap is sent to the specified <CODE>SnmpPeer</CODE> destination.
 * The community string used is the one located in the
 * <CODE>SnmpPeer</CODE> parameters
 * (<CODE>SnmpParameters.getRdCommunity() </CODE>).
 *
 * @param peer The <CODE>SnmpPeer</CODE> destination of the trap.
 * @param agentAddr The agent address to be used for the trap.
 * @param enterpOid The enterprise OID to be used for the trap.
 * @param generic The generic number of the trap.
 * @param specific The specific number of the trap.
 * @param varBindList A list of <CODE>SnmpVarBind</CODE> instances or null.
 * @param time The time stamp (overwrite the current time).
 *
 * @exception IOException An I/O error occurred while sending the trap.
 * @exception SnmpStatusException If the trap exceeds the limit
 * defined by <CODE>bufferSize</CODE>.
 *
 * @since 1.5
 */
@Override
public void snmpV1Trap(SnmpPeer peer,
                       SnmpIpAddress agentAddr,
                       SnmpOid enterpOid,
                       int generic,
                       int specific,
                       SnmpVarBindList varBindList,
                       SnmpTimeticks time)
    throws IOException, SnmpStatusException {

    SnmpParameters p = (SnmpParameters) peer.getParams();
    snmpV1Trap(peer.getDestAddr(),
               peer.getDestPort(),
               agentAddr,
               p.getRdCommunity(),
               enterpOid,
               generic,
               specific,
               varBindList,
               time);
}
 

import com.sun.jmx.snmp.SnmpOid; //导入依赖的package包/类
/**
 * Return a table handler containing the Thread indexes.
 * Indexes are computed from the ThreadId.
 **/
protected SnmpCachedData updateCachedDatas(Object userData) {


    // We are getting all the input args
    final String[] path =
        JvmRuntimeImpl.getClassPath(userData);

    // Time stamp for the cache
    final long time = System.currentTimeMillis();
    final int len = path.length;

    SnmpOid indexes[] = new SnmpOid[len];

    for(int i = 0; i < len; i++) {
        indexes[i] = new SnmpOid(i + 1);
    }

    return new SnmpCachedData(time, indexes, path);
}
 

import com.sun.jmx.snmp.SnmpOid; //导入依赖的package包/类
/**
 * Recompute cached data.
 * @param context A context object, valid during the duration of
 *        of the call to this method, and that will be passed to
 *        {@link #getIndex} and {@link #getData}. <br>
 *        This method is intended to be called by
 *        {@link #updateCachedDatas(Object)}. It is assumed that
 *        the context is be allocated by  before this method is called,
 *        and released just after this method has returned.<br>
 *        This class does not use the context object: it is a simple
 *        hook for subclassed.
 * @param rawDatas The table datas from which the cached data will be
 *        computed.
 * @return the computed cached data.
 **/
protected SnmpCachedData updateCachedDatas(Object context, List<?> rawDatas) {
    final int size = ((rawDatas == null)?0:rawDatas.size());
    if (size == 0) return  null;

    final long time = System.currentTimeMillis();
    final Iterator<?> it  = rawDatas.iterator();
    final TreeMap<SnmpOid, Object> map =
            new TreeMap<>(SnmpCachedData.oidComparator);
    for (int rank=0; it.hasNext() ; rank++) {
        final Object  item  = it.next();
        final SnmpOid index = getIndex(context, rawDatas, rank, item);
        final Object  data  = getData(context, rawDatas, rank, item);
        if (index == null) continue;
        map.put(index,data);
    }

    return new SnmpCachedData(time,map);
}
 

import com.sun.jmx.snmp.SnmpOid; //导入依赖的package包/类
public void createNewEntry(SnmpMibSubRequest req, SnmpOid rowOid, int depth)
    throws SnmpStatusException {
    if (factory != null)
        factory.createNewEntry(req, rowOid, depth, this);
    else
        throw new SnmpStatusException(
            SnmpStatusException.snmpRspNoAccess);
}
 

import com.sun.jmx.snmp.SnmpOid; //导入依赖的package包/类
protected SnmpOid getNextOid(SnmpOid oid, Object userData)
    throws SnmpStatusException {
    final boolean dbg = log.isDebugOn();
    if (dbg) log.debug("getNextOid", "previous=" + oid);


    // Get the data handler.
    //
    SnmpTableHandler handler = getHandler(userData);
    if (handler == null) {
        // This should never happen.
        // If we get here it's a bug.
        //
        if (dbg) log.debug("getNextOid", "handler is null!");
        throw new SnmpStatusException(SnmpStatusException.noSuchInstance);
    }

    // Get the next oid
    //
    final SnmpOid next = handler.getNext(oid);
    if (dbg) log.debug("*** **** **** **** getNextOid", "next=" + next);

    // if next is null: we reached the end of the table.
    //
    if (next == null)
        throw new SnmpStatusException(SnmpStatusException.noSuchInstance);

    return next;
}
 

import com.sun.jmx.snmp.SnmpOid; //导入依赖的package包/类
public SnmpOid getEntryOid(int pos) {
    if (entryoids == null) return null;
    // if (pos == -1 || pos >= entryoids.size() ) return null;
    if (pos == -1 || pos >= entrycount ) return null;
    // return (SnmpOid) entryoids.get(pos);
    return entryoids[pos];
}
 

import com.sun.jmx.snmp.SnmpOid; //导入依赖的package包/类
/**
 * Returns the arc of the next columnar object following "var".
 */
public long getNextVarEntryId( SnmpOid rowOid, long var, Object data )
    throws SnmpStatusException {
    long nextvar = node.getNextVarId(var, data);
    while (!isReadableEntryId(rowOid, nextvar, data))
        nextvar = node.getNextVarId(nextvar, data);
    return nextvar;
}
 

import com.sun.jmx.snmp.SnmpOid; //导入依赖的package包/类
public synchronized void addEntry(SnmpOid rowOid, ObjectName objname,
             Object entry)
    throws SnmpStatusException {
    if (! (entry instanceof JvmThreadInstanceEntryMBean) )
        throw new ClassCastException("Entries for Table \"" +
                       "JvmThreadInstanceTable" + "\" must implement the \"" +
                       "JvmThreadInstanceEntryMBean" + "\" interface.");
    super.addEntry(rowOid, objname, entry);
}
 

import com.sun.jmx.snmp.SnmpOid; //导入依赖的package包/类
public synchronized void addEntry(SnmpOid rowOid, ObjectName objname,
             Object entry)
    throws SnmpStatusException {
    if (! (entry instanceof JvmRTClassPathEntryMBean) )
        throw new ClassCastException("Entries for Table \"" +
                       "JvmRTClassPathTable" + "\" must implement the \"" +
                       "JvmRTClassPathEntryMBean" + "\" interface.");
    super.addEntry(rowOid, objname, entry);
}
 

import com.sun.jmx.snmp.SnmpOid; //导入依赖的package包/类
public boolean skipEntryVariable( SnmpOid rowOid, long var, Object data, int pduVersion) {
    try {
        JvmRTClassPathEntryMBean entry = (JvmRTClassPathEntryMBean) getEntry(rowOid);
        synchronized (this) {
            node.setInstance(entry);
            return node.skipVariable(var, data, pduVersion);
        }
    } catch (SnmpStatusException x) {
        return false;
    }
}
 

import com.sun.jmx.snmp.SnmpOid; //导入依赖的package包/类
protected boolean contains(SnmpOid oid, Object userData) {
    // Get the handler.
    //
    SnmpTableHandler handler = getHandler(userData);

    // handler should never be null.
    //
    if (handler == null)
        return false;
    return filter.contains(handler,oid);
}
 

import com.sun.jmx.snmp.SnmpOid; //导入依赖的package包/类
/**
 * Remove the specified entry from the table.
 * Also triggers the removeEntryCB() callback of the
 * {@link com.sun.jmx.snmp.agent.SnmpTableEntryFactory} interface
 * if this node is bound to a factory.
 *
 * <p>
 * @param pos The position of the entry in the table.
 *
 * @param entry The entry to be removed. This parameter is not used
 *              internally, it is simply passed along to the
 *              removeEntryCB() callback.
 *
 * @exception SnmpStatusException if the specified entry couldn't
 *            be removed.
 */
public synchronized void removeEntry(int pos, Object entry)
    throws SnmpStatusException {
    if (pos == -1)
        return;
    if (pos >= size) return;

    Object obj = entry;
    if (entries != null && entries.size() > pos) {
        obj = entries.elementAt(pos);
        entries.removeElementAt(pos);
    }

    ObjectName name = null;
    if (entrynames != null && entrynames.size() > pos) {
        name = entrynames.elementAt(pos);
        entrynames.removeElementAt(pos);
    }

    final SnmpOid rowOid = tableoids[pos];
    removeOid(pos);
    size --;

    if (obj == null) obj = entry;

    if (factory != null)
        factory.removeEntryCb(pos,rowOid,name,obj,this);

    sendNotification(SnmpTableEntryNotification.SNMP_ENTRY_REMOVED,
                     (new Date()).getTime(), obj, name);
}
 

import com.sun.jmx.snmp.SnmpOid; //导入依赖的package包/类
protected SnmpOid getNextOid(SnmpOid oid, Object userData)
    throws SnmpStatusException {
    final boolean dbg = log.isDebugOn();
    try {
        if (dbg) log.debug("getNextOid", "previous=" + oid);


        // Get the data handler.
        //
        SnmpTableHandler handler = getHandler(userData);
        if (handler == null) {
            // This should never happen.
            // If we get here it's a bug.
            //
            if (dbg) log.debug("getNextOid", "handler is null!");
            throw new
                SnmpStatusException(SnmpStatusException.noSuchInstance);
        }

        // Get the next oid
        //
        final SnmpOid next = handler.getNext(oid);
        if (dbg) log.debug("getNextOid", "next=" + next);

        // if next is null: we reached the end of the table.
        //
        if (next == null)
            throw new
                SnmpStatusException(SnmpStatusException.noSuchInstance);

        return next;
    } catch (SnmpStatusException x) {
        if (dbg) log.debug("getNextOid", "End of MIB View: " + x);
        throw x;
    } catch (RuntimeException r) {
        if (dbg) log.debug("getNextOid", "Unexpected exception: " + r);
        if (dbg) log.debug("getNextOid",r);
        throw r;
    }
}
 

import com.sun.jmx.snmp.SnmpOid; //导入依赖的package包/类
public boolean skipEntryVariable( SnmpOid rowOid, long var, Object data, int pduVersion) {
    try {
        JvmRTLibraryPathEntryMBean entry = (JvmRTLibraryPathEntryMBean) getEntry(rowOid);
        synchronized (this) {
            node.setInstance(entry);
            return node.skipVariable(var, data, pduVersion);
        }
    } catch (SnmpStatusException x) {
        return false;
    }
}