prometheus/cadvisor
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

upon discovering a subdirectory, add a creation event for it

Browse Source
This commit is contained in:
David Ashpole 2018-03-27 17:46:25 -07:00
parent 834edaddc4
commit 4e32e6ea97
1 changed files with 15 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
manager/watcher/raw/raw.go
View File

@ -71,7 +71,7 @@ func NewRawContainerWatcher() (watcher.ContainerWatcher, error) {
func (self *rawContainerWatcher) Start(events chan watcher.ContainerEvent) error { func (self *rawContainerWatcher) Start(events chan watcher.ContainerEvent) error {
// Watch this container (all its cgroups) and all subdirectories. // Watch this container (all its cgroups) and all subdirectories.
for _, cgroupPath := range self.cgroupPaths { for _, cgroupPath := range self.cgroupPaths {
_, err := self.watchDirectory(cgroupPath, "/") _, err := self.watchDirectory(events, cgroupPath, "/")
if err != nil { if err != nil {
return err return err
} }
@ -109,7 +109,7 @@ func (self *rawContainerWatcher) Stop() error {
// Watches the specified directory and all subdirectories. Returns whether the path was // Watches the specified directory and all subdirectories. Returns whether the path was
// already being watched and an error (if any). // already being watched and an error (if any).
func (self *rawContainerWatcher) watchDirectory(dir string, containerName string) (bool, error) { func (self *rawContainerWatcher) watchDirectory(events chan watcher.ContainerEvent, dir string, containerName string) (bool, error) {
alreadyWatching, err := self.watcher.AddWatch(containerName, dir) alreadyWatching, err := self.watcher.AddWatch(containerName, dir)
if err != nil { if err != nil {
return alreadyWatching, err return alreadyWatching, err
@ -135,7 +135,8 @@ func (self *rawContainerWatcher) watchDirectory(dir string, containerName string
for _, entry := range entries { for _, entry := range entries {
if entry.IsDir() { if entry.IsDir() {
entryPath := path.Join(dir, entry.Name()) entryPath := path.Join(dir, entry.Name())
_, err = self.watchDirectory(entryPath, path.Join(containerName, entry.Name())) subcontainerName := path.Join(containerName, entry.Name())
alreadyWatchingSubDir, err := self.watchDirectory(events, entryPath, subcontainerName)
if err != nil { if err != nil {
glog.Errorf("Failed to watch directory %q: %v", entryPath, err) glog.Errorf("Failed to watch directory %q: %v", entryPath, err)
if os.IsNotExist(err) { if os.IsNotExist(err) {
@ -145,6 +146,16 @@ func (self *rawContainerWatcher) watchDirectory(dir string, containerName string
} }
return alreadyWatching, err return alreadyWatching, err
} }
// since we already missed the creation event for this directory, publish an event here.
if !alreadyWatchingSubDir {
go func() {
events <- watcher.ContainerEvent{
EventType: watcher.ContainerAdd,
Name: subcontainerName,
WatchSource: watcher.Raw,
}
}()
}
} }
} }
@ -186,7 +197,7 @@ func (self *rawContainerWatcher) processEvent(event *inotify.Event, events chan
switch eventType { switch eventType {
case watcher.ContainerAdd: case watcher.ContainerAdd:
// New container was created, watch it. // New container was created, watch it.
alreadyWatched, err := self.watchDirectory(event.Name, containerName) alreadyWatched, err := self.watchDirectory(events, event.Name, containerName)
if err != nil { if err != nil {
return err return err
} }