]> Sergey Matveev's repositories - btrtrc.git/commitdiff
Add a few TODOs and fixes to trackerScraper
authorMatt Joiner <anacrolix@gmail.com>
Thu, 24 Apr 2025 13:07:52 +0000 (23:07 +1000)
committerMatt Joiner <anacrolix@gmail.com>
Thu, 24 Apr 2025 13:08:40 +0000 (23:08 +1000)
torrent.go
tracker_scraper.go

index f6d39523244d4c8f7224dbeff55bc838e238af4c..280ae4507d6d8cd319a37766d5d07ef3851029f9 100644 (file)
@@ -3002,6 +3002,7 @@ func (t *Torrent) pieceRequestIndexOffset(piece pieceIndex) RequestIndex {
 }
 
 func (t *Torrent) updateComplete() {
+       // TODO: Announce complete to trackers?
        t.complete.SetBool(t.haveAllPieces())
 }
 
index cc7ba423aae94727ded0d56f457f272b75279f14..399fa63f7e847f3920022f8fc9f5bf480f3ac19f 100644 (file)
@@ -25,6 +25,7 @@ type trackerScraper struct {
        lastAnnounce    trackerAnnounceResult
        lookupTrackerIp func(*url.URL) ([]net.IP, error)
 
+       // TODO: chansync
        stopOnce sync.Once
        stopCh   chan struct{}
 }
@@ -36,7 +37,7 @@ type torrentTrackerAnnouncer interface {
        Stop()
 }
 
-func (me trackerScraper) URL() *url.URL {
+func (me *trackerScraper) URL() *url.URL {
        return &me.u
 }
 
@@ -219,6 +220,7 @@ func (me *trackerScraper) Run() {
 
        ctx, cancel := context.WithCancel(context.Background())
        defer cancel()
+       // TODO: Get rid of the need for this.
        go func() {
                defer cancel()
                select {