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