41     private final Map<String, Set<Watcher>> dataWatches = new HashMap<>();
42     private final Map<String, Set<Watcher>> existWatches = new HashMap<>();
43     private final Map<String, Set<Watcher>> childWatches = new HashMap<>();
44     private final Map<String, Set<Watcher>> persistentWatches = new HashMap<>();
45     private final Map<String, Set<Watcher>> persistentRecursiveWatches = new HashMap<>();
48     private volatile Watcher defaultWatcher;
50     ZKWatchManager(boolean disableAutoWatchReset, Watcher defaultWatcher) {  in ZKWatchManager()
55     void setDefaultWatcher(Watcher defaultWatcher) {  in setDefaultWatcher()
59     Watcher getDefaultWatcher() {  in getDefaultWatcher()
93     Map<String, Set<Watcher>> getDataWatches() {  in getDataWatches()
97     Map<String, Set<Watcher>> getExistWatches() {  in getExistWatches()
101     Map<String, Set<Watcher>> getChildWatches() {  in getChildWatches()
105     Map<String, Set<Watcher>> getPersistentWatches() {  in getPersistentWatches()
109     Map<String, Set<Watcher>> getPersistentRecursiveWatches() {  in getPersistentRecursiveWatches()
113     private void addTo(Set<Watcher> from, Set<Watcher> to) {  in addTo()
119     public Map<Watcher.Event.EventType, Set<Watcher>> removeWatcher(  in removeWatcher()
121         Watcher watcher,  in removeWatcher()
122         Watcher.WatcherType watcherType,  in removeWatcher()
130         Map<Watcher.Event.EventType, Set<Watcher>> removedWatchers = new HashMap<>();  in removeWatcher()
131         HashSet<Watcher> childWatchersToRem = new HashSet<>();  in removeWatcher()
132         removedWatchers.put(Watcher.Event.EventType.ChildWatchRemoved, childWatchersToRem);  in removeWatcher()
133         HashSet<Watcher> dataWatchersToRem = new HashSet<>();  in removeWatcher()
134         removedWatchers.put(Watcher.Event.EventType.DataWatchRemoved, dataWatchersToRem);  in removeWatcher()
135         HashSet<Watcher> persistentWatchersToRem = new HashSet<>();  in removeWatcher()
136 …      removedWatchers.put(Watcher.Event.EventType.PersistentWatchRemoved, persistentWatchersToRem);  in removeWatcher()
191 …private boolean contains(String path, Watcher watcherObj, Map<String, Set<Watcher>> pathVsWatchers…  in contains()
196             Set<Watcher> watchers = pathVsWatchers.get(path);  in contains()
220     void containsWatcher(String path, Watcher watcher, Watcher.WatcherType watcherType) throws  in containsWatcher()
300         Map<String, Set<Watcher>> pathVsWatcher,  in removeWatches()
301         Watcher watcher,  in removeWatches()
305         Set<Watcher> removedWatchers) throws KeeperException {  in removeWatches()
316                 Set<Watcher> pathWatchers = pathVsWatcher.remove(path);  in removeWatches()
323                 Set<Watcher> watchers = pathVsWatcher.get(path);  in removeWatches()
345     public Set<Watcher> materialize(  in materialize()
346         Watcher.Event.KeeperState state,  in materialize()
347         Watcher.Event.EventType type,  in materialize()
350         final Set<Watcher> result = new HashSet<>();  in materialize()
358 …         boolean clear = disableAutoWatchReset && state != Watcher.Event.KeeperState.SyncConnected;  in materialize()
360                 for (Set<Watcher> ws : dataWatches.values()) {  in materialize()
369                 for (Set<Watcher> ws : existWatches.values()) {  in materialize()
378                 for (Set<Watcher> ws : childWatches.values()) {  in materialize()
387                 for (Set<Watcher> ws: persistentWatches.values()) {  in materialize()
393                 for (Set<Watcher> ws: persistentRecursiveWatches.values()) {  in materialize()
421                 Set<Watcher> list = existWatches.remove(clientPath);  in materialize()
445     private void addPersistentWatches(String clientPath, Set<Watcher> result) {  in addPersistentWatches()