mirror of
https://github.com/bluenviron/mediamtx.git
synced 2025-12-24 20:11:56 -08:00
0943b269ab
* split data into specialized structs * move MPEG4-audio decoding into streamTrack * restore video/audio synchronization in HLS muxer and RTMP server * log decode errors * move H264 decoding and re-encoding here from gortsplib * add tests * update gortsplib
71 lines
1.2 KiB
Go
71 lines
1.2 KiB
Go
package core
|
|
|
|
import (
|
|
"time"
|
|
|
|
"github.com/pion/rtp"
|
|
)
|
|
|
|
// data is the data unit routed across the server.
|
|
type data interface {
|
|
getTrackID() int
|
|
getRTPPackets() []*rtp.Packet
|
|
getPTSEqualsDTS() bool
|
|
}
|
|
|
|
type dataGeneric struct {
|
|
trackID int
|
|
rtpPackets []*rtp.Packet
|
|
ptsEqualsDTS bool
|
|
}
|
|
|
|
func (d *dataGeneric) getTrackID() int {
|
|
return d.trackID
|
|
}
|
|
|
|
func (d *dataGeneric) getRTPPackets() []*rtp.Packet {
|
|
return d.rtpPackets
|
|
}
|
|
|
|
func (d *dataGeneric) getPTSEqualsDTS() bool {
|
|
return d.ptsEqualsDTS
|
|
}
|
|
|
|
type dataH264 struct {
|
|
trackID int
|
|
rtpPackets []*rtp.Packet
|
|
ptsEqualsDTS bool
|
|
pts time.Duration
|
|
nalus [][]byte
|
|
}
|
|
|
|
func (d *dataH264) getTrackID() int {
|
|
return d.trackID
|
|
}
|
|
|
|
func (d *dataH264) getRTPPackets() []*rtp.Packet {
|
|
return d.rtpPackets
|
|
}
|
|
|
|
func (d *dataH264) getPTSEqualsDTS() bool {
|
|
return d.ptsEqualsDTS
|
|
}
|
|
|
|
type dataMPEG4Audio struct {
|
|
trackID int
|
|
rtpPackets []*rtp.Packet
|
|
pts time.Duration
|
|
aus [][]byte
|
|
}
|
|
|
|
func (d *dataMPEG4Audio) getTrackID() int {
|
|
return d.trackID
|
|
}
|
|
|
|
func (d *dataMPEG4Audio) getRTPPackets() []*rtp.Packet {
|
|
return d.rtpPackets
|
|
}
|
|
|
|
func (d *dataMPEG4Audio) getPTSEqualsDTS() bool {
|
|
return true
|
|
}
|