package master
|
|
import (
|
"analysis/app"
|
"analysis/logo"
|
"analysis/util"
|
"context"
|
"strings"
|
|
"basic.com/libgowrapper/sdkstruct.git"
|
)
|
|
func reaper(ctxt context.Context) {
|
pidChan := make(chan int, 1)
|
Reap(pidChan)
|
go waitForRestart(ctxt, pidChan)
|
}
|
|
// Run run
|
func Run(ctx context.Context, soFile, configPath string) bool {
|
reaper(ctx)
|
|
fetcher := NewFetcher(soFile)
|
if fetcher == nil {
|
logo.Errorln("New Fetcher Load so File Funcs Error From File: ", soFile)
|
return false
|
}
|
|
logo.Infoln("~~~~~~Created Fetcher, Now Sync From DB")
|
|
fetcher.fnInitDBAPI(util.FSI.IP, util.FSI.HTTPort, util.FSI.HBPort, util.FSI.DataPort, logo.Infoln)
|
// fetcher.fnInitDBAPI("192.168.20.10", util.FSI.HTTPort, util.FSI.HBPort, util.FSI.DataPort, logo.Infoln)
|
sdks := fetcher.fnSDKInfo()
|
for {
|
if len(sdks) == 0 {
|
logo.Errorln("!!!!!!Fetcher Can't Get SDK Infos From Remote DB")
|
continue
|
}
|
break
|
}
|
return manualStart(ctx, sdks, configPath)
|
}
|
|
func manualStart(ctx context.Context, sdks []sdkstruct.SDKInfo, configPath string) bool {
|
rPath := configPath
|
|
params := app.GetParams()
|
|
for _, v := range sdks {
|
|
file := rPath + v.SdkType + ".json"
|
if rPath[len(rPath)-1] != '/' {
|
file = rPath + "/" + v.SdkType + ".json"
|
}
|
|
cfg, err := app.ReadConfig(file)
|
if err != nil {
|
logo.Errorln("Master Read: ", file, " Config Error: ", err)
|
continue
|
}
|
|
if len(cfg.Env) > 0 {
|
envs := strings.Split(cfg.Env, ":")
|
normal := true
|
for _, v := range envs {
|
if !util.IsFileExist(v) {
|
normal = false
|
break
|
}
|
}
|
if !normal {
|
logo.Infoln("Can't Find Runtime Path, Skip It: ", file)
|
continue
|
}
|
}
|
|
logo.Infoln(file, " CONFIG: ", cfg)
|
|
args := []string{
|
`-role=slave`,
|
"-sdk=" + v.SdkType,
|
"-id=" + v.IpcID,
|
"-" + util.ConfigPath + "=" + file,
|
}
|
|
args = append(args, params...)
|
pid, err := runProc(ctx, "./analysis", args, cfg.Env)
|
|
if err != nil {
|
logo.Errorf("ANALYSIS START SLAVE PROC %s IPC: %s error %+v\n", v.SdkType, v.IpcID, err)
|
}
|
logo.Infof("START SDK %s ID %s PID %d Env: %s\n", v.SdkType, v.IpcID, pid, cfg.Env)
|
}
|
return true
|
|
}
|
