Fix qos bug 24.12.23

Signed-off-by: dolibali <[email protected]>

pkg/daemon/controller_linux.go

@@ -528,12 +528,12 @@ func (c *Controller) getPolicyRouting(subnet *kubeovnv1.Subnet) ([]netlink.Rule,
 }
 
 func (c *Controller) handlePod(key string) error {
+	klog.V(3).Infof("v3 log start success")
 	namespace, name, err := cache.SplitMetaNamespaceKey(key)
 	if err != nil {
 		utilruntime.HandleError(fmt.Errorf("invalid resource key: %s", key))
 		return nil
 	}
-	klog.Infof("handle qos update for pod %s/%s", namespace, name)
 
 	pod, err := c.podsLister.Pods(namespace).Get(name)
 	if err != nil {
@@ -557,7 +557,7 @@ func (c *Controller) handlePod(key string) error {
 
 	// set default nic bandwidth
 	ifaceID := ovs.PodNameToPortName(podName, pod.Namespace, util.OvnProvider)
-	err = ovs.SetInterfaceBandwidth(podName, pod.Namespace, ifaceID, pod.Annotations[util.EgressRateAnnotation], pod.Annotations[util.IngressRateAnnotation])
+	err = ovs.SetInterfaceBandwidth(podName, pod.Namespace, ifaceID, pod.Annotations[util.IngressRateAnnotation], pod.Annotations[util.EgressRateAnnotation])
 	if err != nil {
 		klog.Error(err)
 		return err
@@ -574,6 +574,8 @@ func (c *Controller) handlePod(key string) error {
 		return err
 	}
 
+	klog.V(3).Infof("handle qos update for pod %s/%s", namespace, name)
+
 	// set multus-nic bandwidth
 	attachNets, err := nadutils.ParsePodNetworkAnnotation(pod)
 	if err != nil {

pkg/ovs/ovs-vsctl_linux.go

@@ -15,6 +15,8 @@ import (
 func SetInterfaceBandwidth(podName, podNamespace, iface, ingress, egress string) error {
 	ingressMPS, _ := strconv.Atoi(ingress)
 	ingressKPS := ingressMPS * 1000
+	ingressBurst := ingressKPS * 8 / 10
+
 	interfaceList, err := ovsFind("interface", "name", fmt.Sprintf("external-ids:iface-id=%s", iface))
 	if err != nil {
 		klog.Error(err)
@@ -33,35 +35,42 @@ func SetInterfaceBandwidth(podName, podNamespace, iface, ingress, egress string)
 		return err
 	}
 
+	egressMPS, _ := strconv.Atoi(egress)
+	egressBPS := egressMPS * 1000 * 1000
+
 	for _, ifName := range interfaceList {
 		// ingress_policing_rate is in Kbps
-		err := ovsSet("interface", ifName, fmt.Sprintf("ingress_policing_rate=%d", ingressKPS), fmt.Sprintf("ingress_policing_burst=%d", ingressKPS*8/10))
+		err := ovsSet("interface", ifName, fmt.Sprintf("ingress_policing_rate=%d", ingressKPS), fmt.Sprintf("ingress_policing_burst=%d", ingressBurst))
 		if err != nil {
 			klog.Error(err)
 			return err
-		}
-
-		egressMPS, _ := strconv.Atoi(egress)
-		egressBPS := egressMPS * 1000 * 1000
+		} else {
+            klog.V(3).Infof("Successfully set ingress policing rate to %d Kbps on interface %s", ingressKPS, ifName)
+        }
 
 		if egressBPS > 0 {
 			queueUID, err := SetHtbQosQueueRecord(podName, podNamespace, iface, egressBPS, queueIfaceUIDMap)
 			if err != nil {
 				klog.Error(err)
 				return err
-			}
+			} else {
+                klog.V(3).Infof("Successfully set HTB QoS queue record for interface %s with egress %d Bps", iface, egressBPS)
+            }
 
 			if err = SetQosQueueBinding(podName, podNamespace, ifName, iface, queueUID, qosIfaceUIDMap); err != nil {
 				klog.Error(err)
 				return err
-			}
+			} else {
+                klog.V(3).Infof("Successfully bound QoS queue for interface %s", ifName)
+            }
 		} else {
 			if qosUID, ok := qosIfaceUIDMap[iface]; ok {
 				qosType, err := ovsGet("qos", qosUID, "type", "")
 				if err != nil {
 					klog.Error(err)
 					return err
-				}
+				} 
+
 				if qosType != util.HtbQos {
 					continue
 				}
@@ -74,7 +83,9 @@ func SetInterfaceBandwidth(podName, podNamespace, iface, ingress, egress string)
 				if _, err := Exec("remove", "queue", queueID, "other_config", "max-rate"); err != nil {
 					klog.Error(err)
 					return fmt.Errorf("failed to remove rate limit for queue in pod %v/%v, %w", podNamespace, podName, err)
-				}
+				} else {
+                    klog.V(3).Infof("Successfully removed rate limit for queue ID %s in pod %v/%v", queueID, podNamespace, podName)
+                }
 			}
 		}