Home
last modified time | relevance | path

Searched refs:loopMain (Results 1 – 22 of 22) sorted by relevance

/developtools/hdc/src/test/jdwp/
Dmain.cpp22 static uv_loop_t loopMain; variable
101 uv_stop(&loopMain); in FreeInstance()
102 TryCloseLoop(&loopMain, "Hdcjdwp test exit"); in FreeInstance()
115 uv_loop_init(&loopMain); in main()
122 clsHdcJdwpSimulator = new HdcJdwpSimulator(&loopMain, "com.example.myapplication"); in main()
127 uv_run(&loopMain, UV_RUN_DEFAULT); in main()
/developtools/hdc/src/test/
Dut_runtime.cpp21 uv_loop_init(&loopMain); in Runtime()
41 Base::TryCloseLoop(&loopMain, "Runtime childUV"); in ~Runtime()
42 uv_loop_close(&loopMain); in ~Runtime()
77 uv_idle_init(&server.loopMain, idt); in StartServer()
105 uv_idle_init(&daemon.loopMain, idt); in StartDaemon()
180 Base::StartWorkThread(&loopMain, StartServer, funcServerFinish, this); in Initial()
181 Base::StartWorkThread(&loopMain, StartDaemon, funcDaemonFinish, this); in Initial()
182 Base::TimerUvTask(&loopMain, this, DoCheck, sleepTime); in Initial()
225 uv_run(&loopMain, UV_RUN_DEFAULT); in WorkerPendding()
Dut_command.cpp30 uv_loop_t loopMain; in TestRunClient() local
31 uv_loop_init(&loopMain); in TestRunClient()
32 HdcClient client(false, debugServerPort, &loopMain); in TestRunClient()
35 uv_loop_close(&loopMain); in TestRunClient()
Dut_runtime.h40 return &loopMain; in GetRuntimeLoop()
58 uv_loop_t loopMain; variable
/developtools/hdc/test/unittest/common/
DHdcJdwpTest.cpp30 uv_loop_t loopMain; in InstanceHdcJdwp() local
31 uv_loop_init(&loopMain); in InstanceHdcJdwp()
33 return std::make_unique<HdcJdwp>(&loopMain); in InstanceHdcJdwp()
Dhost_uart_test.cpp157 uv_run(&mockServer.loopMain, UV_RUN_NOWAIT);
213 EXPECT_CALL(mockInterface, StartWorkThread(&mockServer.loopMain, mockServer.SessionWorkThread,
227 EXPECT_CALL(mockInterface, StartWorkThread(&mockServer.loopMain, mockServer.SessionWorkThread,
Ddaemon_uart_test.cpp165 EXPECT_NE(uv_run(&mockDaemon.loopMain, UV_RUN_NOWAIT), 0);
170 EXPECT_NE(uv_run(&mockDaemon.loopMain, UV_RUN_NOWAIT), 0);
/developtools/hdc/src/common/
Dchannel.cpp21 loopMain = loopMainIn; in HdcChannelBase()
24 uv_async_init(loopMain, &asyncMainLoop, MainAsyncCallback); in HdcChannelBase()
106 uv_run(loopMain, UV_RUN_DEFAULT); in WorkerPendding()
107 uv_loop_close(loopMain); in WorkerPendding()
216 if (uv_is_closing((uv_handle_t *)thisClass->loopMain)) { in MainAsyncCallback()
224 Base::IdleUvTask(thisClass->loopMain, param, AsyncMainLoopTask); in MainAsyncCallback()
376 uv_tcp_init(loopMain, &hChannel->hWorkTCP); in MallocChannel()
401 uv_stop(thisClass->loopMain); in FreeChannelFinally()
432 Base::IdleUvTask(loopMain, hChannel, FreeChannelFinally); in FreeChannelContinue()
454 Base::TimerUvTask(thisClass->loopMain, hChannel, callbackCheckFreeChannelContinue); in FreeChannelOpeate()
[all …]
Dsession.cpp43 uv_loop_init(&loopMain); in HdcSessionBase()
46 uv_async_init(&loopMain, &asyncMainLoop, MainAsyncCallback); in HdcSessionBase()
66 uv_loop_close(&loopMain); in ~HdcSessionBase()
190 uv_stop(&thisClass->loopMain); in ReMainLoopForInstanceClear()
192 Base::IdleUvTask(&loopMain, this, clearSessionsForFinish); in ReMainLoopForInstanceClear()
193 uv_run(&loopMain, UV_RUN_DEFAULT); in ReMainLoopForInstanceClear()
288 uv_stop(&thisClass->loopMain); in AsyncMainLoopTask()
309 Base::IdleUvTask(&thisClass->loopMain, param, AsyncMainLoopTask); in MainAsyncCallback()
348 uv_run(&loopMain, UV_RUN_DEFAULT); in WorkerPendding()
357 uv_tcp_init(&loopMain, &hSession->hWorkTCP); in MallocSessionByConnectType()
[all …]
Dchannel.h61 uv_loop_t *loopMain; variable
Dsession.h126 uv_loop_t loopMain; variable
/developtools/hdc/src/host/
Dclient.cpp46 Base::TryCloseLoop(loopMain, "ExecuteCommand finish"); in ~HdcClient()
137 uv_check_init(loopMain, &ctrlServerWork); in CtrlServiceWork()
139 uv_run(loopMain, UV_RUN_NOWAIT); in CtrlServiceWork()
332 uv_timer_init(loopMain, &waitTimeDoCmd); in ExecuteCommand()
387 uv_stop(thisClass->loopMain); in CommandWorker()
400 uv_stop(thisClass->loopMain); in CommandWorker()
485 if (uv_tty_init(loopMain, &hChannel->stdoutTty, STDOUT_FILENO, 0) in BindLocalStd()
486 || uv_tty_init(loopMain, &hChannel->stdinTty, STDIN_FILENO, 1)) { in BindLocalStd()
708 hTaskInfo->runLoop = loopMain; in GetRemoteTaskInfo()
Dmain.cpp201 uv_loop_t loopMain; in RunClientMode() local
202 uv_loop_init(&loopMain); in RunClientMode()
203 HdcClient client(false, serverListenString, &loopMain, commands == CMDSTR_CHECK_SERVER); in RunClientMode()
Dhost_usb.cpp27 uv_timer_init(&pServer->loopMain, &devListWatcher); in HdcHostUSB()
168 uv_timer_init(&hdcServer->loopMain, waitTimeDoCmd); in DetectMyNeed()
204 Base::DelayDo(&hdcServer->loopMain, delayRemoveFromList, 0, nodeKey, nullptr, in ReviewUsbNodeLater()
710 …Base::StartWorkThread(&pServer->loopMain, pServer->SessionWorkThread, Base::FinishWorkThread, hSes… in ConnectDetectDaemon()
Dserver.cpp43 Base::TryCloseLoop(&loopMain, "HdcServer::~HdcServer"); in ClearInstanceResource()
88 clsServerForClient = new HdcServerForClient(true, listenString, this, &loopMain); in Initial()
422 Base::DelayDoSimple(&loopMain, waitDaemonReconnect, funcDelayUsbNotify); in NotifyInstanceSessionFree()
788 uv_timer_init(&loopMain, waitTimeDoCmd); in CreatConnectUart()
844 uv_timer_init(&loopMain, waitTimeDoCmd); in CreateConnect()
Dserver_for_client.cpp101 uv_tcp_init(loopMain, &tcpListen); in SetTCPListen()
326 Base::TimerUvTask(loopMain, hChannel, OrderConnecTargetResult, 10); in NewConnectTry()
502 uv_stop(loopMain); in DoCommandLocal()
722 Base::DoNextLoop(loopMain, hChannel, [](const uint8_t flag, string &msg, const void *data) { in BindChannelToSession()
Dhost_tcp.cpp111 …Base::StartWorkThread(&ptrConnect->loopMain, ptrConnect->SessionWorkThread, Base::FinishWorkThread… in Connect()
Dhost_uart.cpp30 uv_timer_init(&server.loopMain, &devUartWatcher); in HdcHostUART()
492 externInterface.StartWorkThread(&server.loopMain, server.SessionWorkThread, in EnumSerialPort()
590 uv_timer_init(&server.loopMain, waitTimeDoCmd); in EnumSerialPort()
/developtools/hdc/src/daemon/
Ddaemon_usb.cpp121 uv_timer_init(&daemon->loopMain, &checkEP); in Initial()
364 …Base::StartWorkThread(&daemon->loopMain, daemon->SessionWorkThread, Base::FinishWorkThread, hChild… in PrepareNewSession()
378 Base::TimerUvTask(&daemon->loopMain, hChildSession, funcNewSessionUp); in PrepareNewSession()
593 ret = uv_fs_read(&daemon->loopMain, req, hUSB->bulkOut, &iov, 1, -1, OnUSBRead); in LoopUSBRead()
615 thisClass->CloseBulkEp(true, thisClass->usbHandle.bulkIn, &daemon->loopMain); in WatchEPTimer()
620 thisClass->CloseBulkEp(false, thisClass->usbHandle.bulkOut, &daemon->loopMain); in WatchEPTimer()
Ddaemon_tcp.cpp111 uv_udp_init(&ptrConnect->loopMain, &servUDP); in SetUDPListen()
127 uv_tcp_init(&ptrConnect->loopMain, &servTCP); in SetTCPListen()
Ddaemon_uart.cpp63 ret = uv_timer_init(&daemon.loopMain, &checkSerialPort); in Initial()
217 externInterface.StartWorkThread(&daemon.loopMain, daemon.SessionWorkThread, in PrepareNewSession()
233 externInterface.TimerUvTask(&daemon.loopMain, hSession, funcNewSessionUp); in PrepareNewSession()
Ddaemon.cpp48 Base::TryCloseLoop(&loopMain, "HdcDaemon::~HdcDaemon"); in ClearInstanceResource()
133 clsJdwp = new(std::nothrow) HdcJdwp(&loopMain); in InitMod()