From 13e8d4e6a2d002c1164d903580b213f6dd14a71f Mon Sep 17 00:00:00 2001 From: dexter <178529795@qq.com> Date: Tue, 1 Mar 2022 20:43:22 +0800 Subject: [PATCH] =?UTF-8?q?=E9=80=82=E9=85=8D=E5=BC=95=E6=93=8E=E5=8F=98?= =?UTF-8?q?=E6=9B=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- main.go | 7 ------- pull.go | 2 +- 2 files changed, 1 insertion(+), 8 deletions(-) diff --git a/main.go b/main.go index 21ce811..200fe4d 100644 --- a/main.go +++ b/main.go @@ -8,7 +8,6 @@ import ( "strings" "time" - . "github.com/logrusorgru/aurora" amf "github.com/zhangpeihao/goamf" "go.uber.org/zap" . "m7s.live/engine/v4" @@ -27,12 +26,6 @@ type HDLConfig struct { func (c *HDLConfig) OnEvent(event any) { switch v := event.(type) { case FirstConfig: - if c.ListenAddr != "" || c.ListenAddrTLS != "" { - plugin.Info(Green("HDL Server Start").String(), zap.String("ListenAddr", c.ListenAddr), zap.String("ListenAddrTLS", c.ListenAddrTLS)) - go c.Listen(plugin, c) - } else { - plugin.Info(Green("HDL start reuse engine port").String()) - } if c.PullOnStart { for streamPath, url := range c.PullList { if err := plugin.Pull(streamPath, url, new(HDLPuller), false); err != nil { diff --git a/pull.go b/pull.go index 2aa70c3..9fa8759 100644 --- a/pull.go +++ b/pull.go @@ -15,7 +15,7 @@ import ( ) func (puller *HDLPuller) Connect() (err error) { - puller.ReConnectCount++ + log.Info("connect", zap.String("remoteURL", puller.RemoteURL)) if strings.HasPrefix(puller.RemoteURL, "http") { var res *http.Response