| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | async_buf_read.rs | 34 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_buf_reader_read_until() localVariable
50 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_reader_read_until() localVariable
54 let mut tcp = tcp.unwrap(); in sdv_buf_reader_read_until() localVariable
92 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_reader_read_line() localVariable
96 let mut tcp = tcp.unwrap(); in sdv_buf_reader_read_line() localVariable
131 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_reader_split() localVariable
135 let mut tcp = tcp.unwrap(); in sdv_buf_reader_split() localVariable
179 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_reader_lines() localVariable
183 let mut tcp = tcp.unwrap(); in sdv_buf_reader_lines() localVariable
273 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_reader_read() localVariable
[all …]
|
| H A D | async_buf_write.rs | 32 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_buf_writer_write() localVariable
43 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_writer_write() localVariable
47 let tcp = tcp.unwrap(); in sdv_buf_writer_write() localVariable
71 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_buf_writer_write_vectored() localVariable
82 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_writer_write_vectored() localVariable
86 let tcp = tcp.unwrap(); in sdv_buf_writer_write_vectored() localVariable
167 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_buf_writer_write_vectored_2() localVariable
178 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_writer_write_vectored_2() localVariable
182 let tcp = tcp.unwrap(); in sdv_buf_writer_write_vectored_2() localVariable
|
| H A D | tcp_test.rs | 252 let tcp = TcpListener::bind(ADDR).await.unwrap(); in sdv_tcp_multi_runtime() localVariable
256 let mut tcp = TcpStream::connect(addr).await; in sdv_tcp_multi_runtime() localVariable
260 let mut tcp = tcp.unwrap(); in sdv_tcp_multi_runtime() localVariable
432 let mut tcp = TcpStream::connect(addr).await; in sdv_tcp_drop_out_context() localVariable
436 let mut tcp = tcp.unwrap(); in sdv_tcp_drop_out_context() localVariable
490 let mut tcp = TcpStream::connect(addr).await; in sdv_tcp_cancel() localVariable
495 let mut tcp = tcp.unwrap(); in sdv_tcp_cancel() localVariable
528 let mut tcp = TcpStream::connect(addr).await; in sdv_tcp_cancel() localVariable
532 let mut tcp = tcp.unwrap(); in sdv_tcp_cancel() localVariable
572 let mut tcp = TcpStream::connect(addr).await; in sdv_tcp_unexpected_eof() localVariable
[all …]
|
| H A D | async_read.rs | 65 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_buf_reader_read_to_string() localVariable
76 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_reader_read_to_string() localVariable
80 let mut tcp = tcp.unwrap(); in sdv_buf_reader_read_to_string() localVariable
|
| H A D | join_set.rs | 110 let mut tcp = TcpStream::connect(addr).await; in sdv_join_set_spawn_io() localVariable
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/ |
| H A D | ylong_tokio_tcp.rs | 26 let tcp = tokioTcpListener::bind(addr).await.unwrap(); localVariable
39 let mut tcp = tokioTcpStream::connect(addr.clone()).await; localVariable
43 let mut tcp = tcp.unwrap(); localVariable
78 let tcp = TcpListener::bind(addr).await.unwrap(); localVariable
91 let mut tcp = TcpStream::connect(addr).await; localVariable
95 let mut tcp = tcp.unwrap(); localVariable
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/examples/ |
| H A D | ylong_runtime_tcp.rs | 25 let tcp = TcpListener::bind(addr).await.unwrap(); in ylong_tcp_server() localVariable
38 let mut tcp = TcpStream::connect(addr).await; in ylong_tcp_client() localVariable
42 let mut tcp = tcp.unwrap(); in ylong_tcp_client() localVariable
|
| H A D | ylong_runtime_tcp_fd_limit.rs | 22 let tcp = TcpListener::bind("127.0.0.1:0").await; in main() localVariable
|
| /ohos5.0/foundation/communication/dsoftbus/tests/core/connection/tcp/ |
| H A D | tcp_manager_test.cpp | 840 const SocketInterface *tcp = GetTcpProtocol(); variable
875 const SocketInterface *tcp = GetTcpProtocol(); variable
909 const SocketInterface *tcp = GetTcpProtocol(); variable
940 const SocketInterface *tcp = GetTcpProtocol(); variable
976 const SocketInterface *tcp = GetTcpProtocol(); variable
1016 const SocketInterface *tcp = GetTcpProtocol(); variable
1302 const SocketInterface *tcp = GetTcpProtocol(); variable
1328 const SocketInterface *tcp = GetTcpProtocol(); variable
1351 const SocketInterface *tcp = GetTcpProtocol(); variable
1391 const SocketInterface *tcp = GetTcpProtocol(); variable
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/ |
| H A D | mod.rs | 14 mod tcp; module
|
| /ohos5.0/foundation/communication/dsoftbus/tests/core/connection/common/unittest/ |
| H A D | softbus_conn_common_test.cpp | 379 const SocketInterface *tcp = GetTcpProtocol(); variable
419 const SocketInterface *tcp = GetTcpProtocol(); variable
456 const SocketInterface *tcp = GetTcpProtocol(); variable
472 const SocketInterface *tcp = GetTcpProtocol(); variable
491 const SocketInterface *tcp = GetTcpProtocol(); variable
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/tests/ |
| H A D | tcp_test.rs | 73 let tcp = net::TcpStream::connect(addr); in sdv_tcp_server() localVariable
147 let tcp = net::TcpStream::connect(addr); in sdv_tcp_server_vectored() localVariable
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/ |
| H A D | mod.rs | 290 let mut tcp = tcp_stream; in https_connect() localVariable
487 let tcp = tcp_stream(eyeballs).await.unwrap(); in ut_ssl_tunnel_error() localVariable
524 let tcp = tcp_stream(eyeballs).await.unwrap(); in ut_ssl_tunnel_error() localVariable
564 let tcp = tcp_stream(eyeballs).await.unwrap(); in ut_ssl_tunnel_error() localVariable
611 let tcp = tcp_stream(eyeballs).await.unwrap(); in ut_ssl_tunnel_connect() localVariable
658 let tcp = tcp_stream(eyeballs).await.unwrap(); in ut_ssl_tunnel_resp_beyond_size() localVariable
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| H A D | current_thread.rs | 363 let tcp = TcpListener::bind(ADDR).await.unwrap(); localVariable
379 let mut tcp = TcpStream::connect(addr).await; localVariable
383 let mut tcp = tcp.unwrap(); localVariable
|
| /ohos5.0/foundation/communication/netmanager_base/services/netmanagernative/bpf/include/netfirewall/ |
| H A D | netfirewall_ct.h | 109 static __always_inline bool ct_update_timeout(struct ct_entry *entry, bool tcp, enum ct_dir dir, in ct_update_timeout()
|
| /ohos5.0/base/notification/common_event_service/test/systemtest/common/acts/actsCESSubscribeInfoTest/ |
| H A D | actsCESSubscribeInfoTest.cpp | 56 TestConfigParser tcp; in SetUpTestCase() local
|
| /ohos5.0/base/startup/init/test/unittest/loopevent/ |
| H A D | loopserver_unittest.cpp | 355 TaskHandle tcp = test.CreateConnect(TCP_SERVER.c_str(), TASK_TCP); variable
|
| /ohos5.0/base/notification/common_event_service/test/systemtest/common/acts/actsCESMatchingSkillsTest/ |
| H A D | actsCESMatchingSkillsTest.cpp | 42 TestConfigParser tcp; in SetUpTestCase() local
|
| /ohos5.0/base/notification/common_event_service/test/systemtest/common/acts/actsCESCESpublishInfoTest/ |
| H A D | actsCESCESpublishInfoTest.cpp | 58 TestConfigParser tcp; in SetUpTestCase() local
|
| /ohos5.0/foundation/communication/dsoftbus/tests/core/authentication/unittest/ |
| H A D | auth_test.cpp | 2155 const SocketInterface *tcp = GetTcpProtocol(); variable
|
| /ohos5.0/base/notification/common_event_service/test/systemtest/common/acts/actsCESManagertest/ |
| H A D | actsCESManagertest.cpp | 114 TestConfigParser tcp; in SetUpTestCase() local
|
| /ohos5.0/foundation/bundlemanager/bundle_framework/test/systemtest/common/bms/acts_bms_kit_system_test/ |
| H A D | acts_bms_kit_system_test.cpp | 286 TestConfigParser tcp; in SetUpTestCase() local
|