diff options
Diffstat (limited to 'examples/v3arch/asyncore/proxy/command/v3-to-v2c-conversion.py')
| -rw-r--r-- | examples/v3arch/asyncore/proxy/command/v3-to-v2c-conversion.py | 22 |
1 files changed, 11 insertions, 11 deletions
diff --git a/examples/v3arch/asyncore/proxy/command/v3-to-v2c-conversion.py b/examples/v3arch/asyncore/proxy/command/v3-to-v2c-conversion.py index 8247e45e..2cc397c7 100644 --- a/examples/v3arch/asyncore/proxy/command/v3-to-v2c-conversion.py +++ b/examples/v3arch/asyncore/proxy/command/v3-to-v2c-conversion.py @@ -82,20 +82,21 @@ config.addTargetParams(snmpEngine, 'distant-agent-auth', 'my-area', 'noAuthNoPriv', 0) config.addTargetAddr( - snmpEngine, 'distant-agent', - udp.domainName + (2,), ('195.218.195.228', 161), - 'distant-agent-auth', retryCount=0 + snmpEngine, 'distant-agent', + udp.domainName + (2,), ('195.218.195.228', 161), + 'distant-agent-auth', retryCount=0 ) # Default SNMP context config.addContext(snmpEngine, '') + class CommandResponder(cmdrsp.CommandResponderBase): - cmdGenMap = { + cmdGenMap = { v2c.GetRequestPDU.tagSet: cmdgen.GetCommandGenerator(), v2c.SetRequestPDU.tagSet: cmdgen.SetCommandGenerator(), v2c.GetNextRequestPDU.tagSet: cmdgen.NextCommandGeneratorSingleRun(), - v2c.GetBulkRequestPDU.tagSet: cmdgen.BulkCommandGeneratorSingleRun() + v2c.GetBulkRequestPDU.tagSet: cmdgen.BulkCommandGeneratorSingleRun() } pduTypes = cmdGenMap.keys() # This app will handle these PDUs @@ -106,14 +107,14 @@ class CommandResponder(cmdrsp.CommandResponderBase): contextEngineId = None # address authoritative SNMP Engine try: self.cmdGenMap[PDU.tagSet].sendPdu( - snmpEngine, 'distant-agent', + snmpEngine, 'distant-agent', contextEngineId, contextName, PDU, self.handleResponsePdu, cbCtx ) except error.PySnmpError: self.handleResponsePdu( - stateReference, 'error', None, cbCtx + snmpEngine, stateReference, 'error', None, cbCtx ) # SNMP response relay @@ -126,15 +127,14 @@ class CommandResponder(cmdrsp.CommandResponderBase): PDU = v2c.apiPDU.getResponse(reqPDU) PDU.setErrorStatus(PDU, 5) - self.sendPdu( - snmpEngine, stateReference, PDU - ) + self.sendPdu(snmpEngine, stateReference, PDU) self.releaseStateInformation(stateReference) + CommandResponder(snmpEngine, context.SnmpContext(snmpEngine)) -snmpEngine.transportDispatcher.jobStarted(1) # this job would never finish +snmpEngine.transportDispatcher.jobStarted(1) # this job would never finish # Run I/O dispatcher which would receive queries and send responses try: |