| 433 | } |
| 434 | |
| 435 | void |
| 436 | gtaskqueue_drain_all(struct gtaskqueue *queue) |
| 437 | { |
| 438 | |
| 439 | if (!queue->tq_spin) |
| 440 | WITNESS_WARN(WARN_GIANTOK | WARN_SLEEPOK, NULL, __func__); |
| 441 | |
| 442 | TQ_LOCK(queue); |
| 443 | gtaskqueue_drain_tq_queue(queue); |
| 444 | gtaskqueue_drain_tq_active(queue); |
| 445 | TQ_UNLOCK(queue); |
| 446 | } |
| 447 | |
| 448 | static int |
| 449 | _gtaskqueue_start_threads(struct gtaskqueue **tqp, int count, int pri, |
nothing calls this directly
no test coverage detected