/dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/main/java/org/apache/zookeeper/ |
H A D | ZKWatchManager.java | 222 boolean containsWatcher = false; in containsWatcher() 232 containsWatcher |= contains_temp; in containsWatcher() 238 containsWatcher |= contains_temp; in containsWatcher() 249 containsWatcher |= contains_temp; in containsWatcher() 255 containsWatcher |= contains_temp; in containsWatcher() 261 containsWatcher |= contains_temp; in containsWatcher() 272 containsWatcher |= contains_temp; in containsWatcher() 277 containsWatcher |= contains_temp; in containsWatcher() 283 containsWatcher |= contains_temp; in containsWatcher() 289 containsWatcher |= contains_temp; in containsWatcher() [all …]
|
/dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-client/zookeeper-client-c/src/ |
H A D | zk_hashtable.c | 340 static int containsWatcher(zk_hashtable *watchers, const char *path, in containsWatcher() function 450 watcher_found = containsWatcher(zh->active_child_watchers, in pathHasWatcher() 454 watcher_found = containsWatcher(zh->active_node_watchers, path, in pathHasWatcher() 457 watcher_found = containsWatcher(zh->active_exist_watchers, path, in pathHasWatcher() 462 watcher_found = containsWatcher(zh->active_child_watchers, path, in pathHasWatcher() 465 watcher_found = containsWatcher(zh->active_node_watchers, path, in pathHasWatcher() 469 watcher_found = containsWatcher(zh->active_exist_watchers, path, in pathHasWatcher()
|
/dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/main/java/org/apache/zookeeper/server/ |
H A D | DataTree.java | 1584 public boolean containsWatcher(String path, WatcherType type, Watcher watcher) { in containsWatcher() method in DataTree 1585 boolean containsWatcher = false; in containsWatcher() 1588 containsWatcher = this.childWatches.containsWatcher(path, watcher); in containsWatcher() 1591 containsWatcher = this.dataWatches.containsWatcher(path, watcher); in containsWatcher() 1594 if (this.childWatches.containsWatcher(path, watcher)) { in containsWatcher() 1595 containsWatcher = true; in containsWatcher() 1597 if (this.dataWatches.containsWatcher(path, watcher)) { in containsWatcher() 1598 containsWatcher = true; in containsWatcher() 1602 return containsWatcher; in containsWatcher()
|
H A D | ZKDatabase.java | 707 public boolean containsWatcher(String path, WatcherType type, Watcher watcher) { in containsWatcher() method in ZKDatabase 708 return dataTree.containsWatcher(path, type, watcher); in containsWatcher()
|
H A D | FinalRequestProcessor.java | 530 boolean containsWatcher = zks.getZKDatabase().containsWatcher(path, type, cnxn); in processRequest() 531 if (!containsWatcher) { in processRequest()
|
/dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/main/java/org/apache/zookeeper/server/watch/ |
H A D | IWatchManager.java | 61 boolean containsWatcher(String path, Watcher watcher); in containsWatcher() method
|
H A D | WatchManagerOptimized.java | 121 public boolean containsWatcher(String path, Watcher watcher) { in containsWatcher() method in WatchManagerOptimized
|
H A D | WatchManager.java | 234 public synchronized boolean containsWatcher(String path, Watcher watcher) { in containsWatcher() method in WatchManager
|
/dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/test/java/org/apache/zookeeper/test/ |
H A D | UnsupportedAddWatcherTest.java | 47 public boolean containsWatcher(String path, Watcher watcher) { in containsWatcher() method in UnsupportedAddWatcherTest.StubbedWatchManager
|
/dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/test/java/org/apache/zookeeper/ |
H A D | RemoveWatchesTest.java | 971 void containsWatcher(String path, Watcher watcher, WatcherType watcherType) { in containsWatcher() method in RemoveWatchesTest.MyWatchManager 1087 …urn serverFactory.getZooKeeperServer().getZKDatabase().getDataTree().containsWatcher(path, type, c… in isServerSessionWatcher()
|