summaryrefslogtreecommitdiffstats
path: root/sys/geom
diff options
context:
space:
mode:
authormav <mav@FreeBSD.org>2015-03-26 08:36:08 +0000
committermav <mav@FreeBSD.org>2015-03-26 08:36:08 +0000
commit40ede50928fcdb02a1ba5fdee412e112b8073513 (patch)
tree709a7d27eab9e3e31805c440a2642d444602c5a3 /sys/geom
parent2f25ad094c26d229d2e0806b8ca9c6244a5af63d (diff)
downloadFreeBSD-src-40ede50928fcdb02a1ba5fdee412e112b8073513.zip
FreeBSD-src-40ede50928fcdb02a1ba5fdee412e112b8073513.tar.gz
MFC r279913: Fix couple BIO_DELETE bugs in geom_mirror.
Do not report GEOM::candelete if none of providers support BIO_DELETE. If consumer still requests BIO_DELETE, report error instead of hanging.
Diffstat (limited to 'sys/geom')
-rw-r--r--sys/geom/mirror/g_mirror.c26
1 files changed, 24 insertions, 2 deletions
diff --git a/sys/geom/mirror/g_mirror.c b/sys/geom/mirror/g_mirror.c
index e4dffdc..0bd9d81 100644
--- a/sys/geom/mirror/g_mirror.c
+++ b/sys/geom/mirror/g_mirror.c
@@ -1027,6 +1027,23 @@ g_mirror_sync_done(struct bio *bp)
}
static void
+g_mirror_candelete(struct bio *bp)
+{
+ struct g_mirror_softc *sc;
+ struct g_mirror_disk *disk;
+ int *val;
+
+ sc = bp->bio_to->geom->softc;
+ LIST_FOREACH(disk, &sc->sc_disks, d_next) {
+ if (disk->d_flags & G_MIRROR_DISK_FLAG_CANDELETE)
+ break;
+ }
+ val = (int *)bp->bio_data;
+ *val = (disk != NULL);
+ g_io_deliver(bp, 0);
+}
+
+static void
g_mirror_kernel_dump(struct bio *bp)
{
struct g_mirror_softc *sc;
@@ -1120,9 +1137,10 @@ g_mirror_start(struct bio *bp)
g_mirror_flush(sc, bp);
return;
case BIO_GETATTR:
- if (g_handleattr_int(bp, "GEOM::candelete", 1))
+ if (!strcmp(bp->bio_attribute, "GEOM::candelete")) {
+ g_mirror_candelete(bp);
return;
- else if (strcmp("GEOM::kerneldump", bp->bio_attribute) == 0) {
+ } else if (strcmp("GEOM::kerneldump", bp->bio_attribute) == 0) {
g_mirror_kernel_dump(bp);
return;
}
@@ -1686,6 +1704,10 @@ g_mirror_register_request(struct bio *bp)
("Consumer %s not opened (r%dw%de%d).",
cp->provider->name, cp->acr, cp->acw, cp->ace));
}
+ if (bioq_first(&queue) == NULL) {
+ g_io_deliver(bp, EOPNOTSUPP);
+ return;
+ }
while ((cbp = bioq_takefirst(&queue)) != NULL) {
G_MIRROR_LOGREQ(3, cbp, "Sending request.");
cp = cbp->bio_caller1;
OpenPOWER on IntegriCloud