zhangmeng
2019-12-17 c2ced9eaa6a8f174866ecbdb77d7ce7b02bb969c
proc/master.go
@@ -4,6 +4,8 @@
   "analysis/logo"
   "analysis/util"
   "context"
   "github.com/spf13/viper"
)
func reaper(ctxt context.Context) {
@@ -18,17 +20,35 @@
   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)
      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)