0de8a60006
A more robust cycle aware event scheduling, to easily implement serial-io, dmg audio channels and improve accuracy. This brings a slight performance hit :/ I also ran dos2unix on some of the files :D Former-commit-id: 62f4ba33e3a083b7976d6512ba6f5720ec493aa0 Former-commit-id: a4b3a92cd1eb156bbe9fd0ef77fbb0e7a45660cb
66 lines
1.8 KiB
Rust
66 lines
1.8 KiB
Rust
use super::connector::AudioJNIConnector;
|
|
|
|
use std::sync::mpsc::{channel, Sender};
|
|
use std::thread;
|
|
use std::thread::JoinHandle;
|
|
|
|
use rustboyadvance_core::util::audio::Consumer;
|
|
|
|
use jni::JavaVM;
|
|
|
|
#[derive(Debug)]
|
|
#[allow(dead_code)]
|
|
pub enum AudioThreadCommand {
|
|
RenderAudio,
|
|
Pause,
|
|
Play,
|
|
Terminate,
|
|
}
|
|
|
|
pub(crate) fn spawn_audio_worker_thread(
|
|
audio_connector: AudioJNIConnector,
|
|
jvm: JavaVM,
|
|
mut consumer: Consumer<i16>,
|
|
) -> (JoinHandle<AudioJNIConnector>, Sender<AudioThreadCommand>) {
|
|
let (tx, rx) = channel();
|
|
|
|
let handle = thread::spawn(move || {
|
|
info!("[AudioWorker] spawned!");
|
|
|
|
info!("[AudioWorker] Attaching JVM");
|
|
let env = jvm.attach_current_thread().unwrap();
|
|
|
|
loop {
|
|
let command = rx.recv().unwrap();
|
|
match command {
|
|
AudioThreadCommand::Pause => {
|
|
info!("[AudioWorker] - got {:?} command", command);
|
|
audio_connector.pause(&env);
|
|
}
|
|
|
|
AudioThreadCommand::Play => {
|
|
info!("[AudioWorker] - got {:?} command", command);
|
|
audio_connector.play(&env);
|
|
}
|
|
|
|
AudioThreadCommand::RenderAudio => {
|
|
let mut samples = [0; 4096 * 2]; // TODO is this memset expansive ?
|
|
let count = consumer.pop_slice(&mut samples);
|
|
|
|
audio_connector.write_audio_samples(&env, &samples[0..count]);
|
|
}
|
|
AudioThreadCommand::Terminate => {
|
|
info!("[AudioWorker] - got terminate command!");
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
info!("[AudioWorker] terminating");
|
|
|
|
// return the audio connector back
|
|
audio_connector
|
|
});
|
|
|
|
(handle, tx)
|
|
}
|