Searched refs:get_cancellation_token (Results 1 – 25 of 27) sorted by relevance
12
32 auto token = manager->get_cancellation_token(); in TEST()45 auto token = manager->get_cancellation_token(); in TEST()56 auto token = manager->get_cancellation_token(); in TEST()66 auto token = manager->get_cancellation_token(); in TEST()80 auto token_1 = manager->get_cancellation_token(); in TEST()84 auto token_2 = manager->get_cancellation_token(); in TEST()94 auto token_3 = manager->get_cancellation_token(); in TEST()129 auto token = cm.get_cancellation_token(); in TEST()150 auto token = manager->get_cancellation_token(); in TEST()163 auto token = manager->get_cancellation_token(); in TEST()[all …]
56 CancellationToken token = cm->get_cancellation_token(); in Compute()
71 CancellationToken get_cancellation_token() { in get_cancellation_token() function
213 CancellationToken token = cancellation_manager->get_cancellation_token(); in RegisterCancellationCallback()
204 token = cm->get_cancellation_token(); in RecvAsync()
53 CancellationToken token = cm->get_cancellation_token(); in TryEnqueue()111 CancellationToken token = cm->get_cancellation_token(); in TryEnqueueMany()157 CancellationToken token = cm->get_cancellation_token(); in TryDequeue()248 CancellationToken token = cm->get_cancellation_token(); in TryDequeueMany()
74 CancellationToken token = cm->get_cancellation_token(); in TryEnqueue()139 CancellationToken token = cm->get_cancellation_token(); in TryEnqueueMany()201 CancellationToken token = cm->get_cancellation_token(); in TryDequeue()292 CancellationToken token = cm->get_cancellation_token(); in TryDequeueMany()
131 CancellationToken token = cm->get_cancellation_token(); in TryEnqueue()189 CancellationToken token = cm->get_cancellation_token(); in TryEnqueueMany()236 CancellationToken token = cm->get_cancellation_token(); in TryDequeue()328 CancellationToken token = cm->get_cancellation_token(); in TryDequeueMany()
73 CancellationToken token = cm->get_cancellation_token(); in TryTakeGrad()
85 token = cm->get_cancellation_token(); in AcquireAsync()
90 CancellationToken token = cm->get_cancellation_token(); in TryDequeueMany()
24 CancellationToken token = cancel_mgr_->get_cancellation_token(); in Start()
212 token = cancellation_manager_.get_cancellation_token(); in DoRunGraph()314 token = cancellation_manager_.get_cancellation_token(); in DoPartialRunGraph()
301 abortion_cancel_mgr_.get_cancellation_token(); in CompleteGroupDistributed()391 abortion_cancel_mgr_.get_cancellation_token(); in CompleteInstanceDistributed()
176 abortion_cancel_mgr_.get_cancellation_token(); in RecvFromPeer()
413 auto token = cm->get_cancellation_token(); in RegisterCall()
103 cancellation_token = cancellation_manager->get_cancellation_token(); in ProvideBuf()194 cancellation_token = cancellation_manager->get_cancellation_token(); in ConsumeBuf()
104 const CancellationToken token = cancel_mgr->get_cancellation_token(); in CompleteGroupLocal()
48 ctx->cancellation_manager()->get_cancellation_token(); in ComputeAsync()
545 ctx->cancellation_manager()->get_cancellation_token(); in Compute()
56 token = cm->get_cancellation_token(); in RunAsync()
208 token = cm->get_cancellation_token(); in Run()
88 CancellationToken cancel_token = cancel_mgr->get_cancellation_token(); in Enqueue()
126 ctx->cancellation_manager()->get_cancellation_token(); in Compute()
349 CancellationToken token = cancellation_manager->get_cancellation_token(); in RegisterCancellation()