diff --git a/WHATS_NEW b/WHATS_NEW index e6af77db6..d93b21c11 100644 --- a/WHATS_NEW +++ b/WHATS_NEW @@ -1,5 +1,10 @@ Version 2.02.17 - =================================== + When lvconvert allocates a mirror log, respect parallel area constraints. + Use loop to iterate through the now-ordered policy list in _allocate(). + Check for failure to allocate just the mirror log. + Introduce calc_area_multiple(). + Support mirror log allocation when there is only one PV: area_count now 0. Fix detection of smallest area in _alloc_parallel_area() for cling policy. Add manpage entry for clvmd -T Fix gulm operation of clvmd, including a hang when doing lvchange -aey diff --git a/lib/metadata/lv_manip.c b/lib/metadata/lv_manip.c index bcea7a5d7..e1612ad71 100644 --- a/lib/metadata/lv_manip.c +++ b/lib/metadata/lv_manip.c @@ -415,6 +415,15 @@ struct alloc_handle { struct list alloced_areas[0]; /* Lists of areas in each stripe */ }; +static uint32_t calc_area_multiple(const struct segment_type *segtype, + const uint32_t area_count) +{ + if (!segtype_is_striped(segtype) || !area_count) + return 1; + + return area_count; +} + /* * Preparation for a specific allocation attempt */ @@ -476,7 +485,7 @@ static struct alloc_handle *_alloc_init(struct cmd_context *cmd, ah->area_count = area_count; ah->log_count = log_count; ah->alloc = alloc; - ah->area_multiple = segtype_is_striped(segtype) ? ah->area_count : 1; + ah->area_multiple = calc_area_multiple(segtype, area_count); for (s = 0; s < ah->area_count; s++) list_init(&ah->alloced_areas[s]); @@ -553,7 +562,7 @@ static int _setup_alloced_segment(struct logical_volume *lv, uint32_t status, if (mirrored_pv) extra_areas = 1; - area_multiple = segtype_is_striped(segtype) ? area_count : 1; + area_multiple = calc_area_multiple(segtype, area_count); /* log_lv gets set up elsehere */ if (!(seg = alloc_lv_segment(lv->vg->cmd->mem, segtype, lv, @@ -707,7 +716,7 @@ static int _for_each_pv(struct cmd_context *cmd, struct logical_volume *lv, if (max_seg_len && *max_seg_len > remaining_seg_len) *max_seg_len = remaining_seg_len; - area_multiple = segtype_is_striped(seg->segtype) ? seg->area_count : 1; + area_multiple = calc_area_multiple(seg->segtype, seg->area_count); area_len = remaining_seg_len / area_multiple ? : 1; for (s = first_area; @@ -1066,6 +1075,7 @@ static int _allocate(struct alloc_handle *ah, int r = 0; struct list *pvms; uint32_t areas_size; + alloc_policy_t alloc; if (allocated >= new_extents && !ah->log_count) { log_error("_allocate called with no work to do!"); @@ -1111,50 +1121,18 @@ static int _allocate(struct alloc_handle *ah, return 0; } - old_allocated = allocated; - if (!_find_parallel_space(ah, ALLOC_CONTIGUOUS, pvms, areas, - areas_size, can_split, - prev_lvseg, &allocated, new_extents)) { - stack; - goto out; + /* Attempt each defined allocation policy in turn */ + for (alloc = ALLOC_CONTIGUOUS; alloc < ALLOC_INHERIT; alloc++) { + old_allocated = allocated; + if (!_find_parallel_space(ah, alloc, pvms, areas, + areas_size, can_split, + prev_lvseg, &allocated, new_extents)) + goto_out; + if ((allocated == new_extents) || (ah->alloc == alloc) || + (!can_split && (allocated != old_allocated))) + break; } - if ((allocated == new_extents) || (ah->alloc == ALLOC_CONTIGUOUS) || - (!can_split && (allocated != old_allocated))) - goto finished; - - old_allocated = allocated; - if (!_find_parallel_space(ah, ALLOC_CLING, pvms, areas, - areas_size, can_split, - prev_lvseg, &allocated, new_extents)) { - stack; - goto out; - } - - if ((allocated == new_extents) || (ah->alloc == ALLOC_CLING) || - (!can_split && (allocated != old_allocated))) - goto finished; - - old_allocated = allocated; - if (!_find_parallel_space(ah, ALLOC_NORMAL, pvms, areas, - areas_size, can_split, - prev_lvseg, &allocated, new_extents)) { - stack; - goto out; - } - - if ((allocated == new_extents) || (ah->alloc == ALLOC_NORMAL) || - (!can_split && (allocated != old_allocated))) - goto finished; - - if (!_find_parallel_space(ah, ALLOC_ANYWHERE, pvms, areas, - areas_size, can_split, - prev_lvseg, &allocated, new_extents)) { - stack; - goto out; - } - - finished: if (allocated != new_extents) { log_error("Insufficient suitable %sallocatable extents " "for logical volume %s: %u more required", @@ -1165,6 +1143,13 @@ static int _allocate(struct alloc_handle *ah, goto out; } + if (ah->log_count && !ah->log_area.len) { + log_error("Insufficient extents for log allocation " + "for logical volume %s.", + lv ? lv->name : ""); + goto out; + } + r = 1; out: diff --git a/lib/metadata/metadata.h b/lib/metadata/metadata.h index f45177ba3..35d8dfd35 100644 --- a/lib/metadata/metadata.h +++ b/lib/metadata/metadata.h @@ -78,17 +78,18 @@ #define FMT_RESIZE_PV 0x00000080U /* Supports pvresize? */ #define FMT_UNLIMITED_STRIPESIZE 0x00000100U /* Unlimited stripe size? */ +/* Ordered list - see lv_manip.c */ typedef enum { - ALLOC_INVALID = 0, - ALLOC_INHERIT, + ALLOC_INVALID, ALLOC_CONTIGUOUS, ALLOC_CLING, ALLOC_NORMAL, - ALLOC_ANYWHERE + ALLOC_ANYWHERE, + ALLOC_INHERIT } alloc_policy_t; typedef enum { - AREA_UNASSIGNED = 0, + AREA_UNASSIGNED, AREA_PV, AREA_LV } area_type_t; diff --git a/tools/lvconvert.c b/tools/lvconvert.c index 10bf051cf..43e2bf6a2 100644 --- a/tools/lvconvert.c +++ b/tools/lvconvert.c @@ -281,15 +281,8 @@ static int lvconvert_mirrors(struct cmd_context * cmd, struct logical_volume * l if (lp->mirrors == existing_mirrors) { if (!seg->log_lv && !arg_count(cmd, corelog_ARG)) { /* No disk log present, add one. */ - /* FIXME: Why doesn't this work? Without - it, we will probably put the log on the - same device as a mirror leg. - if (!(parallel_areas = build_parallel_areas_from_lv(cmd, lv))) { - stack; - return 0; - } - */ - parallel_areas = NULL; + if (!(parallel_areas = build_parallel_areas_from_lv(cmd, lv))) + return_0; if (!lv_mirror_percent(cmd, lv, 0, &sync_percent, NULL)) { log_error("Unable to determine mirror sync status."); return 0; @@ -297,7 +290,7 @@ static int lvconvert_mirrors(struct cmd_context * cmd, struct logical_volume * l segtype = get_segtype_from_string(cmd, "striped"); - if (!(ah = allocate_extents(lv->vg, NULL, segtype, 1, + if (!(ah = allocate_extents(lv->vg, NULL, segtype, 0, 0, 1, 0, NULL, 0, 0, lp->pvh, lp->alloc,