Searched refs:STREAM_MAIN (Results 1 – 12 of 12) sorted by relevance
| /developtools/hdc/src/common/ |
| D | session.cpp | 450 hSession->pollHandle[STREAM_MAIN] = (uv_poll_t *)malloc(handleSize); in MallocSession()
451 uv_poll_t *pollHandleMain = hSession->pollHandle[STREAM_MAIN]; in MallocSession()
458 uv_poll_init_socket(&loopMain, pollHandleMain, hSession->ctrlFd[STREAM_MAIN]); in MallocSession()
460 hSession->pollHandle[STREAM_MAIN]->data = hSession; in MallocSession()
463 uv_tcp_init(&loopMain, &hSession->dataPipe[STREAM_MAIN]); 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()
472 Base::SetTcpOptions(&hSession->dataPipe[STREAM_MAIN], HOST_SOCKETPAIR_SIZE); in MallocSession()
474 Base::SetTcpOptions(&hSession->dataPipe[STREAM_MAIN]); in MallocSession()
569 if (handle == reinterpret_cast<uv_handle_t *>(hSession->pollHandle[STREAM_MAIN])) { in FreeSessionContinue()
[all …]
|
| D | define.h | 40 constexpr uint8_t STREAM_MAIN = 0; // work at main thread variable
|
| D | uart.cpp | 398 unsigned int fd = hSession->dataFd[STREAM_MAIN]; in UartToHdcProtocol()
599 if (UartToHdcProtocol(reinterpret_cast<uv_stream_t *>(&hSession->dataPipe[STREAM_MAIN]), in UartSendToHdcStream()
|
| /developtools/hdc/src/daemon/ |
| D | daemon_tcp.cpp | 97 Base::SendToPollFd(hSession->ctrlFd[STREAM_MAIN], ctrl.data(), ctrl.size()); in AcceptClient()
|
| D | daemon_usb.cpp | 377 Base::SendToPollFd(hChildSession->ctrlFd[STREAM_MAIN], ctrl.data(), ctrl.size()); in PrepareNewSession()
492 uv_stream_t *stream = reinterpret_cast<uv_stream_t *>(&hChildSession->dataPipe[STREAM_MAIN]); in DispatchToWorkThread()
|
| D | daemon_uart.cpp | 228 Base::SendToPollFd(hSession->ctrlFd[STREAM_MAIN], ctrl.data(), ctrl.size()); in PrepareNewSession()
|
| /developtools/hdc/src/host/ |
| D | host_tcp.cpp | 118 Base::SendToPollFd(hSession->ctrlFd[STREAM_MAIN], ctrl.data(), ctrl.size()); in Connect()
|
| D | host_usb.cpp | 464 unsigned int fd = hSession->dataFd[STREAM_MAIN]; in UsbToHdcProtocol()
594 …dRet = SendToHdcStream(hSession, reinterpret_cast<uv_stream_t *>(&hSession->dataPipe[STREAM_MAIN]), in BeginUsbRead()
742 Base::SendToPollFd(hSession->ctrlFd[STREAM_MAIN], ctrl.data(), ctrl.size()); in ConnectDetectDaemon()
|
| D | server_for_client.cpp | 742 Base::SendToPollFd(hSession->ctrlFd[STREAM_MAIN], ctrl.data(), ctrl.size()); in BindChannelToSession()
876 return Base::SendToPollFd(hSession->ctrlFd[STREAM_MAIN], ctrlMsg.data(), ctrlMsg.size()) > 0; in ChannelSendSessionCtrlMsg()
|
| D | host_uart.cpp | 500 externInterface.SendToPollFd(hSession->ctrlFd[STREAM_MAIN], ctrl.data(), ctrl.size()); in EnumSerialPort()
|
| /developtools/hdc/test/unittest/common/ |
| D | host_uart_test.cpp | 218 SendToPollFd(mySession.ctrlFd[STREAM_MAIN], _, _))
232 SendToPollFd(mySession.ctrlFd[STREAM_MAIN], _, _))
|
| D | uart_test.cpp | 507 EXPECT_EQ(close(session.dataFd[STREAM_MAIN]), 0);
|