TxControlPolicyLG.cc

Go to the documentation of this file.

// The MIT License (MIT)
//
// Copyright (c) 2014-2016 Brno University of Technology, PRISTINE project
//
// Permission is hereby granted, free of charge, to any person obtaining a copy
// of this software and associated documentation files (the "Software"), to deal
// in the Software without restriction, including without limitation the rights
// to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
// copies of the Software, and to permit persons to whom the Software is
// furnished to do so, subject to the following conditions:
//
// The above copyright notice and this permission notice shall be included in
// all copies or substantial portions of the Software.
//
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
// THE SOFTWARE.
#include "TxControlPolicyLG.h"

const char * Tx_LG_RATE = "Tx_LG_RATE";
const char * Tx_FLIGHT_SIZE = "Tx_LG_FLIGHT_SIZE";

Register_Class(TxControlPolicyLG);

TxControlPolicyLG::TxControlPolicyLG()
{
    rate = INITIAL_RATE;
    alpha = ALPHA;
    flightSize = 0;
}

TxControlPolicyLG::~TxControlPolicyLG()
{
}

void TxControlPolicyLG::initialize() {
    sigStatRate = registerSignal(Tx_LG_RATE);
    sigStatFlightSize = registerSignal(Tx_FLIGHT_SIZE);
}

void TxControlPolicyLG::updateRate(double load, double acked)
{
    rate = rate * alpha * (1 - rate - load) + rate;
    flightSize -= acked;

    emit(sigStatRate, rate);
    emit(sigStatFlightSize, flightSize);
}

double TxControlPolicyLG::getActualRate(DTPState* dtpState)
{
    return flightSize * SEGMENT_SIZE * 8 / dtpState->getRtt();//0.045; //dtpState->getRtt();   // segment size
}

double TxControlPolicyLG::getRate()
{
    return rate * BANDWIDTH;               // bandwidth
}

bool TxControlPolicyLG::run(DTPState* dtpState, DTCPState* dtcpState)
{
    Enter_Method("TxControlPolicyLG");

    if(getActualRate(dtpState) < getRate()) {
        double addRate = (getRate() - getActualRate(dtpState));
        sendCredit = addRate * dtpState->getRtt() / (SEGMENT_SIZE * 8);

        // -------------  adding packets to send queue
        std::vector<DataTransferPDU*>::iterator it;
        PDUQ_t* pduQ = NULL;
        int sentNo = 1;

        for(int i = 1; i <= 2; i++) {
            if (dtcpState->getClosedWinQueLen() > 0) {
                pduQ = dtcpState->getClosedWindowQ();
            } else
                pduQ = dtpState->getGeneratedPDUQ();

            for (it = pduQ->begin(); it != pduQ->end() && (*it)->getSeqNum() <= dtcpState->getSndRightWinEdge() && sentNo <= sendCredit; sentNo++) {
                dtpState->pushBackToPostablePDUQ((*it));
                flightSize++;
                emit(sigStatFlightSize, flightSize);
                it = pduQ->erase(it);
            }
        }
    }

    dtcpState->setClosedWindow(true);

    return false;
}