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

storageminer: use switch in TrackCommitSectorMsg

Browse Source
This commit is contained in:
Łukasz Magiera 2019-09-17 10:40:13 +02:00
parent 8f84aa7097
commit b9ab33f0ae
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
storage/commitment/tracker.go
View File

@ -54,11 +54,8 @@ func (ct *Tracker) TrackCommitSectorMsg(miner address.Address, sectorId uint64,
defer ct.lk.Unlock() defer ct.lk.Unlock()
tracking, err := ct.commitDs.Get(key) tracking, err := ct.commitDs.Get(key)
if err != datastore.ErrNotFound { switch err {
if err != nil { case datastore.ErrNotFound:
return err
}
var comm commitment var comm commitment
if err := cbor.DecodeInto(tracking, &comm); err != nil { if err := cbor.DecodeInto(tracking, &comm); err != nil {
return err return err
@ -70,6 +67,10 @@ func (ct *Tracker) TrackCommitSectorMsg(miner address.Address, sectorId uint64,
log.Warnf("commitment.TrackCommitSectorMsg called more than once for miner %s, sector %d, message %s", miner, sectorId, mcid) log.Warnf("commitment.TrackCommitSectorMsg called more than once for miner %s, sector %d, message %s", miner, sectorId, mcid)
return nil return nil
case nil:
break
default:
return err
} }
comm := &commitment{Msg: mcid} comm := &commitment{Msg: mcid}