Home
last modified time | relevance | path

Searched refs:cancelled_ (Results 1 – 25 of 32) sorted by relevance

12

/external/libchrome/base/files/
Dfile_path_watcher.h68 cancelled_ = true; in set_cancelled()
72 return cancelled_; in is_cancelled()
77 bool cancelled_; variable
Dfile_path_watcher.cc31 FilePathWatcher::PlatformDelegate::PlatformDelegate(): cancelled_(false) { in PlatformDelegate()
/external/grpc-grpc/src/cpp/server/
Dserver_context.cc48 cancelled_(0) {} in CompletionOp()
72 return finalized_ ? (cancelled_ != 0) : false; in CheckCancelledNoPluck()
80 int cancelled_; member in grpc::ServerContext::CompletionOp
94 ops->data.recv_close_on_server.cancelled = &cancelled_; in FillOps()
108 if (!*status) cancelled_ = 1; in FinalizeResult()
/external/tensorflow/tensorflow/core/platform/default/
Dunbounded_work_queue.cc34 cancelled_ = true; in ~UnboundedWorkQueue()
86 while (!cancelled_ && work_queue_.empty()) { in PooledThreadFunc()
91 if (cancelled_) { in PooledThreadFunc()
Dunbounded_work_queue.h59 bool cancelled_ TF_GUARDED_BY(work_queue_mu_) = false;
/external/rust/crates/grpcio-sys/grpc/src/cpp/server/
Dserver_context.cc56 cancelled_(0), in CompletionOp()
137 return finalized_ ? (cancelled_ != 0) : false; in CheckCancelledNoPluck()
148 int cancelled_; // This is an int (not bool) because it is passed to core member in grpc::ServerContextBase::CompletionOp
164 ops.data.recv_close_on_server.cancelled = &cancelled_; in FillOps()
200 cancelled_ = 1; in FinalizeResult()
203 call_cancel = (cancelled_ != 0); in FinalizeResult()
/external/tensorflow/tensorflow/core/kernels/data/experimental/
Dsleep_dataset_op.cc109 cancelled_ = true; in ~Iterator()
121 cancelled_ = true; in Initialize()
134 Condition(&cancelled_), in GetNextInternal()
163 bool cancelled_ TF_GUARDED_BY(mu_) = false;
Ddata_service_dataset_op.cc251 cancelled_ = true; in CancelThreads()
292 if (!task_thread_manager_ && !cancelled_) { in GetNextInternal()
303 !cancelled_ && status_.ok()) { in GetNextInternal()
312 if (cancelled_) { in GetNextInternal()
419 while (!cancelled_ && Env::Default()->NowMicros() < next_check) { in TaskThreadManager()
426 if (cancelled_) { in TaskThreadManager()
633 if (cancelled_ || job_finished_) { in RunWorkerThread()
744 if (cancelled_) { in GetElementTraced()
788 bool cancelled_ TF_GUARDED_BY(mu_) = false;
Dparallel_interleave_dataset_op.cc301 while (!cancelled_) { in GetNextInternal()
651 cancelled_ = true; in CancelThreads()
749 while (!cancelled_ && !workers_[thread_index].is_producing) { in WorkerThread()
754 if (cancelled_) return; in WorkerThread()
801 while (!cancelled_ && workers_[thread_index].outputs.size() == in WorkerThread()
807 if (cancelled_) return; in WorkerThread()
861 while (!cancelled_ && workers_[thread_index].outputs.size() == in WorkerThread()
867 if (cancelled_) return; in WorkerThread()
1152 bool cancelled_ TF_GUARDED_BY(mu_) = false;
Dmap_and_batch_dataset_op.cc237 while (!cancelled_ && (batch_results_.empty() || in GetNextInternal()
245 if (cancelled_) { in GetNextInternal()
479 cancelled_ = true; in CancelThreads()
545 while (!cancelled_ && busy()) { in RunnerThread()
560 if (cancelled_) { in RunnerThread()
669 bool cancelled_ TF_GUARDED_BY(*mu_) = false;
Dparse_example_dataset_op.cc404 if (cancelled_) { in GetNextInternal()
542 cancelled_ = true; in CancelThreads()
758 while (!cancelled_ && busy()) { in RunnerThread()
763 if (cancelled_) { in RunnerThread()
785 if (cancelled_) { in ShouldWait()
819 if (step != 0 && !cancelled_) { in StatsThread()
823 if (cancelled_) { in StatsThread()
902 bool cancelled_ TF_GUARDED_BY(*mu_) = false;
Dsnapshot_dataset_op.cc1352 cancelled_ = true; in ~SnapshotReaderIterator()
1409 while (!cancelled_ && buffer_.empty() && in GetNextInternal()
1414 if (cancelled_) { in GetNextInternal()
1594 while (!cancelled_ && in ReadFile()
1599 if (cancelled_) { in ReadFile()
1743 bool cancelled_ TF_GUARDED_BY(mu_) = false;
1772 cancelled_ = true; in ~SnapshotWriterIterator()
2085 while (!cancelled_ && in FillBuffer()
2090 if (cancelled_) { in FillBuffer()
2124 while (!cancelled_ && buffer_.empty() && !end_of_sequence_ && in ProcessOneElement()
[all …]
/external/tensorflow/tensorflow/core/data/service/
Dworker_impl.cc62 cancelled_ = true; in ~DataServiceWorkerImpl()
238 while (!cancelled_ && pending_completed_tasks_.empty()) { in TaskCompletionThread()
241 if (cancelled_) { in TaskCompletionThread()
250 if (!cancelled_) { in TaskCompletionThread()
287 while (!cancelled_ && in HeartbeatThread()
294 if (cancelled_) { in HeartbeatThread()
Dtask_runner.cc248 cancelled_ = true; in ~PrefetchThread()
256 while (!cancelled_ && buffer_.size() >= round_size_) { in Run()
259 if (cancelled_) { in Run()
293 while (buffer_.size() < round_size_ && !cancelled_ && status_.ok()) { in FillBuffer()
301 if (cancelled_) { in FillBuffer()
Ddata_service.cc278 if (cancelled_) { in GetElement()
300 cancelled_ = true; in TryCancel()
315 bool cancelled_ TF_GUARDED_BY(mu_) = false;
Dworker_impl.h95 bool cancelled_ TF_GUARDED_BY(mu_) = false;
/external/tensorflow/tensorflow/core/platform/cloud/
Dgcs_dns_cache.h46 cancelled_ = true; in ~GcsDnsCache()
67 bool cancelled_ TF_GUARDED_BY(mu_) = false;
Dgcs_dns_cache.cc160 if (cancelled_) return; in WorkerThread()
162 if (cancelled_) return; in WorkerThread()
/external/tensorflow/tensorflow/core/kernels/data/
Dprefetch_dataset_op.cc176 while (!cancelled_ && buffer_.empty() && !prefetch_thread_finished_ && in GetNextInternal()
185 while (!cancelled_ && buffer_.empty() && !prefetch_thread_finished_ && in GetNextInternal()
193 if (cancelled_) { in GetNextInternal()
361 cancelled_ = true; in CancelThreads()
453 while (!cancelled_ && buffer_.size() >= buffer_limit()) { in PrefetchThread()
459 if (cancelled_) { in PrefetchThread()
564 bool cancelled_ TF_GUARDED_BY(*mu_) = false;
Dparallel_map_dataset_op.cc251 if (cancelled_) { in GetNextInternal()
386 cancelled_ = true; in CancelThreads()
520 while (!cancelled_ && busy()) { in RunnerThread()
525 if (cancelled_) { in RunnerThread()
546 if (cancelled_) { in ShouldWait()
580 if (step != 0 && !cancelled_) { in StatsThread()
584 if (cancelled_) { in StatsThread()
659 bool cancelled_ TF_GUARDED_BY(*mu_) = false;
Dparallel_batch_dataset_op.cc199 while (!cancelled_ && (batch_results_.empty() || in GetNextInternal()
207 if (cancelled_) { in GetNextInternal()
380 cancelled_ = true; in CancelThreads()
416 while (!cancelled_ && busy()) { in RunnerThread()
422 if (cancelled_) { in RunnerThread()
507 bool cancelled_ TF_GUARDED_BY(*mu_) = false;
Dparallel_interleave_dataset_op.cc364 while (!cancelled_ && !Consume(&result)) { in GetNextInternal()
375 if (cancelled_) { in GetNextInternal()
565 cancelled_ = true; in CancelThreads()
771 while (!cancelled_ && in WorkerManagerThread()
777 if (cancelled_ || end_of_input_) { in WorkerManagerThread()
829 while (!cancelled_) { in CurrentWorkerThread()
847 if (cancelled_) { in CurrentWorkerThread()
895 while (!cancelled_ && (future_elements_.size() >= in FutureWorkerThread()
900 if (cancelled_) { in FutureWorkerThread()
1113 if (step != 0 && !cancelled_) { in StatsThread()
[all …]
Dmulti_device_iterator_ops.cc176 cancelled_ = true; in Reset()
206 if (cancelled_) { in GetNextFromShard()
300 while (!cancelled_ && in BackgroundThread()
306 if (cancelled_) { in BackgroundThread()
363 bool cancelled_ TF_GUARDED_BY(mu_) = false;
/external/tensorflow/tensorflow/core/framework/
Drun_handler.cc347 cancelled_ = true; in ~RunHandlerThreadPool()
358 cancelled_ = false; in Start()
377 cancelled_ = false; in StartOneThreadForTesting()
527 while (!cancelled_) { in WorkerLoop()
688 while (!cancelled_ && thread_work_sources->empty()) { in WaitForWork()
701 if (cancelled_) { in WaitForWork()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/health/
Dhealth_check_client.h137 Atomic<bool> cancelled_{false};

12