23 #ifndef INCLUDED_GR_RUNTIME_BLOCK_H 24 #define INCLUDED_GR_RUNTIME_BLOCK_H 66 WORK_CALLED_PRODUCE = -2,
91 unsigned history()
const;
92 void set_history(
unsigned history);
113 void declare_sample_delay(
int which,
unsigned delay);
119 void declare_sample_delay(
unsigned delay);
129 unsigned sample_delay(
int which)
const;
152 virtual void forecast(
int noutput_items,
169 virtual int general_work(
int noutput_items,
182 virtual bool start();
199 void set_output_multiple(
int multiple);
220 void set_alignment(
int multiple);
223 void set_unaligned(
int na);
225 void set_is_unaligned(
bool u);
237 void consume(
int which_input,
int how_many_items);
245 void consume_each(
int how_many_items);
258 void produce(
int which_output,
int how_many_items);
269 void set_relative_rate(
double relative_rate);
288 virtual int fixed_rate_ninput_to_noutput(
int ninput);
295 virtual int fixed_rate_noutput_to_ninput(
int noutput);
300 uint64_t nitems_read(
unsigned int which_input);
305 uint64_t nitems_written(
unsigned int which_output);
338 int max_noutput_items();
346 void set_max_noutput_items(
int m);
363 void unset_max_noutput_items();
369 bool is_set_max_noutput_items();
378 void expand_minmax_buffer(
int port);
383 long max_output_buffer(
size_t i);
401 void set_max_output_buffer(
long max_output_buffer);
420 void set_max_output_buffer(
int port,
long max_output_buffer);
425 long min_output_buffer(
size_t i);
444 void set_min_output_buffer(
long min_output_buffer);
463 void set_min_output_buffer(
int port,
long min_output_buffer);
470 float pc_noutput_items();
475 float pc_noutput_items_avg();
480 float pc_noutput_items_var();
485 float pc_nproduced();
490 float pc_nproduced_avg();
495 float pc_nproduced_var();
500 float pc_input_buffers_full(
int which);
505 float pc_input_buffers_full_avg(
int which);
510 float pc_input_buffers_full_var(
int which);
515 std::vector<float> pc_input_buffers_full();
520 std::vector<float> pc_input_buffers_full_avg();
525 std::vector<float> pc_input_buffers_full_var();
530 float pc_output_buffers_full(
int which);
535 float pc_output_buffers_full_avg(
int which);
540 float pc_output_buffers_full_var(
int which);
545 std::vector<float> pc_output_buffers_full();
550 std::vector<float> pc_output_buffers_full_avg();
555 std::vector<float> pc_output_buffers_full_var();
560 float pc_work_time();
565 float pc_work_time_avg();
570 float pc_work_time_var();
575 float pc_work_time_total();
580 float pc_throughput_avg();
585 void reset_perf_counters();
614 void set_processor_affinity(
const std::vector<int> &mask);
619 void unset_processor_affinity();
629 int active_thread_priority();
641 bool update_rate()
const;
656 int d_output_multiple;
657 bool d_output_multiple_set;
660 double d_relative_rate;
661 block_detail_sptr d_detail;
663 unsigned d_attr_delay;
665 bool d_max_noutput_items_set;
666 int d_max_noutput_items;
667 int d_min_noutput_items;
669 std::vector<int> d_affinity;
677 block(
const std::string &name,
704 this->add_item_tag(which_output, tag);
713 void add_item_tag(
unsigned int which_output,
const tag_t &tag);
738 this->remove_item_tag(which_input, tag);
747 void remove_item_tag(
unsigned int which_input,
const tag_t &tag);
762 void get_tags_in_range(std::vector<tag_t> &
v,
763 unsigned int which_input,
782 void get_tags_in_range(std::vector<tag_t> &v,
783 unsigned int which_input,
809 void get_tags_in_window(std::vector<tag_t> &v,
810 unsigned int which_input,
826 void get_tags_in_window(std::vector<tag_t> &v,
827 unsigned int which_input,
832 void enable_update_rate(
bool en);
853 block_detail_sptr
detail()
const {
return d_detail; }
854 void set_detail(block_detail_sptr detail) { d_detail = detail; }
858 void notify_msg_neighbors();
869 inline block_sptr cast_to_block_sptr(basic_block_sptr p)
double relative_rate() const
return the approximate output rate / input rate
Definition: block.h:274
boost::shared_ptr< io_signature > sptr
Definition: io_signature.h:45
pmt::pmt_t value
the value of tag (as a PMT)
Definition: tags.h:40
uint64_t offset
the item tag occurred at (as a uint64_t)
Definition: tags.h:34
gr::logger_ptr d_debug_logger
Definition: block.h:847
std::vector< int > processor_affinity()
Get the current processor affinity.
Definition: block.h:624
std::vector< block_sptr > block_vector_t
Definition: block.h:866
block_detail_sptr detail() const
Definition: block.h:853
int output_multiple() const
Definition: block.h:200
void set_fixed_rate(bool fixed_rate)
Definition: block.h:681
void add_item_tag(unsigned int which_output, uint64_t abs_offset, const pmt::pmt_t &key, const pmt::pmt_t &value, const pmt::pmt_t &srcid=pmt::PMT_F)
Adds a new tag onto the given output buffer.
Definition: block.h:693
Definition: block_gateway.h:48
#define PMT_F
Definition: pmt.h:105
gr::thread::mutex d_setlock
Definition: block.h:842
bool output_multiple_set() const
Definition: block.h:201
gr::logger_ptr d_logger
Definition: block.h:846
std::vector< const void * > gr_vector_const_void_star
Definition: gnuradio-runtime/include/gnuradio/types.h:38
Definition: cc_common.h:45
#define GR_RUNTIME_API
Definition: gnuradio-runtime/include/gnuradio/api.h:30
void clear_finished()
Make sure we dont think we are finished.
Definition: block.h:862
bool is_unaligned() const
Definition: block.h:226
GR_RUNTIME_API int set_thread_priority(gr_thread_t thread, int priority)
set current thread priority for a given thread ID
std::vector< long > d_min_output_buffer
Definition: block.h:835
std::vector< void * > gr_vector_void_star
Definition: gnuradio-runtime/include/gnuradio/types.h:37
Definition: block_gateway.h:46
std::vector< int > gr_vector_int
Definition: gnuradio-runtime/include/gnuradio/types.h:33
std::vector< block_sptr >::iterator block_viter_t
Definition: block.h:867
std::vector< long > d_max_output_buffer
Definition: block.h:834
Include this header to use the message passing features.
Definition: basic_block.h:45
void * logger_ptr
Definition: logger.h:696
int unaligned() const
Definition: block.h:224
The abstract base class for all signal processing blocks.Basic blocks are the bare abstraction of an ...
Definition: basic_block.h:58
block(void)
Definition: block.h:676
void set_min_noutput_items(int m)
Set the minimum number of output items this block can produce during a call to work.
Definition: block.h:332
GR_RUNTIME_API int thread_priority(gr_thread_t thread)
get current thread priority for a given thread ID
tag_propagation_policy_t
enum to represent different tag propagation policies.
Definition: block.h:73
int min_noutput_items() const
Return the minimum number of output items this block can produce during a call to work...
Definition: block.h:324
bool is_pc_rpc_set()
Checks if this block is already exporting perf. counters to ControlPort.
Definition: block.h:597
int alignment() const
Definition: block.h:221
pmt::pmt_t key
the key of tag (as a PMT symbol)
Definition: tags.h:37
Definition: block_gateway.h:45
std::ostream & operator<<(std::ostream &os, basic_block_sptr basic_block)
Definition: basic_block.h:399
boost::mutex mutex
Definition: thread.h:48
Definition: block_gateway.h:47
pmt::pmt_t srcid
the source ID of tag (as a PMT)
Definition: tags.h:43
boost::intrusive_ptr< pmt_base > pmt_t
typedef for shared pointer (transparent reference counting). See http://www.boost.org/libs/smart_ptr/smart_ptr.htm
Definition: pmt.h:56
The abstract base class for all 'terminal' processing blocks.A signal processing flow is constructed ...
Definition: block.h:60
bool fixed_rate() const
Return true if this block has a fixed input to output rate.
Definition: block.h:136
void set_detail(block_detail_sptr detail)
Definition: block.h:854
void no_pc_rpc()
If the block calls this in its constructor, it's perf. counters will not be exported.
Definition: block.h:603
void remove_item_tag(unsigned int which_input, uint64_t abs_offset, const pmt::pmt_t &key, const pmt::pmt_t &value, const pmt::pmt_t &srcid=pmt::PMT_F)
DEPRECATED. Will be removed in 3.8.
Definition: block.h:727