Cleanly close the websocket connection on complete.

LibreQoE · Jan 13, 2025 · f3fe9e9 · f3fe9e9
1 parent a7af216
commit f3fe9e9
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/src/rust/lqosd/src/lts2_sys/lts2_client/ingestor/message_queue.rs b/src/rust/lqosd/src/lts2_sys/lts2_client/ingestor/message_queue.rs
@@ -287,6 +287,10 @@ impl MessageQueue {
                 return Ok(());
             }
         }
+        if let Err(e) = socket.close(None) {
+            warn!("Failed to close connection to server: {}", e);
+            return Ok(());
+        }
         drop(socket);
         println!("Finished sending messages to {}", remote_host);
         Ok(())