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

storagefsm: Don't log the SectorRestart event

Browse Source
This commit is contained in:
Łukasz Magiera 2021-03-11 12:52:34 +01:00
parent 3be4984d9d
commit a1b6a2f011
1 changed files with 12 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
extern/storage-sealing/fsm.go vendored
View File

@ -191,10 +191,7 @@ var fsmPlanners = map[SectorState]func(events []statemachine.Event, state *Secto
FailedUnrecoverable: final, FailedUnrecoverable: final,
} }
func (m *Sealing) plan(events []statemachine.Event, state *SectorInfo) (func(statemachine.Context, SectorInfo) error, uint64, error) { func (m *Sealing) logEvents(events []statemachine.Event, state *SectorInfo) {
/////
// First process all events
for _, event := range events { for _, event := range events {
e, err := json.Marshal(event) e, err := json.Marshal(event)
if err != nil { if err != nil {
@ -202,6 +199,10 @@ func (m *Sealing) plan(events []statemachine.Event, state *SectorInfo) (func(sta
continue continue
} }
if event.User == (SectorRestart{}) {
continue // don't log on every fsm restart
}
l := Log{ l := Log{
Timestamp: uint64(time.Now().Unix()), Timestamp: uint64(time.Now().Unix()),
Message: string(e), Message: string(e),
@ -225,6 +226,13 @@ func (m *Sealing) plan(events []statemachine.Event, state *SectorInfo) (func(sta
state.Log = append(state.Log, l) state.Log = append(state.Log, l)
} }
}
func (m *Sealing) plan(events []statemachine.Event, state *SectorInfo) (func(statemachine.Context, SectorInfo) error, uint64, error) {
/////
// First process all events
m.logEvents(events, state)
if m.notifee != nil { if m.notifee != nil {
defer func(before SectorInfo) { defer func(before SectorInfo) {