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

remove early occurs check from trackTxnRef

Browse Source 
this happens inline, and it might block when using the badger markset
This commit is contained in:
vyzo 2021-07-22 14:31:39 +03:00
parent 2891a31c99
commit f75d982c76
1 changed files with 0 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
blockstore/splitstore/splitstore_compact.go
View File

@ -184,16 +184,6 @@ func (s *SplitStore) trackTxnRef(c cid.Cid) {
return return
} }
if s.txnProtect != nil {
mark, err := s.txnProtect.Has(c)
if err != nil {
log.Warnf("error checking markset: %s", err)
// track it anyways
} else if mark {
return
}
}
s.txnRefsMx.Lock() s.txnRefsMx.Lock()
s.txnRefs[c] = struct{}{} s.txnRefs[c] = struct{}{}
s.txnRefsMx.Unlock() s.txnRefsMx.Unlock()
@ -209,27 +199,11 @@ func (s *SplitStore) trackTxnRefMany(cids []cid.Cid) {
s.txnRefsMx.Lock() s.txnRefsMx.Lock()
defer s.txnRefsMx.Unlock() defer s.txnRefsMx.Unlock()
quiet := false
for _, c := range cids { for _, c := range cids {
if isUnitaryObject(c) { if isUnitaryObject(c) {
continue continue
} }
if s.txnProtect != nil {
mark, err := s.txnProtect.Has(c)
if err != nil {
if !quiet {
quiet = true
log.Warnf("error checking markset: %s", err)
}
// track it anyways
}
if mark {
continue
}
}
s.txnRefs[c] = struct{}{} s.txnRefs[c] = struct{}{}
} }