| 507 | }; |
| 508 | |
| 509 | void *run_first_tasks(void* arg) { |
| 510 | bthread::ExecutionQueueId<InPlaceTask> queue_id = { (uint64_t)arg }; |
| 511 | InPlaceTask task; |
| 512 | task.first_task = true; |
| 513 | task.thread_id = pthread_self(); |
| 514 | EXPECT_EQ(0, bthread::execution_queue_execute( |
| 515 | queue_id, task, &bthread::TASK_OPTIONS_INPLACE)); |
| 516 | return NULL; |
| 517 | } |
| 518 | |
| 519 | int stuck_and_check_running_thread(void* arg, bthread::TaskIterator<InPlaceTask>& iter) { |
| 520 | if (iter.is_queue_stopped()) { |
nothing calls this directly
no test coverage detected