| /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 | 37 let mut stream = TcpStream::connect(addr).await; in sdv_tcp_ipv6_connect() localVariable
41 let mut stream = stream.unwrap(); in sdv_tcp_ipv6_connect() localVariable
88 let mut stream = TcpStream::connect(addr).await; in sdv_tcp_stream_try() localVariable
92 let stream = stream.unwrap(); in sdv_tcp_stream_try() localVariable
123 let mut stream = TcpStream::connect(addr).await; in sdv_tcp_stream_basic() localVariable
127 let stream = stream.unwrap(); in sdv_tcp_stream_basic() localVariable
170 let mut stream = TcpStream::connect(addr).await; in sdv_tcp_stream_peek() localVariable
174 let stream = stream.unwrap(); in sdv_tcp_stream_peek() localVariable
298 let mut stream = TcpStream::connect(addr).await; in sdv_tcp_split_borrow_half() localVariable
302 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
|
| D | uds_cargo_test.rs | 64 let mut stream = UnixStream::connect(PATH).await; in sdv_uds_listener_read_write_test() localVariable
68 let mut stream = stream.unwrap(); in sdv_uds_listener_read_write_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_http/ylong_http_client/src/util/c_openssl/ |
| D | bio.rs | 129 pub(crate) stream: S, field
352 let stream = Cursor::new(vec![0u8; 10]); in ut_new() localVariable
368 let stream = Cursor::new(vec![0u8; 10]); in ut_get_state() localVariable
384 let stream = Cursor::new(vec![0u8; 10]); in ut_get_error() localVariable
406 let stream = Cursor::new(vec![0u8; 10]); in ut_get_panic() localVariable
428 let stream = Cursor::new(vec![0u8; 10]); in ut_get_stream() localVariable
461 let stream = Cursor::new(vec![0u8; 10]); in ut_ctrl_flush() localVariable
478 let stream = Cursor::new(vec![0u8; 10]); in ut_ctrl_dgram_query() localVariable
496 let stream = Cursor::new(vec![0u8; 10]); in ut_ctrl_default() localVariable
512 let stream = Cursor::new(vec![0u8; 10]); in ut_bwrite() localVariable
[all …]
|
| /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_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_runtime/src/net/sys/unix/ |
| D | mod.rs | 20 mod stream; module
|
| 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_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/examples/ |
| D | ylong_io_tcp_client.rs | 27 let mut stream = match TcpStream::connect(addr) { in main() localVariable
|
| /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/rust/ylong_runtime/ylong_io/src/sys/unix/uds/ |
| D | mod.rs | 19 mod stream; module
|
| /commonlibrary/ets_utils/js_concurrent_module/utils/locks/ |
| D | graph.cpp | 24 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 | 24 mod stream; module
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/ |
| D | mod.rs | 16 mod stream; module
191 let stream = eyeballs_connect(socket_addrs, timeout).await?; in connect() localVariable
275 let stream = eyeballs_connect(socket_addrs, timeout).await?; in connect() localVariable
346 let mut stream = in connect() localVariable
371 let stream = eyeballs_connect(socket_addrs, timeout).await?; in connect() localVariable
437 let mut stream = config in https_connect() localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| D | streams.rs | 336 let stream = Stream::new(recv_window, send_window, headers, data); in insert() localVariable
459 let stream = if let Some(stream) = self.stream_map.get_mut(&id) { in poll_sized_data() localVariable
858 let stream = streams.stream_map.get(&1).unwrap(); in ut_streams_apply_send_initial_window_size() localVariable
863 let stream = streams.stream_map.get(&1).unwrap(); in ut_streams_apply_send_initial_window_size() localVariable
868 let stream = streams.stream_map.get(&1).unwrap(); in ut_streams_apply_send_initial_window_size() localVariable
873 let stream = streams.stream_map.get(&1).unwrap(); in ut_streams_apply_send_initial_window_size() localVariable
877 let stream = streams.stream_map.get(&1).unwrap(); in ut_streams_apply_send_initial_window_size() localVariable
881 let stream = streams.stream_map.get(&1).unwrap(); in ut_streams_apply_send_initial_window_size() localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
| D | pool.rs | 205 let stream = connector.connect(url, HttpVersion::Http1).await?; in conn_h1() localVariable
233 let stream = connector.connect(url, HttpVersion::Http2).await?; in conn_h2() localVariable
267 let mut stream = connector.connect(url, HttpVersion::Http3).await?; in conn_h3() localVariable
305 let stream = connector.connect(url, HttpVersion::Negotiate).await?; in conn_negotiate() localVariable
362 let mut stream = connector.connect(&alt_url, HttpVersion::Http3).await.ok()?; in conn_alt_svc() localVariable
|