UDPSinkUtil< T > Class Template Reference

#include <udpsinkutil.h>

Public Member Functions
	UDPSinkUtil (QObject *parent, unsigned int udpSize)
	UDPSinkUtil (QObject *parent, unsigned int udpSize, unsigned int port)
	UDPSinkUtil (QObject *parent, unsigned int udpSize, QHostAddress &address, unsigned int port)
	~UDPSinkUtil ()
void	moveToThread (QThread *thread)
void	setAddress (QString &address)
void	setPort (unsigned int port)
void	setDestination (const QString &address, int port)
void	write (T sample)
void	write (T *samples, int nbSamples)

Private Attributes
int	m_udpSize
int	m_udpSamples
QHostAddress	m_address
unsigned int	m_port
QUdpSocket *	m_socket
T *	m_sampleBuffer
int	m_sampleBufferIndex

Detailed Description

template<typename T>
class UDPSinkUtil< T >

Definition at line 30 of file udpsinkutil.h.

Constructor & Destructor Documentation

UDPSinkUtil() [1/3]

template<typename T>

UDPSinkUtil< T >::UDPSinkUtil ( QObject *  parent, unsigned int  udpSize  )

inline

Definition at line 33 of file udpsinkutil.h.

                                                       :
        m_udpSize(udpSize),
        m_udpSamples(udpSize/sizeof(T)),
        m_address(QHostAddress::LocalHost),
        m_port(9999),
        m_sampleBufferIndex(0)
    {
        assert(m_udpSamples > 0);
        m_sampleBuffer = new T[m_udpSamples];
        m_socket = new QUdpSocket(parent);
    }

UDPSinkUtil() [2/3]

template<typename T>

UDPSinkUtil< T >::UDPSinkUtil ( QObject *  parent, unsigned int  udpSize, unsigned int  port  )

inline

Definition at line 45 of file udpsinkutil.h.

                                                                          :
        m_udpSize(udpSize),
        m_udpSamples(udpSize/sizeof(T)),
        m_address(QHostAddress::LocalHost),
        m_port(port),
        m_sampleBufferIndex(0)
    {
        assert(m_udpSamples > 0);
        m_sampleBuffer = new T[m_udpSamples];
        m_socket = new QUdpSocket(parent);
    }

UDPSinkUtil() [3/3]

template<typename T>

UDPSinkUtil< T >::UDPSinkUtil ( QObject *  parent, unsigned int  udpSize, QHostAddress &  address, unsigned int  port  )

inline

Definition at line 57 of file udpsinkutil.h.

                                                                                                  :
        m_udpSize(udpSize),
        m_udpSamples(udpSize/sizeof(T)),
        m_address(address),
        m_port(port),
        m_sampleBufferIndex(0)
    {
        assert(m_udpSamples > 0);
        m_sampleBuffer = new T[m_udpSamples];
        m_socket = new QUdpSocket(parent);
    }

~UDPSinkUtil()

template<typename T>

UDPSinkUtil< T >::~UDPSinkUtil ( )

inline

Definition at line 69 of file udpsinkutil.h.

    {
        delete[] m_sampleBuffer;
        delete m_socket;
    }

Member Function Documentation

moveToThread()

template<typename T>

void UDPSinkUtil< T >::moveToThread ( QThread *  thread )

inline

Definition at line 75 of file udpsinkutil.h.

    {
        m_socket->moveToThread(thread);
    }

setAddress()

template<typename T>

void UDPSinkUtil< T >::setAddress ( QString &  address )

inline

Definition at line 80 of file udpsinkutil.h.

Referenced by UDPSink::applySettings().

{ m_address.setAddress(address); }

Here is the caller graph for this function:

setDestination()

template<typename T>

void UDPSinkUtil< T >::setDestination ( const QString &  address, int  port  )

inline

Definition at line 83 of file udpsinkutil.h.

    {
        m_address.setAddress(const_cast<QString&>(address));
        m_port = port;
    }

setPort()

template<typename T>

void UDPSinkUtil< T >::setPort ( unsigned int  port )

inline

Definition at line 81 of file udpsinkutil.h.

Referenced by UDPSink::applySettings().

{ m_port = port; }

Here is the caller graph for this function:

write() [1/2]

template<typename T>

void UDPSinkUtil< T >::write ( T  sample )

inline

Write one sample

Definition at line 92 of file udpsinkutil.h.

Referenced by UDPSink::udpWrite(), UDPSink::udpWriteMono(), UDPSink::udpWriteNorm(), and UDPSink::udpWriteNormMono().

    {
        if (m_sampleBufferIndex < m_udpSamples)
        {
            m_sampleBuffer[m_sampleBufferIndex] = sample;
            m_sampleBufferIndex++;
        }
        else
        {
            m_socket->writeDatagram((const char*)&m_sampleBuffer[0], (qint64 ) m_udpSize, m_address, m_port);
            m_sampleBuffer[0] = sample;
            m_sampleBufferIndex = 1;
        }
    }

Here is the caller graph for this function:

write() [2/2]

template<typename T>

void UDPSinkUtil< T >::write ( T *  samples, int  nbSamples  )

inline

Write a bunch of samples

Definition at line 110 of file udpsinkutil.h.

    {
        int samplesIndex = 0;

        if (m_sampleBufferIndex + nbSamples > m_udpSamples) // fill remainder of buffer and send it
        {
            memcpy(&m_sampleBuffer[m_sampleBufferIndex], &samples[samplesIndex], (m_udpSamples - m_sampleBufferIndex)*sizeof(T)); // fill remainder of buffer
            m_socket->writeDatagram((const char*)&m_sampleBuffer[0], (qint64 ) m_udpSize, m_address, m_port); // send buffer
            samplesIndex += (m_udpSamples - m_sampleBufferIndex);
            nbSamples -= (m_udpSamples - m_sampleBufferIndex);
            m_sampleBufferIndex = 0;
        }

        while (nbSamples > m_udpSamples) // send directly from input without buffering
        {
            m_socket->writeDatagram((const char*)&samples[samplesIndex], (qint64 ) m_udpSize, m_address, m_port);
            samplesIndex += m_udpSamples;
            nbSamples -= m_udpSamples;
        }

        memcpy(&m_sampleBuffer[m_sampleBufferIndex], &samples[samplesIndex], nbSamples*sizeof(T)); // copy remainder of input to buffer
    }

Member Data Documentation

m_address

template<typename T>

QHostAddress UDPSinkUtil< T >::m_address

private

Definition at line 136 of file udpsinkutil.h.

Referenced by UDPSinkUtil< UDPSink::Sample16 >::setAddress(), UDPSinkUtil< UDPSink::Sample16 >::setDestination(), and UDPSinkUtil< UDPSink::Sample16 >::write().

m_port

template<typename T>

unsigned int UDPSinkUtil< T >::m_port

private

Definition at line 137 of file udpsinkutil.h.

Referenced by UDPSinkUtil< UDPSink::Sample16 >::setDestination(), UDPSinkUtil< UDPSink::Sample16 >::setPort(), and UDPSinkUtil< UDPSink::Sample16 >::write().

m_sampleBuffer

template<typename T>

T* UDPSinkUtil< T >::m_sampleBuffer

private

Definition at line 139 of file udpsinkutil.h.

Referenced by UDPSinkUtil< UDPSink::Sample16 >::UDPSinkUtil(), UDPSinkUtil< UDPSink::Sample16 >::write(), and UDPSinkUtil< UDPSink::Sample16 >::~UDPSinkUtil().

m_sampleBufferIndex

template<typename T>

int UDPSinkUtil< T >::m_sampleBufferIndex

private

Definition at line 139 of file udpsinkutil.h.

Referenced by UDPSinkUtil< UDPSink::Sample16 >::write().

m_socket

template<typename T>

QUdpSocket* UDPSinkUtil< T >::m_socket

private

Definition at line 138 of file udpsinkutil.h.

Referenced by UDPSinkUtil< UDPSink::Sample16 >::moveToThread(), UDPSinkUtil< UDPSink::Sample16 >::UDPSinkUtil(), UDPSinkUtil< UDPSink::Sample16 >::write(), and UDPSinkUtil< UDPSink::Sample16 >::~UDPSinkUtil().

m_udpSamples

template<typename T>

int UDPSinkUtil< T >::m_udpSamples

private

Definition at line 135 of file udpsinkutil.h.

Referenced by UDPSinkUtil< UDPSink::Sample16 >::UDPSinkUtil(), and UDPSinkUtil< UDPSink::Sample16 >::write().

m_udpSize

template<typename T>

int UDPSinkUtil< T >::m_udpSize

private

Definition at line 134 of file udpsinkutil.h.

Referenced by UDPSinkUtil< UDPSink::Sample16 >::write().

---

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

• sdrbase/util/udpsinkutil.h