src/libstatgrab/page_stats.c

/*
 * i-scream libstatgrab
 * 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.22 2004/07/18 21:30:11 ats 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
#ifdef WIN32
#include "win32.h"
#endif

static sg_page_stats page_stats;
#ifndef WIN32
static int page_stats_uninit=1;
#endif

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) {
                sg_set_error(SG_ERROR_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) {
                        sg_set_error(SG_ERROR_PARSE, "page");
                        fclose(f);
                        return NULL;
                }

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

                fclose(f);
        } else {
                sg_set_error_with_errno(SG_ERROR_OPEN, "/proc/stat");
                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){
                sg_set_error_with_errno(SG_ERROR_SYSCTLBYNAME,
                                        "vm.stats.vm.v_swappgsin");
                return NULL;
        }
        size = sizeof page_stats.pages_pageout;
        if (sysctlbyname("vm.stats.vm.v_swappgsout", &page_stats.pages_pageout, &size, NULL, 0) < 0){
                sg_set_error_with_errno(SG_ERROR_SYSCTLBYNAME,
                                        "vm.stats.vm.v_swappgsout");
                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
#ifdef WIN32
        sg_set_error(SG_ERROR_UNSUPPORTED, "Win32");
        return NULL;
#endif

        return &page_stats;
}

sg_page_stats *sg_get_page_stats_diff(){
        static sg_page_stats page_stats_diff;
#ifndef WIN32
        sg_page_stats *page_ptr;

        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;

#else /* WIN32 */
        if(read_counter_large(SG_WIN32_PAGEIN, &page_stats_diff.pages_pagein)) {
                sg_set_error(SG_ERROR_PDHREAD, PDH_PAGEIN);
                return NULL;
        }
        if(read_counter_large(SG_WIN32_PAGEOUT, &page_stats_diff.pages_pageout)) {
                sg_set_error(SG_ERROR_PDHREAD, PDH_PAGEIN);
                return NULL;
        }
        page_stats_diff.systime = 0;
#endif /* WIN32 */

        return &page_stats_diff;
}
Revision:	1.23
Committed:	Sat Sep 24 13:29:22 2005 UTC (20 years, 1 month ago) by tdb
Content type:	text/plain
Branch:	MAIN
CVS Tags:	LIBSTATGRAB_0_17, LIBSTATGRAB_0_16, LIBSTATGRAB_0_15, LIBSTATGRAB_0_14, LIBSTATGRAB_0_13
Changes since 1.22:	+25 -3 lines
Log Message:	Add WIN32 support via MINGW. We'll need to add stuff to the README file about what this requires to build. All the hard work done by: skel
#	User	Rev	Content
1	tdb	1.13	/*
2	tdb	1.19	* i-scream libstatgrab
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	tdb	1.23	* $Id: page_stats.c,v 1.22 2004/07/18 21:30:11 ats 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	tdb	1.23	#ifdef WIN32
49			#include "win32.h"
50			#endif
51	pajs	1.3
52	ats	1.18	static sg_page_stats page_stats;
53	tdb	1.23	#ifndef WIN32
54	pajs	1.3	static int page_stats_uninit=1;
55	tdb	1.23	#endif
56	pajs	1.3
57	ats	1.18	sg_page_stats *sg_get_page_stats(){
58	pajs	1.4	#ifdef SOLARIS
59	tdb	1.20	kstat_ctl_t *kc;
60			kstat_t *ksp;
61			cpu_stat_t cs;
62	pajs	1.4	#endif
63	ats	1.11	#if defined(LINUX) \|\| defined(CYGWIN)
64	pajs	1.4	FILE *f;
65			char *line_ptr;
66			#endif
67	tdb	1.17	#if defined(FREEBSD) \|\| defined(DFBSD)
68	pajs	1.5	size_t size;
69			#endif
70	tdb	1.15	#if defined(NETBSD) \|\| defined(OPENBSD)
71	ats	1.9	struct uvmexp *uvm;
72			#endif
73	pajs	1.2
74	ats	1.9	page_stats.systime = time(NULL);
75	tdb	1.20	page_stats.pages_pagein=0;
76			page_stats.pages_pageout=0;
77	pajs	1.1
78	pajs	1.4	#ifdef SOLARIS
79	tdb	1.20	if ((kc = kstat_open()) == NULL) {
80	tdb	1.21	sg_set_error(SG_ERROR_KSTAT_OPEN, NULL);
81	tdb	1.20	return NULL;
82			}
83			for (ksp = kc->kc_chain; ksp!=NULL; ksp = ksp->ks_next) {
84			if ((strcmp(ksp->ks_module, "cpu_stat")) != 0) continue;
85			if (kstat_read(kc, ksp, &cs) == -1) {
86			continue;
87			}
88	pajs	1.1
89	pajs	1.2	page_stats.pages_pagein+=(long long)cs.cpu_vminfo.pgpgin;
90			page_stats.pages_pageout+=(long long)cs.cpu_vminfo.pgpgout;
91			}
92
93			kstat_close(kc);
94	pajs	1.4	#endif
95	ats	1.11	#if defined(LINUX) \|\| defined(CYGWIN)
96	ats	1.10	if ((f = fopen("/proc/vmstat", "r")) != NULL) {
97	ats	1.18	while ((line_ptr = sg_f_read_line(f, "")) != NULL) {
98	ats	1.10	long long value;
99
100			if (sscanf(line_ptr, "%*s %lld", &value) != 1) {
101			continue;
102			}
103
104			if (strncmp(line_ptr, "pgpgin ", 7) == 0) {
105			page_stats.pages_pagein = value;
106			} else if (strncmp(line_ptr, "pgpgout ", 8) == 0) {
107			page_stats.pages_pageout = value;
108			}
109			}
110
111			fclose(f);
112			} else if ((f = fopen("/proc/stat", "r")) != NULL) {
113	ats	1.18	if ((line_ptr = sg_f_read_line(f, "page")) == NULL) {
114	tdb	1.21	sg_set_error(SG_ERROR_PARSE, "page");
115	ats	1.10	fclose(f);
116			return NULL;
117			}
118
119			if (sscanf(line_ptr, "page %lld %lld", &page_stats.pages_pagein, &page_stats.pages_pageout) != 2) {
120	tdb	1.21	sg_set_error(SG_ERROR_PARSE, "page");
121	pajs	1.12	fclose(f);
122	ats	1.10	return NULL;
123			}
124
125	pajs	1.4	fclose(f);
126	ats	1.10	} else {
127	ats	1.22	sg_set_error_with_errno(SG_ERROR_OPEN, "/proc/stat");
128	pajs	1.4	return NULL;
129			}
130	pajs	1.5	#endif
131	tdb	1.17	#if defined(FREEBSD) \|\| defined(DFBSD)
132	ats	1.8	size = sizeof page_stats.pages_pagein;
133	tdb	1.20	if (sysctlbyname("vm.stats.vm.v_swappgsin", &page_stats.pages_pagein, &size, NULL, 0) < 0){
134	ats	1.22	sg_set_error_with_errno(SG_ERROR_SYSCTLBYNAME,
135			"vm.stats.vm.v_swappgsin");
136	tdb	1.20	return NULL;
137			}
138	ats	1.8	size = sizeof page_stats.pages_pageout;
139	tdb	1.20	if (sysctlbyname("vm.stats.vm.v_swappgsout", &page_stats.pages_pageout, &size, NULL, 0) < 0){
140	ats	1.22	sg_set_error_with_errno(SG_ERROR_SYSCTLBYNAME,
141			"vm.stats.vm.v_swappgsout");
142	tdb	1.20	return NULL;
143			}
144	ats	1.9	#endif
145	tdb	1.16	#if defined(NETBSD) \|\| defined(OPENBSD)
146	ats	1.18	if ((uvm = sg_get_uvmexp()) == NULL) {
147	ats	1.9	return NULL;
148			}
149	tdb	1.15
150	ats	1.9	page_stats.pages_pagein = uvm->pgswapin;
151			page_stats.pages_pageout = uvm->pgswapout;
152	pajs	1.4	#endif
153	tdb	1.23	#ifdef WIN32
154			sg_set_error(SG_ERROR_UNSUPPORTED, "Win32");
155			return NULL;
156			#endif
157	pajs	1.1
158	pajs	1.2	return &page_stats;
159	pajs	1.3	}
160
161	ats	1.18	sg_page_stats *sg_get_page_stats_diff(){
162	tdb	1.23	static sg_page_stats page_stats_diff;
163			#ifndef WIN32
164	ats	1.18	sg_page_stats *page_ptr;
165	pajs	1.3
166			if(page_stats_uninit){
167	ats	1.18	page_ptr=sg_get_page_stats();
168	pajs	1.3	if(page_ptr==NULL){
169			return NULL;
170			}
171			page_stats_uninit=0;
172			return page_ptr;
173			}
174
175			page_stats_diff.pages_pagein=page_stats.pages_pagein;
176			page_stats_diff.pages_pageout=page_stats.pages_pageout;
177			page_stats_diff.systime=page_stats.systime;
178
179	ats	1.18	page_ptr=sg_get_page_stats();
180	pajs	1.3	if(page_ptr==NULL){
181			return NULL;
182			}
183
184	tdb	1.20	page_stats_diff.pages_pagein=page_stats.pages_pagein-page_stats_diff.pages_pagein;
185			page_stats_diff.pages_pageout=page_stats.pages_pageout-page_stats_diff.pages_pageout;
186			page_stats_diff.systime=page_stats.systime-page_stats_diff.systime;
187	tdb	1.23
188			#else /* WIN32 */
189			if(read_counter_large(SG_WIN32_PAGEIN, &page_stats_diff.pages_pagein)) {
190			sg_set_error(SG_ERROR_PDHREAD, PDH_PAGEIN);
191			return NULL;
192			}
193			if(read_counter_large(SG_WIN32_PAGEOUT, &page_stats_diff.pages_pageout)) {
194			sg_set_error(SG_ERROR_PDHREAD, PDH_PAGEIN);
195			return NULL;
196			}
197			page_stats_diff.systime = 0;
198			#endif /* WIN32 */
199
200	pajs	1.3	return &page_stats_diff;
201	pajs	1.1	}