Documentation
¶
Index ¶
- Constants
- Variables
- func DecodeGbk(v interface{}, body []byte) error
- func GbkToUtf8(s []byte) ([]byte, error)
- func Get() *bytes.Buffer
- func NewError(err error, params ...interface{}) error
- func PrintStack()
- func Put(b *bytes.Buffer)
- func RandNum16String(n int) string
- func RandNumString(n int) string
- func RandString(n int) string
- func ResolveSelfIP() (net.IP, error)
- func ToJSONString(v interface{}) string
- func ToPrettyString(v interface{}) string
- type DecPSPackage
- type Error
- type IOBuffer
- func (b *IOBuffer) Len() int
- func (b *IOBuffer) Next(n int) []byte
- func (b *IOBuffer) ReadByte() (byte, error)
- func (b *IOBuffer) ReadN(length int) ([]byte, error)
- func (b *IOBuffer) Reset()
- func (b *IOBuffer) Skip(n int) (err error)
- func (b *IOBuffer) Uint16() (uint16, error)
- func (b *IOBuffer) Uint32() (uint32, error)
- func (b *IOBuffer) Write(p []byte) (n int, err error)
- type Pool
- type PriorityQueueRtp
- type Pusher
Constants ¶
View Source
const ( UDPTransfer int = 0 TCPTransferActive int = 1 TCPTransferPassive int = 2 LocalCache int = 3 StreamTypeH264 = 0x1b StreamTypeH265 = 0x24 G711A = 0x90 //PCMA G7221AUDIOTYPE = 0x92 G7231AUDIOTYPE = 0x93 G729AUDIOTYPE = 0x99 StreamIDVideo = 0xe0 StreamIDAudio = 0xc0 StartCodePS = 0x000001ba StartCodeSYS = 0x000001bb StartCodeMAP = 0x000001bc StartCodeVideo = 0x000001e0 StartCodeAudio = 0x000001c0 HaiKangCode = 0x000001bd MEPGProgramEndCode = 0x000001b9 RTPHeaderLength int = 12 PSHeaderLength int = 14 SystemHeaderLength int = 18 MAPHeaderLength int = 24 PESHeaderLength int = 19 RtpLoadLength int = 1460 PESLoadLength int = 0xFFFF MAXFrameLen int = 1024 * 1024 * 2 )
View Source
const MaxRtpDiff = 65000 //相邻两个包之间的最大差值
Variables ¶
View Source
var ( ErrNotFoundStartCode = errors.New("not found the need start code flag") ErrMarkerBit = errors.New("marker bit value error") ErrFormatPack = errors.New("not package standard") ErrParsePakcet = errors.New("parse ps packet error") )
View Source
var ErrTooLarge = errors.New("IOBuffer: too large")
Functions ¶
func Get ¶
Get returns an empty byte buffer from the pool.
Got byte buffer may be returned to the pool via Put call. This reduces the number of memory allocations required for byte buffer management.
func PrintStack ¶
func PrintStack()
func Put ¶
Put returns byte buffer to the pool.
bytes.Buffer.B mustn't be touched after returning it to the pool. Otherwise data races will occur.
func RandNum16String ¶
func RandNumString ¶
func RandString ¶
func ToJSONString ¶
func ToJSONString(v interface{}) string
func ToPrettyString ¶
func ToPrettyString(v interface{}) string
Types ¶
type DecPSPackage ¶
type DecPSPackage struct {
VideoStreamType uint32
AudioStreamType uint32
IOBuffer
Payload []byte
PTS uint32
DTS uint32
// contains filtered or unexported fields
}
https://github.com/videolan/vlc/blob/master/modules/demux/mpeg
func (*DecPSPackage) Read ¶
func (dec *DecPSPackage) Read(ts uint32, pusher Pusher) error
read the buffer and push video or audio
func (*DecPSPackage) ReadPayload ¶
func (dec *DecPSPackage) ReadPayload() (payload []byte, err error)
type Pool ¶
type Pool struct {
// contains filtered or unexported fields
}
Pool represents byte buffer pool.
Distinct pools may be used for distinct types of byte buffers. Properly determined byte buffer types with their own pools may help reducing memory waste.
type PriorityQueueRtp ¶
type PriorityQueueRtp struct {
// contains filtered or unexported fields
}
func NewPqRtp ¶
func NewPqRtp() *PriorityQueueRtp
func (*PriorityQueueRtp) Empty ¶
func (p *PriorityQueueRtp) Empty()
func (*PriorityQueueRtp) Len ¶
func (p *PriorityQueueRtp) Len() int
func (*PriorityQueueRtp) Push ¶
func (p *PriorityQueueRtp) Push(v rtp.Packet)
Source Files
Click to show internal directories.
Click to hide internal directories.