1 /*
2  * CDDL HEADER START
3  *
4  * The contents of this file are subject to the terms of the
5  * Common Development and Distribution License (the "License").
6  * You may not use this file except in compliance with the License.
7  *
8  * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
9  * or https://opensource.org/licenses/CDDL-1.0.
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 /*
23  * Copyright 2015 Nexenta Systems, Inc.  All rights reserved.
24  * Copyright (c) 2005, 2010, Oracle and/or its affiliates. All rights reserved.
25  * Copyright (c) 2011, 2024 by Delphix. All rights reserved.
26  * Copyright 2016 Igor Kozhukhov <[email protected]>
27  * Copyright (c) 2018 Datto Inc.
28  * Copyright (c) 2017 Open-E, Inc. All Rights Reserved.
29  * Copyright (c) 2017, Intel Corporation.
30  * Copyright (c) 2018, loli10K <[email protected]>
31  * Copyright (c) 2021, Colm Buckley <[email protected]>
32  * Copyright (c) 2021, 2023, Klara Inc.
33  */
34 
35 #include <errno.h>
36 #include <libintl.h>
37 #include <stdio.h>
38 #include <stdlib.h>
39 #include <strings.h>
40 #include <unistd.h>
41 #include <libgen.h>
42 #include <zone.h>
43 #include <sys/stat.h>
44 #include <sys/efi_partition.h>
45 #include <sys/systeminfo.h>
46 #include <sys/zfs_ioctl.h>
47 #include <sys/zfs_sysfs.h>
48 #include <sys/vdev_disk.h>
49 #include <sys/types.h>
50 #include <dlfcn.h>
51 #include <libzutil.h>
52 #include <fcntl.h>
53 
54 #include "zfs_namecheck.h"
55 #include "zfs_prop.h"
56 #include "libzfs_impl.h"
57 #include "zfs_comutil.h"
58 #include "zfeature_common.h"
59 
60 static boolean_t zpool_vdev_is_interior(const char *name);
61 
62 typedef struct prop_flags {
63 	unsigned int create:1;	/* Validate property on creation */
64 	unsigned int import:1;	/* Validate property on import */
65 	unsigned int vdevprop:1; /* Validate property as a VDEV property */
66 } prop_flags_t;
67 
68 /*
69  * ====================================================================
70  *   zpool property functions
71  * ====================================================================
72  */
73 
74 static int
zpool_get_all_props(zpool_handle_t * zhp)75 zpool_get_all_props(zpool_handle_t *zhp)
76 {
77 	zfs_cmd_t zc = {"\0"};
78 	libzfs_handle_t *hdl = zhp->zpool_hdl;
79 
80 	(void) strlcpy(zc.zc_name, zhp->zpool_name, sizeof (zc.zc_name));
81 
82 	zcmd_alloc_dst_nvlist(hdl, &zc, 0);
83 
84 	while (zfs_ioctl(hdl, ZFS_IOC_POOL_GET_PROPS, &zc) != 0) {
85 		if (errno == ENOMEM)
86 			zcmd_expand_dst_nvlist(hdl, &zc);
87 		else {
88 			zcmd_free_nvlists(&zc);
89 			return (-1);
90 		}
91 	}
92 
93 	if (zcmd_read_dst_nvlist(hdl, &zc, &zhp->zpool_props) != 0) {
94 		zcmd_free_nvlists(&zc);
95 		return (-1);
96 	}
97 
98 	zcmd_free_nvlists(&zc);
99 
100 	return (0);
101 }
102 
103 int
zpool_props_refresh(zpool_handle_t * zhp)104 zpool_props_refresh(zpool_handle_t *zhp)
105 {
106 	nvlist_t *old_props;
107 
108 	old_props = zhp->zpool_props;
109 
110 	if (zpool_get_all_props(zhp) != 0)
111 		return (-1);
112 
113 	nvlist_free(old_props);
114 	return (0);
115 }
116 
117 static const char *
zpool_get_prop_string(zpool_handle_t * zhp,zpool_prop_t prop,zprop_source_t * src)118 zpool_get_prop_string(zpool_handle_t *zhp, zpool_prop_t prop,
119     zprop_source_t *src)
120 {
121 	nvlist_t *nv, *nvl;
122 	const char *value;
123 	zprop_source_t source;
124 
125 	nvl = zhp->zpool_props;
126 	if (nvlist_lookup_nvlist(nvl, zpool_prop_to_name(prop), &nv) == 0) {
127 		source = fnvlist_lookup_uint64(nv, ZPROP_SOURCE);
128 		value = fnvlist_lookup_string(nv, ZPROP_VALUE);
129 	} else {
130 		source = ZPROP_SRC_DEFAULT;
131 		if ((value = zpool_prop_default_string(prop)) == NULL)
132 			value = "-";
133 	}
134 
135 	if (src)
136 		*src = source;
137 
138 	return (value);
139 }
140 
141 uint64_t
zpool_get_prop_int(zpool_handle_t * zhp,zpool_prop_t prop,zprop_source_t * src)142 zpool_get_prop_int(zpool_handle_t *zhp, zpool_prop_t prop, zprop_source_t *src)
143 {
144 	nvlist_t *nv, *nvl;
145 	uint64_t value;
146 	zprop_source_t source;
147 
148 	if (zhp->zpool_props == NULL && zpool_get_all_props(zhp)) {
149 		/*
150 		 * zpool_get_all_props() has most likely failed because
151 		 * the pool is faulted, but if all we need is the top level
152 		 * vdev's guid then get it from the zhp config nvlist.
153 		 */
154 		if ((prop == ZPOOL_PROP_GUID) &&
155 		    (nvlist_lookup_nvlist(zhp->zpool_config,
156 		    ZPOOL_CONFIG_VDEV_TREE, &nv) == 0) &&
157 		    (nvlist_lookup_uint64(nv, ZPOOL_CONFIG_GUID, &value)
158 		    == 0)) {
159 			return (value);
160 		}
161 		return (zpool_prop_default_numeric(prop));
162 	}
163 
164 	nvl = zhp->zpool_props;
165 	if (nvlist_lookup_nvlist(nvl, zpool_prop_to_name(prop), &nv) == 0) {
166 		source = fnvlist_lookup_uint64(nv, ZPROP_SOURCE);
167 		value = fnvlist_lookup_uint64(nv, ZPROP_VALUE);
168 	} else {
169 		source = ZPROP_SRC_DEFAULT;
170 		value = zpool_prop_default_numeric(prop);
171 	}
172 
173 	if (src)
174 		*src = source;
175 
176 	return (value);
177 }
178 
179 /*
180  * Map VDEV STATE to printed strings.
181  */
182 const char *
zpool_state_to_name(vdev_state_t state,vdev_aux_t aux)183 zpool_state_to_name(vdev_state_t state, vdev_aux_t aux)
184 {
185 	switch (state) {
186 	case VDEV_STATE_CLOSED:
187 	case VDEV_STATE_OFFLINE:
188 		return (gettext("OFFLINE"));
189 	case VDEV_STATE_REMOVED:
190 		return (gettext("REMOVED"));
191 	case VDEV_STATE_CANT_OPEN:
192 		if (aux == VDEV_AUX_CORRUPT_DATA || aux == VDEV_AUX_BAD_LOG)
193 			return (gettext("FAULTED"));
194 		else if (aux == VDEV_AUX_SPLIT_POOL)
195 			return (gettext("SPLIT"));
196 		else
197 			return (gettext("UNAVAIL"));
198 	case VDEV_STATE_FAULTED:
199 		return (gettext("FAULTED"));
200 	case VDEV_STATE_DEGRADED:
201 		return (gettext("DEGRADED"));
202 	case VDEV_STATE_HEALTHY:
203 		return (gettext("ONLINE"));
204 
205 	default:
206 		break;
207 	}
208 
209 	return (gettext("UNKNOWN"));
210 }
211 
212 /*
213  * Map POOL STATE to printed strings.
214  */
215 const char *
zpool_pool_state_to_name(pool_state_t state)216 zpool_pool_state_to_name(pool_state_t state)
217 {
218 	switch (state) {
219 	default:
220 		break;
221 	case POOL_STATE_ACTIVE:
222 		return (gettext("ACTIVE"));
223 	case POOL_STATE_EXPORTED:
224 		return (gettext("EXPORTED"));
225 	case POOL_STATE_DESTROYED:
226 		return (gettext("DESTROYED"));
227 	case POOL_STATE_SPARE:
228 		return (gettext("SPARE"));
229 	case POOL_STATE_L2CACHE:
230 		return (gettext("L2CACHE"));
231 	case POOL_STATE_UNINITIALIZED:
232 		return (gettext("UNINITIALIZED"));
233 	case POOL_STATE_UNAVAIL:
234 		return (gettext("UNAVAIL"));
235 	case POOL_STATE_POTENTIALLY_ACTIVE:
236 		return (gettext("POTENTIALLY_ACTIVE"));
237 	}
238 
239 	return (gettext("UNKNOWN"));
240 }
241 
242 /*
243  * Given a pool handle, return the pool health string ("ONLINE", "DEGRADED",
244  * "SUSPENDED", etc).
245  */
246 const char *
zpool_get_state_str(zpool_handle_t * zhp)247 zpool_get_state_str(zpool_handle_t *zhp)
248 {
249 	zpool_errata_t errata;
250 	zpool_status_t status;
251 	const char *str;
252 
253 	status = zpool_get_status(zhp, NULL, &errata);
254 
255 	if (zpool_get_state(zhp) == POOL_STATE_UNAVAIL) {
256 		str = gettext("FAULTED");
257 	} else if (status == ZPOOL_STATUS_IO_FAILURE_WAIT ||
258 	    status == ZPOOL_STATUS_IO_FAILURE_CONTINUE ||
259 	    status == ZPOOL_STATUS_IO_FAILURE_MMP) {
260 		str = gettext("SUSPENDED");
261 	} else {
262 		nvlist_t *nvroot = fnvlist_lookup_nvlist(
263 		    zpool_get_config(zhp, NULL), ZPOOL_CONFIG_VDEV_TREE);
264 		uint_t vsc;
265 		vdev_stat_t *vs = (vdev_stat_t *)fnvlist_lookup_uint64_array(
266 		    nvroot, ZPOOL_CONFIG_VDEV_STATS, &vsc);
267 		str = zpool_state_to_name(vs->vs_state, vs->vs_aux);
268 	}
269 	return (str);
270 }
271 
272 /*
273  * Get a zpool property value for 'prop' and return the value in
274  * a pre-allocated buffer.
275  */
276 int
zpool_get_prop(zpool_handle_t * zhp,zpool_prop_t prop,char * buf,size_t len,zprop_source_t * srctype,boolean_t literal)277 zpool_get_prop(zpool_handle_t *zhp, zpool_prop_t prop, char *buf,
278     size_t len, zprop_source_t *srctype, boolean_t literal)
279 {
280 	uint64_t intval;
281 	const char *strval;
282 	zprop_source_t src = ZPROP_SRC_NONE;
283 
284 	if (zpool_get_state(zhp) == POOL_STATE_UNAVAIL) {
285 		switch (prop) {
286 		case ZPOOL_PROP_NAME:
287 			(void) strlcpy(buf, zpool_get_name(zhp), len);
288 			break;
289 
290 		case ZPOOL_PROP_HEALTH:
291 			(void) strlcpy(buf, zpool_get_state_str(zhp), len);
292 			break;
293 
294 		case ZPOOL_PROP_GUID:
295 			intval = zpool_get_prop_int(zhp, prop, &src);
296 			(void) snprintf(buf, len, "%llu", (u_longlong_t)intval);
297 			break;
298 
299 		case ZPOOL_PROP_ALTROOT:
300 		case ZPOOL_PROP_CACHEFILE:
301 		case ZPOOL_PROP_COMMENT:
302 		case ZPOOL_PROP_COMPATIBILITY:
303 			if (zhp->zpool_props != NULL ||
304 			    zpool_get_all_props(zhp) == 0) {
305 				(void) strlcpy(buf,
306 				    zpool_get_prop_string(zhp, prop, &src),
307 				    len);
308 				break;
309 			}
310 			zfs_fallthrough;
311 		default:
312 			(void) strlcpy(buf, "-", len);
313 			break;
314 		}
315 
316 		if (srctype != NULL)
317 			*srctype = src;
318 		return (0);
319 	}
320 
321 	if (zhp->zpool_props == NULL && zpool_get_all_props(zhp) &&
322 	    prop != ZPOOL_PROP_NAME)
323 		return (-1);
324 
325 	switch (zpool_prop_get_type(prop)) {
326 	case PROP_TYPE_STRING:
327 		(void) strlcpy(buf, zpool_get_prop_string(zhp, prop, &src),
328 		    len);
329 		break;
330 
331 	case PROP_TYPE_NUMBER:
332 		intval = zpool_get_prop_int(zhp, prop, &src);
333 
334 		switch (prop) {
335 		case ZPOOL_PROP_SIZE:
336 		case ZPOOL_PROP_ALLOCATED:
337 		case ZPOOL_PROP_FREE:
338 		case ZPOOL_PROP_FREEING:
339 		case ZPOOL_PROP_LEAKED:
340 		case ZPOOL_PROP_ASHIFT:
341 		case ZPOOL_PROP_MAXBLOCKSIZE:
342 		case ZPOOL_PROP_MAXDNODESIZE:
343 		case ZPOOL_PROP_BCLONESAVED:
344 		case ZPOOL_PROP_BCLONEUSED:
345 			if (literal)
346 				(void) snprintf(buf, len, "%llu",
347 				    (u_longlong_t)intval);
348 			else
349 				(void) zfs_nicenum(intval, buf, len);
350 			break;
351 
352 		case ZPOOL_PROP_EXPANDSZ:
353 		case ZPOOL_PROP_CHECKPOINT:
354 			if (intval == 0) {
355 				(void) strlcpy(buf, "-", len);
356 			} else if (literal) {
357 				(void) snprintf(buf, len, "%llu",
358 				    (u_longlong_t)intval);
359 			} else {
360 				(void) zfs_nicebytes(intval, buf, len);
361 			}
362 			break;
363 
364 		case ZPOOL_PROP_CAPACITY:
365 			if (literal) {
366 				(void) snprintf(buf, len, "%llu",
367 				    (u_longlong_t)intval);
368 			} else {
369 				(void) snprintf(buf, len, "%llu%%",
370 				    (u_longlong_t)intval);
371 			}
372 			break;
373 
374 		case ZPOOL_PROP_FRAGMENTATION:
375 			if (intval == UINT64_MAX) {
376 				(void) strlcpy(buf, "-", len);
377 			} else if (literal) {
378 				(void) snprintf(buf, len, "%llu",
379 				    (u_longlong_t)intval);
380 			} else {
381 				(void) snprintf(buf, len, "%llu%%",
382 				    (u_longlong_t)intval);
383 			}
384 			break;
385 
386 		case ZPOOL_PROP_BCLONERATIO:
387 		case ZPOOL_PROP_DEDUPRATIO:
388 			if (literal)
389 				(void) snprintf(buf, len, "%llu.%02llu",
390 				    (u_longlong_t)(intval / 100),
391 				    (u_longlong_t)(intval % 100));
392 			else
393 				(void) snprintf(buf, len, "%llu.%02llux",
394 				    (u_longlong_t)(intval / 100),
395 				    (u_longlong_t)(intval % 100));
396 			break;
397 
398 		case ZPOOL_PROP_HEALTH:
399 			(void) strlcpy(buf, zpool_get_state_str(zhp), len);
400 			break;
401 		case ZPOOL_PROP_VERSION:
402 			if (intval >= SPA_VERSION_FEATURES) {
403 				(void) snprintf(buf, len, "-");
404 				break;
405 			}
406 			zfs_fallthrough;
407 		default:
408 			(void) snprintf(buf, len, "%llu", (u_longlong_t)intval);
409 		}
410 		break;
411 
412 	case PROP_TYPE_INDEX:
413 		intval = zpool_get_prop_int(zhp, prop, &src);
414 		if (zpool_prop_index_to_string(prop, intval, &strval)
415 		    != 0)
416 			return (-1);
417 		(void) strlcpy(buf, strval, len);
418 		break;
419 
420 	default:
421 		abort();
422 	}
423 
424 	if (srctype)
425 		*srctype = src;
426 
427 	return (0);
428 }
429 
430 /*
431  * Get a zpool property value for 'propname' and return the value in
432  * a pre-allocated buffer.
433  */
434 int
zpool_get_userprop(zpool_handle_t * zhp,const char * propname,char * buf,size_t len,zprop_source_t * srctype)435 zpool_get_userprop(zpool_handle_t *zhp, const char *propname, char *buf,
436     size_t len, zprop_source_t *srctype)
437 {
438 	nvlist_t *nv, *nvl;
439 	uint64_t ival;
440 	const char *value;
441 	zprop_source_t source = ZPROP_SRC_LOCAL;
442 
443 	nvl = zhp->zpool_props;
444 	if (nvlist_lookup_nvlist(nvl, propname, &nv) == 0) {
445 		if (nvlist_lookup_uint64(nv, ZPROP_SOURCE, &ival) == 0)
446 			source = ival;
447 		verify(nvlist_lookup_string(nv, ZPROP_VALUE, &value) == 0);
448 	} else {
449 		source = ZPROP_SRC_DEFAULT;
450 		value = "-";
451 	}
452 
453 	if (srctype)
454 		*srctype = source;
455 
456 	(void) strlcpy(buf, value, len);
457 
458 	return (0);
459 }
460 
461 /*
462  * Check if the bootfs name has the same pool name as it is set to.
463  * Assuming bootfs is a valid dataset name.
464  */
465 static boolean_t
bootfs_name_valid(const char * pool,const char * bootfs)466 bootfs_name_valid(const char *pool, const char *bootfs)
467 {
468 	int len = strlen(pool);
469 	if (bootfs[0] == '\0')
470 		return (B_TRUE);
471 
472 	if (!zfs_name_valid(bootfs, ZFS_TYPE_FILESYSTEM|ZFS_TYPE_SNAPSHOT))
473 		return (B_FALSE);
474 
475 	if (strncmp(pool, bootfs, len) == 0 &&
476 	    (bootfs[len] == '/' || bootfs[len] == '\0'))
477 		return (B_TRUE);
478 
479 	return (B_FALSE);
480 }
481 
482 /*
483  * Given an nvlist of zpool properties to be set, validate that they are
484  * correct, and parse any numeric properties (index, boolean, etc) if they are
485  * specified as strings.
486  */
487 static nvlist_t *
zpool_valid_proplist(libzfs_handle_t * hdl,const char * poolname,nvlist_t * props,uint64_t version,prop_flags_t flags,char * errbuf)488 zpool_valid_proplist(libzfs_handle_t *hdl, const char *poolname,
489     nvlist_t *props, uint64_t version, prop_flags_t flags, char *errbuf)
490 {
491 	nvpair_t *elem;
492 	nvlist_t *retprops;
493 	zpool_prop_t prop;
494 	const char *strval;
495 	uint64_t intval;
496 	const char *slash, *check;
497 	struct stat64 statbuf;
498 	zpool_handle_t *zhp;
499 	char report[1024];
500 
501 	if (nvlist_alloc(&retprops, NV_UNIQUE_NAME, 0) != 0) {
502 		(void) no_memory(hdl);
503 		return (NULL);
504 	}
505 
506 	elem = NULL;
507 	while ((elem = nvlist_next_nvpair(props, elem)) != NULL) {
508 		const char *propname = nvpair_name(elem);
509 
510 		if (flags.vdevprop && zpool_prop_vdev(propname)) {
511 			vdev_prop_t vprop = vdev_name_to_prop(propname);
512 
513 			if (vdev_prop_readonly(vprop)) {
514 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN, "'%s' "
515 				    "is readonly"), propname);
516 				(void) zfs_error(hdl, EZFS_PROPREADONLY,
517 				    errbuf);
518 				goto error;
519 			}
520 
521 			if (zprop_parse_value(hdl, elem, vprop, ZFS_TYPE_VDEV,
522 			    retprops, &strval, &intval, errbuf) != 0)
523 				goto error;
524 
525 			continue;
526 		} else if (flags.vdevprop && vdev_prop_user(propname)) {
527 			if (nvlist_add_nvpair(retprops, elem) != 0) {
528 				(void) no_memory(hdl);
529 				goto error;
530 			}
531 			continue;
532 		} else if (flags.vdevprop) {
533 			zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
534 			    "invalid property: '%s'"), propname);
535 			(void) zfs_error(hdl, EZFS_BADPROP, errbuf);
536 			goto error;
537 		}
538 
539 		prop = zpool_name_to_prop(propname);
540 		if (prop == ZPOOL_PROP_INVAL && zpool_prop_feature(propname)) {
541 			int err;
542 			char *fname = strchr(propname, '@') + 1;
543 
544 			err = zfeature_lookup_name(fname, NULL);
545 			if (err != 0) {
546 				ASSERT3U(err, ==, ENOENT);
547 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
548 				    "feature '%s' unsupported by kernel"),
549 				    fname);
550 				(void) zfs_error(hdl, EZFS_BADPROP, errbuf);
551 				goto error;
552 			}
553 
554 			if (nvpair_type(elem) != DATA_TYPE_STRING) {
555 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
556 				    "'%s' must be a string"), propname);
557 				(void) zfs_error(hdl, EZFS_BADPROP, errbuf);
558 				goto error;
559 			}
560 
561 			(void) nvpair_value_string(elem, &strval);
562 			if (strcmp(strval, ZFS_FEATURE_ENABLED) != 0 &&
563 			    strcmp(strval, ZFS_FEATURE_DISABLED) != 0) {
564 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
565 				    "property '%s' can only be set to "
566 				    "'enabled' or 'disabled'"), propname);
567 				(void) zfs_error(hdl, EZFS_BADPROP, errbuf);
568 				goto error;
569 			}
570 
571 			if (!flags.create &&
572 			    strcmp(strval, ZFS_FEATURE_DISABLED) == 0) {
573 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
574 				    "property '%s' can only be set to "
575 				    "'disabled' at creation time"), propname);
576 				(void) zfs_error(hdl, EZFS_BADPROP, errbuf);
577 				goto error;
578 			}
579 
580 			if (nvlist_add_uint64(retprops, propname, 0) != 0) {
581 				(void) no_memory(hdl);
582 				goto error;
583 			}
584 			continue;
585 		} else if (prop == ZPOOL_PROP_INVAL &&
586 		    zfs_prop_user(propname)) {
587 			/*
588 			 * This is a user property: make sure it's a
589 			 * string, and that it's less than ZAP_MAXNAMELEN.
590 			 */
591 			if (nvpair_type(elem) != DATA_TYPE_STRING) {
592 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
593 				    "'%s' must be a string"), propname);
594 				(void) zfs_error(hdl, EZFS_BADPROP, errbuf);
595 				goto error;
596 			}
597 
598 			if (strlen(nvpair_name(elem)) >= ZAP_MAXNAMELEN) {
599 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
600 				    "property name '%s' is too long"),
601 				    propname);
602 				(void) zfs_error(hdl, EZFS_BADPROP, errbuf);
603 				goto error;
604 			}
605 
606 			(void) nvpair_value_string(elem, &strval);
607 
608 			if (strlen(strval) >= ZFS_MAXPROPLEN) {
609 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
610 				    "property value '%s' is too long"),
611 				    strval);
612 				(void) zfs_error(hdl, EZFS_BADPROP, errbuf);
613 				goto error;
614 			}
615 
616 			if (nvlist_add_string(retprops, propname,
617 			    strval) != 0) {
618 				(void) no_memory(hdl);
619 				goto error;
620 			}
621 
622 			continue;
623 		}
624 
625 		/*
626 		 * Make sure this property is valid and applies to this type.
627 		 */
628 		if (prop == ZPOOL_PROP_INVAL) {
629 			zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
630 			    "invalid property '%s'"), propname);
631 			(void) zfs_error(hdl, EZFS_BADPROP, errbuf);
632 			goto error;
633 		}
634 
635 		if (zpool_prop_readonly(prop)) {
636 			zfs_error_aux(hdl, dgettext(TEXT_DOMAIN, "'%s' "
637 			    "is readonly"), propname);
638 			(void) zfs_error(hdl, EZFS_PROPREADONLY, errbuf);
639 			goto error;
640 		}
641 
642 		if (!flags.create && zpool_prop_setonce(prop)) {
643 			zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
644 			    "property '%s' can only be set at "
645 			    "creation time"), propname);
646 			(void) zfs_error(hdl, EZFS_BADPROP, errbuf);
647 			goto error;
648 		}
649 
650 		if (zprop_parse_value(hdl, elem, prop, ZFS_TYPE_POOL, retprops,
651 		    &strval, &intval, errbuf) != 0)
652 			goto error;
653 
654 		/*
655 		 * Perform additional checking for specific properties.
656 		 */
657 		switch (prop) {
658 		case ZPOOL_PROP_VERSION:
659 			if (intval < version ||
660 			    !SPA_VERSION_IS_SUPPORTED(intval)) {
661 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
662 				    "property '%s' number %llu is invalid."),
663 				    propname, (unsigned long long)intval);
664 				(void) zfs_error(hdl, EZFS_BADVERSION, errbuf);
665 				goto error;
666 			}
667 			break;
668 
669 		case ZPOOL_PROP_ASHIFT:
670 			if (intval != 0 &&
671 			    (intval < ASHIFT_MIN || intval > ASHIFT_MAX)) {
672 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
673 				    "property '%s' number %llu is invalid, "
674 				    "only values between %" PRId32 " and %"
675 				    PRId32 " are allowed."),
676 				    propname, (unsigned long long)intval,
677 				    ASHIFT_MIN, ASHIFT_MAX);
678 				(void) zfs_error(hdl, EZFS_BADPROP, errbuf);
679 				goto error;
680 			}
681 			break;
682 
683 		case ZPOOL_PROP_BOOTFS:
684 			if (flags.create || flags.import) {
685 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
686 				    "property '%s' cannot be set at creation "
687 				    "or import time"), propname);
688 				(void) zfs_error(hdl, EZFS_BADPROP, errbuf);
689 				goto error;
690 			}
691 
692 			if (version < SPA_VERSION_BOOTFS) {
693 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
694 				    "pool must be upgraded to support "
695 				    "'%s' property"), propname);
696 				(void) zfs_error(hdl, EZFS_BADVERSION, errbuf);
697 				goto error;
698 			}
699 
700 			/*
701 			 * bootfs property value has to be a dataset name and
702 			 * the dataset has to be in the same pool as it sets to.
703 			 */
704 			if (!bootfs_name_valid(poolname, strval)) {
705 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN, "'%s' "
706 				    "is an invalid name"), strval);
707 				(void) zfs_error(hdl, EZFS_INVALIDNAME, errbuf);
708 				goto error;
709 			}
710 
711 			if ((zhp = zpool_open_canfail(hdl, poolname)) == NULL) {
712 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
713 				    "could not open pool '%s'"), poolname);
714 				(void) zfs_error(hdl, EZFS_OPENFAILED, errbuf);
715 				goto error;
716 			}
717 			zpool_close(zhp);
718 			break;
719 
720 		case ZPOOL_PROP_ALTROOT:
721 			if (!flags.create && !flags.import) {
722 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
723 				    "property '%s' can only be set during pool "
724 				    "creation or import"), propname);
725 				(void) zfs_error(hdl, EZFS_BADPROP, errbuf);
726 				goto error;
727 			}
728 
729 			if (strval[0] != '/') {
730 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
731 				    "bad alternate root '%s'"), strval);
732 				(void) zfs_error(hdl, EZFS_BADPATH, errbuf);
733 				goto error;
734 			}
735 			break;
736 
737 		case ZPOOL_PROP_CACHEFILE:
738 			if (strval[0] == '\0')
739 				break;
740 
741 			if (strcmp(strval, "none") == 0)
742 				break;
743 
744 			if (strval[0] != '/') {
745 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
746 				    "property '%s' must be empty, an "
747 				    "absolute path, or 'none'"), propname);
748 				(void) zfs_error(hdl, EZFS_BADPATH, errbuf);
749 				goto error;
750 			}
751 
752 			slash = strrchr(strval, '/');
753 
754 			if (slash[1] == '\0' || strcmp(slash, "/.") == 0 ||
755 			    strcmp(slash, "/..") == 0) {
756 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
757 				    "'%s' is not a valid file"), strval);
758 				(void) zfs_error(hdl, EZFS_BADPATH, errbuf);
759 				goto error;
760 			}
761 
762 			*(char *)slash = '\0';
763 
764 			if (strval[0] != '\0' &&
765 			    (stat64(strval, &statbuf) != 0 ||
766 			    !S_ISDIR(statbuf.st_mode))) {
767 				*(char *)slash = '/';
768 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
769 				    "'%s' is not a valid directory"),
770 				    strval);
771 				(void) zfs_error(hdl, EZFS_BADPATH, errbuf);
772 				goto error;
773 			}
774 
775 			*(char *)slash = '/';
776 			break;
777 
778 		case ZPOOL_PROP_COMPATIBILITY:
779 			switch (zpool_load_compat(strval, NULL, report, 1024)) {
780 			case ZPOOL_COMPATIBILITY_OK:
781 			case ZPOOL_COMPATIBILITY_WARNTOKEN:
782 				break;
783 			case ZPOOL_COMPATIBILITY_BADFILE:
784 			case ZPOOL_COMPATIBILITY_BADTOKEN:
785 			case ZPOOL_COMPATIBILITY_NOFILES:
786 				zfs_error_aux(hdl, "%s", report);
787 				(void) zfs_error(hdl, EZFS_BADPROP, errbuf);
788 				goto error;
789 			}
790 			break;
791 
792 		case ZPOOL_PROP_COMMENT:
793 			for (check = strval; *check != '\0'; check++) {
794 				if (!isprint(*check)) {
795 					zfs_error_aux(hdl,
796 					    dgettext(TEXT_DOMAIN,
797 					    "comment may only have printable "
798 					    "characters"));
799 					(void) zfs_error(hdl, EZFS_BADPROP,
800 					    errbuf);
801 					goto error;
802 				}
803 			}
804 			if (strlen(strval) > ZPROP_MAX_COMMENT) {
805 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
806 				    "comment must not exceed %d characters"),
807 				    ZPROP_MAX_COMMENT);
808 				(void) zfs_error(hdl, EZFS_BADPROP, errbuf);
809 				goto error;
810 			}
811 			break;
812 		case ZPOOL_PROP_READONLY:
813 			if (!flags.import) {
814 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
815 				    "property '%s' can only be set at "
816 				    "import time"), propname);
817 				(void) zfs_error(hdl, EZFS_BADPROP, errbuf);
818 				goto error;
819 			}
820 			break;
821 		case ZPOOL_PROP_MULTIHOST:
822 			if (get_system_hostid() == 0) {
823 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
824 				    "requires a non-zero system hostid"));
825 				(void) zfs_error(hdl, EZFS_BADPROP, errbuf);
826 				goto error;
827 			}
828 			break;
829 		case ZPOOL_PROP_DEDUPDITTO:
830 			printf("Note: property '%s' no longer has "
831 			    "any effect\n", propname);
832 			break;
833 
834 		default:
835 			break;
836 		}
837 	}
838 
839 	return (retprops);
840 error:
841 	nvlist_free(retprops);
842 	return (NULL);
843 }
844 
845 /*
846  * Set zpool property : propname=propval.
847  */
848 int
zpool_set_prop(zpool_handle_t * zhp,const char * propname,const char * propval)849 zpool_set_prop(zpool_handle_t *zhp, const char *propname, const char *propval)
850 {
851 	zfs_cmd_t zc = {"\0"};
852 	int ret = -1;
853 	char errbuf[ERRBUFLEN];
854 	nvlist_t *nvl = NULL;
855 	nvlist_t *realprops;
856 	uint64_t version;
857 	prop_flags_t flags = { 0 };
858 
859 	(void) snprintf(errbuf, sizeof (errbuf),
860 	    dgettext(TEXT_DOMAIN, "cannot set property for '%s'"),
861 	    zhp->zpool_name);
862 
863 	if (nvlist_alloc(&nvl, NV_UNIQUE_NAME, 0) != 0)
864 		return (no_memory(zhp->zpool_hdl));
865 
866 	if (nvlist_add_string(nvl, propname, propval) != 0) {
867 		nvlist_free(nvl);
868 		return (no_memory(zhp->zpool_hdl));
869 	}
870 
871 	version = zpool_get_prop_int(zhp, ZPOOL_PROP_VERSION, NULL);
872 	if ((realprops = zpool_valid_proplist(zhp->zpool_hdl,
873 	    zhp->zpool_name, nvl, version, flags, errbuf)) == NULL) {
874 		nvlist_free(nvl);
875 		return (-1);
876 	}
877 
878 	nvlist_free(nvl);
879 	nvl = realprops;
880 
881 	/*
882 	 * Execute the corresponding ioctl() to set this property.
883 	 */
884 	(void) strlcpy(zc.zc_name, zhp->zpool_name, sizeof (zc.zc_name));
885 
886 	zcmd_write_src_nvlist(zhp->zpool_hdl, &zc, nvl);
887 
888 	ret = zfs_ioctl(zhp->zpool_hdl, ZFS_IOC_POOL_SET_PROPS, &zc);
889 
890 	zcmd_free_nvlists(&zc);
891 	nvlist_free(nvl);
892 
893 	if (ret)
894 		(void) zpool_standard_error(zhp->zpool_hdl, errno, errbuf);
895 	else
896 		(void) zpool_props_refresh(zhp);
897 
898 	return (ret);
899 }
900 
901 int
zpool_expand_proplist(zpool_handle_t * zhp,zprop_list_t ** plp,zfs_type_t type,boolean_t literal)902 zpool_expand_proplist(zpool_handle_t *zhp, zprop_list_t **plp,
903     zfs_type_t type, boolean_t literal)
904 {
905 	libzfs_handle_t *hdl = zhp->zpool_hdl;
906 	zprop_list_t *entry;
907 	char buf[ZFS_MAXPROPLEN];
908 	nvlist_t *features = NULL;
909 	nvpair_t *nvp;
910 	zprop_list_t **last;
911 	boolean_t firstexpand = (NULL == *plp);
912 	int i;
913 
914 	if (zprop_expand_list(hdl, plp, type) != 0)
915 		return (-1);
916 
917 	if (type == ZFS_TYPE_VDEV)
918 		return (0);
919 
920 	last = plp;
921 	while (*last != NULL)
922 		last = &(*last)->pl_next;
923 
924 	if ((*plp)->pl_all)
925 		features = zpool_get_features(zhp);
926 
927 	if ((*plp)->pl_all && firstexpand) {
928 		/* Handle userprops in the all properties case */
929 		if (zhp->zpool_props == NULL && zpool_props_refresh(zhp))
930 			return (-1);
931 
932 		nvp = NULL;
933 		while ((nvp = nvlist_next_nvpair(zhp->zpool_props, nvp)) !=
934 		    NULL) {
935 			const char *propname = nvpair_name(nvp);
936 
937 			if (!zfs_prop_user(propname))
938 				continue;
939 
940 			entry = zfs_alloc(hdl, sizeof (zprop_list_t));
941 			entry->pl_prop = ZPROP_USERPROP;
942 			entry->pl_user_prop = zfs_strdup(hdl, propname);
943 			entry->pl_width = strlen(entry->pl_user_prop);
944 			entry->pl_all = B_TRUE;
945 
946 			*last = entry;
947 			last = &entry->pl_next;
948 		}
949 
950 		for (i = 0; i < SPA_FEATURES; i++) {
951 			entry = zfs_alloc(hdl, sizeof (zprop_list_t));
952 			entry->pl_prop = ZPROP_USERPROP;
953 			entry->pl_user_prop = zfs_asprintf(hdl, "feature@%s",
954 			    spa_feature_table[i].fi_uname);
955 			entry->pl_width = strlen(entry->pl_user_prop);
956 			entry->pl_all = B_TRUE;
957 
958 			*last = entry;
959 			last = &entry->pl_next;
960 		}
961 	}
962 
963 	/* add any unsupported features */
964 	for (nvp = nvlist_next_nvpair(features, NULL);
965 	    nvp != NULL; nvp = nvlist_next_nvpair(features, nvp)) {
966 		char *propname;
967 		boolean_t found;
968 
969 		if (zfeature_is_supported(nvpair_name(nvp)))
970 			continue;
971 
972 		propname = zfs_asprintf(hdl, "unsupported@%s",
973 		    nvpair_name(nvp));
974 
975 		/*
976 		 * Before adding the property to the list make sure that no
977 		 * other pool already added the same property.
978 		 */
979 		found = B_FALSE;
980 		entry = *plp;
981 		while (entry != NULL) {
982 			if (entry->pl_user_prop != NULL &&
983 			    strcmp(propname, entry->pl_user_prop) == 0) {
984 				found = B_TRUE;
985 				break;
986 			}
987 			entry = entry->pl_next;
988 		}
989 		if (found) {
990 			free(propname);
991 			continue;
992 		}
993 
994 		entry = zfs_alloc(hdl, sizeof (zprop_list_t));
995 		entry->pl_prop = ZPROP_USERPROP;
996 		entry->pl_user_prop = propname;
997 		entry->pl_width = strlen(entry->pl_user_prop);
998 		entry->pl_all = B_TRUE;
999 
1000 		*last = entry;
1001 		last = &entry->pl_next;
1002 	}
1003 
1004 	for (entry = *plp; entry != NULL; entry = entry->pl_next) {
1005 		if (entry->pl_fixed && !literal)
1006 			continue;
1007 
1008 		if (entry->pl_prop != ZPROP_USERPROP &&
1009 		    zpool_get_prop(zhp, entry->pl_prop, buf, sizeof (buf),
1010 		    NULL, literal) == 0) {
1011 			if (strlen(buf) > entry->pl_width)
1012 				entry->pl_width = strlen(buf);
1013 		} else if (entry->pl_prop == ZPROP_INVAL &&
1014 		    zfs_prop_user(entry->pl_user_prop) &&
1015 		    zpool_get_userprop(zhp, entry->pl_user_prop, buf,
1016 		    sizeof (buf), NULL) == 0) {
1017 			if (strlen(buf) > entry->pl_width)
1018 				entry->pl_width = strlen(buf);
1019 		}
1020 	}
1021 
1022 	return (0);
1023 }
1024 
1025 int
vdev_expand_proplist(zpool_handle_t * zhp,const char * vdevname,zprop_list_t ** plp)1026 vdev_expand_proplist(zpool_handle_t *zhp, const char *vdevname,
1027     zprop_list_t **plp)
1028 {
1029 	zprop_list_t *entry;
1030 	char buf[ZFS_MAXPROPLEN];
1031 	const char *strval = NULL;
1032 	int err = 0;
1033 	nvpair_t *elem = NULL;
1034 	nvlist_t *vprops = NULL;
1035 	nvlist_t *propval = NULL;
1036 	const char *propname;
1037 	vdev_prop_t prop;
1038 	zprop_list_t **last;
1039 
1040 	for (entry = *plp; entry != NULL; entry = entry->pl_next) {
1041 		if (entry->pl_fixed)
1042 			continue;
1043 
1044 		if (zpool_get_vdev_prop(zhp, vdevname, entry->pl_prop,
1045 		    entry->pl_user_prop, buf, sizeof (buf), NULL,
1046 		    B_FALSE) == 0) {
1047 			if (strlen(buf) > entry->pl_width)
1048 				entry->pl_width = strlen(buf);
1049 		}
1050 		if (entry->pl_prop == VDEV_PROP_NAME &&
1051 		    strlen(vdevname) > entry->pl_width)
1052 			entry->pl_width = strlen(vdevname);
1053 	}
1054 
1055 	/* Handle the all properties case */
1056 	last = plp;
1057 	if (*last != NULL && (*last)->pl_all == B_TRUE) {
1058 		while (*last != NULL)
1059 			last = &(*last)->pl_next;
1060 
1061 		err = zpool_get_all_vdev_props(zhp, vdevname, &vprops);
1062 		if (err != 0)
1063 			return (err);
1064 
1065 		while ((elem = nvlist_next_nvpair(vprops, elem)) != NULL) {
1066 			propname = nvpair_name(elem);
1067 
1068 			/* Skip properties that are not user defined */
1069 			if ((prop = vdev_name_to_prop(propname)) !=
1070 			    VDEV_PROP_USERPROP)
1071 				continue;
1072 
1073 			if (nvpair_value_nvlist(elem, &propval) != 0)
1074 				continue;
1075 
1076 			strval = fnvlist_lookup_string(propval, ZPROP_VALUE);
1077 
1078 			entry = zfs_alloc(zhp->zpool_hdl,
1079 			    sizeof (zprop_list_t));
1080 			entry->pl_prop = prop;
1081 			entry->pl_user_prop = zfs_strdup(zhp->zpool_hdl,
1082 			    propname);
1083 			entry->pl_width = strlen(strval);
1084 			entry->pl_all = B_TRUE;
1085 			*last = entry;
1086 			last = &entry->pl_next;
1087 		}
1088 	}
1089 
1090 	return (0);
1091 }
1092 
1093 /*
1094  * Get the state for the given feature on the given ZFS pool.
1095  */
1096 int
zpool_prop_get_feature(zpool_handle_t * zhp,const char * propname,char * buf,size_t len)1097 zpool_prop_get_feature(zpool_handle_t *zhp, const char *propname, char *buf,
1098     size_t len)
1099 {
1100 	uint64_t refcount;
1101 	boolean_t found = B_FALSE;
1102 	nvlist_t *features = zpool_get_features(zhp);
1103 	boolean_t supported;
1104 	const char *feature = strchr(propname, '@') + 1;
1105 
1106 	supported = zpool_prop_feature(propname);
1107 	ASSERT(supported || zpool_prop_unsupported(propname));
1108 
1109 	/*
1110 	 * Convert from feature name to feature guid. This conversion is
1111 	 * unnecessary for unsupported@... properties because they already
1112 	 * use guids.
1113 	 */
1114 	if (supported) {
1115 		int ret;
1116 		spa_feature_t fid;
1117 
1118 		ret = zfeature_lookup_name(feature, &fid);
1119 		if (ret != 0) {
1120 			(void) strlcpy(buf, "-", len);
1121 			return (ENOTSUP);
1122 		}
1123 		feature = spa_feature_table[fid].fi_guid;
1124 	}
1125 
1126 	if (nvlist_lookup_uint64(features, feature, &refcount) == 0)
1127 		found = B_TRUE;
1128 
1129 	if (supported) {
1130 		if (!found) {
1131 			(void) strlcpy(buf, ZFS_FEATURE_DISABLED, len);
1132 		} else  {
1133 			if (refcount == 0)
1134 				(void) strlcpy(buf, ZFS_FEATURE_ENABLED, len);
1135 			else
1136 				(void) strlcpy(buf, ZFS_FEATURE_ACTIVE, len);
1137 		}
1138 	} else {
1139 		if (found) {
1140 			if (refcount == 0) {
1141 				(void) strcpy(buf, ZFS_UNSUPPORTED_INACTIVE);
1142 			} else {
1143 				(void) strcpy(buf, ZFS_UNSUPPORTED_READONLY);
1144 			}
1145 		} else {
1146 			(void) strlcpy(buf, "-", len);
1147 			return (ENOTSUP);
1148 		}
1149 	}
1150 
1151 	return (0);
1152 }
1153 
1154 /*
1155  * Validate the given pool name, optionally putting an extended error message in
1156  * 'buf'.
1157  */
1158 boolean_t
zpool_name_valid(libzfs_handle_t * hdl,boolean_t isopen,const char * pool)1159 zpool_name_valid(libzfs_handle_t *hdl, boolean_t isopen, const char *pool)
1160 {
1161 	namecheck_err_t why;
1162 	char what;
1163 	int ret;
1164 
1165 	ret = pool_namecheck(pool, &why, &what);
1166 
1167 	/*
1168 	 * The rules for reserved pool names were extended at a later point.
1169 	 * But we need to support users with existing pools that may now be
1170 	 * invalid.  So we only check for this expanded set of names during a
1171 	 * create (or import), and only in userland.
1172 	 */
1173 	if (ret == 0 && !isopen &&
1174 	    (strncmp(pool, "mirror", 6) == 0 ||
1175 	    strncmp(pool, "raidz", 5) == 0 ||
1176 	    strncmp(pool, "draid", 5) == 0 ||
1177 	    strncmp(pool, "spare", 5) == 0 ||
1178 	    strcmp(pool, "log") == 0)) {
1179 		if (hdl != NULL)
1180 			zfs_error_aux(hdl,
1181 			    dgettext(TEXT_DOMAIN, "name is reserved"));
1182 		return (B_FALSE);
1183 	}
1184 
1185 
1186 	if (ret != 0) {
1187 		if (hdl != NULL) {
1188 			switch (why) {
1189 			case NAME_ERR_TOOLONG:
1190 				zfs_error_aux(hdl,
1191 				    dgettext(TEXT_DOMAIN, "name is too long"));
1192 				break;
1193 
1194 			case NAME_ERR_INVALCHAR:
1195 				zfs_error_aux(hdl,
1196 				    dgettext(TEXT_DOMAIN, "invalid character "
1197 				    "'%c' in pool name"), what);
1198 				break;
1199 
1200 			case NAME_ERR_NOLETTER:
1201 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
1202 				    "name must begin with a letter"));
1203 				break;
1204 
1205 			case NAME_ERR_RESERVED:
1206 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
1207 				    "name is reserved"));
1208 				break;
1209 
1210 			case NAME_ERR_DISKLIKE:
1211 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
1212 				    "pool name is reserved"));
1213 				break;
1214 
1215 			case NAME_ERR_LEADING_SLASH:
1216 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
1217 				    "leading slash in name"));
1218 				break;
1219 
1220 			case NAME_ERR_EMPTY_COMPONENT:
1221 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
1222 				    "empty component in name"));
1223 				break;
1224 
1225 			case NAME_ERR_TRAILING_SLASH:
1226 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
1227 				    "trailing slash in name"));
1228 				break;
1229 
1230 			case NAME_ERR_MULTIPLE_DELIMITERS:
1231 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
1232 				    "multiple '@' and/or '#' delimiters in "
1233 				    "name"));
1234 				break;
1235 
1236 			case NAME_ERR_NO_AT:
1237 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
1238 				    "permission set is missing '@'"));
1239 				break;
1240 
1241 			default:
1242 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
1243 				    "(%d) not defined"), why);
1244 				break;
1245 			}
1246 		}
1247 		return (B_FALSE);
1248 	}
1249 
1250 	return (B_TRUE);
1251 }
1252 
1253 /*
1254  * Open a handle to the given pool, even if the pool is currently in the FAULTED
1255  * state.
1256  */
1257 zpool_handle_t *
zpool_open_canfail(libzfs_handle_t * hdl,const char * pool)1258 zpool_open_canfail(libzfs_handle_t *hdl, const char *pool)
1259 {
1260 	zpool_handle_t *zhp;
1261 	boolean_t missing;
1262 
1263 	/*
1264 	 * Make sure the pool name is valid.
1265 	 */
1266 	if (!zpool_name_valid(hdl, B_TRUE, pool)) {
1267 		(void) zfs_error_fmt(hdl, EZFS_INVALIDNAME,
1268 		    dgettext(TEXT_DOMAIN, "cannot open '%s'"),
1269 		    pool);
1270 		return (NULL);
1271 	}
1272 
1273 	zhp = zfs_alloc(hdl, sizeof (zpool_handle_t));
1274 
1275 	zhp->zpool_hdl = hdl;
1276 	(void) strlcpy(zhp->zpool_name, pool, sizeof (zhp->zpool_name));
1277 
1278 	if (zpool_refresh_stats(zhp, &missing) != 0) {
1279 		zpool_close(zhp);
1280 		return (NULL);
1281 	}
1282 
1283 	if (missing) {
1284 		zfs_error_aux(hdl, dgettext(TEXT_DOMAIN, "no such pool"));
1285 		(void) zfs_error_fmt(hdl, EZFS_NOENT,
1286 		    dgettext(TEXT_DOMAIN, "cannot open '%s'"), pool);
1287 		zpool_close(zhp);
1288 		return (NULL);
1289 	}
1290 
1291 	return (zhp);
1292 }
1293 
1294 /*
1295  * Like the above, but silent on error.  Used when iterating over pools (because
1296  * the configuration cache may be out of date).
1297  */
1298 int
zpool_open_silent(libzfs_handle_t * hdl,const char * pool,zpool_handle_t ** ret)1299 zpool_open_silent(libzfs_handle_t *hdl, const char *pool, zpool_handle_t **ret)
1300 {
1301 	zpool_handle_t *zhp;
1302 	boolean_t missing;
1303 
1304 	zhp = zfs_alloc(hdl, sizeof (zpool_handle_t));
1305 
1306 	zhp->zpool_hdl = hdl;
1307 	(void) strlcpy(zhp->zpool_name, pool, sizeof (zhp->zpool_name));
1308 
1309 	if (zpool_refresh_stats(zhp, &missing) != 0) {
1310 		zpool_close(zhp);
1311 		return (-1);
1312 	}
1313 
1314 	if (missing) {
1315 		zpool_close(zhp);
1316 		*ret = NULL;
1317 		return (0);
1318 	}
1319 
1320 	*ret = zhp;
1321 	return (0);
1322 }
1323 
1324 /*
1325  * Similar to zpool_open_canfail(), but refuses to open pools in the faulted
1326  * state.
1327  */
1328 zpool_handle_t *
zpool_open(libzfs_handle_t * hdl,const char * pool)1329 zpool_open(libzfs_handle_t *hdl, const char *pool)
1330 {
1331 	zpool_handle_t *zhp;
1332 
1333 	if ((zhp = zpool_open_canfail(hdl, pool)) == NULL)
1334 		return (NULL);
1335 
1336 	if (zhp->zpool_state == POOL_STATE_UNAVAIL) {
1337 		(void) zfs_error_fmt(hdl, EZFS_POOLUNAVAIL,
1338 		    dgettext(TEXT_DOMAIN, "cannot open '%s'"), zhp->zpool_name);
1339 		zpool_close(zhp);
1340 		return (NULL);
1341 	}
1342 
1343 	return (zhp);
1344 }
1345 
1346 /*
1347  * Close the handle.  Simply frees the memory associated with the handle.
1348  */
1349 void
zpool_close(zpool_handle_t * zhp)1350 zpool_close(zpool_handle_t *zhp)
1351 {
1352 	nvlist_free(zhp->zpool_config);
1353 	nvlist_free(zhp->zpool_old_config);
1354 	nvlist_free(zhp->zpool_props);
1355 	free(zhp);
1356 }
1357 
1358 /*
1359  * Return the name of the pool.
1360  */
1361 const char *
zpool_get_name(zpool_handle_t * zhp)1362 zpool_get_name(zpool_handle_t *zhp)
1363 {
1364 	return (zhp->zpool_name);
1365 }
1366 
1367 
1368 /*
1369  * Return the state of the pool (ACTIVE or UNAVAILABLE)
1370  */
1371 int
zpool_get_state(zpool_handle_t * zhp)1372 zpool_get_state(zpool_handle_t *zhp)
1373 {
1374 	return (zhp->zpool_state);
1375 }
1376 
1377 /*
1378  * Check if vdev list contains a special vdev
1379  */
1380 static boolean_t
zpool_has_special_vdev(nvlist_t * nvroot)1381 zpool_has_special_vdev(nvlist_t *nvroot)
1382 {
1383 	nvlist_t **child;
1384 	uint_t children;
1385 
1386 	if (nvlist_lookup_nvlist_array(nvroot, ZPOOL_CONFIG_CHILDREN, &child,
1387 	    &children) == 0) {
1388 		for (uint_t c = 0; c < children; c++) {
1389 			const char *bias;
1390 
1391 			if (nvlist_lookup_string(child[c],
1392 			    ZPOOL_CONFIG_ALLOCATION_BIAS, &bias) == 0 &&
1393 			    strcmp(bias, VDEV_ALLOC_BIAS_SPECIAL) == 0) {
1394 				return (B_TRUE);
1395 			}
1396 		}
1397 	}
1398 	return (B_FALSE);
1399 }
1400 
1401 /*
1402  * Check if vdev list contains a dRAID vdev
1403  */
1404 static boolean_t
zpool_has_draid_vdev(nvlist_t * nvroot)1405 zpool_has_draid_vdev(nvlist_t *nvroot)
1406 {
1407 	nvlist_t **child;
1408 	uint_t children;
1409 
1410 	if (nvlist_lookup_nvlist_array(nvroot, ZPOOL_CONFIG_CHILDREN,
1411 	    &child, &children) == 0) {
1412 		for (uint_t c = 0; c < children; c++) {
1413 			const char *type;
1414 
1415 			if (nvlist_lookup_string(child[c],
1416 			    ZPOOL_CONFIG_TYPE, &type) == 0 &&
1417 			    strcmp(type, VDEV_TYPE_DRAID) == 0) {
1418 				return (B_TRUE);
1419 			}
1420 		}
1421 	}
1422 	return (B_FALSE);
1423 }
1424 
1425 /*
1426  * Output a dRAID top-level vdev name in to the provided buffer.
1427  */
1428 static char *
zpool_draid_name(char * name,int len,uint64_t data,uint64_t parity,uint64_t spares,uint64_t children)1429 zpool_draid_name(char *name, int len, uint64_t data, uint64_t parity,
1430     uint64_t spares, uint64_t children)
1431 {
1432 	snprintf(name, len, "%s%llu:%llud:%lluc:%llus",
1433 	    VDEV_TYPE_DRAID, (u_longlong_t)parity, (u_longlong_t)data,
1434 	    (u_longlong_t)children, (u_longlong_t)spares);
1435 
1436 	return (name);
1437 }
1438 
1439 /*
1440  * Return B_TRUE if the provided name is a dRAID spare name.
1441  */
1442 boolean_t
zpool_is_draid_spare(const char * name)1443 zpool_is_draid_spare(const char *name)
1444 {
1445 	uint64_t spare_id, parity, vdev_id;
1446 
1447 	if (sscanf(name, VDEV_TYPE_DRAID "%llu-%llu-%llu",
1448 	    (u_longlong_t *)&parity, (u_longlong_t *)&vdev_id,
1449 	    (u_longlong_t *)&spare_id) == 3) {
1450 		return (B_TRUE);
1451 	}
1452 
1453 	return (B_FALSE);
1454 }
1455 
1456 /*
1457  * Create the named pool, using the provided vdev list.  It is assumed
1458  * that the consumer has already validated the contents of the nvlist, so we
1459  * don't have to worry about error semantics.
1460  */
1461 int
zpool_create(libzfs_handle_t * hdl,const char * pool,nvlist_t * nvroot,nvlist_t * props,nvlist_t * fsprops)1462 zpool_create(libzfs_handle_t *hdl, const char *pool, nvlist_t *nvroot,
1463     nvlist_t *props, nvlist_t *fsprops)
1464 {
1465 	zfs_cmd_t zc = {"\0"};
1466 	nvlist_t *zc_fsprops = NULL;
1467 	nvlist_t *zc_props = NULL;
1468 	nvlist_t *hidden_args = NULL;
1469 	uint8_t *wkeydata = NULL;
1470 	uint_t wkeylen = 0;
1471 	char errbuf[ERRBUFLEN];
1472 	int ret = -1;
1473 
1474 	(void) snprintf(errbuf, sizeof (errbuf), dgettext(TEXT_DOMAIN,
1475 	    "cannot create '%s'"), pool);
1476 
1477 	if (!zpool_name_valid(hdl, B_FALSE, pool))
1478 		return (zfs_error(hdl, EZFS_INVALIDNAME, errbuf));
1479 
1480 	zcmd_write_conf_nvlist(hdl, &zc, nvroot);
1481 
1482 	if (props) {
1483 		prop_flags_t flags = { .create = B_TRUE, .import = B_FALSE };
1484 
1485 		if ((zc_props = zpool_valid_proplist(hdl, pool, props,
1486 		    SPA_VERSION_1, flags, errbuf)) == NULL) {
1487 			goto create_failed;
1488 		}
1489 	}
1490 
1491 	if (fsprops) {
1492 		uint64_t zoned;
1493 		const char *zonestr;
1494 
1495 		zoned = ((nvlist_lookup_string(fsprops,
1496 		    zfs_prop_to_name(ZFS_PROP_ZONED), &zonestr) == 0) &&
1497 		    strcmp(zonestr, "on") == 0);
1498 
1499 		if ((zc_fsprops = zfs_valid_proplist(hdl, ZFS_TYPE_FILESYSTEM,
1500 		    fsprops, zoned, NULL, NULL, B_TRUE, errbuf)) == NULL) {
1501 			goto create_failed;
1502 		}
1503 
1504 		if (nvlist_exists(zc_fsprops,
1505 		    zfs_prop_to_name(ZFS_PROP_SPECIAL_SMALL_BLOCKS)) &&
1506 		    !zpool_has_special_vdev(nvroot)) {
1507 			zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
1508 			    "%s property requires a special vdev"),
1509 			    zfs_prop_to_name(ZFS_PROP_SPECIAL_SMALL_BLOCKS));
1510 			(void) zfs_error(hdl, EZFS_BADPROP, errbuf);
1511 			goto create_failed;
1512 		}
1513 
1514 		if (!zc_props &&
1515 		    (nvlist_alloc(&zc_props, NV_UNIQUE_NAME, 0) != 0)) {
1516 			goto create_failed;
1517 		}
1518 		if (zfs_crypto_create(hdl, NULL, zc_fsprops, props, B_TRUE,
1519 		    &wkeydata, &wkeylen) != 0) {
1520 			zfs_error(hdl, EZFS_CRYPTOFAILED, errbuf);
1521 			goto create_failed;
1522 		}
1523 		if (nvlist_add_nvlist(zc_props,
1524 		    ZPOOL_ROOTFS_PROPS, zc_fsprops) != 0) {
1525 			goto create_failed;
1526 		}
1527 		if (wkeydata != NULL) {
1528 			if (nvlist_alloc(&hidden_args, NV_UNIQUE_NAME, 0) != 0)
1529 				goto create_failed;
1530 
1531 			if (nvlist_add_uint8_array(hidden_args, "wkeydata",
1532 			    wkeydata, wkeylen) != 0)
1533 				goto create_failed;
1534 
1535 			if (nvlist_add_nvlist(zc_props, ZPOOL_HIDDEN_ARGS,
1536 			    hidden_args) != 0)
1537 				goto create_failed;
1538 		}
1539 	}
1540 
1541 	if (zc_props)
1542 		zcmd_write_src_nvlist(hdl, &zc, zc_props);
1543 
1544 	(void) strlcpy(zc.zc_name, pool, sizeof (zc.zc_name));
1545 
1546 	if ((ret = zfs_ioctl(hdl, ZFS_IOC_POOL_CREATE, &zc)) != 0) {
1547 
1548 		zcmd_free_nvlists(&zc);
1549 		nvlist_free(zc_props);
1550 		nvlist_free(zc_fsprops);
1551 		nvlist_free(hidden_args);
1552 		if (wkeydata != NULL)
1553 			free(wkeydata);
1554 
1555 		switch (errno) {
1556 		case EBUSY:
1557 			/*
1558 			 * This can happen if the user has specified the same
1559 			 * device multiple times.  We can't reliably detect this
1560 			 * until we try to add it and see we already have a
1561 			 * label.  This can also happen under if the device is
1562 			 * part of an active md or lvm device.
1563 			 */
1564 			zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
1565 			    "one or more vdevs refer to the same device, or "
1566 			    "one of\nthe devices is part of an active md or "
1567 			    "lvm device"));
1568 			return (zfs_error(hdl, EZFS_BADDEV, errbuf));
1569 
1570 		case ERANGE:
1571 			/*
1572 			 * This happens if the record size is smaller or larger
1573 			 * than the allowed size range, or not a power of 2.
1574 			 *
1575 			 * NOTE: although zfs_valid_proplist is called earlier,
1576 			 * this case may have slipped through since the
1577 			 * pool does not exist yet and it is therefore
1578 			 * impossible to read properties e.g. max blocksize
1579 			 * from the pool.
1580 			 */
1581 			zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
1582 			    "record size invalid"));
1583 			return (zfs_error(hdl, EZFS_BADPROP, errbuf));
1584 
1585 		case EOVERFLOW:
1586 			/*
1587 			 * This occurs when one of the devices is below
1588 			 * SPA_MINDEVSIZE.  Unfortunately, we can't detect which
1589 			 * device was the problem device since there's no
1590 			 * reliable way to determine device size from userland.
1591 			 */
1592 			{
1593 				char buf[64];
1594 
1595 				zfs_nicebytes(SPA_MINDEVSIZE, buf,
1596 				    sizeof (buf));
1597 
1598 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
1599 				    "one or more devices is less than the "
1600 				    "minimum size (%s)"), buf);
1601 			}
1602 			return (zfs_error(hdl, EZFS_BADDEV, errbuf));
1603 
1604 		case ENOSPC:
1605 			zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
1606 			    "one or more devices is out of space"));
1607 			return (zfs_error(hdl, EZFS_BADDEV, errbuf));
1608 
1609 		case EINVAL:
1610 			if (zpool_has_draid_vdev(nvroot) &&
1611 			    zfeature_lookup_name("draid", NULL) != 0) {
1612 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
1613 				    "dRAID vdevs are unsupported by the "
1614 				    "kernel"));
1615 				return (zfs_error(hdl, EZFS_BADDEV, errbuf));
1616 			} else {
1617 				return (zpool_standard_error(hdl, errno,
1618 				    errbuf));
1619 			}
1620 
1621 		default:
1622 			return (zpool_standard_error(hdl, errno, errbuf));
1623 		}
1624 	}
1625 
1626 create_failed:
1627 	zcmd_free_nvlists(&zc);
1628 	nvlist_free(zc_props);
1629 	nvlist_free(zc_fsprops);
1630 	nvlist_free(hidden_args);
1631 	if (wkeydata != NULL)
1632 		free(wkeydata);
1633 	return (ret);
1634 }
1635 
1636 /*
1637  * Destroy the given pool.  It is up to the caller to ensure that there are no
1638  * datasets left in the pool.
1639  */
1640 int
zpool_destroy(zpool_handle_t * zhp,const char * log_str)1641 zpool_destroy(zpool_handle_t *zhp, const char *log_str)
1642 {
1643 	zfs_cmd_t zc = {"\0"};
1644 	zfs_handle_t *zfp = NULL;
1645 	libzfs_handle_t *hdl = zhp->zpool_hdl;
1646 	char errbuf[ERRBUFLEN];
1647 
1648 	if (zhp->zpool_state == POOL_STATE_ACTIVE &&
1649 	    (zfp = zfs_open(hdl, zhp->zpool_name, ZFS_TYPE_FILESYSTEM)) == NULL)
1650 		return (-1);
1651 
1652 	(void) strlcpy(zc.zc_name, zhp->zpool_name, sizeof (zc.zc_name));
1653 	zc.zc_history = (uint64_t)(uintptr_t)log_str;
1654 
1655 	if (zfs_ioctl(hdl, ZFS_IOC_POOL_DESTROY, &zc) != 0) {
1656 		(void) snprintf(errbuf, sizeof (errbuf), dgettext(TEXT_DOMAIN,
1657 		    "cannot destroy '%s'"), zhp->zpool_name);
1658 
1659 		if (errno == EROFS) {
1660 			zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
1661 			    "one or more devices is read only"));
1662 			(void) zfs_error(hdl, EZFS_BADDEV, errbuf);
1663 		} else {
1664 			(void) zpool_standard_error(hdl, errno, errbuf);
1665 		}
1666 
1667 		if (zfp)
1668 			zfs_close(zfp);
1669 		return (-1);
1670 	}
1671 
1672 	if (zfp) {
1673 		remove_mountpoint(zfp);
1674 		zfs_close(zfp);
1675 	}
1676 
1677 	return (0);
1678 }
1679 
1680 /*
1681  * Create a checkpoint in the given pool.
1682  */
1683 int
zpool_checkpoint(zpool_handle_t * zhp)1684 zpool_checkpoint(zpool_handle_t *zhp)
1685 {
1686 	libzfs_handle_t *hdl = zhp->zpool_hdl;
1687 	char errbuf[ERRBUFLEN];
1688 	int error;
1689 
1690 	error = lzc_pool_checkpoint(zhp->zpool_name);
1691 	if (error != 0) {
1692 		(void) snprintf(errbuf, sizeof (errbuf), dgettext(TEXT_DOMAIN,
1693 		    "cannot checkpoint '%s'"), zhp->zpool_name);
1694 		(void) zpool_standard_error(hdl, error, errbuf);
1695 		return (-1);
1696 	}
1697 
1698 	return (0);
1699 }
1700 
1701 /*
1702  * Discard the checkpoint from the given pool.
1703  */
1704 int
zpool_discard_checkpoint(zpool_handle_t * zhp)1705 zpool_discard_checkpoint(zpool_handle_t *zhp)
1706 {
1707 	libzfs_handle_t *hdl = zhp->zpool_hdl;
1708 	char errbuf[ERRBUFLEN];
1709 	int error;
1710 
1711 	error = lzc_pool_checkpoint_discard(zhp->zpool_name);
1712 	if (error != 0) {
1713 		(void) snprintf(errbuf, sizeof (errbuf), dgettext(TEXT_DOMAIN,
1714 		    "cannot discard checkpoint in '%s'"), zhp->zpool_name);
1715 		(void) zpool_standard_error(hdl, error, errbuf);
1716 		return (-1);
1717 	}
1718 
1719 	return (0);
1720 }
1721 
1722 /*
1723  * Add the given vdevs to the pool.  The caller must have already performed the
1724  * necessary verification to ensure that the vdev specification is well-formed.
1725  */
1726 int
zpool_add(zpool_handle_t * zhp,nvlist_t * nvroot,boolean_t check_ashift)1727 zpool_add(zpool_handle_t *zhp, nvlist_t *nvroot, boolean_t check_ashift)
1728 {
1729 	zfs_cmd_t zc = {"\0"};
1730 	int ret;
1731 	libzfs_handle_t *hdl = zhp->zpool_hdl;
1732 	char errbuf[ERRBUFLEN];
1733 	nvlist_t **spares, **l2cache;
1734 	uint_t nspares, nl2cache;
1735 
1736 	(void) snprintf(errbuf, sizeof (errbuf), dgettext(TEXT_DOMAIN,
1737 	    "cannot add to '%s'"), zhp->zpool_name);
1738 
1739 	if (zpool_get_prop_int(zhp, ZPOOL_PROP_VERSION, NULL) <
1740 	    SPA_VERSION_SPARES &&
1741 	    nvlist_lookup_nvlist_array(nvroot, ZPOOL_CONFIG_SPARES,
1742 	    &spares, &nspares) == 0) {
1743 		zfs_error_aux(hdl, dgettext(TEXT_DOMAIN, "pool must be "
1744 		    "upgraded to add hot spares"));
1745 		return (zfs_error(hdl, EZFS_BADVERSION, errbuf));
1746 	}
1747 
1748 	if (zpool_get_prop_int(zhp, ZPOOL_PROP_VERSION, NULL) <
1749 	    SPA_VERSION_L2CACHE &&
1750 	    nvlist_lookup_nvlist_array(nvroot, ZPOOL_CONFIG_L2CACHE,
1751 	    &l2cache, &nl2cache) == 0) {
1752 		zfs_error_aux(hdl, dgettext(TEXT_DOMAIN, "pool must be "
1753 		    "upgraded to add cache devices"));
1754 		return (zfs_error(hdl, EZFS_BADVERSION, errbuf));
1755 	}
1756 
1757 	zcmd_write_conf_nvlist(hdl, &zc, nvroot);
1758 	(void) strlcpy(zc.zc_name, zhp->zpool_name, sizeof (zc.zc_name));
1759 	zc.zc_flags = check_ashift;
1760 
1761 	if (zfs_ioctl(hdl, ZFS_IOC_VDEV_ADD, &zc) != 0) {
1762 		switch (errno) {
1763 		case EBUSY:
1764 			/*
1765 			 * This can happen if the user has specified the same
1766 			 * device multiple times.  We can't reliably detect this
1767 			 * until we try to add it and see we already have a
1768 			 * label.
1769 			 */
1770 			zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
1771 			    "one or more vdevs refer to the same device"));
1772 			(void) zfs_error(hdl, EZFS_BADDEV, errbuf);
1773 			break;
1774 
1775 		case EINVAL:
1776 
1777 			if (zpool_has_draid_vdev(nvroot) &&
1778 			    zfeature_lookup_name("draid", NULL) != 0) {
1779 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
1780 				    "dRAID vdevs are unsupported by the "
1781 				    "kernel"));
1782 			} else {
1783 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
1784 				    "invalid config; a pool with removing/"
1785 				    "removed vdevs does not support adding "
1786 				    "raidz or dRAID vdevs"));
1787 			}
1788 
1789 			(void) zfs_error(hdl, EZFS_BADDEV, errbuf);
1790 			break;
1791 
1792 		case EOVERFLOW:
1793 			/*
1794 			 * This occurs when one of the devices is below
1795 			 * SPA_MINDEVSIZE.  Unfortunately, we can't detect which
1796 			 * device was the problem device since there's no
1797 			 * reliable way to determine device size from userland.
1798 			 */
1799 			{
1800 				char buf[64];
1801 
1802 				zfs_nicebytes(SPA_MINDEVSIZE, buf,
1803 				    sizeof (buf));
1804 
1805 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
1806 				    "device is less than the minimum "
1807 				    "size (%s)"), buf);
1808 			}
1809 			(void) zfs_error(hdl, EZFS_BADDEV, errbuf);
1810 			break;
1811 
1812 		case ENOTSUP:
1813 			zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
1814 			    "pool must be upgraded to add these vdevs"));
1815 			(void) zfs_error(hdl, EZFS_BADVERSION, errbuf);
1816 			break;
1817 
1818 		default:
1819 			(void) zpool_standard_error(hdl, errno, errbuf);
1820 		}
1821 
1822 		ret = -1;
1823 	} else {
1824 		ret = 0;
1825 	}
1826 
1827 	zcmd_free_nvlists(&zc);
1828 
1829 	return (ret);
1830 }
1831 
1832 /*
1833  * Exports the pool from the system.  The caller must ensure that there are no
1834  * mounted datasets in the pool.
1835  */
1836 static int
zpool_export_common(zpool_handle_t * zhp,boolean_t force,boolean_t hardforce,const char * log_str)1837 zpool_export_common(zpool_handle_t *zhp, boolean_t force, boolean_t hardforce,
1838     const char *log_str)
1839 {
1840 	zfs_cmd_t zc = {"\0"};
1841 
1842 	(void) strlcpy(zc.zc_name, zhp->zpool_name, sizeof (zc.zc_name));
1843 	zc.zc_cookie = force;
1844 	zc.zc_guid = hardforce;
1845 	zc.zc_history = (uint64_t)(uintptr_t)log_str;
1846 
1847 	if (zfs_ioctl(zhp->zpool_hdl, ZFS_IOC_POOL_EXPORT, &zc) != 0) {
1848 		switch (errno) {
1849 		case EXDEV:
1850 			zfs_error_aux(zhp->zpool_hdl, dgettext(TEXT_DOMAIN,
1851 			    "use '-f' to override the following errors:\n"
1852 			    "'%s' has an active shared spare which could be"
1853 			    " used by other pools once '%s' is exported."),
1854 			    zhp->zpool_name, zhp->zpool_name);
1855 			return (zfs_error_fmt(zhp->zpool_hdl, EZFS_ACTIVE_SPARE,
1856 			    dgettext(TEXT_DOMAIN, "cannot export '%s'"),
1857 			    zhp->zpool_name));
1858 		default:
1859 			return (zpool_standard_error_fmt(zhp->zpool_hdl, errno,
1860 			    dgettext(TEXT_DOMAIN, "cannot export '%s'"),
1861 			    zhp->zpool_name));
1862 		}
1863 	}
1864 
1865 	return (0);
1866 }
1867 
1868 int
zpool_export(zpool_handle_t * zhp,boolean_t force,const char * log_str)1869 zpool_export(zpool_handle_t *zhp, boolean_t force, const char *log_str)
1870 {
1871 	return (zpool_export_common(zhp, force, B_FALSE, log_str));
1872 }
1873 
1874 int
zpool_export_force(zpool_handle_t * zhp,const char * log_str)1875 zpool_export_force(zpool_handle_t *zhp, const char *log_str)
1876 {
1877 	return (zpool_export_common(zhp, B_TRUE, B_TRUE, log_str));
1878 }
1879 
1880 static void
zpool_rewind_exclaim(libzfs_handle_t * hdl,const char * name,boolean_t dryrun,nvlist_t * config)1881 zpool_rewind_exclaim(libzfs_handle_t *hdl, const char *name, boolean_t dryrun,
1882     nvlist_t *config)
1883 {
1884 	nvlist_t *nv = NULL;
1885 	uint64_t rewindto;
1886 	int64_t loss = -1;
1887 	struct tm t;
1888 	char timestr[128];
1889 
1890 	if (!hdl->libzfs_printerr || config == NULL)
1891 		return;
1892 
1893 	if (nvlist_lookup_nvlist(config, ZPOOL_CONFIG_LOAD_INFO, &nv) != 0 ||
1894 	    nvlist_lookup_nvlist(nv, ZPOOL_CONFIG_REWIND_INFO, &nv) != 0) {
1895 		return;
1896 	}
1897 
1898 	if (nvlist_lookup_uint64(nv, ZPOOL_CONFIG_LOAD_TIME, &rewindto) != 0)
1899 		return;
1900 	(void) nvlist_lookup_int64(nv, ZPOOL_CONFIG_REWIND_TIME, &loss);
1901 
1902 	if (localtime_r((time_t *)&rewindto, &t) != NULL &&
1903 	    ctime_r((time_t *)&rewindto, timestr) != NULL) {
1904 		timestr[24] = 0;
1905 		if (dryrun) {
1906 			(void) printf(dgettext(TEXT_DOMAIN,
1907 			    "Would be able to return %s "
1908 			    "to its state as of %s.\n"),
1909 			    name, timestr);
1910 		} else {
1911 			(void) printf(dgettext(TEXT_DOMAIN,
1912 			    "Pool %s returned to its state as of %s.\n"),
1913 			    name, timestr);
1914 		}
1915 		if (loss > 120) {
1916 			(void) printf(dgettext(TEXT_DOMAIN,
1917 			    "%s approximately %lld "),
1918 			    dryrun ? "Would discard" : "Discarded",
1919 			    ((longlong_t)loss + 30) / 60);
1920 			(void) printf(dgettext(TEXT_DOMAIN,
1921 			    "minutes of transactions.\n"));
1922 		} else if (loss > 0) {
1923 			(void) printf(dgettext(TEXT_DOMAIN,
1924 			    "%s approximately %lld "),
1925 			    dryrun ? "Would discard" : "Discarded",
1926 			    (longlong_t)loss);
1927 			(void) printf(dgettext(TEXT_DOMAIN,
1928 			    "seconds of transactions.\n"));
1929 		}
1930 	}
1931 }
1932 
1933 void
zpool_explain_recover(libzfs_handle_t * hdl,const char * name,int reason,nvlist_t * config)1934 zpool_explain_recover(libzfs_handle_t *hdl, const char *name, int reason,
1935     nvlist_t *config)
1936 {
1937 	nvlist_t *nv = NULL;
1938 	int64_t loss = -1;
1939 	uint64_t edata = UINT64_MAX;
1940 	uint64_t rewindto;
1941 	struct tm t;
1942 	char timestr[128];
1943 
1944 	if (!hdl->libzfs_printerr)
1945 		return;
1946 
1947 	if (reason >= 0)
1948 		(void) printf(dgettext(TEXT_DOMAIN, "action: "));
1949 	else
1950 		(void) printf(dgettext(TEXT_DOMAIN, "\t"));
1951 
1952 	/* All attempted rewinds failed if ZPOOL_CONFIG_LOAD_TIME missing */
1953 	if (nvlist_lookup_nvlist(config, ZPOOL_CONFIG_LOAD_INFO, &nv) != 0 ||
1954 	    nvlist_lookup_nvlist(nv, ZPOOL_CONFIG_REWIND_INFO, &nv) != 0 ||
1955 	    nvlist_lookup_uint64(nv, ZPOOL_CONFIG_LOAD_TIME, &rewindto) != 0)
1956 		goto no_info;
1957 
1958 	(void) nvlist_lookup_int64(nv, ZPOOL_CONFIG_REWIND_TIME, &loss);
1959 	(void) nvlist_lookup_uint64(nv, ZPOOL_CONFIG_LOAD_DATA_ERRORS,
1960 	    &edata);
1961 
1962 	(void) printf(dgettext(TEXT_DOMAIN,
1963 	    "Recovery is possible, but will result in some data loss.\n"));
1964 
1965 	if (localtime_r((time_t *)&rewindto, &t) != NULL &&
1966 	    ctime_r((time_t *)&rewindto, timestr) != NULL) {
1967 		timestr[24] = 0;
1968 		(void) printf(dgettext(TEXT_DOMAIN,
1969 		    "\tReturning the pool to its state as of %s\n"
1970 		    "\tshould correct the problem.  "),
1971 		    timestr);
1972 	} else {
1973 		(void) printf(dgettext(TEXT_DOMAIN,
1974 		    "\tReverting the pool to an earlier state "
1975 		    "should correct the problem.\n\t"));
1976 	}
1977 
1978 	if (loss > 120) {
1979 		(void) printf(dgettext(TEXT_DOMAIN,
1980 		    "Approximately %lld minutes of data\n"
1981 		    "\tmust be discarded, irreversibly.  "),
1982 		    ((longlong_t)loss + 30) / 60);
1983 	} else if (loss > 0) {
1984 		(void) printf(dgettext(TEXT_DOMAIN,
1985 		    "Approximately %lld seconds of data\n"
1986 		    "\tmust be discarded, irreversibly.  "),
1987 		    (longlong_t)loss);
1988 	}
1989 	if (edata != 0 && edata != UINT64_MAX) {
1990 		if (edata == 1) {
1991 			(void) printf(dgettext(TEXT_DOMAIN,
1992 			    "After rewind, at least\n"
1993 			    "\tone persistent user-data error will remain.  "));
1994 		} else {
1995 			(void) printf(dgettext(TEXT_DOMAIN,
1996 			    "After rewind, several\n"
1997 			    "\tpersistent user-data errors will remain.  "));
1998 		}
1999 	}
2000 	(void) printf(dgettext(TEXT_DOMAIN,
2001 	    "Recovery can be attempted\n\tby executing 'zpool %s -F %s'.  "),
2002 	    reason >= 0 ? "clear" : "import", name);
2003 
2004 	(void) printf(dgettext(TEXT_DOMAIN,
2005 	    "A scrub of the pool\n"
2006 	    "\tis strongly recommended after recovery.\n"));
2007 	return;
2008 
2009 no_info:
2010 	(void) printf(dgettext(TEXT_DOMAIN,
2011 	    "Destroy and re-create the pool from\n\ta backup source.\n"));
2012 }
2013 
2014 /*
2015  * zpool_import() is a contracted interface. Should be kept the same
2016  * if possible.
2017  *
2018  * Applications should use zpool_import_props() to import a pool with
2019  * new properties value to be set.
2020  */
2021 int
zpool_import(libzfs_handle_t * hdl,nvlist_t * config,const char * newname,char * altroot)2022 zpool_import(libzfs_handle_t *hdl, nvlist_t *config, const char *newname,
2023     char *altroot)
2024 {
2025 	nvlist_t *props = NULL;
2026 	int ret;
2027 
2028 	if (altroot != NULL) {
2029 		if (nvlist_alloc(&props, NV_UNIQUE_NAME, 0) != 0) {
2030 			return (zfs_error_fmt(hdl, EZFS_NOMEM,
2031 			    dgettext(TEXT_DOMAIN, "cannot import '%s'"),
2032 			    newname));
2033 		}
2034 
2035 		if (nvlist_add_string(props,
2036 		    zpool_prop_to_name(ZPOOL_PROP_ALTROOT), altroot) != 0 ||
2037 		    nvlist_add_string(props,
2038 		    zpool_prop_to_name(ZPOOL_PROP_CACHEFILE), "none") != 0) {
2039 			nvlist_free(props);
2040 			return (zfs_error_fmt(hdl, EZFS_NOMEM,
2041 			    dgettext(TEXT_DOMAIN, "cannot import '%s'"),
2042 			    newname));
2043 		}
2044 	}
2045 
2046 	ret = zpool_import_props(hdl, config, newname, props,
2047 	    ZFS_IMPORT_NORMAL);
2048 	nvlist_free(props);
2049 	return (ret);
2050 }
2051 
2052 static void
print_vdev_tree(libzfs_handle_t * hdl,const char * name,nvlist_t * nv,int indent)2053 print_vdev_tree(libzfs_handle_t *hdl, const char *name, nvlist_t *nv,
2054     int indent)
2055 {
2056 	nvlist_t **child;
2057 	uint_t c, children;
2058 	char *vname;
2059 	uint64_t is_log = 0;
2060 
2061 	(void) nvlist_lookup_uint64(nv, ZPOOL_CONFIG_IS_LOG,
2062 	    &is_log);
2063 
2064 	if (name != NULL)
2065 		(void) printf("\t%*s%s%s\n", indent, "", name,
2066 		    is_log ? " [log]" : "");
2067 
2068 	if (nvlist_lookup_nvlist_array(nv, ZPOOL_CONFIG_CHILDREN,
2069 	    &child, &children) != 0)
2070 		return;
2071 
2072 	for (c = 0; c < children; c++) {
2073 		vname = zpool_vdev_name(hdl, NULL, child[c], VDEV_NAME_TYPE_ID);
2074 		print_vdev_tree(hdl, vname, child[c], indent + 2);
2075 		free(vname);
2076 	}
2077 }
2078 
2079 void
zpool_print_unsup_feat(nvlist_t * config)2080 zpool_print_unsup_feat(nvlist_t *config)
2081 {
2082 	nvlist_t *nvinfo, *unsup_feat;
2083 
2084 	nvinfo = fnvlist_lookup_nvlist(config, ZPOOL_CONFIG_LOAD_INFO);
2085 	unsup_feat = fnvlist_lookup_nvlist(nvinfo, ZPOOL_CONFIG_UNSUP_FEAT);
2086 
2087 	for (nvpair_t *nvp = nvlist_next_nvpair(unsup_feat, NULL);
2088 	    nvp != NULL; nvp = nvlist_next_nvpair(unsup_feat, nvp)) {
2089 		const char *desc = fnvpair_value_string(nvp);
2090 		if (strlen(desc) > 0)
2091 			(void) printf("\t%s (%s)\n", nvpair_name(nvp), desc);
2092 		else
2093 			(void) printf("\t%s\n", nvpair_name(nvp));
2094 	}
2095 }
2096 
2097 /*
2098  * Import the given pool using the known configuration and a list of
2099  * properties to be set. The configuration should have come from
2100  * zpool_find_import(). The 'newname' parameters control whether the pool
2101  * is imported with a different name.
2102  */
2103 int
zpool_import_props(libzfs_handle_t * hdl,nvlist_t * config,const char * newname,nvlist_t * props,int flags)2104 zpool_import_props(libzfs_handle_t *hdl, nvlist_t *config, const char *newname,
2105     nvlist_t *props, int flags)
2106 {
2107 	zfs_cmd_t zc = {"\0"};
2108 	zpool_load_policy_t policy;
2109 	nvlist_t *nv = NULL;
2110 	nvlist_t *nvinfo = NULL;
2111 	nvlist_t *missing = NULL;
2112 	const char *thename;
2113 	const char *origname;
2114 	int ret;
2115 	int error = 0;
2116 	char errbuf[ERRBUFLEN];
2117 
2118 	origname = fnvlist_lookup_string(config, ZPOOL_CONFIG_POOL_NAME);
2119 
2120 	(void) snprintf(errbuf, sizeof (errbuf), dgettext(TEXT_DOMAIN,
2121 	    "cannot import pool '%s'"), origname);
2122 
2123 	if (newname != NULL) {
2124 		if (!zpool_name_valid(hdl, B_FALSE, newname))
2125 			return (zfs_error_fmt(hdl, EZFS_INVALIDNAME,
2126 			    dgettext(TEXT_DOMAIN, "cannot import '%s'"),
2127 			    newname));
2128 		thename = newname;
2129 	} else {
2130 		thename = origname;
2131 	}
2132 
2133 	if (props != NULL) {
2134 		uint64_t version;
2135 		prop_flags_t flags = { .create = B_FALSE, .import = B_TRUE };
2136 
2137 		version = fnvlist_lookup_uint64(config, ZPOOL_CONFIG_VERSION);
2138 
2139 		if ((props = zpool_valid_proplist(hdl, origname,
2140 		    props, version, flags, errbuf)) == NULL)
2141 			return (-1);
2142 		zcmd_write_src_nvlist(hdl, &zc, props);
2143 		nvlist_free(props);
2144 	}
2145 
2146 	(void) strlcpy(zc.zc_name, thename, sizeof (zc.zc_name));
2147 
2148 	zc.zc_guid = fnvlist_lookup_uint64(config, ZPOOL_CONFIG_POOL_GUID);
2149 
2150 	zcmd_write_conf_nvlist(hdl, &zc, config);
2151 	zcmd_alloc_dst_nvlist(hdl, &zc, zc.zc_nvlist_conf_size * 2);
2152 
2153 	zc.zc_cookie = flags;
2154 	while ((ret = zfs_ioctl(hdl, ZFS_IOC_POOL_IMPORT, &zc)) != 0 &&
2155 	    errno == ENOMEM)
2156 		zcmd_expand_dst_nvlist(hdl, &zc);
2157 	if (ret != 0)
2158 		error = errno;
2159 
2160 	(void) zcmd_read_dst_nvlist(hdl, &zc, &nv);
2161 
2162 	zcmd_free_nvlists(&zc);
2163 
2164 	zpool_get_load_policy(config, &policy);
2165 
2166 	if (error) {
2167 		char desc[1024];
2168 		char aux[256];
2169 
2170 		/*
2171 		 * Dry-run failed, but we print out what success
2172 		 * looks like if we found a best txg
2173 		 */
2174 		if (policy.zlp_rewind & ZPOOL_TRY_REWIND) {
2175 			zpool_rewind_exclaim(hdl, newname ? origname : thename,
2176 			    B_TRUE, nv);
2177 			nvlist_free(nv);
2178 			return (-1);
2179 		}
2180 
2181 		if (newname == NULL)
2182 			(void) snprintf(desc, sizeof (desc),
2183 			    dgettext(TEXT_DOMAIN, "cannot import '%s'"),
2184 			    thename);
2185 		else
2186 			(void) snprintf(desc, sizeof (desc),
2187 			    dgettext(TEXT_DOMAIN, "cannot import '%s' as '%s'"),
2188 			    origname, thename);
2189 
2190 		switch (error) {
2191 		case ENOTSUP:
2192 			if (nv != NULL && nvlist_lookup_nvlist(nv,
2193 			    ZPOOL_CONFIG_LOAD_INFO, &nvinfo) == 0 &&
2194 			    nvlist_exists(nvinfo, ZPOOL_CONFIG_UNSUP_FEAT)) {
2195 				(void) printf(dgettext(TEXT_DOMAIN, "This "
2196 				    "pool uses the following feature(s) not "
2197 				    "supported by this system:\n"));
2198 				zpool_print_unsup_feat(nv);
2199 				if (nvlist_exists(nvinfo,
2200 				    ZPOOL_CONFIG_CAN_RDONLY)) {
2201 					(void) printf(dgettext(TEXT_DOMAIN,
2202 					    "All unsupported features are only "
2203 					    "required for writing to the pool."
2204 					    "\nThe pool can be imported using "
2205 					    "'-o readonly=on'.\n"));
2206 				}
2207 			}
2208 			/*
2209 			 * Unsupported version.
2210 			 */
2211 			(void) zfs_error(hdl, EZFS_BADVERSION, desc);
2212 			break;
2213 
2214 		case EREMOTEIO:
2215 			if (nv != NULL && nvlist_lookup_nvlist(nv,
2216 			    ZPOOL_CONFIG_LOAD_INFO, &nvinfo) == 0) {
2217 				const char *hostname = "<unknown>";
2218 				uint64_t hostid = 0;
2219 				mmp_state_t mmp_state;
2220 
2221 				mmp_state = fnvlist_lookup_uint64(nvinfo,
2222 				    ZPOOL_CONFIG_MMP_STATE);
2223 
2224 				if (nvlist_exists(nvinfo,
2225 				    ZPOOL_CONFIG_MMP_HOSTNAME))
2226 					hostname = fnvlist_lookup_string(nvinfo,
2227 					    ZPOOL_CONFIG_MMP_HOSTNAME);
2228 
2229 				if (nvlist_exists(nvinfo,
2230 				    ZPOOL_CONFIG_MMP_HOSTID))
2231 					hostid = fnvlist_lookup_uint64(nvinfo,
2232 					    ZPOOL_CONFIG_MMP_HOSTID);
2233 
2234 				if (mmp_state == MMP_STATE_ACTIVE) {
2235 					(void) snprintf(aux, sizeof (aux),
2236 					    dgettext(TEXT_DOMAIN, "pool is imp"
2237 					    "orted on host '%s' (hostid=%lx).\n"
2238 					    "Export the pool on the other "
2239 					    "system, then run 'zpool import'."),
2240 					    hostname, (unsigned long) hostid);
2241 				} else if (mmp_state == MMP_STATE_NO_HOSTID) {
2242 					(void) snprintf(aux, sizeof (aux),
2243 					    dgettext(TEXT_DOMAIN, "pool has "
2244 					    "the multihost property on and "
2245 					    "the\nsystem's hostid is not set. "
2246 					    "Set a unique system hostid with "
2247 					    "the zgenhostid(8) command.\n"));
2248 				}
2249 
2250 				(void) zfs_error_aux(hdl, "%s", aux);
2251 			}
2252 			(void) zfs_error(hdl, EZFS_ACTIVE_POOL, desc);
2253 			break;
2254 
2255 		case EINVAL:
2256 			(void) zfs_error(hdl, EZFS_INVALCONFIG, desc);
2257 			break;
2258 
2259 		case EROFS:
2260 			zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
2261 			    "one or more devices is read only"));
2262 			(void) zfs_error(hdl, EZFS_BADDEV, desc);
2263 			break;
2264 
2265 		case ENXIO:
2266 			if (nv && nvlist_lookup_nvlist(nv,
2267 			    ZPOOL_CONFIG_LOAD_INFO, &nvinfo) == 0 &&
2268 			    nvlist_lookup_nvlist(nvinfo,
2269 			    ZPOOL_CONFIG_MISSING_DEVICES, &missing) == 0) {
2270 				(void) printf(dgettext(TEXT_DOMAIN,
2271 				    "The devices below are missing or "
2272 				    "corrupted, use '-m' to import the pool "
2273 				    "anyway:\n"));
2274 				print_vdev_tree(hdl, NULL, missing, 2);
2275 				(void) printf("\n");
2276 			}
2277 			(void) zpool_standard_error(hdl, error, desc);
2278 			break;
2279 
2280 		case EEXIST:
2281 			(void) zpool_standard_error(hdl, error, desc);
2282 			break;
2283 
2284 		case EBUSY:
2285 			zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
2286 			    "one or more devices are already in use\n"));
2287 			(void) zfs_error(hdl, EZFS_BADDEV, desc);
2288 			break;
2289 		case ENAMETOOLONG:
2290 			zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
2291 			    "new name of at least one dataset is longer than "
2292 			    "the maximum allowable length"));
2293 			(void) zfs_error(hdl, EZFS_NAMETOOLONG, desc);
2294 			break;
2295 		default:
2296 			(void) zpool_standard_error(hdl, error, desc);
2297 			zpool_explain_recover(hdl,
2298 			    newname ? origname : thename, -error, nv);
2299 			break;
2300 		}
2301 
2302 		nvlist_free(nv);
2303 		ret = -1;
2304 	} else {
2305 		zpool_handle_t *zhp;
2306 
2307 		/*
2308 		 * This should never fail, but play it safe anyway.
2309 		 */
2310 		if (zpool_open_silent(hdl, thename, &zhp) != 0)
2311 			ret = -1;
2312 		else if (zhp != NULL)
2313 			zpool_close(zhp);
2314 		if (policy.zlp_rewind &
2315 		    (ZPOOL_DO_REWIND | ZPOOL_TRY_REWIND)) {
2316 			zpool_rewind_exclaim(hdl, newname ? origname : thename,
2317 			    ((policy.zlp_rewind & ZPOOL_TRY_REWIND) != 0), nv);
2318 		}
2319 		nvlist_free(nv);
2320 	}
2321 
2322 	return (ret);
2323 }
2324 
2325 /*
2326  * Translate vdev names to guids.  If a vdev_path is determined to be
2327  * unsuitable then a vd_errlist is allocated and the vdev path and errno
2328  * are added to it.
2329  */
2330 static int
zpool_translate_vdev_guids(zpool_handle_t * zhp,nvlist_t * vds,nvlist_t * vdev_guids,nvlist_t * guids_to_paths,nvlist_t ** vd_errlist)2331 zpool_translate_vdev_guids(zpool_handle_t *zhp, nvlist_t *vds,
2332     nvlist_t *vdev_guids, nvlist_t *guids_to_paths, nvlist_t **vd_errlist)
2333 {
2334 	nvlist_t *errlist = NULL;
2335 	int error = 0;
2336 
2337 	for (nvpair_t *elem = nvlist_next_nvpair(vds, NULL); elem != NULL;
2338 	    elem = nvlist_next_nvpair(vds, elem)) {
2339 		boolean_t spare, cache;
2340 
2341 		const char *vd_path = nvpair_name(elem);
2342 		nvlist_t *tgt = zpool_find_vdev(zhp, vd_path, &spare, &cache,
2343 		    NULL);
2344 
2345 		if ((tgt == NULL) || cache || spare) {
2346 			if (errlist == NULL) {
2347 				errlist = fnvlist_alloc();
2348 				error = EINVAL;
2349 			}
2350 
2351 			uint64_t err = (tgt == NULL) ? EZFS_NODEVICE :
2352 			    (spare ? EZFS_ISSPARE : EZFS_ISL2CACHE);
2353 			fnvlist_add_int64(errlist, vd_path, err);
2354 			continue;
2355 		}
2356 
2357 		uint64_t guid = fnvlist_lookup_uint64(tgt, ZPOOL_CONFIG_GUID);
2358 		fnvlist_add_uint64(vdev_guids, vd_path, guid);
2359 
2360 		char msg[MAXNAMELEN];
2361 		(void) snprintf(msg, sizeof (msg), "%llu", (u_longlong_t)guid);
2362 		fnvlist_add_string(guids_to_paths, msg, vd_path);
2363 	}
2364 
2365 	if (error != 0) {
2366 		verify(errlist != NULL);
2367 		if (vd_errlist != NULL)
2368 			*vd_errlist = errlist;
2369 		else
2370 			fnvlist_free(errlist);
2371 	}
2372 
2373 	return (error);
2374 }
2375 
2376 static int
xlate_init_err(int err)2377 xlate_init_err(int err)
2378 {
2379 	switch (err) {
2380 	case ENODEV:
2381 		return (EZFS_NODEVICE);
2382 	case EINVAL:
2383 	case EROFS:
2384 		return (EZFS_BADDEV);
2385 	case EBUSY:
2386 		return (EZFS_INITIALIZING);
2387 	case ESRCH:
2388 		return (EZFS_NO_INITIALIZE);
2389 	}
2390 	return (err);
2391 }
2392 
2393 /*
2394  * Begin, suspend, cancel, or uninit (clear) the initialization (initializing
2395  * of all free blocks) for the given vdevs in the given pool.
2396  */
2397 static int
zpool_initialize_impl(zpool_handle_t * zhp,pool_initialize_func_t cmd_type,nvlist_t * vds,boolean_t wait)2398 zpool_initialize_impl(zpool_handle_t *zhp, pool_initialize_func_t cmd_type,
2399     nvlist_t *vds, boolean_t wait)
2400 {
2401 	int err;
2402 
2403 	nvlist_t *vdev_guids = fnvlist_alloc();
2404 	nvlist_t *guids_to_paths = fnvlist_alloc();
2405 	nvlist_t *vd_errlist = NULL;
2406 	nvlist_t *errlist;
2407 	nvpair_t *elem;
2408 
2409 	err = zpool_translate_vdev_guids(zhp, vds, vdev_guids,
2410 	    guids_to_paths, &vd_errlist);
2411 
2412 	if (err != 0) {
2413 		verify(vd_errlist != NULL);
2414 		goto list_errors;
2415 	}
2416 
2417 	err = lzc_initialize(zhp->zpool_name, cmd_type,
2418 	    vdev_guids, &errlist);
2419 
2420 	if (err != 0) {
2421 		if (errlist != NULL && nvlist_lookup_nvlist(errlist,
2422 		    ZPOOL_INITIALIZE_VDEVS, &vd_errlist) == 0) {
2423 			goto list_errors;
2424 		}
2425 
2426 		if (err == EINVAL && cmd_type == POOL_INITIALIZE_UNINIT) {
2427 			zfs_error_aux(zhp->zpool_hdl, dgettext(TEXT_DOMAIN,
2428 			    "uninitialize is not supported by kernel"));
2429 		}
2430 
2431 		(void) zpool_standard_error(zhp->zpool_hdl, err,
2432 		    dgettext(TEXT_DOMAIN, "operation failed"));
2433 		goto out;
2434 	}
2435 
2436 	if (wait) {
2437 		for (elem = nvlist_next_nvpair(vdev_guids, NULL); elem != NULL;
2438 		    elem = nvlist_next_nvpair(vdev_guids, elem)) {
2439 
2440 			uint64_t guid = fnvpair_value_uint64(elem);
2441 
2442 			err = lzc_wait_tag(zhp->zpool_name,
2443 			    ZPOOL_WAIT_INITIALIZE, guid, NULL);
2444 			if (err != 0) {
2445 				(void) zpool_standard_error_fmt(zhp->zpool_hdl,
2446 				    err, dgettext(TEXT_DOMAIN, "error "
2447 				    "waiting for '%s' to initialize"),
2448 				    nvpair_name(elem));
2449 
2450 				goto out;
2451 			}
2452 		}
2453 	}
2454 	goto out;
2455 
2456 list_errors:
2457 	for (elem = nvlist_next_nvpair(vd_errlist, NULL); elem != NULL;
2458 	    elem = nvlist_next_nvpair(vd_errlist, elem)) {
2459 		int64_t vd_error = xlate_init_err(fnvpair_value_int64(elem));
2460 		const char *path;
2461 
2462 		if (nvlist_lookup_string(guids_to_paths, nvpair_name(elem),
2463 		    &path) != 0)
2464 			path = nvpair_name(elem);
2465 
2466 		(void) zfs_error_fmt(zhp->zpool_hdl, vd_error,
2467 		    "cannot initialize '%s'", path);
2468 	}
2469 
2470 out:
2471 	fnvlist_free(vdev_guids);
2472 	fnvlist_free(guids_to_paths);
2473 
2474 	if (vd_errlist != NULL)
2475 		fnvlist_free(vd_errlist);
2476 
2477 	return (err == 0 ? 0 : -1);
2478 }
2479 
2480 int
zpool_initialize(zpool_handle_t * zhp,pool_initialize_func_t cmd_type,nvlist_t * vds)2481 zpool_initialize(zpool_handle_t *zhp, pool_initialize_func_t cmd_type,
2482     nvlist_t *vds)
2483 {
2484 	return (zpool_initialize_impl(zhp, cmd_type, vds, B_FALSE));
2485 }
2486 
2487 int
zpool_initialize_wait(zpool_handle_t * zhp,pool_initialize_func_t cmd_type,nvlist_t * vds)2488 zpool_initialize_wait(zpool_handle_t *zhp, pool_initialize_func_t cmd_type,
2489     nvlist_t *vds)
2490 {
2491 	return (zpool_initialize_impl(zhp, cmd_type, vds, B_TRUE));
2492 }
2493 
2494 static int
xlate_trim_err(int err)2495 xlate_trim_err(int err)
2496 {
2497 	switch (err) {
2498 	case ENODEV:
2499 		return (EZFS_NODEVICE);
2500 	case EINVAL:
2501 	case EROFS:
2502 		return (EZFS_BADDEV);
2503 	case EBUSY:
2504 		return (EZFS_TRIMMING);
2505 	case ESRCH:
2506 		return (EZFS_NO_TRIM);
2507 	case EOPNOTSUPP:
2508 		return (EZFS_TRIM_NOTSUP);
2509 	}
2510 	return (err);
2511 }
2512 
2513 static int
zpool_trim_wait(zpool_handle_t * zhp,nvlist_t * vdev_guids)2514 zpool_trim_wait(zpool_handle_t *zhp, nvlist_t *vdev_guids)
2515 {
2516 	int err;
2517 	nvpair_t *elem;
2518 
2519 	for (elem = nvlist_next_nvpair(vdev_guids, NULL); elem != NULL;
2520 	    elem = nvlist_next_nvpair(vdev_guids, elem)) {
2521 
2522 		uint64_t guid = fnvpair_value_uint64(elem);
2523 
2524 		err = lzc_wait_tag(zhp->zpool_name,
2525 		    ZPOOL_WAIT_TRIM, guid, NULL);
2526 		if (err != 0) {
2527 			(void) zpool_standard_error_fmt(zhp->zpool_hdl,
2528 			    err, dgettext(TEXT_DOMAIN, "error "
2529 			    "waiting to trim '%s'"), nvpair_name(elem));
2530 
2531 			return (err);
2532 		}
2533 	}
2534 	return (0);
2535 }
2536 
2537 /*
2538  * Check errlist and report any errors, omitting ones which should be
2539  * suppressed. Returns B_TRUE if any errors were reported.
2540  */
2541 static boolean_t
check_trim_errs(zpool_handle_t * zhp,trimflags_t * trim_flags,nvlist_t * guids_to_paths,nvlist_t * vds,nvlist_t * errlist)2542 check_trim_errs(zpool_handle_t *zhp, trimflags_t *trim_flags,
2543     nvlist_t *guids_to_paths, nvlist_t *vds, nvlist_t *errlist)
2544 {
2545 	nvpair_t *elem;
2546 	boolean_t reported_errs = B_FALSE;
2547 	int num_vds = 0;
2548 	int num_suppressed_errs = 0;
2549 
2550 	for (elem = nvlist_next_nvpair(vds, NULL);
2551 	    elem != NULL; elem = nvlist_next_nvpair(vds, elem)) {
2552 		num_vds++;
2553 	}
2554 
2555 	for (elem = nvlist_next_nvpair(errlist, NULL);
2556 	    elem != NULL; elem = nvlist_next_nvpair(errlist, elem)) {
2557 		int64_t vd_error = xlate_trim_err(fnvpair_value_int64(elem));
2558 		const char *path;
2559 
2560 		/*
2561 		 * If only the pool was specified, and it was not a secure
2562 		 * trim then suppress warnings for individual vdevs which
2563 		 * do not support trimming.
2564 		 */
2565 		if (vd_error == EZFS_TRIM_NOTSUP &&
2566 		    trim_flags->fullpool &&
2567 		    !trim_flags->secure) {
2568 			num_suppressed_errs++;
2569 			continue;
2570 		}
2571 
2572 		reported_errs = B_TRUE;
2573 		if (nvlist_lookup_string(guids_to_paths, nvpair_name(elem),
2574 		    &path) != 0)
2575 			path = nvpair_name(elem);
2576 
2577 		(void) zfs_error_fmt(zhp->zpool_hdl, vd_error,
2578 		    "cannot trim '%s'", path);
2579 	}
2580 
2581 	if (num_suppressed_errs == num_vds) {
2582 		(void) zfs_error_aux(zhp->zpool_hdl, dgettext(TEXT_DOMAIN,
2583 		    "no devices in pool support trim operations"));
2584 		(void) (zfs_error(zhp->zpool_hdl, EZFS_TRIM_NOTSUP,
2585 		    dgettext(TEXT_DOMAIN, "cannot trim")));
2586 		reported_errs = B_TRUE;
2587 	}
2588 
2589 	return (reported_errs);
2590 }
2591 
2592 /*
2593  * Begin, suspend, or cancel the TRIM (discarding of all free blocks) for
2594  * the given vdevs in the given pool.
2595  */
2596 int
zpool_trim(zpool_handle_t * zhp,pool_trim_func_t cmd_type,nvlist_t * vds,trimflags_t * trim_flags)2597 zpool_trim(zpool_handle_t *zhp, pool_trim_func_t cmd_type, nvlist_t *vds,
2598     trimflags_t *trim_flags)
2599 {
2600 	int err;
2601 	int retval = 0;
2602 
2603 	nvlist_t *vdev_guids = fnvlist_alloc();
2604 	nvlist_t *guids_to_paths = fnvlist_alloc();
2605 	nvlist_t *errlist = NULL;
2606 
2607 	err = zpool_translate_vdev_guids(zhp, vds, vdev_guids,
2608 	    guids_to_paths, &errlist);
2609 	if (err != 0) {
2610 		check_trim_errs(zhp, trim_flags, guids_to_paths, vds, errlist);
2611 		retval = -1;
2612 		goto out;
2613 	}
2614 
2615 	err = lzc_trim(zhp->zpool_name, cmd_type, trim_flags->rate,
2616 	    trim_flags->secure, vdev_guids, &errlist);
2617 	if (err != 0) {
2618 		nvlist_t *vd_errlist;
2619 		if (errlist != NULL && nvlist_lookup_nvlist(errlist,
2620 		    ZPOOL_TRIM_VDEVS, &vd_errlist) == 0) {
2621 			if (check_trim_errs(zhp, trim_flags, guids_to_paths,
2622 			    vds, vd_errlist)) {
2623 				retval = -1;
2624 				goto out;
2625 			}
2626 		} else {
2627 			char errbuf[ERRBUFLEN];
2628 
2629 			(void) snprintf(errbuf, sizeof (errbuf),
2630 			    dgettext(TEXT_DOMAIN, "operation failed"));
2631 			zpool_standard_error(zhp->zpool_hdl, err, errbuf);
2632 			retval = -1;
2633 			goto out;
2634 		}
2635 	}
2636 
2637 
2638 	if (trim_flags->wait)
2639 		retval = zpool_trim_wait(zhp, vdev_guids);
2640 
2641 out:
2642 	if (errlist != NULL)
2643 		fnvlist_free(errlist);
2644 	fnvlist_free(vdev_guids);
2645 	fnvlist_free(guids_to_paths);
2646 	return (retval);
2647 }
2648 
2649 /*
2650  * Scan the pool.
2651  */
2652 int
zpool_scan(zpool_handle_t * zhp,pool_scan_func_t func,pool_scrub_cmd_t cmd)2653 zpool_scan(zpool_handle_t *zhp, pool_scan_func_t func, pool_scrub_cmd_t cmd)
2654 {
2655 	char errbuf[ERRBUFLEN];
2656 	int err;
2657 	libzfs_handle_t *hdl = zhp->zpool_hdl;
2658 
2659 	nvlist_t *args = fnvlist_alloc();
2660 	fnvlist_add_uint64(args, "scan_type", (uint64_t)func);
2661 	fnvlist_add_uint64(args, "scan_command", (uint64_t)cmd);
2662 
2663 	err = lzc_scrub(ZFS_IOC_POOL_SCRUB, zhp->zpool_name, args, NULL);
2664 	fnvlist_free(args);
2665 
2666 	if (err == 0) {
2667 		return (0);
2668 	} else if (err == ZFS_ERR_IOC_CMD_UNAVAIL) {
2669 		zfs_cmd_t zc = {"\0"};
2670 		(void) strlcpy(zc.zc_name, zhp->zpool_name,
2671 		    sizeof (zc.zc_name));
2672 		zc.zc_cookie = func;
2673 		zc.zc_flags = cmd;
2674 
2675 		if (zfs_ioctl(hdl, ZFS_IOC_POOL_SCAN, &zc) == 0)
2676 			return (0);
2677 	}
2678 
2679 	/*
2680 	 * An ECANCELED on a scrub means one of the following:
2681 	 * 1. we resumed a paused scrub.
2682 	 * 2. we resumed a paused error scrub.
2683 	 * 3. Error scrub is not run because of no error log.
2684 	 */
2685 	if (err == ECANCELED && (func == POOL_SCAN_SCRUB ||
2686 	    func == POOL_SCAN_ERRORSCRUB) && cmd == POOL_SCRUB_NORMAL)
2687 		return (0);
2688 	/*
2689 	 * The following cases have been handled here:
2690 	 * 1. Paused a scrub/error scrub if there is none in progress.
2691 	 */
2692 	if (err == ENOENT && func != POOL_SCAN_NONE && cmd ==
2693 	    POOL_SCRUB_PAUSE) {
2694 		return (0);
2695 	}
2696 
2697 	ASSERT3U(func, >=, POOL_SCAN_NONE);
2698 	ASSERT3U(func, <, POOL_SCAN_FUNCS);
2699 
2700 	if (func == POOL_SCAN_SCRUB || func == POOL_SCAN_ERRORSCRUB) {
2701 		if (cmd == POOL_SCRUB_PAUSE) {
2702 			(void) snprintf(errbuf, sizeof (errbuf),
2703 			    dgettext(TEXT_DOMAIN, "cannot pause scrubbing %s"),
2704 			    zhp->zpool_name);
2705 		} else {
2706 			assert(cmd == POOL_SCRUB_NORMAL);
2707 			(void) snprintf(errbuf, sizeof (errbuf),
2708 			    dgettext(TEXT_DOMAIN, "cannot scrub %s"),
2709 			    zhp->zpool_name);
2710 		}
2711 	} else if (func == POOL_SCAN_RESILVER) {
2712 		assert(cmd == POOL_SCRUB_NORMAL);
2713 		(void) snprintf(errbuf, sizeof (errbuf), dgettext(TEXT_DOMAIN,
2714 		    "cannot restart resilver on %s"), zhp->zpool_name);
2715 	} else if (func == POOL_SCAN_NONE) {
2716 		(void) snprintf(errbuf, sizeof (errbuf), dgettext(TEXT_DOMAIN,
2717 		    "cannot cancel scrubbing %s"), zhp->zpool_name);
2718 	} else {
2719 		assert(!"unexpected result");
2720 	}
2721 
2722 	/*
2723 	 * With EBUSY, five cases are possible:
2724 	 *
2725 	 * Current state		Requested
2726 	 * 1. Normal Scrub Running	Normal Scrub or Error Scrub
2727 	 * 2. Normal Scrub Paused	Error Scrub
2728 	 * 3. Normal Scrub Paused 	Pause Normal Scrub
2729 	 * 4. Error Scrub Running	Normal Scrub or Error Scrub
2730 	 * 5. Error Scrub Paused	Pause Error Scrub
2731 	 * 6. Resilvering		Anything else
2732 	 */
2733 	if (err == EBUSY) {
2734 		nvlist_t *nvroot;
2735 		pool_scan_stat_t *ps = NULL;
2736 		uint_t psc;
2737 
2738 		nvroot = fnvlist_lookup_nvlist(zhp->zpool_config,
2739 		    ZPOOL_CONFIG_VDEV_TREE);
2740 		(void) nvlist_lookup_uint64_array(nvroot,
2741 		    ZPOOL_CONFIG_SCAN_STATS, (uint64_t **)&ps, &psc);
2742 		if (ps && ps->pss_func == POOL_SCAN_SCRUB &&
2743 		    ps->pss_state == DSS_SCANNING) {
2744 			if (ps->pss_pass_scrub_pause == 0) {
2745 				/* handles case 1 */
2746 				assert(cmd == POOL_SCRUB_NORMAL);
2747 				return (zfs_error(hdl, EZFS_SCRUBBING,
2748 				    errbuf));
2749 			} else {
2750 				if (func == POOL_SCAN_ERRORSCRUB) {
2751 					/* handles case 2 */
2752 					ASSERT3U(cmd, ==, POOL_SCRUB_NORMAL);
2753 					return (zfs_error(hdl,
2754 					    EZFS_SCRUB_PAUSED_TO_CANCEL,
2755 					    errbuf));
2756 				} else {
2757 					/* handles case 3 */
2758 					ASSERT3U(func, ==, POOL_SCAN_SCRUB);
2759 					ASSERT3U(cmd, ==, POOL_SCRUB_PAUSE);
2760 					return (zfs_error(hdl,
2761 					    EZFS_SCRUB_PAUSED, errbuf));
2762 				}
2763 			}
2764 		} else if (ps &&
2765 		    ps->pss_error_scrub_func == POOL_SCAN_ERRORSCRUB &&
2766 		    ps->pss_error_scrub_state == DSS_ERRORSCRUBBING) {
2767 			if (ps->pss_pass_error_scrub_pause == 0) {
2768 				/* handles case 4 */
2769 				ASSERT3U(cmd, ==, POOL_SCRUB_NORMAL);
2770 				return (zfs_error(hdl, EZFS_ERRORSCRUBBING,
2771 				    errbuf));
2772 			} else {
2773 				/* handles case 5 */
2774 				ASSERT3U(func, ==, POOL_SCAN_ERRORSCRUB);
2775 				ASSERT3U(cmd, ==, POOL_SCRUB_PAUSE);
2776 				return (zfs_error(hdl, EZFS_ERRORSCRUB_PAUSED,
2777 				    errbuf));
2778 			}
2779 		} else {
2780 			/* handles case 6 */
2781 			return (zfs_error(hdl, EZFS_RESILVERING, errbuf));
2782 		}
2783 	} else if (err == ENOENT) {
2784 		return (zfs_error(hdl, EZFS_NO_SCRUB, errbuf));
2785 	} else if (err == ENOTSUP && func == POOL_SCAN_RESILVER) {
2786 		return (zfs_error(hdl, EZFS_NO_RESILVER_DEFER, errbuf));
2787 	} else {
2788 		return (zpool_standard_error(hdl, err, errbuf));
2789 	}
2790 }
2791 
2792 /*
2793  * Find a vdev that matches the search criteria specified. We use the
2794  * the nvpair name to determine how we should look for the device.
2795  * 'avail_spare' is set to TRUE if the provided guid refers to an AVAIL
2796  * spare; but FALSE if its an INUSE spare.
2797  */
2798 static nvlist_t *
vdev_to_nvlist_iter(nvlist_t * nv,nvlist_t * search,boolean_t * avail_spare,boolean_t * l2cache,boolean_t * log)2799 vdev_to_nvlist_iter(nvlist_t *nv, nvlist_t *search, boolean_t *avail_spare,
2800     boolean_t *l2cache, boolean_t *log)
2801 {
2802 	uint_t c, children;
2803 	nvlist_t **child;
2804 	nvlist_t *ret;
2805 	uint64_t is_log;
2806 	const char *srchkey;
2807 	nvpair_t *pair = nvlist_next_nvpair(search, NULL);
2808 
2809 	/* Nothing to look for */
2810 	if (search == NULL || pair == NULL)
2811 		return (NULL);
2812 
2813 	/* Obtain the key we will use to search */
2814 	srchkey = nvpair_name(pair);
2815 
2816 	switch (nvpair_type(pair)) {
2817 	case DATA_TYPE_UINT64:
2818 		if (strcmp(srchkey, ZPOOL_CONFIG_GUID) == 0) {
2819 			uint64_t srchval = fnvpair_value_uint64(pair);
2820 			uint64_t theguid = fnvlist_lookup_uint64(nv,
2821 			    ZPOOL_CONFIG_GUID);
2822 			if (theguid == srchval)
2823 				return (nv);
2824 		}
2825 		break;
2826 
2827 	case DATA_TYPE_STRING: {
2828 		const char *srchval, *val;
2829 
2830 		srchval = fnvpair_value_string(pair);
2831 		if (nvlist_lookup_string(nv, srchkey, &val) != 0)
2832 			break;
2833 
2834 		/*
2835 		 * Search for the requested value. Special cases:
2836 		 *
2837 		 * - ZPOOL_CONFIG_PATH for whole disk entries.  These end in
2838 		 *   "-part1", or "p1".  The suffix is hidden from the user,
2839 		 *   but included in the string, so this matches around it.
2840 		 * - ZPOOL_CONFIG_PATH for short names zfs_strcmp_shortname()
2841 		 *   is used to check all possible expanded paths.
2842 		 * - looking for a top-level vdev name (i.e. ZPOOL_CONFIG_TYPE).
2843 		 *
2844 		 * Otherwise, all other searches are simple string compares.
2845 		 */
2846 		if (strcmp(srchkey, ZPOOL_CONFIG_PATH) == 0) {
2847 			uint64_t wholedisk = 0;
2848 
2849 			(void) nvlist_lookup_uint64(nv, ZPOOL_CONFIG_WHOLE_DISK,
2850 			    &wholedisk);
2851 			if (zfs_strcmp_pathname(srchval, val, wholedisk) == 0)
2852 				return (nv);
2853 
2854 		} else if (strcmp(srchkey, ZPOOL_CONFIG_TYPE) == 0) {
2855 			char *type, *idx, *end, *p;
2856 			uint64_t id, vdev_id;
2857 
2858 			/*
2859 			 * Determine our vdev type, keeping in mind
2860 			 * that the srchval is composed of a type and
2861 			 * vdev id pair (i.e. mirror-4).
2862 			 */
2863 			if ((type = strdup(srchval)) == NULL)
2864 				return (NULL);
2865 
2866 			if ((p = strrchr(type, '-')) == NULL) {
2867 				free(type);
2868 				break;
2869 			}
2870 			idx = p + 1;
2871 			*p = '\0';
2872 
2873 			/*
2874 			 * If the types don't match then keep looking.
2875 			 */
2876 			if (strncmp(val, type, strlen(val)) != 0) {
2877 				free(type);
2878 				break;
2879 			}
2880 
2881 			verify(zpool_vdev_is_interior(type));
2882 
2883 			id = fnvlist_lookup_uint64(nv, ZPOOL_CONFIG_ID);
2884 			errno = 0;
2885 			vdev_id = strtoull(idx, &end, 10);
2886 
2887 			/*
2888 			 * If we are looking for a raidz and a parity is
2889 			 * specified, make sure it matches.
2890 			 */
2891 			int rzlen = strlen(VDEV_TYPE_RAIDZ);
2892 			assert(rzlen == strlen(VDEV_TYPE_DRAID));
2893 			int typlen = strlen(type);
2894 			if ((strncmp(type, VDEV_TYPE_RAIDZ, rzlen) == 0 ||
2895 			    strncmp(type, VDEV_TYPE_DRAID, rzlen) == 0) &&
2896 			    typlen != rzlen) {
2897 				uint64_t vdev_parity;
2898 				int parity = *(type + rzlen) - '0';
2899 
2900 				if (parity <= 0 || parity > 3 ||
2901 				    (typlen - rzlen) != 1) {
2902 					/*
2903 					 * Nonsense parity specified, can
2904 					 * never match
2905 					 */
2906 					free(type);
2907 					return (NULL);
2908 				}
2909 				vdev_parity = fnvlist_lookup_uint64(nv,
2910 				    ZPOOL_CONFIG_NPARITY);
2911 				if ((int)vdev_parity != parity) {
2912 					free(type);
2913 					break;
2914 				}
2915 			}
2916 
2917 			free(type);
2918 			if (errno != 0)
2919 				return (NULL);
2920 
2921 			/*
2922 			 * Now verify that we have the correct vdev id.
2923 			 */
2924 			if (vdev_id == id)
2925 				return (nv);
2926 		}
2927 
2928 		/*
2929 		 * Common case
2930 		 */
2931 		if (strcmp(srchval, val) == 0)
2932 			return (nv);
2933 		break;
2934 	}
2935 
2936 	default:
2937 		break;
2938 	}
2939 
2940 	if (nvlist_lookup_nvlist_array(nv, ZPOOL_CONFIG_CHILDREN,
2941 	    &child, &children) != 0)
2942 		return (NULL);
2943 
2944 	for (c = 0; c < children; c++) {
2945 		if ((ret = vdev_to_nvlist_iter(child[c], search,
2946 		    avail_spare, l2cache, NULL)) != NULL) {
2947 			/*
2948 			 * The 'is_log' value is only set for the toplevel
2949 			 * vdev, not the leaf vdevs.  So we always lookup the
2950 			 * log device from the root of the vdev tree (where
2951 			 * 'log' is non-NULL).
2952 			 */
2953 			if (log != NULL &&
2954 			    nvlist_lookup_uint64(child[c],
2955 			    ZPOOL_CONFIG_IS_LOG, &is_log) == 0 &&
2956 			    is_log) {
2957 				*log = B_TRUE;
2958 			}
2959 			return (ret);
2960 		}
2961 	}
2962 
2963 	if (nvlist_lookup_nvlist_array(nv, ZPOOL_CONFIG_SPARES,
2964 	    &child, &children) == 0) {
2965 		for (c = 0; c < children; c++) {
2966 			if ((ret = vdev_to_nvlist_iter(child[c], search,
2967 			    avail_spare, l2cache, NULL)) != NULL) {
2968 				*avail_spare = B_TRUE;
2969 				return (ret);
2970 			}
2971 		}
2972 	}
2973 
2974 	if (nvlist_lookup_nvlist_array(nv, ZPOOL_CONFIG_L2CACHE,
2975 	    &child, &children) == 0) {
2976 		for (c = 0; c < children; c++) {
2977 			if ((ret = vdev_to_nvlist_iter(child[c], search,
2978 			    avail_spare, l2cache, NULL)) != NULL) {
2979 				*l2cache = B_TRUE;
2980 				return (ret);
2981 			}
2982 		}
2983 	}
2984 
2985 	return (NULL);
2986 }
2987 
2988 /*
2989  * Given a physical path or guid, find the associated vdev.
2990  */
2991 nvlist_t *
zpool_find_vdev_by_physpath(zpool_handle_t * zhp,const char * ppath,boolean_t * avail_spare,boolean_t * l2cache,boolean_t * log)2992 zpool_find_vdev_by_physpath(zpool_handle_t *zhp, const char *ppath,
2993     boolean_t *avail_spare, boolean_t *l2cache, boolean_t *log)
2994 {
2995 	nvlist_t *search, *nvroot, *ret;
2996 	uint64_t guid;
2997 	char *end;
2998 
2999 	search = fnvlist_alloc();
3000 
3001 	guid = strtoull(ppath, &end, 0);
3002 	if (guid != 0 && *end == '\0') {
3003 		fnvlist_add_uint64(search, ZPOOL_CONFIG_GUID, guid);
3004 	} else {
3005 		fnvlist_add_string(search, ZPOOL_CONFIG_PHYS_PATH, ppath);
3006 	}
3007 
3008 	nvroot = fnvlist_lookup_nvlist(zhp->zpool_config,
3009 	    ZPOOL_CONFIG_VDEV_TREE);
3010 
3011 	*avail_spare = B_FALSE;
3012 	*l2cache = B_FALSE;
3013 	if (log != NULL)
3014 		*log = B_FALSE;
3015 	ret = vdev_to_nvlist_iter(nvroot, search, avail_spare, l2cache, log);
3016 	fnvlist_free(search);
3017 
3018 	return (ret);
3019 }
3020 
3021 /*
3022  * Determine if we have an "interior" top-level vdev (i.e mirror/raidz).
3023  */
3024 static boolean_t
zpool_vdev_is_interior(const char * name)3025 zpool_vdev_is_interior(const char *name)
3026 {
3027 	if (strncmp(name, VDEV_TYPE_RAIDZ, strlen(VDEV_TYPE_RAIDZ)) == 0 ||
3028 	    strncmp(name, VDEV_TYPE_SPARE, strlen(VDEV_TYPE_SPARE)) == 0 ||
3029 	    strncmp(name,
3030 	    VDEV_TYPE_REPLACING, strlen(VDEV_TYPE_REPLACING)) == 0 ||
3031 	    strncmp(name, VDEV_TYPE_ROOT, strlen(VDEV_TYPE_ROOT)) == 0 ||
3032 	    strncmp(name, VDEV_TYPE_MIRROR, strlen(VDEV_TYPE_MIRROR)) == 0)
3033 		return (B_TRUE);
3034 
3035 	if (strncmp(name, VDEV_TYPE_DRAID, strlen(VDEV_TYPE_DRAID)) == 0 &&
3036 	    !zpool_is_draid_spare(name))
3037 		return (B_TRUE);
3038 
3039 	return (B_FALSE);
3040 }
3041 
3042 /*
3043  * Lookup the nvlist for a given vdev.
3044  */
3045 nvlist_t *
zpool_find_vdev(zpool_handle_t * zhp,const char * path,boolean_t * avail_spare,boolean_t * l2cache,boolean_t * log)3046 zpool_find_vdev(zpool_handle_t *zhp, const char *path, boolean_t *avail_spare,
3047     boolean_t *l2cache, boolean_t *log)
3048 {
3049 	char *end;
3050 	nvlist_t *nvroot, *search, *ret;
3051 	uint64_t guid;
3052 	boolean_t __avail_spare, __l2cache, __log;
3053 
3054 	search = fnvlist_alloc();
3055 
3056 	guid = strtoull(path, &end, 0);
3057 	if (guid != 0 && *end == '\0') {
3058 		fnvlist_add_uint64(search, ZPOOL_CONFIG_GUID, guid);
3059 	} else if (zpool_vdev_is_interior(path)) {
3060 		fnvlist_add_string(search, ZPOOL_CONFIG_TYPE, path);
3061 	} else {
3062 		fnvlist_add_string(search, ZPOOL_CONFIG_PATH, path);
3063 	}
3064 
3065 	nvroot = fnvlist_lookup_nvlist(zhp->zpool_config,
3066 	    ZPOOL_CONFIG_VDEV_TREE);
3067 
3068 	/*
3069 	 * User can pass NULL for avail_spare, l2cache, and log, but
3070 	 * we still need to provide variables to vdev_to_nvlist_iter(), so
3071 	 * just point them to junk variables here.
3072 	 */
3073 	if (!avail_spare)
3074 		avail_spare = &__avail_spare;
3075 	if (!l2cache)
3076 		l2cache = &__l2cache;
3077 	if (!log)
3078 		log = &__log;
3079 
3080 	*avail_spare = B_FALSE;
3081 	*l2cache = B_FALSE;
3082 	if (log != NULL)
3083 		*log = B_FALSE;
3084 	ret = vdev_to_nvlist_iter(nvroot, search, avail_spare, l2cache, log);
3085 	fnvlist_free(search);
3086 
3087 	return (ret);
3088 }
3089 
3090 /*
3091  * Convert a vdev path to a GUID.  Returns GUID or 0 on error.
3092  *
3093  * If is_spare, is_l2cache, or is_log is non-NULL, then store within it
3094  * if the VDEV is a spare, l2cache, or log device.  If they're NULL then
3095  * ignore them.
3096  */
3097 static uint64_t
zpool_vdev_path_to_guid_impl(zpool_handle_t * zhp,const char * path,boolean_t * is_spare,boolean_t * is_l2cache,boolean_t * is_log)3098 zpool_vdev_path_to_guid_impl(zpool_handle_t *zhp, const char *path,
3099     boolean_t *is_spare, boolean_t *is_l2cache, boolean_t *is_log)
3100 {
3101 	boolean_t spare = B_FALSE, l2cache = B_FALSE, log = B_FALSE;
3102 	nvlist_t *tgt;
3103 
3104 	if ((tgt = zpool_find_vdev(zhp, path, &spare, &l2cache,
3105 	    &log)) == NULL)
3106 		return (0);
3107 
3108 	if (is_spare != NULL)
3109 		*is_spare = spare;
3110 	if (is_l2cache != NULL)
3111 		*is_l2cache = l2cache;
3112 	if (is_log != NULL)
3113 		*is_log = log;
3114 
3115 	return (fnvlist_lookup_uint64(tgt, ZPOOL_CONFIG_GUID));
3116 }
3117 
3118 /* Convert a vdev path to a GUID.  Returns GUID or 0 on error. */
3119 uint64_t
zpool_vdev_path_to_guid(zpool_handle_t * zhp,const char * path)3120 zpool_vdev_path_to_guid(zpool_handle_t *zhp, const char *path)
3121 {
3122 	return (zpool_vdev_path_to_guid_impl(zhp, path, NULL, NULL, NULL));
3123 }
3124 
3125 /*
3126  * Bring the specified vdev online.   The 'flags' parameter is a set of the
3127  * ZFS_ONLINE_* flags.
3128  */
3129 int
zpool_vdev_online(zpool_handle_t * zhp,const char * path,int flags,vdev_state_t * newstate)3130 zpool_vdev_online(zpool_handle_t *zhp, const char *path, int flags,
3131     vdev_state_t *newstate)
3132 {
3133 	zfs_cmd_t zc = {"\0"};
3134 	char errbuf[ERRBUFLEN];
3135 	nvlist_t *tgt;
3136 	boolean_t avail_spare, l2cache, islog;
3137 	libzfs_handle_t *hdl = zhp->zpool_hdl;
3138 
3139 	if (flags & ZFS_ONLINE_EXPAND) {
3140 		(void) snprintf(errbuf, sizeof (errbuf),
3141 		    dgettext(TEXT_DOMAIN, "cannot expand %s"), path);
3142 	} else {
3143 		(void) snprintf(errbuf, sizeof (errbuf),
3144 		    dgettext(TEXT_DOMAIN, "cannot online %s"), path);
3145 	}
3146 
3147 	(void) strlcpy(zc.zc_name, zhp->zpool_name, sizeof (zc.zc_name));
3148 	if ((tgt = zpool_find_vdev(zhp, path, &avail_spare, &l2cache,
3149 	    &islog)) == NULL)
3150 		return (zfs_error(hdl, EZFS_NODEVICE, errbuf));
3151 
3152 	zc.zc_guid = fnvlist_lookup_uint64(tgt, ZPOOL_CONFIG_GUID);
3153 
3154 	if (!(flags & ZFS_ONLINE_SPARE) && avail_spare)
3155 		return (zfs_error(hdl, EZFS_ISSPARE, errbuf));
3156 
3157 #ifndef __FreeBSD__
3158 	const char *pathname;
3159 	if ((flags & ZFS_ONLINE_EXPAND ||
3160 	    zpool_get_prop_int(zhp, ZPOOL_PROP_AUTOEXPAND, NULL)) &&
3161 	    nvlist_lookup_string(tgt, ZPOOL_CONFIG_PATH, &pathname) == 0) {
3162 		uint64_t wholedisk = 0;
3163 
3164 		(void) nvlist_lookup_uint64(tgt, ZPOOL_CONFIG_WHOLE_DISK,
3165 		    &wholedisk);
3166 
3167 		/*
3168 		 * XXX - L2ARC 1.0 devices can't support expansion.
3169 		 */
3170 		if (l2cache) {
3171 			zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
3172 			    "cannot expand cache devices"));
3173 			return (zfs_error(hdl, EZFS_VDEVNOTSUP, errbuf));
3174 		}
3175 
3176 		if (wholedisk) {
3177 			const char *fullpath = path;
3178 			char buf[MAXPATHLEN];
3179 			int error;
3180 
3181 			if (path[0] != '/') {
3182 				error = zfs_resolve_shortname(path, buf,
3183 				    sizeof (buf));
3184 				if (error != 0)
3185 					return (zfs_error(hdl, EZFS_NODEVICE,
3186 					    errbuf));
3187 
3188 				fullpath = buf;
3189 			}
3190 
3191 			error = zpool_relabel_disk(hdl, fullpath, errbuf);
3192 			if (error != 0)
3193 				return (error);
3194 		}
3195 	}
3196 #endif
3197 
3198 	zc.zc_cookie = VDEV_STATE_ONLINE;
3199 	zc.zc_obj = flags;
3200 
3201 	if (zfs_ioctl(hdl, ZFS_IOC_VDEV_SET_STATE, &zc) != 0) {
3202 		if (errno == EINVAL) {
3203 			zfs_error_aux(hdl, dgettext(TEXT_DOMAIN, "was split "
3204 			    "from this pool into a new one.  Use '%s' "
3205 			    "instead"), "zpool detach");
3206 			return (zfs_error(hdl, EZFS_POSTSPLIT_ONLINE, errbuf));
3207 		}
3208 		return (zpool_standard_error(hdl, errno, errbuf));
3209 	}
3210 
3211 	*newstate = zc.zc_cookie;
3212 	return (0);
3213 }
3214 
3215 /*
3216  * Take the specified vdev offline
3217  */
3218 int
zpool_vdev_offline(zpool_handle_t * zhp,const char * path,boolean_t istmp)3219 zpool_vdev_offline(zpool_handle_t *zhp, const char *path, boolean_t istmp)
3220 {
3221 	zfs_cmd_t zc = {"\0"};
3222 	char errbuf[ERRBUFLEN];
3223 	nvlist_t *tgt;
3224 	boolean_t avail_spare, l2cache;
3225 	libzfs_handle_t *hdl = zhp->zpool_hdl;
3226 
3227 	(void) snprintf(errbuf, sizeof (errbuf),
3228 	    dgettext(TEXT_DOMAIN, "cannot offline %s"), path);
3229 
3230 	(void) strlcpy(zc.zc_name, zhp->zpool_name, sizeof (zc.zc_name));
3231 	if ((tgt = zpool_find_vdev(zhp, path, &avail_spare, &l2cache,
3232 	    NULL)) == NULL)
3233 		return (zfs_error(hdl, EZFS_NODEVICE, errbuf));
3234 
3235 	zc.zc_guid = fnvlist_lookup_uint64(tgt, ZPOOL_CONFIG_GUID);
3236 
3237 	if (avail_spare)
3238 		return (zfs_error(hdl, EZFS_ISSPARE, errbuf));
3239 
3240 	zc.zc_cookie = VDEV_STATE_OFFLINE;
3241 	zc.zc_obj = istmp ? ZFS_OFFLINE_TEMPORARY : 0;
3242 
3243 	if (zfs_ioctl(hdl, ZFS_IOC_VDEV_SET_STATE, &zc) == 0)
3244 		return (0);
3245 
3246 	switch (errno) {
3247 	case EBUSY:
3248 
3249 		/*
3250 		 * There are no other replicas of this device.
3251 		 */
3252 		return (zfs_error(hdl, EZFS_NOREPLICAS, errbuf));
3253 
3254 	case EEXIST:
3255 		/*
3256 		 * The log device has unplayed logs
3257 		 */
3258 		return (zfs_error(hdl, EZFS_UNPLAYED_LOGS, errbuf));
3259 
3260 	default:
3261 		return (zpool_standard_error(hdl, errno, errbuf));
3262 	}
3263 }
3264 
3265 /*
3266  * Remove the specified vdev asynchronously from the configuration, so
3267  * that it may come ONLINE if reinserted. This is called from zed on
3268  * Udev remove event.
3269  * Note: We also have a similar function zpool_vdev_remove() that
3270  * removes the vdev from the pool.
3271  */
3272 int
zpool_vdev_remove_wanted(zpool_handle_t * zhp,const char * path)3273 zpool_vdev_remove_wanted(zpool_handle_t *zhp, const char *path)
3274 {
3275 	zfs_cmd_t zc = {"\0"};
3276 	char errbuf[ERRBUFLEN];
3277 	nvlist_t *tgt;
3278 	boolean_t avail_spare, l2cache;
3279 	libzfs_handle_t *hdl = zhp->zpool_hdl;
3280 
3281 	(void) snprintf(errbuf, sizeof (errbuf),
3282 	    dgettext(TEXT_DOMAIN, "cannot remove %s"), path);
3283 
3284 	(void) strlcpy(zc.zc_name, zhp->zpool_name, sizeof (zc.zc_name));
3285 	if ((tgt = zpool_find_vdev(zhp, path, &avail_spare, &l2cache,
3286 	    NULL)) == NULL)
3287 		return (zfs_error(hdl, EZFS_NODEVICE, errbuf));
3288 
3289 	zc.zc_guid = fnvlist_lookup_uint64(tgt, ZPOOL_CONFIG_GUID);
3290 
3291 	zc.zc_cookie = VDEV_STATE_REMOVED;
3292 
3293 	if (zfs_ioctl(hdl, ZFS_IOC_VDEV_SET_STATE, &zc) == 0)
3294 		return (0);
3295 
3296 	return (zpool_standard_error(hdl, errno, errbuf));
3297 }
3298 
3299 /*
3300  * Mark the given vdev faulted.
3301  */
3302 int
zpool_vdev_fault(zpool_handle_t * zhp,uint64_t guid,vdev_aux_t aux)3303 zpool_vdev_fault(zpool_handle_t *zhp, uint64_t guid, vdev_aux_t aux)
3304 {
3305 	zfs_cmd_t zc = {"\0"};
3306 	char errbuf[ERRBUFLEN];
3307 	libzfs_handle_t *hdl = zhp->zpool_hdl;
3308 
3309 	(void) snprintf(errbuf, sizeof (errbuf),
3310 	    dgettext(TEXT_DOMAIN, "cannot fault %llu"), (u_longlong_t)guid);
3311 
3312 	(void) strlcpy(zc.zc_name, zhp->zpool_name, sizeof (zc.zc_name));
3313 	zc.zc_guid = guid;
3314 	zc.zc_cookie = VDEV_STATE_FAULTED;
3315 	zc.zc_obj = aux;
3316 
3317 	if (zfs_ioctl(hdl, ZFS_IOC_VDEV_SET_STATE, &zc) == 0)
3318 		return (0);
3319 
3320 	switch (errno) {
3321 	case EBUSY:
3322 
3323 		/*
3324 		 * There are no other replicas of this device.
3325 		 */
3326 		return (zfs_error(hdl, EZFS_NOREPLICAS, errbuf));
3327 
3328 	default:
3329 		return (zpool_standard_error(hdl, errno, errbuf));
3330 	}
3331 
3332 }
3333 
3334 /*
3335  * Generic set vdev state function
3336  */
3337 static int
zpool_vdev_set_state(zpool_handle_t * zhp,uint64_t guid,vdev_aux_t aux,vdev_state_t state)3338 zpool_vdev_set_state(zpool_handle_t *zhp, uint64_t guid, vdev_aux_t aux,
3339     vdev_state_t state)
3340 {
3341 	zfs_cmd_t zc = {"\0"};
3342 	char errbuf[ERRBUFLEN];
3343 	libzfs_handle_t *hdl = zhp->zpool_hdl;
3344 
3345 	(void) snprintf(errbuf, sizeof (errbuf),
3346 	    dgettext(TEXT_DOMAIN, "cannot set %s %llu"),
3347 	    zpool_state_to_name(state, aux), (u_longlong_t)guid);
3348 
3349 	(void) strlcpy(zc.zc_name, zhp->zpool_name, sizeof (zc.zc_name));
3350 	zc.zc_guid = guid;
3351 	zc.zc_cookie = state;
3352 	zc.zc_obj = aux;
3353 
3354 	if (zfs_ioctl(hdl, ZFS_IOC_VDEV_SET_STATE, &zc) == 0)
3355 		return (0);
3356 
3357 	return (zpool_standard_error(hdl, errno, errbuf));
3358 }
3359 
3360 /*
3361  * Mark the given vdev degraded.
3362  */
3363 int
zpool_vdev_degrade(zpool_handle_t * zhp,uint64_t guid,vdev_aux_t aux)3364 zpool_vdev_degrade(zpool_handle_t *zhp, uint64_t guid, vdev_aux_t aux)
3365 {
3366 	return (zpool_vdev_set_state(zhp, guid, aux, VDEV_STATE_DEGRADED));
3367 }
3368 
3369 /*
3370  * Mark the given vdev as in a removed state (as if the device does not exist).
3371  *
3372  * This is different than zpool_vdev_remove() which does a removal of a device
3373  * from the pool (but the device does exist).
3374  */
3375 int
zpool_vdev_set_removed_state(zpool_handle_t * zhp,uint64_t guid,vdev_aux_t aux)3376 zpool_vdev_set_removed_state(zpool_handle_t *zhp, uint64_t guid, vdev_aux_t aux)
3377 {
3378 	return (zpool_vdev_set_state(zhp, guid, aux, VDEV_STATE_REMOVED));
3379 }
3380 
3381 /*
3382  * Returns TRUE if the given nvlist is a vdev that was originally swapped in as
3383  * a hot spare.
3384  */
3385 static boolean_t
is_replacing_spare(nvlist_t * search,nvlist_t * tgt,int which)3386 is_replacing_spare(nvlist_t *search, nvlist_t *tgt, int which)
3387 {
3388 	nvlist_t **child;
3389 	uint_t c, children;
3390 
3391 	if (nvlist_lookup_nvlist_array(search, ZPOOL_CONFIG_CHILDREN, &child,
3392 	    &children) == 0) {
3393 		const char *type = fnvlist_lookup_string(search,
3394 		    ZPOOL_CONFIG_TYPE);
3395 		if ((strcmp(type, VDEV_TYPE_SPARE) == 0 ||
3396 		    strcmp(type, VDEV_TYPE_DRAID_SPARE) == 0) &&
3397 		    children == 2 && child[which] == tgt)
3398 			return (B_TRUE);
3399 
3400 		for (c = 0; c < children; c++)
3401 			if (is_replacing_spare(child[c], tgt, which))
3402 				return (B_TRUE);
3403 	}
3404 
3405 	return (B_FALSE);
3406 }
3407 
3408 /*
3409  * Attach new_disk (fully described by nvroot) to old_disk.
3410  * If 'replacing' is specified, the new disk will replace the old one.
3411  */
3412 int
zpool_vdev_attach(zpool_handle_t * zhp,const char * old_disk,const char * new_disk,nvlist_t * nvroot,int replacing,boolean_t rebuild)3413 zpool_vdev_attach(zpool_handle_t *zhp, const char *old_disk,
3414     const char *new_disk, nvlist_t *nvroot, int replacing, boolean_t rebuild)
3415 {
3416 	zfs_cmd_t zc = {"\0"};
3417 	char errbuf[ERRBUFLEN];
3418 	int ret;
3419 	nvlist_t *tgt;
3420 	boolean_t avail_spare, l2cache, islog;
3421 	uint64_t val;
3422 	char *newname;
3423 	nvlist_t **child;
3424 	uint_t children;
3425 	nvlist_t *config_root;
3426 	libzfs_handle_t *hdl = zhp->zpool_hdl;
3427 
3428 	if (replacing)
3429 		(void) snprintf(errbuf, sizeof (errbuf), dgettext(TEXT_DOMAIN,
3430 		    "cannot replace %s with %s"), old_disk, new_disk);
3431 	else
3432 		(void) snprintf(errbuf, sizeof (errbuf), dgettext(TEXT_DOMAIN,
3433 		    "cannot attach %s to %s"), new_disk, old_disk);
3434 
3435 	(void) strlcpy(zc.zc_name, zhp->zpool_name, sizeof (zc.zc_name));
3436 	if ((tgt = zpool_find_vdev(zhp, old_disk, &avail_spare, &l2cache,
3437 	    &islog)) == NULL)
3438 		return (zfs_error(hdl, EZFS_NODEVICE, errbuf));
3439 
3440 	if (avail_spare)
3441 		return (zfs_error(hdl, EZFS_ISSPARE, errbuf));
3442 
3443 	if (l2cache)
3444 		return (zfs_error(hdl, EZFS_ISL2CACHE, errbuf));
3445 
3446 	zc.zc_guid = fnvlist_lookup_uint64(tgt, ZPOOL_CONFIG_GUID);
3447 	zc.zc_cookie = replacing;
3448 	zc.zc_simple = rebuild;
3449 
3450 	if (rebuild &&
3451 	    zfeature_lookup_guid("org.openzfs:device_rebuild", NULL) != 0) {
3452 		zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
3453 		    "the loaded zfs module doesn't support device rebuilds"));
3454 		return (zfs_error(hdl, EZFS_POOL_NOTSUP, errbuf));
3455 	}
3456 
3457 	if (nvlist_lookup_nvlist_array(nvroot, ZPOOL_CONFIG_CHILDREN,
3458 	    &child, &children) != 0 || children != 1) {
3459 		zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
3460 		    "new device must be a single disk"));
3461 		return (zfs_error(hdl, EZFS_INVALCONFIG, errbuf));
3462 	}
3463 
3464 	config_root = fnvlist_lookup_nvlist(zpool_get_config(zhp, NULL),
3465 	    ZPOOL_CONFIG_VDEV_TREE);
3466 
3467 	if ((newname = zpool_vdev_name(NULL, NULL, child[0], 0)) == NULL)
3468 		return (-1);
3469 
3470 	/*
3471 	 * If the target is a hot spare that has been swapped in, we can only
3472 	 * replace it with another hot spare.
3473 	 */
3474 	if (replacing &&
3475 	    nvlist_lookup_uint64(tgt, ZPOOL_CONFIG_IS_SPARE, &val) == 0 &&
3476 	    (zpool_find_vdev(zhp, newname, &avail_spare, &l2cache,
3477 	    NULL) == NULL || !avail_spare) &&
3478 	    is_replacing_spare(config_root, tgt, 1)) {
3479 		zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
3480 		    "can only be replaced by another hot spare"));
3481 		free(newname);
3482 		return (zfs_error(hdl, EZFS_BADTARGET, errbuf));
3483 	}
3484 
3485 	free(newname);
3486 
3487 	zcmd_write_conf_nvlist(hdl, &zc, nvroot);
3488 
3489 	ret = zfs_ioctl(hdl, ZFS_IOC_VDEV_ATTACH, &zc);
3490 
3491 	zcmd_free_nvlists(&zc);
3492 
3493 	if (ret == 0)
3494 		return (0);
3495 
3496 	switch (errno) {
3497 	case ENOTSUP:
3498 		/*
3499 		 * Can't attach to or replace this type of vdev.
3500 		 */
3501 		if (replacing) {
3502 			uint64_t version = zpool_get_prop_int(zhp,
3503 			    ZPOOL_PROP_VERSION, NULL);
3504 
3505 			if (islog) {
3506 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
3507 				    "cannot replace a log with a spare"));
3508 			} else if (rebuild) {
3509 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
3510 				    "only mirror and dRAID vdevs support "
3511 				    "sequential reconstruction"));
3512 			} else if (zpool_is_draid_spare(new_disk)) {
3513 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
3514 				    "dRAID spares can only replace child "
3515 				    "devices in their parent's dRAID vdev"));
3516 			} else if (version >= SPA_VERSION_MULTI_REPLACE) {
3517 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
3518 				    "already in replacing/spare config; wait "
3519 				    "for completion or use 'zpool detach'"));
3520 			} else {
3521 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
3522 				    "cannot replace a replacing device"));
3523 			}
3524 		} else {
3525 			char status[64] = {0};
3526 			zpool_prop_get_feature(zhp,
3527 			    "feature@device_rebuild", status, 63);
3528 			if (rebuild &&
3529 			    strncmp(status, ZFS_FEATURE_DISABLED, 64) == 0) {
3530 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
3531 				    "device_rebuild feature must be enabled "
3532 				    "in order to use sequential "
3533 				    "reconstruction"));
3534 			} else {
3535 				zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
3536 				    "can only attach to mirrors and top-level "
3537 				    "disks"));
3538 			}
3539 		}
3540 		(void) zfs_error(hdl, EZFS_BADTARGET, errbuf);
3541 		break;
3542 
3543 	case EINVAL:
3544 		/*
3545 		 * The new device must be a single disk.
3546 		 */
3547 		zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
3548 		    "new device must be a single disk"));
3549 		(void) zfs_error(hdl, EZFS_INVALCONFIG, errbuf);
3550 		break;
3551 
3552 	case EBUSY:
3553 		zfs_error_aux(hdl, dgettext(TEXT_DOMAIN, "%s is busy, "
3554 		    "or device removal is in progress"),
3555 		    new_disk);
3556 		(void) zfs_error(hdl, EZFS_BADDEV, errbuf);
3557 		break;
3558 
3559 	case EOVERFLOW:
3560 		/*
3561 		 * The new device is too small.
3562 		 */
3563 		zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
3564 		    "device is too small"));
3565 		(void) zfs_error(hdl, EZFS_BADDEV, errbuf);
3566 		break;
3567 
3568 	case EDOM:
3569 		/*
3570 		 * The new device has a different optimal sector size.
3571 		 */
3572 		zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
3573 		    "new device has a different optimal sector size; use the "
3574 		    "option '-o ashift=N' to override the optimal size"));
3575 		(void) zfs_error(hdl, EZFS_BADDEV, errbuf);
3576 		break;
3577 
3578 	case ENAMETOOLONG:
3579 		/*
3580 		 * The resulting top-level vdev spec won't fit in the label.
3581 		 */
3582 		(void) zfs_error(hdl, EZFS_DEVOVERFLOW, errbuf);
3583 		break;
3584 
3585 	default:
3586 		(void) zpool_standard_error(hdl, errno, errbuf);
3587 	}
3588 
3589 	return (-1);
3590 }
3591 
3592 /*
3593  * Detach the specified device.
3594  */
3595 int
zpool_vdev_detach(zpool_handle_t * zhp,const char * path)3596 zpool_vdev_detach(zpool_handle_t *zhp, const char *path)
3597 {
3598 	zfs_cmd_t zc = {"\0"};
3599 	char errbuf[ERRBUFLEN];
3600 	nvlist_t *tgt;
3601 	boolean_t avail_spare, l2cache;
3602 	libzfs_handle_t *hdl = zhp->zpool_hdl;
3603 
3604 	(void) snprintf(errbuf, sizeof (errbuf),
3605 	    dgettext(TEXT_DOMAIN, "cannot detach %s"), path);
3606 
3607 	(void) strlcpy(zc.zc_name, zhp->zpool_name, sizeof (zc.zc_name));
3608 	if ((tgt = zpool_find_vdev(zhp, path, &avail_spare, &l2cache,
3609 	    NULL)) == NULL)
3610 		return (zfs_error(hdl, EZFS_NODEVICE, errbuf));
3611 
3612 	if (avail_spare)
3613 		return (zfs_error(hdl, EZFS_ISSPARE, errbuf));
3614 
3615 	if (l2cache)
3616 		return (zfs_error(hdl, EZFS_ISL2CACHE, errbuf));
3617 
3618 	zc.zc_guid = fnvlist_lookup_uint64(tgt, ZPOOL_CONFIG_GUID);
3619 
3620 	if (zfs_ioctl(hdl, ZFS_IOC_VDEV_DETACH, &zc) == 0)
3621 		return (0);
3622 
3623 	switch (errno) {
3624 
3625 	case ENOTSUP:
3626 		/*
3627 		 * Can't detach from this type of vdev.
3628 		 */
3629 		zfs_error_aux(hdl, dgettext(TEXT_DOMAIN, "only "
3630 		    "applicable to mirror and replacing vdevs"));
3631 		(void) zfs_error(hdl, EZFS_BADTARGET, errbuf);
3632 		break;
3633 
3634 	case EBUSY:
3635 		/*
3636 		 * There are no other replicas of this device.
3637 		 */
3638 		(void) zfs_error(hdl, EZFS_NOREPLICAS, errbuf);
3639 		break;
3640 
3641 	default:
3642 		(void) zpool_standard_error(hdl, errno, errbuf);
3643 	}
3644 
3645 	return (-1);
3646 }
3647 
3648 /*
3649  * Find a mirror vdev in the source nvlist.
3650  *
3651  * The mchild array contains a list of disks in one of the top-level mirrors
3652  * of the source pool.  The schild array contains a list of disks that the
3653  * user specified on the command line.  We loop over the mchild array to
3654  * see if any entry in the schild array matches.
3655  *
3656  * If a disk in the mchild array is found in the schild array, we return
3657  * the index of that entry.  Otherwise we return -1.
3658  */
3659 static int
find_vdev_entry(zpool_handle_t * zhp,nvlist_t ** mchild,uint_t mchildren,nvlist_t ** schild,uint_t schildren)3660 find_vdev_entry(zpool_handle_t *zhp, nvlist_t **mchild, uint_t mchildren,
3661     nvlist_t **schild, uint_t schildren)
3662 {
3663 	uint_t mc;
3664 
3665 	for (mc = 0; mc < mchildren; mc++) {
3666 		uint_t sc;
3667 		char *mpath = zpool_vdev_name(zhp->zpool_hdl, zhp,
3668 		    mchild[mc], 0);
3669 
3670 		for (sc = 0; sc < schildren; sc++) {
3671 			char *spath = zpool_vdev_name(zhp->zpool_hdl, zhp,
3672 			    schild[sc], 0);
3673 			boolean_t result = (strcmp(mpath, spath) == 0);
3674 
3675 			free(spath);
3676 			if (result) {
3677 				free(mpath);
3678 				return (mc);
3679 			}
3680 		}
3681 
3682 		free(mpath);
3683 	}
3684 
3685 	return (-1);
3686 }
3687 
3688 /*
3689  * Split a mirror pool.  If newroot points to null, then a new nvlist
3690  * is generated and it is the responsibility of the caller to free it.
3691  */
3692 int
zpool_vdev_split(zpool_handle_t * zhp,char * newname,nvlist_t ** newroot,nvlist_t * props,splitflags_t flags)3693 zpool_vdev_split(zpool_handle_t *zhp, char *newname, nvlist_t **newroot,
3694     nvlist_t *props, splitflags_t flags)
3695 {
3696 	zfs_cmd_t zc = {"\0"};
3697 	char errbuf[ERRBUFLEN];
3698 	const char *bias;
3699 	nvlist_t *tree, *config, **child, **newchild, *newconfig = NULL;
3700 	nvlist_t **varray = NULL, *zc_props = NULL;
3701 	uint_t c, children, newchildren, lastlog = 0, vcount, found = 0;
3702 	libzfs_handle_t *hdl = zhp->zpool_hdl;
3703 	uint64_t vers, readonly = B_FALSE;
3704 	boolean_t freelist = B_FALSE, memory_err = B_TRUE;
3705 	int retval = 0;
3706 
3707 	(void) snprintf(errbuf, sizeof (errbuf),
3708 	    dgettext(TEXT_DOMAIN, "Unable to split %s"), zhp->zpool_name);
3709 
3710 	if (!zpool_name_valid(hdl, B_FALSE, newname))
3711 		return (zfs_error(hdl, EZFS_INVALIDNAME, errbuf));
3712 
3713 	if ((config = zpool_get_config(zhp, NULL)) == NULL) {
3714 		(void) fprintf(stderr, gettext("Internal error: unable to "
3715 		    "retrieve pool configuration\n"));
3716 		return (-1);
3717 	}
3718 
3719 	tree = fnvlist_lookup_nvlist(config, ZPOOL_CONFIG_VDEV_TREE);
3720 	vers = fnvlist_lookup_uint64(config, ZPOOL_CONFIG_VERSION);
3721 
3722 	if (props) {
3723 		prop_flags_t flags = { .create = B_FALSE, .import = B_TRUE };
3724 		if ((zc_props = zpool_valid_proplist(hdl, zhp->zpool_name,
3725 		    props, vers, flags, errbuf)) == NULL)
3726 			return (-1);
3727 		(void) nvlist_lookup_uint64(zc_props,
3728 		    zpool_prop_to_name(ZPOOL_PROP_READONLY), &readonly);
3729 		if (readonly) {
3730 			zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
3731 			    "property %s can only be set at import time"),
3732 			    zpool_prop_to_name(ZPOOL_PROP_READONLY));
3733 			return (-1);
3734 		}
3735 	}
3736 
3737 	if (nvlist_lookup_nvlist_array(tree, ZPOOL_CONFIG_CHILDREN, &child,
3738 	    &children) != 0) {
3739 		zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
3740 		    "Source pool is missing vdev tree"));
3741 		nvlist_free(zc_props);
3742 		return (-1);
3743 	}
3744 
3745 	varray = zfs_alloc(hdl, children * sizeof (nvlist_t *));
3746 	vcount = 0;
3747 
3748 	if (*newroot == NULL ||
3749 	    nvlist_lookup_nvlist_array(*newroot, ZPOOL_CONFIG_CHILDREN,
3750 	    &newchild, &newchildren) != 0)
3751 		newchildren = 0;
3752 
3753 	for (c = 0; c < children; c++) {
3754 		uint64_t is_log = B_FALSE, is_hole = B_FALSE;
3755 		boolean_t is_special = B_FALSE, is_dedup = B_FALSE;
3756 		const char *type;
3757 		nvlist_t **mchild, *vdev;
3758 		uint_t mchildren;
3759 		int entry;
3760 
3761 		/*
3762 		 * Unlike cache & spares, slogs are stored in the
3763 		 * ZPOOL_CONFIG_CHILDREN array.  We filter them out here.
3764 		 */
3765 		(void) nvlist_lookup_uint64(child[c], ZPOOL_CONFIG_IS_LOG,
3766 		    &is_log);
3767 		(void) nvlist_lookup_uint64(child[c], ZPOOL_CONFIG_IS_HOLE,
3768 		    &is_hole);
3769 		if (is_log || is_hole) {
3770 			/*
3771 			 * Create a hole vdev and put it in the config.
3772 			 */
3773 			if (nvlist_alloc(&vdev, NV_UNIQUE_NAME, 0) != 0)
3774 				goto out;
3775 			if (nvlist_add_string(vdev, ZPOOL_CONFIG_TYPE,
3776 			    VDEV_TYPE_HOLE) != 0)
3777 				goto out;
3778 			if (nvlist_add_uint64(vdev, ZPOOL_CONFIG_IS_HOLE,
3779 			    1) != 0)
3780 				goto out;
3781 			if (lastlog == 0)
3782 				lastlog = vcount;
3783 			varray[vcount++] = vdev;
3784 			continue;
3785 		}
3786 		lastlog = 0;
3787 		type = fnvlist_lookup_string(child[c], ZPOOL_CONFIG_TYPE);
3788 
3789 		if (strcmp(type, VDEV_TYPE_INDIRECT) == 0) {
3790 			vdev = child[c];
3791 			if (nvlist_dup(vdev, &varray[vcount++], 0) != 0)
3792 				goto out;
3793 			continue;
3794 		} else if (strcmp(type, VDEV_TYPE_MIRROR) != 0) {
3795 			zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
3796 			    "Source pool must be composed only of mirrors\n"));
3797 			retval = zfs_error(hdl, EZFS_INVALCONFIG, errbuf);
3798 			goto out;
3799 		}
3800 
3801 		if (nvlist_lookup_string(child[c],
3802 		    ZPOOL_CONFIG_ALLOCATION_BIAS, &bias) == 0) {
3803 			if (strcmp(bias, VDEV_ALLOC_BIAS_SPECIAL) == 0)
3804 				is_special = B_TRUE;
3805 			else if (strcmp(bias, VDEV_ALLOC_BIAS_DEDUP) == 0)
3806 				is_dedup = B_TRUE;
3807 		}
3808 		verify(nvlist_lookup_nvlist_array(child[c],
3809 		    ZPOOL_CONFIG_CHILDREN, &mchild, &mchildren) == 0);
3810 
3811 		/* find or add an entry for this top-level vdev */
3812 		if (newchildren > 0 &&
3813 		    (entry = find_vdev_entry(zhp, mchild, mchildren,
3814 		    newchild, newchildren)) >= 0) {
3815 			/* We found a disk that the user specified. */
3816 			vdev = mchild[entry];
3817 			++found;
3818 		} else {
3819 			/* User didn't specify a disk for this vdev. */
3820 			vdev = mchild[mchildren - 1];
3821 		}
3822 
3823 		if (nvlist_dup(vdev, &varray[vcount++], 0) != 0)
3824 			goto out;
3825 
3826 		if (flags.dryrun != 0) {
3827 			if (is_dedup == B_TRUE) {
3828 				if (nvlist_add_string(varray[vcount - 1],
3829 				    ZPOOL_CONFIG_ALLOCATION_BIAS,
3830 				    VDEV_ALLOC_BIAS_DEDUP) != 0)
3831 					goto out;
3832 			} else if (is_special == B_TRUE) {
3833 				if (nvlist_add_string(varray[vcount - 1],
3834 				    ZPOOL_CONFIG_ALLOCATION_BIAS,
3835 				    VDEV_ALLOC_BIAS_SPECIAL) != 0)
3836 					goto out;
3837 			}
3838 		}
3839 	}
3840 
3841 	/* did we find every disk the user specified? */
3842 	if (found != newchildren) {
3843 		zfs_error_aux(hdl, dgettext(TEXT_DOMAIN, "Device list must "
3844 		    "include at most one disk from each mirror"));
3845 		retval = zfs_error(hdl, EZFS_INVALCONFIG, errbuf);
3846 		goto out;
3847 	}
3848 
3849 	/* Prepare the nvlist for populating. */
3850 	if (*newroot == NULL) {
3851 		if (nvlist_alloc(newroot, NV_UNIQUE_NAME, 0) != 0)
3852 			goto out;
3853 		freelist = B_TRUE;
3854 		if (nvlist_add_string(*newroot, ZPOOL_CONFIG_TYPE,
3855 		    VDEV_TYPE_ROOT) != 0)
3856 			goto out;
3857 	} else {
3858 		verify(nvlist_remove_all(*newroot, ZPOOL_CONFIG_CHILDREN) == 0);
3859 	}
3860 
3861 	/* Add all the children we found */
3862 	if (nvlist_add_nvlist_array(*newroot, ZPOOL_CONFIG_CHILDREN,
3863 	    (const nvlist_t **)varray, lastlog == 0 ? vcount : lastlog) != 0)
3864 		goto out;
3865 
3866 	/*
3867 	 * If we're just doing a dry run, exit now with success.
3868 	 */
3869 	if (flags.dryrun) {
3870 		memory_err = B_FALSE;
3871 		freelist = B_FALSE;
3872 		goto out;
3873 	}
3874 
3875 	/* now build up the config list & call the ioctl */
3876 	if (nvlist_alloc(&newconfig, NV_UNIQUE_NAME, 0) != 0)
3877 		goto out;
3878 
3879 	if (nvlist_add_nvlist(newconfig,
3880 	    ZPOOL_CONFIG_VDEV_TREE, *newroot) != 0 ||
3881 	    nvlist_add_string(newconfig,
3882 	    ZPOOL_CONFIG_POOL_NAME, newname) != 0 ||
3883 	    nvlist_add_uint64(newconfig, ZPOOL_CONFIG_VERSION, vers) != 0)
3884 		goto out;
3885 
3886 	/*
3887 	 * The new pool is automatically part of the namespace unless we
3888 	 * explicitly export it.
3889 	 */
3890 	if (!flags.import)
3891 		zc.zc_cookie = ZPOOL_EXPORT_AFTER_SPLIT;
3892 	(void) strlcpy(zc.zc_name, zhp->zpool_name, sizeof (zc.zc_name));
3893 	(void) strlcpy(zc.zc_string, newname, sizeof (zc.zc_string));
3894 	zcmd_write_conf_nvlist(hdl, &zc, newconfig);
3895 	if (zc_props != NULL)
3896 		zcmd_write_src_nvlist(hdl, &zc, zc_props);
3897 
3898 	if (zfs_ioctl(hdl, ZFS_IOC_VDEV_SPLIT, &zc) != 0) {
3899 		retval = zpool_standard_error(hdl, errno, errbuf);
3900 		goto out;
3901 	}
3902 
3903 	freelist = B_FALSE;
3904 	memory_err = B_FALSE;
3905 
3906 out:
3907 	if (varray != NULL) {
3908 		int v;
3909 
3910 		for (v = 0; v < vcount; v++)
3911 			nvlist_free(varray[v]);
3912 		free(varray);
3913 	}
3914 	zcmd_free_nvlists(&zc);
3915 	nvlist_free(zc_props);
3916 	nvlist_free(newconfig);
3917 	if (freelist) {
3918 		nvlist_free(*newroot);
3919 		*newroot = NULL;
3920 	}
3921 
3922 	if (retval != 0)
3923 		return (retval);
3924 
3925 	if (memory_err)
3926 		return (no_memory(hdl));
3927 
3928 	return (0);
3929 }
3930 
3931 /*
3932  * Remove the given device.
3933  */
3934 int
zpool_vdev_remove(zpool_handle_t * zhp,const char * path)3935 zpool_vdev_remove(zpool_handle_t *zhp, const char *path)
3936 {
3937 	zfs_cmd_t zc = {"\0"};
3938 	char errbuf[ERRBUFLEN];
3939 	nvlist_t *tgt;
3940 	boolean_t avail_spare, l2cache, islog;
3941 	libzfs_handle_t *hdl = zhp->zpool_hdl;
3942 	uint64_t version;
3943 
3944 	(void) snprintf(errbuf, sizeof (errbuf),
3945 	    dgettext(TEXT_DOMAIN, "cannot remove %s"), path);
3946 
3947 	if (zpool_is_draid_spare(path)) {
3948 		zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
3949 		    "dRAID spares cannot be removed"));
3950 		return (zfs_error(hdl, EZFS_NODEVICE, errbuf));
3951 	}
3952 
3953 	(void) strlcpy(zc.zc_name, zhp->zpool_name, sizeof (zc.zc_name));
3954 	if ((tgt = zpool_find_vdev(zhp, path, &avail_spare, &l2cache,
3955 	    &islog)) == NULL)
3956 		return (zfs_error(hdl, EZFS_NODEVICE, errbuf));
3957 
3958 	version = zpool_get_prop_int(zhp, ZPOOL_PROP_VERSION, NULL);
3959 	if (islog && version < SPA_VERSION_HOLES) {
3960 		zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
3961 		    "pool must be upgraded to support log removal"));
3962 		return (zfs_error(hdl, EZFS_BADVERSION, errbuf));
3963 	}
3964 
3965 	zc.zc_guid = fnvlist_lookup_uint64(tgt, ZPOOL_CONFIG_GUID);
3966 
3967 	if (zfs_ioctl(hdl, ZFS_IOC_VDEV_REMOVE, &zc) == 0)
3968 		return (0);
3969 
3970 	switch (errno) {
3971 
3972 	case EALREADY:
3973 		zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
3974 		    "removal for this vdev is already in progress."));
3975 		(void) zfs_error(hdl, EZFS_BUSY, errbuf);
3976 		break;
3977 
3978 	case EINVAL:
3979 		zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
3980 		    "invalid config; all top-level vdevs must "
3981 		    "have the same sector size and not be raidz."));
3982 		(void) zfs_error(hdl, EZFS_INVALCONFIG, errbuf);
3983 		break;
3984 
3985 	case EBUSY:
3986 		if (islog) {
3987 			zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
3988 			    "Mount encrypted datasets to replay logs."));
3989 		} else {
3990 			zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
3991 			    "Pool busy; removal may already be in progress"));
3992 		}
3993 		(void) zfs_error(hdl, EZFS_BUSY, errbuf);
3994 		break;
3995 
3996 	case EACCES:
3997 		if (islog) {
3998 			zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
3999 			    "Mount encrypted datasets to replay logs."));
4000 			(void) zfs_error(hdl, EZFS_BUSY, errbuf);
4001 		} else {
4002 			(void) zpool_standard_error(hdl, errno, errbuf);
4003 		}
4004 		break;
4005 
4006 	default:
4007 		(void) zpool_standard_error(hdl, errno, errbuf);
4008 	}
4009 	return (-1);
4010 }
4011 
4012 int
zpool_vdev_remove_cancel(zpool_handle_t * zhp)4013 zpool_vdev_remove_cancel(zpool_handle_t *zhp)
4014 {
4015 	zfs_cmd_t zc = {{0}};
4016 	char errbuf[ERRBUFLEN];
4017 	libzfs_handle_t *hdl = zhp->zpool_hdl;
4018 
4019 	(void) snprintf(errbuf, sizeof (errbuf),
4020 	    dgettext(TEXT_DOMAIN, "cannot cancel removal"));
4021 
4022 	(void) strlcpy(zc.zc_name, zhp->zpool_name, sizeof (zc.zc_name));
4023 	zc.zc_cookie = 1;
4024 
4025 	if (zfs_ioctl(hdl, ZFS_IOC_VDEV_REMOVE, &zc) == 0)
4026 		return (0);
4027 
4028 	return (zpool_standard_error(hdl, errno, errbuf));
4029 }
4030 
4031 int
zpool_vdev_indirect_size(zpool_handle_t * zhp,const char * path,uint64_t * sizep)4032 zpool_vdev_indirect_size(zpool_handle_t *zhp, const char *path,
4033     uint64_t *sizep)
4034 {
4035 	char errbuf[ERRBUFLEN];
4036 	nvlist_t *tgt;
4037 	boolean_t avail_spare, l2cache, islog;
4038 	libzfs_handle_t *hdl = zhp->zpool_hdl;
4039 
4040 	(void) snprintf(errbuf, sizeof (errbuf),
4041 	    dgettext(TEXT_DOMAIN, "cannot determine indirect size of %s"),
4042 	    path);
4043 
4044 	if ((tgt = zpool_find_vdev(zhp, path, &avail_spare, &l2cache,
4045 	    &islog)) == NULL)
4046 		return (zfs_error(hdl, EZFS_NODEVICE, errbuf));
4047 
4048 	if (avail_spare || l2cache || islog) {
4049 		*sizep = 0;
4050 		return (0);
4051 	}
4052 
4053 	if (nvlist_lookup_uint64(tgt, ZPOOL_CONFIG_INDIRECT_SIZE, sizep) != 0) {
4054 		zfs_error_aux(hdl, dgettext(TEXT_DOMAIN,
4055 		    "indirect size not available"));
4056 		return (zfs_error(hdl, EINVAL, errbuf));
4057 	}
4058 	return (0);
4059 }
4060 
4061 /*
4062  * Clear the errors for the pool, or the particular device if specified.
4063  */
4064 int
zpool_clear(zpool_handle_t * zhp,const char * path,nvlist_t * rewindnvl)4065 zpool_clear(zpool_handle_t *zhp, const char *path, nvlist_t *rewindnvl)
4066 {
4067 	zfs_cmd_t zc = {"\0"};
4068 	char errbuf[ERRBUFLEN];
4069 	nvlist_t *tgt;
4070 	zpool_load_policy_t policy;
4071 	boolean_t avail_spare, l2cache;
4072 	libzfs_handle_t *hdl = zhp->zpool_hdl;
4073 	nvlist_t *nvi = NULL;
4074 	int error;
4075 
4076 	if (path)
4077 		(void) snprintf(errbuf, sizeof (errbuf),
4078 		    dgettext(TEXT_DOMAIN, "cannot clear errors for %s"),
4079 		    path);
4080 	else
4081 		(void) snprintf(errbuf, sizeof (errbuf),
4082 		    dgettext(TEXT_DOMAIN, "cannot clear errors for %s"),
4083 		    zhp->zpool_name);
4084 
4085 	(void) strlcpy(zc.zc_name, zhp->zpool_name, sizeof (zc.zc_name));
4086 	if (path) {
4087 		if ((tgt = zpool_find_vdev(zhp, path, &avail_spare,
4088 		    &l2cache, NULL)) == NULL)
4089 			return (zfs_error(hdl, EZFS_NODEVICE, errbuf));
4090 
4091 		/*
4092 		 * Don't allow error clearing for hot spares.  Do allow
4093 		 * error clearing for l2cache devices.
4094 		 */
4095 		if (avail_spare)
4096 			return (zfs_error(hdl, EZFS_ISSPARE, errbuf));
4097 
4098 		zc.zc_guid = fnvlist_lookup_uint64(tgt, ZPOOL_CONFIG_GUID);
4099 	}
4100 
4101 	zpool_get_load_policy(rewindnvl, &policy);
4102 	zc.zc_cookie = policy.zlp_rewind;
4103 
4104 	zcmd_alloc_dst_nvlist(hdl, &zc, zhp->zpool_config_size * 2);
4105 	zcmd_write_src_nvlist(hdl, &zc, rewindnvl);
4106 
4107 	while ((error = zfs_ioctl(hdl, ZFS_IOC_CLEAR, &zc)) != 0 &&
4108 	    errno == ENOMEM)
4109 		zcmd_expand_dst_nvlist(hdl, &zc);
4110 
4111 	if (!error || ((policy.zlp_rewind & ZPOOL_TRY_REWIND) &&
4112 	    errno != EPERM && errno != EACCES)) {
4113 		if (policy.zlp_rewind &
4114 		    (ZPOOL_DO_REWIND | ZPOOL_TRY_REWIND)) {
4115 			(void) zcmd_read_dst_nvlist(hdl, &zc, &nvi);
4116 			zpool_rewind_exclaim(hdl, zc.zc_name,
4117 			    ((policy.zlp_rewind & ZPOOL_TRY_REWIND) != 0),
4118 			    nvi);
4119 			nvlist_free(nvi);
4120 		}
4121 		zcmd_free_nvlists(&zc);
4122 		return (0);
4123 	}
4124 
4125 	zcmd_free_nvlists(&zc);
4126 	return (zpool_standard_error(hdl, errno, errbuf));
4127 }
4128 
4129 /*
4130  * Similar to zpool_clear(), but takes a GUID (used by fmd).
4131  */
4132 int
zpool_vdev_clear(zpool_handle_t * zhp,uint64_t guid)4133 zpool_vdev_clear(zpool_handle_t *zhp, uint64_t guid)
4134 {
4135 	zfs_cmd_t zc = {"\0"};
4136 	char errbuf[ERRBUFLEN];
4137 	libzfs_handle_t *hdl = zhp->zpool_hdl;
4138 
4139 	(void) snprintf(errbuf, sizeof (errbuf),
4140 	    dgettext(TEXT_DOMAIN, "cannot clear errors for %llx"),
4141 	    (u_longlong_t)guid);
4142 
4143 	(void) strlcpy(zc.zc_name, zhp->zpool_name, sizeof (zc.zc_name));
4144 	zc.zc_guid = guid;
4145 	zc.zc_cookie = ZPOOL_NO_REWIND;
4146 
4147 	if (zfs_ioctl(hdl, ZFS_IOC_CLEAR, &zc) == 0)
4148 		return (0);
4149 
4150 	return (zpool_standard_error(hdl, errno, errbuf));
4151 }
4152 
4153 /*
4154  * Change the GUID for a pool.
4155  */
4156 int
zpool_reguid(zpool_handle_t * zhp)4157 zpool_reguid(zpool_handle_t *zhp)
4158 {
4159 	char errbuf[ERRBUFLEN];
4160 	libzfs_handle_t *hdl = zhp->zpool_hdl;
4161 	zfs_cmd_t zc = {"\0"};
4162 
4163 	(void) snprintf(errbuf, sizeof (errbuf),
4164 	    dgettext(TEXT_DOMAIN, "cannot reguid '%s'"), zhp->zpool_name);
4165 
4166 	(void) strlcpy(zc.zc_name, zhp->zpool_name, sizeof (zc.zc_name));
4167 	if (zfs_ioctl(hdl, ZFS_IOC_POOL_REGUID, &zc) == 0)
4168 		return (0);
4169 
4170 	return (zpool_standard_error(hdl, errno, errbuf));
4171 }
4172 
4173 /*
4174  * Reopen the pool.
4175  */
4176 int
zpool_reopen_one(zpool_handle_t * zhp,void * data)4177 zpool_reopen_one(zpool_handle_t *zhp, void *data)
4178 {
4179 	libzfs_handle_t *hdl = zpool_get_handle(zhp);
4180 	const char *pool_name = zpool_get_name(zhp);
4181 	boolean_t *scrub_restart = data;
4182 	int error;
4183 
4184 	error = lzc_reopen(pool_name, *scrub_restart);
4185 	if (error) {
4186 		return (zpool_standard_error_fmt(hdl, error,
4187 		    dgettext(TEXT_DOMAIN, "cannot reopen '%s'"), pool_name));
4188 	}
4189 
4190 	return (0);
4191 }
4192 
4193 /* call into libzfs_core to execute the sync IOCTL per pool */
4194 int
zpool_sync_one(zpool_handle_t * zhp,void * data)4195 zpool_sync_one(zpool_handle_t *zhp, void *data)
4196 {
4197 	int ret;
4198 	libzfs_handle_t *hdl = zpool_get_handle(zhp);
4199 	const char *pool_name = zpool_get_name(zhp);
4200 	boolean_t *force = data;
4201 	nvlist_t *innvl = fnvlist_alloc();
4202 
4203 	fnvlist_add_boolean_value(innvl, "force", *force);
4204 	if ((ret = lzc_sync(pool_name, innvl, NULL)) != 0) {
4205 		nvlist_free(innvl);
4206 		return (zpool_standard_error_fmt(hdl, ret,
4207 		    dgettext(TEXT_DOMAIN, "sync '%s' failed"), pool_name));
4208 	}
4209 	nvlist_free(innvl);
4210 
4211 	return (0);
4212 }
4213 
4214 #define	PATH_BUF_LEN	64
4215 
4216 /*
4217  * Given a vdev, return the name to display in iostat.  If the vdev has a path,
4218  * we use that, stripping off any leading "/dev/dsk/"; if not, we use the type.
4219  * We also check if this is a whole disk, in which case we strip off the
4220  * trailing 's0' slice name.
4221  *
4222  * This routine is also responsible for identifying when disks have been
4223  * reconfigured in a new location.  The kernel will have opened the device by
4224  * devid, but the path will still refer to the old location.  To catch this, we
4225  * first do a path -> devid translation (which is fast for the common case).  If
4226  * the devid matches, we're done.  If not, we do a reverse devid -> path
4227  * translation and issue the appropriate ioctl() to update the path of the vdev.
4228  * If 'zhp' is NULL, then this is an exported pool, and we don't need to do any
4229  * of these checks.
4230  */
4231 char *
zpool_vdev_name(libzfs_handle_t * hdl,zpool_handle_t * zhp,nvlist_t * nv,int name_flags)4232 zpool_vdev_name(libzfs_handle_t *hdl, zpool_handle_t *zhp, nvlist_t *nv,
4233     int name_flags)
4234 {
4235 	const char *type, *tpath;
4236 	const char *path;
4237 	uint64_t value;
4238 	char buf[PATH_BUF_LEN];
4239 	char tmpbuf[PATH_BUF_LEN * 2];
4240 
4241 	/*
4242 	 * vdev_name will be "root"/"root-0" for the root vdev, but it is the
4243 	 * zpool name that will be displayed to the user.
4244 	 */
4245 	type = fnvlist_lookup_string(nv, ZPOOL_CONFIG_TYPE);
4246 	if (zhp != NULL && strcmp(type, "root") == 0)
4247 		return (zfs_strdup(hdl, zpool_get_name(zhp)));
4248 
4249 	if (libzfs_envvar_is_set("ZPOOL_VDEV_NAME_PATH"))
4250 		name_flags |= VDEV_NAME_PATH;
4251 	if (libzfs_envvar_is_set("ZPOOL_VDEV_NAME_GUID"))
4252 		name_flags |= VDEV_NAME_GUID;
4253 	if (libzfs_envvar_is_set("ZPOOL_VDEV_NAME_FOLLOW_LINKS"))
4254 		name_flags |= VDEV_NAME_FOLLOW_LINKS;
4255 
4256 	if (nvlist_lookup_uint64(nv, ZPOOL_CONFIG_NOT_PRESENT, &value) == 0 ||
4257 	    name_flags & VDEV_NAME_GUID) {
4258 		(void) nvlist_lookup_uint64(nv, ZPOOL_CONFIG_GUID, &value);
4259 		(void) snprintf(buf, sizeof (buf), "%llu", (u_longlong_t)value);
4260 		path = buf;
4261 	} else if (nvlist_lookup_string(nv, ZPOOL_CONFIG_PATH, &tpath) == 0) {
4262 		path = tpath;
4263 
4264 		if (name_flags & VDEV_NAME_FOLLOW_LINKS) {
4265 			char *rp = realpath(path, NULL);
4266 			if (rp) {
4267 				strlcpy(buf, rp, sizeof (buf));
4268 				path = buf;
4269 				free(rp);
4270 			}
4271 		}
4272 
4273 		/*
4274 		 * For a block device only use the name.
4275 		 */
4276 		if ((strcmp(type, VDEV_TYPE_DISK) == 0) &&
4277 		    !(name_flags & VDEV_NAME_PATH)) {
4278 			path = zfs_strip_path(path);
4279 		}
4280 
4281 		/*
4282 		 * Remove the partition from the path if this is a whole disk.
4283 		 */
4284 		if (strcmp(type, VDEV_TYPE_DRAID_SPARE) != 0 &&
4285 		    nvlist_lookup_uint64(nv, ZPOOL_CONFIG_WHOLE_DISK, &value)
4286 		    == 0 && value && !(name_flags & VDEV_NAME_PATH)) {
4287 			return (zfs_strip_partition(path));
4288 		}
4289 	} else {
4290 		path = type;
4291 
4292 		/*
4293 		 * If it's a raidz device, we need to stick in the parity level.
4294 		 */
4295 		if (strcmp(path, VDEV_TYPE_RAIDZ) == 0) {
4296 			value = fnvlist_lookup_uint64(nv, ZPOOL_CONFIG_NPARITY);
4297 			(void) snprintf(buf, sizeof (buf), "%s%llu", path,
4298 			    (u_longlong_t)value);
4299 			path = buf;
4300 		}
4301 
4302 		/*
4303 		 * If it's a dRAID device, we add parity, groups, and spares.
4304 		 */
4305 		if (strcmp(path, VDEV_TYPE_DRAID) == 0) {
4306 			uint64_t ndata, nparity, nspares;
4307 			nvlist_t **child;
4308 			uint_t children;
4309 
4310 			verify(nvlist_lookup_nvlist_array(nv,
4311 			    ZPOOL_CONFIG_CHILDREN, &child, &children) == 0);
4312 			nparity = fnvlist_lookup_uint64(nv,
4313 			    ZPOOL_CONFIG_NPARITY);
4314 			ndata = fnvlist_lookup_uint64(nv,
4315 			    ZPOOL_CONFIG_DRAID_NDATA);
4316 			nspares = fnvlist_lookup_uint64(nv,
4317 			    ZPOOL_CONFIG_DRAID_NSPARES);
4318 
4319 			path = zpool_draid_name(buf, sizeof (buf), ndata,
4320 			    nparity, nspares, children);
4321 		}
4322 
4323 		/*
4324 		 * We identify each top-level vdev by using a <type-id>
4325 		 * naming convention.
4326 		 */
4327 		if (name_flags & VDEV_NAME_TYPE_ID) {
4328 			uint64_t id = fnvlist_lookup_uint64(nv,
4329 			    ZPOOL_CONFIG_ID);
4330 			(void) snprintf(tmpbuf, sizeof (tmpbuf), "%s-%llu",
4331 			    path, (u_longlong_t)id);
4332 			path = tmpbuf;
4333 		}
4334 	}
4335 
4336 	return (zfs_strdup(hdl, path));
4337 }
4338 
4339 static int
zbookmark_mem_compare(const void * a,const void * b)4340 zbookmark_mem_compare(const void *a, const void *b)
4341 {
4342 	return (memcmp(a, b, sizeof (zbookmark_phys_t)));
4343 }
4344 
4345 /*
4346  * Retrieve the persistent error log, uniquify the members, and return to the
4347  * caller.
4348  */
4349 int
zpool_get_errlog(zpool_handle_t * zhp,nvlist_t ** nverrlistp)4350 zpool_get_errlog(zpool_handle_t *zhp, nvlist_t **nverrlistp)
4351 {
4352 	zfs_cmd_t zc = {"\0"};
4353 	libzfs_handle_t *hdl = zhp->zpool_hdl;
4354 	zbookmark_phys_t *buf;
4355 	uint64_t buflen = 10000; /* approx. 1MB of RAM */
4356 
4357 	if (fnvlist_lookup_uint64(zhp->zpool_config,
4358 	    ZPOOL_CONFIG_ERRCOUNT) == 0)
4359 		return (0);
4360 
4361 	/*
4362 	 * Retrieve the raw error list from the kernel.  If it doesn't fit,
4363 	 * allocate a larger buffer and retry.
4364 	 */
4365 	(void) strcpy(zc.zc_name, zhp->zpool_name);
4366 	for (;;) {
4367 		buf = zfs_alloc(zhp->zpool_hdl,
4368 		    buflen * sizeof (zbookmark_phys_t));
4369 		zc.zc_nvlist_dst = (uintptr_t)buf;
4370 		zc.zc_nvlist_dst_size = buflen;
4371 		if (zfs_ioctl(zhp->zpool_hdl, ZFS_IOC_ERROR_LOG,
4372 		    &zc) != 0) {
4373 			free(buf);
4374 			if (errno == ENOMEM) {
4375 				buflen *= 2;
4376 			} else {
4377 				return (zpool_standard_error_fmt(hdl, errno,
4378 				    dgettext(TEXT_DOMAIN, "errors: List of "
4379 				    "errors unavailable")));
4380 			}
4381 		} else {
4382 			break;
4383 		}
4384 	}
4385 
4386 	/*
4387 	 * Sort the resulting bookmarks.  This is a little confusing due to the
4388 	 * implementation of ZFS_IOC_ERROR_LOG.  The bookmarks are copied last
4389 	 * to first, and 'zc_nvlist_dst_size' indicates the number of bookmarks
4390 	 * _not_ copied as part of the process.  So we point the start of our
4391 	 * array appropriate and decrement the total number of elements.
4392 	 */
4393 	zbookmark_phys_t *zb = buf + zc.zc_nvlist_dst_size;
4394 	uint64_t zblen = buflen - zc.zc_nvlist_dst_size;
4395 
4396 	qsort(zb, zblen, sizeof (zbookmark_phys_t), zbookmark_mem_compare);
4397 
4398 	verify(nvlist_alloc(nverrlistp, 0, KM_SLEEP) == 0);
4399 
4400 	/*
4401 	 * Fill in the nverrlistp with nvlist's of dataset and object numbers.
4402 	 */
4403 	for (uint64_t i = 0; i < zblen; i++) {
4404 		nvlist_t *nv;
4405 
4406 		/* ignoring zb_blkid and zb_level for now */
4407 		if (i > 0 && zb[i-1].zb_objset == zb[i].zb_objset &&
4408 		    zb[i-1].zb_object == zb[i].zb_object)
4409 			continue;
4410 
4411 		if (nvlist_alloc(&nv, NV_UNIQUE_NAME, KM_SLEEP) != 0)
4412 			goto nomem;
4413 		if (nvlist_add_uint64(nv, ZPOOL_ERR_DATASET,
4414 		    zb[i].zb_objset) != 0) {
4415 			nvlist_free(nv);
4416 			goto nomem;
4417 		}
4418 		if (nvlist_add_uint64(nv, ZPOOL_ERR_OBJECT,
4419 		    zb[i].zb_object) != 0) {
4420 			nvlist_free(nv);
4421 			goto nomem;
4422 		}
4423 		if (nvlist_add_nvlist(*nverrlistp, "ejk", nv) != 0) {
4424 			nvlist_free(nv);
4425 			goto nomem;
4426 		}
4427 		nvlist_free(nv);
4428 	}
4429 
4430 	free(buf);
4431 	return (0);
4432 
4433 nomem:
4434 	free(buf);
4435 	return (no_memory(zhp->zpool_hdl));
4436 }
4437 
4438 /*
4439  * Upgrade a ZFS pool to the latest on-disk version.
4440  */
4441 int
zpool_upgrade(zpool_handle_t * zhp,uint64_t new_version)4442 zpool_upgrade(zpool_handle_t *zhp, uint64_t new_version)
4443 {
4444 	zfs_cmd_t zc = {"\0"};
4445 	libzfs_handle_t *hdl = zhp->zpool_hdl;
4446 
4447 	(void) strcpy(zc.zc_name, zhp->zpool_name);
4448 	zc.zc_cookie = new_version;
4449 
4450 	if (zfs_ioctl(hdl, ZFS_IOC_POOL_UPGRADE, &zc) != 0)
4451 		return (zpool_standard_error_fmt(hdl, errno,
4452 		    dgettext(TEXT_DOMAIN, "cannot upgrade '%s'"),
4453 		    zhp->zpool_name));
4454 	return (0);
4455 }
4456 
4457 void
zfs_save_arguments(int argc,char ** argv,char * string,int len)4458 zfs_save_arguments(int argc, char **argv, char *string, int len)
4459 {
4460 	int i;
4461 
4462 	(void) strlcpy(string, zfs_basename(argv[0]), len);
4463 	for (i = 1; i < argc; i++) {
4464 		(void) strlcat(string, " ", len);
4465 		(void) strlcat(string, argv[i], len);
4466 	}
4467 }
4468 
4469 int
zpool_log_history(libzfs_handle_t * hdl,const char * message)4470 zpool_log_history(libzfs_handle_t *hdl, const char *message)
4471 {
4472 	zfs_cmd_t zc = {"\0"};
4473 	nvlist_t *args;
4474 
4475 	args = fnvlist_alloc();
4476 	fnvlist_add_string(args, "message", message);
4477 	zcmd_write_src_nvlist(hdl, &zc, args);
4478 	int err = zfs_ioctl(hdl, ZFS_IOC_LOG_HISTORY, &zc);
4479 	nvlist_free(args);
4480 	zcmd_free_nvlists(&zc);
4481 	return (err);
4482 }
4483 
4484 /*
4485  * Perform ioctl to get some command history of a pool.
4486  *
4487  * 'buf' is the buffer to fill up to 'len' bytes.  'off' is the
4488  * logical offset of the history buffer to start reading from.
4489  *
4490  * Upon return, 'off' is the next logical offset to read from and
4491  * 'len' is the actual amount of bytes read into 'buf'.
4492  */
4493 static int
get_history(zpool_handle_t * zhp,char * buf,uint64_t * off,uint64_t * len)4494 get_history(zpool_handle_t *zhp, char *buf, uint64_t *off, uint64_t *len)
4495 {
4496 	zfs_cmd_t zc = {"\0"};
4497 	libzfs_handle_t *hdl = zhp->zpool_hdl;
4498 
4499 	(void) strlcpy(zc.zc_name, zhp->zpool_name, sizeof (zc.zc_name));
4500 
4501 	zc.zc_history = (uint64_t)(uintptr_t)buf;
4502 	zc.zc_history_len = *len;
4503 	zc.zc_history_offset = *off;
4504 
4505 	if (zfs_ioctl(hdl, ZFS_IOC_POOL_GET_HISTORY, &zc) != 0) {
4506 		switch (errno) {
4507 		case EPERM:
4508 			return (zfs_error_fmt(hdl, EZFS_PERM,
4509 			    dgettext(TEXT_DOMAIN,
4510 			    "cannot show history for pool '%s'"),
4511 			    zhp->zpool_name));
4512 		case ENOENT:
4513 			return (zfs_error_fmt(hdl, EZFS_NOHISTORY,
4514 			    dgettext(TEXT_DOMAIN, "cannot get history for pool "
4515 			    "'%s'"), zhp->zpool_name));
4516 		case ENOTSUP:
4517 			return (zfs_error_fmt(hdl, EZFS_BADVERSION,
4518 			    dgettext(TEXT_DOMAIN, "cannot get history for pool "
4519 			    "'%s', pool must be upgraded"), zhp->zpool_name));
4520 		default:
4521 			return (zpool_standard_error_fmt(hdl, errno,
4522 			    dgettext(TEXT_DOMAIN,
4523 			    "cannot get history for '%s'"), zhp->zpool_name));
4524 		}
4525 	}
4526 
4527 	*len = zc.zc_history_len;
4528 	*off = zc.zc_history_offset;
4529 
4530 	return (0);
4531 }
4532 
4533 /*
4534  * Retrieve the command history of a pool.
4535  */
4536 int
zpool_get_history(zpool_handle_t * zhp,nvlist_t ** nvhisp,uint64_t * off,boolean_t * eof)4537 zpool_get_history(zpool_handle_t *zhp, nvlist_t **nvhisp, uint64_t *off,
4538     boolean_t *eof)
4539 {
4540 	libzfs_handle_t *hdl = zhp->zpool_hdl;
4541 	char *buf;
4542 	int buflen = 128 * 1024;
4543 	nvlist_t **records = NULL;
4544 	uint_t numrecords = 0;
4545 	int err = 0, i;
4546 	uint64_t start = *off;
4547 
4548 	buf = zfs_alloc(hdl, buflen);
4549 
4550 	/* process about 1MiB a time */
4551 	while (*off - start < 1024 * 1024) {
4552 		uint64_t bytes_read = buflen;
4553 		uint64_t leftover;
4554 
4555 		if ((err = get_history(zhp, buf, off, &bytes_read)) != 0)
4556 			break;
4557 
4558 		/* if nothing else was read in, we're at EOF, just return */
4559 		if (!bytes_read) {
4560 			*eof = B_TRUE;
4561 			break;
4562 		}
4563 
4564 		if ((err = zpool_history_unpack(buf, bytes_read,
4565 		    &leftover, &records, &numrecords)) != 0) {
4566 			zpool_standard_error_fmt(hdl, err,
4567 			    dgettext(TEXT_DOMAIN,
4568 			    "cannot get history for '%s'"), zhp->zpool_name);
4569 			break;
4570 		}
4571 		*off -= leftover;
4572 		if (leftover == bytes_read) {
4573 			/*
4574 			 * no progress made, because buffer is not big enough
4575 			 * to hold this record; resize and retry.
4576 			 */
4577 			buflen *= 2;
4578 			free(buf);
4579 			buf = zfs_alloc(hdl, buflen);
4580 		}
4581 	}
4582 
4583 	free(buf);
4584 
4585 	if (!err) {
4586 		*nvhisp = fnvlist_alloc();
4587 		fnvlist_add_nvlist_array(*nvhisp, ZPOOL_HIST_RECORD,
4588 		    (const nvlist_t **)records, numrecords);
4589 	}
4590 	for (i = 0; i < numrecords; i++)
4591 		nvlist_free(records[i]);
4592 	free(records);
4593 
4594 	return (err);
4595 }
4596 
4597 /*
4598  * Retrieve the next event given the passed 'zevent_fd' file descriptor.
4599  * If there is a new event available 'nvp' will contain a newly allocated
4600  * nvlist and 'dropped' will be set to the number of missed events since
4601  * the last call to this function.  When 'nvp' is set to NULL it indicates
4602  * no new events are available.  In either case the function returns 0 and
4603  * it is up to the caller to free 'nvp'.  In the case of a fatal error the
4604  * function will return a non-zero value.  When the function is called in
4605  * blocking mode (the default, unless the ZEVENT_NONBLOCK flag is passed),
4606  * it will not return until a new event is available.
4607  */
4608 int
zpool_events_next(libzfs_handle_t * hdl,nvlist_t ** nvp,int * dropped,unsigned flags,int zevent_fd)4609 zpool_events_next(libzfs_handle_t *hdl, nvlist_t **nvp,
4610     int *dropped, unsigned flags, int zevent_fd)
4611 {
4612 	zfs_cmd_t zc = {"\0"};
4613 	int error = 0;
4614 
4615 	*nvp = NULL;
4616 	*dropped = 0;
4617 	zc.zc_cleanup_fd = zevent_fd;
4618 
4619 	if (flags & ZEVENT_NONBLOCK)
4620 		zc.zc_guid = ZEVENT_NONBLOCK;
4621 
4622 	zcmd_alloc_dst_nvlist(hdl, &zc, ZEVENT_SIZE);
4623 
4624 retry:
4625 	if (zfs_ioctl(hdl, ZFS_IOC_EVENTS_NEXT, &zc) != 0) {
4626 		switch (errno) {
4627 		case ESHUTDOWN:
4628 			error = zfs_error_fmt(hdl, EZFS_POOLUNAVAIL,
4629 			    dgettext(TEXT_DOMAIN, "zfs shutdown"));
4630 			goto out;
4631 		case ENOENT:
4632 			/* Blocking error case should not occur */
4633 			if (!(flags & ZEVENT_NONBLOCK))
4634 				error = zpool_standard_error_fmt(hdl, errno,
4635 				    dgettext(TEXT_DOMAIN, "cannot get event"));
4636 
4637 			goto out;
4638 		case ENOMEM:
4639 			zcmd_expand_dst_nvlist(hdl, &zc);
4640 			goto retry;
4641 		default:
4642 			error = zpool_standard_error_fmt(hdl, errno,
4643 			    dgettext(TEXT_DOMAIN, "cannot get event"));
4644 			goto out;
4645 		}
4646 	}
4647 
4648 	error = zcmd_read_dst_nvlist(hdl, &zc, nvp);
4649 	if (error != 0)
4650 		goto out;
4651 
4652 	*dropped = (int)zc.zc_cookie;
4653 out:
4654 	zcmd_free_nvlists(&zc);
4655 
4656 	return (error);
4657 }
4658 
4659 /*
4660  * Clear all events.
4661  */
4662 int
zpool_events_clear(libzfs_handle_t * hdl,int * count)4663 zpool_events_clear(libzfs_handle_t *hdl, int *count)
4664 {
4665 	zfs_cmd_t zc = {"\0"};
4666 
4667 	if (zfs_ioctl(hdl, ZFS_IOC_EVENTS_CLEAR, &zc) != 0)
4668 		return (zpool_standard_error(hdl, errno,
4669 		    dgettext(TEXT_DOMAIN, "cannot clear events")));
4670 
4671 	if (count != NULL)
4672 		*count = (int)zc.zc_cookie; /* # of events cleared */
4673 
4674 	return (0);
4675 }
4676 
4677 /*
4678  * Seek to a specific EID, ZEVENT_SEEK_START, or ZEVENT_SEEK_END for
4679  * the passed zevent_fd file handle.  On success zero is returned,
4680  * otherwise -1 is returned and hdl->libzfs_error is set to the errno.
4681  */
4682 int
zpool_events_seek(libzfs_handle_t * hdl,uint64_t eid,int zevent_fd)4683 zpool_events_seek(libzfs_handle_t *hdl, uint64_t eid, int zevent_fd)
4684 {
4685 	zfs_cmd_t zc = {"\0"};
4686 	int error = 0;
4687 
4688 	zc.zc_guid = eid;
4689 	zc.zc_cleanup_fd = zevent_fd;
4690 
4691 	if (zfs_ioctl(hdl, ZFS_IOC_EVENTS_SEEK, &zc) != 0) {
4692 		switch (errno) {
4693 		case ENOENT:
4694 			error = zfs_error_fmt(hdl, EZFS_NOENT,
4695 			    dgettext(TEXT_DOMAIN, "cannot get event"));
4696 			break;
4697 
4698 		case ENOMEM:
4699 			error = zfs_error_fmt(hdl, EZFS_NOMEM,
4700 			    dgettext(TEXT_DOMAIN, "cannot get event"));
4701 			break;
4702 
4703 		default:
4704 			error = zpool_standard_error_fmt(hdl, errno,
4705 			    dgettext(TEXT_DOMAIN, "cannot get event"));
4706 			break;
4707 		}
4708 	}
4709 
4710 	return (error);
4711 }
4712 
4713 static void
zpool_obj_to_path_impl(zpool_handle_t * zhp,uint64_t dsobj,uint64_t obj,char * pathname,size_t len,boolean_t always_unmounted)4714 zpool_obj_to_path_impl(zpool_handle_t *zhp, uint64_t dsobj, uint64_t obj,
4715     char *pathname, size_t len, boolean_t always_unmounted)
4716 {
4717 	zfs_cmd_t zc = {"\0"};
4718 	boolean_t mounted = B_FALSE;
4719 	char *mntpnt = NULL;
4720 	char dsname[ZFS_MAX_DATASET_NAME_LEN];
4721 
4722 	if (dsobj == 0) {
4723 		/* special case for the MOS */
4724 		(void) snprintf(pathname, len, "<metadata>:<0x%llx>",
4725 		    (longlong_t)obj);
4726 		return;
4727 	}
4728 
4729 	/* get the dataset's name */
4730 	(void) strlcpy(zc.zc_name, zhp->zpool_name, sizeof (zc.zc_name));
4731 	zc.zc_obj = dsobj;
4732 	if (zfs_ioctl(zhp->zpool_hdl,
4733 	    ZFS_IOC_DSOBJ_TO_DSNAME, &zc) != 0) {
4734 		/* just write out a path of two object numbers */
4735 		(void) snprintf(pathname, len, "<0x%llx>:<0x%llx>",
4736 		    (longlong_t)dsobj, (longlong_t)obj);
4737 		return;
4738 	}
4739 	(void) strlcpy(dsname, zc.zc_value, sizeof (dsname));
4740 
4741 	/* find out if the dataset is mounted */
4742 	mounted = !always_unmounted && is_mounted(zhp->zpool_hdl, dsname,
4743 	    &mntpnt);
4744 
4745 	/* get the corrupted object's path */
4746 	(void) strlcpy(zc.zc_name, dsname, sizeof (zc.zc_name));
4747 	zc.zc_obj = obj;
4748 	if (zfs_ioctl(zhp->zpool_hdl, ZFS_IOC_OBJ_TO_PATH,
4749 	    &zc) == 0) {
4750 		if (mounted) {
4751 			(void) snprintf(pathname, len, "%s%s", mntpnt,
4752 			    zc.zc_value);
4753 		} else {
4754 			(void) snprintf(pathname, len, "%s:%s",
4755 			    dsname, zc.zc_value);
4756 		}
4757 	} else {
4758 		(void) snprintf(pathname, len, "%s:<0x%llx>", dsname,
4759 		    (longlong_t)obj);
4760 	}
4761 	free(mntpnt);
4762 }
4763 
4764 void
zpool_obj_to_path(zpool_handle_t * zhp,uint64_t dsobj,uint64_t obj,char * pathname,size_t len)4765 zpool_obj_to_path(zpool_handle_t *zhp, uint64_t dsobj, uint64_t obj,
4766     char *pathname, size_t len)
4767 {
4768 	zpool_obj_to_path_impl(zhp, dsobj, obj, pathname, len, B_FALSE);
4769 }
4770 
4771 void
zpool_obj_to_path_ds(zpool_handle_t * zhp,uint64_t dsobj,uint64_t obj,char * pathname,size_t len)4772 zpool_obj_to_path_ds(zpool_handle_t *zhp, uint64_t dsobj, uint64_t obj,
4773     char *pathname, size_t len)
4774 {
4775 	zpool_obj_to_path_impl(zhp, dsobj, obj, pathname, len, B_TRUE);
4776 }
4777 /*
4778  * Wait while the specified activity is in progress in the pool.
4779  */
4780 int
zpool_wait(zpool_handle_t * zhp,zpool_wait_activity_t activity)4781 zpool_wait(zpool_handle_t *zhp, zpool_wait_activity_t activity)
4782 {
4783 	boolean_t missing;
4784 
4785 	int error = zpool_wait_status(zhp, activity, &missing, NULL);
4786 
4787 	if (missing) {
4788 		(void) zpool_standard_error_fmt(zhp->zpool_hdl, ENOENT,
4789 		    dgettext(TEXT_DOMAIN, "error waiting in pool '%s'"),
4790 		    zhp->zpool_name);
4791 		return (ENOENT);
4792 	} else {
4793 		return (error);
4794 	}
4795 }
4796 
4797 /*
4798  * Wait for the given activity and return the status of the wait (whether or not
4799  * any waiting was done) in the 'waited' parameter. Non-existent pools are
4800  * reported via the 'missing' parameter, rather than by printing an error
4801  * message. This is convenient when this function is called in a loop over a
4802  * long period of time (as it is, for example, by zpool's wait cmd). In that
4803  * scenario, a pool being exported or destroyed should be considered a normal
4804  * event, so we don't want to print an error when we find that the pool doesn't
4805  * exist.
4806  */
4807 int
zpool_wait_status(zpool_handle_t * zhp,zpool_wait_activity_t activity,boolean_t * missing,boolean_t * waited)4808 zpool_wait_status(zpool_handle_t *zhp, zpool_wait_activity_t activity,
4809     boolean_t *missing, boolean_t *waited)
4810 {
4811 	int error = lzc_wait(zhp->zpool_name, activity, waited);
4812 	*missing = (error == ENOENT);
4813 	if (*missing)
4814 		return (0);
4815 
4816 	if (error != 0) {
4817 		(void) zpool_standard_error_fmt(zhp->zpool_hdl, error,
4818 		    dgettext(TEXT_DOMAIN, "error waiting in pool '%s'"),
4819 		    zhp->zpool_name);
4820 	}
4821 
4822 	return (error);
4823 }
4824 
4825 int
zpool_set_bootenv(zpool_handle_t * zhp,const nvlist_t * envmap)4826 zpool_set_bootenv(zpool_handle_t *zhp, const nvlist_t *envmap)
4827 {
4828 	int error = lzc_set_bootenv(zhp->zpool_name, envmap);
4829 	if (error != 0) {
4830 		(void) zpool_standard_error_fmt(zhp->zpool_hdl, error,
4831 		    dgettext(TEXT_DOMAIN,
4832 		    "error setting bootenv in pool '%s'"), zhp->zpool_name);
4833 	}
4834 
4835 	return (error);
4836 }
4837 
4838 int
zpool_get_bootenv(zpool_handle_t * zhp,nvlist_t ** nvlp)4839 zpool_get_bootenv(zpool_handle_t *zhp, nvlist_t **nvlp)
4840 {
4841 	nvlist_t *nvl;
4842 	int error;
4843 
4844 	nvl = NULL;
4845 	error = lzc_get_bootenv(zhp->zpool_name, &nvl);
4846 	if (error != 0) {
4847 		(void) zpool_standard_error_fmt(zhp->zpool_hdl, error,
4848 		    dgettext(TEXT_DOMAIN,
4849 		    "error getting bootenv in pool '%s'"), zhp->zpool_name);
4850 	} else {
4851 		*nvlp = nvl;
4852 	}
4853 
4854 	return (error);
4855 }
4856 
4857 /*
4858  * Attempt to read and parse feature file(s) (from "compatibility" property).
4859  * Files contain zpool feature names, comma or whitespace-separated.
4860  * Comments (# character to next newline) are discarded.
4861  *
4862  * Arguments:
4863  *  compatibility : string containing feature filenames
4864  *  features : either NULL or pointer to array of boolean
4865  *  report : either NULL or pointer to string buffer
4866  *  rlen : length of "report" buffer
4867  *
4868  * compatibility is NULL (unset), "", "off", "legacy", or list of
4869  * comma-separated filenames. filenames should either be absolute,
4870  * or relative to:
4871  *   1) ZPOOL_SYSCONF_COMPAT_D (eg: /etc/zfs/compatibility.d) or
4872  *   2) ZPOOL_DATA_COMPAT_D (eg: /usr/share/zfs/compatibility.d).
4873  * (Unset), "" or "off" => enable all features
4874  * "legacy" => disable all features
4875  *
4876  * Any feature names read from files which match unames in spa_feature_table
4877  * will have the corresponding boolean set in the features array (if non-NULL).
4878  * If more than one feature set specified, only features present in *all* of
4879  * them will be set.
4880  *
4881  * "report" if not NULL will be populated with a suitable status message.
4882  *
4883  * Return values:
4884  *   ZPOOL_COMPATIBILITY_OK : files read and parsed ok
4885  *   ZPOOL_COMPATIBILITY_BADFILE : file too big or not a text file
4886  *   ZPOOL_COMPATIBILITY_BADTOKEN : SYSCONF file contains invalid feature name
4887  *   ZPOOL_COMPATIBILITY_WARNTOKEN : DATA file contains invalid feature name
4888  *   ZPOOL_COMPATIBILITY_NOFILES : no feature files found
4889  */
4890 zpool_compat_status_t
zpool_load_compat(const char * compat,boolean_t * features,char * report,size_t rlen)4891 zpool_load_compat(const char *compat, boolean_t *features, char *report,
4892     size_t rlen)
4893 {
4894 	int sdirfd, ddirfd, featfd;
4895 	struct stat fs;
4896 	char *fc;
4897 	char *ps, *ls, *ws;
4898 	char *file, *line, *word;
4899 
4900 	char l_compat[ZFS_MAXPROPLEN];
4901 
4902 	boolean_t ret_nofiles = B_TRUE;
4903 	boolean_t ret_badfile = B_FALSE;
4904 	boolean_t ret_badtoken = B_FALSE;
4905 	boolean_t ret_warntoken = B_FALSE;
4906 
4907 	/* special cases (unset), "" and "off" => enable all features */
4908 	if (compat == NULL || compat[0] == '\0' ||
4909 	    strcmp(compat, ZPOOL_COMPAT_OFF) == 0) {
4910 		if (features != NULL)
4911 			for (uint_t i = 0; i < SPA_FEATURES; i++)
4912 				features[i] = B_TRUE;
4913 		if (report != NULL)
4914 			strlcpy(report, gettext("all features enabled"), rlen);
4915 		return (ZPOOL_COMPATIBILITY_OK);
4916 	}
4917 
4918 	/* Final special case "legacy" => disable all features */
4919 	if (strcmp(compat, ZPOOL_COMPAT_LEGACY) == 0) {
4920 		if (features != NULL)
4921 			for (uint_t i = 0; i < SPA_FEATURES; i++)
4922 				features[i] = B_FALSE;
4923 		if (report != NULL)
4924 			strlcpy(report, gettext("all features disabled"), rlen);
4925 		return (ZPOOL_COMPATIBILITY_OK);
4926 	}
4927 
4928 	/*
4929 	 * Start with all true; will be ANDed with results from each file
4930 	 */
4931 	if (features != NULL)
4932 		for (uint_t i = 0; i < SPA_FEATURES; i++)
4933 			features[i] = B_TRUE;
4934 
4935 	char err_badfile[ZFS_MAXPROPLEN] = "";
4936 	char err_badtoken[ZFS_MAXPROPLEN] = "";
4937 
4938 	/*
4939 	 * We ignore errors from the directory open()
4940 	 * as they're only needed if the filename is relative
4941 	 * which will be checked during the openat().
4942 	 */
4943 
4944 /* O_PATH safer than O_RDONLY if system allows it */
4945 #if defined(O_PATH)
4946 #define	ZC_DIR_FLAGS (O_DIRECTORY | O_CLOEXEC | O_PATH)
4947 #else
4948 #define	ZC_DIR_FLAGS (O_DIRECTORY | O_CLOEXEC | O_RDONLY)
4949 #endif
4950 
4951 	sdirfd = open(ZPOOL_SYSCONF_COMPAT_D, ZC_DIR_FLAGS);
4952 	ddirfd = open(ZPOOL_DATA_COMPAT_D, ZC_DIR_FLAGS);
4953 
4954 	(void) strlcpy(l_compat, compat, ZFS_MAXPROPLEN);
4955 
4956 	for (file = strtok_r(l_compat, ",", &ps);
4957 	    file != NULL;
4958 	    file = strtok_r(NULL, ",", &ps)) {
4959 
4960 		boolean_t l_features[SPA_FEATURES];
4961 
4962 		enum { Z_SYSCONF, Z_DATA } source;
4963 
4964 		/* try sysconfdir first, then datadir */
4965 		source = Z_SYSCONF;
4966 		if ((featfd = openat(sdirfd, file, O_RDONLY | O_CLOEXEC)) < 0) {
4967 			featfd = openat(ddirfd, file, O_RDONLY | O_CLOEXEC);
4968 			source = Z_DATA;
4969 		}
4970 
4971 		/* File readable and correct size? */
4972 		if (featfd < 0 ||
4973 		    fstat(featfd, &fs) < 0 ||
4974 		    fs.st_size < 1 ||
4975 		    fs.st_size > ZPOOL_COMPAT_MAXSIZE) {
4976 			(void) close(featfd);
4977 			strlcat(err_badfile, file, ZFS_MAXPROPLEN);
4978 			strlcat(err_badfile, " ", ZFS_MAXPROPLEN);
4979 			ret_badfile = B_TRUE;
4980 			continue;
4981 		}
4982 
4983 /* Prefault the file if system allows */
4984 #if defined(MAP_POPULATE)
4985 #define	ZC_MMAP_FLAGS (MAP_PRIVATE | MAP_POPULATE)
4986 #elif defined(MAP_PREFAULT_READ)
4987 #define	ZC_MMAP_FLAGS (MAP_PRIVATE | MAP_PREFAULT_READ)
4988 #else
4989 #define	ZC_MMAP_FLAGS (MAP_PRIVATE)
4990 #endif
4991 
4992 		/* private mmap() so we can strtok safely */
4993 		fc = (char *)mmap(NULL, fs.st_size, PROT_READ | PROT_WRITE,
4994 		    ZC_MMAP_FLAGS, featfd, 0);
4995 		(void) close(featfd);
4996 
4997 		/* map ok, and last character == newline? */
4998 		if (fc == MAP_FAILED || fc[fs.st_size - 1] != '\n') {
4999 			(void) munmap((void *) fc, fs.st_size);
5000 			strlcat(err_badfile, file, ZFS_MAXPROPLEN);
5001 			strlcat(err_badfile, " ", ZFS_MAXPROPLEN);
5002 			ret_badfile = B_TRUE;
5003 			continue;
5004 		}
5005 
5006 		ret_nofiles = B_FALSE;
5007 
5008 		for (uint_t i = 0; i < SPA_FEATURES; i++)
5009 			l_features[i] = B_FALSE;
5010 
5011 		/* replace final newline with NULL to ensure string ends */
5012 		fc[fs.st_size - 1] = '\0';
5013 
5014 		for (line = strtok_r(fc, "\n", &ls);
5015 		    line != NULL;
5016 		    line = strtok_r(NULL, "\n", &ls)) {
5017 			/* discard comments */
5018 			char *r = strchr(line, '#');
5019 			if (r != NULL)
5020 				*r = '\0';
5021 
5022 			for (word = strtok_r(line, ", \t", &ws);
5023 			    word != NULL;
5024 			    word = strtok_r(NULL, ", \t", &ws)) {
5025 				/* Find matching feature name */
5026 				uint_t f;
5027 				for (f = 0; f < SPA_FEATURES; f++) {
5028 					zfeature_info_t *fi =
5029 					    &spa_feature_table[f];
5030 					if (strcmp(word, fi->fi_uname) == 0) {
5031 						l_features[f] = B_TRUE;
5032 						break;
5033 					}
5034 				}
5035 				if (f < SPA_FEATURES)
5036 					continue;
5037 
5038 				/* found an unrecognized word */
5039 				/* lightly sanitize it */
5040 				if (strlen(word) > 32)
5041 					word[32] = '\0';
5042 				for (char *c = word; *c != '\0'; c++)
5043 					if (!isprint(*c))
5044 						*c = '?';
5045 
5046 				strlcat(err_badtoken, word, ZFS_MAXPROPLEN);
5047 				strlcat(err_badtoken, " ", ZFS_MAXPROPLEN);
5048 				if (source == Z_SYSCONF)
5049 					ret_badtoken = B_TRUE;
5050 				else
5051 					ret_warntoken = B_TRUE;
5052 			}
5053 		}
5054 		(void) munmap((void *) fc, fs.st_size);
5055 
5056 		if (features != NULL)
5057 			for (uint_t i = 0; i < SPA_FEATURES; i++)
5058 				features[i] &= l_features[i];
5059 	}
5060 	(void) close(sdirfd);
5061 	(void) close(ddirfd);
5062 
5063 	/* Return the most serious error */
5064 	if (ret_badfile) {
5065 		if (report != NULL)
5066 			snprintf(report, rlen, gettext("could not read/"
5067 			    "parse feature file(s): %s"), err_badfile);
5068 		return (ZPOOL_COMPATIBILITY_BADFILE);
5069 	}
5070 	if (ret_nofiles) {
5071 		if (report != NULL)
5072 			strlcpy(report,
5073 			    gettext("no valid compatibility files specified"),
5074 			    rlen);
5075 		return (ZPOOL_COMPATIBILITY_NOFILES);
5076 	}
5077 	if (ret_badtoken) {
5078 		if (report != NULL)
5079 			snprintf(report, rlen, gettext("invalid feature "
5080 			    "name(s) in local compatibility files: %s"),
5081 			    err_badtoken);
5082 		return (ZPOOL_COMPATIBILITY_BADTOKEN);
5083 	}
5084 	if (ret_warntoken) {
5085 		if (report != NULL)
5086 			snprintf(report, rlen, gettext("unrecognized feature "
5087 			    "name(s) in distribution compatibility files: %s"),
5088 			    err_badtoken);
5089 		return (ZPOOL_COMPATIBILITY_WARNTOKEN);
5090 	}
5091 	if (report != NULL)
5092 		strlcpy(report, gettext("compatibility set ok"), rlen);
5093 	return (ZPOOL_COMPATIBILITY_OK);
5094 }
5095 
5096 static int
zpool_vdev_guid(zpool_handle_t * zhp,const char * vdevname,uint64_t * vdev_guid)5097 zpool_vdev_guid(zpool_handle_t *zhp, const char *vdevname, uint64_t *vdev_guid)
5098 {
5099 	nvlist_t *tgt;
5100 	boolean_t avail_spare, l2cache;
5101 
5102 	verify(zhp != NULL);
5103 	if (zpool_get_state(zhp) == POOL_STATE_UNAVAIL) {
5104 		char errbuf[ERRBUFLEN];
5105 		(void) snprintf(errbuf, sizeof (errbuf),
5106 		    dgettext(TEXT_DOMAIN, "pool is in an unavailable state"));
5107 		return (zfs_error(zhp->zpool_hdl, EZFS_POOLUNAVAIL, errbuf));
5108 	}
5109 
5110 	if ((tgt = zpool_find_vdev(zhp, vdevname, &avail_spare, &l2cache,
5111 	    NULL)) == NULL) {
5112 		char errbuf[ERRBUFLEN];
5113 		(void) snprintf(errbuf, sizeof (errbuf),
5114 		    dgettext(TEXT_DOMAIN, "can not find %s in %s"),
5115 		    vdevname, zhp->zpool_name);
5116 		return (zfs_error(zhp->zpool_hdl, EZFS_NODEVICE, errbuf));
5117 	}
5118 
5119 	*vdev_guid = fnvlist_lookup_uint64(tgt, ZPOOL_CONFIG_GUID);
5120 	return (0);
5121 }
5122 
5123 /*
5124  * Get a vdev property value for 'prop' and return the value in
5125  * a pre-allocated buffer.
5126  */
5127 int
zpool_get_vdev_prop_value(nvlist_t * nvprop,vdev_prop_t prop,char * prop_name,char * buf,size_t len,zprop_source_t * srctype,boolean_t literal)5128 zpool_get_vdev_prop_value(nvlist_t *nvprop, vdev_prop_t prop, char *prop_name,
5129     char *buf, size_t len, zprop_source_t *srctype, boolean_t literal)
5130 {
5131 	nvlist_t *nv;
5132 	const char *strval;
5133 	uint64_t intval;
5134 	zprop_source_t src = ZPROP_SRC_NONE;
5135 
5136 	if (prop == VDEV_PROP_USERPROP) {
5137 		/* user property, prop_name must contain the property name */
5138 		assert(prop_name != NULL);
5139 		if (nvlist_lookup_nvlist(nvprop, prop_name, &nv) == 0) {
5140 			src = fnvlist_lookup_uint64(nv, ZPROP_SOURCE);
5141 			strval = fnvlist_lookup_string(nv, ZPROP_VALUE);
5142 		} else {
5143 			/* user prop not found */
5144 			return (-1);
5145 		}
5146 		(void) strlcpy(buf, strval, len);
5147 		if (srctype)
5148 			*srctype = src;
5149 		return (0);
5150 	}
5151 
5152 	if (prop_name == NULL)
5153 		prop_name = (char *)vdev_prop_to_name(prop);
5154 
5155 	switch (vdev_prop_get_type(prop)) {
5156 	case PROP_TYPE_STRING:
5157 		if (nvlist_lookup_nvlist(nvprop, prop_name, &nv) == 0) {
5158 			src = fnvlist_lookup_uint64(nv, ZPROP_SOURCE);
5159 			strval = fnvlist_lookup_string(nv, ZPROP_VALUE);
5160 		} else {
5161 			src = ZPROP_SRC_DEFAULT;
5162 			if ((strval = vdev_prop_default_string(prop)) == NULL)
5163 				strval = "-";
5164 		}
5165 		(void) strlcpy(buf, strval, len);
5166 		break;
5167 
5168 	case PROP_TYPE_NUMBER:
5169 		if (nvlist_lookup_nvlist(nvprop, prop_name, &nv) == 0) {
5170 			src = fnvlist_lookup_uint64(nv, ZPROP_SOURCE);
5171 			intval = fnvlist_lookup_uint64(nv, ZPROP_VALUE);
5172 		} else {
5173 			src = ZPROP_SRC_DEFAULT;
5174 			intval = vdev_prop_default_numeric(prop);
5175 		}
5176 
5177 		switch (prop) {
5178 		case VDEV_PROP_ASIZE:
5179 		case VDEV_PROP_PSIZE:
5180 		case VDEV_PROP_SIZE:
5181 		case VDEV_PROP_BOOTSIZE:
5182 		case VDEV_PROP_ALLOCATED:
5183 		case VDEV_PROP_FREE:
5184 		case VDEV_PROP_READ_ERRORS:
5185 		case VDEV_PROP_WRITE_ERRORS:
5186 		case VDEV_PROP_CHECKSUM_ERRORS:
5187 		case VDEV_PROP_INITIALIZE_ERRORS:
5188 		case VDEV_PROP_OPS_NULL:
5189 		case VDEV_PROP_OPS_READ:
5190 		case VDEV_PROP_OPS_WRITE:
5191 		case VDEV_PROP_OPS_FREE:
5192 		case VDEV_PROP_OPS_CLAIM:
5193 		case VDEV_PROP_OPS_TRIM:
5194 		case VDEV_PROP_BYTES_NULL:
5195 		case VDEV_PROP_BYTES_READ:
5196 		case VDEV_PROP_BYTES_WRITE:
5197 		case VDEV_PROP_BYTES_FREE:
5198 		case VDEV_PROP_BYTES_CLAIM:
5199 		case VDEV_PROP_BYTES_TRIM:
5200 			if (literal) {
5201 				(void) snprintf(buf, len, "%llu",
5202 				    (u_longlong_t)intval);
5203 			} else {
5204 				(void) zfs_nicenum(intval, buf, len);
5205 			}
5206 			break;
5207 		case VDEV_PROP_EXPANDSZ:
5208 			if (intval == 0) {
5209 				(void) strlcpy(buf, "-", len);
5210 			} else if (literal) {
5211 				(void) snprintf(buf, len, "%llu",
5212 				    (u_longlong_t)intval);
5213 			} else {
5214 				(void) zfs_nicenum(intval, buf, len);
5215 			}
5216 			break;
5217 		case VDEV_PROP_CAPACITY:
5218 			if (literal) {
5219 				(void) snprintf(buf, len, "%llu",
5220 				    (u_longlong_t)intval);
5221 			} else {
5222 				(void) snprintf(buf, len, "%llu%%",
5223 				    (u_longlong_t)intval);
5224 			}
5225 			break;
5226 		case VDEV_PROP_CHECKSUM_N:
5227 		case VDEV_PROP_CHECKSUM_T:
5228 		case VDEV_PROP_IO_N:
5229 		case VDEV_PROP_IO_T:
5230 		case VDEV_PROP_SLOW_IO_N:
5231 		case VDEV_PROP_SLOW_IO_T:
5232 			if (intval == UINT64_MAX) {
5233 				(void) strlcpy(buf, "-", len);
5234 			} else {
5235 				(void) snprintf(buf, len, "%llu",
5236 				    (u_longlong_t)intval);
5237 			}
5238 			break;
5239 		case VDEV_PROP_FRAGMENTATION:
5240 			if (intval == UINT64_MAX) {
5241 				(void) strlcpy(buf, "-", len);
5242 			} else {
5243 				(void) snprintf(buf, len, "%llu%%",
5244 				    (u_longlong_t)intval);
5245 			}
5246 			break;
5247 		case VDEV_PROP_STATE:
5248 			if (literal) {
5249 				(void) snprintf(buf, len, "%llu",
5250 				    (u_longlong_t)intval);
5251 			} else {
5252 				(void) strlcpy(buf, zpool_state_to_name(intval,
5253 				    VDEV_AUX_NONE), len);
5254 			}
5255 			break;
5256 		default:
5257 			(void) snprintf(buf, len, "%llu",
5258 			    (u_longlong_t)intval);
5259 		}
5260 		break;
5261 
5262 	case PROP_TYPE_INDEX:
5263 		if (nvlist_lookup_nvlist(nvprop, prop_name, &nv) == 0) {
5264 			src = fnvlist_lookup_uint64(nv, ZPROP_SOURCE);
5265 			intval = fnvlist_lookup_uint64(nv, ZPROP_VALUE);
5266 		} else {
5267 			src = ZPROP_SRC_DEFAULT;
5268 			intval = vdev_prop_default_numeric(prop);
5269 		}
5270 		if (vdev_prop_index_to_string(prop, intval,
5271 		    (const char **)&strval) != 0)
5272 			return (-1);
5273 		(void) strlcpy(buf, strval, len);
5274 		break;
5275 
5276 	default:
5277 		abort();
5278 	}
5279 
5280 	if (srctype)
5281 		*srctype = src;
5282 
5283 	return (0);
5284 }
5285 
5286 /*
5287  * Get a vdev property value for 'prop_name' and return the value in
5288  * a pre-allocated buffer.
5289  */
5290 int
zpool_get_vdev_prop(zpool_handle_t * zhp,const char * vdevname,vdev_prop_t prop,char * prop_name,char * buf,size_t len,zprop_source_t * srctype,boolean_t literal)5291 zpool_get_vdev_prop(zpool_handle_t *zhp, const char *vdevname, vdev_prop_t prop,
5292     char *prop_name, char *buf, size_t len, zprop_source_t *srctype,
5293     boolean_t literal)
5294 {
5295 	nvlist_t *reqnvl, *reqprops;
5296 	nvlist_t *retprops = NULL;
5297 	uint64_t vdev_guid = 0;
5298 	int ret;
5299 
5300 	if ((ret = zpool_vdev_guid(zhp, vdevname, &vdev_guid)) != 0)
5301 		return (ret);
5302 
5303 	if (nvlist_alloc(&reqnvl, NV_UNIQUE_NAME, 0) != 0)
5304 		return (no_memory(zhp->zpool_hdl));
5305 	if (nvlist_alloc(&reqprops, NV_UNIQUE_NAME, 0) != 0)
5306 		return (no_memory(zhp->zpool_hdl));
5307 
5308 	fnvlist_add_uint64(reqnvl, ZPOOL_VDEV_PROPS_GET_VDEV, vdev_guid);
5309 
5310 	if (prop != VDEV_PROP_USERPROP) {
5311 		/* prop_name overrides prop value */
5312 		if (prop_name != NULL)
5313 			prop = vdev_name_to_prop(prop_name);
5314 		else
5315 			prop_name = (char *)vdev_prop_to_name(prop);
5316 		assert(prop < VDEV_NUM_PROPS);
5317 	}
5318 
5319 	assert(prop_name != NULL);
5320 	if (nvlist_add_uint64(reqprops, prop_name, prop) != 0) {
5321 		nvlist_free(reqnvl);
5322 		nvlist_free(reqprops);
5323 		return (no_memory(zhp->zpool_hdl));
5324 	}
5325 
5326 	fnvlist_add_nvlist(reqnvl, ZPOOL_VDEV_PROPS_GET_PROPS, reqprops);
5327 
5328 	ret = lzc_get_vdev_prop(zhp->zpool_name, reqnvl, &retprops);
5329 
5330 	if (ret == 0) {
5331 		ret = zpool_get_vdev_prop_value(retprops, prop, prop_name, buf,
5332 		    len, srctype, literal);
5333 	} else {
5334 		char errbuf[ERRBUFLEN];
5335 		(void) snprintf(errbuf, sizeof (errbuf),
5336 		    dgettext(TEXT_DOMAIN, "cannot get vdev property %s from"
5337 		    " %s in %s"), prop_name, vdevname, zhp->zpool_name);
5338 		(void) zpool_standard_error(zhp->zpool_hdl, ret, errbuf);
5339 	}
5340 
5341 	nvlist_free(reqnvl);
5342 	nvlist_free(reqprops);
5343 	nvlist_free(retprops);
5344 
5345 	return (ret);
5346 }
5347 
5348 /*
5349  * Get all vdev properties
5350  */
5351 int
zpool_get_all_vdev_props(zpool_handle_t * zhp,const char * vdevname,nvlist_t ** outnvl)5352 zpool_get_all_vdev_props(zpool_handle_t *zhp, const char *vdevname,
5353     nvlist_t **outnvl)
5354 {
5355 	nvlist_t *nvl = NULL;
5356 	uint64_t vdev_guid = 0;
5357 	int ret;
5358 
5359 	if ((ret = zpool_vdev_guid(zhp, vdevname, &vdev_guid)) != 0)
5360 		return (ret);
5361 
5362 	if (nvlist_alloc(&nvl, NV_UNIQUE_NAME, 0) != 0)
5363 		return (no_memory(zhp->zpool_hdl));
5364 
5365 	fnvlist_add_uint64(nvl, ZPOOL_VDEV_PROPS_GET_VDEV, vdev_guid);
5366 
5367 	ret = lzc_get_vdev_prop(zhp->zpool_name, nvl, outnvl);
5368 
5369 	nvlist_free(nvl);
5370 
5371 	if (ret) {
5372 		char errbuf[ERRBUFLEN];
5373 		(void) snprintf(errbuf, sizeof (errbuf),
5374 		    dgettext(TEXT_DOMAIN, "cannot get vdev properties for"
5375 		    " %s in %s"), vdevname, zhp->zpool_name);
5376 		(void) zpool_standard_error(zhp->zpool_hdl, errno, errbuf);
5377 	}
5378 
5379 	return (ret);
5380 }
5381 
5382 /*
5383  * Set vdev property
5384  */
5385 int
zpool_set_vdev_prop(zpool_handle_t * zhp,const char * vdevname,const char * propname,const char * propval)5386 zpool_set_vdev_prop(zpool_handle_t *zhp, const char *vdevname,
5387     const char *propname, const char *propval)
5388 {
5389 	int ret;
5390 	nvlist_t *nvl = NULL;
5391 	nvlist_t *outnvl = NULL;
5392 	nvlist_t *props;
5393 	nvlist_t *realprops;
5394 	prop_flags_t flags = { 0 };
5395 	uint64_t version;
5396 	uint64_t vdev_guid;
5397 
5398 	if ((ret = zpool_vdev_guid(zhp, vdevname, &vdev_guid)) != 0)
5399 		return (ret);
5400 
5401 	if (nvlist_alloc(&nvl, NV_UNIQUE_NAME, 0) != 0)
5402 		return (no_memory(zhp->zpool_hdl));
5403 	if (nvlist_alloc(&props, NV_UNIQUE_NAME, 0) != 0)
5404 		return (no_memory(zhp->zpool_hdl));
5405 
5406 	fnvlist_add_uint64(nvl, ZPOOL_VDEV_PROPS_SET_VDEV, vdev_guid);
5407 
5408 	if (nvlist_add_string(props, propname, propval) != 0) {
5409 		nvlist_free(props);
5410 		return (no_memory(zhp->zpool_hdl));
5411 	}
5412 
5413 	char errbuf[ERRBUFLEN];
5414 	(void) snprintf(errbuf, sizeof (errbuf),
5415 	    dgettext(TEXT_DOMAIN, "cannot set property %s for %s on %s"),
5416 	    propname, vdevname, zhp->zpool_name);
5417 
5418 	flags.vdevprop = 1;
5419 	version = zpool_get_prop_int(zhp, ZPOOL_PROP_VERSION, NULL);
5420 	if ((realprops = zpool_valid_proplist(zhp->zpool_hdl,
5421 	    zhp->zpool_name, props, version, flags, errbuf)) == NULL) {
5422 		nvlist_free(props);
5423 		nvlist_free(nvl);
5424 		return (-1);
5425 	}
5426 
5427 	nvlist_free(props);
5428 	props = realprops;
5429 
5430 	fnvlist_add_nvlist(nvl, ZPOOL_VDEV_PROPS_SET_PROPS, props);
5431 
5432 	ret = lzc_set_vdev_prop(zhp->zpool_name, nvl, &outnvl);
5433 
5434 	nvlist_free(props);
5435 	nvlist_free(nvl);
5436 	nvlist_free(outnvl);
5437 
5438 	if (ret)
5439 		(void) zpool_standard_error(zhp->zpool_hdl, errno, errbuf);
5440 
5441 	return (ret);
5442 }
5443