diff --git a/pkg/rtc/participant.go b/pkg/rtc/participant.go index ee036bd20..7eaad4794 100644 --- a/pkg/rtc/participant.go +++ b/pkg/rtc/participant.go @@ -1638,18 +1638,16 @@ func (p *ParticipantImpl) addMediaTrack(signalCid string, sdpCid string, ti *liv !p.IsClosed(), ) - isUnpublished := false // re-use Track sid p.pendingTracksLock.Lock() if pti := p.pendingTracks[signalCid]; pti != nil { p.sendTrackPublished(signalCid, pti.trackInfos[0]) } else { p.unpublishedTracks = append(p.unpublishedTracks, ti) - isUnpublished = true } p.pendingTracksLock.Unlock() - if isUnpublished && !p.IsClosed() { + if !p.IsClosed() { // unpublished events aren't necessary when participant is closed p.params.Logger.Debugw("unpublished track", "trackID", ti.Sid, "trackInfo", ti) p.lock.RLock() diff --git a/pkg/sfu/downtrack.go b/pkg/sfu/downtrack.go index e5ac8d338..81418da8f 100644 --- a/pkg/sfu/downtrack.go +++ b/pkg/sfu/downtrack.go @@ -795,7 +795,7 @@ func (d *DownTrack) CloseWithFlush(flush bool) { d.bindLock.Unlock() d.connectionStats.Close() d.rtpStats.Stop() - d.logger.Infow("rtp stats", "direction", "downstream", "mime", d.mime, "stats", d.rtpStats.ToString()) + d.logger.Infow("rtp stats", "direction", "downstream", "mime", d.mime, "ssrc", d.ssrc, "stats", d.rtpStats.ToString()) if d.onMaxLayerChanged != nil && d.kind == webrtc.RTPCodecTypeVideo { d.onMaxLayerChanged(d, InvalidLayerSpatial)