diff options
| author | elie <elie> | 2005-10-05 10:22:18 +0000 |
|---|---|---|
| committer | elie <elie> | 2005-10-05 10:22:18 +0000 |
| commit | ac69c79ec7f2e61437f5d9381462d9028a20bc6d (patch) | |
| tree | 0c6ada65d4afb12b30722e6eea79ae2ffaeff19d /examples/v1arch/asyncore | |
| parent | 4a199692152427dcac5775948696770dcb72c566 (diff) | |
| download | pysnmp-git-ac69c79ec7f2e61437f5d9381462d9028a20bc6d.tar.gz | |
make use of transport dispatcher job control
Diffstat (limited to 'examples/v1arch/asyncore')
4 files changed, 10 insertions, 3 deletions
diff --git a/examples/v1arch/asyncore/agent/cmdrsp/implementing-scalar-mib-objects.py b/examples/v1arch/asyncore/agent/cmdrsp/implementing-scalar-mib-objects.py index 1b14162f..e0031b1a 100644 --- a/examples/v1arch/asyncore/agent/cmdrsp/implementing-scalar-mib-objects.py +++ b/examples/v1arch/asyncore/agent/cmdrsp/implementing-scalar-mib-objects.py @@ -82,4 +82,5 @@ transportDispatcher.registerTransport( udp.domainName, udp.UdpSocketTransport().openServerMode(('localhost', 161)) ) transportDispatcher.registerRecvCbFun(cbFun) +transportDispatcher.jobStarted(1) # this job would never finish transportDispatcher.runDispatcher() diff --git a/examples/v1arch/asyncore/manager/cmdgen/fetch-scalar-value.py b/examples/v1arch/asyncore/manager/cmdgen/fetch-scalar-value.py index 92605778..9f8f4eea 100644 --- a/examples/v1arch/asyncore/manager/cmdgen/fetch-scalar-value.py +++ b/examples/v1arch/asyncore/manager/cmdgen/fetch-scalar-value.py @@ -40,7 +40,7 @@ def cbRecvFun(transportDispatcher, transportDomain, transportAddress, else: for oid, val in pMod.apiPDU.getVarBinds(rspPDU): print oid, val - transportDispatcher.stopDispatcher() + transportDispatcher.jobFinished(1) return wholeMsg transportDispatcher = AsynsockDispatcher() @@ -52,4 +52,6 @@ transportDispatcher.registerTimerCbFun(cbTimerFun) transportDispatcher.sendMessage( encoder.encode(reqMsg), udp.domainName, ('localhost', 161) ) +transportDispatcher.jobStarted(1) transportDispatcher.runDispatcher() +transportDispatcher.closeDispatcher() 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 846ee402..132d6017 100644 --- a/examples/v1arch/asyncore/manager/cmdgen/getnext-pull-whole-mib.py +++ b/examples/v1arch/asyncore/manager/cmdgen/getnext-pull-whole-mib.py @@ -54,7 +54,7 @@ def cbRecvFun(transportDispatcher, transportDomain, transportAddress, if val is not None: break else: - transportDispatcher.stopDispatcher() + transportDispatcher.jobFinished(1) # Generate request for next row pMod.apiPDU.setVarBinds( @@ -79,4 +79,6 @@ transportDispatcher.registerTimerCbFun(cbTimerFun) transportDispatcher.sendMessage( encoder.encode(reqMsg), udp.domainName, ('localhost', 161) ) +transportDispatcher.jobStarted(1) transportDispatcher.runDispatcher() +transportDispatcher.closeDispatcher() diff --git a/examples/v1arch/asyncore/manager/cmdgen/v2c-set.py b/examples/v1arch/asyncore/manager/cmdgen/v2c-set.py index bbc95063..7ba69cbd 100644 --- a/examples/v1arch/asyncore/manager/cmdgen/v2c-set.py +++ b/examples/v1arch/asyncore/manager/cmdgen/v2c-set.py @@ -42,7 +42,7 @@ def cbRecvFun(transportDispatcher, transportDomain, transportAddress, else: for oid, val in pMod.apiPDU.getVarBinds(rspPDU): print oid, val - transportDispatcher.stopDispatcher() + transportDispatcher.jobFinished(1) return wholeMsg transportDispatcher = AsynsockDispatcher() @@ -54,4 +54,6 @@ transportDispatcher.registerTimerCbFun(cbTimerFun) transportDispatcher.sendMessage( encoder.encode(reqMsg), udp.domainName, ('localhost', 161) ) +transportDispatcher.jobStarted(1) transportDispatcher.runDispatcher() +transportDispatcher.closeDispatcher() |