fix

diff --git a/Reply/Msg.go b/Reply/Msg.go
index 153ce0c8ffcdef1fc2b37a46f596bf5960def2a0..43bf35f95066eae84ab351e29e556705b49d8352 100644 (file)
--- a/Reply/Msg.go
+++ b/Reply/Msg.go
@@ -111,6 +111,7 @@ var Msg_map = map[string]func(replyF, string){
        "LITTLE_TIPS":                       replyF.little_tips, //小提示窗口
        "LIKE_INFO_V3_NOTICE":               nil,
        "LIVE_INTERACTIVE_GAME":             nil,
+       "LIVE_MULTI_VIEW_CHANGE":            nil,
 }
 
 // 屏蔽不需要的消息

diff --git a/Reply/stream.go b/Reply/stream.go
index b43af0584f7d8e51ae5bca1395891b9b46ab337c..c501bdc1f2bf4d95f43c9105abd35e5911ffd984 100644 (file)
--- a/Reply/stream.go
+++ b/Reply/stream.go
@@ -417,7 +417,9 @@ func (t *M4SStream) fetchParseM3U8() (m4s_links []*m4s_link_item, m3u8_addon []b
                return
        }
 
-       e = errors.New("未能找到可用流服务器")
+       if e != nil {
+               e = errors.New(e.Error() + " 未能找到可用流服务器")
+       }
        return
 }
 
@@ -750,6 +752,8 @@ func (t *M4SStream) saveStreamM4s() (e error) {
                                        fmp4KeyFrames, last_avilable_offset, e := fmp4Decoder.Seach_stream_fmp4(buf)
                                        if e != nil {
                                                t.log.L(`E: `, e)
+                                               //丢弃所有数据
+                                               last_avilable_offset = len(buf)
                                        }
 
                                        for _, fmp4KeyFrame := range fmp4KeyFrames {