1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
|
/*
* =========================================================================================
* Copyright © 2013-2015 the kamon project <http://kamon.io/>
*
* Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file
* except in compliance with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software distributed under the
* License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
* either express or implied. See the License for the specific language governing permissions
* and limitations under the License.
* =========================================================================================
*/
package kamon.system.sigar
import akka.event.LoggingAdapter
import kamon.metric.GenericEntityRecorder
import kamon.metric.instrument.InstrumentFactory
import org.hyperic.sigar.{ ProcCpu, Sigar }
import scala.util.Try
/**
* Process Cpu usage metrics, as reported by Sigar:
* - user: Process cpu user time.
* - total: Process cpu time (sum of User and Sys).
* - system: Process cpu kernel time.
*/
class ProcessCpuMetrics(sigar: Sigar, instrumentFactory: InstrumentFactory, logger: LoggingAdapter) extends GenericEntityRecorder(instrumentFactory) with SigarMetric {
val processUserCpu = histogram("process-user-cpu")
val processSystemCpu = histogram("process-system-cpu")
val processTotalCpu = histogram("process-cpu")
val pid = sigar.getPid
val totalCores = sigar.getCpuInfoList.headOption.map(_.getTotalCores.toLong).getOrElse(1L)
var lastProcCpu: ProcCpu = sigar.getProcCpu(pid)
var currentLoad: Long = 0
/**
* While CPU usage time updates not very often, We have introduced a simple heuristic, that supposes that the load is the same as previous,
* while CPU usage time doesn't update. But supposing that it could be zero load for a process for some time,
* We used an arbitrary duration of 2000 milliseconds, after which the same CPU usage time value become legal, and it is supposed that the load is really zero.
*
* @see [[http://stackoverflow.com/questions/19323364/using-sigar-api-to-get-jvm-cpu-usage "StackOverflow: Using Sigar API to get JVM Cpu usage"]]
*/
def update(): Unit = {
val currentProcCpu = sigar.getProcCpu(pid)
val totalDiff = currentProcCpu.getTotal - lastProcCpu.getTotal
val userDiff = currentProcCpu.getUser - lastProcCpu.getUser
val systemDiff = currentProcCpu.getSys - lastProcCpu.getSys
val timeDiff = currentProcCpu.getLastTime - lastProcCpu.getLastTime
def percentUsage(delta: Long): Long = Try(100 * delta / timeDiff / totalCores).getOrElse(0L)
if (totalDiff == 0) {
if (timeDiff > 2000) currentLoad = 0
if (currentLoad == 0) lastProcCpu = currentProcCpu
} else {
val totalPercent = percentUsage(totalDiff)
val userPercent = percentUsage(userDiff)
val systemPercent = percentUsage(systemDiff)
processUserCpu.record(userPercent)
processSystemCpu.record(systemPercent)
processTotalCpu.record(userPercent + systemPercent)
currentLoad = totalPercent
lastProcCpu = currentProcCpu
}
}
}
object ProcessCpuMetrics extends SigarMetricRecorderCompanion("process-cpu") {
def apply(sigar: Sigar, instrumentFactory: InstrumentFactory, logger: LoggingAdapter): ProcessCpuMetrics =
new ProcessCpuMetrics(sigar, instrumentFactory, logger)
}
|
