91 …     CHECK_MESSAGE( ( (a.thread_id != b.thread_id)), "same thread used to execute adjacent nodes");  in check()
122             CHECK_MESSAGE( ( result == true), "attempted to cancel graph twice" );  in operator ()()
170     CHECK_MESSAGE( ( g.is_cancelled() == true), "task group not canceled" );  in test_reset()
173 …CHECK_MESSAGE( ( int(async_body_exec_count) == int(b1.my_async_body_exec_count)), "body and global…  in test_reset()
174     CHECK_MESSAGE( ( int(async_body_exec_count) == 1), "global body execution count not 1"  );  in test_reset()
176         CHECK_MESSAGE( ( int(r[i]->my_count) == 1), "counting receiver count not 1" );  in test_reset()
187     CHECK_MESSAGE( ( g.is_cancelled() == false), "task group not canceled" );  in test_reset()
193     CHECK_MESSAGE( int(async_body_exec_count) == int(b2.my_async_body_exec_count),  in test_reset()
196     CHECK_MESSAGE( ( int(async_body_exec_count) == N+1), "global body execution count not N+1"  );  in test_reset()
198 …    CHECK_MESSAGE( ( int(r[i]->my_count) == N+1), "counting receiver has not received N+1 items" );  in test_reset()
208     CHECK_MESSAGE( ( g.is_cancelled() == false), "task group not canceled" );  in test_reset()
214 …  CHECK_MESSAGE( ( int(async_body_exec_count) == 2*N+1), "global body execution count not 2N+1"  );  in test_reset()
215     CHECK_MESSAGE( ( int(b3.my_async_body_exec_count) == N), "local body execution count not N"  );  in test_reset()
217 … CHECK_MESSAGE( ( int(r[i]->my_count) == 2*N+1), "counting receiver has not received 2N+1 items" );  in test_reset()
227     CHECK_MESSAGE( ( g.is_cancelled() == false), "task group not canceled" );  in test_reset()
233 …  CHECK_MESSAGE( ( int(async_body_exec_count) == 3*N+1), "global body execution count not 3N+1"  );  in test_reset()
234 … CHECK_MESSAGE( ( int(b4.my_async_body_exec_count) == 2*N), "local body execution count not 2N"  );  in test_reset()
236 … CHECK_MESSAGE( ( int(r[i]->my_count) == 2*N+1), "counting receiver has not received 2N+1 items" );  in test_reset()
246     CHECK_MESSAGE( ( g.is_cancelled() == false), "task group not canceled" );  in test_reset()
252 …  CHECK_MESSAGE( ( int(async_body_exec_count) == 4*N+1), "global body execution count not 4N+1"  );  in test_reset()
253 … CHECK_MESSAGE( ( int(b5.my_async_body_exec_count) == 3*N), "local body execution count not 3N"  );  in test_reset()
254 … CHECK_MESSAGE( ( int(r[0]->my_count) == 3*N+1), "counting receiver has not received 3N+1 items" );  in test_reset()
256 … CHECK_MESSAGE( ( int(r[i]->my_count) == 2*N+1), "counting receiver has not received 2N+1 items" );  in test_reset()
266     CHECK_MESSAGE( ( g.is_cancelled() == false), "task group not canceled" );  in test_reset()
272 …  CHECK_MESSAGE( ( int(async_body_exec_count) == 5*N+1), "global body execution count not 5N+1"  );  in test_reset()
273     CHECK_MESSAGE( ( int(b6.my_async_body_exec_count) == N), "local body execution count not N"  );  in test_reset()
274 … CHECK_MESSAGE( ( int(r[0]->my_count) == 3*N+1), "counting receiver has not received 3N+1 items" );  in test_reset()
276 … CHECK_MESSAGE( ( int(r[i]->my_count) == 2*N+1), "counting receiver has not received 2N+1 items" );  in test_reset()
454 …CHECK_MESSAGE( ( async_body_exec_count == NUMBER_OF_MSGS), "AsyncBody processed wrong number of si…  in run()
455 …CHECK_MESSAGE( ( async_activity_processed_msg_count == NUMBER_OF_MSGS), "AsyncActivity processed w…  in run()
456 …CHECK_MESSAGE( ( end_body_exec_count == NUMBER_OF_MSGS), "EndBody processed wrong number of signal…  in run()
489 …CHECK_MESSAGE( ( int(async_body_exec_count) == NUMBER_OF_MSGS), "AsyncBody processed wrong number …  in test_copy_ctor()
490     CHECK_MESSAGE( ( int(r1.my_count) == N), "counting receiver r1 has not received N items" );  in test_copy_ctor()
491     CHECK_MESSAGE( ( int(r2.my_count) == 0), "counting receiver r2 has not received 0 items" );  in test_copy_ctor()
500 …CHECK_MESSAGE( ( int(async_body_exec_count) == 2*NUMBER_OF_MSGS), "AsyncBody processed wrong numbe…  in test_copy_ctor()
501     CHECK_MESSAGE( ( int(r1.my_count) == N), "counting receiver r1 has not received N items" );  in test_copy_ctor()
502     CHECK_MESSAGE( ( int(r2.my_count) == N), "counting receiver r2 has not received N items" );  in test_copy_ctor()
570         CHECK_MESSAGE( (async_body_exec_count == overall_message_count),  in run()
572         CHECK_MESSAGE( (async_activity_processed_msg_count == overall_message_count),  in run()
574         CHECK_MESSAGE( (end_body_exec_count == overall_message_count),  in run()
747 …CHECK_MESSAGE((buf.try_get(storage) && buf.try_get(storage) && buf.try_get(storage) && !buf.try_ge…  in test_follows()
779         CHECK_MESSAGE((successor.try_get(storage) && !successor.try_get(storage)),  in test_precedes()