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

storagefsm: More logging for deal test debugging

Browse Source
This commit is contained in:
Łukasz Magiera 2021-01-20 22:44:18 +01:00
parent b9a9f23204
commit df14f156e1
1 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
extern/storage-sealing/input.go vendored
View File

@ -28,6 +28,7 @@ func (m *Sealing) handleWaitDeals(ctx statemachine.Context, sector SectorInfo) e
m.inputLk.Unlock() m.inputLk.Unlock()
// we send another SectorStartPacking in case one was sent in the handleAddPiece state // we send another SectorStartPacking in case one was sent in the handleAddPiece state
log.Infow("starting to seal deal sector", "sector", sector.SectorNumber, "trigger", "wait-timeout")
return ctx.Send(SectorStartPacking{}) return ctx.Send(SectorStartPacking{})
} }
} }
@ -44,6 +45,7 @@ func (m *Sealing) handleWaitDeals(ctx statemachine.Context, sector SectorInfo) e
if len(sector.dealIDs()) >= maxDeals { if len(sector.dealIDs()) >= maxDeals {
// can't accept more deals // can't accept more deals
log.Infow("starting to seal deal sector", "sector", sector.SectorNumber, "trigger", "maxdeals")
return ctx.Send(SectorStartPacking{}) return ctx.Send(SectorStartPacking{})
} }
@ -54,6 +56,7 @@ func (m *Sealing) handleWaitDeals(ctx statemachine.Context, sector SectorInfo) e
if used.Padded() == abi.PaddedPieceSize(ssize) { if used.Padded() == abi.PaddedPieceSize(ssize) {
// sector full // sector full
log.Infow("starting to seal deal sector", "sector", sector.SectorNumber, "trigger", "filled")
return ctx.Send(SectorStartPacking{}) return ctx.Send(SectorStartPacking{})
} }
@ -69,10 +72,13 @@ func (m *Sealing) handleWaitDeals(ctx statemachine.Context, sector SectorInfo) e
if now.After(sealTime) { if now.After(sealTime) {
m.inputLk.Unlock() m.inputLk.Unlock()
log.Infow("starting to seal deal sector", "sector", sector.SectorNumber, "trigger", "wait-timeout")
return ctx.Send(SectorStartPacking{}) return ctx.Send(SectorStartPacking{})
} }
m.sectorTimers[m.minerSectorID(sector.SectorNumber)] = time.AfterFunc(sealTime.Sub(now), func() { m.sectorTimers[m.minerSectorID(sector.SectorNumber)] = time.AfterFunc(sealTime.Sub(now), func() {
log.Infow("starting to seal deal sector", "sector", sector.SectorNumber, "trigger", "wait-timer")
if err := ctx.Send(SectorStartPacking{}); err != nil { if err := ctx.Send(SectorStartPacking{}); err != nil {
log.Errorw("sending SectorStartPacking event failed", "sector", sector.SectorNumber, "error", err) log.Errorw("sending SectorStartPacking event failed", "sector", sector.SectorNumber, "error", err)
} }
@ -175,6 +181,8 @@ func (m *Sealing) handleAddPiece(ctx statemachine.Context, sector SectorInfo) er
}) })
} }
time.Sleep(1 * time.Second) // TODO: deal tests are unhappy without this
ppi, err := m.sealer.AddPiece(sectorstorage.WithPriority(ctx.Context(), DealSectorPriority), ppi, err := m.sealer.AddPiece(sectorstorage.WithPriority(ctx.Context(), DealSectorPriority),
m.minerSector(sector.SectorType, sector.SectorNumber), m.minerSector(sector.SectorType, sector.SectorNumber),
pieceSizes, pieceSizes,
@ -186,6 +194,8 @@ func (m *Sealing) handleAddPiece(ctx statemachine.Context, sector SectorInfo) er
return ctx.Send(SectorAddPieceFailed{err}) return ctx.Send(SectorAddPieceFailed{err})
} }
log.Infow("deal added to a sector", "deal", deal.deal.DealID, "sector", sector.SectorNumber, "piece", ppi.PieceCID)
deal.accepted(sector.SectorNumber, offset, nil) deal.accepted(sector.SectorNumber, offset, nil)
offset += deal.size offset += deal.size