IcingaCheckTask: Add available I/O cpu semaphores as a perfdata

Icinga · Nov 20, 2024 · 729bafd · 729bafd
1 parent 3218908
commit 729bafd
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 1 deletion.
diff --git a/lib/base/io-engine.cpp b/lib/base/io-engine.cpp
@@ -85,6 +85,11 @@ boost::asio::io_context& IoEngine::GetIoContext()
 	return m_IoContext;
 }
 
+int_fast32_t IoEngine::GetCpuSemaphore() const
+{
+	return m_CpuBoundSemaphore;
+}
+
 IoEngine::IoEngine() : m_IoContext(), m_KeepAlive(boost::asio::make_work_guard(m_IoContext)), m_Threads(decltype(m_Threads)::size_type(Configuration::Concurrency * 2u)), m_AlreadyExpiredTimer(m_IoContext)
 {
 	m_AlreadyExpiredTimer.expires_at(boost::posix_time::neg_infin);

diff --git a/lib/base/io-engine.hpp b/lib/base/io-engine.hpp
@@ -83,6 +83,8 @@ class IoEngine
 
 	boost::asio::io_context& GetIoContext();
 
+	int_fast32_t GetCpuSemaphore() const;
+
 	static inline size_t GetCoroutineStackSize() {
 #ifdef _WIN32
 		// Increase the stack size for Windows coroutines to prevent exception corruption.

diff --git a/lib/methods/icingachecktask.cpp b/lib/methods/icingachecktask.cpp
@@ -9,7 +9,7 @@
 #include "icinga/checkable.hpp"
 #include "remote/apilistener.hpp"
 #include "base/application.hpp"
-#include "base/objectlock.hpp"
+#include "base/io-engine.hpp"
 #include "base/utility.hpp"
 #include "base/perfdatavalue.hpp"
 #include "base/function.hpp"
@@ -81,6 +81,8 @@ void IcingaCheckTask::ScriptFunc(const Checkable::Ptr& checkable, const CheckRes
 	perfdata->Add(new PerfdataValue("current_concurrent_checks", Checkable::CurrentConcurrentChecks.load()));
 	perfdata->Add(new PerfdataValue("remote_check_queue", ClusterEvents::GetCheckRequestQueueSize()));
 
+	perfdata->Add(new PerfdataValue("num_free_io_cpu_slots", IoEngine::Get().GetCpuSemaphore()));
+
 	CheckableCheckStatistics scs = CIB::CalculateServiceCheckStats();
 
 	perfdata->Add(new PerfdataValue("min_latency", scs.min_latency));