From a81b8917d8fe5ab34149fa4e83183941f9ce6dfb Mon Sep 17 00:00:00 2001 From: Neil Booth Date: Wed, 21 Dec 2016 21:15:48 +0900 Subject: [PATCH] Logging tweaks --- server/protocol.py | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/server/protocol.py b/server/protocol.py index b008fe1..182caa8 100644 --- a/server/protocol.py +++ b/server/protocol.py @@ -111,7 +111,6 @@ class ServerManager(util.LoggedClass): limit += limit // 2 bands.append(limit) self.bands = sorted(bands) - self.logger.info('bands: {}'.format(self.bands)) def session_priority(self, session): if isinstance(session, LocalRPC): @@ -120,6 +119,9 @@ class ServerManager(util.LoggedClass): return 1 + (bisect_left(self.bands, session.bandwidth_used) + bisect_left(self.bands, group_bandwidth) + 1) // 2 + def is_deprioritized(self, session): + return self.session_priority(session) > self.BANDS + async def enqueue_delayed_sessions(self): while True: now = time.time() @@ -232,6 +234,7 @@ class ServerManager(util.LoggedClass): .format(self.max_subs)) self.logger.info('max subscriptions per session: {:,d}' .format(self.env.max_session_subs)) + self.logger.info('bands: {}'.format(self.bands)) await self.start_external_servers() async def start_external_servers(self): @@ -641,7 +644,7 @@ class Session(JSONRPC): def connection_lost(self, exc): '''Handle client disconnection.''' super().connection_lost(exc) - if (self.pause or self.manager.session_priority(self) >= 5 + if (self.pause or self.manager.is_deprioritized(self) or self.send_size >= 1024*1024 or self.error_count): self.log_info('disconnected. Sent {:,d} bytes in {:,d} messages ' '{:,d} errors'