summaryrefslogtreecommitdiffstats
path: root/sys/kern/vfs_bio.c
diff options
context:
space:
mode:
Diffstat (limited to 'sys/kern/vfs_bio.c')
-rw-r--r--sys/kern/vfs_bio.c41
1 files changed, 26 insertions, 15 deletions
diff --git a/sys/kern/vfs_bio.c b/sys/kern/vfs_bio.c
index 7b1aa8e..db7d681 100644
--- a/sys/kern/vfs_bio.c
+++ b/sys/kern/vfs_bio.c
@@ -3687,11 +3687,34 @@ void
dev_strategy(struct cdev *dev, struct buf *bp)
{
struct cdevsw *csw;
- struct bio *bip;
int ref;
- if ((!bp->b_iocmd) || (bp->b_iocmd & (bp->b_iocmd - 1)))
- panic("b_iocmd botch");
+ KASSERT(dev->si_refcount > 0,
+ ("dev_strategy on un-referenced struct cdev *(%s) %p",
+ devtoname(dev), dev));
+
+ csw = dev_refthread(dev, &ref);
+ dev_strategy_csw(dev, csw, bp);
+ dev_relthread(dev, ref);
+}
+
+void
+dev_strategy_csw(struct cdev *dev, struct cdevsw *csw, struct buf *bp)
+{
+ struct bio *bip;
+
+ KASSERT(bp->b_iocmd == BIO_READ || bp->b_iocmd == BIO_WRITE,
+ ("b_iocmd botch"));
+ KASSERT(((dev->si_flags & SI_ETERNAL) != 0 && csw != NULL) ||
+ dev->si_threadcount > 0,
+ ("dev_strategy_csw threadcount cdev *(%s) %p", devtoname(dev),
+ dev));
+ if (csw == NULL) {
+ bp->b_error = ENXIO;
+ bp->b_ioflags = BIO_ERROR;
+ bufdone(bp);
+ return;
+ }
for (;;) {
bip = g_new_bio();
if (bip != NULL)
@@ -3707,19 +3730,7 @@ dev_strategy(struct cdev *dev, struct buf *bp)
bip->bio_done = bufdonebio;
bip->bio_caller2 = bp;
bip->bio_dev = dev;
- KASSERT(dev->si_refcount > 0,
- ("dev_strategy on un-referenced struct cdev *(%s)",
- devtoname(dev)));
- csw = dev_refthread(dev, &ref);
- if (csw == NULL) {
- g_destroy_bio(bip);
- bp->b_error = ENXIO;
- bp->b_ioflags = BIO_ERROR;
- bufdone(bp);
- return;
- }
(*csw->d_strategy)(bip);
- dev_relthread(dev, ref);
}
/*
OpenPOWER on IntegriCloud