多个解码单元同时运行,注意tcp地址

zhangmeng

2019-05-07 f963cd025c1aa88ac8b211e24f46ceb0eb64c418

 analysis/main.go

@@ -2,6 +2,7 @@

import (
   "analysis/demo"
   srv "analysis/work/service"
   "flag"
   "fmt"
)
@@ -9,6 +10,8 @@
var (
   streamURL string
   picFolder string

   asServer bool
)

func init() {
@@ -17,6 +20,8 @@

   flag.StringVar(&ipcURL, "ipc", "ipc:///tmp/pic.ipc", "ipc label")
   flag.StringVar(&proc, "proc", "", "proc name")

   flag.BoolVar(&asServer, "server", false, "run ipc as server")
}

const (
@@ -29,11 +34,16 @@

   fmt.Println("start test, pic folder: ", picFolder)

   // demo.Face(picFolder)
   // demo.Yolo(streamURL)
   // demo.CVDraw()
   imageChan := make(chan srv.ImageInfo)
   d := srv.NewReciever(ipcURL, imageChan)

   demo.RunYoloFromIPC(ipcURL, false)
   if asServer {
      go d.RunAsServer()
   } else {
      go d.RunAsClient()
   }

   demo.ShowYolo(imageChan)

   fakeStartProc()
}