2 * iostat 2002 Ronnie Sahlberg
4 * $Id: tap-iostat.c,v 1.8 2003/04/29 08:47:20 sahlberg Exp $
6 * Ethereal - Network traffic analyzer
7 * By Gerald Combs <gerald@ethereal.com>
8 * Copyright 1998 Gerald Combs
10 * This program is free software; you can redistribute it and/or
11 * modify it under the terms of the GNU General Public License
12 * as published by the Free Software Foundation; either version 2
13 * of the License, or (at your option) any later version.
15 * This program is distributed in the hope that it will be useful,
16 * but WITHOUT ANY WARRANTY; without even the implied warranty of
17 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
18 * GNU General Public License for more details.
20 * You should have received a copy of the GNU General Public License
21 * along with this program; if not, write to the Free Software
22 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
31 #ifdef HAVE_SYS_TYPES_H
32 # include <sys/types.h>
36 #include "epan/epan_dissect.h"
37 #include "epan/packet_info.h"
42 typedef struct _io_stat_t {
43 gint32 interval; /* unit is ms */
45 struct _io_stat_item_t *items;
49 #define CALC_TYPE_BYTES 0
50 #define CALC_TYPE_COUNT 1
51 #define CALC_TYPE_SUM 2
52 #define CALC_TYPE_MIN 3
53 #define CALC_TYPE_MAX 4
54 #define CALC_TYPE_AVG 5
56 typedef struct _io_stat_item_t {
58 struct _io_stat_item_t *next;
59 struct _io_stat_item_t *prev;
60 gint32 time; /* unit is ms since start of capture */
70 iostat_packet(io_stat_item_t *mit, packet_info *pinfo, epan_dissect_t *edt _U_, void *dummy _U_)
77 current_time=((pinfo->fd->rel_secs*1000)+(pinfo->fd->rel_usecs/1000));
79 /* the prev item before the main one is always the last interval we saw packets for */
82 /* XXX for the time being, just ignore all frames that are in the past.
83 should be fixed in the future but hopefully it is uncommon */
84 if(current_time<it->time){
88 /* we have moved into a new interval, we need to create a new struct */
89 if(current_time>=(it->time+mit->parent->interval)){
90 it->next=g_malloc(sizeof(io_stat_item_t));
96 it->time=(current_time / mit->parent->interval) * mit->parent->interval;
100 it->calc_type=it->prev->calc_type;
101 it->hf_index=it->prev->hf_index;
104 /* it will now give us the current structure to use to store the data in */
107 switch(it->calc_type){
108 case CALC_TYPE_BYTES:
109 it->counter+=pinfo->fd->pkt_len;
111 case CALC_TYPE_COUNT:
112 gp=proto_get_finfo_ptr_array(edt->tree, it->hf_index);
114 it->counter+=gp->len;
118 gp=proto_get_finfo_ptr_array(edt->tree, it->hf_index);
120 for(i=0;i<gp->len;i++){
121 it->counter+=fvalue_get_integer(((field_info *)gp->pdata[i])->value);
126 gp=proto_get_finfo_ptr_array(edt->tree, it->hf_index);
132 type=proto_registrar_get_ftype(it->hf_index);
133 for(i=0;i<gp->len;i++){
139 val=fvalue_get_integer(((field_info *)gp->pdata[i])->value);
140 if((it->frames==1)&&(i==0)){
142 } else if(val<it->counter){
150 val=fvalue_get_integer(((field_info *)gp->pdata[i])->value);
151 if((it->frames==1)&&(i==0)){
153 } else if((gint32)val<(gint32)(it->counter)){
157 case FT_RELATIVE_TIME:
158 new_time=fvalue_get(((field_info *)gp->pdata[i])->value);
159 val=new_time->secs*1000+new_time->nsecs/1000000;
160 if((it->frames==1)&&(i==0)){
162 } else if(val<it->counter){
171 gp=proto_get_finfo_ptr_array(edt->tree, it->hf_index);
177 type=proto_registrar_get_ftype(it->hf_index);
178 for(i=0;i<gp->len;i++){
184 val=fvalue_get_integer(((field_info *)gp->pdata[i])->value);
185 if((it->frames==1)&&(i==0)){
187 } else if(val>it->counter){
195 val=fvalue_get_integer(((field_info *)gp->pdata[i])->value);
196 if((it->frames==1)&&(i==0)){
198 } else if((gint32)val>(gint32)(it->counter)){
202 case FT_RELATIVE_TIME:
203 new_time=fvalue_get(((field_info *)gp->pdata[i])->value);
204 val=new_time->secs*1000+new_time->nsecs/1000000;
205 if((it->frames==1)&&(i==0)){
207 } else if(val>it->counter){
216 gp=proto_get_finfo_ptr_array(edt->tree, it->hf_index);
222 type=proto_registrar_get_ftype(it->hf_index);
223 for(i=0;i<gp->len;i++){
234 val=fvalue_get_integer(((field_info *)gp->pdata[i])->value);
237 case FT_RELATIVE_TIME:
238 new_time=fvalue_get(((field_info *)gp->pdata[i])->value);
239 val=new_time->secs*1000+new_time->nsecs/1000000;
252 iostat_draw(io_stat_item_t *mit)
255 io_stat_item_t **items;
259 guint32 i,more_items;
265 printf("===================================================================\n");
266 printf("IO Statistics\n");
267 printf("Interval: %d.%03d secs\n", iot->interval/1000, iot->interval%1000);
268 for(i=0;i<iot->num_items;i++){
269 printf("Column #%d: %s\n",i,iot->filters[i]?iot->filters[i]:"");
272 for(i=0;i<iot->num_items;i++){
273 printf("| Column #%-2d ",i);
277 for(i=0;i<iot->num_items;i++){
278 switch(iot->items[i].calc_type){
279 case CALC_TYPE_BYTES:
280 printf("|frames| bytes ");
282 case CALC_TYPE_COUNT:
301 items=g_malloc(sizeof(io_stat_item_t *)*iot->num_items);
302 frames=g_malloc(sizeof(guint32)*iot->num_items);
303 counters=g_malloc(sizeof(guint32)*iot->num_items);
304 num=g_malloc(sizeof(guint32)*iot->num_items);
305 /* preset all items at the first interval */
306 for(i=0;i<iot->num_items;i++){
307 items[i]=&iot->items[i];
310 /* loop the items until we run out of them all */
314 for(i=0;i<iot->num_items;i++){
319 for(i=0;i<iot->num_items;i++){
320 if(items[i] && (t>=(items[i]->time+iot->interval))){
321 items[i]=items[i]->next;
324 if(items[i] && (t<(items[i]->time+iot->interval)) && (t>=items[i]->time) ){
325 frames[i]=items[i]->frames;
326 counters[i]=items[i]->counter;
327 num[i]=items[i]->num;
336 printf("%03d.%03d-%03d.%03d ",
338 (t+iot->interval)/1000,(t+iot->interval)%1000);
339 for(i=0;i<iot->num_items;i++){
340 switch(iot->items[i].calc_type){
341 case CALC_TYPE_BYTES:
342 printf("%6d %9d ",frames[i],counters[i]);
344 case CALC_TYPE_COUNT:
345 printf(" %8d ", counters[i]);
348 printf(" %8d ", counters[i]);
351 switch(proto_registrar_get_ftype(iot->items[i].hf_index)){
356 printf(" %8u ", counters[i]);
362 printf(" %8d ", counters[i]);
364 case FT_RELATIVE_TIME:
365 printf(" %6d.%03d ", counters[i]/1000, counters[i]%1000);
370 switch(proto_registrar_get_ftype(iot->items[i].hf_index)){
375 printf(" %8u ", counters[i]);
381 printf(" %8d ", counters[i]);
383 case FT_RELATIVE_TIME:
384 printf(" %6d.%03d ", counters[i]/1000, counters[i]%1000);
392 switch(proto_registrar_get_ftype(iot->items[i].hf_index)){
397 printf(" %8u ", counters[i]/num[i]);
403 printf(" %8d ", counters[i]/num[i]);
405 case FT_RELATIVE_TIME:
407 printf(" %6d.%03d ", counters[i]/1000, counters[i]%1000);
420 printf("===================================================================\n");
430 get_calc_field(char *filter, char **flt)
434 header_field_info *hfi;
437 for(i=0;filter[i];i++){
439 fprintf(stderr,"get_calc_field(): Too long field name: %s\n", filter);
452 hfi=proto_registrar_get_byname(field);
454 fprintf(stderr, "get_calc_field(): No such field %s\n", field);
462 register_io_tap(io_stat_t *io, int i, char *filter)
464 GString *error_string;
467 io->items[i].prev=&io->items[i];
468 io->items[i].next=NULL;
469 io->items[i].parent=io;
471 io->items[i].calc_type=CALC_TYPE_BYTES;
472 io->items[i].frames=0;
473 io->items[i].counter=0;
475 io->filters[i]=filter;
481 if(!strncmp("COUNT(", filter, 6)){
482 io->items[i].calc_type=CALC_TYPE_COUNT;
483 io->items[i].hf_index=get_calc_field(filter+6, &flt);
484 } else if (!strncmp("SUM(", filter, 4)){
485 io->items[i].calc_type=CALC_TYPE_SUM;
486 io->items[i].hf_index=get_calc_field(filter+4, &flt);
487 switch(proto_registrar_get_nth(io->items[i].hf_index)->type){
498 fprintf(stderr, "register_io_tap(): Invalid field type. SUM(x) only supports 8,16,24 and 32 byte integer fields\n");
501 } else if (!strncmp("MIN(", filter, 4)){
502 io->items[i].calc_type=CALC_TYPE_MIN;
503 io->items[i].hf_index=get_calc_field(filter+4, &flt);
504 switch(proto_registrar_get_nth(io->items[i].hf_index)->type){
513 case FT_RELATIVE_TIME:
516 fprintf(stderr, "register_io_tap(): Invalid field type. MIN(x) only supports 8,16,24 and 32 byte integer fields and relative time fields\n");
519 } else if (!strncmp("MAX(", filter, 4)){
520 io->items[i].calc_type=CALC_TYPE_MAX;
521 io->items[i].hf_index=get_calc_field(filter+4, &flt);
522 switch(proto_registrar_get_nth(io->items[i].hf_index)->type){
531 case FT_RELATIVE_TIME:
534 fprintf(stderr, "register_io_tap(): Invalid field type. MAX(x) only supports 8,16,24 and 32 byte integer fields and relative time fields\n");
537 } else if (!strncmp("AVG(", filter, 4)){
538 io->items[i].calc_type=CALC_TYPE_AVG;
539 io->items[i].hf_index=get_calc_field(filter+4, &flt);
540 switch(proto_registrar_get_nth(io->items[i].hf_index)->type){
549 case FT_RELATIVE_TIME:
552 fprintf(stderr, "register_io_tap(): Invalid field type. AVG(x) only supports 8,16,24 and 32 byte integer fields and relative time fields\n");
564 error_string=register_tap_listener("frame", &io->items[i], flt, NULL, (void*)iostat_packet, i?NULL:(void*)iostat_draw);
568 fprintf(stderr, "tethereal: Couldn't register io,stat tap: %s\n",
570 g_string_free(error_string, TRUE);
576 iostat_init(char *optarg)
578 float interval_float;
584 if(sscanf(optarg,"io,stat,%f,%n",&interval_float,&pos)==1){
591 fprintf(stderr, "tethereal: invalid \"-z io,stat,<interval>[,<filter>]\" argument\n");
596 /* make interval be number of ms */
597 interval=(gint32)(interval_float*1000.0+0.9);
599 fprintf(stderr, "tethereal:iostat_init() interval must be >=0.001 seconds\n");
603 io=g_malloc(sizeof(io_stat_t));
604 io->interval=interval;
605 if((!filter)||(filter[0]==0)){
607 io->items=g_malloc(sizeof(io_stat_item_t)*io->num_items);
608 io->filters=g_malloc(sizeof(char *)*io->num_items);
610 register_io_tap(io, 0, NULL);
614 /* find how many ',' separated filters we have */
617 while((str=strchr(str,','))){
622 io->items=g_malloc(sizeof(io_stat_item_t)*io->num_items);
623 io->filters=g_malloc(sizeof(char *)*io->num_items);
625 /* for each filter, register a tap listener */
631 register_io_tap(io, i, NULL);
632 } else if(pos==NULL) {
633 tmp=g_malloc(strlen(str)+1);
635 register_io_tap(io, i, tmp);
637 tmp=g_malloc((pos-str)+1);
638 strncpy(tmp,str,(pos-str));
640 register_io_tap(io, i, tmp);
649 register_tap_listener_iostat(void)
651 register_ethereal_tap("io,stat,", iostat_init);