Use sysctl to fetch stats from the kernel instead of reading variables
directly via libkvm. PR: kern/122875, bin/123014 Tested by: Danny Braniss danny cs.huji.ac.il MFC after: 1 week
This commit is contained in:
parent
d993ea4271
commit
87f2ff4f3e
Notes:
svn2git
2020-12-20 02:59:44 +00:00
svn path=/head/; revision=179710
@ -4,7 +4,7 @@ PROG = rpc.rstatd
|
|||||||
SRCS = rstatd.c rstat_proc.c
|
SRCS = rstatd.c rstat_proc.c
|
||||||
MAN = rpc.rstatd.8
|
MAN = rpc.rstatd.8
|
||||||
|
|
||||||
DPADD= ${LIBRPCSVC} ${LIBUTIL} ${LIBDEVSTAT} ${LIBKVM}
|
DPADD= ${LIBRPCSVC} ${LIBUTIL} ${LIBDEVSTAT}
|
||||||
LDADD= -lrpcsvc -lutil -ldevstat -lkvm
|
LDADD= -lrpcsvc -lutil -ldevstat
|
||||||
|
|
||||||
.include <bsd.prog.mk>
|
.include <bsd.prog.mk>
|
||||||
|
@ -53,9 +53,7 @@ static const char rcsid[] =
|
|||||||
#include <err.h>
|
#include <err.h>
|
||||||
#include <errno.h>
|
#include <errno.h>
|
||||||
#include <fcntl.h>
|
#include <fcntl.h>
|
||||||
#include <kvm.h>
|
|
||||||
#include <limits.h>
|
#include <limits.h>
|
||||||
#include <nlist.h>
|
|
||||||
#include <signal.h>
|
#include <signal.h>
|
||||||
#include <stdio.h>
|
#include <stdio.h>
|
||||||
#include <stdlib.h>
|
#include <stdlib.h>
|
||||||
@ -76,17 +74,8 @@ static const char rcsid[] =
|
|||||||
#undef if_collisions
|
#undef if_collisions
|
||||||
#include <rpcsvc/rstat.h>
|
#include <rpcsvc/rstat.h>
|
||||||
|
|
||||||
struct nlist nl[] = {
|
|
||||||
#define X_CPTIME 0
|
|
||||||
{ "_cp_time" },
|
|
||||||
#define X_CNT 1
|
|
||||||
{ "_cnt" },
|
|
||||||
{ "" },
|
|
||||||
};
|
|
||||||
|
|
||||||
int haveadisk(void);
|
int haveadisk(void);
|
||||||
void updatexfers(int, int *);
|
void updatexfers(int, int *);
|
||||||
void setup(void);
|
|
||||||
int stats_service(void);
|
int stats_service(void);
|
||||||
|
|
||||||
extern int from_inetd;
|
extern int from_inetd;
|
||||||
@ -101,7 +90,6 @@ union {
|
|||||||
|
|
||||||
void updatestat();
|
void updatestat();
|
||||||
static int stat_is_init = 0;
|
static int stat_is_init = 0;
|
||||||
static kvm_t *kd;
|
|
||||||
|
|
||||||
static int cp_time_xlat[RSTAT_CPUSTATES] = { CP_USER, CP_NICE, CP_SYS,
|
static int cp_time_xlat[RSTAT_CPUSTATES] = { CP_USER, CP_NICE, CP_SYS,
|
||||||
CP_IDLE };
|
CP_IDLE };
|
||||||
@ -116,7 +104,6 @@ void
|
|||||||
stat_init(void)
|
stat_init(void)
|
||||||
{
|
{
|
||||||
stat_is_init = 1;
|
stat_is_init = 1;
|
||||||
setup();
|
|
||||||
alarm(0);
|
alarm(0);
|
||||||
updatestat();
|
updatestat();
|
||||||
(void) signal(SIGALRM, updatestat);
|
(void) signal(SIGALRM, updatestat);
|
||||||
@ -194,7 +181,6 @@ updatestat(void)
|
|||||||
#ifdef DEBUG
|
#ifdef DEBUG
|
||||||
fprintf(stderr, "about to closedown\n");
|
fprintf(stderr, "about to closedown\n");
|
||||||
#endif
|
#endif
|
||||||
kvm_close(kd);
|
|
||||||
if (from_inetd)
|
if (from_inetd)
|
||||||
exit(0);
|
exit(0);
|
||||||
else {
|
else {
|
||||||
@ -213,9 +199,9 @@ updatestat(void)
|
|||||||
}
|
}
|
||||||
hz = clockrate.hz;
|
hz = clockrate.hz;
|
||||||
|
|
||||||
if (kvm_read(kd, (long)nl[X_CPTIME].n_value, (char *)bsd_cp_time, sizeof(bsd_cp_time))
|
len = sizeof(bsd_cp_time);
|
||||||
!= sizeof(bsd_cp_time)) {
|
if (sysctlbyname("kern.cp_time", bsd_cp_time, &len, 0, 0) < 0) {
|
||||||
syslog(LOG_ERR, "rstat: can't read cp_time from kmem");
|
syslog(LOG_ERR, "sysctl(kern.cp_time): %m");
|
||||||
exit(1);
|
exit(1);
|
||||||
}
|
}
|
||||||
for(i = 0; i < RSTAT_CPUSTATES ; i++)
|
for(i = 0; i < RSTAT_CPUSTATES ; i++)
|
||||||
@ -244,20 +230,23 @@ updatestat(void)
|
|||||||
stats_all.s1.cp_time[1], stats_all.s1.cp_time[2], stats_all.s1.cp_time[3]);
|
stats_all.s1.cp_time[1], stats_all.s1.cp_time[2], stats_all.s1.cp_time[3]);
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
/* XXX - should use sysctl */
|
#define FETCH_CNT(stat, cnt) do { \
|
||||||
if (kvm_read(kd, (long)nl[X_CNT].n_value, (char *)&cnt, sizeof cnt) != sizeof cnt) {
|
len = sizeof((stat)); \
|
||||||
syslog(LOG_ERR, "rstat: can't read cnt from kmem");
|
if (sysctlbyname("vm.stats." #cnt , &(stat), &len, 0, 0) < 0) { \
|
||||||
exit(1);
|
syslog(LOG_ERR, "sysctl(vm.stats." #cnt "): %m"); \
|
||||||
}
|
exit(1); \
|
||||||
stats_all.s1.v_pgpgin = cnt.v_vnodepgsin;
|
} \
|
||||||
stats_all.s1.v_pgpgout = cnt.v_vnodepgsout;
|
} while (0)
|
||||||
stats_all.s1.v_pswpin = cnt.v_swappgsin;
|
|
||||||
stats_all.s1.v_pswpout = cnt.v_swappgsout;
|
FETCH_CNT(stats_all.s1.v_pgpgin, vm.v_vnodepgsin);
|
||||||
stats_all.s1.v_intr = cnt.v_intr;
|
FETCH_CNT(stats_all.s1.v_pgpgout, vm.v_vnodepgsout);
|
||||||
|
FETCH_CNT(stats_all.s1.v_pswpin, vm.v_swappgsin);
|
||||||
|
FETCH_CNT(stats_all.s1.v_pswpout, vm.v_swappgsout);
|
||||||
|
FETCH_CNT(stats_all.s1.v_intr, sys.v_intr);
|
||||||
|
FETCH_CNT(stats_all.s2.v_swtch, sys.v_swtch);
|
||||||
gettimeofday(&tm, (struct timezone *) 0);
|
gettimeofday(&tm, (struct timezone *) 0);
|
||||||
stats_all.s1.v_intr -= hz*(tm.tv_sec - btm.tv_sec) +
|
stats_all.s1.v_intr -= hz*(tm.tv_sec - btm.tv_sec) +
|
||||||
hz*(tm.tv_usec - btm.tv_usec)/1000000;
|
hz*(tm.tv_usec - btm.tv_usec)/1000000;
|
||||||
stats_all.s2.v_swtch = cnt.v_swtch;
|
|
||||||
|
|
||||||
/* update disk transfers */
|
/* update disk transfers */
|
||||||
updatexfers(RSTAT_DK_NDRIVE, stats_all.s1.dk_xfer);
|
updatexfers(RSTAT_DK_NDRIVE, stats_all.s1.dk_xfer);
|
||||||
@ -303,24 +292,6 @@ updatestat(void)
|
|||||||
alarm(1);
|
alarm(1);
|
||||||
}
|
}
|
||||||
|
|
||||||
void
|
|
||||||
setup()
|
|
||||||
{
|
|
||||||
char errbuf[_POSIX2_LINE_MAX];
|
|
||||||
|
|
||||||
int en;
|
|
||||||
|
|
||||||
if ((kd = kvm_openfiles(NULL, NULL, NULL, O_RDONLY, errbuf)) == NULL) {
|
|
||||||
syslog(LOG_ERR, "rpc.rstatd, %s", errbuf);
|
|
||||||
exit(1);
|
|
||||||
}
|
|
||||||
|
|
||||||
if ((en = kvm_nlist(kd, nl)) != 0) {
|
|
||||||
syslog(LOG_ERR, "rstatd: Can't get namelist. %d", en);
|
|
||||||
exit (1);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* returns true if have a disk
|
* returns true if have a disk
|
||||||
*/
|
*/
|
||||||
|
Loading…
Reference in New Issue
Block a user