Home
last modified time | relevance | path

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

/developtools/hdc/src/common/
Dusb.cpp44 if (uv_tcp_init(&hSession->childLoop, &hSession->dataPipe[STREAM_WORK]) || in ReadyForWorkThread()
45 uv_tcp_open(&hSession->dataPipe[STREAM_WORK], hSession->dataFd[STREAM_WORK])) { in ReadyForWorkThread()
49 hSession->dataPipe[STREAM_WORK].data = hSession; in ReadyForWorkThread()
52 Base::SetTcpOptions(&hSession->dataPipe[STREAM_WORK], HOST_SOCKETPAIR_SIZE); in ReadyForWorkThread()
54 Base::SetTcpOptions(&hSession->dataPipe[STREAM_WORK]); in ReadyForWorkThread()
56 …if (uv_read_start((uv_stream_t *)&hSession->dataPipe[STREAM_WORK], pSession->AllocCallback, ReadUS… in ReadyForWorkThread()
Dsession.cpp463 uv_tcp_init(&loopMain, &hSession->dataPipe[STREAM_MAIN]); in MallocSession()
464 (void)memset_s(&hSession->dataPipe[STREAM_WORK], sizeof(hSession->dataPipe[STREAM_WORK]), in MallocSession()
468 uv_tcp_open(&hSession->dataPipe[STREAM_MAIN], hSession->dataFd[STREAM_MAIN]); in MallocSession()
469 hSession->dataPipe[STREAM_MAIN].data = hSession; in MallocSession()
470 hSession->dataPipe[STREAM_WORK].data = hSession; in MallocSession()
472 Base::SetTcpOptions(&hSession->dataPipe[STREAM_MAIN], HOST_SOCKETPAIR_SIZE); in MallocSession()
474 Base::SetTcpOptions(&hSession->dataPipe[STREAM_MAIN]); in MallocSession()
585 …Base::TryCloseHandle((uv_handle_t *)&hSession->dataPipe[STREAM_MAIN], true, closeSessionTCPHandle); in FreeSessionContinue()
1154 Base::TryCloseHandle((uv_handle_t *)&hSession->dataPipe[STREAM_WORK], true, in DispatchMainThreadCommand()
Duart.cpp599 if (UartToHdcProtocol(reinterpret_cast<uv_stream_t *>(&hSession->dataPipe[STREAM_MAIN]), in UartSendToHdcStream()
981 if (externInterface.UvTcpInit(&hSession->childLoop, &hSession->dataPipe[STREAM_WORK], in ReadyForWorkThread()
986 hSession->dataPipe[STREAM_WORK].data = hSession; in ReadyForWorkThread()
988 externInterface.SetTcpOptions(&hSession->dataPipe[STREAM_WORK]); in ReadyForWorkThread()
989 if (externInterface.UvRead((uv_stream_t *)&hSession->dataPipe[STREAM_WORK], in ReadyForWorkThread()
Ddefine_plus.h411 uv_tcp_t dataPipe[2]; member
/developtools/hdc/src/daemon/
Ddaemon_usb.cpp492 uv_stream_t *stream = reinterpret_cast<uv_stream_t *>(&hChildSession->dataPipe[STREAM_MAIN]); in DispatchToWorkThread()
/developtools/hdc/src/host/
Dhost_usb.cpp594 …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];