Return to rtt.c CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / hping2

Annotation of embedaddon/hping2/rtt.c, revision 1.1

1.1     ! misho       1: /* 
        !             2:  * $smu-mark$ 
        !             3:  * $name: rtt.c$ 
        !             4:  * $author: Salvatore Sanfilippo <antirez@invece.org>$ 
        !             5:  * $copyright: Copyright (C) 1999 by Salvatore Sanfilippo$ 
        !             6:  * $license: This software is under GPL version 2 of license$ 
        !             7:  * $date: Fri Nov  5 11:55:49 MET 1999$ 
        !             8:  * $rev: 3$ 
        !             9:  */ 
        !            10: 
        !            11: #include <time.h>
        !            12: #include <stdio.h>
        !            13: 
        !            14: #include "hping2.h"
        !            15: #include "globals.h"
        !            16: 
        !            17: void minavgmax(float ms_delay)
        !            18: {
        !            19:        static int avg_counter = 0;
        !            20: 
        !            21:        if (rtt_min == 0 || ms_delay < rtt_min)
        !            22:                rtt_min = ms_delay;
        !            23:        if (rtt_max == 0 || ms_delay > rtt_max)
        !            24:                rtt_max = ms_delay;
        !            25:        avg_counter++;
        !            26:        rtt_avg = (rtt_avg*(avg_counter-1)/avg_counter)+(ms_delay/avg_counter);
        !            27: }
        !            28: 
        !            29: int rtt(int *seqp, int recvport, float *ms_delay)
        !            30: {
        !            31:        long sec_delay = 0, usec_delay = 0;
        !            32:        int i, tablepos = -1, status;
        !            33: 
        !            34:        if (*seqp != 0) {
        !            35:                for (i = 0; i < TABLESIZE; i++)
        !            36:                        if (delaytable[i].seq == *seqp) {
        !            37:                                tablepos = i;
        !            38:                                break;
        !            39:                        }
        !            40:        } else {
        !            41:                for (i=0; i<TABLESIZE; i++)
        !            42:                        if (delaytable[i].src == recvport) {
        !            43:                                tablepos = i;
        !            44:                                break;
        !            45:                        }
        !            46:                        if (i != TABLESIZE)
        !            47:                                *seqp = delaytable[i].seq;
        !            48:        }
        !            49: 
        !            50:        if (tablepos != -1)
        !            51:        {
        !            52:                status = delaytable[tablepos].status;
        !            53:                delaytable[tablepos].status = S_RECV;
        !            54: 
        !            55:                sec_delay = time(NULL) - delaytable[tablepos].sec;
        !            56:                usec_delay = get_usec() - delaytable[tablepos].usec;
        !            57:                if (sec_delay == 0 && usec_delay < 0)
        !            58:                        usec_delay += 1000000;
        !            59: 
        !            60:                *ms_delay = (sec_delay * 1000) + ((float)usec_delay / 1000);
        !            61:                minavgmax(*ms_delay);
        !            62:        }
        !            63:        else
        !            64:        {
        !            65:                *ms_delay = 0;  /* not in table.. */
        !            66:                status = 0;     /* we don't know if it's DUP */
        !            67:        }
        !            68: 
        !            69:        /* SANITY CHECK */
        !            70:        if (*ms_delay < 0)
        !            71:        {
        !            72:                printf("\n\nSANITY CHECK in rtt.c FAILED!\n");
        !            73:                printf("- seqnum = %d\n", *seqp);
        !            74:                printf("- status = %d\n", status);
        !            75:                printf("- get_usec() = %ld\n", (long int) get_usec());
        !            76:                printf("- delaytable.usec = %ld\n", 
        !            77:                        (long int) delaytable[tablepos].usec);
        !            78:                printf("- usec_delay = %ld\n", usec_delay);
        !            79:                printf("- time(NULL) = %ld\n", (long int) time(NULL));
        !            80:                printf("- delaytable.sec = %ld\n", 
        !            81:                        (long int) delaytable[tablepos].sec);
        !            82:                printf("- sec_delay = %ld\n", sec_delay);
        !            83:                printf("- ms_delay = %f\n", *ms_delay);
        !            84:                printf("END SANITY CHECK REPORT\n\n");
        !            85:        }
        !            86: 
        !            87:        return status;
        !            88: }
        !            89: 
        !            90: void delaytable_add(int seq, int src, time_t sec, time_t usec, int status)
        !            91: {
        !            92:        delaytable[delaytable_index % TABLESIZE].seq = seq;
        !            93:        delaytable[delaytable_index % TABLESIZE].src = src;
        !            94:        delaytable[delaytable_index % TABLESIZE].sec = sec;
        !            95:        delaytable[delaytable_index % TABLESIZE].usec = usec;
        !            96:        delaytable[delaytable_index % TABLESIZE].status = status;
        !            97:        delaytable_index++;
        !            98: }
        !            99: