1*86d7f5d3SJohn Marino /* $NetBSD: format_pool.c,v 1.1.1.2 2009/12/02 00:26:50 haad Exp $ */
2*86d7f5d3SJohn Marino
3*86d7f5d3SJohn Marino /*
4*86d7f5d3SJohn Marino * Copyright (C) 1997-2004 Sistina Software, Inc. All rights reserved.
5*86d7f5d3SJohn Marino * Copyright (C) 2004-2006 Red Hat, Inc. All rights reserved.
6*86d7f5d3SJohn Marino *
7*86d7f5d3SJohn Marino * This file is part of LVM2.
8*86d7f5d3SJohn Marino *
9*86d7f5d3SJohn Marino * This copyrighted material is made available to anyone wishing to use,
10*86d7f5d3SJohn Marino * modify, copy, or redistribute it subject to the terms and conditions
11*86d7f5d3SJohn Marino * of the GNU Lesser General Public License v.2.1.
12*86d7f5d3SJohn Marino *
13*86d7f5d3SJohn Marino * You should have received a copy of the GNU Lesser General Public License
14*86d7f5d3SJohn Marino * along with this program; if not, write to the Free Software Foundation,
15*86d7f5d3SJohn Marino * Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
16*86d7f5d3SJohn Marino */
17*86d7f5d3SJohn Marino
18*86d7f5d3SJohn Marino #include "lib.h"
19*86d7f5d3SJohn Marino #include "label.h"
20*86d7f5d3SJohn Marino #include "metadata.h"
21*86d7f5d3SJohn Marino #include "limits.h"
22*86d7f5d3SJohn Marino #include "display.h"
23*86d7f5d3SJohn Marino #include "toolcontext.h"
24*86d7f5d3SJohn Marino #include "lvmcache.h"
25*86d7f5d3SJohn Marino #include "disk_rep.h"
26*86d7f5d3SJohn Marino #include "format_pool.h"
27*86d7f5d3SJohn Marino #include "pool_label.h"
28*86d7f5d3SJohn Marino
29*86d7f5d3SJohn Marino /* Must be called after pvs are imported */
_build_usp(struct dm_list * pls,struct dm_pool * mem,int * sps)30*86d7f5d3SJohn Marino static struct user_subpool *_build_usp(struct dm_list *pls, struct dm_pool *mem,
31*86d7f5d3SJohn Marino int *sps)
32*86d7f5d3SJohn Marino {
33*86d7f5d3SJohn Marino struct pool_list *pl;
34*86d7f5d3SJohn Marino struct user_subpool *usp = NULL, *cur_sp = NULL;
35*86d7f5d3SJohn Marino struct user_device *cur_dev = NULL;
36*86d7f5d3SJohn Marino
37*86d7f5d3SJohn Marino /*
38*86d7f5d3SJohn Marino * FIXME: Need to do some checks here - I'm tempted to add a
39*86d7f5d3SJohn Marino * user_pool structure and build the entire thing to check against.
40*86d7f5d3SJohn Marino */
41*86d7f5d3SJohn Marino dm_list_iterate_items(pl, pls) {
42*86d7f5d3SJohn Marino *sps = pl->pd.pl_subpools;
43*86d7f5d3SJohn Marino if (!usp && (!(usp = dm_pool_zalloc(mem, sizeof(*usp) * (*sps))))) {
44*86d7f5d3SJohn Marino log_error("Unable to allocate %d subpool structures",
45*86d7f5d3SJohn Marino *sps);
46*86d7f5d3SJohn Marino return 0;
47*86d7f5d3SJohn Marino }
48*86d7f5d3SJohn Marino
49*86d7f5d3SJohn Marino if (cur_sp != &usp[pl->pd.pl_sp_id]) {
50*86d7f5d3SJohn Marino cur_sp = &usp[pl->pd.pl_sp_id];
51*86d7f5d3SJohn Marino
52*86d7f5d3SJohn Marino cur_sp->id = pl->pd.pl_sp_id;
53*86d7f5d3SJohn Marino cur_sp->striping = pl->pd.pl_striping;
54*86d7f5d3SJohn Marino cur_sp->num_devs = pl->pd.pl_sp_devs;
55*86d7f5d3SJohn Marino cur_sp->type = pl->pd.pl_sp_type;
56*86d7f5d3SJohn Marino cur_sp->initialized = 1;
57*86d7f5d3SJohn Marino }
58*86d7f5d3SJohn Marino
59*86d7f5d3SJohn Marino if (!cur_sp->devs &&
60*86d7f5d3SJohn Marino (!(cur_sp->devs =
61*86d7f5d3SJohn Marino dm_pool_zalloc(mem,
62*86d7f5d3SJohn Marino sizeof(*usp->devs) * pl->pd.pl_sp_devs)))) {
63*86d7f5d3SJohn Marino
64*86d7f5d3SJohn Marino log_error("Unable to allocate %d pool_device "
65*86d7f5d3SJohn Marino "structures", pl->pd.pl_sp_devs);
66*86d7f5d3SJohn Marino return 0;
67*86d7f5d3SJohn Marino }
68*86d7f5d3SJohn Marino
69*86d7f5d3SJohn Marino cur_dev = &cur_sp->devs[pl->pd.pl_sp_devid];
70*86d7f5d3SJohn Marino cur_dev->sp_id = cur_sp->id;
71*86d7f5d3SJohn Marino cur_dev->devid = pl->pd.pl_sp_id;
72*86d7f5d3SJohn Marino cur_dev->blocks = pl->pd.pl_blocks;
73*86d7f5d3SJohn Marino cur_dev->pv = pl->pv;
74*86d7f5d3SJohn Marino cur_dev->initialized = 1;
75*86d7f5d3SJohn Marino }
76*86d7f5d3SJohn Marino
77*86d7f5d3SJohn Marino return usp;
78*86d7f5d3SJohn Marino }
79*86d7f5d3SJohn Marino
_check_usp(char * vgname,struct user_subpool * usp,int sp_count)80*86d7f5d3SJohn Marino static int _check_usp(char *vgname, struct user_subpool *usp, int sp_count)
81*86d7f5d3SJohn Marino {
82*86d7f5d3SJohn Marino int i;
83*86d7f5d3SJohn Marino unsigned j;
84*86d7f5d3SJohn Marino
85*86d7f5d3SJohn Marino for (i = 0; i < sp_count; i++) {
86*86d7f5d3SJohn Marino if (!usp[i].initialized) {
87*86d7f5d3SJohn Marino log_error("Missing subpool %d in pool %s", i, vgname);
88*86d7f5d3SJohn Marino return 0;
89*86d7f5d3SJohn Marino }
90*86d7f5d3SJohn Marino for (j = 0; j < usp[i].num_devs; j++) {
91*86d7f5d3SJohn Marino if (!usp[i].devs[j].initialized) {
92*86d7f5d3SJohn Marino log_error("Missing device %u for subpool %d"
93*86d7f5d3SJohn Marino " in pool %s", j, i, vgname);
94*86d7f5d3SJohn Marino return 0;
95*86d7f5d3SJohn Marino }
96*86d7f5d3SJohn Marino
97*86d7f5d3SJohn Marino }
98*86d7f5d3SJohn Marino }
99*86d7f5d3SJohn Marino
100*86d7f5d3SJohn Marino return 1;
101*86d7f5d3SJohn Marino }
102*86d7f5d3SJohn Marino
_build_vg_from_pds(struct format_instance * fid,struct dm_pool * mem,struct dm_list * pds)103*86d7f5d3SJohn Marino static struct volume_group *_build_vg_from_pds(struct format_instance
104*86d7f5d3SJohn Marino *fid, struct dm_pool *mem,
105*86d7f5d3SJohn Marino struct dm_list *pds)
106*86d7f5d3SJohn Marino {
107*86d7f5d3SJohn Marino struct dm_pool *smem = fid->fmt->cmd->mem;
108*86d7f5d3SJohn Marino struct volume_group *vg = NULL;
109*86d7f5d3SJohn Marino struct user_subpool *usp = NULL;
110*86d7f5d3SJohn Marino int sp_count;
111*86d7f5d3SJohn Marino
112*86d7f5d3SJohn Marino if (!(vg = dm_pool_zalloc(smem, sizeof(*vg)))) {
113*86d7f5d3SJohn Marino log_error("Unable to allocate volume group structure");
114*86d7f5d3SJohn Marino return NULL;
115*86d7f5d3SJohn Marino }
116*86d7f5d3SJohn Marino
117*86d7f5d3SJohn Marino vg->cmd = fid->fmt->cmd;
118*86d7f5d3SJohn Marino vg->vgmem = mem;
119*86d7f5d3SJohn Marino vg->fid = fid;
120*86d7f5d3SJohn Marino vg->name = NULL;
121*86d7f5d3SJohn Marino vg->status = 0;
122*86d7f5d3SJohn Marino vg->extent_count = 0;
123*86d7f5d3SJohn Marino vg->pv_count = 0;
124*86d7f5d3SJohn Marino vg->seqno = 1;
125*86d7f5d3SJohn Marino vg->system_id = NULL;
126*86d7f5d3SJohn Marino dm_list_init(&vg->pvs);
127*86d7f5d3SJohn Marino dm_list_init(&vg->lvs);
128*86d7f5d3SJohn Marino dm_list_init(&vg->tags);
129*86d7f5d3SJohn Marino dm_list_init(&vg->removed_pvs);
130*86d7f5d3SJohn Marino
131*86d7f5d3SJohn Marino if (!import_pool_vg(vg, smem, pds))
132*86d7f5d3SJohn Marino return_NULL;
133*86d7f5d3SJohn Marino
134*86d7f5d3SJohn Marino if (!import_pool_pvs(fid->fmt, vg, &vg->pvs, smem, pds))
135*86d7f5d3SJohn Marino return_NULL;
136*86d7f5d3SJohn Marino
137*86d7f5d3SJohn Marino if (!import_pool_lvs(vg, smem, pds))
138*86d7f5d3SJohn Marino return_NULL;
139*86d7f5d3SJohn Marino
140*86d7f5d3SJohn Marino /*
141*86d7f5d3SJohn Marino * I need an intermediate subpool structure that contains all the
142*86d7f5d3SJohn Marino * relevant info for this. Then i can iterate through the subpool
143*86d7f5d3SJohn Marino * structures for checking, and create the segments
144*86d7f5d3SJohn Marino */
145*86d7f5d3SJohn Marino if (!(usp = _build_usp(pds, mem, &sp_count)))
146*86d7f5d3SJohn Marino return_NULL;
147*86d7f5d3SJohn Marino
148*86d7f5d3SJohn Marino /*
149*86d7f5d3SJohn Marino * check the subpool structures - we can't handle partial VGs in
150*86d7f5d3SJohn Marino * the pool format, so this will error out if we're missing PVs
151*86d7f5d3SJohn Marino */
152*86d7f5d3SJohn Marino if (!_check_usp(vg->name, usp, sp_count))
153*86d7f5d3SJohn Marino return_NULL;
154*86d7f5d3SJohn Marino
155*86d7f5d3SJohn Marino if (!import_pool_segments(&vg->lvs, smem, usp, sp_count))
156*86d7f5d3SJohn Marino return_NULL;
157*86d7f5d3SJohn Marino
158*86d7f5d3SJohn Marino return vg;
159*86d7f5d3SJohn Marino }
160*86d7f5d3SJohn Marino
_pool_vg_read(struct format_instance * fid,const char * vg_name,struct metadata_area * mda __attribute ((unused)))161*86d7f5d3SJohn Marino static struct volume_group *_pool_vg_read(struct format_instance *fid,
162*86d7f5d3SJohn Marino const char *vg_name,
163*86d7f5d3SJohn Marino struct metadata_area *mda __attribute((unused)))
164*86d7f5d3SJohn Marino {
165*86d7f5d3SJohn Marino struct dm_pool *mem = dm_pool_create("pool vg_read", VG_MEMPOOL_CHUNK);
166*86d7f5d3SJohn Marino struct dm_list pds;
167*86d7f5d3SJohn Marino struct volume_group *vg = NULL;
168*86d7f5d3SJohn Marino
169*86d7f5d3SJohn Marino dm_list_init(&pds);
170*86d7f5d3SJohn Marino
171*86d7f5d3SJohn Marino /* We can safely ignore the mda passed in */
172*86d7f5d3SJohn Marino
173*86d7f5d3SJohn Marino if (!mem)
174*86d7f5d3SJohn Marino return_NULL;
175*86d7f5d3SJohn Marino
176*86d7f5d3SJohn Marino /* Strip dev_dir if present */
177*86d7f5d3SJohn Marino vg_name = strip_dir(vg_name, fid->fmt->cmd->dev_dir);
178*86d7f5d3SJohn Marino
179*86d7f5d3SJohn Marino /* Read all the pvs in the vg */
180*86d7f5d3SJohn Marino if (!read_pool_pds(fid->fmt, vg_name, mem, &pds))
181*86d7f5d3SJohn Marino goto_out;
182*86d7f5d3SJohn Marino
183*86d7f5d3SJohn Marino /* Do the rest of the vg stuff */
184*86d7f5d3SJohn Marino if (!(vg = _build_vg_from_pds(fid, mem, &pds)))
185*86d7f5d3SJohn Marino goto_out;
186*86d7f5d3SJohn Marino
187*86d7f5d3SJohn Marino return vg;
188*86d7f5d3SJohn Marino out:
189*86d7f5d3SJohn Marino dm_pool_destroy(mem);
190*86d7f5d3SJohn Marino return NULL;
191*86d7f5d3SJohn Marino }
192*86d7f5d3SJohn Marino
_pool_pv_setup(const struct format_type * fmt __attribute ((unused)),uint64_t pe_start __attribute ((unused)),uint32_t extent_count __attribute ((unused)),uint32_t extent_size __attribute ((unused)),unsigned long data_alignment __attribute ((unused)),unsigned long data_alignment_offset __attribute ((unused)),int pvmetadatacopies __attribute ((unused)),uint64_t pvmetadatasize __attribute ((unused)),struct dm_list * mdas __attribute ((unused)),struct physical_volume * pv __attribute ((unused)),struct volume_group * vg __attribute ((unused)))193*86d7f5d3SJohn Marino static int _pool_pv_setup(const struct format_type *fmt __attribute((unused)),
194*86d7f5d3SJohn Marino uint64_t pe_start __attribute((unused)),
195*86d7f5d3SJohn Marino uint32_t extent_count __attribute((unused)),
196*86d7f5d3SJohn Marino uint32_t extent_size __attribute((unused)),
197*86d7f5d3SJohn Marino unsigned long data_alignment __attribute((unused)),
198*86d7f5d3SJohn Marino unsigned long data_alignment_offset __attribute((unused)),
199*86d7f5d3SJohn Marino int pvmetadatacopies __attribute((unused)),
200*86d7f5d3SJohn Marino uint64_t pvmetadatasize __attribute((unused)),
201*86d7f5d3SJohn Marino struct dm_list *mdas __attribute((unused)),
202*86d7f5d3SJohn Marino struct physical_volume *pv __attribute((unused)),
203*86d7f5d3SJohn Marino struct volume_group *vg __attribute((unused)))
204*86d7f5d3SJohn Marino {
205*86d7f5d3SJohn Marino return 1;
206*86d7f5d3SJohn Marino }
207*86d7f5d3SJohn Marino
_pool_pv_read(const struct format_type * fmt,const char * pv_name,struct physical_volume * pv,struct dm_list * mdas __attribute ((unused)),int scan_label_only __attribute ((unused)))208*86d7f5d3SJohn Marino static int _pool_pv_read(const struct format_type *fmt, const char *pv_name,
209*86d7f5d3SJohn Marino struct physical_volume *pv,
210*86d7f5d3SJohn Marino struct dm_list *mdas __attribute((unused)),
211*86d7f5d3SJohn Marino int scan_label_only __attribute((unused)))
212*86d7f5d3SJohn Marino {
213*86d7f5d3SJohn Marino struct dm_pool *mem = dm_pool_create("pool pv_read", 1024);
214*86d7f5d3SJohn Marino struct pool_list *pl;
215*86d7f5d3SJohn Marino struct device *dev;
216*86d7f5d3SJohn Marino int r = 0;
217*86d7f5d3SJohn Marino
218*86d7f5d3SJohn Marino log_very_verbose("Reading physical volume data %s from disk", pv_name);
219*86d7f5d3SJohn Marino
220*86d7f5d3SJohn Marino if (!mem)
221*86d7f5d3SJohn Marino return_0;
222*86d7f5d3SJohn Marino
223*86d7f5d3SJohn Marino if (!(dev = dev_cache_get(pv_name, fmt->cmd->filter)))
224*86d7f5d3SJohn Marino goto_out;
225*86d7f5d3SJohn Marino
226*86d7f5d3SJohn Marino /*
227*86d7f5d3SJohn Marino * I need to read the disk and populate a pv structure here
228*86d7f5d3SJohn Marino * I'll probably need to abstract some of this later for the
229*86d7f5d3SJohn Marino * vg_read code
230*86d7f5d3SJohn Marino */
231*86d7f5d3SJohn Marino if (!(pl = read_pool_disk(fmt, dev, mem, NULL)))
232*86d7f5d3SJohn Marino goto_out;
233*86d7f5d3SJohn Marino
234*86d7f5d3SJohn Marino if (!import_pool_pv(fmt, fmt->cmd->mem, NULL, pv, pl))
235*86d7f5d3SJohn Marino goto_out;
236*86d7f5d3SJohn Marino
237*86d7f5d3SJohn Marino pv->fmt = fmt;
238*86d7f5d3SJohn Marino
239*86d7f5d3SJohn Marino r = 1;
240*86d7f5d3SJohn Marino
241*86d7f5d3SJohn Marino out:
242*86d7f5d3SJohn Marino dm_pool_destroy(mem);
243*86d7f5d3SJohn Marino return r;
244*86d7f5d3SJohn Marino }
245*86d7f5d3SJohn Marino
246*86d7f5d3SJohn Marino /* *INDENT-OFF* */
247*86d7f5d3SJohn Marino static struct metadata_area_ops _metadata_format_pool_ops = {
248*86d7f5d3SJohn Marino .vg_read = _pool_vg_read,
249*86d7f5d3SJohn Marino };
250*86d7f5d3SJohn Marino /* *INDENT-ON* */
251*86d7f5d3SJohn Marino
_pool_create_instance(const struct format_type * fmt,const char * vgname __attribute ((unused)),const char * vgid __attribute ((unused)),void * private __attribute ((unused)))252*86d7f5d3SJohn Marino static struct format_instance *_pool_create_instance(const struct format_type *fmt,
253*86d7f5d3SJohn Marino const char *vgname __attribute((unused)),
254*86d7f5d3SJohn Marino const char *vgid __attribute((unused)),
255*86d7f5d3SJohn Marino void *private __attribute((unused)))
256*86d7f5d3SJohn Marino {
257*86d7f5d3SJohn Marino struct format_instance *fid;
258*86d7f5d3SJohn Marino struct metadata_area *mda;
259*86d7f5d3SJohn Marino
260*86d7f5d3SJohn Marino if (!(fid = dm_pool_zalloc(fmt->cmd->mem, sizeof(*fid)))) {
261*86d7f5d3SJohn Marino log_error("Unable to allocate format instance structure for "
262*86d7f5d3SJohn Marino "pool format");
263*86d7f5d3SJohn Marino return NULL;
264*86d7f5d3SJohn Marino }
265*86d7f5d3SJohn Marino
266*86d7f5d3SJohn Marino fid->fmt = fmt;
267*86d7f5d3SJohn Marino dm_list_init(&fid->metadata_areas);
268*86d7f5d3SJohn Marino
269*86d7f5d3SJohn Marino /* Define a NULL metadata area */
270*86d7f5d3SJohn Marino if (!(mda = dm_pool_zalloc(fmt->cmd->mem, sizeof(*mda)))) {
271*86d7f5d3SJohn Marino log_error("Unable to allocate metadata area structure "
272*86d7f5d3SJohn Marino "for pool format");
273*86d7f5d3SJohn Marino dm_pool_free(fmt->cmd->mem, fid);
274*86d7f5d3SJohn Marino return NULL;
275*86d7f5d3SJohn Marino }
276*86d7f5d3SJohn Marino
277*86d7f5d3SJohn Marino mda->ops = &_metadata_format_pool_ops;
278*86d7f5d3SJohn Marino mda->metadata_locn = NULL;
279*86d7f5d3SJohn Marino dm_list_add(&fid->metadata_areas, &mda->list);
280*86d7f5d3SJohn Marino
281*86d7f5d3SJohn Marino return fid;
282*86d7f5d3SJohn Marino }
283*86d7f5d3SJohn Marino
_pool_destroy_instance(struct format_instance * fid __attribute ((unused)))284*86d7f5d3SJohn Marino static void _pool_destroy_instance(struct format_instance *fid __attribute((unused)))
285*86d7f5d3SJohn Marino {
286*86d7f5d3SJohn Marino return;
287*86d7f5d3SJohn Marino }
288*86d7f5d3SJohn Marino
_pool_destroy(const struct format_type * fmt)289*86d7f5d3SJohn Marino static void _pool_destroy(const struct format_type *fmt)
290*86d7f5d3SJohn Marino {
291*86d7f5d3SJohn Marino dm_free((void *) fmt);
292*86d7f5d3SJohn Marino }
293*86d7f5d3SJohn Marino
294*86d7f5d3SJohn Marino /* *INDENT-OFF* */
295*86d7f5d3SJohn Marino static struct format_handler _format_pool_ops = {
296*86d7f5d3SJohn Marino .pv_read = _pool_pv_read,
297*86d7f5d3SJohn Marino .pv_setup = _pool_pv_setup,
298*86d7f5d3SJohn Marino .create_instance = _pool_create_instance,
299*86d7f5d3SJohn Marino .destroy_instance = _pool_destroy_instance,
300*86d7f5d3SJohn Marino .destroy = _pool_destroy,
301*86d7f5d3SJohn Marino };
302*86d7f5d3SJohn Marino /* *INDENT-ON */
303*86d7f5d3SJohn Marino
304*86d7f5d3SJohn Marino #ifdef POOL_INTERNAL
init_pool_format(struct cmd_context * cmd)305*86d7f5d3SJohn Marino struct format_type *init_pool_format(struct cmd_context *cmd)
306*86d7f5d3SJohn Marino #else /* Shared */
307*86d7f5d3SJohn Marino struct format_type *init_format(struct cmd_context *cmd);
308*86d7f5d3SJohn Marino struct format_type *init_format(struct cmd_context *cmd)
309*86d7f5d3SJohn Marino #endif
310*86d7f5d3SJohn Marino {
311*86d7f5d3SJohn Marino struct format_type *fmt = dm_malloc(sizeof(*fmt));
312*86d7f5d3SJohn Marino
313*86d7f5d3SJohn Marino if (!fmt) {
314*86d7f5d3SJohn Marino log_error("Unable to allocate format type structure for pool "
315*86d7f5d3SJohn Marino "format");
316*86d7f5d3SJohn Marino return NULL;
317*86d7f5d3SJohn Marino }
318*86d7f5d3SJohn Marino
319*86d7f5d3SJohn Marino fmt->cmd = cmd;
320*86d7f5d3SJohn Marino fmt->ops = &_format_pool_ops;
321*86d7f5d3SJohn Marino fmt->name = FMT_POOL_NAME;
322*86d7f5d3SJohn Marino fmt->alias = NULL;
323*86d7f5d3SJohn Marino fmt->orphan_vg_name = FMT_POOL_ORPHAN_VG_NAME;
324*86d7f5d3SJohn Marino fmt->features = 0;
325*86d7f5d3SJohn Marino fmt->private = NULL;
326*86d7f5d3SJohn Marino
327*86d7f5d3SJohn Marino if (!(fmt->labeller = pool_labeller_create(fmt))) {
328*86d7f5d3SJohn Marino log_error("Couldn't create pool label handler.");
329*86d7f5d3SJohn Marino return NULL;
330*86d7f5d3SJohn Marino }
331*86d7f5d3SJohn Marino
332*86d7f5d3SJohn Marino if (!(label_register_handler(FMT_POOL_NAME, fmt->labeller))) {
333*86d7f5d3SJohn Marino log_error("Couldn't register pool label handler.");
334*86d7f5d3SJohn Marino return NULL;
335*86d7f5d3SJohn Marino }
336*86d7f5d3SJohn Marino
337*86d7f5d3SJohn Marino log_very_verbose("Initialised format: %s", fmt->name);
338*86d7f5d3SJohn Marino
339*86d7f5d3SJohn Marino return fmt;
340*86d7f5d3SJohn Marino }
341