| 468 | } |
| 469 | |
| 470 | int check_running_thread(void* arg, bthread::TaskIterator<LongIntTask>& iter) { |
| 471 | if (iter.is_queue_stopped()) { |
| 472 | return 0; |
| 473 | } |
| 474 | for (; iter; ++iter) {} |
| 475 | EXPECT_EQ(pthread_self(), (pthread_t)arg); |
| 476 | return 0; |
| 477 | } |
| 478 | |
| 479 | void test_in_place_task(bool use_pthread) { |
| 480 | pthread_t thread_id = pthread_self(); |
nothing calls this directly
no test coverage detected