From 04e5880d090ebd0550b8a17182529a4b8a1af516 Mon Sep 17 00:00:00 2001
From: Matt Joiner <anacrolix@gmail.com>
Date: Thu, 29 Jan 2015 14:17:27 +1100
Subject: [PATCH] Comments
---
client.go | 2 ++
dht/dht.go | 1 +
dht/getpeers.go | 5 +++++
3 files changed, 8 insertions(+)
diff --git a/client.go b/client.go
index 52618b5c..11be6680 100644
--- a/client.go
+++ b/client.go
@@ -1729,6 +1729,8 @@ func (cl *Client) AddMagnet(uri string) (T Torrent, err error) {
return
}
+// Actively prunes unused connections. This is required to make space to dial
+// for replacements.
func (cl *Client) connectionPruner(t *torrent) {
for {
time.Sleep(15 * time.Second)
diff --git a/dht/dht.go b/dht/dht.go
index 06cdfcda..350d6d1d 100644
--- a/dht/dht.go
+++ b/dht/dht.go
@@ -856,6 +856,7 @@ func (t *transaction) setOnResponse(f func(m Msg)) {
t.onResponse = f
}
+// Add response nodes to node table.
func (s *Server) liftNodes(d Msg) {
if d["y"] != "r" {
return
diff --git a/dht/getpeers.go b/dht/getpeers.go
index c507809c..e58a0358 100644
--- a/dht/getpeers.go
+++ b/dht/getpeers.go
@@ -1,5 +1,7 @@
package dht
+// get_peers and announce_peers.
+
import (
"log"
"time"
@@ -121,6 +123,7 @@ func (me *peerDiscovery) getPeers(addr dHTAddr) error {
go func() {
select {
case m := <-t.Response:
+ // Register suggested nodes closer to the target info-hash.
me.mu.Lock()
for _, n := range m.Nodes() {
me.responseNode(n)
@@ -160,6 +163,8 @@ type peerStreamValue struct {
NodeInfo // The node that gave the response.
}
+// TODO: This was to be the shared publicly accessible part returned by DHT
+// functions that stream peers. Possibly not necessary anymore.
type peerStream struct {
mu sync.Mutex
Values chan peerStreamValue
--
2.51.0