mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-24 20:24:09 +00:00
Fix comments and typo in the error message.
This commit is contained in:
parent
cb712e41d4
commit
ae147a737c
@ -940,7 +940,7 @@ func (kl *Kubelet) podKiller() {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// checkHostPortConflicts detects pods with conflicted host ports.
|
// hasHostPortConflicts detects pods with conflicted host ports.
|
||||||
func hasHostPortConflicts(pods []*v1.Pod) bool {
|
func hasHostPortConflicts(pods []*v1.Pod) bool {
|
||||||
ports := sets.String{}
|
ports := sets.String{}
|
||||||
for _, pod := range pods {
|
for _, pod := range pods {
|
||||||
@ -1653,7 +1653,7 @@ func (kl *Kubelet) hasHostMountPVC(pod *v1.Pod) bool {
|
|||||||
if pvc != nil {
|
if pvc != nil {
|
||||||
referencedVolume, err := kl.kubeClient.Core().PersistentVolumes().Get(pvc.Spec.VolumeName, metav1.GetOptions{})
|
referencedVolume, err := kl.kubeClient.Core().PersistentVolumes().Get(pvc.Spec.VolumeName, metav1.GetOptions{})
|
||||||
if err != nil {
|
if err != nil {
|
||||||
glog.Warningf("unable to retrieve pvc %s - %v", pvc.Spec.VolumeName, err)
|
glog.Warningf("unable to retrieve pv %s - %v", pvc.Spec.VolumeName, err)
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
if referencedVolume != nil && referencedVolume.Spec.HostPath != nil {
|
if referencedVolume != nil && referencedVolume.Spec.HostPath != nil {
|
||||||
|
@ -88,7 +88,7 @@ func allowHostNetwork(pod *v1.Pod) (bool, error) {
|
|||||||
return false, nil
|
return false, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// Determined whether the specified pod is allowed to use host networking
|
// Determined whether the specified pod is allowed to use host PID
|
||||||
func allowHostPID(pod *v1.Pod) (bool, error) {
|
func allowHostPID(pod *v1.Pod) (bool, error) {
|
||||||
podSource, err := kubetypes.GetPodSource(pod)
|
podSource, err := kubetypes.GetPodSource(pod)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
@ -234,8 +234,7 @@ func (ed *emptyDir) SetUpAt(dir string, fsGroup *int64) error {
|
|||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
// setupTmpfs creates a tmpfs mount at the specified directory with the
|
// setupTmpfs creates a tmpfs mount at the specified directory.
|
||||||
// specified SELinux context.
|
|
||||||
func (ed *emptyDir) setupTmpfs(dir string) error {
|
func (ed *emptyDir) setupTmpfs(dir string) error {
|
||||||
if ed.mounter == nil {
|
if ed.mounter == nil {
|
||||||
return fmt.Errorf("memory storage requested, but mounter is nil")
|
return fmt.Errorf("memory storage requested, but mounter is nil")
|
||||||
@ -258,8 +257,7 @@ func (ed *emptyDir) setupTmpfs(dir string) error {
|
|||||||
return ed.mounter.Mount("tmpfs", dir, "tmpfs", nil /* options */)
|
return ed.mounter.Mount("tmpfs", dir, "tmpfs", nil /* options */)
|
||||||
}
|
}
|
||||||
|
|
||||||
// setupDir creates the directory with the specified SELinux context and
|
// setupDir creates the directory with the default permissions specified by the perm constant.
|
||||||
// the default permissions specified by the perm constant.
|
|
||||||
func (ed *emptyDir) setupDir(dir string) error {
|
func (ed *emptyDir) setupDir(dir string) error {
|
||||||
// Create the directory if it doesn't already exist.
|
// Create the directory if it doesn't already exist.
|
||||||
if err := os.MkdirAll(dir, perm); err != nil {
|
if err := os.MkdirAll(dir, perm); err != nil {
|
||||||
|
Loading…
Reference in New Issue
Block a user