Searched refs:STREAM_MAIN (Results 1 – 13 of 13) sorted by relevance
| /developtools/hdc/src/common/ |
| D | session.cpp | 442 hSession->pollHandle[STREAM_MAIN] = (uv_poll_t *)malloc(handleSize); in MallocSession()
443 uv_poll_t *pollHandleMain = hSession->pollHandle[STREAM_MAIN]; in MallocSession()
450 uv_poll_init_socket(&loopMain, pollHandleMain, hSession->ctrlFd[STREAM_MAIN]); in MallocSession()
452 hSession->pollHandle[STREAM_MAIN]->data = hSession; in MallocSession()
455 uv_tcp_init(&loopMain, &hSession->dataPipe[STREAM_MAIN]); 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()
463 Base::SetTcpOptions(&hSession->dataPipe[STREAM_MAIN]); in MallocSession()
555 if (handle == reinterpret_cast<uv_handle_t *>(hSession->pollHandle[STREAM_MAIN])) { in FreeSessionContinue()
556 free(hSession->pollHandle[STREAM_MAIN]); in FreeSessionContinue()
[all …]
|
| D | task.cpp | 115 fd = hSession->ctrlFd[STREAM_MAIN]; in ThreadCtrlCommunicate()
|
| D | define.h | 38 constexpr uint8_t STREAM_MAIN = 0; // work at main thread variable
|
| D | uart.cpp | 396 unsigned int fd = hSession->dataFd[STREAM_MAIN]; in UartToHdcProtocol()
597 if (UartToHdcProtocol(reinterpret_cast<uv_stream_t *>(&hSession->dataPipe[STREAM_MAIN]), in UartSendToHdcStream()
|
| /developtools/hdc/src/daemon/ |
| D | daemon_tcp.cpp | 94 Base::SendToPollFd(hSession->ctrlFd[STREAM_MAIN], ctrl.data(), ctrl.size()); in AcceptClient()
|
| D | daemon_usb.cpp | 373 Base::SendToPollFd(hChildSession->ctrlFd[STREAM_MAIN], ctrl.data(), ctrl.size()); in PrepareNewSession()
488 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 | 116 Base::SendToPollFd(hSession->ctrlFd[STREAM_MAIN], ctrl.data(), ctrl.size()); in Connect()
|
| D | host_usb.cpp | 451 unsigned int fd = hSession->dataFd[STREAM_MAIN]; in UsbToHdcProtocol()
579 …dRet = SendToHdcStream(hSession, reinterpret_cast<uv_stream_t *>(&hSession->dataPipe[STREAM_MAIN]), in BeginUsbRead()
716 Base::SendToPollFd(hSession->ctrlFd[STREAM_MAIN], ctrl.data(), ctrl.size()); in ConnectDetectDaemon()
|
| D | server_for_client.cpp | 732 Base::SendToPollFd(hSession->ctrlFd[STREAM_MAIN], ctrl.data(), ctrl.size()); in BindChannelToSession()
859 return Base::SendToPollFd(hSession->ctrlFd[STREAM_MAIN], ctrlMsg.data(), ctrlMsg.size()) > 0; in ChannelSendSessionCtrlMsg()
|
| D | host_uart.cpp | 499 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);
|