mth/ebiten
1
0
Fork 0
mirror of https://github.com/hajimehoshi/ebiten.git synced 2024-12-26 19:58:54 +01:00
Code Issues Packages Projects Releases Wiki Activity

audio/internal/readerdriver: Make the implementation thread safe (Unix)

Browse Source 
Closes #1771
This commit is contained in:
Hajime Hoshi 2021-08-18 21:53:43 +09:00
parent 9f0e95f6a2
commit c87e0df8a4
1 changed files with 24 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
audio/internal/readerdriver/driver_unix.go
View File

@ -24,6 +24,7 @@ import "C"
import ( import (
"fmt" "fmt"
"sync"
"time" "time"
"unsafe" "unsafe"
) )
@ -37,9 +38,13 @@ type context struct {
channelNum int channelNum int
bitDepthInBytes int bitDepthInBytes int
suspended bool
handle *C.snd_pcm_t handle *C.snd_pcm_t
supportsPause bool supportsPause bool
cond *sync.Cond
players *players players *players
} }
@ -57,6 +62,7 @@ func NewContext(sampleRate, channelNum, bitDepthInBytes int) (Context, chan stru
sampleRate: sampleRate, sampleRate: sampleRate,
channelNum: channelNum, channelNum: channelNum,
bitDepthInBytes: bitDepthInBytes, bitDepthInBytes: bitDepthInBytes,
cond: sync.NewCond(&sync.Mutex{}),
players: newPlayers(), players: newPlayers(),
} }
theContext = c theContext = c
@ -124,6 +130,13 @@ func (c *context) alsaPcmHwParams(sampleRate, channelNum int, bufferSize, period
} }
func (c *context) readAndWrite(buf32 []float32) error { func (c *context) readAndWrite(buf32 []float32) error {
c.cond.L.Lock()
defer c.cond.L.Unlock()
for c.suspended {
c.cond.Wait()
}
for i := range buf32 { for i := range buf32 {
buf32[i] = 0 buf32[i] = 0
} }
@ -147,6 +160,10 @@ func (c *context) readAndWrite(buf32 []float32) error {
} }
func (c *context) Suspend() error { func (c *context) Suspend() error {
c.cond.L.Lock()
defer c.cond.L.Unlock()
c.suspended = true
if c.supportsPause { if c.supportsPause {
if err := C.snd_pcm_pause(c.handle, 1); err < 0 { if err := C.snd_pcm_pause(c.handle, 1); err < 0 {
return alsaError(err) return alsaError(err)
@ -161,6 +178,13 @@ func (c *context) Suspend() error {
} }
func (c *context) Resume() error { func (c *context) Resume() error {
c.cond.L.Lock()
defer c.cond.L.Unlock()
defer func() {
c.suspended = false
c.cond.Signal()
}()
if c.supportsPause { if c.supportsPause {
if err := C.snd_pcm_pause(c.handle, 0); err < 0 { if err := C.snd_pcm_pause(c.handle, 0); err < 0 {
return alsaError(err) return alsaError(err)