[BACK]Return to rup.c CVS log [TXT][DIR] Up to [local] / src / usr.bin / rup

Annotation of src/usr.bin/rup/rup.c, Revision 1.17

1.17    ! deraadt     1: /*     $OpenBSD: rup.c,v 1.16 2002/05/27 03:14:07 deraadt Exp $        */
1.2       deraadt     2:
1.1       deraadt     3: /*-
                      4:  * Copyright (c) 1993, John Brezak
                      5:  * All rights reserved.
                      6:  *
                      7:  * Redistribution and use in source and binary forms, with or without
                      8:  * modification, are permitted provided that the following conditions
                      9:  * are met:
                     10:  * 1. Redistributions of source code must retain the above copyright
                     11:  *    notice, this list of conditions and the following disclaimer.
                     12:  * 2. Redistributions in binary form must reproduce the above copyright
                     13:  *    notice, this list of conditions and the following disclaimer in the
                     14:  *    documentation and/or other materials provided with the distribution.
                     15:  * 3. All advertising materials mentioning features or use of this software
                     16:  *    must display the following acknowledgement:
                     17:  *     This product includes software developed by the University of
                     18:  *     California, Berkeley and its contributors.
                     19:  * 4. Neither the name of the University nor the names of its contributors
                     20:  *    may be used to endorse or promote products derived from this software
                     21:  *    without specific prior written permission.
                     22:  *
                     23:  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
                     24:  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
                     25:  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
                     26:  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
                     27:  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
                     28:  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
                     29:  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
                     30:  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
                     31:  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
                     32:  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
                     33:  * SUCH DAMAGE.
                     34:  */
                     35:
                     36: #ifndef lint
1.17    ! deraadt    37: static char rcsid[] = "$OpenBSD: rup.c,v 1.16 2002/05/27 03:14:07 deraadt Exp $";
1.1       deraadt    38: #endif /* not lint */
                     39:
                     40: #include <stdio.h>
                     41: #include <stdlib.h>
                     42: #include <string.h>
                     43: #include <time.h>
                     44: #include <sys/param.h>
                     45: #include <sys/socket.h>
                     46: #include <netdb.h>
                     47: #include <rpc/rpc.h>
1.7       deraadt    48: #include <rpc/pmap_clnt.h>
1.1       deraadt    49: #include <arpa/inet.h>
                     50: #include <err.h>
                     51:
                     52: #undef FSHIFT                  /* Use protocol's shift and scale values */
                     53: #undef FSCALE
                     54: #include <rpcsvc/rstat.h>
                     55:
1.11      aaron      56: #define HOST_WIDTH 27
1.1       deraadt    57:
                     58: int printtime;                 /* print the remote host(s)'s time */
                     59:
                     60: struct host_list {
                     61:        struct host_list *next;
                     62:        struct in_addr addr;
                     63: } *hosts;
                     64:
1.15      millert    65: void usage(void);
                     66: int print_rup_data(char *, statstime *host_stat);
1.7       deraadt    67:
1.1       deraadt    68: int
1.17    ! deraadt    69: search_host(struct in_addr addr)
1.1       deraadt    70: {
                     71:        struct host_list *hp;
                     72:
                     73:        if (!hosts)
                     74:                return(0);
                     75:
                     76:        for (hp = hosts; hp != NULL; hp = hp->next) {
                     77:                if (hp->addr.s_addr == addr.s_addr)
                     78:                        return(1);
                     79:        }
                     80:        return(0);
                     81: }
                     82:
                     83: void
1.17    ! deraadt    84: remember_host(struct in_addr addr)
1.1       deraadt    85: {
                     86:        struct host_list *hp;
                     87:
                     88:        if (!(hp = (struct host_list *)malloc(sizeof(struct host_list)))) {
                     89:                err(1, NULL);
                     90:                /* NOTREACHED */
                     91:        }
                     92:        hp->addr.s_addr = addr.s_addr;
                     93:        hp->next = hosts;
                     94:        hosts = hp;
                     95: }
                     96:
                     97:
                     98: struct rup_data {
                     99:        char *host;
                    100:        struct statstime statstime;
                    101: };
                    102: struct rup_data *rup_data;
                    103: int rup_data_idx = 0;
                    104: int rup_data_max = 0;
                    105:
1.17    ! deraadt   106: enum sort_type {
1.1       deraadt   107:        SORT_NONE,
                    108:        SORT_HOST,
                    109:        SORT_LDAV,
                    110:        SORT_UPTIME
                    111: };
                    112: enum sort_type sort_type;
                    113:
1.7       deraadt   114: int
1.17    ! deraadt   115: compare(const void *v1, const void *v2)
1.1       deraadt   116: {
1.17    ! deraadt   117:        const struct rup_data *d1 = v1;
        !           118:        const struct rup_data *d2 = v2;
        !           119:
1.1       deraadt   120:        switch(sort_type) {
                    121:        case SORT_HOST:
                    122:                return strcmp(d1->host, d2->host);
                    123:        case SORT_LDAV:
1.3       deraadt   124:                return d1->statstime.avenrun[0]
1.1       deraadt   125:                        - d2->statstime.avenrun[0];
                    126:        case SORT_UPTIME:
1.17    ! deraadt   127:                return d1->statstime.boottime.tv_sec
1.1       deraadt   128:                        - d2->statstime.boottime.tv_sec;
                    129:        default:
                    130:                /* something's really wrong here */
                    131:                abort();
                    132:        }
                    133: }
                    134:
                    135: void
1.17    ! deraadt   136: remember_rup_data(char *host, struct statstime *st)
1.1       deraadt   137: {
1.14      deraadt   138:        if (rup_data_idx >= rup_data_max) {
                    139:                rup_data_max += 16;
1.17    ! deraadt   140:                rup_data = realloc(rup_data,
1.3       deraadt   141:                    rup_data_max * sizeof(struct rup_data));
1.14      deraadt   142:                if (rup_data == NULL) {
                    143:                        err(1, NULL);
1.1       deraadt   144:                        /* NOTREACHED */
1.14      deraadt   145:                }
                    146:        }
1.1       deraadt   147:
                    148:        rup_data[rup_data_idx].host = strdup(host);
                    149:        rup_data[rup_data_idx].statstime = *st;
                    150:        rup_data_idx++;
                    151: }
                    152:
                    153:
                    154: int
1.17    ! deraadt   155: rstat_reply(char *replyp, struct sockaddr_in *raddrp)
1.1       deraadt   156: {
                    157:        struct hostent *hp;
                    158:        char *host;
                    159:        statstime *host_stat = (statstime *)replyp;
                    160:
                    161:        if (!search_host(raddrp->sin_addr)) {
                    162:                hp = gethostbyaddr((char *)&raddrp->sin_addr.s_addr,
1.3       deraadt   163:                    sizeof(struct in_addr), AF_INET);
1.1       deraadt   164:                if (hp)
                    165:                        host = hp->h_name;
                    166:                else
                    167:                        host = inet_ntoa(raddrp->sin_addr);
                    168:
                    169:                remember_host(raddrp->sin_addr);
                    170:
1.3       deraadt   171:                if (sort_type != SORT_NONE)
1.1       deraadt   172:                        remember_rup_data(host, host_stat);
1.3       deraadt   173:                else
1.1       deraadt   174:                        print_rup_data(host, host_stat);
                    175:        }
                    176:
                    177:        return (0);
                    178: }
                    179:
                    180:
                    181: int
1.17    ! deraadt   182: print_rup_data(char *host, statstime *host_stat)
1.1       deraadt   183: {
1.16      deraadt   184:        unsigned int ups = 0, upm = 0, uph = 0, upd = 0;
                    185:        struct tm *tmp_time, host_time;
                    186:        char days_buf[16], hours_buf[16];
1.1       deraadt   187:
1.9       millert   188:        if (printtime)
1.11      aaron     189:                printf("%-*.*s", HOST_WIDTH-8, HOST_WIDTH-8, host);
1.9       millert   190:        else
                    191:                printf("%-*.*s", HOST_WIDTH, HOST_WIDTH, host);
1.1       deraadt   192:
                    193:        tmp_time = localtime((time_t *)&host_stat->curtime.tv_sec);
                    194:        host_time = *tmp_time;
                    195:
                    196:        host_stat->curtime.tv_sec -= host_stat->boottime.tv_sec;
                    197:
1.12      millert   198:        if (host_stat->curtime.tv_sec > 0)
                    199:                ups=host_stat->curtime.tv_sec;
1.6       tholo     200:        upd=ups/(3600*24);
                    201:        ups-=upd*3600*24;
                    202:        uph=ups/3600;
                    203:        ups-=uph*3600;
                    204:        upm=ups/60;
                    205:
                    206:        if (upd != 0)
1.16      deraadt   207:                snprintf(days_buf, sizeof days_buf, "%3u day%s, ", upd,
                    208:                    (upd > 1) ? "s" : "");
1.1       deraadt   209:        else
                    210:                days_buf[0] = '\0';
                    211:
1.6       tholo     212:        if (uph != 0)
1.16      deraadt   213:                snprintf(hours_buf, sizeof hours_buf, "%2u:%02u, ",
                    214:                    uph, upm);
1.1       deraadt   215:        else
1.6       tholo     216:                if (upm != 0)
1.16      deraadt   217:                        snprintf(hours_buf, sizeof hours_buf, "%2u min%s ",
                    218:                            upm, (upm == 1) ? ", " : "s,");
1.1       deraadt   219:                else
                    220:                        hours_buf[0] = '\0';
                    221:
                    222:        if (printtime)
1.4       deraadt   223:                printf(" %2d:%02d%cm",
                    224:                    (host_time.tm_hour % 12) ? (host_time.tm_hour % 12) : 12,
1.3       deraadt   225:                    host_time.tm_min,
                    226:                    (host_time.tm_hour >= 12) ? 'p' : 'a');
1.1       deraadt   227:
                    228:        printf(" up %9.9s%9.9s load average: %.2f %.2f %.2f\n",
1.3       deraadt   229:            days_buf, hours_buf,
                    230:            (double)host_stat->avenrun[0]/FSCALE,
                    231:            (double)host_stat->avenrun[1]/FSCALE,
                    232:            (double)host_stat->avenrun[2]/FSCALE);
1.1       deraadt   233:
                    234:        return(0);
                    235: }
                    236:
                    237:
                    238: void
1.17    ! deraadt   239: onehost(char *host)
1.1       deraadt   240: {
                    241:        CLIENT *rstat_clnt;
                    242:        statstime host_stat;
                    243:        static struct timeval timeout = {25, 0};
1.5       deraadt   244:        extern char *__progname;
1.1       deraadt   245:
                    246:        rstat_clnt = clnt_create(host, RSTATPROG, RSTATVERS_TIME, "udp");
                    247:        if (rstat_clnt == NULL) {
1.5       deraadt   248:                fprintf(stderr, "%s: %s", __progname,
                    249:                    clnt_spcreateerror(host));
1.1       deraadt   250:                return;
                    251:        }
                    252:
                    253:        bzero((char *)&host_stat, sizeof(host_stat));
1.3       deraadt   254:        if (clnt_call(rstat_clnt, RSTATPROC_STATS, xdr_void, NULL,
                    255:            xdr_statstime, &host_stat, timeout) != RPC_SUCCESS) {
1.5       deraadt   256:                fprintf(stderr, "%s: %s", __progname,
                    257:                    clnt_sperror(rstat_clnt, host));
1.13      deraadt   258:                clnt_destroy(rstat_clnt);
1.1       deraadt   259:                return;
                    260:        }
                    261:
                    262:        print_rup_data(host, &host_stat);
                    263:        clnt_destroy(rstat_clnt);
                    264: }
                    265:
                    266: void
1.17    ! deraadt   267: allhosts(void)
1.1       deraadt   268: {
                    269:        statstime host_stat;
                    270:        enum clnt_stat clnt_stat;
1.5       deraadt   271:        extern char *__progname;
1.1       deraadt   272:        size_t i;
                    273:
                    274:        if (sort_type != SORT_NONE) {
                    275:                printf("collecting responses...");
                    276:                fflush(stdout);
                    277:        }
                    278:
                    279:        clnt_stat = clnt_broadcast(RSTATPROG, RSTATVERS_TIME, RSTATPROC_STATS,
1.7       deraadt   280:            xdr_void, NULL, xdr_statstime, (char *)&host_stat, rstat_reply);
1.1       deraadt   281:        if (clnt_stat != RPC_SUCCESS && clnt_stat != RPC_TIMEDOUT) {
1.8       deraadt   282:                fprintf(stderr, "%s: %s\n", __progname, clnt_sperrno(clnt_stat));
1.1       deraadt   283:                exit(1);
                    284:        }
                    285:
                    286:        if (sort_type != SORT_NONE) {
                    287:                putchar('\n');
1.3       deraadt   288:                qsort(rup_data, rup_data_idx, sizeof(struct rup_data),
                    289:                    compare);
1.1       deraadt   290:
                    291:                for (i = 0; i < rup_data_idx; i++) {
1.3       deraadt   292:                        print_rup_data(rup_data[i].host,
                    293:                            &rup_data[i].statstime);
1.1       deraadt   294:                }
                    295:        }
                    296: }
                    297:
1.7       deraadt   298: int
1.17    ! deraadt   299: main(int argc, char *argv[])
1.1       deraadt   300: {
                    301:        int ch;
                    302:        extern int optind;
                    303:
                    304:        sort_type = SORT_NONE;
                    305:        while ((ch = getopt(argc, argv, "dhlt")) != -1)
                    306:                switch (ch) {
                    307:                case 'd':
                    308:                        printtime = 1;
                    309:                        break;
                    310:                case 'h':
                    311:                        sort_type = SORT_HOST;
                    312:                        break;
                    313:                case 'l':
                    314:                        sort_type = SORT_LDAV;
                    315:                        break;
                    316:                case 't':
                    317:                        sort_type = SORT_UPTIME;
                    318:                        break;
                    319:                default:
                    320:                        usage();
                    321:                        /*NOTREACHED*/
                    322:                }
                    323:
                    324:        setlinebuf(stdout);
                    325:
                    326:        if (argc == optind)
                    327:                allhosts();
                    328:        else {
                    329:                for (; optind < argc; optind++)
                    330:                        onehost(argv[optind]);
                    331:        }
                    332:
                    333:        exit(0);
                    334: }
                    335:
                    336:
1.7       deraadt   337: void
1.17    ! deraadt   338: usage(void)
1.1       deraadt   339: {
                    340:        fprintf(stderr, "Usage: rup [-dhlt] [hosts ...]\n");
                    341:        exit(1);
                    342: }