Changeset 62bf269

Timestamp:

Aug 29, 2008 1:15:28 PM (13 years ago)

Author:

zzz <zzz@…>

Branches:

master

Children:

ef328ed3

Parents:

ee4d68c

Message:

• Profiles: Penalize capacity when tunnel build request times out
• Tunnel BuildExecutor?: Debug cleanup

Files:

• history.txt (modified) (1 diff)
• router/java/src/net/i2p/router/ProfileManager.java (modified) (1 diff)
• router/java/src/net/i2p/router/RouterVersion.java (modified) (1 diff)
• router/java/src/net/i2p/router/peermanager/ProfileManagerImpl.java (modified) (1 diff)
• router/java/src/net/i2p/router/tunnel/pool/BuildExecutor.java (modified) (7 diffs)

history.txt

@@ +1 @@
+2008-08-29 zzz
+    * Tunnel BuildExecutor: Debug cleanup
+    * Profiles: Penalize capacity when tunnel build request times out
+    * Shutdown: Call the shutdown hooks before the router shutdown
+      rather than after
+    * Stats: Remove tunnel.Bps.* stats when the tunnel pool is closed
+
 2008-08-27 zzz
     * Floodfill Peer Selector: Prefer already-connected floodfill

router/java/src/net/i2p/router/ProfileManager.java

@@ -54 +54 @@
      */
     void tunnelRejected(Hash peer, long responseTimeMs, int severity);
+    
+    /**
+     * Note that a router timed out joining a tunnel
+     * 
+     * @param peer who rejected us
+     */
+    void tunnelTimedOut(Hash peer);
     
     /**

router/java/src/net/i2p/router/RouterVersion.java

@@ -18 +18 @@
     public final static String ID = "$Revision: 1.548 $ $Date: 2008-06-07 23:00:00 $";
     public final static String VERSION = "0.6.3";
-    public final static long BUILD = 1;
+    public final static long BUILD = 2;
     public static void main(String args[]) {
         System.out.println("I2P Router version: " + VERSION + "-" + BUILD);

router/java/src/net/i2p/router/peermanager/ProfileManagerImpl.java

@@ -105 +105 @@
     
     /**
+     * Note that a router did not respond to a tunnel join. 
+     *
+     * Since TunnelHistory doesn't have a timeout stat, pretend we were
+     * rejected for bandwidth reasons.
+     */
+    public void tunnelTimedOut(Hash peer) {
+        PeerProfile data = getProfile(peer);
+        if (data == null) return;
+        data.getTunnelHistory().incrementRejected(TunnelHistory.TUNNEL_REJECT_BANDWIDTH);
+    }
+    
+    /**
      * Note that a tunnel that the router is participating in
      * was successfully tested with the given round trip latency

router/java/src/net/i2p/router/tunnel/pool/BuildExecutor.java

@@ -68 +68 @@
     
     private int allowed() {
-        StringBuffer buf = null;
-        if (_log.shouldLog(Log.DEBUG)) {
-            buf = new StringBuffer(128);
-            buf.append("Allowed: ");
-        }
-
         int maxKBps = _context.bandwidthLimiter().getOutboundKBytesPerSecond();
         int allowed = maxKBps / 6; // Max. 1 concurrent build per 6 KB/s outbound
@@ -100 +94 @@
             concurrent = _currentlyBuilding.size();
             allowed -= concurrent;
-            if (buf != null)
-                buf.append(allowed).append(" ").append(_currentlyBuilding.toString());
         }
         
@@ -107 +99 @@
             for (int i = 0; i < expired.size(); i++) {
                 PooledTunnelCreatorConfig cfg = (PooledTunnelCreatorConfig)expired.get(i);
-                // note the fact that this tunnel request timed out in the peers' profiles.
-                // or... not.
                 if (_log.shouldLog(Log.INFO))
                     _log.info("Timed out waiting for reply asking for " + cfg);
@@ -114 +104 @@
                 // Iterate through peers in the tunnel, get their bandwidth tiers,
                 // record for each that a peer of the given tier expired
+                // Also note the fact that this tunnel request timed out in the peers' profiles.
                 for (int iPeer = 0; iPeer < cfg.getLength(); iPeer++) {
                     // Look up peer
                     Hash peer = cfg.getPeer(iPeer);
                     // Avoid recording ourselves
-                    if (peer.toBase64().equals(_context.routerHash().toBase64())) {
-                        if (_log.shouldLog(Log.DEBUG)) _log.debug("Not recording our own expiry in stats.");
+                    if (peer.toBase64().equals(_context.routerHash().toBase64()))
                         continue;
-                    }
                     // Look up routerInfo
                     RouterInfo ri = _context.netDb().lookupRouterInfoLocally(peer);
@@ -127 +116 @@
                     String bwTier = "Unknown";
                     if (ri != null) bwTier = ri.getBandwidthTier(); // Returns "Unknown" if none recognized
-                        else if (_log.shouldLog(Log.WARN)) _log.warn("Failed detecting bwTier, null routerInfo for: " + peer);
                     // Record that a peer of the given tier expired
                     _context.statManager().addRateData("tunnel.tierExpire" + bwTier, 1, 0);
-                }
-
+                    didNotReply(cfg.getReplyMessageId(), peer);
+                    // Blame everybody since we don't know whose fault it is.
+                    // (it could be our exploratory tunnel's fault too...)
+                    _context.profileManager().tunnelTimedOut(peer);
+                }
 
                 TunnelPool pool = cfg.getTunnelPool();
@@ -140 +131 @@
                 else
                     _context.statManager().addRateData("tunnel.buildClientExpire", 1, 0);
-                for (int j = 0; j < cfg.getLength(); j++)
-                    didNotReply(cfg.getReplyMessageId(), cfg.getPeer(j));
-            }
-        }
-        
-        //if (buf != null)
-        //    _log.debug(buf.toString());
+            }
+        }
         
         _context.statManager().addRateData("tunnel.concurrentBuilds", concurrent, 0);
@@ -168 +154 @@
 
     // Estimated cost of tunnel build attempt, bytes
-    private static final int BUILD_BANDWIDTH_ESTIMATE_BYTES = 5*1024;
+    // private static final int BUILD_BANDWIDTH_ESTIMATE_BYTES = 5*1024;
 
     /**