astrotools 0.11.0

Basic building block for the lightspeed protocol and lightspeed compliant drivers
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

use std::sync::mpsc::Receiver;
use std::sync::{
    atomic::{AtomicBool, Ordering},
    Arc,
};

/// Exposure state machine for imaging devices (CCDs, CMOSes).
///
/// Embed this in device structs. In `tick()`, skip `sync_state()` while
/// `ReadingOut` to avoid USB contention errors during frame transfer.
pub enum ExposureState {
    Idle,
    /// Exposure in progress. `done` is set to `true` (Release ordering) by
    /// the monitor thread when the hardware signals completion.
    Exposing {
        done: Arc<AtomicBool>,
    },
    /// USB readout in progress. `rx` receives `(frame_bytes, pixel_count)`.
    ReadingOut {
        rx: Receiver<(Vec<u8>, usize)>,
    },
}

impl Default for ExposureState {
    fn default() -> Self {
        ExposureState::Idle
    }
}

impl ExposureState {
    pub fn is_idle(&self) -> bool {
        matches!(self, ExposureState::Idle)
    }

    pub fn is_exposing(&self) -> bool {
        matches!(self, ExposureState::Exposing { .. })
    }

    pub fn is_reading_out(&self) -> bool {
        matches!(self, ExposureState::ReadingOut { .. })
    }

    /// Returns `true` if the exposure monitor thread has signalled completion.
    /// Only meaningful when in the `Exposing` state.
    pub fn exposure_done(&self) -> bool {
        match self {
            ExposureState::Exposing { done } => done.load(Ordering::Acquire),
            _ => false,
        }
    }
}