88     Body( int priority, utils::SpinBarrier& barrier )  in Body()
89         : my_priority( priority ), my_barrier( barrier ) {}  in Body()
105     NodeType* operator()( graph& g, unsigned index, utils::SpinBarrier& barrier ) {  in operator ()()
107             return new NodeType( g, unlimited, BodyType(index, barrier), node_priority_t(index) );  in operator ()()
109             return new NodeType( g, unlimited, BodyType(no_priority, barrier) );  in operator ()()
115 … continue_node<continue_msg>* operator()( graph& g, unsigned index, utils::SpinBarrier& barrier ) {  in operator ()()
117 …     return new continue_node<continue_msg>( g, BodyType(index, barrier), node_priority_t(index) );  in operator ()()
119             return new continue_node<continue_msg>( g, BodyType(no_priority, barrier) );  in operator ()()
132     utils::SpinBarrier barrier( num_threads );  in test_node()  local
140         nodes.push_back(std::unique_ptr<NodeType>( node_creator(g, i, barrier) ));  in test_node()
265         ServiceThreadFunc(SpinBarrier& barrier) : my_barrier(barrier) {}  in ServiceThreadFunc()
285     AsyncActivity(SpinBarrier& barrier)  in AsyncActivity()
286         : done(false), my_service_thread(ServiceThreadFunc(barrier), this) {}  in AsyncActivity()
305     ParallelForBody(SpinBarrier& barrier, const data_type& input)  in ParallelForBody()
306         : my_barrier(barrier), my_input(input) {}  in ParallelForBody()
320     CpuWorkBody(SpinBarrier& barrier, int tasks_count)  in CpuWorkBody()
321         : my_barrier(barrier), my_tasks_count(tasks_count) {}  in CpuWorkBody()
359     SpinBarrier barrier(cpu_threads + /*async thread=*/1);  in test()  local
367             AsyncActivity activity(barrier);  in test()
372                 g, unlimited, CpuWorkBody(barrier, nested_cpu_tasks));  in test()
742             barrier == 0, "Non-priority successor has to be executed after all priority successors"  in operator ()()
745     std::atomic<int>& barrier;  member
750         --barrier;  in operator ()()
751         while (barrier)  in operator ()()
754     std::atomic<int>& barrier;  member
764             std::atomic<int> barrier;  in test()  local
768                         new continue_node<continue_msg>(g, no_priority_node_body{ barrier })  in test()
774 …                   new continue_node<continue_msg>(g, priority_node_body{ barrier }, /*priority*/1)  in test()
782                 barrier = num_threads;  in test()