Fully clear the muxer generator between streaming cycles. (#3372)

Fixes: #3181
savonet · Aug 31, 2023 · ecd5f32 · ecd5f32
1 parent de9dc76
commit ecd5f32
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 3 deletions.
diff --git a/CHANGES.md b/CHANGES.md
@@ -16,6 +16,7 @@ Changed:
 
 Fixed:
 
+- Fixed slow memory leak in muxer operator (#3372, #3181)
 - Fixed discontinuity logic error in HLS outputs after a restart.
 - Fixed HTTP response status in `output.harbor` (#3255)
 - Make sure main HLS playlist is regenerated after being

diff --git a/src/core/operators/muxer.ml b/src/core/operators/muxer.ml
@@ -159,7 +159,7 @@ class muxer tracks =
     initializer
       self#on_after_output (fun () ->
           clear_track_frames ();
-          Frame.clear self#buffer)
+          Generator.clear self#buffer)
   end
 
 let muxer_operator p =

diff --git a/tests/streams/dtmf.liq b/tests/streams/dtmf.liq
@@ -19,7 +19,7 @@ def f(k)
   end
 end
 
-s = amplify(0.5, dtmf(duration=0.1, keys))
+s = amplify(0.5, dtmf(duration=1., keys))
 # s = add([s, amplify(0.5, noise())]) # Removed to make the test deterministic
 s = dtmf.detect(debug=false, s, f)
 

diff --git a/tests/streams/dtmf_pcm_s16.liq b/tests/streams/dtmf_pcm_s16.liq
@@ -18,7 +18,7 @@ def f(k)
   end
 end
 
-s = amplify(0.5, dtmf(duration=0.1, keys))
+s = amplify(0.5, dtmf(duration=1., keys))
 s = audio.encode.pcm_s16(s)
 s = add([s, blank()])
 s = audio.decode.pcm_s16(s)