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);
233 void consume(
int which_input,
int how_many_items);
239 void consume_each(
int how_many_items);
248 void produce(
int which_output,
int how_many_items);
259 void set_relative_rate(
double relative_rate);
278 virtual int fixed_rate_ninput_to_noutput(
int ninput);
285 virtual int fixed_rate_noutput_to_ninput(
int noutput);
290 uint64_t nitems_read(
unsigned int which_input);
295 uint64_t nitems_written(
unsigned int which_output);
328 int max_noutput_items();
336 void set_max_noutput_items(
int m);
353 void unset_max_noutput_items();
359 bool is_set_max_noutput_items();
368 void expand_minmax_buffer(
int port);
373 long max_output_buffer(
size_t i);
391 void set_max_output_buffer(
long max_output_buffer);
410 void set_max_output_buffer(
int port,
long max_output_buffer);
415 long min_output_buffer(
size_t i);
434 void set_min_output_buffer(
long min_output_buffer);
453 void set_min_output_buffer(
int port,
long min_output_buffer);
460 float pc_noutput_items();
465 float pc_noutput_items_avg();
470 float pc_noutput_items_var();
475 float pc_nproduced();
480 float pc_nproduced_avg();
485 float pc_nproduced_var();
490 float pc_input_buffers_full(
int which);
495 float pc_input_buffers_full_avg(
int which);
500 float pc_input_buffers_full_var(
int which);
505 std::vector<float> pc_input_buffers_full();
510 std::vector<float> pc_input_buffers_full_avg();
515 std::vector<float> pc_input_buffers_full_var();
520 float pc_output_buffers_full(
int which);
525 float pc_output_buffers_full_avg(
int which);
530 float pc_output_buffers_full_var(
int which);
535 std::vector<float> pc_output_buffers_full();
540 std::vector<float> pc_output_buffers_full_avg();
545 std::vector<float> pc_output_buffers_full_var();
550 float pc_work_time();
555 float pc_work_time_avg();
560 float pc_work_time_var();
565 float pc_work_time_total();
570 float pc_throughput_avg();
575 void reset_perf_counters();
604 void set_processor_affinity(
const std::vector<int> &mask);
609 void unset_processor_affinity();
619 int active_thread_priority();
631 bool update_rate()
const;
646 int d_output_multiple;
647 bool d_output_multiple_set;
650 double d_relative_rate;
651 block_detail_sptr d_detail;
653 unsigned d_attr_delay;
655 bool d_max_noutput_items_set;
656 int d_max_noutput_items;
657 int d_min_noutput_items;
659 std::vector<int> d_affinity;
667 block(
const std::string &name,
694 this->add_item_tag(which_output, tag);
703 void add_item_tag(
unsigned int which_output,
const tag_t &tag);
728 this->remove_item_tag(which_input, tag);
737 void remove_item_tag(
unsigned int which_input,
const tag_t &tag);
752 void get_tags_in_range(std::vector<tag_t> &
v,
753 unsigned int which_input,
772 void get_tags_in_range(std::vector<tag_t> &v,
773 unsigned int which_input,
799 void get_tags_in_window(std::vector<tag_t> &v,
800 unsigned int which_input,
816 void get_tags_in_window(std::vector<tag_t> &v,
817 unsigned int which_input,
822 void enable_update_rate(
bool en);
843 block_detail_sptr
detail()
const {
return d_detail; }
844 void set_detail(block_detail_sptr detail) { d_detail = detail; }
848 void notify_msg_neighbors();
859 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:264
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:837
std::vector< int > processor_affinity()
Get the current processor affinity.
Definition: block.h:614
std::vector< block_sptr > block_vector_t
Definition: block.h:856
block_detail_sptr detail() const
Definition: block.h:843
int output_multiple() const
Definition: block.h:200
void set_fixed_rate(bool fixed_rate)
Definition: block.h:671
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:683
Definition: block_gateway.h:48
#define PMT_F
Definition: pmt.h:105
gr::thread::mutex d_setlock
Definition: block.h:832
bool output_multiple_set() const
Definition: block.h:201
gr::logger_ptr d_logger
Definition: block.h:836
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:852
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:825
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:857
std::vector< long > d_max_output_buffer
Definition: block.h:824
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:666
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:322
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:314
bool is_pc_rpc_set()
Checks if this block is already exporting perf. counters to ControlPort.
Definition: block.h:587
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:844
void no_pc_rpc()
If the block calls this in its constructor, it's perf. counters will not be exported.
Definition: block.h:593
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:717