added if condition with logic

Author: rejain789

npm/pkg/dataplane/dataplane_windows.go

@@ -61,21 +61,21 @@ func (dp *DataPlane) initializeDataPlane() error {
 
 	// Filter out any endpoints that are not in "AttachedShared" State. All running Windows pods with networking must be in this state.
 	filterMap := map[string]uint16{"State": hcnEndpointStateAttachedSharing}
-	filterMapL1VH := map[string]uint16{"State": hcnEndpointStateAttached}
-
 	filter, err := json.Marshal(filterMap)
 	if err != nil {
 		return errors.Wrap(err, "failed to marshal endpoint filter map")
 	}
+	dp.endpointQuery.query.Filter = string(filter)
 
-	filterL1VH, errL1VH := json.Marshal(filterMapL1VH)
-	if errL1VH != nil {
-		return errors.Wrap(errL1VH, "failed to marshal endpoint filter map")
+	if dp.EnableNPMLite {
+		filterMapL1VH := map[string]uint16{"State": hcnEndpointStateAttached}
+		filterL1VH, errL1VH := json.Marshal(filterMapL1VH)
+		if errL1VH != nil {
+			return errors.Wrap(errL1VH, "failed to marshal endpoint filter map")
+		}
+		dp.endpointQueryL1VH.query.Filter = string(filterL1VH)
 	}
 
-	dp.endpointQuery.query.Filter = string(filter)
-	dp.endpointQueryL1VH.query.Filter = string(filterL1VH)
-
 	// reset endpoint cache so that netpol references are removed for all endpoints while refreshing pod endpoints
 	// no need to lock endpointCache at boot up
 	dp.endpointCache.cache = make(map[string]*npmEndpoint)