25 #include "ns3/simulator.h"
41 .AddConstructor<TcpBbr>()
42 .SetGroupName(
"Internet")
43 .AddAttribute(
"Stream",
44 "Random number stream (default is set to 4 to align with Linux results)",
47 MakeUintegerChecker<uint32_t>())
48 .AddAttribute(
"HighGain",
52 MakeDoubleChecker<double>())
53 .AddAttribute(
"BwWindowLength",
54 "Length of bandwidth windowed filter",
57 MakeUintegerChecker<uint32_t>())
58 .AddAttribute(
"RttWindowLength",
59 "Length of RTT windowed filter",
63 .AddAttribute(
"ProbeRttDuration",
64 "Time to be spent in PROBE_RTT phase",
68 .AddAttribute(
"ExtraAckedRttWindowLength",
69 "Window length of extra acked window",
72 MakeUintegerChecker<uint32_t>())
74 "AckEpochAckedResetThresh",
75 "Max allowed val for m_ackEpochAcked, after which sampling epoch is reset",
78 MakeUintegerChecker<uint32_t>());
86 m_uv = CreateObject<UniformRandomVariable>();
91 m_bandwidthWindowLength(sock.m_bandwidthWindowLength),
92 m_pacingGain(sock.m_pacingGain),
93 m_cWndGain(sock.m_cWndGain),
94 m_highGain(sock.m_highGain),
95 m_isPipeFilled(sock.m_isPipeFilled),
96 m_minPipeCwnd(sock.m_minPipeCwnd),
97 m_roundCount(sock.m_roundCount),
98 m_roundStart(sock.m_roundStart),
99 m_nextRoundDelivered(sock.m_nextRoundDelivered),
100 m_probeRttDuration(sock.m_probeRttDuration),
101 m_probeRtPropStamp(sock.m_probeRtPropStamp),
102 m_probeRttDoneStamp(sock.m_probeRttDoneStamp),
103 m_probeRttRoundDone(sock.m_probeRttRoundDone),
104 m_packetConservation(sock.m_packetConservation),
105 m_priorCwnd(sock.m_priorCwnd),
106 m_idleRestart(sock.m_idleRestart),
107 m_targetCWnd(sock.m_targetCWnd),
108 m_fullBandwidth(sock.m_fullBandwidth),
109 m_fullBandwidthCount(sock.m_fullBandwidthCount),
111 m_sendQuantum(sock.m_sendQuantum),
112 m_cycleStamp(sock.m_cycleStamp),
113 m_cycleIndex(sock.m_cycleIndex),
114 m_rtPropExpired(sock.m_rtPropExpired),
115 m_rtPropFilterLen(sock.m_rtPropFilterLen),
116 m_rtPropStamp(sock.m_rtPropStamp),
117 m_isInitialized(sock.m_isInitialized),
119 m_delivered(sock.m_delivered),
120 m_appLimited(sock.m_appLimited),
121 m_txItemDelivered(sock.m_txItemDelivered),
122 m_extraAckedGain(sock.m_extraAckedGain),
123 m_extraAckedWinRtt(sock.m_extraAckedWinRtt),
124 m_extraAckedWinRttLength(sock.m_extraAckedWinRttLength),
125 m_ackEpochAckedResetThresh(sock.m_ackEpochAckedResetThresh),
126 m_extraAckedIdx(sock.m_extraAckedIdx),
127 m_ackEpochTime(sock.m_ackEpochTime),
128 m_ackEpochAcked(sock.m_ackEpochAcked),
129 m_hasSeenRtt(sock.m_hasSeenRtt)
211 if (
m_state == BbrMode_t::BBR_PROBE_BW)
249 return (gain * estimatedBdp) + quanta + (2 * tcb->
m_segmentSize);
251 return (gain * estimatedBdp) + quanta;
274 return isFullLength &&
450 if (
m_state == BbrMode_t::BBR_PROBE_RTT)
478 uint32_t maxAggrBytes;
479 uint32_t aggrCwndBytes = 0;
485 aggrCwndBytes =
std::min(aggrCwndBytes, maxAggrBytes);
487 return aggrCwndBytes;
493 uint32_t expectedAcked;
556 if (
m_state == BbrMode_t::BBR_PROBE_RTT)
714 NS_LOG_DEBUG(
"CongestionStateSet triggered to CA_OPEN :: " << newState);
737 NS_LOG_DEBUG(
"CongestionStateSet triggered to CA_LOSS :: " << newState);
743 NS_LOG_DEBUG(
"CongestionStateSet triggered to CA_RECOVERY :: " << newState);
757 NS_LOG_DEBUG(
"CwndEvent triggered to CA_EVENT_COMPLETE_CWR :: " << event);
763 NS_LOG_DEBUG(
"CwndEvent triggered to CA_EVENT_TX_START :: " << event);
767 if (
m_state == BbrMode_t::BBR_PROBE_BW)
771 else if (
m_state == BbrMode_t::BBR_PROBE_RTT)
788 return tcb->m_ssThresh;
794 return CopyObject<TcpBbr>(
this);
Class for representing data rates.
uint64_t GetBitRate() const
Get the underlying bitrate.
This class can be used to hold variables of floating point type such as 'double' or 'float'.
void SetStream(int64_t stream)
Specifies the stream number for the RngStream.
static Time Now()
Return the current simulation virtual time.
BBR congestion control algorithm.
MaxBandwidthFilter_t m_maxBwFilter
Maximum bandwidth filter.
bool m_hasSeenRtt
Have we seen RTT sample yet?
double m_cWndGain
The dynamic congestion window gain factor.
void ModulateCwndForProbeRTT(Ptr< TcpSocketState > tcb)
Modulates congestion window in BBR_PROBE_RTT.
uint32_t m_nextRoundDelivered
Denotes the end of a packet-timed round trip.
BbrMode_t
BBR has the following 4 modes for deciding how fast to send:
uint32_t m_roundCount
Count of packet-timed round trips.
uint32_t m_priorCwnd
The last-known good congestion window.
uint32_t m_extraAckedWinRttLength
Window length of extra acked window.
virtual void SetStream(uint32_t stream)
Assign a fixed random variable stream number to the random variables used by this model.
uint32_t m_extraAckedIdx
Current index in extra acked array.
std::string GetName() const override
Get the name of the congestion control algorithm.
void CongControl(Ptr< TcpSocketState > tcb, const TcpRateOps::TcpRateConnection &rc, const TcpRateOps::TcpRateSample &rs) override
Called when packets are delivered to update cwnd and pacing rate.
bool m_rtPropExpired
A boolean recording whether the BBR.RTprop has expired.
void CwndEvent(Ptr< TcpSocketState > tcb, const TcpSocketState::TcpCAEvent_t event) override
Trigger events/calculations on occurrence of congestion window event.
uint32_t GetSsThresh(Ptr< const TcpSocketState > tcb, uint32_t bytesInFlight) override
Get the slow start threshold after a loss event.
uint32_t m_bandwidthWindowLength
A constant specifying the length of the BBR.BtlBw max filter window, default 10 packet-timed round tr...
double m_highGain
A constant specifying highest gain factor, default is 2.89.
Time m_probeRttDuration
A constant specifying the minimum duration for which ProbeRTT state, default 200 millisecs.
void CheckCyclePhase(Ptr< TcpSocketState > tcb, const TcpRateOps::TcpRateSample &rs)
Checks whether to advance pacing gain in BBR_PROBE_BW state, and if allowed calls AdvanceCyclePhase (...
uint32_t AckAggregationCwnd()
Find Cwnd increment based on ack aggregation.
bool m_idleRestart
When restarting from idle, set it true.
Ptr< UniformRandomVariable > m_uv
Uniform Random Variable.
Time m_rtPropStamp
The wall clock time at which the current BBR.RTProp sample was obtained.
void UpdateBtlBw(Ptr< TcpSocketState > tcb, const TcpRateOps::TcpRateSample &rs)
Updates maximum bottleneck.
static TypeId GetTypeId()
Get the type ID.
uint32_t m_minPipeCwnd
The minimal congestion window value BBR tries to target, default 4 Segment size.
Ptr< TcpCongestionOps > Fork() override
Copy the congestion control algorithm across sockets.
uint32_t GetBbrState()
Gets BBR state.
bool HasCongControl() const override
Returns true when Congestion Control Algorithm implements CongControl.
double GetCwndGain()
Gets current cwnd gain.
void UpdateRound(Ptr< TcpSocketState > tcb, const TcpRateOps::TcpRateSample &rs)
Updates round counting related variables.
BbrMode_t m_state
Current state of BBR state machine.
bool m_roundStart
A boolean that BBR sets to true once per packet-timed round trip.
void AdvanceCyclePhase()
Advances pacing gain using cycle gain algorithm, while in BBR_PROBE_BW state.
void EnterProbeBW()
Updates variables specific to BBR_PROBE_BW state.
double GetPacingGain()
Gets current pacing gain.
uint64_t m_delivered
The total amount of data in bytes delivered so far.
void InitPacingRate(Ptr< TcpSocketState > tcb)
Initializes the pacing rate.
bool IsNextCyclePhase(Ptr< TcpSocketState > tcb, const TcpRateOps::TcpRateSample &rs)
Checks whether to move to next value of pacing gain while in BBR_PROBE_BW.
bool m_isInitialized
Set to true after first time initializtion variables.
void RestoreCwnd(Ptr< TcpSocketState > tcb)
Helper to restore the last-known good congestion window.
bool ModulateCwndForRecovery(Ptr< TcpSocketState > tcb, const TcpRateOps::TcpRateSample &rs)
Modulates congestion window in CA_RECOVERY.
double m_pacingGain
The dynamic pacing gain factor.
static const char *const BbrModeName[BBR_PROBE_RTT+1]
Literal names of BBR mode for use in log messages.
void UpdateRTprop(Ptr< TcpSocketState > tcb)
Updates minimum RTT.
void CheckDrain(Ptr< TcpSocketState > tcb)
Checks whether its time to enter BBR_DRAIN or BBR_PROBE_BW state.
void SetBbrState(BbrMode_t state)
Sets BBR state.
void HandleRestartFromIdle(Ptr< TcpSocketState > tcb, const TcpRateOps::TcpRateSample &rs)
Updates pacing rate if socket is restarting from idle state.
static const double PACING_GAIN_CYCLE[]
BBR uses an eight-phase cycle with the given pacing_gain value in the BBR ProbeBW gain cycle.
WindowedFilter< DataRate, MaxFilter< DataRate >, uint32_t, uint32_t > MaxBandwidthFilter_t
Definition of max bandwidth filter.
bool m_isPipeFilled
A boolean that records whether BBR has filled the pipe.
void EnterStartup()
Updates variables specific to BBR_STARTUP state.
void InitRoundCounting()
Initializes the round counting related variables.
void InitFullPipe()
Initializes the full pipe estimator.
void UpdateAckAggregation(Ptr< TcpSocketState > tcb, const TcpRateOps::TcpRateSample &rs)
Estimates max degree of aggregation.
uint32_t m_txItemDelivered
The number of bytes already delivered at the time of new packet transmission.
bool m_packetConservation
Enable/Disable packet conservation mode.
uint32_t InFlight(Ptr< TcpSocketState > tcb, double gain)
Estimates the target value for congestion window.
uint32_t m_extraAckedWinRtt
Age of extra acked in rtt.
void SetPacingRate(Ptr< TcpSocketState > tcb, double gain)
Updates pacing rate based on network model.
void SaveCwnd(Ptr< const TcpSocketState > tcb)
Helper to remember the last-known good congestion window or the latest congestion window unmodulated ...
void EnterDrain()
Updates variables specific to BBR_DRAIN state.
void CongestionStateSet(Ptr< TcpSocketState > tcb, const TcpSocketState::TcpCongState_t newState) override
Trigger events/calculations specific to a congestion state.
Time m_probeRttDoneStamp
Time to exit from BBR_PROBE_RTT state.
uint32_t m_extraAcked[2]
Maximum excess data acked in epoch.
Time m_rtProp
Estimated two-way round-trip propagation delay of the path, estimated from the windowed minimum recen...
uint32_t m_appLimited
The index of the last transmitted packet marked as application-limited.
void UpdateModelAndState(Ptr< TcpSocketState > tcb, const TcpRateOps::TcpRateSample &rs)
Updates BBR network model (Maximum bandwidth and minimum RTT).
void UpdateControlParameters(Ptr< TcpSocketState > tcb, const TcpRateOps::TcpRateSample &rs)
Updates control parameters congestion windowm, pacing rate, send quantum.
Time m_ackEpochTime
Starting of ACK sampling epoch time.
Time m_cycleStamp
Last time gain cycle updated.
void CheckFullPipe(const TcpRateOps::TcpRateSample &rs)
Identifies whether pipe or BDP is already full.
void EnterProbeRTT()
Updates variables specific to BBR_PROBE_RTT state.
DataRate m_fullBandwidth
Value of full bandwidth recorded.
void HandleProbeRTT(Ptr< TcpSocketState > tcb)
Handles the steps for BBR_PROBE_RTT state.
Time m_rtPropFilterLen
A constant specifying the length of the RTProp min filter window, default 10 secs.
uint32_t m_targetCWnd
Target value for congestion window, adapted to the estimated BDP.
uint32_t m_sendQuantum
The maximum size of a data aggregate scheduled and transmitted together.
void SetSendQuantum(Ptr< TcpSocketState > tcb)
Updates send quantum based on the network model.
uint32_t m_ackEpochAckedResetThresh
Max allowed val for m_ackEpochAcked, after which sampling epoch is reset.
void ExitProbeRTT()
Called on exiting from BBR_PROBE_RTT state, it eithers invoke EnterProbeBW () or EnterStartup ()
bool m_probeRttRoundDone
True when it is time to exit BBR_PROBE_RTT.
uint32_t m_fullBandwidthCount
Count of full bandwidth recorded consistently.
void UpdateTargetCwnd(Ptr< TcpSocketState > tcb)
Updates target congestion window.
uint32_t m_cycleIndex
Current index of gain cycle.
uint32_t m_extraAckedGain
Gain factor for adding extra ack to cwnd.
void CheckProbeRTT(Ptr< TcpSocketState > tcb, const TcpRateOps::TcpRateSample &rs)
This method handles the steps related to the ProbeRTT state.
static const uint8_t GAIN_CYCLE_LENGTH
The number of phases in the BBR ProbeBW gain cycle.
void SetCwnd(Ptr< TcpSocketState > tcb, const TcpRateOps::TcpRateSample &rs)
Updates congestion window based on the network model.
uint32_t m_ackEpochAcked
Bytes ACked in sampling epoch.
Congestion control abstract class.
uint32_t m_segmentSize
Segment size.
TcpCAEvent_t
Congestion avoidance events.
@ CA_EVENT_COMPLETE_CWR
end of congestion recovery
@ CA_EVENT_TX_START
first transmit when no packets in flight
Time m_minRtt
Minimum RTT observed throughout the connection.
uint32_t m_initialSsThresh
Initial Slow Start Threshold value.
TracedValue< DataRate > m_pacingRate
Current Pacing rate.
TracedValue< TcpCongState_t > m_congState
State in the Congestion state machine.
DataRate m_maxPacingRate
Max Pacing rate.
bool m_pacing
Pacing status.
TcpCongState_t
Definition of the Congestion state machine.
@ CA_RECOVERY
CWND was reduced, we are fast-retransmitting.
@ CA_LOSS
CWND was reduced due to RTO timeout or SACK reneging.
@ CA_OPEN
Normal state, no dubious events.
TracedValue< uint32_t > m_cWnd
Congestion window.
uint32_t m_initialCWnd
Initial cWnd value.
TracedValue< Time > m_lastRtt
Last RTT sample collected.
TracedValue< uint32_t > m_bytesInFlight
Bytes in flight.
uint32_t m_lastAckedSackedBytes
The number of bytes acked and sacked as indicated by the current ACK received.
TracedValue< uint32_t > m_ssThresh
Slow start threshold.
Simulation virtual time values and global simulation resolution.
int64_t GetMilliSeconds() const
Get an approximation of the time stored in this instance in the indicated unit.
double GetSeconds() const
Get an approximation of the time stored in this instance in the indicated unit.
static Time Max()
Maximum representable Time Not to be confused with Max(Time,Time).
T Get() const
Get the underlying value.
a unique identifier for an interface.
TypeId SetParent(TypeId tid)
Set the parent TypeId.
Hold an unsigned integer type.
void Update(T new_sample, TimeT new_time)
Updates best estimates with |sample|, and expires and updates best estimates as necessary.
T GetBest() const
Returns Max/Min value so far among the windowed samples.
int64x64_t Max(const int64x64_t &a, const int64x64_t &b)
Maximum.
#define NS_LOG_COMPONENT_DEFINE(name)
Define a Log component with a specific name.
#define NS_LOG_DEBUG(msg)
Use NS_LOG to output a message of level LOG_DEBUG.
#define NS_LOG_FUNCTION(parameters)
If log level LOG_FUNCTION is enabled, this macro will output all input parameters separated by ",...
#define NS_LOG_WARN(msg)
Use NS_LOG to output a message of level LOG_WARN.
void(* DataRate)(DataRate oldValue, DataRate newValue)
TracedValue callback signature for DataRate.
#define NS_OBJECT_ENSURE_REGISTERED(type)
Register an Object subclass with the TypeId system.
Time Seconds(double value)
Construct a Time in the indicated unit.
Time MilliSeconds(uint64_t value)
Construct a Time in the indicated unit.
Every class exported by the ns3 library is enclosed in the ns3 namespace.
Ptr< const AttributeAccessor > MakeTimeAccessor(T1 a1)
Ptr< const AttributeChecker > MakeTimeChecker(const Time min, const Time max)
Helper to make a Time checker with bounded range.
Ptr< const AttributeAccessor > MakeDoubleAccessor(T1 a1)
Ptr< const AttributeAccessor > MakeUintegerAccessor(T1 a1)
Information about the connection rate.
bool m_isAppLimited
Indicates whether the rate sample is application-limited.
uint32_t m_ackedSacked
The amount of data acked and sacked in the last received ack.
DataRate m_deliveryRate
The delivery rate sample.
uint32_t m_priorInFlight
The value if bytes in flight prior to last received ack.
uint32_t m_priorDelivered
The delivered count of the most recent packet delivered.
int32_t m_delivered
The amount of data marked as delivered over the sampling interval.
uint32_t m_bytesLoss
The amount of data marked as lost from the most recent ack received.