fix deadlock (#369)

livekit · Dec 14, 2023 · 54bbfd6 · 54bbfd6
1 parent 602e75b
commit 54bbfd6
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/pkg/synchronizer/track.go b/pkg/synchronizer/track.go
@@ -205,7 +205,7 @@ func (t *TrackSynchronizer) getElapsed(ts int64) time.Duration {
 }
 
 func (t *TrackSynchronizer) resetRTP(pkt *rtp.Packet) (int64, time.Duration) {
-	frames := int64(time.Since(t.lastPacket) / t.GetFrameDuration())
+	frames := int64(time.Since(t.lastPacket) / t.getFrameDuration())
 	duration := t.getFrameDurationRTP() * frames
 	ts := t.lastTS + duration
 	pts := t.lastPTS + t.rtpConverter.toDuration(duration)
@@ -259,6 +259,10 @@ func (t *TrackSynchronizer) GetFrameDuration() time.Duration {
 	t.Lock()
 	defer t.Unlock()
 
+	return t.getFrameDuration()
+}
+
+func (t *TrackSynchronizer) getFrameDuration() time.Duration {
 	switch t.track.Kind() {
 	case webrtc.RTPCodecTypeAudio:
 		// round opus packets to 2.5ms