mirror of
https://github.com/jetkvm/kvm.git
synced 2025-09-16 08:38:14 +00:00
629cdf59a7
- Implement batch audio processing to reduce CGO overhead - Replace mutexes with atomic operations for contention management - Add buffer pooling to reduce allocations - Optimize microphone operation cooldown with lock-free approach - Improve error handling with pre-allocated error objects
64 lines
1.5 KiB
Go
64 lines
1.5 KiB
Go
package audio
|
|
|
|
import (
|
|
"sync"
|
|
)
|
|
|
|
// AudioBufferPool manages reusable audio buffers to reduce allocations
|
|
type AudioBufferPool struct {
|
|
pool sync.Pool
|
|
}
|
|
|
|
// NewAudioBufferPool creates a new buffer pool for audio frames
|
|
func NewAudioBufferPool(bufferSize int) *AudioBufferPool {
|
|
return &AudioBufferPool{
|
|
pool: sync.Pool{
|
|
New: func() interface{} {
|
|
// Pre-allocate buffer with specified size
|
|
return make([]byte, bufferSize)
|
|
},
|
|
},
|
|
}
|
|
}
|
|
|
|
// Get retrieves a buffer from the pool
|
|
func (p *AudioBufferPool) Get() []byte {
|
|
return p.pool.Get().([]byte)
|
|
}
|
|
|
|
// Put returns a buffer to the pool
|
|
func (p *AudioBufferPool) Put(buf []byte) {
|
|
// Reset length but keep capacity for reuse
|
|
if cap(buf) >= 1500 { // Only pool buffers of reasonable size
|
|
p.pool.Put(buf[:0])
|
|
}
|
|
}
|
|
|
|
// Global buffer pools for different audio operations
|
|
var (
|
|
// Pool for 1500-byte audio frame buffers (Opus max frame size)
|
|
audioFramePool = NewAudioBufferPool(1500)
|
|
|
|
// Pool for smaller control buffers
|
|
audioControlPool = NewAudioBufferPool(64)
|
|
)
|
|
|
|
// GetAudioFrameBuffer gets a reusable buffer for audio frames
|
|
func GetAudioFrameBuffer() []byte {
|
|
return audioFramePool.Get()
|
|
}
|
|
|
|
// PutAudioFrameBuffer returns a buffer to the frame pool
|
|
func PutAudioFrameBuffer(buf []byte) {
|
|
audioFramePool.Put(buf)
|
|
}
|
|
|
|
// GetAudioControlBuffer gets a reusable buffer for control data
|
|
func GetAudioControlBuffer() []byte {
|
|
return audioControlPool.Get()
|
|
}
|
|
|
|
// PutAudioControlBuffer returns a buffer to the control pool
|
|
func PutAudioControlBuffer(buf []byte) {
|
|
audioControlPool.Put(buf)
|
|
} |