I2P_Developers/i2p.itoopie
3
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

fix extension messages

Browse Source
This commit is contained in:
zzz
2010-12-02 16:17:28 +00:00
parent 2c8421d8ad
commit 3d6a5bd9e7
3 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
apps/i2psnark/java/src/org/klomp/snark/PeerConnectionIn.java
View File

@ -178,6 +178,7 @@ class PeerConnectionIn implements Runnable
ps.extensionMessage(id, payload);
if (_log.shouldLog(Log.DEBUG))
_log.debug("Received extension message from " + peer + " on " + peer.metainfo.getName());
break;
default:
byte[] bs = new byte[i-1];
din.readFully(bs);

5
apps/i2psnark/java/src/org/klomp/snark/PeerConnectionOut.java
View File

@ -543,9 +543,8 @@ class PeerConnectionOut implements Runnable
m.type = Message.EXTENSION;
m.piece = id;
m.data = bytes;
m.begin = 0;
m.length = bytes.length;
m.off = 0;
m.len = bytes.length;
addMessage(m);
}
}

5
apps/i2psnark/java/src/org/klomp/snark/PeerState.java
View File

@ -493,7 +493,10 @@ class PeerState implements DataLoader
Map map = bev.getMap();
if (_log.shouldLog(Log.DEBUG))
_log.debug("Got extension handshake message " + bev.toString());
} catch (Exception e) {}
} catch (Exception e) {
if (_log.shouldLog(Log.DEBUG))
_log.debug("Failed extension decode", e);
}
} else {
if (_log.shouldLog(Log.DEBUG))
_log.debug("Got extended message type: " + id + " length: " + bs.length);