diff --git a/pkg/rtc/room.go b/pkg/rtc/room.go index 61d32ada7..8a1ffa980 100644 --- a/pkg/rtc/room.go +++ b/pkg/rtc/room.go @@ -245,7 +245,7 @@ func (r *Room) Join(participant types.LocalParticipant, opts *ParticipantOptions // it's important to set this before connection, we don't want to miss out on any publishedTracks participant.OnTrackPublished(r.onTrackPublished) participant.OnStateChange(func(p types.LocalParticipant, oldState livekit.ParticipantInfo_State) { - r.Logger.Debugw("participant state changed", + r.Logger.Infow("participant state changed", "state", p.State(), "participant", p.Identity(), "pID", p.ID(), @@ -408,7 +408,7 @@ func (r *Room) RemoveParticipant(identity livekit.ParticipantIdentity, pID livek p.OnSubscribedTo(nil) // close participant as well - r.Logger.Infow("closing participant for removal", "pID", p.ID(), "participant", p.Identity()) + r.Logger.Debugw("closing participant for removal", "pID", p.ID(), "participant", p.Identity()) _ = p.Close(true, reason) r.lock.RLock() diff --git a/pkg/sfu/downtrack.go b/pkg/sfu/downtrack.go index ca1a63d8c..42c664ed2 100644 --- a/pkg/sfu/downtrack.go +++ b/pkg/sfu/downtrack.go @@ -717,7 +717,7 @@ func (d *DownTrack) CloseWithFlush(flush bool) { d.receiver.DeleteDownTrack(d.subscriberID) if d.rtcpReader != nil { - logger.Debugw("downtrack close rtcp reader") + d.logger.Debugw("downtrack close rtcp reader") d.rtcpReader.Close() d.rtcpReader.OnPacket(nil) }