| /developtools/hdc/src/test/ |
| H A D | ut_runtime.cpp | 56 Runtime *thisClass = (Runtime *)arg->data; in CheckStopServer() local
57 thisClass->serverRunning = true; in CheckStopServer()
58 if (!thisClass->checkFinish) { in CheckStopServer()
62 thisClass->server->PostStopInstanceMessage(); in CheckStopServer()
63 Base::TryCloseHandle((uv_handle_t *)&thisClass->checkServerStop); in CheckStopServer()
69 Runtime *thisClass = static_cast<Runtime *>(arg->data); in StartServer() local
73 thisClass->server = &server; in StartServer()
75 uv_idle_t *idt = &thisClass->checkServerStop; in StartServer()
76 idt->data = thisClass; in StartServer()
86 Runtime *thisClass in CheckStopDaemon() local
98 Runtime *thisClass = static_cast<Runtime *>(arg->data); StartDaemon() local
130 Runtime *thisClass = (Runtime *)handle->data; DoCheck() local
[all...] |
| /developtools/hdc/src/common/ |
| H A D | file_descriptor.cpp | 78 HdcFileDescriptor *thisClass = ctxIO->thisClass; in FileIOOnThread() local
88 ev.data.fd = thisClass->fdIO; in FileIOOnThread()
90 epoll_ctl(epfd, EPOLL_CTL_ADD, thisClass->fdIO, &ev); in FileIOOnThread()
93 if (thisClass->workContinue == false) { in FileIOOnThread()
94 WRITE_LOG(LOG_INFO, "FileIOOnThread fdIO:%d workContinue false", thisClass->fdIO); in FileIOOnThread()
112 FD_SET(thisClass->fdIO, &rset); in FileIOOnThread()
113 int rc = select(thisClass->fdIO + 1, &rset, nullptr, nullptr, &timeout); in FileIOOnThread()
117 thisClass->fdIO, errno); in FileIOOnThread()
130 if ((event & EPOLLIN) && (thisClass in FileIOOnThread()
[all...] |
| H A D | transfer.cpp | 65 context->thisClass = this; in ResetCtx()
154 HdcTransferBase *thisClass = (HdcTransferBase *)context->thisClass; in OnFileClose() local
158 thisClass->WhenTransferFinish(context); in OnFileClose()
160 --thisClass->refCount; in OnFileClose()
233 HdcTransferBase *thisClass = (HdcTransferBase *)context->thisClass; in OnFileIO() local
258 if (!thisClass->SendIOPayload(context, context->indexIO - req->result, bufIO, req->result)) { in OnFileIO()
269 thisClass->SimpleFileIO(context, context->indexIO, nullptr, context->isStableBufSize ? in OnFileIO()
270 (Base::GetMaxBufSizeStable() * thisClass in OnFileIO()
326 HdcTransferBase *thisClass = (HdcTransferBase *)context->thisClass; OnFileOpenFailed() local
343 HdcTransferBase *thisClass = (HdcTransferBase *)context->thisClass; OnFileOpen() local
764 HdcTransferBase *thisClass = (HdcTransferBase *)context->thisClass; CommandDispatch() local
[all...] |
| H A D | channel.cpp | 118 HdcChannelBase *thisClass = (HdcChannelBase *)hChannel->clsChannel; in ReadStream() local
149 childRet = thisClass->ReadChannel(hChannel, reinterpret_cast<uint8_t *>(hChannel->ioBuf) + in ReadStream()
172 thisClass->FreeChannel(hChannel->channelId); in ReadStream()
181 HdcChannelBase *thisClass = (HdcChannelBase *)hChannel->clsChannel; in WriteCallback() local
186 thisClass->FreeChannel(hChannel->channelId); in WriteCallback()
196 HdcChannelBase *thisClass = (HdcChannelBase *)param->thisClass; in AsyncMainLoopTask() local
201 thisClass->FreeChannel(param->sid); in AsyncMainLoopTask()
219 HdcChannelBase *thisClass = (HdcChannelBase *)handle->data; in MainAsyncCallback() local
220 if (uv_is_closing((uv_handle_t *)thisClass in MainAsyncCallback()
413 HdcChannelBase *thisClass = (HdcChannelBase *)hChannel->clsChannel; FreeChannelFinally() local
473 HdcChannelBase *thisClass = (HdcChannelBase *)hChannel->clsChannel; FreeChannelOpeate() local
[all...] |
| H A D | async_cmd.cpp | 84 AsyncCmd *thisClass = static_cast<AsyncCmd *>(const_cast<void *>(context)); in FinishShellProc() local
85 WRITE_LOG(LOG_DEBUG, "FinishShellProc finish pipeRead fd:%d pid:%d", thisClass->fd, thisClass->pid); in FinishShellProc()
86 thisClass->resultCallback(true, result, thisClass->cmdResult + exitMsg); in FinishShellProc()
87 --thisClass->refCount; in FinishShellProc()
93 AsyncCmd *thisClass = static_cast<AsyncCmd *>(const_cast<void *>(context)); in ChildReadCallback() local
94 if (thisClass->options & OPTION_COMMAND_ONETIME) { in ChildReadCallback()
96 thisClass->cmdResult += s; in ChildReadCallback()
100 return thisClass in ChildReadCallback()
[all...] |
| H A D | tcp.cpp | 39 HdcTCPBase *thisClass = (HdcTCPBase *)handle->data; in RecvUDP() local
48 thisClass->RecvUDPEntry(addr, handle, rcvbuf); in RecvUDP()
73 HdcTCPBase *thisClass = (HdcTCPBase *)hSession->classModule; in ReadStream() local
74 HdcSessionBase *hSessionBase = (HdcSessionBase *)thisClass->clsMainBase; in ReadStream()
|
| H A D | forward.cpp | 91 HdcForwardBase *thisClass = ctxListen->thisClass; in ListenCallback() local
97 thisClass->FreeContext(ctxListen, 0, false); in ListenCallback()
98 thisClass->TaskFinish(); in ListenCallback()
101 HCtxForward ctxClient = (HCtxForward)thisClass->MallocContext(true); in ListenCallback()
106 uv_tcp_init(ctxClient->thisClass->loopTask, &ctxClient->tcp); in ListenCallback()
110 uv_pipe_init(ctxClient->thisClass->loopTask, &ctxClient->pipe, 0); in ListenCallback()
113 thisClass->OnAccept(server, ctxClient, client); in ListenCallback()
124 ctx->thisClass = this; in MallocContext()
158 ctx->thisClass in FreeJDWP()
277 HdcForwardBase *thisClass = ctx->thisClass; ConnectTarget() local
[all...] |
| H A D | session.cpp | 115 HdcSessionBase *thisClass = (HdcSessionBase *)hTask->ownerSessionClass; in BeginRemoveTask()
120 bool ret = thisClass->RemoveInstanceTask(OP_CLEAR, hTask); in BeginRemoveTask()
134 if (!thisClass->TryRemoveTask(hTask)) { in BeginRemoveTask()
199 HdcSessionBase *thisClass = (HdcSessionBase *)handle->data; in ReMainLoopForInstanceClear()
200 if (thisClass->sessionRef > 0) { in ReMainLoopForInstanceClear()
205 uv_stop(&thisClass->loopMain); in ReMainLoopForInstanceClear()
296 HdcSessionBase *thisClass = (HdcSessionBase *)param->thisClass; in AsyncMainLoopTask() local
300 thisClass->FreeSession(param->sid); in AsyncMainLoopTask()
303 uv_stop(&thisClass in AsyncMainLoopTask()
318 HdcSessionBase *thisClass = (HdcSessionBase *)handle->data; MainAsyncCallback() local
555 HdcSessionBase *thisClass = (HdcSessionBase *)hSession->classInstance; FreeSessionFinally() local
615 HdcSessionBase *thisClass = (HdcSessionBase *)hSession->classInstance; FreeSessionOpeate() local
1002 HdcSessionBase *thisClass = (HdcSessionBase *)hSession->classInstance; FinishWriteSessionTCP() local
1280 HdcSessionBase *thisClass = (HdcSessionBase *)hSession->classInstance; SessionWorkThread() local
[all...] |
| /developtools/hdc/src/daemon/ |
| H A D | daemon_usb.cpp | 112 ctxRecv.thisClass = this; in Initial()
270 HdcDaemonUSB *thisClass; in CloseBulkEp() member
281 ctx->thisClass = this; in CloseBulkEp()
288 ctx->thisClass->usbHandle.bulkIn = 0; in CloseBulkEp()
290 ctx->thisClass->usbHandle.bulkOut = 0; in CloseBulkEp()
588 auto thisClass = reinterpret_cast<HdcDaemonUSB *>(ctxIo->thisClass); in OnUSBRead() local
594 if (bytesIOBytes > hUSB->wMaxPacketSizeSend && bytesIOBytes != thisClass->saveNextReadSize) { in OnUSBRead()
595 WRITE_LOG(LOG_WARN, "Not full packet, wanted:%d really:%d", thisClass->saveNextReadSize, bytesIOBytes); in OnUSBRead()
597 while (thisClass in OnUSBRead()
684 HdcDaemonUSB *thisClass = (HdcDaemonUSB *)handle->data; WatchEPTimer() local
[all...] |
| H A D | jdwp.cpp | 49 HdcJdwp *thisClass = (HdcJdwp *)handle->data; in Stop()
50 --thisClass->refCount; in Stop()
69 ctx->thisClass = this; in MallocContext()
88 --ctxIn->thisClass->refCount; in FreeContext()
137 HdcJdwp *thisClass = static_cast<HdcJdwp *>(ctxJdwp->thisClass); in ReadStream() local
166 thisClass->AdminContext(OP_ADD, pid, ctxJdwp); in ReadStream()
172 thisClass->freeContextMutex.lock(); in ReadStream()
173 thisClass->pollNodeMap.emplace(fd, PollNode(fd, pid)); in ReadStream()
174 thisClass in ReadStream()
227 HdcJdwp *thisClass = (HdcJdwp *)listenPipe->data; AcceptClient() local
645 auto thisClass = static_cast<HdcJdwp *>(args); FdEventPollThread() local
[all...] |
| H A D | daemon_uart.h | 39 HdcDaemonUART *thisClass = static_cast<HdcDaemonUART *>(handle->data);
in UvWatchTimer() local
40 if (thisClass != nullptr) {
in UvWatchTimer()
41 thisClass->WatcherTimerCallBack();
in UvWatchTimer()
|
| H A D | daemon_tcp.cpp | 70 HdcDaemonTCP *thisClass = (HdcDaemonTCP *)pServTCP->data; in AcceptClient() local
71 HdcSessionBase *ptrConnect = reinterpret_cast<HdcSessionBase *>(thisClass->clsMainBase); in AcceptClient()
72 HdcSessionBase *daemon = reinterpret_cast<HdcSessionBase *>(thisClass->clsMainBase); in AcceptClient()
75 HSession hSession = ptrConnect->MallocSession(false, CONN_TCP, thisClass); in AcceptClient()
|
| H A D | daemon_forward.cpp | 35 HdcDaemonForward *thisClass = reinterpret_cast<HdcDaemonForward *>(ctxPoint->thisClass); in SetupJdwpPointCallBack() local
36 thisClass->SetupPointContinue(ctxPoint, 1); // It usually works in SetupJdwpPointCallBack()
38 --thisClass->refCount; in SetupJdwpPointCallBack()
|
| H A D | daemon_bridge.cpp | 65 HdcDaemonBridge *thisClass = (HdcDaemonBridge *)pServBridge->data; in AcceptClient() local
66 HdcSessionBase *ptrConnect = reinterpret_cast<HdcSessionBase *>(thisClass->clsMainBase); in AcceptClient()
76 HSession hSession = ptrConnect->MallocSession(false, CONN_TCP, thisClass); in AcceptClient()
|
| H A D | shell.cpp | 277 HdcShell *thisClass = reinterpret_cast<HdcShell *>(const_cast<void *>(context)); in FinishShellProc() local
278 thisClass->TaskFinish(); in FinishShellProc()
279 --thisClass->refCount; in FinishShellProc()
285 HdcShell *thisClass = reinterpret_cast<HdcShell *>(const_cast<void *>(context)); in ChildReadCallback() local
286 return thisClass->SendToAnother(CMD_KERNEL_ECHO_RAW, reinterpret_cast<uint8_t *>(buf), size); in ChildReadCallback()
|
| /developtools/hdc/src/host/ |
| H A D | client.cpp | 143 HdcClient *thisClass = (HdcClient *)handle->data; in DoCtrlServiceWork() local
144 string &strCmd = thisClass->command; in DoCtrlServiceWork()
145 if (!strncmp(thisClass->command.c_str(), CMDSTR_SERVICE_START.c_str(), CMDSTR_SERVICE_START.size())) { in DoCtrlServiceWork()
146 thisClass->StartServer(strCmd); in DoCtrlServiceWork()
147 } else if (!strncmp(thisClass->command.c_str(), CMDSTR_SERVICE_KILL.c_str(), CMDSTR_SERVICE_KILL.size())) { in DoCtrlServiceWork()
148 thisClass->KillServer(strCmd); in DoCtrlServiceWork()
150 } else if (!strncmp(thisClass->command.c_str(), CMDSTR_GENERATE_KEY.c_str(), CMDSTR_GENERATE_KEY.size()) && in DoCtrlServiceWork()
419 HdcClient *thisClass = (HdcClient *)handle->data; in CommandWorker() local
420 if (++thisClass->debugRetryCount > maxWaitRetry) { in CommandWorker()
422 uv_stop(thisClass in CommandWorker()
475 HdcClient *thisClass = (HdcClient *)hChannel->clsChannel; ReadStd() local
540 HdcClient *thisClass = (HdcClient *)connection->data; Connect() local
571 HdcClient *thisClass = (HdcClient *)handle->data; RetryTcpConnectWorker() local
[all...] |
| H A D | host_unity.cpp | 21 opContext.thisClass = this; in HdcHostUnity()
61 HdcHostUnity *thisClass = reinterpret_cast<HdcHostUnity *>(context->thisClass); in OnFileClose() local
63 --thisClass->refCount; in OnFileClose()
85 HdcHostUnity *thisClass = reinterpret_cast<HdcHostUnity *>(context->thisClass); in OnFileIO() local
88 --thisClass->refCount; in OnFileIO()
|
| H A D | host_uart.h | 68 HdcHostUART *thisClass = static_cast<HdcHostUART *>(handle->data);
in UvWatchUartDevPlugin() local
69 if (thisClass != nullptr) {
in UvWatchUartDevPlugin()
70 thisClass->WatchUartDevPlugin();
in UvWatchUartDevPlugin()
|
| H A D | host_usb.cpp | 217 HdcHostUSB *thisClass = static_cast<HdcHostUSB *>(handle->data); in WatchUsbNodeChange() local
218 HdcServer *ptrConnect = static_cast<HdcServer *>(thisClass->clsMainBase); in WatchUsbNodeChange()
224 ssize_t cnt = libusb_get_device_list(thisClass->ctxUSB, &devs); in WatchUsbNodeChange()
234 UsbCheckStatus statusCheck = thisClass->mapIgnoreDevice[szTmpKey]; in WatchUsbNodeChange()
239 if (thisClass->HasValidDevice(dev) && !thisClass->DetectMyNeed(dev, sn)) { in WatchUsbNodeChange()
240 thisClass->ReviewUsbNodeLater(szTmpKey); in WatchUsbNodeChange()
273 HdcHostUSB *thisClass = (HdcHostUSB *)arg; in UsbWorkThread() local
275 while (thisClass->modRunning) { in UsbWorkThread()
279 libusb_handle_events_timeout(thisClass in UsbWorkThread()
[all...] |
| H A D | server_for_client.cpp | 50 HdcServerForClient *thisClass = (HdcServerForClient *)pServTCP->data; in AcceptClient() local
52 uint32_t uid = thisClass->MallocChannel(&hChannel); in AcceptClient()
60 thisClass->FreeChannel(uid); in AcceptClient()
91 thisClass->Send(hChannel->channelId, (uint8_t *)&handShake, sizeof(struct ChannelHandShake)); in AcceptClient()
94 thisClass->Send(hChannel->channelId, reinterpret_cast<uint8_t *>(&handShake), in AcceptClient()
262 HdcServerForClient *thisClass = (HdcServerForClient *)hChannel->clsChannel; in OrderConnecTargetResult() local
263 HdcServer *ptrServer = (HdcServer *)thisClass->clsServer; in OrderConnecTargetResult()
282 thisClass->CommandRemoveSession(hChannel, hChannel->key.c_str()); in OrderConnecTargetResult()
283 thisClass->EchoClient(hChannel, MSG_OK, const_cast<char *>(hdi->version.c_str())); in OrderConnecTargetResult()
286 thisClass in OrderConnecTargetResult()
[all...] |
| H A D | host_unity.h | 36 HdcHostUnity *thisClass; member
|
| /developtools/hdc/src/test/jdwp/ |
| H A D | HdcJdwpSimulator.cpp | 144 HdcJdwpSimulator *thisClass = static_cast<HdcJdwpSimulator *>(ctxJdwp->thisClass);
in ReceiveNewFd() local
168 uv_tcp_init(thisClass->loop, &ctxJdwp->newFd);
in ReceiveNewFd()
191 HdcJdwpSimulator *thisClass = static_cast<HdcJdwpSimulator *>(ctxJdwp->thisClass);
in ConnectJdwp() local
195 string pkgName = thisClass->pkgName;
in ConnectJdwp()
221 thisClass->SendToStream(reinterpret_cast<uv_stream_t *>(&ctxJdwp->pipe), info, pkgSize,
in ConnectJdwp()
237 thisClass->SendToStream(reinterpret_cast<uv_stream_t *>(&ctxJdwp->pipe),
in ConnectJdwp()
241 uv_read_start(reinterpret_cast<uv_stream_t *>(&ctxJdwp->pipe), thisClass->alloc_buffer,
in ConnectJdwp()
252 ctx->thisClass in MallocContext()
[all...] |
| H A D | HdcJdwpSimulator.h | 34 HdcJdwpSimulator *thisClass;
member
|
| /developtools/hdc/hdc_rust/src/cffi/host/ |
| H A D | host_usb.cpp | 83 HostUsb *thisClass = (HostUsb *)arg;
in UsbWorkThread() local
85 while (thisClass->running) {
in UsbWorkThread()
89 libusb_handle_events_timeout(thisClass->ctxUSB, &zerotime);
in UsbWorkThread()
95 HostUsb *thisClass = (HostUsb *)arg;
in WatchUsbNodeChange() local
98 ssize_t cnt = libusb_get_device_list(thisClass->ctxUSB, &devs);
in WatchUsbNodeChange()
107 UsbCheckStatus statusCheck = thisClass->mapIgnoreDevice[szTmpKey];
in WatchUsbNodeChange()
112 if (thisClass->HasValidDevice(dev) && !thisClass->DetectMyNeed(dev, sn)) {
in WatchUsbNodeChange()
113 thisClass->ReviewUsbNodeLater(szTmpKey);
in WatchUsbNodeChange()
|
| /developtools/hdc/test/fuzztest/daemonusbread_fuzzer/ |
| H A D | DaemonUsbRead_fuzzer.cpp | 42 ctxRecv.thisClass = &daemonusb; in FuzzDaemonUsbRead()
|