| /external/rust/crates/tokio/tests/ |
| D | fs_file_mocked.rs | 78 let mut file = File::from_std(file); in open_read()
104 let mut file = File::from_std(file); in read_twice_before_dispatch()
126 let mut file = File::from_std(file); in read_with_smaller_buf()
159 let mut file = File::from_std(file); in read_with_bigger_buf()
200 let mut file = File::from_std(file); in read_err_then_read_success()
231 let mut file = File::from_std(file); in open_write()
254 let mut file = File::from_std(file); in flush_while_idle()
281 let mut file = File::from_std(file); in read_with_buffer_larger_than_max()
324 let mut file = File::from_std(file); in write_with_buffer_larger_than_max()
356 let mut file = File::from_std(file); in write_twice_before_dispatch()
[all …]
|
| D | io_driver_drop.rs | 15 TcpListener::from_std(listener).unwrap() in tcp_doesnt_block()
34 TcpListener::from_std(listener).unwrap() in drop_wakes()
|
| D | no_rt.rs | 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 | tcp_into_std.rs | 38 let mut tokio_tcp_stream = TcpStream::from_std(std_tcp_stream)?; in tcp_into_std()
|
| D | io_driver.rs | 97 tokio::net::TcpListener::from_std(std::net::TcpListener::bind("127.0.0.1:0").unwrap()); in panics_when_io_disabled()
|
| /external/rust/crates/tokio/src/time/ |
| D | instant.rs | 53 pub fn from_std(std: std::time::Instant) -> Instant { in from_std() method
150 self.std.checked_add(duration).map(Instant::from_std) in checked_add()
157 self.std.checked_sub(duration).map(Instant::from_std) in checked_sub()
163 Instant::from_std(time) in from()
177 Instant::from_std(self.std + other) in add()
199 Instant::from_std(self.std - rhs) in sub()
220 Instant::from_std(std::time::Instant::now()) in now()
|
| D | clock.rs | 16 Instant::from_std(std::time::Instant::now())
146 Instant::from_std(std::time::Instant::now())
209 Instant::from_std(ret)
|
| /external/rust/crates/mio/src/net/uds/ |
| D | datagram.rs | 18 sys::uds::datagram::bind(path.as_ref()).map(UnixDatagram::from_std) in bind()
27 pub fn from_std(socket: net::UnixDatagram) -> UnixDatagram { in from_std() method
40 sys::uds::datagram::unbound().map(UnixDatagram::from_std) in unbound()
47 UnixDatagram::from_std(socket1), in pair()
48 UnixDatagram::from_std(socket2), in pair()
163 UnixDatagram::from_std(FromRawFd::from_raw_fd(fd)) in from_raw_fd()
|
| D | stream.rs | 19 sys::uds::stream::connect(path.as_ref()).map(UnixStream::from_std) in connect()
34 pub fn from_std(stream: net::UnixStream) -> UnixStream { in from_std() method
45 (UnixStream::from_std(stream1), UnixStream::from_std(stream2)) in pair()
172 UnixStream::from_std(FromRawFd::from_raw_fd(fd)) in from_raw_fd()
|
| D | listener.rs | 18 sys::uds::listener::bind(path.as_ref()).map(UnixListener::from_std) in bind()
27 pub fn from_std(listener: net::UnixListener) -> UnixListener { in from_std() method
102 UnixListener::from_std(FromRawFd::from_raw_fd(fd)) in from_raw_fd()
|
| /external/rust/crates/same-file/src/ |
| D | unix.rs | 74 pub fn from_std(file: File) -> io::Result<Handle> { in from_std() method
82 Handle::from_std(unsafe { File::from_raw_fd(0) }) in stdin()
86 Handle::from_std(unsafe { File::from_raw_fd(1) }) in stdout()
90 Handle::from_std(unsafe { File::from_raw_fd(2) }) in stderr()
|
| /external/rust/crates/mio/src/net/tcp/ |
| D | listener.rs | 75 pub fn from_std(listener: net::TcpListener) -> TcpListener { in from_std() method
91 sys::tcp::accept(inner).map(|(stream, addr)| (TcpStream::from_std(stream), addr)) in accept()
180 TcpListener::from_std(FromRawFd::from_raw_fd(fd)) in from_raw_fd()
207 TcpListener::from_std(FromRawSocket::from_raw_socket(socket)) in from_raw_socket()
|
| D | stream.rs | 69 pub fn from_std(stream: net::TcpStream) -> TcpStream { in from_std() method
276 TcpStream::from_std(FromRawFd::from_raw_fd(fd)) in from_raw_fd()
303 TcpStream::from_std(FromRawSocket::from_raw_socket(socket)) in from_raw_socket()
|
| D | socket.rs | 86 Ok(TcpStream::from_std(stream)) in connect()
96 Ok(TcpListener::from_std(listener)) in listen()
|
| /external/rust/crates/tokio/src/net/unix/ |
| D | listener.rs | 85 pub fn from_std(listener: net::UnixListener) -> io::Result<UnixListener> { in from_std() method
86 let listener = mio::net::UnixListener::from_std(listener); in from_std()
165 Self::from_std(stream) in try_from()
|
| D | stream.rs | 504 pub fn from_std(stream: net::UnixStream) -> io::Result<UnixStream> { in from_std() method
505 let stream = mio::net::UnixStream::from_std(stream); in from_std()
641 Self::from_std(stream) in try_from()
|
| /external/rust/crates/mio/src/net/ |
| D | udp.rs | 122 sys::udp::bind(addr).map(UdpSocket::from_std) in bind()
131 pub fn from_std(socket: net::UdpSocket) -> UdpSocket { in from_std() method
583 UdpSocket::from_std(FromRawFd::from_raw_fd(fd)) in from_raw_fd()
610 UdpSocket::from_std(FromRawSocket::from_raw_socket(socket)) in from_raw_socket()
|
| /external/rust/crates/tokio/src/net/tcp/ |
| D | listener.rs | 217 pub fn from_std(listener: net::TcpListener) -> io::Result<TcpListener> { in from_std() method
218 let io = mio::net::TcpListener::from_std(listener); in from_std()
358 Self::from_std(stream) in try_from()
|
| D | stream.rs | 189 pub fn from_std(stream: std::net::TcpStream) -> io::Result<TcpStream> { in from_std() method
190 let io = mio::net::TcpStream::from_std(stream); in from_std()
1049 Self::from_std(stream) in try_from()
|
| /external/rust/crates/chrono/src/ |
| D | oldtime.rs | 278 pub fn from_std(duration: StdDuration) -> Result<Duration, OutOfRangeError> { in from_std() method
663 assert_eq!(Ok(Duration::seconds(1)), Duration::from_std(StdDuration::new(1, 0))); in test_from_std()
664 assert_eq!(Ok(Duration::seconds(86401)), Duration::from_std(StdDuration::new(86401, 0))); in test_from_std()
667 Duration::from_std(StdDuration::new(0, 123000000)) in test_from_std()
671 Duration::from_std(StdDuration::new(123, 765000000)) in test_from_std()
673 assert_eq!(Ok(Duration::nanoseconds(777)), Duration::from_std(StdDuration::new(0, 777))); in test_from_std()
674 assert_eq!(Ok(MAX), Duration::from_std(StdDuration::new(9223372036854775, 807000000))); in test_from_std()
676 Duration::from_std(StdDuration::new(9223372036854776, 0)), in test_from_std()
680 Duration::from_std(StdDuration::new(9223372036854775, 807000001)), in test_from_std()
|
| /external/rust/crates/tokio/src/fs/ |
| D | file.rs | 147 Ok(File::from_std(std)) in open()
186 Ok(File::from_std(std_file)) in create()
202 pub fn from_std(std: sys::File) -> File { in from_std() method
391 Ok(File::from_std(std_file)) in try_clone()
690 Self::from_std(std) in from()
|
| /external/rust/crates/tokio/src/net/unix/datagram/ |
| D | socket.rs | 373 pub fn from_std(datagram: net::UnixDatagram) -> io::Result<UnixDatagram> { in from_std() method
374 let socket = mio::net::UnixDatagram::from_std(datagram); in from_std()
1260 Self::from_std(stream) in try_from()
|
| /external/rust/crates/nix/test/sys/ |
| D | test_socket.rs | 17 let addr = InetAddr::from_std(&actual); in test_inetv4_addr_to_sock_addr()
45 let addr = InetAddr::from_std(&actual); in test_inetv6_addr_to_sock_addr()
213 let inet_addr = InetAddr::from_std(&std_sa); in udp()
253 let inet_addr = InetAddr::from_std(&std_sa); in gso()
327 let inet_addr = InetAddr::from_std(&std_sa); in udp_sendmmsg()
328 let inet_addr2 = InetAddr::from_std(&std_sa2); in udp_sendmmsg()
396 let inet_addr = InetAddr::from_std(&std_sa); in udp_recvmmsg()
463 let inet_addr = InetAddr::from_std(&std_sa); in udp_recvmmsg_dontwait_short_read()
772 let inet_addr = InetAddr::from_std(&std_sa); in test_sendmsg_ipv4packetinfo()
824 let inet_addr = InetAddr::from_std(&std_sa); in test_sendmsg_ipv6packetinfo()
|
| /external/rust/crates/tokio/src/net/ |
| D | udp.rs | 209 pub fn from_std(socket: net::UdpSocket) -> io::Result<UdpSocket> { in from_std() method
210 let io = mio::net::UdpSocket::from_std(socket); in from_std()
1405 Self::from_std(stream) in try_from()
|
| /external/rust/crates/nix/src/sys/socket/ |
| D | addr.rs | 260 pub fn from_std(std: &net::SocketAddr) -> InetAddr { in from_std() method
266 sin_addr: Ipv4Addr::from_std(addr.ip()).0, in from_std()
274 sin6_addr: Ipv6Addr::from_std(addr.ip()).0, in from_std()
376 pub fn from_std(std: &net::IpAddr) -> IpAddr { in from_std() method
378 net::IpAddr::V4(ref std) => IpAddr::V4(Ipv4Addr::from_std(std)), in from_std()
379 net::IpAddr::V6(ref std) => IpAddr::V6(Ipv6Addr::from_std(std)), in from_std()
422 pub fn from_std(std: &net::Ipv4Addr) -> Ipv4Addr { in from_std() method
481 pub fn from_std(std: &net::Ipv6Addr) -> Ipv6Addr { in from_std() method
|