Implementation details to support the signal processing abstractionThis class contains implementation detail that should be "out of sight" of almost all users of GNU Radio. This decoupling also means that we can make changes to the guts without having to recompile everything. More...

#include <gr_block_detail.h>

Public Member Functions
	~gr_block_detail ()
int	ninputs () const
int	noutputs () const
bool	sink_p () const
bool	source_p () const
void	set_done (bool done)
bool	done () const
void	set_input (unsigned int which, gr_buffer_reader_sptr reader)
gr_buffer_reader_sptr	input (unsigned int which)
void	set_output (unsigned int which, gr_buffer_sptr buffer)
gr_buffer_sptr	output (unsigned int which)
void	consume (int which_input, int how_many_items)
	Tell the scheduler `how_many_items` of input stream `which_input` were consumed.
void	consume_each (int how_many_items)
	Tell the scheduler `how_many_items` were consumed on each input stream.
void	produce (int which_output, int how_many_items)
	Tell the scheduler `how_many_items` were produced on output stream `which_output`.
void	produce_each (int how_many_items)
	Tell the scheduler `how_many_items` were produced on each output stream.
uint64_t	nitems_read (unsigned int which_input)
uint64_t	nitems_written (unsigned int which_output)
void	add_item_tag (unsigned int which_output, const gr_tag_t &tag)
	Adds a new tag to the given output stream.
void	remove_item_tag (unsigned int which_input, const gr_tag_t &tag, long id)
	Removes a tag from the given input stream.
void	get_tags_in_range (std::vector< gr_tag_t > &v, unsigned int which_input, uint64_t abs_start, uint64_t abs_end, long id)
	Given a [start,end), returns a vector of all tags in the range.
void	get_tags_in_range (std::vector< gr_tag_t > &v, unsigned int which_input, uint64_t abs_start, uint64_t abs_end, const pmt::pmt_t &key, long id)
	Given a [start,end), returns a vector of all tags in the range with a given key.
void	set_processor_affinity (const std::vector< int > &mask)
	Set core affinity of block to the cores in the vector mask.
void	unset_processor_affinity ()
	Unset core affinity.
void	start_perf_counters ()
void	stop_perf_counters (int noutput_items, int nproduced)
void	reset_perf_counters ()
float	pc_noutput_items ()
float	pc_nproduced ()
float	pc_input_buffers_full (size_t which)
std::vector< float >	pc_input_buffers_full ()
float	pc_output_buffers_full (size_t which)
std::vector< float >	pc_output_buffers_full ()
float	pc_work_time ()
float	pc_noutput_items_var ()
float	pc_nproduced_var ()
float	pc_input_buffers_full_var (size_t which)
std::vector< float >	pc_input_buffers_full_var ()
float	pc_output_buffers_full_var (size_t which)
std::vector< float >	pc_output_buffers_full_var ()
float	pc_work_time_var ()
Public Attributes
bool	threaded
gruel::gr_thread_t	thread
gr_tpb_detail	d_tpb
int	d_produce_or
Friends
struct	gr_tpb_detail
GR_CORE_API gr_block_detail_sptr	gr_make_block_detail (unsigned int ninputs, unsigned int noutputs)

Detailed Description

Implementation details to support the signal processing abstraction

This class contains implementation detail that should be "out of sight" of almost all users of GNU Radio. This decoupling also means that we can make changes to the guts without having to recompile everything.

Constructor & Destructor Documentation

gr_block_detail::~gr_block_detail ( )

Member Function Documentation

void gr_block_detail::add_item_tag	(	unsigned int	which_output,
		const gr_tag_t &	tag
	)

Adds a new tag to the given output stream.

Calls gr_buffer::add_item_tag(), which appends the tag onto its deque.

Parameters:

which_output	an integer of which output stream to attach the tag
tag	the tag object to add

void gr_block_detail::consume	(	int	which_input,
		int	how_many_items
	)

Tell the scheduler how_many_items of input stream which_input were consumed.

void gr_block_detail::consume_each ( int how_many_items )

Tell the scheduler how_many_items were consumed on each input stream.

bool gr_block_detail::done ( ) const [inline]

void gr_block_detail::get_tags_in_range	(	std::vector< gr_tag_t > &	v,
		unsigned int	which_input,
		uint64_t	abs_start,
		uint64_t	abs_end,
		long	id
	)

Given a [start,end), returns a vector of all tags in the range.

Pass-through function to gr_buffer_reader to get a vector of tags in given range. Range of counts is from start to end-1.

Tags are tuples of: (item count, source id, key, value)

Parameters:

v	a vector reference to return tags into
which_input	an integer of which input stream to pull from
abs_start	a uint64 count of the start of the range of interest
abs_end	a uint64 count of the end of the range of interest
id	Block ID

void gr_block_detail::get_tags_in_range	(	std::vector< gr_tag_t > &	v,
		unsigned int	which_input,
		uint64_t	abs_start,
		uint64_t	abs_end,
		const pmt::pmt_t &	key,
		long	id
	)

Given a [start,end), returns a vector of all tags in the range with a given key.

Calls get_tags_in_range(which_input, abs_start, abs_end) to get a vector of tags from the buffers. This function then provides a secondary filter to the tags to extract only tags with the given 'key'.

Tags are tuples of: (item count, source id, key, value)

Parameters:

v	a vector reference to return tags into
which_input	an integer of which input stream to pull from
abs_start	a uint64 count of the start of the range of interest
abs_end	a uint64 count of the end of the range of interest
key	a PMT symbol to select only tags of this key
id	Block ID

gr_buffer_reader_sptr gr_block_detail::input ( unsigned int which ) [inline]

int gr_block_detail::ninputs ( ) const [inline]

uint64_t gr_block_detail::nitems_read ( unsigned int which_input )

uint64_t gr_block_detail::nitems_written ( unsigned int which_output )

int gr_block_detail::noutputs ( ) const [inline]

gr_buffer_sptr gr_block_detail::output ( unsigned int which ) [inline]

float gr_block_detail::pc_input_buffers_full ( size_t which )

std::vector<float> gr_block_detail::pc_input_buffers_full ( )

float gr_block_detail::pc_input_buffers_full_var ( size_t which )

std::vector<float> gr_block_detail::pc_input_buffers_full_var ( )

float gr_block_detail::pc_noutput_items ( )

float gr_block_detail::pc_noutput_items_var ( )

float gr_block_detail::pc_nproduced ( )

float gr_block_detail::pc_nproduced_var ( )

std::vector<float> gr_block_detail::pc_output_buffers_full ( )

float gr_block_detail::pc_output_buffers_full ( size_t which )

float gr_block_detail::pc_output_buffers_full_var ( size_t which )

std::vector<float> gr_block_detail::pc_output_buffers_full_var ( )

float gr_block_detail::pc_work_time ( )

float gr_block_detail::pc_work_time_var ( )

void gr_block_detail::produce	(	int	which_output,
		int	how_many_items
	)

Tell the scheduler how_many_items were produced on output stream which_output.

void gr_block_detail::produce_each ( int how_many_items )

Tell the scheduler how_many_items were produced on each output stream.

void gr_block_detail::remove_item_tag	(	unsigned int	which_input,
		const gr_tag_t &	tag,
		long	id
	)

Removes a tag from the given input stream.

Calls gr_buffer::remove_item_tag(). The tag in question will then no longer appear on subsequent calls of get_tags_in_range().

Parameters:

which_input	an integer of which input stream to remove the tag from
tag	the tag object to add
id	The unique block ID (use gr_block::unique_id())

void gr_block_detail::reset_perf_counters ( )

void gr_block_detail::set_done ( bool done )

void gr_block_detail::set_input	(	unsigned int	which,
		gr_buffer_reader_sptr	reader
	)

void gr_block_detail::set_output	(	unsigned int	which,
		gr_buffer_sptr	buffer
	)

void gr_block_detail::set_processor_affinity ( const std::vector< int > & mask )

Set core affinity of block to the cores in the vector mask.

Parameters:

mask	a vector of ints of the core numbers available to this block.

bool gr_block_detail::sink_p ( ) const [inline]

bool gr_block_detail::source_p ( ) const [inline]

void gr_block_detail::start_perf_counters ( )

void gr_block_detail::stop_perf_counters	(	int	noutput_items,
		int	nproduced
	)

void gr_block_detail::unset_processor_affinity ( )

Unset core affinity.

Friends And Related Function Documentation

GR_CORE_API gr_block_detail_sptr gr_make_block_detail	(	unsigned int	ninputs,
		unsigned int	noutputs
	)		`[friend]`

friend struct gr_tpb_detail [friend]

Member Data Documentation

int gr_block_detail::d_produce_or

gr_tpb_detail gr_block_detail::d_tpb

gruel::gr_thread_t gr_block_detail::thread

bool gr_block_detail::threaded

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

gr_block_detail.h

gr_block_detail Class ReferenceImplementation Details

Public Member Functions

Public Attributes

Friends

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Friends And Related Function Documentation

Member Data Documentation

gr_block_detail Class Reference
Implementation Details