sl := func() torrentTrackerAnnouncer {
switch u.Scheme {
case "ws", "wss":
- wst := websocketTracker{*u, webtorrent.NewClient(t.cl.peerID, t.infoHash, t.onWebRtcConn,
+ wst := websocketTracker{*u, webtorrent.NewTrackerClient(t.cl.peerID, t.infoHash, t.onWebRtcConn,
t.logger.WithText(func(m log.Msg) string {
return fmt.Sprintf("%q: %v", u.String(), m.Text())
}))}
type onDataChannelOpen func(_ datachannel.ReadWriteCloser, dcc DataChannelContext)
-func NewClient(peerId, infoHash [20]byte, onConn onDataChannelOpen, logger log.Logger) *TrackerClient {
+func NewTrackerClient(peerId, infoHash [20]byte, onConn onDataChannelOpen, logger log.Logger) *TrackerClient {
return &TrackerClient{
outboundOffers: make(map[string]outboundOffer),
peerIDBinary: binaryToJsonString(peerId[:]),
}
func (c *TrackerClient) trackerReadLoop() error {
-
c.lock.Lock()
tracker := c.tracker
c.lock.Unlock()