98     HSession hSession = (HSession)connection->data;  in Connect()  local
100     HdcSessionBase *ptrConnect = (HdcSessionBase *)hSession->classInstance;  in Connect()
106     if ((hSession->fdChildWorkTCP = Base::DuplicateUvSocket(&hSession->hWorkTCP)) < 0) {  in Connect()
107         WRITE_LOG(LOG_FATAL, "Connect fdChildWorkTCP:%d", hSession->fdChildWorkTCP);  in Connect()
110     uv_read_stop((uv_stream_t *)&hSession->hWorkTCP);  in Connect()
111     Base::SetTcpOptions((uv_tcp_t *)&hSession->hWorkTCP);  in Connect()
113 …WorkThread(&ptrConnect->loopMain, ptrConnect->SessionWorkThread, Base::FinishWorkThread, hSession);  in Connect()
115     while (hSession->childLoop.active_handles == 0) {  in Connect()
118     Base::SendToPollFd(hSession->ctrlFd[STREAM_MAIN], ctrl.data(), ctrl.size());  in Connect()
121     WRITE_LOG(LOG_FATAL, "Connect failed sessionId:%u", hSession->sessionId);  in Connect()
122     ptrConnect->FreeSession(hSession->sessionId);  in Connect()
135     HSession hSession = ptrConnect->MallocSession(true, CONN_TCP, this);  in ConnectDaemon()  local
136     if (!hSession) {  in ConnectDaemon()
140     hSession->isCheck = isCheck;  in ConnectDaemon()
141     hSession->connectKey = connectKey;  in ConnectDaemon()
147         delete hSession;  in ConnectDaemon()
148         hSession = nullptr;  in ConnectDaemon()
151     conn->data = hSession;  in ConnectDaemon()
152     uv_tcp_connect(conn, (uv_tcp_t *)&hSession->hWorkTCP, (const struct sockaddr *)&dest, Connect);  in ConnectDaemon()
153     return hSession;  in ConnectDaemon()