Review comments.

EVerest · Feb 22, 2024 · 8eb113a · 8eb113a
1 parent 0ffa665
commit 8eb113a
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/lib/ocpp/common/websocket/websocket_base.cpp b/lib/ocpp/common/websocket/websocket_base.cpp
@@ -74,12 +74,13 @@ void WebsocketBase::disconnect(websocketpp::close::status::value code) {
         EVLOG_error << "Cannot disconnect a websocket that was not initialized";
         return;
     }
-    if (code == websocketpp::close::status::normal) {
-        this->shutting_down = true;
-    }
 
     {
         std::lock_guard<std::mutex> lk(this->reconnect_mutex);
+        if (code == websocketpp::close::status::normal) {
+            this->shutting_down = true;
+        }
+
         if (this->reconnect_timer) {
             this->reconnect_timer.get()->cancel();
         }