提交 6d42824c 编写于 作者: 7 710leo

refactor: change plugin workdir

上级 360aa94f
......@@ -32,6 +32,7 @@ func ListPlugins(dir string) map[string]*Plugin {
filename := f.Name()
arr := strings.Split(filename, "_")
if len(arr) < 2 {
logger.Warningf("plugin:%s name illegal, should be: $cycle_$xx", filename)
continue
}
......@@ -39,10 +40,16 @@ func ListPlugins(dir string) map[string]*Plugin {
var cycle int
cycle, err = strconv.Atoi(arr[0])
if err != nil {
logger.Warningf("plugin:%s name illegal, should be: $cycle_$xx %v", filename, err)
continue
}
fpath, err := filepath.Abs(filepath.Join(dir, filename))
if err != nil {
logger.Warningf("plugin:%s absolute path get err:%v", filename, err)
continue
}
fpath := filepath.Join(dir, filename)
plugin := &Plugin{FilePath: fpath, MTime: f.ModTime().Unix(), Cycle: cycle}
ret[fpath] = plugin
}
......
......@@ -50,8 +50,7 @@ func PluginRun(plugin *Plugin) {
timeout := plugin.Cycle*1000 - 500 //比运行周期少500毫秒
fpath := filepath.Join(file.SelfDir(), plugin.FilePath)
fpath := plugin.FilePath
if !file.IsExist(fpath) {
logger.Error("no such plugin:", fpath)
return
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册