diff options
Diffstat (limited to 'ext/snmp/winsnmp.c')
| -rw-r--r-- | ext/snmp/winsnmp.c | 249 |
1 files changed, 249 insertions, 0 deletions
diff --git a/ext/snmp/winsnmp.c b/ext/snmp/winsnmp.c new file mode 100644 index 0000000000..331a116e74 --- /dev/null +++ b/ext/snmp/winsnmp.c @@ -0,0 +1,249 @@ +/* +Created from the snmputil sample in the Microsoft SDK for NT +*/ + +#include "php.h" +#if COMPILE_DL +#include "../phpdl.h" +#include "functions/dl.h" +#endif +#include "php_snmp.h" +#include <sys/types.h> + +#include <stdio.h> +#include <string.h> +#include <malloc.h> + +#if HAVE_SNMP + +#include <snmp.h> +#include <mgmtapi.h> + +/* {{{ snmp_functions[] + */ +const zend_function_entry snmp_functions[] = { + {"snmpget", php3_snmpget, NULL}, + {"snmpwalk", php3_snmpwalk, NULL}, + {NULL,NULL,NULL} +}; +/* }}} */ + +/* {{{ snmp_module_entry + */ +zend_module_entry snmp_module_entry = { + STANDARD_MODULE_HEADER, + "SNMP", + snmp_functions, + NULL, + NULL, + NULL, + NULL, + NULL, + NO_VERSION_YET, + STANDARD_MODULE_PROPERTIES +}; +/* }}} */ + +#if COMPILE_DL +DLEXPORT zend_module_entry *get_module() { return &snmp_module_entry; } +#endif + +#define GET 1 +#define WALK 2 +#define GETNEXT 3 + +#define TIMEOUT 6000 /* milliseconds */ +#define RETRIES 3 + +/* {{{ _php_snmp + */ +void _php_snmp(INTERNAL_FUNCTION_PARAMETERS, int st) { + zval *a1, *a2, *a3; + INT operation; + LPSTR agent; + LPSTR community; + RFC1157VarBindList variableBindings; + LPSNMP_MGR_SESSION session; + + INT timeout = TIMEOUT; + INT retries = RETRIES; + + BYTE requestType; + AsnInteger errorStatus; + AsnInteger errorIndex; + AsnObjectIdentifier oid; + char *chkPtr = NULL; + + if (zend_get_parameters_ex(3, &a1, &a2, &a3) == FAILURE) { + WRONG_PARAM_COUNT; + } + convert_to_string_ex(a1); + convert_to_string_ex(a2); + convert_to_string_ex(a3); + + agent=Z_STRVAL_PP(a1); + community=Z_STRVAL_PP(a2); + operation=st; + SnmpMgrStrToOid(Z_STRVAL_PP(a3), &oid); + +/* + I've limited this to only one oid, but we can create a + list of oid's here, and expand the function to take multiple + oid's +*/ + variableBindings.list->name = oid; + variableBindings.list->value.asnType = ASN_NULL; + variableBindings.len = 1; + +/* Establish a SNMP session to communicate with the remote agent. The + community, communications timeout, and communications retry count + for the session are also required. +*/ + if ((session = SnmpMgrOpen(agent, community, timeout, retries)) == NULL){ + php_error_docref(NULL TSRMLS_CC, E_WARNING, "error on SnmpMgrOpen %d", GetLastError()); + } + + /* Determine and perform the requested operation.*/ + if (operation == GET || operation == GETNEXT){ + /* Get and GetNext are relatively simple operations to perform. + Simply initiate the request and process the result and/or + possible error conditions. */ + + if (operation == GET){ + requestType = ASN_RFC1157_GETREQUEST; + } else { + requestType = ASN_RFC1157_GETNEXTREQUEST; + } + + /* Request that the API carry out the desired operation.*/ + if (!SnmpMgrRequest(session, requestType, &variableBindings, + &errorStatus, &errorIndex)){ + /* The API is indicating an error. */ + php_error_docref(NULL TSRMLS_CC, E_WARNING, "error on SnmpMgrRequest %d", GetLastError()); + } else { + /* The API succeeded, errors may be indicated from the remote + agent. */ + if (errorStatus > 0){ + php_error_docref(NULL TSRMLS_CC, E_WARNING, "Error: errorStatus=%d, errorIndex=%d", + errorStatus, errorIndex); + } else { + /* Display the resulting variable bindings.*/ + UINT i; + char *str = NULL; + + for(i=0; i < variableBindings.len; i++) + { + SnmpMgrOidToStr(&variableBindings.list[i].name, &str); + php_printf("Variable = %s\n", str); + if (str) SNMP_free(str); + + php_printf("Value = "); + SnmpUtilPrintAsnAny(&variableBindings.list[i].value); + + php_printf("\n"); + } /* end for() */ + } + } + + /* Free the variable bindings that have been allocated.*/ + SnmpUtilVarBindListFree(&variableBindings); + } + else if (operation == WALK) + { + /* Walk is a common term used to indicate that all MIB variables + under a given OID are to be traversed and displayed. This is + a more complex operation requiring tests and looping in addition + to the steps for get/getnext above. */ + AsnObjectIdentifier root; + AsnObjectIdentifier tempOid; + + SnmpUtilOidCpy(&root, &variableBindings.list[0].name); + requestType = ASN_RFC1157_GETNEXTREQUEST; + + while(1) + { + if (!SnmpMgrRequest(session, requestType, &variableBindings, + &errorStatus, &errorIndex)){ + /* The API is indicating an error.*/ + php_error_docref(NULL TSRMLS_CC, E_WARNING, "error on SnmpMgrRequest %d", GetLastError()); + break; + } + else + { + /* The API succeeded, errors may be indicated from the remote + agent. + Test for end of subtree or end of MIB. */ + if (errorStatus == SNMP_ERRORSTATUS_NOSUCHNAME || + SnmpUtilOidNCmp(&variableBindings.list[0].name, + &root, root.idLength)) + { + PUTS("End of MIB subtree.\n\n"); + break; + } + + /* Test for general error conditions or sucesss. */ + if (errorStatus > 0){ + php_error_docref(NULL TSRMLS_CC, E_ERROR,"Error: errorStatus=%d, errorIndex=%d", errorStatus, errorIndex); + break; + } + else + { + /* Display resulting variable binding for this iteration. */ + char *str = NULL; + + SnmpMgrOidToStr(&variableBindings.list[0].name, &str); + php_printf("Variable = %s\n", str); + if (str) SNMP_free(str); + + php_printf("Value = "); + SnmpUtilPrintAsnAny(&variableBindings.list[0].value); + + php_printf("\n"); + } + } /* end if () */ + /* Prepare for the next iteration. Make sure returned oid is + preserved and the returned value is freed. + */ + SnmpUtilOidCpy(&tempOid, &variableBindings.list[0].name); + SnmpUtilVarBindFree(&variableBindings.list[0]); + SnmpUtilOidCpy(&variableBindings.list[0].name, &tempOid); + variableBindings.list[0].value.asnType = ASN_NULL; + SnmpUtilOidFree(&tempOid); + } /* end while() */ + /* Free the variable bindings that have been allocated.*/ + SnmpUtilVarBindListFree(&variableBindings); + SnmpUtilOidFree(&root); + } /* end if (operation) */ + + + /* Close SNMP session with the remote agent.*/ + if (!SnmpMgrClose(session)){ + php_error_docref(NULL TSRMLS_CC, E_WARNING, "error on SnmpMgrClose %d", GetLastError()); + } +} +/* }}} */ + +/* {{{ php3_snmpget + */ +DLEXPORT void php3_snmpget(INTERNAL_FUNCTION_PARAMETERS) { + _php_snmp(INTERNAL_FUNCTION_PARAM_PASSTHRU,1); +} +/* }}} */ + +/* {{{ php3_snmpwalk + */ +DLEXPORT void php3_snmpwalk(INTERNAL_FUNCTION_PARAMETERS) { + _php_snmp(INTERNAL_FUNCTION_PARAM_PASSTHRU,2); +} +/* }}} */ + +#endif + +/* + * Local variables: + * tab-width: 4 + * c-basic-offset: 4 + * End: + * vim600: sw=4 ts=4 fdm=marker + * vim<600: sw=4 ts=4 + */ |