feat: 增加所有插件都启动的接口

pluginmgr/plugin_proc.go

@@ -14,7 +14,10 @@ import (
 	"linkfog.com/public/lib/l"
 )
 
-var EnableValidatePluginMD5 = true
+var (
+	EnableValidatePluginMD5 = true
+	InitDur                 time.Duration
+)
 
 type pluginProcess struct {
 	conf *PluginProcessConf
@@ -128,6 +131,6 @@ func GetProcRSS(pid int) (rss uint64, err error) {
 }
 
 func pathExists(path string) bool {
-		_,err := os.Stat(path)
+	_, err := os.Stat(path)
 	return err == nil || os.IsExist(err)
 }

pluginmgr/plugin_proc_mgr.go

@@ -63,7 +63,7 @@ func (mgr *PluginProcessMgr) Stop() {
 
 func (mgr *PluginProcessMgr) run() {
 	mgr.detection()
-	ticker := time.NewTicker(10 * time.Second)
+	ticker := time.NewTicker(InitDur)
 	defer ticker.Stop()
 	defer close(mgr.doneResp)
 	for {
@@ -163,3 +163,13 @@ func (mgr *PluginProcessMgr) unregisterAllProcess() {
 		mgr.unregisterProcess(name, p)
 	}
 }
+
+func (mgr *PluginProcessMgr) AllPluginProcessIsRunning() bool {
+	for _, p := range mgr.pluginProcessMap {
+		if p.isExited() {
+			return false
+		}
+	}
+
+	return true
+}