/* $OpenBSD: pppstats.c,v 1.10 2009/10/27 23:59:53 deraadt Exp $ */ /* * print PPP statistics: * pppstats [-a|-d] [-v|-r|-z] [-c count] [-w wait] [interface] * * -a Show absolute values rather than deltas * -d Show data rate (KB/s) rather than bytes * -v Show more stats for VJ TCP header compression * -r Show compression ratio * -z Show compression statistics instead of default display * * History: * perkins@cps.msu.edu: Added compression statistics and alternate * display. 11/94 * Brad Parker (brad@cayman.com) 6/92 * * from the original "slstats" by Van Jacobson: * * Contributed by Van Jacobson (van@ee.lbl.gov), Dec 31, 1989. * * Copyright (c) 1989, 1990, 1991, 1992 Regents of the University of * California. 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. * 2. Redistributions in binary form must reproduce the above copyright * notice, this list of conditions and the following disclaimer in the * documentation and/or other materials provided with the distribution. * 3. Neither the name of the University nor the names of its contributors * may be used to endorse or promote products derived from this software * without specific prior written permission. * * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE * FOR ANY DIRECT, INDIRECT, INCIDENTAL, 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 DAMAGE. */ #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include int vflag, rflag, zflag; /* select type of display */ int aflag; /* print absolute values, not deltas */ int dflag; /* print data rates, not bytes */ int interval, count; int infinite; int unit; int s; /* socket file descriptor */ int signalled; /* set if alarm goes off "early" */ char interface[IFNAMSIZ]; void usage(void); void catchalarm(int); void get_ppp_stats(struct ppp_stats *); void get_ppp_cstats(struct ppp_comp_stats *); void intpr(void); int main(int, char *argv[]); void usage() { extern char *__progname; fprintf(stderr, "usage: %s [-adrvz] [-c count] [-w wait] [interface]\n", __progname); exit(1); } /* * Called if an interval expires before intpr has completed a loop. * Sets a flag to not wait for the alarm. */ void catchalarm(arg) int arg; { signalled = 1; } void get_ppp_stats(curp) struct ppp_stats *curp; { struct ifpppstatsreq req; memset(&req, 0, sizeof(req)); (void)strlcpy(req.ifr_name, interface, sizeof(req.ifr_name)); if (ioctl(s, SIOCGPPPSTATS, &req) < 0) { if (errno == ENOTTY) errx(1, "kernel support missing"); else err(1, "couldn't get PPP statistics"); } *curp = req.stats; } void get_ppp_cstats(csp) struct ppp_comp_stats *csp; { struct ifpppcstatsreq creq; memset(&creq, 0, sizeof(creq)); (void)strlcpy(creq.ifr_name, interface, sizeof(creq.ifr_name)); if (ioctl(s, SIOCGPPPCSTATS, &creq) < 0) { if (errno == ENOTTY) { warnx("no kernel compression support"); if (zflag) exit(1); rflag = 0; } else err(1, "couldn't get PPP compression stats"); } *csp = creq.stats; } #define MAX0(a) ((int)(a) > 0? (a): 0) #define V(offset) MAX0(cur.offset - old.offset) #define W(offset) MAX0(ccs.offset - ocs.offset) #define RATIO(c, i, u) ((c) == 0? 1.0: (u) / ((double)(c) + (i))) #define CRATE(x) RATIO(W(x.comp_bytes), W(x.inc_bytes), W(x.unc_bytes)) #define KBPS(n) ((n) / (interval * 1000.0)) /* * Print a running summary of interface statistics. * Repeat display every interval seconds, showing statistics * collected over that interval. Assumes that interval is non-zero. * First line printed is cumulative. */ void intpr() { register int line = 0; sigset_t oldmask, mask; char *bunit; int ratef = 0; struct ppp_stats cur, old; struct ppp_comp_stats ccs, ocs; memset(&old, 0, sizeof(old)); memset(&ocs, 0, sizeof(ocs)); for (;;) { get_ppp_stats(&cur); if (zflag || rflag) get_ppp_cstats(&ccs); (void)signal(SIGALRM, catchalarm); signalled = 0; (void)alarm(interval); if ((line % 20) == 0) { if (zflag) { printf("IN: COMPRESSED INCOMPRESSIBLE COMP | "); printf("OUT: COMPRESSED INCOMPRESSIBLE COMP\n"); bunit = dflag? "KB/S": "BYTE"; printf(" %s PACK %s PACK RATIO | ", bunit, bunit); printf(" %s PACK %s PACK RATIO", bunit, bunit); } else { printf("%8.8s %6.6s %6.6s", "IN", "PACK", "VJCOMP"); if (!rflag) printf(" %6.6s %6.6s", "VJUNC", "VJERR"); if (vflag) printf(" %6.6s %6.6s", "VJTOSS", "NON-VJ"); if (rflag) printf(" %6.6s %6.6s", "RATIO", "UBYTE"); printf(" | %8.8s %6.6s %6.6s", "OUT", "PACK", "VJCOMP"); if (!rflag) printf(" %6.6s %6.6s", "VJUNC", "NON-VJ"); if (vflag) printf(" %6.6s %6.6s", "VJSRCH", "VJMISS"); if (rflag) printf(" %6.6s %6.6s", "RATIO", "UBYTE"); } putchar('\n'); } if (zflag) { if (ratef) { printf("%8.3f %6u %8.3f %6u %6.2f", KBPS(W(d.comp_bytes)), W(d.comp_packets), KBPS(W(d.inc_bytes)), W(d.inc_packets), ccs.d.ratio * 256.0); printf(" | %8.3f %6u %8.3f %6u %6.2f", KBPS(W(c.comp_bytes)), W(c.comp_packets), KBPS(W(c.inc_bytes)), W(c.inc_packets), ccs.c.ratio * 256.0); } else { printf("%8u %6u %8u %6u %6.2f", W(d.comp_bytes), W(d.comp_packets), W(d.inc_bytes), W(d.inc_packets), ccs.d.ratio * 256.0); printf(" | %8u %6u %8u %6u %6.2f", W(c.comp_bytes), W(c.comp_packets), W(c.inc_bytes), W(c.inc_packets), ccs.c.ratio * 256.0); } } else { if (ratef) printf("%8.3f", KBPS(V(p.ppp_ibytes))); else printf("%8u", V(p.ppp_ibytes)); printf(" %6u %6u", V(p.ppp_ipackets), V(vj.vjs_compressedin)); if (!rflag) printf(" %6u %6u", V(vj.vjs_uncompressedin), V(vj.vjs_errorin)); if (vflag) printf(" %6u %6u", V(vj.vjs_tossed), V(p.ppp_ipackets) - V(vj.vjs_compressedin) - V(vj.vjs_uncompressedin) - V(vj.vjs_errorin)); if (rflag) { printf(" %6.2f ", CRATE(d)); if (ratef) printf("%6.2f", KBPS(W(d.unc_bytes))); else printf("%6u", W(d.unc_bytes)); } if (ratef) printf(" | %8.3f", KBPS(V(p.ppp_obytes))); else printf(" | %8u", V(p.ppp_obytes)); printf(" %6u %6u", V(p.ppp_opackets), V(vj.vjs_compressed)); if (!rflag) printf(" %6u %6u", V(vj.vjs_packets) - V(vj.vjs_compressed), V(p.ppp_opackets) - V(vj.vjs_packets)); if (vflag) printf(" %6u %6u", V(vj.vjs_searches), V(vj.vjs_misses)); if (rflag) { printf(" %6.2f ", CRATE(c)); if (ratef) printf("%6.2f", KBPS(W(c.unc_bytes))); else printf("%6u", W(c.unc_bytes)); } } putchar('\n'); fflush(stdout); line++; count--; if (!infinite && !count) break; sigemptyset(&mask); sigaddset(&mask, SIGALRM); sigprocmask(SIG_BLOCK, &mask, &oldmask); if (signalled == 0) { sigemptyset(&mask); sigsuspend(&mask); } sigprocmask(SIG_SETMASK, &oldmask, NULL); signalled = 0; (void)alarm(interval); if (!aflag) { old = cur; ocs = ccs; ratef = dflag; } } } int main(argc, argv) int argc; char *argv[]; { int c; struct ifreq ifr; (void)strlcpy(interface, "ppp0", sizeof(interface)); while ((c = getopt(argc, argv, "advrzc:w:")) != -1) { switch (c) { case 'a': ++aflag; break; case 'd': ++dflag; break; case 'v': ++vflag; break; case 'r': ++rflag; break; case 'z': ++zflag; break; case 'c': count = atoi(optarg); if (count <= 0) usage(); break; case 'w': interval = atoi(optarg); if (interval <= 0) usage(); break; default: usage(); } } argc -= optind; argv += optind; if (!interval && count) interval = 5; if (interval && !count) infinite = 1; if (!interval && !count) count = 1; if (aflag) dflag = 0; if (argc > 1) usage(); if (argc > 0) (void)strlcpy(interface, argv[0], sizeof(interface)); if (sscanf(interface, "ppp%d", &unit) != 1 || unit < 0) errx(1, "invalid interface '%s' specified", interface); s = socket(AF_INET, SOCK_DGRAM, 0); if (s < 0) err(1, "couldn't create IP socket"); (void)strlcpy(ifr.ifr_name, interface, sizeof(ifr.ifr_name)); if (ioctl(s, SIOCGIFFLAGS, (caddr_t)&ifr) < 0) errx(1, "nonexistent interface '%s' specified", interface); intpr(); exit(0); }