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

only occur check for DAGs

Browse Source
This commit is contained in:
vyzo 2021-07-05 11:11:08 +03:00
parent c81ae5fc20
commit 839f7bd2b5
1 changed files with 14 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
blockstore/splitstore/splitstore.go
View File

@ -1205,19 +1205,21 @@ func (s *SplitStore) walkObjectIncomplete(c cid.Cid, walked *cid.Set, f, missing
return nil return nil
} }
// occurs check // occurs check -- only for DAGs
has, err := s.hot.Has(c) if c.Prefix().Codec == cid.DagCBOR {
if err != nil { has, err := s.hot.Has(c)
return xerrors.Errorf("error occur checking %s: %w", c, err) if err != nil {
} return xerrors.Errorf("error occur checking %s: %w", c, err)
if !has {
err = missing(c)
if err == errStopWalk {
return nil
} }
return err if !has {
err = missing(c)
if err == errStopWalk {
return nil
}
return err
}
} }
if err := f(c); err != nil { if err := f(c); err != nil {
@ -1233,7 +1235,7 @@ func (s *SplitStore) walkObjectIncomplete(c cid.Cid, walked *cid.Set, f, missing
} }
var links []cid.Cid var links []cid.Cid
err = s.view(c, func(data []byte) error { err := s.view(c, func(data []byte) error {
return cbg.ScanForLinks(bytes.NewReader(data), func(c cid.Cid) { return cbg.ScanForLinks(bytes.NewReader(data), func(c cid.Cid) {
links = append(links, c) links = append(links, c)
}) })