//
// This program is free software: you can redistribute it and/or modify
// it under the terms of the GNU Lesser General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version.
//
// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
// GNU Lesser General Public License for more details.
//
// You should have received a copy of the GNU Lesser General Public License
// along with this program. If not, see http://www.gnu.org/licenses/.
//
#ifndef __RINA_RMTQUEUE_H_
#define __RINA_RMTQUEUE_H_
#include <omnetpp.h>
#include <queue>
#include "PDU_m.h"
#include "RINASignals.h"
class RMTQueue : public cSimpleModule
{
protected:
virtual void initialize();
virtual void handleMessage(cMessage *msg);
public:
RMTQueue();
virtual ~RMTQueue();
enum queueType { INPUT = 'I', OUTPUT = 'O'};
RMTQueue::queueType getType();
void setType(RMTQueue::queueType type);
int getMaxLength();
void setMaxLength(int value);
int getThreshLength();
void setThreshLength(int value);
double getAverageLength() const;
void setAverageLength(double avr);
int getLength() const;
short getQosId();
double getWeight() const;
simtime_t getQTime() const;
int getAqmCounter() const;
void setAqmCounter(int val);
cGate* getOutputGate();
cGate* getInputGate();
cGate* getRmtAccessGate();
void setRmtAccessGate(cGate* gate);
void releasePDU();
void dropLast();
void markCongestionOnLast();
void redrawGUI();
std::string info() const;
private:
std::deque<cMessage*> queue;
int maxQLength;
int thresholdQLength;
simtime_t qTime;
queueType type;
cGate* rmtAccessGate;
cGate* outputGate;
cGate* inputGate;
simsignal_t sigRMTPDURcvd;
void enqueuePDU(cMessage* pdu);
};
std::ostream& operator<< (std::ostream& os, const RMTQueue& cte);
#endif