tauri-plugin-serialplugin 3.0.0

Tauri plugin for serial port access (desktop and Android).
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

//! Cancel in-flight exchange on physical or CMUX virtual ports.

use crate::cmux::CmuxSession;
use crate::port::tx_queue::PortTxQueue;
use std::sync::atomic::{AtomicBool, Ordering};
use std::sync::Arc;

/// Cancel in-flight exchange on a physical port (hub waiter + TX queue).
pub fn cancel_physical_exchange(
    exchange_cancel: &AtomicBool,
    tx_queue: &PortTxQueue,
    hub_cancel: impl FnOnce(),
) {
    exchange_cancel.store(true, Ordering::SeqCst);
    hub_cancel();
    tx_queue.cancel_all();
    tx_queue.clear_halt();
}

/// Cancel in-flight exchange on a CMUX virtual channel.
pub fn cancel_virtual_exchange(
    exchange_cancel: &AtomicBool,
    tx_queue: &PortTxQueue,
    session: &CmuxSession,
    dlci: u8,
) {
    exchange_cancel.store(true, Ordering::SeqCst);
    session.cancel_active_exchange(dlci);
    tx_queue.cancel_all();
    tx_queue.clear_halt();
}

/// Type-erased hub cancel callback for physical ports.
pub type HubCancelFn = Box<dyn FnOnce() + Send>;

/// Cancel physical exchange when hub cancel is optional (poisoned lock, etc.).
pub fn cancel_physical_exchange_optional(
    exchange_cancel: &Arc<AtomicBool>,
    tx_queue: &Arc<PortTxQueue>,
    hub_cancel: Option<HubCancelFn>,
) {
    exchange_cancel.store(true, Ordering::SeqCst);
    if let Some(cancel) = hub_cancel {
        cancel();
    }
    tx_queue.cancel_all();
    tx_queue.clear_halt();
}