maolan-engine 0.2.25

Audio engine for the Maolan DAW with audio/MIDI tracks, routing, export, and out-of-process CLAP/VST3/LV2 plugin support
Documentation 
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
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129

use crate::message::HwMidiEvent;

pub trait HwWorkerDriver {
    fn cycle_samples(&self) -> usize;
    fn sample_rate(&self) -> i32;
    fn request_stop(&mut self) {}
    fn run_cycle_for_worker(&mut self) -> Result<(), String>;
    fn run_assist_step_for_worker(&mut self) -> Result<bool, String>;

    /// File descriptors for async I/O via kqueue/AsyncFd.
    /// When both return `Some`, the HW worker uses an async select loop
    /// instead of the blocking assist thread.
    #[cfg(unix)]
    fn capture_fd(&self) -> Option<std::os::fd::RawFd> {
        None
    }
    #[cfg(unix)]
    fn playback_fd(&self) -> Option<std::os::fd::RawFd> {
        None
    }
}

pub trait HwMidiHub {
    fn read_events_into(&mut self, out: &mut Vec<HwMidiEvent>);
    fn read_events_blocking_into(&mut self, out: &mut Vec<HwMidiEvent>) {
        self.read_events_into(out);
    }
    fn wait_ready_blocking(&mut self) -> Option<Vec<i32>> {
        None
    }
    fn read_events_for_fds(&mut self, _ready_fds: &[i32], out: &mut Vec<HwMidiEvent>) {
        self.read_events_into(out);
    }
    fn wake_input_waiter(&mut self) {}
    fn close_input_waiter(&mut self) {}
    fn write_events(&mut self, events: &[HwMidiEvent]);
}

pub trait HwDevice {
    fn input_channels(&self) -> usize;
    fn output_channels(&self) -> usize;
    fn sample_rate(&self) -> i32;
    fn latency_ranges(&self) -> ((usize, usize), (usize, usize));
}

#[macro_export]
macro_rules! impl_hw_worker_traits_for_driver {
    ($driver:ty) => {
        impl $crate::hw::traits::HwWorkerDriver for $driver {
            fn cycle_samples(&self) -> usize {
                self.cycle_samples()
            }

            fn sample_rate(&self) -> i32 {
                self.sample_rate()
            }

            fn run_cycle_for_worker(&mut self) -> Result<(), String> {
                self.channel().run_cycle().map_err(|e| e.to_string())
            }

            fn run_assist_step_for_worker(&mut self) -> Result<bool, String> {
                self.channel().run_assist_step().map_err(|e| e.to_string())
            }
        }
    };
}

#[macro_export]
macro_rules! impl_hw_device_for_driver {
    ($driver:ty) => {
        impl $crate::hw::traits::HwDevice for $driver {
            fn input_channels(&self) -> usize {
                self.input_channels()
            }

            fn output_channels(&self) -> usize {
                self.output_channels()
            }

            fn sample_rate(&self) -> i32 {
                self.sample_rate()
            }

            fn latency_ranges(&self) -> ((usize, usize), (usize, usize)) {
                self.latency_ranges()
            }
        }
    };
}

#[macro_export]
macro_rules! impl_hw_midi_hub_traits {
    ($hub:ty) => {
        impl $crate::hw::traits::HwMidiHub for $hub {
            fn read_events_into(&mut self, out: &mut Vec<$crate::message::HwMidiEvent>) {
                <$hub>::read_events_into(self, out);
            }

            fn read_events_blocking_into(&mut self, out: &mut Vec<$crate::message::HwMidiEvent>) {
                <$hub>::read_events_blocking_into(self, out);
            }

            fn wait_ready_blocking(&mut self) -> Option<Vec<i32>> {
                <$hub>::wait_ready_blocking(self)
            }

            fn read_events_for_fds(
                &mut self,
                ready_fds: &[i32],
                out: &mut Vec<$crate::message::HwMidiEvent>,
            ) {
                <$hub>::read_events_for_fds(self, ready_fds, out)
            }

            fn wake_input_waiter(&mut self) {
                <$hub>::wake_input_waiter(self);
            }

            fn close_input_waiter(&mut self) {
                <$hub>::close_input_waiter(self);
            }

            fn write_events(&mut self, events: &[$crate::message::HwMidiEvent]) {
                <$hub>::write_events(self, events);
            }
        }
    };
}