mirror of
https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs.git
synced 2024-06-10 18:29:22 +00:00
Simplify some code around event/query views
This commit is contained in:
parent
65fcd55160
commit
f44b86cd30
|
@ -656,7 +656,7 @@ fn test_iradio_mode() {
|
|||
);
|
||||
|
||||
{
|
||||
if let Some(tag_event) = srcpad.sticky_event::<gst::event::Tag<_>>(0) {
|
||||
if let Some(tag_event) = srcpad.sticky_event::<gst::event::Tag>(0) {
|
||||
let tags = tag_event.tag();
|
||||
assert_eq!(tags.get::<gst::tags::Organization>().unwrap().get(), "Name");
|
||||
assert_eq!(tags.get::<gst::tags::Genre>().unwrap().get(), "Genre");
|
||||
|
|
|
@ -681,11 +681,7 @@ impl JsonGstParse {
|
|||
}
|
||||
}
|
||||
|
||||
fn perform_seek(
|
||||
&self,
|
||||
event: &gst::event::Seek<gst::EventRef>,
|
||||
element: &super::JsonGstParse,
|
||||
) -> bool {
|
||||
fn perform_seek(&self, event: &gst::event::Seek, element: &super::JsonGstParse) -> bool {
|
||||
if self.state.lock().unwrap().pull.is_none() {
|
||||
gst_error!(CAT, obj: element, "seeking is only supported in pull mode");
|
||||
return false;
|
||||
|
|
|
@ -252,7 +252,7 @@ impl CustomSource {
|
|||
let mut stream_type = None;
|
||||
|
||||
// Take stream type from stream-start event if we can
|
||||
if let Some(ev) = pad.sticky_event::<gst::event::StreamStart<_>>(0) {
|
||||
if let Some(ev) = pad.sticky_event::<gst::event::StreamStart>(0) {
|
||||
stream_type = ev.stream().map(|s| s.stream_type());
|
||||
}
|
||||
|
||||
|
|
|
@ -1243,7 +1243,7 @@ impl FallbackSrc {
|
|||
|
||||
let mut is_image = false;
|
||||
|
||||
if let Some(ev) = pad.sticky_event::<gst::event::StreamStart<_>>(0) {
|
||||
if let Some(ev) = pad.sticky_event::<gst::event::StreamStart>(0) {
|
||||
let stream = ev.stream();
|
||||
|
||||
if let Some(stream) = stream {
|
||||
|
@ -1547,7 +1547,7 @@ impl FallbackSrc {
|
|||
None => return Ok(()),
|
||||
};
|
||||
|
||||
let segment = match pad.sticky_event::<gst::event::Segment<_>>(0) {
|
||||
let segment = match pad.sticky_event::<gst::event::Segment>(0) {
|
||||
Some(ev) => ev.segment().clone(),
|
||||
None => {
|
||||
gst_warning!(CAT, obj: element, "Have no segment event yet");
|
||||
|
|
|
@ -202,7 +202,7 @@ impl VideoDecoderImpl for CdgDec {
|
|||
fn decide_allocation(
|
||||
&self,
|
||||
element: &Self::Type,
|
||||
query: &mut gst::query::Allocation<gst::QueryRef>,
|
||||
query: &mut gst::query::Allocation,
|
||||
) -> Result<(), gst::LoggableError> {
|
||||
if query
|
||||
.find_allocation_meta::<gst_video::VideoMeta>()
|
||||
|
|
|
@ -299,7 +299,7 @@ impl State {
|
|||
Ok(ret)
|
||||
}
|
||||
|
||||
fn handle_gap(&mut self, gap: &gst::event::Gap<gst::EventRef>) -> Vec<gst::Buffer> {
|
||||
fn handle_gap(&mut self, gap: &gst::event::Gap) -> Vec<gst::Buffer> {
|
||||
let mut ret = vec![];
|
||||
|
||||
let (pts, duration) = gap.get();
|
||||
|
|
|
@ -943,11 +943,7 @@ impl MccParse {
|
|||
}
|
||||
}
|
||||
|
||||
fn perform_seek(
|
||||
&self,
|
||||
event: &gst::event::Seek<gst::EventRef>,
|
||||
element: &super::MccParse,
|
||||
) -> bool {
|
||||
fn perform_seek(&self, event: &gst::event::Seek, element: &super::MccParse) -> bool {
|
||||
if self.state.lock().unwrap().pull.is_none() {
|
||||
gst_error!(CAT, obj: element, "seeking is only supported in pull mode");
|
||||
return false;
|
||||
|
|
|
@ -818,11 +818,7 @@ impl SccParse {
|
|||
}
|
||||
}
|
||||
|
||||
fn perform_seek(
|
||||
&self,
|
||||
event: &gst::event::Seek<gst::EventRef>,
|
||||
element: &super::SccParse,
|
||||
) -> bool {
|
||||
fn perform_seek(&self, event: &gst::event::Seek, element: &super::SccParse) -> bool {
|
||||
if self.state.lock().unwrap().pull.is_none() {
|
||||
gst_error!(CAT, obj: element, "seeking is only supported in pull mode");
|
||||
return false;
|
||||
|
|
|
@ -463,7 +463,7 @@ impl VideoDecoderImpl for Dav1dDec {
|
|||
fn decide_allocation(
|
||||
&self,
|
||||
element: &Self::Type,
|
||||
query: &mut gst::query::Allocation<gst::QueryRef>,
|
||||
query: &mut gst::query::Allocation,
|
||||
) -> Result<(), gst::LoggableError> {
|
||||
self.negotiation_infos.lock().unwrap().video_meta_supported = query
|
||||
.find_allocation_meta::<gst_video::VideoMeta>()
|
||||
|
|
|
@ -458,7 +458,7 @@ impl VideoDecoderImpl for Ffv1Dec {
|
|||
fn decide_allocation(
|
||||
&self,
|
||||
element: &Self::Type,
|
||||
query: &mut gst::query::Allocation<gst::QueryRef>,
|
||||
query: &mut gst::query::Allocation,
|
||||
) -> Result<(), gst::LoggableError> {
|
||||
let supported = query
|
||||
.find_allocation_meta::<gst_video::VideoMeta>()
|
||||
|
|
|
@ -275,7 +275,7 @@ impl VideoEncoderImpl for GifEnc {
|
|||
fn propose_allocation(
|
||||
&self,
|
||||
element: &Self::Type,
|
||||
query: &mut gst::query::Allocation<gst::QueryRef>,
|
||||
query: &mut gst::query::Allocation,
|
||||
) -> Result<(), gst::LoggableError> {
|
||||
query.add_allocation_meta::<gst_video::VideoMeta>(None);
|
||||
self.parent_propose_allocation(element, query)
|
||||
|
|
|
@ -225,7 +225,7 @@ impl BaseSinkImpl for PaintableSink {
|
|||
fn propose_allocation(
|
||||
&self,
|
||||
element: &Self::Type,
|
||||
query: &mut gst::query::Allocation<gst::QueryRef>,
|
||||
query: &mut gst::query::Allocation,
|
||||
) -> Result<(), gst::LoggableError> {
|
||||
query.add_allocation_meta::<gst_video::VideoMeta>(None);
|
||||
|
||||
|
|
|
@ -488,7 +488,7 @@ impl VideoEncoderImpl for Rav1Enc {
|
|||
fn propose_allocation(
|
||||
&self,
|
||||
element: &Self::Type,
|
||||
query: &mut gst::query::Allocation<gst::QueryRef>,
|
||||
query: &mut gst::query::Allocation,
|
||||
) -> Result<(), gst::LoggableError> {
|
||||
query.add_allocation_meta::<gst_video::VideoMeta>(None);
|
||||
self.parent_propose_allocation(element, query)
|
||||
|
|
|
@ -610,8 +610,8 @@ impl BaseTransformImpl for RoundedCorners {
|
|||
fn propose_allocation(
|
||||
&self,
|
||||
element: &Self::Type,
|
||||
decide_query: Option<&gst::query::Allocation<gst::QueryRef>>,
|
||||
query: &mut gst::query::Allocation<gst::QueryRef>,
|
||||
decide_query: Option<&gst::query::Allocation>,
|
||||
query: &mut gst::query::Allocation,
|
||||
) -> Result<(), gst::LoggableError> {
|
||||
query.add_allocation_meta::<gst_video::VideoMeta>(None);
|
||||
self.parent_propose_allocation(element, decide_query, query)
|
||||
|
|
Loading…
Reference in a new issue