Commit 1fb42886 authored by Juliusz Chroboczek's avatar Juliusz Chroboczek

Don't send NACKs from disk writer.

We're already doing it in the receiver loop.
parent 564dcd41
...@@ -414,7 +414,7 @@ func (t *diskTrack) Write(buf []byte) (int, error) { ...@@ -414,7 +414,7 @@ func (t *diskTrack) Write(buf []byte) (int, error) {
count := p.SequenceNumber - lastSeqno count := p.SequenceNumber - lastSeqno
if count < 256 { if count < 256 {
for i := uint16(1); i < count; i++ { for i := uint16(1); i < count; i++ {
recover(t, lastSeqno+i) fetch(t, lastSeqno+i)
} }
} else { } else {
requestKeyframe(t) requestKeyframe(t)
...@@ -439,10 +439,10 @@ func (t *diskTrack) Write(buf []byte) (int, error) { ...@@ -439,10 +439,10 @@ func (t *diskTrack) Write(buf []byte) (int, error) {
return len(buf), nil return len(buf), nil
} }
func recover(t *diskTrack, seqno uint16) { func fetch(t *diskTrack, seqno uint16) {
// since the samplebuilder retains packets, use a fresh buffer // since the samplebuilder retains packets, use a fresh buffer
buf := make([]byte, 1504) buf := make([]byte, 1504)
n := t.remote.GetPacket(seqno, buf, true) n := t.remote.GetPacket(seqno, buf, false)
if n == 0 { if n == 0 {
return return
} }
...@@ -462,7 +462,7 @@ func requestKeyframe(t *diskTrack) { ...@@ -462,7 +462,7 @@ func requestKeyframe(t *diskTrack) {
} }
} }
// writeRTP writes the packet without doing any loss recovery. // writeRTP writes the packet without fetching lost packets
// Called locked. // Called locked.
func (t *diskTrack) writeRTP(p *rtp.Packet) error { func (t *diskTrack) writeRTP(p *rtp.Packet) error {
codec := t.remote.Codec().MimeType codec := t.remote.Codec().MimeType
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment