connector

This commit is contained in:
4tochka 2019-05-16 18:37:43 +03:00
parent 41021e0c30
commit 6736fa0dfe

View File

@ -209,8 +209,8 @@ class Worker:
self.loop.set_default_executor(ThreadPoolExecutor(20)) self.loop.set_default_executor(ThreadPoolExecutor(20))
self.out_writer = out_writer self.out_writer = out_writer
self.in_reader = in_reader self.in_reader = in_reader
self.coins = MRU(100000) self.coins = MRU(500000)
self.destroyed_coins = MRU(100000) self.destroyed_coins = MRU(500000)
signal.signal(signal.SIGTERM, self.terminate) signal.signal(signal.SIGTERM, self.terminate)
self.loop.create_task(self.message_loop()) self.loop.create_task(self.message_loop())
self.loop.run_forever() self.loop.run_forever()
@ -296,7 +296,7 @@ class Worker:
self.rpc_batch_limit = bytes_to_int(msg) self.rpc_batch_limit = bytes_to_int(msg)
continue continue
except: except:
self.log.critical("exc") pass