Searched refs:STREAM_WORK (Results 1 - 6 of 6) sorted by relevance
| /developtools/hdc/src/common/ |
| H A D | usb.cpp | 44 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, ReadUSB)) { in ReadyForWorkThread()
60 WRITE_LOG(LOG_DEBUG, "USBBase ReadyForWorkThread finish dataFd[STREAM_WORK]:%d", in ReadyForWorkThread()
61 hSession->dataFd[STREAM_WORK]); in ReadyForWorkThread()
|
| H A D | session.cpp | 460 hSession->pollHandle[STREAM_WORK] = (uv_poll_t *)malloc(handleSize); in MallocSession()
463 if (pollHandleMain == nullptr || hSession->pollHandle[STREAM_WORK] == nullptr) { in MallocSession()
472 hSession->pollHandle[STREAM_WORK]->data = hSession; in MallocSession()
475 (void)memset_s(&hSession->dataPipe[STREAM_WORK], sizeof(hSession->dataPipe[STREAM_WORK]), in MallocSession()
481 hSession->dataPipe[STREAM_WORK].data = hSession; in MallocSession()
582 Base::CloseFd(hSession->ctrlFd[STREAM_WORK]); in FreeSessionContinue()
589 Base::CloseFd(hSession->dataFd[STREAM_WORK]); in FreeSessionContinue()
622 if (hSession->pollHandle[STREAM_WORK]->loop) { in FreeSessionOpeate()
1164 if (handle == (uv_handle_t *)hSession->pollHandle[STREAM_WORK]) { in DispatchMainThreadCommand()
[all...] |
| H A D | task.cpp | 120 int fd = hSession->ctrlFd[STREAM_WORK]; in ThreadCtrlCommunicate()
|
| H A D | uart.cpp | 981 if (externInterface.UvTcpInit(&hSession->childLoop, &hSession->dataPipe[STREAM_WORK],
in ReadyForWorkThread()
982 hSession->dataFd[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()
|
| H A D | define.h | 48 constexpr uint8_t STREAM_WORK = 1; // work at work thread member
|
| /developtools/hdc/test/unittest/common/ |
| H A D | uart_test.cpp | 420 auto tcp = &session.dataPipe[STREAM_WORK];
in HWTEST_F()
421 session.dataFd[STREAM_WORK] = rnd();
in HWTEST_F()
422 auto socket = session.dataFd[STREAM_WORK];
in HWTEST_F()
503 read(session.dataFd[STREAM_WORK], recvBuf.data(), recvBuf.size());
in HWTEST_F()
511 EXPECT_EQ(close(session.dataFd[STREAM_WORK]), 0);
in HWTEST_F()
|
Completed in 8 milliseconds