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

Comparing projects/libstatgrab/src/libstatgrab/swap_stats.c (file contents):
Revision 1.12 by tdb, Thu Feb 12 23:04:52 2004 UTC vs.
Revision 1.23 by ats, Sat Nov 6 15:41:30 2004 UTC

# Line 1 | Line 1
1   /*
2 < * i-scream central monitoring system
2 > * i-scream libstatgrab
3   * http://www.i-scream.org
4   * Copyright (C) 2000-2004 i-scream
5   *
# Line 36 | Line 36
36   #include <stdio.h>
37   #include <string.h>
38   #endif
39 < #ifdef FREEBSD
40 < #include <unistd.h>
39 > #if defined(FREEBSD) || defined(DFBSD)
40 > #ifdef FREEBSD5
41 > #include <sys/param.h>
42 > #include <sys/sysctl.h>
43 > #include <sys/user.h>
44 > #else
45   #include <sys/types.h>
46   #include <kvm.h>
47   #endif
48 < #ifdef OPENBSD
49 < #include <stdlib.h>
48 > #include <unistd.h>
49 > #endif
50 > #if defined(NETBSD) || defined(OPENBSD)
51   #include <sys/param.h>
52 < #include <sys/sysctl.h>
52 > #include <sys/time.h>
53   #include <uvm/uvm.h>
54 + #include <unistd.h>
55   #endif
56 + #ifdef HPUX
57 + #include <sys/param.h>
58 + #include <sys/pstat.h>
59 + #include <unistd.h>
60 + #define SWAP_BATCH 5
61 + #endif
62  
63 < swap_stat_t *get_swap_stats(){
63 > sg_swap_stats *sg_get_swap_stats(){
64  
65 <        static swap_stat_t swap_stat;
65 >        static sg_swap_stats swap_stat;
66  
67 + #ifdef HPUX
68 +        struct pst_swapinfo pstat_swapinfo[SWAP_BATCH];
69 +        int swapidx = 0;
70 +        int num, i;
71 + #endif
72   #ifdef SOLARIS
73          struct anoninfo ai;
74          int pagesize;
# Line 61 | Line 78 | swap_stat_t *get_swap_stats(){
78          char *line_ptr;
79          unsigned long long value;
80   #endif
81 < #ifdef FREEBSD
65 <        struct kvm_swap swapinfo;
81 > #if defined(FREEBSD) || defined(DFBSD)
82          int pagesize;
83 + #ifdef FREEBSD5
84 +        struct xswdev xsw;
85 +        int mib[16], n;
86 +        size_t mibsize, size;
87 + #else
88 +        struct kvm_swap swapinfo;
89          kvm_t *kvmd;
90   #endif
91 + #endif
92   #if defined(NETBSD) || defined(OPENBSD)
93          struct uvmexp *uvm;
94   #endif
72 – #ifdef OPENBSD
73 –        int mib[2];
74 –        size_t size;
75 – #endif
95  
96 + #ifdef HPUX
97 +        swap_stat.total = 0;
98 +        swap_stat.used = 0;
99 +        swap_stat.free = 0;
100 +
101 +        while (1) {
102 +                num = pstat_getswap(pstat_swapinfo, sizeof pstat_swapinfo[0],
103 +                                    SWAP_BATCH, swapidx);
104 +                if (num == -1) {
105 +                        sg_set_error_with_errno(SG_ERROR_PSTAT,
106 +                                                "pstat_getswap");
107 +                        return NULL;
108 +                } else if (num == 0) {
109 +                        break;
110 +                }
111 +
112 +                for (i = 0; i < num; i++) {
113 +                        struct pst_swapinfo *si = &pstat_swapinfo[i];
114 +
115 +                        if ((si->pss_flags & SW_ENABLED) != SW_ENABLED) {
116 +                                continue;
117 +                        }
118 +        
119 +                        if ((si->pss_flags & SW_BLOCK) == SW_BLOCK) {
120 +                                swap_stat.total += ((long long) si->pss_nblksavail) * 1024LL;
121 +                                swap_stat.used += ((long long) si->pss_nfpgs) * 1024LL;
122 +                                swap_stat.free = swap_stat.total - swap_stat.used;
123 +                        }
124 +                        if ((si->pss_flags & SW_FS) == SW_FS) {
125 +                                swap_stat.total += ((long long) si->pss_limit) * 1024LL;
126 +                                swap_stat.used += ((long long) si->pss_allocated) * 1024LL;
127 +                                swap_stat.free = swap_stat.total - swap_stat.used;
128 +                        }
129 +                }
130 +                swapidx = pstat_swapinfo[num - 1].pss_idx + 1;
131 +        }
132 + #endif
133   #ifdef SOLARIS
134          if((pagesize=sysconf(_SC_PAGESIZE)) == -1){
135 +                sg_set_error_with_errno(SG_ERROR_SYSCONF, "_SC_PAGESIZE");
136                  return NULL;
137          }
138          if (swapctl(SC_AINFO, &ai) == -1) {
139 +                sg_set_error_with_errno(SG_ERROR_SWAPCTL, NULL);
140                  return NULL;
141          }
142          swap_stat.total = (long long)ai.ani_max * (long long)pagesize;
# Line 87 | Line 145 | swap_stat_t *get_swap_stats(){
145   #endif
146   #if defined(LINUX) || defined(CYGWIN)
147          if ((f = fopen("/proc/meminfo", "r")) == NULL) {
148 +                sg_set_error_with_errno(SG_ERROR_OPEN, "/proc/meminfo");
149                  return NULL;
150          }
151  
152 <        while ((line_ptr = f_read_line(f, "")) != NULL) {
152 >        while ((line_ptr = sg_f_read_line(f, "")) != NULL) {
153                  if (sscanf(line_ptr, "%*s %llu kB", &value) != 1) {
154                          continue;
155                  }
# Line 106 | Line 165 | swap_stat_t *get_swap_stats(){
165          fclose(f);
166          swap_stat.used = swap_stat.total - swap_stat.free;
167   #endif
168 < #ifdef FREEBSD
169 <        if((kvmd = get_kvm()) == NULL){
168 > #if defined(FREEBSD) || defined(DFBSD)
169 >        pagesize=getpagesize();
170 >
171 > #ifdef FREEBSD5
172 >        swap_stat.total = 0;
173 >        swap_stat.used = 0;
174 >
175 >        mibsize = sizeof mib / sizeof mib[0];
176 >        if (sysctlnametomib("vm.swap_info", mib, &mibsize) < 0) {
177 >                sg_set_error_with_errno(SG_ERROR_SYSCTLNAMETOMIB,
178 >                                        "vm.swap_info");
179                  return NULL;
180          }
181 <        if ((kvm_getswapinfo(kvmd, &swapinfo, 1,0)) == -1){
182 <                return NULL;
181 >        for (n = 0; ; ++n) {
182 >                mib[mibsize] = n;
183 >                size = sizeof xsw;
184 >                if (sysctl(mib, mibsize + 1, &xsw, &size, NULL, NULL) < 0) {
185 >                        break;
186 >                }
187 >                if (xsw.xsw_version != XSWDEV_VERSION) {
188 >                        sg_set_error(SG_ERROR_XSW_VER_MISMATCH, NULL);
189 >                        return NULL;
190 >                }
191 >                swap_stat.total += (long long) xsw.xsw_nblks;
192 >                swap_stat.used += (long long) xsw.xsw_used;
193          }
194 <        pagesize=getpagesize();
195 <
118 <        swap_stat.total= (long long)swapinfo.ksw_total * (long long)pagesize;
119 <        swap_stat.used = (long long)swapinfo.ksw_used * (long long)pagesize;
120 <        swap_stat.free = swap_stat.total-swap_stat.used;
121 < #endif
122 < #ifdef NETBSD
123 <        if ((uvm = get_uvmexp()) == NULL) {
194 >        if (errno != ENOENT) {
195 >                sg_set_error_with_errno(SG_ERROR_SYSCTL, "vm.swap_info");
196                  return NULL;
197          }
198 < #endif
199 < #ifdef OPENBSD
128 <        mib[0] = CTL_VM;
129 <        mib[1] = VM_UVMEXP;
130 <
131 <        if (sysctl(mib, 2, NULL, &size, NULL, 0) < 0) {
198 > #else
199 >        if((kvmd = sg_get_kvm()) == NULL){
200                  return NULL;
201          }
202 <
203 <        uvm = malloc(size);
136 <        if (uvm == NULL) {
202 >        if ((kvm_getswapinfo(kvmd, &swapinfo, 1,0)) == -1){
203 >                sg_set_error(SG_ERROR_KVM_GETSWAPINFO, NULL);
204                  return NULL;
205          }
206  
207 <        if (sysctl(mib, 2, uvm, &size, NULL, 0) < 0) {
207 >        swap_stat.total = (long long)swapinfo.ksw_total;
208 >        swap_stat.used = (long long)swapinfo.ksw_used;
209 > #endif
210 >        swap_stat.total *= pagesize;
211 >        swap_stat.used *= pagesize;
212 >        swap_stat.free = swap_stat.total - swap_stat.used;
213 > #endif
214 > #if defined(NETBSD) || defined(OPENBSD)
215 >        if ((uvm = sg_get_uvmexp()) == NULL) {
216                  return NULL;
217          }
143 – #endif
218  
145 – #if defined(NETBSD) || defined(OPENBSD)
219          swap_stat.total = (long long)uvm->pagesize * (long long)uvm->swpages;
220          swap_stat.used = (long long)uvm->pagesize * (long long)uvm->swpginuse;
221          swap_stat.free = swap_stat.total - swap_stat.used;
149 – #endif
150 –
151 – #ifdef OPENBSD
152 –        free(uvm);
222   #endif
223  
224          return &swap_stat;

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines