?  search:
summary | log | graphiclog1 | graphiclog2 | commit | commitdiff | tree | refs | edit | fork
blame | history | raw | HEAD
Make a branch to make krunner Good Enough For Aaron™.
[kdebase/uwolfer.git] / workspace / ksysguard / ksysguardd / Tru64 / NetDev.c
blob0699b929aa0d4f2d1b236ea15b8c581a554d0338
1 /*
2 KSysGuard, the KDE System Guard
3
4 Copyright (c) 1999, 2000 Chris Schlaeger <cs@kde.org>
5
6 Solaris support by Torsten Kasch <tk@Genetik.Uni-Bielefeld.DE>
7
8 This program is free software; you can redistribute it and/or
9 modify it under the terms of version 2 of the GNU General Public
10 License as published by the Free Software Foundation.
11
12 This program is distributed in the hope that it will be useful,
13 but WITHOUT ANY WARRANTY; without even the implied warranty of
14 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
15 GNU General Public License for more details.
16
17 You should have received a copy of the GNU General Public License
18 along with this program; if not, write to the Free Software
19 Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
20
21 */
22
23 #include <stdio.h>
24 #include <stdlib.h>
25 #include <unistd.h>
26 #include <string.h>
27 #include <errno.h>
28 #include <stropts.h>
29 #include <ctype.h>
30 #include <sys/types.h>
31 #include <sys/socket.h>
32 #include <net/if.h>
33
34 #include "config.h"
35
36 #ifdef HAVE_KSTAT
37 #include <kstat.h>
38 #endif
39
40 #include "ksysguardd.h"
41 #include "Command.h"
42 #include "NetDev.h"
43
44 /*
45 * available network interface statistics through kstat(3):
46 *
47 * kstat name value
48 * ----------------------------------------------------------------------
49 * for the loopback interface(s) we can get
50 * ipackets # packets received
51 * opackets # packets sent
52 * in addition to those, for "real" interfaces:
53 * oerrors # xmit errors
54 * ierrors # recv errors
55 * macxmt_errors # xmit errors reported by hardware?
56 * macrcv_errors # recv errors reported by hardware?
57 * opackets64 same as opackets (64bit)
58 * ipackets64 same as ipackets (64bit)
59 * obytes # bytes sent
60 * rbytes # bytes received
61 * obytes64 same as obytes (64bit)
62 * rbytes64 same as ibytes (64bit)
63 * collisions # collisions
64 * multixmt # multicasts sent?
65 * multircv # multicasts received?
66 * brdcstxmt # broadcasts transmitted
67 * brdcstrcv # broadcasts received
68 * unknowns
69 * blocked
70 * ex_collisions
71 * defer_xmts
72 * align_errors
73 * fcs_errors
74 * oflo # overflow errors
75 * uflo # underflow errors
76 * runt_errors
77 * missed
78 * tx_late_collisions
79 * carrier_errors
80 * noxmtbuf
81 * norcvbuf
82 * xmt_badinterp
83 * rcv_badinterp
84 * intr # interrupts?
85 * xmtretry # xmit retries?
86 * ifspeed interface speed: 10000000 for 10BaseT
87 * duplex "half" or "full"
88 * media e.g. "PHY/MII"
89 * promisc promiscuous mode (e.g. "off")
90 * first_collisions
91 * multi_collisions
92 * sqe_errors
93 * toolong_errors
94 */
95
96 typedef struct {
97 char *Name;
98 short flags;
99 unsigned long ipackets;
100 unsigned long OLDipackets;
101 unsigned long opackets;
102 unsigned long OLDopackets;
103 unsigned long ierrors;
104 unsigned long OLDierrors;
105 unsigned long oerrors;
106 unsigned long OLDoerrors;
107 unsigned long collisions;
108 unsigned long OLDcollisions;
109 unsigned long multixmt;
110 unsigned long OLDmultixmt;
111 unsigned long multircv;
112 unsigned long OLDmultircv;
113 unsigned long brdcstxmt;
114 unsigned long OLDbrdcstxmt;
115 unsigned long brdcstrcv;
116 unsigned long OLDbrdcstrcv;
117 } NetDevInfo;
118
119
120 #define NBUFFERS 64
121 #define MAXNETDEVS 64
122 static NetDevInfo IfInfo[MAXNETDEVS];
123
124 static int NetDevCount;
125
126 /*
127 * insertnetdev() -- insert device name & flags into our list
128 */
129 int insertnetdev( const char *name, const short flags ) {
130
131 int i = 0;
132
133 /*
134 * interface "aliases" don't seem to have
135 * separate kstat statistics, so we skip them
136 */
137 if( strchr( name, (int) ':' ) != NULL )
138 return( 0 );
139
140 while( (i < NetDevCount) && (strcmp( IfInfo[i].Name, name ) != 0) ) {
141 if( strcmp( IfInfo[i].Name, name ) == 0 )
142 return( 0 );
143 i++;
144 }
145
146 /*
147 * init new slot
148 */
149 IfInfo[i].Name = strdup( name );
150 IfInfo[i].flags = flags;
151 IfInfo[i].ipackets = 0L;
152 IfInfo[i].OLDipackets = 0L;
153 IfInfo[i].opackets = 0L;
154 IfInfo[i].OLDopackets = 0L;
155 IfInfo[i].ierrors = 0L;
156 IfInfo[i].OLDierrors = 0L;
157 IfInfo[i].oerrors = 0L;
158 IfInfo[i].OLDoerrors = 0L;
159 IfInfo[i].collisions = 0L;
160 IfInfo[i].OLDcollisions = 0L;
161 IfInfo[i].multixmt = 0L;
162 IfInfo[i].OLDmultixmt = 0L;
163 IfInfo[i].multircv = 0L;
164 IfInfo[i].OLDmultircv = 0L;
165 IfInfo[i].brdcstxmt = 0L;
166 IfInfo[i].OLDbrdcstxmt = 0L;
167 IfInfo[i].brdcstrcv = 0L;
168 IfInfo[i].OLDbrdcstrcv = 0L;
169 NetDevCount = ++i;
170
171 /* XXX: need sanity checks! */
172 return( 0 );
173 }
174
175 /*
176 * getnetdevlist() -- get a list of all "up" interfaces
177 */
178 int getnetdevlist( void ) {
179
180 int fd;
181 int buffsize;
182 int prevsize;
183 int prevCount;
184 struct ifconf ifc;
185 struct ifreq *ifr;
186
187 if( (fd = socket( PF_INET, SOCK_DGRAM, 0 )) < 0 ) {
188 return( -1 );
189 }
190
191 /*
192 * get the interface list via iotl( SIOCGIFCONF )
193 * the following algorithm based on ideas from W.R. Stevens'
194 * "UNIX Network Programming", Vol. 1:
195 * Since the ioctl may return 0, indicating success, even if the
196 * ifreq buffer was too small, we have to make sure, it didn't
197 * get truncated by comparing our initial size guess with the
198 * actual returned size.
199 */
200 prevsize = 0;
201 buffsize = NBUFFERS * sizeof( struct ifreq );
202 while( 1 ) {
203 if( (ifc.ifc_buf = malloc( buffsize )) == NULL )
204 return( -1 );
205
206 ifc.ifc_len = buffsize;
207 if( ioctl( fd, SIOCGIFCONF, &ifc ) < 0 ) {
208 if( errno != EINVAL || prevsize != 0 ) {
209 free( ifc.ifc_buf );
210 return( -1 );
211 }
212 } else {
213 if( ifc.ifc_len == prevsize )
214 /* success */
215 break;
216 prevsize = ifc.ifc_len;
217 }
218 /*
219 * initial buffer guessed too small, allocate a bigger one
220 */
221 free( ifc.ifc_buf );
222 buffsize = (NBUFFERS + 10) * sizeof( struct ifreq );
223 }
224
225 /*
226 * get the names for all interfaces which are configured "up"
227 * we're not interested in the ifc data (address), so we reuse the
228 * same structure (with ifc.len set) for the next ioctl()
229 */
230 prevCount = NetDevCount;
231 for( ifr = (struct ifreq *) ifc.ifc_buf;
232 ifr < (struct ifreq *) (ifc.ifc_buf + ifc.ifc_len);
233 ifr++ ) {
234 if( ioctl( fd, SIOCGIFFLAGS, ifr ) < 0 ) {
235 free( ifc.ifc_buf );
236 return( -1 );
237 }
238 if( ifr->ifr_flags & IFF_UP )
239 insertnetdev( ifr->ifr_name, ifr->ifr_flags );
240 }
241 free( ifc.ifc_buf );
242 close( fd );
243
244 if( (prevCount > 0) && (prevCount != NetDevCount) ) {
245 print_error( "RECONFIGURE\n" );
246 prevCount = NetDevCount;
247 }
248
249 return( NetDevCount );
250 }
251
252 void initNetDev( struct SensorModul* sm ) {
253 #ifdef HAVE_KSTAT
254 char mon[128];
255 int i;
256
257 getnetdevlist();
258 for( i = 0; i < NetDevCount; i++ ) {
259 sprintf( mon, "network/%s/ipackets", IfInfo[i].Name );
260 registerMonitor( mon, "integer",
261 printIPackets, printIPacketsInfo, sm );
262 sprintf( mon, "network/%s/opackets", IfInfo[i].Name );
263 registerMonitor( mon, "integer",
264 printOPackets, printOPacketsInfo, sm );
265 /*
266 * if this isn't a loopback interface,
267 * register additional monitors
268 */
269 if( ! (IfInfo[i].flags & IFF_LOOPBACK) ) {
270 /*
271 * recv errors
272 */
273 sprintf( mon, "network/%s/ierrors",
274 IfInfo[i].Name );
275 registerMonitor( mon, "integer",
276 printIErrors, printIErrorsInfo, sm );
277 /*
278 * xmit errors
279 */
280 sprintf( mon, "network/%s/oerrors",
281 IfInfo[i].Name );
282 registerMonitor( mon, "integer",
283 printOErrors, printOErrorsInfo, sm );
284 /*
285 * collisions
286 */
287 sprintf( mon, "network/%s/collisions",
288 IfInfo[i].Name );
289 registerMonitor( mon, "integer",
290 printCollisions, printCollisionsInfo, sm );
291 /*
292 * multicast xmits
293 */
294 sprintf( mon, "network/%s/multixmt",
295 IfInfo[i].Name );
296 registerMonitor( mon, "integer",
297 printMultiXmits, printMultiXmitsInfo, sm );
298 /*
299 * multicast recvs
300 */
301 sprintf( mon, "network/%s/multircv",
302 IfInfo[i].Name );
303 registerMonitor( mon, "integer",
304 printMultiRecvs, printMultiRecvsInfo, sm );
305 /*
306 * broadcast xmits
307 */
308 sprintf( mon, "network/%s/brdcstxmt",
309 IfInfo[i].Name );
310 registerMonitor( mon, "integer",
311 printBcastXmits, printBcastXmitsInfo, sm );
312 /*
313 * broadcast recvs
314 */
315 sprintf( mon, "network/%s/brdcstrcv",
316 IfInfo[i].Name );
317 registerMonitor( mon, "integer",
318 printBcastRecvs, printBcastRecvsInfo, sm );
319 }
320 }
321 #endif
322 }
323
324 void exitNetDev( void ) {
325 }
326
327 int updateNetDev( void ) {
328
329 #ifdef HAVE_KSTAT
330 kstat_ctl_t *kctl;
331 kstat_t *ksp;
332 kstat_named_t *kdata;
333 int i;
334
335 /*
336 * get a kstat handle and update the user's kstat chain
337 */
338 if( (kctl = kstat_open()) == NULL )
339 return( 0 );
340 while( kstat_chain_update( kctl ) != 0 )
341 ;
342
343 for( i = 0; i < NetDevCount; i++ ) {
344 char *name;
345 char *ptr;
346
347 /*
348 * chop off the trailing interface no
349 */
350 name = strdup( IfInfo[i].Name );
351 ptr = name + strlen( name ) - 1;
352 while( (ptr > name) && isdigit( (int) *ptr ) ) {
353 *ptr = '\0';
354 ptr--;
355 }
356
357 /*
358 * traverse the kstat chain
359 * to find the appropriate statistics
360 */
361 if( (ksp = kstat_lookup( kctl,
362 name, 0, IfInfo[i].Name )) == NULL ) {
363 free( name );
364 return( 0 );
365 }
366 if( kstat_read( kctl, ksp, NULL ) == -1 ) {
367 free( name );
368 return( 0 );
369 }
370 free( name );
371
372 /*
373 * lookup & store the data
374 */
375 kdata = (kstat_named_t *) kstat_data_lookup( ksp, "ipackets" );
376 if( kdata != NULL ) {
377 IfInfo[i].OLDipackets = IfInfo[i].ipackets;
378 IfInfo[i].ipackets = kdata->value.ul;
379 }
380 kdata = (kstat_named_t *) kstat_data_lookup( ksp, "opackets" );
381 if( kdata != NULL ) {
382 IfInfo[i].OLDopackets = IfInfo[i].opackets;
383 IfInfo[i].opackets = kdata->value.ul;
384 }
385 kdata = (kstat_named_t *) kstat_data_lookup( ksp, "ierrors" );
386 if( kdata != NULL ) {
387 IfInfo[i].OLDierrors = IfInfo[i].ierrors;
388 IfInfo[i].ierrors = kdata->value.ul;
389 }
390 kdata = (kstat_named_t *) kstat_data_lookup( ksp, "oerrors" );
391 if( kdata != NULL ) {
392 IfInfo[i].OLDoerrors = IfInfo[i].oerrors;
393 IfInfo[i].oerrors = kdata->value.ul;
394 }
395 kdata = (kstat_named_t *) kstat_data_lookup( ksp, "collisions" );
396 if( kdata != NULL ) {
397 IfInfo[i].OLDcollisions = IfInfo[i].collisions;
398 IfInfo[i].collisions = kdata->value.ul;
399 }
400 kdata = (kstat_named_t *) kstat_data_lookup( ksp, "multixmt" );
401 if( kdata != NULL ) {
402 IfInfo[i].OLDmultixmt = IfInfo[i].multixmt;
403 IfInfo[i].multixmt = kdata->value.ul;
404 }
405 kdata = (kstat_named_t *) kstat_data_lookup( ksp, "multircv" );
406 if( kdata != NULL ) {
407 IfInfo[i].OLDmultircv = IfInfo[i].multircv;
408 IfInfo[i].multircv = kdata->value.ul;
409 }
410 kdata = (kstat_named_t *) kstat_data_lookup( ksp, "brdcstxmt" );
411 if( kdata != NULL ) {
412 IfInfo[i].OLDbrdcstxmt = IfInfo[i].brdcstxmt;
413 IfInfo[i].brdcstxmt = kdata->value.ul;
414 }
415 kdata = (kstat_named_t *) kstat_data_lookup( ksp, "brdcstrcv" );
416 if( kdata != NULL ) {
417 IfInfo[i].OLDbrdcstrcv = IfInfo[i].brdcstrcv;
418 IfInfo[i].brdcstrcv = kdata->value.ul;
419 }
420 }
421
422 kstat_close( kctl );
423 #endif /* ! HAVE_KSTAT */
424
425 return( 0 );
426 }
427
428 void printIPacketsInfo( const char *cmd ) {
429 fprintf(CurrentClient, "Received Packets\t0\t0\tPackets\n" );
430 }
431
432 void printIPackets( const char *cmd ) {
433
434 char *cmdcopy = strdup( cmd );
435 char *name, *ptr;
436 int i;
437
438 ptr = strchr( cmdcopy, (int) '/' );
439 name = ++ptr;
440 ptr = strchr( name, (int) '/' );
441 *ptr = '\0';
442
443 for( i = 0; i < NetDevCount; i++ ) {
444 if( (IfInfo[i].OLDipackets > 0)
445 && (strcmp( IfInfo[i].Name, name ) == 0) ) {
446 fprintf(CurrentClient, "%ld\n",
447 IfInfo[i].ipackets - IfInfo[i].OLDipackets);
448 free( cmdcopy );
449 return;
450 }
451 }
452 free( cmdcopy );
453 fprintf(CurrentClient, "0\n" );
454 }
455
456 void printOPacketsInfo( const char *cmd ) {
457 fprintf(CurrentClient, "Transmitted Packets\t0\t0\tPackets\n" );
458 }
459
460 void printOPackets( const char *cmd ) {
461
462 char *cmdcopy = strdup( cmd );
463 char *name, *ptr;
464 int i;
465
466 ptr = strchr( cmdcopy, (int) '/' );
467 name = ++ptr;
468 ptr = strchr( name, (int) '/' );
469 *ptr = '\0';
470
471 for( i = 0; i < NetDevCount; i++ ) {
472 if( (IfInfo[i].OLDopackets > 0)
473 && (strcmp( IfInfo[i].Name, name ) == 0) ) {
474 fprintf(CurrentClient, "%ld\n",
475 IfInfo[i].opackets - IfInfo[i].OLDopackets );
476 free( cmdcopy );
477 return;
478 }
479 }
480 free( cmdcopy );
481 fprintf(CurrentClient, "0\n" );
482 }
483
484 void printIErrorsInfo( const char *cmd ) {
485 fprintf(CurrentClient, "Input Errors\t0\t0\tPackets\n" );
486 }
487
488 void printIErrors( const char *cmd ) {
489
490 char *cmdcopy = strdup( cmd );
491 char *name, *ptr;
492 int i;
493
494 ptr = strchr( cmdcopy, (int) '/' );
495 name = ++ptr;
496 ptr = strchr( name, (int) '/' );
497 *ptr = '\0';
498
499 for( i = 0; i < NetDevCount; i++ ) {
500 if( (IfInfo[i].OLDierrors > 0)
501 && (strcmp( IfInfo[i].Name, name ) == 0) ) {
502 fprintf(CurrentClient, "%ld\n",
503 IfInfo[i].ierrors - IfInfo[i].OLDierrors );
504 free( cmdcopy );
505 return;
506 }
507 }
508 free( cmdcopy );
509 fprintf(CurrentClient, "0\n" );
510 }
511
512 void printOErrorsInfo( const char *cmd ) {
513 fprintf(CurrentClient, "Output Errors\t0\t0\tPackets\n" );
514 }
515
516 void printOErrors( const char *cmd ) {
517
518 char *cmdcopy = strdup( cmd );
519 char *name, *ptr;
520 int i;
521
522 ptr = strchr( cmdcopy, (int) '/' );
523 name = ++ptr;
524 ptr = strchr( name, (int) '/' );
525 *ptr = '\0';
526
527 for( i = 0; i < NetDevCount; i++ ) {
528 if( (IfInfo[i].OLDoerrors > 0)
529 && (strcmp( IfInfo[i].Name, name ) == 0) ) {
530 fprintf(CurrentClient, "%ld\n",
531 IfInfo[i].oerrors - IfInfo[i].OLDoerrors );
532 free( cmdcopy );
533 return;
534 }
535 }
536 free( cmdcopy );
537 fprintf(CurrentClient, "0\n" );
538 }
539
540 void printCollisionsInfo( const char *cmd ) {
541 fprintf(CurrentClient, "Collisions\t0\t0\tPackets\n" );
542 }
543
544 void printCollisions( const char *cmd ) {
545
546 char *cmdcopy = strdup( cmd );
547 char *name, *ptr;
548 int i;
549
550 ptr = strchr( cmdcopy, (int) '/' );
551 name = ++ptr;
552 ptr = strchr( name, (int) '/' );
553 *ptr = '\0';
554
555 for( i = 0; i < NetDevCount; i++ ) {
556 if( (IfInfo[i].OLDcollisions > 0)
557 && (strcmp( IfInfo[i].Name, name ) == 0) ) {
558 fprintf(CurrentClient, "%ld\n",
559 IfInfo[i].collisions - IfInfo[i].OLDcollisions );
560 free( cmdcopy );
561 return;
562 }
563 }
564 free( cmdcopy );
565 fprintf(CurrentClient, "0\n" );
566 }
567
568 void printMultiXmitsInfo( const char *cmd ) {
569 fprintf(CurrentClient, "Multicasts Sent\t0\t0\tPackets\n" );
570 }
571
572 void printMultiXmits( const char *cmd ) {
573
574 char *cmdcopy = strdup( cmd );
575 char *name, *ptr;
576 int i;
577
578 ptr = strchr( cmdcopy, (int) '/' );
579 name = ++ptr;
580 ptr = strchr( name, (int) '/' );
581 *ptr = '\0';
582
583 for( i = 0; i < NetDevCount; i++ ) {
584 if( (IfInfo[i].OLDmultixmt > 0)
585 && (strcmp( IfInfo[i].Name, name ) == 0) ) {
586 fprintf(CurrentClient, "%ld\n",
587 IfInfo[i].multixmt - IfInfo[i].OLDmultixmt );
588 free( cmdcopy );
589 return;
590 }
591 }
592 free( cmdcopy );
593 fprintf(CurrentClient, "0\n" );
594 }
595
596 void printMultiRecvsInfo( const char *cmd ) {
597 fprintf(CurrentClient, "Multicasts Received\t0\t0\tPackets\n" );
598 }
599
600 void printMultiRecvs( const char *cmd ) {
601
602 char *cmdcopy = strdup( cmd );
603 char *name, *ptr;
604 int i;
605
606 ptr = strchr( cmdcopy, (int) '/' );
607 name = ++ptr;
608 ptr = strchr( name, (int) '/' );
609 *ptr = '\0';
610
611 for( i = 0; i < NetDevCount; i++ ) {
612 if( (IfInfo[i].OLDmultircv > 0)
613 && (strcmp( IfInfo[i].Name, name ) == 0) ) {
614 fprintf(CurrentClient, "%ld\n",
615 IfInfo[i].multircv - IfInfo[i].OLDmultircv );
616 free( cmdcopy );
617 return;
618 }
619 }
620 free( cmdcopy );
621 fprintf(CurrentClient, "0\n" );
622 }
623
624 void printBcastXmitsInfo( const char *cmd ) {
625 fprintf(CurrentClient, "Broadcasts Sent\t0\t0\tPackets\n" );
626 }
627
628 void printBcastXmits( const char *cmd ) {
629
630 char *cmdcopy = strdup( cmd );
631 char *name, *ptr;
632 int i;
633
634 ptr = strchr( cmdcopy, (int) '/' );
635 name = ++ptr;
636 ptr = strchr( name, (int) '/' );
637 *ptr = '\0';
638
639 for( i = 0; i < NetDevCount; i++ ) {
640 if( (IfInfo[i].OLDbrdcstxmt > 0)
641 && (strcmp( IfInfo[i].Name, name ) == 0) ) {
642 fprintf(CurrentClient, "%ld\n",
643 IfInfo[i].brdcstxmt - IfInfo[i].OLDbrdcstxmt );
644 free( cmdcopy );
645 return;
646 }
647 }
648 free( cmdcopy );
649 fprintf(CurrentClient, "0\n" );
650 }
651
652 void printBcastRecvsInfo( const char *cmd ) {
653 fprintf(CurrentClient, "Broadcasts Received\t0\t0\tPackets\n" );
654 }
655
656 void printBcastRecvs( const char *cmd ) {
657
658 char *cmdcopy = strdup( cmd );
659 char *name, *ptr;
660 int i;
661
662 ptr = strchr( cmdcopy, (int) '/' );
663 name = ++ptr;
664 ptr = strchr( name, (int) '/' );
665 *ptr = '\0';
666
667 for( i = 0; i < NetDevCount; i++ ) {
668 if( (IfInfo[i].OLDbrdcstrcv > 0)
669 && (strcmp( IfInfo[i].Name, name ) == 0) ) {
670 fprintf(CurrentClient, "%ld\n",
671 IfInfo[i].brdcstrcv - IfInfo[i].OLDbrdcstrcv );
672 free( cmdcopy );
673 return;
674 }
675 }
676 free( cmdcopy );
677 fprintf(CurrentClient, "0\n" );
678 }
working branch for uwolfer