#include <datvideorender.h>

Inheritance diagram for DATVideoRender:

Collaboration diagram for DATVideoRender:

Signals
void	onMetaDataChanged (DataTSMetaData2 *metaData)

Signals inherited from TVScreen
void	traceSizeChanged (int)

void	sampleRateChanged (int)

Public Member Functions
	DATVideoRender (QWidget *parent)

	~DATVideoRender ()

void	SetFullScreen (bool blnFullScreen)

bool	OpenStream (DATVideostream *objDevice)

bool	RenderStream ()

bool	CloseStream (QIODevice *objDevice)

void	setAudioFIFO (AudioFifo *fifo)

int	getVideoStreamIndex () const

int	getAudioStreamIndex () const

void	setAudioMute (bool audioMute)

void	setVideoMute (bool videoMute)

void	setAudioVolume (int audioVolume)

bool	getAudioDecodeOK () const

bool	getVideoDecodeOK () const

Public Member Functions inherited from TVScreen
	TVScreen (bool blnColor, QWidget *parent=0)

virtual	~TVScreen ()

void	setColor (bool blnColor)

void	resizeTVScreen (int intCols, int intRows)

void	getSize (int &intCols, int &intRows) const

void	renderImage (unsigned char *objData)

QRgb *	getRowBuffer (int intRow)

void	resetImage ()

void	resetImage (int alpha)

bool	selectRow (int intLine)

bool	setDataColor (int intCol, int intRed, int intGreen, int intBlue)

bool	setDataColor (int intCol, int intRed, int intGreen, int intBlue, int intAlpha)

void	setAlphaBlend (bool blnAlphaBlend)

void	setAlphaReset ()

void	connectTimer (const QTimer &timer)

Public Attributes
struct DataTSMetaData2	MetaData

Protected Member Functions
virtual bool	eventFilter (QObject obj, QEvent event)

Private Member Functions
bool	InitializeFFMPEG ()

bool	PreprocessStream ()

void	ResetMetaData ()

int	new_decode (AVCodecContext avctx, AVFrame frame, int got_frame, AVPacket pkt)

void	setResampler ()

Private Attributes
QWidget *	m_parentWidget

Qt::WindowFlags	m_originalWindowFlags

QSize	m_originalSize

bool	m_running

bool	m_isFullScreen

bool	m_isFFMPEGInitialized

bool	m_isOpen

SwsContext *	m_swsCtx

AVFormatContext *	m_formatCtx

AVCodecContext *	m_videoDecoderCtx

AVCodecContext *	m_audioDecoderCtx

AVFrame *	m_frame

AudioFifo *	m_audioFifo

struct SwrContext *	m_audioSWR

int	m_audioSampleRate

int16_t	m_audioFifoBuffer [m_audioFifoBufferSize *2]

int	m_audioFifoBufferIndex

bool	m_audioMute

bool	m_videoMute

float	m_audioVolume

bool	m_updateAudioResampler

uint8_t *	m_pbytDecodedData [4]

int	m_pintDecodedLineSize [4]

int	m_frameCount

int	m_videoStreamIndex

int	m_audioStreamIndex

int	m_currentRenderWidth

int	m_currentRenderHeight

bool	m_audioDecodeOK

bool	m_videoDecodeOK

Static Private Attributes
static const int	m_audioFifoBufferSize = 16000

Additional Inherited Members
Static Public Attributes inherited from TVScreen
static const int	TV_COLS =256

static const int	TV_ROWS =256

Protected Slots inherited from TVScreen
void	cleanup ()

void	tick ()

Detailed Description

Definition at line 85 of file datvideorender.h.

Constructor & Destructor Documentation

◆ DATVideoRender()

DATVideoRender::DATVideoRender ( QWidget * parent )

explicit

Definition at line 32 of file datvideorender.cpp.

References m_audioDecodeOK, m_audioDecoderCtx, m_audioFifo, m_audioFifoBufferIndex, m_audioMute, m_audioSampleRate, m_audioStreamIndex, m_audioSWR, m_audioVolume, m_currentRenderHeight, m_currentRenderWidth, m_formatCtx, m_frame, m_frameCount, m_isFFMPEGInitialized, m_isFullScreen, m_isOpen, m_running, m_swsCtx, m_updateAudioResampler, m_videoDecodeOK, m_videoDecoderCtx, m_videoMute, and m_videoStreamIndex.

                                               : TVScreen(true, parent), m_parentWidget(parent)
 {
     installEventFilter(this);
     m_isFullScreen = false;
     m_running = false;
 
     m_isFFMPEGInitialized = false;
     m_isOpen = false;
     m_formatCtx = nullptr;
     m_videoDecoderCtx = nullptr;
     m_audioDecoderCtx = nullptr;
     m_swsCtx = nullptr;
     m_audioFifo = nullptr;
     m_audioSWR = nullptr;
     m_audioSampleRate = 48000;
     m_audioFifoBufferIndex = 0;
     m_videoStreamIndex = -1;
     m_audioStreamIndex = -1;
     m_audioMute = false;
     m_videoMute = false;
     m_audioVolume = 0;
     m_updateAudioResampler = false;
 
     m_currentRenderWidth = -1;
     m_currentRenderHeight = -1;
 
     m_frame = nullptr;
     m_frameCount = -1;
 
     m_audioDecodeOK = false;
     m_videoDecodeOK = false;
 
     // for (int i = 0; i < m_audioFifoBufferSize; i++)
     // {
     //     m_audioFifoBuffer[2*i]   = 8192.0f * sin((M_PI * i)/(m_audioFifoBufferSize/1000.0f));
     //     m_audioFifoBuffer[2*i+1] = m_audioFifoBuffer[2*i];
     // }
 }

◆ ~DATVideoRender()

DATVideoRender::~DATVideoRender ( )

Definition at line 71 of file datvideorender.cpp.

References m_audioSWR.

 {
     if (m_audioSWR) {
         swr_free(&m_audioSWR);
     }
 }

Member Function Documentation

◆ CloseStream()

bool DATVideoRender::CloseStream ( QIODevice * objDevice )

Definition at line 715 of file datvideorender.cpp.

References m_currentRenderHeight, m_currentRenderWidth, m_formatCtx, m_frame, m_isOpen, m_running, m_swsCtx, m_videoDecoderCtx, MetaData, onMetaDataChanged(), and ResetMetaData().

 {
 
     if (m_running)
     {
         return false;
     }
 
     if (!device)
     {
         qDebug() << "DATVideoRender::CloseStream QIODevice is nullptr";
         return false;
     }
 
     if (!m_isOpen)
     {
         qDebug() << "DATVideoRender::CloseStream Stream not open";
         return false;
     }
 
     if (!m_formatCtx)
     {
         qDebug() << "DATVideoRender::CloseStream FFMEG Context is not initialized";
         return false;
     }
 
     //Only once execution
     m_running = true;
 
     // maybe done in the avcodec_close
     //    avformat_close_input(&m_formatCtx);
     //    m_formatCtx=nullptr;
 
     if (m_videoDecoderCtx)
     {
         avcodec_close(m_videoDecoderCtx);
         m_videoDecoderCtx = nullptr;
     }
 
     if (m_frame)
     {
         av_frame_unref(m_frame);
         av_frame_free(&m_frame);
     }
 
     if (m_swsCtx != nullptr)
     {
         sws_freeContext(m_swsCtx);
         m_swsCtx = nullptr;
     }
 
     device->close();
     m_isOpen = false;
     m_running = false;
     m_currentRenderWidth = -1;
     m_currentRenderHeight = -1;
 
     ResetMetaData();
     emit onMetaDataChanged(&MetaData);
 
     return true;
 }

Here is the call graph for this function:

◆ eventFilter()

bool DATVideoRender::eventFilter	(	QObject *	obj,
		QEvent *	event
	)

protectedvirtual

Definition at line 78 of file datvideorender.cpp.

References SetFullScreen().

 {
     if (event->type() == QEvent::MouseButtonRelease)
     {
         SetFullScreen(false);
         return true;
     }
     else
     {
         // standard event processing
         return QObject::eventFilter(obj, event);
     }
 }

Here is the call graph for this function:

◆ getAudioDecodeOK()

bool DATVideoRender::getAudioDecodeOK ( ) const

inline

Definition at line 107 of file datvideorender.h.

Referenced by DATVDemod::audioDecodeOK().

107 { return m_audioDecodeOK; }

DATVideoRender::m_audioDecodeOK

bool m_audioDecodeOK

Definition: datvideorender.h:149

Here is the caller graph for this function:

◆ getAudioStreamIndex()

int DATVideoRender::getAudioStreamIndex ( ) const

inline

Definition at line 101 of file datvideorender.h.

Referenced by DATVDemod::audioActive().

101 { return m_audioStreamIndex; }

DATVideoRender::m_audioStreamIndex

int m_audioStreamIndex

Definition: datvideorender.h:144

Here is the caller graph for this function:

◆ getVideoDecodeOK()

bool DATVideoRender::getVideoDecodeOK ( ) const

inline

Definition at line 108 of file datvideorender.h.

Referenced by DATVDemod::videoDecodeOK().

108 { return m_videoDecodeOK; }

DATVideoRender::m_videoDecodeOK

bool m_videoDecodeOK

Definition: datvideorender.h:150

Here is the caller graph for this function:

◆ getVideoStreamIndex()

int DATVideoRender::getVideoStreamIndex ( ) const

inline

Definition at line 100 of file datvideorender.h.

Referenced by DATVDemod::videoActive().

100 { return m_videoStreamIndex; }

DATVideoRender::m_videoStreamIndex

int m_videoStreamIndex

Definition: datvideorender.h:143

Here is the caller graph for this function:

◆ InitializeFFMPEG()

bool DATVideoRender::InitializeFFMPEG ( )

private

Definition at line 177 of file datvideorender.cpp.

References m_isFFMPEGInitialized, and ResetMetaData().

Referenced by OpenStream().

 {
     ResetMetaData();
 
     if (m_isFFMPEGInitialized)
     {
         return false;
     }
 
     avcodec_register_all();
     av_register_all();
     av_log_set_level(AV_LOG_FATAL);
     //av_log_set_level(AV_LOG_ERROR);
 
     m_isFFMPEGInitialized = true;
 
     return true;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

◆ new_decode()

int DATVideoRender::new_decode	(	AVCodecContext *	avctx,
		AVFrame *	frame,
		int *	got_frame,
		AVPacket *	pkt
	)

private

Replacement of deprecated avcodec_decode_video2 with the same signature https://blogs.gentoo.org/lu_zero/2016/03/29/new-avcodec-api/

Definition at line 782 of file datvideorender.cpp.

Referenced by RenderStream().

 {
     int ret;
 
     *got_frame = 0;
 
     if (pkt)
     {
         ret = avcodec_send_packet(avctx, pkt);
         // In particular, we don't expect AVERROR(EAGAIN), because we read all
         // decoded frames with avcodec_receive_frame() until done.
         if (ret < 0)
         {
             return ret == AVERROR_EOF ? 0 : ret;
         }
     }
 
     ret = avcodec_receive_frame(avctx, frame);
 
     if (ret < 0 && ret != AVERROR(EAGAIN) && ret != AVERROR_EOF)
     {
         return ret;
     }
 
     if (ret >= 0)
     {
         *got_frame = 1;
     }
 
     return 0;
 }

Here is the caller graph for this function:

◆ onMetaDataChanged

void DATVideoRender::onMetaDataChanged ( DataTSMetaData2 * metaData )

signal

Referenced by CloseStream(), DATVDemodGUI::DATVDemodGUI(), OpenStream(), PreprocessStream(), RenderStream(), and ResetMetaData().

Here is the caller graph for this function:

◆ OpenStream()

bool DATVideoRender::OpenStream ( DATVideostream * objDevice )

Definition at line 378 of file datvideorender.cpp.

References DATVideostream::bytesAvailable(), InitializeFFMPEG(), m_formatCtx, m_isFFMPEGInitialized, m_isOpen, m_running, MetaData, DataTSMetaData2::OK_Data, onMetaDataChanged(), and DATVideostream::open().

 {
     int ioBufferSize = 32768;
     unsigned char *ptrIOBuffer = nullptr;
     AVIOContext *ioCtx = nullptr;
 
     if (m_running)
     {
         return false;
     }
 
     if (device == nullptr)
     {
         qDebug() << "DATVideoRender::OpenStream QIODevice is nullptr";
         return false;
     }
 
     if (m_isOpen)
     {
         qDebug() << "DATVideoRender::OpenStream already open";
         return false;
     }
 
     if (device->bytesAvailable() <= 0)
     {
         qDebug() << "DATVideoRender::OpenStream no data available";
         MetaData.OK_Data = false;
         emit onMetaDataChanged(&MetaData);
         return false;
     }
 
     //Only once execution
     m_running = true;
 
     MetaData.OK_Data = true;
     emit onMetaDataChanged(&MetaData);
 
     InitializeFFMPEG();
 
     if (!m_isFFMPEGInitialized)
     {
         qDebug() << "DATVideoRender::OpenStream FFMPEG not initialized";
         m_running = false;
         return false;
     }
 
     if (!device->open(QIODevice::ReadOnly))
     {
         qDebug() << "DATVideoRender::OpenStream cannot open QIODevice";
         m_running = false;
         return false;
     }
 
     //Connect QIODevice to FFMPEG Reader
 
     m_formatCtx = avformat_alloc_context();
 
     if (m_formatCtx == nullptr)
     {
         qDebug() << "DATVideoRender::OpenStream cannot alloc format FFMPEG context";
         m_running = false;
         return false;
     }
 
     ptrIOBuffer = (unsigned char *)av_malloc(ioBufferSize + AV_INPUT_BUFFER_PADDING_SIZE);
 
     ioCtx = avio_alloc_context(ptrIOBuffer,
                                   ioBufferSize,
                                   0,
                                   reinterpret_cast<void *>(device),
                                   &ReadFunction,
                                   nullptr,
                                   &SeekFunction);
 
     m_formatCtx->pb = ioCtx;
     m_formatCtx->flags |= AVFMT_FLAG_CUSTOM_IO;
 
     if (avformat_open_input(&m_formatCtx, nullptr, nullptr, nullptr) < 0)
     {
         qDebug() << "DATVideoRender::OpenStream cannot open stream";
         m_running = false;
         return false;
     }
 
     if (!PreprocessStream())
     {
         m_running = false;
         return false;
     }
 
     m_isOpen = true;
     m_running = false;
 
     return true;
 }

Here is the call graph for this function:

◆ PreprocessStream()

bool DATVideoRender::PreprocessStream ( )

private

Definition at line 196 of file datvideorender.cpp.

References DataTSMetaData2::BitRate, DataTSMetaData2::Channels, DataTSMetaData2::CodecDescription, DataTSMetaData2::CodecID, DataTSMetaData2::Height, m_audioDecoderCtx, m_audioStreamIndex, m_formatCtx, m_frame, m_frameCount, m_videoDecoderCtx, m_videoStreamIndex, MetaData, DataTSMetaData2::OK_TransportStream, DataTSMetaData2::OK_VideoStream, onMetaDataChanged(), DataTSMetaData2::PID, DataTSMetaData2::Program, setResampler(), DataTSMetaData2::Stream, and DataTSMetaData2::Width.

 {
     AVDictionary *opts = nullptr;
     AVCodec *videoCodec = nullptr;
     AVCodec *audioCodec = nullptr;
 
     int intRet = -1;
     char *buffer = nullptr;
 
     //Identify stream
 
     if (avformat_find_stream_info(m_formatCtx, nullptr) < 0)
     {
         avformat_close_input(&m_formatCtx);
         m_formatCtx = nullptr;
         qDebug() << "DATVideoRender::PreprocessStream cannot find stream info";
         return false;
     }
 
     //Find video stream
     intRet = av_find_best_stream(m_formatCtx, AVMEDIA_TYPE_VIDEO, -1, -1, nullptr, 0);
 
     if (intRet < 0)
     {
         avformat_close_input(&m_formatCtx);
         qDebug() << "DATVideoRender::PreprocessStream cannot find video stream";
         return false;
     }
 
     m_videoStreamIndex = intRet;
 
     //Find audio stream
     intRet = av_find_best_stream(m_formatCtx, AVMEDIA_TYPE_AUDIO, -1, -1, nullptr, 0);
 
     if (intRet < 0)
     {
         qDebug() << "DATVideoRender::PreprocessStream cannot find audio stream";
     }
 
     m_audioStreamIndex = intRet;
 
     // Prepare Video Codec and extract meta data
 
     AVCodecParameters *parms = m_formatCtx->streams[m_videoStreamIndex]->codecpar;
 
     if (m_videoDecoderCtx) {
         avcodec_free_context(&m_videoDecoderCtx);
     }
 
     m_videoDecoderCtx = avcodec_alloc_context3(NULL);
     avcodec_parameters_to_context(m_videoDecoderCtx, parms);
 
     // m_videoDecoderCtx = m_formatCtx->streams[m_videoStreamIndex]->codec; // old style
 
     //Meta Data
 
     MetaData.PID = m_formatCtx->streams[m_videoStreamIndex]->id;
     MetaData.CodecID = m_videoDecoderCtx->codec_id;
     MetaData.OK_TransportStream = true;
     MetaData.Program = "";
     MetaData.Stream = "";
 
     if (m_formatCtx->programs)
     {
         buffer = nullptr;
         av_dict_get_string(m_formatCtx->programs[m_videoStreamIndex]->metadata, &buffer, ':', '\n');
 
         if (buffer != nullptr)
         {
             MetaData.Program = QString("%1").arg(buffer);
         }
     }
 
     buffer = nullptr;
 
     av_dict_get_string(m_formatCtx->streams[m_videoStreamIndex]->metadata, &buffer, ':', '\n');
 
     if (buffer != nullptr)
     {
         MetaData.Stream = QString("%1").arg(buffer);
     }
 
     emit onMetaDataChanged(&MetaData);
 
     //Decoder
     videoCodec = avcodec_find_decoder(m_videoDecoderCtx->codec_id);
 
     if (videoCodec == nullptr)
     {
         avformat_close_input(&m_formatCtx);
         m_formatCtx = nullptr;
 
         qDebug() << "DATVideoRender::PreprocessStream cannot find associated video CODEC";
         return false;
     }
     else
     {
         qDebug() << "DATVideoRender::PreprocessStream: video CODEC found: " << videoCodec->name;
     }
 
     av_dict_set(&opts, "refcounted_frames", "1", 0);
 
     if (avcodec_open2(m_videoDecoderCtx, videoCodec, &opts) < 0)
     {
         avformat_close_input(&m_formatCtx);
         m_formatCtx = nullptr;
 
         qDebug() << "DATVideoRender::PreprocessStream cannot open associated video CODEC";
         return false;
     }
 
     //Allocate Frame
     m_frame = av_frame_alloc();
 
     if (!m_frame)
     {
         avformat_close_input(&m_formatCtx);
         m_formatCtx = nullptr;
 
         qDebug() << "DATVideoRender::PreprocessStream cannot allocate frame";
         return false;
     }
 
     m_frameCount = 0;
     MetaData.Width = m_videoDecoderCtx->width;
     MetaData.Height = m_videoDecoderCtx->height;
     MetaData.BitRate = m_videoDecoderCtx->bit_rate;
     MetaData.Channels = m_videoDecoderCtx->channels;
     MetaData.CodecDescription = QString("%1").arg(videoCodec->long_name);
     MetaData.OK_VideoStream = true;
 
     emit onMetaDataChanged(&MetaData);
 
     // Prepare Audio Codec
 
     if (m_audioStreamIndex >= 0)
     {
         AVCodecParameters *parms = m_formatCtx->streams[m_audioStreamIndex]->codecpar;
 
         if (m_audioDecoderCtx) {
             avcodec_free_context(&m_audioDecoderCtx);
         }
 
         m_audioDecoderCtx = avcodec_alloc_context3(nullptr);
         avcodec_parameters_to_context(m_audioDecoderCtx, parms);
 
         //m_audioDecoderCtx = m_formatCtx->streams[m_audioStreamIndex]->codec; // old style
 
         qDebug() << "DATVideoRender::PreprocessStream: audio: "
         << " channels: " << m_audioDecoderCtx->channels
         << " channel_layout: " << m_audioDecoderCtx->channel_layout
         << " sample_rate: " << m_audioDecoderCtx->sample_rate
         << " sample_fmt: " << m_audioDecoderCtx->sample_fmt
         << " codec_id: "<< m_audioDecoderCtx->codec_id;
 
         audioCodec = avcodec_find_decoder(m_audioDecoderCtx->codec_id);
 
         if (audioCodec == nullptr)
         {
             qDebug() << "DATVideoRender::PreprocessStream cannot find associated audio CODEC";
             m_audioStreamIndex = -1; // invalidate audio
         }
         else
         {
             qDebug() << "DATVideoRender::PreprocessStream: audio CODEC found: " << audioCodec->name;
 
             if (avcodec_open2(m_audioDecoderCtx, audioCodec, nullptr) < 0)
             {
                 qDebug() << "DATVideoRender::PreprocessStream cannot open associated audio CODEC";
                 m_audioStreamIndex = -1; // invalidate audio
             }
             else
             {
                 setResampler();
             }
 
         }
     }
 
     return true;
 }

Here is the call graph for this function:

◆ RenderStream()

bool DATVideoRender::RenderStream ( )

Definition at line 474 of file datvideorender.cpp.

References DataTSMetaData2::Height, i, m_audioDecodeOK, m_audioDecoderCtx, m_audioFifo, m_audioFifoBuffer, m_audioFifoBufferIndex, m_audioFifoBufferSize, m_audioMute, m_audioStreamIndex, m_audioSWR, m_audioVolume, m_currentRenderHeight, m_currentRenderWidth, m_formatCtx, m_frame, m_frameCount, m_isOpen, m_pbytDecodedData, m_pintDecodedLineSize, m_running, m_swsCtx, m_updateAudioResampler, m_videoDecodeOK, m_videoDecoderCtx, m_videoMute, m_videoStreamIndex, MetaData, new_decode(), DataTSMetaData2::OK_Decoding, onMetaDataChanged(), TVScreen::renderImage(), TVScreen::resetImage(), TVScreen::resizeTVScreen(), setResampler(), DataTSMetaData2::Width, and AudioFifo::write().

 {
     AVPacket packet;
     int gotFrame;
     bool needRenderingSetup;
 
     if (!m_isOpen)
     {
         qDebug() << "DATVideoRender::RenderStream Stream not open";
         return false;
     }
 
     if (m_running)
     {
         return false;
     }
 
     //Only once execution
     m_running = true;
 
     //********** Rendering **********
 
     if (av_read_frame(m_formatCtx, &packet) < 0)
     {
         qDebug() << "DATVideoRender::RenderStream reading packet error";
         m_running = false;
         return false;
     }
 
     //Video channel
     if ((packet.stream_index == m_videoStreamIndex) && (!m_videoMute))
     {
         memset(m_frame, 0, sizeof(AVFrame));
         av_frame_unref(m_frame);
 
         gotFrame = 0;
 
         if (new_decode(m_videoDecoderCtx, m_frame, &gotFrame, &packet) >= 0)
         {
             m_videoDecodeOK = true;
 
             if (gotFrame)
             {
                 //Rendering and RGB Converter setup
                 needRenderingSetup = (m_frameCount == 0);
                 needRenderingSetup |= (m_swsCtx == nullptr);
 
                 if ((m_currentRenderWidth != m_frame->width) || (m_currentRenderHeight != m_frame->height))
                 {
                     needRenderingSetup = true;
                 }
 
                 if (needRenderingSetup)
                 {
                     if (m_swsCtx != nullptr)
                     {
                         sws_freeContext(m_swsCtx);
                         m_swsCtx = nullptr;
                     }
 
                     //Convertisseur YUV -> RGB
                     m_swsCtx = sws_alloc_context();
 
                     av_opt_set_int(m_swsCtx, "srcw", m_frame->width, 0);
                     av_opt_set_int(m_swsCtx, "srch", m_frame->height, 0);
                     av_opt_set_int(m_swsCtx, "src_format", m_frame->format, 0);
 
                     av_opt_set_int(m_swsCtx, "dstw", m_frame->width, 0);
                     av_opt_set_int(m_swsCtx, "dsth", m_frame->height, 0);
                     av_opt_set_int(m_swsCtx, "dst_format", AV_PIX_FMT_RGB24, 0);
 
                     av_opt_set_int(m_swsCtx, "sws_flag", SWS_FAST_BILINEAR /* SWS_BICUBIC*/, 0);
 
                     if (sws_init_context(m_swsCtx, nullptr, nullptr) < 0)
                     {
                         qDebug() << "DATVideoRender::RenderStream cannont init video data converter";
                         m_swsCtx = nullptr;
                         m_running = false;
                         return false;
                     }
 
                     if ((m_currentRenderHeight > 0) && (m_currentRenderWidth > 0))
                     {
                         //av_freep(&m_pbytDecodedData[0]);
                         //av_freep(&m_pintDecodedLineSize[0]);
                     }
 
                     if (av_image_alloc(m_pbytDecodedData, m_pintDecodedLineSize, m_frame->width, m_frame->height, AV_PIX_FMT_RGB24, 1) < 0)
                     {
                         qDebug() << "DATVideoRender::RenderStream cannont init video image buffer";
                         sws_freeContext(m_swsCtx);
                         m_swsCtx = nullptr;
                         m_running = false;
                         return false;
                     }
 
                     //Rendering device setup
 
                     resizeTVScreen(m_frame->width, m_frame->height);
                     update();
                     resetImage();
 
                     m_currentRenderWidth = m_frame->width;
                     m_currentRenderHeight = m_frame->height;
 
                     MetaData.Width = m_frame->width;
                     MetaData.Height = m_frame->height;
                     MetaData.OK_Decoding = true;
                     emit onMetaDataChanged(&MetaData);
                 }
 
                 //Frame rendering
 
                 if (sws_scale(m_swsCtx, m_frame->data, m_frame->linesize, 0, m_frame->height, m_pbytDecodedData, m_pintDecodedLineSize) < 0)
                 {
                     qDebug() << "DATVideoRender::RenderStream error converting video frame to RGB";
                     m_running = false;
                     return false;
                 }
 
                 renderImage(m_pbytDecodedData[0]);
                 av_frame_unref(m_frame);
                 m_frameCount++;
             }
         }
         else
         {
             m_videoDecodeOK = false;
             // qDebug() << "DATVideoRender::RenderStream video decode error";
         }
     }
     // Audio channel
     else if ((packet.stream_index == m_audioStreamIndex) && (m_audioFifo) && (swr_is_initialized(m_audioSWR)) && (!m_audioMute))
     {
         if (m_updateAudioResampler)
         {
             setResampler();
             m_updateAudioResampler = false;
         }
 
         memset(m_frame, 0, sizeof(AVFrame));
         av_frame_unref(m_frame);
         gotFrame = 0;
 
         if (new_decode(m_audioDecoderCtx, m_frame, &gotFrame, &packet) >= 0)
         {
             m_audioDecodeOK = true;
 
             if (gotFrame)
             {
                 int16_t *audioBuffer;
                 av_samples_alloc((uint8_t**) &audioBuffer, nullptr, 2, m_frame->nb_samples, AV_SAMPLE_FMT_S16, 0);
                 int frame_count = swr_convert(m_audioSWR, (uint8_t**) &audioBuffer, m_frame->nb_samples, (const uint8_t**) m_frame->data, m_frame->nb_samples);
 
                 // direct writing:
                 // int ret = m_audioFifo->write((const quint8*) &audioBuffer[0], frame_count);
 
                 // if (ret < frame_count) {
                 //     qDebug("DATVideoRender::RenderStream: audio frames missing %d vs %d", ret, frame_count);
                 // }
 
                 // buffered writing:
                 // if (m_audioFifoBufferIndex + frame_count < m_audioFifoBufferSize)
                 // {
                 //     std::copy(&audioBuffer[0], &audioBuffer[2*frame_count], &m_audioFifoBuffer[2*m_audioFifoBufferIndex]);
                 //     m_audioFifoBufferIndex += frame_count;
                 // }
                 // else
                 // {
                 //     int remainder = m_audioFifoBufferSize - m_audioFifoBufferIndex;
                 //     std::copy(&audioBuffer[0], &audioBuffer[2*remainder], &m_audioFifoBuffer[2*m_audioFifoBufferIndex]);
                 //     m_audioFifo->write((const quint8*) &m_audioFifoBuffer[0], m_audioFifoBufferSize);
                 //     std::copy(&audioBuffer[2*remainder], &audioBuffer[2*frame_count], &m_audioFifoBuffer[0]);
                 //     m_audioFifoBufferIndex = frame_count - remainder;
                 // }
 
                 // Apply volume:
                 for (int i = 0; i < frame_count; i++)
                 {
                     m_audioFifoBuffer[2*m_audioFifoBufferIndex]   = m_audioVolume * audioBuffer[2*i];
                     m_audioFifoBuffer[2*m_audioFifoBufferIndex+1] = m_audioVolume * audioBuffer[2*i+1];
                     m_audioFifoBufferIndex++;
 
                     if (m_audioFifoBufferIndex >= m_audioFifoBufferSize)
                     {
                         m_audioFifo->write((const quint8*) &m_audioFifoBuffer[0], m_audioFifoBufferSize);
                         m_audioFifoBufferIndex = 0;
                     }
                 }
             }
         }
         else
         {
             m_audioDecodeOK = false;
             // qDebug("DATVideoRender::RenderStream: audio decode error");
         }
     }
 
     av_packet_unref(&packet);
 
     //********** Rendering **********
 
     m_running = false;
     return true;
 }

Here is the call graph for this function:

◆ ResetMetaData()

void DATVideoRender::ResetMetaData ( )

private

Definition at line 158 of file datvideorender.cpp.

References DataTSMetaData2::BitRate, DataTSMetaData2::Channels, DataTSMetaData2::CodecDescription, DataTSMetaData2::CodecID, DataTSMetaData2::Height, MetaData, DataTSMetaData2::OK_Decoding, DataTSMetaData2::OK_TransportStream, DataTSMetaData2::OK_VideoStream, onMetaDataChanged(), DataTSMetaData2::PID, DataTSMetaData2::Program, DataTSMetaData2::Stream, and DataTSMetaData2::Width.

Referenced by CloseStream(), and InitializeFFMPEG().

 {
     MetaData.CodecID = -1;
     MetaData.PID = -1;
     MetaData.Program = "";
     MetaData.Stream = "";
     MetaData.Width = -1;
     MetaData.Height = -1;
     MetaData.BitRate = -1;
     MetaData.Channels = -1;
     MetaData.CodecDescription = "";
 
     MetaData.OK_Decoding = false;
     MetaData.OK_TransportStream = false;
     MetaData.OK_VideoStream = false;
 
     emit onMetaDataChanged(&MetaData);
 }

Here is the caller graph for this function:

◆ setAudioFIFO()

void DATVideoRender::setAudioFIFO ( AudioFifo * fifo )

inline

Definition at line 99 of file datvideorender.h.

Referenced by DATVDemod::SetVideoRender().

99 { m_audioFifo = fifo; }

DATVideoRender::m_audioFifo

AudioFifo * m_audioFifo

Definition: datvideorender.h:128

Here is the caller graph for this function:

◆ setAudioMute()

void DATVideoRender::setAudioMute ( bool audioMute )

inline

Definition at line 103 of file datvideorender.h.

Referenced by DATVDemod::applySettings().

103 { m_audioMute = audioMute; }

DATVideoRender::m_audioMute

bool m_audioMute

Definition: datvideorender.h:134

Here is the caller graph for this function:

◆ setAudioVolume()

void DATVideoRender::setAudioVolume ( int audioVolume )

Definition at line 680 of file datvideorender.cpp.

References m_audioVolume.

Referenced by DATVDemod::applySettings().

 {
     int audioVolumeConstrained = audioVolume < 0 ? 0 : audioVolume > 100 ? 100 : audioVolume;
     m_audioVolume = pow(10.0, audioVolumeConstrained*0.02 - 2.0); // .01 -> 1 log
 }

Here is the caller graph for this function:

◆ SetFullScreen()

void DATVideoRender::SetFullScreen ( bool blnFullScreen )

Definition at line 92 of file datvideorender.cpp.

References m_isFullScreen.

Referenced by eventFilter().

 {
     if (m_isFullScreen == fullScreen)
     {
         return;
     }
 
     if (fullScreen == true)
     {
         qDebug("DATVideoRender::SetFullScreen: go to fullscreen");
         // m_originalWindowFlags = this->windowFlags();
         // m_originalSize = this->size();
         // m_parentWidget->layout()->removeWidget(this);
         // //this->setParent(0);
         // this->setWindowFlags( Qt::FramelessWindowHint|Qt::WindowStaysOnTopHint);
         // m_parentWidget->show();
         setWindowFlags(Qt::Window);
         setWindowState(Qt::WindowFullScreen);
         show();
         m_isFullScreen = true;
     }
     else
     {
         qDebug("DATVideoRender::SetFullScreen: come back from fullscreen");
         // //this->setParent(m_parentWidget);
         // this->resize(m_originalSize);
         // this->overrideWindowFlags(m_originalWindowFlags);
         // setWindowState(Qt::WindowNoState);
         // m_parentWidget->layout()->addWidget(this);
         // m_parentWidget->show();
         setWindowFlags(Qt::Widget);
         setWindowState(Qt::WindowNoState);
         show();
         m_isFullScreen = false;
     }
 }

Here is the caller graph for this function:

◆ setResampler()

void DATVideoRender::setResampler ( )

private

Definition at line 686 of file datvideorender.cpp.

References m_audioDecoderCtx, m_audioSampleRate, and m_audioSWR.

Referenced by PreprocessStream(), and RenderStream().

 {
     if (m_audioSWR) {
         swr_free(&m_audioSWR);
     }
 
     m_audioSWR = swr_alloc();
     av_opt_set_int(m_audioSWR, "in_channel_count",  m_audioDecoderCtx->channels, 0);
     av_opt_set_int(m_audioSWR, "out_channel_count", 2, 0);
     av_opt_set_int(m_audioSWR, "in_channel_layout",  m_audioDecoderCtx->channel_layout, 0);
     av_opt_set_int(m_audioSWR, "out_channel_layout", AV_CH_LAYOUT_STEREO, 0);
     av_opt_set_int(m_audioSWR, "in_sample_rate", m_audioDecoderCtx->sample_rate, 0);
     av_opt_set_int(m_audioSWR, "out_sample_rate", m_audioSampleRate, 0);
     av_opt_set_sample_fmt(m_audioSWR, "in_sample_fmt",  m_audioDecoderCtx->sample_fmt, 0);
     av_opt_set_sample_fmt(m_audioSWR, "out_sample_fmt", AV_SAMPLE_FMT_S16,  0);
 
     swr_init(m_audioSWR);
 
     qDebug() << "DATVideoRender::setResampler: "
         << " in_channel_count: " <<  m_audioDecoderCtx->channels
         << " out_channel_count: " << 2
         << " in_channel_layout: " <<  m_audioDecoderCtx->channel_layout
         << " out_channel_layout: " <<  AV_CH_LAYOUT_STEREO
         << " in_sample_rate: " << m_audioDecoderCtx->sample_rate
         << " out_sample_rate: " << m_audioSampleRate
         << " in_sample_fmt: " << m_audioDecoderCtx->sample_fmt
         << " out_sample_fmt: " << AV_SAMPLE_FMT_S16;
 }

Here is the caller graph for this function:

◆ setVideoMute()

void DATVideoRender::setVideoMute ( bool videoMute )

inline

Definition at line 104 of file datvideorender.h.

Referenced by DATVDemod::applySettings().

104 { m_videoMute = videoMute; }

DATVideoRender::m_videoMute

bool m_videoMute

Definition: datvideorender.h:135

Here is the caller graph for this function:

Member Data Documentation

◆ m_audioDecodeOK

bool DATVideoRender::m_audioDecodeOK

private

Definition at line 149 of file datvideorender.h.

Referenced by DATVideoRender(), and RenderStream().

◆ m_audioDecoderCtx

AVCodecContext* DATVideoRender::m_audioDecoderCtx

private

Definition at line 126 of file datvideorender.h.

Referenced by DATVideoRender(), PreprocessStream(), RenderStream(), and setResampler().

◆ m_audioFifo

AudioFifo* DATVideoRender::m_audioFifo

private

Definition at line 128 of file datvideorender.h.

Referenced by DATVideoRender(), and RenderStream().

◆ m_audioFifoBuffer

int16_t DATVideoRender::m_audioFifoBuffer[m_audioFifoBufferSize *2]

private

Definition at line 132 of file datvideorender.h.

Referenced by RenderStream().

◆ m_audioFifoBufferIndex

int DATVideoRender::m_audioFifoBufferIndex

private

Definition at line 133 of file datvideorender.h.

Referenced by DATVideoRender(), and RenderStream().

◆ m_audioFifoBufferSize

const int DATVideoRender::m_audioFifoBufferSize = 16000

staticprivate

Definition at line 131 of file datvideorender.h.

Referenced by RenderStream().

◆ m_audioMute

bool DATVideoRender::m_audioMute

private

Definition at line 134 of file datvideorender.h.

Referenced by DATVideoRender(), and RenderStream().

◆ m_audioSampleRate

int DATVideoRender::m_audioSampleRate

private

Definition at line 130 of file datvideorender.h.

Referenced by DATVideoRender(), and setResampler().

◆ m_audioStreamIndex

int DATVideoRender::m_audioStreamIndex

private

Definition at line 144 of file datvideorender.h.

Referenced by DATVideoRender(), PreprocessStream(), and RenderStream().

◆ m_audioSWR

struct SwrContext* DATVideoRender::m_audioSWR

private

Definition at line 129 of file datvideorender.h.

Referenced by DATVideoRender(), RenderStream(), setResampler(), and ~DATVideoRender().

◆ m_audioVolume

float DATVideoRender::m_audioVolume

private

Definition at line 136 of file datvideorender.h.

Referenced by DATVideoRender(), RenderStream(), and setAudioVolume().

◆ m_currentRenderHeight

int DATVideoRender::m_currentRenderHeight

private

Definition at line 147 of file datvideorender.h.

Referenced by CloseStream(), DATVideoRender(), and RenderStream().

◆ m_currentRenderWidth

int DATVideoRender::m_currentRenderWidth

private

Definition at line 146 of file datvideorender.h.

Referenced by CloseStream(), DATVideoRender(), and RenderStream().

◆ m_formatCtx

AVFormatContext* DATVideoRender::m_formatCtx

private

Definition at line 124 of file datvideorender.h.

Referenced by CloseStream(), DATVideoRender(), OpenStream(), PreprocessStream(), and RenderStream().

◆ m_frame

AVFrame* DATVideoRender::m_frame

private

Definition at line 127 of file datvideorender.h.

Referenced by CloseStream(), DATVideoRender(), PreprocessStream(), and RenderStream().

◆ m_frameCount

int DATVideoRender::m_frameCount

private

Definition at line 142 of file datvideorender.h.

Referenced by DATVideoRender(), PreprocessStream(), and RenderStream().

◆ m_isFFMPEGInitialized

bool DATVideoRender::m_isFFMPEGInitialized

private

Definition at line 120 of file datvideorender.h.

Referenced by DATVideoRender(), InitializeFFMPEG(), and OpenStream().

◆ m_isFullScreen

bool DATVideoRender::m_isFullScreen

private

Definition at line 118 of file datvideorender.h.

Referenced by DATVideoRender(), and SetFullScreen().

◆ m_isOpen

bool DATVideoRender::m_isOpen

private

Definition at line 121 of file datvideorender.h.

Referenced by CloseStream(), DATVideoRender(), OpenStream(), and RenderStream().

◆ m_originalSize

QSize DATVideoRender::m_originalSize

private

Definition at line 115 of file datvideorender.h.

◆ m_originalWindowFlags

Qt::WindowFlags DATVideoRender::m_originalWindowFlags

private

Definition at line 114 of file datvideorender.h.

◆ m_parentWidget

QWidget* DATVideoRender::m_parentWidget

private

Definition at line 113 of file datvideorender.h.

◆ m_pbytDecodedData

uint8_t* DATVideoRender::m_pbytDecodedData[4]

private

Definition at line 139 of file datvideorender.h.

Referenced by RenderStream().

◆ m_pintDecodedLineSize

int DATVideoRender::m_pintDecodedLineSize[4]

private

Definition at line 140 of file datvideorender.h.

Referenced by RenderStream().

◆ m_running

bool DATVideoRender::m_running

private

Definition at line 117 of file datvideorender.h.

Referenced by CloseStream(), DATVideoRender(), OpenStream(), and RenderStream().

◆ m_swsCtx

SwsContext* DATVideoRender::m_swsCtx

private

Definition at line 123 of file datvideorender.h.

Referenced by CloseStream(), DATVideoRender(), and RenderStream().

◆ m_updateAudioResampler

bool DATVideoRender::m_updateAudioResampler

private

Definition at line 137 of file datvideorender.h.

Referenced by DATVideoRender(), and RenderStream().

◆ m_videoDecodeOK

bool DATVideoRender::m_videoDecodeOK

private

Definition at line 150 of file datvideorender.h.

Referenced by DATVideoRender(), and RenderStream().

◆ m_videoDecoderCtx

AVCodecContext* DATVideoRender::m_videoDecoderCtx

private

Definition at line 125 of file datvideorender.h.

Referenced by CloseStream(), DATVideoRender(), PreprocessStream(), and RenderStream().

◆ m_videoMute

bool DATVideoRender::m_videoMute

private

Definition at line 135 of file datvideorender.h.

Referenced by DATVideoRender(), and RenderStream().

◆ m_videoStreamIndex

int DATVideoRender::m_videoStreamIndex

private

Definition at line 143 of file datvideorender.h.

Referenced by DATVideoRender(), PreprocessStream(), and RenderStream().

◆ MetaData

struct DataTSMetaData2 DATVideoRender::MetaData

Definition at line 110 of file datvideorender.h.

Referenced by CloseStream(), OpenStream(), PreprocessStream(), RenderStream(), and ResetMetaData().

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

plugins/channelrx/demoddatv/datvideorender.h
plugins/channelrx/demoddatv/datvideorender.cpp

Signals

Public Member Functions

Public Attributes

Protected Member Functions

Private Member Functions

Private Attributes

Static Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ DATVideoRender()

◆ ~DATVideoRender()

Member Function Documentation

◆ CloseStream()

◆ eventFilter()

◆ getAudioDecodeOK()

◆ getAudioStreamIndex()

◆ getVideoDecodeOK()

◆ getVideoStreamIndex()

◆ InitializeFFMPEG()

◆ new_decode()

◆ onMetaDataChanged

◆ OpenStream()

◆ PreprocessStream()

◆ RenderStream()

◆ ResetMetaData()

◆ setAudioFIFO()

◆ setAudioMute()

◆ setAudioVolume()

◆ SetFullScreen()

◆ setResampler()

◆ setVideoMute()

Member Data Documentation

◆ m_audioDecodeOK

◆ m_audioDecoderCtx

◆ m_audioFifo

◆ m_audioFifoBuffer

◆ m_audioFifoBufferIndex

◆ m_audioFifoBufferSize

◆ m_audioMute

◆ m_audioSampleRate

◆ m_audioStreamIndex

◆ m_audioSWR

◆ m_audioVolume

◆ m_currentRenderHeight

◆ m_currentRenderWidth

◆ m_formatCtx

◆ m_frame

◆ m_frameCount

◆ m_isFFMPEGInitialized

◆ m_isFullScreen

◆ m_isOpen

◆ m_originalSize

◆ m_originalWindowFlags

◆ m_parentWidget

◆ m_pbytDecodedData

◆ m_pintDecodedLineSize

◆ m_running

◆ m_swsCtx

◆ m_updateAudioResampler

◆ m_videoDecodeOK

◆ m_videoDecoderCtx

◆ m_videoMute

◆ m_videoStreamIndex

◆ MetaData