#include <generic.h>

Inheritance diagram for leansdr::file_printer< T >:

Collaboration diagram for leansdr::file_printer< T >:

Public Member Functions
	file_printer (scheduler sch, const char _format, pipebuf< T > &_in, int _fdout, int _decimation=1)

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 ()

Public Attributes
T	scale

int	decimation

Public Attributes inherited from leansdr::runnable_common
const char *	name

Private Attributes
pipereader< T >	in

const char *	format

int	fdout

int	phase

Additional Inherited Members
Protected Attributes inherited from leansdr::runnable
scheduler *	sch

Detailed Description

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

Definition at line 149 of file generic.h.

Constructor & Destructor Documentation

◆ file_printer()

template<typename T >

leansdr::file_printer< T >::file_printer	(	scheduler *	sch,
		const char *	_format,
		pipebuf< T > &	_in,
		int	_fdout,
		int	_decimation = `1`
	)

inline

Definition at line 151 of file generic.h.

                                       : runnable(sch, _in.name),
                                         scale(1), decimation(_decimation),
                                         in(_in), format(_format), fdout(_fdout), phase(0)
     {
     }

Member Function Documentation

◆ run()

template<typename T >

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

inlinevirtual

Reimplemented from leansdr::runnable_common.

Definition at line 158 of file generic.h.

References decimation(), and leansdr::fatal().

     {
         int n = in.readable();
         T *pin = in.rd(), *pend = pin + n;
         for (; pin < pend; ++pin)
         {
             if (++phase >= decimation)
             {
                 phase -= decimation;
                 char buf[256];
                 int len = snprintf(buf, sizeof(buf), format, (*pin) * scale);
                 if (len < 0)
                     fatal("obsolete glibc");
                 int nw = write(fdout, buf, len);
                 if (nw != len)
                     fatal("partial write");
             }
         }
         in.read(n);
     }