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

remove stale references to lmdb from splitstore implementation

Browse Source
This commit is contained in:
vyzo 2021-02-28 13:23:08 +02:00
parent f62999d2b8
commit 05fee27840
1 changed files with 1 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
chain/store/splitstore/splitstore.go
View File

@ -10,8 +10,6 @@ import (
"golang.org/x/xerrors"
"github.com/ledgerwatch/lmdb-go/lmdb"
blocks "github.com/ipfs/go-block-format"
cid "github.com/ipfs/go-cid"
dstore "github.com/ipfs/go-datastore"
@ -171,7 +169,7 @@ func (s *SplitStore) Put(blk blocks.Block) error {
s.mx.Unlock()
err := s.snoop.Put(blk.Cid(), epoch)
if err != nil && !lmdb.IsErrno(err, lmdb.KeyExist) {
if err != nil {
log.Errorf("error tracking CID in hotstore: %s; falling back to coldstore", err)
return s.cold.Put(blk)
}
@ -196,17 +194,6 @@ func (s *SplitStore) PutMany(blks []blocks.Block) error {
err := s.snoop.PutBatch(batch, epoch)
if err != nil {
if lmdb.IsErrno(err, lmdb.KeyExist) {
// a write is duplicate, but we don't know which; write each block separately
for _, blk := range blks {
err = s.Put(blk)
if err != nil {
return err
}
}
return nil
}
log.Errorf("error tracking CIDs in hotstore: %s; falling back to coldstore", err)
return s.cold.PutMany(blks)
}