commit b85c0626d99ad9acbc997a06bf9b705e692e5e49
author ptrkrysik <ptrkrysik@gmail.com> Mon Jun 01 14:21:20 2015 +0200
committer ptrkrysik <ptrkrysik@gmail.com> Mon Jun 01 14:21:20 2015 +0200
tree 704df10202bd0afd6a5696b52a7579c7ee88145a
parent 963f8b2031193d99c38b1b089ce94363c79560ba

Changed place where thread join function is invoked to run().

lib/misc_utils/burst_source_impl.cc

diff --git a/lib/misc_utils/burst_source_impl.cc b/lib/misc_utils/burst_source_impl.cc
index b6f2940..336838b 100644
--- a/lib/misc_utils/burst_source_impl.cc
+++ b/lib/misc_utils/burst_source_impl.cc
@@ -58,13 +58,9 @@
      */
     burst_source_impl::~burst_source_impl()
     {
-        if (d_input_file.is_open())
-        {
-            d_input_file.close();
+        if (d_finished == false){
+            d_finished = true;
         }
-        d_finished = true;
-        d_thread->interrupt();
-        d_thread->join();
     }
 
     bool burst_source_impl::start()
@@ -78,8 +74,6 @@
     bool burst_source_impl::stop()
     {
         d_finished = true;
-        d_thread->interrupt();
-        d_thread->join();
         return block::stop();
     }
 
@@ -97,12 +91,14 @@
             {
                 break;
             }
+
             std::string s(unserialized, PMT_SIZE);
             pmt::pmt_t burst = pmt::deserialize_str(s);
             message_port_pub(pmt::mp("out"), burst);
         }
         d_input_file.close();
-        stop();
+        d_thread->interrupt();
+        d_thread->join();    
     }
   } /* namespace gsm */
 } /* namespace gr */