update

zhangmeng

2019-12-24 75b938ecc540af937eeccd29327e5a97381e539d

update

 app/common.go

@@ -43,15 +43,11 @@
}

// GetParams params
func GetParams(rKey, rValue string) []string {
func GetParams() []string {
    var params []string

    for k, v := range util.MapParames {
        param := "-" + k + "=" + v
        if k == rKey {
            param = "-" + k + "=" + rValue
        }
        params = append(params, param)
        params = append(params, "-"+k+"="+v)
    }

    return params

 app/master/master.go

@@ -30,12 +30,17 @@
    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()

    if len(sdks) == 0 {
        logo.Errorln("!!!!!!Fetcher Can't Get SDK Infos From Remote DB")
        return false
    }
    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 +64,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 {