inet::VoipStreamReceiver::Connection Class Reference

#include <VoipStreamReceiver.h>

Public Member Functions
	Connection ()
void	addAudioStream (enum AVCodecID codec_id)
void	openAudio (const char *fileName)
void	writeAudioFrame (uint8_t *buf, int len)
void	writeLostSamples (int sampleCount)
void	closeAudio ()

Public Attributes
bool	offline = true
uint16_t	seqNo = 0
uint32_t	timeStamp = 0
uint32_t	ssrc = 0
enum AVCodecID	codec = AV_CODEC_ID_NONE
short	sampleBits = 0
int	sampleRate = 0
int	samplesPerPacket = 0
int	transmitBitrate = 0
simtime_t	lastPacketFinish
AVFormatContext *	oc = nullptr
AVOutputFormat *	fmt = nullptr
AVStream *	audio_st = nullptr
AVCodecContext *	decCtx = nullptr
AVCodec *	pCodecDec = nullptr
AudioOutFile	outFile
L3Address	srcAddr
int	srcPort = -1
L3Address	destAddr
int	destPort = -1

Constructor & Destructor Documentation

Connection()

inet::VoipStreamReceiver::Connection::Connection ( )

inline

{}

Member Function Documentation

addAudioStream()

void inet::VoipStreamReceiver::Connection::addAudioStream

(

enum AVCodecID

codec_id

)

closeAudio()

void inet::VoipStreamReceiver::Connection::closeAudio

(

)

{
    outFile.close();
}

openAudio()

void inet::VoipStreamReceiver::Connection::openAudio

(

const char *

fileName

)

{
    outFile.open(fileName, sampleRate, 8 * av_get_bytes_per_sample(decCtx->sample_fmt));
}

Referenced by inet::VoipStreamReceiver::createConnection().

writeAudioFrame()

void inet::VoipStreamReceiver::Connection::writeAudioFrame	(	uint8_t *	buf,
		int	len
	)

{
    AVPacket avpkt;
    av_init_packet(&avpkt);
    avpkt.data = inbuf;
    avpkt.size = inbytes;
 
    int gotFrame;
    AVFrame decodedFrame = {
        { nullptr }
    };
    int consumedBytes = avcodec_decode_audio4(decCtx, &decodedFrame, &gotFrame, &avpkt);
    if (consumedBytes < 0 || !gotFrame)
        throw cRuntimeError("Error in avcodec_decode_audio4(): returns: %d, gotFrame: %d", consumedBytes, gotFrame);
    if (consumedBytes != inbytes)
        throw cRuntimeError("Model error: remained bytes after avcodec_decode_audio4(): %d = ( %d - %d )", inbytes - consumedBytes, inbytes, consumedBytes);
    simtime_t decodedTime(1.0 * decodedFrame.nb_samples / sampleRate);
    lastPacketFinish += decodedTime;
    if (outFile.isOpen())
        outFile.write(decodedFrame.data[0], decodedFrame.linesize[0]);
}

Referenced by inet::VoipStreamReceiver::decodePacket().

writeLostSamples()

void inet::VoipStreamReceiver::Connection::writeLostSamples

(

int

sampleCount

)

{
    int pktBytes = sampleCount * av_get_bytes_per_sample(decCtx->sample_fmt);
    if (outFile.isOpen()) {
        uint8_t decBuf[pktBytes];
        memset(decBuf, 0, pktBytes);
        outFile.write(decBuf, pktBytes);
    }
}

Referenced by inet::VoipStreamReceiver::decodePacket().

Member Data Documentation

audio_st

AVStream* inet::VoipStreamReceiver::Connection::audio_st = nullptr

codec

enum AVCodecID inet::VoipStreamReceiver::Connection::codec = AV_CODEC_ID_NONE

Referenced by inet::VoipStreamReceiver::checkSourceAndParameters(), and inet::VoipStreamReceiver::createConnection().

decCtx

AVCodecContext* inet::VoipStreamReceiver::Connection::decCtx = nullptr

Referenced by inet::VoipStreamReceiver::closeConnection(), inet::VoipStreamReceiver::createConnection(), and openAudio().

destAddr

L3Address inet::VoipStreamReceiver::Connection::destAddr

Referenced by inet::VoipStreamReceiver::checkSourceAndParameters(), and inet::VoipStreamReceiver::createConnection().

destPort

int inet::VoipStreamReceiver::Connection::destPort = -1

Referenced by inet::VoipStreamReceiver::checkSourceAndParameters(), and inet::VoipStreamReceiver::createConnection().

fmt

AVOutputFormat* inet::VoipStreamReceiver::Connection::fmt = nullptr

lastPacketFinish

simtime_t inet::VoipStreamReceiver::Connection::lastPacketFinish

Referenced by inet::VoipStreamReceiver::createConnection(), and inet::VoipStreamReceiver::decodePacket().

oc

AVFormatContext* inet::VoipStreamReceiver::Connection::oc = nullptr

offline

bool inet::VoipStreamReceiver::Connection::offline = true

Referenced by inet::VoipStreamReceiver::checkSourceAndParameters(), inet::VoipStreamReceiver::closeConnection(), inet::VoipStreamReceiver::createConnection(), and inet::VoipStreamReceiver::socketDataArrived().

outFile

AudioOutFile inet::VoipStreamReceiver::Connection::outFile

Referenced by inet::VoipStreamReceiver::closeConnection(), and openAudio().

pCodecDec

AVCodec* inet::VoipStreamReceiver::Connection::pCodecDec = nullptr

Referenced by inet::VoipStreamReceiver::createConnection().

sampleBits

short inet::VoipStreamReceiver::Connection::sampleBits = 0

Referenced by inet::VoipStreamReceiver::checkSourceAndParameters(), and inet::VoipStreamReceiver::createConnection().

sampleRate

int inet::VoipStreamReceiver::Connection::sampleRate = 0

Referenced by inet::VoipStreamReceiver::checkSourceAndParameters(), inet::VoipStreamReceiver::createConnection(), inet::VoipStreamReceiver::decodePacket(), and openAudio().

samplesPerPacket

int inet::VoipStreamReceiver::Connection::samplesPerPacket = 0

Referenced by inet::VoipStreamReceiver::checkSourceAndParameters(), and inet::VoipStreamReceiver::createConnection().

seqNo

uint16_t inet::VoipStreamReceiver::Connection::seqNo = 0

Referenced by inet::VoipStreamReceiver::createConnection(), inet::VoipStreamReceiver::decodePacket(), and inet::VoipStreamReceiver::socketDataArrived().

srcAddr

L3Address inet::VoipStreamReceiver::Connection::srcAddr

Referenced by inet::VoipStreamReceiver::checkSourceAndParameters(), and inet::VoipStreamReceiver::createConnection().

srcPort

int inet::VoipStreamReceiver::Connection::srcPort = -1

Referenced by inet::VoipStreamReceiver::checkSourceAndParameters(), and inet::VoipStreamReceiver::createConnection().

ssrc

uint32_t inet::VoipStreamReceiver::Connection::ssrc = 0

Referenced by inet::VoipStreamReceiver::checkSourceAndParameters(), and inet::VoipStreamReceiver::createConnection().

timeStamp

uint32_t inet::VoipStreamReceiver::Connection::timeStamp = 0

Referenced by inet::VoipStreamReceiver::createConnection(), and inet::VoipStreamReceiver::socketDataArrived().

transmitBitrate

int inet::VoipStreamReceiver::Connection::transmitBitrate = 0

Referenced by inet::VoipStreamReceiver::checkSourceAndParameters(), and inet::VoipStreamReceiver::createConnection().

---

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

• VoipStreamReceiver.h
• VoipStreamReceiver.cc