11 #ifndef INCLUDED_GR_RUNTIME_BUFFER_READER_H
12 #define INCLUDED_GR_RUNTIME_BUFFER_READER_H
24 class buffer_reader_sm;
35 block_sptr link = block_sptr(),
65 void declare_sample_delay(
unsigned delay);
72 unsigned sample_delay()
const;
77 virtual int items_available()
const;
82 buffer_sptr
buffer()
const {
return d_buffer; }
95 const void* read_pointer();
100 void update_read_pointer(
int nitems);
102 void set_done(
bool done) { d_buffer->set_done(done); }
103 bool done()
const {
return d_buffer->done(); }
112 d_abs_read_offset = 0;
121 block_sptr
link()
const {
return block_sptr(d_link); }
137 void get_tags_in_range(std::vector<tag_t>&
v,
buffer_sptr buffer() const
Return buffer this reader reads from.
Definition: buffer_reader.h:82
Definition: buffer_reader_sm.h:21
How we keep track of the readers of a gr::buffer.
Definition: buffer_reader.h:48
block_sptr link() const
Return the block that reads via this reader.
Definition: buffer_reader.h:121
Single writer, multiple reader fifo.
Definition: buffer_double_mapped.h:28
void set_done(bool done)
Definition: buffer_reader.h:102
unsigned int d_read_index
Definition: buffer_reader.h:176
std::shared_ptr< logger > logger_ptr
Definition: logger.h:250
buffer_sptr d_buffer
Definition: buffer_reader.h:175
void reset_nitem_counter()
Definition: buffer_reader.h:109
int max_possible_items_available() const
Return maximum number of items that could ever be available for reading. This is used as a sanity che...
Definition: buffer_reader.h:88
GR_RUNTIME_API buffer_reader_sptr buffer_add_reader(buffer_sptr buf, int nzero_preload, block_sptr link=block_sptr(), int delay=0)
Create a new gr::buffer_reader and attach it to buffer buf.
uint64_t nitems_read() const
Definition: buffer_reader.h:107
uint64_t get_abs_read_offset() const
Definition: buffer_reader.h:162
Definition: cc_common.h:35
std::weak_ptr< block > d_link
Definition: buffer_reader.h:178
#define GR_RUNTIME_API
Definition: gnuradio-runtime/include/gnuradio/api.h:18
bool done() const
Definition: buffer_reader.h:103
A single mapped buffer where wrapping conditions are handled explicitly via input/output_blocked_call...
Definition: buffer_single_mapped.h:29
Single writer, multiple reader fifo.
Definition: buffer.h:66
GNU Radio logging wrapper.
Definition: basic_block.h:29
unsigned int get_read_index() const
Definition: buffer_reader.h:161
size_t get_sizeof_item()
Definition: buffer_reader.h:115
virtual bool input_blocked_callback(int items_required, int items_avail)
Callback function that the scheduler will call when it determines that the input is blocked...
Definition: buffer_reader.h:155
virtual bool input_blkd_cb_ready(int items_required) const
Returns true when the current thread is ready to call the callback, false otherwise. Delegate calls to buffer class's input_blkd_cb_ready(). Note if input_blocked_callback is overridden then this function should also be overridden.
Definition: buffer_reader.h:148
gr::thread::mutex * mutex()
Definition: buffer_reader.h:105
GR_RUNTIME_API long buffer_ncurrently_allocated()
returns # of buffers currently allocated
boost::mutex mutex
Definition: thread.h:37
uint64_t d_abs_read_offset
Definition: buffer_reader.h:177
unsigned d_attr_delay
Definition: buffer_reader.h:179
GR_RUNTIME_API long buffer_reader_ncurrently_allocated()
returns # of buffer_readers currently allocated