aetherdsp-core 0.1.1

Hard real-time modular DSP engine — lock-free graph scheduler, generational arena, and buffer pool
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

//! Lock-free command protocol between the control thread and the RT audio thread.
//!
//! Commands are sent via an SPSC ring buffer. The RT thread drains up to
//! MAX_COMMANDS_PER_TICK per callback, bounding mutation cost.

use crate::{arena::NodeId, param::Param};
use serde::{Deserialize, Serialize};

/// All mutations the control thread can request.
#[derive(Debug, Clone)]
pub enum Command {
    /// Add a new node.
    AddNode { id: NodeId },

    /// Remove a node and release its buffer.
    RemoveNode { id: NodeId },

    /// Connect output of `src` to input slot `slot` of `dst`.
    Connect { src: NodeId, dst: NodeId, slot: usize },

    /// Disconnect input slot `slot` of `dst`.
    Disconnect { dst: NodeId, slot: usize },

    /// Update a parameter with a new smoothed value.
    UpdateParam { node: NodeId, param_index: usize, new_param: Param },

    /// Swap the output node.
    SetOutputNode { id: NodeId },

    /// Mute / unmute all audio output.
    SetMute { muted: bool },

    /// Remove all nodes and edges — silence the graph.
    ClearGraph,
}

/// Serializable graph description for UI ↔ host communication.
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct GraphSnapshot {
    pub nodes: Vec<NodeSnapshot>,
    pub edges: Vec<EdgeSnapshot>,
}

#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct NodeSnapshot {
    pub id: u32,
    pub generation: u32,
    pub node_type: String,
    pub params: Vec<f32>,
}

#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct EdgeSnapshot {
    pub src_id: u32,
    pub dst_id: u32,
    pub slot: usize,
}