LteHarqProcessTx.h Source File¶

Simu5G: LteHarqProcessTx.h Source File
Simu5G
//
//                  Simu5G
//
// Copyright (C) 2012-2021 Giovanni Nardini, Giovanni Stea, Antonio Virdis et al. (University of Pisa)
// Copyright (C) 2022-2026 Giovanni Nardini, Giovanni Stea et al. (University of Pisa)
//
// This file is part of a software released under the license included in file
// "license.pdf". Please read LICENSE and README files before using it.
// The above files and the present reference are part of the software itself,
// and cannot be removed from it.
//
 
#ifndef _LTE_LTEHARQPROCESSTX_H_
#define _LTE_LTEHARQPROCESSTX_H_
 
#include "simu5g/stack/mac/buffer/harq/LteHarqUnitTx.h"
#include "simu5g/stack/mac/LteMacBase.h"
 
namespace simu5g {
 
using namespace omnetpp;
 
typedef std::vector<LteHarqUnitTx *> UnitVector;
typedef std::pair<unsigned char, TxHarqPduStatus> UnitStatus;
typedef std::vector<std::vector<UnitStatus>> BufferStatus;
 
class LteHarqProcessTx : noncopyable
{
  protected:
    opp_component_ptr<LteMacBase> macOwner_;
    UnitVector units_;
    unsigned int numProcesses_;
    unsigned char numHarqUnits_;
    unsigned char acid_;
    unsigned char numEmptyUnits_; //++ @ insert, -- @ unit reset (ack or fourth nack)
    unsigned int numSelected_; //++ @ markSelected and insert, -- @ extract/sendDown
    bool dropped_;
 
  public:
 
    /*
     * Default Constructor
     */
    LteHarqProcessTx() {}
    LteHarqProcessTx(Binder *binder, unsigned char acid, unsigned int numUnits, unsigned int numProcesses, LteMacBase *macOwner,
            LteMacBase *dstMac);
    virtual void insertPdu(inet::Packet *pdu, Codeword cw);
 
    virtual void markSelected(Codeword cw);
 
    virtual inet::Packet *extractPdu(Codeword cw);
 
    virtual bool pduFeedback(HarqAcknowledgment fb, Codeword cw);
 
    virtual bool selfNack(Codeword cw);
    std::vector<UnitStatus> getProcessStatus();
    bool hasReadyUnits();
    simtime_t getOldestUnitTxTime();
    virtual CwList readyUnitsIds();
    virtual CwList emptyUnitsIds();
    virtual CwList selectedUnitsIds();
    bool isEmpty();
 
    inet::Packet *getPdu(Codeword cw);
    long getPduId(Codeword cw);
 
    virtual void forceDropProcess();
 
    virtual bool forceDropUnit(Codeword cw);
 
    unsigned int getNumHarqUnits()
    {
        return numHarqUnits_;
    }
 
    TxHarqPduStatus getUnitStatus(Codeword cw);
 
    virtual void dropPdu(Codeword cw);
    bool isUnitEmpty(Codeword cw);
    bool isUnitReady(Codeword cw);
    unsigned char getTransmissions(Codeword cw);
    int64_t getPduLength(Codeword cw);
    simtime_t getTxTime(Codeword cw);
    bool isUnitMarked(Codeword cw);
    bool isDropped();
 
    virtual bool isHarqProcessActive();
 
    virtual ~LteHarqProcessTx();
};
 
} //namespace
 
#endif
 