3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock/*
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * CDDL HEADER START
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock *
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * The contents of this file are subject to the terms of the
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * Common Development and Distribution License (the "License").
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * You may not use this file except in compliance with the License.
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock *
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * or http://www.opensolaris.org/os/licensing.
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * See the License for the specific language governing permissions
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * and limitations under the License.
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock *
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * When distributing Covered Code, include this CDDL HEADER in each
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * If applicable, add the following below this CDDL HEADER, with the
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * fields enclosed by brackets "[]" replaced with your own identifying
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * information: Portions Copyright [yyyy] [name of copyright owner]
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock *
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * CDDL HEADER END
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock */
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock/*
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor * Copyright (c) 2007, 2010, Oracle and/or its affiliates. All rights reserved.
4263d13f00c9691fa14620eff82abef795be0693George Wilson * Copyright (c) 2012 by Delphix. All rights reserved.
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld * Copyright 2015 Nexenta Systems, Inc. All rights reserved.
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock */
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock/*
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * ZFS syseventd module.
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock *
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * The purpose of this module is to identify when devices are added to the
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * system, and appropriately online or replace the affected vdevs.
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock *
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * When a device is added to the system:
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock *
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * 1. Search for any vdevs whose devid matches that of the newly added
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * device.
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock *
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * 2. If no vdevs are found, then search for any vdevs whose devfs path
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * matches that of the new device.
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock *
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * 3. If no vdevs match by either method, then ignore the event.
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock *
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * 4. Attempt to online the device with a flag to indicate that it should
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * be unspared when resilvering completes. If this succeeds, then the
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * same device was inserted and we should continue normally.
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock *
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * 5. If the pool does not have the 'autoreplace' property set, attempt to
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * online the device again without the unspare flag, which will
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * generate a FMA fault.
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock *
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * 6. If the pool has the 'autoreplace' property set, and the matching vdev
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * is a whole disk, then label the new disk and attempt a 'zpool
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * replace'.
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock *
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * The module responds to EC_DEV_ADD events for both disks and lofi devices,
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * with the latter used for testing. The special ESC_ZFS_VDEV_CHECK event
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * indicates that a device failed to open during pool load, but the autoreplace
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * property was set. In this case, we deferred the associated FMA fault until
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * our module had a chance to process the autoreplace logic. If the device
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * could not be replaced, then the second online attempt will trigger the FMA
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * fault that we skipped earlier.
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock */
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock#include <alloca.h>
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock#include <devid.h>
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock#include <fcntl.h>
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock#include <libnvpair.h>
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock#include <libsysevent.h>
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock#include <libzfs.h>
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock#include <limits.h>
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock#include <stdlib.h>
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock#include <string.h>
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock#include <syslog.h>
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor#include <sys/list.h>
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock#include <sys/sunddi.h>
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock#include <sys/sysevent/eventdefs.h>
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock#include <sys/sysevent/dev.h>
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor#include <thread_pool.h>
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock#include <unistd.h>
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor#include "syseventd.h"
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock#if defined(__i386) || defined(__amd64)
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock#define PHYS_PATH ":q"
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock#define RAW_SLICE "p0"
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock#elif defined(__sparc)
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock#define PHYS_PATH ":c"
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock#define RAW_SLICE "s2"
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock#else
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock#error Unknown architecture
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock#endif
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrocktypedef void (*zfs_process_func_t)(zpool_handle_t *, nvlist_t *, boolean_t);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrocklibzfs_handle_t *g_zfshdl;
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylorlist_t g_pool_list;
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylortpool_t *g_tpool;
37e3a0d8ec40beeef3861086ca78f757dd47eabdEric Taylorboolean_t g_enumeration_done;
37e3a0d8ec40beeef3861086ca78f757dd47eabdEric Taylorthread_t g_zfs_tid;
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylortypedef struct unavailpool {
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor zpool_handle_t *uap_zhp;
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor list_node_t uap_node;
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor} unavailpool_t;
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylorint
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylorzfs_toplevel_state(zpool_handle_t *zhp)
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor{
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor nvlist_t *nvroot;
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor vdev_stat_t *vs;
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor unsigned int c;
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor verify(nvlist_lookup_nvlist(zpool_get_config(zhp, NULL),
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor ZPOOL_CONFIG_VDEV_TREE, &nvroot) == 0);
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor verify(nvlist_lookup_uint64_array(nvroot, ZPOOL_CONFIG_VDEV_STATS,
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor (uint64_t **)&vs, &c) == 0);
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor return (vs->vs_state);
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor}
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylorstatic int
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylorzfs_unavail_pool(zpool_handle_t *zhp, void *data)
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor{
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor if (zfs_toplevel_state(zhp) < VDEV_STATE_DEGRADED) {
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor unavailpool_t *uap;
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor uap = malloc(sizeof (unavailpool_t));
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor uap->uap_zhp = zhp;
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor list_insert_tail((list_t *)data, uap);
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor } else {
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor zpool_close(zhp);
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor }
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor return (0);
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor}
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock/*
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * The device associated with the given vdev (either by devid or physical path)
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * has been added to the system. If 'isdisk' is set, then we only attempt a
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * replacement if it's a whole disk. This also implies that we should label the
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * disk first.
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock *
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * First, we attempt to online the device (making sure to undo any spare
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * operation when finished). If this succeeds, then we're done. If it fails,
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * and the new state is VDEV_CANT_OPEN, it indicates that the device was opened,
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * but that the label was not what we expected. If the 'autoreplace' property
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * is not set, then we relabel the disk (if specified), and attempt a 'zpool
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * replace'. If the online is successful, but the new state is something else
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * (REMOVED or FAULTED), it indicates that we're out of sync or in some sort of
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * race, and we should avoid attempting to relabel the disk.
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock */
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrockstatic void
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrockzfs_process_add(zpool_handle_t *zhp, nvlist_t *vdev, boolean_t isdisk)
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock{
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock char *path;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock vdev_state_t newstate;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock nvlist_t *nvroot, *newvd;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock uint64_t wholedisk = 0ULL;
acd07c6b871cfa70bc42c9278037a17c430897b6Yuri Pankov uint64_t offline = 0ULL;
bf82a41b568b2bd31bf9814587eb25ee2e7b05ffeschrock char *physpath = NULL;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock char rawpath[PATH_MAX], fullpath[PATH_MAX];
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock size_t len;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock if (nvlist_lookup_string(vdev, ZPOOL_CONFIG_PATH, &path) != 0)
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock return;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
bf82a41b568b2bd31bf9814587eb25ee2e7b05ffeschrock (void) nvlist_lookup_string(vdev, ZPOOL_CONFIG_PHYS_PATH, &physpath);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock (void) nvlist_lookup_uint64(vdev, ZPOOL_CONFIG_WHOLE_DISK, &wholedisk);
acd07c6b871cfa70bc42c9278037a17c430897b6Yuri Pankov (void) nvlist_lookup_uint64(vdev, ZPOOL_CONFIG_OFFLINE, &offline);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock /*
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * We should have a way to online a device by guid. With the current
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * interface, we are forced to chop off the 's0' for whole disks.
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock */
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock (void) strlcpy(fullpath, path, sizeof (fullpath));
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock if (wholedisk)
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock fullpath[strlen(fullpath) - 2] = '\0';
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock /*
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * Attempt to online the device. It would be nice to online this by
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * GUID, but the current interface only supports lookup by path.
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock */
acd07c6b871cfa70bc42c9278037a17c430897b6Yuri Pankov if (offline ||
acd07c6b871cfa70bc42c9278037a17c430897b6Yuri Pankov (zpool_vdev_online(zhp, fullpath,
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock ZFS_ONLINE_CHECKREMOVE | ZFS_ONLINE_UNSPARE, &newstate) == 0 &&
acd07c6b871cfa70bc42c9278037a17c430897b6Yuri Pankov (newstate == VDEV_STATE_HEALTHY ||
acd07c6b871cfa70bc42c9278037a17c430897b6Yuri Pankov newstate == VDEV_STATE_DEGRADED)))
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock return;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock /*
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * If the pool doesn't have the autoreplace property set, then attempt a
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * true online (without the unspare flag), which will trigger a FMA
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * fault.
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock */
990b4856d0eaada6f8140335733a1b1771ed2746lling if (!zpool_get_prop_int(zhp, ZPOOL_PROP_AUTOREPLACE, NULL) ||
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock (isdisk && !wholedisk)) {
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock (void) zpool_vdev_online(zhp, fullpath, ZFS_ONLINE_FORCEFAULT,
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock &newstate);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock return;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock }
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock if (isdisk) {
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock /*
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * If this is a request to label a whole disk, then attempt to
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * write out the label. Before we can label the disk, we need
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * access to a raw node. Ideally, we'd like to walk the devinfo
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * tree and find a raw node from the corresponding parent node.
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * This is overly complicated, and since we know how we labeled
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * this device in the first place, we know it's save to switch
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * from /dev/dsk to /dev/rdsk and append the backup slice.
c5904d138f3bdf0762dbf452a43d5a5c387ea6a8eschrock *
c5904d138f3bdf0762dbf452a43d5a5c387ea6a8eschrock * If any part of this process fails, then do a force online to
c5904d138f3bdf0762dbf452a43d5a5c387ea6a8eschrock * trigger a ZFS fault for the device (and any hot spare
c5904d138f3bdf0762dbf452a43d5a5c387ea6a8eschrock * replacement).
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock */
6401734d545a04c18f68b448202f9d9a77216bb9Will Andrews if (strncmp(path, ZFS_DISK_ROOTD,
6401734d545a04c18f68b448202f9d9a77216bb9Will Andrews strlen(ZFS_DISK_ROOTD)) != 0) {
c5904d138f3bdf0762dbf452a43d5a5c387ea6a8eschrock (void) zpool_vdev_online(zhp, fullpath,
c5904d138f3bdf0762dbf452a43d5a5c387ea6a8eschrock ZFS_ONLINE_FORCEFAULT, &newstate);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock return;
c5904d138f3bdf0762dbf452a43d5a5c387ea6a8eschrock }
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock (void) strlcpy(rawpath, path + 9, sizeof (rawpath));
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock len = strlen(rawpath);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock rawpath[len - 2] = '\0';
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
c5904d138f3bdf0762dbf452a43d5a5c387ea6a8eschrock if (zpool_label_disk(g_zfshdl, zhp, rawpath) != 0) {
c5904d138f3bdf0762dbf452a43d5a5c387ea6a8eschrock (void) zpool_vdev_online(zhp, fullpath,
c5904d138f3bdf0762dbf452a43d5a5c387ea6a8eschrock ZFS_ONLINE_FORCEFAULT, &newstate);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock return;
c5904d138f3bdf0762dbf452a43d5a5c387ea6a8eschrock }
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock }
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock /*
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * Cosntruct the root vdev to pass to zpool_vdev_attach(). While adding
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * the entire vdev structure is harmless, we construct a reduced set of
bf82a41b568b2bd31bf9814587eb25ee2e7b05ffeschrock * path/physpath/wholedisk to keep it simple.
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock */
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock if (nvlist_alloc(&nvroot, NV_UNIQUE_NAME, 0) != 0)
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock return;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock if (nvlist_alloc(&newvd, NV_UNIQUE_NAME, 0) != 0) {
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock nvlist_free(nvroot);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock return;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock }
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock if (nvlist_add_string(newvd, ZPOOL_CONFIG_TYPE, VDEV_TYPE_DISK) != 0 ||
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock nvlist_add_string(newvd, ZPOOL_CONFIG_PATH, path) != 0 ||
bf82a41b568b2bd31bf9814587eb25ee2e7b05ffeschrock (physpath != NULL && nvlist_add_string(newvd,
bf82a41b568b2bd31bf9814587eb25ee2e7b05ffeschrock ZPOOL_CONFIG_PHYS_PATH, physpath) != 0) ||
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock nvlist_add_uint64(newvd, ZPOOL_CONFIG_WHOLE_DISK, wholedisk) != 0 ||
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock nvlist_add_string(nvroot, ZPOOL_CONFIG_TYPE, VDEV_TYPE_ROOT) != 0 ||
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock nvlist_add_nvlist_array(nvroot, ZPOOL_CONFIG_CHILDREN, &newvd,
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock 1) != 0) {
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock nvlist_free(newvd);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock nvlist_free(nvroot);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock return;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock }
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock nvlist_free(newvd);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock (void) zpool_vdev_attach(zhp, fullpath, path, nvroot, B_TRUE);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock nvlist_free(nvroot);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock}
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock/*
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * Utility functions to find a vdev matching given criteria.
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock */
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrocktypedef struct dev_data {
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock const char *dd_compare;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock const char *dd_prop;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock zfs_process_func_t dd_func;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock boolean_t dd_found;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock boolean_t dd_isdisk;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock uint64_t dd_pool_guid;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock uint64_t dd_vdev_guid;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock} dev_data_t;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrockstatic void
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrockzfs_iter_vdev(zpool_handle_t *zhp, nvlist_t *nvl, void *data)
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock{
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock dev_data_t *dp = data;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock char *path;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock uint_t c, children;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock nvlist_t **child;
b01c3b58f7eb7fb570f606f96f130fb9b2018b49eschrock size_t len;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock uint64_t guid;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock /*
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * First iterate over any children.
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock */
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock if (nvlist_lookup_nvlist_array(nvl, ZPOOL_CONFIG_CHILDREN,
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock &child, &children) == 0) {
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock for (c = 0; c < children; c++)
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock zfs_iter_vdev(zhp, child[c], data);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock return;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock }
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock if (dp->dd_vdev_guid != 0) {
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock if (nvlist_lookup_uint64(nvl, ZPOOL_CONFIG_GUID,
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock &guid) != 0 || guid != dp->dd_vdev_guid)
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock return;
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld } else if (dp->dd_compare != NULL) {
b01c3b58f7eb7fb570f606f96f130fb9b2018b49eschrock len = strlen(dp->dd_compare);
b01c3b58f7eb7fb570f606f96f130fb9b2018b49eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock if (nvlist_lookup_string(nvl, dp->dd_prop, &path) != 0 ||
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock strncmp(dp->dd_compare, path, len) != 0)
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock return;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock /*
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * Normally, we want to have an exact match for the comparison
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * string. However, we allow substring matches in the following
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * cases:
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock *
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * <path>: This is a devpath, and the target is one
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * of its children.
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock *
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * <path/> This is a devid for a whole disk, and
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * the target is one of its children.
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock */
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock if (path[len] != '\0' && path[len] != ':' &&
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock path[len - 1] != '/')
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock return;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock }
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock (dp->dd_func)(zhp, nvl, dp->dd_isdisk);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock}
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylorvoid
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylorzfs_enable_ds(void *arg)
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor{
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor unavailpool_t *pool = (unavailpool_t *)arg;
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor (void) zpool_enable_datasets(pool->uap_zhp, NULL, 0);
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor zpool_close(pool->uap_zhp);
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor free(pool);
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor}
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrockstatic int
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrockzfs_iter_pool(zpool_handle_t *zhp, void *data)
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock{
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock nvlist_t *config, *nvl;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock dev_data_t *dp = data;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock uint64_t pool_guid;
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor unavailpool_t *pool;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock if ((config = zpool_get_config(zhp, NULL)) != NULL) {
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock if (dp->dd_pool_guid == 0 ||
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock (nvlist_lookup_uint64(config, ZPOOL_CONFIG_POOL_GUID,
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock &pool_guid) == 0 && pool_guid == dp->dd_pool_guid)) {
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock (void) nvlist_lookup_nvlist(config,
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock ZPOOL_CONFIG_VDEV_TREE, &nvl);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock zfs_iter_vdev(zhp, nvl, data);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock }
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock }
37e3a0d8ec40beeef3861086ca78f757dd47eabdEric Taylor if (g_enumeration_done) {
37e3a0d8ec40beeef3861086ca78f757dd47eabdEric Taylor for (pool = list_head(&g_pool_list); pool != NULL;
37e3a0d8ec40beeef3861086ca78f757dd47eabdEric Taylor pool = list_next(&g_pool_list, pool)) {
37e3a0d8ec40beeef3861086ca78f757dd47eabdEric Taylor
37e3a0d8ec40beeef3861086ca78f757dd47eabdEric Taylor if (strcmp(zpool_get_name(zhp),
37e3a0d8ec40beeef3861086ca78f757dd47eabdEric Taylor zpool_get_name(pool->uap_zhp)))
37e3a0d8ec40beeef3861086ca78f757dd47eabdEric Taylor continue;
37e3a0d8ec40beeef3861086ca78f757dd47eabdEric Taylor if (zfs_toplevel_state(zhp) >= VDEV_STATE_DEGRADED) {
37e3a0d8ec40beeef3861086ca78f757dd47eabdEric Taylor list_remove(&g_pool_list, pool);
37e3a0d8ec40beeef3861086ca78f757dd47eabdEric Taylor (void) tpool_dispatch(g_tpool, zfs_enable_ds,
37e3a0d8ec40beeef3861086ca78f757dd47eabdEric Taylor pool);
37e3a0d8ec40beeef3861086ca78f757dd47eabdEric Taylor break;
37e3a0d8ec40beeef3861086ca78f757dd47eabdEric Taylor }
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor }
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor }
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock zpool_close(zhp);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock return (0);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock}
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock/*
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * Given a physical device path, iterate over all (pool, vdev) pairs which
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * correspond to the given path.
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock */
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrockstatic boolean_t
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrockdevpath_iter(const char *devpath, zfs_process_func_t func, boolean_t wholedisk)
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock{
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock dev_data_t data = { 0 };
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock data.dd_compare = devpath;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock data.dd_func = func;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock data.dd_prop = ZPOOL_CONFIG_PHYS_PATH;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock data.dd_found = B_FALSE;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock data.dd_isdisk = wholedisk;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock (void) zpool_iter(g_zfshdl, zfs_iter_pool, &data);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock return (data.dd_found);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock}
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock/*
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * Given a /devices path, lookup the corresponding devid for each minor node,
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * and find any vdevs with matching devids. Doing this straight up would be
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * rather inefficient, O(minor nodes * vdevs in system), so we take advantage of
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * the fact that each devid ends with "/<minornode>". Once we find any valid
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * minor node, we chop off the portion after the last slash, and then search for
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * matching vdevs, which is O(vdevs in system).
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock */
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrockstatic boolean_t
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrockdevid_iter(const char *devpath, zfs_process_func_t func, boolean_t wholedisk)
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock{
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock size_t len = strlen(devpath) + sizeof ("/devices") +
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock sizeof (PHYS_PATH) - 1;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock char *fullpath;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock int fd;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock ddi_devid_t devid;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock char *devidstr, *fulldevid;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock dev_data_t data = { 0 };
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock /*
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * Try to open a known minor node.
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock */
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock fullpath = alloca(len);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock (void) snprintf(fullpath, len, "/devices%s%s", devpath, PHYS_PATH);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock if ((fd = open(fullpath, O_RDONLY)) < 0)
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock return (B_FALSE);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock /*
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * Determine the devid as a string, with no trailing slash for the minor
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * node.
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock */
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock if (devid_get(fd, &devid) != 0) {
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock (void) close(fd);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock return (B_FALSE);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock }
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock (void) close(fd);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock if ((devidstr = devid_str_encode(devid, NULL)) == NULL) {
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock devid_free(devid);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock return (B_FALSE);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock }
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock len = strlen(devidstr) + 2;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock fulldevid = alloca(len);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock (void) snprintf(fulldevid, len, "%s/", devidstr);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock data.dd_compare = fulldevid;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock data.dd_func = func;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock data.dd_prop = ZPOOL_CONFIG_DEVID;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock data.dd_found = B_FALSE;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock data.dd_isdisk = wholedisk;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock (void) zpool_iter(g_zfshdl, zfs_iter_pool, &data);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock devid_str_free(devidstr);
25085d90140a7be7bb8524085d401fac7ca23cfbEric Taylor devid_free(devid);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock return (data.dd_found);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock}
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock/*
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * This function is called when we receive a devfs add event. This can be
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * either a disk event or a lofi event, and the behavior is slightly different
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * depending on which it is.
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock */
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrockstatic int
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrockzfs_deliver_add(nvlist_t *nvl, boolean_t is_lofi)
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock{
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock char *devpath, *devname;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock char path[PATH_MAX], realpath[PATH_MAX];
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock char *colon, *raw;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock int ret;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock /*
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * The main unit of operation is the physical device path. For disks,
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * this is the device node, as all minor nodes are affected. For lofi
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * devices, this includes the minor path. Unfortunately, this isn't
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * represented in the DEV_PHYS_PATH for various reasons.
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock */
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock if (nvlist_lookup_string(nvl, DEV_PHYS_PATH, &devpath) != 0)
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock return (-1);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock /*
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * If this is a lofi device, then also get the minor instance name.
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * Unfortunately, the current payload doesn't include an easy way to get
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * this information. So we cheat by resolving the 'dev_name' (which
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * refers to the raw device) and taking the portion between ':(*),raw'.
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock */
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock (void) strlcpy(realpath, devpath, sizeof (realpath));
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock if (is_lofi) {
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock if (nvlist_lookup_string(nvl, DEV_NAME,
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock &devname) == 0 &&
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock (ret = resolvepath(devname, path,
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock sizeof (path))) > 0) {
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock path[ret] = '\0';
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock colon = strchr(path, ':');
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock if (colon != NULL)
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock raw = strstr(colon + 1, ",raw");
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock if (colon != NULL && raw != NULL) {
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock *raw = '\0';
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock (void) snprintf(realpath,
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock sizeof (realpath), "%s%s",
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock devpath, colon);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock *raw = ',';
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock }
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock }
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock }
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock /*
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * Iterate over all vdevs with a matching devid, and then those with a
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * matching /devices path. For disks, we only want to pay attention to
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * vdevs marked as whole disks. For lofi, we don't care (because we're
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * matching an exact minor name).
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock */
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock if (!devid_iter(realpath, zfs_process_add, !is_lofi))
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock (void) devpath_iter(realpath, zfs_process_add, !is_lofi);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock return (0);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock}
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock/*
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * Called when we receive a VDEV_CHECK event, which indicates a device could not
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * be opened during initial pool open, but the autoreplace property was set on
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * the pool. In this case, we treat it as if it were an add event.
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock */
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrockstatic int
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrockzfs_deliver_check(nvlist_t *nvl)
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock{
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock dev_data_t data = { 0 };
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock if (nvlist_lookup_uint64(nvl, ZFS_EV_POOL_GUID,
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock &data.dd_pool_guid) != 0 ||
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock nvlist_lookup_uint64(nvl, ZFS_EV_VDEV_GUID,
efb4a871d8fd510a833bdca610528dde5ed69e42Yuri Pankov &data.dd_vdev_guid) != 0 ||
efb4a871d8fd510a833bdca610528dde5ed69e42Yuri Pankov data.dd_vdev_guid == 0)
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock return (0);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock data.dd_isdisk = B_TRUE;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock data.dd_func = zfs_process_add;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock (void) zpool_iter(g_zfshdl, zfs_iter_pool, &data);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock return (0);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock}
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor#define DEVICE_PREFIX "/devices"
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylorstatic int
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylorzfsdle_vdev_online(zpool_handle_t *zhp, void *data)
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor{
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor char *devname = data;
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor boolean_t avail_spare, l2cache;
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor vdev_state_t newstate;
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor nvlist_t *tgt;
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor syseventd_print(9, "zfsdle_vdev_online: searching for %s in pool %s\n",
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor devname, zpool_get_name(zhp));
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor if ((tgt = zpool_find_vdev_by_physpath(zhp, devname,
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor &avail_spare, &l2cache, NULL)) != NULL) {
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor char *path, fullpath[MAXPATHLEN];
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor uint64_t wholedisk = 0ULL;
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor verify(nvlist_lookup_string(tgt, ZPOOL_CONFIG_PATH,
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor &path) == 0);
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor verify(nvlist_lookup_uint64(tgt, ZPOOL_CONFIG_WHOLE_DISK,
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor &wholedisk) == 0);
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor (void) strlcpy(fullpath, path, sizeof (fullpath));
4263d13f00c9691fa14620eff82abef795be0693George Wilson if (wholedisk) {
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor fullpath[strlen(fullpath) - 2] = '\0';
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor
4263d13f00c9691fa14620eff82abef795be0693George Wilson /*
4263d13f00c9691fa14620eff82abef795be0693George Wilson * We need to reopen the pool associated with this
4263d13f00c9691fa14620eff82abef795be0693George Wilson * device so that the kernel can update the size
4263d13f00c9691fa14620eff82abef795be0693George Wilson * of the expanded device.
4263d13f00c9691fa14620eff82abef795be0693George Wilson */
4263d13f00c9691fa14620eff82abef795be0693George Wilson (void) zpool_reopen(zhp);
4263d13f00c9691fa14620eff82abef795be0693George Wilson }
4263d13f00c9691fa14620eff82abef795be0693George Wilson
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor if (zpool_get_prop_int(zhp, ZPOOL_PROP_AUTOEXPAND, NULL)) {
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor syseventd_print(9, "zfsdle_vdev_online: setting device"
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor " device %s to ONLINE state in pool %s.\n",
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor fullpath, zpool_get_name(zhp));
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor if (zpool_get_state(zhp) != POOL_STATE_UNAVAIL)
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor (void) zpool_vdev_online(zhp, fullpath, 0,
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor &newstate);
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor }
25085d90140a7be7bb8524085d401fac7ca23cfbEric Taylor zpool_close(zhp);
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor return (1);
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor }
25085d90140a7be7bb8524085d401fac7ca23cfbEric Taylor zpool_close(zhp);
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor return (0);
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor}
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld/*
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld * This function is called for each vdev of a pool for which any of the
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld * following events was recieved:
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld * - ESC_ZFS_vdev_add
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld * - ESC_ZFS_vdev_attach
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld * - ESC_ZFS_vdev_clear
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld * - ESC_ZFS_vdev_online
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld * - ESC_ZFS_pool_create
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld * - ESC_ZFS_pool_import
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld * It will update the vdevs FRU property if it is out of date.
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld */
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld/*ARGSUSED2*/
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeldstatic void
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeldzfs_update_vdev_fru(zpool_handle_t *zhp, nvlist_t *vdev, boolean_t isdisk)
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld{
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld char *devpath, *cptr, *oldfru = NULL;
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld const char *newfru;
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld uint64_t vdev_guid;
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld (void) nvlist_lookup_uint64(vdev, ZPOOL_CONFIG_GUID, &vdev_guid);
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld (void) nvlist_lookup_string(vdev, ZPOOL_CONFIG_PHYS_PATH, &devpath);
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld (void) nvlist_lookup_string(vdev, ZPOOL_CONFIG_FRU, &oldfru);
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld /* remove :<slice> from devpath */
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld cptr = strrchr(devpath, ':');
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld if (cptr != NULL)
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld *cptr = '\0';
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld newfru = libzfs_fru_lookup(g_zfshdl, devpath);
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld if (newfru == NULL) {
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld syseventd_print(9, "zfs_update_vdev_fru: no FRU for %s\n",
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld devpath);
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld return;
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld }
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld /* do nothing if the FRU hasn't changed */
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld if (oldfru != NULL && libzfs_fru_compare(g_zfshdl, oldfru, newfru)) {
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld syseventd_print(9, "zfs_update_vdev_fru: FRU unchanged\n");
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld return;
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld }
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld syseventd_print(9, "zfs_update_vdev_fru: devpath = %s\n", devpath);
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld syseventd_print(9, "zfs_update_vdev_fru: FRU = %s\n", newfru);
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld (void) zpool_fru_set(zhp, vdev_guid, newfru);
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld}
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld/*
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld * This function handles the following events:
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld * - ESC_ZFS_vdev_add
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld * - ESC_ZFS_vdev_attach
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld * - ESC_ZFS_vdev_clear
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld * - ESC_ZFS_vdev_online
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld * - ESC_ZFS_pool_create
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld * - ESC_ZFS_pool_import
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld * It will iterate over the pool vdevs to update the FRU property.
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld */
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeldint
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeldzfs_deliver_update(nvlist_t *nvl)
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld{
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld dev_data_t dd = { 0 };
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld char *pname;
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld zpool_handle_t *zhp;
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld nvlist_t *config, *vdev;
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld if (nvlist_lookup_string(nvl, "pool_name", &pname) != 0) {
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld syseventd_print(9, "zfs_deliver_update: no pool name\n");
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld return (-1);
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld }
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld /*
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld * If this event was triggered by a pool export or destroy we cannot
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld * open the pool. This is not an error, just return 0 as we don't care
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld * about these events.
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld */
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld zhp = zpool_open_canfail(g_zfshdl, pname);
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld if (zhp == NULL)
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld return (0);
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld config = zpool_get_config(zhp, NULL);
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld if (config == NULL) {
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld syseventd_print(9, "zfs_deliver_update: "
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld "failed to get pool config for %s\n", pname);
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld zpool_close(zhp);
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld return (-1);
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld }
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld if (nvlist_lookup_nvlist(config, ZPOOL_CONFIG_VDEV_TREE, &vdev) != 0) {
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld syseventd_print(0, "zfs_deliver_update: "
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld "failed to get vdev tree for %s\n", pname);
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld zpool_close(zhp);
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld return (-1);
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld }
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld libzfs_fru_refresh(g_zfshdl);
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld dd.dd_func = zfs_update_vdev_fru;
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld zfs_iter_vdev(zhp, vdev, &dd);
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld zpool_close(zhp);
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld return (0);
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld}
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylorint
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylorzfs_deliver_dle(nvlist_t *nvl)
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor{
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor char *devname;
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor if (nvlist_lookup_string(nvl, DEV_PHYS_PATH, &devname) != 0) {
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor syseventd_print(9, "zfs_deliver_event: no physpath\n");
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor return (-1);
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor }
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor if (strncmp(devname, DEVICE_PREFIX, strlen(DEVICE_PREFIX)) != 0) {
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor syseventd_print(9, "zfs_deliver_event: invalid "
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor "device '%s'", devname);
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor return (-1);
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor }
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor /*
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor * We try to find the device using the physical
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor * path that has been supplied. We need to strip off
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor * the /devices prefix before starting our search.
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor */
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor devname += strlen(DEVICE_PREFIX);
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor if (zpool_iter(g_zfshdl, zfsdle_vdev_online, devname) != 1) {
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor syseventd_print(9, "zfs_deliver_event: device '%s' not"
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor " found\n", devname);
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor return (1);
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor }
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor return (0);
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor}
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock/*ARGSUSED*/
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrockstatic int
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrockzfs_deliver_event(sysevent_t *ev, int unused)
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock{
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock const char *class = sysevent_get_class_name(ev);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock const char *subclass = sysevent_get_subclass_name(ev);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock nvlist_t *nvl;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock int ret;
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld boolean_t is_lofi = B_FALSE, is_check = B_FALSE;
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld boolean_t is_dle = B_FALSE, is_update = B_FALSE;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock if (strcmp(class, EC_DEV_ADD) == 0) {
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock /*
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * We're mainly interested in disk additions, but we also listen
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock * for new lofi devices, to allow for simplified testing.
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock */
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock if (strcmp(subclass, ESC_DISK) == 0)
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock is_lofi = B_FALSE;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock else if (strcmp(subclass, ESC_LOFI) == 0)
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock is_lofi = B_TRUE;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock else
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock return (0);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock is_check = B_FALSE;
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld } else if (strcmp(class, EC_ZFS) == 0) {
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld if (strcmp(subclass, ESC_ZFS_VDEV_CHECK) == 0) {
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld /*
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld * This event signifies that a device failed to open
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld * during pool load, but the 'autoreplace' property was
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld * set, so we should pretend it's just been added.
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld */
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld is_check = B_TRUE;
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld } else if ((strcmp(subclass, ESC_ZFS_VDEV_ADD) == 0) ||
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld (strcmp(subclass, ESC_ZFS_VDEV_ATTACH) == 0) ||
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld (strcmp(subclass, ESC_ZFS_VDEV_CLEAR) == 0) ||
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld (strcmp(subclass, ESC_ZFS_VDEV_ONLINE) == 0) ||
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld (strcmp(subclass, ESC_ZFS_POOL_CREATE) == 0) ||
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld (strcmp(subclass, ESC_ZFS_POOL_IMPORT) == 0)) {
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld /*
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld * When we receive these events we check the pool
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld * configuration and update the vdev FRUs if necessary.
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld */
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld is_update = B_TRUE;
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld }
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor } else if (strcmp(class, EC_DEV_STATUS) == 0 &&
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor strcmp(subclass, ESC_DEV_DLE) == 0) {
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor is_dle = B_TRUE;
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock } else {
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock return (0);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock }
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock if (sysevent_get_attr_list(ev, &nvl) != 0)
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock return (-1);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor if (is_dle)
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor ret = zfs_deliver_dle(nvl);
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld else if (is_update)
1437283407f89cab03860accf49408f94559bc34Hans Rosenfeld ret = zfs_deliver_update(nvl);
b98131cff90a91303826565dacf89c46a422e6c5Eric Taylor else if (is_check)
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock ret = zfs_deliver_check(nvl);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock else
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock ret = zfs_deliver_add(nvl, is_lofi);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock nvlist_free(nvl);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock return (ret);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock}
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
37e3a0d8ec40beeef3861086ca78f757dd47eabdEric Taylor/*ARGSUSED*/
37e3a0d8ec40beeef3861086ca78f757dd47eabdEric Taylorvoid *
37e3a0d8ec40beeef3861086ca78f757dd47eabdEric Taylorzfs_enum_pools(void *arg)
37e3a0d8ec40beeef3861086ca78f757dd47eabdEric Taylor{
37e3a0d8ec40beeef3861086ca78f757dd47eabdEric Taylor (void) zpool_iter(g_zfshdl, zfs_unavail_pool, (void *)&g_pool_list);
37e3a0d8ec40beeef3861086ca78f757dd47eabdEric Taylor if (!list_is_empty(&g_pool_list))
37e3a0d8ec40beeef3861086ca78f757dd47eabdEric Taylor g_tpool = tpool_create(1, sysconf(_SC_NPROCESSORS_ONLN),
37e3a0d8ec40beeef3861086ca78f757dd47eabdEric Taylor 0, NULL);
37e3a0d8ec40beeef3861086ca78f757dd47eabdEric Taylor g_enumeration_done = B_TRUE;
37e3a0d8ec40beeef3861086ca78f757dd47eabdEric Taylor return (NULL);
37e3a0d8ec40beeef3861086ca78f757dd47eabdEric Taylor}
37e3a0d8ec40beeef3861086ca78f757dd47eabdEric Taylor
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrockstatic struct slm_mod_ops zfs_mod_ops = {
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock SE_MAJOR_VERSION, SE_MINOR_VERSION, 10, zfs_deliver_event
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock};
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrockstruct slm_mod_ops *
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrockslm_init()
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock{
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock if ((g_zfshdl = libzfs_init()) == NULL)
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock return (NULL);
37e3a0d8ec40beeef3861086ca78f757dd47eabdEric Taylor /*
37e3a0d8ec40beeef3861086ca78f757dd47eabdEric Taylor * collect a list of unavailable pools (asynchronously,
37e3a0d8ec40beeef3861086ca78f757dd47eabdEric Taylor * since this can take a while)
37e3a0d8ec40beeef3861086ca78f757dd47eabdEric Taylor */
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor list_create(&g_pool_list, sizeof (struct unavailpool),
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor offsetof(struct unavailpool, uap_node));
37e3a0d8ec40beeef3861086ca78f757dd47eabdEric Taylor if (thr_create(NULL, 0, zfs_enum_pools, NULL, 0, &g_zfs_tid) != 0)
37e3a0d8ec40beeef3861086ca78f757dd47eabdEric Taylor return (NULL);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock return (&zfs_mod_ops);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock}
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrockvoid
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrockslm_fini()
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock{
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor unavailpool_t *pool;
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor
37e3a0d8ec40beeef3861086ca78f757dd47eabdEric Taylor if (g_tpool != NULL) {
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor tpool_wait(g_tpool);
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor tpool_destroy(g_tpool);
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor }
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor while ((pool = (list_head(&g_pool_list))) != NULL) {
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor list_remove(&g_pool_list, pool);
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor zpool_close(pool->uap_zhp);
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor free(pool);
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor }
37e3a0d8ec40beeef3861086ca78f757dd47eabdEric Taylor (void) thr_join(g_zfs_tid, NULL, NULL);
3c112a2b34403220c06c3e2fcac403358cfba168Eric Taylor list_destroy(&g_pool_list);
25085d90140a7be7bb8524085d401fac7ca23cfbEric Taylor libzfs_fini(g_zfshdl);
3d7072f8bd27709dba14f6fe336f149d25d9e207eschrock}