Home
last modified time | relevance | path

Searched refs:wlock (Results 1 – 25 of 655) sorted by relevance

12345678910>>...27

/dports/sysutils/py-pywatchman/watchman-4.9.0/watcher/
H A Dkqueue.cpp112 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 Dinotify.cpp112 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 Dwin32.cpp128 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 Dfsevents.cpp252 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 DPubSub.cpp19 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 Dperf.cpp34 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 DCookieSync.cpp56 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 DSynchronizedTest.cpp417 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 DExportedStatMap.cpp85 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 DEventBaseLocal.cpp35 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 Dflocks_unittest.cc35 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 Dupgrade.py193 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 Dlatch.h48 void wlock();
93 void wlock();
172 theLatch.wlock(); in AutoLatch()
188 void wlock() {}
/dports/devel/mercurial/mercurial-6.0/tests/
H A Dtest-debugcommands.t419 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 Diothread.cpp41 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 Ddb.go77 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 Ddb.go77 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 Ddb.go77 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 Ddb.go77 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 Ddb.go77 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 Ddb.go77 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 Ddb.go77 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 Ddb.go77 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 Ddb.go77 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 Ddb.go77 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()

12345678910>>...27