DEVOPS-10175 connection thread stopvar

BITERP · Jun 5, 2024 · 9fa084e · 9fa084e
1 parent 4150b5b
commit 9fa084e
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 5 deletions.
diff --git a/src/linux/ConnectionImpl.cpp b/src/linux/ConnectionImpl.cpp
@@ -5,7 +5,7 @@
 #include <condition_variable>
 
 ConnectionImpl::ConnectionImpl(const AMQP::Address& address) : 
-    trChannel(nullptr)
+    trChannel(nullptr), stop(false)
 {
     static bool sslInited = false;
     if (!sslInited){
@@ -20,9 +20,7 @@ ConnectionImpl::ConnectionImpl(const AMQP::Address& address) :
 
 ConnectionImpl::~ConnectionImpl() {
     closeChannel(trChannel);
-    if (!connection->closed()){
-        connection->close();
-    }
+    stop = true;
     event_base_loopbreak(eventLoop);
     thread.join();
     connection.reset(nullptr);
@@ -33,7 +31,7 @@ ConnectionImpl::~ConnectionImpl() {
 
 void ConnectionImpl::loopThread(ConnectionImpl* thiz) {
     event_base* loop = thiz->eventLoop;
-    while(!thiz->connection->closed()) {
+    while(!thiz->stop) {
         try{
             event_base_loop(loop, EVLOOP_NONBLOCK);
         }catch(std::exception& ex){

diff --git a/src/linux/ConnectionImpl.h b/src/linux/ConnectionImpl.h
@@ -26,5 +26,6 @@ class ConnectionImpl{
 
     std::unique_ptr<AMQP::TcpChannel> trChannel;
     std::thread thread;
+    volatile bool stop;
 };