mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-23 19:56:01 +00:00
Merge pull request #24205 from yujuhong/fix_stats
e2e: fix error checking in kubelet stats
This commit is contained in:
commit
97acf8ca69
@ -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 {
|
||||||
|
Loading…
Reference in New Issue
Block a user