mirrors/gst-plugins-rs
mirrors/gst-plugins-rs
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs.git synced 2025-02-08 17:12:22 +00:00
Code Issues Projects Releases Wiki Activity

fmp4: dash_vod example: reformat

Browse source 
Not sure why rustfmt updated those because of my previous change.

Part-of: <https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs/-/merge_requests/1177>
This commit is contained in:
Guillaume Desmottes 2023-04-13 09:49:03 +02:00
parent 371ac83169
commit 367b98bfcb
1 changed files with 25 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

32
mux/fmp4/examples/dash_vod.rs
View file

@ -72,7 +72,10 @@ fn main() -> Result<(), Error> {
// header, i.e. the `ftyp`, `moov` and other media boxes. // header, i.e. the `ftyp`, `moov` and other media boxes.
// //
// This might be the initial header or the updated header at the end of the stream. // This might be the initial header or the updated header at the end of the stream.
if first.flags().contains(gst::BufferFlags::DISCONT | gst::BufferFlags::HEADER) { if first
.flags()
.contains(gst::BufferFlags::DISCONT | gst::BufferFlags::HEADER)
{
let mut path = state.path.clone(); let mut path = state.path.clone();
std::fs::create_dir_all(&path).expect("failed to create directory"); std::fs::create_dir_all(&path).expect("failed to create directory");
path.push("init.cmfi"); path.push("init.cmfi");
@ -99,32 +102,47 @@ fn main() -> Result<(), Error> {
// followed by one or more actual media buffers. // followed by one or more actual media buffers.
assert!(first.flags().contains(gst::BufferFlags::HEADER)); assert!(first.flags().contains(gst::BufferFlags::HEADER));
let segment = sample.segment().expect("no segment") let segment = sample
.downcast_ref::<gst::ClockTime>().expect("no time segment"); .segment()
.expect("no segment")
.downcast_ref::<gst::ClockTime>()
.expect("no time segment");
// Initialize the start time with the first PTS we observed. This will be used // Initialize the start time with the first PTS we observed. This will be used
// later for calculating the duration of the whole media for the DASH manifest. // later for calculating the duration of the whole media for the DASH manifest.
// //
// The PTS of the segment header is equivalent to the earliest PTS of the whole // The PTS of the segment header is equivalent to the earliest PTS of the whole
// segment. // segment.
let pts = segment.to_running_time(first.pts().unwrap()).expect("can't get running time"); let pts = segment
.to_running_time(first.pts().unwrap())
.expect("can't get running time");
if state.start_time.is_none() { if state.start_time.is_none() {
state.start_time = Some(pts); state.start_time = Some(pts);
} }
// The metadata of the first media buffer is duplicated to the segment header. // The metadata of the first media buffer is duplicated to the segment header.
// Based on this we can know the timecode of the first frame in this segment. // Based on this we can know the timecode of the first frame in this segment.
let meta = first.meta::<gst_video::VideoTimeCodeMeta>().expect("no timecode meta"); let meta = first
.meta::<gst_video::VideoTimeCodeMeta>()
.expect("no timecode meta");
let mut path = state.path.clone(); let mut path = state.path.clone();
path.push(format!("segment_{}.cmfv", state.segments.len() + 1)); path.push(format!("segment_{}.cmfv", state.segments.len() + 1));
println!("writing segment with timecode {} to {}", meta.tc(), path.display()); println!(
"writing segment with timecode {} to {}",
meta.tc(),
path.display()
);
// Calculate the end time at this point. The duration of the segment header is set // Calculate the end time at this point. The duration of the segment header is set
// to the whole duration of this segment. // to the whole duration of this segment.
let duration = first.duration().unwrap(); let duration = first.duration().unwrap();
let end_time = first.pts().unwrap() + first.duration().unwrap(); let end_time = first.pts().unwrap() + first.duration().unwrap();
state.end_time = Some(segment.to_running_time(end_time).expect("can't get running time")); state.end_time = Some(
segment
.to_running_time(end_time)
.expect("can't get running time"),
);
let mut file = std::fs::File::create(path).expect("failed to open fragment"); let mut file = std::fs::File::create(path).expect("failed to open fragment");
for buffer in &*buffer_list { for buffer in &*buffer_list {