| 684 | }; |
| 685 | |
| 686 | int cancel_self(void* /*meta*/, bthread::TaskIterator<CancelSelf*>& iter) { |
| 687 | |
| 688 | for (; iter; ++iter) { |
| 689 | while ((*iter)->handle == NULL) { |
| 690 | usleep(10); |
| 691 | } |
| 692 | EXPECT_EQ(1, bthread::execution_queue_cancel(*(*iter)->handle.load())); |
| 693 | EXPECT_EQ(1, bthread::execution_queue_cancel(*(*iter)->handle.load())); |
| 694 | EXPECT_EQ(1, bthread::execution_queue_cancel(*(*iter)->handle.load())); |
| 695 | } |
| 696 | return 0; |
| 697 | } |
| 698 | |
| 699 | void test_cancel_self(bool use_pthread) { |
| 700 | bthread::ExecutionQueueId<CancelSelf*> queue_id = { 0 }; // to suppress warnings |
nothing calls this directly
no test coverage detected