| /external/rust/crates/tokio/src/net/tcp/ |
| D | listener.rs | 52 pub struct TcpListener {
53 io: PollEvented<mio::net::TcpListener>,
57 impl TcpListener { implementation
97 pub async fn bind<A: ToSocketAddrs>(addr: A) -> io::Result<TcpListener> { in bind() argument
103 match TcpListener::bind_addr(addr) { in bind()
117 fn bind_addr(addr: SocketAddr) -> io::Result<TcpListener> { in bind_addr() argument
118 let listener = mio::net::TcpListener::bind(addr)?; in bind_addr()
119 TcpListener::new(listener) in bind_addr()
217 pub fn from_std(listener: net::TcpListener) -> io::Result<TcpListener> { in from_std() argument
218 let io = mio::net::TcpListener::from_std(listener); in from_std()
[all …]
|
| D | socket.rs | 1 use crate::net::{TcpListener, TcpStream};
481 pub fn listen(self, backlog: u32) -> io::Result<TcpListener> { in listen() argument
483 TcpListener::new(mio) in listen()
|
| /external/rust/crates/mio/src/net/tcp/ |
| D | listener.rs | 38 pub struct TcpListener { struct
39 inner: IoSource<net::TcpListener>, argument
42 impl TcpListener { impl
52 pub fn bind(addr: SocketAddr) -> io::Result<TcpListener> { in bind() argument
75 pub fn from_std(listener: net::TcpListener) -> TcpListener { in from_std() argument
76 TcpListener { in from_std()
127 impl event::Source for TcpListener { implementation
151 impl fmt::Debug for TcpListener { implementation
158 impl IntoRawFd for TcpListener { implementation
165 impl AsRawFd for TcpListener { implementation
[all …]
|
| D | socket.rs | 10 use crate::net::{TcpListener, TcpStream};
91 pub fn listen(self, backlog: u32) -> io::Result<TcpListener> { in listen() argument
96 Ok(TcpListener::from_std(listener)) in listen()
|
| /external/rust/crates/tokio-stream/src/wrappers/ |
| D | tcp_listener.rs | 5 use tokio::net::{TcpListener, TcpStream};
14 inner: TcpListener,
19 pub fn new(listener: TcpListener) -> Self { in new()
24 pub fn into_inner(self) -> TcpListener { in into_inner() argument
44 impl AsRef<TcpListener> for TcpListenerStream {
45 fn as_ref(&self) -> &TcpListener { in as_ref() argument
50 impl AsMut<TcpListener> for TcpListenerStream {
51 fn as_mut(&mut self) -> &mut TcpListener { in as_mut() argument
|
| /external/rust/crates/tokio/tests/ |
| D | tcp_connect.rs | 4 use tokio::net::{TcpListener, TcpStream};
12 let srv = assert_ok!(TcpListener::bind("127.0.0.1:0").await); in connect_v4()
39 let srv = assert_ok!(TcpListener::bind("[::1]:0").await); in connect_v6()
66 let srv = assert_ok!(TcpListener::bind("127.0.0.1:0").await); in connect_addr_ip_string()
83 let srv = assert_ok!(TcpListener::bind("127.0.0.1:0").await); in connect_addr_ip_str_slice()
100 let srv = assert_ok!(TcpListener::bind("127.0.0.1:0").await); in connect_addr_host_string()
117 let srv = assert_ok!(TcpListener::bind("127.0.0.1:0").await); in connect_addr_ip_port_tuple()
134 let srv = assert_ok!(TcpListener::bind("127.0.0.1:0").await); in connect_addr_ip_str_port_tuple()
151 let srv = assert_ok!(TcpListener::bind("127.0.0.1:0").await); in connect_addr_host_str_port_tuple()
|
| D | io_driver_drop.rs | 4 use tokio::net::TcpListener;
14 let listener = std::net::TcpListener::bind("127.0.0.1:0").unwrap(); in tcp_doesnt_block()
15 TcpListener::from_std(listener).unwrap() in tcp_doesnt_block()
33 let listener = std::net::TcpListener::bind("127.0.0.1:0").unwrap(); in drop_wakes()
34 TcpListener::from_std(listener).unwrap() in drop_wakes()
|
| D | no_rt.rs | 7 use std::net::TcpListener;
22 let srv = TcpListener::bind("127.0.0.1:0").unwrap(); in panics_when_no_reactor()
38 let _ = tokio::net::TcpListener::from_std(std::net::TcpListener::bind("127.0.0.1:0").unwrap()); in io_panics_when_no_tokio_context()
|
| D | net_bind_resource.rs | 4 use tokio::net::TcpListener;
12 let listener = net::TcpListener::bind("127.0.0.1:0").expect("failed to bind listener"); in no_runtime_panics_binding_net_tcp_listener()
13 let _ = TcpListener::try_from(listener); in no_runtime_panics_binding_net_tcp_listener()
|
| D | io_driver.rs | 4 use tokio::net::TcpListener;
58 let listener = assert_ok!(TcpListener::bind("127.0.0.1:0").await); in test_drop_on_notify()
97 tokio::net::TcpListener::from_std(std::net::TcpListener::bind("127.0.0.1:0").unwrap()); in panics_when_io_disabled()
|
| D | tcp_accept.rs | 4 use tokio::net::{TcpListener, TcpStream};
16 let listener = assert_ok!(TcpListener::bind($target).await);
53 listener: &'a mut TcpListener,
67 let mut listener = assert_ok!(TcpListener::bind("127.0.0.1:0").await); in no_extra_poll()
105 let listener = assert_ok!(TcpListener::bind("127.0.0.1:0").await); in accept_many()
|
| D | tcp_into_split.rs | 9 use tokio::net::{TcpListener, TcpStream};
16 let listener = TcpListener::bind("127.0.0.1:0").await?; in split()
58 let listener = net::TcpListener::bind("127.0.0.1:0")?; in reunite()
88 let listener = net::TcpListener::bind("127.0.0.1:0")?; in drop_write()
|
| D | tcp_stream.rs | 5 use tokio::net::{TcpListener, TcpStream};
18 let listener = TcpListener::bind("127.0.0.1:0").await.unwrap(); in set_linger()
36 let listener = TcpListener::bind("127.0.0.1:0").await.unwrap(); in try_read_write()
206 let listener = assert_ok!(TcpListener::bind("127.0.0.1:0").await); in create_pair()
243 let listener = TcpListener::bind("127.0.0.1:0").await.unwrap(); in try_read_buf()
|
| D | tcp_shutdown.rs | 5 use tokio::net::{TcpListener, TcpStream};
10 let srv = assert_ok!(TcpListener::bind("127.0.0.1:0").await); in shutdown()
|
| D | tcp_into_std.rs | 7 use tokio::net::TcpListener;
13 let listener = TcpListener::bind("127.0.0.1:34254").await?; in tcp_into_std()
|
| D | tcp_echo.rs | 5 use tokio::net::{TcpListener, TcpStream};
15 let srv = assert_ok!(TcpListener::bind("127.0.0.1:0").await); in echo_server()
|
| D | buffered.rs | 4 use tokio::net::TcpListener;
15 let srv = assert_ok!(TcpListener::bind("127.0.0.1:0").await); in echo_server()
|
| /external/rust/crates/async-stream/examples/ |
| D | tcp_accept.rs | 4 use tokio::net::TcpListener;
8 let mut listener = TcpListener::bind("127.0.0.1:0").await.unwrap(); in main()
|
| /external/rust/crates/flate2/tests/ |
| D | tokio.rs | 12 use std::net::{Shutdown, TcpListener};
29 let listener = TcpListener::bind("127.0.0.1:0").unwrap(); in tcp_stream_echo_pattern()
85 let listener = TcpListener::bind("127.0.0.1:0").unwrap(); in echo_random()
|
| /external/rust/crates/gdbstub/examples/armv4t/ |
| D | main.rs | 1 use std::net::{TcpListener, TcpStream};
20 let sock = TcpListener::bind(sockaddr)?; in wait_for_tcp()
|
| /external/rust/crates/gdbstub/examples/armv4t_multicore/ |
| D | main.rs | 1 use std::net::{TcpListener, TcpStream};
20 let sock = TcpListener::bind(sockaddr)?; in wait_for_tcp()
|
| /external/antlr/runtime/CSharp2/Sources/Antlr3.Runtime/Antlr.Runtime.Debug/ |
| D | DebugEventSocketProxy.cs | 43 using TcpListener = System.Net.Sockets.TcpListener; typedef
56 protected TcpListener serverSocket;
98 serverSocket = new TcpListener(ipAddress, port); in Handshake()
|
| /external/antlr/runtime/CSharp3/Sources/Antlr3.Runtime.Debug/ |
| D | DebugEventSocketProxy.cs | 42 using TcpListener = System.Net.Sockets.TcpListener; typedef
56 protected TcpListener serverSocket;
105 serverSocket = new TcpListener( ipAddress, port ); in Handshake()
|
| /external/libchromeos-rs/src/ |
| D | net.rs | 8 use std::net::{SocketAddr, SocketAddrV4, SocketAddrV6, TcpListener, TcpStream, ToSocketAddrs};
172 pub fn listen(self) -> io::Result<TcpListener> { in listen() argument
181 Ok(unsafe { TcpListener::from_raw_fd(self.into_raw_fd()) }) in listen()
|
| /external/rust/crates/mio/src/sys/shell/ |
| D | tcp.rs | 24 pub(crate) fn listen(_: TcpSocket, _: u32) -> io::Result<net::TcpListener> { in listen() argument
121 pub fn accept(_: &net::TcpListener) -> io::Result<(net::TcpStream, SocketAddr)> { in accept()
|