mirror of
https://github.com/Icinga/icinga2.git
synced 2025-09-19 07:47:44 +02:00
abc3652b00
Rather than leaving stale connections about we tried to poll for data coming in from InfluxDB and timeout if it didn't repond in a timely manner. This introduced a race where the timeout triggers, a context switch occurs where data is actually available and the TlsStream spins trying to asynchronously notify that data is available, but which never gets read. Not only does this use up 100% of a core, but it also slowly starves the system of handler threads at which point metrics stop being delivered. This basically removes the poll and timeout, any TLS socket erros should be detected by TCP keep-alives. Fixes #5460 #5469
87 lines
3.3 KiB
C++
87 lines
3.3 KiB
C++
/******************************************************************************
|
|
* Icinga 2 *
|
|
* Copyright (C) 2012-2017 Icinga Development Team (https://www.icinga.com/) *
|
|
* *
|
|
* This program is free software; you can redistribute it and/or *
|
|
* modify it under the terms of the GNU General Public License *
|
|
* as published by the Free Software Foundation; either version 2 *
|
|
* of the License, or (at your option) any later version. *
|
|
* *
|
|
* This program is distributed in the hope that it will be useful, *
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of *
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the *
|
|
* GNU General Public License for more details. *
|
|
* *
|
|
* You should have received a copy of the GNU General Public License *
|
|
* along with this program; if not, write to the Free Software Foundation *
|
|
* Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA. *
|
|
******************************************************************************/
|
|
|
|
#ifndef INFLUXDBWRITER_H
|
|
#define INFLUXDBWRITER_H
|
|
|
|
#include "perfdata/influxdbwriter.thpp"
|
|
#include "icinga/service.hpp"
|
|
#include "base/configobject.hpp"
|
|
#include "base/tcpsocket.hpp"
|
|
#include "base/timer.hpp"
|
|
#include "base/workqueue.hpp"
|
|
#include <boost/thread/mutex.hpp>
|
|
#include <fstream>
|
|
|
|
namespace icinga
|
|
{
|
|
|
|
/**
|
|
* An Icinga InfluxDB writer.
|
|
*
|
|
* @ingroup perfdata
|
|
*/
|
|
class InfluxdbWriter : public ObjectImpl<InfluxdbWriter>
|
|
{
|
|
public:
|
|
DECLARE_OBJECT(InfluxdbWriter);
|
|
DECLARE_OBJECTNAME(InfluxdbWriter);
|
|
|
|
InfluxdbWriter(void);
|
|
|
|
static void StatsFunc(const Dictionary::Ptr& status, const Array::Ptr& perfdata);
|
|
|
|
virtual void ValidateHostTemplate(const Dictionary::Ptr& value, const ValidationUtils& utils) override;
|
|
virtual void ValidateServiceTemplate(const Dictionary::Ptr& value, const ValidationUtils& utils) override;
|
|
|
|
protected:
|
|
virtual void OnConfigLoaded(void) override;
|
|
virtual void Start(bool runtimeCreated) override;
|
|
virtual void Stop(bool runtimeRemoved) override;
|
|
|
|
private:
|
|
WorkQueue m_WorkQueue;
|
|
Timer::Ptr m_FlushTimer;
|
|
std::vector<String> m_DataBuffer;
|
|
boost::mutex m_DataBufferMutex;
|
|
|
|
void CheckResultHandler(const Checkable::Ptr& checkable, const CheckResult::Ptr& cr);
|
|
void InternalCheckResultHandler(const Checkable::Ptr& checkable, const CheckResult::Ptr& cr);
|
|
void SendPerfdata(const Dictionary::Ptr& tmpl, const Checkable::Ptr& checkable, const CheckResult::Ptr& cr, double ts);
|
|
void SendMetric(const Dictionary::Ptr& tmpl, const String& label, const Dictionary::Ptr& fields, double ts);
|
|
void FlushTimeout(void);
|
|
void Flush(void);
|
|
|
|
static String FormatInteger(int val);
|
|
static String FormatBoolean(bool val);
|
|
|
|
static String EscapeKey(const String& str);
|
|
static String EscapeField(const String& str);
|
|
|
|
Stream::Ptr Connect();
|
|
|
|
void AssertOnWorkQueue(void);
|
|
|
|
void ExceptionHandler(boost::exception_ptr exp);
|
|
};
|
|
|
|
}
|
|
|
|
#endif /* INFLUXDBWRITER_H */
|