11# -*- coding: utf-8 -*-
22
3- import random
43import logging
4+ import random
55
66from zope .interface import implementer
77
88from twisted import plugin
9- from twisted .internet import pollreactor
10-
11- from twisted .python import usage , log
12- from twisted .internet import defer
13- from twisted .internet .error import CannotListenError
149from twisted .application import service
10+ from twisted .internet import defer , pollreactor
11+ from twisted .internet .error import CannotListenError
12+ from twisted .python import log , usage
1513
16- from .recast import CastFactory
17- from .udpbcast import SharedUDP
1814from .announce import Announcer
1915from .processors import ProcessorController
16+ from .recast import CastFactory
17+ from .udpbcast import SharedUDP
2018
2119_log = logging .getLogger (__name__ )
2220
@@ -28,7 +26,8 @@ class Log2Twisted(logging.StreamHandler):
2826
2927 def __init__ (self ):
3028 super (Log2Twisted , self ).__init__ (stream = self )
31- # The Twisted log publisher adds a newline, so strip the newline added by the Python log handler.
29+ # The Twisted log publisher adds a newline,
30+ # so strip the newline added by the Python log handler.
3231 self .terminator = ""
3332 self .write = log .msg
3433
@@ -61,9 +60,7 @@ def __init__(self, config):
6160 if port :
6261 port = int (port )
6362 if port <= 0 or port > 0xFFFF :
64- raise usage .UsageError (
65- "Port numbers must be in the range [1,65535]"
66- )
63+ raise usage .UsageError ("Port numbers must be in the range [1,65535]" )
6764 else :
6865 port = 5049
6966
@@ -85,9 +82,7 @@ def privilegedStartService(self):
8582 # Attaching CastFactory to ProcessorController
8683 self .tcpFactory .commit = self .ctrl .commit
8784
88- self .tcp = self .reactor .listenTCP (
89- self .port , self .tcpFactory , interface = self .bind
90- )
85+ self .tcp = self .reactor .listenTCP (self .port , self .tcpFactory , interface = self .bind )
9186 try :
9287 self .tcp .startListening ()
9388 except CannotListenError :
@@ -109,9 +104,7 @@ def privilegedStartService(self):
109104 period = self .annperiod ,
110105 )
111106
112- self .udp = SharedUDP (
113- self .port , self .udpProto , reactor = self .reactor , interface = self .bind
114- )
107+ self .udp = SharedUDP (self .port , self .udpProto , reactor = self .reactor , interface = self .bind )
115108 self .udp .startListening ()
116109
117110 # This will start up plugin Processors
0 commit comments