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

handle MDB_KEY_EXIST in tracking store Puts

Browse Source
This commit is contained in:
vyzo 2021-02-27 10:03:41 +02:00
parent 9977f5c3ec
commit e79445123f
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
chain/store/splitstore/snoop_lmdb.go
View File

@ -68,7 +68,11 @@ func (s *LMDBTrackingStore) Put(cid cid.Cid, epoch abi.ChainEpoch) error {
return withMaxReadersRetry(
func() error {
return s.env.Update(func(txn *lmdb.Txn) error {
return txn.Put(s.db, cid.Hash(), val, 0)
err := txn.Put(s.db, cid.Hash(), val, 0)
if err == nil || lmdb.IsErrno(err, lmdb.KeyExist) {
return nil
}
return err
})
})
}
@ -80,9 +84,10 @@ func (s *LMDBTrackingStore) PutBatch(cids []cid.Cid, epoch abi.ChainEpoch) error
return s.env.Update(func(txn *lmdb.Txn) error {
for _, cid := range cids {
err := txn.Put(s.db, cid.Hash(), val, 0)
if err != nil {
return err
if err == nil || lmdb.IsErrno(err, lmdb.KeyExist) {
continue
}
return err
}
return nil