Home
last modified time | relevance | path

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

1234

/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/smartperf_host/ide/test/trace/database/logic-worker/
DProcedureLogicWorkerJsCpuProfiler.test.ts35 expect(procedureLogicWorkerJsCpuProfiler.handle(data)).toBeUndefined();
49 expect(procedureLogicWorkerJsCpuProfiler.handle(data)).toBeUndefined();
62 expect(procedureLogicWorkerJsCpuProfiler.handle(data)).toBeUndefined();
81 expect(procedureLogicWorkerJsCpuProfiler.handle(data)).toBeUndefined();
100 expect(procedureLogicWorkerJsCpuProfiler.handle(data)).toBeUndefined();
115 expect(procedureLogicWorkerJsCpuProfiler.handle(data)).toBeUndefined();
DProcedureLogicWorkerSchedulingAnalysis.test.ts47 expect(procedureLogicWorkerSchedulingAnalysis.handle(data)).toBeUndefined();
225 expect(procedureLogicWorkerSchedulingAnalysis.handle(data)).toBeUndefined();
242 expect(procedureLogicWorkerSchedulingAnalysis.handle(data)).toBeUndefined();
259 expect(procedureLogicWorkerSchedulingAnalysis.handle(data)).toBeUndefined();
276 expect(procedureLogicWorkerSchedulingAnalysis.handle(data)).toBeUndefined();
293 expect(procedureLogicWorkerSchedulingAnalysis.handle(data)).toBeUndefined();
310 expect(procedureLogicWorkerSchedulingAnalysis.handle(data)).toBeUndefined();
327 expect(procedureLogicWorkerSchedulingAnalysis.handle(data)).toBeUndefined();
344 expect(procedureLogicWorkerSchedulingAnalysis.handle(data)).toBeUndefined();
361 expect(procedureLogicWorkerSchedulingAnalysis.handle(data)).toBeUndefined();
[all …]
DProcedureLogicWorkerFileSystem.test.ts46 expect(procedureLogicWorkerFileSystem.handle(data)).toBeUndefined();
57 expect(procedureLogicWorkerFileSystem.handle(data)).toBeUndefined();
67 expect(procedureLogicWorkerF.handle(data)).toBeUndefined();
83 expect(procedureLogicWorkerF.handle(data)).toBeUndefined();
94 expect(procedureLogicWorkerFileSystem.handle(data)).toBeUndefined();
105 expect(procedureLogicWorkerFileSystem.handle(data)).toBeUndefined();
193 procedureLogicWorkerF.handle(data);
429 expect(procedureLogicWorkerF.handle(data)).toBeUndefined();
439 expect(procedureLogicWorkerF.handle(data)).toBeUndefined();
449 expect(procedureLogicWorkerF.handle(data)).toBeUndefined();
[all …]
DProcedureLogicWorkerNativeNemory.test.ts193 expect(procedureLogicWorkerNativeMemory.handle(data)).toBeUndefined();
208 expect(procedureLogicWorkerNativeMemory.handle(data)).toBeUndefined();
223 expect(procedureLogicWorkerNativeMemory.handle(data)).toBeUndefined();
239 expect(procedureLogicWorkerNativeMemory.handle(data)).toBeUndefined();
255 expect(procedureLogicWorkerNativeMemory.handle(data)).toBeUndefined();
387 expect(procedureLogicWorkerNativeMemory.handle(data)).toBeUndefined();
402 expect(procedureLogicWorkerNativeMemory.handle(data)).toBeUndefined();
417 expect(procedureLogicWorkerNativeMemory.handle(data)).toBeUndefined();
432 expect(procedureLogicWorkerNativeMemory.handle(data)).toBeUndefined();
DProcedureLogicWorkerSPT.test.ts57 expect(procedureLogicWorkerSPT.handle(data)).toBeUndefined();
72 expect(procedureLogicWorkerSPT.handle(data)).toBeUndefined();
87 expect(procedureLogicWorkerSPT.handle(data)).toBeUndefined();
/developtools/hdc/src/common/
Dchannel.cpp175 HChannel hChannel = (HChannel)req->handle->data; in WriteCallback()
179 Base::TryCloseHandle((uv_handle_t *)req->handle); in WriteCallback()
189 void HdcChannelBase::AsyncMainLoopTask(uv_idle_t *handle) in AsyncMainLoopTask() argument
191 AsyncParam *param = (AsyncParam *)handle->data; in AsyncMainLoopTask()
207 uv_close((uv_handle_t *)handle, Base::CloseIdleCallback); in AsyncMainLoopTask()
213 void HdcChannelBase::MainAsyncCallback(uv_async_t *handle) in MainAsyncCallback() argument
215 HdcChannelBase *thisClass = (HdcChannelBase *)handle->data; in MainAsyncCallback()
346 void HdcChannelBase::AllocCallback(uv_handle_t *handle, size_t sizeWanted, uv_buf_t *buf) in AllocCallback() argument
348 HChannel context = (HChannel)handle->data; in AllocCallback()
390 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.h28 virtual void RecvUDPEntry(const sockaddr *addrSrc, uv_udp_t *handle, const uv_buf_t *rcvbuf) in RecvUDPEntry() argument
32 …uv_udp_t *handle, ssize_t nread, const uv_buf_t *rcvbuf, const struct sockaddr *addr, unsigned fla…
34 static void AllocStreamUDP(uv_handle_t *handle, size_t sizeWanted, uv_buf_t *buf);
Dsession.cpp109 auto taskClassDeleteRetry = [](uv_timer_t *handle) -> void { in BeginRemoveTask() argument
111 HTaskInfo hTask = (HTaskInfo)handle->data; in BeginRemoveTask()
128 Base::TryCloseHandle((uv_handle_t *)handle, Base::CloseTimerCallback); in BeginRemoveTask()
183 auto clearSessionsForFinish = [](uv_idle_t *handle) -> void { in ReMainLoopForInstanceClear() argument
184 HdcSessionBase *thisClass = (HdcSessionBase *)handle->data; in ReMainLoopForInstanceClear()
189 uv_close((uv_handle_t *)handle, Base::CloseIdleCallback); in ReMainLoopForInstanceClear()
278 void HdcSessionBase::AsyncMainLoopTask(uv_idle_t *handle) in AsyncMainLoopTask() argument
280 AsyncParam *param = (AsyncParam *)handle->data; in AsyncMainLoopTask()
298 Base::TryCloseHandle((uv_handle_t *)handle, Base::CloseIdleCallback); in AsyncMainLoopTask()
301 void HdcSessionBase::MainAsyncCallback(uv_async_t *handle) in MainAsyncCallback() argument
[all …]
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
Dbase.h38 void AllocBufferCallback(uv_handle_t *handle, size_t sizeSuggested, uv_buf_t *buf);
51 void TryCloseHandle(const uv_handle_t *handle);
52 void TryCloseHandle(const uv_handle_t *handle, uv_close_cb closeCallBack);
53 void TryCloseHandle(const uv_handle_t *handle, bool alwaysCallback, uv_close_cb closeCallBack);
59 void CloseIdleCallback(uv_handle_t *handle);
60 void CloseTimerCallback(uv_handle_t *handle);
/developtools/profiler/device/plugins/native_hook/test/
Dhook_test.cpp135 void* handle = nullptr; in ThreadFuncCppHook() local
143 handle = dlopen(SO_PATH, RTLD_LAZY); in ThreadFuncCppHook()
144 if (handle == nullptr) { in ThreadFuncCppHook()
148 mallocFunc = (DepthMallocSo)dlsym(handle, "DepthMallocSo"); in ThreadFuncCppHook()
149 freeFunc = (DepthFreeSo)dlsym(handle, "DepthFreeSo"); in ThreadFuncCppHook()
164 if (handle != nullptr) { in ThreadFuncCppHook()
165 dlclose(handle); in ThreadFuncCppHook()
Dstatistics_test.cpp105 void* handle = nullptr; in DlopenAndCloseSo() local
111 handle = dlopen(filePath.data(), RTLD_LAZY); in DlopenAndCloseSo()
112 if (handle == nullptr) { in DlopenAndCloseSo()
116 mallocFunc = (DepthMallocSo)dlsym(handle, "DepthMallocSo"); in DlopenAndCloseSo()
117 freeFunc = (DepthFreeSo)dlsym(handle, "DepthFreeSo"); in DlopenAndCloseSo()
128 if (handle != nullptr) { in DlopenAndCloseSo()
130 dlclose(handle); in DlopenAndCloseSo()
/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_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()
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);
Djdwp.cpp47 auto funcListenPipeClose = [](uv_handle_t *handle) -> void { in Stop() argument
48 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 …]
/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/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")…
318 void* handle = dlopen(path.c_str(), RTLD_LAZY); variable
319 EXPECT_NE(handle, nullptr);
320 …PluginModuleStruct* plugin = reinterpret_cast<PluginModuleStruct*>(dlsym(handle, "g_pluginModule")…
/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/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(AdaptLongPath(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()

1234