mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-25 04:33:26 +00:00
volumemanager: remove unneccesary closure
This commit is contained in:
parent
3cb73605aa
commit
f3922dff19
@ -129,13 +129,13 @@ func (dswp *desiredStateOfWorldPopulator) Run(sourcesReady config.SourcesReady,
|
|||||||
glog.Infof("Desired state populator starts to run")
|
glog.Infof("Desired state populator starts to run")
|
||||||
wait.PollUntil(dswp.loopSleepDuration, func() (bool, error) {
|
wait.PollUntil(dswp.loopSleepDuration, func() (bool, error) {
|
||||||
done := sourcesReady.AllReady()
|
done := sourcesReady.AllReady()
|
||||||
dswp.populatorLoopFunc()()
|
dswp.populatorLoop()
|
||||||
return done, nil
|
return done, nil
|
||||||
}, stopCh)
|
}, stopCh)
|
||||||
dswp.hasAddedPodsLock.Lock()
|
dswp.hasAddedPodsLock.Lock()
|
||||||
dswp.hasAddedPods = true
|
dswp.hasAddedPods = true
|
||||||
dswp.hasAddedPodsLock.Unlock()
|
dswp.hasAddedPodsLock.Unlock()
|
||||||
wait.Until(dswp.populatorLoopFunc(), dswp.loopSleepDuration, stopCh)
|
wait.Until(dswp.populatorLoop, dswp.loopSleepDuration, stopCh)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (dswp *desiredStateOfWorldPopulator) ReprocessPod(
|
func (dswp *desiredStateOfWorldPopulator) ReprocessPod(
|
||||||
@ -149,26 +149,24 @@ func (dswp *desiredStateOfWorldPopulator) HasAddedPods() bool {
|
|||||||
return dswp.hasAddedPods
|
return dswp.hasAddedPods
|
||||||
}
|
}
|
||||||
|
|
||||||
func (dswp *desiredStateOfWorldPopulator) populatorLoopFunc() func() {
|
func (dswp *desiredStateOfWorldPopulator) populatorLoop() {
|
||||||
return func() {
|
dswp.findAndAddNewPods()
|
||||||
dswp.findAndAddNewPods()
|
|
||||||
|
|
||||||
// findAndRemoveDeletedPods() calls out to the container runtime to
|
// findAndRemoveDeletedPods() calls out to the container runtime to
|
||||||
// determine if the containers for a given pod are terminated. This is
|
// determine if the containers for a given pod are terminated. This is
|
||||||
// an expensive operation, therefore we limit the rate that
|
// an expensive operation, therefore we limit the rate that
|
||||||
// findAndRemoveDeletedPods() is called independently of the main
|
// findAndRemoveDeletedPods() is called independently of the main
|
||||||
// populator loop.
|
// populator loop.
|
||||||
if time.Since(dswp.timeOfLastGetPodStatus) < dswp.getPodStatusRetryDuration {
|
if time.Since(dswp.timeOfLastGetPodStatus) < dswp.getPodStatusRetryDuration {
|
||||||
glog.V(5).Infof(
|
glog.V(5).Infof(
|
||||||
"Skipping findAndRemoveDeletedPods(). Not permitted until %v (getPodStatusRetryDuration %v).",
|
"Skipping findAndRemoveDeletedPods(). Not permitted until %v (getPodStatusRetryDuration %v).",
|
||||||
dswp.timeOfLastGetPodStatus.Add(dswp.getPodStatusRetryDuration),
|
dswp.timeOfLastGetPodStatus.Add(dswp.getPodStatusRetryDuration),
|
||||||
dswp.getPodStatusRetryDuration)
|
dswp.getPodStatusRetryDuration)
|
||||||
|
|
||||||
return
|
return
|
||||||
}
|
|
||||||
|
|
||||||
dswp.findAndRemoveDeletedPods()
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
dswp.findAndRemoveDeletedPods()
|
||||||
}
|
}
|
||||||
|
|
||||||
func (dswp *desiredStateOfWorldPopulator) isPodTerminated(pod *v1.Pod) bool {
|
func (dswp *desiredStateOfWorldPopulator) isPodTerminated(pod *v1.Pod) bool {
|
||||||
|
Loading…
Reference in New Issue
Block a user