diff options
author | mav <mav@FreeBSD.org> | 2009-12-30 17:23:27 +0000 |
---|---|---|
committer | mav <mav@FreeBSD.org> | 2009-12-30 17:23:27 +0000 |
commit | b5e1bf6b39a54b6002831b1f842627cf421b0794 (patch) | |
tree | d009ddc6a14c838836b845f54686d588c5004c72 | |
parent | 5694a8569bd5c057cbf3a314c8bc3fab41f9b91a (diff) | |
download | FreeBSD-src-b5e1bf6b39a54b6002831b1f842627cf421b0794.zip FreeBSD-src-b5e1bf6b39a54b6002831b1f842627cf421b0794.tar.gz |
Call wakeup() only for the first request on the queue.
-rw-r--r-- | sys/geom/geom_io.c | 10 |
1 files changed, 8 insertions, 2 deletions
diff --git a/sys/geom/geom_io.c b/sys/geom/geom_io.c index c95840a..0b6525e 100644 --- a/sys/geom/geom_io.c +++ b/sys/geom/geom_io.c @@ -391,6 +391,7 @@ void g_io_request(struct bio *bp, struct g_consumer *cp) { struct g_provider *pp; + int first; KASSERT(cp != NULL, ("NULL cp in g_io_request")); KASSERT(bp != NULL, ("NULL bp in g_io_request")); @@ -463,12 +464,14 @@ g_io_request(struct bio *bp, struct g_consumer *cp) pp->nstart++; cp->nstart++; + first = TAILQ_EMPTY(&g_bio_run_down.bio_queue); TAILQ_INSERT_TAIL(&g_bio_run_down.bio_queue, bp, bio_queue); g_bio_run_down.bio_queue_length++; g_bioq_unlock(&g_bio_run_down); /* Pass it on down. */ - wakeup(&g_wait_down); + if (first) + wakeup(&g_wait_down); } void @@ -476,6 +479,7 @@ g_io_deliver(struct bio *bp, int error) { struct g_consumer *cp; struct g_provider *pp; + int first; KASSERT(bp != NULL, ("NULL bp in g_io_deliver")); pp = bp->bio_to; @@ -536,11 +540,13 @@ g_io_deliver(struct bio *bp, int error) pp->nend++; if (error != ENOMEM) { bp->bio_error = error; + first = TAILQ_EMPTY(&g_bio_run_up.bio_queue); TAILQ_INSERT_TAIL(&g_bio_run_up.bio_queue, bp, bio_queue); bp->bio_flags |= BIO_ONQUEUE; g_bio_run_up.bio_queue_length++; g_bioq_unlock(&g_bio_run_up); - wakeup(&g_wait_up); + if (first) + wakeup(&g_wait_up); return; } g_bioq_unlock(&g_bio_run_up); |