| | |
| | | ) |
| | | |
| | | 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() { |
| | |
| | | } |
| | | |
| | | 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) |
| | | |