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

Comparing projects/libstatgrab/src/libstatgrab/network_stats.c (file contents):
Revision 1.3 by pajs, Wed Feb 19 17:13:24 2003 UTC vs.
Revision 1.13 by pajs, Mon Mar 31 13:24:12 2003 UTC

# Line 22 | Line 22
22   #include "config.h"
23   #endif
24  
25 – #include <stdio.h>
26 – #include "statgrab.h"
25   #include <stdlib.h>
26 + #include <string.h>
27 + #include "statgrab.h"
28 + #include <time.h>
29   #ifdef SOLARIS
30   #include <kstat.h>
31   #include <sys/sysinfo.h>
31 – #include <string.h>
32   #endif
33 + #ifdef LINUX
34 + #include <stdio.h>
35 + #include <sys/types.h>
36 + #include <regex.h>
37 + #include "tools.h"
38 + #endif
39  
40   static network_stat_t *network_stats=NULL;
41   static int interfaces=0;
# Line 72 | Line 78 | network_stat_t *network_stat_malloc(int needed_entries
78  
79  
80   network_stat_t *get_network_stats(int *entries){
81 +
82 +        static int sizeof_network_stats=0;      
83 +        network_stat_t *network_stat_ptr;
84 +
85 + #ifdef SOLARIS
86          kstat_ctl_t *kc;
87          kstat_t *ksp;
88          kstat_named_t *knp;
89 + #endif
90  
91 <        static int sizeof_network_stats=0;      
92 <        
93 <        network_stat_t *network_stat_ptr;
91 > #ifdef LINUX
92 >        FILE *f;
93 >        /* Horrible big enough, but it should be easily big enough */
94 >        char line[8096];
95 >        regex_t regex;
96 >        regmatch_t line_match[4];
97 > #endif
98  
99 + #ifdef SOLARIS
100          if ((kc = kstat_open()) == NULL) {
101                  return NULL;
102          }
103  
104 <        interfaces=0;  
104 >        interfaces=0;
105  
106          for (ksp = kc->kc_chain; ksp; ksp = ksp->ks_next) {
107                  if (!strcmp(ksp->ks_class, "net")) {
108                          kstat_read(kc, ksp, NULL);
109  
110 <                        if((knp=kstat_data_lookup(ksp, "rbytes64"))==NULL){
110 > #ifdef SOL7
111 > #define RLOOKUP "rbytes"
112 > #define WLOOKUP "obytes"
113 > #define VALTYPE value.ui32
114 > #else
115 > #define RLOOKUP "rbytes64"
116 > #define WLOOKUP "obytes64"
117 > #define VALTYPE value.ui64
118 > #endif
119 >
120 >                        if((knp=kstat_data_lookup(ksp, RLOOKUP))==NULL){
121                                  /* Not a network interface, so skip to the next entry */
122                                  continue;
123                          }
# Line 100 | Line 127 | network_stat_t *get_network_stats(int *entries){
127                                  return NULL;
128                          }
129                          network_stat_ptr=network_stats+interfaces;
130 <                        network_stat_ptr->rx=knp->value.ui64;
130 >                        network_stat_ptr->rx=knp->VALTYPE;
131  
132 <                        if((knp=kstat_data_lookup(ksp, "obytes64"))==NULL){
132 >                        if((knp=kstat_data_lookup(ksp, WLOOKUP))==NULL){
133                                  /* Not a network interface, so skip to the next entry */
134                                  continue;
135                          }
136 <                        network_stat_ptr->tx=knp->value.ui64;
136 >                        network_stat_ptr->tx=knp->VALTYPE;
137                          if(network_stat_ptr->interface_name!=NULL){
138                                  free(network_stat_ptr->interface_name);
139                          }
# Line 118 | Line 145 | network_stat_t *get_network_stats(int *entries){
145          }
146                  
147          kstat_close(kc);        
148 + #endif
149 + #ifdef LINUX
150 +        f=fopen("/proc/net/dev", "r");
151 +        if(f==NULL){
152 +                return NULL;
153 +        }
154 +        /* read the 2 lines.. Its the title, so we dont care :) */
155 +        fgets(line, sizeof(line), f);
156 +        fgets(line, sizeof(line), f);
157  
158 +
159 +        if((regcomp(&regex, "^[[:space:]]*([^:]+):[[:space:]]*([[:digit:]]+)[[:space:]]+[[:digit:]]+[[:space:]]+[[:digit:]]+[[:space:]]+[[:digit:]]+[[:space:]]+[[:digit:]]+[[:space:]]+[[:digit:]]+[[:space:]]+[[:digit:]]+[[:space:]]+[[:digit:]]+[[:space:]]+([[:digit:]]+)", REG_EXTENDED))!=0){
160 +                return NULL;
161 +        }
162 +
163 +        interfaces=0;
164 +
165 +        while((fgets(line, sizeof(line), f)) != NULL){
166 +                if((regexec(&regex, line, 4, line_match, 0))!=0){
167 +                        continue;
168 +                }
169 +                network_stats=network_stat_malloc((interfaces+1), &sizeof_network_stats, network_stats);
170 +                if(network_stats==NULL){
171 +                        return NULL;
172 +                }
173 +                network_stat_ptr=network_stats+interfaces;
174 +
175 +                if(network_stat_ptr->interface_name!=NULL){
176 +                        free(network_stat_ptr->interface_name);
177 +                }
178 +
179 +                network_stat_ptr->interface_name=get_string_match(line, &line_match[1]);
180 +                network_stat_ptr->rx=get_ll_match(line, &line_match[2]);
181 +                network_stat_ptr->tx=get_ll_match(line, &line_match[3]);
182 +                network_stat_ptr->systime=time(NULL);
183 +
184 +                interfaces++;
185 +        }
186 +        fclose(f);
187 +        regfree(&regex);
188 +
189 + #endif
190          *entries=interfaces;
191  
192          return network_stats;  
193   }
194  
195 + long long transfer_diff(long long new, long long old){
196 + #ifdef SOL7
197 + #define MAXVAL 4294967296
198 + #else
199 + #define MAXVAL 18446744073709551616
200 + #endif
201 +        long long result;
202 +        if(new>=old){
203 +                result = (new-old);
204 +        }else{
205 +                result = (MAXVAL+(new-old));
206 +        }
207 +
208 +        return result;
209 +
210 + }
211 +
212   network_stat_t *get_network_stats_diff(int *entries){
213          static network_stat_t *network_stats_diff=NULL;
214          static int sizeof_net_stats_diff=0;
# Line 162 | Line 247 | network_stat_t *get_network_stats_diff(int *entries){
247          for(x=0;x<sizeof_net_stats_diff;x++){
248  
249                  if((strcmp(network_stats_diff_ptr->interface_name, network_stats_ptr->interface_name))==0){
250 <                        network_stats_diff_ptr->tx = network_stats_ptr->tx - network_stats_diff_ptr->tx;
251 <                        network_stats_diff_ptr->rx = network_stats_ptr->rx - network_stats_diff_ptr->rx;        
250 >                        network_stats_diff_ptr->tx = transfer_diff(network_stats_ptr->tx, network_stats_diff_ptr->tx);
251 >                        network_stats_diff_ptr->rx = transfer_diff(network_stats_ptr->rx, network_stats_diff_ptr->rx);
252                          network_stats_diff_ptr->systime = network_stats_ptr->systime - network_stats_diff_ptr->systime;
253                  }else{
254                          
255                          network_stats_ptr=network_stats;
256                          for(y=0;y<ifaces;y++){
257                                  if((strcmp(network_stats_diff_ptr->interface_name, network_stats_ptr->interface_name))==0){
258 <                                        network_stats_diff_ptr->tx = network_stats_ptr->tx - network_stats_diff_ptr->tx;
259 <                                        network_stats_diff_ptr->rx = network_stats_ptr->rx - network_stats_diff_ptr->rx;        
258 >                                        network_stats_diff_ptr->tx = transfer_diff(network_stats_ptr->tx, network_stats_diff_ptr->tx);
259 >                                        network_stats_diff_ptr->rx = transfer_diff(network_stats_ptr->rx, network_stats_diff_ptr->rx);  
260                                          network_stats_diff_ptr->systime = network_stats_ptr->systime - network_stats_diff_ptr->systime;
261                                          break;
262                                  }
# Line 184 | Line 269 | network_stat_t *get_network_stats_diff(int *entries){
269                  network_stats_diff_ptr++;
270          }
271  
272 +        *entries=sizeof_net_stats_diff;
273          return network_stats_diff;
274   }      
189 –
190 –
275  

Diff Legend

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