| /ohos5.0/foundation/communication/ipc/ipc/native/c/manager/src/ |
| H A D | ipc_thread_pool.c | 33 ThreadContext *GetCurrentThreadContext(void) in GetCurrentThreadContext()
35 ThreadContext *current = NULL; in GetCurrentThreadContext()
38 current = (ThreadContext *)curTLS; in GetCurrentThreadContext()
40 current = (ThreadContext *)calloc(1, sizeof(ThreadContext)); in GetCurrentThreadContext()
55 ThreadContext *threadContext = (ThreadContext *)args; in TlsDestructor()
77 ThreadContext *threadContext = GetCurrentThreadContext(); in GetAndUpdateInvoker()
87 ThreadContext *threadContext = (ThreadContext *)args; in ThreadHandler()
159 ThreadContext *threadContext = (ThreadContext *)calloc(1, sizeof(ThreadContext)); in SpawnNewThread()
206 ThreadContext *threadContext = GetCurrentThreadContext(); in GetRemoteInvoker()
|
| H A D | ipc_process_skeleton.c | 137 ThreadContext *currentContext = GetCurrentThreadContext(); in ProcessGetCallingPid()
148 ThreadContext *currentContext = GetCurrentThreadContext(); in ProcessGetCallingUid()
|
| /ohos5.0/base/startup/appspawn/test/moduletest/ |
| H A D | appspawn_test_cmder.h | 33 } ThreadContext; typedef
37 class AppSpawnTestCommander : public ThreadContext {
92 static AppSpawnTestCommander *ConvertTo(const ThreadContext *context) in ConvertTo()
96 static void TaskExecutorProc(ThreadTaskHandle handle, const ThreadContext *context);
97 static void SendTaskFinish(ThreadTaskHandle handle, const ThreadContext *context);
98 static void InputThread(ThreadTaskHandle handle, const ThreadContext *context);
99 static void DumpThread(ThreadTaskHandle handle, const ThreadContext *context);
|
| H A D | appspawn_test_cmder.cpp | 449 …dMgrAddExecutor(threadMgr_, taskHandle, TaskExecutorProc, reinterpret_cast<ThreadContext *>(this)); in StartSendMsg()
456 void AppSpawnTestCommander::TaskExecutorProc(ThreadTaskHandle handle, const ThreadContext *context) in TaskExecutorProc()
462 void AppSpawnTestCommander::SendTaskFinish(ThreadTaskHandle handle, const ThreadContext *context) in SendTaskFinish()
491 void AppSpawnTestCommander::InputThread(ThreadTaskHandle handle, const ThreadContext *context) in InputThread()
525 void AppSpawnTestCommander::DumpThread(ThreadTaskHandle handle, const ThreadContext *context) in DumpThread()
|
| /ohos5.0/base/startup/appspawn/test/moduletest/threadpool/ |
| H A D | thread_manager.h | 30 typedef struct TagThreadContext ThreadContext; typedef
32 typedef void (*TaskFinishProcessor)(ThreadTaskHandle handle, const ThreadContext *context);
33 typedef void (*TaskExecutor)(ThreadTaskHandle handle, const ThreadContext *context);
39 ThreadTaskHandle taskHandle, TaskExecutor executor, const ThreadContext *context);
43 ThreadTaskHandle taskHandle, TaskFinishProcessor process, const ThreadContext *context);
|
| H A D | thread_manager.c | 52 const ThreadContext *context;
62 const ThreadContext *context;
365 ThreadTaskHandle taskHandle, TaskExecutor executor, const ThreadContext *context) in ThreadMgrAddExecutor()
438 ThreadTaskHandle taskHandle, TaskFinishProcessor process, const ThreadContext *context) in TaskExecute()
|
| /ohos5.0/base/hiviewdfx/faultloggerd/interfaces/innerkits/unwinder/include/ |
| H A D | thread_context.h | 36 struct ThreadContext { struct
56 ~ThreadContext() in ~ThreadContext() argument
71 std::shared_ptr<ThreadContext> CollectThreadContext(int32_t tid);
72 std::shared_ptr<ThreadContext> GetThreadContext(int32_t tid);
81 bool SignalRequestThread(int32_t tid, ThreadContext* ctx);
|
| /ohos5.0/base/hiviewdfx/faultloggerd/interfaces/innerkits/unwinder/ |
| H A D | thread_context.cpp | 43 std::map<int32_t, std::shared_ptr<ThreadContext>> g_contextMap {};
46 void CreateContext(std::shared_ptr<ThreadContext>& threadContext) in CreateContext()
57 void ReleaseContext(std::shared_ptr<ThreadContext> threadContext) in ReleaseContext()
68 std::shared_ptr<ThreadContext> GetContextLocked(int32_t tid) in GetContextLocked()
72 auto threadContext = std::make_shared<ThreadContext>(); in GetContextLocked()
137 NO_SANITIZE std::shared_ptr<ThreadContext> LocalThreadContext::GetThreadContext(int32_t tid) in GetThreadContext()
164 std::shared_ptr<ThreadContext> LocalThreadContext::CollectThreadContext(int32_t tid) in CollectThreadContext()
191 auto ctxPtr = static_cast<ThreadContext *>(si->si_value.sival_ptr); in CopyContextAndWaitTimeout()
254 bool LocalThreadContext::SignalRequestThread(int32_t tid, ThreadContext* threadContext) in SignalRequestThread()
|
| /ohos5.0/foundation/graphic/graphic_3d/lume/LumeEngine/src/threading/ |
| H A D | task_queue_factory.cpp | 140 : threadCount_(threadCount), threads_(make_unique<ThreadContext[]>(threadCount)) in ThreadPool()
145 auto threads = array_view<ThreadContext>(threads_.get(), threadCount_); in ThreadPool()
146 for (ThreadContext& context : threads) { in ThreadPool()
282 struct ThreadContext { struct in __anondcf869ec0110::ThreadPool
338 void ThreadProc(ThreadContext& context) in ThreadProc()
383 unique_ptr<ThreadContext[]> threads_;
|
| /ohos5.0/foundation/communication/ipc/ipc/native/c/manager/include/ |
| H A D | ipc_thread_pool.h | 48 } ThreadContext; typedef
63 ThreadContext *GetCurrentThreadContext(void);
|
| /ohos5.0/foundation/communication/ipc/ipc/native/c/rpc/src/ |
| H A D | dbinder_invoker.c | 67 ThreadContext *threadContext = GetCurrentThreadContext(); in GetUniqueSeqNumber()
336 ThreadContext *threadContext = GetCurrentThreadContext(); in GetCallerSessionId()
374 ThreadContext *threadContext = GetCurrentThreadContext(); in ProcessTransaction()
744 ThreadContext *threadContext = GetCurrentThreadContext(); in RpcJoinThread()
768 ThreadContext *threadContext = GetCurrentThreadContext(); in RpcStopWorkThread()
|
| /ohos5.0/foundation/communication/ipc/services/dbinder/c/src/ |
| H A D | dbinder_stub.c | 67 ThreadContext *threadContext = GetCurrentThreadContext(); in ProcessProto()
|
| /ohos5.0/foundation/communication/ipc/ipc/native/c/rpc/ipc_adapter/mini/ |
| H A D | ipc_proxy_inner.c | 202 ThreadContext *threadContext = GetCurrentThreadContext(); in UpdateProto()
|
| /ohos5.0/foundation/communication/ipc/ipc/native/c/rpc/ipc_adapter/small/ |
| H A D | ipc_proxy_inner.c | 242 ThreadContext *threadContext = GetCurrentThreadContext(); in UpdateProto()
|
| /ohos5.0/foundation/communication/ipc/ipc/native/c/ipc/src/liteos_a/ |
| H A D | ipc_invoker.c | 290 ThreadContext *threadContext = GetCurrentThreadContext(); in CallIpcCallback()
492 ThreadContext *threadContext = GetCurrentThreadContext(); in IpcJoinThreadLoop()
|
| /ohos5.0/foundation/communication/ipc/ipc/test/unittest/rpc/client/ |
| H A D | RpcClientTest.cpp | 301 ThreadContext *threadContext = GetCurrentThreadContext();
|
| /ohos5.0/foundation/communication/ipc/ipc/native/c/ipc/src/linux/ |
| H A D | ipc_invoker.c | 215 ThreadContext *threadContext = GetCurrentThreadContext(); in HandleTransaction()
|
| /ohos5.0/base/hiviewdfx/faultloggerd/test/unittest/unwind/ |
| H A D | dwarf_test.cpp | 1211 std::shared_ptr<ThreadContext> ret = instance.GetThreadContext(-1);
|