debug

zhangmeng

2020-01-15 ba1e2c442a3b71ccdf79f03c7404d706f5c44c04

 app/master/master.go

@@ -16,7 +16,7 @@
}

// Run run
func Run(ctx context.Context, configPath, soFile string) bool {
func Run(ctx context.Context, soFile, configPath string) bool {
   reaper(ctx)

   fetcher := NewFetcher(soFile)
@@ -27,15 +27,23 @@

   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)
   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 {

@@ -59,7 +67,7 @@
         "-" + util.ConfigPath + "=" + file,
      }

      args = append(args, app.GetParams(util.ConfigPath, file)...)
      args = append(args, params...)
      pid, err := runProc(ctx, "./analysis", args, cfg.Env)

      if err != nil {