From 0ccc9f65a69affd68a7cc84c23751c5f2ced6534 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=C5=81ukasz=20Magiera?= Date: Tue, 14 Jul 2020 19:10:37 +0200 Subject: [PATCH] gofmt --- api/apistruct/struct.go | 16 ++++++++-------- node/impl/full/state.go | 2 +- storage/wdpost_run.go | 7 +++---- 3 files changed, 12 insertions(+), 13 deletions(-) diff --git a/api/apistruct/struct.go b/api/apistruct/struct.go index c232f6e39..3aae7985f 100644 --- a/api/apistruct/struct.go +++ b/api/apistruct/struct.go @@ -125,14 +125,14 @@ type FullNodeStruct struct { ClientCalcCommP func(ctx context.Context, inpath string, miner address.Address) (*api.CommPRet, error) `perm:"read"` ClientGenCar func(ctx context.Context, ref api.FileRef, outpath string) error `perm:"write"` - StateNetworkName func(context.Context) (dtypes.NetworkName, error) `perm:"read"` - StateMinerSectors func(context.Context, address.Address, *abi.BitField, bool, types.TipSetKey) ([]*api.ChainSectorInfo, error) `perm:"read"` - StateMinerProvingSet func(context.Context, address.Address, types.TipSetKey) ([]*api.ChainSectorInfo, error) `perm:"read"` - StateMinerProvingDeadline func(context.Context, address.Address, types.TipSetKey) (*miner.DeadlineInfo, error) `perm:"read"` - StateMinerPower func(context.Context, address.Address, types.TipSetKey) (*api.MinerPower, error) `perm:"read"` - StateMinerInfo func(context.Context, address.Address, types.TipSetKey) (api.MinerInfo, error) `perm:"read"` - StateMinerDeadlines func(context.Context, address.Address, types.TipSetKey) ([]*miner.Deadline, error) `perm:"read"` - StateMinerPartitions func(context.Context, address.Address, uint64, types.TipSetKey) ([]*miner.Partition, error) + StateNetworkName func(context.Context) (dtypes.NetworkName, error) `perm:"read"` + StateMinerSectors func(context.Context, address.Address, *abi.BitField, bool, types.TipSetKey) ([]*api.ChainSectorInfo, error) `perm:"read"` + StateMinerProvingSet func(context.Context, address.Address, types.TipSetKey) ([]*api.ChainSectorInfo, error) `perm:"read"` + StateMinerProvingDeadline func(context.Context, address.Address, types.TipSetKey) (*miner.DeadlineInfo, error) `perm:"read"` + StateMinerPower func(context.Context, address.Address, types.TipSetKey) (*api.MinerPower, error) `perm:"read"` + StateMinerInfo func(context.Context, address.Address, types.TipSetKey) (api.MinerInfo, error) `perm:"read"` + StateMinerDeadlines func(context.Context, address.Address, types.TipSetKey) ([]*miner.Deadline, error) `perm:"read"` + StateMinerPartitions func(context.Context, address.Address, uint64, types.TipSetKey) ([]*miner.Partition, error) StateMinerFaults func(context.Context, address.Address, types.TipSetKey) (*abi.BitField, error) `perm:"read"` StateAllMinerFaults func(context.Context, abi.ChainEpoch, types.TipSetKey) ([]*api.Fault, error) `perm:"read"` StateMinerRecoveries func(context.Context, address.Address, types.TipSetKey) (*abi.BitField, error) `perm:"read"` diff --git a/node/impl/full/state.go b/node/impl/full/state.go index 2edd42e14..d8cc68ae8 100644 --- a/node/impl/full/state.go +++ b/node/impl/full/state.go @@ -98,7 +98,7 @@ func (a *StateAPI) StateMinerDeadlines(ctx context.Context, m address.Address, t func(store adt.Store, idx uint64, deadline *miner.Deadline) error { out = append(out, deadline) return nil - }))))) + }))))) } func (a *StateAPI) StateMinerPartitions(ctx context.Context, m address.Address, dlIdx uint64, tsk types.TipSetKey) ([]*miner.Partition, error) { diff --git a/storage/wdpost_run.go b/storage/wdpost_run.go index f50b4a224..20c51575d 100644 --- a/storage/wdpost_run.go +++ b/storage/wdpost_run.go @@ -157,7 +157,6 @@ func (s *WindowPoStScheduler) checkNextRecoveries(ctx context.Context, dlIdx uin }) } - if len(params.Recoveries) == 0 { if faulty != 0 { log.Warnw("No recoveries to declare", "deadline", dlIdx, "faulty", faulty) @@ -166,7 +165,7 @@ func (s *WindowPoStScheduler) checkNextRecoveries(ctx context.Context, dlIdx uin return nil } - enc, aerr := actors.SerializeParams(params) + enc, aerr := actors.SerializeParams(params) if aerr != nil { return xerrors.Errorf("could not serialize declare recoveries parameters: %w", aerr) } @@ -292,7 +291,7 @@ func (s *WindowPoStScheduler) runPost(ctx context.Context, di miner.DeadlineInfo defer declWait.Wait() declWait.Add(1) - go func(){ + go func() { defer declWait.Done() // check faults / recoveries for the *next* deadline. It's already too @@ -385,7 +384,7 @@ func (s *WindowPoStScheduler) runPost(ctx context.Context, di miner.DeadlineInfo } params.Partitions[partIdx] = miner.PoStPartition{ - Index: uint64(partIdx), + Index: uint64(partIdx), Skipped: skipped, } }