#include <generic.h>

Inheritance diagram for leansdr::file_reader< T >:

Collaboration diagram for leansdr::file_reader< T >:

Public Member Functions
	file_reader (scheduler *sch, int _fdin, pipebuf< T > &_out)

void	run ()

void	set_realtime (T &_filler)

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
bool	loop

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

Private Attributes
T *	filler

int	fdin

pipewriter< T >	out

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

Detailed Description

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

Definition at line 44 of file generic.h.

Constructor & Destructor Documentation

◆ file_reader()

template<typename T >

leansdr::file_reader< T >::file_reader	(	scheduler *	sch,
		int	_fdin,
		pipebuf< T > &	_out
	)

inline

Definition at line 46 of file generic.h.

         : runnable(sch, _out.name),
           loop(false),
           filler(NULL),
           fdin(_fdin), out(_out)
     {
     }

Member Function Documentation

◆ run()

template<typename T >

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

inlinevirtual

Reimplemented from leansdr::runnable_common.

Definition at line 53 of file generic.h.

References leansdr::scheduler::debug, leansdr::fatal(), leansdr::file_reader< T >::fdin, leansdr::file_reader< T >::filler, leansdr::file_reader< T >::loop, leansdr::runnable_common::name, leansdr::file_reader< T >::out, and leansdr::runnable::sch.

     {
         size_t size = out.writable() * sizeof(T);
         if (!size)
             return;
 
     again:
         ssize_t nr = read(fdin, out.wr(), size);
         if (nr < 0 && errno == EWOULDBLOCK)
         {
             if (filler)
             {
                 if (sch->debug)
                     fprintf(stderr, "U");
                 out.write(*filler);
             }
             return;
         }
         if (nr < 0)
             fatal("read(file_reader)");
         if (!nr)
         {
             if (!loop)
                 return;
             if (sch->debug)
                 fprintf(stderr, "%s looping\n", name);
             off_t res = lseek(fdin, 0, SEEK_SET);
             if (res == (off_t)-1)
                 fatal("lseek");
             goto again;
         }
 
         // Always stop at element boundary (may block)
         size_t partial = nr % sizeof(T);
         size_t remain = partial ? sizeof(T) - partial : 0;
         while (remain)
         {
             if (sch->debug)
                 fprintf(stderr, "+");
             ssize_t nr2 = read(fdin, (char *)out.wr() + nr, remain);
             if (nr2 <= 0)
                 fatal("partial read");
             nr += nr2;
             remain -= nr2;
         }
 
         out.written(nr / sizeof(T));
     }

Here is the call graph for this function:

◆ set_realtime()

template<typename T >

void leansdr::file_reader< T >::set_realtime ( T & _filler )

inline

Definition at line 102 of file generic.h.

References leansdr::fatal(), leansdr::file_reader< T >::fdin, and leansdr::file_reader< T >::filler.

     {
         int flags = fcntl(fdin, F_GETFL);
         if (fcntl(fdin, F_SETFL, flags | O_NONBLOCK))
             fatal("fcntl");
         filler = new T(_filler);
     }