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

//! Marker traits and types for [Pipeline](crate::pipeline::Pipeline).

use crate::{common::*, config::Config, pipeline_profile::PipelineProfile};

/// Marker trait for pipeline marker types.
pub trait PipelineState {
    #[doc(hidden)]
    unsafe fn unsafe_clone(&self) -> Self;
}

/// A marker type indicating the [Pipeline](crate::pipeline::Pipeline) is started.
#[derive(Debug)]
pub struct Active {
    pub profile: PipelineProfile,
    pub config: Option<Config>,
}

impl Active {
    pub fn into_raw_parts(self) -> (*mut sys::rs2_pipeline_profile, Option<*mut sys::rs2_config>) {
        let profile_ptr = unsafe { self.profile.unsafe_clone().into_raw() };
        let config_ptr = unsafe {
            self.config
                .as_ref()
                .map(|config| config.unsafe_clone().into_raw())
        };
        mem::forget(self);
        (profile_ptr, config_ptr)
    }

    pub unsafe fn from_raw_parts(
        profile_ptr: *mut sys::rs2_pipeline_profile,
        config_ptr: Option<*mut sys::rs2_config>,
    ) -> Self {
        Self {
            profile: PipelineProfile::from_raw(profile_ptr),
            config: config_ptr.map(|ptr| Config::from_raw(ptr)),
        }
    }
}

impl PipelineState for Active {
    unsafe fn unsafe_clone(&self) -> Self {
        Self {
            profile: self.profile.unsafe_clone(),
            config: self.config.as_ref().map(|config| config.unsafe_clone()),
        }
    }
}

/// A marker type indicating the [Pipeline](crate::pipeline::Pipeline) is stopped.
#[derive(Debug)]
pub struct Inactive;

impl PipelineState for Inactive {
    unsafe fn unsafe_clone(&self) -> Self {
        Self
    }
}