Lines Matching refs:STREAM_WORK

449     hSession->pollHandle[STREAM_WORK] = (uv_poll_t *)malloc(handleSize);  in MallocSession()
452     if (pollHandleMain == nullptr || hSession->pollHandle[STREAM_WORK] == nullptr) {  in MallocSession()
461     hSession->pollHandle[STREAM_WORK]->data = hSession;  in MallocSession()
464     (void)memset_s(&hSession->dataPipe[STREAM_WORK], sizeof(hSession->dataPipe[STREAM_WORK]),  in MallocSession()
470     hSession->dataPipe[STREAM_WORK].data = hSession;  in MallocSession()
571             Base::CloseFd(hSession->ctrlFd[STREAM_WORK]);  in FreeSessionContinue()
610     if (hSession->pollHandle[STREAM_WORK]->loop) {  in FreeSessionOpeate()
1140                 if (handle == (uv_handle_t *)hSession->pollHandle[STREAM_WORK]) {  in DispatchMainThreadCommand()
1141                     free(hSession->pollHandle[STREAM_WORK]);  in DispatchMainThreadCommand()
1152             Base::TryCloseHandle((uv_handle_t *)hSession->pollHandle[STREAM_WORK], true,  in DispatchMainThreadCommand()
1154             Base::TryCloseHandle((uv_handle_t *)&hSession->dataPipe[STREAM_WORK], true,  in DispatchMainThreadCommand()
1189     ssize_t nread = Base::ReadFromFd(hSession->ctrlFd[STREAM_WORK], buf, size);  in ReadCtrlFromMain()
1257     uv_poll_t *pollHandle = hSession->pollHandle[STREAM_WORK];  in SessionWorkThread()
1259     uv_poll_init_socket(&hSession->childLoop, pollHandle, hSession->ctrlFd[STREAM_WORK]);  in SessionWorkThread()