flush move log when cold collection is done
This commit is contained in:
		
							parent
							
								
									fc247e4223
								
							
						
					
					
						commit
						fce7b8dc9b
					
				| @ -43,6 +43,14 @@ func (d *debugLog) LogMove(curTs *types.TipSet, cid cid.Cid, writeEpoch abi.Chai | |||||||
| 	// TODO
 | 	// TODO
 | ||||||
| } | } | ||||||
| 
 | 
 | ||||||
|  | func (d *debugLog) FlushMove() { | ||||||
|  | 	if d == nil { | ||||||
|  | 		return | ||||||
|  | 	} | ||||||
|  | 
 | ||||||
|  | 	// TODO
 | ||||||
|  | } | ||||||
|  | 
 | ||||||
| func (d *debugLog) Close() error { | func (d *debugLog) Close() error { | ||||||
| 	if d == nil { | 	if d == nil { | ||||||
| 		return nil | 		return nil | ||||||
|  | |||||||
| @ -806,6 +806,8 @@ func (s *SplitStore) doCompact(curTs *types.TipSet) error { | |||||||
| 		return nil | 		return nil | ||||||
| 	}) | 	}) | ||||||
| 
 | 
 | ||||||
|  | 	s.debug.FlushMove() | ||||||
|  | 
 | ||||||
| 	if err != nil { | 	if err != nil { | ||||||
| 		return xerrors.Errorf("error collecting cold objects: %w", err) | 		return xerrors.Errorf("error collecting cold objects: %w", err) | ||||||
| 	} | 	} | ||||||
|  | |||||||
		Loading…
	
		Reference in New Issue
	
	Block a user