inet::UDPVideoStreamCli Class Reference

A "Realtime" VideoStream client application. More...

#include <UDPVideoStreamCli.h>

Inheritance diagram for inet::UDPVideoStreamCli:

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

Protected Member Functions
virtual int	numInitStages () const override
virtual void	initialize (int stage) override
virtual void	finish () override
virtual void	handleMessageWhenUp (cMessage *msg) override
virtual void	requestStream ()
virtual void	receiveStream (cPacket *msg)
virtual bool	handleNodeStart (IDoneCallback *doneCallback) override
virtual bool	handleNodeShutdown (IDoneCallback *doneCallback) override
virtual void	handleNodeCrash () override
Protected Member Functions inherited from inet::ApplicationBase
virtual bool	isInitializeStage (int stage) override
virtual bool	isNodeStartStage (int stage) override
virtual bool	isNodeShutdownStage (int stage) override
Protected Member Functions inherited from inet::OperationalBase
virtual void	handleMessage (cMessage *msg) override
virtual void	handleMessageWhenDown (cMessage *msg)
virtual bool	handleOperationStage (LifecycleOperation *operation, int stage, IDoneCallback *doneCallback) override
	Perform one stage of a lifecycle operation. More...
virtual void	setOperational (bool isOperational)

Protected Attributes
UDPSocket	socket
cMessage *	selfMsg = nullptr
Protected Attributes inherited from inet::OperationalBase
bool	isOperational
simtime_t	lastChange

Static Protected Attributes
static simsignal_t	rcvdPkSignal = registerSignal("rcvdPk")

Detailed Description

A "Realtime" VideoStream client application.

Basic video stream application. Clients connect to server and get a stream of video back.

Constructor & Destructor Documentation

inet::UDPVideoStreamCli::UDPVideoStreamCli ( )

inline

{ }

virtual inet::UDPVideoStreamCli::~UDPVideoStreamCli ( )

inlinevirtual

{ cancelAndDelete(selfMsg); }

Member Function Documentation

void inet::UDPVideoStreamCli::finish ( )

overrideprotectedvirtual

{
    ApplicationBase::finish();
}

void inet::UDPVideoStreamCli::handleMessageWhenUp ( cMessage *  msg )

overrideprotectedvirtual

Implements inet::OperationalBase.

{
    if (msg->isSelfMessage()) {
        requestStream();
    }
    else if (msg->getKind() == UDP_I_DATA) {
        // process incoming packet
        receiveStream(PK(msg));
    }
    else if (msg->getKind() == UDP_I_ERROR) {
        EV_WARN << "Ignoring UDP error report\n";
        delete msg;
    }
    else {
        throw cRuntimeError("Unrecognized message (%s)%s", msg->getClassName(), msg->getName());
    }
}

void inet::UDPVideoStreamCli::handleNodeCrash ( )

overrideprotectedvirtual

Reimplemented from inet::OperationalBase.

{
    cancelEvent(selfMsg);
}

bool inet::UDPVideoStreamCli::handleNodeShutdown ( IDoneCallback *  doneCallback )

overrideprotectedvirtual

Reimplemented from inet::OperationalBase.

{
    cancelEvent(selfMsg);
    //TODO if(socket.isOpened()) socket.close();
    return true;
}

bool inet::UDPVideoStreamCli::handleNodeStart ( IDoneCallback *  doneCallback )

overrideprotectedvirtual

Reimplemented from inet::OperationalBase.

{
    simtime_t startTimePar = par("startTime");
    simtime_t startTime = std::max(startTimePar, simTime());
    scheduleAt(startTime, selfMsg);
    return true;
}

void inet::UDPVideoStreamCli::initialize ( int  stage )

overrideprotectedvirtual

Reimplemented from inet::OperationalBase.

{
    ApplicationBase::initialize(stage);

    if (stage == INITSTAGE_LOCAL) {
        selfMsg = new cMessage("UDPVideoStreamStart");
    }
}

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

inlineoverrideprotectedvirtual

Reimplemented from inet::OperationalBase.

{ return NUM_INIT_STAGES; }

void inet::UDPVideoStreamCli::receiveStream ( cPacket *  msg )

protectedvirtual

Referenced by handleMessageWhenUp().

{
    EV_INFO << "Video stream packet: " << UDPSocket::getReceivedPacketInfo(pk) << endl;
    emit(rcvdPkSignal, pk);
    delete pk;
}

void inet::UDPVideoStreamCli::requestStream ( )

protectedvirtual

Referenced by handleMessageWhenUp().

{
    int svrPort = par("serverPort");
    int localPort = par("localPort");
    const char *address = par("serverAddress");
    L3Address svrAddr = L3AddressResolver().resolve(address);

    if (svrAddr.isUnspecified()) {
        EV_ERROR << "Server address is unspecified, skip sending video stream request\n";
        return;
    }

    EV_INFO << "Requesting video stream from " << svrAddr << ":" << svrPort << "\n";

    socket.setOutputGate(gate("udpOut"));
    socket.bind(localPort);

    cPacket *pk = new cPacket("VideoStrmReq");
    pk->setByteLength(1);   //FIXME set packet length
    socket.sendTo(pk, svrAddr, svrPort);
}

Member Data Documentation

simsignal_t inet::UDPVideoStreamCli::rcvdPkSignal = registerSignal("rcvdPk")

staticprotected

Referenced by receiveStream().

cMessage* inet::UDPVideoStreamCli::selfMsg = nullptr

protected

Referenced by handleNodeCrash(), handleNodeShutdown(), handleNodeStart(), and initialize().

UDPSocket inet::UDPVideoStreamCli::socket

protected

Referenced by requestStream().

---

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

• UDPVideoStreamCli.h
• UDPVideoStreamCli.cc