23 #ifndef INCLUDED_GR_RUNTIME_BLOCK_H
24 #define INCLUDED_GR_RUNTIME_BLOCK_H
66 WORK_CALLED_PRODUCE = -2,
85 unsigned history()
const;
86 void set_history(
unsigned history);
107 void declare_sample_delay(
int which,
unsigned delay);
113 void declare_sample_delay(
unsigned delay);
123 unsigned sample_delay(
int which)
const;
146 virtual void forecast(
int noutput_items,
163 virtual int general_work(
int noutput_items,
176 virtual bool start();
193 void set_output_multiple(
int multiple);
214 void set_alignment(
int multiple);
217 void set_unaligned(
int na);
219 void set_is_unaligned(
bool u);
227 void consume(
int which_input,
int how_many_items);
233 void consume_each(
int how_many_items);
242 void produce(
int which_output,
int how_many_items);
253 void set_relative_rate(
double relative_rate);
272 virtual int fixed_rate_ninput_to_noutput(
int ninput);
279 virtual int fixed_rate_noutput_to_ninput(
int noutput);
284 uint64_t nitems_read(
unsigned int which_input);
289 uint64_t nitems_written(
unsigned int which_output);
322 int max_noutput_items();
330 void set_max_noutput_items(
int m);
347 void unset_max_noutput_items();
353 bool is_set_max_noutput_items();
362 void expand_minmax_buffer(
int port);
367 long max_output_buffer(
size_t i);
372 void set_max_output_buffer(
long max_output_buffer);
377 void set_max_output_buffer(
int port,
long max_output_buffer);
382 long min_output_buffer(
size_t i);
387 void set_min_output_buffer(
long min_output_buffer);
392 void set_min_output_buffer(
int port,
long min_output_buffer);
399 float pc_noutput_items();
404 float pc_noutput_items_avg();
409 float pc_noutput_items_var();
414 float pc_nproduced();
419 float pc_nproduced_avg();
424 float pc_nproduced_var();
429 float pc_input_buffers_full(
int which);
434 float pc_input_buffers_full_avg(
int which);
439 float pc_input_buffers_full_var(
int which);
444 std::vector<float> pc_input_buffers_full();
449 std::vector<float> pc_input_buffers_full_avg();
454 std::vector<float> pc_input_buffers_full_var();
459 float pc_output_buffers_full(
int which);
464 float pc_output_buffers_full_avg(
int which);
469 float pc_output_buffers_full_var(
int which);
474 std::vector<float> pc_output_buffers_full();
479 std::vector<float> pc_output_buffers_full_avg();
484 std::vector<float> pc_output_buffers_full_var();
489 float pc_work_time();
494 float pc_work_time_avg();
499 float pc_work_time_var();
504 float pc_work_time_total();
509 float pc_throughput_avg();
514 void reset_perf_counters();
543 void set_processor_affinity(
const std::vector<int> &mask);
548 void unset_processor_affinity();
558 int active_thread_priority();
570 bool update_rate()
const;
585 int d_output_multiple;
586 bool d_output_multiple_set;
589 double d_relative_rate;
590 block_detail_sptr d_detail;
592 unsigned d_attr_delay;
594 bool d_max_noutput_items_set;
595 int d_max_noutput_items;
596 int d_min_noutput_items;
598 std::vector<int> d_affinity;
606 block(
const std::string &name,
633 this->add_item_tag(which_output, tag);
642 void add_item_tag(
unsigned int which_output,
const tag_t &tag);
667 this->remove_item_tag(which_input, tag);
676 void remove_item_tag(
unsigned int which_input,
const tag_t &tag);
691 void get_tags_in_range(std::vector<tag_t> &
v,
692 unsigned int which_input,
711 void get_tags_in_range(std::vector<tag_t> &
v,
712 unsigned int which_input,
738 void get_tags_in_window(std::vector<tag_t> &
v,
739 unsigned int which_input,
755 void get_tags_in_window(std::vector<tag_t> &
v,
756 unsigned int which_input,
761 void enable_update_rate(
bool en);
782 block_detail_sptr
detail()
const {
return d_detail; }
783 void set_detail(block_detail_sptr detail) { d_detail = detail; }
787 void notify_msg_neighbors();
798 inline block_sptr cast_to_block_sptr(basic_block_sptr p)
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:776
std::vector< int > processor_affinity()
Get the current processor affinity.
Definition: block.h:553
std::vector< block_sptr > block_vector_t
Definition: block.h:795
block_detail_sptr detail() const
Definition: block.h:782
void set_fixed_rate(bool fixed_rate)
Definition: block.h:610
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:622
bool output_multiple_set() const
Definition: block.h:195
gr::thread::mutex d_setlock
Definition: block.h:771
gr::logger_ptr d_logger
Definition: block.h:775
std::vector< const void * > gr_vector_const_void_star
Definition: gnuradio-runtime/include/gnuradio/types.h:38
Definition: cc_common.h:45
int unaligned() const
Definition: block.h:218
#define GR_RUNTIME_API
Definition: gnuradio-runtime/include/gnuradio/api.h:30
int min_noutput_items() const
Return the minimum number of output items this block can produce during a call to work...
Definition: block.h:308
void clear_finished()
Make sure we dont think we are finished.
Definition: block.h:791
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:764
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:796
std::vector< long > d_max_output_buffer
Definition: block.h:763
The abstract base class for all signal processing blocks.Basic blocks are the bare abstraction of an ...
Definition: basic_block.h:58
bool fixed_rate() const
Return true if this block has a fixed input to output rate.
Definition: block.h:130
block(void)
Definition: block.h:605
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:316
GR_RUNTIME_API int thread_priority(gr_thread_t thread)
get current thread priority for a given thread ID
tag_propagation_policy_t
Definition: block.h:70
PMT_API const pmt_t PMT_F
bool is_pc_rpc_set()
Checks if this block is already exporting perf. counters to ControlPort.
Definition: block.h:526
pmt::pmt_t key
the key of tag (as a PMT symbol)
Definition: tags.h:37
log4cpp::Category * logger_ptr
GR_LOG macrosThese macros wrap the standard LOG4CPP_LEVEL macros. The availablie macros are: LOG_DEBU...
Definition: logger.h:147
Definition: block_gateway.h:45
std::ostream & operator<<(std::ostream &os, basic_block_sptr basic_block)
Definition: basic_block.h:399
bool is_unaligned() const
Definition: block.h:220
boost::mutex mutex
Definition: thread.h:46
Definition: block_gateway.h:47
double relative_rate() const
return the approximate output rate / input rate
Definition: block.h:258
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
tag_propagation_policy_t
Definition: block_gateway.h:44
void set_detail(block_detail_sptr detail)
Definition: block.h:783
int alignment() const
Definition: block.h:215
void no_pc_rpc()
If the block calls this in its constructor, it's perf. counters will not be exported.
Definition: block.h:532
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:656
int output_multiple() const
Definition: block.h:194