Revert "test"

This reverts commit 449c2af.

Author: rayaisaiah

npm/pkg/dataplane/dataplane_linux_test.go

@@ -94,6 +94,8 @@ func TestNetPolInBackgroundUpdatePolicy(t *testing.T) {
 }
 
 func TestNetPolInBackgroundSkipAddAfterRemove(t *testing.T) {
+	// Sleep for a bit to let IncNumACLRulesBy be resolved to avoid race condition
+	time.Sleep(100 * time.Millisecond)
 	metrics.ReinitializeAll()
 
 	calls := getBootupTestCalls()

npm/pkg/dataplane/types.go

@@ -144,7 +144,8 @@ func (c *updatePodCache) enqueue(m *PodMetadata) *updateNPMPod {
 	}
 
 	if !ok {
-		klog.Infof("[DataPlane] pod key %s not found in updatePodCache. creating a new obj", m.PodKey)
+		// TODO: Refactor non-error/warning klogs with Zap and set the following logs to "debug" level
+		// klog.Infof("[DataPlane] pod key %s not found in updatePodCache. creating a new obj", m.PodKey)
 
 		pod = newUpdateNPMPod(m)
 		c.cache[m.PodKey] = pod
@@ -157,7 +158,8 @@ func (c *updatePodCache) enqueue(m *PodMetadata) *updateNPMPod {
 // dequeue returns the first pod in the queue and removes it from the queue.
 func (c *updatePodCache) dequeue() *updateNPMPod {
 	if c.isEmpty() {
-		klog.Infof("[DataPlane] updatePodCache is empty. returning nil for dequeue()")
+		// TODO: Refactor non-error/warning klogs with Zap and set the following logs to "debug" level
+		// klog.Infof("[DataPlane] updatePodCache is empty. returning nil for dequeue()")
 		return nil
 	}
 
@@ -177,7 +179,8 @@ func (c *updatePodCache) dequeue() *updateNPMPod {
 func (c *updatePodCache) requeue(pod *updateNPMPod) {
 	if _, ok := c.cache[pod.PodKey]; ok {
 		// should not happen
-		klog.Infof("[DataPlane] pod key %s already exists in updatePodCache. skipping requeue", pod.PodKey)
+		// TODO: Refactor non-error/warning klogs with Zap and set the following logs to "debug" level
+		// klog.Infof("[DataPlane] pod key %s already exists in updatePodCache. skipping requeue", pod.PodKey)
 		return
 	}
 
@@ -208,11 +211,12 @@ func (q *netPolQueue) len() int {
 
 // enqueue adds a NetPol to the queue. If the NetPol already exists in the queue, the NetPol object is updated.
 func (q *netPolQueue) enqueue(policy *policies.NPMNetworkPolicy) {
-	if _, ok := q.toAdd[policy.PolicyKey]; ok {
-		klog.Infof("[DataPlane] policy %s exists in netPolQueue. updating", policy.PolicyKey)
-	} else {
-		klog.Infof("[DataPlane] enqueuing policy %s in netPolQueue", policy.PolicyKey)
-	}
+	// TODO: Refactor non-error/warning klogs with Zap and set the following logs to "debug" level
+	// if _, ok := q.toAdd[policy.PolicyKey]; ok {
+	// 	klog.Infof("[DataPlane] policy %s exists in netPolQueue. updating", policy.PolicyKey)
+	// } else {
+	// 	klog.Infof("[DataPlane] enqueuing policy %s in netPolQueue", policy.PolicyKey)
+	// }
 	q.toAdd[policy.PolicyKey] = policy
 }