Home
last modified time | relevance | path

Searched refs:tcp (Results 1 – 25 of 89) sorted by relevance

1234

/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
H A Dasync_buf_read.rs51 while tcp.is_err() { in sdv_buf_reader_read_until()
54 let mut tcp = tcp.unwrap(); in sdv_buf_reader_read_until() localVariable
56 tcp.write_all(&buf).await.unwrap(); in sdv_buf_reader_read_until()
93 while tcp.is_err() { in sdv_buf_reader_read_line()
96 let mut tcp = tcp.unwrap(); in sdv_buf_reader_read_line() localVariable
132 while tcp.is_err() { in sdv_buf_reader_split()
135 let mut tcp = tcp.unwrap(); in sdv_buf_reader_split() localVariable
180 while tcp.is_err() { in sdv_buf_reader_lines()
183 let mut tcp = tcp.unwrap(); in sdv_buf_reader_lines() localVariable
274 while tcp.is_err() { in sdv_buf_reader_read()
[all …]
H A Dtcp_test.rs257 while tcp.is_err() { in sdv_tcp_multi_runtime()
260 let mut tcp = tcp.unwrap(); in sdv_tcp_multi_runtime() localVariable
433 while tcp.is_err() { in sdv_tcp_drop_out_context()
436 let mut tcp = tcp.unwrap(); in sdv_tcp_drop_out_context() localVariable
443 tcp in sdv_tcp_drop_out_context()
491 while tcp.is_err() { in sdv_tcp_cancel()
495 let mut tcp = tcp.unwrap(); in sdv_tcp_cancel() localVariable
529 while tcp.is_err() { in sdv_tcp_cancel()
532 let mut tcp = tcp.unwrap(); in sdv_tcp_cancel() localVariable
573 while tcp.is_err() { in sdv_tcp_unexpected_eof()
[all …]
H A Dasync_buf_write.rs43 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_writer_write() localVariable
44 while tcp.is_err() { in sdv_buf_writer_write()
45 tcp = TcpStream::connect(addr).await; in sdv_buf_writer_write()
47 let tcp = tcp.unwrap(); in sdv_buf_writer_write() localVariable
82 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_writer_write_vectored() localVariable
83 while tcp.is_err() { in sdv_buf_writer_write_vectored()
84 tcp = TcpStream::connect(addr).await; in sdv_buf_writer_write_vectored()
86 let tcp = tcp.unwrap(); in sdv_buf_writer_write_vectored() localVariable
179 while tcp.is_err() { in sdv_buf_writer_write_vectored_2()
180 tcp = TcpStream::connect(addr).await; in sdv_buf_writer_write_vectored_2()
[all …]
H A Dasync_read.rs65 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_buf_reader_read_to_string() localVariable
66 let (stream, _) = tcp.accept().await.unwrap(); in sdv_buf_reader_read_to_string()
76 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_reader_read_to_string() localVariable
77 while tcp.is_err() { in sdv_buf_reader_read_to_string()
78 tcp = TcpStream::connect(addr).await; in sdv_buf_reader_read_to_string()
80 let mut tcp = tcp.unwrap(); in sdv_buf_reader_read_to_string() localVariable
82 tcp.write_all(&buf).await.unwrap(); in sdv_buf_reader_read_to_string()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/
H A Dylong_tokio_tcp.rs27 let (mut stream, _) = tcp.accept().await.unwrap();
40 while tcp.is_err() {
43 let mut tcp = tcp.unwrap(); localVariable
46 tcp.write_all(&buf).await.unwrap();
49 tcp.read_exact(&mut buf).await.unwrap();
91 let mut tcp = TcpStream::connect(addr).await; localVariable
92 while tcp.is_err() {
93 tcp = TcpStream::connect(addr).await;
95 let mut tcp = tcp.unwrap(); localVariable
98 tcp.write_all(&buf).await.unwrap();
[all …]
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/examples/
H A Dylong_runtime_tcp.rs25 let tcp = TcpListener::bind(addr).await.unwrap(); in ylong_tcp_server() localVariable
26 let (mut stream, _) = tcp.accept().await.unwrap(); in ylong_tcp_server()
38 let mut tcp = TcpStream::connect(addr).await; in ylong_tcp_client() localVariable
39 while tcp.is_err() { in ylong_tcp_client()
40 tcp = TcpStream::connect(addr).await; in ylong_tcp_client()
42 let mut tcp = tcp.unwrap(); in ylong_tcp_client() localVariable
45 tcp.write_all(&buf).await.unwrap(); in ylong_tcp_client()
48 tcp.read_exact(&mut buf).await.unwrap(); in ylong_tcp_client()
H A Dylong_runtime_tcp_fd_limit.rs22 let tcp = TcpListener::bind("127.0.0.1:0").await; in main() localVariable
23 match tcp { in main()
/ohos5.0/foundation/communication/dsoftbus/tests/core/connection/common/unittest/
H A Dsoftbus_conn_common_test.cpp380 ASSERT_NE(tcp, nullptr);
395 int port = tcp->GetSockPort(fd);
399 fd = tcp->OpenServerSocket(nullptr);
405 fd = tcp->OpenServerSocket(&info);
420 ASSERT_NE(tcp, nullptr);
457 ASSERT_NE(tcp, nullptr);
473 ASSERT_NE(tcp, nullptr);
492 ASSERT_NE(tcp, nullptr);
507 int port = tcp->GetSockPort(fd);
511 fd = tcp->OpenServerSocket(nullptr);
[all …]
/ohos5.0/foundation/communication/dsoftbus/tests/core/connection/tcp/
H A Dtcp_manager_test.cpp841 ASSERT_NE(tcp, nullptr);
876 ASSERT_NE(tcp, nullptr);
910 ASSERT_NE(tcp, nullptr);
941 ASSERT_NE(tcp, nullptr);
977 ASSERT_NE(tcp, nullptr);
1017 ASSERT_NE(tcp, nullptr);
1303 ASSERT_NE(tcp, nullptr);
1329 ASSERT_NE(tcp, nullptr);
1352 ASSERT_NE(tcp, nullptr);
1392 ASSERT_NE(tcp, nullptr);
[all …]
/ohos5.0/docs/zh-cn/device-dev/subsystems/
H A Dsubsys-toolchain-hdc-guide.md304 hdc fport tcp:1234 tcp:1080
314 hdc rport tcp:2080 tcp:2345
326 | 'tcp:1234 tcp:1080' [Forward] | 正向端口转发任务 |
327 | 'tcp:2080 tcp:2345' [Reverse] | 反向端口转发任务 |
343 hdc fport rm tcp:1234 tcp:1080
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/
H A DCargo.toml11 default = ["tcp", "udp"]
13 tcp = []
21 required-features = ["tcp"]
26 required-features = ["tcp"]
/ohos5.0/docs/zh-cn/application-dev/dfx/
H A Dhdc.md282 2. 记录设备界面显示的监听端口号，记为PORT，用于后面的tcp连接。
284 3. 通过tcp连接设备（需要事先知道设备IP和打开的PORT），执行以下命令：
617 PC端支持的端口转发类型：tcp。
630 | tcp:1234 tcp:1080 [Forward] | 正向端口转发任务 |
631 | tcp:2080 tcp:2345 [Reverse] | 反向端口转发任务 |
656 hdc fport tcp:1234 tcp:1080
675 hdc rport tcp:1234 tcp:1080
686 | _taskstr_ | 端口转发任务，形如 tcp:XXXX tcp:XXXX。 |
691 | Remove forward ruler success, ruler:tcp:XXXX tcp:XXXX | 端口转发任务删除正常。 |
692 …| [Fail]Remove forward ruler failed, ruler is not exist tcp:XXXX tcp:XXXX | 端口转发任务删除失败，不存在指定的转发任务。…
[all …]
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/
H A Dmod.rs290 let mut tcp = tcp_stream; in https_connect() localVariable
293 let _ = tcp.fchown(fchown.uid, fchown.gid); in https_connect()
295 let local = tcp in https_connect()
298 let peer = tcp in https_connect()
302 tcp = tunnel(tcp, &host, port, auth) in https_connect()
487 let tcp = tcp_stream(eyeballs).await.unwrap(); in ut_ssl_tunnel_error() localVariable
489 tcp, in ut_ssl_tunnel_error()
526 tcp, in ut_ssl_tunnel_error()
566 tcp, in ut_ssl_tunnel_error()
613 tcp, in ut_ssl_tunnel_connect()
[all …]
/ohos5.0/docs/zh-cn/device-dev/kernel/
H A Dkernel-small-debug-shell-net-netstat.md40 tcp 0 0 192.168.1.10:578 192.168.1.3:2049 ESTABLISHED
41 tcp 0 0 192.168.1.10:58653 0.0.0.0:0 LISTEN
42 tcp 0 0 192.168.1.10:58652 0.0.0.0:0 LISTEN
43 tcp 0 0 192.168.1.10:58651 0.0.0.0:0 LISTEN
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/
H A Dcurrent_thread.rs363 let tcp = TcpListener::bind(ADDR).await.unwrap(); localVariable
364 let addr = tcp.local_addr().unwrap();
366 let (mut stream, _) = tcp.accept().await.unwrap();
379 let mut tcp = TcpStream::connect(addr).await; localVariable
380 while tcp.is_err() {
381 tcp = TcpStream::connect(addr).await;
383 let mut tcp = tcp.unwrap(); localVariable
386 tcp.write_all(&buf).await.unwrap();
389 tcp.read_exact(&mut buf).await.unwrap();
/ohos5.0/foundation/arkui/napi/sample/native_module_netserver/
H A Dnet_server.cpp106 uv_tcp_init(that->loop_, (uv_tcp_t*)&that->clients_->tcp); in OnConnection()
107 that->clients_->tcp.data = server->data; in OnConnection()
108 uv_accept(server, (uv_stream_t*)&that->clients_->tcp); in OnConnection()
109 uv_read_start((uv_stream_t*)&that->clients_->tcp, EchoAlloc, AfterRead); in OnConnection()
124 uv_close((uv_handle_t*)&i->tcp, nullptr); in OnServerClose()
H A Dnetserver.cpp105 uv_tcp_init(that->loop_, (uv_tcp_t*)&that->clients_->tcp); in OnConnection()
106 that->clients_->tcp.data = server->data; in OnConnection()
107 uv_accept(server, (uv_stream_t*)&that->clients_->tcp); in OnConnection()
108 uv_read_start((uv_stream_t*)&that->clients_->tcp, EchoAlloc, AfterRead); in OnConnection()
123 uv_close((uv_handle_t*)&i->tcp, nullptr); in OnServerClose()
/ohos5.0/foundation/communication/dsoftbus/core/connection/tcp/
H A Dconn_tcp.gni18 "$dsoftbus_root_path/core/connection/tcp/src/softbus_tcp_connect_manager.c",
22 "$dsoftbus_root_path/core/connection/tcp/src/softbus_tcp_connect_virtual.c",
27 "$dsoftbus_root_path/core/connection/tcp/include",
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/tests/
H A Dtcp_test.rs73 let tcp = net::TcpStream::connect(addr); in sdv_tcp_server() localVariable
74 match tcp { in sdv_tcp_server()
147 let tcp = net::TcpStream::connect(addr); in sdv_tcp_server_vectored() localVariable
148 match tcp { in sdv_tcp_server_vectored()
/ohos5.0/docs/en/device-dev/kernel/
H A Dkernel-small-debug-shell-net-netstat.md40 tcp 0 0 192.168.1.10:578 192.168.1.3:2049 ESTABLISHED
41 tcp 0 0 192.168.1.10:58653 0.0.0.0:0 LISTEN
42 tcp 0 0 192.168.1.10:58652 0.0.0.0:0 LISTEN
43 tcp 0 0 192.168.1.10:58651 0.0.0.0:0 LISTEN
/ohos5.0/docs/zh-cn/application-dev/napi/
H A Djsvm-debugger-cpuprofiler-heapsnapshot.md43 6. 转发端口。hdc fport tcp:9229 tcp:9225。转发PC侧端口9229到端侧端口9225。结果为"Forwardport result:OK"即可。
141 …上激活inspector，创建socket。例如OH_JSVM_OpenInspectorWithName(env, 123, “test”)，创建 tcp socket 及其对应的 unixdo…
143 … | grep jsvm"。结果出现可用的 unix 端口即可, 如: jsvm_devtools_remote_9229_123, 其中 9229 为 tcp 端口号, 123 为对应的 pid。
144 6. 转发端口。hdc fport tcp:9229 tcp:9229。转发PC侧端口9229到端侧端口9229。结果为"Forwardport result:OK"即可。
167 例如：hdc fport tcp:9227 tcp:9226
/ohos5.0/docs/zh-cn/application-dev/network/
H A Dsocket-connection.md124 tcp.on('message', (value: SocketInfo) => {
134 tcp.on('connect', () => {
137 tcp.on('close', () => {
160 tcp.connect(tcpConnect).then(() => {
165 tcp.send(tcpSendOptions).then(() => {
177 tcp.close().then(() => {
182 tcp.off('message');
183 tcp.off('connect');
184 tcp.off('close');
680 tcp.on('message', (value: SocketInfo) => {
[all …]
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/
H A Dmod.rs14 mod tcp; module
15 pub use tcp::{
/ohos5.0/docs/zh-cn/application-dev/reference/apis-network-kit/
H A Djs-apis-net-vpn-sys.md258 let tcp: socket.TCPSocket = socket.constructTCPSocketInstance();
262 tcp.bind(ipAddress);
271 tcp.connect(addressConnect);
272 tcp.getSocketFd().then((tunnelfd: number) => {
335 let tcp: socket.TCPSocket = socket.constructTCPSocketInstance();
339 tcp.bind(ipAddress);
348 tcp.connect(addressConnect);
349 tcp.getSocketFd().then((tunnelfd: number) => {
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/
H A Dmod.rs28 mod tcp;
29 pub use self::tcp::{TcpListener, TcpStream};

1234