Searched refs:STREAM_WORK (Results 1 – 6 of 6) sorted by relevance
| /developtools/hdc/src/common/ |
| D | usb.cpp | 43 if (uv_tcp_init(&hSession->childLoop, &hSession->dataPipe[STREAM_WORK]) || in ReadyForWorkThread()
44 uv_tcp_open(&hSession->dataPipe[STREAM_WORK], hSession->dataFd[STREAM_WORK])) { in ReadyForWorkThread()
48 hSession->dataPipe[STREAM_WORK].data = hSession; in ReadyForWorkThread()
50 Base::SetTcpOptions(&hSession->dataPipe[STREAM_WORK]); in ReadyForWorkThread()
51 …if (uv_read_start((uv_stream_t *)&hSession->dataPipe[STREAM_WORK], pSession->AllocCallback, ReadUS… in ReadyForWorkThread()
56 hSession->dataFd[STREAM_WORK]); in ReadyForWorkThread()
|
| D | session.cpp | 441 hSession->pollHandle[STREAM_WORK] = (uv_poll_t *)malloc(handleSize); in MallocSession()
444 if (pollHandleMain == nullptr || hSession->pollHandle[STREAM_WORK] == nullptr) { in MallocSession()
453 hSession->pollHandle[STREAM_WORK]->data = hSession; in MallocSession()
456 (void)memset_s(&hSession->dataPipe[STREAM_WORK], sizeof(hSession->dataPipe[STREAM_WORK]), in MallocSession()
462 hSession->dataPipe[STREAM_WORK].data = hSession; in MallocSession()
593 if (hSession->pollHandle[STREAM_WORK]->loop) { in FreeSessionOpeate()
1003 ssize_t nread = Base::ReadFromFd(hSession->ctrlFd[STREAM_WORK], buf, size); in ReadCtrlFromSession()
1118 if (handle == (uv_handle_t *)hSession->pollHandle[STREAM_WORK]) { in DispatchMainThreadCommand()
1119 free(hSession->pollHandle[STREAM_WORK]); in DispatchMainThreadCommand()
1130 Base::TryCloseHandle((uv_handle_t *)hSession->pollHandle[STREAM_WORK], true, in DispatchMainThreadCommand()
[all …]
|
| D | task.cpp | 117 fd = hSession->ctrlFd[STREAM_WORK]; in ThreadCtrlCommunicate()
|
| D | define.h | 39 constexpr uint8_t STREAM_WORK = 1; // work at work thread variable
|
| D | uart.cpp | 979 if (externInterface.UvTcpInit(&hSession->childLoop, &hSession->dataPipe[STREAM_WORK], in ReadyForWorkThread()
980 hSession->dataFd[STREAM_WORK])) { in ReadyForWorkThread()
984 hSession->dataPipe[STREAM_WORK].data = hSession; in ReadyForWorkThread()
986 externInterface.SetTcpOptions(&hSession->dataPipe[STREAM_WORK]); in ReadyForWorkThread()
987 if (externInterface.UvRead((uv_stream_t *)&hSession->dataPipe[STREAM_WORK], in ReadyForWorkThread()
|
| /developtools/hdc/test/unittest/common/ |
| D | uart_test.cpp | 420 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);
|