Searched refs:cnode (Results 1 – 1 of 1) sorted by relevance
152 tbb::flow::continue_node<int> cnode(g, /*number_of_predecessors*/ 1, in TestContinueNode() local155 tbb::flow::make_edge(fnode0, cnode); in TestContinueNode()156 tbb::flow::make_edge(cnode, fnode1); in TestContinueNode()160 … CHECK_MESSAGE( (cnode.my_predecessor_count == 2), "predecessor addition didn't increment count"); in TestContinueNode()161 CHECK_MESSAGE( (!cnode.successors().empty()), "successors empty though we added one"); in TestContinueNode()162 CHECK_MESSAGE( (cnode.my_current_count == 0), "state of continue_receiver incorrect"); in TestContinueNode()177 CHECK_MESSAGE( (!cnode.try_get(i)), "try_get not rejected"); in TestContinueNode()195 …CHECK_MESSAGE( (cnode.my_predecessor_count == cnode.my_initial_predecessor_count), "predecessor co… in TestContinueNode()205 tbb::spin_mutex::scoped_lock l(cnode.my_mutex); in TestContinueNode()206 return serial_continue_state0 == 0 && cnode.my_current_count == 0; in TestContinueNode()[all …]