mirror of
https://github.com/ClusterCockpit/cc-metric-collector.git
synced 2024-12-25 15:09:05 +01:00
Refactoring of LikwidCollector and metric units (#62)
* Reduce complexity of LikwidCollector and allow metric units * Add unit to LikwidCollector docu and fix some typos * Make library path configurable
This commit is contained in:
parent
c9b8fcdaa7
commit
73f22c1041
@ -15,7 +15,6 @@ import (
|
|||||||
"io/ioutil"
|
"io/ioutil"
|
||||||
"math"
|
"math"
|
||||||
"os"
|
"os"
|
||||||
"regexp"
|
|
||||||
"strconv"
|
"strconv"
|
||||||
"strings"
|
"strings"
|
||||||
"time"
|
"time"
|
||||||
@ -28,48 +27,6 @@ import (
|
|||||||
"github.com/NVIDIA/go-nvml/pkg/dl"
|
"github.com/NVIDIA/go-nvml/pkg/dl"
|
||||||
)
|
)
|
||||||
|
|
||||||
type MetricScope string
|
|
||||||
|
|
||||||
const (
|
|
||||||
METRIC_SCOPE_HWTHREAD = iota
|
|
||||||
METRIC_SCOPE_CORE
|
|
||||||
METRIC_SCOPE_LLC
|
|
||||||
METRIC_SCOPE_NUMA
|
|
||||||
METRIC_SCOPE_DIE
|
|
||||||
METRIC_SCOPE_SOCKET
|
|
||||||
METRIC_SCOPE_NODE
|
|
||||||
)
|
|
||||||
|
|
||||||
func (ms MetricScope) String() string {
|
|
||||||
return string(ms)
|
|
||||||
}
|
|
||||||
|
|
||||||
func (ms MetricScope) Likwid() string {
|
|
||||||
LikwidDomains := map[string]string{
|
|
||||||
"cpu": "",
|
|
||||||
"core": "",
|
|
||||||
"llc": "C",
|
|
||||||
"numadomain": "M",
|
|
||||||
"die": "D",
|
|
||||||
"socket": "S",
|
|
||||||
"node": "N",
|
|
||||||
}
|
|
||||||
return LikwidDomains[string(ms)]
|
|
||||||
}
|
|
||||||
|
|
||||||
func (ms MetricScope) Granularity() int {
|
|
||||||
for i, g := range GetAllMetricScopes() {
|
|
||||||
if ms == g {
|
|
||||||
return i
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return -1
|
|
||||||
}
|
|
||||||
|
|
||||||
func GetAllMetricScopes() []MetricScope {
|
|
||||||
return []MetricScope{"cpu" /*, "core", "llc", "numadomain", "die",*/, "socket", "node"}
|
|
||||||
}
|
|
||||||
|
|
||||||
const (
|
const (
|
||||||
LIKWID_LIB_NAME = "liblikwid.so"
|
LIKWID_LIB_NAME = "liblikwid.so"
|
||||||
LIKWID_LIB_DL_FLAGS = dl.RTLD_LAZY | dl.RTLD_GLOBAL
|
LIKWID_LIB_DL_FLAGS = dl.RTLD_LAZY | dl.RTLD_GLOBAL
|
||||||
@ -79,15 +36,13 @@ const (
|
|||||||
type LikwidCollectorMetricConfig struct {
|
type LikwidCollectorMetricConfig struct {
|
||||||
Name string `json:"name"` // Name of the metric
|
Name string `json:"name"` // Name of the metric
|
||||||
Calc string `json:"calc"` // Calculation for the metric using
|
Calc string `json:"calc"` // Calculation for the metric using
|
||||||
//Aggr string `json:"aggregation"` // if scope unequal to LIKWID metric scope, the values are combined (sum, min, max, mean or avg, median)
|
Type string `json:"type"` // Metric type (aka node, socket, cpu, ...)
|
||||||
Scope MetricScope `json:"scope"` // scope for calculation. subscopes are aggregated using the 'aggregation' function
|
|
||||||
Publish bool `json:"publish"`
|
Publish bool `json:"publish"`
|
||||||
granulatity MetricScope
|
Unit string `json:"unit"` // Unit of metric if any
|
||||||
}
|
}
|
||||||
|
|
||||||
type LikwidCollectorEventsetConfig struct {
|
type LikwidCollectorEventsetConfig struct {
|
||||||
Events map[string]string `json:"events"`
|
Events map[string]string `json:"events"`
|
||||||
granulatity map[string]MetricScope
|
|
||||||
Metrics []LikwidCollectorMetricConfig `json:"metrics"`
|
Metrics []LikwidCollectorMetricConfig `json:"metrics"`
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -98,6 +53,7 @@ type LikwidCollectorConfig struct {
|
|||||||
InvalidToZero bool `json:"invalid_to_zero,omitempty"`
|
InvalidToZero bool `json:"invalid_to_zero,omitempty"`
|
||||||
AccessMode string `json:"access_mode,omitempty"`
|
AccessMode string `json:"access_mode,omitempty"`
|
||||||
DaemonPath string `json:"accessdaemon_path,omitempty"`
|
DaemonPath string `json:"accessdaemon_path,omitempty"`
|
||||||
|
LibraryPath string `json:"liblikwid_path,omitempty"`
|
||||||
}
|
}
|
||||||
|
|
||||||
type LikwidCollector struct {
|
type LikwidCollector struct {
|
||||||
@ -105,7 +61,6 @@ type LikwidCollector struct {
|
|||||||
cpulist []C.int
|
cpulist []C.int
|
||||||
cpu2tid map[int]int
|
cpu2tid map[int]int
|
||||||
sock2tid map[int]int
|
sock2tid map[int]int
|
||||||
scopeRespTids map[MetricScope]map[int]int
|
|
||||||
metrics map[C.int]map[string]int
|
metrics map[C.int]map[string]int
|
||||||
groups []C.int
|
groups []C.int
|
||||||
config LikwidCollectorConfig
|
config LikwidCollectorConfig
|
||||||
@ -119,7 +74,7 @@ type LikwidCollector struct {
|
|||||||
type LikwidMetric struct {
|
type LikwidMetric struct {
|
||||||
name string
|
name string
|
||||||
search string
|
search string
|
||||||
scope MetricScope
|
scope string
|
||||||
group_idx int
|
group_idx int
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -131,152 +86,43 @@ func eventsToEventStr(events map[string]string) string {
|
|||||||
return strings.Join(elist, ",")
|
return strings.Join(elist, ",")
|
||||||
}
|
}
|
||||||
|
|
||||||
func getGranularity(counter, event string) MetricScope {
|
|
||||||
if strings.HasPrefix(counter, "PMC") || strings.HasPrefix(counter, "FIXC") {
|
|
||||||
return "cpu"
|
|
||||||
} else if strings.Contains(counter, "BOX") || strings.Contains(counter, "DEV") {
|
|
||||||
return "socket"
|
|
||||||
} else if strings.HasPrefix(counter, "PWR") {
|
|
||||||
if event == "RAPL_CORE_ENERGY" {
|
|
||||||
return "cpu"
|
|
||||||
} else {
|
|
||||||
return "socket"
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return "unknown"
|
|
||||||
}
|
|
||||||
|
|
||||||
func getBaseFreq() float64 {
|
func getBaseFreq() float64 {
|
||||||
var freq float64 = math.NaN()
|
var freq float64 = math.NaN()
|
||||||
C.power_init(0)
|
C.power_init(0)
|
||||||
info := C.get_powerInfo()
|
info := C.get_powerInfo()
|
||||||
if float64(info.baseFrequency) != 0 {
|
if float64(info.baseFrequency) != 0 {
|
||||||
freq = float64(info.baseFrequency) * 1e3
|
freq = float64(info.baseFrequency) * 1e6
|
||||||
} else {
|
} else {
|
||||||
buffer, err := ioutil.ReadFile("/sys/devices/system/cpu/cpu0/cpufreq/bios_limit")
|
buffer, err := ioutil.ReadFile("/sys/devices/system/cpu/cpu0/cpufreq/bios_limit")
|
||||||
if err == nil {
|
if err == nil {
|
||||||
data := strings.Replace(string(buffer), "\n", "", -1)
|
data := strings.Replace(string(buffer), "\n", "", -1)
|
||||||
x, err := strconv.ParseInt(data, 0, 64)
|
x, err := strconv.ParseInt(data, 0, 64)
|
||||||
if err == nil {
|
if err == nil {
|
||||||
freq = float64(x) * 1e3
|
freq = float64(x) * 1e6
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return freq
|
return freq
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *LikwidCollector) initGranularity() {
|
|
||||||
splitRegex := regexp.MustCompile("[+-/*()]")
|
|
||||||
for _, evset := range m.config.Eventsets {
|
|
||||||
evset.granulatity = make(map[string]MetricScope)
|
|
||||||
for counter, event := range evset.Events {
|
|
||||||
gran := getGranularity(counter, event)
|
|
||||||
if gran.Granularity() >= 0 {
|
|
||||||
evset.granulatity[counter] = gran
|
|
||||||
}
|
|
||||||
}
|
|
||||||
for i, metric := range evset.Metrics {
|
|
||||||
s := splitRegex.Split(metric.Calc, -1)
|
|
||||||
gran := MetricScope("cpu")
|
|
||||||
evset.Metrics[i].granulatity = gran
|
|
||||||
for _, x := range s {
|
|
||||||
if _, ok := evset.Events[x]; ok {
|
|
||||||
if evset.granulatity[x].Granularity() > gran.Granularity() {
|
|
||||||
gran = evset.granulatity[x]
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
evset.Metrics[i].granulatity = gran
|
|
||||||
}
|
|
||||||
}
|
|
||||||
for i, metric := range m.config.Metrics {
|
|
||||||
s := splitRegex.Split(metric.Calc, -1)
|
|
||||||
gran := MetricScope("cpu")
|
|
||||||
m.config.Metrics[i].granulatity = gran
|
|
||||||
for _, x := range s {
|
|
||||||
for _, evset := range m.config.Eventsets {
|
|
||||||
for _, m := range evset.Metrics {
|
|
||||||
if m.Name == x && m.granulatity.Granularity() > gran.Granularity() {
|
|
||||||
gran = m.granulatity
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
m.config.Metrics[i].granulatity = gran
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
type TopoResolveFunc func(cpuid int) int
|
|
||||||
|
|
||||||
func (m *LikwidCollector) getResponsiblities() map[MetricScope]map[int]int {
|
|
||||||
get_cpus := func(scope MetricScope) map[int]int {
|
|
||||||
var slist []int
|
|
||||||
var cpu C.int
|
|
||||||
var input func(index int) string
|
|
||||||
switch scope {
|
|
||||||
case "node":
|
|
||||||
slist = []int{0}
|
|
||||||
input = func(index int) string { return "N:0" }
|
|
||||||
case "socket":
|
|
||||||
input = func(index int) string { return fmt.Sprintf("%s%d:0", scope.Likwid(), index) }
|
|
||||||
slist = topo.SocketList()
|
|
||||||
// case "numadomain":
|
|
||||||
// input = func(index int) string { return fmt.Sprintf("%s%d:0", scope.Likwid(), index) }
|
|
||||||
// slist = topo.NumaNodeList()
|
|
||||||
// cclog.Debug(scope, " ", input(0), " ", slist)
|
|
||||||
// case "die":
|
|
||||||
// input = func(index int) string { return fmt.Sprintf("%s%d:0", scope.Likwid(), index) }
|
|
||||||
// slist = topo.DieList()
|
|
||||||
// case "llc":
|
|
||||||
// input = fmt.Sprintf("%s%d:0", scope.Likwid(), s)
|
|
||||||
// slist = topo.LLCacheList()
|
|
||||||
case "cpu":
|
|
||||||
input = func(index int) string { return fmt.Sprintf("%d", index) }
|
|
||||||
slist = topo.CpuList()
|
|
||||||
case "hwthread":
|
|
||||||
input = func(index int) string { return fmt.Sprintf("%d", index) }
|
|
||||||
slist = topo.CpuList()
|
|
||||||
}
|
|
||||||
outmap := make(map[int]int)
|
|
||||||
for _, s := range slist {
|
|
||||||
t := C.CString(input(s))
|
|
||||||
clen := C.cpustr_to_cpulist(t, &cpu, 1)
|
|
||||||
if int(clen) == 1 {
|
|
||||||
outmap[s] = m.cpu2tid[int(cpu)]
|
|
||||||
} else {
|
|
||||||
cclog.Error(fmt.Sprintf("Cannot determine responsible CPU for %s", input(s)))
|
|
||||||
outmap[s] = -1
|
|
||||||
}
|
|
||||||
C.free(unsafe.Pointer(t))
|
|
||||||
}
|
|
||||||
return outmap
|
|
||||||
}
|
|
||||||
|
|
||||||
scopes := GetAllMetricScopes()
|
|
||||||
complete := make(map[MetricScope]map[int]int)
|
|
||||||
for _, s := range scopes {
|
|
||||||
complete[s] = get_cpus(s)
|
|
||||||
}
|
|
||||||
return complete
|
|
||||||
}
|
|
||||||
|
|
||||||
func (m *LikwidCollector) Init(config json.RawMessage) error {
|
func (m *LikwidCollector) Init(config json.RawMessage) error {
|
||||||
var ret C.int
|
var ret C.int
|
||||||
m.name = "LikwidCollector"
|
m.name = "LikwidCollector"
|
||||||
m.config.AccessMode = LIKWID_DEF_ACCESSMODE
|
m.config.AccessMode = LIKWID_DEF_ACCESSMODE
|
||||||
|
m.config.LibraryPath = LIKWID_LIB_NAME
|
||||||
if len(config) > 0 {
|
if len(config) > 0 {
|
||||||
err := json.Unmarshal(config, &m.config)
|
err := json.Unmarshal(config, &m.config)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
lib := dl.New(LIKWID_LIB_NAME, LIKWID_LIB_DL_FLAGS)
|
lib := dl.New(m.config.LibraryPath, LIKWID_LIB_DL_FLAGS)
|
||||||
if lib == nil {
|
if lib == nil {
|
||||||
return fmt.Errorf("error instantiating DynamicLibrary for %s", LIKWID_LIB_NAME)
|
return fmt.Errorf("error instantiating DynamicLibrary for %s", m.config.LibraryPath)
|
||||||
}
|
}
|
||||||
err := lib.Open()
|
err := lib.Open()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return fmt.Errorf("error opening %s: %v", LIKWID_LIB_NAME, err)
|
return fmt.Errorf("error opening %s: %v", m.config.LibraryPath, err)
|
||||||
}
|
}
|
||||||
|
|
||||||
if m.config.ForceOverwrite {
|
if m.config.ForceOverwrite {
|
||||||
@ -306,10 +152,6 @@ func (m *LikwidCollector) Init(config json.RawMessage) error {
|
|||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
// Determine which counter works at which level. PMC*: cpu, *BOX*: socket, ...
|
|
||||||
m.initGranularity()
|
|
||||||
// Generate map for MetricScope -> scope_id (like socket id) -> responsible id (offset in cpulist)
|
|
||||||
m.scopeRespTids = m.getResponsiblities()
|
|
||||||
switch m.config.AccessMode {
|
switch m.config.AccessMode {
|
||||||
case "direct":
|
case "direct":
|
||||||
C.HPMmode(0)
|
C.HPMmode(0)
|
||||||
@ -336,6 +178,9 @@ func (m *LikwidCollector) Init(config json.RawMessage) error {
|
|||||||
globalParams["inverseClock"] = float64(1.0)
|
globalParams["inverseClock"] = float64(1.0)
|
||||||
// While adding the events, we test the metrics whether they can be computed at all
|
// While adding the events, we test the metrics whether they can be computed at all
|
||||||
for i, evset := range m.config.Eventsets {
|
for i, evset := range m.config.Eventsets {
|
||||||
|
var gid C.int
|
||||||
|
var cstr *C.char
|
||||||
|
if len(evset.Events) > 0 {
|
||||||
estr := eventsToEventStr(evset.Events)
|
estr := eventsToEventStr(evset.Events)
|
||||||
// Generate parameter list for the metric computing test
|
// Generate parameter list for the metric computing test
|
||||||
params := make(map[string]interface{})
|
params := make(map[string]interface{})
|
||||||
@ -357,8 +202,12 @@ func (m *LikwidCollector) Init(config json.RawMessage) error {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
// Now we add the list of events to likwid
|
// Now we add the list of events to likwid
|
||||||
cstr := C.CString(estr)
|
cstr = C.CString(estr)
|
||||||
gid := C.perfmon_addEventSet(cstr)
|
gid = C.perfmon_addEventSet(cstr)
|
||||||
|
} else {
|
||||||
|
cclog.ComponentError(m.name, "Invalid Likwid eventset config, no events given")
|
||||||
|
continue
|
||||||
|
}
|
||||||
if gid >= 0 {
|
if gid >= 0 {
|
||||||
m.groups = append(m.groups, gid)
|
m.groups = append(m.groups, gid)
|
||||||
}
|
}
|
||||||
@ -434,15 +283,9 @@ func (m *LikwidCollector) calcEventsetMetrics(group int, interval time.Duration,
|
|||||||
// Go over events and get the results
|
// Go over events and get the results
|
||||||
for eidx = 0; int(eidx) < len(evset.Events); eidx++ {
|
for eidx = 0; int(eidx) < len(evset.Events); eidx++ {
|
||||||
ctr := C.perfmon_getCounterName(gid, eidx)
|
ctr := C.perfmon_getCounterName(gid, eidx)
|
||||||
ev := C.perfmon_getEventName(gid, eidx)
|
|
||||||
gctr := C.GoString(ctr)
|
gctr := C.GoString(ctr)
|
||||||
gev := C.GoString(ev)
|
|
||||||
// MetricScope for the counter (and if needed the event)
|
for _, tid := range m.cpu2tid {
|
||||||
scope := getGranularity(gctr, gev)
|
|
||||||
// Get the map scope-id -> tids
|
|
||||||
// This way we read less counters like only the responsible hardware thread for a socket
|
|
||||||
scopemap := m.scopeRespTids[scope]
|
|
||||||
for _, tid := range scopemap {
|
|
||||||
if tid >= 0 {
|
if tid >= 0 {
|
||||||
m.results[group][tid]["time"] = interval.Seconds()
|
m.results[group][tid]["time"] = interval.Seconds()
|
||||||
m.results[group][tid]["inverseClock"] = invClock
|
m.results[group][tid]["inverseClock"] = invClock
|
||||||
@ -456,7 +299,10 @@ func (m *LikwidCollector) calcEventsetMetrics(group int, interval time.Duration,
|
|||||||
for _, metric := range evset.Metrics {
|
for _, metric := range evset.Metrics {
|
||||||
// The metric scope is determined in the Init() function
|
// The metric scope is determined in the Init() function
|
||||||
// Get the map scope-id -> tids
|
// Get the map scope-id -> tids
|
||||||
scopemap := m.scopeRespTids[metric.Scope]
|
scopemap := m.cpu2tid
|
||||||
|
if metric.Type == "socket" {
|
||||||
|
scopemap = m.sock2tid
|
||||||
|
}
|
||||||
for domain, tid := range scopemap {
|
for domain, tid := range scopemap {
|
||||||
if tid >= 0 {
|
if tid >= 0 {
|
||||||
value, err := agg.EvalFloat64Condition(metric.Calc, m.results[group][tid])
|
value, err := agg.EvalFloat64Condition(metric.Calc, m.results[group][tid])
|
||||||
@ -474,13 +320,15 @@ func (m *LikwidCollector) calcEventsetMetrics(group int, interval time.Duration,
|
|||||||
// Now we have the result, send it with the proper tags
|
// Now we have the result, send it with the proper tags
|
||||||
if !math.IsNaN(value) {
|
if !math.IsNaN(value) {
|
||||||
if metric.Publish {
|
if metric.Publish {
|
||||||
tags := map[string]string{"type": metric.Scope.String()}
|
|
||||||
if metric.Scope != "node" {
|
|
||||||
tags["type-id"] = fmt.Sprintf("%d", domain)
|
|
||||||
}
|
|
||||||
fields := map[string]interface{}{"value": value}
|
fields := map[string]interface{}{"value": value}
|
||||||
y, err := lp.New(metric.Name, tags, m.meta, fields, time.Now())
|
y, err := lp.New(metric.Name, map[string]string{"type": metric.Type}, m.meta, fields, time.Now())
|
||||||
if err == nil {
|
if err == nil {
|
||||||
|
if metric.Type != "node" {
|
||||||
|
y.AddTag("type-id", fmt.Sprintf("%d", domain))
|
||||||
|
}
|
||||||
|
if len(metric.Unit) > 0 {
|
||||||
|
y.AddMeta("unit", metric.Unit)
|
||||||
|
}
|
||||||
output <- y
|
output <- y
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -495,7 +343,10 @@ func (m *LikwidCollector) calcEventsetMetrics(group int, interval time.Duration,
|
|||||||
// Go over the global metrics, derive the value out of the event sets' metric values and send it
|
// Go over the global metrics, derive the value out of the event sets' metric values and send it
|
||||||
func (m *LikwidCollector) calcGlobalMetrics(interval time.Duration, output chan lp.CCMetric) error {
|
func (m *LikwidCollector) calcGlobalMetrics(interval time.Duration, output chan lp.CCMetric) error {
|
||||||
for _, metric := range m.config.Metrics {
|
for _, metric := range m.config.Metrics {
|
||||||
scopemap := m.scopeRespTids[metric.Scope]
|
scopemap := m.cpu2tid
|
||||||
|
if metric.Type == "socket" {
|
||||||
|
scopemap = m.sock2tid
|
||||||
|
}
|
||||||
for domain, tid := range scopemap {
|
for domain, tid := range scopemap {
|
||||||
if tid >= 0 {
|
if tid >= 0 {
|
||||||
// Here we generate parameter list
|
// Here we generate parameter list
|
||||||
@ -521,13 +372,16 @@ func (m *LikwidCollector) calcGlobalMetrics(interval time.Duration, output chan
|
|||||||
// Now we have the result, send it with the proper tags
|
// Now we have the result, send it with the proper tags
|
||||||
if !math.IsNaN(value) {
|
if !math.IsNaN(value) {
|
||||||
if metric.Publish {
|
if metric.Publish {
|
||||||
tags := map[string]string{"type": metric.Scope.String()}
|
tags := map[string]string{"type": metric.Type}
|
||||||
if metric.Scope != "node" {
|
|
||||||
tags["type-id"] = fmt.Sprintf("%d", domain)
|
|
||||||
}
|
|
||||||
fields := map[string]interface{}{"value": value}
|
fields := map[string]interface{}{"value": value}
|
||||||
y, err := lp.New(metric.Name, tags, m.meta, fields, time.Now())
|
y, err := lp.New(metric.Name, tags, m.meta, fields, time.Now())
|
||||||
if err == nil {
|
if err == nil {
|
||||||
|
if metric.Type != "node" {
|
||||||
|
y.AddTag("type-id", fmt.Sprintf("%d", domain))
|
||||||
|
}
|
||||||
|
if len(metric.Unit) > 0 {
|
||||||
|
y.AddMeta("unit", metric.Unit)
|
||||||
|
}
|
||||||
output <- y
|
output <- y
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -4,14 +4,17 @@
|
|||||||
The `likwid` collector is probably the most complicated collector. The LIKWID library is included as static library with *direct* access mode. The *direct* access mode is suitable if the daemon is executed by a root user. The static library does not contain the performance groups, so all information needs to be provided in the configuration.
|
The `likwid` collector is probably the most complicated collector. The LIKWID library is included as static library with *direct* access mode. The *direct* access mode is suitable if the daemon is executed by a root user. The static library does not contain the performance groups, so all information needs to be provided in the configuration.
|
||||||
|
|
||||||
The `likwid` configuration consists of two parts, the "eventsets" and "globalmetrics":
|
The `likwid` configuration consists of two parts, the "eventsets" and "globalmetrics":
|
||||||
- An event set list itself has two parts, the "events" and a set of derivable "metrics". Each of the "events" is a counter:event pair in LIKWID's syntax. The "metrics" are a list of formulas to derive the metric value from the measurements of the "events". Each metric has a name, the formula, a scope and a publish flag. Counter names can be used like variables in the formulas, so `PMC0+PMC1` sums the measurements for the both events configured in the counters `PMC0` and `PMC1`. The scope tells the Collector whether it is a metric for each hardware thread (`cpu`) or each CPU socket (`socket`). The last one is the publishing flag. It tells the collector whether a metric should be sent to the router.
|
- An event set list itself has two parts, the "events" and a set of derivable "metrics". Each of the "events" is a counter:event pair in LIKWID's syntax. The "metrics" are a list of formulas to derive the metric value from the measurements of the "events". Each metric has a name, the formula, a scope and a publish flag. Counter names can be used like variables in the formulas, so `PMC0+PMC1` sums the measurements for the both events configured in the counters `PMC0` and `PMC1`. The scope tells the Collector whether it is a metric for each hardware thread (`cpu`) or each CPU socket (`socket`). You may specify a unit for the metric with `unit`. The last one is the publishing flag. It tells the collector whether a metric should be sent to the router.
|
||||||
- The global metrics are metrics which require data from all event set measurements to be derived. The inputs are the metrics in the event sets. Similar to the metrics in the event sets, the global metrics are defined by a name, a formula, a scope and a publish flag. See event set metrics for details. The only difference is that there is no access to the raw event measurements anymore but only to the metrics. So, the idea is to derive a metric in the "eventsets" section and reuse it in the "globalmetrics" part. If you need a metric only for deriving the global metrics, disable forwarding of the event set metrics. **Be aware** that the combination might be misleading because the "behavior" of a metric changes over time and the multiple measurements might count different computing phases.
|
- The global metrics are metrics which require data from all event set measurements to be derived. The inputs are the metrics in the event sets. Similar to the metrics in the event sets, the global metrics are defined by a name, a formula, a scope and a publish flag. See event set metrics for details. The only difference is that there is no access to the raw event measurements anymore but only to the metrics. So, the idea is to derive a metric in the "eventsets" section and reuse it in the "globalmetrics" part. If you need a metric only for deriving the global metrics, disable forwarding of the event set metrics (`publish=false`). **Be aware** that the combination might be misleading because the "behavior" of a metric changes over time and the multiple measurements might count different computing phases. Similar to the metrics in the eventset, you can specify a metric unit with the `unit` field.
|
||||||
|
|
||||||
Additional options:
|
Additional options:
|
||||||
- `access_mode` : Method to use for hardware performance monitoring (`direct` access as root user, `accessdaemon` for the daemon mode)
|
- `access_mode` : Method to use for hardware performance monitoring (`direct` access as root user, `accessdaemon` for the daemon mode)
|
||||||
- `accessdaemon_path`: Folder with the access daemon `likwid-accessD`, commonly `$LIKWID_INSTALL_LOC/sbin`
|
- `accessdaemon_path`: Folder with the access daemon `likwid-accessD`, commonly `$LIKWID_INSTALL_LOC/sbin`
|
||||||
- `force_overwrite`: Same as setting `LIKWID_FORCE=1`. In case counters are already in-use, LIKWID overwrites their configuration to do its measurements
|
- `force_overwrite`: Same as setting `LIKWID_FORCE=1`. In case counters are already in-use, LIKWID overwrites their configuration to do its measurements
|
||||||
- `invalid_to_zero`: In some cases, the calculations result in `NaN` or `Inf`. With this option, all `NaN` and `Inf` values are replaces with `0.0`.
|
- `invalid_to_zero`: In some cases, the calculations result in `NaN` or `Inf`. With this option, all `NaN` and `Inf` values are replaces with `0.0`.
|
||||||
|
- `access_mode`: Specify LIKWID access mode: `direct` for direct register access as root user or `accessdaemon`
|
||||||
|
- `accessdaemon_path`: Folder of the accessDaemon `likwid-accessD`
|
||||||
|
- `liblikwid_path`: Location of `liblikwid.so`
|
||||||
|
|
||||||
### Available metric scopes
|
### Available metric scopes
|
||||||
|
|
||||||
@ -54,7 +57,8 @@ $ scripts/likwid_perfgroup_to_cc_config.py ICX MEM_DP
|
|||||||
"calc": "time",
|
"calc": "time",
|
||||||
"name": "Runtime (RDTSC) [s]",
|
"name": "Runtime (RDTSC) [s]",
|
||||||
"publish": true,
|
"publish": true,
|
||||||
"scope": "hwthread"
|
"unit": "seconds"
|
||||||
|
"scope": "cpu"
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
"..." : "..."
|
"..." : "..."
|
||||||
@ -104,25 +108,28 @@ $ chwon $CCUSER /var/run/likwid.lock
|
|||||||
{
|
{
|
||||||
"name": "ipc",
|
"name": "ipc",
|
||||||
"calc": "PMC0/PMC1",
|
"calc": "PMC0/PMC1",
|
||||||
"scope": "cpu",
|
"type": "cpu",
|
||||||
"publish": true
|
"publish": true
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
"name": "flops_any",
|
"name": "flops_any",
|
||||||
"calc": "0.000001*PMC2/time",
|
"calc": "0.000001*PMC2/time",
|
||||||
"scope": "cpu",
|
"unit": "MFlops/s",
|
||||||
|
"type": "cpu",
|
||||||
"publish": true
|
"publish": true
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
"name": "clock_mhz",
|
"name": "clock",
|
||||||
"calc": "0.000001*(FIXC1/FIXC2)/inverseClock",
|
"calc": "0.000001*(FIXC1/FIXC2)/inverseClock",
|
||||||
"scope": "cpu",
|
"type": "cpu",
|
||||||
|
"unit": "MHz",
|
||||||
"publish": true
|
"publish": true
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
"name": "mem1",
|
"name": "mem1",
|
||||||
"calc": "0.000001*(DFC0+DFC1+DFC2+DFC3)*64.0/time",
|
"calc": "0.000001*(DFC0+DFC1+DFC2+DFC3)*64.0/time",
|
||||||
"scope": "socket",
|
"unit": "Mbyte/s",
|
||||||
|
"type": "socket",
|
||||||
"publish": false
|
"publish": false
|
||||||
}
|
}
|
||||||
]
|
]
|
||||||
@ -140,19 +147,22 @@ $ chwon $CCUSER /var/run/likwid.lock
|
|||||||
{
|
{
|
||||||
"name": "pwr_core",
|
"name": "pwr_core",
|
||||||
"calc": "PWR0/time",
|
"calc": "PWR0/time",
|
||||||
"scope": "socket",
|
"unit": "Watt"
|
||||||
|
"type": "socket",
|
||||||
"publish": true
|
"publish": true
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
"name": "pwr_pkg",
|
"name": "pwr_pkg",
|
||||||
"calc": "PWR1/time",
|
"calc": "PWR1/time",
|
||||||
"scope": "socket",
|
"type": "socket",
|
||||||
|
"unit": "Watt"
|
||||||
"publish": true
|
"publish": true
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
"name": "mem2",
|
"name": "mem2",
|
||||||
"calc": "0.000001*(DFC0+DFC1+DFC2+DFC3)*64.0/time",
|
"calc": "0.000001*(DFC0+DFC1+DFC2+DFC3)*64.0/time",
|
||||||
"scope": "socket",
|
"unit": "Mbyte/s",
|
||||||
|
"type": "socket",
|
||||||
"publish": false
|
"publish": false
|
||||||
}
|
}
|
||||||
]
|
]
|
||||||
@ -162,7 +172,8 @@ $ chwon $CCUSER /var/run/likwid.lock
|
|||||||
{
|
{
|
||||||
"name": "mem_bw",
|
"name": "mem_bw",
|
||||||
"calc": "mem1+mem2",
|
"calc": "mem1+mem2",
|
||||||
"scope": "socket",
|
"type": "socket",
|
||||||
|
"unit": "Mbyte/s",
|
||||||
"publish": true
|
"publish": true
|
||||||
}
|
}
|
||||||
]
|
]
|
||||||
@ -198,3 +209,4 @@ IPC PMC0/PMC1 -> {
|
|||||||
-> ]
|
-> ]
|
||||||
```
|
```
|
||||||
|
|
||||||
|
The script `scripts/likwid_perfgroup_to_cc_config.py` might help you.
|
Loading…
Reference in New Issue
Block a user