status-im
/
torrent
mirror of
2
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Disable update requests timer

This commit is contained in:
Matt Joiner 2022-05-11 16:08:19 +10:00
parent 590d1ac265
commit 669c69faac
No known key found for this signature in database
GPG Key ID: 6B990B8185E7F782
3 changed files with 11 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
client.go
View File

@ -991,7 +991,9 @@ func (p *Peer) initUpdateRequestsTimer() {
panic(p.updateRequestsTimer)
}
}
p.updateRequestsTimer = time.AfterFunc(math.MaxInt64, p.updateRequestsTimerFunc)
if enableUpdateRequestsTimer {
p.updateRequestsTimer = time.AfterFunc(math.MaxInt64, p.updateRequestsTimerFunc)
}
}
const peerUpdateRequestsTimerReason = "updateRequestsTimer"

2
peerconn.go
View File

@ -503,7 +503,7 @@ var (
// The actual value to use as the maximum outbound requests.
func (cn *Peer) nominalMaxRequests() maxRequests {
return maxRequests(maxInt(1, minInt(cn.PeerMaxRequests, cn.peakRequests*2, maxLocalToRemoteRequests)))
return maxInt(1, minInt(cn.PeerMaxRequests, cn.peakRequests*2, maxLocalToRemoteRequests))
}
func (cn *Peer) totalExpectingTime() (ret time.Duration) {

9
requesting.go
View File

@ -312,9 +312,14 @@ func (p *Peer) applyRequestState(next desiredRequestState) {
p.peakRequests = newPeakRequests
p.needRequestUpdate = ""
p.lastRequestUpdate = time.Now()
p.updateRequestsTimer.Reset(updateRequestsTimerDuration)
if enableUpdateRequestsTimer {
p.updateRequestsTimer.Reset(updateRequestsTimerDuration)
}
}
// This could be set to 10s to match the unchoke/request update interval recommended by some
// specifications. I've set it shorter to trigger it more often for testing for now.
const updateRequestsTimerDuration = 3 * time.Second
const (
updateRequestsTimerDuration = 3 * time.Second
enableUpdateRequestsTimer = false
)