Skip to content

K
k3s
Commit c6a26112 authored by Yu-Ju Hong's avatar Yu-Ju Hong
Browse files
Options

e2e: fix error checking in kubelet stats

parent ae576441
Hide whitespace changes
Inline Side-by-side
Showing with 1 addition and 1 deletion
test/e2e/kubelet_stats.go
View file @ c6a26112
...@@ -501,11 +501,11 @@ func (r *resourceCollector) Stop() { ...@@ -501,11 +501,11 @@ func (r *resourceCollector) Stop() {
// the resource usage, and pushes it to the buffer. // the resource usage, and pushes it to the buffer.
func (r *resourceCollector) collectStats(oldStatsMap map[string]*stats.ContainerStats) { func (r *resourceCollector) collectStats(oldStatsMap map[string]*stats.ContainerStats) {
summary, err := getNodeStatsSummary(r.client, r.node) summary, err := getNodeStatsSummary(r.client, r.node)
cStatsMap := getSystemContainerStats(summary)
if err != nil { if err != nil {
Logf("Error getting node stats summary on %q, err: %v", r.node, err) Logf("Error getting node stats summary on %q, err: %v", r.node, err)
return return
} }
cStatsMap := getSystemContainerStats(summary)
r.lock.Lock() r.lock.Lock()
defer r.lock.Unlock() defer r.lock.Unlock()
for _, name := range r.containers { for _, name := range r.containers {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment