diff options
author | Arun Raghavan <arun@asymptotic.io> | 2020-04-05 17:38:52 +0300 |
---|---|---|
committer | Arun Raghavan <arun@arunraghavan.net> | 2020-04-05 22:10:47 +0300 |
commit | dc3c8fd0494056ae5e5f87aa716b4c3866af6591 (patch) | |
tree | 3226cac3439fd29b7b02f6456f3162d6a3d1e00a /generic/threadshare/tests/jitterbuffer.rs | |
parent | 205b6040fbb918c0fa736874b09f8e3f3f261e44 (diff) |
Drop gst-plugin- prefix in plugin directory name
Diffstat (limited to 'generic/threadshare/tests/jitterbuffer.rs')
-rw-r--r-- | generic/threadshare/tests/jitterbuffer.rs | 172 |
1 files changed, 172 insertions, 0 deletions
diff --git a/generic/threadshare/tests/jitterbuffer.rs b/generic/threadshare/tests/jitterbuffer.rs new file mode 100644 index 000000000..cdc227672 --- /dev/null +++ b/generic/threadshare/tests/jitterbuffer.rs @@ -0,0 +1,172 @@ +// Copyright (C) 2020 François Laignel <fengalin@free.fr> +// +// This library is free software; you can redistribute it and/or +// modify it under the terms of the GNU Library General Public +// License as published by the Free Software Foundation; either +// version 2 of the License, or (at your option) any later version. +// +// This library is distributed in the hope that it will be useful, +// but WITHOUT ANY WARRANTY; without even the implied warranty of +// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU +// Library General Public License for more details. +// +// You should have received a copy of the GNU Library General Public +// License along with this library; if not, write to the +// Free Software Foundation, Inc., 51 Franklin Street, Suite 500, +// Boston, MA 02110-1335, USA. + +use gst; +use gst::gst_debug; +use gst::prelude::*; + +use lazy_static::lazy_static; + +use std::sync::mpsc; + +use gstthreadshare; + +lazy_static! { + static ref CAT: gst::DebugCategory = gst::DebugCategory::new( + "ts-test", + gst::DebugColorFlags::empty(), + Some("Thread-sharing test"), + ); +} + +fn init() { + use std::sync::Once; + static INIT: Once = Once::new(); + + INIT.call_once(|| { + gst::init().unwrap(); + gstthreadshare::plugin_register_static().expect("gstthreadshare jitterbuffer test"); + }); +} + +#[test] +fn jb_pipeline() { + init(); + + const CONTEXT_WAIT: u32 = 20; + const LATENCY: u32 = 20; + const BUFFER_NB: i32 = 3; + + let pipeline = gst::Pipeline::new(None); + + let src = gst::ElementFactory::make("audiotestsrc", Some("audiotestsrc")).unwrap(); + src.set_property("is-live", &true).unwrap(); + src.set_property("num-buffers", &BUFFER_NB).unwrap(); + + let enc = gst::ElementFactory::make("alawenc", Some("alawenc")).unwrap(); + let pay = gst::ElementFactory::make("rtppcmapay", Some("rtppcmapay")).unwrap(); + + let jb = gst::ElementFactory::make("ts-jitterbuffer", Some("ts-jitterbuffer")).unwrap(); + jb.set_property("context", &"jb_pipeline").unwrap(); + jb.set_property("context-wait", &CONTEXT_WAIT).unwrap(); + jb.set_property("latency", &LATENCY).unwrap(); + + let depay = gst::ElementFactory::make("rtppcmadepay", Some("rtppcmadepay")).unwrap(); + let dec = gst::ElementFactory::make("alawdec", Some("alawdec")).unwrap(); + + let sink = gst::ElementFactory::make("appsink", Some("appsink")).unwrap(); + sink.set_property("sync", &false).unwrap(); + sink.set_property("async", &false).unwrap(); + sink.set_property("emit-signals", &true).unwrap(); + + pipeline + .add_many(&[&src, &enc, &pay, &jb, &depay, &dec, &sink]) + .unwrap(); + gst::Element::link_many(&[&src, &enc, &pay, &jb, &depay, &dec, &sink]).unwrap(); + + let appsink = sink.dynamic_cast::<gst_app::AppSink>().unwrap(); + let (sender, receiver) = mpsc::channel(); + appsink.connect_new_sample(move |appsink| { + let _sample = appsink + .emit("pull-sample", &[]) + .unwrap() + .unwrap() + .get::<gst::Sample>() + .unwrap() + .unwrap(); + + sender.send(()).unwrap(); + Ok(gst::FlowSuccess::Ok) + }); + + pipeline.set_state(gst::State::Playing).unwrap(); + + gst_debug!(CAT, "jb_pipeline: waiting for {} buffers", BUFFER_NB); + for idx in 0..BUFFER_NB { + receiver.recv().unwrap(); + gst_debug!(CAT, "jb_pipeline: received buffer #{}", idx); + } + + pipeline.set_state(gst::State::Null).unwrap(); +} + +#[test] +fn jb_ts_pipeline() { + init(); + + const CONTEXT_WAIT: u32 = 20; + const LATENCY: u32 = 20; + const BUFFER_NB: i32 = 3; + + let pipeline = gst::Pipeline::new(None); + + let src = gst::ElementFactory::make("audiotestsrc", Some("audiotestsrc")).unwrap(); + src.set_property("is-live", &true).unwrap(); + src.set_property("num-buffers", &BUFFER_NB).unwrap(); + + let queue = gst::ElementFactory::make("ts-queue", Some("ts-queue")).unwrap(); + queue + .set_property("context", &"jb_ts_pipeline_queue") + .unwrap(); + queue.set_property("context-wait", &CONTEXT_WAIT).unwrap(); + + let enc = gst::ElementFactory::make("alawenc", Some("alawenc")).unwrap(); + let pay = gst::ElementFactory::make("rtppcmapay", Some("rtppcmapay")).unwrap(); + + let jb = gst::ElementFactory::make("ts-jitterbuffer", Some("ts-jitterbuffer")).unwrap(); + jb.set_property("context", &"jb_ts_pipeline").unwrap(); + jb.set_property("context-wait", &CONTEXT_WAIT).unwrap(); + jb.set_property("latency", &LATENCY).unwrap(); + + let depay = gst::ElementFactory::make("rtppcmadepay", Some("rtppcmadepay")).unwrap(); + let dec = gst::ElementFactory::make("alawdec", Some("alawdec")).unwrap(); + + let sink = gst::ElementFactory::make("appsink", Some("appsink")).unwrap(); + sink.set_property("sync", &false).unwrap(); + sink.set_property("async", &false).unwrap(); + sink.set_property("emit-signals", &true).unwrap(); + + pipeline + .add_many(&[&src, &queue, &enc, &pay, &jb, &depay, &dec, &sink]) + .unwrap(); + gst::Element::link_many(&[&src, &queue, &enc, &pay, &jb, &depay, &dec, &sink]).unwrap(); + + let appsink = sink.dynamic_cast::<gst_app::AppSink>().unwrap(); + let (sender, receiver) = mpsc::channel(); + appsink.connect_new_sample(move |appsink| { + let _sample = appsink + .emit("pull-sample", &[]) + .unwrap() + .unwrap() + .get::<gst::Sample>() + .unwrap() + .unwrap(); + + sender.send(()).unwrap(); + Ok(gst::FlowSuccess::Ok) + }); + + pipeline.set_state(gst::State::Playing).unwrap(); + + gst_debug!(CAT, "jb_ts_pipeline: waiting for {} buffers", BUFFER_NB); + for idx in 0..BUFFER_NB { + receiver.recv().unwrap(); + gst_debug!(CAT, "jb_ts_pipeline: received buffer #{}", idx); + } + + pipeline.set_state(gst::State::Null).unwrap(); +} |