Home
last modified time | relevance | path

Searched refs:watcherId (Results 1 - 7 of 7) sorted by relevance

/base/startup/init/test/unittest/param/
H A Dwatcher_proxy_unittest.cpp68 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
148 TestDelWatcher(const std::string &keyPrefix, uint32_t watcherId) TestDelWatcher() argument
164 TestProcessWatcherMessage(const std::string &name, uint32_t watcherId) TestProcessWatcherMessage() argument
216 TestWatchAgentDied(uint32_t watcherId) TestWatchAgentDied() argument
275 uint32_t watcherId = 0; HWTEST_F() local
276 test.TestAddRemoteWatcher(getpid(), watcherId); HWTEST_F() local
286 uint32_t watcherId = 0; HWTEST_F() local
287 test.TestAddRemoteWatcher(getpid(), watcherId); HWTEST_F() local
298 uint32_t watcherId = 0; HWTEST_F() local
299 test.TestAddRemoteWatcher(getpid(), watcherId); HWTEST_F() local
307 uint32_t watcherId = 0; HWTEST_F() local
308 test.TestAddRemoteWatcher(getpid(), watcherId); HWTEST_F() local
318 uint32_t watcherId = 0; HWTEST_F() local
319 test.TestAddRemoteWatcher(getpid(), watcherId); HWTEST_F() local
328 uint32_t watcherId = 0; HWTEST_F() local
329 test.TestAddRemoteWatcher(getpid(), watcherId); HWTEST_F() local
339 uint32_t watcherId = 0; HWTEST_F() local
340 test.TestAddRemoteWatcher(getpid(), watcherId); HWTEST_F() local
350 uint32_t watcherId = 0; HWTEST_F() local
351 test.TestAddRemoteWatcher(getpid(), watcherId); HWTEST_F() local
372 uint32_t watcherId = 0; HWTEST_F() local
373 test.TestAddRemoteWatcher(getpid(), watcherId); HWTEST_F() local
[all...]
H A Dwatcher_agent_unittest.cpp169 data.WriteString("watcherId"); in TestRecvMessage()
219 data.WriteString("watcherId"); in TestWatcherProxy()
225 data.WriteString("watcherId"); in TestWatcherProxy()
238 data.WriteString("watcherId"); in TestWatcherProxy()
242 uint32_t watcherId = watcherManager->AddRemoteWatcher(1000, remoteWatcher); in TestWatcherProxy() local
244 int ret = watcherManager->AddWatcher("test.watcher.proxy", watcherId); in TestWatcherProxy()
246 ret = watcherManager->DelWatcher("test.watcher.proxy", watcherId); in TestWatcherProxy()
248 ret = watcherManager->RefreshWatcher("test.watcher.proxy", watcherId); in TestWatcherProxy()
250 watcherManager->DelRemoteWatcher(watcherId); in TestWatcherProxy()
/base/startup/init/services/param/watcher/proxy/
H A Dwatcher_manager.h182 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()
H A Dwatcher_manager.cpp163 request->id.watcherId = group->GetGroupId(); in SendMessage()
214 WATCHER_LOGV("Process watcher message name '%s' group id %u ", msg->key, msg->id.watcherId); in ProcessWatcherMessage()
217 WatcherGroupPtr group = GetWatcherGroup(msg->id.watcherId); in ProcessWatcherMessage()
218 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/
H A Dparam_message.h62 uint32_t watcherId; member
H A Dparam_service.c256 extData.info.waitInfo.waitId = msg->id.watcherId; in HandleParamWaitAdd()
297 extData.info.watchInfo.watchId = msg->id.watcherId; in HandleParamWatcherAdd()
303 PARAM_LOGV("HandleParamWatcherAdd name %s watcher: %d", msg->key, msg->id.watcherId); in HandleParamWatcherAdd()
310 PARAM_LOGV("HandleParamWatcherDel name %s watcher: %d", msg->key, msg->id.watcherId); in HandleParamWatcherDel()
311 DelWatchTrigger(TRIGGER_PARAM_WATCH, (const void *)&msg->id.watcherId); in HandleParamWatcherDel()
/base/startup/init/interfaces/kits/jskits/src/
H A Dnative_parameters_watch.cpp225 static uint32_t watcherId = 0;
227 watcherId++;
228 watcher->callbackReferences[watcherId] = callbackRef;
230 watcher->keyPrefix, watcherId);
403 PARAM_JS_LOGV("JSApp watcher notify key %s callback deleted watcherId %u",

Completed in 6 milliseconds