[src/trunk]: src/sys/kern add some event counters, for commits, writes, cache...

[jdolecek <jdolecek%NetBSD.org@localhost>]

details:   https://anonhg.NetBSD.org/src/rev/c12c7162e583
branches:  trunk
changeset: 822156:c12c7162e583
user:      jdolecek <jdolecek%NetBSD.org@localhost>
date:      Sun Mar 05 13:57:29 2017 +0000

description:
add some event counters, for commits, writes, cache flush

diffstat:

 sys/kern/vfs_wapbl.c |  57 +++++++++++++++++++++++++++++++++++++++++++++++++--
 1 files changed, 54 insertions(+), 3 deletions(-)

diffs (141 lines):

diff -r 0be05702d12a -r c12c7162e583 sys/kern/vfs_wapbl.c
--- a/sys/kern/vfs_wapbl.c      Sun Mar 05 11:52:38 2017 +0000
+++ b/sys/kern/vfs_wapbl.c      Sun Mar 05 13:57:29 2017 +0000
@@ -1,4 +1,4 @@
-/*     $NetBSD: vfs_wapbl.c,v 1.86 2016/11/10 20:56:32 jdolecek Exp $  */
+/*     $NetBSD: vfs_wapbl.c,v 1.87 2017/03/05 13:57:29 jdolecek Exp $  */
 
 /*-
  * Copyright (c) 2003, 2008, 2009 The NetBSD Foundation, Inc.
@@ -36,7 +36,7 @@
 #define WAPBL_INTERNAL
 
 #include <sys/cdefs.h>
-__KERNEL_RCSID(0, "$NetBSD: vfs_wapbl.c,v 1.86 2016/11/10 20:56:32 jdolecek Exp $");
+__KERNEL_RCSID(0, "$NetBSD: vfs_wapbl.c,v 1.87 2017/03/05 13:57:29 jdolecek Exp $");
 
 #include <sys/param.h>
 #include <sys/bitops.h>
@@ -176,14 +176,21 @@
         * wl_count or wl_bufs or head or tail
         */
 
+#if _KERNEL
        /*
         * Callback called from within the flush routine to flush any extra
         * bits.  Note that flush may be skipped without calling this if
         * there are no outstanding buffers in the transaction.
         */
-#if _KERNEL
        wapbl_flush_fn_t wl_flush;      /* r    */
        wapbl_flush_fn_t wl_flush_abort;/* r    */
+
+       /* Event counters */
+       char wl_ev_group[EVCNT_STRING_MAX];     /* r    */
+       struct evcnt wl_ev_commit;              /* l    */
+       struct evcnt wl_ev_journalwrite;        /* l    */
+       struct evcnt wl_ev_metawrite;           /* lm   */
+       struct evcnt wl_ev_cacheflush;          /* l    */
 #endif
 
        size_t wl_bufbytes;     /* m:   Byte count of pages in wl_bufs */
@@ -270,6 +277,9 @@
 static void wapbl_deallocation_free(struct wapbl *, struct wapbl_dealloc *,
        bool);
 
+static void wapbl_evcnt_init(struct wapbl *);
+static void wapbl_evcnt_free(struct wapbl *);
+
 #if 0
 int wapbl_replay_verify(struct wapbl_replay *, struct vnode *);
 #endif
@@ -352,6 +362,34 @@
        return 0;
 }
 
+static void
+wapbl_evcnt_init(struct wapbl *wl)
+{
+       snprintf(wl->wl_ev_group, sizeof(wl->wl_ev_group),
+           "wapbl fsid 0x%x/0x%x",
+           wl->wl_mount->mnt_stat.f_fsidx.__fsid_val[0],
+           wl->wl_mount->mnt_stat.f_fsidx.__fsid_val[1]
+       );
+
+       evcnt_attach_dynamic(&wl->wl_ev_commit, EVCNT_TYPE_MISC,
+           NULL, wl->wl_ev_group, "commit");
+       evcnt_attach_dynamic(&wl->wl_ev_journalwrite, EVCNT_TYPE_MISC,
+           NULL, wl->wl_ev_group, "journal sync block write");
+       evcnt_attach_dynamic(&wl->wl_ev_metawrite, EVCNT_TYPE_MISC,
+           NULL, wl->wl_ev_group, "metadata finished block write");
+       evcnt_attach_dynamic(&wl->wl_ev_cacheflush, EVCNT_TYPE_MISC,
+           NULL, wl->wl_ev_group, "cache flush");
+}
+
+static void
+wapbl_evcnt_free(struct wapbl *wl)
+{
+       evcnt_detach(&wl->wl_ev_commit);
+       evcnt_detach(&wl->wl_ev_journalwrite);
+       evcnt_detach(&wl->wl_ev_metawrite);
+       evcnt_detach(&wl->wl_ev_cacheflush);
+}
+
 static int
 wapbl_start_flush_inodes(struct wapbl *wl, struct wapbl_replay *wr)
 {
@@ -522,6 +560,8 @@
 
        wapbl_inodetrk_init(wl, WAPBL_INODETRK_SIZE);
 
+       wapbl_evcnt_init(wl);
+
        /* Initialize the commit header */
        {
                struct wapbl_wc_header *wc;
@@ -746,6 +786,8 @@
        wapbl_free(wl->wl_buffer, MAXPHYS);
        wapbl_inodetrk_free(wl);
 
+       wapbl_evcnt_free(wl);
+
        cv_destroy(&wl->wl_reclaimable_cv);
        mutex_destroy(&wl->wl_mtx);
        rw_destroy(&wl->wl_rwlock);
@@ -858,6 +900,8 @@
            wl->wl_devvp, wl->wl_buffer_dblk, B_WRITE);
        wl->wl_buffer_used = 0;
 
+       wl->wl_ev_journalwrite.ev_count++;
+
        return error;
 }
 
@@ -1471,6 +1515,7 @@
        KASSERT(wl->wl_unsynced_bufbytes >= bufsize);
        wl->wl_unsynced_bufbytes -= bufsize;
 #endif
+       wl->wl_ev_metawrite.ev_count++;
 
        /*
         * If the current transaction can be reclaimed, start
@@ -2179,6 +2224,9 @@
                    msg, (uintmax_t)wl->wl_devvp->v_rdev,
                    (uintmax_t)ts.tv_sec, ts.tv_nsec);
        }
+
+       wl->wl_ev_cacheflush.ev_count++;
+
        return error;
 }
 
@@ -2269,6 +2317,9 @@
                        panic("wapbl_write_commit: error writing duplicate "
                              "log header: %d", error);
        }
+
+       wl->wl_ev_commit.ev_count++;
+
        return 0;
 }