idk/muwire
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

download pieces sequentially if over a threshold

Browse Source
This commit is contained in:
Zlatin Balevsky
2019-05-29 09:19:09 +01:00
parent 64bcb63dd9
commit 89b07ba350
1 changed files with 14 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
core/src/main/groovy/com/muwire/core/download/Pieces.groovy
View File

@@ -3,16 +3,29 @@ package com.muwire.core.download
class Pieces { class Pieces {
private final BitSet bitSet private final BitSet bitSet
private final int nPieces private final int nPieces
private final float ratio
private final Random random = new Random() private final Random random = new Random()
Pieces(int nPieces) { Pieces(int nPieces) {
this(nPieces, 1.0f)
}
Pieces(int nPieces, float ratio) {
this.nPieces = nPieces this.nPieces = nPieces
this.ratio = ratio
bitSet = new BitSet(nPieces) bitSet = new BitSet(nPieces)
} }
synchronized int getRandomPiece() { synchronized int getRandomPiece() {
if (isComplete()) int cardinality = bitSet.cardinality()
if (cardinality == nPieces)
return -1 return -1
// if fuller than ratio just do sequential
if ( (1.0f * cardinality) / nPieces > ratio) {
return bitSet.nextClearBit(0)
}
while(true) { while(true) {
int start = random.nextInt(nPieces) int start = random.nextInt(nPieces)
while(bitSet.get(start) && ++start < nPieces); while(bitSet.get(start) && ++start < nPieces);