Searched refs:cancel_pending_enqueues_ (Results 1 – 3 of 3) sorted by relevance
56 cancel_pending_enqueues_(false), in Barrier()115 !cancel_pending_enqueues_ && in TryInsertMany()119 cancel_pending_enqueues_, in TryInsertMany()258 if (closed_ && (cancel_pending_enqueues_ || !cancel_pending_enqueues)) { in Close()264 cancel_pending_enqueues_ = cancel_pending_enqueues; in Close()266 if (cancel_pending_enqueues_ || incomplete_.empty()) { in Close()269 CloseQueueLocked(ctx, cancel_pending_enqueues_, callback); in Close()322 ". Pending enqueues cancelled: ", cancel_pending_enqueues_, in InsertOneLocked()431 bool cancel_pending_enqueues_ GUARDED_BY(mu_);636 &cancel_pending_enqueues_)); in BarrierCloseOp()[all …]
330 &cancel_pending_enqueues_)); in QueueCloseOp()335 queue->Close(ctx, cancel_pending_enqueues_, callback); in ComputeAsync()
235 bool cancel_pending_enqueues_;