|
5 | 5 | "time"
|
6 | 6 |
|
7 | 7 | "github.com/bluenviron/gortsplib/v4/pkg/rtcpreceiver"
|
8 |
| - "github.com/bluenviron/gortsplib/v4/pkg/rtpreorderer" |
9 | 8 | "github.com/pion/rtcp"
|
10 | 9 | "github.com/pion/rtp"
|
11 | 10 | "github.com/pion/webrtc/v4"
|
@@ -287,8 +286,9 @@ func (t *IncomingTrack) start() {
|
287 | 286 | t.packetsLost.Start()
|
288 | 287 |
|
289 | 288 | t.rtcpReceiver = &rtcpreceiver.RTCPReceiver{
|
290 |
| - ClockRate: int(t.track.SSRC()), |
291 |
| - Period: 1 * time.Second, |
| 289 | + ClockRate: int(t.track.SSRC()), |
| 290 | + UnrealiableTransport: true, |
| 291 | + Period: 1 * time.Second, |
292 | 292 | WritePacketRTCP: func(p rtcp.Packet) {
|
293 | 293 | t.writeRTCP([]rtcp.Packet{p}) //nolint:errcheck
|
294 | 294 | },
|
@@ -342,30 +342,25 @@ func (t *IncomingTrack) start() {
|
342 | 342 |
|
343 | 343 | // read incoming RTP packets.
|
344 | 344 | go func() {
|
345 |
| - reorderer := &rtpreorderer.Reorderer{} |
346 |
| - reorderer.Initialize() |
347 |
| - |
348 | 345 | for {
|
349 | 346 | pkt, _, err2 := t.track.ReadRTP()
|
350 | 347 | if err2 != nil {
|
351 | 348 | return
|
352 | 349 | }
|
353 | 350 |
|
354 |
| - packets, lost := reorderer.Process(pkt) |
| 351 | + packets, lost, err2 := t.rtcpReceiver.ProcessPacket2(pkt, time.Now(), true) |
| 352 | + if err2 != nil { |
| 353 | + t.log.Log(logger.Warn, err2.Error()) |
| 354 | + continue |
| 355 | + } |
355 | 356 | if lost != 0 {
|
356 |
| - atomic.AddUint64(t.rtpPacketsLost, uint64(lost)) |
357 |
| - t.packetsLost.Add(uint64(lost)) |
| 357 | + atomic.AddUint64(t.rtpPacketsLost, lost) |
| 358 | + t.packetsLost.Add(lost) |
358 | 359 | // do not return
|
359 | 360 | }
|
360 | 361 |
|
361 | 362 | atomic.AddUint64(t.rtpPacketsReceived, uint64(len(packets)))
|
362 | 363 |
|
363 |
| - err2 = t.rtcpReceiver.ProcessPacket(pkt, time.Now(), true) |
364 |
| - if err2 != nil { |
365 |
| - t.log.Log(logger.Warn, err2.Error()) |
366 |
| - continue |
367 |
| - } |
368 |
| - |
369 | 364 | var ntp time.Time
|
370 | 365 | if t.useAbsoluteTimestamp {
|
371 | 366 | var avail bool
|
|
0 commit comments