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 05f52b1fad
commit 42c9d53ae1
3 changed files with 10 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
node/config/def.go
View File

@ -56,7 +56,7 @@ type Storage struct {
// Local worker config // Local worker config
AllowPreCommit1 bool AllowPreCommit1 bool
AllowPreCommit2 bool AllowPreCommit2 bool
AllowCommit bool AllowCommit bool
} }
func defCommon() Common { func defCommon() Common {

12
storage/sectorstorage/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
storage/sectorstorage/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