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.7 by tdb, Sun Aug 24 20:24:09 2003 UTC vs.
Revision 1.30 by tdb, Mon Nov 1 18:30:17 2004 UTC

# Line 1 | Line 1
1 < /*
2 < * i-scream central monitoring system
1 > /*
2 > * i-scream libstatgrab
3   * http://www.i-scream.org
4 < * Copyright (C) 2000-2003 i-scream
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
# Line 23 | Line 26
26   #endif
27  
28   #include "statgrab.h"
29 + #include "tools.h"
30   #ifdef SOLARIS
31   #include <unistd.h>
32   #include <kstat.h>
33   #endif
34 < #ifdef LINUX
34 > #if defined(LINUX) || defined(CYGWIN)
35   #include <stdio.h>
36   #include <string.h>
33 #include "tools.h"
37   #endif
38 < #ifdef FREEBSD
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) || defined(OPENBSD)
44 + #include <sys/param.h>
45 + #include <sys/time.h>
46 + #include <uvm/uvm.h>
47 + #endif
48 + #ifdef HPUX
49 + #include <sys/param.h>
50 + #include <sys/pstat.h>
51 + #include <unistd.h>
52 + #endif
53  
54 < mem_stat_t *get_memory_stats(){
54 > sg_mem_stats *sg_get_mem_stats(){
55  
56 <        static mem_stat_t mem_stat;
56 >        static sg_mem_stats mem_stat;
57  
58 + #ifdef HPUX
59 +        struct pst_static pstat_static;
60 +        struct pst_dynamic pstat_dynamic;
61 +        long long pagesize;
62 + #endif
63   #ifdef SOLARIS
64          kstat_ctl_t *kc;
65          kstat_t *ksp;
# Line 49 | Line 67 | mem_stat_t *get_memory_stats(){
67          long totalmem;
68          int pagesize;
69   #endif
70 < #ifdef LINUX
70 > #if defined(LINUX) || defined(CYGWIN)
71          char *line_ptr;
72 +        unsigned long long value;
73          FILE *f;
74   #endif
75 < #ifdef FREEBSD
76 <        long inactive;
75 > #if defined(FREEBSD) || defined(DFBSD)
76 >        int mib[2];
77 >        u_long physmem;
78          size_t size;
79 +        u_int free_count;
80 +        u_int cache_count;
81 +        u_int inactive_count;
82          int pagesize;
83   #endif
84 + #if defined(NETBSD) || defined(OPENBSD)
85 +        struct uvmexp *uvm;
86 + #endif
87  
88 + #ifdef HPUX
89 +        if((pagesize=sysconf(_SC_PAGESIZE)) == -1){
90 +                sg_set_error_with_errno(SG_ERROR_SYSCONF, "_SC_PAGESIZE");
91 +                return NULL;
92 +        }
93 +
94 +        if (pstat_getdynamic(&pstat_dynamic, sizeof(pstat_dynamic), 1, 0) == -1) {
95 +                sg_set_error_with_errno(SG_ERROR_PSTAT, "pstat_dynamic");
96 +                return NULL;
97 +        }
98 +        if (pstat_getstatic(&pstat_static, sizeof(pstat_static), 1, 0) == -1) {
99 +                sg_set_error_with_errno(SG_ERROR_PSTAT, "pstat_static");
100 +                return NULL;
101 +        }
102 +
103 +        mem_stat.total = ((long long) pstat_static.physical_memory) * pagesize;
104 +        mem_stat.free = ((long long) pstat_dynamic.psd_free) * pagesize;
105 +        mem_stat.used = mem_stat.total - mem_stat.free;
106 + #endif
107   #ifdef SOLARIS
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((totalmem=sysconf(_SC_PHYS_PAGES)) == -1){
114 +                sg_set_error_with_errno(SG_ERROR_SYSCONF, "_SC_PHYS_PAGES");
115                  return NULL;
116          }
117  
118          if ((kc = kstat_open()) == NULL) {
119 +                sg_set_error(SG_ERROR_KSTAT_OPEN, NULL);
120                  return NULL;
121          }
122          if((ksp=kstat_lookup(kc, "unix", 0, "system_pages")) == NULL){
123 +                sg_set_error(SG_ERROR_KSTAT_LOOKUP, "unix,0,system_pages");
124                  return NULL;
125          }
126          if (kstat_read(kc, ksp, 0) == -1) {
127 +                sg_set_error(SG_ERROR_KSTAT_READ, NULL);
128                  return NULL;
129          }
130          if((kn=kstat_data_lookup(ksp, "freemem")) == NULL){
131 +                sg_set_error(SG_ERROR_KSTAT_DATA_LOOKUP, "freemem");
132                  return NULL;
133          }
134 <        kstat_close(kc);
134 >        kstat_close(kc);
135  
136          mem_stat.total = (long long)totalmem * (long long)pagesize;
137          mem_stat.free = ((long long)kn->value.ul) * (long long)pagesize;
138          mem_stat.used = mem_stat.total - mem_stat.free;
139   #endif
140  
141 < #ifdef LINUX
142 <        f=fopen("/proc/meminfo", "r");
143 <        if(f==NULL){
141 > #if defined(LINUX) || defined(CYGWIN)
142 >        if ((f = fopen("/proc/meminfo", "r")) == NULL) {
143 >                sg_set_error_with_errno(SG_ERROR_OPEN, "/proc/meminfo");
144                  return NULL;
145          }
146  
147 <        if((line_ptr=f_read_line(f, "Mem:"))==NULL){
148 <                fclose(f);
149 <                return NULL;
150 <        }
147 >        while ((line_ptr = sg_f_read_line(f, "")) != NULL) {
148 >                if (sscanf(line_ptr, "%*s %llu kB", &value) != 1) {
149 >                        continue;
150 >                }
151 >                value *= 1024;
152  
153 <        fclose(f);
154 <
155 <        /* Linux actually stores this as a unsigned long long, but
156 <         * our structures are just long longs. This shouldn't be a
157 <         * problem for sometime yet :)
158 <         */
159 <        if((sscanf(line_ptr,"Mem:  %lld %lld %lld %*d %*d %lld", \
108 <                &mem_stat.total, \
109 <                &mem_stat.used, \
110 <                &mem_stat.free, \
111 <                &mem_stat.cache))!=4){
112 <                        return NULL;
153 >                if (strncmp(line_ptr, "MemTotal:", 9) == 0) {
154 >                        mem_stat.total = value;
155 >                } else if (strncmp(line_ptr, "MemFree:", 8) == 0) {
156 >                        mem_stat.free = value;
157 >                } else if (strncmp(line_ptr, "Cached:", 7) == 0) {
158 >                        mem_stat.cache = value;
159 >                }
160          }
161  
162 +        fclose(f);
163 +        mem_stat.used = mem_stat.total - mem_stat.free;
164   #endif
165  
166 < #ifdef FREEBSD
167 <        /* Returns byes */
168 <        if (sysctlbyname("hw.physmem", NULL, &size, NULL, NULL) < 0){
166 > #if defined(FREEBSD) || defined(DFBSD)
167 >        /* Returns bytes */
168 >        mib[0] = CTL_HW;
169 >        mib[1] = HW_PHYSMEM;
170 >        size = sizeof physmem;
171 >        if (sysctl(mib, 2, &physmem, &size, NULL, 0) < 0) {
172 >                sg_set_error_with_errno(SG_ERROR_SYSCTL, "CTL_HW.HW_PHYSMEM");
173                  return NULL;
174 <        }
175 <        if (sysctlbyname("hw.physmem", &mem_stat.total, &size, NULL, NULL) < 0){
123 <                return NULL;
124 <        }
174 >        }
175 >        mem_stat.total = physmem;
176  
177          /*returns pages*/
178 <        if (sysctlbyname("vm.stats.vm.v_free_count", NULL, &size, NULL, NULL) < 0){
178 >        size = sizeof free_count;
179 >        if (sysctlbyname("vm.stats.vm.v_free_count", &free_count, &size, NULL, 0) < 0){
180 >                sg_set_error_with_errno(SG_ERROR_SYSCTLBYNAME,
181 >                                        "vm.stats.vm.v_free_count");
182                  return NULL;
183 <        }
130 <        if (sysctlbyname("vm.stats.vm.v_free_count", &mem_stat.free, &size, NULL, NULL) < 0){
131 <                return NULL;
132 <        }
183 >        }
184  
185 <        if (sysctlbyname("vm.stats.vm.v_inactive_count", NULL, &size, NULL, NULL) < 0){
185 >        size = sizeof inactive_count;
186 >        if (sysctlbyname("vm.stats.vm.v_inactive_count", &inactive_count , &size, NULL, 0) < 0){
187 >                sg_set_error_with_errno(SG_ERROR_SYSCTLBYNAME,
188 >                                        "vm.stats.vm.v_inactive_count");
189                  return NULL;
190 <        }
137 <        if (sysctlbyname("vm.stats.vm.v_inactive_count", &inactive , &size, NULL, NULL) < 0){
138 <                return NULL;
139 <        }
190 >        }
191  
192 <        if (sysctlbyname("vm.stats.vm.v_cache_count", NULL, &size, NULL, NULL) < 0){
192 >        size = sizeof cache_count;
193 >        if (sysctlbyname("vm.stats.vm.v_cache_count", &cache_count, &size, NULL, 0) < 0){
194 >                sg_set_error_with_errno(SG_ERROR_SYSCTLBYNAME,
195 >                                        "vm.stats.vm.v_cache_count");
196                  return NULL;
197 <        }
144 <        if (sysctlbyname("vm.stats.vm.v_cache_count", &mem_stat.cache, &size, NULL, NULL) < 0){
145 <                return NULL;
146 <        }
197 >        }
198  
199 <        /* Because all the vm.stats returns pages, i need to get the page size.
200 <         * After that i then need to multiple the anything that used vm.stats to get
201 <         * the system statistics by pagesize
199 >        /* Because all the vm.stats returns pages, I need to get the page size.
200 >         * After that I then need to multiple the anything that used vm.stats to
201 >         * get the system statistics by pagesize
202           */
203 <        if ((pagesize=getpagesize()) == -1){
204 <                return NULL;
154 <        }
203 >        pagesize = getpagesize();
204 >        mem_stat.cache=cache_count*pagesize;
205  
206 <        mem_stat.cache=mem_stat.cache*pagesize;
207 <        /* Of couse nothing is ever that simple :) And i have inactive pages to deal
158 <         * with too. So im goingto add them to free memory :)
206 >        /* Of couse nothing is ever that simple :) And I have inactive pages to
207 >         * deal with too. So I'm going to add them to free memory :)
208           */
209 <        mem_stat.free=(mem_stat.free*pagesize)+(inactive*pagesize);
210 <        
211 <        mem_stat.used=mem_stat.total-mem_stat.free;
209 >        mem_stat.free=(free_count*pagesize)+(inactive_count*pagesize);
210 >        mem_stat.used=physmem-mem_stat.free;
211 > #endif
212  
213 + #if defined(NETBSD) || defined(OPENBSD)
214 +        if ((uvm = sg_get_uvmexp()) == NULL) {
215 +                return NULL;
216 +        }
217 +
218 +        mem_stat.total = uvm->pagesize * uvm->npages;
219 + #ifdef NETBSD
220 +        mem_stat.cache = uvm->pagesize * (uvm->filepages + uvm->execpages);
221 + #else
222 +        /* Can't find cache memory on OpenBSD */
223 +        mem_stat.cache = 0;
224   #endif
225 +        mem_stat.free = uvm->pagesize * (uvm->free + uvm->inactive);
226 +        mem_stat.used = mem_stat.total - mem_stat.free;
227 + #endif
228  
229          return &mem_stat;
167
230   }

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines