zilstat

#!/bin/sh

OPT_MEGA=0
OPT_POOL=0
OPT_TIME=0
OPT_TXG=0
FILTER=0
POOL=
LINES=-1
INTERVAL=1
COUNT=-1

SCRIPT_PATH=/tmp/dtrace.zilstat

trap 'rm -f $SCRIPT_PATH' 0

while getopts hl:Mp:t OPT
do
    case $OPT in
    l)  LINES=$OPTARG
        ;;
    M)  OPT_MEGA=1
        ;;
    p)  OPT_POOL=1
        POOL=$OPTARG 
        ;;
    t)  OPT_TIME=1 
        ;;
    h|?)    
        ME="$(basename $0)"
        cat 2>&1 <<'        END' | sed -e 's/            //'
            Usage: $ME [gMt][-l linecount] [-p poolname] [INTERVAL [COUNT]]
        
            -M  # print numbers as megabytes (base 10)
            -t  # print timestamp
            -p poolname      # only look at poolname
            -l linecount     # print header every linecount lines (default=only once)
        
            interval in seconds or "txg" for transaction group commit intervals
            note: "txg" only appropriate when -p poolname is used
            count will limit the number of intervals reported
        
            examples:
                $ME # default output, 1 second samples
                $ME 10  # 10 second samples
                $ME 10 6    # print 6 x 10 second samples
                $ME -p rpool    # show ZIL stats for rpool only
        
            output:
                [TIME]
                N-Bytes    - data bytes written to ZIL over the interval
                N-Bytes/s  - data bytes/s written to ZIL over ther interval
                N-Max-Rate - maximum data rate during any 1-second sample
                B-Bytes    - buffer bytes written to ZIL over the interval
                B-Bytes/s  - buffer bytes/s written to ZIL over ther interval
                B-Max-Rate - maximum buffer rate during any 1-second sample
                ops        - number of synchronous iops per interval
                <=4kB      - number of synchronous iops <= 4kBytes per interval
                4-32kB     - number of synchronous iops 4-32kBytes per interval
                >=32kB     - number of synchronous iops >= 32kBytes per interval
        
                note: data bytes are actual data, total bytes counts buffer size
        END
        exit 1
		;;
    esac
done

shift $((OPTIND - 1))

### option logic
if [ "$1" != "" ] && ( [ "$1" = "txg" ] || [ "$1" -gt 0 ] ); then
    INTERVAL="$1"; 
    shift
fi

if [ "$1" != "" ] && ( [ "$1" = "txg" ] || [ "$1" -gt 0 ] ) ; then
    COUNT="$1";
    shift
fi

if [ "$OPT_POOL" -eq 1 ]; then
    FILTER=1
fi

case "$INTERVAL" in
    "txg")
        if [ "$OPT_POOL" -ne 1 ]; then
            echo "error: -p poolname option must be used for txg intervals"
            exit 1
        fi
        OPT_TXG=1
        INTERVAL=0
        ;;
    [0-9]*)
        ;;
    *)
        echo "error: interval must be a number or \"txg\""
        exit 1
        ;;
esac

cat > $SCRIPT_PATH << EOF
     #pragma D option quiet
     inline int OPT_TIME = $OPT_TIME;
     inline int OPT_TXG  = $OPT_TXG;
     inline int OPT_POOL = $OPT_POOL;
     inline int OPT_MEGA = $OPT_MEGA;
     inline int INTERVAL = $INTERVAL;
     inline int LINES    = $LINES;
     inline int COUNTER  = $COUNT;
     inline int FILTER   = $FILTER;
     inline string POOL  = "$POOL";
     dtrace:::BEGIN
     {
        /* starting values */
        mega = 1000000;
        counts = COUNTER;
        secs = INTERVAL;
        interval = INTERVAL;
        interval == 0 ? interval++ : 1;
        line = 0;
        last_event[""] = 0;
        nused=0;
        nused_max_per_sec=0;
        nused_per_sec=0;
        size=0;
        size_max_per_sec=0;
        size_per_sec=0;
        syncops=0;
        size_4k=0;
        size_4k_32k=0;
        size_32k=0;
        OPT_TXG ? printf("waiting for txg commit...\n") : 1;
     }

     /*
      * collect info when zil_lwb_write_start fires
      */
    fbt::zil_lwb_write_start:entry
    /OPT_POOL == 0 || POOL == args[0]->zl_dmu_pool->dp_spa->spa_name/
    {
         nused += args[1]->lwb_nused;
         nused_per_sec += args[1]->lwb_nused;
         size += args[1]->lwb_sz;
         size_per_sec += args[1]->lwb_sz;
         syncops++;
         args[1]->lwb_sz <= 4096 ? size_4k++ : 1;
         args[1]->lwb_sz > 4096 && args[1]->lwb_sz < 32768 ? size_4k_32k++ : 1;
         args[1]->lwb_sz >= 32768 ? size_32k++ : 1;
    }

    /*
     * Timer
     */
    profile:::tick-1sec
    {
        OPT_TXG ? secs++ : secs--;
            nused_per_sec > nused_max_per_sec ? nused_max_per_sec = nused_per_sec : 1;
            nused_per_sec = 0;
            size_per_sec > size_max_per_sec ? size_max_per_sec = size_per_sec : 1;
            size_per_sec = 0;
    }

    /*
     * Print header
     */
    profile:::tick-1sec
    /OPT_TXG == 0 && line == 0/
    {
        /* print optional headers */
        OPT_TIME   ? printf("%-20s ", "TIME")  : 1;

        /* print header */
            OPT_MEGA  ? printf("%10s %10s %10s %10s %10s %10s",
                    "N-MB", "N-MB/s", "N-Max-Rate",
                    "B-MB", "B-MB/s", "B-Max-Rate") :
                printf("%10s %10s %10s %10s %10s %10s",
                    "N-Bytes", "N-Bytes/s", "N-Max-Rate",
                    "B-Bytes", "B-Bytes/s", "B-Max-Rate");
            printf(" %6s %6s %6s %6s\n",
                    "ops", "<=4kB", "4-32kB", ">=32kB");
        line = LINES;
    }

    fbt::txg_quiesce:entry
    /OPT_TXG == 1 && POOL == args[0]->dp_spa->spa_name && line == 0/
    {
        OPT_TIME  ? printf("%-20s ", "TIME")  : 1;

            OPT_MEGA  ? printf("%10s %10s %10s %10s %10s %10s %10s",
                    "txg", "N-MB", "N-MB/s", "N-Max-Rate",
                    "B-MB", "B-MB/s", "B-Max-Rate") :
                printf("%10s %10s %10s %10s %10s %10s %10s",
                    "txg", "N-Bytes", "N-Bytes/s", "N-Max-Rate",
                    "B-Bytes", "B-Bytes/s", "B-Max-Rate");
            printf(" %6s %6s %6s %6s\n",
                    "ops", "<=4kB", "4-32kB", ">=32kB");
        line = LINES;
    }

     /*
      * Print Output
      */
    profile:::tick-1sec
    /OPT_TXG == 0 && secs == 0/
    {
        OPT_TIME  ? printf("%-20Y ", walltimestamp) : 1;
            OPT_MEGA  ?
                printf("%10d %10d %10d %10d %10d %10d",
                    nused/mega, nused/(mega*mega), nused_max_per_sec/mega,
                    size/mega, size/(interval*mega), size_max_per_sec/mega) :
                printf("%10d %10d %10d %10d %10d %10d",
                    nused, nused/interval, nused_max_per_sec,
                    size, size/interval, size_max_per_sec);
            printf(" %6d %6d %6d %6d\n",
                    syncops, size_4k, size_4k_32k, size_32k);
            nused = 0;
            nused_per_sec = 0;
            nused_max_per_sec = 0;
            size=0;
            size_max_per_sec=0;
            size_per_sec=0;
            syncops=0;
            size_4k=0;
            size_4k_32k=0;
            size_32k=0;
            secs = interval;
        counts--;
        line--;
    }

    fbt::txg_quiesce:entry
    /OPT_TXG == 1 && POOL == args[0]->dp_spa->spa_name/
    {
            secs <= 0 ? secs=1 : 1;
        OPT_TIME ? printf("%-20Y ", walltimestamp) : 1;
            OPT_MEGA ?
                printf("%10d %10d %10d %10d %10d %10d %10d", args[1],
                    nused/mega, nused/(secs*mega), nused_max_per_sec/mega,
                    size/mega, size/(secs*mega), size_max_per_sec/mega) :
                printf("%10d %10d %10d %10d %10d %10d %10d", args[1],
                    nused, nused/secs, nused_max_per_sec,
                    size, size/secs, size_max_per_sec);
            printf(" %6d %6d %6d %6d\n",
                    syncops, size_4k, size_4k_32k, size_32k);
            nused = 0;
            nused_per_sec = 0;
            nused_max_per_sec = 0;
            size=0;
            size_max_per_sec=0;
            size_per_sec=0;
            syncops=0;
            size_4k=0;
            size_4k_32k=0;
            size_32k=0;
            secs = 0;
        counts--;
        line--;
    }

    /*
    * End of program
    */
    profile:::tick-1sec
    /OPT_TXG == 0 && counts == 0/
    {
        exit(0);
    }

    fbt::txg_quiesce:entry
    /OPT_TXG == 1 && counts == 0/
    {
        exit(0);
    }
EOF

/usr/sbin/dtrace -s $SCRIPT_PATH