Whamcloud - gitweb
b=19860
[fs/lustre-release.git] / lustre / include / md_object.h
index 8832552..6f818b5 100644 (file)
@@ -56,7 +56,7 @@
 /*
  * super-class definitions.
  */
-#include <lu_object.h>
+#include <dt_object.h>
 #include <lvfs.h>
 
 struct md_device;
@@ -246,7 +246,10 @@ struct md_object_operations {
                             struct lustre_capa *, int renewal);
 
         int (*moo_object_sync)(const struct lu_env *, struct md_object *);
-
+        dt_obj_version_t (*moo_version_get)(const struct lu_env *,
+                                            struct md_object *);
+        void (*moo_version_set)(const struct lu_env *, struct md_object *,
+                                dt_obj_version_t);
         int (*moo_path)(const struct lu_env *env, struct md_object *obj,
                         char *path, int pathlen, __u64 *recno, int *linkno);
 };
@@ -408,11 +411,13 @@ struct md_device_operations {
 };
 
 enum md_upcall_event {
-        /**sync the md layer*/
+        /** Sync the md layer*/
         MD_LOV_SYNC = (1 << 0),
         /** Just for split, no need trans, for replay */
         MD_NO_TRANS = (1 << 1),
-        MD_LOV_CONFIG = (1 << 2)
+        MD_LOV_CONFIG = (1 << 2),
+        /** Trigger quota recovery */
+        MD_LOV_QUOTA = (1 << 3)
 };
 
 struct md_upcall {
@@ -423,7 +428,7 @@ struct md_upcall {
         struct md_device       *mu_upcall_dev;
         /** upcall function */
         int (*mu_upcall)(const struct lu_env *env, struct md_device *md,
-                         enum md_upcall_event ev);
+                         enum md_upcall_event ev, void *data);
 };
 
 struct md_device {
@@ -455,14 +460,15 @@ static inline void md_upcall_fini(struct md_device *m)
 }
 
 static inline int md_do_upcall(const struct lu_env *env, struct md_device *m,
-                               enum md_upcall_event ev)
+                               enum md_upcall_event ev, void *data)
 {
         int rc = 0;
         down_read(&m->md_upcall.mu_upcall_sem);
         if (m->md_upcall.mu_upcall_dev != NULL &&
             m->md_upcall.mu_upcall_dev->md_upcall.mu_upcall != NULL) {
                 rc = m->md_upcall.mu_upcall_dev->md_upcall.mu_upcall(env,
-                                              m->md_upcall.mu_upcall_dev, ev);
+                                              m->md_upcall.mu_upcall_dev,
+                                              ev, data);
         }
         up_read(&m->md_upcall.mu_upcall_sem);
         return rc;
@@ -704,6 +710,20 @@ static inline int mo_object_sync(const struct lu_env *env, struct md_object *m)
         return m->mo_ops->moo_object_sync(env, m);
 }
 
+static inline dt_obj_version_t mo_version_get(const struct lu_env *env,
+                                              struct md_object *m)
+{
+        LASSERT(m->mo_ops->moo_version_get);
+        return m->mo_ops->moo_version_get(env, m);
+}
+
+static inline void mo_version_set(const struct lu_env *env,
+                                  struct md_object *m, dt_obj_version_t ver)
+{
+        LASSERT(m->mo_ops->moo_version_set);
+        return m->mo_ops->moo_version_set(env, m, ver);
+}
+
 static inline int mdo_lookup(const struct lu_env *env,
                              struct md_object *p,
                              const struct lu_name *lname,