inet::rtp::RTPAVProfilePayload32Receiver Class Reference

This module is used to receive getData(mpeg video) of payload 32 for rtp endsystems working under the rtp av profile. More...

#include <RTPAVProfilePayload32Receiver.h>

Inheritance diagram for inet::rtp::RTPAVProfilePayload32Receiver:

Protected Member Functions
virtual	~RTPAVProfilePayload32Receiver ()
	Destructor. More...
virtual void	initialize () override
	Calls the method of the superclass RTPPayloadReceiver and sets the payload type to 32. More...
virtual void	processPacket (RTPPacket *packet) override
	Writes information about received frames into the output file. More...
Protected Member Functions inherited from inet::rtp::RTPPayloadReceiver
virtual void	handleMessage (cMessage *msg) override
	Method for handling incoming packets. More...
virtual void	openOutputFile (const char *fileName)
	This method is called by initialize and opens the output file stream. More...
virtual void	closeOutputFile ()
	Closes the output file stream. More...

Protected Attributes
cQueue *	_queue
	A reordering queue for incoming packets. More...
uint32	_lowestAllowedTimeStamp
	Stores the lowest allowed time stamp of rtp data packets. More...
uint32	_highestSequenceNumber
Protected Attributes inherited from inet::rtp::RTPPayloadReceiver
std::ofstream	_outputFileStream
	The output file stream. More...
std::ofstream	_outputLogLoss
	The output file stream. More...
int	_payloadType
	The payload type this RTPPayloadReceiver module processes. More...

Additional Inherited Members
Public Member Functions inherited from inet::rtp::RTPPayloadReceiver
virtual	~RTPPayloadReceiver ()
	Destructor. More...
Static Protected Attributes inherited from inet::rtp::RTPPayloadReceiver
static simsignal_t	_rcvdPkRtpTimestampSignal = registerSignal("rcvdPkRtpTimestamp")
	An output signal used to store arrival of rtp data packets. More...

Detailed Description

This module is used to receive getData(mpeg video) of payload 32 for rtp endsystems working under the rtp av profile.

It expects data in the format defined in rfc 2250. Its corresponding sender module is RTPAVProfilePayload32Sender. This implementation doesn't work with real mpeg data, so it doesn't write an mpeg file but a sim file, which can be played with a modified mpeg player.

Constructor & Destructor Documentation

inet::rtp::RTPAVProfilePayload32Receiver::~RTPAVProfilePayload32Receiver ( )

protectedvirtual

Destructor.

{
    delete _queue;
}

Member Function Documentation

void inet::rtp::RTPAVProfilePayload32Receiver::initialize ( )

overrideprotectedvirtual

Calls the method of the superclass RTPPayloadReceiver and sets the payload type to 32.

Reimplemented from inet::rtp::RTPPayloadReceiver.

{
    RTPPayloadReceiver::initialize();
    _payloadType = 32;
    _queue = new cQueue("IncomingQueue", &compareRTPPacketsBySequenceNumber);
    _lowestAllowedTimeStamp = 0;
    _highestSequenceNumber = 0;
}

void inet::rtp::RTPAVProfilePayload32Receiver::processPacket ( RTPPacket *  packet )

overrideprotectedvirtual

Writes information about received frames into the output file.

The only error correction provided is reordering packets of one frame if needed.

Reimplemented from inet::rtp::RTPPayloadReceiver.

{
    // the first packet sets the lowest allowed time stamp
    if (_lowestAllowedTimeStamp == 0) {
        _lowestAllowedTimeStamp = rtpPacket->getTimeStamp();
        _highestSequenceNumber = rtpPacket->getSequenceNumber();
        if (_outputLogLoss.is_open())
        _outputLogLoss << "sequenceNumberBase" << rtpPacket->getSequenceNumber() << endl;
    }
    else if (_outputLogLoss.is_open()) {
        for (int i = _highestSequenceNumber + 1; i < rtpPacket->getSequenceNumber(); i++) {
            //char line[100];
            //sprintf(line, "%i", i);
            _outputLogLoss << i << endl;
        }
    }

    if ((rtpPacket->getTimeStamp() < _lowestAllowedTimeStamp) ||
        (rtpPacket->getSequenceNumber() <= _highestSequenceNumber))
    {
        delete rtpPacket;
    }
    else {
        // is this packet from the next frame ?
        // this can happen when the marked packet has been
        // lost or arrives late
        bool nextTimeStamp = rtpPacket->getTimeStamp() > _lowestAllowedTimeStamp;

        // is this packet marked, which means that it's
        // the last packet of this frame
        bool marked = rtpPacket->getMarker();

        // test if end of frame reached

        // check if we received the last (= marked)
        // packet of the frame or
        // we received a packet of the next frame
        _highestSequenceNumber = rtpPacket->getSequenceNumber();

        if (nextTimeStamp || marked) {
            // a marked packet belongs to this frame
            if (marked && !nextTimeStamp) {
                _queue->insert(rtpPacket);
            }

            int pictureType = 0;
            int frameSize = 0;

            // the queue contains all packets for this frame
            // we have received
            while (!_queue->isEmpty()) {
                RTPPacket *readPacket = (RTPPacket *)(_queue->pop());
                RTPMpegPacket *mpegPacket = (RTPMpegPacket *)(readPacket->decapsulate());
                if (pictureType == 0)
                    pictureType = mpegPacket->getPictureType();
                frameSize = frameSize + mpegPacket->getPayloadLength();

                delete mpegPacket;
                delete readPacket;
            }

            // we start the next frame
            // set the allowed time stamp
            if (nextTimeStamp) {
                _lowestAllowedTimeStamp = rtpPacket->getTimeStamp();
                _queue->insert(rtpPacket);
            }

            // we have calculated a frame
            if (frameSize > 0 && _outputFileStream.is_open()) {
                char line[100];
                // what picture type is it
                char picture;
                switch (pictureType) {
                    case 1:
                        picture = 'I';
                        break;

                    case 2:
                        picture = 'P';
                        break;

                    case 3:
                        picture = 'B';
                        break;

                    case 4:
                        picture = 'D';
                        break;

                    default:
                        picture = ' ';
                        break;
                }

                // create sim line
                sprintf(line, "%f %i %c-Frame", simTime().dbl(), frameSize * 8, picture);
                // and write it to the file
                _outputFileStream << line << endl;
            }
        }
        else {
            // we are not at the end of the frame
            // so just insert this packet
            _queue->insert(rtpPacket);
        }
    }
}

Member Data Documentation

uint32 inet::rtp::RTPAVProfilePayload32Receiver::_highestSequenceNumber

protected

Referenced by initialize(), and processPacket().

uint32 inet::rtp::RTPAVProfilePayload32Receiver::_lowestAllowedTimeStamp

protected

Stores the lowest allowed time stamp of rtp data packets.

The value is used to throw away packets from mpeg frames already stored in the data file.

Referenced by initialize(), and processPacket().

cQueue* inet::rtp::RTPAVProfilePayload32Receiver::_queue

protected

A reordering queue for incoming packets.

Referenced by initialize(), processPacket(), and ~RTPAVProfilePayload32Receiver().

---

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

• RTPAVProfilePayload32Receiver.h
• RTPAVProfilePayload32Receiver.cc