Searched refs:ThreadProcessInfo (Results 1 – 13 of 13) sorted by relevance
| /ohos5.0/foundation/communication/ipc/ipc/native/c/rpc/include/ |
| H A D | rpc_process_skeleton.h | 54 } ThreadProcessInfo; typedef
115 void AddDataInfoToThread(ThreadProcessInfo *processInfo);
116 ThreadProcessInfo *PopDataInfoFromThread(pthread_t threadId);
|
| /ohos5.0/foundation/communication/ipc/ipc/native/c/rpc/src/ |
| H A D | dbinder_invoker.c | 443 static void OnTransaction(ThreadProcessInfo *processInfo) in OnTransaction()
458 static ThreadProcessInfo *MakeThreadProcessInfo(uint32_t handle, const char *inBuffer, uint32_t siz… in MakeThreadProcessInfo()
465 ThreadProcessInfo *processInfo = (ThreadProcessInfo *)malloc(sizeof(ThreadProcessInfo)); in MakeThreadProcessInfo()
502 ThreadProcessInfo *processInfo = MakeThreadProcessInfo(handle, buffer, size); in StartProcessLoop()
752 ThreadProcessInfo *processInfo = PopDataInfoFromThread(threadId); in RpcJoinThread()
|
| H A D | rpc_process_skeleton.c | 209 void AddDataInfoToThread(ThreadProcessInfo *processInfo) in AddDataInfoToThread()
216 ThreadProcessInfo *PopDataInfoFromThread(pthread_t threadId) in PopDataInfoFromThread()
218 ThreadProcessInfo *node = NULL; in PopDataInfoFromThread()
220 UTILS_DL_LIST_FOR_EACH_ENTRY(node, &g_processInfoList.processInfo, ThreadProcessInfo, list) in PopDataInfoFromThread()
|
| /ohos5.0/foundation/communication/ipc/ipc/native/src/core/include/ |
| H A D | ipc_process_skeleton.h | 63 struct ThreadProcessInfo { struct
186 …void AddDataInfoToThread(const std::thread::id &threadId, std::shared_ptr<ThreadProcessInfo> proce…
187 std::shared_ptr<ThreadProcessInfo> PopDataInfoFromThread(const std::thread::id &threadId);
279 …std::map<std::thread::id, std::vector<std::shared_ptr<ThreadProcessInfo>>> dataInfoQueue_; // key …
|
| /ohos5.0/foundation/communication/ipc/ipc/native/src/mock/include/ |
| H A D | dbinder_base_invoker_process.h | 232 std::shared_ptr<ThreadProcessInfo> DBinderBaseInvoker<T>::MakeThreadProcessInfo(int32_t socketId, c… in MakeThreadProcessInfo()
240 … std::shared_ptr<ThreadProcessInfo> processInfo(new ThreadProcessInfo, [](ThreadProcessInfo *ptr) { in MakeThreadProcessInfo()
|
| H A D | dbinder_base_invoker_define.h | 76 virtual void OnTransaction(std::shared_ptr<ThreadProcessInfo> processInfo);
131 …std::shared_ptr<ThreadProcessInfo> MakeThreadProcessInfo(int32_t socketId, const char *buffer, uin…
|
| H A D | dbinder_base_invoker_interface.h | 141 template <class T> void DBinderBaseInvoker<T>::OnTransaction(std::shared_ptr<ThreadProcessInfo> pro… in OnTransaction()
|
| H A D | dbinder_base_invoker_object.h | 451 std::shared_ptr<ThreadProcessInfo> processInfo = MakeThreadProcessInfo(socketId, buffer, size); in StartProcessLoop()
|
| /ohos5.0/foundation/communication/ipc/ipc/native/test/fuzztest/mock/dbinderdatabusinvoker_fuzzer/ |
| H A D | dbinderdatabusinvoker_fuzzer.cpp | 233 …std::shared_ptr<ThreadProcessInfo> processInfo = invoker.MakeThreadProcessInfo(handle, indata, siz… in MakeThreadProcessInfoTest()
|
| /ohos5.0/foundation/communication/ipc/ipc/native/test/unittest/common/ |
| H A D | ipc_process_skeleton_unittest.cpp | 557 std::shared_ptr<ThreadProcessInfo> processInfo =
558 std::make_shared<ThreadProcessInfo>();
1852 std::shared_ptr<ThreadProcessInfo> processInfo =
1853 std::make_shared<ThreadProcessInfo>();
|
| /ohos5.0/foundation/communication/ipc/ipc/native/test/fuzztest/core/ipcprocessskeleton_fuzzer/ |
| H A D | ipcprocessskeleton_fuzzer.cpp | 908 std::shared_ptr<ThreadProcessInfo> processInfo = std::make_shared<ThreadProcessInfo>(); in AddToPopDataInfoToThreadTest()
|
| /ohos5.0/foundation/communication/ipc/ipc/native/src/core/source/ |
| H A D | ipc_process_skeleton.cpp | 798 std::shared_ptr<ThreadProcessInfo> processInfo) in AddDataInfoToThread()
806 std::shared_ptr<ThreadProcessInfo> IPCProcessSkeleton::PopDataInfoFromThread(const std::thread::id … in PopDataInfoFromThread()
815 std::shared_ptr<ThreadProcessInfo> processInfo = (dataInfoQueue_[threadId]).front(); in PopDataInfoFromThread()
|
| /ohos5.0/foundation/communication/ipc/ipc/native/src/mock/source/ |
| H A D | dbinder_databus_invoker.cpp | 435 std::shared_ptr<ThreadProcessInfo> processInfo = nullptr; in JoinProcessThread()
|