zzz/i2p.i2p
1
0
Fork 0
forked from I2P_Developers/i2p.i2p
Code Issues Pull Requests Packages Projects Releases Wiki Activity

* i2psnark: Don't prefer leeches during end game, to

Browse Source 
prevent slowdowns or stalls
This commit is contained in:
zzz
2014-07-19 12:48:16 +00:00
parent df81006b42
commit 5d21738410
3 changed files with 13 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
apps/i2psnark/java/src/org/klomp/snark/PeerCoordinator.java
View File

@@ -1202,22 +1202,23 @@ class PeerCoordinator implements PeerListener
boolean skipped = false; boolean skipped = false;
for(Piece piece : wantedPieces) { for(Piece piece : wantedPieces) {
if (piece.getId() == savedPiece) { if (piece.getId() == savedPiece) {
if (peer.isCompleted() && piece.getPeerCount() > 1) { if (peer.isCompleted() && piece.getPeerCount() > 1 &&
wantedPieces.size() > 2*END_GAME_THRESHOLD) {
// Try to preserve rarest-first // Try to preserve rarest-first
// by not requesting a partial piece that non-seeders also have // by not requesting a partial piece that at least two non-seeders also have
// from a seeder // from a seeder
boolean nonSeeds = false; int nonSeeds = 0;
for (Peer pr : peers) { for (Peer pr : peers) {
PeerState state = pr.state; PeerState state = pr.state;
if (state == null) continue; if (state == null) continue;
BitField bf = state.bitfield; BitField bf = state.bitfield;
if (bf == null) continue; if (bf == null) continue;
if (bf.get(savedPiece) && !pr.isCompleted()) { if (bf.get(savedPiece) && !pr.isCompleted()) {
nonSeeds = true; if (++nonSeeds > 1)
break; break;
} }
} }
if (nonSeeds) { if (nonSeeds > 1) {
skipped = true; skipped = true;
break; break;
} }

5
history.txt
View File

@@ -1,3 +1,8 @@
2014-07-19 zzz
* i2psnark: Don't prefer leeches during end game, to
prevent slowdowns or stalls
* Streaming; Disable fail-fast for now.
2014-07-15 str4d 2014-07-15 str4d
* I2CP: Stubs for I2CP connections over Unix domain sockets * I2CP: Stubs for I2CP connections over Unix domain sockets

2
router/java/src/net/i2p/router/RouterVersion.java
View File

@@ -18,7 +18,7 @@ public class RouterVersion {
/** deprecated */ /** deprecated */
public final static String ID = "Monotone"; public final static String ID = "Monotone";
public final static String VERSION = CoreVersion.VERSION; public final static String VERSION = CoreVersion.VERSION;
public final static long BUILD = 15; public final static long BUILD = 16;
/** for example "-test" */ /** for example "-test" */
public final static String EXTRA = ""; public final static String EXTRA = "";