Searched refs:KernelTalker (Results 1 - 9 of 9) sorted by relevance
| /foundation/filemanagement/dfs_service/services/distributedfiledaemon/src/network/ |
| H A D | kernel_talker.cpp | 73 void KernelTalker::SinkSessionTokernel(shared_ptr<BaseSession> session, const std::string backStage) in SinkSessionTokernel()
101 void KernelTalker::SinkDevslTokernel(const std::string &cid, uint32_t devsl) in SinkDevslTokernel()
115 void KernelTalker::SinkOfflineCmdToKernel(string cid) in SinkOfflineCmdToKernel()
132 void KernelTalker::CreatePollThread() in CreatePollThread()
139 pollThread_ = make_unique<thread>(&KernelTalker::PollRun, this); in CreatePollThread()
143 void KernelTalker::WaitForPollThreadExited() in WaitForPollThreadExited()
159 void KernelTalker::PollRun() in PollRun()
208 void KernelTalker::HandleAllNotify(int fd) in HandleAllNotify()
223 void KernelTalker::NotifyHandler(NotifyParam ¶m) in NotifyHandler()
|
| H A D | devsl_dispatcher.cpp | 26 std::map<std::string, std::vector<std::weak_ptr<KernelTalker>>> DevslDispatcher::talkersMap_;
56 uint32_t DevslDispatcher::DevslGetRegister(const std::string &cid, std::weak_ptr<KernelTalker> talker) in DevslGetRegister()
73 std::vector<std::weak_ptr<KernelTalker>> talkers; in DevslGetRegister()
|
| /foundation/filemanagement/dfs_service/services/distributedfiledaemon/test/unittest/network/ |
| H A D | session_pool_test.cpp | 57 void KernelTalker::SinkSessionTokernel(std::shared_ptr<BaseSession> session, const std::string backStage) in SinkSessionTokernel()
62 void KernelTalker::SinkOfflineCmdToKernel(std::string cid) in SinkOfflineCmdToKernel()
67 void KernelTalker::CreatePollThread() in CreatePollThread()
72 void KernelTalker::WaitForPollThreadExited() in WaitForPollThreadExited()
134 auto kernelTalker = std::make_shared<KernelTalker>(wmp, [](NotifyParam ¶m) {}, [](int32_t fd) {}); in HWTEST_F()
160 auto kernelTalker = std::make_shared<KernelTalker>(wmp, [](NotifyParam ¶m) {}, [](int32_t fd) {}); in HWTEST_F()
190 auto kernelTalker = std::make_shared<KernelTalker>(wmp, [](NotifyParam ¶m) {}, [](int32_t fd) {}); in HWTEST_F()
220 auto kernelTalker = std::make_shared<KernelTalker>(wmp, [](NotifyParam ¶m) {}, [](int32_t fd) {}); in HWTEST_F()
248 auto kernelTalker = std::make_shared<KernelTalker>(wmp, [](NotifyParam ¶m) {}, [](int32_t fd) {}); in HWTEST_F()
280 auto kernelTalker = std::make_shared<KernelTalker>(wm in HWTEST_F()
[all...] |
| H A D | kernel_talker_test.cpp | 37 shared_ptr<KernelTalker> g_talker;
58 g_talker = std::make_shared<KernelTalker>(g_wmp, [](NotifyParam ¶m) {}, [](int32_t fd) {}); in SetUpTestCase()
|
| H A D | devsl_dispatcher_test.cpp | 146 auto kernelTalker = std::make_shared<KernelTalker>(wmp, [](NotifyParam ¶m) {}, [](int32_t fd) {}); in HWTEST_F()
|
| /foundation/filemanagement/dfs_service/services/distributedfiledaemon/include/network/ |
| H A D | kernel_talker.h | 42 class KernelTalker final : protected NoCopyable, public std::enable_shared_from_this<KernelTalker> {
44 explicit KernelTalker(std::weak_ptr<MountPoint> mountPoint, in KernelTalker() function in OHOS::Storage::DistributedFile::final
50 KernelTalker() = default;
51 ~KernelTalker() = default;
|
| H A D | devsl_dispatcher.h | 37 static uint32_t DevslGetRegister(const std::string &cid, std::weak_ptr<KernelTalker>);
41 static std::map<std::string, std::vector<std::weak_ptr<KernelTalker>>> talkersMap_;
|
| H A D | session_pool.h | 33 explicit SessionPool(std::shared_ptr<KernelTalker> &talker) : talker_(talker) {} in SessionPool()
47 std::shared_ptr<KernelTalker> &talker_;
|
| H A D | network_agent_template.h | 49 kernerlTalker_(std::make_shared<KernelTalker>( in NetworkAgentTemplate()
94 std::shared_ptr<KernelTalker> kernerlTalker_;
|
Completed in 4 milliseconds