| 379 | } |
| 380 | |
| 381 | static int |
| 382 | task_is_running(struct gtaskqueue *queue, struct gtask *gtask) |
| 383 | { |
| 384 | struct gtaskqueue_busy *tb; |
| 385 | |
| 386 | TQ_ASSERT_LOCKED(queue); |
| 387 | LIST_FOREACH(tb, &queue->tq_active, tb_link) { |
| 388 | if (tb->tb_running == gtask) |
| 389 | return (1); |
| 390 | } |
| 391 | return (0); |
| 392 | } |
| 393 | |
| 394 | static int |
| 395 | gtaskqueue_cancel_locked(struct gtaskqueue *queue, struct gtask *gtask) |
no outgoing calls
no test coverage detected