opensource/kubo
1
0
Fork 0
mirror of https://github.com/ipfs/kubo.git synced 2025-07-02 03:28:25 +08:00
Code Issues Projects Releases Wiki Activity

fix: batches of blocks have equal priority

Browse Source 
addresses...

https://github.com/jbenet/go-ipfs/pull/438/files#r21878994

License: MIT
Signed-off-by: Brian Tiger Chow <brian@perfmode.com>
This commit is contained in:
Brian Tiger Chow
2014-12-17 03:37:49 -08:00
committed by Juan Batiz-Benet
parent bd3ee739b9
commit 8100582e38
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
exchange/bitswap/bitswap.go
View File

@ -3,6 +3,7 @@
package bitswap package bitswap
import ( import (
"math"
"sync" "sync"
"time" "time"
@ -30,6 +31,8 @@ const (
providerRequestTimeout = time.Second * 10 providerRequestTimeout = time.Second * 10
hasBlockTimeout = time.Second * 15 hasBlockTimeout = time.Second * 15
sizeBatchRequestChan = 32 sizeBatchRequestChan = 32
// kMaxPriority is the max priority as defined by the bitswap protocol
kMaxPriority = math.MaxInt32
) )
var ( var (
@ -261,7 +264,7 @@ func (bs *bitswap) clientWorker(parent context.Context) {
continue continue
} }
for i, k := range ks { for i, k := range ks {
bs.wantlist.Add(k, len(ks)-i) bs.wantlist.Add(k, kMaxPriority-i)
} }
// NB: send want list to providers for the first peer in this list. // NB: send want list to providers for the first peer in this list.
// the assumption is made that the providers of the first key in // the assumption is made that the providers of the first key in