gstreamer/auto/
bus.rs

1// This file was generated by gir (https://github.com/gtk-rs/gir)
2// from gir-files (https://github.com/gtk-rs/gir-files)
3// from gst-gir-files (https://gitlab.freedesktop.org/gstreamer/gir-files-rs.git)
4// DO NOT EDIT
5
6use crate::{ClockTime, Message, Object, ffi};
7use glib::{
8    object::ObjectType as _,
9    prelude::*,
10    signal::{SignalHandlerId, connect_raw},
11    translate::*,
12};
13use std::boxed::Box as Box_;
14
15glib::wrapper! {
16    #[doc(alias = "GstBus")]
17    pub struct Bus(Object<ffi::GstBus, ffi::GstBusClass>) @extends Object;
18
19    match fn {
20        type_ => || ffi::gst_bus_get_type(),
21    }
22}
23
24impl Bus {
25    #[doc(alias = "gst_bus_new")]
26    pub fn new() -> Bus {
27        assert_initialized_main_thread!();
28        unsafe { from_glib_full(ffi::gst_bus_new()) }
29    }
30
31    #[doc(alias = "gst_bus_add_signal_watch")]
32    pub fn add_signal_watch(&self) {
33        unsafe {
34            ffi::gst_bus_add_signal_watch(self.to_glib_none().0);
35        }
36    }
37
38    //#[doc(alias = "gst_bus_async_signal_func")]
39    //pub fn async_signal_func(&self, message: &Message, data: /*Unimplemented*/Option<Basic: Pointer>) -> bool {
40    //    unsafe { TODO: call ffi:gst_bus_async_signal_func() }
41    //}
42
43    #[doc(alias = "gst_bus_disable_sync_message_emission")]
44    pub fn disable_sync_message_emission(&self) {
45        unsafe {
46            ffi::gst_bus_disable_sync_message_emission(self.to_glib_none().0);
47        }
48    }
49
50    #[doc(alias = "gst_bus_enable_sync_message_emission")]
51    pub fn enable_sync_message_emission(&self) {
52        unsafe {
53            ffi::gst_bus_enable_sync_message_emission(self.to_glib_none().0);
54        }
55    }
56
57    //#[doc(alias = "gst_bus_get_pollfd")]
58    //#[doc(alias = "get_pollfd")]
59    //pub fn pollfd(&self, fd: /*Ignored*/glib::PollFD) {
60    //    unsafe { TODO: call ffi:gst_bus_get_pollfd() }
61    //}
62
63    #[doc(alias = "gst_bus_have_pending")]
64    pub fn have_pending(&self) -> bool {
65        unsafe { from_glib(ffi::gst_bus_have_pending(self.to_glib_none().0)) }
66    }
67
68    #[doc(alias = "gst_bus_peek")]
69    pub fn peek(&self) -> Option<Message> {
70        unsafe { from_glib_full(ffi::gst_bus_peek(self.to_glib_none().0)) }
71    }
72
73    #[doc(alias = "gst_bus_pop")]
74    pub fn pop(&self) -> Option<Message> {
75        unsafe { from_glib_full(ffi::gst_bus_pop(self.to_glib_none().0)) }
76    }
77
78    #[doc(alias = "gst_bus_post")]
79    pub fn post(&self, message: Message) -> Result<(), glib::error::BoolError> {
80        unsafe {
81            glib::result_from_gboolean!(
82                ffi::gst_bus_post(self.to_glib_none().0, message.into_glib_ptr()),
83                "Failed to post message"
84            )
85        }
86    }
87
88    #[doc(alias = "gst_bus_remove_signal_watch")]
89    pub fn remove_signal_watch(&self) {
90        unsafe {
91            ffi::gst_bus_remove_signal_watch(self.to_glib_none().0);
92        }
93    }
94
95    #[doc(alias = "gst_bus_remove_watch")]
96    #[allow(dead_code)]
97    pub(crate) fn remove_watch(&self) -> Result<(), glib::error::BoolError> {
98        unsafe {
99            glib::result_from_gboolean!(
100                ffi::gst_bus_remove_watch(self.to_glib_none().0),
101                "Bus has no event source"
102            )
103        }
104    }
105
106    #[doc(alias = "gst_bus_set_flushing")]
107    pub fn set_flushing(&self, flushing: bool) {
108        unsafe {
109            ffi::gst_bus_set_flushing(self.to_glib_none().0, flushing.into_glib());
110        }
111    }
112
113    //#[doc(alias = "gst_bus_sync_signal_handler")]
114    //pub fn sync_signal_handler(&self, message: &Message, data: /*Unimplemented*/Option<Basic: Pointer>) -> BusSyncReply {
115    //    unsafe { TODO: call ffi:gst_bus_sync_signal_handler() }
116    //}
117
118    #[doc(alias = "gst_bus_timed_pop")]
119    pub fn timed_pop(&self, timeout: impl Into<Option<ClockTime>>) -> Option<Message> {
120        unsafe {
121            from_glib_full(ffi::gst_bus_timed_pop(
122                self.to_glib_none().0,
123                timeout.into().into_glib(),
124            ))
125        }
126    }
127
128    #[doc(alias = "message")]
129    pub fn connect_message<F: Fn(&Self, &Message) + Send + 'static>(
130        &self,
131        detail: Option<&str>,
132        f: F,
133    ) -> SignalHandlerId {
134        unsafe extern "C" fn message_trampoline<F: Fn(&Bus, &Message) + Send + 'static>(
135            this: *mut ffi::GstBus,
136            message: *mut ffi::GstMessage,
137            f: glib::ffi::gpointer,
138        ) {
139            unsafe {
140                let f: &F = &*(f as *const F);
141                f(&from_glib_borrow(this), &from_glib_borrow(message))
142            }
143        }
144        unsafe {
145            let f: Box_<F> = Box_::new(f);
146            let detailed_signal_name = detail.map(|name| format!("message::{name}\0"));
147            let signal_name = detailed_signal_name.as_ref().map_or(c"message", |n| {
148                std::ffi::CStr::from_bytes_with_nul_unchecked(n.as_bytes())
149            });
150            connect_raw(
151                self.as_ptr() as *mut _,
152                signal_name.as_ptr(),
153                Some(std::mem::transmute::<*const (), unsafe extern "C" fn()>(
154                    message_trampoline::<F> as *const (),
155                )),
156                Box_::into_raw(f),
157            )
158        }
159    }
160
161    #[doc(alias = "sync-message")]
162    pub fn connect_sync_message<F: Fn(&Self, &Message) + Send + Sync + 'static>(
163        &self,
164        detail: Option<&str>,
165        f: F,
166    ) -> SignalHandlerId {
167        unsafe extern "C" fn sync_message_trampoline<
168            F: Fn(&Bus, &Message) + Send + Sync + 'static,
169        >(
170            this: *mut ffi::GstBus,
171            message: *mut ffi::GstMessage,
172            f: glib::ffi::gpointer,
173        ) {
174            unsafe {
175                let f: &F = &*(f as *const F);
176                f(&from_glib_borrow(this), &from_glib_borrow(message))
177            }
178        }
179        unsafe {
180            let f: Box_<F> = Box_::new(f);
181            let detailed_signal_name = detail.map(|name| format!("sync-message::{name}\0"));
182            let signal_name = detailed_signal_name.as_ref().map_or(c"sync-message", |n| {
183                std::ffi::CStr::from_bytes_with_nul_unchecked(n.as_bytes())
184            });
185            connect_raw(
186                self.as_ptr() as *mut _,
187                signal_name.as_ptr(),
188                Some(std::mem::transmute::<*const (), unsafe extern "C" fn()>(
189                    sync_message_trampoline::<F> as *const (),
190                )),
191                Box_::into_raw(f),
192            )
193        }
194    }
195}
196
197impl Default for Bus {
198    fn default() -> Self {
199        Self::new()
200    }
201}
202
203unsafe impl Send for Bus {}
204unsafe impl Sync for Bus {}
gstreamer/auto/bus.rs

gstreamer/auto/
bus.rs
