From 9d9cd1d3b93613071d1dffc1c82c4515d2a65af6 Mon Sep 17 00:00:00 2001 From: zhangmeng <775834166@qq.com> Date: 星期二, 21 一月 2020 17:22:39 +0800 Subject: [PATCH] bug fixed change real fetcher ip --- app/master/daemon.go | 16 +++++++++------- 1 files changed, 9 insertions(+), 7 deletions(-) diff --git a/app/master/daemon.go b/app/master/daemon.go index 8e849b8..88bd840 100644 --- a/app/master/daemon.go +++ b/app/master/daemon.go @@ -237,11 +237,11 @@ removes := difference(w.info.Channels, proc.Channels) if len(removes) > 0 { // 閫氱煡瀛愯繘绋嬪叧闂�氶亾 - notice = Notice{ + n := Notice{ Op: opRemove, Content: removes, } - if d, err := json.Marshal(notice); err == nil { + if d, err := json.Marshal(n); err == nil { w.trans.chNotify <- d } } @@ -250,11 +250,11 @@ adds := difference(proc.Channels, w.info.Channels) if len(adds) > 0 { // 閫氱煡瀛愯繘绋嬫墦寮�閫氶亾 - notice = Notice{ + n := Notice{ Op: opAdd, Content: adds, } - if d, err := json.Marshal(notice); err == nil { + if d, err := json.Marshal(n); err == nil { w.trans.chNotify <- d } } @@ -373,8 +373,10 @@ if cmd == nil { logo.Errorf("ANALYSIS START SLAVE PROC %s IPC: %s Failed\n", typ, ipcID) + return } logo.Infof("START SDK %s ID %s PID %d Env: %s\n", typ, ipcID, cmd.Process.Pid, info.Env) + logo.Infoln(cmd.Args) ch := make(chan []byte, 3) cancel := fnNotify(ctx, ipcID, ch, logo.Infoln) @@ -407,9 +409,9 @@ os.Setenv(runtime, old) } - // //debug - // cmd.Stdout = os.Stdout - // cmd.Stderr = os.Stderr + //debug + cmd.Stdout = os.Stdout + cmd.Stderr = os.Stderr cmd.SysProcAttr = &syscall.SysProcAttr{Pdeathsig: syscall.SIGTERM} if err := cmd.Start(); err == nil { -- Gitblit v1.8.0