Skip to content

Commit 07b7994

Browse files
authoredMay 11, 2024
Merge pull request #202 from skruger/memory_usage_stats
Report memory usage and correct CPU percentage in heartbeat messages
2 parents edd5204 + ce46146 commit 07b7994

File tree

2 files changed

+10
-2
lines changed

2 files changed

+10
-2
lines changed
 

‎runner.go

+4-2
Original file line numberDiff line numberDiff line change
@@ -621,9 +621,11 @@ func (r *slaveRunner) run() {
621621
}
622622
// send client heartbeat message
623623
CPUUsage := GetCurrentCPUUsage()
624+
MemUsage := GetCurrentMemUsage()
624625
data := map[string]interface{}{
625-
"state": r.state,
626-
"current_cpu_usage": CPUUsage,
626+
"state": r.state,
627+
"current_cpu_usage": CPUUsage,
628+
"current_memory_usage": MemUsage,
627629
}
628630
r.client.sendChannel() <- newGenericMessage("heartbeat", data, r.nodeID)
629631
case <-r.shutdownChan:

‎utils.go

+6
Original file line numberDiff line numberDiff line change
@@ -137,3 +137,9 @@ func GetCurrentCPUUsage() float64 {
137137
}
138138
return percent / float64(runtime.NumCPU())
139139
}
140+
141+
func GetCurrentMemUsage() uint64 {
142+
var m runtime.MemStats
143+
runtime.ReadMemStats(&m)
144+
return m.Alloc
145+
}

0 commit comments

Comments
 (0)