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.23 2005/09/24 13:29:22 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
#ifdef AIX
#include <libperfstat.h>
#endif
#ifdef HPUX
#include <sys/pstat.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
#ifdef AIX
       perfstat_memory_total_t mem;
#endif
#ifdef HPUX
       struct pst_vminfo vminfo;
#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 AIX
        /* return code is number of structures returned */
        if(perfstat_memory_total(NULL, &mem, sizeof(perfstat_memory_total_t), 1) != 1) {
                sg_set_error_with_errno(SG_ERROR_SYSCTLBYNAME, "perfstat_memory_total");
                return NULL;
        }

        page_stats.pages_pagein  = mem.pgins;
        page_stats.pages_pageout = mem.pgouts;
#endif
#ifdef HPUX
        if( pstat_getvminfo( &vminfo, sizeof(vminfo), 1, 0 ) == -1 ) {
                sg_set_error_with_errno(SG_ERROR_SYSCTLBYNAME, "pstat_getswap");
                return NULL;
        };

        page_stats.pages_pagein  = vminfo.psv_spgin;
        page_stats.pages_pageout = vminfo.psv_spgout;
#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.24
Committed:	Sun Oct 3 18:35:58 2010 UTC (15 years, 1 month ago) by tdb
Content type:	text/plain
Branch:	MAIN
CVS Tags:	HEAD
Changes since 1.23:	+32 -1 lines
Log Message:	Add support for AIX 5.x - 9.x. Many thanks to Jens Rehsack <rehsack@googlemail.com> for providing the patch for this work. Thanks!
#	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.24	* $Id: page_stats.c,v 1.23 2005/09/24 13:29:22 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	tdb	1.24	#ifdef AIX
49			#include <libperfstat.h>
50			#endif
51			#ifdef HPUX
52			#include <sys/pstat.h>
53			#endif
54	tdb	1.23	#ifdef WIN32
55			#include "win32.h"
56			#endif
57	pajs	1.3
58	ats	1.18	static sg_page_stats page_stats;
59	tdb	1.23	#ifndef WIN32
60	pajs	1.3	static int page_stats_uninit=1;
61	tdb	1.23	#endif
62	pajs	1.3
63	ats	1.18	sg_page_stats *sg_get_page_stats(){
64	pajs	1.4	#ifdef SOLARIS
65	tdb	1.20	kstat_ctl_t *kc;
66			kstat_t *ksp;
67			cpu_stat_t cs;
68	pajs	1.4	#endif
69	ats	1.11	#if defined(LINUX) \|\| defined(CYGWIN)
70	pajs	1.4	FILE *f;
71			char *line_ptr;
72			#endif
73	tdb	1.17	#if defined(FREEBSD) \|\| defined(DFBSD)
74	pajs	1.5	size_t size;
75			#endif
76	tdb	1.15	#if defined(NETBSD) \|\| defined(OPENBSD)
77	ats	1.9	struct uvmexp *uvm;
78			#endif
79	tdb	1.24	#ifdef AIX
80			perfstat_memory_total_t mem;
81			#endif
82			#ifdef HPUX
83			struct pst_vminfo vminfo;
84			#endif
85	pajs	1.2
86	ats	1.9	page_stats.systime = time(NULL);
87	tdb	1.20	page_stats.pages_pagein=0;
88			page_stats.pages_pageout=0;
89	pajs	1.1
90	pajs	1.4	#ifdef SOLARIS
91	tdb	1.20	if ((kc = kstat_open()) == NULL) {
92	tdb	1.21	sg_set_error(SG_ERROR_KSTAT_OPEN, NULL);
93	tdb	1.20	return NULL;
94			}
95			for (ksp = kc->kc_chain; ksp!=NULL; ksp = ksp->ks_next) {
96			if ((strcmp(ksp->ks_module, "cpu_stat")) != 0) continue;
97			if (kstat_read(kc, ksp, &cs) == -1) {
98			continue;
99			}
100	pajs	1.1
101	pajs	1.2	page_stats.pages_pagein+=(long long)cs.cpu_vminfo.pgpgin;
102			page_stats.pages_pageout+=(long long)cs.cpu_vminfo.pgpgout;
103			}
104
105			kstat_close(kc);
106	pajs	1.4	#endif
107	ats	1.11	#if defined(LINUX) \|\| defined(CYGWIN)
108	ats	1.10	if ((f = fopen("/proc/vmstat", "r")) != NULL) {
109	ats	1.18	while ((line_ptr = sg_f_read_line(f, "")) != NULL) {
110	ats	1.10	long long value;
111
112			if (sscanf(line_ptr, "%*s %lld", &value) != 1) {
113			continue;
114			}
115
116			if (strncmp(line_ptr, "pgpgin ", 7) == 0) {
117			page_stats.pages_pagein = value;
118			} else if (strncmp(line_ptr, "pgpgout ", 8) == 0) {
119			page_stats.pages_pageout = value;
120			}
121			}
122
123			fclose(f);
124			} else if ((f = fopen("/proc/stat", "r")) != NULL) {
125	ats	1.18	if ((line_ptr = sg_f_read_line(f, "page")) == NULL) {
126	tdb	1.21	sg_set_error(SG_ERROR_PARSE, "page");
127	ats	1.10	fclose(f);
128			return NULL;
129			}
130
131			if (sscanf(line_ptr, "page %lld %lld", &page_stats.pages_pagein, &page_stats.pages_pageout) != 2) {
132	tdb	1.21	sg_set_error(SG_ERROR_PARSE, "page");
133	pajs	1.12	fclose(f);
134	ats	1.10	return NULL;
135			}
136
137	pajs	1.4	fclose(f);
138	ats	1.10	} else {
139	ats	1.22	sg_set_error_with_errno(SG_ERROR_OPEN, "/proc/stat");
140	pajs	1.4	return NULL;
141			}
142	pajs	1.5	#endif
143	tdb	1.17	#if defined(FREEBSD) \|\| defined(DFBSD)
144	ats	1.8	size = sizeof page_stats.pages_pagein;
145	tdb	1.20	if (sysctlbyname("vm.stats.vm.v_swappgsin", &page_stats.pages_pagein, &size, NULL, 0) < 0){
146	ats	1.22	sg_set_error_with_errno(SG_ERROR_SYSCTLBYNAME,
147			"vm.stats.vm.v_swappgsin");
148	tdb	1.20	return NULL;
149			}
150	ats	1.8	size = sizeof page_stats.pages_pageout;
151	tdb	1.20	if (sysctlbyname("vm.stats.vm.v_swappgsout", &page_stats.pages_pageout, &size, NULL, 0) < 0){
152	ats	1.22	sg_set_error_with_errno(SG_ERROR_SYSCTLBYNAME,
153			"vm.stats.vm.v_swappgsout");
154	tdb	1.20	return NULL;
155			}
156	ats	1.9	#endif
157	tdb	1.16	#if defined(NETBSD) \|\| defined(OPENBSD)
158	ats	1.18	if ((uvm = sg_get_uvmexp()) == NULL) {
159	ats	1.9	return NULL;
160			}
161	tdb	1.15
162	ats	1.9	page_stats.pages_pagein = uvm->pgswapin;
163			page_stats.pages_pageout = uvm->pgswapout;
164	pajs	1.4	#endif
165	tdb	1.24	#ifdef AIX
166			/* return code is number of structures returned */
167			if(perfstat_memory_total(NULL, &mem, sizeof(perfstat_memory_total_t), 1) != 1) {
168			sg_set_error_with_errno(SG_ERROR_SYSCTLBYNAME, "perfstat_memory_total");
169			return NULL;
170			}
171
172			page_stats.pages_pagein = mem.pgins;
173			page_stats.pages_pageout = mem.pgouts;
174			#endif
175			#ifdef HPUX
176			if( pstat_getvminfo( &vminfo, sizeof(vminfo), 1, 0 ) == -1 ) {
177			sg_set_error_with_errno(SG_ERROR_SYSCTLBYNAME, "pstat_getswap");
178			return NULL;
179			};
180
181			page_stats.pages_pagein = vminfo.psv_spgin;
182			page_stats.pages_pageout = vminfo.psv_spgout;
183			#endif
184	tdb	1.23	#ifdef WIN32
185			sg_set_error(SG_ERROR_UNSUPPORTED, "Win32");
186			return NULL;
187			#endif
188	pajs	1.1
189	pajs	1.2	return &page_stats;
190	pajs	1.3	}
191
192	ats	1.18	sg_page_stats *sg_get_page_stats_diff(){
193	tdb	1.23	static sg_page_stats page_stats_diff;
194			#ifndef WIN32
195	ats	1.18	sg_page_stats *page_ptr;
196	pajs	1.3
197			if(page_stats_uninit){
198	ats	1.18	page_ptr=sg_get_page_stats();
199	pajs	1.3	if(page_ptr==NULL){
200			return NULL;
201			}
202			page_stats_uninit=0;
203			return page_ptr;
204			}
205
206			page_stats_diff.pages_pagein=page_stats.pages_pagein;
207			page_stats_diff.pages_pageout=page_stats.pages_pageout;
208			page_stats_diff.systime=page_stats.systime;
209
210	ats	1.18	page_ptr=sg_get_page_stats();
211	pajs	1.3	if(page_ptr==NULL){
212			return NULL;
213			}
214
215	tdb	1.20	page_stats_diff.pages_pagein=page_stats.pages_pagein-page_stats_diff.pages_pagein;
216			page_stats_diff.pages_pageout=page_stats.pages_pageout-page_stats_diff.pages_pageout;
217			page_stats_diff.systime=page_stats.systime-page_stats_diff.systime;
218	tdb	1.23
219			#else /* WIN32 */
220			if(read_counter_large(SG_WIN32_PAGEIN, &page_stats_diff.pages_pagein)) {
221			sg_set_error(SG_ERROR_PDHREAD, PDH_PAGEIN);
222			return NULL;
223			}
224			if(read_counter_large(SG_WIN32_PAGEOUT, &page_stats_diff.pages_pageout)) {
225			sg_set_error(SG_ERROR_PDHREAD, PDH_PAGEIN);
226			return NULL;
227			}
228			page_stats_diff.systime = 0;
229			#endif /* WIN32 */
230
231	pajs	1.3	return &page_stats_diff;
232	pajs	1.1	}