opensource/kubo
1
0
Fork 0
mirror of https://github.com/ipfs/kubo.git synced 2025-09-10 05:52:20 +08:00
Code Issues Projects Releases Wiki Activity

blockstore Allkeys: ignore non multihash keys

Browse Source
This commit is contained in:
Juan Batiz-Benet
2015-01-11 21:19:42 -08:00
parent 0d059a3881
commit 6a8414bcfb
1 changed files with 10 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
blocks/blockstore/blockstore.go
View File

@ -133,6 +133,13 @@ func (bs *blockstore) AllKeysChan(ctx context.Context, offset int, limit int) (<
// need to convert to u.Key using u.KeyFromDsKey. // need to convert to u.Key using u.KeyFromDsKey.
k = u.KeyFromDsKey(ds.NewKey(e.Key)) k = u.KeyFromDsKey(ds.NewKey(e.Key))
log.Debug("blockstore: query got key", k) log.Debug("blockstore: query got key", k)
// key must be a multihash. else ignore it.
_, err := mh.Cast([]byte(k))
if err != nil {
return "", true
}
return k, true return k, true
} }
} }
@ -149,6 +156,9 @@ func (bs *blockstore) AllKeysChan(ctx context.Context, offset int, limit int) (<
if !ok { if !ok {
return return
} }
if k == "" {
continue
}
select { select {
case <-ctx.Done(): case <-ctx.Done():