blob: 961d4e9544d96053e5f444ab62d8b26b037548cd (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
|
/* Icinga 2 | (c) 2012 Icinga GmbH | GPLv2+ */
#ifndef PERFDATAWRITER_H
#define PERFDATAWRITER_H
#include "perfdata/perfdatawriter-ti.hpp"
#include "icinga/service.hpp"
#include "base/configobject.hpp"
#include "base/timer.hpp"
#include <fstream>
namespace icinga
{
/**
* An Icinga perfdata writer.
*
* @ingroup icinga
*/
class PerfdataWriter final : public ObjectImpl<PerfdataWriter>
{
public:
DECLARE_OBJECT(PerfdataWriter);
DECLARE_OBJECTNAME(PerfdataWriter);
static void StatsFunc(const Dictionary::Ptr& status, const Array::Ptr& perfdata);
void ValidateHostFormatTemplate(const Lazy<String>& lvalue, const ValidationUtils& utils) override;
void ValidateServiceFormatTemplate(const Lazy<String>& lvalue, const ValidationUtils& utils) override;
protected:
void OnConfigLoaded() override;
void Resume() override;
void Pause() override;
private:
boost::signals2::connection m_HandleCheckResults;
Timer::Ptr m_RotationTimer;
std::ofstream m_ServiceOutputFile;
std::ofstream m_HostOutputFile;
std::mutex m_StreamMutex;
void CheckResultHandler(const Checkable::Ptr& checkable, const CheckResult::Ptr& cr);
static Value EscapeMacroMetric(const Value& value);
void RotationTimerHandler();
void RotateAllFiles();
void RotateFile(std::ofstream& output, const String& temp_path, const String& perfdata_path);
};
}
#endif /* PERFDATAWRITER_H */
|
