Searched refs:task_proxy (Results 1 – 5 of 5) sorted by relevance
31 struct task_proxy : public d1::task { struct42 std::atomic<task_proxy*> next_in_mailbox; argument98 typedef std::atomic<task_proxy*> atomic_proxy_ptr;115 task_proxy* internal_pop( isolation_type isolation ) { in internal_pop()116 task_proxy* curr = my_first.load(std::memory_order_acquire); in internal_pop()131 if ( task_proxy* second = curr->next_in_mailbox.load(std::memory_order_acquire) ) { in internal_pop()159 void push( task_proxy* t ) { in push()191 for( ; task_proxy* t = my_first; ) { in drain()221 task_proxy* pop( isolation_type isolation ) { in pop()
46 task_proxy& tp = static_cast<task_proxy&>(*result); in get_task_impl()48 if ( d1::task *t = tp.extract_task<task_proxy::pool_bit>() ) { in get_task_impl()176 task_proxy& tp = *static_cast<task_proxy*>(result); in steal_task()178 …if (!task_proxy::is_shared(tp.task_and_tag) || !tp.outbox->recipient_is_idle() || a.mailbox(slot_i… in steal_task()
459 task_proxy &tp = *(task_proxy*)t; in steal_task()461 t = tp.extract_task<task_proxy::pool_bit>(); in steal_task()
57 auto proxy = alloc.new_object<task_proxy>(static_cast<d1::execution_data&>(ed)); in spawn()67 proxy->task_and_tag = intptr_t(&t) | task_proxy::location_mask; in spawn()
442 while (task_proxy* const tp = my_inbox.pop(isolation)) { in get_mailbox_task()443 if (d1::task* result = tp->extract_task<task_proxy::mailbox_bit>()) { in get_mailbox_task()