]> Sergey Matveev's repositories - btrtrc.git/blobdiff - tracker_scraper.go
Rework Reader waiting
[btrtrc.git] / tracker_scraper.go
index 21c4111be1d9813e074b56db3da612feb0ca1938..c339c2b4415f1e865a8337b0600756120c8293d5 100644 (file)
@@ -216,7 +216,6 @@ func (me *trackerScraper) Run() {
 
                me.t.cl.lock()
                wantPeers := me.t.wantPeersEvent.C()
-               closed := me.t.closed.C()
                me.t.cl.unlock()
 
                // If we want peers, reduce the interval to the minimum if it's appropriate.
@@ -234,7 +233,7 @@ func (me *trackerScraper) Run() {
                }
 
                select {
-               case <-closed:
+               case <-me.t.closed.Done():
                        return
                case <-reconsider:
                        // Recalculate the interval.