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

print better error if no blocksync peers

Browse Source
This commit is contained in:
whyrusleeping 2019-11-30 22:10:23 -06:00
parent ebf65dae5b
commit 74be20f864
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
chain/blocksync/blocksync_client.go
View File

@ -156,8 +156,9 @@ func (bs *BlockSync) GetChainMessages(ctx context.Context, h *types.TipSet, coun
var err error var err error
for _, p := range perm { for _, p := range perm {
res, err := bs.sendRequestToPeer(ctx, peers[p], req) res, rerr := bs.sendRequestToPeer(ctx, peers[p], req)
if err != nil { if rerr != nil {
err = rerr
log.Warnf("BlockSync request failed for peer %s: %s", peers[p].String(), err) log.Warnf("BlockSync request failed for peer %s: %s", peers[p].String(), err)
continue continue
} }
@ -172,6 +173,10 @@ func (bs *BlockSync) GetChainMessages(ctx context.Context, h *types.TipSet, coun
} }
} }
if err == nil {
return nil, xerrors.Errorf("GetChainMessages failed, no peers connected")
}
// TODO: What if we have no peers (and err is nil)? // TODO: What if we have no peers (and err is nil)?
return nil, xerrors.Errorf("GetChainMessages failed with all peers(%d): %w", len(peers), err) return nil, xerrors.Errorf("GetChainMessages failed with all peers(%d): %w", len(peers), err)
} }