InfluxdbWriter: don't leak sockets

refs #6989 (cherry picked from commit 2a6b122)
Icinga · Mar 19, 2019 · 1fc3a77 · 1fc3a77
1 parent c9d27e7
commit 1fc3a77
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/lib/perfdata/influxdbwriter.cpp b/lib/perfdata/influxdbwriter.cpp
@@ -26,6 +26,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"
@@ -432,6 +433,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());