tyler.durden/icinga2
1
0
Fork 0
mirror of https://github.com/Icinga/icinga2.git synced 2025-07-26 23:24:09 +02:00
Code Issues Packages Projects Releases Wiki Activity

Keep object locked until events are dispatched.

Browse Source
This commit is contained in:
William Calliari 2025-03-10 13:51:25 +01:00
parent c253e7eb6e
commit abf2fb392b
No known key found for this signature in database
GPG Key ID: DBFD45030805358F
1 changed files with 42 additions and 54 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

92
lib/icinga/checkable-check.cpp
View File

@ -104,10 +104,8 @@ Checkable::ProcessingResult Checkable::ProcessCheckResult(const CheckResult::Ptr
VERIFY(cr); VERIFY(cr);
VERIFY(producer); VERIFY(producer);
{
ObjectLock olock(this); ObjectLock olock(this);
m_CheckRunning = false; m_CheckRunning = false;
}
double now = Utility::GetTime(); double now = Utility::GetTime();
@ -169,8 +167,6 @@ Checkable::ProcessingResult Checkable::ProcessCheckResult(const CheckResult::Ptr
// This will be used to determine whether the on reachability changed event should be triggered. // This will be used to determine whether the on reachability changed event should be triggered.
bool affectsPreviousStateChildren(reachable && AffectsChildren()); bool affectsPreviousStateChildren(reachable && AffectsChildren());
ObjectLock olock(this);
CheckResult::Ptr old_cr = GetLastCheckResult(); CheckResult::Ptr old_cr = GetLastCheckResult();
ServiceState old_state = GetStateRaw(); ServiceState old_state = GetStateRaw();
StateType old_stateType = GetStateType(); StateType old_stateType = GetStateType();
@ -333,8 +329,6 @@ Checkable::ProcessingResult Checkable::ProcessCheckResult(const CheckResult::Ptr
if (is_volatile && IsStateOK(old_state) && IsStateOK(new_state)) if (is_volatile && IsStateOK(old_state) && IsStateOK(new_state))
send_notification = false; /* Don't send notifications for volatile OK -> OK changes. */ send_notification = false; /* Don't send notifications for volatile OK -> OK changes. */
olock.Unlock();
if (remove_acknowledgement_comments) if (remove_acknowledgement_comments)
RemoveAckComments(String(), cr->GetExecutionEnd()); RemoveAckComments(String(), cr->GetExecutionEnd());
@ -350,25 +344,14 @@ Checkable::ProcessingResult Checkable::ProcessCheckResult(const CheckResult::Ptr
cr->SetVarsAfter(vars_after); cr->SetVarsAfter(vars_after);
olock.Lock(); bool problem_change = false;
if (service) { if (service) {
SetLastCheckResult(cr); SetLastCheckResult(cr);
} else { } else {
bool wasProblem = GetProblem(); bool wasProblem = GetProblem();
SetLastCheckResult(cr); SetLastCheckResult(cr);
problem_change = GetProblem() != wasProblem;
if (GetProblem() != wasProblem) {
auto services = host->GetServices();
olock.Unlock();
for (auto& service : services) {
Service::OnHostProblemChanged(service, cr, origin);
} }
olock.Lock();
}
}
bool was_flapping = IsFlapping(); bool was_flapping = IsFlapping();
UpdateFlappingStatus(cr->GetState()); UpdateFlappingStatus(cr->GetState());
@ -399,8 +382,6 @@ Checkable::ProcessingResult Checkable::ProcessCheckResult(const CheckResult::Ptr
} }
} }
olock.Unlock();
#ifdef I2_DEBUG /* I2_DEBUG */ #ifdef I2_DEBUG /* I2_DEBUG */
Log(LogDebug, "Checkable") Log(LogDebug, "Checkable")
<< "Flapping: Checkable " << GetName() << "Flapping: Checkable " << GetName()
@ -411,36 +392,6 @@ Checkable::ProcessingResult Checkable::ProcessCheckResult(const CheckResult::Ptr
<< "% current: " << GetFlappingCurrent() << "%."; << "% current: " << GetFlappingCurrent() << "%.";
#endif /* I2_DEBUG */ #endif /* I2_DEBUG */
if (recovery) {
for (auto& child : children) {
if (child->GetProblem() && child->GetEnableActiveChecks()) {
auto nextCheck (now + Utility::Random() % 60);
ObjectLock oLock (child);
if (nextCheck < child->GetNextCheck()) {
child->SetNextCheck(nextCheck);
}
}
}
}
if (stateChange) {
/* reschedule direct parents */
for (const Checkable::Ptr& parent : GetParents()) {
if (parent.get() == this)
continue;
if (!parent->GetEnableActiveChecks())
continue;
if (parent->GetNextCheck() >= now + parent->GetRetryInterval()) {
ObjectLock olock(parent);
parent->SetNextCheck(now);
}
}
}
OnNewCheckResult(this, cr, origin); OnNewCheckResult(this, cr, origin);
/* signal status updates to for example db_ido */ /* signal status updates to for example db_ido */
@ -521,7 +472,6 @@ Checkable::ProcessingResult Checkable::ProcessCheckResult(const CheckResult::Ptr
* stash them into a notification types bitmask for maybe re-sending later. * stash them into a notification types bitmask for maybe re-sending later.
*/ */
ObjectLock olock (this);
int suppressed_types_before (GetSuppressedNotifications()); int suppressed_types_before (GetSuppressedNotifications());
int suppressed_types_after (suppressed_types_before | suppressed_types); int suppressed_types_after (suppressed_types_before | suppressed_types);
@ -551,6 +501,44 @@ Checkable::ProcessingResult Checkable::ProcessCheckResult(const CheckResult::Ptr
if ((stateChange || hardChange) && !children.empty() && (affectsPreviousStateChildren || AffectsChildren())) if ((stateChange || hardChange) && !children.empty() && (affectsPreviousStateChildren || AffectsChildren()))
OnReachabilityChanged(this, cr, children, origin); OnReachabilityChanged(this, cr, children, origin);
olock->Unlock();
if (!service && problem_change) {
auto services = host->GetServices();
for (auto& service : services) {
Service::OnHostProblemChanged(service, cr, origin);
}
}
if (recovery) {
for (auto& child : children) {
if (child->GetProblem() && child->GetEnableActiveChecks()) {
auto nextCheck (now + Utility::Random() % 60);
ObjectLock oLock (child);
if (nextCheck < child->GetNextCheck()) {
child->SetNextCheck(nextCheck);
}
}
}
}
if (stateChange) {
/* reschedule direct parents */
for (const Checkable::Ptr& parent : GetParents()) {
if (parent.get() == this)
continue;
if (!parent->GetEnableActiveChecks())
continue;
if (parent->GetNextCheck() >= now + parent->GetRetryInterval()) {
ObjectLock olock(parent);
parent->SetNextCheck(now);
}
}
}
return Result::Ok; return Result::Ok;
} }