watcher_proxy_unittest.cpp - OpenGrok cross reference for /base/startup/init/test/unittest/param/watcher_proxy

Lines Matching refs:watcherId
68     int TestAddRemoteWatcher(uint32_t agentId, uint32_t &watcherId)
83         watcherId = reply.ReadUint32();
84         EXPECT_NE(watcherId, 0);
86         auto remoteWatcher = watcherManager->GetRemoteWatcher(watcherId);
95     int TestDelRemoteWatcher(uint32_t watcherId)
104         data.WriteUint32(watcherId);
108         EXPECT_EQ(watcherManager->GetRemoteWatcher(watcherId) == nullptr, 1);
112     int TestAddWatcher(const std::string &keyPrefix, uint32_t watcherId)
122         data.WriteUint32(watcherId);
130     int TestRefreshWatcher(const std::string &keyPrefix, uint32_t watcherId)
140         data.WriteUint32(watcherId);
148     int TestDelWatcher(const std::string &keyPrefix, uint32_t watcherId)
157         data.WriteUint32(watcherId);
164     int TestProcessWatcherMessage(const std::string &name, uint32_t watcherId)
176         msg->id.watcherId = watcherId;
216     int TestWatchAgentDied(uint32_t watcherId)
220         auto remoteWatcher = watcherManager->GetRemoteWatcher(watcherId);
225         EXPECT_EQ(watcherManager->GetRemoteWatcher(watcherId) == nullptr, 1);
275     uint32_t watcherId = 0;
276     test.TestAddRemoteWatcher(getpid(), watcherId);
277     test.TestAddWatcher("test.permission.watcher.test1", watcherId);
278     test.TestRefreshWatcher("test.permission.watcher.test1", watcherId);
279     test.TestProcessWatcherMessage("test.permission.watcher.test1", watcherId);
286     uint32_t watcherId = 0;
287     test.TestAddRemoteWatcher(getpid(), watcherId);
288     test.TestAddWatcher("test.permission.watcher.test2", watcherId);
289     test.TestAddWatcher("test.permission.watcher.test2", watcherId);
290     test.TestAddWatcher("test.permission.watcher.test2", watcherId);
291     test.TestRefreshWatcher("test.permission.watcher.test2", watcherId);
298     uint32_t watcherId = 0;
299     test.TestAddRemoteWatcher(getpid(), watcherId);
300     test.TestAddWatcher("test.permission.watcher.test3", watcherId);
307     uint32_t watcherId = 0;
308     test.TestAddRemoteWatcher(getpid(), watcherId);
311     test.TestAddWatcher("test.watcher.test4*", watcherId);
318     uint32_t watcherId = 0;
319     test.TestAddRemoteWatcher(getpid(), watcherId);
320     test.TestAddWatcher("test.permission.watcher.test5", watcherId);
328     uint32_t watcherId = 0;
329     test.TestAddRemoteWatcher(getpid(), watcherId);
330     test.TestAddWatcher("test.permission.watcher.testDel", watcherId);
331     test.TestDelWatcher("test.permission.watcher.testDel", watcherId);
332     test.TestDelRemoteWatcher(watcherId);
339     uint32_t watcherId = 0;
340     test.TestAddRemoteWatcher(getpid(), watcherId);
341     test.TestAddWatcher("test.permission.watcher.testdied", watcherId);
342     test.TestDelWatcher("test.permission.watcher.testdied", watcherId);
343     test.TestWatchAgentDied(watcherId);
350     uint32_t watcherId = 0;
351     test.TestAddRemoteWatcher(getpid(), watcherId);
352     test.TestAddWatcher("test.watcher*", watcherId);
353     test.TestAddWatcher("test.watcher.", watcherId);
360     test.TestWatchProxy("test.permission.watcher.test1", "watcherId");
372     uint32_t watcherId = 0;
373     test.TestAddRemoteWatcher(getpid(), watcherId);
374     test.TestAddWatcher("test.permission.watcher.stop", watcherId);