This is an automated email from the ASF dual-hosted git repository.
exceptionfactory pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/main by this push:
new f8d0d2f9b6 NIFI-11921 Set CPU Load Average for C2 Heartbeats
f8d0d2f9b6 is described below
commit f8d0d2f9b63b6c3e5bf1522464af8108a8046740
Author: Kalman Jantner <[email protected]>
AuthorDate: Tue Aug 8 16:25:07 2023 +0200
NIFI-11921 Set CPU Load Average for C2 Heartbeats
This closes #7584
Signed-off-by: David Handermann <[email protected]>
---
.../org/apache/nifi/c2/client/service/C2HeartbeatFactory.java | 2 +-
.../main/java/org/apache/nifi/c2/protocol/api/SystemInfo.java | 9 +++++++++
2 files changed, 10 insertions(+), 1 deletion(-)
diff --git
a/c2/c2-client-bundle/c2-client-service/src/main/java/org/apache/nifi/c2/client/service/C2HeartbeatFactory.java
b/c2/c2-client-bundle/c2-client-service/src/main/java/org/apache/nifi/c2/client/service/C2HeartbeatFactory.java
index b157e8294e..8534536430 100644
---
a/c2/c2-client-bundle/c2-client-service/src/main/java/org/apache/nifi/c2/client/service/C2HeartbeatFactory.java
+++
b/c2/c2-client-bundle/c2-client-service/src/main/java/org/apache/nifi/c2/client/service/C2HeartbeatFactory.java
@@ -228,7 +228,7 @@ public class C2HeartbeatFactory {
// getSystemLoadAverage is not available in Windows, so we need to
prevent to send invalid data
if (systemLoadAverage >= 0) {
- systemInfo.setCpuUtilization(systemLoadAverage / (double)
osMXBean.getAvailableProcessors());
+ systemInfo.setCpuLoadAverage(systemLoadAverage);
}
return systemInfo;
diff --git
a/c2/c2-protocol/c2-protocol-api/src/main/java/org/apache/nifi/c2/protocol/api/SystemInfo.java
b/c2/c2-protocol/c2-protocol-api/src/main/java/org/apache/nifi/c2/protocol/api/SystemInfo.java
index 05c87cf2f3..cd07ef19b7 100644
---
a/c2/c2-protocol/c2-protocol-api/src/main/java/org/apache/nifi/c2/protocol/api/SystemInfo.java
+++
b/c2/c2-protocol/c2-protocol-api/src/main/java/org/apache/nifi/c2/protocol/api/SystemInfo.java
@@ -45,6 +45,7 @@ public class SystemInfo implements Serializable {
@ApiModelProperty
private Double cpuUtilization;
+ private Double cpuLoadAverage;
public String getMachineArch() {
return machineArch;
@@ -93,4 +94,12 @@ public class SystemInfo implements Serializable {
public void setvCores(Integer vCores) {
this.vCores = vCores;
}
+
+ public Double getCpuLoadAverage() {
+ return cpuLoadAverage;
+ }
+
+ public void setCpuLoadAverage(Double cpuLoadAverage) {
+ this.cpuLoadAverage = cpuLoadAverage;
+ }
}