diff --git a/pkg/rtc/participant.go b/pkg/rtc/participant.go index 28ab0034f..ca4c5da35 100644 --- a/pkg/rtc/participant.go +++ b/pkg/rtc/participant.go @@ -2392,7 +2392,6 @@ func (p *ParticipantImpl) addMediaTrack(signalCid string, sdpCid string, ti *liv p.supervisor.ClearPublishedTrack(trackID, mt) } - // not logged when closing p.params.Telemetry.TrackUnpublished( context.Background(), p.ID(), @@ -2401,7 +2400,6 @@ func (p *ParticipantImpl) addMediaTrack(signalCid string, sdpCid string, ti *liv true, ) - // re-use Track sid p.pendingTracksLock.Lock() if pti := p.pendingTracks[signalCid]; pti != nil { p.sendTrackPublished(signalCid, pti.trackInfos[0]) diff --git a/pkg/telemetry/events.go b/pkg/telemetry/events.go index d3488a273..5233b3990 100644 --- a/pkg/telemetry/events.go +++ b/pkg/telemetry/events.go @@ -86,7 +86,6 @@ func (t *telemetryService) ParticipantJoined( livekit.RoomName(room.Name), livekit.ParticipantID(participant.Sid), livekit.ParticipantIdentity(participant.Identity), - false, ) if !found { prometheus.IncrementParticipantRtcConnected(1) @@ -125,7 +124,6 @@ func (t *telemetryService) ParticipantActive( livekit.RoomName(room.Name), livekit.ParticipantID(participant.Sid), livekit.ParticipantIdentity(participant.Identity), - false, ) if !found { // need to also account for participant count @@ -162,7 +160,6 @@ func (t *telemetryService) ParticipantResumed( livekit.RoomName(room.Name), livekit.ParticipantID(participant.Sid), livekit.ParticipantIdentity(participant.Identity), - true, ) if !found { prometheus.AddParticipant() diff --git a/pkg/telemetry/telemetryservice.go b/pkg/telemetry/telemetryservice.go index ca0aa022f..1673ffe09 100644 --- a/pkg/telemetry/telemetryservice.go +++ b/pkg/telemetry/telemetryservice.go @@ -197,7 +197,6 @@ func (t *telemetryService) getOrCreateWorker( roomName livekit.RoomName, participantID livekit.ParticipantID, participantIdentity livekit.ParticipantIdentity, - transferConnectedState bool, ) (*StatsWorker, bool) { t.workersMu.Lock() defer t.workersMu.Unlock() @@ -208,7 +207,7 @@ func (t *telemetryService) getOrCreateWorker( } existingIsConnected := false - if ok && transferConnectedState { + if ok { existingIsConnected = worker.IsConnected() }