Improve 完善录制事件

diff --git a/Reply/stream.go b/Reply/stream.go
index 3a7ad7774f3e43dd81d3ea58c6e009bb43be977d..307311ba86689a9c5b51be7c579702f2c13eff1f 100644 (file)
--- a/Reply/stream.go
+++ b/Reply/stream.go
@@ -764,6 +764,7 @@ func (t *M4SStream) saveStreamFlv() (e error) {
                                                        // fmt.Println("write front_buf")
                                                        out.Write(t.first_buf)
                                                        t.Stream_msg.PushLock_tag(`data`, t.first_buf)
+                                                       t.msg.Push_tag(`load`, t)
                                                }
                                                if len(t.first_buf) != 0 && keyframe.Size() != 0 {
                                                        t.bootBufPush(keyframe.GetPureBuf())
@@ -977,6 +978,7 @@ func (t *M4SStream) saveStreamM4s() (e error) {
                                                out.Write(t.first_buf, true)
                                                out.Sync()
                                        }
+                                       t.msg.Push_tag(`load`, t)
                                }
                                t.putM4s(download_seq[k])
                                download_seq = append(download_seq[:k], download_seq[k+1:]...)