Lines Matching refs:pollHandle
460 hSession->pollHandle[STREAM_WORK] = (uv_poll_t *)malloc(handleSize);
461 hSession->pollHandle[STREAM_MAIN] = (uv_poll_t *)malloc(handleSize);
462 uv_poll_t *pollHandleMain = hSession->pollHandle[STREAM_MAIN];
463 if (pollHandleMain == nullptr || hSession->pollHandle[STREAM_WORK] == nullptr) {
464 WRITE_LOG(LOG_FATAL, "MallocSession malloc hSession->pollHandle failed");
471 hSession->pollHandle[STREAM_MAIN]->data = hSession;
472 hSession->pollHandle[STREAM_WORK]->data = hSession;
580 if (handle == reinterpret_cast<uv_handle_t *>(hSession->pollHandle[STREAM_MAIN])) {
583 free(hSession->pollHandle[STREAM_MAIN]);
596 Base::TryCloseHandle((uv_handle_t *)hSession->pollHandle[STREAM_MAIN], true, closeSessionTCPHandle);
622 if (hSession->pollHandle[STREAM_WORK]->loop) {
1164 if (handle == (uv_handle_t *)hSession->pollHandle[STREAM_WORK]) {
1165 free(hSession->pollHandle[STREAM_WORK]);
1177 Base::TryCloseHandle((uv_handle_t *)hSession->pollHandle[STREAM_WORK], true,
1283 uv_poll_t *pollHandle = hSession->pollHandle[STREAM_WORK];
1284 pollHandle->data = hSession;
1285 uv_poll_init_socket(&hSession->childLoop, pollHandle, hSession->ctrlFd[STREAM_WORK]);
1286 uv_poll_start(pollHandle, UV_READABLE, ReadCtrlFromMain);