From 48635ae34153c5db0370bdb638e84c4e2822c645 Mon Sep 17 00:00:00 2001 From: Alexey Khit Date: Fri, 18 Nov 2022 09:12:48 +0300 Subject: [PATCH] Add two locks for Track --- pkg/streamer/track.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/pkg/streamer/track.go b/pkg/streamer/track.go index b3c2e5d2..d2d81a1e 100644 --- a/pkg/streamer/track.go +++ b/pkg/streamer/track.go @@ -18,7 +18,9 @@ type Track struct { func (t *Track) String() string { s := t.Codec.String() + t.sinkMu.RLock() s += fmt.Sprintf(", sinks=%d", len(t.sink)) + t.sinkMu.RUnlock() return s } @@ -55,7 +57,9 @@ func (t *Track) Unbind() { } func (t *Track) GetSink(from *Track) { + t.sinkMu.Lock() t.sink = from.sink + t.sinkMu.Unlock() } func (t *Track) HasSink() bool {