From: Cameron Dale <camrdale@gmail.com>
Date: Wed, 9 Jan 2008 05:49:34 +0000 (-0800)
Subject: Added more debug printing to noisy krpc protocol.
X-Git-Url: https://git.mxchange.org/?a=commitdiff_plain;h=ed355739a35a159655e9813cf872648816976cb6;p=quix0rs-apt-p2p.git

Added more debug printing to noisy krpc protocol.
---

diff --git a/apt_dht_Khashmir/krpc.py b/apt_dht_Khashmir/krpc.py
index 2c1f7e8..7427e0a 100644
--- a/apt_dht_Khashmir/krpc.py
+++ b/apt_dht_Khashmir/krpc.py
@@ -64,7 +64,7 @@ class hostbroker(protocol.DatagramProtocol):
 
 ## connection
 class KRPC:
-    noisy = 1
+    noisy = 0
     def __init__(self, addr, server, transport):
         self.transport = transport
         self.factory = server
@@ -85,7 +85,7 @@ class KRPC:
                 print "response decode error: " + `e`
         else:
             if self.noisy:
-                print msg
+                print self.factory.port, "received from", addr, self.addr, ":", msg
             # look at msg type
             if msg[TYP]  == REQ:
                 ilen = len(str)
@@ -100,6 +100,8 @@ class KRPC:
                         ## send error
                         out = bencode({TID:msg[TID], TYP:ERR, ERR :`format_exception(type(e), e, sys.exc_info()[2])`})
                         olen = len(out)
+                        if self.noisy:
+                            print self.factory.port, "responding to", addr, self.addr, ":", out
                         self.transport.write(out, addr)
                     else:
                         if ret:
@@ -109,6 +111,8 @@ class KRPC:
                             out = bencode({TID : msg[TID], TYP : RSP, RSP : {}})
                         #	send response
                         olen = len(out)
+                        if self.noisy:
+                            print self.factory.port, "responding to", addr, self.addr, ":", out
                         self.transport.write(out, addr)
 
                 else:
@@ -117,6 +121,8 @@ class KRPC:
                     # unknown method
                     out = bencode({TID:msg[TID], TYP:ERR, ERR : KRPC_ERROR_METHOD_UNKNOWN})
                     olen = len(out)
+                    if self.noisy:
+                        print self.factory.port, "responding to", addr, self.addr, ":", out
                     self.transport.write(out, addr)
                 if self.noisy:
                     print "%s %s >>> %s - %s %s %s" % (asctime(), addr, self.factory.node.port, 
@@ -158,6 +164,8 @@ class KRPC:
         # send it
         msg = {TID : chr(self.mtid), TYP : REQ,  REQ : method, ARG : args}
         self.mtid = (self.mtid + 1) % 256
+        if self.noisy:
+            print self.factory.port, "sending to", self.addr, ":", msg
         str = bencode(msg)
         d = Deferred()
         self.tids[msg[TID]] = d