func()

in pkg/nitro_enclaves_device_monitor/monitor.go [63:85]


func (nepm *NitroEnclavesPluginMonitor) Init() error {
	glog.V(0).Infof("Creating plugin monitor for %v", nepm.devicePlugin.ResourceName())
	nepm.setState(PluginIdle)

	var err error

	if nepm.fsWatcher, err = fsnotify.NewWatcher(); err != nil {
		glog.Error("Error while creating file system watcher!")
		return err
	}

	if err = nepm.fsWatcher.Add(nepm.devicePluginPath); err != nil {
		glog.Errorf("Error while accessing: %s", pluginapi.DevicePluginPath)
		defer nepm.fsWatcher.Close()
		return err
	}

	nepm.sigWatcher = make(chan os.Signal, 1)
	signal.Notify(nepm.sigWatcher, syscall.SIGINT, syscall.SIGTERM, syscall.SIGQUIT)
	glog.V(0).Info("Plugin monitor has been successfully created.")

	return nil
}