summaryrefslogtreecommitdiff
path: root/examples/v1arch/asyncore/manager/cmdgen/getnext-pull-whole-mib.py
diff options
context:
space:
mode:
Diffstat (limited to 'examples/v1arch/asyncore/manager/cmdgen/getnext-pull-whole-mib.py')
-rw-r--r--examples/v1arch/asyncore/manager/cmdgen/getnext-pull-whole-mib.py3
1 files changed, 3 insertions, 0 deletions
diff --git a/examples/v1arch/asyncore/manager/cmdgen/getnext-pull-whole-mib.py b/examples/v1arch/asyncore/manager/cmdgen/getnext-pull-whole-mib.py
index c18b356a..b6216207 100644
--- a/examples/v1arch/asyncore/manager/cmdgen/getnext-pull-whole-mib.py
+++ b/examples/v1arch/asyncore/manager/cmdgen/getnext-pull-whole-mib.py
@@ -49,6 +49,7 @@ def cbTimerFun(timeNow):
# noinspection PyUnusedLocal
def cbRecvFun(transportDispatcher, transportDomain, transportAddress,
wholeMsg, reqPDU=reqPDU, headVars=headVars):
+
while wholeMsg:
rspMsg, wholeMsg = decoder.decode(wholeMsg, asn1Spec=pMod.Message())
rspPDU = pMod.apiMessage.getPDU(rspMsg)
@@ -73,6 +74,7 @@ def cbRecvFun(transportDispatcher, transportDomain, transportAddress,
break
else:
transportDispatcher.jobFinished(1)
+ continue
# Generate request for next row
pMod.apiPDU.setVarBinds(
@@ -86,6 +88,7 @@ def cbRecvFun(transportDispatcher, transportDomain, transportAddress,
if time() - startedAt > 3:
raise Exception('Request timed out')
startedAt = time()
+
return wholeMsg