tcp-yeah.cc

Go to the documentation of this file.

/*
 * Copyright (c) 2016 ResiliNets, ITTC, University of Kansas
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License version 2 as
 * published by the Free Software Foundation;
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 *
 * Author: Truc Anh N. Nguyen <annguyen@ittc.ku.edu>
 *
 * James P.G. Sterbenz <jpgs@ittc.ku.edu>, director
 * ResiliNets Research Group  https://resilinets.org/
 * Information and Telecommunication Technology Center (ITTC)
 * and Department of Electrical Engineering and Computer Science
 * The University of Kansas Lawrence, KS USA.
 */
 
#include "tcp-yeah.h"
 
#include "ns3/log.h"
 
namespace ns3
{
 
NS_LOG_COMPONENT_DEFINE("TcpYeah");
NS_OBJECT_ENSURE_REGISTERED(TcpYeah);
 
TypeId
TcpYeah::GetTypeId()
{
    static TypeId tid =
        TypeId("ns3::TcpYeah")
            .SetParent<TcpNewReno>()
            .AddConstructor<TcpYeah>()
            .SetGroupName("Internet")
            .AddAttribute("Alpha",
                          "Maximum backlog allowed at the bottleneck queue",
                          UintegerValue(80),
                          MakeUintegerAccessor(&TcpYeah::m_alpha),
                          MakeUintegerChecker<uint32_t>())
            .AddAttribute("Gamma",
                          "Fraction of queue to be removed per RTT",
                          UintegerValue(1),
                          MakeUintegerAccessor(&TcpYeah::m_gamma),
                          MakeUintegerChecker<uint32_t>())
            .AddAttribute("Delta",
                          "Log minimum fraction of cwnd to be removed on loss",
                          UintegerValue(3),
                          MakeUintegerAccessor(&TcpYeah::m_delta),
                          MakeUintegerChecker<uint32_t>())
            .AddAttribute("Epsilon",
                          "Log maximum fraction to be removed on early decongestion",
                          UintegerValue(1),
                          MakeUintegerAccessor(&TcpYeah::m_epsilon),
                          MakeUintegerChecker<uint32_t>())
            .AddAttribute("Phy",
                          "Maximum delta from base",
                          UintegerValue(8),
                          MakeUintegerAccessor(&TcpYeah::m_phy),
                          MakeUintegerChecker<uint32_t>())
            .AddAttribute("Rho",
                          "Minimum # of consecutive RTT to consider competition on loss",
                          UintegerValue(16),
                          MakeUintegerAccessor(&TcpYeah::m_rho),
                          MakeUintegerChecker<uint32_t>())
            .AddAttribute("Zeta",
                          "Minimum # of state switches to reset m_renoCount",
                          UintegerValue(50),
                          MakeUintegerAccessor(&TcpYeah::m_zeta),
                          MakeUintegerChecker<uint32_t>())
            .AddAttribute("StcpAiFactor",
                          "STCP additive increase factor",
                          UintegerValue(100),
                          MakeUintegerAccessor(&TcpYeah::m_stcpAiFactor),
                          MakeUintegerChecker<uint32_t>());
    return tid;
}
 
TcpYeah::TcpYeah()
    : TcpNewReno(),
      m_alpha(80),
      m_gamma(1),
      m_delta(3),
      m_epsilon(1),
      m_phy(8),
      m_rho(16),
      m_zeta(50),
      m_stcpAiFactor(100),
      m_stcp(nullptr),
      m_baseRtt(Time::Max()),
      m_minRtt(Time::Max()),
      m_cntRtt(0),
      m_doingYeahNow(true),
      m_begSndNxt(0),
      m_lastQ(0),
      m_doingRenoNow(0),
      m_renoCount(2),
      m_fastCount(0)
{
    NS_LOG_FUNCTION(this);
    m_stcp = CreateObject<TcpScalable>();
    m_stcp->SetAttribute("AIFactor", static_cast<UintegerValue>(m_stcpAiFactor));
}
 
TcpYeah::TcpYeah(const TcpYeah& sock)
    : TcpNewReno(sock),
      m_alpha(sock.m_alpha),
      m_gamma(sock.m_gamma),
      m_delta(sock.m_delta),
      m_epsilon(sock.m_epsilon),
      m_phy(sock.m_phy),
      m_rho(sock.m_rho),
      m_zeta(sock.m_zeta),
      m_stcpAiFactor(sock.m_stcpAiFactor),
      m_baseRtt(sock.m_baseRtt),
      m_minRtt(sock.m_minRtt),
      m_cntRtt(sock.m_cntRtt),
      m_doingYeahNow(sock.m_doingYeahNow),
      m_begSndNxt(sock.m_begSndNxt),
      m_lastQ(sock.m_lastQ),
      m_doingRenoNow(sock.m_doingRenoNow),
      m_renoCount(sock.m_renoCount),
      m_fastCount(sock.m_fastCount)
{
    NS_LOG_FUNCTION(this);
    m_stcp = CopyObject(sock.m_stcp);
}
 
TcpYeah::~TcpYeah()
{
    NS_LOG_FUNCTION(this);
}
 
Ptr<TcpCongestionOps>
TcpYeah::Fork()
{
    return CopyObject<TcpYeah>(this);
}
 
void
TcpYeah::PktsAcked(Ptr<TcpSocketState> tcb, uint32_t segmentsAcked, const Time& rtt)
{
    NS_LOG_FUNCTION(this << tcb << segmentsAcked << rtt);
 
    if (rtt.IsZero())
    {
        return;
    }
 
    m_minRtt = std::min(m_minRtt, rtt);
    NS_LOG_DEBUG("Updated m_minRtt = " << m_minRtt.GetMilliSeconds() << " ms");
 
    m_baseRtt = std::min(m_baseRtt, rtt);
    NS_LOG_DEBUG("Updated m_baseRtt = " << m_baseRtt.GetMilliSeconds() << " ms");
 
    // Update RTT counter
    m_cntRtt++;
    NS_LOG_DEBUG("Updated m_cntRtt = " << m_cntRtt);
}
 
void
TcpYeah::EnableYeah(const SequenceNumber32& nextTxSequence)
{
    NS_LOG_FUNCTION(this << nextTxSequence);
 
    m_doingYeahNow = true;
    m_begSndNxt = nextTxSequence;
    m_cntRtt = 0;
    m_minRtt = Time::Max();
}
 
void
TcpYeah::DisableYeah()
{
    NS_LOG_FUNCTION(this);
 
    m_doingYeahNow = false;
}
 
void
TcpYeah::CongestionStateSet(Ptr<TcpSocketState> tcb, const TcpSocketState::TcpCongState_t newState)
{
    NS_LOG_FUNCTION(this << tcb << newState);
 
    if (newState == TcpSocketState::CA_OPEN)
    {
        EnableYeah(tcb->m_nextTxSequence);
    }
    else
    {
        DisableYeah();
    }
}
 
void
TcpYeah::IncreaseWindow(Ptr<TcpSocketState> tcb, uint32_t segmentsAcked)
{
    NS_LOG_FUNCTION(this << tcb << segmentsAcked);
 
    if (tcb->m_cWnd < tcb->m_ssThresh)
    {
        NS_LOG_LOGIC("In slow start, invoke NewReno slow start.");
        TcpNewReno::SlowStart(tcb, segmentsAcked);
    }
    else if (!m_doingRenoNow)
    { // Fast mode
        NS_LOG_LOGIC("In Fast mode, increment cwnd according to STCP rule.");
        m_stcp->IncreaseWindow(tcb, segmentsAcked);
        NS_LOG_INFO("In Fast mode, updated to cwnd " << tcb->m_cWnd << " ssthresh "
                                                     << tcb->m_ssThresh);
    }
    else
    { // Behave like NewReno
        TcpNewReno::CongestionAvoidance(tcb, segmentsAcked);
    }
 
    if (tcb->m_lastAckedSeq >= m_begSndNxt)
    { // A YeAH cycle has finished, we do YeAH cwnd adjustment every RTT.
 
        NS_LOG_LOGIC("A YeAH cycle has finished, check if enough RTT samples.");
        /*
         * We perform YeAH calculations only if we got enough RTT samples to
         * insure that at least 1 of those samples wasn't from a delayed ACK.
         */
        if (m_cntRtt > 2)
        {
            NS_LOG_LOGIC("Enough RTT samples to perform YeAH calculations");
            /*
             * We have enough RTT samples to perform YeAH algorithm.
             * Now we need to determine if we should operate in Fast or Slow mode,
             * and if we should execute the precautionary decongestion algorithm.
             */
 
            uint32_t segCwnd = tcb->GetCwndInSegments();
 
            // Calculate the extra number of packets in queue
            // Naming convention: minRtt is the minimum RTT of this round,
            // baseRtt is the minimum RTT of the entire transmission.
            NS_ASSERT(m_minRtt >= m_baseRtt);
            Time rttQueue = m_minRtt - m_baseRtt;
 
            // queue = rttQueue * bw = rttQueue * (cwnd/RTTmin)
            double bw = segCwnd / m_minRtt.GetSeconds();
            auto queue = static_cast<uint32_t>(bw * rttQueue.GetSeconds());
            NS_LOG_DEBUG("Queue backlog = " << queue << " given by cwnd = " << segCwnd
                                            << ", minRtt = " << m_minRtt.GetMilliSeconds()
                                            << " ms, baseRtt = " << m_baseRtt.GetMilliSeconds()
                                            << " ms");
 
            double L = rttQueue.GetSeconds() / m_baseRtt.GetSeconds();
            NS_LOG_DEBUG("Network congestion level = " << L);
 
            if (queue > m_alpha || L > (1 / m_phy))
            { // Slow mode
                if (queue > m_alpha && segCwnd > m_renoCount)
                { // Precautionary decongestion
                    NS_LOG_LOGIC("Execute the precautionary decongestion.");
                    uint32_t reduction = std::min(queue / m_gamma, segCwnd >> m_epsilon);
                    segCwnd -= reduction;
                    segCwnd = std::max(segCwnd, m_renoCount);
                    tcb->m_cWnd = segCwnd * tcb->m_segmentSize;
                    tcb->m_ssThresh = tcb->m_cWnd;
 
                    NS_LOG_INFO("In Slow mode, after precautionary decongestion, "
                                "updated to cwnd "
                                << tcb->m_cWnd << " ssthresh " << tcb->m_ssThresh);
                }
 
                if (m_renoCount <= 2)
                {
                    m_renoCount = std::max(segCwnd >> 1, static_cast<uint32_t>(2));
                }
                else
                {
                    m_renoCount++;
                }
 
                m_doingRenoNow = m_doingRenoNow + 1;
                NS_LOG_DEBUG("In Slow mode, updated to m_renoCount = "
                             << m_renoCount << " m_doingRenoNow = " << m_doingRenoNow);
            }
            else
            { // Fast mode
                m_fastCount++;
                if (m_fastCount > m_zeta)
                { // Reset renoCount
                    m_renoCount = 2;
                    m_fastCount = 0;
                }
                m_doingRenoNow = 0;
                NS_LOG_DEBUG("In Fast mode, updated to m_renoCount = "
                             << m_renoCount << " m_doingRenoNow = " << m_doingRenoNow);
            }
            m_lastQ = queue;
        }
 
        // Save the current right edge for next Yeah cycle
        m_begSndNxt = tcb->m_nextTxSequence;
 
        // Reset cntRtt & minRtt
        m_cntRtt = 0;
        m_minRtt = Time::Max();
    }
}
 
std::string
TcpYeah::GetName() const
{
    return "TcpYeah";
}
 
uint32_t
TcpYeah::GetSsThresh(Ptr<const TcpSocketState> tcb, uint32_t bytesInFlight)
{
    NS_LOG_FUNCTION(this << tcb << bytesInFlight);
    uint32_t reduction;
    uint32_t segBytesInFlight = bytesInFlight / tcb->m_segmentSize;
 
    if (m_doingRenoNow < m_rho)
    { // Not competing with Reno flows
        NS_LOG_LOGIC("Not competing with Reno flows upon loss");
        reduction = m_lastQ;
        reduction = std::max(reduction, segBytesInFlight >> m_delta);
        reduction = std::min(reduction, std::max(segBytesInFlight >> 1, 2U));
    }
    else
    { // Competing with Reno flows
        NS_LOG_LOGIC("Competing with Reno flows upon loss");
        reduction = std::max(segBytesInFlight >> 1, static_cast<uint32_t>(2));
    }
 
    NS_LOG_INFO("Reduction amount upon loss = " << reduction);
 
    m_fastCount = 0;
    m_renoCount = std::max(m_renoCount >> 1, static_cast<uint32_t>(2));
 
    // Allow, at least, 2 segment to go out
    uint32_t ret =
        std::max(bytesInFlight - (reduction * tcb->m_segmentSize), 2U * tcb->m_segmentSize);
    return ret;
}
 
} // namespace ns3