summaryrefslogtreecommitdiff
path: root/examples/v1arch/asyncore/manager/cmdgen/v2c-set.py
diff options
context:
space:
mode:
Diffstat (limited to 'examples/v1arch/asyncore/manager/cmdgen/v2c-set.py')
-rw-r--r--examples/v1arch/asyncore/manager/cmdgen/v2c-set.py14
1 files changed, 8 insertions, 6 deletions
diff --git a/examples/v1arch/asyncore/manager/cmdgen/v2c-set.py b/examples/v1arch/asyncore/manager/cmdgen/v2c-set.py
index 5c8c8318..08e277a1 100644
--- a/examples/v1arch/asyncore/manager/cmdgen/v2c-set.py
+++ b/examples/v1arch/asyncore/manager/cmdgen/v2c-set.py
@@ -21,18 +21,18 @@ from pysnmp.proto import api
from time import time
# Protocol version to use
-#pMod = api.protoModules[api.protoVersion1]
+# pMod = api.protoModules[api.protoVersion1]
pMod = api.protoModules[api.protoVersion2c]
# Build PDU
-reqPDU = pMod.SetRequestPDU()
+reqPDU = pMod.SetRequestPDU()
pMod.apiPDU.setDefaults(reqPDU)
pMod.apiPDU.setVarBinds(
reqPDU,
# A list of Var-Binds to SET
- ( ('1.3.6.1.2.1.1.9.1.3.1', pMod.OctetString('New system description')),
- ('1.3.6.1.2.1.1.9.1.4.1', pMod.TimeTicks(12)) )
- )
+ (('1.3.6.1.2.1.1.9.1.3.1', pMod.OctetString('New system description')),
+ ('1.3.6.1.2.1.1.9.1.4.1', pMod.TimeTicks(12)))
+)
# Build message
reqMsg = pMod.Message()
@@ -42,6 +42,7 @@ pMod.apiMessage.setPDU(reqMsg, reqPDU)
startedAt = time()
+
def cbTimerFun(timeNow):
if timeNow - startedAt > 3:
raise Exception("Request timed out")
@@ -54,7 +55,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:
@@ -65,6 +66,7 @@ def cbRecvFun(transportDispatcher, transportDomain, transportAddress,
transportDispatcher.jobFinished(1)
return wholeMsg
+
transportDispatcher = AsyncoreDispatcher()
transportDispatcher.registerRecvCbFun(cbRecvFun)