| /dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/test/java/org/apache/zookeeper/server/watch/ |
| H A D | WatchManagerTest.java | 54 private ConcurrentHashMap<Integer, DumbWatcher> watchers; field in WatchManagerTest
87 private final int watchers; field in WatchManagerTest.AddWatcherWorker
92 IWatchManager manager, int paths, int watchers, AtomicInteger watchesAdded) { in AddWatcherWorker()
155 private final int watchers; field in WatchManagerTest.RemoveWatcherWorker
160 IWatchManager manager, int paths, int watchers, AtomicInteger watchesRemoved) { in RemoveWatcherWorker()
191 private final int watchers; field in WatchManagerTest.CreateDeadWatchersWorker
196 IWatchManager manager, int watchers, Set<Watcher> removedWatchers) { in CreateDeadWatchersWorker()
234 int watchers = 10000; in testAddAndTriggerWatcher() local
295 int watchers = 10000; in testRemoveWatcherOnPath() local
358 int watchers = 100000; in testDeadWatchers() local
|
| /dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/main/java/org/apache/zookeeper/server/watch/ |
| H A D | WatchManagerOptimized.java | 88 BitHashSet watchers = pathWatches.get(path); in addWatch() local
122 BitHashSet watchers = pathWatches.get(path); in containsWatcher() local
213 BitHashSet watchers = remove(path); in triggerWatch() local
326 BitHashSet watchers = e.getValue(); in getWatchesByPath() local
349 BitHashSet watchers = e.getValue(); in getWatcher2PathesMap() local
372 BitHashSet watchers = e.getValue(); in dumpWatches() local
|
| H A D | WatcherOrBitSet.java | 27 private Set<Watcher> watchers; field in WatcherOrBitSet
30 public WatcherOrBitSet(final Set<Watcher> watchers) { in WatcherOrBitSet()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/chrome/browser/chromeos/file_system_provider/ |
| H A D | provided_file_system_unittest.cc | 161 const Watchers& watchers) override { in OnWatcherListChanged()
348 Watchers* const watchers = provided_file_system_->GetWatchers(); in TEST_F() local
375 Watchers* const watchers = provided_file_system_->GetWatchers(); in TEST_F() local
472 Watchers* const watchers = provided_file_system_->GetWatchers(); in TEST_F() local
544 Watchers* const watchers = provided_file_system_->GetWatchers(); in TEST_F() local
578 Watchers* const watchers = provided_file_system_->GetWatchers(); in TEST_F() local
608 Watchers* const watchers = provided_file_system_->GetWatchers(); in TEST_F() local
664 Watchers* const watchers = provided_file_system_->GetWatchers(); in TEST_F() local
681 Watchers* const watchers = provided_file_system_->GetWatchers(); in TEST_F() local
703 Watchers* const watchers = provided_file_system_->GetWatchers(); in TEST_F() local
[all …]
|
| H A D | fake_registry.cc | 18 const Watchers& watchers) { in RememberFileSystem()
67 const Watchers* FakeRegistry::watchers() const { in watchers() function in chromeos::file_system_provider::FakeRegistry
|
| H A D | registry.cc | 53 const Watchers& watchers) { in RememberFileSystem()
193 const base::DictionaryValue* watchers = NULL; in RestoreFileSystems() local
264 base::DictionaryValue* watchers = NULL; in UpdateWatcherTag() local
|
| /dports/devel/grpc134/grpc-1.34.1/src/core/ext/xds/ |
| H A D | xds_client.h | 244 watchers; member
252 watchers; member
259 watchers; member
267 watchers; member
|
| /dports/audio/spotifyd/spotifyd-0.3.0/cargo-crates/tokio-0.2.11/src/sync/ |
| H A D | watch.rs | 135 watchers: Mutex<Watchers>, field
144 watchers: FnvHashMap<u64, Arc<WatchInner>>, field
187 let mut watchers = FnvHashMap::with_capacity_and_hasher(0, Default::default()); in channel() localVariable
319 let mut watchers = shared.watchers.lock().unwrap(); in clone() localVariable
341 let mut watchers = self.shared.watchers.lock().unwrap(); in drop() localVariable
400 let watchers = shared.watchers.lock().unwrap(); in notify_all() localVariable
|
| /dports/devel/grpc/grpc-1.42.0/src/core/ext/xds/ |
| H A D | xds_client.h | 262 watchers; member
271 watchers; member
279 watchers; member
288 watchers; member
|
| /dports/devel/pecl-grpc/grpc-1.42.0/src/core/ext/xds/ |
| H A D | xds_client.h | 262 watchers; member
271 watchers; member
279 watchers; member
288 watchers; member
|
| /dports/mail/nextcloud-mail/mail/vendor/amphp/amp/lib/Loop/ |
| H A D | UvDriver.php | 19 private $watchers = []; variable in Amp\\Loop\\UvDriver
223 protected function activate(array $watchers)
|
| /dports/devel/py-grpcio/grpcio-1.43.0/src/core/ext/xds/ |
| H A D | xds_client.h | 269 watchers; member
278 watchers; member
286 watchers; member
294 watchers; member
|
| /dports/multimedia/librespot/librespot-0.1.3/cargo-crates/tokio-sync-0.1.8/src/ |
| H A D | watch.rs | 164 watchers: Mutex<Watchers>, field
173 watchers: FnvHashMap<u64, Arc<WatchInner>>, field
216 let mut watchers = FnvHashMap::with_capacity_and_hasher(0, Default::default()); in channel() localVariable
312 let mut watchers = shared.watchers.lock().unwrap(); in clone() localVariable
334 let mut watchers = self.shared.watchers.lock().unwrap(); in drop() localVariable
403 let watchers = shared.watchers.lock().unwrap(); in notify_all() localVariable
|
| /dports/devel/sccache/sccache-0.2.15/cargo-crates/tokio-sync-0.1.8/src/ |
| H A D | watch.rs | 164 watchers: Mutex<Watchers>, field
173 watchers: FnvHashMap<u64, Arc<WatchInner>>, field
216 let mut watchers = FnvHashMap::with_capacity_and_hasher(0, Default::default()); in channel() localVariable
312 let mut watchers = shared.watchers.lock().unwrap(); in clone() localVariable
334 let mut watchers = self.shared.watchers.lock().unwrap(); in drop() localVariable
403 let watchers = shared.watchers.lock().unwrap(); in notify_all() localVariable
|
| /dports/net-mgmt/nfs-exporter/freebsd-nfs-exporter-0.3.0/cargo-crates/tokio-sync-0.1.8/src/ |
| H A D | watch.rs | 164 watchers: Mutex<Watchers>, field
173 watchers: FnvHashMap<u64, Arc<WatchInner>>, field
216 let mut watchers = FnvHashMap::with_capacity_and_hasher(0, Default::default()); in channel() localVariable
312 let mut watchers = shared.watchers.lock().unwrap(); in clone() localVariable
334 let mut watchers = self.shared.watchers.lock().unwrap(); in drop() localVariable
403 let watchers = shared.watchers.lock().unwrap(); in notify_all() localVariable
|
| /dports/www/ffsend/ffsend-ccd489ce2e75b91c0f17fbf13dbd91fe84f5ad98/cargo-crates/tokio-sync-0.1.8/src/ |
| H A D | watch.rs | 164 watchers: Mutex<Watchers>, field
173 watchers: FnvHashMap<u64, Arc<WatchInner>>, field
216 let mut watchers = FnvHashMap::with_capacity_and_hasher(0, Default::default()); in channel() localVariable
312 let mut watchers = shared.watchers.lock().unwrap(); in clone() localVariable
334 let mut watchers = self.shared.watchers.lock().unwrap(); in drop() localVariable
403 let watchers = shared.watchers.lock().unwrap(); in notify_all() localVariable
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/tokio-sync-0.1.7/src/ |
| H A D | watch.rs | 164 watchers: Mutex<Watchers>, field
173 watchers: FnvHashMap<u64, Arc<WatchInner>>, field
216 let mut watchers = FnvHashMap::with_capacity_and_hasher(0, Default::default()); in channel() localVariable
312 let mut watchers = shared.watchers.lock().unwrap(); in clone() localVariable
334 let mut watchers = self.shared.watchers.lock().unwrap(); in drop() localVariable
403 let watchers = shared.watchers.lock().unwrap(); in notify_all() localVariable
|
| /dports/editors/xi-term/xi-term-d264767/cargo-crates/tokio-sync-0.1.6/src/ |
| H A D | watch.rs | 164 watchers: Mutex<Watchers>, field
173 watchers: FnvHashMap<u64, Arc<WatchInner>>, field
216 let mut watchers = FnvHashMap::with_capacity_and_hasher(0, Default::default()); in channel() localVariable
312 let mut watchers = shared.watchers.lock().unwrap(); in clone() localVariable
334 let mut watchers = self.shared.watchers.lock().unwrap(); in drop() localVariable
403 let watchers = shared.watchers.lock().unwrap(); in notify_all() localVariable
|
| /dports/security/sequoia/sequoia-383133f6be990237044900a4df676488bf8dd71e/cargo-crates/tokio-sync-0.1.8/src/ |
| H A D | watch.rs | 164 watchers: Mutex<Watchers>, field
173 watchers: FnvHashMap<u64, Arc<WatchInner>>, field
216 let mut watchers = FnvHashMap::with_capacity_and_hasher(0, Default::default()); in channel() localVariable
312 let mut watchers = shared.watchers.lock().unwrap(); in clone() localVariable
334 let mut watchers = self.shared.watchers.lock().unwrap(); in drop() localVariable
403 let watchers = shared.watchers.lock().unwrap(); in notify_all() localVariable
|
| /dports/www/websocat/websocat-1.9.0/cargo-crates/tokio-sync-0.1.8/src/ |
| H A D | watch.rs | 164 watchers: Mutex<Watchers>, field
173 watchers: FnvHashMap<u64, Arc<WatchInner>>, field
216 let mut watchers = FnvHashMap::with_capacity_and_hasher(0, Default::default()); in channel() localVariable
312 let mut watchers = shared.watchers.lock().unwrap(); in clone() localVariable
334 let mut watchers = self.shared.watchers.lock().unwrap(); in drop() localVariable
403 let watchers = shared.watchers.lock().unwrap(); in notify_all() localVariable
|
| /dports/audio/spotifyd/spotifyd-0.3.0/cargo-crates/tokio-sync-0.1.7/src/ |
| H A D | watch.rs | 164 watchers: Mutex<Watchers>, field
173 watchers: FnvHashMap<u64, Arc<WatchInner>>, field
216 let mut watchers = FnvHashMap::with_capacity_and_hasher(0, Default::default()); in channel() localVariable
312 let mut watchers = shared.watchers.lock().unwrap(); in clone() localVariable
334 let mut watchers = self.shared.watchers.lock().unwrap(); in drop() localVariable
403 let watchers = shared.watchers.lock().unwrap(); in notify_all() localVariable
|
| /dports/sysutils/flowgger/flowgger-0.2.10/cargo-crates/tokio-sync-0.1.6/src/ |
| H A D | watch.rs | 164 watchers: Mutex<Watchers>, field
173 watchers: FnvHashMap<u64, Arc<WatchInner>>, field
216 let mut watchers = FnvHashMap::with_capacity_and_hasher(0, Default::default()); in channel() localVariable
312 let mut watchers = shared.watchers.lock().unwrap(); in clone() localVariable
334 let mut watchers = self.shared.watchers.lock().unwrap(); in drop() localVariable
403 let watchers = shared.watchers.lock().unwrap(); in notify_all() localVariable
|
| /dports/sysutils/rsfetch/rsfetch-2.0.0/cargo-crates/tokio-sync-0.1.8/src/ |
| H A D | watch.rs | 164 watchers: Mutex<Watchers>, field
173 watchers: FnvHashMap<u64, Arc<WatchInner>>, field
216 let mut watchers = FnvHashMap::with_capacity_and_hasher(0, Default::default()); in channel() localVariable
312 let mut watchers = shared.watchers.lock().unwrap(); in clone() localVariable
334 let mut watchers = self.shared.watchers.lock().unwrap(); in drop() localVariable
403 let watchers = shared.watchers.lock().unwrap(); in notify_all() localVariable
|
| /dports/cad/abc/abc-a4518e6f833885c905964f1233d11e5b941ec24c/src/sat/satoko/ |
| H A D | watch_list.h | 27 struct watcher *watchers; member
72 struct watcher *watchers = in watch_list_grow() local
107 struct watcher *watchers = watch_list_array(wl); in watch_list_remove() local
|
| /dports/x11-toolkits/kf5-kirigami2/kirigami2-5.89.0/src/libkirigami/ |
| H A D | basictheme_p.h | 166 QVector<BasicTheme *> watchers; variable
|