logging (reduce gc churn)

This commit is contained in:
jrandom
2004-04-27 08:42:40 +00:00
committed by zzz
parent 34e8db0fe3
commit a78df1a152

View File

@ -62,6 +62,7 @@ class TunnelBuilder {
peerLists = randomizeLists(peerHashes, 1, settings.getDepthInbound()); peerLists = randomizeLists(peerHashes, 1, settings.getDepthInbound());
} }
if (peerLists.size() <= 0) { if (peerLists.size() <= 0) {
if (_log.shouldLog(Log.INFO))
_log.info("Configuring local inbound tunnel"); _log.info("Configuring local inbound tunnel");
return configureInboundTunnel(dest, settings, new ArrayList()); return configureInboundTunnel(dest, settings, new ArrayList());
} else { } else {
@ -83,6 +84,7 @@ class TunnelBuilder {
peerLists = randomizeLists(peerHashes, 1, settings.getDepthOutbound()); peerLists = randomizeLists(peerHashes, 1, settings.getDepthOutbound());
} }
if (peerLists.size() <= 0) { if (peerLists.size() <= 0) {
if (_log.shouldLog(Log.INFO))
_log.info("Configuring local outbound tunnel"); _log.info("Configuring local outbound tunnel");
return configureOutboundTunnel(settings, new ArrayList()); return configureOutboundTunnel(settings, new ArrayList());
} else { } else {
@ -112,12 +114,14 @@ class TunnelBuilder {
Set tunnels = new HashSet(); Set tunnels = new HashSet();
int numIn = settings.getNumInboundTunnels(); int numIn = settings.getNumInboundTunnels();
if (numIn <= 0) { if (numIn <= 0) {
if (_log.shouldLog(Log.INFO))
_log.info("No inbound tunnels requested, but we're creating one anyway"); _log.info("No inbound tunnels requested, but we're creating one anyway");
numIn = 1; numIn = 1;
} }
List peerLists = null; List peerLists = null;
if (!useFake) { if (!useFake) {
List peerHashes = selectInboundPeers(numIn, settings.getDepthInbound()); List peerHashes = selectInboundPeers(numIn, settings.getDepthInbound());
if (_log.shouldLog(Log.DEBUG))
_log.debug("Peer hashes selected: " + peerHashes.size()); _log.debug("Peer hashes selected: " + peerHashes.size());
peerLists = randomizeLists(peerHashes, settings.getNumInboundTunnels(), settings.getDepthInbound()); peerLists = randomizeLists(peerHashes, settings.getNumInboundTunnels(), settings.getDepthInbound());
} else { } else {
@ -127,6 +131,7 @@ class TunnelBuilder {
for (int i = 0; i < numIn; i++) { for (int i = 0; i < numIn; i++) {
TunnelInfo tunnel = configureInboundTunnel(dest, settings, new ArrayList()); TunnelInfo tunnel = configureInboundTunnel(dest, settings, new ArrayList());
tunnels.add(tunnel); tunnels.add(tunnel);
if (_log.shouldLog(Log.INFO))
_log.info("Dummy inbound tunnel " + tunnel.getTunnelId() + " configured (" + tunnel + ")"); _log.info("Dummy inbound tunnel " + tunnel.getTunnelId() + " configured (" + tunnel + ")");
} }
} else { } else {
@ -134,6 +139,7 @@ class TunnelBuilder {
List peerList = (List)iter.next(); List peerList = (List)iter.next();
TunnelInfo tunnel = configureInboundTunnel(dest, settings, peerList); TunnelInfo tunnel = configureInboundTunnel(dest, settings, peerList);
tunnels.add(tunnel); tunnels.add(tunnel);
if (_log.shouldLog(Log.INFO))
_log.info("Real inbound tunnel " + tunnel.getTunnelId() + " configured (" + tunnel + ")"); _log.info("Real inbound tunnel " + tunnel.getTunnelId() + " configured (" + tunnel + ")");
} }
} }
@ -154,6 +160,7 @@ class TunnelBuilder {
List peerLists = null; List peerLists = null;
if (!useFake) { if (!useFake) {
List peerHashes = selectOutboundPeers(settings.getNumOutboundTunnels(), settings.getDepthOutbound()); List peerHashes = selectOutboundPeers(settings.getNumOutboundTunnels(), settings.getDepthOutbound());
if (_log.shouldLog(Log.DEBUG))
_log.debug("Peer hashes selected: " + peerHashes.size()); _log.debug("Peer hashes selected: " + peerHashes.size());
peerLists = randomizeLists(peerHashes, settings.getNumOutboundTunnels(), settings.getDepthOutbound()); peerLists = randomizeLists(peerHashes, settings.getNumOutboundTunnels(), settings.getDepthOutbound());
} else { } else {
@ -163,6 +170,7 @@ class TunnelBuilder {
for (int i = 0; i < settings.getNumOutboundTunnels(); i++) { for (int i = 0; i < settings.getNumOutboundTunnels(); i++) {
TunnelInfo tunnel = configureOutboundTunnel(settings, new ArrayList()); TunnelInfo tunnel = configureOutboundTunnel(settings, new ArrayList());
tunnels.add(tunnel); tunnels.add(tunnel);
if (_log.shouldLog(Log.INFO))
_log.info("Dummy outbound tunnel " + tunnel.getTunnelId() + " configured (" + tunnel + ")"); _log.info("Dummy outbound tunnel " + tunnel.getTunnelId() + " configured (" + tunnel + ")");
} }
} else { } else {
@ -170,6 +178,7 @@ class TunnelBuilder {
List peerList = (List)iter.next(); List peerList = (List)iter.next();
TunnelInfo tunnel = configureOutboundTunnel(settings, peerList); TunnelInfo tunnel = configureOutboundTunnel(settings, peerList);
tunnels.add(tunnel); tunnels.add(tunnel);
if (_log.shouldLog(Log.INFO))
_log.info("Real outbound tunnel " + tunnel.getTunnelId() + " configured (" + tunnel + ")"); _log.info("Real outbound tunnel " + tunnel.getTunnelId() + " configured (" + tunnel + ")");
} }
} }
@ -206,6 +215,7 @@ class TunnelBuilder {
if (null != _context.netDb().lookupRouterInfoLocally(peer)) if (null != _context.netDb().lookupRouterInfoLocally(peer))
rv.add(peer); rv.add(peer);
else { else {
if (_log.shouldLog(Log.WARN))
_log.warn("peer manager selected a peer we don't know about - drop it"); _log.warn("peer manager selected a peer we don't know about - drop it");
} }
} }
@ -225,9 +235,11 @@ class TunnelBuilder {
List tunnels = new ArrayList(numTunnels); List tunnels = new ArrayList(numTunnels);
if (peerHashes.size() == 0) { if (peerHashes.size() == 0) {
if (_log.shouldLog(Log.INFO))
_log.info("No peer hashes provided"); _log.info("No peer hashes provided");
return tunnels; return tunnels;
} else { } else {
if (_log.shouldLog(Log.INFO))
_log.info("# peers randomizing: " + peerHashes + " into " + numTunnels + " tunnels"); _log.info("# peers randomizing: " + peerHashes + " into " + numTunnels + " tunnels");
} }
@ -240,10 +252,12 @@ class TunnelBuilder {
if (!peers.contains(peer)) if (!peers.contains(peer))
peers.add(peer); peers.add(peer);
} }
if (_log.shouldLog(Log.INFO))
_log.info("Tunnel " + i + " [" + numPerTunnel + "/(" + startOn+ ")]: " + peers); _log.info("Tunnel " + i + " [" + numPerTunnel + "/(" + startOn+ ")]: " + peers);
tunnels.add(peers); tunnels.add(peers);
} }
if (_log.shouldLog(Log.INFO))
_log.info("Tunnels: " + tunnels); _log.info("Tunnels: " + tunnels);
return tunnels; return tunnels;