import com.sun.jmx.snmp.SnmpStatusException; //导入依赖的package包/类
/**
 * Get the value of a scalar variable
 */
public SnmpValue get(long var, Object data)
    throws SnmpStatusException {
    switch((int)var) {
        case 4:
            return new SnmpInt(node.getJvmOSProcessorCount());

        case 3:
            return new SnmpString(node.getJvmOSVersion());

        case 2:
            return new SnmpString(node.getJvmOSArch());

        case 1:
            return new SnmpString(node.getJvmOSName());

        default:
            break;
    }
    throw new SnmpStatusException(SnmpStatusException.noSuchObject);
}
 

import com.sun.jmx.snmp.SnmpStatusException; //导入依赖的package包/类
public static int mapSetException(int errorStatus, int version)
    throws SnmpStatusException {

    final int errorCode = errorStatus;

    if (version == SnmpDefinitions.snmpVersionOne)
        return errorCode;

    int mappedErrorCode = errorCode;

    // Now take care of V2 errorCodes that can be stored
    // in the varbind itself:
    if (errorCode == SnmpStatusException.noSuchObject)
        // noSuchObject => notWritable
        mappedErrorCode = SnmpStatusException.snmpRspNotWritable;

    else if (errorCode == SnmpStatusException.noSuchInstance)
        // noSuchInstance => notWritable
        mappedErrorCode = SnmpStatusException.snmpRspNotWritable;

    return mappedErrorCode;
}
 

import com.sun.jmx.snmp.SnmpStatusException; //导入依赖的package包/类
public final SnmpOid getNext(SnmpOid index) {
    int pos = 0;
    if (index == null) {
        if( (datas!= null) && (datas.length >= 1) )
            return new SnmpOid(0);
    }
    try {
        pos = (int) index.getOidArc(0);
    }catch(SnmpStatusException e) {
        return null;
    }

    if(pos < (datas.length - 1))
        return new SnmpOid(pos+1);
    else
        return null;
}
 

import com.sun.jmx.snmp.SnmpStatusException; //导入依赖的package包/类
/**
 * Generic handling of the <CODE>set</CODE> operation.
 * <p> The default implementation of this method is to
 * call the generated
 * <CODE>set(req,oid,depth+1)</CODE> method.
 * <p>
 * <pre>
 * public void set(SnmpMibSubRequest req, int depth)
 *    throws SnmpStatusException {
 *    final SnmpOid oid = req.getEntryOid();
 *    final int  action = getRowAction(req,oid,depth+1);
 *
 *    set(req,oid,depth+1);
 *    endRowAction(req,oid,depth+1,action);
 * }
 * </pre>
 * <p> You should not need to override this method in any cases, because
 * it will eventually call
 * <CODE>set(SnmpMibSubRequest req, int depth)</CODE> on the generated
 * derivative of <CODE>SnmpMibEntry</CODE>. If you need to implement
 * specific policies for minimizing the accesses made to some remote
 * underlying resources, or if you need to implement some consistency
 * checks between the different values provided in the varbind list,
 * you should then rather override
 * <CODE>set(SnmpMibSubRequest req, int depth)</CODE> on the generated
 * derivative of <CODE>SnmpMibEntry</CODE>.
 * <p>
 *
 */
@Override
public void set(SnmpMibSubRequest req, int depth)
    throws SnmpStatusException {


    if (SNMP_ADAPTOR_LOGGER.isLoggable(Level.FINEST)) {
        SNMP_ADAPTOR_LOGGER.logp(Level.FINEST, SnmpMibTable.class.getName(),
                "set", "Entering set");
    }

    final SnmpOid     oid    = req.getEntryOid();
    final int         action = getRowAction(req,oid,depth+1);

    if (SNMP_ADAPTOR_LOGGER.isLoggable(Level.FINEST)) {
        SNMP_ADAPTOR_LOGGER.logp(Level.FINEST, SnmpMibTable.class.getName(),
                "set", "Calling set for " + req.getSize() + " varbinds");
    }

    set(req,oid,depth+1);

    if (SNMP_ADAPTOR_LOGGER.isLoggable(Level.FINEST)) {
        SNMP_ADAPTOR_LOGGER.logp(Level.FINEST, SnmpMibTable.class.getName(),
                "set", "Calling endRowAction");
    }

    endRowAction(req,oid,depth+1,action);

    if (SNMP_ADAPTOR_LOGGER.isLoggable(Level.FINEST)) {
        SNMP_ADAPTOR_LOGGER.logp(Level.FINEST, SnmpMibTable.class.getName(),
                "set", "RowAction finished");
    }

}
 

import com.sun.jmx.snmp.SnmpStatusException; //导入依赖的package包/类
/**
 * Check the value of a scalar variable
 */
public void check(SnmpValue x, long var, Object data)
    throws SnmpStatusException {
    switch((int) var) {
        case 2:
            throw new SnmpStatusException(SnmpStatusException.snmpRspNotWritable);

        case 1:
            throw new SnmpStatusException(SnmpStatusException.snmpRspNotWritable);

        default:
            throw new SnmpStatusException(SnmpStatusException.snmpRspNotWritable);
    }
}
 

import com.sun.jmx.snmp.SnmpStatusException; //导入依赖的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.SnmpStatusException; //导入依赖的package包/类
/**
 * Get the value of a scalar variable
 */
public SnmpValue get(long var, Object data)
    throws SnmpStatusException {
    switch((int)var) {
        case 2:
            return new SnmpString(node.getJvmRTClassPathItem());

        case 1:
            throw new SnmpStatusException(SnmpStatusException.noSuchInstance);
        default:
            break;
    }
    throw new SnmpStatusException(SnmpStatusException.noSuchObject);
}
 

import com.sun.jmx.snmp.SnmpStatusException; //导入依赖的package包/类
/**
 * Check the value of a scalar variable
 */
public void check(SnmpValue x, long var, Object data)
    throws SnmpStatusException {
    switch((int) var) {
        case 3:
            throw new SnmpStatusException(SnmpStatusException.snmpRspNotWritable);

        case 2:
            throw new SnmpStatusException(SnmpStatusException.snmpRspNotWritable);

        default:
            throw new SnmpStatusException(SnmpStatusException.snmpRspNotWritable);
    }
}
 

import com.sun.jmx.snmp.SnmpStatusException; //导入依赖的package包/类
/**
 * Return the name of the attribute corresponding to the SNMP variable identified by "id".
 */
public String getAttributeName(long id)
    throws SnmpStatusException {
    switch((int)id) {
        case 6:
            return "JvmThreadCpuTimeMonitoring";

        case 5:
            return "JvmThreadContentionMonitoring";

        case 4:
            return "JvmThreadTotalStartedCount";

        case 3:
            return "JvmThreadPeakCount";

        case 2:
            return "JvmThreadDaemonCount";

        case 1:
            return "JvmThreadCount";

        case 10: {
            throw new SnmpStatusException(SnmpStatusException.noSuchInstance);
            }

        case 7:
            return "JvmThreadPeakCountReset";

        default:
            break;
    }
    throw new SnmpStatusException(SnmpStatusException.noSuchObject);
}
 

import com.sun.jmx.snmp.SnmpStatusException; //导入依赖的package包/类
/**
 * Getter for the "JvmThreadInstLockedOwnerId" variable.
 */
public String getJvmThreadInstLockOwnerPtr() throws SnmpStatusException {
   long id = info.getLockOwnerId();

   if(id == -1)
       return new String("0.0");

   SnmpOid oid = JvmThreadInstanceTableMetaImpl.makeOid(id);

   return getJvmThreadInstIndexOid() + "." + oid.toString();
}
 

import com.sun.jmx.snmp.SnmpStatusException; //导入依赖的package包/类
/**
 * Setter for the "JvmMemoryGCVerboseLevel" variable.
 */
public void setJvmMemoryGCVerboseLevel(EnumJvmMemoryGCVerboseLevel x)
    throws SnmpStatusException {
    if (JvmMemoryGCVerboseLevelVerbose.intValue() == x.intValue())
        ManagementFactory.getMemoryMXBean().setVerbose(true);
    else
        ManagementFactory.getMemoryMXBean().setVerbose(false);
}
 

import com.sun.jmx.snmp.SnmpStatusException; //导入依赖的package包/类
public static String getJvmThreadInstIndexOid()
    throws SnmpStatusException {
    if (jvmThreadInstIndexOid == null) {
        final SnmpOidTable  table = new JVM_MANAGEMENT_MIBOidTable();
        final SnmpOidRecord record =
            table.resolveVarName("jvmThreadInstIndex");
        jvmThreadInstIndexOid = record.getOid();
    }
    return jvmThreadInstIndexOid;
}
 

import com.sun.jmx.snmp.SnmpStatusException; //导入依赖的package包/类
/**
 * Getter for the "JvmMemPoolCollectThreshold" variable.
 */
public Long getJvmMemPoolCollectThreshold() throws SnmpStatusException {
    if (!pool.isCollectionUsageThresholdSupported())
        return JvmMemoryImpl.Long0;
    final long val = pool.getCollectionUsageThreshold();
    if (val > -1) return  new Long(val);
    else return JvmMemoryImpl.Long0;
}
 

import com.sun.jmx.snmp.SnmpStatusException; //导入依赖的package包/类
/**
 * Get the value of a scalar variable
 */
public SnmpValue get(long var, Object data)
    throws SnmpStatusException {
    switch((int)var) {
        case 2:
            return new SnmpString(node.getJvmRTLibraryPathItem());

        case 1:
            throw new SnmpStatusException(SnmpStatusException.noSuchInstance);
        default:
            break;
    }
    throw new SnmpStatusException(SnmpStatusException.noSuchObject);
}
 

import com.sun.jmx.snmp.SnmpStatusException; //导入依赖的package包/类
/**
 * Getter for the "JvmMemPoolThreshdSupport" variable.
 */
public EnumJvmMemPoolCollectThreshdSupport
    getJvmMemPoolCollectThreshdSupport()
    throws SnmpStatusException {
    if (pool.isCollectionUsageThresholdSupported())
        return EnumJvmMemPoolCollectThreshdSupported;
    else
        return EnumJvmMemPoolCollectThreshdUnsupported;
}
 

import com.sun.jmx.snmp.SnmpStatusException; //导入依赖的package包/类
/**
 * Setter for the "JvmThreadCpuTimeMonitoring" variable.
 */
public void setJvmThreadCpuTimeMonitoring(EnumJvmThreadCpuTimeMonitoring x)
    throws SnmpStatusException {

    ThreadMXBean mbean = getThreadMXBean();

    // We can trust the received value, it has been checked in
    // checkJvmThreadCpuTimeMonitoring
    if(JvmThreadCpuTimeMonitoringEnabled.intValue() == x.intValue())
        mbean.setThreadCpuTimeEnabled(true);
    else
        mbean.setThreadCpuTimeEnabled(false);
}
 

import com.sun.jmx.snmp.SnmpStatusException; //导入依赖的package包/类
static void setRowStatusFail(SnmpMibSubRequest req, int errorStatus)
    throws SnmpStatusException {

    final SnmpVarBind statusvb  = req.getRowStatusVarBind();
    final SnmpStatusException x = new SnmpStatusException(errorStatus);
    req.registerSetException(statusvb,x);
}
 

import com.sun.jmx.snmp.SnmpStatusException; //导入依赖的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.SnmpStatusException; //导入依赖的package包/类
/**
 * Sends a trap using SNMP V1 trap format.
 * <BR>The trap is sent to the specified <CODE>InetAddress</CODE>
 * destination using the specified parameters (and the ACL file is not
 * used).
 * Note that if the specified <CODE>InetAddress</CODE> destination is null,
 * then the ACL file mechanism is used.
 *
 * @param addr The <CODE>InetAddress</CODE> destination of the trap.
 * @param agentAddr The agent address to be used for the trap.
 * @param cs The community string 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
 */
public void snmpV1Trap(InetAddress addr,
                       SnmpIpAddress agentAddr,
                       String cs,
                       SnmpOid enterpOid,
                       int generic,
                       int specific,
                       SnmpVarBindList varBindList,
                       SnmpTimeticks time)
    throws IOException, SnmpStatusException {
    snmpV1Trap(addr,
               trapPort,
               agentAddr,
               cs,
               enterpOid,
               generic,
               specific,
               varBindList,
               time);
}
 

import com.sun.jmx.snmp.SnmpStatusException; //导入依赖的package包/类
/**
 * Sends a trap using SNMP V1 trap format.
 * <BR>The trap is sent to each destination defined in the ACL file
 * (if available).
 * If no ACL file or no destinations are available, the trap is sent
 * to the local host.
 *
 * @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.
 *
 * @exception IOException An I/O error occurred while sending the trap.
 * @exception SnmpStatusException If the trap exceeds the limit defined
 *            by <CODE>bufferSize</CODE>.
 */
@Override
public void snmpV1Trap(int generic, int specific,
                       SnmpVarBindList varBindList)
    throws IOException, SnmpStatusException {

    if (SNMP_ADAPTOR_LOGGER.isLoggable(Level.FINER)) {
        SNMP_ADAPTOR_LOGGER.logp(Level.FINER, dbgTag,
            "snmpV1Trap", "generic=" + generic +
              ", specific=" + specific);
    }

    // First, make an SNMP V1 trap pdu
    //
    SnmpPduTrap pdu = new SnmpPduTrap() ;
    pdu.address = null ;
    pdu.port = trapPort ;
    pdu.type = pduV1TrapPdu ;
    pdu.version = snmpVersionOne ;
    pdu.community = null ;
    pdu.enterprise = enterpriseOid ;
    pdu.genericTrap = generic ;
    pdu.specificTrap = specific ;
    pdu.timeStamp = getSysUpTime();

    if (varBindList != null) {
        pdu.varBindList = new SnmpVarBind[varBindList.size()] ;
        varBindList.copyInto(pdu.varBindList);
    }
    else
        pdu.varBindList = null ;

    // If the local host cannot be determined, we put 0.0.0.0 in agentAddr
    try {
        if (address != null)
            pdu.agentAddr = handleMultipleIpVersion(address.getAddress());
        else pdu.agentAddr =
          handleMultipleIpVersion(InetAddress.getLocalHost().getAddress());
    } catch (UnknownHostException e) {
        byte[] zeroedAddr = new byte[4];
        pdu.agentAddr = handleMultipleIpVersion(zeroedAddr) ;
    }

    // Next, send the pdu to all destinations defined in ACL
    //
    sendTrapPdu(pdu) ;
}