Skip to content

Commit 184bf48

Browse files
committed
fixing some loggin nits
Signed-off-by: Jesse Jaggars <jjaggars@redhat.com>
1 parent 1a5e120 commit 184bf48

3 files changed

Lines changed: 4 additions & 4 deletions

File tree

receptor/messages/envelope.py

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -92,7 +92,6 @@ async def handle_frame(self, data):
9292
await self.consume(rest)
9393

9494
async def consume(self, data):
95-
logger.debug("consuming %d bytes; to_read = %d bytes", len(data), self.to_read)
9695
data, rest = data[:self.to_read], data[self.to_read:]
9796
self.to_read -= len(data)
9897
self.bb += data
@@ -102,7 +101,6 @@ async def consume(self, data):
102101
await self.handle_frame(rest)
103102

104103
async def finish(self):
105-
logger.debug("finish: %s", self.current_frame)
106104
if self.current_frame.type == Frame.Types.HEADER:
107105
self.header = json.loads(self.bb)
108106
elif self.current_frame.type == Frame.Types.PAYLOAD:

receptor/node.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@ def mainloop(receptor, ping_interval=None, loop=asyncio.get_event_loop(), skip_r
3636
c = WSClient(receptor, loop)
3737
loop.create_task(c.connect(peer))
3838
else:
39-
print(f"invalid peer: {peer} -> {parsed}")
39+
logger.warn(f"invalid peer: %s -> %s", peer, parsed)
4040

4141
if ping_interval > 0:
4242
ping_time = (((int(loop.time()) + 1) // ping_interval) + 1) * ping_interval

receptor/ws.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -71,7 +71,9 @@ async def start_processing(self, ws):
7171
logger.debug("sending routes")
7272
await self.receptor.send_route_advertisement()
7373
logger.debug("starting normal loop")
74-
self.handle_task = self.loop.create_task(self.receptor.message_handler(self.buf))
74+
self.handle_task = self.loop.create_task(
75+
self.receptor.message_handler(self.buf)
76+
)
7577
out = self.receptor.buffer_mgr.get_buffer_for_node(
7678
self.remote_id, self.receptor
7779
)

0 commit comments

Comments
 (0)