diff options
Diffstat (limited to 'gnuradio-runtime/lib/sync_block.cc')
| -rw-r--r-- | gnuradio-runtime/lib/sync_block.cc | 53 |
1 files changed, 24 insertions, 29 deletions
diff --git a/gnuradio-runtime/lib/sync_block.cc b/gnuradio-runtime/lib/sync_block.cc index e00b80c79e..8597b93b41 100644 --- a/gnuradio-runtime/lib/sync_block.cc +++ b/gnuradio-runtime/lib/sync_block.cc @@ -28,45 +28,40 @@ namespace gr { - sync_block::sync_block(const std::string &name, - io_signature::sptr input_signature, - io_signature::sptr output_signature) +sync_block::sync_block(const std::string& name, + io_signature::sptr input_signature, + io_signature::sptr output_signature) : block(name, input_signature, output_signature) - { +{ set_fixed_rate(true); - } +} - void - sync_block::forecast(int noutput_items, - gr_vector_int &ninput_items_required) - { +void sync_block::forecast(int noutput_items, gr_vector_int& ninput_items_required) +{ unsigned ninputs = ninput_items_required.size(); - for(unsigned i = 0; i < ninputs; i++) - ninput_items_required[i] = fixed_rate_noutput_to_ninput(noutput_items); - } + for (unsigned i = 0; i < ninputs; i++) + ninput_items_required[i] = fixed_rate_noutput_to_ninput(noutput_items); +} - int - sync_block::fixed_rate_noutput_to_ninput(int noutput_items) - { +int sync_block::fixed_rate_noutput_to_ninput(int noutput_items) +{ return noutput_items + history() - 1; - } +} - int - sync_block::fixed_rate_ninput_to_noutput(int ninput_items) - { +int sync_block::fixed_rate_ninput_to_noutput(int ninput_items) +{ return std::max(0, ninput_items - (int)history() + 1); - } +} - int - sync_block::general_work(int noutput_items, - gr_vector_int &ninput_items, - gr_vector_const_void_star &input_items, - gr_vector_void_star &output_items) - { +int sync_block::general_work(int noutput_items, + gr_vector_int& ninput_items, + gr_vector_const_void_star& input_items, + gr_vector_void_star& output_items) +{ int r = work(noutput_items, input_items, output_items); - if(r > 0) - consume_each(r); + if (r > 0) + consume_each(r); return r; - } +} } /* namespace gr */ |