Lines Matching defs:dc
53 dispatch_continuation_t dc, pthread_priority_t pp);
1818 dispatch_continuation_t dc;
1819 dc = _dispatch_thread_getspecific(dispatch_cache_key);
1820 if (dc) {
1822 _dispatch_cache_cleanup(dc);
1830 dispatch_continuation_t dc, next_dc = value;
1832 while ((dc = next_dc)) {
1833 next_dc = dc->do_next;
1834 _dispatch_continuation_free_to_heap(dc);
1843 _dispatch_continuation_free_to_cache_limit(dispatch_continuation_t dc)
1845 _dispatch_continuation_free_to_heap(dc);
1847 dc = _dispatch_thread_getspecific(dispatch_cache_key);
1849 if (!dc || (cnt = dc->dc_cache_cnt -
1854 next_dc = dc->do_next;
1855 _dispatch_continuation_free_to_heap(dc);
1856 } while (--cnt && (dc = next_dc));
1865 dispatch_continuation_t dc = dou._dc;
1868 if (!DISPATCH_OBJ_IS_VTABLE(dc) &&
1869 (long)dc->do_vtable & DISPATCH_OBJ_SYNC_SLOW_BIT) {
1872 (_dispatch_thread_semaphore_t)dc->dc_other);
1875 _dispatch_async_f_redirect(dq, dc,
2234 dispatch_continuation_t dc = _dispatch_continuation_alloc_from_heap();
2236 dc->do_vtable = (void *)(DISPATCH_OBJ_ASYNC_BIT | DISPATCH_OBJ_BARRIER_BIT);
2237 dc->dc_func = func;
2238 dc->dc_ctxt = ctxt;
2239 _dispatch_continuation_voucher_set(dc, flags);
2240 _dispatch_continuation_priority_set(dc, pp, flags);
2242 pp = _dispatch_continuation_get_override_priority(dq, dc);
2244 _dispatch_queue_push(dq, dc, pp);
2253 dispatch_continuation_t dc;
2255 dc = fastpath(_dispatch_continuation_alloc_cacheonly());
2256 if (!dc) {
2260 dc->do_vtable = (void *)(DISPATCH_OBJ_ASYNC_BIT | DISPATCH_OBJ_BARRIER_BIT);
2261 dc->dc_func = func;
2262 dc->dc_ctxt = ctxt;
2263 _dispatch_continuation_voucher_set(dc, flags);
2264 _dispatch_continuation_priority_set(dc, pp, flags);
2266 pp = _dispatch_continuation_get_override_priority(dq, dc);
2268 _dispatch_queue_push(dq, dc, pp);
2324 struct dispatch_continuation_s *dc = ctxt;
2325 struct dispatch_continuation_s *other_dc = dc->dc_other;
2326 dispatch_queue_t old_dq, dq = dc->dc_data, rq;
2350 _dispatch_async_f_redirect2(dispatch_queue_t dq, dispatch_continuation_t dc,
2370 _dispatch_queue_push_wakeup(dq, dc, pp, running == 0);
2378 dispatch_continuation_t dc = _dispatch_continuation_alloc();
2380 dc->do_vtable = (void *)DISPATCH_OBJ_ASYNC_BIT;
2381 dc->dc_func = _dispatch_async_redirect_invoke;
2382 dc->dc_ctxt = dc;
2383 dc->dc_data = dq;
2384 dc->dc_other = other_dc;
2385 dc->dc_priority = 0;
2386 dc->dc_voucher = NULL;
2391 return _dispatch_async_f_redirect2(dq, dc, pp);
2394 _dispatch_queue_push(dq, dc, pp);
2399 _dispatch_async_f2(dispatch_queue_t dq, dispatch_continuation_t dc,
2415 return _dispatch_async_f_redirect(dq, dc, pp);
2421 _dispatch_queue_push_wakeup(dq, dc, pp, running == 0);
2430 dispatch_continuation_t dc = _dispatch_continuation_alloc_from_heap();
2432 dc->do_vtable = (void *)DISPATCH_OBJ_ASYNC_BIT;
2433 dc->dc_func = func;
2434 dc->dc_ctxt = ctxt;
2435 _dispatch_continuation_voucher_set(dc, flags);
2436 _dispatch_continuation_priority_set(dc, pp, flags);
2438 pp = _dispatch_continuation_get_override_priority(dq, dc);
2442 return _dispatch_async_f2(dq, dc, pp);
2445 _dispatch_queue_push(dq, dc, pp);
2453 dispatch_continuation_t dc;
2460 dc = fastpath(_dispatch_continuation_alloc_cacheonly());
2461 if (!dc) {
2465 dc->do_vtable = (void *)DISPATCH_OBJ_ASYNC_BIT;
2466 dc->dc_func = func;
2467 dc->dc_ctxt = ctxt;
2468 _dispatch_continuation_voucher_set(dc, flags);
2469 _dispatch_continuation_priority_set(dc, pp, flags);
2471 pp = _dispatch_continuation_get_override_priority(dq, dc);
2475 return _dispatch_async_f2(dq, dc, pp);
2478 _dispatch_queue_push(dq, dc, pp);
2518 dispatch_continuation_t dc;
2523 dc = _dispatch_continuation_alloc();
2527 dc->do_vtable = (void *)(DISPATCH_OBJ_ASYNC_BIT | DISPATCH_OBJ_GROUP_BIT |
2529 dc->dc_func = func;
2530 dc->dc_ctxt = ctxt;
2531 dc->dc_data = dg;
2532 _dispatch_continuation_voucher_set(dc, flags);
2533 _dispatch_continuation_priority_set(dc, pp, flags);
2535 pp = _dispatch_continuation_get_override_priority(dq, dc);
2539 return _dispatch_async_f2(dq, dc, pp);
2542 _dispatch_queue_push(dq, dc, pp);
2596 dispatch_continuation_t dc = ctxt;
2597 _dispatch_function_invoke(dc->dc_data, dc->dc_ctxt, dc->dc_func);
2605 struct dispatch_continuation_s dc = {
2610 _dispatch_sync_f(dq->do_targetq, &dc, _dispatch_sync_recurse_invoke, pp);
2625 dispatch_continuation_t dc = dou._dc;
2628 if (DISPATCH_OBJ_IS_VTABLE(dc) || ((long)dc->do_vtable &
2633 _dispatch_trace_continuation_pop(dq, dc);
2636 th = (mach_port_t)dc->dc_data;
2637 dc = dc->dc_ctxt;
2638 dq = dc->dc_data;
2639 sema = (_dispatch_thread_semaphore_t)dc->dc_other;
2656 dispatch_continuation_t dc = ctxt;
2657 dispatch_queue_t dq = dc->dc_data;
2659 sema = (_dispatch_thread_semaphore_t)dc->dc_other;
2665 _dispatch_continuation_voucher_adopt(dc);
2666 _dispatch_client_callout(dc->dc_ctxt, dc->dc_func);
2667 dispatch_atomic_store2o(dc, dc_func, NULL, release);
2691 struct dispatch_continuation_s dc = {
2704 _dispatch_continuation_voucher_set(&dc, 0);
2711 .dc_ctxt = &dc,
2723 if (dc.dc_func == NULL) {
2936 struct dispatch_continuation_s dc = {
2946 _dispatch_queue_push_wakeup(dq, &dc,
2947 _dispatch_continuation_get_override_priority(dq, &dc), wakeup);
3103 dispatch_continuation_t dc = ctxt, dc1;
3104 dispatch_source_t ds = dc->dc_data;
3105 dc1 = _dispatch_continuation_free_cacheonly(dc);
3106 _dispatch_client_callout(dc->dc_ctxt, dc->dc_func);
3143 dispatch_continuation_t dc = _dispatch_continuation_alloc();
3144 dc->do_vtable = (void *)(DISPATCH_OBJ_ASYNC_BIT);
3145 dc->dc_func = func;
3146 dc->dc_ctxt = ctxt;
3147 dc->dc_data = ds;
3149 dispatch_set_context(ds, dc);
3482 struct dispatch_object_s *dc;
3483 _dispatch_wait_until(dc = fastpath(dq->dq_items_head));
3484 return dc;
3489 _dispatch_queue_next(dispatch_queue_t dq, struct dispatch_object_s *dc)
3492 next_dc = fastpath(dc->do_next);
3494 if (!next_dc && !dispatch_atomic_cmpxchg2o(dq, dq_items_tail, dc, NULL,
3496 _dispatch_wait_until(next_dc = fastpath(dc->do_next));
3507 struct dispatch_object_s *dc, *next_dc;
3528 dc = _dispatch_queue_head(dq);
3541 if (!DISPATCH_OBJ_IS_VTABLE(dc) &&
3542 (long)dc->do_vtable & DISPATCH_OBJ_BARRIER_BIT) {
3550 next_dc = _dispatch_queue_next(dq, dc);
3552 _dispatch_continuation_redirect(dq, dc);
3555 if ((sema = _dispatch_barrier_sync_f_pop(dq, dc, true))) {
3558 _dispatch_continuation_pop(dc);
3560 } while ((dc = next_dc));
3590 struct dispatch_object_s *dc, *next_dc;
3591 dc = _dispatch_queue_head(dq);
3593 next_dc = _dispatch_queue_next(dq, dc);
3594 if (dc == dmarker) {
3597 _dispatch_continuation_pop(dc);
3599 } while ((dc = next_dc));
3628 struct dispatch_object_s *dc, *next_dc;
3629 dc = _dispatch_queue_head(dq);
3630 next_dc = _dispatch_queue_next(dq, dc);
3631 _dispatch_continuation_pop(dc);
3649 struct dispatch_object_s *dc;
3653 dc = dq->dq_items_head;
3654 if (slowpath(!dc) || !(sema = _dispatch_barrier_sync_f_pop(dq, dc, false))){
3657 // dequeue dc, it is a barrier sync
3658 (void)_dispatch_queue_next(dq, dc);
3785 dispatch_continuation_t dc = (dispatch_continuation_t)ctxt;
3786 dispatch_queue_t dq = dc->dc_data;
3797 _dispatch_reset_defaultpriority(dc->dc_priority);
3869 dispatch_continuation_t dc = _dispatch_continuation_alloc();
3870 dc->do_vtable = (void *)(DISPATCH_OBJ_ASYNC_BIT | DISPATCH_OBJ_BARRIER_BIT);
3871 dc->dc_func = _dispatch_queue_override_invoke;
3872 dc->dc_ctxt = dc;
3873 dc->dc_priority = tq->dq_priority;
3874 dc->dc_voucher = NULL;
3875 dc->dc_data = dq;
3878 _dispatch_queue_push(rq, dc, 0);