Whamcloud - gitweb
LU-3319 procfs: update ldiskfs proc handling to seq_files
[fs/lustre-release.git] / lustre / osd-ldiskfs / osd_lproc.c
1 /*
2  * GPL HEADER START
3  *
4  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
5  *
6  * This program is free software; you can redistribute it and/or modify
7  * it under the terms of the GNU General Public License version 2 only,
8  * as published by the Free Software Foundation.
9  *
10  * This program is distributed in the hope that it will be useful, but
11  * WITHOUT ANY WARRANTY; without even the implied warranty of
12  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
13  * General Public License version 2 for more details (a copy is included
14  * in the LICENSE file that accompanied this code).
15  *
16  * You should have received a copy of the GNU General Public License
17  * version 2 along with this program; If not, see
18  * http://www.sun.com/software/products/lustre/docs/GPLv2.pdf
19  *
20  * Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa Clara,
21  * CA 95054 USA or visit www.sun.com if you need additional information or
22  * have any questions.
23  *
24  * GPL HEADER END
25  */
26 /*
27  * Copyright (c) 2008, 2010, Oracle and/or its affiliates. All rights reserved.
28  * Use is subject to license terms.
29  *
30  * Copyright (c) 2011, 2013, Intel Corporation.
31  */
32 /*
33  * This file is part of Lustre, http://www.lustre.org/
34  * Lustre is a trademark of Sun Microsystems, Inc.
35  *
36  * lustre/osd/osd_lproc.c
37  *
38  * Author: Mikhail Pershin <tappro@sun.com>
39  */
40
41 #define DEBUG_SUBSYSTEM S_CLASS
42
43 #include <lprocfs_status.h>
44 #include <lustre/lustre_idl.h>
45
46 #include "osd_internal.h"
47
48 #ifdef LPROCFS
49
50 void osd_brw_stats_update(struct osd_device *osd, struct osd_iobuf *iobuf)
51 {
52         struct brw_stats *s = &osd->od_brw_stats;
53         unsigned long    *last_block = NULL;
54         struct page     **pages = iobuf->dr_pages;
55         struct page      *last_page = NULL;
56         unsigned long     discont_pages = 0;
57         unsigned long     discont_blocks = 0;
58         unsigned long    *blocks = iobuf->dr_blocks;
59         int               i, nr_pages = iobuf->dr_npages;
60         int               blocks_per_page;
61         int               rw = iobuf->dr_rw;
62
63         if (unlikely(nr_pages == 0))
64                 return;
65
66         blocks_per_page = PAGE_CACHE_SIZE >> osd_sb(osd)->s_blocksize_bits;
67
68         lprocfs_oh_tally_log2(&s->hist[BRW_R_PAGES+rw], nr_pages);
69
70         while (nr_pages-- > 0) {
71                 if (last_page && (*pages)->index != (last_page->index + 1))
72                         discont_pages++;
73                 last_page = *pages;
74                 pages++;
75                 for (i = 0; i < blocks_per_page; i++) {
76                         if (last_block && *blocks != (*last_block + 1))
77                                 discont_blocks++;
78                         last_block = blocks++;
79                 }
80         }
81
82         lprocfs_oh_tally(&s->hist[BRW_R_DISCONT_PAGES+rw], discont_pages);
83         lprocfs_oh_tally(&s->hist[BRW_R_DISCONT_BLOCKS+rw], discont_blocks);
84 }
85
86 #define pct(a, b) (b ? a * 100 / b : 0)
87
88 static void display_brw_stats(struct seq_file *seq, char *name, char *units,
89         struct obd_histogram *read, struct obd_histogram *write, int scale)
90 {
91         unsigned long read_tot, write_tot, r, w, read_cum = 0, write_cum = 0;
92         int i;
93
94         seq_printf(seq, "\n%26s read      |     write\n", " ");
95         seq_printf(seq, "%-22s %-5s %% cum %% |  %-11s %% cum %%\n",
96                    name, units, units);
97
98         read_tot = lprocfs_oh_sum(read);
99         write_tot = lprocfs_oh_sum(write);
100         for (i = 0; i < OBD_HIST_MAX; i++) {
101                 r = read->oh_buckets[i];
102                 w = write->oh_buckets[i];
103                 read_cum += r;
104                 write_cum += w;
105                 if (read_cum == 0 && write_cum == 0)
106                         continue;
107
108                 if (!scale)
109                         seq_printf(seq, "%u", i);
110                 else if (i < 10)
111                         seq_printf(seq, "%u", scale << i);
112                 else if (i < 20)
113                         seq_printf(seq, "%uK", scale << (i-10));
114                 else
115                         seq_printf(seq, "%uM", scale << (i-20));
116
117                 seq_printf(seq, ":\t\t%10lu %3lu %3lu   | %4lu %3lu %3lu\n",
118                            r, pct(r, read_tot), pct(read_cum, read_tot),
119                            w, pct(w, write_tot), pct(write_cum, write_tot));
120
121                 if (read_cum == read_tot && write_cum == write_tot)
122                         break;
123         }
124 }
125
126 static void brw_stats_show(struct seq_file *seq, struct brw_stats *brw_stats)
127 {
128         struct timeval now;
129
130         /* this sampling races with updates */
131         do_gettimeofday(&now);
132         seq_printf(seq, "snapshot_time:         %lu.%lu (secs.usecs)\n",
133                    now.tv_sec, now.tv_usec);
134
135         display_brw_stats(seq, "pages per bulk r/w", "rpcs",
136                           &brw_stats->hist[BRW_R_PAGES],
137                           &brw_stats->hist[BRW_W_PAGES], 1);
138
139         display_brw_stats(seq, "discontiguous pages", "rpcs",
140                           &brw_stats->hist[BRW_R_DISCONT_PAGES],
141                           &brw_stats->hist[BRW_W_DISCONT_PAGES], 0);
142
143         display_brw_stats(seq, "discontiguous blocks", "rpcs",
144                           &brw_stats->hist[BRW_R_DISCONT_BLOCKS],
145                           &brw_stats->hist[BRW_W_DISCONT_BLOCKS], 0);
146
147         display_brw_stats(seq, "disk fragmented I/Os", "ios",
148                           &brw_stats->hist[BRW_R_DIO_FRAGS],
149                           &brw_stats->hist[BRW_W_DIO_FRAGS], 0);
150
151         display_brw_stats(seq, "disk I/Os in flight", "ios",
152                           &brw_stats->hist[BRW_R_RPC_HIST],
153                           &brw_stats->hist[BRW_W_RPC_HIST], 0);
154
155         display_brw_stats(seq, "I/O time (1/1000s)", "ios",
156                           &brw_stats->hist[BRW_R_IO_TIME],
157                           &brw_stats->hist[BRW_W_IO_TIME], 1000 / HZ);
158
159         display_brw_stats(seq, "disk I/O size", "ios",
160                           &brw_stats->hist[BRW_R_DISK_IOSIZE],
161                           &brw_stats->hist[BRW_W_DISK_IOSIZE], 1);
162 }
163
164 #undef pct
165
166 static int osd_brw_stats_seq_show(struct seq_file *seq, void *v)
167 {
168         struct osd_device *osd = seq->private;
169
170         brw_stats_show(seq, &osd->od_brw_stats);
171
172         return 0;
173 }
174
175 static ssize_t osd_brw_stats_seq_write(struct file *file, const char *buf,
176                                        size_t len, loff_t *off)
177 {
178         struct seq_file *seq = file->private_data;
179         struct osd_device *osd = seq->private;
180         int i;
181
182         for (i = 0; i < BRW_LAST; i++)
183                 lprocfs_oh_clear(&osd->od_brw_stats.hist[i]);
184
185         return len;
186 }
187
188 LPROC_SEQ_FOPS(osd_brw_stats);
189
190 static int osd_stats_init(struct osd_device *osd)
191 {
192         int i, result;
193         ENTRY;
194
195         for (i = 0; i < BRW_LAST; i++)
196                 spin_lock_init(&osd->od_brw_stats.hist[i].oh_lock);
197
198         osd->od_stats = lprocfs_alloc_stats(LPROC_OSD_LAST, 0);
199         if (osd->od_stats != NULL) {
200                 result = lprocfs_register_stats(osd->od_proc_entry, "stats",
201                                                 osd->od_stats);
202                 if (result)
203                         GOTO(out, result);
204
205                 lprocfs_counter_init(osd->od_stats, LPROC_OSD_GET_PAGE,
206                                      LPROCFS_CNTR_AVGMINMAX|LPROCFS_CNTR_STDDEV,
207                                      "get_page", "usec");
208                 lprocfs_counter_init(osd->od_stats, LPROC_OSD_NO_PAGE,
209                                      LPROCFS_CNTR_AVGMINMAX,
210                                      "get_page_failures", "num");
211                 lprocfs_counter_init(osd->od_stats, LPROC_OSD_CACHE_ACCESS,
212                                      LPROCFS_CNTR_AVGMINMAX,
213                                      "cache_access", "pages");
214                 lprocfs_counter_init(osd->od_stats, LPROC_OSD_CACHE_HIT,
215                                      LPROCFS_CNTR_AVGMINMAX,
216                                      "cache_hit", "pages");
217                 lprocfs_counter_init(osd->od_stats, LPROC_OSD_CACHE_MISS,
218                                      LPROCFS_CNTR_AVGMINMAX,
219                                      "cache_miss", "pages");
220 #if OSD_THANDLE_STATS
221                 lprocfs_counter_init(osd->od_stats, LPROC_OSD_THANDLE_STARTING,
222                                      LPROCFS_CNTR_AVGMINMAX,
223                                      "thandle starting", "usec");
224                 lprocfs_counter_init(osd->od_stats, LPROC_OSD_THANDLE_OPEN,
225                                      LPROCFS_CNTR_AVGMINMAX,
226                                      "thandle open", "usec");
227                 lprocfs_counter_init(osd->od_stats, LPROC_OSD_THANDLE_CLOSING,
228                                      LPROCFS_CNTR_AVGMINMAX,
229                                      "thandle closing", "usec");
230 #endif
231                 result = lprocfs_seq_create(osd->od_proc_entry, "brw_stats",
232                                             0644, &osd_brw_stats_fops, osd);
233         } else
234                 result = -ENOMEM;
235
236 out:
237         RETURN(result);
238 }
239
240 static int ldiskfs_osd_fstype_seq_show(struct seq_file *m, void *data)
241 {
242         struct osd_device *osd = osd_dt_dev((struct dt_device *)m->private);
243
244         LASSERT(osd != NULL);
245         return seq_printf(m, "ldiskfs\n");
246 }
247 LPROC_SEQ_FOPS_RO(ldiskfs_osd_fstype);
248
249 static int ldiskfs_osd_mntdev_seq_show(struct seq_file *m, void *data)
250 {
251         struct osd_device *osd = osd_dt_dev((struct dt_device *)m->private);
252
253         LASSERT(osd != NULL);
254         if (unlikely(osd->od_mnt == NULL))
255                 return -EINPROGRESS;
256
257         return seq_printf(m, "%s\n", osd->od_mntdev);
258 }
259 LPROC_SEQ_FOPS_RO(ldiskfs_osd_mntdev);
260
261 static int ldiskfs_osd_cache_seq_show(struct seq_file *m, void *data)
262 {
263         struct osd_device *osd = osd_dt_dev((struct dt_device *)m->private);
264
265         LASSERT(osd != NULL);
266         if (unlikely(osd->od_mnt == NULL))
267                 return -EINPROGRESS;
268
269         return seq_printf(m, "%u\n", osd->od_read_cache);
270 }
271
272 static ssize_t
273 ldiskfs_osd_cache_seq_write(struct file *file, const char *buffer,
274                             size_t count, loff_t *off)
275 {
276         struct seq_file   *m = file->private_data;
277         struct dt_device  *dt = m->private;
278         struct osd_device *osd = osd_dt_dev(dt);
279         int                val, rc;
280
281         LASSERT(osd != NULL);
282         if (unlikely(osd->od_mnt == NULL))
283                 return -EINPROGRESS;
284
285         rc = lprocfs_write_helper(buffer, count, &val);
286         if (rc)
287                 return rc;
288
289         osd->od_read_cache = !!val;
290         return count;
291 }
292 LPROC_SEQ_FOPS(ldiskfs_osd_cache);
293
294 static int ldiskfs_osd_wcache_seq_show(struct seq_file *m, void *data)
295 {
296         struct osd_device *osd = osd_dt_dev((struct dt_device *)m->private);
297
298         LASSERT(osd != NULL);
299         if (unlikely(osd->od_mnt == NULL))
300                 return -EINPROGRESS;
301
302         return seq_printf(m, "%u\n", osd->od_writethrough_cache);
303 }
304
305 static ssize_t
306 ldiskfs_osd_wcache_seq_write(struct file *file, const char *buffer,
307                                 size_t count, loff_t *off)
308 {
309         struct seq_file   *m = file->private_data;
310         struct dt_device  *dt = m->private;
311         struct osd_device *osd = osd_dt_dev(dt);
312         int                val, rc;
313
314         LASSERT(osd != NULL);
315         if (unlikely(osd->od_mnt == NULL))
316                 return -EINPROGRESS;
317
318         rc = lprocfs_write_helper(buffer, count, &val);
319         if (rc)
320                 return rc;
321
322         osd->od_writethrough_cache = !!val;
323         return count;
324 }
325 LPROC_SEQ_FOPS(ldiskfs_osd_wcache);
326
327 static ssize_t
328 lprocfs_osd_force_sync_seq_write(struct file *file, const char *buffer,
329                                         size_t count, loff_t *off)
330 {
331         struct seq_file   *m = file->private_data;
332         struct dt_device  *dt = m->private;
333         struct osd_device *osd = osd_dt_dev(dt);
334         struct lu_env      env;
335         int                rc;
336
337         LASSERT(osd != NULL);
338         if (unlikely(osd->od_mnt == NULL))
339                 return -EINPROGRESS;
340
341         rc = lu_env_init(&env, LCT_LOCAL);
342         if (rc)
343                 return rc;
344         rc = dt_sync(&env, dt);
345         lu_env_fini(&env);
346
347         return rc == 0 ? count : rc;
348 }
349 LPROC_SEQ_FOPS_WO_TYPE(ldiskfs, osd_force_sync);
350
351 static int ldiskfs_osd_pdo_seq_show(struct seq_file *m, void *data)
352 {
353         return seq_printf(m, "%s\n", ldiskfs_pdo ? "ON" : "OFF");
354 }
355
356 static ssize_t
357 ldiskfs_osd_pdo_seq_write(struct file *file, const char *buffer,
358                                 size_t count, loff_t *off)
359 {
360         int pdo, rc;
361
362         rc = lprocfs_write_helper(buffer, count, &pdo);
363         if (rc != 0)
364                 return rc;
365
366         ldiskfs_pdo = !!pdo;
367
368         return count;
369 }
370 LPROC_SEQ_FOPS(ldiskfs_osd_pdo);
371
372 static int ldiskfs_osd_auto_scrub_seq_show(struct seq_file *m, void *data)
373 {
374         struct osd_device *dev = osd_dt_dev((struct dt_device *)m->private);
375
376         LASSERT(dev != NULL);
377         if (unlikely(dev->od_mnt == NULL))
378                 return -EINPROGRESS;
379
380         return seq_printf(m, "%d\n", !dev->od_noscrub);
381 }
382
383 static ssize_t
384 ldiskfs_osd_auto_scrub_seq_write(struct file *file, const char *buffer,
385                                         size_t count, loff_t *off)
386 {
387         struct seq_file   *m = file->private_data;
388         struct dt_device  *dt = m->private;
389         struct osd_device *dev = osd_dt_dev(dt);
390         int val, rc;
391
392         LASSERT(dev != NULL);
393         if (unlikely(dev->od_mnt == NULL))
394                 return -EINPROGRESS;
395
396         rc = lprocfs_write_helper(buffer, count, &val);
397         if (rc)
398                 return rc;
399
400         dev->od_noscrub = !val;
401         return count;
402 }
403 LPROC_SEQ_FOPS(ldiskfs_osd_auto_scrub);
404
405 static int
406 ldiskfs_osd_track_declares_assert_seq_show(struct seq_file *m, void *data)
407 {
408         return seq_printf(m, "%d\n", ldiskfs_track_declares_assert);
409 }
410
411 static ssize_t
412 ldiskfs_osd_track_declares_assert_seq_write(struct file *file,
413                                                 const char *buffer,
414                                                 size_t count, loff_t *off)
415 {
416         int     track_declares_assert;
417         int     rc;
418
419         rc = lprocfs_write_helper(buffer, count, &track_declares_assert);
420         if (rc != 0)
421                 return rc;
422
423         ldiskfs_track_declares_assert = !!track_declares_assert;
424
425         return count;
426 }
427 LPROC_SEQ_FOPS(ldiskfs_osd_track_declares_assert);
428
429 static int ldiskfs_osd_oi_scrub_seq_show(struct seq_file *m, void *data)
430 {
431         struct osd_device *dev = osd_dt_dev((struct dt_device *)m->private);
432
433         LASSERT(dev != NULL);
434         if (unlikely(dev->od_mnt == NULL))
435                 return -EINPROGRESS;
436
437         return osd_scrub_dump(m, dev);
438 }
439 LPROC_SEQ_FOPS_RO(ldiskfs_osd_oi_scrub);
440
441 int ldiskfs_osd_readcache_seq_show(struct seq_file *m, void *data)
442 {
443         struct osd_device *osd = osd_dt_dev((struct dt_device *)m->private);
444
445         LASSERT(osd != NULL);
446         if (unlikely(osd->od_mnt == NULL))
447                 return -EINPROGRESS;
448
449         return seq_printf(m, LPU64"\n", osd->od_readcache_max_filesize);
450 }
451
452 ssize_t
453 ldiskfs_osd_readcache_seq_write(struct file *file, const char *buffer,
454                                 size_t count, loff_t *off)
455 {
456         struct seq_file   *m = file->private_data;
457         struct dt_device  *dt = m->private;
458         struct osd_device *osd = osd_dt_dev(dt);
459         __u64              val;
460         int                rc;
461
462         LASSERT(osd != NULL);
463         if (unlikely(osd->od_mnt == NULL))
464                 return -EINPROGRESS;
465
466         rc = lprocfs_write_u64_helper(buffer, count, &val);
467         if (rc)
468                 return rc;
469
470         osd->od_readcache_max_filesize = val > OSD_MAX_CACHE_SIZE ?
471                                          OSD_MAX_CACHE_SIZE : val;
472         return count;
473 }
474 LPROC_SEQ_FOPS(ldiskfs_osd_readcache);
475
476 static int ldiskfs_osd_lma_self_repair_seq_show(struct seq_file *m, void *data)
477 {
478         struct osd_device *dev = osd_dt_dev((struct dt_device *)m->private);
479
480         LASSERT(dev != NULL);
481         if (unlikely(dev->od_mnt == NULL))
482                 return -EINPROGRESS;
483
484         return seq_printf(m, "%d\n", !!dev->od_lma_self_repair);
485 }
486
487 static ssize_t
488 ldiskfs_osd_lma_self_repair_seq_write(struct file *file, const char *buffer,
489                                         size_t count, loff_t *off)
490 {
491         struct seq_file   *m = file->private_data;
492         struct dt_device  *dt = m->private;
493         struct osd_device *dev = osd_dt_dev(dt);
494         int                val;
495         int                rc;
496
497         LASSERT(dev != NULL);
498         if (unlikely(dev->od_mnt == NULL))
499                 return -EINPROGRESS;
500
501         rc = lprocfs_write_helper(buffer, count, &val);
502         if (rc)
503                 return rc;
504
505         dev->od_lma_self_repair = !!val;
506         return count;
507 }
508 LPROC_SEQ_FOPS(ldiskfs_osd_lma_self_repair);
509
510 LPROC_SEQ_FOPS_RO_TYPE(ldiskfs, dt_blksize);
511 LPROC_SEQ_FOPS_RO_TYPE(ldiskfs, dt_kbytestotal);
512 LPROC_SEQ_FOPS_RO_TYPE(ldiskfs, dt_kbytesfree);
513 LPROC_SEQ_FOPS_RO_TYPE(ldiskfs, dt_kbytesavail);
514 LPROC_SEQ_FOPS_RO_TYPE(ldiskfs, dt_filestotal);
515 LPROC_SEQ_FOPS_RO_TYPE(ldiskfs, dt_filesfree);
516
517 struct lprocfs_seq_vars lprocfs_osd_obd_vars[] = {
518         { .name =       "blocksize",
519           .fops =       &ldiskfs_dt_blksize_fops        },
520         { .name =       "kbytestotal",
521           .fops =       &ldiskfs_dt_kbytestotal_fops    },
522         { .name =       "kbytesfree",
523           .fops =       &ldiskfs_dt_kbytesfree_fops     },
524         { .name =       "kbytesavail",
525           .fops =       &ldiskfs_dt_kbytesavail_fops    },
526         { .name =       "filestotal",
527           .fops =       &ldiskfs_dt_filestotal_fops     },
528         { .name =       "filesfree",
529           .fops =       &ldiskfs_dt_filesfree_fops      },
530         { .name =       "fstype",
531           .fops =       &ldiskfs_osd_fstype_fops        },
532         { .name =       "mntdev",
533           .fops =       &ldiskfs_osd_mntdev_fops        },
534         { .name =       "force_sync",
535           .fops =       &ldiskfs_osd_force_sync_fops    },
536         { .name =       "pdo",
537           .fops =       &ldiskfs_osd_pdo_fops           },
538         { .name =       "auto_scrub",
539           .fops =       &ldiskfs_osd_auto_scrub_fops    },
540         { .name =       "oi_scrub",
541           .fops =       &ldiskfs_osd_oi_scrub_fops      },
542         { .name =       "read_cache_enable",
543           .fops =       &ldiskfs_osd_cache_fops         },
544         { .name =       "writethrough_cache_enable",
545           .fops =       &ldiskfs_osd_wcache_fops        },
546         { .name =       "readcache_max_filesize",
547           .fops =       &ldiskfs_osd_readcache_fops     },
548         { .name =       "lma_self_repair",
549           .fops =       &ldiskfs_osd_lma_self_repair_fops       },
550         { 0 }
551 };
552
553 struct lprocfs_seq_vars lprocfs_osd_module_vars[] = {
554         { .name =       "track_declares_assert",
555           .fops =       &ldiskfs_osd_track_declares_assert_fops         },
556         { 0 }
557 };
558
559
560 int osd_procfs_init(struct osd_device *osd, const char *name)
561 {
562         struct obd_type *type;
563         int             rc;
564         ENTRY;
565
566         if (osd->od_proc_entry)
567                 RETURN(0);
568
569         /* at the moment there is no linkage between lu_type
570          * and obd_type, so we lookup obd_type this way */
571         type = class_search_type(LUSTRE_OSD_LDISKFS_NAME);
572
573         LASSERT(name != NULL);
574         LASSERT(type != NULL);
575
576         /* Find the type procroot and add the proc entry for this device */
577         osd->od_proc_entry = lprocfs_seq_register(name, type->typ_procroot,
578                                                   lprocfs_osd_obd_vars,
579                                                   &osd->od_dt_dev);
580         if (IS_ERR(osd->od_proc_entry)) {
581                 rc = PTR_ERR(osd->od_proc_entry);
582                 CERROR("Error %d setting up lprocfs for %s\n",
583                        rc, name);
584                 osd->od_proc_entry = NULL;
585                 GOTO(out, rc);
586         }
587
588         rc = osd_stats_init(osd);
589
590         EXIT;
591 out:
592         if (rc)
593                 osd_procfs_fini(osd);
594         return rc;
595 }
596
597 int osd_procfs_fini(struct osd_device *osd)
598 {
599         if (osd->od_stats)
600                 lprocfs_free_stats(&osd->od_stats);
601
602         if (osd->od_proc_entry)
603                 lprocfs_remove(&osd->od_proc_entry);
604         RETURN(0);
605 }
606 #endif