leansdr::scheduler Struct Reference

#include <framework.h>

Collaboration diagram for leansdr::scheduler:

Public Member Functions
	scheduler ()
void	add_pipe (pipebuf_common *p)
void	add_runnable (runnable_common *r)
void	step ()
void	run ()
void	shutdown ()
unsigned long long	hash ()
void	dump ()

Public Attributes
pipebuf_common *	pipes [MAX_PIPES]
int	npipes
runnable_common *	runnables [MAX_RUNNABLES]
int	nrunnables
window_placement *	windows
bool	verbose
bool	debug
bool	debug2

Detailed Description

Definition at line 114 of file framework.h.

Constructor & Destructor Documentation

scheduler()

leansdr::scheduler::scheduler ( )

inline

Definition at line 123 of file framework.h.

                : npipes(0),
                  nrunnables(0),
                  windows(NULL),
                  verbose(false),
                  debug(false),
                  debug2(false)
    {
    }

Member Function Documentation

add_pipe()

void leansdr::scheduler::add_pipe ( pipebuf_common *  p )

inline

Definition at line 132 of file framework.h.

References leansdr::fail().

Referenced by leansdr::pipebuf< leansdr::complex< leansdr::f32 > >::pipebuf().

    {
        if (npipes == MAX_PIPES)
            fail("MAX_PIPES");
        pipes[npipes++] = p;
    }

Here is the call graph for this function:

Here is the caller graph for this function:

add_runnable()

void leansdr::scheduler::add_runnable ( runnable_common *  r )

inline

Definition at line 139 of file framework.h.

References leansdr::fail().

    {
        if (nrunnables == MAX_RUNNABLES)
            fail("MAX_RUNNABLES");
        runnables[nrunnables++] = r;
    }

Here is the call graph for this function:

dump()

void leansdr::scheduler::dump ( )

inline

Definition at line 180 of file framework.h.

References leansdr::pipebuf_common::dump(), and i.

    {
        fprintf(stderr, "\n");
        std::size_t total_bufs = 0;
        for (int i = 0; i < npipes; ++i)
            pipes[i]->dump(&total_bufs);
        fprintf(stderr, "Total buffer memory: %ld KiB\n",
                (unsigned long)total_bufs / 1024);
    }

Here is the call graph for this function:

hash()

unsigned long long leansdr::scheduler::hash ( )

inline

Definition at line 172 of file framework.h.

References leansdr::pipebuf_common::hash(), and i.

    {
        unsigned long long h = 0;
        for (int i = 0; i < npipes; ++i)
            h += (1 + i) * pipes[i]->hash();
        return h;
    }

Here is the call graph for this function:

run()

void leansdr::scheduler::run ( )

inline

Definition at line 152 of file framework.h.

References leansdr::pipebuf_common::hash().

    {
        unsigned long long prev_hash = 0;

        while (1)
        {
            step();
            unsigned long long h = hash();
            if (h == prev_hash)
                break;
            prev_hash = h;
        }
    }

Here is the call graph for this function:

shutdown()

void leansdr::scheduler::shutdown ( )

inline

Definition at line 166 of file framework.h.

References i.

Referenced by DATVDemod::CleanUpDATVFramework().

    {
        for (int i = 0; i < nrunnables; ++i)
            runnables[i]->shutdown();
    }

Here is the caller graph for this function:

step()

void leansdr::scheduler::step ( )

inline

Definition at line 146 of file framework.h.

References i.

Referenced by DATVDemod::feed().

    {
        for (int i = 0; i < nrunnables; ++i)
            runnables[i]->run();
    }

Here is the caller graph for this function:

Member Data Documentation

debug

bool leansdr::scheduler::debug

Definition at line 121 of file framework.h.

Referenced by leansdr::auto_notch< leansdr::f32 >::detect(), leansdr::hdlc_sync::hdlc_sync(), leansdr::deconvol_sync< leansdr::u8, 0 >::inverse_convolution(), leansdr::rotator< leansdr::f32 >::rotator(), leansdr::file_reader< T >::run(), leansdr::dvb_deconvol_sync< Tin >::run(), leansdr::rs_decoder< leansdr::u8, 0 >::run(), leansdr::derandomizer::run(), leansdr::viterbi_sync::run(), leansdr::deconvol_sync< leansdr::u8, 0 >::run_decoding(), leansdr::mpeg_sync< leansdr::u8, 0 >::run_decoding(), leansdr::s2_fecdec< SOFTBIT, SOFTBYTE >::s2_fecdec(), leansdr::s2_fecenc::s2_fecenc(), and leansdr::mpeg_sync< leansdr::u8, 0 >::search_sync().

debug2

bool leansdr::scheduler::debug2

Definition at line 121 of file framework.h.

npipes

int leansdr::scheduler::npipes

Definition at line 117 of file framework.h.

nrunnables

int leansdr::scheduler::nrunnables

Definition at line 119 of file framework.h.

pipes

pipebuf_common* leansdr::scheduler::pipes[MAX_PIPES]

Definition at line 116 of file framework.h.

runnables

runnable_common* leansdr::scheduler::runnables[MAX_RUNNABLES]

Definition at line 118 of file framework.h.

verbose

bool leansdr::scheduler::verbose

Definition at line 121 of file framework.h.

Referenced by leansdr::deconvol_sync< leansdr::u8, 0 >::deconvol_sync(), leansdr::fir_filter< leansdr::complex, float >::run(), and leansdr::fir_resampler< T, Tc >::run().

windows

window_placement* leansdr::scheduler::windows

Definition at line 120 of file framework.h.

---

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

• plugins/channelrx/demoddatv/leansdr/framework.h