Home
last modified time | relevance | path

Searched refs:acquire (Results 1 - 25 of 106) sorted by relevance

12345

/third_party/python/Lib/test/
H A Dlock_tests.py109 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...]
H A Dtest_threadsignals.py50 signalled_all.acquire()
52 signalled_all.acquire()
99 lock.acquire()
102 self.assertRaises(KeyboardInterrupt, lock.acquire, timeout=5)
105 # We want to assert that lock.acquire() was interrupted because
107 # after timeout return of lock.acquire() (which can fool assertRaises).
133 rlock.acquire()
137 # Wait until we can't acquire it without blocking...
138 while rlock.acquire(blocking=False):
143 self.assertRaises(KeyboardInterrupt, rlock.acquire, timeou
[all...]
H A Dtest_thread.py31 self.done_mutex.acquire()
69 self.done_mutex.acquire()
105 self.done_mutex.acquire()
114 mut.acquire()
119 mut.acquire()
148 started.acquire()
150 started.acquire()
165 self.checkout_mutex.acquire()
168 self.checkin_mutex.acquire()
176 self.checkout_mutex.acquire()
[all...]
H A Dtest_threading.py246 mutex.acquire()
250 mutex.acquire()
374 ready.acquire()
391 ready.acquire() # Be sure the other thread is waiting.
513 cond.acquire()
744 started.acquire()
745 finish.acquire()
748 finish.acquire()
754 started.acquire()
759 self.assertFalse(tstate_lock.acquire(timeou
[all...]
/third_party/python/Lib/test/test_asyncio/
H A Dtest_locks.py33 await lock.acquire()
90 self.assertTrue(await lock.acquire())
93 if await lock.acquire():
98 if await lock.acquire():
103 if await lock.acquire():
139 self.assertTrue(await lock.acquire())
141 task = asyncio.create_task(lock.acquire())
150 # - B is blocked in acquire()
151 # - C is blocked in acquire()
165 await lock.acquire()
[all...]
/third_party/python/Lib/multiprocessing/
H A Dsynchronize.py91 self.acquire = self._semlock.acquire
236 self.acquire = self._lock.acquire
249 'must acquire() condition before using wait()'
261 return self._wait_semaphore.acquire(True, timeout)
268 self._lock.acquire()
272 assert not self._wait_semaphore.acquire(
273 False), ('notify: Should not have been able to acquire '
278 while self._woken_count.acquire(Fals
[all...]
H A Dqueues.py89 if not self._sem.acquire(block, timeout):
108 if not self._rlock.acquire(block, timeout):
215 nacquire = notempty.acquire
221 wacquire = writelock.acquire
311 if not self._sem.acquire(block, timeout):
323 if not self._unfinished_tasks.acquire(False):
/third_party/vk-gl-cts/framework/delibs/decpp/
H A DdeSharedPtr.hpp147 void acquire (void);
188 void acquire (void);
284 acquire(); in SharedPtr()
299 acquire(); in SharedPtr()
343 // Copy from other and acquire reference. in operator =()
347 acquire(); in operator =()
369 // Copy from other and acquire reference. in operator =()
373 acquire(); in operator =()
383 * Tries to acquire reference to WeakPtr, releases current reference and
504 inline void SharedPtr<T>::acquire (voi function in de::SharedPtr
620 inline void WeakPtr<T>::acquire (void) acquire() function in de::WeakPtr
[all...]
/third_party/python/Lib/
H A Dthreading.py94 thread has acquired a reentrant lock, the same thread may acquire it again
107 thread has acquired a reentrant lock, the same thread may acquire it
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()
240 # Export the lock's acquire() and release() methods
241 self.acquire = lock.acquire
245 # release() and acquire() o
433 def acquire(self, blocking=True, timeout=None): global() member in Semaphore
[all...]
/third_party/ltp/testcases/misc/lvm/
H A Dprepare_lvm.sh46 LVM_DEV1=`tst_device acquire 1040 "$LVM_IMGDIR/lvm_pv1.img"`
48 LVM_DEV2=`tst_device acquire 1040 "$LVM_IMGDIR/lvm_pv2.img"`
54 LVM_DEV3=`tst_device acquire $DEVSIZE "$LVM_IMGDIR/lvm_pv3.img"`
56 LVM_DEV4=`tst_device acquire $DEVSIZE "$LVM_IMGDIR/lvm_pv4.img"`
/third_party/mesa3d/src/gallium/drivers/zink/
H A Dzink_kopper.c141 VKSCR(DestroySemaphore)(screen->dev, cswap->images[i].acquire, NULL); in destroy_swapchain()
475 (cdt->swapchain->images[res->obj->dt_idx].acquire || cdt->swapchain->images[res->obj->dt_idx].acquired)) in kopper_acquire()
477 VkSemaphore acquire = VK_NULL_HANDLE; in kopper_acquire()
500 if (!acquire) { in kopper_acquire()
501 ret = VKSCR(CreateSemaphore)(screen->dev, &sci, NULL, &acquire); in kopper_acquire()
502 assert(acquire); in kopper_acquire()
506 ret = VKSCR(AcquireNextImageKHR)(screen->dev, cdt->swapchain->swapchain, timeout, acquire, VK_NULL_HANDLE, &res->obj->dt_idx); in kopper_acquire()
512 VKSCR(DestroySemaphore)(screen->dev, acquire, NULL); in kopper_acquire()
518 cdt->swapchain->images[res->obj->dt_idx].acquire = acquire; in kopper_acquire()
601 VkSemaphore acquire = cdt->swapchain->images[res->obj->dt_idx].acquire; zink_kopper_acquire_submit() local
818 VkSemaphore acquire = zink_kopper_acquire_submit(screen, res); zink_kopper_present_readback() local
[all...]
/third_party/python/Lib/asyncio/
H A Dlocks.py15 await self.acquire()
32 acquire() and release(). When the state is unlocked, acquire()
34 state is locked, acquire() blocks until a call to release() in
35 another coroutine changes it to unlocked, then the acquire() call
41 When more than one coroutine is blocked in acquire() waiting for
44 is blocked in acquire() is being processed.
46 acquire() is a coroutine and should be called with 'await'.
55 await lock.acquire()
71 await lock.acquire()
93 async def acquire(self): global() member in Lock
364 async def acquire(self): global() member in Semaphore
[all...]
/third_party/skia/include/private/
H A DSkSpinlock.h19 void acquire() SK_ACQUIRE() { in SK_ACQUIRE()
20 // To act as a mutex, we need an acquire barrier when we acquire the lock. in SK_ACQUIRE()
29 // To act as a mutex, we need an acquire barrier when we acquire the lock. in SK_TRY_ACQUIRE()
50 SkAutoSpinlock(SkSpinlock& mutex) SK_ACQUIRE(mutex) : fSpinlock(mutex) { fSpinlock.acquire(); } in SK_ACQUIRE()
H A DSkMutex.h21 void acquire() SK_ACQUIRE() { in SK_ACQUIRE()
43 SkAutoMutexExclusive(SkMutex& mutex) SK_ACQUIRE(mutex) : fMutex(mutex) { fMutex.acquire(); } in SK_ACQUIRE()
/third_party/skia/tests/
H A DSkSharedMutexTest.cpp15 sm.acquire(); in DEF_TEST()
44 sm.acquire(); in DEF_TEST()
/third_party/skia/src/core/
H A DSkSharedMutex.h35 void acquire() SK_ACQUIRE();
78 lock.acquire(); in SK_ACQUIRE()
/third_party/skia/third_party/externals/swiftshader/third_party/llvm-subzero/include/llvm/Support/
H A DMutex.h32 /// Initializes the lock but doesn't acquire it. if \p recursive is set
34 /// also more likely to deadlock (same thread can't acquire more than
48 /// Attempts to unconditionally acquire the lock. If the lock is held by
49 /// another thread, this method will wait until it can acquire the lock.
51 /// @brief Unconditionally acquire the lock.
52 bool acquire();
55 /// thread, the lock is released allowing other threads to acquire the
61 /// Attempts to acquire the lock without blocking. If the lock is not
66 /// @brief Try to acquire the lock.
101 return impl.acquire(); in lock()
[all...]
/third_party/skia/third_party/externals/swiftshader/third_party/llvm-subzero/lib/Support/
H A DMutex.cpp28 bool MutexImpl::acquire() { return true; } in acquire() function in llvm::MutexImpl
84 MutexImpl::acquire()
/third_party/skia/third_party/externals/swiftshader/third_party/llvm-10.0/llvm/lib/Support/
H A DRWMutex.cpp119 return static_cast<MutexImpl *>(data_)->acquire();
127 return static_cast<MutexImpl *>(data_)->acquire();
/third_party/node/tools/inspector_protocol/jinja2/
H A Dutils.py359 self._wlock.acquire()
371 self._wlock.acquire()
398 self._wlock.acquire()
418 self._wlock.acquire()
433 self._wlock.acquire()
/third_party/skia/third_party/externals/swiftshader/third_party/llvm-10.0/llvm/include/llvm/Support/
H A DAtomicOrdering.h31 acquire = 2, member in llvm::AtomicOrderingCABI
55 /// \-->consume-->acquire--/
82 "consume", "acquire", "release", in toIRString()
96 /* acquire */ { true, true, true, true, false, false, false, false}, in isStrongerThan()
111 /* acquire */ { true, true, true, true, true, false, false, false}, in isAtLeastOrStrongerThan()
141 /* acquire */ AtomicOrderingCABI::acquire, in toCABI()
/third_party/vixl/tools/
H A Dprinter.py70 if not has_lock: __print_lock__.acquire()
86 if not has_lock: __print_lock__.acquire()
/third_party/mesa3d/src/virtio/vulkan/
H A Dvn_render_pass.c42 _acquire_atts->acquire = true; \
48 _release_atts->acquire = false; \
99 if (att->acquire) { in vn_render_pass_setup_present_src_barriers()
/third_party/vk-gl-cts/modules/egl/
H A DteglAndroidUtil.cpp109 pfnAHardwareBuffer_acquire acquire; member
122 (pAhbFunctions->acquire != DE_NULL) && in ahbFunctionsLoaded()
139 ahbFunctions.acquire = reinterpret_cast<pfnAHardwareBuffer_acquire>(libnativewindow.getFunction("AHardwareBuffer_acquire")); in loadAhbDynamicApis()
/third_party/node/deps/v8/third_party/jinja2/
H A Dutils.py402 self._wlock.acquire()
426 self._wlock.acquire()
446 self._wlock.acquire()
461 self._wlock.acquire()

Completed in 16 milliseconds

12345