mth/ebiten
1
0
Fork 0
mirror of https://github.com/hajimehoshi/ebiten.git synced 2024-11-10 04:57:26 +01:00
Code Issues Packages Projects Releases Wiki Activity

audio/internal/go2cpp: Simplify reading the source

Browse Source
This commit is contained in:
Hajime Hoshi 2021-05-10 04:00:58 +09:00
parent 9585c1e09a
commit 9b965a6308
1 changed files with 11 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
audio/internal/go2cpp/player_js.go
View File

@ -213,7 +213,10 @@ func (p *Player) Close() error {
func (p *Player) close(remove bool) error {
p.cond.L.Lock()
defer p.cond.L.Unlock()
return p.closeImpl(remove)
}
func (p *Player) closeImpl(remove bool) error {
if p.state == playerStateClosed {
return p.err
}
@ -271,12 +274,6 @@ func (p *Player) waitUntilUnpaused() bool {
return p.v.Truthy() && p.state == playerStatePlaying
}
func (p *Player) write(dst js.Value, src []byte) {
p.cond.L.Lock()
defer p.cond.L.Unlock()
p.writeImpl(dst, src)
}
func (p *Player) writeImpl(dst js.Value, src []byte) {
if p.state == playerStateClosed {
return
@ -300,22 +297,22 @@ func (p *Player) loop() {
return
}
n := readChunkSize
if max := p.context.MaxBufferSize() - p.UnplayedBufferSize(); n > max {
n = max
}
n2, err := p.src.Read(buf[:n])
p.cond.L.Lock()
n, err := p.src.Read(buf)
if err != nil && err != io.EOF {
p.setError(err)
p.setErrorImpl(err)
p.cond.L.Unlock()
return
}
if n > 0 {
p.write(dst, buf[:n2])
p.writeImpl(dst, buf[:n])
}
if err == io.EOF {
p.close(false)
p.closeImpl(false)
p.cond.L.Unlock()
return
}
p.cond.L.Unlock()
}
}