2017-08-08 20:37:48 +00:00
|
|
|
extern crate gstreamer as gst;
|
|
|
|
use gst::*;
|
|
|
|
|
|
|
|
extern crate glib;
|
|
|
|
use glib::*;
|
|
|
|
|
|
|
|
use std::env;
|
|
|
|
use std::u64;
|
|
|
|
|
|
|
|
fn main() {
|
|
|
|
gst::init().unwrap();
|
|
|
|
|
|
|
|
let args: Vec<_> = env::args().collect();
|
|
|
|
let uri: &str = if args.len() == 2 {
|
|
|
|
args[1].as_ref()
|
|
|
|
} else {
|
|
|
|
panic!("Usage: toc file_path");
|
|
|
|
};
|
|
|
|
|
|
|
|
let pipeline = gst::Pipeline::new(None);
|
|
|
|
let src = gst::ElementFactory::make("filesrc", None).unwrap();
|
|
|
|
let decodebin = gst::ElementFactory::make("decodebin", None).unwrap();
|
|
|
|
|
|
|
|
src.set_property("location", &Value::from(uri)).unwrap();
|
|
|
|
|
|
|
|
pipeline.add_many(&[&src, &decodebin]).unwrap();
|
|
|
|
gst::Element::link_many(&[&src, &decodebin]).unwrap();
|
|
|
|
|
|
|
|
// Need to move a new reference into the closure
|
|
|
|
let pipeline_clone = pipeline.clone();
|
|
|
|
decodebin.connect_pad_added(move |_, src_pad| {
|
|
|
|
let pipeline = &pipeline_clone;
|
2017-08-09 16:40:20 +00:00
|
|
|
let queue = gst::ElementFactory::make("queue", None).unwrap();
|
|
|
|
let sink = gst::ElementFactory::make("fakesink", None).unwrap();
|
2017-08-08 20:37:48 +00:00
|
|
|
|
2017-08-09 16:40:20 +00:00
|
|
|
let elements = &[&queue, &sink];
|
|
|
|
pipeline.add_many(elements).unwrap();
|
|
|
|
gst::Element::link_many(elements).unwrap();
|
2017-08-08 20:37:48 +00:00
|
|
|
|
2017-08-09 16:40:20 +00:00
|
|
|
for e in elements {
|
|
|
|
e.sync_state_with_parent().unwrap();
|
2017-08-08 20:37:48 +00:00
|
|
|
}
|
2017-08-09 16:40:20 +00:00
|
|
|
|
|
|
|
let sink_pad = queue.get_static_pad("sink").unwrap();
|
|
|
|
assert_eq!(src_pad.link(&sink_pad), gst::PadLinkReturn::Ok);
|
2017-08-08 20:37:48 +00:00
|
|
|
});
|
|
|
|
|
|
|
|
assert_ne!(
|
|
|
|
pipeline.set_state(gst::State::Paused),
|
|
|
|
gst::StateChangeReturn::Failure
|
|
|
|
);
|
|
|
|
|
|
|
|
let bus = pipeline.get_bus().unwrap();
|
|
|
|
|
|
|
|
loop {
|
|
|
|
let msg = match bus.timed_pop(u64::MAX) {
|
|
|
|
None => break,
|
|
|
|
Some(msg) => msg,
|
|
|
|
};
|
|
|
|
|
|
|
|
match msg.view() {
|
|
|
|
MessageView::Eos(..) => break,
|
|
|
|
MessageView::Error(err) => {
|
|
|
|
println!(
|
|
|
|
"Error from {}: {} ({:?})",
|
|
|
|
msg.get_src().get_path_string(),
|
|
|
|
err.get_error(),
|
|
|
|
err.get_debug()
|
|
|
|
);
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
MessageView::AsyncDone(_) => break,
|
|
|
|
MessageView::Toc(msg_toc) => {
|
|
|
|
let (toc, updated) = msg_toc.get_toc();
|
|
|
|
println!(
|
|
|
|
"\nReceived toc: {:?} - updated: {}",
|
|
|
|
toc.get_scope(),
|
|
|
|
updated
|
|
|
|
);
|
|
|
|
if let Some(tags) = toc.get_tags() {
|
|
|
|
println!("- tags: {}", tags.to_string());
|
|
|
|
}
|
|
|
|
for toc_entry in toc.get_entries() {
|
|
|
|
println!(
|
|
|
|
"\t{:?} - {}",
|
|
|
|
toc_entry.get_entry_type(),
|
|
|
|
toc_entry.get_uid()
|
|
|
|
);
|
|
|
|
if let Some((start, stop)) = toc_entry.get_start_stop_times() {
|
|
|
|
println!("\t- start: {}, stop: {}", start, stop);
|
|
|
|
}
|
|
|
|
if let Some(tags) = toc_entry.get_tags() {
|
|
|
|
println!("\t- tags: {}", tags.to_string());
|
|
|
|
}
|
|
|
|
for toc_sub_entry in toc_entry.get_sub_entries() {
|
|
|
|
println!(
|
|
|
|
"\n\t\t{:?} - {}",
|
|
|
|
toc_sub_entry.get_entry_type(),
|
|
|
|
toc_sub_entry.get_uid()
|
|
|
|
);
|
|
|
|
if let Some((start, stop)) = toc_sub_entry.get_start_stop_times() {
|
|
|
|
println!("\t\t- start: {}, stop: {}", start, stop);
|
|
|
|
}
|
|
|
|
if let Some(tags) = toc_sub_entry.get_tags() {
|
|
|
|
println!("\t\t- tags: {:?}", tags.to_string());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
_ => (),
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
assert_ne!(
|
|
|
|
pipeline.set_state(gst::State::Null),
|
|
|
|
gst::StateChangeReturn::Failure
|
|
|
|
);
|
|
|
|
}
|