summaryrefslogtreecommitdiffstats
path: root/core/stats.go
diff options
context:
space:
mode:
authorVladimir Lavor <vlavor@cisco.com>2022-05-05 10:56:23 +0200
committerVladimir Lavor <vlavor@cisco.com>2022-05-05 11:28:52 +0200
commit874266e00029174d6ad512eeac678b0c99512cd7 (patch)
tree2dba41113b0be28e304051e840863522506e9f57 /core/stats.go
parent945b7c7ae69c414ef851f85596be4edeb1d9290e (diff)
support error counters also as normal counters
https://gerrit.fd.io/r/c/vpp/+/35640 Signed-off-by: Vladimir Lavor <vlavor@cisco.com> Change-Id: I91820bb15655e7b309af814c659eb9f5e7cd08a4
Diffstat (limited to 'core/stats.go')
-rw-r--r--core/stats.go23
1 files changed, 14 insertions, 9 deletions
diff --git a/core/stats.go b/core/stats.go
index 4033981..f05383d 100644
--- a/core/stats.go
+++ b/core/stats.go
@@ -40,8 +40,8 @@ const (
CounterStatsPrefix = "/err/"
MemoryStatSegPrefix = "/mem/statseg"
- MemoryStatPrefix = "/mem/stat"
- MemoryMainPrefix = "/mem/main"
+ MemoryStatSegment = "/mem/stat segment"
+ MemoryMainHeap = "/mem/main heap"
MemoryStats_Total = "total"
MemoryStats_Used = "used"
@@ -303,9 +303,6 @@ func (c *StatsConnection) GetErrorStats(errorStats *api.ErrorStats) (err error)
}
for i, stat := range c.errorStatsData.Entries {
- if stat.Type != adapter.ErrorIndex {
- continue
- }
if errStat, ok := stat.Data.(adapter.ErrorStat); ok {
values := make([]uint64, len(errStat))
for j, errStatW := range errStat {
@@ -313,8 +310,16 @@ func (c *StatsConnection) GetErrorStats(errorStats *api.ErrorStats) (err error)
}
errorStats.Errors[i].Values = values
}
+ if errStat, ok := stat.Data.(adapter.SimpleCounterStat); ok {
+ values := make([]uint64, len(errStat))
+ for j, errStatW := range errStat {
+ for _, val := range errStatW {
+ values[j] += uint64(val)
+ }
+ }
+ errorStats.Errors[i].Values = values
+ }
}
-
return nil
}
@@ -547,7 +552,7 @@ func (c *StatsConnection) GetBufferStats(bufStats *api.BufferStats) (err error)
}
func (c *StatsConnection) GetMemoryStats(memStats *api.MemoryStats) (err error) {
- if err := c.updateStats(&c.memStatsData, MemoryStatSegPrefix, MemoryStatPrefix, MemoryMainPrefix); err != nil {
+ if err := c.updateStats(&c.memStatsData, MemoryStatSegPrefix, MemoryStatSegment, MemoryMainHeap); err != nil {
return err
}
convertStats := func(stats []adapter.Counter) api.MemoryCounters {
@@ -573,7 +578,7 @@ func (c *StatsConnection) GetMemoryStats(memStats *api.MemoryStats) (err error)
case MemoryStats_Used:
memStats.Used = val
}
- } else if strings.Contains(string(stat.Name), MemoryStatPrefix) {
+ } else if string(stat.Name) == MemoryStatSegment {
if perHeapStats, ok := stat.Data.(adapter.SimpleCounterStat); ok {
if memStats.Stat == nil {
memStats.Stat = make(map[int]api.MemoryCounters)
@@ -582,7 +587,7 @@ func (c *StatsConnection) GetMemoryStats(memStats *api.MemoryStats) (err error)
memStats.Stat[heap] = convertStats(stats)
}
}
- } else if strings.Contains(string(stat.Name), MemoryMainPrefix) {
+ } else if string(stat.Name) == MemoryMainHeap {
if perHeapStats, ok := stat.Data.(adapter.SimpleCounterStat); ok {
if memStats.Main == nil {
memStats.Main = make(map[int]api.MemoryCounters)