From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: (qmail 20639 invoked by alias); 7 Oct 2006 23:40:37 -0000 Received: (qmail 20623 invoked by uid 9447); 7 Oct 2006 23:40:36 -0000 Date: Sat, 07 Oct 2006 23:40:00 -0000 Message-ID: <20061007234036.20621.qmail@sourceware.org> From: agk@sourceware.org To: lvm2-cvs@sourceware.org Subject: LVM2 ./WHATS_NEW lib/metadata/lv_manip.c Mailing-List: contact lvm2-cvs-help@sourceware.org; run by ezmlm Precedence: bulk List-Subscribe: List-Post: List-Help: , Sender: lvm2-cvs-owner@sourceware.org X-SW-Source: 2006-10/txt/msg00025.txt.bz2 List-Id: CVSROOT: /cvs/lvm2 Module name: LVM2 Changes by: agk@sourceware.org 2006-10-07 23:40:36 Modified files: . : WHATS_NEW lib/metadata : lv_manip.c Log message: check_contiguous to use for_each_pv Patches: http://sourceware.org/cgi-bin/cvsweb.cgi/LVM2/WHATS_NEW.diff?cvsroot=lvm2&r1=1.460&r2=1.461 http://sourceware.org/cgi-bin/cvsweb.cgi/LVM2/lib/metadata/lv_manip.c.diff?cvsroot=lvm2&r1=1.108&r2=1.109 --- LVM2/WHATS_NEW 2006/10/07 12:41:06 1.460 +++ LVM2/WHATS_NEW 2006/10/07 23:40:36 1.461 @@ -7,6 +7,7 @@ Add report columns with underscore before field names ending 'size'. Correct regionsize default on lvcreate man page (MB). Fix clvmd bug that could cause it to die when a node with a long name crashed. + Add device size to text metadata. Fix format_text mda_setup pv->size and pv_setup pe_count calculations. Fix _for_each_pv() for mirror with core log. Add lvm_dump.sh script to create a tarball of debugging info from a system. --- LVM2/lib/metadata/lv_manip.c 2006/10/07 16:00:28 1.108 +++ LVM2/lib/metadata/lv_manip.c 2006/10/07 23:40:36 1.109 @@ -398,6 +398,7 @@ * Details of an allocation attempt */ struct alloc_handle { + struct cmd_context *cmd; struct dm_pool *mem; alloc_policy_t alloc; /* Overall policy */ @@ -417,7 +418,8 @@ /* * Preparation for a specific allocation attempt */ -static struct alloc_handle *_alloc_init(struct dm_pool *mem, +static struct alloc_handle *_alloc_init(struct cmd_context *cmd, + struct dm_pool *mem, const struct segment_type *segtype, alloc_policy_t alloc, uint32_t mirrors, @@ -464,6 +466,8 @@ if (segtype_is_virtual(segtype)) return ah; + ah->cmd = cmd; + if (!(ah->mem = dm_pool_create("allocation", 1024))) { log_error("allocation pool creation failed"); return NULL; @@ -675,7 +679,12 @@ */ static int _for_each_pv(struct cmd_context *cmd, struct logical_volume *lv, uint32_t le, uint32_t len, uint32_t *max_seg_len, - int (*fn)(struct cmd_context *cmd, struct pv_segment *peg, void *data), + uint32_t first_area, uint32_t max_areas, + int top_level_area_index, + int only_single_area_segments, + int (*fn)(struct cmd_context *cmd, + struct pv_segment *peg, uint32_t s, + void *data), void *data) { struct lv_segment *seg; @@ -701,24 +710,32 @@ area_multiple = segtype_is_striped(seg->segtype) ? seg->area_count : 1; area_len = remaining_seg_len / area_multiple ? : 1; - for (s = 0; s < seg->area_count; s++) { + for (s = first_area; + s < seg->area_count && (!max_areas || s <= max_areas); + s++) { if (seg_type(seg, s) == AREA_LV) { if (!(r = _for_each_pv(cmd, seg_lv(seg, s), seg_le(seg, s) + (le - seg->le) / area_multiple, - area_len, max_seg_len, fn, + area_len, max_seg_len, + only_single_area_segments ? 0 : 0, + only_single_area_segments ? 1 : 0, + top_level_area_index != -1 ? top_level_area_index : s, + only_single_area_segments, fn, data))) stack; } else if (seg_type(seg, s) == AREA_PV) - if (!(r = fn(cmd, seg_pvseg(seg, s), data))) + if (!(r = fn(cmd, seg_pvseg(seg, s), top_level_area_index != -1 ? top_level_area_index : s, data))) stack; if (r != 1) return r; } - if (seg_is_mirrored(seg) && seg->log_lv) { + /* FIXME only_single_area_segments used as workaround to skip log LV - needs new param? */ + if (!only_single_area_segments && seg_is_mirrored(seg) && seg->log_lv) { if (!(r = _for_each_pv(cmd, seg->log_lv, 0, MIRROR_LOG_SIZE, - NULL, fn, data))) + NULL, 0, 0, 0, only_single_area_segments, + fn, data))) stack; if (r != 1) return r; @@ -744,6 +761,18 @@ } /* + * Search for pvseg that matches condition + */ +struct pv_match { + int (*condition)(struct pv_segment *pvseg, struct pv_area *pva); + + struct pv_area **areas; + struct pv_area *pva; + uint32_t areas_size; + int s; /* Area index of match */ +}; + +/* * Is PV area contiguous to PV segment? */ static int _is_contiguous(struct pv_segment *pvseg, struct pv_area *pva) @@ -757,50 +786,49 @@ return 1; } -static int _check_pv_contiguous(struct logical_volume *prev_lv, uint32_t prev_le, struct pv_area *pva, - struct pv_area **areas, uint32_t areas_size) +static int _is_contiguous_condition(struct cmd_context *cmd, + struct pv_segment *pvseg, uint32_t s, + void *data) { - struct lv_segment *seg; - uint32_t s; - int r; + struct pv_match *pvmatch = data; - if (!(seg = find_seg_by_le(prev_lv, prev_le))) { - log_error("Failed to find segment for %s extent %" PRIu32, - prev_lv->name, prev_le); - return 0; - } + if (!pvmatch->condition(pvseg, pvmatch->pva)) + return 1; /* Continue */ - for (s = 0; s < seg->area_count && s < areas_size; s++) { - if (seg_type(seg, s) == AREA_LV) { - /* FIXME For more areas supply flattened seg to ensure consistency */ - if (seg->area_count == 1) { - if (!(r = _check_pv_contiguous(seg->lv, seg->le + seg->len - 1, pva, &areas[s], 1))) - stack; - if (r != 1) - return r; - } - } else if (seg_type(seg, s) == AREA_PV) - if (_is_contiguous(seg_pvseg(seg, s), pva)) { - areas[s] = pva; - return 2; /* Finished */ - } - } + if (s >= pvmatch->areas_size) + return 1; + + pvmatch->areas[s] = pvmatch->pva; - return 1; /* Continue search */ + return 2; /* Finished */ } /* * Is pva contiguous to any existing areas or on the same PV? */ -static int _check_contiguous(struct lv_segment *prev_lvseg, struct pv_area *pva, +static int _check_contiguous(struct cmd_context *cmd, + struct lv_segment *prev_lvseg, struct pv_area *pva, struct pv_area **areas, uint32_t areas_size) { + struct pv_match pvmatch; int r; - if (!(r = _check_pv_contiguous(prev_lvseg->lv, prev_lvseg->le + prev_lvseg->len - 1, pva, areas, areas_size))) + pvmatch.condition = _is_contiguous; + pvmatch.areas = areas; + pvmatch.areas_size = areas_size; + pvmatch.pva = pva; + + /* FIXME Cope with stacks by flattening */ + if (!(r = _for_each_pv(cmd, prev_lvseg->lv, + prev_lvseg->le + prev_lvseg->len - 1, 1, NULL, + 0, 0, -1, 1, + _is_contiguous_condition, &pvmatch))) stack; - return r ? 1 : 0; + if (r != 2) + return 0; + + return 1; } /* @@ -888,7 +916,8 @@ list_iterate_items(pva, &pvm->areas) { if (contiguous) { if (prev_lvseg && - _check_contiguous(prev_lvseg, + _check_contiguous(ah->cmd, + prev_lvseg, pva, areas, areas_size)) { contiguous_count++; @@ -1124,7 +1153,7 @@ if (alloc == ALLOC_INHERIT) alloc = vg->alloc; - if (!(ah = _alloc_init(vg->cmd->mem, segtype, alloc, mirrors, + if (!(ah = _alloc_init(vg->cmd, vg->cmd->mem, segtype, alloc, mirrors, stripes, log_count, mirrored_pv, mirrored_pe, parallel_areas))) { stack; @@ -1468,7 +1497,8 @@ return lv; } -static int _add_pvs(struct cmd_context *cmd, struct pv_segment *peg, void *data) +static int _add_pvs(struct cmd_context *cmd, struct pv_segment *peg, + uint32_t s __attribute((unused)), void *data) { struct seg_pvs *spvs = (struct seg_pvs *) data; struct pv_list *pvl; @@ -1522,7 +1552,8 @@ /* Find next segment end */ /* FIXME Unnecessary nesting! */ - if (!_for_each_pv(cmd, lv, current_le, spvs->len, &spvs->len, _add_pvs, (void *) spvs)) { + if (!_for_each_pv(cmd, lv, current_le, spvs->len, &spvs->len, + 0, 0, -1, 0, _add_pvs, (void *) spvs)) { stack; return NULL; }