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

WIP3

Browse Source
This commit is contained in:
Alexander A. Klimov 2025-04-03 15:30:31 +02:00
parent 84dc5dff72
commit afccb1e0fe
5 changed files with 16 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
lib/methods/clusterzonechecktask.cpp
View File

@ -137,6 +137,7 @@ void ClusterZoneCheckTask::ScriptFunc(const Checkable::Ptr& checkable, const Che
double messagesReceivedPerSecond = 0; double messagesReceivedPerSecond = 0;
double bytesSentPerSecond = 0; double bytesSentPerSecond = 0;
double bytesReceivedPerSecond = 0; double bytesReceivedPerSecond = 0;
double secondsAwaitingMessages = 0;
double secondsReadingMessages = 0; double secondsReadingMessages = 0;
double secondsAwaitingSemaphore = 0; double secondsAwaitingSemaphore = 0;
double secondsProcessingMessages = 0; double secondsProcessingMessages = 0;
@ -163,6 +164,7 @@ void ClusterZoneCheckTask::ScriptFunc(const Checkable::Ptr& checkable, const Che
messagesReceivedPerSecond += endpoint->GetMessagesReceivedPerSecond(); messagesReceivedPerSecond += endpoint->GetMessagesReceivedPerSecond();
bytesSentPerSecond += endpoint->GetBytesSentPerSecond(); bytesSentPerSecond += endpoint->GetBytesSentPerSecond();
bytesReceivedPerSecond += endpoint->GetBytesReceivedPerSecond(); bytesReceivedPerSecond += endpoint->GetBytesReceivedPerSecond();
secondsAwaitingMessages += endpoint->GetSecondsAwaitingMessages();
secondsReadingMessages += endpoint->GetSecondsReadingMessages(); secondsReadingMessages += endpoint->GetSecondsReadingMessages();
secondsAwaitingSemaphore += endpoint->GetSecondsAwaitingSemaphore(); secondsAwaitingSemaphore += endpoint->GetSecondsAwaitingSemaphore();
secondsProcessingMessages += endpoint->GetSecondsProcessingMessages(); secondsProcessingMessages += endpoint->GetSecondsProcessingMessages();
@ -217,6 +219,7 @@ void ClusterZoneCheckTask::ScriptFunc(const Checkable::Ptr& checkable, const Che
new PerfdataValue("sum_messages_received_per_second", messagesReceivedPerSecond), new PerfdataValue("sum_messages_received_per_second", messagesReceivedPerSecond),
new PerfdataValue("sum_bytes_sent_per_second", bytesSentPerSecond), new PerfdataValue("sum_bytes_sent_per_second", bytesSentPerSecond),
new PerfdataValue("sum_bytes_received_per_second", bytesReceivedPerSecond), new PerfdataValue("sum_bytes_received_per_second", bytesReceivedPerSecond),
new PerfdataValue("sum_seconds_awaiting_messages", secondsAwaitingMessages, true),
new PerfdataValue("sum_seconds_reading_messages", secondsReadingMessages, true), new PerfdataValue("sum_seconds_reading_messages", secondsReadingMessages, true),
new PerfdataValue("sum_seconds_awaiting_semaphore", secondsAwaitingSemaphore, true), new PerfdataValue("sum_seconds_awaiting_semaphore", secondsAwaitingSemaphore, true),
new PerfdataValue("sum_seconds_processing_messages", secondsProcessingMessages, true) new PerfdataValue("sum_seconds_processing_messages", secondsProcessingMessages, true)

3
lib/methods/icingachecktask.cpp
View File

@ -127,6 +127,7 @@ void IcingaCheckTask::ScriptFunc(const Checkable::Ptr& checkable, const CheckRes
double messagesReceivedPerSecond = 0; double messagesReceivedPerSecond = 0;
double bytesSentPerSecond = 0; double bytesSentPerSecond = 0;
double bytesReceivedPerSecond = 0; double bytesReceivedPerSecond = 0;
double secondsAwaitingMessages = 0;
double secondsReadingMessages = 0; double secondsReadingMessages = 0;
double secondsAwaitingSemaphore = 0; double secondsAwaitingSemaphore = 0;
double secondsProcessingMessages = 0; double secondsProcessingMessages = 0;
@ -143,6 +144,7 @@ void IcingaCheckTask::ScriptFunc(const Checkable::Ptr& checkable, const CheckRes
messagesReceivedPerSecond += endpoint->GetMessagesReceivedPerSecond(); messagesReceivedPerSecond += endpoint->GetMessagesReceivedPerSecond();
bytesSentPerSecond += endpoint->GetBytesSentPerSecond(); bytesSentPerSecond += endpoint->GetBytesSentPerSecond();
bytesReceivedPerSecond += endpoint->GetBytesReceivedPerSecond(); bytesReceivedPerSecond += endpoint->GetBytesReceivedPerSecond();
secondsAwaitingMessages += endpoint->GetSecondsAwaitingMessages();
secondsReadingMessages += endpoint->GetSecondsReadingMessages(); secondsReadingMessages += endpoint->GetSecondsReadingMessages();
secondsAwaitingSemaphore += endpoint->GetSecondsAwaitingSemaphore(); secondsAwaitingSemaphore += endpoint->GetSecondsAwaitingSemaphore();
secondsProcessingMessages += endpoint->GetSecondsProcessingMessages(); secondsProcessingMessages += endpoint->GetSecondsProcessingMessages();
@ -154,6 +156,7 @@ void IcingaCheckTask::ScriptFunc(const Checkable::Ptr& checkable, const CheckRes
perfdata->Add(new PerfdataValue("sum_messages_received_per_second", messagesReceivedPerSecond)); perfdata->Add(new PerfdataValue("sum_messages_received_per_second", messagesReceivedPerSecond));
perfdata->Add(new PerfdataValue("sum_bytes_sent_per_second", bytesSentPerSecond)); perfdata->Add(new PerfdataValue("sum_bytes_sent_per_second", bytesSentPerSecond));
perfdata->Add(new PerfdataValue("sum_bytes_received_per_second", bytesReceivedPerSecond)); perfdata->Add(new PerfdataValue("sum_bytes_received_per_second", bytesReceivedPerSecond));
perfdata->Add(new PerfdataValue("sum_seconds_awaiting_messages", secondsAwaitingMessages, true));
perfdata->Add(new PerfdataValue("sum_seconds_reading_messages", secondsReadingMessages, true)); perfdata->Add(new PerfdataValue("sum_seconds_reading_messages", secondsReadingMessages, true));
perfdata->Add(new PerfdataValue("sum_seconds_awaiting_semaphore", secondsAwaitingSemaphore, true)); perfdata->Add(new PerfdataValue("sum_seconds_awaiting_semaphore", secondsAwaitingSemaphore, true));
perfdata->Add(new PerfdataValue("sum_seconds_processing_messages", secondsProcessingMessages, true)); perfdata->Add(new PerfdataValue("sum_seconds_processing_messages", secondsProcessingMessages, true));

5
lib/remote/endpoint.cpp
View File

@ -137,6 +137,11 @@ double Endpoint::GetBytesReceivedPerSecond() const
return m_BytesReceived.CalculateRate(Utility::GetTime(), 60); return m_BytesReceived.CalculateRate(Utility::GetTime(), 60);
} }
double Endpoint::GetSecondsAwaitingMessages() const
{
return m_InputWaitTime;
}
double Endpoint::GetSecondsReadingMessages() const double Endpoint::GetSecondsReadingMessages() const
{ {
return m_InputReadTime; return m_InputReadTime;

1
lib/remote/endpoint.hpp
View File

@ -58,6 +58,7 @@ public:
double GetBytesSentPerSecond() const override; double GetBytesSentPerSecond() const override;
double GetBytesReceivedPerSecond() const override; double GetBytesReceivedPerSecond() const override;
double GetSecondsAwaitingMessages() const override;
double GetSecondsReadingMessages() const override; double GetSecondsReadingMessages() const override;
double GetSecondsAwaitingSemaphore() const override; double GetSecondsAwaitingSemaphore() const override;
double GetSecondsProcessingMessages() const override; double GetSecondsProcessingMessages() const override;

4
lib/remote/endpoint.ti
View File

@ -55,6 +55,10 @@ class Endpoint : ConfigObject
get; get;
}; };
[no_user_modify, no_storage] double seconds_awaiting_messages {
get;
};
[no_user_modify, no_storage] double seconds_reading_messages { [no_user_modify, no_storage] double seconds_reading_messages {
get; get;
}; };