| /* |
| * DisMan Event MIB: |
| * Implementation of the event table configure handling |
| */ |
| |
| #include <net-snmp/net-snmp-config.h> |
| #include <net-snmp/net-snmp-includes.h> |
| #include <net-snmp/agent/net-snmp-agent-includes.h> |
| #include <net-snmp/agent/agent_callbacks.h> |
| #include "disman/event/mteObjects.h" |
| #include "disman/event/mteEvent.h" |
| #include "disman/event/mteEventConf.h" |
| |
| |
| /** Initializes the mteEventsConf module */ |
| void |
| init_mteEventConf(void) |
| { |
| init_event_table_data(); |
| |
| /* |
| * Register config handlers for user-level (fixed) events.... |
| */ |
| snmpd_register_config_handler("notificationEvent", |
| parse_notificationEvent, NULL, |
| "eventname notifyOID [-m] [-i OID|-o OID]*"); |
| snmpd_register_config_handler("setEvent", |
| parse_setEvent, NULL, |
| "eventname [-I] OID = value"); |
| |
| netsnmp_ds_register_config(ASN_BOOLEAN, |
| netsnmp_ds_get_string(NETSNMP_DS_LIBRARY_ID, |
| NETSNMP_DS_LIB_APPTYPE), |
| "strictDisman", NETSNMP_DS_APPLICATION_ID, |
| NETSNMP_DS_AGENT_STRICT_DISMAN); |
| |
| /* |
| * ... and for persistent storage of dynamic event table entries. |
| * |
| * (The previous implementation didn't store these entries, |
| * so we don't need to worry about backwards compatability) |
| */ |
| snmpd_register_config_handler("_mteETable", |
| parse_mteETable, NULL, NULL); |
| snmpd_register_config_handler("_mteENotTable", |
| parse_mteENotTable, NULL, NULL); |
| snmpd_register_config_handler("_mteESetTable", |
| parse_mteESetTable, NULL, NULL); |
| |
| /* |
| * Register to save (non-fixed) entries when the agent shuts down |
| */ |
| snmp_register_callback(SNMP_CALLBACK_LIBRARY, SNMP_CALLBACK_STORE_DATA, |
| store_mteETable, NULL); |
| snmp_register_callback(SNMP_CALLBACK_APPLICATION, |
| SNMPD_CALLBACK_PRE_UPDATE_CONFIG, |
| clear_mteETable, NULL); |
| } |
| |
| |
| /* ============================== |
| * |
| * utility routines |
| * |
| * ============================== */ |
| |
| /* |
| * Find or create the specified event entry |
| */ |
| static struct mteEvent * |
| _find_mteEvent_entry( const char *owner, const char *ename ) |
| { |
| netsnmp_variable_list owner_var, ename_var; |
| netsnmp_tdata_row *row; |
| /* |
| * If there's already an existing entry, |
| * then use that... |
| */ |
| memset(&owner_var, 0, sizeof(netsnmp_variable_list)); |
| memset(&ename_var, 0, sizeof(netsnmp_variable_list)); |
| snmp_set_var_typed_value(&owner_var, ASN_OCTET_STR, owner, strlen(owner)); |
| snmp_set_var_typed_value(&ename_var, ASN_PRIV_IMPLIED_OCTET_STR, |
| ename, strlen(ename)); |
| owner_var.next_variable = &ename_var; |
| row = netsnmp_tdata_row_get_byidx( event_table_data, &owner_var ); |
| /* |
| * ... otherwise, create a new one |
| */ |
| if (!row) |
| row = mteEvent_createEntry( owner, ename, 0 ); |
| if (!row) |
| return NULL; |
| |
| /* return (struct mteEvent *)netsnmp_tdata_row_entry( row ); */ |
| return (struct mteEvent *)row->data; |
| } |
| |
| static struct mteEvent * |
| _find_typed_mteEvent_entry( const char *owner, const char *ename, int type ) |
| { |
| struct mteEvent *entry = _find_mteEvent_entry( owner, ename ); |
| if (!entry) |
| return NULL; |
| |
| /* |
| * If this is an existing (i.e. valid) entry of the |
| * same type, then throw an error and discard it. |
| * But allow combined Set/Notification events. |
| */ |
| if ( entry && |
| (entry->flags & MTE_EVENT_FLAG_VALID) && |
| (entry->mteEventActions & type )) { |
| config_perror("error: duplicate event name"); |
| return NULL; |
| } |
| return entry; |
| } |
| |
| |
| /* ============================== |
| * |
| * User-configured (static) events |
| * |
| * ============================== */ |
| |
| void |
| parse_notificationEvent( const char *token, char *line ) |
| { |
| char ename[MTE_STR1_LEN+1]; |
| char buf[SPRINT_MAX_LEN]; |
| oid name_buf[MAX_OID_LEN]; |
| size_t name_buf_len; |
| struct mteEvent *entry; |
| struct mteObject *object; |
| int wild = 1; |
| int idx = 0; |
| char *cp; |
| #ifndef NETSNMP_DISABLE_MIB_LOADING |
| struct tree *tp; |
| #endif |
| struct varbind_list *var; |
| |
| DEBUGMSGTL(("disman:event:conf", "Parsing notificationEvent config\n")); |
| |
| /* |
| * The event name could be used directly to index the mteObjectsTable. |
| * But it's quite possible that the same name could also be used to |
| * set up a mteTriggerTable entry (with trigger-specific objects). |
| * |
| * To avoid such a clash, we'll add a prefix ("_E"). |
| */ |
| memset(ename, 0, sizeof(ename)); |
| ename[0] = '_'; |
| ename[1] = 'E'; |
| cp = copy_nword(line, ename+2, MTE_STR1_LEN-2); |
| if (!cp || ename[2] == '\0') { |
| config_perror("syntax error: no event name"); |
| return; |
| } |
| |
| /* |
| * Parse the notification OID field ... |
| */ |
| cp = copy_nword(cp, buf, SPRINT_MAX_LEN); |
| if ( buf[0] == '\0' ) { |
| config_perror("syntax error: no notification OID"); |
| return; |
| } |
| name_buf_len = MAX_OID_LEN; |
| if (!snmp_parse_oid(buf, name_buf, &name_buf_len)) { |
| snmp_log(LOG_ERR, "notificationEvent OID: %s\n", buf); |
| config_perror("unknown notification OID"); |
| return; |
| } |
| |
| /* |
| * ... and the relevant object/instances. |
| */ |
| if ( cp && *cp=='-' && *(cp+1)=='m' ) { |
| #ifdef NETSNMP_DISABLE_MIB_LOADING |
| config_perror("Can't use -m if MIB loading is disabled"); |
| return; |
| #else |
| /* |
| * Use the MIB definition to add the standard |
| * notification payload to the mteObjectsTable. |
| */ |
| cp = skip_token( cp ); |
| tp = get_tree( name_buf, name_buf_len, get_tree_head()); |
| if (!tp) { |
| config_perror("Can't locate notification payload info"); |
| return; |
| } |
| for (var = tp->varbinds; var; var=var->next) { |
| idx++; |
| object = mteObjects_addOID( "snmpd.conf", ename, idx, |
| var->vblabel, wild ); |
| idx = object->mteOIndex; |
| } |
| #endif |
| } |
| while (cp) { |
| if ( *cp == '-' ) { |
| switch (*(cp+1)) { |
| case 'm': |
| config_perror("-m option must come first"); |
| return; |
| case 'i': /* exact instance */ |
| case 'w': /* "not-wild" (backward compatability) */ |
| wild = 0; |
| break; |
| case 'o': /* wildcarded object */ |
| wild = 1; |
| break; |
| default: |
| config_perror("unrecognised option"); |
| return; |
| } |
| cp = skip_token( cp ); |
| if (!cp) { |
| config_perror("missing parameter"); |
| return; |
| } |
| } |
| idx++; |
| cp = copy_nword(cp, buf, SPRINT_MAX_LEN); |
| object = mteObjects_addOID( "snmpd.conf", ename, idx, buf, wild ); |
| idx = object->mteOIndex; |
| wild = 1; /* default to wildcarded objects */ |
| } |
| |
| /* |
| * If the entry has parsed successfully, then create, |
| * populate and activate the new event entry. |
| */ |
| entry = _find_typed_mteEvent_entry("snmpd.conf", ename+2, |
| MTE_EVENT_NOTIFICATION); |
| if (!entry) { |
| mteObjects_removeEntries( "snmpd.conf", ename ); |
| return; |
| } |
| entry->mteNotification_len = name_buf_len; |
| memcpy( entry->mteNotification, name_buf, name_buf_len*sizeof(oid)); |
| memcpy( entry->mteNotifyOwner, "snmpd.conf", 10 ); |
| memcpy( entry->mteNotifyObjects, ename, MTE_STR1_LEN ); |
| entry->mteEventActions |= MTE_EVENT_NOTIFICATION; |
| entry->flags |= MTE_EVENT_FLAG_ENABLED | |
| MTE_EVENT_FLAG_ACTIVE | |
| MTE_EVENT_FLAG_FIXED | |
| MTE_EVENT_FLAG_VALID; |
| return; |
| } |
| |
| void |
| parse_setEvent( const char *token, char *line ) |
| { |
| char ename[MTE_STR1_LEN+1]; |
| char buf[SPRINT_MAX_LEN]; |
| oid name_buf[MAX_OID_LEN]; |
| size_t name_buf_len; |
| long value; |
| int wild = 1; |
| struct mteEvent *entry; |
| char *cp; |
| |
| DEBUGMSGTL(("disman:event:conf", "Parsing setEvent config... ")); |
| |
| memset( ename, 0, sizeof(ename)); |
| cp = copy_nword(line, ename, MTE_STR1_LEN); |
| if (!cp || ename[0] == '\0') { |
| config_perror("syntax error: no event name"); |
| return; |
| } |
| |
| if (cp && *cp=='-' && *(cp+1)=='I') { |
| wild = 0; /* an instance assignment */ |
| cp = skip_token( cp ); |
| } |
| |
| /* |
| * Parse the SET assignment in the form "OID = value" |
| */ |
| cp = copy_nword(cp, buf, SPRINT_MAX_LEN); |
| if ( buf[0] == '\0' ) { |
| config_perror("syntax error: no set OID"); |
| return; |
| } |
| name_buf_len = MAX_OID_LEN; |
| if (!snmp_parse_oid(buf, name_buf, &name_buf_len)) { |
| snmp_log(LOG_ERR, "setEvent OID: %s\n", buf); |
| config_perror("unknown set OID"); |
| return; |
| } |
| if (cp && *cp == '=') { |
| cp = skip_token( cp ); /* skip the '=' assignment character */ |
| } |
| if (!cp) { |
| config_perror("syntax error: missing set value"); |
| return; |
| } |
| |
| value = strtol( cp, NULL, 0); |
| |
| /* |
| * If the entry has parsed successfully, then create, |
| * populate and activate the new event entry. |
| */ |
| entry = _find_typed_mteEvent_entry("snmpd.conf", ename, MTE_EVENT_SET); |
| if (!entry) { |
| return; |
| } |
| memcpy( entry->mteSetOID, name_buf, name_buf_len*sizeof(oid)); |
| entry->mteSetOID_len = name_buf_len; |
| entry->mteSetValue = value; |
| if (wild) |
| entry->flags |= MTE_SET_FLAG_OBJWILD; |
| entry->mteEventActions |= MTE_EVENT_SET; |
| entry->flags |= MTE_EVENT_FLAG_ENABLED | |
| MTE_EVENT_FLAG_ACTIVE | |
| MTE_EVENT_FLAG_FIXED | |
| MTE_EVENT_FLAG_VALID; |
| return; |
| } |
| |
| |
| /* ============================== |
| * |
| * Persistent (dynamic) configuration |
| * |
| * ============================== */ |
| |
| void |
| parse_mteETable(const char *token, char *line ) |
| { |
| char owner[MTE_STR1_LEN+1]; |
| char ename[MTE_STR1_LEN+1]; |
| void *vp; |
| size_t tmp; |
| size_t len; |
| struct mteEvent *entry; |
| |
| DEBUGMSGTL(("disman:event:conf", "Parsing mteEventTable config... ")); |
| |
| /* |
| * Read in the index information for this entry |
| * and create a (non-fixed) data structure for it. |
| */ |
| memset( owner, 0, sizeof(owner)); |
| memset( ename, 0, sizeof(ename)); |
| len = MTE_STR1_LEN; vp = owner; |
| line = read_config_read_data(ASN_OCTET_STR, line, &vp, &len); |
| len = MTE_STR1_LEN; vp = ename; |
| line = read_config_read_data(ASN_OCTET_STR, line, &vp, &len); |
| entry = _find_mteEvent_entry( owner, ename ); |
| |
| DEBUGMSG(("disman:event:conf", "(%s, %s) ", owner, ename)); |
| |
| /* |
| * Read in the accessible (event-independent) column values. |
| */ |
| len = MTE_STR2_LEN; vp = entry->mteEventComment; |
| line = read_config_read_data(ASN_OCTET_STR, line, &vp, &len); |
| /* |
| * Skip the mteEventAction field, and note that the |
| * boolean values are combined into a single field. |
| */ |
| line = read_config_read_data(ASN_UNSIGNED, line, &tmp, NULL); |
| entry->flags |= (tmp & |
| (MTE_EVENT_FLAG_ENABLED|MTE_EVENT_FLAG_ACTIVE)); |
| /* |
| * XXX - Will need to read in the 'iquery' access information |
| */ |
| entry->flags |= MTE_EVENT_FLAG_VALID; |
| |
| DEBUGMSG(("disman:event:conf", "\n")); |
| } |
| |
| |
| void |
| parse_mteENotTable(const char *token, char *line) |
| { |
| char owner[MTE_STR1_LEN+1]; |
| char ename[MTE_STR1_LEN+1]; |
| void *vp; |
| size_t len; |
| struct mteEvent *entry; |
| |
| DEBUGMSGTL(("disman:event:conf", "Parsing mteENotifyTable config... ")); |
| |
| /* |
| * Read in the index information for this entry |
| * and create a (non-fixed) data structure for it. |
| */ |
| memset( owner, 0, sizeof(owner)); |
| memset( ename, 0, sizeof(ename)); |
| len = MTE_STR1_LEN; vp = owner; |
| line = read_config_read_data(ASN_OCTET_STR, line, &vp, &len); |
| len = MTE_STR1_LEN; vp = ename; |
| line = read_config_read_data(ASN_OCTET_STR, line, &vp, &len); |
| entry = _find_mteEvent_entry( owner, ename ); |
| |
| DEBUGMSG(("disman:event:conf", "(%s, %s) ", owner, ename)); |
| |
| /* |
| * Read in the accessible column values. |
| */ |
| vp = entry->mteNotification; |
| line = read_config_read_data(ASN_OBJECT_ID, line, &vp, |
| &entry->mteNotification_len); |
| len = MTE_STR1_LEN; vp = entry->mteNotifyOwner; |
| line = read_config_read_data(ASN_OCTET_STR, line, &vp, &len); |
| len = MTE_STR1_LEN; vp = entry->mteNotifyObjects; |
| line = read_config_read_data(ASN_OCTET_STR, line, &vp, &len); |
| |
| entry->mteEventActions |= MTE_EVENT_NOTIFICATION; |
| entry->flags |= MTE_EVENT_FLAG_VALID; |
| |
| DEBUGMSG(("disman:event:conf", "\n")); |
| } |
| |
| |
| void |
| parse_mteESetTable(const char *token, char *line) |
| { |
| char owner[MTE_STR1_LEN+1]; |
| char ename[MTE_STR1_LEN+1]; |
| void *vp; |
| size_t len; |
| struct mteEvent *entry; |
| |
| DEBUGMSGTL(("disman:event:conf", "Parsing mteESetTable config... ")); |
| |
| /* |
| * Read in the index information for this entry |
| * and create a (non-fixed) data structure for it. |
| */ |
| memset( owner, 0, sizeof(owner)); |
| memset( ename, 0, sizeof(ename)); |
| len = MTE_STR1_LEN; vp = owner; |
| line = read_config_read_data(ASN_OCTET_STR, line, &vp, &len); |
| len = MTE_STR1_LEN; vp = ename; |
| line = read_config_read_data(ASN_OCTET_STR, line, &vp, &len); |
| entry = _find_mteEvent_entry( owner, ename ); |
| |
| DEBUGMSG(("disman:event:conf", "(%s, %s) ", owner, ename)); |
| |
| /* |
| * Read in the accessible column values. |
| */ |
| vp = entry->mteSetOID; |
| line = read_config_read_data(ASN_OBJECT_ID, line, &vp, |
| &entry->mteSetOID_len); |
| line = read_config_read_data(ASN_UNSIGNED, line, |
| &entry->mteSetValue, &len); |
| len = MTE_STR2_LEN; vp = entry->mteSetTarget; |
| line = read_config_read_data(ASN_OCTET_STR, line, &vp, &len); |
| len = MTE_STR2_LEN; vp = entry->mteSetContext; |
| line = read_config_read_data(ASN_OCTET_STR, line, &vp, &len); |
| |
| entry->mteEventActions |= MTE_EVENT_SET; |
| entry->flags |= MTE_EVENT_FLAG_VALID; |
| |
| DEBUGMSG(("disman:event:conf", "\n")); |
| } |
| |
| |
| |
| int |
| store_mteETable(int majorID, int minorID, void *serverarg, void *clientarg) |
| { |
| char line[SNMP_MAXBUF]; |
| char *cptr, *cp; |
| void *vp; |
| size_t tint; |
| netsnmp_tdata_row *row; |
| struct mteEvent *entry; |
| |
| |
| DEBUGMSGTL(("disman:event:conf", "Storing mteEventTable config:\n")); |
| |
| for (row = netsnmp_tdata_row_first( event_table_data ); |
| row; |
| row = netsnmp_tdata_row_next( event_table_data, row )) { |
| |
| /* |
| * Skip entries that were set up via static config directives |
| */ |
| entry = (struct mteEvent *)netsnmp_tdata_row_entry( row ); |
| if ( entry->flags & MTE_EVENT_FLAG_FIXED ) |
| continue; |
| |
| DEBUGMSGTL(("disman:event:conf", " Storing (%s %s)\n", |
| entry->mteOwner, entry->mteEName)); |
| |
| /* |
| * Save the basic mteEventTable entry... |
| */ |
| memset(line, 0, sizeof(line)); |
| strcat(line, "_mteETable "); |
| cptr = line + strlen(line); |
| |
| cp = entry->mteOwner; tint = strlen( cp ); |
| cptr = read_config_store_data( ASN_OCTET_STR, cptr, &cp, &tint ); |
| cp = entry->mteEName; tint = strlen( cp ); |
| cptr = read_config_store_data( ASN_OCTET_STR, cptr, &cp, &tint ); |
| cp = entry->mteEventComment; tint = strlen( cp ); |
| cptr = read_config_store_data( ASN_OCTET_STR, cptr, &cp, &tint ); |
| /* ... (but skip the mteEventAction field)... */ |
| tint = entry->flags & (MTE_EVENT_FLAG_ENABLED|MTE_EVENT_FLAG_ACTIVE); |
| cptr = read_config_store_data( ASN_UNSIGNED, cptr, &tint, NULL ); |
| /* XXX - Need to store the 'iquery' access information */ |
| snmpd_store_config(line); |
| |
| /* |
| * ... then save Notify and/or Set entries separately |
| * (The mteEventAction bits will be set when these are read in). |
| */ |
| if ( entry->mteEventActions & MTE_EVENT_NOTIFICATION ) { |
| memset(line, 0, sizeof(line)); |
| strcat(line, "_mteENotTable "); |
| cptr = line + strlen(line); |
| |
| cp = entry->mteOwner; tint = strlen( cp ); |
| cptr = read_config_store_data(ASN_OCTET_STR, cptr, &cp, &tint ); |
| cp = entry->mteEName; tint = strlen( cp ); |
| cptr = read_config_store_data(ASN_OCTET_STR, cptr, &cp, &tint ); |
| vp = entry->mteNotification; |
| cptr = read_config_store_data(ASN_OBJECT_ID, cptr, &vp, |
| &entry->mteNotification_len); |
| cp = entry->mteNotifyOwner; tint = strlen( cp ); |
| cptr = read_config_store_data(ASN_OCTET_STR, cptr, &cp, &tint ); |
| cp = entry->mteNotifyObjects; tint = strlen( cp ); |
| cptr = read_config_store_data(ASN_OCTET_STR, cptr, &cp, &tint ); |
| snmpd_store_config(line); |
| } |
| |
| if ( entry->mteEventActions & MTE_EVENT_SET ) { |
| memset(line, 0, sizeof(line)); |
| strcat(line, "_mteESetTable "); |
| cptr = line + strlen(line); |
| |
| cp = entry->mteOwner; tint = strlen( cp ); |
| cptr = read_config_store_data(ASN_OCTET_STR, cptr, &cp, &tint ); |
| cp = entry->mteEName; tint = strlen( cp ); |
| cptr = read_config_store_data(ASN_OCTET_STR, cptr, &cp, &tint ); |
| vp = entry->mteSetOID; |
| cptr = read_config_store_data(ASN_OBJECT_ID, cptr, &vp, |
| &entry->mteSetOID_len); |
| tint = entry->mteSetValue; |
| cptr = read_config_store_data(ASN_INTEGER, cptr, &tint, NULL); |
| cp = entry->mteSetTarget; tint = strlen( cp ); |
| cptr = read_config_store_data(ASN_OCTET_STR, cptr, &cp, &tint ); |
| cp = entry->mteSetContext; tint = strlen( cp ); |
| cptr = read_config_store_data(ASN_OCTET_STR, cptr, &cp, &tint ); |
| tint = entry->flags & (MTE_SET_FLAG_OBJWILD|MTE_SET_FLAG_CTXWILD); |
| cptr = read_config_store_data(ASN_UNSIGNED, cptr, &tint, NULL); |
| snmpd_store_config(line); |
| } |
| } |
| |
| DEBUGMSGTL(("disman:event:conf", " done.\n")); |
| return SNMPERR_SUCCESS; |
| } |
| |
| int |
| clear_mteETable(int majorID, int minorID, void *serverarg, void *clientarg) |
| { |
| netsnmp_tdata_row *row; |
| netsnmp_variable_list owner_var; |
| |
| /* |
| * We're only interested in entries set up via the config files |
| */ |
| memset( &owner_var, 0, sizeof(netsnmp_variable_list)); |
| snmp_set_var_typed_value( &owner_var, ASN_OCTET_STR, |
| "snmpd.conf", strlen("snmpd.conf")); |
| while (( row = netsnmp_tdata_row_next_byidx( event_table_data, |
| &owner_var ))) { |
| /* |
| * XXX - check for owner of "snmpd.conf" |
| * and break at the end of these |
| */ |
| netsnmp_tdata_remove_and_delete_row( event_table_data, row ); |
| } |
| return SNMPERR_SUCCESS; |
| } |
