diff --git a/extern/storage-sealing/input.go b/extern/storage-sealing/input.go index b69cf8c19ea..875c33cdf17 100644 --- a/extern/storage-sealing/input.go +++ b/extern/storage-sealing/input.go @@ -60,6 +60,10 @@ func (m *Sealing) handleWaitDeals(ctx statemachine.Context, sector SectorInfo) e return ctx.Send(SectorAddPiece{}) }, } + } else { + // make sure we're only accounting for pieces which were correctly added + // (note that m.assignedPieces[sid] will always be empty here) + m.openSectors[sid].used = used } go func() {