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