mirrors/gstreamer-rs
mirrors/gstreamer-rs
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer-rs.git synced 2024-05-14 22:32:41 +00:00
Code Issues Projects Releases Wiki Activity

gstreamer: buffer: Add bindings for Buffer::map_range_readable() and _writable()

Browse source 
Fixes https://gitlab.freedesktop.org/gstreamer/gstreamer-rs/-/issues/496

Part-of: <https://gitlab.freedesktop.org/gstreamer/gstreamer-rs/-/merge_requests/1363>
This commit is contained in:
Sebastian Dröge 2023-12-10 19:05:58 +02:00
parent 248b6d2f31
commit 33e3e25b49
1 changed files with 92 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

92
gstreamer/src/buffer.rs
View file

@ -207,6 +207,98 @@ impl BufferRef {
}
}
fn memory_range_into_idx_len(
&self,
range: impl RangeBounds<u32>,
) -> Result<(u32, i32), glib::BoolError> {
let n_memory = self.n_memory();
let start_idx = match range.start_bound() {
ops::Bound::Included(idx) if *idx >= n_memory => {
return Err(glib::bool_error!("Invalid range start"));
}
ops::Bound::Included(idx) => *idx,
ops::Bound::Excluded(idx) if idx.checked_add(1).map_or(true, |idx| idx >= n_memory) => {
return Err(glib::bool_error!("Invalid range start"));
}
ops::Bound::Excluded(idx) => *idx + 1,
ops::Bound::Unbounded => 0,
};
let end_idx = match range.end_bound() {
ops::Bound::Included(idx) if idx.checked_add(1).map_or(true, |idx| idx >= n_memory) => {
return Err(glib::bool_error!("Invalid range end"));
}
ops::Bound::Included(idx) => *idx + 1,
ops::Bound::Excluded(idx) if *idx >= n_memory => {
return Err(glib::bool_error!("Invalid range end"));
}
ops::Bound::Excluded(idx) => *idx,
ops::Bound::Unbounded => n_memory,
};
Ok((
start_idx,
i32::try_from(end_idx - start_idx).map_err(|_| glib::bool_error!("Too large range"))?,
))
}
#[doc(alias = "gst_buffer_map_range")]
#[inline]
pub fn map_range_readable(
&self,
range: impl RangeBounds<u32>,
) -> Result<BufferMap<Readable>, glib::BoolError> {
let (idx, len) = self.memory_range_into_idx_len(range)?;
unsafe {
let mut map_info = mem::MaybeUninit::uninit();
let res = ffi::gst_buffer_map_range(
self.as_mut_ptr(),
idx,
len,
map_info.as_mut_ptr(),
ffi::GST_MAP_READ,
);
if res == glib::ffi::GTRUE {
Ok(BufferMap {
buffer: self,
map_info: map_info.assume_init(),
phantom: PhantomData,
})
} else {
Err(glib::bool_error!("Failed to map buffer readable"))
}
}
}
#[doc(alias = "gst_buffer_map_range")]
#[inline]
pub fn map_range_writable(
&mut self,
range: impl RangeBounds<u32>,
) -> Result<BufferMap<Writable>, glib::BoolError> {
let (idx, len) = self.memory_range_into_idx_len(range)?;
unsafe {
let mut map_info = mem::MaybeUninit::uninit();
let res = ffi::gst_buffer_map_range(
self.as_mut_ptr(),
idx,
len,
map_info.as_mut_ptr(),
ffi::GST_MAP_READWRITE,
);
if res == glib::ffi::GTRUE {
Ok(BufferMap {
buffer: self,
map_info: map_info.assume_init(),
phantom: PhantomData,
})
} else {
Err(glib::bool_error!("Failed to map buffer writable"))
}
}
}
#[doc(alias = "gst_buffer_copy_region")]
pub fn copy_region(
&self,