zhangmeng
2020-01-21 9d9cd1d3b93613071d1dffc1c82c4515d2a65af6
main.go
@@ -40,25 +40,24 @@
)
func init() {
   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(&role, "role", roleMaster, "进程启动方式,master/slave")
   flag.StringVar(&runType, "sdk", util.FeatAll, "进程运行的算法类型FaceDetect/Yolo,etc.slave使用")
   flag.StringVar(&id, "id", util.FakeSdkID, "进程运行算法的ID,slave使用")
   flag.StringVar(&configPath, util.ConfigPath, "", "sdk config file path")
   flag.StringVar(&configPath, util.ConfigPath, "", "进程运行算法的参数配置文件路径,master从路径读取文件,slave使用文件")
   flag.BoolVar(&logit, util.LogIt, false, "use logger,default flase")
   flag.BoolVar(&shm, util.SHM, false, "use shm for performance")
   flag.BoolVar(&logit, util.LogIt, false, "是否保存日志文件,默认false")
   flag.BoolVar(&shm, util.SHM, false, "是否使用shared memory, 默认false, slave使用")
   flag.IntVar(&gpu, util.GPU, -1, "gpu index")
   flag.IntVar(&gpu, util.GPU, -1, "进程运行算法需要的GPU Index")
   // 指定获取配置信息从sqlite,有最高优先级, master使用
   flag.StringVar(&util.FSI.IP, util.FetchSrvIP, util.FSI.IP, "fetch server ip, like camera info")
   flag.IntVar(&util.FSI.HTTPort, util.FetchSrvPort, util.FSI.HTTPort, "fetch server port")
   flag.IntVar(&util.FSI.HBPort, util.FetchSrvHeartbeatPort, util.FSI.HBPort, "fetch server heartbeat port")
   flag.IntVar(&util.FSI.DataPort, util.FetchSrvDataPort, util.FSI.DataPort, "fetch server data port")
   flag.StringVar(&util.FSI.IP, util.FetchSrvIP, util.FSI.IP, "从IP获取需要运行的SDK,master使用")
   flag.IntVar(&util.FSI.HBPort, util.FetchSrvHeartbeatPort, util.FSI.HBPort, "获取需要运行的SDK服务器的心跳 Port,master使用")
   flag.IntVar(&util.FSI.DataPort, util.FetchSrvDataPort, util.FSI.DataPort, "获取需要运行的SDK服务器的数据 Port,master使用")
   // 指定发送到ruleprocess的ipc地址
   flag.StringVar(&util.ToRuleIPC, util.RuleIPC, util.ToRuleIPC, "send data to ruleprocess ipc")
   flag.StringVar(&util.ToRuleIPC, util.RuleIPC, util.ToRuleIPC, "将算法运行结果发送到规则服务器的IPC地址,slave使用")
}
func runLogger() {
@@ -74,10 +73,9 @@
}
func setParamters() {
   util.FillParams(util.FetchSrvIP, util.FSI.IP)
   util.FillParams(util.FetchSrvPort, strconv.Itoa(util.FSI.HTTPort))
   util.FillParams(util.FetchSrvHeartbeatPort, strconv.Itoa(util.FSI.HBPort))
   util.FillParams(util.FetchSrvDataPort, strconv.Itoa(util.FSI.DataPort))
   // util.FillParams(util.FetchSrvIP, util.FSI.IP)
   // util.FillParams(util.FetchSrvHeartbeatPort, strconv.Itoa(util.FSI.HBPort))
   // util.FillParams(util.FetchSrvDataPort, strconv.Itoa(util.FSI.DataPort))
   util.FillParams(util.RuleIPC, util.ToRuleIPC)