| /external/libxcam/xcore/ |
| D | xcam_mutex.h | 72 pthread_cond_init (&_cond, NULL); in Cond()
75 pthread_cond_destroy (&_cond); in ~Cond()
79 return pthread_cond_wait (&_cond, &mutex._mutex); in wait()
91 return pthread_cond_timedwait (&_cond, &mutex._mutex, &abstime); in timedwait()
95 return pthread_cond_signal (&_cond); in signal()
98 return pthread_cond_broadcast (&_cond); in broadcast()
101 pthread_cond_t _cond;
|
| /external/python/cpython2/Lib/multiprocessing/ |
| D | pool.py | 543 self._cond = threading.Condition(threading.Lock())
558 self._cond.acquire()
561 self._cond.wait(timeout)
563 self._cond.release()
578 self._cond.acquire()
581 self._cond.notify()
583 self._cond.release()
615 self._cond.acquire()
618 self._cond.notify()
620 self._cond.release()
[all …]
|
| D | synchronize.py | 302 self._cond = Condition(Lock())
306 self._cond.acquire()
313 self._cond.release()
316 self._cond.acquire()
320 self._cond.notify_all()
322 self._cond.release()
325 self._cond.acquire()
329 self._cond.release()
332 self._cond.acquire()
337 self._cond.wait(timeout)
[all …]
|
| D | queues.py | 300 self._cond = Condition()
303 return Queue.__getstate__(self) + (self._cond, self._unfinished_tasks)
307 self._cond, self._unfinished_tasks = state[-2:]
315 self._cond.acquire()
323 self._cond.release()
327 self._cond.acquire()
332 self._cond.notify_all()
334 self._cond.release()
337 self._cond.acquire()
340 self._cond.wait()
[all …]
|
| /external/python/cpython3/Lib/ |
| D | threading.py | 385 self._cond = Condition(Lock())
416 with self._cond:
427 self._cond.wait(timeout)
442 with self._cond:
444 self._cond.notify()
481 with self._cond:
485 self._cond.notify()
500 self._cond = Condition(Lock())
505 self._cond.__init__(Lock())
520 with self._cond:
[all …]
|
| /external/python/cpython3/Lib/multiprocessing/ |
| 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)
373 self._cond, self._wrapper) = state
378 self._cond, self._wrapper)
|
| D | queues.py | 291 self._cond = ctx.Condition()
294 return Queue.__getstate__(self) + (self._cond, self._unfinished_tasks)
298 self._cond, self._unfinished_tasks = state[-2:]
305 with self._notempty, self._cond:
313 with self._cond:
317 self._cond.notify_all()
320 with self._cond:
322 self._cond.wait()
|
| D | pool.py | 718 self._cond = threading.Condition(threading.Lock())
731 with self._cond:
737 self._cond.wait(timeout)
753 with self._cond:
761 self._cond.notify()
769 with self._cond:
772 self._cond.notify()
782 with self._cond:
785 self._cond.notify()
|
| /external/mesa3d/src/gallium/tests/unit/ |
| D | pipe_barrier_test.c | 63 #define CHECK(_cond) \ argument
64 if (!(_cond)) { \
65 fprintf(stderr, "%s:%u: `%s` failed\n", __FILE__, __LINE__, #_cond); \
|
| /external/python/cpython3/Lib/test/ |
| D | test_sched.py | 14 self._cond = threading.Condition()
19 with self._cond:
25 with self._cond:
29 self._cond.wait()
35 with self._cond:
37 self._cond.notify_all()
|
| D | lock_tests.py | 423 with evt._cond:
424 self.assertFalse(evt._cond.acquire(False))
426 with evt._cond:
427 self.assertFalse(evt._cond.acquire(False))
|
| /external/libxcam/modules/soft/ |
| D | soft_handler.cpp | 44 Cond _cond; member in XCam::SyncMeta
55 _cond.broadcast (); in signal_done()
63 _cond.broadcast (); in wakeup()
72 _cond.wait (_mutex); in signal_wait_ret()
|
| /external/harfbuzz_ng/src/ |
| D | hb.hh | 354 #define ASSERT_STATIC_EXPR_ZERO(_cond) (0 * (unsigned int) sizeof (hb_assert_constant_t<_cond>)) argument
|
| /external/tensorflow/tensorflow/python/kernel_tests/ |
| D | cond_v2_test.py | 301 return _cond(pred, false_true_fn, false_false_fn, "inside_false_fn")
324 return _cond(pred, lambda: x + y, lambda: x * x, name=None)
327 return _cond(pred, lambda: x - y, lambda: y * y, name=None)
363 return _cond(
372 return _cond(
1169 def _cond(pred, true_fn, false_fn, name): function
|
| /external/iw/ |
| D | util.c | 551 #define PRINT_HT_CAP(_cond, _str) \ in print_ht_capability() argument
553 if (_cond) \ in print_ht_capability()
|
| /external/swiftshader/third_party/llvm-7.0/llvm/test/Transforms/CodeExtractor/ |
| D | PartialInlineVarArg.ll | 107 ; CHECK-NEXT: call void (i32*, ...) @vararg2.1_cond.end(i32* %foo, i32 signext 8)
|
| /external/tensorflow/tensorflow/contrib/factorization/python/ops/ |
| D | clustering_ops.py | 646 def _cond(i, _): function
701 _, num_remaining = control_flow_ops.while_loop(_cond, _body, [0, 0])
|
| /external/tensorflow/tensorflow/python/ops/ |
| D | clustering_ops.py | 645 def _cond(i, _): function
700 _, num_remaining = control_flow_ops.while_loop(_cond, _body, [0, 0])
|