b=18127

[fs/lustre-release.git] / lustre / mdt / mdt_internal.h

diff --git a/lustre/mdt/mdt_internal.h b/lustre/mdt/mdt_internal.h
index 5457a05..c8f215c 100644 (file)
--- a/lustre/mdt/mdt_internal.h
+++ b/lustre/mdt/mdt_internal.h
@@ -71,6 +71,7 @@
 #include <lvfs.h>
 #include <lustre_idmap.h>
 #include <lustre_eacl.h>
+#include <lustre_fsfilt.h>
 
 static inline __u64 lcd_last_transno(struct lsd_client_data *lcd)
 {
@@ -127,7 +128,8 @@ struct mdt_device {
                                    mo_acl        :1,
                                    mo_compat_resname:1,
                                    mo_mds_capa   :1,
-                                   mo_oss_capa   :1;
+                                   mo_oss_capa   :1,
+                                   mo_cos        :1;
         } mdt_opts;
         /* mdt state flags */
         __u32                      mdt_fl_cfglog:1,
@@ -173,13 +175,23 @@ struct mdt_device {
         struct lustre_capa_key     mdt_capa_keys[2];
         unsigned int               mdt_capa_conf:1;
 
+        /* root squash */
+        uid_t                      mdt_squash_uid;
+        gid_t                      mdt_squash_gid;
+        struct list_head           mdt_nosquash_nids;
+        char                      *mdt_nosquash_str;
+        int                        mdt_nosquash_strlen;
+        struct rw_semaphore        mdt_squash_sem;
+
         cfs_proc_dir_entry_t      *mdt_proc_entry;
         struct lprocfs_stats      *mdt_stats;
+        int                        mdt_sec_level;
 };
 
 #define MDT_SERVICE_WATCHDOG_FACTOR     (2000)
 #define MDT_ROCOMPAT_SUPP       (OBD_ROCOMPAT_LOVOBJID)
 #define MDT_INCOMPAT_SUPP       (OBD_INCOMPAT_MDT | OBD_INCOMPAT_COMMON_LR)
+#define MDT_COS_DEFAULT         (1)
 
 struct mdt_object {
         struct lu_object_header mot_header;
@@ -310,7 +322,7 @@ struct mdt_thread_info {
 
         /*
          * XXX: Part Three:
-         * The following members will be filled explictly
+         * The following members will be filled explicitly
          * with zero in mdt_reint_unpack(), because they are only used
          * by reint requests (including mdt_reint_open()).
          */
@@ -367,6 +379,7 @@ struct mdt_thread_info {
 
         /* Ops object filename */
         struct lu_name             mti_name;
+        struct md_attr             mti_tmp_attr;
 };
 
 typedef void (*mdt_cb_t)(const struct mdt_device *mdt, __u64 transno,
@@ -376,6 +389,12 @@ struct mdt_commit_cb {
         void     *mdt_cb_data;
 };
 
+enum mdt_txn_op {
+        MDT_TXN_CAPA_KEYS_WRITE_OP,
+        MDT_TXN_LAST_RCVD_WRITE_OP,
+};
+
+
 /*
  * Info allocated per-transaction.
  */
@@ -530,7 +549,7 @@ extern void target_recovery_fini(struct obd_device *obd);
 extern void target_recovery_init(struct obd_device *obd,
                                  svc_handler_t handler);
 int mdt_fs_setup(const struct lu_env *, struct mdt_device *,
-                 struct obd_device *);
+                 struct obd_device *, struct lustre_sb_info *lsi);
 void mdt_fs_cleanup(const struct lu_env *, struct mdt_device *);
 
 int mdt_client_del(const struct lu_env *env,
@@ -575,8 +594,12 @@ void mdt_shrink_reply(struct mdt_thread_info *info);
 int mdt_handle_last_unlink(struct mdt_thread_info *, struct mdt_object *,
                            const struct md_attr *);
 void mdt_reconstruct_open(struct mdt_thread_info *, struct mdt_lock_handle *);
+
+void mdt_trans_credit_init(const struct lu_env *env,
+                           struct mdt_device *mdt,
+                           enum mdt_txn_op op);
 struct thandle* mdt_trans_start(const struct lu_env *env,
-                                struct mdt_device *mdt, int credits);
+                                struct mdt_device *mdt);
 void mdt_trans_stop(const struct lu_env *env,
                     struct mdt_device *mdt, struct thandle *th);
 int mdt_record_write(const struct lu_env *env,
@@ -597,21 +620,16 @@ int mdt_init_ucred_reint(struct mdt_thread_info *);
 void mdt_exit_ucred(struct mdt_thread_info *);
 
 /* mdt_idmap.c */
+int mdt_init_sec_level(struct mdt_thread_info *);
 int mdt_init_idmap(struct mdt_thread_info *);
-
 void mdt_cleanup_idmap(struct mdt_export_data *);
-
 int mdt_handle_idmap(struct mdt_thread_info *);
-
 int ptlrpc_user_desc_do_idmap(struct ptlrpc_request *,
                               struct ptlrpc_user_desc *);
-
 void mdt_body_reverse_idmap(struct mdt_thread_info *,
                             struct mdt_body *);
-
 int mdt_remote_perm_reverse_idmap(struct ptlrpc_request *,
                                   struct mdt_remote_perm *);
-
 int mdt_fix_attr_ucred(struct mdt_thread_info *, __u32);
 
 static inline struct mdt_device *mdt_dev(struct lu_device *d)
@@ -680,13 +698,15 @@ static inline int is_identity_get_disabled(struct upcall_cache *cache)
         return cache ? (strcmp(cache->uc_upcall, "NONE") == 0) : 1;
 }
 
+int mdt_blocking_ast(struct ldlm_lock*, struct ldlm_lock_desc*, void*, int);
+
 /* Issues dlm lock on passed @ns, @f stores it lock handle into @lh. */
 static inline int mdt_fid_lock(struct ldlm_namespace *ns,
                                struct lustre_handle *lh,
                                ldlm_mode_t mode,
                                ldlm_policy_data_t *policy,
                                const struct ldlm_res_id *res_id,
-                               int flags)
+                               int flags, const __u64 *client_cookie)
 {
         int rc;
 
@@ -694,9 +714,9 @@ static inline int mdt_fid_lock(struct ldlm_namespace *ns,
         LASSERT(lh != NULL);
 
         rc = ldlm_cli_enqueue_local(ns, res_id, LDLM_IBITS, policy,
-                                    mode, &flags, ldlm_blocking_ast,
-                                    ldlm_completion_ast, NULL, NULL,
-                                    0, NULL, lh);
+                                    mode, &flags, mdt_blocking_ast,
+                                    ldlm_completion_ast,
+                                    NULL, NULL, 0, NULL, client_cookie, lh);
         return rc == ELDLM_OK ? 0 : -EIO;
 }
 
@@ -749,6 +769,9 @@ static inline struct lu_name *mdt_name_copy(struct lu_name *tlname,
         return tlname;
 }
 
+void mdt_enable_cos(struct mdt_device *, int);
+int mdt_cos_is_enabled(struct mdt_device *);
+
 /* lprocfs stuff */
 void lprocfs_mdt_init_vars(struct lprocfs_static_vars *lvars);
 int mdt_procfs_init(struct mdt_device *mdt, const char *name);
@@ -771,11 +794,11 @@ static inline void mdt_set_capainfo(struct mdt_thread_info *info, int offset,
                                     const struct lu_fid *fid,
                                     struct lustre_capa *capa)
 {
-        struct mdt_device *dev = info->mti_mdt;
         struct md_capainfo *ci;
 
         LASSERT(offset >= 0 && offset <= MD_CAPAINFO_MAX);
-        if (!dev->mdt_opts.mo_mds_capa)
+        if (!info->mti_mdt->mdt_opts.mo_mds_capa ||
+            !(info->mti_exp->exp_connect_flags & OBD_CONNECT_MDS_CAPA))
                 return;
 
         ci = md_capainfo(info->mti_env);
@@ -808,5 +831,9 @@ static inline void mdt_dump_capainfo(struct mdt_thread_info *info)
         }
 }
 
+static inline struct obd_device *mdt2obd_dev(const struct mdt_device *mdt)
+{
+        return mdt->mdt_md_dev.md_lu_dev.ld_obd;
+}
 #endif /* __KERNEL__ */
 #endif /* _MDT_H */