Whamcloud - gitweb
LU-3336 lfsck: namespace visible lost+found directory
[fs/lustre-release.git] / lustre / lfsck / lfsck_internal.h
index 8862f83..b9cdd69 100644 (file)
@@ -101,8 +101,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 {
@@ -286,6 +292,11 @@ struct lfsck_operations {
                          int result,
                          bool init);
 
+       int (*lfsck_interpret)(const struct lu_env *env,
+                              struct ptlrpc_request *req,
+                              void *args,
+                              int rc);
+
        int (*lfsck_dump)(const struct lu_env *env,
                          struct lfsck_component *com,
                          char *buf,
@@ -383,6 +394,7 @@ struct lfsck_component {
        void                    *lc_file_ram;
        void                    *lc_file_disk;
        void                    *lc_data;
+       struct lu_fid            lc_fid_latest_scanned_phase2;
 
        /* The time for last checkpoint, jiffies */
        cfs_time_t               lc_time_last_checkpoint;
@@ -443,6 +455,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;
@@ -492,7 +506,8 @@ struct lfsck_instance {
        unsigned int              li_oit_over:1, /* oit is finished. */
                                  li_drop_dryrun:1, /* Ever dryrun, not now. */
                                  li_master:1, /* Master instance or not. */
-                                 li_current_oit_processed:1;
+                                 li_current_oit_processed:1,
+                                 li_start_unplug:1;
 };
 
 enum lfsck_linkea_flags {
@@ -508,6 +523,8 @@ struct lfsck_async_interpret_args {
        struct lfsck_tgt_descs          *laia_ltds;
        struct lfsck_tgt_desc           *laia_ltd;
        struct lfsck_request            *laia_lr;
+       int                              laia_result;
+       unsigned int                     laia_shared:1;
 };
 
 struct lfsck_thread_args {
@@ -524,8 +541,10 @@ 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;
        struct ost_id           lti_oi;
        union {
                struct lustre_mdt_attrs lti_lma;
@@ -539,6 +558,7 @@ struct lfsck_thread_info {
        char                    lti_key[NAME_MAX + 16];
        struct lfsck_request    lti_lr;
        struct lfsck_async_interpret_args lti_laia;
+       struct lfsck_start      lti_start;
        struct lfsck_stop       lti_stop;
        ldlm_policy_data_t      lti_policy;
        struct ldlm_res_id      lti_resid;
@@ -547,9 +567,17 @@ struct lfsck_thread_info {
                struct filter_fid       lti_new_pfid;
        };
        struct dt_allocation_hint lti_hint;
+       struct lu_orphan_rec    lti_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,
+                                            __u16 type);
 const char *lfsck_status2names(enum lfsck_status status);
 void lfsck_component_cleanup(const struct lu_env *env,
                             struct lfsck_component *com);
@@ -593,6 +621,8 @@ 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,