LU-718 mds: new MDS layer.

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

diff --git a/lustre/mdt/mdt_internal.h b/lustre/mdt/mdt_internal.h
index 2d68060..b3e5a34 100644 (file)
--- a/lustre/mdt/mdt_internal.h
+++ b/lustre/mdt/mdt_internal.h
@@ -415,6 +415,61 @@ struct mdt_thread_info {
        char                       mti_xattr_buf[128];
 };
 
+/* ptlrpc request handler for MDT. All handlers are
+ * grouped into several slices - struct mdt_opc_slice,
+ * and stored in an array - mdt_handlers[].
+ */
+struct mdt_handler {
+       /* The name of this handler. */
+       const char *mh_name;
+       /* Fail id for this handler, checked at the beginning of this handler*/
+       int      mh_fail_id;
+       /* Operation code for this handler */
+       __u32       mh_opc;
+       /* flags are listed in enum mdt_handler_flags below. */
+       __u32       mh_flags;
+       /* The actual handler function to execute. */
+       int (*mh_act)(struct mdt_thread_info *info);
+       /* Request format for this request. */
+       const struct req_format *mh_fmt;
+};
+
+enum mdt_handler_flags {
+       /*
+        * struct mdt_body is passed in the incoming message, and object
+        * identified by this fid exists on disk.
+        *
+        * "habeo corpus" == "I have a body"
+        */
+       HABEO_CORPUS = (1 << 0),
+       /*
+        * struct ldlm_request is passed in the incoming message.
+        *
+        * "habeo clavis" == "I have a key"
+        */
+       HABEO_CLAVIS = (1 << 1),
+       /*
+        * this request has fixed reply format, so that reply message can be
+        * packed by generic code.
+        *
+        * "habeo refero" == "I have a reply"
+        */
+       HABEO_REFERO = (1 << 2),
+       /*
+        * this request will modify something, so check whether the filesystem
+        * is readonly or not, then return -EROFS to client asap if necessary.
+        *
+        * "mutabor" == "I shall modify"
+        */
+       MUTABOR      = (1 << 3)
+};
+
+struct mdt_opc_slice {
+       __u32                   mos_opc_start;
+       int                     mos_opc_end;
+       struct mdt_handler      *mos_hs;
+};
+
 static inline const struct md_device_operations *
 mdt_child_ops(struct mdt_device * m)
 {
@@ -624,6 +679,45 @@ int mdt_version_get_check(struct mdt_thread_info *, struct mdt_object *, int);
 void mdt_version_get_save(struct mdt_thread_info *, struct mdt_object *, int);
 int mdt_version_get_check_save(struct mdt_thread_info *, struct mdt_object *,
                                int);
+int mdt_handle_common(struct ptlrpc_request *req,
+                     struct mdt_opc_slice *supported);
+int mdt_connect(struct mdt_thread_info *info);
+int mdt_disconnect(struct mdt_thread_info *info);
+int mdt_set_info(struct mdt_thread_info *info);
+int mdt_get_info(struct mdt_thread_info *info);
+int mdt_getstatus(struct mdt_thread_info *info);
+int mdt_getattr(struct mdt_thread_info *info);
+int mdt_getattr_name(struct mdt_thread_info *info);
+int mdt_statfs(struct mdt_thread_info *info);
+int mdt_reint(struct mdt_thread_info *info);
+int mdt_sync(struct mdt_thread_info *info);
+int mdt_is_subdir(struct mdt_thread_info *info);
+int mdt_obd_ping(struct mdt_thread_info *info);
+int mdt_obd_log_cancel(struct mdt_thread_info *info);
+int mdt_obd_qc_callback(struct mdt_thread_info *info);
+int mdt_enqueue(struct mdt_thread_info *info);
+int mdt_convert(struct mdt_thread_info *info);
+int mdt_bl_callback(struct mdt_thread_info *info);
+int mdt_cp_callback(struct mdt_thread_info *info);
+int mdt_llog_create(struct mdt_thread_info *info);
+int mdt_llog_destroy(struct mdt_thread_info *info);
+int mdt_llog_read_header(struct mdt_thread_info *info);
+int mdt_llog_next_block(struct mdt_thread_info *info);
+int mdt_llog_prev_block(struct mdt_thread_info *info);
+int mdt_sec_ctx_handle(struct mdt_thread_info *info);
+int mdt_readpage(struct mdt_thread_info *info);
+int mdt_obd_idx_read(struct mdt_thread_info *info);
+
+extern struct mdt_opc_slice mdt_regular_handlers[];
+extern struct mdt_opc_slice mdt_seq_handlers[];
+extern struct mdt_opc_slice mdt_fld_handlers[];
+
+int mdt_quotacheck(struct mdt_thread_info *info);
+int mdt_quotactl(struct mdt_thread_info *info);
+int mdt_quota_dqacq(struct mdt_thread_info *info);
+
+extern struct lprocfs_vars lprocfs_mds_module_vars[];
+extern struct lprocfs_vars lprocfs_mds_obd_vars[];
 
 /* mdt_idmap.c */
 int mdt_init_sec_level(struct mdt_thread_info *);
@@ -818,6 +912,7 @@ enum {
 void mdt_counter_incr(struct ptlrpc_request *req, int opcode);
 void mdt_stats_counter_init(struct lprocfs_stats *stats);
 void lprocfs_mdt_init_vars(struct lprocfs_static_vars *lvars);
+void lprocfs_mds_init_vars(struct lprocfs_static_vars *lvars);
 int mdt_procfs_init(struct mdt_device *mdt, const char *name);
 int mdt_procfs_fini(struct mdt_device *mdt);
 void mdt_rename_counter_tally(struct mdt_thread_info *info,
@@ -877,5 +972,28 @@ static inline struct obd_device *mdt2obd_dev(const struct mdt_device *mdt)
 {
         return mdt->mdt_md_dev.md_lu_dev.ld_obd;
 }
+
+extern const struct lu_device_operations mdt_lu_ops;
+
+static inline int lu_device_is_mdt(struct lu_device *d)
+{
+       return ergo(d != NULL && d->ld_ops != NULL, d->ld_ops == &mdt_lu_ops);
+}
+
+static inline struct mdt_device *lu2mdt_dev(struct lu_device *d)
+{
+       LASSERTF(lu_device_is_mdt(d), "It is %s instead of MDT %p %p\n",
+                d->ld_type->ldt_name, d->ld_ops, &mdt_lu_ops);
+       return container_of0(d, struct mdt_device, mdt_md_dev.md_lu_dev);
+}
+
+static inline char *mdt_obd_name(struct mdt_device *mdt)
+{
+       return mdt->mdt_md_dev.md_lu_dev.ld_obd->obd_name;
+}
+
+int mds_mod_init(void);
+void mds_mod_exit(void);
+
 #endif /* __KERNEL__ */
 #endif /* _MDT_H */