Whamcloud - gitweb
LU-17705 ptlrpc: replace synchronize_rcu() with rcu_barrier()
[fs/lustre-release.git] / lustre / fid / fid_handler.c
index 9dff6eb..95684d9 100644 (file)
  *
  * You should have received a copy of the GNU General Public License
  * version 2 along with this program; If not, see
- * http://www.sun.com/software/products/lustre/docs/GPLv2.pdf
- *
- * Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa Clara,
- * CA 95054 USA or visit www.sun.com if you need additional information or
- * have any questions.
+ * http://www.gnu.org/licenses/gpl-2.0.html
  *
  * GPL HEADER END
  */
  * Copyright (c) 2007, 2010, Oracle and/or its affiliates. All rights reserved.
  * Use is subject to license terms.
  *
- * Copyright (c) 2011, 2013, Intel Corporation.
+ * Copyright (c) 2011, 2017, Intel Corporation.
  */
 /*
  * This file is part of Lustre, http://www.lustre.org/
- * Lustre is a trademark of Sun Microsystems, Inc.
  *
  * lustre/fid/fid_handler.c
  *
 #include <obd.h>
 #include <obd_class.h>
 #include <dt_object.h>
-#include <md_object.h>
 #include <obd_support.h>
 #include <lustre_req_layout.h>
 #include <lustre_fid.h>
 #include "fid_internal.h"
 
-static void seq_server_proc_fini(struct lu_server_seq *seq);
-
 /* Assigns client to sequence controller node. */
-int seq_server_set_cli(struct lu_server_seq *seq,
-                       struct lu_client_seq *cli,
-                       const struct lu_env *env)
+int seq_server_set_cli(const struct lu_env *env, struct lu_server_seq *seq,
+                      struct lu_client_seq *cli)
 {
-        int rc = 0;
-        ENTRY;
+       int rc = 0;
+       ENTRY;
 
-        /*
-         * Ask client for new range, assign that range to ->seq_space and write
-         * seq state to backing store should be atomic.
-         */
+       /*
+        * Ask client for new range, assign that range to ->seq_space and write
+        * seq state to backing store should be atomic.
+        */
        mutex_lock(&seq->lss_mutex);
 
-        if (cli == NULL) {
-                CDEBUG(D_INFO, "%s: Detached sequence client %s\n",
-                       seq->lss_name, cli->lcs_name);
-                seq->lss_cli = cli;
-                GOTO(out_up, rc = 0);
-        }
+       if (!cli) {
+               CDEBUG(D_INFO, "%s: Detached sequence client\n", seq->lss_name);
+               seq->lss_cli = NULL;
+               GOTO(out_up, rc = 0);
+       }
 
-       if (seq->lss_cli != NULL) {
-               CDEBUG(D_HA, "%s: Sequence controller is already "
-                      "assigned\n", seq->lss_name);
+       if (seq->lss_cli) {
+               CDEBUG(D_HA, "%s: Sequence controller is already assigned\n",
+                      seq->lss_name);
                GOTO(out_up, rc = -EEXIST);
        }
 
-        CDEBUG(D_INFO, "%s: Attached sequence controller %s\n",
-               seq->lss_name, cli->lcs_name);
+       CDEBUG(D_INFO, "%s: Attached sequence controller %s\n",
+              seq->lss_name, cli->lcs_name);
 
        seq->lss_cli = cli;
        cli->lcs_space.lsr_index = seq->lss_site->ss_node_id;
        EXIT;
 out_up:
        mutex_unlock(&seq->lss_mutex);
-        return rc;
+       return rc;
 }
 EXPORT_SYMBOL(seq_server_set_cli);
 /*
  * allocate \a w units of sequence from range \a from.
  */
 static inline void range_alloc(struct lu_seq_range *to,
-                               struct lu_seq_range *from,
-                               __u64 width)
+                              struct lu_seq_range *from,
+                              __u64 width)
 {
-        width = min(range_space(from), width);
-        to->lsr_start = from->lsr_start;
-        to->lsr_end = from->lsr_start + width;
-        from->lsr_start += width;
+       width = min(lu_seq_range_space(from), width);
+       to->lsr_start = from->lsr_start;
+       to->lsr_end = from->lsr_start + width;
+       from->lsr_start += width;
 }
 
 /**
@@ -114,16 +104,16 @@ static inline void range_alloc(struct lu_seq_range *to,
  */
 
 static int __seq_server_alloc_super(struct lu_server_seq *seq,
-                                    struct lu_seq_range *out,
-                                    const struct lu_env *env)
+                                   struct lu_seq_range *out,
+                                   const struct lu_env *env)
 {
        struct lu_seq_range *space = &seq->lss_space;
        int rc;
        ENTRY;
 
-       LASSERT(range_is_sane(space));
+       LASSERT(lu_seq_range_is_sane(space));
 
-       if (range_is_exhausted(space)) {
+       if (lu_seq_range_is_exhausted(space)) {
                CERROR("%s: Sequences space is exhausted\n",
                       seq->lss_name);
                RETURN(-ENOSPC);
@@ -140,31 +130,66 @@ static int __seq_server_alloc_super(struct lu_server_seq *seq,
 }
 
 int seq_server_alloc_super(struct lu_server_seq *seq,
-                           struct lu_seq_range *out,
-                           const struct lu_env *env)
+                          struct lu_seq_range *out,
+                          const struct lu_env *env)
 {
-        int rc;
-        ENTRY;
+       int rc;
+       ENTRY;
 
        mutex_lock(&seq->lss_mutex);
-        rc = __seq_server_alloc_super(seq, out, env);
+       rc = __seq_server_alloc_super(seq, out, env);
+       mutex_unlock(&seq->lss_mutex);
+
+       RETURN(rc);
+}
+
+int seq_server_alloc_spec(struct lu_server_seq *seq,
+                         struct lu_seq_range *spec,
+                         const struct lu_env *env)
+{
+       struct lu_seq_range *space = &seq->lss_space;
+       int rc = -ENOSPC;
+       ENTRY;
+
+       /*
+        * In some cases (like recovery after a disaster)
+        * we may need to allocate sequences manually
+        * Notice some sequences can be lost if requested
+        * range doesn't start at the beginning of current
+        * free space. Also notice it's not possible now
+        * to allocate sequences out of natural order.
+        */
+       if (spec->lsr_start >= spec->lsr_end)
+               RETURN(-EINVAL);
+       if (spec->lsr_flags != LU_SEQ_RANGE_MDT &&
+           spec->lsr_flags != LU_SEQ_RANGE_OST)
+               RETURN(-EINVAL);
+
+       mutex_lock(&seq->lss_mutex);
+       if (spec->lsr_start >= space->lsr_start) {
+               space->lsr_start = spec->lsr_end;
+               rc = seq_store_update(env, seq, spec, 1 /* sync */);
+
+               LCONSOLE_INFO("%s: "DRANGE" sequences allocated: rc = %d \n",
+                             seq->lss_name, PRANGE(spec), rc);
+       }
        mutex_unlock(&seq->lss_mutex);
 
-        RETURN(rc);
+       RETURN(rc);
 }
 
 static int __seq_set_init(const struct lu_env *env,
-                            struct lu_server_seq *seq)
+                         struct lu_server_seq *seq)
 {
-        struct lu_seq_range *space = &seq->lss_space;
-        int rc;
+       struct lu_seq_range *space = &seq->lss_space;
+       int rc;
 
-        range_alloc(&seq->lss_lowater_set, space, seq->lss_set_width);
-        range_alloc(&seq->lss_hiwater_set, space, seq->lss_set_width);
+       range_alloc(&seq->lss_lowater_set, space, seq->lss_set_width);
+       range_alloc(&seq->lss_hiwater_set, space, seq->lss_set_width);
 
-        rc = seq_store_update(env, seq, NULL, 1);
+       rc = seq_store_update(env, seq, NULL, 1);
 
-        return rc;
+       return rc;
 }
 
 /*
@@ -179,66 +204,77 @@ static int __seq_set_init(const struct lu_env *env,
  *
  * when lss_lowater_set reaches the end it is replaced with hiwater one and
  * a write operation is initiated to allocate new hiwater range.
- * if last seq write opearion is still not commited, current operation is
+ * if last seq write opearion is still not committed, current operation is
  * flaged as sync write op.
  */
 static int range_alloc_set(const struct lu_env *env,
-                            struct lu_seq_range *out,
-                            struct lu_server_seq *seq)
+                          struct lu_seq_range *out,
+                          struct lu_server_seq *seq)
 {
-        struct lu_seq_range *space = &seq->lss_space;
-        struct lu_seq_range *loset = &seq->lss_lowater_set;
-        struct lu_seq_range *hiset = &seq->lss_hiwater_set;
-        int rc = 0;
+       struct lu_seq_range *space = &seq->lss_space;
+       struct lu_seq_range *loset = &seq->lss_lowater_set;
+       struct lu_seq_range *hiset = &seq->lss_hiwater_set;
+       int rc = 0;
 
-        if (range_is_zero(loset))
-                __seq_set_init(env, seq);
+       if (lu_seq_range_is_zero(loset))
+               __seq_set_init(env, seq);
 
-        if (OBD_FAIL_CHECK(OBD_FAIL_SEQ_ALLOC)) /* exhaust set */
-                loset->lsr_start = loset->lsr_end;
+       if (CFS_FAIL_CHECK(OBD_FAIL_SEQ_ALLOC)) /* exhaust set */
+               loset->lsr_start = loset->lsr_end;
 
-        if (range_is_exhausted(loset)) {
-                /* reached high water mark. */
+       if (lu_seq_range_is_exhausted(loset)) {
+               /* reached high water mark. */
                struct lu_device *dev = seq->lss_site->ss_lu->ls_top_dev;
-                int obd_num_clients = dev->ld_obd->obd_num_exports;
-                __u64 set_sz;
+               int obd_num_clients = dev->ld_obd->obd_num_exports;
+               __u64 set_sz;
 
-                /* calculate new seq width based on number of clients */
-                set_sz = max(seq->lss_set_width,
-                             obd_num_clients * seq->lss_width);
-                set_sz = min(range_space(space), set_sz);
+               /* calculate new seq width based on number of clients */
+               set_sz = max(seq->lss_set_width,
+                            obd_num_clients * seq->lss_width);
+               set_sz = min(lu_seq_range_space(space), set_sz);
 
-                /* Switch to hiwater range now */
-                *loset = *hiset;
-                /* allocate new hiwater range */
-                range_alloc(hiset, space, set_sz);
+               /* Switch to hiwater range now */
+               *loset = *hiset;
+               /* allocate new hiwater range */
+               range_alloc(hiset, space, set_sz);
 
-                /* update ondisk seq with new *space */
-                rc = seq_store_update(env, seq, NULL, seq->lss_need_sync);
-        }
+               /* update ondisk seq with new *space */
+               rc = seq_store_update(env, seq, NULL, seq->lss_need_sync);
+       }
 
-        LASSERTF(!range_is_exhausted(loset) || range_is_sane(loset),
-                 DRANGE"\n", PRANGE(loset));
+       LASSERTF(!lu_seq_range_is_exhausted(loset) ||
+                lu_seq_range_is_sane(loset),
+                DRANGE"\n", PRANGE(loset));
 
-        if (rc == 0)
-                range_alloc(out, loset, seq->lss_width);
+       if (rc == 0)
+               range_alloc(out, loset, seq->lss_width);
 
-        RETURN(rc);
+       RETURN(rc);
 }
 
-static int __seq_server_alloc_meta(struct lu_server_seq *seq,
-                                   struct lu_seq_range *out,
-                                   const struct lu_env *env)
+/**
+ * Check if the sequence server has sequence avaible
+ *
+ * Check if the sequence server has sequence avaible, if not, then
+ * allocating super sequence from sequence manager (MDT0).
+ *
+ * \param[in] env      execution environment
+ * \param[in] seq      server sequence
+ *
+ * \retval             negative errno if allocating new sequence fails
+ * \retval             0 if there is enough sequence or allocating
+ *                      new sequence succeeds
+ */
+int seq_server_check_and_alloc_super(const struct lu_env *env,
+                                    struct lu_server_seq *seq)
 {
        struct lu_seq_range *space = &seq->lss_space;
        int rc = 0;
 
        ENTRY;
 
-       LASSERT(range_is_sane(space));
-
        /* Check if available space ends and allocate new super seq */
-       if (range_is_exhausted(space)) {
+       if (lu_seq_range_is_exhausted(space)) {
                if (!seq->lss_cli) {
                        CERROR("%s: No sequence controller is attached.\n",
                               seq->lss_name);
@@ -247,50 +283,94 @@ static int __seq_server_alloc_meta(struct lu_server_seq *seq,
 
                rc = seq_client_alloc_super(seq->lss_cli, env);
                if (rc) {
-                       CERROR("%s: Can't allocate super-sequence, rc %d\n",
+                       CDEBUG(D_HA,
+                              "%s: Can't allocate super-sequence: rc = %d\n",
                               seq->lss_name, rc);
                        RETURN(rc);
                }
 
                /* Saving new range to allocation space. */
                *space = seq->lss_cli->lcs_space;
-               LASSERT(range_is_sane(space));
+               LASSERT(lu_seq_range_is_sane(space));
+               if (!seq->lss_cli->lcs_srv) {
+                       struct lu_server_fld *fld;
+
+                       /* Insert it to the local FLDB */
+                       fld = seq->lss_site->ss_server_fld;
+                       mutex_lock(&fld->lsf_lock);
+                       rc = fld_insert_entry(env, fld, space);
+                       mutex_unlock(&fld->lsf_lock);
+               }
+       }
+
+       if (lu_seq_range_is_zero(&seq->lss_lowater_set))
+               __seq_set_init(env, seq);
+
+       RETURN(rc);
+}
+EXPORT_SYMBOL(seq_server_check_and_alloc_super);
+
+static int __seq_server_alloc_meta(struct lu_server_seq *seq,
+                                  struct lu_seq_range *out,
+                                  const struct lu_env *env)
+{
+       struct lu_seq_range *space = &seq->lss_space;
+       int rc = 0;
+
+       ENTRY;
+
+       LASSERT(lu_seq_range_is_sane(space));
+
+       rc = seq_server_check_and_alloc_super(env, seq);
+       if (rc < 0) {
+               if (rc == -EINPROGRESS) {
+                       static int printed;
+
+                       if (printed++ % 8 == 0)
+                               LCONSOLE_INFO("%s: Waiting to contact MDT0000 to allocate super-sequence: rc = %d\n",
+                                             seq->lss_name, rc);
+               } else {
+                       CERROR("%s: Allocated super-sequence failed: rc = %d\n",
+                              seq->lss_name, rc);
+               }
+               RETURN(rc);
        }
 
        rc = range_alloc_set(env, out, seq);
        if (rc != 0) {
                CERROR("%s: Allocated meta-sequence failed: rc = %d\n",
-                       seq->lss_name, rc);
+                      seq->lss_name, rc);
                RETURN(rc);
        }
 
        CDEBUG(D_INFO, "%s: Allocated meta-sequence " DRANGE"\n",
-               seq->lss_name, PRANGE(out));
+              seq->lss_name, PRANGE(out));
 
        RETURN(rc);
 }
 
 int seq_server_alloc_meta(struct lu_server_seq *seq,
-                          struct lu_seq_range *out,
-                          const struct lu_env *env)
+                         struct lu_seq_range *out,
+                         const struct lu_env *env)
 {
-        int rc;
-        ENTRY;
+       int rc;
+       ENTRY;
 
        mutex_lock(&seq->lss_mutex);
-        rc = __seq_server_alloc_meta(seq, out, env);
+       rc = __seq_server_alloc_meta(seq, out, env);
        mutex_unlock(&seq->lss_mutex);
 
-        RETURN(rc);
+       RETURN(rc);
 }
 EXPORT_SYMBOL(seq_server_alloc_meta);
 
 static int seq_server_handle(struct lu_site *site,
-                             const struct lu_env *env,
-                             __u32 opc, struct lu_seq_range *out)
+                            const struct lu_env *env,
+                            __u32 opc, struct lu_seq_range *out)
 {
        int rc;
        struct seq_server_site *ss_site;
+       struct dt_device *dev;
        ENTRY;
 
        ss_site = lu_site2seq(site);
@@ -298,18 +378,30 @@ static int seq_server_handle(struct lu_site *site,
        switch (opc) {
        case SEQ_ALLOC_META:
                if (!ss_site->ss_server_seq) {
-                       CERROR("Sequence server is not "
-                              "initialized\n");
-                       RETURN(-EINVAL);
+                       rc = -EINVAL;
+                       CERROR("Sequence server is not initialized: rc = %d\n",
+                              rc);
+                       RETURN(rc);
                }
+
+               dev = lu2dt_dev(ss_site->ss_server_seq->lss_obj->do_lu.lo_dev);
+               if (dev->dd_rdonly)
+                       RETURN(-EROFS);
+
                rc = seq_server_alloc_meta(ss_site->ss_server_seq, out, env);
                break;
        case SEQ_ALLOC_SUPER:
                if (!ss_site->ss_control_seq) {
-                       CERROR("Sequence controller is not "
-                              "initialized\n");
-                       RETURN(-EINVAL);
+                       rc = -EINVAL;
+                       CERROR("Sequence controller is not initialized: rc = %d\n",
+                              rc);
+                       RETURN(rc);
                }
+
+               dev = lu2dt_dev(ss_site->ss_control_seq->lss_obj->do_lu.lo_dev);
+               if (dev->dd_rdonly)
+                       RETURN(-EROFS);
+
                rc = seq_server_alloc_super(ss_site->ss_control_seq, out, env);
                break;
        default:
@@ -334,16 +426,17 @@ static int seq_handler(struct tgt_session_info *tsi)
        LASSERT(site != NULL);
 
        opc = req_capsule_client_get(tsi->tsi_pill, &RMF_SEQ_OPC);
-       if (opc != NULL) {
+       if (opc) {
                out = req_capsule_server_get(tsi->tsi_pill, &RMF_SEQ_RANGE);
-               if (out == NULL)
+               if (!out)
                        RETURN(err_serious(-EPROTO));
 
                tmp = req_capsule_client_get(tsi->tsi_pill, &RMF_SEQ_RANGE);
 
-               /* seq client passed mdt id, we need to pass that using out
-                * range parameter */
-
+               /*
+                * seq client passed mdt id, we need to pass that using out
+                * range parameter
+                */
                out->lsr_index = tmp->lsr_index;
                out->lsr_flags = tmp->lsr_flags;
                rc = seq_server_handle(site, tsi->tsi_env, *opc, out);
@@ -355,7 +448,7 @@ static int seq_handler(struct tgt_session_info *tsi)
 }
 
 struct tgt_handler seq_handlers[] = {
-TGT_SEQ_HDL(HABEO_REFERO,      SEQ_QUERY,      seq_handler),
+TGT_SEQ_HDL(HAS_REPLY, SEQ_QUERY,      seq_handler),
 };
 EXPORT_SYMBOL(seq_handlers);
 
@@ -365,147 +458,128 @@ LU_KEY_INIT_FINI(seq, struct seq_thread_info);
 /* context key: seq_thread_key */
 LU_CONTEXT_KEY_DEFINE(seq, LCT_MD_THREAD | LCT_DT_THREAD);
 
-static int seq_server_proc_init(struct lu_server_seq *seq)
+static void seq_server_debugfs_fini(struct lu_server_seq *seq)
 {
-#ifdef LPROCFS
-
-        int rc;
-        ENTRY;
-
-        seq->lss_proc_dir = lprocfs_register(seq->lss_name,
-                                             seq_type_proc_dir,
-                                             NULL, NULL);
-        if (IS_ERR(seq->lss_proc_dir)) {
-                rc = PTR_ERR(seq->lss_proc_dir);
-                RETURN(rc);
-        }
-
-        rc = lprocfs_add_vars(seq->lss_proc_dir,
-                              seq_server_proc_list, seq);
-        if (rc) {
-                CERROR("%s: Can't init sequence manager "
-                       "proc, rc %d\n", seq->lss_name, rc);
-                GOTO(out_cleanup, rc);
-        }
-
-        RETURN(0);
-
-out_cleanup:
-        seq_server_proc_fini(seq);
-        return rc;
-#else /* LPROCFS */
-       return 0;
-#endif
+       debugfs_remove_recursive(seq->lss_debugfs_entry);
 }
 
-static void seq_server_proc_fini(struct lu_server_seq *seq)
+static void seq_server_debugfs_init(struct lu_server_seq *seq)
 {
-#ifdef LPROCFS
-        ENTRY;
-        if (seq->lss_proc_dir != NULL) {
-                if (!IS_ERR(seq->lss_proc_dir))
-                        lprocfs_remove(&seq->lss_proc_dir);
-                seq->lss_proc_dir = NULL;
-        }
-        EXIT;
-#endif /* LPROCFS */
+       ENTRY;
+
+       seq->lss_debugfs_entry = debugfs_create_dir(seq->lss_name,
+                                                   seq_debugfs_dir);
+
+       ldebugfs_add_vars(seq->lss_debugfs_entry,
+                         seq_server_debugfs_list, seq);
+
+       if (seq->lss_type == LUSTRE_SEQ_CONTROLLER)
+               debugfs_create_file("fldb", 0644, seq->lss_debugfs_entry,
+                                   seq, &seq_fld_debugfs_seq_fops);
 }
 
-int seq_server_init(struct lu_server_seq *seq,
+int seq_server_init(const struct lu_env *env,
+                   struct lu_server_seq *seq,
                    struct dt_device *dev,
                    const char *prefix,
                    enum lu_mgr_type type,
-                   struct seq_server_site *ss,
-                   const struct lu_env *env)
+                   struct seq_server_site *ss)
 {
-        int rc, is_srv = (type == LUSTRE_SEQ_SERVER);
-        ENTRY;
+       int rc, is_srv = (type == LUSTRE_SEQ_SERVER);
+       ENTRY;
 
-        LASSERT(dev != NULL);
-        LASSERT(prefix != NULL);
+       LASSERT(dev != NULL);
+       LASSERT(prefix != NULL);
        LASSERT(ss != NULL);
        LASSERT(ss->ss_lu != NULL);
 
+       /*
+        * Check all lu_fid fields are converted in fid_cpu_to_le() and friends
+        * and that there is no padding added by compiler to the struct.
+        */
+       {
+               struct lu_fid tst;
+
+               BUILD_BUG_ON(sizeof(tst) != sizeof(tst.f_seq) +
+                            sizeof(tst.f_oid) + sizeof(tst.f_ver));
+       }
+
        seq->lss_cli = NULL;
        seq->lss_type = type;
        seq->lss_site = ss;
-       range_init(&seq->lss_space);
+       lu_seq_range_init(&seq->lss_space);
 
-        range_init(&seq->lss_lowater_set);
-        range_init(&seq->lss_hiwater_set);
-        seq->lss_set_width = LUSTRE_SEQ_BATCH_WIDTH;
+       lu_seq_range_init(&seq->lss_lowater_set);
+       lu_seq_range_init(&seq->lss_hiwater_set);
+       seq->lss_set_width = LUSTRE_SEQ_BATCH_WIDTH;
 
        mutex_init(&seq->lss_mutex);
 
-        seq->lss_width = is_srv ?
-                LUSTRE_SEQ_META_WIDTH : LUSTRE_SEQ_SUPER_WIDTH;
+       seq->lss_width = is_srv ?
+               LUSTRE_SEQ_META_WIDTH : LUSTRE_SEQ_SUPER_WIDTH;
 
-        snprintf(seq->lss_name, sizeof(seq->lss_name),
-                 "%s-%s", (is_srv ? "srv" : "ctl"), prefix);
+       snprintf(seq->lss_name, sizeof(seq->lss_name),
+                "%s-%s", (is_srv ? "srv" : "ctl"), prefix);
 
-        rc = seq_store_init(seq, env, dev);
-        if (rc)
-                GOTO(out, rc);
-        /* Request backing store for saved sequence info. */
-        rc = seq_store_read(seq, env);
-        if (rc == -ENODATA) {
+       rc = seq_store_init(seq, env, dev);
+       if (rc)
+               GOTO(out, rc);
+       /* Request backing store for saved sequence info. */
+       rc = seq_store_read(seq, env);
+       if (rc == -ENODATA) {
 
-                /* Nothing is read, init by default value. */
-                seq->lss_space = is_srv ?
-                        LUSTRE_SEQ_ZERO_RANGE:
-                        LUSTRE_SEQ_SPACE_RANGE;
+               /* Nothing is read, init by default value. */
+               seq->lss_space = is_srv ?
+                       LUSTRE_SEQ_ZERO_RANGE :
+                       LUSTRE_SEQ_SPACE_RANGE;
 
-               LASSERT(ss != NULL);
                seq->lss_space.lsr_index = ss->ss_node_id;
-               LCONSOLE_INFO("%s: No data found "
-                             "on store. Initialize space\n",
+               LCONSOLE_INFO("%s: No data found on store. Initialize space.\n",
                              seq->lss_name);
 
-                rc = seq_store_update(env, seq, NULL, 0);
-                if (rc) {
-                        CERROR("%s: Can't write space data, "
-                               "rc %d\n", seq->lss_name, rc);
-                }
-        } else if (rc) {
-                CERROR("%s: Can't read space data, rc %d\n",
-                       seq->lss_name, rc);
-                GOTO(out, rc);
-        }
-
-        if (is_srv) {
-                LASSERT(range_is_sane(&seq->lss_space));
-        } else {
-                LASSERT(!range_is_zero(&seq->lss_space) &&
-                        range_is_sane(&seq->lss_space));
-        }
-
-        rc  = seq_server_proc_init(seq);
-        if (rc)
-                GOTO(out, rc);
-
-        EXIT;
+               rc = seq_store_update(env, seq, NULL, 0);
+               if (rc) {
+                       CERROR("%s: Can't write space data: rc = %d\n",
+                              seq->lss_name, rc);
+               }
+       } else if (rc) {
+               CERROR("%s: Can't read space data: rc = %d\n",
+                      seq->lss_name, rc);
+               GOTO(out, rc);
+       }
+
+       if (is_srv) {
+               LASSERT(lu_seq_range_is_sane(&seq->lss_space));
+       } else {
+               LASSERT(!lu_seq_range_is_zero(&seq->lss_space) &&
+                       lu_seq_range_is_sane(&seq->lss_space));
+       }
+
+       seq_server_debugfs_init(seq);
+
+       EXIT;
 out:
-        if (rc)
-                seq_server_fini(seq, env);
-        return rc;
+       if (rc)
+               seq_server_fini(seq, env);
+       return rc;
 }
 EXPORT_SYMBOL(seq_server_init);
 
 void seq_server_fini(struct lu_server_seq *seq,
-                     const struct lu_env *env)
+                    const struct lu_env *env)
 {
-        ENTRY;
+       ENTRY;
 
-        seq_server_proc_fini(seq);
-        seq_store_fini(seq, env);
+       seq_server_debugfs_fini(seq);
+       seq_store_fini(seq, env);
 
-        EXIT;
+       EXIT;
 }
 EXPORT_SYMBOL(seq_server_fini);
 
 int seq_site_fini(const struct lu_env *env, struct seq_server_site *ss)
 {
-       if (ss == NULL)
+       if (!ss)
                RETURN(0);
 
        if (ss->ss_server_seq) {