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

synchronously mark live refs on put/putmany

Browse Source
This commit is contained in:
vyzo 2022-02-01 09:07:14 +02:00
parent 37673c6de6
commit 3aabb0314a
1 changed files with 4 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
blockstore/splitstore/splitstore.go
View File

@ -370,10 +370,10 @@ func (s *SplitStore) Put(ctx context.Context, blk blocks.Block) error {
} }
s.txnLk.RLock() s.txnLk.RLock()
defer s.txnLk.RUnlock()
err := s.hot.Put(ctx, blk) err := s.hot.Put(ctx, blk)
if err != nil { if err != nil {
s.txnLk.RUnlock()
return err return err
} }
@ -381,13 +381,9 @@ func (s *SplitStore) Put(ctx context.Context, blk blocks.Block) error {
// critical section // critical section
if s.txnMarkSet != nil { if s.txnMarkSet != nil {
go func() { s.markLiveRefs([]cid.Cid{blk.Cid()})
defer s.txnLk.RUnlock()
s.markLiveRefs([]cid.Cid{blk.Cid()})
}()
return nil return nil
} }
defer s.txnLk.RUnlock()
s.trackTxnRef(blk.Cid()) s.trackTxnRef(blk.Cid())
return nil return nil
@ -425,10 +421,10 @@ func (s *SplitStore) PutMany(ctx context.Context, blks []blocks.Block) error {
} }
s.txnLk.RLock() s.txnLk.RLock()
defer s.txnLk.RUnlock()
err := s.hot.PutMany(ctx, blks) err := s.hot.PutMany(ctx, blks)
if err != nil { if err != nil {
s.txnLk.RUnlock()
return err return err
} }
@ -436,13 +432,9 @@ func (s *SplitStore) PutMany(ctx context.Context, blks []blocks.Block) error {
// critical section // critical section
if s.txnMarkSet != nil { if s.txnMarkSet != nil {
go func() { s.markLiveRefs(batch)
defer s.txnLk.RUnlock()
s.markLiveRefs(batch)
}()
return nil return nil
} }
defer s.txnLk.RUnlock()
s.trackTxnRefMany(batch) s.trackTxnRefMany(batch)
return nil return nil