inet::eigrp::EigrpRequestQueue Class Reference

Queue for storing requests for message sending. More...

#include <EigrpRtp.h>

Inheritance diagram for inet::eigrp::EigrpRequestQueue:

Public Member Functions
virtual	~EigrpRequestQueue ()
void	pushReq (EigrpMsgReq *req)
EigrpMsgReq *	findReqByIf (int ifaceId, bool sent=true)
	Get first rel/unrel message with given interface ID from request Queue. More...
EigrpMsgReq *	findReqByNeighbor (int neighId, bool sent=true)
EigrpMsgReq *	findUnrelReqByIf (int ifaceId)
	Get first unrel message with given interface ID from request Queue. More...
EigrpMsgReq *	findReqBySeq (uint32_t seqNumber)
EigrpMsgReq *	removeReq (EigrpMsgReq *msgReq)
void	removeAllMsgsToIf (int ifaceId)
	Delete all messages with given destination interface ID (fall of interface,...). More...
void	removeAllMsgsToNeigh (int ifaceId)
	Delete all messages with given destination neighbor ID (end of neighborship,...). More...
int	getNumReq () const
void	printInfo () const

Private Types
typedef std::list< EigrpMsgReq * >	MessageQueue

Private Attributes
MessageQueue	reqQueue
	Queue with requests waiting for sending (rel/unrel) More...

Detailed Description

Queue for storing requests for message sending.

Member Typedef Documentation

MessageQueue

typedef std::list<EigrpMsgReq *> inet::eigrp::EigrpRequestQueue::MessageQueue

private

Constructor & Destructor Documentation

~EigrpRequestQueue()

inet::eigrp::EigrpRequestQueue::~EigrpRequestQueue ( )

virtual

{
    MessageQueue::iterator it;
    for (it = reqQueue.begin(); it != reqQueue.end(); it++) {
        delete *it;
    }
}

Member Function Documentation

findReqByIf()

EigrpMsgReq * inet::eigrp::EigrpRequestQueue::findReqByIf	(	int	ifaceId,
		bool	sent = true
	)

Get first rel/unrel message with given interface ID from request Queue.

Parameters

sent	If false search only for messages waiting for send (not actually sent).

{
    MessageQueue::iterator it;
    for (it = reqQueue.begin(); it != reqQueue.end(); it++) {
        if ((*it)->getDestInterface() == ifaceId) {
            if (sent) // Get first message
                return *it;
            else if ((*it)->getNumOfAck() == 0)
                return *it;
        }
    }
    return nullptr;
}

findReqByNeighbor()

EigrpMsgReq * inet::eigrp::EigrpRequestQueue::findReqByNeighbor	(	int	neighId,
		bool	sent = true
	)

{
    MessageQueue::iterator it;
    for (it = reqQueue.begin(); it != reqQueue.end(); it++) {
        if ((*it)->getDestNeighbor() == neighId) {
            if (sent) // Get first message
                return *it;
            else if ((*it)->getNumOfAck() == 0)
                return *it;
        }
    }
    return nullptr;
}

findReqBySeq()

EigrpMsgReq * inet::eigrp::EigrpRequestQueue::findReqBySeq

(

uint32_t

seqNumber

)

{
    MessageQueue::iterator it;
    for (it = reqQueue.begin(); it != reqQueue.end(); it++) {
        if ((*it)->getSeqNumber() == seqNumber)
            return *it;
    }
    return nullptr;
}

findUnrelReqByIf()

EigrpMsgReq * inet::eigrp::EigrpRequestQueue::findUnrelReqByIf

(

int

ifaceId

)

Get first unrel message with given interface ID from request Queue.

{
    MessageQueue::iterator it;
    for (it = reqQueue.begin(); it != reqQueue.end(); it++) {
        if ((*it)->getDestInterface() == ifaceId && !(*it)->isMsgReliable()) {
            return *it;
        }
    }
    return nullptr;
}

getNumReq()

int inet::eigrp::EigrpRequestQueue::getNumReq ( ) const

inline

{ return reqQueue.size(); }

printInfo()

void inet::eigrp::EigrpRequestQueue::printInfo

(

)

const

{
    MessageQueue::const_iterator it;
    EigrpMsgReq *req;
 
    EV_DEBUG << "EIGRP RTP: content of request queue:" << endl;
    for (it = reqQueue.begin(); it != reqQueue.end(); it++) {
        req = *it;
 
        EV_DEBUG << "  Type:" << eigrpRtp::UserMsgs[req->getOpcode()];
        EV_DEBUG << "  destIF:" << req->getDestInterface();
        EV_DEBUG << "  destNeighbor:" << req->getDestNeighbor();
        EV_DEBUG << "  seqNumber:" << req->getSeqNumber();
        EV_DEBUG << "  ackNumber:" << req->getAckNumber();
        EV_DEBUG << "  numberOfAck:" << req->getNumOfAck() << endl;
    }
}

pushReq()

void inet::eigrp::EigrpRequestQueue::pushReq

(

EigrpMsgReq *

req

)

{
    reqQueue.push_back(req);
#ifdef EIGRP_RTP_DEBUG
//    printInfo();
#endif
}

removeAllMsgsToIf()

void inet::eigrp::EigrpRequestQueue::removeAllMsgsToIf

(

int

ifaceId

)

Delete all messages with given destination interface ID (fall of interface,...).

{
    MessageQueue::iterator it;
    for (it = reqQueue.begin(); it != reqQueue.end();) {
        if ((*it)->getDestInterface() == ifaceId) {
            delete *it;
            it = reqQueue.erase(it);
        }
        else
            ++it;
    }
}

removeAllMsgsToNeigh()

void inet::eigrp::EigrpRequestQueue::removeAllMsgsToNeigh

(

int

ifaceId

)

Delete all messages with given destination neighbor ID (end of neighborship,...).

{
    MessageQueue::iterator it;
    for (it = reqQueue.begin(); it != reqQueue.end();) {
        if ((*it)->getDestNeighbor() == neighborId) {
            delete *it;
            it = reqQueue.erase(it);
        }
        else
            ++it;
    }
}

removeReq()

EigrpMsgReq * inet::eigrp::EigrpRequestQueue::removeReq

(

EigrpMsgReq *

msgReq

)

{
    MessageQueue::iterator it;
    for (it = reqQueue.begin(); it != reqQueue.end(); it++) {
        if ((*it) == msgReq) {
            reqQueue.erase(it);
#ifdef EIGRP_RTP_DEBUG
//            printInfo();
#endif
            return msgReq;
        }
    }
    return nullptr;
}

Member Data Documentation

reqQueue

MessageQueue inet::eigrp::EigrpRequestQueue::reqQueue

private

Queue with requests waiting for sending (rel/unrel)

Referenced by findReqByIf(), findReqByNeighbor(), findReqBySeq(), findUnrelReqByIf(), getNumReq(), printInfo(), pushReq(), removeAllMsgsToIf(), removeAllMsgsToNeigh(), removeReq(), and ~EigrpRequestQueue().

---

The documentation for this class was generated from the following files:

• EigrpRtp.h
• EigrpRtp.cc