| /developtools/hdc/src/test/ |
| 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 = (Runtime *)arg->data; in CheckStopDaemon() local
[all …]
|
| /developtools/hdc/src/common/ |
| D | file_descriptor.cpp | 52 auto thisClass = (HdcFileDescriptor *)req->data; in StopWork() local
54 if (thisClass->callbackCloseFd != nullptr) { in StopWork()
55 thisClass->callbackCloseFd(); in StopWork()
57 --thisClass->refIO; in StopWork()
65 HdcFileDescriptor *thisClass = ctxIO->thisClass; in OnFileIO() local
73 if (!thisClass->callbackRead(thisClass->callerContext, buf, req->result)) { in OnFileIO()
77 thisClass->LoopRead(); in OnFileIO()
86 WRITE_LOG(LOG_DEBUG, "OnFileIO fd:%d failed:%s", thisClass->fdIO, buffer); in OnFileIO()
97 --thisClass->refIO; in OnFileIO()
99 thisClass->callbackFinish(thisClass->callerContext, fetalFinish, STRING_EMPTY); in OnFileIO()
[all …]
|
| D | async_cmd.cpp | 74 AsyncCmd *thisClass = static_cast<AsyncCmd *>(const_cast<void *>(context)); in FinishShellProc() local
75 thisClass->resultCallback(true, result, thisClass->cmdResult + exitMsg); in FinishShellProc()
76 --thisClass->refCount; in FinishShellProc()
82 AsyncCmd *thisClass = static_cast<AsyncCmd *>(const_cast<void *>(context)); in ChildReadCallback() local
83 if (thisClass->options & OPTION_COMMAND_ONETIME) { in ChildReadCallback()
85 thisClass->cmdResult += s; in ChildReadCallback()
89 return thisClass->resultCallback(false, 0, s); in ChildReadCallback()
|
| D | channel.cpp | 117 HdcChannelBase *thisClass = (HdcChannelBase *)hChannel->clsChannel; in ReadStream() local
146 childRet = thisClass->ReadChannel(hChannel, reinterpret_cast<uint8_t *>(hChannel->ioBuf) + in ReadStream()
167 thisClass->FreeChannel(hChannel->channelId); in ReadStream()
176 HdcChannelBase *thisClass = (HdcChannelBase *)hChannel->clsChannel; in WriteCallback() local
180 thisClass->FreeChannel(hChannel->channelId); in WriteCallback()
191 HdcChannelBase *thisClass = (HdcChannelBase *)param->thisClass; in AsyncMainLoopTask() local
196 thisClass->FreeChannel(param->sid); in AsyncMainLoopTask()
214 HdcChannelBase *thisClass = (HdcChannelBase *)handle->data; in MainAsyncCallback() local
215 if (uv_is_closing((uv_handle_t *)thisClass->loopMain)) { in MainAsyncCallback()
219 list<void *> &lst = thisClass->lstMainThreadOP; in MainAsyncCallback()
[all …]
|
| D | transfer.cpp | 47 context->thisClass = this; in ResetCtx()
112 HdcTransferBase *thisClass = (HdcTransferBase *)context->thisClass; in OnFileClose() local
116 thisClass->WhenTransferFinish(context); in OnFileClose()
118 --thisClass->refCount; in OnFileClose()
190 HdcTransferBase *thisClass = (HdcTransferBase *)context->thisClass; in OnFileIO() local
213 … if (!thisClass->SendIOPayload(context, context->indexIO - req->result, bufIO, req->result)) { in OnFileIO()
218 thisClass->SimpleFileIO(context, context->indexIO, nullptr, in OnFileIO()
219 Base::GetMaxBufSize() * thisClass->maxTransferBufFactor); in OnFileIO()
233 thisClass->SetFileTime(context); in OnFileIO()
242 ++thisClass->refCount; in OnFileIO()
[all …]
|
| 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()
|
| D | forward.cpp | 86 HdcForwardBase *thisClass = ctxListen->thisClass; in ListenCallback() local
90 thisClass->FreeContext(ctxListen, 0, false); in ListenCallback()
91 thisClass->TaskFinish(); in ListenCallback()
94 HCtxForward ctxClient = (HCtxForward)thisClass->MallocContext(true); in ListenCallback()
99 uv_tcp_init(ctxClient->thisClass->loopTask, &ctxClient->tcp); in ListenCallback()
103 uv_pipe_init(ctxClient->thisClass->loopTask, &ctxClient->pipe, 0); in ListenCallback()
106 thisClass->OnAccept(server, ctxClient, client); in ListenCallback()
117 ctx->thisClass = this; in MallocContext()
150 ctx->thisClass->FreeContextCallBack(ctx); in FreeJDWP()
184 ctx->thisClass->FreeContextCallBack(ctx); in FreeContext()
[all …]
|
| D | session.cpp | 109 HdcSessionBase *thisClass = (HdcSessionBase *)hTask->ownerSessionClass; in BeginRemoveTask() local
117 if (!thisClass->TryRemoveTask(hTask)) { in BeginRemoveTask()
179 HdcSessionBase *thisClass = (HdcSessionBase *)handle->data; in ReMainLoopForInstanceClear() local
180 if (thisClass->sessionRef > 0) { in ReMainLoopForInstanceClear()
185 uv_stop(&thisClass->loopMain); in ReMainLoopForInstanceClear()
276 HdcSessionBase *thisClass = (HdcSessionBase *)param->thisClass; in AsyncMainLoopTask() local
280 thisClass->FreeSession(param->sid); in AsyncMainLoopTask()
283 uv_stop(&thisClass->loopMain); in AsyncMainLoopTask()
298 HdcSessionBase *thisClass = (HdcSessionBase *)handle->data; in MainAsyncCallback() local
300 list<void *> &lst = thisClass->lstMainThreadOP; in MainAsyncCallback()
[all …]
|
| D | file_descriptor.h | 41 HdcFileDescriptor *thisClass; member
|
| /developtools/hdc/src/daemon/ |
| D | jdwp.cpp | 50 HdcJdwp *thisClass = (HdcJdwp *)handle->data; in Stop() local
51 --thisClass->refCount; in Stop()
69 ctx->thisClass = this; in MallocContext()
87 --ctx->thisClass->refCount; in FreeContext()
123 HdcJdwp *thisClass = static_cast<HdcJdwp *>(ctxJdwp->thisClass); in ReadStream() local
149 thisClass->AdminContext(OP_ADD, pid, ctxJdwp); in ReadStream()
155 thisClass->freeContextMutex.lock(); in ReadStream()
156 thisClass->pollNodeMap.emplace(fd, PollNode(fd, pid)); in ReadStream()
157 thisClass->freeContextMutex.unlock(); in ReadStream()
158 thisClass->WakePollThread(); in ReadStream()
[all …]
|
| D | daemon_usb.cpp | 102 ctxRecv.thisClass = this; in Initial()
266 HdcDaemonUSB *thisClass; in CloseBulkEp() member
277 ctx->thisClass = this; in CloseBulkEp()
284 ctx->thisClass->usbHandle.bulkIn = 0; in CloseBulkEp()
286 ctx->thisClass->usbHandle.bulkOut = 0; in CloseBulkEp()
439 auto thisClass = reinterpret_cast<HdcDaemonUSB *>(ctxIo->thisClass); in OnUSBRead() local
445 if (bytesIOBytes > hUSB->wMaxPacketSizeSend && bytesIOBytes != thisClass->saveNextReadSize) { in OnUSBRead()
446 …WRITE_LOG(LOG_WARN, "Not full packet, wanted:%d really:%d", thisClass->saveNextReadSize, bytesIOBy… in OnUSBRead()
448 while (thisClass->isAlive) { in OnUSBRead()
470 if (thisClass->JumpAntiquePacket(*bufPtr, bytesIOBytes)) { in OnUSBRead()
[all …]
|
| D | daemon_forward.cpp | 34 HdcDaemonForward *thisClass = reinterpret_cast<HdcDaemonForward *>(ctxPoint->thisClass); in SetupJdwpPointCallBack() local
35 thisClass->SetupPointContinue(ctxPoint, 1); // It usually works in SetupJdwpPointCallBack()
38 --thisClass->refCount; in SetupJdwpPointCallBack()
|
| 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()
|
| D | shell.cpp | 208 HdcShell *thisClass = reinterpret_cast<HdcShell *>(const_cast<void *>(context)); in FinishShellProc() local
209 thisClass->TaskFinish(); in FinishShellProc()
210 --thisClass->refCount; in FinishShellProc()
216 HdcShell *thisClass = reinterpret_cast<HdcShell *>(const_cast<void *>(context)); in ChildReadCallback() local
217 return thisClass->SendToAnother(CMD_KERNEL_ECHO_RAW, (uint8_t *)buf, size); in ChildReadCallback()
|
| D | daemon_tcp.cpp | 73 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()
|
| D | daemon_usb.h | 32 void *thisClass; member
|
| D | jdwp.h | 64 HdcJdwp *thisClass; member
|
| /developtools/hdc/src/host/ |
| D | client.cpp | 115 HdcClient *thisClass = (HdcClient *)handle->data; in DoCtrlServiceWork() local
116 string &strCmd = thisClass->command; in DoCtrlServiceWork()
117 …if (!strncmp(thisClass->command.c_str(), CMDSTR_SERVICE_START.c_str(), CMDSTR_SERVICE_START.size()… in DoCtrlServiceWork()
118 thisClass->StartKillServer(thisClass->command.c_str(), true); in DoCtrlServiceWork()
119 …} else if (!strncmp(thisClass->command.c_str(), CMDSTR_SERVICE_KILL.c_str(), CMDSTR_SERVICE_KILL.s… in DoCtrlServiceWork()
120 thisClass->StartKillServer(thisClass->command.c_str(), false); in DoCtrlServiceWork()
122 …} else if (!strncmp(thisClass->command.c_str(), CMDSTR_GENERATE_KEY.c_str(), CMDSTR_GENERATE_KEY.s… in DoCtrlServiceWork()
235 HdcClient *thisClass = (HdcClient *)handle->data; in CommandWorker() local
236 if (++thisClass->debugRetryCount > maxWaitRetry) { in CommandWorker()
238 uv_stop(thisClass->loopMain); in CommandWorker()
[all …]
|
| D | host_unity.cpp | 21 opContext.thisClass = this; in HdcHostUnity()
58 HdcHostUnity *thisClass = reinterpret_cast<HdcHostUnity *>(context->thisClass); in OnFileClose() local
60 --thisClass->refCount; in OnFileClose()
81 HdcHostUnity *thisClass = reinterpret_cast<HdcHostUnity *>(context->thisClass); in OnFileIO() local
84 --thisClass->refCount; in OnFileIO()
|
| 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()
|
| D | server_for_client.cpp | 47 HdcServerForClient *thisClass = (HdcServerForClient *)pServTCP->data; in AcceptClient() local
49 uint32_t uid = thisClass->MallocChannel(&hChannel); in AcceptClient()
54 thisClass->FreeChannel(uid); in AcceptClient()
84 thisClass->Send(hChannel->channelId, (uint8_t *)&handShake, sizeof(struct ChannelHandShake)); in AcceptClient()
87 thisClass->Send(hChannel->channelId, reinterpret_cast<uint8_t *>(&handShake), in AcceptClient()
210 HdcServerForClient *thisClass = (HdcServerForClient *)hChannel->clsChannel; in OrderConnecTargetResult() local
211 HdcServer *ptrServer = (HdcServer *)thisClass->clsServer; in OrderConnecTargetResult()
230 thisClass->CommandRemoveSession(hChannel, hChannel->key.c_str()); in OrderConnecTargetResult()
231 thisClass->EchoClient(hChannel, MSG_OK, const_cast<char *>(hdi->version.c_str())); in OrderConnecTargetResult()
234 thisClass->EchoClient(hChannel, MSG_OK, const_cast<char *>(sRet.c_str())); in OrderConnecTargetResult()
[all …]
|
| D | host_usb.cpp | 206 HdcHostUSB *thisClass = (HdcHostUSB *)handle->data; in WatchUsbNodeChange() local
207 HdcServer *ptrConnect = (HdcServer *)thisClass->clsMainBase; in WatchUsbNodeChange()
213 ssize_t cnt = libusb_get_device_list(thisClass->ctxUSB, &devs); in WatchUsbNodeChange()
223 UsbCheckStatus statusCheck = thisClass->mapIgnoreDevice[szTmpKey]; in WatchUsbNodeChange()
228 if (!thisClass->DetectMyNeed(dev, sn)) { in WatchUsbNodeChange()
229 thisClass->ReviewUsbNodeLater(szTmpKey); in WatchUsbNodeChange()
238 HdcHostUSB *thisClass = (HdcHostUSB *)arg; in UsbWorkThread() local
240 while (thisClass->modRunning) { in UsbWorkThread()
244 libusb_handle_events_timeout(thisClass->ctxUSB, &zerotime); in UsbWorkThread()
|
| D | host_unity.h | 36 HdcHostUnity *thisClass; member
|
| /developtools/hdc/src/test/jdwp/ |
| 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()
236 thisClass->SendToStream(reinterpret_cast<uv_stream_t *>(&ctxJdwp->pipe), in ConnectJdwp()
240 uv_read_start(reinterpret_cast<uv_stream_t *>(&ctxJdwp->pipe), thisClass->alloc_buffer, in ConnectJdwp()
251 ctx->thisClass = this; in MallocContext()
|
| D | HdcJdwpSimulator.h | 34 HdcJdwpSimulator *thisClass; member
|