diff options
Diffstat (limited to 'pysnmp/carrier')
-rw-r--r-- | pysnmp/carrier/asyncore/dgram/base.py | 4 | ||||
-rw-r--r-- | pysnmp/carrier/twisted/dispatch.py | 8 |
2 files changed, 6 insertions, 6 deletions
diff --git a/pysnmp/carrier/asyncore/dgram/base.py b/pysnmp/carrier/asyncore/dgram/base.py index 14ab8723..7f9578e0 100644 --- a/pysnmp/carrier/asyncore/dgram/base.py +++ b/pysnmp/carrier/asyncore/dgram/base.py @@ -23,7 +23,7 @@ class DgramSocketTransport(AbstractSocketTransport): addressType = lambda x: x def __init__(self, sock=None, sockMap=None): self.__outQueue = [] - self._sendto = lambda s,b,a: s.sendto(b, a) + self._sendto = lambda s, b, a: s.sendto(b, a) def __recvfrom(s, sz): d, a = s.recvfrom(sz) return d, self.addressType(a) @@ -61,7 +61,7 @@ class DgramSocketTransport(AbstractSocketTransport): raise error.CarrierError('sendmsg()/recvmsg() interface is not supported by this OS and/or Python version') try: - if self.socket.family in (socket.AF_INET,socket.AF_INET6): + if self.socket.family in (socket.AF_INET, socket.AF_INET6): self.socket.setsockopt(socket.SOL_IP, socket.IP_PKTINFO, flag) if self.socket.family == socket.AF_INET6: self.socket.setsockopt(socket.SOL_IPV6, socket.IPV6_RECVPKTINFO, flag) diff --git a/pysnmp/carrier/twisted/dispatch.py b/pysnmp/carrier/twisted/dispatch.py index 90284849..858bbd0f 100644 --- a/pysnmp/carrier/twisted/dispatch.py +++ b/pysnmp/carrier/twisted/dispatch.py @@ -36,17 +36,17 @@ class TwistedDispatcher(AbstractTransportDispatcher): def registerTransport(self, tDomain, transport): if not self.loopingcall.running and self.getTimerResolution() > 0: - self.loopingcall.start(self.getTimerResolution(), now = False) + self.loopingcall.start(self.getTimerResolution(), now=False) AbstractTransportDispatcher.registerTransport( self, tDomain, transport - ) - self.__transportCount = self.__transportCount + 1 + ) + self.__transportCount += 1 def unregisterTransport(self, tDomain): t = AbstractTransportDispatcher.getTransport(self, tDomain) if t is not None: AbstractTransportDispatcher.unregisterTransport(self, tDomain) - self.__transportCount = self.__transportCount - 1 + self.__transportCount -= 1 # The last transport has been removed, stop the timeout if self.__transportCount == 0 and self.loopingcall.running: |