apps/engine
1
0
Fork 0
mirror of https://github.com/Monibuca/engine.git synced 2025-10-17 06:00:48 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

追赶技术有问题，先回退

Browse Source
This commit is contained in:
langhuihui
2020-12-12 16:47:15 +08:00
parent 56384f4a99
commit 9d8e6e612f
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
subscriber.go
View File

@@ -73,7 +73,7 @@ func (s *Subscriber) Subscribe(streamPath string) (err error) {
s.Delay = s.AVRing.GetLast().Timestamp - packet.Timestamp s.Delay = s.AVRing.GetLast().Timestamp - packet.Timestamp
s.send(packet) s.send(packet)
packet.GoNext() packet.GoNext()
targetStartTime := s.AVRing.GetLast().Timestamp //实际开始时间戳 // targetStartTime := s.AVRing.GetLast().Timestamp //实际开始时间戳
for atsent, dropping, droped := s.AudioTag == nil, false, 0; s.Err() == nil; packet.GoNext() { for atsent, dropping, droped := s.AudioTag == nil, false, 0; s.Err() == nil; packet.GoNext() {
s.TotalPacket++ s.TotalPacket++
if !dropping { if !dropping {
@@ -83,9 +83,9 @@ func (s *Subscriber) Subscribe(streamPath string) (err error) {
atsent = true atsent = true
} }
s.sendAv(&packet.AVPacket, packet.Timestamp-s.startTime) s.sendAv(&packet.AVPacket, packet.Timestamp-s.startTime)
if targetStartTime > s.startTime { // if targetStartTime > s.startTime {
s.startTime++ //逐步追赶，使得开始时间逼近实际开始时间戳 // s.startTime++ //逐步追赶，使得开始时间逼近实际开始时间戳
} // }
if s.checkDrop(packet) { if s.checkDrop(packet) {
dropping = true dropping = true
droped = 0 droped = 0