diff --git a/apps/i2psnark/java/src/org/klomp/snark/ExtensionHandler.java b/apps/i2psnark/java/src/org/klomp/snark/ExtensionHandler.java
index 001897764e03a94af60671d870e5829918e21302..1835ffe90c0de2a165aaa2e82c2d70df0023e254 100644
--- a/apps/i2psnark/java/src/org/klomp/snark/ExtensionHandler.java
+++ b/apps/i2psnark/java/src/org/klomp/snark/ExtensionHandler.java
@@ -90,17 +90,20 @@ abstract class ExtensionHandler {
peer.setHandshakeMap(map);
Map<String, BEValue> msgmap = map.get("m").getMap();
- if (msgmap.get(TYPE_PEX) != null) {
- if (log.shouldLog(Log.DEBUG))
- log.debug("Peer supports PEX extension: " + peer);
- // peer state calls peer listener calls sendPEX()
- }
+ if (log.shouldLog(Log.DEBUG))
+ log.debug("Peer " + peer + " supports extensions: " + msgmap.keySet());
- if (msgmap.get(TYPE_DHT) != null) {
- if (log.shouldLog(Log.DEBUG))
- log.debug("Peer supports DHT extension: " + peer);
- // peer state calls peer listener calls sendDHT()
- }
+ //if (msgmap.get(TYPE_PEX) != null) {
+ // if (log.shouldLog(Log.DEBUG))
+ // log.debug("Peer supports PEX extension: " + peer);
+ // // peer state calls peer listener calls sendPEX()
+ //}
+
+ //if (msgmap.get(TYPE_DHT) != null) {
+ // if (log.shouldLog(Log.DEBUG))
+ // log.debug("Peer supports DHT extension: " + peer);
+ // // peer state calls peer listener calls sendDHT()
+ //}
MagnetState state = peer.getMagnetState();
diff --git a/apps/i2psnark/java/src/org/klomp/snark/Peer.java b/apps/i2psnark/java/src/org/klomp/snark/Peer.java
index 9a4e3524db0676e89a6a5a5511eb33060fefaaf9..d612ce0275a4d90626abee9d5314a191e3748abe 100644
--- a/apps/i2psnark/java/src/org/klomp/snark/Peer.java
+++ b/apps/i2psnark/java/src/org/klomp/snark/Peer.java
@@ -82,12 +82,12 @@ public class Peer implements Comparable<Peer>
// bytes per bt spec: 0011223344556677
private static final long OPTION_EXTENSION = 0x0000000000100000l;
private static final long OPTION_FAST = 0x0000000000000004l;
- private static final long OPTION_DHT = 0x0000000000000001l;
+ //private static final long OPTION_DHT = 0x0000000000000001l;
/** we use a different bit since the compact format is different */
/* no, let's use an extension message
static final long OPTION_I2P_DHT = 0x0000000040000000l;
*/
- private static final long OPTION_AZMP = 0x1000000000000000l;
+ //private static final long OPTION_AZMP = 0x1000000000000000l;
private long options;
/**
@@ -388,7 +388,7 @@ public class Peer implements Comparable<Peer>
if (options != 0) {
// send them something in runConnection() above
if (_log.shouldLog(Log.DEBUG))
- _log.debug("Peer supports options 0x" + Long.toString(options, 16) + ": " + toString());
+ _log.debug("Peer supports options 0x" + Long.toHexString(options) + ": " + toString());
}
return bs;
diff --git a/apps/i2psnark/java/src/org/klomp/snark/PeerConnectionIn.java b/apps/i2psnark/java/src/org/klomp/snark/PeerConnectionIn.java
index 962034ab842de7a3470a065030c4b88f199f8d1a..1f47b59b6056c00addf57a7d435e5dfef3fd923f 100644
--- a/apps/i2psnark/java/src/org/klomp/snark/PeerConnectionIn.java
+++ b/apps/i2psnark/java/src/org/klomp/snark/PeerConnectionIn.java
@@ -98,8 +98,6 @@ class PeerConnectionIn implements Runnable
}
byte b = din.readByte();
- Message m = new Message();
- m.type = b;
switch (b)
{
case Message.CHOKE:
diff --git a/apps/i2psnark/java/src/org/klomp/snark/PeerConnectionOut.java b/apps/i2psnark/java/src/org/klomp/snark/PeerConnectionOut.java
index 6b11200b6a1ac747ffd6bb9afe40ff9d01405a5e..194ae22cdeeea3810bbc9debfebf2ec0febfde64 100644
--- a/apps/i2psnark/java/src/org/klomp/snark/PeerConnectionOut.java
+++ b/apps/i2psnark/java/src/org/klomp/snark/PeerConnectionOut.java
@@ -286,6 +286,8 @@ class PeerConnectionOut implements Runnable
r.piece = m.piece;
r.begin = m.begin;
r.length = m.length;
+ if (_log.shouldLog(Log.DEBUG))
+ _log.debug("Send " + peer + ": " + r);
try {
r.sendMessage(dout);
} catch (IOException ioe) {}
@@ -525,7 +527,8 @@ class PeerConnectionOut implements Runnable
}
/**
- * Remove all Request messages from the queue
+ * Remove all Request messages from the queue.
+ * Does not send a cancel message.
* @since 0.8.2
*/
void cancelRequestMessages() {
@@ -537,9 +540,12 @@ class PeerConnectionOut implements Runnable
}
}
- // Called by the PeerState when the other side doesn't want this
- // request to be handled anymore. Removes any pending Piece Message
- // from out send queue.
+ /**
+ * Called by the PeerState when the other side doesn't want this
+ * request to be handled anymore. Removes any pending Piece Message
+ * from out send queue.
+ * Does not send a cancel message.
+ */
void cancelRequest(int piece, int begin, int length)
{
synchronized (sendQueue)
diff --git a/apps/i2psnark/java/src/org/klomp/snark/PeerState.java b/apps/i2psnark/java/src/org/klomp/snark/PeerState.java
index 675b42bf116bdb9178d6c574eb32d468520a8f12..cf29c415fbd9b13e8c5d2fe92aa0ec452813298c 100644
--- a/apps/i2psnark/java/src/org/klomp/snark/PeerState.java
+++ b/apps/i2psnark/java/src/org/klomp/snark/PeerState.java
@@ -165,9 +165,15 @@ class PeerState implements DataLoader
* @since 0.9.21
*/
private void bitfieldMessage(byte[] bitmap, boolean isAll) {
+ if (_log.shouldLog(Log.DEBUG)) {
+ if (bitmap != null)
+ _log.debug(peer + " rcv bitfield bytes: " + bitmap.length);
+ else if (isAll)
+ _log.debug(peer + " rcv bitfield HAVE_ALL");
+ else
+ _log.debug(peer + " rcv bitfield HAVE_NONE");
+ }
synchronized(this) {
- if (_log.shouldLog(Log.DEBUG))
- _log.debug(peer + " rcv bitfield");
if (bitfield != null)
{
// XXX - Be liberal in what you accept?