Current release: 5.9.4

skip to page content

About
Download
Tutorials
Documentation
Wiki
Support
Development

·	Projects
·	Release Schedule
·	Helping Out
·	Git
·	Release Policy
·	API

Related Info/SW

Archive Search: Users Coders Announce Bugs Patches SVN (named "CVS")

Require all words?

Site Search:

         

---

snmp_agent.c File Reference

#include <config.h>
#include <sys/types.h>
#include <limits.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <sys/time.h>
#include <time.h>
#include <sys/select.h>
#include <netinet/in.h>
#include <errno.h>
#include <dmalloc.h>
#include "mibincl.h"
#include "snmp_client.h"
#include "snmp_alarm.h"
#include "snmpd.h"
#include "mibgroup/struct.h"
#include "mibgroup/util_funcs.h"
#include "mib_module_config.h"
#include "default_store.h"
#include "system.h"
#include "ds_agent.h"
#include "snmp_agent.h"
#include "vacm.h"
#include "snmp_transport.h"
#include "snmpUDPDomain.h"
#include "snmpCallbackDomain.h"
#include "snmpUnixDomain.h"
#include "snmpTCPDomain.h"
#include "agentx/protocol.h"
#include "agentx/master.h"

Go to the source code of this file.

Data Structures
struct	_agent_nsap
struct	addrCache
struct	agent_set_cache_s
struct	saved_var_data
Defines
#define	SNMP_NEED_REQUEST_LIST
#define	SNMP_ADDRCACHE_SIZE   10
Typedefs
typedef _agent_nsap	agent_nsap
typedef agent_set_cache_s	agent_set_cache
Functions
int	snmp_check_packet (struct snmp_session *, struct _snmp_transport *, void *, int)
int	snmp_check_parse (struct snmp_session *, struct snmp_pdu *, int)
void	delete_subtree_cache (struct agent_snmp_session *asp)
int	handle_pdu (struct agent_snmp_session *asp)
int	wrap_up_request (struct agent_snmp_session *asp, int status)
int	check_delayed_request (struct agent_snmp_session *asp)
int	handle_getnext_loop (struct agent_snmp_session *asp)
	repeatedly calls getnext handlers looking for an answer till all requests are satisified. More...
int	handle_set_loop (struct agent_snmp_session *asp)
agent_set_cache *	save_set_cache (struct agent_snmp_session *asp)
void	get_set_cache (struct agent_snmp_session *asp)
int	getNextSessID ()
int	agent_check_and_process (int block)
void	snmp_addrcache_initialise (void)
void	snmp_addrcache_age (void)
int	snmp_check_packet (struct snmp_session *session, snmp_transport *transport, void *transport_data, int transport_data_length)
int	register_agent_nsap (snmp_transport *t)
void	deregister_agent_nsap (int handle)
int	init_master_agent (void)
agent_snmp_session *	init_agent_snmp_session (struct snmp_session *session, struct snmp_pdu *pdu)
void	free_agent_snmp_session (struct agent_snmp_session *asp)
int	check_for_delegated (struct agent_snmp_session *asp)
void	dump_sess_list (void)
void	remove_and_free_agent_snmp_session (struct agent_snmp_session *asp)
void	free_agent_snmp_session_by_session (struct snmp_session *sess, void(*free_request)(struct request_list *))
int	handle_snmp_packet (int op, struct snmp_session *session, int reqid, struct snmp_pdu *pdu, void *magic)
	handles an incoming SNMP packet into the agent. More...
int	add_varbind_to_cache (struct agent_snmp_session *asp, int vbcount, struct variable_list *varbind_ptr, struct subtree *tp)
int	check_acm (struct agent_snmp_session *asp, u_char type)
int	create_subtree_cache (struct agent_snmp_session *asp)
int	reassign_requests (struct agent_snmp_session *asp)
void	delete_request_infos (request_info *reqlist)
int	check_requests_status (struct agent_snmp_session *asp, request_info *requests)
int	check_all_requests_status (struct agent_snmp_session *asp)
int	handle_var_requests (struct agent_snmp_session *asp)
void	check_outstanding_agent_requests (int status)
int	check_transaction_id (int transaction_id)
	Decide if the requested transaction_id is still being processed within the agent. More...
int	check_getnext_results (struct agent_snmp_session *asp)
	returns 1 if there are valid GETNEXT requests left. More...
int	handle_set (struct agent_snmp_session *asp)
int	set_request_error (agent_request_info *reqinfo, request_info *request, int error_value)
int	set_mode_request_error (int mode, request_info *request, int error_value)
int	set_all_requests_error (agent_request_info *reqinfo, request_info *requests, int error_value)
int	marker_uptime (marker_t pm)
int	timeval_uptime (struct timeval *tv)
int	get_agent_uptime (void)
void	agent_add_list_data (agent_request_info *ari, data_list *node)
void *	agent_get_list_data (agent_request_info *ari, const char *name)
void	free_agent_data_set (agent_request_info *ari)
void	free_agent_data_sets (agent_request_info *ari)
void	free_agent_request_info (agent_request_info *ari)
Variables
int	lastAddrAge = 0
int	log_addresses = 0
agent_snmp_session *	agent_delegated_list = NULL
snmp_session *	main_session = NULL
timeval	starttime

---

Define Documentation

#define SNMP_ADDRCACHE_SIZE   10

Definition at line 112 of file snmp_agent.c.

#define SNMP_NEED_REQUEST_LIST

Definition at line 72 of file snmp_agent.c.

---

Typedef Documentation

typedef struct _agent_nsap agent_nsap

typedef struct agent_set_cache_s agent_set_cache

---

Function Documentation

int add_varbind_to_cache (  struct agent_snmp_session *    asp, int    vbcount, struct variable_list *    varbind_ptr, struct subtree *    tp )

Definition at line 1125 of file snmp_agent.c. Referenced by create_subtree_cache(), and reassign_requests(). { request_info *request; int cacheid; tree_cache *tmpc; if (tp == NULL) { /* no appropriate registration found */ /* make up the response ourselves */ switch(asp->pdu->command) { case SNMP_MSG_GETNEXT: case SNMP_MSG_GETBULK: varbind_ptr->type = SNMP_ENDOFMIBVIEW; break; case SNMP_MSG_SET: return SNMP_NOSUCHOBJECT; case SNMP_MSG_GET: varbind_ptr->type = SNMP_NOSUCHOBJECT; break; default: return SNMPERR_GENERR; /* shouldn't get here */ } } else { if (!MODE_IS_SET(asp->pdu->command)) varbind_ptr->type = ASN_NULL; /* malloc the request structure */ request = SNMP_MALLOC_TYPEDEF(request_info); if (request == NULL) return SNMP_ERR_GENERR; request->index = vbcount; /* place them in a cache */ if (tp->cacheid > -1 && tp->cacheid <= asp->treecache_num && asp->treecache[tp->cacheid]->subtree == tp) { /* we have already added a request to this tree pointer before */ cacheid = tp->cacheid; } else { cacheid = ++(asp->treecache_num); /* new slot needed */ if (asp->treecache_num >= asp->treecache_len) { /* exapand cache array */ /* WWW: non-linear expansion needed (with cap) */ asp->treecache_len = (asp->treecache_len + 16); asp->treecache = realloc(asp->treecache, sizeof(tree_cache *) * asp->treecache_len); if (asp->treecache == NULL) return SNMP_ERR_GENERR; } tmpc = (tree_cache *) calloc(1, sizeof(tree_cache)); asp->treecache[cacheid] = tmpc; asp->treecache[cacheid]->subtree = tp; asp->treecache[cacheid]->requests_begin = request; tp->cacheid = cacheid; } /* if this is a search type, get the ending range oid as well */ if (asp->pdu->command == SNMP_MSG_GETNEXT || asp->pdu->command == SNMP_MSG_GETBULK) { request->range_end = tp->end; request->range_end_len = tp->end_len; } /* link into chain */ if (asp->treecache[cacheid]->requests_end) asp->treecache[cacheid]->requests_end->next = request; request->prev = asp->treecache[cacheid]->requests_end; asp->treecache[cacheid]->requests_end = request; /* add the given request to the list of requests they need to handle results for */ request->requestvb = varbind_ptr; } return SNMP_ERR_NOERROR; }

void agent_add_list_data (  agent_request_info *    agent, data_list *    node )  [inline]

Definition at line 1939 of file snmp_agent.c. { if (ari) { if (ari->agent_data) add_list_data(&ari->agent_data, node); else ari->agent_data = node; } }

int agent_check_and_process (  int    block )

Definition at line 256 of file snmp_agent.c. { int numfds; fd_set fdset; struct timeval timeout = { LONG_MAX, 0 }, *tvp = &timeout; int count; int fakeblock=0; numfds = 0; FD_ZERO(&fdset); snmp_select_info(&numfds, &fdset, tvp, &fakeblock); if (block != 0 && fakeblock != 0) { /* There are no alarms registered, and the caller asked for blocking, so let select() block forever. */ tvp = NULL; } else if (block != 0 && fakeblock == 0) { /* The caller asked for blocking, but there is an alarm due sooner than LONG_MAX seconds from now, so use the modified timeout returned by snmp_select_info as the timeout for select(). */ } else if (block == 0) { /* The caller does not want us to block at all. */ tvp->tv_sec = 0; tvp->tv_usec = 0; } count = select(numfds, &fdset, 0, 0, tvp); if (count > 0) { /* packets found, process them */ snmp_read(&fdset); } else switch(count) { case 0: snmp_timeout(); break; case -1: if (errno != EINTR) { snmp_log_perror("select"); } return -1; default: snmp_log(LOG_ERR, "select returned %d\n", count); return -1; } /* endif -- count>0 */ /* Run requested alarms. */ run_alarms(); return count; }

void* agent_get_list_data (  agent_request_info *    agent, const char *    name )  [inline]

Definition at line 1950 of file snmp_agent.c. { if (ari) return get_list_data(ari->agent_data,name); return NULL; }

int check_acm (  struct agent_snmp_session *    asp, u_char    type )

Definition at line 1214 of file snmp_agent.c. Referenced by handle_getnext_loop(), and handle_pdu(). { int view; int i; request_info *request; int ret = 0; struct variable_list *vb; for(i = 0; i <= asp->treecache_num; i++) { for(request = asp->treecache[i]->requests_begin; request; request = request->next) { /* for each request, run it through in_a_view() */ vb = request->requestvb; if (vb->type == ASN_NULL) /* not yet processed */ continue; view = in_a_view(vb->name, &vb->name_length, asp->pdu, vb->type); /* if a ACM error occurs, mark it as type passed in */ if (view != VACM_SUCCESS) { ret++; snmp_set_var_typed_value(vb, type, NULL, 0); } } } return ret; }

int check_all_requests_status (  struct agent_snmp_session *    asp )

Definition at line 1396 of file snmp_agent.c. Referenced by check_delayed_request(). { int i; for(i = 0; i <= asp->treecache_num; i++) { check_requests_status(asp, asp->treecache[i]->requests_begin); } return asp->status; }

int check_delayed_request (  struct agent_snmp_session *    asp )

Definition at line 1501 of file snmp_agent.c. Referenced by check_outstanding_agent_requests(). { int status = SNMP_ERR_NOERROR; check_all_requests_status(asp); /* update the asp->status */ switch(asp->mode) { case SNMP_MSG_GETNEXT: handle_getnext_loop(asp); break; case SNMP_MSG_GETBULK: /* WWW */ break; case MODE_SET_BEGIN: case MODE_SET_RESERVE1: case MODE_SET_RESERVE2: case MODE_SET_ACTION: case MODE_SET_COMMIT: case MODE_SET_FREE: case MODE_SET_UNDO: handle_set_loop(asp); if (asp->mode != FINISHED_SUCCESS && asp->mode != FINISHED_FAILURE) { if (check_for_delegated(asp)) { /* add to delegated request chain */ if (!asp->status) asp->status = status; asp->next = agent_delegated_list; agent_delegated_list = asp; } return SNMP_ERR_NOERROR; } break; default: break; } /* if we don't have anything outstanding (delegated), wrap up */ if (!check_for_delegated(asp)) return wrap_up_request(asp, status); return 1; }

int check_for_delegated (  struct agent_snmp_session *    asp )

Definition at line 858 of file snmp_agent.c. Referenced by check_delayed_request(), check_outstanding_agent_requests(), handle_getnext_loop(), handle_set_loop(), and handle_snmp_packet(). { int i; request_info *request; for(i = 0; i <= asp->treecache_num; i++) { for(request = asp->treecache[i]->requests_begin; request; request = request->next) { if (request->delegated) return 1; } } return 0; }

int check_getnext_results (  struct agent_snmp_session *    asp )

returns 1 if there are valid GETNEXT requests left. Returns 0 if not. Definition at line 1551 of file snmp_agent.c. Referenced by handle_getnext_loop(). { /* get old info */ tree_cache **old_treecache = asp->treecache; int old_treecache_num = asp->treecache_num; int count = 0; int i; request_info *request; for(i = 0; i <= old_treecache_num; i++) { for(request = old_treecache[i]->requests_begin; request; request = request->next) { /* out of range? */ if (snmp_oid_compare(request->requestvb->name, request->requestvb->name_length, request->range_end, request->range_end_len) > 0) { /* ack, it's beyond the accepted end of range. */ /* fix it by setting the oid to the end of range oid instead */ DEBUGMSGTL(("check_getnext_results", "request response %d out of range", request->index)); snmp_set_var_objid(request->requestvb, request->range_end, request->range_end_len); snmp_set_var_typed_value(request->requestvb, ASN_NULL, NULL, 0); } /* mark any existent requests with illegal results as NULL */ if (request->requestvb->type == SNMP_ENDOFMIBVIEW) { /* illegal response from a subagent. Change it back to NULL */ request->requestvb->type = ASN_NULL; } if (request->requestvb->type == ASN_NULL || request->requestvb->type == ASN_PRIV_RETRY) count++; } } return count; }

void check_outstanding_agent_requests (  int    status )

Definition at line 1455 of file snmp_agent.c. { struct agent_snmp_session *asp, *prev_asp = NULL, *next_asp = NULL; for(asp = agent_delegated_list; asp; prev_asp = asp, asp = next_asp) { next_asp = asp->next; /* save in case we clean up asp */ if (!check_for_delegated(asp)) { /* we're done with this one, remove from queue */ if (prev_asp != NULL) prev_asp->next = asp->next; else agent_delegated_list = asp->next; /* continue processing or finish up */ check_delayed_request(asp); } } }

int check_requests_status (  struct agent_snmp_session *    asp, request_info *    requests )

Definition at line 1381 of file snmp_agent.c. Referenced by check_all_requests_status(), and handle_var_requests(). { /* find any errors marked in the requests */ while(requests) { if (requests->status != SNMP_ERR_NOERROR && (asp->index == 0 || requests->index < asp->index)) { asp->index = requests->index; asp->status = requests->status; } requests = requests->next; } return asp->status; }

int check_transaction_id (  int    transaction_id )

Decide if the requested transaction_id is still being processed within the agent. This is used to validate whether a delayed cache (containing possibly freed pointers) is still usable. returns SNMPERR_SUCCESS if it's still valid, or SNMPERR_GENERR if not. Definition at line 1480 of file snmp_agent.c. { struct agent_snmp_session *asp, *prev_asp = NULL; for(asp = agent_delegated_list; asp; prev_asp = asp, asp = asp->next) { if (asp->pdu->transid == transaction_id) return SNMPERR_SUCCESS; } return SNMPERR_GENERR; }

int create_subtree_cache (  struct agent_snmp_session *    asp )

Definition at line 1242 of file snmp_agent.c. Referenced by handle_pdu(). { struct subtree *tp; struct variable_list *varbind_ptr; int ret; int view; int vbcount = 0; if (asp->treecache == NULL && asp->treecache_len == 0) { asp->treecache_len = 16; asp->treecache = malloc(sizeof(tree_cache *) * asp->treecache_len); if (asp->treecache == NULL) return SNMP_ERR_GENERR; } asp->treecache_num = -1; /* collect varbinds into their registered trees */ for(varbind_ptr = asp->start; varbind_ptr; varbind_ptr = varbind_ptr->next_variable) { /* count the varbinds */ ++vbcount; if (varbind_ptr->type != ASN_NULL && /* skip previously answered */ !(MODE_IS_SET(asp->pdu->command))) continue; /* find the owning tree */ tp = find_subtree(varbind_ptr->name, varbind_ptr->name_length, NULL, asp->pdu->contextName); /* WWW: only v3 pdu's have */ /* check access control */ switch(asp->pdu->command) { case SNMP_MSG_GET: view = in_a_view(varbind_ptr->name, &varbind_ptr->name_length, asp->pdu, varbind_ptr->type); if (view != VACM_SUCCESS) snmp_set_var_typed_value(varbind_ptr, SNMP_NOSUCHOBJECT, NULL, 0); break; case SNMP_MSG_SET: view = in_a_view(varbind_ptr->name, &varbind_ptr->name_length, asp->pdu, varbind_ptr->type); if (view != VACM_SUCCESS) return SNMP_ERR_NOTWRITABLE; break; case SNMP_MSG_GETNEXT: default: view = VACM_SUCCESS; /* WWW: check VACM here to see if "tp" is even worthwhile */ } if (view == VACM_SUCCESS) { ret = add_varbind_to_cache(asp, vbcount, varbind_ptr, tp); if (ret != SNMP_ERR_NOERROR) return ret; } } return SNMPERR_SUCCESS; }

void delete_request_infos (  request_info *    reqlist )

Definition at line 1357 of file snmp_agent.c. Referenced by delete_subtree_cache(). { request_info *saveit; while(reqlist) { /* don't delete varbind */ saveit = reqlist; reqlist = reqlist->next; if (saveit->parent_data) free_all_list_data(saveit->parent_data); free(saveit); } }

void delete_subtree_cache (  struct agent_snmp_session *    asp )

Definition at line 1370 of file snmp_agent.c. Referenced by free_agent_snmp_session(). { while(asp->treecache_num >= 0) { /* don't delete subtrees */ delete_request_infos(asp->treecache[asp->treecache_num] ->requests_begin); free(asp->treecache[asp->treecache_num]); asp->treecache_num--; } }

void deregister_agent_nsap (  int    handle )

Definition at line 580 of file snmp_agent.c. { agent_nsap *a = NULL, **prevNext = &agent_nsap_list; int main_session_deregistered = 0; DEBUGMSGTL(("deregister_agent_nsap", "handle %d\n", handle)); for (a = agent_nsap_list; a != NULL && a->handle < handle; a = a->next) { prevNext = &(a->next); } if (a != NULL && a->handle == handle) { *prevNext = a->next; if (main_session == snmp_sess_session(a->s)) { main_session_deregistered = 1; } snmp_close(snmp_sess_session(a->s)); /* The above free()s the transport and session pointers. */ free(a); } /* If we've deregistered the session that main_session used to point to, then make it point to another one, or in the last resort, make it equal to NULL. Basically this shouldn't ever happen in normal operation because main_session starts off pointing at the first session added by init_master_agent(), which then discards the handle. */ if (main_session_deregistered) { if (agent_nsap_list != NULL) { DEBUGMSGTL(("snmp_agent", "WARNING: main_session pointer changed from %p to %p\n", main_session, snmp_sess_session(agent_nsap_list->s))); main_session = snmp_sess_session(agent_nsap_list->s); } else { DEBUGMSGTL(("snmp_agent", "WARNING: main_session pointer changed from %p to NULL\n", main_session)); main_session = NULL; } } }

void dump_sess_list (  void    )

Definition at line 972 of file snmp_agent.c. { struct agent_snmp_session *a; DEBUGMSGTL(("snmp_agent", "DUMP agent_sess_list -> ")); for (a = agent_session_list; a != NULL; a = a->next) { DEBUGMSG(("snmp_agent", "%08p[session %08p] -> ", a, a->session)); } DEBUGMSG(("snmp_agent", "[NIL]\n")); }

void free_agent_data_set (  agent_request_info *    agent )  [inline]

Definition at line 1958 of file snmp_agent.c. { if (ari) free_list_data(ari->agent_data); }

void free_agent_data_sets (  agent_request_info *    agent )  [inline]

Definition at line 1965 of file snmp_agent.c. { if (ari) free_all_list_data(ari->agent_data); }

void free_agent_request_info (  agent_request_info *    ari )  [inline]

Definition at line 1972 of file snmp_agent.c. { if (ari) { if (ari->agent_data) free_all_list_data(ari->agent_data); free(ari); } }

void free_agent_snmp_session (  struct agent_snmp_session *    asp )

Definition at line 840 of file snmp_agent.c. { if (!asp) return; if (asp->orig_pdu) snmp_free_pdu(asp->orig_pdu); if (asp->pdu) snmp_free_pdu(asp->pdu); if (asp->reqinfo) free_agent_request_info(asp->reqinfo); if (asp->treecache) { delete_subtree_cache(asp); free(asp->treecache); } free(asp); }

void free_agent_snmp_session_by_session (  struct snmp_session *    sess, void(*    free_request)(struct request_list *) )

Definition at line 1009 of file snmp_agent.c. { struct agent_snmp_session *a, *next, **prevNext = &agent_session_list; DEBUGMSGTL(("snmp_agent", "REMOVE session == %08p\n", sess)); for (a = agent_session_list; a != NULL; a = next) { if (a->session == sess) { *prevNext = a->next; next = a->next; free_agent_snmp_session(a); } else { prevNext = &(a->next); next = a->next; } } }

int getNextSessID (  void    )

Definition at line 248 of file snmp_agent.c. { static int SessionID = 0; return ++SessionID; }

int get_agent_uptime (  void    )

Definition at line 1928 of file snmp_agent.c. { struct timeval now; gettimeofday(&now, NULL); return timeval_uptime( &now ); }

void get_set_cache (  struct agent_snmp_session *    asp )

Definition at line 219 of file snmp_agent.c. Referenced by handle_pdu(). { agent_set_cache *ptr, *prev=NULL; for ( ptr=Sets ; ptr != NULL ; ptr=ptr->next ) { if ( ptr->sess == asp->session && ptr->transID == asp->pdu->transid ) { if ( prev ) prev->next = ptr->next; else Sets = ptr->next; /* found it. Get the needed data */ asp->treecache = ptr->treecache; asp->treecache_len = ptr->treecache_len; asp->treecache_num = ptr->treecache_num; if (!asp->reqinfo) { asp->reqinfo = SNMP_MALLOC_TYPEDEF(agent_request_info); if (asp->reqinfo) { asp->reqinfo->asp = asp; asp->reqinfo->agent_data = ptr->agent_data; } } free(ptr); return; } prev = ptr; } }

int handle_getnext_loop (  struct agent_snmp_session *    asp )

repeatedly calls getnext handlers looking for an answer till all requests are satisified. It's expected that one pass has been made before entering this function Definition at line 1597 of file snmp_agent.c. Referenced by check_delayed_request(), and handle_pdu(). { int status; struct variable_list *var_ptr; int count; /* loop */ while (1) { /* bail for now if anything is delegated. */ if (check_for_delegated(asp)) { return SNMP_ERR_NOERROR; } /* check vacm against results */ check_acm(asp, ASN_PRIV_RETRY); /* need to keep going we're not done yet. */ if (!check_getnext_results(asp)) /* nothing left, quit now */ break; /* never had a request (empty pdu), quit now */ /* XXXWWW: huh? this would be too late, no? shouldn't we catch this earlier? */ /* if (count == 0) break; */ DEBUGIF("results") { DEBUGMSGTL(("results","getnext results, before next pass: \n")); for(var_ptr = asp->pdu->variables; var_ptr; var_ptr = var_ptr->next_variable) { char buf[SPRINT_MAX_LEN]; sprint_variable(buf, var_ptr->name, var_ptr->name_length, var_ptr); DEBUGMSGTL(("results"," %s\n", buf)); } } reassign_requests(asp); status = handle_var_requests(asp); if (status != SNMP_ERR_NOERROR) { return status; /* should never really happen */ } } return SNMP_ERR_NOERROR; }

int handle_pdu (  struct agent_snmp_session *    asp )

Definition at line 1738 of file snmp_agent.c. Referenced by handle_snmp_packet(). { int status; /* for illegal requests, mark all nodes as ASN_NULL */ switch(asp->pdu->command) { case SNMP_MSG_INTERNAL_SET_RESERVE2: case SNMP_MSG_INTERNAL_SET_ACTION: case SNMP_MSG_INTERNAL_SET_COMMIT: case SNMP_MSG_INTERNAL_SET_FREE: case SNMP_MSG_INTERNAL_SET_UNDO: get_set_cache(asp); break; case SNMP_MSG_GET: case SNMP_MSG_GETNEXT: case SNMP_MSG_GETBULK: snmp_reset_var_types(asp->pdu->variables, ASN_NULL); /* fall through */ case SNMP_MSG_INTERNAL_SET_BEGIN: case SNMP_MSG_INTERNAL_SET_RESERVE1: default: /* collect varbinds */ status = create_subtree_cache(asp); if (status != SNMP_ERR_NOERROR) return status; } asp->mode = asp->pdu->command; switch(asp->mode) { case SNMP_MSG_GET: /* increment the message type counter */ snmp_increment_statistic(STAT_SNMPINGETREQUESTS); /* check vacm ahead of time */ check_acm(asp, SNMP_NOSUCHOBJECT); /* get the results */ status = handle_var_requests(asp); /* deal with unhandled results -> noSuchObject */ if (status == SNMP_ERR_NOERROR) snmp_replace_var_types(asp->pdu->variables, ASN_NULL, SNMP_NOSUCHOBJECT); break; case SNMP_MSG_GETNEXT: /* increment the message type counter */ snmp_increment_statistic(STAT_SNMPINGETNEXTS); /* loop through our mib tree till we find an appropriate response to return to the caller. */ /* first pass */ status = handle_var_requests(asp); if (status != SNMP_ERR_NOERROR) { return status; /* should never really happen */ } handle_getnext_loop(asp); break; case SNMP_MSG_SET: /* check access permissions first */ if (check_acm(asp, SNMP_NOSUCHOBJECT)) return SNMP_ERR_NOTWRITABLE; asp->mode = MODE_SET_BEGIN; status = handle_set_loop(asp); break; case SNMP_MSG_INTERNAL_SET_BEGIN: case SNMP_MSG_INTERNAL_SET_RESERVE1: case SNMP_MSG_INTERNAL_SET_RESERVE2: case SNMP_MSG_INTERNAL_SET_ACTION: case SNMP_MSG_INTERNAL_SET_COMMIT: case SNMP_MSG_INTERNAL_SET_FREE: case SNMP_MSG_INTERNAL_SET_UNDO: asp->pdu->flags |= UCD_MSG_FLAG_ONE_PASS_ONLY; status = handle_set_loop(asp); /* asp related cache is saved in cleanup */ break; case SNMP_MSG_GETBULK: break; /* WWW */ case SNMP_MSG_RESPONSE: snmp_increment_statistic(STAT_SNMPINGETRESPONSES); return SNMP_ERR_NOERROR; case SNMP_MSG_TRAP: case SNMP_MSG_TRAP2: snmp_increment_statistic(STAT_SNMPINTRAPS); return SNMP_ERR_NOERROR; default: /* WWW: are reports counted somewhere ? */ snmp_increment_statistic(STAT_SNMPINASNPARSEERRS); return SNMPERR_GENERR; /* shouldn't get here */ /* WWW */ } return status; }

int handle_set (  struct agent_snmp_session *    asp )

Definition at line 1644 of file snmp_agent.c. Referenced by handle_set_loop(). { int status; /* * SETS require 3-4 passes through the var_op_list. * The first two * passes verify that all types, lengths, and values are valid * and may reserve resources and the third does the set and a * fourth executes any actions. Then the identical GET RESPONSE * packet is returned. * If either of the first two passes returns an error, another * pass is made so that any reserved resources can be freed. * If the third pass returns an error, another pass is * made so that * any changes can be reversed. * If the fourth pass (or any of the error handling passes) * return an error, we'd rather not know about it! */ if (!(asp->pdu->flags & UCD_MSG_FLAG_ONE_PASS_ONLY)) { switch (asp->mode) { case MODE_SET_BEGIN: snmp_increment_statistic(STAT_SNMPINSETREQUESTS); asp->rw = WRITE; /* WWW: still needed? */ asp->mode = MODE_SET_RESERVE1; asp->status = SNMP_ERR_NOERROR; break; case MODE_SET_RESERVE1: if ( asp->status != SNMP_ERR_NOERROR ) asp->mode = MODE_SET_FREE; else asp->mode = MODE_SET_RESERVE2; break; case MODE_SET_RESERVE2: if ( asp->status != SNMP_ERR_NOERROR ) asp->mode = MODE_SET_FREE; else asp->mode = MODE_SET_ACTION; break; case MODE_SET_ACTION: if ( asp->status != SNMP_ERR_NOERROR ) asp->mode = MODE_SET_UNDO; else asp->mode = MODE_SET_COMMIT; break; case MODE_SET_COMMIT: if ( asp->status != SNMP_ERR_NOERROR ) { asp->status = SNMP_ERR_COMMITFAILED; asp->mode = FINISHED_FAILURE; } else asp->mode = FINISHED_SUCCESS; break; case MODE_SET_UNDO: if (asp->status != SNMP_ERR_NOERROR ) asp->status = SNMP_ERR_UNDOFAILED; asp->mode = FINISHED_FAILURE; break; case MODE_SET_FREE: asp->mode = FINISHED_FAILURE; break; } } if (asp->mode != FINISHED_SUCCESS && asp->mode != FINISHED_FAILURE) { DEBUGMSGTL(("agent_set","doing set mode = %d\n",asp->mode)); status = handle_var_requests( asp ); if (status != SNMP_ERR_NOERROR && asp->status == SNMP_ERR_NOERROR) asp->status = status; DEBUGMSGTL(("agent_set","did set mode = %d, status = %d\n", asp->mode, asp->status)); } return asp->status; }

int handle_set_loop (  struct agent_snmp_session *    asp )

Definition at line 1726 of file snmp_agent.c. Referenced by check_delayed_request(), and handle_pdu(). { while(asp->mode != FINISHED_FAILURE && asp->mode != FINISHED_SUCCESS) { handle_set(asp); if (check_for_delegated(asp)) return SNMP_ERR_NOERROR; if (asp->pdu->flags & UCD_MSG_FLAG_ONE_PASS_ONLY) return asp->status; } return asp->status; }

int handle_snmp_packet (  int    op, struct snmp_session *    session, int    reqid, struct snmp_pdu *    pdu, void *    magic )

handles an incoming SNMP packet into the agent. Definition at line 1030 of file snmp_agent.c. { struct agent_snmp_session *asp; int status, access_ret; struct variable_list *var_ptr; /* we only support receiving here */ if (op != SNMP_CALLBACK_OP_RECEIVED_MESSAGE) { return 1; } /* new request */ asp = init_agent_snmp_session( session, pdu ); status = SNMP_ERR_NOERROR; /* initial access check. Is request user/community allowed to do anything at all? If not, abondon all hope here. */ if ((access_ret = check_access(pdu)) != 0) { if (access_ret == VACM_NOSUCHCONTEXT) { /* rfc2573 section 3.2, step 5 says that we increment the counter but don't return a response of any kind */ /* we currently don't support unavailable contexts, as there is no reason to that I currently know of */ snmp_increment_statistic(STAT_SNMPUNKNOWNCONTEXTS); /* drop the request */ remove_and_free_agent_snmp_session( asp ); return 0; } else { /* access control setup is incorrect */ send_easy_trap(SNMP_TRAP_AUTHFAIL, 0); if (asp->pdu->version != SNMP_VERSION_1 && asp->pdu->version != SNMP_VERSION_2c) { asp->pdu->errstat = SNMP_ERR_AUTHORIZATIONERROR; asp->pdu->command = SNMP_MSG_RESPONSE; snmp_increment_statistic(STAT_SNMPOUTPKTS); if (! snmp_send( asp->session, asp->pdu )) snmp_free_pdu(asp->pdu); asp->pdu = NULL; remove_and_free_agent_snmp_session(asp); return 1; } else { /* drop the request */ remove_and_free_agent_snmp_session( asp ); return 0; } } } /* process the request */ status = handle_pdu(asp); /* print the results in approrpiate debugging mode */ DEBUGIF("results") { DEBUGMSGTL(("results","request results (status = %d): \n", status)); for(var_ptr = asp->pdu->variables; var_ptr; var_ptr = var_ptr->next_variable) { char buf[SPRINT_MAX_LEN]; sprint_variable(buf, var_ptr->name, var_ptr->name_length, var_ptr); DEBUGMSGTL(("results"," %s\n", buf)); } } /* check for uncompleted requests */ if (check_for_delegated(asp)) { /* add to delegated request chain */ asp->status = status; asp->next = agent_delegated_list; agent_delegated_list = asp; } else { /* if we don't have anything outstanding (delegated), wrap up */ return wrap_up_request(asp, status); } /* done */ DEBUGMSGTL(("snmp_agent", "end of handle_snmp_packet, asp = %08p\n", asp)); return 1; }

int handle_var_requests (  struct agent_snmp_session *    asp )

Definition at line 1405 of file snmp_agent.c. Referenced by handle_getnext_loop(), handle_pdu(), and handle_set(). { int i, retstatus = SNMP_ERR_NOERROR, status = SNMP_ERR_NOERROR, final_status = SNMP_ERR_NOERROR; handler_registration *reginfo; /* create the agent_request_info data */ if (!asp->reqinfo) { asp->reqinfo = SNMP_MALLOC_TYPEDEF(agent_request_info); if (!asp->reqinfo) return SNMP_ERR_GENERR; } asp->reqinfo->asp = asp; asp->reqinfo->mode = asp->mode; /* now, have the subtrees in the cache go search for their results */ for(i=0; i <= asp->treecache_num; i++) { reginfo = asp->treecache[i]->subtree->reginfo; status = call_handlers(reginfo, asp->reqinfo, asp->treecache[i]->requests_begin); /* find any errors marked in the requests */ retstatus = check_requests_status(asp, asp->treecache[i]->requests_begin); /* always take lowest varbind if possible */ if (retstatus != SNMP_ERR_NOERROR) status = retstatus; /* other things we know less about (no index) */ /* WWW: drop support for this? */ if (final_status == SNMP_ERR_NOERROR && status != SNMP_ERR_NOERROR) { /* we can't break here, since some processing needs to be done for all requests anyway (IE, SET handling for UNDO needs to be called regardless of previous status results. WWW: This should be predictable though and breaking should be possible in some cases (eg GET, GETNEXT, ...) */ final_status = status; } } return final_status; }

struct agent_snmp_session* init_agent_snmp_session (  struct snmp_session *    session, struct snmp_pdu *    pdu )

Definition at line 812 of file snmp_agent.c. { struct agent_snmp_session *asp; asp = (struct agent_snmp_session *) calloc(1, sizeof( struct agent_snmp_session )); if ( asp == NULL ) return NULL; asp->session = session; asp->pdu = snmp_clone_pdu(pdu); asp->orig_pdu = snmp_clone_pdu(pdu); asp->rw = READ; asp->exact = TRUE; asp->next = NULL; asp->mode = RESERVE1; asp->status = SNMP_ERR_NOERROR; asp->index = 0; asp->start = asp->pdu->variables; asp->end = asp->pdu->variables; if ( asp->end != NULL ) while ( asp->end->next_variable != NULL ) asp->end = asp->end->next_variable; return asp; }

int init_master_agent (  void    )

Definition at line 648 of file snmp_agent.c. Referenced by main(). { snmp_transport *transport; char *cptr, *cptr2; char buf[SPRINT_MAX_LEN]; if (ds_get_boolean(DS_APPLICATION_ID, DS_AGENT_ROLE) != MASTER_AGENT) { DEBUGMSGTL(("snmp_agent", "init_master_agent; not master agent\n")); return 0; /* No error if ! MASTER_AGENT */ } #ifdef USING_AGENTX_MASTER_MODULE if ( ds_get_boolean(DS_APPLICATION_ID, DS_AGENT_AGENTX_MASTER) == 1 ) real_init_master(); #endif /* Have specific agent ports been specified? */ cptr = ds_get_string(DS_APPLICATION_ID, DS_AGENT_PORTS); if (cptr) { sprintf(buf, "%s", cptr); } else { /* No, so just specify the default port. */ if (ds_get_int(DS_APPLICATION_ID, DS_AGENT_FLAGS) & SNMP_FLAGS_STREAM_SOCKET) { sprintf(buf, "tcp:%d", SNMP_PORT); } else { sprintf(buf, "udp:%d", SNMP_PORT); } } DEBUGMSGTL(("snmp_agent", "final port spec: %s\n", buf)); cptr = strtok(buf, ","); while (cptr) { /* Specification format: NONE: (a pseudo-transport) UDP:[address:]port (also default if no transport is specified) TCP:[address:]port (if supported) Unix:pathname (if supported) AAL5PVC:itf.vpi.vci (if supported) IPX:[network]:node[/port] (if supported) */ DEBUGMSGTL(("snmp_agent", "installing master agent on port %s\n", cptr)); if (!cptr || !(*cptr)) { snmp_log(LOG_ERR, "improper port specification\n"); return 1; } /* Transport type specifier? */ if ((cptr2 = strchr(cptr, ':')) != NULL) { if (strncasecmp(cptr, "none", 4) == 0) { DEBUGMSGTL(("snmp_agent", "init_master_agent; pseudo-transport \"none\" requested\n")); return 0; } else if (strncasecmp(cptr, "tcp", 3) == 0) { #ifdef SNMP_TRANSPORT_TCP_DOMAIN struct sockaddr_in addr; if (snmp_sockaddr_in(&addr, cptr2+1, 0)) { transport = snmp_tcp_transport(&addr, 1); } else { snmp_log(LOG_ERR, "Badly formatted IP address (should be [a.b.c.d:]p)\n"); return 1; } #else snmp_log(LOG_ERR, "No support for requested TCP domain\n"); return 1; #endif } else if (strncasecmp(cptr, "ipx", 3) == 0) { #ifdef SNMP_TRANSPORT_IPX_DOMAIN struct sockaddr_ipx addr; if (snmp_sockaddr_ipx(&addr, cptr2+1)) { transport = snmp_ipx_transport(&addr, 1); } else { snmp_log(LOG_ERR, "Badly formatted IPX address (should be [net]:node[/port])\n"); return 1; } #else snmp_log(LOG_ERR, "No support for requested IPX domain\n"); #endif } else if (strncasecmp(cptr, "aal5pvc", 7) == 0) { #ifdef SNMP_TRANSPORT_AAL5PVC_DOMAIN struct sockaddr_atmpvc addr; if (sscanf(cptr2+1, "%d.%d.%d", &(addr.sap_addr.itf), &(addr.sap_addr.vpi), &(addr.sap_addr.vci))==3) { addr.sap_family = AF_ATMPVC; transport = snmp_aal5pvc_transport(&addr, 1); } else { snmp_log(LOG_ERR, "Badly formatted AAL5 PVC address (should be itf.vpi.vci)\n"); return 1; } #else snmp_log(LOG_ERR, "No support for requested AAL5 PVC domain\n"); return 1; #endif } else if (strncasecmp(cptr, "unix", 4) == 0) { #ifdef SNMP_TRANSPORT_UNIX_DOMAIN struct sockaddr_un addr; addr.sun_family = AF_UNIX; strncpy(addr.sun_path, cptr2+1, sizeof(addr) - (size_t) (((struct sockaddr_un *)0)->sun_path)); transport = snmp_unix_transport(&addr, 1); #else snmp_log(LOG_ERR, "No support for requested Unix domain\n"); return 1; #endif } else if (strncasecmp(cptr, "udp", 3) == 0) { struct sockaddr_in addr; if (snmp_sockaddr_in(&addr, cptr2+1, 0)) { transport = snmp_udp_transport(&addr, 1); } else { snmp_log(LOG_ERR, "Badly formatted IP address (should be [a.b.c.d:]p)\n"); return 1; } } else { snmp_log(LOG_ERR, "Unknown transport domain \"%s\"\n", cptr); return 1; } } else { /* No transport type specifier; default to UDP. */ struct sockaddr_in addr; if (snmp_sockaddr_in(&addr, cptr, 0)) { transport = snmp_udp_transport(&addr, 1); } else { snmp_log(LOG_ERR, "Badly formatted IP address (should be [a.b.c.d:]p)\n"); return 1; } } if (transport == NULL) { snmp_log(LOG_ERR, "Error opening specified transport \"%s\"\n", cptr); return 1; } if (register_agent_nsap(transport) == 0) { snmp_log(LOG_ERR, "Error registering specified transport \"%s\" as an agent NSAP\n", cptr); return 1; } else { DEBUGMSGTL(("snmp_agent", "init_master_agent; \"%s\" registered as an agent NSAP\n", cptr)); } /* Next transport please... */ cptr = strtok(NULL, ","); } return 0; }

int marker_uptime (  marker_t    pm )

Definition at line 1911 of file snmp_agent.c. { int res; marker_t start = (marker_t)&starttime; res = atime_diff( start, pm ); return res/10; /* atime_diff works in msec, not csec */ }

int reassign_requests (  struct agent_snmp_session *    asp )

Definition at line 1308 of file snmp_agent.c. Referenced by handle_getnext_loop(). { /* assume all the requests have been filled or rejected by the subtrees, so reassign the rejected ones to the next subtree in the chain */ int i, ret; request_info *request, *lastreq = NULL; /* get old info */ tree_cache **old_treecache = asp->treecache; int old_treecache_num = asp->treecache_num; /* malloc new space */ asp->treecache = (tree_cache **) malloc(sizeof(tree_cache *) * asp->treecache_len); asp->treecache_num = -1; for(i = 0; i <= old_treecache_num; i++) { for(request = old_treecache[i]->requests_begin; request; request = request->next) { if (lastreq) free(lastreq); lastreq = request; if (request->requestvb->type == ASN_NULL) { ret = add_varbind_to_cache(asp, request->index, request->requestvb, old_treecache[i]->subtree->next); if (ret != SNMP_ERR_NOERROR) return ret; /* WWW: mem leak */ } else if (request->requestvb->type == ASN_PRIV_RETRY) { /* re-add the same subtree */ request->requestvb->type = ASN_NULL; ret = add_varbind_to_cache(asp, request->index, request->requestvb, old_treecache[i]->subtree); if (ret != SNMP_ERR_NOERROR) return ret; /* WWW: mem leak */ } } } if (lastreq) free(lastreq); free(old_treecache); return SNMP_ERR_NOERROR; }

int register_agent_nsap (  snmp_transport *    t )

Definition at line 508 of file snmp_agent.c. { struct snmp_session *s, *sp = NULL; agent_nsap *a = NULL, *n = NULL, **prevNext = &agent_nsap_list; int handle = 0; void *isp = NULL; if (t == NULL) { return -1; } DEBUGMSGTL(("register_agent_nsap", "fd %d\n", t->sock)); n = (agent_nsap *)malloc(sizeof(agent_nsap)); if (n == NULL) { return -1; } s = (struct snmp_session *)malloc(sizeof(struct snmp_session)); if (s == NULL) { free(n); return -1; } memset(s, 0, sizeof(struct snmp_session)); snmp_sess_init(s); /* Set up the session appropriately for an agent. */ s->version = SNMP_DEFAULT_VERSION; s->callback = handle_snmp_packet; s->authenticator = NULL; s->flags = ds_get_int(DS_APPLICATION_ID, DS_AGENT_FLAGS); s->isAuthoritative = SNMP_SESS_AUTHORITATIVE; sp = snmp_add(s, t, snmp_check_packet, snmp_check_parse); if (sp == NULL) { free(s); free(n); return -1; } isp = snmp_sess_pointer(sp); if (isp == NULL) { /* over-cautious */ free(s); free(n); return -1; } n->s = isp; n->t = t; if (main_session == NULL) { main_session = snmp_sess_session(isp); } for (a = agent_nsap_list; a != NULL && handle+1 >= a->handle; a = a->next) { handle = a->handle; prevNext = &(a->next); } if (handle < INT_MAX) { n->handle = handle + 1; n->next = a; *prevNext = n; free(s); return n->handle; } else { free(s); free(n); return -1; } }

void remove_and_free_agent_snmp_session (  struct agent_snmp_session *    asp )

Definition at line 984 of file snmp_agent.c. { struct agent_snmp_session *a, **prevNext = &agent_session_list; DEBUGMSGTL(("snmp_agent", "REMOVE %08p\n", asp)); for (a = agent_session_list; a != NULL; a = *prevNext) { if (a == asp) { *prevNext = a->next; a->next = NULL; free_agent_snmp_session(a); asp = NULL; break; } else { prevNext = &(a->next); } } if (a == NULL && asp != NULL) { /* We coulnd't find it on the list, so free it anyway. */ free_agent_snmp_session(asp); } }

agent_set_cache* save_set_cache (  struct agent_snmp_session *    asp )

Definition at line 192 of file snmp_agent.c. Referenced by wrap_up_request(). { agent_set_cache *ptr; ptr = SNMP_MALLOC_TYPEDEF(agent_set_cache); if (ptr == NULL ) return NULL; /* Save the important information */ ptr->transID = asp->pdu->transid; ptr->sess = asp->session; ptr->treecache = asp->treecache; ptr->treecache_len = asp->treecache_len; ptr->treecache_num = asp->treecache_num; ptr->agent_data = asp->reqinfo->agent_data; /* make the agent forget about what we've saved */ asp->treecache = NULL; asp->reqinfo->agent_data = NULL; ptr->next = Sets; Sets = ptr; return ptr; }

int set_all_requests_error (  agent_request_info *    reqinfo, request_info *    requests, int    error_value )

Definition at line 1898 of file snmp_agent.c. { while(requests) { set_request_error(reqinfo, requests, error_value); requests = requests->next; } return error_value; }

int set_mode_request_error (  int    mode, request_info *    request, int    error_value )

Definition at line 1853 of file snmp_agent.c. { if (!request) return error_value; request->processed = 1; switch(error_value) { case SNMP_NOSUCHOBJECT: case SNMP_NOSUCHINSTANCE: case SNMP_ENDOFMIBVIEW: /* these are exceptions that should be put in the varbind in the case of a GET but should be translated for a SET into a real error status code and put in the request */ switch (mode) { case MODE_GET: request->requestvb->type = error_value; return error_value; case MODE_GETNEXT: case MODE_GETBULK: /* ignore these. They're illegal to set by the client APIs for these modes */ return error_value; default: request->status = SNMP_ERR_NOSUCHNAME; /* WWW: correct? */ return error_value; } break; /* never get here */ default: if (request->status < 0) { /* illegal local error code. translate to generr */ /* WWW: full translation map? */ request->status = SNMP_ERR_GENERR; } else { /* WWW: translations and mode checking? */ request->status = error_value; } return error_value; } return error_value; }

int set_request_error (  agent_request_info *    reqinfo, request_info *    request, int    error_value )

Definition at line 1845 of file snmp_agent.c. { if (!request || !reqinfo) return error_value; return set_mode_request_error(reqinfo->mode, request, error_value); }

void snmp_addrcache_age (  void    )

Definition at line 325 of file snmp_agent.c. Referenced by main(). { int i = 0; lastAddrAge = 0; for (i = 0; i < SNMP_ADDRCACHE_SIZE; i++) { if (addrCache[i].status == SNMP_ADDRCACHE_OLD) { addrCache[i].status = SNMP_ADDRCACHE_UNUSED; if (addrCache[i].addr != NULL) { free(addrCache[i].addr); addrCache[i].addr = NULL; } } if (addrCache[i].status == SNMP_ADDRCACHE_USED) { addrCache[i].status = SNMP_ADDRCACHE_OLD; } } }

void snmp_addrcache_initialise (  void    )

Definition at line 311 of file snmp_agent.c. Referenced by main(). { int i = 0; for (i = 0; i < SNMP_ADDRCACHE_SIZE; i++) { addrCache[i].addr = NULL; addrCache[i].status = SNMP_ADDRCACHE_UNUSED; } }

int snmp_check_packet (  struct snmp_session *    session, snmp_transport *    transport, void *    transport_data, int    transport_data_length )

Definition at line 361 of file snmp_agent.c. { char *addr_string = NULL; int i = 0; /* * Log the message and/or dump the message. * Optionally cache the network address of the sender. */ if (transport != NULL && transport->f_fmtaddr != NULL) { /* Okay I do know how to format this address for logging. */ addr_string = transport->f_fmtaddr(transport, transport_data, transport_data_length); /* Don't forget to free() it. */ } else { /* Don't know how to format the address for logging. */ addr_string = strdup("<UNKNOWN>"); } #ifdef USE_LIBWRAP if (hosts_ctl("snmpd", addr_string, addr_string, STRING_UNKNOWN)) { snmp_log(allow_severity, "Connection from %s\n", addr_string); } else { snmp_log(deny_severity, "Connection from %s REFUSED\n", addr_string); if (addr_string != NULL) { free(addr_string); } return 0; } #endif/*USE_LIBWRAP*/ snmp_increment_statistic(STAT_SNMPINPKTS); if (log_addresses || ds_get_boolean(DS_APPLICATION_ID, DS_AGENT_VERBOSE)) { for (i = 0; i < SNMP_ADDRCACHE_SIZE; i++) { if ((addrCache[i].status != SNMP_ADDRCACHE_UNUSED) && (strcmp(addrCache[i].addr, addr_string) == 0)) { break; } } if (i >= SNMP_ADDRCACHE_SIZE || ds_get_boolean(DS_APPLICATION_ID, DS_AGENT_VERBOSE)){ /* Address wasn't in the cache, so log the packet... */ snmp_log(LOG_INFO, "Received SNMP packet(s) from %s\n", addr_string); /* ...and try to cache the address. */ for (i = 0; i < SNMP_ADDRCACHE_SIZE; i++) { if (addrCache[i].status == SNMP_ADDRCACHE_UNUSED) { if (addrCache[i].addr != NULL) { free(addrCache[i].addr); } addrCache[i].addr = addr_string; addrCache[i].status = SNMP_ADDRCACHE_USED; addr_string = NULL; /* Don't free this 'temporary' string since it's now part of the cache */ break; } } if (i >= SNMP_ADDRCACHE_SIZE) { /* We didn't find a free slot to cache the address. Perhaps we should be using an LRU replacement policy here or something. Oh well. */ DEBUGMSGTL(("snmp_check_packet", "cache overrun")); } } else { addrCache[i].status = SNMP_ADDRCACHE_USED; } } if (addr_string != NULL) { free(addr_string); addr_string = NULL; } return 1; }

int snmp_check_packet (  struct snmp_session *   , struct _snmp_transport *   , void *   , int    )

int snmp_check_parse (  struct snmp_session *    session, struct snmp_pdu *    pdu, int    result )

Definition at line 441 of file snmp_agent.c. { if (result == 0) { if (ds_get_boolean(DS_APPLICATION_ID, DS_AGENT_VERBOSE) && snmp_get_do_logging()) { struct variable_list *var_ptr; switch (pdu->command) { case SNMP_MSG_GET: snmp_log(LOG_DEBUG, " GET message\n"); break; case SNMP_MSG_GETNEXT: snmp_log(LOG_DEBUG, " GETNEXT message\n"); break; case SNMP_MSG_RESPONSE: snmp_log(LOG_DEBUG, " RESPONSE message\n"); break; case SNMP_MSG_SET: snmp_log(LOG_DEBUG, " SET message\n"); break; case SNMP_MSG_TRAP: snmp_log(LOG_DEBUG, " TRAP message\n"); break; case SNMP_MSG_GETBULK: snmp_log(LOG_DEBUG, " GETBULK message, non-rep=%d, max_rep=%d\n", pdu->errstat, pdu->errindex); break; case SNMP_MSG_INFORM: snmp_log(LOG_DEBUG, " INFORM message\n"); break; case SNMP_MSG_TRAP2: snmp_log(LOG_DEBUG, " TRAP2 message\n"); break; case SNMP_MSG_REPORT: snmp_log(LOG_DEBUG, " REPORT message\n"); break; } for (var_ptr = pdu->variables; var_ptr != NULL; var_ptr=var_ptr->next_variable) { size_t c_oidlen = 256, c_outlen = 0; u_char *c_oid = (u_char *)malloc(c_oidlen); if (c_oid) { if (!sprint_realloc_objid(&c_oid, &c_oidlen, &c_outlen, 1, var_ptr->name, var_ptr->name_length)) { snmp_log(LOG_DEBUG, " -- %s [TRUNCATED]\n", c_oid); } else { snmp_log(LOG_DEBUG, " -- %s\n", c_oid); } free(c_oid); } } } return 1; } return 0; /* XXX: does it matter what the return value is? Yes: if we return 0, then the PDU is dumped. */ }

int timeval_uptime (  struct timeval *    tv )

Definition at line 1921 of file snmp_agent.c. { return marker_uptime((marker_t)tv); }

int wrap_up_request (  struct agent_snmp_session *    asp, int    status )

Definition at line 874 of file snmp_agent.c. Referenced by check_delayed_request(), and handle_snmp_packet(). { struct variable_list *var_ptr; int i; /* some stuff needs to be saved in special subagent cases */ switch(asp->pdu->command) { case SNMP_MSG_INTERNAL_SET_BEGIN: case SNMP_MSG_INTERNAL_SET_RESERVE1: case SNMP_MSG_INTERNAL_SET_RESERVE2: case SNMP_MSG_INTERNAL_SET_ACTION: case SNMP_MSG_INTERNAL_SET_COMMIT: case SNMP_MSG_INTERNAL_SET_FREE: case SNMP_MSG_INTERNAL_SET_UNDO: save_set_cache(asp); break; } /* * May need to "dumb down" a SET error status for a * v1 query. See RFC2576 - section 4.3 */ if (( asp->pdu ) && ( asp->pdu->command == SNMP_MSG_SET ) && ( asp->pdu->version == SNMP_VERSION_1 )) { switch ( status ) { case SNMP_ERR_WRONGVALUE: case SNMP_ERR_WRONGENCODING: case SNMP_ERR_WRONGTYPE: case SNMP_ERR_WRONGLENGTH: case SNMP_ERR_INCONSISTENTVALUE: status = SNMP_ERR_BADVALUE; break; case SNMP_ERR_NOACCESS: case SNMP_ERR_NOTWRITABLE: case SNMP_ERR_NOCREATION: case SNMP_ERR_INCONSISTENTNAME: case SNMP_ERR_AUTHORIZATIONERROR: status = SNMP_ERR_NOSUCHNAME; break; case SNMP_ERR_RESOURCEUNAVAILABLE: case SNMP_ERR_COMMITFAILED: case SNMP_ERR_UNDOFAILED: status = SNMP_ERR_GENERR; break; } } /* * Similarly we may need to "dumb down" v2 exception * types to throw an error for a v1 query. * See RFC2576 - section 4.1.2.3 */ if (( asp->pdu ) && ( asp->pdu->command != SNMP_MSG_SET ) && ( asp->pdu->version == SNMP_VERSION_1 )) { for ( var_ptr = asp->pdu->variables, i=1 ; var_ptr != NULL ; var_ptr = var_ptr->next_variable, i++ ) { switch ( var_ptr->type ) { case SNMP_NOSUCHOBJECT: case SNMP_NOSUCHINSTANCE: case SNMP_ENDOFMIBVIEW: case ASN_COUNTER64: status = SNMP_ERR_NOSUCHNAME; asp->index=i; break; } } } if (( status == SNMP_ERR_NOERROR ) && ( asp->pdu )) { snmp_increment_statistic_by( (asp->pdu->command == SNMP_MSG_SET ? STAT_SNMPINTOTALSETVARS : STAT_SNMPINTOTALREQVARS ), count_varbinds( asp->pdu->variables )); } else { /* * Use a copy of the original request * to report failures. */ snmp_free_pdu( asp->pdu ); asp->pdu = asp->orig_pdu; asp->orig_pdu = NULL; } if ( asp->pdu ) { asp->pdu->command = SNMP_MSG_RESPONSE; asp->pdu->errstat = asp->status; asp->pdu->errindex = asp->index; if (! snmp_send( asp->session, asp->pdu )) snmp_free_pdu(asp->pdu); snmp_increment_statistic(STAT_SNMPOUTPKTS); snmp_increment_statistic(STAT_SNMPOUTGETRESPONSES); asp->pdu = NULL; remove_and_free_agent_snmp_session(asp); } return 1; }

---

Variable Documentation

struct agent_snmp_session* agent_delegated_list = NULL

Definition at line 136 of file snmp_agent.c.

int lastAddrAge = 0

Definition at line 122 of file snmp_agent.c.

int log_addresses = 0

Definition at line 123 of file snmp_agent.c.

struct snmp_session* main_session = NULL

Definition at line 500 of file snmp_agent.c.

struct timeval starttime

Definition at line 1907 of file snmp_agent.c.

---

[an error occurred while processing this directive] [an error occurred while processing this directive]

---

Last modified: Wednesday, 01-Aug-2018 04:41:28 UTC
For questions regarding web content and site functionality, please write to the net-snmp-users mail list.