| /dports/devel/quantum/quantum-2.2/tests/ |
| H A D | quantum_locks_tests.cpp | 347 ReadWriteSpinLock::Guard guard(lock, lock::acquireRead); in TEST()
435 ReadWriteSpinLock::Guard guard(lock, lock::acquireRead); in TEST()
764 ReadWriteMutex::Guard guard(mutex, lock::acquireRead); in TEST()
804 ReadWriteMutex::Guard guard(mutex, lock::acquireRead); in TEST()
883 ReadWriteMutex::Guard guard(mutex, lock::acquireRead); in TEST()
898 ReadWriteMutex::Guard guard(mutex, lock::acquireRead); in TEST()
910 ReadWriteMutex::Guard guard(mutex, lock::acquireRead); in TEST()
924 ReadWriteMutex::Guard guard(mutex, lock::acquireRead); in TEST()
941 ReadWriteMutex::Guard guard(mutex, lock::acquireRead); in TEST()
963 ReadWriteMutex::Guard guard(mutex, lock::acquireRead); in TEST()
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/thrift/contrib/fb303/cpp/ |
| H A D | FacebookBase.cpp | 50 counters_.acquireRead(); in incrementCounter()
77 counters_.acquireRead(); in setCounter()
99 counters_.acquireRead(); in getCounters()
110 counters_.acquireRead(); in getCounter()
113 it->second.acquireRead(); in getCounter()
|
| /dports/net/storj/storj-1.45.3/vendor/github.com/apache/thrift/contrib/fb303/cpp/ |
| H A D | FacebookBase.cpp | 50 counters_.acquireRead(); in incrementCounter()
77 counters_.acquireRead(); in setCounter()
99 counters_.acquireRead(); in getCounters()
110 counters_.acquireRead(); in getCounter()
113 it->second.acquireRead(); in getCounter()
|
| /dports/www/fabio/fabio-1.5.14/vendor/github.com/apache/thrift/thrift-da1169d75b15/contrib/fb303/cpp/ |
| H A D | FacebookBase.cpp | 50 counters_.acquireRead(); in incrementCounter()
77 counters_.acquireRead(); in setCounter()
99 counters_.acquireRead(); in getCounters()
110 counters_.acquireRead(); in getCounter()
113 it->second.acquireRead(); in getCounter()
|
| /dports/devel/thrift-cpp/thrift-0.14.0/contrib/fb303/cpp/ |
| H A D | FacebookBase.cpp | 50 counters_.acquireRead(); in incrementCounter()
77 counters_.acquireRead(); in setCounter()
99 counters_.acquireRead(); in getCounters()
110 counters_.acquireRead(); in getCounter()
113 it->second.acquireRead(); in getCounter()
|
| /dports/devel/thrift-c_glib/thrift-0.14.0/contrib/fb303/cpp/ |
| H A D | FacebookBase.cpp | 50 counters_.acquireRead(); in incrementCounter()
77 counters_.acquireRead(); in setCounter()
99 counters_.acquireRead(); in getCounters()
110 counters_.acquireRead(); in getCounter()
113 it->second.acquireRead(); in getCounter()
|
| /dports/devel/thrift/thrift-0.14.0/contrib/fb303/cpp/ |
| H A D | FacebookBase.cpp | 50 counters_.acquireRead(); in incrementCounter()
77 counters_.acquireRead(); in setCounter()
99 counters_.acquireRead(); in getCounters()
110 counters_.acquireRead(); in getCounter()
113 it->second.acquireRead(); in getCounter()
|
| /dports/misc/concourse/concourse-6.7.2/vendor/github.com/apache/thrift/contrib/fb303/cpp/ |
| H A D | FacebookBase.cpp | 50 counters_.acquireRead(); in incrementCounter()
77 counters_.acquireRead(); in setCounter()
99 counters_.acquireRead(); in getCounters()
110 counters_.acquireRead(); in getCounter()
113 it->second.acquireRead(); in getCounter()
|
| /dports/devel/node-thrift/thrift-0.14.0/contrib/fb303/cpp/ |
| H A D | FacebookBase.cpp | 50 counters_.acquireRead(); in incrementCounter()
77 counters_.acquireRead(); in setCounter()
99 counters_.acquireRead(); in getCounters()
110 counters_.acquireRead(); in getCounter()
113 it->second.acquireRead(); in getCounter()
|
| /dports/devel/py-thrift/thrift-0.14.0/contrib/fb303/cpp/ |
| H A D | FacebookBase.cpp | 50 counters_.acquireRead(); in incrementCounter()
77 counters_.acquireRead(); in setCounter()
99 counters_.acquireRead(); in getCounters()
110 counters_.acquireRead(); in getCounter()
113 it->second.acquireRead(); in getCounter()
|
| /dports/www/fabio/fabio-1.5.14/vendor/github.com/apache/thrift/thrift-da1169d75b15/lib/cpp/src/thrift/concurrency/ |
| H A D | Mutex.h | 98 virtual void acquireRead() const;
124 virtual void acquireRead() const;
169 rw_mutex_.acquireRead(); in rw_mutex_()
177 rw_mutex_.acquireRead(); in RWGuard()
|
| H A D | Mutex.cpp | 297 void acquireRead() const { in acquireRead() function in apache::thrift::concurrency::ReadWriteMutex::impl
330 void ReadWriteMutex::acquireRead() const { in acquireRead() function in apache::thrift::concurrency::ReadWriteMutex
331 impl_->acquireRead(); in acquireRead()
353 void NoStarveReadWriteMutex::acquireRead() const { in acquireRead() function in apache::thrift::concurrency::NoStarveReadWriteMutex
360 ReadWriteMutex::acquireRead(); in acquireRead()
|
| /dports/net/storj/storj-1.45.3/vendor/github.com/apache/thrift/lib/cpp/src/thrift/concurrency/ |
| H A D | Mutex.h | 98 virtual void acquireRead() const;
124 virtual void acquireRead() const;
169 rw_mutex_.acquireRead(); in rw_mutex_()
177 rw_mutex_.acquireRead(); in RWGuard()
|
| H A D | Mutex.cpp | 297 void acquireRead() const { in acquireRead() function in apache::thrift::concurrency::ReadWriteMutex::impl
330 void ReadWriteMutex::acquireRead() const { in acquireRead() function in apache::thrift::concurrency::ReadWriteMutex
331 impl_->acquireRead(); in acquireRead()
353 void NoStarveReadWriteMutex::acquireRead() const { in acquireRead() function in apache::thrift::concurrency::NoStarveReadWriteMutex
360 ReadWriteMutex::acquireRead(); in acquireRead()
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/utils/thrift/thrift/concurrency/ |
| H A D | Mutex.h | 95 virtual void acquireRead() const;
123 virtual void acquireRead() const;
193 rw_mutex_.acquireRead(); in rw_mutex_()
206 rw_mutex_.acquireRead(); in RWGuard()
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/utils/thrift/thrift/concurrency/ |
| H A D | Mutex.h | 95 virtual void acquireRead() const;
123 virtual void acquireRead() const;
193 rw_mutex_.acquireRead(); in rw_mutex_()
206 rw_mutex_.acquireRead(); in RWGuard()
|
| /dports/lang/zig-devel/zig-0.9.0/lib/std/event/ |
| H A D | rwlocked.zig | 43 pub fn acquireRead(self: *Self) callconv(.Async) HeldReadLock {
45 .held = self.lock.acquireRead(),
|
| /dports/lang/zig/zig-0.9.0/lib/std/event/ |
| H A D | rwlocked.zig | 43 pub fn acquireRead(self: *Self) callconv(.Async) HeldReadLock {
45 .held = self.lock.acquireRead(),
|
| /dports/math/vampire/vampire-4.5.1/UnitTests/ |
| H A D | tfork.cpp | 142 p1.acquireRead(); in TEST_FUN()
171 p1.acquireRead(); in TEST_FUN()
201 p2.acquireRead(); in TEST_FUN()
|
| /dports/www/typo3-11/typo3_src-11.5.7/vendor/symfony/lock/ |
| H A D | SharedLockInterface.php | 33 public function acquireRead(bool $blocking = false); function
|
| /dports/math/vampire/vampire-4.5.1/Lib/Sys/ |
| H A D | SyncPipe.hpp | 32 void acquireRead();
|
| /dports/devel/quantum/quantum-2.2/quantum/ |
| H A D | quantum_spinlock_traits.h | 95 static constexpr const LockTraits::AcquireRead acquireRead; variable
|
| /dports/devel/hs-git-annex/git-annex-8.20210903/_cabal_deps/SafeSemaphore-0.10.1/src/Control/Concurrent/ |
| H A D | FairRWLock.hs | 40 , acquireRead, acquireWrite
116 withRead = liftA2 bracket_ acquireRead (releaseRead >=> either throw return)
399 acquireRead :: RWLock -> IO ()
400 acquireRead (RWL rwlVar) = mask_ . join . modifyMVar rwlVar $ \ rwd -> do function
|
| /dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/src/java.base/share/classes/java/util/concurrent/locks/ |
| H A D | StampedLock.java | 554 return acquireRead(false, false, 0L); in readLock()
589 nextState = acquireRead(true, true, System.nanoTime() + nanos); in tryReadLock()
610 (nextState = acquireRead(true, false, 0L)) != INTERRUPTED)) in readLockInterruptibly()
1273 private long acquireRead(boolean interruptible, boolean timed, long time) { in acquireRead() method in StampedLock
|
| /dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/src/java.base/share/classes/java/util/concurrent/locks/ |
| H A D | StampedLock.java | 554 return acquireRead(false, false, 0L); in readLock()
589 nextState = acquireRead(true, true, System.nanoTime() + nanos); in tryReadLock()
610 (nextState = acquireRead(true, false, 0L)) != INTERRUPTED)) in readLockInterruptibly()
1273 private long acquireRead(boolean interruptible, boolean timed, long time) { in acquireRead() method in StampedLock
|