Mirrors/rodio
2
0
Fork 0
mirror of https://github.com/RustAudio/rodio synced 2024-12-14 06:02:31 +00:00
Code Issues Projects Releases Packages Wiki Activity

Initialize each new voice with one period of 0s

Browse source
This commit is contained in:
Pierre Krieger 2015-09-27 13:31:51 +02:00
parent 8503bc2f8a
commit ac3b7c964a
1 changed files with 22 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
src/engine.rs
View file

@ -204,7 +204,26 @@ fn background(rx: Receiver<Command>) {
// polling for new commands // polling for new commands
if let Ok(command) = rx.try_recv() { if let Ok(command) = rx.try_recv() {
match command { match command {
Command::Play(endpoint, new_voice, decoder, remaining_duration_ms) => { Command::Play(endpoint, mut new_voice, decoder, remaining_duration_ms) => {
if let Some(ref mut new_voice) = new_voice {
// we initialize the new voice by writing one period of 0s,
// so that we are always one period ahead of time
let period = new_voice.get_period();
let mut buffer = new_voice.append_data(period);
match buffer {
UnknownTypeBuffer::U16(ref mut buffer) => {
for o in buffer.iter_mut() { *o = 32768; }
},
UnknownTypeBuffer::I16(ref mut buffer) => {
for o in buffer.iter_mut() { *o = 0; }
},
UnknownTypeBuffer::F32(ref mut buffer) => {
for o in buffer.iter_mut() { *o = 0.0; }
},
}
}
let mut entry = voices.entry(endpoint.get_name()).or_insert_with(|| { let mut entry = voices.entry(endpoint.get_name()).or_insert_with(|| {
(new_voice.unwrap(), Vec::new()) (new_voice.unwrap(), Vec::new())
}); });
@ -252,8 +271,8 @@ fn background(rx: Receiver<Command>) {
let mut buffer = { let mut buffer = {
let samples_to_write = voice.get_samples_rate().0 * voice.get_channels() as u32 * FIXED_STEP_MS / 1000; let samples_to_write = voice.get_samples_rate().0 * voice.get_channels() as u32 * FIXED_STEP_MS / 1000;
let samples_to_write = cmp::max(samples_to_write, voice.get_period() as u32); let samples_to_write = cmp::max(samples_to_write as usize, voice.get_period());
voice.append_data(samples_to_write as usize) voice.append_data(samples_to_write)
}; };
match buffer { match buffer {