diff options
| author | elie <elie> | 2005-06-23 22:30:33 +0000 |
|---|---|---|
| committer | elie <elie> | 2005-06-23 22:30:33 +0000 |
| commit | 37790b3f72cb2fafd5345bce38d82b2a8154e7ee (patch) | |
| tree | 9457e73b4ed645f00bfb8f2a5540481629afe6d2 | |
| parent | 3c44a28be54bf738493ae057bdfd2c9f615a7762 (diff) | |
| download | pysnmp-37790b3f72cb2fafd5345bce38d82b2a8154e7ee.tar.gz | |
stopDispatcher() implemented
| -rw-r--r-- | pysnmp/carrier/asynsock/dispatch.py | 4 | ||||
| -rw-r--r-- | pysnmp/carrier/base.py | 5 |
2 files changed, 6 insertions, 3 deletions
diff --git a/pysnmp/carrier/asynsock/dispatch.py b/pysnmp/carrier/asynsock/dispatch.py index 81fbc01..1d88ed1 100644 --- a/pysnmp/carrier/asynsock/dispatch.py +++ b/pysnmp/carrier/asynsock/dispatch.py @@ -46,11 +46,11 @@ class AsynsockDispatcher(base.AbstractTransportDispatcher): base.AbstractTransportDispatcher.unregisterTransports(self, tDomain) def runDispatcher(self, liveForever=1): - self.doDispatchFlag = liveForever + self._doDispatchFlag = liveForever while 1: poll(self.timeout, self.__sockMap) self.handleTimerTick(time()) - if not self.doDispatchFlag: + if not self._doDispatchFlag: break # XXX doDispatchFlag is needed? diff --git a/pysnmp/carrier/base.py b/pysnmp/carrier/base.py index 71d8880..36a62b9 100644 --- a/pysnmp/carrier/base.py +++ b/pysnmp/carrier/base.py @@ -3,7 +3,7 @@ from pysnmp.carrier import error class AbstractTransportDispatcher: def __init__(self): - self.doDispatchFlag = 1 + self._doDispatchFlag = 1 self.__transports = {} self.__recvCbFun = self.__timerCbFun = None @@ -82,6 +82,9 @@ class AbstractTransportDispatcher: def runDispatcher(self, timeout=0.0): raise error.CarrierError('Method not implemented') + def stopDispatcher(self): + self._doDispatchFlag = 0 + def closeDispatcher(self): self.closeTransports() for tDomain in self.__transports.keys(): |