Page MenuHomeFreeBSD
Differential D1626 Diff 3371 usr.bin/nfsstat/nfsstat.c

Changeset View

Standalone View

View Options

usr.bin/nfsstat/nfsstat.c

Context not available.
* OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
* SUCH DAMAGE. * SUCH DAMAGE.
*/ */
/*-
* Copyright (c) 2004, 2008, 2009 Silicon Graphics International Corp.
* All rights reserved.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions
* are met:
* 1. Redistributions of source code must retain the above copyright
* notice, this list of conditions, and the following disclaimer,
* without modification.
* 2. Redistributions in binary form must reproduce at minimum a disclaimer
* substantially similar to the "NO WARRANTY" disclaimer below
* ("Disclaimer") and any redistribution must be conditioned upon
* including a substantially similar Disclaimer requirement for further
* binary redistribution.
*
* NO WARRANTY
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
* "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
* LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTIBILITY AND FITNESS FOR
* A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
* HOLDERS OR CONTRIBUTORS BE LIABLE FOR SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
* DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
* OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
* HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
* STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING
* IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
* POSSIBILITY OF SUCH DAMAGES.
*/
#ifndef lint #ifndef lint
static const char copyright[] = static const char copyright[] =
"@(#) Copyright (c) 1983, 1989, 1993\n\ "@(#) Copyright (c) 1983, 1989, 1993\n\
Context not available.
#include <stdlib.h> #include <stdlib.h>
#include <string.h> #include <string.h>
#include <paths.h> #include <paths.h>
#include <devstat.h>
#include <err.h> #include <err.h>
struct nlist nl[] = { struct nlist nl[] = {
Context not available.
static int extra_output = 0; static int extra_output = 0;
void intpr(int, int); void intpr(int, int);
void printhdr(int, int); void printhdr(int, int, int);
void sidewaysintpr(u_int, int, int); void sidewaysintpr(u_int, int, int);
void usage(void); void usage(void);
char *sperc1(int, int); char *sperc1(int, int);
char *sperc2(int, int); char *sperc2(int, int);
void exp_intpr(int, int); void exp_intpr(int, int);
void exp_sidewaysintpr(u_int, int, int); void exp_sidewaysintpr(u_int, int, int, int);
void compute_new_stats(struct ext_nfsstats *cur_stats,
struct ext_nfsstats *prev_stats, int curop, long double etime,
long double *mbsec, long double *kb_per_transfer,
long double *transfers_per_second, long double *ms_per_transfer,
kenUnsubmitted
Not Done
Inline Actions

This needs to be declared static ("static struct stattypes...") to fix a build warning/error with clang at least.

ken: This needs to be declared static ("static struct stattypes...") to fix a build warning/error…
uint64_t *queue_len, long double *busy_pct);
#define DELTA(field) (nfsstats.field - lastst.field) #define DELTA(field) (nfsstats.field - lastst.field)
#define STAT_TYPE_READ 0
#define STAT_TYPE_WRITE 1
#define STAT_TYPE_COMMIT 2
#define NUM_STAT_TYPES 3
struct stattypes {
int stat_type;
int nfs_type;
} statstruct[] = {
{STAT_TYPE_READ, NFSV4OP_READ},
{STAT_TYPE_WRITE, NFSV4OP_WRITE},
{STAT_TYPE_COMMIT, NFSV4OP_COMMIT}
};
#define STAT_TYPE_TO_NFS(stat_type) statstruct[stat_type].nfs_type
int int
main(int argc, char **argv) main(int argc, char **argv)
{ {
Context not available.
u_int interval; u_int interval;
int clientOnly = -1; int clientOnly = -1;
int serverOnly = -1; int serverOnly = -1;
int newStats = 0;
int ch; int ch;
char *memf, *nlistf; char *memf, *nlistf;
char errbuf[_POSIX2_LINE_MAX]; char errbuf[_POSIX2_LINE_MAX];
Context not available.
interval = 0; interval = 0;
memf = nlistf = NULL; memf = nlistf = NULL;
while ((ch = getopt(argc, argv, "cesWM:mN:ow:z")) != -1) while ((ch = getopt(argc, argv, "cdesWM:mN:ow:z")) != -1)
switch(ch) { switch(ch) {
case 'M': case 'M':
memf = optarg; memf = optarg;
Context not available.
if (serverOnly < 0) if (serverOnly < 0)
serverOnly = 0; serverOnly = 0;
break; break;
case 'd':
newStats = 1;
break;
case 's': case 's':
serverOnly = 1; serverOnly = 1;
if (clientOnly < 0) if (clientOnly < 0)
Context not available.
if (interval) { if (interval) {
if (run_v4 > 0) if (run_v4 > 0)
exp_sidewaysintpr(interval, clientOnly, serverOnly); exp_sidewaysintpr(interval, clientOnly, serverOnly,
newStats);
else else
sidewaysintpr(interval, clientOnly, serverOnly); sidewaysintpr(interval, clientOnly, serverOnly);
} else { } else {
Context not available.
nfsstatsp = &lastst; nfsstatsp = &lastst;
nfsrvstatsp = &lastsrvst; nfsrvstatsp = &lastsrvst;
readstats(&nfsstatsp, &nfsrvstatsp, 0); readstats(&nfsstatsp, &nfsrvstatsp, 0);
if (clientOnly && !nfsstatsp) { if (clientOnly && !nfsstatsp) {
printf("Client not present!\n"); printf("Client not present!\n");
clientOnly = 0; clientOnly = 0;
Context not available.
readstats(&nfsstatsp, &nfsrvstatsp, 0); readstats(&nfsstatsp, &nfsrvstatsp, 0);
if (--hdrcnt == 0) { if (--hdrcnt == 0) {
printhdr(clientOnly, serverOnly); printhdr(clientOnly, serverOnly, 0);
if (clientOnly && serverOnly) if (clientOnly && serverOnly)
hdrcnt = 10; hdrcnt = 10;
else else
Context not available.
} }
void void
printhdr(int clientOnly, int serverOnly) printhdr(int clientOnly, int serverOnly, int newStats)
{ {
printf("%s%6.6s %6.6s %6.6s %6.6s %6.6s %6.6s %6.6s %6.6s", if (newStats) {
((serverOnly && clientOnly) ? " " : " "), printf(
"GtAttr", "Lookup", "Rdlink", "Read", "Write", "Rename", " [%s Read %s] [%s Write %s] %s[=========== Total ============]\n"
"Access", "Rddir"); " KB/t tps MB/s%s KB/t tps MB/s%s %sKB/t tps MB/s ms ql %%b",
if (widemode && clientOnly) { widemode ? "========" : "=====",
printf(" Attr Lkup BioR BioW Accs BioD"); widemode ? "========" : "=====",
widemode ? "========" : "=====",
widemode ? "=======" : "====",
widemode ? "[Commit ] " : "",
widemode ? " ms" : "",
widemode ? " ms" : "",
widemode ? "tps ms " : "");
} else {
printf("%s%6.6s %6.6s %6.6s %6.6s %6.6s %6.6s %6.6s %6.6s",
((serverOnly && clientOnly) ? " " : " "),
"GtAttr", "Lookup", "Rdlink", "Read", "Write", "Rename",
"Access", "Rddir");
if (widemode && clientOnly) {
printf(" Attr Lkup BioR BioW Accs BioD");
}
} }
printf("\n"); printf("\n");
fflush(stdout); fflush(stdout);
Context not available.
usage(void) usage(void)
{ {
(void)fprintf(stderr, (void)fprintf(stderr,
"usage: nfsstat [-cemoszW] [-M core] [-N system] [-w wait]\n"); "usage: nfsstat [-cdemoszW] [-M core] [-N system] [-w wait]\n");
exit(1); exit(1);
} }
Context not available.
return(p); return(p);
} }
#define DELTA_T(field) \
devstat_compute_etime(&cur_stats->field, \
(prev_stats ? &prev_stats->field : NULL))
/* /*
* XXX KDM mostly copied from ctlstat. We should commonize the code (and
* the devstat code) somehow.
*/
void
compute_new_stats(struct ext_nfsstats *cur_stats,
struct ext_nfsstats *prev_stats, int curop,
long double etime, long double *mbsec,
long double *kb_per_transfer,
long double *transfers_per_second,
long double *ms_per_transfer, uint64_t *queue_len,
long double *busy_pct)
{
uint64_t total_bytes = 0, total_operations = 0;
struct bintime total_time_bt;
struct timespec total_time_ts;
bzero(&total_time_bt, sizeof(total_time_bt));
bzero(&total_time_ts, sizeof(total_time_ts));
total_bytes = cur_stats->srvbytes[curop];
total_operations = cur_stats->srvops[curop];
if (prev_stats != NULL) {
total_bytes -= prev_stats->srvbytes[curop];
total_operations -= prev_stats->srvops[curop];
}
*mbsec = total_bytes;
*mbsec /= 1024 * 1024;
if (etime > 0.0) {
*busy_pct = DELTA_T(busytime);
if (*busy_pct < 0)
*busy_pct = 0;
*busy_pct /= etime;
*busy_pct *= 100;
if (*busy_pct < 0)
*busy_pct = 0;
*mbsec /= etime;
} else {
*busy_pct = 0;
*mbsec = 0;
}
*kb_per_transfer = total_bytes;
*kb_per_transfer /= 1024;
if (total_operations > 0)
*kb_per_transfer /= total_operations;
else
*kb_per_transfer = 0;
if (etime > 0.0) {
*transfers_per_second = total_operations;
*transfers_per_second /= etime;
} else {
*transfers_per_second = 0.0;
}
if (total_operations > 0) {
*ms_per_transfer = DELTA_T(srvduration[curop]);
*ms_per_transfer /= total_operations;
*ms_per_transfer *= 1000;
} else
*ms_per_transfer = 0.0;
*queue_len = cur_stats->srvstartcnt - cur_stats->srvdonecnt;
}
/*
* Print a description of the nfs stats for the experimental client/server. * Print a description of the nfs stats for the experimental client/server.
*/ */
void void
Context not available.
} }
} }
static void
compute_totals(struct ext_nfsstats *total_stats, struct ext_nfsstats *cur_stats)
{
int i;
bzero(total_stats, sizeof(*total_stats));
for (i = 0; i < (NFSV4OP_NOPS + NFSV4OP_FAKENOPS); i++) {
total_stats->srvbytes[0] += cur_stats->srvbytes[i];
total_stats->srvops[0] += cur_stats->srvops[i];
bintime_add(&total_stats->srvduration[0],
&cur_stats->srvduration[i]);
total_stats->srvrpccnt[i] = cur_stats->srvrpccnt[i];
}
total_stats->srvstartcnt = cur_stats->srvstartcnt;
total_stats->srvdonecnt = cur_stats->srvdonecnt;
total_stats->busytime = cur_stats->busytime;
}
/* /*
* Print a running summary of nfs statistics for the experimental client and/or * Print a running summary of nfs statistics for the experimental client and/or
* server. * server.
Context not available.
* First line printed at top of screen is always cumulative. * First line printed at top of screen is always cumulative.
*/ */
void void
exp_sidewaysintpr(u_int interval, int clientOnly, int serverOnly) exp_sidewaysintpr(u_int interval, int clientOnly, int serverOnly,
int newStats)
{ {
struct ext_nfsstats nfsstats, lastst, *ext_nfsstatsp; struct ext_nfsstats nfsstats, lastst, *ext_nfsstatsp;
struct ext_nfsstats curtotal, lasttotal;
struct timespec ts, lastts;
int hdrcnt = 1; int hdrcnt = 1;
ext_nfsstatsp = &lastst; ext_nfsstatsp = &lastst;
if (nfssvc(NFSSVC_GETSTATS, ext_nfsstatsp) < 0) if (nfssvc(NFSSVC_GETSTATS, ext_nfsstatsp) < 0)
err(1, "Can't get stats"); err(1, "Can't get stats");
clock_gettime(CLOCK_MONOTONIC, &lastts);
compute_totals(&lasttotal, ext_nfsstatsp);
sleep(interval); sleep(interval);
for (;;) { for (;;) {
Context not available.
ext_nfsstatsp = &nfsstats; ext_nfsstatsp = &nfsstats;
if (nfssvc(NFSSVC_GETSTATS, ext_nfsstatsp) < 0) if (nfssvc(NFSSVC_GETSTATS, ext_nfsstatsp) < 0)
err(1, "Can't get stats"); err(1, "Can't get stats");
clock_gettime(CLOCK_MONOTONIC, &ts);
if (--hdrcnt == 0) { if (--hdrcnt == 0) {
printhdr(clientOnly, serverOnly); printhdr(clientOnly, serverOnly, newStats);
if (clientOnly && serverOnly) if (newStats)
hdrcnt = 20;
else if (clientOnly && serverOnly)
hdrcnt = 10; hdrcnt = 10;
else else
hdrcnt = 20; hdrcnt = 20;
} }
if (clientOnly) { if (clientOnly && newStats == 0) {
printf("%s %6d %6d %6d %6d %6d %6d %6d %6d", printf("%s %6d %6d %6d %6d %6d %6d %6d %6d",
((clientOnly && serverOnly) ? "Client:" : ""), ((clientOnly && serverOnly) ? "Client:" : ""),
DELTA(rpccnt[NFSPROC_GETATTR]), DELTA(rpccnt[NFSPROC_GETATTR]),
Context not available.
} }
printf("\n"); printf("\n");
} }
if (serverOnly) {
if (serverOnly && newStats) {
long double cur_secs, last_secs, etime;
long double mbsec;
long double kb_per_transfer;
long double transfers_per_second;
long double ms_per_transfer;
uint64_t queue_len;
long double busy_pct;
int i;
cur_secs = ts.tv_sec +
((long double)ts.tv_nsec / 1000000000);
last_secs = lastts.tv_sec +
((long double)lastts.tv_nsec / 1000000000);
etime = cur_secs - last_secs;
compute_totals(&curtotal, &nfsstats);
for (i = 0; i < NUM_STAT_TYPES; i++) {
compute_new_stats(&nfsstats, &lastst,
STAT_TYPE_TO_NFS(i), etime, &mbsec,
&kb_per_transfer,
&transfers_per_second,
&ms_per_transfer, &queue_len,
&busy_pct);
if (i == STAT_TYPE_COMMIT) {
if (widemode == 0)
continue;
printf("%2.0Lf %7.2Lf ",
transfers_per_second,
ms_per_transfer);
} else {
printf("%5.2Lf %5.0Lf %7.2Lf ",
kb_per_transfer,
transfers_per_second, mbsec);
if (widemode)
printf("%5.2Lf ",
ms_per_transfer);
}
}
compute_new_stats(&curtotal, &lasttotal, 0, etime,
&mbsec, &kb_per_transfer, &transfers_per_second,
&ms_per_transfer, &queue_len, &busy_pct);
printf("%5.2Lf %5.0Lf %7.2Lf %5.2Lf %3ju %3.0Lf\n",
kb_per_transfer, transfers_per_second, mbsec,
ms_per_transfer, queue_len, busy_pct);
} else if (serverOnly) {
printf("%s %6d %6d %6d %6d %6d %6d %6d %6d", printf("%s %6d %6d %6d %6d %6d %6d %6d %6d",
((clientOnly && serverOnly) ? "Server:" : ""), ((clientOnly && serverOnly) ? "Server:" : ""),
DELTA(srvrpccnt[NFSV4OP_GETATTR]), DELTA(srvrpccnt[NFSV4OP_GETATTR]),
Context not available.
DELTA(srvrpccnt[NFSV4OP_READDIRPLUS])); DELTA(srvrpccnt[NFSV4OP_READDIRPLUS]));
printf("\n"); printf("\n");
} }
lastst = nfsstats; bcopy(&nfsstats, &lastst, sizeof(lastst));
bcopy(&curtotal, &lasttotal, sizeof(lasttotal));
lastts = ts;
fflush(stdout); fflush(stdout);
sleep(interval); sleep(interval);
} }
Context not available.