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-gc: rename runGC to garbageCollect()

Browse source 
One less function named run.
This commit is contained in:
Markus Lehtonen 2023-08-17 18:09:14 +03:00
parent fe0763eccb
commit ec51b29b3c
1 changed files with 5 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
pkg/nfd-topology-gc/nfd-nrt-gc.go
View file

@ -112,8 +112,9 @@ func (n *topologyGC) deleteNodeHandler(object interface{}) {
n.deleteNRT(node.GetName()) n.deleteNRT(node.GetName())
} }
func (n *topologyGC) runGC() { // garbageCollect removes all stale API objects
klog.InfoS("Running GC") func (n *topologyGC) garbageCollect() {
klog.InfoS("performing garbage collection")
objects := n.factory.Core().V1().Nodes().Informer().GetIndexer().List() objects := n.factory.Core().V1().Nodes().Informer().GetIndexer().List()
nodes := sets.NewString() nodes := sets.NewString()
for _, object := range objects { for _, object := range objects {
@ -150,7 +151,7 @@ func (n *topologyGC) periodicGC(gcPeriod time.Duration) {
for { for {
select { select {
case <-gcTrigger.C: case <-gcTrigger.C:
n.runGC() n.garbageCollect()
case <-n.stopChan: case <-n.stopChan:
klog.InfoS("shutting down periodic Garbage Collector") klog.InfoS("shutting down periodic Garbage Collector")
return return
@ -171,7 +172,7 @@ func (n *topologyGC) run() error {
n.factory.Start(n.stopChan) n.factory.Start(n.stopChan)
n.factory.WaitForCacheSync(n.stopChan) n.factory.WaitForCacheSync(n.stopChan)
n.runGC() n.garbageCollect()
return nil return nil
} }