| | |
| | | ) |
| | | var dbIp = flag.String("dbIp","127.0.0.1","dbserver ip") |
| | | var dbPort = flag.Int("dbPort",8001,"default dbPort=8001") |
| | | var surveyPort = flag.Int("surveyPort",40007,"survey port") |
| | | var pubPort = flag.Int("pubPort",50007,"pubsub port") |
| | | var surveyPort = flag.Int("surveyPort",40007,"survey port") //心跳 |
| | | var pubPort = flag.Int("pubPort",50007,"pubsub port") //数据更新 |
| | | var initchan = make(chan bool) |
| | | func main() { |
| | | flag.Parse() |
| | |
| | | arg.IsStatic = false |
| | | if len(sdkinfo.Sdkdata) > 1 { |
| | | // 大于1才有数据 |
| | | fmt.Println("----------------------------------------------------",m.Cid) |
| | | yoloParam := protomsg.ParamYoloObj{} |
| | | err = proto.Unmarshal(sdkinfo.Sdkdata, &yoloParam) |
| | | if err != nil { |