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
|
#include <udt.h>
#include <ccc.h>
class CTCP: public CCC
{
public:
void init()
{
m_bSlowStart = true;
m_issthresh = 83333;
m_dPktSndPeriod = 0.0;
m_dCWndSize = 2.0;
setACKInterval(2);
setRTO(1000000);
}
virtual void onACK(const int& ack)
{
if (ack == m_iLastACK)
{
if (3 == ++ m_iDupACKCount)
DupACKAction();
else if (m_iDupACKCount > 3)
m_dCWndSize += 1.0;
else
ACKAction();
}
else
{
if (m_iDupACKCount >= 3)
m_dCWndSize = m_issthresh;
m_iLastACK = ack;
m_iDupACKCount = 1;
ACKAction();
}
}
virtual void onTimeout()
{
m_issthresh = getPerfInfo()->pktFlightSize / 2;
if (m_issthresh < 2)
m_issthresh = 2;
m_bSlowStart = true;
m_dCWndSize = 2.0;
}
protected:
virtual void ACKAction()
{
if (m_bSlowStart)
{
m_dCWndSize += 1.0;
if (m_dCWndSize >= m_issthresh)
m_bSlowStart = false;
}
else
m_dCWndSize += 1.0/m_dCWndSize;
}
virtual void DupACKAction()
{
m_bSlowStart = false;
m_issthresh = getPerfInfo()->pktFlightSize / 2;
if (m_issthresh < 2)
m_issthresh = 2;
m_dCWndSize = m_issthresh + 3;
}
protected:
int m_issthresh;
bool m_bSlowStart;
int m_iDupACKCount;
int m_iLastACK;
};
class CUDPBlast: public CCC
{
public:
CUDPBlast()
{
m_dPktSndPeriod = 1000000;
m_dCWndSize = 83333.0;
}
public:
void setRate(double mbps)
{
m_dPktSndPeriod = (m_iMSS * 8.0) / mbps;
}
};
|
