Print this page
NEX-9673 Add capability to replicate cloned datasets relative to origin
Reviewed by: Alex Deiter <alex.deiter@nexenta.com>
Reviewed by: Sanjay Nadkarni <sanjay.nadkarni@nexenta.com>
NEX-6855 System fails to boot up after a large number of datasets created
Reviewed by: Sanjay Nadkarni <sanjay.nadkarni@nexenta.com>
Reviewed by: Yuri Pankov <yuri.pankov@nexenta.com>
Revert "NEX-7251 Resume_token is not cleared right after finishing receive"
This reverts commit 9e97a45e8cf6ca59307a39e2d3c11c6e845e4187.
NEX-7251 Resume_token is not cleared right after finishing receive
Reviewed by: Alek Pinchuk <alek.pinchuk@nexenta.com>
Reviewed by: Alexey Komarov <alexey.komarov@nexenta.com>
NEX-5272 KRRP: replicate snapshot properties
Reviewed by: Sanjay Nadkarni <sanjay.nadkarni@nexenta.com>
Reviewed by: Alexey Komarov <alexey.komarov@nexenta.com>
Reviewed by: Alex Aizman <alex.aizman@nexenta.com>
2605 want to resume interrupted zfs send
Reviewed by: George Wilson <george.wilson@delphix.com>
Reviewed by: Paul Dagnelie <pcd@delphix.com>
Reviewed by: Richard Elling <Richard.Elling@RichardElling.com>
Reviewed by: Xin Li <delphij@freebsd.org>
Reviewed by: Arne Jansen <sensille@gmx.net>
Approved by: Dan McDonald <danmcd@omniti.com>
6160 /usr/lib/fs/zfs/bootinstall should use bootadm
Reviewed by: Igor Kozhukhov <ikozhukhov@gmail.com>
Reviewed by: Adam Števko <adam.stevko@gmail.com>
Reviewed by: Josef Sipek <jeffpc@josefsipek.net>
Approved by: Richard Lowe <richlowe@richlowe.net>
4185 add new cryptographic checksums to ZFS: SHA-512, Skein, Edon-R (NULL is not an int)
6171 dsl_prop_unregister() slows down dataset eviction.
Reviewed by: Matthew Ahrens <mahrens@delphix.com>
Reviewed by: Prakash Surya <prakash.surya@delphix.com>
Approved by: Dan McDonald <danmcd@omniti.com>
6047 SPARC boot should support feature@embedded_data
Reviewed by: Igor Kozhukhov <ikozhukhov@gmail.com>
Approved by: Dan McDonald <danmcd@omniti.com>
5959 clean up per-dataset feature count code
Reviewed by: Toomas Soome <tsoome@me.com>
Reviewed by: George Wilson <george@delphix.com>
Reviewed by: Alex Reece <alex@delphix.com>
Approved by: Richard Lowe <richlowe@richlowe.net>
NEX-4582 update wrc test cases for allow to use write back cache per tree of datasets
Reviewed by: Steve Peng <steve.peng@nexenta.com>
Reviewed by: Alex Aizman <alex.aizman@nexenta.com>
5960 zfs recv should prefetch indirect blocks
5925 zfs receive -o origin=
Reviewed by: Prakash Surya <prakash.surya@delphix.com>
Reviewed by: Matthew Ahrens <mahrens@delphix.com>
5765 add support for estimating send stream size with lzc_send_space when source is a bookmark
Reviewed by: Matthew Ahrens <mahrens@delphix.com>
Reviewed by: Christopher Siden <christopher.siden@delphix.com>
Reviewed by: Steven Hartland <killing@multiplay.co.uk>
Reviewed by: Bayard Bell <buffer.g.overflow@gmail.com>
Approved by: Albert Lee <trisk@nexenta.com>
NEX-3558 KRRP Integration
Fixup merge results
re #12585 rb4049 ZFS++ work port - refactoring to improve separation of open/closed code, bug fixes, performance improvements - open code
Bug 11205: add missing libzfs_closed_stubs.c to fix opensource-only build.
ZFS plus work: special vdevs, cos, cos/vdev properties


   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  * Copyright (c) 2011, 2017 by Delphix. All rights reserved.
  24  * Copyright (c) 2013, Joyent, Inc. All rights reserved.
  25  * Copyright (c) 2013 Steven Hartland. All rights reserved.
  26  * Copyright (c) 2014 Spectra Logic Corporation, All rights reserved.
  27  * Copyright (c) 2014 Integros [integros.com]

  28  */
  29 
  30 #ifndef _SYS_DSL_DATASET_H
  31 #define _SYS_DSL_DATASET_H
  32 
  33 #include <sys/dmu.h>
  34 #include <sys/spa.h>
  35 #include <sys/txg.h>
  36 #include <sys/zio.h>
  37 #include <sys/bplist.h>
  38 #include <sys/dsl_synctask.h>
  39 #include <sys/zfs_context.h>
  40 #include <sys/dsl_deadlist.h>
  41 #include <sys/refcount.h>
  42 #include <sys/rrwlock.h>
  43 #include <zfeature_common.h>
  44 
  45 #ifdef  __cplusplus
  46 extern "C" {
  47 #endif


  84  * bookmarks of this dataset.  If it is present, then this dataset is counted
  85  * in the refcount of the SPA_FEATURES_BOOKMARKS feature.
  86  */
  87 #define DS_FIELD_BOOKMARK_NAMES "com.delphix:bookmarks"
  88 
  89 /*
  90  * These fields are set on datasets that are in the middle of a resumable
  91  * receive, and allow the sender to resume the send if it is interrupted.
  92  */
  93 #define DS_FIELD_RESUME_FROMGUID "com.delphix:resume_fromguid"
  94 #define DS_FIELD_RESUME_TONAME "com.delphix:resume_toname"
  95 #define DS_FIELD_RESUME_TOGUID "com.delphix:resume_toguid"
  96 #define DS_FIELD_RESUME_OBJECT "com.delphix:resume_object"
  97 #define DS_FIELD_RESUME_OFFSET "com.delphix:resume_offset"
  98 #define DS_FIELD_RESUME_BYTES "com.delphix:resume_bytes"
  99 #define DS_FIELD_RESUME_LARGEBLOCK "com.delphix:resume_largeblockok"
 100 #define DS_FIELD_RESUME_EMBEDOK "com.delphix:resume_embedok"
 101 #define DS_FIELD_RESUME_COMPRESSOK "com.delphix:resume_compressok"
 102 
 103 /*
 104  * This field is set to the object number of the remap deadlist if one exists.
 105  */
 106 #define DS_FIELD_REMAP_DEADLIST "com.delphix:remap_deadlist"
 107 
 108 /*
 109  * DS_FLAG_CI_DATASET is set if the dataset contains a file system whose
 110  * name lookups should be performed case-insensitively.
 111  */
 112 #define DS_FLAG_CI_DATASET      (1ULL<<16)
 113 
 114 #define DS_CREATE_FLAG_NODIRTY  (1ULL<<24)
 115 








 116 typedef struct dsl_dataset_phys {
 117         uint64_t ds_dir_obj;            /* DMU_OT_DSL_DIR */
 118         uint64_t ds_prev_snap_obj;      /* DMU_OT_DSL_DATASET */
 119         uint64_t ds_prev_snap_txg;
 120         uint64_t ds_next_snap_obj;      /* DMU_OT_DSL_DATASET */
 121         uint64_t ds_snapnames_zapobj;   /* DMU_OT_DSL_DS_SNAP_MAP 0 for snaps */
 122         uint64_t ds_num_children;       /* clone/snap children; ==0 for head */
 123         uint64_t ds_creation_time;      /* seconds since 1970 */
 124         uint64_t ds_creation_txg;
 125         uint64_t ds_deadlist_obj;       /* DMU_OT_DEADLIST */
 126         /*
 127          * ds_referenced_bytes, ds_compressed_bytes, and ds_uncompressed_bytes
 128          * include all blocks referenced by this dataset, including those
 129          * shared with any other datasets.
 130          */
 131         uint64_t ds_referenced_bytes;
 132         uint64_t ds_compressed_bytes;
 133         uint64_t ds_uncompressed_bytes;
 134         uint64_t ds_unique_bytes;       /* only relevant to snapshots */
 135         /*


 149 
 150 typedef struct dsl_dataset {
 151         dmu_buf_user_t ds_dbu;
 152         rrwlock_t ds_bp_rwlock; /* Protects ds_phys->ds_bp */
 153 
 154         /* Immutable: */
 155         struct dsl_dir *ds_dir;
 156         dmu_buf_t *ds_dbuf;
 157         uint64_t ds_object;
 158         uint64_t ds_fsid_guid;
 159         boolean_t ds_is_snapshot;
 160 
 161         /* only used in syncing context, only valid for non-snapshots: */
 162         struct dsl_dataset *ds_prev;
 163         uint64_t ds_bookmarks;  /* DMU_OTN_ZAP_METADATA */
 164 
 165         /* has internal locking: */
 166         dsl_deadlist_t ds_deadlist;
 167         bplist_t ds_pending_deadlist;
 168 
 169         /*
 170          * The remap deadlist contains blocks (DVA's, really) that are
 171          * referenced by the previous snapshot and point to indirect vdevs,
 172          * but in this dataset they have been remapped to point to concrete
 173          * (or at least, less-indirect) vdevs.  In other words, the
 174          * physical DVA is referenced by the previous snapshot but not by
 175          * this dataset.  Logically, the DVA continues to be referenced,
 176          * but we are using a different (less indirect) physical DVA.
 177          * This deadlist is used to determine when physical DVAs that
 178          * point to indirect vdevs are no longer referenced anywhere,
 179          * and thus should be marked obsolete.
 180          *
 181          * This is only used if SPA_FEATURE_OBSOLETE_COUNTS is enabled.
 182          */
 183         dsl_deadlist_t ds_remap_deadlist;
 184         /* protects creation of the ds_remap_deadlist */
 185         kmutex_t ds_remap_deadlist_lock;
 186 
 187         /* protected by lock on pool's dp_dirty_datasets list */
 188         txg_node_t ds_dirty_link;
 189         list_node_t ds_synced_link;
 190 
 191         /*
 192          * ds_phys->ds_<accounting> is also protected by ds_lock.
 193          * Protected by ds_lock:
 194          */
 195         kmutex_t ds_lock;
 196         objset_t *ds_objset;
 197         uint64_t ds_userrefs;
 198         void *ds_owner;
 199 
 200         /*















 201          * Long holds prevent the ds from being destroyed; they allow the
 202          * ds to remain held even after dropping the dp_config_rwlock.
 203          * Owning counts as a long hold.  See the comments above
 204          * dsl_pool_hold() for details.
 205          */

 206         refcount_t ds_longholds;
 207 
 208         /* no locking; only for making guesses */
 209         uint64_t ds_trysnap_txg;
 210 
 211         /* for objset_open() */
 212         kmutex_t ds_opening_lock;
 213 
 214         uint64_t ds_reserved;   /* cached refreservation */
 215         uint64_t ds_quota;      /* cached refquota */
 216 
 217         kmutex_t ds_sendstream_lock;
 218         list_t ds_sendstreams;
 219 
 220         /*
 221          * When in the middle of a resumable receive, tracks how much
 222          * progress we have made.
 223          */
 224         uint64_t ds_resume_object[TXG_SIZE];
 225         uint64_t ds_resume_offset[TXG_SIZE];


 250         return (ds->ds_dbuf->db_data);
 251 }
 252 
 253 typedef struct dsl_dataset_promote_arg {
 254         const char *ddpa_clonename;
 255         dsl_dataset_t *ddpa_clone;
 256         list_t shared_snaps, origin_snaps, clone_snaps;
 257         dsl_dataset_t *origin_origin; /* origin of the origin */
 258         uint64_t used, comp, uncomp, unique, cloneusedsnap, originusedsnap;
 259         nvlist_t *err_ds;
 260         cred_t *cr;
 261 } dsl_dataset_promote_arg_t;
 262 
 263 typedef struct dsl_dataset_rollback_arg {
 264         const char *ddra_fsname;
 265         const char *ddra_tosnap;
 266         void *ddra_owner;
 267         nvlist_t *ddra_result;
 268 } dsl_dataset_rollback_arg_t;
 269 
 270 typedef struct dsl_dataset_snapshot_arg {
 271         nvlist_t *ddsa_snaps;
 272         nvlist_t *ddsa_props;
 273         nvlist_t *ddsa_errors;
 274         cred_t *ddsa_cr;
 275 } dsl_dataset_snapshot_arg_t;
 276 
 277 /*
 278  * The max length of a temporary tag prefix is the number of hex digits
 279  * required to express UINT64_MAX plus one for the hyphen.
 280  */
 281 #define MAX_TAG_PREFIX_LEN      17
 282 
 283 #define dsl_dataset_is_snapshot(ds) \
 284         (dsl_dataset_phys(ds)->ds_num_children != 0)
 285 
 286 #define DS_UNIQUE_IS_ACCURATE(ds)       \
 287         ((dsl_dataset_phys(ds)->ds_flags & DS_FLAG_UNIQUE_ACCURATE) != 0)
 288 
 289 int dsl_dataset_hold(struct dsl_pool *dp, const char *name, void *tag,
 290     dsl_dataset_t **dsp);
 291 boolean_t dsl_dataset_try_add_ref(struct dsl_pool *dp, dsl_dataset_t *ds,
 292     void *tag);
 293 int dsl_dataset_hold_obj(struct dsl_pool *dp, uint64_t dsobj, void *tag,
 294     dsl_dataset_t **);
 295 void dsl_dataset_rele(dsl_dataset_t *ds, void *tag);
 296 int dsl_dataset_own(struct dsl_pool *dp, const char *name,


 316     boolean_t force);
 317 int dsl_dataset_rename_snapshot(const char *fsname,
 318     const char *oldsnapname, const char *newsnapname, boolean_t recursive);
 319 int dsl_dataset_snapshot_tmp(const char *fsname, const char *snapname,
 320     minor_t cleanup_minor, const char *htag);
 321 
 322 blkptr_t *dsl_dataset_get_blkptr(dsl_dataset_t *ds);
 323 
 324 spa_t *dsl_dataset_get_spa(dsl_dataset_t *ds);
 325 
 326 boolean_t dsl_dataset_modified_since_snap(dsl_dataset_t *ds,
 327     dsl_dataset_t *snap);
 328 
 329 void dsl_dataset_sync(dsl_dataset_t *os, zio_t *zio, dmu_tx_t *tx);
 330 void dsl_dataset_sync_done(dsl_dataset_t *os, dmu_tx_t *tx);
 331 
 332 void dsl_dataset_block_born(dsl_dataset_t *ds, const blkptr_t *bp,
 333     dmu_tx_t *tx);
 334 int dsl_dataset_block_kill(dsl_dataset_t *ds, const blkptr_t *bp,
 335     dmu_tx_t *tx, boolean_t async);
 336 void dsl_dataset_block_remapped(dsl_dataset_t *ds, uint64_t vdev,
 337     uint64_t offset, uint64_t size, uint64_t birth, dmu_tx_t *tx);
 338 
 339 void dsl_dataset_dirty(dsl_dataset_t *ds, dmu_tx_t *tx);
 340 
 341 int get_clones_stat_impl(dsl_dataset_t *ds, nvlist_t *val);
 342 char *get_receive_resume_stats_impl(dsl_dataset_t *ds);
 343 char *get_child_receive_stats(dsl_dataset_t *ds);
 344 uint64_t dsl_get_refratio(dsl_dataset_t *ds);
 345 uint64_t dsl_get_logicalreferenced(dsl_dataset_t *ds);
 346 uint64_t dsl_get_compressratio(dsl_dataset_t *ds);
 347 uint64_t dsl_get_used(dsl_dataset_t *ds);
 348 uint64_t dsl_get_creation(dsl_dataset_t *ds);
 349 uint64_t dsl_get_creationtxg(dsl_dataset_t *ds);
 350 uint64_t dsl_get_refquota(dsl_dataset_t *ds);
 351 uint64_t dsl_get_refreservation(dsl_dataset_t *ds);
 352 uint64_t dsl_get_guid(dsl_dataset_t *ds);
 353 uint64_t dsl_get_unique(dsl_dataset_t *ds);
 354 uint64_t dsl_get_objsetid(dsl_dataset_t *ds);
 355 uint64_t dsl_get_userrefs(dsl_dataset_t *ds);
 356 uint64_t dsl_get_defer_destroy(dsl_dataset_t *ds);
 357 uint64_t dsl_get_referenced(dsl_dataset_t *ds);


 405 
 406 void dsl_dataset_remove_from_next_clones(dsl_dataset_t *ds, uint64_t obj,
 407     dmu_tx_t *tx);
 408 void dsl_dataset_recalc_head_uniq(dsl_dataset_t *ds);
 409 int dsl_dataset_get_snapname(dsl_dataset_t *ds);
 410 int dsl_dataset_snap_lookup(dsl_dataset_t *ds, const char *name,
 411     uint64_t *value);
 412 int dsl_dataset_snap_remove(dsl_dataset_t *ds, const char *name, dmu_tx_t *tx,
 413     boolean_t adj_cnt);
 414 void dsl_dataset_set_refreservation_sync_impl(dsl_dataset_t *ds,
 415     zprop_source_t source, uint64_t value, dmu_tx_t *tx);
 416 void dsl_dataset_zapify(dsl_dataset_t *ds, dmu_tx_t *tx);
 417 boolean_t dsl_dataset_is_zapified(dsl_dataset_t *ds);
 418 boolean_t dsl_dataset_has_resume_receive_state(dsl_dataset_t *ds);
 419 
 420 int dsl_dataset_rollback_check(void *arg, dmu_tx_t *tx);
 421 void dsl_dataset_rollback_sync(void *arg, dmu_tx_t *tx);
 422 int dsl_dataset_rollback(const char *fsname, const char *tosnap, void *owner,
 423     nvlist_t *result);
 424 
 425 uint64_t dsl_dataset_get_remap_deadlist_object(dsl_dataset_t *ds);
 426 void dsl_dataset_create_remap_deadlist(dsl_dataset_t *ds, dmu_tx_t *tx);
 427 boolean_t dsl_dataset_remap_deadlist_exists(dsl_dataset_t *ds);
 428 void dsl_dataset_destroy_remap_deadlist(dsl_dataset_t *ds, dmu_tx_t *tx);
 429 



















 430 void dsl_dataset_deactivate_feature(uint64_t dsobj,
 431     spa_feature_t f, dmu_tx_t *tx);
 432 
 433 #ifdef ZFS_DEBUG
 434 #define dprintf_ds(ds, fmt, ...) do { \
 435         if (zfs_flags & ZFS_DEBUG_DPRINTF) { \
 436         char *__ds_name = kmem_alloc(ZFS_MAX_DATASET_NAME_LEN, KM_SLEEP); \
 437         dsl_dataset_name(ds, __ds_name); \
 438         dprintf("ds=%s " fmt, __ds_name, __VA_ARGS__); \
 439         kmem_free(__ds_name, ZFS_MAX_DATASET_NAME_LEN); \
 440         } \
 441 _NOTE(CONSTCOND) } while (0)
 442 #else
 443 #define dprintf_ds(dd, fmt, ...)
 444 #endif
 445 
 446 #ifdef  __cplusplus
 447 }
 448 #endif
 449 


   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  * Copyright (c) 2011, 2017 by Delphix. All rights reserved.
  24  * Copyright (c) 2013, Joyent, Inc. All rights reserved.
  25  * Copyright (c) 2013 Steven Hartland. All rights reserved.
  26  * Copyright (c) 2014 Spectra Logic Corporation, All rights reserved.
  27  * Copyright (c) 2014 Integros [integros.com]
  28  * Copyright 2016 Nexenta Systems, Inc. All rights reserved.
  29  */
  30 
  31 #ifndef _SYS_DSL_DATASET_H
  32 #define _SYS_DSL_DATASET_H
  33 
  34 #include <sys/dmu.h>
  35 #include <sys/spa.h>
  36 #include <sys/txg.h>
  37 #include <sys/zio.h>
  38 #include <sys/bplist.h>
  39 #include <sys/dsl_synctask.h>
  40 #include <sys/zfs_context.h>
  41 #include <sys/dsl_deadlist.h>
  42 #include <sys/refcount.h>
  43 #include <sys/rrwlock.h>
  44 #include <zfeature_common.h>
  45 
  46 #ifdef  __cplusplus
  47 extern "C" {
  48 #endif


  85  * bookmarks of this dataset.  If it is present, then this dataset is counted
  86  * in the refcount of the SPA_FEATURES_BOOKMARKS feature.
  87  */
  88 #define DS_FIELD_BOOKMARK_NAMES "com.delphix:bookmarks"
  89 
  90 /*
  91  * These fields are set on datasets that are in the middle of a resumable
  92  * receive, and allow the sender to resume the send if it is interrupted.
  93  */
  94 #define DS_FIELD_RESUME_FROMGUID "com.delphix:resume_fromguid"
  95 #define DS_FIELD_RESUME_TONAME "com.delphix:resume_toname"
  96 #define DS_FIELD_RESUME_TOGUID "com.delphix:resume_toguid"
  97 #define DS_FIELD_RESUME_OBJECT "com.delphix:resume_object"
  98 #define DS_FIELD_RESUME_OFFSET "com.delphix:resume_offset"
  99 #define DS_FIELD_RESUME_BYTES "com.delphix:resume_bytes"
 100 #define DS_FIELD_RESUME_LARGEBLOCK "com.delphix:resume_largeblockok"
 101 #define DS_FIELD_RESUME_EMBEDOK "com.delphix:resume_embedok"
 102 #define DS_FIELD_RESUME_COMPRESSOK "com.delphix:resume_compressok"
 103 
 104 /*





 105  * DS_FLAG_CI_DATASET is set if the dataset contains a file system whose
 106  * name lookups should be performed case-insensitively.
 107  */
 108 #define DS_FLAG_CI_DATASET      (1ULL<<16)
 109 
 110 #define DS_CREATE_FLAG_NODIRTY  (1ULL<<24)
 111 
 112 typedef struct dsl_dataset_snapshot_arg {
 113         nvlist_t *ddsa_snaps;
 114         nvlist_t *ddsa_props;
 115         nvlist_t *ddsa_errors;
 116         cred_t *ddsa_cr;
 117         boolean_t ddsa_autosnap;
 118 } dsl_dataset_snapshot_arg_t;
 119 
 120 typedef struct dsl_dataset_phys {
 121         uint64_t ds_dir_obj;            /* DMU_OT_DSL_DIR */
 122         uint64_t ds_prev_snap_obj;      /* DMU_OT_DSL_DATASET */
 123         uint64_t ds_prev_snap_txg;
 124         uint64_t ds_next_snap_obj;      /* DMU_OT_DSL_DATASET */
 125         uint64_t ds_snapnames_zapobj;   /* DMU_OT_DSL_DS_SNAP_MAP 0 for snaps */
 126         uint64_t ds_num_children;       /* clone/snap children; ==0 for head */
 127         uint64_t ds_creation_time;      /* seconds since 1970 */
 128         uint64_t ds_creation_txg;
 129         uint64_t ds_deadlist_obj;       /* DMU_OT_DEADLIST */
 130         /*
 131          * ds_referenced_bytes, ds_compressed_bytes, and ds_uncompressed_bytes
 132          * include all blocks referenced by this dataset, including those
 133          * shared with any other datasets.
 134          */
 135         uint64_t ds_referenced_bytes;
 136         uint64_t ds_compressed_bytes;
 137         uint64_t ds_uncompressed_bytes;
 138         uint64_t ds_unique_bytes;       /* only relevant to snapshots */
 139         /*


 153 
 154 typedef struct dsl_dataset {
 155         dmu_buf_user_t ds_dbu;
 156         rrwlock_t ds_bp_rwlock; /* Protects ds_phys->ds_bp */
 157 
 158         /* Immutable: */
 159         struct dsl_dir *ds_dir;
 160         dmu_buf_t *ds_dbuf;
 161         uint64_t ds_object;
 162         uint64_t ds_fsid_guid;
 163         boolean_t ds_is_snapshot;
 164 
 165         /* only used in syncing context, only valid for non-snapshots: */
 166         struct dsl_dataset *ds_prev;
 167         uint64_t ds_bookmarks;  /* DMU_OTN_ZAP_METADATA */
 168 
 169         /* has internal locking: */
 170         dsl_deadlist_t ds_deadlist;
 171         bplist_t ds_pending_deadlist;
 172 


















 173         /* protected by lock on pool's dp_dirty_datasets list */
 174         txg_node_t ds_dirty_link;
 175         list_node_t ds_synced_link;
 176 
 177         /*
 178          * ds_phys->ds_<accounting> is also protected by ds_lock.
 179          * Protected by ds_lock:
 180          */
 181         kmutex_t ds_lock;
 182         objset_t *ds_objset;
 183         uint64_t ds_userrefs;
 184         void *ds_owner;
 185 
 186         /*
 187          * NOTE: for pool with special device only
 188          * Last transaction data was moved from special devices
 189          * to other (regular) devices in a pool.
 190          */
 191         uint64_t ds_lstxg;
 192 
 193         /*
 194          * NOTE: for pool with special device only
 195          * Level 0 bookmark we remembered when we were interrupted
 196          * during traversal process. Used to resume traversal
 197          * later.
 198          */
 199         zbookmark_phys_t ds_lszb;
 200 
 201         /*
 202          * Long holds prevent the ds from being destroyed; they allow the
 203          * ds to remain held even after dropping the dp_config_rwlock.
 204          * Owning counts as a long hold.  See the comments above
 205          * dsl_pool_hold() for details.
 206          */
 207 
 208         refcount_t ds_longholds;
 209 
 210         /* no locking; only for making guesses */
 211         uint64_t ds_trysnap_txg;
 212 
 213         /* for objset_open() */
 214         kmutex_t ds_opening_lock;
 215 
 216         uint64_t ds_reserved;   /* cached refreservation */
 217         uint64_t ds_quota;      /* cached refquota */
 218 
 219         kmutex_t ds_sendstream_lock;
 220         list_t ds_sendstreams;
 221 
 222         /*
 223          * When in the middle of a resumable receive, tracks how much
 224          * progress we have made.
 225          */
 226         uint64_t ds_resume_object[TXG_SIZE];
 227         uint64_t ds_resume_offset[TXG_SIZE];


 252         return (ds->ds_dbuf->db_data);
 253 }
 254 
 255 typedef struct dsl_dataset_promote_arg {
 256         const char *ddpa_clonename;
 257         dsl_dataset_t *ddpa_clone;
 258         list_t shared_snaps, origin_snaps, clone_snaps;
 259         dsl_dataset_t *origin_origin; /* origin of the origin */
 260         uint64_t used, comp, uncomp, unique, cloneusedsnap, originusedsnap;
 261         nvlist_t *err_ds;
 262         cred_t *cr;
 263 } dsl_dataset_promote_arg_t;
 264 
 265 typedef struct dsl_dataset_rollback_arg {
 266         const char *ddra_fsname;
 267         const char *ddra_tosnap;
 268         void *ddra_owner;
 269         nvlist_t *ddra_result;
 270 } dsl_dataset_rollback_arg_t;
 271 







 272 /*
 273  * The max length of a temporary tag prefix is the number of hex digits
 274  * required to express UINT64_MAX plus one for the hyphen.
 275  */
 276 #define MAX_TAG_PREFIX_LEN      17
 277 
 278 #define dsl_dataset_is_snapshot(ds) \
 279         (dsl_dataset_phys(ds)->ds_num_children != 0)
 280 
 281 #define DS_UNIQUE_IS_ACCURATE(ds)       \
 282         ((dsl_dataset_phys(ds)->ds_flags & DS_FLAG_UNIQUE_ACCURATE) != 0)
 283 
 284 int dsl_dataset_hold(struct dsl_pool *dp, const char *name, void *tag,
 285     dsl_dataset_t **dsp);
 286 boolean_t dsl_dataset_try_add_ref(struct dsl_pool *dp, dsl_dataset_t *ds,
 287     void *tag);
 288 int dsl_dataset_hold_obj(struct dsl_pool *dp, uint64_t dsobj, void *tag,
 289     dsl_dataset_t **);
 290 void dsl_dataset_rele(dsl_dataset_t *ds, void *tag);
 291 int dsl_dataset_own(struct dsl_pool *dp, const char *name,


 311     boolean_t force);
 312 int dsl_dataset_rename_snapshot(const char *fsname,
 313     const char *oldsnapname, const char *newsnapname, boolean_t recursive);
 314 int dsl_dataset_snapshot_tmp(const char *fsname, const char *snapname,
 315     minor_t cleanup_minor, const char *htag);
 316 
 317 blkptr_t *dsl_dataset_get_blkptr(dsl_dataset_t *ds);
 318 
 319 spa_t *dsl_dataset_get_spa(dsl_dataset_t *ds);
 320 
 321 boolean_t dsl_dataset_modified_since_snap(dsl_dataset_t *ds,
 322     dsl_dataset_t *snap);
 323 
 324 void dsl_dataset_sync(dsl_dataset_t *os, zio_t *zio, dmu_tx_t *tx);
 325 void dsl_dataset_sync_done(dsl_dataset_t *os, dmu_tx_t *tx);
 326 
 327 void dsl_dataset_block_born(dsl_dataset_t *ds, const blkptr_t *bp,
 328     dmu_tx_t *tx);
 329 int dsl_dataset_block_kill(dsl_dataset_t *ds, const blkptr_t *bp,
 330     dmu_tx_t *tx, boolean_t async);


 331 
 332 void dsl_dataset_dirty(dsl_dataset_t *ds, dmu_tx_t *tx);
 333 
 334 int get_clones_stat_impl(dsl_dataset_t *ds, nvlist_t *val);
 335 char *get_receive_resume_stats_impl(dsl_dataset_t *ds);
 336 char *get_child_receive_stats(dsl_dataset_t *ds);
 337 uint64_t dsl_get_refratio(dsl_dataset_t *ds);
 338 uint64_t dsl_get_logicalreferenced(dsl_dataset_t *ds);
 339 uint64_t dsl_get_compressratio(dsl_dataset_t *ds);
 340 uint64_t dsl_get_used(dsl_dataset_t *ds);
 341 uint64_t dsl_get_creation(dsl_dataset_t *ds);
 342 uint64_t dsl_get_creationtxg(dsl_dataset_t *ds);
 343 uint64_t dsl_get_refquota(dsl_dataset_t *ds);
 344 uint64_t dsl_get_refreservation(dsl_dataset_t *ds);
 345 uint64_t dsl_get_guid(dsl_dataset_t *ds);
 346 uint64_t dsl_get_unique(dsl_dataset_t *ds);
 347 uint64_t dsl_get_objsetid(dsl_dataset_t *ds);
 348 uint64_t dsl_get_userrefs(dsl_dataset_t *ds);
 349 uint64_t dsl_get_defer_destroy(dsl_dataset_t *ds);
 350 uint64_t dsl_get_referenced(dsl_dataset_t *ds);


 398 
 399 void dsl_dataset_remove_from_next_clones(dsl_dataset_t *ds, uint64_t obj,
 400     dmu_tx_t *tx);
 401 void dsl_dataset_recalc_head_uniq(dsl_dataset_t *ds);
 402 int dsl_dataset_get_snapname(dsl_dataset_t *ds);
 403 int dsl_dataset_snap_lookup(dsl_dataset_t *ds, const char *name,
 404     uint64_t *value);
 405 int dsl_dataset_snap_remove(dsl_dataset_t *ds, const char *name, dmu_tx_t *tx,
 406     boolean_t adj_cnt);
 407 void dsl_dataset_set_refreservation_sync_impl(dsl_dataset_t *ds,
 408     zprop_source_t source, uint64_t value, dmu_tx_t *tx);
 409 void dsl_dataset_zapify(dsl_dataset_t *ds, dmu_tx_t *tx);
 410 boolean_t dsl_dataset_is_zapified(dsl_dataset_t *ds);
 411 boolean_t dsl_dataset_has_resume_receive_state(dsl_dataset_t *ds);
 412 
 413 int dsl_dataset_rollback_check(void *arg, dmu_tx_t *tx);
 414 void dsl_dataset_rollback_sync(void *arg, dmu_tx_t *tx);
 415 int dsl_dataset_rollback(const char *fsname, const char *tosnap, void *owner,
 416     nvlist_t *result);
 417 
 418 int dsl_dataset_snapshot_check(void *arg, dmu_tx_t *tx);
 419 void dsl_dataset_snapshot_sync(void *arg, dmu_tx_t *tx);


 420 
 421 typedef struct {
 422         char name[ZFS_MAX_DATASET_NAME_LEN];
 423         char origin_name[ZFS_MAX_DATASET_NAME_LEN];
 424         uint64_t origin_guid;
 425         uint64_t cookie;
 426         boolean_t cookie_is_snap;
 427         boolean_t top_level_ds;
 428         dsl_dataset_t *ds;
 429         list_node_t node;
 430         avl_tree_t snapshots;
 431 } zfs_ds_collector_entry_t;
 432 
 433 uint64_t dsl_dataset_creation_txg(const char *name);
 434 
 435 boolean_t dataset_name_hidden(const char *name);
 436 
 437 zfs_ds_collector_entry_t *dsl_dataset_collector_cache_alloc();
 438 void dsl_dataset_collector_cache_free(zfs_ds_collector_entry_t *entry);
 439 
 440 void dsl_dataset_deactivate_feature(uint64_t dsobj,
 441     spa_feature_t f, dmu_tx_t *tx);
 442 
 443 #ifdef ZFS_DEBUG
 444 #define dprintf_ds(ds, fmt, ...) do { \
 445         if (zfs_flags & ZFS_DEBUG_DPRINTF) { \
 446         char *__ds_name = kmem_alloc(ZFS_MAX_DATASET_NAME_LEN, KM_SLEEP); \
 447         dsl_dataset_name(ds, __ds_name); \
 448         dprintf("ds=%s " fmt, __ds_name, __VA_ARGS__); \
 449         kmem_free(__ds_name, ZFS_MAX_DATASET_NAME_LEN); \
 450         } \
 451 _NOTE(CONSTCOND) } while (0)
 452 #else
 453 #define dprintf_ds(dd, fmt, ...)
 454 #endif
 455 
 456 #ifdef  __cplusplus
 457 }
 458 #endif
 459