asyncio: don't close loop explicitly (prevent callback calls from throwing), ignore already disconnected servers
This commit is contained in:
parent
3e2881bcfc
commit
387981a642
@ -717,11 +717,6 @@ class Network(util.DaemonThread):
|
|||||||
We distinguish by whether it is in self.interfaces.'''
|
We distinguish by whether it is in self.interfaces.'''
|
||||||
async with self.all_server_locks("connection down"):
|
async with self.all_server_locks("connection down"):
|
||||||
if server in self.disconnected_servers:
|
if server in self.disconnected_servers:
|
||||||
try:
|
|
||||||
raise Exception("already disconnected " + server + " because " + repr(self.disconnected_servers[server]) + ". new reason: " + repr(reason))
|
|
||||||
except:
|
|
||||||
traceback.print_exc()
|
|
||||||
sys.exit(1)
|
|
||||||
return
|
return
|
||||||
self.print_error("connection down", server)
|
self.print_error("connection down", server)
|
||||||
self.disconnected_servers[server] = reason
|
self.disconnected_servers[server] = reason
|
||||||
@ -1128,7 +1123,6 @@ class Network(util.DaemonThread):
|
|||||||
loop.run_until_complete(run_future)
|
loop.run_until_complete(run_future)
|
||||||
run_future.exception()
|
run_future.exception()
|
||||||
self.print_error("run future result", run_future.result())
|
self.print_error("run future result", run_future.result())
|
||||||
loop.close()
|
|
||||||
|
|
||||||
async def run_async(self, future):
|
async def run_async(self, future):
|
||||||
try:
|
try:
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user