#![unstable(feature = "sgx_platform", issue = "56975")]
use crate::net;
pub use crate::sys::abi::usercalls::raw::Fd as RawFd;
use crate::sys::{self, AsInner, FromInner, IntoInner, TryIntoInner};
#[unstable(feature = "sgx_platform", issue = "56975")]
pub trait AsRawFd {
#[unstable(feature = "sgx_platform", issue = "56975")]
fn as_raw_fd(&self) -> RawFd;
}
#[unstable(feature = "sgx_platform", issue = "56975")]
pub trait FromRawFd {
type Metadata: Default;
#[unstable(feature = "sgx_platform", issue = "56975")]
unsafe fn from_raw_fd(fd: RawFd, metadata: Self::Metadata) -> Self;
}
#[unstable(feature = "sgx_platform", issue = "56975")]
pub trait TryIntoRawFd: Sized {
#[unstable(feature = "sgx_platform", issue = "56975")]
fn try_into_raw_fd(self) -> Result<RawFd, Self>;
}
impl AsRawFd for net::TcpStream {
#[inline]
fn as_raw_fd(&self) -> RawFd {
*self.as_inner().as_inner().as_inner().as_inner()
}
}
impl AsRawFd for net::TcpListener {
#[inline]
fn as_raw_fd(&self) -> RawFd {
*self.as_inner().as_inner().as_inner().as_inner()
}
}
#[derive(Debug, Clone, Default)]
#[unstable(feature = "sgx_platform", issue = "56975")]
pub struct TcpStreamMetadata {
pub local_addr: Option<String>,
pub peer_addr: Option<String>,
}
impl FromRawFd for net::TcpStream {
type Metadata = TcpStreamMetadata;
#[inline]
unsafe fn from_raw_fd(fd: RawFd, metadata: Self::Metadata) -> net::TcpStream {
let fd = sys::fd::FileDesc::from_inner(fd);
let socket = sys::net::Socket::from_inner((fd, metadata.local_addr));
net::TcpStream::from_inner(sys::net::TcpStream::from_inner((socket, metadata.peer_addr)))
}
}
#[derive(Debug, Clone, Default)]
#[unstable(feature = "sgx_platform", issue = "56975")]
pub struct TcpListenerMetadata {
pub local_addr: Option<String>,
}
impl FromRawFd for net::TcpListener {
type Metadata = TcpListenerMetadata;
#[inline]
unsafe fn from_raw_fd(fd: RawFd, metadata: Self::Metadata) -> net::TcpListener {
let fd = sys::fd::FileDesc::from_inner(fd);
let socket = sys::net::Socket::from_inner((fd, metadata.local_addr));
net::TcpListener::from_inner(sys::net::TcpListener::from_inner(socket))
}
}
impl TryIntoRawFd for net::TcpStream {
#[inline]
fn try_into_raw_fd(self) -> Result<RawFd, Self> {
let (socket, peer_addr) = self.into_inner().into_inner();
match socket.try_into_inner() {
Ok(fd) => Ok(fd.into_inner()),
Err(socket) => {
let sys = sys::net::TcpStream::from_inner((socket, peer_addr));
Err(net::TcpStream::from_inner(sys))
}
}
}
}
impl TryIntoRawFd for net::TcpListener {
#[inline]
fn try_into_raw_fd(self) -> Result<RawFd, Self> {
match self.into_inner().into_inner().try_into_inner() {
Ok(fd) => Ok(fd.into_inner()),
Err(socket) => {
let sys = sys::net::TcpListener::from_inner(socket);
Err(net::TcpListener::from_inner(sys))
}
}
}
}