audio: Refactoring

This commit is contained in:
Hajime Hoshi 2015-01-24 14:50:41 +09:00
parent b57c675996
commit edda664ca8
4 changed files with 111 additions and 97 deletions

View File

@ -22,10 +22,13 @@ func SampleRate() int {
return audio.SampleRate return audio.SampleRate
} }
// TODO: better name
func AppendToBuffer(channel int, l []float32, r []float32) bool { func AppendToBuffer(channel int, l []float32, r []float32) bool {
return audio.Append(channel, l, r) return audio.Append(channel, l, r)
} }
// TODO: Add funciton to append samples to the buffer without adjusting.
// TODO: better name // TODO: better name
func CurrentTime() int { func CurrentTime() int {
return audio.CurrentBytes() return audio.CurrentBytes()

View File

@ -12,30 +12,101 @@
// See the License for the specific language governing permissions and // See the License for the specific language governing permissions and
// limitations under the License. // limitations under the License.
// +build !js
package audio package audio
const bufferSize = 1024
const SampleRate = 44100 const SampleRate = 44100
var nextInsertion = 0
var currentBytes = 0
type channel struct {
l []float32
r []float32
}
var channels = make([]*channel, 16)
func init() {
for i, _ := range channels {
channels[i] = &channel{
l: []float32{},
r: []float32{},
}
}
}
func Init() { func Init() {
// TODO: Implement initialize()
} }
func Start() { func Start() {
// TODO: Implement start()
} }
func Append(channel int, l []float32, r []float32) bool { func Append(channel int, l []float32, r []float32) bool {
// TODO: Implement // TODO: Mutex (especially for OpenAL)
return false if len(l) != len(r) {
panic("len(l) must equal to len(r)")
}
ch := channelAt(channel)
if ch == nil {
return false
}
ch.l = append(ch.l, make([]float32, nextInsertion-len(ch.l))...)
ch.r = append(ch.r, make([]float32, nextInsertion-len(ch.r))...)
ch.l = append(ch.l, l...)
ch.r = append(ch.r, r...)
return true
} }
func CurrentBytes() int { func CurrentBytes() int {
// TODO: Implement return currentBytes + nextInsertion
return 0
} }
func Update() { func Update() {
// TODO: Implement nextInsertion += SampleRate / 60
}
func channelAt(i int) *channel {
if i == -1 {
for _, ch := range channels {
if len(ch.l) <= nextInsertion {
return ch
}
}
return nil
}
ch := channels[i]
if len(ch.l) <= nextInsertion {
return ch
}
return nil
}
func min(a, b int) int {
if a < b {
return a
}
return b
}
func loadChannelBuffers() (l, r []float32) {
inputL := make([]float32, bufferSize)
inputR := make([]float32, bufferSize)
for _, ch := range channels {
if len(ch.l) == 0 {
continue
}
l := min(len(ch.l), bufferSize)
for i := 0; i < l; i++ {
inputL[i] += ch.l[i]
inputR[i] += ch.r[i]
}
// TODO: Use copyFromChannel?
usedLen := min(bufferSize, len(ch.l))
ch.l = ch.l[usedLen:]
ch.r = ch.r[usedLen:]
}
return inputL, inputR
} }

View File

@ -24,41 +24,7 @@ import (
var node js.Object var node js.Object
var context js.Object var context js.Object
const bufferSize = 1024 func initialize() {
const SampleRate = 44100
var nextInsertion = 0
type channel struct {
l []float32
r []float32
}
var channels = make([]*channel, 16)
func init() {
for i, _ := range channels {
channels[i] = &channel{
l: []float32{},
r: []float32{},
}
}
}
func min(a, b int) int {
if a < b {
return a
}
return b
}
var currentBytes = 0
func CurrentBytes() int {
return currentBytes + nextInsertion
}
func Init() {
context = js.Global.Get("AudioContext").New() context = js.Global.Get("AudioContext").New()
// TODO: ScriptProcessorNode will be replaced with Audio WebWorker. // TODO: ScriptProcessorNode will be replaced with Audio WebWorker.
// https://developer.mozilla.org/ja/docs/Web/API/ScriptProcessorNode // https://developer.mozilla.org/ja/docs/Web/API/ScriptProcessorNode
@ -70,22 +36,7 @@ func Init() {
l := e.Get("outputBuffer").Call("getChannelData", 0) l := e.Get("outputBuffer").Call("getChannelData", 0)
r := e.Get("outputBuffer").Call("getChannelData", 1) r := e.Get("outputBuffer").Call("getChannelData", 1)
inputL := make([]float32, bufferSize) inputL, inputR := loadChannelBuffers()
inputR := make([]float32, bufferSize)
for _, ch := range channels {
if len(ch.l) == 0 {
continue
}
l := min(len(ch.l), bufferSize)
for i := 0; i < l; i++ {
inputL[i] += ch.l[i]
inputR[i] += ch.r[i]
}
// TODO: Use copyFromChannel?
usedLen := min(bufferSize, len(ch.l))
ch.l = ch.l[usedLen:]
ch.r = ch.r[usedLen:]
}
nextInsertion -= min(bufferSize, nextInsertion) nextInsertion -= min(bufferSize, nextInsertion)
for i := 0; i < bufferSize; i++ { for i := 0; i < bufferSize; i++ {
// TODO: Use copyFromChannel? // TODO: Use copyFromChannel?
@ -100,43 +51,7 @@ func Init() {
}) })
} }
func Update() { func start() {
nextInsertion += SampleRate / 60
}
func Start() {
// TODO: For iOS, node should be connected with a buffer node. // TODO: For iOS, node should be connected with a buffer node.
node.Call("connect", context.Get("destination")) node.Call("connect", context.Get("destination"))
} }
func channelAt(i int) *channel {
if i == -1 {
for _, ch := range channels {
if len(ch.l) <= nextInsertion {
return ch
}
}
return nil
}
ch := channels[i]
if len(ch.l) <= nextInsertion {
return ch
}
return nil
}
func Append(i int, l []float32, r []float32) bool {
// TODO: Mutex (especially for OpenAL)
if len(l) != len(r) {
panic("len(l) must equal to len(r)")
}
ch := channelAt(i)
if ch == nil {
return false
}
ch.l = append(ch.l, make([]float32, nextInsertion-len(ch.l))...)
ch.r = append(ch.r, make([]float32, nextInsertion-len(ch.r))...)
ch.l = append(ch.l, l...)
ch.r = append(ch.r, r...)
return true
}

View File

@ -0,0 +1,25 @@
// Copyright 2015 Hajime Hoshi
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
// +build !js
package audio
func initialize() {
// TODO: Implement
}
func start() {
// TODO: Implement
}