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

mark peer for disconnection in connmgr

Browse Source
This commit is contained in:
whyrusleeping 2020-02-18 09:20:17 -08:00
parent 1dafcf24f1
commit 4f6ec225cf
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
node/modules/services.go
View File

@ -58,7 +58,10 @@ func HandleIncomingBlocks(mctx helpers.MetricsCtx, lc fx.Lifecycle, ps *pubsub.P
panic(err) panic(err)
} }
v := sub.NewBlockValidator(ps.BlacklistPeer) v := sub.NewBlockValidator(func(p peer.ID) {
ps.BlacklistPeer(p)
h.ConnManager().TagPeer(p, "badblock", -1000)
})
if err := ps.RegisterTopicValidator(BlocksTopic, v.Validate); err != nil { if err := ps.RegisterTopicValidator(BlocksTopic, v.Validate); err != nil {
panic(err) panic(err)