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

topology-updater: log event type that triggered update

Browse source 
Specify the event type as part of the log message.
In order to reduce the log volume, make it V4

Signed-off-by: Talor Itzhak <titzhak@redhat.com>
This commit is contained in:
Talor Itzhak 2023-01-08 16:56:40 +02:00
parent 7b248ecae2
commit 1c12876815
1 changed files with 4 additions and 4 deletions

8
pkg/nfd-topology-updater/nfd-topology-updater.go
View file

@ -160,16 +160,16 @@ func (w *nfdTopologyUpdater) Run() error {
for { for {
select { select {
case <-w.eventSource: case info := <-w.eventSource:
klog.Infof("Scanning") klog.V(4).Infof("got %q event. scanning...", info.Event)
scanResponse, err := resScan.Scan() scanResponse, err := resScan.Scan()
utils.KlogDump(1, "podResources are", " ", scanResponse.PodResources) utils.KlogDump(1, "podResources are", " ", scanResponse.PodResources)
if err != nil { if err != nil {
klog.Warningf("Scan failed: %v", err) klog.Warningf("scan failed: %v", err)
continue continue
} }
zones = resAggr.Aggregate(scanResponse.PodResources) zones = resAggr.Aggregate(scanResponse.PodResources)
utils.KlogDump(1, "After aggregating resources identified zones are", " ", zones) utils.KlogDump(1, "after aggregating resources identified zones are", " ", zones)
if !w.args.NoPublish { if !w.args.NoPublish {
if err = w.updateNodeResourceTopology(zones, scanResponse); err != nil { if err = w.updateNodeResourceTopology(zones, scanResponse); err != nil {
return err return err