gio/unix_input_stream.rs
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
// Take a look at the license at the top of the repository in the LICENSE file.
#[cfg(unix)]
use std::os::unix::io::{AsRawFd, IntoRawFd, RawFd};
use glib::{prelude::*, translate::*};
#[cfg(all(not(unix), docsrs))]
use socket::{AsRawFd, IntoRawFd, RawFd};
use crate::{ffi, InputStream, UnixInputStream};
impl UnixInputStream {
// rustdoc-stripper-ignore-next
/// Creates a new [`Self`] that takes ownership of the passed in fd.
///
/// # Safety
/// You must not close the fd unless you've previously called [`UnixInputStreamExtManual::set_close_fd`]
/// with `true` on this stream. At which point you may only do so when all references to this
/// stream have been dropped.
#[doc(alias = "g_unix_input_stream_new")]
pub unsafe fn take_fd(fd: impl IntoRawFd) -> UnixInputStream {
let fd = fd.into_raw_fd();
let close_fd = true.into_glib();
InputStream::from_glib_full(ffi::g_unix_input_stream_new(fd, close_fd)).unsafe_cast()
}
// rustdoc-stripper-ignore-next
/// Creates a new [`Self`] that does not take ownership of the passed in fd.
///
/// # Safety
/// You may only close the fd if all references to this stream have been dropped.
#[doc(alias = "g_unix_input_stream_new")]
pub unsafe fn with_fd<T: AsRawFd>(fd: T) -> UnixInputStream {
let fd = fd.as_raw_fd();
let close_fd = false.into_glib();
InputStream::from_glib_full(ffi::g_unix_input_stream_new(fd, close_fd)).unsafe_cast()
}
}
impl AsRawFd for UnixInputStream {
fn as_raw_fd(&self) -> RawFd {
unsafe { ffi::g_unix_input_stream_get_fd(self.to_glib_none().0) as _ }
}
}
mod sealed {
pub trait Sealed {}
impl<T: super::IsA<super::UnixInputStream>> Sealed for T {}
}
pub trait UnixInputStreamExtManual: sealed::Sealed + IsA<UnixInputStream> + Sized {
// rustdoc-stripper-ignore-next
/// Sets whether the fd of this stream will be closed when the stream is closed.
///
/// # Safety
/// If you pass in `false` as the parameter, you may only close the fd if the all references
/// to the stream have been dropped. If you pass in `true`, you must never call close.
#[doc(alias = "g_unix_input_stream_set_close_fd")]
unsafe fn set_close_fd(&self, close_fd: bool) {
ffi::g_unix_input_stream_set_close_fd(self.as_ref().to_glib_none().0, close_fd.into_glib());
}
}
impl<O: IsA<UnixInputStream>> UnixInputStreamExtManual for O {}