use crate::RTSPAddressPool;
use crate::RTSPMediaStatus;
use crate::RTSPPublishClockMode;
use crate::RTSPStream;
use crate::RTSPStreamTransport;
use crate::RTSPSuspendMode;
use crate::RTSPThread;
use crate::RTSPTransportMode;
use glib::object::Cast;
use glib::object::IsA;
use glib::signal::connect_raw;
use glib::signal::SignalHandlerId;
use glib::translate::*;
use glib::StaticType;
use glib::ToValue;
use std::boxed::Box as Box_;
#[cfg(any(feature = "v1_18", feature = "dox"))]
#[cfg_attr(feature = "dox", doc(cfg(feature = "v1_18")))]
use std::mem;
use std::mem::transmute;
glib::wrapper! {
pub struct RTSPMedia(Object<ffi::GstRTSPMedia, ffi::GstRTSPMediaClass>);
match fn {
type_ => || ffi::gst_rtsp_media_get_type(),
}
}
impl RTSPMedia {
#[doc(alias = "gst_rtsp_media_new")]
pub fn new<P: IsA<gst::Element>>(element: &P) -> RTSPMedia {
assert_initialized_main_thread!();
unsafe { from_glib_full(ffi::gst_rtsp_media_new(element.as_ref().to_glib_full())) }
}
}
unsafe impl Send for RTSPMedia {}
unsafe impl Sync for RTSPMedia {}
pub const NONE_RTSP_MEDIA: Option<&RTSPMedia> = None;
pub trait RTSPMediaExt: 'static {
#[doc(alias = "gst_rtsp_media_collect_streams")]
fn collect_streams(&self);
#[doc(alias = "gst_rtsp_media_create_stream")]
fn create_stream<P: IsA<gst::Element>, Q: IsA<gst::Pad>>(
&self,
payloader: &P,
pad: &Q,
) -> Option<RTSPStream>;
#[doc(alias = "gst_rtsp_media_find_stream")]
fn find_stream(&self, control: &str) -> Option<RTSPStream>;
#[doc(alias = "gst_rtsp_media_get_address_pool")]
#[doc(alias = "get_address_pool")]
fn address_pool(&self) -> Option<RTSPAddressPool>;
#[doc(alias = "gst_rtsp_media_get_base_time")]
#[doc(alias = "get_base_time")]
fn base_time(&self) -> gst::ClockTime;
#[doc(alias = "gst_rtsp_media_get_buffer_size")]
#[doc(alias = "get_buffer_size")]
fn buffer_size(&self) -> u32;
#[doc(alias = "gst_rtsp_media_get_clock")]
#[doc(alias = "get_clock")]
fn clock(&self) -> Option<gst::Clock>;
#[cfg(any(feature = "v1_16", feature = "dox"))]
#[cfg_attr(feature = "dox", doc(cfg(feature = "v1_16")))]
#[doc(alias = "gst_rtsp_media_get_do_retransmission")]
#[doc(alias = "get_do_retransmission")]
fn does_retransmission(&self) -> bool;
#[cfg(any(feature = "v1_18", feature = "dox"))]
#[cfg_attr(feature = "dox", doc(cfg(feature = "v1_18")))]
#[doc(alias = "gst_rtsp_media_get_dscp_qos")]
#[doc(alias = "get_dscp_qos")]
fn dscp_qos(&self) -> i32;
#[doc(alias = "gst_rtsp_media_get_element")]
#[doc(alias = "get_element")]
fn element(&self) -> Option<gst::Element>;
#[doc(alias = "gst_rtsp_media_get_latency")]
#[doc(alias = "get_latency")]
fn latency(&self) -> u32;
#[cfg(any(feature = "v1_16", feature = "dox"))]
#[cfg_attr(feature = "dox", doc(cfg(feature = "v1_16")))]
#[doc(alias = "gst_rtsp_media_get_max_mcast_ttl")]
#[doc(alias = "get_max_mcast_ttl")]
fn max_mcast_ttl(&self) -> u32;
#[doc(alias = "gst_rtsp_media_get_multicast_iface")]
#[doc(alias = "get_multicast_iface")]
fn multicast_iface(&self) -> Option<glib::GString>;
#[doc(alias = "gst_rtsp_media_get_profiles")]
#[doc(alias = "get_profiles")]
fn profiles(&self) -> gst_rtsp::RTSPProfile;
#[doc(alias = "gst_rtsp_media_get_protocols")]
#[doc(alias = "get_protocols")]
fn protocols(&self) -> gst_rtsp::RTSPLowerTrans;
#[doc(alias = "gst_rtsp_media_get_publish_clock_mode")]
#[doc(alias = "get_publish_clock_mode")]
fn publish_clock_mode(&self) -> RTSPPublishClockMode;
#[doc(alias = "gst_rtsp_media_get_range_string")]
#[doc(alias = "get_range_string")]
fn range_string(&self, play: bool, unit: gst_rtsp::RTSPRangeUnit) -> Option<glib::GString>;
#[cfg(any(feature = "v1_18", feature = "dox"))]
#[cfg_attr(feature = "dox", doc(cfg(feature = "v1_18")))]
#[doc(alias = "gst_rtsp_media_get_rate_control")]
#[doc(alias = "get_rate_control")]
fn is_rate_control(&self) -> bool;
#[cfg(any(feature = "v1_18", feature = "dox"))]
#[cfg_attr(feature = "dox", doc(cfg(feature = "v1_18")))]
#[doc(alias = "gst_rtsp_media_get_rates")]
#[doc(alias = "get_rates")]
fn rates(&self) -> Option<(f64, f64)>;
#[doc(alias = "gst_rtsp_media_get_retransmission_time")]
#[doc(alias = "get_retransmission_time")]
fn retransmission_time(&self) -> gst::ClockTime;
#[doc(alias = "gst_rtsp_media_get_status")]
#[doc(alias = "get_status")]
fn status(&self) -> RTSPMediaStatus;
#[doc(alias = "gst_rtsp_media_get_stream")]
#[doc(alias = "get_stream")]
fn stream(&self, idx: u32) -> Option<RTSPStream>;
#[doc(alias = "gst_rtsp_media_get_suspend_mode")]
#[doc(alias = "get_suspend_mode")]
fn suspend_mode(&self) -> RTSPSuspendMode;
#[doc(alias = "gst_rtsp_media_get_transport_mode")]
#[doc(alias = "get_transport_mode")]
fn transport_mode(&self) -> RTSPTransportMode;
#[cfg(any(feature = "v1_18", feature = "dox"))]
#[cfg_attr(feature = "dox", doc(cfg(feature = "v1_18")))]
#[doc(alias = "gst_rtsp_media_has_completed_sender")]
fn has_completed_sender(&self) -> bool;
#[cfg(any(feature = "v1_16", feature = "dox"))]
#[cfg_attr(feature = "dox", doc(cfg(feature = "v1_16")))]
#[doc(alias = "gst_rtsp_media_is_bind_mcast_address")]
fn is_bind_mcast_address(&self) -> bool;
#[doc(alias = "gst_rtsp_media_is_eos_shutdown")]
fn is_eos_shutdown(&self) -> bool;
#[cfg(any(feature = "v1_18", feature = "dox"))]
#[cfg_attr(feature = "dox", doc(cfg(feature = "v1_18")))]
#[doc(alias = "gst_rtsp_media_is_receive_only")]
fn is_receive_only(&self) -> bool;
#[doc(alias = "gst_rtsp_media_is_reusable")]
fn is_reusable(&self) -> bool;
#[doc(alias = "gst_rtsp_media_is_shared")]
fn is_shared(&self) -> bool;
#[doc(alias = "gst_rtsp_media_is_stop_on_disconnect")]
fn is_stop_on_disconnect(&self) -> bool;
#[doc(alias = "gst_rtsp_media_is_time_provider")]
fn is_time_provider(&self) -> bool;
#[cfg(any(feature = "v1_18", feature = "dox"))]
#[cfg_attr(feature = "dox", doc(cfg(feature = "v1_18")))]
#[doc(alias = "gst_rtsp_media_lock")]
fn lock(&self);
#[doc(alias = "gst_rtsp_media_n_streams")]
fn n_streams(&self) -> u32;
#[doc(alias = "gst_rtsp_media_prepare")]
fn prepare(&self, thread: Option<&RTSPThread>) -> Result<(), glib::error::BoolError>;
#[doc(alias = "gst_rtsp_media_set_address_pool")]
fn set_address_pool<P: IsA<RTSPAddressPool>>(&self, pool: Option<&P>);
#[cfg(any(feature = "v1_16", feature = "dox"))]
#[cfg_attr(feature = "dox", doc(cfg(feature = "v1_16")))]
#[doc(alias = "gst_rtsp_media_set_bind_mcast_address")]
fn set_bind_mcast_address(&self, bind_mcast_addr: bool);
#[doc(alias = "gst_rtsp_media_set_buffer_size")]
fn set_buffer_size(&self, size: u32);
#[doc(alias = "gst_rtsp_media_set_clock")]
fn set_clock<P: IsA<gst::Clock>>(&self, clock: Option<&P>);
#[cfg(any(feature = "v1_16", feature = "dox"))]
#[cfg_attr(feature = "dox", doc(cfg(feature = "v1_16")))]
#[doc(alias = "gst_rtsp_media_set_do_retransmission")]
fn set_do_retransmission(&self, do_retransmission: bool);
#[cfg(any(feature = "v1_18", feature = "dox"))]
#[cfg_attr(feature = "dox", doc(cfg(feature = "v1_18")))]
#[doc(alias = "gst_rtsp_media_set_dscp_qos")]
fn set_dscp_qos(&self, dscp_qos: i32);
#[doc(alias = "gst_rtsp_media_set_eos_shutdown")]
fn set_eos_shutdown(&self, eos_shutdown: bool);
#[doc(alias = "gst_rtsp_media_set_latency")]
fn set_latency(&self, latency: u32);
#[cfg(any(feature = "v1_16", feature = "dox"))]
#[cfg_attr(feature = "dox", doc(cfg(feature = "v1_16")))]
#[doc(alias = "gst_rtsp_media_set_max_mcast_ttl")]
fn set_max_mcast_ttl(&self, ttl: u32) -> bool;
#[doc(alias = "gst_rtsp_media_set_multicast_iface")]
fn set_multicast_iface(&self, multicast_iface: Option<&str>);
#[doc(alias = "gst_rtsp_media_set_pipeline_state")]
fn set_pipeline_state(&self, state: gst::State);
#[doc(alias = "gst_rtsp_media_set_profiles")]
fn set_profiles(&self, profiles: gst_rtsp::RTSPProfile);
#[doc(alias = "gst_rtsp_media_set_protocols")]
fn set_protocols(&self, protocols: gst_rtsp::RTSPLowerTrans);
#[doc(alias = "gst_rtsp_media_set_publish_clock_mode")]
fn set_publish_clock_mode(&self, mode: RTSPPublishClockMode);
#[cfg(any(feature = "v1_18", feature = "dox"))]
#[cfg_attr(feature = "dox", doc(cfg(feature = "v1_18")))]
#[doc(alias = "gst_rtsp_media_set_rate_control")]
fn set_rate_control(&self, enabled: bool);
#[doc(alias = "gst_rtsp_media_set_retransmission_time")]
fn set_retransmission_time(&self, time: gst::ClockTime);
#[doc(alias = "gst_rtsp_media_set_reusable")]
fn set_reusable(&self, reusable: bool);
#[doc(alias = "gst_rtsp_media_set_shared")]
fn set_shared(&self, shared: bool);
#[doc(alias = "gst_rtsp_media_set_state")]
fn set_state(&self, state: gst::State, transports: &[RTSPStreamTransport]) -> bool;
#[doc(alias = "gst_rtsp_media_set_stop_on_disconnect")]
fn set_stop_on_disconnect(&self, stop_on_disconnect: bool);
#[doc(alias = "gst_rtsp_media_set_suspend_mode")]
fn set_suspend_mode(&self, mode: RTSPSuspendMode);
#[doc(alias = "gst_rtsp_media_set_transport_mode")]
fn set_transport_mode(&self, mode: RTSPTransportMode);
#[doc(alias = "gst_rtsp_media_suspend")]
fn suspend(&self) -> Result<(), glib::error::BoolError>;
#[cfg(any(feature = "v1_18", feature = "dox"))]
#[cfg_attr(feature = "dox", doc(cfg(feature = "v1_18")))]
#[doc(alias = "gst_rtsp_media_unlock")]
fn unlock(&self);
#[doc(alias = "gst_rtsp_media_unprepare")]
fn unprepare(&self) -> Result<(), glib::error::BoolError>;
#[doc(alias = "gst_rtsp_media_unsuspend")]
fn unsuspend(&self) -> Result<(), glib::error::BoolError>;
#[doc(alias = "gst_rtsp_media_use_time_provider")]
fn use_time_provider(&self, time_provider: bool);
#[doc(alias = "bind-mcast-address")]
fn get_property_bind_mcast_address(&self) -> bool;
#[doc(alias = "bind-mcast-address")]
fn set_property_bind_mcast_address(&self, bind_mcast_address: bool);
#[doc(alias = "dscp-qos")]
fn get_property_dscp_qos(&self) -> i32;
#[doc(alias = "dscp-qos")]
fn set_property_dscp_qos(&self, dscp_qos: i32);
#[doc(alias = "max-mcast-ttl")]
fn get_property_max_mcast_ttl(&self) -> u32;
#[doc(alias = "max-mcast-ttl")]
fn set_property_max_mcast_ttl(&self, max_mcast_ttl: u32);
#[doc(alias = "time-provider")]
fn set_time_provider(&self, time_provider: bool);
#[doc(alias = "new-state")]
fn connect_new_state<F: Fn(&Self, i32) + Send + Sync + 'static>(&self, f: F)
-> SignalHandlerId;
#[doc(alias = "new-stream")]
fn connect_new_stream<F: Fn(&Self, &RTSPStream) + Send + Sync + 'static>(
&self,
f: F,
) -> SignalHandlerId;
#[doc(alias = "prepared")]
fn connect_prepared<F: Fn(&Self) + Send + Sync + 'static>(&self, f: F) -> SignalHandlerId;
#[doc(alias = "removed-stream")]
fn connect_removed_stream<F: Fn(&Self, &RTSPStream) + Send + Sync + 'static>(
&self,
f: F,
) -> SignalHandlerId;
#[doc(alias = "target-state")]
fn connect_target_state<F: Fn(&Self, i32) + Send + Sync + 'static>(
&self,
f: F,
) -> SignalHandlerId;
#[doc(alias = "unprepared")]
fn connect_unprepared<F: Fn(&Self) + Send + Sync + 'static>(&self, f: F) -> SignalHandlerId;
#[doc(alias = "bind-mcast-address")]
fn connect_bind_mcast_address_notify<F: Fn(&Self) + Send + Sync + 'static>(
&self,
f: F,
) -> SignalHandlerId;
#[doc(alias = "buffer-size")]
fn connect_buffer_size_notify<F: Fn(&Self) + Send + Sync + 'static>(
&self,
f: F,
) -> SignalHandlerId;
#[doc(alias = "clock")]
fn connect_clock_notify<F: Fn(&Self) + Send + Sync + 'static>(&self, f: F) -> SignalHandlerId;
#[doc(alias = "dscp-qos")]
fn connect_dscp_qos_notify<F: Fn(&Self) + Send + Sync + 'static>(
&self,
f: F,
) -> SignalHandlerId;
#[doc(alias = "eos-shutdown")]
fn connect_eos_shutdown_notify<F: Fn(&Self) + Send + Sync + 'static>(
&self,
f: F,
) -> SignalHandlerId;
#[doc(alias = "latency")]
fn connect_latency_notify<F: Fn(&Self) + Send + Sync + 'static>(&self, f: F)
-> SignalHandlerId;
#[doc(alias = "max-mcast-ttl")]
fn connect_max_mcast_ttl_notify<F: Fn(&Self) + Send + Sync + 'static>(
&self,
f: F,
) -> SignalHandlerId;
#[doc(alias = "profiles")]
fn connect_profiles_notify<F: Fn(&Self) + Send + Sync + 'static>(
&self,
f: F,
) -> SignalHandlerId;
#[doc(alias = "protocols")]
fn connect_protocols_notify<F: Fn(&Self) + Send + Sync + 'static>(
&self,
f: F,
) -> SignalHandlerId;
#[doc(alias = "reusable")]
fn connect_reusable_notify<F: Fn(&Self) + Send + Sync + 'static>(
&self,
f: F,
) -> SignalHandlerId;
#[doc(alias = "shared")]
fn connect_shared_notify<F: Fn(&Self) + Send + Sync + 'static>(&self, f: F) -> SignalHandlerId;
#[doc(alias = "stop-on-disconnect")]
fn connect_stop_on_disconnect_notify<F: Fn(&Self) + Send + Sync + 'static>(
&self,
f: F,
) -> SignalHandlerId;
#[doc(alias = "suspend-mode")]
fn connect_suspend_mode_notify<F: Fn(&Self) + Send + Sync + 'static>(
&self,
f: F,
) -> SignalHandlerId;
#[doc(alias = "time-provider")]
fn connect_time_provider_notify<F: Fn(&Self) + Send + Sync + 'static>(
&self,
f: F,
) -> SignalHandlerId;
#[doc(alias = "transport-mode")]
fn connect_transport_mode_notify<F: Fn(&Self) + Send + Sync + 'static>(
&self,
f: F,
) -> SignalHandlerId;
}
impl<O: IsA<RTSPMedia>> RTSPMediaExt for O {
fn collect_streams(&self) {
unsafe {
ffi::gst_rtsp_media_collect_streams(self.as_ref().to_glib_none().0);
}
}
fn create_stream<P: IsA<gst::Element>, Q: IsA<gst::Pad>>(
&self,
payloader: &P,
pad: &Q,
) -> Option<RTSPStream> {
unsafe {
from_glib_none(ffi::gst_rtsp_media_create_stream(
self.as_ref().to_glib_none().0,
payloader.as_ref().to_glib_none().0,
pad.as_ref().to_glib_none().0,
))
}
}
fn find_stream(&self, control: &str) -> Option<RTSPStream> {
unsafe {
from_glib_none(ffi::gst_rtsp_media_find_stream(
self.as_ref().to_glib_none().0,
control.to_glib_none().0,
))
}
}
fn address_pool(&self) -> Option<RTSPAddressPool> {
unsafe {
from_glib_full(ffi::gst_rtsp_media_get_address_pool(
self.as_ref().to_glib_none().0,
))
}
}
fn base_time(&self) -> gst::ClockTime {
unsafe {
from_glib(ffi::gst_rtsp_media_get_base_time(
self.as_ref().to_glib_none().0,
))
}
}
fn buffer_size(&self) -> u32 {
unsafe { ffi::gst_rtsp_media_get_buffer_size(self.as_ref().to_glib_none().0) }
}
fn clock(&self) -> Option<gst::Clock> {
unsafe {
from_glib_full(ffi::gst_rtsp_media_get_clock(
self.as_ref().to_glib_none().0,
))
}
}
#[cfg(any(feature = "v1_16", feature = "dox"))]
#[cfg_attr(feature = "dox", doc(cfg(feature = "v1_16")))]
fn does_retransmission(&self) -> bool {
unsafe {
from_glib(ffi::gst_rtsp_media_get_do_retransmission(
self.as_ref().to_glib_none().0,
))
}
}
#[cfg(any(feature = "v1_18", feature = "dox"))]
#[cfg_attr(feature = "dox", doc(cfg(feature = "v1_18")))]
fn dscp_qos(&self) -> i32 {
unsafe { ffi::gst_rtsp_media_get_dscp_qos(self.as_ref().to_glib_none().0) }
}
fn element(&self) -> Option<gst::Element> {
unsafe {
from_glib_full(ffi::gst_rtsp_media_get_element(
self.as_ref().to_glib_none().0,
))
}
}
fn latency(&self) -> u32 {
unsafe { ffi::gst_rtsp_media_get_latency(self.as_ref().to_glib_none().0) }
}
#[cfg(any(feature = "v1_16", feature = "dox"))]
#[cfg_attr(feature = "dox", doc(cfg(feature = "v1_16")))]
fn max_mcast_ttl(&self) -> u32 {
unsafe { ffi::gst_rtsp_media_get_max_mcast_ttl(self.as_ref().to_glib_none().0) }
}
fn multicast_iface(&self) -> Option<glib::GString> {
unsafe {
from_glib_full(ffi::gst_rtsp_media_get_multicast_iface(
self.as_ref().to_glib_none().0,
))
}
}
fn profiles(&self) -> gst_rtsp::RTSPProfile {
unsafe {
from_glib(ffi::gst_rtsp_media_get_profiles(
self.as_ref().to_glib_none().0,
))
}
}
fn protocols(&self) -> gst_rtsp::RTSPLowerTrans {
unsafe {
from_glib(ffi::gst_rtsp_media_get_protocols(
self.as_ref().to_glib_none().0,
))
}
}
fn publish_clock_mode(&self) -> RTSPPublishClockMode {
unsafe {
from_glib(ffi::gst_rtsp_media_get_publish_clock_mode(
self.as_ref().to_glib_none().0,
))
}
}
fn range_string(&self, play: bool, unit: gst_rtsp::RTSPRangeUnit) -> Option<glib::GString> {
unsafe {
from_glib_full(ffi::gst_rtsp_media_get_range_string(
self.as_ref().to_glib_none().0,
play.into_glib(),
unit.into_glib(),
))
}
}
#[cfg(any(feature = "v1_18", feature = "dox"))]
#[cfg_attr(feature = "dox", doc(cfg(feature = "v1_18")))]
fn is_rate_control(&self) -> bool {
unsafe {
from_glib(ffi::gst_rtsp_media_get_rate_control(
self.as_ref().to_glib_none().0,
))
}
}
#[cfg(any(feature = "v1_18", feature = "dox"))]
#[cfg_attr(feature = "dox", doc(cfg(feature = "v1_18")))]
fn rates(&self) -> Option<(f64, f64)> {
unsafe {
let mut rate = mem::MaybeUninit::uninit();
let mut applied_rate = mem::MaybeUninit::uninit();
let ret = from_glib(ffi::gst_rtsp_media_get_rates(
self.as_ref().to_glib_none().0,
rate.as_mut_ptr(),
applied_rate.as_mut_ptr(),
));
let rate = rate.assume_init();
let applied_rate = applied_rate.assume_init();
if ret {
Some((rate, applied_rate))
} else {
None
}
}
}
fn retransmission_time(&self) -> gst::ClockTime {
unsafe {
from_glib(ffi::gst_rtsp_media_get_retransmission_time(
self.as_ref().to_glib_none().0,
))
}
}
fn status(&self) -> RTSPMediaStatus {
unsafe {
from_glib(ffi::gst_rtsp_media_get_status(
self.as_ref().to_glib_none().0,
))
}
}
fn stream(&self, idx: u32) -> Option<RTSPStream> {
unsafe {
from_glib_none(ffi::gst_rtsp_media_get_stream(
self.as_ref().to_glib_none().0,
idx,
))
}
}
fn suspend_mode(&self) -> RTSPSuspendMode {
unsafe {
from_glib(ffi::gst_rtsp_media_get_suspend_mode(
self.as_ref().to_glib_none().0,
))
}
}
fn transport_mode(&self) -> RTSPTransportMode {
unsafe {
from_glib(ffi::gst_rtsp_media_get_transport_mode(
self.as_ref().to_glib_none().0,
))
}
}
#[cfg(any(feature = "v1_18", feature = "dox"))]
#[cfg_attr(feature = "dox", doc(cfg(feature = "v1_18")))]
fn has_completed_sender(&self) -> bool {
unsafe {
from_glib(ffi::gst_rtsp_media_has_completed_sender(
self.as_ref().to_glib_none().0,
))
}
}
#[cfg(any(feature = "v1_16", feature = "dox"))]
#[cfg_attr(feature = "dox", doc(cfg(feature = "v1_16")))]
fn is_bind_mcast_address(&self) -> bool {
unsafe {
from_glib(ffi::gst_rtsp_media_is_bind_mcast_address(
self.as_ref().to_glib_none().0,
))
}
}
fn is_eos_shutdown(&self) -> bool {
unsafe {
from_glib(ffi::gst_rtsp_media_is_eos_shutdown(
self.as_ref().to_glib_none().0,
))
}
}
#[cfg(any(feature = "v1_18", feature = "dox"))]
#[cfg_attr(feature = "dox", doc(cfg(feature = "v1_18")))]
fn is_receive_only(&self) -> bool {
unsafe {
from_glib(ffi::gst_rtsp_media_is_receive_only(
self.as_ref().to_glib_none().0,
))
}
}
fn is_reusable(&self) -> bool {
unsafe {
from_glib(ffi::gst_rtsp_media_is_reusable(
self.as_ref().to_glib_none().0,
))
}
}
fn is_shared(&self) -> bool {
unsafe {
from_glib(ffi::gst_rtsp_media_is_shared(
self.as_ref().to_glib_none().0,
))
}
}
fn is_stop_on_disconnect(&self) -> bool {
unsafe {
from_glib(ffi::gst_rtsp_media_is_stop_on_disconnect(
self.as_ref().to_glib_none().0,
))
}
}
fn is_time_provider(&self) -> bool {
unsafe {
from_glib(ffi::gst_rtsp_media_is_time_provider(
self.as_ref().to_glib_none().0,
))
}
}
#[cfg(any(feature = "v1_18", feature = "dox"))]
#[cfg_attr(feature = "dox", doc(cfg(feature = "v1_18")))]
fn lock(&self) {
unsafe {
ffi::gst_rtsp_media_lock(self.as_ref().to_glib_none().0);
}
}
fn n_streams(&self) -> u32 {
unsafe { ffi::gst_rtsp_media_n_streams(self.as_ref().to_glib_none().0) }
}
fn prepare(&self, thread: Option<&RTSPThread>) -> Result<(), glib::error::BoolError> {
unsafe {
glib::result_from_gboolean!(
ffi::gst_rtsp_media_prepare(self.as_ref().to_glib_none().0, thread.to_glib_full()),
"Failed to prepare media"
)
}
}
fn set_address_pool<P: IsA<RTSPAddressPool>>(&self, pool: Option<&P>) {
unsafe {
ffi::gst_rtsp_media_set_address_pool(
self.as_ref().to_glib_none().0,
pool.map(|p| p.as_ref()).to_glib_none().0,
);
}
}
#[cfg(any(feature = "v1_16", feature = "dox"))]
#[cfg_attr(feature = "dox", doc(cfg(feature = "v1_16")))]
fn set_bind_mcast_address(&self, bind_mcast_addr: bool) {
unsafe {
ffi::gst_rtsp_media_set_bind_mcast_address(
self.as_ref().to_glib_none().0,
bind_mcast_addr.into_glib(),
);
}
}
fn set_buffer_size(&self, size: u32) {
unsafe {
ffi::gst_rtsp_media_set_buffer_size(self.as_ref().to_glib_none().0, size);
}
}
fn set_clock<P: IsA<gst::Clock>>(&self, clock: Option<&P>) {
unsafe {
ffi::gst_rtsp_media_set_clock(
self.as_ref().to_glib_none().0,
clock.map(|p| p.as_ref()).to_glib_none().0,
);
}
}
#[cfg(any(feature = "v1_16", feature = "dox"))]
#[cfg_attr(feature = "dox", doc(cfg(feature = "v1_16")))]
fn set_do_retransmission(&self, do_retransmission: bool) {
unsafe {
ffi::gst_rtsp_media_set_do_retransmission(
self.as_ref().to_glib_none().0,
do_retransmission.into_glib(),
);
}
}
#[cfg(any(feature = "v1_18", feature = "dox"))]
#[cfg_attr(feature = "dox", doc(cfg(feature = "v1_18")))]
fn set_dscp_qos(&self, dscp_qos: i32) {
unsafe {
ffi::gst_rtsp_media_set_dscp_qos(self.as_ref().to_glib_none().0, dscp_qos);
}
}
fn set_eos_shutdown(&self, eos_shutdown: bool) {
unsafe {
ffi::gst_rtsp_media_set_eos_shutdown(
self.as_ref().to_glib_none().0,
eos_shutdown.into_glib(),
);
}
}
fn set_latency(&self, latency: u32) {
unsafe {
ffi::gst_rtsp_media_set_latency(self.as_ref().to_glib_none().0, latency);
}
}
#[cfg(any(feature = "v1_16", feature = "dox"))]
#[cfg_attr(feature = "dox", doc(cfg(feature = "v1_16")))]
fn set_max_mcast_ttl(&self, ttl: u32) -> bool {
unsafe {
from_glib(ffi::gst_rtsp_media_set_max_mcast_ttl(
self.as_ref().to_glib_none().0,
ttl,
))
}
}
fn set_multicast_iface(&self, multicast_iface: Option<&str>) {
unsafe {
ffi::gst_rtsp_media_set_multicast_iface(
self.as_ref().to_glib_none().0,
multicast_iface.to_glib_none().0,
);
}
}
fn set_pipeline_state(&self, state: gst::State) {
unsafe {
ffi::gst_rtsp_media_set_pipeline_state(
self.as_ref().to_glib_none().0,
state.into_glib(),
);
}
}
fn set_profiles(&self, profiles: gst_rtsp::RTSPProfile) {
unsafe {
ffi::gst_rtsp_media_set_profiles(self.as_ref().to_glib_none().0, profiles.into_glib());
}
}
fn set_protocols(&self, protocols: gst_rtsp::RTSPLowerTrans) {
unsafe {
ffi::gst_rtsp_media_set_protocols(
self.as_ref().to_glib_none().0,
protocols.into_glib(),
);
}
}
fn set_publish_clock_mode(&self, mode: RTSPPublishClockMode) {
unsafe {
ffi::gst_rtsp_media_set_publish_clock_mode(
self.as_ref().to_glib_none().0,
mode.into_glib(),
);
}
}
#[cfg(any(feature = "v1_18", feature = "dox"))]
#[cfg_attr(feature = "dox", doc(cfg(feature = "v1_18")))]
fn set_rate_control(&self, enabled: bool) {
unsafe {
ffi::gst_rtsp_media_set_rate_control(
self.as_ref().to_glib_none().0,
enabled.into_glib(),
);
}
}
fn set_retransmission_time(&self, time: gst::ClockTime) {
unsafe {
ffi::gst_rtsp_media_set_retransmission_time(
self.as_ref().to_glib_none().0,
time.into_glib(),
);
}
}
fn set_reusable(&self, reusable: bool) {
unsafe {
ffi::gst_rtsp_media_set_reusable(self.as_ref().to_glib_none().0, reusable.into_glib());
}
}
fn set_shared(&self, shared: bool) {
unsafe {
ffi::gst_rtsp_media_set_shared(self.as_ref().to_glib_none().0, shared.into_glib());
}
}
fn set_state(&self, state: gst::State, transports: &[RTSPStreamTransport]) -> bool {
unsafe {
from_glib(ffi::gst_rtsp_media_set_state(
self.as_ref().to_glib_none().0,
state.into_glib(),
transports.to_glib_none().0,
))
}
}
fn set_stop_on_disconnect(&self, stop_on_disconnect: bool) {
unsafe {
ffi::gst_rtsp_media_set_stop_on_disconnect(
self.as_ref().to_glib_none().0,
stop_on_disconnect.into_glib(),
);
}
}
fn set_suspend_mode(&self, mode: RTSPSuspendMode) {
unsafe {
ffi::gst_rtsp_media_set_suspend_mode(self.as_ref().to_glib_none().0, mode.into_glib());
}
}
fn set_transport_mode(&self, mode: RTSPTransportMode) {
unsafe {
ffi::gst_rtsp_media_set_transport_mode(
self.as_ref().to_glib_none().0,
mode.into_glib(),
);
}
}
fn suspend(&self) -> Result<(), glib::error::BoolError> {
unsafe {
glib::result_from_gboolean!(
ffi::gst_rtsp_media_suspend(self.as_ref().to_glib_none().0),
"Failed to suspend media"
)
}
}
#[cfg(any(feature = "v1_18", feature = "dox"))]
#[cfg_attr(feature = "dox", doc(cfg(feature = "v1_18")))]
fn unlock(&self) {
unsafe {
ffi::gst_rtsp_media_unlock(self.as_ref().to_glib_none().0);
}
}
fn unprepare(&self) -> Result<(), glib::error::BoolError> {
unsafe {
glib::result_from_gboolean!(
ffi::gst_rtsp_media_unprepare(self.as_ref().to_glib_none().0),
"Failed to unprepare media"
)
}
}
fn unsuspend(&self) -> Result<(), glib::error::BoolError> {
unsafe {
glib::result_from_gboolean!(
ffi::gst_rtsp_media_unsuspend(self.as_ref().to_glib_none().0),
"Failed to unsuspend media"
)
}
}
fn use_time_provider(&self, time_provider: bool) {
unsafe {
ffi::gst_rtsp_media_use_time_provider(
self.as_ref().to_glib_none().0,
time_provider.into_glib(),
);
}
}
fn get_property_bind_mcast_address(&self) -> bool {
unsafe {
let mut value = glib::Value::from_type(<bool as StaticType>::static_type());
glib::gobject_ffi::g_object_get_property(
self.to_glib_none().0 as *mut glib::gobject_ffi::GObject,
b"bind-mcast-address\0".as_ptr() as *const _,
value.to_glib_none_mut().0,
);
value
.get()
.expect("Return Value for property `bind-mcast-address` getter")
}
}
fn set_property_bind_mcast_address(&self, bind_mcast_address: bool) {
unsafe {
glib::gobject_ffi::g_object_set_property(
self.to_glib_none().0 as *mut glib::gobject_ffi::GObject,
b"bind-mcast-address\0".as_ptr() as *const _,
bind_mcast_address.to_value().to_glib_none().0,
);
}
}
fn get_property_dscp_qos(&self) -> i32 {
unsafe {
let mut value = glib::Value::from_type(<i32 as StaticType>::static_type());
glib::gobject_ffi::g_object_get_property(
self.to_glib_none().0 as *mut glib::gobject_ffi::GObject,
b"dscp-qos\0".as_ptr() as *const _,
value.to_glib_none_mut().0,
);
value
.get()
.expect("Return Value for property `dscp-qos` getter")
}
}
fn set_property_dscp_qos(&self, dscp_qos: i32) {
unsafe {
glib::gobject_ffi::g_object_set_property(
self.to_glib_none().0 as *mut glib::gobject_ffi::GObject,
b"dscp-qos\0".as_ptr() as *const _,
dscp_qos.to_value().to_glib_none().0,
);
}
}
fn get_property_max_mcast_ttl(&self) -> u32 {
unsafe {
let mut value = glib::Value::from_type(<u32 as StaticType>::static_type());
glib::gobject_ffi::g_object_get_property(
self.to_glib_none().0 as *mut glib::gobject_ffi::GObject,
b"max-mcast-ttl\0".as_ptr() as *const _,
value.to_glib_none_mut().0,
);
value
.get()
.expect("Return Value for property `max-mcast-ttl` getter")
}
}
fn set_property_max_mcast_ttl(&self, max_mcast_ttl: u32) {
unsafe {
glib::gobject_ffi::g_object_set_property(
self.to_glib_none().0 as *mut glib::gobject_ffi::GObject,
b"max-mcast-ttl\0".as_ptr() as *const _,
max_mcast_ttl.to_value().to_glib_none().0,
);
}
}
fn set_time_provider(&self, time_provider: bool) {
unsafe {
glib::gobject_ffi::g_object_set_property(
self.to_glib_none().0 as *mut glib::gobject_ffi::GObject,
b"time-provider\0".as_ptr() as *const _,
time_provider.to_value().to_glib_none().0,
);
}
}
#[doc(alias = "new-state")]
fn connect_new_state<F: Fn(&Self, i32) + Send + Sync + 'static>(
&self,
f: F,
) -> SignalHandlerId {
unsafe extern "C" fn new_state_trampoline<P, F: Fn(&P, i32) + Send + Sync + 'static>(
this: *mut ffi::GstRTSPMedia,
object: libc::c_int,
f: glib::ffi::gpointer,
) where
P: IsA<RTSPMedia>,
{
let f: &F = &*(f as *const F);
f(&RTSPMedia::from_glib_borrow(this).unsafe_cast_ref(), object)
}
unsafe {
let f: Box_<F> = Box_::new(f);
connect_raw(
self.as_ptr() as *mut _,
b"new-state\0".as_ptr() as *const _,
Some(transmute::<_, unsafe extern "C" fn()>(
new_state_trampoline::<Self, F> as *const (),
)),
Box_::into_raw(f),
)
}
}
#[doc(alias = "new-stream")]
fn connect_new_stream<F: Fn(&Self, &RTSPStream) + Send + Sync + 'static>(
&self,
f: F,
) -> SignalHandlerId {
unsafe extern "C" fn new_stream_trampoline<
P,
F: Fn(&P, &RTSPStream) + Send + Sync + 'static,
>(
this: *mut ffi::GstRTSPMedia,
object: *mut ffi::GstRTSPStream,
f: glib::ffi::gpointer,
) where
P: IsA<RTSPMedia>,
{
let f: &F = &*(f as *const F);
f(
&RTSPMedia::from_glib_borrow(this).unsafe_cast_ref(),
&from_glib_borrow(object),
)
}
unsafe {
let f: Box_<F> = Box_::new(f);
connect_raw(
self.as_ptr() as *mut _,
b"new-stream\0".as_ptr() as *const _,
Some(transmute::<_, unsafe extern "C" fn()>(
new_stream_trampoline::<Self, F> as *const (),
)),
Box_::into_raw(f),
)
}
}
#[doc(alias = "prepared")]
fn connect_prepared<F: Fn(&Self) + Send + Sync + 'static>(&self, f: F) -> SignalHandlerId {
unsafe extern "C" fn prepared_trampoline<P, F: Fn(&P) + Send + Sync + 'static>(
this: *mut ffi::GstRTSPMedia,
f: glib::ffi::gpointer,
) where
P: IsA<RTSPMedia>,
{
let f: &F = &*(f as *const F);
f(&RTSPMedia::from_glib_borrow(this).unsafe_cast_ref())
}
unsafe {
let f: Box_<F> = Box_::new(f);
connect_raw(
self.as_ptr() as *mut _,
b"prepared\0".as_ptr() as *const _,
Some(transmute::<_, unsafe extern "C" fn()>(
prepared_trampoline::<Self, F> as *const (),
)),
Box_::into_raw(f),
)
}
}
#[doc(alias = "removed-stream")]
fn connect_removed_stream<F: Fn(&Self, &RTSPStream) + Send + Sync + 'static>(
&self,
f: F,
) -> SignalHandlerId {
unsafe extern "C" fn removed_stream_trampoline<
P,
F: Fn(&P, &RTSPStream) + Send + Sync + 'static,
>(
this: *mut ffi::GstRTSPMedia,
object: *mut ffi::GstRTSPStream,
f: glib::ffi::gpointer,
) where
P: IsA<RTSPMedia>,
{
let f: &F = &*(f as *const F);
f(
&RTSPMedia::from_glib_borrow(this).unsafe_cast_ref(),
&from_glib_borrow(object),
)
}
unsafe {
let f: Box_<F> = Box_::new(f);
connect_raw(
self.as_ptr() as *mut _,
b"removed-stream\0".as_ptr() as *const _,
Some(transmute::<_, unsafe extern "C" fn()>(
removed_stream_trampoline::<Self, F> as *const (),
)),
Box_::into_raw(f),
)
}
}
#[doc(alias = "target-state")]
fn connect_target_state<F: Fn(&Self, i32) + Send + Sync + 'static>(
&self,
f: F,
) -> SignalHandlerId {
unsafe extern "C" fn target_state_trampoline<P, F: Fn(&P, i32) + Send + Sync + 'static>(
this: *mut ffi::GstRTSPMedia,
object: libc::c_int,
f: glib::ffi::gpointer,
) where
P: IsA<RTSPMedia>,
{
let f: &F = &*(f as *const F);
f(&RTSPMedia::from_glib_borrow(this).unsafe_cast_ref(), object)
}
unsafe {
let f: Box_<F> = Box_::new(f);
connect_raw(
self.as_ptr() as *mut _,
b"target-state\0".as_ptr() as *const _,
Some(transmute::<_, unsafe extern "C" fn()>(
target_state_trampoline::<Self, F> as *const (),
)),
Box_::into_raw(f),
)
}
}
#[doc(alias = "unprepared")]
fn connect_unprepared<F: Fn(&Self) + Send + Sync + 'static>(&self, f: F) -> SignalHandlerId {
unsafe extern "C" fn unprepared_trampoline<P, F: Fn(&P) + Send + Sync + 'static>(
this: *mut ffi::GstRTSPMedia,
f: glib::ffi::gpointer,
) where
P: IsA<RTSPMedia>,
{
let f: &F = &*(f as *const F);
f(&RTSPMedia::from_glib_borrow(this).unsafe_cast_ref())
}
unsafe {
let f: Box_<F> = Box_::new(f);
connect_raw(
self.as_ptr() as *mut _,
b"unprepared\0".as_ptr() as *const _,
Some(transmute::<_, unsafe extern "C" fn()>(
unprepared_trampoline::<Self, F> as *const (),
)),
Box_::into_raw(f),
)
}
}
#[doc(alias = "bind-mcast-address")]
fn connect_bind_mcast_address_notify<F: Fn(&Self) + Send + Sync + 'static>(
&self,
f: F,
) -> SignalHandlerId {
unsafe extern "C" fn notify_bind_mcast_address_trampoline<
P,
F: Fn(&P) + Send + Sync + 'static,
>(
this: *mut ffi::GstRTSPMedia,
_param_spec: glib::ffi::gpointer,
f: glib::ffi::gpointer,
) where
P: IsA<RTSPMedia>,
{
let f: &F = &*(f as *const F);
f(&RTSPMedia::from_glib_borrow(this).unsafe_cast_ref())
}
unsafe {
let f: Box_<F> = Box_::new(f);
connect_raw(
self.as_ptr() as *mut _,
b"notify::bind-mcast-address\0".as_ptr() as *const _,
Some(transmute::<_, unsafe extern "C" fn()>(
notify_bind_mcast_address_trampoline::<Self, F> as *const (),
)),
Box_::into_raw(f),
)
}
}
#[doc(alias = "buffer-size")]
fn connect_buffer_size_notify<F: Fn(&Self) + Send + Sync + 'static>(
&self,
f: F,
) -> SignalHandlerId {
unsafe extern "C" fn notify_buffer_size_trampoline<P, F: Fn(&P) + Send + Sync + 'static>(
this: *mut ffi::GstRTSPMedia,
_param_spec: glib::ffi::gpointer,
f: glib::ffi::gpointer,
) where
P: IsA<RTSPMedia>,
{
let f: &F = &*(f as *const F);
f(&RTSPMedia::from_glib_borrow(this).unsafe_cast_ref())
}
unsafe {
let f: Box_<F> = Box_::new(f);
connect_raw(
self.as_ptr() as *mut _,
b"notify::buffer-size\0".as_ptr() as *const _,
Some(transmute::<_, unsafe extern "C" fn()>(
notify_buffer_size_trampoline::<Self, F> as *const (),
)),
Box_::into_raw(f),
)
}
}
#[doc(alias = "clock")]
fn connect_clock_notify<F: Fn(&Self) + Send + Sync + 'static>(&self, f: F) -> SignalHandlerId {
unsafe extern "C" fn notify_clock_trampoline<P, F: Fn(&P) + Send + Sync + 'static>(
this: *mut ffi::GstRTSPMedia,
_param_spec: glib::ffi::gpointer,
f: glib::ffi::gpointer,
) where
P: IsA<RTSPMedia>,
{
let f: &F = &*(f as *const F);
f(&RTSPMedia::from_glib_borrow(this).unsafe_cast_ref())
}
unsafe {
let f: Box_<F> = Box_::new(f);
connect_raw(
self.as_ptr() as *mut _,
b"notify::clock\0".as_ptr() as *const _,
Some(transmute::<_, unsafe extern "C" fn()>(
notify_clock_trampoline::<Self, F> as *const (),
)),
Box_::into_raw(f),
)
}
}
#[doc(alias = "dscp-qos")]
fn connect_dscp_qos_notify<F: Fn(&Self) + Send + Sync + 'static>(
&self,
f: F,
) -> SignalHandlerId {
unsafe extern "C" fn notify_dscp_qos_trampoline<P, F: Fn(&P) + Send + Sync + 'static>(
this: *mut ffi::GstRTSPMedia,
_param_spec: glib::ffi::gpointer,
f: glib::ffi::gpointer,
) where
P: IsA<RTSPMedia>,
{
let f: &F = &*(f as *const F);
f(&RTSPMedia::from_glib_borrow(this).unsafe_cast_ref())
}
unsafe {
let f: Box_<F> = Box_::new(f);
connect_raw(
self.as_ptr() as *mut _,
b"notify::dscp-qos\0".as_ptr() as *const _,
Some(transmute::<_, unsafe extern "C" fn()>(
notify_dscp_qos_trampoline::<Self, F> as *const (),
)),
Box_::into_raw(f),
)
}
}
#[doc(alias = "eos-shutdown")]
fn connect_eos_shutdown_notify<F: Fn(&Self) + Send + Sync + 'static>(
&self,
f: F,
) -> SignalHandlerId {
unsafe extern "C" fn notify_eos_shutdown_trampoline<P, F: Fn(&P) + Send + Sync + 'static>(
this: *mut ffi::GstRTSPMedia,
_param_spec: glib::ffi::gpointer,
f: glib::ffi::gpointer,
) where
P: IsA<RTSPMedia>,
{
let f: &F = &*(f as *const F);
f(&RTSPMedia::from_glib_borrow(this).unsafe_cast_ref())
}
unsafe {
let f: Box_<F> = Box_::new(f);
connect_raw(
self.as_ptr() as *mut _,
b"notify::eos-shutdown\0".as_ptr() as *const _,
Some(transmute::<_, unsafe extern "C" fn()>(
notify_eos_shutdown_trampoline::<Self, F> as *const (),
)),
Box_::into_raw(f),
)
}
}
#[doc(alias = "latency")]
fn connect_latency_notify<F: Fn(&Self) + Send + Sync + 'static>(
&self,
f: F,
) -> SignalHandlerId {
unsafe extern "C" fn notify_latency_trampoline<P, F: Fn(&P) + Send + Sync + 'static>(
this: *mut ffi::GstRTSPMedia,
_param_spec: glib::ffi::gpointer,
f: glib::ffi::gpointer,
) where
P: IsA<RTSPMedia>,
{
let f: &F = &*(f as *const F);
f(&RTSPMedia::from_glib_borrow(this).unsafe_cast_ref())
}
unsafe {
let f: Box_<F> = Box_::new(f);
connect_raw(
self.as_ptr() as *mut _,
b"notify::latency\0".as_ptr() as *const _,
Some(transmute::<_, unsafe extern "C" fn()>(
notify_latency_trampoline::<Self, F> as *const (),
)),
Box_::into_raw(f),
)
}
}
#[doc(alias = "max-mcast-ttl")]
fn connect_max_mcast_ttl_notify<F: Fn(&Self) + Send + Sync + 'static>(
&self,
f: F,
) -> SignalHandlerId {
unsafe extern "C" fn notify_max_mcast_ttl_trampoline<P, F: Fn(&P) + Send + Sync + 'static>(
this: *mut ffi::GstRTSPMedia,
_param_spec: glib::ffi::gpointer,
f: glib::ffi::gpointer,
) where
P: IsA<RTSPMedia>,
{
let f: &F = &*(f as *const F);
f(&RTSPMedia::from_glib_borrow(this).unsafe_cast_ref())
}
unsafe {
let f: Box_<F> = Box_::new(f);
connect_raw(
self.as_ptr() as *mut _,
b"notify::max-mcast-ttl\0".as_ptr() as *const _,
Some(transmute::<_, unsafe extern "C" fn()>(
notify_max_mcast_ttl_trampoline::<Self, F> as *const (),
)),
Box_::into_raw(f),
)
}
}
#[doc(alias = "profiles")]
fn connect_profiles_notify<F: Fn(&Self) + Send + Sync + 'static>(
&self,
f: F,
) -> SignalHandlerId {
unsafe extern "C" fn notify_profiles_trampoline<P, F: Fn(&P) + Send + Sync + 'static>(
this: *mut ffi::GstRTSPMedia,
_param_spec: glib::ffi::gpointer,
f: glib::ffi::gpointer,
) where
P: IsA<RTSPMedia>,
{
let f: &F = &*(f as *const F);
f(&RTSPMedia::from_glib_borrow(this).unsafe_cast_ref())
}
unsafe {
let f: Box_<F> = Box_::new(f);
connect_raw(
self.as_ptr() as *mut _,
b"notify::profiles\0".as_ptr() as *const _,
Some(transmute::<_, unsafe extern "C" fn()>(
notify_profiles_trampoline::<Self, F> as *const (),
)),
Box_::into_raw(f),
)
}
}
#[doc(alias = "protocols")]
fn connect_protocols_notify<F: Fn(&Self) + Send + Sync + 'static>(
&self,
f: F,
) -> SignalHandlerId {
unsafe extern "C" fn notify_protocols_trampoline<P, F: Fn(&P) + Send + Sync + 'static>(
this: *mut ffi::GstRTSPMedia,
_param_spec: glib::ffi::gpointer,
f: glib::ffi::gpointer,
) where
P: IsA<RTSPMedia>,
{
let f: &F = &*(f as *const F);
f(&RTSPMedia::from_glib_borrow(this).unsafe_cast_ref())
}
unsafe {
let f: Box_<F> = Box_::new(f);
connect_raw(
self.as_ptr() as *mut _,
b"notify::protocols\0".as_ptr() as *const _,
Some(transmute::<_, unsafe extern "C" fn()>(
notify_protocols_trampoline::<Self, F> as *const (),
)),
Box_::into_raw(f),
)
}
}
#[doc(alias = "reusable")]
fn connect_reusable_notify<F: Fn(&Self) + Send + Sync + 'static>(
&self,
f: F,
) -> SignalHandlerId {
unsafe extern "C" fn notify_reusable_trampoline<P, F: Fn(&P) + Send + Sync + 'static>(
this: *mut ffi::GstRTSPMedia,
_param_spec: glib::ffi::gpointer,
f: glib::ffi::gpointer,
) where
P: IsA<RTSPMedia>,
{
let f: &F = &*(f as *const F);
f(&RTSPMedia::from_glib_borrow(this).unsafe_cast_ref())
}
unsafe {
let f: Box_<F> = Box_::new(f);
connect_raw(
self.as_ptr() as *mut _,
b"notify::reusable\0".as_ptr() as *const _,
Some(transmute::<_, unsafe extern "C" fn()>(
notify_reusable_trampoline::<Self, F> as *const (),
)),
Box_::into_raw(f),
)
}
}
#[doc(alias = "shared")]
fn connect_shared_notify<F: Fn(&Self) + Send + Sync + 'static>(&self, f: F) -> SignalHandlerId {
unsafe extern "C" fn notify_shared_trampoline<P, F: Fn(&P) + Send + Sync + 'static>(
this: *mut ffi::GstRTSPMedia,
_param_spec: glib::ffi::gpointer,
f: glib::ffi::gpointer,
) where
P: IsA<RTSPMedia>,
{
let f: &F = &*(f as *const F);
f(&RTSPMedia::from_glib_borrow(this).unsafe_cast_ref())
}
unsafe {
let f: Box_<F> = Box_::new(f);
connect_raw(
self.as_ptr() as *mut _,
b"notify::shared\0".as_ptr() as *const _,
Some(transmute::<_, unsafe extern "C" fn()>(
notify_shared_trampoline::<Self, F> as *const (),
)),
Box_::into_raw(f),
)
}
}
#[doc(alias = "stop-on-disconnect")]
fn connect_stop_on_disconnect_notify<F: Fn(&Self) + Send + Sync + 'static>(
&self,
f: F,
) -> SignalHandlerId {
unsafe extern "C" fn notify_stop_on_disconnect_trampoline<
P,
F: Fn(&P) + Send + Sync + 'static,
>(
this: *mut ffi::GstRTSPMedia,
_param_spec: glib::ffi::gpointer,
f: glib::ffi::gpointer,
) where
P: IsA<RTSPMedia>,
{
let f: &F = &*(f as *const F);
f(&RTSPMedia::from_glib_borrow(this).unsafe_cast_ref())
}
unsafe {
let f: Box_<F> = Box_::new(f);
connect_raw(
self.as_ptr() as *mut _,
b"notify::stop-on-disconnect\0".as_ptr() as *const _,
Some(transmute::<_, unsafe extern "C" fn()>(
notify_stop_on_disconnect_trampoline::<Self, F> as *const (),
)),
Box_::into_raw(f),
)
}
}
#[doc(alias = "suspend-mode")]
fn connect_suspend_mode_notify<F: Fn(&Self) + Send + Sync + 'static>(
&self,
f: F,
) -> SignalHandlerId {
unsafe extern "C" fn notify_suspend_mode_trampoline<P, F: Fn(&P) + Send + Sync + 'static>(
this: *mut ffi::GstRTSPMedia,
_param_spec: glib::ffi::gpointer,
f: glib::ffi::gpointer,
) where
P: IsA<RTSPMedia>,
{
let f: &F = &*(f as *const F);
f(&RTSPMedia::from_glib_borrow(this).unsafe_cast_ref())
}
unsafe {
let f: Box_<F> = Box_::new(f);
connect_raw(
self.as_ptr() as *mut _,
b"notify::suspend-mode\0".as_ptr() as *const _,
Some(transmute::<_, unsafe extern "C" fn()>(
notify_suspend_mode_trampoline::<Self, F> as *const (),
)),
Box_::into_raw(f),
)
}
}
#[doc(alias = "time-provider")]
fn connect_time_provider_notify<F: Fn(&Self) + Send + Sync + 'static>(
&self,
f: F,
) -> SignalHandlerId {
unsafe extern "C" fn notify_time_provider_trampoline<P, F: Fn(&P) + Send + Sync + 'static>(
this: *mut ffi::GstRTSPMedia,
_param_spec: glib::ffi::gpointer,
f: glib::ffi::gpointer,
) where
P: IsA<RTSPMedia>,
{
let f: &F = &*(f as *const F);
f(&RTSPMedia::from_glib_borrow(this).unsafe_cast_ref())
}
unsafe {
let f: Box_<F> = Box_::new(f);
connect_raw(
self.as_ptr() as *mut _,
b"notify::time-provider\0".as_ptr() as *const _,
Some(transmute::<_, unsafe extern "C" fn()>(
notify_time_provider_trampoline::<Self, F> as *const (),
)),
Box_::into_raw(f),
)
}
}
#[doc(alias = "transport-mode")]
fn connect_transport_mode_notify<F: Fn(&Self) + Send + Sync + 'static>(
&self,
f: F,
) -> SignalHandlerId {
unsafe extern "C" fn notify_transport_mode_trampoline<
P,
F: Fn(&P) + Send + Sync + 'static,
>(
this: *mut ffi::GstRTSPMedia,
_param_spec: glib::ffi::gpointer,
f: glib::ffi::gpointer,
) where
P: IsA<RTSPMedia>,
{
let f: &F = &*(f as *const F);
f(&RTSPMedia::from_glib_borrow(this).unsafe_cast_ref())
}
unsafe {
let f: Box_<F> = Box_::new(f);
connect_raw(
self.as_ptr() as *mut _,
b"notify::transport-mode\0".as_ptr() as *const _,
Some(transmute::<_, unsafe extern "C" fn()>(
notify_transport_mode_trampoline::<Self, F> as *const (),
)),
Box_::into_raw(f),
)
}
}
}