diff --git a/AUTHORS b/AUTHORS index 0718440ad0..6b648735c5 100644 --- a/AUTHORS +++ b/AUTHORS @@ -301,6 +301,7 @@ vigiroux Vytenis Darulis Wenger Florian Will Frey +William Calliari <42240136+w1ll-i-code@users.noreply.github.com> Winfried Angele Wolfgang Nieder XnS diff --git a/lib/icinga/checkable-check.cpp b/lib/icinga/checkable-check.cpp index 38dca27ab4..fe7b651bed 100644 --- a/lib/icinga/checkable-check.cpp +++ b/lib/icinga/checkable-check.cpp @@ -104,10 +104,8 @@ Checkable::ProcessingResult Checkable::ProcessCheckResult(const CheckResult::Ptr VERIFY(cr); VERIFY(producer); - { - ObjectLock olock(this); - m_CheckRunning = false; - } + ObjectLock olock(this); + m_CheckRunning = false; 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. bool affectsPreviousStateChildren(reachable && AffectsChildren()); - ObjectLock olock(this); - CheckResult::Ptr old_cr = GetLastCheckResult(); ServiceState old_state = GetStateRaw(); StateType old_stateType = GetStateType(); @@ -333,8 +329,6 @@ Checkable::ProcessingResult Checkable::ProcessCheckResult(const CheckResult::Ptr if (is_volatile && IsStateOK(old_state) && IsStateOK(new_state)) send_notification = false; /* Don't send notifications for volatile OK -> OK changes. */ - olock.Unlock(); - if (remove_acknowledgement_comments) RemoveAckComments(String(), cr->GetExecutionEnd()); @@ -350,8 +344,6 @@ Checkable::ProcessingResult Checkable::ProcessCheckResult(const CheckResult::Ptr cr->SetVarsAfter(vars_after); - olock.Lock(); - if (service) { SetLastCheckResult(cr); } else { @@ -361,11 +353,9 @@ Checkable::ProcessingResult Checkable::ProcessCheckResult(const CheckResult::Ptr if (GetProblem() != wasProblem) { auto services = host->GetServices(); - olock.Unlock(); for (auto& service : services) { Service::OnHostProblemChanged(service, cr, origin); } - olock.Lock(); } } @@ -399,8 +389,6 @@ Checkable::ProcessingResult Checkable::ProcessCheckResult(const CheckResult::Ptr } } - olock.Unlock(); - #ifdef I2_DEBUG /* I2_DEBUG */ Log(LogDebug, "Checkable") << "Flapping: Checkable " << GetName() @@ -411,36 +399,6 @@ Checkable::ProcessingResult Checkable::ProcessCheckResult(const CheckResult::Ptr << "% current: " << GetFlappingCurrent() << "%."; #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); /* signal status updates to for example db_ido */ @@ -521,7 +479,6 @@ Checkable::ProcessingResult Checkable::ProcessCheckResult(const CheckResult::Ptr * stash them into a notification types bitmask for maybe re-sending later. */ - ObjectLock olock (this); int suppressed_types_before (GetSuppressedNotifications()); int suppressed_types_after (suppressed_types_before | suppressed_types); @@ -551,6 +508,38 @@ Checkable::ProcessingResult Checkable::ProcessCheckResult(const CheckResult::Ptr if ((stateChange || hardChange) && !children.empty() && (affectsPreviousStateChildren || AffectsChildren())) OnReachabilityChanged(this, cr, children, origin); + olock.Unlock(); + + 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; }