Keep object locked until events are dispatched.

AUTHORS

@@ -301,6 +301,7 @@ vigiroux <[email protected]>
 Vytenis Darulis <[email protected]>
 Wenger Florian <[email protected]>
 Will Frey <[email protected]>
+William Calliari <[email protected]>
 Winfried Angele <[email protected]>
 Wolfgang Nieder <[email protected]>
 XnS <[email protected]>

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;
 }