Lines Matching refs:STREAM_MAIN
461 hSession->pollHandle[STREAM_MAIN] = (uv_poll_t *)malloc(handleSize);
462 uv_poll_t *pollHandleMain = hSession->pollHandle[STREAM_MAIN];
469 uv_poll_init_socket(&loopMain, pollHandleMain, hSession->ctrlFd[STREAM_MAIN]);
471 hSession->pollHandle[STREAM_MAIN]->data = hSession;
474 uv_tcp_init(&loopMain, &hSession->dataPipe[STREAM_MAIN]);
479 uv_tcp_open(&hSession->dataPipe[STREAM_MAIN], hSession->dataFd[STREAM_MAIN]);
480 hSession->dataPipe[STREAM_MAIN].data = hSession;
483 Base::SetTcpOptions(&hSession->dataPipe[STREAM_MAIN], HOST_SOCKETPAIR_SIZE);
485 Base::SetTcpOptions(&hSession->dataPipe[STREAM_MAIN]);
580 if (handle == reinterpret_cast<uv_handle_t *>(hSession->pollHandle[STREAM_MAIN])) {
581 Base::CloseFd(hSession->ctrlFd[STREAM_MAIN]);
583 free(hSession->pollHandle[STREAM_MAIN]);
596 Base::TryCloseHandle((uv_handle_t *)hSession->pollHandle[STREAM_MAIN], true, closeSessionTCPHandle);
597 Base::TryCloseHandle((uv_handle_t *)&hSession->dataPipe[STREAM_MAIN], true, closeSessionTCPHandle);
624 Base::SendToPollFd(hSession->ctrlFd[STREAM_MAIN], ctrl.data(), ctrl.size());
1041 ssize_t nread = Base::ReadFromFd(hSession->ctrlFd[STREAM_MAIN], buf, size);