From 3f19ab3c8cb8b5d0ee4aed32eb58e92519b22f3e Mon Sep 17 00:00:00 2001 From: zhangmeng <775834166@qq.com> Date: 星期二, 24 十二月 2019 09:18:01 +0800 Subject: [PATCH] update --- main.go | 33 +++++++++++---------------------- 1 files changed, 11 insertions(+), 22 deletions(-) diff --git a/main.go b/main.go index e62501b..097b036 100644 --- a/main.go +++ b/main.go @@ -3,7 +3,9 @@ import ( "analysis/logo" "analysis/util" + "os/signal" "strconv" + "syscall" "analysis/app/master" "analysis/app/slave" @@ -12,8 +14,6 @@ "flag" "os" - - "basic.com/valib/gogpu.git" // "net/http" // _ "net/http/pprof" ) @@ -28,8 +28,6 @@ ruleIPC string configPath string - - showConsole bool ) const ( @@ -38,8 +36,8 @@ ) func init() { - flag.StringVar(&role, "role", roleMaster, "run process role master/slave, default single") - flag.StringVar(&runType, "sdk", util.FeatAll, "run sdk type, face/facedetect/facecompare/yolo,etc.") + flag.StringVar(&role, "role", roleMaster, "run process role master/slave, default master") + flag.StringVar(&runType, "sdk", util.FeatAll, "run sdk type, facedetect/yolo,etc.") flag.StringVar(&id, "id", util.FakeSdkID, "sdk id as ipc label") flag.StringVar(&configPath, util.ConfigPath, "", "sdk config file path") @@ -48,8 +46,6 @@ flag.BoolVar(&shm, util.SHM, false, "use shm for performance") flag.IntVar(&gpu, util.GPU, -1, "gpu index") - - flag.BoolVar(&showConsole, "log-console", false, "log show console, only for debug") // 鎸囧畾鑾峰彇閰嶇疆淇℃伅浠巗qlite,鏈夋渶楂樹紭鍏堢骇, master浣跨敤 flag.StringVar(&util.FSI.IP, util.FetchSrvIP, util.FSI.IP, "fetch server ip, like camera info") @@ -70,9 +66,7 @@ logo.Config(file, 500, 3, 30) logo.Infoln("START LOGGER FILE: ", file) } - if showConsole { - logo.ShowConsole() - } + logo.ShowConsole() } func setParamters() { @@ -94,12 +88,6 @@ func main() { - indices := gogpu.RankGPU() - if len(indices) == 0 { - logo.Errorln("there is no gpu for valid") - return - } - util.InitConfig() flag.Parse() @@ -120,17 +108,18 @@ ret := false if role == roleMaster { setParamters() - ret = master.Run(ctx, configPath, "./libcomm.so") + ret = master.Run(ctx, "./libcomm.so", configPath) } else if role == roleSlave { ret = slave.Run(ctx, configPath, runType, id, gpu, shm) + } else if role == "test" { + ret = slave.TwoPluginConflict("./libcomm.so", "./zconf/Yolo.json") } if ret { - // c := make(chan os.Signal, 1) - // signal.Notify(c, os.Interrupt, os.Kill, unix.SIGTERM) - // <-c - select {} + c := make(chan os.Signal, 1) + signal.Notify(c, os.Interrupt, os.Kill, syscall.SIGTERM) + <-c } cancel() -- Gitblit v1.8.0