sys/cddl/contrib/opensolaris/uts/common/fs/zfs/zvol.c

   1 /*
   2  * CDDL HEADER START
   3  *
   4  * The contents of this file are subject to the terms of the
   5  * Common Development and Distribution License (the "License").
   6  * You may not use this file except in compliance with the License.
   7  *
   8  * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
   9  * or http://www.opensolaris.org/os/licensing.
  10  * See the License for the specific language governing permissions
  11  * and limitations under the License.
  12  *
  13  * When distributing Covered Code, include this CDDL HEADER in each
  14  * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
  15  * If applicable, add the following below this CDDL HEADER, with the
  16  * fields enclosed by brackets "[]" replaced with your own identifying
  17  * information: Portions Copyright [yyyy] [name of copyright owner]
  18  *
  19  * CDDL HEADER END
  20  */
  21 /*
  22  * Copyright (c) 2005, 2010, Oracle and/or its affiliates. All rights reserved.
  23  *
  24  * Copyright (c) 2006-2010 Pawel Jakub Dawidek <pjd@FreeBSD.org>
  25  * All rights reserved.
  26  * Copyright (c) 2013 by Delphix. All rights reserved.
  27  * Copyright (c) 2013, Joyent, Inc. All rights reserved.
  28  */
  29
  30 /* Portions Copyright 2010 Robert Milkowski */
  31 /* Portions Copyright 2011 Martin Matuska <mm@FreeBSD.org> */
  32
  33 /*
  34  * ZFS volume emulation driver.
  35  *
  36  * Makes a DMU object look like a volume of arbitrary size, up to 2^64 bytes.
  37  * Volumes are accessed through the symbolic links named:
  38  *
  39  * /dev/zvol/dsk/<pool_name>/<dataset_name>
  40  * /dev/zvol/rdsk/<pool_name>/<dataset_name>
  41  *
  42  * These links are created by the /dev filesystem (sdev_zvolops.c).
  43  * Volumes are persistent through reboot.  No user command needs to be
  44  * run before opening and using a device.
  45  *
  46  * FreeBSD notes.
  47  * On FreeBSD ZVOLs are simply GEOM providers like any other storage device
  48  * in the system.
  49  */
  50
  51 #include <sys/types.h>
  52 #include <sys/param.h>
  53 #include <sys/kernel.h>
  54 #include <sys/errno.h>
  55 #include <sys/uio.h>
  56 #include <sys/bio.h>
  57 #include <sys/buf.h>
  58 #include <sys/kmem.h>
  59 #include <sys/conf.h>
  60 #include <sys/cmn_err.h>
  61 #include <sys/stat.h>
  62 #include <sys/zap.h>
  63 #include <sys/spa.h>
  64 #include <sys/spa_impl.h>
  65 #include <sys/zio.h>
  66 #include <sys/dmu_traverse.h>
  67 #include <sys/dnode.h>
  68 #include <sys/dsl_dataset.h>
  69 #include <sys/dsl_prop.h>
  70 #include <sys/dkio.h>
  71 #include <sys/byteorder.h>
  72 #include <sys/sunddi.h>
  73 #include <sys/dirent.h>
  74 #include <sys/policy.h>
  75 #include <sys/fs/zfs.h>
  76 #include <sys/zfs_ioctl.h>
  77 #include <sys/zil.h>
  78 #include <sys/refcount.h>
  79 #include <sys/zfs_znode.h>
  80 #include <sys/zfs_rlock.h>
  81 #include <sys/vdev_impl.h>
  82 #include <sys/vdev_raidz.h>
  83 #include <sys/zvol.h>
  84 #include <sys/zil_impl.h>
  85 #include <sys/dbuf.h>
  86 #include <sys/dmu_tx.h>
  87 #include <sys/zfeature.h>
  88 #include <sys/zio_checksum.h>
  89
  90 #include <geom/geom.h>
  91
  92 #include "zfs_namecheck.h"
  93
  94 struct g_class zfs_zvol_class = {
  95         .name = "ZFS::ZVOL",
  96         .version = G_VERSION,
  97 };
  98
  99 DECLARE_GEOM_CLASS(zfs_zvol_class, zfs_zvol);
 100
 101 void *zfsdev_state;
 102 static char *zvol_tag = "zvol_tag";
 103
 104 #define ZVOL_DUMPSIZE           "dumpsize"
 105
 106 /*
 107  * The spa_namespace_lock protects the zfsdev_state structure from being
 108  * modified while it's being used, e.g. an open that comes in before a
 109  * create finishes.  It also protects temporary opens of the dataset so that,
 110  * e.g., an open doesn't get a spurious EBUSY.
 111  */
 112 static uint32_t zvol_minors;
 113
 114 typedef struct zvol_extent {
 115         list_node_t     ze_node;
 116         dva_t           ze_dva;         /* dva associated with this extent */
 117         uint64_t        ze_nblks;       /* number of blocks in extent */
 118 } zvol_extent_t;
 119
 120 /*
 121  * The in-core state of each volume.
 122  */
 123 typedef struct zvol_state {
 124         char            zv_name[MAXPATHLEN]; /* pool/dd name */
 125         uint64_t        zv_volsize;     /* amount of space we advertise */
 126         uint64_t        zv_volblocksize; /* volume block size */
 127         struct g_provider *zv_provider; /* GEOM provider */
 128         uint8_t         zv_min_bs;      /* minimum addressable block shift */
 129         uint8_t         zv_flags;       /* readonly, dumpified, etc. */
 130         objset_t        *zv_objset;     /* objset handle */
 131         uint32_t        zv_total_opens; /* total open count */
 132         zilog_t         *zv_zilog;      /* ZIL handle */
 133         list_t          zv_extents;     /* List of extents for dump */
 134         znode_t         zv_znode;       /* for range locking */
 135         dmu_buf_t       *zv_dbuf;       /* bonus handle */
 136         int             zv_state;
 137         struct bio_queue_head zv_queue;
 138         struct mtx      zv_queue_mtx;   /* zv_queue mutex */
 139 } zvol_state_t;
 140
 141 /*
 142  * zvol specific flags
 143  */
 144 #define ZVOL_RDONLY     0x1
 145 #define ZVOL_DUMPIFIED  0x2
 146 #define ZVOL_EXCL       0x4
 147 #define ZVOL_WCE        0x8
 148
 149 /*
 150  * zvol maximum transfer in one DMU tx.
 151  */
 152 int zvol_maxphys = DMU_MAX_ACCESS/2;
 153
 154 extern int zfs_set_prop_nvlist(const char *, zprop_source_t,
 155     nvlist_t *, nvlist_t *);
 156 static int zvol_remove_zv(zvol_state_t *);
 157 static int zvol_get_data(void *arg, lr_write_t *lr, char *buf, zio_t *zio);
 158 static int zvol_dumpify(zvol_state_t *zv);
 159 static int zvol_dump_fini(zvol_state_t *zv);
 160 static int zvol_dump_init(zvol_state_t *zv, boolean_t resize);
 161
 162 static zvol_state_t *zvol_geom_create(const char *name);
 163 static void zvol_geom_run(zvol_state_t *zv);
 164 static void zvol_geom_destroy(zvol_state_t *zv);
 165 static int zvol_geom_access(struct g_provider *pp, int acr, int acw, int ace);
 166 static void zvol_geom_start(struct bio *bp);
 167 static void zvol_geom_worker(void *arg);
 168
 169 static void
 170 zvol_size_changed(zvol_state_t *zv)
 171 {
 172 #ifdef sun
 173         dev_t dev = makedevice(maj, min);
 174
 175         VERIFY(ddi_prop_update_int64(dev, zfs_dip,
 176             "Size", volsize) == DDI_SUCCESS);
 177         VERIFY(ddi_prop_update_int64(dev, zfs_dip,
 178             "Nblocks", lbtodb(volsize)) == DDI_SUCCESS);
 179
 180         /* Notify specfs to invalidate the cached size */
 181         spec_size_invalidate(dev, VBLK);
 182         spec_size_invalidate(dev, VCHR);
 183 #else   /* !sun */
 184         struct g_provider *pp;
 185
 186         pp = zv->zv_provider;
 187         if (pp == NULL)
 188                 return;
 189         if (zv->zv_volsize == pp->mediasize)
 190                 return;
 191         /*
 192          * Changing provider size is not really supported by GEOM, but it
 193          * should be safe when provider is closed.
 194          */
 195         if (zv->zv_total_opens > 0)
 196                 return;
 197         pp->mediasize = zv->zv_volsize;
 198 #endif  /* !sun */
 199 }
 200
 201 int
 202 zvol_check_volsize(uint64_t volsize, uint64_t blocksize)
 203 {
 204         if (volsize == 0)
 205                 return (SET_ERROR(EINVAL));
 206
 207         if (volsize % blocksize != 0)
 208                 return (SET_ERROR(EINVAL));
 209
 210 #ifdef _ILP32
 211         if (volsize - 1 > SPEC_MAXOFFSET_T)
 212                 return (SET_ERROR(EOVERFLOW));
 213 #endif
 214         return (0);
 215 }
 216
 217 int
 218 zvol_check_volblocksize(uint64_t volblocksize)
 219 {
 220         if (volblocksize < SPA_MINBLOCKSIZE ||
 221             volblocksize > SPA_MAXBLOCKSIZE ||
 222             !ISP2(volblocksize))
 223                 return (SET_ERROR(EDOM));
 224
 225         return (0);
 226 }
 227
 228 int
 229 zvol_get_stats(objset_t *os, nvlist_t *nv)
 230 {
 231         int error;
 232         dmu_object_info_t doi;
 233         uint64_t val;
 234
 235         error = zap_lookup(os, ZVOL_ZAP_OBJ, "size", 8, 1, &val);
 236         if (error)
 237                 return (error);
 238
 239         dsl_prop_nvlist_add_uint64(nv, ZFS_PROP_VOLSIZE, val);
 240
 241         error = dmu_object_info(os, ZVOL_OBJ, &doi);
 242
 243         if (error == 0) {
 244                 dsl_prop_nvlist_add_uint64(nv, ZFS_PROP_VOLBLOCKSIZE,
 245                     doi.doi_data_block_size);
 246         }
 247
 248         return (error);
 249 }
 250
 251 static zvol_state_t *
 252 zvol_minor_lookup(const char *name)
 253 {
 254         struct g_provider *pp;
 255         struct g_geom *gp;
 256         zvol_state_t *zv = NULL;
 257
 258         ASSERT(MUTEX_HELD(&spa_namespace_lock));
 259
 260         g_topology_lock();
 261         LIST_FOREACH(gp, &zfs_zvol_class.geom, geom) {
 262                 pp = LIST_FIRST(&gp->provider);
 263                 if (pp == NULL)
 264                         continue;
 265                 zv = pp->private;
 266                 if (zv == NULL)
 267                         continue;
 268                 if (strcmp(zv->zv_name, name) == 0)
 269                         break;
 270         }
 271         g_topology_unlock();
 272
 273         return (gp != NULL ? zv : NULL);
 274 }
 275
 276 /* extent mapping arg */
 277 struct maparg {
 278         zvol_state_t    *ma_zv;
 279         uint64_t        ma_blks;
 280 };
 281
 282 /*ARGSUSED*/
 283 static int
 284 zvol_map_block(spa_t *spa, zilog_t *zilog, const blkptr_t *bp,
 285     const zbookmark_t *zb, const dnode_phys_t *dnp, void *arg)
 286 {
 287         struct maparg *ma = arg;
 288         zvol_extent_t *ze;
 289         int bs = ma->ma_zv->zv_volblocksize;
 290
 291         if (BP_IS_HOLE(bp) ||
 292             zb->zb_object != ZVOL_OBJ || zb->zb_level != 0)
 293                 return (0);
 294
 295         VERIFY3U(ma->ma_blks, ==, zb->zb_blkid);
 296         ma->ma_blks++;
 297
 298         /* Abort immediately if we have encountered gang blocks */
 299         if (BP_IS_GANG(bp))
 300                 return (SET_ERROR(EFRAGS));
 301
 302         /*
 303          * See if the block is at the end of the previous extent.
 304          */
 305         ze = list_tail(&ma->ma_zv->zv_extents);
 306         if (ze &&
 307             DVA_GET_VDEV(BP_IDENTITY(bp)) == DVA_GET_VDEV(&ze->ze_dva) &&
 308             DVA_GET_OFFSET(BP_IDENTITY(bp)) ==
 309             DVA_GET_OFFSET(&ze->ze_dva) + ze->ze_nblks * bs) {
 310                 ze->ze_nblks++;
 311                 return (0);
 312         }
 313
 314         dprintf_bp(bp, "%s", "next blkptr:");
 315
 316         /* start a new extent */
 317         ze = kmem_zalloc(sizeof (zvol_extent_t), KM_SLEEP);
 318         ze->ze_dva = bp->blk_dva[0];    /* structure assignment */
 319         ze->ze_nblks = 1;
 320         list_insert_tail(&ma->ma_zv->zv_extents, ze);
 321         return (0);
 322 }
 323
 324 static void
 325 zvol_free_extents(zvol_state_t *zv)
 326 {
 327         zvol_extent_t *ze;
 328
 329         while (ze = list_head(&zv->zv_extents)) {
 330                 list_remove(&zv->zv_extents, ze);
 331                 kmem_free(ze, sizeof (zvol_extent_t));
 332         }
 333 }
 334
 335 static int
 336 zvol_get_lbas(zvol_state_t *zv)
 337 {
 338         objset_t *os = zv->zv_objset;
 339         struct maparg   ma;
 340         int             err;
 341
 342         ma.ma_zv = zv;
 343         ma.ma_blks = 0;
 344         zvol_free_extents(zv);
 345
 346         /* commit any in-flight changes before traversing the dataset */
 347         txg_wait_synced(dmu_objset_pool(os), 0);
 348         err = traverse_dataset(dmu_objset_ds(os), 0,
 349             TRAVERSE_PRE | TRAVERSE_PREFETCH_METADATA, zvol_map_block, &ma);
 350         if (err || ma.ma_blks != (zv->zv_volsize / zv->zv_volblocksize)) {
 351                 zvol_free_extents(zv);
 352                 return (err ? err : EIO);
 353         }
 354
 355         return (0);
 356 }
 357
 358 /* ARGSUSED */
 359 void
 360 zvol_create_cb(objset_t *os, void *arg, cred_t *cr, dmu_tx_t *tx)
 361 {
 362         zfs_creat_t *zct = arg;
 363         nvlist_t *nvprops = zct->zct_props;
 364         int error;
 365         uint64_t volblocksize, volsize;
 366
 367         VERIFY(nvlist_lookup_uint64(nvprops,
 368             zfs_prop_to_name(ZFS_PROP_VOLSIZE), &volsize) == 0);
 369         if (nvlist_lookup_uint64(nvprops,
 370             zfs_prop_to_name(ZFS_PROP_VOLBLOCKSIZE), &volblocksize) != 0)
 371                 volblocksize = zfs_prop_default_numeric(ZFS_PROP_VOLBLOCKSIZE);
 372
 373         /*
 374          * These properties must be removed from the list so the generic
 375          * property setting step won't apply to them.
 376          */
 377         VERIFY(nvlist_remove_all(nvprops,
 378             zfs_prop_to_name(ZFS_PROP_VOLSIZE)) == 0);
 379         (void) nvlist_remove_all(nvprops,
 380             zfs_prop_to_name(ZFS_PROP_VOLBLOCKSIZE));
 381
 382         error = dmu_object_claim(os, ZVOL_OBJ, DMU_OT_ZVOL, volblocksize,
 383             DMU_OT_NONE, 0, tx);
 384         ASSERT(error == 0);
 385
 386         error = zap_create_claim(os, ZVOL_ZAP_OBJ, DMU_OT_ZVOL_PROP,
 387             DMU_OT_NONE, 0, tx);
 388         ASSERT(error == 0);
 389
 390         error = zap_update(os, ZVOL_ZAP_OBJ, "size", 8, 1, &volsize, tx);
 391         ASSERT(error == 0);
 392 }
 393
 394 /*
 395  * Replay a TX_WRITE ZIL transaction that didn't get committed
 396  * after a system failure
 397  */
 398 static int
 399 zvol_replay_write(zvol_state_t *zv, lr_write_t *lr, boolean_t byteswap)
 400 {
 401         objset_t *os = zv->zv_objset;
 402         char *data = (char *)(lr + 1);  /* data follows lr_write_t */
 403         uint64_t offset, length;
 404         dmu_tx_t *tx;
 405         int error;
 406
 407         if (byteswap)
 408                 byteswap_uint64_array(lr, sizeof (*lr));
 409
 410         offset = lr->lr_offset;
 411         length = lr->lr_length;
 412
 413         /* If it's a dmu_sync() block, write the whole block */
 414         if (lr->lr_common.lrc_reclen == sizeof (lr_write_t)) {
 415                 uint64_t blocksize = BP_GET_LSIZE(&lr->lr_blkptr);
 416                 if (length < blocksize) {
 417                         offset -= offset % blocksize;
 418                         length = blocksize;
 419                 }
 420         }
 421
 422         tx = dmu_tx_create(os);
 423         dmu_tx_hold_write(tx, ZVOL_OBJ, offset, length);
 424         error = dmu_tx_assign(tx, TXG_WAIT);
 425         if (error) {
 426                 dmu_tx_abort(tx);
 427         } else {
 428                 dmu_write(os, ZVOL_OBJ, offset, length, data, tx);
 429                 dmu_tx_commit(tx);
 430         }
 431
 432         return (error);
 433 }
 434
 435 /* ARGSUSED */
 436 static int
 437 zvol_replay_err(zvol_state_t *zv, lr_t *lr, boolean_t byteswap)
 438 {
 439         return (SET_ERROR(ENOTSUP));
 440 }
 441
 442 /*
 443  * Callback vectors for replaying records.
 444  * Only TX_WRITE is needed for zvol.
 445  */
 446 zil_replay_func_t *zvol_replay_vector[TX_MAX_TYPE] = {
 447         zvol_replay_err,        /* 0 no such transaction type */
 448         zvol_replay_err,        /* TX_CREATE */
 449         zvol_replay_err,        /* TX_MKDIR */
 450         zvol_replay_err,        /* TX_MKXATTR */
 451         zvol_replay_err,        /* TX_SYMLINK */
 452         zvol_replay_err,        /* TX_REMOVE */
 453         zvol_replay_err,        /* TX_RMDIR */
 454         zvol_replay_err,        /* TX_LINK */
 455         zvol_replay_err,        /* TX_RENAME */
 456         zvol_replay_write,      /* TX_WRITE */
 457         zvol_replay_err,        /* TX_TRUNCATE */
 458         zvol_replay_err,        /* TX_SETATTR */
 459         zvol_replay_err,        /* TX_ACL */
 460         zvol_replay_err,        /* TX_CREATE_ACL */
 461         zvol_replay_err,        /* TX_CREATE_ATTR */
 462         zvol_replay_err,        /* TX_CREATE_ACL_ATTR */
 463         zvol_replay_err,        /* TX_MKDIR_ACL */
 464         zvol_replay_err,        /* TX_MKDIR_ATTR */
 465         zvol_replay_err,        /* TX_MKDIR_ACL_ATTR */
 466         zvol_replay_err,        /* TX_WRITE2 */
 467 };
 468
 469 #ifdef sun
 470 int
 471 zvol_name2minor(const char *name, minor_t *minor)
 472 {
 473         zvol_state_t *zv;
 474
 475         mutex_enter(&spa_namespace_lock);
 476         zv = zvol_minor_lookup(name);
 477         if (minor && zv)
 478                 *minor = zv->zv_minor;
 479         mutex_exit(&spa_namespace_lock);
 480         return (zv ? 0 : -1);
 481 }
 482 #endif  /* sun */
 483
 484 /*
 485  * Create a minor node (plus a whole lot more) for the specified volume.
 486  */
 487 int
 488 zvol_create_minor(const char *name)
 489 {
 490         zfs_soft_state_t *zs;
 491         zvol_state_t *zv;
 492         objset_t *os;
 493         dmu_object_info_t doi;
 494         uint64_t volsize;
 495         int error;
 496
 497         ZFS_LOG(1, "Creating ZVOL %s...", name);
 498
 499         mutex_enter(&spa_namespace_lock);
 500
 501         if (zvol_minor_lookup(name) != NULL) {
 502                 mutex_exit(&spa_namespace_lock);
 503                 return (SET_ERROR(EEXIST));
 504         }
 505
 506         /* lie and say we're read-only */
 507         error = dmu_objset_own(name, DMU_OST_ZVOL, B_TRUE, FTAG, &os);
 508
 509         if (error) {
 510                 mutex_exit(&spa_namespace_lock);
 511                 return (error);
 512         }
 513
 514 #ifdef sun
 515         if ((minor = zfsdev_minor_alloc()) == 0) {
 516                 dmu_objset_disown(os, FTAG);
 517                 mutex_exit(&spa_namespace_lock);
 518                 return (SET_ERROR(ENXIO));
 519         }
 520
 521         if (ddi_soft_state_zalloc(zfsdev_state, minor) != DDI_SUCCESS) {
 522                 dmu_objset_disown(os, FTAG);
 523                 mutex_exit(&spa_namespace_lock);
 524                 return (SET_ERROR(EAGAIN));
 525         }
 526         (void) ddi_prop_update_string(minor, zfs_dip, ZVOL_PROP_NAME,
 527             (char *)name);
 528
 529         (void) snprintf(chrbuf, sizeof (chrbuf), "%u,raw", minor);
 530
 531         if (ddi_create_minor_node(zfs_dip, chrbuf, S_IFCHR,
 532             minor, DDI_PSEUDO, 0) == DDI_FAILURE) {
 533                 ddi_soft_state_free(zfsdev_state, minor);
 534                 dmu_objset_disown(os, FTAG);
 535                 mutex_exit(&spa_namespace_lock);
 536                 return (SET_ERROR(EAGAIN));
 537         }
 538
 539         (void) snprintf(blkbuf, sizeof (blkbuf), "%u", minor);
 540
 541         if (ddi_create_minor_node(zfs_dip, blkbuf, S_IFBLK,
 542             minor, DDI_PSEUDO, 0) == DDI_FAILURE) {
 543                 ddi_remove_minor_node(zfs_dip, chrbuf);
 544                 ddi_soft_state_free(zfsdev_state, minor);
 545                 dmu_objset_disown(os, FTAG);
 546                 mutex_exit(&spa_namespace_lock);
 547                 return (SET_ERROR(EAGAIN));
 548         }
 549
 550         zs = ddi_get_soft_state(zfsdev_state, minor);
 551         zs->zss_type = ZSST_ZVOL;
 552         zv = zs->zss_data = kmem_zalloc(sizeof (zvol_state_t), KM_SLEEP);
 553 #else   /* !sun */
 554
 555         error = zap_lookup(os, ZVOL_ZAP_OBJ, "size", 8, 1, &volsize);
 556         if (error) {
 557                 ASSERT(error == 0);
 558                 dmu_objset_disown(os, zvol_tag);
 559                 mutex_exit(&spa_namespace_lock);
 560                 return (error);
 561         }
 562
 563         DROP_GIANT();
 564         g_topology_lock();
 565         zv = zvol_geom_create(name);
 566         zv->zv_volsize = volsize;
 567         zv->zv_provider->mediasize = zv->zv_volsize;
 568
 569 #endif  /* !sun */
 570
 571         (void) strlcpy(zv->zv_name, name, MAXPATHLEN);
 572         zv->zv_min_bs = DEV_BSHIFT;
 573         zv->zv_objset = os;
 574         if (dmu_objset_is_snapshot(os) || !spa_writeable(dmu_objset_spa(os)))
 575                 zv->zv_flags |= ZVOL_RDONLY;
 576         mutex_init(&zv->zv_znode.z_range_lock, NULL, MUTEX_DEFAULT, NULL);
 577         avl_create(&zv->zv_znode.z_range_avl, zfs_range_compare,
 578             sizeof (rl_t), offsetof(rl_t, r_node));
 579         list_create(&zv->zv_extents, sizeof (zvol_extent_t),
 580             offsetof(zvol_extent_t, ze_node));
 581         /* get and cache the blocksize */
 582         error = dmu_object_info(os, ZVOL_OBJ, &doi);
 583         ASSERT(error == 0);
 584         zv->zv_volblocksize = doi.doi_data_block_size;
 585
 586         if (spa_writeable(dmu_objset_spa(os))) {
 587                 if (zil_replay_disable)
 588                         zil_destroy(dmu_objset_zil(os), B_FALSE);
 589                 else
 590                         zil_replay(os, zv, zvol_replay_vector);
 591         }
 592         dmu_objset_disown(os, FTAG);
 593         zv->zv_objset = NULL;
 594
 595         zvol_minors++;
 596
 597         mutex_exit(&spa_namespace_lock);
 598
 599         zvol_geom_run(zv);
 600
 601         g_topology_unlock();
 602         PICKUP_GIANT();
 603
 604         ZFS_LOG(1, "ZVOL %s created.", name);
 605
 606         return (0);
 607 }
 608
 609 /*
 610  * Remove minor node for the specified volume.
 611  */
 612 static int
 613 zvol_remove_zv(zvol_state_t *zv)
 614 {
 615 #ifdef sun
 616         minor_t minor = zv->zv_minor;
 617 #endif
 618
 619         ASSERT(MUTEX_HELD(&spa_namespace_lock));
 620         if (zv->zv_total_opens != 0)
 621                 return (SET_ERROR(EBUSY));
 622
 623         ZFS_LOG(1, "ZVOL %s destroyed.", zv->zv_name);
 624
 625 #ifdef sun
 626         (void) snprintf(nmbuf, sizeof (nmbuf), "%u,raw", minor);
 627         ddi_remove_minor_node(zfs_dip, nmbuf);
 628 #endif  /* sun */
 629
 630         avl_destroy(&zv->zv_znode.z_range_avl);
 631         mutex_destroy(&zv->zv_znode.z_range_lock);
 632
 633         zvol_geom_destroy(zv);
 634
 635         zvol_minors--;
 636         return (0);
 637 }
 638
 639 int
 640 zvol_remove_minor(const char *name)
 641 {
 642         zvol_state_t *zv;
 643         int rc;
 644
 645         mutex_enter(&spa_namespace_lock);
 646         if ((zv = zvol_minor_lookup(name)) == NULL) {
 647                 mutex_exit(&spa_namespace_lock);
 648                 return (SET_ERROR(ENXIO));
 649         }
 650         g_topology_lock();
 651         rc = zvol_remove_zv(zv);
 652         g_topology_unlock();
 653         mutex_exit(&spa_namespace_lock);
 654         return (rc);
 655 }
 656
 657 int
 658 zvol_first_open(zvol_state_t *zv)
 659 {
 660         objset_t *os;
 661         uint64_t volsize;
 662         int error;
 663         uint64_t readonly;
 664
 665         /* lie and say we're read-only */
 666         error = dmu_objset_own(zv->zv_name, DMU_OST_ZVOL, B_TRUE,
 667             zvol_tag, &os);
 668         if (error)
 669                 return (error);
 670
 671         error = zap_lookup(os, ZVOL_ZAP_OBJ, "size", 8, 1, &volsize);
 672         if (error) {
 673                 ASSERT(error == 0);
 674                 dmu_objset_disown(os, zvol_tag);
 675                 return (error);
 676         }
 677         zv->zv_objset = os;
 678         error = dmu_bonus_hold(os, ZVOL_OBJ, zvol_tag, &zv->zv_dbuf);
 679         if (error) {
 680                 dmu_objset_disown(os, zvol_tag);
 681                 return (error);
 682         }
 683         zv->zv_volsize = volsize;
 684         zv->zv_zilog = zil_open(os, zvol_get_data);
 685         zvol_size_changed(zv);
 686
 687         VERIFY(dsl_prop_get_integer(zv->zv_name, "readonly", &readonly,
 688             NULL) == 0);
 689         if (readonly || dmu_objset_is_snapshot(os) ||
 690             !spa_writeable(dmu_objset_spa(os)))
 691                 zv->zv_flags |= ZVOL_RDONLY;
 692         else
 693                 zv->zv_flags &= ~ZVOL_RDONLY;
 694         return (error);
 695 }
 696
 697 void
 698 zvol_last_close(zvol_state_t *zv)
 699 {
 700         zil_close(zv->zv_zilog);
 701         zv->zv_zilog = NULL;
 702
 703         dmu_buf_rele(zv->zv_dbuf, zvol_tag);
 704         zv->zv_dbuf = NULL;
 705
 706         /*
 707          * Evict cached data
 708          */
 709         if (dsl_dataset_is_dirty(dmu_objset_ds(zv->zv_objset)) &&
 710             !(zv->zv_flags & ZVOL_RDONLY))
 711                 txg_wait_synced(dmu_objset_pool(zv->zv_objset), 0);
 712         dmu_objset_evict_dbufs(zv->zv_objset);
 713
 714         dmu_objset_disown(zv->zv_objset, zvol_tag);
 715         zv->zv_objset = NULL;
 716 }
 717
 718 #ifdef sun
 719 int
 720 zvol_prealloc(zvol_state_t *zv)
 721 {
 722         objset_t *os = zv->zv_objset;
 723         dmu_tx_t *tx;
 724         uint64_t refd, avail, usedobjs, availobjs;
 725         uint64_t resid = zv->zv_volsize;
 726         uint64_t off = 0;
 727
 728         /* Check the space usage before attempting to allocate the space */
 729         dmu_objset_space(os, &refd, &avail, &usedobjs, &availobjs);
 730         if (avail < zv->zv_volsize)
 731                 return (SET_ERROR(ENOSPC));
 732
 733         /* Free old extents if they exist */
 734         zvol_free_extents(zv);
 735
 736         while (resid != 0) {
 737                 int error;
 738                 uint64_t bytes = MIN(resid, SPA_MAXBLOCKSIZE);
 739
 740                 tx = dmu_tx_create(os);
 741                 dmu_tx_hold_write(tx, ZVOL_OBJ, off, bytes);
 742                 error = dmu_tx_assign(tx, TXG_WAIT);
 743                 if (error) {
 744                         dmu_tx_abort(tx);
 745                         (void) dmu_free_long_range(os, ZVOL_OBJ, 0, off);
 746                         return (error);
 747                 }
 748                 dmu_prealloc(os, ZVOL_OBJ, off, bytes, tx);
 749                 dmu_tx_commit(tx);
 750                 off += bytes;
 751                 resid -= bytes;
 752         }
 753         txg_wait_synced(dmu_objset_pool(os), 0);
 754
 755         return (0);
 756 }
 757 #endif  /* sun */
 758
 759 static int
 760 zvol_update_volsize(objset_t *os, uint64_t volsize)
 761 {
 762         dmu_tx_t *tx;
 763         int error;
 764
 765         ASSERT(MUTEX_HELD(&spa_namespace_lock));
 766
 767         tx = dmu_tx_create(os);
 768         dmu_tx_hold_zap(tx, ZVOL_ZAP_OBJ, TRUE, NULL);
 769         error = dmu_tx_assign(tx, TXG_WAIT);
 770         if (error) {
 771                 dmu_tx_abort(tx);
 772                 return (error);
 773         }
 774
 775         error = zap_update(os, ZVOL_ZAP_OBJ, "size", 8, 1,
 776             &volsize, tx);
 777         dmu_tx_commit(tx);
 778
 779         if (error == 0)
 780                 error = dmu_free_long_range(os,
 781                     ZVOL_OBJ, volsize, DMU_OBJECT_END);
 782         return (error);
 783 }
 784
 785 void
 786 zvol_remove_minors(const char *name)
 787 {
 788         struct g_geom *gp, *gptmp;
 789         struct g_provider *pp;
 790         zvol_state_t *zv;
 791         size_t namelen;
 792
 793         namelen = strlen(name);
 794
 795         DROP_GIANT();
 796         mutex_enter(&spa_namespace_lock);
 797         g_topology_lock();
 798
 799         LIST_FOREACH_SAFE(gp, &zfs_zvol_class.geom, geom, gptmp) {
 800                 pp = LIST_FIRST(&gp->provider);
 801                 if (pp == NULL)
 802                         continue;
 803                 zv = pp->private;
 804                 if (zv == NULL)
 805                         continue;
 806                 if (strcmp(zv->zv_name, name) == 0 ||
 807                     (strncmp(zv->zv_name, name, namelen) == 0 &&
 808                      zv->zv_name[namelen] == '/')) {
 809                         (void) zvol_remove_zv(zv);
 810                 }
 811         }
 812
 813         g_topology_unlock();
 814         mutex_exit(&spa_namespace_lock);
 815         PICKUP_GIANT();
 816 }
 817
 818 int
 819 zvol_set_volsize(const char *name, major_t maj, uint64_t volsize)
 820 {
 821         zvol_state_t *zv = NULL;
 822         objset_t *os;
 823         int error;
 824         dmu_object_info_t doi;
 825         uint64_t old_volsize = 0ULL;
 826         uint64_t readonly;
 827
 828         mutex_enter(&spa_namespace_lock);
 829         zv = zvol_minor_lookup(name);
 830         if ((error = dmu_objset_hold(name, FTAG, &os)) != 0) {
 831                 mutex_exit(&spa_namespace_lock);
 832                 return (error);
 833         }
 834
 835         if ((error = dmu_object_info(os, ZVOL_OBJ, &doi)) != 0 ||
 836             (error = zvol_check_volsize(volsize,
 837             doi.doi_data_block_size)) != 0)
 838                 goto out;
 839
 840         VERIFY(dsl_prop_get_integer(name, "readonly", &readonly,
 841             NULL) == 0);
 842         if (readonly) {
 843                 error = EROFS;
 844                 goto out;
 845         }
 846
 847         error = zvol_update_volsize(os, volsize);
 848         /*
 849          * Reinitialize the dump area to the new size. If we
 850          * failed to resize the dump area then restore it back to
 851          * its original size.
 852          */
 853         if (zv && error == 0) {
 854 #ifdef ZVOL_DUMP
 855                 if (zv->zv_flags & ZVOL_DUMPIFIED) {
 856                         old_volsize = zv->zv_volsize;
 857                         zv->zv_volsize = volsize;
 858                         if ((error = zvol_dumpify(zv)) != 0 ||
 859                             (error = dumpvp_resize()) != 0) {
 860                                 (void) zvol_update_volsize(os, old_volsize);
 861                                 zv->zv_volsize = old_volsize;
 862                                 error = zvol_dumpify(zv);
 863                         }
 864                 }
 865 #endif  /* ZVOL_DUMP */
 866                 if (error == 0) {
 867                         zv->zv_volsize = volsize;
 868                         zvol_size_changed(zv);
 869                 }
 870         }
 871
 872 #ifdef sun
 873         /*
 874          * Generate a LUN expansion event.
 875          */
 876         if (zv && error == 0) {
 877                 sysevent_id_t eid;
 878                 nvlist_t *attr;
 879                 char *physpath = kmem_zalloc(MAXPATHLEN, KM_SLEEP);
 880
 881                 (void) snprintf(physpath, MAXPATHLEN, "%s%u", ZVOL_PSEUDO_DEV,
 882                     zv->zv_minor);
 883
 884                 VERIFY(nvlist_alloc(&attr, NV_UNIQUE_NAME, KM_SLEEP) == 0);
 885                 VERIFY(nvlist_add_string(attr, DEV_PHYS_PATH, physpath) == 0);
 886
 887                 (void) ddi_log_sysevent(zfs_dip, SUNW_VENDOR, EC_DEV_STATUS,
 888                     ESC_DEV_DLE, attr, &eid, DDI_SLEEP);
 889
 890                 nvlist_free(attr);
 891                 kmem_free(physpath, MAXPATHLEN);
 892         }
 893 #endif  /* sun */
 894
 895 out:
 896         dmu_objset_rele(os, FTAG);
 897
 898         mutex_exit(&spa_namespace_lock);
 899
 900         return (error);
 901 }
 902
 903 /*ARGSUSED*/
 904 static int
 905 zvol_open(struct g_provider *pp, int flag, int count)
 906 {
 907         zvol_state_t *zv;
 908         int err = 0;
 909         boolean_t locked = B_FALSE;
 910
 911         /*
 912          * Protect against recursively entering spa_namespace_lock
 913          * when spa_open() is used for a pool on a (local) ZVOL(s).
 914          * This is needed since we replaced upstream zfsdev_state_lock
 915          * with spa_namespace_lock in the ZVOL code.
 916          * We are using the same trick as spa_open().
 917          * Note that calls in zvol_first_open which need to resolve
 918          * pool name to a spa object will enter spa_open()
 919          * recursively, but that function already has all the
 920          * necessary protection.
 921          */
 922         if (!MUTEX_HELD(&spa_namespace_lock)) {
 923                 mutex_enter(&spa_namespace_lock);
 924                 locked = B_TRUE;
 925         }
 926
 927         zv = pp->private;
 928         if (zv == NULL) {
 929                 if (locked)
 930                         mutex_exit(&spa_namespace_lock);
 931                 return (SET_ERROR(ENXIO));
 932         }
 933
 934         if (zv->zv_total_opens == 0)
 935                 err = zvol_first_open(zv);
 936         if (err) {
 937                 if (locked)
 938                         mutex_exit(&spa_namespace_lock);
 939                 return (err);
 940         }
 941         if ((flag & FWRITE) && (zv->zv_flags & ZVOL_RDONLY)) {
 942                 err = SET_ERROR(EROFS);
 943                 goto out;
 944         }
 945         if (zv->zv_flags & ZVOL_EXCL) {
 946                 err = SET_ERROR(EBUSY);
 947                 goto out;
 948         }
 949 #ifdef FEXCL
 950         if (flag & FEXCL) {
 951                 if (zv->zv_total_opens != 0) {
 952                         err = SET_ERROR(EBUSY);
 953                         goto out;
 954                 }
 955                 zv->zv_flags |= ZVOL_EXCL;
 956         }
 957 #endif
 958
 959         zv->zv_total_opens += count;
 960         if (locked)
 961                 mutex_exit(&spa_namespace_lock);
 962
 963         return (err);
 964 out:
 965         if (zv->zv_total_opens == 0)
 966                 zvol_last_close(zv);
 967         if (locked)
 968                 mutex_exit(&spa_namespace_lock);
 969         return (err);
 970 }
 971
 972 /*ARGSUSED*/
 973 static int
 974 zvol_close(struct g_provider *pp, int flag, int count)
 975 {
 976         zvol_state_t *zv;
 977         int error = 0;
 978         boolean_t locked = B_FALSE;
 979
 980         /* See comment in zvol_open(). */
 981         if (!MUTEX_HELD(&spa_namespace_lock)) {
 982                 mutex_enter(&spa_namespace_lock);
 983                 locked = B_TRUE;
 984         }
 985
 986         zv = pp->private;
 987         if (zv == NULL) {
 988                 if (locked)
 989                         mutex_exit(&spa_namespace_lock);
 990                 return (SET_ERROR(ENXIO));
 991         }
 992
 993         if (zv->zv_flags & ZVOL_EXCL) {
 994                 ASSERT(zv->zv_total_opens == 1);
 995                 zv->zv_flags &= ~ZVOL_EXCL;
 996         }
 997
 998         /*
 999          * If the open count is zero, this is a spurious close.
1000          * That indicates a bug in the kernel / DDI framework.
1001          */
1002         ASSERT(zv->zv_total_opens != 0);
1003
1004         /*
1005          * You may get multiple opens, but only one close.
1006          */
1007         zv->zv_total_opens -= count;
1008
1009         if (zv->zv_total_opens == 0)
1010                 zvol_last_close(zv);
1011
1012         if (locked)
1013                 mutex_exit(&spa_namespace_lock);
1014         return (error);
1015 }
1016
1017 static void
1018 zvol_get_done(zgd_t *zgd, int error)
1019 {
1020         if (zgd->zgd_db)
1021                 dmu_buf_rele(zgd->zgd_db, zgd);
1022
1023         zfs_range_unlock(zgd->zgd_rl);
1024
1025         if (error == 0 && zgd->zgd_bp)
1026                 zil_add_block(zgd->zgd_zilog, zgd->zgd_bp);
1027
1028         kmem_free(zgd, sizeof (zgd_t));
1029 }
1030
1031 /*
1032  * Get data to generate a TX_WRITE intent log record.
1033  */
1034 static int
1035 zvol_get_data(void *arg, lr_write_t *lr, char *buf, zio_t *zio)
1036 {
1037         zvol_state_t *zv = arg;
1038         objset_t *os = zv->zv_objset;
1039         uint64_t object = ZVOL_OBJ;
1040         uint64_t offset = lr->lr_offset;
1041         uint64_t size = lr->lr_length;  /* length of user data */
1042         blkptr_t *bp = &lr->lr_blkptr;
1043         dmu_buf_t *db;
1044         zgd_t *zgd;
1045         int error;
1046
1047         ASSERT(zio != NULL);
1048         ASSERT(size != 0);
1049
1050         zgd = kmem_zalloc(sizeof (zgd_t), KM_SLEEP);
1051         zgd->zgd_zilog = zv->zv_zilog;
1052         zgd->zgd_rl = zfs_range_lock(&zv->zv_znode, offset, size, RL_READER);
1053
1054         /*
1055          * Write records come in two flavors: immediate and indirect.
1056          * For small writes it's cheaper to store the data with the
1057          * log record (immediate); for large writes it's cheaper to
1058          * sync the data and get a pointer to it (indirect) so that
1059          * we don't have to write the data twice.
1060          */
1061         if (buf != NULL) {      /* immediate write */
1062                 error = dmu_read(os, object, offset, size, buf,
1063                     DMU_READ_NO_PREFETCH);
1064         } else {
1065                 size = zv->zv_volblocksize;
1066                 offset = P2ALIGN(offset, size);
1067                 error = dmu_buf_hold(os, object, offset, zgd, &db,
1068                     DMU_READ_NO_PREFETCH);
1069                 if (error == 0) {
1070                         blkptr_t *obp = dmu_buf_get_blkptr(db);
1071                         if (obp) {
1072                                 ASSERT(BP_IS_HOLE(bp));
1073                                 *bp = *obp;
1074                         }
1075
1076                         zgd->zgd_db = db;
1077                         zgd->zgd_bp = bp;
1078
1079                         ASSERT(db->db_offset == offset);
1080                         ASSERT(db->db_size == size);
1081
1082                         error = dmu_sync(zio, lr->lr_common.lrc_txg,
1083                             zvol_get_done, zgd);
1084
1085                         if (error == 0)
1086                                 return (0);
1087                 }
1088         }
1089
1090         zvol_get_done(zgd, error);
1091
1092         return (error);
1093 }
1094
1095 /*
1096  * zvol_log_write() handles synchronous writes using TX_WRITE ZIL transactions.
1097  *
1098  * We store data in the log buffers if it's small enough.
1099  * Otherwise we will later flush the data out via dmu_sync().
1100  */
1101 ssize_t zvol_immediate_write_sz = 32768;
1102
1103 static void
1104 zvol_log_write(zvol_state_t *zv, dmu_tx_t *tx, offset_t off, ssize_t resid,
1105     boolean_t sync)
1106 {
1107         uint32_t blocksize = zv->zv_volblocksize;
1108         zilog_t *zilog = zv->zv_zilog;
1109         boolean_t slogging;
1110         ssize_t immediate_write_sz;
1111
1112         if (zil_replaying(zilog, tx))
1113                 return;
1114
1115         immediate_write_sz = (zilog->zl_logbias == ZFS_LOGBIAS_THROUGHPUT)
1116             ? 0 : zvol_immediate_write_sz;
1117
1118         slogging = spa_has_slogs(zilog->zl_spa) &&
1119             (zilog->zl_logbias == ZFS_LOGBIAS_LATENCY);
1120
1121         while (resid) {
1122                 itx_t *itx;
1123                 lr_write_t *lr;
1124                 ssize_t len;
1125                 itx_wr_state_t write_state;
1126
1127                 /*
1128                  * Unlike zfs_log_write() we can be called with
1129                  * upto DMU_MAX_ACCESS/2 (5MB) writes.
1130                  */
1131                 if (blocksize > immediate_write_sz && !slogging &&
1132                     resid >= blocksize && off % blocksize == 0) {
1133                         write_state = WR_INDIRECT; /* uses dmu_sync */
1134                         len = blocksize;
1135                 } else if (sync) {
1136                         write_state = WR_COPIED;
1137                         len = MIN(ZIL_MAX_LOG_DATA, resid);
1138                 } else {
1139                         write_state = WR_NEED_COPY;
1140                         len = MIN(ZIL_MAX_LOG_DATA, resid);
1141                 }
1142
1143                 itx = zil_itx_create(TX_WRITE, sizeof (*lr) +
1144                     (write_state == WR_COPIED ? len : 0));
1145                 lr = (lr_write_t *)&itx->itx_lr;
1146                 if (write_state == WR_COPIED && dmu_read(zv->zv_objset,
1147                     ZVOL_OBJ, off, len, lr + 1, DMU_READ_NO_PREFETCH) != 0) {
1148                         zil_itx_destroy(itx);
1149                         itx = zil_itx_create(TX_WRITE, sizeof (*lr));
1150                         lr = (lr_write_t *)&itx->itx_lr;
1151                         write_state = WR_NEED_COPY;
1152                 }
1153
1154                 itx->itx_wr_state = write_state;
1155                 if (write_state == WR_NEED_COPY)
1156                         itx->itx_sod += len;
1157                 lr->lr_foid = ZVOL_OBJ;
1158                 lr->lr_offset = off;
1159                 lr->lr_length = len;
1160                 lr->lr_blkoff = 0;
1161                 BP_ZERO(&lr->lr_blkptr);
1162
1163                 itx->itx_private = zv;
1164                 itx->itx_sync = sync;
1165
1166                 zil_itx_assign(zilog, itx, tx);
1167
1168                 off += len;
1169                 resid -= len;
1170         }
1171 }
1172
1173 #ifdef sun
1174 static int
1175 zvol_dumpio_vdev(vdev_t *vd, void *addr, uint64_t offset, uint64_t origoffset,
1176     uint64_t size, boolean_t doread, boolean_t isdump)
1177 {
1178         vdev_disk_t *dvd;
1179         int c;
1180         int numerrors = 0;
1181
1182         if (vd->vdev_ops == &vdev_mirror_ops ||
1183             vd->vdev_ops == &vdev_replacing_ops ||
1184             vd->vdev_ops == &vdev_spare_ops) {
1185                 for (c = 0; c < vd->vdev_children; c++) {
1186                         int err = zvol_dumpio_vdev(vd->vdev_child[c],
1187                             addr, offset, origoffset, size, doread, isdump);
1188                         if (err != 0) {
1189                                 numerrors++;
1190                         } else if (doread) {
1191                                 break;
1192                         }
1193                 }
1194         }
1195
1196         if (!vd->vdev_ops->vdev_op_leaf && vd->vdev_ops != &vdev_raidz_ops)
1197                 return (numerrors < vd->vdev_children ? 0 : EIO);
1198
1199         if (doread && !vdev_readable(vd))
1200                 return (SET_ERROR(EIO));
1201         else if (!doread && !vdev_writeable(vd))
1202                 return (SET_ERROR(EIO));
1203
1204         if (vd->vdev_ops == &vdev_raidz_ops) {
1205                 return (vdev_raidz_physio(vd,
1206                     addr, size, offset, origoffset, doread, isdump));
1207         }
1208
1209         offset += VDEV_LABEL_START_SIZE;
1210
1211         if (ddi_in_panic() || isdump) {
1212                 ASSERT(!doread);
1213                 if (doread)
1214                         return (SET_ERROR(EIO));
1215                 dvd = vd->vdev_tsd;
1216                 ASSERT3P(dvd, !=, NULL);
1217                 return (ldi_dump(dvd->vd_lh, addr, lbtodb(offset),
1218                     lbtodb(size)));
1219         } else {
1220                 dvd = vd->vdev_tsd;
1221                 ASSERT3P(dvd, !=, NULL);
1222                 return (vdev_disk_ldi_physio(dvd->vd_lh, addr, size,
1223                     offset, doread ? B_READ : B_WRITE));
1224         }
1225 }
1226
1227 static int
1228 zvol_dumpio(zvol_state_t *zv, void *addr, uint64_t offset, uint64_t size,
1229     boolean_t doread, boolean_t isdump)
1230 {
1231         vdev_t *vd;
1232         int error;
1233         zvol_extent_t *ze;
1234         spa_t *spa = dmu_objset_spa(zv->zv_objset);
1235
1236         /* Must be sector aligned, and not stradle a block boundary. */
1237         if (P2PHASE(offset, DEV_BSIZE) || P2PHASE(size, DEV_BSIZE) ||
1238             P2BOUNDARY(offset, size, zv->zv_volblocksize)) {
1239                 return (SET_ERROR(EINVAL));
1240         }
1241         ASSERT(size <= zv->zv_volblocksize);
1242
1243         /* Locate the extent this belongs to */
1244         ze = list_head(&zv->zv_extents);
1245         while (offset >= ze->ze_nblks * zv->zv_volblocksize) {
1246                 offset -= ze->ze_nblks * zv->zv_volblocksize;
1247                 ze = list_next(&zv->zv_extents, ze);
1248         }
1249
1250         if (ze == NULL)
1251                 return (SET_ERROR(EINVAL));
1252
1253         if (!ddi_in_panic())
1254                 spa_config_enter(spa, SCL_STATE, FTAG, RW_READER);
1255
1256         vd = vdev_lookup_top(spa, DVA_GET_VDEV(&ze->ze_dva));
1257         offset += DVA_GET_OFFSET(&ze->ze_dva);
1258         error = zvol_dumpio_vdev(vd, addr, offset, DVA_GET_OFFSET(&ze->ze_dva),
1259             size, doread, isdump);
1260
1261         if (!ddi_in_panic())
1262                 spa_config_exit(spa, SCL_STATE, FTAG);
1263
1264         return (error);
1265 }
1266 #endif  /* sun */
1267
1268 int
1269 zvol_strategy(struct bio *bp)
1270 {
1271         zvol_state_t *zv = bp->bio_to->private;
1272         uint64_t off, volsize;
1273         size_t resid;
1274         char *addr;
1275         objset_t *os;
1276         rl_t *rl;
1277         int error = 0;
1278         boolean_t doread = (bp->bio_cmd == BIO_READ);
1279         boolean_t is_dumpified;
1280         boolean_t sync;
1281
1282         if (zv == NULL) {
1283                 g_io_deliver(bp, ENXIO);
1284                 return (0);
1285         }
1286
1287         if (bp->bio_cmd != BIO_READ && (zv->zv_flags & ZVOL_RDONLY)) {
1288                 g_io_deliver(bp, EROFS);
1289                 return (0);
1290         }
1291
1292         off = bp->bio_offset;
1293         volsize = zv->zv_volsize;
1294
1295         os = zv->zv_objset;
1296         ASSERT(os != NULL);
1297
1298         addr = bp->bio_data;
1299         resid = bp->bio_length;
1300
1301         if (resid > 0 && (off < 0 || off >= volsize)) {
1302                 g_io_deliver(bp, EIO);
1303                 return (0);
1304         }
1305
1306 #ifdef illumos
1307         is_dumpified = zv->zv_flags & ZVOL_DUMPIFIED;
1308 #else
1309         is_dumpified = B_FALSE;
1310 #endif
1311         sync = !doread && !is_dumpified &&
1312             zv->zv_objset->os_sync == ZFS_SYNC_ALWAYS;
1313
1314         /*
1315          * There must be no buffer changes when doing a dmu_sync() because
1316          * we can't change the data whilst calculating the checksum.
1317          */
1318         rl = zfs_range_lock(&zv->zv_znode, off, resid,
1319             doread ? RL_READER : RL_WRITER);
1320
1321         while (resid != 0 && off < volsize) {
1322                 size_t size = MIN(resid, zvol_maxphys);
1323 #ifdef illumos
1324                 if (is_dumpified) {
1325                         size = MIN(size, P2END(off, zv->zv_volblocksize) - off);
1326                         error = zvol_dumpio(zv, addr, off, size,
1327                             doread, B_FALSE);
1328                 } else if (doread) {
1329 #else
1330                 if (doread) {
1331 #endif
1332                         error = dmu_read(os, ZVOL_OBJ, off, size, addr,
1333                             DMU_READ_PREFETCH);
1334                 } else {
1335                         dmu_tx_t *tx = dmu_tx_create(os);
1336                         dmu_tx_hold_write(tx, ZVOL_OBJ, off, size);
1337                         error = dmu_tx_assign(tx, TXG_WAIT);
1338                         if (error) {
1339                                 dmu_tx_abort(tx);
1340                         } else {
1341                                 dmu_write(os, ZVOL_OBJ, off, size, addr, tx);
1342                                 zvol_log_write(zv, tx, off, size, sync);
1343                                 dmu_tx_commit(tx);
1344                         }
1345                 }
1346                 if (error) {
1347                         /* convert checksum errors into IO errors */
1348                         if (error == ECKSUM)
1349                                 error = SET_ERROR(EIO);
1350                         break;
1351                 }
1352                 off += size;
1353                 addr += size;
1354                 resid -= size;
1355         }
1356         zfs_range_unlock(rl);
1357
1358         bp->bio_completed = bp->bio_length - resid;
1359         if (bp->bio_completed < bp->bio_length)
1360                 bp->bio_error = (off > volsize ? EINVAL : error);
1361
1362         if (sync)
1363                 zil_commit(zv->zv_zilog, ZVOL_OBJ);
1364         g_io_deliver(bp, 0);
1365
1366         return (0);
1367 }
1368
1369 #ifdef sun
1370 /*
1371  * Set the buffer count to the zvol maximum transfer.
1372  * Using our own routine instead of the default minphys()
1373  * means that for larger writes we write bigger buffers on X86
1374  * (128K instead of 56K) and flush the disk write cache less often
1375  * (every zvol_maxphys - currently 1MB) instead of minphys (currently
1376  * 56K on X86 and 128K on sparc).
1377  */
1378 void
1379 zvol_minphys(struct buf *bp)
1380 {
1381         if (bp->b_bcount > zvol_maxphys)
1382                 bp->b_bcount = zvol_maxphys;
1383 }
1384
1385 int
1386 zvol_dump(dev_t dev, caddr_t addr, daddr_t blkno, int nblocks)
1387 {
1388         minor_t minor = getminor(dev);
1389         zvol_state_t *zv;
1390         int error = 0;
1391         uint64_t size;
1392         uint64_t boff;
1393         uint64_t resid;
1394
1395         zv = zfsdev_get_soft_state(minor, ZSST_ZVOL);
1396         if (zv == NULL)
1397                 return (SET_ERROR(ENXIO));
1398
1399         if ((zv->zv_flags & ZVOL_DUMPIFIED) == 0)
1400                 return (SET_ERROR(EINVAL));
1401
1402         boff = ldbtob(blkno);
1403         resid = ldbtob(nblocks);
1404
1405         VERIFY3U(boff + resid, <=, zv->zv_volsize);
1406
1407         while (resid) {
1408                 size = MIN(resid, P2END(boff, zv->zv_volblocksize) - boff);
1409                 error = zvol_dumpio(zv, addr, boff, size, B_FALSE, B_TRUE);
1410                 if (error)
1411                         break;
1412                 boff += size;
1413                 addr += size;
1414                 resid -= size;
1415         }
1416
1417         return (error);
1418 }
1419
1420 /*ARGSUSED*/
1421 int
1422 zvol_read(dev_t dev, uio_t *uio, cred_t *cr)
1423 {
1424         minor_t minor = getminor(dev);
1425         zvol_state_t *zv;
1426         uint64_t volsize;
1427         rl_t *rl;
1428         int error = 0;
1429
1430         zv = zfsdev_get_soft_state(minor, ZSST_ZVOL);
1431         if (zv == NULL)
1432                 return (SET_ERROR(ENXIO));
1433
1434         volsize = zv->zv_volsize;
1435         if (uio->uio_resid > 0 &&
1436             (uio->uio_loffset < 0 || uio->uio_loffset >= volsize))
1437                 return (SET_ERROR(EIO));
1438
1439         if (zv->zv_flags & ZVOL_DUMPIFIED) {
1440                 error = physio(zvol_strategy, NULL, dev, B_READ,
1441                     zvol_minphys, uio);
1442                 return (error);
1443         }
1444
1445         rl = zfs_range_lock(&zv->zv_znode, uio->uio_loffset, uio->uio_resid,
1446             RL_READER);
1447         while (uio->uio_resid > 0 && uio->uio_loffset < volsize) {
1448                 uint64_t bytes = MIN(uio->uio_resid, DMU_MAX_ACCESS >> 1);
1449
1450                 /* don't read past the end */
1451                 if (bytes > volsize - uio->uio_loffset)
1452                         bytes = volsize - uio->uio_loffset;
1453
1454                 error =  dmu_read_uio(zv->zv_objset, ZVOL_OBJ, uio, bytes);
1455                 if (error) {
1456                         /* convert checksum errors into IO errors */
1457                         if (error == ECKSUM)
1458                                 error = SET_ERROR(EIO);
1459                         break;
1460                 }
1461         }
1462         zfs_range_unlock(rl);
1463         return (error);
1464 }
1465
1466 /*ARGSUSED*/
1467 int
1468 zvol_write(dev_t dev, uio_t *uio, cred_t *cr)
1469 {
1470         minor_t minor = getminor(dev);
1471         zvol_state_t *zv;
1472         uint64_t volsize;
1473         rl_t *rl;
1474         int error = 0;
1475         boolean_t sync;
1476
1477         zv = zfsdev_get_soft_state(minor, ZSST_ZVOL);
1478         if (zv == NULL)
1479                 return (SET_ERROR(ENXIO));
1480
1481         volsize = zv->zv_volsize;
1482         if (uio->uio_resid > 0 &&
1483             (uio->uio_loffset < 0 || uio->uio_loffset >= volsize))
1484                 return (SET_ERROR(EIO));
1485
1486         if (zv->zv_flags & ZVOL_DUMPIFIED) {
1487                 error = physio(zvol_strategy, NULL, dev, B_WRITE,
1488                     zvol_minphys, uio);
1489                 return (error);
1490         }
1491
1492         sync = !(zv->zv_flags & ZVOL_WCE) ||
1493             (zv->zv_objset->os_sync == ZFS_SYNC_ALWAYS);
1494
1495         rl = zfs_range_lock(&zv->zv_znode, uio->uio_loffset, uio->uio_resid,
1496             RL_WRITER);
1497         while (uio->uio_resid > 0 && uio->uio_loffset < volsize) {
1498                 uint64_t bytes = MIN(uio->uio_resid, DMU_MAX_ACCESS >> 1);
1499                 uint64_t off = uio->uio_loffset;
1500                 dmu_tx_t *tx = dmu_tx_create(zv->zv_objset);
1501
1502                 if (bytes > volsize - off)      /* don't write past the end */
1503                         bytes = volsize - off;
1504
1505                 dmu_tx_hold_write(tx, ZVOL_OBJ, off, bytes);
1506                 error = dmu_tx_assign(tx, TXG_WAIT);
1507                 if (error) {
1508                         dmu_tx_abort(tx);
1509                         break;
1510                 }
1511                 error = dmu_write_uio_dbuf(zv->zv_dbuf, uio, bytes, tx);
1512                 if (error == 0)
1513                         zvol_log_write(zv, tx, off, bytes, sync);
1514                 dmu_tx_commit(tx);
1515
1516                 if (error)
1517                         break;
1518         }
1519         zfs_range_unlock(rl);
1520         if (sync)
1521                 zil_commit(zv->zv_zilog, ZVOL_OBJ);
1522         return (error);
1523 }
1524
1525 int
1526 zvol_getefi(void *arg, int flag, uint64_t vs, uint8_t bs)
1527 {
1528         struct uuid uuid = EFI_RESERVED;
1529         efi_gpe_t gpe = { 0 };
1530         uint32_t crc;
1531         dk_efi_t efi;
1532         int length;
1533         char *ptr;
1534
1535         if (ddi_copyin(arg, &efi, sizeof (dk_efi_t), flag))
1536                 return (SET_ERROR(EFAULT));
1537         ptr = (char *)(uintptr_t)efi.dki_data_64;
1538         length = efi.dki_length;
1539         /*
1540          * Some clients may attempt to request a PMBR for the
1541          * zvol.  Currently this interface will return EINVAL to
1542          * such requests.  These requests could be supported by
1543          * adding a check for lba == 0 and consing up an appropriate
1544          * PMBR.
1545          */
1546         if (efi.dki_lba < 1 || efi.dki_lba > 2 || length <= 0)
1547                 return (SET_ERROR(EINVAL));
1548
1549         gpe.efi_gpe_StartingLBA = LE_64(34ULL);
1550         gpe.efi_gpe_EndingLBA = LE_64((vs >> bs) - 1);
1551         UUID_LE_CONVERT(gpe.efi_gpe_PartitionTypeGUID, uuid);
1552
1553         if (efi.dki_lba == 1) {
1554                 efi_gpt_t gpt = { 0 };
1555
1556                 gpt.efi_gpt_Signature = LE_64(EFI_SIGNATURE);
1557                 gpt.efi_gpt_Revision = LE_32(EFI_VERSION_CURRENT);
1558                 gpt.efi_gpt_HeaderSize = LE_32(sizeof (gpt));
1559                 gpt.efi_gpt_MyLBA = LE_64(1ULL);
1560                 gpt.efi_gpt_FirstUsableLBA = LE_64(34ULL);
1561                 gpt.efi_gpt_LastUsableLBA = LE_64((vs >> bs) - 1);
1562                 gpt.efi_gpt_PartitionEntryLBA = LE_64(2ULL);
1563                 gpt.efi_gpt_NumberOfPartitionEntries = LE_32(1);
1564                 gpt.efi_gpt_SizeOfPartitionEntry =
1565                     LE_32(sizeof (efi_gpe_t));
1566                 CRC32(crc, &gpe, sizeof (gpe), -1U, crc32_table);
1567                 gpt.efi_gpt_PartitionEntryArrayCRC32 = LE_32(~crc);
1568                 CRC32(crc, &gpt, sizeof (gpt), -1U, crc32_table);
1569                 gpt.efi_gpt_HeaderCRC32 = LE_32(~crc);
1570                 if (ddi_copyout(&gpt, ptr, MIN(sizeof (gpt), length),
1571                     flag))
1572                         return (SET_ERROR(EFAULT));
1573                 ptr += sizeof (gpt);
1574                 length -= sizeof (gpt);
1575         }
1576         if (length > 0 && ddi_copyout(&gpe, ptr, MIN(sizeof (gpe),
1577             length), flag))
1578                 return (SET_ERROR(EFAULT));
1579         return (0);
1580 }
1581
1582 /*
1583  * BEGIN entry points to allow external callers access to the volume.
1584  */
1585 /*
1586  * Return the volume parameters needed for access from an external caller.
1587  * These values are invariant as long as the volume is held open.
1588  */
1589 int
1590 zvol_get_volume_params(minor_t minor, uint64_t *blksize,
1591     uint64_t *max_xfer_len, void **minor_hdl, void **objset_hdl, void **zil_hdl,
1592     void **rl_hdl, void **bonus_hdl)
1593 {
1594         zvol_state_t *zv;
1595
1596         zv = zfsdev_get_soft_state(minor, ZSST_ZVOL);
1597         if (zv == NULL)
1598                 return (SET_ERROR(ENXIO));
1599         if (zv->zv_flags & ZVOL_DUMPIFIED)
1600                 return (SET_ERROR(ENXIO));
1601
1602         ASSERT(blksize && max_xfer_len && minor_hdl &&
1603             objset_hdl && zil_hdl && rl_hdl && bonus_hdl);
1604
1605         *blksize = zv->zv_volblocksize;
1606         *max_xfer_len = (uint64_t)zvol_maxphys;
1607         *minor_hdl = zv;
1608         *objset_hdl = zv->zv_objset;
1609         *zil_hdl = zv->zv_zilog;
1610         *rl_hdl = &zv->zv_znode;
1611         *bonus_hdl = zv->zv_dbuf;
1612         return (0);
1613 }
1614
1615 /*
1616  * Return the current volume size to an external caller.
1617  * The size can change while the volume is open.
1618  */
1619 uint64_t
1620 zvol_get_volume_size(void *minor_hdl)
1621 {
1622         zvol_state_t *zv = minor_hdl;
1623
1624         return (zv->zv_volsize);
1625 }
1626
1627 /*
1628  * Return the current WCE setting to an external caller.
1629  * The WCE setting can change while the volume is open.
1630  */
1631 int
1632 zvol_get_volume_wce(void *minor_hdl)
1633 {
1634         zvol_state_t *zv = minor_hdl;
1635
1636         return ((zv->zv_flags & ZVOL_WCE) ? 1 : 0);
1637 }
1638
1639 /*
1640  * Entry point for external callers to zvol_log_write
1641  */
1642 void
1643 zvol_log_write_minor(void *minor_hdl, dmu_tx_t *tx, offset_t off, ssize_t resid,
1644     boolean_t sync)
1645 {
1646         zvol_state_t *zv = minor_hdl;
1647
1648         zvol_log_write(zv, tx, off, resid, sync);
1649 }
1650 /*
1651  * END entry points to allow external callers access to the volume.
1652  */
1653
1654 /*
1655  * Dirtbag ioctls to support mkfs(1M) for UFS filesystems.  See dkio(7I).
1656  */
1657 /*ARGSUSED*/
1658 int
1659 zvol_ioctl(dev_t dev, int cmd, intptr_t arg, int flag, cred_t *cr, int *rvalp)
1660 {
1661         zvol_state_t *zv;
1662         struct dk_cinfo dki;
1663         struct dk_minfo dkm;
1664         struct dk_callback *dkc;
1665         int error = 0;
1666         rl_t *rl;
1667
1668         mutex_enter(&spa_namespace_lock);
1669
1670         zv = zfsdev_get_soft_state(getminor(dev), ZSST_ZVOL);
1671
1672         if (zv == NULL) {
1673                 mutex_exit(&spa_namespace_lock);
1674                 return (SET_ERROR(ENXIO));
1675         }
1676         ASSERT(zv->zv_total_opens > 0);
1677
1678         switch (cmd) {
1679
1680         case DKIOCINFO:
1681                 bzero(&dki, sizeof (dki));
1682                 (void) strcpy(dki.dki_cname, "zvol");
1683                 (void) strcpy(dki.dki_dname, "zvol");
1684                 dki.dki_ctype = DKC_UNKNOWN;
1685                 dki.dki_unit = getminor(dev);
1686                 dki.dki_maxtransfer = 1 << (SPA_MAXBLOCKSHIFT - zv->zv_min_bs);
1687                 mutex_exit(&spa_namespace_lock);
1688                 if (ddi_copyout(&dki, (void *)arg, sizeof (dki), flag))
1689                         error = SET_ERROR(EFAULT);
1690                 return (error);
1691
1692         case DKIOCGMEDIAINFO:
1693                 bzero(&dkm, sizeof (dkm));
1694                 dkm.dki_lbsize = 1U << zv->zv_min_bs;
1695                 dkm.dki_capacity = zv->zv_volsize >> zv->zv_min_bs;
1696                 dkm.dki_media_type = DK_UNKNOWN;
1697                 mutex_exit(&spa_namespace_lock);
1698                 if (ddi_copyout(&dkm, (void *)arg, sizeof (dkm), flag))
1699                         error = SET_ERROR(EFAULT);
1700                 return (error);
1701
1702         case DKIOCGETEFI:
1703                 {
1704                         uint64_t vs = zv->zv_volsize;
1705                         uint8_t bs = zv->zv_min_bs;
1706
1707                         mutex_exit(&spa_namespace_lock);
1708                         error = zvol_getefi((void *)arg, flag, vs, bs);
1709                         return (error);
1710                 }
1711
1712         case DKIOCFLUSHWRITECACHE:
1713                 dkc = (struct dk_callback *)arg;
1714                 mutex_exit(&spa_namespace_lock);
1715                 zil_commit(zv->zv_zilog, ZVOL_OBJ);
1716                 if ((flag & FKIOCTL) && dkc != NULL && dkc->dkc_callback) {
1717                         (*dkc->dkc_callback)(dkc->dkc_cookie, error);
1718                         error = 0;
1719                 }
1720                 return (error);
1721
1722         case DKIOCGETWCE:
1723                 {
1724                         int wce = (zv->zv_flags & ZVOL_WCE) ? 1 : 0;
1725                         if (ddi_copyout(&wce, (void *)arg, sizeof (int),
1726                             flag))
1727                                 error = SET_ERROR(EFAULT);
1728                         break;
1729                 }
1730         case DKIOCSETWCE:
1731                 {
1732                         int wce;
1733                         if (ddi_copyin((void *)arg, &wce, sizeof (int),
1734                             flag)) {
1735                                 error = SET_ERROR(EFAULT);
1736                                 break;
1737                         }
1738                         if (wce) {
1739                                 zv->zv_flags |= ZVOL_WCE;
1740                                 mutex_exit(&spa_namespace_lock);
1741                         } else {
1742                                 zv->zv_flags &= ~ZVOL_WCE;
1743                                 mutex_exit(&spa_namespace_lock);
1744                                 zil_commit(zv->zv_zilog, ZVOL_OBJ);
1745                         }
1746                         return (0);
1747                 }
1748
1749         case DKIOCGGEOM:
1750         case DKIOCGVTOC:
1751                 /*
1752                  * commands using these (like prtvtoc) expect ENOTSUP
1753                  * since we're emulating an EFI label
1754                  */
1755                 error = SET_ERROR(ENOTSUP);
1756                 break;
1757
1758         case DKIOCDUMPINIT:
1759                 rl = zfs_range_lock(&zv->zv_znode, 0, zv->zv_volsize,
1760                     RL_WRITER);
1761                 error = zvol_dumpify(zv);
1762                 zfs_range_unlock(rl);
1763                 break;
1764
1765         case DKIOCDUMPFINI:
1766                 if (!(zv->zv_flags & ZVOL_DUMPIFIED))
1767                         break;
1768                 rl = zfs_range_lock(&zv->zv_znode, 0, zv->zv_volsize,
1769                     RL_WRITER);
1770                 error = zvol_dump_fini(zv);
1771                 zfs_range_unlock(rl);
1772                 break;
1773
1774         case DKIOCFREE:
1775         {
1776                 dkioc_free_t df;
1777                 dmu_tx_t *tx;
1778
1779                 if (ddi_copyin((void *)arg, &df, sizeof (df), flag)) {
1780                         error = SET_ERROR(EFAULT);
1781                         break;
1782                 }
1783
1784                 /*
1785                  * Apply Postel's Law to length-checking.  If they overshoot,
1786                  * just blank out until the end, if there's a need to blank
1787                  * out anything.
1788                  */
1789                 if (df.df_start >= zv->zv_volsize)
1790                         break;  /* No need to do anything... */
1791                 if (df.df_start + df.df_length > zv->zv_volsize)
1792                         df.df_length = DMU_OBJECT_END;
1793
1794                 rl = zfs_range_lock(&zv->zv_znode, df.df_start, df.df_length,
1795                     RL_WRITER);
1796                 tx = dmu_tx_create(zv->zv_objset);
1797                 error = dmu_tx_assign(tx, TXG_WAIT);
1798                 if (error != 0) {
1799                         dmu_tx_abort(tx);
1800                 } else {
1801                         zvol_log_truncate(zv, tx, df.df_start,
1802                             df.df_length, B_TRUE);
1803                         dmu_tx_commit(tx);
1804                         error = dmu_free_long_range(zv->zv_objset, ZVOL_OBJ,
1805                             df.df_start, df.df_length);
1806                 }
1807
1808                 zfs_range_unlock(rl);
1809
1810                 if (error == 0) {
1811                         /*
1812                          * If the write-cache is disabled or 'sync' property
1813                          * is set to 'always' then treat this as a synchronous
1814                          * operation (i.e. commit to zil).
1815                          */
1816                         if (!(zv->zv_flags & ZVOL_WCE) ||
1817                             (zv->zv_objset->os_sync == ZFS_SYNC_ALWAYS))
1818                                 zil_commit(zv->zv_zilog, ZVOL_OBJ);
1819
1820                         /*
1821                          * If the caller really wants synchronous writes, and
1822                          * can't wait for them, don't return until the write
1823                          * is done.
1824                          */
1825                         if (df.df_flags & DF_WAIT_SYNC) {
1826                                 txg_wait_synced(
1827                                     dmu_objset_pool(zv->zv_objset), 0);
1828                         }
1829                 }
1830                 break;
1831         }
1832
1833         default:
1834                 error = SET_ERROR(ENOTTY);
1835                 break;
1836
1837         }
1838         mutex_exit(&spa_namespace_lock);
1839         return (error);
1840 }
1841 #endif  /* sun */
1842
1843 int
1844 zvol_busy(void)
1845 {
1846         return (zvol_minors != 0);
1847 }
1848
1849 void
1850 zvol_init(void)
1851 {
1852         VERIFY(ddi_soft_state_init(&zfsdev_state, sizeof (zfs_soft_state_t),
1853             1) == 0);
1854         ZFS_LOG(1, "ZVOL Initialized.");
1855 }
1856
1857 void
1858 zvol_fini(void)
1859 {
1860         ddi_soft_state_fini(&zfsdev_state);
1861         ZFS_LOG(1, "ZVOL Deinitialized.");
1862 }
1863
1864 #ifdef sun
1865 /*ARGSUSED*/
1866 static int
1867 zfs_mvdev_dump_feature_check(void *arg, dmu_tx_t *tx)
1868 {
1869         spa_t *spa = dmu_tx_pool(tx)->dp_spa;
1870
1871         if (spa_feature_is_active(spa, SPA_FEATURE_MULTI_VDEV_CRASH_DUMP))
1872                 return (1);
1873         return (0);
1874 }
1875
1876 /*ARGSUSED*/
1877 static void
1878 zfs_mvdev_dump_activate_feature_sync(void *arg, dmu_tx_t *tx)
1879 {
1880         spa_t *spa = dmu_tx_pool(tx)->dp_spa;
1881
1882         spa_feature_incr(spa, SPA_FEATURE_MULTI_VDEV_CRASH_DUMP, tx);
1883 }
1884
1885 static int
1886 zvol_dump_init(zvol_state_t *zv, boolean_t resize)
1887 {
1888         dmu_tx_t *tx;
1889         int error;
1890         objset_t *os = zv->zv_objset;
1891         spa_t *spa = dmu_objset_spa(os);
1892         vdev_t *vd = spa->spa_root_vdev;
1893         nvlist_t *nv = NULL;
1894         uint64_t version = spa_version(spa);
1895         enum zio_checksum checksum;
1896
1897         ASSERT(MUTEX_HELD(&spa_namespace_lock));
1898         ASSERT(vd->vdev_ops == &vdev_root_ops);
1899
1900         error = dmu_free_long_range(zv->zv_objset, ZVOL_OBJ, 0,
1901             DMU_OBJECT_END);
1902         /* wait for dmu_free_long_range to actually free the blocks */
1903         txg_wait_synced(dmu_objset_pool(zv->zv_objset), 0);
1904
1905         /*
1906          * If the pool on which the dump device is being initialized has more
1907          * than one child vdev, check that the MULTI_VDEV_CRASH_DUMP feature is
1908          * enabled.  If so, bump that feature's counter to indicate that the
1909          * feature is active. We also check the vdev type to handle the
1910          * following case:
1911          *   # zpool create test raidz disk1 disk2 disk3
1912          *   Now have spa_root_vdev->vdev_children == 1 (the raidz vdev),
1913          *   the raidz vdev itself has 3 children.
1914          */
1915         if (vd->vdev_children > 1 || vd->vdev_ops == &vdev_raidz_ops) {
1916                 if (!spa_feature_is_enabled(spa,
1917                     SPA_FEATURE_MULTI_VDEV_CRASH_DUMP))
1918                         return (SET_ERROR(ENOTSUP));
1919                 (void) dsl_sync_task(spa_name(spa),
1920                     zfs_mvdev_dump_feature_check,
1921                     zfs_mvdev_dump_activate_feature_sync, NULL, 2);
1922         }
1923
1924         tx = dmu_tx_create(os);
1925         dmu_tx_hold_zap(tx, ZVOL_ZAP_OBJ, TRUE, NULL);
1926         dmu_tx_hold_bonus(tx, ZVOL_OBJ);
1927         error = dmu_tx_assign(tx, TXG_WAIT);
1928         if (error) {
1929                 dmu_tx_abort(tx);
1930                 return (error);
1931         }
1932
1933         /*
1934          * If MULTI_VDEV_CRASH_DUMP is active, use the NOPARITY checksum
1935          * function.  Otherwise, use the old default -- OFF.
1936          */
1937         checksum = spa_feature_is_active(spa,
1938             SPA_FEATURE_MULTI_VDEV_CRASH_DUMP) ? ZIO_CHECKSUM_NOPARITY :
1939             ZIO_CHECKSUM_OFF;
1940
1941         /*
1942          * If we are resizing the dump device then we only need to
1943          * update the refreservation to match the newly updated
1944          * zvolsize. Otherwise, we save off the original state of the
1945          * zvol so that we can restore them if the zvol is ever undumpified.
1946          */
1947         if (resize) {
1948                 error = zap_update(os, ZVOL_ZAP_OBJ,
1949                     zfs_prop_to_name(ZFS_PROP_REFRESERVATION), 8, 1,
1950                     &zv->zv_volsize, tx);
1951         } else {
1952                 uint64_t checksum, compress, refresrv, vbs, dedup;
1953
1954                 error = dsl_prop_get_integer(zv->zv_name,
1955                     zfs_prop_to_name(ZFS_PROP_COMPRESSION), &compress, NULL);
1956                 error = error ? error : dsl_prop_get_integer(zv->zv_name,
1957                     zfs_prop_to_name(ZFS_PROP_CHECKSUM), &checksum, NULL);
1958                 error = error ? error : dsl_prop_get_integer(zv->zv_name,
1959                     zfs_prop_to_name(ZFS_PROP_REFRESERVATION), &refresrv, NULL);
1960                 error = error ? error : dsl_prop_get_integer(zv->zv_name,
1961                     zfs_prop_to_name(ZFS_PROP_VOLBLOCKSIZE), &vbs, NULL);
1962                 if (version >= SPA_VERSION_DEDUP) {
1963                         error = error ? error :
1964                             dsl_prop_get_integer(zv->zv_name,
1965                             zfs_prop_to_name(ZFS_PROP_DEDUP), &dedup, NULL);
1966                 }
1967
1968                 error = error ? error : zap_update(os, ZVOL_ZAP_OBJ,
1969                     zfs_prop_to_name(ZFS_PROP_COMPRESSION), 8, 1,
1970                     &compress, tx);
1971                 error = error ? error : zap_update(os, ZVOL_ZAP_OBJ,
1972                     zfs_prop_to_name(ZFS_PROP_CHECKSUM), 8, 1, &checksum, tx);
1973                 error = error ? error : zap_update(os, ZVOL_ZAP_OBJ,
1974                     zfs_prop_to_name(ZFS_PROP_REFRESERVATION), 8, 1,
1975                     &refresrv, tx);
1976                 error = error ? error : zap_update(os, ZVOL_ZAP_OBJ,
1977                     zfs_prop_to_name(ZFS_PROP_VOLBLOCKSIZE), 8, 1,
1978                     &vbs, tx);
1979                 error = error ? error : dmu_object_set_blocksize(
1980                     os, ZVOL_OBJ, SPA_MAXBLOCKSIZE, 0, tx);
1981                 if (version >= SPA_VERSION_DEDUP) {
1982                         error = error ? error : zap_update(os, ZVOL_ZAP_OBJ,
1983                             zfs_prop_to_name(ZFS_PROP_DEDUP), 8, 1,
1984                             &dedup, tx);
1985                 }
1986                 if (error == 0)
1987                         zv->zv_volblocksize = SPA_MAXBLOCKSIZE;
1988         }
1989         dmu_tx_commit(tx);
1990
1991         /*
1992          * We only need update the zvol's property if we are initializing
1993          * the dump area for the first time.
1994          */
1995         if (!resize) {
1996                 VERIFY(nvlist_alloc(&nv, NV_UNIQUE_NAME, KM_SLEEP) == 0);
1997                 VERIFY(nvlist_add_uint64(nv,
1998                     zfs_prop_to_name(ZFS_PROP_REFRESERVATION), 0) == 0);
1999                 VERIFY(nvlist_add_uint64(nv,
2000                     zfs_prop_to_name(ZFS_PROP_COMPRESSION),
2001                     ZIO_COMPRESS_OFF) == 0);
2002                 VERIFY(nvlist_add_uint64(nv,
2003                     zfs_prop_to_name(ZFS_PROP_CHECKSUM),
2004                     checksum) == 0);
2005                 if (version >= SPA_VERSION_DEDUP) {
2006                         VERIFY(nvlist_add_uint64(nv,
2007                             zfs_prop_to_name(ZFS_PROP_DEDUP),
2008                             ZIO_CHECKSUM_OFF) == 0);
2009                 }
2010
2011                 error = zfs_set_prop_nvlist(zv->zv_name, ZPROP_SRC_LOCAL,
2012                     nv, NULL);
2013                 nvlist_free(nv);
2014
2015                 if (error)
2016                         return (error);
2017         }
2018
2019         /* Allocate the space for the dump */
2020         error = zvol_prealloc(zv);
2021         return (error);
2022 }
2023
2024 static int
2025 zvol_dumpify(zvol_state_t *zv)
2026 {
2027         int error = 0;
2028         uint64_t dumpsize = 0;
2029         dmu_tx_t *tx;
2030         objset_t *os = zv->zv_objset;
2031
2032         if (zv->zv_flags & ZVOL_RDONLY)
2033                 return (SET_ERROR(EROFS));
2034
2035         if (zap_lookup(zv->zv_objset, ZVOL_ZAP_OBJ, ZVOL_DUMPSIZE,
2036             8, 1, &dumpsize) != 0 || dumpsize != zv->zv_volsize) {
2037                 boolean_t resize = (dumpsize > 0);
2038
2039                 if ((error = zvol_dump_init(zv, resize)) != 0) {
2040                         (void) zvol_dump_fini(zv);
2041                         return (error);
2042                 }
2043         }
2044
2045         /*
2046          * Build up our lba mapping.
2047          */
2048         error = zvol_get_lbas(zv);
2049         if (error) {
2050                 (void) zvol_dump_fini(zv);
2051                 return (error);
2052         }
2053
2054         tx = dmu_tx_create(os);
2055         dmu_tx_hold_zap(tx, ZVOL_ZAP_OBJ, TRUE, NULL);
2056         error = dmu_tx_assign(tx, TXG_WAIT);
2057         if (error) {
2058                 dmu_tx_abort(tx);
2059                 (void) zvol_dump_fini(zv);
2060                 return (error);
2061         }
2062
2063         zv->zv_flags |= ZVOL_DUMPIFIED;
2064         error = zap_update(os, ZVOL_ZAP_OBJ, ZVOL_DUMPSIZE, 8, 1,
2065             &zv->zv_volsize, tx);
2066         dmu_tx_commit(tx);
2067
2068         if (error) {
2069                 (void) zvol_dump_fini(zv);
2070                 return (error);
2071         }
2072
2073         txg_wait_synced(dmu_objset_pool(os), 0);
2074         return (0);
2075 }
2076
2077 static int
2078 zvol_dump_fini(zvol_state_t *zv)
2079 {
2080         dmu_tx_t *tx;
2081         objset_t *os = zv->zv_objset;
2082         nvlist_t *nv;
2083         int error = 0;
2084         uint64_t checksum, compress, refresrv, vbs, dedup;
2085         uint64_t version = spa_version(dmu_objset_spa(zv->zv_objset));
2086
2087         /*
2088          * Attempt to restore the zvol back to its pre-dumpified state.
2089          * This is a best-effort attempt as it's possible that not all
2090          * of these properties were initialized during the dumpify process
2091          * (i.e. error during zvol_dump_init).
2092          */
2093
2094         tx = dmu_tx_create(os);
2095         dmu_tx_hold_zap(tx, ZVOL_ZAP_OBJ, TRUE, NULL);
2096         error = dmu_tx_assign(tx, TXG_WAIT);
2097         if (error) {
2098                 dmu_tx_abort(tx);
2099                 return (error);
2100         }
2101         (void) zap_remove(os, ZVOL_ZAP_OBJ, ZVOL_DUMPSIZE, tx);
2102         dmu_tx_commit(tx);
2103
2104         (void) zap_lookup(zv->zv_objset, ZVOL_ZAP_OBJ,
2105             zfs_prop_to_name(ZFS_PROP_CHECKSUM), 8, 1, &checksum);
2106         (void) zap_lookup(zv->zv_objset, ZVOL_ZAP_OBJ,
2107             zfs_prop_to_name(ZFS_PROP_COMPRESSION), 8, 1, &compress);
2108         (void) zap_lookup(zv->zv_objset, ZVOL_ZAP_OBJ,
2109             zfs_prop_to_name(ZFS_PROP_REFRESERVATION), 8, 1, &refresrv);
2110         (void) zap_lookup(zv->zv_objset, ZVOL_ZAP_OBJ,
2111             zfs_prop_to_name(ZFS_PROP_VOLBLOCKSIZE), 8, 1, &vbs);
2112
2113         VERIFY(nvlist_alloc(&nv, NV_UNIQUE_NAME, KM_SLEEP) == 0);
2114         (void) nvlist_add_uint64(nv,
2115             zfs_prop_to_name(ZFS_PROP_CHECKSUM), checksum);
2116         (void) nvlist_add_uint64(nv,
2117             zfs_prop_to_name(ZFS_PROP_COMPRESSION), compress);
2118         (void) nvlist_add_uint64(nv,
2119             zfs_prop_to_name(ZFS_PROP_REFRESERVATION), refresrv);
2120         if (version >= SPA_VERSION_DEDUP &&
2121             zap_lookup(zv->zv_objset, ZVOL_ZAP_OBJ,
2122             zfs_prop_to_name(ZFS_PROP_DEDUP), 8, 1, &dedup) == 0) {
2123                 (void) nvlist_add_uint64(nv,
2124                     zfs_prop_to_name(ZFS_PROP_DEDUP), dedup);
2125         }
2126         (void) zfs_set_prop_nvlist(zv->zv_name, ZPROP_SRC_LOCAL,
2127             nv, NULL);
2128         nvlist_free(nv);
2129
2130         zvol_free_extents(zv);
2131         zv->zv_flags &= ~ZVOL_DUMPIFIED;
2132         (void) dmu_free_long_range(os, ZVOL_OBJ, 0, DMU_OBJECT_END);
2133         /* wait for dmu_free_long_range to actually free the blocks */
2134         txg_wait_synced(dmu_objset_pool(zv->zv_objset), 0);
2135         tx = dmu_tx_create(os);
2136         dmu_tx_hold_bonus(tx, ZVOL_OBJ);
2137         error = dmu_tx_assign(tx, TXG_WAIT);
2138         if (error) {
2139                 dmu_tx_abort(tx);
2140                 return (error);
2141         }
2142         if (dmu_object_set_blocksize(os, ZVOL_OBJ, vbs, 0, tx) == 0)
2143                 zv->zv_volblocksize = vbs;
2144         dmu_tx_commit(tx);
2145
2146         return (0);
2147 }
2148 #endif  /* sun */
2149
2150 static zvol_state_t *
2151 zvol_geom_create(const char *name)
2152 {
2153         struct g_provider *pp;
2154         struct g_geom *gp;
2155         zvol_state_t *zv;
2156
2157         gp = g_new_geomf(&zfs_zvol_class, "zfs::zvol::%s", name);
2158         gp->start = zvol_geom_start;
2159         gp->access = zvol_geom_access;
2160         pp = g_new_providerf(gp, "%s/%s", ZVOL_DRIVER, name);
2161         pp->sectorsize = DEV_BSIZE;
2162
2163         zv = kmem_zalloc(sizeof(*zv), KM_SLEEP);
2164         zv->zv_provider = pp;
2165         zv->zv_state = 0;
2166         bioq_init(&zv->zv_queue);
2167         mtx_init(&zv->zv_queue_mtx, "zvol", NULL, MTX_DEF);
2168
2169         pp->private = zv;
2170
2171         return (zv);
2172 }
2173
2174 static void
2175 zvol_geom_run(zvol_state_t *zv)
2176 {
2177         struct g_provider *pp;
2178
2179         pp = zv->zv_provider;
2180         g_error_provider(pp, 0);
2181
2182         kproc_kthread_add(zvol_geom_worker, zv, &zfsproc, NULL, 0, 0,
2183             "zfskern", "zvol %s", pp->name + sizeof(ZVOL_DRIVER));
2184 }
2185
2186 static void
2187 zvol_geom_destroy(zvol_state_t *zv)
2188 {
2189         struct g_provider *pp;
2190
2191         g_topology_assert();
2192
2193         mtx_lock(&zv->zv_queue_mtx);
2194         zv->zv_state = 1;
2195         wakeup_one(&zv->zv_queue);
2196         while (zv->zv_state != 2)
2197                 msleep(&zv->zv_state, &zv->zv_queue_mtx, 0, "zvol:w", 0);
2198         mtx_destroy(&zv->zv_queue_mtx);
2199
2200         pp = zv->zv_provider;
2201         zv->zv_provider = NULL;
2202         pp->private = NULL;
2203         g_wither_geom(pp->geom, ENXIO);
2204
2205         kmem_free(zv, sizeof(*zv));
2206 }
2207
2208 static int
2209 zvol_geom_access(struct g_provider *pp, int acr, int acw, int ace)
2210 {
2211         int count, error, flags;
2212
2213         g_topology_assert();
2214
2215         /*
2216          * To make it easier we expect either open or close, but not both
2217          * at the same time.
2218          */
2219         KASSERT((acr >= 0 && acw >= 0 && ace >= 0) ||
2220             (acr <= 0 && acw <= 0 && ace <= 0),
2221             ("Unsupported access request to %s (acr=%d, acw=%d, ace=%d).",
2222             pp->name, acr, acw, ace));
2223
2224         if (pp->private == NULL) {
2225                 if (acr <= 0 && acw <= 0 && ace <= 0)
2226                         return (0);
2227                 return (pp->error);
2228         }
2229
2230         /*
2231          * We don't pass FEXCL flag to zvol_open()/zvol_close() if ace != 0,
2232          * because GEOM already handles that and handles it a bit differently.
2233          * GEOM allows for multiple read/exclusive consumers and ZFS allows
2234          * only one exclusive consumer, no matter if it is reader or writer.
2235          * I like better the way GEOM works so I'll leave it for GEOM to
2236          * decide what to do.
2237          */
2238
2239         count = acr + acw + ace;
2240         if (count == 0)
2241                 return (0);
2242
2243         flags = 0;
2244         if (acr != 0 || ace != 0)
2245                 flags |= FREAD;
2246         if (acw != 0)
2247                 flags |= FWRITE;
2248
2249         g_topology_unlock();
2250         if (count > 0)
2251                 error = zvol_open(pp, flags, count);
2252         else
2253                 error = zvol_close(pp, flags, -count);
2254         g_topology_lock();
2255         return (error);
2256 }
2257
2258 static void
2259 zvol_geom_start(struct bio *bp)
2260 {
2261         zvol_state_t *zv;
2262         boolean_t first;
2263
2264         switch (bp->bio_cmd) {
2265         case BIO_READ:
2266         case BIO_WRITE:
2267         case BIO_FLUSH:
2268                 zv = bp->bio_to->private;
2269                 ASSERT(zv != NULL);
2270                 mtx_lock(&zv->zv_queue_mtx);
2271                 first = (bioq_first(&zv->zv_queue) == NULL);
2272                 bioq_insert_tail(&zv->zv_queue, bp);
2273                 mtx_unlock(&zv->zv_queue_mtx);
2274                 if (first)
2275                         wakeup_one(&zv->zv_queue);
2276                 break;
2277         case BIO_GETATTR:
2278         case BIO_DELETE:
2279         default:
2280                 g_io_deliver(bp, EOPNOTSUPP);
2281                 break;
2282         }
2283 }
2284
2285 static void
2286 zvol_geom_worker(void *arg)
2287 {
2288         zvol_state_t *zv;
2289         struct bio *bp;
2290
2291         thread_lock(curthread);
2292         sched_prio(curthread, PRIBIO);
2293         thread_unlock(curthread);
2294
2295         zv = arg;
2296         for (;;) {
2297                 mtx_lock(&zv->zv_queue_mtx);
2298                 bp = bioq_takefirst(&zv->zv_queue);
2299                 if (bp == NULL) {
2300                         if (zv->zv_state == 1) {
2301                                 zv->zv_state = 2;
2302                                 wakeup(&zv->zv_state);
2303                                 mtx_unlock(&zv->zv_queue_mtx);
2304                                 kthread_exit();
2305                         }
2306                         msleep(&zv->zv_queue, &zv->zv_queue_mtx, PRIBIO | PDROP,
2307                             "zvol:io", 0);
2308                         continue;
2309                 }
2310                 mtx_unlock(&zv->zv_queue_mtx);
2311                 switch (bp->bio_cmd) {
2312                 case BIO_FLUSH:
2313                         zil_commit(zv->zv_zilog, ZVOL_OBJ);
2314                         g_io_deliver(bp, 0);
2315                         break;
2316                 case BIO_READ:
2317                 case BIO_WRITE:
2318                         zvol_strategy(bp);
2319                         break;
2320                 }
2321         }
2322 }
2323
2324 extern boolean_t dataset_name_hidden(const char *name);
2325
2326 static int
2327 zvol_create_snapshots(objset_t *os, const char *name)
2328 {
2329         uint64_t cookie, obj;
2330         char *sname;
2331         int error, len;
2332
2333         cookie = obj = 0;
2334         sname = kmem_alloc(MAXPATHLEN, KM_SLEEP);
2335
2336 #if 0
2337         (void) dmu_objset_find(name, dmu_objset_prefetch, NULL,
2338             DS_FIND_SNAPSHOTS);
2339 #endif
2340
2341         for (;;) {
2342                 len = snprintf(sname, MAXPATHLEN, "%s@", name);
2343                 if (len >= MAXPATHLEN) {
2344                         dmu_objset_rele(os, FTAG);
2345                         error = ENAMETOOLONG;
2346                         break;
2347                 }
2348
2349                 dsl_pool_config_enter(dmu_objset_pool(os), FTAG);
2350                 error = dmu_snapshot_list_next(os, MAXPATHLEN - len,
2351                     sname + len, &obj, &cookie, NULL);
2352                 dsl_pool_config_exit(dmu_objset_pool(os), FTAG);
2353                 if (error != 0) {
2354                         if (error == ENOENT)
2355                                 error = 0;
2356                         break;
2357                 }
2358
2359                 if ((error = zvol_create_minor(sname)) != 0) {
2360                         printf("ZFS WARNING: Unable to create ZVOL %s (error=%d).\n",
2361                             sname, error);
2362                         break;
2363                 }
2364         }
2365
2366         kmem_free(sname, MAXPATHLEN);
2367         return (error);
2368 }
2369
2370 int
2371 zvol_create_minors(const char *name)
2372 {
2373         uint64_t cookie;
2374         objset_t *os;
2375         char *osname, *p;
2376         int error, len;
2377
2378         if (dataset_name_hidden(name))
2379                 return (0);
2380
2381         if ((error = dmu_objset_hold(name, FTAG, &os)) != 0) {
2382                 printf("ZFS WARNING: Unable to put hold on %s (error=%d).\n",
2383                     name, error);
2384                 return (error);
2385         }
2386         if (dmu_objset_type(os) == DMU_OST_ZVOL) {
2387                 dsl_dataset_long_hold(os->os_dsl_dataset, FTAG);
2388                 dsl_pool_rele(dmu_objset_pool(os), FTAG);
2389                 if ((error = zvol_create_minor(name)) == 0)
2390                         error = zvol_create_snapshots(os, name);
2391                 else {
2392                         printf("ZFS WARNING: Unable to create ZVOL %s (error=%d).\n",
2393                             name, error);
2394                 }
2395                 dsl_dataset_long_rele(os->os_dsl_dataset, FTAG);
2396                 dsl_dataset_rele(os->os_dsl_dataset, FTAG);
2397                 return (error);
2398         }
2399         if (dmu_objset_type(os) != DMU_OST_ZFS) {
2400                 dmu_objset_rele(os, FTAG);
2401                 return (0);
2402         }
2403
2404         osname = kmem_alloc(MAXPATHLEN, KM_SLEEP);
2405         if (snprintf(osname, MAXPATHLEN, "%s/", name) >= MAXPATHLEN) {
2406                 dmu_objset_rele(os, FTAG);
2407                 kmem_free(osname, MAXPATHLEN);
2408                 return (ENOENT);
2409         }
2410         p = osname + strlen(osname);
2411         len = MAXPATHLEN - (p - osname);
2412
2413 #if 0
2414         /* Prefetch the datasets. */
2415         cookie = 0;
2416         while (dmu_dir_list_next(os, len, p, NULL, &cookie) == 0) {
2417                 if (!dataset_name_hidden(osname))
2418                         (void) dmu_objset_prefetch(osname, NULL);
2419         }
2420 #endif
2421
2422         cookie = 0;
2423         while (dmu_dir_list_next(os, MAXPATHLEN - (p - osname), p, NULL,
2424             &cookie) == 0) {
2425                 dmu_objset_rele(os, FTAG);
2426                 (void)zvol_create_minors(osname);
2427                 if ((error = dmu_objset_hold(name, FTAG, &os)) != 0) {
2428                         printf("ZFS WARNING: Unable to put hold on %s (error=%d).\n",
2429                             name, error);
2430                         return (error);
2431                 }
2432         }
2433
2434         dmu_objset_rele(os, FTAG);
2435         kmem_free(osname, MAXPATHLEN);
2436         return (0);
2437 }
2438
2439 static void
2440 zvol_rename_minor(struct g_geom *gp, const char *newname)
2441 {
2442         struct g_provider *pp;
2443         zvol_state_t *zv;
2444
2445         ASSERT(MUTEX_HELD(&spa_namespace_lock));
2446         g_topology_assert();
2447
2448         pp = LIST_FIRST(&gp->provider);
2449         ASSERT(pp != NULL);
2450         zv = pp->private;
2451         ASSERT(zv != NULL);
2452
2453         zv->zv_provider = NULL;
2454         g_wither_provider(pp, ENXIO);
2455
2456         pp = g_new_providerf(gp, "%s/%s", ZVOL_DRIVER, newname);
2457         pp->sectorsize = DEV_BSIZE;
2458         pp->mediasize = zv->zv_volsize;
2459         pp->private = zv;
2460         zv->zv_provider = pp;
2461         strlcpy(zv->zv_name, newname, sizeof(zv->zv_name));
2462         g_error_provider(pp, 0);
2463 }
2464
2465 void
2466 zvol_rename_minors(const char *oldname, const char *newname)
2467 {
2468         char name[MAXPATHLEN];
2469         struct g_provider *pp;
2470         struct g_geom *gp;
2471         size_t oldnamelen, newnamelen;
2472         zvol_state_t *zv;
2473         char *namebuf;
2474
2475         oldnamelen = strlen(oldname);
2476         newnamelen = strlen(newname);
2477
2478         DROP_GIANT();
2479         mutex_enter(&spa_namespace_lock);
2480         g_topology_lock();
2481
2482         LIST_FOREACH(gp, &zfs_zvol_class.geom, geom) {
2483                 pp = LIST_FIRST(&gp->provider);
2484                 if (pp == NULL)
2485                         continue;
2486                 zv = pp->private;
2487                 if (zv == NULL)
2488                         continue;
2489                 if (strcmp(zv->zv_name, oldname) == 0) {
2490                         zvol_rename_minor(gp, newname);
2491                 } else if (strncmp(zv->zv_name, oldname, oldnamelen) == 0 &&
2492                     (zv->zv_name[oldnamelen] == '/' ||
2493                      zv->zv_name[oldnamelen] == '@')) {
2494                         snprintf(name, sizeof(name), "%s%c%s", newname,
2495                             zv->zv_name[oldnamelen],
2496                             zv->zv_name + oldnamelen + 1);
2497                         zvol_rename_minor(gp, name);
2498                 }
2499         }
2500
2501         g_topology_unlock();
2502         mutex_exit(&spa_namespace_lock);
2503         PICKUP_GIANT();
2504 }