#include <datvudpstream.h>

Public Member Functions
	DATVUDPStream (int tsBlockSize)

	~DATVUDPStream ()

void	pushData (const char *chrData, int nbTSBlocks)

void	setActive (bool active)

bool	setAddress (const QString &address)

void	setPort (quint16 port)

Static Public Attributes
static const int	m_tsBlocksPerFrame = 7

Private Attributes
bool	m_active

QUdpSocket	m_udpSocket

QHostAddress	m_address

quint16	m_port

int	m_tsBlockSize

int	m_tsBlockIndex

char *	m_tsBuffer

Detailed Description

Definition at line 28 of file datvudpstream.h.

Constructor & Destructor Documentation

◆ DATVUDPStream()

DATVUDPStream::DATVUDPStream ( int tsBlockSize )

Definition at line 24 of file datvudpstream.cpp.

References m_tsBlockSize, m_tsBlocksPerFrame, and m_tsBuffer.

                                             :
     m_active(false),
     m_address(QHostAddress::LocalHost),
     m_port(8882),
     m_tsBlockSize(tsBlockSize),
     m_tsBlockIndex(0)
 {
     m_tsBuffer = new char[m_tsBlocksPerFrame*m_tsBlockSize];
 }

◆ ~DATVUDPStream()

DATVUDPStream::~DATVUDPStream ( )

Definition at line 34 of file datvudpstream.cpp.

References m_tsBuffer.

 {
     delete[] m_tsBuffer;
 }

Member Function Documentation

◆ pushData()

void DATVUDPStream::pushData	(	const char *	chrData,
		int	nbTSBlocks
	)

Definition at line 39 of file datvudpstream.cpp.

References i, m_active, m_address, m_port, m_tsBlockIndex, m_tsBlockSize, m_tsBlocksPerFrame, m_tsBuffer, and m_udpSocket.

Referenced by leansdr::datvvideoplayer< leansdr::tspacket >::run().

 {
     if (!m_active) {
         return;
     }
 
     for (int i = 0; i < nbTSBlocks; i++)
     {
         if (m_tsBlockIndex < m_tsBlocksPerFrame)
         {
             std::copy(chrData + i*m_tsBlockSize, chrData + (i+1)*m_tsBlockSize, m_tsBuffer + m_tsBlockIndex*m_tsBlockSize);
             m_tsBlockIndex++;
         }
         else
         {
             m_udpSocket.writeDatagram(m_tsBuffer, m_tsBlocksPerFrame*m_tsBlockSize, m_address, m_port);
             m_tsBlockIndex = 0;
         }
     }
 }