/**************************************************************
* Copyright (C) 2001 Tali Rozin, Optical Access
*
* All Rights Reserved
*
* Permission to use, copy, modify and distribute this software and its
* documentation for any purpose and without fee is hereby granted,
* provided that the above copyright notice appear in all copies and that
* both that copyright notice and this permission notice appear in
* supporting documentation.
*
* TALI ROZIN DISCLAIM ALL WARRANTIES WITH REGARD TO THIS SOFTWARE, INCLUDING
* ALL IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS, IN NO EVENT SHALL
* ALEX ROZIN BE LIABLE FOR ANY SPECIAL, INDIRECT OR CONSEQUENTIAL DAMAGES OR
* ANY DAMAGES WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS,
* WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION,
* ARISING OUT OF OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS
* SOFTWARE.
******************************************************************/
#include <net-snmp/net-snmp-config.h>
#if HAVE_STDLIB
#include <stdlib.h>
#endif
#if TIME_WITH_SYS_TIME
# include <sys/time.h>
# include <time.h>
#else
# if HAVE_SYS_TIME_H
# include <sys/time.h>
# else
# include <time.h>
# endif
#endif
#if HAVE_UNISTD_H
#include <unistd.h>
#endif
#include <net-snmp/net-snmp-includes.h>
#include <net-snmp/agent/net-snmp-agent-includes.h>
#include "statistics.h"
/*
* Implementation headers
*/
#include "agutil_api.h"
#include "row_api.h"
/*
* File scope definitions section
*/
/*
* from MIB compilation
*/
#define MIB_DESCR "EthStat"
#define etherStatsEntryFirstIndexBegin 11
#define IDetherStatsDroppedFrames 1
#define IDetherStatsCreateTime 2
#define IDetherStatsIndex 3
#define IDetherStatsDataSource 4
#define IDetherStatsDropEvents 5
#define IDetherStatsOctets 6
#define IDetherStatsPkts 7
#define IDetherStatsBroadcastPkts 8
#define IDetherStatsMulticastPkts 9
#define IDetherStatsCRCAlignErrors 10
#define IDetherStatsUndersizePkts 11
#define IDetherStatsOversizePkts 12
#define IDetherStatsFragments 13
#define IDetherStatsJabbers 14
#define IDetherStatsCollisions 15
#define IDetherStatsPkts64Octets 16
#define IDetherStatsPkts65to127Octets 17
#define IDetherStatsPkts128to255Octets 18
#define IDetherStatsPkts256to511Octets 19
#define IDetherStatsPkts512to1023Octets 20
#define IDetherStatsPkts1024to1518Octets 21
#define IDetherStatsOwner 22
#define IDetherStatsStatus 23
#define Leaf_etherStatsDataSource 2
#define Leaf_etherStatsOwner 20
#define Leaf_etherStatsStatus 21
#define MIN_etherStatsIndex 1
#define MAX_etherStatsIndex 65535
typedef struct {
VAR_OID_T
data_source;
u_long
etherStatsCreateTime;
ETH_STATS_T
eth;
} CRTL_ENTRY_T;
/*
* Main section
*/
static TABLE_DEFINTION_T
StatCtrlTable;
static TABLE_DEFINTION_T *
table_ptr = &
StatCtrlTable;
/*
* Control Table RowApi Callbacks
*/
int
stat_Create(RMON_ENTRY_T * eptr)
{ /* create the body: alloc it and set defaults */
CRTL_ENTRY_T *body;
static VAR_OID_T data_src_if_index_1 =
{ 11, {1, 3, 6, 1, 2, 1, 2, 2, 1, 1, 1} };
eptr->body = AGMALLOC(sizeof(CRTL_ENTRY_T));
if (!eptr->body)
return -3;
body = (CRTL_ENTRY_T *) eptr->body;
/*
* set defaults
*/
memcpy(&body->data_source, &data_src_if_index_1, sizeof(VAR_OID_T));
body->data_source.objid[body->data_source.length - 1] =
eptr->ctrl_index;
eptr->owner = AGSTRDUP("Startup Mgmt");
memset(&body->eth, 0, sizeof(ETH_STATS_T));
return 0;
}
int
stat_Validate(RMON_ENTRY_T * eptr)
{
/*
* T.B.D. (system dependent) check valid inteface in body->data_source;
*/
return 0;
}
int
stat_Activate(RMON_ENTRY_T * eptr)
{
CRTL_ENTRY_T *body = (CRTL_ENTRY_T *) eptr->body;
body->etherStatsCreateTime = AGUTIL_sys_up_time();
return 0;
}
int
stat_Copy(RMON_ENTRY_T * eptr)
{
CRTL_ENTRY_T *body = (CRTL_ENTRY_T *) eptr->body;
CRTL_ENTRY_T *clone = (CRTL_ENTRY_T *) eptr->tmp;
if (snmp_oid_compare
(clone->data_source.objid, clone->data_source.length,
body->data_source.objid, body->data_source.length)) {
memcpy(&body->data_source, &clone->data_source, sizeof(VAR_OID_T));
}
return 0;
}
int
stat_Deactivate(RMON_ENTRY_T * eptr)
{
CRTL_ENTRY_T *body = (CRTL_ENTRY_T *) eptr->body;
memset(&body->eth, 0, sizeof(ETH_STATS_T));
return 0;
}
/***************************************************
* Function:var_etherStats2Entry
* Purpose: Handles the request for etherStats2Entry variable instances
***************************************************/
u_char *
var_etherStats2Entry(struct variable * vp, oid * name, size_t * length,
int exact, size_t * var_len,
WriteMethod ** write_method)
{
static long long_return;
static CRTL_ENTRY_T theEntry;
RMON_ENTRY_T *hdr;
*write_method = NULL;
hdr = ROWAPI_header_ControlEntry(vp, name, length, exact, var_len,
table_ptr,
&theEntry, sizeof(CRTL_ENTRY_T));
if (!hdr)
return NULL;
*var_len = sizeof(long); /* default */
switch (vp->magic) {
case IDetherStatsDroppedFrames:
long_return = 0;
return (u_char *) & long_return;
case IDetherStatsCreateTime:
long_return = theEntry.etherStatsCreateTime;
return (u_char *) & long_return;
default:
ag_trace("%s: unknown vp->magic=%d", table_ptr->name,
(int) vp->magic);
ERROR_MSG("");
}; /* of switch by 'vp->magic' */
return NULL;
}
/***************************************************
* Function:write_etherStatsEntry
***************************************************/
static int
write_etherStatsEntry(int action, u_char * var_val, u_char var_val_type,
size_t var_val_len, u_char * statP,
oid * name, size_t name_len)
{
long long_temp;
int leaf_id, snmp_status;
static int prev_action = COMMIT;
RMON_ENTRY_T *hdr;
CRTL_ENTRY_T *cloned_body;
CRTL_ENTRY_T *body;
switch (action) {
case RESERVE1:
case FREE:
case UNDO:
case ACTION:
case COMMIT:
default:
snmp_status =
ROWAPI_do_another_action(name, etherStatsEntryFirstIndexBegin,
action, &prev_action, table_ptr,
sizeof(CRTL_ENTRY_T));
if (SNMP_ERR_NOERROR != snmp_status) {
ag_trace("failed action %d with %d", action, snmp_status);
}
break;
case RESERVE2:
/*
* get values from PDU, check them and save them in the cloned entry
*/
long_temp = name[etherStatsEntryFirstIndexBegin];
leaf_id = (int) name[etherStatsEntryFirstIndexBegin - 1];
hdr = ROWAPI_find(table_ptr, long_temp); /* it MUST be OK */
cloned_body = (CRTL_ENTRY_T *) hdr->tmp;
body = (CRTL_ENTRY_T *) hdr->body;
switch (leaf_id) {
case Leaf_etherStatsDataSource:
snmp_status = AGUTIL_get_oid_value(var_val, var_val_type,
var_val_len,
&cloned_body->data_source);
if (SNMP_ERR_NOERROR != snmp_status) {
return snmp_status;
}
if (RMON1_ENTRY_UNDER_CREATION != hdr->status &&
snmp_oid_compare(cloned_body->data_source.objid,
cloned_body->data_source.length,
body->data_source.objid,
body->data_source.length))
return SNMP_ERR_BADVALUE;
break;
break;
case Leaf_etherStatsOwner:
if (hdr->new_owner)
AGFREE(hdr->new_owner);
hdr->new_owner = AGMALLOC(MAX_OWNERSTRING);
if (!hdr->new_owner)
return SNMP_ERR_TOOBIG;
snmp_status = AGUTIL_get_string_value(var_val, var_val_type,
var_val_len,
MAX_OWNERSTRING,
1, NULL, hdr->new_owner);
if (SNMP_ERR_NOERROR != snmp_status) {
return snmp_status;
}
break;
case Leaf_etherStatsStatus:
snmp_status = AGUTIL_get_int_value(var_val, var_val_type,
var_val_len,
RMON1_ENTRY_VALID,
RMON1_ENTRY_INVALID,
&long_temp);
if (SNMP_ERR_NOERROR != snmp_status) {
ag_trace("cannot browse etherStatsStatus");
return snmp_status;
}
hdr->new_status = long_temp;
break;
break;
default:
ag_trace("%s:unknown leaf_id=%d\n", table_ptr->name,
(int) leaf_id);
return SNMP_ERR_NOSUCHNAME;
} /* of switch by 'leaf_id' */
break;
} /* of switch by 'action' */
prev_action = action;
return SNMP_ERR_NOERROR;
}
/***************************************************
* Function:var_etherStatsEntry
* Purpose: Handles the request for etherStatsEntry variable instances
***************************************************/
u_char *
var_etherStatsEntry(struct variable * vp, oid * name, size_t * length,
int exact, size_t * var_len,
WriteMethod ** write_method)
{
static unsigned char zero_octet_string[1];
static long long_return;
static CRTL_ENTRY_T theEntry;
RMON_ENTRY_T *hdr;
*write_method = write_etherStatsEntry;
hdr = ROWAPI_header_ControlEntry(vp, name, length, exact, var_len,
table_ptr,
&theEntry, sizeof(CRTL_ENTRY_T));
if (!hdr)
return NULL;
if (RMON1_ENTRY_VALID == hdr->status)
SYSTEM_get_eth_statistics(&theEntry.data_source, &theEntry.eth);
*var_len = sizeof(long);
switch (vp->magic) {
case IDetherStatsIndex:
long_return = hdr->ctrl_index;
return (u_char *) & long_return;
case IDetherStatsDataSource:
*var_len = sizeof(oid) * theEntry.data_source.length;
return (unsigned char *) theEntry.data_source.objid;
case IDetherStatsDropEvents:
long_return = 0; /* theEntry.eth.etherStatsDropEvents; */
return (u_char *) & long_return;
case IDetherStatsOctets:
long_return = theEntry.eth.octets;
return (u_char *) & long_return;
case IDetherStatsPkts:
long_return = theEntry.eth.packets;
return (u_char *) & long_return;
case IDetherStatsBroadcastPkts:
long_return = theEntry.eth.bcast_pkts;
return (u_char *) & long_return;
case IDetherStatsMulticastPkts:
long_return = theEntry.eth.mcast_pkts;
return (u_char *) & long_return;
case IDetherStatsCRCAlignErrors:
long_return = theEntry.eth.crc_align;
return (u_char *) & long_return;
case IDetherStatsUndersizePkts:
long_return = theEntry.eth.undersize;
return (u_char *) & long_return;
case IDetherStatsOversizePkts:
long_return = theEntry.eth.oversize;
return (u_char *) & long_return;
case IDetherStatsFragments:
long_return = theEntry.eth.fragments;
return (u_char *) & long_return;
case IDetherStatsJabbers:
long_return = theEntry.eth.jabbers;
return (u_char *) & long_return;
case IDetherStatsCollisions:
long_return = theEntry.eth.collisions;
return (u_char *) & long_return;
case IDetherStatsPkts64Octets:
long_return = theEntry.eth.pkts_64;
return (u_char *) & long_return;
case IDetherStatsPkts65to127Octets:
long_return = theEntry.eth.pkts_65_127;
return (u_char *) & long_return;
case IDetherStatsPkts128to255Octets:
long_return = theEntry.eth.pkts_128_255;
return (u_char *) & long_return;
case IDetherStatsPkts256to511Octets:
long_return = theEntry.eth.pkts_256_511;
return (u_char *) & long_return;
case IDetherStatsPkts512to1023Octets:
long_return = theEntry.eth.pkts_512_1023;
return (u_char *) & long_return;
case IDetherStatsPkts1024to1518Octets:
long_return = theEntry.eth.pkts_1024_1518;
return (u_char *) & long_return;
case IDetherStatsOwner:
if (hdr->owner) {
*var_len = strlen(hdr->owner);
return (unsigned char *) hdr->owner;
} else {
*var_len = 0;
return zero_octet_string;
}
case IDetherStatsStatus:
long_return = hdr->status;
return (u_char *) & long_return;
default:
ERROR_MSG("");
}; /* of switch by 'vp->magic' */
return NULL;
}
#if 1 /* debug, but may be used for init. TBD: may be token snmpd.conf ? */
int
add_statistics_entry(int ctrl_index, int ifIndex)
{
int ierr;
ierr = ROWAPI_new(table_ptr, ctrl_index);
switch (ierr) {
case -1:
ag_trace("max. number exedes\n");
break;
case -2:
ag_trace("malloc failed");
break;
case -3:
ag_trace("ClbkCreate failed");
break;
case 0:
break;
default:
ag_trace("Unknown code %d", ierr);
break;
}
if (!ierr) {
register RMON_ENTRY_T *eptr = ROWAPI_find(table_ptr, ctrl_index);
if (!eptr) {
ag_trace("cannot find it");
ierr = -4;
} else {
CRTL_ENTRY_T *body = (CRTL_ENTRY_T *) eptr->body;
body->data_source.objid[body->data_source.length - 1] =
ifIndex;
eptr->new_status = RMON1_ENTRY_VALID;
ierr = ROWAPI_commit(table_ptr, ctrl_index);
if (ierr) {
ag_trace("ROWAPI_commit returned %d", ierr);
}
}
}
return ierr;
}
#endif
/***************************************************
* define Variables callbacks
***************************************************/
oid oidstatisticsVariablesOid[] = { 1, 3, 6, 1, 2, 1, 16, 1 };
struct variable7 oidstatisticsVariables[] = {
{IDetherStatsIndex, ASN_INTEGER, NETSNMP_OLDAPI_RONLY,
var_etherStatsEntry, 3, {1, 1, 1}},
{IDetherStatsDataSource, ASN_OBJECT_ID, NETSNMP_OLDAPI_RWRITE,
var_etherStatsEntry, 3, {1, 1, 2}},
{IDetherStatsDropEvents, ASN_COUNTER, NETSNMP_OLDAPI_RONLY,
var_etherStatsEntry, 3, {1, 1, 3}},
{IDetherStatsOctets, ASN_COUNTER, NETSNMP_OLDAPI_RONLY,
var_etherStatsEntry, 3, {1, 1, 4}},
{IDetherStatsPkts, ASN_COUNTER, NETSNMP_OLDAPI_RONLY,
var_etherStatsEntry, 3, {1, 1, 5}},
{IDetherStatsBroadcastPkts, ASN_COUNTER, NETSNMP_OLDAPI_RONLY,
var_etherStatsEntry, 3, {1, 1, 6}},
{IDetherStatsMulticastPkts, ASN_COUNTER, NETSNMP_OLDAPI_RONLY,
var_etherStatsEntry, 3, {1, 1, 7}},
{IDetherStatsCRCAlignErrors, ASN_COUNTER, NETSNMP_OLDAPI_RONLY,
var_etherStatsEntry, 3, {1, 1, 8}},
{IDetherStatsUndersizePkts, ASN_COUNTER, NETSNMP_OLDAPI_RONLY,
var_etherStatsEntry, 3, {1, 1, 9}},
{IDetherStatsOversizePkts, ASN_COUNTER, NETSNMP_OLDAPI_RONLY,
var_etherStatsEntry, 3, {1, 1, 10}},
{IDetherStatsFragments, ASN_COUNTER, NETSNMP_OLDAPI_RONLY,
var_etherStatsEntry, 3, {1, 1, 11}},
{IDetherStatsJabbers, ASN_COUNTER, NETSNMP_OLDAPI_RONLY,
var_etherStatsEntry, 3, {1, 1, 12}},
{IDetherStatsCollisions, ASN_COUNTER, NETSNMP_OLDAPI_RONLY,
var_etherStatsEntry, 3, {1, 1, 13}},
{IDetherStatsPkts64Octets, ASN_COUNTER, NETSNMP_OLDAPI_RONLY,
var_etherStatsEntry, 3, {1, 1, 14}},
{IDetherStatsPkts65to127Octets, ASN_COUNTER, NETSNMP_OLDAPI_RONLY,
var_etherStatsEntry, 3, {1, 1, 15}},
{IDetherStatsPkts128to255Octets, ASN_COUNTER, NETSNMP_OLDAPI_RONLY,
var_etherStatsEntry, 3, {1, 1, 16}},
{IDetherStatsPkts256to511Octets, ASN_COUNTER, NETSNMP_OLDAPI_RONLY,
var_etherStatsEntry, 3, {1, 1, 17}},
{IDetherStatsPkts512to1023Octets, ASN_COUNTER, NETSNMP_OLDAPI_RONLY,
var_etherStatsEntry, 3, {1, 1, 18}},
{IDetherStatsPkts1024to1518Octets, ASN_COUNTER, NETSNMP_OLDAPI_RONLY,
var_etherStatsEntry, 3, {1, 1, 19}},
{IDetherStatsOwner, ASN_OCTET_STR, NETSNMP_OLDAPI_RWRITE,
var_etherStatsEntry, 3, {1, 1, 20}},
{IDetherStatsStatus, ASN_INTEGER, NETSNMP_OLDAPI_RWRITE,
var_etherStatsEntry, 3, {1, 1, 21}},
{IDetherStatsDroppedFrames, ASN_COUNTER, NETSNMP_OLDAPI_RONLY,
var_etherStats2Entry, 3, {4, 1, 1}},
{IDetherStatsCreateTime, ASN_TIMETICKS, NETSNMP_OLDAPI_RONLY,
var_etherStats2Entry, 3, {4, 1, 2}},
};
/***************************************************
* Function:init_statistics
* Purpose: register statistics objects in the agent
***************************************************/
void
init_statistics(void)
{
REGISTER_MIB(MIB_DESCR, oidstatisticsVariables, variable7,
oidstatisticsVariablesOid);
ROWAPI_init_table(&StatCtrlTable, MIB_DESCR, 0, &stat_Create, NULL, /* &stat_Clone, */
NULL, /* &stat_Delete, */
&stat_Validate,
&stat_Activate, &stat_Deactivate, &stat_Copy);
#if 0 /* debug */
{
int iii;
for (iii = 1; iii < 6; iii++) {
add_statistics_entry(iii, iii);
}
add_statistics_entry(10, 16);
add_statistics_entry(12, 11);
}
#endif
}
/*
* end of file statistics.c
*/