NrPdcpRxEntity.h Source File¶

Simu5G: NrPdcpRxEntity.h Source File
Simu5G
//
//                  Simu5G
//
// Copyright (C) 2019-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 _NRPDCPRXENTITY_H_
#define _NRPDCPRXENTITY_H_
 
#include "simu5g/stack/pdcp/LtePdcpRxEntity.h"
#include "simu5g/stack/dcX2Forwarder/DcX2Forwarder.h"
#include "simu5g/common/timer/TTimer.h"
 
namespace simu5g {
 
/*
 * Descriptor of the entity status
 * Taken from 3GPP TS 38.323
 */
struct PdcpRxWindowDesc
{
  public:
    unsigned int windowSize_ = 16;
    unsigned int rxNext_;
    unsigned int rxDeliv_;
    unsigned int rxReord_;
 
    void clear(unsigned int i = 0)
    {
        rxNext_ = i;
        rxDeliv_ = i;
        rxReord_ = i;
    }
 
    PdcpRxWindowDesc()
    {
        clear();
    }
 
};
 
inline std::ostream& operator<<(std::ostream& os, const PdcpRxWindowDesc& w)
{
    os << "windowSize=" << w.windowSize_ << " rxNext=" << w.rxNext_
       << " rxDeliv=" << w.rxDeliv_ << " rxReord=" << w.rxReord_;
    return os;
}
 
enum PdcpRxTimerType
{
    REORDERING_T = 0
};
class NrPdcpRxEntity : public LtePdcpRxEntity
{
  protected:
 
    // true on a multi-leg bearer: reorder the SN stream merged from several legs
    bool reorderingEnabled_ = false;
 
    // if true, deliver packets to the upper layer without reordering
    // NOTE: reordering can apply for Split Bearers only
    bool outOfOrderDelivery_;
 
    // The SDU enqueue buffer.
    cArray sduBuffer_;
 
    // For each SDU a received status variable is kept
    std::vector<bool> received_;
 
    // State variables
    PdcpRxWindowDesc rxWindowDesc_;
 
    // Timer to manage the reordering of the PDUs
    TTimer t_reordering_ = TTimer(this);
 
    // Timeout for the above timer
    double timeout_;
 
    // handler for PDCP SDU
    void handlePdcpSdu(Packet *pdcpSdu, unsigned int sequenceNumber) override;
 
  public:
 
 
    void initialize(int stage) override;
 
    void handleMessage(cMessage *msg) override;
 
    bool isEmpty() const override { return sduBuffer_.size() == 0; }
};
 
} //namespace
 
#endif
 