Mirrors/cloud-game
1
0
Fork 0
mirror of https://github.com/giongto35/cloud-game.git synced 2026-07-25 11:03:56 +00:00
Code Issues Projects Releases Packages Wiki Activity

Use new OPUS buffer every audio frame for less garbage

Browse source
This commit is contained in:
Sergey Stepanov 2021-01-21 19:25:19 +03:00
parent 76b7cafb71
commit 69bc3cbb6f
No known key found for this signature in database
GPG key ID: A56B4929BAA8556B
1 changed files with 12 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

23
pkg/encoder/opus/encoder.go
View file

@ -14,7 +14,7 @@ type Encoder struct {
inFrequency int
outFrequency int
// OPUS output buffer, 1K should be enough
outBuffer []byte
outBufferSize int
buffer Buffer
onFullBuffer func(data []byte)
@ -32,13 +32,13 @@ func NewEncoder(inputSampleRate, outputSampleRate, channels int, options ...func
return Encoder{}, err
}
enc := &Encoder{
Encoder: encoder,
buffer: Buffer{Data: make([]int16, inputSampleRate*20/1000*channels)},
channels: channels,
inFrequency: inputSampleRate,
outFrequency: outputSampleRate,
outBuffer: make([]byte, 1024),
onFullBuffer: func(data []byte) {},
Encoder: encoder,
buffer: Buffer{Data: make([]int16, inputSampleRate*20/1000*channels)},
channels: channels,
inFrequency: inputSampleRate,
outFrequency: outputSampleRate,
outBufferSize: 1024,
onFullBuffer: func(data []byte) {},
}
_ = enc.SetMaxBandwidth(opus.Fullband)
@ -91,11 +91,12 @@ func (e *Encoder) Encode(pcm []int16) ([]byte, error) {
if e.resampleBufSize > 0 {
pcm = resampleFn(pcm, e.resampleBufSize)
}
n, err := e.Encoder.Encode(pcm, e.outBuffer)
data := make([]byte, e.outBufferSize)
n, err := e.Encoder.Encode(pcm, data)
if err != nil {
return nil, err
return []byte{}, err
}
return e.outBuffer[:n], nil
return data[:n], nil
}
func (e *Encoder) GetInfo() string {