LU-8900 snapshot: simulate readonly device

[fs/lustre-release.git] / lustre / osd-zfs / osd_handler.c

diff --git a/lustre/osd-zfs/osd_handler.c b/lustre/osd-zfs/osd_handler.c
index 5307f92..f57e3a7 100644 (file)
--- a/lustre/osd-zfs/osd_handler.c
+++ b/lustre/osd-zfs/osd_handler.c
@@ -337,6 +337,14 @@ static struct thandle *osd_trans_create(const struct lu_env *env,
        dmu_tx_t                *tx;
        ENTRY;
 
+       if (dt->dd_rdonly) {
+               CERROR("%s: someone try to start transaction under "
+                      "readonly mode, should be disabled.\n",
+                      osd_name(osd_dt_dev(dt)));
+               dump_stack();
+               RETURN(ERR_PTR(-EROFS));
+       }
+
        tx = dmu_tx_create(osd->od_os);
        if (tx == NULL)
                RETURN(ERR_PTR(-ENOMEM));
@@ -481,7 +489,8 @@ static int osd_objset_statfs(struct osd_device *osd, struct obd_statfs *osfs)
        osfs->os_bavail = osfs->os_bfree; /* no extra root reservation */
 
        /* Take replication (i.e. number of copies) into account */
-       osfs->os_bavail /= os->os_copies;
+       if (os->os_copies != 0)
+               osfs->os_bavail /= os->os_copies;
 
        /*
         * Reserve some space so we don't run into ENOSPC due to grants not
@@ -615,10 +624,14 @@ static void osd_conf_get(const struct lu_env *env,
  */
 static int osd_sync(const struct lu_env *env, struct dt_device *d)
 {
-       struct osd_device  *osd = osd_dt_dev(d);
-       CDEBUG(D_CACHE, "syncing OSD %s\n", LUSTRE_OSD_ZFS_NAME);
-       txg_wait_synced(dmu_objset_pool(osd->od_os), 0ULL);
-       CDEBUG(D_CACHE, "synced OSD %s\n", LUSTRE_OSD_ZFS_NAME);
+       if (!d->dd_rdonly) {
+               struct osd_device  *osd = osd_dt_dev(d);
+
+               CDEBUG(D_CACHE, "syncing OSD %s\n", LUSTRE_OSD_ZFS_NAME);
+               txg_wait_synced(dmu_objset_pool(osd->od_os), 0ULL);
+               CDEBUG(D_CACHE, "synced OSD %s\n", LUSTRE_OSD_ZFS_NAME);
+       }
+
        return 0;
 }
 
@@ -839,11 +852,14 @@ static int osd_objset_open(struct osd_device *o)
        int             rc;
        ENTRY;
 
-       rc = -dmu_objset_own(o->od_mntdev, DMU_OST_ZFS, B_FALSE, o, &o->od_os);
+       rc = -dmu_objset_own(o->od_mntdev, DMU_OST_ZFS,
+                            o->od_dt_dev.dd_rdonly ? B_TRUE : B_FALSE,
+                            o, &o->od_os);
        if (rc) {
                CERROR("%s: can't open %s\n", o->od_svname, o->od_mntdev);
                o->od_os = NULL;
-               goto out;
+
+               GOTO(out, rc);
        }
 
        /* Check ZFS version */
@@ -908,6 +924,14 @@ osd_unlinked_object_free(struct osd_device *osd, uint64_t oid)
        int       rc;
        dmu_tx_t *tx;
 
+       if (osd->od_dt_dev.dd_rdonly) {
+               CERROR("%s: someone try to free objects under "
+                      "readonly mode, should be disabled.\n", osd_name(osd));
+               dump_stack();
+
+               return -EROFS;
+       }
+
        rc = -dmu_free_long_range(osd->od_os, oid, 0, DMU_OBJECT_END);
        if (rc != 0) {
                CWARN("%s: Cannot truncate %llu: rc = %d\n",
@@ -973,6 +997,7 @@ static int osd_mount(const struct lu_env *env,
                     struct osd_device *o, struct lustre_cfg *cfg)
 {
        char                    *mntdev = lustre_cfg_string(cfg, 1);
+       char                    *str    = lustre_cfg_string(cfg, 2);
        char                    *svname = lustre_cfg_string(cfg, 4);
        dnode_t *rootdn;
        const char              *opts;
@@ -993,6 +1018,21 @@ static int osd_mount(const struct lu_env *env,
        if (rc >= sizeof(o->od_svname))
                RETURN(-E2BIG);
 
+       str = strstr(str, ":");
+       if (str) {
+               unsigned long flags;
+
+               rc = kstrtoul(str + 1, 10, &flags);
+               if (rc)
+                       RETURN(-EINVAL);
+
+               if (flags & LMD_FLG_DEV_RDONLY) {
+                       o->od_dt_dev.dd_rdonly = 1;
+                       LCONSOLE_WARN("%s: set dev_rdonly on this device\n",
+                                     svname);
+               }
+       }
+
        if (server_name_is_ost(o->od_svname))
                o->od_is_ost = 1;
 
@@ -1052,7 +1092,7 @@ static int osd_mount(const struct lu_env *env,
 
        osd_unlinked_drain(env, o);
 err:
-       if (rc) {
+       if (rc && o->od_os) {
                dmu_objset_disown(o->od_os, o);
                o->od_os = NULL;
        }
@@ -1075,8 +1115,9 @@ static void osd_umount(const struct lu_env *env, struct osd_device *o)
                       atomic_read(&o->od_zerocopy_pin));
 
        if (o->od_os != NULL) {
-               /* force a txg sync to get all commit callbacks */
-               txg_wait_synced(dmu_objset_pool(o->od_os), 0ULL);
+               if (!o->od_dt_dev.dd_rdonly)
+                       /* force a txg sync to get all commit callbacks */
+                       txg_wait_synced(dmu_objset_pool(o->od_os), 0ULL);
 
                /* close the object set */
                dmu_objset_disown(o->od_os, o);
@@ -1177,8 +1218,11 @@ static struct lu_device *osd_device_fini(const struct lu_env *env,
 
        if (o->od_os) {
                osd_objset_unregister_callbacks(o);
-               osd_sync(env, lu2dt_dev(d));
-               txg_wait_callbacks(spa_get_dsl(dmu_objset_spa(o->od_os)));
+               if (!o->od_dt_dev.dd_rdonly) {
+                       osd_sync(env, lu2dt_dev(d));
+                       txg_wait_callbacks(
+                                       spa_get_dsl(dmu_objset_spa(o->od_os)));
+               }
        }
 
        rc = osd_procfs_fini(o);