| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/ |
| D | ylong_tokio_signal.rs | 39 let mut stream = tokio_signal($kind).unwrap(); localVariable
63 let mut stream = tokio_signal($kind).unwrap(); localVariable
88 let mut stream = ylong_signal($kind).unwrap(); localVariable
112 let mut stream = ylong_signal($kind).unwrap(); localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| D | tcp_test.rs | 35 let mut stream = TcpStream::connect(addr).await; in sdv_tcp_ipv6_connect() localVariable
39 let mut stream = stream.unwrap(); in sdv_tcp_ipv6_connect() localVariable
86 let mut stream = TcpStream::connect(addr).await; in sdv_tcp_stream_try() localVariable
90 let stream = stream.unwrap(); in sdv_tcp_stream_try() localVariable
121 let mut stream = TcpStream::connect(addr).await; in sdv_tcp_stream_basic() localVariable
125 let stream = stream.unwrap(); in sdv_tcp_stream_basic() localVariable
168 let mut stream = TcpStream::connect(addr).await; in sdv_tcp_stream_peek() localVariable
172 let stream = stream.unwrap(); in sdv_tcp_stream_peek() localVariable
296 let mut stream = TcpStream::connect(addr).await; in sdv_tcp_split_borrow_half() localVariable
300 let mut stream = stream.unwrap(); in sdv_tcp_split_borrow_half() localVariable
[all …]
|
| D | signal.rs | 51 let mut stream = signal(SignalKind::alarm()).unwrap(); in sdv_signal_recv_test() localVariable
73 let mut stream = signal(SignalKind::child()).unwrap(); in sdv_signal_recv_multi_thread_test() localVariable
95 let mut stream = signal(SignalKind::hangup()).unwrap(); in sdv_signal_poll_recv_test() localVariable
117 let mut stream = signal(SignalKind::io()).unwrap(); in sdv_signal_poll_recv_multi_thread_test() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/ |
| D | split.rs | 139 let mut stream = TcpStream::connect(addr).await; in ut_test_borrow_half() localVariable
143 let mut stream = stream.unwrap(); in ut_test_borrow_half() localVariable
185 let mut stream = TcpStream::connect(addr).await; in ut_test_owned_half() localVariable
189 let stream = stream.unwrap(); in ut_test_owned_half() localVariable
232 let mut stream = TcpStream::connect(addr).await; in ut_test_borrow_half_vector() localVariable
236 let mut stream = stream.unwrap(); in ut_test_borrow_half_vector() localVariable
282 let mut stream = TcpStream::connect(addr).await; in ut_test_owned_half_vector() localVariable
286 let stream = stream.unwrap(); in ut_test_owned_half_vector() localVariable
|
| D | stream.rs | 97 let stream = super::super::addr::each_addr(addr, ylong_io::TcpStream::connect).await?; in connect() localVariable
102 let stream = TcpStream::new(stream)?; in connect_inner() localVariable
689 let mut stream = TcpStream::connect(addr).await; in ut_tcp_stream_basic() localVariable
693 let stream = stream.unwrap(); in ut_tcp_stream_basic() localVariable
729 let mut stream = TcpStream::connect(addr).await; in ut_tcp_stream_peek() localVariable
733 let stream = stream.unwrap(); in ut_tcp_stream_peek() localVariable
762 let mut stream = TcpStream::connect(addr).await; in ut_tcp_stream_try() localVariable
766 let stream = stream.unwrap(); in ut_tcp_stream_try() localVariable
|
| D | mod.rs | 17 mod stream; module
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/examples/ |
| D | ylong_runtime_signal.rs | 44 let mut stream = signal(SignalKind::child()).unwrap(); in run_multi_thread_signal() localVariable
63 let mut stream = signal(SignalKind::ctrl_c()).unwrap(); in run_multi_thread_signal() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/unix/ |
| D | mod.rs | 20 mod stream; module
|
| D | listener.rs | 72 let stream = UnixStream::new(stream)?; in accept() localVariable
183 let mut stream = UnixStream::connect(PATH).await; in ut_uds_listener_read_write_test() localVariable
187 let mut stream = stream.unwrap(); in ut_uds_listener_read_write_test() localVariable
|
| D | stream.rs | 55 let stream = UnixStream::new(ylong_io::UnixStream::connect(path)?)?; in connect() localVariable
90 let stream = ylong_io::UnixStream::from_std(listener); in from_std() localVariable
415 let stream = res.unwrap(); in ut_uds_stream_baisc_test() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/tcp/ |
| D | mod.rs | 20 mod stream; module
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/tcp/ |
| D | mod.rs | 22 mod stream; module
|
| D | listener.rs | 61 let stream = match syscall!(accept4( in accept() localVariable
74 let stream = match syscall!(accept( in accept() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_io/examples/ |
| D | ylong_io_tcp_client.rs | 27 let mut stream = match TcpStream::connect(addr) { in main() localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ssl_stream/ |
| D | wrapper.rs | 23 pub(crate) stream: S, field
36 let stream = Pin::new_unchecked(&mut self.stream); in inner() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/uds/ |
| D | mod.rs | 19 mod stream; module
|
| /commonlibrary/rust/ylong_runtime/ylong_io/tests/ |
| D | tcp_test.rs | 34 let stream = server.accept(); in sdv_tcp_server() localVariable
104 let stream = server.accept(); in sdv_tcp_server_vectored() localVariable
|
| /commonlibrary/ets_utils/js_concurrent_module/utils/locks/ |
| D | graph.cpp | 25 std::ostream &operator<<(std::ostream &stream, typename G::VColor c) in operator <<()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ssl/ |
| D | mod.rs | 19 mod stream; module
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/bin/ |
| D | ylong_runtime_tcp_client_perf.rs | 25 let mut stream = match TcpStream::connect(addr).await { in main() localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h3/ |
| D | mod.rs | 25 mod stream; module
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/ |
| D | mod.rs | 16 mod stream; module
155 let stream = eyeballs_connect(resolver, addr.as_str(), timeout).await?; in connect() localVariable
222 let stream = eyeballs_connect(resolver, addr.as_str(), timeout).await?; in connect() localVariable
251 let stream = eyeballs_connect(resolver, addr.as_str(), timeout).await?; in connect() localVariable
308 let mut stream = config in https_connect() localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/io/ |
| D | split.rs | 43 stream: Mutex<T>, field
116 fn stream(&mut self) -> Pin<&mut T> { in stream() method
|
| /commonlibrary/rust/ylong_http/ylong_http_client/tests/common/ |
| D | mod.rs | 201 let mut stream = tokio_openssl::SslStream::new(ssl, stream).expect("SslStream Error"); localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
| D | pool.rs | 143 let stream = connector.connect(url).await?; in conn_h2() localVariable
183 let stream = connector.connect(url).await?; in conn_negotiate() localVariable
|