infom.c

嵌入式RMON,RMON为Remote monitor的缩写,基于SNMP为网络提供主动监控及错误告警,智能交换路由必备协议

/* Beholder RMON ethernet network monitor,Copyright (C) 1993 DNPAP group */
/* See file COPYING 'GNU General Public Licence' for copyright details   */
#include <memory.h>
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <dnpap.h>
#include <config.h>
#include <mac.h>
#include <snmp.h>
#include <mibrqs.h>
#include <mibsup.h>
#include <message.h>
#include <channel.h>

#include "infoe.h"
#include "infoc.h"
#include "info.h"


IMPORT BOOLEAN BeholderStrictRMON;


#define INDEXSIZE       1


static MIB_LOCAL    *beholderInfo = NULL;


static BOOLEAN RmonNext (SNMP_OBJECT *Obj, MIB_LOCAL **Local, WORD IdLen, WORD IdSze, BEHOLDER_INFO **Elm);



BOOLEAN InfoMInit(VOID)
{
LONG i, nriface;
CHAR s[81];
BOOLEAN v;

MAC_IFACE *iface;

LONG infosource[] = {1,3,6,1,2,1,2,2,1,1,1};
CHAR infoowner[] = "monitorBeholderInfo";

#define STATUSINDEX     (BTNG_MIBLEN + 4)
SNMP_OBJECT infoobj[] = {
    { SNMP_PDU_SET, {BTNG_MIB,1,1,1,10,1}, (BTNG_MIBLEN + 5), SNMP_INTEGER },
    { SNMP_PDU_SET, {BTNG_MIB,1,1,1,9,1},  (BTNG_MIBLEN + 5), SNMP_DISPLAYSTR },
    { SNMP_PDU_SET, {BTNG_MIB,1,1,1,2,1},  (BTNG_MIBLEN + 5), SNMP_OBJECTID }
};

    MessageConfig(INFO_ERROR, "BeholderInfo");

    nriface = (LONG)MacIfaceCount();
    for (i = 1; i <= nriface; i++)
    {
        sprintf(s, "beholder.info.iface.%ld", i);
        if (ConfigGetBoolean(s, &v) == TRUE)
        {
            iface = MacIfaceGet((WORD)i);
            if (iface != NULL && v == TRUE &&
                (iface->type == MAC_TYPE_ETHERNET_CSMACD ||
                 iface->type == MAC_TYPE_88023_CSMACD))
            {
                infoobj[0].Id[STATUSINDEX] = i;
                infoobj[1].Id[STATUSINDEX] = i;
                infoobj[2].Id[STATUSINDEX] = i;

                infoobj[0].Syntax.LngInt = SNMP_INVALID;
                MibRequest(&infoobj[0]);
                infoobj[0].Syntax.LngInt = SNMP_CREATEREQUEST;
                if (MibRequest(&infoobj[0]) != SNMP_NOERROR)
                {
                    DnpapMessage(DMC_WARNING, INFO_INFOINIT, "beholderInfo: couldn't create beholderInfo collector %ld", i);
                    continue;
                }
                strncpy(infoobj[1].Syntax.BufChr, infoowner, infoobj[1].SyntaxLen = strlen(infoowner));
                if (MibRequest(&infoobj[1]) != SNMP_NOERROR)
                {
                    DnpapMessage(DMC_WARNING, INFO_INFOINIT, "beholderInfo: couldn't set owner of beholderInfo collector %ld", i);
                    infoobj[0].Syntax.LngInt = SNMP_INVALID;
                    MibRequest(&infoobj[0]);
                    continue;
                }
                memcpy(infoobj[2].Syntax.BufInt, infosource, sizeof(infosource));
                infoobj[2].Syntax.BufInt[sizeof(infosource)/sizeof(infosource[0])-1] = i;
                infoobj[2].SyntaxLen = sizeof(infosource)/sizeof(infosource[0]);
                if (MibRequest(&infoobj[2]) != SNMP_NOERROR)
                {
                    DnpapMessage(DMC_WARNING, INFO_INFOINIT, "beholderInfo: couldn't set datasource of beholderInfo collector %ld", i);
                    infoobj[0].Syntax.LngInt = SNMP_INVALID;
                    MibRequest(&infoobj[0]);
                    continue;
                }
                infoobj[0].Syntax.LngInt = SNMP_VALID;
                if (MibRequest(&infoobj[0]) != SNMP_NOERROR)
                {
                    DnpapMessage(DMC_WARNING, INFO_INFOINIT, "beholderInfo: couldn't set beholderInfo collector %ld to valid", i);
                    infoobj[0].Syntax.LngInt = SNMP_INVALID;
                    MibRequest(&infoobj[0]);
                    continue;
                }
            }
        }
    }

    return TRUE;
}


/*****************************************************************
** NAME:        RmonNext
** SYNOPSIS:    BOOLEAN RmonNext (SNMP_OBJECT *Obj,
**                                  MIB_LOCAL **Local, WORD IdLen,
**                                  WORD IdSze, VOID **Elm)
** PARAMETERS:  Obj: requested object
**              Local: local datastructure: a collector
**              IdLen: identifier length known to the MIB
**              IdSze: number of indices after the MIB
**              Elm: pointer to object if tables are used
** DESCRIPTION: application specific RMON NEXT function.
**              only called after MibRmon() for next requests 
**              searches the next object in the collector
** REMARKS:     ONLY FOR INTERNAL USE
** RETURNS:     TRUE: object found
**                    OPTIONAL: Elm -> pointer to object in table
*******************************************************************/

BOOLEAN RmonNext (SNMP_OBJECT *Obj, MIB_LOCAL **Local, WORD IdLen, WORD IdSze, BEHOLDER_INFO **Elm)
{
MIB_LOCAL    *local = *Local;

    if (local == NULL)
        return FALSE;
    if (Obj->IdLen == IdLen || local->Index > Obj->Id[IdLen])
    {
        /********************************************************************
        **  OPTIONAL: search function to find first obj in a table !! 
        **  if (not found)
        **      search next collector
        **  adjust object identifier to identifier first object
        **  Elm -> found table obj
        ********************************************************************/
        Obj->IdLen = IdLen + IdSze;
        Obj->Id[IdLen] = local->Index;
        return TRUE;
    }
    /********************************************************************
    **  OPTIONAL: search function to find next obj in a table !! 
    **  if (found)
    **      adjust object identifier to identifier next object
    **      Elm -> found table obj
    **      return TRUE
    ********************************************************************/
    *Local = local->Next;
    return RmonNext(Obj, Local, IdLen, IdSze, Elm);
}

WORD InfoIndex (SNMP_OBJECT *Obj, WORD IdLen)
{
MIB_LOCAL    *local = NULL;

    if ((local = MibRmon (Obj, beholderInfo, IdLen, INDEXSIZE)) == NULL)
        return SNMP_NOSUCHNAME;
    switch (Obj->Request)
    {
    case SNMP_PDU_NEXT:
        if (RmonNext (Obj, &local, IdLen, INDEXSIZE, NULL) == FALSE)
            return SNMP_NOSUCHNAME;
    case SNMP_PDU_GET:
        Obj->Syntax.LngInt = local->Index;
        return SNMP_NOERROR;
    }
    return SNMP_GENERROR;
}

WORD InfoDataSource (SNMP_OBJECT *Obj, WORD IdLen)
{
MIB_LOCAL       *local = NULL;
BEHOLDER_INFO   *data;
MAC_IFACE       *iface;

    if ((local = MibRmon(Obj, beholderInfo, IdLen, INDEXSIZE)) == NULL)
        return SNMP_NOSUCHNAME;

    switch (Obj->Request)
    {           
    case SNMP_PDU_NEXT:
        if (RmonNext (Obj, &local, IdLen, INDEXSIZE, NULL) == FALSE)
            return SNMP_NOSUCHNAME;
    case SNMP_PDU_GET:
        data = (BEHOLDER_INFO*) local->Data;
		if (BeholderStrictRMON && !BooleanCheck(data->ObjectSet, INFO_BOOLEAN_DATASOURCE))
			return SNMP_NOSUCHNAME;
        memcpy (Obj->Syntax.BufInt, data->Source, data->SourceLen * sizeof (LONG));
        Obj->SyntaxLen = data->SourceLen;
        return SNMP_NOERROR;
    case SNMP_PDU_SET:
        data = (BEHOLDER_INFO*) local->Data;
        if (data->Status != SNMP_UNDERCREATION)
            return SNMP_READONLY;
        if (data->SourceLen != Obj->SyntaxLen ||
            memcmp(data->Source, Obj->Syntax.BufInt, (data->SourceLen-1)*sizeof(data->Source[0])))
            return SNMP_BADVALUE;
        if ((iface = MacIfaceGet((WORD) Obj->Syntax.BufInt[Obj->SyntaxLen-1])) == NULL)
            return SNMP_BADVALUE;
        if (iface->type != MAC_TYPE_ETHERNET_CSMACD && iface->type != MAC_TYPE_88023_CSMACD)
        	return SNMP_BADVALUE;
        memcpy (data->Source, Obj->Syntax.BufInt, Obj->SyntaxLen*sizeof(data->Source[0]));
        data->SourceLen = Obj->SyntaxLen;
        data->Iface = iface;
		BooleanSetTrue(data->ObjectSet, INFO_BOOLEAN_DATASOURCE);
        return SNMP_NOERROR;
    }
    return SNMP_GENERROR;
}

WORD InfoLostPkts (SNMP_OBJECT *Obj, WORD IdLen)
{
MIB_LOCAL    *local = NULL;
BEHOLDER_INFO  *data;
MAC_STAT stat;

    if ((local = MibRmon(Obj, beholderInfo, IdLen, INDEXSIZE)) == NULL)
        return SNMP_NOSUCHNAME;

    switch (Obj->Request)
    {
    case SNMP_PDU_NEXT:
        if (RmonNext (Obj, &local, IdLen, INDEXSIZE, NULL) == FALSE)
            return SNMP_NOSUCHNAME;
    case SNMP_PDU_GET:
        data = (BEHOLDER_INFO*) local->Data;
        if (data->Status != SNMP_VALID)
        {
            Obj->Syntax.LngUns = 0UL;
            return SNMP_NOERROR;
        }
        MacStatistics(data->Iface, &stat);
        Obj->Syntax.LngUns = stat.LostPkts - data->BaseStat.LostPkts;
        return SNMP_NOERROR;
    }
    return SNMP_GENERROR;
}

WORD InfoPkts (SNMP_OBJECT *Obj, WORD IdLen)
{
MIB_LOCAL    *local = NULL;
BEHOLDER_INFO  *data;
MAC_STAT stat;

    if ((local = MibRmon(Obj, beholderInfo, IdLen, INDEXSIZE)) == NULL)
        return SNMP_NOSUCHNAME;

    switch (Obj->Request)
    {
    case SNMP_PDU_NEXT:
        if (RmonNext (Obj, &local, IdLen, INDEXSIZE, NULL) == FALSE)
            return SNMP_NOSUCHNAME;