xref: /dragonfly/usr.bin/rup/rup.c (revision dc71b7ab81c4f5270d3668e1625d94a58895fa7a)
1 /*-
2  * Copyright (c) 1993, John Brezak
3  * All rights reserved.
4  *
5  * Redistribution and use in source and binary forms, with or without
6  * modification, are permitted provided that the following conditions
7  * are met:
8  * 1. Redistributions of source code must retain the above copyright
9  *    notice, this list of conditions and the following disclaimer.
10  * 2. Redistributions in binary form must reproduce the above copyright
11  *    notice, this list of conditions and the following disclaimer in the
12  *    documentation and/or other materials provided with the distribution.
13  * 3. Neither the name of the University nor the names of its contributors
14  *    may be used to endorse or promote products derived from this software
15  *    without specific prior written permission.
16  *
17  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
18  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
19  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
20  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
21  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
22  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
23  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
24  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
25  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
26  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
27  * SUCH DAMAGE.
28  *
29  * $FreeBSD: src/usr.bin/rup/rup.c,v 1.19 2005/12/04 18:25:26 philip Exp $
30  * $DragonFly: src/usr.bin/rup/rup.c,v 1.5 2005/08/04 18:21:25 liamfoy Exp $
31  */
32 #include <sys/param.h>
33 #include <sys/socket.h>
34 
35 #include <arpa/inet.h>
36 #include <rpc/rpc.h>
37 #include <rpc/pmap_clnt.h>
38 #undef FSHIFT                           /* Use protocol's shift and scale values */
39 #undef FSCALE
40 #include <rpcsvc/rstat.h>
41 
42 #include <err.h>
43 #include <netdb.h>
44 #include <stdio.h>
45 #include <stdlib.h>
46 #include <string.h>
47 #include <time.h>
48 #include <unistd.h>
49 
50 #define HOST_WIDTH 15
51 
52 struct host_list {
53           struct host_list *next;
54           struct in_addr addr;
55 } *hosts;
56 
57 static int
search_host(struct in_addr addr)58 search_host(struct in_addr addr)
59 {
60           struct host_list *hp;
61 
62           if (hosts == NULL)
63                     return(0);
64 
65           for (hp = hosts; hp != NULL; hp = hp->next) {
66                     if (hp->addr.s_addr == addr.s_addr)
67                               return(1);
68           }
69           return(0);
70 }
71 
72 static void
remember_host(struct in_addr addr)73 remember_host(struct in_addr addr)
74 {
75           struct host_list *hp;
76 
77           if ((hp = malloc(sizeof(struct host_list))) == NULL)
78                     err(1, "malloc failed");
79           hp->addr.s_addr = addr.s_addr;
80           hp->next = hosts;
81           hosts = hp;
82 }
83 
84 static bool_t
rstat_reply(caddr_t replyp,struct sockaddr_in * raddrp)85 rstat_reply(caddr_t replyp, struct sockaddr_in *raddrp)
86 {
87           struct tm *tmp_time;
88           struct tm host_time;
89           struct tm host_uptime;
90           char days_buf[16];
91           char hours_buf[16];
92           struct hostent *hp;
93           char *host;
94           statstime *host_stat = (statstime *)replyp;
95           time_t tmp_time_t;
96 
97           if (search_host(raddrp->sin_addr))
98                     return(0);
99 
100           hp = gethostbyaddr(&raddrp->sin_addr.s_addr, sizeof(struct in_addr),
101                                  AF_INET);
102           if (hp)
103                     host = hp->h_name;
104           else
105                     host = inet_ntoa(raddrp->sin_addr);
106 
107           /* truncate hostname to fit nicely into field */
108           if (strlen(host) > HOST_WIDTH)
109                     host[HOST_WIDTH] = '\0';
110 
111           printf("%-*s\t", HOST_WIDTH, host);
112 
113           if (sizeof(time_t) == sizeof(host_stat->curtime.tv_sec)) {
114                     tmp_time = localtime((time_t *)&host_stat->curtime.tv_sec);
115                     host_time = *tmp_time;
116 
117                     host_stat->curtime.tv_sec -= host_stat->boottime.tv_sec;
118 
119                     tmp_time = gmtime((time_t *)&host_stat->curtime.tv_sec);
120                     host_uptime = *tmp_time;
121           }
122           else {                        /* non-32-bit time_t */
123                     tmp_time_t = host_stat->curtime.tv_sec;
124                     tmp_time = localtime(&tmp_time_t);
125                     host_time = *tmp_time;
126 
127                     host_stat->curtime.tv_sec -= host_stat->boottime.tv_sec;
128 
129                     tmp_time_t = host_stat->curtime.tv_sec;
130                     tmp_time = gmtime(&tmp_time_t);
131                     host_uptime = *tmp_time;
132           }
133 
134           #define updays (host_stat->curtime.tv_sec  / 86400)
135           if (host_uptime.tm_yday != 0)
136                     snprintf(days_buf, sizeof days_buf, "%3d day%s, ", updays,
137                               (updays > 1) ? "s" : "");
138           else
139                     days_buf[0] = '\0';
140 
141           if (host_uptime.tm_hour != 0)
142                     snprintf(hours_buf, sizeof hours_buf, "%2d:%02d, ",
143                               host_uptime.tm_hour, host_uptime.tm_min);
144           else if (host_uptime.tm_min != 0)
145                     snprintf(hours_buf, sizeof hours_buf, "%2d mins, ",
146                                host_uptime.tm_min);
147           else if (host_stat->curtime.tv_sec < 60)
148                     snprintf(hours_buf, sizeof hours_buf, "%2d secs, ",
149                                host_uptime.tm_sec);
150           else
151                     hours_buf[0] = '\0';
152 
153           printf(" %2d:%02d%cm  up %9.9s%9.9s load average: %.2f %.2f %.2f\n",
154                     (host_time.tm_hour % 12) ? host_time.tm_hour % 12 : 12,
155                     host_time.tm_min,
156                     (host_time.tm_hour >= 12) ? 'p' : 'a',
157                     days_buf,
158                     hours_buf,
159                     (double)host_stat->avenrun[0]/FSCALE,
160                     (double)host_stat->avenrun[1]/FSCALE,
161                     (double)host_stat->avenrun[2]/FSCALE);
162 
163           remember_host(raddrp->sin_addr);
164           return(0);
165 }
166 
167 static int
onehost(const char * host)168 onehost(const char *host)
169 {
170           CLIENT *rstat_clnt;
171           statstime host_stat;
172           struct sockaddr_in addr;
173           struct hostent *hp;
174           struct timeval tv;
175 
176           hp = gethostbyname(host);
177           if (hp == NULL) {
178                     herror("rup");
179                     return(1);
180           }
181 
182           rstat_clnt = clnt_create(host, RSTATPROG, RSTATVERS_TIME, "udp");
183           if (rstat_clnt == NULL) {
184                     clnt_pcreateerror(host);
185                     return(1);
186           }
187 
188           bzero(&host_stat, sizeof(host_stat));
189           tv.tv_sec = 15;     /* XXX ??? */
190           tv.tv_usec = 0;
191           if (clnt_call(rstat_clnt, RSTATPROC_STATS, (xdrproc_t)xdr_void, NULL,
192               (xdrproc_t)xdr_statstime, &host_stat, tv) != RPC_SUCCESS) {
193                     clnt_perror(rstat_clnt, host);
194                     clnt_destroy(rstat_clnt);
195                     return(1);
196           }
197 
198           addr.sin_addr.s_addr = *(int *)hp->h_addr;
199           rstat_reply((caddr_t)&host_stat, &addr);
200           clnt_destroy(rstat_clnt);
201           return (0);
202 }
203 
204 static void
allhosts(void)205 allhosts(void)
206 {
207           statstime host_stat;
208           enum clnt_stat clnt_stat;
209 
210           clnt_stat = clnt_broadcast(RSTATPROG, RSTATVERS_TIME, RSTATPROC_STATS,
211                                            (xdrproc_t)xdr_void, NULL,
212                                            (xdrproc_t)xdr_statstime, &host_stat,
213                                            (resultproc_t)rstat_reply);
214           if (clnt_stat != RPC_SUCCESS && clnt_stat != RPC_TIMEDOUT)
215                     errx(1, "%s", clnt_sperrno(clnt_stat));
216 }
217 
218 static void
usage(void)219 usage(void)
220 {
221           fprintf(stderr, "usage: rup [host ...]\n");
222           exit(1);
223 }
224 
225 int
main(int argc,char * argv[])226 main(int argc, char *argv[])
227 {
228           int ch, retval;
229 
230           retval = 0;
231           while ((ch = getopt(argc, argv, "")) != -1)
232                     switch (ch) {
233                     default:
234                               usage();
235                               /*NOTREACHED*/
236                     }
237 
238           setlinebuf(stdout);
239           if (argc == optind)
240                     allhosts();
241           else {
242                     for (; optind < argc; optind++)
243                               retval += onehost(argv[optind]);
244           }
245           exit(retval ? 1 : 0);
246 }
247