145     const int N = NUMBER_OF_MSGS;  in test_reset()  local
164     for (int i = 0; i < N; ++i) {  in test_reset()
183     for (int i = 0; i < N; ++i) {  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()
204     for (int i = 0; i < N; ++i) {  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()
223     for (int i = 0; i < N; ++i) {  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()
242     for (int i = 0; i < N; ++i) {  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()
262     for (int i = 0; i < N; ++i) {  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()
467     const int N = NUMBER_OF_MSGS;  in test_copy_ctor()  local
482     for (int i = 0; i < N; ++i) {  in test_copy_ctor()
490     CHECK_MESSAGE( ( int(r1.my_count) == N), "counting receiver r1 has not received N items" );  in test_copy_ctor()
493     for (int i = 0; i < N; ++i) {  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()