#include <generic.h>

Inheritance diagram for leansdr::decimator< T >:

Collaboration diagram for leansdr::decimator< T >:

Public Member Functions
	decimator (scheduler *sch, int _d, pipebuf< T > &_in, pipebuf< T > &_out)

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
int	d

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

Private Attributes
pipereader< T >	in

pipewriter< T >	out

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

Detailed Description

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

Definition at line 309 of file generic.h.

Constructor & Destructor Documentation

◆ decimator()

template<typename T>

leansdr::decimator< T >::decimator	(	scheduler *	sch,
		int	_d,
		pipebuf< T > &	_in,
		pipebuf< T > &	_out
	)

inline

Definition at line 313 of file generic.h.

         : runnable(sch, "decimator"),
           d(_d),
           in(_in), out(_out)
     {
     }

Member Function Documentation

◆ run()

template<typename T>

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

inlinevirtual

Reimplemented from leansdr::runnable_common.

Definition at line 319 of file generic.h.

     {
         long count = min(in.readable() / d, out.writable());
         T *pin = in.rd(), *pend = pin + count * d, *pout = out.wr();
         for (; pin < pend; pin += d, ++pout)
             *pout = *pin;
         in.read(count * d);
         out.written(count);
     }