 |
GNU Radio Manual and C++ API Reference
3.9.1.0
The Free & Open Software Radio Ecosystem
|
|
Go to the documentation of this file.
11 #ifndef INCLUDED_GR_RUNTIME_BLOCK_DETAIL_H
12 #define INCLUDED_GR_RUNTIME_BLOCK_DETAIL_H
40 bool sink_p()
const {
return d_noutputs == 0; }
41 bool source_p()
const {
return d_ninputs == 0; }
43 void set_done(
bool done);
44 bool done()
const {
return d_done; }
46 void set_input(
unsigned int which, buffer_reader_sptr reader);
47 buffer_reader_sptr
input(
unsigned int which)
49 if (which >= d_ninputs)
50 throw std::invalid_argument(
"block_detail::input");
51 return d_input[which];
54 void set_output(
unsigned int which, buffer_sptr
buffer);
55 buffer_sptr
output(
unsigned int which)
57 if (which >= d_noutputs)
58 throw std::invalid_argument(
"block_detail::output");
59 return d_output[which];
66 void consume(
int which_input,
int how_many_items);
72 void consume_each(
int how_many_items);
78 void produce(
int which_output,
int how_many_items);
84 void produce_each(
int how_many_items);
87 uint64_t nitems_read(
unsigned int which_input);
90 uint64_t nitems_written(
unsigned int which_output);
94 void reset_nitem_counters();
108 void add_item_tag(
unsigned int which_output,
const tag_t& tag);
121 void remove_item_tag(
unsigned int which_input,
const tag_t& tag,
long id);
138 void get_tags_in_range(std::vector<tag_t>&
v,
139 unsigned int which_input,
163 void get_tags_in_range(std::vector<tag_t>&
v,
164 unsigned int which_input,
177 void set_processor_affinity(
const std::vector<int>& mask);
182 void unset_processor_affinity();
199 void start_perf_counters();
200 void stop_perf_counters(
int noutput_items,
int nproduced);
201 void reset_perf_counters();
204 float pc_noutput_items();
205 float pc_nproduced();
206 float pc_input_buffers_full(
size_t which);
207 std::vector<float> pc_input_buffers_full();
208 float pc_output_buffers_full(
size_t which);
209 std::vector<float> pc_output_buffers_full();
210 float pc_work_time();
212 float pc_noutput_items_avg();
213 float pc_nproduced_avg();
214 float pc_input_buffers_full_avg(
size_t which);
215 std::vector<float> pc_input_buffers_full_avg();
216 float pc_output_buffers_full_avg(
size_t which);
217 std::vector<float> pc_output_buffers_full_avg();
218 float pc_work_time_avg();
219 float pc_throughput_avg();
221 float pc_noutput_items_var();
222 float pc_nproduced_var();
223 float pc_input_buffers_full_var(
size_t which);
224 std::vector<float> pc_input_buffers_full_var();
225 float pc_output_buffers_full_var(
size_t which);
226 std::vector<float> pc_output_buffers_full_var();
227 float pc_work_time_var();
229 float pc_work_time_total();
234 int consumed()
const;
243 unsigned int d_ninputs;
244 unsigned int d_noutputs;
245 std::vector<buffer_reader_sptr> d_input;
246 std::vector<buffer_sptr> d_output;
251 float d_ins_noutput_items;
252 float d_avg_noutput_items;
253 float d_var_noutput_items;
254 float d_total_noutput_items;
257 float d_ins_nproduced;
258 float d_avg_nproduced;
259 float d_var_nproduced;
260 std::vector<float> d_ins_input_buffers_full;
261 std::vector<float> d_avg_input_buffers_full;
262 std::vector<float> d_var_input_buffers_full;
263 std::vector<float> d_ins_output_buffers_full;
264 std::vector<float> d_avg_output_buffers_full;
265 std::vector<float> d_var_output_buffers_full;
267 float d_ins_work_time;
268 float d_avg_work_time;
269 float d_var_work_time;
270 float d_total_work_time;
271 float d_avg_throughput;
274 block_detail(
unsigned int ninputs,
unsigned int noutputs);
279 unsigned int noutputs);
283 unsigned int noutputs);
int d_produce_or
Definition: block_detail.h:232
tpb_detail d_tpb
Definition: block_detail.h:231
gr::logger_ptr d_logger
Definition: block_detail.h:238
pthread_t gr_thread_t
a system-dependent typedef for the underlying thread type.
Definition: thread.h:50
int noutputs() const
Definition: block_detail.h:39
used by thread-per-block scheduler
Definition: tpb_detail.h:26
bool sink_p() const
Definition: block_detail.h:40
GR_RUNTIME_API long block_detail_ncurrently_allocated()
Definition: cc_common.h:35
GR_RUNTIME_API int set_thread_priority(gr_thread_t thread, int priority)
set current thread priority for a given thread ID
bool source_p() const
Definition: block_detail.h:41
#define GR_RUNTIME_API
Definition: gnuradio-runtime/include/gnuradio/api.h:18
bool threaded
Definition: block_detail.h:196
buffer_reader_sptr input(unsigned int which)
Definition: block_detail.h:47
int ninputs() const
Definition: block_detail.h:38
log4cpp::Category * logger_ptr
GR_LOG macros.
Definition: logger.h:60
std::shared_ptr< pmt_base > pmt_t
typedef for shared pointer (transparent reference counting).
Definition: pmt.h:84
signed long long high_res_timer_type
Typedef for the timer tick count.
Definition: high_res_timer.h:38
bool done() const
Definition: block_detail.h:44
buffer_sptr output(unsigned int which)
Definition: block_detail.h:55
Single writer, multiple reader fifo.
Definition: buffer.h:46
GNU Radio logging wrapper for log4cpp library (C++ port of log4j)
Definition: basic_block.h:29
gr::thread::gr_thread_t thread
Definition: block_detail.h:197
GR_RUNTIME_API block_detail_sptr make_block_detail(unsigned int ninputs, unsigned int noutputs)
GR_RUNTIME_API int thread_priority(gr_thread_t thread)
get current thread priority for a given thread ID
Implementation details to support the signal processing abstraction.
Definition: block_detail.h:33