Showing the message only if successfully decoded, #75

d2fa7b247e16580aa19c570326ec97b2d60c11a5 · 2024-07-26 12:06:17 -0700 · Mark Kockerbeck

Files touched

M exo/networking/grpc/grpc_discovery.py

Diff

commit d2fa7b247e16580aa19c570326ec97b2d60c11a5
Author: Mark Kockerbeck <xebxeb@gmail.com>
Date:   Fri Jul 26 12:06:17 2024 -0700

    Showing the message only if successfully decoded, #75
---
 exo/networking/grpc/grpc_discovery.py | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/exo/networking/grpc/grpc_discovery.py b/exo/networking/grpc/grpc_discovery.py
index a279c7f4..b607f083 100644
--- a/exo/networking/grpc/grpc_discovery.py
+++ b/exo/networking/grpc/grpc_discovery.py
@@ -102,8 +102,6 @@ class GRPCDiscovery(Discovery):
                 print(traceback.format_exc())
 
     async def on_listen_message(self, data, addr):
-        if DEBUG_DISCOVERY >= 2: print(f"received from peer {addr}: {data}")
-        
         if not data:
             return
 
@@ -116,6 +114,7 @@ class GRPCDiscovery(Discovery):
 
         decoder = json.JSONDecoder(strict=False)
         message = decoder.decode(decoded_data)
+        if DEBUG_DISCOVERY >= 2: print(f"received from peer {addr}: {message}")
 
         if message['type'] == 'discovery' and message['node_id'] != self.node_id:
             peer_id = message['node_id']

← 4f5ab78d Addressing issue #75 to avoid decoding binary packets · back to Exo · log chatgpt integration test output from each process on git e856d7f7 →