webtorrent/tracker_client.go | 6 ------ webtorrent/transport.go | 4 ---- diff --git a/webtorrent/tracker_client.go b/webtorrent/tracker_client.go index 13df300b88eea900286cf4199b06657e4194dbec..9644cf19ace48f6b037850c67b199f06df5eed84 100644 --- a/webtorrent/tracker_client.go +++ b/webtorrent/tracker_client.go @@ -42,9 +42,6 @@ type outboundOffer struct { originalOffer webrtc.SessionDescription peerConnection wrappedPeerConnection dataChannel *webrtc.DataChannel - // Whether we've received an answer for this offer, and closing its PeerConnection has been - // handed off. - answered bool } type DataChannelContext struct { @@ -86,9 +83,6 @@ } func (tc *TrackerClient) closeUnusedOffers() { for _, offer := range tc.outboundOffers { - if offer.answered { - continue - } offer.peerConnection.Close() } tc.outboundOffers = nil diff --git a/webtorrent/transport.go b/webtorrent/transport.go index 809d2c13966f45e3057c39e67372ea82c1d462b9..37989b842e56c046945563172640ea322a892bc8 100644 --- a/webtorrent/transport.go +++ b/webtorrent/transport.go @@ -130,10 +130,6 @@ func (t *outboundOffer) setAnswer(answer webrtc.SessionDescription, onOpen func(datachannel.ReadWriteCloser)) error { setDataChannelOnOpen(t.dataChannel, t.peerConnection, onOpen) err := t.peerConnection.SetRemoteDescription(answer) - if err == nil { - // TODO: Maybe grab this inside the onOpen callback and mark the offer used there. - t.answered = true - } return err }