fluencelabs/tendermint
1
0
Fork 0
mirror of https://github.com/fluencelabs/tendermint synced 2025-06-27 19:51:41 +00:00
Code Issues Projects Releases Wiki Activity

Peer pruning

Browse Source
This commit is contained in:
Sean Braithwaite
2019-07-19 02:17:49 +03:00
parent 5f84e3ecf5
commit 10ff7bd342
1 changed files with 26 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

34
blockchain/v2/scheduler.go
View File

@ -380,9 +380,16 @@ func (sc *schedule) selectPeer(peers []*scPeer) *scPeer {
return peers[r.Intn(len(peers))] return peers[r.Intn(len(peers))]
} }
func (sc *schedule) prunablePeers(time time.Time, minSpeed int) []p2p.ID { // XXX: this duplicates the logic of peersInactiveSince and peersSlowerThan
// TODO func (sc *schedule) prunablePeers(peerTimout time.Duration, minRecvRate int64, now time.Time) []p2p.ID {
return []p2p.ID{} prunable := []p2p.ID{}
for peerID, peer := range sc.peers {
if now.Sub(peer.lastTouched) > peerTimout || peer.lastRate < minRecvRate {
prunable = append(prunable, peerID)
}
}
return prunable
} }
func (sc *schedule) numBlockInState(targetState blockState) uint32 { func (sc *schedule) numBlockInState(targetState blockState) uint32 {
@ -399,12 +406,16 @@ type Scheduler struct {
sc *schedule sc *schedule
targetPending uint32 // the number of blocks we want in blockStatePending targetPending uint32 // the number of blocks we want in blockStatePending
targetReceived uint32 // the number of blocks we want in blockStateReceived targetReceived uint32 // the number of blocks we want in blockStateReceived
minRecvRate int64
peerTimeout time.Duration
} }
func NewScheduler(minHeight int64, targetPending uint32, targetReceived uint32) *Scheduler { func NewScheduler(minHeight int64, minRecvRate int64, peerTimeout time.Duration,
targetPending uint32, targetReceived uint32) *Scheduler {
return &Scheduler{ return &Scheduler{
sc: newSchedule(minHeight), sc: newSchedule(minHeight),
minRecvRate: minRecvRate,
peerTimeout: peerTimeout,
targetPending: targetPending, targetPending: targetPending,
targetReceived: targetReceived, targetReceived: targetReceived,
} }
@ -499,9 +510,16 @@ func (sdr *Scheduler) handleBlockProcessError(peerID p2p.ID, height int64) Event
return Skip{} return Skip{}
} }
func (sdr *Scheduler) handleTimeCheck(peerID p2p.ID, now time.Time) interface{} { // XXX: Probably split this into two methods
// prune peers // + handlePurgePeers
// TODO // + handleNextSchehedule
func (sdr *Scheduler) handleTimeCheck(now time.Time) interface{} {
prunablePeers := sdr.sc.prunablePeers(sdr.peerTimeout, sdr.minRecvRate, now)
for _, peerID := range prunablePeers {
// XXX: Emit these events
_ = sdr.sc.removePeer(peerID)
}
// produce new schedule // produce new schedule
events := []scBlockRequestMessage{} events := []scBlockRequestMessage{}