Searched refs:remoteWatcher (Results 1 – 3 of 3) sorted by relevance
| /base/startup/init/services/param/watcher/proxy/ |
| D | watcher_manager.cpp | 56 RemoteWatcher *remoteWatcher = new RemoteWatcher(remoteWatcherId, watcher); in AddRemoteWatcher() local
57 WATCHER_CHECK(remoteWatcher != nullptr, return 0, "Failed to create watcher for %u", id); in AddRemoteWatcher()
58 remoteWatcher->SetAgentId(id); in AddRemoteWatcher()
59 AddRemoteWatcher(remoteWatcher); in AddRemoteWatcher()
70 RemoteWatcher *remoteWatcher = GetRemoteWatcher(remoteWatcherId); in DelRemoteWatcher() local
71 … WATCHER_CHECK(remoteWatcher != nullptr, return 0, "Can not find watcher %u", remoteWatcherId); in DelRemoteWatcher()
73 watcher = remoteWatcher->GetWatcher(); in DelRemoteWatcher()
74 DelRemoteWatcher(remoteWatcher); in DelRemoteWatcher()
86 auto remoteWatcher = GetRemoteWatcher(remoteWatcherId); in AddWatcher() local
87 …WATCHER_CHECK(remoteWatcher != nullptr, return -1, "Can not find remote watcher %d", remoteWatcher… in AddWatcher()
[all …]
|
| D | watcher_manager.h | 93 void SendLocalChange(const std::string &keyPrefix, RemoteWatcherPtr &remoteWatcher);
99 int AddRemoteWatcher(RemoteWatcherPtr remoteWatcher);
102 void DelRemoteWatcher(RemoteWatcherPtr remoteWatcher);
109 int AddParamWatcher(WatcherGroupPtr group, RemoteWatcherPtr remoteWatcher);
110 int DelParamWatcher(WatcherGroupPtr group, RemoteWatcherPtr remoteWatcher);
115 void OnRemoteDied(RemoteWatcherPtr remoteWatcher);
|
| /base/startup/init/test/unittest/param/ |
| D | watcher_proxy_unittest.cpp | 78 auto remoteWatcher = watcherManager->GetRemoteWatcher(watcherId); in TestAddRemoteWatcher() local
79 if (remoteWatcher != nullptr) { in TestAddRemoteWatcher()
80 EXPECT_EQ(remoteWatcher->GetAgentId(), agentId); in TestAddRemoteWatcher()
192 auto remoteWatcher = watcherManager->GetRemoteWatcher(watcherId); in TestWatchAgentDied() local
193 WATCHER_CHECK(remoteWatcher != nullptr, return -1, "Failed to get remote watcher"); in TestWatchAgentDied()
195 … watcherManager->GetDeathRecipient()->OnRemoteDied(remoteWatcher->GetWatcher()->AsObject()); in TestWatchAgentDied()
|