inet::sctp::SCTPReceiveStream Class Reference

#include <SCTPReceiveStream.h>

Inheritance diagram for inet::sctp::SCTPReceiveStream:

Public Member Functions
uint32	enqueueNewDataChunk (SCTPDataVariables *dchunk)
	SCTPReceiveStream (SCTPAssociation *assoc)
	Ctor. More...
int32	getExpectedStreamSeqNum ()
void	setExpectedStreamSeqNum (const int32 num)
	~SCTPReceiveStream ()
	Virtual dtor. More...
SCTPQueue *	getDeliveryQ () const
SCTPQueue *	getOrderedQ () const
SCTPQueue *	getUnorderedQ () const
int32	getStreamId () const
void	setStreamId (const uint16 id)

Protected Member Functions
uint32	reassemble (SCTPQueue *queue, uint32 tsn)

Protected Attributes
SCTPAssociation *	assoc
uint16	streamId
int32	expectedStreamSeqNum
SCTPQueue *	deliveryQ
SCTPQueue *	orderedQ
SCTPQueue *	unorderedQ

Constructor & Destructor Documentation

inet::sctp::SCTPReceiveStream::SCTPReceiveStream

(

SCTPAssociation *

assoc

)

Ctor.

{
    streamId = 0;
    expectedStreamSeqNum = 0;
    deliveryQ = new SCTPQueue();
    orderedQ = new SCTPQueue();
    unorderedQ = new SCTPQueue();
    assoc = assoc_;
}

inet::sctp::SCTPReceiveStream::~SCTPReceiveStream

(

)

Virtual dtor.

{
    delete deliveryQ;
    delete orderedQ;
    delete unorderedQ;
}

Member Function Documentation

uint32 inet::sctp::SCTPReceiveStream::enqueueNewDataChunk

(

SCTPDataVariables *

dchunk

)

{
    uint32 delivery = 0;    //0:orderedQ=false && deliveryQ=false; 1:orderedQ=true && deliveryQ=false; 2:oderedQ=true && deliveryQ=true; 3:fragment

    SCTPDataVariables *chunk;
    /* Enqueueing NEW data chunk. Append it to the respective queue */

    // ====== Unordered delivery =============================================
    if (!dchunk->ordered) {
        if (dchunk->bbit && dchunk->ebit) {
            /* put message into deliveryQ */
            if (deliveryQ->checkAndInsertChunk(dchunk->tsn, dchunk)) {
                delivery = 2;
            }
        } else {
            if (unorderedQ->checkAndInsertChunk(dchunk->tsn, dchunk)) {
                delivery = 3;
            }

            /* try to reassemble here */
            uint32 reassembled = reassemble(unorderedQ, dchunk->tsn);

            if ((unorderedQ->getChunk(reassembled))->bbit && (unorderedQ->getChunk(reassembled))->bbit) {
                /* put message into deliveryQ */
                if (deliveryQ->checkAndInsertChunk(reassembled, unorderedQ->getAndExtractChunk(reassembled))) {
                    delivery = 2;
                }
            }
        }
    }
    // ====== Ordered delivery ===============================================
    else if (dchunk->ordered) {
        /* put message into orderedQ */
        if (orderedQ->checkAndInsertChunk(dchunk->tsn, dchunk))
            delivery = 1;

        if (!dchunk->bbit || !dchunk->ebit) {
            delivery = 3;
            /* try to reassemble */
            reassemble(orderedQ, dchunk->tsn);
        }

        if (orderedQ->getQueueSize() > 0) {
            /* dequeue first from orderedQ */
            chunk = orderedQ->dequeueChunkBySSN(expectedStreamSeqNum);
            if (chunk) {
                if (deliveryQ->checkAndInsertChunk(chunk->tsn, chunk)) {
                    ++expectedStreamSeqNum;
                    if (expectedStreamSeqNum > 65535)
                        expectedStreamSeqNum = 0;
                    delivery = 2;
                }
            }
        }
    }

    return delivery;
}

SCTPQueue* inet::sctp::SCTPReceiveStream::getDeliveryQ ( ) const

inline

Referenced by inet::sctp::SCTPAssociation::calculateRcvBuffer(), inet::sctp::SCTPAssociation::makeRoomForTsn(), inet::sctp::SCTPAssociation::pushUlp(), and inet::sctp::SCTPAssociation::putInDeliveryQ().

{ return deliveryQ; };

int32 inet::sctp::SCTPReceiveStream::getExpectedStreamSeqNum

(

)

Referenced by inet::sctp::SCTPAssociation::makeRoomForTsn(), inet::sctp::SCTPAssociation::processForwardTsnArrived(), and inet::sctp::SCTPAssociation::putInDeliveryQ().

                                                 {
    return expectedStreamSeqNum;
}

SCTPQueue* inet::sctp::SCTPReceiveStream::getOrderedQ ( ) const

inline

Referenced by inet::sctp::SCTPAssociation::calculateRcvBuffer(), inet::sctp::SCTPAssociation::makeRoomForTsn(), inet::sctp::SCTPAssociation::processForwardTsnArrived(), and inet::sctp::SCTPAssociation::putInDeliveryQ().

{ return orderedQ; };

int32 inet::sctp::SCTPReceiveStream::getStreamId ( ) const

inline

Referenced by inet::sctp::SCTPAssociation::makeRoomForTsn().

{ return streamId; };

SCTPQueue* inet::sctp::SCTPReceiveStream::getUnorderedQ ( ) const

inline

Referenced by inet::sctp::SCTPAssociation::calculateRcvBuffer(), and inet::sctp::SCTPAssociation::makeRoomForTsn().

{ return unorderedQ; };

uint32 inet::sctp::SCTPReceiveStream::reassemble ( SCTPQueue *  queue, uint32  tsn  )

protected

Referenced by enqueueNewDataChunk().

{
    uint32 begintsn = tsn, endtsn = 0;

    EV_INFO << "Trying to reassemble message..." << endl;

    /* test if we have all fragments down to the first */
    while (queue->getChunk(begintsn) && !(queue->getChunk(begintsn))->bbit)
        begintsn--;

    if (queue->getChunk(begintsn)) {
        endtsn = begintsn;

        /* test if we have all fragments up to the end */
        while (queue->getChunk(endtsn) && !(queue->getChunk(endtsn))->ebit)
            endtsn++;

        if (queue->getChunk(endtsn)) {
            EV_INFO << "All fragments found, now reassembling..." << endl;

            SCTPDataVariables *firstVar = queue->getChunk(begintsn), *processVar;
            SCTPSimpleMessage *firstSimple = check_and_cast<SCTPSimpleMessage *>(firstVar->userData);

            EV_INFO << "First fragment has " << firstVar->len / 8 << " bytes." << endl;

            while (++begintsn <= endtsn) {
                processVar = queue->getAndExtractChunk(begintsn);
                SCTPSimpleMessage *processSimple = check_and_cast<SCTPSimpleMessage *>(processVar->userData);

                EV_INFO << "Adding fragment with " << processVar->len / 8 << " bytes." << endl;

                if ((firstSimple->getDataArraySize() > 0) && (processSimple->getDataArraySize() > 0)) {
                    firstSimple->setDataArraySize(firstSimple->getDataArraySize() + processSimple->getDataArraySize());
                    firstSimple->setDataLen(firstSimple->getDataLen() + processSimple->getDataLen());
                    firstSimple->setByteLength(firstSimple->getByteLength() + processSimple->getByteLength());
                    /* copy data */
                    for (uint32 i = 0; i < (processVar->len / 8); i++)
                        firstSimple->setData(i + (firstVar->len / 8), processSimple->getData(i));
                }

                firstVar->len += processVar->len;

                delete processVar->userData;
                delete processVar;
            }

            firstVar->ebit = 1;

            EV_INFO << "Reassembly done. Length=" << firstVar->len << "\n";
            return firstVar->tsn;
        }
    }
    return tsn;
}

void inet::sctp::SCTPReceiveStream::setExpectedStreamSeqNum

(

const int32

num

)

Referenced by inet::sctp::SCTPAssociation::makeRoomForTsn(), inet::sctp::SCTPAssociation::processForwardTsnArrived(), and inet::sctp::SCTPAssociation::putInDeliveryQ().

                                                            {
    expectedStreamSeqNum = seqNum;
}

void inet::sctp::SCTPReceiveStream::setStreamId ( const uint16  id )

inline

Referenced by inet::sctp::SCTPAssociation::addInStreams(), and inet::sctp::SCTPAssociation::initStreams().

{ streamId = id; };

Member Data Documentation

SCTPAssociation* inet::sctp::SCTPReceiveStream::assoc

protected

Referenced by SCTPReceiveStream().

SCTPQueue* inet::sctp::SCTPReceiveStream::deliveryQ

protected

Referenced by enqueueNewDataChunk(), SCTPReceiveStream(), and ~SCTPReceiveStream().

int32 inet::sctp::SCTPReceiveStream::expectedStreamSeqNum

protected

Referenced by enqueueNewDataChunk(), getExpectedStreamSeqNum(), SCTPReceiveStream(), and setExpectedStreamSeqNum().

SCTPQueue* inet::sctp::SCTPReceiveStream::orderedQ

protected

Referenced by enqueueNewDataChunk(), SCTPReceiveStream(), and ~SCTPReceiveStream().

uint16 inet::sctp::SCTPReceiveStream::streamId

protected

Referenced by SCTPReceiveStream().

SCTPQueue* inet::sctp::SCTPReceiveStream::unorderedQ

protected

Referenced by enqueueNewDataChunk(), SCTPReceiveStream(), and ~SCTPReceiveStream().

---

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

• SCTPReceiveStream.h
• SCTPReceiveStream.cc