InfluxdbWriter: don't leak sockets

refs #6989

diff --git a/lib/perfdata/influxdbwriter.cpp b/lib/perfdata/influxdbwriter.cpp
index 773f21a2a23d1f49ecfbcdfaca6e385918119ac3..b75cd7a3f428320688d31d67bf1c7ef65e542080 100644 (file)
--- a/lib/perfdata/influxdbwriter.cpp
+++ b/lib/perfdata/influxdbwriter.cpp
@@ -9,6 +9,7 @@
 #include "icinga/macroprocessor.hpp"
 #include "icinga/icingaapplication.hpp"
 #include "icinga/checkcommand.hpp"
+#include "base/defer.hpp"
 #include "base/tcpsocket.hpp"
 #include "base/configtype.hpp"
 #include "base/objectlock.hpp"
@@ -447,6 +448,8 @@ void InfluxdbWriter::Flush()
        if (!stream)
                return;
 
+       Defer close ([&stream]() { stream->Close(); });
+
        Url::Ptr url = new Url();
        url->SetScheme(GetSslEnable() ? "https" : "http");
        url->SetHost(GetHost());