/* * Copyright (c) 1994, 1995, 1996, 1997 * Ohio University. All rights reserved. * * Redistribution and use in source and binary forms, with or without * modification, are permitted provided that: (1) source code * distributions retain the above copyright notice and this paragraph * in its entirety, (2) distributions including binary code include * the above copyright notice and this paragraph in its entirety in * the documentation or other materials provided with the * distribution, and (3) all advertising materials mentioning features * or use of this software display the following acknowledgment: * ``This product includes software developed by the Ohio University * Internetworking Research Laboratory.'' Neither the name of the * University nor the names of its contributors may be used to endorse * or promote products derived from this software without specific * prior written permission. * THIS SOFTWARE IS PROVIDED ``AS IS'' AND WITHOUT ANY EXPRESS OR * IMPLIED WARRANTIES, INCLUDING, WITHOUT LIMITATION, THE IMPLIED * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE. * * Author: Shawn Ostermann * School of Electrical Engineering and Computer Science * Ohio University * Athens, OH * ostermann@cs.ohiou.edu */ static char const copyright[] = "@(#)Copyright (c) 1996 -- Ohio University. All rights reserved.\n"; static char const rcsid[] = "@(#)$Header: /home/sdo/src/tcptrace/RCS/output.c,v 3.17 1997/12/11 21:23:29 sdo Exp $"; #include "tcptrace.h" #include "gcache.h" /* local routines */ static u_int SynCount(tcp_pair *); static u_int FinCount(tcp_pair *); static double Average(double, int); static double Stdev(double, double, int); static void StatLineI(char *, char *, char *, u_long, u_long); static void StatLineF(char *, char *, char *, double, double); static void StatLineField(char *, char *, char *, u_long, int); static void StatLineFieldF(char *, char *, char *, double, int); static void StatLineOne(char *, char *, char *); static char *FormatBrief(tcp_pair *ptp); static u_int SynCount( tcp_pair *ptp) { tcb *pab = &ptp->a2b; tcb *pba = &ptp->b2a; return(((pab->syn_count >= 1)?1:0) + ((pba->syn_count >= 1)?1:0)); } static u_int FinCount( tcp_pair *ptp) { tcb *pab = &ptp->a2b; tcb *pba = &ptp->b2a; return(((pab->fin_count >= 1)?1:0) + ((pba->fin_count >= 1)?1:0)); } int ConnComplete( tcp_pair *ptp) { return(SynCount(ptp) >= 2 && FinCount(ptp) >= 2); } int ConnReset( tcp_pair *ptp) { return(ptp->a2b.reset_count + ptp->b2a.reset_count != 0); } static double Average( double sum, int count) { return((double) sum / ((double)count+.0001)); } static double Stdev( double sum, double sum2, int n) { double term; double term1; double term2; double retval; if (n<=2) return(0.0); term1 = sum2; term2 = (sum * sum) / (double)n; term = term1-term2; term /= (double)(n-1); retval = sqrt(term); /* printf("Stdev(%f,%f,%d) is %f\n", sum,sum2,n,retval); */ return(retval); } static char * FormatBrief( tcp_pair *ptp) { tcb *pab = &ptp->a2b; tcb *pba = &ptp->b2a; static char infobuf[100]; sprintf(infobuf,"%s - %s (%s2%s)", ptp->a_endpoint, ptp->b_endpoint, pab->host_letter, pba->host_letter); return(infobuf); } void PrintBrief( tcp_pair *ptp) { tcb *pab = &ptp->a2b; tcb *pba = &ptp->b2a; static int max_width = -1; /* determine the maximum connection name width to make it nice */ if (max_width == -1) { int ix; int len; tcp_pair *tmp_ptp; for (ix = 0; ix <= num_tcp_pairs; ++ix) { tmp_ptp = ttp[ix]; len = strlen(FormatBrief(tmp_ptp)); if (len > max_width) max_width = len; } if (debug > 2) fprintf(stderr,"Max name width: %d\n", max_width); } if (TRUE) { /* new version */ fprintf(stdout,"%*s", -max_width, FormatBrief(ptp)); fprintf(stdout," %4lu>", pab->packets); fprintf(stdout," %4lu<", pba->packets); } else { /* old version */ fprintf(stdout,"%s <==> %s", ptp->a_endpoint, ptp->b_endpoint); fprintf(stdout," %s2%s:%lu", pab->host_letter, pba->host_letter, pab->packets); fprintf(stdout," %s2%s:%lu", pba->host_letter, pab->host_letter, pba->packets); } if (ConnComplete(ptp)) fprintf(stdout," (complete)"); if (ConnReset(ptp)) fprintf(stdout," (reset)"); fprintf(stdout,"\n"); } void PrintTrace( tcp_pair *ptp) { double etime; u_long etime_secs; u_long etime_usecs; double etime_data1; double etime_data2; tcb *pab = &ptp->a2b; tcb *pba = &ptp->b2a; char *host1 = pab->host_letter; char *host2 = pba->host_letter; char bufl[40],bufr[40]; fprintf(stdout,"\thost %-4s %s\n", (sprintf(bufl,"%s:", host1),bufl), ptp->a_endpoint); fprintf(stdout,"\thost %-4s %s\n", (sprintf(bufl,"%s:", host2),bufl), ptp->b_endpoint); fprintf(stdout,"\tcomplete conn: %s", ConnReset(ptp)?"RESET":( ConnComplete(ptp)?"yes":"no")); if (ConnComplete(ptp)) fprintf(stdout,"\n"); else fprintf(stdout,"\t(SYNs: %u) (FINs: %u)\n", SynCount(ptp), FinCount(ptp)); fprintf(stdout,"\tfirst packet: %s\n", ts2ascii(&ptp->first_time)); fprintf(stdout,"\tlast packet: %s\n", ts2ascii(&ptp->last_time)); etime = elapsed(ptp->first_time,ptp->last_time); etime_secs = etime / 1000000.0; etime_usecs = 1000000 * (etime/1000000.0 - (double)etime_secs); fprintf(stdout,"\telapsed time: %lu:%02lu:%02lu.%06lu\n", etime_secs / (60 * 60), etime_secs % (60 * 60) / 60, (etime_secs % (60 * 60)) % 60, etime_usecs); fprintf(stdout,"\ttotal packets: %lu\n", ptp->packets); fprintf(stdout," %s->%s: %s->%s:\n", host1,host2,host2,host1); StatLineI("total packets","","%8lu", pab->packets, pba->packets); if (pab->reset_count || pba->reset_count) StatLineI("resets sent","","%8lu", pab->reset_count, pba->reset_count); StatLineI("ack pkts sent","","%8lu", pab->ack_pkts, pba->ack_pkts); StatLineI("unique bytes sent","","%8lu", pab->data_bytes-pab->rexmit_bytes, pba->data_bytes-pba->rexmit_bytes); #ifdef OLD StatLineI("unique packets","","%8lu", pab->data_pkts-pab->rexmit_pkts, pba->data_pkts-pba->rexmit_pkts); #endif /* OLD */ StatLineI("actual data pkts","","%8lu", pab->data_pkts, pba->data_pkts); StatLineI("actual data bytes","","%8lu", pab->data_bytes, pba->data_bytes); StatLineI("rexmt data pkts","","%8lu", pab->rexmit_pkts, pba->rexmit_pkts); StatLineI("rexmt data bytes","","%8lu", pab->rexmit_bytes, pba->rexmit_bytes); StatLineI("outoforder pkts","","%8lu", pab->out_order_pkts, pba->out_order_pkts); StatLineI("SYN/FIN pkts sent","","%s", (sprintf(bufl,"%d/%d", pab->syn_count, pab->fin_count),(int)bufl), (sprintf(bufr,"%d/%d", pba->syn_count, pba->fin_count),(int)bufr)); if (pab->f1323_ws || pba->f1323_ws || pab->f1323_ts || pba->f1323_ts) { StatLineI("req 1323 ws/ts","","%s", (sprintf(bufl,"%c/%c", pab->f1323_ws?'Y':'N',pab->f1323_ts?'Y':'N'),(int)bufl), (sprintf(bufr,"%c/%c", pba->f1323_ws?'Y':'N',pba->f1323_ts?'Y':'N'),(int)bufr)); } if (pab->f1323_ws || pba->f1323_ws) { StatLineI("adv wind scale","","%d", pab->window_scale, pba->window_scale); } if (pab->fsack_req || pba->fsack_req) { StatLineI("req sack","","%c", pab->fsack_req?'Y':'N', pba->fsack_req?'Y':'N'); StatLineI("sacks sent","","%d", pab->sacks_sent, pba->sacks_sent); } StatLineI("mss requested","bytes","%8lu", pab->mss, pba->mss); StatLineI("max segm size","bytes","%8lu", pab->max_seg_size, pba->max_seg_size); StatLineI("min segm size","bytes","%8lu", pab->min_seg_size, pba->min_seg_size); StatLineI("avg segm size","bytes","%8lu", (int)((double)pab->data_bytes / ((double)pab->data_pkts+.001)), (int)((double)pba->data_bytes / ((double)pba->data_pkts+.001))); StatLineI("max win adv","bytes","%8lu", pab->win_max, pba->win_max); StatLineI("min win adv","bytes","%8lu", pab->win_min, pba->win_min); StatLineI("zero win adv","times","%8lu", pab->win_zero_ct, pba->win_zero_ct); StatLineI("avg win adv","bytes","%8lu", pab->ack_pkts==0?0:pab->win_tot/pab->ack_pkts, pba->ack_pkts==0?0:pba->win_tot/pba->ack_pkts); if (print_cwin) { StatLineI("max cwin","bytes","%8lu", pab->cwin_max, pba->cwin_max); StatLineI("min cwin","bytes","%8lu", pab->cwin_min, pba->cwin_min); StatLineI("avg cwin","bytes","%8lu", pab->ack_pkts==0?0:pab->cwin_tot/pab->ack_pkts, pba->ack_pkts==0?0:pba->cwin_tot/pba->ack_pkts); } StatLineI("initial window","bytes","%8lu", pab->initialwin_bytes, pba->initialwin_bytes); StatLineI("initial window","pkts","%8lu", pab->initialwin_segs, pba->initialwin_segs); /* compare to theoretical length of the stream (not just what we saw) using the SYN and FIN (N.B. not taking wrapped seq space into account) */ if ((pab->syn_count > 0) && (pab->fin_count > 0) && (pba->syn_count > 0) && (pba->fin_count > 0)) { StatLineI("ttl stream length","bytes","%8lu", pab->fin-pab->syn-1, pba->fin-pba->syn-1); StatLineI("missed data","bytes","%8lu", pab->fin-pab->syn-1-(pab->data_bytes-pab->rexmit_bytes), pba->fin-pba->syn-1-(pba->data_bytes-pba->rexmit_bytes)); } else { StatLineI("ttl stream length","","%s",(int)"NA",(int)"NA"); StatLineI("missed data","","%s",(int)"NA",(int)"NA"); } /* if we saved the contents, tell how much is missing */ if (save_tcp_data) { StatLineI("truncated data","bytes","%8lu", pab->trunc_bytes, pba->trunc_bytes); StatLineI("truncated packets","pkts","%8lu", pab->trunc_segs, pba->trunc_segs); } /* stats on just the data */ etime_data1 = elapsed(pab->first_data_time, pab->last_data_time); /* in usecs */ etime_data2 = elapsed(pba->first_data_time, pba->last_data_time); /* in usecs */ StatLineI("data xmit time","secs","%s", (sprintf(bufl,"%lu.%03lu", (int)etime_data1 / 1000000, ((int)etime_data1%1000000)/1000), (int)bufl), (sprintf(bufr,"%lu.%03lu", (int)etime_data2 / 1000000, ((int)etime_data2%1000000)/1000), (int)bufr)); /* do the throughput calcs */ etime /= 1000000.0; /* convert to seconds */ if (etime == 0.0) StatLineI("throughput","","%s",(int)"NA",(int)"NA"); else StatLineF("throughput","Bps","%8.0f", (double) (pab->data_bytes-pab->rexmit_bytes) / etime, (double) (pba->data_bytes-pba->rexmit_bytes) / etime); if (print_rtt) { fprintf(stdout,"\n"); StatLineI("RTT samples","","%8lu", pab->rtt_count, pba->rtt_count); StatLineF("RTT min","ms","%8.1f", (double)pab->rtt_min/1000.0, (double)pba->rtt_min/1000.0); StatLineF("RTT max","ms","%8.1f", (double)pab->rtt_max/1000.0, (double)pba->rtt_max/1000.0); StatLineF("RTT avg","ms","%8.1f", Average(pab->rtt_sum, pab->rtt_count) / 1000.0, Average(pba->rtt_sum, pba->rtt_count) / 1000.0); StatLineF("RTT stdev","ms","%8.1f", Stdev(pab->rtt_sum, pab->rtt_sum2, pab->rtt_count) / 1000.0, Stdev(pba->rtt_sum, pba->rtt_sum2, pba->rtt_count) / 1000.0); if (pab->rtt_amback || pba->rtt_amback) { fprintf(stdout, "\ \t For the following 5 RTT statistics, only ACKs for\n\ \t multiply-transmitted segments (ambiguous ACKs) were\n\ \t considered. Times are taken from the last instance\n\ \t of a segment.\n\ "); StatLineI("ambiguous acks","","%8lu", pab->rtt_amback, pba->rtt_amback); StatLineF("RTT min (last)","ms","%8.1f", (double)pab->rtt_min_last/1000.0, (double)pba->rtt_min_last/1000.0); StatLineF("RTT max (last)","ms","%8.1f", (double)pab->rtt_max_last/1000.0, (double)pba->rtt_max_last/1000.0); StatLineF("RTT avg (last)","ms","%8.1f", Average(pab->rtt_sum_last, pab->rtt_count_last) / 1000.0, Average(pba->rtt_sum_last, pba->rtt_count_last) / 1000.0); StatLineF("RTT sdv (last)","ms","%8.1f", Stdev(pab->rtt_sum_last, pab->rtt_sum2_last, pab->rtt_count_last) / 1000.0, Stdev(pba->rtt_sum_last, pba->rtt_sum2_last, pba->rtt_count_last) / 1000.0); } StatLineI("segs cum acked","","%8lu", pab->rtt_cumack, pba->rtt_cumack); StatLineI("duplicate acks","","%8lu", pab->rtt_dupack, pba->rtt_dupack); if (debug) StatLineI("unknown acks:","","%8lu", pab->rtt_unkack, pba->rtt_unkack); StatLineI("max # retrans","","%8lu", pab->retr_max, pba->retr_max); StatLineF("min retr time","ms","%8.1f", (double)((double)pab->retr_min_tm/1000.0), (double)((double)pba->retr_min_tm/1000.0)); StatLineF("max retr time","ms","%8.1f", (double)((double)pab->retr_max_tm/1000.0), (double)((double)pba->retr_max_tm/1000.0)); StatLineF("avg retr time","ms","%8.1f", Average(pab->retr_tm_sum, pab->retr_tm_count) / 1000.0, Average(pba->retr_tm_sum, pba->retr_tm_count) / 1000.0); StatLineF("sdv retr time","ms","%8.1f", Stdev(pab->retr_tm_sum, pab->retr_tm_sum2, pab->retr_tm_count) / 1000.0, Stdev(pba->retr_tm_sum, pba->retr_tm_sum2, pba->retr_tm_count) / 1000.0); } } static void StatLineI( char *label, char *units, char *format, u_long argleft, u_long argright) { StatLineField(label,units,format,argleft,0); StatLineField(label,units,format,argright,1); } static void StatLineF( char *label, char *units, char *format, double argleft, double argright) { StatLineFieldF(label,units,format,argleft,0); StatLineFieldF(label,units,format,argright,1); } static void StatLineField( char *label, char *units, char *format, u_long arg, int f_rightside) { char valbuf[20]; /* determine the value to print */ sprintf(valbuf,format,arg); /* print the field */ printf(" "); StatLineOne(label, units, valbuf); if (f_rightside) printf("\n"); } static void StatLineFieldF( char *label, char *units, char *format, double arg, int f_rightside) { int printable; char valbuf[20]; /* see if the float argument is printable */ printable = finite(arg); /* determine the value to print */ if (printable) sprintf(valbuf,format,arg); /* print the field */ printf(" "); if (printable) StatLineOne(label, units, valbuf); else StatLineOne(label, "", "NA"); if (f_rightside) printf("\n"); } static void StatLineOne( char *label, char *units, char *value) { char labbuf[20]; /* format the label */ sprintf(labbuf, "%s:", label); /* print the field */ printf("%-18s %9s %-5s", labbuf, value, units); }