| /third_party/python/Lib/test/ |
| D | lock_tests.py | 109 lock.acquire()
115 lock.acquire()
120 lock.acquire()
126 self.assertTrue(lock.acquire(False))
131 lock.acquire()
134 result.append(lock.acquire(False))
141 lock.acquire()
144 lock.acquire()
158 lock.acquire()
176 lock.acquire()
[all …]
|
| D | test_threadsignals.py | 47 signalled_all.acquire()
49 signalled_all.acquire()
96 lock.acquire()
99 self.assertRaises(KeyboardInterrupt, lock.acquire, timeout=5)
130 rlock.acquire()
135 while rlock.acquire(blocking=False):
140 self.assertRaises(KeyboardInterrupt, rlock.acquire, timeout=5)
158 lock.acquire()
171 while lock.acquire(blocking=False):
174 result = lock.acquire() # Block while we receive a signal.
[all …]
|
| D | test_thread.py | 29 self.done_mutex.acquire()
67 self.done_mutex.acquire()
103 self.done_mutex.acquire()
112 mut.acquire()
117 mut.acquire()
146 started.acquire()
148 started.acquire()
163 self.checkout_mutex.acquire()
166 self.checkin_mutex.acquire()
174 self.checkout_mutex.acquire()
[all …]
|
| /third_party/python/Lib/test/test_asyncio/ |
| D | test_locks.py | 29 await lock.acquire()
97 self.assertTrue(await lock.acquire())
100 if await lock.acquire():
105 if await lock.acquire():
110 if await lock.acquire():
146 self.assertTrue(await lock.acquire())
148 task = asyncio.create_task(lock.acquire())
172 await lock.acquire()
214 await lock.acquire()
221 await lock.acquire()
[all …]
|
| /third_party/python/Lib/multiprocessing/ |
| D | synchronize.py | 91 self.acquire = self._semlock.acquire
236 self.acquire = self._lock.acquire
261 return self._wait_semaphore.acquire(True, timeout)
268 self._lock.acquire()
272 assert not self._wait_semaphore.acquire(
278 while self._woken_count.acquire(False):
279 res = self._sleeping_count.acquire(False)
284 while sleepers < n and self._sleeping_count.acquire(False):
290 self._woken_count.acquire() # wait for a sleeper to wake
293 while self._wait_semaphore.acquire(False):
[all …]
|
| D | queues.py | 89 if not self._sem.acquire(block, timeout):
108 if not self._rlock.acquire(block, timeout):
217 nacquire = notempty.acquire
223 wacquire = writelock.acquire
312 if not self._sem.acquire(block, timeout):
324 if not self._unfinished_tasks.acquire(False):
|
| /third_party/vk-gl-cts/framework/delibs/decpp/ |
| D | deSharedPtr.hpp | 147 void acquire (void);
188 void acquire (void);
284 acquire(); in SharedPtr()
299 acquire(); in SharedPtr()
347 acquire(); in operator =()
373 acquire(); in operator =()
504 inline void SharedPtr<T>::acquire (void) in acquire() function in de::SharedPtr
553 acquire(); in WeakPtr()
565 acquire(); in WeakPtr()
593 acquire(); in operator =()
[all …]
|
| /third_party/ltp/testcases/misc/lvm/ |
| D | prepare_lvm.sh | 47 LVM_DEV1=`tst_device acquire 1040 "$LVM_IMGDIR/lvm_pv1.img"`
49 LVM_DEV2=`tst_device acquire 1040 "$LVM_IMGDIR/lvm_pv2.img"`
55 LVM_DEV3=`tst_device acquire $DEVSIZE "$LVM_IMGDIR/lvm_pv3.img"`
57 LVM_DEV4=`tst_device acquire $DEVSIZE "$LVM_IMGDIR/lvm_pv4.img"`
|
| /third_party/python/Lib/ |
| D | threading.py | 138 def acquire(self, blocking=True, timeout=-1): member in _RLock
168 rc = self._block.acquire(blocking, timeout)
174 __enter__ = acquire
205 self._block.acquire()
241 self.acquire = lock.acquire
277 self._lock.acquire() # Ignore saved state
282 if self._lock.acquire(False):
314 waiter.acquire()
320 waiter.acquire()
324 gotit = waiter.acquire(True, timeout)
[all …]
|
| /third_party/python/Lib/asyncio/ |
| D | locks.py | 13 await self.acquire()
92 async def acquire(self): member in Lock
237 self.acquire = lock.acquire
278 await self.acquire()
372 async def acquire(self): member in Semaphore
|
| /third_party/grpc/src/python/grpcio_tests/tests/unit/ |
| D | test_common.py | 119 self.cv.acquire()
124 self.cv.acquire()
131 self.cv.acquire()
|
| /third_party/skia/third_party/externals/swiftshader/third_party/llvm-subzero/lib/Support/Unix/ |
| D | RWMutex.inc | 26 // will therefore deadlock if a thread tries to acquire a read lock
36 return static_cast<MutexImpl *>(data_)->acquire();
44 return static_cast<MutexImpl *>(data_)->acquire();
|
| /third_party/python/Doc/library/ |
| D | asyncio-sync.rst | 60 await lock.acquire()
72 .. coroutinemethod:: acquire()
79 When more than one coroutine is blocked in :meth:`acquire`
212 await cond.acquire()
218 .. coroutinemethod:: acquire()
285 :meth:`acquire` call and incremented by each :meth:`release` call.
286 The counter can never go below zero; when :meth:`acquire` finds
314 await sem.acquire()
320 .. coroutinemethod:: acquire()
335 Can wake up a task waiting to acquire the semaphore.
[all …]
|
| /third_party/grpc/tools/run_tests/python_utils/ |
| D | port_server.py | 122 mu.acquire()
130 mu.acquire()
166 mu.acquire()
188 mu.acquire()
|
| /third_party/jerryscript/docs/ |
| D | 16.MIGRATION-GUIDE.md | 69 // create or acquire value
83 // create or acquire value
98 ... // create or acquire value
117 // create or acquire value
134 // create or acquire value
157 // create or acquire value
171 // create or acquire value
186 // create or acquire value
206 // create or acquire value
223 // create or acquire value
[all …]
|
| /third_party/flutter/skia/include/private/ |
| D | SkSpinlock.h | 19 void acquire() SK_ACQUIRE() { in acquire() function
50 SkAutoSpinlock(SkSpinlock& mutex) SK_ACQUIRE(mutex) : fSpinlock(mutex) { fSpinlock.acquire(); } in SkAutoSpinlock()
|
| D | SkMutex.h | 21 void acquire() SK_ACQUIRE() { in acquire() function
43 SkAutoMutexExclusive(SkMutex& mutex) SK_ACQUIRE(mutex) : fMutex(mutex) { fMutex.acquire(); } in SkAutoMutexExclusive()
|
| /third_party/skia/include/private/ |
| D | SkSpinlock.h | 19 void acquire() SK_ACQUIRE() { in acquire() function
50 SkAutoSpinlock(SkSpinlock& mutex) SK_ACQUIRE(mutex) : fSpinlock(mutex) { fSpinlock.acquire(); } in SkAutoSpinlock()
|
| D | SkMutex.h | 21 void acquire() SK_ACQUIRE() { in acquire() function
43 SkAutoMutexExclusive(SkMutex& mutex) SK_ACQUIRE(mutex) : fMutex(mutex) { fMutex.acquire(); } in SkAutoMutexExclusive()
|
| /third_party/boost/boost/ |
| D | memory_order.hpp | 51 acquire = 2, enumerator
59 …INLINE_VARIABLE BOOST_CONSTEXPR_OR_CONST memory_order memory_order_acquire = memory_order::acquire;
|
| /third_party/flutter/skia/tests/ |
| D | SkSharedMutexTest.cpp | 15 sm.acquire(); in DEF_TEST()
44 sm.acquire(); in DEF_TEST()
|
| /third_party/skia/tests/ |
| D | SkSharedMutexTest.cpp | 15 sm.acquire(); in DEF_TEST()
44 sm.acquire(); in DEF_TEST()
|
| /third_party/skia/third_party/externals/opengl-registry/extensions/EXT/ |
| D | EXT_win32_keyed_mutex.txt | 78 where <memory> identifies which keyed mutex to acquire, <key> is the
80 to wait before failing the acquire operation.
82 FALSE is returned if the acquire operation timed out or failed. No
109 ReleaseKeyedMutexWin32EXT if the acquire or release operation failed
|
| /third_party/openGLES/extensions/EXT/ |
| D | EXT_win32_keyed_mutex.txt | 78 where <memory> identifies which keyed mutex to acquire, <key> is the
80 to wait before failing the acquire operation.
82 FALSE is returned if the acquire operation timed out or failed. No
109 ReleaseKeyedMutexWin32EXT if the acquire or release operation failed
|
| /third_party/gstreamer/gstplugins_bad/gst-libs/gst/vulkan/ |
| D | gstvkhandlepool.c | 157 klass->acquire = gst_vulkan_handle_pool_default_acquire; in gst_vulkan_handle_pool_class_init()
181 g_return_val_if_fail (klass->acquire != NULL, NULL); in gst_vulkan_handle_pool_acquire()
183 return klass->acquire (pool, error); in gst_vulkan_handle_pool_acquire()
|