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

rename som Txn methods for better readability

Browse Source
This commit is contained in:
vyzo 2021-07-07 09:52:31 +03:00
parent 90da6227b3
commit 05dbbe9681
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
blockstore/splitstore/splitstore.go
View File

@ -489,7 +489,7 @@ func (s *SplitStore) HeadChange(_, apply []*types.TipSet) error {
if epoch-s.baseEpoch > CompactionThreshold {
// it's time to compact -- prepare the transaction and go!
s.prepareTxnProtect(curTs)
s.beginTxnProtect(curTs)
go func() {
defer atomic.StoreInt32(&s.compacting, 0)
defer s.endTxnProtect()
@ -808,7 +808,7 @@ func (s *SplitStore) doCompact(curTs *types.TipSet) error {
log.Infow("marking done", "took", time.Since(startMark), "marked", count)
// begin transactional protection with concurrent marking and fetch references created while marking
txnRefs := s.beginTxnProtect(markSet)
txnRefs := s.beginTxnConcurrentMarking(markSet)
// 1.1 Update markset for references created during marking
if len(txnRefs) > 0 {
@ -987,7 +987,7 @@ func (s *SplitStore) doCompact(curTs *types.TipSet) error {
return nil
}
func (s *SplitStore) prepareTxnProtect(curTs *types.TipSet) {
func (s *SplitStore) beginTxnProtect(curTs *types.TipSet) {
lookbackEpoch := curTs.Height() - CompactionLookback
log.Info("preparing compaction transaction")
@ -999,7 +999,7 @@ func (s *SplitStore) prepareTxnProtect(curTs *types.TipSet) {
s.txnLookbackEpoch = lookbackEpoch
}
func (s *SplitStore) beginTxnProtect(markSet MarkSet) map[cid.Cid]struct{} {
func (s *SplitStore) beginTxnConcurrentMarking(markSet MarkSet) map[cid.Cid]struct{} {
s.txnLk.Lock()
defer s.txnLk.Unlock()