github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-25 12:43:23 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #111439 from claudiubelu/fix-plugin-watcher

Browse Source 
kubelet: Fixes plugin Watcher for Windows
This commit is contained in:
Kubernetes Prow Robot 2022-07-29 19:29:44 -07:00 committed by GitHub
commit 25cdaccf0d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
pkg/kubelet/pluginmanager/pluginwatcher/plugin_watcher.go
View File

@ -131,12 +131,12 @@ func (w *Watcher) traversePluginDir(dir string) error {
return nil return nil
} }
switch mode := info.Mode(); { mode := info.Mode()
case mode.IsDir(): if mode.IsDir() {
if err := w.fsWatcher.Add(path); err != nil { if err := w.fsWatcher.Add(path); err != nil {
return fmt.Errorf("failed to watch %s, err: %v", path, err) return fmt.Errorf("failed to watch %s, err: %v", path, err)
} }
case mode&os.ModeSocket != 0: } else if isSocket, _ := util.IsUnixDomainSocket(path); isSocket {
event := fsnotify.Event{ event := fsnotify.Event{
Name: path, Name: path,
Op: fsnotify.Create, Op: fsnotify.Create,
@ -145,7 +145,7 @@ func (w *Watcher) traversePluginDir(dir string) error {
if err := w.handleCreateEvent(event); err != nil { if err := w.handleCreateEvent(event); err != nil {
klog.ErrorS(err, "Error when handling create", "event", event) klog.ErrorS(err, "Error when handling create", "event", event)
} }
default: } else {
klog.V(5).InfoS("Ignoring file", "path", path, "mode", mode) klog.V(5).InfoS("Ignoring file", "path", path, "mode", mode)
} }