152     tbb::flow::continue_node<int> cnode(g, /*number_of_predecessors*/ 1,  in TestContinueNode()  local
155     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()
181 …  CHECK_MESSAGE( (!cnode.my_successors.empty()), "Empty successors in built graph (before reset)");  in TestContinueNode()
182 …       CHECK_MESSAGE( (cnode.my_predecessor_count == 2), "predecessor_count reset (before reset)");  in TestContinueNode()
184 …  CHECK_MESSAGE( (!cnode.my_successors.empty()), "Empty successors in built graph (after reset)" );  in TestContinueNode()
185 …        CHECK_MESSAGE( (cnode.my_predecessor_count == 2), "predecessor_count reset (after reset)");  in TestContinueNode()
190 … CHECK_MESSAGE( (!cnode.my_successors.empty()), "Empty successors in built graph (before reset)" );  in TestContinueNode()
191 …      CHECK_MESSAGE( (cnode.my_predecessor_count == 2), "predecessor_count reset (before reset)" );  in TestContinueNode()
193 …CHECK_MESSAGE( (cnode.my_current_count == 0), "state of continue_receiver incorrect after reset(rf…  in TestContinueNode()
194 …CHECK_MESSAGE( (cnode.my_successors.empty()), "buffering node has a successor after reset(rf_clear…  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()
209             CHECK_MESSAGE( (cnode.my_current_count == 1), "state of continue_receiver incorrect");  in TestContinueNode()
216 …CHECK_MESSAGE( (cnode.my_current_count == 0), " my_current_count not reset before body of continue…  in TestContinueNode()