inet::UDPVideoStreamSvr Class Reference

Stream VBR video streams to clients. More...

#include <UDPVideoStreamSvr.h>

Inheritance diagram for inet::UDPVideoStreamSvr:

Classes
struct	VideoStreamData

Public Member Functions
	UDPVideoStreamSvr ()
virtual	~UDPVideoStreamSvr ()
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 Types
typedef std::map< long int, VideoStreamData >	VideoStreamMap

Protected Member Functions
virtual void	processStreamRequest (cMessage *msg)
virtual void	sendStreamData (cMessage *timer)
virtual int	numInitStages () const override
virtual void	initialize (int stage) override
virtual void	finish () override
virtual void	handleMessageWhenUp (cMessage *msg) override
virtual void	clearStreams ()
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
VideoStreamMap	streams
UDPSocket	socket
int	localPort = -1
cPar *	sendInterval = nullptr
cPar *	packetLen = nullptr
cPar *	videoSize = nullptr
unsigned int	numStreams = 0
unsigned long	numPkSent = 0
Protected Attributes inherited from inet::OperationalBase
bool	isOperational
simtime_t	lastChange

Static Protected Attributes
static simsignal_t	reqStreamBytesSignal = registerSignal("reqStreamBytes")
static simsignal_t	sentPkSignal = registerSignal("sentPk")

Detailed Description

Stream VBR video streams to clients.

Cooperates with UDPVideoStreamCli. UDPVideoStreamCli requests a stream and UDPVideoStreamSvr starts streaming to them. Capable of handling streaming to multiple clients.

Member Typedef Documentation

typedef std::map<long int, VideoStreamData> inet::UDPVideoStreamSvr::VideoStreamMap

protected

Constructor & Destructor Documentation

inet::UDPVideoStreamSvr::UDPVideoStreamSvr ( )

inline

{}

inet::UDPVideoStreamSvr::~UDPVideoStreamSvr ( )

virtual

{
    for (auto & elem : streams)
        cancelAndDelete(elem.second.timer);
}

Member Function Documentation

void inet::UDPVideoStreamSvr::clearStreams ( )

protectedvirtual

Referenced by handleNodeCrash(), and handleNodeShutdown().

{
    for (auto & elem : streams)
        cancelAndDelete(elem.second.timer);
    streams.clear();
}

void inet::UDPVideoStreamSvr::finish ( )

overrideprotectedvirtual

{
}

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

overrideprotectedvirtual

Implements inet::OperationalBase.

{
    if (msg->isSelfMessage()) {
        // timer for a particular video stream expired, send packet
        sendStreamData(msg);
    }
    else if (msg->getKind() == UDP_I_DATA) {
        // start streaming
        processStreamRequest(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::UDPVideoStreamSvr::handleNodeCrash ( )

overrideprotectedvirtual

Reimplemented from inet::OperationalBase.

{
    clearStreams();
}

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

overrideprotectedvirtual

Reimplemented from inet::OperationalBase.

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

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

overrideprotectedvirtual

Reimplemented from inet::OperationalBase.

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

    return true;
}

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

overrideprotectedvirtual

Reimplemented from inet::OperationalBase.

{
    ApplicationBase::initialize(stage);

    if (stage == INITSTAGE_LOCAL) {
        sendInterval = &par("sendInterval");
        packetLen = &par("packetLen");
        videoSize = &par("videoSize");
        localPort = par("localPort");

        // statistics
        numStreams = 0;
        numPkSent = 0;

        WATCH_MAP(streams);
    }
}

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

inlineoverrideprotectedvirtual

Reimplemented from inet::OperationalBase.

{ return NUM_INIT_STAGES; }

void inet::UDPVideoStreamSvr::processStreamRequest ( cMessage *  msg )

protectedvirtual

Referenced by handleMessageWhenUp().

{
    // register video stream...
    UDPDataIndication *ctrl = check_and_cast<UDPDataIndication *>(msg->getControlInfo());

    cMessage *timer = new cMessage("VideoStreamTmr");
    VideoStreamData *d = &streams[timer->getId()];
    d->timer = timer;
    d->clientAddr = ctrl->getSrcAddr();
    d->clientPort = ctrl->getSrcPort();
    d->videoSize = (*videoSize);
    d->bytesLeft = d->videoSize;
    d->numPkSent = 0;
    ASSERT(d->videoSize > 0);
    delete msg;

    numStreams++;
    emit(reqStreamBytesSignal, d->videoSize);

    // ... then transmit first packet right away
    sendStreamData(timer);
}

void inet::UDPVideoStreamSvr::sendStreamData ( cMessage *  timer )

protectedvirtual

Referenced by handleMessageWhenUp(), and processStreamRequest().

{
    auto it = streams.find(timer->getId());
    if (it == streams.end())
        throw cRuntimeError("Model error: Stream not found for timer");

    VideoStreamData *d = &(it->second);

    // generate and send a packet
    cPacket *pkt = new cPacket("VideoStrmPk");
    long pktLen = packetLen->longValue();

    if (pktLen > d->bytesLeft)
        pktLen = d->bytesLeft;

    pkt->setByteLength(pktLen);
    emit(sentPkSignal, pkt);
    socket.sendTo(pkt, d->clientAddr, d->clientPort);

    d->bytesLeft -= pktLen;
    d->numPkSent++;
    numPkSent++;

    // reschedule timer if there's bytes left to send
    if (d->bytesLeft > 0) {
        simtime_t interval = (*sendInterval);
        scheduleAt(simTime() + interval, timer);
    }
    else {
        streams.erase(it);
        delete timer;
    }
}

Member Data Documentation

int inet::UDPVideoStreamSvr::localPort = -1

protected

Referenced by handleNodeStart(), and initialize().

unsigned long inet::UDPVideoStreamSvr::numPkSent = 0

protected

Referenced by initialize(), and sendStreamData().

unsigned int inet::UDPVideoStreamSvr::numStreams = 0

protected

Referenced by initialize(), and processStreamRequest().

cPar* inet::UDPVideoStreamSvr::packetLen = nullptr

protected

Referenced by initialize(), and sendStreamData().

simsignal_t inet::UDPVideoStreamSvr::reqStreamBytesSignal = registerSignal("reqStreamBytes")

staticprotected

Referenced by processStreamRequest().

cPar* inet::UDPVideoStreamSvr::sendInterval = nullptr

protected

Referenced by initialize().

simsignal_t inet::UDPVideoStreamSvr::sentPkSignal = registerSignal("sentPk")

staticprotected

Referenced by sendStreamData().

UDPSocket inet::UDPVideoStreamSvr::socket

protected

Referenced by handleNodeStart(), and sendStreamData().

VideoStreamMap inet::UDPVideoStreamSvr::streams

protected

Referenced by clearStreams(), initialize(), processStreamRequest(), sendStreamData(), and ~UDPVideoStreamSvr().

cPar* inet::UDPVideoStreamSvr::videoSize = nullptr

protected

Referenced by initialize().

---

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

• UDPVideoStreamSvr.h
• UDPVideoStreamSvr.cc