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

workers: gofmt

Browse Source
This commit is contained in:
Łukasz Magiera 2020-03-25 21:20:24 +01:00
parent 8c63b25704
commit db93e784ab
2 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
manager.go
View File

@ -119,9 +119,15 @@ func New(ctx context.Context, ls stores.LocalStorage, si stores.SectorIndex, cfg
localTasks := []sealtasks.TaskType{ localTasks := []sealtasks.TaskType{
sealtasks.TTAddPiece, sealtasks.TTCommit1, sealtasks.TTFinalize, sealtasks.TTAddPiece, sealtasks.TTCommit1, sealtasks.TTFinalize,
} }
if sc.AllowPreCommit1 { localTasks = append(localTasks, sealtasks.TTPreCommit1)} if sc.AllowPreCommit1 {
if sc.AllowPreCommit2 { localTasks = append(localTasks, sealtasks.TTPreCommit2)} localTasks = append(localTasks, sealtasks.TTPreCommit1)
if sc.AllowCommit { localTasks = append(localTasks, sealtasks.TTCommit2)} }
if sc.AllowPreCommit2 {
localTasks = append(localTasks, sealtasks.TTPreCommit2)
}
if sc.AllowCommit {
localTasks = append(localTasks, sealtasks.TTCommit2)
}
err = m.AddWorker(ctx, NewLocalWorker(WorkerConfig{ err = m.AddWorker(ctx, NewLocalWorker(WorkerConfig{
SealProof: cfg.SealProofType, SealProof: cfg.SealProofType,

1
stores/local.go
View File

@ -337,7 +337,6 @@ func (st *Local) MoveStorage(ctx context.Context, s abi.SectorID, types sectorbu
return xerrors.Errorf("failed to get source storage info: %w", err) return xerrors.Errorf("failed to get source storage info: %w", err)
} }
if sst.ID == dst.ID { if sst.ID == dst.ID {
log.Debugf("not moving %v(%d); src and dest are the same", s, fileType) log.Debugf("not moving %v(%d); src and dest are the same", s, fileType)
continue continue