| | |
| | | ) |
| | | |
| | | 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.HTTPort, util.FetchSrvPort, util.FSI.HTTPort, "获取需要运行的SDK服务器的HTTP Port,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() { |
| | |
| | | package util |
| | | |
| | | // FetchServerInfo 从sqlite的服务器获取同步信息的服务 |
| | | // FetchServerInfo 从sqlite的服务器获取SDK信息的服务器信息 |
| | | type FetchServerInfo struct { |
| | | IP string |
| | | HTTPort int |
| | |
| | | } |
| | | |
| | | var ( |
| | | // FSI 同步服务器信息 |
| | | // FSI SDK信息服务器IP/Port |
| | | FSI = &FetchServerInfo{ |
| | | IP: "127.0.0.1", |
| | | HTTPort: 8001, |