panlei
2019-07-01 5bfa782ca7e9c61a351c3929dd2bd108ec976bc3
在main里测试
1个文件已修改
17 ■■■■■ 已修改文件
main.go 17 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
main.go
@@ -2,6 +2,7 @@
import (
    "fmt"
    "log"
    "ruleprocess/insertdata"
    "ruleprocess/ruleserver"
    "ruleprocess/util"
@@ -9,15 +10,19 @@
    "basic.com/pubsub/protomsg.git"
    "basic.com/valib/deliver.git"
    "github.com/golang/protobuf/proto"
    "sync"
)
func main() {
    wg := sync.WaitGroup{}
    wg.Add(1)
    go ruleserver.TimeTicker()
    nReciever("ipc:///tmp/sdk-2-rules-process.ipc", deliver.PushPull, 1)
    wg.Wait()
    //wg := sync.WaitGroup{}
    //wg.Add(1)
    //go ruleserver.TimeTicker()
    //nReciever("ipc:///tmp/sdk-2-rules-process.ipc", deliver.PushPull, 1)
    //wg.Wait()
    resp,err := util.DrawPolygon()
    if err != nil {
        log.Println("画框或者上传有问题")
    }
    log.Println(resp["fileUrl"].(string))
}
func nReciever(url string, m deliver.Mode, count int) {
    c := deliver.NewServer(m, url)