X-Git-Url: https://git.whamcloud.com/?a=blobdiff_plain;f=lustre%2Fosc%2Fosc_create.c;h=cbe8d5d5713a13616187d8c958b1e0aa63746f65;hb=refs%2Ftags%2Fv1_10_0_41a;hp=6c555d5bfa7b2ab5354395b9e605280094146fa9;hpb=cfa207a65e9dc08a006460d48c5b583e45428ab1;p=fs%2Flustre-release.git

diff --git a/lustre/osc/osc_create.c b/lustre/osc/osc_create.c
index 6c555d5..cbe8d5d 100644
--- a/lustre/osc/osc_create.c
+++ b/lustre/osc/osc_create.c
@@ -95,7 +95,7 @@ static int osc_interpret_create(const struct lu_env *env,
         switch (rc) {
         case 0: {
                 if (body) {
-                        int diff =ostid_id(&body->oa.o_oi)- oscc->oscc_last_id;
+                        int diff = body->oa.o_id - oscc->oscc_last_id;
 
                         /* oscc_internal_create() stores the original value of
                          * grow_count in rq_async_args.space[0].
@@ -117,7 +117,7 @@ static int osc_interpret_create(const struct lu_env *env,
                                  * next time if needed */
                                 oscc->oscc_flags &= ~OSCC_FLAG_LOW;
                         }
-                        oscc->oscc_last_id = ostid_id(&body->oa.o_oi);
+                        oscc->oscc_last_id = body->oa.o_id;
                 }
                 cfs_spin_unlock(&oscc->oscc_lock);
                 break;
@@ -238,18 +238,9 @@ static int oscc_internal_create(struct osc_creator *oscc)
         body = req_capsule_client_get(&request->rq_pill, &RMF_OST_BODY);
 
         cfs_spin_lock(&oscc->oscc_lock);
-
-        if (likely(fid_seq_is_mdt(oscc->oscc_oa.o_seq))) {
-                body->oa.o_oi.oi_seq = oscc->oscc_oa.o_seq;
-                body->oa.o_oi.oi_id  = oscc->oscc_last_id +
-                                       oscc->oscc_grow_count;
-        } else {
-                /*Just warning here currently, since not sure how fid-on-ost
-                 *will be implemented here */
-                CWARN("o_seq: "LPU64" is not indicate any MDTs.\n",
-                       oscc->oscc_oa.o_seq);
-        }
-
+        body->oa.o_id = oscc->oscc_last_id + oscc->oscc_grow_count;
+        body->oa.o_gr = oscc->oscc_oa.o_gr;
+        LASSERT_MDS_GROUP(body->oa.o_gr);
         body->oa.o_valid |= OBD_MD_FLID | OBD_MD_FLGROUP;
         request->rq_async_args.space[0] = oscc->oscc_grow_count;
         cfs_spin_unlock(&oscc->oscc_lock);
@@ -459,7 +450,7 @@ int osc_create_async(struct obd_export *exp, struct obd_info *oinfo,
         struct obdo *oa = oinfo->oi_oa;
         ENTRY;
 
-        if ((oa->o_valid & OBD_MD_FLGROUP) && !fid_seq_is_mdt(oa->o_seq)) {
+        if ((oa->o_valid & OBD_MD_FLGROUP) && !filter_group_is_mds(oa->o_gr)) {
                 rc = osc_real_create(exp, oinfo->oi_oa, ea, oti);
                 rc = oinfo->oi_cb_up(oinfo, rc);
                 RETURN(rc);
@@ -533,7 +524,7 @@ int osc_create(struct obd_export *exp, struct obdo *oa,
                 RETURN(osc_real_create(exp, oa, ea, oti));
         }
 
-        if (!fid_seq_is_mdt(oa->o_seq))
+        if (!filter_group_is_mds(oa->o_gr))
                 RETURN(osc_real_create(exp, oa, ea, oti));
 
         /* this is the special case where create removes orphans */