-struct lov_extent *lovea_off2le(struct lov_stripe_md *lsm, obd_off lov_off)
-{
- struct lov_array_info *lai;
- struct lov_extent *le;
- int i = 0;
-
- LASSERT(lsm->lsm_array != NULL);
- lai = lsm->lsm_array;
- LASSERT(lai->lai_ext_count > 1);
-
- for (le = lai->lai_ext_array, i = 0;
- i < lai->lai_ext_count && le->le_start + le->le_len <= lov_off
- && le->le_len != -1;
- i ++, le ++) {
- ; /* empty loop */
- }
-
- CDEBUG(D_INFO, "off "LPU64" idx %d, ext "LPU64":"LPU64" idx %d sc %d\n",
- lov_off, i, le->le_start, le->le_len, le->le_loi_idx,
- le->le_stripe_count);
-
- RETURN(le);
-}
-
-struct lov_extent *lovea_idx2le(struct lov_stripe_md *lsm, int stripe_no)
-{
- struct lov_extent *le;
- struct lov_array_info *lai;
- int i, stripe_index;
-
- LASSERT(lsm->lsm_array != NULL);
- LASSERT(stripe_no >= 0 && stripe_no <= lsm->lsm_stripe_count);
- lai = lsm->lsm_array;
- LASSERT(lai->lai_ext_count > 1);
-
- for (le = lai->lai_ext_array, i = 0, stripe_index = le->le_stripe_count;
- i < lai->lai_ext_count && stripe_index <= stripe_no &&
- le->le_len != -1; i ++, le ++,
- stripe_index += le->le_stripe_count) {
- ; /* empty loop */
- }
-
- CDEBUG(D_INFO, "stripe %d idx %d, ext "LPU64":"LPU64" idx %d sc %d\n",
- stripe_no, i, le->le_start, le->le_len, le->le_loi_idx,
- le->le_stripe_count);
- RETURN(le);
-}
-
-static void lovea_free_array_info(struct lov_stripe_md *lsm)
-{
- if (!lsm || !lsm->lsm_array)
- return;
-
- if (lsm->lsm_array->lai_ext_array)
- OBD_FREE(lsm->lsm_array->lai_ext_array,
- lsm->lsm_array->lai_ext_count *
- sizeof(struct lov_extent));
-
- OBD_FREE_PTR(lsm->lsm_array);
-}
-
-static void lsm_free_join(struct lov_stripe_md *lsm)
-{
- lovea_free_array_info(lsm);
- lsm_free_plain(lsm);
-}
-
-static void
-lsm_stripe_by_index_join(struct lov_stripe_md *lsm, int *stripeno,
- obd_off *lov_off, obd_off *swidth)
-{
- struct lov_extent *le;
-
- LASSERT(stripeno != NULL);
-
- le = lovea_idx2le(lsm, *stripeno);
-
- LASSERT(le != NULL && le->le_stripe_count != 0);
-
- *stripeno -= le->le_loi_idx;
-
- if (swidth)
- *swidth = (obd_off)lsm->lsm_stripe_size * le->le_stripe_count;
-
- if (lov_off) {
- struct lov_extent *lov_le = lovea_off2le(lsm, *lov_off);
- if (lov_le == le) {
- *lov_off = (*lov_off > le->le_start) ?
- (*lov_off - le->le_start) : 0;
- } else {
- *lov_off = (*lov_off > le->le_start) ?
- le->le_len : 0;
- LASSERT(*lov_off != -1);
- }
- }
-}
-
-static void
-lsm_stripe_by_offset_join(struct lov_stripe_md *lsm, int *stripeno,
- obd_off *lov_off, obd_off *swidth)
-{
- struct lov_extent *le;
-
- LASSERT(lov_off != NULL);
-
- le = lovea_off2le(lsm, *lov_off);
-
- LASSERT(le != NULL && le->le_stripe_count != 0);
-
- *lov_off = (*lov_off > le->le_start) ? (*lov_off - le->le_start) : 0;
-
- if (stripeno)
- *stripeno -= le->le_loi_idx;
-
- if (swidth)
- *swidth = (obd_off)lsm->lsm_stripe_size * le->le_stripe_count;
-}
-
-static obd_off
-lsm_stripe_offset_by_index_join(struct lov_stripe_md *lsm,
- int stripe_index)
-{
- struct lov_extent *le;
-
- le = lovea_idx2le(lsm, stripe_index);
-
- return le ? le->le_start : 0;
-}
-
-static obd_off
-lsm_stripe_offset_by_offset_join(struct lov_stripe_md *lsm,
- obd_off lov_off)
-{
- struct lov_extent *le;
-
- le = lovea_off2le(lsm, lov_off);
-
- return le ? le->le_start : 0;
-}
-
-static int
-lsm_stripe_index_by_offset_join(struct lov_stripe_md *lsm,
- obd_off lov_off)
-{
- struct lov_extent *le = NULL;
-
- le = lovea_off2le(lsm, lov_off);
-
- return le ? le->le_loi_idx : 0;
-}
-
-static int lovea_unpack_array(struct llog_handle *handle,
- struct llog_rec_hdr *rec, void *data)
-{
- struct lovea_unpack_args *args = (struct lovea_unpack_args *)data;
- struct llog_array_rec *la_rec = (struct llog_array_rec*)rec;
- struct mds_extent_desc *med = &la_rec->lmr_med;
- struct lov_stripe_md *lsm = args->lsm;
- int cursor = args->cursor++;
- struct lov_mds_md *lmm;
- struct lov_array_info *lai;
- struct lov_oinfo * loi;
- int i, loi_index;
- ENTRY;
-
- /* sanity check */
- LASSERT(lsm->lsm_stripe_count != 0);
- lmm = &med->med_lmm;
- LASSERT(lsm->lsm_array != NULL);
-
- lai = lsm->lsm_array;
-
- if (cursor == 0) {
- lai->lai_ext_array[cursor].le_loi_idx = 0;
- } else {
- int next_loi_index = lai->lai_ext_array[cursor - 1].le_loi_idx +
- lai->lai_ext_array[cursor - 1].le_stripe_count;
- lai->lai_ext_array[cursor].le_loi_idx = next_loi_index;
- }
- /* insert extent desc into lsm extent array */
- lai->lai_ext_array[cursor].le_start = le64_to_cpu(med->med_start);
- lai->lai_ext_array[cursor].le_len = le64_to_cpu(med->med_len);
- lai->lai_ext_array[cursor].le_stripe_count =
- le32_to_cpu(lmm->lmm_stripe_count);
-
- /* unpack extent's lmm to lov_oinfo array */
- loi_index = lai->lai_ext_array[cursor].le_loi_idx;
- CDEBUG(D_INFO, "lovea upackmd cursor %d, loi_index %d extent "
- LPU64":"LPU64"\n", cursor, loi_index, med->med_start,
- med->med_len);
-
- for (i = 0; i < le32_to_cpu(lmm->lmm_stripe_count); i ++, loi_index++) {
- /* XXX LOV STACKING call down to osc_unpackmd() */
- loi = lsm->lsm_oinfo[loi_index];
- loi->loi_id = le64_to_cpu(lmm->lmm_objects[i].l_object_id);
- loi->loi_gr = le64_to_cpu(lmm->lmm_objects[i].l_object_gr);
- loi->loi_ost_idx = le32_to_cpu(lmm->lmm_objects[i].l_ost_idx);
- loi->loi_ost_gen = le32_to_cpu(lmm->lmm_objects[i].l_ost_gen);
- }
-
- RETURN(0);
-}
-
-static int lsm_revalidate_join(struct lov_stripe_md *lsm,
- struct obd_device *obd)
-{
- struct llog_handle *llh;
- struct llog_ctxt *ctxt;
- struct lovea_unpack_args args;
- int rc, rc2;
- ENTRY;
-
- LASSERT(lsm->lsm_array != NULL);
-
- /*Revalidate lsm might be called from client or MDS server.
- *So the ctxt might be in different position
- */
- ctxt = llog_get_context(obd, LLOG_LOVEA_REPL_CTXT);
- if (!ctxt)
- ctxt = llog_get_context(obd, LLOG_LOVEA_ORIG_CTXT);
-
- LASSERT(ctxt);
-
- if (lsm->lsm_array && lsm->lsm_array->lai_ext_array)
- GOTO(release_ctxt, rc = 0);
-
- CDEBUG(D_INFO, "get lsm logid: "LPU64":"LPU64"\n",
- lsm->lsm_array->lai_array_id.lgl_oid,
- lsm->lsm_array->lai_array_id.lgl_ogr);
- OBD_ALLOC(lsm->lsm_array->lai_ext_array,lsm->lsm_array->lai_ext_count *
- sizeof (struct lov_extent));
- if (!lsm->lsm_array->lai_ext_array)
- GOTO(release_ctxt, rc = -ENOMEM);
-
- CDEBUG(D_INFO, "get lsm logid: "LPU64":"LPU64"\n",
- lsm->lsm_array->lai_array_id.lgl_oid,
- lsm->lsm_array->lai_array_id.lgl_ogr);
-
- rc = llog_create(ctxt, &llh, &lsm->lsm_array->lai_array_id, NULL);
- if (rc)
- GOTO(out, rc);
-
- args.lsm = lsm;
- args.cursor = 0;
- rc = llog_init_handle(llh, LLOG_F_IS_PLAIN, NULL);
- if (rc == 0)
- rc = llog_process(llh, lovea_unpack_array, &args, NULL);
- rc2 = llog_close(llh);
- if (rc == 0)
- rc = rc2;
-out:
- if (rc)
- lovea_free_array_info(lsm);
-release_ctxt:
- llog_ctxt_put(ctxt);
- RETURN(rc);
-}
-
-int lsm_destroy_join(struct lov_stripe_md *lsm, struct obdo *oa,
- struct obd_export *md_exp)
-{
- struct llog_ctxt *ctxt;
- struct llog_handle *llh;
- int rc = 0;
- ENTRY;
-
- LASSERT(md_exp != NULL);
- /*for those orphan inode, we should keep array id*/
- if (!(oa->o_valid & OBD_MD_FLCOOKIE))
- RETURN(rc);
-
- ctxt = llog_get_context(md_exp->exp_obd, LLOG_LOVEA_REPL_CTXT);
- if (!ctxt)
- RETURN(-EINVAL);
-
- LASSERT(lsm->lsm_array != NULL);
- rc = llog_create(ctxt, &llh, &lsm->lsm_array->lai_array_id,
- NULL);
- if (rc)
- GOTO(out, rc);
-
- rc = llog_init_handle(llh, LLOG_F_IS_PLAIN, NULL);
- if (rc == 0) {
- rc = llog_destroy(llh);
- }
- llog_free_handle(llh);
-out:
- llog_ctxt_put(ctxt);
- RETURN(rc);
-}
-
-static int lsm_lmm_verify_join(struct lov_mds_md *lmm, int lmm_bytes,
- int *stripe_count)
-{
- struct lov_mds_md_join *lmmj = (struct lov_mds_md_join *)lmm;
-
- if (lmm_bytes < sizeof(*lmmj)) {
- CERROR("lov_mds_md too small: %d, need at least %d\n",
- lmm_bytes, (int)sizeof(*lmmj));
- return -EINVAL;
- }
-
- if (lmmj->lmmj_array_id.lgl_oid == 0) {
- CERROR("zero array object id\n");
- return -EINVAL;
- }
-
- *stripe_count = le32_to_cpu(lmmj->lmmj_md.lmm_stripe_count);
-
- return lsm_lmm_verify_common(&lmmj->lmmj_md, lmm_bytes, *stripe_count);
-}
-
-static int lovea_init_array_info(struct lov_stripe_md *lsm,
- struct llog_logid *logid,
- __u32 extent_count)
-{
- struct lov_array_info *lai;
- ENTRY;
-
- OBD_ALLOC_PTR(lai);
- if (!lai)
- RETURN(-ENOMEM);
-
- lai->lai_array_id.lgl_oid = le64_to_cpu(logid->lgl_oid);
- lai->lai_array_id.lgl_ogr = le64_to_cpu(logid->lgl_ogr);
- lai->lai_array_id.lgl_ogen = le32_to_cpu(logid->lgl_ogen);
- lai->lai_ext_count = le32_to_cpu(extent_count);
- lsm->lsm_array = lai;
- RETURN(0);
-}
-
-static int lsm_unpackmd_join(struct lov_obd *lov, struct lov_stripe_md *lsm,
- struct lov_mds_md *lmm)
-{
- struct lov_mds_md_join *lmmj = (struct lov_mds_md_join*)lmm;
- int rc;
- ENTRY;
-
- lsm_unpackmd_common(lsm, &lmmj->lmmj_md);
-
- rc = lovea_init_array_info(lsm, &lmmj->lmmj_array_id,
- lmmj->lmmj_extent_count);
- if (rc) {
- CERROR("Init joined lsm id"LPU64" arrary error %d",
- lsm->lsm_object_id, rc);
- GOTO(out, rc);
- }
-out:
- RETURN(rc);
-}
-
-const struct lsm_operations lsm_join_ops = {
- .lsm_free = lsm_free_join,
- .lsm_destroy = lsm_destroy_join,
- .lsm_stripe_by_index = lsm_stripe_by_index_join,
- .lsm_stripe_by_offset = lsm_stripe_by_offset_join,
- .lsm_revalidate = lsm_revalidate_join,
- .lsm_stripe_offset_by_index = lsm_stripe_offset_by_index_join,
- .lsm_stripe_offset_by_offset = lsm_stripe_offset_by_offset_join,
- .lsm_stripe_index_by_offset = lsm_stripe_index_by_offset_join,
- .lsm_lmm_verify = lsm_lmm_verify_join,
- .lsm_unpackmd = lsm_unpackmd_join,
-};
-
-
git://git.whamcloud.com / fs / lustre-release.git / commitdiff