package main
|
|
import (
|
"context"
|
"decoder/demo"
|
"decoder/valib/ipc"
|
"encoding/json"
|
"flag"
|
"fmt"
|
// "videoServer/demo"
|
)
|
|
var (
|
streamURL string
|
picFolder string
|
|
ipcURL string
|
proc string
|
)
|
|
func init() {
|
flag.StringVar(&streamURL, "i", "rtsp://192.168.1.203:8554/16.mkv", "input url")
|
flag.StringVar(&picFolder, "f", ".", "test pic folder")
|
|
flag.StringVar(&ipcURL, "ipc", "ipc:///tmp/pic.ipc", "ipc label")
|
}
|
|
// CameraInfo camera info
|
type CameraInfo struct {
|
ID string `json:"Cameraid"`
|
URL string `json:"Rtsp"`
|
}
|
|
// MsgIPC msg for ipc
|
type MsgIPC struct {
|
CMD string `json:"Command"`
|
Port int `jsong:"PortIpc"`
|
}
|
|
var (
|
mapCI = make(map[string]CameraInfo)
|
port = 7001
|
)
|
|
func recvFromIPC(ctx context.Context, url string, ch chan<- CameraInfo) {
|
ipc := ipc.NewClient(ctx, url)
|
|
for {
|
msg := ipc.Recv()
|
if msg != nil {
|
fmt.Println(string(msg))
|
var c CameraInfo
|
if err := json.Unmarshal(msg, &c); err == nil {
|
ch <- c
|
fmt.Printf("recv camere info %+v\n", c)
|
} else {
|
fmt.Println(err)
|
}
|
msgIpc := MsgIPC{"new decoder", port}
|
if b, err := json.Marshal(msgIpc); err == nil {
|
ipc.Send(b)
|
}
|
}
|
}
|
}
|
|
func main() {
|
flag.Parse()
|
|
test()
|
|
// ctx, cancel := context.WithCancel(context.Background())
|
|
// ch := make(chan CameraInfo)
|
// go recvFromIPC(ctx, "tcp://192.168.1.124:7000", ch)
|
|
// for {
|
// select {
|
// case <-ctx.Done():
|
// return
|
// case c := <-ch:
|
// if _, ok := mapCI[c.ID]; !ok {
|
// mapCI[c.ID] = c
|
// ipc := "tcp://192.168.1.124:" + strconv.Itoa(port)
|
// port++
|
// fmt.Printf("create ipc %s for decode : %s, on camera id %s\n", ipc, c.URL, c.ID)
|
|
// url := strings.TrimSpace(c.URL)
|
// id := strings.TrimSpace(c.ID)
|
// i := strings.TrimSpace(ipc)
|
// go demo.SendByIPC(url, id, i)
|
// }
|
// }
|
// }
|
// cancel()
|
|
}
|
|
func test() {
|
fmt.Println("start test")
|
|
fmt.Println(picFolder)
|
|
demo.SendByIPC(streamURL, "camera1", ipcURL, true)
|
}
|
