int lod_verify_striping(struct lod_device *d, struct lod_object *lo,
const struct lu_buf *buf, bool is_from_disk)
{
- struct lov_user_md_v1 *lum;
- struct lov_comp_md_v1 *comp_v1;
- __u32 magic;
- int rc = 0, i;
+ struct lov_desc *desc = &d->lod_desc;
+ struct lov_user_md_v1 *lum;
+ struct lov_comp_md_v1 *comp_v1;
+ struct lov_comp_md_entry_v1 *ent;
+ struct lu_extent *ext;
+ struct lu_buf tmp;
+ __u64 prev_end = 0;
+ __u32 stripe_size = 0;
+ __u16 prev_mid = -1, mirror_id = -1;
+ __u32 mirror_count = 0;
+ __u32 magic;
+ int rc = 0, i;
ENTRY;
lum = buf->lb_buf;
RETURN(-EINVAL);
}
- if (magic == LOV_USER_MAGIC_COMP_V1) {
- struct lov_comp_md_entry_v1 *ent;
- struct lu_extent *ext;
- struct lov_desc *desc = &d->lod_desc;
- struct lu_buf tmp;
- __u64 prev_end = 0;
- __u32 stripe_size = 0;
-
- comp_v1 = buf->lb_buf;
- if (buf->lb_len < le32_to_cpu(comp_v1->lcm_size)) {
- CDEBUG(D_LAYOUT, "buf len %zu is less than %u\n",
- buf->lb_len, le32_to_cpu(comp_v1->lcm_size));
- RETURN(-EINVAL);
- }
+ if (magic != LOV_USER_MAGIC_COMP_V1)
+ RETURN(lod_verify_v1v3(d, buf, is_from_disk));
- if (le16_to_cpu(comp_v1->lcm_entry_count) == 0) {
- CDEBUG(D_LAYOUT, "entry count is zero\n");
- RETURN(-EINVAL);
- }
+ /* magic == LOV_USER_MAGIC_COMP_V1 */
+ comp_v1 = buf->lb_buf;
+ if (buf->lb_len < le32_to_cpu(comp_v1->lcm_size)) {
+ CDEBUG(D_LAYOUT, "buf len %zu is less than %u\n",
+ buf->lb_len, le32_to_cpu(comp_v1->lcm_size));
+ RETURN(-EINVAL);
+ }
- if (S_ISREG(lod2lu_obj(lo)->lo_header->loh_attr) &&
- lo->ldo_comp_cnt > 0) {
- __u32 cnt = lo->ldo_comp_cnt;
+ if (le16_to_cpu(comp_v1->lcm_entry_count) == 0) {
+ CDEBUG(D_LAYOUT, "entry count is zero\n");
+ RETURN(-EINVAL);
+ }
- ext = &lo->ldo_comp_entries[cnt - 1].llc_extent;
- prev_end = ext->e_end;
- }
+ if (S_ISREG(lod2lu_obj(lo)->lo_header->loh_attr) &&
+ lo->ldo_comp_cnt > 0) {
+ /* could be called from lustre.lov.add */
+ __u32 cnt = lo->ldo_comp_cnt;
- for (i = 0; i < le16_to_cpu(comp_v1->lcm_entry_count); i++) {
- ent = &comp_v1->lcm_entries[i];
- ext = &ent->lcme_extent;
+ ext = &lo->ldo_comp_entries[cnt - 1].llc_extent;
+ prev_end = ext->e_end;
- if (is_from_disk &&
- (le32_to_cpu(ent->lcme_id) == 0 ||
- le32_to_cpu(ent->lcme_id) > LCME_ID_MAX)) {
+ ++mirror_count;
+ }
+
+ for (i = 0; i < le16_to_cpu(comp_v1->lcm_entry_count); i++) {
+ ent = &comp_v1->lcm_entries[i];
+ ext = &ent->lcme_extent;
+
+ if (le64_to_cpu(ext->e_start) >= le64_to_cpu(ext->e_end)) {
+ CDEBUG(D_LAYOUT, "invalid extent "DEXT"\n",
+ le64_to_cpu(ext->e_start),
+ le64_to_cpu(ext->e_end));
+ RETURN(-EINVAL);
+ }
+
+ if (is_from_disk) {
+ /* lcme_id contains valid value */
+ if (le32_to_cpu(ent->lcme_id) == 0 ||
+ le32_to_cpu(ent->lcme_id) > LCME_ID_MAX) {
CDEBUG(D_LAYOUT, "invalid id %u\n",
le32_to_cpu(ent->lcme_id));
RETURN(-EINVAL);
}
- if (le64_to_cpu(ext->e_start) >=
- le64_to_cpu(ext->e_end)) {
- CDEBUG(D_LAYOUT, "invalid extent "
- "[%llu, %llu)\n",
- le64_to_cpu(ext->e_start),
- le64_to_cpu(ext->e_end));
- RETURN(-EINVAL);
- }
+ if (le16_to_cpu(comp_v1->lcm_mirror_count) > 0) {
+ mirror_id = mirror_id_of(
+ le32_to_cpu(ent->lcme_id));
- /* first component must start with 0, and the next
- * must be adjacent with the previous one */
- if (le64_to_cpu(ext->e_start) != prev_end) {
- CDEBUG(D_LAYOUT, "invalid start "
- "actual:%llu, expect:%llu\n",
- le64_to_cpu(ext->e_start), prev_end);
- RETURN(-EINVAL);
+ /* first component must start with 0 */
+ if (mirror_id != prev_mid &&
+ le64_to_cpu(ext->e_start) != 0) {
+ CDEBUG(D_LAYOUT,
+ "invalid start:%llu, expect:0\n",
+ le64_to_cpu(ext->e_start));
+ RETURN(-EINVAL);
+ }
+
+ prev_mid = mirror_id;
}
+ }
- prev_end = le64_to_cpu(ext->e_end);
+ if (le64_to_cpu(ext->e_start) == 0) {
+ ++mirror_count;
+ prev_end = 0;
+ }
- tmp.lb_buf = (char *)comp_v1 +
- le32_to_cpu(ent->lcme_offset);
- tmp.lb_len = le32_to_cpu(ent->lcme_size);
+ /* the next must be adjacent with the previous one */
+ if (le64_to_cpu(ext->e_start) != prev_end) {
+ CDEBUG(D_LAYOUT,
+ "invalid start actual:%llu, expect:%llu\n",
+ le64_to_cpu(ext->e_start), prev_end);
+ RETURN(-EINVAL);
+ }
- /* Checks for DoM entry in composite layout. */
- lum = tmp.lb_buf;
- if (lov_pattern(le32_to_cpu(lum->lmm_pattern)) ==
- LOV_PATTERN_MDT) {
- /* DoM component can be only the first entry */
- if (i > 0) {
- CDEBUG(D_LAYOUT, "invalid DoM layout "
- "entry found at %i index\n", i);
- RETURN(-EINVAL);
- }
- stripe_size = le32_to_cpu(lum->lmm_stripe_size);
- /* There is just one stripe on MDT and it must
- * cover whole component size. */
- if (stripe_size != prev_end) {
- CDEBUG(D_LAYOUT, "invalid DoM layout "
- "stripe size %u != %llu "
- "(component size)\n",
- stripe_size, prev_end);
- RETURN(-EINVAL);
- }
- /* Check stripe size againts per-MDT limit */
- if (stripe_size > d->lod_dom_max_stripesize) {
- CDEBUG(D_LAYOUT, "DoM component size "
- "%u is bigger than MDT limit "
- "%u, check dom_max_stripesize"
- " parameter\n",
- stripe_size,
- d->lod_dom_max_stripesize);
- RETURN(-EINVAL);
- }
- }
- rc = lod_verify_v1v3(d, &tmp, is_from_disk);
- if (rc)
- break;
+ prev_end = le64_to_cpu(ext->e_end);
- lum = tmp.lb_buf;
+ tmp.lb_buf = (char *)comp_v1 + le32_to_cpu(ent->lcme_offset);
+ tmp.lb_len = le32_to_cpu(ent->lcme_size);
- /* extent end must be aligned with the stripe_size */
+ /* Check DoM entry is always the first one */
+ lum = tmp.lb_buf;
+ if (lov_pattern(le32_to_cpu(lum->lmm_pattern)) ==
+ LOV_PATTERN_MDT) {
+ /* DoM component can be only the first entry */
+ if (i > 0) {
+ CDEBUG(D_LAYOUT, "invalid DoM layout "
+ "entry found at %i index\n", i);
+ RETURN(-EINVAL);
+ }
stripe_size = le32_to_cpu(lum->lmm_stripe_size);
- if (stripe_size == 0)
- stripe_size = desc->ld_default_stripe_size;
- if (stripe_size == 0 ||
- (prev_end != LUSTRE_EOF &&
- (prev_end & (stripe_size - 1)))) {
- CDEBUG(D_LAYOUT, "stripe size isn't aligned. "
- " stripe_sz: %u, [%llu, %llu)\n",
- stripe_size, ext->e_start, prev_end);
+ /* There is just one stripe on MDT and it must
+ * cover whole component size. */
+ if (stripe_size != prev_end) {
+ CDEBUG(D_LAYOUT, "invalid DoM layout "
+ "stripe size %u != %llu "
+ "(component size)\n",
+ stripe_size, prev_end);
+ RETURN(-EINVAL);
+ }
+ /* Check stripe size againts per-MDT limit */
+ if (stripe_size > d->lod_dom_max_stripesize) {
+ CDEBUG(D_LAYOUT, "DoM component size "
+ "%u is bigger than MDT limit %u, check "
+ "dom_max_stripesize parameter\n",
+ stripe_size, d->lod_dom_max_stripesize);
RETURN(-EINVAL);
}
}
- } else {
- rc = lod_verify_v1v3(d, buf, is_from_disk);
+
+ rc = lod_verify_v1v3(d, &tmp, is_from_disk);
+ if (rc)
+ RETURN(rc);
+
+ if (prev_end == LUSTRE_EOF)
+ continue;
+
+ /* extent end must be aligned with the stripe_size */
+ stripe_size = le32_to_cpu(lum->lmm_stripe_size);
+ if (stripe_size == 0)
+ stripe_size = desc->ld_default_stripe_size;
+ if (stripe_size == 0 || (prev_end & (stripe_size - 1))) {
+ CDEBUG(D_LAYOUT, "stripe size isn't aligned, "
+ "stripe_sz: %u, [%llu, %llu)\n",
+ stripe_size, ext->e_start, prev_end);
+ RETURN(-EINVAL);
+ }
}
- RETURN(rc);
+ /* make sure that the mirror_count is telling the truth */
+ if (mirror_count != le16_to_cpu(comp_v1->lcm_mirror_count) + 1)
+ RETURN(-EINVAL);
+
+ RETURN(0);
}
/**
* in config log, use them.
*/
if (lod_need_inherit_more(lc, false)) {
-
if (lc->ldo_comp_cnt == 0) {
rc = lod_alloc_comp_entries(lc, 0, 1);
if (rc)
struct lu_attr *attr = &lod_env_info(env)->lti_attr;
uint64_t size, offs;
int i, rc, stripe, stripe_count = 0, stripe_size = 0;
+ struct lu_extent size_ext;
ENTRY;
if (!lod_obj_is_striped(dt))
if (size == 0)
RETURN(0);
+ size_ext = (typeof(size_ext)){ .e_start = size - 1, .e_end = size };
for (i = 0; i < lo->ldo_comp_cnt; i++) {
struct lod_layout_component *lod_comp;
struct lu_extent *extent;
continue;
extent = &lod_comp->llc_extent;
- CDEBUG(D_INFO, "%lld [%lld, %lld)\n",
- size, extent->e_start, extent->e_end);
+ CDEBUG(D_INFO, "%lld "DEXT"\n", size, PEXT(extent));
if (!lo->ldo_is_composite ||
- (size >= extent->e_start && size < extent->e_end)) {
+ lu_extent_is_overlapped(extent, &size_ext)) {
objects = lod_comp->llc_stripe;
stripe_count = lod_comp->llc_stripe_count;
stripe_size = lod_comp->llc_stripe_size;
- break;
- }
- }
- if (stripe_count == 0)
- RETURN(0);
+ /* next mirror */
+ if (stripe_count == 0)
+ continue;
- LASSERT(objects != NULL && stripe_size != 0);
+ LASSERT(objects != NULL && stripe_size != 0);
+ /* ll_do_div64(a, b) returns a % b, and a = a / b */
+ ll_do_div64(size, (__u64)stripe_size);
+ stripe = ll_do_div64(size, (__u64)stripe_count);
+ LASSERT(objects[stripe] != NULL);
- /* ll_do_div64(a, b) returns a % b, and a = a / b */
- ll_do_div64(size, (__u64)stripe_size);
- stripe = ll_do_div64(size, (__u64)stripe_count);
- LASSERT(objects[stripe] != NULL);
+ size = size * stripe_size;
+ offs = attr->la_size;
+ size += ll_do_div64(offs, stripe_size);
- size = size * stripe_size;
- offs = attr->la_size;
- size += ll_do_div64(offs, stripe_size);
+ attr->la_valid = LA_SIZE;
+ attr->la_size = size;
- attr->la_valid = LA_SIZE;
- attr->la_size = size;
-
- rc = lod_sub_declare_attr_set(env, objects[stripe], attr, th);
+ rc = lod_sub_declare_attr_set(env, objects[stripe],
+ attr, th);
+ }
+ }
RETURN(rc);
}
{
struct lod_layout_component *lod_comp;
struct lod_object *lo = lod_dt_obj(dt);
+ __u16 mirror_id;
int rc = 0, i, j;
ENTRY;
LASSERT(lo->ldo_comp_cnt != 0 && lo->ldo_comp_entries != NULL);
+ mirror_id = lo->ldo_mirror_count > 1 ? 1 : 0;
+
/* create all underlying objects */
for (i = 0; i < lo->ldo_comp_cnt; i++) {
lod_comp = &lo->ldo_comp_entries[i];
+ if (lod_comp->llc_extent.e_start == 0 && i > 0) /* new mirror */
+ ++mirror_id;
+
if (lod_comp->llc_id == LCME_ID_INVAL) {
- lod_comp->llc_id = lod_gen_component_id(lo, 0, i);
+ lod_comp->llc_id = lod_gen_component_id(lo,
+ mirror_id, i);
if (lod_comp->llc_id == LCME_ID_INVAL)
GOTO(out, rc = -ERANGE);
}
git://git.whamcloud.com / fs / lustre-release.git / commitdiff