#include <datvvideoplayer.h>

Inheritance diagram for leansdr::datvvideoplayer< T >:

Collaboration diagram for leansdr::datvvideoplayer< T >:

Public Member Functions
	datvvideoplayer (scheduler sch, pipebuf< T > &_in, DATVideostream objVideoStream, DATVUDPStream *udpStream)

void	run ()

Public Member Functions inherited from leansdr::runnable
	runnable (scheduler _sch, const char name)

Public Member Functions inherited from leansdr::runnable_common
	runnable_common (const char *_name)

virtual	~runnable_common ()

virtual void	shutdown ()

Private Attributes
pipereader< T >	in

DATVideostream *	m_objVideoStream

DATVUDPStream *	m_udpStream

Additional Inherited Members
Public Attributes inherited from leansdr::runnable_common
const char *	name

Protected Attributes inherited from leansdr::runnable
scheduler *	sch

Detailed Description

template<typename T>
struct leansdr::datvvideoplayer< T >

Definition at line 29 of file datvvideoplayer.h.

Constructor & Destructor Documentation

◆ datvvideoplayer()

template<typename T>

leansdr::datvvideoplayer< T >::datvvideoplayer	(	scheduler *	sch,
		pipebuf< T > &	_in,
		DATVideostream *	objVideoStream,
		DATVUDPStream *	udpStream
	)

inline

Definition at line 31 of file datvvideoplayer.h.

                                       :
         runnable(sch, _in.name),
         in(_in),
         m_objVideoStream(objVideoStream),
         m_udpStream(udpStream)
     {
     }

Member Function Documentation

◆ run()

template<typename T>

void leansdr::datvvideoplayer< T >::run ( )

inlinevirtual

Reimplemented from leansdr::runnable_common.

Definition at line 43 of file datvvideoplayer.h.

     {
         int size = in.readable() * sizeof(T);
 
         if (!size) {
             return;
         }
 
         m_udpStream->pushData((const char *) in.rd(), in.readable());
         int nw = m_objVideoStream->pushData((const char *) in.rd(), size);
 
         if (!nw)
         {
             fatal("leansdr::datvvideoplayer::run: pipe");
             return;
         }
 
         if (nw < 0)
         {
             fatal("leansdr::datvvideoplayer::run: write");
             return;
         }
 
         if (nw % sizeof(T))
         {
             fatal("leansdr::datvvideoplayer::run: partial write");
             return;
         }
 
         if (nw != size) {
             fprintf(stderr, "leansdr::datvvideoplayer::run: nw: %d size: %d\n", nw, size);
         }
 
         in.read(nw / sizeof(T));
     }