blob: 0017500482eafa9ab1a4a4ce0ca529d922943995 (
plain)
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
|
// Copyright (c) 2012 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
// This class is a helper class to TcpCubicSender.
// Slow start is the initial startup phase of TCP, it lasts until first packet
// loss. This class implements hybrid slow start of the TCP cubic send side
// congestion algorithm. The key feaure of hybrid slow start is that it tries to
// avoid running into the wall too hard during the slow start phase, which
// the traditional TCP implementation does.
// This does not implement ack train detection because it interacts poorly with
// pacing.
// http://netsrv.csc.ncsu.edu/export/hybridstart_pfldnet08.pdf
// http://research.csc.ncsu.edu/netsrv/sites/default/files/hystart_techreport_2008.pdf
#ifndef QUICHE_QUIC_CORE_CONGESTION_CONTROL_HYBRID_SLOW_START_H_
#define QUICHE_QUIC_CORE_CONGESTION_CONTROL_HYBRID_SLOW_START_H_
#include <cstdint>
#include "net/third_party/quiche/src/quic/core/quic_packets.h"
#include "net/third_party/quiche/src/quic/core/quic_time.h"
#include "net/third_party/quiche/src/quic/platform/api/quic_export.h"
namespace quic {
class QUIC_EXPORT_PRIVATE HybridSlowStart {
public:
HybridSlowStart();
HybridSlowStart(const HybridSlowStart&) = delete;
HybridSlowStart& operator=(const HybridSlowStart&) = delete;
void OnPacketAcked(QuicPacketNumber acked_packet_number);
void OnPacketSent(QuicPacketNumber packet_number);
// ShouldExitSlowStart should be called on every new ack frame, since a new
// RTT measurement can be made then.
// rtt: the RTT for this ack packet.
// min_rtt: is the lowest delay (RTT) we have seen during the session.
// congestion_window: the congestion window in packets.
bool ShouldExitSlowStart(QuicTime::Delta rtt,
QuicTime::Delta min_rtt,
QuicPacketCount congestion_window);
// Start a new slow start phase.
void Restart();
// TODO(ianswett): The following methods should be private, but that requires
// a follow up CL to update the unit test.
// Returns true if this ack the last packet number of our current slow start
// round.
// Call Reset if this returns true.
bool IsEndOfRound(QuicPacketNumber ack) const;
// Call for the start of each receive round (burst) in the slow start phase.
void StartReceiveRound(QuicPacketNumber last_sent);
// Whether slow start has started.
bool started() const { return started_; }
private:
// Whether a condition for exiting slow start has been found.
enum HystartState {
NOT_FOUND,
DELAY, // Too much increase in the round's min_rtt was observed.
};
// Whether the hybrid slow start has been started.
bool started_;
HystartState hystart_found_;
// Last packet number sent which was CWND limited.
QuicPacketNumber last_sent_packet_number_;
// Variables for tracking acks received during a slow start round.
QuicPacketNumber end_packet_number_; // End of the receive round.
uint32_t rtt_sample_count_; // Number of rtt samples in the current round.
QuicTime::Delta current_min_rtt_; // The minimum rtt of current round.
};
} // namespace quic
#endif // QUICHE_QUIC_CORE_CONGESTION_CONTROL_HYBRID_SLOW_START_H_
|
