98     HSession hSession = (HSession)connection->data;  in Connect()  local
100     HdcSessionBase *ptrConnect = (HdcSessionBase *)hSession->classInstance;  in Connect()
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()
111 …WorkThread(&ptrConnect->loopMain, ptrConnect->SessionWorkThread, Base::FinishWorkThread, hSession);  in Connect()
113     while (hSession->childLoop.active_handles == 0) {  in Connect()
116     Base::SendToPollFd(hSession->ctrlFd[STREAM_MAIN], ctrl.data(), ctrl.size());  in Connect()
120     ptrConnect->FreeSession(hSession->sessionId);  in Connect()
132     HSession hSession = ptrConnect->MallocSession(true, CONN_TCP, this);  in ConnectDaemon()  local
133     if (!hSession) {  in ConnectDaemon()
136     hSession->isCheck = isCheck;  in ConnectDaemon()
137     hSession->connectKey = connectKey;  in ConnectDaemon()
143         delete hSession;  in ConnectDaemon()
144         hSession = nullptr;  in ConnectDaemon()
147     conn->data = hSession;  in ConnectDaemon()
148     uv_tcp_connect(conn, (uv_tcp_t *)&hSession->hWorkTCP, (const struct sockaddr *)&dest, Connect);  in ConnectDaemon()
149     return hSession;  in ConnectDaemon()