1 /*
2  * print PPP statistics:
3  * 	pppstats [-a|-d] [-v|-r|-z] [-c count] [-w wait] [interface]
4  *
5  *   -a Show absolute values rather than deltas
6  *   -d Show data rate (kB/s) rather than bytes
7  *   -v Show more stats for VJ TCP header compression
8  *   -r Show compression ratio
9  *   -z Show compression statistics instead of default display
10  *
11  * History:
12  *      perkins@cps.msu.edu: Added compression statistics and alternate
13  *                display. 11/94
14  *	Brad Parker (brad@cayman.com) 6/92
15  *
16  * from the original "slstats" by Van Jacobson
17  *
18  * Copyright (c) 2000-2001 by Sun Microsystems, Inc.
19  * All rights reserved.
20  *
21  * Copyright (c) 1989 Regents of the University of California.
22  * All rights reserved.
23  *
24  * Redistribution and use in source and binary forms are permitted
25  * provided that the above copyright notice and this paragraph are
26  * duplicated in all such forms and that any documentation,
27  * advertising materials, and other materials related to such
28  * distribution and use acknowledge that the software was developed
29  * by the University of California, Berkeley.  The name of the
30  * University may not be used to endorse or promote products derived
31  * from this software without specific prior written permission.
32  * THIS SOFTWARE IS PROVIDED ``AS IS'' AND WITHOUT ANY EXPRESS OR
33  * IMPLIED WARRANTIES, INCLUDING, WITHOUT LIMITATION, THE IMPLIED
34  * WARRANTIES OF MERCHANTIBILITY AND FITNESS FOR A PARTICULAR PURPOSE.
35  */
36 
37 #ifndef __STDC__
38 #define const
39 #endif
40 
41 #include <stdio.h>
42 #include <stddef.h>
43 #include <stdlib.h>
44 #include <string.h>
45 #include <ctype.h>
46 #include <errno.h>
47 #include <signal.h>
48 #include <fcntl.h>
49 #include <unistd.h>
50 #include <sys/param.h>
51 #include <sys/types.h>
52 #include <sys/ioctl.h>
53 
54 #ifndef STREAMS
55 #if defined(_linux_) && defined(__powerpc__) \
56     && (__GLIBC__ == 2 && __GLIBC_MINOR__ == 0)
57 /* kludge alert! */
58 #undef __GLIBC__
59 #endif
60 #include <sys/socket.h>		/* *BSD, Linux, NeXT, Ultrix etc. */
61 #ifndef _linux_
62 #include <net/if.h>
63 #include <net/ppp_defs.h>
64 #include <net/if_ppp.h>
65 #else
66 /* Linux */
67 #if __GLIBC__ >= 2
68 #include <asm/types.h>		/* glibc 2 conflicts with linux/types.h */
69 #include <net/if.h>
70 #else
71 #include <linux/types.h>
72 #include <linux/if.h>
73 #endif
74 #include <linux/ppp_defs.h>
75 #include <linux/if_ppp.h>
76 #endif /* _linux_ */
77 
78 #else	/* STREAMS */
79 #include <sys/stropts.h>	/* SVR4, Solaris 2, SunOS 4, OSF/1, etc. */
80 #include <net/ppp_defs.h>
81 #include <net/pppio.h>
82 
83 #ifdef PPPIO_GETSTAT64
84 #define	ppp_stats64	ppp_stats64
85 #endif
86 #endif	/* STREAMS */
87 
88 #ifndef ppp_stats64
89 #define	ppp_stats64	ppp_stats
90 #endif
91 
92 static int	vflag, rflag, zflag;	/* select type of display */
93 static int	aflag;			/* print absolute values, not deltas */
94 static int	dflag;			/* print data rates, not bytes */
95 static int	interval, count;
96 static int	infinite;
97 static int	unit;
98 static int	s;			/* socket or /dev/ppp file descriptor */
99 static int	signalled;		/* set if alarm goes off "early" */
100 static char	*progname;
101 static char	*interface;
102 
103 #if defined(SUNOS4) || defined(ULTRIX) || defined(NeXT)
104 extern int optind;
105 extern char *optarg;
106 #endif
107 
108 /*
109  * If PPP_DRV_NAME is not defined, use the legacy "ppp" as the
110  * device name.
111  */
112 #if !defined(PPP_DRV_NAME)
113 #define PPP_DRV_NAME    "ppp"
114 #endif /* !defined(PPP_DRV_NAME) */
115 
116 static void usage __P((void));
117 static void catchalarm __P((int));
118 static void get_ppp_stats __P((struct ppp_stats64 *));
119 static void get_ppp_cstats __P((struct ppp_comp_stats *));
120 static void intpr __P((void));
121 
122 int main __P((int, char *argv[]));
123 
124 static void
usage()125 usage()
126 {
127     (void) fprintf(stderr,
128 	"Usage: %s [-a|-d] [-v|-r|-z] [-c count] [-w wait] [interface]\n",
129 	progname);
130     exit(1);
131 }
132 
133 /*
134  * Called if an interval expires before intpr has completed a loop.
135  * Sets a flag to not wait for the alarm.
136  */
137 /* ARGSUSED */
138 static void
catchalarm(arg)139 catchalarm(arg)
140     int arg;
141 {
142     signalled = 1;
143 }
144 
145 
146 #ifndef STREAMS
147 static void
get_ppp_stats(curp)148 get_ppp_stats(curp)
149     struct ppp_stats64 *curp;
150 {
151     struct ifpppstatsreq req;
152 
153     (void) memset (&req, 0, sizeof (req));
154 
155 #ifdef _linux_
156     req.stats_ptr = (caddr_t) &req.stats;
157 #undef ifr_name
158 #define ifr_name ifr__name
159 #endif
160 
161     strncpy(req.ifr_name, interface, sizeof(req.ifr_name));
162     if (ioctl(s, SIOCGPPPSTATS, &req) < 0) {
163 	(void) fprintf(stderr, "%s: ", progname);
164 	if (errno == ENOTTY)
165 	    (void) fprintf(stderr, "kernel support missing\n");
166 	else
167 	    perror("couldn't get PPP statistics");
168 	exit(1);
169     }
170     *curp = req.stats;
171 }
172 
173 static void
get_ppp_cstats(csp)174 get_ppp_cstats(csp)
175     struct ppp_comp_stats *csp;
176 {
177     struct ifpppcstatsreq creq;
178 
179     (void) memset (&creq, 0, sizeof (creq));
180 
181 #ifdef _linux_
182     creq.stats_ptr = (caddr_t) &creq.stats;
183 #undef  ifr_name
184 #define ifr_name ifr__name
185 #endif
186 
187     strncpy(creq.ifr_name, interface, sizeof(creq.ifr_name));
188     if (ioctl(s, SIOCGPPPCSTATS, &creq) < 0) {
189 	(void) fprintf(stderr, "%s: ", progname);
190 	if (errno == ENOTTY) {
191 	    (void) fprintf(stderr, "no kernel compression support\n");
192 	    if (zflag)
193 		exit(1);
194 	    rflag = 0;
195 	} else {
196 	    perror("couldn't get PPP compression stats");
197 	    exit(1);
198 	}
199     }
200 
201 #ifdef _linux_
202     if (creq.stats.c.bytes_out == 0) {
203 	creq.stats.c.bytes_out = creq.stats.c.comp_bytes + creq.stats.c.inc_bytes;
204 	creq.stats.c.in_count = creq.stats.c.unc_bytes;
205     }
206     if (creq.stats.c.bytes_out == 0)
207 	creq.stats.c.ratio = 0.0;
208     else
209 	creq.stats.c.ratio = 256.0 * creq.stats.c.in_count /
210 			     creq.stats.c.bytes_out;
211 
212     if (creq.stats.d.bytes_out == 0) {
213 	creq.stats.d.bytes_out = creq.stats.d.comp_bytes + creq.stats.d.inc_bytes;
214 	creq.stats.d.in_count = creq.stats.d.unc_bytes;
215     }
216     if (creq.stats.d.bytes_out == 0)
217 	creq.stats.d.ratio = 0.0;
218     else
219 	creq.stats.d.ratio = 256.0 * creq.stats.d.in_count /
220 			     creq.stats.d.bytes_out;
221 #endif
222 
223     *csp = creq.stats;
224 }
225 
226 #else	/* STREAMS */
227 
228 static int
strioctl(fd,cmd,ptr,ilen,olen)229 strioctl(fd, cmd, ptr, ilen, olen)
230     int fd, cmd, ilen, olen;
231     char *ptr;
232 {
233     struct strioctl str;
234 
235     str.ic_cmd = cmd;
236     str.ic_timout = 0;
237     str.ic_len = ilen;
238     str.ic_dp = ptr;
239     if (ioctl(fd, I_STR, &str) == -1)
240 	return -1;
241     if (str.ic_len != olen)
242 	(void) fprintf(stderr,
243 	    "strioctl: expected %d bytes, got %d for cmd %x\n",
244 	    olen, str.ic_len, cmd);
245     return 0;
246 }
247 
248 static void
get_ppp_stats(curp)249 get_ppp_stats(curp)
250     struct ppp_stats64 *curp;
251 {
252 #ifdef PPPIO_GETSTAT64
253     struct ppp_stats oldstat;
254     if (strioctl(s, PPPIO_GETSTAT64, (char *)curp, 0, sizeof(*curp)) >= 0)
255 	return;
256     if (strioctl(s, PPPIO_GETSTAT, (char *)&oldstat, 0, sizeof(oldstat)) >= 0) {
257 	curp->p.ppp_ibytes = oldstat.p.ppp_ibytes;
258 	curp->p.ppp_ipackets = oldstat.p.ppp_ipackets;
259 	curp->p.ppp_ierrors = oldstat.p.ppp_ierrors;
260 	curp->p.ppp_obytes = oldstat.p.ppp_obytes;
261 	curp->p.ppp_opackets = oldstat.p.ppp_opackets;
262 	curp->p.ppp_oerrors = oldstat.p.ppp_oerrors;
263 	curp->vj = oldstat.vj;
264 	return;
265     }
266 #else
267     if (strioctl(s, PPPIO_GETSTAT, (char *)curp, 0, sizeof(*curp)) >= 0)
268 	return;
269 #endif
270 
271     (void) fprintf(stderr, "%s: ", progname);
272     if (errno == EINVAL)
273 	(void) fprintf(stderr, "kernel support missing\n");
274     else
275 	perror("couldn't get PPP statistics");
276     exit(1);
277 }
278 
279 static void
get_ppp_cstats(csp)280 get_ppp_cstats(csp)
281     struct ppp_comp_stats *csp;
282 {
283     if (strioctl(s, PPPIO_GETCSTAT, (char *)csp, 0, sizeof(*csp)) < 0) {
284 	(void) fprintf(stderr, "%s: ", progname);
285 	if (errno == ENOTTY) {
286 	    (void) fprintf(stderr, "no kernel compression support\n");
287 	    if (zflag)
288 		exit(1);
289 	    rflag = 0;
290 	} else {
291 	    perror("couldn't get PPP compression statistics");
292 	    exit(1);
293 	}
294     }
295 }
296 
297 #endif /* STREAMS */
298 
299 #define MAX0(a)		((int)(a) > 0? (a): 0)
300 #define V(offset)	MAX0(cur.offset - old.offset)
301 #define W(offset)	MAX0(ccs.offset - ocs.offset)
302 
303 #define RATIO(c, i, u)	((c) == 0? 1.0: (u) / ((double)(c) + (i)))
304 #define CRATE(x)	RATIO(W(x.comp_bytes), W(x.inc_bytes), W(x.unc_bytes))
305 
306 #define KBPS(n)		((n) / (interval * 1000.0))
307 
308 /*
309  * Print a running summary of interface statistics.
310  * Repeat display every interval seconds, showing statistics
311  * collected over that interval.  Assumes that interval is non-zero.
312  * First line printed is cumulative.
313  */
314 static void
intpr()315 intpr()
316 {
317     register int line = 0;
318     sigset_t oldmask, mask;
319     char *bunit;
320     int ratef = 0;
321     struct ppp_stats64 cur, old;
322     struct ppp_comp_stats ccs, ocs;
323 
324     (void) memset(&old, 0, sizeof(old));
325     (void) memset(&ocs, 0, sizeof(ocs));
326 
327     for (;;) {
328 	get_ppp_stats(&cur);
329 	if (zflag || rflag)
330 	    get_ppp_cstats(&ccs);
331 
332 	(void)signal(SIGALRM, catchalarm);
333 	signalled = 0;
334 	(void)alarm(interval);
335 
336 	if ((line % 20) == 0) {
337 	    if (zflag) {
338 		(void) printf("IN:  COMPRESSED  INCOMPRESSIBLE   COMP | ");
339 		(void) printf("OUT: COMPRESSED  INCOMPRESSIBLE   COMP\n");
340 		bunit = dflag? "KB/S": "BYTE";
341 		(void) printf("    %s   PACK     %s   PACK  RATIO | ", bunit,
342 		    bunit);
343 		(void) printf("    %s   PACK     %s   PACK  RATIO", bunit,
344 		    bunit);
345 	    } else {
346 		(void) printf("%8.8s %6.6s %6.6s",
347 		       "IN", "PACK", "VJCOMP");
348 
349 		if (!rflag)
350 		    (void) printf(" %6.6s %6.6s", "VJUNC", "VJERR");
351 		if (vflag)
352 		    (void) printf(" %6.6s %6.6s", "VJTOSS", "NON-VJ");
353 		if (rflag)
354 		    (void) printf(" %6.6s %6.6s", "RATIO", "UBYTE");
355 		(void) printf("  | %8.8s %6.6s %6.6s",
356 		       "OUT", "PACK", "VJCOMP");
357 
358 		if (!rflag)
359 		    (void) printf(" %6.6s %6.6s", "VJUNC", "NON-VJ");
360 		if (vflag)
361 		    (void) printf(" %6.6s %6.6s", "VJSRCH", "VJMISS");
362 		if (rflag)
363 		    (void) printf(" %6.6s %6.6s", "RATIO", "UBYTE");
364 	    }
365 	    (void) putchar('\n');
366 	}
367 
368 	if (zflag) {
369 	    if (ratef) {
370 		(void) printf("%8.3f %6u %8.3f %6u %6.2f",
371 		       KBPS(W(d.comp_bytes)),
372 		       W(d.comp_packets),
373 		       KBPS(W(d.inc_bytes)),
374 		       W(d.inc_packets),
375 		       ccs.d.ratio / 256.0);
376 		(void) printf(" | %8.3f %6u %8.3f %6u %6.2f",
377 		       KBPS(W(c.comp_bytes)),
378 		       W(c.comp_packets),
379 		       KBPS(W(c.inc_bytes)),
380 		       W(c.inc_packets),
381 		       ccs.c.ratio / 256.0);
382 	    } else {
383 		(void) printf("%8u %6u %8u %6u %6.2f",
384 		       W(d.comp_bytes),
385 		       W(d.comp_packets),
386 		       W(d.inc_bytes),
387 		       W(d.inc_packets),
388 		       ccs.d.ratio / 256.0);
389 		(void) printf(" | %8u %6u %8u %6u %6.2f",
390 		       W(c.comp_bytes),
391 		       W(c.comp_packets),
392 		       W(c.inc_bytes),
393 		       W(c.inc_packets),
394 		       ccs.c.ratio / 256.0);
395 	    }
396 
397 	} else {
398 	    if (ratef)
399 		(void) printf("%8.3f", KBPS(V(p.ppp_ibytes)));
400 	    else
401 		(void) printf("%8" PPP_COUNTER_F, V(p.ppp_ibytes));
402 	    (void) printf(" %6" PPP_COUNTER_F " %6u",
403 		   V(p.ppp_ipackets),
404 		   V(vj.vjs_compressedin));
405 	    if (!rflag)
406 		(void) printf(" %6u %6u",
407 		       V(vj.vjs_uncompressedin),
408 		       V(vj.vjs_errorin));
409 	    if (vflag)
410 		(void) printf(" %6u %6" PPP_COUNTER_F,
411 		       V(vj.vjs_tossed),
412 		       V(p.ppp_ipackets) - V(vj.vjs_compressedin)
413 		       - V(vj.vjs_uncompressedin) - V(vj.vjs_errorin));
414 	    if (rflag) {
415 		(void) printf(" %6.2f ", CRATE(d));
416 		if (ratef)
417 		    (void) printf("%6.2f", KBPS(W(d.unc_bytes)));
418 		else
419 		    (void) printf("%6u", W(d.unc_bytes));
420 	    }
421 	    if (ratef)
422 		(void) printf("  | %8.3f", KBPS(V(p.ppp_obytes)));
423 	    else
424 		(void) printf("  | %8" PPP_COUNTER_F, V(p.ppp_obytes));
425 	    (void) printf(" %6" PPP_COUNTER_F " %6u",
426 		   V(p.ppp_opackets),
427 		   V(vj.vjs_compressed));
428 	    if (!rflag)
429 		(void) printf(" %6u %6" PPP_COUNTER_F,
430 		       V(vj.vjs_packets) - V(vj.vjs_compressed),
431 		       V(p.ppp_opackets) - V(vj.vjs_packets));
432 	    if (vflag)
433 		(void) printf(" %6u %6u",
434 		       V(vj.vjs_searches),
435 		       V(vj.vjs_misses));
436 	    if (rflag) {
437 		(void) printf(" %6.2f ", CRATE(c));
438 		if (ratef)
439 		    (void) printf("%6.2f", KBPS(W(c.unc_bytes)));
440 		else
441 		    (void) printf("%6u", W(c.unc_bytes));
442 	    }
443 
444 	}
445 
446 	(void) putchar('\n');
447 	(void) fflush(stdout);
448 	line++;
449 
450 	count--;
451 	if (!infinite && !count)
452 	    break;
453 
454 	(void) sigemptyset(&mask);
455 	(void) sigaddset(&mask, SIGALRM);
456 	(void) sigprocmask(SIG_BLOCK, &mask, &oldmask);
457 	if (!signalled) {
458 	    (void) sigemptyset(&mask);
459 	    (void) sigsuspend(&mask);
460 	}
461 	(void) sigprocmask(SIG_SETMASK, &oldmask, NULL);
462 	signalled = 0;
463 	(void)alarm(interval);
464 
465 	if (!aflag) {
466 	    old = cur;
467 	    ocs = ccs;
468 	    ratef = dflag;
469 	}
470     }
471 }
472 
473 int
main(argc,argv)474 main(argc, argv)
475     int argc;
476     char *argv[];
477 {
478     int c;
479 #ifdef STREAMS
480     char *dev;
481 #endif
482 
483     interface = PPP_DRV_NAME "0";
484     if ((progname = strrchr(argv[0], '/')) == NULL)
485 	progname = argv[0];
486     else
487 	++progname;
488 
489     while ((c = getopt(argc, argv, "advrzc:w:")) != -1) {
490 	switch (c) {
491 	case 'a':
492 	    ++aflag;
493 	    break;
494 	case 'd':
495 	    ++dflag;
496 	    break;
497 	case 'v':
498 	    ++vflag;
499 	    break;
500 	case 'r':
501 	    ++rflag;
502 	    break;
503 	case 'z':
504 	    ++zflag;
505 	    break;
506 	case 'c':
507 	    count = atoi(optarg);
508 	    if (count <= 0)
509 		usage();
510 	    break;
511 	case 'w':
512 	    interval = atoi(optarg);
513 	    if (interval <= 0)
514 		usage();
515 	    break;
516 	default:
517 	    usage();
518 	}
519     }
520     argc -= optind;
521     argv += optind;
522 
523     if (!interval && count)
524 	interval = 5;
525     if (interval && !count)
526 	infinite = 1;
527     if (!interval && !count)
528 	count = 1;
529     if (aflag)
530 	dflag = 0;
531 
532     if (argc > 1)
533 	usage();
534     if (argc > 0)
535 	interface = argv[0];
536 
537     if (sscanf(interface, PPP_DRV_NAME "%d", &unit) != 1) {
538 	(void) fprintf(stderr, "%s: invalid interface '%s' specified\n",
539 		progname, interface);
540     }
541 
542 #ifndef STREAMS
543     {
544 	struct ifreq ifr;
545 
546 	s = socket(AF_INET, SOCK_DGRAM, 0);
547 	if (s < 0) {
548 	    (void) fprintf(stderr, "%s: ", progname);
549 	    perror("couldn't create IP socket");
550 	    exit(1);
551 	}
552 
553 #ifdef _linux_
554 #undef  ifr_name
555 #define ifr_name ifr_ifrn.ifrn_name
556 #endif
557 	strncpy(ifr.ifr_name, interface, sizeof(ifr.ifr_name));
558 	if (ioctl(s, SIOCGIFFLAGS, (caddr_t)&ifr) < 0) {
559 	    (void) fprintf(stderr, "%s: nonexistent interface '%s' specified\n",
560 		    progname, interface);
561 	    exit(1);
562 	}
563     }
564 
565 #else	/* STREAMS */
566 #ifdef __osf__
567     dev = "/dev/streams/ppp";
568 #else
569     dev = "/dev/" PPP_DRV_NAME;
570 #endif
571     if ((s = open(dev, O_RDONLY)) < 0) {
572 	(void) fprintf(stderr, "%s: couldn't open ", progname);
573 	perror(dev);
574 	exit(1);
575     }
576     if (strioctl(s, PPPIO_ATTACH, (char *)&unit, sizeof(int), 0) < 0) {
577 	(void) fprintf(stderr, "%s: " PPP_DRV_NAME "%d is not available\n",
578 	    progname, unit);
579 	exit(1);
580     }
581 
582 #endif	/* STREAMS */
583 
584     intpr();
585     return (0);
586 }
587