coosld/kubo
1
0
Fork 0
mirror of https://github.com/ipfs/kubo.git synced 2026-02-26 04:47:45 +08:00
Code Issues Actions 13 Packages Projects Releases Wiki Activity

misc(bitswap) renaming

Browse Source 
License: MIT
Signed-off-by: Brian Tiger Chow <brian@perfmode.com>
This commit is contained in:
Brian Tiger Chow 2014-11-19 09:40:21 -08:00 committed by Jeromy
parent f8243c36be
commit 9af9ee6255
1 changed files with 20 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

39
exchange/bitswap/bitswap.go
View File

@ -153,14 +153,14 @@ func (bs *bitswap) sendWantListTo(ctx context.Context, peers <-chan peer.Peer) e
func (bs *bitswap) run(ctx context.Context) {
const batchDelay = time.Millisecond * 3 // Time to wait before sending out wantlists to better batch up requests
const numKeysPerBatch = 10
const maxProvidersPerRequest = 6
const rebroadcastPeriod = time.Second * 5 // Every so often, we should resend out our current want list
const batchDelay = time.Millisecond * 3 // Time to wait before sending out wantlists to better batch up requests
const peersPerSend = 6
const threshold = 10
var sendlist <-chan peer.Peer // NB: must be initialized to zero value
var providers <-chan peer.Peer // NB: must be initialized to zero value
broadcastSignal := time.After(rebroadcastPeriod)
unsent := 0
unsentKeys := 0
for {
select {
@ -169,32 +169,33 @@ func (bs *bitswap) run(ctx context.Context) {
if len(wantlist) == 0 {
continue
}
if sendlist == nil {
if providers == nil {
// rely on semi randomness of maps
firstKey := wantlist[0]
sendlist = bs.routing.FindProvidersAsync(ctx, firstKey, 6)
providers = bs.routing.FindProvidersAsync(ctx, firstKey, 6)
}
err := bs.sendWantListTo(ctx, sendlist)
err := bs.sendWantListTo(ctx, providers)
if err != nil {
log.Errorf("error sending wantlist: %s", err)
}
sendlist = nil
providers = nil
broadcastSignal = time.After(rebroadcastPeriod)
case k := <-bs.blockRequests:
if unsent == 0 {
sendlist = bs.routing.FindProvidersAsync(ctx, k, peersPerSend)
}
unsent++
if unsent >= threshold {
// send wantlist to sendlist
err := bs.sendWantListTo(ctx, sendlist)
case k := <-bs.blockRequests:
if unsentKeys == 0 {
providers = bs.routing.FindProvidersAsync(ctx, k, maxProvidersPerRequest)
}
unsentKeys++
if unsentKeys >= numKeysPerBatch {
// send wantlist to providers
err := bs.sendWantListTo(ctx, providers)
if err != nil {
log.Errorf("error sending wantlist: %s", err)
}
unsent = 0
unsentKeys = 0
broadcastSignal = time.After(rebroadcastPeriod)
sendlist = nil
providers = nil
} else {
// set a timeout to wait for more blocks or send current wantlist