SCTPPeer.h

Go to the documentation of this file.

//
// Copyright (C) 2008 Irene Ruengeler
//
// This program is free software; you can redistribute it and/or
// modify it under the terms of the GNU General Public License
// as published by the Free Software Foundation; either version 2
// 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 General Public License for more details.
//
// You should have received a copy of the GNU General Public License
// along with this program; if not, see <http://www.gnu.org/licenses/>.
//

#ifndef __SCTPPEER_H_
#define __SCTPPEER_H_

#include <omnetpp.h>
#include "SCTPAssociation.h"
#include "SCTPSocket.h"


class INET_API SCTPPeer : public cSimpleModule, public SCTPSocket::CallbackInterface
{
    protected:
        int32 notifications;
        int32 serverAssocId;
        int32 clientAssocId;
        SCTPSocket clientSocket;
        double delay;
        double echoFactor;
        bool schedule;
        bool shutdownReceived;
        long bytesSent;
        int32 packetsSent;
        int32 packetsRcvd;
        int32 numSessions;
        int32 numRequestsToSend; // requests to send in this session
        bool ordered;
        int32 queueSize;
        cMessage *timeoutMsg;
        int32 outboundStreams;
        cMessage *timeMsg;
        cMessage *connectTimer;
        int32 bytesRcvd;
        int32 echoedBytesSent;
        int32 lastStream;
        bool sendAllowed;
        int32 numPacketsToReceive;
        typedef std::map<int32,long> RcvdPacketsPerAssoc;
        RcvdPacketsPerAssoc rcvdPacketsPerAssoc;
        typedef std::map<int32,long> SentPacketsPerAssoc;
        SentPacketsPerAssoc sentPacketsPerAssoc;
        typedef std::map<int32,long> RcvdBytesPerAssoc;
        RcvdBytesPerAssoc rcvdBytesPerAssoc;
        typedef std::map<int32,cOutVector*> BytesPerAssoc;
        BytesPerAssoc bytesPerAssoc;
        typedef std::map<int32,cDoubleHistogram*> HistEndToEndDelay;
        HistEndToEndDelay histEndToEndDelay;
        typedef std::map<int32,cOutVector*> EndToEndDelay;
        EndToEndDelay endToEndDelay;
        void sendOrSchedule(cPacket *msg);
        void sendRequest(bool last=true);
        int32 ssn;
    public:
        struct pathStatus {
            bool active;
            bool primaryPath;
            IPAddress  pid;
        };
        typedef std::map<IPvXAddress,pathStatus> SCTPPathStatus;
        SCTPPathStatus sctpPathStatus;
        void initialize();
        void handleMessage(cMessage *msg);
        void finish();
        void handleTimer(cMessage *msg);
        void generateAndSend(SCTPConnectInfo *connectInfo);
        void connect();

        void socketEstablished(int32 connId, void *yourPtr);

        void socketDataArrived(int32 connId, void *yourPtr, cPacket *msg, bool urgent);

        void socketDataNotificationArrived(int32 connId, void *yourPtr, cPacket *msg);
        void socketPeerClosed(int32 connId, void *yourPtr);

        void socketClosed(int32 connId, void *yourPtr);

        void socketFailure(int32 connId, void *yourPtr, int32 code);

        void socketStatusArrived(int32 connId, void *yourPtr, SCTPStatusInfo *status);
        void setPrimaryPath ();
        void sendRequestArrived();
        void sendQueueRequest();
        void shutdownReceivedArrived(int32 connId);
        void sendqueueFullArrived(int32 connId);

        void setStatusString(const char *s);
        void addressAddedArrived(int32 assocId, IPvXAddress remoteAddr);
};

#endif