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.45 by tdb, Mon Feb 16 14:55:32 2004 UTC vs.
Revision 1.58 by tdb, Sun Apr 4 21:54:48 2004 UTC

# Line 66 | Line 66 | typedef __uint64_t u64;
66   #include <net/if.h>
67   #include <net/if_media.h>
68   #include <sys/ioctl.h>
69 + #include <unistd.h>
70   #endif
71  
72   static network_stat_t *network_stats=NULL;
# Line 77 | Line 78 | void network_stat_init(int start, int end, network_sta
78                  net_stats->interface_name=NULL;
79                  net_stats->tx=0;
80                  net_stats->rx=0;
81 +                net_stats->ipackets=0;
82 +                net_stats->opackets=0;
83 +                net_stats->ierrors=0;
84 +                net_stats->oerrors=0;
85 +                net_stats->collisions=0;
86                  net_stats++;
87          }
88   }
# Line 124 | Line 130 | network_stat_t *get_network_stats(int *entries){
130          /* Horrible big enough, but it should be easily big enough */
131          char line[8096];
132          regex_t regex;
133 <        regmatch_t line_match[4];
133 >        regmatch_t line_match[9];
134   #endif
135   #ifdef ALLBSD
136          struct ifaddrs *net, *net_ptr;
# Line 151 | Line 157 | network_stat_t *get_network_stats(int *entries){
157                  if(network_stat_ptr->interface_name==NULL) return NULL;
158                  net_data=(struct if_data *)net_ptr->ifa_data;
159                  network_stat_ptr->rx=net_data->ifi_ibytes;
160 <                network_stat_ptr->tx=net_data->ifi_obytes;                      
160 >                network_stat_ptr->tx=net_data->ifi_obytes;
161 >                network_stat_ptr->ipackets=net_data->ifi_ipackets;
162 >                network_stat_ptr->opackets=net_data->ifi_opackets;
163 >                network_stat_ptr->ierrors=net_data->ifi_ierrors;
164 >                network_stat_ptr->oerrors=net_data->ifi_oerrors;
165 >                network_stat_ptr->collisions=net_data->ifi_collisions;
166                  network_stat_ptr->systime=time(NULL);
167                  interfaces++;
168          }
# Line 170 | Line 181 | network_stat_t *get_network_stats(int *entries){
181                          kstat_read(kc, ksp, NULL);
182  
183   #ifdef SOL7
184 < #define RLOOKUP "rbytes"
185 < #define WLOOKUP "obytes"
184 > #define LRX "rbytes"
185 > #define LTX "obytes"
186 > #define LIPACKETS "ipackets"
187 > #define LOPACKETS "opackets"
188   #define VALTYPE value.ui32
189   #else
190 < #define RLOOKUP "rbytes64"
191 < #define WLOOKUP "obytes64"
190 > #define LRX "rbytes64"
191 > #define LTX "obytes64"
192 > #define LIPACKETS "ipackets64"
193 > #define LOPACKETS "opackets64"
194   #define VALTYPE value.ui64
195   #endif
196  
197 <                        if((knp=kstat_data_lookup(ksp, RLOOKUP))==NULL){
197 >                        /* Read rx */
198 >                        if((knp=kstat_data_lookup(ksp, LRX))==NULL){
199                                  /* This is a network interface, but it doesn't
200                                   * have the rbytes/obytes values; for instance,
201                                   * the loopback devices have this behaviour
202                                   * (although they do track packets in/out). */
203 +                                /* FIXME: Show packet counts when byte counts
204 +                                 * not available. */
205                                  continue;
206                          }
207  
208 +                        /* Create new network_stats */
209                          network_stats=network_stat_malloc((interfaces+1), &sizeof_network_stats, network_stats);
210                          if(network_stats==NULL){
211                                  return NULL;
212                          }
213                          network_stat_ptr=network_stats+interfaces;
214 +
215 +                        /* Finish reading rx */
216                          network_stat_ptr->rx=knp->VALTYPE;
217  
218 <                        if((knp=kstat_data_lookup(ksp, WLOOKUP))==NULL){
218 >                        /* Read tx */
219 >                        if((knp=kstat_data_lookup(ksp, LTX))==NULL){
220                                  continue;
221                          }
222                          network_stat_ptr->tx=knp->VALTYPE;
223 +
224 +                        /* Read ipackets */
225 +                        if((knp=kstat_data_lookup(ksp, LIPACKETS))==NULL){
226 +                                continue;
227 +                        }
228 +                        network_stat_ptr->ipackets=knp->VALTYPE;
229 +
230 +                        /* Read opackets */
231 +                        if((knp=kstat_data_lookup(ksp, LOPACKETS))==NULL){
232 +                                continue;
233 +                        }
234 +                        network_stat_ptr->opackets=knp->VALTYPE;
235 +
236 +                        /* Read ierrors */
237 +                        if((knp=kstat_data_lookup(ksp, "ierrors"))==NULL){
238 +                                continue;
239 +                        }
240 +                        network_stat_ptr->ierrors=knp->value.ui32;
241 +
242 +                        /* Read oerrors */
243 +                        if((knp=kstat_data_lookup(ksp, "oerrors"))==NULL){
244 +                                continue;
245 +                        }
246 +                        network_stat_ptr->oerrors=knp->value.ui32;
247 +
248 +                        /* Read collisions */
249 +                        if((knp=kstat_data_lookup(ksp, "collisions"))==NULL){
250 +                                continue;
251 +                        }
252 +                        network_stat_ptr->collisions=knp->value.ui32;
253 +
254 +                        /* Read interface name */
255                          if(network_stat_ptr->interface_name!=NULL){
256                                  free(network_stat_ptr->interface_name);
257                          }
258                          network_stat_ptr->interface_name=strdup(ksp->ks_name);
259  
260 +                        /* Store systime */
261                          network_stat_ptr->systime=time(NULL);
262 +
263                          interfaces++;
264                  }
265          }
# Line 220 | Line 276 | network_stat_t *get_network_stats(int *entries){
276          fgets(line, sizeof(line), f);
277  
278  
279 <        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){
279 >        if((regcomp(&regex, "^ *([^:]+): *([0-9]+) +([0-9]+) +([0-9]+) +[0-9]+ +[0-9]+ +[0-9]+ +[0-9]+ +[0-9]+ +([0-9]+) +([0-9]+) +([0-9]+) +[0-9]+ +[0-9]+ +([0-9]+)", REG_EXTENDED))!=0){
280                  return NULL;
281          }
282  
283          interfaces=0;
284  
285          while((fgets(line, sizeof(line), f)) != NULL){
286 <                if((regexec(&regex, line, 4, line_match, 0))!=0){
286 >                if((regexec(&regex, line, 9, line_match, 0))!=0){
287                          continue;
288                  }
289                  network_stats=network_stat_malloc((interfaces+1), &sizeof_network_stats, network_stats);
# Line 242 | Line 298 | network_stat_t *get_network_stats(int *entries){
298  
299                  network_stat_ptr->interface_name=get_string_match(line, &line_match[1]);
300                  network_stat_ptr->rx=get_ll_match(line, &line_match[2]);
301 <                network_stat_ptr->tx=get_ll_match(line, &line_match[3]);
301 >                network_stat_ptr->tx=get_ll_match(line, &line_match[5]);
302 >                network_stat_ptr->ipackets=get_ll_match(line, &line_match[3]);
303 >                network_stat_ptr->opackets=get_ll_match(line, &line_match[6]);
304 >                network_stat_ptr->ierrors=get_ll_match(line, &line_match[4]);
305 >                network_stat_ptr->oerrors=get_ll_match(line, &line_match[7]);
306 >                network_stat_ptr->collisions=get_ll_match(line, &line_match[8]);
307                  network_stat_ptr->systime=time(NULL);
308  
309                  interfaces++;
# Line 262 | Line 323 | network_stat_t *get_network_stats(int *entries){
323   }
324  
325   long long transfer_diff(long long new, long long old){
326 < #if defined(SOL7) || defined(LINUX) || defined(FREEBSD) || defined(DFBSD)
327 < #define MAXVAL 4294967296LL
326 > #if defined(SOL7) || defined(LINUX) || defined(FREEBSD) || defined(DFBSD) || defined(OPENBSD)
327 >        /* 32-bit quantities, so we must explicitly deal with wraparound. */
328 > #define MAXVAL 0x100000000LL
329 >        if (new >= old) {
330 >                return new - old;
331 >        } else {
332 >                return MAXVAL + new - old;
333 >        }
334   #else
335 < #define MAXVAL 18446744073709551616LL
335 >        /* 64-bit quantities, so plain subtraction works. */
336 >        return new - old;
337   #endif
270 –        long long result;
271 –        if(new>=old){
272 –                result = (new-old);
273 –        }else{
274 –                result = (MAXVAL+(new-old));
275 –        }
276 –
277 –        return result;
278 –
338   }
339  
340   network_stat_t *get_network_stats_diff(int *entries) {
341          static network_stat_t *diff = NULL;
342          static int diff_count = 0;
343 <        network_stat_t *src, *dest;
343 >        network_stat_t *src = NULL, *dest;
344          int i, j, new_count;
345  
346          if (network_stats == NULL) {
# Line 306 | Line 365 | network_stat_t *get_network_stats_diff(int *entries) {
365                  dest->interface_name = strdup(src->interface_name);
366                  dest->rx = src->rx;
367                  dest->tx = src->tx;
368 +                dest->ipackets = src->ipackets;
369 +                dest->opackets = src->opackets;
370 +                dest->ierrors = src->ierrors;
371 +                dest->oerrors = src->oerrors;
372 +                dest->collisions = src->collisions;
373                  dest->systime = src->systime;
374          }
375  
# Line 336 | Line 400 | network_stat_t *get_network_stats_diff(int *entries) {
400                     difference. */
401                  dest->rx = transfer_diff(src->rx, dest->rx);
402                  dest->tx = transfer_diff(src->tx, dest->tx);
403 +                dest->ipackets = transfer_diff(src->ipackets, dest->ipackets);
404 +                dest->opackets = transfer_diff(src->opackets, dest->opackets);
405 +                dest->ierrors = transfer_diff(src->ierrors, dest->ierrors);
406 +                dest->oerrors = transfer_diff(src->oerrors, dest->oerrors);
407 +                dest->collisions = transfer_diff(src->collisions, dest->collisions);
408                  dest->systime = src->systime - dest->systime;
409          }
410  
# Line 477 | Line 546 | network_iface_stat_t *get_network_iface_stats(int *ent
546                          case(IFM_1000_SX):
547                          case(IFM_1000_LX):
548                          case(IFM_1000_CX):
549 < #ifdef IFM_1000_TX
550 <                        case(IFM_1000_TX): /* FreeBSD 4 and others? */
549 > #if defined(IFM_1000_TX) && !defined(OPENBSD)
550 >                        case(IFM_1000_TX): /* FreeBSD 4 and others (but NOT OpenBSD)? */
551   #endif
552   #ifdef IFM_1000_FX
553                          case(IFM_1000_FX): /* FreeBSD 4 */

Diff Legend

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