diff --git a/pipeline.dot b/pipeline.dot deleted file mode 100644 index c1454d4..0000000 --- a/pipeline.dot +++ /dev/null @@ -1,296 +0,0 @@ -digraph pipeline { - rankdir=LR; - fontname="sans"; - fontsize="10"; - labelloc=t; - nodesep=.1; - ranksep=.2; - label="\npipeline0\n[>]"; - node [style="filled,rounded", shape=box, fontsize="9", fontname="sans", margin="0.0,0.0"]; - edge [labelfontsize="6", fontsize="9", fontname="monospace"]; - - legend [ - pos="0,0!", - margin="0.05,0.05", - style="filled", - label="Legend\lElement-States: [~] void-pending, [0] null, [-] ready, [=] paused, [>] playing\lPad-Activation: [-] none, [>] push, [<] pull\lPad-Flags: [b]locked, [f]lushing, [b]locking, [E]OS; upper-case is set\lPad-Task: [T] has started task, [t] has paused task\l", - ]; - subgraph cluster_capsfilter1_0x7f8f2691e5d0 { - fontname="Bitstream Vera Sans"; - fontsize="8"; - style="filled,rounded"; - color=black; - label="GstCapsFilter\ncapsfilter1\n[>]\ncaps=video/x-h264, profile=(string)main"; - subgraph cluster_capsfilter1_0x7f8f2691e5d0_sink { - label=""; - style="invis"; - capsfilter1_0x7f8f2691e5d0_sink_0x7f8f23076e20 [color=black, fillcolor="#aaaaff", label="sink\n[>][bfb]", height="0.2", style="filled,solid"]; - } - - subgraph cluster_capsfilter1_0x7f8f2691e5d0_src { - label=""; - style="invis"; - capsfilter1_0x7f8f2691e5d0_src_0x7f8f23077070 [color=black, fillcolor="#ffaaaa", label="src\n[>][bfb]", height="0.2", style="filled,solid"]; - } - - capsfilter1_0x7f8f2691e5d0_sink_0x7f8f23076e20 -> capsfilter1_0x7f8f2691e5d0_src_0x7f8f23077070 [style="invis"]; - fillcolor="#aaffaa"; - } - - capsfilter1_0x7f8f2691e5d0_src_0x7f8f23077070 -> queue0_0x7f8f24028010_sink_0x7f8f268f0d50 [label="video/x-h264\l stream-format: byte-stream\l alignment: au\l level: 3.1\l profile: main\l width: 1280\l height: 720\l pixel-aspect-ratio: 1/1\l framerate: 30/1\l interlace-mode: progressive\l colorimetry: bt709\l chroma-site: mpeg2\l multiview-mode: mono\l multiview-flags: 0:ffffffff:/right-view...\l"] - subgraph cluster_capsfilter0_0x7f8f2691e290 { - fontname="Bitstream Vera Sans"; - fontsize="8"; - style="filled,rounded"; - color=black; - label="GstCapsFilter\ncapsfilter0\n[>]\ncaps=video/x-raw, framerate=(fraction)30/1, width=(int)1280, height=(int)720"; - subgraph cluster_capsfilter0_0x7f8f2691e290_sink { - label=""; - style="invis"; - capsfilter0_0x7f8f2691e290_sink_0x7f8f23076980 [color=black, fillcolor="#aaaaff", label="sink\n[>][bfb]", height="0.2", style="filled,solid"]; - } - - subgraph cluster_capsfilter0_0x7f8f2691e290_src { - label=""; - style="invis"; - capsfilter0_0x7f8f2691e290_src_0x7f8f23076bd0 [color=black, fillcolor="#ffaaaa", label="src\n[>][bfb]", height="0.2", style="filled,solid"]; - } - - capsfilter0_0x7f8f2691e290_sink_0x7f8f23076980 -> capsfilter0_0x7f8f2691e290_src_0x7f8f23076bd0 [style="invis"]; - fillcolor="#aaffaa"; - } - - capsfilter0_0x7f8f2691e290_src_0x7f8f23076bd0 -> timeoverlay0_0x7f8f268f2a00_video_sink_0x7f8f268f0410 [label="video/x-raw\l format: I420\l width: 1280\l height: 720\l framerate: 30/1\l multiview-mode: mono\l pixel-aspect-ratio: 1/1\l interlace-mode: progressive\l"] - subgraph cluster_queue1_0x7f8f24028310 { - fontname="Bitstream Vera Sans"; - fontsize="8"; - style="filled,rounded"; - color=black; - label="GstQueue\nqueue1\n[>]"; - subgraph cluster_queue1_0x7f8f24028310_sink { - label=""; - style="invis"; - queue1_0x7f8f24028310_sink_0x7f8f230764e0 [color=black, fillcolor="#aaaaff", label="sink\n[>][bfb]", height="0.2", style="filled,solid"]; - } - - subgraph cluster_queue1_0x7f8f24028310_src { - label=""; - style="invis"; - queue1_0x7f8f24028310_src_0x7f8f23076730 [color=black, fillcolor="#ffaaaa", label="src\n[>][bfb][T]", height="0.2", style="filled,solid"]; - } - - queue1_0x7f8f24028310_sink_0x7f8f230764e0 -> queue1_0x7f8f24028310_src_0x7f8f23076730 [style="invis"]; - fillcolor="#aaffaa"; - } - - queue1_0x7f8f24028310_src_0x7f8f23076730 -> mux_0x7f8f23062190_sink_66_0x7f8f26008f60 [label="audio/mpeg\l channels: 1\l rate: 44100\l mpegversion: 4\l base-profile: lc\l framed: true\l stream-format: raw\l level: 2\l profile: lc\l codec_data: 120856e500\l"] - subgraph cluster_avenc_aac0_0x7f8f268fb270 { - fontname="Bitstream Vera Sans"; - fontsize="8"; - style="filled,rounded"; - color=black; - label="avenc_aac\navenc_aac0\n[>]\nbitrate=128000"; - subgraph cluster_avenc_aac0_0x7f8f268fb270_sink { - label=""; - style="invis"; - avenc_aac0_0x7f8f268fb270_sink_0x7f8f23076040 [color=black, fillcolor="#aaaaff", label="sink\n[>][bfb]", height="0.2", style="filled,solid"]; - } - - subgraph cluster_avenc_aac0_0x7f8f268fb270_src { - label=""; - style="invis"; - avenc_aac0_0x7f8f268fb270_src_0x7f8f23076290 [color=black, fillcolor="#ffaaaa", label="src\n[>][bfb]", height="0.2", style="filled,solid"]; - } - - avenc_aac0_0x7f8f268fb270_sink_0x7f8f23076040 -> avenc_aac0_0x7f8f268fb270_src_0x7f8f23076290 [style="invis"]; - fillcolor="#aaffaa"; - } - - avenc_aac0_0x7f8f268fb270_src_0x7f8f23076290 -> queue1_0x7f8f24028310_sink_0x7f8f230764e0 [label="audio/mpeg\l channels: 1\l rate: 44100\l mpegversion: 4\l base-profile: lc\l framed: true\l stream-format: raw\l level: 2\l profile: lc\l codec_data: 120856e500\l"] - subgraph cluster_audioconvert0_0x7f8f230754d0 { - fontname="Bitstream Vera Sans"; - fontsize="8"; - style="filled,rounded"; - color=black; - label="GstAudioConvert\naudioconvert0\n[>]"; - subgraph cluster_audioconvert0_0x7f8f230754d0_sink { - label=""; - style="invis"; - audioconvert0_0x7f8f230754d0_sink_0x7f8f268f1b30 [color=black, fillcolor="#aaaaff", label="sink\n[>][bfb]", height="0.2", style="filled,solid"]; - } - - subgraph cluster_audioconvert0_0x7f8f230754d0_src { - label=""; - style="invis"; - audioconvert0_0x7f8f230754d0_src_0x7f8f268f1d80 [color=black, fillcolor="#ffaaaa", label="src\n[>][bfb]", height="0.2", style="filled,solid"]; - } - - audioconvert0_0x7f8f230754d0_sink_0x7f8f268f1b30 -> audioconvert0_0x7f8f230754d0_src_0x7f8f268f1d80 [style="invis"]; - fillcolor="#aaffaa"; - } - - audioconvert0_0x7f8f230754d0_src_0x7f8f268f1d80 -> avenc_aac0_0x7f8f268fb270_sink_0x7f8f23076040 [label="audio/x-raw\l rate: 44100\l channels: 1\l format: F32LE\l layout: interleaved\l"] - subgraph cluster_audiotestsrc0_0x7f8f23071ce0 { - fontname="Bitstream Vera Sans"; - fontsize="8"; - style="filled,rounded"; - color=black; - label="GstAudioTestSrc\naudiotestsrc0\n[>]\nis-live=TRUE"; - subgraph cluster_audiotestsrc0_0x7f8f23071ce0_src { - label=""; - style="invis"; - audiotestsrc0_0x7f8f23071ce0_src_0x7f8f268f18e0 [color=black, fillcolor="#ffaaaa", label="src\n[>][bfb][T]", height="0.2", style="filled,solid"]; - } - - fillcolor="#ffaaaa"; - } - - audiotestsrc0_0x7f8f23071ce0_src_0x7f8f268f18e0 -> audioconvert0_0x7f8f230754d0_sink_0x7f8f268f1b30 [label="audio/x-raw\l rate: 44100\l channels: 1\l format: F32LE\l layout: interleaved\l"] - subgraph cluster_udpsink0_0x7f8f2305ba90 { - fontname="Bitstream Vera Sans"; - fontsize="8"; - style="filled,rounded"; - color=black; - label="GstUDPSink\nudpsink0\n[>]\nlast-sample=((GstSample*) 0x7f8f2607d420)\nbytes-to-serve=50187776\nbytes-served=50187776\nused-socket=((GSocket*) 0x7f8f26016130)\nused-socket-v6=((GSocket*) 0x7f8f26016280)\nclients=\"184.73.103.62:5000\"\nhost=\"184.73.103.62\"\nport=5000"; - subgraph cluster_udpsink0_0x7f8f2305ba90_sink { - label=""; - style="invis"; - udpsink0_0x7f8f2305ba90_sink_0x7f8f268f1690 [color=black, fillcolor="#aaaaff", label="sink\n[>][bfb]", height="0.2", style="filled,solid"]; - } - - fillcolor="#aaaaff"; - } - - subgraph cluster_rtpmp2tpay0_0x7f8f2306c0f0 { - fontname="Bitstream Vera Sans"; - fontsize="8"; - style="filled,rounded"; - color=black; - label="GstRTPMP2TPay\nrtpmp2tpay0\n[>]\npt=33\ntimestamp=1905327734\nseqnum=3460"; - subgraph cluster_rtpmp2tpay0_0x7f8f2306c0f0_sink { - label=""; - style="invis"; - rtpmp2tpay0_0x7f8f2306c0f0_sink_0x7f8f268f1440 [color=black, fillcolor="#aaaaff", label="sink\n[>][bfb]", height="0.2", style="filled,solid"]; - } - - subgraph cluster_rtpmp2tpay0_0x7f8f2306c0f0_src { - label=""; - style="invis"; - rtpmp2tpay0_0x7f8f2306c0f0_src_0x7f8f268f11f0 [color=black, fillcolor="#ffaaaa", label="src\n[>][bfb]", height="0.2", style="filled,solid"]; - } - - rtpmp2tpay0_0x7f8f2306c0f0_sink_0x7f8f268f1440 -> rtpmp2tpay0_0x7f8f2306c0f0_src_0x7f8f268f11f0 [style="invis"]; - fillcolor="#aaffaa"; - } - - rtpmp2tpay0_0x7f8f2306c0f0_src_0x7f8f268f11f0 -> udpsink0_0x7f8f2305ba90_sink_0x7f8f268f1690 [label="application/x-rtp\l media: video\l clock-rate: 90000\l encoding-name: MP2T\l payload: 33\l seqnum-offset: 31205\l timestamp-offset: 1889868735\l ssrc: 3127985935\l"] - subgraph cluster_mux_0x7f8f23062190 { - fontname="Bitstream Vera Sans"; - fontsize="8"; - style="filled,rounded"; - color=black; - label="GstMpegTsMux\nmux\n[>]\nalignment=7\nscte-35-pid=500\nscte-35-null-interval=450000"; - subgraph cluster_mux_0x7f8f23062190_sink { - label=""; - style="invis"; - mux_0x7f8f23062190_sink_65_0x7f8f26012960 [color=black, fillcolor="#aaaaff", label="sink_65\n[>][bfb]", height="0.2", style="filled,dashed"]; - mux_0x7f8f23062190_sink_66_0x7f8f26008f60 [color=black, fillcolor="#aaaaff", label="sink_66\n[>][bfb]", height="0.2", style="filled,dashed"]; - } - - subgraph cluster_mux_0x7f8f23062190_src { - label=""; - style="invis"; - mux_0x7f8f23062190_src_0x7f8f23008360 [color=black, fillcolor="#ffaaaa", label="src\n[>][bfb][T]", height="0.2", style="filled,solid"]; - } - - mux_0x7f8f23062190_sink_65_0x7f8f26012960 -> mux_0x7f8f23062190_src_0x7f8f23008360 [style="invis"]; - fillcolor="#aaffaa"; - } - - mux_0x7f8f23062190_src_0x7f8f23008360 -> rtpmp2tpay0_0x7f8f2306c0f0_sink_0x7f8f268f1440 [label="video/mpegts\l systemstream: true\l packetsize: 188\l streamheader: < (buffer)47400031a6... >\l"] - subgraph cluster_queue0_0x7f8f24028010 { - fontname="Bitstream Vera Sans"; - fontsize="8"; - style="filled,rounded"; - color=black; - label="GstQueue\nqueue0\n[>]"; - subgraph cluster_queue0_0x7f8f24028010_sink { - label=""; - style="invis"; - queue0_0x7f8f24028010_sink_0x7f8f268f0d50 [color=black, fillcolor="#aaaaff", label="sink\n[>][bfb]", height="0.2", style="filled,solid"]; - } - - subgraph cluster_queue0_0x7f8f24028010_src { - label=""; - style="invis"; - queue0_0x7f8f24028010_src_0x7f8f268f0fa0 [color=black, fillcolor="#ffaaaa", label="src\n[>][bfb][T]", height="0.2", style="filled,solid"]; - } - - queue0_0x7f8f24028010_sink_0x7f8f268f0d50 -> queue0_0x7f8f24028010_src_0x7f8f268f0fa0 [style="invis"]; - fillcolor="#aaffaa"; - } - - queue0_0x7f8f24028010_src_0x7f8f268f0fa0 -> mux_0x7f8f23062190_sink_65_0x7f8f26012960 [label="video/x-h264\l stream-format: byte-stream\l alignment: au\l level: 3.1\l profile: main\l width: 1280\l height: 720\l pixel-aspect-ratio: 1/1\l framerate: 30/1\l interlace-mode: progressive\l colorimetry: bt709\l chroma-site: mpeg2\l multiview-mode: mono\l multiview-flags: 0:ffffffff:/right-view...\l"] - subgraph cluster_encoder_0x7f8f23059550 { - fontname="Bitstream Vera Sans"; - fontsize="8"; - style="filled,rounded"; - color=black; - label="GstX264Enc\nencoder\n[>]\ntune=zerolatency"; - subgraph cluster_encoder_0x7f8f23059550_sink { - label=""; - style="invis"; - encoder_0x7f8f23059550_sink_0x7f8f268f08b0 [color=black, fillcolor="#aaaaff", label="sink\n[>][bfb]", height="0.2", style="filled,solid"]; - } - - subgraph cluster_encoder_0x7f8f23059550_src { - label=""; - style="invis"; - encoder_0x7f8f23059550_src_0x7f8f268f0b00 [color=black, fillcolor="#ffaaaa", label="src\n[>][bfb]", height="0.2", style="filled,solid"]; - } - - encoder_0x7f8f23059550_sink_0x7f8f268f08b0 -> encoder_0x7f8f23059550_src_0x7f8f268f0b00 [style="invis"]; - fillcolor="#aaffaa"; - } - - encoder_0x7f8f23059550_src_0x7f8f268f0b00 -> capsfilter1_0x7f8f2691e5d0_sink_0x7f8f23076e20 [label="video/x-h264\l stream-format: byte-stream\l alignment: au\l level: 3.1\l profile: main\l width: 1280\l height: 720\l pixel-aspect-ratio: 1/1\l framerate: 30/1\l interlace-mode: progressive\l colorimetry: bt709\l chroma-site: mpeg2\l multiview-mode: mono\l multiview-flags: 0:ffffffff:/right-view...\l"] - subgraph cluster_timeoverlay0_0x7f8f268f2a00 { - fontname="Bitstream Vera Sans"; - fontsize="8"; - style="filled,rounded"; - color=black; - label="GstTimeOverlay\ntimeoverlay0\n[>]\nhalignment=left\nvalignment=top\ntext-x=29\ntext-y=31\ntext-width=304\ntext-height=38\ndatetime-epoch=((GDateTime*) 0x7f8f12d0e0e0)"; - subgraph cluster_timeoverlay0_0x7f8f268f2a00_sink { - label=""; - style="invis"; - timeoverlay0_0x7f8f268f2a00_video_sink_0x7f8f268f0410 [color=black, fillcolor="#aaaaff", label="video_sink\n[>][bfb]", height="0.2", style="filled,solid"]; - } - - subgraph cluster_timeoverlay0_0x7f8f268f2a00_src { - label=""; - style="invis"; - timeoverlay0_0x7f8f268f2a00_src_0x7f8f268f0660 [color=black, fillcolor="#ffaaaa", label="src\n[>][bfb]", height="0.2", style="filled,solid"]; - } - - timeoverlay0_0x7f8f268f2a00_video_sink_0x7f8f268f0410 -> timeoverlay0_0x7f8f268f2a00_src_0x7f8f268f0660 [style="invis"]; - fillcolor="#aaffaa"; - } - - timeoverlay0_0x7f8f268f2a00_src_0x7f8f268f0660 -> encoder_0x7f8f23059550_sink_0x7f8f268f08b0 [label="video/x-raw\l format: I420\l width: 1280\l height: 720\l framerate: 30/1\l multiview-mode: mono\l pixel-aspect-ratio: 1/1\l interlace-mode: progressive\l"] - subgraph cluster_videotestsrc0_0x7f8f268ec8e0 { - fontname="Bitstream Vera Sans"; - fontsize="8"; - style="filled,rounded"; - color=black; - label="GstVideoTestSrc\nvideotestsrc0\n[>]\nis-live=TRUE"; - subgraph cluster_videotestsrc0_0x7f8f268ec8e0_src { - label=""; - style="invis"; - videotestsrc0_0x7f8f268ec8e0_src_0x7f8f268f01c0 [color=black, fillcolor="#ffaaaa", label="src\n[>][bfb][T]", height="0.2", style="filled,solid"]; - } - - fillcolor="#ffaaaa"; - } - - videotestsrc0_0x7f8f268ec8e0_src_0x7f8f268f01c0 -> capsfilter0_0x7f8f2691e290_sink_0x7f8f23076980 [label="video/x-raw\l format: I420\l width: 1280\l height: 720\l framerate: 30/1\l multiview-mode: mono\l pixel-aspect-ratio: 1/1\l interlace-mode: progressive\l"] -} diff --git a/src/main.rs b/src/main.rs index 6613d62..ed781d5 100644 --- a/src/main.rs +++ b/src/main.rs @@ -1,5 +1,6 @@ +use glib::translate::ToGlibPtr; use gst::prelude::*; -use log::info; +use log::{debug, info}; use std::fs::File; use std::io::Write; use std::process; @@ -11,9 +12,10 @@ where C: FnOnce() -> *mut gst_mpegts::GstMpegtsSCTESIT, { let sit = gst_sit(); + assert!(!sit.is_null()); unsafe { let section = gst_mpegts::gst_mpegts_section_from_scte_sit(sit, 500); - gst_mpegts::gst_mpegts_section_send_event(section, element.as_ptr()); + gst_mpegts::gst_mpegts_section_send_event(section, element.to_glib_none().0); gst::ffi::gst_mini_object_unref(section as _); }; } @@ -36,6 +38,22 @@ fn send_splice_out(element: &gst::Element, event_id: u32, time: gst::ClockTime) }) } +#[derive(Clone)] +pub struct EventId(Arc>); + +impl EventId { + pub fn new() -> Self { + Self(Arc::new(Mutex::new(0))) + } + + pub fn next(&self) -> u32 { + let mut counter = self.0.lock().unwrap(); + *counter += 1; + *counter + } +} + + fn main() -> eyre::Result<()> { pretty_env_logger::init_timed(); gst::init()?; @@ -43,14 +61,17 @@ fn main() -> eyre::Result<()> { gst_mpegts::gst_mpegts_initialize(); } + // ! rtpmp2tpay ! udpsink sync=true host=184.73.103.62 port=5000 let pipeline = gst::parse_launch( r#" + audiotestsrc is-live=true ! audioconvert ! avenc_aac bitrate=128000 ! queue ! mux. + videotestsrc is-live=true ! video/x-raw,framerate=30/1,width=1280,height=720 ! timeoverlay ! x264enc tune=zerolatency name=encoder - encoder. ! video/x-h264,profile=main ! queue ! mpegtsmux name=mux scte-35-pid=500 scte-35-null-interval=450000 alignment=7 ! rtpmp2tpay ! udpsink sync=true host=184.73.103.62 port=5000 + encoder. ! video/x-h264,profile=main ! queue ! mpegtsmux name=mux scte-35-pid=500 scte-35-null-interval=450000 - audiotestsrc is-live=true ! audioconvert ! avenc_aac bitrate=128000 ! queue ! mux. + mux. ! filesink sync=true location=out.ts "#, )? @@ -59,12 +80,12 @@ fn main() -> eyre::Result<()> { info!("Starting pipeline..."); - let ad_event_counter = Arc::new(Mutex::new(0u32)); + let event_counter = EventId::new(); - // Every 90 seconds we will loop on an ad scheduling process.. + // Every 60 seconds we will loop on an ad scheduling process.. glib::timeout_add(Duration::from_secs(60), { let pipeline_weak = pipeline.downgrade(); - let ad_event_counter = ad_event_counter.clone(); + let event_counter = event_counter.clone(); move || { if let Some(pipeline) = pipeline_weak.upgrade() { let muxer = pipeline.by_name("mux").unwrap(); @@ -73,39 +94,28 @@ fn main() -> eyre::Result<()> { // is, so we use the pipeline running time to base our timing calculations let now = pipeline.current_running_time().unwrap(); - // How much ahead should the ad be inserted, we say 5 seconds in the future + // How much ahead should the ad be inserted, we say 0 seconds in the future (immediate) let ahead = gst::ClockTime::from_seconds(0); - // next event id - let event_id = { - let mut ad_event_counter = ad_event_counter.lock().unwrap(); - *ad_event_counter += 1; - *ad_event_counter - }; - send_splice_out(&muxer, event_id, now + ahead); + // Trigger the Splice Out event in the SCTE-35 stream + send_splice_out(&muxer, event_counter.next(), now + ahead); // Now we add a timed call for the duration of the ad from now to indicate via // splice in that the stream can go back to normal programming. glib::timeout_add(Duration::from_secs(30), { let muxer_weak = muxer.downgrade(); - let ad_event_counter = ad_event_counter.clone(); + let event_counter = event_counter.clone(); move || { if let Some(muxer) = muxer_weak.upgrade() { - // next event id - let event_id = { - let mut ad_event_counter = ad_event_counter.lock().unwrap(); - *ad_event_counter += 1; - *ad_event_counter - }; let now = muxer.current_running_time().unwrap(); - send_splice_in(&muxer, event_id, now + ahead); + send_splice_in(&muxer, event_counter.next(), now + ahead); } - // This don't need to run again + // This shall not run again glib::Continue(false) } }); } - // Run this again next time... + // Run this again after the timeout... glib::Continue(true) } }); @@ -118,6 +128,7 @@ fn main() -> eyre::Result<()> { let bus = pipeline.bus().unwrap(); bus.add_watch({ let main_loop = main_loop.clone(); + let pipeline_weak = pipeline.downgrade(); move |_, msg| { use gst::MessageView; @@ -133,6 +144,19 @@ fn main() -> eyre::Result<()> { ); main_loop.quit(); } + MessageView::StateChanged(s) => { + if let Some(pipeline) = pipeline_weak.upgrade() { + if s.src().map(|e| e == pipeline).unwrap_or(false) { + debug!("Writing dot file for status: {:?}", s.current()); + + let mut file = File::create(format!("Pipeline-{:?}.dot", s.current())).unwrap(); + let dot_data = pipeline.debug_to_dot_data( + gst::DebugGraphDetails::all(), + ); + file.write_all(dot_data.as_bytes()).unwrap(); + } + } + } _ => (), }; @@ -142,21 +166,9 @@ fn main() -> eyre::Result<()> { .expect("Failed to add bus watch"); ctrlc::set_handler({ - let pipeline_weak = pipeline.downgrade(); + let main_loop = main_loop.clone(); move || { - if let Some(pipeline) = pipeline_weak.upgrade() { - pipeline.call_async(|itself| { - let dot_graph = itself - .debug_to_dot_data(gst::DebugGraphDetails::all()) - .to_string(); - let mut graph = File::create("pipeline.dot").unwrap(); - graph.write_all(dot_graph.as_bytes()).unwrap(); - - itself.set_state(gst::State::Null).unwrap(); - - process::exit(0); - }); - } + main_loop.quit(); } })?;