Land b_head_quota onto HEAD (20081116_0105)

[fs/lustre-release.git] / lustre / cmm / cmm_device.c

diff --git a/lustre/cmm/cmm_device.c b/lustre/cmm/cmm_device.c
index d2c435d..839322a 100644 (file)
--- a/lustre/cmm/cmm_device.c
+++ b/lustre/cmm/cmm_device.c
@@ -53,6 +53,9 @@
 #include <lustre_ver.h>
 #include "cmm_internal.h"
 #include "mdc_internal.h"
+#ifdef HAVE_QUOTA_SUPPORT
+# include <lustre_quota.h>
+#endif
 
 static struct obd_ops cmm_obd_device_ops = {
         .o_owner           = THIS_MODULE
@@ -127,12 +130,286 @@ static int cmm_update_capa_key(const struct lu_env *env,
         RETURN(rc);
 }
 
+#ifdef HAVE_QUOTA_SUPPORT
+static int cmm_quota_notify(const struct lu_env *env, struct md_device *m)
+{
+        struct cmm_device *cmm_dev = md2cmm_dev(m);
+        int rc;
+        ENTRY;
+
+        /* disable quota for CMD case temporary. */
+        if (cmm_dev->cmm_tgt_count)
+                RETURN(-EOPNOTSUPP);
+
+        rc = cmm_child_ops(cmm_dev)->mdo_quota.mqo_notify(env,
+                                                          cmm_dev->cmm_child);
+        RETURN(rc);
+}
+
+static int cmm_quota_setup(const struct lu_env *env, struct md_device *m,
+                           void *data)
+{
+        struct cmm_device *cmm_dev = md2cmm_dev(m);
+        int rc;
+        ENTRY;
+
+        /* disable quota for CMD case temporary. */
+        if (cmm_dev->cmm_tgt_count)
+                RETURN(-EOPNOTSUPP);
+
+        rc = cmm_child_ops(cmm_dev)->mdo_quota.mqo_setup(env,
+                                                         cmm_dev->cmm_child,
+                                                         data);
+        RETURN(rc);
+}
+
+static int cmm_quota_cleanup(const struct lu_env *env, struct md_device *m)
+{
+        struct cmm_device *cmm_dev = md2cmm_dev(m);
+        int rc;
+        ENTRY;
+
+        /* disable quota for CMD case temporary. */
+        if (cmm_dev->cmm_tgt_count)
+                RETURN(-EOPNOTSUPP);
+
+        rc = cmm_child_ops(cmm_dev)->mdo_quota.mqo_cleanup(env,
+                                                           cmm_dev->cmm_child);
+        RETURN(rc);
+}
+
+static int cmm_quota_recovery(const struct lu_env *env, struct md_device *m)
+{
+        struct cmm_device *cmm_dev = md2cmm_dev(m);
+        int rc;
+        ENTRY;
+
+        /* disable quota for CMD case temporary. */
+        if (cmm_dev->cmm_tgt_count)
+                RETURN(-EOPNOTSUPP);
+
+        rc = cmm_child_ops(cmm_dev)->mdo_quota.mqo_recovery(env,
+                                                            cmm_dev->cmm_child);
+        RETURN(rc);
+}
+
+static int cmm_quota_check(const struct lu_env *env, struct md_device *m,
+                           struct obd_export *exp, __u32 type)
+{
+        struct cmm_device *cmm_dev = md2cmm_dev(m);
+        int rc;
+        ENTRY;
+
+        /* disable quota for CMD case temporary. */
+        if (cmm_dev->cmm_tgt_count)
+                RETURN(-EOPNOTSUPP);
+
+        rc = cmm_child_ops(cmm_dev)->mdo_quota.mqo_check(env,
+                                                         cmm_dev->cmm_child,
+                                                         exp, type);
+        RETURN(rc);
+}
+
+static int cmm_quota_on(const struct lu_env *env, struct md_device *m,
+                        __u32 type, __u32 id)
+{
+        struct cmm_device *cmm_dev = md2cmm_dev(m);
+        int rc;
+        ENTRY;
+
+        /* disable quota for CMD case temporary. */
+        if (cmm_dev->cmm_tgt_count)
+                RETURN(-EOPNOTSUPP);
+
+        rc = cmm_child_ops(cmm_dev)->mdo_quota.mqo_on(env,
+                                                      cmm_dev->cmm_child,
+                                                      type, id);
+        RETURN(rc);
+}
+
+static int cmm_quota_off(const struct lu_env *env, struct md_device *m,
+                         __u32 type, __u32 id)
+{
+        struct cmm_device *cmm_dev = md2cmm_dev(m);
+        int rc;
+        ENTRY;
+
+        /* disable quota for CMD case temporary. */
+        if (cmm_dev->cmm_tgt_count)
+                RETURN(-EOPNOTSUPP);
+
+        rc = cmm_child_ops(cmm_dev)->mdo_quota.mqo_off(env,
+                                                       cmm_dev->cmm_child,
+                                                       type, id);
+        RETURN(rc);
+}
+
+static int cmm_quota_setinfo(const struct lu_env *env, struct md_device *m,
+                             __u32 type, __u32 id, struct obd_dqinfo *dqinfo)
+{
+        struct cmm_device *cmm_dev = md2cmm_dev(m);
+        int rc;
+        ENTRY;
+
+        /* disable quota for CMD case temporary. */
+        if (cmm_dev->cmm_tgt_count)
+                RETURN(-EOPNOTSUPP);
+
+        rc = cmm_child_ops(cmm_dev)->mdo_quota.mqo_setinfo(env,
+                                                           cmm_dev->cmm_child,
+                                                           type, id, dqinfo);
+        RETURN(rc);
+}
+
+static int cmm_quota_getinfo(const struct lu_env *env,
+                             const struct md_device *m,
+                             __u32 type, __u32 id, struct obd_dqinfo *dqinfo)
+{
+        struct cmm_device *cmm_dev = md2cmm_dev((struct md_device *)m);
+        int rc;
+        ENTRY;
+
+        /* disable quota for CMD case temporary. */
+        if (cmm_dev->cmm_tgt_count)
+                RETURN(-EOPNOTSUPP);
+
+        rc = cmm_child_ops(cmm_dev)->mdo_quota.mqo_getinfo(env,
+                                                           cmm_dev->cmm_child,
+                                                           type, id, dqinfo);
+        RETURN(rc);
+}
+
+static int cmm_quota_setquota(const struct lu_env *env, struct md_device *m,
+                              __u32 type, __u32 id, struct obd_dqblk *dqblk)
+{
+        struct cmm_device *cmm_dev = md2cmm_dev(m);
+        int rc;
+        ENTRY;
+
+        /* disable quota for CMD case temporary. */
+        if (cmm_dev->cmm_tgt_count)
+                RETURN(-EOPNOTSUPP);
+
+        rc = cmm_child_ops(cmm_dev)->mdo_quota.mqo_setquota(env,
+                                                            cmm_dev->cmm_child,
+                                                            type, id, dqblk);
+        RETURN(rc);
+}
+
+static int cmm_quota_getquota(const struct lu_env *env,
+                              const struct md_device *m,
+                              __u32 type, __u32 id, struct obd_dqblk *dqblk)
+{
+        struct cmm_device *cmm_dev = md2cmm_dev((struct md_device *)m);
+        int rc;
+        ENTRY;
+
+        /* disable quota for CMD case temporary. */
+        if (cmm_dev->cmm_tgt_count)
+                RETURN(-EOPNOTSUPP);
+
+        rc = cmm_child_ops(cmm_dev)->mdo_quota.mqo_getquota(env,
+                                                            cmm_dev->cmm_child,
+                                                            type, id, dqblk);
+        RETURN(rc);
+}
+
+static int cmm_quota_getoinfo(const struct lu_env *env,
+                              const struct md_device *m,
+                              __u32 type, __u32 id, struct obd_dqinfo *dqinfo)
+{
+        struct cmm_device *cmm_dev = md2cmm_dev((struct md_device *)m);
+        int rc;
+        ENTRY;
+
+        /* disable quota for CMD case temporary. */
+        if (cmm_dev->cmm_tgt_count)
+                RETURN(-EOPNOTSUPP);
+
+        rc = cmm_child_ops(cmm_dev)->mdo_quota.mqo_getoinfo(env,
+                                                            cmm_dev->cmm_child,
+                                                            type, id, dqinfo);
+        RETURN(rc);
+}
+
+static int cmm_quota_getoquota(const struct lu_env *env,
+                               const struct md_device *m,
+                               __u32 type, __u32 id, struct obd_dqblk *dqblk)
+{
+        struct cmm_device *cmm_dev = md2cmm_dev((struct md_device *)m);
+        int rc;
+        ENTRY;
+
+        /* disable quota for CMD case temporary. */
+        if (cmm_dev->cmm_tgt_count)
+                RETURN(-EOPNOTSUPP);
+
+        rc = cmm_child_ops(cmm_dev)->mdo_quota.mqo_getoquota(env,
+                                                             cmm_dev->cmm_child,
+                                                             type, id, dqblk);
+        RETURN(rc);
+}
+
+static int cmm_quota_invalidate(const struct lu_env *env, struct md_device *m,
+                                __u32 type)
+{
+        struct cmm_device *cmm_dev = md2cmm_dev(m);
+        int rc;
+        ENTRY;
+
+        /* disable quota for CMD case temporary. */
+        if (cmm_dev->cmm_tgt_count)
+                RETURN(-EOPNOTSUPP);
+
+        rc = cmm_child_ops(cmm_dev)->mdo_quota.mqo_invalidate(env,
+                                                              cmm_dev->cmm_child,
+                                                              type);
+        RETURN(rc);
+}
+
+static int cmm_quota_finvalidate(const struct lu_env *env, struct md_device *m,
+                                 __u32 type)
+{
+        struct cmm_device *cmm_dev = md2cmm_dev(m);
+        int rc;
+        ENTRY;
+
+        /* disable quota for CMD case temporary. */
+        if (cmm_dev->cmm_tgt_count)
+                RETURN(-EOPNOTSUPP);
+
+        rc = cmm_child_ops(cmm_dev)->mdo_quota.mqo_finvalidate(env,
+                                                               cmm_dev->cmm_child,
+                                                               type);
+        RETURN(rc);
+}
+#endif
+
 static const struct md_device_operations cmm_md_ops = {
         .mdo_statfs          = cmm_statfs,
         .mdo_root_get        = cmm_root_get,
         .mdo_maxsize_get     = cmm_maxsize_get,
         .mdo_init_capa_ctxt  = cmm_init_capa_ctxt,
         .mdo_update_capa_key = cmm_update_capa_key,
+#ifdef HAVE_QUOTA_SUPPORT
+        .mdo_quota           = {
+                .mqo_notify      = cmm_quota_notify,
+                .mqo_setup       = cmm_quota_setup,
+                .mqo_cleanup     = cmm_quota_cleanup,
+                .mqo_recovery    = cmm_quota_recovery,
+                .mqo_check       = cmm_quota_check,
+                .mqo_on          = cmm_quota_on,
+                .mqo_off         = cmm_quota_off,
+                .mqo_setinfo     = cmm_quota_setinfo,
+                .mqo_getinfo     = cmm_quota_getinfo,
+                .mqo_setquota    = cmm_quota_setquota,
+                .mqo_getquota    = cmm_quota_getquota,
+                .mqo_getoinfo    = cmm_quota_getoinfo,
+                .mqo_getoquota   = cmm_quota_getoquota,
+                .mqo_invalidate  = cmm_quota_invalidate,
+                .mqo_finvalidate = cmm_quota_finvalidate
+        }
+#endif
 };
 
 extern struct lu_device_type mdc_device_type;