Searched refs:_cond (Results 1 - 15 of 15) sorted by relevance
| /third_party/python/Lib/ |
| H A D | threading.py | 425 self._cond = Condition(Lock())
461 with self._cond:
472 self._cond.wait(timeout)
489 with self._cond:
492 self._cond.notify()
536 with self._cond:
541 self._cond.notify()
556 self._cond = Condition(Lock())
566 self._cond._at_fork_reinit()
590 with self._cond
[all...] |
| /third_party/python/Lib/asyncio/ |
| H A D | locks.py | 460 self._cond = Condition() # notify all tasks when state changes
488 async with self._cond:
510 await self._cond.wait_for(
526 self._cond.notify_all()
534 await self._cond.wait_for(lambda: self._state is not _BarrierState.FILLING)
545 self._cond.notify_all()
553 async with self._cond:
560 self._cond.notify_all()
568 async with self._cond:
570 self._cond
[all...] |
| /third_party/mesa3d/src/gallium/tests/unit/ |
| H A D | pipe_barrier_test.c | 63 #define CHECK(_cond) \
64 if (!(_cond)) { \
65 fprintf(stderr, "%s:%u: `%s` failed\n", __FILE__, __LINE__, #_cond); \
|
| /third_party/python/Lib/multiprocessing/ |
| H A D | synchronize.py | 324 self._cond = ctx.Condition(ctx.Lock())
328 with self._cond:
335 with self._cond:
338 self._cond.notify_all()
341 with self._cond:
345 with self._cond:
349 self._cond.wait(timeout)
376 self._cond, self._wrapper) = state
381 self._cond, self._wrapper)
|
| H A D | queues.py | 299 self._cond = ctx.Condition()
302 return Queue.__getstate__(self) + (self._cond, self._unfinished_tasks)
306 self._cond, self._unfinished_tasks = state[-2:]
314 with self._notempty, self._cond:
322 with self._cond:
326 self._cond.notify_all()
329 with self._cond:
331 self._cond.wait()
|
| H A D | pool.py | 841 self._cond = threading.Condition(threading.Lock())
854 with self._cond:
861 self._cond.wait(timeout)
878 with self._cond:
886 self._cond.notify()
895 with self._cond:
898 self._cond.notify()
909 with self._cond:
912 self._cond.notify()
|
| /third_party/python/Lib/test/ |
| H A D | test_sched.py | 15 self._cond = threading.Condition()
20 with self._cond:
26 with self._cond:
30 self._cond.wait()
36 with self._cond:
38 self._cond.notify_all()
|
| H A D | lock_tests.py | 452 with evt._cond:
453 self.assertFalse(evt._cond.acquire(False))
455 with evt._cond:
456 self.assertFalse(evt._cond.acquire(False))
|
| /third_party/lzma/C/ |
| H A D | Threads.c | 355 RINOK(pthread_cond_init(&p->_cond, NULL))
in Event_Create()
376 int res1 = pthread_cond_broadcast(&p->_cond);
in Event_Set()
395 pthread_cond_wait(&p->_cond, &p->_mutex);
in Event_Wait()
412 int res2 = pthread_cond_destroy(&p->_cond);
in Event_Close()
423 RINOK(pthread_cond_init(&p->_cond, NULL))
in Semaphore_Create()
467 ret = pthread_cond_broadcast(&p->_cond);
in Semaphore_ReleaseN()
478 pthread_cond_wait(&p->_cond, &p->_mutex);
in Semaphore_Wait()
491 int res2 = pthread_cond_destroy(&p->_cond);
in Semaphore_Close()
|
| H A D | Threads.h | 182 pthread_cond_t _cond;
member
208 pthread_cond_t _cond;
member
|
| /third_party/lzma/CPP/Windows/ |
| H A D | Synchronization.h | 214 pthread_cond_t _cond;
member in NWindows::NSynchronization::MY_UNCOPYABLE
224 ::pthread_cond_destroy(&_cond);
in ~CSynchro()
231 const WRes ret = ::pthread_cond_init(&_cond, NULL);
in Create()
245 return ::pthread_cond_wait(&_cond, &_mutex);
in WaitCond()
249 const WRes res1 = ::pthread_cond_broadcast(&_cond);
in LeaveAndSignal()
|
| /third_party/node/deps/openssl/openssl/crypto/bio/ |
| H A D | bio_addr.c | 434 # define _cond bai->bai_family != AF_UNIX in BIO_ADDRINFO_free() macro
436 # define _cond 1 in BIO_ADDRINFO_free()
438 if (_cond) { in BIO_ADDRINFO_free()
|
| /third_party/openssl/crypto/bio/ |
| H A D | bio_addr.c | 434 # define _cond bai->bai_family != AF_UNIX in BIO_ADDRINFO_free() macro
436 # define _cond 1 in BIO_ADDRINFO_free()
438 if (_cond) { in BIO_ADDRINFO_free()
|
| /third_party/mbedtls/tests/scripts/ |
| H A D | generate_test_code.py | 834 _cond = dependency.group(2) if dependency.group(2) else ''
840 #if {_not}{_defined}({macro}{_cond}{_value})
848 _cond=_cond, _value=_value)
|
| /third_party/ltp/tools/sparse/sparse-src/ |
| H A D | linearize.h | 107 pseudo_t _cond; member
|
Completed in 13 milliseconds