inet::rtp::RTPAVProfilePayload32Sender Class Reference

An RTPAVProfilePayload32Sender is a module for sending data of payload type 32 in the rtp audio/video profile, which is mpeg video. More...

#include <RTPAVProfilePayload32Sender.h>

Inheritance diagram for inet::rtp::RTPAVProfilePayload32Sender:

Protected Member Functions
virtual void	initialize () override
	Initializes the module. More...
virtual void	initializeSenderModule (RTPInnerPacket *rinpIn) override
	The main method. More...
virtual bool	sendPacket () override
	This method sends one mpeg frame. More...
Protected Member Functions inherited from inet::rtp::RTPPayloadSender
virtual void	handleMessage (cMessage *msg) override
virtual void	openSourceFile (const char *fileName)
	This method is called by initializeSenderModule and opens the source data file as an inputFileStream stored in member variable _inputFileStream. More...
virtual void	closeSourceFile ()
	This method is called by the destructor and closes the data file. More...
virtual void	play ()
	Starts data transmission. More...
virtual void	playUntilTime (simtime_t moment)
	Starts transmission from the current file position and plays until given time (relative to start of file) is reached. More...
virtual void	playUntilByte (int position)
	Starts transmission from the current file position and plays until given byte position (excluding file header) is reached. More...
virtual void	pause ()
	When data is being transmitted this methods suspends till a new PLAY command. More...
virtual void	seekTime (simtime_t moment)
	When the data transmission is paused the current position is changed to this time (relative to start of file). More...
virtual void	seekByte (int position)
	When the data transmission is paused the current position is changed to this byte position (excluding file header). More...
virtual void	stop ()
	This method stop data transmission and resets the sender module so that a following PLAY command would start the transmission at the beginning again. More...
virtual void	endOfFile ()
	This method gets called when the sender module reaches the end of file. More...

Protected Attributes
double	_initialDelay
	The initial delay of the mpeg video. More...
double	_framesPerSecond
	The number of frames per second of the mpeg video. More...
double	_frameNumber
	The number of the current mpeg frame. More...
Protected Attributes inherited from inet::rtp::RTPPayloadSender
std::ifstream	_inputFileStream
	The input file stream for the data file. More...
int	_mtu = 0
	The maximum size of an RTPPacket. More...
uint32	_ssrc = 0
	The ssrc identifier of this sender module. More...
int	_payloadType = -1
	The payload type this sender creates. More...
int	_clockRate = 0
	The clock rate in ticks per second this sender uses. More...
uint32	_timeStampBase = 0
	The first rtp time stamp used for created rtp data packets. More...
uint32	_timeStamp = 0
	The current rtp time stamp. More...
uint16	_sequenceNumberBase = 0
	The first sequence number used for created rtp data packets. More...
uint16	_sequenceNumber = 0
	The current sequence number. More...
SenderStatus	_status = (SenderStatus)-1
	The current state of data transmission. More...
cMessage *	_reminderMessage = nullptr
	A self message used as timer for the moment the next packet must be sent. More...

Additional Inherited Members
Public Member Functions inherited from inet::rtp::RTPPayloadSender
	RTPPayloadSender ()
	Constructor. More...
virtual	~RTPPayloadSender ()
	Destructor. More...
Protected Types inherited from inet::rtp::RTPPayloadSender
enum	SenderStatus { STOPPED, PLAYING }
	A sender module's transmission can be in different states. More...

Detailed Description

An RTPAVProfilePayload32Sender is a module for sending data of payload type 32 in the rtp audio/video profile, which is mpeg video.

This implementation doesn't send real mpeg data it just reads the gdf file created by Mpeg_Stat and sends rtp data packets which contain an RTPMpegPacket. The corresponding receiver module RTPAVProfilePayload32Receiver.

Member Function Documentation

void inet::rtp::RTPAVProfilePayload32Sender::initialize ( )

overrideprotectedvirtual

Initializes the module.

It sets the values for clock rate and payload type.

Reimplemented from inet::rtp::RTPPayloadSender.

{
    RTPPayloadSender::initialize();

    _clockRate = 90000;
    _payloadType = 32;
}

void inet::rtp::RTPAVProfilePayload32Sender::initializeSenderModule ( RTPInnerPacket *  rinpIn )

overrideprotectedvirtual

The main method.

This method reads the gdf file header.

Reimplemented from inet::rtp::RTPPayloadSender.

{
    EV_TRACE << "initializeSenderModule Enter" << endl;
    char line[100];
    char unit[100];
    char description[100];

    RTPPayloadSender::initializeSenderModule(rinpIn);

    // first line: fps unit description
    _inputFileStream.get(line, 100, '\n');

    float fps;
    sscanf(line, "%f %s %s", &fps, unit, description);
    _framesPerSecond = fps;

    _frameNumber = 0;

    // get new line character
    char c;
    _inputFileStream.get(c);

    // second line: initial delay unit description
    _inputFileStream.get(line, 100, '\n');

    float delay;
    sscanf(line, "%f %s %s", &delay, unit, description);

    _initialDelay = delay;

    // wait initial delay
    // cPacket *reminderMessage = new cMessage("next frame");
    // scheduleAt(simTime() + _initialDelay, reminderMessage);
    EV_TRACE << "initializeSenderModule Exit" << endl;
}

bool inet::rtp::RTPAVProfilePayload32Sender::sendPacket ( )

overrideprotectedvirtual

This method sends one mpeg frame.

It sends one or more rtp data packet. Returns false if there were no more frames.

Reimplemented from inet::rtp::RTPPayloadSender.

{
    EV_TRACE << "sendPacket() " << endl;
    // read next frame line
    int bits;
    char unit[100];
    char description[100];
    bool ret;

    _inputFileStream >> bits;
    _inputFileStream >> unit;
    _inputFileStream.get(description, 100, '\n');

    int pictureType;
    char *ptr;

    for (ptr = description; *ptr == ' ' || *ptr == '\t' ; ptr++)
        ;
    switch (*ptr) {
        case 'I':
            pictureType = 1;
            break;

        case 'P':
            pictureType = 2;
            break;

        case 'B':
            pictureType = 3;
            break;

        case 'D':
            pictureType = 4;
            break;

        default:
            pictureType = 0;
            break;
    }

    int bytesRemaining = bits / 8;

    if (!_inputFileStream.eof()) {
        while (bytesRemaining > 0) {
            RTPPacket *rtpPacket = new RTPPacket("RTPPacket");
            RTPMpegPacket *mpegPacket = new RTPMpegPacket("MpegPacket");

            // the only mpeg information we know is the picture type
            mpegPacket->setPictureType(pictureType);

            // the maximum number of real data bytes
            int maxDataSize = _mtu - rtpPacket->getByteLength() - mpegPacket->getByteLength();

            if (bytesRemaining > maxDataSize) {
                // we do not know where slices in the
                // mpeg picture begin
                // so we simulate by assuming a slice
                // has a length of 64 bytes
                int slicedDataSize = (maxDataSize / 64) * 64;

                mpegPacket->setPayloadLength(slicedDataSize);
                mpegPacket->addByteLength(slicedDataSize);

                rtpPacket->encapsulate(mpegPacket);

                bytesRemaining = bytesRemaining - slicedDataSize;
            }
            else {
                mpegPacket->setPayloadLength(bytesRemaining);
                mpegPacket->addByteLength(bytesRemaining);
                rtpPacket->encapsulate(mpegPacket);
                // set marker because this is
                // the last packet of the frame
                rtpPacket->setMarker(1);
                bytesRemaining = 0;
            }

            rtpPacket->setPayloadType(_payloadType);
            rtpPacket->setSequenceNumber(_sequenceNumber);
            _sequenceNumber++;

            rtpPacket->setTimeStamp(_timeStampBase + (_initialDelay + (1 / _framesPerSecond) * (double)_frameNumber) * _clockRate);
            rtpPacket->setSsrc(_ssrc);

            RTPInnerPacket *rinpOut = new RTPInnerPacket("dataOut()");

            rinpOut->setDataOutPkt(rtpPacket);

            send(rinpOut, "profileOut");
        }
        _frameNumber++;

        _reminderMessage = new cMessage("nextFrame");
        scheduleAt(simTime() + 1.0 / _framesPerSecond, _reminderMessage);
        ret = true;
    }
    else {
        std::cout << "LastSequenceNumber " << _sequenceNumber << endl;
        ret = false;
    }
    EV_TRACE << "sendPacket() Exit" << endl;
    return ret;
}

Member Data Documentation

double inet::rtp::RTPAVProfilePayload32Sender::_frameNumber

protected

The number of the current mpeg frame.

Needed for calculating the rtp time stamp in the rtp data packets.

Referenced by initializeSenderModule(), and sendPacket().

double inet::rtp::RTPAVProfilePayload32Sender::_framesPerSecond

protected

The number of frames per second of the mpeg video.

Referenced by initializeSenderModule(), and sendPacket().

double inet::rtp::RTPAVProfilePayload32Sender::_initialDelay

protected

The initial delay of the mpeg video.

Referenced by initializeSenderModule(), and sendPacket().

---

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

• RTPAVProfilePayload32Sender.h
• RTPAVProfilePayload32Sender.cc