2
#if defined(_WIN32) && !defined(_WIN32_WINNT)
3
#define _WIN32_WINNT 0x501
12
#include <net-snmp/net-snmp-config.h>
13
#include <net-snmp/net-snmp-includes.h>
14
#include <net-snmp/agent/net-snmp-agent-includes.h>
16
#include "perl_snmptrapd.h"
18
#include "const-c.inc"
20
typedef struct trapd_cb_data_s {
24
typedef struct netsnmp_oid_s {
27
oid namebuf[ MAX_OID_LEN ];
30
int perl_trapd_handler( netsnmp_pdu *pdu,
31
netsnmp_transport *transport,
32
netsnmp_trapd_handler *handler)
34
trapd_cb_data *cb_data;
36
netsnmp_variable_list *vb;
41
size_t ob_len = 0, oo_len = 0;
45
int callingCFfailed = 0;
46
int result = NETSNMPTRAPD_HANDLER_OK;
47
netsnmp_pdu * v2pdu = NULL;
57
if (pdu->command == SNMP_MSG_TRAP) {
58
v2pdu = convert_v1pdu_to_v2(pdu);
62
cb_data = handler->handler_data;
63
if (!cb_data || !cb_data->perl_cb)
66
pcallback = cb_data->perl_cb;
68
/* get PDU related info */
70
#define STOREPDU(n, v) (void)hv_store(pduinfo, n, strlen(n), v, 0)
71
#define STOREPDUi(n, v) STOREPDU(n, newSViv(v))
72
#define STOREPDUs(n, v) STOREPDU(n, newSVpv(v, 0))
73
STOREPDUi("version", pdu->version);
74
STOREPDUs("notificationtype", ((pdu->command == SNMP_MSG_INFORM) ? "INFORM":"TRAP"));
75
STOREPDUi("requestid", pdu->reqid);
76
STOREPDUi("messageid", pdu->msgid);
77
STOREPDUi("transactionid", pdu->transid);
78
STOREPDUi("errorstatus", pdu->errstat);
79
STOREPDUi("errorindex", pdu->errindex);
80
if (pdu->version == 3) {
81
STOREPDUi("securitymodel", pdu->securityModel);
82
STOREPDUi("securitylevel", pdu->securityLevel);
83
STOREPDU("contextName",
84
newSVpv(pdu->contextName, pdu->contextNameLen));
85
STOREPDU("contextEngineID",
86
newSVpv((char *) pdu->contextEngineID,
87
pdu->contextEngineIDLen));
88
STOREPDU("securityEngineID",
89
newSVpv((char *) pdu->securityEngineID,
90
pdu->securityEngineIDLen));
91
STOREPDU("securityName",
92
newSVpv((char *) pdu->securityName, pdu->securityNameLen));
95
newSVpv((char *) pdu->community, pdu->community_len));
98
if (transport && transport->f_fmtaddr) {
99
char *tstr = transport->f_fmtaddr(transport, pdu->transport_data,
100
pdu->transport_data_length);
101
STOREPDUs("receivedfrom", tstr);
107
* collect OID objects in a temp array first
109
/* get VARBIND related info */
110
i = count_varbinds(pdu->variables);
111
tmparray = malloc(sizeof(*tmparray) * i);
113
for(vb = pdu->variables; vb; vb = vb->next_variable) {
116
o = malloc(sizeof(netsnmp_oid));
117
o->name = o->namebuf;
118
o->len = vb->name_length;
119
memcpy(o->name, vb->name, vb->name_length * sizeof(oid));
121
#undef CALL_EXTERNAL_OID_NEW
123
#ifdef CALL_EXTERNAL_OID_NEW
130
rarg = sv_2mortal(newSViv((IV) 0));
131
arg = sv_2mortal(newSVrv(rarg, "netsnmp_oidPtr"));
132
sv_setiv(arg, (IV) o);
136
i = perl_call_pv("NetSNMP::OID::newwithptr", G_SCALAR);
140
snmp_log(LOG_ERR, "unhandled OID error.\n");
144
tmparray[c++] = POPs;
145
SvREFCNT_inc(tmparray[c-1]);
148
#else /* build it and bless ourselves */
151
SV *rv = newRV_noinc((SV *) hv);
152
SV *rvsub = newRV_noinc((SV *) newSViv((UV) o));
153
rvsub = sv_bless(rvsub, gv_stashpv("netsnmp_oidPtr", 1));
154
(void)hv_store(hv, "oidptr", 6, rvsub, 0);
155
rv = sv_bless(rv, gv_stashpv("NetSNMP::OID", 1));
159
#endif /* build oid ourselves */
163
* build the varbind lists
166
for(vb = pdu->variables, i = 0; vb; vb = vb->next_variable, i++) {
176
sprint_realloc_by_type(&outbuf, &ob_len, &oo_len, 1,
179
av_push(vba,tmparray[i]);
180
av_push(vba,newSVpvn((char *) outbuf, oo_len));
181
netsnmp_free(outbuf);
182
av_push(vba,newSViv(vb->type));
183
av_push(varbinds, (SV *) newRV_noinc((SV *) vba));
188
/* store the collected information on the stack */
189
XPUSHs(sv_2mortal(newRV_noinc((SV*) pduinfo)));
190
XPUSHs(sv_2mortal(newRV_noinc((SV*) varbinds)));
192
/* put the stack back in order */
195
/* actually call the callback function */
196
if (SvTYPE(pcallback) == SVt_PVCV) {
197
noValuesReturned = perl_call_sv(pcallback, G_SCALAR);
198
/* XXX: it discards the results, which isn't right */
199
} else if (SvROK(pcallback) && SvTYPE(SvRV(pcallback)) == SVt_PVCV) {
200
/* reference to code */
201
noValuesReturned = perl_call_sv(SvRV(pcallback), G_SCALAR);
203
snmp_log(LOG_ERR, " tried to call a perl function but failed to understand its type: (ref = %p, svrok: %lu, SVTYPE: %lu)\n", pcallback, (unsigned long)SvROK(pcallback), (unsigned long)SvTYPE(pcallback));
207
if (!callingCFfailed) {
210
if ( noValuesReturned == 0 ) {
211
snmp_log(LOG_WARNING, " perl callback function %p did not return a scalar, assuming %d (NETSNMPTRAPD_HANDLER_OK)\n", pcallback, NETSNMPTRAPD_HANDLER_OK);
216
if (SvTYPE(rv) != SVt_IV) {
217
snmp_log(LOG_WARNING, " perl callback function %p returned a scalar of type %lu instead of an integer, assuming %d (NETSNMPTRAPD_HANDLER_OK)\n", pcallback, (unsigned long)SvTYPE(rv), NETSNMPTRAPD_HANDLER_OK);
220
int rvi = (IV)SvIVx(rv);
222
if ((NETSNMPTRAPD_HANDLER_OK <= rvi) && (rvi <= NETSNMPTRAPD_HANDLER_FINISH)) {
223
snmp_log(LOG_DEBUG, " perl callback function %p returns %d\n", pcallback, rvi);
227
snmp_log(LOG_WARNING, " perl callback function %p returned an invalid scalar integer value (%d), assuming %d (NETSNMPTRAPD_HANDLER_OK)\n", pcallback, rvi, NETSNMPTRAPD_HANDLER_OK);
236
fprintf(stderr, "DUMPDUMPDUMPDUMPDUMPDUMP\n");
238
fprintf(stderr, "--------------------\n");
242
/* svREFCNT_dec((SV *) pduinfo); */
246
while(vba = av_pop(varbinds)) {
247
av_undef((AV *) vba);
255
snmp_free_pdu(v2pdu);
263
MODULE = NetSNMP::TrapReceiver PACKAGE = NetSNMP::TrapReceiver
265
INCLUDE: const-xs.inc
267
MODULE = NetSNMP::TrapReceiver PACKAGE = NetSNMP::TrapReceiver PREFIX=trapd_
269
trapd_register(regoid, perlcallback)
273
oid myoid[MAX_OID_LEN];
274
size_t myoid_len = MAX_OID_LEN;
275
trapd_cb_data *cb_data;
276
netsnmp_trapd_handler *handler = NULL;
279
if (!regoid || !perlcallback) {
283
if (strcmp(regoid,"all") == 0) {
285
netsnmp_add_global_traphandler(NETSNMPTRAPD_POST_HANDLER,
287
} else if (strcmp(regoid,"default") == 0) {
289
netsnmp_add_default_traphandler(perl_trapd_handler);
290
} else if (!snmp_parse_oid(regoid, myoid, &myoid_len)) {
292
"Failed to parse oid for perl registration: %s\n",
298
netsnmp_add_traphandler(perl_trapd_handler,
303
cb_data = malloc(sizeof(trapd_cb_data));
304
cb_data->perl_cb = newSVsv(perlcallback);
305
handler->handler_data = cb_data;
306
handler->authtypes = (1 << VACM_VIEW_EXECUTE);