Home
last modified time | relevance | path

Searched refs:STREAM_WORK (Results 1 – 6 of 6) 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()
61 hSession->dataFd[STREAM_WORK]); in ReadyForWorkThread()
Dsession.cpp449 hSession->pollHandle[STREAM_WORK] = (uv_poll_t *)malloc(handleSize); in MallocSession()
452 if (pollHandleMain == nullptr || hSession->pollHandle[STREAM_WORK] == nullptr) { in MallocSession()
461 hSession->pollHandle[STREAM_WORK]->data = hSession; in MallocSession()
464 (void)memset_s(&hSession->dataPipe[STREAM_WORK], sizeof(hSession->dataPipe[STREAM_WORK]), in MallocSession()
470 hSession->dataPipe[STREAM_WORK].data = hSession; in MallocSession()
571 Base::CloseFd(hSession->ctrlFd[STREAM_WORK]); in FreeSessionContinue()
610 if (hSession->pollHandle[STREAM_WORK]->loop) { in FreeSessionOpeate()
1140 if (handle == (uv_handle_t *)hSession->pollHandle[STREAM_WORK]) { in DispatchMainThreadCommand()
1141 free(hSession->pollHandle[STREAM_WORK]); in DispatchMainThreadCommand()
1152 Base::TryCloseHandle((uv_handle_t *)hSession->pollHandle[STREAM_WORK], true, in DispatchMainThreadCommand()
[all …]
Dtask.cpp115 int fd = hSession->ctrlFd[STREAM_WORK]; in ThreadCtrlCommunicate()
Ddefine.h41 constexpr uint8_t STREAM_WORK = 1; // work at work thread variable
Duart.cpp981 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()
/developtools/hdc/test/unittest/common/
Duart_test.cpp420 auto tcp = &session.dataPipe[STREAM_WORK];
421 session.dataFd[STREAM_WORK] = rnd();
422 auto socket = session.dataFd[STREAM_WORK];
503 read(session.dataFd[STREAM_WORK], recvBuf.data(), recvBuf.size());
511 EXPECT_EQ(close(session.dataFd[STREAM_WORK]), 0);