libzfs_config.c revision 168404
1168404Spjd/* 2168404Spjd * CDDL HEADER START 3168404Spjd * 4168404Spjd * The contents of this file are subject to the terms of the 5168404Spjd * Common Development and Distribution License (the "License"). 6168404Spjd * You may not use this file except in compliance with the License. 7168404Spjd * 8168404Spjd * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE 9168404Spjd * or http://www.opensolaris.org/os/licensing. 10168404Spjd * See the License for the specific language governing permissions 11168404Spjd * and limitations under the License. 12168404Spjd * 13168404Spjd * When distributing Covered Code, include this CDDL HEADER in each 14168404Spjd * file and include the License file at usr/src/OPENSOLARIS.LICENSE. 15168404Spjd * If applicable, add the following below this CDDL HEADER, with the 16168404Spjd * fields enclosed by brackets "[]" replaced with your own identifying 17168404Spjd * information: Portions Copyright [yyyy] [name of copyright owner] 18168404Spjd * 19168404Spjd * CDDL HEADER END 20168404Spjd */ 21168404Spjd/* 22168404Spjd * Copyright 2007 Sun Microsystems, Inc. All rights reserved. 23168404Spjd * Use is subject to license terms. 24168404Spjd */ 25168404Spjd 26168404Spjd#pragma ident "%Z%%M% %I% %E% SMI" 27168404Spjd 28168404Spjd/* 29168404Spjd * The pool configuration repository is stored in /etc/zfs/zpool.cache as a 30168404Spjd * single packed nvlist. While it would be nice to just read in this 31168404Spjd * file from userland, this wouldn't work from a local zone. So we have to have 32168404Spjd * a zpool ioctl to return the complete configuration for all pools. In the 33168404Spjd * global zone, this will be identical to reading the file and unpacking it in 34168404Spjd * userland. 35168404Spjd */ 36168404Spjd 37168404Spjd#include <errno.h> 38168404Spjd#include <sys/stat.h> 39168404Spjd#include <fcntl.h> 40168404Spjd#include <stddef.h> 41168404Spjd#include <string.h> 42168404Spjd#include <unistd.h> 43168404Spjd#include <libintl.h> 44168404Spjd#include <libuutil.h> 45168404Spjd 46168404Spjd#include "libzfs_impl.h" 47168404Spjd 48168404Spjdtypedef struct config_node { 49168404Spjd char *cn_name; 50168404Spjd nvlist_t *cn_config; 51168404Spjd uu_avl_node_t cn_avl; 52168404Spjd} config_node_t; 53168404Spjd 54168404Spjd/* ARGSUSED */ 55168404Spjdstatic int 56168404Spjdconfig_node_compare(const void *a, const void *b, void *unused) 57168404Spjd{ 58168404Spjd int ret; 59168404Spjd 60168404Spjd const config_node_t *ca = (config_node_t *)a; 61168404Spjd const config_node_t *cb = (config_node_t *)b; 62168404Spjd 63168404Spjd ret = strcmp(ca->cn_name, cb->cn_name); 64168404Spjd 65168404Spjd if (ret < 0) 66168404Spjd return (-1); 67168404Spjd else if (ret > 0) 68168404Spjd return (1); 69168404Spjd else 70168404Spjd return (0); 71168404Spjd} 72168404Spjd 73168404Spjdvoid 74168404Spjdnamespace_clear(libzfs_handle_t *hdl) 75168404Spjd{ 76168404Spjd if (hdl->libzfs_ns_avl) { 77168404Spjd uu_avl_walk_t *walk; 78168404Spjd config_node_t *cn; 79168404Spjd 80168404Spjd if ((walk = uu_avl_walk_start(hdl->libzfs_ns_avl, 81168404Spjd UU_WALK_ROBUST)) == NULL) 82168404Spjd return; 83168404Spjd 84168404Spjd while ((cn = uu_avl_walk_next(walk)) != NULL) { 85168404Spjd uu_avl_remove(hdl->libzfs_ns_avl, cn); 86168404Spjd nvlist_free(cn->cn_config); 87168404Spjd free(cn->cn_name); 88168404Spjd free(cn); 89168404Spjd } 90168404Spjd 91168404Spjd uu_avl_walk_end(walk); 92168404Spjd 93168404Spjd uu_avl_destroy(hdl->libzfs_ns_avl); 94168404Spjd hdl->libzfs_ns_avl = NULL; 95168404Spjd } 96168404Spjd 97168404Spjd if (hdl->libzfs_ns_avlpool) { 98168404Spjd uu_avl_pool_destroy(hdl->libzfs_ns_avlpool); 99168404Spjd hdl->libzfs_ns_avlpool = NULL; 100168404Spjd } 101168404Spjd} 102168404Spjd 103168404Spjd/* 104168404Spjd * Loads the pool namespace, or re-loads it if the cache has changed. 105168404Spjd */ 106168404Spjdstatic int 107168404Spjdnamespace_reload(libzfs_handle_t *hdl) 108168404Spjd{ 109168404Spjd nvlist_t *config; 110168404Spjd config_node_t *cn; 111168404Spjd nvpair_t *elem; 112168404Spjd zfs_cmd_t zc = { 0 }; 113168404Spjd uu_avl_walk_t *walk; 114168404Spjd 115168404Spjd if (hdl->libzfs_ns_gen == 0) { 116168404Spjd /* 117168404Spjd * This is the first time we've accessed the configuration 118168404Spjd * cache. Initialize the AVL tree and then fall through to the 119168404Spjd * common code. 120168404Spjd */ 121168404Spjd if ((hdl->libzfs_ns_avlpool = uu_avl_pool_create("config_pool", 122168404Spjd sizeof (config_node_t), 123168404Spjd offsetof(config_node_t, cn_avl), 124168404Spjd config_node_compare, UU_DEFAULT)) == NULL) 125168404Spjd return (no_memory(hdl)); 126168404Spjd 127168404Spjd if ((hdl->libzfs_ns_avl = uu_avl_create(hdl->libzfs_ns_avlpool, 128168404Spjd NULL, UU_DEFAULT)) == NULL) 129168404Spjd return (no_memory(hdl)); 130168404Spjd } 131168404Spjd 132168404Spjd if (zcmd_alloc_dst_nvlist(hdl, &zc, 0) != 0) 133168404Spjd return (-1); 134168404Spjd 135168404Spjd for (;;) { 136168404Spjd zc.zc_cookie = hdl->libzfs_ns_gen; 137168404Spjd if (ioctl(hdl->libzfs_fd, ZFS_IOC_POOL_CONFIGS, &zc) != 0) { 138168404Spjd switch (errno) { 139168404Spjd case EEXIST: 140168404Spjd /* 141168404Spjd * The namespace hasn't changed. 142168404Spjd */ 143168404Spjd zcmd_free_nvlists(&zc); 144168404Spjd return (0); 145168404Spjd 146168404Spjd case ENOMEM: 147168404Spjd if (zcmd_expand_dst_nvlist(hdl, &zc) != 0) { 148168404Spjd zcmd_free_nvlists(&zc); 149168404Spjd return (-1); 150168404Spjd } 151168404Spjd break; 152168404Spjd 153168404Spjd default: 154168404Spjd zcmd_free_nvlists(&zc); 155168404Spjd return (zfs_standard_error(hdl, errno, 156168404Spjd dgettext(TEXT_DOMAIN, "failed to read " 157168404Spjd "pool configuration"))); 158168404Spjd } 159168404Spjd } else { 160168404Spjd hdl->libzfs_ns_gen = zc.zc_cookie; 161168404Spjd break; 162168404Spjd } 163168404Spjd } 164168404Spjd 165168404Spjd if (zcmd_read_dst_nvlist(hdl, &zc, &config) != 0) { 166168404Spjd zcmd_free_nvlists(&zc); 167168404Spjd return (-1); 168168404Spjd } 169168404Spjd 170168404Spjd zcmd_free_nvlists(&zc); 171168404Spjd 172168404Spjd /* 173168404Spjd * Clear out any existing configuration information. 174168404Spjd */ 175168404Spjd if ((walk = uu_avl_walk_start(hdl->libzfs_ns_avl, 176168404Spjd UU_WALK_ROBUST)) == NULL) { 177168404Spjd nvlist_free(config); 178168404Spjd return (no_memory(hdl)); 179168404Spjd } 180168404Spjd 181168404Spjd while ((cn = uu_avl_walk_next(walk)) != NULL) { 182168404Spjd uu_avl_remove(hdl->libzfs_ns_avl, cn); 183168404Spjd nvlist_free(cn->cn_config); 184168404Spjd free(cn->cn_name); 185168404Spjd free(cn); 186168404Spjd } 187168404Spjd 188168404Spjd uu_avl_walk_end(walk); 189168404Spjd 190168404Spjd elem = NULL; 191168404Spjd while ((elem = nvlist_next_nvpair(config, elem)) != NULL) { 192168404Spjd nvlist_t *child; 193168404Spjd uu_avl_index_t where; 194168404Spjd 195168404Spjd if ((cn = zfs_alloc(hdl, sizeof (config_node_t))) == NULL) { 196168404Spjd nvlist_free(config); 197168404Spjd return (-1); 198168404Spjd } 199168404Spjd 200168404Spjd if ((cn->cn_name = zfs_strdup(hdl, 201168404Spjd nvpair_name(elem))) == NULL) { 202168404Spjd free(cn); 203168404Spjd nvlist_free(config); 204168404Spjd return (-1); 205168404Spjd } 206168404Spjd 207168404Spjd verify(nvpair_value_nvlist(elem, &child) == 0); 208168404Spjd if (nvlist_dup(child, &cn->cn_config, 0) != 0) { 209168404Spjd free(cn->cn_name); 210168404Spjd free(cn); 211168404Spjd nvlist_free(config); 212168404Spjd return (no_memory(hdl)); 213168404Spjd } 214168404Spjd verify(uu_avl_find(hdl->libzfs_ns_avl, cn, NULL, &where) 215168404Spjd == NULL); 216168404Spjd 217168404Spjd uu_avl_insert(hdl->libzfs_ns_avl, cn, where); 218168404Spjd } 219168404Spjd 220168404Spjd nvlist_free(config); 221168404Spjd return (0); 222168404Spjd} 223168404Spjd 224168404Spjd/* 225168404Spjd * Retrive the configuration for the given pool. The configuration is a nvlist 226168404Spjd * describing the vdevs, as well as the statistics associated with each one. 227168404Spjd */ 228168404Spjdnvlist_t * 229168404Spjdzpool_get_config(zpool_handle_t *zhp, nvlist_t **oldconfig) 230168404Spjd{ 231168404Spjd if (oldconfig) 232168404Spjd *oldconfig = zhp->zpool_old_config; 233168404Spjd return (zhp->zpool_config); 234168404Spjd} 235168404Spjd 236168404Spjd/* 237168404Spjd * Refresh the vdev statistics associated with the given pool. This is used in 238168404Spjd * iostat to show configuration changes and determine the delta from the last 239168404Spjd * time the function was called. This function can fail, in case the pool has 240168404Spjd * been destroyed. 241168404Spjd */ 242168404Spjdint 243168404Spjdzpool_refresh_stats(zpool_handle_t *zhp, boolean_t *missing) 244168404Spjd{ 245168404Spjd zfs_cmd_t zc = { 0 }; 246168404Spjd int error; 247168404Spjd nvlist_t *config; 248168404Spjd libzfs_handle_t *hdl = zhp->zpool_hdl; 249168404Spjd 250168404Spjd *missing = B_FALSE; 251168404Spjd (void) strcpy(zc.zc_name, zhp->zpool_name); 252168404Spjd 253168404Spjd if (zhp->zpool_config_size == 0) 254168404Spjd zhp->zpool_config_size = 1 << 16; 255168404Spjd 256168404Spjd if (zcmd_alloc_dst_nvlist(hdl, &zc, zhp->zpool_config_size) != 0) 257168404Spjd return (-1); 258168404Spjd 259168404Spjd for (;;) { 260168404Spjd if (ioctl(zhp->zpool_hdl->libzfs_fd, ZFS_IOC_POOL_STATS, 261168404Spjd &zc) == 0) { 262168404Spjd /* 263168404Spjd * The real error is returned in the zc_cookie field. 264168404Spjd */ 265168404Spjd error = zc.zc_cookie; 266168404Spjd break; 267168404Spjd } 268168404Spjd 269168404Spjd if (errno == ENOMEM) { 270168404Spjd if (zcmd_expand_dst_nvlist(hdl, &zc) != 0) { 271168404Spjd zcmd_free_nvlists(&zc); 272168404Spjd return (-1); 273168404Spjd } 274168404Spjd } else { 275168404Spjd zcmd_free_nvlists(&zc); 276168404Spjd if (errno == ENOENT || errno == EINVAL) 277168404Spjd *missing = B_TRUE; 278168404Spjd zhp->zpool_state = POOL_STATE_UNAVAIL; 279168404Spjd return (0); 280168404Spjd } 281168404Spjd } 282168404Spjd 283168404Spjd if (zcmd_read_dst_nvlist(hdl, &zc, &config) != 0) { 284168404Spjd zcmd_free_nvlists(&zc); 285168404Spjd return (-1); 286168404Spjd } 287168404Spjd 288168404Spjd zcmd_free_nvlists(&zc); 289168404Spjd 290168404Spjd zhp->zpool_config_size = zc.zc_nvlist_dst_size; 291168404Spjd 292168404Spjd if (zhp->zpool_config != NULL) { 293168404Spjd uint64_t oldtxg, newtxg; 294168404Spjd 295168404Spjd verify(nvlist_lookup_uint64(zhp->zpool_config, 296168404Spjd ZPOOL_CONFIG_POOL_TXG, &oldtxg) == 0); 297168404Spjd verify(nvlist_lookup_uint64(config, 298168404Spjd ZPOOL_CONFIG_POOL_TXG, &newtxg) == 0); 299168404Spjd 300168404Spjd if (zhp->zpool_old_config != NULL) 301168404Spjd nvlist_free(zhp->zpool_old_config); 302168404Spjd 303168404Spjd if (oldtxg != newtxg) { 304168404Spjd nvlist_free(zhp->zpool_config); 305168404Spjd zhp->zpool_old_config = NULL; 306168404Spjd } else { 307168404Spjd zhp->zpool_old_config = zhp->zpool_config; 308168404Spjd } 309168404Spjd } 310168404Spjd 311168404Spjd zhp->zpool_config = config; 312168404Spjd if (error) 313168404Spjd zhp->zpool_state = POOL_STATE_UNAVAIL; 314168404Spjd else 315168404Spjd zhp->zpool_state = POOL_STATE_ACTIVE; 316168404Spjd 317168404Spjd return (0); 318168404Spjd} 319168404Spjd 320168404Spjd/* 321168404Spjd * Iterate over all pools in the system. 322168404Spjd */ 323168404Spjdint 324168404Spjdzpool_iter(libzfs_handle_t *hdl, zpool_iter_f func, void *data) 325168404Spjd{ 326168404Spjd config_node_t *cn; 327168404Spjd zpool_handle_t *zhp; 328168404Spjd int ret; 329168404Spjd 330168404Spjd if (namespace_reload(hdl) != 0) 331168404Spjd return (-1); 332168404Spjd 333168404Spjd for (cn = uu_avl_first(hdl->libzfs_ns_avl); cn != NULL; 334168404Spjd cn = uu_avl_next(hdl->libzfs_ns_avl, cn)) { 335168404Spjd 336168404Spjd if (zpool_open_silent(hdl, cn->cn_name, &zhp) != 0) 337168404Spjd return (-1); 338168404Spjd 339168404Spjd if (zhp == NULL) 340168404Spjd continue; 341168404Spjd 342168404Spjd if ((ret = func(zhp, data)) != 0) 343168404Spjd return (ret); 344168404Spjd } 345168404Spjd 346168404Spjd return (0); 347168404Spjd} 348168404Spjd 349168404Spjd/* 350168404Spjd * Iterate over root datasets, calling the given function for each. The zfs 351168404Spjd * handle passed each time must be explicitly closed by the callback. 352168404Spjd */ 353168404Spjdint 354168404Spjdzfs_iter_root(libzfs_handle_t *hdl, zfs_iter_f func, void *data) 355168404Spjd{ 356168404Spjd config_node_t *cn; 357168404Spjd zfs_handle_t *zhp; 358168404Spjd int ret; 359168404Spjd 360168404Spjd if (namespace_reload(hdl) != 0) 361168404Spjd return (-1); 362168404Spjd 363168404Spjd for (cn = uu_avl_first(hdl->libzfs_ns_avl); cn != NULL; 364168404Spjd cn = uu_avl_next(hdl->libzfs_ns_avl, cn)) { 365168404Spjd 366168404Spjd if ((zhp = make_dataset_handle(hdl, cn->cn_name)) == NULL) 367168404Spjd continue; 368168404Spjd 369168404Spjd if ((ret = func(zhp, data)) != 0) 370168404Spjd return (ret); 371168404Spjd } 372168404Spjd 373168404Spjd return (0); 374168404Spjd} 375