Implemented cpu stats

This commit is contained in:
Diptanu Choudhury
2016-05-19 13:32:03 -07:00
parent ea1370d426
commit 30cbfe1f71
4 changed files with 69 additions and 3 deletions

View File

@@ -150,6 +150,7 @@ func (e *UniversalExecutor) Stats() (*cstructs.TaskResourceUsage, error) {
}
// CPU Related Stats
totalProcessCPUUsage := stats.CpuStats.CpuUsage.TotalUsage
userModeTime := stats.CpuStats.CpuUsage.UsageInUsermode
kernelModeTime := stats.CpuStats.CpuUsage.UsageInKernelmode
@@ -162,6 +163,9 @@ func (e *UniversalExecutor) Stats() (*cstructs.TaskResourceUsage, error) {
ThrottledPeriods: stats.CpuStats.ThrottlingData.ThrottledPeriods,
ThrottledTime: stats.CpuStats.ThrottlingData.ThrottledTime,
}
if e.cpuStats != nil {
cs.Percent = e.cpuStats.Percent(totalProcessCPUUsage)
}
return &cstructs.TaskResourceUsage{MemoryStats: ms, CpuStats: cs, Timestamp: time.Now()}, nil
}