Lines Matching refs:hSession
78 HSession hSession = ptrConnect->MallocSession(false, CONN_TCP, thisClass); in AcceptClient() local
79 if (!hSession) { in AcceptClient()
83 if (uv_accept(server, (uv_stream_t *)&hSession->hWorkTCP) < 0) { in AcceptClient()
84 WRITE_LOG(LOG_FATAL, "uv_accept error sessionId:%u", hSession->sessionId); in AcceptClient()
87 if ((hSession->fdChildWorkTCP = Base::DuplicateUvSocket(&hSession->hWorkTCP)) < 0) { in AcceptClient()
88 WRITE_LOG(LOG_FATAL, "AcceptClient error fdChildWorkTCP:%d", hSession->fdChildWorkTCP); in AcceptClient()
91 Base::TryCloseHandle((uv_handle_t *)&hSession->hWorkTCP); in AcceptClient()
92 Base::StartWorkThread(ptrLoop, ptrConnect->SessionWorkThread, Base::FinishWorkThread, hSession); in AcceptClient()
94 while (hSession->childLoop.active_handles == 0) { in AcceptClient()
97 Base::SendToPollFd(hSession->ctrlFd[STREAM_MAIN], ctrl.data(), ctrl.size()); in AcceptClient()
100 ptrConnect->FreeSession(hSession->sessionId); in AcceptClient()