From 78929984b35f18549d709e695fda2db9701ed3dd Mon Sep 17 00:00:00 2001 From: phk Date: Tue, 1 Apr 2003 12:49:40 +0000 Subject: [PATCH] Introduce bioq_flush() function. --- sys/kern/subr_disk.c | 15 +++++++++++++++ sys/sys/bio.h | 1 + 2 files changed, 16 insertions(+) diff --git a/sys/kern/subr_disk.c b/sys/kern/subr_disk.c index 35c2295b745e..475b4d873d3a 100644 --- a/sys/kern/subr_disk.c +++ b/sys/kern/subr_disk.c @@ -89,6 +89,21 @@ bioq_remove(struct bio_queue_head *head, struct bio *bp) if (TAILQ_FIRST(&head->queue) == head->switch_point) head->switch_point = NULL; } + +void +bioq_flush(struct bio_queue_head *head, struct devstat *stp, int error) +{ + struct bio *bp; + + for (;;) { + bp = bioq_first(head); + if (bp == NULL) + break; + bioq_remove(head, bp); + biofinish(bp, stp, ENXIO); + } +} + void bioq_insert_tail(struct bio_queue_head *head, struct bio *bp) { diff --git a/sys/sys/bio.h b/sys/sys/bio.h index c7e81ea8d114..89b68f588647 100644 --- a/sys/sys/bio.h +++ b/sys/sys/bio.h @@ -120,6 +120,7 @@ int biowait(struct bio *bp, const char *wchan); void bioq_disksort(struct bio_queue_head *ap, struct bio *bp); #define bioqdisksort(foo, bar) bioq_disksort(foo, bar) struct bio *bioq_first(struct bio_queue_head *head); +void bioq_flush(struct bio_queue_head *head, struct devstat *stp, int error); void bioq_init(struct bio_queue_head *head); void bioq_insert_tail(struct bio_queue_head *head, struct bio *bp); void bioq_remove(struct bio_queue_head *head, struct bio *bp);