remove debug logs

livekit · Jul 23, 2024 · 31f90a0 · 31f90a0
1 parent ceac6ad
commit 31f90a0
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 6 deletions.
diff --git 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
@@ -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)