diff options
Diffstat (limited to 'examples/v1arch/asyncore/manager/cmdgen/fetch-scalar-value.py')
| -rw-r--r-- | examples/v1arch/asyncore/manager/cmdgen/fetch-scalar-value.py | 34 |
1 files changed, 18 insertions, 16 deletions
diff --git a/examples/v1arch/asyncore/manager/cmdgen/fetch-scalar-value.py b/examples/v1arch/asyncore/manager/cmdgen/fetch-scalar-value.py index c350f85b..a61b51fa 100644 --- a/examples/v1arch/asyncore/manager/cmdgen/fetch-scalar-value.py +++ b/examples/v1arch/asyncore/manager/cmdgen/fetch-scalar-value.py @@ -22,15 +22,15 @@ from time import time # Protocol version to use pMod = api.protoModules[api.protoVersion1] -#pMod = api.protoModules[api.protoVersion2c] +# 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() @@ -40,6 +40,7 @@ pMod.apiMessage.setPDU(reqMsg, reqPDU) startedAt = time() + def cbTimerFun(timeNow): if timeNow - startedAt > 3: raise Exception("Request timed out") @@ -52,7 +53,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: @@ -63,6 +64,7 @@ def cbRecvFun(transportDispatcher, transportDomain, transportAddress, transportDispatcher.jobFinished(1) return wholeMsg + transportDispatcher = AsyncoreDispatcher() transportDispatcher.registerRecvCbFun(cbRecvFun) @@ -80,26 +82,26 @@ transportDispatcher.sendMessage( transportDispatcher.jobStarted(1) ## UDP/IPv6 (second copy of the same PDU will be sent) -#transportDispatcher.registerTransport( +# transportDispatcher.registerTransport( # udp6.domainName, udp6.Udp6SocketTransport().openClientMode() -#) +# ) # Pass message to dispatcher -#transportDispatcher.sendMessage( +# transportDispatcher.sendMessage( # encoder.encode(reqMsg), udp6.domainName, ('::1', 161) -#) -#transportDispatcher.jobStarted(1) +# ) +# transportDispatcher.jobStarted(1) ## Local domain socket -#transportDispatcher.registerTransport( +# transportDispatcher.registerTransport( # unix.domainName, unix.UnixSocketTransport().openClientMode() -#) +# ) # # Pass message to dispatcher -#transportDispatcher.sendMessage( +# transportDispatcher.sendMessage( # encoder.encode(reqMsg), unix.domainName, '/tmp/snmp-agent' -#) -#transportDispatcher.jobStarted(1) +# ) +# transportDispatcher.jobStarted(1) # Dispatcher will finish as job#1 counter reaches zero transportDispatcher.runDispatcher() |