filter used qos when delete qos

kubeovn · Dec 23, 2021 · 0a48f6a · 0a48f6a
1 parent 26f239a
commit 0a48f6a
Showing 1 changed file with 20 additions and 2 deletions.
diff --git a/pkg/ovs/ovs-vsctl.go b/pkg/ovs/ovs-vsctl.go
@@ -111,8 +111,26 @@ func ClearPodBandwidth(podName, podNamespace string) error {
 	}
 	qosList = append(qosList, qosListByPod...)
 	qosList = util.UniqString(qosList)
-	for _, qos := range qosList {
-		if err := ovsDestroy("qos", qos); err != nil {
+
+	// https://github.com/kubeovn/kube-ovn/issues/1191
+	usedQosList, err := ovsFind("port", "qos", "qos!=[]")
+	if err != nil {
+		return err
+	}
+
+	for _, qosId := range qosList {
+		found := false
+		for _, usedQosId := range usedQosList {
+			if qosId == usedQosId {
+				found = true
+				break
+			}
+		}
+		if found {
+			continue
+		}
+
+		if err := ovsDestroy("qos", qosId); err != nil {
 			return err
 		}
 	}