Fixing mulitple sends of the DISCONNECT message to the client.

commschamp · Jul 9, 2023 · 08c6e5f · 08c6e5f
1 parent bc22158
commit 08c6e5f
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/gateway/src/lib/session_op/PubSend.cpp b/gateway/src/lib/session_op/PubSend.cpp
@@ -162,7 +162,10 @@ void PubSend::newSends()
     }
 
     if (st.m_pendingClientDisconnect) {
-        sendDisconnect();
+        if (!m_disconnectAlreadySent) {
+            sendDisconnect();
+            m_disconnectAlreadySent = true;
+        }
         return;
     }
 

diff --git a/gateway/src/lib/session_op/PubSend.h b/gateway/src/lib/session_op/PubSend.h
@@ -57,6 +57,7 @@ class PubSend : public SessionOp
     bool m_registered = false;
     bool m_acked = false;
     bool m_ping = false;
+    bool m_disconnectAlreadySent = false;
 };
 
 }  // namespace session_op