change to fixed_rate_noutput_to_ninput in block for non fixed rates

2 files changed, 9 insertions, 1 deletions

diff --git a/lib/gr_block.cpp b/lib/gr_block.cpp
index a384af1..b32158a 100644
--- a/lib/gr_block.cpp
+++ b/lib/gr_block.cpp
@@ -80,7 +80,14 @@ bool gr_block::is_unaligned(void)
 
 size_t gr_block::fixed_rate_noutput_to_ninput(const size_t noutput_items)
 {
-    return size_t(0.5 + (noutput_items/this->relative_rate())) + this->history() - 1;
+    if ((*this)->block->enable_fixed_rate)
+    {
+        return size_t(0.5 + (noutput_items/this->relative_rate())) + this->history() - 1;
+    }
+    else
+    {
+        return noutput_items + this->history() - 1;
+    }
 }
 
 size_t gr_block::interpolation(void) const
diff --git a/lib/top_block.cpp b/lib/top_block.cpp
index d71a4a7..a09744e 100644
--- a/lib/top_block.cpp
+++ b/lib/top_block.cpp
@@ -107,6 +107,7 @@ void TopBlock::run(void)
 {
     this->start();
     this->wait();
+    this->disconnect_all();
 }
 
 GRAS_FORCE_INLINE void wait_thread_yield(void)