/dports/sysutils/py-pywatchman/watchman-4.9.0/watcher/ |
H A D | kqueue.cpp | 112 auto wlock = maps_.wlock(); in startWatchFile() local 126 auto wlock = maps_.wlock(); in startWatchFile() local 127 wlock->name_to_fd.erase(full_name); in startWatchFile() 128 wlock->fd_to_name.erase(rawFd); in startWatchFile() 186 auto wlock = maps_.wlock(); in startWatchDir() local 195 auto wlock = maps_.wlock(); in startWatchDir() local 196 wlock->name_to_fd.erase(dir_name); in startWatchDir() 197 wlock->fd_to_name.erase(rawFd); in startWatchDir() 239 auto wlock = maps_.wlock(); in consumeNotify() local 275 wlock->name_to_fd.erase(path); in consumeNotify() [all …]
|
H A D | inotify.cpp | 112 auto wlock = maps.wlock(); in InotifyWatcher() local 113 wlock->wd_to_name.reserve( in InotifyWatcher() 149 auto wlock = maps.wlock(); in startWatchDir() local 150 wlock->wd_to_name[newwd] = dir_name; in startWatchDir() 207 auto wlock = maps.wlock(); in process_inotify_event() local 218 auto wlock = maps.wlock(); in process_inotify_event() local 220 if (it != wlock->move_map.end()) { in process_inotify_event() 242 wlock->wd_to_name[wd] = name; in process_inotify_event() 295 auto wlock = maps.wlock(); in process_inotify_event() local 350 auto wlock = maps.wlock(); in consumeNotify() local [all …]
|
H A D | win32.cpp | 128 auto wlock = changedItems.wlock(); in readChangesThread() local 278 auto wlock = changedItems.wlock(); in readChangesThread() local 279 wlock->splice(wlock->end(), items); in readChangesThread() 298 auto wlock = changedItems.wlock(); in start() local 313 auto wlock = self->changedItems.wlock(); in start() local 322 if (cond.wait_for(wlock.getUniqueLock(), std::chrono::seconds(10)) == in start() 359 auto wlock = changedItems.wlock(); in consumeNotify() local 360 std::swap(items, *wlock); in consumeNotify() 375 auto wlock = changedItems.wlock(); in waitNotify() local 376 cond.wait_for(wlock.getUniqueLock(), std::chrono::milliseconds(timeoutms)); in waitNotify() [all …]
|
H A D | fsevents.cpp | 252 auto wlock = watcher->items_.wlock(); in fse_callback() local 253 std::move(items.begin(), items.end(), std::back_inserter(*wlock)); in fse_callback() 449 auto wlock = items_.wlock(); in FSEventsThread() local 514 auto wlock = items_.wlock(); in consumeNotify() local 515 std::swap(items, *wlock); in consumeNotify() 587 auto wlock = items_.wlock(); in start() local 608 fse_cond.wait(wlock.getUniqueLock()); in start() 627 auto wlock = items_.wlock(); in waitNotify() local 629 wlock.getUniqueLock(), std::chrono::milliseconds(timeoutms)); in waitNotify() 630 return !wlock->empty(); in waitNotify() [all …]
|
/dports/sysutils/py-pywatchman/watchman-4.9.0/ |
H A D | PubSub.cpp | 19 auto wlock = publisher_->state_.wlock(); in ~Subscriber() local 20 auto it = wlock->subscribers.begin(); in ~Subscriber() 21 while (it != wlock->subscribers.end()) { in ~Subscriber() 25 it = wlock->subscribers.erase(it); in ~Subscriber() 32 wlock->collectGarbage(); in ~Subscriber() 120 auto wlock = state_.wlock(); in enqueue() local 125 auto it = wlock->subscribers.begin(); in enqueue() 126 while (it != wlock->subscribers.end()) { in enqueue() 130 it = wlock->subscribers.erase(it); in enqueue() 139 wlock->collectGarbage(); in enqueue() [all …]
|
H A D | perf.cpp | 34 auto wlock = samples_.wlock(); in addSample() local 35 if (!*wlock) { in addSample() 36 *wlock = json_array(); in addSample() 38 json_array_append_new(*wlock, std::move(sample)); in addSample() 168 auto wlock = samples_.wlock(); in loop() local 169 if (!*wlock) { in loop() 170 cond_.wait(wlock.getUniqueLock()); in loop() 174 std::swap(samples, *wlock); in loop()
|
H A D | CookieSync.cpp | 56 auto wlock = cookies_.wlock(); in sync() local 57 auto& map = *wlock; in sync() 67 cookies_.wlock()->erase(path_str); in sync() 119 auto map = cookies_.wlock(); in abortAllCookies() 134 auto map = cookies_.wlock(); in notifyCookie()
|
/dports/devel/folly/folly-2021.12.27.00/folly/test/ |
H A D | SynchronizedTest.cpp | 417 auto wlock = sync.wlock(); in TEST_F() local 435 auto wlock = sync.wlock(); in TEST_F() local 436 auto slock = wlock.moveFromWriteToRead(); in TEST_F() 480 sync.withWLockPtr([](auto wlock) { in TEST_F() argument 518 sync.withWLockPtr([](auto wlock) { in TEST_F() argument 823 auto wlock = synchronized.wlock(); in TEST_F() local 824 wlock.unlock(); in TEST_F() 827 wlock = ulock.moveFromUpgradeToWrite(); in TEST_F() 828 wlock.unlock(); in TEST_F() 841 lock(folly::wlock(one), folly::rlock(two), folly::wlock(three)); in TEST() [all …]
|
/dports/net/fb303/fb303-83ae662219660d30b49ad8474f5c63bbfc6d5f6f/fb303/ |
H A D | ExportedStatMap.cpp | 85 auto wlock = ulock.moveFromUpgradeToWrite(); in getStatPtrNoExport() local 86 auto item = wlock->try_emplace(name, std::move(value)); in getStatPtrNoExport() 95 auto lockedStatMap = statMap_.wlock(); in unExportStatAll() 107 statMap_.wlock()->clear(); in forgetAllStats() 111 statMap_.wlock()->erase(name); in forgetStatsFor() 115 auto lockedStatMap = statMap_.wlock(); in clearAllStats()
|
/dports/devel/folly/folly-2021.12.27.00/folly/io/async/ |
H A D | EventBaseLocal.cpp | 35 auto locked = eventBases_.wlock(); in ~EventBaseLocalBase() 57 evb.localStorageToDtor_.wlock()->erase(this); in erase() 59 eventBases_.wlock()->erase(&evb); in erase() 85 eventBases_.wlock()->insert(&evb); in setVoid() 86 evb.localStorageToDtor_.wlock()->insert(this); in setVoid()
|
/dports/sysutils/lizardfs/lizardfs-3.12.0/src/master/ |
H A D | flocks_unittest.cc | 35 bool wlock(FileLocks &locks, uint32_t inode, uint64_t owner, bool nonblocking = false) { in wlock() function 89 EXPECT_FALSE(wlock(locks, 0, USER3)); in TEST() 94 EXPECT_TRUE(wlock(locks, 0, USER2)); in TEST() 99 EXPECT_FALSE(wlock(locks, 0, USER3)); in TEST() 137 EXPECT_FALSE(wlock(locks, 0, USER1, nonblocking)); in TEST() 139 EXPECT_FALSE(wlock(locks, 0, USER2)); in TEST() 141 EXPECT_FALSE(wlock(locks, 0, USER3, nonblocking)); in TEST()
|
/dports/devel/mercurial/mercurial-6.0/mercurial/ |
H A D | upgrade.py | 193 with repo.wlock(), repo.lock(): 215 with dstrepo.wlock(), dstrepo.lock(): 248 wlock = None 263 wlock = lockmod.trylock(ui, hgvfs, b'wlock', 0, 0) 296 if wlock: 297 wlock.release() 309 wlock = None 322 wlock = lockmod.trylock(ui, hgvfs, b'wlock', 0, 0) 355 if wlock: 356 wlock.release()
|
/dports/textproc/zorba/zorba-2.7.0/src/zorbautils/ |
H A D | latch.h | 48 void wlock(); 93 void wlock(); 172 theLatch.wlock(); in AutoLatch() 188 void wlock() {}
|
/dports/devel/mercurial/mercurial-6.0/tests/ |
H A D | test-debugcommands.t | 419 wlock: free 449 wlock: free 456 * Test setting the wlock 459 $ waitlock .hg/wlock 467 $ [ -f .hg/wlock ] || echo "There is no wlock" 468 There is no wlock 495 wlock: free 504 wlock: free 511 wlock: free 519 $ waitlock .hg/wlock [all …]
|
/dports/sysutils/py-pywatchman/watchman-4.9.0/root/ |
H A D | iothread.cpp | 41 auto view = view_.wlock(); in fullCrawl() 47 pending_.wlock()->add(root->root_path, start, W_PENDING_RECURSIVE); in fullCrawl() 121 auto lock = pending.wlock(); in clientModeCrawl() 134 auto info = root->recrawlInfo.wlock(); in handleShouldRecrawl() 145 auto localPendingLock = pending.wlock(); in ioThread() 202 auto view = view_.wlock(); in ioThread() 274 auto srcLock = pending_.wlock(); in processPending()
|
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/containerd/containerd/containerd-1.4.3/metadata/ |
H A D | db.go | 77 wlock sync.RWMutex member 243 m.wlock.RLock() 244 defer m.wlock.RUnlock() 262 m.wlock.Lock() 264 m.wlock.Unlock() 281 m.wlock.Lock() 286 m.wlock.Unlock() 315 m.wlock.Unlock() 358 m.wlock.Unlock()
|
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/containerd/containerd/metadata/ |
H A D | db.go | 77 wlock sync.RWMutex member 243 m.wlock.RLock() 244 defer m.wlock.RUnlock() 262 m.wlock.Lock() 264 m.wlock.Unlock() 281 m.wlock.Lock() 286 m.wlock.Unlock() 315 m.wlock.Unlock() 358 m.wlock.Unlock()
|
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/docker/docker/vendor/github.com/containerd/containerd/metadata/ |
H A D | db.go | 77 wlock sync.RWMutex member 243 m.wlock.RLock() 244 defer m.wlock.RUnlock() 262 m.wlock.Lock() 264 m.wlock.Unlock() 281 m.wlock.Lock() 286 m.wlock.Unlock() 315 m.wlock.Unlock() 358 m.wlock.Unlock()
|
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/containerd/containerd/metadata/ |
H A D | db.go | 77 wlock sync.RWMutex member 243 m.wlock.RLock() 244 defer m.wlock.RUnlock() 262 m.wlock.Lock() 264 m.wlock.Unlock() 281 m.wlock.Lock() 286 m.wlock.Unlock() 315 m.wlock.Unlock() 358 m.wlock.Unlock()
|
/dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/docker/docker/vendor/github.com/containerd/containerd/metadata/ |
H A D | db.go | 77 wlock sync.RWMutex member 243 m.wlock.RLock() 244 defer m.wlock.RUnlock() 262 m.wlock.Lock() 264 m.wlock.Unlock() 281 m.wlock.Lock() 286 m.wlock.Unlock() 315 m.wlock.Unlock() 358 m.wlock.Unlock()
|
/dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/containerd/containerd/metadata/ |
H A D | db.go | 77 wlock sync.RWMutex member 243 m.wlock.RLock() 244 defer m.wlock.RUnlock() 262 m.wlock.Lock() 264 m.wlock.Unlock() 281 m.wlock.Lock() 286 m.wlock.Unlock() 315 m.wlock.Unlock() 358 m.wlock.Unlock()
|
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/containerd/containerd/metadata/ |
H A D | db.go | 77 wlock sync.RWMutex member 243 m.wlock.RLock() 244 defer m.wlock.RUnlock() 262 m.wlock.Lock() 264 m.wlock.Unlock() 281 m.wlock.Lock() 286 m.wlock.Unlock() 315 m.wlock.Unlock() 358 m.wlock.Unlock()
|
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/docker/docker/vendor/github.com/containerd/containerd/metadata/ |
H A D | db.go | 77 wlock sync.RWMutex member 243 m.wlock.RLock() 244 defer m.wlock.RUnlock() 262 m.wlock.Lock() 264 m.wlock.Unlock() 281 m.wlock.Lock() 286 m.wlock.Unlock() 315 m.wlock.Unlock() 358 m.wlock.Unlock()
|
/dports/sysutils/helm/helm-3.5.2/vendor/github.com/containerd/containerd/metadata/ |
H A D | db.go | 77 wlock sync.RWMutex member 243 m.wlock.RLock() 244 defer m.wlock.RUnlock() 262 m.wlock.Lock() 264 m.wlock.Unlock() 281 m.wlock.Lock() 286 m.wlock.Unlock() 315 m.wlock.Unlock() 358 m.wlock.Unlock()
|
/dports/security/vault/vault-1.8.2/vendor/github.com/containerd/containerd/metadata/ |
H A D | db.go | 77 wlock sync.RWMutex member 243 m.wlock.RLock() 244 defer m.wlock.RUnlock() 262 m.wlock.Lock() 264 m.wlock.Unlock() 281 m.wlock.Lock() 286 m.wlock.Unlock() 315 m.wlock.Unlock() 358 m.wlock.Unlock()
|