xref: /illumos-gate/usr/src/uts/common/fs/zfs/sys/vdev_removal.h (revision 0250c53ad267726f2438e3c6556199a0bbf588a2)
1 /*
2  * CDDL HEADER START
3  *
4  * This file and its contents are supplied under the terms of the
5  * Common Development and Distribution License ("CDDL"), version 1.0.
6  * You may only use this file in accordance with the terms of version
7  * 1.0 of the CDDL.
8  *
9  * A full copy of the text of the CDDL should have accompanied this
10  * source.  A copy of the CDDL is also available via the Internet at
11  * http://www.illumos.org/license/CDDL.
12  *
13  * CDDL HEADER END
14  */
15 
16 /*
17  * Copyright (c) 2014, 2017 by Delphix. All rights reserved.
18  */
19 
20 #ifndef _SYS_VDEV_REMOVAL_H
21 #define	_SYS_VDEV_REMOVAL_H
22 
23 #include <sys/spa.h>
24 #include <sys/bpobj.h>
25 #include <sys/vdev_indirect_mapping.h>
26 #include <sys/vdev_indirect_births.h>
27 
28 #ifdef	__cplusplus
29 extern "C" {
30 #endif
31 
32 typedef struct spa_vdev_removal {
33 	uint64_t	svr_vdev_id;
34 	uint64_t	svr_max_offset_to_sync[TXG_SIZE];
35 	/* Thread performing a vdev removal. */
36 	kthread_t	*svr_thread;
37 	/* Segments left to copy from the current metaslab. */
38 	range_tree_t	*svr_allocd_segs;
39 	kmutex_t	svr_lock;
40 	kcondvar_t	svr_cv;
41 	boolean_t	svr_thread_exit;
42 
43 	/*
44 	 * New mappings to write out each txg.
45 	 */
46 	list_t		svr_new_segments[TXG_SIZE];
47 
48 	/*
49 	 * Ranges that were freed while a mapping was in flight.  This is
50 	 * a subset of the ranges covered by vdev_im_new_segments.
51 	 */
52 	range_tree_t	*svr_frees[TXG_SIZE];
53 
54 	/*
55 	 * Number of bytes which we have finished our work for
56 	 * in each txg.  This could be data copied (which will be part of
57 	 * the mappings in vdev_im_new_segments), or data freed before
58 	 * we got around to copying it.
59 	 */
60 	uint64_t	svr_bytes_done[TXG_SIZE];
61 
62 	/* List of leaf zap objects to be unlinked */
63 	nvlist_t	*svr_zaplist;
64 } spa_vdev_removal_t;
65 
66 typedef struct spa_condensing_indirect {
67 	/*
68 	 * New mappings to write out each txg.
69 	 */
70 	list_t		sci_new_mapping_entries[TXG_SIZE];
71 
72 	vdev_indirect_mapping_t *sci_new_mapping;
73 } spa_condensing_indirect_t;
74 
75 extern int spa_remove_init(spa_t *);
76 extern void spa_restart_removal(spa_t *);
77 extern int spa_condense_init(spa_t *);
78 extern void spa_condense_fini(spa_t *);
79 extern void spa_start_indirect_condensing_thread(spa_t *);
80 extern void spa_vdev_condense_suspend(spa_t *);
81 extern int spa_vdev_remove(spa_t *, uint64_t, boolean_t);
82 extern void free_from_removing_vdev(vdev_t *, uint64_t, uint64_t);
83 extern int spa_removal_get_stats(spa_t *, pool_removal_stat_t *);
84 extern void svr_sync(spa_t *spa, dmu_tx_t *tx);
85 extern void spa_vdev_remove_suspend(spa_t *);
86 extern int spa_vdev_remove_cancel(spa_t *);
87 extern void spa_vdev_removal_destroy(spa_vdev_removal_t *svr);
88 
89 extern int vdev_removal_max_span;
90 extern int zfs_remove_max_segment;
91 
92 #ifdef	__cplusplus
93 }
94 #endif
95 
96 #endif	/* _SYS_VDEV_REMOVAL_H */
97