inet::sctp::SCTP Class Reference

Implements the SCTP protocol. More...

#include <SCTP.h>

Inheritance diagram for inet::sctp::SCTP:

Classes
struct	AppAssocKey
struct	AssocStat
struct	SockPair
struct	VTagPair

Public Types
typedef std::map< int32, AssocStat >	AssocStatMap
typedef std::map< int32, VTagPair >	SctpVTagMap
typedef std::map< AppAssocKey, SCTPAssociation * >	SctpAppAssocMap
typedef std::map< SockPair, SCTPAssociation * >	SctpAssocMap

Public Member Functions
void	printInfoAssocMap ()
void	printVTagMap ()
void	removeAssociation (SCTPAssociation *assoc)
virtual	~SCTP ()
virtual void	initialize (int stage) override
virtual int	numInitStages () const override
virtual void	handleMessage (cMessage *msg) override
virtual void	finish () override
virtual void	send_to_ip (SCTPMessage *msg)
AssocStat *	getAssocStat (uint32 assocId)
void	updateSockPair (SCTPAssociation *assoc, L3Address localAddr, L3Address remoteAddr, int32 localPort, int32 remotePort)
	To be called from SCTPAssociation when socket pair changes. More...
void	addLocalAddress (SCTPAssociation *assoc, L3Address address)
void	addLocalAddressToAllRemoteAddresses (SCTPAssociation *assoc, L3Address address, std::vector< L3Address > remAddresses)
bool	addRemoteAddress (SCTPAssociation *assoc, L3Address localAddress, L3Address remoteAddress)
void	removeLocalAddressFromAllRemoteAddresses (SCTPAssociation *assoc, L3Address address, std::vector< L3Address > remAddresses)
void	removeRemoteAddressFromAllAssociations (SCTPAssociation *assoc, L3Address address, std::vector< L3Address > locAddresses)
void	addForkedAssociation (SCTPAssociation *assoc, SCTPAssociation *newAssoc, L3Address localAddr, L3Address remoteAddr, int32 localPort, int32 remotePort)
	Update assocs socket pair, and register newAssoc (which'll keep LISTENing). More...
uint16	getEphemeralPort ()
	To be called from SCTPAssociation: reserves an ephemeral port for the connection. More...
SCTPAssociation *	getAssoc (int32 assocId)
SCTPAssociation *	findAssocWithVTag (uint32 peerVTag, uint32 remotePort, uint32 localPort)
SCTPAssociation *	findAssocForInitAck (SCTPInitAckChunk *initack, L3Address srcAddr, L3Address destAddr, uint32 srcPort, uint32 destPort, bool findListen)
SctpVTagMap	getVTagMap ()
void	bindPortForUDP ()
SocketOptions *	collectSocketOptions ()
	Getter and Setter for the socket options. More...
void	setSocketOptions (SocketOptions *options)
int	getMaxInitRetrans ()
int	getMaxInitRetransTimeout ()
double	getRtoInitial ()
double	getRtoMin ()
double	getRtoMax ()
int	getSackFrequency ()
double	getSackPeriod ()
int	getMaxBurst ()
int	getFragPoint ()
int	getNagle ()
bool	getEnableHeartbeats ()
int	getPathMaxRetrans ()
int	getAssocMaxRtx ()
double	getHbInterval ()
void	setRtoInitial (double rtoInitial)
void	setRtoMin (double rtoMin)
void	setRtoMax (double rtoMax)

Public Attributes
AssocStatMap	assocStatMap
SctpVTagMap	sctpVTagMap
SctpAppAssocMap	sctpAppAssocMap
SctpAssocMap	sctpAssocMap
std::list< SCTPAssociation * >	assocList
UDPSocket	udpSocket
SocketOptions *	socketOptions
simtime_t	testTimeout
uint32	numGapReports
uint32	numPacketsReceived
uint32	numPacketsDropped
bool	auth
bool	addIP
bool	pktdrop
bool	sackNow
uint64	numPktDropReports

Protected Member Functions
SCTPAssociation *	findAssocForMessage (L3Address srcAddr, L3Address destAddr, uint32 srcPort, uint32 destPort, bool findListen)
SCTPAssociation *	findAssocForApp (int32 appGateIndex, int32 assocId)
int32	findAssocForFd (int32 fd)
void	sendAbortFromMain (SCTPMessage *sctpmsg, L3Address fromAddr, L3Address toAddr)
void	sendShutdownCompleteFromMain (SCTPMessage *sctpmsg, L3Address fromAddr, L3Address toAddr)
virtual void	refreshDisplay () const override

Protected Attributes
IRoutingTable *	rt
IInterfaceTable *	ift
int32	sizeAssocMap
uint16	nextEphemeralPort

Detailed Description

Implements the SCTP protocol.

This section describes the internal architecture of the SCTP model.

You may want to check the SCTPSocket class which makes it easier to use SCTP from applications.

The SCTP protocol implementation is composed of several classes (discussion follows below):

• SCTP: the module class
• SCTPAssociation: manages an association
• SCTPSendQueue, SCTPReceiveQueue: abstract base classes for various types of send and receive queues
• SCTPAlgorithm: abstract base class for SCTP algorithms

SCTP subclassed from cSimpleModule. It manages socketpair-to-association mapping, and dispatches segments and user commands to the appropriate SCTPAssociation object.

SCTPAssociation manages the association, with the help of other objects. SCTPAssociation itself implements the basic SCTP "machinery": takes care of the state machine, stores the state variables (TCB), sends/receives etc.

SCTPAssociation internally relies on 3 objects. The first two are subclassed from SCTPSendQueue and SCTPReceiveQueue. They manage the actual data stream, so SCTPAssociation itself only works with sequence number variables. This makes it possible to easily accomodate need for various types of simulated data transfer: real byte stream, "virtual" bytes (byte counts only), and sequence of cMessage objects (where every message object is mapped to a SCTP sequence number range).

Currently implemented send queue and receive queue classes are SCTPVirtualDataSendQueue and SCTPVirtualDataRcvQueue which implement queues with "virtual" bytes (byte counts only).

The third object is subclassed from SCTPAlgorithm. Control over retransmissions, congestion control and ACK sending are "outsourced" from SCTPAssociation into SCTPAlgorithm: delayed acks, slow start, fast rexmit, etc. are all implemented in SCTPAlgorithm subclasses.

The concrete SCTPAlgorithm class to use can be chosen per association (in OPEN) or in a module parameter.

Member Typedef Documentation

typedef std::map<int32, AssocStat> inet::sctp::SCTP::AssocStatMap

typedef std::map<AppAssocKey, SCTPAssociation *> inet::sctp::SCTP::SctpAppAssocMap

typedef std::map<SockPair, SCTPAssociation *> inet::sctp::SCTP::SctpAssocMap

typedef std::map<int32, VTagPair> inet::sctp::SCTP::SctpVTagMap

Constructor & Destructor Documentation

inet::sctp::SCTP::~SCTP ( )

virtual

{
    EV_DEBUG << "delete SCTPMain\n";
    if (!(sctpAppAssocMap.empty())) {
        EV_DEBUG << "clear appConnMap ptr=" << &sctpAppAssocMap << "\n";
        sctpAppAssocMap.clear();
    }
    if (!(assocStatMap.empty())) {
        EV_DEBUG << "clear assocStatMap ptr=" << &assocStatMap << "\n";
        assocStatMap.clear();
    }
    if (!(sctpVTagMap.empty())) {
        sctpVTagMap.clear();
    }
    EV_DEBUG << "after clearing maps\n";
}

Member Function Documentation

void inet::sctp::SCTP::addForkedAssociation	(	SCTPAssociation *	assoc,
		SCTPAssociation *	newAssoc,
		L3Address	localAddr,
		L3Address	remoteAddr,
		int32	localPort,
		int32	remotePort
	)

Update assocs socket pair, and register newAssoc (which'll keep LISTENing).

Also, assoc will get a new assocId (and newAssoc will live on with its old assocId).

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

{
    SockPair keyAssoc;
    bool found = false;

    EV_INFO << "addForkedConnection assocId=" << assoc->assocId << "    newId=" << newAssoc->assocId << "\n";

    for (auto & elem : sctpAssocMap) {
        if (assoc->assocId == elem.second->assocId) {
            keyAssoc = elem.first;
            found = true;
            break;
        }
    }

    ASSERT(found == true);

    // update assoc's socket pair, and register newAssoc (which'll keep LISTENing)
    updateSockPair(assoc, localAddr, remoteAddr, localPort, remotePort);
    updateSockPair(newAssoc, keyAssoc.localAddr, keyAssoc.remoteAddr, keyAssoc.localPort, keyAssoc.remotePort);

    // assoc will get a new assocId...
    AppAssocKey key;
    key.appGateIndex = assoc->appGateIndex;
    key.assocId = assoc->assocId;
    sctpAppAssocMap.erase(key);
    key.assocId = assoc->assocId = SCTPSocket::getNewAssocId();
    sctpAppAssocMap[key] = assoc;

    // ...and newAssoc will live on with the old assocId
    key.appGateIndex = newAssoc->appGateIndex;
    key.assocId = newAssoc->assocId;
    sctpAppAssocMap[key] = newAssoc;
    sizeAssocMap = sctpAssocMap.size();
    printInfoAssocMap();
}

void inet::sctp::SCTP::addLocalAddress	(	SCTPAssociation *	assoc,
		L3Address	address
	)

Referenced by inet::sctp::SCTPAssociation::processInitArrived(), and inet::sctp::SCTPAssociation::sendInit().

{
    SockPair key;

    key.localAddr = assoc->localAddr;
    key.remoteAddr = assoc->remoteAddr;
    key.localPort = assoc->localPort;
    key.remotePort = assoc->remotePort;

    auto i = sctpAssocMap.find(key);
    if (i != sctpAssocMap.end()) {
        ASSERT(i->second == assoc);
        if (key.localAddr.isUnspecified()) {
            sctpAssocMap.erase(i);
            sizeAssocMap--;
        }
    }
    else
        EV_INFO << "no actual sockPair found\n";
    key.localAddr = address;
    sctpAssocMap[key] = assoc;
    sizeAssocMap = sctpAssocMap.size();
    EV_INFO << "addLocalAddress " << address << " number of connections now=" << sizeAssocMap << "\n";

    printInfoAssocMap();
}

void inet::sctp::SCTP::addLocalAddressToAllRemoteAddresses	(	SCTPAssociation *	assoc,
		L3Address	address,
		std::vector< L3Address >	remAddresses
	)

Referenced by inet::sctp::SCTPAssociation::processAsconfAckArrived(), and inet::sctp::SCTPAssociation::sendAsconf().

{
    SockPair key;

    for (auto & remAddresse : remAddresses) {
        //EV_DEBUG<<"remote address="<<(*i)<<"\n";
        key.localAddr = assoc->localAddr;
        key.remoteAddr = (remAddresse);
        key.localPort = assoc->localPort;
        key.remotePort = assoc->remotePort;

        auto j = sctpAssocMap.find(key);
        if (j != sctpAssocMap.end()) {
            ASSERT(j->second == assoc);
            if (key.localAddr.isUnspecified()) {
                sctpAssocMap.erase(j);
                sizeAssocMap--;
            }
        }
        else
            EV_INFO << "no actual sockPair found\n";
        key.localAddr = address;
        sctpAssocMap[key] = assoc;

        sizeAssocMap++;
        EV_DEBUG << "number of connections=" << sctpAssocMap.size() << "\n";

        printInfoAssocMap();
    }
}

bool inet::sctp::SCTP::addRemoteAddress	(	SCTPAssociation *	assoc,
		L3Address	localAddress,
		L3Address	remoteAddress
	)

Referenced by inet::sctp::SCTPAssociation::processAsconfArrived(), inet::sctp::SCTPAssociation::processInitAckArrived(), and inet::sctp::SCTPAssociation::processInitArrived().

{
    EV_INFO << "Add remote Address: " << remoteAddress << " to local Address " << localAddress << "\n";

    SockPair key;
    key.localAddr = localAddress;
    key.remoteAddr = remoteAddress;
    key.localPort = assoc->localPort;
    key.remotePort = assoc->remotePort;

    auto i = sctpAssocMap.find(key);
    if (i != sctpAssocMap.end()) {
        ASSERT(i->second == assoc);
        return false;
    }
    else {
        sctpAssocMap[key] = assoc;
        sizeAssocMap++;
    }

    printInfoAssocMap();
    return true;
}

void inet::sctp::SCTP::bindPortForUDP

(

)

Referenced by initialize().

{
    EV_INFO << "Binding to UDP port " << SCTP_UDP_PORT << endl;

    udpSocket.setOutputGate(gate("to_ip"));
    udpSocket.bind(SCTP_UDP_PORT);
}

SocketOptions * inet::sctp::SCTP::collectSocketOptions

(

)

Getter and Setter for the socket options.

Referenced by handleMessage().

{
    SocketOptions* sockOptions = new SocketOptions();
    sockOptions->maxInitRetrans = (int) par("maxInitRetrans");
    sockOptions->maxInitRetransTimeout = SCTP_TIMEOUT_INIT_REXMIT_MAX;
    sockOptions->rtoInitial = (int) par("rtoInitial");
    sockOptions->rtoMin = (int) par("rtoMin");
    sockOptions->rtoMax = (int) par("rtoMax");
    sockOptions->sackFrequency = (int) par("sackFrequency");
    sockOptions->sackPeriod = (double) par("sackPeriod");
    sockOptions->maxBurst = (int) par("maxBurst");
    sockOptions->fragPoint = (int) par("fragPoint");
    sockOptions->nagle = ((bool) par("nagleEnabled")) ? 1 : 0;
    sockOptions->enableHeartbeats = (bool) par("enableHeartbeats");
    sockOptions->pathMaxRetrans = (int) par("pathMaxRetrans");
    sockOptions->hbInterval = (double) par("hbInterval");
    sockOptions->assocMaxRtx = (int) par("assocMaxRetrans");
    return sockOptions;
}

SCTPAssociation * inet::sctp::SCTP::findAssocForApp ( int32  appGateIndex, int32  assocId  )

protected

Referenced by handleMessage().

{
    AppAssocKey key;
    key.appGateIndex = appGateIndex;
    key.assocId = assocId;
    EV_INFO << "findAssoc for appGateIndex " << appGateIndex << " and assoc " << assocId << "\n";
    auto i = sctpAppAssocMap.find(key);
    return (i == sctpAppAssocMap.end()) ? nullptr : i->second;
}

int32 inet::sctp::SCTP::findAssocForFd ( int32  fd )

protected

Referenced by handleMessage().

{
    SCTPAssociation *assoc = NULL;
    for (auto & elem : sctpAppAssocMap) {
        assoc = elem.second;
        if (assoc->fd == fd)
            return assoc->assocId;
    }
    return -1;
}

SCTPAssociation * inet::sctp::SCTP::findAssocForInitAck	(	SCTPInitAckChunk *	initack,
		L3Address	srcAddr,
		L3Address	destAddr,
		uint32	srcPort,
		uint32	destPort,
		bool	findListen
	)

Referenced by handleMessage().

{
    SCTPAssociation *assoc = nullptr;
    int numberAddresses = initAckChunk->getAddressesArraySize();
    for (int32 j = 0; j < numberAddresses; j++) {
        if (initAckChunk->getAddresses(j).getType() == L3Address::IPv6)
            continue;
        assoc = findAssocForMessage(initAckChunk->getAddresses(j), destAddr, srcPort, destPort, findListen);
        if (assoc) {
            break;
        }
    }
    return assoc;
}

SCTPAssociation * inet::sctp::SCTP::findAssocForMessage ( L3Address  srcAddr, L3Address  destAddr, uint32  srcPort, uint32  destPort, bool  findListen  )

protected

Referenced by findAssocForInitAck(), and handleMessage().

{
    SockPair key;

    key.localAddr = destAddr;
    key.remoteAddr = srcAddr;
    key.localPort = destPort;
    key.remotePort = srcPort;
    SockPair save = key;
    EV_DEBUG << "findAssocForMessage: srcAddr=" << destAddr << " destAddr=" << srcAddr << " srcPort=" << destPort << "  destPort=" << srcPort << "\n";
    printInfoAssocMap();

    // try with fully qualified SockPair
    auto i = sctpAssocMap.find(key);
    if (i != sctpAssocMap.end())
        return i->second;

    // try with localAddr missing (only localPort specified in passive/active open)
    key.localAddr = L3Address();

    i = sctpAssocMap.find(key);
    if (i != sctpAssocMap.end()) {
        // try with localAddr missing (only localPort specified in passive/active open)
        return i->second;
    }

    if (findListen == true) {
        // try fully qualified local socket + blank remote socket (for incoming SYN)
        key = save;
        key.remoteAddr = L3Address();
        key.remotePort = 0;
        i = sctpAssocMap.find(key);
        if (i != sctpAssocMap.end()) {
            // try fully qualified local socket + blank remote socket
            return i->second;
        }

        // try with blank remote socket, and localAddr missing (for incoming SYN)
        key.localAddr = L3Address();
        i = sctpAssocMap.find(key);
        if (i != sctpAssocMap.end()) {
            // try with blank remote socket, and localAddr missing
            return i->second;
        }
    }
    // given up

    EV_INFO << "giving up on trying to find assoc for localAddr=" << srcAddr << " remoteAddr=" << destAddr << " localPort=" << srcPort << " remotePort=" << destPort << "\n";
    return nullptr;
}

SCTPAssociation * inet::sctp::SCTP::findAssocWithVTag	(	uint32	peerVTag,
		uint32	remotePort,
		uint32	localPort
	)

Referenced by handleMessage().

{
    printVTagMap();
    EV_DEBUG << "findAssocWithVTag: peerVTag=" << peerVTag << " srcPort=" << remotePort << "    destPort=" << localPort << "\n";
    printInfoAssocMap();

    // try with fully qualified SockPair
    for (auto & elem : sctpVTagMap) {
        if ((elem.second.peerVTag == peerVTag && elem.second.localPort == localPort
             && elem.second.remotePort == remotePort)
            || (elem.second.localVTag == peerVTag && elem.second.localPort == localPort
                && elem.second.remotePort == remotePort))
            return getAssoc(elem.first);
    }
    return nullptr;
}

void inet::sctp::SCTP::finish ( )

overridevirtual

{
    auto assocMapIterator = sctpAssocMap.begin();
    while (assocMapIterator != sctpAssocMap.end()) {
        removeAssociation(assocMapIterator->second);
        assocMapIterator = sctpAssocMap.begin();
    }
    EV_INFO << getFullPath() << ": finishing SCTP with "
            << sctpAssocMap.size() << " connections open." << endl;

    for (AssocStatMap::const_iterator iterator = assocStatMap.begin();
         iterator != assocStatMap.end(); iterator++)
    {
        const SCTP::AssocStat& assoc = iterator->second;

        EV_DETAIL << "Association " << assoc.assocId << ": started at " << assoc.start
                  << " and finished at " << assoc.stop << " --> lifetime: " << assoc.lifeTime << endl;
        EV_DETAIL << "Association " << assoc.assocId << ": sent bytes=" << assoc.sentBytes
                  << ", acked bytes=" << assoc.ackedBytes << ", throughput=" << assoc.throughput << " bit/s" << endl;
        EV_DETAIL << "Association " << assoc.assocId << ": transmitted Bytes="
                  << assoc.transmittedBytes << ", retransmitted Bytes=" << assoc.transmittedBytes - assoc.ackedBytes << endl;
        EV_DETAIL << "Association " << assoc.assocId << ": number of Fast RTX="
                  << assoc.numFastRtx << ", number of Timer-Based RTX=" << assoc.numT3Rtx
                  << ", path failures=" << assoc.numPathFailures << ", ForwardTsns=" << assoc.numForwardTsn << endl;
        EV_DETAIL << "AllMessages=" << numPacketsReceived << " BadMessages=" << numPacketsDropped << endl;

        recordScalar("Association Lifetime", assoc.lifeTime);
        recordScalar("Acked Bytes", assoc.ackedBytes);
        recordScalar("Throughput [bit/s]", assoc.throughput);
        recordScalar("Transmitted Bytes", assoc.transmittedBytes);
        recordScalar("Fast RTX", assoc.numFastRtx);
        recordScalar("Timer-Based RTX", assoc.numT3Rtx);
        recordScalar("Duplicate Acks", assoc.numDups);
        recordScalar("Packets Received", numPacketsReceived);
        recordScalar("Packets Dropped", numPacketsDropped);
        recordScalar("Sum of R Gap Ranges", assoc.sumRGapRanges);
        recordScalar("Sum of NR Gap Ranges", assoc.sumNRGapRanges);
        recordScalar("Overfull SACKs", assoc.numOverfullSACKs);
        recordScalar("Drops Because New TSN Greater Than Highest TSN", assoc.numDropsBecauseNewTSNGreaterThanHighestTSN);
        recordScalar("Drops Because No Room In Buffer", assoc.numDropsBecauseNoRoomInBuffer);
        recordScalar("Chunks Reneged", assoc.numChunksReneged);
        recordScalar("sackPeriod", (simtime_t)socketOptions->sackPeriod);
        recordScalar("Number of AUTH chunks sent", assoc.numAuthChunksSent);
        recordScalar("Number of AUTH chunks accepted", assoc.numAuthChunksAccepted);
        recordScalar("Number of AUTH chunks rejected", assoc.numAuthChunksRejected);
        recordScalar("Number of StreamReset requests sent", assoc.numResetRequestsSent);
        recordScalar("Number of StreamReset requests performed", assoc.numResetRequestsPerformed);
        if ((double)par("fairStart") > 0) {
            recordScalar("fair acked bytes", assoc.fairAckedBytes);
            recordScalar("fair start time", assoc.fairStart);
            recordScalar("fair stop time", assoc.fairStop);
            recordScalar("fair lifetime", assoc.fairLifeTime);
            recordScalar("fair throughput", assoc.fairThroughput);
        }
        recordScalar("Number of PacketDrop Reports", numPktDropReports);

        if (assoc.numEndToEndMessages > 0 && (assoc.cumEndToEndDelay / assoc.numEndToEndMessages) > 0) {
            uint32 msgnum = assoc.numEndToEndMessages - assoc.startEndToEndDelay;
            if (assoc.stopEndToEndDelay > 0)
                msgnum -= (assoc.numEndToEndMessages - assoc.stopEndToEndDelay);
            recordScalar("Average End to End Delay", assoc.cumEndToEndDelay / msgnum);
        }

        recordScalar("RTXMethod", (double)par("RTXMethod"));
    }
}

SCTPAssociation * inet::sctp::SCTP::getAssoc

(

int32

assocId

)

Referenced by findAssocWithVTag().

{
    for (auto & elem : sctpAppAssocMap) {
        if (elem.first.assocId == assocId)
            return elem.second;
    }
    return nullptr;
}

int inet::sctp::SCTP::getAssocMaxRtx ( )

inline

Referenced by inet::sctp::SCTPAssociation::process_TIMEOUT_HEARTBEAT(), inet::sctp::SCTPAssociation::process_TIMEOUT_RTX(), inet::sctp::SCTPAssociation::process_TIMEOUT_SHUTDOWN(), and inet::sctp::SCTPAssociation::updateCounters().

{ return socketOptions->assocMaxRtx; };

AssocStat* inet::sctp::SCTP::getAssocStat ( uint32  assocId )

inline

Referenced by inet::sctp::SCTPAssociation::dequeueAckedChunks(), inet::sctp::SCTPAssociation::handleChunkReportedAsAcked(), inet::sctp::SCTPAssociation::handleChunkReportedAsMissing(), and inet::sctp::SCTPAssociation::processSackArrived().

    {
        auto found = assocStatMap.find(assocId);
        if (found != assocStatMap.end()) {
            return &found->second;
        }
        return nullptr;
    }

bool inet::sctp::SCTP::getEnableHeartbeats ( )

inline

Referenced by inet::sctp::SCTPAssociation::pmDataIsSentOn(), inet::sctp::SCTPAssociation::pmStartPathManagement(), inet::sctp::SCTPAssociation::process_TIMEOUT_HEARTBEAT_INTERVAL(), and inet::sctp::SCTPAssociation::processAsconfArrived().

{ return socketOptions->enableHeartbeats; };

uint16 inet::sctp::SCTP::getEphemeralPort

(

)

To be called from SCTPAssociation: reserves an ephemeral port for the connection.

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

{
    if (nextEphemeralPort == 5000)
        throw cRuntimeError("Ephemeral port range 1024..4999 exhausted (email SCTP model "
                            "author that he should implement reuse of ephemeral ports!!!)");
    return nextEphemeralPort++;
}

int inet::sctp::SCTP::getFragPoint ( )

inline

{ return socketOptions->fragPoint; };

double inet::sctp::SCTP::getHbInterval ( )

inline

Referenced by inet::sctp::SCTPAssociation::pmDataIsSentOn(), inet::sctp::SCTPAssociation::pmStartPathManagement(), inet::sctp::SCTPAssociation::process_TIMEOUT_HEARTBEAT_INTERVAL(), and inet::sctp::SCTPAssociation::processHeartbeatAckArrived().

{ return socketOptions->hbInterval; };

int inet::sctp::SCTP::getMaxBurst ( )

inline

{ return socketOptions->maxBurst; };

int inet::sctp::SCTP::getMaxInitRetrans ( )

inline

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

{ return socketOptions->maxInitRetrans; };

int inet::sctp::SCTP::getMaxInitRetransTimeout ( )

inline

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

{ return socketOptions->maxInitRetransTimeout; };

int inet::sctp::SCTP::getNagle ( )

inline

{ return socketOptions->nagle; };

int inet::sctp::SCTP::getPathMaxRetrans ( )

inline

Referenced by inet::sctp::SCTPAssociation::process_TIMEOUT_HEARTBEAT(), inet::sctp::SCTPPathVariables::SCTPPathVariables(), and inet::sctp::SCTPAssociation::updateCounters().

{ return socketOptions->pathMaxRetrans; };

double inet::sctp::SCTP::getRtoInitial ( )

inline

Referenced by inet::sctp::SCTPAssociation::pmStartPathManagement(), and inet::sctp::SCTPPathVariables::SCTPPathVariables().

{ return socketOptions->rtoInitial; };

double inet::sctp::SCTP::getRtoMax ( )

inline

Referenced by inet::sctp::SCTPAssociation::pmRttMeasurement(), inet::sctp::SCTPAssociation::process_TIMEOUT_ASCONF(), inet::sctp::SCTPAssociation::process_TIMEOUT_HEARTBEAT(), inet::sctp::SCTPAssociation::process_TIMEOUT_RESET(), and inet::sctp::SCTPAssociation::process_TIMEOUT_RTX().

{ return socketOptions->rtoMax; };

double inet::sctp::SCTP::getRtoMin ( )

inline

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

{ return socketOptions->rtoMin; };

int inet::sctp::SCTP::getSackFrequency ( )

inline

{ return socketOptions->sackFrequency; };

double inet::sctp::SCTP::getSackPeriod ( )

inline

{ return socketOptions->sackPeriod; };

SctpVTagMap inet::sctp::SCTP::getVTagMap ( )

inline

{ return sctpVTagMap; };

void inet::sctp::SCTP::handleMessage ( cMessage *  msg )

overridevirtual

{
    L3Address destAddr;
    L3Address srcAddr;
    bool findListen = false;

    EV_DEBUG << "\n\nSCTPMain handleMessage at " << getFullPath() << "\n";

    if (msg->isSelfMessage()) {
        EV_DEBUG << "selfMessage\n";

        SCTPAssociation *assoc = (SCTPAssociation *)msg->getContextPointer();
        if (assoc) {
            bool ret = assoc->processTimer(msg);

            if (!ret)
                removeAssociation(assoc);
        }
    }
    else if (msg->arrivedOn("from_ip")) {
        EV_INFO << "Message from IP\n";
        printInfoAssocMap();
        if (!dynamic_cast<SCTPMessage *>(msg)) {
            EV_INFO << "no sctp message, delete it\n";
            delete msg;
            return;
        }
        SCTPMessage *sctpmsg = check_and_cast<SCTPMessage *>(msg);

        numPacketsReceived++;

        if (!pktdrop && (sctpmsg->hasBitError() || !(sctpmsg->getChecksumOk()))) {
            EV_WARN << "Packet has bit-error. delete it\n";

            numPacketsDropped++;
            delete msg;
            return;
        }

        if (par("udpEncapsEnabled")) {
            EV_DETAIL << "Size of SCTPMSG=" << sctpmsg->getByteLength() << "\n";
            UDPDataIndication *ctrl = check_and_cast<UDPDataIndication *>(msg->removeControlInfo());
            srcAddr = ctrl->getSrcAddr();
            destAddr = ctrl->getDestAddr();
            delete ctrl;
            EV_INFO << "controlInfo srcAddr=" << srcAddr << "  destAddr=" << destAddr << "\n";
            EV_DETAIL << "VTag=" << sctpmsg->getTag() << "\n";
        } else {
            INetworkProtocolControlInfo *controlInfo = check_and_cast<INetworkProtocolControlInfo *>(msg->removeControlInfo());
            srcAddr = controlInfo->getSourceAddress();
            destAddr = controlInfo->getDestinationAddress();
            delete controlInfo;
            EV_INFO << "controlInfo srcAddr=" << srcAddr << "   destAddr=" << destAddr << "\n";
        }

        EV_INFO << "srcAddr=" << srcAddr << " destAddr=" << destAddr << "\n";
        if (sctpmsg->getByteLength() > (SCTP_COMMON_HEADER)) {
            if (((SCTPChunk *)(sctpmsg->getChunks(0)))->getChunkType() == INIT || ((SCTPChunk *)(sctpmsg->getChunks(0)))->getChunkType() == INIT_ACK)
                findListen = true;

            SCTPAssociation *assoc = findAssocForMessage(srcAddr, destAddr, sctpmsg->getSrcPort(), sctpmsg->getDestPort(), findListen);
            if (!assoc && sctpAssocMap.size() > 0 && (((SCTPChunk *)(sctpmsg->getChunks(0)))->getChunkType() == INIT_ACK)) {
                SCTPInitAckChunk* initack = check_and_cast<SCTPInitAckChunk *>((SCTPChunk *)(sctpmsg->getChunks(0)));
                assoc = findAssocForInitAck(initack, srcAddr, destAddr, sctpmsg->getSrcPort(), sctpmsg->getDestPort(), findListen);
            }
            if (!assoc && sctpAssocMap.size() > 0 && (((SCTPChunk *)(sctpmsg->getChunks(0)))->getChunkType() == ERRORTYPE
                                                      || (sctpmsg->getChunksArraySize() > 1 &&
                                                          (((SCTPChunk *)(sctpmsg->getChunks(1)))->getChunkType() == ASCONF || ((SCTPChunk *)(sctpmsg->getChunks(1)))->getChunkType() == ASCONF_ACK))))
            {
                assoc = findAssocWithVTag(sctpmsg->getTag(), sctpmsg->getSrcPort(), sctpmsg->getDestPort());
            }
            if (!assoc) {
                EV_INFO << "no assoc found msg=" << sctpmsg->getName() << "\n";
                if (sctpmsg->hasBitError() || !(sctpmsg->getChecksumOk())) {
                    delete sctpmsg;
                    return;
                }
                if (((SCTPChunk *)(sctpmsg->getChunks(0)))->getChunkType() == SHUTDOWN_ACK)
                    sendShutdownCompleteFromMain(sctpmsg, destAddr, srcAddr);
                else if (((SCTPChunk *)(sctpmsg->getChunks(0)))->getChunkType() != ABORT &&
                         ((SCTPChunk *)(sctpmsg->getChunks(0)))->getChunkType() != SHUTDOWN_COMPLETE) {
                    sendAbortFromMain(sctpmsg, destAddr, srcAddr);
                }
                delete sctpmsg;
            }
            else {
                EV_INFO << "assoc " << assoc->assocId << " found\n";
                bool ret = assoc->processSCTPMessage(sctpmsg, srcAddr, destAddr);
                if (!ret) {
                    EV_DEBUG << "SCTPMain:: removeAssociation \n";
                    removeAssociation(assoc);
                    delete sctpmsg;
                }
                else {
                    delete sctpmsg;
                }
            }
        }
        else {
            delete sctpmsg;
        }
    }
    else {    // must be from app
        EV_DEBUG << "must be from app\n";
        if (msg->getKind() == SCTP_C_GETSOCKETOPTIONS) {
            cPacket* cmsg = new cPacket("SocketOptions", SCTP_I_SENDSOCKETOPTIONS);
            SCTPCommand* indication = new SCTPCommand("SCTP_I_SENDSOCKETOPTIONS");
            cmsg->setControlInfo(indication);
            socketOptions = collectSocketOptions();
            cmsg->setContextPointer((void*) socketOptions);
            send(cmsg, "to_appl", 0);
            delete msg;
        } else {
            SCTPCommand *controlInfo = check_and_cast<SCTPCommand *>(msg->getControlInfo());

            int32 appGateIndex;
            if (controlInfo->getGate() != -1)
                appGateIndex = controlInfo->getGate();
            else
                appGateIndex = msg->getArrivalGate()->getIndex();
            int32 assocId = controlInfo->getAssocId();
            if (assocId == -1) {
                int32 fd = controlInfo->getFd();
                assocId = findAssocForFd(fd);
            }
            EV_INFO << "msg arrived from app for assoc " << assocId << "\n";
            SCTPAssociation *assoc = findAssocForApp(appGateIndex, assocId);

            if (!assoc) {
                EV_INFO << "no assoc found. msg=" << msg->getName() << " number of assocs = " << assocList.size() << "\n";

                if (strcmp(msg->getName(), "PassiveOPEN") == 0 || strcmp(msg->getName(), "Associate") == 0) {
                    if (assocList.size() > 0) {
                        assoc = nullptr;
                        SCTPOpenCommand *open = check_and_cast<SCTPOpenCommand *>(controlInfo);
                        EV_INFO << "Looking for assoc with remoteAddr=" << open->getRemoteAddr() << ", remotePort=" << open->getRemotePort() << ", localPort=" << open->getLocalPort() << "\n";
                        for (auto & elem : assocList) {
                            EV_DETAIL << "remoteAddr=" << (elem)->remoteAddr << ", remotePort=" << (elem)->remotePort << ", localPort=" << (elem)->localPort << "\n";
                            if ((elem)->remoteAddr == open->getRemoteAddr() && (elem)->localPort == open->getLocalPort() && (elem)->remotePort == open->getRemotePort()) {
                                assoc = (elem);
                                break;
                            }
                        }
                    }
                    if (assocList.size() == 0 || assoc == nullptr) {
                        assoc = new SCTPAssociation(this, appGateIndex, assocId, rt, ift);

                        AppAssocKey key;
                        key.appGateIndex = appGateIndex;
                        key.assocId = assocId;
                        sctpAppAssocMap[key] = assoc;
                        EV_INFO << "SCTP association created for appGateIndex " << appGateIndex << " and assoc " << assocId << "\n";
                        bool ret = assoc->processAppCommand(msg);
                        if (!ret) {
                            removeAssociation(assoc);
                        }
                    }
                }
            } else {
                EV_INFO << "assoc found\n";
                bool ret = assoc->processAppCommand(msg);

                if (!ret)
                    removeAssociation(assoc);
            }
            delete msg;
        }
    }
}

void inet::sctp::SCTP::initialize ( int  stage )

overridevirtual

{
    cSimpleModule::initialize(stage);

    if (stage == INITSTAGE_LOCAL) {
        ift = getModuleFromPar<IInterfaceTable>(par("interfaceTableModule"), this);
        rt = getModuleFromPar<IRoutingTable>(par("routingTableModule"), this);
        this->auth = (bool)par("auth");
        this->pktdrop = (bool)par("packetDrop");
        this->sackNow = (bool)par("sackNow");
        numPktDropReports = 0;
        numPacketsReceived = 0;
        numPacketsDropped = 0;
        sizeAssocMap = 0;
        nextEphemeralPort = (uint16)(intrand(10000) + 30000);

        cModule *netw = getSimulation()->getSystemModule();
        if (netw->hasPar("testTimeout")) {
            testTimeout = (simtime_t)netw->par("testTimeout");
        }
    }
    else if (stage == INITSTAGE_TRANSPORT_LAYER) {
        IPSocket socket(gate("to_ip"));
        socket.registerProtocol(IP_PROT_SCTP);
    }
    else if (stage == INITSTAGE_TRANSPORT_LAYER_2) {
        if (par("udpEncapsEnabled").boolValue()) {
            bindPortForUDP();
        }
    }
}

virtual int inet::sctp::SCTP::numInitStages ( ) const

inlineoverridevirtual

{ return NUM_INIT_STAGES; }

void inet::sctp::SCTP::printInfoAssocMap

(

)

Referenced by addForkedAssociation(), addLocalAddress(), addLocalAddressToAllRemoteAddresses(), addRemoteAddress(), inet::sctp::SCTPAssociation::cloneAssociation(), findAssocForMessage(), findAssocWithVTag(), handleMessage(), removeAssociation(), removeLocalAddressFromAllRemoteAddresses(), removeRemoteAddressFromAllAssociations(), inet::sctp::SCTPAssociation::sendInit(), and updateSockPair().

{
    SCTPAssociation *assoc;
    SockPair key;
    EV_DETAIL << "Number of Assocs: " << sizeAssocMap << "\n";
    if (sizeAssocMap > 0) {
        for (auto & elem : sctpAssocMap) {
            assoc = elem.second;
            key = elem.first;

            EV_DETAIL << "assocId: " << assoc->assocId << "  assoc: " << assoc << " src: " << key.localAddr << " dst: " << key.remoteAddr << " lPort: " << key.localPort << " rPort: " << key.remotePort << " fd: " << assoc->fd <<"\n";
        }

        EV_DETAIL << "\n";
    }
}

void inet::sctp::SCTP::printVTagMap

(

)

Referenced by findAssocWithVTag().

{
    int32 assocId;
    VTagPair key;
    EV_DETAIL << "Number of Assocs: " << sctpVTagMap.size() << "\n";
    if (sctpVTagMap.size() > 0) {
        for (auto & elem : sctpVTagMap) {
            assocId = elem.first;
            key = elem.second;

            EV_DETAIL << "assocId: " << assocId << " peerVTag: " << key.peerVTag
                      << " localVTag: " << key.localVTag
                      << " localPort: " << key.localPort << " rPort: " << key.remotePort << "\n";
        }

        EV_DETAIL << "\n";
    }
}

void inet::sctp::SCTP::refreshDisplay ( ) const

overrideprotectedvirtual

{
#if 0
    if (getEnvir()->disable_tracing) {
        // in express mode, we don't bother to update the display
        // (std::map's iteration is not very fast if map is large)
        getDisplayString().setTagArg("t", 0, "");
        return;
    }

    //char buf[40];
    //sprintf(buf,"%d conns", sctpAppConnMap.size());
    //displayString().setTagArg("t",0,buf);

    int32 numCLOSED = 0, numLISTEN = 0, numSYN_SENT = 0, numSYN_RCVD = 0,
          numESTABLISHED = 0, numCLOSE_WAIT = 0, numLAST_ACK = 0, numFIN_WAIT_1 = 0,
          numFIN_WAIT_2 = 0, numCLOSING = 0, numTIME_WAIT = 0;

    for (auto i = sctpAppConnMap.begin(); i != sctpAppConnMap.end(); ++i) {
        int32 state = (*i).second->getFsmState();
        switch (state) {
            // case SCTP_S_INIT:           numINIT++; break;
            case SCTP_S_CLOSED:
                numCLOSED++;
                break;

            case SCTP_S_COOKIE_WAIT:
                numLISTEN++;
                break;

            case SCTP_S_COOKIE_ECHOED:
                numSYN_SENT++;
                break;

            case SCTP_S_ESTABLISHED:
                numESTABLISHED++;
                break;

            case SCTP_S_SHUTDOWN_PENDING:
                numCLOSE_WAIT++;
                break;

            case SCTP_S_SHUTDOWN_SENT:
                numLAST_ACK++;
                break;

            case SCTP_S_SHUTDOWN_RECEIVED:
                numFIN_WAIT_1++;
                break;

            case SCTP_S_SHUTDOWN_ACK_SENT:
                numFIN_WAIT_2++;
                break;
        }
    }
    char buf2[300];
    buf2[0] = '\0';
    if (numCLOSED > 0)
        sprintf(buf2 + strlen(buf2), "closed:%d ", numCLOSED);
    if (numLISTEN > 0)
        sprintf(buf2 + strlen(buf2), "listen:%d ", numLISTEN);
    if (numSYN_SENT > 0)
        sprintf(buf2 + strlen(buf2), "syn_sent:%d ", numSYN_SENT);
    if (numSYN_RCVD > 0)
        sprintf(buf2 + strlen(buf2), "syn_rcvd:%d ", numSYN_RCVD);
    if (numESTABLISHED > 0)
        sprintf(buf2 + strlen(buf2), "estab:%d ", numESTABLISHED);
    if (numCLOSE_WAIT > 0)
        sprintf(buf2 + strlen(buf2), "close_wait:%d ", numCLOSE_WAIT);
    if (numLAST_ACK > 0)
        sprintf(buf2 + strlen(buf2), "last_ack:%d ", numLAST_ACK);
    if (numFIN_WAIT_1 > 0)
        sprintf(buf2 + strlen(buf2), "fin_wait_1:%d ", numFIN_WAIT_1);
    if (numFIN_WAIT_2 > 0)
        sprintf(buf2 + strlen(buf2), "fin_wait_2:%d ", numFIN_WAIT_2);
    if (numCLOSING > 0)
        sprintf(buf2 + strlen(buf2), "closing:%d ", numCLOSING);
    if (numTIME_WAIT > 0)
        sprintf(buf2 + strlen(buf2), "time_wait:%d ", numTIME_WAIT);
    getDisplayString().setTagArg("t", 0, buf2);
#endif // if 0
}

void inet::sctp::SCTP::removeAssociation

(

SCTPAssociation *

assoc

)

Referenced by finish(), handleMessage(), inet::sctp::SCTPAssociation::process_RCV_Message(), inet::sctp::SCTPAssociation::process_TIMEOUT_HEARTBEAT(), inet::sctp::SCTPAssociation::process_TIMEOUT_RTX(), inet::sctp::SCTPAssociation::process_TIMEOUT_SHUTDOWN(), and inet::sctp::SCTPAssociation::updateCounters().

{
    bool ok = false;
    bool find = false;
    const int32 id = assoc->assocId;

    EV_INFO << "Deleting SCTP connection " << assoc << " id= " << id << endl;

    printInfoAssocMap();
    if (sizeAssocMap > 0) {
        auto assocStatMapIterator = assocStatMap.find(assoc->assocId);
        if (assocStatMapIterator != assocStatMap.end()) {
            assocStatMapIterator->second.stop = simTime();
            assocStatMapIterator->second.lifeTime = assocStatMapIterator->second.stop - assocStatMapIterator->second.start;
            assocStatMapIterator->second.throughput = assocStatMapIterator->second.ackedBytes * 8 / assocStatMapIterator->second.lifeTime.dbl();
        }
        while (!ok) {
            if (sizeAssocMap == 0) {
                ok = true;
            }
            else {
                for (auto sctpAssocMapIterator = sctpAssocMap.begin();
                     sctpAssocMapIterator != sctpAssocMap.end(); sctpAssocMapIterator++)
                {
                    if (sctpAssocMapIterator->second != nullptr) {
                        SCTPAssociation *myAssoc = sctpAssocMapIterator->second;
                        if (myAssoc->assocId == assoc->assocId) {
                            if (myAssoc->T1_InitTimer) {
                                myAssoc->stopTimer(myAssoc->T1_InitTimer);
                            }
                            if (myAssoc->T2_ShutdownTimer) {
                                myAssoc->stopTimer(myAssoc->T2_ShutdownTimer);
                            }
                            if (myAssoc->T5_ShutdownGuardTimer) {
                                myAssoc->stopTimer(myAssoc->T5_ShutdownGuardTimer);
                            }
                            if (myAssoc->SackTimer) {
                                myAssoc->stopTimer(myAssoc->SackTimer);
                            }
                            if (myAssoc->StartAddIP) {
                                myAssoc->stopTimer(myAssoc->StartAddIP);
                            }
                            sctpAssocMap.erase(sctpAssocMapIterator);
                            sizeAssocMap--;
                            find = true;
                            break;
                        }
                    }
                }
            }

            if (!find) {
                ok = true;
            }
            else {
                find = false;
            }
        }
    }
    // Write statistics
    char str[128];
    for (auto pathMapIterator = assoc->sctpPathMap.begin();
         pathMapIterator != assoc->sctpPathMap.end(); pathMapIterator++)
    {
        const SCTPPathVariables *path = pathMapIterator->second;
        snprintf((char *)&str, sizeof(str), "Number of Fast Retransmissions %d:%s",
                assoc->assocId, path->remoteAddress.str().c_str());
        recordScalar(str, path->numberOfFastRetransmissions);
        snprintf((char *)&str, sizeof(str), "Number of Timer-Based Retransmissions %d:%s",
                assoc->assocId, path->remoteAddress.str().c_str());
        recordScalar(str, path->numberOfTimerBasedRetransmissions);
        snprintf((char *)&str, sizeof(str), "Number of Heartbeats Sent %d:%s",
                assoc->assocId, path->remoteAddress.str().c_str());
        recordScalar(str, path->numberOfHeartbeatsSent);
        snprintf((char *)&str, sizeof(str), "Number of Heartbeats Received %d:%s",
                assoc->assocId, path->remoteAddress.str().c_str());
        recordScalar(str, path->numberOfHeartbeatsRcvd);
        snprintf((char *)&str, sizeof(str), "Number of Heartbeat ACKs Sent %d:%s",
                assoc->assocId, path->remoteAddress.str().c_str());
        recordScalar(str, path->numberOfHeartbeatAcksSent);
        snprintf((char *)&str, sizeof(str), "Number of Heartbeat ACKs Received %d:%s",
                assoc->assocId, path->remoteAddress.str().c_str());
        recordScalar(str, path->numberOfHeartbeatAcksRcvd);
        snprintf((char *)&str, sizeof(str), "Number of Duplicates %d:%s",
                assoc->assocId, path->remoteAddress.str().c_str());
        recordScalar(str, path->numberOfDuplicates);
        snprintf((char *)&str, sizeof(str), "Number of Bytes received from %d:%s",
                assoc->assocId, path->remoteAddress.str().c_str());
        recordScalar(str, path->numberOfBytesReceived);
    }
    for (uint16 i = 0; i < assoc->inboundStreams; i++) {
        snprintf((char *)&str, sizeof(str), "Bytes received on stream %d of assoc %d",
                i, assoc->assocId);
        recordScalar(str, assoc->getState()->streamThroughput[i]);
    }
    recordScalar("Blocking TSNs Moved", assoc->state->blockingTSNsMoved);

    assoc->removePath();
    assoc->deleteStreams();

    // Chunks may be in the transmission and retransmission queues simultaneously.
    // Remove entry from transmission queue if it is already in the retransmission queue.
    for (auto i = assoc->getRetransmissionQueue()->payloadQueue.begin();
         i != assoc->getRetransmissionQueue()->payloadQueue.end(); i++)
    {
        auto j = assoc->getTransmissionQueue()->payloadQueue.find(i->second->tsn);
        if (j != assoc->getTransmissionQueue()->payloadQueue.end()) {
            assoc->getTransmissionQueue()->payloadQueue.erase(j);
        }
    }
    // Now, both queues can be safely deleted.
    delete assoc->getRetransmissionQueue();
    delete assoc->getTransmissionQueue();

    AppAssocKey key;
    key.appGateIndex = assoc->appGateIndex;
    key.assocId = assoc->assocId;
    sctpAppAssocMap.erase(key);
    assocList.remove(assoc);
    delete assoc;
}

void inet::sctp::SCTP::removeLocalAddressFromAllRemoteAddresses	(	SCTPAssociation *	assoc,
		L3Address	address,
		std::vector< L3Address >	remAddresses
	)

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

{
    SockPair key;

    for (auto & remAddresse : remAddresses) {
        key.localAddr = address;
        key.remoteAddr = (remAddresse);
        key.localPort = assoc->localPort;
        key.remotePort = assoc->remotePort;

        auto j = sctpAssocMap.find(key);
        if (j != sctpAssocMap.end()) {
            ASSERT(j->second == assoc);
            sctpAssocMap.erase(j);
            sizeAssocMap--;
        }
        else
            EV_INFO << "no actual sockPair found\n";

        printInfoAssocMap();
    }
}

void inet::sctp::SCTP::removeRemoteAddressFromAllAssociations	(	SCTPAssociation *	assoc,
		L3Address	address,
		std::vector< L3Address >	locAddresses
	)

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

{
    SockPair key;

    for (auto & locAddresse : locAddresses) {
        key.localAddr = (locAddresse);
        key.remoteAddr = address;
        key.localPort = assoc->localPort;
        key.remotePort = assoc->remotePort;

        auto j = sctpAssocMap.find(key);
        if (j != sctpAssocMap.end()) {
            ASSERT(j->second == assoc);
            sctpAssocMap.erase(j);
            sizeAssocMap--;
        }
        else
            EV_INFO << "no actual sockPair found\n";

        printInfoAssocMap();
    }
}

void inet::sctp::SCTP::send_to_ip ( SCTPMessage *  msg )

virtual

Referenced by sendAbortFromMain(), sendShutdownCompleteFromMain(), and inet::sctp::SCTPAssociation::sendToIP().

{
// enable this and run all SCTP tests tp see if SCTP serializer correctly handles all SCTP packets
#if 0
    char buff[4096];
    serializer::Buffer b(buff, 4096);
    serializer::Context ctx;
    serializer::SCTPSerializer().serializePacket(msg, b, ctx);
    ASSERT(b.getPos() == msg->getByteLength());
#endif
    send(msg, "to_ip");
}

void inet::sctp::SCTP::sendAbortFromMain ( SCTPMessage *  sctpmsg, L3Address  fromAddr, L3Address  toAddr  )

protected

Referenced by handleMessage().

{
    SCTPMessage *msg = new SCTPMessage();

    EV_DEBUG << "\n\nSCTP::sendAbortFromMain()\n";

    msg->setSrcPort(sctpmsg->getDestPort());
    msg->setDestPort(sctpmsg->getSrcPort());
    msg->setBitLength(SCTP_COMMON_HEADER * 8);
    msg->setChecksumOk(true);

    SCTPAbortChunk *abortChunk = new SCTPAbortChunk("ABORT");
    abortChunk->setChunkType(ABORT);
    if (sctpmsg->getChunksArraySize() > 0 && ((SCTPChunk *)(sctpmsg->getChunks(0)))->getChunkType() == INIT) {
        SCTPInitChunk *initChunk = check_and_cast<SCTPInitChunk *>(sctpmsg->getChunks(0));
        abortChunk->setT_Bit(0);
        msg->setTag(initChunk->getInitTag());
    }
    else {
        abortChunk->setT_Bit(1);
        msg->setTag(sctpmsg->getTag());
    }
    abortChunk->setBitLength(SCTP_ABORT_CHUNK_LENGTH * 8);
    msg->addChunk(abortChunk);
    if ((bool)par("udpEncapsEnabled")) {
        EV_DETAIL << "VTag=" << msg->getTag() << "\n";
        udpSocket.sendTo(msg, toAddr, SCTP_UDP_PORT);
    }
    else {
        INetworkProtocolControlInfo *controlInfo = toAddr.getAddressType()->createNetworkProtocolControlInfo();
        controlInfo->setTransportProtocol(IP_PROT_SCTP);
        controlInfo->setSourceAddress(fromAddr);
        controlInfo->setDestinationAddress(toAddr);
        msg->setControlInfo(check_and_cast<cObject *>(controlInfo));
        send_to_ip(msg);
    }
}

void inet::sctp::SCTP::sendShutdownCompleteFromMain ( SCTPMessage *  sctpmsg, L3Address  fromAddr, L3Address  toAddr  )

protected

Referenced by handleMessage().

{
    SCTPMessage *msg = new SCTPMessage();

    EV_DEBUG << "\n\nSCTP:sendShutdownCompleteFromMain \n";

    msg->setSrcPort(sctpmsg->getDestPort());
    msg->setDestPort(sctpmsg->getSrcPort());
    msg->setBitLength(SCTP_COMMON_HEADER * 8);
    msg->setChecksumOk(true);

    SCTPShutdownCompleteChunk *scChunk = new SCTPShutdownCompleteChunk("SHUTDOWN_COMPLETE");
    scChunk->setChunkType(SHUTDOWN_COMPLETE);
    scChunk->setTBit(1);
    msg->setTag(sctpmsg->getTag());

    scChunk->setBitLength(SCTP_SHUTDOWN_ACK_LENGTH * 8);
    msg->addChunk(scChunk);

    INetworkProtocolControlInfo *controlInfo = toAddr.getAddressType()->createNetworkProtocolControlInfo();
    controlInfo->setTransportProtocol(IP_PROT_SCTP);
    controlInfo->setSourceAddress(fromAddr);
    controlInfo->setDestinationAddress(toAddr);
    msg->setControlInfo(check_and_cast<cObject *>(controlInfo));
    send_to_ip(msg);
}

void inet::sctp::SCTP::setRtoInitial ( double  rtoInitial )

inline

{ socketOptions->rtoInitial = rtoInitial; };

void inet::sctp::SCTP::setRtoMax ( double  rtoMax )

inline

{ socketOptions->rtoMax = rtoMax; };

void inet::sctp::SCTP::setRtoMin ( double  rtoMin )

inline

{ socketOptions->rtoMin = rtoMin; };

void inet::sctp::SCTP::setSocketOptions ( SocketOptions *  options )

inline

Referenced by inet::sctp::SCTPAssociation::process_ASSOCIATE(), and inet::sctp::SCTPAssociation::process_OPEN_PASSIVE().

{ socketOptions = options; };

void inet::sctp::SCTP::updateSockPair	(	SCTPAssociation *	assoc,
		L3Address	localAddr,
		L3Address	remoteAddr,
		int32	localPort,
		int32	remotePort
	)

To be called from SCTPAssociation when socket pair changes.

Referenced by addForkedAssociation(), inet::sctp::SCTPAssociation::process_ASSOCIATE(), inet::sctp::SCTPAssociation::process_OPEN_PASSIVE(), and inet::sctp::SCTPAssociation::processInitArrived().

{
    SockPair key;
    EV_INFO << "updateSockPair:   localAddr: " << localAddr << "   remoteAddr=" << remoteAddr << "    localPort=" << localPort << " remotePort=" << remotePort << "\n";

    key.localAddr = (assoc->localAddr = localAddr);
    key.remoteAddr = (assoc->remoteAddr = remoteAddr);
    key.localPort = assoc->localPort = localPort;
    key.remotePort = assoc->remotePort = remotePort;

    // Do not update a sock pair that is already stored
    for (auto & elem : sctpAssocMap) {
        if (elem.second == assoc &&
            elem.first.localAddr == key.localAddr &&
            elem.first.remoteAddr == key.remoteAddr &&
            elem.first.localPort == key.localPort
            && elem.first.remotePort == key.remotePort)
            return;
    }

    for (auto i = sctpAssocMap.begin(); i != sctpAssocMap.end(); i++) {
        if (i->second == assoc) {
            sctpAssocMap.erase(i);
            break;
        }
    }

    EV_INFO << "updateSockPair assoc=" << assoc << "    localAddr=" << key.localAddr << "            remoteAddr=" << key.remoteAddr << "     localPort=" << key.localPort << "  remotePort=" << remotePort << "\n";

    sctpAssocMap[key] = assoc;
    sizeAssocMap = sctpAssocMap.size();
    EV_DEBUG << "assoc inserted in sctpAssocMap\n";
    printInfoAssocMap();
}

Member Data Documentation

bool inet::sctp::SCTP::addIP

std::list<SCTPAssociation *> inet::sctp::SCTP::assocList

Referenced by handleMessage(), removeAssociation(), inet::sctp::SCTPAssociation::sendInit(), and inet::sctp::SCTPAssociation::sendInitAck().

AssocStatMap inet::sctp::SCTP::assocStatMap

Referenced by inet::sctp::SCTPAssociation::addAuthChunkIfNecessary(), inet::sctp::SCTPAssociation::createForwardTsnChunk(), inet::sctp::SCTPAssociation::createSack(), finish(), inet::sctp::SCTPAssociation::makeRoomForTsn(), inet::sctp::SCTPAssociation::pathStatusIndication(), inet::sctp::SCTPAssociation::process_RCV_Message(), inet::sctp::SCTPAssociation::process_SEND(), inet::sctp::SCTPAssociation::process_TIMEOUT_RTX(), inet::sctp::SCTPAssociation::processAddInAndOutResetRequestArrived(), inet::sctp::SCTPAssociation::processAsconfArrived(), inet::sctp::SCTPAssociation::processDataArrived(), inet::sctp::SCTPAssociation::processOutAndResponseArrived(), inet::sctp::SCTPAssociation::processResetResponseArrived(), inet::sctp::SCTPAssociation::pushUlp(), removeAssociation(), inet::sctp::SCTPAssociation::retransmitAsconf(), inet::sctp::SCTPAssociation::retransmitCookieEcho(), inet::sctp::SCTPAssociation::sendAbort(), inet::sctp::SCTPAssociation::sendAddOutgoingStreamsRequest(), inet::sctp::SCTPAssociation::sendAsconf(), inet::sctp::SCTPAssociation::sendAsconfAck(), inet::sctp::SCTPAssociation::sendCookieAck(), inet::sctp::SCTPAssociation::sendCookieEcho(), inet::sctp::SCTPAssociation::sendHeartbeat(), inet::sctp::SCTPAssociation::sendHeartbeatAck(), inet::sctp::SCTPAssociation::sendInvalidStreamError(), inet::sctp::SCTPAssociation::sendOnPath(), inet::sctp::SCTPAssociation::sendSack(), inet::sctp::SCTPAssociation::sendShutdown(), inet::sctp::SCTPAssociation::sendStreamResetRequest(), and ~SCTP().

bool inet::sctp::SCTP::auth

Referenced by initialize(), inet::sctp::SCTPAssociation::sendInit(), and inet::sctp::SCTPAssociation::sendInitAck().

IInterfaceTable* inet::sctp::SCTP::ift

protected

Referenced by handleMessage(), and initialize().

uint16 inet::sctp::SCTP::nextEphemeralPort

protected

Referenced by getEphemeralPort(), and initialize().

uint32 inet::sctp::SCTP::numGapReports

uint32 inet::sctp::SCTP::numPacketsDropped

Referenced by finish(), handleMessage(), and initialize().

uint32 inet::sctp::SCTP::numPacketsReceived

Referenced by finish(), handleMessage(), and initialize().

uint64 inet::sctp::SCTP::numPktDropReports

Referenced by finish(), initialize(), and inet::sctp::SCTPAssociation::sendPacketDrop().

bool inet::sctp::SCTP::pktdrop

Referenced by handleMessage(), initialize(), inet::sctp::SCTPAssociation::process_RCV_Message(), inet::sctp::SCTPAssociation::processDataArrived(), inet::sctp::SCTPAssociation::sendInit(), and inet::sctp::SCTPAssociation::sendInitAck().

IRoutingTable* inet::sctp::SCTP::rt

protected

Referenced by handleMessage(), and initialize().

bool inet::sctp::SCTP::sackNow

Referenced by inet::sctp::SCTPAssociation::chunkReschedulingControl(), inet::sctp::SCTPAssociation::fragmentOutboundDataMsgs(), initialize(), and inet::sctp::SCTPAssociation::sendOnPath().

SctpAppAssocMap inet::sctp::SCTP::sctpAppAssocMap

Referenced by addForkedAssociation(), findAssocForApp(), findAssocForFd(), getAssoc(), handleMessage(), removeAssociation(), and ~SCTP().

SctpAssocMap inet::sctp::SCTP::sctpAssocMap

Referenced by addForkedAssociation(), addLocalAddress(), addLocalAddressToAllRemoteAddresses(), addRemoteAddress(), findAssocForMessage(), finish(), handleMessage(), printInfoAssocMap(), removeAssociation(), removeLocalAddressFromAllRemoteAddresses(), removeRemoteAddressFromAllAssociations(), and updateSockPair().

SctpVTagMap inet::sctp::SCTP::sctpVTagMap

Referenced by findAssocWithVTag(), printVTagMap(), and ~SCTP().

int32 inet::sctp::SCTP::sizeAssocMap

protected

Referenced by addForkedAssociation(), addLocalAddress(), addLocalAddressToAllRemoteAddresses(), addRemoteAddress(), initialize(), printInfoAssocMap(), removeAssociation(), removeLocalAddressFromAllRemoteAddresses(), removeRemoteAddressFromAllAssociations(), and updateSockPair().

SocketOptions* inet::sctp::SCTP::socketOptions

Referenced by finish(), and handleMessage().

simtime_t inet::sctp::SCTP::testTimeout

Referenced by initialize().

UDPSocket inet::sctp::SCTP::udpSocket

Referenced by bindPortForUDP(), sendAbortFromMain(), and inet::sctp::SCTPAssociation::sendToIP().

---

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

• SCTP.h
• SCTP.cc