Home
last modified time | relevance | path

Searched refs:UnixStream (Results 1 – 25 of 67) sorted by relevance

123

/external/rust/android-crates-io/crates/mio/src/net/uds/
Dstream.rs12 pub struct UnixStream { struct
13 inner: IoSource<net::UnixStream>, argument
16 impl UnixStream { implementation
21 pub fn connect<P: AsRef<Path>>(path: P) -> io::Result<UnixStream> { in connect() argument
23 UnixStream::connect_addr(&addr) in connect()
30 pub fn connect_addr(address: &SocketAddr) -> io::Result<UnixStream> { in connect_addr() argument
31 sys::uds::stream::connect_addr(address).map(UnixStream::from_std) in connect_addr()
46 pub fn from_std(stream: net::UnixStream) -> UnixStream { in from_std() argument
47 UnixStream { in from_std()
55 pub fn pair() -> io::Result<(UnixStream, UnixStream)> { in pair()
[all …]
/external/rust/android-crates-io/crates/tokio/src/net/unix/
Dstream.rs42 pub struct UnixStream {
43 io: PollEvented<mio::net::UnixStream>,
47 impl UnixStream { implementation
48 pub(crate) async fn connect_mio(sys: mio::net::UnixStream) -> io::Result<UnixStream> { in connect_mio() argument
49 let stream = UnixStream::new(sys)?; in connect_mio()
71 pub async fn connect<P>(path: P) -> io::Result<UnixStream> in connect()
88 let stream = mio::net::UnixStream::connect_addr(&addr)?; in connect()
89 let stream = UnixStream::new(stream)?; in connect()
820 pub fn from_std(stream: net::UnixStream) -> io::Result<UnixStream> { in from_std() argument
821 let stream = mio::net::UnixStream::from_std(stream); in from_std()
[all …]
Dsplit_owned.rs12 use crate::net::UnixStream;
36 inner: Arc<UnixStream>,
55 inner: Arc<UnixStream>,
59 pub(crate) fn split_owned(stream: UnixStream) -> (OwnedReadHalf, OwnedWriteHalf) { in split_owned()
74 ) -> Result<UnixStream, ReuniteError> { in reunite() argument
107 pub fn reunite(self, other: OwnedWriteHalf) -> Result<UnixStream, ReuniteError> { in reunite() argument
261 pub fn reunite(self, other: OwnedReadHalf) -> Result<UnixStream, ReuniteError> { in reunite() argument
409 impl AsRef<UnixStream> for OwnedReadHalf {
410 fn as_ref(&self) -> &UnixStream { in as_ref() argument
415 impl AsRef<UnixStream> for OwnedWriteHalf {
[all …]
Ducred.rs73 use crate::net::unix::{self, UnixStream};
83 pub(crate) fn get_peer_cred(sock: &UnixStream) -> io::Result<super::UCred> { in get_peer_cred()
125 use crate::net::unix::{self, UnixStream};
132 pub(crate) fn get_peer_cred(sock: &UnixStream) -> io::Result<super::UCred> { in get_peer_cred()
167 use crate::net::unix::{self, UnixStream};
174 pub(crate) fn get_peer_cred(sock: &UnixStream) -> io::Result<super::UCred> { in get_peer_cred()
204 use crate::net::unix::{self, UnixStream};
212 pub(crate) fn get_peer_cred(sock: &UnixStream) -> io::Result<super::UCred> { in get_peer_cred()
251 use crate::net::unix::{self, UnixStream};
256 pub(crate) fn get_peer_cred(sock: &UnixStream) -> io::Result<super::UCred> { in get_peer_cred()
[all …]
Dsplit.rs12 use crate::net::UnixStream;
33 pub struct ReadHalf<'a>(&'a UnixStream);
49 pub struct WriteHalf<'a>(&'a UnixStream);
51 pub(crate) fn split(stream: &mut UnixStream) -> (ReadHalf<'_>, WriteHalf<'_>) { in split()
321 impl AsRef<UnixStream> for ReadHalf<'_> {
322 fn as_ref(&self) -> &UnixStream { in as_ref() argument
327 impl AsRef<UnixStream> for WriteHalf<'_> {
328 fn as_ref(&self) -> &UnixStream { in as_ref() argument
Dlistener.rs2 use crate::net::unix::{SocketAddr, UnixStream};
186 pub async fn accept(&self) -> io::Result<(UnixStream, SocketAddr)> { in accept() argument
194 let stream = UnixStream::new(mio)?; in accept()
204 pub fn poll_accept(&self, cx: &mut Context<'_>) -> Poll<io::Result<(UnixStream, SocketAddr)>> { in poll_accept() argument
207 let sock = UnixStream::new(sock)?; in poll_accept()
Dsocket.rs6 use crate::net::{UnixDatagram, UnixListener, UnixStream};
201 pub async fn connect(self, path: impl AsRef<Path>) -> io::Result<UnixStream> { in connect() argument
219 unsafe { mio::net::UnixStream::from_raw_fd(raw_fd) } in connect()
222 UnixStream::connect_mio(mio).await in connect()
/external/rust/android-crates-io/crates/mio/src/sys/shell/
Duds.rs22 use crate::net::UnixStream;
28 pub(crate) fn accept(_: &net::UnixListener) -> io::Result<(UnixStream, SocketAddr)> { in accept() argument
37 pub(crate) fn connect_addr(_: &SocketAddr) -> io::Result<net::UnixStream> { in connect_addr() argument
41 pub(crate) fn pair() -> io::Result<(net::UnixStream, net::UnixStream)> { in pair()
/external/rust/android-crates-io/crates/mio/src/sys/unix/uds/
Dstream.rs8 pub(crate) fn connect_addr(address: &SocketAddr) -> io::Result<net::UnixStream> { in connect_addr() argument
10 let socket = unsafe { net::UnixStream::from_raw_fd(fd) }; in connect_addr()
23 pub(crate) fn pair() -> io::Result<(net::UnixStream, net::UnixStream)> { in pair()
Dlistener.rs8 use crate::net::UnixStream;
24 pub(crate) fn accept(listener: &net::UnixListener) -> io::Result<(UnixStream, SocketAddr)> { in accept() argument
61 .map(|socket| unsafe { net::UnixStream::from_raw_fd(socket) }) in accept()
87 let s = unsafe { net::UnixStream::from_raw_fd(socket) }; in accept()
103 let socket = socket.map(UnixStream::from_std)?; in accept()
/external/rust/android-crates-io/crates/tokio/tests/
Duds_stream.rs14 use tokio::net::{UnixListener, UnixStream};
30 let connect = UnixStream::connect(&sock_path); in accept_read_write()
57 let connect = UnixStream::connect(&sock_path); in shutdown()
80 let client = UnixStream::connect(&bind_path).await?; in try_read_write()
196 async fn create_pair() -> (UnixStream, UnixStream) { in create_pair()
203 let connect = UnixStream::connect(&bind_path); in create_pair()
280 fn read_until_pending(stream: &mut UnixStream) { in read_until_pending() argument
293 fn write_until_pending(stream: &mut UnixStream) { in write_until_pending() argument
317 let client = UnixStream::connect(&bind_path).await?; in try_read_buf()
399 let connect = UnixStream::connect(&sock_path); in epollhup()
[all …]
Duds_cred.rs5 use tokio::net::UnixStream;
16 let (a, b) = UnixStream::pair().unwrap(); in test_socket_pair()
Duds_split.rs7 use tokio::net::UnixStream;
16 let (mut a, mut b) = UnixStream::pair()?; in split()
/external/crosvm/base/src/sys/linux/
Dnotifiers.rs5 use std::os::unix::net::UnixStream;
11 impl ReadNotifier for UnixStream { implementation
17 impl CloseNotifier for UnixStream { implementation
/external/rust/android-crates-io/crates/signal-hook/src/iterator/
Dmod.rs66 use std::os::unix::net::UnixStream;
129 pub struct SignalsInfo<E: Exfiltrator = SignalOnly>(SignalDelivery<UnixStream, E>);
151 let (read, write) = UnixStream::pair()?; in with_exfiltrator()
184 fn has_signals(read: &mut UnixStream) -> Result<bool, Error> { in has_signals()
299 pub struct Forever<'a, E: Exfiltrator>(RefSignalIterator<'a, UnixStream, E>);
/external/crosvm/devices/src/virtio/vhost/user/device/connection/sys/linux/
Dstream.rs7 use std::os::unix::net::UnixStream;
26 pub struct VhostUserStream(UnixStream);
51 let stream = UnixStream::from(safe_fd); in new_socket_from_fd()
74 stream: UnixStream, in stream_run_with_handler() argument
/external/rust/android-crates-io/crates/tokio/src/runtime/signal/
Dmod.rs8 use mio::net::UnixStream;
24 receiver: UnixStream,
71 ManuallyDrop::new(unsafe { std::os::unix::net::UnixStream::from_raw_fd(receiver_fd) }); in new()
72 let mut receiver = UnixStream::from_std(original.try_clone()?); in new()
/external/crosvm/third_party/vmm_vhost/src/sys/
Dunix.rs13 use std::os::unix::net::UnixStream;
127 sock: ScmSocket<UnixStream>,
257 UnixStream::from(fd).try_into() in try_from()
261 impl<R: Req> TryFrom<UnixStream> for Connection<R> {
264 fn try_from(sock: UnixStream) -> Result<Self> { in try_from()
278 let (client, server) = UnixStream::pair()?; in pair()
305 let (tx, rx) = UnixStream::pair()?; in with_stream()
330 let sock = UnixStream::connect(path).map_err(Error::SocketConnect)?; in connect()
/external/rust/android-crates-io/crates/gdbstub/src/conn/impls/
Dunixstream.rs4 use std::os::unix::net::UnixStream;
11 impl PeekExt for UnixStream { implementation
57 impl Connection for UnixStream { implementation
79 impl ConnectionExt for UnixStream { implementation
/external/rust/android-crates-io/crates/tokio-stream/src/wrappers/
Dunix_listener.rs5 use tokio::net::{UnixListener, UnixStream};
30 type Item = io::Result<UnixStream>;
35 ) -> Poll<Option<io::Result<UnixStream>>> { in poll_next() argument
/external/crosvm/base/src/sys/unix/
Ddescriptor.rs21 use std::os::unix::net::UnixStream;
155 impl From<SafeDescriptor> for UnixStream { implementation
228 AsRawDescriptor!(UnixStream);
231 FromRawDescriptor!(UnixStream);
236 IntoRawDescriptor!(UnixStream);
/external/crosvm/common/audio_streams/src/
Dasync_api.rs19 use std::os::unix::net::UnixStream;
68 fn async_unix_stream(&self, f: UnixStream) -> Result<AsyncStream>; in async_unix_stream()
99 fn async_unix_stream(&self, _f: UnixStream) -> Result<AsyncStream> { in async_unix_stream()
/external/rust/android-crates-io/crates/vhost/src/vhost_user/
Dbackend_req.rs7 use std::os::unix::net::UnixStream;
116 pub fn from_stream(sock: UnixStream) -> Self { in from_stream()
196 let (p1, _p2) = UnixStream::pair().unwrap(); in test_backend_req_set_failed()
206 let (p1, _) = UnixStream::pair().unwrap(); in test_backend_req_send_failure()
221 let (p1, p2) = UnixStream::pair().unwrap(); in test_backend_req_recv_negative()
/external/crosvm/devices/src/
Dserial_device.rs13 use std::os::unix::net::UnixStream;
74 impl SerialInput for UnixStream {} implementation
91 UnixStream, enumerator
109 SerialType::UnixStream => "UnixStream".to_string(), in fmt()
222 if self.type_ != SerialType::UnixStream { in create_serial_device()
285 SerialType::UnixStream => { in create_serial_device()
287 let output = UnixStream::connect(path).map_err(Error::SocketConnect)?; in create_serial_device()
361 assert_eq!(params.type_, SerialType::UnixStream); in params_from_key_values()
/external/rust/android-crates-io/crates/nix/test/
Dtest_sendfile.rs13 use std::os::unix::net::UnixStream;
76 let (mut rd, wr) = UnixStream::pair().unwrap(); in test_sendfile_freebsd()
127 let (mut rd, wr) = UnixStream::pair().unwrap(); in test_sendfile_dragonfly()
176 let (mut rd, wr) = UnixStream::pair().unwrap(); in test_sendfile_darwin()
226 let (mut rd, wr) = UnixStream::pair().unwrap(); in test_sendfilev()

123