inet::RTPApplication Class Reference

#include <RTPApplication.h>

Inheritance diagram for inet::RTPApplication:

Public Member Functions
	RTPApplication ()
Public Member Functions inherited from inet::ILifecycle
virtual	~ILifecycle ()

Protected Types
enum	SelfMsgKind { ENTER_SESSION, START_TRANSMISSION, STOP_TRANSMISSION, LEAVE_SESSION }

Protected Member Functions
virtual void	initialize (int stage) override
virtual int	numInitStages () const override
virtual void	handleMessage (cMessage *msg) override
virtual bool	handleOperationStage (LifecycleOperation *operation, int stage, IDoneCallback *doneCallback) override
	Perform one stage of a lifecycle operation. More...

Protected Attributes
const char *	fileName = nullptr
const char *	commonName = nullptr
const char *	profileName = nullptr
int	bandwidth = 0
int	port = -1
int	payloadType = -1
simtime_t	sessionEnterDelay
simtime_t	transmissionStartDelay
simtime_t	transmissionStopDelay
simtime_t	sessionLeaveDelay
IPv4Address	destinationAddress
uint32	ssrc = 0
bool	isActiveSession = false

Member Enumeration Documentation

enum inet::RTPApplication::SelfMsgKind

protected

Enumerator
ENTER_SESSION
START_TRANSMISSION
STOP_TRANSMISSION
LEAVE_SESSION

                     {
        ENTER_SESSION,
        START_TRANSMISSION,
        STOP_TRANSMISSION,
        LEAVE_SESSION
    };

Constructor & Destructor Documentation

inet::RTPApplication::RTPApplication ( )

inline

{}

Member Function Documentation

void inet::RTPApplication::handleMessage ( cMessage *  msg )

overrideprotectedvirtual

{
    using namespace rtp;

    if (msgIn->isSelfMessage()) {
        switch (msgIn->getKind()) {
            case ENTER_SESSION:
                EV_INFO << "enterSession" << endl;
                if (isActiveSession) {
                    EV_WARN << "Session already entered\n";
                }
                else {
                    isActiveSession = true;
                    RTPCIEnterSession *ci = new RTPCIEnterSession();
                    ci->setCommonName(commonName);
                    ci->setProfileName(profileName);
                    ci->setBandwidth(bandwidth);
                    ci->setDestinationAddress(destinationAddress);
                    ci->setPort(port);
                    cMessage *msg = new RTPControlMsg("Enter Session");
                    msg->setControlInfo(ci);
                    send(msg, "rtpOut");
                }
                break;

            case START_TRANSMISSION:
                EV_INFO << "startTransmission" << endl;
                if (!isActiveSession) {
                    EV_WARN << "Session already left\n";
                }
                else {
                    RTPCISenderControl *ci = new RTPCISenderControl();
                    ci->setCommand(RTP_CONTROL_PLAY);
                    ci->setSsrc(ssrc);
                    cMessage *msg = new RTPControlMsg("senderModuleControl(PLAY)");
                    msg->setControlInfo(ci);
                    send(msg, "rtpOut");

                    cMessage *selfMsg = new cMessage("stopTransmission", STOP_TRANSMISSION);
                    scheduleAt(simTime() + transmissionStopDelay, selfMsg);
                }
                break;

            case STOP_TRANSMISSION:
                EV_INFO << "stopTransmission" << endl;
                if (!isActiveSession) {
                    EV_WARN << "Session already left\n";
                }
                else {
                    RTPCISenderControl *ci = new RTPCISenderControl();
                    ci->setCommand(RTP_CONTROL_STOP);
                    ci->setSsrc(ssrc);
                    cMessage *msg = new RTPControlMsg("senderModuleControl(STOP)");
                    msg->setControlInfo(ci);
                    send(msg, "rtpOut");
                }
                break;

            case LEAVE_SESSION:
                EV_INFO << "leaveSession" << endl;
                if (!isActiveSession) {
                    EV_WARN << "Session already left\n";
                }
                else {
                    RTPCILeaveSession *ci = new RTPCILeaveSession();
                    cMessage *msg = new RTPControlMsg("Leave Session");
                    msg->setControlInfo(ci);
                    send(msg, "rtpOut");
                }
                break;

            default:
                throw cRuntimeError("Invalid msgKind value %d in message '%s'",
                    msgIn->getKind(), msgIn->getName());
        }
    }
    else if (isActiveSession) {
        cObject *obj = msgIn->removeControlInfo();
        RTPControlInfo *ci = dynamic_cast<RTPControlInfo *>(obj);
        if (ci) {
            switch (ci->getType()) {
                case RTP_IFP_SESSION_ENTERED: {
                    EV_INFO << "Session Entered" << endl;
                    ssrc = (check_and_cast<RTPCISessionEntered *>(ci))->getSsrc();
                    if (opp_strcmp(fileName, "")) {
                        EV_INFO << "CreateSenderModule" << endl;
                        RTPCICreateSenderModule *ci = new RTPCICreateSenderModule();
                        ci->setSsrc(ssrc);
                        ci->setPayloadType(payloadType);
                        ci->setFileName(fileName);
                        cMessage *msg = new RTPControlMsg("createSenderModule()");
                        msg->setControlInfo(ci);
                        send(msg, "rtpOut");
                    }
                    else {
                        cMessage *selfMsg = new cMessage("leaveSession", LEAVE_SESSION);
                        EV_INFO << "Receiver Module : leaveSession" << endl;
                        scheduleAt(simTime() + sessionLeaveDelay, selfMsg);
                    }
                }
                break;

                case RTP_IFP_SENDER_MODULE_CREATED: {
                    EV_INFO << "Sender Module Created" << endl;
                    cMessage *selfMsg = new cMessage("startTransmission", START_TRANSMISSION);
                    scheduleAt(simTime() + transmissionStartDelay, selfMsg);
                }
                break;

                case RTP_IFP_SENDER_STATUS: {
                    cMessage *selfMsg;
                    RTPCISenderStatus *rsim = check_and_cast<RTPCISenderStatus *>(ci);
                    switch (rsim->getStatus()) {
                        case RTP_SENDER_STATUS_PLAYING:
                            EV_INFO << "PLAYING" << endl;
                            break;

                        case RTP_SENDER_STATUS_FINISHED:
                            EV_INFO << "FINISHED" << endl;
                            selfMsg = new cMessage("leaveSession", LEAVE_SESSION);
                            scheduleAt(simTime() + sessionLeaveDelay, selfMsg);
                            break;

                        case RTP_SENDER_STATUS_STOPPED:
                            EV_INFO << "STOPPED" << endl;
                            selfMsg = new cMessage("leaveSession", LEAVE_SESSION);
                            scheduleAt(simTime() + sessionLeaveDelay, selfMsg);
                            break;

                        default:
                            throw cRuntimeError("Invalid sender status: %d", rsim->getStatus());
                    }
                }
                break;

                case RTP_IFP_SESSION_LEFT:
                    if (!isActiveSession)
                        EV_WARN << "Session already left\n";
                    else
                        isActiveSession = false;
                    break;

                case RTP_IFP_SENDER_MODULE_DELETED:
                    EV_INFO << "Sender Module Deleted" << endl;
                    break;

                default:
                    break;
            }
        }
        delete obj;
    }
    delete msgIn;
}

bool inet::RTPApplication::handleOperationStage ( LifecycleOperation *  operation, int  stage, IDoneCallback *  doneCallback  )

overrideprotectedvirtual

Perform one stage of a lifecycle operation.

Processing may be done entirely within this method, or may be a longer process that involves nonzero simulation time or several events, and is triggered by this method call.

Return value: true = "done"; false = "not yet done, will invoke doneCallback when done"

Implements inet::ILifecycle.

{
    Enter_Method_Silent();

    throw cRuntimeError("Unsupported lifecycle operation '%s'", operation->getClassName());
    return true;
}

virtual void inet::RTPApplication::initialize ( int  stage )

overrideprotectedvirtual

virtual int inet::RTPApplication::numInitStages ( ) const

inlineoverrideprotectedvirtual

{ return NUM_INIT_STAGES; }

Member Data Documentation

int inet::RTPApplication::bandwidth = 0

protected

Referenced by handleMessage().

const char* inet::RTPApplication::commonName = nullptr

protected

Referenced by handleMessage().

IPv4Address inet::RTPApplication::destinationAddress

protected

Referenced by handleMessage().

const char* inet::RTPApplication::fileName = nullptr

protected

Referenced by handleMessage().

bool inet::RTPApplication::isActiveSession = false

protected

Referenced by handleMessage().

int inet::RTPApplication::payloadType = -1

protected

Referenced by handleMessage().

int inet::RTPApplication::port = -1

protected

Referenced by handleMessage().

const char* inet::RTPApplication::profileName = nullptr

protected

Referenced by handleMessage().

simtime_t inet::RTPApplication::sessionEnterDelay

protected

simtime_t inet::RTPApplication::sessionLeaveDelay

protected

Referenced by handleMessage().

uint32 inet::RTPApplication::ssrc = 0

protected

Referenced by handleMessage().

simtime_t inet::RTPApplication::transmissionStartDelay

protected

Referenced by handleMessage().

simtime_t inet::RTPApplication::transmissionStopDelay

protected

Referenced by handleMessage().

---

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

• RTPApplication.h
• RTPApplication.cc