alex/agb
1
0
Fork 0
mirror of https://github.com/italicsjenga/agb.git synced 2024-12-23 08:11:33 +11:00
Code Issues Packages Projects Releases Wiki Activity

Extract methods

Browse source
This commit is contained in:
Gwilym Inzani 2023-07-16 20:55:28 +01:00
parent 938f05f8d1
commit d929a1689a
1 changed files with 68 additions and 61 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

129
agb/src/sound/mixer/sw_mixer.rs
View file

@ -1,5 +1,6 @@
use core::cell::RefCell; use core::cell::RefCell;
use core::marker::PhantomData; use core::marker::PhantomData;
use core::ops::ControlFlow;
use core::pin::Pin; use core::pin::Pin;
use alloc::boxed::Box; use alloc::boxed::Box;
@ -417,68 +418,9 @@ impl MixerBuffer {
for channel in channels.filter(|channel| !channel.is_done) { for channel in channels.filter(|channel| !channel.is_done) {
if channel.volume != 0.into() { if channel.volume != 0.into() {
if channel.is_stereo { if channel.is_stereo {
if (channel.pos + 2 * self.frequency.buffer_size() as u32).floor() self.write_stereo(channel, working_buffer);
>= channel.data.len() as u32
{
if channel.should_loop {
channel.pos = 0.into();
} else {
channel.is_done = true;
continue;
}
}
unsafe {
agb_rs__mixer_add_stereo(
channel.data.as_ptr().add(channel.pos.floor() as usize),
working_buffer.as_mut_ptr(),
channel.volume,
self.frequency.buffer_size(),
);
}
channel.pos += 2 * self.frequency.buffer_size() as u32;
} else { } else {
let right_amount = ((channel.panning + 1) / 2) * channel.volume; self.write_mono(channel, working_buffer);
let left_amount = ((-channel.panning + 1) / 2) * channel.volume;
let channel_len = Num::<u32, 8>::new(channel.data.len() as u32);
let mut playback_speed = channel.playback_speed;
while playback_speed >= channel_len {
playback_speed -= channel_len;
}
// SAFETY: always aligned correctly by construction
let working_buffer_i32: &mut [i32] = unsafe {
core::slice::from_raw_parts_mut(
working_buffer.as_mut_ptr().cast(),
working_buffer.len() / 2,
)
};
let mul_amount = ((left_amount.to_raw() as i32) << 16)
| (right_amount.to_raw() as i32 & 0x0000ffff);
'outer: for i in 0..self.frequency.buffer_size() {
if channel.pos >= channel_len {
if channel.should_loop {
channel.pos -= channel_len;
} else {
channel.is_done = true;
break 'outer;
}
}
// SAFETY: channel.pos < channel_len by the above if statement and the fact we reduce the playback speed
let value =
unsafe { *channel.data.get_unchecked(channel.pos.floor() as usize) }
as i8 as i32;
// SAFETY: working buffer length = self.frequency.buffer_size()
unsafe { *working_buffer_i32.get_unchecked_mut(i) += value * mul_amount };
channel.pos += playback_speed;
}
} }
} }
} }
@ -493,6 +435,71 @@ impl MixerBuffer {
); );
} }
} }
fn write_stereo(&self, channel: &mut SoundChannel, working_buffer: &mut [Num<i16, 4>]) {
if (channel.pos + 2 * self.frequency.buffer_size() as u32).floor()
>= channel.data.len() as u32
{
if channel.should_loop {
channel.pos = 0.into();
} else {
channel.is_done = true;
return;
}
}
unsafe {
agb_rs__mixer_add_stereo(
channel.data.as_ptr().add(channel.pos.floor() as usize),
working_buffer.as_mut_ptr(),
channel.volume,
self.frequency.buffer_size(),
);
}
channel.pos += 2 * self.frequency.buffer_size() as u32;
}
fn write_mono(&self, channel: &mut SoundChannel, working_buffer: &mut [Num<i16, 4>]) {
let right_amount = ((channel.panning + 1) / 2) * channel.volume;
let left_amount = ((-channel.panning + 1) / 2) * channel.volume;
let channel_len = Num::<u32, 8>::new(channel.data.len() as u32);
let mut playback_speed = channel.playback_speed;
while playback_speed >= channel_len {
playback_speed -= channel_len;
}
// SAFETY: always aligned correctly by construction
let working_buffer_i32: &mut [i32] = unsafe {
core::slice::from_raw_parts_mut(
working_buffer.as_mut_ptr().cast(),
working_buffer.len() / 2,
)
};
let mul_amount =
((left_amount.to_raw() as i32) << 16) | (right_amount.to_raw() as i32 & 0x0000ffff);
'outer: for i in 0..self.frequency.buffer_size() {
if channel.pos >= channel_len {
if channel.should_loop {
channel.pos -= channel_len;
} else {
channel.is_done = true;
break 'outer;
}
}
// SAFETY: channel.pos < channel_len by the above if statement and the fact we reduce the playback speed
let value =
unsafe { *channel.data.get_unchecked(channel.pos.floor() as usize) } as i8 as i32;
// SAFETY: working buffer length = self.frequency.buffer_size()
unsafe { *working_buffer_i32.get_unchecked_mut(i) += value * mul_amount };
channel.pos += playback_speed;
}
}
} }
#[cfg(test)] #[cfg(test)]