Home
last modified time | relevance | path

Searched refs:thisClass (Results 1 – 25 of 32) sorted by relevance

12

/developtools/hdc/src/test/
Dut_runtime.cpp56 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 = (Runtime *)arg->data; in CheckStopDaemon() local
[all …]
/developtools/hdc/src/common/
Dfile_descriptor.cpp75 HdcFileDescriptor *thisClass = ctxIO->thisClass; in FileIOOnThread() local
85 ev.data.fd = thisClass->fdIO; in FileIOOnThread()
87 epoll_ctl(epfd, EPOLL_CTL_ADD, thisClass->fdIO, &ev); in FileIOOnThread()
90 if (thisClass->workContinue == false) { in FileIOOnThread()
91 WRITE_LOG(LOG_INFO, "FileIOOnThread fdIO:%d workContinue false", thisClass->fdIO); in FileIOOnThread()
109 FD_SET(thisClass->fdIO, &rset); in FileIOOnThread()
110 int rc = select(thisClass->fdIO + 1, &rset, nullptr, nullptr, &timeout); in FileIOOnThread()
114 thisClass->fdIO, errno); in FileIOOnThread()
134 if ((nBytes > 0) && !thisClass->callbackRead(thisClass->callerContext, buf, nBytes)) { in FileIOOnThread()
135 WRITE_LOG(LOG_WARN, "FileIOOnThread fdIO:%d callbackRead false", thisClass->fdIO); in FileIOOnThread()
[all …]
Dchannel.cpp118 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
187 thisClass->FreeChannel(hChannel->channelId); in WriteCallback()
197 HdcChannelBase *thisClass = (HdcChannelBase *)param->thisClass; in AsyncMainLoopTask() local
202 thisClass->FreeChannel(param->sid); in AsyncMainLoopTask()
220 HdcChannelBase *thisClass = (HdcChannelBase *)handle->data; in MainAsyncCallback() local
221 if (uv_is_closing((uv_handle_t *)thisClass->loopMain)) { in MainAsyncCallback()
226 list<void *> &lst = thisClass->lstMainThreadOP; in MainAsyncCallback()
[all …]
Dtransfer.cpp51 context->thisClass = this; in ResetCtx()
127 HdcTransferBase *thisClass = (HdcTransferBase *)context->thisClass; in OnFileClose() local
131 thisClass->WhenTransferFinish(context); in OnFileClose()
133 --thisClass->refCount; in OnFileClose()
206 HdcTransferBase *thisClass = (HdcTransferBase *)context->thisClass; in OnFileIO() local
230 … if (!thisClass->SendIOPayload(context, context->indexIO - req->result, bufIO, req->result)) { in OnFileIO()
235 thisClass->SimpleFileIO(context, context->indexIO, nullptr, in OnFileIO()
236 Base::GetMaxBufSize() * thisClass->maxTransferBufFactor); in OnFileIO()
250 thisClass->SetFileTime(context); in OnFileIO()
259 ++thisClass->refCount; in OnFileIO()
[all …]
Dasync_cmd.cpp83 AsyncCmd *thisClass = static_cast<AsyncCmd *>(const_cast<void *>(context)); in FinishShellProc() local
84 …WRITE_LOG(LOG_DEBUG, "FinishShellProc finish pipeRead fd:%d pid:%d", thisClass->fd, thisClass->pid… in FinishShellProc()
85 thisClass->resultCallback(true, result, thisClass->cmdResult + exitMsg); in FinishShellProc()
86 --thisClass->refCount; in FinishShellProc()
92 AsyncCmd *thisClass = static_cast<AsyncCmd *>(const_cast<void *>(context)); in ChildReadCallback() local
93 if (thisClass->options & OPTION_COMMAND_ONETIME) { in ChildReadCallback()
95 thisClass->cmdResult += s; in ChildReadCallback()
99 return thisClass->resultCallback(false, 0, s); in ChildReadCallback()
Dsession.cpp115 HdcSessionBase *thisClass = (HdcSessionBase *)hTask->ownerSessionClass; in BeginRemoveTask() local
123 if (!thisClass->TryRemoveTask(hTask)) { in BeginRemoveTask()
188 HdcSessionBase *thisClass = (HdcSessionBase *)handle->data; in ReMainLoopForInstanceClear() local
189 if (thisClass->sessionRef > 0) { in ReMainLoopForInstanceClear()
194 uv_stop(&thisClass->loopMain); in ReMainLoopForInstanceClear()
285 HdcSessionBase *thisClass = (HdcSessionBase *)param->thisClass; in AsyncMainLoopTask() local
289 thisClass->FreeSession(param->sid); in AsyncMainLoopTask()
292 uv_stop(&thisClass->loopMain); in AsyncMainLoopTask()
307 HdcSessionBase *thisClass = (HdcSessionBase *)handle->data; in MainAsyncCallback() local
309 list<void *> &lst = thisClass->lstMainThreadOP; in MainAsyncCallback()
[all …]
Dtcp.cpp39 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()
Dforward.cpp91 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->FreeContextCallBack(ctx); in FreeJDWP()
193 ctx->thisClass->FreeContextCallBack(ctx); in FreeContext()
[all …]
/developtools/hdc/src/daemon/
Ddaemon_usb.cpp112 ctxRecv.thisClass = this; in Initial()
267 HdcDaemonUSB *thisClass; in CloseBulkEp() member
278 ctx->thisClass = this; in CloseBulkEp()
285 ctx->thisClass->usbHandle.bulkIn = 0; in CloseBulkEp()
287 ctx->thisClass->usbHandle.bulkOut = 0; in CloseBulkEp()
520 auto thisClass = reinterpret_cast<HdcDaemonUSB *>(ctxIo->thisClass); in OnUSBRead() local
526 if (bytesIOBytes > hUSB->wMaxPacketSizeSend && bytesIOBytes != thisClass->saveNextReadSize) { in OnUSBRead()
527 …WRITE_LOG(LOG_WARN, "Not full packet, wanted:%d really:%d", thisClass->saveNextReadSize, bytesIOBy… in OnUSBRead()
529 while (thisClass->isAlive) { in OnUSBRead()
551 if (thisClass->JumpAntiquePacket(*bufPtr, bytesIOBytes)) { in OnUSBRead()
[all …]
Djdwp.cpp48 HdcJdwp *thisClass = (HdcJdwp *)handle->data; in Stop() local
49 --thisClass->refCount; in Stop()
68 ctx->thisClass = this; in MallocContext()
88 --ctxIn->thisClass->refCount; in FreeContext()
130 HdcJdwp *thisClass = static_cast<HdcJdwp *>(ctxJdwp->thisClass); in ReadStream() local
159 thisClass->AdminContext(OP_ADD, pid, ctxJdwp); in ReadStream()
165 thisClass->freeContextMutex.lock(); in ReadStream()
166 thisClass->pollNodeMap.emplace(fd, PollNode(fd, pid)); in ReadStream()
167 thisClass->freeContextMutex.unlock(); in ReadStream()
168 thisClass->WakePollThread(); in ReadStream()
[all …]
Ddaemon_uart.h39 HdcDaemonUART *thisClass = static_cast<HdcDaemonUART *>(handle->data); in UvWatchTimer() local
40 if (thisClass != nullptr) { in UvWatchTimer()
41 thisClass->WatcherTimerCallBack(); in UvWatchTimer()
Ddaemon_forward.cpp35 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()
Ddaemon_tcp.cpp73 HdcDaemonTCP *thisClass = (HdcDaemonTCP *)pServTCP->data; in AcceptClient() local
74 HdcSessionBase *ptrConnect = reinterpret_cast<HdcSessionBase *>(thisClass->clsMainBase); in AcceptClient()
75 HdcSessionBase *daemon = reinterpret_cast<HdcSessionBase *>(thisClass->clsMainBase); in AcceptClient()
78 HSession hSession = ptrConnect->MallocSession(false, CONN_TCP, thisClass); in AcceptClient()
Ddaemon_bridge.cpp65 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()
Dshell.cpp277 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/
Dhost_unity.cpp21 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()
Dclient.cpp117 HdcClient *thisClass = (HdcClient *)handle->data; in DoCtrlServiceWork() local
118 string &strCmd = thisClass->command; in DoCtrlServiceWork()
119 …if (!strncmp(thisClass->command.c_str(), CMDSTR_SERVICE_START.c_str(), CMDSTR_SERVICE_START.size()… in DoCtrlServiceWork()
120 thisClass->StartKillServer(thisClass->command.c_str(), true); in DoCtrlServiceWork()
121 …} else if (!strncmp(thisClass->command.c_str(), CMDSTR_SERVICE_KILL.c_str(), CMDSTR_SERVICE_KILL.s… in DoCtrlServiceWork()
122 thisClass->StartKillServer(thisClass->command.c_str(), false); in DoCtrlServiceWork()
124 …} else if (!strncmp(thisClass->command.c_str(), CMDSTR_GENERATE_KEY.c_str(), CMDSTR_GENERATE_KEY.s… in DoCtrlServiceWork()
387 HdcClient *thisClass = (HdcClient *)handle->data; in CommandWorker() local
388 if (++thisClass->debugRetryCount > maxWaitRetry) { in CommandWorker()
390 uv_stop(thisClass->loopMain); in CommandWorker()
[all …]
Dhost_uart.h68 HdcHostUART *thisClass = static_cast<HdcHostUART *>(handle->data); in UvWatchUartDevPlugin() local
69 if (thisClass != nullptr) { in UvWatchUartDevPlugin()
70 thisClass->WatchUartDevPlugin(); in UvWatchUartDevPlugin()
Dserver_for_client.cpp50 HdcServerForClient *thisClass = (HdcServerForClient *)pServTCP->data; in AcceptClient() local
52 uint32_t uid = thisClass->MallocChannel(&hChannel); in AcceptClient()
60 thisClass->FreeChannel(uid); in AcceptClient()
90 thisClass->Send(hChannel->channelId, (uint8_t *)&handShake, sizeof(struct ChannelHandShake)); in AcceptClient()
93 thisClass->Send(hChannel->channelId, reinterpret_cast<uint8_t *>(&handShake), in AcceptClient()
261 HdcServerForClient *thisClass = (HdcServerForClient *)hChannel->clsChannel; in OrderConnecTargetResult() local
262 HdcServer *ptrServer = (HdcServer *)thisClass->clsServer; in OrderConnecTargetResult()
281 thisClass->CommandRemoveSession(hChannel, hChannel->key.c_str()); in OrderConnecTargetResult()
282 thisClass->EchoClient(hChannel, MSG_OK, const_cast<char *>(hdi->version.c_str())); in OrderConnecTargetResult()
285 thisClass->EchoClient(hChannel, MSG_OK, const_cast<char *>(sRet.c_str())); in OrderConnecTargetResult()
[all …]
Dhost_usb.cpp216 HdcHostUSB *thisClass = static_cast<HdcHostUSB *>(handle->data); in WatchUsbNodeChange() local
217 HdcServer *ptrConnect = static_cast<HdcServer *>(thisClass->clsMainBase); in WatchUsbNodeChange()
223 ssize_t cnt = libusb_get_device_list(thisClass->ctxUSB, &devs); in WatchUsbNodeChange()
233 UsbCheckStatus statusCheck = thisClass->mapIgnoreDevice[szTmpKey]; in WatchUsbNodeChange()
238 if (thisClass->HasValidDevice(dev) && !thisClass->DetectMyNeed(dev, sn)) { in WatchUsbNodeChange()
239 thisClass->ReviewUsbNodeLater(szTmpKey); in WatchUsbNodeChange()
272 HdcHostUSB *thisClass = (HdcHostUSB *)arg; in UsbWorkThread() local
274 while (thisClass->modRunning) { in UsbWorkThread()
278 libusb_handle_events_timeout(thisClass->ctxUSB, &zerotime); in UsbWorkThread()
Dhost_unity.h36 HdcHostUnity *thisClass; member
/developtools/hdc/src/test/jdwp/
DHdcJdwpSimulator.cpp144 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 = this; in MallocContext()
/developtools/hdc/src/register/
Dhdc_jdwp.cpp77 HdcJdwpSimulator *thisClass = param; in ConnectJpid() local
79 std::string processName = thisClass->processName_; in ConnectJpid()
80 std::string pkgName = thisClass->pkgName_; in ConnectJpid()
81 bool isDebug = thisClass->isDebug_; in ConnectJpid()
109 ret = SendToJpid(thisClass->ctxPoint_->cfd, static_cast<uint8_t*>(info), ppSize); in ConnectJpid()
123 ctx->thisClass = this; in MallocContext()
Dhdc_jdwp.h35 HdcJdwpSimulator *thisClass; member
/developtools/hdc/hdc_rust/src/cffi/host/
Dhost_usb.cpp83 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()

12