| /* |
| *Copyright(c)2004,Cisco URP imburses and Network Information Center in Beijing University of Posts and Telecommunications researches. |
| * |
| *All right reserved |
| * |
| *File Name:lookupCtlTable.c |
| *File Description:Rows of the lookupCtlTable MIB add , delete and read.Rows of lookupResultsTable |
| * MIB add and delete. |
| |
| * |
| *Current Version:1.0 |
| *Author:ChenJing |
| *Date:2004.8.20 |
| */ |
| |
| /* |
| * This should always be included first before anything else |
| */ |
| #if HAVE_STDLIB_H |
| #include <stdlib.h> |
| #endif |
| #if HAVE_STRING_H |
| #include <string.h> |
| #else |
| #include <strings.h> |
| #endif |
| #ifdef HAVE_LIMITS_H |
| #include <limits.h> |
| #endif |
| |
| #include <netdb.h> |
| #include <netinet/in.h> |
| |
| #include <sys/types.h> |
| #include <sys/socket.h> |
| #include <arpa/inet.h> |
| |
| #include <net-snmp/net-snmp-config.h> |
| #include <net-snmp/net-snmp-includes.h> |
| #include <net-snmp/agent/net-snmp-agent-includes.h> |
| |
| #include "lookupCtlTable.h" |
| #include "lookupResultsTable.h" |
| #include "header_complex.h" |
| |
| /* |
| *For discontinuity checking. |
| */ |
| |
| oid lookupCtlTable_variables_oid[] = |
| { 1, 3, 6, 1, 2, 1, 82, 1, 3 }; |
| |
| |
| struct variable2 lookupCtlTable_variables[] = { |
| /* |
| * magic number , variable type , ro/rw , callback fn , L, oidsuffix |
| */ |
| {COLUMN_LOOKUPCTLTARGETADDRESSTYPE, ASN_INTEGER, NETSNMP_OLDAPI_RWRITE, |
| var_lookupCtlTable, 2, {1, 3}}, |
| {COLUMN_LOOKUPCTLTARGETADDRESS, ASN_OCTET_STR, NETSNMP_OLDAPI_RWRITE, |
| var_lookupCtlTable, 2, {1, 4}}, |
| {COLUMN_LOOKUPCTLOPERSTATUS, ASN_INTEGER, NETSNMP_OLDAPI_RONLY, |
| var_lookupCtlTable, 2, {1, 5}}, |
| {COLUMN_LOOKUPCTLTIME, ASN_UNSIGNED, NETSNMP_OLDAPI_RONLY, |
| var_lookupCtlTable, 2, {1, 6}}, |
| {COLUMN_LOOKUPCTLRC, ASN_INTEGER, NETSNMP_OLDAPI_RONLY, |
| var_lookupCtlTable, 2, {1, 7}}, |
| {COLUMN_LOOKUPCTLROWSTATUS, ASN_INTEGER, NETSNMP_OLDAPI_RWRITE, |
| var_lookupCtlTable, 2, {1, 8}} |
| }; |
| |
| |
| /* |
| * global storage of our data, saved in and configured by header_complex() |
| */ |
| |
| |
| struct header_complex_index *lookupCtlTableStorage = NULL; |
| struct header_complex_index *lookupResultsTableStorage = NULL; |
| |
| int modify_lookupCtlTime(struct lookupTable_data *thedata, unsigned long val); |
| int modify_lookupCtlOperStatus(struct lookupTable_data *thedata, long val); |
| int modify_lookupCtlRc(struct lookupTable_data *thedata, long val); |
| |
| |
| void |
| init_lookupCtlTable(void) |
| { |
| DEBUGMSGTL(("lookupCtlTable", "initializing... ")); |
| /* |
| * register ourselves with the agent to handle our mib tree |
| */ |
| REGISTER_MIB("lookupCtlTable", lookupCtlTable_variables, variable2, |
| lookupCtlTable_variables_oid); |
| |
| |
| /* |
| * register our config handler(s) to deal with registrations |
| */ |
| snmpd_register_config_handler("lookupCtlTable", parse_lookupCtlTable, |
| NULL, NULL); |
| |
| /* |
| * we need to be called back later to store our data |
| */ |
| snmp_register_callback(SNMP_CALLBACK_LIBRARY, SNMP_CALLBACK_STORE_DATA, |
| store_lookupCtlTable, NULL); |
| |
| DEBUGMSGTL(("lookupCtlTable", "done.\n")); |
| } |
| |
| struct lookupTable_data * |
| create_lookupTable_data(void) |
| { |
| struct lookupTable_data *StorageNew = NULL; |
| StorageNew = SNMP_MALLOC_STRUCT(lookupTable_data); |
| if (StorageNew == NULL) { |
| exit(1); |
| } |
| StorageNew->lookupCtlTargetAddress = strdup(""); |
| StorageNew->lookupCtlTargetAddressLen = 0; |
| StorageNew->lookupCtlOperStatus = 2l; |
| StorageNew->lookupCtlTime = 0; |
| StorageNew->storagetype = ST_NONVOLATILE; |
| return StorageNew; |
| } |
| |
| /* |
| * lookupCtlTable_add(): adds a structure node to our data set |
| */ |
| int |
| lookupCtlTable_add(struct lookupTable_data *thedata) |
| { |
| netsnmp_variable_list *vars = NULL; |
| |
| |
| DEBUGMSGTL(("lookupCtlTable", "adding data... ")); |
| /* |
| * add the index variables to the varbind list, which is |
| * used by header_complex to index the data |
| */ |
| |
| |
| snmp_varlist_add_variable(&vars, NULL, 0, ASN_OCTET_STR, (char *) thedata->lookupCtlOwnerIndex, thedata->lookupCtlOwnerIndexLen); /* lookupCtlOwnerIndex */ |
| snmp_varlist_add_variable(&vars, NULL, 0, ASN_OCTET_STR, (char *) thedata->lookupCtlOperationName, thedata->lookupCtlOperationNameLen); /* lookupCtlOperationName */ |
| |
| |
| if (header_complex_add_data(&lookupCtlTableStorage, vars, thedata) == |
| NULL) { |
| return SNMPERR_GENERR; |
| } |
| DEBUGMSGTL(("lookupCtlTable", "registered an entry\n")); |
| vars = NULL; |
| |
| DEBUGMSGTL(("lookupCtlTable", "done.\n")); |
| return SNMPERR_SUCCESS; |
| } |
| |
| int |
| lookupResultsTable_add(struct lookupTable_data *thedata) |
| { |
| netsnmp_variable_list *vars_list = NULL; |
| struct lookupResultsTable_data *p = NULL; |
| p = thedata->ResultsTable; |
| if (thedata->ResultsTable != NULL) |
| do { |
| snmp_varlist_add_variable(&vars_list, NULL, 0, ASN_OCTET_STR, (char *) p->lookupCtlOwnerIndex, p->lookupCtlOwnerIndexLen); /* lookupCtlOwnerIndex */ |
| snmp_varlist_add_variable(&vars_list, NULL, 0, ASN_OCTET_STR, (char *) p->lookupCtlOperationName, p->lookupCtlOperationNameLen); /* lookupCtlOperationName */ |
| snmp_varlist_add_variable(&vars_list, NULL, 0, ASN_UNSIGNED, (char *) &p->lookupResultsIndex, sizeof(p->lookupResultsIndex)); /* lookupResultsIndex */ |
| |
| |
| DEBUGMSGTL(("lookupResultsTable", "adding data... ")); |
| /* |
| * add the index variables to the varbind list, which is |
| * used by header_complex to index the data |
| */ |
| |
| if (header_complex_add_data |
| (&lookupResultsTableStorage, vars_list, p) == NULL) { |
| return SNMPERR_GENERR; |
| } |
| |
| DEBUGMSGTL(("lookupResultsTable", "out finished\n")); |
| vars_list = NULL; |
| p = p->next; |
| } while (p != NULL); |
| |
| |
| DEBUGMSGTL(("lookupResultsTable", "done.\n")); |
| return SNMPERR_SUCCESS; |
| } |
| |
| void |
| lookupCtlTable_cleaner(struct header_complex_index *thestuff) |
| { |
| struct header_complex_index *hciptr = NULL; |
| struct lookupTable_data *StorageDel = NULL; |
| DEBUGMSGTL(("lookupCtlTable", "cleanerout ")); |
| for (hciptr = thestuff; hciptr != NULL; hciptr = hciptr->next) { |
| StorageDel = |
| header_complex_extract_entry(&lookupCtlTableStorage, hciptr); |
| if (StorageDel != NULL) { |
| free(StorageDel->lookupCtlOwnerIndex); |
| StorageDel->lookupCtlOwnerIndex = NULL; |
| free(StorageDel->lookupCtlOperationName); |
| StorageDel->lookupCtlOperationName = NULL; |
| free(StorageDel->lookupCtlTargetAddress); |
| StorageDel->lookupCtlTargetAddress = NULL; |
| free(StorageDel); |
| StorageDel = NULL; |
| |
| } |
| DEBUGMSGTL(("lookupCtlTable", "cleaner ")); |
| } |
| } |
| |
| /* |
| * parse_lookupCtlTable(): |
| * parses .conf file entries needed to configure the mib. |
| */ |
| void |
| parse_lookupCtlTable(const char *token, char *line) |
| { |
| size_t tmpint; |
| struct lookupTable_data *StorageTmp = |
| SNMP_MALLOC_STRUCT(lookupTable_data); |
| |
| DEBUGMSGTL(("lookupCtlTable", "parsing config... ")); |
| |
| |
| if (StorageTmp == NULL) { |
| config_perror("malloc failure"); |
| return; |
| } |
| |
| |
| line = |
| read_config_read_data(ASN_OCTET_STR, line, |
| &StorageTmp->lookupCtlOwnerIndex, |
| &StorageTmp->lookupCtlOwnerIndexLen); |
| if (StorageTmp->lookupCtlOwnerIndex == NULL) { |
| config_perror("invalid specification for lookupCtlOwnerIndex"); |
| return; |
| } |
| |
| line = |
| read_config_read_data(ASN_OCTET_STR, line, |
| &StorageTmp->lookupCtlOperationName, |
| &StorageTmp->lookupCtlOperationNameLen); |
| if (StorageTmp->lookupCtlOperationName == NULL) { |
| config_perror("invalid specification for lookupCtlOperationName"); |
| return; |
| } |
| |
| line = |
| read_config_read_data(ASN_INTEGER, line, |
| &StorageTmp->lookupCtlTargetAddressType, |
| &tmpint); |
| |
| line = |
| read_config_read_data(ASN_OCTET_STR, line, |
| &StorageTmp->lookupCtlTargetAddress, |
| &StorageTmp->lookupCtlTargetAddressLen); |
| if (StorageTmp->lookupCtlTargetAddress == NULL) { |
| config_perror("invalid specification for lookupCtlTargetAddress"); |
| return; |
| } |
| |
| line = |
| read_config_read_data(ASN_INTEGER, line, |
| &StorageTmp->lookupCtlOperStatus, &tmpint); |
| |
| line = |
| read_config_read_data(ASN_UNSIGNED, line, |
| &StorageTmp->lookupCtlTime, &tmpint); |
| |
| line = |
| read_config_read_data(ASN_INTEGER, line, |
| &StorageTmp->lookupCtlRc, &tmpint); |
| |
| line = |
| read_config_read_data(ASN_INTEGER, line, |
| &StorageTmp->lookupCtlRowStatus, &tmpint); |
| |
| |
| StorageTmp->storagetype = ST_NONVOLATILE; |
| lookupCtlTable_add(StorageTmp); |
| /* lookupCtlTable_cleaner(lookupCtlTableStorage); */ |
| |
| DEBUGMSGTL(("lookupCtlTable", "done.\n")); |
| } |
| |
| |
| |
| /* |
| * store_lookupCtlTable(): |
| * stores .conf file entries needed to configure the mib. |
| */ |
| int |
| store_lookupCtlTable(int majorID, int minorID, void *serverarg, |
| void *clientarg) |
| { |
| char line[SNMP_MAXBUF]; |
| char *cptr; |
| size_t tmpint; |
| struct lookupTable_data *StorageTmp; |
| struct header_complex_index *hcindex; |
| |
| |
| DEBUGMSGTL(("lookupCtlTable", "storing data... ")); |
| |
| |
| for (hcindex = lookupCtlTableStorage; hcindex != NULL; |
| hcindex = hcindex->next) { |
| StorageTmp = (struct lookupTable_data *) hcindex->data; |
| |
| if (StorageTmp->storagetype != ST_READONLY) { |
| memset(line, 0, sizeof(line)); |
| strcat(line, "lookupCtlTable "); |
| cptr = line + strlen(line); |
| |
| |
| cptr = |
| read_config_store_data(ASN_OCTET_STR, cptr, |
| &StorageTmp->lookupCtlOwnerIndex, |
| &StorageTmp-> |
| lookupCtlOwnerIndexLen); |
| cptr = |
| read_config_store_data(ASN_OCTET_STR, cptr, |
| &StorageTmp->lookupCtlOperationName, |
| &StorageTmp-> |
| lookupCtlOperationNameLen); |
| cptr = |
| read_config_store_data(ASN_INTEGER, cptr, |
| &StorageTmp-> |
| lookupCtlTargetAddressType, |
| &tmpint); |
| cptr = |
| read_config_store_data(ASN_OCTET_STR, cptr, |
| &StorageTmp->lookupCtlTargetAddress, |
| &StorageTmp-> |
| lookupCtlTargetAddressLen); |
| |
| cptr = |
| read_config_store_data(ASN_INTEGER, cptr, |
| &StorageTmp->lookupCtlOperStatus, |
| &tmpint); |
| cptr = |
| read_config_store_data(ASN_UNSIGNED, cptr, |
| &StorageTmp->lookupCtlTime, |
| &tmpint); |
| cptr = |
| read_config_store_data(ASN_INTEGER, cptr, |
| &StorageTmp->lookupCtlRc, &tmpint); |
| cptr = |
| read_config_store_data(ASN_INTEGER, cptr, |
| &StorageTmp->lookupCtlRowStatus, |
| &tmpint); |
| |
| |
| |
| snmpd_store_config(line); |
| } |
| } |
| DEBUGMSGTL(("lookupCtlTable", "done.\n")); |
| return SNMPERR_SUCCESS; |
| } |
| |
| |
| |
| |
| /* |
| * var_lookupCtlTable(): |
| * Handle this table separately from the scalar value case. |
| * The workings of this are basically the same as for var_mteObjectsTable above. |
| */ |
| unsigned char * |
| var_lookupCtlTable(struct variable *vp, |
| oid * name, |
| size_t *length, |
| int exact, size_t *var_len, WriteMethod ** write_method) |
| { |
| |
| |
| struct lookupTable_data *StorageTmp = NULL; |
| |
| /* |
| * this assumes you have registered all your data properly |
| */ |
| if ((StorageTmp = |
| header_complex(lookupCtlTableStorage, vp, name, length, exact, |
| var_len, write_method)) == NULL) { |
| if (vp->magic == COLUMN_LOOKUPCTLROWSTATUS) |
| *write_method = write_lookupCtlRowStatus; |
| return NULL; |
| } |
| |
| /* |
| * this is where we do the value assignments for the mib results. |
| */ |
| switch (vp->magic) { |
| |
| |
| case COLUMN_LOOKUPCTLTARGETADDRESSTYPE: |
| *write_method = write_lookupCtlTargetAddressType; |
| *var_len = sizeof(StorageTmp->lookupCtlTargetAddressType); |
| return (u_char *) & StorageTmp->lookupCtlTargetAddressType; |
| |
| case COLUMN_LOOKUPCTLTARGETADDRESS: |
| *write_method = write_lookupCtlTargetAddress; |
| *var_len = (StorageTmp->lookupCtlTargetAddressLen); |
| |
| return (u_char *) StorageTmp->lookupCtlTargetAddress; |
| |
| case COLUMN_LOOKUPCTLOPERSTATUS: |
| *var_len = sizeof(StorageTmp->lookupCtlOperStatus); |
| |
| return (u_char *) & StorageTmp->lookupCtlOperStatus; |
| |
| case COLUMN_LOOKUPCTLTIME: |
| *var_len = sizeof(StorageTmp->lookupCtlTime); |
| |
| return (u_char *) & StorageTmp->lookupCtlTime; |
| |
| case COLUMN_LOOKUPCTLRC: |
| *var_len = sizeof(StorageTmp->lookupCtlRc); |
| |
| return (u_char *) & StorageTmp->lookupCtlRc; |
| |
| case COLUMN_LOOKUPCTLROWSTATUS: |
| *write_method = write_lookupCtlRowStatus; |
| *var_len = sizeof(StorageTmp->lookupCtlRowStatus); |
| |
| return (u_char *) & StorageTmp->lookupCtlRowStatus; |
| |
| default: |
| ERROR_MSG(""); |
| } |
| return NULL; |
| } |
| |
| |
| void |
| run_lookup(struct lookupTable_data *item) |
| { |
| |
| long addressType; |
| char *address = NULL; |
| size_t addresslen; |
| struct lookupResultsTable_data *current = NULL; |
| struct lookupResultsTable_data *temp = NULL; |
| int i = 0, n = 1, t = 0; |
| |
| /* for ipv4,ipv6 */ |
| unsigned int addr_in, addr_in6; |
| struct hostent *lookup = NULL; |
| |
| struct timeval tpstart, tpend; |
| unsigned long timeuse, timeuse4, timeuse6; |
| |
| /* for dns */ |
| |
| struct in_addr a; |
| struct in6_addr a6; |
| |
| if (item == NULL) |
| return; |
| |
| addressType = (long) item->lookupCtlTargetAddressType; |
| addresslen = (size_t) item->lookupCtlTargetAddressLen; |
| address = (char *) malloc(addresslen + 1); |
| memcpy(address, item->lookupCtlTargetAddress, addresslen + 1); |
| address[addresslen] = '\0'; |
| |
| if (addressType == 1) { |
| addr_in = inet_addr(address); |
| if (addr_in == 0xffffffff |
| && strcmp(address, "255.255.255.255") != 0) { |
| DEBUGMSGTL(("lookupResultsTable", "Invalid argument: %s\n", |
| address)); |
| return; |
| } |
| |
| gettimeofday(&tpstart, NULL); |
| lookup = gethostbyaddr((char *) &addr_in, 4, AF_INET); |
| gettimeofday(&tpend, NULL); |
| timeuse = 1000000 * (tpend.tv_sec - tpstart.tv_sec) + |
| tpend.tv_usec - tpstart.tv_usec; |
| timeuse /= 1000; |
| modify_lookupCtlTime(item, timeuse); |
| modify_lookupCtlOperStatus(item, 3l); |
| |
| if (lookup == NULL) { |
| DEBUGMSGTL(("lookupCtlTable", |
| "Can't get a network host entry for ipv4 address: %s\n", |
| address)); |
| modify_lookupCtlRc(item, 1l); |
| return; |
| } else { |
| modify_lookupCtlRc(item, 0l); |
| if (lookup->h_name != NULL) { |
| current = temp = |
| SNMP_MALLOC_STRUCT(lookupResultsTable_data); |
| if (temp == NULL) { |
| exit(1); |
| } |
| temp->lookupResultsIndex = n; |
| |
| temp->lookupCtlOwnerIndex = |
| (char *) malloc(item->lookupCtlOwnerIndexLen + 1); |
| if (temp->lookupCtlOwnerIndex == NULL) { |
| exit(1); |
| } |
| memcpy(temp->lookupCtlOwnerIndex, |
| item->lookupCtlOwnerIndex, |
| item->lookupCtlOwnerIndexLen + 1); |
| temp->lookupCtlOwnerIndex[item->lookupCtlOwnerIndexLen] = |
| '\0'; |
| temp->lookupCtlOwnerIndexLen = |
| item->lookupCtlOwnerIndexLen; |
| |
| temp->lookupCtlOperationName = |
| (char *) malloc(item->lookupCtlOperationNameLen + 1); |
| if (temp->lookupCtlOperationName == NULL) { |
| exit(1); |
| } |
| memcpy(temp->lookupCtlOperationName, |
| item->lookupCtlOperationName, |
| item->lookupCtlOperationNameLen + 1); |
| temp->lookupCtlOperationName[item-> |
| lookupCtlOperationNameLen] = |
| '\0'; |
| temp->lookupCtlOperationNameLen = |
| item->lookupCtlOperationNameLen; |
| |
| temp->lookupResultsAddressType = 16; |
| temp->lookupResultsAddress = |
| (char *) malloc(strlen(lookup->h_name) + 1); |
| memcpy(temp->lookupResultsAddress, lookup->h_name, |
| strlen(lookup->h_name) + 1); |
| temp->lookupResultsAddress[strlen(lookup->h_name)] = '\0'; |
| temp->lookupResultsAddressLen = strlen(lookup->h_name); |
| item->ResultsTable = temp; |
| n = n + 1; |
| |
| } |
| |
| i = 0; |
| while (lookup->h_aliases[i]) { |
| temp = SNMP_MALLOC_STRUCT(lookupResultsTable_data); |
| if (temp == NULL) { |
| exit(1); |
| } |
| temp->lookupCtlOwnerIndex = |
| (char *) malloc(item->lookupCtlOwnerIndexLen + 1); |
| if (temp->lookupCtlOwnerIndex == NULL) { |
| exit(1); |
| } |
| memcpy(temp->lookupCtlOwnerIndex, |
| item->lookupCtlOwnerIndex, |
| item->lookupCtlOwnerIndexLen + 1); |
| temp->lookupCtlOwnerIndex[item->lookupCtlOwnerIndexLen] = |
| '\0'; |
| temp->lookupCtlOwnerIndexLen = |
| item->lookupCtlOwnerIndexLen; |
| |
| temp->lookupCtlOperationName = |
| (char *) malloc(item->lookupCtlOperationNameLen + 1); |
| if (temp->lookupCtlOperationName == NULL) { |
| exit(1); |
| } |
| memcpy(temp->lookupCtlOperationName, |
| item->lookupCtlOperationName, |
| item->lookupCtlOperationNameLen + 1); |
| temp->lookupCtlOperationName[item-> |
| lookupCtlOperationNameLen] = |
| '\0'; |
| temp->lookupCtlOperationNameLen = |
| item->lookupCtlOperationNameLen; |
| |
| temp->lookupResultsIndex = n; |
| temp->lookupResultsAddressType = 16; |
| temp->lookupResultsAddress = |
| (char *) malloc(strlen(lookup->h_aliases[i]) + 1); |
| memcpy(temp->lookupResultsAddress, lookup->h_aliases[i], |
| strlen(lookup->h_aliases[i]) + 1); |
| temp->lookupResultsAddress[strlen(lookup->h_aliases[i])] = |
| '\0'; |
| temp->lookupResultsAddressLen = |
| strlen(lookup->h_aliases[i]); |
| current->next = temp; |
| current = temp; |
| i = i + 1; |
| n = n + 1; |
| } |
| current->next = NULL; |
| |
| } |
| |
| |
| if (item->ResultsTable != NULL) |
| if (lookupResultsTable_add(item) != SNMPERR_SUCCESS) |
| DEBUGMSGTL(("lookupResultsTable", |
| "registered an entry error\n")); |
| |
| SNMP_FREE(address); |
| address = NULL; |
| return; |
| } |
| |
| else if (addressType == 16) { |
| |
| gettimeofday(&tpstart, NULL); |
| lookup = gethostbyname(address); |
| gettimeofday(&tpend, NULL); |
| timeuse4 = 1000000 * (tpend.tv_sec - tpstart.tv_sec) + |
| tpend.tv_usec - tpstart.tv_usec; |
| timeuse4 /= 1000; |
| if (lookup == NULL) { |
| DEBUGMSGTL(("lookupCtlTable", |
| "Can't get a network host entry for %s\n", |
| address)); |
| } else { |
| while (*lookup->h_addr_list) { |
| memcpy(&a, *lookup->h_addr_list++, sizeof(a)); |
| |
| temp = SNMP_MALLOC_STRUCT(lookupResultsTable_data); |
| if (temp == NULL) { |
| exit(1); |
| } |
| temp->lookupResultsIndex = n; |
| |
| temp->lookupCtlOwnerIndex = |
| (char *) malloc(item->lookupCtlOwnerIndexLen + 1); |
| if (temp->lookupCtlOwnerIndex == NULL) { |
| exit(1); |
| } |
| memcpy(temp->lookupCtlOwnerIndex, |
| item->lookupCtlOwnerIndex, |
| item->lookupCtlOwnerIndexLen + 1); |
| temp->lookupCtlOwnerIndex[item->lookupCtlOwnerIndexLen] = |
| '\0'; |
| temp->lookupCtlOwnerIndexLen = |
| item->lookupCtlOwnerIndexLen; |
| |
| temp->lookupCtlOperationName = |
| (char *) malloc(item->lookupCtlOperationNameLen + 1); |
| if (temp->lookupCtlOperationName == NULL) { |
| exit(1); |
| } |
| |
| memcpy(temp->lookupCtlOperationName, |
| item->lookupCtlOperationName, |
| item->lookupCtlOperationNameLen + 1); |
| temp->lookupCtlOperationName[item-> |
| lookupCtlOperationNameLen] = |
| '\0'; |
| temp->lookupCtlOperationNameLen = |
| item->lookupCtlOperationNameLen; |
| |
| temp->lookupResultsAddressType = 1; |
| temp->lookupResultsAddress = |
| (char *) malloc(strlen(inet_ntoa(a)) + 1); |
| if (temp->lookupResultsAddress == NULL) { |
| exit(1); |
| } |
| memcpy(temp->lookupResultsAddress, inet_ntoa(a), |
| strlen(inet_ntoa(a)) + 1); |
| temp->lookupResultsAddress[strlen(inet_ntoa(a))] = '\0'; |
| temp->lookupResultsAddressLen = strlen(inet_ntoa(a)); |
| if (n == 1) |
| item->ResultsTable = temp; |
| else |
| current->next = temp; |
| current = temp; |
| n = n + 1; |
| |
| } |
| current->next = NULL; |
| t = n; |
| |
| } |
| |
| struct hostent *hp; |
| char pa[64]; |
| char *hostname = NULL; |
| |
| gettimeofday(&tpstart, NULL); |
| hp = gethostbyname2(address, AF_INET6); |
| gettimeofday(&tpend, NULL); |
| timeuse6 = 1000000 * (tpend.tv_sec - tpstart.tv_sec) + |
| tpend.tv_usec - tpstart.tv_usec; |
| timeuse6 /= 1000; |
| |
| if (hp == NULL) { |
| DEBUGMSGTL(("lookupCtlTable", |
| "Can't get a ipv6 network host entry for %s\n", |
| address)); |
| } else { |
| while (*hp->h_addr_list) { |
| memmove((caddr_t) & a6, *hp->h_addr_list++, 16); |
| hostname = (char *) hp->h_name; |
| |
| temp = SNMP_MALLOC_STRUCT(lookupResultsTable_data); |
| if (temp == NULL) { |
| exit(1); |
| } |
| temp->lookupResultsIndex = n; |
| |
| temp->lookupCtlOwnerIndex = |
| (char *) malloc(item->lookupCtlOwnerIndexLen + 1); |
| if (temp->lookupCtlOwnerIndex == NULL) { |
| exit(1); |
| } |
| memcpy(temp->lookupCtlOwnerIndex, |
| item->lookupCtlOwnerIndex, |
| item->lookupCtlOwnerIndexLen + 1); |
| temp->lookupCtlOwnerIndex[item->lookupCtlOwnerIndexLen] = |
| '\0'; |
| temp->lookupCtlOwnerIndexLen = |
| item->lookupCtlOwnerIndexLen; |
| |
| temp->lookupCtlOperationName = |
| (char *) malloc(item->lookupCtlOperationNameLen + 1); |
| if (temp->lookupCtlOperationName == NULL) { |
| exit(1); |
| } |
| memcpy(temp->lookupCtlOperationName, |
| item->lookupCtlOperationName, |
| item->lookupCtlOperationNameLen + 1); |
| temp->lookupCtlOperationName[item-> |
| lookupCtlOperationNameLen] = |
| '\0'; |
| temp->lookupCtlOperationNameLen = |
| item->lookupCtlOperationNameLen; |
| |
| temp->lookupResultsAddressType = 2; |
| temp->lookupResultsAddress = |
| (char *) |
| malloc(strlen(inet_ntop(AF_INET6, &a6, pa, 64)) + 1); |
| memcpy(temp->lookupResultsAddress, |
| inet_ntop(AF_INET6, &a6, pa, 64), |
| strlen(inet_ntop(AF_INET6, &a6, pa, 64)) + 1); |
| temp-> |
| lookupResultsAddress[strlen |
| (inet_ntop |
| (AF_INET6, &a6, pa, 64))] = '\0'; |
| temp->lookupResultsAddressLen = |
| strlen(inet_ntop(AF_INET6, &a6, pa, 64)); |
| if (n == 1) |
| item->ResultsTable = temp; |
| else |
| current->next = temp; |
| current = temp; |
| n = n + 1; |
| |
| } |
| current->next = NULL; |
| } |
| timeuse = timeuse4 + timeuse6; |
| modify_lookupCtlTime(item, timeuse); |
| modify_lookupCtlOperStatus(item, 3l); |
| |
| if (item->ResultsTable != NULL) { |
| |
| modify_lookupCtlRc(item, 0l); |
| if (lookupResultsTable_add(item) != SNMPERR_SUCCESS) |
| DEBUGMSGTL(("lookupResultsTable", |
| "registered an entry error\n")); |
| } else { |
| modify_lookupCtlRc(item, 1l); |
| } |
| SNMP_FREE(address); |
| address = NULL; |
| |
| return; |
| |
| } |
| |
| |
| else if (addressType == 2) { |
| if (inet_pton(AF_INET6, address, &addr_in6) == 1) |
| DEBUGMSGTL(("lookupCtlTable", "success! \n")); |
| else |
| DEBUGMSGTL(("lookupCtlTable", "error! \n")); |
| |
| |
| gettimeofday(&tpstart, NULL); |
| lookup = gethostbyaddr((char *) &addr_in6, 16, AF_INET6); |
| gettimeofday(&tpend, NULL); |
| timeuse = 1000000 * (tpend.tv_sec - tpstart.tv_sec) + |
| tpend.tv_usec - tpstart.tv_usec; |
| timeuse /= 1000; |
| modify_lookupCtlTime(item, timeuse); |
| modify_lookupCtlOperStatus(item, 3l); |
| |
| if (lookup == NULL) { |
| DEBUGMSGTL(("lookupCtlTable", |
| "Can't get a network host entry for %s\n", |
| address)); |
| modify_lookupCtlRc(item, 1l); |
| return; |
| } else { |
| modify_lookupCtlRc(item, 0l); |
| if (lookup->h_name != NULL) { |
| current = temp = |
| SNMP_MALLOC_STRUCT(lookupResultsTable_data); |
| if (temp == NULL) { |
| exit(1); |
| } |
| temp->lookupResultsIndex = n; |
| |
| temp->lookupCtlOwnerIndex = |
| (char *) malloc(item->lookupCtlOwnerIndexLen + 1); |
| if (temp->lookupCtlOwnerIndex == NULL) { |
| exit(1); |
| } |
| memcpy(temp->lookupCtlOwnerIndex, |
| item->lookupCtlOwnerIndex, |
| item->lookupCtlOwnerIndexLen + 1); |
| temp->lookupCtlOwnerIndex[item->lookupCtlOwnerIndexLen] = |
| '\0'; |
| temp->lookupCtlOwnerIndexLen = |
| item->lookupCtlOwnerIndexLen; |
| |
| temp->lookupCtlOperationName = |
| (char *) malloc(item->lookupCtlOperationNameLen + 1); |
| if (temp->lookupCtlOperationName == NULL) { |
| exit(1); |
| } |
| memcpy(temp->lookupCtlOperationName, |
| item->lookupCtlOperationName, |
| item->lookupCtlOperationNameLen + 1); |
| temp->lookupCtlOperationName[item-> |
| lookupCtlOperationNameLen] = |
| '\0'; |
| temp->lookupCtlOperationNameLen = |
| item->lookupCtlOperationNameLen; |
| |
| temp->lookupResultsAddressType = 16; |
| temp->lookupResultsAddress = |
| (char *) malloc(strlen(lookup->h_name) + 1); |
| memcpy(temp->lookupResultsAddress, lookup->h_name, |
| strlen(lookup->h_name) + 1); |
| temp->lookupResultsAddress[strlen(lookup->h_name)] = '\0'; |
| temp->lookupResultsAddressLen = strlen(lookup->h_name); |
| item->ResultsTable = temp; |
| n = n + 1; |
| |
| } |
| |
| i = 0; |
| while (lookup->h_aliases[i]) { |
| temp = SNMP_MALLOC_STRUCT(lookupResultsTable_data); |
| if (temp == NULL) { |
| exit(1); |
| } |
| temp->lookupCtlOwnerIndex = |
| (char *) malloc(item->lookupCtlOwnerIndexLen + 1); |
| if (temp->lookupCtlOwnerIndex == NULL) { |
| exit(1); |
| } |
| memcpy(temp->lookupCtlOwnerIndex, |
| item->lookupCtlOwnerIndex, |
| item->lookupCtlOwnerIndexLen + 1); |
| temp->lookupCtlOwnerIndex[item->lookupCtlOwnerIndexLen] = |
| '\0'; |
| temp->lookupCtlOwnerIndexLen = |
| item->lookupCtlOwnerIndexLen; |
| |
| temp->lookupCtlOperationName = |
| (char *) malloc(item->lookupCtlOperationNameLen + 1); |
| if (temp->lookupCtlOperationName == NULL) { |
| exit(1); |
| } |
| memcpy(temp->lookupCtlOperationName, |
| item->lookupCtlOperationName, |
| item->lookupCtlOperationNameLen + 1); |
| temp->lookupCtlOperationName[item-> |
| lookupCtlOperationNameLen] = |
| '\0'; |
| temp->lookupCtlOperationNameLen = |
| item->lookupCtlOperationNameLen; |
| |
| temp->lookupResultsIndex = n; |
| temp->lookupResultsAddressType = 16; |
| temp->lookupResultsAddress = |
| (char *) malloc(strlen(lookup->h_aliases[i]) + 1); |
| if (temp->lookupResultsAddress == NULL) { |
| exit(1); |
| } |
| memcpy(temp->lookupResultsAddress, lookup->h_aliases[i], |
| strlen(lookup->h_aliases[i]) + 1); |
| temp->lookupResultsAddress[strlen(lookup->h_aliases[i])] = |
| '\0'; |
| temp->lookupResultsAddressLen = |
| strlen(lookup->h_aliases[i]); |
| current->next = temp; |
| current = temp; |
| i = i + 1; |
| n = n + 1; |
| |
| } |
| |
| if (item->ResultsTable != NULL) |
| current->next = NULL; |
| else |
| current = NULL; |
| |
| } |
| |
| |
| if (item->ResultsTable != NULL) |
| if (lookupResultsTable_add(item) != SNMPERR_SUCCESS) |
| DEBUGMSGTL(("lookupResultsTable", |
| "registered an entry error\n")); |
| SNMP_FREE(address); |
| address = NULL; |
| return; |
| } else { |
| SNMP_FREE(address); |
| address = NULL; |
| return; |
| } |
| } |
| |
| |
| int |
| modify_lookupCtlOperStatus(struct lookupTable_data *thedata, long val) |
| { |
| netsnmp_variable_list *vars = NULL; |
| struct lookupTable_data *StorageTmp = NULL; |
| |
| snmp_varlist_add_variable(&vars, NULL, 0, ASN_OCTET_STR, (char *) thedata->lookupCtlOwnerIndex, thedata->lookupCtlOwnerIndexLen); /* lookupCtlOwnerIndex */ |
| snmp_varlist_add_variable(&vars, NULL, 0, ASN_OCTET_STR, (char *) thedata->lookupCtlOperationName, thedata->lookupCtlOperationNameLen); /* lookupCtlOperationName */ |
| |
| |
| if ((StorageTmp = |
| header_complex_get(lookupCtlTableStorage, vars)) == NULL) { |
| snmp_free_varbind(vars); |
| vars = NULL; |
| return SNMP_ERR_NOSUCHNAME; |
| } |
| StorageTmp->lookupCtlOperStatus = val; |
| |
| snmp_free_varbind(vars); |
| vars = NULL; |
| |
| DEBUGMSGTL(("lookupOperStatus", "done.\n")); |
| return SNMPERR_SUCCESS; |
| } |
| |
| int |
| modify_lookupCtlTime(struct lookupTable_data *thedata, unsigned long val) |
| { |
| netsnmp_variable_list *vars = NULL; |
| struct lookupTable_data *StorageTmp = NULL; |
| |
| snmp_varlist_add_variable(&vars, NULL, 0, ASN_OCTET_STR, (char *) thedata->lookupCtlOwnerIndex, thedata->lookupCtlOwnerIndexLen); /* lookupCtlOwnerIndex */ |
| snmp_varlist_add_variable(&vars, NULL, 0, ASN_OCTET_STR, (char *) thedata->lookupCtlOperationName, thedata->lookupCtlOperationNameLen); /* lookupCtlOperationName */ |
| |
| |
| if ((StorageTmp = |
| header_complex_get(lookupCtlTableStorage, vars)) == NULL) { |
| snmp_free_varbind(vars); |
| vars = NULL; |
| return SNMP_ERR_NOSUCHNAME; |
| } |
| StorageTmp->lookupCtlTime = val; |
| |
| snmp_free_varbind(vars); |
| vars = NULL; |
| |
| DEBUGMSGTL(("lookupCtlTime", "done.\n")); |
| return SNMPERR_SUCCESS; |
| } |
| |
| int |
| modify_lookupCtlRc(struct lookupTable_data *thedata, long val) |
| { |
| netsnmp_variable_list *vars = NULL; |
| struct lookupTable_data *StorageTmp = NULL; |
| |
| snmp_varlist_add_variable(&vars, NULL, 0, ASN_OCTET_STR, (char *) thedata->lookupCtlOwnerIndex, thedata->lookupCtlOwnerIndexLen); /* lookupCtlOwnerIndex */ |
| snmp_varlist_add_variable(&vars, NULL, 0, ASN_OCTET_STR, (char *) thedata->lookupCtlOperationName, thedata->lookupCtlOperationNameLen); /* lookupCtlOperationName */ |
| |
| |
| if ((StorageTmp = |
| header_complex_get(lookupCtlTableStorage, vars)) == NULL) { |
| snmp_free_varbind(vars); |
| vars = NULL; |
| return SNMP_ERR_NOSUCHNAME; |
| } |
| StorageTmp->lookupCtlRc = val; |
| |
| snmp_free_varbind(vars); |
| vars = NULL; |
| DEBUGMSGTL(("lookupOperStatus", "done.\n")); |
| return SNMPERR_SUCCESS; |
| } |
| |
| |
| int |
| lookupResultsTable_del(struct lookupTable_data *thedata) |
| { |
| struct header_complex_index *hciptr2 = NULL; |
| struct lookupResultsTable_data *StorageDel = NULL; |
| netsnmp_variable_list *vars = NULL; |
| oid newoid[MAX_OID_LEN]; |
| size_t newoid_len; |
| |
| snmp_varlist_add_variable(&vars, NULL, 0, ASN_OCTET_STR, (char *) thedata->lookupCtlOwnerIndex, thedata->lookupCtlOwnerIndexLen); /* lookupCtlOwnerIndex */ |
| snmp_varlist_add_variable(&vars, NULL, 0, ASN_OCTET_STR, (char *) thedata->lookupCtlOperationName, thedata->lookupCtlOperationNameLen); /* lookupCtlOperationName */ |
| memset(newoid, '\0', MAX_OID_LEN * sizeof(oid)); |
| header_complex_generate_oid(newoid, &newoid_len, NULL, 0, vars); |
| |
| |
| snmp_free_varbind(vars); |
| vars = NULL; |
| for (hciptr2 = lookupResultsTableStorage; hciptr2 != NULL; |
| hciptr2 = hciptr2->next) { |
| if (snmp_oid_compare(newoid, newoid_len, hciptr2->name, newoid_len) |
| == 0) { |
| StorageDel = |
| header_complex_extract_entry(&lookupResultsTableStorage, |
| hciptr2); |
| if (StorageDel != NULL) { |
| SNMP_FREE(StorageDel->lookupCtlOwnerIndex); |
| SNMP_FREE(StorageDel->lookupCtlOperationName); |
| SNMP_FREE(StorageDel->lookupResultsAddress); |
| SNMP_FREE(StorageDel); |
| } |
| DEBUGMSGTL(("lookupResultsTable", "delete success!\n")); |
| |
| } |
| } |
| return SNMPERR_SUCCESS; |
| } |
| |
| |
| int |
| write_lookupCtlTargetAddressType(int action, |
| u_char * var_val, |
| u_char var_val_type, |
| size_t var_val_len, |
| u_char * statP, oid * name, |
| size_t name_len) |
| { |
| static size_t tmpvar; |
| struct lookupTable_data *StorageTmp = NULL; |
| size_t newlen = |
| name_len - (sizeof(lookupCtlTable_variables_oid) / sizeof(oid) + |
| 3 - 1); |
| |
| if ((StorageTmp = |
| header_complex(lookupCtlTableStorage, NULL, |
| &name[sizeof(lookupCtlTable_variables_oid) / |
| sizeof(oid) + 3 - 1], &newlen, 1, NULL, |
| NULL)) == NULL) |
| return SNMP_ERR_NOSUCHNAME; /* remove if you support creation here */ |
| |
| if (StorageTmp && StorageTmp->storagetype == ST_READONLY) { |
| return SNMP_ERR_NOTWRITABLE; |
| } |
| |
| if (StorageTmp && StorageTmp->lookupCtlRowStatus == RS_ACTIVE) { |
| return SNMP_ERR_NOTWRITABLE; |
| } |
| switch (action) { |
| case RESERVE1: |
| if (var_val_type != ASN_INTEGER) { |
| snmp_log(LOG_ERR, |
| "write to lookupCtlTargetAddressType not ASN_INTEGER\n"); |
| return SNMP_ERR_WRONGTYPE; |
| } |
| break; |
| |
| |
| case RESERVE2: |
| /* |
| * memory reseveration, final preparation... |
| */ |
| break; |
| |
| |
| case FREE: |
| /* |
| * Release any resources that have been allocated |
| */ |
| break; |
| |
| |
| case ACTION: |
| /* |
| * The variable has been stored in objid for |
| * you to use, and you have just been asked to do something with |
| * it. Note that anything done here must be reversable in the UNDO case |
| */ |
| tmpvar = StorageTmp->lookupCtlTargetAddressType; |
| StorageTmp->lookupCtlTargetAddressType = *((long *) var_val); |
| break; |
| |
| |
| case UNDO: |
| /* |
| * Back out any changes made in the ACTION case |
| */ |
| StorageTmp->lookupCtlTargetAddressType = tmpvar; |
| break; |
| |
| |
| case COMMIT: |
| /* |
| * Things are working well, so it's now safe to make the change |
| * permanently. Make sure that anything done here can't fail! |
| */ |
| break; |
| } |
| return SNMP_ERR_NOERROR; |
| } |
| |
| |
| |
| int |
| write_lookupCtlTargetAddress(int action, |
| u_char * var_val, |
| u_char var_val_type, |
| size_t var_val_len, |
| u_char * statP, oid * name, size_t name_len) |
| { |
| static char *tmpvar = NULL; |
| static size_t tmplen; |
| struct lookupTable_data *StorageTmp = NULL; |
| size_t newlen = |
| name_len - (sizeof(lookupCtlTable_variables_oid) / sizeof(oid) + |
| 3 - 1); |
| if ((StorageTmp = |
| header_complex(lookupCtlTableStorage, NULL, |
| &name[sizeof(lookupCtlTable_variables_oid) / |
| sizeof(oid) + 3 - 1], &newlen, 1, NULL, |
| NULL)) == NULL) |
| return SNMP_ERR_NOSUCHNAME; /* remove if you support creation here */ |
| |
| if (StorageTmp && StorageTmp->storagetype == ST_READONLY) { |
| return SNMP_ERR_NOTWRITABLE; |
| } |
| |
| if (StorageTmp && StorageTmp->lookupCtlRowStatus == RS_ACTIVE) { |
| return SNMP_ERR_NOTWRITABLE; |
| } |
| |
| switch (action) { |
| case RESERVE1: |
| if (var_val_type != ASN_OCTET_STR) { |
| snmp_log(LOG_ERR, |
| "write to lookupCtlTargetAddress not ASN_OCTET_STR\n"); |
| return SNMP_ERR_WRONGTYPE; |
| } |
| |
| break; |
| |
| |
| case RESERVE2: |
| /* |
| * memory reseveration, final preparation... |
| */ |
| |
| break; |
| |
| |
| case FREE: |
| /* |
| * Release any resources that have been allocated |
| */ |
| |
| break; |
| |
| |
| case ACTION: |
| /* |
| * The variable has been stored in long_ret for |
| * you to use, and you have just been asked to do something with |
| * it. Note that anything done here must be reversable in the UNDO case |
| */ |
| tmpvar = StorageTmp->lookupCtlTargetAddress; |
| tmplen = StorageTmp->lookupCtlTargetAddressLen; |
| |
| if ((StorageTmp->lookupCtlTargetAddress = |
| (char *) malloc(var_val_len + 1)) == NULL) { |
| exit(1); |
| } |
| memcpy(StorageTmp->lookupCtlTargetAddress, var_val, var_val_len); |
| StorageTmp->lookupCtlTargetAddress[var_val_len] = '\0'; |
| StorageTmp->lookupCtlTargetAddressLen = var_val_len; |
| |
| break; |
| |
| |
| case UNDO: |
| /* |
| * Back out any changes made in the ACTION case |
| */ |
| free(StorageTmp->lookupCtlTargetAddress); |
| StorageTmp->lookupCtlTargetAddress = NULL; |
| StorageTmp->lookupCtlTargetAddress = tmpvar; |
| StorageTmp->lookupCtlTargetAddressLen = tmplen; |
| |
| break; |
| |
| |
| case COMMIT: |
| /* |
| * Things are working well, so it's now safe to make the change |
| * permanently. Make sure that anything done here can't fail! |
| */ |
| |
| free(tmpvar); |
| tmpvar = NULL; |
| |
| break; |
| } |
| return SNMP_ERR_NOERROR; |
| } |
| |
| |
| |
| |
| |
| |
| int |
| write_lookupCtlRowStatus(int action, |
| u_char * var_val, |
| u_char var_val_type, |
| size_t var_val_len, |
| u_char * statP, oid * name, size_t name_len) |
| { |
| struct lookupTable_data *StorageTmp = NULL; |
| static struct lookupTable_data *StorageNew, *StorageDel = NULL; |
| size_t newlen = |
| name_len - (sizeof(lookupCtlTable_variables_oid) / sizeof(oid) + |
| 3 - 1); |
| static int old_value; |
| int set_value; |
| static netsnmp_variable_list *vars, *vp; |
| struct header_complex_index *hciptr = NULL; |
| |
| StorageTmp = |
| header_complex(lookupCtlTableStorage, NULL, |
| &name[sizeof(lookupCtlTable_variables_oid) / |
| sizeof(oid) + 3 - 1], &newlen, 1, NULL, NULL); |
| |
| if (var_val_type != ASN_INTEGER || var_val == NULL) { |
| snmp_log(LOG_ERR, "write to lookupCtlRowStatus not ASN_INTEGER\n"); |
| return SNMP_ERR_WRONGTYPE; |
| } |
| if (StorageTmp && StorageTmp->storagetype == ST_READONLY) { |
| return SNMP_ERR_NOTWRITABLE; |
| } |
| |
| set_value = *((long *) var_val); |
| |
| |
| /* |
| * check legal range, and notReady is reserved for us, not a user |
| */ |
| if (set_value < 1 || set_value > 6 || set_value == RS_NOTREADY) |
| return SNMP_ERR_INCONSISTENTVALUE; |
| |
| |
| switch (action) { |
| case RESERVE1: |
| /* |
| * stage one: test validity |
| */ |
| if (StorageTmp == NULL) { |
| /* |
| * create the row now? |
| */ |
| |
| |
| /* |
| * ditch illegal values now |
| */ |
| if (set_value == RS_ACTIVE || set_value == RS_NOTINSERVICE) { |
| |
| return SNMP_ERR_INCONSISTENTVALUE; |
| } |
| |
| /* |
| * destroying a non-existent row is actually legal |
| */ |
| if (set_value == RS_DESTROY) { |
| return SNMP_ERR_NOERROR; |
| } |
| |
| |
| /* |
| * illegal creation values |
| */ |
| if (set_value == RS_ACTIVE || set_value == RS_NOTINSERVICE) { |
| return SNMP_ERR_INCONSISTENTVALUE; |
| } |
| } else { |
| /* |
| * row exists. Check for a valid state change |
| */ |
| if (set_value == RS_CREATEANDGO |
| || set_value == RS_CREATEANDWAIT) { |
| /* |
| * can't create a row that exists |
| */ |
| return SNMP_ERR_INCONSISTENTVALUE; |
| } |
| |
| /* |
| * XXX: interaction with row storage type needed |
| */ |
| |
| if (StorageTmp->lookupCtlRowStatus == RS_ACTIVE && |
| set_value != RS_DESTROY) { |
| /* |
| * "Once made active an entry may not be modified except to |
| * delete it." XXX: doesn't this in fact apply to ALL |
| * columns of the table and not just this one? |
| */ |
| return SNMP_ERR_INCONSISTENTVALUE; |
| } |
| if (StorageTmp->storagetype != ST_NONVOLATILE) |
| return SNMP_ERR_NOTWRITABLE; |
| } |
| break; |
| |
| |
| |
| |
| case RESERVE2: |
| /* |
| * memory reseveration, final preparation... |
| */ |
| if (StorageTmp == NULL) { |
| /* |
| * creation |
| */ |
| if (set_value == RS_DESTROY) { |
| return SNMP_ERR_NOERROR; |
| } |
| vars = NULL; |
| |
| /* |
| * ½«nameΪ¿ÕµÄÈý¸öË÷Òý×ֶμӵ½var±äÁ¿ÁбíµÄĩβ |
| */ |
| snmp_varlist_add_variable(&vars, NULL, 0, ASN_OCTET_STR, NULL, 0); /* lookupCtlOwnerIndex */ |
| snmp_varlist_add_variable(&vars, NULL, 0, ASN_OCTET_STR, NULL, 0); /* lookupCtlOperationName */ |
| |
| if (header_complex_parse_oid |
| (& |
| (name |
| [sizeof(lookupCtlTable_variables_oid) / sizeof(oid) + |
| 2]), newlen, vars) != SNMPERR_SUCCESS) { |
| /* |
| * XXX: free, zero vars |
| */ |
| snmp_free_varbind(vars); |
| vars = NULL; |
| return SNMP_ERR_INCONSISTENTNAME; |
| } |
| vp = vars; |
| StorageNew = create_lookupTable_data(); |
| StorageNew->lookupCtlOwnerIndex = malloc(vp->val_len + 1); |
| memcpy(StorageNew->lookupCtlOwnerIndex, vp->val.string, |
| vp->val_len); |
| StorageNew->lookupCtlOwnerIndex[vp->val_len] = '\0'; |
| StorageNew->lookupCtlOwnerIndexLen = vp->val_len; |
| vp = vp->next_variable; |
| |
| StorageNew->lookupCtlOperationName = malloc(vp->val_len + 1); |
| memcpy(StorageNew->lookupCtlOperationName, vp->val.string, |
| vp->val_len); |
| StorageNew->lookupCtlOperationName[vp->val_len] = '\0'; |
| StorageNew->lookupCtlOperationNameLen = vp->val_len; |
| vp = vp->next_variable; |
| |
| /* |
| * XXX: fill in default row values here into StorageNew |
| */ |
| |
| StorageNew->lookupCtlTargetAddressType = 1; /* ipv4 */ |
| |
| StorageNew->lookupCtlRowStatus = set_value; |
| |
| snmp_free_varbind(vars); |
| vars = NULL; |
| |
| /* |
| * XXX: free, zero vars, no longer needed? |
| */ |
| } |
| |
| |
| break; |
| |
| |
| |
| |
| case FREE: |
| /* |
| * XXX: free, zero vars |
| */ |
| /* |
| * Release any resources that have been allocated |
| */ |
| break; |
| |
| |
| |
| |
| case ACTION: |
| /* |
| * The variable has been stored in set_value for you to |
| * use, and you have just been asked to do something with |
| * it. Note that anything done here must be reversable in |
| * the UNDO case |
| */ |
| |
| |
| if (StorageTmp == NULL) { |
| /* |
| * row creation, so add it |
| */ |
| if (set_value == RS_DESTROY) { |
| return SNMP_ERR_NOERROR; |
| } |
| if (StorageNew != NULL) |
| #if 1 |
| DEBUGMSGTL(("lookupCtlTable", |
| "write_lookupCtlRowStatus entering new=%d... \n", |
| action)); |
| #endif |
| lookupCtlTable_add(StorageNew); |
| /* |
| * XXX: ack, and if it is NULL? |
| */ |
| } else if (set_value != RS_DESTROY) { |
| /* |
| * set the flag? |
| */ |
| old_value = StorageTmp->lookupCtlRowStatus; |
| StorageTmp->lookupCtlRowStatus = *((long *) var_val); |
| } else { |
| /* |
| * destroy... extract it for now |
| */ |
| DEBUGMSGTL(("lookupCtlTable", |
| "write_lookupCtlTable_delete 1 \n")); |
| hciptr = |
| header_complex_find_entry(lookupCtlTableStorage, |
| StorageTmp); |
| |
| StorageDel = |
| header_complex_extract_entry(&lookupCtlTableStorage, |
| hciptr); |
| lookupResultsTable_del(StorageTmp); |
| |
| DEBUGMSGTL(("lookupCtlTable", |
| "write_lookupCtlTable_delete \n")); |
| |
| } |
| break; |
| |
| |
| |
| |
| case UNDO: |
| /* |
| * Back out any changes made in the ACTION case |
| */ |
| if (StorageTmp == NULL) { |
| /* |
| * row creation, so remove it again |
| */ |
| hciptr = |
| header_complex_find_entry(lookupCtlTableStorage, |
| StorageTmp); |
| StorageDel = |
| header_complex_extract_entry(&lookupCtlTableStorage, |
| hciptr); |
| |
| lookupResultsTable_del(StorageTmp); |
| |
| /* |
| * XXX: free it |
| */ |
| } else if (StorageDel != NULL) { |
| /* |
| * row deletion, so add it again |
| */ |
| lookupCtlTable_add(StorageDel); |
| lookupResultsTable_add(StorageDel); |
| } else { |
| StorageTmp->lookupCtlRowStatus = old_value; |
| } |
| break; |
| |
| |
| |
| |
| case COMMIT: |
| /* |
| * Things are working well, so it's now safe to make the change |
| * permanently. Make sure that anything done here can't fail! |
| */ |
| if (StorageTmp == NULL) { |
| if (set_value == RS_DESTROY) { |
| return SNMP_ERR_NOERROR; |
| } |
| } |
| |
| if (StorageDel != NULL) { |
| SNMP_FREE(StorageDel->lookupCtlOwnerIndex); |
| StorageDel->lookupCtlOwnerIndex = NULL; |
| SNMP_FREE(StorageDel->lookupCtlOperationName); |
| StorageDel->lookupCtlOperationName = NULL; |
| SNMP_FREE(StorageDel->lookupCtlTargetAddress); |
| StorageDel->lookupCtlTargetAddress = NULL; |
| SNMP_FREE(StorageDel); |
| StorageDel = NULL; |
| |
| StorageDel = 0; |
| /* |
| * XXX: free it, its dead |
| */ |
| } else { |
| if (StorageTmp |
| && StorageTmp->lookupCtlRowStatus == RS_CREATEANDGO) { |
| StorageTmp->lookupCtlRowStatus = RS_ACTIVE; |
| } else if (StorageTmp && |
| StorageTmp->lookupCtlRowStatus == |
| RS_CREATEANDWAIT) { |
| |
| StorageTmp->lookupCtlRowStatus = RS_NOTINSERVICE; |
| } |
| } |
| if (StorageTmp && StorageTmp->lookupCtlRowStatus == RS_ACTIVE) { |
| #if 1 |
| DEBUGMSGTL(("lookupCtlTable", |
| "write_lookupCtlRowStatus entering runbefore=%ld... \n", |
| StorageTmp->lookupCtlTargetAddressType)); |
| |
| #endif |
| modify_lookupCtlOperStatus(StorageTmp, 2l); |
| run_lookup((struct lookupTable_data *) StorageTmp); |
| |
| } |
| |
| break; |
| } |
| return SNMP_ERR_NOERROR; |
| } |
