ViewVC Help
View File | Revision Log | Show Annotations | Revision Graph | Root Listing
root/i-scream/projects/libstatgrab/src/libstatgrab/memory_stats.c
(Generate patch)

Comparing projects/libstatgrab/src/libstatgrab/memory_stats.c (file contents):
Revision 1.4 by tdb, Fri Feb 28 22:59:35 2003 UTC vs.
Revision 1.34 by tdb, Mon Oct 30 08:20:05 2006 UTC

# Line 1 | Line 1
1 < /*
2 < * i-scream central monitoring system
3 < * http://www.i-scream.org.uk
4 < * Copyright (C) 2000-2002 i-scream
1 > /*
2 > * i-scream libstatgrab
3 > * http://www.i-scream.org
4 > * Copyright (C) 2000-2004 i-scream
5   *
6 < * This program is free software; you can redistribute it and/or
7 < * modify it under the terms of the GNU General Public License
8 < * as published by the Free Software Foundation; either version 2
9 < * of the License, or (at your option) any later version.
6 > * 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   *
11 < * This program is distributed in the hope that it will be useful,
11 > * This library is distributed in the hope that it will be useful,
12   * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 < * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
14 < * GNU General Public License for more details.
13 > * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
14 > * Lesser General Public License for more details.
15   *
16 < * You should have received a copy of the GNU General Public License
17 < * along with this program; if not, write to the Free Software
18 < * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
16 > * 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 > *
21 > * $Id$
22   */
23  
24   #ifdef HAVE_CONFIG_H
25   #include "config.h"
26   #endif
27  
25 #include <stdio.h>
28   #include "statgrab.h"
29 + #include "tools.h"
30   #ifdef SOLARIS
31   #include <unistd.h>
32   #include <kstat.h>
33   #endif
34 + #if defined(LINUX) || defined(CYGWIN)
35 + #include <stdio.h>
36 + #include <string.h>
37 + #endif
38 + #if defined(FREEBSD) || defined(DFBSD)
39 + #include <sys/types.h>
40 + #include <sys/sysctl.h>
41 + #include <unistd.h>
42 + #endif
43 + #if defined(NETBSD)
44 + #include <sys/param.h>
45 + #include <sys/time.h>
46 + #include <uvm/uvm.h>
47 + #endif
48 + #if defined(OPENBSD)
49 + #include <sys/param.h>
50 + #include <sys/types.h>
51 + #include <sys/sysctl.h>
52 + #include <sys/unistd.h>
53 + #endif
54 + #ifdef HPUX
55 + #include <sys/param.h>
56 + #include <sys/pstat.h>
57 + #include <unistd.h>
58 + #endif
59 + #ifdef WIN32
60 + #include <windows.h>
61 + #include "win32.h"
62 + #endif
63  
64 < mem_stat_t *get_memory_stats(){
64 > sg_mem_stats *sg_get_mem_stats(){
65  
66 <        static mem_stat_t mem_stat;
66 >        static sg_mem_stats mem_stat;
67  
68 + #ifdef HPUX
69 +        struct pst_static *pstat_static;
70 +        struct pst_dynamic pstat_dynamic;
71 +        long long pagesize;
72 + #endif
73   #ifdef SOLARIS
74          kstat_ctl_t *kc;
75          kstat_t *ksp;
# Line 40 | Line 77 | mem_stat_t *get_memory_stats(){
77          long totalmem;
78          int pagesize;
79   #endif
80 + #if defined(LINUX) || defined(CYGWIN)
81 +        char *line_ptr;
82 +        unsigned long long value;
83 +        FILE *f;
84 + #endif
85 + #if defined(FREEBSD) || defined(DFBSD)
86 +        int mib[2];
87 +        u_long physmem;
88 +        size_t size;
89 +        u_int free_count;
90 +        u_int cache_count;
91 +        u_int inactive_count;
92 +        int pagesize;
93 + #endif
94 + #if defined(NETBSD)
95 +        struct uvmexp *uvm;
96 + #endif
97 + #if defined(OPENBSD)
98 +        int mib[2];
99 +        struct vmtotal vmtotal;
100 +        size_t size;
101 +        static int pagesize, pageshift;
102 + #endif
103 + #ifdef WIN32
104 +        MEMORYSTATUSEX memstats;
105 + #endif
106  
107 + #ifdef HPUX
108 +        if((pagesize=sysconf(_SC_PAGESIZE)) == -1){
109 +                sg_set_error_with_errno(SG_ERROR_SYSCONF, "_SC_PAGESIZE");
110 +                return NULL;
111 +        }
112 +
113 +        if (pstat_getdynamic(&pstat_dynamic, sizeof(pstat_dynamic), 1, 0) == -1) {
114 +                sg_set_error_with_errno(SG_ERROR_PSTAT, "pstat_dynamic");
115 +                return NULL;
116 +        }
117 +        pstat_static = sg_get_pstat_static();
118 +        if (pstat_static == NULL) {
119 +                return NULL;
120 +        }
121 +
122 +        /* FIXME Does this include swap? */
123 +        mem_stat.total = ((long long) pstat_static->physical_memory) * pagesize;
124 +        mem_stat.free = ((long long) pstat_dynamic.psd_free) * pagesize;
125 +        mem_stat.used = mem_stat.total - mem_stat.free;
126 + #endif
127   #ifdef SOLARIS
128          if((pagesize=sysconf(_SC_PAGESIZE)) == -1){
129 +                sg_set_error_with_errno(SG_ERROR_SYSCONF, "_SC_PAGESIZE");
130                  return NULL;    
131          }
132  
133          if((totalmem=sysconf(_SC_PHYS_PAGES)) == -1){
134 +                sg_set_error_with_errno(SG_ERROR_SYSCONF, "_SC_PHYS_PAGES");
135                  return NULL;
136          }
137  
138          if ((kc = kstat_open()) == NULL) {
139 +                sg_set_error(SG_ERROR_KSTAT_OPEN, NULL);
140                  return NULL;
141          }
142          if((ksp=kstat_lookup(kc, "unix", 0, "system_pages")) == NULL){
143 +                sg_set_error(SG_ERROR_KSTAT_LOOKUP, "unix,0,system_pages");
144                  return NULL;
145          }
146          if (kstat_read(kc, ksp, 0) == -1) {
147 +                sg_set_error(SG_ERROR_KSTAT_READ, NULL);
148                  return NULL;
149          }
150          if((kn=kstat_data_lookup(ksp, "freemem")) == NULL){
151 +                sg_set_error(SG_ERROR_KSTAT_DATA_LOOKUP, "freemem");
152                  return NULL;
153          }
154 <        kstat_close(kc);
154 >        kstat_close(kc);
155  
156          mem_stat.total = (long long)totalmem * (long long)pagesize;
157          mem_stat.free = ((long long)kn->value.ul) * (long long)pagesize;
158          mem_stat.used = mem_stat.total - mem_stat.free;
159   #endif
160  
161 <        return &mem_stat;
161 > #if defined(LINUX) || defined(CYGWIN)
162 >        if ((f = fopen("/proc/meminfo", "r")) == NULL) {
163 >                sg_set_error_with_errno(SG_ERROR_OPEN, "/proc/meminfo");
164 >                return NULL;
165 >        }
166  
167 +        while ((line_ptr = sg_f_read_line(f, "")) != NULL) {
168 +                if (sscanf(line_ptr, "%*s %llu kB", &value) != 1) {
169 +                        continue;
170 +                }
171 +                value *= 1024;
172 +
173 +                if (strncmp(line_ptr, "MemTotal:", 9) == 0) {
174 +                        mem_stat.total = value;
175 +                } else if (strncmp(line_ptr, "MemFree:", 8) == 0) {
176 +                        mem_stat.free = value;
177 +                } else if (strncmp(line_ptr, "Cached:", 7) == 0) {
178 +                        mem_stat.cache = value;
179 +                }
180 +        }
181 +
182 +        fclose(f);
183 +        mem_stat.used = mem_stat.total - mem_stat.free;
184 + #endif
185 +
186 + #if defined(FREEBSD) || defined(DFBSD)
187 +        /* Returns bytes */
188 +        mib[0] = CTL_HW;
189 +        mib[1] = HW_PHYSMEM;
190 +        size = sizeof physmem;
191 +        if (sysctl(mib, 2, &physmem, &size, NULL, 0) < 0) {
192 +                sg_set_error_with_errno(SG_ERROR_SYSCTL, "CTL_HW.HW_PHYSMEM");
193 +                return NULL;
194 +        }
195 +        mem_stat.total = physmem;
196 +
197 +        /*returns pages*/
198 +        size = sizeof free_count;
199 +        if (sysctlbyname("vm.stats.vm.v_free_count", &free_count, &size, NULL, 0) < 0){
200 +                sg_set_error_with_errno(SG_ERROR_SYSCTLBYNAME,
201 +                                        "vm.stats.vm.v_free_count");
202 +                return NULL;
203 +        }
204 +
205 +        size = sizeof inactive_count;
206 +        if (sysctlbyname("vm.stats.vm.v_inactive_count", &inactive_count , &size, NULL, 0) < 0){
207 +                sg_set_error_with_errno(SG_ERROR_SYSCTLBYNAME,
208 +                                        "vm.stats.vm.v_inactive_count");
209 +                return NULL;
210 +        }
211 +
212 +        size = sizeof cache_count;
213 +        if (sysctlbyname("vm.stats.vm.v_cache_count", &cache_count, &size, NULL, 0) < 0){
214 +                sg_set_error_with_errno(SG_ERROR_SYSCTLBYNAME,
215 +                                        "vm.stats.vm.v_cache_count");
216 +                return NULL;
217 +        }
218 +
219 +        /* Because all the vm.stats returns pages, I need to get the page size.
220 +         * After that I then need to multiple the anything that used vm.stats to
221 +         * get the system statistics by pagesize
222 +         */
223 +        pagesize = getpagesize();
224 +        mem_stat.cache=cache_count*pagesize;
225 +
226 +        /* Of couse nothing is ever that simple :) And I have inactive pages to
227 +         * deal with too. So I'm going to add them to free memory :)
228 +         */
229 +        mem_stat.free=(free_count*pagesize)+(inactive_count*pagesize);
230 +        mem_stat.used=physmem-mem_stat.free;
231 + #endif
232 +
233 + #if defined(NETBSD)
234 +        if ((uvm = sg_get_uvmexp()) == NULL) {
235 +                return NULL;
236 +        }
237 +
238 +        mem_stat.total = uvm->pagesize * uvm->npages;
239 +        mem_stat.cache = uvm->pagesize * (uvm->filepages + uvm->execpages);
240 +        mem_stat.free = uvm->pagesize * (uvm->free + uvm->inactive);
241 +        mem_stat.used = mem_stat.total - mem_stat.free;
242 + #endif
243 +
244 + #if defined(OPENBSD)
245 +        /* get the page size with "getpagesize" and calculate pageshift
246 +         * from it
247 +         */
248 +        pagesize = getpagesize();
249 +        pageshift = 0;
250 +        while (pagesize > 1) {
251 +                pageshift++;
252 +                pagesize >>= 1;
253 +        }
254 +
255 +        /* we only need the amount of log(2)1024 for our conversion */
256 +        pageshift -= 10;        /* Log base 2 of 1024 is 10 (2^10 == 1024) */
257 + #define pagetok(size) ((size) << pageshift)
258 +        mib[0] = CTL_VM;
259 +        mib[1] = VM_METER;
260 +        size = sizeof(vmtotal);
261 +        if (sysctl(mib, 2, &vmtotal, &size, NULL, 0) < 0) {
262 +                sg_set_error_with_errno(SG_ERROR_SYSCTL,
263 +                                        "CTL_VM.VM_METER");
264 +                return NULL;
265 +        }
266 +        /* convert memory stats to Kbytes */
267 +        mem_stat.used = pagetok(vmtotal.t_rm);          /* total real mem in use */
268 +        mem_stat.cache = 0;                             /* ? */
269 +        mem_stat.free = pagetok(vmtotal.t_free);        /* free memory pages */
270 +        mem_stat.total = (mem_stat.used + mem_stat.free);
271 + #endif
272 +
273 + #ifdef WIN32
274 +        memstats.dwLength = sizeof(memstats);
275 +        if (!GlobalMemoryStatusEx(&memstats)) {
276 +                sg_set_error_with_errno(SG_ERROR_MEMSTATUS, NULL);
277 +                return NULL;
278 +        }
279 +        mem_stat.free = memstats.ullAvailPhys;
280 +        mem_stat.total = memstats.ullTotalPhys;
281 +        mem_stat.used = mem_stat.total - mem_stat.free;
282 +        if(read_counter_large(SG_WIN32_MEM_CACHE, &mem_stat.cache)) {
283 +                mem_stat.cache = 0;
284 +        }
285 + #endif
286 +        return &mem_stat;
287   }

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines