update libgowrapper

zhangmeng

2019-12-23 ea5e8e0577d5c86c624e0f43bfc7f5874e8b719b

 app/master/master.go

@@ -5,7 +5,6 @@
   "analysis/logo"
   "analysis/util"
   "context"
   "io/ioutil"

   "basic.com/libgowrapper/sdkstruct.git"
)
@@ -17,36 +16,12 @@
}

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

   rPath := configPath
   configFile := configPath
   var fetcher *Fetcher

   fs, _ := ioutil.ReadDir(rPath)
   for _, file := range fs {
      if !file.IsDir() {
         if rPath[len(rPath)-1] != '/' {
            configFile = rPath + "/" + file.Name()
         } else {
            configFile = rPath + file.Name()
         }

         cfg, err := app.ReadConfig(configFile)
         if err != nil {
            logo.Errorln("Run Fetcher Master Read From File: ", configFile, " Config Error: ", err)
            continue
         }
         fetcher = NewFetcher(cfg.SoFile)
         if fetcher == nil {
            logo.Errorln("New Fetcher Load so File Funcs Error From File: ", cfg.SoFile)
            continue
         }
      }
   }
   fetcher := NewFetcher(soFile)
   if fetcher == nil {
      logo.Errorln("!!!!!!Read All So File, But Can't Init DB Fetcher")
      logo.Errorln("New Fetcher Load so File Funcs Error From File: ", soFile)
      return false
   }

@@ -85,7 +60,7 @@
      }

      args = append(args, app.GetParams(util.ConfigPath, file)...)
      pid, err := runProc(ctx, "./analysis", args, &cfg.Env)
      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)