| | |
|---|
| | | "basic.com/valib/deliver.git" |
|---|
| | | "ruleprocess/insertdata" |
|---|
| | | "ruleprocess/util" |
|---|
| | | "runtime" |
|---|
| | | "time" |
|---|
| | | |
|---|
| | | //"bufio" |
|---|
| | |
|---|
| | | "ruleprocess/ruleserver" |
|---|
| | | "sync" |
|---|
| | | ) |
|---|
| | | |
|---|
| | | 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 initchan = make(chan bool) |
|---|
| | | |
|---|
| | | func init () { |
|---|
| | | // 日志初始化 |
|---|
| | | logger.Config("./info.log", logger.DebugLevel) |
|---|
| | |
|---|
| | | fmt.Println("recv error : ", err) |
|---|
| | | continue |
|---|
| | | } else { |
|---|
| | | //for msg := range msgChan { |
|---|
| | | runtime.GOMAXPROCS(runtime.NumCPU()) |
|---|
| | | logger.Debug("使用的cpu个数：",runtime.NumCPU()) |
|---|
| | | go func(msg []byte) { |
|---|
| | | logger.Debug("当前时间戳：",time.Now().Unix()) |
|---|
| | | arg := ruleserver.SdkDatas{} |
|---|
| | |
|---|
| | | //事件推送 |
|---|
| | | //go labelFilter.Judge(resultMsg) |
|---|
| | | }(msg) |
|---|
| | | //} |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | // 将外部传进来的rect（top,bottom,left,right）转化为自己内部的rect(left top width height) |
|---|
| | | func rectFormat(rcobj *protomsg.Rect) ruleserver.Rect { |
|---|
| | | //logger.Info("++++++++++++++++++++++++++++++收到的yolo的区域坐标：",rcobj) |
|---|
