mirrors/node-feature-discovery
mirrors/node-feature-discovery
1
0
Fork 0
mirror of https://github.com/kubernetes-sigs/node-feature-discovery.git synced 2025-03-31 04:04:51 +00:00
Code Activity

Merge pull request #1191 from marquiz/devel/master-logging

Browse source 
nfd-master: log node name when processing NodeFeatureRules
This commit is contained in:
Kubernetes Prow Robot 2023-04-26 00:16:17 -07:00 • committed by GitHub
commit dbb06905e5
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
pkg/nfd-master/nfd-master.go
View file

@ -762,7 +762,7 @@ func (m *nfdMaster) refreshNodeFeatures(cli *kubernetes.Clientset, nodeName stri
labels = make(map[string]string) labels = make(map[string]string)
} }
crLabels, crExtendedResources, crTaints := m.processNodeFeatureRule(features) crLabels, crExtendedResources, crTaints := m.processNodeFeatureRule(nodeName, features)
// Mix in CR-originated labels // Mix in CR-originated labels
for k, v := range crLabels { for k, v := range crLabels {
@ -898,7 +898,7 @@ func authorizeClient(c context.Context, checkNodeName bool, nodeName string) err
return nil return nil
} }
func (m *nfdMaster) processNodeFeatureRule(features *nfdv1alpha1.Features) (Labels, ExtendedResources, []corev1.Taint) { func (m *nfdMaster) processNodeFeatureRule(nodeName string, features *nfdv1alpha1.Features) (Labels, ExtendedResources, []corev1.Taint) {
if m.nfdController == nil { if m.nfdController == nil {
return nil, nil, nil return nil, nil, nil
} }
@ -920,15 +920,15 @@ func (m *nfdMaster) processNodeFeatureRule(features *nfdv1alpha1.Features) (Labe
for _, spec := range ruleSpecs { for _, spec := range ruleSpecs {
switch { switch {
case klog.V(3).Enabled(): case klog.V(3).Enabled():
h := fmt.Sprintf("executing NodeFeatureRule %q:", spec.Name) h := fmt.Sprintf("executing NodeFeatureRule %q on node %q:", spec.Name, nodeName)
utils.KlogDump(3, h, " ", spec.Spec) utils.KlogDump(3, h, " ", spec.Spec)
case klog.V(1).Enabled(): case klog.V(1).Enabled():
klog.Infof("executing NodeFeatureRule %q", spec.Name) klog.Infof("executing NodeFeatureRule %q on node %q", spec.Name, nodeName)
} }
for _, rule := range spec.Spec.Rules { for _, rule := range spec.Spec.Rules {
ruleOut, err := rule.Execute(features) ruleOut, err := rule.Execute(features)
if err != nil { if err != nil {
klog.Errorf("failed to process Rule %q: %v", rule.Name, err) klog.Errorf("failed to process Rule %q on node %q: %v", rule.Name, nodeName, err)
continue continue
} }
taints = append(taints, ruleOut.Taints...) taints = append(taints, ruleOut.Taints...)