fix reconnect

This commit is contained in:
Victor Shyba 2018-09-17 15:32:16 -03:00 committed by Lex Berezhny
parent 873437e6a9
commit 94b920ab2a

View file

@ -138,6 +138,7 @@ class BaseNetwork:
@defer.inlineCallbacks @defer.inlineCallbacks
def start(self): def start(self):
self.running = True
for server in cycle(self.config['default_servers']): for server in cycle(self.config['default_servers']):
connection_string = 'tcp:{}:{}'.format(*server) connection_string = 'tcp:{}:{}'.format(*server)
endpoint = clientFromString(reactor, connection_string) endpoint = clientFromString(reactor, connection_string)