• Home
  • Raw
  • Download

Lines Matching refs:pollHandle

441     hSession->pollHandle[STREAM_WORK] = (uv_poll_t *)malloc(handleSize);  in MallocSession()
442 hSession->pollHandle[STREAM_MAIN] = (uv_poll_t *)malloc(handleSize); in MallocSession()
443 uv_poll_t *pollHandleMain = hSession->pollHandle[STREAM_MAIN]; in MallocSession()
444 if (pollHandleMain == nullptr || hSession->pollHandle[STREAM_WORK] == nullptr) { in MallocSession()
452 hSession->pollHandle[STREAM_MAIN]->data = hSession; in MallocSession()
453 hSession->pollHandle[STREAM_WORK]->data = hSession; in MallocSession()
555 if (handle == reinterpret_cast<uv_handle_t *>(hSession->pollHandle[STREAM_MAIN])) { in FreeSessionContinue()
556 free(hSession->pollHandle[STREAM_MAIN]); in FreeSessionContinue()
568 …Base::TryCloseHandle((uv_handle_t *)hSession->pollHandle[STREAM_MAIN], true, closeSessionTCPHandle… in FreeSessionContinue()
593 if (hSession->pollHandle[STREAM_WORK]->loop) { in FreeSessionOpeate()
1118 if (handle == (uv_handle_t *)hSession->pollHandle[STREAM_WORK]) { in DispatchMainThreadCommand()
1119 free(hSession->pollHandle[STREAM_WORK]); in DispatchMainThreadCommand()
1130 Base::TryCloseHandle((uv_handle_t *)hSession->pollHandle[STREAM_WORK], true, in DispatchMainThreadCommand()
1235 uv_poll_t *pollHandle = hSession->pollHandle[STREAM_WORK]; in SessionWorkThread() local
1236 pollHandle->data = hSession; in SessionWorkThread()
1237 uv_poll_init_socket(&hSession->childLoop, pollHandle, hSession->ctrlFd[STREAM_WORK]); in SessionWorkThread()
1238 uv_poll_start(pollHandle, UV_READABLE, ReadCtrlFromMain); in SessionWorkThread()