webtorrent/tracker_client.go | 6 +++++- diff --git a/webtorrent/tracker_client.go b/webtorrent/tracker_client.go index 9644cf19ace48f6b037850c67b199f06df5eed84..5c84a72930866ed449f4d0396df411786718926b 100644 --- a/webtorrent/tracker_client.go +++ b/webtorrent/tracker_client.go @@ -53,6 +53,7 @@ type onDataChannelOpen func(_ datachannel.ReadWriteCloser, dcc DataChannelContext) func (tc *TrackerClient) doWebsocket() error { + metrics.Add("websocket dials", 1) c, _, err := websocket.DefaultDialer.Dial(tc.Url, nil) if err != nil { return fmt.Errorf("dialing tracker: %w", err) @@ -76,7 +77,7 @@ func (tc *TrackerClient) Run() error { for { err := tc.doWebsocket() - tc.Logger.Printf("websocket instance ended: %v", err) + tc.Logger.WithDefaultLevel(log.Warning).Printf("websocket instance ended: %v", err) time.Sleep(time.Minute) } } @@ -89,6 +90,7 @@ tc.outboundOffers = nil } func (tc *TrackerClient) announce(event tracker.AnnounceEvent) error { + metrics.Add("outbound announces", 1) var randOfferId [20]byte _, err := rand.Read(randOfferId[:]) if err != nil { @@ -201,7 +203,9 @@ tc.Logger.WithDefaultLevel(log.Warning).Printf("could not find offer for id %q", offerId) return } tc.Logger.Printf("offer %q got answer %v", offerId, answer) + metrics.Add("outbound offers answered", 1) err := offer.setAnswer(answer, func(dc datachannel.ReadWriteCloser) { + metrics.Add("outbound offers answered with datachannel", 1) tc.OnConn(dc, DataChannelContext{ Local: offer.originalOffer, Remote: answer,