#include <RtpApplication.h>

Inheritance diagram for inet::RtpApplication:

Public Member Functions
	RtpApplication ()

Public Member Functions inherited from inet::LifecycleUnsupported
virtual bool	handleOperationStage (LifecycleOperation operation, IDoneCallback doneCallback) override
	Perform one stage of a lifecycle operation. More...

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

Protected Member Functions
virtual void	initialize (int stage) override

virtual int	numInitStages () const override

virtual void	handleMessage (cMessage *msg) override

Protected Attributes
const char *	fileName = nullptr

const char *	commonName = nullptr

const char *	profileName = nullptr

double	bandwidth = 0

int	port = -1

int	payloadType = -1

simtime_t	sessionEnterDelay

simtime_t	transmissionStartDelay

simtime_t	transmissionStopDelay

simtime_t	sessionLeaveDelay

Ipv4Address	destinationAddress

uint32_t	ssrc = 0

bool	isActiveSession = false

Constructor & Destructor Documentation

◆ RtpApplication()

inet::RtpApplication::RtpApplication ( )

inline

43 {}

Member Function Documentation

◆ handleMessage()

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

overrideprotectedvirtual

 {
     using namespace rtp;
  
     if (msgIn->isSelfMessage()) {
         switch (msgIn->getKind()) {
             case RTPAPP_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 RTPAPP_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", RTPAPP_STOP_TRANSMISSION);
                     scheduleAfter(transmissionStopDelay, selfMsg);
                 }
                 break;
  
             case RTPAPP_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 RTPAPP_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", RTPAPP_LEAVE_SESSION);
                         EV_INFO << "Receiver Module : leaveSession" << endl;
                         scheduleAfter(sessionLeaveDelay, selfMsg);
                     }
                 }
                 break;
  
                 case RTP_IFP_SENDER_MODULE_CREATED: {
                     EV_INFO << "Sender Module Created" << endl;
                     cMessage *selfMsg = new cMessage("startTransmission", RTPAPP_START_TRANSMISSION);
                     scheduleAfter(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", RTPAPP_LEAVE_SESSION);
                             scheduleAfter(sessionLeaveDelay, selfMsg);
                             break;
  
                         case RTP_SENDER_STATUS_STOPPED:
                             EV_INFO << "STOPPED" << endl;
                             selfMsg = new cMessage("leaveSession", RTPAPP_LEAVE_SESSION);
                             scheduleAfter(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;
 }