diff options
author | Ilya Etingof <etingof@gmail.com> | 2019-02-26 08:56:24 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2019-02-26 08:56:24 +0100 |
commit | 3f2f132a9fdf7a48ec6131d5498145dded3cfcad (patch) | |
tree | 63e6170b35f6b392bf2e3d3feb6996b886e4d36f /pysnmp/carrier/asyncore/dispatch.py | |
parent | 2ad26f8bfef0e39b3789d9e6d4fcbf76820c9867 (diff) | |
download | pysnmp-git-3f2f132a9fdf7a48ec6131d5498145dded3cfcad.tar.gz |
PEP-8 long lines and dunders (#245)
This patch massively reformats the whole codebase mainly wrapping
long lines and eliminating dundered private attributes.
Diffstat (limited to 'pysnmp/carrier/asyncore/dispatch.py')
-rw-r--r-- | pysnmp/carrier/asyncore/dispatch.py | 21 |
1 files changed, 13 insertions, 8 deletions
diff --git a/pysnmp/carrier/asyncore/dispatch.py b/pysnmp/carrier/asyncore/dispatch.py index 897fdd0c..3f448471 100644 --- a/pysnmp/carrier/asyncore/dispatch.py +++ b/pysnmp/carrier/asyncore/dispatch.py @@ -16,7 +16,8 @@ from pysnmp.error import PySnmpError class AsyncoreDispatcher(AbstractTransportDispatcher): def __init__(self): - self.__sockMap = {} # use own map for MT safety + # use own map for MT safety + self.__sockMap = {} AbstractTransportDispatcher.__init__(self) def getSocketMap(self): @@ -25,13 +26,14 @@ class AsyncoreDispatcher(AbstractTransportDispatcher): def setSocketMap(self, sockMap=socket_map): self.__sockMap = sockMap - def registerTransport(self, tDomain, t): - AbstractTransportDispatcher.registerTransport(self, tDomain, t) - t.registerSocket(self.__sockMap) + def registerTransport(self, transportDomain, transport): + AbstractTransportDispatcher.registerTransport( + self, transportDomain, transport) + transport.registerSocket(self.__sockMap) - def unregisterTransport(self, tDomain): - self.getTransport(tDomain).unregisterSocket(self.__sockMap) - AbstractTransportDispatcher.unregisterTransport(self, tDomain) + def unregisterTransport(self, transportDomain): + self.getTransport(transportDomain).unregisterSocket(self.__sockMap) + AbstractTransportDispatcher.unregisterTransport(self, transportDomain) def transportsAreWorking(self): for transport in self.__sockMap.values(): @@ -43,9 +45,12 @@ class AsyncoreDispatcher(AbstractTransportDispatcher): try: loop(timeout or self.getTimerResolution(), use_poll=True, map=self.__sockMap, count=1) + except KeyboardInterrupt: raise except Exception: - raise PySnmpError('poll error: %s' % ';'.join(format_exception(*exc_info()))) + raise PySnmpError( + 'poll error: %s' % ';'.join(format_exception(*exc_info()))) + self.handleTimerTick(time()) |