开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > SNMP编程 > 查看源码
if.c
资源名称：net-snmp-5.2.2.rar　[点击查看]
上传用户：wxp200602
上传日期：2007-10-30
资源大小：4028k
文件大小：28k
源码类别：

SNMP编程

开发平台：

Unix_Linux

if.c：源码内容
  1. /* $OpenBSD: if.c,v 1.42 2005/03/13 16:05:50 mpf Exp $ */
  2. /* $NetBSD: if.c,v 1.16.4.2 1996/06/07 21:46:46 thorpej Exp $ */
  4. /*
  5.  * Copyright (c) 1983, 1988, 1993
  6.  * The Regents of the University of California.  All rights reserved.
  7.  *
  8.  * Redistribution and use in source and binary forms, with or without
  9.  * modification, are permitted provided that the following conditions
  10.  * are met:
  11.  * 1. Redistributions of source code must retain the above copyright
  12.  *    notice, this list of conditions and the following disclaimer.
  13.  * 2. Redistributions in binary form must reproduce the above copyright
  14.  *    notice, this list of conditions and the following disclaimer in the
  15.  *    documentation and/or other materials provided with the distribution.
  16.  * 3. Neither the name of the University nor the names of its contributors
  17.  *    may be used to endorse or promote products derived from this software
  18.  *    without specific prior written permission.
  19.  *
  20.  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
  21.  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  22.  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  23.  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
  24.  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
  25.  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
  26.  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
  27.  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
  28.  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
  29.  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
  30.  * SUCH DAMAGE.
  31.  */
  33. #ifdef  INHERITED_CODE
  34. #ifndef lint
  35. #if 0
  36. static char sccsid[] = "from: @(#)if.c 8.2 (Berkeley) 2/21/94";
  37. #else
  38. static char *rcsid = "$OpenBSD: if.c,v 1.42 2005/03/13 16:05:50 mpf Exp $";
  39. #endif
  40. #endif /* not lint */
  41. #endif
  43. #include <net-snmp/net-snmp-config.h>
  44. #include <net-snmp/net-snmp-includes.h>
  46. #if HAVE_UNISTD_H
  47. #include <unistd.h>
  48. #endif
  49. #if HAVE_NET_IF_H
  50. #include <net/if.h>
  51. #endif
  52. #define __USE_XOPEN
  53. #define __USE_XOPEN_EXTENDED
  54. #include <signal.h>
  56. #include "main.h"
  57. #include "netstat.h"
  59. #define YES 1
  60. #define NO 0
  62. static void sidewaysintpr(u_int);
  63. static void timerSet(int interval_seconds);
  64. static void timerPause(void);
  66.     struct _if_info {
  67.         char            name[128];
  68.         char            ip[128], route[128];
  69.         int             mtu;
  70.         int             drops;
  71.         int             ifindex;
  72.                         /*
  73.                          * Save "expandable" fields as string values
  74.                          *  rather than integer statistics
  75.                          */
  76.         char            s_ipkts[20], s_ierrs[20];
  77.         char            s_opkts[20], s_oerrs[20];
  78.         char            s_ibytes[20], s_obytes[20];
  79.         char            s_outq[20];
  80.         unsigned long   ipkts, opkts;  /* Need to combine 2 MIB values */
  81.         int             operstatus;
  82. /*
  83.         u_long          netmask;
  84.         struct in_addr  ifip, ifroute;
  85.  */
  86.         struct _if_info *next;
  87.     };
  90. /*
  91.  * Retrieve the interface addressing information
  92.  * XXX - This could also be extended to handle non-IP interfaces
  93.  */
  94. void
  95. _set_address( struct _if_info *cur_if )
  96. {
  97.     oid    ipaddr_oid[] = { 1,3,6,1,2,1,4,20,1,0 };
  98.     size_t ipaddr_len   = OID_LENGTH( ipaddr_oid );
  99.     static netsnmp_variable_list *addr_if_var  =NULL;
  100.     static netsnmp_variable_list *addr_mask_var=NULL;
  101.     netsnmp_variable_list *vp, *vp2;
  102.     union {
  103.         in_addr_t addr;
  104.         char      data[4];
  105.     } tmpAddr;
  106.     char *cp;
  107.     in_addr_t ifAddr, mask;
  109.         /*
  110.          *  Note that this information only needs to be retrieved 
  111.          *    once, and can be re-used for subsequent calls.
  112.          */
  113.     if ( addr_if_var == NULL ) {
  114.         ipaddr_oid[ 9 ] = 2;  /* ipAdEntIfIndex */
  115.         snmp_varlist_add_variable( &addr_if_var, ipaddr_oid, ipaddr_len,
  116.                                    ASN_NULL, NULL,  0);
  117.         netsnmp_query_walk( addr_if_var, ss );
  119.         ipaddr_oid[ 9 ] = 3;  /* ipAdEntNetMask */
  120.         snmp_varlist_add_variable( &addr_mask_var, ipaddr_oid, ipaddr_len,
  121.                                    ASN_NULL, NULL,  0);
  122.         netsnmp_query_walk( addr_mask_var, ss );
  123.     }
  125.     /*
  126.      * Find the address row relevant to this interface
  127.      */
  128.     for (vp=addr_if_var, vp2=addr_mask_var;  vp;
  129.          vp=vp->next_variable, vp2=vp2->next_variable) {
  130.         if ( *vp->val.integer == cur_if->ifindex )
  131.             break;
  132.     }
  133.     if (vp2) {
  134.         /*
  135.          * Always want a numeric interface IP address
  136.          */
  137.         snprintf( cur_if->ip, 128, "%lu.%lu.%lu.%lu",
  138.                   vp2->name[10],
  139.                   vp2->name[11],
  140.                   vp2->name[12],
  141.                   vp2->name[13]);
  143.         /*
  144.          * But re-use the routing table utilities/code for
  145.          *   displaying the local network information
  146.          */
  147.         cp = tmpAddr.data;
  148.         cp[0] = vp2->name[ 10 ] & 0xff;
  149.         cp[1] = vp2->name[ 11 ] & 0xff;
  150.         cp[2] = vp2->name[ 12 ] & 0xff;
  151.         cp[3] = vp2->name[ 13 ] & 0xff;
  152.         ifAddr = tmpAddr.addr;
  153.         cp = tmpAddr.data;
  154.         cp[0] = vp2->val.string[ 0 ] & 0xff;
  155.         cp[1] = vp2->val.string[ 1 ] & 0xff;
  156.         cp[2] = vp2->val.string[ 2 ] & 0xff;
  157.         cp[3] = vp2->val.string[ 3 ] & 0xff;
  158.         mask = tmpAddr.addr;
  159.         snprintf( cur_if->route, 128, "%s", netname(ifAddr, mask));
  160.     }
  161. }
  164. /*
  165.  * Print a description of the network interfaces.
  166.  */
  167. void
  168. intpr(int interval)
  169. {
  170.     oid    ifcol_oid[]  = { 1,3,6,1,2,1,2,2,1,0 };
  171.     size_t ifcol_len    = OID_LENGTH( ifcol_oid );
  173.     struct _if_info *if_head, *if_tail, *cur_if;
  174.     netsnmp_variable_list *var, *vp;
  175.            /*
  176.             * Track maximum field widths, expanding as necessary
  177.             *   This is one reason why results can't be
  178.             *   displayed immediately they are retrieved.
  179.             */
  180.     int    max_name  = 4, max_ip    = 7, max_route = 7, max_outq  = 5;
  181.     int    max_ipkts = 5, max_ierrs = 5, max_opkts = 5, max_oerrs = 5;
  182.     int    max_ibytes = 6, max_obytes = 6;
  183.     int    i;
  186.     if (interval) {
  187.         sidewaysintpr((unsigned)interval);
  188.         return;
  189.     }
  191.         /*
  192.          * The traditional "netstat -i" output combines information
  193.          *   from two SNMP tables:
  194.          *      ipAddrTable   (for the IP address/network)
  195.          *      ifTable       (for the interface statistics)
  196.          *
  197.          * The previous approach was to retrieve (and save) the
  198.          *   address information first. Then walk the main ifTable,
  199.          *   add the relevant stored addresses, and saving the
  200.          *   full information for each interface, before displaying 
  201.          *   the results as a separate pass.
  202.          *
  203.          * This code reverses this general structure, by first retrieving
  204.          *   (and storing) the interface statistics for the whole table,
  205.          *   then inserting the address information obtained from the
  206.          *   ipAddrTable, and finally displaying the results.
  207.          * Such an arrangement should make it easier to extend this
  208.          *   to handle non-IP interfaces (hence not in ipAddrTable)
  209.          */
  210.     if_head = NULL;
  211.     if_tail = NULL;
  212.     var     = NULL;
  214. #define ADD_IFVAR( x ) ifcol_oid[ ifcol_len-1 ] = x; 
  215.     snmp_varlist_add_variable( &var, ifcol_oid, ifcol_len, ASN_NULL, NULL,  0)
  216.     ADD_IFVAR( 2 );                 /* ifName  */
  217.     ADD_IFVAR( 4 );                 /* ifMtu   */
  218.     ADD_IFVAR( 8 );                 /* ifOperStatus */
  219.     /*
  220.      * The Net/Open-BSD behaviour is to display *either* byte
  221.      *   counts *or* packet/error counts (but not both). FreeBSD
  222.      *   integrates the byte counts into the traditional display.
  223.      *
  224.      * The previous 'snmpnetstat' implementation followed the
  225.      *   separatist model.  This re-write offers an opportunity
  226.      *   to adopt the (more useful, IMO) Free-BSD approach.
  227.      *
  228.      * Or we could perhaps support both styles? :-)
  229.      */
  230.     if (bflag || oflag) {
  231.         ADD_IFVAR( 10 );            /* ifInOctets   */
  232.         ADD_IFVAR( 16 );            /* ifOutOctets  */
  233.     }
  234.     if (!oflag) {
  235.         ADD_IFVAR( 11 );            /* ifInUcastPkts  */
  236.         ADD_IFVAR( 12 );            /* ifInNUcastPkts */
  237.         ADD_IFVAR( 14 );            /* ifInErrors     */
  238.         ADD_IFVAR( 17 );            /* ifOutUcastPkts */
  239.         ADD_IFVAR( 18 );            /* ifOutNUcastPkts */
  240.         ADD_IFVAR( 20 );            /* ifOutErrors    */
  241.         ADD_IFVAR( 21 );            /* ifOutQLen      */
  242.     }
  243. /*  if (tflag) {
  244.         ADD_IFVAR( XX );            // ???
  245.     }
  246.  */
  247.     if (dflag) {
  248.         ADD_IFVAR( 19 );            /* ifOutDiscards  */
  249.     }
  250. #undef ADD_IFVAR
  252.         /*
  253.  * Now walk the ifTable, creating a list of interfaces
  254.  */
  255.     while ( 1 ) {
  256.         if (netsnmp_query_getnext( var, ss ) != SNMP_ERR_NOERROR)
  257.             break;
  258.         ifcol_oid[ ifcol_len-1 ] = 2; /* ifDescr */
  259.         if ( snmp_oid_compare( ifcol_oid, ifcol_len,
  260.                                var->name, ifcol_len) != 0 )
  261.             break;    /* End of Table */
  262.         cur_if = SNMP_MALLOC_TYPEDEF( struct _if_info );
  263.         if (!cur_if)
  264.             break;
  265.         cur_if->ifindex = var->name[ var->name_length-1 ];
  266.         for ( vp=var; vp; vp=vp->next_variable ) {
  267.             if ( var->name[ var->name_length-1 ] != cur_if->ifindex ) {
  268.                 /*
  269.                  * Inconsistent index information
  270.                  * XXX - Try to recover ?
  271.                  */
  272.                 SNMP_FREE( cur_if );
  273.                 cur_if = NULL;
  274.                 break;    /* not for now, no */
  275.             }
  276.             switch ( vp->name[ var->name_length-2 ] ) {
  277.             case 2:     /* ifDescr */
  278.                 if (vp->val_len >= sizeof(cur_if->name))
  279.                     vp->val_len  = sizeof(cur_if->name)-1;
  280.                 memmove( cur_if->name, vp->val.string, vp->val_len );
  281.                 cur_if->name[vp->val_len] = 0;
  282.                 if ((i = strlen(cur_if->name) + 1) > max_name)
  283.                     max_name = i;
  284.                 break;
  285.             case 4:     /* ifMtu   */
  286.                 cur_if->mtu = *vp->val.integer;
  287.                 break;
  288.             case 8:     /* ifOperStatus   */
  289.                 cur_if->operstatus = *vp->val.integer;
  290.                 /* XXX - any special processing ?? */
  291.                 break;
  292.             case 10: /* ifInOctets     */
  293.                 sprintf(cur_if->s_ibytes, "%lu", *vp->val.integer);
  294.                 i = strlen(cur_if->s_ibytes);
  295.                 if (i > max_ibytes)
  296.                     max_ibytes = i;
  297.                 break;
  298.             case 11: /* ifInUcastPkts  */
  299.                 cur_if->ipkts += *vp->val.integer;
  300.                 sprintf(cur_if->s_ipkts, "%lu", cur_if->ipkts);
  301.                 i = strlen(cur_if->s_ipkts);
  302.                 if (i > max_ipkts)
  303.                     max_ipkts = i;
  304.                 break;
  305.             case 12: /* ifInNUcastPkts  */
  306.                 cur_if->ipkts += *vp->val.integer;
  307.                 sprintf(cur_if->s_ipkts, "%lu", cur_if->ipkts);
  308.                 i = strlen(cur_if->s_ipkts);
  309.                 if (i > max_ipkts)
  310.                     max_ipkts = i;
  311.                 break;
  312.             case 14: /* ifInErrors      */
  313.                 sprintf(cur_if->s_ierrs, "%lu", *vp->val.integer);
  314.                 i = strlen(cur_if->s_ierrs);
  315.                 if (i > max_ierrs)
  316.                     max_ierrs = i;
  317.                 break;
  318.             case 16: /* ifOutOctets      */
  319.                 sprintf(cur_if->s_obytes, "%lu", *vp->val.integer);
  320.                 i = strlen(cur_if->s_obytes);
  321.                 if (i > max_obytes)
  322.                     max_obytes = i;
  323.                 break;
  324.             case 17: /* ifOutUcastPkts */
  325.                 cur_if->opkts += *vp->val.integer;
  326.                 sprintf(cur_if->s_opkts, "%lu", cur_if->opkts);
  327.                 i = strlen(cur_if->s_opkts);
  328.                 if (i > max_opkts)
  329.                     max_opkts = i;
  330.                 break;
  331.             case 18: /* ifOutNUcastPkts */
  332.                 cur_if->opkts += *vp->val.integer;
  333.                 sprintf(cur_if->s_opkts, "%lu", cur_if->opkts);
  334.                 i = strlen(cur_if->s_opkts);
  335.                 if (i > max_opkts)
  336.                     max_opkts = i;
  337.                 break;
  338.             case 19:    /* ifOutDiscards   */
  339.                 cur_if->drops = *vp->val.integer;
  340.                 break;
  341.             case 20: /* ifOutErrors     */
  342.                 sprintf(cur_if->s_oerrs, "%lu", *vp->val.integer);
  343.                 i = strlen(cur_if->s_oerrs);
  344.                 if (i > max_oerrs)
  345.                     max_oerrs = i;
  346.                 break;
  347.             case 21: /* ifOutQLen       */
  348.                 sprintf(cur_if->s_outq, "%lu", *vp->val.integer);
  349.                 i = strlen(cur_if->s_outq);
  350.                 if (i > max_outq)
  351.                     max_outq = i;
  352.                 break;
  353.             }
  354.         }
  356.         /*
  357.          *  XXX - Perhaps query ifXTable for additional info ??
  358.          *    (ifName/ifAlias, or HC counters)
  359.          */
  361.         /*
  362.          * If we're to monitor a particular interface, then
  363.          *   ignore all others.  It would be more efficient
  364.          *   to check this earlier (as part of processing 
  365.          *   the varbind list).  But performing this test here
  366.          *   means we can recognise ifXTable names as well)
  367.          */
  368.         if ( intrface && strcmp( cur_if->name, intrface ) != 0) {
  369.             SNMP_FREE( cur_if );
  370.             cur_if = NULL;
  371.         }
  373.         /*
  374.          * Insert the IP address and network settings, and
  375.          *   add the new _if_stat structure to the list.
  376.          */
  377.         if ( cur_if ) {
  378.             _set_address( cur_if );
  379.             i = strlen(cur_if->ip);
  380.             if (i > max_ip)
  381.                 max_ip = i;
  382.             i = strlen(cur_if->route);
  383.             if (i > max_route)
  384.                 max_route = i;
  386.             if ( if_tail ) {
  387.                 if_tail->next = cur_if;
  388.                 if_tail       = cur_if;
  389.             } else {
  390.                 if_head       = cur_if;
  391.                 if_tail       = cur_if;
  392.             }
  393.         }
  394.     }   /* while (1) */
  396.         /*
  397.          * Now display the specified results (in Free-BSD format)
  398.          *   setting the field widths appropriately....
  399.          */
  400.     printf("%*.*s %5.5s %*.*s %*.*s",
  401.            -max_name,  max_name,  "Name", "Mtu",
  402.            -max_route, max_route, "Network",
  403.            -max_ip,    max_ip,    "Address");
  404.     if (oflag) {
  405.         printf(" %*s %*s", max_ibytes,  "Ibytes",
  406.                            max_obytes,  "Obytes");
  407.     } else {
  408.         printf(" %*s %*s", max_ipkts,   "Ipkts",
  409.                            max_ierrs,   "Ierrs");
  410.         if (bflag) 
  411.             printf(" %*s", max_ibytes,  "Ibytes");
  413.         printf(" %*s %*s", max_opkts,   "Opkts",
  414.                            max_oerrs,   "Oerrs");
  415.         if (bflag) 
  416.             printf(" %*s", max_obytes,  "Obytes");
  418.         printf(" %*s",     max_outq,    "Queue");
  419.     }
  420.  /* if (tflag)
  421.         printf(" %s", "Time");
  422.   */
  423.     if (dflag)
  424.         printf(" %s", "Drop");
  425.     putchar('n');
  427.     for (cur_if = if_head; cur_if; cur_if=cur_if->next) {
  428.         if (cur_if->name[0] == 0)
  429.             continue;
  430.         printf( "%*.*s %5d", -max_name,  max_name,  cur_if->name, cur_if->mtu);
  431.         printf(" %*.*s",     -max_route, max_route, cur_if->route);
  432.         printf(" %*.*s",     -max_ip,    max_ip,    cur_if->ip);
  434.         if (oflag) {
  435.             printf(" %*s %*s", max_ibytes,  cur_if->s_ibytes,
  436.                                max_obytes,  cur_if->s_obytes);
  437.         } else {
  438.             printf(" %*s %*s", max_ipkts,   cur_if->s_ipkts,
  439.                                max_ierrs,   cur_if->s_ierrs);
  440.             if (bflag) 
  441.                 printf(" %*s", max_ibytes,  cur_if->s_ibytes);
  442.     
  443.             printf(" %*s %*s", max_opkts,   cur_if->s_opkts,
  444.                                max_oerrs,   cur_if->s_oerrs);
  445.             if (bflag) 
  446.                 printf(" %*s", max_obytes,  cur_if->s_obytes);
  447.             printf(" %*s",     max_outq,    cur_if->s_outq);
  448.         }
  449.      /* if (tflag)
  450.             printf(" %4d", cur_if->???);
  451.       */
  452.         if (dflag)
  453.             printf(" %4d", cur_if->drops);
  454.         putchar('n');
  455.     }
  457.         /*
  458.          * ... and tidy up.
  459.          */
  460.     for (cur_if = if_head; cur_if; cur_if=if_head) {
  461.         if_head=cur_if->next;
  462.         cur_if->next = NULL;
  463.         SNMP_FREE( cur_if );
  464.     }
  465. }
  468. #define MAXIF 100
  469. struct iftot {
  470. char ift_name[128]; /* interface name */
  471.         int     ifIndex;
  472. u_long ift_ip; /* input packets */
  473. u_long ift_ib; /* input bytes */
  474. u_long ift_ie; /* input errors */
  475. u_long ift_op; /* output packets */
  476. u_long ift_ob; /* output bytes */
  477. u_long ift_oe; /* output errors */
  478. u_long ift_co; /* collisions */
  479. u_long ift_dr; /* drops */
  480. };
  482. int signalled; /* set if alarm goes off "early" */
  484. /*
  485.  * Print a running summary of interface statistics.
  486.  * Repeat display every interval seconds, showing statistics
  487.  * collected over that interval.  Assumes that interval is non-zero.
  488.  * First line printed at top of screen is always cumulative.
  489.  */
  490. static void
  491. sidewaysintpr(unsigned int interval)
  492. {
  493.     /*
  494.      * As with the "one-shot" interface display, there are
  495.      *   two different possible output formats.  The Net/
  496.      *   Open-BSD style displays both information about a
  497.      *   single interface *and* the overall totals.
  498.      * The equivalent Free-BSD approach is to report on one
  499.      *   or the other (rather than both).  This is probably
  500.      *   more useful (IMO), and significantly more efficient.
  501.      *   So that's the style implemented here.
  502.      *
  503.      * Note that the 'ifcol' OID buffer can represent a full
  504.      *   instance (including ifIndex), rather than just a
  505.      *   column object OID, as with the one-shot code.
  506.      */
  507.     oid    ifcol_oid[]  = { 1,3,6,1,2,1,2,2,1,0,0 };
  508.     size_t ifcol_len    = OID_LENGTH( ifcol_oid );
  509.     netsnmp_variable_list *var, *vp;
  510.     struct iftot *ip  = NULL, *cur_if = NULL;    /* single I/F display */
  511.     struct iftot *sum = NULL, *total  = NULL;    /* overall summary    */
  512.     int    line;
  513.     int    first;
  514.     int    i;
  516.     var = NULL;
  517.     if ( intrface ) {
  518.         /*
  519.          * Locate the ifIndex of the interface to monitor,
  520.          *   by walking the ifDescr column of the ifTable
  521.          */
  522.         ifcol_oid[ ifcol_len-2 ] = 2;   /* ifDescr  */
  523.         snmp_varlist_add_variable( &var, ifcol_oid, ifcol_len-1,
  524.                                    ASN_NULL, NULL,  0);
  525.         i = strlen(intrface);
  526.         netsnmp_query_walk( var, ss );
  527.         for (vp=var; vp; vp=vp->next_variable) {
  528.             if (strncmp(intrface, (char *)vp->val.string, i) == 0 &&
  529.                 i == vp->val_len)
  530.                 break;  /* found requested interface */
  531.         }
  532.         /*
  533.          * XXX - Might be worth searching ifName/ifAlias as well
  534.          */
  535.         if (!vp) {
  536.             fprintf(stderr, "%s: unknown interfacen", intrface );
  537.             exit(1);
  538.         }
  540.         /*
  541.          *  Prepare the current and previous 'iftot' structures,
  542.          *    and set the ifIndex value in the OID buffer.
  543.          */
  544.         ip     = SNMP_MALLOC_TYPEDEF( struct iftot );
  545.         cur_if = SNMP_MALLOC_TYPEDEF( struct iftot );
  546.         if (!ip || !cur_if) {
  547.             fprintf(stderr, "internal errorn");
  548.             exit(1);
  549.         }
  550.         ifcol_oid[ ifcol_len-1 ] = vp->name[ ifcol_len-1 ];
  551.         snmp_free_var( var );
  552.         var = NULL;
  553.     } else {
  554.         /*
  555.          *  Prepare the current and previous 'iftot' structures.
  556.          *    (using different pointers, for consistency with *BSD code)
  557.          */
  558.         sum   = SNMP_MALLOC_TYPEDEF( struct iftot );
  559.         total = SNMP_MALLOC_TYPEDEF( struct iftot );
  560.         if (!sum || !total) {
  561.             fprintf(stderr, "internal errorn");
  562.             exit(1);
  563.         }
  564.     }
  566.     timerSet( interval );
  567.     first = 1;
  568. banner:
  569.     printf( "%17s %14s %16s", "input",
  570.         intrface ? intrface : "(Total)", "output");
  571.     putchar('n');
  572.     printf( "%10s %5s %10s %10s %5s %10s %5s",
  573.         "packets", "errs", "bytes", "packets", "errs", "bytes", "colls");
  574.     if (dflag)
  575. printf(" %5.5s", "drops");
  576.     putchar('n');
  577.     fflush(stdout);
  578.     line = 0;
  579. loop:
  580.     if ( intrface ) {
  581. #define ADD_IFVAR( x ) ifcol_oid[ ifcol_len-2 ] = x; 
  582.     snmp_varlist_add_variable( &var, ifcol_oid, ifcol_len, ASN_NULL, NULL,  0)
  583.     /*  if (bflag) { */
  584.             ADD_IFVAR( 10 );        /* ifInOctets     */
  585.             ADD_IFVAR( 16 );        /* ifOutOctets    */
  586.     /*  } */
  587.         ADD_IFVAR( 11 );            /* ifInUcastPkts  */
  588.         ADD_IFVAR( 12 );            /* ifInNUcastPkts */
  589.         ADD_IFVAR( 14 );            /* ifInErrors     */
  590.         ADD_IFVAR( 17 );            /* ifOutUcastPkts */
  591.         ADD_IFVAR( 18 );            /* ifOutNUcastPkts */
  592.         ADD_IFVAR( 20 );            /* ifOutErrors    */
  593.         ADD_IFVAR( 21 );            /* ifOutQLen      */
  594.         if (dflag) {
  595.             ADD_IFVAR( 19 );        /* ifOutDiscards  */
  596.         }
  597. #undef ADD_IFVAR
  599.         netsnmp_query_get( var, ss );   /* Or parallel walk ?? */
  600.         cur_if->ift_ip = 0;
  601.         cur_if->ift_ib = 0;
  602.         cur_if->ift_ie = 0;
  603.         cur_if->ift_op = 0;
  604.         cur_if->ift_ob = 0;
  605.         cur_if->ift_oe = 0;
  606.         cur_if->ift_co = 0;
  607.         cur_if->ift_dr = 0;
  608.         cur_if->ifIndex = var->name[ ifcol_len-1 ];
  609.         for (vp=var; vp; vp=vp->next_variable) {
  610.             switch (vp->name[ifcol_len-2]) {
  611.             case 10:    /* ifInOctets */
  612.                 cur_if->ift_ib = *vp->val.integer;
  613.                 break;
  614.             case 11:    /* ifInUcastPkts */
  615.                 cur_if->ift_ip += *vp->val.integer;
  616.                 break;
  617.             case 12:    /* ifInNUcastPkts */
  618.                 cur_if->ift_ip += *vp->val.integer;
  619.                 break;
  620.             case 14:    /* ifInErrors */
  621.                 cur_if->ift_ie = *vp->val.integer;
  622.                 break;
  623.             case 16:    /* ifOutOctets */
  624.                 cur_if->ift_ob = *vp->val.integer;
  625.                 break;
  626.             case 17:    /* ifOutUcastPkts */
  627.                 cur_if->ift_op += *vp->val.integer;
  628.                 break;
  629.             case 18:    /* ifOutNUcastPkts */
  630.                 cur_if->ift_op += *vp->val.integer;
  631.                 break;
  632.             case 19:    /* ifOutDiscards */
  633.                 cur_if->ift_dr = *vp->val.integer;
  634.                 break;
  635.             case 20:    /* ifOutErrors */
  636.                 cur_if->ift_oe = *vp->val.integer;
  637.                 break;
  638.             case 21:    /* ifOutQLen */
  639.                 cur_if->ift_co = *vp->val.integer;
  640.                 break;
  641.             }
  642.         }
  643.         snmp_free_varbind( var );
  644.         var = NULL;
  645.  
  646.         if (!first) {
  647.       printf("%10lu %5lu %10lu %10lu %5lu %10lu %5lu",
  648.   cur_if->ift_ip - ip->ift_ip,
  649.   cur_if->ift_ie - ip->ift_ie,
  650. cur_if->ift_ib - ip->ift_ib,
  651. cur_if->ift_op - ip->ift_op,
  652. cur_if->ift_oe - ip->ift_oe,
  653. cur_if->ift_ob - ip->ift_ob,
  654. cur_if->ift_co - ip->ift_co);
  655.     if (dflag)
  656. printf(" %5lu", cur_if->ift_dr - ip->ift_dr);
  657.             putchar('n');
  658.             fflush(stdout);
  659. }
  660. ip->ift_ip = cur_if->ift_ip;
  661. ip->ift_ie = cur_if->ift_ie;
  662. ip->ift_ib = cur_if->ift_ib;
  663. ip->ift_op = cur_if->ift_op;
  664. ip->ift_oe = cur_if->ift_oe;
  665. ip->ift_ob = cur_if->ift_ob;
  666. ip->ift_co = cur_if->ift_co;
  667. ip->ift_dr = cur_if->ift_dr;
  668.     }  /* (single) interface */
  669.     else {
  670. sum->ift_ip = 0;
  671. sum->ift_ib = 0;
  672. sum->ift_ie = 0;
  673. sum->ift_op = 0;
  674. sum->ift_ob = 0;
  675. sum->ift_oe = 0;
  676. sum->ift_co = 0;
  677. sum->ift_dr = 0;
  678. #define ADD_IFVAR( x ) ifcol_oid[ ifcol_len-2 ] = x; 
  679.     snmp_varlist_add_variable( &var, ifcol_oid, ifcol_len-1, ASN_NULL, NULL,  0)
  680.         ADD_IFVAR( 11 );            /* ifInUcastPkts  */
  681.         ADD_IFVAR( 12 );            /* ifInNUcastPkts */
  682.         ADD_IFVAR( 14 );            /* ifInErrors     */
  683.         ADD_IFVAR( 17 );            /* ifOutUcastPkts */
  684.         ADD_IFVAR( 18 );            /* ifOutNUcastPkts */
  685.         ADD_IFVAR( 20 );            /* ifOutErrors    */
  686.         ADD_IFVAR( 21 );            /* ifOutQLen      */
  687.     /*  if (bflag) { */
  688.             ADD_IFVAR( 10 );        /* ifInOctets     */
  689.             ADD_IFVAR( 16 );        /* ifOutOctets    */
  690.     /*  } */
  691.         if (dflag) {
  692.             ADD_IFVAR( 19 );        /* ifOutDiscards  */
  693.         }
  694. #undef ADD_IFVAR
  696.         ifcol_oid[ ifcol_len-2 ] = 11;       /* ifInUcastPkts */
  697.         while ( 1 ) {
  698.             if (netsnmp_query_getnext( var, ss ) != SNMP_ERR_NOERROR)
  699.                 break;
  700.             if ( snmp_oid_compare( ifcol_oid, ifcol_len-2,
  701.                                    var->name, ifcol_len-2) != 0 )
  702.                 break;    /* End of Table */
  703.             
  704.             for ( vp=var; vp; vp=vp->next_variable ) {
  705.                 switch ( vp->name[ ifcol_len-2 ] ) {
  706.                 case 10:    /* ifInOctets */
  707.                     sum->ift_ib += *vp->val.integer;
  708.                     break;
  709.                 case 11:    /* ifInUcastPkts */
  710.                     sum->ift_ip += *vp->val.integer;
  711.                     break;
  712.                 case 12:    /* ifInNUcastPkts */
  713.                     sum->ift_ip += *vp->val.integer;
  714.                     break;
  715.                 case 14:    /* ifInErrors */
  716.                     sum->ift_ie += *vp->val.integer;
  717.                     break;
  718.                 case 16:    /* ifOutOctets */
  719.                     sum->ift_ob += *vp->val.integer;
  720.                     break;
  721.                 case 17:    /* ifOutUcastPkts */
  722.                     sum->ift_op += *vp->val.integer;
  723.                     break;
  724.                 case 18:    /* ifOutNUcastPkts */
  725.                     sum->ift_op += *vp->val.integer;
  726.                     break;
  727.                 case 19:    /* ifOutDiscards */
  728.                     sum->ift_dr += *vp->val.integer;
  729.                     break;
  730.                 case 20:    /* ifOutErrors */
  731.                     sum->ift_oe += *vp->val.integer;
  732.                     break;
  733.                 case 21:    /* ifOutQLen */
  734.                     sum->ift_co += *vp->val.integer;
  735.                     break;
  736.                 }
  737.             }
  738.             /*
  739.              * Now loop to retrieve the next entry from the table.
  740.              */
  741.         }   /* while (1) */
  743.         snmp_free_varbind( var );
  744.         var = NULL;
  745.  
  746.         if (!first) {
  747.       printf("%10lu %5lu %10lu %10lu %5lu %10lu %5lu",
  748.   sum->ift_ip - total->ift_ip,
  749.   sum->ift_ie - total->ift_ie,
  750. sum->ift_ib - total->ift_ib,
  751. sum->ift_op - total->ift_op,
  752. sum->ift_oe - total->ift_oe,
  753. sum->ift_ob - total->ift_ob,
  754. sum->ift_co - total->ift_co);
  755.     if (dflag)
  756. printf(" %5lu", sum->ift_dr - total->ift_dr);
  757.             putchar('n');
  758.             fflush(stdout);
  759. }
  760. total->ift_ip = sum->ift_ip;
  761. total->ift_ie = sum->ift_ie;
  762. total->ift_ib = sum->ift_ib;
  763. total->ift_op = sum->ift_op;
  764. total->ift_oe = sum->ift_oe;
  765. total->ift_ob = sum->ift_ob;
  766. total->ift_co = sum->ift_co;
  767. total->ift_dr = sum->ift_dr;
  768.     }  /* overall summary */
  770.     timerPause();
  771.     timerSet(interval);
  772.     line++;
  773.     first = 0;
  774.     if (line == 21)
  775.      goto banner;
  776.     else
  777.      goto loop;
  778.     /*NOTREACHED*/
  779. }
  782. /*
  783.  * timerSet sets or resets the timer to fire in "interval" seconds.
  784.  * timerPause waits only if the timer has not fired.
  785.  * timing precision is not considered important.
  786.  */
  788. #if (defined(WIN32) || defined(cygwin))
  789. static int      sav_int;
  790. static time_t   timezup;
  791. static void
  792. timerSet(int interval_seconds)
  793. {
  794.     sav_int = interval_seconds;
  795.     timezup = time(0) + interval_seconds;
  796. }
  798. /*
  799.  * you can do better than this ! 
  800.  */
  801. static void
  802. timerPause(void)
  803. {
  804.     time_t          now;
  805.     while (time(&now) < timezup)
  806. #ifdef WIN32
  807.         Sleep(400);
  808. #else
  809.     {
  810.         struct timeval  tx;
  811.         tx.tv_sec = 0;
  812.         tx.tv_usec = 400 * 1000;        /* 400 milliseconds */
  813.         select(0, 0, 0, 0, &tx);
  814.     }
  815. #endif
  816. }
  818. #else
  820. /*
  821.  * Called if an interval expires before sidewaysintpr has completed a loop.
  822.  * Sets a flag to not wait for the alarm.
  823.  */
  824. RETSIGTYPE
  825. catchalarm(int sig)
  826. {
  827.     signalled = YES;
  828. }
  830. static void
  831. timerSet(int interval_seconds)
  832. {
  833. #ifdef HAVE_SIGSET
  834.     (void) sigset(SIGALRM, catchalarm);
  835. #else
  836.     (void) signal(SIGALRM, catchalarm);
  837. #endif
  838.     signalled = NO;
  839.     (void) alarm(interval_seconds);
  840. }
  842. static void
  843. timerPause(void)
  844. {
  845. #ifdef HAVE_SIGHOLD
  846.     sighold(SIGALRM);
  847.     if (!signalled) {
  848.         sigpause(SIGALRM);
  849.     }
  850. #else
  851.     int             oldmask;
  852.     oldmask = sigblock(sigmask(SIGALRM));
  853.     if (!signalled) {
  854.         sigpause(0);
  855.     }
  856.     sigsetmask(oldmask);
  857. #endif
  858. }
  860. #endif                          /* !WIN32 && !cygwin */