e_midi_shared 0.1.5

Shared types/midi/MusicXML logic for e_midi and its build script.
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

//! Inter-process communication module using iceoryx2
//!
//! This module provides lock-free, zero-copy communication between the MIDI player
//! and other applications in the e_* ecosystem (e_grid, state server, etc.)

pub mod events;
pub mod music_sync_publisher;
pub mod music_sync_subscriber;
pub mod publisher;
pub mod service;
pub mod subscriber;
pub mod types;

pub use crate::ipc::types::*;
pub use events::*;
pub use music_sync_publisher::*;
pub use music_sync_subscriber::*;
pub use publisher::*;
pub use service::*;
pub use subscriber::*;

use std::error::Error;
use std::fmt;

impl fmt::Display for IpcError {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        match self {
            IpcError::NodeCreation(msg) => write!(f, "Node creation failed: {}", msg),
            IpcError::ServiceCreation(msg) => write!(f, "Service creation failed: {}", msg),
            IpcError::PublisherCreation(msg) => write!(f, "Publisher creation failed: {}", msg),
            IpcError::SubscriberCreation(msg) => write!(f, "Subscriber creation failed: {}", msg),
            IpcError::SendError(msg) => write!(f, "Send failed: {}", msg),
            IpcError::ReceiveError(msg) => write!(f, "Receive failed: {}", msg),
            IpcError::SerializationError(msg) => write!(f, "Serialization failed: {}", msg),
            IpcError::DeserializationError(msg) => write!(f, "Deserialization failed: {}", msg),
            IpcError::PayloadTooLarge(msg) => write!(f, "Payload too large: {}", msg),
        }
    }
}

impl Error for IpcError {}

use crate::ipc::events::IpcEventSender;
use once_cell::sync::OnceCell;

pub static IPC_EVENT_SENDER: OnceCell<IpcEventSender> = OnceCell::new();
pub const EMIDI_EVENTS_SERVICE: &str = "e_midi_events";