Home
last modified time | relevance | path

Searched refs:handle (Results 1 – 25 of 86) 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/hdc/hdc_rust/src/cffi/
Duart.h89 bool WinCloseSerialPort(HANDLE& handle);
90 ssize_t WinReadUartDev(HANDLE handle, std::vector<uint8_t> &readBuf, size_t expectedSize, OVERLAPPE…
91 ssize_t WinWriteUartDev(HANDLE handle, uint8_t *data, const size_t length, OVERLAPPED &ovWrite);
100 ssize_t ReadUartDev(int handle, std::vector<uint8_t> &readBuf, size_t expectedSize);
101 ssize_t WriteUartDev(int handle, uint8_t *data, const size_t length);
102 bool CloseSerialPort(int& handle);
Duart.cpp237 bool WinCloseSerialPort(HANDLE &handle) { argument
239 if (handle != INVALID_HANDLE_VALUE) {
240 CloseHandle(handle);
241 handle = INVALID_HANDLE_VALUE;
246 ssize_t WinReadUartDev(HANDLE handle, std::vector<uint8_t> &readBuf, size_t expectedSize, OVERLAPPE… argument
253 …BOOL bReadStatus = ReadFile(handle, uartReadBuffer, sizeof(uartReadBuffer), &bytesRead, &overRead);
261 if (!GetOverlappedResultEx(handle, &overRead, &bytesRead,
294 ssize_t WinWriteUartDev(HANDLE handle, uint8_t *data, const size_t length, OVERLAPPED &ovWrite) { argument
298 …BOOL bWriteStat = WriteFile(handle, data + totalBytesWrite, length - totalBytesWrite, &bytesWrite,…
301 if (!GetOverlappedResult(handle, &ovWrite, &bytesWrite, TRUE)) {
[all …]
/developtools/smartperf_host/ide/test/trace/database/logic-worker/
DProcedureLogicWorkerJsCpuProfiler.test.ts37 expect(procedureLogicWorkerJsCpuProfiler.handle(data)).toBeUndefined();
51 expect(procedureLogicWorkerJsCpuProfiler.handle(data)).toBeUndefined();
64 expect(procedureLogicWorkerJsCpuProfiler.handle(data)).toBeUndefined();
83 expect(procedureLogicWorkerJsCpuProfiler.handle(data)).toBeUndefined();
102 expect(procedureLogicWorkerJsCpuProfiler.handle(data)).toBeUndefined();
117 expect(procedureLogicWorkerJsCpuProfiler.handle(data)).toBeUndefined();
DProcedureLogicWorkerSchedulingAnalysis.test.ts46 expect(procedureLogicWorkerSchedulingAnalysis.handle(data)).toBeUndefined();
224 expect(procedureLogicWorkerSchedulingAnalysis.handle(data)).toBeUndefined();
241 expect(procedureLogicWorkerSchedulingAnalysis.handle(data)).toBeUndefined();
258 expect(procedureLogicWorkerSchedulingAnalysis.handle(data)).toBeUndefined();
275 expect(procedureLogicWorkerSchedulingAnalysis.handle(data)).toBeUndefined();
292 expect(procedureLogicWorkerSchedulingAnalysis.handle(data)).toBeUndefined();
309 expect(procedureLogicWorkerSchedulingAnalysis.handle(data)).toBeUndefined();
326 expect(procedureLogicWorkerSchedulingAnalysis.handle(data)).toBeUndefined();
343 expect(procedureLogicWorkerSchedulingAnalysis.handle(data)).toBeUndefined();
360 expect(procedureLogicWorkerSchedulingAnalysis.handle(data)).toBeUndefined();
[all …]
DProcedureLogicWorkerFileSystem.test.ts45 expect(procedureLogicWorkerFileSystem.handle(data)).toBeUndefined();
56 expect(procedureLogicWorkerFileSystem.handle(data)).toBeUndefined();
66 expect(procedureLogicWorkerF.handle(data)).toBeUndefined();
82 expect(procedureLogicWorkerF.handle(data)).toBeUndefined();
93 expect(procedureLogicWorkerFileSystem.handle(data)).toBeUndefined();
104 expect(procedureLogicWorkerFileSystem.handle(data)).toBeUndefined();
192 procedureLogicWorkerF.handle(data);
430 expect(procedureLogicWorkerF.handle(data)).toBeUndefined();
440 expect(procedureLogicWorkerF.handle(data)).toBeUndefined();
450 expect(procedureLogicWorkerF.handle(data)).toBeUndefined();
[all …]
DProcedureLogicWorkerNativeNemory.test.ts188 expect(procedureLogicWorkerNativeMemory.handle(data)).toBeUndefined();
203 expect(procedureLogicWorkerNativeMemory.handle(data)).toBeUndefined();
218 expect(procedureLogicWorkerNativeMemory.handle(data)).toBeUndefined();
234 expect(procedureLogicWorkerNativeMemory.handle(data)).toBeUndefined();
250 expect(procedureLogicWorkerNativeMemory.handle(data)).toBeUndefined();
356 expect(procedureLogicWorkerNativeMemory.handle(data)).toBeUndefined();
372 expect(procedureLogicWorkerNativeMemory.handle(data)).toBeUndefined();
391 expect(procedureLogicWorkerNativeMemory.handle(data)).toBeUndefined();
406 expect(procedureLogicWorkerNativeMemory.handle(data)).toBeUndefined();
421 expect(procedureLogicWorkerNativeMemory.handle(data)).toBeUndefined();
[all …]
DProcedureLogicWorkerSPT.test.ts36 expect(procedureLogicWorkerSPT.handle(data)).toBeUndefined();
51 expect(procedureLogicWorkerSPT.handle(data)).toBeUndefined();
66 expect(procedureLogicWorkerSPT.handle(data)).toBeUndefined();
/developtools/profiler/device/plugins/gpu_plugin/src/
Dtest_main.cpp30 void* handle = dlopen("./libgpudataplugin.z.so", RTLD_LAZY); in main() local
31 if (handle == nullptr) { in main()
35 std::cout << "test:handle = " << handle << std::endl; in main()
36 gpuPlugin = reinterpret_cast<PluginModuleStruct*>(dlsym(handle, "g_pluginModule")); in main()
66 dlclose(handle); in main()
/developtools/hdc/src/common/
Dchannel.cpp180 HChannel hChannel = (HChannel)req->handle->data; in WriteCallback()
186 Base::TryCloseHandle((uv_handle_t *)req->handle); in WriteCallback()
195 void HdcChannelBase::AsyncMainLoopTask(uv_idle_t *handle) in AsyncMainLoopTask() argument
197 AsyncParam *param = (AsyncParam *)handle->data; in AsyncMainLoopTask()
213 uv_close((uv_handle_t *)handle, Base::CloseIdleCallback); in AsyncMainLoopTask()
219 void HdcChannelBase::MainAsyncCallback(uv_async_t *handle) in MainAsyncCallback() argument
221 HdcChannelBase *thisClass = (HdcChannelBase *)handle->data; in MainAsyncCallback()
358 void HdcChannelBase::AllocCallback(uv_handle_t *handle, size_t sizeWanted, uv_buf_t *buf) in AllocCallback() argument
360 HChannel context = (HChannel)handle->data; in AllocCallback()
407 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);
69 static void MainAsyncCallback(uv_async_t *handle);
71 static void AsyncMainLoopTask(uv_idle_t *handle);
72 static void FreeChannelOpeate(uv_timer_t *handle);
73 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.cpp112 auto taskClassDeleteRetry = [](uv_timer_t *handle) -> void { in BeginRemoveTask() argument
114 HTaskInfo hTask = (HTaskInfo)handle->data; in BeginRemoveTask()
132 Base::TryCloseHandle((uv_handle_t *)handle, Base::CloseTimerCallback); in BeginRemoveTask()
187 auto clearSessionsForFinish = [](uv_idle_t *handle) -> void { in ReMainLoopForInstanceClear() argument
188 HdcSessionBase *thisClass = (HdcSessionBase *)handle->data; in ReMainLoopForInstanceClear()
193 uv_close((uv_handle_t *)handle, Base::CloseIdleCallback); in ReMainLoopForInstanceClear()
282 void HdcSessionBase::AsyncMainLoopTask(uv_idle_t *handle) in AsyncMainLoopTask() argument
284 AsyncParam *param = (AsyncParam *)handle->data; in AsyncMainLoopTask()
302 Base::TryCloseHandle((uv_handle_t *)handle, Base::CloseIdleCallback); in AsyncMainLoopTask()
305 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);
52 void TryCloseHandle(const uv_handle_t *handle);
53 void TryCloseHandle(const uv_handle_t *handle, uv_close_cb closeCallBack);
54 void TryCloseHandle(const uv_handle_t *handle, bool alwaysCallback, uv_close_cb closeCallBack);
60 void CloseIdleCallback(uv_handle_t *handle);
61 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_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);
/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()

1234