Home
last modified time | relevance | path

Searched refs:remoteWatcherId (Results 1 – 7 of 7) sorted by relevance

/ohos5.0/base/startup/init/services/param/watcher/agent/
H A Dwatcher_manager_proxy.cpp38 int32_t WatcherManagerProxy::DelRemoteWatcher(uint32_t remoteWatcherId) in DelRemoteWatcher() argument
42 data.WriteUint32(remoteWatcherId); in DelRemoteWatcher()
51 int32_t WatcherManagerProxy::SendMsg(int op, const std::string &keyPrefix, uint32_t remoteWatcherId) in SendMsg() argument
56 data.WriteUint32(remoteWatcherId); in SendMsg()
64 int32_t WatcherManagerProxy::AddWatcher(const std::string &keyPrefix, uint32_t remoteWatcherId) in AddWatcher() argument
66 …SendMsg(static_cast<uint32_t>(ParamWatcherInterfaceCode::ADD_WATCHER), keyPrefix, remoteWatcherId); in AddWatcher()
69 int32_t WatcherManagerProxy::DelWatcher(const std::string &keyPrefix, uint32_t remoteWatcherId) in DelWatcher() argument
71 …SendMsg(static_cast<uint32_t>(ParamWatcherInterfaceCode::DEL_WATCHER), keyPrefix, remoteWatcherId); in DelWatcher()
74 int32_t WatcherManagerProxy::RefreshWatcher(const std::string &keyPrefix, uint32_t remoteWatcherId) in RefreshWatcher() argument
76 …Msg(static_cast<uint32_t>(ParamWatcherInterfaceCode::REFRESH_WATCHER), keyPrefix, remoteWatcherId); in RefreshWatcher()
H A Dwatcher_manager_proxy.h30 int32_t DelRemoteWatcher(uint32_t remoteWatcherId) override;
31 int32_t AddWatcher(const std::string &keyPrefix, uint32_t remoteWatcherId) override;
32 int32_t DelWatcher(const std::string &keyPrefix, uint32_t remoteWatcherId) override;
33 int32_t RefreshWatcher(const std::string &keyPrefix, uint32_t remoteWatcherId) override;
35 int32_t SendMsg(int op, const std::string &keyPrefix, uint32_t remoteWatcherId);
H A Dwatcher_manager_kits.cpp107 uint32_t remoteWatcherId = GetRemoteWatcher(); in ReAddWatcher() local
108 WATCHER_CHECK(remoteWatcherId > 0, return, "Failed to get remote agent"); in ReAddWatcher()
112 int ret = watcherManager->AddWatcher(iter->first, remoteWatcherId); in ReAddWatcher()
148 uint32_t remoteWatcherId = GetRemoteWatcher(); in AddWatcher() local
149 WATCHER_CHECK(remoteWatcherId > 0, return -1, "Failed to get remote agent"); in AddWatcher()
154 WATCHER_CHECK(remoteWatcherId > 0, return -1, "Failed to get remote agent"); in AddWatcher()
160 ret = watcherManager->AddWatcher(keyPrefix, remoteWatcherId); in AddWatcher()
167 ret = watcherManager->RefreshWatcher(keyPrefix, remoteWatcherId); in AddWatcher()
169 "Failed to refresh watcher for %s %d", keyPrefix.c_str(), remoteWatcherId); in AddWatcher()
172 …ER_LOGI("Add watcher keyPrefix %s remoteWatcherId %u success", keyPrefix.c_str(), remoteWatcherId); in AddWatcher()
/ohos5.0/base/startup/init/services/param/watcher/proxy/
H A Dwatcher_manager.cpp54 uint32_t remoteWatcherId = 0; in AddRemoteWatcher() local
58 int ret = GetRemoteWatcherId(remoteWatcherId); in AddRemoteWatcher()
67 return remoteWatcherId; in AddRemoteWatcher()
70 int32_t WatcherManager::DelRemoteWatcher(uint32_t remoteWatcherId) in DelRemoteWatcher() argument
95 auto remoteWatcher = GetRemoteWatcher(remoteWatcherId); in AddWatcher()
110 SendLocalChange(keyPrefix, remoteWatcherId); in AddWatcher()
122 auto remoteWatcher = GetRemoteWatcher(remoteWatcherId); in DelWatcher()
143 auto remoteWatcher = GetRemoteWatcher(remoteWatcherId); in RefreshWatcher()
150 SendLocalChange(keyPrefix, remoteWatcherId); in RefreshWatcher()
231 uint32_t remoteWatcherId; in SendLocalChange() member
[all …]
H A Dwatcher_manager.h77 int32_t DelRemoteWatcher(uint32_t remoteWatcherId) override;
78 int32_t AddWatcher(const std::string &keyPrefix, uint32_t remoteWatcherId) override;
79 int32_t DelWatcher(const std::string &keyPrefix, uint32_t remoteWatcherId) override;
80 int32_t RefreshWatcher(const std::string &keyPrefix, uint32_t remoteWatcherId) override;
89 void SendLocalChange(const std::string &keyPrefix, uint32_t remoteWatcherId);
92 int GetRemoteWatcherId(uint32_t &remoteWatcherId);
96 RemoteWatcherPtr GetRemoteWatcher(uint32_t remoteWatcherId);
H A Dwatcher_manager_stub.cpp58 uint32_t remoteWatcherId = AddRemoteWatcher(data.ReadUint32(), watcher); in OnRemoteRequest() local
59 reply.WriteUint32(remoteWatcherId); in OnRemoteRequest()
/ohos5.0/base/startup/init/services/param/watcher/include/
H A Diwatcher_manager.h32 virtual int32_t DelRemoteWatcher(uint32_t remoteWatcherId) = 0;
33 virtual int32_t AddWatcher(const std::string &keyPrefix, uint32_t remoteWatcherId) = 0;
34 virtual int32_t DelWatcher(const std::string &keyPrefix, uint32_t remoteWatcherId) = 0;
35 virtual int32_t RefreshWatcher(const std::string &keyPrefix, uint32_t remoteWatcherId) = 0;