cerc-io/lotus
16
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

badger/AllKeysChan(): respect context.

Browse Source
This commit is contained in:
Raúl Kripalani 2020-11-11 23:12:16 +00:00
parent 6f593d53d0
commit 04a866121e
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
lib/blockstore/badger/blockstore.go
View File

@ -359,7 +359,11 @@ func (b *Blockstore) AllKeysChan(ctx context.Context) (<-chan cid.Cid, error) {
buf = make([]byte, reqlen) buf = make([]byte, reqlen)
} }
if n, err := base32.RawStdEncoding.Decode(buf, k); err == nil { if n, err := base32.RawStdEncoding.Decode(buf, k); err == nil {
ch <- cid.NewCidV1(cid.Raw, buf[:n]) select {
case ch <- cid.NewCidV1(cid.Raw, buf[:n]):
case <-ctx.Done():
return
}
} else { } else {
log.Warnf("failed to decode key %s in badger AllKeysChan; err: %s", k, err) log.Warnf("failed to decode key %s in badger AllKeysChan; err: %s", k, err)
} }