Welcome to mirror list, hosted at ThFree Co, Russian Federation.

gitlab.freedesktop.org/gstreamer/gst-plugins-rs.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorFrançois Laignel <fengalin@free.fr>2021-04-12 15:49:54 +0300
committerFrançois Laignel <fengalin@free.fr>2021-04-12 16:57:19 +0300
commit06accc8d98cc2876bcacfc6f9e097af690b4e64f (patch)
treee4f056143e5257d49b367dd28ef5fecaa1df9ebc /generic/threadshare/src/udpsink
parentc3fb55f235f7feb1ab737a64f8d3d53d03a81c7a (diff)
fix-getters-{def,calls} pass
Diffstat (limited to 'generic/threadshare/src/udpsink')
-rw-r--r--generic/threadshare/src/udpsink/imp.rs18
1 files changed, 9 insertions, 9 deletions
diff --git a/generic/threadshare/src/udpsink/imp.rs b/generic/threadshare/src/udpsink/imp.rs
index c9a1e519a..93b556bad 100644
--- a/generic/threadshare/src/udpsink/imp.rs
+++ b/generic/threadshare/src/udpsink/imp.rs
@@ -256,7 +256,7 @@ impl UdpSinkPadHandler {
self.0.write().unwrap().add_client(gst_pad, addr);
}
- fn get_clients(&self) -> Vec<SocketAddr> {
+ fn clients(&self) -> Vec<SocketAddr> {
(*self.0.read().unwrap().clients).clone()
}
@@ -411,7 +411,7 @@ impl UdpSinkPadHandler {
if let Some(segment) = &inner.segment {
if let Some(segment) = segment.downcast_ref::<gst::format::Time>() {
- rtime = segment.to_running_time(buffer.get_pts());
+ rtime = segment.to_running_time(buffer.pts());
if inner.latency.is_some() {
rtime += inner.latency;
}
@@ -522,7 +522,7 @@ impl UdpSinkPadHandler {
/* Wait until specified time */
async fn sync(&self, element: &super::UdpSink, running_time: gst::ClockTime) {
- let now = element.get_current_running_time();
+ let now = element.current_running_time();
if let Some(delay) = running_time
.saturating_sub(now)
@@ -538,10 +538,10 @@ impl UdpSinkPadHandler {
let _ = element.post_message(gst::message::Eos::builder().src(element).build());
}
EventView::Segment(e) => {
- self.0.write().unwrap().segment = Some(e.get_segment().clone());
+ self.0.write().unwrap().segment = Some(e.segment().clone());
}
EventView::SinkMessage(e) => {
- let _ = element.post_message(e.get_message());
+ let _ = element.post_message(e.message());
}
_ => (),
}
@@ -1193,7 +1193,7 @@ impl ObjectImpl for UdpSink {
pspec: &glib::ParamSpec,
) {
let mut settings = self.settings.lock().unwrap();
- match pspec.get_name() {
+ match pspec.name() {
"sync" => {
settings.sync = value.get_some().expect("type checked upstream");
}
@@ -1288,7 +1288,7 @@ impl ObjectImpl for UdpSink {
fn get_property(&self, _obj: &Self::Type, _id: usize, pspec: &glib::ParamSpec) -> glib::Value {
let settings = self.settings.lock().unwrap();
- match pspec.get_name() {
+ match pspec.name() {
"sync" => settings.sync.to_value(),
"bind-address" => settings.bind_address.to_value(),
"bind-port" => settings.bind_port.to_value(),
@@ -1324,7 +1324,7 @@ impl ObjectImpl for UdpSink {
let clients: Vec<String> = self
.sink_pad_handler
- .get_clients()
+ .clients()
.iter()
.map(ToString::to_string)
.collect();
@@ -1410,7 +1410,7 @@ impl ElementImpl for UdpSink {
fn send_event(&self, _element: &Self::Type, event: gst::Event) -> bool {
match event.view() {
EventView::Latency(ev) => {
- self.sink_pad_handler.set_latency(ev.get_latency());
+ self.sink_pad_handler.set_latency(ev.latency());
self.sink_pad.gst_pad().push_event(event)
}
EventView::Step(..) => false,