apps/snmpgetnext.c - vendor/opensource/netsnmp - Git at Google

 /*
  * snmpgetnext.c - send snmp GETNEXT requests to a network entity.
  *
  */
 /***********************************************************************
 	Copyright 1988, 1989, 1991, 1992 by Carnegie Mellon University

                       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, and that the name of CMU not be
 used in advertising or publicity pertaining to distribution of the
 software without specific, written prior permission.

 CMU DISCLAIMS ALL WARRANTIES WITH REGARD TO THIS SOFTWARE, INCLUDING
 ALL IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS, IN NO EVENT SHALL
 CMU 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 <config.h>

 #include <sys/types.h>
 #if HAVE_NETINET_IN_H
 #include <netinet/in.h>
 #endif
 #include <stdio.h>
 #include <ctype.h>
 #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
 #include <netdb.h>

 #include "snmp.h"
 #include "asn1.h"
 #include "snmp_impl.h"
 #include "snmp_api.h"
 #include "snmp_client.h"
 #include "party.h"
 #include "context.h"
 #include "view.h"
 #include "acl.h"

 extern int  errno;
 int	snmp_dump_packet = 0;

 usage(){
     fprintf(stderr, "Usage: snmpgetnext -v 1 [-q] hostname community [objectID]+           or:\n");
     fprintf(stderr, "Usage: snmpgetnext [-v 2] [-q] hostname noAuth [objectID]+            or:\n");
     fprintf(stderr, "Usage: snmpgetnext [-v 2] [-q] hostname srcParty dstParty context [objectID]+\n");
 }

 main(argc, argv)
     int	    argc;
     char    *argv[];
 {
     struct snmp_session session, *ss;
     struct snmp_pdu *pdu, *response;
     struct variable_list *vars;
     int	arg;
     char *hostname = NULL;
     char *community = NULL;
     int timeout_flag = 0, timeout, retransmission_flag = 0, retransmission;
     int	count, current_name = 0;
     char *names[128];
     oid name[MAX_NAME_LEN];
     int name_length;
     int status;
     int version = 2;
     int port_flag = 0;
     int dest_port = 0;
     u_long      srcclock, dstclock;
     int clock_flag = 0;
     oid src[MAX_NAME_LEN], dst[MAX_NAME_LEN], context[MAX_NAME_LEN];
     int srclen = 0, dstlen = 0, contextlen = 0;
     struct partyEntry *pp;
     struct contextEntry *cxp;
     int trivialSNMPv2 = FALSE;
     struct hostent *hp;
     u_long destAddr;
     char ctmp[300];


     init_mib();
     for(arg = 1; arg < argc; arg++){
 	if (argv[arg][0] == '-'){
 	    switch(argv[arg][1]){
 		case 'd':
 		    snmp_dump_packet++;
 		    break;
 		case 'q':
 		    quick_print++;
 		    break;
                 case 'p':
                     port_flag++;
                     dest_port = atoi(argv[++arg]);
                     break;
                 case 't':
                     timeout_flag++;
                     timeout = atoi(argv[++arg]) * 1000000L;
                     break;
                 case 'r':
                     retransmission_flag++;
                     retransmission = atoi(argv[++arg]);
                     break;
                 case 'c':
                     clock_flag++;
                     srcclock = atoi(argv[++arg]);
                     dstclock = atoi(argv[++arg]);
                     break;
                 case 'v':
                     version = atoi(argv[++arg]);
                     if (version < 1 || version > 2){
                         fprintf(stderr, "Invalid version\n");
                         usage();
                         exit(1);
                     }
                     break;
 		default:
 		    printf("invalid option: -%c\n", argv[arg][1]);
 		    break;
 	    }
 	    continue;
 	}
 	if (hostname == NULL){
 	    hostname = argv[arg];
         } else if (version == 1 && community == NULL){
             community = argv[arg];
 	} else if (version == 2 && srclen == 0 && !trivialSNMPv2){
             sprintf(ctmp,"%s/party.conf",SNMPLIBPATH);
 	    if (read_party_database(ctmp) > 0){
 		fprintf(stderr,
 			"Couldn't read party database from %s\n",ctmp);
 		exit(0);
 	    }
             sprintf(ctmp,"%s/context.conf",SNMPLIBPATH);
 	    if (read_context_database(ctmp) > 0){
 		fprintf(stderr,
 			"Couldn't read context database from %s\n",ctmp);
 		exit(0);
 	    }
             sprintf(ctmp,"%s/acl.conf",SNMPLIBPATH);
 	    if (read_acl_database(ctmp) > 0){
 		fprintf(stderr,
 			"Couldn't read access control database from %s\n",ctmp);
 		exit(0);
 	    }
             if (!strcasecmp(argv[arg], "noauth")){
                 trivialSNMPv2 = TRUE;
             } else {
                 party_scanInit();
 		for(pp = party_scanNext(); pp; pp = party_scanNext()){
 		    if (!strcasecmp(pp->partyName, argv[arg])){
 			srclen = pp->partyIdentityLen;
 #ifdef SVR4
 			memmove(src, pp->partyIdentity, srclen * sizeof(oid));
 #else
 			bcopy(pp->partyIdentity, src, srclen * sizeof(oid));
 #endif
 			break;
 		    }
 		}
 		if (!pp){
 		    srclen = MAX_NAME_LEN;
 		    if (!read_objid(argv[arg], src, &srclen)){
 			printf("Invalid source party: %s\n", argv[arg]);
 			srclen = 0;
 			usage();
 			exit(1);
 		    }
 		}
 	    }
 	} else if (version == 2 && dstlen == 0 && !trivialSNMPv2){
 	    dstlen = MAX_NAME_LEN;
 	    party_scanInit();
 	    for(pp = party_scanNext(); pp; pp = party_scanNext()){
 		if (!strcasecmp(pp->partyName, argv[arg])){
 		    dstlen = pp->partyIdentityLen;
 #ifdef SVR4
 		    memmove(dst, pp->partyIdentity, dstlen * sizeof(oid));
 #else
 		    bcopy(pp->partyIdentity, dst, dstlen * sizeof(oid));
 #endif
 		    break;
 		}
 	    }
 	    if (!pp){
 		if (!read_objid(argv[arg], dst, &dstlen)){
 		    printf("Invalid destination party: %s\n", argv[arg]);
 		    dstlen = 0;
 		    usage();
 		    exit(1);
 		}
 	    }
         } else if (version == 2 && contextlen == 0 && !trivialSNMPv2){
             contextlen = MAX_NAME_LEN;
             context_scanInit();
             for(cxp = context_scanNext(); cxp; cxp = context_scanNext()){
                 if (!strcasecmp(cxp->contextName, argv[arg])){
                     contextlen = cxp->contextIdentityLen;
 #ifdef SVR4
                     memmove(context, cxp->contextIdentity,
                           contextlen * sizeof(oid));
 #else
                     bcopy(cxp->contextIdentity, context,
                           contextlen * sizeof(oid));
 #endif
                     break;
                 }
             }
             if (!cxp){
                 if (!read_objid(argv[arg], context, &contextlen)){
                     printf("Invalid context: %s\n", argv[arg]);
                     contextlen = 0;
 		    usage();
                     exit(1);
                 }
             }
 	} else {
 	    names[current_name++] = argv[arg];
 	}
     }

     if (!hostname || current_name <= 0 || (version < 1) || (version > 2)
 	|| (version == 1 && !community)
 	|| (version == 2 && (!srclen || !dstlen || !contextlen)
 	    && !trivialSNMPv2)){
 	usage();
 	exit(1);
     }

     if (trivialSNMPv2){
 	if ((destAddr = inet_addr(hostname)) == -1){
 	    hp = gethostbyname(hostname);
 	    if (hp == NULL){
 		fprintf(stderr, "unknown host: %s\n", hostname);
 		exit(1);
 	    } else {
 #ifdef SVR4
 		memmove((char *)&destAddr, (char *)hp->h_addr,
 		      hp->h_length);
 #else
 		bcopy((char *)hp->h_addr, (char *)&destAddr,
 		      hp->h_length);
 #endif
 	    }
 	}
 	srclen = dstlen = contextlen = MAX_NAME_LEN;
 	ms_party_init(destAddr, src, &srclen, dst, &dstlen,
 		      context, &contextlen);
     }

     if (clock_flag){
         pp = party_getEntry(src, srclen);
         if (pp){
             pp->partyAuthClock = srcclock;
             gettimeofday(&pp->tv, (struct timezone *)0);
             pp->tv.tv_sec -= pp->partyAuthClock;
         }
         pp = party_getEntry(dst, dstlen);
         if (pp){
             pp->partyAuthClock = dstclock;
             gettimeofday(&pp->tv, (struct timezone *)0);
             pp->tv.tv_sec -= pp->partyAuthClock;
         }
     }

 #ifdef SVR4
     memset((char *)&session, NULL, sizeof(struct snmp_session));
 #else
     bzero((char *)&session, sizeof(struct snmp_session));
 #endif
     session.peername = hostname;
     if (port_flag)
         session.remote_port = dest_port;

     if (version == 1){
         session.version = SNMP_VERSION_1;
         session.community = (u_char *)community;
         session.community_len = strlen((char *)community);
     } else if (version == 2){
         session.version = SNMP_VERSION_2;
         session.srcParty = src;
         session.srcPartyLen = srclen;
         session.dstParty = dst;
         session.dstPartyLen = dstlen;
         session.context = context;
         session.contextLen = contextlen;
     }
     if (retransmission_flag)
         session.retries = retransmission;
     else
         session.retries = SNMP_DEFAULT_RETRIES;
     if (timeout_flag)
         session.timeout = timeout;
     else
         session.timeout = SNMP_DEFAULT_TIMEOUT;

     session.authenticator = NULL;
     snmp_synch_setup(&session);
     ss = snmp_open(&session);
     if (ss == NULL){
 	printf("Couldn't open snmp\n");
 	exit(-1);
     }

     pdu = snmp_pdu_create(GETNEXT_REQ_MSG);

     for(count = 0; count < current_name; count++){
 	name_length = MAX_NAME_LEN;
 	if (!read_objid(names[count], name, &name_length)){
 	    printf("Invalid object identifier: %s\n", names[count]);
 	}

 	snmp_add_null_var(pdu, name, name_length);
     }

 retry:
     status = snmp_synch_response(ss, pdu, &response);
     if (status == STAT_SUCCESS){
 	if (response->errstat == SNMP_ERR_NOERROR){
 	    for(vars = response->variables; vars; vars = vars->next_variable)
 		print_variable(vars->name, vars->name_length, vars);
 	} else {
 	    printf("Error in packet.\nReason: %s\n", snmp_errstring(response->errstat));
 	    if (response->errstat == SNMP_ERR_NOSUCHNAME){
 		printf("This name doesn't exist: ");
 		for(count = 1, vars = response->variables; vars && count != response->errindex;
 		    vars = vars->next_variable, count++)
 			;
 		if (vars)
 		    print_objid(vars->name, vars->name_length);
 		printf("\n");
 	    }
 	    if ((pdu = snmp_fix_pdu(response, GETNEXT_REQ_MSG)) != NULL)
 		goto retry;
 	}

     } else if (status == STAT_TIMEOUT){
 	printf("No Response from %s\n", hostname);
     } else {    /* status == STAT_ERROR */
 	printf("An error occurred, Quitting\n");
     }

     if (response)
 	snmp_free_pdu(response);
     snmp_close(ss);
 }
	/*
	* snmpgetnext.c - send snmp GETNEXT requests to a network entity.
	*
	*/
	/***********************************************************************
	Copyright 1988, 1989, 1991, 1992 by Carnegie Mellon University

	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, and that the name of CMU not be
	used in advertising or publicity pertaining to distribution of the
	software without specific, written prior permission.

	CMU DISCLAIMS ALL WARRANTIES WITH REGARD TO THIS SOFTWARE, INCLUDING
	ALL IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS, IN NO EVENT SHALL
	CMU 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 <config.h>

	#include <sys/types.h>
	#if HAVE_NETINET_IN_H
	#include <netinet/in.h>
	#endif
	#include <stdio.h>
	#include <ctype.h>
	#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
	#include <netdb.h>

	#include "snmp.h"
	#include "asn1.h"
	#include "snmp_impl.h"
	#include "snmp_api.h"
	#include "snmp_client.h"
	#include "party.h"
	#include "context.h"
	#include "view.h"
	#include "acl.h"

	extern int errno;
	int snmp_dump_packet = 0;

	usage(){
	fprintf(stderr, "Usage: snmpgetnext -v 1 [-q] hostname community [objectID]+ or:\n");
	fprintf(stderr, "Usage: snmpgetnext [-v 2] [-q] hostname noAuth [objectID]+ or:\n");
	fprintf(stderr, "Usage: snmpgetnext [-v 2] [-q] hostname srcParty dstParty context [objectID]+\n");
	}

	main(argc, argv)
	int argc;
	char *argv[];
	{
	struct snmp_session session, *ss;
	struct snmp_pdu pdu, response;
	struct variable_list *vars;
	int arg;
	char *hostname = NULL;
	char *community = NULL;
	int timeout_flag = 0, timeout, retransmission_flag = 0, retransmission;
	int count, current_name = 0;
	char *names[128];
	oid name[MAX_NAME_LEN];
	int name_length;
	int status;
	int version = 2;
	int port_flag = 0;
	int dest_port = 0;
	u_long srcclock, dstclock;
	int clock_flag = 0;
	oid src[MAX_NAME_LEN], dst[MAX_NAME_LEN], context[MAX_NAME_LEN];
	int srclen = 0, dstlen = 0, contextlen = 0;
	struct partyEntry *pp;
	struct contextEntry *cxp;
	int trivialSNMPv2 = FALSE;
	struct hostent *hp;
	u_long destAddr;
	char ctmp[300];



	init_mib();
	for(arg = 1; arg < argc; arg++){
	if (argv[arg][0] == '-'){
	switch(argv[arg][1]){
	case 'd':
	snmp_dump_packet++;
	break;
	case 'q':
	quick_print++;
	break;
	case 'p':
	port_flag++;
	dest_port = atoi(argv[++arg]);
	break;
	case 't':
	timeout_flag++;
	timeout = atoi(argv[++arg]) * 1000000L;
	break;
	case 'r':
	retransmission_flag++;
	retransmission = atoi(argv[++arg]);
	break;
	case 'c':
	clock_flag++;
	srcclock = atoi(argv[++arg]);
	dstclock = atoi(argv[++arg]);
	break;
	case 'v':
	version = atoi(argv[++arg]);
	if (version < 1 \|\| version > 2){
	fprintf(stderr, "Invalid version\n");
	usage();
	exit(1);
	}
	break;
	default:
	printf("invalid option: -%c\n", argv[arg][1]);
	break;
	}
	continue;
	}
	if (hostname == NULL){
	hostname = argv[arg];
	} else if (version == 1 && community == NULL){
	community = argv[arg];
	} else if (version == 2 && srclen == 0 && !trivialSNMPv2){
	sprintf(ctmp,"%s/party.conf",SNMPLIBPATH);
	if (read_party_database(ctmp) > 0){
	fprintf(stderr,
	"Couldn't read party database from %s\n",ctmp);
	exit(0);
	}
	sprintf(ctmp,"%s/context.conf",SNMPLIBPATH);
	if (read_context_database(ctmp) > 0){
	fprintf(stderr,
	"Couldn't read context database from %s\n",ctmp);
	exit(0);
	}
	sprintf(ctmp,"%s/acl.conf",SNMPLIBPATH);
	if (read_acl_database(ctmp) > 0){
	fprintf(stderr,
	"Couldn't read access control database from %s\n",ctmp);
	exit(0);
	}
	if (!strcasecmp(argv[arg], "noauth")){
	trivialSNMPv2 = TRUE;
	} else {
	party_scanInit();
	for(pp = party_scanNext(); pp; pp = party_scanNext()){
	if (!strcasecmp(pp->partyName, argv[arg])){
	srclen = pp->partyIdentityLen;
	#ifdef SVR4
	memmove(src, pp->partyIdentity, srclen * sizeof(oid));
	#else
	bcopy(pp->partyIdentity, src, srclen * sizeof(oid));
	#endif
	break;
	}
	}
	if (!pp){
	srclen = MAX_NAME_LEN;
	if (!read_objid(argv[arg], src, &srclen)){
	printf("Invalid source party: %s\n", argv[arg]);
	srclen = 0;
	usage();
	exit(1);
	}
	}
	}
	} else if (version == 2 && dstlen == 0 && !trivialSNMPv2){
	dstlen = MAX_NAME_LEN;
	party_scanInit();
	for(pp = party_scanNext(); pp; pp = party_scanNext()){
	if (!strcasecmp(pp->partyName, argv[arg])){
	dstlen = pp->partyIdentityLen;
	#ifdef SVR4
	memmove(dst, pp->partyIdentity, dstlen * sizeof(oid));
	#else
	bcopy(pp->partyIdentity, dst, dstlen * sizeof(oid));
	#endif
	break;
	}
	}
	if (!pp){
	if (!read_objid(argv[arg], dst, &dstlen)){
	printf("Invalid destination party: %s\n", argv[arg]);
	dstlen = 0;
	usage();
	exit(1);
	}
	}
	} else if (version == 2 && contextlen == 0 && !trivialSNMPv2){
	contextlen = MAX_NAME_LEN;
	context_scanInit();
	for(cxp = context_scanNext(); cxp; cxp = context_scanNext()){
	if (!strcasecmp(cxp->contextName, argv[arg])){
	contextlen = cxp->contextIdentityLen;
	#ifdef SVR4
	memmove(context, cxp->contextIdentity,
	contextlen * sizeof(oid));
	#else
	bcopy(cxp->contextIdentity, context,
	contextlen * sizeof(oid));
	#endif
	break;
	}
	}
	if (!cxp){
	if (!read_objid(argv[arg], context, &contextlen)){
	printf("Invalid context: %s\n", argv[arg]);
	contextlen = 0;
	usage();
	exit(1);
	}
	}
	} else {
	names[current_name++] = argv[arg];
	}
	}

	if (!hostname \|\| current_name <= 0 \|\| (version < 1) \|\| (version > 2)
	\|\| (version == 1 && !community)
	\|\| (version == 2 && (!srclen \|\| !dstlen \|\| !contextlen)
	&& !trivialSNMPv2)){
	usage();
	exit(1);
	}

	if (trivialSNMPv2){
	if ((destAddr = inet_addr(hostname)) == -1){
	hp = gethostbyname(hostname);
	if (hp == NULL){
	fprintf(stderr, "unknown host: %s\n", hostname);
	exit(1);
	} else {
	#ifdef SVR4
	memmove((char )&destAddr, (char )hp->h_addr,
	hp->h_length);
	#else
	bcopy((char )hp->h_addr, (char )&destAddr,
	hp->h_length);
	#endif
	}
	}
	srclen = dstlen = contextlen = MAX_NAME_LEN;
	ms_party_init(destAddr, src, &srclen, dst, &dstlen,
	context, &contextlen);
	}

	if (clock_flag){
	pp = party_getEntry(src, srclen);
	if (pp){
	pp->partyAuthClock = srcclock;
	gettimeofday(&pp->tv, (struct timezone *)0);
	pp->tv.tv_sec -= pp->partyAuthClock;
	}
	pp = party_getEntry(dst, dstlen);
	if (pp){
	pp->partyAuthClock = dstclock;
	gettimeofday(&pp->tv, (struct timezone *)0);
	pp->tv.tv_sec -= pp->partyAuthClock;
	}
	}

	#ifdef SVR4
	memset((char *)&session, NULL, sizeof(struct snmp_session));
	#else
	bzero((char *)&session, sizeof(struct snmp_session));
	#endif
	session.peername = hostname;
	if (port_flag)
	session.remote_port = dest_port;

	if (version == 1){
	session.version = SNMP_VERSION_1;
	session.community = (u_char *)community;
	session.community_len = strlen((char *)community);
	} else if (version == 2){
	session.version = SNMP_VERSION_2;
	session.srcParty = src;
	session.srcPartyLen = srclen;
	session.dstParty = dst;
	session.dstPartyLen = dstlen;
	session.context = context;
	session.contextLen = contextlen;
	}
	if (retransmission_flag)
	session.retries = retransmission;
	else
	session.retries = SNMP_DEFAULT_RETRIES;
	if (timeout_flag)
	session.timeout = timeout;
	else
	session.timeout = SNMP_DEFAULT_TIMEOUT;

	session.authenticator = NULL;
	snmp_synch_setup(&session);
	ss = snmp_open(&session);
	if (ss == NULL){
	printf("Couldn't open snmp\n");
	exit(-1);
	}

	pdu = snmp_pdu_create(GETNEXT_REQ_MSG);

	for(count = 0; count < current_name; count++){
	name_length = MAX_NAME_LEN;
	if (!read_objid(names[count], name, &name_length)){
	printf("Invalid object identifier: %s\n", names[count]);
	}

	snmp_add_null_var(pdu, name, name_length);
	}

	retry:
	status = snmp_synch_response(ss, pdu, &response);
	if (status == STAT_SUCCESS){
	if (response->errstat == SNMP_ERR_NOERROR){
	for(vars = response->variables; vars; vars = vars->next_variable)
	print_variable(vars->name, vars->name_length, vars);
	} else {
	printf("Error in packet.\nReason: %s\n", snmp_errstring(response->errstat));
	if (response->errstat == SNMP_ERR_NOSUCHNAME){
	printf("This name doesn't exist: ");
	for(count = 1, vars = response->variables; vars && count != response->errindex;
	vars = vars->next_variable, count++)
	;
	if (vars)
	print_objid(vars->name, vars->name_length);
	printf("\n");
	}
	if ((pdu = snmp_fix_pdu(response, GETNEXT_REQ_MSG)) != NULL)
	goto retry;
	}

	} else if (status == STAT_TIMEOUT){
	printf("No Response from %s\n", hostname);
	} else { /* status == STAT_ERROR */
	printf("An error occurred, Quitting\n");
	}

	if (response)
	snmp_free_pdu(response);
	snmp_close(ss);
	}