leansdr::pipebuf< T > Struct Template Reference

#include <framework.h>

Inheritance diagram for leansdr::pipebuf< T >:

Collaboration diagram for leansdr::pipebuf< T >:

Public Member Functions
int	sizeofT ()
	pipebuf (scheduler *sch, const char *name, unsigned long size)
int	add_reader ()
void	pack ()
long long	hash ()
void	dump (std::size_t *total_bufs)
Public Member Functions inherited from leansdr::pipebuf_common
	pipebuf_common (const char *_name)
virtual	~pipebuf_common ()

Public Attributes
T *	buf
T *	rds [MAX_READERS]
int	nrd
T *	wr
T *	end
unsigned long	min_write
unsigned long	total_written
unsigned long	total_read
Public Attributes inherited from leansdr::pipebuf_common
const char *	name

Detailed Description

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

Definition at line 203 of file framework.h.

Constructor & Destructor Documentation

pipebuf()

template<typename T>

leansdr::pipebuf< T >::pipebuf ( scheduler *  sch, const char *  name, unsigned long  size  )

inline

Definition at line 216 of file framework.h.

                                                                  : pipebuf_common(name),
                                                                    buf(new T[size]),
                                                                    nrd(0), wr(buf),
                                                                    end(buf + size),
                                                                    min_write(1),
                                                                    total_written(0),
                                                                    total_read(0)
    {
        sch->add_pipe(this);
    }

Member Function Documentation

add_reader()

template<typename T>

int leansdr::pipebuf< T >::add_reader ( )

inline

Definition at line 227 of file framework.h.

    {
        if (nrd == MAX_READERS)
            fail("too many readers");
        rds[nrd] = wr;
        return nrd++;
    }

dump()

template<typename T>

void leansdr::pipebuf< T >::dump ( std::size_t *  total_bufs )

inlinevirtual

Reimplemented from leansdr::pipebuf_common.

Definition at line 252 of file framework.h.

    {
        if (total_written < 10000)
            fprintf(stderr, ".%-16s : %4ld/%4ld", name, total_read,
                    total_written);
        else if (total_written < 1000000)
            fprintf(stderr, ".%-16s : %3ldk/%3ldk", name, total_read / 1000,
                    total_written / 1000);
        else
            fprintf(stderr, ".%-16s : %3ldM/%3ldM", name, total_read / 1000000,
                    total_written / 1000000);
        *total_bufs += (end - buf) * sizeof(T);
        unsigned long nw = end - wr;
        fprintf(stderr, " %6ld writable %c,", nw, (nw < min_write) ? '!' : ' ');
        T *rd = wr;
        for (int j = 0; j < nrd; ++j)
            if (rds[j] < rd)
                rd = rds[j];
        fprintf(stderr, " %6d unread (", (int)(wr - rd));
        for (int j = 0; j < nrd; ++j)
            fprintf(stderr, " %d", (int)(wr - rds[j]));
        fprintf(stderr, " )\n");
    }

hash()

template<typename T>

long long leansdr::pipebuf< T >::hash ( )

inlinevirtual

Reimplemented from leansdr::pipebuf_common.

Definition at line 247 of file framework.h.

    {
        return total_written + total_read;
    }

pack()

template<typename T>

void leansdr::pipebuf< T >::pack ( )

inline

Definition at line 235 of file framework.h.

Referenced by leansdr::pipewriter< leansdr::complex< leansdr::f32 > >::writable().

    {
        T *rd = wr;
        for (int i = 0; i < nrd; ++i)
            if (rds[i] < rd)
                rd = rds[i];
        memmove(buf, rd, (wr - rd) * sizeof(T));
        wr -= rd - buf;
        for (int i = 0; i < nrd; ++i)
            rds[i] -= rd - buf;
    }

Here is the caller graph for this function:

sizeofT()

template<typename T>

int leansdr::pipebuf< T >::sizeofT ( )

inlinevirtual

Reimplemented from leansdr::pipebuf_common.

Definition at line 211 of file framework.h.

    {
        return sizeof(T);
    }

Member Data Documentation

buf

template<typename T>

T* leansdr::pipebuf< T >::buf

Definition at line 205 of file framework.h.

end

template<typename T>

T* leansdr::pipebuf< T >::end

Definition at line 209 of file framework.h.

Referenced by leansdr::pipewriter< leansdr::complex< leansdr::f32 > >::writable(), and leansdr::pipewriter< leansdr::complex< leansdr::f32 > >::written().

min_write

template<typename T>

unsigned long leansdr::pipebuf< T >::min_write

Definition at line 275 of file framework.h.

Referenced by leansdr::pipewriter< leansdr::complex< leansdr::f32 > >::pipewriter(), and leansdr::pipewriter< leansdr::complex< leansdr::f32 > >::writable().

nrd

template<typename T>

int leansdr::pipebuf< T >::nrd

Definition at line 207 of file framework.h.

rds

template<typename T>

T* leansdr::pipebuf< T >::rds[MAX_READERS]

Definition at line 206 of file framework.h.

Referenced by leansdr::pipereader< leansdr::complex< leansdr::f32 > >::rd(), leansdr::pipereader< leansdr::complex< leansdr::f32 > >::read(), and leansdr::pipereader< leansdr::complex< leansdr::f32 > >::readable().

total_read

template<typename T>

unsigned long leansdr::pipebuf< T >::total_read

Definition at line 276 of file framework.h.

Referenced by leansdr::pipereader< leansdr::complex< leansdr::f32 > >::read().

total_written

template<typename T>

unsigned long leansdr::pipebuf< T >::total_written

Definition at line 276 of file framework.h.

Referenced by leansdr::pipewriter< leansdr::complex< leansdr::f32 > >::written().

wr

template<typename T>

T* leansdr::pipebuf< T >::wr

Definition at line 208 of file framework.h.

Referenced by leansdr::pipereader< leansdr::complex< leansdr::f32 > >::read(), leansdr::pipereader< leansdr::complex< leansdr::f32 > >::readable(), leansdr::pipewriter< leansdr::complex< leansdr::f32 > >::wr(), leansdr::pipewriter< leansdr::complex< leansdr::f32 > >::writable(), and leansdr::pipewriter< leansdr::complex< leansdr::f32 > >::written().

---

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

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