11 "github.com/anacrolix/missinggo"
13 "github.com/anacrolix/torrent/tracker"
16 // Announces a torrent to a tracker at regular intervals, when peers are
18 type trackerScraper struct {
20 // Causes the trackerScraper to stop running.
23 lastAnnounce trackerAnnounceResult
26 func (ts *trackerScraper) statusLine() string {
28 fmt.Fprintf(&w, "%q\t%s\t%s",
31 na := time.Until(ts.lastAnnounce.Completed.Add(ts.lastAnnounce.Interval))
41 if ts.lastAnnounce.Err != nil {
42 return ts.lastAnnounce.Err.Error()
44 if ts.lastAnnounce.Completed.IsZero() {
47 return fmt.Sprintf("%d peers", ts.lastAnnounce.NumPeers)
53 type trackerAnnounceResult struct {
56 Interval time.Duration
60 func (me *trackerScraper) getIp() (ip net.IP, err error) {
61 ips, err := net.LookupIP(me.u.Hostname())
66 err = errors.New("no ips")
69 for _, ip = range ips {
70 if me.t.cl.ipIsBlocked(ip) {
85 err = errors.New("no acceptable ips")
89 func (me *trackerScraper) trackerUrl(ip net.IP) string {
92 u.Host = net.JoinHostPort(ip.String(), u.Port())
97 // Return how long to wait before trying again. For most errors, we return 5
98 // minutes, a relatively quick turn around for DNS changes.
99 func (me *trackerScraper) announce() (ret trackerAnnounceResult) {
101 ret.Completed = time.Now()
103 ret.Interval = 5 * time.Minute
104 ip, err := me.getIp()
106 ret.Err = fmt.Errorf("error getting ip: %s", err)
110 req := me.t.announceRequest()
112 res, err := tracker.Announce{
113 HttpClient: me.t.cl.config.HTTP,
114 UserAgent: me.t.cl.config.HTTPUserAgent,
115 TrackerUrl: me.trackerUrl(ip),
117 HostHeader: me.u.Host,
120 ret.Err = fmt.Errorf("error announcing: %s", err)
123 me.t.AddPeers(Peers(nil).FromTracker(res.Peers))
124 ret.NumPeers = len(res.Peers)
125 ret.Interval = time.Duration(res.Interval) * time.Second
129 func (me *trackerScraper) Run() {
132 case <-me.t.closed.LockedChan(&me.t.cl.mu):
134 case <-me.stop.LockedChan(&me.t.cl.mu):
136 case <-me.t.wantPeersEvent.LockedChan(&me.t.cl.mu):
144 intervalChan := time.After(time.Until(ar.Completed.Add(ar.Interval)))
147 case <-me.t.closed.LockedChan(&me.t.cl.mu):
149 case <-me.stop.LockedChan(&me.t.cl.mu):