expobjecttable.c

snmp的源代码,已经在我的ubuntu下编译通过

/*
 *Copyright(c)2004,Cisco URP imburses and Network Information Center in Beijing University of Posts and Telecommunications researches.
 *
 *All right reserved
 *
 *File Name: expObjectTable.c
 *File Description: expObjectTable MIB operation.
 *
 *Current Version:1.0
 *Author:JianShun Tong
 *Date:2004.8.20
 */


/*
 * This file was generated by mib2c and is intended for use as
 * a mib module for the ucd-snmp snmpd agent. 
 */


/*
 * This should always be included first before anything else 
 */
#include <net-snmp/net-snmp-config.h>
#if HAVE_STDLIB_H
#include <stdlib.h>
#endif
#if HAVE_STRING_H
#include <string.h>
#else
#include <strings.h>
#endif
#ifdef HAVE_LIMITS_H
#include <limits.h>
#endif


/*
 * minimal include directives 
 */
#include <net-snmp/net-snmp-includes.h>
#include <net-snmp/agent/net-snmp-agent-includes.h>

#include "header_complex.h"
#include "expExpressionTable.h"
#include "expObjectTable.h"


/*
 * expObjectTable_variables_oid:
 *   this is the top level oid that we want to register under.  This
 *   is essentially a prefix, with the suffix appearing in the
 *   variable below.
 */
oid             TimeInstance[] = { 1, 3, 6, 1, 2, 1, 1, 3, 0 };

oid             expObjectTable_variables_oid[] =
    { 1, 3, 6, 1, 2, 1, 90, 1, 2, 3 };

/*
 * variable2 expObjectTable_variables:
 */

struct variable2 expObjectTable_variables[] = {
    /*
     * magic number        , variable type , ro/rw , callback fn  , L, oidsuffix 
     */
#define	EXPOBJECTID  2
    {EXPOBJECTID,         ASN_OBJECT_ID, RWRITE, var_expObjectTable, 2, {1, 2}},
#define	EXPOBJECTIDWILDCARD 3
    {EXPOBJECTIDWILDCARD, ASN_INTEGER,   RWRITE, var_expObjectTable, 2, {1, 3}},
#define	EXPOBJECTSAMPLETYPE 4
    {EXPOBJECTSAMPLETYPE, ASN_INTEGER,   RWRITE, var_expObjectTable, 2, {1, 4}},
#define	EXPOBJECTDELTADISCONTINUITYID 5
    {EXPOBJECTDELTADISCONTINUITYID,  ASN_OBJECT_ID, RWRITE, var_expObjectTable, 2, {1, 5}},
#define	EXPOBJECTDISCONTINUITYIDWILDCARD 6
    {EXPOBJECTDISCONTINUITYIDWILDCARD, ASN_INTEGER, RWRITE, var_expObjectTable, 2, {1, 6}},
#define	EXPOBJECTDISCONTINUITYIDTYPE 7
    {EXPOBJECTDISCONTINUITYIDTYPE,     ASN_INTEGER, RWRITE, var_expObjectTable, 2, {1, 7}},
#define	EXPOBJECTCONDITIONAL  8
    {EXPOBJECTCONDITIONAL, ASN_OBJECT_ID, RWRITE, var_expObjectTable, 2, {1, 8}},
#define	EXPOBJECTCONDITIONALWILDCARD  9
    {EXPOBJECTCONDITIONALWILDCARD,     ASN_INTEGER, RWRITE, var_expObjectTable, 2, {1, 9}},
#define	EXPOBJECTENTRYSTATUS  10
    {EXPOBJECTENTRYSTATUS, ASN_INTEGER, RWRITE, var_expObjectTable, 2, {1, 10}}
};


/*
 * global storage of our data, saved in and configured by header_complex() 
 */
extern struct header_complex_index *expExpressionTableStorage;
extern struct header_complex_index *expValueTableStorage;

struct header_complex_index *expObjectTableStorage = NULL;

/*
 * init_expObjectTable():
 *   Initialization routine.  This is called when the agent starts up.
 *   At a minimum, registration of your variables should take place here.
 */
void
init_expObjectTable(void)
{
    DEBUGMSGTL(("expObjectTable", "initializing...  "));


    /*
     * register ourselves with the agent to handle our mib tree 
     */
    REGISTER_MIB("expObjectTable",
                 expObjectTable_variables, variable2,
                 expObjectTable_variables_oid);

    /*
     * register our config handler(s) to deal with registrations 
     */
    snmpd_register_config_handler("expObjectTable", parse_expObjectTable,
                                  NULL, NULL);

    snmp_register_callback(SNMP_CALLBACK_LIBRARY, SNMP_CALLBACK_STORE_DATA,
                           store_expObjectTable, NULL);

    DEBUGMSGTL(("expObjectTable", "done.\n"));
}


struct expObjectTable_data *
create_expObjectTable_data(void)
{
    struct expObjectTable_data *StorageNew;

    StorageNew = SNMP_MALLOC_STRUCT(expObjectTable_data);

    /*
     * fill in default row values here into StorageNew 
     */
    /*
     * fill in values for all tables (even if not
     * appropriate), since its easier to do here than anywhere
     * else 
     */

    StorageNew->expObjectIDWildcard = EXPOBJCETIDWILDCARD_FALSE;
    StorageNew->expObjectSampleType = EXPOBJCETSAMPLETYPE_ABSOLUTEVALUE;
    memdup((unsigned char **)
           &(StorageNew->expObjectDeltaDiscontinuityID),
           (unsigned char *) TimeInstance, sizeof(TimeInstance));
    StorageNew->expObjectDeltaDiscontinuityIDLen =
        sizeof(TimeInstance) / sizeof(oid);




    StorageNew->expObjectDiscontinuityIDWildcard =
        EXPOBJCETDISCONTINUITYIDWILDCARD_FALSE;
    StorageNew->expObjectDiscontinuityIDType =
        EXPOBJECTDISCONTINUITYIDTYPE_TIMETICKS;

    StorageNew->expObjectConditional = calloc(1, sizeof(oid) * 2);      /* 0.0 */
    StorageNew->expObjectConditionalLen = 2;

    StorageNew->expObjectID = calloc(1, sizeof(oid) * 2);       /* 0.0 */
    StorageNew->expObjectIDLen = 2;

    StorageNew->expObjectConditionalWildcard =
        EXPOBJECTCONDITIONALWILDCARD_FALSE;
    StorageNew->storageType = ST_NONVOLATILE;

    return StorageNew;
}

int
expObjectTable_add(struct expObjectTable_data *thedata)
{
    netsnmp_variable_list *vars = NULL;


    DEBUGMSGTL(("expObjectTable", "adding data...  "));
    /*
     * add the index variables to the varbind list, which is 
     * used by header_complex to index the data 
     */


    snmp_varlist_add_variable(&vars, NULL, 0, ASN_OCTET_STR, (char *) thedata->expExpressionOwner, thedata->expExpressionOwnerLen);     /* expExpressionOwner */
    snmp_varlist_add_variable(&vars, NULL, 0, ASN_OCTET_STR, (char *) thedata->expExpressionName, thedata->expExpressionNameLen);       /* expExpressionName */
    snmp_varlist_add_variable(&vars, NULL, 0, ASN_UNSIGNED, (char *) &thedata->expObjectIndex, sizeof(thedata->expObjectIndex));        /* expExpressionName */




    header_complex_add_data(&expObjectTableStorage, vars, thedata);
    DEBUGMSGTL(("expObjectTable", "registered an entry\n"));


    DEBUGMSGTL(("expObjectTable", "done.\n"));
    return SNMPERR_SUCCESS;
}



/*
 * parse_mteTriggerTable():
 *   parses .conf file entries needed to configure the mib.
 */
void
parse_expObjectTable(const char *token, char *line)
{
    size_t          tmpint;
    oid            *tmpoid = NULL;
    struct expObjectTable_data *StorageTmp =
        SNMP_MALLOC_STRUCT(expObjectTable_data);

    DEBUGMSGTL(("expObjectTable", "parsing config...  "));

    if (StorageTmp == NULL) {
        config_perror("malloc failure");
        return;
    }

    line =
        read_config_read_data(ASN_OCTET_STR, line,
                              &StorageTmp->expExpressionOwner,
                              &StorageTmp->expExpressionOwnerLen);
    if (StorageTmp->expExpressionOwner == NULL) {
        config_perror("invalid specification for expExpressionOwner");
        return;
    }

    line =
        read_config_read_data(ASN_OCTET_STR, line,
                              &StorageTmp->expExpressionName,
                              &StorageTmp->expExpressionNameLen);
    if (StorageTmp->expExpressionName == NULL) {
        config_perror("invalid specification for expExpressionName");
        return;
    }

    line =
        read_config_read_data(ASN_UNSIGNED, line,
                              &StorageTmp->expObjectIndex, &tmpint);

    line =
        read_config_read_data(ASN_OBJECT_ID, line,
                              &StorageTmp->expObjectID,
                              &StorageTmp->expObjectIDLen);
    if (StorageTmp->expObjectID == NULL) {
        config_perror("invalid specification for expObjectID");
        return;
    }

    line =
        read_config_read_data(ASN_INTEGER, line,
                              &StorageTmp->expObjectIDWildcard, &tmpint);

    line =
        read_config_read_data(ASN_INTEGER, line,
                              &StorageTmp->expObjectSampleType, &tmpint);

    line =
        read_config_read_data(ASN_OBJECT_ID, line,
                              &StorageTmp->expObjectDeltaDiscontinuityID,
                              &StorageTmp->
                              expObjectDeltaDiscontinuityIDLen);
    if (StorageTmp->expObjectDeltaDiscontinuityID == NULL) {
        config_perror
            ("invalid specification for expObjectDeltaDiscontinuityID");
        return;
    }

    line =
        read_config_read_data(ASN_INTEGER, line,
                              &StorageTmp->
                              expObjectDiscontinuityIDWildcard, &tmpint);

    line =
        read_config_read_data(ASN_INTEGER, line,
                              &StorageTmp->expObjectDiscontinuityIDType,
                              &tmpint);

    line =
        read_config_read_data(ASN_OBJECT_ID, line,
                              &StorageTmp->expObjectConditional,
                              &StorageTmp->expObjectConditionalLen);
    if (StorageTmp->expObjectConditional == NULL) {
        config_perror("invalid specification for expObjectConditional");
        return;
    }

    line =
        read_config_read_data(ASN_INTEGER, line,
                              &StorageTmp->expObjectConditionalWildcard,
                              &tmpint);

    line =
        read_config_read_data(ASN_INTEGER, line,
                              &StorageTmp->expObjectEntryStatus, &tmpint);

    StorageTmp->storageType = ST_NONVOLATILE;
    expObjectTable_add(StorageTmp);

    DEBUGMSGTL(("expObjectTable", "done.\n"));

}



/*
 * store_expExpressionTable():
 *   stores .conf file entries needed to configure the mib.
 */
int
store_expObjectTable(int majorID, int minorID, void *serverarg,
                     void *clientarg)
{
    char            line[SNMP_MAXBUF];
    char           *cptr;
    size_t          tmpint;
    struct expObjectTable_data *StorageTmp;
    struct header_complex_index *hcindex;

    DEBUGMSGTL(("expObjectTable", "storing data...  "));

    for (hcindex = expObjectTableStorage; hcindex != NULL;
         hcindex = hcindex->next) {
        StorageTmp = (struct expObjectTable_data *) hcindex->data;



        if (StorageTmp->storageType == ST_NONVOLATILE) {

            memset(line, 0, sizeof(line));
            strcat(line, "expObjectTable ");
            cptr = line + strlen(line);
            /*
             * expObjectTable
             */

            cptr =
                read_config_store_data(ASN_OCTET_STR, cptr,
                                       &StorageTmp->expExpressionOwner,
                                       &StorageTmp->expExpressionOwnerLen);
            cptr =
                read_config_store_data(ASN_OCTET_STR, cptr,
                                       &StorageTmp->expExpressionName,
                                       &StorageTmp->expExpressionNameLen);
            cptr =
                read_config_store_data(ASN_UNSIGNED, cptr,
                                       &StorageTmp->expObjectIndex,
                                       &tmpint);
            cptr =
                read_config_store_data(ASN_OBJECT_ID, cptr,
                                       &StorageTmp->expObjectID,
                                       &StorageTmp->expObjectIDLen);
            cptr =
                read_config_store_data(ASN_INTEGER, cptr,
                                       &StorageTmp->expObjectIDWildcard,
                                       &tmpint);
            cptr =
                read_config_store_data(ASN_INTEGER, cptr,
                                       &StorageTmp->expObjectSampleType,
                                       &tmpint);
            cptr =
                read_config_store_data(ASN_OBJECT_ID, cptr,
                                       &StorageTmp->
                                       expObjectDeltaDiscontinuityID,
                                       &StorageTmp->
                                       expObjectDeltaDiscontinuityIDLen);
            cptr =
                read_config_store_data(ASN_INTEGER, cptr,
                                       &StorageTmp->
                                       expObjectDiscontinuityIDWildcard,
                                       &tmpint);
            cptr =
                read_config_store_data(ASN_INTEGER, cptr,
                                       &StorageTmp->
                                       expObjectDiscontinuityIDType,
                                       &tmpint);
            cptr =
                read_config_store_data(ASN_OBJECT_ID, cptr,
                                       &StorageTmp->expObjectConditional,
                                       &StorageTmp->
                                       expObjectConditionalLen);
            cptr =
                read_config_store_data(ASN_INTEGER, cptr,
                                       &StorageTmp->
                                       expObjectConditionalWildcard,
                                       &tmpint);
            cptr =
                read_config_store_data(ASN_INTEGER, cptr,
                                       &StorageTmp->expObjectEntryStatus,
                                       &tmpint);
            snmpd_store_config(line);
        }
    }
    DEBUGMSGTL(("expObjectTable", "storage done\n"));
}


/*
 * var_expObjectTable():
 *   Handle this table separately from the scalar value case.
 *   The workings of this are basically the same as for var_expObjectTable above.
 */
unsigned char  *
var_expObjectTable(struct variable *vp,
                   oid * name,
                   size_t *length,
                   int exact, size_t *var_len, WriteMethod ** write_method)
{
    struct expObjectTable_data *StorageTmp = NULL;


    DEBUGMSGTL(("expObjectTable", "var_expObjectTable: Entering...  \n"));
    /*
     * this assumes you have registered all your data properly
     */
    if ((StorageTmp =
         header_complex(expObjectTableStorage, vp, name, length, exact,
                        var_len, write_method)) == NULL) {
        if (vp->magic == EXPOBJECTENTRYSTATUS)
            *write_method = write_expObjectEntryStatus;
        return NULL;
    }
    /*
     * this is where we do the value assignments for the mib results.
     */
    switch (vp->magic) {

    case EXPOBJECTID:
        *write_method = write_expObjectID;
        *var_len = StorageTmp->expObjectIDLen * sizeof(oid);
        return (u_char *) StorageTmp->expObjectID;

    case EXPOBJECTIDWILDCARD:
        *write_method = write_expObjectIDWildcard;
        *var_len = sizeof(StorageTmp->expObjectIDWildcard);
        return (u_char *) & StorageTmp->expObjectIDWildcard;

    case EXPOBJECTSAMPLETYPE:
        *write_method = write_expObjectSampleType;
        *var_len = sizeof(StorageTmp->expObjectSampleType);
        return (u_char *) & StorageTmp->expObjectSampleType;

    case EXPOBJECTDELTADISCONTINUITYID:
        *write_method = write_expObjectDeltaDiscontinuityID;
        *var_len =
            StorageTmp->expObjectDeltaDiscontinuityIDLen * sizeof(oid);
        return (u_char *) StorageTmp->expObjectDeltaDiscontinuityID;

    case EXPOBJECTDISCONTINUITYIDWILDCARD:
        *write_method = write_expObjectDiscontinuityIDWildcard;
        *var_len = sizeof(StorageTmp->expObjectDiscontinuityIDWildcard);
        return (u_char *) & StorageTmp->expObjectDiscontinuityIDWildcard;

    case EXPOBJECTDISCONTINUITYIDTYPE:
        *write_method = write_expObjectDiscontinuityIDWildcard;
        *var_len = sizeof(StorageTmp->expObjectDiscontinuityIDType);
        return (u_char *) & StorageTmp->expObjectDiscontinuityIDType;

    case EXPOBJECTCONDITIONAL:
        *write_method = write_expObjectConditional;
        *var_len = StorageTmp->expObjectConditionalLen * sizeof(oid);
        return (u_char *) StorageTmp->expObjectConditional;

    case EXPOBJECTCONDITIONALWILDCARD:
        *write_method = write_expObjectConditionalWildcard;
        *var_len = sizeof(StorageTmp->expObjectConditionalWildcard);
        return (u_char *) & StorageTmp->expObjectConditionalWildcard;

    case EXPOBJECTENTRYSTATUS:
        *write_method = write_expObjectEntryStatus;
        *var_len = sizeof(StorageTmp->expObjectEntryStatus);
        return (u_char *) & StorageTmp->expObjectEntryStatus;


    default:
        ERROR_MSG("");
    }
    return NULL;
}