1 /*****************************************************************************\
2 * Copyright (C) 2007-2010 Lawrence Livermore National Security, LLC.
3 * Copyright (C) 2007 The Regents of the University of California.
4 * Produced at Lawrence Livermore National Laboratory (cf, DISCLAIMER).
5 * Written by Brian Behlendorf <behlendorf1@llnl.gov>.
8 * This file is part of the SPL, Solaris Porting Layer.
9 * For details, see <http://zfsonlinux.org/>.
11 * The SPL is free software; you can redistribute it and/or modify it
12 * under the terms of the GNU General Public License as published by the
13 * Free Software Foundation; either version 2 of the License, or (at your
14 * option) any later version.
16 * The SPL is distributed in the hope that it will be useful, but WITHOUT
17 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
18 * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
21 * You should have received a copy of the GNU General Public License along
22 * with the SPL. If not, see <http://www.gnu.org/licenses/>.
24 * Solaris Porting Layer (SPL) Kstat Implementation.
25 \*****************************************************************************/
27 #include <linux/seq_file.h>
28 #include <sys/kstat.h>
30 #include <sys/cmn_err.h>
33 #define PDE_DATA(x) (PDE(x)->data)
36 static kmutex_t kstat_module_lock
;
37 static struct list_head kstat_module_list
;
38 static kid_t kstat_id
;
41 kstat_resize_raw(kstat_t
*ksp
)
43 if (ksp
->ks_raw_bufsize
== KSTAT_RAW_MAX
)
46 vmem_free(ksp
->ks_raw_buf
, ksp
->ks_raw_bufsize
);
47 ksp
->ks_raw_bufsize
= MIN(ksp
->ks_raw_bufsize
* 2, KSTAT_RAW_MAX
);
48 ksp
->ks_raw_buf
= vmem_alloc(ksp
->ks_raw_bufsize
, KM_SLEEP
);
54 kstat_waitq_enter(kstat_io_t
*kiop
)
60 delta
= new - kiop
->wlastupdate
;
61 kiop
->wlastupdate
= new;
64 kiop
->wlentime
+= delta
* wcnt
;
68 EXPORT_SYMBOL(kstat_waitq_enter
);
71 kstat_waitq_exit(kstat_io_t
*kiop
)
77 delta
= new - kiop
->wlastupdate
;
78 kiop
->wlastupdate
= new;
80 ASSERT((int)wcnt
> 0);
81 kiop
->wlentime
+= delta
* wcnt
;
84 EXPORT_SYMBOL(kstat_waitq_exit
);
87 kstat_runq_enter(kstat_io_t
*kiop
)
93 delta
= new - kiop
->rlastupdate
;
94 kiop
->rlastupdate
= new;
97 kiop
->rlentime
+= delta
* rcnt
;
101 EXPORT_SYMBOL(kstat_runq_enter
);
104 kstat_runq_exit(kstat_io_t
*kiop
)
110 delta
= new - kiop
->rlastupdate
;
111 kiop
->rlastupdate
= new;
113 ASSERT((int)rcnt
> 0);
114 kiop
->rlentime
+= delta
* rcnt
;
115 kiop
->rtime
+= delta
;
117 EXPORT_SYMBOL(kstat_runq_exit
);
120 kstat_seq_show_headers(struct seq_file
*f
)
122 kstat_t
*ksp
= (kstat_t
*)f
->private;
125 ASSERT(ksp
->ks_magic
== KS_MAGIC
);
127 seq_printf(f
, "%d %d 0x%02x %d %d %lld %lld\n",
128 ksp
->ks_kid
, ksp
->ks_type
, ksp
->ks_flags
,
129 ksp
->ks_ndata
, (int)ksp
->ks_data_size
,
130 ksp
->ks_crtime
, ksp
->ks_snaptime
);
132 switch (ksp
->ks_type
) {
135 if (ksp
->ks_raw_ops
.headers
) {
136 rc
= ksp
->ks_raw_ops
.headers(
137 ksp
->ks_raw_buf
, ksp
->ks_raw_bufsize
);
138 if (rc
== ENOMEM
&& !kstat_resize_raw(ksp
))
141 seq_puts(f
, ksp
->ks_raw_buf
);
143 seq_printf(f
, "raw data\n");
146 case KSTAT_TYPE_NAMED
:
147 seq_printf(f
, "%-31s %-4s %s\n",
148 "name", "type", "data");
150 case KSTAT_TYPE_INTR
:
151 seq_printf(f
, "%-8s %-8s %-8s %-8s %-8s\n",
152 "hard", "soft", "watchdog",
153 "spurious", "multsvc");
157 "%-8s %-8s %-8s %-8s %-8s %-8s "
158 "%-8s %-8s %-8s %-8s %-8s %-8s\n",
159 "nread", "nwritten", "reads", "writes",
160 "wtime", "wlentime", "wupdate",
161 "rtime", "rlentime", "rupdate",
164 case KSTAT_TYPE_TIMER
:
167 "%-8s %-8s %-8s %-8s %-8s\n",
168 "name", "events", "elapsed",
169 "min", "max", "start", "stop");
172 PANIC("Undefined kstat type %d\n", ksp
->ks_type
);
179 kstat_seq_show_raw(struct seq_file
*f
, unsigned char *p
, int l
)
184 seq_printf(f
, "%03x:", i
);
186 for (j
= 0; j
< 16; j
++) {
187 if (i
* 16 + j
>= l
) {
192 seq_printf(f
, " %02x", (unsigned char)p
[i
* 16 + j
]);
201 kstat_seq_show_named(struct seq_file
*f
, kstat_named_t
*knp
)
203 seq_printf(f
, "%-31s %-4d ", knp
->name
, knp
->data_type
);
205 switch (knp
->data_type
) {
206 case KSTAT_DATA_CHAR
:
207 knp
->value
.c
[15] = '\0'; /* NULL terminate */
208 seq_printf(f
, "%-16s", knp
->value
.c
);
211 * NOTE - We need to be more careful able what tokens are
212 * used for each arch, for now this is correct for x86_64.
214 case KSTAT_DATA_INT32
:
215 seq_printf(f
, "%d", knp
->value
.i32
);
217 case KSTAT_DATA_UINT32
:
218 seq_printf(f
, "%u", knp
->value
.ui32
);
220 case KSTAT_DATA_INT64
:
221 seq_printf(f
, "%lld", (signed long long)knp
->value
.i64
);
223 case KSTAT_DATA_UINT64
:
224 seq_printf(f
, "%llu",
225 (unsigned long long)knp
->value
.ui64
);
227 case KSTAT_DATA_LONG
:
228 seq_printf(f
, "%ld", knp
->value
.l
);
230 case KSTAT_DATA_ULONG
:
231 seq_printf(f
, "%lu", knp
->value
.ul
);
233 case KSTAT_DATA_STRING
:
234 KSTAT_NAMED_STR_PTR(knp
)
235 [KSTAT_NAMED_STR_BUFLEN(knp
)-1] = '\0';
236 seq_printf(f
, "%s", KSTAT_NAMED_STR_PTR(knp
));
239 PANIC("Undefined kstat data type %d\n", knp
->data_type
);
248 kstat_seq_show_intr(struct seq_file
*f
, kstat_intr_t
*kip
)
250 seq_printf(f
, "%-8u %-8u %-8u %-8u %-8u\n",
251 kip
->intrs
[KSTAT_INTR_HARD
],
252 kip
->intrs
[KSTAT_INTR_SOFT
],
253 kip
->intrs
[KSTAT_INTR_WATCHDOG
],
254 kip
->intrs
[KSTAT_INTR_SPURIOUS
],
255 kip
->intrs
[KSTAT_INTR_MULTSVC
]);
261 kstat_seq_show_io(struct seq_file
*f
, kstat_io_t
*kip
)
264 "%-8llu %-8llu %-8u %-8u %-8lld %-8lld "
265 "%-8lld %-8lld %-8lld %-8lld %-8u %-8u\n",
266 kip
->nread
, kip
->nwritten
,
267 kip
->reads
, kip
->writes
,
268 kip
->wtime
, kip
->wlentime
, kip
->wlastupdate
,
269 kip
->rtime
, kip
->rlentime
, kip
->rlastupdate
,
270 kip
->wcnt
, kip
->rcnt
);
276 kstat_seq_show_timer(struct seq_file
*f
, kstat_timer_t
*ktp
)
279 "%-31s %-8llu %-8lld %-8lld %-8lld %-8lld %-8lld\n",
280 ktp
->name
, ktp
->num_events
, ktp
->elapsed_time
,
281 ktp
->min_time
, ktp
->max_time
,
282 ktp
->start_time
, ktp
->stop_time
);
288 kstat_seq_show(struct seq_file
*f
, void *p
)
290 kstat_t
*ksp
= (kstat_t
*)f
->private;
293 ASSERT(ksp
->ks_magic
== KS_MAGIC
);
295 switch (ksp
->ks_type
) {
298 if (ksp
->ks_raw_ops
.data
) {
299 rc
= ksp
->ks_raw_ops
.data(
300 ksp
->ks_raw_buf
, ksp
->ks_raw_bufsize
, p
);
301 if (rc
== ENOMEM
&& !kstat_resize_raw(ksp
))
304 seq_puts(f
, ksp
->ks_raw_buf
);
306 ASSERT(ksp
->ks_ndata
== 1);
307 rc
= kstat_seq_show_raw(f
, ksp
->ks_data
,
311 case KSTAT_TYPE_NAMED
:
312 rc
= kstat_seq_show_named(f
, (kstat_named_t
*)p
);
314 case KSTAT_TYPE_INTR
:
315 rc
= kstat_seq_show_intr(f
, (kstat_intr_t
*)p
);
318 rc
= kstat_seq_show_io(f
, (kstat_io_t
*)p
);
320 case KSTAT_TYPE_TIMER
:
321 rc
= kstat_seq_show_timer(f
, (kstat_timer_t
*)p
);
324 PANIC("Undefined kstat type %d\n", ksp
->ks_type
);
331 kstat_default_update(kstat_t
*ksp
, int rw
)
335 if (rw
== KSTAT_WRITE
)
342 kstat_seq_data_addr(kstat_t
*ksp
, loff_t n
)
346 switch (ksp
->ks_type
) {
348 if (ksp
->ks_raw_ops
.addr
)
349 rc
= ksp
->ks_raw_ops
.addr(ksp
, n
);
353 case KSTAT_TYPE_NAMED
:
354 rc
= ksp
->ks_data
+ n
* sizeof (kstat_named_t
);
356 case KSTAT_TYPE_INTR
:
357 rc
= ksp
->ks_data
+ n
* sizeof (kstat_intr_t
);
360 rc
= ksp
->ks_data
+ n
* sizeof (kstat_io_t
);
362 case KSTAT_TYPE_TIMER
:
363 rc
= ksp
->ks_data
+ n
* sizeof (kstat_timer_t
);
366 PANIC("Undefined kstat type %d\n", ksp
->ks_type
);
373 kstat_seq_start(struct seq_file
*f
, loff_t
*pos
)
376 kstat_t
*ksp
= (kstat_t
*)f
->private;
377 ASSERT(ksp
->ks_magic
== KS_MAGIC
);
379 mutex_enter(ksp
->ks_lock
);
381 if (ksp
->ks_type
== KSTAT_TYPE_RAW
) {
382 ksp
->ks_raw_bufsize
= PAGE_SIZE
;
383 ksp
->ks_raw_buf
= vmem_alloc(ksp
->ks_raw_bufsize
, KM_SLEEP
);
386 /* Dynamically update kstat, on error existing kstats are used */
387 (void) ksp
->ks_update(ksp
, KSTAT_READ
);
389 ksp
->ks_snaptime
= gethrtime();
391 if (!(ksp
->ks_flags
& KSTAT_FLAG_NO_HEADERS
) && !n
&&
392 kstat_seq_show_headers(f
))
395 if (n
>= ksp
->ks_ndata
)
398 return (kstat_seq_data_addr(ksp
, n
));
402 kstat_seq_next(struct seq_file
*f
, void *p
, loff_t
*pos
)
404 kstat_t
*ksp
= (kstat_t
*)f
->private;
405 ASSERT(ksp
->ks_magic
== KS_MAGIC
);
408 if (*pos
>= ksp
->ks_ndata
)
411 return (kstat_seq_data_addr(ksp
, *pos
));
415 kstat_seq_stop(struct seq_file
*f
, void *v
)
417 kstat_t
*ksp
= (kstat_t
*)f
->private;
418 ASSERT(ksp
->ks_magic
== KS_MAGIC
);
420 if (ksp
->ks_type
== KSTAT_TYPE_RAW
)
421 vmem_free(ksp
->ks_raw_buf
, ksp
->ks_raw_bufsize
);
423 mutex_exit(ksp
->ks_lock
);
426 static struct seq_operations kstat_seq_ops
= {
427 .show
= kstat_seq_show
,
428 .start
= kstat_seq_start
,
429 .next
= kstat_seq_next
,
430 .stop
= kstat_seq_stop
,
433 static kstat_module_t
*
434 kstat_find_module(char *name
)
436 kstat_module_t
*module
;
438 list_for_each_entry(module
, &kstat_module_list
, ksm_module_list
) {
439 if (strncmp(name
, module
->ksm_name
, KSTAT_STRLEN
) == 0)
446 static kstat_module_t
*
447 kstat_create_module(char *name
)
449 kstat_module_t
*module
;
450 struct proc_dir_entry
*pde
;
452 pde
= proc_mkdir(name
, proc_spl_kstat
);
456 module
= kmem_alloc(sizeof (kstat_module_t
), KM_SLEEP
);
457 module
->ksm_proc
= pde
;
458 strlcpy(module
->ksm_name
, name
, KSTAT_STRLEN
+1);
459 INIT_LIST_HEAD(&module
->ksm_kstat_list
);
460 list_add_tail(&module
->ksm_module_list
, &kstat_module_list
);
467 kstat_delete_module(kstat_module_t
*module
)
469 ASSERT(list_empty(&module
->ksm_kstat_list
));
470 remove_proc_entry(module
->ksm_name
, proc_spl_kstat
);
471 list_del(&module
->ksm_module_list
);
472 kmem_free(module
, sizeof (kstat_module_t
));
476 proc_kstat_open(struct inode
*inode
, struct file
*filp
)
481 rc
= seq_open(filp
, &kstat_seq_ops
);
485 f
= filp
->private_data
;
486 f
->private = PDE_DATA(inode
);
492 proc_kstat_write(struct file
*filp
, const char __user
*buf
, size_t len
,
495 struct seq_file
*f
= filp
->private_data
;
496 kstat_t
*ksp
= f
->private;
499 ASSERT(ksp
->ks_magic
== KS_MAGIC
);
501 mutex_enter(ksp
->ks_lock
);
502 rc
= ksp
->ks_update(ksp
, KSTAT_WRITE
);
503 mutex_exit(ksp
->ks_lock
);
512 static struct file_operations proc_kstat_operations
= {
513 .open
= proc_kstat_open
,
514 .write
= proc_kstat_write
,
517 .release
= seq_release
,
521 __kstat_set_raw_ops(kstat_t
*ksp
,
522 int (*headers
)(char *buf
, size_t size
),
523 int (*data
)(char *buf
, size_t size
, void *data
),
524 void *(*addr
)(kstat_t
*ksp
, loff_t index
))
526 ksp
->ks_raw_ops
.headers
= headers
;
527 ksp
->ks_raw_ops
.data
= data
;
528 ksp
->ks_raw_ops
.addr
= addr
;
530 EXPORT_SYMBOL(__kstat_set_raw_ops
);
533 __kstat_create(const char *ks_module
, int ks_instance
, const char *ks_name
,
534 const char *ks_class
, uchar_t ks_type
, uint_t ks_ndata
,
540 ASSERT(ks_instance
== 0);
543 if ((ks_type
== KSTAT_TYPE_INTR
) || (ks_type
== KSTAT_TYPE_IO
))
544 ASSERT(ks_ndata
== 1);
546 ksp
= kmem_zalloc(sizeof (*ksp
), KM_SLEEP
);
550 mutex_enter(&kstat_module_lock
);
551 ksp
->ks_kid
= kstat_id
;
553 mutex_exit(&kstat_module_lock
);
555 ksp
->ks_magic
= KS_MAGIC
;
556 mutex_init(&ksp
->ks_private_lock
, NULL
, MUTEX_DEFAULT
, NULL
);
557 ksp
->ks_lock
= &ksp
->ks_private_lock
;
558 INIT_LIST_HEAD(&ksp
->ks_list
);
560 ksp
->ks_crtime
= gethrtime();
561 ksp
->ks_snaptime
= ksp
->ks_crtime
;
562 strncpy(ksp
->ks_module
, ks_module
, KSTAT_STRLEN
);
563 ksp
->ks_instance
= ks_instance
;
564 strncpy(ksp
->ks_name
, ks_name
, KSTAT_STRLEN
);
565 strncpy(ksp
->ks_class
, ks_class
, KSTAT_STRLEN
);
566 ksp
->ks_type
= ks_type
;
567 ksp
->ks_flags
= ks_flags
;
568 ksp
->ks_update
= kstat_default_update
;
569 ksp
->ks_private
= NULL
;
570 ksp
->ks_raw_ops
.headers
= NULL
;
571 ksp
->ks_raw_ops
.data
= NULL
;
572 ksp
->ks_raw_ops
.addr
= NULL
;
573 ksp
->ks_raw_buf
= NULL
;
574 ksp
->ks_raw_bufsize
= 0;
576 switch (ksp
->ks_type
) {
579 ksp
->ks_data_size
= ks_ndata
;
581 case KSTAT_TYPE_NAMED
:
582 ksp
->ks_ndata
= ks_ndata
;
583 ksp
->ks_data_size
= ks_ndata
* sizeof (kstat_named_t
);
585 case KSTAT_TYPE_INTR
:
586 ksp
->ks_ndata
= ks_ndata
;
587 ksp
->ks_data_size
= ks_ndata
* sizeof (kstat_intr_t
);
590 ksp
->ks_ndata
= ks_ndata
;
591 ksp
->ks_data_size
= ks_ndata
* sizeof (kstat_io_t
);
593 case KSTAT_TYPE_TIMER
:
594 ksp
->ks_ndata
= ks_ndata
;
595 ksp
->ks_data_size
= ks_ndata
* sizeof (kstat_timer_t
);
598 PANIC("Undefined kstat type %d\n", ksp
->ks_type
);
601 if (ksp
->ks_flags
& KSTAT_FLAG_VIRTUAL
) {
604 ksp
->ks_data
= kmem_zalloc(ksp
->ks_data_size
, KM_SLEEP
);
605 if (ksp
->ks_data
== NULL
) {
606 kmem_free(ksp
, sizeof (*ksp
));
613 EXPORT_SYMBOL(__kstat_create
);
616 kstat_detect_collision(kstat_t
*ksp
)
618 kstat_module_t
*module
;
623 parent
= kmem_asprintf("%s", ksp
->ks_module
);
625 if ((cp
= strrchr(parent
, '/')) == NULL
) {
631 if ((module
= kstat_find_module(parent
)) != NULL
) {
632 list_for_each_entry(tmp
, &module
->ksm_kstat_list
, ks_list
) {
633 if (strncmp(tmp
->ks_name
, cp
+1, KSTAT_STRLEN
) == 0) {
645 __kstat_install(kstat_t
*ksp
)
647 kstat_module_t
*module
;
652 mutex_enter(&kstat_module_lock
);
654 module
= kstat_find_module(ksp
->ks_module
);
655 if (module
== NULL
) {
656 if (kstat_detect_collision(ksp
) != 0) {
657 cmn_err(CE_WARN
, "kstat_create('%s', '%s'): namespace" \
658 " collision", ksp
->ks_module
, ksp
->ks_name
);
661 module
= kstat_create_module(ksp
->ks_module
);
667 * Only one entry by this name per-module, on failure the module
668 * shouldn't be deleted because we know it has at least one entry.
670 list_for_each_entry(tmp
, &module
->ksm_kstat_list
, ks_list
) {
671 if (strncmp(tmp
->ks_name
, ksp
->ks_name
, KSTAT_STRLEN
) == 0)
675 list_add_tail(&ksp
->ks_list
, &module
->ksm_kstat_list
);
677 mutex_enter(ksp
->ks_lock
);
678 ksp
->ks_owner
= module
;
679 ksp
->ks_proc
= proc_create_data(ksp
->ks_name
, 0644,
680 module
->ksm_proc
, &proc_kstat_operations
, (void *)ksp
);
681 if (ksp
->ks_proc
== NULL
) {
682 list_del_init(&ksp
->ks_list
);
683 if (list_empty(&module
->ksm_kstat_list
))
684 kstat_delete_module(module
);
686 mutex_exit(ksp
->ks_lock
);
688 mutex_exit(&kstat_module_lock
);
690 EXPORT_SYMBOL(__kstat_install
);
693 __kstat_delete(kstat_t
*ksp
)
695 kstat_module_t
*module
= ksp
->ks_owner
;
697 mutex_enter(&kstat_module_lock
);
698 list_del_init(&ksp
->ks_list
);
699 mutex_exit(&kstat_module_lock
);
702 remove_proc_entry(ksp
->ks_name
, module
->ksm_proc
);
704 /* Remove top level module directory if it's empty */
705 if (list_empty(&module
->ksm_kstat_list
))
706 kstat_delete_module(module
);
709 if (!(ksp
->ks_flags
& KSTAT_FLAG_VIRTUAL
))
710 kmem_free(ksp
->ks_data
, ksp
->ks_data_size
);
713 mutex_destroy(&ksp
->ks_private_lock
);
714 kmem_free(ksp
, sizeof (*ksp
));
716 EXPORT_SYMBOL(__kstat_delete
);
721 mutex_init(&kstat_module_lock
, NULL
, MUTEX_DEFAULT
, NULL
);
722 INIT_LIST_HEAD(&kstat_module_list
);
730 ASSERT(list_empty(&kstat_module_list
));
731 mutex_destroy(&kstat_module_lock
);