/* NFSSRC @(#)rup.c 2.1 86/04/16 */ #ifndef lint static char sccsid[] = "@(#)rup.c 1.1 86/02/05 Copyr 1985 Sun Micro"; #endif /* * Copyright (c) 1985 by Sun Microsystems, Inc. */ #include <stdio.h> #include <netdb.h> #include <sys/param.h> #include <sys/stat.h> #include <sys/time.h> #include <sys/socket.h> #include <rpcsvc/rstat.h> #include <rpc/rpc.h> #include <rpc/pmap_clnt.h> #define MACHINELEN 12 /* length of machine name printed out */ #define AVENSIZE (3*sizeof(long)) int machinecmp(); int loadcmp(); int uptimecmp(); int collectnames(); struct entry { int addr; char *machine; struct timeval boottime; time_t curtime; long avenrun[3]; } entry[200]; int curentry; int vers; /* which version did the broadcasting */ int lflag; /* load: sort by load average */ int tflag; /* time: sort by uptime average */ int hflag; /* host: sort by machine name */ int dflag; /* debug: list only first n machines */ int debug; main(argc, argv) char **argv; { struct statstime sw; int err; int single; enum clnt_stat clnt_stat; single = 0; while (argc > 1) { if (argv[1][0] != '-') { single++; singlehost(argv[1]); } else { switch(argv[1][1]) { case 'l': lflag++; break; case 't': tflag++; break; case 'h': hflag++; break; case 'd': dflag++; if (argc < 3) usage(); debug = atoi(argv[2]); argc--; argv++; break; default: usage(); } } argv++; argc--; } if (single > 0) exit(0); if (hflag || tflag || lflag) { printf("collecting responses... "); fflush(stdout); } vers = RSTATVERS_TIME; clnt_stat = clnt_broadcast(RSTATPROG, RSTATVERS_TIME, RSTATPROC_STATS, xdr_void, NULL, xdr_statstime, &sw, collectnames); #ifdef TESTING fprintf(stderr, "starting second round of broadcasting\n"); #endif vers = RSTATVERS_SWTCH; clnt_stat = clnt_broadcast(RSTATPROG, RSTATVERS_SWTCH, RSTATPROC_STATS, xdr_void, NULL, xdr_statsswtch, &sw, collectnames); if (hflag || tflag || lflag) printnames(); } singlehost(host) char *host; { enum clnt_stat err; struct statstime sw; time_t now; err = (enum clnt_stat)callrpc(host, RSTATPROG, RSTATVERS_TIME, RSTATPROC_STATS, xdr_void, 0, xdr_statstime, &sw); if (err == RPC_SUCCESS) now = sw.curtime.tv_sec; else if (err == RPC_PROGVERSMISMATCH) { if (err = (enum clnt_stat)callrpc(host, RSTATPROG, RSTATVERS_SWTCH, RSTATPROC_STATS, xdr_void, 0, xdr_statsswtch, &sw)) { fprintf(stderr, "%*.*s: ", MACHINELEN, MACHINELEN, host); clnt_perrno(err); fprintf(stderr, "\n"); return; } time (&now); } else { fprintf(stderr, "%*.*s: ", MACHINELEN, MACHINELEN, host); clnt_perrno(err); fprintf(stderr, "\n"); return; } printf("%*.*s ", MACHINELEN, MACHINELEN, host); putline(now, sw.boottime, sw.avenrun); } putline(now, boottime, avenrun) time_t now; struct timeval boottime; long avenrun[]; { int uptime, days, hrs, mins, i; uptime = now - boottime.tv_sec; uptime += 30; if (uptime < 0) /* unsynchronized clocks */ uptime = 0; days = uptime / (60*60*24); uptime %= (60*60*24); hrs = uptime / (60*60); uptime %= (60*60); mins = uptime / 60; printf(" up"); if (days > 0) printf(" %2d day%s", days, days>1?"s,":", "); else printf(" "); if (hrs > 0) printf(" %2d:%02d, ", hrs, mins); else printf(" %2d min%s", mins, mins>1?"s,":", "); /* * Print 1, 5, and 15 minute load averages. * (Found by looking in kernel for avenrun). */ printf(" load average:"); for (i = 0; i < (AVENSIZE/sizeof(avenrun[0])); i++) { if (i > 0) printf(","); printf(" %.2f", (double)avenrun[i]); } printf("\n"); } collectnames(resultsp, raddrp) char *resultsp; struct sockaddr_in *raddrp; { struct hostent *hp; static int debugcnt; int i, cnt; register int addr; register struct entry *entryp, *lim; struct statstime *sw; time_t now; /* * weed out duplicates */ addr = raddrp->sin_addr.s_addr; lim = entry + curentry; for (entryp = entry; entryp < lim; entryp++) if (addr == entryp->addr) return (0); sw = (struct statstime *)resultsp; debugcnt++; entry[curentry].addr = addr; /* * if raw, print this entry out immediately * otherwise store for later sorting */ if (!hflag && !lflag && !tflag) { hp = gethostbyaddr(&raddrp->sin_addr.s_addr, sizeof(int),AF_INET); if (hp == NULL) printf(" 0x%08.8x: ", addr); else printf("%*.*s ", MACHINELEN, MACHINELEN, hp->h_name); if (vers == RSTATVERS_TIME) now = sw->curtime.tv_sec; else time (&now); putline(now, sw->boottime, sw->avenrun); } else { entry[curentry].boottime = sw->boottime; if (vers == RSTATVERS_TIME) entry[curentry].curtime = sw->curtime.tv_sec; else time(&entry[curentry].curtime); bcopy(sw->avenrun, entry[curentry].avenrun, AVENSIZE); } curentry++; if (dflag && debugcnt >= debug) return (1); return(0); } printnames() { char buf[MACHINELEN+1]; struct hostent *hp; int i, j; for (i = 0; i < curentry; i++) { hp = gethostbyaddr(&entry[i].addr,sizeof(int),AF_INET); if (hp == NULL) sprintf(buf, "0x%08.8x", entry[i].addr); else sprintf(buf, "%.*s", MACHINELEN, hp->h_name); entry[i].machine = (char *)malloc(MACHINELEN+1); strcpy(entry[i].machine, buf); } if (hflag) qsort(entry, curentry, sizeof(struct entry), machinecmp); else if (lflag) qsort(entry, curentry, sizeof(struct entry), loadcmp); else qsort(entry, curentry, sizeof(struct entry), uptimecmp); printf("\n"); for (i = 0; i < curentry; i++) { printf("%12.12s ", entry[i].machine); putline(entry[i].curtime, entry[i].boottime, entry[i].avenrun); } } machinecmp(a,b) struct entry *a, *b; { return (strcmp(a->machine, b->machine)); } uptimecmp(a,b) struct entry *a, *b; { int tmp; return (a->boottime.tv_sec - b->boottime.tv_sec); } loadcmp(a,b) struct entry *a, *b; { return (a->avenrun[0] - b->avenrun[0]); } usage() { fprintf(stderr, "Usage: rup [-h] [-l] [-t] [host ...]\n"); exit(1); }