dandri/livekit
1
0
Fork 0
mirror of https://github.com/livekit/livekit.git synced 2026-03-30 11:19:52 +00:00
Code Issues Packages Projects Releases Wiki Activity

use separate allocation for signal stats telemetry guard (#4281)

Browse Source
This commit is contained in:
Paul Wells
2026-02-03 02:13:49 -08:00
committed by GitHub
parent d2bae34d53
commit 3cca718072
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
pkg/telemetry/signalanddatastats.go
View File

@@ -174,7 +174,7 @@ type BytesSignalStats struct {
BytesTrackStats
ctx context.Context
guard ReferenceGuard
guard *ReferenceGuard
participantResolver roomobs.ParticipantReporterResolver
trackResolver roomobs.KeyResolver
@@ -198,6 +198,7 @@ func NewBytesSignalStats(
reporter: trackReporter,
},
ctx: ctx,
guard: &ReferenceGuard{},
participantResolver: participantReporterResolver,
trackResolver: trackReporterResolver,
}
@@ -235,7 +236,7 @@ func (s *BytesSignalStats) Reset() {
<-s.stopped
s.stopped = nil
s.done = core.Fuse{}
s.guard = ReferenceGuard{}
s.guard = &ReferenceGuard{}
}
s.ri = nil
s.pi = nil
@@ -260,14 +261,14 @@ func (s *BytesSignalStats) maybeStart() {
)
s.trackResolver.Resolve(string(s.trackID))
s.telemetry.ParticipantJoined(s.ctx, s.ri, s.pi, nil, nil, false, &s.guard)
s.telemetry.ParticipantJoined(s.ctx, s.ri, s.pi, nil, nil, false, s.guard)
s.stopped = make(chan struct{})
go s.worker()
}
func (s *BytesSignalStats) worker() {
s.BytesTrackStats.worker()
s.telemetry.ParticipantLeft(s.ctx, s.ri, s.pi, false, &s.guard)
s.telemetry.ParticipantLeft(s.ctx, s.ri, s.pi, false, s.guard)
close(s.stopped)
}