tyler.durden/icinga2
1
0
Fork 0
mirror of https://github.com/Icinga/icinga2.git synced 2025-07-25 06:34:42 +02:00
Code Issues Packages Projects Releases Wiki Activity

Bugfix: use service identity rather than just their names.

Browse Source
This commit is contained in:
Gunnar Beutner 2012-06-22 12:22:36 +02:00
parent e294cf6686
commit 69d3e71b03
3 changed files with 11 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
components/checker/checkercomponent.cpp
View File

@ -76,7 +76,7 @@ void CheckerComponent::CheckTimerHandler(void)
Application::Log(LogDebug, "checker", "Executing service check for '" + service.GetName() + "'"); Application::Log(LogDebug, "checker", "Executing service check for '" + service.GetName() + "'");
m_PendingServices.insert(service.GetName()); m_PendingServices.insert(service.GetConfigObject());
CheckTask::Ptr task = CheckTask::CreateTask(service); CheckTask::Ptr task = CheckTask::CreateTask(service);
task->Enqueue(); task->Enqueue();
@ -111,7 +111,7 @@ void CheckerComponent::ResultTimerHandler(void)
/* if the service isn't in the set of pending services /* if the service isn't in the set of pending services
* it was removed and we need to ignore this check result. */ * it was removed and we need to ignore this check result. */
if (m_PendingServices.find(service.GetName()) == m_PendingServices.end()) if (m_PendingServices.find(service.GetConfigObject()) == m_PendingServices.end())
continue; continue;
CheckResult result = task->GetResult(); CheckResult result = task->GetResult();
@ -132,7 +132,7 @@ void CheckerComponent::ResultTimerHandler(void)
failed++; failed++;
service.SetNextCheck(now + service.GetCheckInterval()); service.SetNextCheck(now + service.GetCheckInterval());
m_PendingServices.erase(service.GetName()); m_PendingServices.erase(service.GetConfigObject());
m_Services.push(service); m_Services.push(service);
} }

2
components/checker/checkercomponent.h
View File

@ -51,7 +51,7 @@ private:
VirtualEndpoint::Ptr m_CheckerEndpoint; VirtualEndpoint::Ptr m_CheckerEndpoint;
ServiceQueue m_Services; ServiceQueue m_Services;
set<string> m_PendingServices; set<ConfigObject::Ptr> m_PendingServices;
Timer::Ptr m_CheckTimer; Timer::Ptr m_CheckTimer;

14
components/delegation/delegationcomponent.cpp
View File

@ -235,6 +235,13 @@ void DelegationComponent::DelegationTimerHandler(void)
assert(candidates.size() == 0 || !service.GetChecker().empty()); assert(candidates.size() == 0 || !service.GetChecker().empty());
} }
map<Endpoint::Ptr, int>::iterator hit;
for (hit = histogram.begin(); hit != histogram.end(); hit++) {
stringstream msgbuf;
msgbuf << "histogram: " << hit->first->GetIdentity() << " - " << hit->second;
Application::Log(LogInformation, "delegation", msgbuf.str());
}
if (delegated > 0) { if (delegated > 0) {
if (need_clear) { if (need_clear) {
map<Endpoint::Ptr, int>::iterator hit; map<Endpoint::Ptr, int>::iterator hit;
@ -252,13 +259,6 @@ void DelegationComponent::DelegationTimerHandler(void)
AssignService(endpoint, *sit); AssignService(endpoint, *sit);
} }
map<Endpoint::Ptr, int>::iterator hit;
for (hit = histogram.begin(); hit != histogram.end(); hit++) {
stringstream msgbuf;
msgbuf << "histogram: " << hit->first->GetIdentity() << " - " << hit->second;
Application::Log(LogInformation, "delegation", msgbuf.str());
}
} }
stringstream msgbuf; stringstream msgbuf;