Sign Up
Log In
Log In
or
Sign Up
Places
All Projects
Status Monitor
Collapse sidebar
openSUSE:Leap:15.5:Update
net-snmp.22256
net-snmp-5.7.3-subagent-set-response.patch
Overview
Repositories
Revisions
Requests
Users
Attributes
Meta
File net-snmp-5.7.3-subagent-set-response.patch of Package net-snmp.22256
diff --git a/agent/mibgroup/agentx/subagent.c b/agent/mibgroup/agentx/subagent.c index b3da321..713b022 100644 --- a/agent/mibgroup/agentx/subagent.c +++ b/agent/mibgroup/agentx/subagent.c @@ -78,6 +78,7 @@ typedef struct _net_snmpsubagent_magic_s { struct agent_netsnmp_set_info { int transID; int mode; + int req_pending; int errstat; time_t uptime; netsnmp_session *sess; @@ -190,6 +191,7 @@ save_set_vars(netsnmp_session * ss, netsnmp_pdu *pdu) ptr->sess = ss; ptr->mode = SNMP_MSG_INTERNAL_SET_RESERVE1; ptr->uptime = netsnmp_get_agent_uptime(); + ptr->req_pending = 0; ptr->var_list = snmp_clone_varbind(pdu->variables); if (ptr->var_list == NULL) { @@ -204,6 +206,18 @@ save_set_vars(netsnmp_session * ss, netsnmp_pdu *pdu) } struct agent_netsnmp_set_info * +pending_trans_set_info(netsnmp_session * sess, netsnmp_pdu *pdu) +{ + struct agent_netsnmp_set_info *ptr; + + for (ptr = Sets; ptr != NULL; ptr = ptr->next) + if (ptr->sess == sess && ptr->transID == pdu->transid) + break; + + return ptr; +} + +struct agent_netsnmp_set_info * restore_set_vars(netsnmp_session * sess, netsnmp_pdu *pdu) { struct agent_netsnmp_set_info *ptr; @@ -411,6 +425,14 @@ handle_agentx_packet(int operation, netsnmp_session * session, int reqid, * XXXWWW we have to map this twice to both RESERVE1 and RESERVE2 */ DEBUGMSGTL(("agentx/subagent", " -> testset\n")); + asi = pending_trans_set_info(session, pdu); + if (asi) { + DEBUGMSGTL(("agentx/subagent", + "dropping testset retry for transid 0x%x in mode %d\n", + (unsigned)pdu->transid, asi->mode)); + //SNMP_FREE(retmagic); XXX necessary? + return 1; + } asi = save_set_vars(session, pdu); if (asi == NULL) { SNMP_FREE(smagic); @@ -432,6 +454,13 @@ handle_agentx_packet(int operation, netsnmp_session * session, int reqid, send_agentx_error(session, pdu, AGENTX_ERR_PROCESSING_ERROR, 0); return 1; } + if (asi->req_pending) { + DEBUGMSGTL(("agentx/subagent", + "dropping commitset - request pending for transid 0x%x in mode %d\n", + (unsigned)pdu->transid, asi->mode)); + //SNMP_FREE(retmagic); XXX necessary? + return 1; + } if (asi->mode != SNMP_MSG_INTERNAL_SET_RESERVE2) { SNMP_FREE(smagic); snmp_log(LOG_WARNING, @@ -454,6 +483,13 @@ handle_agentx_packet(int operation, netsnmp_session * session, int reqid, send_agentx_error(session, pdu, AGENTX_ERR_PROCESSING_ERROR, 0); return 1; } + if (asi->req_pending) { + DEBUGMSGTL(("agentx/subagent", + "dropping cleanupset - request pending for transid 0x%x in mode %d\n", + (unsigned)pdu->transid, asi->mode)); + //SNMP_FREE(retmagic); XXX necessary? + return 1; + } if (asi->mode == SNMP_MSG_INTERNAL_SET_RESERVE1 || asi->mode == SNMP_MSG_INTERNAL_SET_RESERVE2) { asi->mode = pdu->command = SNMP_MSG_INTERNAL_SET_FREE; @@ -479,6 +515,13 @@ handle_agentx_packet(int operation, netsnmp_session * session, int reqid, send_agentx_error(session, pdu, AGENTX_ERR_PROCESSING_ERROR, 0); return 1; } + if (asi->req_pending) { + DEBUGMSGTL(("agentx/subagent", + "dropping undoset - request pending for transid 0x%x in mode %d\n", + (unsigned)pdu->transid, asi->mode)); + //SNMP_FREE(retmagic); XXX necessary? + return 1; + } asi->mode = pdu->command = SNMP_MSG_INTERNAL_SET_UNDO; mycallback = handle_subagent_set_response; retmagic = asi; @@ -511,6 +554,8 @@ handle_agentx_packet(int operation, netsnmp_session * session, int reqid, retmagic); if (result == 0) { snmp_free_pdu( internal_pdu ); + } else if (asi) { + asi->req_pending = 1; } return 1; } @@ -630,6 +675,7 @@ handle_subagent_set_response(int op, netsnmp_session * session, int reqid, { netsnmp_session *retsess; struct agent_netsnmp_set_info *asi; + int new_mode; int result; if (op != NETSNMP_CALLBACK_OP_RECEIVED_MESSAGE || magic == NULL) { @@ -638,13 +684,61 @@ handle_subagent_set_response(int op, netsnmp_session * session, int reqid, DEBUGMSGTL(("agentx/subagent", "handling agentx subagent set response (mode=%d,req=0x%x," - "trans=0x%x,sess=0x%x)\n", + "trans=0x%x,sess=0x%x,magic=%p)\n", (unsigned)pdu->command, (unsigned)pdu->reqid, - (unsigned)pdu->transid, (unsigned)pdu->sessid)); + (unsigned)pdu->transid, (unsigned)pdu->sessid, + magic)); + pdu = snmp_clone_pdu(pdu); asi = (struct agent_netsnmp_set_info *) magic; + + DEBUGMSGTL(("agentx/subagent", + "set response in mode %d (errstat %d, req_pending %d)\n", + asi->mode, pdu->errstat, asi->req_pending)); + + asi->req_pending = 0; retsess = asi->sess; + + if (!snmp_sess_pointer(retsess) || retsess->sessid != pdu->sessid) { + DEBUGMSGTL(("agentx/subagent", + "session id 0x%x gone for set response (transid 0x%x, reqid 0x%x)\n", + (unsigned)pdu->sessid, (unsigned)pdu->transid, (unsigned)pdu->reqid)); + + result = 0; + + if (!pdu->errstat) { + switch (asi->mode) { + case SNMP_MSG_INTERNAL_SET_RESERVE1: + case SNMP_MSG_INTERNAL_SET_RESERVE2: + new_mode = SNMP_MSG_INTERNAL_SET_FREE; + break; + + case SNMP_MSG_INTERNAL_SET_ACTION: + new_mode = SNMP_MSG_INTERNAL_SET_UNDO; + break; + + default: + new_mode = 0; + } + + if (new_mode) { + asi->mode = pdu->command = new_mode; + result = snmp_async_send(agentx_callback_sess, pdu, + handle_subagent_set_response, asi); + } + } + + if (result == 0) { + /* don't need to (or cannot) FREE/UNDO */ + free_set_vars(retsess, pdu); + snmp_free_pdu(pdu); + } else { + asi->req_pending = 1; + } + return 1; + } + asi->errstat = pdu->errstat; if (asi->mode == SNMP_MSG_INTERNAL_SET_RESERVE1) { @@ -660,6 +754,8 @@ handle_subagent_set_response(int op, netsnmp_session * session, int reqid, handle_subagent_set_response, asi); if (result == 0) { snmp_free_pdu( pdu ); + } else { + asi->req_pending = 1; } DEBUGMSGTL(("agentx/subagent", " going from RESERVE1 -> RESERVE2\n"));
Locations
Projects
Search
Status Monitor
Help
OpenBuildService.org
Documentation
API Documentation
Code of Conduct
Contact
Support
@OBShq
Terms
openSUSE Build Service is sponsored by
The Open Build Service is an
openSUSE project
.
Sign Up
Log In
Places
Places
All Projects
Status Monitor
