Dynamic outbound max requests

[btrtrc.git] / peer.go

diff --git a/peer.go b/peer.go
new file mode 100644 (file)
index 0000000..e1bab18
--- /dev/null
+++ b/peer.go
@@ -0,0 +1,15 @@
+package torrent
+
+func (p *Peer) isLowOnRequests() bool {
+       return p.requestState.Requests.IsEmpty() && p.requestState.Cancelled.IsEmpty()
+}
+
+func (p *Peer) decPeakRequests() {
+       // // This can occur when peak requests are altered by the update request timer to be lower than
+       // // the actual number of outstanding requests. Let's let it go negative and see what happens. I
+       // // wonder what happens if maxRequests is not signed.
+       // if p.peakRequests < 1 {
+       //      panic(p.peakRequests)
+       // }
+       p.peakRequests--
+}