Whamcloud - gitweb
Revert "LU-3319 procfs: move osp proc handling to seq_files" 31/8931/2
authorOleg Drokin <oleg.drokin@intel.com>
Mon, 20 Jan 2014 23:10:06 +0000 (23:10 +0000)
committerOleg Drokin <oleg.drokin@intel.com>
Mon, 20 Jan 2014 23:27:26 +0000 (23:27 +0000)
This seems to be causing issues like LU-45-13 and LU-4510
This reverts commit a97e4898ad9e0b65f457b01bdfa954f7d7cd272d.

Change-Id: I6066a255ded24dbdb76b4804e82a377f1069af5f
Reviewed-on: http://review.whamcloud.com/8931
Reviewed-by: Oleg Drokin <oleg.drokin@intel.com>
Tested-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 4565f9f..75ebeb1 100644 (file)
 #include "osp_internal.h"
 
 #ifdef LPROCFS
-static int osp_active_seq_show(struct seq_file *m, void *data)
+static int osp_rd_active(char *page, char **start, off_t off,
+                        int count, int *eof, void *data)
 {
-       struct obd_device       *dev = m->private;
+       struct obd_device       *dev = data;
        int                      rc;
 
        LPROCFS_CLIMP_CHECK(dev);
-       rc = seq_printf(m, "%d\n", !dev->u.cli.cl_import->imp_deactive);
+       rc = snprintf(page, count, "%d\n",
+                     !dev->u.cli.cl_import->imp_deactive);
        LPROCFS_CLIMP_EXIT(dev);
        return rc;
 }
 
-static ssize_t
-osp_active_seq_write(struct file *file, const char *buffer,
-                       size_t count, loff_t *off)
+static int osp_wr_active(struct file *file, const char *buffer,
+                        unsigned long count, void *data)
 {
-       struct obd_device *dev = ((struct seq_file *)file->private_data)->private;
-       int                val, rc;
+       struct obd_device       *dev = data;
+       int                      val, rc;
 
        rc = lprocfs_write_helper(buffer, count, &val);
        if (rc)
@@ -80,60 +81,67 @@ osp_active_seq_write(struct file *file, const char *buffer,
        LPROCFS_CLIMP_EXIT(dev);
        return count;
 }
-LPROC_SEQ_FOPS(osp_active);
 
-static int osp_syn_in_flight_seq_show(struct seq_file *m, void *data)
+static int osp_rd_syn_in_flight(char *page, char **start, off_t off,
+                               int count, int *eof, void *data)
 {
-       struct obd_device       *dev = m->private;
+       struct obd_device       *dev = data;
        struct osp_device       *osp = lu2osp_dev(dev->obd_lu_dev);
+       int                      rc;
 
        if (osp == NULL)
                return -EINVAL;
 
-       return seq_printf(m, "%u\n", osp->opd_syn_rpc_in_flight);
+       rc = snprintf(page, count, "%u\n", osp->opd_syn_rpc_in_flight);
+       return rc;
 }
-LPROC_SEQ_FOPS_RO(osp_syn_in_flight);
 
-static int osp_syn_in_prog_seq_show(struct seq_file *m, void *data)
+static int osp_rd_syn_in_prog(char *page, char **start, off_t off, int count,
+                             int *eof, void *data)
 {
-       struct obd_device       *dev = m->private;
+       struct obd_device       *dev = data;
        struct osp_device       *osp = lu2osp_dev(dev->obd_lu_dev);
+       int                      rc;
 
        if (osp == NULL)
                return -EINVAL;
 
-       return seq_printf(m, "%u\n", osp->opd_syn_rpc_in_progress);
+       rc = snprintf(page, count, "%u\n", osp->opd_syn_rpc_in_progress);
+       return rc;
 }
-LPROC_SEQ_FOPS_RO(osp_syn_in_prog);
 
-static int osp_syn_changes_seq_show(struct seq_file *m, void *data)
+static int osp_rd_syn_changes(char *page, char **start, off_t off,
+                             int count, int *eof, void *data)
 {
-       struct obd_device       *dev = m->private;
+       struct obd_device       *dev = data;
        struct osp_device       *osp = lu2osp_dev(dev->obd_lu_dev);
+       int                      rc;
 
        if (osp == NULL)
                return -EINVAL;
 
-       return seq_printf(m, "%lu\n", osp->opd_syn_changes);
+       rc = snprintf(page, count, "%lu\n", osp->opd_syn_changes);
+       return rc;
 }
-LPROC_SEQ_FOPS_RO(osp_syn_changes);
 
-static int osp_max_rpcs_in_flight_seq_show(struct seq_file *m, void *data)
+static int osp_rd_max_rpcs_in_flight(char *page, char **start, off_t off,
+                                    int count, int *eof, void *data)
 {
-       struct obd_device       *dev = m->private;
+       struct obd_device       *dev = data;
        struct osp_device       *osp = lu2osp_dev(dev->obd_lu_dev);
+       int                      rc;
 
        if (osp == NULL)
                return -EINVAL;
 
-       return seq_printf(m, "%u\n", osp->opd_syn_max_rpc_in_flight);
+       rc = snprintf(page, count, "%u\n", osp->opd_syn_max_rpc_in_flight);
+       return rc;
 }
 
-static ssize_t
-osp_max_rpcs_in_flight_seq_write(struct file *file, const char *buffer,
-                               size_t count, loff_t *off)
+static int osp_wr_max_rpcs_in_flight(struct file *file, const char *buffer,
+                                    unsigned long count, void *data)
 {
-       struct obd_device       *dev = ((struct seq_file *)file->private_data)->private;
+       struct obd_device       *dev = data;
        struct osp_device       *osp = lu2osp_dev(dev->obd_lu_dev);
        int                      val, rc;
 
@@ -150,24 +158,25 @@ osp_max_rpcs_in_flight_seq_write(struct file *file, const char *buffer,
        osp->opd_syn_max_rpc_in_flight = val;
        return count;
 }
-LPROC_SEQ_FOPS(osp_max_rpcs_in_flight);
 
-static int osp_max_rpcs_in_prog_seq_show(struct seq_file *m, void *data)
+static int osp_rd_max_rpcs_in_prog(char *page, char **start, off_t off,
+                                  int count, int *eof, void *data)
 {
-       struct obd_device       *dev = m->private;
+       struct obd_device       *dev = data;
        struct osp_device       *osp = lu2osp_dev(dev->obd_lu_dev);
+       int                      rc;
 
        if (osp == NULL)
                return -EINVAL;
 
-       return seq_printf(m, "%u\n", osp->opd_syn_max_rpc_in_progress);
+       rc = snprintf(page, count, "%u\n", osp->opd_syn_max_rpc_in_progress);
+       return rc;
 }
 
-static ssize_t
-osp_max_rpcs_in_prog_seq_write(struct file *file, const char *buffer,
-                               size_t count, loff_t *off)
+static int osp_wr_max_rpcs_in_prog(struct file *file, const char *buffer,
+                                  unsigned long count, void *data)
 {
-       struct obd_device       *dev = ((struct seq_file *)file->private_data)->private;
+       struct obd_device       *dev = data;
        struct osp_device       *osp = lu2osp_dev(dev->obd_lu_dev);
        int                      val, rc;
 
@@ -185,24 +194,23 @@ osp_max_rpcs_in_prog_seq_write(struct file *file, const char *buffer,
 
        return count;
 }
-LPROC_SEQ_FOPS(osp_max_rpcs_in_prog);
 
-static int osp_create_count_seq_show(struct seq_file *m, void *data)
+static int osp_rd_create_count(char *page, char **start, off_t off, int count,
+                              int *eof, void *data)
 {
-       struct obd_device *obd = m->private;
+       struct obd_device *obd = data;
        struct osp_device *osp = lu2osp_dev(obd->obd_lu_dev);
 
        if (osp == NULL || osp->opd_pre == NULL)
                return 0;
 
-       return seq_printf(m, "%d\n", osp->opd_pre_grow_count);
+       return snprintf(page, count, "%d\n", osp->opd_pre_grow_count);
 }
 
-static ssize_t
-osp_create_count_seq_write(struct file *file, const char *buffer,
-                               size_t count, loff_t *off)
+static int osp_wr_create_count(struct file *file, const char *buffer,
+                              unsigned long count, void *data)
 {
-       struct obd_device       *obd = ((struct seq_file *)file->private_data)->private;
+       struct obd_device       *obd = data;
        struct osp_device       *osp = lu2osp_dev(obd->obd_lu_dev);
        int                      val, rc, i;
 
@@ -234,24 +242,23 @@ osp_create_count_seq_write(struct file *file, const char *buffer,
 
        return count;
 }
-LPROC_SEQ_FOPS(osp_create_count);
 
-static int osp_max_create_count_seq_show(struct seq_file *m, void *data)
+static int osp_rd_max_create_count(char *page, char **start, off_t off,
+                                  int count, int *eof, void *data)
 {
-       struct obd_device *obd = m->private;
+       struct obd_device *obd = data;
        struct osp_device *osp = lu2osp_dev(obd->obd_lu_dev);
 
        if (osp == NULL || osp->opd_pre == NULL)
                return 0;
 
-       return seq_printf(m, "%d\n", osp->opd_pre_max_grow_count);
+       return snprintf(page, count, "%d\n", osp->opd_pre_max_grow_count);
 }
 
-static ssize_t
-osp_max_create_count_seq_write(struct file *file, const char *buffer,
-                               size_t count, loff_t *off)
+static int osp_wr_max_create_count(struct file *file, const char *buffer,
+                                  unsigned long count, void *data)
 {
-       struct obd_device       *obd = ((struct seq_file *)file->private_data)->private;
+       struct obd_device       *obd = data;
        struct osp_device       *osp = lu2osp_dev(obd->obd_lu_dev);
        int                      val, rc;
 
@@ -274,85 +281,89 @@ osp_max_create_count_seq_write(struct file *file, const char *buffer,
 
        return count;
 }
-LPROC_SEQ_FOPS(osp_max_create_count);
 
-static int osp_prealloc_next_id_seq_show(struct seq_file *m, void *data)
+static int osp_rd_prealloc_next_id(char *page, char **start, off_t off,
+                                  int count, int *eof, void *data)
 {
-       struct obd_device *obd = m->private;
+       struct obd_device *obd = data;
        struct osp_device *osp = lu2osp_dev(obd->obd_lu_dev);
 
        if (osp == NULL || osp->opd_pre == NULL)
                return 0;
 
-       return seq_printf(m, "%u\n", fid_oid(&osp->opd_pre_used_fid) + 1);
+       return snprintf(page, count, "%u\n",
+                       fid_oid(&osp->opd_pre_used_fid) + 1);
 }
-LPROC_SEQ_FOPS_RO(osp_prealloc_next_id);
 
-static int osp_prealloc_last_id_seq_show(struct seq_file *m, void *data)
+static int osp_rd_prealloc_last_id(char *page, char **start, off_t off,
+                                  int count, int *eof, void *data)
 {
-       struct obd_device *obd = m->private;
+       struct obd_device *obd = data;
        struct osp_device *osp = lu2osp_dev(obd->obd_lu_dev);
 
        if (osp == NULL || osp->opd_pre == NULL)
                return 0;
 
-       return seq_printf(m, "%u\n", fid_oid(&osp->opd_pre_last_created_fid));
+       return snprintf(page, count, "%u\n",
+                       fid_oid(&osp->opd_pre_last_created_fid));
 }
-LPROC_SEQ_FOPS_RO(osp_prealloc_last_id);
 
-static int osp_prealloc_next_seq_seq_show(struct seq_file *m, void *data)
+static int osp_rd_prealloc_next_seq(char *page, char **start, off_t off,
+                                   int count, int *eof, void *data)
 {
-       struct obd_device *obd = m->private;
+       struct obd_device *obd = data;
        struct osp_device *osp = lu2osp_dev(obd->obd_lu_dev);
 
        if (osp == NULL || osp->opd_pre == NULL)
                return 0;
 
-       return seq_printf(m, LPX64"\n", fid_seq(&osp->opd_pre_used_fid));
+       return snprintf(page, count, LPX64"\n",
+                       fid_seq(&osp->opd_pre_used_fid));
 }
-LPROC_SEQ_FOPS_RO(osp_prealloc_next_seq);
 
-static int osp_prealloc_last_seq_seq_show(struct seq_file *m, void *data)
+static int osp_rd_prealloc_last_seq(char *page, char **start, off_t off,
+                                   int count, int *eof, void *data)
 {
-       struct obd_device *obd = m->private;
+       struct obd_device *obd = data;
        struct osp_device *osp = lu2osp_dev(obd->obd_lu_dev);
 
        if (osp == NULL || osp->opd_pre == NULL)
                return 0;
 
-       return seq_printf(m, LPX64"\n",
+       return snprintf(page, count, LPX64"\n",
                        fid_seq(&osp->opd_pre_last_created_fid));
 }
-LPROC_SEQ_FOPS_RO(osp_prealloc_last_seq);
 
-static int osp_prealloc_reserved_seq_show(struct seq_file *m, void *data)
+static int osp_rd_prealloc_reserved(char *page, char **start, off_t off,
+                                   int count, int *eof, void *data)
 {
-       struct obd_device *obd = m->private;
+       struct obd_device *obd = data;
        struct osp_device *osp = lu2osp_dev(obd->obd_lu_dev);
 
        if (osp == NULL || osp->opd_pre == NULL)
                return 0;
 
-       return seq_printf(m, LPU64"\n", osp->opd_pre_reserved);
+       return snprintf(page, count, LPU64"\n", osp->opd_pre_reserved);
 }
-LPROC_SEQ_FOPS_RO(osp_prealloc_reserved);
 
-static int osp_maxage_seq_show(struct seq_file *m, void *data)
+static int osp_rd_maxage(char *page, char **start, off_t off,
+                        int count, int *eof, void *data)
 {
-       struct obd_device       *dev = m->private;
+       struct obd_device       *dev = data;
        struct osp_device       *osp = lu2osp_dev(dev->obd_lu_dev);
+       int                      rc;
 
        if (osp == NULL)
                return -EINVAL;
 
-       return seq_printf(m, "%u\n", osp->opd_statfs_maxage);
+       rc = snprintf(page, count, "%u\n", osp->opd_statfs_maxage);
+       return rc;
 }
 
-static ssize_t
-osp_maxage_seq_write(struct file *file, const char *buffer,
-                       size_t count, loff_t *off)
+static int osp_wr_maxage(struct file *file, const char *buffer,
+                        unsigned long count, void *data)
 {
-       struct obd_device       *dev = ((struct seq_file *)file->private_data)->private;
+       struct obd_device       *dev = data;
        struct osp_device       *osp = lu2osp_dev(dev->obd_lu_dev);
        int                      val, rc;
 
@@ -370,23 +381,25 @@ osp_maxage_seq_write(struct file *file, const char *buffer,
 
        return count;
 }
-LPROC_SEQ_FOPS(osp_maxage);
 
-static int osp_pre_status_seq_show(struct seq_file *m, void *data)
+static int osp_rd_pre_status(char *page, char **start, off_t off,
+                            int count, int *eof, void *data)
 {
-       struct obd_device       *dev = m->private;
+       struct obd_device       *dev = data;
        struct osp_device       *osp = lu2osp_dev(dev->obd_lu_dev);
+       int                      rc;
 
        if (osp == NULL || osp->opd_pre == NULL)
                return -EINVAL;
 
-       return seq_printf(m, "%d\n", osp->opd_pre_status);
+       rc = snprintf(page, count, "%d\n", osp->opd_pre_status);
+       return rc;
 }
-LPROC_SEQ_FOPS_RO(osp_pre_status);
 
-static int osp_destroys_in_flight_seq_show(struct seq_file *m, void *data)
+static int osp_rd_destroys_in_flight(char *page, char **start, off_t off,
+                                    int count, int *eof, void *data)
 {
-       struct obd_device *dev = m->private;
+       struct obd_device *dev = data;
        struct osp_device *osp = lu2osp_dev(dev->obd_lu_dev);
 
        if (osp == NULL)
@@ -398,126 +411,87 @@ static int osp_destroys_in_flight_seq_show(struct seq_file *m, void *data)
         * - sync changes are zero - no llog records
         * - sync in progress are zero - no RPCs in flight
         */
-       return seq_printf(m, "%lu\n",
+       return snprintf(page, count, "%lu\n",
                        osp->opd_syn_rpc_in_progress + osp->opd_syn_changes);
 }
-LPROC_SEQ_FOPS_RO(osp_destroys_in_flight);
 
-static int osp_old_sync_processed_seq_show(struct seq_file *m, void *data)
+static int osp_rd_old_sync_processed(char *page, char **start, off_t off,
+                                    int count, int *eof, void *data)
 {
-       struct obd_device       *dev = m->private;
+       struct obd_device       *dev = data;
        struct osp_device       *osp = lu2osp_dev(dev->obd_lu_dev);
+       int                      rc;
 
        if (osp == NULL)
                return -EINVAL;
 
-       return seq_printf(m, "%d\n", osp->opd_syn_prev_done);
+       rc = snprintf(page, count, "%d\n", osp->opd_syn_prev_done);
+       return rc;
 }
-LPROC_SEQ_FOPS_RO(osp_old_sync_processed);
-
-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);
 
-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_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 },
 
        /* for compatibility reasons */
-       { .name =       "destroys_in_flight",
-         .fops =       &osp_destroys_in_flight_fops    },
+       { "destroys_in_flight", osp_rd_destroys_in_flight, 0, 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          },
+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 },
        { 0 }
 };
 
+static struct lprocfs_vars lprocfs_osp_module_vars[] = {
+       { "num_refs",           lprocfs_rd_numrefs, 0, 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;
 
-       obd->obd_proc_entry = lprocfs_seq_register(obd->obd_name,
+       obd->obd_proc_entry = lprocfs_register(obd->obd_name,
                                               obd->obd_type->typ_procroot,
                                               lprocfs_osp_osd_vars,
                                               &osp->opd_dt_dev);
@@ -528,59 +502,33 @@ void osp_lprocfs_init(struct osp_device *osp)
                return;
        }
 
-       rc = lprocfs_seq_add_vars(obd->obd_proc_entry, lprocfs_osp_obd_vars, obd);
+       rc = lprocfs_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;
        }
-       obd->obd_vars = lprocfs_osp_obd_vars;
 
        ptlrpc_lprocfs_register_obd(obd);
 
-       if (osp->opd_connect_mdt)
-               return;
-
        /* for compatibility we link old procfs's OSC entries to osp ones */
-       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);
+       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);
                        OBD_FREE(name, strlen(obd->obd_name) + 1);
-                       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;
-                       }
+                       osp->opd_symlink = symlink;
                }
        }
 }
index 755c096..fce82a2 100644 (file)
@@ -210,13 +210,25 @@ const struct lu_device_operations lwp_lu_ops = {
        .ldo_process_config     = lwp_process_config,
 };
 
-static struct lprocfs_seq_vars lprocfs_lwp_obd_vars[] = {
+static struct lprocfs_vars lprocfs_lwp_module_vars[] = {
+       { "num_refs",           lprocfs_rd_numrefs, 0, 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)
 {
+       struct lprocfs_static_vars lvars = { 0 };
        int                        rc;
        ENTRY;
 
@@ -245,8 +257,8 @@ int lwp_init0(const struct lu_env *env, struct lwp_device *lwp,
                RETURN(rc);
        }
 
-       lwp->lpd_obd->obd_vars = lprocfs_lwp_obd_vars;
-       if (lprocfs_seq_obd_setup(lwp->lpd_obd) == 0)
+       lprocfs_lwp_init_vars(&lvars);
+       if (lprocfs_obd_setup(lwp->lpd_obd, lvars.obd_vars) == 0)
                ptlrpc_lprocfs_register_obd(lwp->lpd_obd);
 
        RETURN(0);
index e41133f..d246678 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 obd_device               *obd = d->opd_obd;
+       struct lprocfs_static_vars       lvars = { 0 };
        int                              rc;
 
        ENTRY;
@@ -385,9 +385,11 @@ static int osp_process_config(const struct lu_env *env,
                rc = osp_shutdown(env, d);
                break;
        case LCFG_PARAM:
-               LASSERT(obd);
-               rc = class_process_proc_seq_param(PARAM_OSC, obd->obd_vars,
-                                                 lcfg, obd);
+               lprocfs_osp_init_vars(&lvars);
+
+               LASSERT(d->opd_obd);
+               rc = class_process_proc_param(PARAM_OSC, lvars.obd_vars,
+                                             lcfg, d->opd_obd);
                if (rc > 0)
                        rc = 0;
                if (rc == -ENOSYS) {
@@ -840,9 +842,6 @@ static struct lu_device *osp_device_fini(const struct lu_env *env,
                        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);
@@ -1236,25 +1235,33 @@ struct llog_operations osp_mds_ost_orig_logops;
 
 static int __init osp_mod_init(void)
 {
-       int rc;
+       struct lprocfs_static_vars       lvars;
+       cfs_proc_dir_entry_t            *osc_proc_dir;
+       int                              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
-                               NULL,
+                               lvars.module_vars,
 #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;
        }
 
+       lprocfs_lwp_init_vars(&lvars);
+
        rc = class_register_type(&lwp_obd_device_ops, NULL, NULL,
 #ifndef HAVE_ONLY_PROCFS_SEQ
-                               NULL,
+                               lvars.module_vars,
 #endif
                                LUSTRE_LWP_NAME, &lwp_device_type);
        if (rc != 0) {
@@ -1267,11 +1274,22 @@ 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;
+
+       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)
 {
+       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);
index 988ab79..025a249 100644 (file)
@@ -434,6 +434,7 @@ 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 */
+void lprocfs_osp_init_vars(struct lprocfs_static_vars *lvars);
 void osp_lprocfs_init(struct osp_device *osp);
 
 /* osp_sync.c */
@@ -447,6 +448,7 @@ int osp_sync_fini(struct osp_device *d);
 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;