+ lmm_size, logcookies, fid, NULL);
+ RETURN(rc);
+}
+
+static int grouplock_blocking_ast(struct ldlm_lock *lock,
+ struct ldlm_lock_desc *desc,
+ void *data, int flag)
+{
+ struct md_attr *ma = data;
+ struct lustre_handle lockh;
+ int rc = 0;
+ ENTRY;
+
+ switch (flag)
+ {
+ case LDLM_CB_BLOCKING :
+ /* lock is canceled */
+ CDEBUG(D_DLMTRACE, "Lock %p is canceled\n", lock);
+
+ ldlm_lock2handle(lock, &lockh);
+ rc = ldlm_cli_cancel(&lockh);
+
+ break;
+ case LDLM_CB_CANCELING :
+ CDEBUG(D_DLMTRACE,
+ "Lock %p has been canceled, do cleaning\n",
+ lock);
+
+ if (ma && ma->ma_som)
+ OBD_FREE_PTR(ma->ma_som);
+ if (ma)
+ OBD_FREE_PTR(ma);
+ break;
+ default:
+ LBUG();
+ }
+ RETURN(rc);
+}
+
+static int grouplock_glimpse_ast(struct ldlm_lock *lock, void *data)
+{
+ struct ptlrpc_request *req = data;
+ struct ost_lvb *lvb;
+ int rc;
+ struct md_attr *ma;
+ ENTRY;
+
+ ma = lock->l_ast_data;
+
+ req_capsule_extend(&req->rq_pill, &RQF_LDLM_GL_CALLBACK);
+ req_capsule_set_size(&req->rq_pill, &RMF_DLM_LVB, RCL_SERVER,
+ sizeof(*lvb));
+ rc = req_capsule_server_pack(&req->rq_pill);
+ if (rc) {
+ CERROR("failed pack reply: %d\n", rc);
+ GOTO(out, rc);
+ }
+
+ lvb = req_capsule_server_get(&req->rq_pill, &RMF_DLM_LVB);
+
+ if ((ma) && (ma->ma_valid & MA_SOM)) {
+ lvb->lvb_size = ma->ma_som->msd_size;
+ lvb->lvb_blocks = ma->ma_som->msd_blocks;
+ } else if ((ma) && (ma->ma_valid & MA_INODE)) {
+ lvb->lvb_size = ma->ma_attr.la_size;
+ lvb->lvb_blocks = ma->ma_attr.la_blocks;
+ } else {
+ lvb->lvb_size = 0;
+ rc = -ELDLM_NO_LOCK_DATA;
+ }
+
+ EXIT;
+out:
+ if (rc == -ELDLM_NO_LOCK_DATA)
+ lustre_pack_reply(req, 1, NULL, NULL);
+
+ req->rq_status = rc;
+ return rc;
+}
+
+int mdd_file_lock(const struct lu_env *env, struct md_object *obj,
+ struct lov_mds_md *lmm, struct ldlm_extent *extent,
+ struct lustre_handle *lockh)
+{
+ struct ldlm_enqueue_info einfo = { 0 };
+ struct obd_info oinfo = { { { 0 } } };
+ struct obd_device *obd;
+ struct obd_export *lov_exp;
+ struct lov_stripe_md *lsm = NULL;
+ struct md_attr *ma = NULL;
+ int rc;
+ ENTRY;