diff options
Diffstat (limited to 'examples/v1arch/asyncore/manager/cmdgen/spoof-source-address.py')
| -rw-r--r-- | examples/v1arch/asyncore/manager/cmdgen/spoof-source-address.py | 15 |
1 files changed, 9 insertions, 6 deletions
diff --git a/examples/v1arch/asyncore/manager/cmdgen/spoof-source-address.py b/examples/v1arch/asyncore/manager/cmdgen/spoof-source-address.py index 332bb8d2..929ff771 100644 --- a/examples/v1arch/asyncore/manager/cmdgen/spoof-source-address.py +++ b/examples/v1arch/asyncore/manager/cmdgen/spoof-source-address.py @@ -41,16 +41,16 @@ transportAddress = udp.UdpTransportAddress(('195.218.195.228', 161)) transportAddress.setLocalAddress(('1.2.3.4', 0)) # Protocol version to use -#pMod = api.protoModules[api.protoVersion1] +# pMod = api.protoModules[api.protoVersion1] pMod = api.protoModules[api.protoVersion2c] # Build PDU -reqPDU = pMod.GetRequestPDU() +reqPDU = pMod.GetRequestPDU() pMod.apiPDU.setDefaults(reqPDU) pMod.apiPDU.setVarBinds( - reqPDU, ( ('1.3.6.1.2.1.1.1.0', pMod.Null('')), - ('1.3.6.1.2.1.1.3.0', pMod.Null('')) ) - ) + reqPDU, (('1.3.6.1.2.1.1.1.0', pMod.Null('')), + ('1.3.6.1.2.1.1.3.0', pMod.Null(''))) +) # Build message reqMsg = pMod.Message() @@ -60,8 +60,10 @@ pMod.apiMessage.setPDU(reqMsg, reqPDU) startedAt = time() + class StopWaiting(Exception): pass + def cbTimerFun(timeNow): if timeNow - startedAt > 3: raise StopWaiting() @@ -74,7 +76,7 @@ def cbRecvFun(transportDispatcher, transportDomain, transportAddress, rspMsg, wholeMsg = decoder.decode(wholeMsg, asn1Spec=pMod.Message()) rspPDU = pMod.apiMessage.getPDU(rspMsg) # Match response to request - if pMod.apiPDU.getRequestID(reqPDU)==pMod.apiPDU.getRequestID(rspPDU): + if pMod.apiPDU.getRequestID(reqPDU) == pMod.apiPDU.getRequestID(rspPDU): # Check for SNMP errors reported errorStatus = pMod.apiPDU.getErrorStatus(rspPDU) if errorStatus: @@ -85,6 +87,7 @@ def cbRecvFun(transportDispatcher, transportDomain, transportAddress, transportDispatcher.jobFinished(1) return wholeMsg + transportDispatcher = AsyncoreDispatcher() transportDispatcher.registerRecvCbFun(cbRecvFun) |