SET_IF_DESIRED(av15, avg_15);
}
+ static char buff[BUFFSIZE]; /* used in the procedures */
+/***********************************************************************/
+
+static void crash(const char *filename) {
+ perror(filename);
+ exit(EXIT_FAILURE);
+}
+
+/***********************************************************************/
+
+static void getrunners(unsigned int *restrict running, unsigned int *restrict blocked) {
+ struct direct *ent;
+ DIR *proc;
+
+ *running=0;
+ *blocked=0;
+
+ if((proc=opendir("/proc"))==NULL) crash("/proc");
+
+ while(( ent=readdir(proc) )) {
+ unsigned size;
+ int fd;
+ char filename[80];
+ char c;
+ if (!isdigit(ent->d_name[0])) continue;
+ sprintf(filename, "/proc/%s/stat", ent->d_name);
+ fd = open(filename, O_RDONLY, 0);
+ if (fd == -1) continue;
+ read(fd,buff,BUFFSIZE-1);
+ sscanf(
+ buff,
+ "%*d %*s %c "
+ "%*d %*d %*d %*d %*d %*u %*u"
+ " %*u %*u %*u %*d %*d %*d %*d %*d %*d %*u %*u %*d %*u %u"
+ /* " %*u %*u %*u %*u %*u %*u %*u %*u %*u %*u %*u\n" */ ,
+ &c,
+ &size
+ );
+ close(fd);
+
+ if (c=='R') {
+ (*running)++;
+ continue;
+ }
+ if (c=='D') {
+ (*blocked)++;
+ continue;
+ }
+ }
+ closedir(proc);
+}
+
+/***********************************************************************/
+
+void getstat(jiff *restrict cuse, jiff *restrict cice, jiff *restrict csys, jiff *restrict cide, jiff *restrict ciow,
+ unsigned long *restrict pin, unsigned long *restrict pout, unsigned long *restrict s_in, unsigned long *restrict sout,
+ unsigned *restrict intr, unsigned *restrict ctxt,
+ unsigned int *restrict running, unsigned int *restrict blocked,
+ unsigned int *restrict btime, unsigned int *restrict processes) {
+ static int fd;
+ int need_vmstat_file = 0;
+ int need_proc_scan = 0;
+ const char* b;
+ buff[BUFFSIZE-1] = 0; /* ensure null termination in buffer */
+
+ if(fd){
+ lseek(fd, 0L, SEEK_SET);
+ }else{
+ fd = open("/proc/stat", O_RDONLY, 0);
+ if(fd == -1) crash("/proc/stat");
+ }
+ read(fd,buff,BUFFSIZE-1);
+ *intr = 0;
+ *ciow = 0; /* not separated out until the 2.5.41 kernel */
+
+ b = strstr(buff, "cpu ");
+ if(b) sscanf(b, "cpu %Lu %Lu %Lu %Lu %Lu", cuse, cice, csys, cide, ciow);
+
+ b = strstr(buff, "page ");
+ if(b) sscanf(b, "page %lu %lu", pin, pout);
+ else need_vmstat_file = 1;
+
+ b = strstr(buff, "swap ");
+ if(b) sscanf(b, "swap %lu %lu", s_in, sout);
+ else need_vmstat_file = 1;
+
+ b = strstr(buff, "intr ");
+ if(b) sscanf(b, "intr %u", intr);
+
+ b = strstr(buff, "ctxt ");
+ if(b) sscanf(b, "ctxt %u", ctxt);
+
+ b = strstr(buff, "btime ");
+ if(b) sscanf(b, "btime %u", btime);
+
+ b = strstr(buff, "processes ");
+ if(b) sscanf(b, "processes %u", processes);
+
+ b = strstr(buff, "procs_running ");
+ if(b) sscanf(b, "procs_running %u", running);
+ else need_proc_scan = 1;
+
+ b = strstr(buff, "procs_blocked ");
+ if(b) sscanf(b, "procs_blocked %u", blocked);
+ else need_proc_scan = 1;
+
+ if(need_proc_scan){ /* Linux 2.5.46 (approximately) and below */
+ getrunners(running, blocked);
+ }
+
+ (*running)--; // exclude vmstat itself
+
+ if(need_vmstat_file){ /* Linux 2.5.40-bk4 and above */
+ vminfo();
+ *pin = vm_pgpgin;
+ *pout = vm_pgpgout;
+ *s_in = vm_pswpin;
+ *sout = vm_pswpout;
+ }
+}
+
/***********************************************************************/
/*
* Copyright 1999 by Albert Cahalan; all rights reserved.
head = tail+1;
}
}
-/*****************************************************************/
+
// old: "Copyright 1994 by Henry Ware <al172@yfn.ysu.edu>. Copyleft same year."
// most code copyright 2002 Albert Cahalan
+// 27/05/2003 (Fabian) : Add unit conversion + interface
+// Export proc/stat access to libproc
+// Adapt vmstat helpfile
#include <stdio.h>
#include <stdlib.h>
#include "proc/sysinfo.h"
#include "proc/version.h"
+#include "vmstat.h"
-#define BUFFSIZE 8192
#define FALSE 0
#define TRUE 1
-static char buff[BUFFSIZE]; /* used in the procedures */
-
-typedef unsigned long long jiff;
-
static int a_option; /* "-a" means "show active/inactive" */
static unsigned sleep_time = 1;
fprintf(stderr," -V prints version.\n");
fprintf(stderr," -n causes the headers not to be reprinted regularly.\n");
fprintf(stderr," -a print inactive/active page stats.\n");
+ fprintf(stderr," -S unit size\n");
fprintf(stderr," delay is the delay between updates in seconds. \n");
+ fprintf(stderr," unit size k:1000 K:1024 m:1000000 M:1048576 (default is K)\n");
fprintf(stderr," count is the number of updates.\n");
exit(EXIT_FAILURE);
}
-static void crash(const char *filename) NORETURN;
-static void crash(const char *filename) {
- perror(filename);
- exit(EXIT_FAILURE);
-}
-
-
-////////////////////////////////////////////////////////////////////////
-
-static void getrunners(unsigned int *restrict running, unsigned int *restrict blocked) {
- static struct direct *ent;
- DIR *proc;
-
- *running=0;
- *blocked=0;
-
- if((proc=opendir("/proc"))==NULL) crash("/proc");
-
- while(( ent=readdir(proc) )) {
- unsigned size;
- int fd;
- char filename[80];
- char c;
- if (!isdigit(ent->d_name[0])) continue;
- sprintf(filename, "/proc/%s/stat", ent->d_name);
- fd = open(filename, O_RDONLY, 0);
- if (fd == -1) continue;
- read(fd,buff,BUFFSIZE-1);
- sscanf(
- buff,
- "%*d %*s %c "
- "%*d %*d %*d %*d %*d %*u %*u"
- " %*u %*u %*u %*d %*d %*d %*d %*d %*d %*u %*u %*d %*u %u"
- /* " %*u %*u %*u %*u %*u %*u %*u %*u %*u %*u %*u\n" */ ,
- &c,
- &size
- );
- close(fd);
-
- if (c=='R') {
- (*running)++;
- continue;
- }
- if (c=='D') {
- (*blocked)++;
- continue;
- }
- }
- closedir(proc);
-}
-
-static void getstat(jiff *restrict cuse, jiff *restrict cice, jiff *restrict csys, jiff *restrict cide, jiff *restrict ciow,
- unsigned long *restrict pin, unsigned long *restrict pout, unsigned long *restrict s_in, unsigned long *restrict sout,
- unsigned *restrict intr, unsigned *restrict ctxt,
- unsigned int *restrict running, unsigned int *restrict blocked,
- unsigned int *restrict btime, unsigned int *restrict processes) {
- static int fd;
- int need_vmstat_file = 0;
- int need_proc_scan = 0;
- const char* b;
- buff[BUFFSIZE-1] = 0; /* ensure null termination in buffer */
-
- if(fd){
- lseek(fd, 0L, SEEK_SET);
- }else{
- fd = open("/proc/stat", O_RDONLY, 0);
- if(fd == -1) crash("/proc/stat");
- }
- read(fd,buff,BUFFSIZE-1);
- *intr = 0;
- *ciow = 0; /* not separated out until the 2.5.41 kernel */
-
- b = strstr(buff, "cpu ");
- if(b) sscanf(b, "cpu %Lu %Lu %Lu %Lu %Lu", cuse, cice, csys, cide, ciow);
-
- b = strstr(buff, "page ");
- if(b) sscanf(b, "page %lu %lu", pin, pout);
- else need_vmstat_file = 1;
-
- b = strstr(buff, "swap ");
- if(b) sscanf(b, "swap %lu %lu", s_in, sout);
- else need_vmstat_file = 1;
-
- b = strstr(buff, "intr ");
- if(b) sscanf(b, "intr %u", intr);
-
- b = strstr(buff, "ctxt ");
- if(b) sscanf(b, "ctxt %u", ctxt);
-
- b = strstr(buff, "btime ");
- if(b) sscanf(b, "btime %u", btime);
-
- b = strstr(buff, "processes ");
- if(b) sscanf(b, "processes %u", processes);
-
- b = strstr(buff, "procs_running ");
- if(b) sscanf(b, "procs_running %u", running);
- else need_proc_scan = 1;
-
- b = strstr(buff, "procs_blocked ");
- if(b) sscanf(b, "procs_blocked %u", blocked);
- else need_proc_scan = 1;
-
- if(need_proc_scan){ /* Linux 2.5.46 (approximately) and below */
- getrunners(running, blocked);
- }
-
- (*running)--; // exclude vmstat itself
-
- if(need_vmstat_file){ /* Linux 2.5.40-bk4 and above */
- vminfo();
- *pin = vm_pgpgin;
- *pout = vm_pgpgout;
- *s_in = vm_pswpin;
- *sout = vm_pswpout;
- }
-}
-
-
-//////////////////////////////////////////////////////////////////////////////////////
+/////////////////////////////////////////////////////////////////////////////
#if 0
// produce: " 6 ", "123 ", "123k ", etc.
);
}
+////////////////////////////////////////////////////////////////////////////
+
+unsigned long unitConvert(unsigned int kbsize)
+{
+ float cvSize;
+ cvSize=(float)kbsize/dataUnit*1024;
+ return ((unsigned long) cvSize);
+}
+
+////////////////////////////////////////////////////////////////////////////
+
static void new_format(void) {
const char format[]="%2u %2u %6lu %6lu %6lu %6lu %4u %4u %5u %5u %4u %5u %2u %2u %2u %2u\n";
unsigned int tog=0; /* toggle switch for cleaner code */
new_header();
meminfo();
+
getstat(cpu_use,cpu_nic,cpu_sys,cpu_idl,cpu_iow,
pgpgin,pgpgout,pswpin,pswpout,
intr,ctxt,
&running,&blocked,
&dummy_1, &dummy_2);
+
duse= *cpu_use + *cpu_nic;
dsys= *cpu_sys;
didl= *cpu_idl;
divo2= Div/2UL;
printf(format,
running, blocked,
- kb_swap_used, kb_main_free,
- a_option?kb_inactive:kb_main_buffers,
- a_option?kb_active:kb_main_cached,
- (unsigned)( (*pswpin * kb_per_page * hz + divo2) / Div ),
- (unsigned)( (*pswpout * kb_per_page * hz + divo2) / Div ),
+ unitConvert(kb_swap_used), unitConvert(kb_main_free),
+ unitConvert(a_option?kb_inactive:kb_main_buffers),
+ unitConvert(a_option?kb_active:kb_main_cached),
+ (unsigned)( (*pswpin * unitConvert(kb_per_page) * hz + divo2) / Div ),
+ (unsigned)( (*pswpout * unitConvert(kb_per_page) * hz + divo2) / Div ),
(unsigned)( (*pgpgin * hz + divo2) / Div ),
(unsigned)( (*pgpgout * hz + divo2) / Div ),
(unsigned)( (*intr * hz + divo2) / Div ),
tog= !tog;
meminfo();
+
getstat(cpu_use+tog,cpu_nic+tog,cpu_sys+tog,cpu_idl+tog,cpu_iow+tog,
pgpgin+tog,pgpgout+tog,pswpin+tog,pswpout+tog,
intr+tog,ctxt+tog,
&running,&blocked,
&dummy_1,&dummy_2);
+
duse= cpu_use[tog]-cpu_use[!tog] + cpu_nic[tog]-cpu_nic[!tog];
dsys= cpu_sys[tog]-cpu_sys[!tog];
didl= cpu_idl[tog]-cpu_idl[!tog];
divo2= Div/2UL;
printf(format,
running, blocked,
- kb_swap_used,kb_main_free,
- a_option?kb_inactive:kb_main_buffers,
- a_option?kb_active:kb_main_cached,
- (unsigned)( ( (pswpin [tog] - pswpin [!tog])*kb_per_page+sleep_half )/sleep_time ),
- (unsigned)( ( (pswpout[tog] - pswpout[!tog])*kb_per_page+sleep_half )/sleep_time ),
- (unsigned)( ( pgpgin [tog] - pgpgin [!tog] +sleep_half )/sleep_time ),
- (unsigned)( ( pgpgout[tog] - pgpgout[!tog] +sleep_half )/sleep_time ),
- (unsigned)( ( intr [tog] - intr [!tog] +sleep_half )/sleep_time ),
- (unsigned)( ( ctxt [tog] - ctxt [!tog] +sleep_half )/sleep_time ),
- (unsigned)( (100*duse+divo2)/Div ),
- (unsigned)( (100*dsys+divo2)/Div ),
- (unsigned)( (100*didl+divo2)/Div ),
- (unsigned)( (100*diow+divo2)/Div )
+ unitConvert(kb_swap_used),unitConvert(kb_main_free),
+ unitConvert(a_option?kb_inactive:kb_main_buffers),
+ unitConvert(a_option?kb_active:kb_main_cached),
+ (unsigned)( ( (pswpin [tog] - pswpin [!tog])*unitConvert(kb_per_page)+sleep_half )/sleep_time ), /*si*/
+ (unsigned)( ( (pswpout[tog] - pswpout[!tog])*unitConvert(kb_per_page)+sleep_half )/sleep_time ), /*so*/
+ (unsigned)( ( pgpgin [tog] - pgpgin [!tog] +sleep_half )/sleep_time ), /*bi*/
+ (unsigned)( ( pgpgout[tog] - pgpgout[!tog] +sleep_half )/sleep_time ), /*bo*/
+ (unsigned)( ( intr [tog] - intr [!tog] +sleep_half )/sleep_time ), /*in*/
+ (unsigned)( ( ctxt [tog] - ctxt [!tog] +sleep_half )/sleep_time ), /*cs*/
+ (unsigned)( (100*duse+divo2)/Div ), /*us*/
+ (unsigned)( (100*dsys+divo2)/Div ), /*sy*/
+ (unsigned)( (100*didl+divo2)/Div ), /*id*/
+ (unsigned)( (100*diow+divo2)/Div ) /*wa*/
);
}
}
-
-//////////////////////////////////////////////////////////////////////////////////////
+////////////////////////////////////////////////////////////////////////////
static void sum_format(void) {
unsigned int running, blocked, btime, processes;
unsigned int intr, ctxt;
meminfo();
+
getstat(&cpu_use, &cpu_nic, &cpu_sys, &cpu_idl, &cpu_iow,
&pgpgin, &pgpgout, &pswpin, &pswpout,
&intr, &ctxt,
&running, &blocked,
&btime, &processes);
- printf("%13lu kB total memory\n", kb_main_total);
- printf("%13lu kB used memory\n", kb_main_used);
- printf("%13lu kB active memory\n", kb_active);
- printf("%13lu kB inactive memory\n", kb_inactive);
- printf("%13lu kB free memory\n", kb_main_free);
- printf("%13lu kB buffer memory\n", kb_main_buffers);
- printf("%13lu kB swap cache\n", kb_main_cached);
- printf("%13lu kB total swap\n", kb_swap_total);
- printf("%13lu kB used swap\n", kb_swap_used);
- printf("%13lu kB free swap\n", kb_swap_free);
+
+ printf("%13lu %s total memory\n", unitConvert(kb_main_total),szDataUnit);
+ printf("%13lu %s used memory\n", unitConvert(kb_main_used),szDataUnit);
+ printf("%13lu %s active memory\n", unitConvert(kb_active),szDataUnit);
+ printf("%13lu %s inactive memory\n", unitConvert(kb_inactive),szDataUnit);
+ printf("%13lu %s free memory\n", unitConvert(kb_main_free),szDataUnit);
+ printf("%13lu %s buffer memory\n", unitConvert(kb_main_buffers),szDataUnit);
+ printf("%13lu %s swap cache\n", unitConvert(kb_main_cached),szDataUnit);
+ printf("%13lu %s total swap\n", unitConvert(kb_swap_total),szDataUnit);
+ printf("%13lu %s used swap\n", unitConvert(kb_swap_used),szDataUnit);
+ printf("%13lu %s free swap\n", unitConvert(kb_swap_free),szDataUnit);
printf("%13Lu non-nice user cpu ticks\n", cpu_use);
printf("%13Lu nice user cpu ticks\n", cpu_nic);
printf("%13Lu system cpu ticks\n", cpu_sys);
printf("%13u boot time\n", btime);
printf("%13u forks\n", processes);
}
-
static void fork_format(void) {
unsigned int running, blocked, btime, processes;
jiff cpu_use, cpu_nic, cpu_sys, cpu_idl, cpu_iow;
&intr, &ctxt,
&running, &blocked,
&btime, &processes);
+
printf("%13u forks\n", processes);
}
for (argv++;*argv;argv++) {
if ('-' ==(**argv)) {
switch (*(++(*argv))) {
+
case 'V':
display_version();
exit(0);
/* print only one header */
moreheaders=FALSE;
break;
+ case 'S':
+ if (argv[1]){
+ ++argv;
+ if (!strcmp(*argv, "k")) dataUnit=UNIT_k;
+ else if (!strcmp(*argv, "K")) dataUnit=UNIT_K;
+ else if (!strcmp(*argv, "m")) dataUnit=UNIT_m;
+ else if (!strcmp(*argv, "M")) dataUnit=UNIT_M;
+ else {fprintf(stderr, "-S requires k, K, m or M (default is kb)\n");
+ exit(EXIT_FAILURE);
+ }
+ strcpy(szDataUnit, *argv);
+ }else {fprintf(stderr, "-S requires an argument\n");
+ exit(EXIT_FAILURE);
+ }
+ break;
+
case 's':
// FIXME: check for conflicting args
sum_format();