package proc
|
|
import (
|
"analysis/logo"
|
"analysis/util"
|
"context"
|
|
"github.com/spf13/viper"
|
)
|
|
func reaper(ctxt context.Context) {
|
pidChan := make(chan int, 1)
|
Reap(pidChan)
|
go waitForRestart(ctxt, pidChan)
|
}
|
|
// MasterRole master
|
func MasterRole(ctx context.Context) bool {
|
reaper(ctx)
|
|
util.InitDBAPI()
|
|
const (
|
configFilePath = "/opt/vasystem/config/"
|
configFileName = "sdkconfig"
|
configFileType = "yaml"
|
)
|
viper.SetConfigType(configFileType)
|
viper.SetConfigName(configFileName)
|
viper.AddConfigPath(configFilePath)
|
viper.AddConfigPath("./")
|
|
envString := ""
|
|
sdks := util.SDKInfo()
|
for k, v := range sdks {
|
|
if err := viper.ReadInConfig(); err == nil {
|
|
envString = viper.GetString(v.SdkType)
|
|
}
|
logo.Errorln("MASTER ANALYSIS START SLAVE TYPE: ", v.SdkType, " SDK CONFIG: ", envString)
|
|
args := []string{
|
`-role=slave`,
|
"-sdk=" + v.SdkType,
|
"-id=" + v.IpcId,
|
}
|
args = append(args, (*util.GetParams())...)
|
pid, err := runProc(ctx, "./analysis", args, &envString)
|
|
if err != nil {
|
logo.Errorf("ANALYSIS START SLAVE PROC %s IPC: %s error %+v\n", v.SdkType, v.IpcId, err)
|
}
|
logo.Infof("START %d PROC %d SDK %s ID %s\n", k, pid, v.IpcId, v.SdkType)
|
}
|
return true
|
}
|
