Connection status stuff is now atomic.

Author: JonathanHenson

include/aws/crt/mqtt/MqttClient.h

@@ -21,6 +21,7 @@
 
 #include <functional>
 #include <memory>
+#include <atomic>
 
 namespace Aws
 {
@@ -163,8 +164,8 @@ namespace Aws
                 OnConnectionFailedHandler m_onConnectionFailed;
                 OnConnAckHandler m_onConnAck;
                 OnDisconnectHandler m_onDisconnect;
-                int m_lastError;
-                ConnectionState m_connectionState;
+                std::atomic<int> m_lastError;
+                std::atomic<ConnectionState> m_connectionState;
 
                 static void s_onConnectionFailed(aws_mqtt_client_connection* connection, int errorCode, void* userData);
                 static void s_onConnAck(aws_mqtt_client_connection* connection,

source/mqtt/MqttClient.cpp

@@ -181,9 +181,10 @@ namespace Aws
                 m_onConnectionFailed(std::move(toMove.m_onConnectionFailed)),
                 m_onConnAck(std::move(toMove.m_onConnAck)),
                 m_onDisconnect(std::move(toMove.m_onDisconnect)),
-                m_lastError(toMove.m_lastError),
-                m_connectionState(toMove.m_connectionState)
+                m_lastError(toMove.m_lastError.load()),
+                m_connectionState(toMove.m_connectionState.load())
             {
+
                 toMove.m_owningClient = nullptr;
                 toMove.m_underlyingConnection = nullptr;
                 toMove.m_lastError = AWS_ERROR_UNKNOWN;
@@ -202,8 +203,8 @@ namespace Aws
                 m_onConnectionFailed = std::move(toMove.m_onConnectionFailed);
                 m_onConnAck = std::move(toMove.m_onConnAck);
                 m_onDisconnect = std::move(toMove.m_onDisconnect);
-                m_lastError = toMove.m_lastError;
-                m_connectionState = toMove.m_connectionState;
+                m_lastError = toMove.m_lastError.load();
+                m_connectionState = toMove.m_connectionState.load();
 
                 toMove.m_owningClient = nullptr;
                 toMove.m_underlyingConnection = nullptr;