From 31f90a08685d795b90d2588e62402896768a6a40 Mon Sep 17 00:00:00 2001 From: David Colburn Date: Tue, 23 Jul 2024 01:43:09 -0400 Subject: [PATCH] remove debug logs --- pkg/pipeline/builder/video.go | 4 ---- test/stream.go | 4 ++-- 2 files changed, 2 insertions(+), 6 deletions(-) diff --git a/pkg/pipeline/builder/video.go b/pkg/pipeline/builder/video.go index fe8b51cf..78c5690a 100644 --- a/pkg/pipeline/builder/video.go +++ b/pkg/pipeline/builder/video.go @@ -719,12 +719,10 @@ func (b *VideoBin) createSrcPad(trackID, name string) { b.mu.Lock() if pts < b.lastPTS || (b.selectedPad != videoTestSrcName && b.selectedPad != name) { b.mu.Unlock() - logger.Debugw(fmt.Sprintf("%s dropping %v", name, time.Duration(pts))) return gst.PadProbeDrop } b.lastPTS = pts b.mu.Unlock() - logger.Debugw(fmt.Sprintf("%s pushing %v", name, time.Duration(pts))) return gst.PadProbeOK }) @@ -741,12 +739,10 @@ func (b *VideoBin) createTestSrcPad() { b.mu.Lock() if pts < b.lastPTS || (b.selectedPad != videoTestSrcName) { b.mu.Unlock() - logger.Debugw(fmt.Sprintf("%s dropping %v", videoTestSrcName, time.Duration(pts))) return gst.PadProbeDrop } b.lastPTS = pts b.mu.Unlock() - logger.Debugw(fmt.Sprintf("%s pushing %v", videoTestSrcName, time.Duration(pts))) return gst.PadProbeOK }) diff --git a/test/stream.go b/test/stream.go index 3873c68e..c036cf75 100644 --- a/test/stream.go +++ b/test/stream.go @@ -143,11 +143,11 @@ func (r *Runner) runStreamTest(t *testing.T, req *rpc.StartEgressRequest, test * require.NotZero(t, info.EndedAt) switch info.Url { - case urls[0][0]: + case urls[0][1]: require.Equal(t, livekit.StreamInfo_FINISHED.String(), info.Status.String()) require.Greater(t, float64(info.Duration)/1e9, 15.0) - case urls[2][0]: + case urls[2][1]: require.Equal(t, livekit.StreamInfo_FINISHED.String(), info.Status.String()) require.Greater(t, float64(info.Duration)/1e9, 10.0)