utils

Documentation

Index

• func WaitChannelWithTimeout(c <-chan bool, nbWaitFor int, d time.Duration) (err error)
• type PacketList
  • func NewPacketListFromRtpPacket(packet *rtp.DataPacket) *PacketList
  • func (pl *PacketList) GetLast() *PacketList
  • func (pl *PacketList) Iterate(f func(p *PacketList))
  • func (pl *PacketList) Len() (length int)
  • func (pl *PacketList) Next() *PacketList
  • func (pl *PacketList) SetNext(npl *PacketList)

Functions

func WaitChannelWithTimeout

func WaitChannelWithTimeout(c <-chan bool, nbWaitFor int, d time.Duration) (err error)

WaitChannelWithTimeout read exactly number of nbWaitFor values out from channel then return if this cannot achieve within timeout duration, non-nil error returned

Types

type PacketList

type PacketList struct {
	Payload     []byte // rtp payload
	RawBuffer   []byte // rtp payload + rtp header
	PayloadType uint8
	Pts         uint32 // presentation timestamp
	PrevPts     uint32 // previous packet's pts
	Marker      bool   // should mark-bit in rtp header be set?
	Ssrc        uint32
	Csrc        []uint32
	// contains filtered or unexported fields
}

PacketList is either received RTP data packet or generated packets by codecs that can be readily put to stack for transmission. audio data is usually one packet at a time as no pts is required, but video codecs can build multiple packets of the same pts. those packets can be linked and send to rtp stack as a whole.

func NewPacketListFromRtpPacket

func NewPacketListFromRtpPacket(packet *rtp.DataPacket) *PacketList

func (*PacketList) GetLast

func (pl *PacketList) GetLast() *PacketList

func (*PacketList) Iterate

func (pl *PacketList) Iterate(f func(p *PacketList))

func (*PacketList) Len

func (pl *PacketList) Len() (length int)

func (*PacketList) Next

func (pl *PacketList) Next() *PacketList

func (*PacketList) SetNext

func (pl *PacketList) SetNext(npl *PacketList)