Fixed thread termination

SAtacker · Mar 10, 2021 · 8d07fab · 8d07fab
1 parent 5eb3117
commit 8d07fab
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/cpp_app/data_handler.cpp b/cpp_app/data_handler.cpp
@@ -86,7 +86,7 @@ void datahandler::start_slt(bool _start)
         a =new boost::asio::ip::tcp::acceptor(io_service,boost::asio::ip::tcp::endpoint(boost::asio::ip::tcp::v4(),2121));
         a->accept(*tcp_socket);
         init_server();
-        boost::thread th([this]{this->spin();});
+        th =new boost::thread([this]{this->spin();});
     }
 }
 
@@ -100,9 +100,11 @@ void datahandler::close_slt(bool _close)
         tcp_socket->shutdown(tcp_socket->shutdown_both);
         tcp_socket->close();
         udp_socket->close();
+        th->interrupt();
         delete a;
         delete tcp_socket;
         delete udp_socket;
+        delete th;
     }
 }
 

diff --git a/cpp_app/data_handler.h b/cpp_app/data_handler.h
@@ -48,6 +48,7 @@ public slots:
     boost::asio::ip::udp::socket *udp_socket;
     pid_terms_incomming_values vals;
     boost::asio::ip::tcp::acceptor *a;
+    boost::thread *th;
 };
 
 #endif // DATA_HANDLER_H