make use of transport dispatcher job control

4 files changed, 10 insertions, 3 deletions

diff --git a/examples/v1arch/agent/cmdrsp.py b/examples/v1arch/agent/cmdrsp.py
index 1b14162..e0031b1 100644
--- a/examples/v1arch/agent/cmdrsp.py
+++ b/examples/v1arch/agent/cmdrsp.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/manager/getgen.py b/examples/v1arch/manager/getgen.py
index 9260577..9f8f4ee 100644
--- a/examples/v1arch/manager/getgen.py
+++ b/examples/v1arch/manager/getgen.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/manager/nextgen.py b/examples/v1arch/manager/nextgen.py
index 846ee40..132d601 100644
--- a/examples/v1arch/manager/nextgen.py
+++ b/examples/v1arch/manager/nextgen.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/manager/setgen.py b/examples/v1arch/manager/setgen.py
index bbc9506..7ba69cb 100644
--- a/examples/v1arch/manager/setgen.py
+++ b/examples/v1arch/manager/setgen.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()