1 /* $NetBSD: vgmerge.c,v 1.1.1.2 2009/12/02 00:25:57 haad Exp $ */
2
3 /*
4 * Copyright (C) 2001-2004 Sistina Software, Inc. All rights reserved.
5 * Copyright (C) 2004-2009 Red Hat, Inc. All rights reserved.
6 *
7 * This file is part of LVM2.
8 *
9 * This copyrighted material is made available to anyone wishing to use,
10 * modify, copy, or redistribute it subject to the terms and conditions
11 * of the GNU Lesser General Public License v.2.1.
12 *
13 * You should have received a copy of the GNU Lesser General Public License
14 * along with this program; if not, write to the Free Software Foundation,
15 * Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
16 */
17
18 #include "tools.h"
19
_vgmerge_vg_read(struct cmd_context * cmd,const char * vg_name)20 static struct volume_group *_vgmerge_vg_read(struct cmd_context *cmd,
21 const char *vg_name)
22 {
23 struct volume_group *vg;
24 log_verbose("Checking for volume group \"%s\"", vg_name);
25 vg = vg_read_for_update(cmd, vg_name, NULL, 0);
26 if (vg_read_error(vg)) {
27 vg_release(vg);
28 return NULL;
29 }
30 return vg;
31 }
32
_vgmerge_single(struct cmd_context * cmd,const char * vg_name_to,const char * vg_name_from)33 static int _vgmerge_single(struct cmd_context *cmd, const char *vg_name_to,
34 const char *vg_name_from)
35 {
36 struct volume_group *vg_to, *vg_from;
37 struct lv_list *lvl1, *lvl2;
38 int r = ECMD_FAILED;
39 int lock_vg_from_first = 0;
40
41 if (!strcmp(vg_name_to, vg_name_from)) {
42 log_error("Duplicate volume group name \"%s\"", vg_name_from);
43 return ECMD_FAILED;
44 }
45
46 if (strcmp(vg_name_to, vg_name_from) > 0)
47 lock_vg_from_first = 1;
48
49 if (lock_vg_from_first) {
50 vg_from = _vgmerge_vg_read(cmd, vg_name_from);
51 if (!vg_from) {
52 stack;
53 return ECMD_FAILED;
54 }
55 vg_to = _vgmerge_vg_read(cmd, vg_name_to);
56 if (!vg_to) {
57 stack;
58 unlock_and_release_vg(cmd, vg_from, vg_name_from);
59 return ECMD_FAILED;
60 }
61 } else {
62 vg_to = _vgmerge_vg_read(cmd, vg_name_to);
63 if (!vg_to) {
64 stack;
65 return ECMD_FAILED;
66 }
67
68 vg_from = _vgmerge_vg_read(cmd, vg_name_from);
69 if (!vg_from) {
70 stack;
71 unlock_and_release_vg(cmd, vg_to, vg_name_to);
72 return ECMD_FAILED;
73 }
74 }
75
76 if (!vgs_are_compatible(cmd, vg_from, vg_to))
77 goto_bad;
78
79 /* FIXME List arg: vg_show_with_pv_and_lv(vg_to); */
80
81 if (!archive(vg_from) || !archive(vg_to))
82 goto_bad;
83
84 drop_cached_metadata(vg_from);
85
86 /* Merge volume groups */
87 while (!dm_list_empty(&vg_from->pvs)) {
88 struct dm_list *pvh = vg_from->pvs.n;
89 struct physical_volume *pv;
90
91 dm_list_move(&vg_to->pvs, pvh);
92
93 pv = dm_list_item(pvh, struct pv_list)->pv;
94 pv->vg_name = dm_pool_strdup(cmd->mem, vg_to->name);
95 }
96 vg_to->pv_count += vg_from->pv_count;
97
98 /* Fix up LVIDs */
99 dm_list_iterate_items(lvl1, &vg_to->lvs) {
100 union lvid *lvid1 = &lvl1->lv->lvid;
101 char uuid[64] __attribute((aligned(8)));
102
103 dm_list_iterate_items(lvl2, &vg_from->lvs) {
104 union lvid *lvid2 = &lvl2->lv->lvid;
105
106 if (id_equal(&lvid1->id[1], &lvid2->id[1])) {
107 if (!id_create(&lvid2->id[1])) {
108 log_error("Failed to generate new "
109 "random LVID for %s",
110 lvl2->lv->name);
111 goto bad;
112 }
113 if (!id_write_format(&lvid2->id[1], uuid,
114 sizeof(uuid)))
115 goto_bad;
116
117 log_verbose("Changed LVID for %s to %s",
118 lvl2->lv->name, uuid);
119 }
120 }
121 }
122
123 while (!dm_list_empty(&vg_from->lvs)) {
124 struct dm_list *lvh = vg_from->lvs.n;
125
126 dm_list_move(&vg_to->lvs, lvh);
127 }
128
129 while (!dm_list_empty(&vg_from->fid->metadata_areas)) {
130 struct dm_list *mdah = vg_from->fid->metadata_areas.n;
131
132 dm_list_move(&vg_to->fid->metadata_areas, mdah);
133 }
134
135 vg_to->extent_count += vg_from->extent_count;
136 vg_to->free_count += vg_from->free_count;
137
138 /* store it on disks */
139 log_verbose("Writing out updated volume group");
140 if (!vg_write(vg_to) || !vg_commit(vg_to))
141 goto_bad;
142
143 /* FIXME Remove /dev/vgfrom */
144
145 backup(vg_to);
146 log_print("Volume group \"%s\" successfully merged into \"%s\"",
147 vg_from->name, vg_to->name);
148 r = ECMD_PROCESSED;
149 bad:
150 if (lock_vg_from_first) {
151 unlock_and_release_vg(cmd, vg_to, vg_name_to);
152 unlock_and_release_vg(cmd, vg_from, vg_name_from);
153 } else {
154 unlock_and_release_vg(cmd, vg_from, vg_name_from);
155 unlock_and_release_vg(cmd, vg_to, vg_name_to);
156 }
157 return r;
158 }
159
vgmerge(struct cmd_context * cmd,int argc,char ** argv)160 int vgmerge(struct cmd_context *cmd, int argc, char **argv)
161 {
162 char *vg_name_to, *vg_name_from;
163 int opt = 0;
164 int ret = 0, ret_max = 0;
165
166 if (argc < 2) {
167 log_error("Please enter 2 or more volume groups to merge");
168 return EINVALID_CMD_LINE;
169 }
170
171 vg_name_to = skip_dev_dir(cmd, argv[0], NULL);
172 argc--;
173 argv++;
174
175 for (; opt < argc; opt++) {
176 vg_name_from = skip_dev_dir(cmd, argv[opt], NULL);
177
178 ret = _vgmerge_single(cmd, vg_name_to, vg_name_from);
179 if (ret > ret_max)
180 ret_max = ret;
181 }
182
183 return ret_max;
184 }
185