cpacketqueue.h

//==========================================================================
//  CPACKETQUEUE.H - part of
//                     OMNeT++/OMNEST
//            Discrete System Simulation in C++
//
//==========================================================================

/*--------------------------------------------------------------*
  Copyright (C) 1992-2017 Andras Varga
  Copyright (C) 2006-2017 OpenSim Ltd.

  This file is distributed WITHOUT ANY WARRANTY. See the file
  `license' for details on this and other legal matters.
*--------------------------------------------------------------*/

#ifndef __OMNETPP_CPACKETQUEUE_H
#define __OMNETPP_CPACKETQUEUE_H

#include "cqueue.h"
#include "cpacket.h"

namespace omnetpp {


class SIM_API cPacketQueue : public cQueue
{
  private:
    int64_t bitLength=0;

  private:
    void copy(const cPacketQueue& other);
    virtual void insert(cObject *obj) override;
    virtual void insertBefore(cObject *where, cObject *obj) override;
    virtual void insertAfter(cObject *where, cObject *obj) override;
    virtual cObject *remove(cObject *obj) override;

  protected:
    // internal
    void addLength(cPacket *pkt);
    cPacket *checkPacket(cObject *obj);

  public:
    cPacketQueue(const char *name=nullptr, Comparator *cmp=nullptr) : cQueue(name, cmp) {}

    cPacketQueue(const char *name, CompareFunc cmp) : cQueue(name, cmp) {}

    cPacketQueue(const cPacketQueue& queue);

    cPacketQueue& operator=(const cPacketQueue& queue);


    virtual cPacketQueue *dup() const override  {return new cPacketQueue(*this);}

    virtual std::string str() const override;

    virtual void parsimPack(cCommBuffer *buffer) const override;

    virtual void parsimUnpack(cCommBuffer *buffer) override;

    virtual void insert(cPacket *pkt);

    virtual void insertBefore(cPacket *where, cPacket *pkt);

    virtual void insertAfter(cPacket *where, cPacket *pkt);

    virtual cPacket *remove(cPacket *pkt);

    virtual cPacket *pop() override;

    virtual void clear() override;

    int64_t getBitLength() const  {return bitLength;}

    int64_t getByteLength() const  {return (bitLength+7)>>3;}

    virtual cPacket *front() const override  {return (cPacket *)cQueue::front();}

    virtual cPacket *back() const override  {return (cPacket *)cQueue::back();}

    virtual cPacket *get(int i) const override {return (cPacket *)cQueue::get(i);}
};

}  // namespace omnetpp


#endif