IXWebSocketTransport::setReadyState(): Run under lock

ixwebsocket/IXWebSocketTransport.cpp

@@ -205,6 +205,12 @@ namespace ix
 
     void WebSocketTransport::setReadyState(ReadyState readyState)
     {
+        // Lock the _setReadyStateMutex for the duration of this
+        // method. This ensures that only a single thread runs the
+        // logic below avoiding concurrent execution of the
+        // close callback my multiple threads at the same time.
+        std::lock_guard<std::mutex> lock(_setReadyStateMutex);
+
         // No state change, return
         if (_readyState == readyState) return;
 

ixwebsocket/IXWebSocketTransport.h

@@ -185,6 +185,8 @@ namespace ix
 
         // Hold the state of the connection (OPEN, CLOSED, etc...)
         std::atomic<ReadyState> _readyState;
+        // Mutex to serialize setReadyState() execution.
+        std::mutex _setReadyStateMutex;
 
         OnCloseCallback _onCloseCallback;
         std::string _closeReason;