Changeset f492770

Timestamp:

Sep 23, 2008 6:47:10 PM (12 years ago)

Author:

zzz <zzz@…>

Branches:

master

Children:

fbad8a1

Parents:

e5c7b79

Message:

• TunnelPeerSelector?: Avoid a peer for 20s after a reject or timeout

Location:

router/java/src/net/i2p/router

Files:

• peermanager/ProfileOrganizer.java (modified) (1 diff)
• tunnel/pool/TunnelPeerSelector.java (modified) (1 diff)

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

@@ -476 +476 @@
             _log.info("Unreachable: " + l);
         return l;
+    }
+
+    /**
+     * Get the peers that have recently rejected us for bandwidth
+     * recent == last 20s
+     *
+     */
+    public List selectPeersRecentlyRejecting() { 
+        synchronized (_reorganizeLock) {
+            long cutoff = _context.clock().now() - (20*1000);
+            int count = _notFailingPeers.size();
+            List l = new ArrayList(count / 128);
+            for (Iterator iter = _notFailingPeers.values().iterator(); iter.hasNext(); ) {
+                PeerProfile prof = (PeerProfile) iter.next();
+                if (prof.getTunnelHistory().getLastRejectedBandwidth() > cutoff)
+                    l.add(prof.getPeer());
+            }
+            return l;
+        }
     }
 

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

@@ -177 +177 @@
 
         Set peers = new HashSet(1);
+        peers.addAll(ctx.profileOrganizer().selectPeersRecentlyRejecting());
         // if (false && filterUnreachable(ctx, isInbound, isExploratory)) {
         if (filterUnreachable(ctx, isInbound, isExploratory)) {