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