src/libstatgrab/page_stats.c

/*
 * i-scream central monitoring system
 * http://www.i-scream.org
 * Copyright (C) 2000-2004 i-scream
 * 
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation; either
 * version 2.1 of the License, or (at your option) any later version.
 * 
 * This library is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * Lesser General Public License for more details.
 * 
 * You should have received a copy of the GNU Lesser General Public
 * License along with this library; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA
 * 02111-1307 USA
 *
 * $Id: page_stats.c,v 1.17 2004/02/16 14:55:32 tdb Exp $
 */

#ifdef HAVE_CONFIG_H
#include "config.h"
#endif

#include "statgrab.h"
#include "tools.h"
#include <time.h>
#ifdef SOLARIS
#include <kstat.h>
#include <sys/sysinfo.h>
#include <string.h>
#endif
#if defined(LINUX) || defined(CYGWIN)
#include <stdio.h>
#include <string.h>
#endif
#if defined(FREEBSD) || defined(DFBSD)
#include <sys/types.h>
#include <sys/sysctl.h>
#endif
#if defined(NETBSD) || defined(OPENBSD)
#include <sys/param.h>
#include <uvm/uvm.h>
#endif

static sg_page_stats page_stats;
static int page_stats_uninit=1;

sg_page_stats *sg_get_page_stats(){
#ifdef SOLARIS
        kstat_ctl_t *kc;
        kstat_t *ksp;
        cpu_stat_t cs;
#endif
#if defined(LINUX) || defined(CYGWIN)
        FILE *f;
        char *line_ptr;
#endif
#if defined(FREEBSD) || defined(DFBSD)
        size_t size;
#endif
#if defined(NETBSD) || defined(OPENBSD)
        struct uvmexp *uvm;
#endif

        page_stats.systime = time(NULL);
        page_stats.pages_pagein=0;
        page_stats.pages_pageout=0;

#ifdef SOLARIS
        if ((kc = kstat_open()) == NULL) {
                return NULL;
        }
        for (ksp = kc->kc_chain; ksp!=NULL; ksp = ksp->ks_next) {
                if ((strcmp(ksp->ks_module, "cpu_stat")) != 0) continue;
                if (kstat_read(kc, ksp, &cs) == -1) {
                        continue;
                }

                page_stats.pages_pagein+=(long long)cs.cpu_vminfo.pgpgin;
                page_stats.pages_pageout+=(long long)cs.cpu_vminfo.pgpgout;
        }

        kstat_close(kc);
#endif
#if defined(LINUX) || defined(CYGWIN)
        if ((f = fopen("/proc/vmstat", "r")) != NULL) {
                while ((line_ptr = sg_f_read_line(f, "")) != NULL) {
                        long long value;

                        if (sscanf(line_ptr, "%*s %lld", &value) != 1) {
                                continue;
                        }

                        if (strncmp(line_ptr, "pgpgin ", 7) == 0) {
                                page_stats.pages_pagein = value;
                        } else if (strncmp(line_ptr, "pgpgout ", 8) == 0) {
                                page_stats.pages_pageout = value;
                        }
                }

                fclose(f);
        } else if ((f = fopen("/proc/stat", "r")) != NULL) {
                if ((line_ptr = sg_f_read_line(f, "page")) == NULL) {
                        fclose(f);
                        return NULL;
                }

                if (sscanf(line_ptr, "page %lld %lld", &page_stats.pages_pagein, &page_stats.pages_pageout) != 2) {
                        fclose(f);
                        return NULL;
                }

                fclose(f);
        } else {
                return NULL;
        }
#endif
#if defined(FREEBSD) || defined(DFBSD)
        size = sizeof page_stats.pages_pagein;
        if (sysctlbyname("vm.stats.vm.v_swappgsin", &page_stats.pages_pagein, &size, NULL, 0) < 0){
                return NULL;
        }
        size = sizeof page_stats.pages_pageout;
        if (sysctlbyname("vm.stats.vm.v_swappgsout", &page_stats.pages_pageout, &size, NULL, 0) < 0){
                return NULL;
        }
#endif
#if defined(NETBSD) || defined(OPENBSD)
        if ((uvm = sg_get_uvmexp()) == NULL) {
                return NULL;
        }

        page_stats.pages_pagein = uvm->pgswapin;
        page_stats.pages_pageout = uvm->pgswapout;
#endif

        return &page_stats;
}

sg_page_stats *sg_get_page_stats_diff(){
        sg_page_stats *page_ptr;
        static sg_page_stats page_stats_diff;

        if(page_stats_uninit){
                page_ptr=sg_get_page_stats();
                if(page_ptr==NULL){
                        return NULL;
                }
                page_stats_uninit=0;
                return page_ptr;
        }

        page_stats_diff.pages_pagein=page_stats.pages_pagein;
        page_stats_diff.pages_pageout=page_stats.pages_pageout;
        page_stats_diff.systime=page_stats.systime;

        page_ptr=sg_get_page_stats();
        if(page_ptr==NULL){
                return NULL;
        }

        page_stats_diff.pages_pagein=page_stats.pages_pagein-page_stats_diff.pages_pagein;
        page_stats_diff.pages_pageout=page_stats.pages_pageout-page_stats_diff.pages_pageout;
        page_stats_diff.systime=page_stats.systime-page_stats_diff.systime;
        
        return &page_stats_diff;
}
Revision:	1.18
Committed:	Mon Apr 5 15:40:15 2004 UTC (20 years, 1 month ago) by ats
Content type:	text/plain
Branch:	MAIN
Changes since 1.17:	+11 -11 lines
Log Message:	Rename all the functions, types and enums in the API to be consistent. Types are now of the form "sg_mem_stats"; functions of the form "sg_get_mem_stats"; enums of the form "SG_PROCESS_STATE_RUNNING". (The old get_proc_snapshot follows the usual calling convention now.) Make internal functions static where possible. Rename non-static internal functions to have an sg_ prefix so they don't collide with those from other libraries. In particular, strlcpy and strlcat are now called sg_strlcpy and sg_strlcat and are always included. Fix saidar and statgrab to use the new API.
#	User	Rev	Content
1	tdb	1.13	/*
2	pajs	1.1	* i-scream central monitoring system
3	tdb	1.6	* http://www.i-scream.org
4	tdb	1.13	* Copyright (C) 2000-2004 i-scream
5	pajs	1.1	*
6	tdb	1.13	* This library is free software; you can redistribute it and/or
7			* modify it under the terms of the GNU Lesser General Public
8			* License as published by the Free Software Foundation; either
9			* version 2.1 of the License, or (at your option) any later version.
10	pajs	1.1	*
11	tdb	1.13	* This library is distributed in the hope that it will be useful,
12	pajs	1.1	* but WITHOUT ANY WARRANTY; without even the implied warranty of
13	tdb	1.13	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14			* Lesser General Public License for more details.
15	pajs	1.1	*
16	tdb	1.13	* You should have received a copy of the GNU Lesser General Public
17			* License along with this library; if not, write to the Free Software
18			* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA
19			* 02111-1307 USA
20	tdb	1.14	*
21	ats	1.18	* $Id: page_stats.c,v 1.17 2004/02/16 14:55:32 tdb Exp $
22	pajs	1.1	*/
23
24			#ifdef HAVE_CONFIG_H
25			#include "config.h"
26			#endif
27
28	pajs	1.2	#include "statgrab.h"
29	ats	1.9	#include "tools.h"
30	pajs	1.4	#include <time.h>
31	pajs	1.1	#ifdef SOLARIS
32			#include <kstat.h>
33			#include <sys/sysinfo.h>
34	pajs	1.2	#include <string.h>
35	pajs	1.1	#endif
36	ats	1.11	#if defined(LINUX) \|\| defined(CYGWIN)
37	pajs	1.4	#include <stdio.h>
38	ats	1.10	#include <string.h>
39	pajs	1.4	#endif
40	tdb	1.17	#if defined(FREEBSD) \|\| defined(DFBSD)
41	pajs	1.5	#include <sys/types.h>
42			#include <sys/sysctl.h>
43			#endif
44	tdb	1.16	#if defined(NETBSD) \|\| defined(OPENBSD)
45	tdb	1.15	#include <sys/param.h>
46			#include <uvm/uvm.h>
47			#endif
48	pajs	1.3
49	ats	1.18	static sg_page_stats page_stats;
50	pajs	1.3	static int page_stats_uninit=1;
51
52	ats	1.18	sg_page_stats *sg_get_page_stats(){
53	pajs	1.4	#ifdef SOLARIS
54	pajs	1.1	kstat_ctl_t *kc;
55			kstat_t *ksp;
56			cpu_stat_t cs;
57	pajs	1.4	#endif
58	ats	1.11	#if defined(LINUX) \|\| defined(CYGWIN)
59	pajs	1.4	FILE *f;
60			char *line_ptr;
61			#endif
62	tdb	1.17	#if defined(FREEBSD) \|\| defined(DFBSD)
63	pajs	1.5	size_t size;
64			#endif
65	tdb	1.15	#if defined(NETBSD) \|\| defined(OPENBSD)
66	ats	1.9	struct uvmexp *uvm;
67			#endif
68	pajs	1.2
69	ats	1.9	page_stats.systime = time(NULL);
70	pajs	1.2	page_stats.pages_pagein=0;
71			page_stats.pages_pageout=0;
72	pajs	1.1
73	pajs	1.4	#ifdef SOLARIS
74	pajs	1.1	if ((kc = kstat_open()) == NULL) {
75			return NULL;
76			}
77			for (ksp = kc->kc_chain; ksp!=NULL; ksp = ksp->ks_next) {
78			if ((strcmp(ksp->ks_module, "cpu_stat")) != 0) continue;
79			if (kstat_read(kc, ksp, &cs) == -1) {
80			continue;
81			}
82
83	pajs	1.2	page_stats.pages_pagein+=(long long)cs.cpu_vminfo.pgpgin;
84			page_stats.pages_pageout+=(long long)cs.cpu_vminfo.pgpgout;
85			}
86
87			kstat_close(kc);
88	pajs	1.4	#endif
89	ats	1.11	#if defined(LINUX) \|\| defined(CYGWIN)
90	ats	1.10	if ((f = fopen("/proc/vmstat", "r")) != NULL) {
91	ats	1.18	while ((line_ptr = sg_f_read_line(f, "")) != NULL) {
92	ats	1.10	long long value;
93
94			if (sscanf(line_ptr, "%*s %lld", &value) != 1) {
95			continue;
96			}
97
98			if (strncmp(line_ptr, "pgpgin ", 7) == 0) {
99			page_stats.pages_pagein = value;
100			} else if (strncmp(line_ptr, "pgpgout ", 8) == 0) {
101			page_stats.pages_pageout = value;
102			}
103			}
104
105			fclose(f);
106			} else if ((f = fopen("/proc/stat", "r")) != NULL) {
107	ats	1.18	if ((line_ptr = sg_f_read_line(f, "page")) == NULL) {
108	ats	1.10	fclose(f);
109			return NULL;
110			}
111
112			if (sscanf(line_ptr, "page %lld %lld", &page_stats.pages_pagein, &page_stats.pages_pageout) != 2) {
113	pajs	1.12	fclose(f);
114	ats	1.10	return NULL;
115			}
116
117	pajs	1.4	fclose(f);
118	ats	1.10	} else {
119	pajs	1.4	return NULL;
120			}
121	pajs	1.5	#endif
122	tdb	1.17	#if defined(FREEBSD) \|\| defined(DFBSD)
123	ats	1.8	size = sizeof page_stats.pages_pagein;
124	ats	1.7	if (sysctlbyname("vm.stats.vm.v_swappgsin", &page_stats.pages_pagein, &size, NULL, 0) < 0){
125	pajs	1.5	return NULL;
126			}
127	ats	1.8	size = sizeof page_stats.pages_pageout;
128	ats	1.7	if (sysctlbyname("vm.stats.vm.v_swappgsout", &page_stats.pages_pageout, &size, NULL, 0) < 0){
129	pajs	1.5	return NULL;
130			}
131	ats	1.9	#endif
132	tdb	1.16	#if defined(NETBSD) \|\| defined(OPENBSD)
133	ats	1.18	if ((uvm = sg_get_uvmexp()) == NULL) {
134	ats	1.9	return NULL;
135			}
136	tdb	1.15
137	ats	1.9	page_stats.pages_pagein = uvm->pgswapin;
138			page_stats.pages_pageout = uvm->pgswapout;
139	pajs	1.4	#endif
140	pajs	1.1
141	pajs	1.2	return &page_stats;
142	pajs	1.3	}
143
144	ats	1.18	sg_page_stats *sg_get_page_stats_diff(){
145			sg_page_stats *page_ptr;
146			static sg_page_stats page_stats_diff;
147	pajs	1.3
148			if(page_stats_uninit){
149	ats	1.18	page_ptr=sg_get_page_stats();
150	pajs	1.3	if(page_ptr==NULL){
151			return NULL;
152			}
153			page_stats_uninit=0;
154			return page_ptr;
155			}
156
157			page_stats_diff.pages_pagein=page_stats.pages_pagein;
158			page_stats_diff.pages_pageout=page_stats.pages_pageout;
159			page_stats_diff.systime=page_stats.systime;
160
161	ats	1.18	page_ptr=sg_get_page_stats();
162	pajs	1.3	if(page_ptr==NULL){
163			return NULL;
164			}
165
166			page_stats_diff.pages_pagein=page_stats.pages_pagein-page_stats_diff.pages_pagein;
167			page_stats_diff.pages_pageout=page_stats.pages_pageout-page_stats_diff.pages_pageout;
168			page_stats_diff.systime=page_stats.systime-page_stats_diff.systime;
169
170			return &page_stats_diff;
171	pajs	1.1	}