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:
Diffstat (limited to 'generic/threadshare/src/jitterbuffer/jitterbuffer.rs')
-rw-r--r--generic/threadshare/src/jitterbuffer/jitterbuffer.rs23
1 files changed, 10 insertions, 13 deletions
diff --git a/generic/threadshare/src/jitterbuffer/jitterbuffer.rs b/generic/threadshare/src/jitterbuffer/jitterbuffer.rs
index 5984db98f..d240e3e24 100644
--- a/generic/threadshare/src/jitterbuffer/jitterbuffer.rs
+++ b/generic/threadshare/src/jitterbuffer/jitterbuffer.rs
@@ -19,9 +19,6 @@ use super::ffi;
use std::ptr;
-use glib_sys as glib_ffi;
-use gstreamer_sys as gst_ffi;
-
use glib::glib_wrapper;
use glib::prelude::*;
use glib::translate::*;
@@ -81,7 +78,7 @@ impl RTPJitterBufferItem {
rtptime: u32,
) -> RTPJitterBufferItem {
unsafe {
- let ptr = ptr::NonNull::new(glib_sys::g_slice_alloc0(mem::size_of::<
+ let ptr = ptr::NonNull::new(glib::ffi::g_slice_alloc0(mem::size_of::<
ffi::RTPJitterBufferItem,
>()) as *mut ffi::RTPJitterBufferItem)
.expect("Allocation failed");
@@ -107,8 +104,8 @@ impl RTPJitterBufferItem {
pub fn into_buffer(mut self) -> gst::Buffer {
unsafe {
let item = self.0.take().expect("Invalid wrapper");
- let buf = item.as_ref().data as *mut gst_ffi::GstBuffer;
- glib_sys::g_slice_free1(
+ let buf = item.as_ref().data as *mut gst::ffi::GstBuffer;
+ glib::ffi::g_slice_free1(
mem::size_of::<ffi::RTPJitterBufferItem>(),
item.as_ptr() as *mut _,
);
@@ -119,7 +116,7 @@ impl RTPJitterBufferItem {
pub fn get_dts(&self) -> gst::ClockTime {
unsafe {
let item = self.0.as_ref().expect("Invalid wrapper");
- if item.as_ref().dts == gst_ffi::GST_CLOCK_TIME_NONE {
+ if item.as_ref().dts == gst::ffi::GST_CLOCK_TIME_NONE {
gst::CLOCK_TIME_NONE
} else {
gst::ClockTime(Some(item.as_ref().dts))
@@ -130,7 +127,7 @@ impl RTPJitterBufferItem {
pub fn get_pts(&self) -> gst::ClockTime {
unsafe {
let item = self.0.as_ref().expect("Invalid wrapper");
- if item.as_ref().pts == gst_ffi::GST_CLOCK_TIME_NONE {
+ if item.as_ref().pts == gst::ffi::GST_CLOCK_TIME_NONE {
gst::CLOCK_TIME_NONE
} else {
gst::ClockTime(Some(item.as_ref().pts))
@@ -163,10 +160,10 @@ impl Drop for RTPJitterBufferItem {
unsafe {
if let Some(ref item) = self.0 {
if !item.as_ref().data.is_null() {
- gst_ffi::gst_mini_object_unref(item.as_ref().data as *mut _);
+ gst::ffi::gst_mini_object_unref(item.as_ref().data as *mut _);
}
- glib_sys::g_slice_free1(
+ glib::ffi::g_slice_free1(
mem::size_of::<ffi::RTPJitterBufferItem>(),
item.as_ptr() as *mut _,
);
@@ -274,7 +271,7 @@ impl RTPJitterBuffer {
is_rtx.to_glib(),
);
- if pts == gst_ffi::GST_CLOCK_TIME_NONE {
+ if pts == gst::ffi::GST_CLOCK_TIME_NONE {
gst::CLOCK_TIME_NONE
} else {
pts.into()
@@ -319,7 +316,7 @@ impl RTPJitterBuffer {
Some(seqnum as u16)
};
- if pts == gst_ffi::GST_CLOCK_TIME_NONE {
+ if pts == gst::ffi::GST_CLOCK_TIME_NONE {
(gst::CLOCK_TIME_NONE, seqnum)
} else {
(pts.into(), seqnum)
@@ -361,7 +358,7 @@ impl RTPJitterBuffer {
}
pub fn flush(&self) {
- unsafe extern "C" fn free_item(item: glib_ffi::gpointer, _: glib_ffi::gpointer) {
+ unsafe extern "C" fn free_item(item: glib::ffi::gpointer, _: glib::ffi::gpointer) {
let _ =
RTPJitterBufferItem(Some(ptr::NonNull::new(item as *mut _).expect("NULL item")));
}