Searched refs:hWorkTCP (Results 1 – 7 of 7) sorted by relevance
| /developtools/hdc/src/host/ |
| D | host_tcp.cpp | 105 if ((hSession->fdChildWorkTCP = Base::DuplicateUvSocket(&hSession->hWorkTCP)) < 0) { in Connect()
108 uv_read_stop((uv_stream_t *)&hSession->hWorkTCP); in Connect()
109 Base::SetTcpOptions((uv_tcp_t *)&hSession->hWorkTCP); in Connect()
148 uv_tcp_connect(conn, (uv_tcp_t *)&hSession->hWorkTCP, (const struct sockaddr *)&dest, Connect); in ConnectDaemon()
|
| D | client.cpp | 351 if (uv_is_closing((const uv_handle_t *)&channel->hWorkTCP)) { in ConnectServerForClient()
371 … uv_tcp_connect(conn, (uv_tcp_t *)&channel->hWorkTCP, (const struct sockaddr *)&destv4, Connect); in ConnectServerForClient()
376 … uv_tcp_connect(conn, (uv_tcp_t *)&channel->hWorkTCP, (const struct sockaddr *)&dest, Connect); in ConnectServerForClient()
506 if (status < 0 || uv_is_closing((const uv_handle_t *)&hChannel->hWorkTCP)) { in Connect()
512 Base::SetTcpOptions((uv_tcp_t *)&hChannel->hWorkTCP); in Connect()
513 uv_read_start((uv_stream_t *)&hChannel->hWorkTCP, AllocCallback, ReadStream); in Connect()
|
| D | server_for_client.cpp | 56 if (uv_accept(server, (uv_stream_t *)&hChannel->hWorkTCP) < 0) { in AcceptClient()
63 uv_recv_buffer_size((uv_handle_t *)&hChannel->hWorkTCP, &bufMaxSize); in AcceptClient()
75 uv_read_start((uv_stream_t *)&hChannel->hWorkTCP, funcChannelHeaderAlloc, ReadStream); in AcceptClient()
709 bool isClosing = uv_is_closing((const uv_handle_t *)&hChannel->hWorkTCP); in BindChannelToSession()
710 … if (!isClosing && (hChannel->fdChildWorkTCP = Base::DuplicateUvSocket(&hChannel->hWorkTCP)) < 0) { in BindChannelToSession()
720 uv_close((uv_handle_t *)&hChannel->hWorkTCP, funcWorkTcpClose); in BindChannelToSession()
|
| /developtools/hdc/src/daemon/ |
| D | daemon_tcp.cpp | 82 if (uv_accept(server, (uv_stream_t *)&hSession->hWorkTCP) < 0) { in AcceptClient()
85 if ((hSession->fdChildWorkTCP = Base::DuplicateUvSocket(&hSession->hWorkTCP)) < 0) { in AcceptClient()
88 Base::TryCloseHandle((uv_handle_t *)&hSession->hWorkTCP); in AcceptClient()
|
| /developtools/hdc/src/common/ |
| D | channel.cpp | 317 sendStream = (uv_stream_t *)&hChannel->hWorkTCP; in SendChannel()
376 uv_tcp_init(loopMain, &hChannel->hWorkTCP); in MallocChannel()
379 hChannel->hWorkTCP.data = hChannel; in MallocChannel()
427 if (uv_is_closing((const uv_handle_t *)&hChannel->hWorkTCP)) { in FreeChannelContinue()
430 Base::TryCloseHandle((uv_handle_t *)&hChannel->hWorkTCP, closeChannelHandle); in FreeChannelContinue()
|
| D | define_plus.h | 418 uv_tcp_t hWorkTCP; member
490 uv_tcp_t hWorkTCP; // work channel for client, forward channel for server member
|
| D | session.cpp | 357 uv_tcp_init(&loopMain, &hSession->hWorkTCP); in MallocSessionByConnectType()
359 hSession->hWorkTCP.data = hSession; in MallocSessionByConnectType()
561 Base::TryCloseHandle((uv_handle_t *)&hSession->hWorkTCP, true, closeSessionTCPHandle); in FreeSessionContinue()
771 ret = pTCP->WriteUvTcpFd(&hSession->hWorkTCP, bufPtr, bufLen); in SendByProtocol()
|