INET Framework for OMNeT++/OMNEST
RTPPayloadReceiver Class Reference

#include <RTPPayloadReceiver.h>

Inheritance diagram for RTPPayloadReceiver:
RTPAVProfilePayload32Receiver

List of all members.

Protected Member Functions

virtual ~RTPPayloadReceiver ()
virtual void initialize ()
virtual void handleMessage (cMessage *msg)
virtual void processPacket (RTPPacket *packet)
virtual void openOutputFile (const char *fileName)
virtual void closeOutputFile ()

Protected Attributes

std::ofstream _outputFileStream
std::ofstream _outputLogLoss
int _payloadType
cOutVector * _packetArrival

Detailed Description

The class RTPPayloadReceiver acts as a base class for modules processing incoming rtp data packets.


Constructor & Destructor Documentation

RTPPayloadReceiver::~RTPPayloadReceiver ( ) [protected, virtual]

Destructor. Disposes the queue object and closes the output file.


Member Function Documentation

void RTPPayloadReceiver::closeOutputFile ( ) [protected, virtual]

Closes the output file stream.

Referenced by ~RTPPayloadReceiver().

{
    _outputFileStream.close();
    _outputLogLoss.close();
}
void RTPPayloadReceiver::handleMessage ( cMessage *  msg) [protected, virtual]

Method for handling incoming packets. At the moment only RTPInnerPackets containing an encapsulated RTPPacket are handled.

{
    RTPInnerPacket *rinp = check_and_cast<RTPInnerPacket *>(msg);
    if (rinp->getType() == RTPInnerPacket::RTP_INP_DATA_IN) {
        RTPPacket *packet = check_and_cast<RTPPacket *>(rinp->decapsulate());
        processPacket(packet);
        delete rinp;
    }
    else {
        error("RTPInnerPacket of wrong type received");
        delete rinp;
    }
}
void RTPPayloadReceiver::initialize ( ) [protected, virtual]

Initializes the receiver module, opens the output file and creates a queue for incoming packets. Subclasses must overwrite it (but should call this method too)

Reimplemented in RTPAVProfilePayload32Receiver.

{
    const char *fileName = par("outputFileName");
    openOutputFile(fileName);
    char logName[100];
    sprintf (logName, "outputLogLoss%d.log", getId());
    _outputLogLoss.open(logName);
    _packetArrival = new cOutVector("packet arrival");
}
void RTPPayloadReceiver::openOutputFile ( const char *  fileName) [protected, virtual]

This method is called by initialize and opens the output file stream. For most payload receivers this method works well, only when using a library for a payload type which provides an own open method it must

Referenced by initialize().

{
    _outputFileStream.open(fileName);
}
void RTPPayloadReceiver::processPacket ( RTPPacket packet) [protected, virtual]

Writes contents of this RTPPacket into the output file. Must be overwritten by subclasses.

Reimplemented in RTPAVProfilePayload32Receiver.

Referenced by handleMessage().

{
    _packetArrival->record((double)(packet->getTimeStamp()));
}

Member Data Documentation

std::ofstream RTPPayloadReceiver::_outputLogLoss [protected]
cOutVector* RTPPayloadReceiver::_packetArrival [protected]

An output vector used to store arrival of rtp data packets.

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

The payload type this RTPPayloadReceiver module processes.

Referenced by RTPAVProfilePayload32Receiver::initialize().


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