/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 | 61 HdcFileDescriptor *thisClass = ctxIO->thisClass; in FileIOOnThread() local 72 if (thisClass->workContinue == false) { in FileIOOnThread() 73 WRITE_LOG(LOG_INFO, "FileIOOnThread fdIO:%d workContinue false", thisClass->fdIO); in FileIOOnThread() 79 nBytes = write(thisClass->fdIO, buf, bufSize); in FileIOOnThread() 81 WRITE_LOG(LOG_WARN, "FileIOOnThread fdIO:%d write interrupt", thisClass->fdIO); in FileIOOnThread() 91 FD_SET(thisClass->fdIO, &rset); in FileIOOnThread() 92 int rc = select(thisClass->fdIO + 1, &rset, nullptr, nullptr, &timeout); in FileIOOnThread() 94 … WRITE_LOG(LOG_FATAL, "FileIOOnThread select fdIO:%d error:%d", thisClass->fdIO, errno); in FileIOOnThread() 99 nBytes = read(thisClass->fdIO, buf, bufSize); in FileIOOnThread() 101 WRITE_LOG(LOG_WARN, "FileIOOnThread fdIO:%d read interrupt", thisClass->fdIO); in FileIOOnThread() [all …]
|
D | async_cmd.cpp | 79 AsyncCmd *thisClass = static_cast<AsyncCmd *>(const_cast<void *>(context)); in FinishShellProc() local 80 …WRITE_LOG(LOG_DEBUG, "FinishShellProc finish pipeRead fd:%d pid:%d", thisClass->fd, thisClass->pid… in FinishShellProc() 81 thisClass->resultCallback(true, result, thisClass->cmdResult + exitMsg); in FinishShellProc() 82 --thisClass->refCount; in FinishShellProc() 88 AsyncCmd *thisClass = static_cast<AsyncCmd *>(const_cast<void *>(context)); in ChildReadCallback() local 89 if (thisClass->options & OPTION_COMMAND_ONETIME) { in ChildReadCallback() 91 thisClass->cmdResult += s; in ChildReadCallback() 95 return thisClass->resultCallback(false, 0, s); in ChildReadCallback()
|
D | channel.cpp | 118 HdcChannelBase *thisClass = (HdcChannelBase *)hChannel->clsChannel; in ReadStream() local 147 childRet = thisClass->ReadChannel(hChannel, reinterpret_cast<uint8_t *>(hChannel->ioBuf) + in ReadStream() 168 thisClass->FreeChannel(hChannel->channelId); in ReadStream() 177 HdcChannelBase *thisClass = (HdcChannelBase *)hChannel->clsChannel; in WriteCallback() local 181 thisClass->FreeChannel(hChannel->channelId); in WriteCallback() 192 HdcChannelBase *thisClass = (HdcChannelBase *)param->thisClass; in AsyncMainLoopTask() local 197 thisClass->FreeChannel(param->sid); in AsyncMainLoopTask() 215 HdcChannelBase *thisClass = (HdcChannelBase *)handle->data; in MainAsyncCallback() local 216 if (uv_is_closing((uv_handle_t *)thisClass->loopMain)) { in MainAsyncCallback() 220 list<void *> &lst = thisClass->lstMainThreadOP; in MainAsyncCallback() [all …]
|
D | transfer.cpp | 52 context->thisClass = this; in ResetCtx() 128 HdcTransferBase *thisClass = (HdcTransferBase *)context->thisClass; in OnFileClose() local 132 thisClass->WhenTransferFinish(context); in OnFileClose() 134 --thisClass->refCount; in OnFileClose() 207 HdcTransferBase *thisClass = (HdcTransferBase *)context->thisClass; in OnFileIO() local 231 … if (!thisClass->SendIOPayload(context, context->indexIO - req->result, bufIO, req->result)) { in OnFileIO() 236 thisClass->SimpleFileIO(context, context->indexIO, nullptr, in OnFileIO() 237 Base::GetMaxBufSize() * thisClass->maxTransferBufFactor); in OnFileIO() 251 thisClass->SetFileTime(context); in OnFileIO() 260 ++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() 185 ctx->thisClass->FreeContextCallBack(ctx); in FreeContext() [all …]
|
D | session.cpp | 112 HdcSessionBase *thisClass = (HdcSessionBase *)hTask->ownerSessionClass; in BeginRemoveTask() local 120 if (!thisClass->TryRemoveTask(hTask)) { in BeginRemoveTask() 184 HdcSessionBase *thisClass = (HdcSessionBase *)handle->data; in ReMainLoopForInstanceClear() local 185 if (thisClass->sessionRef > 0) { in ReMainLoopForInstanceClear() 190 uv_stop(&thisClass->loopMain); in ReMainLoopForInstanceClear() 281 HdcSessionBase *thisClass = (HdcSessionBase *)param->thisClass; in AsyncMainLoopTask() local 285 thisClass->FreeSession(param->sid); in AsyncMainLoopTask() 288 uv_stop(&thisClass->loopMain); in AsyncMainLoopTask() 303 HdcSessionBase *thisClass = (HdcSessionBase *)handle->data; in MainAsyncCallback() local 305 list<void *> &lst = thisClass->lstMainThreadOP; in MainAsyncCallback() [all …]
|
D | file_descriptor.h | 25 HdcFileDescriptor *thisClass; member
|
/developtools/hdc/src/daemon/ |
D | jdwp.cpp | 48 HdcJdwp *thisClass = (HdcJdwp *)handle->data; in Stop() local 49 --thisClass->refCount; in Stop() 67 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 | 111 ctxRecv.thisClass = this; in Initial() 262 HdcDaemonUSB *thisClass; in CloseBulkEp() member 273 ctx->thisClass = this; in CloseBulkEp() 280 ctx->thisClass->usbHandle.bulkIn = 0; in CloseBulkEp() 282 ctx->thisClass->usbHandle.bulkOut = 0; in CloseBulkEp() 514 auto thisClass = reinterpret_cast<HdcDaemonUSB *>(ctxIo->thisClass); in OnUSBRead() local 520 if (bytesIOBytes > hUSB->wMaxPacketSizeSend && bytesIOBytes != thisClass->saveNextReadSize) { in OnUSBRead() 521 …WRITE_LOG(LOG_WARN, "Not full packet, wanted:%d really:%d", thisClass->saveNextReadSize, bytesIOBy… in OnUSBRead() 523 while (thisClass->isAlive) { in OnUSBRead() 545 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 | 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 | shell.cpp | 251 HdcShell *thisClass = reinterpret_cast<HdcShell *>(const_cast<void *>(context)); in FinishShellProc() local 252 thisClass->TaskFinish(); in FinishShellProc() 253 --thisClass->refCount; in FinishShellProc() 259 HdcShell *thisClass = reinterpret_cast<HdcShell *>(const_cast<void *>(context)); in ChildReadCallback() local 260 return thisClass->SendToAnother(CMD_KERNEL_ECHO_RAW, (uint8_t *)buf, size); in ChildReadCallback()
|
D | daemon_usb.h | 32 void *thisClass; member
|
D | jdwp.h | 68 HdcJdwp *thisClass; member
|
/developtools/hdc/src/host/ |
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 | 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() 384 HdcClient *thisClass = (HdcClient *)handle->data; in CommandWorker() local 385 if (++thisClass->debugRetryCount > maxWaitRetry) { in CommandWorker() 387 uv_stop(thisClass->loopMain); in CommandWorker() [all …]
|
D | server_for_client.cpp | 50 HdcServerForClient *thisClass = (HdcServerForClient *)pServTCP->data; in AcceptClient() local 52 uint32_t uid = thisClass->MallocChannel(&hChannel); in AcceptClient() 57 thisClass->FreeChannel(uid); in AcceptClient() 87 thisClass->Send(hChannel->channelId, (uint8_t *)&handShake, sizeof(struct ChannelHandShake)); in AcceptClient() 90 thisClass->Send(hChannel->channelId, reinterpret_cast<uint8_t *>(&handShake), in AcceptClient() 254 HdcServerForClient *thisClass = (HdcServerForClient *)hChannel->clsChannel; in OrderConnecTargetResult() local 255 HdcServer *ptrServer = (HdcServer *)thisClass->clsServer; in OrderConnecTargetResult() 274 thisClass->CommandRemoveSession(hChannel, hChannel->key.c_str()); in OrderConnecTargetResult() 275 thisClass->EchoClient(hChannel, MSG_OK, const_cast<char *>(hdi->version.c_str())); in OrderConnecTargetResult() 278 thisClass->EchoClient(hChannel, MSG_OK, const_cast<char *>(sRet.c_str())); in OrderConnecTargetResult() [all …]
|
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 | host_usb.cpp | 210 HdcHostUSB *thisClass = (HdcHostUSB *)handle->data; in WatchUsbNodeChange() local 211 HdcServer *ptrConnect = (HdcServer *)thisClass->clsMainBase; in WatchUsbNodeChange() 217 ssize_t cnt = libusb_get_device_list(thisClass->ctxUSB, &devs); in WatchUsbNodeChange() 227 UsbCheckStatus statusCheck = thisClass->mapIgnoreDevice[szTmpKey]; in WatchUsbNodeChange() 232 if (thisClass->HasValidDevice(dev) && !thisClass->DetectMyNeed(dev, sn)) { in WatchUsbNodeChange() 233 thisClass->ReviewUsbNodeLater(szTmpKey); in WatchUsbNodeChange() 266 HdcHostUSB *thisClass = (HdcHostUSB *)arg; in UsbWorkThread() local 268 while (thisClass->modRunning) { in UsbWorkThread() 272 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() 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()
|
D | HdcJdwpSimulator.h | 34 HdcJdwpSimulator *thisClass; member
|