Searched refs:hWorkTCP (Results 1 – 7 of 7) sorted by relevance
| /developtools/hdc/src/host/ |
| D | host_tcp.cpp | 106 if ((hSession->fdChildWorkTCP = Base::DuplicateUvSocket(&hSession->hWorkTCP)) < 0) { in Connect()
110 uv_read_stop((uv_stream_t *)&hSession->hWorkTCP); in Connect()
111 Base::SetTcpOptions((uv_tcp_t *)&hSession->hWorkTCP); in Connect()
152 uv_tcp_connect(conn, (uv_tcp_t *)&hSession->hWorkTCP, (const struct sockaddr *)&dest, Connect); in ConnectDaemon()
|
| D | client.cpp | 353 if (uv_is_closing((const uv_handle_t *)&channel->hWorkTCP)) { in ConnectServerForClient()
374 … uv_tcp_connect(conn, (uv_tcp_t *)&channel->hWorkTCP, (const struct sockaddr *)&destv4, Connect); in ConnectServerForClient()
379 … uv_tcp_connect(conn, (uv_tcp_t *)&channel->hWorkTCP, (const struct sockaddr *)&dest, Connect); in ConnectServerForClient()
510 if (status < 0 || uv_is_closing((const uv_handle_t *)&hChannel->hWorkTCP)) { in Connect()
516 Base::SetTcpOptions((uv_tcp_t *)&hChannel->hWorkTCP); in Connect()
517 uv_read_start((uv_stream_t *)&hChannel->hWorkTCP, AllocCallback, ReadStream); in Connect()
|
| D | server_for_client.cpp | 57 int rc = uv_accept(server, (uv_stream_t *)&hChannel->hWorkTCP); in AcceptClient()
66 uv_recv_buffer_size((uv_handle_t *)&hChannel->hWorkTCP, &bufMaxSize); in AcceptClient()
78 uv_read_start((uv_stream_t *)&hChannel->hWorkTCP, funcChannelHeaderAlloc, ReadStream); in AcceptClient()
718 bool isClosing = uv_is_closing((const uv_handle_t *)&hChannel->hWorkTCP); in BindChannelToSession()
719 … if (!isClosing && (hChannel->fdChildWorkTCP = Base::DuplicateUvSocket(&hChannel->hWorkTCP)) < 0) { in BindChannelToSession()
729 uv_close((uv_handle_t *)&hChannel->hWorkTCP, funcWorkTcpClose); in BindChannelToSession()
|
| /developtools/hdc/src/daemon/ |
| D | daemon_tcp.cpp | 83 if (uv_accept(server, (uv_stream_t *)&hSession->hWorkTCP) < 0) { in AcceptClient()
87 if ((hSession->fdChildWorkTCP = Base::DuplicateUvSocket(&hSession->hWorkTCP)) < 0) { in AcceptClient()
91 Base::TryCloseHandle((uv_handle_t *)&hSession->hWorkTCP); in AcceptClient()
|
| /developtools/hdc/src/common/ |
| D | channel.cpp | 327 sendStream = (uv_stream_t *)&hChannel->hWorkTCP; in SendChannel()
393 uv_tcp_init(loopMain, &hChannel->hWorkTCP); in MallocChannel()
396 hChannel->hWorkTCP.data = hChannel; in MallocChannel()
446 if (uv_is_closing((const uv_handle_t *)&hChannel->hWorkTCP)) { in FreeChannelContinue()
449 Base::TryCloseHandle((uv_handle_t *)&hChannel->hWorkTCP, closeChannelHandle); in FreeChannelContinue()
|
| D | define_plus.h | 421 uv_tcp_t hWorkTCP; member
493 uv_tcp_t hWorkTCP; // work channel for client, forward channel for server member
|
| D | session.cpp | 361 uv_tcp_init(&loopMain, &hSession->hWorkTCP); in MallocSessionByConnectType()
363 hSession->hWorkTCP.data = hSession; in MallocSessionByConnectType()
577 Base::TryCloseHandle((uv_handle_t *)&hSession->hWorkTCP, true, closeSessionTCPHandle); in FreeSessionContinue()
788 ret = pTCP->WriteUvTcpFd(&hSession->hWorkTCP, bufPtr, bufLen); in SendByProtocol()
|