rstat_proc.c revision 1.20 1 1.20 mrg /* $NetBSD: rstat_proc.c,v 1.20 1997/10/07 11:28:18 mrg Exp $ */
2 1.16 thorpej
3 1.1 brezak /*
4 1.1 brezak * Sun RPC is a product of Sun Microsystems, Inc. and is provided for
5 1.1 brezak * unrestricted use provided that this legend is included on all tape
6 1.1 brezak * media and as a part of the software program in whole or part. Users
7 1.1 brezak * may copy or modify Sun RPC without charge, but are not authorized
8 1.1 brezak * to license or distribute it to anyone else except as part of a product or
9 1.1 brezak * program developed by the user.
10 1.1 brezak *
11 1.1 brezak * SUN RPC IS PROVIDED AS IS WITH NO WARRANTIES OF ANY KIND INCLUDING THE
12 1.1 brezak * WARRANTIES OF DESIGN, MERCHANTIBILITY AND FITNESS FOR A PARTICULAR
13 1.1 brezak * PURPOSE, OR ARISING FROM A COURSE OF DEALING, USAGE OR TRADE PRACTICE.
14 1.1 brezak *
15 1.1 brezak * Sun RPC is provided with no support and without any obligation on the
16 1.1 brezak * part of Sun Microsystems, Inc. to assist in its use, correction,
17 1.1 brezak * modification or enhancement.
18 1.1 brezak *
19 1.1 brezak * SUN MICROSYSTEMS, INC. SHALL HAVE NO LIABILITY WITH RESPECT TO THE
20 1.1 brezak * INFRINGEMENT OF COPYRIGHTS, TRADE SECRETS OR ANY PATENTS BY SUN RPC
21 1.1 brezak * OR ANY PART THEREOF.
22 1.1 brezak *
23 1.1 brezak * In no event will Sun Microsystems, Inc. be liable for any lost revenue
24 1.1 brezak * or profits or other special, indirect and consequential damages, even if
25 1.1 brezak * Sun has been advised of the possibility of such damages.
26 1.1 brezak *
27 1.1 brezak * Sun Microsystems, Inc.
28 1.1 brezak * 2550 Garcia Avenue
29 1.1 brezak * Mountain View, California 94043
30 1.1 brezak */
31 1.20 mrg
32 1.20 mrg #include <sys/cdefs.h>
33 1.3 mycroft #ifndef lint
34 1.20 mrg #if 0
35 1.20 mrg static char sccsid[] = "from: @(#)rpc.rstatd.c 1.1 86/09/25 Copyr 1984 Sun Micro";
36 1.20 mrg static char sccsid[] = "from: @(#)rstat_proc.c 2.2 88/08/01 4.0 RPCSRC";
37 1.20 mrg #else
38 1.20 mrg __RCSID("$NetBSD: rstat_proc.c,v 1.20 1997/10/07 11:28:18 mrg Exp $");
39 1.20 mrg #endif
40 1.3 mycroft #endif
41 1.1 brezak
42 1.1 brezak /*
43 1.1 brezak * rstat service: built with rstat.x and derived from rpc.rstatd.c
44 1.3 mycroft *
45 1.3 mycroft * Copyright (c) 1984 by Sun Microsystems, Inc.
46 1.1 brezak */
47 1.1 brezak
48 1.4 jtc #include <stdio.h>
49 1.4 jtc #include <stdlib.h>
50 1.4 jtc #include <string.h>
51 1.1 brezak #include <signal.h>
52 1.9 pk #include <fcntl.h>
53 1.9 pk #include <kvm.h>
54 1.9 pk #include <limits.h>
55 1.1 brezak #include <rpc/rpc.h>
56 1.1 brezak #include <sys/socket.h>
57 1.1 brezak #include <nlist.h>
58 1.1 brezak #include <syslog.h>
59 1.1 brezak #include <sys/errno.h>
60 1.1 brezak #include <sys/param.h>
61 1.1 brezak #ifdef BSD
62 1.1 brezak #include <sys/vmmeter.h>
63 1.1 brezak #include <sys/dkstat.h>
64 1.18 thorpej #include "dkstats.h"
65 1.1 brezak #else
66 1.1 brezak #include <sys/dk.h>
67 1.1 brezak #endif
68 1.1 brezak #include <net/if.h>
69 1.4 jtc
70 1.4 jtc #undef FSHIFT /* Use protocol's shift and scale values */
71 1.4 jtc #undef FSCALE
72 1.5 mycroft #undef DK_NDRIVE
73 1.8 cgd #undef CPUSTATES
74 1.8 cgd #undef if_ipackets
75 1.8 cgd #undef if_ierrors
76 1.8 cgd #undef if_opackets
77 1.8 cgd #undef if_oerrors
78 1.8 cgd #undef if_collisions
79 1.1 brezak #include <rpcsvc/rstat.h>
80 1.1 brezak
81 1.9 pk #ifdef BSD
82 1.9 pk #define BSD_CPUSTATES 5 /* Use protocol's idea of CPU states */
83 1.9 pk int cp_xlat[CPUSTATES] = { CP_USER, CP_NICE, CP_SYS, CP_IDLE };
84 1.9 pk #endif
85 1.9 pk
86 1.1 brezak struct nlist nl[] = {
87 1.18 thorpej #define X_CNT 0
88 1.7 cgd { "_cnt" },
89 1.18 thorpej #define X_IFNET 1
90 1.1 brezak { "_ifnet" },
91 1.18 thorpej #define X_BOOTTIME 2
92 1.1 brezak { "_boottime" },
93 1.17 cgd { NULL },
94 1.1 brezak };
95 1.18 thorpej
96 1.18 thorpej extern int dk_ndrive; /* From dkstats.c */
97 1.18 thorpej extern struct _disk cur, last;
98 1.18 thorpej int hz;
99 1.18 thorpej char *memf = NULL, *nlistf = NULL;
100 1.18 thorpej
101 1.12 cgd struct ifnet_head ifnetq; /* chain of ethernet interfaces */
102 1.10 cgd int numintfs;
103 1.1 brezak
104 1.1 brezak extern int from_inetd;
105 1.1 brezak int sincelastreq = 0; /* number of alarms since last request */
106 1.1 brezak extern int closedown;
107 1.9 pk kvm_t *kfd;
108 1.1 brezak
109 1.1 brezak union {
110 1.11 mycroft struct stats s1;
111 1.11 mycroft struct statsswtch s2;
112 1.11 mycroft struct statstime s3;
113 1.1 brezak } stats_all;
114 1.1 brezak
115 1.20 mrg extern void dkreadstats __P((void));
116 1.20 mrg extern int dkinit __P((int));
117 1.20 mrg
118 1.20 mrg void updatestat __P((int));
119 1.20 mrg void setup __P((void));
120 1.20 mrg void stat_init __P((void));
121 1.20 mrg int havedisk __P((void));
122 1.20 mrg void rstat_service __P((struct svc_req *, SVCXPRT *));
123 1.20 mrg
124 1.1 brezak static stat_is_init = 0;
125 1.1 brezak extern int errno;
126 1.1 brezak
127 1.1 brezak #ifndef FSCALE
128 1.1 brezak #define FSCALE (1 << 8)
129 1.1 brezak #endif
130 1.1 brezak
131 1.20 mrg void
132 1.1 brezak stat_init()
133 1.1 brezak {
134 1.11 mycroft stat_is_init = 1;
135 1.11 mycroft setup();
136 1.20 mrg updatestat(0);
137 1.11 mycroft (void) signal(SIGALRM, updatestat);
138 1.11 mycroft alarm(1);
139 1.1 brezak }
140 1.1 brezak
141 1.1 brezak statstime *
142 1.13 pk rstatproc_stats_3_svc(arg, rqstp)
143 1.13 pk void *arg;
144 1.13 pk struct svc_req *rqstp;
145 1.1 brezak {
146 1.11 mycroft if (!stat_is_init)
147 1.11 mycroft stat_init();
148 1.11 mycroft sincelastreq = 0;
149 1.11 mycroft return (&stats_all.s3);
150 1.1 brezak }
151 1.1 brezak
152 1.1 brezak statsswtch *
153 1.13 pk rstatproc_stats_2_svc(arg, rqstp)
154 1.13 pk void *arg;
155 1.13 pk struct svc_req *rqstp;
156 1.1 brezak {
157 1.11 mycroft if (!stat_is_init)
158 1.11 mycroft stat_init();
159 1.11 mycroft sincelastreq = 0;
160 1.19 fvdl stats_all.s2.if_opackets = stats_all.s3.if_opackets;
161 1.11 mycroft return (&stats_all.s2);
162 1.1 brezak }
163 1.1 brezak
164 1.1 brezak stats *
165 1.13 pk rstatproc_stats_1_svc(arg, rqstp)
166 1.13 pk void *arg;
167 1.13 pk struct svc_req *rqstp;
168 1.1 brezak {
169 1.11 mycroft if (!stat_is_init)
170 1.11 mycroft stat_init();
171 1.11 mycroft sincelastreq = 0;
172 1.19 fvdl stats_all.s1.if_opackets = stats_all.s3.if_opackets;
173 1.11 mycroft return (&stats_all.s1);
174 1.1 brezak }
175 1.1 brezak
176 1.1 brezak u_int *
177 1.13 pk rstatproc_havedisk_3_svc(arg, rqstp)
178 1.13 pk void *arg;
179 1.13 pk struct svc_req *rqstp;
180 1.1 brezak {
181 1.11 mycroft static u_int have;
182 1.1 brezak
183 1.11 mycroft if (!stat_is_init)
184 1.11 mycroft stat_init();
185 1.11 mycroft sincelastreq = 0;
186 1.11 mycroft have = havedisk();
187 1.11 mycroft return (&have);
188 1.1 brezak }
189 1.1 brezak
190 1.1 brezak u_int *
191 1.13 pk rstatproc_havedisk_2_svc(arg, rqstp)
192 1.13 pk void *arg;
193 1.13 pk struct svc_req *rqstp;
194 1.1 brezak {
195 1.13 pk return (rstatproc_havedisk_3_svc(arg, rqstp));
196 1.1 brezak }
197 1.1 brezak
198 1.1 brezak u_int *
199 1.13 pk rstatproc_havedisk_1_svc(arg, rqstp)
200 1.13 pk void *arg;
201 1.13 pk struct svc_req *rqstp;
202 1.1 brezak {
203 1.13 pk return (rstatproc_havedisk_3_svc(arg, rqstp));
204 1.1 brezak }
205 1.1 brezak
206 1.1 brezak void
207 1.20 mrg updatestat(dummy)
208 1.20 mrg int dummy;
209 1.1 brezak {
210 1.10 cgd long off;
211 1.18 thorpej int i;
212 1.7 cgd struct vmmeter cnt;
213 1.1 brezak struct ifnet ifnet;
214 1.1 brezak double avrun[3];
215 1.1 brezak struct timeval tm, btm;
216 1.1 brezak
217 1.1 brezak #ifdef DEBUG
218 1.11 mycroft syslog(LOG_DEBUG, "entering updatestat");
219 1.1 brezak #endif
220 1.1 brezak if (sincelastreq >= closedown) {
221 1.1 brezak #ifdef DEBUG
222 1.11 mycroft syslog(LOG_DEBUG, "about to closedown");
223 1.1 brezak #endif
224 1.1 brezak if (from_inetd)
225 1.1 brezak exit(0);
226 1.1 brezak else {
227 1.1 brezak stat_is_init = 0;
228 1.1 brezak return;
229 1.1 brezak }
230 1.1 brezak }
231 1.1 brezak sincelastreq++;
232 1.1 brezak
233 1.18 thorpej /*
234 1.18 thorpej * dkreadstats reads in the "disk_count" as well as the "disklist"
235 1.18 thorpej * statistics. It also retrieves "hz" and the "cp_time" array.
236 1.18 thorpej */
237 1.18 thorpej dkreadstats();
238 1.19 fvdl memset(stats_all.s3.dk_xfer, 0, sizeof(stats_all.s3.dk_xfer));
239 1.18 thorpej for (i = 0; i < dk_ndrive && i < DK_NDRIVE; i++)
240 1.19 fvdl stats_all.s3.dk_xfer[i] = cur.dk_xfer[i];
241 1.18 thorpej
242 1.9 pk #ifdef BSD
243 1.9 pk for (i = 0; i < CPUSTATES; i++)
244 1.19 fvdl stats_all.s3.cp_time[i] = cur.cp_time[cp_xlat[i]];
245 1.9 pk #else
246 1.9 pk if (kvm_read(kfd, (long)nl[X_CPTIME].n_value,
247 1.19 fvdl (char *)stats_all.s3.cp_time,
248 1.19 fvdl sizeof (stats_all.s3.cp_time))
249 1.19 fvdl != sizeof (stats_all.s3.cp_time)) {
250 1.11 mycroft syslog(LOG_ERR, "can't read cp_time from kmem");
251 1.1 brezak exit(1);
252 1.1 brezak }
253 1.1 brezak #endif
254 1.1 brezak #ifdef BSD
255 1.1 brezak (void)getloadavg(avrun, sizeof(avrun) / sizeof(avrun[0]));
256 1.1 brezak #endif
257 1.19 fvdl stats_all.s3.avenrun[0] = avrun[0] * FSCALE;
258 1.19 fvdl stats_all.s3.avenrun[1] = avrun[1] * FSCALE;
259 1.19 fvdl stats_all.s3.avenrun[2] = avrun[2] * FSCALE;
260 1.9 pk if (kvm_read(kfd, (long)nl[X_BOOTTIME].n_value,
261 1.19 fvdl (char *)&btm, sizeof (stats_all.s3.boottime))
262 1.19 fvdl != sizeof (stats_all.s3.boottime)) {
263 1.11 mycroft syslog(LOG_ERR, "can't read boottime from kmem");
264 1.1 brezak exit(1);
265 1.1 brezak }
266 1.19 fvdl stats_all.s3.boottime.tv_sec = btm.tv_sec;
267 1.19 fvdl stats_all.s3.boottime.tv_usec = btm.tv_usec;
268 1.1 brezak
269 1.1 brezak
270 1.1 brezak #ifdef DEBUG
271 1.19 fvdl syslog(LOG_DEBUG, "%d %d %d %d\n", stats_all.s3.cp_time[0],
272 1.19 fvdl stats_all.s3.cp_time[1], stats_all.s3.cp_time[2], stats_all.s3.cp_time[3]);
273 1.1 brezak #endif
274 1.1 brezak
275 1.9 pk if (kvm_read(kfd, (long)nl[X_CNT].n_value, (char *)&cnt, sizeof cnt) !=
276 1.9 pk sizeof cnt) {
277 1.11 mycroft syslog(LOG_ERR, "can't read cnt from kmem");
278 1.1 brezak exit(1);
279 1.1 brezak }
280 1.19 fvdl stats_all.s3.v_pgpgin = cnt.v_pgpgin;
281 1.19 fvdl stats_all.s3.v_pgpgout = cnt.v_pgpgout;
282 1.19 fvdl stats_all.s3.v_pswpin = cnt.v_pswpin;
283 1.19 fvdl stats_all.s3.v_pswpout = cnt.v_pswpout;
284 1.19 fvdl stats_all.s3.v_intr = cnt.v_intr;
285 1.1 brezak gettimeofday(&tm, (struct timezone *) 0);
286 1.19 fvdl stats_all.s3.v_intr -= hz*(tm.tv_sec - btm.tv_sec) +
287 1.1 brezak hz*(tm.tv_usec - btm.tv_usec)/1000000;
288 1.19 fvdl stats_all.s3.v_swtch = cnt.v_swtch;
289 1.18 thorpej
290 1.19 fvdl stats_all.s3.if_ipackets = 0;
291 1.19 fvdl stats_all.s3.if_opackets = 0;
292 1.19 fvdl stats_all.s3.if_ierrors = 0;
293 1.19 fvdl stats_all.s3.if_oerrors = 0;
294 1.19 fvdl stats_all.s3.if_collisions = 0;
295 1.12 cgd for (off = (long)ifnetq.tqh_first, i = 0; off && i < numintfs; i++) {
296 1.9 pk if (kvm_read(kfd, off, (char *)&ifnet, sizeof ifnet) !=
297 1.9 pk sizeof ifnet) {
298 1.11 mycroft syslog(LOG_ERR, "can't read ifnet from kmem");
299 1.1 brezak exit(1);
300 1.1 brezak }
301 1.19 fvdl stats_all.s3.if_ipackets += ifnet.if_data.ifi_ipackets;
302 1.19 fvdl stats_all.s3.if_opackets += ifnet.if_data.ifi_opackets;
303 1.19 fvdl stats_all.s3.if_ierrors += ifnet.if_data.ifi_ierrors;
304 1.19 fvdl stats_all.s3.if_oerrors += ifnet.if_data.ifi_oerrors;
305 1.19 fvdl stats_all.s3.if_collisions += ifnet.if_data.ifi_collisions;
306 1.12 cgd off = (long)ifnet.if_list.tqe_next;
307 1.1 brezak }
308 1.1 brezak gettimeofday((struct timeval *)&stats_all.s3.curtime,
309 1.1 brezak (struct timezone *) 0);
310 1.1 brezak alarm(1);
311 1.1 brezak }
312 1.1 brezak
313 1.20 mrg void
314 1.1 brezak setup()
315 1.1 brezak {
316 1.1 brezak struct ifnet ifnet;
317 1.10 cgd long off;
318 1.9 pk char errbuf[_POSIX2_LINE_MAX];
319 1.9 pk
320 1.9 pk kfd = kvm_openfiles(NULL, NULL, NULL, O_RDONLY, errbuf);
321 1.9 pk if (kfd == NULL) {
322 1.11 mycroft syslog(LOG_ERR, "%s", errbuf);
323 1.9 pk exit (1);
324 1.9 pk }
325 1.1 brezak
326 1.9 pk if (kvm_nlist(kfd, nl) != 0) {
327 1.11 mycroft syslog(LOG_ERR, "can't get namelist");
328 1.1 brezak exit (1);
329 1.1 brezak }
330 1.1 brezak
331 1.12 cgd if (kvm_read(kfd, (long)nl[X_IFNET].n_value, &ifnetq,
332 1.12 cgd sizeof ifnetq) != sizeof ifnetq) {
333 1.12 cgd syslog(LOG_ERR, "can't read ifnet queue head from kmem");
334 1.1 brezak exit(1);
335 1.1 brezak }
336 1.1 brezak
337 1.1 brezak numintfs = 0;
338 1.12 cgd for (off = (long)ifnetq.tqh_first; off;) {
339 1.9 pk if (kvm_read(kfd, off, (char *)&ifnet, sizeof ifnet) !=
340 1.9 pk sizeof ifnet) {
341 1.11 mycroft syslog(LOG_ERR, "can't read ifnet from kmem");
342 1.1 brezak exit(1);
343 1.1 brezak }
344 1.1 brezak numintfs++;
345 1.12 cgd off = (long)ifnet.if_list.tqe_next;
346 1.1 brezak }
347 1.18 thorpej dkinit(0);
348 1.1 brezak }
349 1.1 brezak
350 1.1 brezak /*
351 1.1 brezak * returns true if have a disk
352 1.1 brezak */
353 1.9 pk int
354 1.1 brezak havedisk()
355 1.1 brezak {
356 1.18 thorpej return dk_ndrive != 0;
357 1.1 brezak }
358 1.1 brezak
359 1.1 brezak void
360 1.1 brezak rstat_service(rqstp, transp)
361 1.1 brezak struct svc_req *rqstp;
362 1.1 brezak SVCXPRT *transp;
363 1.1 brezak {
364 1.1 brezak union {
365 1.1 brezak int fill;
366 1.1 brezak } argument;
367 1.1 brezak char *result;
368 1.14 pk xdrproc_t xdr_argument, xdr_result;
369 1.13 pk char *(*local) __P((void *, struct svc_req *));
370 1.1 brezak
371 1.1 brezak switch (rqstp->rq_proc) {
372 1.1 brezak case NULLPROC:
373 1.1 brezak (void)svc_sendreply(transp, xdr_void, (char *)NULL);
374 1.1 brezak goto leave;
375 1.1 brezak
376 1.1 brezak case RSTATPROC_STATS:
377 1.14 pk xdr_argument = (xdrproc_t)xdr_void;
378 1.14 pk xdr_result = (xdrproc_t)xdr_statstime;
379 1.1 brezak switch (rqstp->rq_vers) {
380 1.1 brezak case RSTATVERS_ORIG:
381 1.13 pk local = (char *(*) __P((void *, struct svc_req *)))
382 1.13 pk rstatproc_stats_1_svc;
383 1.1 brezak break;
384 1.1 brezak case RSTATVERS_SWTCH:
385 1.13 pk local = (char *(*) __P((void *, struct svc_req *)))
386 1.13 pk rstatproc_stats_2_svc;
387 1.1 brezak break;
388 1.1 brezak case RSTATVERS_TIME:
389 1.13 pk local = (char *(*) __P((void *, struct svc_req *)))
390 1.13 pk rstatproc_stats_3_svc;
391 1.1 brezak break;
392 1.1 brezak default:
393 1.2 brezak svcerr_progvers(transp, RSTATVERS_ORIG, RSTATVERS_TIME);
394 1.1 brezak goto leave;
395 1.1 brezak }
396 1.1 brezak break;
397 1.1 brezak
398 1.1 brezak case RSTATPROC_HAVEDISK:
399 1.14 pk xdr_argument = (xdrproc_t)xdr_void;
400 1.14 pk xdr_result = (xdrproc_t)xdr_u_int;
401 1.1 brezak switch (rqstp->rq_vers) {
402 1.1 brezak case RSTATVERS_ORIG:
403 1.13 pk local = (char *(*) __P((void *, struct svc_req *)))
404 1.13 pk rstatproc_havedisk_1_svc;
405 1.1 brezak break;
406 1.1 brezak case RSTATVERS_SWTCH:
407 1.13 pk local = (char *(*) __P((void *, struct svc_req *)))
408 1.13 pk rstatproc_havedisk_2_svc;
409 1.1 brezak break;
410 1.1 brezak case RSTATVERS_TIME:
411 1.13 pk local = (char *(*) __P((void *, struct svc_req *)))
412 1.13 pk rstatproc_havedisk_3_svc;
413 1.1 brezak break;
414 1.1 brezak default:
415 1.2 brezak svcerr_progvers(transp, RSTATVERS_ORIG, RSTATVERS_TIME);
416 1.1 brezak goto leave;
417 1.1 brezak }
418 1.1 brezak break;
419 1.1 brezak
420 1.1 brezak default:
421 1.1 brezak svcerr_noproc(transp);
422 1.1 brezak goto leave;
423 1.1 brezak }
424 1.1 brezak bzero((char *)&argument, sizeof(argument));
425 1.10 cgd if (!svc_getargs(transp, xdr_argument, (caddr_t)&argument)) {
426 1.1 brezak svcerr_decode(transp);
427 1.1 brezak goto leave;
428 1.1 brezak }
429 1.1 brezak result = (*local)(&argument, rqstp);
430 1.1 brezak if (result != NULL && !svc_sendreply(transp, xdr_result, result)) {
431 1.1 brezak svcerr_systemerr(transp);
432 1.1 brezak }
433 1.10 cgd if (!svc_freeargs(transp, xdr_argument, (caddr_t)&argument)) {
434 1.1 brezak (void)fprintf(stderr, "unable to free arguments\n");
435 1.1 brezak exit(1);
436 1.1 brezak }
437 1.1 brezak leave:
438 1.1 brezak if (from_inetd)
439 1.1 brezak exit(0);
440 1.1 brezak }
441