remove redundant carriage return (cont'd)
This commit is contained in:
parent
bc93e7bcde
commit
caeb584230
@ -79,8 +79,7 @@ func (kl *Kubelet) newVolumeMounterFromPlugins(spec *volume.Spec, pod *v1.Pod, o
|
|||||||
|
|
||||||
// cleanupOrphanedPodDirs removes the volumes of pods that should not be
|
// cleanupOrphanedPodDirs removes the volumes of pods that should not be
|
||||||
// running and that have no containers running. Note that we roll up logs here since it runs in the main loop.
|
// running and that have no containers running. Note that we roll up logs here since it runs in the main loop.
|
||||||
func (kl *Kubelet) cleanupOrphanedPodDirs(
|
func (kl *Kubelet) cleanupOrphanedPodDirs(pods []*v1.Pod, runningPods []*kubecontainer.Pod) error {
|
||||||
pods []*v1.Pod, runningPods []*kubecontainer.Pod) error {
|
|
||||||
allPods := sets.NewString()
|
allPods := sets.NewString()
|
||||||
for _, pod := range pods {
|
for _, pod := range pods {
|
||||||
allPods.Insert(string(pod.UID))
|
allPods.Insert(string(pod.UID))
|
||||||
|
@ -298,8 +298,7 @@ func (r *hostPathDeleter) Delete() error {
|
|||||||
return os.RemoveAll(r.GetPath())
|
return os.RemoveAll(r.GetPath())
|
||||||
}
|
}
|
||||||
|
|
||||||
func getVolumeSource(
|
func getVolumeSource(spec *volume.Spec) (*v1.HostPathVolumeSource, bool, error) {
|
||||||
spec *volume.Spec) (*v1.HostPathVolumeSource, bool, error) {
|
|
||||||
if spec.Volume != nil && spec.Volume.HostPath != nil {
|
if spec.Volume != nil && spec.Volume.HostPath != nil {
|
||||||
return spec.Volume.HostPath, spec.ReadOnly, nil
|
return spec.Volume.HostPath, spec.ReadOnly, nil
|
||||||
} else if spec.PersistentVolume != nil &&
|
} else if spec.PersistentVolume != nil &&
|
||||||
|
Loading…
Reference in New Issue
Block a user