1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
|
//! The `audio` crate stores all audio assets that need to be loaded during runtime
use raylib::audio::RaylibAudio;
use std::{
collections::BinaryHeap,
rc::Rc,
sync::atomic::Ordering,
time::{Duration, Instant},
};
use channel::Device;
use crate::{
channel::Channels,
program::{Program, Track},
};
mod channel;
mod parse;
pub mod program;
/// The `Error` type used within this crate
pub type Error = Box<dyn std::error::Error>;
/// The `Result` type used witin this crate
pub type Result<T> = std::result::Result<T, crate::Error>;
const AUDIO_FPS: u32 = 60;
const TIME_SLICE: Duration = Duration::from_millis(1000 / AUDIO_FPS as u64);
/// The `Audio` container initalizes the audio subsystem
/// for raylib, leaks it (to gurentee audio is statically loaded),
/// then loads all needed audio samples
pub struct Audio {
device: Device<'static>,
last: Instant,
queue: BinaryHeap<Program>,
}
impl Audio {
pub fn load() -> crate::Result<Self> {
// Phantom handle to the raylib audio subsystem
// Raylib doesnt use a handle, but the rust bindings
// have one to ensure memory safety.
//
// We must leak this handle after allocating it,
// if we dont then all audio will be unloaded :(
//
// NOTE: would this cause issues if `Audio::load` was
// called multiple times?
let handle = Box::leak(Box::new(RaylibAudio::init_audio_device()?));
let device = Device::load(handle)?;
let last = Instant::now();
let queue = BinaryHeap::new();
Ok(Self {
device,
last,
queue,
})
}
pub fn schedule(&mut self, track: Rc<Track>, priority: u32, looping: bool) {
let program = Program::new(track, priority, looping);
self.queue.push(program);
}
pub fn clear(&mut self) {
self.queue.clear();
}
pub fn update(&mut self) {
if self.last.elapsed() >= TIME_SLICE {
let res_opt = self
.queue
.peek_mut()
.map(|mut program| (program.exec(), program.is_finished()));
let channels = match res_opt {
Some((res, finished)) => {
if finished {
self.queue.pop();
}
res
}
// make the output quiet!
None => Channels::default(),
};
self.device.channels.store(channels, Ordering::Relaxed);
self.last = Instant::now();
}
}
}
|
