koordlet: fix some fmt err

Signed-off-by: acejilam <acejilam@gmail.com>

pkg/descheduler/controllers/migration/evict.go

@@ -83,7 +83,7 @@ func CreatePodMigrationJob(ctx context.Context, pod *corev1.Pod, evictOptions fr
 
 	err := client.Create(ctx, job)
 	if err != nil {
-		klog.Errorf("Failed to create PodMigrationJob for Pod %s/s, err: %v", pod.Namespace, pod.Name, err)
+		klog.Errorf("Failed to create PodMigrationJob for Pod %s/%s, err: %v", pod.Namespace, pod.Name, err)
 		return err
 	}
 	return nil

pkg/koordlet/metricsadvisor/collectors/coldmemoryresource/cold_page_kidled.go

@@ -64,12 +64,12 @@ func (k *kidledcoldPageCollector) Enabled() bool {
 		kidledConfig := system.NewDefaultKidledConfig()
 		err := system.SetKidledScanPeriodInSeconds(kidledConfig.ScanPeriodInseconds)
 		if err != nil {
-			klog.V(4).Infof("cold page collector start kidled err:", err)
+			klog.V(4).Infof("cold page collector start kidled err: %v", err)
 			return false
 		}
 		err = system.SetKidledUseHierarchy(kidledConfig.UseHierarchy)
 		if err != nil {
-			klog.V(4).Infof("cold page collector start kidled err:", err)
+			klog.V(4).Infof("cold page collector start kidled err: %v", err)
 			return false
 		}
 		system.SetIsStartColdMemory(true)

pkg/koordlet/qosmanager/framework/pod_qos_control.go

@@ -61,7 +61,7 @@ func InjectQOSGreyCtrlPlugins(pod *corev1.Pod, policyType QOSPolicyType, policy
 			klog.Warningf("running qos grey control plugin %v for pod %v failed", name, util.GetPodKey(pod))
 		} else if pluginInjected {
 			klog.V(5).Infof("running qos grey control plugin %v for pod %v success, policy detail %v",
-				name, util.GetPodKey(pod))
+				name, util.GetPodKey(pod), policy)
 			injected = true
 		}
 	}

pkg/koordlet/qosmanager/plugins/cpuevict/cpu_evict.go

@@ -218,7 +218,7 @@ func (c *cpuEvictor) calculateMilliRelease(thresholdConfig *slov1alpha1.Resource
 	if milliRelease > 0 {
 		klog.V(4).Infof("cpuEvict by ResourceSatisfaction start to evict, milliRelease: %v,"+
 			"current status (BEUsage:%v, BERequest:%v, BELimit:%v, BERealLimit:%v, BEAllocatable:%v)",
-			currentBECPUMilliUsage, currentBECPUMilliRequest, currentBECPUMilliLimit, currentBECPUMilliRealLimit,
+			milliRelease, currentBECPUMilliUsage, currentBECPUMilliRequest, currentBECPUMilliLimit, currentBECPUMilliRealLimit,
 			beCPUMilliAllocatable)
 	}
 	return milliRelease
@@ -305,7 +305,7 @@ func (c *cpuEvictor) killAndEvictBEPodsRelease(node *corev1.Node, bePodInfos []*
 		killedPods = append(killedPods, bePod.pod)
 		cpuMilliReleased = cpuMilliReleased + bePod.milliRequest
 
-		klog.V(5).Infof("cpuEvict pick pod %s/%s to evict", util.GetPodKey(bePod.pod))
+		klog.V(5).Infof("cpuEvict pick pod %s to evict", util.GetPodKey(bePod.pod))
 	}
 
 	c.evictor.EvictPodsIfNotEvicted(killedPods, node, resourceexecutor.EvictPodByBECPUSatisfaction, message)

pkg/koordlet/qosmanager/plugins/cpusuppress/cpu_suppress.go

@@ -453,7 +453,7 @@ func (r *CPUSuppress) recoverCPUSetForBECPUManager() {
 		}
 		resourceStatus, err := apiext.GetResourceStatus(podMeta.Pod.Annotations)
 		if err != nil {
-			klog.Warningf("get resource status for pod %s failed, error %v", podMeta.Key())
+			klog.Warningf("get resource status for pod %s failed, error %v", podMeta.Key(), err.Error())
 			continue
 		}
 

pkg/koordlet/runtimehooks/hooks/coresched/helper.go

@@ -126,8 +126,7 @@ func (p *Plugin) addCookie(pids []uint32, groupID string) (uint64, []uint32, err
 // TODO: refactor to resource updater.
 func (p *Plugin) assignCookie(pids, siblingPIDs []uint32, groupID string, targetCookieID uint64) ([]uint32, []uint32, error) {
 	if len(pids) <= 0 {
-		klog.V(6).Infof("aborted to assign PIDs cookie for group %s, target cookie %v, no PID",
-			targetCookieID, groupID)
+		klog.V(6).Infof("aborted to assign PIDs cookie for group %v, target cookie %v, no PID", groupID, targetCookieID)
 		return nil, nil, nil
 	}
 	pidsToAssign := NewPIDCache()
@@ -225,7 +224,7 @@ func (p *Plugin) clearCookie(pids []uint32, groupID string, lastCookieID uint64)
 
 	failedPIDs, err := p.cse.Clear(sysutil.CoreSchedScopeThreadGroup, pidsToClear.GetAllSorted()...)
 	if err != nil {
-		klog.V(4).Infof("failed to clear cookie for group, last cookie %v, PID %v failed of %v, total %v, err: %s",
+		klog.V(4).Infof("failed to clear cookie for group %v, last cookie %v, PID %v failed of %v, total %v, err: %s",
 			groupID, lastCookieID, len(failedPIDs), pidsToClear.GetAllSorted(), len(pids), err)
 		pidsToClear.DeleteAny(failedPIDs...)
 	}

pkg/koordlet/runtimehooks/hooks/groupidentity/rule.go

@@ -212,7 +212,7 @@ func (b *bvtPlugin) ruleUpdateCb(target *statesinformer.CallbackTarget) error {
 		kubeQOSParentDir := koordletutil.GetPodQoSRelativePath(kubeQOS)
 		podCgroupDirs, err := koordletutil.GetCgroupPathsByTargetDepth(sysutil.CPUBVTWarpNsName, kubeQOSParentDir, koordletutil.PodCgroupPathRelativeDepth)
 		if err != nil {
-			klog.Infof("get pod cgroup paths failed, qos %s, err: %w", kubeQOS, err)
+			klog.Infof("get pod cgroup paths failed, qos %s, err: %v", kubeQOS, err.Error())
 			continue
 		}
 		for _, cgroupDir := range podCgroupDirs {

pkg/koordlet/runtimehooks/protocol/container_context.go

@@ -92,7 +92,7 @@ func (c *ContainerRequest) FromNri(pod *api.PodSandbox, container *api.Container
 
 	spec, err := apiext.GetExtendedResourceSpec(pod.GetAnnotations())
 	if err != nil {
-		klog.V(4).Infof("failed to get ExtendedResourceSpec from nri via annotation, container %s/%s, err: %s",
+		klog.V(4).Infof("failed to get ExtendedResourceSpec from nri via annotation, container %s/%s, name: %s, err: %s",
 			c.PodMeta.Namespace, c.PodMeta.Name, c.ContainerMeta.Name, err)
 	}
 	if spec != nil && spec.Containers != nil {
@@ -112,7 +112,7 @@ func (c *ContainerRequest) FromProxy(req *runtimeapi.ContainerResourceHookReques
 	// retrieve ExtendedResources from pod annotations
 	spec, err := apiext.GetExtendedResourceSpec(req.GetPodAnnotations())
 	if err != nil {
-		klog.V(4).Infof("failed to get ExtendedResourceSpec from proxy via annotation, container %s/%s, err: %s",
+		klog.V(4).Infof("failed to get ExtendedResourceSpec from proxy via annotation, container %s/%s, name: %s, err: %s",
 			c.PodMeta.Namespace, c.PodMeta.Name, c.ContainerMeta.Name, err)
 	}
 	if spec != nil && spec.Containers != nil {
@@ -166,7 +166,7 @@ func (c *ContainerRequest) FromReconciler(podMeta *statesinformer.PodMeta, conta
 	// retrieve ExtendedResources from container spec and pod annotations (prefer container spec)
 	specFromAnnotations, err := apiext.GetExtendedResourceSpec(podMeta.Pod.Annotations)
 	if err != nil {
-		klog.V(4).Infof("failed to get ExtendedResourceSpec from reconciler via annotation, container %s/%s, err: %s",
+		klog.V(4).Infof("failed to get ExtendedResourceSpec from reconciler via annotation, container %s/%s, name: %s, err: %s",
 			c.PodMeta.Namespace, c.PodMeta.Name, c.ContainerMeta.Name, err)
 	}
 	if specFromContainer != nil {

pkg/koordlet/runtimehooks/rule/rule.go

@@ -65,7 +65,7 @@ func (r *Rule) runUpdateCallbacks(target *statesinformer.CallbackTarget) {
 	for _, callbackFn := range r.callbacks {
 		if err := callbackFn(target); err != nil {
 			cbName := runtime.FuncForPC(reflect.ValueOf(callbackFn).Pointer()).Name()
-			klog.Warningf("executing %s callback function %s failed, error %v", r.name, cbName)
+			klog.Warningf("executing %s callback function %s failed, error %v", r.name, cbName, err.Error())
 		}
 	}
 }

pkg/koordlet/statesinformer/impl/callback_runner.go

@@ -117,7 +117,7 @@ func (s *callbackRunner) Start(stopCh <-chan struct{}) {
 				case cbCtx := <-s.callbackChans[cbType]:
 					cbObj := s.getObjByType(cbType, cbCtx)
 					if cbObj == nil {
-						klog.Warningf("callback runner with type %v is not exist")
+						klog.Warningf("callback runner with type %T is not exist", cbObj)
 					} else {
 						s.runCallbacks(cbType, cbObj)
 					}

pkg/koordlet/statesinformer/impl/states_pods.go

@@ -117,7 +117,7 @@ func (s *podsInformer) Start(stopCh <-chan struct{}) {
 	go s.syncKubeletLoop(s.config.KubeletSyncInterval, stopCh)
 	go func() {
 		if err := s.pleg.Run(stopCh); err != nil {
-			klog.Fatalf("Unable to run the pleg: ", err)
+			klog.Fatalf("Unable to run the pleg: %v", err.Error())
 		}
 	}()
 

pkg/koordlet/util/meminfo.go

@@ -176,7 +176,7 @@ func GetHugePagesInfo(nodeDir string) (map[uint64]*HugePagesInfo, error) {
 	hugepageDir := system.GetNUMAHugepagesDir(nodeDir)
 	hugeDirs, err := os.ReadDir(hugepageDir)
 	if err != nil {
-		klog.Warningf("failed to read hugepage dir %s, err: %w", hugepageDir, err)
+		klog.Warningf("failed to read hugepage dir %s, err: %v", hugepageDir, err)
 		return hugePagesInfo, err
 	}
 

pkg/koordlet/util/system/config.go

@@ -68,7 +68,7 @@ func InitSupportConfigs() {
 	initCgroupsVersion()
 	HostSystemInfo = collectVersionInfo()
 	if isResctrlSupported, err := IsSupportResctrl(); err != nil {
-		klog.Warningf("failed to check resctrl support status, use %d, err: %v", isResctrlSupported, err)
+		klog.Warningf("failed to check resctrl support status, use %v, err: %v", isResctrlSupported, err)
 	} else {
 		klog.V(4).Infof("resctrl supported: %v", isResctrlSupported)
 	}

pkg/util/httputil/reverseproxy.go

@@ -596,7 +596,7 @@ func (p *ReverseProxy) handleUpgradeResponse(rw http.ResponseWriter, req *http.R
 
 	conn, brw, err := hj.Hijack()
 	if err != nil {
-		p.getErrorHandler()(rw, req, fmt.Errorf("Hijack failed on protocol switch: %v", err))
+		p.getErrorHandler()(rw, req, fmt.Errorf("hijack failed on protocol switch: %v", err))
 		return
 	}
 	defer conn.Close()

pkg/util/metrics/expire_metric.go

@@ -253,7 +253,7 @@ func (e *metricGC) UpdateStatus(metricName string, labels prometheus.Labels) {
 	err := e.updateStatus(time.Now().Unix(), metricName, labels)
 	e.globalLock.RUnlock()
 	if err != nil {
-		klog.Errorf("failed to update status for metric %s, err: %s", metricName)
+		klog.Errorf("failed to update status for metric %s, err: %s", metricName, err.Error())
 	}
 }
 
@@ -271,7 +271,7 @@ func (e *metricGC) RemoveStatus(metricName string, labels prometheus.Labels) {
 	err := e.removeStatus(metricName, labels)
 	e.globalLock.RUnlock()
 	if err != nil {
-		klog.Errorf("failed to remove status for metric %s, err: %s", metricName)
+		klog.Errorf("failed to remove status for metric %s, err: %s", metricName, err.Error())
 	}
 }
 

pkg/webhook/api_debug_server.go

@@ -32,6 +32,6 @@ func RegisterDebugAPIProvider(name string, provider http.Handler) {
 func InstallDebugAPIHandler(server *webhook.Server) {
 	for name, provider := range debugAPIProviderMap {
 		server.Register(name, provider)
-		klog.Infof("Success register debug api handler, name:%v, tcpAddr:%v", name)
+		klog.Infof("Success register debug api handler, name:%v, tcpAddr:%s:%d", name, server.Host, server.Port)
 	}
 }

pkg/webhook/pod/mutating/extended_resource_spec.go

@@ -67,7 +67,7 @@ func (h *PodMutatingHandler) mutateByExtendedResources(pod *corev1.Pod) error {
 	}
 	if reflect.DeepEqual(extendedResourceSpec, spec) {
 		// if resource requirements not changed, just return
-		klog.V(6).Infof("extended resource spec of pod %s/%s unchanged, skip patch the annotation")
+		klog.V(6).Infof("extended resource spec of pod %s/%s unchanged, skip patch the annotation", pod.Namespace, pod.Name)
 		return nil
 	}