Searched refs:STREAM_MAIN (Results 1 – 13 of 13) sorted by relevance
| /developtools/hdc/src/common/ |
| D | session.cpp | 434 uv_tcp_init(&loopMain, &hSession->ctrlPipe[STREAM_MAIN]); in MallocSession()
439 uv_tcp_open(&hSession->ctrlPipe[STREAM_MAIN], hSession->ctrlFd[STREAM_MAIN]); in MallocSession()
440 …uv_read_start((uv_stream_t *)&hSession->ctrlPipe[STREAM_MAIN], Base::AllocBufferCallback, ReadCtrl… in MallocSession()
441 hSession->ctrlPipe[STREAM_MAIN].data = hSession; in MallocSession()
444 uv_tcp_init(&loopMain, &hSession->dataPipe[STREAM_MAIN]); in MallocSession()
449 uv_tcp_open(&hSession->dataPipe[STREAM_MAIN], hSession->dataFd[STREAM_MAIN]); in MallocSession()
450 hSession->dataPipe[STREAM_MAIN].data = hSession; in MallocSession()
452 Base::SetTcpOptions(&hSession->dataPipe[STREAM_MAIN]); in MallocSession()
554 …Base::TryCloseHandle((uv_handle_t *)&hSession->ctrlPipe[STREAM_MAIN], true, closeSessionTCPHandle); in FreeSessionContinue()
555 …Base::TryCloseHandle((uv_handle_t *)&hSession->dataPipe[STREAM_MAIN], true, closeSessionTCPHandle); in FreeSessionContinue()
[all …]
|
| D | task.cpp | 112 handleStream = (uv_stream_t *)&hSession->ctrlPipe[STREAM_MAIN]; in ThreadCtrlCommunicate()
|
| D | define.h | 38 constexpr uint8_t STREAM_MAIN = 0; // work at main thread variable
|
| D | uart.cpp | 391 unsigned int fd = hSession->dataFd[STREAM_MAIN]; in UartToHdcProtocol()
592 if (UartToHdcProtocol(reinterpret_cast<uv_stream_t *>(&hSession->dataPipe[STREAM_MAIN]), in UartSendToHdcStream()
|
| /developtools/hdc/src/daemon/ |
| D | daemon_tcp.cpp | 94 Base::SendToStream((uv_stream_t *)&hSession->ctrlPipe[STREAM_MAIN], ctrl.data(), ctrl.size()); in AcceptClient()
|
| D | daemon_usb.cpp | 373 …Base::SendToStream((uv_stream_t *)&hChildSession->ctrlPipe[STREAM_MAIN], ctrl.data(), ctrl.size()); in PrepareNewSession()
414 uv_stream_t *stream = reinterpret_cast<uv_stream_t *>(&hChildSession->dataPipe[STREAM_MAIN]); in DispatchToWorkThread()
|
| D | daemon_uart.cpp | 228 Base::SendToStream((uv_stream_t *)&hSession->ctrlPipe[STREAM_MAIN], ctrl.data(), in PrepareNewSession()
|
| /developtools/hdc/src/host/ |
| D | host_usb.cpp | 420 unsigned int fd = hSession->dataFd[STREAM_MAIN]; in UsbToHdcProtocol()
548 …dRet = SendToHdcStream(hSession, reinterpret_cast<uv_stream_t *>(&hSession->dataPipe[STREAM_MAIN]), in BeginUsbRead()
685 Base::SendToStream((uv_stream_t *)&hSession->ctrlPipe[STREAM_MAIN], ctrl.data(), ctrl.size()); in ConnectDetectDaemon()
|
| D | host_tcp.cpp | 116 Base::SendToStream((uv_stream_t *)&hSession->ctrlPipe[STREAM_MAIN], ctrl.data(), ctrl.size()); in Connect()
|
| D | server_for_client.cpp | 679 … Base::SendToStream((uv_stream_t *)&hSession->ctrlPipe[STREAM_MAIN], ctrl.data(), ctrl.size()); in BindChannelToSession()
806 …return Base::SendToStream((uv_stream_t *)&hSession->ctrlPipe[STREAM_MAIN], ctrlMsg.data(), ctrlMsg… in ChannelSendSessionCtrlMsg()
|
| D | host_uart.cpp | 497 externInterface.SendToStream((uv_stream_t *)&hSession->ctrlPipe[STREAM_MAIN], ctrl.data(), in EnumSerialPort()
|
| /developtools/hdc/test/unittest/common/ |
| D | host_uart_test.cpp | 217 SendToStream(reinterpret_cast<uv_stream_t *>(&mySession.ctrlPipe[STREAM_MAIN]), _, _))
231 SendToStream(reinterpret_cast<uv_stream_t *>(&mySession.ctrlPipe[STREAM_MAIN]), _, _))
|
| D | uart_test.cpp | 507 EXPECT_EQ(close(session.dataFd[STREAM_MAIN]), 0);
|