Changeset e392469
- Timestamp:
- Sep 1, 2009 2:51:11 PM (12 years ago)
- Branches:
- master
- Children:
- 5372a50, 6a2dfff
- Parents:
- 7745bd8
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
router/java/src/net/i2p/router/tunnel/TunnelDispatcher.java
r7745bd8 re392469 29 29 */ 30 30 public class TunnelDispatcher implements Service { 31 private RouterContext _context;32 private Log _log;33 private Map<TunnelId, TunnelGateway> _outboundGateways;34 private Map<TunnelId, OutboundTunnelEndpoint> _outboundEndpoints;35 private Map<TunnelId, TunnelParticipant> _participants;36 private Map<TunnelId, TunnelGateway> _inboundGateways;37 private Map<TunnelId, HopConfig> _participatingConfig;31 private final RouterContext _context; 32 private final Log _log; 33 private final Map<TunnelId, TunnelGateway> _outboundGateways; 34 private final Map<TunnelId, OutboundTunnelEndpoint> _outboundEndpoints; 35 private final Map<TunnelId, TunnelParticipant> _participants; 36 private final Map<TunnelId, TunnelGateway> _inboundGateways; 37 private final Map<TunnelId, HopConfig> _participatingConfig; 38 38 /** what is the date/time on which the last non-locally-created tunnel expires? */ 39 39 private long _lastParticipatingExpiration; 40 40 private BloomFilterIVValidator _validator; 41 private LeaveTunnel _leaveJob;41 private final LeaveTunnel _leaveJob; 42 42 /** what is the date/time we last deliberately dropped a tunnel? **/ 43 43 private long _lastDropTime; 44 private TunnelGatewayPumper _pumper;44 private final TunnelGatewayPumper _pumper; 45 45 46 46 /** Creates a new instance of TunnelDispatcher */ … … 616 616 } 617 617 618 private static final int DROP_BASE_INTERVAL = 40 * 1000;619 private static final int DROP_RANDOM_BOOST = 10 * 1000;618 //private static final int DROP_BASE_INTERVAL = 40 * 1000; 619 //private static final int DROP_RANDOM_BOOST = 10 * 1000; 620 620 621 621 /** … … 623 623 * the build executor may call this. 624 624 */ 625 625 /******* 626 626 public void dropBiggestParticipating() { 627 627 … … 678 678 _lastDropTime = _context.clock().now() + _context.random().nextInt(DROP_RANDOM_BOOST); 679 679 } 680 680 ******/ 681 681 682 public void startup() { 682 683 // NB: 256 == assume max rate (size adjusted to handle 256 messages per second)
Note: See TracChangeset
for help on using the changeset viewer.