From 4eb8b9581a0f24d030f9c7b8e7652e72e60ed92f Mon Sep 17 00:00:00 2001 From: zhangmeng <775834166@qq.com> Date: 星期一, 06 五月 2019 13:27:40 +0800 Subject: [PATCH] 整理代码 --- decoder/main.go | 11 +++++++---- 1 files changed, 7 insertions(+), 4 deletions(-) diff --git a/decoder/main.go b/decoder/main.go index fa513b3..a9d8816 100644 --- a/decoder/main.go +++ b/decoder/main.go @@ -2,14 +2,13 @@ import ( "context" - "decoder/demo" "decoder/valib/ipc" + srv "decoder/work/service" "encoding/json" "flag" "fmt" "strconv" "strings" - // "videoServer/demo" ) var ( @@ -98,17 +97,21 @@ url := strings.TrimSpace(c.URL) id := strings.TrimSpace(c.ID) i := strings.TrimSpace(ipc) - go demo.SendByIPC(url, id, i, false) + go runSender(id, url, i) } } } cancel() } +func runSender(cameraID, rtspURL, ipcLabel string) { + d := srv.NewSender(cameraID, rtspURL, ipcLabel) + d.RunAsClient() +} func test() { fmt.Println("start test") fmt.Println(picFolder) - demo.SendByIPC(streamURL, "camera1", ipcURL, false) + runSender("cameraid", streamURL, ipcURL) } -- Gitblit v1.8.0