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

sealing: more logging in pledge sector flow

Browse Source
This commit is contained in:
Łukasz Magiera 2020-01-31 20:22:31 +01:00
parent b6ba0ed47c
commit 37929ff75f
2 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
storage/sealing/garbage.go
View File

@ -37,6 +37,8 @@ func (m *Sealing) pledgeSector(ctx context.Context, sectorID uint64, existingPie
return nil, nil return nil, nil
} }
log.Infof("Pledge %d, contains %+v", sectorID, existingPieceSizes)
deals := make([]actors.StorageDealProposal, len(sizes)) deals := make([]actors.StorageDealProposal, len(sizes))
for i, size := range sizes { for i, size := range sizes {
commP, err := m.fastPledgeCommitment(size, uint64(runtime.NumCPU())) commP, err := m.fastPledgeCommitment(size, uint64(runtime.NumCPU()))
@ -59,6 +61,8 @@ func (m *Sealing) pledgeSector(ctx context.Context, sectorID uint64, existingPie
deals[i] = sdp deals[i] = sdp
} }
log.Infof("Publishing deals for %d", sectorID)
params, aerr := actors.SerializeParams(&actors.PublishStorageDealsParams{ params, aerr := actors.SerializeParams(&actors.PublishStorageDealsParams{
Deals: deals, Deals: deals,
}) })
@ -78,7 +82,7 @@ func (m *Sealing) pledgeSector(ctx context.Context, sectorID uint64, existingPie
if err != nil { if err != nil {
return nil, err return nil, err
} }
r, err := m.api.StateWaitMsg(ctx, smsg.Cid()) r, err := m.api.StateWaitMsg(ctx, smsg.Cid()) // TODO: more finality
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -93,8 +97,9 @@ func (m *Sealing) pledgeSector(ctx context.Context, sectorID uint64, existingPie
return nil, xerrors.New("got unexpected number of DealIDs from PublishStorageDeals") return nil, xerrors.New("got unexpected number of DealIDs from PublishStorageDeals")
} }
out := make([]Piece, len(sizes)) log.Infof("Deals for sector %d: %+v", sectorID, resp.DealIDs)
out := make([]Piece, len(sizes))
for i, size := range sizes { for i, size := range sizes {
ppi, err := m.sb.AddPiece(ctx, size, sectorID, m.pledgeReader(size, uint64(runtime.NumCPU())), existingPieceSizes) ppi, err := m.sb.AddPiece(ctx, size, sectorID, m.pledgeReader(size, uint64(runtime.NumCPU())), existingPieceSizes)
if err != nil { if err != nil {

1
storage/sealing/sealing.go
View File

@ -121,6 +121,7 @@ func (m *Sealing) SealPiece(ctx context.Context, size uint64, r io.Reader, secto
} }
func (m *Sealing) newSector(ctx context.Context, sid uint64, dealID uint64, ppi sectorbuilder.PublicPieceInfo) error { func (m *Sealing) newSector(ctx context.Context, sid uint64, dealID uint64, ppi sectorbuilder.PublicPieceInfo) error {
log.Infof("Start sealing %d", sid)
return m.sectors.Send(sid, SectorStart{ return m.sectors.Send(sid, SectorStart{
id: sid, id: sid,
pieces: []Piece{ pieces: []Piece{