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.46 by tdb, Sat Mar 6 19:04:29 2004 UTC vs.
Revision 1.55 by ats, Tue Mar 9 11:29:46 2004 UTC

# Line 77 | Line 77 | void network_stat_init(int start, int end, network_sta
77                  net_stats->interface_name=NULL;
78                  net_stats->tx=0;
79                  net_stats->rx=0;
80 +                net_stats->ipackets=0;
81 +                net_stats->opackets=0;
82 +                net_stats->ierrors=0;
83 +                net_stats->oerrors=0;
84 +                net_stats->collisions=0;
85                  net_stats++;
86          }
87   }
# Line 124 | Line 129 | network_stat_t *get_network_stats(int *entries){
129          /* Horrible big enough, but it should be easily big enough */
130          char line[8096];
131          regex_t regex;
132 <        regmatch_t line_match[4];
132 >        regmatch_t line_match[9];
133   #endif
134   #ifdef ALLBSD
135          struct ifaddrs *net, *net_ptr;
# Line 175 | Line 180 | network_stat_t *get_network_stats(int *entries){
180                          kstat_read(kc, ksp, NULL);
181  
182   #ifdef SOL7
183 < #define RLOOKUP "rbytes"
184 < #define WLOOKUP "obytes"
183 > #define LRX "rbytes"
184 > #define LTX "obytes"
185 > #define LIPACKETS "ipackets"
186 > #define LOPACKETS "opackets"
187   #define VALTYPE value.ui32
188   #else
189 < #define RLOOKUP "rbytes64"
190 < #define WLOOKUP "obytes64"
189 > #define LRX "rbytes64"
190 > #define LTX "obytes64"
191 > #define LIPACKETS "ipackets64"
192 > #define LOPACKETS "opackets64"
193   #define VALTYPE value.ui64
194   #endif
195  
196 <                        if((knp=kstat_data_lookup(ksp, RLOOKUP))==NULL){
196 >                        /* Read rx */
197 >                        if((knp=kstat_data_lookup(ksp, LRX))==NULL){
198                                  /* This is a network interface, but it doesn't
199                                   * have the rbytes/obytes values; for instance,
200                                   * the loopback devices have this behaviour
201                                   * (although they do track packets in/out). */
202 +                                /* FIXME: Show packet counts when byte counts
203 +                                 * not available. */
204                                  continue;
205                          }
206  
207 +                        /* Create new network_stats */
208                          network_stats=network_stat_malloc((interfaces+1), &sizeof_network_stats, network_stats);
209                          if(network_stats==NULL){
210                                  return NULL;
211                          }
212                          network_stat_ptr=network_stats+interfaces;
213 +
214 +                        /* Finish reading rx */
215                          network_stat_ptr->rx=knp->VALTYPE;
216  
217 <                        if((knp=kstat_data_lookup(ksp, WLOOKUP))==NULL){
217 >                        /* Read tx */
218 >                        if((knp=kstat_data_lookup(ksp, LTX))==NULL){
219                                  continue;
220                          }
221                          network_stat_ptr->tx=knp->VALTYPE;
222 +
223 +                        /* Read ipackets */
224 +                        if((knp=kstat_data_lookup(ksp, LIPACKETS))==NULL){
225 +                                continue;
226 +                        }
227 +                        network_stat_ptr->ipackets=knp->VALTYPE;
228 +
229 +                        /* Read opackets */
230 +                        if((knp=kstat_data_lookup(ksp, LOPACKETS))==NULL){
231 +                                continue;
232 +                        }
233 +                        network_stat_ptr->opackets=knp->VALTYPE;
234 +
235 +                        /* Read ierrors */
236 +                        if((knp=kstat_data_lookup(ksp, "ierrors"))==NULL){
237 +                                continue;
238 +                        }
239 +                        network_stat_ptr->ierrors=knp->value.ui32;
240 +
241 +                        /* Read oerrors */
242 +                        if((knp=kstat_data_lookup(ksp, "oerrors"))==NULL){
243 +                                continue;
244 +                        }
245 +                        network_stat_ptr->oerrors=knp->value.ui32;
246 +
247 +                        /* Read collisions */
248 +                        if((knp=kstat_data_lookup(ksp, "collisions"))==NULL){
249 +                                continue;
250 +                        }
251 +                        network_stat_ptr->collisions=knp->value.ui32;
252 +
253 +                        /* Read interface name */
254                          if(network_stat_ptr->interface_name!=NULL){
255                                  free(network_stat_ptr->interface_name);
256                          }
257                          network_stat_ptr->interface_name=strdup(ksp->ks_name);
258  
259 +                        /* Store systime */
260                          network_stat_ptr->systime=time(NULL);
261 +
262                          interfaces++;
263                  }
264          }
# Line 225 | Line 275 | network_stat_t *get_network_stats(int *entries){
275          fgets(line, sizeof(line), f);
276  
277  
278 <        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){
278 >        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){
279                  return NULL;
280          }
281  
282          interfaces=0;
283  
284          while((fgets(line, sizeof(line), f)) != NULL){
285 <                if((regexec(&regex, line, 4, line_match, 0))!=0){
285 >                if((regexec(&regex, line, 9, line_match, 0))!=0){
286                          continue;
287                  }
288                  network_stats=network_stat_malloc((interfaces+1), &sizeof_network_stats, network_stats);
# Line 247 | Line 297 | network_stat_t *get_network_stats(int *entries){
297  
298                  network_stat_ptr->interface_name=get_string_match(line, &line_match[1]);
299                  network_stat_ptr->rx=get_ll_match(line, &line_match[2]);
300 <                network_stat_ptr->tx=get_ll_match(line, &line_match[3]);
300 >                network_stat_ptr->tx=get_ll_match(line, &line_match[5]);
301 >                network_stat_ptr->ipackets=get_ll_match(line, &line_match[3]);
302 >                network_stat_ptr->opackets=get_ll_match(line, &line_match[6]);
303 >                network_stat_ptr->ierrors=get_ll_match(line, &line_match[4]);
304 >                network_stat_ptr->oerrors=get_ll_match(line, &line_match[7]);
305 >                network_stat_ptr->collisions=get_ll_match(line, &line_match[8]);
306                  network_stat_ptr->systime=time(NULL);
307  
308                  interfaces++;
# Line 268 | Line 323 | network_stat_t *get_network_stats(int *entries){
323  
324   long long transfer_diff(long long new, long long old){
325   #if defined(SOL7) || defined(LINUX) || defined(FREEBSD) || defined(DFBSD)
326 < #define MAXVAL 4294967296LL
326 > #define MAXVAL 0xffffffffLL
327   #else
328 < #define MAXVAL 18446744073709551616LL
328 > #define MAXVAL 0xffffffffffffffffLL
329   #endif
330          long long result;
331          if(new>=old){
# Line 311 | Line 366 | network_stat_t *get_network_stats_diff(int *entries) {
366                  dest->interface_name = strdup(src->interface_name);
367                  dest->rx = src->rx;
368                  dest->tx = src->tx;
369 +                dest->ipackets = src->ipackets;
370 +                dest->opackets = src->opackets;
371 +                dest->ierrors = src->ierrors;
372 +                dest->oerrors = src->oerrors;
373 +                dest->collisions = src->collisions;
374                  dest->systime = src->systime;
375          }
376  
# Line 341 | Line 401 | network_stat_t *get_network_stats_diff(int *entries) {
401                     difference. */
402                  dest->rx = transfer_diff(src->rx, dest->rx);
403                  dest->tx = transfer_diff(src->tx, dest->tx);
404 +                dest->ipackets = transfer_diff(src->ipackets, dest->ipackets);
405 +                dest->opackets = transfer_diff(src->opackets, dest->opackets);
406 +                dest->ierrors = transfer_diff(src->ierrors, dest->ierrors);
407 +                dest->oerrors = transfer_diff(src->oerrors, dest->oerrors);
408 +                dest->collisions = transfer_diff(src->collisions, dest->collisions);
409                  dest->systime = src->systime - dest->systime;
410          }
411  
# Line 482 | Line 547 | network_iface_stat_t *get_network_iface_stats(int *ent
547                          case(IFM_1000_SX):
548                          case(IFM_1000_LX):
549                          case(IFM_1000_CX):
550 < #ifdef IFM_1000_TX
551 <                        case(IFM_1000_TX): /* FreeBSD 4 and others? */
550 > #if defined(IFM_1000_TX) && !defined(OPENBSD)
551 >                        case(IFM_1000_TX): /* FreeBSD 4 and others (but NOT OpenBSD)? */
552   #endif
553   #ifdef IFM_1000_FX
554                          case(IFM_1000_FX): /* FreeBSD 4 */

Diff Legend

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