[freenet-cvs] r18441 - trunk/freenet/src/freenet/io/xfer

[t...@freenetproject.org]

Author: toad
Date: 2008-03-10 20:47:38 +0000 (Mon, 10 Mar 2008)
New Revision: 18441

Modified:
   trunk/freenet/src/freenet/io/xfer/PacketThrottle.java
Log:
Logging

Modified: trunk/freenet/src/freenet/io/xfer/PacketThrottle.java
===================================================================
--- trunk/freenet/src/freenet/io/xfer/PacketThrottle.java       2008-03-10 
20:12:42 UTC (rev 18440)
+++ trunk/freenet/src/freenet/io/xfer/PacketThrottle.java       2008-03-10 
20:47:38 UTC (rev 18441)
@@ -212,13 +212,13 @@
                MyCallback callback = new MyCallback();
                try {
                        if(!((PeerNode)peer).isLocalAddress()) {
-                               if(logMINOR) Logger.minor(this, "Throttling 
"+peer.shortToString()+" : "+packetSize);
+                               if(logMINOR) Logger.minor(this, "Throttling 
"+peer.shortToString()+" : "+packetSize+" for "+this);
                                long startTime = System.currentTimeMillis();
                                overallThrottle.blockingGrab(packetSize);
                                long delayTime = System.currentTimeMillis() - 
startTime;
                                
((PeerNode)peer).reportThrottledPacketSendTime(delayTime);
                        } else if(logMINOR)
-                               Logger.minor(this, "Not throttling 
"+peer.shortToString());
+                               Logger.minor(this, "Not throttling 
"+peer.shortToString()+" for "+this);
                        peer.sendAsync(msg, callback, packetSize, ctr);
                } catch (RuntimeException e) {
                        callback.fatalError();
@@ -246,7 +246,7 @@
                                _packetsInFlight--;
                                PacketThrottle.this.notifyAll();
                        }
-                       if(logMINOR) Logger.minor(this, "Removed packet: 
acked");
+                       if(logMINOR) Logger.minor(this, "Removed packet: acked 
for "+this);
                }

                public void disconnected() {
@@ -256,7 +256,7 @@
                                _packetsInFlight--;
                                PacketThrottle.this.notifyAll();
                        }
-                       if(logMINOR) Logger.minor(this, "Removed packet: 
disconnected");
+                       if(logMINOR) Logger.minor(this, "Removed packet: 
disconnected for "+this);
                }

                public void fatalError() {
@@ -266,7 +266,7 @@
                                _packetsInFlight--;
                                PacketThrottle.this.notifyAll();
                        }
-                       if(logMINOR) Logger.minor(this, "Removed packet: 
error");
+                       if(logMINOR) Logger.minor(this, "Removed packet: error 
for "+this);
                }

                public void sent() {