inet::sctp::SCTPSendStream Class Reference

#include <SCTPSendStream.h>

Inheritance diagram for inet::sctp::SCTPSendStream:

Public Member Functions
	SCTPSendStream (SCTPAssociation *assoc, const uint16 id)
	~SCTPSendStream ()
cPacketQueue *	getStreamQ () const
cPacketQueue *	getUnorderedStreamQ () const
uint32	getNextStreamSeqNum ()
uint32	getBytesInFlight () const
void	setNextStreamSeqNum (const uint16 num)
void	setBytesInFlight (const uint32 bytes)
bool	getFragInProgress () const
void	setFragInProgress (const bool frag)
uint16	getStreamId () const
void	setStreamId (const uint16 id)
void	deleteQueue ()

Protected Attributes
SCTPAssociation *	assoc
uint16	streamId
uint16	nextStreamSeqNum
uint32	bytesInFlight
bool	resetRequested
bool	fragInProgress
cPacketQueue *	streamQ
cPacketQueue *	uStreamQ

Constructor & Destructor Documentation

inet::sctp::SCTPSendStream::SCTPSendStream	(	SCTPAssociation *	assoc,
		const uint16	id
	)

{
    assoc = assoc_;
    streamId = id;
    nextStreamSeqNum = 0;
    bytesInFlight = 0;
    resetRequested = false;
    fragInProgress = false;

    char queueName[64];
    snprintf(queueName, sizeof(queueName), "OrderedSendQueue ID %d", id);
    streamQ = new cPacketQueue(queueName);
    snprintf(queueName, sizeof(queueName), "UnorderedSendQueue ID %d", id);
    uStreamQ = new cPacketQueue(queueName);
}

inet::sctp::SCTPSendStream::~SCTPSendStream

(

)

{
    deleteQueue();
}

Member Function Documentation

void inet::sctp::SCTPSendStream::deleteQueue

(

)

Referenced by ~SCTPSendStream().

{
    SCTPDataMsg *datMsg;
    SCTPSimpleMessage *smsg;
    int32 count = streamQ->getLength();
    while (!streamQ->isEmpty()) {
        datMsg = check_and_cast<SCTPDataMsg *>(streamQ->pop());
        smsg = check_and_cast<SCTPSimpleMessage *>(datMsg->decapsulate());
        delete smsg;
        delete datMsg;
        count--;
    }
    while (!uStreamQ->isEmpty()) {
        datMsg = check_and_cast<SCTPDataMsg *>(uStreamQ->pop());
        smsg = check_and_cast<SCTPSimpleMessage *>(datMsg->decapsulate());
        delete smsg;
        delete datMsg;
    }
    delete streamQ;
    delete uStreamQ;
}

uint32 inet::sctp::SCTPSendStream::getBytesInFlight ( ) const

inline

Referenced by inet::sctp::SCTPAssociation::decreaseOutstandingBytes(), and inet::sctp::SCTPAssociation::increaseOutstandingBytes().

{ return bytesInFlight; };

bool inet::sctp::SCTPSendStream::getFragInProgress ( ) const

inline

{ return fragInProgress; };

uint32 inet::sctp::SCTPSendStream::getNextStreamSeqNum

(

)

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

                                           {
    return nextStreamSeqNum;
};

uint16 inet::sctp::SCTPSendStream::getStreamId ( ) const

inline

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

{ return streamId; };

cPacketQueue* inet::sctp::SCTPSendStream::getStreamQ ( ) const

inline

Referenced by inet::sctp::SCTPAssociation::dequeueOutboundDataMsg(), inet::sctp::SCTPAssociation::fragmentOutboundDataMsgs(), inet::sctp::SCTPAssociation::generateSendQueueAbatedIndication(), inet::sctp::SCTPAssociation::nextChunkFitsIntoPacket(), inet::sctp::SCTPAssociation::pathStreamSchedulerMapToPath(), and inet::sctp::SCTPAssociation::process_SEND().

{ return streamQ; };

cPacketQueue* inet::sctp::SCTPSendStream::getUnorderedStreamQ ( ) const

inline

Referenced by inet::sctp::SCTPAssociation::dequeueOutboundDataMsg(), inet::sctp::SCTPAssociation::fragmentOutboundDataMsgs(), inet::sctp::SCTPAssociation::generateSendQueueAbatedIndication(), inet::sctp::SCTPAssociation::nextChunkFitsIntoPacket(), inet::sctp::SCTPAssociation::pathStreamSchedulerMapToPath(), and inet::sctp::SCTPAssociation::process_SEND().

{ return uStreamQ; };

void inet::sctp::SCTPSendStream::setBytesInFlight ( const uint32  bytes )

inline

Referenced by inet::sctp::SCTPAssociation::decreaseOutstandingBytes(), and inet::sctp::SCTPAssociation::increaseOutstandingBytes().

{ bytesInFlight = bytes; };

void inet::sctp::SCTPSendStream::setFragInProgress ( const bool  frag )

inline

{ fragInProgress = frag; };

void inet::sctp::SCTPSendStream::setNextStreamSeqNum

(

const uint16

num

)

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

                                                         {
    nextStreamSeqNum = num;
};

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

inline

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

{ streamId = id; };

Member Data Documentation

SCTPAssociation* inet::sctp::SCTPSendStream::assoc

protected

Referenced by SCTPSendStream().

uint32 inet::sctp::SCTPSendStream::bytesInFlight

protected

Referenced by SCTPSendStream().

bool inet::sctp::SCTPSendStream::fragInProgress

protected

Referenced by SCTPSendStream().

uint16 inet::sctp::SCTPSendStream::nextStreamSeqNum

protected

Referenced by getNextStreamSeqNum(), SCTPSendStream(), and setNextStreamSeqNum().

bool inet::sctp::SCTPSendStream::resetRequested

protected

Referenced by SCTPSendStream().

uint16 inet::sctp::SCTPSendStream::streamId

protected

Referenced by SCTPSendStream().

cPacketQueue* inet::sctp::SCTPSendStream::streamQ

protected

Referenced by deleteQueue(), and SCTPSendStream().

cPacketQueue* inet::sctp::SCTPSendStream::uStreamQ

protected

Referenced by deleteQueue(), and SCTPSendStream().

---

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

• SCTPSendStream.h
• SCTPSendStream.cc