Home
last modified time | relevance | path

Searched refs:notify_all (Results 1 – 25 of 146) sorted by relevance

123456

/external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_server/
D_handler.py73 self._condition.notify_all()
81 self._condition.notify_all()
97 self._condition.notify_all()
106 self._condition.notify_all()
131 self._condition.notify_all()
138 self._condition.notify_all()
148 self._condition.notify_all()
158 self._condition.notify_all()
200 self._condition.notify_all()
/external/tensorflow/tensorflow/core/kernels/
Drecord_yielder.cc39 buf_empty_.notify_all(); in ~RecordYielder()
40 buf_enough_.notify_all(); in ~RecordYielder()
41 buf_not_full_.notify_all(); in ~RecordYielder()
62 buf_empty_.notify_all(); in YieldOne()
65 buf_not_full_.notify_all(); in YieldOne()
110 buf_enough_.notify_all(); in MainLoop()
154 buf_enough_.notify_all(); in MainLoop()
163 buf_enough_.notify_all(); in MainLoop()
193 buf_enough_.notify_all(); in Add()
/external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_channel/
D_rpc_state.py49 self._condition.notify_all()
58 self._condition.notify_all()
99 self._condition.notify_all()
128 self._condition.notify_all()
150 self._condition.notify_all()
162 self._condition.notify_all()
172 self._condition.notify_all()
/external/tensorflow/tensorflow/compiler/tf2tensorrt/utils/
Dtrt_int8_calibrator.cc84 cond_.notify_all(); in setBatch()
93 cond_.notify_all(); in getBatch()
120 cond_.notify_all(); in waitAndSetDone()
133 cond_.notify_all(); in setDone()
/external/tensorflow/tensorflow/core/common_runtime/eager/
Deager_executor.cc25 nodes_pending_.notify_all(); in ~EagerExecutor()
61 nodes_pending_.notify_all(); in Add()
102 nodes_pending_.notify_all(); in ClearError()
145 it->second->notify_all(); in Run()
/external/tensorflow/tensorflow/core/common_runtime/gpu/
Dgpu_event_mgr.cc73 all_initialized.notify_all(); in InitThreadpoolLabels()
79 ready_to_exit.notify_all(); in InitThreadpoolLabels()
156 events_pending_.notify_all(); in StopPollingLoop()
237 if (was_empty) events_pending_.notify_all(); in QueueInUse()
/external/grpc-grpc/src/python/grpcio_tests/tests/unit/_cython/
D_cancel_many_calls_test.py64 self._state.condition.notify_all()
104 state.condition.notify_all()
125 self._condition.notify_all()
207 state.condition.notify_all()
/external/libcxx/include/
Dcondition_variable32 void notify_all() noexcept;
76 void notify_all() noexcept;
133 void notify_all() _NOEXCEPT;
183 condition_variable_any::notify_all() _NOEXCEPT
186 __cv_.notify_all();
/external/grpc-grpc/src/python/grpcio_tests/tests/unit/framework/common/
Dtest_control.py67 self._condition.notify_all()
79 self._condition.notify_all()
/external/libcxx/src/
Dfuture.cpp98 __cv_.notify_all(); in set_value()
119 __cv_.notify_all(); in set_exception()
137 __cv_.notify_all(); in __make_ready()
/external/grpc-grpc/src/python/grpcio_tests/tests/unit/beta/
D_beta_features_test.py56 self._condition.notify_all()
66 self._condition.notify_all()
78 self._condition.notify_all()
90 self._condition.notify_all()
131 self._condition.notify_all()
/external/tensorflow/tensorflow/core/kernels/data/
Dparallel_map_iterator.cc68 cond_var_->notify_all(); in ~ParallelMapIterator()
214 cond_var_->notify_all(); in CallCompleted()
307 cond_var_->notify_all(); in RunnerThread()
327 cond_var_->notify_all(); in ShouldWait()
334 cond_var_->notify_all(); in ShouldWait()
Dprefetch_dataset_op.cc97 cond_var_.notify_all(); in ~Iterator()
262 cond_var_.notify_all(); in Consume()
313 cond_var_.notify_all(); in PrefetchThread()
322 cond_var_.notify_all(); in PrefetchThread()
/external/grpc-grpc/src/python/grpcio/grpc/beta/
D_server_adaptations.py115 self._condition.notify_all()
120 self._condition.notify_all()
126 self._condition.notify_all()
131 self._condition.notify_all()
Dutilities.py63 self._condition.notify_all()
78 self._condition.notify_all()
/external/swiftshader/third_party/llvm-7.0/llvm/lib/Support/
DThreadPool.cpp66 CompletionCondition.notify_all(); in ThreadPool()
105 QueueCondition.notify_all(); in ~ThreadPool()
/external/python/cpython3/Lib/
Dthreading.py358 def notify_all(self): member in Condition
367 notifyAll = notify_all
522 self._cond.notify_all()
639 self._cond.notify_all()
663 self._cond.notify_all()
683 self._cond.notify_all()
699 self._cond.notify_all()
/external/grpc-grpc/src/python/grpcio_testing/grpc_testing/
D_time.py101 self._state.condition.notify_all()
141 self._state.condition.notify_all()
165 self._state.condition.notify_all()
/external/llvm/lib/Support/
DThreadPool.cpp69 CompletionCondition.notify_all(); in ThreadPool()
108 QueueCondition.notify_all(); in ~ThreadPool()
/external/libcxx/utils/google-benchmark/src/
Dmutex.h110 if (last_thread) phase_condition_.notify_all(); in wait()
117 if (entered_ != 0) phase_condition_.notify_all(); in removeThread()
/external/google-benchmark/src/
Dmutex.h110 if (last_thread) phase_condition_.notify_all(); in wait()
117 if (entered_ != 0) phase_condition_.notify_all(); in removeThread()
/external/python/cpython2/Lib/multiprocessing/dummy/
D__init__.py89 notify_all = threading._Condition.notify_all.im_func variable in Condition
/external/tensorflow/tensorflow/core/lib/core/
Dthreadpool_test.cc205 done.notify_all(); in BM_Sequential()
228 done.notify_all(); in BM_Parallel()
254 done.notify_all(); in BM_ParallelFor()
/external/tensorflow/tensorflow/core/kernels/data/experimental/
Dnuma_map_and_batch_dataset_op.cc406 worker_cond_var_.notify_all(); in PushInputs()
408 client_cond_var_.notify_all(); in PushInputs()
419 worker_cond_var_.notify_all(); in SetEndOfInput()
420 client_cond_var_.notify_all(); in SetEndOfInput()
511 client_cond_var_.notify_all(); in RecordBatchEntryComplete()
583 runner_cond_var_.notify_all(); in GetBatch()
592 runner_cond_var_.notify_all(); in Cancel()
593 worker_cond_var_.notify_all(); in Cancel()
594 client_cond_var_.notify_all(); in Cancel()
/external/grpc-grpc/src/python/grpcio/grpc/
D_utilities.py94 self._condition.notify_all()
109 self._condition.notify_all()

123456