Home
last modified time | relevance | path

Searched refs:dataPipe (Results 1 – 7 of 7) sorted by relevance

/developtools/hdc/src/common/
Dusb.cpp43 if (uv_tcp_init(&hSession->childLoop, &hSession->dataPipe[STREAM_WORK]) || in ReadyForWorkThread()
44 uv_tcp_open(&hSession->dataPipe[STREAM_WORK], hSession->dataFd[STREAM_WORK])) { in ReadyForWorkThread()
48 hSession->dataPipe[STREAM_WORK].data = hSession; in ReadyForWorkThread()
50 Base::SetTcpOptions(&hSession->dataPipe[STREAM_WORK]); in ReadyForWorkThread()
51 …if (uv_read_start((uv_stream_t *)&hSession->dataPipe[STREAM_WORK], pSession->AllocCallback, ReadUS… in ReadyForWorkThread()
Dsession.cpp455 uv_tcp_init(&loopMain, &hSession->dataPipe[STREAM_MAIN]); in MallocSession()
456 (void)memset_s(&hSession->dataPipe[STREAM_WORK], sizeof(hSession->dataPipe[STREAM_WORK]), in MallocSession()
460 uv_tcp_open(&hSession->dataPipe[STREAM_MAIN], hSession->dataFd[STREAM_MAIN]); in MallocSession()
461 hSession->dataPipe[STREAM_MAIN].data = hSession; in MallocSession()
462 hSession->dataPipe[STREAM_WORK].data = hSession; in MallocSession()
463 Base::SetTcpOptions(&hSession->dataPipe[STREAM_MAIN]); in MallocSession()
569 …Base::TryCloseHandle((uv_handle_t *)&hSession->dataPipe[STREAM_MAIN], true, closeSessionTCPHandle); in FreeSessionContinue()
1132 Base::TryCloseHandle((uv_handle_t *)&hSession->dataPipe[STREAM_WORK], true, in DispatchMainThreadCommand()
Duart.cpp597 if (UartToHdcProtocol(reinterpret_cast<uv_stream_t *>(&hSession->dataPipe[STREAM_MAIN]), in UartSendToHdcStream()
979 if (externInterface.UvTcpInit(&hSession->childLoop, &hSession->dataPipe[STREAM_WORK], in ReadyForWorkThread()
984 hSession->dataPipe[STREAM_WORK].data = hSession; in ReadyForWorkThread()
986 externInterface.SetTcpOptions(&hSession->dataPipe[STREAM_WORK]); in ReadyForWorkThread()
987 if (externInterface.UvRead((uv_stream_t *)&hSession->dataPipe[STREAM_WORK], in ReadyForWorkThread()
Ddefine_plus.h408 uv_tcp_t dataPipe[2]; member
/developtools/hdc/src/daemon/
Ddaemon_usb.cpp488 uv_stream_t *stream = reinterpret_cast<uv_stream_t *>(&hChildSession->dataPipe[STREAM_MAIN]); in DispatchToWorkThread()
/developtools/hdc/src/host/
Dhost_usb.cpp579 …dRet = SendToHdcStream(hSession, reinterpret_cast<uv_stream_t *>(&hSession->dataPipe[STREAM_MAIN]), in BeginUsbRead()
/developtools/hdc/test/unittest/common/
Duart_test.cpp420 auto tcp = &session.dataPipe[STREAM_WORK];