mirrors/gstreamer-rs
mirrors/gstreamer-rs
1
1
Fork 1
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer-rs.git synced 2024-11-29 13:01:05 +00:00
Code Issues Projects Releases Wiki Activity

gstreamer: Allow returning Handled from BufferList pad probes

Browse source 
This is handled exactly the same way as buffers.

Part-of: <https://gitlab.freedesktop.org/gstreamer/gstreamer-rs/-/merge_requests/1174>
This commit is contained in:
Sebastian Dröge 2022-12-23 14:18:17 +02:00 committed by GStreamer Marge Bot
parent dcfea9c35a
commit cdc7aa4846
1 changed files with 6 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
gstreamer/src/pad.rs
View file

@ -1142,7 +1142,7 @@ unsafe fn update_probe_info(
) { ) {
if ret == PadProbeReturn::Handled { if ret == PadProbeReturn::Handled {
// Handled queries need to be returned // Handled queries need to be returned
// Handled buffers are consumed // Handled buffers and buffer lists are consumed
// No other types can safely be used here // No other types can safely be used here
match probe_info.data { match probe_info.data {
@ -1154,11 +1154,16 @@ unsafe fn update_probe_info(
assert_eq!(data_type, Some(Buffer::static_type())); assert_eq!(data_type, Some(Buffer::static_type()));
// Buffer not consumed by probe; consume it here // Buffer not consumed by probe; consume it here
} }
Some(PadProbeData::BufferList(_)) => {
assert_eq!(data_type, Some(BufferList::static_type()));
// BufferList not consumed by probe; consume it here
}
Some(PadProbeData::Event(_)) => { Some(PadProbeData::Event(_)) => {
assert_eq!(data_type, Some(Event::static_type())); assert_eq!(data_type, Some(Event::static_type()));
// Event not consumed by probe; consume it here // Event not consumed by probe; consume it here
} }
None if data_type == Some(Buffer::static_type()) None if data_type == Some(Buffer::static_type())
|| data_type == Some(BufferList::static_type())
|| data_type == Some(Event::static_type()) => || data_type == Some(Event::static_type()) =>
{ {
// Buffer or Event consumed by probe // Buffer or Event consumed by probe