1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192
// This file was generated by gir (https://github.com/gtk-rs/gir)
// from gir-files (https://github.com/gtk-rs/gir-files)
// from gst-gir-files (https://gitlab.freedesktop.org/gstreamer/gir-files-rs.git)
// DO NOT EDIT
use crate::ffi;
use glib::{
prelude::*,
signal::{connect_raw, SignalHandlerId},
translate::*,
};
use std::boxed::Box as Box_;
glib::wrapper! {
/// This object exposes the time of a [`gst::Clock`][crate::gst::Clock] on the network.
///
/// A [`NetTimeProvider`][crate::NetTimeProvider] is created with [`new()`][Self::new()] which
/// takes a [`gst::Clock`][crate::gst::Clock], an address and a port number as arguments.
///
/// After creating the object, a client clock such as [`NetClientClock`][crate::NetClientClock] can
/// query the exposed clock over the network for its values.
///
/// The [`NetTimeProvider`][crate::NetTimeProvider] typically wraps the clock used by a [`gst::Pipeline`][crate::gst::Pipeline].
///
/// ## Properties
///
///
/// #### `active`
/// Readable | Writeable
///
///
/// #### `address`
/// Readable | Writeable | Construct Only
///
///
/// #### `clock`
/// Readable | Writeable | Construct Only
///
///
/// #### `port`
/// Readable | Writeable | Construct Only
///
///
/// #### `qos-dscp`
/// Readable | Writeable
/// <details><summary><h4>Object</h4></summary>
///
///
/// #### `name`
/// Readable | Writeable | Construct
///
///
/// #### `parent`
/// The parent of the object. Please note, that when changing the 'parent'
/// property, we don't emit [`notify`][struct@crate::glib::Object#notify] and [`deep-notify`][struct@crate::gst::Object#deep-notify]
/// signals due to locking issues. In some cases one can use
/// `GstBin::element-added` or `GstBin::element-removed` signals on the parent to
/// achieve a similar effect.
///
/// Readable | Writeable
/// </details>
///
/// # Implements
///
/// [`trait@gst::prelude::ObjectExt`], [`trait@glib::ObjectExt`]
#[doc(alias = "GstNetTimeProvider")]
pub struct NetTimeProvider(Object<ffi::GstNetTimeProvider, ffi::GstNetTimeProviderClass>) @extends gst::Object;
match fn {
type_ => || ffi::gst_net_time_provider_get_type(),
}
}
impl NetTimeProvider {
/// Allows network clients to get the current time of `clock`.
/// ## `clock`
/// a [`gst::Clock`][crate::gst::Clock] to export over the network
/// ## `address`
/// an address to bind on as a dotted quad
/// (xxx.xxx.xxx.xxx), IPv6 address, or NULL to bind to all addresses
/// ## `port`
/// a port to bind on, or 0 to let the kernel choose
///
/// # Returns
///
/// the new [`NetTimeProvider`][crate::NetTimeProvider], or NULL on error
#[doc(alias = "gst_net_time_provider_new")]
pub fn new(
clock: &impl IsA<gst::Clock>,
address: Option<&str>,
port: i32,
) -> Result<NetTimeProvider, glib::BoolError> {
assert_initialized_main_thread!();
unsafe {
Option::<_>::from_glib_full(ffi::gst_net_time_provider_new(
clock.as_ref().to_glib_none().0,
address.to_glib_none().0,
port,
))
.ok_or_else(|| glib::bool_error!("Failed to create NetTimeProvider"))
}
}
pub fn is_active(&self) -> bool {
ObjectExt::property(self, "active")
}
pub fn set_active(&self, active: bool) {
ObjectExt::set_property(self, "active", active)
}
pub fn address(&self) -> Option<glib::GString> {
ObjectExt::property(self, "address")
}
pub fn clock(&self) -> Option<gst::Clock> {
ObjectExt::property(self, "clock")
}
pub fn port(&self) -> i32 {
ObjectExt::property(self, "port")
}
#[doc(alias = "qos-dscp")]
pub fn qos_dscp(&self) -> i32 {
ObjectExt::property(self, "qos-dscp")
}
#[doc(alias = "qos-dscp")]
pub fn set_qos_dscp(&self, qos_dscp: i32) {
ObjectExt::set_property(self, "qos-dscp", qos_dscp)
}
#[doc(alias = "active")]
pub fn connect_active_notify<F: Fn(&Self) + Send + Sync + 'static>(
&self,
f: F,
) -> SignalHandlerId {
unsafe extern "C" fn notify_active_trampoline<
F: Fn(&NetTimeProvider) + Send + Sync + 'static,
>(
this: *mut ffi::GstNetTimeProvider,
_param_spec: glib::ffi::gpointer,
f: glib::ffi::gpointer,
) {
let f: &F = &*(f as *const F);
f(&from_glib_borrow(this))
}
unsafe {
let f: Box_<F> = Box_::new(f);
connect_raw(
self.as_ptr() as *mut _,
b"notify::active\0".as_ptr() as *const _,
Some(std::mem::transmute::<*const (), unsafe extern "C" fn()>(
notify_active_trampoline::<F> as *const (),
)),
Box_::into_raw(f),
)
}
}
#[doc(alias = "qos-dscp")]
pub fn connect_qos_dscp_notify<F: Fn(&Self) + Send + Sync + 'static>(
&self,
f: F,
) -> SignalHandlerId {
unsafe extern "C" fn notify_qos_dscp_trampoline<
F: Fn(&NetTimeProvider) + Send + Sync + 'static,
>(
this: *mut ffi::GstNetTimeProvider,
_param_spec: glib::ffi::gpointer,
f: glib::ffi::gpointer,
) {
let f: &F = &*(f as *const F);
f(&from_glib_borrow(this))
}
unsafe {
let f: Box_<F> = Box_::new(f);
connect_raw(
self.as_ptr() as *mut _,
b"notify::qos-dscp\0".as_ptr() as *const _,
Some(std::mem::transmute::<*const (), unsafe extern "C" fn()>(
notify_qos_dscp_trampoline::<F> as *const (),
)),
Box_::into_raw(f),
)
}
}
}
unsafe impl Send for NetTimeProvider {}
unsafe impl Sync for NetTimeProvider {}