Whamcloud - gitweb
LU-3319 procfs: move osp proc handling to seq_files 29/8029/7
authorJames Simmons <uja.ornl@gmail.com>
Fri, 3 Jan 2014 15:16:08 +0000 (10:16 -0500)
committerOleg Drokin <oleg.drokin@intel.com>
Sat, 18 Jan 2014 05:48:40 +0000 (05:48 +0000)
With 3.10 linux kernel and above proc handling now only
uses struct seq_files. This patch migrates the osp
layer proc entries over to using seq_files.

Signed-off-by: James Simmons <uja.ornl@gmail.com>
Change-Id: If58826e11524a5fffd2e491c1386e3795015bc7e
Reviewed-on: http://review.whamcloud.com/8029
Tested-by: Jenkins
Tested-by: Maloo <hpdd-maloo@intel.com>
Reviewed-by: Yang Sheng <yang.sheng@intel.com>
Reviewed-by: Bob Glossman <bob.glossman@intel.com>
Reviewed-by: Oleg Drokin <oleg.drokin@intel.com>
lustre/osp/lproc_osp.c
lustre/osp/lwp_dev.c
lustre/osp/osp_dev.c
lustre/osp/osp_internal.h

index 75ebeb1..4565f9f 100644 (file)
 #include "osp_internal.h"
 
 #ifdef LPROCFS
 #include "osp_internal.h"
 
 #ifdef LPROCFS
-static int osp_rd_active(char *page, char **start, off_t off,
-                        int count, int *eof, void *data)
+static int osp_active_seq_show(struct seq_file *m, void *data)
 {
 {
-       struct obd_device       *dev = data;
+       struct obd_device       *dev = m->private;
        int                      rc;
 
        LPROCFS_CLIMP_CHECK(dev);
        int                      rc;
 
        LPROCFS_CLIMP_CHECK(dev);
-       rc = snprintf(page, count, "%d\n",
-                     !dev->u.cli.cl_import->imp_deactive);
+       rc = seq_printf(m, "%d\n", !dev->u.cli.cl_import->imp_deactive);
        LPROCFS_CLIMP_EXIT(dev);
        return rc;
 }
 
        LPROCFS_CLIMP_EXIT(dev);
        return rc;
 }
 
-static int osp_wr_active(struct file *file, const char *buffer,
-                        unsigned long count, void *data)
+static ssize_t
+osp_active_seq_write(struct file *file, const char *buffer,
+                       size_t count, loff_t *off)
 {
 {
-       struct obd_device       *dev = data;
-       int                      val, rc;
+       struct obd_device *dev = ((struct seq_file *)file->private_data)->private;
+       int                val, rc;
 
        rc = lprocfs_write_helper(buffer, count, &val);
        if (rc)
 
        rc = lprocfs_write_helper(buffer, count, &val);
        if (rc)
@@ -81,67 +80,60 @@ static int osp_wr_active(struct file *file, const char *buffer,
        LPROCFS_CLIMP_EXIT(dev);
        return count;
 }
        LPROCFS_CLIMP_EXIT(dev);
        return count;
 }
+LPROC_SEQ_FOPS(osp_active);
 
 
-static int osp_rd_syn_in_flight(char *page, char **start, off_t off,
-                               int count, int *eof, void *data)
+static int osp_syn_in_flight_seq_show(struct seq_file *m, void *data)
 {
 {
-       struct obd_device       *dev = data;
+       struct obd_device       *dev = m->private;
        struct osp_device       *osp = lu2osp_dev(dev->obd_lu_dev);
        struct osp_device       *osp = lu2osp_dev(dev->obd_lu_dev);
-       int                      rc;
 
        if (osp == NULL)
                return -EINVAL;
 
 
        if (osp == NULL)
                return -EINVAL;
 
-       rc = snprintf(page, count, "%u\n", osp->opd_syn_rpc_in_flight);
-       return rc;
+       return seq_printf(m, "%u\n", osp->opd_syn_rpc_in_flight);
 }
 }
+LPROC_SEQ_FOPS_RO(osp_syn_in_flight);
 
 
-static int osp_rd_syn_in_prog(char *page, char **start, off_t off, int count,
-                             int *eof, void *data)
+static int osp_syn_in_prog_seq_show(struct seq_file *m, void *data)
 {
 {
-       struct obd_device       *dev = data;
+       struct obd_device       *dev = m->private;
        struct osp_device       *osp = lu2osp_dev(dev->obd_lu_dev);
        struct osp_device       *osp = lu2osp_dev(dev->obd_lu_dev);
-       int                      rc;
 
        if (osp == NULL)
                return -EINVAL;
 
 
        if (osp == NULL)
                return -EINVAL;
 
-       rc = snprintf(page, count, "%u\n", osp->opd_syn_rpc_in_progress);
-       return rc;
+       return seq_printf(m, "%u\n", osp->opd_syn_rpc_in_progress);
 }
 }
+LPROC_SEQ_FOPS_RO(osp_syn_in_prog);
 
 
-static int osp_rd_syn_changes(char *page, char **start, off_t off,
-                             int count, int *eof, void *data)
+static int osp_syn_changes_seq_show(struct seq_file *m, void *data)
 {
 {
-       struct obd_device       *dev = data;
+       struct obd_device       *dev = m->private;
        struct osp_device       *osp = lu2osp_dev(dev->obd_lu_dev);
        struct osp_device       *osp = lu2osp_dev(dev->obd_lu_dev);
-       int                      rc;
 
        if (osp == NULL)
                return -EINVAL;
 
 
        if (osp == NULL)
                return -EINVAL;
 
-       rc = snprintf(page, count, "%lu\n", osp->opd_syn_changes);
-       return rc;
+       return seq_printf(m, "%lu\n", osp->opd_syn_changes);
 }
 }
+LPROC_SEQ_FOPS_RO(osp_syn_changes);
 
 
-static int osp_rd_max_rpcs_in_flight(char *page, char **start, off_t off,
-                                    int count, int *eof, void *data)
+static int osp_max_rpcs_in_flight_seq_show(struct seq_file *m, void *data)
 {
 {
-       struct obd_device       *dev = data;
+       struct obd_device       *dev = m->private;
        struct osp_device       *osp = lu2osp_dev(dev->obd_lu_dev);
        struct osp_device       *osp = lu2osp_dev(dev->obd_lu_dev);
-       int                      rc;
 
        if (osp == NULL)
                return -EINVAL;
 
 
        if (osp == NULL)
                return -EINVAL;
 
-       rc = snprintf(page, count, "%u\n", osp->opd_syn_max_rpc_in_flight);
-       return rc;
+       return seq_printf(m, "%u\n", osp->opd_syn_max_rpc_in_flight);
 }
 
 }
 
-static int osp_wr_max_rpcs_in_flight(struct file *file, const char *buffer,
-                                    unsigned long count, void *data)
+static ssize_t
+osp_max_rpcs_in_flight_seq_write(struct file *file, const char *buffer,
+                               size_t count, loff_t *off)
 {
 {
-       struct obd_device       *dev = data;
+       struct obd_device       *dev = ((struct seq_file *)file->private_data)->private;
        struct osp_device       *osp = lu2osp_dev(dev->obd_lu_dev);
        int                      val, rc;
 
        struct osp_device       *osp = lu2osp_dev(dev->obd_lu_dev);
        int                      val, rc;
 
@@ -158,25 +150,24 @@ static int osp_wr_max_rpcs_in_flight(struct file *file, const char *buffer,
        osp->opd_syn_max_rpc_in_flight = val;
        return count;
 }
        osp->opd_syn_max_rpc_in_flight = val;
        return count;
 }
+LPROC_SEQ_FOPS(osp_max_rpcs_in_flight);
 
 
-static int osp_rd_max_rpcs_in_prog(char *page, char **start, off_t off,
-                                  int count, int *eof, void *data)
+static int osp_max_rpcs_in_prog_seq_show(struct seq_file *m, void *data)
 {
 {
-       struct obd_device       *dev = data;
+       struct obd_device       *dev = m->private;
        struct osp_device       *osp = lu2osp_dev(dev->obd_lu_dev);
        struct osp_device       *osp = lu2osp_dev(dev->obd_lu_dev);
-       int                      rc;
 
        if (osp == NULL)
                return -EINVAL;
 
 
        if (osp == NULL)
                return -EINVAL;
 
-       rc = snprintf(page, count, "%u\n", osp->opd_syn_max_rpc_in_progress);
-       return rc;
+       return seq_printf(m, "%u\n", osp->opd_syn_max_rpc_in_progress);
 }
 
 }
 
-static int osp_wr_max_rpcs_in_prog(struct file *file, const char *buffer,
-                                  unsigned long count, void *data)
+static ssize_t
+osp_max_rpcs_in_prog_seq_write(struct file *file, const char *buffer,
+                               size_t count, loff_t *off)
 {
 {
-       struct obd_device       *dev = data;
+       struct obd_device       *dev = ((struct seq_file *)file->private_data)->private;
        struct osp_device       *osp = lu2osp_dev(dev->obd_lu_dev);
        int                      val, rc;
 
        struct osp_device       *osp = lu2osp_dev(dev->obd_lu_dev);
        int                      val, rc;
 
@@ -194,23 +185,24 @@ static int osp_wr_max_rpcs_in_prog(struct file *file, const char *buffer,
 
        return count;
 }
 
        return count;
 }
+LPROC_SEQ_FOPS(osp_max_rpcs_in_prog);
 
 
-static int osp_rd_create_count(char *page, char **start, off_t off, int count,
-                              int *eof, void *data)
+static int osp_create_count_seq_show(struct seq_file *m, void *data)
 {
 {
-       struct obd_device *obd = data;
+       struct obd_device *obd = m->private;
        struct osp_device *osp = lu2osp_dev(obd->obd_lu_dev);
 
        if (osp == NULL || osp->opd_pre == NULL)
                return 0;
 
        struct osp_device *osp = lu2osp_dev(obd->obd_lu_dev);
 
        if (osp == NULL || osp->opd_pre == NULL)
                return 0;
 
-       return snprintf(page, count, "%d\n", osp->opd_pre_grow_count);
+       return seq_printf(m, "%d\n", osp->opd_pre_grow_count);
 }
 
 }
 
-static int osp_wr_create_count(struct file *file, const char *buffer,
-                              unsigned long count, void *data)
+static ssize_t
+osp_create_count_seq_write(struct file *file, const char *buffer,
+                               size_t count, loff_t *off)
 {
 {
-       struct obd_device       *obd = data;
+       struct obd_device       *obd = ((struct seq_file *)file->private_data)->private;
        struct osp_device       *osp = lu2osp_dev(obd->obd_lu_dev);
        int                      val, rc, i;
 
        struct osp_device       *osp = lu2osp_dev(obd->obd_lu_dev);
        int                      val, rc, i;
 
@@ -242,23 +234,24 @@ static int osp_wr_create_count(struct file *file, const char *buffer,
 
        return count;
 }
 
        return count;
 }
+LPROC_SEQ_FOPS(osp_create_count);
 
 
-static int osp_rd_max_create_count(char *page, char **start, off_t off,
-                                  int count, int *eof, void *data)
+static int osp_max_create_count_seq_show(struct seq_file *m, void *data)
 {
 {
-       struct obd_device *obd = data;
+       struct obd_device *obd = m->private;
        struct osp_device *osp = lu2osp_dev(obd->obd_lu_dev);
 
        if (osp == NULL || osp->opd_pre == NULL)
                return 0;
 
        struct osp_device *osp = lu2osp_dev(obd->obd_lu_dev);
 
        if (osp == NULL || osp->opd_pre == NULL)
                return 0;
 
-       return snprintf(page, count, "%d\n", osp->opd_pre_max_grow_count);
+       return seq_printf(m, "%d\n", osp->opd_pre_max_grow_count);
 }
 
 }
 
-static int osp_wr_max_create_count(struct file *file, const char *buffer,
-                                  unsigned long count, void *data)
+static ssize_t
+osp_max_create_count_seq_write(struct file *file, const char *buffer,
+                               size_t count, loff_t *off)
 {
 {
-       struct obd_device       *obd = data;
+       struct obd_device       *obd = ((struct seq_file *)file->private_data)->private;
        struct osp_device       *osp = lu2osp_dev(obd->obd_lu_dev);
        int                      val, rc;
 
        struct osp_device       *osp = lu2osp_dev(obd->obd_lu_dev);
        int                      val, rc;
 
@@ -281,89 +274,85 @@ static int osp_wr_max_create_count(struct file *file, const char *buffer,
 
        return count;
 }
 
        return count;
 }
+LPROC_SEQ_FOPS(osp_max_create_count);
 
 
-static int osp_rd_prealloc_next_id(char *page, char **start, off_t off,
-                                  int count, int *eof, void *data)
+static int osp_prealloc_next_id_seq_show(struct seq_file *m, void *data)
 {
 {
-       struct obd_device *obd = data;
+       struct obd_device *obd = m->private;
        struct osp_device *osp = lu2osp_dev(obd->obd_lu_dev);
 
        if (osp == NULL || osp->opd_pre == NULL)
                return 0;
 
        struct osp_device *osp = lu2osp_dev(obd->obd_lu_dev);
 
        if (osp == NULL || osp->opd_pre == NULL)
                return 0;
 
-       return snprintf(page, count, "%u\n",
-                       fid_oid(&osp->opd_pre_used_fid) + 1);
+       return seq_printf(m, "%u\n", fid_oid(&osp->opd_pre_used_fid) + 1);
 }
 }
+LPROC_SEQ_FOPS_RO(osp_prealloc_next_id);
 
 
-static int osp_rd_prealloc_last_id(char *page, char **start, off_t off,
-                                  int count, int *eof, void *data)
+static int osp_prealloc_last_id_seq_show(struct seq_file *m, void *data)
 {
 {
-       struct obd_device *obd = data;
+       struct obd_device *obd = m->private;
        struct osp_device *osp = lu2osp_dev(obd->obd_lu_dev);
 
        if (osp == NULL || osp->opd_pre == NULL)
                return 0;
 
        struct osp_device *osp = lu2osp_dev(obd->obd_lu_dev);
 
        if (osp == NULL || osp->opd_pre == NULL)
                return 0;
 
-       return snprintf(page, count, "%u\n",
-                       fid_oid(&osp->opd_pre_last_created_fid));
+       return seq_printf(m, "%u\n", fid_oid(&osp->opd_pre_last_created_fid));
 }
 }
+LPROC_SEQ_FOPS_RO(osp_prealloc_last_id);
 
 
-static int osp_rd_prealloc_next_seq(char *page, char **start, off_t off,
-                                   int count, int *eof, void *data)
+static int osp_prealloc_next_seq_seq_show(struct seq_file *m, void *data)
 {
 {
-       struct obd_device *obd = data;
+       struct obd_device *obd = m->private;
        struct osp_device *osp = lu2osp_dev(obd->obd_lu_dev);
 
        if (osp == NULL || osp->opd_pre == NULL)
                return 0;
 
        struct osp_device *osp = lu2osp_dev(obd->obd_lu_dev);
 
        if (osp == NULL || osp->opd_pre == NULL)
                return 0;
 
-       return snprintf(page, count, LPX64"\n",
-                       fid_seq(&osp->opd_pre_used_fid));
+       return seq_printf(m, LPX64"\n", fid_seq(&osp->opd_pre_used_fid));
 }
 }
+LPROC_SEQ_FOPS_RO(osp_prealloc_next_seq);
 
 
-static int osp_rd_prealloc_last_seq(char *page, char **start, off_t off,
-                                   int count, int *eof, void *data)
+static int osp_prealloc_last_seq_seq_show(struct seq_file *m, void *data)
 {
 {
-       struct obd_device *obd = data;
+       struct obd_device *obd = m->private;
        struct osp_device *osp = lu2osp_dev(obd->obd_lu_dev);
 
        if (osp == NULL || osp->opd_pre == NULL)
                return 0;
 
        struct osp_device *osp = lu2osp_dev(obd->obd_lu_dev);
 
        if (osp == NULL || osp->opd_pre == NULL)
                return 0;
 
-       return snprintf(page, count, LPX64"\n",
+       return seq_printf(m, LPX64"\n",
                        fid_seq(&osp->opd_pre_last_created_fid));
 }
                        fid_seq(&osp->opd_pre_last_created_fid));
 }
+LPROC_SEQ_FOPS_RO(osp_prealloc_last_seq);
 
 
-static int osp_rd_prealloc_reserved(char *page, char **start, off_t off,
-                                   int count, int *eof, void *data)
+static int osp_prealloc_reserved_seq_show(struct seq_file *m, void *data)
 {
 {
-       struct obd_device *obd = data;
+       struct obd_device *obd = m->private;
        struct osp_device *osp = lu2osp_dev(obd->obd_lu_dev);
 
        if (osp == NULL || osp->opd_pre == NULL)
                return 0;
 
        struct osp_device *osp = lu2osp_dev(obd->obd_lu_dev);
 
        if (osp == NULL || osp->opd_pre == NULL)
                return 0;
 
-       return snprintf(page, count, LPU64"\n", osp->opd_pre_reserved);
+       return seq_printf(m, LPU64"\n", osp->opd_pre_reserved);
 }
 }
+LPROC_SEQ_FOPS_RO(osp_prealloc_reserved);
 
 
-static int osp_rd_maxage(char *page, char **start, off_t off,
-                        int count, int *eof, void *data)
+static int osp_maxage_seq_show(struct seq_file *m, void *data)
 {
 {
-       struct obd_device       *dev = data;
+       struct obd_device       *dev = m->private;
        struct osp_device       *osp = lu2osp_dev(dev->obd_lu_dev);
        struct osp_device       *osp = lu2osp_dev(dev->obd_lu_dev);
-       int                      rc;
 
        if (osp == NULL)
                return -EINVAL;
 
 
        if (osp == NULL)
                return -EINVAL;
 
-       rc = snprintf(page, count, "%u\n", osp->opd_statfs_maxage);
-       return rc;
+       return seq_printf(m, "%u\n", osp->opd_statfs_maxage);
 }
 
 }
 
-static int osp_wr_maxage(struct file *file, const char *buffer,
-                        unsigned long count, void *data)
+static ssize_t
+osp_maxage_seq_write(struct file *file, const char *buffer,
+                       size_t count, loff_t *off)
 {
 {
-       struct obd_device       *dev = data;
+       struct obd_device       *dev = ((struct seq_file *)file->private_data)->private;
        struct osp_device       *osp = lu2osp_dev(dev->obd_lu_dev);
        int                      val, rc;
 
        struct osp_device       *osp = lu2osp_dev(dev->obd_lu_dev);
        int                      val, rc;
 
@@ -381,25 +370,23 @@ static int osp_wr_maxage(struct file *file, const char *buffer,
 
        return count;
 }
 
        return count;
 }
+LPROC_SEQ_FOPS(osp_maxage);
 
 
-static int osp_rd_pre_status(char *page, char **start, off_t off,
-                            int count, int *eof, void *data)
+static int osp_pre_status_seq_show(struct seq_file *m, void *data)
 {
 {
-       struct obd_device       *dev = data;
+       struct obd_device       *dev = m->private;
        struct osp_device       *osp = lu2osp_dev(dev->obd_lu_dev);
        struct osp_device       *osp = lu2osp_dev(dev->obd_lu_dev);
-       int                      rc;
 
        if (osp == NULL || osp->opd_pre == NULL)
                return -EINVAL;
 
 
        if (osp == NULL || osp->opd_pre == NULL)
                return -EINVAL;
 
-       rc = snprintf(page, count, "%d\n", osp->opd_pre_status);
-       return rc;
+       return seq_printf(m, "%d\n", osp->opd_pre_status);
 }
 }
+LPROC_SEQ_FOPS_RO(osp_pre_status);
 
 
-static int osp_rd_destroys_in_flight(char *page, char **start, off_t off,
-                                    int count, int *eof, void *data)
+static int osp_destroys_in_flight_seq_show(struct seq_file *m, void *data)
 {
 {
-       struct obd_device *dev = data;
+       struct obd_device *dev = m->private;
        struct osp_device *osp = lu2osp_dev(dev->obd_lu_dev);
 
        if (osp == NULL)
        struct osp_device *osp = lu2osp_dev(dev->obd_lu_dev);
 
        if (osp == NULL)
@@ -411,87 +398,126 @@ static int osp_rd_destroys_in_flight(char *page, char **start, off_t off,
         * - sync changes are zero - no llog records
         * - sync in progress are zero - no RPCs in flight
         */
         * - sync changes are zero - no llog records
         * - sync in progress are zero - no RPCs in flight
         */
-       return snprintf(page, count, "%lu\n",
+       return seq_printf(m, "%lu\n",
                        osp->opd_syn_rpc_in_progress + osp->opd_syn_changes);
 }
                        osp->opd_syn_rpc_in_progress + osp->opd_syn_changes);
 }
+LPROC_SEQ_FOPS_RO(osp_destroys_in_flight);
 
 
-static int osp_rd_old_sync_processed(char *page, char **start, off_t off,
-                                    int count, int *eof, void *data)
+static int osp_old_sync_processed_seq_show(struct seq_file *m, void *data)
 {
 {
-       struct obd_device       *dev = data;
+       struct obd_device       *dev = m->private;
        struct osp_device       *osp = lu2osp_dev(dev->obd_lu_dev);
        struct osp_device       *osp = lu2osp_dev(dev->obd_lu_dev);
-       int                      rc;
 
        if (osp == NULL)
                return -EINVAL;
 
 
        if (osp == NULL)
                return -EINVAL;
 
-       rc = snprintf(page, count, "%d\n", osp->opd_syn_prev_done);
-       return rc;
+       return seq_printf(m, "%d\n", osp->opd_syn_prev_done);
 }
 }
+LPROC_SEQ_FOPS_RO(osp_old_sync_processed);
 
 
-static struct lprocfs_vars lprocfs_osp_obd_vars[] = {
-       { "uuid",               lprocfs_rd_uuid, 0, 0 },
-       { "ping",               0, lprocfs_wr_ping, 0, 0, 0222 },
-       { "connect_flags",      lprocfs_rd_connect_flags, 0, 0 },
-       { "ost_server_uuid",    lprocfs_rd_server_uuid, 0, 0 },
-       { "ost_conn_uuid",      lprocfs_rd_conn_uuid, 0, 0 },
-       { "active",             osp_rd_active, osp_wr_active, 0 },
-       { "max_rpcs_in_flight", osp_rd_max_rpcs_in_flight,
-                               osp_wr_max_rpcs_in_flight, 0 },
-       { "max_rpcs_in_progress", osp_rd_max_rpcs_in_prog,
-                                 osp_wr_max_rpcs_in_prog, 0 },
-       { "create_count",       osp_rd_create_count,
-                               osp_wr_create_count, 0 },
-       { "max_create_count",   osp_rd_max_create_count,
-                               osp_wr_max_create_count, 0 },
-       { "prealloc_next_id",   osp_rd_prealloc_next_id, 0, 0 },
-       { "prealloc_next_seq",  osp_rd_prealloc_next_seq, 0, 0 },
-       { "prealloc_last_id",   osp_rd_prealloc_last_id,  0, 0 },
-       { "prealloc_last_seq",  osp_rd_prealloc_last_seq, 0, 0 },
-       { "prealloc_reserved",  osp_rd_prealloc_reserved, 0, 0 },
-       { "timeouts",           lprocfs_rd_timeouts, 0, 0 },
-       { "import",             lprocfs_rd_import, lprocfs_wr_import, 0 },
-       { "state",              lprocfs_rd_state, 0, 0 },
-       { "maxage",             osp_rd_maxage, osp_wr_maxage, 0 },
-       { "prealloc_status",    osp_rd_pre_status, 0, 0 },
-       { "sync_changes",       osp_rd_syn_changes, 0, 0 },
-       { "sync_in_flight",     osp_rd_syn_in_flight, 0, 0 },
-       { "sync_in_progress",   osp_rd_syn_in_prog, 0, 0 },
-       { "old_sync_processed", osp_rd_old_sync_processed, 0, 0 },
+LPROC_SEQ_FOPS_WO_TYPE(osp, ping);
+LPROC_SEQ_FOPS_RO_TYPE(osp, uuid);
+LPROC_SEQ_FOPS_RO_TYPE(osp, connect_flags);
+LPROC_SEQ_FOPS_RO_TYPE(osp, server_uuid);
+LPROC_SEQ_FOPS_RO_TYPE(osp, conn_uuid);
 
 
-       /* for compatibility reasons */
-       { "destroys_in_flight", osp_rd_destroys_in_flight, 0, 0 },
-       { 0 }
-};
+static int osp_max_pages_per_rpc_seq_show(struct seq_file *m, void *v)
+{
+       return lprocfs_obd_max_pages_per_rpc_seq_show(m, m->private);
+}
+LPROC_SEQ_FOPS_RO(osp_max_pages_per_rpc);
+LPROC_SEQ_FOPS_RO_TYPE(osp, timeouts);
+
+LPROC_SEQ_FOPS_RW_TYPE(osp, import);
+LPROC_SEQ_FOPS_RO_TYPE(osp, state);
+
+static struct lprocfs_seq_vars lprocfs_osp_obd_vars[] = {
+       { .name =       "uuid",
+         .fops =       &osp_uuid_fops                  },
+       { .name =       "ping",
+         .fops =       &osp_ping_fops,
+         .proc_mode =  0222                            },
+       { .name =       "connect_flags",
+         .fops =       &osp_connect_flags_fops         },
+       { .name =       "ost_server_uuid",
+         .fops =       &osp_server_uuid_fops           },
+       { .name =       "ost_conn_uuid",
+         .fops =       &osp_conn_uuid_fops             },
+       { .name =       "active",
+         .fops =       &osp_active_fops                },
+       { .name =       "max_rpcs_in_flight",
+         .fops =       &osp_max_rpcs_in_flight_fops    },
+       { .name =       "max_rpcs_in_progress",
+         .fops =       &osp_max_rpcs_in_prog_fops      },
+       { .name =       "create_count",
+         .fops =       &osp_create_count_fops          },
+       { .name =       "max_create_count",
+         .fops =       &osp_max_create_count_fops      },
+       { .name =       "prealloc_next_id",
+         .fops =       &osp_prealloc_next_id_fops      },
+       { .name =       "prealloc_next_seq",
+         .fops =       &osp_prealloc_next_seq_fops     },
+       { .name =       "prealloc_last_id",
+         .fops =       &osp_prealloc_last_id_fops      },
+       { .name =       "prealloc_last_seq",
+         .fops =       &osp_prealloc_last_seq_fops     },
+       { .name =       "prealloc_reserved",
+         .fops =       &osp_prealloc_reserved_fops     },
+       { .name =       "timeouts",
+         .fops =       &osp_timeouts_fops              },
+       { .name =       "import",
+         .fops =       &osp_import_fops                },
+       { .name =       "state",
+         .fops =       &osp_state_fops                 },
+       { .name =       "maxage",
+         .fops =       &osp_maxage_fops                },
+       { .name =       "prealloc_status",
+         .fops =       &osp_pre_status_fops            },
+       { .name =       "sync_changes",
+         .fops =       &osp_syn_changes_fops           },
+       { .name =       "sync_in_flight",
+         .fops =       &osp_syn_in_flight_fops         },
+       { .name =       "sync_in_progress",
+         .fops =       &osp_syn_in_prog_fops           },
+       { .name =       "old_sync_processed",
+         .fops =       &osp_old_sync_processed_fops    },
 
 
-static struct lprocfs_vars lprocfs_osp_osd_vars[] = {
-       { "blocksize",          lprocfs_dt_rd_blksize, 0, 0 },
-       { "kbytestotal",        lprocfs_dt_rd_kbytestotal, 0, 0 },
-       { "kbytesfree",         lprocfs_dt_rd_kbytesfree, 0, 0 },
-       { "kbytesavail",        lprocfs_dt_rd_kbytesavail, 0, 0 },
-       { "filestotal",         lprocfs_dt_rd_filestotal, 0, 0 },
-       { "filesfree",          lprocfs_dt_rd_filesfree, 0, 0 },
+       /* for compatibility reasons */
+       { .name =       "destroys_in_flight",
+         .fops =       &osp_destroys_in_flight_fops    },
        { 0 }
 };
 
        { 0 }
 };
 
-static struct lprocfs_vars lprocfs_osp_module_vars[] = {
-       { "num_refs",           lprocfs_rd_numrefs, 0, 0 },
+LPROC_SEQ_FOPS_RO_TYPE(osp, dt_blksize);
+LPROC_SEQ_FOPS_RO_TYPE(osp, dt_kbytestotal);
+LPROC_SEQ_FOPS_RO_TYPE(osp, dt_kbytesfree);
+LPROC_SEQ_FOPS_RO_TYPE(osp, dt_kbytesavail);
+LPROC_SEQ_FOPS_RO_TYPE(osp, dt_filestotal);
+LPROC_SEQ_FOPS_RO_TYPE(osp, dt_filesfree);
+
+static struct lprocfs_seq_vars lprocfs_osp_osd_vars[] = {
+       { .name =       "blocksize",
+         .fops =       &osp_dt_blksize_fops            },
+       { .name =       "kbytestotal",
+         .fops =       &osp_dt_kbytestotal_fops        },
+       { .name =       "kbytesfree",
+         .fops =       &osp_dt_kbytesfree_fops         },
+       { .name =       "kbytesavail",
+         .fops =       &osp_dt_kbytesavail_fops        },
+       { .name =       "filestotal",
+         .fops =       &osp_dt_filestotal_fops         },
+       { .name =       "filesfree",
+         .fops =       &osp_dt_filesfree_fops          },
        { 0 }
 };
 
        { 0 }
 };
 
-void lprocfs_osp_init_vars(struct lprocfs_static_vars *lvars)
-{
-       lvars->module_vars = lprocfs_osp_module_vars;
-       lvars->obd_vars = lprocfs_osp_obd_vars;
-}
-
 void osp_lprocfs_init(struct osp_device *osp)
 {
        struct obd_device       *obd = osp->opd_obd;
        struct proc_dir_entry   *osc_proc_dir;
        int                      rc;
 
 void osp_lprocfs_init(struct osp_device *osp)
 {
        struct obd_device       *obd = osp->opd_obd;
        struct proc_dir_entry   *osc_proc_dir;
        int                      rc;
 
-       obd->obd_proc_entry = lprocfs_register(obd->obd_name,
+       obd->obd_proc_entry = lprocfs_seq_register(obd->obd_name,
                                               obd->obd_type->typ_procroot,
                                               lprocfs_osp_osd_vars,
                                               &osp->opd_dt_dev);
                                               obd->obd_type->typ_procroot,
                                               lprocfs_osp_osd_vars,
                                               &osp->opd_dt_dev);
@@ -502,33 +528,59 @@ void osp_lprocfs_init(struct osp_device *osp)
                return;
        }
 
                return;
        }
 
-       rc = lprocfs_add_vars(obd->obd_proc_entry, lprocfs_osp_obd_vars, obd);
+       rc = lprocfs_seq_add_vars(obd->obd_proc_entry, lprocfs_osp_obd_vars, obd);
        if (rc) {
                CERROR("%s: can't register in lprocfs: %ld\n",
                       obd->obd_name, PTR_ERR(obd->obd_proc_entry));
                return;
        }
        if (rc) {
                CERROR("%s: can't register in lprocfs: %ld\n",
                       obd->obd_name, PTR_ERR(obd->obd_proc_entry));
                return;
        }
+       obd->obd_vars = lprocfs_osp_obd_vars;
 
        ptlrpc_lprocfs_register_obd(obd);
 
 
        ptlrpc_lprocfs_register_obd(obd);
 
+       if (osp->opd_connect_mdt)
+               return;
+
        /* for compatibility we link old procfs's OSC entries to osp ones */
        /* for compatibility we link old procfs's OSC entries to osp ones */
-       if (!osp->opd_connect_mdt) {
-               osc_proc_dir = lprocfs_srch(proc_lustre_root, "osc");
-               if (osc_proc_dir) {
-                       cfs_proc_dir_entry_t    *symlink = NULL;
-                       char                    *name;
-
-                       OBD_ALLOC(name, strlen(obd->obd_name) + 1);
-                       if (name == NULL)
-                               return;
-
-                       strcpy(name, obd->obd_name);
-                       if (strstr(name, "osc"))
-                               symlink = lprocfs_add_symlink(name,
-                                               osc_proc_dir, "../osp/%s",
-                                               obd->obd_name);
+       osc_proc_dir = obd->obd_proc_private;
+       if (osc_proc_dir == NULL) {
+               cfs_proc_dir_entry_t    *symlink = NULL;
+               struct obd_type         *type;
+               char                    *name;
+
+               type = class_search_type(LUSTRE_OSC_NAME);
+               if (type == NULL) {
+                       osc_proc_dir = lprocfs_seq_register("osc",
+                                                       proc_lustre_root,
+                                                       NULL, NULL);
+                       if (IS_ERR(osc_proc_dir)) {
+                               CERROR("osp: can't create compat entry \"osc\": %d\n",
+                                       (int) PTR_ERR(osc_proc_dir));
+                       } else {
+                               obd->obd_proc_private = osc_proc_dir;
+                       }
+               } else {
+                       osc_proc_dir = type->typ_procroot;
+               }
+
+               OBD_ALLOC(name, strlen(obd->obd_name) + 1);
+               if (name == NULL)
+                       return;
+
+               strcpy(name, obd->obd_name);
+               if (strstr(name, "osc")) {
+                       symlink = lprocfs_add_symlink(name, osc_proc_dir,
+                                                       "../osp/%s",
+                                                       obd->obd_name);
                        OBD_FREE(name, strlen(obd->obd_name) + 1);
                        OBD_FREE(name, strlen(obd->obd_name) + 1);
-                       osp->opd_symlink = symlink;
+                       if (symlink == NULL) {
+                               CERROR("could not register OSC symlink for "
+                                       "/proc/fs/lustre/osp/%s.",
+                                       obd->obd_name);
+                               lprocfs_remove(&osc_proc_dir);
+                       } else {
+                               osp->opd_symlink = symlink;
+                       }
                }
        }
 }
                }
        }
 }
index fce82a2..755c096 100644 (file)
@@ -210,25 +210,13 @@ const struct lu_device_operations lwp_lu_ops = {
        .ldo_process_config     = lwp_process_config,
 };
 
        .ldo_process_config     = lwp_process_config,
 };
 
-static struct lprocfs_vars lprocfs_lwp_module_vars[] = {
-       { "num_refs",           lprocfs_rd_numrefs, 0, 0 },
+static struct lprocfs_seq_vars lprocfs_lwp_obd_vars[] = {
        { 0 }
 };
 
        { 0 }
 };
 
-static struct lprocfs_vars lprocfs_lwp_obd_vars[] = {
-       { 0 }
-};
-
-void lprocfs_lwp_init_vars(struct lprocfs_static_vars *lvars)
-{
-       lvars->module_vars = lprocfs_lwp_module_vars;
-       lvars->obd_vars = lprocfs_lwp_obd_vars;
-}
-
 int lwp_init0(const struct lu_env *env, struct lwp_device *lwp,
              struct lu_device_type *ldt, struct lustre_cfg *cfg)
 {
 int lwp_init0(const struct lu_env *env, struct lwp_device *lwp,
              struct lu_device_type *ldt, struct lustre_cfg *cfg)
 {
-       struct lprocfs_static_vars lvars = { 0 };
        int                        rc;
        ENTRY;
 
        int                        rc;
        ENTRY;
 
@@ -257,8 +245,8 @@ int lwp_init0(const struct lu_env *env, struct lwp_device *lwp,
                RETURN(rc);
        }
 
                RETURN(rc);
        }
 
-       lprocfs_lwp_init_vars(&lvars);
-       if (lprocfs_obd_setup(lwp->lpd_obd, lvars.obd_vars) == 0)
+       lwp->lpd_obd->obd_vars = lprocfs_lwp_obd_vars;
+       if (lprocfs_seq_obd_setup(lwp->lpd_obd) == 0)
                ptlrpc_lprocfs_register_obd(lwp->lpd_obd);
 
        RETURN(0);
                ptlrpc_lprocfs_register_obd(lwp->lpd_obd);
 
        RETURN(0);
index d246678..e41133f 100644 (file)
@@ -371,7 +371,7 @@ static int osp_process_config(const struct lu_env *env,
                              struct lu_device *dev, struct lustre_cfg *lcfg)
 {
        struct osp_device               *d = lu2osp_dev(dev);
                              struct lu_device *dev, struct lustre_cfg *lcfg)
 {
        struct osp_device               *d = lu2osp_dev(dev);
-       struct lprocfs_static_vars       lvars = { 0 };
+       struct obd_device               *obd = d->opd_obd;
        int                              rc;
 
        ENTRY;
        int                              rc;
 
        ENTRY;
@@ -385,11 +385,9 @@ static int osp_process_config(const struct lu_env *env,
                rc = osp_shutdown(env, d);
                break;
        case LCFG_PARAM:
                rc = osp_shutdown(env, d);
                break;
        case LCFG_PARAM:
-               lprocfs_osp_init_vars(&lvars);
-
-               LASSERT(d->opd_obd);
-               rc = class_process_proc_param(PARAM_OSC, lvars.obd_vars,
-                                             lcfg, d->opd_obd);
+               LASSERT(obd);
+               rc = class_process_proc_seq_param(PARAM_OSC, obd->obd_vars,
+                                                 lcfg, obd);
                if (rc > 0)
                        rc = 0;
                if (rc == -ENOSYS) {
                if (rc > 0)
                        rc = 0;
                if (rc == -ENOSYS) {
@@ -842,6 +840,9 @@ static struct lu_device *osp_device_fini(const struct lu_env *env,
                        OBD_FREE_PTR(cli->cl_rpc_lock);
                        cli->cl_rpc_lock = NULL;
                }
                        OBD_FREE_PTR(cli->cl_rpc_lock);
                        cli->cl_rpc_lock = NULL;
                }
+       } else {
+               if (m->opd_obd->obd_proc_private != NULL)
+                       lprocfs_remove((struct proc_dir_entry **)&m->opd_obd->obd_proc_private);
        }
 
        rc = client_obd_cleanup(m->opd_obd);
        }
 
        rc = client_obd_cleanup(m->opd_obd);
@@ -1235,33 +1236,25 @@ struct llog_operations osp_mds_ost_orig_logops;
 
 static int __init osp_mod_init(void)
 {
 
 static int __init osp_mod_init(void)
 {
-       struct lprocfs_static_vars       lvars;
-       cfs_proc_dir_entry_t            *osc_proc_dir;
-       int                              rc;
+       int rc;
 
        rc = lu_kmem_init(osp_caches);
        if (rc)
                return rc;
 
 
        rc = lu_kmem_init(osp_caches);
        if (rc)
                return rc;
 
-       lprocfs_osp_init_vars(&lvars);
-
        rc = class_register_type(&osp_obd_device_ops, NULL, NULL,
 #ifndef HAVE_ONLY_PROCFS_SEQ
        rc = class_register_type(&osp_obd_device_ops, NULL, NULL,
 #ifndef HAVE_ONLY_PROCFS_SEQ
-                               lvars.module_vars,
+                               NULL,
 #endif
                                LUSTRE_OSP_NAME, &osp_device_type);
 #endif
                                LUSTRE_OSP_NAME, &osp_device_type);
-
-       /* create "osc" entry in procfs for compatibility purposes */
        if (rc != 0) {
                lu_kmem_fini(osp_caches);
                return rc;
        }
 
        if (rc != 0) {
                lu_kmem_fini(osp_caches);
                return rc;
        }
 
-       lprocfs_lwp_init_vars(&lvars);
-
        rc = class_register_type(&lwp_obd_device_ops, NULL, NULL,
 #ifndef HAVE_ONLY_PROCFS_SEQ
        rc = class_register_type(&lwp_obd_device_ops, NULL, NULL,
 #ifndef HAVE_ONLY_PROCFS_SEQ
-                               lvars.module_vars,
+                               NULL,
 #endif
                                LUSTRE_LWP_NAME, &lwp_device_type);
        if (rc != 0) {
 #endif
                                LUSTRE_LWP_NAME, &lwp_device_type);
        if (rc != 0) {
@@ -1274,22 +1267,11 @@ static int __init osp_mod_init(void)
        osp_mds_ost_orig_logops = llog_osd_ops;
        osp_mds_ost_orig_logops.lop_add = llog_cat_add_rec;
        osp_mds_ost_orig_logops.lop_declare_add = llog_cat_declare_add_rec;
        osp_mds_ost_orig_logops = llog_osd_ops;
        osp_mds_ost_orig_logops.lop_add = llog_cat_add_rec;
        osp_mds_ost_orig_logops.lop_declare_add = llog_cat_declare_add_rec;
-
-       osc_proc_dir = lprocfs_srch(proc_lustre_root, "osc");
-       if (osc_proc_dir == NULL) {
-               osc_proc_dir = lprocfs_register("osc", proc_lustre_root, NULL,
-                                               NULL);
-               if (IS_ERR(osc_proc_dir))
-                       CERROR("osp: can't create compat entry \"osc\": %d\n",
-                              (int) PTR_ERR(osc_proc_dir));
-       }
        return rc;
 }
 
 static void __exit osp_mod_exit(void)
 {
        return rc;
 }
 
 static void __exit osp_mod_exit(void)
 {
-       lprocfs_try_remove_proc_entry("osc", proc_lustre_root);
-
        class_unregister_type(LUSTRE_LWP_NAME);
        class_unregister_type(LUSTRE_OSP_NAME);
        lu_kmem_fini(osp_caches);
        class_unregister_type(LUSTRE_LWP_NAME);
        class_unregister_type(LUSTRE_OSP_NAME);
        lu_kmem_fini(osp_caches);
index 025a249..988ab79 100644 (file)
@@ -434,7 +434,6 @@ int osp_write_last_oid_seq_files(struct lu_env *env, struct osp_device *osp,
 int osp_init_pre_fid(struct osp_device *osp);
 
 /* lproc_osp.c */
 int osp_init_pre_fid(struct osp_device *osp);
 
 /* lproc_osp.c */
-void lprocfs_osp_init_vars(struct lprocfs_static_vars *lvars);
 void osp_lprocfs_init(struct osp_device *osp);
 
 /* osp_sync.c */
 void osp_lprocfs_init(struct osp_device *osp);
 
 /* osp_sync.c */
@@ -448,7 +447,6 @@ int osp_sync_fini(struct osp_device *d);
 void __osp_sync_check_for_work(struct osp_device *d);
 
 /* lwp_dev.c */
 void __osp_sync_check_for_work(struct osp_device *d);
 
 /* lwp_dev.c */
-void lprocfs_lwp_init_vars(struct lprocfs_static_vars *lvars);
 extern struct obd_ops lwp_obd_device_ops;
 extern struct lu_device_type lwp_device_type;
 
 extern struct obd_ops lwp_obd_device_ops;
 extern struct lu_device_type lwp_device_type;