Searched refs:watcherId (Results 1 – 7 of 7) sorted by relevance
| /base/startup/init/test/unittest/param/ |
| D | watcher_proxy_unittest.cpp | 68 int TestAddRemoteWatcher(uint32_t agentId, uint32_t &watcherId) in TestAddRemoteWatcher() argument
83 watcherId = reply.ReadUint32(); in TestAddRemoteWatcher()
84 EXPECT_NE(watcherId, 0); in TestAddRemoteWatcher()
86 auto remoteWatcher = watcherManager->GetRemoteWatcher(watcherId); in TestAddRemoteWatcher()
95 int TestDelRemoteWatcher(uint32_t watcherId) in TestDelRemoteWatcher() argument
104 data.WriteUint32(watcherId); in TestDelRemoteWatcher()
108 EXPECT_EQ(watcherManager->GetRemoteWatcher(watcherId) == nullptr, 1); in TestDelRemoteWatcher()
112 int TestAddWatcher(const std::string &keyPrefix, uint32_t watcherId) in TestAddWatcher() argument
122 data.WriteUint32(watcherId); in TestAddWatcher()
130 int TestRefreshWatcher(const std::string &keyPrefix, uint32_t watcherId) in TestRefreshWatcher() argument
[all …]
|
| D | watcher_agent_unittest.cpp | 239 uint32_t watcherId = watcherManager->AddRemoteWatcher(1000, remoteWatcher); in TestWatcherProxy() local
241 int ret = watcherManager->AddWatcher("test.watcher.proxy", watcherId); in TestWatcherProxy()
243 ret = watcherManager->DelWatcher("test.watcher.proxy", watcherId); in TestWatcherProxy()
245 ret = watcherManager->RefreshWatcher("test.watcher.proxy", watcherId); in TestWatcherProxy()
247 watcherManager->DelRemoteWatcher(watcherId); in TestWatcherProxy()
|
| /base/startup/init/services/param/watcher/proxy/ |
| D | watcher_manager.h | 182 explicit ParamWatcher(uint32_t watcherId) : WatcherNode(watcherId) {} in ParamWatcher() argument
216 RemoteWatcher(uint32_t watcherId, const sptr<IWatcher> &watcher) in RemoteWatcher() argument
217 : WatcherNode(watcherId), ParamWatcherList(), watcher_(watcher) {} in RemoteWatcher()
|
| D | watcher_manager.cpp | 145 request->id.watcherId = group->GetGroupId(); in SendMessage()
191 WATCHER_LOGV("Process watcher message name '%s' group id %u ", msg->key, msg->id.watcherId); in ProcessWatcherMessage()
194 WatcherGroupPtr group = GetWatcherGroup(msg->id.watcherId); in ProcessWatcherMessage()
195 … WATCHER_CHECK(group != NULL, return, "Can not find group for %u %s", msg->id.watcherId, msg->key); in ProcessWatcherMessage()
|
| /base/startup/init/services/param/linux/ |
| D | param_service.c | 250 extData.info.waitInfo.waitId = msg->id.watcherId; in HandleParamWaitAdd()
291 extData.info.watchInfo.watchId = msg->id.watcherId; in HandleParamWatcherAdd()
297 PARAM_LOGV("HandleParamWatcherAdd name %s watcher: %d", msg->key, msg->id.watcherId); in HandleParamWatcherAdd()
304 PARAM_LOGV("HandleParamWatcherDel name %s watcher: %d", msg->key, msg->id.watcherId); in HandleParamWatcherDel()
305 DelWatchTrigger(TRIGGER_PARAM_WATCH, (const void *)&msg->id.watcherId); in HandleParamWatcherDel()
|
| D | param_message.h | 61 uint32_t watcherId; member
|
| /base/startup/init/interfaces/kits/jskits/src/ |
| D | native_parameters_watch.cpp | 225 static uint32_t watcherId = 0; in AddWatcherCallback() local
227 watcherId++; in AddWatcherCallback()
228 watcher->callbackReferences[watcherId] = callbackRef; in AddWatcherCallback()
230 watcher->keyPrefix, watcherId); in AddWatcherCallback()
|