mirror of
https://github.com/bluenviron/mediamtx.git
synced 2025-12-21 02:22:01 -08:00
1083eea307
Some checks failed
code_lint / golangci_lint (push) Has been cancelled
code_lint / mod_tidy (push) Has been cancelled
code_lint / api_docs (push) Has been cancelled
code_test / test_64 (push) Has been cancelled
code_test / test_32 (push) Has been cancelled
code_test / test_e2e (push) Has been cancelled
when RTSP encryption is enabled, maximum RTP packet size is slightly decreased to make room for SRTP.
57 lines
1.1 KiB
Go
57 lines
1.1 KiB
Go
package formatprocessor
|
|
|
|
import (
|
|
"fmt"
|
|
"time"
|
|
|
|
"github.com/bluenviron/gortsplib/v4/pkg/format"
|
|
"github.com/pion/rtp"
|
|
|
|
"github.com/bluenviron/mediamtx/internal/logger"
|
|
"github.com/bluenviron/mediamtx/internal/unit"
|
|
)
|
|
|
|
type generic struct {
|
|
RTPMaxPayloadSize int
|
|
Format format.Format
|
|
GenerateRTPPackets bool
|
|
Parent logger.Writer
|
|
}
|
|
|
|
func (t *generic) initialize() error {
|
|
if t.GenerateRTPPackets {
|
|
return fmt.Errorf("we don't know how to generate RTP packets of format %T", t.Format)
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func (t *generic) ProcessUnit(_ unit.Unit) error {
|
|
return fmt.Errorf("using a generic unit without RTP is not supported")
|
|
}
|
|
|
|
func (t *generic) ProcessRTPPacket(
|
|
pkt *rtp.Packet,
|
|
ntp time.Time,
|
|
pts int64,
|
|
_ bool,
|
|
) (unit.Unit, error) {
|
|
u := &unit.Generic{
|
|
Base: unit.Base{
|
|
RTPPackets: []*rtp.Packet{pkt},
|
|
NTP: ntp,
|
|
PTS: pts,
|
|
},
|
|
}
|
|
|
|
// remove padding
|
|
pkt.Padding = false
|
|
pkt.PaddingSize = 0
|
|
|
|
if len(pkt.Payload) > t.RTPMaxPayloadSize {
|
|
return nil, fmt.Errorf("RTP payload size (%d) is greater than maximum allowed (%d)",
|
|
len(pkt.Payload), t.RTPMaxPayloadSize)
|
|
}
|
|
|
|
return u, nil
|
|
}
|