Capitalize all log messages for consistency

nmn3m · nmn3m · commit f1c473e7ed63 · 2025-10-09T18:33:35.000+03:00
Signed-off-by: Nour &lt;nurmn3m@gmail.com&gt;
diff --git a/cmd/compute-domain-controller/cleanup.go b/cmd/compute-domain-controller/cleanup.go
@@ -115,7 +115,7 @@ func (m *CleanupManager[T]) cleanup(ctx context.Context) {
 
 		computeDomain, err := m.getComputeDomain(uid)
 		if err != nil {
-			klog.Errorf("error getting ComputeDomain: %v", err)
+			klog.Errorf("Error getting ComputeDomain: %v", err)
 			continue
 		}
 
@@ -125,7 +125,7 @@ func (m *CleanupManager[T]) cleanup(ctx context.Context) {
 
 		klog.Infof("Cleanup: stale %T found for ComputeDomain '%s', running callback", *new(T), uid)
 		if err := m.callback(ctx, uid); err != nil {
-			klog.Errorf("error running CleanupManager callback: %v", err)
+			klog.Errorf("Error running CleanupManager callback: %v", err)
 			continue
 		}
 	}
diff --git a/cmd/compute-domain-controller/computedomain.go b/cmd/compute-domain-controller/computedomain.go
@@ -93,7 +93,7 @@ func (m *ComputeDomainManager) Start(ctx context.Context) (rerr error) {
 	defer func() {
 		if rerr != nil {
 			if err := m.Stop(); err != nil {
-				klog.Errorf("error stopping ComputeDomain manager: %v", err)
+				klog.Errorf("Error stopping ComputeDomain manager: %v", err)
 			}
 		}
 	}()
diff --git a/cmd/compute-domain-controller/daemonset.go b/cmd/compute-domain-controller/daemonset.go
@@ -112,7 +112,7 @@ func (m *DaemonSetManager) Start(ctx context.Context) (rerr error) {
 	defer func() {
 		if rerr != nil {
 			if err := m.Stop(); err != nil {
-				klog.Errorf("error stopping DaemonSet manager: %v", err)
+				klog.Errorf("Error stopping DaemonSet manager: %v", err)
 			}
 		}
 	}()
diff --git a/cmd/compute-domain-controller/daemonsetpods.go b/cmd/compute-domain-controller/daemonsetpods.go
@@ -103,7 +103,7 @@ func (m *DaemonSetPodManager) Start(ctx context.Context) (rerr error) {
 	defer func() {
 		if rerr != nil {
 			if err := m.Stop(); err != nil {
-				klog.Errorf("error stopping DaemonSetPod manager: %v", err)
+				klog.Errorf("Error stopping DaemonSetPod manager: %v", err)
 			}
 		}
 	}()
diff --git a/cmd/compute-domain-controller/node.go b/cmd/compute-domain-controller/node.go
@@ -75,7 +75,7 @@ func (m *NodeManager) Start(ctx context.Context) (rerr error) {
 	defer func() {
 		if rerr != nil {
 			if err := m.Stop(); err != nil {
-				klog.Errorf("error stopping Node manager: %v", err)
+				klog.Errorf("Error stopping Node manager: %v", err)
 			}
 		}
 	}()
diff --git a/cmd/compute-domain-controller/resourceclaimtemplate.go b/cmd/compute-domain-controller/resourceclaimtemplate.go
@@ -115,7 +115,7 @@ func (m *BaseResourceClaimTemplateManager) Start(ctx context.Context) (rerr erro
 	defer func() {
 		if rerr != nil {
 			if err := m.Stop(); err != nil {
-				klog.Errorf("error stopping ResourceClaimTemplate  manager: %v", err)
+				klog.Errorf("Error stopping ResourceClaimTemplate  manager: %v", err)
 			}
 		}
 	}()
diff --git a/cmd/compute-domain-daemon/computedomain.go b/cmd/compute-domain-daemon/computedomain.go
@@ -90,7 +90,7 @@ func (m *ComputeDomainManager) Start(ctx context.Context) (rerr error) {
 	defer func() {
 		if rerr != nil {
 			if err := m.Stop(); err != nil {
-				klog.Errorf("error stopping ComputeDomainManager: %v", err)
+				klog.Errorf("Error stopping ComputeDomainManager: %v", err)
 			}
 		}
 	}()
@@ -333,7 +333,7 @@ func (m *ComputeDomainManager) MaybePushNodesUpdate(cd *nvapi.ComputeDomain) {
 	// wait for all 'numNodes' nodes to show up before sending an update.
 	if !featuregates.Enabled(featuregates.IMEXDaemonsWithDNSNames) {
 		if len(cd.Status.Nodes) != cd.Spec.NumNodes {
-			klog.Infof("numNodes: %d, nodes seen: %d", cd.Spec.NumNodes, len(cd.Status.Nodes))
+			klog.Infof("NumNodes: %d, nodes seen: %d", cd.Spec.NumNodes, len(cd.Status.Nodes))
 			return
 		}
 	}
diff --git a/cmd/compute-domain-daemon/main.go b/cmd/compute-domain-daemon/main.go
@@ -205,7 +205,7 @@ func run(ctx context.Context, cancel context.CancelFunc, flags *Flags) error {
 		podNamespace:           flags.podNamespace,
 		maxNodesPerIMEXDomain:  flags.maxNodesPerIMEXDomain,
 	}
-	klog.Infof("config: %v", config)
+	klog.Infof("Config: %v", config)
 
 	// Write the IMEX config with the current pod IP before starting the daemon
 	if err := writeIMEXConfig(flags.podIP); err != nil {
@@ -241,7 +241,7 @@ func run(ctx context.Context, cancel context.CancelFunc, flags *Flags) error {
 	go func() {
 		defer wg.Done()
 		if err := controller.Run(ctx); err != nil {
-			klog.Errorf("controller failed, initiate shutdown: %s", err)
+			klog.Errorf("Controller failed, initiate shutdown: %s", err)
 			cancel()
 		}
 		klog.Infof("Terminated: controller task")
@@ -275,7 +275,7 @@ func run(ctx context.Context, cancel context.CancelFunc, flags *Flags) error {
 		// Watchdog restarts the IMEX daemon upon unexpected termination, and
 		// shuts it down gracefully upon our own shutdown.
 		if err := processManager.Watchdog(ctx); err != nil {
-			klog.Errorf("watch failed, initiate shutdown: %s", err)
+			klog.Errorf("Watch failed, initiate shutdown: %s", err)
 			cancel()
 		}
 		klog.Infof("Terminated: process manager")
@@ -292,10 +292,10 @@ func run(ctx context.Context, cancel context.CancelFunc, flags *Flags) error {
 // IMEX daemon nodes config file and (re)starting the IMEX daemon process.
 func IMEXDaemonUpdateLoopWithIPs(ctx context.Context, controller *Controller, cliqueID string, pm *ProcessManager) error {
 	for {
-		klog.Infof("wait for nodes update")
+		klog.Infof("Wait for nodes update")
 		select {
 		case <-ctx.Done():
-			klog.Infof("shutdown: stop IMEXDaemonUpdateLoopWithIPs")
+			klog.Infof("Shutdown: stop IMEXDaemonUpdateLoopWithIPs")
 			return nil
 		case nodes := <-controller.GetNodesUpdateChan():
 			if err := writeNodesConfig(cliqueID, nodes); err != nil {
@@ -320,10 +320,10 @@ func IMEXDaemonUpdateLoopWithIPs(ctx context.Context, controller *Controller, cl
 // unexpectedly and expectedly).
 func IMEXDaemonUpdateLoopWithDNSNames(ctx context.Context, controller *Controller, processManager *ProcessManager, dnsNameManager *DNSNameManager) error {
 	for {
-		klog.Infof("wait for nodes update")
+		klog.Infof("Wait for nodes update")
 		select {
 		case <-ctx.Done():
-			klog.Infof("shutdown: stop IMEXDaemonUpdateLoopWithDNSNames")
+			klog.Infof("Shutdown: stop IMEXDaemonUpdateLoopWithDNSNames")
 			return nil
 		case nodes := <-controller.GetNodesUpdateChan():
 			updated, err := dnsNameManager.UpdateDNSNameMappings(nodes)
@@ -349,13 +349,13 @@ func IMEXDaemonUpdateLoopWithDNSNames(ctx context.Context, controller *Controlle
 
 			// Actively ask the IMEX daemon to re-read its config and to
 			// re-connect to its peers (involving DNS name re-resolution).
-			klog.Infof("updated DNS/IP mapping, old process: send SIGUSR1")
+			klog.Infof("Updated DNS/IP mapping, old process: send SIGUSR1")
 			if err := processManager.Signal(syscall.SIGUSR1); err != nil {
 				// Only log (ignore this error for now: if the process went away
 				// unexpectedly, the process manager will handle that. If any
 				// other error resulted in bad signal delivery, we may get away
 				// with it).
-				klog.Errorf("failed to send SIGUSR1 to child process: %s", err)
+				klog.Errorf("Failed to send SIGUSR1 to child process: %s", err)
 			}
 		}
 	}
diff --git a/cmd/compute-domain-kubelet-plugin/cdi.go b/cmd/compute-domain-kubelet-plugin/cdi.go
@@ -146,7 +146,7 @@ func (cdi *CDIHandler) CreateStandardDeviceSpecFile(allocatable AllocatableDevic
 	}
 	defer func() {
 		if r := cdi.nvml.Shutdown(); r != nvml.SUCCESS {
-			klog.Warningf("failed to shutdown NVML: %v", r)
+			klog.Warningf("Failed to shutdown NVML: %v", r)
 		}
 	}()
 
diff --git a/cmd/compute-domain-kubelet-plugin/computedomain.go b/cmd/compute-domain-kubelet-plugin/computedomain.go
@@ -89,7 +89,7 @@ func (m *ComputeDomainManager) Start(ctx context.Context) (rerr error) {
 	defer func() {
 		if rerr != nil {
 			if err := m.Stop(); err != nil {
-				klog.Errorf("error stopping ComputeDomainManager: %v", err)
+				klog.Errorf("Error stopping ComputeDomainManager: %v", err)
 			}
 		}
 	}()
@@ -366,13 +366,13 @@ func (m *ComputeDomainManager) periodicCleanup(ctx context.Context) {
 				continue
 			}
 			if err != nil {
-				klog.Errorf("error checking for existence of directory '%s': %v", m.configFilesRoot, err)
+				klog.Errorf("Error checking for existence of directory '%s': %v", m.configFilesRoot, err)
 				continue
 			}
 
 			entries, err := os.ReadDir(m.configFilesRoot)
 			if err != nil {
-				klog.Errorf("error reading entries under directory '%s': %v", m.configFilesRoot, err)
+				klog.Errorf("Error reading entries under directory '%s': %v", m.configFilesRoot, err)
 				continue
 			}
 
@@ -387,7 +387,7 @@ func (m *ComputeDomainManager) periodicCleanup(ctx context.Context) {
 
 				computeDomain, err := m.GetComputeDomain(ctx, uid)
 				if err != nil {
-					klog.Errorf("error getting ComputeDomain: %v", err)
+					klog.Errorf("Error getting ComputeDomain: %v", err)
 					continue
 				}
 
@@ -399,7 +399,7 @@ func (m *ComputeDomainManager) periodicCleanup(ctx context.Context) {
 				klog.V(6).Infof("Stale directory found for ComputeDomain '%s', running cleanup", uid)
 
 				if err := os.RemoveAll(path); err != nil {
-					klog.Errorf("error removing artifacts directory for ComputeDomain '%s': %v", uid, err)
+					klog.Errorf("Error removing artifacts directory for ComputeDomain '%s': %v", uid, err)
 					continue
 				}
 			}
diff --git a/cmd/compute-domain-kubelet-plugin/device_state.go b/cmd/compute-domain-kubelet-plugin/device_state.go
@@ -77,7 +77,7 @@ func NewDeviceState(ctx context.Context, config *Config) (*DeviceState, error) {
 	}
 
 	devRoot := containerDriverRoot.getDevRoot()
-	klog.Infof("using devRoot=%v", devRoot)
+	klog.Infof("Using devRoot=%v", devRoot)
 
 	hostDriverRoot := config.flags.hostDriverRoot
 	cdi, err := NewCDIHandler(
@@ -155,7 +155,7 @@ func (s *DeviceState) Prepare(ctx context.Context, claim *resourceapi.ResourceCl
 		// Make this a noop. Associated device(s) has/ave been prepared by us.
 		// Prepare() must be idempotent, as it may be invoked more than once per
 		// claim (and actual device preparation must happen at most once).
-		klog.V(6).Infof("skip prepare: claim %v found in checkpoint", claimUID)
+		klog.V(6).Infof("Skip prepare: claim %v found in checkpoint", claimUID)
 		return preparedClaim.PreparedDevices.GetDevices(), nil
 	}
 
@@ -168,7 +168,7 @@ func (s *DeviceState) Prepare(ctx context.Context, claim *resourceapi.ResourceCl
 	if err != nil {
 		return nil, fmt.Errorf("unable to update checkpoint: %w", err)
 	}
-	klog.V(6).Infof("checkpoint updated for claim %v", claimUID)
+	klog.V(6).Infof("Checkpoint updated for claim %v", claimUID)
 
 	preparedDevices, err := s.prepareDevices(ctx, claim)
 	if err != nil {
@@ -189,7 +189,7 @@ func (s *DeviceState) Prepare(ctx context.Context, claim *resourceapi.ResourceCl
 	if err != nil {
 		return nil, fmt.Errorf("unable to update checkpoint: %w", err)
 	}
-	klog.V(6).Infof("checkpoint updated for claim %v", claimUID)
+	klog.V(6).Infof("Checkpoint updated for claim %v", claimUID)
 
 	return preparedDevices.GetDevices(), nil
 }
@@ -212,7 +212,7 @@ func (s *DeviceState) Unprepare(ctx context.Context, claimRef kubeletplugin.Name
 		// device was never prepared or has already been unprepared (assume that
 		// Prepare+Checkpoint are done transactionally). Note that
 		// claimRef.String() contains namespace, name, UID.
-		klog.Infof("unprepare noop: claim not found in checkpoint data: %v", claimRef.String())
+		klog.Infof("Unprepare noop: claim not found in checkpoint data: %v", claimRef.String())
 		return nil
 	}
 
diff --git a/cmd/compute-domain-kubelet-plugin/driver.go b/cmd/compute-domain-kubelet-plugin/driver.go
@@ -254,7 +254,7 @@ func (d *driver) nodePrepareResource(ctx context.Context, claim *resourceapi.Res
 		return false, res
 	}
 
-	klog.Infof("prepared devices for claim '%s/%s:%s': %v", claim.Namespace, claim.Name, claim.UID, devs)
+	klog.Infof("Prepared devices for claim '%s/%s:%s': %v", claim.Namespace, claim.Name, claim.UID, devs)
 	return true, kubeletplugin.PrepareResult{Devices: devs}
 }
 
@@ -269,7 +269,7 @@ func (d *driver) nodeUnprepareResource(ctx context.Context, claimRef kubeletplug
 		return isPermanentError(err), fmt.Errorf("error unpreparing devices for claim '%v': %w", claimRef.String(), err)
 	}
 
-	klog.Infof("unprepared devices for claim '%v'", claimRef.String())
+	klog.Infof("Unprepared devices for claim '%v'", claimRef.String())
 	return true, nil
 }
 
diff --git a/cmd/compute-domain-kubelet-plugin/health.go b/cmd/compute-domain-kubelet-plugin/health.go
@@ -64,7 +64,7 @@ func startHealthcheck(ctx context.Context, config *Config) (*healthcheck, error)
 		// are enabled and the filename includes a uid.
 		Path: path.Join(config.flags.kubeletRegistrarDirectoryPath, DriverName+"-reg.sock"),
 	}).String()
-	klog.V(6).Infof("connecting to registration socket path=%s", regSockPath)
+	klog.V(6).Infof("Connecting to registration socket path=%s", regSockPath)
 	regConn, err := grpc.NewClient(
 		regSockPath,
 		grpc.WithTransportCredentials(insecure.NewCredentials()),
@@ -77,7 +77,7 @@ func startHealthcheck(ctx context.Context, config *Config) (*healthcheck, error)
 		Scheme: "unix",
 		Path:   path.Join(config.DriverPluginPath(), "dra.sock"),
 	}).String()
-	klog.V(6).Infof("connecting to DRA socket path=%s", draSockPath)
+	klog.V(6).Infof("Connecting to DRA socket path=%s", draSockPath)
 	draConn, err := grpc.NewClient(
 		draSockPath,
 		grpc.WithTransportCredentials(insecure.NewCredentials()),
@@ -97,9 +97,9 @@ func startHealthcheck(ctx context.Context, config *Config) (*healthcheck, error)
 	healthcheck.wg.Add(1)
 	go func() {
 		defer healthcheck.wg.Done()
-		klog.Infof("starting healthcheck service at %s", lis.Addr().String())
+		klog.Infof("Starting healthcheck service at %s", lis.Addr().String())
 		if err := server.Serve(lis); err != nil {
-			klog.Errorf("failed to serve healthcheck service on %s: %v", addr, err)
+			klog.Errorf("Failed to serve healthcheck service on %s: %v", addr, err)
 		}
 	}()
 
diff --git a/cmd/compute-domain-kubelet-plugin/main.go b/cmd/compute-domain-kubelet-plugin/main.go
@@ -225,12 +225,12 @@ func RunPlugin(ctx context.Context, config *Config) error {
 	if err := ctx.Err(); err != nil && !errors.Is(err, context.Canceled) {
 		// A canceled context is the normal case here when the process receives
 		// a signal. Only log the error for more interesting cases.
-		klog.Errorf("error from context: %v", err)
+		klog.Errorf("Error from context: %v", err)
 	}
 
 	err = driver.Shutdown()
 	if err != nil {
-		klog.Errorf("unable to cleanly shutdown driver: %v", err)
+		klog.Errorf("Unable to cleanly shutdown driver: %v", err)
 	}
 
 	return nil
diff --git a/cmd/compute-domain-kubelet-plugin/nvlib.go b/cmd/compute-domain-kubelet-plugin/nvlib.go
@@ -122,7 +122,7 @@ func (l deviceLib) init() error {
 func (l deviceLib) alwaysShutdown() {
 	ret := l.nvmllib.Shutdown()
 	if ret != nvml.SUCCESS {
-		klog.Warningf("error shutting down NVML: %v", ret)
+		klog.Warningf("Error shutting down NVML: %v", ret)
 	}
 }
 
@@ -217,7 +217,7 @@ func (l deviceLib) getCliqueID() (string, error) {
 		}
 
 		if !isFabricAttached {
-			klog.Infof("no-clique fallback: fabric not attached (device %d/%s)", i, duid)
+			klog.Infof("No-clique fallback: fabric not attached (device %d/%s)", i, duid)
 			return nil
 		}
 
@@ -240,7 +240,7 @@ func (l deviceLib) getCliqueID() (string, error) {
 
 		uniqueClusterUUIDs[clusterUUID.String()] = struct{}{}
 		uniqueCliqueIDs[cliqueID] = struct{}{}
-		klog.Infof("identified fabric clique UUID/ID (device %d/%s): %s/%s", i, duid, clusterUUID.String(), cliqueID)
+		klog.Infof("Identified fabric clique UUID/ID (device %d/%s): %s/%s", i, duid, clusterUUID.String(), cliqueID)
 
 		return nil
 	})
diff --git a/cmd/gpu-kubelet-plugin/cdi.go b/cmd/gpu-kubelet-plugin/cdi.go
@@ -146,7 +146,7 @@ func (cdi *CDIHandler) CreateStandardDeviceSpecFile(allocatable AllocatableDevic
 	}
 	defer func() {
 		if r := cdi.nvml.Shutdown(); r != nvml.SUCCESS {
-			klog.Warningf("failed to shutdown NVML: %v", r)
+			klog.Warningf("Failed to shutdown NVML: %v", r)
 		}
 	}()
 
diff --git a/cmd/gpu-kubelet-plugin/device_state.go b/cmd/gpu-kubelet-plugin/device_state.go
@@ -68,7 +68,7 @@ func NewDeviceState(ctx context.Context, config *Config) (*DeviceState, error) {
 	}
 
 	devRoot := containerDriverRoot.getDevRoot()
-	klog.Infof("using devRoot=%v", devRoot)
+	klog.Infof("Using devRoot=%v", devRoot)
 
 	hostDriverRoot := config.flags.hostDriverRoot
 	cdi, err := NewCDIHandler(
@@ -152,14 +152,14 @@ func (s *DeviceState) Prepare(ctx context.Context, claim *resourceapi.ResourceCl
 	if err != nil {
 		return nil, fmt.Errorf("unable to update checkpoint: %w", err)
 	}
-	klog.V(6).Infof("checkpoint updated for claim %v", claimUID)
+	klog.V(6).Infof("Checkpoint updated for claim %v", claimUID)
 
 	preparedClaim, exists := checkpoint.V2.PreparedClaims[claimUID]
 	if exists && preparedClaim.CheckpointState == ClaimCheckpointStatePrepareCompleted {
 		// Make this a noop. Associated device(s) has/ave been prepared by us.
 		// Prepare() must be idempotent, as it may be invoked more than once per
 		// claim (and actual device preparation must happen at most once).
-		klog.V(6).Infof("skip prepare: claim %v found in checkpoint", claimUID)
+		klog.V(6).Infof("Skip prepare: claim %v found in checkpoint", claimUID)
 		return preparedClaim.PreparedDevices.GetDevices(), nil
 	}
 
@@ -182,7 +182,7 @@ func (s *DeviceState) Prepare(ctx context.Context, claim *resourceapi.ResourceCl
 	if err != nil {
 		return nil, fmt.Errorf("unable to update checkpoint: %w", err)
 	}
-	klog.V(6).Infof("checkpoint updated for claim %v", claimUID)
+	klog.V(6).Infof("Checkpoint updated for claim %v", claimUID)
 
 	return preparedDevices.GetDevices(), nil
 }
@@ -202,13 +202,13 @@ func (s *DeviceState) Unprepare(ctx context.Context, claimUID string) error {
 		// device was never prepared or has already been unprepared (assume that
 		// Prepare+Checkpoint are done transactionally). Note that
 		// claimRef.String() contains namespace, name, UID.
-		klog.Infof("unprepare noop: claim not found in checkpoint data: %v", claimUID)
+		klog.Infof("Unprepare noop: claim not found in checkpoint data: %v", claimUID)
 		return nil
 	}
 
 	switch pc.CheckpointState {
 	case ClaimCheckpointStatePrepareStarted:
-		klog.Infof("unprepare noop: claim preparation started but not completed: %v", claimUID)
+		klog.Infof("Unprepare noop: claim preparation started but not completed: %v", claimUID)
 		return nil
 	case ClaimCheckpointStatePrepareCompleted:
 		if err := s.unprepareDevices(ctx, claimUID, pc.PreparedDevices); err != nil {
diff --git a/cmd/gpu-kubelet-plugin/health.go b/cmd/gpu-kubelet-plugin/health.go
diff --git a/cmd/gpu-kubelet-plugin/main.go b/cmd/gpu-kubelet-plugin/main.go
diff --git a/cmd/gpu-kubelet-plugin/nvlib.go b/cmd/gpu-kubelet-plugin/nvlib.go
diff --git a/cmd/webhook/main.go b/cmd/webhook/main.go
diff --git a/pkg/workqueue/workqueue.go b/pkg/workqueue/workqueue.go

Original file line number	Diff line number	Diff line change
`@@ -115,7 +115,7 @@ func (m *CleanupManager[T]) cleanup(ctx context.Context) {`
`115`	`115`
`116`	`116`	`computeDomain, err := m.getComputeDomain(uid)`
`117`	`117`	`if err != nil {`
`118`		`- klog.Errorf("error getting ComputeDomain: %v", err)`
	`118`	`+ klog.Errorf("Error getting ComputeDomain: %v", err)`
`119`	`119`	`continue`
`120`	`120`	`}`
`121`	`121`
`@@ -125,7 +125,7 @@ func (m *CleanupManager[T]) cleanup(ctx context.Context) {`
`125`	`125`
`126`	`126`	`klog.Infof("Cleanup: stale %T found for ComputeDomain '%s', running callback", *new(T), uid)`
`127`	`127`	`if err := m.callback(ctx, uid); err != nil {`
`128`		`- klog.Errorf("error running CleanupManager callback: %v", err)`
	`128`	`+ klog.Errorf("Error running CleanupManager callback: %v", err)`
`129`	`129`	`continue`
`130`	`130`	`}`
`131`	`131`	`}`
Original file line number	Diff line number	Diff line change
`@@ -93,7 +93,7 @@ func (m *ComputeDomainManager) Start(ctx context.Context) (rerr error) {`
`93`	`93`	`defer func() {`
`94`	`94`	`if rerr != nil {`
`95`	`95`	`if err := m.Stop(); err != nil {`
`96`		`- klog.Errorf("error stopping ComputeDomain manager: %v", err)`
	`96`	`+ klog.Errorf("Error stopping ComputeDomain manager: %v", err)`
`97`	`97`	`}`
`98`	`98`	`}`
`99`	`99`	`}()`
Original file line number	Diff line number	Diff line change
`@@ -112,7 +112,7 @@ func (m *DaemonSetManager) Start(ctx context.Context) (rerr error) {`
`112`	`112`	`defer func() {`
`113`	`113`	`if rerr != nil {`
`114`	`114`	`if err := m.Stop(); err != nil {`
`115`		`- klog.Errorf("error stopping DaemonSet manager: %v", err)`
	`115`	`+ klog.Errorf("Error stopping DaemonSet manager: %v", err)`
`116`	`116`	`}`
`117`	`117`	`}`
`118`	`118`	`}()`
Original file line number	Diff line number	Diff line change
`@@ -103,7 +103,7 @@ func (m *DaemonSetPodManager) Start(ctx context.Context) (rerr error) {`
`103`	`103`	`defer func() {`
`104`	`104`	`if rerr != nil {`
`105`	`105`	`if err := m.Stop(); err != nil {`
`106`		`- klog.Errorf("error stopping DaemonSetPod manager: %v", err)`
	`106`	`+ klog.Errorf("Error stopping DaemonSetPod manager: %v", err)`
`107`	`107`	`}`
`108`	`108`	`}`
`109`	`109`	`}()`
Original file line number	Diff line number	Diff line change
`@@ -75,7 +75,7 @@ func (m *NodeManager) Start(ctx context.Context) (rerr error) {`
`75`	`75`	`defer func() {`
`76`	`76`	`if rerr != nil {`
`77`	`77`	`if err := m.Stop(); err != nil {`
`78`		`- klog.Errorf("error stopping Node manager: %v", err)`
	`78`	`+ klog.Errorf("Error stopping Node manager: %v", err)`
`79`	`79`	`}`
`80`	`80`	`}`
`81`	`81`	`}()`
Original file line number	Diff line number	Diff line change
`@@ -115,7 +115,7 @@ func (m *BaseResourceClaimTemplateManager) Start(ctx context.Context) (rerr erro`
`115`	`115`	`defer func() {`
`116`	`116`	`if rerr != nil {`
`117`	`117`	`if err := m.Stop(); err != nil {`
`118`		`- klog.Errorf("error stopping ResourceClaimTemplate manager: %v", err)`
	`118`	`+ klog.Errorf("Error stopping ResourceClaimTemplate manager: %v", err)`
`119`	`119`	`}`
`120`	`120`	`}`
`121`	`121`	`}()`
Original file line number	Diff line number	Diff line change
`@@ -90,7 +90,7 @@ func (m *ComputeDomainManager) Start(ctx context.Context) (rerr error) {`
`90`	`90`	`defer func() {`
`91`	`91`	`if rerr != nil {`
`92`	`92`	`if err := m.Stop(); err != nil {`
`93`		`- klog.Errorf("error stopping ComputeDomainManager: %v", err)`
	`93`	`+ klog.Errorf("Error stopping ComputeDomainManager: %v", err)`
`94`	`94`	`}`
`95`	`95`	`}`
`96`	`96`	`}()`
`@@ -333,7 +333,7 @@ func (m ComputeDomainManager) MaybePushNodesUpdate(cd nvapi.ComputeDomain) {`
`333`	`333`	`// wait for all 'numNodes' nodes to show up before sending an update.`
`334`	`334`	`if !featuregates.Enabled(featuregates.IMEXDaemonsWithDNSNames) {`
`335`	`335`	`if len(cd.Status.Nodes) != cd.Spec.NumNodes {`
`336`		`- klog.Infof("numNodes: %d, nodes seen: %d", cd.Spec.NumNodes, len(cd.Status.Nodes))`
	`336`	`+ klog.Infof("NumNodes: %d, nodes seen: %d", cd.Spec.NumNodes, len(cd.Status.Nodes))`
`337`	`337`	`return`
`338`	`338`	`}`
`339`	`339`	`}`
Original file line number	Diff line number	Diff line change
`@@ -146,7 +146,7 @@ func (cdi *CDIHandler) CreateStandardDeviceSpecFile(allocatable AllocatableDevic`
`146`	`146`	`}`
`147`	`147`	`defer func() {`
`148`	`148`	`if r := cdi.nvml.Shutdown(); r != nvml.SUCCESS {`
`149`		`- klog.Warningf("failed to shutdown NVML: %v", r)`
	`149`	`+ klog.Warningf("Failed to shutdown NVML: %v", r)`
`150`	`150`	`}`
`151`	`151`	`}()`
`152`	`152`
Original file line number	Diff line number	Diff line change
`@@ -89,7 +89,7 @@ func (m *ComputeDomainManager) Start(ctx context.Context) (rerr error) {`
`89`	`89`	`defer func() {`
`90`	`90`	`if rerr != nil {`
`91`	`91`	`if err := m.Stop(); err != nil {`
`92`		`- klog.Errorf("error stopping ComputeDomainManager: %v", err)`
	`92`	`+ klog.Errorf("Error stopping ComputeDomainManager: %v", err)`
`93`	`93`	`}`
`94`	`94`	`}`
`95`	`95`	`}()`
`@@ -366,13 +366,13 @@ func (m *ComputeDomainManager) periodicCleanup(ctx context.Context) {`
`366`	`366`	`continue`
`367`	`367`	`}`
`368`	`368`	`if err != nil {`
`369`		`- klog.Errorf("error checking for existence of directory '%s': %v", m.configFilesRoot, err)`
	`369`	`+ klog.Errorf("Error checking for existence of directory '%s': %v", m.configFilesRoot, err)`
`370`	`370`	`continue`
`371`	`371`	`}`
`372`	`372`
`373`	`373`	`entries, err := os.ReadDir(m.configFilesRoot)`
`374`	`374`	`if err != nil {`
`375`		`- klog.Errorf("error reading entries under directory '%s': %v", m.configFilesRoot, err)`
	`375`	`+ klog.Errorf("Error reading entries under directory '%s': %v", m.configFilesRoot, err)`
`376`	`376`	`continue`
`377`	`377`	`}`
`378`	`378`
`@@ -387,7 +387,7 @@ func (m *ComputeDomainManager) periodicCleanup(ctx context.Context) {`
`387`	`387`
`388`	`388`	`computeDomain, err := m.GetComputeDomain(ctx, uid)`
`389`	`389`	`if err != nil {`
`390`		`- klog.Errorf("error getting ComputeDomain: %v", err)`
	`390`	`+ klog.Errorf("Error getting ComputeDomain: %v", err)`
`391`	`391`	`continue`
`392`	`392`	`}`
`393`	`393`
`@@ -399,7 +399,7 @@ func (m *ComputeDomainManager) periodicCleanup(ctx context.Context) {`
`399`	`399`	`klog.V(6).Infof("Stale directory found for ComputeDomain '%s', running cleanup", uid)`
`400`	`400`
`401`	`401`	`if err := os.RemoveAll(path); err != nil {`
`402`		`- klog.Errorf("error removing artifacts directory for ComputeDomain '%s': %v", uid, err)`
	`402`	`+ klog.Errorf("Error removing artifacts directory for ComputeDomain '%s': %v", uid, err)`
`403`	`403`	`continue`
`404`	`404`	`}`
`405`	`405`	`}`