diff --git a/apps/BOB/src/net/i2p/BOB/DoCMDS.java b/apps/BOB/src/net/i2p/BOB/DoCMDS.java
index fd53efd69..af5830818 100644
--- a/apps/BOB/src/net/i2p/BOB/DoCMDS.java
+++ b/apps/BOB/src/net/i2p/BOB/DoCMDS.java
@@ -400,7 +400,7 @@ public class DoCMDS implements Runnable {
*/
private boolean is64ok(String data) {
try {
- Destination x = new Destination(data);
+ new Destination(data);
return true;
} catch (Exception e) {
return false;
diff --git a/apps/i2psnark/java/src/org/klomp/snark/PeerCheckerTask.java b/apps/i2psnark/java/src/org/klomp/snark/PeerCheckerTask.java
index 86d129983..9efce9f07 100644
--- a/apps/i2psnark/java/src/org/klomp/snark/PeerCheckerTask.java
+++ b/apps/i2psnark/java/src/org/klomp/snark/PeerCheckerTask.java
@@ -59,9 +59,7 @@ class PeerCheckerTask implements Runnable
long worstdownload = Long.MAX_VALUE;
Peer worstDownloader = null;
- int peers = 0;
int uploaders = 0;
- int downloaders = 0;
int removedCount = 0;
long uploaded = 0;
@@ -84,12 +82,8 @@ class PeerCheckerTask implements Runnable
continue;
}
- peers++;
-
if (!peer.isChoking())
uploaders++;
- if (!peer.isChoked() && peer.isInteresting())
- downloaders++;
long upload = peer.getUploaded();
uploaded += upload;
diff --git a/apps/i2psnark/java/src/org/klomp/snark/Snark.java b/apps/i2psnark/java/src/org/klomp/snark/Snark.java
index b586265c7..7d609324d 100644
--- a/apps/i2psnark/java/src/org/klomp/snark/Snark.java
+++ b/apps/i2psnark/java/src/org/klomp/snark/Snark.java
@@ -315,8 +315,6 @@ public class Snark
id = generateID();
debug("My peer id: " + PeerID.idencode(id), Snark.INFO);
- int port;
- IOException lastException = null;
/*
* Don't start a tunnel if the torrent isn't going to be started.
* If we are starting,
diff --git a/apps/i2psnark/java/src/org/klomp/snark/TrackerClient.java b/apps/i2psnark/java/src/org/klomp/snark/TrackerClient.java
index 775ad2fc2..2ac9cac9a 100644
--- a/apps/i2psnark/java/src/org/klomp/snark/TrackerClient.java
+++ b/apps/i2psnark/java/src/org/klomp/snark/TrackerClient.java
@@ -198,8 +198,6 @@ public class TrackerClient extends I2PAppThread
long left = coordinator.getLeft();
boolean completed = (left == 0);
- int sleptTime = 0;
-
try
{
if (!verifyConnected()) return;
@@ -258,8 +256,6 @@ public class TrackerClient extends I2PAppThread
event = NO_EVENT;
// *** loop once for each tracker
- // Only do a request when necessary.
- sleptTime = 0;
int maxSeenPeers = 0;
for (Iterator iter = trackers.iterator(); iter.hasNext(); ) {
Tracker tr = (Tracker)iter.next();
@@ -308,7 +304,6 @@ public class TrackerClient extends I2PAppThread
// only delay if we actually make an attempt to add peer
if(coordinator.addPeer(cur) && it.hasNext()) {
int delay = (DELAY_MUL * r.nextInt(10)) + DELAY_MIN;
- sleptTime += delay;
try { Thread.sleep(delay); } catch (InterruptedException ie) {}
}
}
diff --git a/apps/i2psnark/java/src/org/klomp/snark/web/I2PSnarkServlet.java b/apps/i2psnark/java/src/org/klomp/snark/web/I2PSnarkServlet.java
index 5bc584cef..d08c16c59 100644
--- a/apps/i2psnark/java/src/org/klomp/snark/web/I2PSnarkServlet.java
+++ b/apps/i2psnark/java/src/org/klomp/snark/web/I2PSnarkServlet.java
@@ -495,7 +495,6 @@ public class I2PSnarkServlet extends DefaultServlet {
// return;
//}
if ("Add".equals(action)) {
- String newFile = req.getParameter("newFile");
String newURL = req.getParameter("newURL");
/******
// NOTE - newFile currently disabled in HTML form - see below
diff --git a/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelConnectClient.java b/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelConnectClient.java
index e4c7c9907..49261da24 100644
--- a/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelConnectClient.java
+++ b/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelConnectClient.java
@@ -176,7 +176,6 @@ public class I2PTunnelConnectClient extends I2PTunnelHTTPClientBase implements R
in = s.getInputStream();
String line, method = null, host = null, destination = null, restofline = null;
StringBuilder newRequest = new StringBuilder();
- int ahelper = 0;
String authorization = null;
while (true) {
// Use this rather than BufferedReader because we can't have readahead,
diff --git a/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelHTTPClient.java b/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelHTTPClient.java
index 1d1dc4758..1b5ca2173 100644
--- a/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelHTTPClient.java
+++ b/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelHTTPClient.java
@@ -320,7 +320,6 @@ public class I2PTunnelHTTPClient extends I2PTunnelHTTPClientBase implements Runn
public static final String PROP_DISABLE_HELPER = "i2ptunnel.httpclient.disableAddressHelper";
protected void clientConnectionRun(Socket s) {
- InputStream in = null;
OutputStream out = null;
/**
@@ -941,7 +940,7 @@ public class I2PTunnelHTTPClient extends I2PTunnelHTTPClientBase implements Runn
I2PSocket i2ps = createI2PSocket(clientDest, getDefaultOptions(opts));
byte[] data = newRequest.toString().getBytes("ISO-8859-1");
Runnable onTimeout = new OnTimeout(s, s.getOutputStream(), targetRequest, usingWWWProxy, currentProxy, requestId);
- I2PTunnelRunner runner = new I2PTunnelHTTPClientRunner(s, i2ps, sockLock, data, mySockets, onTimeout);
+ new I2PTunnelHTTPClientRunner(s, i2ps, sockLock, data, mySockets, onTimeout);
} catch (SocketException ex) {
if (_log.shouldLog(Log.INFO))
_log.info(getPrefix(requestId) + "Error trying to connect", ex);
diff --git a/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/socks/SOCKS4aServer.java b/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/socks/SOCKS4aServer.java
index fa974be1b..63c38dc75 100644
--- a/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/socks/SOCKS4aServer.java
+++ b/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/socks/SOCKS4aServer.java
@@ -131,7 +131,6 @@ public class SOCKS4aServer extends SOCKSServer {
}
protected void confirmConnection() throws SOCKSException {
- DataInputStream in;
DataOutputStream out;
try {
out = new DataOutputStream(clientSock.getOutputStream());
diff --git a/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/socks/SOCKS5Server.java b/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/socks/SOCKS5Server.java
index 50b633c96..45915f6b3 100644
--- a/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/socks/SOCKS5Server.java
+++ b/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/socks/SOCKS5Server.java
@@ -97,7 +97,6 @@ public class SOCKS5Server extends SOCKSServer {
*/
private void init(DataInputStream in, DataOutputStream out) throws IOException, SOCKSException {
int nMethods = in.readUnsignedByte();
- boolean methodOk = false;
int method = Method.NO_ACCEPTABLE_METHODS;
for (int i = 0; i < nMethods; ++i) {
@@ -247,7 +246,6 @@ public class SOCKS5Server extends SOCKSServer {
}
protected void confirmConnection() throws SOCKSException {
- DataInputStream in;
DataOutputStream out;
try {
out = new DataOutputStream(clientSock.getOutputStream());
diff --git a/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/udpTunnel/I2PTunnelUDPClientBase.java b/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/udpTunnel/I2PTunnelUDPClientBase.java
index c7613d35e..de5fd597f 100644
--- a/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/udpTunnel/I2PTunnelUDPClientBase.java
+++ b/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/udpTunnel/I2PTunnelUDPClientBase.java
@@ -91,11 +91,10 @@ import net.i2p.util.EventDispatcher;
// create i2pclient and destination
I2PClient client = I2PClientFactory.createClient();
- Destination destN;
byte[] key;
try {
ByteArrayOutputStream out = new ByteArrayOutputStream(512);
- destN = client.createDestination(out);
+ client.createDestination(out);
key = out.toByteArray();
} catch(Exception exc) {
throw new RuntimeException("failed to create i2p-destination", exc);
diff --git a/apps/routerconsole/java/src/net/i2p/router/web/ConfigClientsHandler.java b/apps/routerconsole/java/src/net/i2p/router/web/ConfigClientsHandler.java
index d1690212e..6c37db829 100644
--- a/apps/routerconsole/java/src/net/i2p/router/web/ConfigClientsHandler.java
+++ b/apps/routerconsole/java/src/net/i2p/router/web/ConfigClientsHandler.java
@@ -262,7 +262,6 @@ public class ConfigClientsHandler extends FormHandler {
private void saveWebAppChanges() {
Properties props = RouterConsoleRunner.webAppProperties();
Set keys = props.keySet();
- int cur = 0;
for (Iterator iter = keys.iterator(); iter.hasNext(); ) {
String name = (String)iter.next();
if (! (name.startsWith(RouterConsoleRunner.PREFIX) && name.endsWith(RouterConsoleRunner.ENABLED)))
@@ -279,7 +278,6 @@ public class ConfigClientsHandler extends FormHandler {
private void savePluginChanges() {
Properties props = PluginStarter.pluginProperties();
Set keys = props.keySet();
- int cur = 0;
for (Iterator iter = keys.iterator(); iter.hasNext(); ) {
String name = (String)iter.next();
if (! (name.startsWith(PluginStarter.PREFIX) && name.endsWith(PluginStarter.ENABLED)))
diff --git a/apps/routerconsole/java/src/net/i2p/router/web/ProfileOrganizerRenderer.java b/apps/routerconsole/java/src/net/i2p/router/web/ProfileOrganizerRenderer.java
index f68a53a36..8ef108817 100644
--- a/apps/routerconsole/java/src/net/i2p/router/web/ProfileOrganizerRenderer.java
+++ b/apps/routerconsole/java/src/net/i2p/router/web/ProfileOrganizerRenderer.java
@@ -67,7 +67,6 @@ class ProfileOrganizerRenderer {
int fast = 0;
int reliable = 0;
int integrated = 0;
- int failing = 0;
StringBuilder buf = new StringBuilder(16*1024);
buf.append("").append(_("Peer Profiles")).append("
\n");
buf.append(ngettext("Showing 1 recent profile.", "Showing {0} recent profiles.", order.size())).append('\n');
@@ -101,7 +100,6 @@ class ProfileOrganizerRenderer {
tier = 2;
reliable++;
} else if (_organizer.isFailing(peer)) {
- failing++;
} else {
tier = 3;
}
diff --git a/apps/routerconsole/java/src/net/i2p/router/web/StatsGenerator.java b/apps/routerconsole/java/src/net/i2p/router/web/StatsGenerator.java
index cd39b4a25..3cc985033 100644
--- a/apps/routerconsole/java/src/net/i2p/router/web/StatsGenerator.java
+++ b/apps/routerconsole/java/src/net/i2p/router/web/StatsGenerator.java
@@ -207,7 +207,6 @@ public class StatsGenerator {
long numPeriods = curRate.getLifetimePeriods();
if (numPeriods > 0) {
double avgFrequency = curRate.getLifetimeEventCount() / (double)numPeriods;
- double peakFrequency = curRate.getExtremeEventCount();
buf.append(" (").append(_("Average event count")).append(": ");
buf.append(num(avgFrequency));
buf.append("; ").append(_("Events in peak period")).append(": ");
diff --git a/apps/routerconsole/java/src/net/i2p/router/web/SummaryListener.java b/apps/routerconsole/java/src/net/i2p/router/web/SummaryListener.java
index 9756c0b5e..96ad1a6bf 100644
--- a/apps/routerconsole/java/src/net/i2p/router/web/SummaryListener.java
+++ b/apps/routerconsole/java/src/net/i2p/router/web/SummaryListener.java
@@ -141,7 +141,6 @@ class SummaryListener implements RateSummaryListener {
long heartbeat = period*10/1000;
def.addDatasource(_name, "GAUGE", heartbeat, Double.NaN, Double.NaN);
def.addDatasource(_eventName, "GAUGE", heartbeat, 0, Double.NaN);
- int steps = 1;
if (_isPersistent) {
_rows = (int) Math.max(MIN_ROWS, Math.min(MAX_ROWS, THREE_MONTHS / period));
} else {
diff --git a/apps/sam/java/src/net/i2p/sam/SAMUtils.java b/apps/sam/java/src/net/i2p/sam/SAMUtils.java
index 859154c4f..ebf99cb3a 100644
--- a/apps/sam/java/src/net/i2p/sam/SAMUtils.java
+++ b/apps/sam/java/src/net/i2p/sam/SAMUtils.java
@@ -151,7 +151,7 @@ public class SAMUtils {
* @return Properties with the parsed SAM params
*/
public static Properties parseParams(StringTokenizer tok) throws SAMException {
- int pos, nprops = 0, ntoks = tok.countTokens();
+ int pos, ntoks = tok.countTokens();
String token, param;
Properties props = new Properties();
@@ -175,7 +175,6 @@ public class SAMUtils {
props.setProperty(param, value.toString());
value.setLength(0);
- nprops += 1;
}
if (_log.shouldLog(Log.DEBUG)) {
diff --git a/apps/streaming/java/src/net/i2p/client/streaming/Connection.java b/apps/streaming/java/src/net/i2p/client/streaming/Connection.java
index a7a99174e..6ce781840 100644
--- a/apps/streaming/java/src/net/i2p/client/streaming/Connection.java
+++ b/apps/streaming/java/src/net/i2p/client/streaming/Connection.java
@@ -307,10 +307,7 @@ class Connection {
packet.setFlag(Packet.FLAG_SIGNATURE_REQUESTED);
}
- boolean ackOnly = false;
-
if ( (packet.getSequenceNum() == 0) && (!packet.isFlagSet(Packet.FLAG_SYNCHRONIZE)) ) {
- ackOnly = true;
//if (_log.shouldLog(Log.DEBUG))
// _log.debug("No resend for " + packet);
} else {
diff --git a/apps/streaming/java/src/net/i2p/client/streaming/MessageInputStream.java b/apps/streaming/java/src/net/i2p/client/streaming/MessageInputStream.java
index e83ca74a7..fbb723728 100644
--- a/apps/streaming/java/src/net/i2p/client/streaming/MessageInputStream.java
+++ b/apps/streaming/java/src/net/i2p/client/streaming/MessageInputStream.java
@@ -335,11 +335,9 @@ class MessageInputStream extends InputStream {
ByteArray cur = _readyDataBlocks.get(0);
byte rv = cur.getData()[cur.getOffset()+_readyDataBlockIndex];
_readyDataBlockIndex++;
- boolean removed = false;
if (cur.getValid() <= _readyDataBlockIndex) {
_readyDataBlockIndex = 0;
_readyDataBlocks.remove(0);
- removed = true;
}
_readTotal++;
target[offset + i] = rv; // rv < 0 ? rv + 256 : rv
diff --git a/apps/streaming/java/src/net/i2p/client/streaming/Packet.java b/apps/streaming/java/src/net/i2p/client/streaming/Packet.java
index 437eb5dee..bb3e723b6 100644
--- a/apps/streaming/java/src/net/i2p/client/streaming/Packet.java
+++ b/apps/streaming/java/src/net/i2p/client/streaming/Packet.java
@@ -270,7 +270,6 @@ class Packet {
//_payload = null;
}
public ByteArray acquirePayload() {
- ByteArray old = _payload;
_payload = new ByteArray(new byte[Packet.MAX_PAYLOAD_SIZE]);
return _payload;
}
diff --git a/apps/susimail/src/src/i2p/susi/webmail/encoding/Base64.java b/apps/susimail/src/src/i2p/susi/webmail/encoding/Base64.java
index 1d376fc38..d866b210b 100644
--- a/apps/susimail/src/src/i2p/susi/webmail/encoding/Base64.java
+++ b/apps/susimail/src/src/i2p/susi/webmail/encoding/Base64.java
@@ -152,7 +152,6 @@ public class Base64 implements Encoding {
}
private static byte decodeByte( byte b ) throws DecodingException {
- byte a = b;
if( b >= 'A' && b <= 'Z' )
b -= 'A';
else if( b >= 'a' && b <= 'z' )
diff --git a/apps/susimail/src/src/i2p/susi/webmail/encoding/QuotedPrintable.java b/apps/susimail/src/src/i2p/susi/webmail/encoding/QuotedPrintable.java
index 5a98c6a05..2194b24c0 100644
--- a/apps/susimail/src/src/i2p/susi/webmail/encoding/QuotedPrintable.java
+++ b/apps/susimail/src/src/i2p/susi/webmail/encoding/QuotedPrintable.java
@@ -70,7 +70,6 @@ public class QuotedPrintable implements Encoding {
private static int BUFSIZE = 2;
private String encode( InputStream in ) throws EncodingException, IOException {
StringBuilder out = new StringBuilder();
- int l = 0;
int read = 0, buffered = 0, tmp[] = new int[BUFSIZE];
while( true ) {
read = in.available();
@@ -88,7 +87,6 @@ public class QuotedPrintable implements Encoding {
if( c > 32 && c < 127 && c != 61 ) {
out.append( (char)c );
- l++;
}
else if( ( c == 32 || c == 9 ) ) {
if( buffered > 0 && ( tmp[0] == 10 || tmp[0] == 13 ) ) {
@@ -96,11 +94,9 @@ public class QuotedPrintable implements Encoding {
* whitespace at end of line
*/
out.append( c == 32 ? "=20" : "=09" );
- l += 3;
}
else {
out.append( (char)c );
- l++;
}
}
else if( c == 13 && buffered > 0 && tmp[0] == 10 ) {
@@ -108,14 +104,12 @@ public class QuotedPrintable implements Encoding {
buffered--;
for( int j = 1; j < BUFSIZE; j++ )
tmp[j-1] = tmp[j];
- l = 0;
}
else {
if( c < 0 || c > 255 ) {
throw new EncodingException( "Encoding supports only values of 0..255." );
}
out.append( HexTable.table[ c ] );
- l += 3;
}
}
return out.toString();
diff --git a/core/java/src/net/i2p/client/MessageState.java b/core/java/src/net/i2p/client/MessageState.java
index a67b52770..9700b8b70 100644
--- a/core/java/src/net/i2p/client/MessageState.java
+++ b/core/java/src/net/i2p/client/MessageState.java
@@ -100,7 +100,7 @@ class MessageState {
}
public void waitFor(int status, long expiration) {
- long checkTime = -1;
+ //long checkTime = -1;
boolean found = false;
while (!found) {
if (_cancelled) return;
@@ -112,13 +112,13 @@ class MessageState {
}
found = false;
synchronized (_receivedStatus) {
- long beforeCheck = _context.clock().now();
+ //long beforeCheck = _context.clock().now();
if (locked_isSuccess(status) || locked_isFailure(status)) {
if (_log.shouldLog(Log.DEBUG))
_log.debug(_prefix + "Received a confirm (one way or the other)");
found = true;
}
- checkTime = _context.clock().now() - beforeCheck;
+ //checkTime = _context.clock().now() - beforeCheck;
if (!found) {
if (timeToWait > 5000) {
timeToWait = 5000;
diff --git a/core/java/src/net/i2p/client/MessageStatusMessageHandler.java b/core/java/src/net/i2p/client/MessageStatusMessageHandler.java
index 1ee979ae4..cbd49b9b0 100644
--- a/core/java/src/net/i2p/client/MessageStatusMessageHandler.java
+++ b/core/java/src/net/i2p/client/MessageStatusMessageHandler.java
@@ -27,7 +27,6 @@ class MessageStatusMessageHandler extends HandlerImpl {
}
public void handleMessage(I2CPMessage message, I2PSessionImpl session) {
- boolean skipStatus = true;
if (_log.shouldLog(Log.DEBUG))
_log.debug("Handle message " + message);
MessageStatusMessage msg = (MessageStatusMessage) message;
diff --git a/core/java/src/net/i2p/client/datagram/I2PDatagramDissector.java b/core/java/src/net/i2p/client/datagram/I2PDatagramDissector.java
index 8f60e2f2d..b8e55276e 100644
--- a/core/java/src/net/i2p/client/datagram/I2PDatagramDissector.java
+++ b/core/java/src/net/i2p/client/datagram/I2PDatagramDissector.java
@@ -61,8 +61,6 @@ public final class I2PDatagramDissector {
*/
public void loadI2PDatagram(byte[] dgram) throws DataFormatException {
ByteArrayInputStream dgStream = new ByteArrayInputStream(dgram);
- byte[] rxTrimmedPayload;
-
// set invalid(very important!)
this.valid = false;
diff --git a/core/java/src/net/i2p/crypto/CryptixRijndael_Algorithm.java b/core/java/src/net/i2p/crypto/CryptixRijndael_Algorithm.java
index e00752a38..af8815d43 100644
--- a/core/java/src/net/i2p/crypto/CryptixRijndael_Algorithm.java
+++ b/core/java/src/net/i2p/crypto/CryptixRijndael_Algorithm.java
@@ -89,8 +89,6 @@ public final class CryptixRijndael_Algorithm // implicit no-argument constructor
//...........................................................................
static {
- long time = Clock.getInstance().now();
-
if (_RDEBUG && _debuglevel > 6) {
System.out.println("Algorithm Name: Rijndael ver 0.1");
System.out.println("Electronic Codebook (ECB) Mode");
diff --git a/core/java/src/net/i2p/crypto/ElGamalAESEngine.java b/core/java/src/net/i2p/crypto/ElGamalAESEngine.java
index b5dd7f181..755b688a2 100644
--- a/core/java/src/net/i2p/crypto/ElGamalAESEngine.java
+++ b/core/java/src/net/i2p/crypto/ElGamalAESEngine.java
@@ -318,7 +318,6 @@ public class ElGamalAESEngine {
//_log.debug("Hash of entire aes block after decryption: \n" + DataHelper.toString(h.getData(), 32));
try {
SessionKey newKey = null;
- Hash readHash = null;
List tags = null;
//ByteArrayInputStream bais = new ByteArrayInputStream(decrypted);
diff --git a/core/java/src/net/i2p/data/Base64.java b/core/java/src/net/i2p/data/Base64.java
index 7f04d3985..ef7b1c618 100644
--- a/core/java/src/net/i2p/data/Base64.java
+++ b/core/java/src/net/i2p/data/Base64.java
@@ -520,10 +520,9 @@ public class Base64 {
// + ((len % 3) > 0 ? 4 : 0) // Account for padding
// + (breakLines ? (len43 / MAX_LINE_LENGTH) : 0)]; // New lines
int d = 0;
- int e = 0;
int len2 = len - 2;
int lineLength = 0;
- for (; d < len2; d += 3, e += 4) {
+ for (; d < len2; d += 3) {
//encode3to4(source, d + off, 3, outBuff, e);
encode3to4(source, d + off, 3, out, alpha);
@@ -531,7 +530,6 @@ public class Base64 {
if (breakLines && lineLength == MAX_LINE_LENGTH) {
//outBuff[e + 4] = NEW_LINE;
out.append('\n');
- e++;
lineLength = 0;
} // end if: end of line
} // en dfor: each piece of array
@@ -539,7 +537,6 @@ public class Base64 {
if (d < len) {
//encode3to4(source, d + off, len - d, outBuff, e);
encode3to4(source, d + off, len - d, out, alpha);
- e += 4;
} // end if: some padding needed
//out.append(new String(outBuff, 0, e));
diff --git a/core/java/src/net/i2p/util/FileUtil.java b/core/java/src/net/i2p/util/FileUtil.java
index 27e95bee7..8e6d874ba 100644
--- a/core/java/src/net/i2p/util/FileUtil.java
+++ b/core/java/src/net/i2p/util/FileUtil.java
@@ -212,8 +212,7 @@ public class FileUtil {
}
try {
InputStream in = zip.getInputStream(entry);
- int read = 0;
- while ( (read = in.read(buf)) != -1) {
+ while ( (in.read(buf)) != -1) {
// throw the data away
}
//System.err.println("INFO: File [" + entry.getName() + "] extracted");
diff --git a/core/java/src/net/i2p/util/LogManager.java b/core/java/src/net/i2p/util/LogManager.java
index 0d6a2f952..83ef11132 100644
--- a/core/java/src/net/i2p/util/LogManager.java
+++ b/core/java/src/net/i2p/util/LogManager.java
@@ -333,7 +333,6 @@ public class LogManager {
_fileSize = getFileSize(config.getProperty(PROP_FILESIZE, DEFAULT_FILESIZE));
_rotationLimit = -1;
try {
- String str = config.getProperty(PROP_ROTATIONLIMIT);
_rotationLimit = Integer.parseInt(config.getProperty(PROP_ROTATIONLIMIT, DEFAULT_ROTATIONLIMIT));
} catch (NumberFormatException nfe) {
System.err.println("Invalid rotation limit");
@@ -521,14 +520,12 @@ public class LogManager {
private void updateLimit(Log log) {
List limits = getLimits(log);
LogLimit max = null;
- LogLimit notMax = null;
if (limits != null) {
for (LogLimit cur : limits) {
if (max == null)
max = cur;
else {
if (cur.getRootName().length() > max.getRootName().length()) {
- notMax = max;
max = cur;
}
}
diff --git a/core/java/src/net/i2p/util/ShellCommand.java b/core/java/src/net/i2p/util/ShellCommand.java
index bb0aec5f8..a1cc2f118 100644
--- a/core/java/src/net/i2p/util/ShellCommand.java
+++ b/core/java/src/net/i2p/util/ShellCommand.java
@@ -103,10 +103,8 @@ public class ShellCommand {
@Override
public void run() {
- String streamData;
-
try {
- while ((streamData = bufferedReader.readLine()) != null) {
+ while ((bufferedReader.readLine()) != null) {
// Just like a Hoover.
}
} catch (IOException e) {
diff --git a/core/java/src/net/metanotion/io/block/index/BSkipSpan.java b/core/java/src/net/metanotion/io/block/index/BSkipSpan.java
index 38342a678..5e4481c8c 100644
--- a/core/java/src/net/metanotion/io/block/index/BSkipSpan.java
+++ b/core/java/src/net/metanotion/io/block/index/BSkipSpan.java
@@ -164,7 +164,6 @@ public class BSkipSpan extends SkipSpan {
if (nKeys <= 0 && prev != null)
bf.log.error("Flushing with no entries?" + this, new Exception());
- int ksz, vsz;
int curPage = this.page;
int[] curNextPage = new int[1];
curNextPage[0] = this.overflowPage;
diff --git a/core/java/src/net/metanotion/io/block/index/IBSkipIterator.java b/core/java/src/net/metanotion/io/block/index/IBSkipIterator.java
index a43df79c8..732862e3b 100644
--- a/core/java/src/net/metanotion/io/block/index/IBSkipIterator.java
+++ b/core/java/src/net/metanotion/io/block/index/IBSkipIterator.java
@@ -91,7 +91,6 @@ public class IBSkipIterator extends SkipIterator {
*/
@Override
public Comparable nextKey() {
- Comparable c;
if(index < ss.nKeys) {
if (ss.keys == null) {
try {
diff --git a/core/java/src/net/metanotion/util/skiplist/SkipIterator.java b/core/java/src/net/metanotion/util/skiplist/SkipIterator.java
index bc723050c..b0793d638 100644
--- a/core/java/src/net/metanotion/util/skiplist/SkipIterator.java
+++ b/core/java/src/net/metanotion/util/skiplist/SkipIterator.java
@@ -84,7 +84,6 @@ public class SkipIterator implements ListIterator {
* @throws NoSuchElementException
*/
public Comparable nextKey() {
- Comparable c;
if(index < ss.nKeys) { return ss.keys[index]; }
throw new NoSuchElementException();
}
diff --git a/router/java/src/net/i2p/router/JobQueueRunner.java b/router/java/src/net/i2p/router/JobQueueRunner.java
index 7048e0689..0d3b0af3b 100644
--- a/router/java/src/net/i2p/router/JobQueueRunner.java
+++ b/router/java/src/net/i2p/router/JobQueueRunner.java
@@ -40,7 +40,6 @@ class JobQueueRunner implements Runnable {
public void run() {
//_state = 2;
long lastActive = _context.clock().now();
- long jobNum = 0;
while ( (_keepRunning) && (_context.jobQueue().isAlive()) ) {
//_state = 3;
try {
@@ -69,7 +68,6 @@ class JobQueueRunner implements Runnable {
}
}
- long betweenJobs = now - lastActive;
_currentJob = job;
_lastJob = null;
//_state = 9;
@@ -117,7 +115,6 @@ class JobQueueRunner implements Runnable {
_lastJob = _currentJob;
_currentJob = null;
_lastEnd = lastActive;
- jobNum++;
//_state = 15;
//if ( (jobNum % 10) == 0)
diff --git a/router/java/src/net/i2p/router/networkdb/kademlia/ExpireRoutersJob.java b/router/java/src/net/i2p/router/networkdb/kademlia/ExpireRoutersJob.java
index a78ef7c77..6243d05c6 100644
--- a/router/java/src/net/i2p/router/networkdb/kademlia/ExpireRoutersJob.java
+++ b/router/java/src/net/i2p/router/networkdb/kademlia/ExpireRoutersJob.java
@@ -71,7 +71,7 @@ class ExpireRoutersJob extends JobImpl {
// no need to impose our own expiration here.
// One issue is this will queue a ton of floodfill queries the first time it is run
// after the 1h router startup grace period.
- RouterInfo ri = _facade.lookupRouterInfoLocally(key);
+ _facade.lookupRouterInfoLocally(key);
}
}
diff --git a/router/java/src/net/i2p/router/networkdb/kademlia/KBucketImpl.java b/router/java/src/net/i2p/router/networkdb/kademlia/KBucketImpl.java
index 0fc3e023b..eeff28086 100644
--- a/router/java/src/net/i2p/router/networkdb/kademlia/KBucketImpl.java
+++ b/router/java/src/net/i2p/router/networkdb/kademlia/KBucketImpl.java
@@ -391,7 +391,7 @@ class KBucketImpl implements KBucket {
//buf.append(toString(rnd.getData())).append('\n');
boolean ok = bucket.shouldContain(rnd);
if (!ok) {
- byte diff[] = bucket.getLocal().cachedXor(rnd);
+ //byte diff[] = bucket.getLocal().cachedXor(rnd);
//BigInteger dv = new BigInteger(1, diff);
//log.error("WTF! bucket doesn't want: \n" + toString(rnd.getData())
// + "\nDelta: \n" + toString(diff) + "\nDelta val: \n" + dv.toString(2)
@@ -427,7 +427,7 @@ class KBucketImpl implements KBucket {
//buf.append(toString(rnd.getData())).append('\n');
boolean ok = bucket.shouldContain(rnd);
if (!ok) {
- byte diff[] = bucket.getLocal().cachedXor(rnd);
+ //byte diff[] = bucket.getLocal().cachedXor(rnd);
//BigInteger dv = new BigInteger(1, diff);
//log.error("WTF! bucket doesn't want: \n" + toString(rnd.getData())
// + "\nDelta: \n" + toString(diff) + "\nDelta val: \n" + dv.toString(2)
diff --git a/router/java/src/net/i2p/router/networkdb/kademlia/LocalHash.java b/router/java/src/net/i2p/router/networkdb/kademlia/LocalHash.java
index a15716c87..d2b10e79d 100644
--- a/router/java/src/net/i2p/router/networkdb/kademlia/LocalHash.java
+++ b/router/java/src/net/i2p/router/networkdb/kademlia/LocalHash.java
@@ -67,8 +67,6 @@ class LocalHash extends Hash {
byte[] distance = _xorCache.get(key);
if (distance == null) {
- // not cached, lets cache it
- int cached = 0;
synchronized (_xorCache) {
int toRemove = _xorCache.size() + 1 - MAX_CACHED_XOR;
if (toRemove > 0) {
@@ -83,7 +81,6 @@ class LocalHash extends Hash {
}
distance = DataHelper.xor(key.getData(), getData());
_xorCache.put(key, distance);
- cached = _xorCache.size();
}
/****
if (_log.shouldLog(Log.DEBUG)) {
diff --git a/router/java/src/net/i2p/router/networkdb/kademlia/SearchJob.java b/router/java/src/net/i2p/router/networkdb/kademlia/SearchJob.java
index 8abd3f763..346bb4ef2 100644
--- a/router/java/src/net/i2p/router/networkdb/kademlia/SearchJob.java
+++ b/router/java/src/net/i2p/router/networkdb/kademlia/SearchJob.java
@@ -653,9 +653,6 @@ class SearchJob extends JobImpl {
TunnelInfo outTunnel = getContext().tunnelManager().selectOutboundExploratoryTunnel(to);
if (outTunnel != null) {
- TunnelId targetTunnelId = null; // not needed
- Job onSend = null; // not wanted
-
if (_log.shouldLog(Log.DEBUG))
_log.debug("resending leaseSet out to " + to + " through " + outTunnel + ": " + msg);
getContext().tunnelDispatcher().dispatchOutbound(msg, outTunnel.getSendTunnelId(0), null, to);
diff --git a/router/java/src/net/i2p/router/peermanager/PeerProfile.java b/router/java/src/net/i2p/router/peermanager/PeerProfile.java
index 59f24506c..96d9273c2 100644
--- a/router/java/src/net/i2p/router/peermanager/PeerProfile.java
+++ b/router/java/src/net/i2p/router/peermanager/PeerProfile.java
@@ -625,7 +625,6 @@ public class PeerProfile {
System.out.println(numExpanded + "/" + numCompact + ": create array - Used: " + used + " bytes (or " + usedPer + " bytes per array entry)");
int i = 0;
- int j = 0;
try {
for (; i < numExpanded; i++)
profs[i] = new PeerProfile(ctx, new Hash(new byte[Hash.HASH_LENGTH]));
diff --git a/router/java/src/net/i2p/router/startup/LoadRouterInfoJob.java b/router/java/src/net/i2p/router/startup/LoadRouterInfoJob.java
index 9b484fc5c..392a8b3c8 100644
--- a/router/java/src/net/i2p/router/startup/LoadRouterInfoJob.java
+++ b/router/java/src/net/i2p/router/startup/LoadRouterInfoJob.java
@@ -55,9 +55,6 @@ public class LoadRouterInfoJob extends JobImpl {
private void loadRouterInfo() {
String routerInfoFile = getContext().getProperty(Router.PROP_INFO_FILENAME, Router.PROP_INFO_FILENAME_DEFAULT);
RouterInfo info = null;
- boolean failedRead = false;
-
-
String keyFilename = getContext().getProperty(Router.PROP_KEYS_FILENAME, Router.PROP_KEYS_FILENAME_DEFAULT);
File rif = new File(getContext().getRouterDir(), routerInfoFile);
diff --git a/router/java/src/net/i2p/router/startup/RebuildRouterInfoJob.java b/router/java/src/net/i2p/router/startup/RebuildRouterInfoJob.java
index 045542a1a..ee92f6414 100644
--- a/router/java/src/net/i2p/router/startup/RebuildRouterInfoJob.java
+++ b/router/java/src/net/i2p/router/startup/RebuildRouterInfoJob.java
@@ -78,7 +78,6 @@ public class RebuildRouterInfoJob extends JobImpl {
}
void rebuildRouterInfo(boolean alreadyRunning) {
_log.debug("Rebuilding the new router info");
- boolean fullRebuild = false;
RouterInfo info = null;
String infoFilename = getContext().getProperty(Router.PROP_INFO_FILENAME, Router.PROP_INFO_FILENAME_DEFAULT);
File infoFile = new File(getContext().getRouterDir(), infoFilename);
@@ -158,7 +157,6 @@ public class RebuildRouterInfoJob extends JobImpl {
// this proc writes the keys and info to the file as well as builds the latest and greatest info
CreateRouterInfoJob j = new CreateRouterInfoJob(getContext(), null);
info = j.createRouterInfo();
- fullRebuild = true;
}
//MessageHistory.initialize();
diff --git a/router/java/src/net/i2p/router/transport/TransportImpl.java b/router/java/src/net/i2p/router/transport/TransportImpl.java
index 954c16426..9c0356b8f 100644
--- a/router/java/src/net/i2p/router/transport/TransportImpl.java
+++ b/router/java/src/net/i2p/router/transport/TransportImpl.java
@@ -292,9 +292,9 @@ public abstract class TransportImpl implements Transport {
}
if (log) {
+ /*
String type = msg.getMessageType();
// the udp transport logs some further details
- /*
_context.messageHistory().sendMessage(type, msg.getMessageId(),
msg.getExpiration(),
msg.getTarget().getIdentity().getHash(),
diff --git a/router/java/src/net/i2p/router/transport/TransportManager.java b/router/java/src/net/i2p/router/transport/TransportManager.java
index 2a45a0ffe..41ed91b11 100644
--- a/router/java/src/net/i2p/router/transport/TransportManager.java
+++ b/router/java/src/net/i2p/router/transport/TransportManager.java
@@ -149,7 +149,7 @@ public class TransportManager implements TransportEventListener {
configTransports();
_log.debug("Starting up the transport manager");
for (Transport t : _transports.values()) {
- RouterAddress addr = t.startListening();
+ t.startListening();
if (_log.shouldLog(Log.DEBUG))
_log.debug("Transport " + t.getStyle() + " started");
}
diff --git a/router/java/src/net/i2p/router/transport/UPnPManager.java b/router/java/src/net/i2p/router/transport/UPnPManager.java
index 1bf1f5975..6f5a721e2 100644
--- a/router/java/src/net/i2p/router/transport/UPnPManager.java
+++ b/router/java/src/net/i2p/router/transport/UPnPManager.java
@@ -120,7 +120,6 @@ class UPnPManager {
_log.debug("UPnP Callback:");
DetectedIP[] ips = _upnp.getAddress();
- byte[] detected = null;
if (ips != null) {
for (DetectedIP ip : ips) {
// store the first public one and tell the transport manager if it changed
diff --git a/router/java/src/net/i2p/router/transport/ntcp/EventPumper.java b/router/java/src/net/i2p/router/transport/ntcp/EventPumper.java
index 0639dabb4..33bf70e90 100644
--- a/router/java/src/net/i2p/router/transport/ntcp/EventPumper.java
+++ b/router/java/src/net/i2p/router/transport/ntcp/EventPumper.java
@@ -501,7 +501,7 @@ class EventPumper implements Runnable {
chan.socket().setKeepAlive(true);
SelectionKey ckey = chan.register(_selector, SelectionKey.OP_READ);
- NTCPConnection con = new NTCPConnection(_context, _transport, chan, ckey);
+ new NTCPConnection(_context, _transport, chan, ckey);
//if (_log.shouldLog(Log.DEBUG))
// _log.debug("new NTCP connection established: " +con);
} catch (IOException ioe) {
diff --git a/router/java/src/net/i2p/router/transport/ntcp/NTCPTransport.java b/router/java/src/net/i2p/router/transport/ntcp/NTCPTransport.java
index aed896803..4b5c3ef22 100644
--- a/router/java/src/net/i2p/router/transport/ntcp/NTCPTransport.java
+++ b/router/java/src/net/i2p/router/transport/ntcp/NTCPTransport.java
@@ -737,12 +737,6 @@ public class NTCPTransport extends TransportImpl {
}
long offsetTotal = 0;
- int bpsIn = 0;
- int bpsOut = 0;
- long uptimeMsTotal = 0;
- long sendTotal = 0;
- long recvTotal = 0;
- int numPeers = 0;
float bpsSend = 0;
float bpsRecv = 0;
long totalUptime = 0;
diff --git a/router/java/src/net/i2p/router/transport/udp/ACKSender.java b/router/java/src/net/i2p/router/transport/udp/ACKSender.java
index 012af9e97..c17992568 100644
--- a/router/java/src/net/i2p/router/transport/udp/ACKSender.java
+++ b/router/java/src/net/i2p/router/transport/udp/ACKSender.java
@@ -178,7 +178,7 @@ class ACKSender implements Runnable {
if (_log.shouldLog(Log.INFO))
_log.info("Sending ACK for " + ackBitfields);
- boolean ok = peer.allocateSendingBytes(ack.getPacket().getLength(), true);
+ peer.allocateSendingBytes(ack.getPacket().getLength(), true);
// ignore whether its ok or not, its a bloody ack. this should be fixed, probably.
_transport.send(ack);
diff --git a/router/java/src/net/i2p/router/transport/udp/EstablishmentManager.java b/router/java/src/net/i2p/router/transport/udp/EstablishmentManager.java
index 79a0176bf..339e41caa 100644
--- a/router/java/src/net/i2p/router/transport/udp/EstablishmentManager.java
+++ b/router/java/src/net/i2p/router/transport/udp/EstablishmentManager.java
@@ -496,7 +496,6 @@ class EstablishmentManager {
private void handleCompletelyEstablished(InboundEstablishState state) {
if (state.complete()) return;
- long now = _context.clock().now();
RouterIdentity remote = state.getConfirmedIdentity();
PeerState peer = new PeerState(_context, _transport,
state.getSentIP(), state.getSentPort(), remote.calculateHash(), true);
@@ -1076,7 +1075,6 @@ class EstablishmentManager {
if ( (nextSendTime == -1) || (delay > 0) ) {
if (delay > 1000)
delay = 1000;
- boolean interrupted = false;
try {
synchronized (_activityLock) {
if (_activity > 0)
@@ -1087,7 +1085,6 @@ class EstablishmentManager {
_activityLock.wait(delay);
}
} catch (InterruptedException ie) {
- interrupted = true;
}
// if (_log.shouldLog(Log.DEBUG))
// _log.debug("After waiting w/ nextSend=" + nextSendTime
diff --git a/router/java/src/net/i2p/router/transport/udp/InboundMessageFragments.java b/router/java/src/net/i2p/router/transport/udp/InboundMessageFragments.java
index 6bb24c225..64c52ae03 100644
--- a/router/java/src/net/i2p/router/transport/udp/InboundMessageFragments.java
+++ b/router/java/src/net/i2p/router/transport/udp/InboundMessageFragments.java
@@ -118,7 +118,6 @@ class InboundMessageFragments /*implements UDPTransport.PartialACKSource */{
continue;
}
- int size = data.readMessageFragmentSize(i);
InboundMessageState state = null;
boolean messageComplete = false;
boolean messageExpired = false;
diff --git a/router/java/src/net/i2p/router/transport/udp/MessageReceiver.java b/router/java/src/net/i2p/router/transport/udp/MessageReceiver.java
index a699aaa15..15d8b7310 100644
--- a/router/java/src/net/i2p/router/transport/udp/MessageReceiver.java
+++ b/router/java/src/net/i2p/router/transport/udp/MessageReceiver.java
@@ -115,7 +115,6 @@ class MessageReceiver {
while (_alive) {
int expired = 0;
long expiredLifetime = 0;
- int remaining = 0;
try {
while (message == null) {
message = _completeMessages.take();
diff --git a/router/java/src/net/i2p/router/transport/udp/PacketBuilder.java b/router/java/src/net/i2p/router/transport/udp/PacketBuilder.java
index a8891b62b..78b27e22c 100644
--- a/router/java/src/net/i2p/router/transport/udp/PacketBuilder.java
+++ b/router/java/src/net/i2p/router/transport/udp/PacketBuilder.java
@@ -226,7 +226,6 @@ class PacketBuilder {
int off = HEADER_SIZE;
StringBuilder msg = null;
- boolean acksIncluded = false;
if (_log.shouldLog(Log.INFO)) {
msg = new StringBuilder(128);
msg.append("Data pkt to ").append(peer.getRemotePeer().toBase64());
diff --git a/router/java/src/net/i2p/router/transport/udp/UDPTransport.java b/router/java/src/net/i2p/router/transport/udp/UDPTransport.java
index 38187c6ba..fdc3d6f93 100644
--- a/router/java/src/net/i2p/router/transport/udp/UDPTransport.java
+++ b/router/java/src/net/i2p/router/transport/udp/UDPTransport.java
@@ -1562,12 +1562,9 @@ public class UDPTransport extends TransportImpl implements TimedWeightedPriority
public int countActivePeers() {
long now = _context.clock().now();
int active = 0;
- int inactive = 0;
- for (Iterator iter = _peersByIdent.values().iterator(); iter.hasNext(); ) {
+ for (Iterator iter = _peersByIdent.values().iterator(); iter.hasNext(); ) {
PeerState peer = iter.next();
- if (now-peer.getLastReceiveTime() > 5*60*1000)
- inactive++;
- else
+ if (now-peer.getLastReceiveTime() <= 5*60*1000)
active++;
}
return active;
@@ -1577,12 +1574,9 @@ public class UDPTransport extends TransportImpl implements TimedWeightedPriority
public int countActiveSendPeers() {
long now = _context.clock().now();
int active = 0;
- int inactive = 0;
- for (Iterator iter = _peersByIdent.values().iterator(); iter.hasNext(); ) {
+ for (Iterator iter = _peersByIdent.values().iterator(); iter.hasNext(); ) {
PeerState peer = iter.next();
- if (now-peer.getLastSendFullyTime() > 1*60*1000)
- inactive++;
- else
+ if (now-peer.getLastSendFullyTime() <= 1*60*1000)
active++;
}
return active;
@@ -2089,9 +2083,9 @@ public class UDPTransport extends TransportImpl implements TimedWeightedPriority
buf.append("| ");
long skew = peer.getClockSkew();
- buf.append(DataHelper.formatDuration2(peer.getClockSkew()));
+ buf.append(DataHelper.formatDuration2(skew));
buf.append(" | ");
- offsetTotal = offsetTotal + peer.getClockSkew();
+ offsetTotal = offsetTotal + skew;
long sendWindow = peer.getSendWindowBytes();
@@ -2155,7 +2149,6 @@ public class UDPTransport extends TransportImpl implements TimedWeightedPriority
//buf.append(peer.getPacketRetransmissionRate());
buf.append("");
- double recvDupPct = (double)peer.getPacketsReceivedDuplicate()/(double)peer.getPacketsReceived();
buf.append("");
buf.append(dupRecv); //formatPct(recvDupPct));
buf.append(" | ");
diff --git a/router/java/src/net/i2p/router/tunnel/TrivialPreprocessor.java b/router/java/src/net/i2p/router/tunnel/TrivialPreprocessor.java
index 7109e4ae3..63f667804 100644
--- a/router/java/src/net/i2p/router/tunnel/TrivialPreprocessor.java
+++ b/router/java/src/net/i2p/router/tunnel/TrivialPreprocessor.java
@@ -157,8 +157,6 @@ class TrivialPreprocessor implements TunnelGateway.QueuePreprocessor {
protected int writeFirstFragment(TunnelGateway.Pending msg, byte target[], int offset) {
boolean fragmented = false;
- int origOffset = offset;
-
int instructionsLength = getInstructionsSize(msg);
int payloadLength = msg.getData().length - msg.getOffset();
if (offset + payloadLength + instructionsLength + IV_SIZE + 1 + 4 > PREPROCESSED_SIZE) {
diff --git a/router/java/src/net/i2p/router/tunnel/pool/BuildExecutor.java b/router/java/src/net/i2p/router/tunnel/pool/BuildExecutor.java
index ddde21b12..774d4763c 100644
--- a/router/java/src/net/i2p/router/tunnel/pool/BuildExecutor.java
+++ b/router/java/src/net/i2p/router/tunnel/pool/BuildExecutor.java
@@ -284,11 +284,6 @@ class BuildExecutor implements Runnable {
List wanted = new ArrayList(MAX_CONCURRENT_BUILDS);
List pools = new ArrayList(8);
- //long loopBegin = 0;
- //long afterBuildZeroHop = 0;
- long afterBuildReal = 0;
- long afterHandleInbound = 0;
-
while (_isRunning && !_manager.isShutdown()){
//loopBegin = System.currentTimeMillis();
try {
@@ -383,7 +378,6 @@ class BuildExecutor implements Runnable {
}
}
- afterBuildReal = System.currentTimeMillis();
//if (_log.shouldLog(Log.DEBUG))
// _log.debug("build loop complete, tot=" + (afterHandleInbound-loopBegin) +
diff --git a/router/java/src/net/i2p/router/tunnel/pool/BuildHandler.java b/router/java/src/net/i2p/router/tunnel/pool/BuildHandler.java
index 4e3043acf..f578f7672 100644
--- a/router/java/src/net/i2p/router/tunnel/pool/BuildHandler.java
+++ b/router/java/src/net/i2p/router/tunnel/pool/BuildHandler.java
@@ -202,8 +202,6 @@ class BuildHandler implements Runnable {
// search through the tunnels for a reply
long replyMessageId = state.msg.getUniqueId();
PooledTunnelCreatorConfig cfg = _exec.removeFromBuilding(replyMessageId);
- StringBuilder buf = null;
-
if (cfg == null) {
// cannot handle - not pending... took too long?
if (_log.shouldLog(Log.WARN))
diff --git a/router/java/src/net/i2p/router/tunnel/pool/TunnelPool.java b/router/java/src/net/i2p/router/tunnel/pool/TunnelPool.java
index 7b385a8ac..4b4b4afe0 100644
--- a/router/java/src/net/i2p/router/tunnel/pool/TunnelPool.java
+++ b/router/java/src/net/i2p/router/tunnel/pool/TunnelPool.java
@@ -903,7 +903,6 @@ public class TunnelPool {
int fallback = 0;
synchronized (_tunnels) {
- boolean enough = _tunnels.size() > wanted;
for (int i = 0; i < _tunnels.size(); i++) {
TunnelInfo info = _tunnels.get(i);
if (allowZeroHop || (info.getLength() > 1)) {