github-mirrors/netris-warp
1
0
Fork 0
mirror of https://github.com/nestriness/warp.git synced 2025-12-13 02:15:42 +02:00
Code Issues Packages Projects Releases Wiki Activity

fix(sink): add a probe for handling queries from the muxer

Browse Source
This commit is contained in:
Wanjohi
2024-01-24 09:22:02 +03:00
parent d15d26eb34
commit 44013045de
2 changed files with 28 additions and 47 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
.gitignore vendored
View File

@@ -1 +1,3 @@
/target /target
**/target

71
src/media.rs
View File

@@ -270,62 +270,41 @@ impl GST {
// Set the `emit-signals` property to `true` to receive signals // Set the `emit-signals` property to `true` to receive signals
appsink.set_property("emit-signals", &true); appsink.set_property("emit-signals", &true);
// Set up a callback for the `new-sample` signal
// appsink.connect_new_sample(move |sink| {
// // Handle the new sample
// let sample = sink.pull_sample().map_err(|_| gst::FlowError::Error)?;
// let buffer = sample.buffer().ok_or_else(|| gst::FlowError::Error)?;
// let _map = buffer.map_readable().map_err(|_| gst::FlowError::Error)?;
// // Perform any necessary operations on the buffer data
// // Return Ok to indicate successful handling of the new sample
// Ok(gst::FlowSuccess::Ok)
// });
// Set up a pad probe on the sink pad to intercept queries // Set up a pad probe on the sink pad to intercept queries
let sink_pad = appsink.static_pad("sink").unwrap(); let sink_pad = appsink.static_pad("sink").unwrap();
sink_pad.add_probe(gst::PadProbeType::QUERY_DOWNSTREAM, |pad, info| {
if let Some(ref query) = info.query_mut() {
//https://github.com/Kurento/gstreamer/blob/f2553fb153edeeecc2f4f74fca996c74dc8210df/plugins/elements/gstfilesink.c#L496C51-L496C69
use gst::QueryViewMut;
match query.view_mut() { //FIX: https://github.com/sdroege/gst-plugin-rs/blob/95c007953c0874bc46152078775d673cf44cc255/mux/mp4/src/mp4mux/imp.rs#L1243
QueryViewMut::Seeking(q) => { sink_pad.add_probe(gst::PadProbeType::QUERY_DOWNSTREAM, move |_pad, info| {
// We don't support any seeking at all let Some(query) = info.query_mut() else {
println!("Handling query {:?}", q); unreachable!();
};
let format = q.format(); match query.view_mut() {
if format == gst::Format::Bytes || format == gst::Format::Default { gst::QueryViewMut::Seeking(q) => {
println!("Handling query {:?}", q);
let format = q.format();
use gst::Format::Bytes;
//https://github.com/Kurento/gstreamer/blob/f2553fb153edeeecc2f4f74fca996c74dc8210df/plugins/elements/gstfilesink.c#L494
match format {
gst::Format::Bytes | gst::Format::Default => {
q.set( q.set(
true, true,
gst::GenericFormattedValue::none_for_format(format), 0.bytes(),
gst::GenericFormattedValue::none_for_format(format), // No known end position, or you can specify it if known
);
}
_ => {
// For other formats, do not handle the seeking query
q.set(
false,
0.bytes(),
gst::GenericFormattedValue::none_for_format(format), gst::GenericFormattedValue::none_for_format(format),
); );
} else {
q.set(
false,
gst::GenericFormattedValue::none_for_format(format),
gst::GenericFormattedValue::none_for_format(format),
);
} }
} }
_ => (),
} }
_ => {
// if let gst::QueryView::Seeking(mut seeking) = query.view() { unreachable!();
// println!("Handling query {:?}", query); }
// if seeking.format() == gst::Format::Bytes || seeking.format() == gst::Format::Default {
// seeking.to_owned().set(true, 0.bytes(), 1.bytes());
// return gst::PadProbeReturn::Handled;
// } else {
// seeking.to_owned().set(false, 0.bytes(), 1.bytes());
// return gst::PadProbeReturn::Handled;
// }
// }
} }
gst::PadProbeReturn::Pass gst::PadProbeReturn::Pass
}); });