1 /******************************************************************************
3 * Copyright (C) 2012-2018 Icinga Development Team (https://www.icinga.com/) *
5 * This program is free software; you can redistribute it and/or *
6 * modify it under the terms of the GNU General Public License *
7 * as published by the Free Software Foundation; either version 2 *
8 * of the License, or (at your option) any later version. *
10 * This program is distributed in the hope that it will be useful, *
11 * but WITHOUT ANY WARRANTY; without even the implied warranty of *
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the *
13 * GNU General Public License for more details. *
15 * You should have received a copy of the GNU General Public License *
16 * along with this program; if not, write to the Free Software Foundation *
17 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA. *
18 ******************************************************************************/
20 #include "icinga/compatutility.hpp"
21 #include "compat/checkresultreader.hpp"
22 #include "compat/checkresultreader-ti.cpp"
23 #include "icinga/service.hpp"
24 #include "icinga/pluginutility.hpp"
25 #include "icinga/icingaapplication.hpp"
26 #include "base/configtype.hpp"
27 #include "base/objectlock.hpp"
28 #include "base/logger.hpp"
29 #include "base/convert.hpp"
30 #include "base/application.hpp"
31 #include "base/utility.hpp"
32 #include "base/exception.hpp"
33 #include "base/context.hpp"
34 #include "base/statsfunction.hpp"
37 using namespace icinga;
39 REGISTER_TYPE(CheckResultReader);
41 REGISTER_STATSFUNCTION(CheckResultReader, &CheckResultReader::StatsFunc);
43 void CheckResultReader::StatsFunc(const Dictionary::Ptr& status, const Array::Ptr&)
47 for (const CheckResultReader::Ptr& checkresultreader : ConfigType::GetObjectsByType<CheckResultReader>()) {
48 nodes.emplace_back(checkresultreader->GetName(), 1); //add more stats
51 status->Set("checkresultreader", new Dictionary(std::move(nodes)));
55 * @threadsafety Always.
57 void CheckResultReader::Start(bool runtimeCreated)
59 ObjectImpl<CheckResultReader>::Start(runtimeCreated);
61 Log(LogInformation, "CheckResultReader")
62 << "'" << GetName() << "' started.";
63 Log(LogWarning, "CheckResultReader")
64 << "The CheckResultReader feature is deprecated and will be removed with Icinga 2.10.0";
67 m_ReadTimer = new Timer();
68 m_ReadTimer->OnTimerExpired.connect(std::bind(&CheckResultReader::ReadTimerHandler, this));
69 m_ReadTimer->SetInterval(5);
75 * @threadsafety Always.
77 void CheckResultReader::Stop(bool runtimeRemoved)
79 Log(LogInformation, "CheckResultReader")
80 << "'" << GetName() << "' stopped.";
82 ObjectImpl<CheckResultReader>::Stop(runtimeRemoved);
86 * @threadsafety Always.
88 void CheckResultReader::ReadTimerHandler() const
90 CONTEXT("Processing check result files in '" + GetSpoolDir() + "'");
92 Utility::Glob(GetSpoolDir() + "/c??????.ok", std::bind(&CheckResultReader::ProcessCheckResultFile, this, _1), GlobFile);
95 void CheckResultReader::ProcessCheckResultFile(const String& path) const
97 CONTEXT("Processing check result file '" + path + "'");
99 String crfile = String(path.Begin(), path.End() - 3); /* Remove the ".ok" extension. */
102 fp.exceptions(std::ifstream::badbit);
103 fp.open(crfile.CStr());
105 std::map<String, String> attrs;
109 std::getline(fp, line);
111 if (line.empty() || line[0] == '#')
112 continue; /* Ignore comments and empty lines. */
114 size_t pos = line.find_first_of('=');
116 if (pos == std::string::npos)
117 continue; /* Ignore invalid lines. */
119 String key = line.substr(0, pos);
120 String value = line.substr(pos + 1);
125 /* Remove the checkresult files. */
126 if (unlink(path.CStr()) < 0)
127 BOOST_THROW_EXCEPTION(posix_error()
128 << boost::errinfo_api_function("unlink")
129 << boost::errinfo_errno(errno)
130 << boost::errinfo_file_name(path));
132 if (unlink(crfile.CStr()) < 0)
133 BOOST_THROW_EXCEPTION(posix_error()
134 << boost::errinfo_api_function("unlink")
135 << boost::errinfo_errno(errno)
136 << boost::errinfo_file_name(crfile));
138 Checkable::Ptr checkable;
140 Host::Ptr host = Host::GetByName(attrs["host_name"]);
143 Log(LogWarning, "CheckResultReader")
144 << "Ignoring checkresult file for host '" << attrs["host_name"] << "': Host does not exist.";
149 if (attrs.find("service_description") != attrs.end()) {
150 Service::Ptr service = host->GetServiceByShortName(attrs["service_description"]);
153 Log(LogWarning, "CheckResultReader")
154 << "Ignoring checkresult file for host '" << attrs["host_name"]
155 << "', service '" << attrs["service_description"] << "': Service does not exist.";
164 CheckResult::Ptr result = new CheckResult();
165 String output = CompatUtility::UnEscapeString(attrs["output"]);
166 std::pair<String, Value> co = PluginUtility::ParseCheckOutput(output);
167 result->SetOutput(co.first);
168 result->SetPerformanceData(PluginUtility::SplitPerfdata(co.second));
169 result->SetState(PluginUtility::ExitStatusToState(Convert::ToLong(attrs["return_code"])));
171 if (attrs.find("start_time") != attrs.end())
172 result->SetExecutionStart(Convert::ToDouble(attrs["start_time"]));
174 result->SetExecutionStart(Utility::GetTime());
176 if (attrs.find("finish_time") != attrs.end())
177 result->SetExecutionEnd(Convert::ToDouble(attrs["finish_time"]));
179 result->SetExecutionEnd(result->GetExecutionStart());
181 checkable->ProcessCheckResult(result);
183 Log(LogDebug, "CheckResultReader")
184 << "Processed checkresult file for object '" << checkable->GetName() << "'";
186 /* Reschedule the next check. The side effect of this is that for as long
187 * as we receive check result files for a host/service we won't execute any
189 checkable->SetNextCheck(Utility::GetTime() + checkable->GetCheckInterval());