From ba1e2c442a3b71ccdf79f03c7404d706f5c44c04 Mon Sep 17 00:00:00 2001
From: zhangmeng <775834166@qq.com>
Date: 星期三, 15 一月 2020 14:28:13 +0800
Subject: [PATCH] debug
---
app/master/master.go | 20 ++++++++++++++------
1 files changed, 14 insertions(+), 6 deletions(-)
diff --git a/app/master/master.go b/app/master/master.go
index fa83f15..c4107e9 100644
--- a/app/master/master.go
+++ b/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,8 +67,8 @@
"-" + util.ConfigPath + "=" + file,
}
- args = append(args, app.GetParams(util.ConfigPath, file)...)
- pid, err := runProc(ctx, "./analysis", args, &cfg.Env)
+ args = append(args, params...)
+ 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)
--
Gitblit v1.8.0