Home
last modified time | relevance | path

Searched refs:handle (Results 1 – 25 of 72) sorted by relevance

123

/developtools/hdc/src/test/jdwp/
Dmain.cpp35 static void TryCloseHandle(const uv_handle_t *handle, bool alwaysCallback, in TryCloseHandle() argument
39 if (handle->loop && !uv_is_closing(handle)) { in TryCloseHandle()
40 uv_close((uv_handle_t *)handle, closeCallBack); in TryCloseHandle()
44 closeCallBack((uv_handle_t *)handle); in TryCloseHandle()
48 static void TryCloseHandle(const uv_handle_t *handle, uv_close_cb closeCallBack) in TryCloseHandle() argument
50 TryCloseHandle(handle, false, closeCallBack); in TryCloseHandle()
53 static void TryCloseHandle(const uv_handle_t *handle) in TryCloseHandle() argument
55 TryCloseHandle(handle, nullptr); in TryCloseHandle()
73 auto clearLoopTask = [](uv_handle_t *handle, void *arg) -> void { in TryCloseLoop() argument
74 TryCloseHandle(handle); in TryCloseLoop()
/developtools/hdc/src/common/
Dchannel.cpp174 HChannel hChannel = (HChannel)req->handle->data; in WriteCallback()
178 Base::TryCloseHandle((uv_handle_t *)req->handle); in WriteCallback()
188 void HdcChannelBase::AsyncMainLoopTask(uv_idle_t *handle) in AsyncMainLoopTask() argument
190 AsyncParam *param = (AsyncParam *)handle->data; in AsyncMainLoopTask()
206 uv_close((uv_handle_t *)handle, Base::CloseIdleCallback); in AsyncMainLoopTask()
212 void HdcChannelBase::MainAsyncCallback(uv_async_t *handle) in MainAsyncCallback() argument
214 HdcChannelBase *thisClass = (HdcChannelBase *)handle->data; in MainAsyncCallback()
341 void HdcChannelBase::AllocCallback(uv_handle_t *handle, size_t sizeWanted, uv_buf_t *buf) in AllocCallback() argument
343 HChannel context = (HChannel)handle->data; in AllocCallback()
385 void HdcChannelBase::FreeChannelFinally(uv_idle_t *handle) in FreeChannelFinally() argument
[all …]
Dchannel.h25 static void AllocCallback(uv_handle_t *handle, size_t sizeWanted, uv_buf_t *buf);
68 static void MainAsyncCallback(uv_async_t *handle);
70 static void AsyncMainLoopTask(uv_idle_t *handle);
71 static void FreeChannelOpeate(uv_timer_t *handle);
72 static void FreeChannelFinally(uv_idle_t *handle);
Dtcp.h27 virtual void RecvUDPEntry(const sockaddr *addrSrc, uv_udp_t *handle, const uv_buf_t *rcvbuf) in RecvUDPEntry() argument
31 …uv_udp_t *handle, ssize_t nread, const uv_buf_t *rcvbuf, const struct sockaddr *addr, unsigned fla…
33 static void AllocStreamUDP(uv_handle_t *handle, size_t sizeWanted, uv_buf_t *buf);
Dtcp.cpp35 void HdcTCPBase::RecvUDP(uv_udp_t *handle, ssize_t nread, const uv_buf_t *rcvbuf, const struct sock… in RecvUDP() argument
39 HdcTCPBase *thisClass = (HdcTCPBase *)handle->data; in RecvUDP()
48 thisClass->RecvUDPEntry(addr, handle, rcvbuf); in RecvUDP()
54 void HdcTCPBase::AllocStreamUDP(uv_handle_t *handle, size_t sizeWanted, uv_buf_t *buf) in AllocStreamUDP() argument
Dsession.cpp107 auto taskClassDeleteRetry = [](uv_timer_t *handle) -> void { in BeginRemoveTask() argument
108 HTaskInfo hTask = (HTaskInfo)handle->data; in BeginRemoveTask()
125 Base::TryCloseHandle((uv_handle_t *)handle, Base::CloseTimerCallback); in BeginRemoveTask()
178 auto clearSessionsForFinish = [](uv_idle_t *handle) -> void { in ReMainLoopForInstanceClear() argument
179 HdcSessionBase *thisClass = (HdcSessionBase *)handle->data; in ReMainLoopForInstanceClear()
184 uv_close((uv_handle_t *)handle, Base::CloseIdleCallback); in ReMainLoopForInstanceClear()
273 void HdcSessionBase::AsyncMainLoopTask(uv_idle_t *handle) in AsyncMainLoopTask() argument
275 AsyncParam *param = (AsyncParam *)handle->data; in AsyncMainLoopTask()
293 Base::TryCloseHandle((uv_handle_t *)handle, Base::CloseIdleCallback); in AsyncMainLoopTask()
296 void HdcSessionBase::MainAsyncCallback(uv_async_t *handle) in MainAsyncCallback() argument
[all …]
Dbase.h37 void AllocBufferCallback(uv_handle_t *handle, size_t sizeSuggested, uv_buf_t *buf);
50 void TryCloseHandle(const uv_handle_t *handle);
51 void TryCloseHandle(const uv_handle_t *handle, uv_close_cb closeCallBack);
52 void TryCloseHandle(const uv_handle_t *handle, bool alwaysCallback, uv_close_cb closeCallBack);
58 void CloseIdleCallback(uv_handle_t *handle);
59 void CloseTimerCallback(uv_handle_t *handle);
Dbase.cpp301 void AllocBufferCallback(uv_handle_t *handle, size_t sizeSuggested, uv_buf_t *buf) in AllocBufferCallback() argument
343 … auto clearLoopTask = [](uv_handle_t *handle, void *arg) -> void { TryCloseHandle(handle); }; in TryCloseLoop() argument
363 void TryCloseHandle(const uv_handle_t *handle) in TryCloseHandle() argument
365 TryCloseHandle(handle, nullptr); in TryCloseHandle()
368 void TryCloseHandle(const uv_handle_t *handle, uv_close_cb closeCallBack) in TryCloseHandle() argument
370 TryCloseHandle(handle, false, closeCallBack); in TryCloseHandle()
373 void TryCloseHandle(const uv_handle_t *handle, bool alwaysCallback, uv_close_cb closeCallBack) in TryCloseHandle() argument
376 if (handle->loop && !uv_is_closing(handle)) { in TryCloseHandle()
377 uv_close((uv_handle_t *)handle, closeCallBack); in TryCloseHandle()
381 closeCallBack((uv_handle_t *)handle); in TryCloseHandle()
[all …]
/developtools/profiler/device/plugins/native_hook/test/
Dhook_test.cpp135 void* handle = nullptr; in thread_func_cpp_hook() local
143 handle = dlopen(SO_PATH, RTLD_LAZY); in thread_func_cpp_hook()
144 if (handle == nullptr) { in thread_func_cpp_hook()
148 mallocFunc = (DepthMallocSo)dlsym(handle, "DepthMallocSo"); in thread_func_cpp_hook()
149 freeFunc = (DepthFreeSo)dlsym(handle, "DepthFreeSo"); in thread_func_cpp_hook()
164 if (handle != nullptr) { in thread_func_cpp_hook()
165 dlclose(handle); in thread_func_cpp_hook()
/developtools/profiler/device/plugins/diskio_plugin/src/
Dtest_main.cpp71 void* handle = dlopen("./libdiskiodataplugin.z.so", RTLD_LAZY); in main() local
72 if (handle == nullptr) { in main()
76 std::cout << "test:handle = " << handle << std::endl; in main()
77 diskioPlugin = (PluginModuleStruct*)dlsym(handle, "g_pluginModule"); in main()
115 dlclose(handle); in main()
/developtools/hdc/src/daemon/
Ddaemon_uart.h36 static inline void UvWatchTimer(uv_timer_t *handle) in UvWatchTimer() argument
38 if (handle != nullptr) { in UvWatchTimer()
39 HdcDaemonUART *thisClass = static_cast<HdcDaemonUART *>(handle->data); in UvWatchTimer()
Ddaemon_tcp.h28 void RecvUDPEntry(const sockaddr *addrSrc, uv_udp_t *handle, const uv_buf_t *rcvbuf) override;
35 void TransmitConfig(const sockaddr *addrSrc, uv_udp_t *handle);
Ddaemon_forward.cpp31 void HdcDaemonForward::SetupJdwpPointCallBack(uv_idle_t *handle) in SetupJdwpPointCallBack() argument
33 HCtxForward ctxPoint = (HCtxForward)handle->data; in SetupJdwpPointCallBack()
36 Base::TryCloseHandle((const uv_handle_t *)handle, Base::CloseIdleCallback); in SetupJdwpPointCallBack()
Djdwp.cpp49 auto funcListenPipeClose = [](uv_handle_t *handle) -> void { in Stop() argument
50 HdcJdwp *thisClass = (HdcJdwp *)handle->data; in Stop()
85 auto funcReqClose = [](uv_idle_t *handle) -> void { in FreeContext() argument
86 HCtxJdwp ctx = (HCtxJdwp)handle->data; in FreeContext()
88 Base::TryCloseHandle((uv_handle_t *)handle, Base::CloseIdleCallback); in FreeContext()
201 auto funAlloc = [](uv_handle_t *handle, size_t sizeSuggested, uv_buf_t *buf) -> void { in AcceptClient() argument
202 HCtxJdwp ctxJdwp = (HCtxJdwp)handle->data; in AcceptClient()
241 int HdcJdwp::UvPipeBind(uv_pipe_t* handle, const char* name, size_t size) in UvPipeBind() argument
245 if (handle->io_watcher.fd >= 0) { in UvPipeBind()
246 WRITE_LOG(LOG_FATAL, "socket already bound %d", handle->io_watcher.fd); in UvPipeBind()
[all …]
Ddaemon_tcp.cpp54 void HdcDaemonTCP::TransmitConfig(const sockaddr *addrSrc, uv_udp_t *handle) in TransmitConfig() argument
66 uv_udp_send(req, handle, &sndbuf, 1, &addrSrcIPPort, SendUDPFinish); in TransmitConfig()
100 void HdcDaemonTCP::RecvUDPEntry(const sockaddr *addrSrc, uv_udp_t *handle, const uv_buf_t *rcvbuf) in RecvUDPEntry() argument
102 TransmitConfig(addrSrc, handle); in RecvUDPEntry()
/developtools/profiler/device/plugins/cpu_plugin/src/
Dtest_main.cpp87 void* handle = dlopen(SO_PATH.c_str(), RTLD_LAZY); in main() local
88 if (handle == nullptr) { in main()
96 PluginModuleStruct* cpuPlugin = (PluginModuleStruct*)dlsym(handle, "g_pluginModule"); in main()
98 dlclose(handle); in main()
128 dlclose(handle); in main()
/developtools/hdc/src/host/
Dhost_tcp.h30 static void BroadcastTimer(uv_idle_t *handle);
33 void RecvUDPEntry(const sockaddr *addrSrc, uv_udp_t *handle, const uv_buf_t *rcvbuf) override;
Dclient.h36 static void DoCtrlServiceWork(uv_check_t *handle);
38 static void AllocStdbuf(uv_handle_t *handle, size_t sizeWanted, uv_buf_t *buf);
40 static void CommandWorker(uv_timer_t *handle);
/developtools/profiler/host/smartperf/ide/test/trace/database/logic-worker/
DProcedureLogicWorkerSPT.test.ts51 expect(procedureLogicWorkerSPT.handle(data)).toBeUndefined();
64 expect(procedureLogicWorkerSPT.handle(data)).toBeUndefined();
77 expect(procedureLogicWorkerSPT.handle(data)).toBeUndefined();
DProcedureLogicWorkerFileSystem.test.ts41 expect(procedureLogicWorkerFileSystem.handle(data)).toBeUndefined()
52 expect(procedureLogicWorkerFileSystem.handle(data)).toBeUndefined()
63 expect(procedureLogicWorkerFileSystem.handle(data)).toBeUndefined()
76 expect(procedureLogicWorkerFileSystem.handle(data)).toBeUndefined()
87 expect(procedureLogicWorkerFileSystem.handle(data)).toBeUndefined()
98 expect(procedureLogicWorkerFileSystem.handle(data)).toBeUndefined()
DProcedureLogicWorkerPerf.test.ts37 expect(procedureLogicWorkerPerf.handle(data)).toBeUndefined();
51 expect(procedureLogicWorkerPerf.handle(data)).toBeUndefined();
65 expect(procedureLogicWorkerPerf.handle(data)).toBeUndefined();
79 expect(procedureLogicWorkerPerf.handle(data)).toBeUndefined();
94 expect(procedureLogicWorkerPerf.handle(data)).toBeUndefined();
108 expect(procedureLogicWorkerPerf.handle(data)).toBeUndefined();
123 expect(procedureLogicWorkerPerf.handle(data)).toBeUndefined();
DProcedureLogicWorkerCpuState.test.ts45 expect(procedureLogicWorkerCpuState.handle(data)).toBeUndefined();
68 expect(procedureLogicWorkerCpuState.handle(data)).toBeUndefined();
/developtools/hdc/src/test/
Dut_mod.cpp178 uv_close((uv_handle_t *)client, [](uv_handle_t *handle) { free(handle); }); in UtForwardWaiter() argument
188 [](uv_handle_t *handle, size_t suggested_size, uv_buf_t *buf) { in UtForwardWaiter() argument
194 uv_close((uv_handle_t *)client, [](uv_handle_t *handle) { free(handle); }); in UtForwardWaiter() argument
216 …Base::SendToStream((uv_stream_t *)req->handle, (uint8_t *)MESSAGE_SUCCESS.c_str(), MESSAGE_SUCCESS… in UtForwardConnect()
217 … Base::DelayDoSimple(req->handle->loop, 3000, [=](const uint8_t flag, string &msg, const void *p) { in UtForwardConnect()
/developtools/global_resource_tool/src/
Dfile_entry.cpp67 HANDLE handle = FindFirstFile(AdapateLongPath(temp).c_str(), &findData); in GetChilds() local
68 if (handle == INVALID_HANDLE_VALUE) { in GetChilds()
82 } while (FindNextFile(handle, &findData)); in GetChilds()
83 FindClose(handle); in GetChilds()
85 DIR *handle = opendir(filePath.c_str()); in GetChilds() local
87 while ((entry = readdir(handle)) != nullptr) { in GetChilds()
98 closedir(handle); in GetChilds()
/developtools/profiler/device/plugins/network_plugin/test/unittest/
Dnetwork_plugin_test.cpp255 void* handle = dlopen(path.c_str(), RTLD_LAZY); variable
256 EXPECT_NE(handle, nullptr);
257 …PluginModuleStruct* plugin = reinterpret_cast<PluginModuleStruct*>(dlsym(handle, "g_pluginModule")…
284 void* handle = dlopen(path.c_str(), RTLD_LAZY); variable
285 EXPECT_NE(handle, nullptr);
286 …PluginModuleStruct* plugin = reinterpret_cast<PluginModuleStruct*>(dlsym(handle, "g_pluginModule")…

123