| /developtools/hdc/src/common/ |
| D | tcp.cpp | 70 void HdcTCPBase::ReadStream(uv_stream_t *tcp, ssize_t nread, const uv_buf_t *buf) in ReadStream() argument
72 HSession hSession = (HSession)tcp->data; in ReadStream()
98 Base::TryCloseHandle(reinterpret_cast<uv_handle_t *>(tcp)); in ReadStream()
103 int HdcTCPBase::WriteUvTcpFd(uv_tcp_t *tcp, uint8_t *buf, int size) in WriteUvTcpFd() argument
109 uv_fileno(reinterpret_cast<uv_handle_t*>(tcp), &uvfd); in WriteUvTcpFd()
|
| D | forward.cpp | 106 uv_tcp_init(ctxClient->thisClass->loopTask, &ctxClient->tcp); in ListenCallback()
107 client = (uv_stream_t *)&ctxClient->tcp; in ListenCallback()
126 ctx->tcp.data = ctx; in MallocContext()
199 Base::TryCloseHandle((uv_handle_t *)&ctx->tcp, true, funcHandleClose); in FreeContext()
369 ctxPoint->tcp.data = ctxPoint; in SetupTCPPoint()
370 uv_tcp_init(loopTask, &ctxPoint->tcp); in SetupTCPPoint()
374 uv_tcp_bind(&ctxPoint->tcp, (const struct sockaddr *)&addr, 0); in SetupTCPPoint()
375 if (uv_listen((uv_stream_t *)&ctxPoint->tcp, 4, ListenCallback)) { in SetupTCPPoint()
387 … uv_tcp_connect(conn, (uv_tcp_t *)&ctxPoint->tcp, (const struct sockaddr *)&addr, ConnectTarget); in SetupTCPPoint()
660 uv_tcp_nodelay((uv_tcp_t *)&ctx->tcp, 1); in DoForwardBegin()
[all …]
|
| D | tcp.h | 24 static void ReadStream(uv_stream_t *tcp, ssize_t nread, const uv_buf_t *buf);
25 int WriteUvTcpFd(uv_tcp_t *tcp, uint8_t *buf, int size);
|
| D | channel.h | 26 static void ReadStream(uv_stream_t *tcp, ssize_t nread, const uv_buf_t *buf);
|
| D | forward.h | 48 uv_tcp_t tcp; member
|
| D | channel.cpp | 111 void HdcChannelBase::ReadStream(uv_stream_t *tcp, ssize_t nread, const uv_buf_t *buf) in ReadStream() argument
118 HChannel hChannel = (HChannel)tcp->data; in ReadStream()
130 Base::TryCloseHandle((uv_handle_t *)tcp); in ReadStream()
|
| D | base.h | 151 uv_os_sock_t DuplicateUvSocket(uv_tcp_t *tcp);
|
| D | uart.cpp | 46 int ExternInterface::UvTcpInit(uv_loop_t *loop, uv_tcp_t *tcp, int socketFd) in UvTcpInit() argument
48 if (uv_tcp_init(loop, tcp) == 0) { in UvTcpInit()
49 return uv_tcp_open(tcp, socketFd); in UvTcpInit()
|
| D | base.cpp | 1533 uv_os_sock_t DuplicateUvSocket(uv_tcp_t *tcp) in DuplicateUvSocket() argument
1539 if (WSADuplicateSocketA(tcp->socket, GetCurrentProcessId(), &info) < 0) { in DuplicateUvSocket()
1545 if (uv_fileno((const uv_handle_t *)tcp, &fdOs) < 0) { in DuplicateUvSocket()
|
| /developtools/hdc/src/daemon/ |
| D | daemon_forward.cpp | 61 if (uv_tcp_init(loopTask, &ctxPoint->tcp)) { in SetupJdwpPoint()
64 ctxPoint->tcp.data = ctxPoint; in SetupJdwpPoint()
65 if (uv_tcp_open(&ctxPoint->tcp, fds[0])) { in SetupJdwpPoint()
|
| /developtools/hdc/hdc_rust/src/ |
| D | transfer.rs | 19 pub mod tcp; module
|
| /developtools/hdc/ |
| D | README_zh.md | 176 …="p15653482487"></a>使用TCP模式连接设备，需在USB模式工作下使用tmode tcp切换至TCP工作模式，或者在<br>系统属性值中设置persist.hdc.mode属性值…
205 …01376355"><a name="p23801376355"></a><a name="p23801376355"></a>举例： hdc fport tcp:1234 tcp:1080</p>
211 …01376355"><a name="p23801376355"></a><a name="p23801376355"></a>举例： hdc rport tcp:1234 tcp:1080</p>
222 …76358"><a name="p23801376358"></a><a name="p23801376358"></a>举例： hdc fport rm tcp:1234 tcp:1080</p>
|
| D | BUILD.gn | 38 "src/common/tcp.cpp",
|
| /developtools/hdc/hdc_rust/src/host/ |
| D | server.rs | 121 let recv_opt = transfer::tcp::recv_channel_message(&mut rd).await; in handle_client()
201 let recv = transfer::tcp::recv_channel_message(rd).await.unwrap(); in handshake_with_client()
|
| D | auth.rs | 50 let msg = transfer::tcp::unpack_task_message(rd).await?; in handshake_with_daemon()
|
| D | task.rs | 350 match transfer::tcp::unpack_task_message(&mut rd).await { in tcp_handle_deamon()
|
| /developtools/hdc/hdc_rust/src/transfer/ |
| D | buffer.rs | 21 use super::{tcp, uart_wrapper};
260 tcp::recv_channel_message(&mut rd).await in recv()
|
| /developtools/hdc/test/unittest/common/ |
| D | uart_test.cpp | 420 auto tcp = &session.dataPipe[STREAM_WORK]; variable
426 EXPECT_CALL(mockInterface, UvTcpInit(loop, tcp, socket)).Times(1);
427 EXPECT_CALL(mockInterface, UvRead((uv_stream_t *)tcp, alloc, cb)).Times(1);
430 EXPECT_CALL(mockInterface, UvTcpInit(loop, tcp, socket)).Times(1).WillOnce(Return(-1));
434 EXPECT_CALL(mockInterface, UvTcpInit(loop, tcp, socket)).Times(1);
|
| /developtools/hdc/hdc_rust/src/daemon/ |
| D | main.rs | 82 let recv_msg = transfer::tcp::unpack_task_message(&mut rd).await?; in tcp_handle_client()
103 transfer::tcp::unpack_task_message(&mut rd).await, in tcp_handle_client()
|
| /developtools/hdc/test/ |
| D | BUILD.gn | 34 "${hdc_path}/src/common/tcp.cpp",
|
| /developtools/profiler/hiebpf/include/ |
| D | vmlinux.h | 9197 struct nf_tcp_net tcp; member
146233 } tcp; member
146512 } tcp; member
146552 struct ip_ct_tcp tcp; member
147830 struct tcp_sock tcp; member
149947 bool tcp; member
158381 struct cfg80211_wowlan_tcp *tcp; member
158422 const struct wiphy_wowlan_tcp_support *tcp; member
|