diff options
| author | Josh Morman <jmorman@gnuradio.org> | 2021-12-10 07:31:24 -0500 |
|---|---|---|
| committer | mormj <34754695+mormj@users.noreply.github.com> | 2021-12-10 16:00:57 -0500 |
| commit | 0b5946b349d99590495dad1fa5ec679c4906d4fa (patch) | |
| tree | f859246bf4f7c2846c217c2547e062912c9906fb /gnuradio-runtime/lib | |
| parent | c4fa6b371479cc8003b3c0f4e1dcfbd0780e3d4b (diff) | |
runtime: configurable blkd_input timer
Signed-off-by: Josh Morman <jmorman@gnuradio.org>
Diffstat (limited to 'gnuradio-runtime/lib')
| -rw-r--r-- | gnuradio-runtime/lib/block.cc | 7 | ||||
| -rw-r--r-- | gnuradio-runtime/lib/tpb_thread_body.cc | 3 |
2 files changed, 9 insertions, 1 deletions
diff --git a/gnuradio-runtime/lib/block.cc b/gnuradio-runtime/lib/block.cc index 8965a9eaea..25a77982c5 100644 --- a/gnuradio-runtime/lib/block.cc +++ b/gnuradio-runtime/lib/block.cc @@ -381,6 +381,13 @@ void block::set_min_output_buffer(int port, long min_output_buffer) d_min_output_buffer[port] = min_output_buffer; } +void block::set_blkd_input_timer_value(unsigned int value) +{ + d_blkd_input_timer_value = value; +} + +unsigned int block::blkd_input_timer_value() { return d_blkd_input_timer_value; } + void block::allocate_detail(int ninputs, int noutputs, const std::vector<int>& downstream_max_nitems_vec, diff --git a/gnuradio-runtime/lib/tpb_thread_body.cc b/gnuradio-runtime/lib/tpb_thread_body.cc index abf722dec2..c95547748a 100644 --- a/gnuradio-runtime/lib/tpb_thread_body.cc +++ b/gnuradio-runtime/lib/tpb_thread_body.cc @@ -132,7 +132,8 @@ tpb_thread_body::tpb_thread_body(block_sptr block, if (!d->d_tpb.input_changed) { boost::system_time const timeout = - boost::get_system_time() + boost::posix_time::milliseconds(250); + boost::get_system_time() + + boost::posix_time::milliseconds(block->blkd_input_timer_value()); d->d_tpb.input_cond.timed_wait(guard, timeout); } } break; |