"sync"
"time"
- "github.com/anacrolix/generics"
+ g "github.com/anacrolix/generics"
"github.com/anacrolix/log"
"github.com/gorilla/websocket"
"github.com/pion/datachannel"
pingTicker *time.Ticker
WebsocketTrackerHttpHeader func() http.Header
+ ICEServers []string
}
func (me *TrackerClient) Stats() TrackerClientStats {
return fmt.Errorf("creating offer: %w", err)
}
- err = tc.announce(event, infoHash, []outboundOffer{{
- offerId: offerIDBinary,
- outboundOfferValue: outboundOfferValue{
- originalOffer: offer,
- peerConnection: pc,
- infoHash: infoHash,
- dataChannel: dc,
- }},
+ err = tc.announce(event, infoHash, []outboundOffer{
+ {
+ offerId: offerIDBinary,
+ outboundOfferValue: outboundOfferValue{
+ originalOffer: offer,
+ peerConnection: pc,
+ infoHash: infoHash,
+ dataChannel: dc,
+ },
+ },
})
if err != nil {
dc.Close()
return fmt.Errorf("write AnnounceRequest: %w", err)
}
for _, offer := range offers {
- generics.MakeMapIfNilAndSet(&tc.outboundOffers, offer.offerId, offer.outboundOfferValue)
+ g.MakeMapIfNilAndSet(&tc.outboundOffers, offer.offerId, offer.outboundOfferValue)
}
return nil
}