Use OWD estimator from mediatransportutil. (#811)

Author: boks1971

go.mod

@@ -9,7 +9,7 @@ require (
 	github.com/gorilla/websocket v1.5.4-0.20250319132907-e064f32e3674
 	github.com/livekit/mageutil v0.0.0-20250511045019-0f1ff63f7731
 	github.com/livekit/media-sdk v0.0.0-20251106223430-dd8f5e0de2cf
-	github.com/livekit/mediatransportutil v0.0.0-20250922175932-f537f0880397
+	github.com/livekit/mediatransportutil v0.0.0-20251128105421-19c7a7b81c22
 	github.com/livekit/protocol v1.43.1-0.20251111125113-f20b33cc16b9
 	github.com/magefile/mage v1.15.0
 	github.com/pion/dtls/v3 v3.0.7

go.sum

@@ -157,8 +157,8 @@ github.com/livekit/mageutil v0.0.0-20250511045019-0f1ff63f7731 h1:9x+U2HGLrSw5AT
 github.com/livekit/mageutil v0.0.0-20250511045019-0f1ff63f7731/go.mod h1:Rs3MhFwutWhGwmY1VQsygw28z5bWcnEYmS1OG9OxjOQ=
 github.com/livekit/media-sdk v0.0.0-20251106223430-dd8f5e0de2cf h1:gvun6axx2Mrh8+NvuQBLQUoiG5MBubI435XoX68VGL8=
 github.com/livekit/media-sdk v0.0.0-20251106223430-dd8f5e0de2cf/go.mod h1:7ssWiG+U4xnbvLih9WiZbhQP6zIKMjgXdUtIE1bm/E8=
-github.com/livekit/mediatransportutil v0.0.0-20250922175932-f537f0880397 h1:Z7j2mY+bvG05UC80MpnJkitlJju8sSDWsr0Bb4dPceo=
-github.com/livekit/mediatransportutil v0.0.0-20250922175932-f537f0880397/go.mod h1:mSNtYzSf6iY9xM3UX42VEI+STHvMgHmrYzEHPcdhB8A=
+github.com/livekit/mediatransportutil v0.0.0-20251128105421-19c7a7b81c22 h1:dzCBxOGLLWVtQhL7OYK2EGN+5Q+23Mq/jfz4vQisirA=
+github.com/livekit/mediatransportutil v0.0.0-20251128105421-19c7a7b81c22/go.mod h1:mSNtYzSf6iY9xM3UX42VEI+STHvMgHmrYzEHPcdhB8A=
 github.com/livekit/protocol v1.43.1-0.20251111125113-f20b33cc16b9 h1:ECXv1c9S/1qXytKfDGe5m5AJagEbSgea/ZE0DspkwVY=
 github.com/livekit/protocol v1.43.1-0.20251111125113-f20b33cc16b9/go.mod h1:TpqU2qCI1ES4Lk7PAWSgYO4RaexfVXb54ZO2hXv0Bmc=
 github.com/livekit/psrpc v0.7.1-0.20251105165826-1016ad610a7e h1:K6GKMFGJW8U2RoEyi8Zar7pPwUB7RMsn3AEJXf/Mgfc=

pkg/synchronizer/owd_estimator.go

@@ -28,6 +28,7 @@ import (
 
 	"github.com/livekit/media-sdk/jitter"
 	"github.com/livekit/mediatransportutil"
+	"github.com/livekit/mediatransportutil/pkg/latency"
 	"github.com/livekit/protocol/logger"
 	"github.com/livekit/protocol/utils/mono"
 	"github.com/livekit/protocol/utils/rtputil"
@@ -101,7 +102,7 @@ type TrackSynchronizer struct {
 
 	nextPTSAdjustmentAt time.Time
 
-	propagationDelayEstimator *OWDEstimator
+	propagationDelayEstimator *latency.OWDEstimator
 	totalStartTimeAdjustment  time.Duration
 	startTimeAdjustResidual   time.Duration
 	initialized               bool
@@ -127,7 +128,7 @@ func newTrackSynchronizer(s *Synchronizer, track TrackRemote) *TrackSynchronizer
 		oldPacketThreshold:                s.config.OldPacketThreshold,
 		enableStartGate:                   s.config.EnableStartGate,
 		nextPTSAdjustmentAt:               mono.Now(),
-		propagationDelayEstimator:         NewOWDEstimator(OWDEstimatorParamsDefault),
+		propagationDelayEstimator:         latency.NewOWDEstimator(latency.OWDEstimatorParamsDefault),
 		maxMediaRunningTimeDelay:          s.config.MaxMediaRunningTimeDelay,
 		lastPTSAdjustedLogBucket:          math.MaxInt64,
 	}