upstream/kubernetes
1
0
Fork 0
mirror of https://github.com/kubernetes/kubernetes.git synced 2026-06-10 17:35:44 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

kubelet: DRA: healthinfo: set logging prefix

Browse source
This commit is contained in:
Ed Bartosh 2026-01-26 17:13:59 +02:00
parent 7933d90815
commit acff01fe8b
1 changed files with 3 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
pkg/kubelet/cm/dra/healthinfo.go
View file

@ -42,6 +42,7 @@ type healthInfoCache struct {
// newHealthInfoCache creates a new cache, loading from a checkpoint if present.
func newHealthInfoCache(logger klog.Logger, stateFile string) (*healthInfoCache, error) {
logger = logger.WithName("dra-healthinfo")
cache := &healthInfoCache{
HealthInfo: &state.DevicesHealthMap{},
stateFile: stateFile,
@ -85,6 +86,7 @@ func (cache *healthInfoCache) withRLock(f func() error) error {
// saveToCheckpointInternal does the actual saving without locking.
// Assumes the caller holds the necessary lock.
func (cache *healthInfoCache) saveToCheckpointInternal(logger klog.Logger) error {
logger = logger.WithName("dra-healthinfo")
if cache.stateFile == "" {
return nil
}
@ -152,6 +154,7 @@ func (cache *healthInfoCache) getHealthInfo(driverName, poolName, deviceName str
// from a plugin. It identifies which devices have changed state and handles devices
// that are no longer being reported by the plugin.
func (cache *healthInfoCache) updateHealthInfo(logger klog.Logger, driverName string, devices []state.DeviceHealth) ([]state.DeviceHealth, error) {
logger = logger.WithName("dra-healthinfo")
changedDevices := []state.DeviceHealth{}
err := cache.withLock(func() error {
now := time.Now()