prevent_thread_lock.patch

prevent_thread_lock.patch

diff --git a/src/gstreamer-1.0/gsttcamsrc.cpp b/src/gstreamer-1.0/gsttcamsrc.cpp
index 5ee4f01..82235bd 100644
--- a/src/gstreamer-1.0/gsttcamsrc.cpp
+++ b/src/gstreamer-1.0/gsttcamsrc.cpp
@@ -1064,7 +1064,11 @@ static void gst_tcam_src_device_lost_callback (const struct tcam_device_info* in
 
 #endif
 
-    gst_tcam_src_stop(GST_BASE_SRC(self));
+
+    self->is_running = FALSE;
+    gst_element_send_event(GST_ELEMENT(self), gst_event_new_eos());
+    // gst_tcam_src_stop(GST_BASE_SRC(self));
+
 }
 
 
diff --git a/src/v4l2/V4l2Device.cpp b/src/v4l2/V4l2Device.cpp
index bc56921..d58b017 100644
--- a/src/v4l2/V4l2Device.cpp
+++ b/src/v4l2/V4l2Device.cpp
@@ -94,6 +94,7 @@ V4l2Device::~V4l2Device ()
     if (is_stream_on)
         stop_stream();
 
+    this->is_stream_on = false;
     this->stop_all = true;
     this->abort_all = true;
     // signal the udev monitor to exit it's poll/select
@@ -128,6 +129,12 @@ V4l2Device::~V4l2Device ()
 
     if (notification_thread.joinable())
     {
+        // deactivate device_lost
+        // we simply want to join all thread as
+        // we already are destroying the device
+        this->device_is_lost = false;
+        this->cv.notify_all();
+
         notification_thread.join();
     }
 
@@ -578,7 +585,8 @@ void V4l2Device::notification_loop ()
     while(this->is_stream_on)
     {
         std::unique_lock<std::mutex> lck(this->mtx);
-        this->cv.wait(lck);
+        auto reg_check = std::chrono::microseconds(2);
+        this->cv.wait_for(lck, reg_check);
 
         if (this->device_is_lost)
         {