Searched refs:cancelled_ (Results 1 – 17 of 17) sorted by relevance
48 cancelled_(0) {} in CompletionOp()72 return finalized_ ? (cancelled_ != 0) : false; in CheckCancelledNoPluck()80 int cancelled_; member in grpc::ServerContext::CompletionOp94 ops->data.recv_close_on_server.cancelled = &cancelled_; in FillOps()108 if (!*status) cancelled_ = 1; in FinalizeResult()
68 cancelled_ = true; in set_cancelled()72 return cancelled_; in is_cancelled()77 bool cancelled_; variable
31 FilePathWatcher::PlatformDelegate::PlatformDelegate(): cancelled_(false) { in PlatformDelegate()
69 cancelled_ = true; in ~UnboundedThreadPool()135 while (!cancelled_ && work_queue_.empty()) { in PooledThreadFunc()140 if (cancelled_) { in PooledThreadFunc()
103 cancelled_ = true; in ~Iterator()165 while (!cancelled_ && in OptimizeThread()173 if (cancelled_) return; in OptimizeThread()194 bool cancelled_ GUARDED_BY(mu_) = false;
96 cancelled_ = true; in ~Iterator()114 while (!cancelled_ && buffer_.empty() && !prefetch_thread_finished_ && in GetNextInternal()122 if (cancelled_) { in GetNextInternal()288 while (!cancelled_ && buffer_.size() >= auto_tuner_.buffer_limit()) { in PrefetchThread()294 if (cancelled_) { in PrefetchThread()375 bool cancelled_ GUARDED_BY(mu_) = false;
67 cancelled_ = true; in ~ParallelMapIterator()287 while (!cancelled_ && busy()) { in RunnerThread()292 if (cancelled_) { in RunnerThread()400 bool cancelled_ GUARDED_BY(*mu_) = false;
157 cancelled_ = true; in Reset()185 if (cancelled_) { in GetNextFromShard()278 while (!cancelled_ && in BackgroundThread()283 if (cancelled_) { in BackgroundThread()340 bool cancelled_ GUARDED_BY(mu_) = false;
220 cancelled_ = true; in ~ParallelInterleaveIterator()463 while (!cancelled_ && (!end_of_input_ || num_open_ > 0) && busy()) { in CurrentElementsManager()469 if (cancelled_ || in CurrentElementsManager()592 while (!cancelled_ && !end_of_input_ && busy()) { in FutureElementsManager()598 if (cancelled_ || end_of_input_) { in FutureElementsManager()917 bool cancelled_ GUARDED_BY(*mu_) = false;
68 bool cancelled_ GUARDED_BY(work_queue_mu_) = false;
212 cancelled_ = true; in ~Iterator()370 while (!cancelled_ && batches_[next].state != BatchState::kEmpty) { in WaitForInputSpace()378 if (cancelled_) { in WaitForInputSpace()433 while (!cancelled_ && in RetrieveInput()440 if (cancelled_) { in RetrieveInput()524 while (!cancelled_ && in GetBatch()534 if (cancelled_) { in GetBatch()591 cancelled_ = true; in Cancel()606 while (!cancelled_ && !AllMapOperationsFinished()) { in Quiesce()609 if (cancelled_) { in Quiesce()[all …]
246 cancelled_ = true; in ~Iterator()268 while (!cancelled_) { in GetNextInternal()675 while (!cancelled_ && !workers_[thread_index].is_producing) { in WorkerThread()680 if (cancelled_) return; in WorkerThread()726 while (!cancelled_ && workers_[thread_index].outputs.size() == in WorkerThread()732 if (cancelled_) return; in WorkerThread()777 while (!cancelled_ && workers_[thread_index].outputs.size() == in WorkerThread()783 if (cancelled_) return; in WorkerThread()1060 bool cancelled_ GUARDED_BY(mu_) = false;
272 cancelled_ = true; in ~Iterator()616 while (!cancelled_ && busy()) { in RunnerThread()631 if (cancelled_) { in RunnerThread()802 bool cancelled_ GUARDED_BY(*mu_) = false;
46 cancelled_ = true; in ~GcsDnsCache()67 bool cancelled_ GUARDED_BY(mu_) = false;
158 if (cancelled_) return; in WorkerThread()160 if (cancelled_) return; in WorkerThread()
442 cancelled_ = true; in ~BackgroundWorker()466 while (!cancelled_ && work_queue_.empty()) { in WorkerLoop()469 if (cancelled_) { in WorkerLoop()
938 bool cancelled_ GUARDED_BY(mu_) = false;