| /base/startup/init/services/param/watcher/agent/ |
| H A D | watcher_manager_proxy.cpp | 38 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 return 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 return 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 return SendMsg(static_cast<uint32_t>(ParamWatcherInterfaceCode::REFRESH_WATCHER), keyPrefix, remoteWatcherId); in RefreshWatcher()
[all...] |
| H A D | watcher_manager_proxy.h | 30 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 D | watcher_manager_kits.cpp | 107 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 WATCHER_LOGI("Add watcher keyPrefix %s remoteWatcherId in AddWatcher()
[all...] |
| /base/startup/init/services/param/watcher/include/ |
| H A D | iwatcher_manager.h | 32 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;
|
| /base/startup/init/services/param/watcher/proxy/ |
| H A D | watcher_manager.cpp | 54 uint32_t remoteWatcherId = 0; in AddRemoteWatcher() local
58 int ret = GetRemoteWatcherId(remoteWatcherId); in AddRemoteWatcher()
61 RemoteWatcher *remoteWatcher = new RemoteWatcher(remoteWatcherId, watcher); in AddRemoteWatcher()
66 WATCHER_LOGI("Add remote watcher remoteWatcherId %u %u success", remoteWatcherId, id); in AddRemoteWatcher()
67 return remoteWatcherId; in AddRemoteWatcher()
70 int32_t WatcherManager::DelRemoteWatcher(uint32_t remoteWatcherId) in DelRemoteWatcher() argument
75 RemoteWatcher *remoteWatcher = GetRemoteWatcher(remoteWatcherId); in DelRemoteWatcher()
76 WATCHER_CHECK(remoteWatcher != nullptr, return 0, "Can not find watcher %u", remoteWatcherId); in DelRemoteWatcher()
79 WATCHER_LOGI("Del remote watcher remoteWatcherId in DelRemoteWatcher()
90 AddWatcher(const std::string &keyPrefix, uint32_t remoteWatcherId) AddWatcher() argument
116 DelWatcher(const std::string &keyPrefix, uint32_t remoteWatcherId) DelWatcher() argument
138 RefreshWatcher(const std::string &keyPrefix, uint32_t remoteWatcherId) RefreshWatcher() argument
227 SendLocalChange(const std::string &keyPrefix, uint32_t remoteWatcherId) SendLocalChange() argument
231 uint32_t remoteWatcherId; SendLocalChange() member
436 GetRemoteWatcherId(uint32_t &remoteWatcherId) GetRemoteWatcherId() argument
557 GetRemoteWatcher(uint32_t remoteWatcherId) GetRemoteWatcher() argument
[all...] |
| H A D | watcher_manager.h | 77 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 D | watcher_manager_stub.cpp | 60 uint32_t remoteWatcherId = AddRemoteWatcher(id, watcher); in OnRemoteRequest() local
61 reply.WriteUint32(remoteWatcherId); in OnRemoteRequest()
|