| 462 | } |
| 463 | |
| 464 | void thread(unsigned int tid) |
| 465 | { |
| 466 | RelacyThreadExitNotifier::notify_relacy_thread_start(); |
| 467 | |
| 468 | for (int i = 0; i != 7; ++i) { |
| 469 | q.enqueue(tid * 7 + i); |
| 470 | } |
| 471 | |
| 472 | int item; |
| 473 | ConsumerToken t(q); |
| 474 | for (int i = 0; i != 7; ++i) { |
| 475 | if (q.try_dequeue(t, item)) { |
| 476 | RL_ASSERT(!seen[item]); |
| 477 | seen[item] = true; |
| 478 | } |
| 479 | } |
| 480 | |
| 481 | RelacyThreadExitNotifier::notify_relacy_thread_exit(); |
| 482 | } |
| 483 | |
| 484 | void after() |
| 485 | { |
nothing calls this directly
no test coverage detected