synchronizer

package

v2.9.0 Latest Latest Go to latest Published: May 29, 2025 License: Apache-2.0 Imports: 8 Imported by: 3

Details

This section is empty.

This section is empty.

This section is empty.

type Synchronizer struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

a single Synchronizer is shared between all audio and video writers

func NewSynchronizer(onStarted func()) *Synchronizer

func (s *Synchronizer) AddTrack(track TrackRemote, identity string) *TrackSynchronizer

func (s *Synchronizer) End()

func (s *Synchronizer) GetEndedAt() int64

func (s *Synchronizer) GetStartedAt() int64

func (s *Synchronizer) OnRTCP(packet rtcp.Packet)

OnRTCP syncs a/v using sender reports

func (s *Synchronizer) RemoveTrack(trackID string)

type TrackRemote interface {
	ID() string
	Codec() webrtc.RTPCodecParameters
	Kind() webrtc.RTPCodecType
	SSRC() webrtc.SSRC
}

type TrackSynchronizer struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (t *TrackSynchronizer) GetPTS(pkt *rtp.Packet) (time.Duration, error)

GetPTS will reset sequence numbers and/or offsets if necessary Packets are expected to be in order

func (t *TrackSynchronizer) Initialize(pkt *rtp.Packet)

Initialize should be called as soon as the first packet is received

func (t *TrackSynchronizer) OnSenderReport(f func(drift time.Duration))