[rpc] Add message queue disabling when disconnected

Author: c-jimenez

src/rpc/RpcBase.cpp

@@ -272,6 +272,14 @@ void RpcBase::stop()
     }
 }
 
+/** @brief Process the websocket disconnection event */
+void RpcBase::processDisconnected()
+{
+    // Disable queues
+    m_requests_queue.setEnable(false);
+    m_results_queue.setEnable(false);
+}
+
 /** @brief Process received data */
 void RpcBase::processReceivedData(const void* data, size_t size)
 {

src/rpc/RpcBase.h

@@ -124,6 +124,8 @@ class RpcBase : public IRpc
     void start();
     /** @brief Stop RPC operations */
     void stop();
+    /** @brief Process the websocket disconnection event */
+    void processDisconnected();
     /** @brief Process received data */
     void processReceivedData(const void* data, size_t size);
     /** @brief Get the RPC listener */

src/rpc/RpcServer.cpp

@@ -173,6 +173,10 @@ bool RpcServer::Client::isConnected() const
 /** @brief void IWebsocketServer::IClient::IListener::wsClientDisconnected() */
 void RpcServer::Client::wsClientDisconnected()
 {
+    // Process disconnection event
+    processDisconnected();
+
+    // Notify listener
     rpcListener()->rpcDisconnected();
 }