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