LU-5099 api: transfer object type via dt_insert API

[fs/lustre-release.git] / lustre / lfsck / lfsck_internal.h

diff --git a/lustre/lfsck/lfsck_internal.h b/lustre/lfsck/lfsck_internal.h
index 9f20729..36259fa 100644 (file)
--- a/lustre/lfsck/lfsck_internal.h
+++ b/lustre/lfsck/lfsck_internal.h
@@ -45,6 +45,7 @@
 #include <lustre_dlm.h>
 #include <lustre_fid.h>
 #include <md_object.h>
+#include <lustre_linkea.h>
 
 #define HALF_SEC                       (HZ >> 1)
 #define LFSCK_CHECKPOINT_INTERVAL      60
@@ -101,8 +102,14 @@ struct lfsck_bookmark {
        /* For 64-bits aligned. */
        __u16   lb_padding;
 
+       /* The FID for .lustre/lost+found/MDTxxxx */
+       struct lu_fid   lb_lpf_fid;
+
+       /* The FID for the last MDT-object created by the LFSCK repairing. */
+       struct lu_fid   lb_last_fid;
+
        /* For future using. */
-       __u64   lb_reserved[6];
+       __u64   lb_reserved[2];
 };
 
 struct lfsck_namespace {
@@ -175,8 +182,11 @@ struct lfsck_namespace {
        /* The latest object has been processed (failed) during double scan. */
        struct lu_fid   ln_fid_latest_scanned_phase2;
 
-       /* For further using. 256-bytes aligned now. */
-       __u64   ln_reserved[2];
+       /* How many FID-in-dirent entries have been repaired. */
+       __u64   ln_dirent_repaired;
+
+       /* How many linkEA entries have been repaired. */
+       __u64   ln_linkea_repaired;
 };
 
 enum lfsck_layout_inconsistency_type {
@@ -224,7 +234,8 @@ struct lfsck_layout {
        /* Position for the last LFSCK checkpoint. */
        __u64   ll_pos_last_checkpoint;
 
-       /* Position for the first should be updated object. */
+       /* Position for the first object to be fixed or
+        * failed to be checked in the phase1. */
        __u64   ll_pos_first_inconsistent;
 
        /* How many objects have been checked. */
@@ -239,7 +250,7 @@ struct lfsck_layout {
        /* How many objects failed to be processed during double scan. */
        __u64   ll_objs_failed_phase2;
 
-       /* kinds of inconsistency have been repaired.
+       /* kinds of inconsistency have been or to be repaired.
         * ll_objs_repaired[type - 1] is the count for the given @type. */
        __u64   ll_objs_repaired[LLIT_MAX];
 
@@ -293,8 +304,7 @@ struct lfsck_operations {
 
        int (*lfsck_dump)(const struct lu_env *env,
                          struct lfsck_component *com,
-                         char *buf,
-                         int len);
+                         struct seq_file *m);
 
        int (*lfsck_double_scan)(const struct lu_env *env,
                                 struct lfsck_component *com);
@@ -449,6 +459,8 @@ struct lfsck_instance {
        struct lu_fid             li_local_root_fid;  /* backend root "/" */
        struct lu_fid             li_global_root_fid; /* /ROOT */
        struct dt_object         *li_bookmark_obj;
+       struct dt_object         *li_lpf_obj;
+       struct lu_client_seq     *li_seq;
        struct lfsck_bookmark     li_bookmark_ram;
        struct lfsck_bookmark     li_bookmark_disk;
        struct lfsck_position     li_pos_current;
@@ -526,6 +538,8 @@ struct lfsck_thread_args {
        struct lfsck_start_param        *lta_lsp;
 };
 
+#define LFSCK_TMPBUF_LEN       64
+
 struct lfsck_thread_info {
        struct lu_name          lti_name;
        struct lu_buf           lti_buf;
@@ -533,6 +547,7 @@ struct lfsck_thread_info {
        struct lu_buf           lti_big_buf;
        struct lu_fid           lti_fid;
        struct lu_fid           lti_fid2;
+       struct lu_fid           lti_fid3;
        struct lu_attr          lti_la;
        struct lu_attr          lti_la2;
        struct lu_attr          lti_la3;
@@ -543,10 +558,9 @@ struct lfsck_thread_info {
                char                    lti_lma_old[LMA_OLD_SIZE];
        };
        struct dt_object_format lti_dof;
-       /* lti_ent and lti_key must be conjoint,
-        * then lti_ent::lde_name will be lti_key. */
-       struct lu_dirent        lti_ent;
-       char                    lti_key[NAME_MAX + 16];
+       /* There will be '\0' at the end of the name. */
+       char            lti_key[sizeof(struct lu_dirent) + NAME_MAX + 1];
+       char                    lti_tmpbuf[LFSCK_TMPBUF_LEN];
        struct lfsck_request    lti_lr;
        struct lfsck_async_interpret_args lti_laia;
        struct lfsck_start      lti_start;
@@ -559,9 +573,14 @@ struct lfsck_thread_info {
        };
        struct dt_allocation_hint lti_hint;
        struct lu_orphan_rec    lti_rec;
+       struct lov_user_md      lti_lum;
+       struct dt_insert_rec    lti_dt_rec;
 };
 
 /* lfsck_lib.c */
+int lfsck_fid_alloc(const struct lu_env *env, struct lfsck_instance *lfsck,
+                   struct lu_fid *fid, bool locked);
+int lfsck_create_lpf(const struct lu_env *env, struct lfsck_instance *lfsck);
 struct lfsck_instance *lfsck_instance_find(struct dt_device *key, bool ref,
                                           bool unlink);
 struct lfsck_component *lfsck_component_find(struct lfsck_instance *lfsck,
@@ -571,13 +590,14 @@ void lfsck_component_cleanup(const struct lu_env *env,
                             struct lfsck_component *com);
 void lfsck_instance_cleanup(const struct lu_env *env,
                            struct lfsck_instance *lfsck);
-int lfsck_bits_dump(char **buf, int *len, int bits, const char *names[],
+int lfsck_bits_dump(struct seq_file *m, int bits, const char *names[],
                    const char *prefix);
-int lfsck_time_dump(char **buf, int *len, __u64 time, const char *prefix);
-int lfsck_pos_dump(char **buf, int *len, struct lfsck_position *pos,
+int lfsck_time_dump(struct seq_file *m, __u64 time, const char *prefix);
+int lfsck_pos_dump(struct seq_file *m, struct lfsck_position *pos,
                   const char *prefix);
 void lfsck_pos_fill(const struct lu_env *env, struct lfsck_instance *lfsck,
                    struct lfsck_position *pos, bool init);
+bool __lfsck_set_speed(struct lfsck_instance *lfsck, __u32 limit);
 void lfsck_control_speed(struct lfsck_instance *lfsck);
 void lfsck_control_speed_by_self(struct lfsck_component *com);
 int lfsck_reset(const struct lu_env *env, struct lfsck_instance *lfsck,
@@ -609,12 +629,19 @@ int lfsck_async_request(const struct lu_env *env, struct obd_export *exp,
 int lfsck_master_engine(void *args);
 
 /* lfsck_bookmark.c */
+void lfsck_bookmark_cpu_to_le(struct lfsck_bookmark *des,
+                             struct lfsck_bookmark *src);
 int lfsck_bookmark_store(const struct lu_env *env,
                         struct lfsck_instance *lfsck);
 int lfsck_bookmark_setup(const struct lu_env *env,
                         struct lfsck_instance *lfsck);
+int lfsck_set_param(const struct lu_env *env, struct lfsck_instance *lfsck,
+                   struct lfsck_start *start, bool reset);
 
 /* lfsck_namespace.c */
+int lfsck_verify_linkea(const struct lu_env *env, struct dt_device *dev,
+                       struct dt_object *obj, const struct lu_name *cname,
+                       const struct lu_fid *pfid);
 int lfsck_namespace_setup(const struct lu_env *env,
                          struct lfsck_instance *lfsck);