topology-aware: reconfigure implicit affinities.

Fix the handling of implicit affinities corresponding to the
colocate{Pods,Namespaces} configuration settings. Unregister
and reregister disabled and enabled implicit affinities as
necessary when we receive a new configuration.

Signed-off-by: Krisztian Litkey <[email protected]>

cmd/plugins/topology-aware/policy/affinity.go

@@ -119,17 +119,28 @@ func (p *policy) registerImplicitAffinities() error {
 		},
 	}
 
-	enabled := map[string]cache.ImplicitAffinity{}
+	var (
+		enabled  = map[string]cache.ImplicitAffinity{}
+		disabled = []string{}
+	)
 	for _, a := range affinities {
 		if a.disabled {
 			log.Info("implicit affinity %s is disabled", a.name)
+			disabled = append(disabled, PolicyName+":"+a.name)
 			continue
 		}
+		log.Info("implicit affinity %s is enabled", a.name)
 		enabled[PolicyName+":"+a.name] = a.affinity
 	}
 
-	if err := p.cache.AddImplicitAffinities(enabled); err != nil {
-		return policyError("failed to register implicit affinities: %v", err)
+	if len(enabled) > 0 {
+		if err := p.cache.AddImplicitAffinities(enabled); err != nil {
+			return policyError("failed to register implicit affinities: %v", err)
+		}
+	}
+
+	if len(disabled) > 0 {
+		p.cache.DeleteImplicitAffinities(disabled)
 	}
 
 	return nil

cmd/plugins/topology-aware/policy/topology-aware-policy.go

@@ -484,6 +484,8 @@ func (p *policy) Reconfigure(newCfg interface{}) error {
 		return policyError("failed to reconfigure: %v", err)
 	}
 
+	p.registerImplicitAffinities()
+
 	for _, grant := range allocations.grants {
 		if err := grant.RefetchNodes(); err != nil {
 			*p = savedPolicy